activity.go 47 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092
  1. package models
  2. import (
  3. "fmt"
  4. "github.com/beego/beego/v2/client/orm"
  5. "github.com/rdlucklib/rdluck_tools/paging"
  6. "hongze/hongze_cygx/utils"
  7. "strings"
  8. "time"
  9. )
  10. //活动详情
  11. type CygxActivity struct {
  12. ActivityId int `orm:"column(activity_id);pk";description:"活动ID 等于0新增活动,大于0修改活动"`
  13. ActivityTypeId int `description:"活动类型id"`
  14. ActivityTypeName string `description:"活动类型名称"`
  15. ChartPermissionId int `description:"行业id"`
  16. ChartPermissionName string `description:"行业名称"`
  17. ChartPermissionNames string `description:"行业名称辅助字段,区分研选子分类"`
  18. Body string `description:"内容"`
  19. CreateTime time.Time `description:"创建时间"`
  20. IsLimitPeople int `description:"是否限制人数 1是,0否"`
  21. LimitPeopleNum int `description:"限制的人数数量"`
  22. CustomerTypeIds string `description:"活动可见的客户类型,多个ID用 , 隔开"`
  23. PublishStatus int `description:"发布状态 1已发布,0未发布"`
  24. LastUpdatedTime time.Time `description:"更新时间"`
  25. ActivityTime string `description:"活动时间"`
  26. ActivityTimeText string `description:"活动时间带文字"`
  27. DistinguishedGuest string `description:"嘉宾"`
  28. Host string `description:"主持人"`
  29. MainlandTell string `description:"大陆拨入号"`
  30. HongKongTell string `description:"香港拨入号"`
  31. TaiwanTell string `description:"台湾拨入号"`
  32. AmericaTell string `description:"美国拨入号"`
  33. ParticipationCode string `description:"参会密码"`
  34. Theme string `description:"主题"`
  35. Expert string `description:"专家"`
  36. ActivityName string `description:"活动名称"`
  37. ActivityNameTask string `description:"活动名称定时任务同步的时候使用"`
  38. OnlineParticipation string `description:"网络参会"`
  39. ReportLink string `description:"报告链接"`
  40. City string `description:"城市"`
  41. Address string `description:"活动地址"`
  42. Highlights string `description:"活动亮点"`
  43. Remarks string `description:"备注"`
  44. Speaker string `description:"主讲人"`
  45. ArticleId int `description:"关联报告id"`
  46. Label string `description:"标签"`
  47. LinkParticipants string `description:"链接参会"`
  48. AppAttendance string `description:"App参会"`
  49. ConferencePassword string `description:"会议密码"`
  50. TemporaryLabel string `description:"临时标签"`
  51. IsMakerShow int `description:"是否仅决策人可见 0,否 、1,是"`
  52. VisibleRange int `description:"可见范围 1,仅本组可见 、2,全部客户可见"`
  53. Scale string `description:"管理规模,空不填,1::50亿以下,2:50~100亿,3:100亿以上。多个用, 隔开"`
  54. IsShowSubjectName int `description:"小程序内是否展示标的名称 1是 ,0 否 默认0 "`
  55. IsHideAppointment int `description:"是否隐藏预约纪要按钮 1是 ,0 否 默认0 "`
  56. AdminId int `description:"销售/管理员ID"`
  57. AdminName string `description:"销售/管理员姓名"`
  58. IsCanAppointmentMinutes int `description:"是否可预约纪要 1是 ,0 否 默认0 "`
  59. YidongActivityId string `description:"易董活动ID"`
  60. YidongActivityUrl string `description:"易董活动跳转地址"`
  61. YidongActivityEndTime string `description:"易董活动截止时间"`
  62. ActivityJoinType string `description:"活动入会类型01报名审核后可入会 02预约即可入会 03仅定向邀请人员可入会"`
  63. YidongSignUpEnd string `description:"易董活动截止时间"` // 报名结束时间,适应于报名审核后可入会,为空表示不限制报名时间
  64. YidongSignUpStart string `description:"易董活动截止时间"` // 报名开始时间,适应于报名审核后可入会,为空表示不限制报名时间
  65. }
  66. type Activity struct {
  67. ActivityTypeId int `description:"活动类型id"`
  68. ActivityTypeName string `description:"活动名称"`
  69. TemplateP string `description:"活动模板,带P标签"`
  70. Template string `description:"活动模板"`
  71. ShowType string `description:"人数限制类型,1不展示限制,2可选限制,3强制限制"`
  72. }
  73. type ActivityIdRep struct {
  74. ActivityId int `description:"活动id"`
  75. PlaySeconds int `description:"播放时长"`
  76. }
  77. type ActivitySingnupRep struct {
  78. ActivityId int `description:"活动id"`
  79. SignupType int `description:"报名方式,1预约外呼,2我要报名"`
  80. }
  81. type ActivityCcustomerType struct {
  82. CustomerTypeId int `description:"活动类型id"`
  83. CustomerName string `description:"活动名称"`
  84. }
  85. type ActivityCcustomerTypeList struct {
  86. List []*ActivityCcustomerType
  87. }
  88. //列表
  89. func GetActivityCcustomerTypeList() (items []*ActivityCcustomerType, err error) {
  90. o := orm.NewOrm()
  91. sql := `SELECT * FROM cygx_customer_type ORDER BY sort DESC`
  92. _, err = o.Raw(sql).QueryRows(&items)
  93. return
  94. }
  95. //活动添加、修改入参
  96. type ActivityRep struct {
  97. ActivityTypeId int `description:"活动类型id"`
  98. ChartPermissionId int `description:"行业id"`
  99. Body string `description:"内容"`
  100. LimitPeopleNum int `description:"限制的人数数量"`
  101. CustomerTypeIds string `description:"活动可见的客户类型,多个ID用 , 隔开"`
  102. ActivityId int `description:"活动ID 等于0新增活动,大于0修改活动"`
  103. DoType int `description:"操作类型 0,保存 、1,发布"`
  104. }
  105. type ActivityArticleResp struct {
  106. ReportLink string `description:"报告链接"`
  107. ArticleId int `description:"报告id(报告链接跳转使用)"`
  108. }
  109. //活动详情
  110. type ActivityDetail struct {
  111. ActivityId int `orm:"column(activity_id);pk";description:"活动ID "`
  112. ActivityTypeId int `description:"活动类型id"`
  113. ActivityTypeName string `description:"活动类型名称"`
  114. ChartPermissionId int `description:"行业id"`
  115. ChartPermissionName string `description:"行业名称"`
  116. ChartPermissionNames string `description:"行业名称辅助字段,区分研选子分类"`
  117. Body string `description:"内容"`
  118. CreateTime string `description:"创建时间"`
  119. IsLimitPeople int `description:"是否限制人数 1是,0否"`
  120. LimitPeopleNum int `description:"限制的人数数量"`
  121. LastUpdatedTime string `description:"更新时间"`
  122. ActivityTime string `description:"活动时间"`
  123. ActivityTimeText string `description:"活动时间带文字"`
  124. DistinguishedGuest string `description:"嘉宾"`
  125. Host string `description:"主持人"`
  126. Speaker string `description:"主讲人"`
  127. MainlandTell string `description:"大陆拨入号"`
  128. HongKongTell string `description:"香港拨入号"`
  129. TaiwanTell string `description:"台湾拨入号"`
  130. AmericaTell string `description:"美国拨入号"`
  131. ParticipationCode string `description:"参会密码"`
  132. Theme string `description:"主题"`
  133. Expert string `description:"专家"`
  134. ActivityName string `description:"活动名称"`
  135. OnlineParticipation string `description:"网络参会"`
  136. ReportLink string `description:"报告链接"`
  137. City string `description:"城市"`
  138. Address string `description:"活动地址"`
  139. Highlights string `description:"活动亮点"`
  140. Remarks string `description:"备注"`
  141. ShowType string `description:"人数限制类型,1不展示限制,2可选限制,3强制限制"`
  142. IsSignup int `description:"是否已报名 1是 ,0 否"`
  143. IsAppointment int `description:"是否已预约纪要 1是 ,0 否"`
  144. SignupNum int `description:"已报名人数"`
  145. SignupType int `description:"报名方式,1预约外呼,2自主拨入,3我要报名"`
  146. ActiveState string `description:"活动进行状态 未开始:1、进行中2、已结束3"`
  147. IsCancelMeetingReminder int `description:"是否取消会议提醒 1展示取消会议提醒 ,0展示会议提醒"`
  148. ArticleId int `description:"报告id(报告链接跳转使用)"`
  149. CustomerTypeIds string `description:"活动可见的客户类型,多个ID用 , 隔开"`
  150. IsShowSustainable bool `description:"是否展示限免标签"`
  151. Description string `description:"研选内容说明"`
  152. IsResearch bool `description:"是否属于研选"`
  153. LinkParticipants string `description:"链接参会"`
  154. AppAttendance string `description:"App参会"`
  155. ConferencePassword string `description:"会议密码"`
  156. Scale string `description:"管理规模,空不填,1::50亿以下,2:50~100亿,3:100亿以上。多个用, 隔开"`
  157. IsShowAppointment bool `description:"是否展示预约纪要"`
  158. IsHideAppointment int `description:"是否隐藏预约纪要按钮 1是,0 否"`
  159. IsCClassMeeting bool `description:"是否是c类电话会"`
  160. ArticleList []*ActivityArticleResp // 下面是列表添加的部分结构体
  161. IsBrackets int `description:"是否有方括号 1是 ,0 否"`
  162. Label string `description:"主题标签"`
  163. ImgUrl string `description:"图片链接"`
  164. ImgUrlText string `description:"图片链接文字"`
  165. ActivityType int `description:"活动线上线下类型 1线上,0 线下"`
  166. JmcjRoadshowTitle string `description:"进门财经手动匹配的活动名称"`
  167. Listndustrial []*IndustrialManagementRep `description:"活动关联的产业信息"`
  168. IsShowOutboundCall bool `description:"是否展示预约外呼"`
  169. IsShowMeetingReminder bool `description:"是否展示会议提醒"`
  170. IsShowHelpSsk bool `description:"是否展示帮我带问"`
  171. IsShowSignup bool `description:"是否展示我要报名"`
  172. IsShowDetails bool `description:"是否展示查看详情按钮"`
  173. TemporaryLabel string `description:"临时标签"`
  174. IsCanAppointmentMinutes int `description:"是否可预约纪要 1是 ,0 否 默认0 "`
  175. YidongActivityId string `description:"易董活动ID"`
  176. YidongActivityUrl string `description:"易董活动跳转地址"`
  177. AudioLink bool `description:"是否展示回放按钮"`
  178. VoiceList *CygxActivityVoiceReq `description:"音频数据"`
  179. AdminId int `description:"管理员、销售ID "`
  180. IsMakerShow int `description:"是否仅决策人可见 0,否 、1,是"`
  181. VisibleRange int `description:"可见范围 1,仅本组可见 、2,全部客户可见"`
  182. VideoDetail *CygxActivityVideoListResp `description:"视频数据"`
  183. FileType int `description:"类型: 1-音频; 2-视频"`
  184. IsCollect bool `description:"是否收藏"`
  185. SourceType int `description:"活动来源。 1:活动 、2:专项产业调研"`
  186. TripImgLink string `description:"专项产业调研行程链接"`
  187. ActivityTimeEnd string `description:"专项产业调研活动预期结束时间"`
  188. }
  189. type CygxActivityResp struct {
  190. HaqveJurisdiction bool `description:"是否有权限"`
  191. OperationMode string `description:"操作方式 Apply:立即申请、Call:拨号 为空则为有权限"`
  192. HasPermission int `description:"操作方式,1:有该行业权限,正常展示,2:无该行业权限,3:潜在客户,未提交过申请,4:潜在客户,已提交过申请,5:有IFCC、无权益"`
  193. PopupMsg string `description:"权限弹窗信息"`
  194. MsgType string `description:"Type : 类型 , Industry : 行业"`
  195. SellerMobile string `description:"销售电话"`
  196. SellerName string `description:"销售姓名"`
  197. Detail *ActivityDetail
  198. }
  199. //通过纪要ID获取活动详情
  200. func GetAddActivityInfoById(ActivityId int) (item *ActivityDetail, err error) {
  201. o := orm.NewOrm()
  202. sql := `SELECT * FROM cygx_activity WHERE activity_id=? AND publish_status = 1 `
  203. err = o.Raw(sql, ActivityId).QueryRow(&item)
  204. return
  205. }
  206. //通过活动名称获取活动详情
  207. func GetAddActivityInfoByTitle(title, startDate, endDate string) (item *ActivityDetail, err error) {
  208. o := orm.NewOrm()
  209. sql := `SELECT * FROM cygx_activity WHERE activity_time > '` + startDate + `' AND activity_time < '` + endDate + `' AND (activity_name_task LIKE '%` + title + `%' OR jmcj_roadshow_title LIKE '%` + title + `%') AND activity_id NOT IN (1328) LIMIT 1 `
  210. err = o.Raw(sql).QueryRow(&item)
  211. return
  212. }
  213. //通过纪要ID获取活动详情
  214. func GetAddActivityInfoByIdShow(uid, ActivityId int) (item *ActivityDetail, err error) {
  215. o := orm.NewOrm()
  216. 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,
  217. ( 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,
  218. ( 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,
  219. ( SELECT COUNT( 1 ) FROM cygx_activity_appointment AS ap WHERE ap.activity_id = a.activity_id AND ap.user_id = ? ) AS is_appointment
  220. FROM cygx_activity AS a WHERE activity_id=? AND publish_status = 1 `
  221. err = o.Raw(sql, uid, uid, uid, ActivityId).QueryRow(&item)
  222. return
  223. }
  224. //活动列表
  225. type CygxActivityList struct {
  226. ActivityId int `orm:"column(activity_id);pk";description:"活动ID 等于0新增活动,大于0修改活动"`
  227. ActivityTypeId int `description:"活动类型id"`
  228. ActivityName string `description:"活动名称"`
  229. ActivityTypeName string `description:"活动类型名称"`
  230. Speaker string `description:"主讲人"`
  231. SignupType int `description:"报名方式,1预约外呼,2我要报名"`
  232. ChartPermissionId int `description:"行业id"`
  233. ChartPermissionName string `description:"行业名称"`
  234. IsLimitPeople int `description:"是否限制人数 1是,0否"`
  235. LimitPeopleNum int `description:"限制的人数数量"`
  236. ActivityTime string `description:"活动时间"`
  237. ActivityTimeText string `description:"活动时间带文字"`
  238. City string `description:"城市"`
  239. Address string `description:"活动地址"`
  240. DistinguishedGuest string `description:"嘉宾"`
  241. Expert string `description:"专家"`
  242. IsSignup int `description:"是否已报名 1是 ,0 否"`
  243. IsAppointment int `description:"是否已预约纪要 1是 ,0 否"`
  244. IsShowAppointment bool `description:"是否展示预约纪要"`
  245. SignupNum int `description:"已报名人数"`
  246. ActiveState string `description:"活动进行状态 未开始:1、进行中2、已结束3"`
  247. IsCancelMeetingReminder int `description:"是否取消会议提醒 1展示取消会议提醒 ,0展示会议提醒"`
  248. IsBrackets int `description:"是否有方括号 1是 ,0 否"`
  249. Label string `description:"主题标签"`
  250. IsShowSustainable bool `description:"是否展示限免标签"`
  251. ImgUrl string `description:"图片链接"`
  252. ImgUrlText string `description:"图片链接文字"`
  253. ActivityType int `description:"活动线上线下类型 1线上,0 线下"`
  254. IsHideAppointment int `description:"是否隐藏预约纪要按钮 1是,0 否"`
  255. JmcjRoadshowTitle string `description:"进门财经手动匹配的活动名称"`
  256. IsCClassMeeting bool `description:"是否是c类电话会"`
  257. }
  258. type GetCygxActivityListRep struct {
  259. Paging *paging.PagingItem `description:"分页数据"`
  260. List []*ActivityDetail
  261. Label string `description:"主题"`
  262. ImgUrl string `description:"图片路径"`
  263. IsResearch bool `description:"是否属于研选"`
  264. IsJump bool `description:"是否跳转"`
  265. IndustrialManagementId int `description:"产业ID"`
  266. IndustryNewLabel bool `description:"产业是否新标签"`
  267. }
  268. //列表
  269. func GetActivityListAll(condition string, pars []interface{}, uid, startSize, pageSize, playBack int) (items []*ActivityDetail, err error) {
  270. var sqlJiontable string
  271. if playBack == 1 {
  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,
  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. _, err = o.Raw(sql, pars, uid, uid, uid, startSize, pageSize).QueryRows(&items)
  288. return
  289. }
  290. //列表
  291. func GetActivityListByDateTime(startDate, endDate, activityIds, activityIdsLongTime string) (items []*CygxActivityList, err error) {
  292. o := orm.NewOrm()
  293. sql := `SELECT * FROM cygx_activity WHERE activity_time > '` + startDate + `' AND activity_time < '` + endDate + `' `
  294. activityIds = strings.TrimRight(activityIds, ",")
  295. if activityIds != "" {
  296. sql += ` AND activity_id NOT IN (` + activityIds + `,1328 ) `
  297. }
  298. sql += ` OR activity_id IN (` + activityIdsLongTime + `)`
  299. _, err = o.Raw(sql).QueryRows(&items)
  300. return
  301. }
  302. //获取数量
  303. func GetActivityCount(condition string, playBack int, pars []interface{}, filter int) (count int, err error) {
  304. var sqlJiontable string
  305. if playBack == 1 {
  306. //sqlJiontable = ` INNER JOIN cygx_activity_voice AS ac ON ac.activity_id = art.activity_id `
  307. }
  308. if filter == 1 {
  309. sqlJiontable = ` INNER JOIN cygx_activity_video AS av ON av.activity_id = art.activity_id `
  310. } else if filter == 2 {
  311. sqlJiontable = ` INNER JOIN cygx_activity_voice AS ac ON ac.activity_id = art.activity_id `
  312. }
  313. sqlCount := ` SELECT COUNT(1) AS count FROM cygx_activity as art ` + sqlJiontable + ` WHERE 1= 1 `
  314. if condition != "" {
  315. sqlCount += condition
  316. }
  317. o := orm.NewOrm()
  318. err = o.Raw(sqlCount, pars).QueryRow(&count)
  319. return
  320. }
  321. //获取我的日程数量
  322. func GetScheduleCount(condition string, uid int) (count int, err error) {
  323. o := orm.NewOrm()
  324. sqlCount := `SELECT COUNT( 1 ) AS count
  325. FROM cygx_my_schedule AS m
  326. INNER JOIN cygx_activity AS art ON art.activity_id = m.activity_id
  327. WHERE
  328. user_id = ?`
  329. if condition != "" {
  330. sqlCount += condition
  331. }
  332. err = o.Raw(sqlCount, uid).QueryRow(&count)
  333. return
  334. }
  335. //我的日程列表
  336. func GetScheduleList(condition string, pars []interface{}, uid, startSize, pageSize int) (items []*ActivityDetail, err error) {
  337. o := orm.NewOrm()
  338. sql := `SELECT art.*,t.activity_type,t.img_url_text,c.image_url as img_url,
  339. ( 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,
  340. ( 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 ,
  341. ( SELECT COUNT( 1 ) FROM cygx_activity_appointment AS ap WHERE ap.activity_id = art.activity_id AND ap.user_id = ? ) AS is_appointment,
  342. ( 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
  343. FROM cygx_activity AS art
  344. INNER JOIN cygx_my_schedule as my ON my.activity_id = art.activity_id
  345. INNER JOIN cygx_activity_type as t ON t.activity_type_id = art.activity_type_id
  346. INNER JOIN chart_permission AS c ON c.chart_permission_id = art.chart_permission_id
  347. WHERE 1=1 AND my.user_id = ? `
  348. if condition != "" {
  349. sql += condition
  350. }
  351. sql += ` ORDER BY art.active_state ASC,art.activity_time ASC LIMIT ?,?`
  352. _, err = o.Raw(sql, pars, uid, uid, uid, uid, startSize, pageSize).QueryRows(&items)
  353. return
  354. }
  355. //我的日程列表 活动以及专项调研一起
  356. func GetScheduleAndSpecilList(condition string, pars []interface{}, conditionSpecil string, parsSpecil []interface{}, startSize, pageSize int) (items []*ActivityDetail, err error) {
  357. o := orm.NewOrm()
  358. sql := `SELECT
  359. art.activity_id,
  360. art.activity_time_text,
  361. art.activity_name,
  362. art.chart_permission_id,
  363. art.active_state,
  364. t.activity_type,
  365. art.chart_permission_name,
  366. art.distinguished_guest,
  367. art.expert,
  368. art.speaker,
  369. "" AS trip_img_link,
  370. "" AS activity_time_end,
  371. art.yidong_activity_id,
  372. art.is_can_appointment_minutes,
  373. art.activity_type_id,
  374. art.limit_people_num,
  375. 1 AS source_type,
  376. art.activity_time
  377. FROM
  378. cygx_activity AS art
  379. INNER JOIN cygx_my_schedule AS my ON my.activity_id = art.activity_id
  380. INNER JOIN cygx_activity_type AS t ON t.activity_type_id = art.activity_type_id
  381. INNER JOIN chart_permission AS c ON c.chart_permission_id = art.chart_permission_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. 2 AS source_type,
  406. art.activity_time
  407. FROM
  408. cygx_activity_special AS art
  409. INNER JOIN cygx_activity_special_trip AS my ON my.activity_id = art.activity_id
  410. WHERE
  411. 1 = 1`
  412. if conditionSpecil != "" {
  413. sql += conditionSpecil
  414. }
  415. sql += ` ORDER BY activity_time DESC LIMIT ?,?`
  416. _, err = o.Raw(sql, pars, parsSpecil, startSize, pageSize).QueryRows(&items)
  417. return
  418. }
  419. //获取数量
  420. func GetActivityCountById(activityId int) (count int, err error) {
  421. o := orm.NewOrm()
  422. sqlCount := `SELECT COUNT(1) AS count FROM cygx_activity WHERE activity_id = ?`
  423. err = o.Raw(sqlCount, activityId).QueryRow(&count)
  424. return
  425. }
  426. //删除数据
  427. func DeleteActivity(activityId int) (err error) {
  428. o := orm.NewOrm()
  429. sql := ` DELETE FROM cygx_activity WHERE activity_id = ?`
  430. _, err = o.Raw(sql, activityId).Exec()
  431. return
  432. }
  433. //修改活动状态至进行中
  434. func UpdateActivitySattusToHaveInHand() (err error) {
  435. defer func() {
  436. if err != nil {
  437. fmt.Println(err)
  438. go utils.SendAlarmMsg("修改活动状态至进行中失败"+err.Error(), 2)
  439. go utils.SendEmail(utils.APPNAME+"【"+utils.RunMode+"】"+"失败提醒", "修改活动状态至进行中失败 ErrMsg:"+err.Error(), utils.EmailSendToUsers)
  440. }
  441. }()
  442. o := orm.NewOrm()
  443. resultTime_30 := time.Now().Add(-time.Minute * 30).Format("2006-01-02 15:04:05")
  444. resultTime_60 := time.Now().Add(-time.Minute * 60).Format("2006-01-02 15:04:05")
  445. var sqlOr string
  446. var condition string
  447. condition += ` AND activity_time < NOW()`
  448. sqlOr = condition
  449. condition += ` AND (activity_type_id IN ( 1, 2, 3, 7 ) AND activity_time > ` + "'" + resultTime_30 + "'" + ")"
  450. condition += ` OR(activity_type_id IN ( 4, 5, 6 ) AND activity_time > ` + "'" + resultTime_60 + "'" + sqlOr + ")"
  451. msql := " UPDATE cygx_activity SET active_state = 2 WHERE 1 = 1 " + condition
  452. _, err = o.Raw(msql).Exec()
  453. return
  454. }
  455. //修改活动状态至已结束
  456. func UpdateActivitySattusToComplete() (err error) {
  457. defer func() {
  458. if err != nil {
  459. fmt.Println(err)
  460. go utils.SendAlarmMsg("修改活动状态至已结束"+err.Error(), 2)
  461. go utils.SendEmail(utils.APPNAME+"【"+utils.RunMode+"】"+"失败提醒", "修改活动状态至已结束 ErrMsg:"+err.Error(), utils.EmailSendToUsers)
  462. }
  463. }()
  464. o := orm.NewOrm()
  465. resultTime_30 := time.Now().Add(-time.Minute * 30).Format("2006-01-02 15:04:05")
  466. resultTime_60 := time.Now().Add(-time.Minute * 60).Format("2006-01-02 15:04:05")
  467. //var sqlOr string
  468. var condition string
  469. //condition += ` AND activity_time < NOW()`
  470. //sqlOr = condition
  471. condition += ` AND (activity_type_id IN ( 1, 2, 3, 7 ) AND activity_time < ` + "'" + resultTime_30 + "'" + ")"
  472. condition += ` OR(activity_type_id IN ( 4, 5, 6 ) AND activity_time < ` + "'" + resultTime_60 + "'" + ")"
  473. msql := " UPDATE cygx_activity SET active_state = 3 WHERE 1 = 1 " + condition
  474. _, err = o.Raw(msql).Exec()
  475. return
  476. }
  477. //活动详情
  478. type WxMsgCygxActivityList struct {
  479. Id int `description:"报名ID"`
  480. UserId int `description:"用户ID"`
  481. ActivityId int `description:"活动ID 等于0新增活动,大于0修改活动"`
  482. ActivityTypeId int `description:"活动类型id"`
  483. ActivityName string `description:"活动名称"`
  484. ActivityTypeName string `description:"活动类型名称"`
  485. Speaker string `description:"主讲人"`
  486. SignupType int `description:"报名方式,1预约外呼,2我要报名"`
  487. ChartPermissionId int `description:"行业id"`
  488. ChartPermissionName string `description:"行业名称"`
  489. IsLimitPeople int `description:"是否限制人数 1是,0否"`
  490. LimitPeopleNum int `description:"限制的人数数量"`
  491. ActivityTime string `description:"活动时间"`
  492. ActivityTimeText string `description:"活动时间带文字"`
  493. City string `description:"城市"`
  494. Address string `description:"活动地址"`
  495. DistinguishedGuest string `description:"嘉宾"`
  496. Expert string `description:"专家"`
  497. IsSignup int `description:"是否已报名 1是 ,0 否"`
  498. SignupNum int `description:"已报名人数"`
  499. ActiveState string `description:"活动进行状态 未开始:1、进行中2、已结束3"`
  500. IsCancelMeetingReminder int `description:"是否取消会议提醒 1展示取消会议提醒 ,0展示会议提醒"`
  501. IsBrackets int `description:"是否有方括号 1是 ,0 否"`
  502. OpenId string `description:"OenId"`
  503. FailType int `description:"失败原因,0,未失败,1总人数已满,2单机构超限制,3,爽约次数超限"`
  504. }
  505. //列表 3o分钟
  506. func GetActivitySendMsgListAll(endDate string) (items []*WxMsgCygxActivityList, err error) {
  507. o := orm.NewOrm()
  508. sql := `SELECT
  509. s.id,
  510. s.user_id,
  511. s.fail_type,
  512. cr.open_id,
  513. a.*
  514. FROM
  515. cygx_activity AS a
  516. INNER JOIN cygx_activity_signup AS s ON s.activity_id = a.activity_id
  517. INNER JOIN user_record AS c ON c.bind_account = s.mobile
  518. INNER JOIN cygx_user_record AS cr ON cr.union_id = c.union_id
  519. WHERE
  520. 1 = 1
  521. AND s.is_send_wx_msg = 0
  522. AND s.do_fail_type = 0
  523. AND a.publish_status = 1
  524. AND c.create_platform = 4
  525. AND a.activity_time <= ? AND a.activity_time >= NOW()
  526. AND s.is_cancel = 0
  527. AND( a.activity_type_id IN (4,5,6) OR (a.activity_type_id = 3 AND a.is_limit_people = 1 )) GROUP BY s.id`
  528. _, err = o.Raw(sql, endDate).QueryRows(&items)
  529. return
  530. }
  531. //列表 15分钟提醒
  532. func GetActivitySendMsgListAllMeeting(endDate string) (items []*WxMsgCygxActivityList, err error) {
  533. o := orm.NewOrm()
  534. sql := `SELECT
  535. m.id,
  536. cr.open_id,
  537. a.*
  538. FROM
  539. cygx_activity AS a
  540. INNER JOIN cygx_activity_meeting_reminder AS m ON m.activity_id = a.activity_id
  541. INNER JOIN user_record AS c ON c.bind_account = m.mobile
  542. INNER JOIN cygx_user_record AS cr ON cr.union_id = c.union_id
  543. WHERE
  544. 1 = 1
  545. AND m.is_send_wx_msg = 0
  546. AND a.publish_status = 1
  547. AND a.activity_time <= ? AND a.activity_time >= NOW()
  548. AND m.is_cancel = 0
  549. AND c.create_platform = 4
  550. AND (
  551. a.activity_type_id IN ( 1, 2 )
  552. OR ( a.activity_type_id = 3 AND a.is_limit_people = 0 ))
  553. GROUP BY m.id`
  554. _, err = o.Raw(sql, endDate).QueryRows(&items)
  555. return
  556. }
  557. //修改是否推送消息状态
  558. func UPdateSendedMsgStatus(signupIds string) (err error) {
  559. sql := ` UPDATE cygx_activity_signup SET is_send_wx_msg= 1 WHERE id IN(` + signupIds + `)`
  560. o := orm.NewOrm()
  561. _, err = o.Raw(sql).Exec()
  562. return
  563. }
  564. //修改是否推送消息状态
  565. func UPdateSendedMsgMeetingStatus(signupIds string) (err error) {
  566. sql := ` UPDATE cygx_activity_meeting_reminder SET is_send_wx_msg= 1 WHERE id IN(` + signupIds + `)`
  567. o := orm.NewOrm()
  568. _, err = o.Raw(sql).Exec()
  569. return
  570. }
  571. //获取满足推送的活动ID数量
  572. func GetCountActivityIdToSendFile(endDate string) (count int, err error) {
  573. o := orm.NewOrm()
  574. sql := `SELECT
  575. COUNT(1) count
  576. FROM
  577. cygx_activity AS a
  578. INNER JOIN cygx_activity_signup AS s ON s.activity_id = a.activity_id
  579. WHERE
  580. 1 = 1
  581. AND s.signup_type = 1
  582. AND s.fail_type = 0
  583. AND a.is_send_file_toemail = 0
  584. AND a.activity_time <= ? AND a.activity_time >= NOW() GROUP BY a.activity_id `
  585. err = o.Raw(sql, endDate).QueryRow(&count)
  586. return
  587. }
  588. //获取满足推送的活动ID
  589. func GetActivityIdToSendFile(endDate string) (items []*ActivityIdRep, err error) {
  590. o := orm.NewOrm()
  591. sql := `SELECT
  592. *
  593. FROM
  594. cygx_activity AS a
  595. INNER JOIN cygx_activity_signup AS s ON s.activity_id = a.activity_id
  596. INNER JOIN cygx_activity_type AS t ON a.activity_type_id = t.activity_type_id
  597. WHERE
  598. 1 = 1
  599. AND s.signup_type = 1
  600. AND a.yidong_activity_id = ''
  601. AND t.activity_type = 1
  602. AND s.fail_type = 0
  603. AND a.is_send_file_toemail = 0
  604. AND a.activity_time <= ? AND a.activity_time >= NOW() GROUP BY a.activity_id `
  605. _, err = o.Raw(sql, endDate).QueryRows(&items)
  606. return
  607. }
  608. type SignupExportRep struct {
  609. Mobile string `description:"手机号"`
  610. CompanyName string `description:"公司名称"`
  611. RealName string `description:"姓名"`
  612. CountryCode string `description:"区号"`
  613. OutboundMobile string `description:"外呼手机号"`
  614. SellerName string `description:"销售姓名"`
  615. }
  616. type ActivityMsgExportRep struct {
  617. UserId int `description:"用户ID"`
  618. RealName string `description:"姓名"`
  619. CompanyName string `description:"公司名称"`
  620. CompanyId int `description:"公司ID"`
  621. Content string `description:"内容"`
  622. CreateTime string `description:"提交时间"`
  623. }
  624. func GetSignupExport(activityId int) (item []*SignupExportRep, err error) {
  625. o := orm.NewOrm()
  626. sql := ` SELECT s.outbound_mobile,
  627. s.country_code,
  628. a.is_limit_people,
  629. u.real_name,
  630. ( SELECT p.seller_name FROM company_product AS p WHERE p.company_id = u.company_id AND p.product_id = 2 ) AS seller_name,
  631. ( SELECT c.company_name FROM company AS c WHERE c.company_id = u.company_id ) AS company_name
  632. FROM
  633. cygx_activity_signup AS s
  634. LEFT JOIN wx_user AS u ON u.user_id = s.user_id
  635. LEFT JOIN cygx_activity AS a ON a.activity_id = s.activity_id
  636. LEFT JOIN company_product AS p ON p.company_id = u.company_id
  637. WHERE a.activity_id = ? AND s.do_fail_type = 0 AND s.signup_type = 1 GROUP BY s.id `
  638. _, err = o.Raw(sql, activityId).QueryRows(&item)
  639. return
  640. }
  641. //修改文件是否推送状态
  642. func UPdateActivityIdToSendFile(activityId int) (err error) {
  643. sql := ` UPDATE cygx_activity SET is_send_file_toemail= 1 WHERE activity_id = ?`
  644. o := orm.NewOrm()
  645. _, err = o.Raw(sql, activityId).Exec()
  646. return
  647. }
  648. //活动详情
  649. type CygxActivityLabelList struct {
  650. KeyWord string `orm:"column(label)";description:"主题"`
  651. Timesort string `description:"最大时间"`
  652. Mintimesort string `description:"最小时间"`
  653. ImgUrlBg string `description:"背景图片"`
  654. ActivityId int `description:"活动ID "`
  655. IsShowSubjectName int `description:"小程序内是否展示标的名称 1是 ,0否 默认0 "`
  656. Resource int `description:"位置 ,1:活动 ,2:专项产业调研"`
  657. TemporaryLabel string `description:"临时标签"`
  658. IsNew bool `description:"是否为新:活动存在关联的的产业所关联的报告均在3个月内/无报告则标记新"`
  659. YidongActivityId int `description:"易董活动ID"`
  660. IsExternalLabel bool `description:"是否为外部资源"`
  661. }
  662. //主题列表
  663. func GetActivityLabelListAll(condition, sortTime string, pars []interface{}, startSize, pageSize int) (items []*CygxActivityLabelList, err error) {
  664. o := orm.NewOrm()
  665. 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
  666. FROM cygx_activity as art WHERE 1= 1 `
  667. if condition != "" {
  668. sql += condition
  669. }
  670. sql += ` GROUP BY art.label ORDER BY ` + sortTime + ` ,art.activity_id DESC LIMIT ?,? `
  671. _, err = o.Raw(sql, pars, startSize, pageSize).QueryRows(&items)
  672. return
  673. }
  674. type GetCygxActivityLabelListRep struct {
  675. Label string `description:"主题"`
  676. ImgUrl string `description:"图片路径"`
  677. List []*CygxActivityLabelList
  678. }
  679. //获取研选系列专家电话会,会前1小时,满足推送的活动ID数量
  680. func GetCountActivityResearchToSendFile(condition, endDate string) (count int, err error) {
  681. o := orm.NewOrm()
  682. sql := `SELECT
  683. COUNT(1) count
  684. FROM
  685. cygx_activity AS a
  686. INNER JOIN cygx_activity_help_ask AS k ON k.activity_id = a.activity_id
  687. WHERE
  688. 1 = 1 ` + condition + `
  689. AND a.is_send_ask_msg = 0
  690. AND a.activity_time <= ?
  691. AND a.activity_time >= NOW()`
  692. err = o.Raw(sql, endDate).QueryRow(&count)
  693. return
  694. }
  695. //获取研选系列专家电话会,会前1小时,满足推送的活动ID
  696. func GetActivityResearchToSendFile(condition, endDate string) (items []*ActivityIdRep, err error) {
  697. o := orm.NewOrm()
  698. sql := `SELECT
  699. *
  700. FROM
  701. cygx_activity AS a
  702. INNER JOIN cygx_activity_help_ask AS k ON k.activity_id = a.activity_id
  703. WHERE
  704. 1 = 1 ` + condition + `
  705. AND a.is_send_ask_msg = 0
  706. AND a.activity_time <= ?
  707. AND a.activity_time >= NOW()
  708. GROUP BY
  709. a.activity_id `
  710. _, err = o.Raw(sql, endDate).QueryRows(&items)
  711. return
  712. }
  713. func GetActivityMsgExport(activityId int) (item []*ActivityMsgExportRep, err error) {
  714. o := orm.NewOrm()
  715. sql := `SELECT
  716. k.*,
  717. u.real_name
  718. FROM
  719. cygx_activity_help_ask AS k
  720. LEFT JOIN wx_user AS u ON u.user_id = k.user_id
  721. WHERE
  722. k.activity_id = ?
  723. GROUP BY
  724. k.ask_id`
  725. _, err = o.Raw(sql, activityId).QueryRows(&item)
  726. return
  727. }
  728. //修改文件带问消息是否推送状态
  729. func UPdateActivityMsgToSendFile(activityId int) (err error) {
  730. sql := ` UPDATE cygx_activity SET is_send_ask_msg= 1 WHERE activity_id = ?`
  731. o := orm.NewOrm()
  732. _, err = o.Raw(sql, activityId).Exec()
  733. return
  734. }
  735. type AskEmailRep struct {
  736. Name string `description:"姓名"`
  737. Email string `description:"邮箱"`
  738. Mobile string `description:"手机号"`
  739. }
  740. func GetAskEmail() (item []*AskEmailRep, err error) {
  741. o := orm.NewOrm()
  742. sql := `SELECT * FROM cygx_activity_ask_email`
  743. _, err = o.Raw(sql).QueryRows(&item)
  744. return
  745. }
  746. //主题列表
  747. func GetActivityLabelSpecialListAll(condition string, pars []interface{}, startSize, pageSize int) (items []*CygxActivityLabelList, err error) {
  748. o := orm.NewOrm()
  749. sql := `SELECT label,activity_id,is_show_subject_name
  750. FROM cygx_activity_special as art WHERE 1= 1 `
  751. if condition != "" {
  752. sql += condition
  753. }
  754. sql += ` LIMIT ?,? `
  755. _, err = o.Raw(sql, pars, startSize, pageSize).QueryRows(&items)
  756. return
  757. }
  758. type GetCygxActivitySpecialDetailListResp struct {
  759. IsFollow bool `description:"是否关注新调研通知"`
  760. IsBindingMobile bool `description:"是否绑定了手机号"`
  761. Paging *paging.PagingItem `description:"分页数据"`
  762. List []*CygxActivitySpecialDetail
  763. }
  764. type CygxActivitySpecialResp struct {
  765. HaqveJurisdiction bool `description:"是否有权限"`
  766. OperationMode string `description:"操作方式 Apply:立即申请、Call:拨号 为空则为有权限"`
  767. HasPermission int `description:"操作方式,1:有该行业权限,正常展示,2:无该行业权限,3:潜在客户,未提交过申请,4:潜在客户,已提交过申请,5:有IFCC、无权益"`
  768. PopupMsg string `description:"权限弹窗信息"`
  769. MsgType string `description:"Type : 类型 , Industry : 行业"`
  770. SellerMobile string `description:"销售电话"`
  771. SellerName string `description:"销售姓名"`
  772. IsFollow bool `description:"是否关注新调研通知"`
  773. Detail *CygxActivitySpecialDetail
  774. }
  775. //获取专项调研活动列表
  776. func GetCygxActivitySpecialDetailList(condition string, pars []interface{}, uid, startSize, pageSize int) (items []*CygxActivitySpecialDetail, err error) {
  777. o := orm.NewOrm()
  778. sql := ` SELECT
  779. art.*,
  780. c.image_url AS img_url,
  781. (
  782. SELECT
  783. COUNT( 1 )
  784. FROM
  785. cygx_activity_special_signup AS s
  786. WHERE
  787. s.activity_id = art.activity_id
  788. AND s.user_id = ?
  789. ) AS is_signup
  790. FROM
  791. cygx_activity_special AS art
  792. INNER JOIN chart_permission AS c ON c.chart_permission_id = art.chart_permission_id
  793. WHERE
  794. 1 = 1 `
  795. if condition != "" {
  796. sql += condition
  797. }
  798. sql += ` LIMIT ?,? `
  799. _, err = o.Raw(sql, uid, pars, startSize, pageSize).QueryRows(&items)
  800. return
  801. }
  802. //通过活动ID获取活动详情
  803. func GetCygxActivitySpecialDetailById(uid, ActivityId int) (item *CygxActivitySpecialDetail, err error) {
  804. o := orm.NewOrm()
  805. sql := `SELECT *,( SELECT COUNT( 1 ) FROM cygx_activity_special_signup AS s WHERE s.activity_id = a.activity_id AND s.user_id = ? ) AS is_signup
  806. FROM
  807. cygx_activity_special AS a
  808. WHERE
  809. activity_id = ?
  810. AND publish_status = 1 AND is_offline = 0 `
  811. err = o.Raw(sql, uid, ActivityId).QueryRow(&item)
  812. return
  813. }
  814. //通过活动ID获取活动详情
  815. func GetCygxActivitySpecialDetail(ActivityId int) (item *CygxActivitySpecialDetail, err error) {
  816. o := orm.NewOrm()
  817. sql := `SELECT * FROM cygx_activity_special WHERE activity_id=? AND publish_status = 1 `
  818. err = o.Raw(sql, ActivityId).QueryRow(&item)
  819. return
  820. }
  821. func UpdateCygxActivityName(activityId int, Name string) (err error) {
  822. o := orm.NewOrm()
  823. sql := `UPDATE cygx_activity SET activity_name_task = ? WHERE activity_id=? `
  824. _, err = o.Raw(sql, Name, activityId).Exec()
  825. return
  826. }
  827. //获取已发布但是为开始活动的权限
  828. func GetActivityWeekPermission() (permission string, err error) {
  829. o := orm.NewOrm()
  830. sql := ` SELECT
  831. GROUP_CONCAT( DISTINCT chart_permission_name SEPARATOR ',' ) AS permission
  832. FROM
  833. cygx_activity
  834. WHERE
  835. active_state = 1`
  836. err = o.Raw(sql).QueryRow(&permission)
  837. return
  838. }
  839. //列表
  840. func GetIndustrialActivityGroupManagementList(activityId int) (items []*IndustrialManagementRep, err error) {
  841. o := orm.NewOrm()
  842. sql := `SELECT
  843. p.permission_name,
  844. p.chart_permission_id,
  845. m.industrial_management_id,
  846. m.industry_name
  847. FROM
  848. cygx_industrial_activity_group_management AS am
  849. INNER JOIN cygx_industrial_management AS m ON m.industrial_management_id = am.industrial_management_id
  850. INNER JOIN chart_permission AS p ON p.chart_permission_id = m.chart_permission_id
  851. WHERE
  852. am.activity_id = ? AND am.source = 1`
  853. _, err = o.Raw(sql, activityId).QueryRows(&items)
  854. return
  855. }
  856. //GetActivityListByYiDong 获取易董同步过来的活动列表
  857. func GetActivityListByYiDong() (items []*CygxActivity, err error) {
  858. o := orm.NewOrm()
  859. sql := ` SELECT * FROM cygx_activity WHERE yidong_activity_id != '' `
  860. _, err = o.Raw(sql).QueryRows(&items)
  861. return
  862. }
  863. //AddCygxActivity 添加活动
  864. func AddCygxActivity(item *CygxActivity) (lastId int64, err error) {
  865. o := orm.NewOrm()
  866. lastId, err = o.Insert(item)
  867. return
  868. }
  869. //列表
  870. func GetActivityListByYidong(condition string) (items []*ActivityDetail, err error) {
  871. o := orm.NewOrm()
  872. sql := `SELECT * FROM cygx_activity WHERE yidong_activity_id != '' `
  873. if condition != "" {
  874. sql += condition
  875. }
  876. _, err = o.Raw(sql).QueryRows(&items)
  877. return
  878. }
  879. //UpdateCygxActivitySubmitMeetingByYidong ,跟易董返回的用户状态修改活动以提交到会状态
  880. func UpdateCygxActivitySubmitMeetingByYidong(yidongActivityId string) (err error) {
  881. o := orm.NewOrm()
  882. sql := `UPDATE cygx_activity SET is_submit_meeting = 1 WHERE yidong_activity_id=? `
  883. _, err = o.Raw(sql, yidongActivityId).Exec()
  884. return
  885. }
  886. //UpdateActivityshowSubject 根据易董推过来的匹配信息,判断临时标签是否展示
  887. func UpdateActivityshowSubject(activityId int) (err error) {
  888. sql := ` UPDATE cygx_activity SET is_show_subject_name= 1 , temporary_label = '' WHERE activity_id = ?`
  889. o := orm.NewOrm()
  890. _, err = o.Raw(sql, activityId).Exec()
  891. return
  892. }
  893. //GetActivitySpecialSearcheList 活动与专项调研的搜索
  894. func GetActivitySpecialSearcheList(condition string, pars []interface{}, conditionSpecil string, parsSpecil []interface{}, startSize, pageSize int) (items []*ActivityDetail, total int, err error) {
  895. o := orm.NewOrm()
  896. sql := `SELECT
  897. art.activity_id,
  898. art.activity_time_text,
  899. art.activity_name,
  900. art.chart_permission_id,
  901. art.active_state,
  902. t.activity_type,
  903. art.chart_permission_name,
  904. art.distinguished_guest,
  905. art.expert,
  906. art.speaker,
  907. "" AS trip_img_link,
  908. "" AS activity_time_end,
  909. art.yidong_activity_id,
  910. art.is_can_appointment_minutes,
  911. art.activity_type_id,
  912. art.limit_people_num,
  913. 1 AS source_type,
  914. art.activity_time
  915. FROM
  916. cygx_activity AS art
  917. INNER JOIN cygx_activity_type AS t ON t.activity_type_id = art.activity_type_id
  918. WHERE
  919. 1 = 1 `
  920. if condition != `` {
  921. sql += condition
  922. }
  923. sql += ` UNION ALL
  924. SELECT
  925. art.activity_id,
  926. art.activity_time_text_by_day AS activity_time_text,
  927. art.research_theme AS activity_name,
  928. art.chart_permission_id,
  929. "",
  930. art.special_type AS activity_type,
  931. art.chart_permission_name,
  932. "",
  933. "",
  934. "",
  935. art.trip_img_link_fix AS trip_img_link,
  936. art.activity_time_end,
  937. "",
  938. "",
  939. "",
  940. "",
  941. 2 AS source_type,
  942. art.activity_time
  943. FROM
  944. cygx_activity_special AS art
  945. WHERE
  946. 1 = 1 `
  947. if conditionSpecil != "" {
  948. sql += conditionSpecil
  949. }
  950. totalSql := `SELECT COUNT(1) total FROM (` + sql + `) z `
  951. err = o.Raw(totalSql, pars, parsSpecil).QueryRow(&total)
  952. if err != nil {
  953. return
  954. }
  955. sql += ` ORDER BY activity_time DESC LIMIT ?,?`
  956. _, err = o.Raw(sql, pars, parsSpecil, startSize, pageSize).QueryRows(&items)
  957. return
  958. }
  959. //列表
  960. func GetActivityListNew(condition string, pars []interface{}, uid, startSize, pageSize, playBack, filter int, typeName string) (items []*ActivityDetail, err error) {
  961. var sqlJiontable string
  962. if playBack == 1 {
  963. //sqlJiontable = ` INNER JOIN cygx_activity_voice AS ac ON ac.activity_id = art.activity_id `
  964. }
  965. if filter == 1 {
  966. sqlJiontable = ` INNER JOIN cygx_activity_video AS av ON av.activity_id = art.activity_id `
  967. } else if filter == 2 {
  968. sqlJiontable = ` INNER JOIN cygx_activity_voice AS ac ON ac.activity_id = art.activity_id `
  969. }
  970. o := orm.NewOrm()
  971. sql := `SELECT art.* ,t.activity_type,t.img_url_text,c.image_url as img_url,
  972. ( 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,
  973. ( 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,
  974. ( 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,
  975. ( SELECT COUNT( 1 ) FROM cygx_activity_appointment AS ap WHERE ap.activity_id = art.activity_id AND ap.user_id = ? ) AS is_appointment
  976. FROM cygx_activity as art
  977. INNER JOIN cygx_activity_type as t ON t.activity_type_id = art.activity_type_id
  978. INNER JOIN chart_permission AS c ON c.chart_permission_id = art.chart_permission_id ` + sqlJiontable + ` WHERE 1= 1 `
  979. if condition != "" {
  980. sql += condition
  981. }
  982. sql += ` LIMIT ?,?`
  983. if typeName != "" {
  984. typeSlice := strings.Split(typeName, ",")
  985. tempCondition := ""
  986. for _, s := range typeSlice {
  987. if s == "1" {
  988. tempCondition += "'专家电话会',"
  989. } else if s == "2" {
  990. tempCondition += "'分析师电话会',"
  991. } else if s == "1,2" {
  992. tempCondition += "'专家电话会','分析师电话会',"
  993. }
  994. }
  995. tempCondition = strings.TrimRight(tempCondition, ",")
  996. sql = `SELECT * FROM(` + sql + `) AS t WHERE t.activity_type_name IN (` + tempCondition + `)`
  997. }
  998. _, err = o.Raw(sql, pars, uid, uid, uid, startSize, pageSize).QueryRows(&items)
  999. return
  1000. }
  1001. //主题列表
  1002. func GetActivityLabelListAllNoLimit(condition, sortTime string, pars []interface{}, conditionSpecial string) (items []*CygxActivityLabelList, err error) {
  1003. o := orm.NewOrm()
  1004. sql := `SELECT activity_id, label,temporary_label,is_show_subject_name, art.activity_time, 1 AS resource, yidong_activity_id
  1005. FROM cygx_activity as art WHERE 1= 1 `
  1006. if condition != "" {
  1007. sql += condition
  1008. }
  1009. sql += ` UNION ALL `
  1010. sql += ` SELECT
  1011. art.activity_id,
  1012. art.label,
  1013. art.temporary_label,
  1014. is_show_subject_name,
  1015. art.activity_time,
  1016. 2 AS resource,
  1017. '' AS yidong_activity_id
  1018. FROM
  1019. cygx_activity_special AS art WHERE 1= 1 ` + conditionSpecial
  1020. sql += ` GROUP BY label,resource ORDER BY ` + sortTime + ` , activity_id DESC `
  1021. _, err = o.Raw(sql, pars).QueryRows(&items)
  1022. return
  1023. }