activity.go 80 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786178717881789179017911792179317941795179617971798179918001801180218031804180518061807180818091810181118121813181418151816181718181819182018211822182318241825182618271828182918301831183218331834183518361837183818391840184118421843184418451846184718481849185018511852185318541855185618571858185918601861186218631864186518661867186818691870187118721873187418751876187718781879188018811882188318841885188618871888188918901891189218931894189518961897189818991900190119021903190419051906190719081909191019111912191319141915191619171918191919201921192219231924192519261927192819291930193119321933193419351936193719381939194019411942194319441945194619471948194919501951195219531954195519561957195819591960196119621963196419651966196719681969197019711972197319741975197619771978197919801981198219831984198519861987198819891990199119921993199419951996199719981999200020012002200320042005200620072008200920102011201220132014201520162017201820192020202120222023202420252026202720282029203020312032203320342035203620372038203920402041204220432044204520462047204820492050205120522053205420552056205720582059206020612062206320642065206620672068206920702071207220732074207520762077207820792080208120822083208420852086208720882089209020912092209320942095209620972098209921002101210221032104210521062107210821092110211121122113211421152116211721182119212021212122212321242125212621272128212921302131213221332134213521362137213821392140214121422143214421452146214721482149215021512152215321542155215621572158215921602161216221632164216521662167216821692170217121722173217421752176217721782179218021812182218321842185218621872188218921902191219221932194219521962197219821992200220122022203220422052206220722082209221022112212221322142215221622172218221922202221222222232224222522262227222822292230223122322233223422352236223722382239224022412242224322442245224622472248224922502251225222532254225522562257225822592260226122622263226422652266226722682269227022712272227322742275227622772278227922802281228222832284228522862287228822892290229122922293229422952296229722982299230023012302230323042305230623072308230923102311231223132314231523162317231823192320232123222323232423252326232723282329233023312332233323342335233623372338233923402341234223432344234523462347234823492350235123522353235423552356235723582359236023612362236323642365236623672368236923702371237223732374237523762377237823792380238123822383238423852386238723882389239023912392239323942395239623972398239924002401240224032404240524062407240824092410241124122413241424152416241724182419242024212422242324242425242624272428242924302431243224332434243524362437243824392440244124422443244424452446244724482449245024512452245324542455245624572458245924602461246224632464246524662467246824692470247124722473247424752476247724782479248024812482
  1. package controllers
  2. import (
  3. "encoding/json"
  4. "fmt"
  5. "github.com/rdlucklib/rdluck_tools/paging"
  6. "hongze/hongze_clpt/models"
  7. "hongze/hongze_clpt/services"
  8. "hongze/hongze_clpt/utils"
  9. "strconv"
  10. "strings"
  11. "time"
  12. )
  13. type ActivityController struct {
  14. BaseAuthController
  15. }
  16. type ActivityNoLoginController struct {
  17. BaseAuthMobileController
  18. }
  19. // @Title 活动类型下的主题列表
  20. // @Description 获取活动类型下的主题列表接口
  21. // @Param ChartPermissionIds query string false "行业id 多个用 , 隔开"
  22. // @Param ActivityTypeIds query string false "活动类型id 多个用 , 隔开"
  23. // @Param ActiveState query string false "活动进行状态 未开始:1、进行中2、已结束3 多个用 , 隔开"
  24. // @Param WhichDay query string false "哪一天 今天:1、明天:2,多个用 , 隔开"
  25. // @Param IsPower query int false "是否选择有权限行业 ,1是 0 否 默认0"
  26. // @Param IsExternalLabel query int false "是否仅展示外部资源 1:是、0:否 默认0"
  27. // @Param IsResearchPoints query int false "是否仅展示研选扣点 1:是、0:否 默认0"
  28. // @Param IsResearch query bool true "是否为研选"
  29. // @Success 200 {object} models.ActivityTypeListHomeResp
  30. // @router /labelTypeList [get]
  31. func (this *ActivityNoLoginController) LabelTypeList() {
  32. br := new(models.BaseResponse).Init()
  33. defer func() {
  34. this.Data["json"] = br
  35. this.ServeJSON()
  36. }()
  37. user := this.User
  38. if user == nil {
  39. br.Msg = "请登录"
  40. br.ErrMsg = "请登录,SysUser Is Empty"
  41. return
  42. }
  43. chartPermissionIds := this.GetString("ChartPermissionIds")
  44. isPower, _ := this.GetInt("IsPower")
  45. whichDay := this.GetString("WhichDay")
  46. activeState := this.GetString("ActiveState")
  47. isExternalLabel, _ := this.GetInt("IsExternalLabel") //
  48. isResearchPoints, _ := this.GetInt("IsResearchPoints") //
  49. isResearch, _ := this.GetBool("IsResearch", false) // 是否为研选 查研观向11.0 (研选活动独立显示)
  50. var condition string
  51. var conditioninit string
  52. var pars []interface{}
  53. // 查研观向7.4-始终查询宏观的活动
  54. if chartPermissionIds != "" {
  55. chartPermissionIds += ",1"
  56. }
  57. //condition += `AND art.activity_time > ? `
  58. //pars = append(pars, time.Now().AddDate(0, -3, 0).Format(utils.FormatDate))
  59. if isResearch {
  60. chartPermissionIds = strconv.Itoa(utils.CHART_PERMISSION_ID_YANXUAN)
  61. } else {
  62. conditioninit += ` AND ( art.chart_permission_id != ` + strconv.Itoa(utils.CHART_PERMISSION_ID_YANXUAN) + ` OR ( art.is_show_hz = 1 AND art.chart_permission_id = ` + strconv.Itoa(utils.CHART_PERMISSION_ID_YANXUAN) + `) )`
  63. conditioninit += ` AND IF ( art.active_state = 3, art.chart_permission_id != ` + strconv.Itoa(utils.CHART_PERMISSION_ID_YANXUAN) + `, 1 = 1 ) ` //V 11.0 研选活动结束后就不在已结束页面展示了
  64. }
  65. //行业名称
  66. if len(chartPermissionIds) > 0 {
  67. conditioninit += ` AND art.chart_permission_id IN (` + chartPermissionIds + `)`
  68. }
  69. //哪一天
  70. if whichDay != "" {
  71. var startDate string
  72. var endDate string
  73. if whichDay == "1" {
  74. startDate = time.Now().Format(utils.FormatDate)
  75. endDate = startDate
  76. } else if whichDay == "2" {
  77. startDate = time.Now().AddDate(0, 0, +1).Format(utils.FormatDate)
  78. endDate = startDate
  79. } else if whichDay == "3" {
  80. startDate = utils.GetNowWeekMonday().Format(utils.FormatDate)
  81. endDate = utils.GetNowWeekSunday().Format(utils.FormatDate)
  82. } else if whichDay == "4" {
  83. startDate = utils.GetLastWeekMonday().Format(utils.FormatDate)
  84. endDate = utils.GetLastWeekSunday().Format(utils.FormatDate)
  85. } else if whichDay == "5" {
  86. startDate = utils.GetNowMonthFirstDay().Format(utils.FormatDate)
  87. endDate = utils.GetNowMonthLastDay().Format(utils.FormatDate)
  88. } else if whichDay == "6" {
  89. startDate = utils.GetLastMonthFirstDay().Format(utils.FormatDate)
  90. endDate = utils.GetLastMonthLastDay().Format(utils.FormatDate)
  91. } else if whichDay == "1,2" {
  92. startDate = time.Now().Format(utils.FormatDate)
  93. endDate = time.Now().AddDate(0, 0, +1).Format(utils.FormatDate)
  94. } else if whichDay == "3,4" {
  95. startDate = utils.GetLastWeekMonday().Format(utils.FormatDate)
  96. endDate = utils.GetNowWeekSunday().Format(utils.FormatDate)
  97. } else if whichDay == "5,6" {
  98. startDate = utils.GetLastMonthFirstDay().Format(utils.FormatDate)
  99. endDate = utils.GetNowMonthLastDay().Format(utils.FormatDate)
  100. } else {
  101. startDate = time.Now().Format(utils.FormatDate)
  102. endDate = time.Now().AddDate(0, 0, +1).Format(utils.FormatDate)
  103. }
  104. conditioninit += ` AND art.activity_time >= ` + "'" + startDate + " 00:00:00'"
  105. conditioninit += ` AND art.activity_time <= ` + "'" + endDate + " 23:59:59'"
  106. }
  107. //活动状态搜索
  108. if activeState != "" {
  109. // 默认查看未开始跟进行中
  110. if activeState == "1" {
  111. conditioninit += ` AND art.active_state IN (1,2)`
  112. } else {
  113. conditioninit += ` AND art.active_state IN (` + activeState + `)`
  114. }
  115. } else {
  116. conditioninit += ` AND art.active_state IN (1,2)`
  117. }
  118. //是否为外部资源
  119. if isExternalLabel == 1 {
  120. conditioninit += ` AND art.is_external_label = 1 `
  121. }
  122. if isResearchPoints == 1 {
  123. conditioninit += ` AND art.is_research_points = 1 `
  124. }
  125. conditionActivity, err := services.ActivityConditioninitSql(user, conditioninit, isPower)
  126. //conditionActivity, err := services.GetActivityonditionList(user, "", chartPermissionIds, whichDay, activeState, "", isPower, 0, "", 0, 1)
  127. if err != nil && err.Error() != utils.ErrNoRow() {
  128. br.Msg = "获取失败"
  129. br.ErrMsg = "获取活动权限数据失败,Err:" + err.Error()
  130. return
  131. }
  132. //condition += ` AND art.is_limit_people = 1 ` + conditionActivity
  133. condition += conditionActivity
  134. sortTime := ` mintimesort ASC `
  135. if activeState == "3" {
  136. sortTime = ` timesort DESC `
  137. }
  138. activityList, err := models.GetCygxActivityList(condition, pars, sortTime, 0, 1000)
  139. if err != nil {
  140. br.Msg = "获取失败"
  141. br.ErrMsg = "获取数据失败,Err:" + err.Error()
  142. return
  143. }
  144. var conditionType string
  145. if isResearch {
  146. conditionType = " AND source_type IN (0,2) "
  147. } else {
  148. conditionType = " AND source_type IN (0,1) "
  149. }
  150. list, err := models.GetActivityTypeHomeList(conditionType)
  151. if err != nil {
  152. br.Msg = "获取失败"
  153. br.ErrMsg = "获取数据失败,Err:" + err.Error()
  154. return
  155. }
  156. list, err = services.HandleActivityTypeHomeList(list, activityList, user)
  157. //专项产业调研未开始状态不查询
  158. if activeState == "1" {
  159. activeState = ""
  160. }
  161. conditionActivitySpecial := services.ActivityLabelSpecialSql(chartPermissionIds, whichDay, activeState)
  162. speciaItem, err := services.GetActivityLabelSpecialList(user, conditionActivitySpecial, activeState)
  163. if err != nil {
  164. br.Msg = "获取失败"
  165. br.ErrMsg = "获取失败,Err:" + err.Error()
  166. return
  167. }
  168. if len(speciaItem.List) == 0 {
  169. speciaItem.List = make([]*models.CygxActivityLabelList, 0)
  170. }
  171. if speciaItem.ActivityTypeId > 0 {
  172. list = append(list, speciaItem)
  173. }
  174. resp := new(models.ActivityTypeListHomeResp)
  175. resp.List = list
  176. br.Ret = 200
  177. br.Success = true
  178. br.Msg = "获取成功"
  179. br.Data = resp
  180. }
  181. // @Title 活动列表
  182. // @Description 获取活动列表接口
  183. // @Param PageSize query int true "每页数据条数"
  184. // @Param CurrentIndex query int true "当前页页码,从1开始"
  185. // @Param Label query string false "搜索主题 多个用 , 隔开"
  186. // @Param ChartPermissionIds query string false "行业id 多个用 , 隔开"
  187. // @Param WhichDay query string false "哪一天 今天:1、明天:2, 本周:3 上周:4,本月:5上月:6多个用 , 隔开"
  188. // @Param ActiveState query string false "活动进行状态 未开始:1、进行中2、已结束3"
  189. // @Param ActivityTypeId query string false "活动类型id 多个用 , 隔开"
  190. // @Param Source query int false "来源 0手机 ,1Pc 默认0"
  191. // @Param IsPower query int false "是否选择有权限行业 ,1是 0 否 默认0"
  192. // @Param PlayBack query int false "是否仅展示回放 1:是、0:否 默认0"
  193. // @Param KeyWord query string false "搜索关键词 多个用 , 隔开"
  194. // @Param ActivityId query int false "活动列表传过来的活动ID"
  195. // @Param Filter query int false "筛选条件 0:全部 1:视频 2:音频"
  196. // @Param IsExternalLabel query int false "是否仅展示外部资源 1:是、0:否 默认0"
  197. // @Param IsResearchPoints query int false "是否仅展示研选扣点 1:是、0:否 默认0"
  198. // @Param IsResearch query bool false "是否为研选"
  199. // @Success 200 {object} models.GetCygxActivityListRep
  200. // @router /list [get]
  201. func (this *ActivityNoLoginController) ActivityListNew() {
  202. br := new(models.BaseResponse).Init()
  203. defer func() {
  204. this.Data["json"] = br
  205. this.ServeJSON()
  206. }()
  207. user := this.User
  208. if user == nil {
  209. br.Msg = "请登录"
  210. br.ErrMsg = "请登录,SysUser Is Empty"
  211. return
  212. }
  213. uid := user.UserId
  214. pageSize, _ := this.GetInt("PageSize")
  215. currentIndex, _ := this.GetInt("CurrentIndex")
  216. //source, _ := this.GetInt("Source")
  217. label := this.GetString("Label")
  218. chartPermissionIds := this.GetString("ChartPermissionIds")
  219. whichDay := this.GetString("WhichDay")
  220. //whichTime := this.GetString("WhichTime")
  221. activeState := this.GetString("ActiveState")
  222. activityTypeId := this.GetString("ActivityTypeId")
  223. keyWord := this.GetString("KeyWord")
  224. playBack, _ := this.GetInt("PlayBack")
  225. filter, _ := this.GetInt("Filter")
  226. isPower, _ := this.GetInt("IsPower")
  227. activityId, _ := this.GetInt("ActivityId") // 仅用于判断【新】标签
  228. isExternalLabel, _ := this.GetInt("IsExternalLabel") //
  229. isResearchPoints, _ := this.GetInt("IsResearchPoints") //
  230. isResearch, _ := this.GetBool("IsResearch", false) // 是否为研选 查研观向11.0 (研选活动独立显示)
  231. var startSize int
  232. if pageSize <= 0 {
  233. pageSize = utils.PageSize20
  234. }
  235. if currentIndex <= 0 {
  236. currentIndex = 1
  237. }
  238. startSize = utils.StartIndex(currentIndex, pageSize)
  239. var condition string
  240. var conditioninit string //初始化搜索条件
  241. var pars []interface{}
  242. //主题
  243. if label != "" {
  244. conditioninit += ` AND art.label LIKE "%` + label + `%" `
  245. }
  246. //是否是研选
  247. if isResearch {
  248. chartPermissionIds = strconv.Itoa(utils.CHART_PERMISSION_ID_YANXUAN)
  249. } else {
  250. conditioninit += ` AND ( art.chart_permission_id != '` + strconv.Itoa(utils.CHART_PERMISSION_ID_YANXUAN) + `' OR ( art.is_show_hz = 1 AND art.chart_permission_id = '` + strconv.Itoa(utils.CHART_PERMISSION_ID_YANXUAN) + `') )`
  251. conditioninit += ` AND IF ( art.active_state = 3, art.chart_permission_id != ` + strconv.Itoa(utils.CHART_PERMISSION_ID_YANXUAN) + `, 1 = 1 ) ` //V 11.0 研选活动结束后就不在已结束页面展示了
  252. }
  253. //行业名称
  254. if len(chartPermissionIds) > 0 {
  255. conditioninit += ` AND art.chart_permission_id IN (` + chartPermissionIds + `)`
  256. }
  257. //哪一天
  258. if whichDay != "" {
  259. var startDate string
  260. var endDate string
  261. if whichDay == "1" {
  262. startDate = time.Now().Format(utils.FormatDate)
  263. endDate = startDate
  264. } else if whichDay == "2" {
  265. startDate = time.Now().AddDate(0, 0, +1).Format(utils.FormatDate)
  266. endDate = startDate
  267. } else if whichDay == "3" {
  268. startDate = utils.GetNowWeekMonday().Format(utils.FormatDate)
  269. endDate = utils.GetNowWeekSunday().Format(utils.FormatDate)
  270. } else if whichDay == "4" {
  271. startDate = utils.GetLastWeekMonday().Format(utils.FormatDate)
  272. endDate = utils.GetLastWeekSunday().Format(utils.FormatDate)
  273. } else if whichDay == "5" {
  274. startDate = utils.GetNowMonthFirstDay().Format(utils.FormatDate)
  275. endDate = utils.GetNowMonthLastDay().Format(utils.FormatDate)
  276. } else if whichDay == "6" {
  277. startDate = utils.GetLastMonthFirstDay().Format(utils.FormatDate)
  278. endDate = utils.GetLastMonthLastDay().Format(utils.FormatDate)
  279. } else if whichDay == "1,2" {
  280. startDate = time.Now().Format(utils.FormatDate)
  281. endDate = time.Now().AddDate(0, 0, +1).Format(utils.FormatDate)
  282. } else if whichDay == "3,4" {
  283. startDate = utils.GetLastWeekMonday().Format(utils.FormatDate)
  284. endDate = utils.GetNowWeekSunday().Format(utils.FormatDate)
  285. } else if whichDay == "5,6" {
  286. startDate = utils.GetLastMonthFirstDay().Format(utils.FormatDate)
  287. endDate = utils.GetNowMonthLastDay().Format(utils.FormatDate)
  288. } else {
  289. startDate = time.Now().Format(utils.FormatDate)
  290. endDate = time.Now().AddDate(0, 0, +1).Format(utils.FormatDate)
  291. }
  292. conditioninit += ` AND art.activity_time >= ` + "'" + startDate + " 00:00:00'"
  293. conditioninit += ` AND art.activity_time <= ` + "'" + endDate + " 23:59:59'"
  294. }
  295. //活动状态搜索
  296. if activeState != "" {
  297. // 默认查看未开始跟进行中
  298. if activeState == "1" {
  299. conditioninit += ` AND art.active_state IN (1,2)`
  300. } else {
  301. conditioninit += ` AND art.active_state IN (` + activeState + `)`
  302. }
  303. } else {
  304. conditioninit += ` AND art.active_state IN (1,2)`
  305. }
  306. // 如果是分析师电话会,那么可以连同C类一起查看
  307. if activityTypeId != "" {
  308. if activityTypeId == strconv.Itoa(utils.ANALYST_TELL_ACTIVITY_TYPE_ID) {
  309. conditioninit += ` AND art.activity_type_id IN (` + activityTypeId + "," + strconv.Itoa(utils.C_CLASS_ACTIVITY_TYPE_ID) + `)`
  310. } else {
  311. conditioninit += ` AND art.activity_type_id IN (` + activityTypeId + `)`
  312. }
  313. }
  314. //关键词搜索
  315. if keyWord != "" {
  316. conditioninit += ` AND (art.label REGEXP '` + keyWord + `' OR art.activity_name REGEXP '` + keyWord + `' ) `
  317. }
  318. //回放
  319. if playBack == 1 {
  320. //获取所有带回放的活动ID
  321. playBackActivityIds, err := services.GetActivityPlayBackActivityIds()
  322. if err != nil {
  323. br.Msg = "获取失败"
  324. br.ErrMsg = "获取失败,Err:" + err.Error()
  325. return
  326. }
  327. conditioninit += ` AND art.activity_id IN ( ` + playBackActivityIds + `) `
  328. }
  329. //音频视频 1:视频 2:音频
  330. if filter > 0 {
  331. videoOrVoiceActivityIds, err := services.GetActivityVideoOrVoiceActivityIds(filter)
  332. if err != nil {
  333. br.Msg = "获取失败"
  334. br.ErrMsg = "获取失败,Err:" + err.Error()
  335. return
  336. }
  337. conditioninit += ` AND art.activity_id IN ( ` + videoOrVoiceActivityIds + `) `
  338. }
  339. if isExternalLabel == 1 && isResearchPoints == 1 {
  340. conditioninit += ` AND ( art.is_external_label = 1 OR art.is_research_points = 1 )`
  341. } else {
  342. //是否为外部资源
  343. if isExternalLabel == 1 {
  344. conditioninit += ` AND art.is_external_label = 1 `
  345. }
  346. // 是否为研选扣点
  347. if isResearchPoints == 1 {
  348. conditioninit += ` AND art.is_research_points = 1 `
  349. }
  350. }
  351. condition = ""
  352. //活动可见限制
  353. conditionActivity, err := services.ActivityConditioninitSql(user, conditioninit, isPower)
  354. if err != nil && err.Error() != utils.ErrNoRow() {
  355. br.Msg = "获取失败"
  356. br.ErrMsg = "获取活动权限数据失败,Err:" + err.Error()
  357. return
  358. }
  359. condition += ` AND art.publish_status = 1 ` + conditionActivity
  360. total, err := models.GetActivityCount(condition, playBack, pars, filter)
  361. if err != nil {
  362. br.Msg = "获取失败"
  363. br.ErrMsg = "获取失败,Err:" + err.Error()
  364. return
  365. }
  366. //return
  367. var conditionOrder string
  368. if activeState == "2" || activeState == "3" {
  369. conditionOrder = ` ORDER BY art.activity_time DESC `
  370. } else if activeState == "2,3" {
  371. conditionOrder = ` ORDER BY art.active_state ASC, art.activity_time DESC `
  372. } else {
  373. conditionOrder = ` ORDER BY art.activity_time DESC , art.active_state ASC `
  374. }
  375. if label != "" && activeState == "1" {
  376. conditionOrder = ` ORDER BY art.activity_time ASC `
  377. }
  378. //未开始进行中默认按照时间正序
  379. if activeState == "1" || activeState == "1,2" || activeState == "" {
  380. conditionOrder = ` ORDER BY art.activity_time ASC `
  381. }
  382. condition += conditionOrder
  383. list, errList := models.GetActivityListNew(condition, pars, uid, startSize, pageSize, playBack, filter, "")
  384. if errList != nil {
  385. br.Msg = "获取失败"
  386. br.ErrMsg = "获取失败,Err:" + errList.Error()
  387. return
  388. }
  389. var isShow bool
  390. isShow = services.GetShowSustainable()
  391. detail, err := models.GetConfigByCode("city_img_url")
  392. if err != nil {
  393. br.Msg = "获取数据失败"
  394. br.ErrMsg = "城市配置信息失败,Err:" + err.Error()
  395. return
  396. }
  397. detailChart, err := models.GetConfigByCode("chart_img_url")
  398. if err != nil {
  399. br.Msg = "获取数据失败"
  400. br.ErrMsg = "行业配置信息失败,Err:" + err.Error()
  401. return
  402. }
  403. addressList := strings.Split(detail.ConfigValue, "{|}")
  404. mapAddress := make(map[string]string)
  405. chartList := strings.Split(detailChart.ConfigValue, "{|}")
  406. mapChart := make(map[string]string)
  407. var cityName string
  408. var chartName string
  409. var imgUrl string
  410. var imgUrlChart string
  411. var mapActivityId []int
  412. for _, v := range addressList {
  413. vslice := strings.Split(v, "_")
  414. cityName = vslice[0]
  415. imgUrl = vslice[len(vslice)-1]
  416. mapAddress[cityName] = imgUrl
  417. }
  418. for _, v := range chartList {
  419. vslice := strings.Split(v, "_")
  420. chartName = vslice[0]
  421. imgUrlChart = vslice[len(vslice)-1]
  422. mapChart[chartName] = imgUrlChart
  423. }
  424. for k, v := range list {
  425. if strings.Contains(v.ActivityName, "【") {
  426. list[k].IsBrackets = 1
  427. }
  428. if v.SignupNum > v.LimitPeopleNum {
  429. list[k].SignupNum = v.LimitPeopleNum
  430. }
  431. if isShow && strings.Contains(v.ChartPermissionName, "研选") {
  432. list[k].IsShowSustainable = true
  433. }
  434. if strings.Contains(v.ChartPermissionName, "研选") && v.ActivityTypeId == 1 {
  435. //list[k].ActivityTypeName = "买方研选电话会"
  436. list[k].ImgUrlText = utils.YAN_XUAN_IMG
  437. }
  438. if v.ActivityType == 0 {
  439. if mapAddress[v.City] != "" {
  440. list[k].ImgUrl = mapAddress[v.City]
  441. } else {
  442. list[k].ImgUrl = mapAddress["其它"]
  443. }
  444. } else {
  445. if mapChart[v.ChartPermissionName] != "" {
  446. list[k].ImgUrl = mapChart[v.ChartPermissionName]
  447. }
  448. }
  449. expertTxt, _ := services.GetReportContentTextSub(v.Expert)
  450. list[k].Expert = expertTxt
  451. if v.ActivityTypeId == utils.C_CLASS_ACTIVITY_TYPE_ID {
  452. list[k].IsCClassMeeting = true
  453. }
  454. mapActivityId = append(mapActivityId, v.ActivityId)
  455. }
  456. page := paging.GetPaging(currentIndex, pageSize, total)
  457. resp := new(models.GetCygxActivityListRep)
  458. var activityList []*models.ActivityListResp
  459. resp.Label = label
  460. if activityTypeId != "" && label == "" {
  461. activityTypeIdint, err := strconv.Atoi(activityTypeId)
  462. if err == nil {
  463. detail, errDetail := models.GetActivityTypeDetailById(activityTypeIdint)
  464. if errDetail != nil {
  465. br.Msg = "获取信息失败"
  466. br.ErrMsg = "获取信息失败,Err:" + errDetail.Error()
  467. return
  468. }
  469. resp.ImgUrl = detail.OnlineIco
  470. resp.Label = detail.ActivityTypeName
  471. }
  472. }
  473. //处理音频回放
  474. mapActivityVoice, err := services.GetActivityVoiceResp(mapActivityId)
  475. if err != nil {
  476. br.Msg = "获取信息失败"
  477. br.ErrMsg = "GetActivityVoiceResp,Err:" + err.Error()
  478. return
  479. }
  480. //处理视频回放
  481. mapActivityVideo, err := services.GetActivityVideoResp(mapActivityId)
  482. if err != nil {
  483. br.Msg = "获取信息失败"
  484. br.ErrMsg = "GetActivityVideoResp,Err:" + err.Error()
  485. return
  486. }
  487. //用户权限
  488. authInfo, permissionArr, e := services.GetUserRaiPermissionInfo(user.UserId, user.CompanyId)
  489. if e != nil {
  490. br.Msg = "获取失败"
  491. br.ErrMsg = "获取用户权限失败, Err: " + e.Error()
  492. return
  493. }
  494. for k, v := range list {
  495. au := new(models.UserPermissionAuthInfo)
  496. au.SellerName = authInfo.SellerName
  497. au.SellerMobile = authInfo.SellerMobile
  498. au.HasPermission = authInfo.HasPermission
  499. au.OperationMode = authInfo.OperationMode
  500. if au.HasPermission == 1 {
  501. // 非宏观权限进一步判断是否有权限
  502. if v.ChartPermissionId != utils.HONG_GUAN_ID && !utils.InArrayByStr(permissionArr, v.ChartPermissionName) {
  503. au.HasPermission = 2
  504. }
  505. //如果是易董的活动,主、副权限有一个满足即可 查研观向 11.0
  506. if v.YidongActivityId != "" {
  507. if utils.InArrayByStr(permissionArr, v.ChartPermissionName) || utils.InArrayByStr(permissionArr, v.ChartPermissionNameDeputy) {
  508. au.HasPermission = 1
  509. }
  510. }
  511. }
  512. // 无权限的弹框提示
  513. if au.HasPermission != 1 {
  514. if au.OperationMode == services.UserPermissionOperationModeCall {
  515. if v.FileType == 1 {
  516. au.PopupMsg = services.UserPermissionPopupMsgCallMicroVoice
  517. } else {
  518. au.PopupMsg = services.UserPermissionPopupMsgCallMicroVideo
  519. }
  520. } else {
  521. if v.FileType == 1 {
  522. au.PopupMsg = services.UserPermissionPopupMsgApplyMicroVoice
  523. } else {
  524. au.PopupMsg = services.UserPermissionPopupMsgApplyMicroVideo
  525. }
  526. }
  527. }
  528. list[k].AuthInfo = au
  529. if mapActivityVoice[v.ActivityId] != nil {
  530. list[k].FileType = 1
  531. list[k].AudioLink = true
  532. if au.HasPermission == 1 {
  533. list[k].VoiceList = mapActivityVoice[v.ActivityId]
  534. }
  535. }
  536. if mapActivityVideo[v.ActivityId] != nil {
  537. list[k].FileType = 2
  538. list[k].AudioLink = true
  539. if au.HasPermission == 1 {
  540. list[k].VideoDetail = mapActivityVideo[v.ActivityId]
  541. }
  542. }
  543. //activityList = append(activityList, services.ActivityButtonShow(list[k], user, permissionArr))
  544. }
  545. activityList = services.ActivityArrButtonShow(list, user, permissionArr)
  546. //处理不同的报名方式按钮回显
  547. mapActivitySignup, err := services.GetActivitySignupResp(mapActivityId, user)
  548. if err != nil {
  549. br.Msg = "获取信息失败"
  550. br.ErrMsg = "GetActivitySignupResp,Err:" + err.Error()
  551. return
  552. }
  553. for _, v := range activityList {
  554. v.SignupType = mapActivitySignup[v.ActivityId]
  555. }
  556. // 查研观向7.4-判断标签是否为产业, 为产业时是否跳转资源包
  557. if label != "" {
  558. industry, e := models.GetIndustryByName(label)
  559. if e != nil && e.Error() != utils.ErrNoRow() {
  560. br.Msg = "获取信息失败"
  561. br.ErrMsg = "获取标签产业失败, Err:" + e.Error()
  562. return
  563. }
  564. if industry != nil {
  565. sourceIndustry, e := models.GetSourceIndustryByName(label)
  566. if e != nil && e.Error() != utils.ErrNoRow() {
  567. br.Msg = "获取信息失败"
  568. br.ErrMsg = "获取标签产业资源包失败, Err:" + e.Error()
  569. return
  570. }
  571. if sourceIndustry != nil {
  572. resp.IndustrialManagementId = sourceIndustry.IndustrialManagementId
  573. resp.ChartPermissionId = sourceIndustry.ChartPermissionId
  574. resp.IsJump = true
  575. // 研选产业不跳资源包
  576. if sourceIndustry.ChartPermissionId == utils.CHART_PERMISSION_ID_YANXUAN {
  577. resp.IsJump = false
  578. }
  579. }
  580. }
  581. // 新标签
  582. if activityId > 0 && activeState != "3" {
  583. activityIds := []int{activityId}
  584. activityNewMap, _, e := services.GetActivityNewLabelMap(activityIds)
  585. if e != nil {
  586. br.Msg = "获取信息失败"
  587. br.ErrMsg = "获取活动新标签失败, Err: " + e.Error()
  588. return
  589. }
  590. resp.IndustryNewLabel = activityNewMap[activityId]
  591. }
  592. }
  593. //添加活动搜索记录
  594. //if keyWord != "" {
  595. // go services.AddActivitykeyWordSearch(keyWord, user)
  596. //}
  597. if len(activityList) == 0 {
  598. activityList = make([]*models.ActivityListResp, 0)
  599. }
  600. if activityTypeId == "3" || activityTypeId == "5" {
  601. resp.IsShowResearchPoints = true
  602. }
  603. //预处理返给前端的字段
  604. resp.List = activityList
  605. resp.Paging = page
  606. br.Ret = 200
  607. br.Success = true
  608. br.Msg = "获取成功"
  609. br.Data = resp
  610. }
  611. // @Title 活动详情
  612. // @Description 获取活动详情接口
  613. // @Param ActivityId query int true "活动ID"
  614. // @Success Ret=200 {object} models.CygxActivityResp
  615. // @router /detail [get]
  616. func (this *ActivityController) Detail() {
  617. br := new(models.BaseResponse).Init()
  618. defer func() {
  619. this.Data["json"] = br
  620. this.ServeJSON()
  621. }()
  622. user := this.User
  623. if user == nil {
  624. br.Msg = "请登录"
  625. br.ErrMsg = "请登录,用户信息为空"
  626. br.Ret = 408
  627. return
  628. }
  629. uid := user.UserId
  630. activityId, _ := this.GetInt("ActivityId")
  631. if activityId < 1 {
  632. br.Msg = "请输入活动ID"
  633. return
  634. }
  635. resp := new(models.CygxActivityResp)
  636. activityInfo, err := models.GetAddActivityInfoByIdShow(uid, activityId)
  637. if err != nil && err.Error() != utils.ErrNoRow() {
  638. br.Msg = "获取信息失败"
  639. br.ErrMsg = "获取活动详情信息失败,Err:" + err.Error()
  640. return
  641. }
  642. if activityInfo == nil {
  643. br.Msg = "活动不存在"
  644. br.ErrMsg = "活动ID错误,Err:" + "activityId:" + strconv.Itoa(activityId)
  645. return
  646. }
  647. // 判断是否属于研选类型的活动
  648. if strings.Contains(activityInfo.ChartPermissionName, utils.CHART_PERMISSION_NAME_YANXUAN) {
  649. activityInfo.IsResearch = true
  650. }
  651. if activityInfo.ActivityTypeId == utils.C_CLASS_ACTIVITY_TYPE_ID {
  652. activityInfo.IsCClassMeeting = true
  653. }
  654. signupCount, err := models.GetActivitySignupSuccessByUserCountNoHz(activityId)
  655. if err != nil {
  656. br.Msg = "获取信息"
  657. br.ErrMsg = "GetActivitySignupSuccessByUserCountNoHz,Err:" + err.Error()
  658. return
  659. }
  660. activityInfo.SignupNum = signupCount
  661. havePower, isResearchSpecial, err := services.GetActivityDetailUserPower(user, activityInfo)
  662. if err != nil {
  663. br.Msg = "获取信息失败"
  664. br.ErrMsg = "校验用户权限失败,Err:" + err.Error()
  665. return
  666. }
  667. resp.IsResearchSpecial = isResearchSpecial
  668. if havePower {
  669. resp.HasPermission = 1
  670. //permissionArr := make([]string, 0)
  671. detailResp := services.ActivityButtonShow(activityInfo, user, make([]string, 0))
  672. detailResp, err = services.ActivityDetaailShow(detailResp)
  673. if err != nil {
  674. br.Msg = "获取信息失败"
  675. br.ErrMsg = "ActivityDetaailShow Err:" + err.Error() + "activityId:" + strconv.Itoa(activityId)
  676. return
  677. }
  678. //处理活动关联的产业
  679. industrialList, err := models.GetIndustrialActivityGroupManagementList(activityId)
  680. if err != nil && err.Error() != utils.ErrNoRow() {
  681. br.Msg = "获取信息失败"
  682. br.ErrMsg = "获取活动关联的产业列表信息失败,Err:" + err.Error() + "activityId:" + strconv.Itoa(activityId)
  683. return
  684. }
  685. if activityInfo.TemporaryLabel != "" {
  686. industrialList = make([]*models.IndustrialManagementRep, 0)
  687. item := new(models.IndustrialManagementRep)
  688. item.IndustryName = activityInfo.Label
  689. industrialList = append(industrialList, item)
  690. } else {
  691. industryIds := make([]int, 0)
  692. var industrialManagementId string
  693. for k, v := range industrialList {
  694. if v.ChartPermissionId == utils.CHART_PERMISSION_ID_YANXUAN {
  695. industrialList[k].IsResearch = true
  696. }
  697. industryIds = append(industryIds, v.IndustrialManagementId)
  698. industrialManagementId += strconv.Itoa(v.IndustrialManagementId) + ","
  699. }
  700. // 查研观向7.4-行业新标签
  701. industryNewMap, e := services.GetIndustryNewLabelMap(industryIds)
  702. if e != nil {
  703. br.Msg = "获取信息失败"
  704. br.ErrMsg = "获取产业新标签失败, Err: " + e.Error()
  705. return
  706. }
  707. //判断产业下是否有关联的报告,并处理是否跳转
  708. industrialManagementId = strings.TrimRight(industrialManagementId, ",")
  709. if industrialManagementId != "" {
  710. var condition string
  711. condition = ` AND m.industrial_management_id IN (` + industrialManagementId + `)`
  712. condition += ` AND a.article_id < ` + strconv.Itoa(utils.SummaryArticleId)
  713. listIndustrialGrop, err := models.GetSearchResourceList(condition)
  714. if err != nil && err.Error() != utils.ErrNoRow() {
  715. br.Msg = "获取信息失败"
  716. br.ErrMsg = "GetSearchResourceList,Err:" + err.Error() + "activityId:" + strconv.Itoa(activityId)
  717. return
  718. }
  719. mapIndustrial := make(map[int]int)
  720. if len(listIndustrialGrop) > 0 {
  721. for _, v := range listIndustrialGrop {
  722. mapIndustrial[v.IndustrialManagementId] = v.IndustrialManagementId
  723. }
  724. }
  725. for k, v := range industrialList {
  726. if mapIndustrial[v.IndustrialManagementId] > 0 && !industrialList[k].IsResearch {
  727. industrialList[k].IsJump = true
  728. }
  729. if activityInfo.ActivityTypeId == 1 {
  730. industrialList[k].IndustryNewLabel = industryNewMap[v.IndustrialManagementId]
  731. }
  732. }
  733. }
  734. }
  735. //if activityInfo.YidongActivityId != "" {
  736. // ydTgc, _ := services.GetYiDongCreateUserInfo(user)
  737. // yidongLongLink, err := services.GetYiDongOriginalLink(activityInfo)
  738. // if err != nil {
  739. // br.Msg = "获取信息失败"
  740. // br.ErrMsg = "GetYiDongOriginalLink,Err:" + err.Error() + "activityId:" + strconv.Itoa(activityId)
  741. // return
  742. // }
  743. // detailResp.YidongActivityUrl = yidongLongLink + "%26source=11%26fromHz=true%26tgc=" + ydTgc
  744. //}
  745. if len(industrialList) > 0 {
  746. detailResp.Label = ""
  747. }
  748. detailResp.Listndustrial = industrialList
  749. //处理音频回放
  750. var mapActivityId []int
  751. mapActivityId = append(mapActivityId, activityId)
  752. mapActivityVoice, err := services.GetActivityVoiceResp(mapActivityId)
  753. if err != nil {
  754. br.Msg = "获取信息失败"
  755. br.ErrMsg = "GetActivityVoiceResp,Err:" + err.Error() + "activityId:" + strconv.Itoa(activityId)
  756. return
  757. }
  758. if mapActivityVoice[activityId] != nil {
  759. detailResp.FileType = 1
  760. detailResp.AudioLink = true
  761. detailResp.VoiceDetail = mapActivityVoice[activityId]
  762. }
  763. //处理视频回放
  764. mapActivityVideo, err := services.GetActivityVideoResp(mapActivityId)
  765. if err != nil {
  766. br.Msg = "获取信息失败"
  767. br.ErrMsg = "GetActivityVideoResp,Err:" + err.Error()
  768. return
  769. }
  770. if mapActivityVideo[activityId] != nil {
  771. detailResp.FileType = 2
  772. detailResp.AudioLink = true
  773. detailResp.VideoDetail = mapActivityVideo[activityId]
  774. }
  775. //处理不同的报名方式按钮回显
  776. mapActivitySignup, err := services.GetActivitySignupResp(mapActivityId, user)
  777. if err != nil {
  778. br.Msg = "获取信息失败"
  779. br.ErrMsg = "GetActivitySignupResp,Err:" + err.Error()
  780. return
  781. }
  782. detailResp.SignupType = mapActivitySignup[activityId]
  783. resp.Detail = detailResp
  784. } else {
  785. hasPermission, sellerName, sellerMobile, popupMsg, err := services.GetUserHasPermission(user)
  786. if err != nil {
  787. br.Msg = "获取信息失败"
  788. br.ErrMsg = "判断是否已申请过试用失败,Err:" + err.Error()
  789. return
  790. }
  791. popupMsg = "暂无查看权限"
  792. resp.PopupMsg = popupMsg
  793. resp.HasPermission = hasPermission
  794. resp.SellerName = sellerName
  795. resp.SellerMobile = sellerMobile
  796. }
  797. // 判断是否属于研选类型的活动
  798. if strings.Contains(activityInfo.ChartPermissionName, utils.CHART_PERMISSION_NAME_YANXUAN) {
  799. resp.IsResearch = true
  800. }
  801. br.Ret = 200
  802. br.Success = true
  803. br.Msg = "获取成功"
  804. br.Data = resp
  805. }
  806. // @Title 活动报名
  807. // @Description 活动报名接口
  808. // @Param request body models.ActivitySingnupRep true "type json string"
  809. // @Success Ret=200 {object} models.SignupStatus
  810. // @router /signup/add [post]
  811. func (this *ActivityController) SignupAdd() {
  812. br := new(models.BaseResponse).Init()
  813. defer func() {
  814. this.Data["json"] = br
  815. this.ServeJSON()
  816. }()
  817. user := this.User
  818. if user == nil {
  819. br.Msg = "请登录"
  820. br.ErrMsg = "请登录,用户信息为空"
  821. br.Ret = 408
  822. return
  823. }
  824. uid := user.UserId
  825. signupStatus := ""
  826. var req models.ActivitySingnupRep
  827. resp := new(models.SignupStatus)
  828. var total int
  829. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  830. if err != nil {
  831. br.Msg = "参数解析异常!"
  832. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  833. return
  834. }
  835. activityId := req.ActivityId
  836. signupType := req.SignupType
  837. email := req.Email
  838. //如果用户传了邮箱就绑定邮箱
  839. if email != "" && user.Email == "" {
  840. if !utils.ValidateEmailFormatat(req.Email) {
  841. br.Msg = "邮箱格式错误,请重新输入"
  842. br.ErrMsg = "邮箱格式错误,请重新输入"
  843. return
  844. }
  845. user.Email = req.Email
  846. err = models.UpdateUserEmail(email, uid)
  847. if err != nil {
  848. br.Msg = "操作失败"
  849. br.ErrMsg = "绑定客户邮箱失败!"
  850. }
  851. }
  852. hasPermission := 0
  853. if signupType == 1 && user.Mobile == "" && user.OutboundMobile == "" {
  854. resp.GoBindEmail = true
  855. }
  856. activityInfo, errInfo := models.GetAddActivityInfoById(activityId)
  857. if activityInfo == nil {
  858. br.Msg = "操作失败"
  859. br.ErrMsg = "活动ID错误,不存在activityId:" + strconv.Itoa(activityId)
  860. return
  861. }
  862. if errInfo != nil {
  863. br.Msg = "操作失败"
  864. br.ErrMsg = "操作失败,Err:" + errInfo.Error()
  865. return
  866. }
  867. // 如果是 易董办会 且没有勾选 可提供外呼 默认为自主入会
  868. if activityInfo.IsYidongConduct && activityInfo.IsCanOutboundCall == 0 {
  869. signupType = 4
  870. }
  871. havePower, isResearchSpecial, err := services.GetActivityDetailUserPower(user, activityInfo)
  872. if err != nil {
  873. br.Msg = "获取信息失败"
  874. br.ErrMsg = "校验用户权限失败,Err:" + err.Error()
  875. return
  876. }
  877. resp.IsResearchSpecial = isResearchSpecial
  878. if havePower {
  879. item := new(models.CygxActivitySignup)
  880. item.RegisterPlatform = utils.REGISTER_PLATFORM
  881. resp.HasPermission = 1
  882. hasPermission = 1
  883. signupStatus = "Success"
  884. resultTime := utils.StrTimeToTime(activityInfo.ActivityTime) //时间字符串格式转时间格式
  885. if time.Now().After(resultTime.Add(-time.Minute * 60)) {
  886. signupStatus = "Overtime"
  887. resp.SignupType = signupType
  888. resp.SignupStatus = signupStatus
  889. resp.HasPermission = hasPermission
  890. resp.PopupMsg = "活动开始前1小时内无法预约,请联系对口销售处理"
  891. br.Ret = 200
  892. br.Success = true
  893. br.Msg = ""
  894. br.Data = resp
  895. return
  896. }
  897. var sellerName string
  898. sellerName, err = models.GetCompanySellerName(user.CompanyId)
  899. if err != nil {
  900. br.Msg = "报名失败!"
  901. br.ErrMsg = "获取对应销售失败,Err:" + err.Error()
  902. return
  903. }
  904. popupMsg, err := services.CheckActivityUserAll(activityInfo, user)
  905. if err != nil {
  906. br.Msg = "报名失败!"
  907. br.ErrMsg = "CheckActivityUserAll,Err:" + err.Error()
  908. return
  909. }
  910. if popupMsg != "" {
  911. br.Msg = "报名失败!"
  912. br.ErrMsg = fmt.Sprint("userId:", uid, "Activity:id", popupMsg)
  913. return
  914. }
  915. //人数已满:FullStarffed、单机构超过两人:TwoPeople、爽约次数过多:BreakPromise、超时:Overtime 、成功:Success"`
  916. //如果是下面几种情况则对报名信息做判断限制 (公司调研电话会(限制人数)、公司线下调研、专家/分析师线下沙龙)
  917. //if (activityInfo.ActivityTypeId == 3 && activityInfo.IsLimitPeople == 1) || activityInfo.ActivityTypeId > 3 {
  918. if activityInfo.IsLimitPeople == 1 {
  919. signupStatus, resp.PopupMsg, item.FailType, err = services.CheckActivitySignUpLimit(user, activityInfo)
  920. //判断优先级:总人数限制→单机构2人限制→爽约3次限制
  921. totalRestrict, err := models.GetUserRestrictCount(user.Mobile)
  922. if err != nil {
  923. br.Msg = "获取信息失败"
  924. br.ErrMsg = "获取客户信息失败,Err:" + err.Error()
  925. return
  926. }
  927. totalUserRestrictCount, err := models.GetActivitySignupByUserRestrictCount(uid, activityId)
  928. if err != nil {
  929. br.Msg = "获取失败"
  930. br.ErrMsg = "获取失败,Err:" + err.Error()
  931. return
  932. }
  933. //解除报名限制之后二次报名相同活动
  934. if totalUserRestrictCount > 0 && totalRestrict == 0 && resp.GoBindEmail != true {
  935. item.UserId = uid
  936. item.RealName = user.RealName
  937. item.SellerName = sellerName
  938. item.ActivityId = activityId
  939. item.CreateTime = time.Now()
  940. item.Mobile = user.Mobile
  941. item.Email = user.Email
  942. item.CompanyId = user.CompanyId
  943. item.CompanyName = user.CompanyName
  944. item.SignupType = signupType
  945. item.FailType = 0
  946. item.DoFailType = 0
  947. _, errSignup := models.AddActivitySignupByRestrict(item)
  948. if errSignup != nil {
  949. br.Msg = "操作失败"
  950. br.ErrMsg = "操作失败,Err:" + errSignup.Error()
  951. return
  952. }
  953. resp.HaqveJurisdiction = true
  954. resp.SignupType = signupType
  955. resp.SignupStatus = "Success"
  956. resp.HasPermission = hasPermission
  957. resp.ActivityId = activityId
  958. total, err = models.GetUserMeetingReminderCount(user.UserId)
  959. if err != nil {
  960. br.Msg = "获取信息失败"
  961. br.ErrMsg = "获取日程数量信息失败,Err:" + err.Error()
  962. return
  963. }
  964. if total == 0 {
  965. resp.GoFollow = true
  966. }
  967. br.Ret = 200
  968. br.Success = true
  969. br.Msg = "操作成功"
  970. br.Data = resp
  971. return
  972. }
  973. totalMy, err := models.GetActivitySignupByUserCount(uid, activityId)
  974. if err != nil {
  975. br.Msg = "获取失败"
  976. br.ErrMsg = "获取失败,Err:" + err.Error()
  977. return
  978. }
  979. if signupStatus != "Success" && totalMy == 0 && resp.GoBindEmail != true {
  980. item.UserId = uid
  981. item.RealName = user.RealName
  982. item.SellerName = sellerName
  983. item.ActivityId = activityId
  984. item.CreateTime = time.Now()
  985. item.Mobile = user.Mobile
  986. item.Email = user.Email
  987. item.CompanyId = user.CompanyId
  988. item.CompanyName = user.CompanyName
  989. item.SignupType = signupType
  990. item.DoFailType = item.FailType
  991. if user.OutboundMobile != "" {
  992. item.OutboundMobile = user.OutboundMobile
  993. if user.OutboundCountryCode == "" {
  994. item.CountryCode = "86"
  995. } else {
  996. item.CountryCode = user.OutboundCountryCode
  997. }
  998. } else {
  999. item.OutboundMobile = user.Mobile
  1000. if user.CountryCode == "" {
  1001. item.CountryCode = "86"
  1002. } else {
  1003. item.CountryCode = user.CountryCode
  1004. }
  1005. }
  1006. //添加报名信息,但是不加入日程
  1007. _, errSignup := models.AddActivitySignupNoSchedule(item)
  1008. if errSignup != nil {
  1009. br.Msg = "操作失败"
  1010. br.ErrMsg = "操作失败,Err:" + errSignup.Error()
  1011. return
  1012. }
  1013. }
  1014. }
  1015. totalMySuccess, err := models.GetActivitySignupCount(uid, activityId)
  1016. if err != nil {
  1017. br.Msg = "获取失败"
  1018. br.ErrMsg = "获取失败,Err:" + err.Error()
  1019. return
  1020. }
  1021. if totalMySuccess > 0 {
  1022. br.Msg = "您已报名这个活动"
  1023. return
  1024. }
  1025. if signupStatus == "Success" && resp.GoBindEmail != true {
  1026. item.UserId = uid
  1027. item.RealName = user.RealName
  1028. item.SellerName = sellerName
  1029. item.ActivityId = activityId
  1030. item.CreateTime = time.Now()
  1031. item.Mobile = user.Mobile
  1032. item.Email = user.Email
  1033. item.CompanyId = user.CompanyId
  1034. item.CompanyName = user.CompanyName
  1035. item.SignupType = signupType
  1036. item.FailType = 0
  1037. item.DoFailType = 0
  1038. item.OutboundMobile = user.Mobile
  1039. if user.OutboundMobile != "" {
  1040. item.OutboundMobile = user.OutboundMobile
  1041. if user.OutboundCountryCode == "" {
  1042. item.CountryCode = "86"
  1043. } else {
  1044. item.CountryCode = user.OutboundCountryCode
  1045. }
  1046. } else {
  1047. item.OutboundMobile = user.Mobile
  1048. if user.CountryCode == "" {
  1049. item.CountryCode = "86"
  1050. } else {
  1051. item.CountryCode = user.CountryCode
  1052. }
  1053. }
  1054. _, errSignup := models.AddActivitySignup(item)
  1055. if errSignup != nil {
  1056. br.Msg = "操作失败"
  1057. br.ErrMsg = "操作失败,Err:" + errSignup.Error()
  1058. return
  1059. }
  1060. resp.HaqveJurisdiction = true
  1061. //1:预约外呼 、2:设置会议提醒 、 3:预约纪要 、4:活动报名
  1062. if signupType == 1 {
  1063. go services.ActivityUserRemind(user, activityInfo, 1)
  1064. resp.PopupMsg = "<b>预约成功,已加入您的活动日程</b><br/><br/>想要及时获取活动信息变更通知,请关注【查研观向小助手】公众号"
  1065. } else if signupType == 4 {
  1066. go services.ActivityUserRemind(user, activityInfo, 4)
  1067. resp.PopupMsg = "<b>报名成功,请复制腾讯会议号打开腾讯会议app参会</b><br/><br/>想要及时获取活动信息变更通知,请关注【查研观向小助手】公众号"
  1068. } else {
  1069. go services.ActivityUserRemind(user, activityInfo, 4)
  1070. resp.PopupMsg = "<b>报名成功,已加入您的活动日程</b><br/><br/>想要及时获取活动信息变更通知,请关注【查研观向小助手】公众号"
  1071. }
  1072. if activityInfo.IsResearchPoints {
  1073. resp.PopupMsg = "<b>报名成功,已加入您的活动日程</b><br/><br/>想要及时获取活动信息变更通知,请关注【查研观向小助手】公众号"
  1074. }
  1075. go services.YanXuanActivityPointsBillSignupAdd(activityId, uid) // 用户报名添加到处理研选扣点
  1076. }
  1077. } else {
  1078. hasPermission, sellerName, sellerMobile, popupMsg, err := services.GetUserHasPermission(user)
  1079. if err != nil {
  1080. br.Msg = "获取信息失败"
  1081. br.ErrMsg = "判断是否已申请过试用失败,Err:" + err.Error()
  1082. return
  1083. }
  1084. popupMsg = "暂无查看权限"
  1085. resp.PopupMsg = popupMsg
  1086. resp.HasPermission = hasPermission
  1087. resp.SellerName = sellerName
  1088. resp.SellerMobile = sellerMobile
  1089. }
  1090. if signupType == 1 && user.IsMsgOutboundMobile == 0 {
  1091. resp.GoOutboundMobile = true
  1092. if user.Mobile != "" || user.OutboundMobile != "" {
  1093. go models.ModifyWxUserIsMsgOutboundMobile(user.UserId)
  1094. }
  1095. }
  1096. if user.OutboundMobile == "" {
  1097. resp.Mobile = user.Mobile
  1098. if user.CountryCode == "" && len(user.Mobile) == 11 {
  1099. resp.CountryCode = "86"
  1100. } else {
  1101. resp.CountryCode = user.CountryCode
  1102. }
  1103. } else {
  1104. resp.Mobile = user.OutboundMobile
  1105. resp.CountryCode = user.OutboundCountryCode
  1106. }
  1107. //如果用户有绑定手机号,但是没有绑定外呼手机号
  1108. if signupType == 1 && user.Mobile != "" && user.OutboundMobile == "" {
  1109. var countryCode string
  1110. if len(user.Mobile) == 8 {
  1111. countryCode = "852"
  1112. } else if len(user.Mobile) == 9 {
  1113. countryCode = "886"
  1114. } else if len(user.Mobile) == 10 {
  1115. countryCode = "1"
  1116. } else if len(user.Mobile) >= 11 {
  1117. countryCode = "86"
  1118. }
  1119. models.BindUserOutboundMobileByMobile(user.Mobile, countryCode, uid)
  1120. }
  1121. // 判断是否属于研选类型的活动
  1122. if strings.Contains(activityInfo.ChartPermissionName, utils.CHART_PERMISSION_NAME_YANXUAN) {
  1123. resp.IsResearch = true
  1124. }
  1125. resp.SignupType = signupType
  1126. resp.SignupStatus = signupStatus
  1127. //resp.HasPermission = hasPermission
  1128. //if signupStatus == "Success" {
  1129. resp.ActivityId = activityId
  1130. //}
  1131. total, err = models.GetUserSignupCount(user.UserId)
  1132. if err != nil {
  1133. br.Msg = "获取信息失败"
  1134. br.ErrMsg = "获取日程数量信息失败,Err:" + err.Error()
  1135. return
  1136. }
  1137. if total <= 1 {
  1138. resp.GoFollow = true
  1139. }
  1140. br.Ret = 200
  1141. br.Success = true
  1142. br.Msg = "操作成功"
  1143. br.Data = resp
  1144. }
  1145. // @Title 活动取消报名
  1146. // @Description 活动取消报名接口
  1147. // @Param request body models.ActivitySingnupRep true "type json string"
  1148. // @Success Ret=200 {object} models.SignupStatus
  1149. // @router /signup/cancel [post]
  1150. func (this *ActivityController) SignupCancel() {
  1151. br := new(models.BaseResponse).Init()
  1152. defer func() {
  1153. this.Data["json"] = br
  1154. this.ServeJSON()
  1155. }()
  1156. user := this.User
  1157. if user == nil {
  1158. br.Msg = "请登录"
  1159. br.ErrMsg = "请登录,用户信息为空"
  1160. br.Ret = 408
  1161. return
  1162. }
  1163. uid := user.UserId
  1164. var req models.ActivitySingnupRep
  1165. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  1166. if err != nil {
  1167. br.Msg = "参数解析异常!"
  1168. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  1169. return
  1170. }
  1171. activityId := req.ActivityId
  1172. signupType := req.SignupType
  1173. item := new(models.CygxActivitySignup)
  1174. activityInfo, errInfo := models.GetAddActivityInfoById(activityId)
  1175. if activityInfo == nil {
  1176. br.Msg = "操作失败"
  1177. br.ErrMsg = "活动ID错误,不存在activityId:" + strconv.Itoa(activityId)
  1178. return
  1179. }
  1180. if errInfo != nil {
  1181. br.Msg = "操作失败"
  1182. br.ErrMsg = "操作失败,Err:" + errInfo.Error()
  1183. return
  1184. }
  1185. //checkTime, _ := services.CheckSiginupDeadline(activityInfo)
  1186. //if !checkTime {
  1187. // br.Msg = "报名名单已提交举办方,若想取消,请联系对口销售"
  1188. // br.ErrMsg = "报名名单已提交举办方,若想取消,请联系对口销售"
  1189. // return
  1190. //}
  1191. cancelDeadlineMsg := services.CheckCancelDeadline(activityInfo)
  1192. if cancelDeadlineMsg != "" {
  1193. br.Msg = cancelDeadlineMsg
  1194. br.ErrMsg = cancelDeadlineMsg
  1195. return
  1196. }
  1197. resultTime := utils.StrTimeToTime(activityInfo.ActivityTime) //时间字符串格式转时间格式
  1198. if time.Now().After(resultTime.Add(-time.Minute * 60)) {
  1199. if signupType == 1 {
  1200. br.Msg = "活动开始前1小时内无法取消预约外呼,请联系对口销售处理"
  1201. } else {
  1202. br.Msg = "活动开始前1小时内无法取消报名,请联系对口销售处理"
  1203. }
  1204. br.ErrMsg = br.Msg
  1205. return
  1206. }
  1207. total, err := models.GetActivitySignupCount(uid, activityId)
  1208. if err != nil {
  1209. br.Msg = "获取失败"
  1210. br.ErrMsg = "获取失败,Err:" + err.Error()
  1211. return
  1212. }
  1213. if total == 0 {
  1214. br.Msg = "您暂未报名这个活动"
  1215. return
  1216. }
  1217. item.UserId = uid
  1218. item.ActivityId = activityId
  1219. item.CreateTime = time.Now()
  1220. item.Mobile = user.Mobile
  1221. item.Email = user.Email
  1222. item.CompanyId = user.CompanyId
  1223. item.CompanyName = user.CompanyName
  1224. _, errSignup := models.CancelActivitySignup(item)
  1225. if errSignup != nil {
  1226. br.Msg = "操作失败"
  1227. br.ErrMsg = "操作失败,Err:" + errSignup.Error()
  1228. return
  1229. }
  1230. go services.YanXuanActivityPointsBillSignupCancel(activityId, uid) // 用户取消报名添加到处理研选扣点
  1231. // 如果是买方研选下的专家沙龙,同时推给内容组四人
  1232. if activityInfo.ActivityTypeId == 5 {
  1233. go services.SendActivitieCancelSignTemplateMsg(user, activityInfo)
  1234. }
  1235. br.Ret = 200
  1236. br.Success = true
  1237. br.Msg = "操作成功"
  1238. }
  1239. // @Title 添加会议提醒
  1240. // @Description 添加会议提醒接口
  1241. // @Param request body models.ActivityIdRep true "type json string"
  1242. // @Success Ret=200 {object} models.SignupStatus
  1243. // @router /meetingReminder/add [post]
  1244. func (this *ActivityController) MeetingReminderAdd() {
  1245. br := new(models.BaseResponse).Init()
  1246. defer func() {
  1247. this.Data["json"] = br
  1248. this.ServeJSON()
  1249. }()
  1250. user := this.User
  1251. if user == nil {
  1252. br.Msg = "请登录"
  1253. br.ErrMsg = "请登录,用户信息为空"
  1254. br.Ret = 408
  1255. return
  1256. }
  1257. uid := user.UserId
  1258. signupStatus := ""
  1259. var req models.ActivitySingnupRep
  1260. resp := new(models.SignupStatus)
  1261. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  1262. if err != nil {
  1263. br.Msg = "参数解析异常!"
  1264. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  1265. return
  1266. }
  1267. activityId := req.ActivityId
  1268. signupType := req.SignupType
  1269. hasPermission := 0
  1270. if signupType == 1 && user.Mobile == "" && user.OutboundMobile == "" {
  1271. resp.GoBindEmail = true
  1272. }
  1273. activityInfo, errInfo := models.GetAddActivityInfoById(activityId)
  1274. if activityInfo == nil {
  1275. br.Msg = "操作失败"
  1276. br.ErrMsg = "活动ID错误,不存在activityId:" + strconv.Itoa(activityId)
  1277. return
  1278. }
  1279. if errInfo != nil {
  1280. br.Msg = "操作失败"
  1281. br.ErrMsg = "操作失败,Err:" + errInfo.Error()
  1282. return
  1283. }
  1284. havePower, isResearchSpecial, err := services.GetActivityDetailUserPower(user, activityInfo)
  1285. if err != nil {
  1286. br.Msg = "获取信息失败"
  1287. br.ErrMsg = "校验用户权限失败,Err:" + err.Error()
  1288. return
  1289. }
  1290. resp.IsResearchSpecial = isResearchSpecial
  1291. if havePower {
  1292. item := new(models.CygxActivityMeetingReminder)
  1293. item.RegisterPlatform = utils.REGISTER_PLATFORM
  1294. resp.HasPermission = 1
  1295. hasPermission = 1
  1296. signupStatus = "Success"
  1297. resultTime := utils.StrTimeToTime(activityInfo.ActivityTime) //时间字符串格式转时间格式
  1298. if time.Now().After(resultTime.Add(-time.Minute * 15)) {
  1299. signupStatus = "Overtime"
  1300. resp.SignupType = signupType
  1301. resp.SignupStatus = signupStatus
  1302. resp.HasPermission = hasPermission
  1303. resp.PopupMsg = "活动开始前15分钟无法设置会议提醒"
  1304. br.Ret = 200
  1305. br.Success = true
  1306. br.Msg = ""
  1307. br.Data = resp
  1308. return
  1309. }
  1310. hasPermission = 1
  1311. signupStatus = "Success"
  1312. totalMeeting, errMeeting := models.GetActivityMeetingReminderCount(uid, activityId)
  1313. if errMeeting != nil {
  1314. br.Msg = "获取失败"
  1315. br.ErrMsg = "获取失败,Err:" + errMeeting.Error()
  1316. return
  1317. }
  1318. if totalMeeting > 0 {
  1319. br.Msg = "您已预约,请勿重复预约"
  1320. return
  1321. }
  1322. item.UserId = uid
  1323. item.ActivityId = activityId
  1324. item.CreateTime = time.Now()
  1325. item.Mobile = user.Mobile
  1326. item.Email = user.Email
  1327. item.CompanyId = user.CompanyId
  1328. item.CompanyName = user.CompanyName
  1329. _, errSignup := models.AddActivityMeetingReminder(item)
  1330. if errSignup != nil {
  1331. br.Msg = "操作失败"
  1332. br.ErrMsg = "操作失败,Err:" + errSignup.Error()
  1333. return
  1334. }
  1335. br.Msg = "设置成功,会前15分钟会为您推送微信消息提醒"
  1336. resp.PopupMsg = "设置成功,会前15分钟会为您推送微信消息提醒<br/><br/>请关注【查研观向小助手】公众号,以获取微信消息提醒"
  1337. } else {
  1338. hasPermission, sellerName, sellerMobile, popupMsg, err := services.GetUserHasPermission(user)
  1339. if err != nil {
  1340. br.Msg = "获取信息失败"
  1341. br.ErrMsg = "判断是否已申请过试用失败,Err:" + err.Error()
  1342. return
  1343. }
  1344. popupMsg = "暂无查看权限"
  1345. resp.PopupMsg = popupMsg
  1346. resp.HasPermission = hasPermission
  1347. resp.SellerName = sellerName
  1348. resp.SellerMobile = sellerMobile
  1349. }
  1350. // 判断是否属于研选类型的活动
  1351. if strings.Contains(activityInfo.ChartPermissionName, utils.CHART_PERMISSION_NAME_YANXUAN) {
  1352. resp.IsResearch = true
  1353. }
  1354. br.Ret = 200
  1355. br.Success = true
  1356. br.Msg = "操作成功"
  1357. br.Data = resp
  1358. }
  1359. // @Title 取消会议提醒
  1360. // @Description 取消会议提醒接口
  1361. // @Param request body models.ActivityIdRep true "type json string"
  1362. // @Success Ret=200 {object} models.SignupStatus
  1363. // @router /meetingReminder/cancel [post]
  1364. func (this *ActivityController) MeetingReminderCancel() {
  1365. br := new(models.BaseResponse).Init()
  1366. defer func() {
  1367. this.Data["json"] = br
  1368. this.ServeJSON()
  1369. }()
  1370. user := this.User
  1371. if user == nil {
  1372. br.Msg = "请登录"
  1373. br.ErrMsg = "请登录,用户信息为空"
  1374. br.Ret = 408
  1375. return
  1376. }
  1377. uid := user.UserId
  1378. var req models.ActivityIdRep
  1379. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  1380. if err != nil {
  1381. br.Msg = "参数解析异常!"
  1382. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  1383. return
  1384. }
  1385. activityId := req.ActivityId
  1386. signupStatus := "Success"
  1387. item := new(models.CygxActivityMeetingReminder)
  1388. activityInfo, errInfo := models.GetAddActivityInfoById(activityId)
  1389. if activityInfo == nil {
  1390. br.Msg = "操作失败"
  1391. br.ErrMsg = "活动ID错误,不存在activityId:" + strconv.Itoa(activityId)
  1392. return
  1393. }
  1394. if errInfo != nil {
  1395. br.Msg = "操作失败"
  1396. br.ErrMsg = "操作失败,Err:" + errInfo.Error()
  1397. return
  1398. }
  1399. total, err := models.GetActivityMeetingReminderCount(uid, activityId)
  1400. if err != nil {
  1401. br.Msg = "获取失败"
  1402. br.ErrMsg = "获取失败,Err:" + err.Error()
  1403. return
  1404. }
  1405. if total == 0 {
  1406. br.Msg = "您暂未添加该活动会议提醒"
  1407. return
  1408. }
  1409. item.UserId = uid
  1410. item.ActivityId = activityId
  1411. item.CreateTime = time.Now()
  1412. item.Mobile = user.Mobile
  1413. item.Email = user.Email
  1414. item.CompanyId = user.CompanyId
  1415. item.CompanyName = user.CompanyName
  1416. _, errSignup := models.CancelActivityMeetingReminder(item)
  1417. if errSignup != nil {
  1418. br.Msg = "操作失败"
  1419. br.ErrMsg = "操作失败,Err:" + errSignup.Error()
  1420. return
  1421. }
  1422. resp := new(models.SignupStatus)
  1423. resp.SignupStatus = signupStatus
  1424. resp.HasPermission = 1
  1425. resp.ActivityId = activityId
  1426. br.Ret = 200
  1427. br.Success = true
  1428. br.Msg = "会议提醒已取消"
  1429. br.Data = resp
  1430. }
  1431. // @Title 预约纪要
  1432. // @Description 预约纪要接口
  1433. // @Param request body models.ActivityIdRep true "type json string"
  1434. // @Success Ret=200 {object} models.AppointmentResp
  1435. // @router /appointment/add [post]
  1436. func (this *ActivityController) ActivityAppointmentAdd() {
  1437. br := new(models.BaseResponse).Init()
  1438. defer func() {
  1439. this.Data["json"] = br
  1440. this.ServeJSON()
  1441. }()
  1442. user := this.User
  1443. if user == nil {
  1444. br.Msg = "请登录"
  1445. br.ErrMsg = "请登录,用户信息为空"
  1446. br.Ret = 408
  1447. return
  1448. }
  1449. uid := user.UserId
  1450. var req models.ActivitySingnupRep
  1451. resp := new(models.SignupStatus)
  1452. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  1453. if err != nil {
  1454. br.Msg = "参数解析异常!"
  1455. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  1456. return
  1457. }
  1458. activityId := req.ActivityId
  1459. signupType := req.SignupType
  1460. if signupType == 1 && user.Mobile == "" && user.OutboundMobile == "" {
  1461. resp.GoBindEmail = true
  1462. }
  1463. activityInfo, errInfo := models.GetAddActivityInfoById(activityId)
  1464. if activityInfo == nil {
  1465. br.Msg = "操作失败"
  1466. br.ErrMsg = "活动ID错误,不存在activityId:" + strconv.Itoa(activityId)
  1467. return
  1468. }
  1469. if errInfo != nil {
  1470. br.Msg = "操作失败"
  1471. br.ErrMsg = "操作失败,Err:" + errInfo.Error()
  1472. return
  1473. }
  1474. havePower, isResearchSpecial, err := services.GetActivityDetailUserPower(user, activityInfo)
  1475. if err != nil {
  1476. br.Msg = "获取信息失败"
  1477. br.ErrMsg = "校验用户权限失败,Err:" + err.Error()
  1478. return
  1479. }
  1480. resp.IsResearchSpecial = isResearchSpecial
  1481. if havePower {
  1482. item := new(models.CygxActivityAppointment)
  1483. item.RegisterPlatform = utils.REGISTER_PLATFORM
  1484. resp.HasPermission = 1
  1485. totalMeeting, errMeeting := models.GetUserCygxActivityAppointmentCount(uid, activityId)
  1486. if errMeeting != nil {
  1487. br.Msg = "获取失败"
  1488. br.ErrMsg = "获取失败,Err:" + errMeeting.Error()
  1489. return
  1490. }
  1491. if totalMeeting > 0 {
  1492. br.Msg = "您已预约,请勿重复预约"
  1493. return
  1494. }
  1495. var sellerName string
  1496. sellerName, err = models.GetCompanySellerName(user.CompanyId)
  1497. if err != nil {
  1498. br.Msg = "报名失败!"
  1499. br.ErrMsg = "获取对应销售失败,Err:" + err.Error()
  1500. return
  1501. }
  1502. item.UserId = uid
  1503. item.ActivityId = activityId
  1504. item.CreateTime = time.Now()
  1505. item.Mobile = user.Mobile
  1506. item.Email = user.Email
  1507. item.CompanyId = user.CompanyId
  1508. item.CompanyName = user.CompanyName
  1509. item.SellerName = sellerName
  1510. item.RealName = user.RealName
  1511. err = models.AddCygxActivityAppointment(item)
  1512. if err != nil {
  1513. br.Msg = "操作失败"
  1514. br.ErrMsg = "操作失败,Err:" + err.Error()
  1515. return
  1516. }
  1517. resp.SignupStatus = "Success"
  1518. //1:预约外呼 、2:设置会议提醒 、 3:预约纪要 、4:活动报名
  1519. //go services.ActivityUserRemind(user, activityInfo, 3)
  1520. } else {
  1521. hasPermission, sellerName, sellerMobile, popupMsg, err := services.GetUserHasPermission(user)
  1522. if err != nil {
  1523. br.Msg = "获取信息失败"
  1524. br.ErrMsg = "判断是否已申请过试用失败,Err:" + err.Error()
  1525. return
  1526. }
  1527. popupMsg = "暂无查看权限"
  1528. resp.PopupMsg = popupMsg
  1529. resp.HasPermission = hasPermission
  1530. resp.SellerName = sellerName
  1531. resp.SellerMobile = sellerMobile
  1532. }
  1533. // 判断是否属于研选类型的活动
  1534. if strings.Contains(activityInfo.ChartPermissionName, utils.CHART_PERMISSION_NAME_YANXUAN) {
  1535. resp.IsResearch = true
  1536. }
  1537. br.Ret = 200
  1538. br.Success = true
  1539. br.Msg = "操作成功"
  1540. br.Data = resp
  1541. }
  1542. // @Title 取消预约纪要
  1543. // @Description 取消预约纪要接口
  1544. // @Param request body models.ActivityIdRep true "type json string"
  1545. // @Success Ret=200 {object} models.SignupStatus
  1546. // @router /appointment/cancel [post]
  1547. func (this *ActivityController) ActivityAppointmentCancel() {
  1548. br := new(models.BaseResponse).Init()
  1549. defer func() {
  1550. this.Data["json"] = br
  1551. this.ServeJSON()
  1552. }()
  1553. user := this.User
  1554. if user == nil {
  1555. br.Msg = "请登录"
  1556. br.ErrMsg = "请登录,用户信息为空"
  1557. br.Ret = 408
  1558. return
  1559. }
  1560. uid := user.UserId
  1561. var req models.ActivityIdRep
  1562. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  1563. if err != nil {
  1564. br.Msg = "参数解析异常!"
  1565. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  1566. return
  1567. }
  1568. activityId := req.ActivityId
  1569. signupStatus := "Success"
  1570. item := new(models.CygxActivityAppointment)
  1571. activityInfo, errInfo := models.GetAddActivityInfoById(activityId)
  1572. if activityInfo == nil {
  1573. br.Msg = "操作失败"
  1574. br.ErrMsg = "活动ID错误,不存在activityId:" + strconv.Itoa(activityId)
  1575. return
  1576. }
  1577. if errInfo != nil {
  1578. br.Msg = "操作失败"
  1579. br.ErrMsg = "操作失败,Err:" + errInfo.Error()
  1580. return
  1581. }
  1582. total, err := models.GetUserCygxActivityAppointmentCount(uid, activityId)
  1583. if err != nil {
  1584. br.Msg = "获取失败"
  1585. br.ErrMsg = "获取失败,Err:" + err.Error()
  1586. return
  1587. }
  1588. if total == 0 {
  1589. br.Msg = "您暂未预约该纪要"
  1590. return
  1591. }
  1592. item.UserId = uid
  1593. item.ActivityId = activityId
  1594. item.CreateTime = time.Now()
  1595. item.Mobile = user.Mobile
  1596. item.Email = user.Email
  1597. item.CompanyId = user.CompanyId
  1598. item.CompanyName = user.CompanyName
  1599. _, errSignup := models.CancelcygxActivityAppointment(item)
  1600. if errSignup != nil {
  1601. br.Msg = "操作失败"
  1602. br.ErrMsg = "操作失败,Err:" + errSignup.Error()
  1603. return
  1604. }
  1605. resp := new(models.SignupStatus)
  1606. resp.SignupStatus = signupStatus
  1607. resp.ActivityId = activityId
  1608. resp.HasPermission = 1
  1609. br.Ret = 200
  1610. br.Success = true
  1611. br.Msg = "已取消"
  1612. br.Data = resp
  1613. }
  1614. // @Title 活动带问
  1615. // @Description 新增活动带问接口
  1616. // @Param request body models.AddCygxActivityHelpAsk true "type json string"
  1617. // @Success Ret=200 新增成功
  1618. // @router /askAdd [post]
  1619. func (this *ActivityController) AskAdd() {
  1620. br := new(models.BaseResponse).Init()
  1621. defer func() {
  1622. this.Data["json"] = br
  1623. this.ServeJSON()
  1624. }()
  1625. user := this.User
  1626. if user == nil {
  1627. br.Msg = "请登录"
  1628. br.ErrMsg = "请登录,SysUser Is Empty"
  1629. br.Ret = 408
  1630. return
  1631. }
  1632. var req models.CygxActivityHelpAsk
  1633. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  1634. if err != nil {
  1635. br.Msg = "参数解析异常!"
  1636. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  1637. return
  1638. }
  1639. if req.Content == "" {
  1640. br.Msg = "建议内容不可为空"
  1641. return
  1642. }
  1643. content := req.Content
  1644. activityId := req.ActivityId
  1645. activityInfo, errInfo := models.GetAddActivityInfoById(activityId)
  1646. if activityInfo == nil {
  1647. br.Msg = "操作失败"
  1648. br.ErrMsg = "活动ID错误,不存在activityId:" + strconv.Itoa(activityId)
  1649. return
  1650. }
  1651. if errInfo != nil {
  1652. br.Msg = "操作失败"
  1653. br.ErrMsg = "操作失败,Err:" + errInfo.Error()
  1654. return
  1655. }
  1656. resp := new(models.SignupStatus)
  1657. havePower, isResearchSpecial, err := services.GetActivityDetailUserPower(user, activityInfo)
  1658. if err != nil {
  1659. br.Msg = "获取信息失败"
  1660. br.ErrMsg = "校验用户权限失败,Err:" + err.Error()
  1661. return
  1662. }
  1663. resp.IsResearchSpecial = isResearchSpecial
  1664. if havePower {
  1665. companyDetail, err := models.GetCompanyDetailById(user.CompanyId)
  1666. if err != nil {
  1667. br.Msg = "提交失败!"
  1668. br.ErrMsg = "获取客户详情失败,Err:" + err.Error()
  1669. return
  1670. }
  1671. if companyDetail == nil {
  1672. br.Msg = "提交失败!"
  1673. br.ErrMsg = "客户不存在,uid:" + strconv.Itoa(user.UserId)
  1674. return
  1675. }
  1676. resp.SignupStatus = "Success"
  1677. resp.HasPermission = 1
  1678. item := new(models.CygxActivityHelpAsk)
  1679. item.RegisterPlatform = utils.REGISTER_PLATFORM
  1680. item.UserId = user.UserId
  1681. item.ActivityId = req.ActivityId
  1682. item.CompanyId = user.CompanyId
  1683. item.CompanyName = companyDetail.CompanyName
  1684. item.CreateTime = time.Now()
  1685. item.Mobile = user.Mobile
  1686. item.Email = user.Email
  1687. item.Content = content
  1688. msgId, err := models.AddActivityHelpAsk(item)
  1689. if err != nil {
  1690. br.Msg = "提交失败"
  1691. br.ErrMsg = "提交带问失败,Err:" + err.Error()
  1692. return
  1693. }
  1694. var isSendMsg bool
  1695. resultTime := utils.StrTimeToTime(activityInfo.ActivityTime) //时间字符串格式转时间格式
  1696. if activityInfo.ActivityTypeId == 1 && activityInfo.ChartPermissionId != 31 {
  1697. if time.Now().After(resultTime.Add(-time.Minute * 15)) {
  1698. isSendMsg = true
  1699. }
  1700. } else {
  1701. if time.Now().After(resultTime.Add(-time.Minute * 60)) {
  1702. isSendMsg = true
  1703. }
  1704. }
  1705. if isSendMsg {
  1706. listEmail, err := models.GetAskEmail()
  1707. if err != nil {
  1708. br.Msg = "提交失败"
  1709. br.ErrMsg = "提交带问失败,Err:" + err.Error()
  1710. return
  1711. }
  1712. var sendMobile string
  1713. for _, v := range listEmail {
  1714. if strings.Index(activityInfo.Host, v.Name) > 0 {
  1715. sendMobile = v.Mobile
  1716. }
  1717. }
  1718. if activityInfo.ChartPermissionId == 31 {
  1719. sendMobile = utils.ActSendMsgMobile
  1720. }
  1721. //获取销售信息
  1722. sellerItem, err := models.GetSellerByCompanyIdCheckFicc(user.CompanyId, 2)
  1723. if err != nil && err.Error() != utils.ErrNoRow() {
  1724. br.Msg = "提交失败"
  1725. br.ErrMsg = "获取销售信息失败,Err:" + err.Error()
  1726. return
  1727. }
  1728. //给研究员发送消息
  1729. if sendMobile != "" {
  1730. openIpItem, _ := models.GetUserRecordByMobile(4, sendMobile)
  1731. if openIpItem != nil && openIpItem.OpenId != "" {
  1732. if sellerItem != nil {
  1733. //services.SendActivityAskApplyTemplateMsgV2(user.RealName+"——"+user.CompanyName, "所属销售:"+sellerItem.RealName, time.Now().Format(utils.FormatDateTime), req.Content, activityInfo.ActivityName, openIpItem, activityInfo)
  1734. services.SendActivityAskApplyTemplateMsgV2(user.RealName+"——"+user.CompanyName+"("+sellerItem.RealName+")", "留言:"+activityInfo.ActivityName, time.Now().Format(utils.FormatDateTime), req.Content, activityInfo.ActivityName, openIpItem, activityInfo, int(msgId))
  1735. }
  1736. }
  1737. }
  1738. // 给所属销售发送消息
  1739. if sellerItem != nil {
  1740. openIpItem, _ := models.GetUserRecordByMobile(4, sellerItem.Mobile)
  1741. if openIpItem != nil && openIpItem.OpenId != "" {
  1742. //services.SendActivityAskApplyTemplateMsgV2(user.RealName+"——"+user.CompanyName, "所属销售:"+sellerItem.RealName, time.Now().Format(utils.FormatDateTime), req.Content, activityInfo.ActivityName, openIpItem, activityInfo)
  1743. services.SendActivityAskApplyTemplateMsgV2(user.RealName+"——"+user.CompanyName+"("+sellerItem.RealName+")", "留言:"+activityInfo.ActivityName, time.Now().Format(utils.FormatDateTime), req.Content, activityInfo.ActivityName, openIpItem, activityInfo, int(msgId))
  1744. }
  1745. }
  1746. }
  1747. } else {
  1748. hasPermission, sellerName, sellerMobile, popupMsg, err := services.GetUserHasPermission(user)
  1749. if err != nil {
  1750. br.Msg = "获取信息失败"
  1751. br.ErrMsg = "判断是否已申请过试用失败,Err:" + err.Error()
  1752. return
  1753. }
  1754. popupMsg = "暂无查看权限"
  1755. resp.PopupMsg = popupMsg
  1756. resp.HasPermission = hasPermission
  1757. resp.SellerName = sellerName
  1758. resp.SellerMobile = sellerMobile
  1759. }
  1760. // 判断是否属于研选类型的活动
  1761. if strings.Contains(activityInfo.ChartPermissionName, utils.CHART_PERMISSION_NAME_YANXUAN) {
  1762. resp.IsResearch = true
  1763. }
  1764. br.Ret = 200
  1765. br.Success = true
  1766. br.Data = resp
  1767. br.Msg = "提交成功"
  1768. }
  1769. // @Title 视频详情
  1770. // @Description 时间线接口
  1771. // @Param VideoId query int true "视频ID"
  1772. // @Success 200 {object} models.IndustryVideoDetailResp
  1773. // @router /detailVideo [get]
  1774. func (this *ActivityController) DetailVideo() {
  1775. br := new(models.BaseResponse).Init()
  1776. defer func() {
  1777. this.Data["json"] = br
  1778. this.ServeJSON()
  1779. }()
  1780. user := this.User
  1781. if user == nil {
  1782. br.Msg = "请重新登录"
  1783. br.Ret = 408
  1784. return
  1785. }
  1786. videoId, _ := this.GetInt("VideoId")
  1787. videoSimple, au, err := services.GetActivityVideoDetailById(user, videoId)
  1788. if err != nil {
  1789. br.Msg = "获取失败"
  1790. br.ErrMsg = "获取用户权限失败, Err: " + err.Error()
  1791. return
  1792. }
  1793. resp := new(models.ActivityVideoDetailResp)
  1794. resp.VideoDetail = videoSimple
  1795. resp.AuthInfo = au
  1796. br.Ret = 200
  1797. br.Success = true
  1798. br.Msg = "获取成功"
  1799. br.Data = resp
  1800. }
  1801. // @Title 活动、专项调研搜索
  1802. // @Description 活动、专项调研搜索接口
  1803. // @Param PageSize query int true "每页数据条数"
  1804. // @Param CurrentIndex query int true "当前页页码,从1开始"
  1805. // @Param KeyWord query string false "搜索关键词 多个用 , 隔开"
  1806. // @Param PlayBack query int false "是否仅展示回放 1:是、0:否 默认0"
  1807. // @Success 200 {object} models.GetCygxActivityListRep
  1808. // @router /listSearch [get]
  1809. func (this *ActivityController) ActivityListSearch() {
  1810. br := new(models.BaseResponse).Init()
  1811. defer func() {
  1812. this.Data["json"] = br
  1813. this.ServeJSON()
  1814. }()
  1815. user := this.User
  1816. if user == nil {
  1817. br.Msg = "请登录"
  1818. br.ErrMsg = "请登录,SysUser Is Empty"
  1819. return
  1820. }
  1821. pageSize, _ := this.GetInt("PageSize")
  1822. currentIndex, _ := this.GetInt("CurrentIndex")
  1823. source, _ := this.GetInt("Source")
  1824. keyWord := this.GetString("KeyWord")
  1825. playBack, _ := this.GetInt("PlayBack")
  1826. var startSize int
  1827. if pageSize <= 0 {
  1828. pageSize = utils.PageSize20
  1829. }
  1830. if currentIndex <= 0 {
  1831. currentIndex = 1
  1832. }
  1833. startSize = utils.StartIndex(currentIndex, pageSize)
  1834. var condition string
  1835. //活动可见限制
  1836. conditionActivity, err := services.GetActivityonditionList(user, "", "", "", "3", "", 0, 1, keyWord, playBack, 1)
  1837. if err != nil && err.Error() != utils.ErrNoRow() {
  1838. br.Msg = "获取失败"
  1839. br.ErrMsg = "获取活动权限数据失败,Err:" + err.Error()
  1840. return
  1841. }
  1842. if source == 1 {
  1843. condition += ` AND art.yidong_activity_id = '' `
  1844. }
  1845. condition += ` AND art.is_limit_people = 1 AND art.publish_status = 1 ` + conditionActivity
  1846. listActivity, total, err := services.GetActivitySpecialSearcheList(user, condition, startSize, pageSize, playBack, keyWord)
  1847. if err != nil {
  1848. br.Msg = "获取失败"
  1849. br.ErrMsg = "获取失败,Err:" + err.Error()
  1850. return
  1851. }
  1852. //return
  1853. //用户权限
  1854. authInfo, permissionArr, e := services.GetUserRaiPermissionInfo(user.UserId, user.CompanyId)
  1855. if e != nil {
  1856. br.Msg = "获取失败"
  1857. br.ErrMsg = "获取用户权限失败, Err: " + e.Error()
  1858. return
  1859. }
  1860. page := paging.GetPaging(currentIndex, pageSize, total)
  1861. resp := new(models.HomeResourceDataListResp)
  1862. var list []*models.CygxResourceDataResp
  1863. for _, v := range listActivity {
  1864. var item = new(models.CygxResourceDataResp)
  1865. //resp.List = append(resp.List, &models.CygxResourceDataResp{
  1866. item.SourceId = v.ActivityId
  1867. if v.SourceType == 1 {
  1868. item.Source = "activity"
  1869. } else {
  1870. item.Source = "activityspecial"
  1871. }
  1872. item.Title = v.ActivityName
  1873. item.City = v.City
  1874. item.IsSignup = v.IsSignup
  1875. item.SignupType = v.SignupType
  1876. item.ActivityTypeId = v.ActivityTypeId
  1877. item.IsCancelMeetingReminder = v.IsCancelMeetingReminder
  1878. item.IsAppointment = v.IsAppointment
  1879. item.ActiveState = v.ActiveState
  1880. item.ImgUrlText = v.ImgUrlText
  1881. item.ImgUrl = v.ImgUrl
  1882. item.ActivityType = v.ActivityType
  1883. item.IsShowOutboundCall = v.IsShowOutboundCall
  1884. item.IsShowMeetingReminder = v.IsShowMeetingReminder
  1885. item.IsShowHelpSsk = v.IsShowHelpSsk
  1886. item.IsShowSignup = v.IsShowSignup
  1887. item.IsShowAppointment = v.IsShowAppointment
  1888. item.IsShowDetails = v.IsShowDetails
  1889. item.ActivityTimeText = v.ActivityTimeText
  1890. item.Expert = v.Expert
  1891. item.Speaker = v.Speaker
  1892. item.DistinguishedGuest = v.DistinguishedGuest
  1893. item.PublishDate = v.ActivityTime
  1894. item.TripImgLink = v.TripImgLink
  1895. item.TripStatus = 2
  1896. item.ActiveState = v.ActiveState
  1897. item.PublishDate = v.ActivityTime
  1898. item.FileType = v.FileType
  1899. item.IsYidongConduct = v.IsYidongConduct
  1900. item.IsCanOutboundCall = v.IsCanOutboundCall
  1901. item.IsLimitPeople = v.IsLimitPeople
  1902. item.IsResearchPoints = v.IsResearchPoints
  1903. item.SiginupDeadline = v.SiginupDeadline
  1904. // 判断是否属于研选类型的活动
  1905. if strings.Contains(v.ChartPermissionName, utils.CHART_PERMISSION_NAME_YANXUAN) {
  1906. item.IsResearch = true
  1907. if (v.ActivityTypeId == 3 || v.ActivityTypeId == 5) && v.YidongActivityId == "" && strings.Contains(v.ChartPermissionName, utils.CHART_PERMISSION_NAME_YANXUAN) && utils.InArrayByStr(permissionArr, utils.CHART_PERMISSION_NAME_MF_YANXUAN) {
  1908. item.IsResearchSpecial = true
  1909. }
  1910. }
  1911. if v.VoiceList != nil || v.VideoDetail != nil {
  1912. item.AudioLink = true
  1913. }
  1914. if v.FileType == 1 {
  1915. if v.VoiceList != nil {
  1916. item.VoiceDetail = v.VoiceList
  1917. }
  1918. } else {
  1919. if v.VideoDetail != nil {
  1920. item.VideoDetail = v.VideoDetail
  1921. }
  1922. }
  1923. au := new(models.UserPermissionAuthInfo)
  1924. au.SellerName = authInfo.SellerName
  1925. au.SellerMobile = authInfo.SellerMobile
  1926. au.HasPermission = authInfo.HasPermission
  1927. au.OperationMode = authInfo.OperationMode
  1928. if au.HasPermission == 1 {
  1929. // 非宏观权限进一步判断是否有权限
  1930. if v.ChartPermissionId != utils.HONG_GUAN_ID && !utils.InArrayByStr(permissionArr, v.ChartPermissionName) {
  1931. au.HasPermission = 2
  1932. }
  1933. //如果是易董的活动,主、副权限有一个满足即可 查研观向 11.0
  1934. if v.YidongActivityId != "" {
  1935. if utils.InArrayByStr(permissionArr, v.ChartPermissionName) || utils.InArrayByStr(permissionArr, v.ChartPermissionNameDeputy) {
  1936. au.HasPermission = 1
  1937. }
  1938. }
  1939. }
  1940. // 无权限的弹框提示
  1941. if au.HasPermission != 1 {
  1942. if au.OperationMode == services.UserPermissionOperationModeCall {
  1943. if v.FileType == 1 {
  1944. au.PopupMsg = services.UserPermissionPopupMsgCallActivity
  1945. } else {
  1946. au.PopupMsg = services.UserPermissionPopupMsgCallMicroVideo
  1947. }
  1948. } else {
  1949. if v.FileType == 1 {
  1950. au.PopupMsg = services.UserPermissionPopupMsgApplyActivity
  1951. } else {
  1952. au.PopupMsg = services.UserPermissionPopupMsgApplyMicroVideo
  1953. }
  1954. }
  1955. //}
  1956. item.AuthInfo = au
  1957. }
  1958. list = append(list, item)
  1959. }
  1960. if len(list) == 0 {
  1961. list = make([]*models.CygxResourceDataResp, 0)
  1962. }
  1963. //添加活动搜索记录
  1964. //if keyWord != "" {
  1965. //go services.AddActivitykeyWordSearch(keyWord, user)
  1966. //}
  1967. resp.Paging = page
  1968. resp.List = list
  1969. br.Ret = 200
  1970. br.Success = true
  1971. br.Msg = "获取成功"
  1972. br.Data = resp
  1973. }
  1974. // @Title 我的日程
  1975. // @Description 我的日程列表接口
  1976. // @Param PageSize query int true "每页数据条数"
  1977. // @Param CurrentIndex query int true "当前页页码,从1开始"
  1978. // @Success 200 {object} models.GetCygxActivityListRep
  1979. // @router /scheduleList [get]
  1980. func (this *ActivityController) ScheduleList() {
  1981. br := new(models.BaseResponse).Init()
  1982. defer func() {
  1983. this.Data["json"] = br
  1984. this.ServeJSON()
  1985. }()
  1986. user := this.User
  1987. if user == nil {
  1988. br.Msg = "请登录"
  1989. br.ErrMsg = "请登录,SysUser Is Empty"
  1990. return
  1991. }
  1992. uid := user.UserId
  1993. pageSize, _ := this.GetInt("PageSize")
  1994. currentIndex, _ := this.GetInt("CurrentIndex")
  1995. //source, _ := this.GetInt("Source")
  1996. var startSize int
  1997. if pageSize <= 0 {
  1998. pageSize = utils.PageSize20
  1999. }
  2000. if currentIndex <= 0 {
  2001. currentIndex = 1
  2002. }
  2003. startSize = utils.StartIndex(currentIndex, pageSize)
  2004. var condition string
  2005. var conditionCount string
  2006. var pars []interface{}
  2007. condition += ` AND art.publish_status = 1 `
  2008. //if source == 1 {
  2009. // condition += ` AND art.yidong_activity_id = '' `
  2010. // conditionCount += ` AND art.yidong_activity_id = '' `
  2011. //}
  2012. total, err := models.GetScheduleCount(conditionCount, uid)
  2013. specialtotal, err := models.GetSpecialScheduleCount(uid)
  2014. page := paging.GetPaging(currentIndex, pageSize, total+specialtotal)
  2015. if err != nil {
  2016. br.Msg = "获取失败"
  2017. br.ErrMsg = "获取失败,Err:" + err.Error()
  2018. return
  2019. }
  2020. conditionCount = ` AND art.active_state = 2 `
  2021. totalCount, err := models.GetScheduleCount(conditionCount, uid) //获取正在进行中的活动数量
  2022. if err != nil {
  2023. br.Msg = "获取失败"
  2024. br.ErrMsg = "获取失败,Err:" + err.Error()
  2025. return
  2026. }
  2027. var list []*models.ActivityDetail
  2028. //全部都是进行中的活动
  2029. if totalCount > currentIndex*pageSize {
  2030. condition += ` AND art.active_state IN(2) `
  2031. //if source == 1 {
  2032. // condition += ` AND art.yidong_activity_id = '' `
  2033. //}
  2034. listHave, errList := models.GetScheduleList(condition, pars, uid, startSize, pageSize)
  2035. list = listHave
  2036. if errList != nil {
  2037. br.Msg = "获取失败"
  2038. br.ErrMsg = "获取失败,Err:" + errList.Error()
  2039. return
  2040. }
  2041. } else if totalCount > currentIndex-1*pageSize && totalCount < currentIndex*pageSize { //部分是进行中的活动
  2042. condition = ` AND art.publish_status = 1 AND art.active_state IN(2) `
  2043. //if source == 1 {
  2044. // condition += ` AND art.yidong_activity_id = '' `
  2045. //}
  2046. listHave, errList := models.GetScheduleList(condition, pars, uid, startSize, pageSize)
  2047. list = listHave
  2048. if errList != nil {
  2049. br.Msg = "获取失败"
  2050. br.ErrMsg = "获取失败,Err:" + errList.Error()
  2051. return
  2052. }
  2053. pageSize = pageSize - len(listHave)
  2054. condition = ` AND art.publish_status = 1 AND art.active_state IN(1,3) `
  2055. //if source == 1 {
  2056. // condition += ` AND art.yidong_activity_id = '' `
  2057. //}
  2058. //listOther, errList := models.GetScheduleList(condition, pars, uid, startSize, pageSize)
  2059. listOther, errList := services.GetScheduleAndSpecilList(user, condition, startSize, pageSize)
  2060. if errList != nil {
  2061. br.Msg = "获取失败"
  2062. br.ErrMsg = "获取失败,Err:" + errList.Error()
  2063. return
  2064. }
  2065. if len(listOther) > 0 {
  2066. for _, v := range listOther {
  2067. list = append(list, v)
  2068. }
  2069. }
  2070. } else {
  2071. condition += ` AND art.active_state IN(1,3)` //全部都不是进行中的活动
  2072. //listOther, errList := models.GetScheduleList(condition, pars, uid, startSize, pageSize)
  2073. listOther, errList := services.GetScheduleAndSpecilList(user, condition, startSize, pageSize)
  2074. list = listOther
  2075. if errList != nil {
  2076. br.Msg = "获取失败"
  2077. br.ErrMsg = "获取失败,Err:" + errList.Error()
  2078. return
  2079. }
  2080. }
  2081. var isShow bool
  2082. isShow = services.GetShowSustainable()
  2083. detail, err := models.GetConfigByCode("city_img_url")
  2084. if err != nil {
  2085. br.Msg = "获取数据失败"
  2086. br.ErrMsg = "城市配置信息失败,Err:" + err.Error()
  2087. return
  2088. }
  2089. detailChart, err := models.GetConfigByCode("chart_img_url")
  2090. if err != nil {
  2091. br.Msg = "获取数据失败"
  2092. br.ErrMsg = "行业配置信息失败,Err:" + err.Error()
  2093. return
  2094. }
  2095. addressList := strings.Split(detail.ConfigValue, "{|}")
  2096. mapAddress := make(map[string]string)
  2097. chartList := strings.Split(detailChart.ConfigValue, "{|}")
  2098. mapChart := make(map[string]string)
  2099. var cityName string
  2100. var chartName string
  2101. var imgUrl string
  2102. var imgUrlChart string
  2103. var mapActivityId []int
  2104. for _, v := range addressList {
  2105. vslice := strings.Split(v, "_")
  2106. cityName = vslice[0]
  2107. imgUrl = vslice[len(vslice)-1]
  2108. mapAddress[cityName] = imgUrl
  2109. }
  2110. for _, v := range chartList {
  2111. vslice := strings.Split(v, "_")
  2112. chartName = vslice[0]
  2113. imgUrlChart = vslice[len(vslice)-1]
  2114. mapChart[chartName] = imgUrlChart
  2115. }
  2116. for k, v := range list {
  2117. if strings.Contains(v.ActivityName, "【") {
  2118. list[k].IsBrackets = 1
  2119. }
  2120. if v.SignupNum > v.LimitPeopleNum {
  2121. list[k].SignupNum = v.LimitPeopleNum
  2122. }
  2123. //是否展示限免标签
  2124. if isShow && strings.Contains(v.ChartPermissionName, "研选") {
  2125. list[k].IsShowSustainable = true
  2126. }
  2127. if strings.Contains(v.ChartPermissionName, utils.CHART_PERMISSION_NAME_YANXUAN) {
  2128. list[k].IsResearch = true
  2129. }
  2130. if strings.Contains(v.ChartPermissionName, "研选") && v.ActivityTypeId == 1 {
  2131. //list[k].ActivityTypeName = "买方研选电话会"
  2132. //list[k].ImgUrlText = "https://hongze.oss-cn-shanghai.aliyuncs.com/static/images/202112/20211221/bIdfv8t86xrFRpDOeGGHXOmKEuKl.png"
  2133. list[k].ImgUrlText = utils.YAN_XUAN_IMG
  2134. }
  2135. if v.ActivityType == 0 && v.SourceType == 1 {
  2136. if mapAddress[v.City] != "" {
  2137. list[k].ImgUrl = mapAddress[v.City]
  2138. } else {
  2139. list[k].ImgUrl = mapAddress["其它"]
  2140. }
  2141. } else {
  2142. if mapChart[v.ChartPermissionName] != "" {
  2143. list[k].ImgUrl = mapChart[v.ChartPermissionName]
  2144. }
  2145. }
  2146. expertTxt, _ := services.GetReportContentTextSub(v.Expert)
  2147. list[k].Expert = expertTxt
  2148. if v.IsHideAppointment == 0 {
  2149. list[k].IsShowAppointment = services.IsShowAppointment(v.ActivityTypeId, v.ChartPermissionName)
  2150. }
  2151. if v.ActivityTypeId == utils.C_CLASS_ACTIVITY_TYPE_ID {
  2152. list[k].IsCClassMeeting = true
  2153. }
  2154. mapActivityId = append(mapActivityId, v.ActivityId)
  2155. }
  2156. //添加我的日程访问记录
  2157. item := new(models.CygxPageHistoryRecord)
  2158. item.UserId = user.UserId
  2159. item.CreateTime = time.Now()
  2160. item.Mobile = user.Mobile
  2161. item.Email = user.Email
  2162. item.CompanyId = user.CompanyId
  2163. item.CompanyName = user.CompanyName
  2164. item.PageType = "MySchedule"
  2165. go models.AddCygxPageHistoryRecord(item)
  2166. resp := new(models.GetCygxActivityListRep)
  2167. //处理音频回放
  2168. mapActivityVoice, err := services.GetActivityVoiceResp(mapActivityId)
  2169. if err != nil {
  2170. br.Msg = "获取信息失败"
  2171. br.ErrMsg = "GetActivityVoiceResp,Err:" + err.Error()
  2172. return
  2173. }
  2174. //处理视频回放
  2175. mapActivityVideo, err := services.GetActivityVideoResp(mapActivityId)
  2176. if err != nil {
  2177. br.Msg = "获取信息失败"
  2178. br.ErrMsg = "GetActivityVideoResp,Err:" + err.Error()
  2179. return
  2180. }
  2181. //处理不同的报名方式按钮回显
  2182. mapActivitySignup, err := services.GetActivitySignupResp(mapActivityId, user)
  2183. if err != nil {
  2184. br.Msg = "获取信息失败"
  2185. br.ErrMsg = "GetActivitySignupResp,Err:" + err.Error()
  2186. return
  2187. }
  2188. for k, v := range list {
  2189. if mapActivityVoice[v.ActivityId] != nil {
  2190. list[k].FileType = 1
  2191. list[k].AudioLink = true
  2192. list[k].VoiceList = mapActivityVoice[v.ActivityId]
  2193. }
  2194. if mapActivityVideo[v.ActivityId] != nil {
  2195. list[k].FileType = 2
  2196. list[k].AudioLink = true
  2197. list[k].VideoDetail = mapActivityVideo[v.ActivityId]
  2198. }
  2199. v.SignupType = mapActivitySignup[v.ActivityId]
  2200. //处理列表的标签是否展示逻辑
  2201. resp.List = append(resp.List, services.ActivityButtonShow(v, user, make([]string, 0)))
  2202. }
  2203. resp.Paging = page
  2204. br.Ret = 200
  2205. br.Success = true
  2206. br.Msg = "获取成功"
  2207. br.Data = resp
  2208. }
  2209. // @Title 活动报名之前的校验(权限、时间、点数、邮箱)
  2210. // @Description 活动报名之前的校验(权限、时间、点数、邮箱)接口
  2211. // @Param request body models.ActivityIdRep true "type json string"
  2212. // @Success Ret=200 {object} models.SignupStatus
  2213. // @router /check [post]
  2214. func (this *ActivityController) Check() {
  2215. br := new(models.BaseResponse).Init()
  2216. defer func() {
  2217. this.Data["json"] = br
  2218. this.ServeJSON()
  2219. }()
  2220. user := this.User
  2221. if user == nil {
  2222. br.Msg = "请登录"
  2223. br.ErrMsg = "请登录,用户信息为空"
  2224. br.Ret = 408
  2225. return
  2226. }
  2227. var req models.ActivityIdRep
  2228. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  2229. if err != nil {
  2230. br.Msg = "参数解析异常!"
  2231. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  2232. return
  2233. }
  2234. activityId := req.ActivityId
  2235. activityInfo, errInfo := models.GetAddActivityInfoById(activityId)
  2236. if activityInfo == nil {
  2237. br.Msg = "操作失败"
  2238. br.ErrMsg = "活动ID错误,不存在activityId:" + strconv.Itoa(activityId)
  2239. return
  2240. }
  2241. if errInfo != nil {
  2242. br.Msg = "操作失败"
  2243. br.ErrMsg = "操作失败,Err:" + errInfo.Error()
  2244. return
  2245. }
  2246. //这里的文案顺序提示 权限>时间>研选扣点>邮箱绑定。
  2247. resp := new(models.ActivityCheck)
  2248. resp.CancelPopupMsg, err = services.ActivityCancelDeadlineMsg(activityInfo) //处理取消报名截止时间的弹窗文案
  2249. if err != nil {
  2250. br.Msg = "操作失败"
  2251. br.ErrMsg = "操作失败,Err:" + err.Error()
  2252. return
  2253. }
  2254. hasPermission := 0
  2255. havePower, isResearchSpecial, err := services.GetActivityDetailUserPower(user, activityInfo)
  2256. if err != nil {
  2257. br.Msg = "获取信息失败"
  2258. br.ErrMsg = "校验用户权限失败,Err:" + err.Error()
  2259. return
  2260. }
  2261. resp.IsResearchSpecial = isResearchSpecial
  2262. if havePower {
  2263. hasPermission = 1
  2264. resp.CheckPermission = true
  2265. resp.HasPermission = hasPermission
  2266. } else {
  2267. hasPermission, sellerName, sellerMobile, popupMsg, err := services.GetUserHasPermission(user)
  2268. if err != nil {
  2269. br.Msg = "获取信息失败"
  2270. br.ErrMsg = "判断是否已申请过试用失败,Err:" + err.Error()
  2271. return
  2272. }
  2273. resp.PopupMsg = popupMsg
  2274. resp.HasPermission = hasPermission
  2275. resp.SellerName = sellerName
  2276. resp.SellerMobile = sellerMobile
  2277. }
  2278. if resp.CheckPermission {
  2279. //如果权限通过了校验,那么就来校验时间
  2280. resp.CheckTime, resp.PopupMsg = services.CheckSiginupDeadline(activityInfo)
  2281. }
  2282. if resp.CheckTime {
  2283. // 如果时间通过校验就校验点数
  2284. resp.CheckPoints, resp.PopupMsg, resp.CompanyPoints, resp.ActivityPoints, err = services.CheckActivityPoints(activityInfo, user)
  2285. if err != nil {
  2286. br.Msg = "获取信息失败"
  2287. br.ErrMsg = "CheckActivityPoints,Err:" + err.Error()
  2288. return
  2289. }
  2290. }
  2291. if resp.CheckPoints {
  2292. //如果通过点数的校验,就来校验邮箱
  2293. resp.CheckEmail, resp.PopupMsg = services.CheckActivityUserEmail(activityInfo, user)
  2294. }
  2295. // 判断是否属于研选类型的活动
  2296. if strings.Contains(activityInfo.ChartPermissionName, utils.CHART_PERMISSION_NAME_YANXUAN) {
  2297. resp.IsResearch = true
  2298. }
  2299. br.Ret = 200
  2300. br.Success = true
  2301. br.Data = resp
  2302. }
  2303. // @Title 记录用户浏览音频回放接口
  2304. // @Description 记录用户浏览音频回放接口
  2305. // @Param request body models.ActivityIdRep true "type json string"
  2306. // @Success Ret=200 {object} models.AppointmentResp
  2307. // @router /voiceHistory/add [post]
  2308. func (this *ActivityController) ActivityVoiceHistoryAdd() {
  2309. br := new(models.BaseResponse).Init()
  2310. defer func() {
  2311. this.Data["json"] = br
  2312. this.ServeJSON()
  2313. }()
  2314. user := this.User
  2315. if user == nil {
  2316. br.Msg = "请登录"
  2317. br.ErrMsg = "请登录,用户信息为空"
  2318. br.Ret = 408
  2319. return
  2320. }
  2321. uid := user.UserId
  2322. var req models.ActivityIdRep
  2323. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  2324. if err != nil {
  2325. br.Msg = "参数解析异常!"
  2326. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  2327. return
  2328. }
  2329. activityId := req.ActivityId
  2330. playSeconds := req.PlaySeconds
  2331. activityInfo, errInfo := models.GetAddActivityInfoById(activityId)
  2332. if activityInfo == nil {
  2333. br.Msg = "操作失败"
  2334. br.ErrMsg = "活动ID错误,不存在activityId:" + strconv.Itoa(activityId)
  2335. return
  2336. }
  2337. if errInfo != nil {
  2338. br.Msg = "操作失败"
  2339. br.ErrMsg = "操作失败,Err:" + errInfo.Error()
  2340. return
  2341. }
  2342. var sellerName string
  2343. sellerName, err = models.GetCompanySellerName(user.CompanyId)
  2344. if err != nil {
  2345. br.Msg = "报名失败!"
  2346. br.ErrMsg = "获取对应销售失败,Err:" + err.Error()
  2347. return
  2348. }
  2349. item := models.CygxActivityVoiceHistory{
  2350. ActivityId: activityId,
  2351. UserId: uid,
  2352. CreateTime: time.Now(),
  2353. Mobile: user.Mobile,
  2354. Email: user.Email,
  2355. CompanyId: user.CompanyId,
  2356. CompanyName: user.CompanyName,
  2357. RealName: user.RealName,
  2358. SellerName: sellerName,
  2359. PlaySeconds: strconv.Itoa(req.PlaySeconds),
  2360. ModifyTime: time.Now(),
  2361. }
  2362. if playSeconds != 0 {
  2363. lastItem, err := models.GetLastCygxActivityVoiceHistory(activityId, user.UserId)
  2364. if err != nil {
  2365. br.Msg = "操作失败"
  2366. br.ErrMsg = "操作失败,GetLastCygxActivityVoiceHistory Err:" + err.Error()
  2367. return
  2368. }
  2369. err = models.UpdateLastCygxActivityVoiceHistory(strconv.Itoa(req.PlaySeconds), lastItem.Id)
  2370. if err != nil {
  2371. br.Msg = "更新失败"
  2372. br.ErrMsg = "更新失败,UpdateLastCygxActivityVoiceHistory Err:" + err.Error()
  2373. return
  2374. }
  2375. } else {
  2376. err = models.AddCygxActivityVoiceHistory(&item)
  2377. if err != nil {
  2378. br.Msg = "操作失败"
  2379. br.ErrMsg = "操作失败,Err:" + err.Error()
  2380. return
  2381. }
  2382. err = models.UpdateCygxActivityVoiceCounts(activityId)
  2383. if err != nil {
  2384. br.Msg = "更新失败"
  2385. br.ErrMsg = "更新失败,Err:" + err.Error()
  2386. return
  2387. }
  2388. go services.ActivityVideoUserRmind(user, activityId, 2)
  2389. }
  2390. br.Ret = 200
  2391. br.Success = true
  2392. br.Msg = "操作成功"
  2393. return
  2394. }