calendar.go 23 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615
  1. package roadshow
  2. import (
  3. "github.com/beego/beego/v2/client/orm"
  4. "github.com/rdlucklib/rdluck_tools/paging"
  5. "hongze/hongze_mobile_admin/models/tables/admin"
  6. "time"
  7. )
  8. type AddActivityReq struct {
  9. ActivityType string `description:"活动类型"`
  10. RoadshowType string `description:"路演形式"`
  11. RoadshowPlatform string `description:"路演平台"`
  12. CompanyId int `description:"客户id"`
  13. CompanyName string `description:"客户名称"`
  14. Province string `description:"省"`
  15. ProvinceCode string `description:"省编码"`
  16. City string `description:"市"`
  17. CityCode string `description:"市编码"`
  18. Theme string `description:"会议主题"`
  19. CooperationName string `description:"合作方名称"`
  20. ActivityCategory string `description:"活动类别"`
  21. ResearcherList []*CalendarResearcher
  22. EnglishCompany int `description:"是否为英文客户"`
  23. }
  24. type CalendarResearcher struct {
  25. ResearcherId int `description:"研究员id"`
  26. ResearcherName string `description:"研究员名称"`
  27. StartDate string `description:"开始日期"`
  28. EndDate string `description:"结束日期"`
  29. StartTime string `description:"开始时间"`
  30. EndTime string `description:"结束时间"`
  31. StartWeek string `description:"开始日期对应周"`
  32. EndWeek string `description:"结束日期对应周"`
  33. }
  34. type RsCalendar struct {
  35. RsCalendarId int `orm:"column(rs_calendar_id);pk"`
  36. SysUserId int `description:"创建人id"`
  37. SysUserRealName string `description:"创建人名称"`
  38. ActivityType string `description:"活动类型"`
  39. RoadshowType string `description:"路演形式"`
  40. RoadshowPlatform string `description:"路演平台"`
  41. CompanyId int `description:"客户id"`
  42. CompanyName string `description:"客户名称"`
  43. Province string `description:"省"`
  44. ProvinceCode string `description:"省编码"`
  45. City string `description:"市"`
  46. CityCode string `description:"市编码"`
  47. Theme string `description:"会议主题"`
  48. CooperationName string `description:"合作方名称"`
  49. Title string `description:"展示在日历的标题"`
  50. Source int8 `description:"来源,0:自系统,1:上海方的"`
  51. CreateTime time.Time
  52. ModifyTime time.Time
  53. ActivityCategory string `description:"活动类别"`
  54. IsSynced int `description:"是否与上海同步 0:未同步 1:已同步"`
  55. UnionCode string `description:"公开会议联合编码"`
  56. EnglishCompany int `description:"是否为英文客户: 0-否; 1-是"`
  57. }
  58. type RsCalendarResearcher struct {
  59. RsCalendarResearcherId int `orm:"column(rs_calendar_researcher_id);pk"`
  60. RsCalendarId int `description:"日历活动id"`
  61. ResearcherId int `description:"研究员id"`
  62. ResearcherName string `description:"研究员名称"`
  63. StartDate string `description:"开始日期"`
  64. EndDate string `description:"结束日期"`
  65. StartTime string `description:"开始时间"`
  66. EndTime string `description:"结束时间"`
  67. StartWeek string `description:"开始日期对应周"`
  68. EndWeek string `description:"结束日期对应周"`
  69. CreateTime time.Time
  70. ModifyTime time.Time
  71. Status int `description:"状态:1:待接受,2:已接受,3:已拒绝,4:已删除,5:已撤回,6:已结束"`
  72. RefuseReason string `description:"拒绝理由"`
  73. RefuseTime time.Time `description:"拒绝时间"`
  74. DeleteReason string `description:"删除理由"`
  75. DeleteTime time.Time `description:"删除时间"`
  76. ApproveTime time.Time `description:"接受时间"`
  77. IsSynced int `description:"是否与上海同步 0:未同步 1:已同步"`
  78. ResearcherSort int `description:"研究员新增排序"`
  79. }
  80. func GetRsCalendarById(rsCalendarId int) (item *RsCalendar, err error) {
  81. o := orm.NewOrm()
  82. sql := `SELECT * FROM rs_calendar WHERE rs_calendar_id=? `
  83. err = o.Raw(sql, rsCalendarId).QueryRow(&item)
  84. return
  85. }
  86. func GetRsCalendarResearcherById(rsCalendarResearcherId int) (item *RsCalendarResearcher, err error) {
  87. o := orm.NewOrm()
  88. sql := `SELECT * FROM rs_calendar_researcher WHERE rs_calendar_researcher_id=? `
  89. err = o.Raw(sql, rsCalendarResearcherId).QueryRow(&item)
  90. return
  91. }
  92. func GetRsCalendarResearcherListById(rsCalendarId int) (item []*RsCalendarResearcher, err error) {
  93. o := orm.NewOrm()
  94. sql := `SELECT * FROM rs_calendar_researcher WHERE rs_calendar_id=? `
  95. _, err = o.Raw(sql, rsCalendarId).QueryRows(&item)
  96. return
  97. }
  98. func GetRsCalendarResearcherListByCalendarResearcherId(rsCalendarResearcherId int) (item []*RsCalendarResearcher, err error) {
  99. o := orm.NewOrm()
  100. sql := `SELECT * FROM rs_calendar_researcher WHERE rs_calendar_researcher_id=? `
  101. _, err = o.Raw(sql, rsCalendarResearcherId).QueryRows(&item)
  102. return
  103. }
  104. type Researcher struct {
  105. AdminId int `description:"研究员id"`
  106. RealName string `description:"研究员名称"`
  107. GroupId int `description:"分组id"`
  108. GroupName string `description:"分组名称"`
  109. RoleTypeCode string `description:"角色编码"`
  110. }
  111. type ResearcherGroup struct {
  112. GroupId int `description:"分组id"`
  113. GroupName string `description:"分组名称"`
  114. ResearcherList []*Researcher
  115. }
  116. type CalendarListView struct {
  117. RsCalendarId int `orm:"column(rs_calendar_id);pk"`
  118. SysUserId int `description:"创建人id"`
  119. SysUserRealName string `description:"创建人名称"`
  120. ActivityType string `description:"活动类型"`
  121. RoadshowType string `description:"路演形式"`
  122. RoadshowPlatform string `description:"路演平台"`
  123. CompanyId int `description:"客户id"`
  124. CompanyName string `description:"客户名称"`
  125. CompanyStatus string `description:"客户状态"`
  126. RsCalendarResearcherId int `description:"活动研究员id"`
  127. ResearcherId string `description:"研究员id"`
  128. ResearcherName string `description:"研究员名称"`
  129. StartDate string `description:"开始日期"`
  130. EndDate string `description:"结束日期"`
  131. StartTime string `description:"开始时间"`
  132. EndTime string `description:"结束时间"`
  133. StartWeek string `description:"开始日期对应周"`
  134. EndWeek string `description:"结束日期对应周"`
  135. CreateTime time.Time
  136. ModifyTime time.Time
  137. Status int `description:"状态:1:待接受,2:已接受,3:已拒绝,4:已删除,5:已撤回"`
  138. RefuseReason string `description:"拒绝理由"`
  139. RefuseTime time.Time `description:"拒绝时间"`
  140. DeleteReason string `description:"删除原因"`
  141. Province string `description:"省"`
  142. ProvinceCode string `description:"省编码"`
  143. City string `description:"市"`
  144. CityCode string `description:"市编码"`
  145. Theme string `description:"会议主题"`
  146. CooperationName string `description:"合作方名称"`
  147. ActivityCategory string `description:"活动类别"`
  148. Source int `description:"来源,0:自系统,1:上海方的"`
  149. Title string `description:"活动标题"`
  150. EnglishCompany int `description:"是否为英文客户: 0-否; 1-是"`
  151. EnglishCountry string `description:"英文客户-国家"`
  152. EnglishViewTotal int `description:"英文客户-累计点击量"`
  153. }
  154. type CalendarListResp struct {
  155. Paging *paging.PagingItem
  156. List []*CalendarListView
  157. }
  158. func GetCalendarListCount(condition string, pars []interface{}) (count int, err error) {
  159. o := orm.NewOrm()
  160. sql := `SELECT COUNT(1) AS count FROM rs_calendar AS a
  161. INNER JOIN rs_calendar_researcher AS b ON a.rs_calendar_id=b.rs_calendar_id
  162. WHERE 1=1 `
  163. if condition != "" {
  164. sql += condition
  165. }
  166. err = o.Raw(sql, pars).QueryRow(&count)
  167. return
  168. }
  169. func GetCalendarList(condition string, pars []interface{}, status int, pageLimit ...int) (list []*CalendarListView, err error) {
  170. o := orm.NewOrm()
  171. sql := `SELECT * FROM rs_calendar AS a
  172. INNER JOIN rs_calendar_researcher AS b ON a.rs_calendar_id=b.rs_calendar_id
  173. `
  174. if condition != "" {
  175. sql += condition
  176. }
  177. if status == 1 {
  178. sql += ` ORDER BY b.create_time ASC LIMIT ?,? `
  179. } else {
  180. sql += ` ORDER BY b.create_time DESC LIMIT ?,? `
  181. }
  182. _, err = o.Raw(sql, pars, pageLimit).QueryRows(&list)
  183. return
  184. }
  185. type AcceptReq struct {
  186. RsCalendarId int `description:"日历活动id"`
  187. RsCalendarResearcherId int `description:"活动研究员id"`
  188. }
  189. type DeleteReq struct {
  190. RsCalendarId int `description:"日历活动id"`
  191. RsCalendarResearcherId int `description:"活动研究员id"`
  192. DeleteReason string `description:"删除原因"`
  193. }
  194. type RefuseReq struct {
  195. RsCalendarId int `description:"日历活动id"`
  196. RsCalendarResearcherId int `description:"活动研究员id"`
  197. RefuseReason string `description:"拒绝原因"`
  198. }
  199. // 更新
  200. func UpdateCalendarResearcher(where, updateParams map[string]interface{}) error {
  201. o := orm.NewOrm()
  202. ptrStructOrTableName := "rs_calendar_researcher"
  203. qs := o.QueryTable(ptrStructOrTableName)
  204. for expr, exprV := range where {
  205. qs = qs.Filter(expr, exprV)
  206. }
  207. _, err := qs.Update(updateParams)
  208. return err
  209. }
  210. // 更新
  211. func UpdateCalendarResearcherFromSH(item *RsCalendarResearcher) error {
  212. o := orm.NewOrm()
  213. _, err := o.Update(item, "")
  214. return err
  215. }
  216. type AddMattersReq struct {
  217. StartDate string `description:"开始日期"`
  218. EndDate string `description:"结束日期"`
  219. StartTime string `description:"开始时间"`
  220. EndTime string `description:"结束时间"`
  221. StartWeek string `description:"开始日期周"`
  222. EndWeek string `description:"结束日期周"`
  223. MatterContent string `description:"事项内容"`
  224. }
  225. type RsMatters struct {
  226. RsMattersId int `orm:"column(rs_matters_id);pk"`
  227. SysUserId int `description:"添加事项人id"`
  228. SysUserRealName string `description:"创建人姓名"`
  229. StartDate string `description:"开始日期"`
  230. EndDate string `description:"结束日期"`
  231. StartTime string `description:"开始时间"`
  232. EndTime string `description:"结束时间"`
  233. StartWeek string `description:"开始日期周"`
  234. EndWeek string `description:"结束日期周"`
  235. MatterContent string `description:"事项内容"`
  236. Status int8 `description:"状态:1:进行中,6:已结束"`
  237. CreateTime time.Time `description:"创建时间"`
  238. ModifyTime time.Time `description:"修改时间"`
  239. IsSynced int `description:"是否与上海同步 0:未同步 1:已同步"`
  240. EditReason string `description:"修改原因"`
  241. IsSeller int `description:"是否为销售事项: 0-否; 1-是"`
  242. }
  243. type UpdateMattersReq struct {
  244. RsMattersId int `orm:"column(rs_matters_id);pk"`
  245. StartDate string `description:"开始日期"`
  246. EndDate string `description:"结束日期"`
  247. StartTime string `description:"开始时间"`
  248. EndTime string `description:"结束时间"`
  249. StartWeek string `description:"开始日期周"`
  250. EndWeek string `description:"结束日期周"`
  251. MatterContent string `description:"事项内容"`
  252. EditReason string `description:"修改原因"`
  253. }
  254. type CalendarDetailResp struct {
  255. RsCalendarItem *RsCalendar
  256. RsCalendarResearcherItem *RsCalendarResearcher
  257. CompanyDetail *CompanyDetailView
  258. }
  259. type MattersListResp struct {
  260. Paging *paging.PagingItem
  261. List []*RsMattersView
  262. }
  263. type RsMattersView struct {
  264. RsMattersId int `orm:"column(rs_matters_id);pk"`
  265. SysUserId int `description:"添加事项人id"`
  266. SysUserRealName string `description:"创建人姓名"`
  267. StartDate string `description:"开始日期"`
  268. EndDate string `description:"结束日期"`
  269. StartTime string `description:"开始时间"`
  270. EndTime string `description:"结束时间"`
  271. StartWeek string `description:"开始日期周"`
  272. EndWeek string `description:"结束日期周"`
  273. MatterContent string `description:"事项内容"`
  274. Status int8 `description:"状态:1:进行中,6:已结束"`
  275. CreateTime string `description:"创建时间"`
  276. ModifyTime string `description:"修改时间"`
  277. IsSynced int `description:"是否与上海同步 0:未同步 1:已同步"`
  278. EditReason string `description:"修改原因"`
  279. ButtonAuth RsMatterButton `description:"按钮权限"`
  280. }
  281. // RsMatterButton 事项按钮权限
  282. type RsMatterButton struct {
  283. EditDisabled bool `description:"禁用编辑"`
  284. RemoveDisabled bool `description:"禁用删除"`
  285. }
  286. func GetMattersListCount(condition string, pars []interface{}) (count int, err error) {
  287. o := orm.NewOrm()
  288. sql := `SELECT COUNT(1) AS count FROM rs_matters AS a
  289. WHERE 1=1 `
  290. if condition != "" {
  291. sql += condition
  292. }
  293. err = o.Raw(sql, pars).QueryRow(&count)
  294. return
  295. }
  296. func GetMattersList(condition string, pars []interface{}, pageLimit ...int) (list []*RsMattersView, err error) {
  297. o := orm.NewOrm()
  298. sql := `SELECT * FROM rs_matters AS a
  299. WHERE 1=1 `
  300. if condition != "" {
  301. sql += condition
  302. }
  303. sql += ` ORDER BY a.create_time DESC LIMIT ?,? `
  304. _, err = o.Raw(sql, pars, pageLimit).QueryRows(&list)
  305. return
  306. }
  307. type DeleteMattersReq struct {
  308. RsMattersId int `description:"事项id"`
  309. }
  310. // 删除事项
  311. func DeleteRsMatters(rsMattersId int) (err error) {
  312. o := orm.NewOrm()
  313. sql := ` DELETE FROM rs_matters WHERE rs_matters_id=? `
  314. _, err = o.Raw(sql, rsMattersId).Exec()
  315. return err
  316. }
  317. func CheckMattersCount(condition string, pars []interface{}) (count int, err error) {
  318. o := orm.NewOrm()
  319. sql := `SELECT COUNT(1) AS count FROM rs_matters AS a
  320. WHERE 1=1 `
  321. if condition != "" {
  322. sql += condition
  323. }
  324. err = o.Raw(sql, pars).QueryRow(&count)
  325. return
  326. }
  327. func GetResearcherFromAdmin(condition string, pars []interface{}) (lists []*admin.Admin, err error) {
  328. o := orm.NewOrm()
  329. sql := `SELECT * FROM admin WHERE 1=1 `
  330. if condition != "" {
  331. sql += condition
  332. }
  333. _, err = o.Raw(sql, pars).QueryRows(&lists)
  334. return
  335. }
  336. // 更新活动信息
  337. func UpdateRsCalendar(where, updateParams map[string]interface{}) error {
  338. o := orm.NewOrm()
  339. ptrStructOrTableName := "rs_calendar"
  340. qs := o.QueryTable(ptrStructOrTableName)
  341. for expr, exprV := range where {
  342. qs = qs.Filter(expr, exprV)
  343. }
  344. _, err := qs.Update(updateParams)
  345. return err
  346. }
  347. // 更新
  348. func UpdateRsMatters(where, updateParams map[string]interface{}) error {
  349. o := orm.NewOrm()
  350. ptrStructOrTableName := "rs_matters"
  351. qs := o.QueryTable(ptrStructOrTableName)
  352. for expr, exprV := range where {
  353. qs = qs.Filter(expr, exprV)
  354. }
  355. _, err := qs.Update(updateParams)
  356. return err
  357. }
  358. type EditActivityReq struct {
  359. EditType int `description:"修改方式: 1:修改,2:修改重提"`
  360. RsCalendarId int `description:"路演活动id"`
  361. RsCalendarResearcherId int `description:"活动研究员id"`
  362. ActivityType string `description:"活动类型"`
  363. RoadshowType string `description:"路演形式"`
  364. RoadshowPlatform string `description:"路演平台"`
  365. CompanyId int `description:"客户id"`
  366. CompanyName string `description:"客户名称"`
  367. Province string `description:"省"`
  368. ProvinceCode string `description:"省编码"`
  369. City string `description:"市"`
  370. CityCode string `description:"市编码"`
  371. Theme string `description:"会议主题"`
  372. CooperationName string `description:"合作方名称"`
  373. ActivityCategory string `description:"活动类别"`
  374. ResearcherList []*CalendarResearcher
  375. EnglishCompany int `description:"是否为英文客户"`
  376. }
  377. // GetRsCalendarResearcherListByRsCalendarId 根据路演id获取路演研究员列表
  378. func GetRsCalendarResearcherListByRsCalendarId(rsCalendarId int) (items []*RsCalendarResearcher, err error) {
  379. o := orm.NewOrm()
  380. sql := `SELECT * FROM rs_calendar_researcher WHERE rs_calendar_id=? `
  381. _, err = o.Raw(sql, rsCalendarId).QueryRows(&items)
  382. return
  383. }
  384. func CheckCalendarResearcherCount(condition string, pars []interface{}) (count int, err error) {
  385. o := orm.NewOrm()
  386. sql := `SELECT COUNT(1) AS count FROM rs_calendar_researcher AS a
  387. WHERE 1=1 `
  388. if condition != "" {
  389. sql += condition
  390. }
  391. err = o.Raw(sql, pars).QueryRow(&count)
  392. return
  393. }
  394. func GetMattersById(rsMatters int) (item *RsMatters, err error) {
  395. o := orm.NewOrm()
  396. sql := `SELECT * FROM rs_matters
  397. WHERE rs_matters_id=? `
  398. err = o.Raw(sql, rsMatters).QueryRow(&item)
  399. return
  400. }
  401. // 添加RsCalendarResearcher
  402. func AddRsMatters(item *RsMatters) (id int64, err error) {
  403. o := orm.NewOrm()
  404. id, err = o.Insert(item)
  405. return
  406. }
  407. // 添加RsCalendar
  408. func AddRsCalendar(item *RsCalendar) (lastId int64, err error) {
  409. o := orm.NewOrm()
  410. lastId, err = o.Insert(item)
  411. return
  412. }
  413. // 添加RsCalendarResearcher
  414. func AddRsCalendarResearcher(item *RsCalendarResearcher) (lastId int64, err error) {
  415. o := orm.NewOrm()
  416. lastId, err = o.Insert(item)
  417. return
  418. }
  419. func GetRsCalendarResearcherByRsCalendarIdAndResearcherId(rsCalendarId, researcherId int) (item *RsCalendarResearcher, err error) {
  420. o := orm.NewOrm()
  421. sql := `SELECT * FROM rs_calendar_researcher WHERE rs_calendar_id=? AND researcher_id=? `
  422. err = o.Raw(sql, rsCalendarId, researcherId).QueryRow(&item)
  423. return
  424. }
  425. func GetRsCalendarResearcherByCalendarId(rsCalendarId int) (item []*RsCalendarResearcher, err error) {
  426. o := orm.NewOrm()
  427. sql := `SELECT * FROM rs_calendar_researcher WHERE rs_calendar_id=? `
  428. _, err = o.Raw(sql, rsCalendarId).QueryRows(&item)
  429. return
  430. }
  431. // 删除
  432. func DeleteRsCalendarResearcher(rsCalendarId int) (err error) {
  433. o := orm.NewOrm()
  434. sql := ` DELETE FROM rs_calendar_researcher WHERE rs_calendar_id=? `
  435. _, err = o.Raw(sql, rsCalendarId).Exec()
  436. return err
  437. }
  438. func GetResearcherGroup() (list []*ResearcherGroup, err error) {
  439. o := orm.NewOrm()
  440. sql := ` SELECT group_id,group_name FROM admin AS a
  441. WHERE a.role_type_code IN('researcher','ficc_researcher','ficc_admin')
  442. AND a.enabled=1
  443. AND a.group_id>0
  444. AND a.group_name<>'无'
  445. GROUP BY a.group_id
  446. ORDER BY a.group_id ASC `
  447. _, err = o.Raw(sql).QueryRows(&list)
  448. return
  449. }
  450. func GetResearcher() (list []*Researcher, err error) {
  451. o := orm.NewOrm()
  452. sql := ` SELECT * FROM admin AS a
  453. WHERE a.role_type_code IN('researcher','rai_researcher','ficc_researcher','ficc_admin')
  454. AND a.enabled=1 AND a.real_name<>'于菲' `
  455. _, err = o.Raw(sql).QueryRows(&list)
  456. return
  457. }
  458. // 删除
  459. func DeleteCalendar(rsCalendarId, rsCalendarResearcherId int) (err error) {
  460. o := orm.NewOrm()
  461. sql := ` DELETE FROM rs_calendar_researcher WHERE rs_calendar_id=? `
  462. _, err = o.Raw(sql, rsCalendarId).Exec()
  463. if err != nil {
  464. return err
  465. }
  466. //var count int
  467. //sql = ` SELECT COUNT(1) AS count FROM rs_calendar_researcher WHERE rs_calendar_id=? `
  468. //err = o.Raw(sql, rsCalendarId).QueryRow(&count)
  469. //if err != nil && err.Error() != utils.ErrNoRow() {
  470. // return err
  471. //}
  472. //if count <= 0 {
  473. // sql := ` DELETE FROM rs_calendar WHERE rs_calendar_id=? `
  474. // _, err = o.Raw(sql, rsCalendarId).Exec()
  475. // if err != nil {
  476. // return err
  477. // }
  478. //}
  479. sql = ` DELETE FROM rs_calendar WHERE rs_calendar_id=? `
  480. _, err = o.Raw(sql, rsCalendarId).Exec()
  481. if err != nil {
  482. return err
  483. }
  484. return err
  485. }
  486. type ActivityTypeList struct {
  487. ActivityTypeId int `description:"活动类型ID"`
  488. ActivityTypeName string `description:"活动类型名称"`
  489. Pid int `description:"父级id,默认是:0"`
  490. Sort int `description:"排序字段"`
  491. FrontIsShow int8 `description:"是否在前台展示,0:不展示,1:展示"`
  492. CreateTime time.Time `description:"创建时间"`
  493. ChildList []*ActivityTypeList `description:"下级活动类型列表"`
  494. }
  495. // GetActivityTypeListByActivityTypePId 根据上级id获取活动分类列表
  496. func GetActivityTypeListByActivityTypePId(pid int) (list []*ActivityTypeList, err error) {
  497. o := orm.NewOrm()
  498. sql := `select * from yb_activity_type where pid=? order by sort asc ,activity_type_id asc`
  499. _, err = o.Raw(sql, pid).QueryRows(&list)
  500. return
  501. }
  502. type CalendarPanelDetailResp struct {
  503. CalendarList []*CalendarListView
  504. RsMattersList []*RsMatters
  505. }
  506. func GetCalendarDetailList(condition string, pars []interface{}) (list []*CalendarListView, err error) {
  507. o := orm.NewOrm()
  508. sql := `SELECT a.*,b.*,c.status AS company_status FROM rs_calendar AS a
  509. INNER JOIN rs_calendar_researcher AS b ON a.rs_calendar_id=b.rs_calendar_id
  510. LEFT JOIN company_product AS c ON a.company_id=c.company_id AND c.product_id=1
  511. WHERE 1=1 `
  512. if condition != "" {
  513. sql += condition
  514. }
  515. sql += ` ORDER BY a.create_time DESC `
  516. _, err = o.Raw(sql, pars).QueryRows(&list)
  517. return
  518. }
  519. func GetRsMattersList(startDate, endDate string, researcherId int) (list []*RsMatters, err error) {
  520. o := orm.NewOrm()
  521. //sql := `SELECT * FROM rs_matters AS a WHERE a.start_date>=? AND a.end_date<=? AND sys_user_id=? `
  522. //sql := `SELECT * FROM rs_matters AS a WHERE a.end_date>=? AND sys_user_id=? `
  523. sql := `SELECT * FROM rs_matters AS a WHERE sys_user_id=? `
  524. sql += ` ORDER BY a.create_time DESC `
  525. _, err = o.Raw(sql, researcherId).QueryRows(&list)
  526. return
  527. }
  528. func GetCalendarTypeList(condition string, pars []interface{}, startSize, pageSize int) (list []*CalendarListView, err error) {
  529. o := orm.NewOrm()
  530. sql := ` SELECT a.rs_calendar_id,a.activity_type,a.roadshow_type,a.activity_category,a.roadshow_platform,b.create_time,
  531. b.modify_time,GROUP_CONCAT(b.researcher_id ORDER BY researcher_sort ASC) AS researcher_id,GROUP_CONCAT(b.researcher_name ORDER BY researcher_sort ASC) AS researcher_name,
  532. b.rs_calendar_researcher_id,b.start_date,
  533. b.end_date,b.start_time,b.end_time,b.start_week,b.end_week,b.status,b.refuse_reason,b.refuse_time,
  534. b.delete_reason,a.sys_user_real_name,a.city,a.province,a.company_name,a.company_id,
  535. a.cooperation_name,a.theme,a.activity_category
  536. FROM rs_calendar AS a
  537. INNER JOIN rs_calendar_researcher AS b ON a.rs_calendar_id=b.rs_calendar_id
  538. WHERE 1=1
  539. `
  540. if condition != "" {
  541. sql += condition
  542. }
  543. sql += ` GROUP BY a.rs_calendar_id
  544. ORDER BY b.create_time DESC LIMIT ?,? `
  545. _, err = o.Raw(sql, pars, startSize, pageSize).QueryRows(&list)
  546. return
  547. }
  548. func GetCalendarTypeListCount(condition string, pars []interface{}) (count int, err error) {
  549. o := orm.NewOrm()
  550. sql := `SELECT COUNT(1) AS count FROM(SELECT COUNT(1) AS count
  551. FROM rs_calendar AS a
  552. INNER JOIN rs_calendar_researcher AS b ON a.rs_calendar_id=b.rs_calendar_id
  553. WHERE 1=1 `
  554. if condition != "" {
  555. sql += condition
  556. }
  557. sql += ` GROUP BY a.rs_calendar_id ) AS t `
  558. err = o.Raw(sql, pars).QueryRow(&count)
  559. return
  560. }