activity.go 33 KB

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