activity.go 28 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528
  1. package models
  2. import (
  3. "github.com/beego/beego/v2/client/orm"
  4. "github.com/rdlucklib/rdluck_tools/paging"
  5. "time"
  6. )
  7. //活动详情
  8. type CygxActivity struct {
  9. ActivityId int `orm:"column(activity_id);pk";description:"活动ID 等于0新增活动,大于0修改活动"`
  10. ActivityTypeId int `description:"活动类型id"`
  11. ActivityTypeName string `description:"活动类型名称"`
  12. ChartPermissionId int `description:"行业id"`
  13. ChartPermissionName string `description:"行业名称"`
  14. ChartPermissionNames string `description:"行业名称辅助字段,区分研选子分类"`
  15. Body string `description:"内容"`
  16. CreateTime time.Time `description:"创建时间"`
  17. PublishDate time.Time `description:"发布时间"`
  18. IsLimitPeople int `description:"是否限制人数 1是,0否"`
  19. LimitPeopleNum int `description:"限制的人数数量"`
  20. CustomerTypeIds string `description:"活动可见的客户类型,多个ID用 , 隔开"`
  21. PublishStatus int `description:"发布状态 1已发布,0未发布"`
  22. LastUpdatedTime time.Time `description:"更新时间"`
  23. ActivityTime string `description:"活动时间"`
  24. ActivityTimeText string `description:"活动时间带文字"`
  25. DistinguishedGuest string `description:"嘉宾"`
  26. Host string `description:"主持人"`
  27. MainlandTell string `description:"大陆拨入号"`
  28. HongKongTell string `description:"香港拨入号"`
  29. TaiwanTell string `description:"台湾拨入号"`
  30. AmericaTell string `description:"美国拨入号"`
  31. ParticipationCode string `description:"参会密码"`
  32. Theme string `description:"主题"`
  33. Expert string `description:"专家"`
  34. ActivityName string `description:"活动名称"`
  35. ActivityNameTask string `description:"活动名称定时任务同步的时候使用"`
  36. OnlineParticipation string `description:"网络参会"`
  37. ReportLink string `description:"报告链接"`
  38. City string `description:"城市"`
  39. Address string `description:"活动地址"`
  40. Highlights string `description:"活动亮点"`
  41. Remarks string `description:"备注"`
  42. Speaker string `description:"主讲人"`
  43. ArticleId int `description:"关联报告id"`
  44. Label string `description:"标签"`
  45. LinkParticipants string `description:"链接参会"`
  46. AppAttendance string `description:"App参会"`
  47. ConferencePassword string `description:"会议密码"`
  48. TemporaryLabel string `description:"临时标签"`
  49. IsMakerShow int `description:"是否仅决策人可见 0,否 、1,是"`
  50. VisibleRange int `description:"可见范围 1,仅本组可见 、2,全部客户可见"`
  51. Scale string `description:"管理规模,空不填,1::50亿以下,2:50~100亿,3:100亿以上。多个用, 隔开"`
  52. IsShowSubjectName int `description:"小程序内是否展示标的名称 1是 ,0 否 默认0 "`
  53. IsHideAppointment int `description:"是否隐藏预约纪要按钮 1是 ,0 否 默认0 "`
  54. AdminId int `description:"销售/管理员ID"`
  55. AdminName string `description:"销售/管理员姓名"`
  56. IsCanAppointmentMinutes int `description:"是否可预约纪要 1是 ,0 否 默认0 "`
  57. YidongActivityId string `description:"易董活动ID"`
  58. }
  59. //活动详情
  60. type ActivityDetail struct {
  61. ActivityId int `orm:"column(activity_id);pk";description:"活动ID "`
  62. ActivityTypeId int `description:"活动类型id"`
  63. ActivityTypeName string `description:"活动类型名称"`
  64. ChartPermissionId int `description:"行业id"`
  65. ChartPermissionName string `description:"行业名称"`
  66. ChartPermissionNames string `description:"行业名称辅助字段,区分研选子分类"`
  67. Body string `description:"内容"`
  68. CreateTime string `description:"创建时间"`
  69. IsLimitPeople int `description:"是否限制人数 1是,0否"`
  70. LimitPeopleNum int `description:"限制的人数数量"`
  71. LastUpdatedTime string `description:"更新时间"`
  72. ActivityTime string `description:"活动时间"`
  73. ActivityTimeText string `description:"活动时间带文字"`
  74. DistinguishedGuest string `description:"嘉宾"`
  75. Host string `description:"主持人"`
  76. Speaker string `description:"主讲人"`
  77. MainlandTell string `description:"大陆拨入号"`
  78. HongKongTell string `description:"香港拨入号"`
  79. TaiwanTell string `description:"台湾拨入号"`
  80. AmericaTell string `description:"美国拨入号"`
  81. ParticipationCode string `description:"参会密码"`
  82. Theme string `description:"主题"`
  83. Expert string `description:"专家"`
  84. ActivityName string `description:"活动名称"`
  85. OnlineParticipation string `description:"网络参会"`
  86. ReportLink string `description:"报告链接"`
  87. City string `description:"城市"`
  88. Address string `description:"活动地址"`
  89. Highlights string `description:"活动亮点"`
  90. Remarks string `description:"备注"`
  91. ShowType string `description:"人数限制类型,1不展示限制,2可选限制,3强制限制"`
  92. IsSignup int `description:"是否已报名 1是 ,0 否"`
  93. IsAppointment int `description:"是否已预约纪要 1是 ,0 否"`
  94. SignupNum int `description:"已报名人数"`
  95. SignupType int `description:"报名方式,1预约外呼,2自主拨入,3我要报名"`
  96. ActiveState string `description:"活动进行状态 未开始:1、进行中2、已结束3"`
  97. IsCancelMeetingReminder int `description:"是否取消会议提醒 1展示取消会议提醒 ,0展示会议提醒"`
  98. ArticleId int `description:"报告id(报告链接跳转使用)"`
  99. CustomerTypeIds string `description:"活动可见的客户类型,多个ID用 , 隔开"`
  100. IsShowSustainable bool `description:"是否展示限免标签"`
  101. Description string `description:"研选内容说明"`
  102. IsResearch bool `description:"是否属于研选"`
  103. LinkParticipants string `description:"链接参会"`
  104. AppAttendance string `description:"App参会"`
  105. ConferencePassword string `description:"会议密码"`
  106. Scale string `description:"管理规模,空不填,1::50亿以下,2:50~100亿,3:100亿以上。多个用, 隔开"`
  107. IsShowAppointment bool `description:"是否展示预约纪要"`
  108. IsHideAppointment int `description:"是否隐藏预约纪要按钮 1是,0 否"`
  109. IsCClassMeeting bool `description:"是否是c类电话会"`
  110. ArticleList []*ActivityArticleResp // 下面是列表添加的部分结构体
  111. IsBrackets int `description:"是否有方括号 1是 ,0 否"`
  112. Label string `description:"主题标签"`
  113. ImgUrl string `description:"图片链接"`
  114. ImgUrlText string `description:"图片链接文字"`
  115. ActivityType int `description:"活动线上线下类型 1线上,0 线下"`
  116. JmcjRoadshowTitle string `description:"进门财经手动匹配的活动名称"`
  117. Listndustrial []*IndustrialManagementRep `description:"活动关联的产业信息"`
  118. IsShowOutboundCall bool `description:"是否展示预约外呼"`
  119. IsShowMeetingReminder bool `description:"是否展示会议提醒"`
  120. IsShowHelpSsk bool `description:"是否展示帮我带问"`
  121. IsShowSignup bool `description:"是否展示我要报名"`
  122. IsShowDetails bool `description:"是否展示查看详情按钮"`
  123. TemporaryLabel string `description:"临时标签"`
  124. IsCanAppointmentMinutes int `description:"是否可预约纪要 1是 ,0 否 默认0 "`
  125. YidongActivityId string `description:"易董活动ID"`
  126. YidongActivityUrl string `description:"易董活动跳转地址"`
  127. AudioLink bool `description:"是否展示回放按钮"`
  128. VoiceList *CygxActivityVoiceReq `description:"音频数据"`
  129. AdminId int `description:"管理员、销售ID "`
  130. IsMakerShow int `description:"是否仅决策人可见 0,否 、1,是"`
  131. VisibleRange int `description:"可见范围 1,仅本组可见 、2,全部客户可见"`
  132. VideoDetail *CygxActivityVideoListResp `description:"视频数据"`
  133. FileType int `description:"类型: 1-音频; 2-视频"`
  134. SourceType int `description:"活动来源。 1:活动 、2:专项产业调研"`
  135. TripImgLink string `description:"专项产业调研行程链接"`
  136. ActivityTimeEnd string `description:"专项产业调研活动预期结束时间"`
  137. AuthInfo *UserPermissionAuthInfo `description:"用户查看视频的权限"`
  138. Days int `description:"调研天数"`
  139. }
  140. //活动详情
  141. type ActivityListResp struct {
  142. ActivityId int `description:"活动ID "`
  143. ActivityTypeId int `description:"活动类型id"`
  144. ActivityTypeName string `description:"活动类型名称"`
  145. ChartPermissionId int `description:"行业id"`
  146. ChartPermissionName string `description:"行业名称"`
  147. IsLimitPeople int `description:"是否限制人数 1是,0否"`
  148. LimitPeopleNum int `description:"限制的人数数量"`
  149. LastUpdatedTime string `description:"更新时间"`
  150. ActivityTime string `description:"活动时间"`
  151. ActivityTimeText string `description:"活动时间带文字"`
  152. DistinguishedGuest string `description:"嘉宾"`
  153. Host string `description:"主持人"`
  154. Speaker string `description:"主讲人"`
  155. MainlandTell string `description:"大陆拨入号" json:"-"`
  156. HongKongTell string `description:"香港拨入号" json:"-"`
  157. TaiwanTell string `description:"台湾拨入号" json:"-"`
  158. AmericaTell string `description:"美国拨入号" json:"-"`
  159. ParticipationCode string `description:"参会密码"`
  160. Theme string `description:"主题"`
  161. Expert string `description:"专家"`
  162. ActivityName string `description:"活动名称"`
  163. OnlineParticipation string `description:"网络参会"`
  164. ReportLink string `description:"报告链接" json:"-"`
  165. City string `description:"城市"`
  166. Address string `description:"活动地址" json:"-"`
  167. Highlights string `description:"活动亮点" json:"-"`
  168. Remarks string `description:"备注"`
  169. IsSignup int `description:"是否已报名 1是 ,0 否"`
  170. SignupNum int `description:"已报名人数"`
  171. IsAppointment int `description:"是否已预约纪要 1是 ,0 否"`
  172. IsCancelMeetingReminder int `description:"是否添加了消息消息提醒 1是 ,0 否"`
  173. ActiveState string `description:"活动进行状态 未开始:1、进行中2、已结束3"`
  174. IsShowSustainable bool `description:"是否展示限免标签"`
  175. Description string `description:"研选内容说明"`
  176. IsResearch bool `description:"是否属于研选"`
  177. IsHideAppointment int `description:"是否隐藏预约纪要按钮 1是,0 否"`
  178. IsCClassMeeting bool `description:"是否是c类电话会"`
  179. Label string `description:"主题标签"`
  180. ImgUrl string `description:"行业图片链接"`
  181. ImgUrlText string `description:"活动类型图片链接"`
  182. ActivityType int `description:"活动线上线下类型 1线上,0 线下"`
  183. IsShowOutboundCall bool `description:"是否展示预约外呼"`
  184. IsShowMeetingReminder bool `description:"是否展示会议提醒"`
  185. IsShowHelpSsk bool `description:"是否展示帮我带问"`
  186. IsShowSignup bool `description:"是否展示我要报名"`
  187. IsShowAppointment bool `description:"是否展示预约纪要"`
  188. IsShowDetails bool `description:"是否展示查看详情按钮"`
  189. AudioLink bool `description:"是否展示回放按钮"`
  190. VoiceDetail *CygxActivityVoiceReq `description:"音频数据"`
  191. VideoDetail *CygxActivityVideoListResp `description:"视频数据"`
  192. FileType int `description:"类型: 1-音频; 2-视频"`
  193. SourceType int `description:"活动来源。 1:活动 、2:专项产业调研"`
  194. YidongActivityUrl string `description:"易董活动跳转地址"`
  195. ArticleList []*ActivityArticleResp
  196. Listndustrial []*IndustrialManagementRep `description:"活动关联的产业信息"`
  197. AuthInfo *UserPermissionAuthInfo `description:"用户查看视频的权限"`
  198. Explain string `description:"活动右上角提示"`
  199. TripImgLink string `description:"专项产业调研行程链接"`
  200. IsTrip int `description:"是否报名 1是 ,0 否"`
  201. TripStatus int `description:"行程进行状态 1:预报名,2:确定行程"`
  202. Days int `description:"调研天数"`
  203. }
  204. type ActivityArticleResp struct {
  205. ReportLink string `description:"报告链接"`
  206. ArticleId int `description:"报告id(报告链接跳转使用)"`
  207. }
  208. type CygxActivityResp struct {
  209. HasPermission int `description:"1:有该行业权限,正常展示,2:无该行业权限,不存在权益客户下(ficc),3:无该品类权限,已提交过申请,4:无该品类权限,未提交过申请,5:潜在客户,未提交过申请,6:潜在客户,已提交过申请"`
  210. PopupMsg string `description:"权限弹窗信息"`
  211. SellerMobile string `description:"销售电话"`
  212. SellerName string `description:"销售姓名"`
  213. Detail *ActivityListResp
  214. }
  215. //列表
  216. func GetCygxActivityList(condition string, pars []interface{}, sortTime string, startSize, pageSize int) (items []*CygxActivity, err error) {
  217. o := orm.NewOrm()
  218. sql := `SELECT activity_id, label,temporary_label,is_show_subject_name, MAX( art.activity_time ) AS timesort, MIn( art.activity_time ) AS mintimesort , yidong_activity_id , activity_type_id
  219. FROM cygx_activity as art WHERE 1= 1 `
  220. if condition != "" {
  221. sql += condition
  222. }
  223. sql += ` GROUP BY art.activity_id ORDER BY ` + sortTime + ` ,art.activity_id DESC LIMIT ?,? `
  224. _, err = o.Raw(sql, pars, startSize, pageSize).QueryRows(&items)
  225. return
  226. }
  227. //通过纪要ID获取活动详情
  228. func GetAddActivityInfoById(ActivityId int) (item *ActivityDetail, err error) {
  229. o := orm.NewOrm()
  230. sql := `SELECT * FROM cygx_activity WHERE activity_id=? AND publish_status = 1 `
  231. err = o.Raw(sql, ActivityId).QueryRow(&item)
  232. return
  233. }
  234. //获取数量
  235. func GetActivityCount(condition string, playBack int, pars []interface{}, filter int) (count int, err error) {
  236. var sqlJiontable string
  237. if playBack == 1 {
  238. //sqlJiontable = ` INNER JOIN cygx_activity_voice AS ac ON ac.activity_id = art.activity_id `
  239. }
  240. if filter == 1 {
  241. sqlJiontable = ` INNER JOIN cygx_activity_video AS av ON av.activity_id = art.activity_id `
  242. } else if filter == 2 {
  243. sqlJiontable = ` INNER JOIN cygx_activity_voice AS ac ON ac.activity_id = art.activity_id `
  244. }
  245. sqlCount := ` SELECT COUNT(1) AS count FROM cygx_activity as art ` + sqlJiontable + ` WHERE 1= 1 `
  246. if condition != "" {
  247. sqlCount += condition
  248. }
  249. o := orm.NewOrm()
  250. err = o.Raw(sqlCount, pars).QueryRow(&count)
  251. return
  252. }
  253. //列表
  254. func GetActivityListNew(condition string, pars []interface{}, uid, startSize, pageSize, playBack, filter int) (items []*ActivityDetail, err error) {
  255. var sqlJiontable string
  256. if playBack == 1 {
  257. //sqlJiontable = ` INNER JOIN cygx_activity_voice AS ac ON ac.activity_id = art.activity_id `
  258. }
  259. if filter == 1 {
  260. sqlJiontable = ` INNER JOIN cygx_activity_video AS av ON av.activity_id = art.activity_id `
  261. } else if filter == 2 {
  262. sqlJiontable = ` INNER JOIN cygx_activity_voice AS ac ON ac.activity_id = art.activity_id `
  263. }
  264. o := orm.NewOrm()
  265. sql := `SELECT art.* ,t.activity_type,t.img_url_text,c.image_url as img_url,
  266. ( SELECT COUNT( 1 ) FROM cygx_activity_signup AS s WHERE s.activity_id = art.activity_id AND s.user_id = ? AND s.is_cancel = 0 AND s.do_fail_type = 0) AS is_signup,
  267. ( SELECT COUNT( DISTINCT user_id ) FROM cygx_activity_signup AS s WHERE s.activity_id = art.activity_id AND s.is_cancel = 0 AND s.do_fail_type = 0) AS signup_num,
  268. ( SELECT COUNT( 1 ) FROM cygx_activity_meeting_reminder AS m WHERE m.activity_id = art.activity_id AND m.user_id = ? AND m.is_cancel = 0 ) AS is_cancel_meeting_reminder,
  269. ( SELECT COUNT( 1 ) FROM cygx_activity_appointment AS ap WHERE ap.activity_id = art.activity_id AND ap.user_id = ? ) AS is_appointment
  270. FROM cygx_activity as art
  271. INNER JOIN cygx_activity_type as t ON t.activity_type_id = art.activity_type_id
  272. INNER JOIN chart_permission AS c ON c.chart_permission_id = art.chart_permission_id ` + sqlJiontable + ` WHERE 1= 1 `
  273. if condition != "" {
  274. sql += condition
  275. }
  276. sql += ` LIMIT ?,?`
  277. _, err = o.Raw(sql, uid, uid, uid, pars, startSize, pageSize).QueryRows(&items)
  278. return
  279. }
  280. //列表
  281. func GetActivityListHomeNew(condition string, startSize, pageSize int) (items []*ActivityDetail, err error) {
  282. o := orm.NewOrm()
  283. sql := `SELECT activity_id
  284. FROM cygx_activity as art
  285. INNER JOIN cygx_activity_type as t ON t.activity_type_id = art.activity_type_id
  286. INNER JOIN chart_permission AS c ON c.chart_permission_id = art.chart_permission_id WHERE 1= 1 `
  287. if condition != "" {
  288. sql += condition
  289. }
  290. sql += ` LIMIT ?,?`
  291. _, err = o.Raw(sql, startSize, pageSize).QueryRows(&items)
  292. return
  293. }
  294. type GetCygxActivityListRep struct {
  295. Paging *paging.PagingItem `description:"分页数据"`
  296. List []*ActivityListResp
  297. Label string `description:"主题"`
  298. ImgUrl string `description:"图片路径"`
  299. IsResearch bool `description:"是否属于研选"`
  300. IsJump bool `description:"是否跳转"`
  301. IndustrialManagementId int `description:"产业ID"`
  302. IndustryNewLabel bool `description:"产业是否新标签"`
  303. ChartPermissionId int `description:"权限id"`
  304. }
  305. type GetCygxActivityListSearchResp struct {
  306. Paging *paging.PagingItem `description:"分页数据"`
  307. List []*ActivityDetail
  308. Label string `description:"主题"`
  309. ImgUrl string `description:"图片路径"`
  310. IsResearch bool `description:"是否属于研选"`
  311. IsJump bool `description:"是否跳转"`
  312. IndustrialManagementId int `description:"产业ID"`
  313. IndustryNewLabel bool `description:"产业是否新标签"`
  314. ChartPermissionId int `description:"权限id"`
  315. }
  316. //通过纪要ID获取活动详情
  317. func GetAddActivityInfoByIdShow(uid, ActivityId int) (item *ActivityDetail, err error) {
  318. o := orm.NewOrm()
  319. sql := `SELECT *,( SELECT COUNT( 1 ) FROM cygx_activity_signup AS s WHERE s.activity_id = a.activity_id AND s.user_id = ? AND s.is_cancel = 0 AND s.do_fail_type = 0) AS is_signup,
  320. ( SELECT COUNT( DISTINCT user_id ) FROM cygx_activity_signup AS s WHERE s.activity_id = a.activity_id AND s.is_cancel = 0 AND s.do_fail_type = 0) AS signup_num,
  321. ( SELECT COUNT( 1 ) FROM cygx_activity_meeting_reminder AS m WHERE m.activity_id = a.activity_id AND m.user_id = ? AND m.is_cancel = 0 ) AS is_cancel_meeting_reminder,
  322. ( SELECT COUNT( 1 ) FROM cygx_activity_appointment AS ap WHERE ap.activity_id = a.activity_id AND ap.user_id = ? ) AS is_appointment
  323. FROM cygx_activity AS a WHERE activity_id=? AND publish_status = 1 `
  324. err = o.Raw(sql, uid, uid, uid, ActivityId).QueryRow(&item)
  325. return
  326. }
  327. //GetActivitySpecialSearcheList 活动与专项调研的搜索
  328. func GetActivitySpecialSearcheList(condition string, pars []interface{}, conditionSpecil string, parsSpecil []interface{}, startSize, pageSize int) (items []*ActivityDetail, total int, err error) {
  329. o := orm.NewOrm()
  330. sql := `SELECT
  331. art.activity_id,
  332. art.activity_time_text,
  333. art.activity_name,
  334. art.chart_permission_id,
  335. art.active_state,
  336. t.activity_type,
  337. art.chart_permission_name,
  338. art.distinguished_guest,
  339. art.expert,
  340. art.speaker,
  341. "" AS trip_img_link,
  342. "" AS activity_time_end,
  343. art.yidong_activity_id,
  344. art.is_can_appointment_minutes,
  345. art.activity_type_id,
  346. art.limit_people_num,
  347. 1 AS source_type,
  348. t.img_url_text,
  349. art.activity_time
  350. FROM
  351. cygx_activity AS art
  352. INNER JOIN cygx_activity_type AS t ON t.activity_type_id = art.activity_type_id
  353. WHERE
  354. 1 = 1 `
  355. if condition != `` {
  356. sql += condition
  357. }
  358. sql += ` UNION ALL
  359. SELECT
  360. art.activity_id,
  361. art.activity_time_text_by_day AS activity_time_text,
  362. art.research_theme AS activity_name,
  363. art.chart_permission_id,
  364. "",
  365. art.special_type AS activity_type,
  366. art.chart_permission_name,
  367. "",
  368. "",
  369. "",
  370. art.trip_img_link_fix AS trip_img_link,
  371. art.activity_time_end,
  372. "",
  373. "",
  374. "",
  375. "",
  376. 2 AS source_type,
  377. "",
  378. art.activity_time
  379. FROM
  380. cygx_activity_special AS art
  381. WHERE
  382. 1 = 1 `
  383. if conditionSpecil != "" {
  384. sql += conditionSpecil
  385. }
  386. totalSql := `SELECT COUNT(1) total FROM (` + sql + `) z `
  387. err = o.Raw(totalSql, pars, parsSpecil).QueryRow(&total)
  388. if err != nil {
  389. return
  390. }
  391. sql += ` ORDER BY activity_time DESC LIMIT ?,?`
  392. _, err = o.Raw(sql, pars, parsSpecil, startSize, pageSize).QueryRows(&items)
  393. return
  394. }
  395. //获取我的日程数量
  396. func GetScheduleCount(condition string, uid int) (count int, err error) {
  397. o := orm.NewOrm()
  398. sqlCount := `SELECT COUNT( 1 ) AS count
  399. FROM cygx_my_schedule AS m
  400. INNER JOIN cygx_activity AS art ON art.activity_id = m.activity_id
  401. WHERE
  402. user_id = ?`
  403. if condition != "" {
  404. sqlCount += condition
  405. }
  406. err = o.Raw(sqlCount, uid).QueryRow(&count)
  407. return
  408. }
  409. //获取我的日程数量
  410. func GetSpecialScheduleCount(uid int) (count int, err error) {
  411. o := orm.NewOrm()
  412. sqlCount := `
  413. SELECT COUNT( 1 ) AS count FROM
  414. cygx_activity_special AS art
  415. INNER JOIN cygx_activity_special_trip AS my ON my.activity_id = art.activity_id
  416. WHERE
  417. 1 = 1 AND my.user_id = ? AND my.is_cancel = 0`
  418. err = o.Raw(sqlCount, uid).QueryRow(&count)
  419. return
  420. }
  421. //我的日程列表
  422. func GetScheduleList(condition string, pars []interface{}, uid, startSize, pageSize int) (items []*ActivityDetail, err error) {
  423. o := orm.NewOrm()
  424. sql := `SELECT art.*,t.activity_type,t.img_url_text,c.image_url as img_url,
  425. ( SELECT COUNT( 1 ) FROM cygx_activity_signup AS s WHERE s.activity_id = art.activity_id AND s.user_id = ? AND s.is_cancel = 0 AND s.do_fail_type = 0) AS is_signup,
  426. ( SELECT COUNT( DISTINCT user_id ) FROM cygx_activity_signup AS s WHERE s.activity_id = art.activity_id AND s.is_cancel = 0 AND s.do_fail_type = 0) AS signup_num ,
  427. ( SELECT COUNT( 1 ) FROM cygx_activity_appointment AS ap WHERE ap.activity_id = art.activity_id AND ap.user_id = ? ) AS is_appointment,
  428. ( SELECT COUNT( 1 ) FROM cygx_activity_meeting_reminder AS m WHERE m.activity_id = art.activity_id AND m.is_cancel = 0 AND m.user_id = ? ) AS is_cancel_meeting_reminder
  429. FROM cygx_activity AS art
  430. INNER JOIN cygx_my_schedule as my ON my.activity_id = art.activity_id
  431. INNER JOIN cygx_activity_type as t ON t.activity_type_id = art.activity_type_id
  432. INNER JOIN chart_permission AS c ON c.chart_permission_id = art.chart_permission_id
  433. WHERE 1=1 AND my.user_id = ? `
  434. if condition != "" {
  435. sql += condition
  436. }
  437. sql += ` ORDER BY art.active_state ASC,art.activity_time ASC LIMIT ?,?`
  438. _, err = o.Raw(sql, pars, uid, uid, uid, uid, startSize, pageSize).QueryRows(&items)
  439. return
  440. }
  441. //我的日程列表 活动以及专项调研一起
  442. func GetScheduleAndSpecilList(condition string, pars []interface{}, conditionSpecil string, parsSpecil []interface{}, startSize, pageSize int) (items []*ActivityDetail, err error) {
  443. o := orm.NewOrm()
  444. sql := `SELECT
  445. art.activity_id,
  446. art.activity_time_text,
  447. art.activity_name,
  448. art.chart_permission_id,
  449. art.active_state,
  450. t.activity_type,
  451. art.chart_permission_name,
  452. art.distinguished_guest,
  453. art.expert,
  454. art.speaker,
  455. "" AS trip_img_link,
  456. "" AS activity_time_end,
  457. art.yidong_activity_id,
  458. art.is_can_appointment_minutes,
  459. art.activity_type_id,
  460. art.limit_people_num,
  461. 1 AS source_type,
  462. art.activity_time,
  463. 0 AS days
  464. FROM
  465. cygx_activity AS art
  466. INNER JOIN cygx_my_schedule AS my ON my.activity_id = art.activity_id
  467. INNER JOIN cygx_activity_type AS t ON t.activity_type_id = art.activity_type_id
  468. INNER JOIN chart_permission AS c ON c.chart_permission_id = art.chart_permission_id
  469. WHERE
  470. 1 = 1 `
  471. if condition != `` {
  472. sql += condition
  473. }
  474. sql += ` UNION ALL
  475. SELECT
  476. art.activity_id,
  477. art.activity_time_text_by_day AS activity_time_text,
  478. art.research_theme AS activity_name,
  479. art.chart_permission_id,
  480. "",
  481. art.special_type AS activity_type,
  482. art.chart_permission_name,
  483. "",
  484. "",
  485. "",
  486. art.trip_img_link_fix AS trip_img_link,
  487. art.activity_time_end,
  488. "",
  489. "",
  490. "",
  491. "",
  492. 2 AS source_type,
  493. art.activity_time,
  494. art.days
  495. FROM
  496. cygx_activity_special AS art
  497. INNER JOIN cygx_activity_special_trip AS my ON my.activity_id = art.activity_id
  498. WHERE
  499. 1 = 1`
  500. if conditionSpecil != "" {
  501. sql += conditionSpecil
  502. }
  503. sql += ` ORDER BY activity_time DESC LIMIT ?,?`
  504. _, err = o.Raw(sql, pars, parsSpecil, startSize, pageSize).QueryRows(&items)
  505. return
  506. }