activity.go 51 KB

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