activity.go 92 KB

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