activity.go 29 KB

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