activity.go 30 KB

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