activity.go 131 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719172017211722172317241725172617271728172917301731173217331734173517361737173817391740174117421743174417451746174717481749175017511752175317541755175617571758175917601761176217631764176517661767176817691770177117721773177417751776177717781779178017811782178317841785178617871788178917901791179217931794179517961797179817991800180118021803180418051806180718081809181018111812181318141815181618171818181918201821182218231824182518261827182818291830183118321833183418351836183718381839184018411842184318441845184618471848184918501851185218531854185518561857185818591860186118621863186418651866186718681869187018711872187318741875187618771878187918801881188218831884188518861887188818891890189118921893189418951896189718981899190019011902190319041905190619071908190919101911191219131914191519161917191819191920192119221923192419251926192719281929193019311932193319341935193619371938193919401941194219431944194519461947194819491950195119521953195419551956195719581959196019611962196319641965196619671968196919701971197219731974197519761977197819791980198119821983198419851986198719881989199019911992199319941995199619971998199920002001200220032004200520062007200820092010201120122013201420152016201720182019202020212022202320242025202620272028202920302031203220332034203520362037203820392040204120422043204420452046204720482049205020512052205320542055205620572058205920602061206220632064206520662067206820692070207120722073207420752076207720782079208020812082208320842085208620872088208920902091209220932094209520962097209820992100210121022103210421052106210721082109211021112112211321142115211621172118211921202121212221232124212521262127212821292130213121322133213421352136213721382139214021412142214321442145214621472148214921502151215221532154215521562157215821592160216121622163216421652166216721682169217021712172217321742175217621772178217921802181218221832184218521862187218821892190219121922193219421952196219721982199220022012202220322042205220622072208220922102211221222132214221522162217221822192220222122222223222422252226222722282229223022312232223322342235223622372238223922402241224222432244224522462247224822492250225122522253225422552256225722582259226022612262226322642265226622672268226922702271227222732274227522762277227822792280228122822283228422852286228722882289229022912292229322942295229622972298229923002301230223032304230523062307230823092310231123122313231423152316231723182319232023212322232323242325232623272328232923302331233223332334233523362337233823392340234123422343234423452346234723482349235023512352235323542355235623572358235923602361236223632364236523662367236823692370237123722373237423752376237723782379238023812382238323842385238623872388238923902391239223932394239523962397239823992400240124022403240424052406240724082409241024112412241324142415241624172418241924202421242224232424242524262427242824292430243124322433243424352436243724382439244024412442244324442445244624472448244924502451245224532454245524562457245824592460246124622463246424652466246724682469247024712472247324742475247624772478247924802481248224832484248524862487248824892490249124922493249424952496249724982499250025012502250325042505250625072508250925102511251225132514251525162517251825192520252125222523252425252526252725282529253025312532253325342535253625372538253925402541254225432544254525462547254825492550255125522553255425552556255725582559256025612562256325642565256625672568256925702571257225732574257525762577257825792580258125822583258425852586258725882589259025912592259325942595259625972598259926002601260226032604260526062607260826092610261126122613261426152616261726182619262026212622262326242625262626272628262926302631263226332634263526362637263826392640264126422643264426452646264726482649265026512652265326542655265626572658265926602661266226632664266526662667266826692670267126722673267426752676267726782679268026812682268326842685268626872688268926902691269226932694269526962697269826992700270127022703270427052706270727082709271027112712271327142715271627172718271927202721272227232724272527262727272827292730273127322733273427352736273727382739274027412742274327442745274627472748274927502751275227532754275527562757275827592760276127622763276427652766276727682769277027712772277327742775277627772778277927802781278227832784278527862787278827892790279127922793279427952796279727982799280028012802280328042805280628072808280928102811281228132814281528162817281828192820282128222823282428252826282728282829283028312832283328342835283628372838283928402841284228432844284528462847284828492850285128522853285428552856285728582859286028612862286328642865286628672868286928702871287228732874287528762877287828792880288128822883288428852886288728882889289028912892289328942895289628972898289929002901290229032904290529062907290829092910291129122913291429152916291729182919292029212922292329242925292629272928292929302931293229332934293529362937293829392940294129422943294429452946294729482949295029512952295329542955295629572958295929602961296229632964296529662967296829692970297129722973297429752976297729782979298029812982298329842985298629872988298929902991299229932994299529962997299829993000300130023003300430053006300730083009301030113012301330143015301630173018301930203021302230233024302530263027302830293030303130323033303430353036303730383039304030413042304330443045304630473048304930503051305230533054305530563057305830593060306130623063306430653066306730683069307030713072307330743075307630773078307930803081308230833084308530863087308830893090309130923093309430953096309730983099310031013102310331043105310631073108310931103111311231133114311531163117311831193120312131223123312431253126312731283129313031313132313331343135313631373138313931403141314231433144314531463147314831493150315131523153315431553156315731583159316031613162316331643165316631673168316931703171317231733174317531763177317831793180318131823183318431853186318731883189319031913192319331943195319631973198319932003201320232033204320532063207320832093210321132123213321432153216321732183219322032213222322332243225322632273228322932303231323232333234323532363237323832393240324132423243324432453246324732483249325032513252325332543255325632573258325932603261326232633264326532663267326832693270327132723273327432753276327732783279328032813282328332843285328632873288328932903291329232933294329532963297329832993300330133023303330433053306330733083309331033113312331333143315331633173318331933203321332233233324332533263327332833293330333133323333333433353336333733383339334033413342334333443345334633473348334933503351335233533354335533563357335833593360336133623363336433653366336733683369337033713372337333743375337633773378337933803381338233833384338533863387338833893390339133923393339433953396339733983399340034013402340334043405340634073408340934103411341234133414341534163417341834193420342134223423342434253426342734283429343034313432343334343435343634373438343934403441344234433444344534463447344834493450345134523453345434553456345734583459346034613462346334643465346634673468346934703471347234733474347534763477347834793480348134823483348434853486348734883489349034913492349334943495349634973498349935003501350235033504350535063507350835093510351135123513351435153516351735183519352035213522352335243525352635273528352935303531353235333534353535363537353835393540354135423543354435453546354735483549355035513552355335543555355635573558355935603561356235633564356535663567356835693570357135723573357435753576357735783579358035813582358335843585358635873588358935903591359235933594359535963597359835993600360136023603360436053606360736083609361036113612361336143615361636173618361936203621362236233624362536263627362836293630363136323633363436353636363736383639364036413642364336443645364636473648364936503651365236533654365536563657365836593660366136623663366436653666366736683669367036713672367336743675367636773678367936803681368236833684368536863687368836893690369136923693369436953696369736983699370037013702370337043705370637073708370937103711371237133714371537163717371837193720372137223723372437253726372737283729373037313732373337343735373637373738373937403741374237433744374537463747374837493750375137523753375437553756375737583759376037613762376337643765376637673768376937703771377237733774377537763777377837793780378137823783378437853786378737883789379037913792379337943795379637973798379938003801380238033804380538063807380838093810381138123813381438153816381738183819382038213822382338243825382638273828382938303831383238333834383538363837383838393840384138423843384438453846384738483849385038513852385338543855385638573858385938603861386238633864386538663867386838693870387138723873387438753876387738783879388038813882388338843885388638873888388938903891389238933894389538963897389838993900390139023903390439053906390739083909391039113912391339143915391639173918391939203921392239233924392539263927392839293930393139323933393439353936393739383939394039413942394339443945394639473948394939503951395239533954395539563957395839593960396139623963396439653966396739683969397039713972397339743975397639773978397939803981398239833984398539863987398839893990399139923993399439953996399739983999400040014002400340044005400640074008400940104011401240134014401540164017401840194020402140224023402440254026402740284029403040314032403340344035403640374038403940404041404240434044404540464047404840494050405140524053405440554056405740584059406040614062406340644065406640674068406940704071407240734074
  1. package controllers
  2. import (
  3. "encoding/json"
  4. "fmt"
  5. "hongze/hongze_cygx/models"
  6. "hongze/hongze_cygx/services"
  7. "hongze/hongze_cygx/utils"
  8. "sort"
  9. "strconv"
  10. "strings"
  11. "time"
  12. "github.com/medivhzhan/weapp/v2"
  13. "github.com/rdlucklib/rdluck_tools/paging"
  14. )
  15. // 活动
  16. type ActivityCoAntroller struct {
  17. BaseAuthController
  18. }
  19. type ActivityABaseController struct {
  20. BaseCommonController
  21. }
  22. type ActivityNoLoginController struct {
  23. BaseAuthMobileController
  24. }
  25. // @Title 活动类型列表
  26. // @Description活动类型列表接口
  27. // @Success 200 {object} models.ActivityTypeListResp
  28. // @router /activityTypelist [get]
  29. func (this *ActivityCoAntroller) List() {
  30. br := new(models.BaseResponse).Init()
  31. defer func() {
  32. this.Data["json"] = br
  33. this.ServeJSON()
  34. }()
  35. user := this.User
  36. if user == nil {
  37. br.Msg = "请登录"
  38. br.ErrMsg = "请登录,SysUser Is Empty"
  39. br.Ret = 408
  40. return
  41. }
  42. resp := new(models.ActivityTypeListResp)
  43. list, err := models.GetActivityTypeList()
  44. if err != nil {
  45. br.Msg = "获取失败"
  46. br.ErrMsg = "获取数据失败,Err:" + err.Error()
  47. return
  48. }
  49. resp.List = list
  50. br.Ret = 200
  51. br.Success = true
  52. br.Msg = "获取成功"
  53. br.Data = resp
  54. }
  55. // @Title 我的日程
  56. // @Description 我的日程列表接口
  57. // @Param PageSize query int true "每页数据条数"
  58. // @Param CurrentIndex query int true "当前页页码,从1开始"
  59. // @Param Source query int false "来源 0:手机 ,1:Pc 默认0"
  60. // @Success 200 {object} models.GetCygxActivityListRep
  61. // @router /scheduleList [get]
  62. func (this *ActivityCoAntroller) ScheduleList() {
  63. br := new(models.BaseResponse).Init()
  64. defer func() {
  65. this.Data["json"] = br
  66. this.ServeJSON()
  67. }()
  68. user := this.User
  69. if user == nil {
  70. br.Msg = "请登录"
  71. br.ErrMsg = "请登录,SysUser Is Empty"
  72. return
  73. }
  74. uid := user.UserId
  75. pageSize, _ := this.GetInt("PageSize")
  76. currentIndex, _ := this.GetInt("CurrentIndex")
  77. source, _ := this.GetInt("Source")
  78. var startSize int
  79. if pageSize <= 0 {
  80. pageSize = utils.PageSize20
  81. }
  82. if currentIndex <= 0 {
  83. currentIndex = 1
  84. }
  85. startSize = utils.StartIndex(currentIndex, pageSize)
  86. var condition string
  87. var conditionCount string
  88. var pars []interface{}
  89. condition += ` AND art.publish_status = 1 `
  90. if source == 1 {
  91. condition += ` AND art.yidong_activity_id = '' `
  92. conditionCount += ` AND art.yidong_activity_id = '' `
  93. }
  94. total, err := models.GetScheduleCount(conditionCount, uid)
  95. specialtotal, err := models.GetSpecialScheduleCount(uid)
  96. page := paging.GetPaging(currentIndex, pageSize, total+specialtotal)
  97. if err != nil {
  98. br.Msg = "获取失败"
  99. br.ErrMsg = "获取失败,Err:" + err.Error()
  100. return
  101. }
  102. conditionCount = ` AND art.active_state = 2 `
  103. totalCount, err := models.GetScheduleCount(conditionCount, uid) //获取正在进行中的活动数量
  104. if err != nil {
  105. br.Msg = "获取失败"
  106. br.ErrMsg = "获取失败,Err:" + err.Error()
  107. return
  108. }
  109. var list []*models.ActivityDetail
  110. //全部都是进行中的活动
  111. if totalCount > currentIndex*pageSize {
  112. condition += ` AND art.active_state IN(2) `
  113. if source == 1 {
  114. condition += ` AND art.yidong_activity_id = '' `
  115. }
  116. listHave, errList := models.GetScheduleList(condition, pars, uid, startSize, pageSize)
  117. list = listHave
  118. if errList != nil {
  119. br.Msg = "获取失败"
  120. br.ErrMsg = "获取失败,Err:" + errList.Error()
  121. return
  122. }
  123. } else if totalCount > currentIndex-1*pageSize && totalCount < currentIndex*pageSize { //部分是进行中的活动
  124. condition = ` AND art.publish_status = 1 AND art.active_state IN(2) `
  125. if source == 1 {
  126. condition += ` AND art.yidong_activity_id = '' `
  127. }
  128. listHave, errList := models.GetScheduleList(condition, pars, uid, startSize, pageSize)
  129. list = listHave
  130. if errList != nil {
  131. br.Msg = "获取失败"
  132. br.ErrMsg = "获取失败,Err:" + errList.Error()
  133. return
  134. }
  135. pageSize = pageSize - len(listHave)
  136. condition = ` AND art.publish_status = 1 AND art.active_state IN(1,3) `
  137. if source == 1 {
  138. condition += ` AND art.yidong_activity_id = '' `
  139. }
  140. //listOther, errList := models.GetScheduleList(condition, pars, uid, startSize, pageSize)
  141. listOther, errList := services.GetScheduleAndSpecilList(user, condition, startSize, pageSize)
  142. if errList != nil {
  143. br.Msg = "获取失败"
  144. br.ErrMsg = "获取失败,Err:" + errList.Error()
  145. return
  146. }
  147. if len(listOther) > 0 {
  148. for _, v := range listOther {
  149. list = append(list, v)
  150. }
  151. }
  152. } else {
  153. condition += ` AND art.active_state IN(1,3)` //全部都不是进行中的活动
  154. //listOther, errList := models.GetScheduleList(condition, pars, uid, startSize, pageSize)
  155. listOther, errList := services.GetScheduleAndSpecilList(user, condition, startSize, pageSize)
  156. list = listOther
  157. if errList != nil {
  158. br.Msg = "获取失败"
  159. br.ErrMsg = "获取失败,Err:" + errList.Error()
  160. return
  161. }
  162. }
  163. var isShow bool
  164. isShow = services.GetShowSustainable()
  165. detail, err := models.GetConfigByCode("city_img_url")
  166. if err != nil {
  167. br.Msg = "获取数据失败"
  168. br.ErrMsg = "城市配置信息失败,Err:" + err.Error()
  169. return
  170. }
  171. detailChart, err := models.GetConfigByCode("chart_img_url")
  172. if err != nil {
  173. br.Msg = "获取数据失败"
  174. br.ErrMsg = "行业配置信息失败,Err:" + err.Error()
  175. return
  176. }
  177. addressList := strings.Split(detail.ConfigValue, "{|}")
  178. mapAddress := make(map[string]string)
  179. chartList := strings.Split(detailChart.ConfigValue, "{|}")
  180. mapChart := make(map[string]string)
  181. var cityName string
  182. var chartName string
  183. var imgUrl string
  184. var imgUrlChart string
  185. var mapActivityId []int
  186. for _, v := range addressList {
  187. vslice := strings.Split(v, "_")
  188. cityName = vslice[0]
  189. imgUrl = vslice[len(vslice)-1]
  190. mapAddress[cityName] = imgUrl
  191. }
  192. for _, v := range chartList {
  193. vslice := strings.Split(v, "_")
  194. chartName = vslice[0]
  195. imgUrlChart = vslice[len(vslice)-1]
  196. mapChart[chartName] = imgUrlChart
  197. }
  198. for k, v := range list {
  199. if strings.Contains(v.ActivityName, "【") {
  200. list[k].IsBrackets = 1
  201. }
  202. if v.SignupNum > v.LimitPeopleNum {
  203. list[k].SignupNum = v.LimitPeopleNum
  204. }
  205. //是否展示限免标签
  206. if isShow && strings.Contains(v.ChartPermissionName, "研选") {
  207. list[k].IsShowSustainable = true
  208. }
  209. if strings.Contains(v.ChartPermissionName, "研选") && v.ActivityTypeId == 1 {
  210. list[k].ActivityTypeName = "买方研选电话会"
  211. list[k].ImgUrlText = utils.YAN_XUAN_IMG
  212. }
  213. if v.ActivityType == 0 {
  214. if mapAddress[v.City] != "" {
  215. list[k].ImgUrl = mapAddress[v.City]
  216. } else {
  217. list[k].ImgUrl = mapAddress["其它"]
  218. }
  219. } else {
  220. if mapChart[v.ChartPermissionName] != "" {
  221. list[k].ImgUrl = mapChart[v.ChartPermissionName]
  222. }
  223. }
  224. expertTxt, _ := services.GetReportContentTextSub(v.Expert)
  225. list[k].Expert = expertTxt
  226. if v.IsHideAppointment == 0 {
  227. list[k].IsShowAppointment = services.IsShowAppointment(v.ActivityTypeId, v.ChartPermissionName)
  228. }
  229. if v.ActivityTypeId == utils.C_CLASS_ACTIVITY_TYPE_ID {
  230. list[k].IsCClassMeeting = true
  231. }
  232. mapActivityId = append(mapActivityId, v.ActivityId)
  233. }
  234. //添加我的日程访问记录
  235. //item := new(models.CygxPageHistoryRecord)
  236. //item.UserId = user.UserId
  237. //item.CreateTime = time.Now()
  238. //item.Mobile = user.Mobile
  239. //item.Email = user.Email
  240. //item.CompanyId = user.CompanyId
  241. //item.CompanyName = user.CompanyName
  242. //item.PageType = "MySchedule"
  243. //go models.AddCygxPageHistoryRecord(item)
  244. resp := new(models.GetCygxActivityListRep)
  245. //处理音频回放
  246. mapActivityVoice, err := services.GetActivityVoiceResp(mapActivityId)
  247. if err != nil {
  248. br.Msg = "获取信息失败"
  249. br.ErrMsg = "GetActivityVoiceResp,Err:" + err.Error()
  250. return
  251. }
  252. //处理视频回放
  253. mapActivityVideo, err := services.GetActivityVideoResp(mapActivityId)
  254. if err != nil {
  255. br.Msg = "获取信息失败"
  256. br.ErrMsg = "GetActivityVideoResp,Err:" + err.Error()
  257. return
  258. }
  259. //处理不同的报名方式按钮回显
  260. mapActivitySignup, err := services.GetActivitySignupResp(mapActivityId, user)
  261. if err != nil {
  262. br.Msg = "获取信息失败"
  263. br.ErrMsg = "GetActivitySignupResp,Err:" + err.Error()
  264. return
  265. }
  266. for k, v := range list {
  267. if mapActivityVoice[v.ActivityId] != nil {
  268. list[k].FileType = 1
  269. list[k].AudioLink = true
  270. list[k].VoiceList = mapActivityVoice[v.ActivityId]
  271. }
  272. if mapActivityVideo[v.ActivityId] != nil {
  273. list[k].FileType = 2
  274. list[k].AudioLink = true
  275. list[k].VideoDetail = mapActivityVideo[v.ActivityId]
  276. }
  277. v.SignupType = mapActivitySignup[v.ActivityId]
  278. //处理列表的标签是否展示逻辑
  279. resp.List = append(resp.List, services.ActivityButtonShow(v))
  280. }
  281. resp.Paging = page
  282. br.Ret = 200
  283. br.Success = true
  284. br.Msg = "获取成功"
  285. br.Data = resp
  286. }
  287. // @Title 活动详情
  288. // @Description 获取活动详情接口
  289. // @Param ActivityId query int true "活动ID"
  290. // @Param IsSendWx query int false "是否是通过微信模版进来的 1是,其它否"
  291. // @Success Ret=200 {object} models.CygxActivityResp
  292. // @router /detail [get]
  293. func (this *ActivityCoAntroller) Detail() {
  294. br := new(models.BaseResponse).Init()
  295. defer func() {
  296. this.Data["json"] = br
  297. this.ServeJSON()
  298. }()
  299. user := this.User
  300. if user == nil {
  301. br.Msg = "请登录"
  302. br.ErrMsg = "请登录,用户信息为空"
  303. br.Ret = 408
  304. return
  305. }
  306. uid := user.UserId
  307. activityId, _ := this.GetInt("ActivityId")
  308. isSendWx, _ := this.GetInt("IsSendWx")
  309. if activityId < 1 {
  310. br.Msg = "请输入活动ID"
  311. return
  312. }
  313. resp := new(models.CygxActivityResp)
  314. activityInfo, err := models.GetAddActivityInfoByIdShow(uid, activityId)
  315. if err != nil && err.Error() != utils.ErrNoRow() {
  316. br.Msg = "获取信息失败"
  317. br.ErrMsg = "获取活动详情信息失败,Err:" + err.Error()
  318. return
  319. }
  320. if activityInfo == nil {
  321. br.Msg = "活动不存在"
  322. br.ErrMsg = "活动ID错误,Err:" + "activityId:" + strconv.Itoa(activityId)
  323. return
  324. }
  325. // 判断是否属于研选类型的活动
  326. if strings.Contains(activityInfo.ChartPermissionName, utils.CHART_PERMISSION_NAME_YANXUAN) {
  327. resp.IsResearch = true
  328. }
  329. signupCount, err := models.GetActivitySignupSuccessByUserCountNoHz(activityId)
  330. if err != nil {
  331. br.Msg = "获取信息"
  332. br.ErrMsg = "GetActivitySignupSuccessByUserCountNoHz,Err:" + err.Error()
  333. return
  334. }
  335. activityInfo.SignupNum = signupCount
  336. havePower, isResearchSpecial, err := services.GetActivityDetailUserPower(user, activityInfo)
  337. if err != nil {
  338. br.Msg = "获取信息失败"
  339. br.ErrMsg = "校验用户权限失败,Err:" + err.Error()
  340. return
  341. }
  342. resp.IsResearchSpecial = isResearchSpecial
  343. if havePower {
  344. //是否展示限免标签
  345. if services.GetShowSustainable() && strings.Contains(activityInfo.ChartPermissionName, utils.CHART_PERMISSION_NAME_YANXUAN) {
  346. activityInfo.IsShowSustainable = true
  347. }
  348. resp.HasPermission = 1
  349. configCode := "description_of_research"
  350. detail, err := models.GetConfigByCode(configCode)
  351. if err != nil {
  352. br.Msg = "获取数据失败"
  353. br.ErrMsg = "获取数据失败,Err:" + err.Error()
  354. return
  355. }
  356. activityInfo.Description = detail.ConfigValue
  357. if activityInfo.SignupNum > activityInfo.LimitPeopleNum {
  358. activityInfo.SignupNum = activityInfo.LimitPeopleNum
  359. }
  360. if activityInfo.ChartPermissionNames != "" {
  361. activityInfo.ChartPermissionName = activityInfo.ChartPermissionNames
  362. }
  363. if activityInfo.IsHideAppointment == 0 {
  364. activityInfo.IsShowAppointment = services.IsShowAppointment(activityInfo.ActivityTypeId, activityInfo.ChartPermissionName)
  365. }
  366. activityInfo.ActivityTypeName = strings.Replace(activityInfo.ActivityTypeName, "(C类)", "", -1)
  367. //处理活动关联的产业
  368. industrialList, err := models.GetIndustrialActivityGroupManagementList(activityId)
  369. if err != nil && err.Error() != utils.ErrNoRow() {
  370. br.Msg = "获取信息失败"
  371. br.ErrMsg = "获取活动关联的产业列表信息失败,Err:" + err.Error() + "activityId:" + strconv.Itoa(activityId)
  372. return
  373. }
  374. if activityInfo.TemporaryLabel != "" {
  375. industrialList = make([]*models.IndustrialManagementRep, 0)
  376. item := new(models.IndustrialManagementRep)
  377. item.IndustryName = activityInfo.Label
  378. industrialList = append(industrialList, item)
  379. } else {
  380. industryIds := make([]int, 0)
  381. var industrialManagementId string
  382. for k, v := range industrialList {
  383. if v.ChartPermissionId == utils.CHART_PERMISSION_ID_YANXUAN {
  384. industrialList[k].IsResearch = true
  385. }
  386. industryIds = append(industryIds, v.IndustrialManagementId)
  387. industrialManagementId += strconv.Itoa(v.IndustrialManagementId) + ","
  388. }
  389. // 查研观向7.4-行业新标签
  390. industryNewMap, e := services.GetIndustryNewLabelMap(industryIds)
  391. if e != nil {
  392. br.Msg = "获取信息失败"
  393. br.ErrMsg = "获取产业新标签失败, Err: " + e.Error()
  394. return
  395. }
  396. //判断产业下是否有关联的报告,并处理是否跳转
  397. industrialManagementId = strings.TrimRight(industrialManagementId, ",")
  398. if industrialManagementId != "" {
  399. var condition string
  400. condition = ` AND m.industrial_management_id IN (` + industrialManagementId + `)`
  401. condition += ` AND a.article_id < ` + strconv.Itoa(utils.SummaryArticleId)
  402. listIndustrialGrop, err := models.GetSearchResourceList(user.UserId, condition, 0, 0)
  403. if err != nil && err.Error() != utils.ErrNoRow() {
  404. br.Msg = "获取信息失败"
  405. br.ErrMsg = "GetSearchResourceList,Err:" + err.Error() + "activityId:" + strconv.Itoa(activityId)
  406. return
  407. }
  408. mapIndustrial := make(map[int]int)
  409. if len(listIndustrialGrop) > 0 {
  410. for _, v := range listIndustrialGrop {
  411. mapIndustrial[v.IndustrialManagementId] = v.IndustrialManagementId
  412. }
  413. }
  414. for k, v := range industrialList {
  415. if mapIndustrial[v.IndustrialManagementId] > 0 && !industrialList[k].IsResearch {
  416. industrialList[k].IsJump = true
  417. }
  418. industrialList[k].IndustryNewLabel = industryNewMap[v.IndustrialManagementId]
  419. }
  420. }
  421. }
  422. activityInfo.Listndustrial = industrialList
  423. if activityInfo.YidongActivityId != "" {
  424. ydTgc, _ := services.GetYiDongCreateUserInfo(user)
  425. yidongLongLink, err := services.GetYiDongOriginalLink(activityInfo)
  426. if err != nil {
  427. br.Msg = "获取信息失败"
  428. br.ErrMsg = "GetYiDongOriginalLink,Err:" + err.Error() + "activityId:" + strconv.Itoa(activityId)
  429. return
  430. }
  431. //yidongKwy := activityInfo.YidongActivityUrl
  432. //activityInfo.YidongActivityUrl = yidongLongLink + "?source=11&fromHz=true&tgc=" + ydTgc
  433. activityInfo.YidongActivityUrl = yidongLongLink + "%26source=11%26fromHz=true%26tgc=" + ydTgc
  434. }
  435. //处理音频回放
  436. var mapActivityId []int
  437. mapActivityId = append(mapActivityId, activityId)
  438. mapActivityVoice, err := services.GetActivityVoiceResp(mapActivityId)
  439. if err != nil {
  440. br.Msg = "获取信息失败"
  441. br.ErrMsg = "GetActivityVoiceResp,Err:" + err.Error() + "activityId:" + strconv.Itoa(activityId)
  442. return
  443. }
  444. if mapActivityVoice[activityId] != nil {
  445. activityInfo.FileType = 1
  446. activityInfo.AudioLink = true
  447. activityInfo.VoiceList = mapActivityVoice[activityId]
  448. }
  449. //处理视频回放
  450. mapActivityVideo, err := services.GetActivityVideoResp(mapActivityId)
  451. if err != nil {
  452. br.Msg = "获取信息失败"
  453. br.ErrMsg = "GetActivityVideoResp,Err:" + err.Error()
  454. return
  455. }
  456. if mapActivityVideo[activityId] != nil {
  457. activityInfo.FileType = 2
  458. activityInfo.AudioLink = true
  459. activityInfo.VideoDetail = mapActivityVideo[activityId]
  460. }
  461. //8.5 小程序活动详情页 除专家电话外 其余属于新产业的活动 ,不显示 new 标签
  462. if activityInfo.ActivityTypeName != "专家电话会" {
  463. for _, rep := range activityInfo.Listndustrial {
  464. rep.IndustryNewLabel = false
  465. }
  466. }
  467. //8.5 买方研选的活动去掉限免标签
  468. if strings.Contains(activityInfo.ChartPermissionName, "研选") {
  469. activityInfo.IsShowSustainable = false
  470. }
  471. //处理不同的报名方式按钮回显
  472. mapActivitySignup, err := services.GetActivitySignupResp(mapActivityId, user)
  473. if err != nil {
  474. br.Msg = "获取信息失败"
  475. br.ErrMsg = "GetActivitySignupResp,Err:" + err.Error()
  476. return
  477. }
  478. activityInfo.SignupType = mapActivitySignup[activityId]
  479. //处理活动关联的产业
  480. industrialListNew, err := models.GetIndustrialActivityGroupManagementList(activityId)
  481. if err != nil && err.Error() != utils.ErrNoRow() {
  482. br.Msg = "获取信息失败"
  483. br.ErrMsg = "获取活动关联的产业列表信息失败,Err:" + err.Error() + "activityId:" + strconv.Itoa(activityId)
  484. return
  485. }
  486. //判断是不是通过微信模版推送消息进来的
  487. if isSendWx == 1 && len(industrialListNew) > 0 {
  488. industryUserFollowMap, err := services.GetIndustryUserFollowMap(user)
  489. if err != nil {
  490. br.Msg = "获取信息失败"
  491. br.ErrMsg = "GetActivitySignupResp,Err:" + err.Error()
  492. return
  493. }
  494. for _, v := range industrialListNew {
  495. if industryUserFollowMap[v.IndustrialManagementId] {
  496. activityInfo.IsFollowButton = true
  497. }
  498. }
  499. activityInfo.IsShowFollowButton = true
  500. }
  501. if activityInfo.ReportLink != "" {
  502. artList, err := services.GetActivityReportLinkToArticleList(activityInfo)
  503. if err != nil && err.Error() != utils.ErrNoRow() {
  504. br.Msg = "获取信息失败"
  505. br.ErrMsg = "解析文章关联的报告内容失败:" + activityInfo.ReportLink
  506. return
  507. }
  508. activityInfo.ArticleList = artList
  509. } else {
  510. activityInfo.ArticleList = make([]*models.ActivityArticleResp, 0)
  511. }
  512. if (activityInfo.ActivityTypeId == 5 || activityInfo.ActivityTypeId == 6) && services.GetBelongingRai(user.Mobile) && activityInfo.SigninImg != "" {
  513. activityInfo.IsShowSigninButton = true
  514. activityInfo.IsShowSignUpDetail = true
  515. }
  516. //处理按钮是否展示问题
  517. resp.Detail = services.ActivityButtonShow(activityInfo)
  518. } else {
  519. hasPermission, sellerName, sellerMobile, popupMsg, err := services.GetUserHasPermissionActivity(user, activityInfo)
  520. if err != nil {
  521. br.Msg = "获取信息失败"
  522. br.ErrMsg = "判断是否已申请过试用失败,Err:" + err.Error()
  523. return
  524. }
  525. resp.PopupMsg = popupMsg
  526. resp.HasPermission = hasPermission
  527. resp.SellerName = sellerName
  528. resp.SellerMobile = sellerMobile
  529. }
  530. collectCount1, err := models.GetActivityVoiceCollectCount(uid, activityId)
  531. if err != nil && err.Error() != utils.ErrNoRow() {
  532. br.Msg = "获取信息失败"
  533. br.ErrMsg = "判断是否已收藏失败,Err:" + strconv.Itoa(uid) + ";activityId" + strconv.Itoa(activityId)
  534. return
  535. }
  536. collectCount2, err := models.GetActivityVideoCollectCountByActivityId(uid, activityId)
  537. if err != nil && err.Error() != utils.ErrNoRow() {
  538. br.Msg = "获取信息失败"
  539. br.ErrMsg = "判断是否已收藏失败,Err:" + strconv.Itoa(uid) + ";activityId" + strconv.Itoa(activityId)
  540. return
  541. }
  542. if collectCount1+collectCount2 > 0 {
  543. resp.Detail.IsCollect = true
  544. }
  545. br.Ret = 200
  546. br.Success = true
  547. br.Msg = "获取成功"
  548. br.Data = resp
  549. }
  550. // @Title 活动报名
  551. // @Description 活动报名接口
  552. // @Param request body models.ActivitySingnupRep true "type json string"
  553. // @Success Ret=200 {object} models.SignupStatus
  554. // @router /signup/add [post]
  555. func (this *ActivityCoAntroller) SignupAdd() {
  556. br := new(models.BaseResponse).Init()
  557. defer func() {
  558. this.Data["json"] = br
  559. this.ServeJSON()
  560. }()
  561. user := this.User
  562. if user == nil {
  563. br.Msg = "请登录"
  564. br.ErrMsg = "请登录,用户信息为空"
  565. br.Ret = 408
  566. return
  567. }
  568. uid := user.UserId
  569. signupStatus := ""
  570. var req models.ActivitySingnupRep
  571. resp := new(models.SignupStatus)
  572. var total int
  573. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  574. if err != nil {
  575. br.Msg = "参数解析异常!"
  576. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  577. return
  578. }
  579. if user.Mobile == "" {
  580. user.Mobile = user.OutboundMobile
  581. }
  582. activityId := req.ActivityId
  583. signupType := req.SignupType
  584. hasPermission := 0
  585. if signupType == 1 && user.Mobile == "" && user.OutboundMobile == "" {
  586. resp.GoBindEmail = true
  587. }
  588. activityInfo, errInfo := models.GetAddActivityInfoById(activityId)
  589. if activityInfo == nil {
  590. br.Msg = "操作失败"
  591. br.ErrMsg = "活动ID错误,不存在activityId:" + strconv.Itoa(activityId)
  592. return
  593. }
  594. if errInfo != nil {
  595. br.Msg = "操作失败"
  596. br.ErrMsg = "操作失败,Err:" + errInfo.Error()
  597. return
  598. }
  599. // 如果是 易董办会 且没有勾选 可提供外呼 默认为自主入会
  600. if activityInfo.IsYidongConduct && activityInfo.IsCanOutboundCall == 0 {
  601. signupType = 4
  602. }
  603. //SignupStatus "报名状态:人数已满:FullStarffed、单机构超过两人:TwoPeople、爽约次数过多:BreakPromise、超时:Overtime 、成功:Success"`
  604. //HasPermission "1:有该行业权限,正常展示,2:无该行业权限,3:潜在客户,未提交过申请,4:潜在客户,已提交过申请"`
  605. var userType int
  606. userType, _, err = services.GetUserType(user.CompanyId)
  607. if err != nil {
  608. br.Msg = "获取信息失败!"
  609. br.ErrMsg = "获取失败,Err:" + err.Error()
  610. return
  611. }
  612. if userType == 1 && strings.Contains(activityInfo.ChartPermissionName, "研选") {
  613. br.Msg = "您暂无查看该活动权限"
  614. br.ErrMsg = "被分享客户不可见,永续客户无法查看研选行业"
  615. return
  616. }
  617. item := new(models.CygxActivitySignup)
  618. // 判断是否属于研选类型的活动
  619. if strings.Contains(activityInfo.ChartPermissionName, utils.CHART_PERMISSION_NAME_YANXUAN) {
  620. resp.IsResearch = true
  621. }
  622. havePower, isResearchSpecial, err := services.GetActivityDetailUserPower(user, activityInfo)
  623. if err != nil {
  624. br.Msg = "获取信息失败"
  625. br.ErrMsg = "校验用户权限失败,Err:" + err.Error()
  626. return
  627. }
  628. resp.IsResearchSpecial = isResearchSpecial
  629. if havePower {
  630. hasPermission = 1
  631. signupStatus = "Success"
  632. resp.HasPermission = hasPermission
  633. resultTime := utils.StrTimeToTime(activityInfo.ActivityTime) //时间字符串格式转时间格式
  634. if time.Now().After(resultTime.Add(-time.Minute * 60)) {
  635. signupStatus = "Overtime"
  636. resp.SignupType = signupType
  637. resp.SignupStatus = signupStatus
  638. resp.HasPermission = hasPermission
  639. resp.PopupMsg = "活动开始前1小时内无法预约,请联系对口销售处理"
  640. br.Ret = 200
  641. br.Success = true
  642. br.Msg = ""
  643. br.Data = resp
  644. return
  645. }
  646. var sellerName string
  647. sellerName, err = models.GetCompanySellerName(user.CompanyId)
  648. if err != nil {
  649. br.Msg = "报名失败!"
  650. br.ErrMsg = "获取对应销售失败,Err:" + err.Error()
  651. return
  652. }
  653. popupMsg, err := services.CheckActivityUserAll(activityInfo, user)
  654. if err != nil {
  655. br.Msg = "报名失败!"
  656. br.ErrMsg = "CheckActivityUserAll,Err:" + err.Error()
  657. return
  658. }
  659. if popupMsg != "" {
  660. br.Msg = "报名失败!"
  661. br.ErrMsg = fmt.Sprint("userId:", uid, "Activity:id", popupMsg)
  662. return
  663. }
  664. //人数已满:FullStarffed、单机构超过两人:TwoPeople、爽约次数过多:BreakPromise、超时:Overtime 、成功:Success"`
  665. //如果是下面几种情况则对报名信息做判断限制 (公司调研电话会(限制人数)、公司线下调研、专家/分析师线下沙龙)
  666. //if (activityInfo.ActivityTypeId == 3 && activityInfo.IsLimitPeople == 1) || activityInfo.ActivityTypeId > 3 {
  667. if activityInfo.IsLimitPeople == 1 {
  668. signupStatus, resp.PopupMsg, item.FailType, err = services.CheckActivitySignUpLimit(user, activityInfo)
  669. //判断优先级:总人数限制→单机构2人限制→爽约3次限制
  670. totalRestrict, err := models.GetUserRestrictCount(user.Mobile)
  671. if err != nil {
  672. br.Msg = "获取信息失败"
  673. br.ErrMsg = "获取客户信息失败,Err:" + err.Error()
  674. return
  675. }
  676. totalUserRestrictCount, err := models.GetActivitySignupByUserRestrictCount(uid, activityId)
  677. if err != nil {
  678. br.Msg = "获取失败"
  679. br.ErrMsg = "获取失败,Err:" + err.Error()
  680. return
  681. }
  682. //解除报名限制之后二次报名相同活动
  683. if totalUserRestrictCount > 0 && totalRestrict == 0 && resp.GoBindEmail != true {
  684. item.UserId = uid
  685. item.RealName = user.RealName
  686. item.SellerName = sellerName
  687. item.ActivityId = activityId
  688. item.CreateTime = time.Now()
  689. item.Mobile = user.Mobile
  690. item.Email = user.Email
  691. item.CompanyId = user.CompanyId
  692. item.CompanyName = user.CompanyName
  693. item.SignupType = signupType
  694. item.FailType = 0
  695. item.DoFailType = 0
  696. _, errSignup := models.AddActivitySignupByRestrict(item)
  697. if errSignup != nil {
  698. br.Msg = "操作失败"
  699. br.ErrMsg = "操作失败,Err:" + errSignup.Error()
  700. return
  701. }
  702. resp.HaqveJurisdiction = true
  703. resp.SignupType = signupType
  704. resp.SignupStatus = "Success"
  705. resp.HasPermission = hasPermission
  706. resp.ActivityId = activityId
  707. total, err = models.GetUserMeetingReminderCount(user.UserId)
  708. if err != nil {
  709. br.Msg = "获取信息失败"
  710. br.ErrMsg = "获取日程数量信息失败,Err:" + err.Error()
  711. return
  712. }
  713. if total == 0 {
  714. resp.GoFollow = true
  715. }
  716. br.Ret = 200
  717. br.Success = true
  718. br.Msg = "操作成功"
  719. br.Data = resp
  720. return
  721. }
  722. totalMy, err := models.GetActivitySignupByUserCount(uid, activityId)
  723. if err != nil {
  724. br.Msg = "获取失败"
  725. br.ErrMsg = "获取失败,Err:" + err.Error()
  726. return
  727. }
  728. if signupStatus != "Success" && totalMy == 0 && resp.GoBindEmail != true {
  729. item.UserId = uid
  730. item.RealName = user.RealName
  731. item.SellerName = sellerName
  732. item.ActivityId = activityId
  733. item.CreateTime = time.Now()
  734. item.Mobile = user.Mobile
  735. item.Email = user.Email
  736. item.CompanyId = user.CompanyId
  737. item.CompanyName = user.CompanyName
  738. item.SignupType = signupType
  739. item.DoFailType = item.FailType
  740. if user.OutboundMobile != "" {
  741. item.OutboundMobile = user.OutboundMobile
  742. if user.OutboundCountryCode == "" {
  743. item.CountryCode = "86"
  744. } else {
  745. item.CountryCode = user.OutboundCountryCode
  746. }
  747. } else {
  748. item.OutboundMobile = user.Mobile
  749. if user.CountryCode == "" {
  750. item.CountryCode = "86"
  751. } else {
  752. item.CountryCode = user.CountryCode
  753. }
  754. }
  755. //添加报名信息,但是不加入日程
  756. _, errSignup := models.AddActivitySignupNoSchedule(item)
  757. if errSignup != nil {
  758. br.Msg = "操作失败"
  759. br.ErrMsg = "操作失败,Err:" + errSignup.Error()
  760. return
  761. }
  762. }
  763. }
  764. totalMySuccess, err := models.GetActivitySignupCount(uid, activityId)
  765. if err != nil {
  766. br.Msg = "获取失败"
  767. br.ErrMsg = "获取失败,Err:" + err.Error()
  768. return
  769. }
  770. if totalMySuccess > 0 {
  771. br.Msg = "您已报名这个活动"
  772. return
  773. }
  774. if signupStatus == "Success" && resp.GoBindEmail != true {
  775. item.UserId = uid
  776. item.RealName = user.RealName
  777. item.SellerName = sellerName
  778. item.ActivityId = activityId
  779. item.CreateTime = time.Now()
  780. item.Mobile = user.Mobile
  781. item.Email = user.Email
  782. item.CompanyId = user.CompanyId
  783. item.CompanyName = user.CompanyName
  784. item.SignupType = signupType
  785. item.FailType = 0
  786. item.DoFailType = 0
  787. item.OutboundMobile = user.Mobile
  788. if user.OutboundMobile != "" {
  789. item.OutboundMobile = user.OutboundMobile
  790. if user.OutboundCountryCode == "" {
  791. item.CountryCode = "86"
  792. } else {
  793. item.CountryCode = user.OutboundCountryCode
  794. }
  795. } else {
  796. item.OutboundMobile = user.Mobile
  797. if user.CountryCode == "" {
  798. item.CountryCode = "86"
  799. } else {
  800. item.CountryCode = user.CountryCode
  801. }
  802. }
  803. _, errSignup := models.AddActivitySignup(item)
  804. if errSignup != nil {
  805. br.Msg = "操作失败"
  806. br.ErrMsg = "操作失败,Err:" + errSignup.Error()
  807. return
  808. }
  809. resp.HaqveJurisdiction = true
  810. //1:预约外呼 、2:设置会议提醒 、 3:预约纪要 、4:活动报名
  811. if signupType == 1 {
  812. go services.ActivityUserRemind(user, activityInfo, 1)
  813. resp.PopupMsg = "<b>预约成功,已加入您的活动日程</b><br/><br/>想要及时获取活动信息变更通知,请关注【查研观向小助手】公众号"
  814. } else if signupType == 4 {
  815. go services.ActivityUserRemind(user, activityInfo, 4)
  816. resp.PopupMsg = "<b>报名成功,请复制腾讯会议号打开腾讯会议app参会</b><br/>想要及时获取活动信息变更通知,请关注【查研观向小助手】公众号"
  817. } else {
  818. go services.ActivityUserRemind(user, activityInfo, 4)
  819. resp.PopupMsg = "<b>报名成功,已加入您的活动日程</b><br/>想要及时获取活动信息变更通知,请关注【查研观向小助手】公众号"
  820. }
  821. go services.YanXuanActivityPointsBillSignupAdd(activityId, uid) // 用户报名添加到处理研选扣点
  822. }
  823. } else {
  824. hasPermission, sellerName, sellerMobile, popupMsg, err := services.GetUserHasPermissionActivity(user, activityInfo)
  825. if err != nil {
  826. br.Msg = "获取信息失败"
  827. br.ErrMsg = "判断是否已申请过试用失败,Err:" + err.Error()
  828. return
  829. }
  830. resp.PopupMsg = popupMsg
  831. resp.HasPermission = hasPermission
  832. resp.SellerName = sellerName
  833. resp.SellerMobile = sellerMobile
  834. }
  835. // 判断是否属于研选类型的活动
  836. if strings.Contains(activityInfo.ChartPermissionName, utils.CHART_PERMISSION_NAME_YANXUAN) {
  837. resp.IsResearch = true
  838. }
  839. //公司线下调研活动客户报名后给建会人,所属销售推送模板信息
  840. if signupStatus == "Success" {
  841. go services.SendResearchActivitiesTemplateMsg(user, activityInfo)
  842. }
  843. if signupType == 1 && user.IsMsgOutboundMobile == 0 {
  844. resp.GoOutboundMobile = true
  845. if user.Mobile != "" || user.OutboundMobile != "" {
  846. go models.ModifyWxUserIsMsgOutboundMobile(user.UserId)
  847. }
  848. }
  849. if user.OutboundMobile == "" {
  850. resp.Mobile = user.Mobile
  851. if user.CountryCode == "" && len(user.Mobile) == 11 {
  852. resp.CountryCode = "86"
  853. } else {
  854. resp.CountryCode = user.CountryCode
  855. }
  856. } else {
  857. resp.Mobile = user.OutboundMobile
  858. resp.CountryCode = user.OutboundCountryCode
  859. }
  860. //如果用户有绑定手机号,但是没有绑定外呼手机号
  861. if signupType == 1 && user.Mobile != "" && user.OutboundMobile == "" {
  862. var countryCode string
  863. if len(user.Mobile) == 8 {
  864. countryCode = "852"
  865. } else if len(user.Mobile) == 9 {
  866. countryCode = "886"
  867. } else if len(user.Mobile) == 10 {
  868. countryCode = "1"
  869. } else if len(user.Mobile) >= 11 {
  870. countryCode = "86"
  871. }
  872. models.BindUserOutboundMobileByMobile(user.Mobile, countryCode, uid)
  873. }
  874. resp.SignupType = signupType
  875. resp.SignupStatus = signupStatus
  876. //resp.HasPermission = hasPermission
  877. //if signupStatus == "Success" {
  878. resp.ActivityId = activityId
  879. //}
  880. total, err = models.GetUserSignupCount(user.UserId)
  881. if err != nil {
  882. br.Msg = "获取信息失败"
  883. br.ErrMsg = "获取日程数量信息失败,Err:" + err.Error()
  884. return
  885. }
  886. if total <= 1 {
  887. resp.GoFollow = true
  888. }
  889. br.Ret = 200
  890. br.Success = true
  891. br.Msg = "操作成功"
  892. br.Data = resp
  893. }
  894. // @Title 活动取消报名
  895. // @Description 活动取消报名接口
  896. // @Param request body models.ActivitySingnupRep true "type json string"
  897. // @Success Ret=200 {object} models.SignupStatus
  898. // @router /signup/cancel [post]
  899. func (this *ActivityCoAntroller) SignupCancel() {
  900. br := new(models.BaseResponse).Init()
  901. defer func() {
  902. this.Data["json"] = br
  903. this.ServeJSON()
  904. }()
  905. user := this.User
  906. if user == nil {
  907. br.Msg = "请登录"
  908. br.ErrMsg = "请登录,用户信息为空"
  909. br.Ret = 408
  910. return
  911. }
  912. uid := user.UserId
  913. var req models.ActivitySingnupRep
  914. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  915. if err != nil {
  916. br.Msg = "参数解析异常!"
  917. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  918. return
  919. }
  920. activityId := req.ActivityId
  921. signupType := req.SignupType
  922. item := new(models.CygxActivitySignup)
  923. activityInfo, errInfo := models.GetAddActivityInfoById(activityId)
  924. if activityInfo == nil {
  925. br.Msg = "操作失败"
  926. br.ErrMsg = "活动ID错误,不存在activityId:" + strconv.Itoa(activityId)
  927. return
  928. }
  929. if errInfo != nil {
  930. br.Msg = "操作失败"
  931. br.ErrMsg = "操作失败,Err:" + errInfo.Error()
  932. return
  933. }
  934. cancelDeadlineMsg := services.CheckCancelDeadline(activityInfo)
  935. if cancelDeadlineMsg != "" {
  936. br.Msg = cancelDeadlineMsg
  937. br.ErrMsg = cancelDeadlineMsg
  938. return
  939. }
  940. resultTime := utils.StrTimeToTime(activityInfo.ActivityTime) //时间字符串格式转时间格式
  941. if time.Now().After(resultTime.Add(-time.Minute * 60)) {
  942. if signupType == 1 {
  943. br.Msg = "活动开始前1小时内无法取消预约外呼,请联系对口销售处理"
  944. } else {
  945. br.Msg = "活动开始前1小时内无法取消报名,请联系对口销售处理"
  946. }
  947. return
  948. }
  949. total, err := models.GetActivitySignupCount(uid, activityId)
  950. if err != nil {
  951. br.Msg = "获取失败"
  952. br.ErrMsg = "获取失败,Err:" + err.Error()
  953. return
  954. }
  955. if total == 0 {
  956. br.Msg = "您暂未报名这个活动"
  957. return
  958. }
  959. item.UserId = uid
  960. item.ActivityId = activityId
  961. item.CreateTime = time.Now()
  962. item.Mobile = user.Mobile
  963. item.Email = user.Email
  964. item.CompanyId = user.CompanyId
  965. item.CompanyName = user.CompanyName
  966. resp := new(models.SignupStatus)
  967. resp.ActivityId = activityId
  968. _, errSignup := models.CancelActivitySignup(item)
  969. if errSignup != nil {
  970. br.Msg = "操作失败"
  971. br.ErrMsg = "操作失败,Err:" + errSignup.Error()
  972. return
  973. }
  974. // 如果是买方研选下的专家沙龙,同时推给内容组四人
  975. if activityInfo.ActivityTypeId == 5 {
  976. go services.SendActivitieCancelSignTemplateMsg(user, activityInfo)
  977. }
  978. go services.YanXuanActivityPointsBillSignupCancel(activityId, uid) // 用户取消报名添加到处理研选扣点
  979. br.Ret = 200
  980. br.Success = true
  981. br.Msg = "操作成功"
  982. br.Data = resp
  983. }
  984. // @Title 用户搜索详情
  985. // @Description 获取用户搜索详情接口
  986. // @Param IsShowJurisdiction query int true "是否仅展示有权限的,默认为0,1是,2否 "
  987. // @Param IsHideResearch query int true "是否隐藏研选行业 "
  988. // @Success Ret=200 {object} models.ActivityUserSearchContentList
  989. // @router /getUserSearchContent [get]
  990. func (this *ActivityCoAntroller) GetUserSearchContent() {
  991. br := new(models.BaseResponse).Init()
  992. defer func() {
  993. this.Data["json"] = br
  994. this.ServeJSON()
  995. }()
  996. user := this.User
  997. if user == nil {
  998. br.Msg = "请登录"
  999. br.ErrMsg = "请登录,用户信息为空"
  1000. br.Ret = 408
  1001. return
  1002. }
  1003. isHideResearch, _ := this.GetBool("IsHideResearch", false)
  1004. uid := user.UserId
  1005. detailSeearch := new(models.CygxActivityUserSearchContent)
  1006. detailSeearch.IsShowJurisdiction = 0
  1007. detailSeearch.ChartPermissionids = ""
  1008. detailSeearch.ActiveState = ""
  1009. resp := new(models.ActivityUserSearchContentList)
  1010. detail, _ := models.GetUserSearchContentByUid(uid)
  1011. if detail == nil {
  1012. detail = detailSeearch
  1013. }
  1014. isShowJurisdiction, _ := this.GetInt("IsShowJurisdiction")
  1015. listActivityType, errActivityType := models.GetActivityTypeList()
  1016. if errActivityType != nil {
  1017. br.Msg = "获取失败"
  1018. br.ErrMsg = "获取数据失败,Err:" + errActivityType.Error()
  1019. return
  1020. }
  1021. var listChartPermissionid []*models.ActivityChartPermission
  1022. var errChart error
  1023. if isShowJurisdiction == 1 {
  1024. listChartPermissionidAll, errChartAll := models.GetUserCompanyPermission(user.CompanyId)
  1025. listChartPermissionid = listChartPermissionidAll
  1026. errChart = errChartAll
  1027. } else if isShowJurisdiction == 2 {
  1028. listChartPermissionidAll, errChartAll := models.GetChartPermissionActivity()
  1029. listChartPermissionid = listChartPermissionidAll
  1030. errChart = errChartAll
  1031. } else {
  1032. if detail.IsShowJurisdiction == 1 {
  1033. listChartPermissionidAll, errChartAll := models.GetUserCompanyPermission(user.CompanyId)
  1034. listChartPermissionid = listChartPermissionidAll
  1035. errChart = errChartAll
  1036. } else {
  1037. listChartPermissionidAll, errChartAll := models.GetChartPermissionActivity()
  1038. listChartPermissionid = listChartPermissionidAll
  1039. errChart = errChartAll
  1040. }
  1041. }
  1042. if errChart != nil {
  1043. br.Msg = "获取信息失败"
  1044. br.ErrMsg = "获取品种信息失败,Err:" + errChart.Error()
  1045. return
  1046. }
  1047. if detail.IsShowJurisdiction == 1 {
  1048. resp.IsShowJurisdiction = true
  1049. }
  1050. if isShowJurisdiction == 1 || detail.IsShowJurisdiction == 1 {
  1051. resp.IsShowJurisdiction = true
  1052. for k, _ := range listChartPermissionid {
  1053. listChartPermissionid[k].IsChoose = true
  1054. }
  1055. }
  1056. if isShowJurisdiction == 2 {
  1057. resp.IsShowJurisdiction = false
  1058. }
  1059. activeStateList := []models.ActivityStaus{models.ActivityStaus{Id: 1, StatusName: "未开始", IsChoose: true}, models.ActivityStaus{Id: 2, StatusName: "进行中"}, models.ActivityStaus{Id: 3, StatusName: "已结束"}}
  1060. list2, err := models.GetChartPermissionActivity()
  1061. if err != nil {
  1062. br.Msg = "获取信息失败"
  1063. br.ErrMsg = "获取品种信息失败,Err:" + err.Error()
  1064. return
  1065. }
  1066. if activeStateList[1].IsChoose == activeStateList[2].IsChoose == false {
  1067. activeStateList[0].IsChoose = true
  1068. }
  1069. var userType int
  1070. userType, _, err = services.GetUserType(user.CompanyId)
  1071. if err != nil {
  1072. br.Msg = "获取信息失败!"
  1073. br.ErrMsg = "获取失败,Err:" + err.Error()
  1074. return
  1075. }
  1076. var listChartPermissionidNew2 []*models.ActivityChartPermission
  1077. for _, v := range list2 {
  1078. if userType == 1 || isHideResearch {
  1079. //if v.PermissionName != "研选" {
  1080. if !strings.Contains(v.PermissionName, "研选") {
  1081. listChartPermissionidNew2 = append(listChartPermissionidNew2, v)
  1082. }
  1083. } else {
  1084. listChartPermissionidNew2 = append(listChartPermissionidNew2, v)
  1085. }
  1086. }
  1087. resp.ListChartPermission2 = listChartPermissionidNew2
  1088. var listChartPermissionidNew []*models.ActivityChartPermission
  1089. for _, v := range listChartPermissionid {
  1090. if userType == 1 || isHideResearch {
  1091. if !strings.Contains(v.PermissionName, "研选") {
  1092. listChartPermissionidNew = append(listChartPermissionidNew, v)
  1093. }
  1094. } else {
  1095. listChartPermissionidNew = append(listChartPermissionidNew, v)
  1096. }
  1097. }
  1098. resp.ListActivityType = listActivityType
  1099. resp.ListChartPermission = listChartPermissionidNew
  1100. resp.ListActivityStaus = activeStateList
  1101. br.Ret = 200
  1102. br.Success = true
  1103. br.Msg = "获取成功"
  1104. br.Data = resp
  1105. }
  1106. // @Title 添加会议提醒
  1107. // @Description 添加会议提醒接口
  1108. // @Param request body models.ActivityIdRep true "type json string"
  1109. // @Success Ret=200 {object} models.SignupStatus
  1110. // @router /meetingReminder/add [post]
  1111. func (this *ActivityCoAntroller) MeetingReminderAdd() {
  1112. br := new(models.BaseResponse).Init()
  1113. defer func() {
  1114. this.Data["json"] = br
  1115. this.ServeJSON()
  1116. }()
  1117. user := this.User
  1118. if user == nil {
  1119. br.Msg = "请登录"
  1120. br.ErrMsg = "请登录,用户信息为空"
  1121. br.Ret = 408
  1122. return
  1123. }
  1124. uid := user.UserId
  1125. //var signupStatus string
  1126. signupStatus := "Success"
  1127. var req models.ActivityIdRep
  1128. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  1129. if err != nil {
  1130. br.Msg = "参数解析异常!"
  1131. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  1132. return
  1133. }
  1134. activityId := req.ActivityId
  1135. activityInfo, errInfo := models.GetAddActivityInfoById(activityId)
  1136. if activityInfo == nil {
  1137. br.Msg = "操作失败"
  1138. br.ErrMsg = "活动ID错误,不存在activityId:" + strconv.Itoa(activityId)
  1139. return
  1140. }
  1141. if errInfo != nil {
  1142. br.Msg = "操作失败"
  1143. br.ErrMsg = "操作失败,Err:" + errInfo.Error()
  1144. return
  1145. }
  1146. //SignupStatus string `description:"报名状态:人数已满:FullStarffed、单机构超过两人:TwoPeople、爽约次数过多:BreakPromise、超时:Overtime 、成功:Success"`
  1147. item := new(models.CygxActivityMeetingReminder)
  1148. resp := new(models.SignupStatus)
  1149. hasPermission := 0
  1150. resultTime := utils.StrTimeToTime(activityInfo.ActivityTime) //时间字符串格式转时间格式
  1151. if time.Now().After(resultTime.Add(-time.Minute * 15)) {
  1152. br.Msg = "活动开始前15分钟无法设置会议提醒"
  1153. return
  1154. }
  1155. // 判断是否属于研选类型的活动
  1156. if strings.Contains(activityInfo.ChartPermissionName, utils.CHART_PERMISSION_NAME_YANXUAN) {
  1157. resp.IsResearch = true
  1158. }
  1159. havePower, isResearchSpecial, err := services.GetActivityDetailUserPower(user, activityInfo)
  1160. if err != nil {
  1161. br.Msg = "获取信息失败"
  1162. br.ErrMsg = "校验用户权限失败,Err:" + err.Error()
  1163. return
  1164. }
  1165. resp.IsResearchSpecial = isResearchSpecial
  1166. if havePower {
  1167. hasPermission = 1
  1168. signupStatus = "Success"
  1169. totalMeeting, errMeeting := models.GetActivityMeetingReminderCount(uid, activityId)
  1170. if errMeeting != nil {
  1171. br.Msg = "获取失败"
  1172. br.ErrMsg = "获取失败,Err:" + errMeeting.Error()
  1173. return
  1174. }
  1175. if totalMeeting > 0 {
  1176. br.Msg = "您已预约,请勿重复预约"
  1177. return
  1178. }
  1179. item.UserId = uid
  1180. item.ActivityId = activityId
  1181. item.CreateTime = time.Now()
  1182. item.Mobile = user.Mobile
  1183. item.Email = user.Email
  1184. item.CompanyId = user.CompanyId
  1185. item.CompanyName = user.CompanyName
  1186. resp.HasPermission = hasPermission
  1187. _, errSignup := models.AddActivityMeetingReminder(item)
  1188. if errSignup != nil {
  1189. br.Msg = "操作失败"
  1190. br.ErrMsg = "操作失败,Err:" + errSignup.Error()
  1191. return
  1192. }
  1193. resp.HaqveJurisdiction = true
  1194. //1:预约外呼 、2:设置会议提醒 、 3:预约纪要 、4:活动报名
  1195. go services.ActivityUserRemind(user, activityInfo, 2)
  1196. } else {
  1197. hasPermission, sellerName, sellerMobile, popupMsg, err := services.GetUserHasPermissionActivity(user, activityInfo)
  1198. if err != nil {
  1199. br.Msg = "获取信息失败"
  1200. br.ErrMsg = "判断是否已申请过试用失败,Err:" + err.Error()
  1201. return
  1202. }
  1203. resp.PopupMsg = popupMsg
  1204. resp.HasPermission = hasPermission
  1205. resp.SellerName = sellerName
  1206. resp.SellerMobile = sellerMobile
  1207. }
  1208. // 判断是否属于研选类型的活动
  1209. if strings.Contains(activityInfo.ChartPermissionName, utils.CHART_PERMISSION_NAME_YANXUAN) {
  1210. resp.IsResearch = true
  1211. }
  1212. resp.SignupStatus = signupStatus
  1213. resp.ActivityId = activityId
  1214. var total int
  1215. total, err = models.GetUserActivityMeetingReminderCount(user.UserId)
  1216. if err != nil {
  1217. br.Msg = "获取信息失败"
  1218. br.ErrMsg = "获取日程数量信息失败,Err:" + err.Error()
  1219. return
  1220. }
  1221. if total <= 1 {
  1222. resp.GoFollow = true
  1223. }
  1224. br.Ret = 200
  1225. br.Success = true
  1226. if hasPermission == 1 {
  1227. br.Msg = "设置成功,会前15分钟会为您推送微信消息提醒"
  1228. resp.PopupMsg = "设置成功,会前15分钟会为您推送微信消息提醒<br/><br/>请关注【查研观向小助手】公众号,以获取微信消息提醒"
  1229. }
  1230. br.Data = resp
  1231. }
  1232. // @Title 取消会议提醒
  1233. // @Description 取消会议提醒接口
  1234. // @Param request body models.ActivityIdRep true "type json string"
  1235. // @Success Ret=200 {object} models.SignupStatus
  1236. // @router /meetingReminder/cancel [post]
  1237. func (this *ActivityCoAntroller) MeetingReminderCancel() {
  1238. br := new(models.BaseResponse).Init()
  1239. defer func() {
  1240. this.Data["json"] = br
  1241. this.ServeJSON()
  1242. }()
  1243. user := this.User
  1244. if user == nil {
  1245. br.Msg = "请登录"
  1246. br.ErrMsg = "请登录,用户信息为空"
  1247. br.Ret = 408
  1248. return
  1249. }
  1250. uid := user.UserId
  1251. var req models.ActivityIdRep
  1252. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  1253. if err != nil {
  1254. br.Msg = "参数解析异常!"
  1255. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  1256. return
  1257. }
  1258. activityId := req.ActivityId
  1259. signupStatus := "Success"
  1260. item := new(models.CygxActivityMeetingReminder)
  1261. activityInfo, errInfo := models.GetAddActivityInfoById(activityId)
  1262. if activityInfo == nil {
  1263. br.Msg = "操作失败"
  1264. br.ErrMsg = "活动ID错误,不存在activityId:" + strconv.Itoa(activityId)
  1265. return
  1266. }
  1267. if errInfo != nil {
  1268. br.Msg = "操作失败"
  1269. br.ErrMsg = "操作失败,Err:" + errInfo.Error()
  1270. return
  1271. }
  1272. //if signupStatus == "Success" {
  1273. total, err := models.GetActivityMeetingReminderCount(uid, activityId)
  1274. if err != nil {
  1275. br.Msg = "获取失败"
  1276. br.ErrMsg = "获取失败,Err:" + err.Error()
  1277. return
  1278. }
  1279. if total == 0 {
  1280. br.Msg = "您暂未添加该活动会议提醒"
  1281. return
  1282. }
  1283. resultTime := utils.StrTimeToTime(activityInfo.ActivityTime) //时间字符串格式转时间格式
  1284. if time.Now().After(resultTime.Add(-time.Minute * 15)) {
  1285. br.Msg = "活动开始前15分钟无法取消会议提醒"
  1286. return
  1287. }
  1288. item.UserId = uid
  1289. item.ActivityId = activityId
  1290. item.CreateTime = time.Now()
  1291. item.Mobile = user.Mobile
  1292. item.Email = user.Email
  1293. item.CompanyId = user.CompanyId
  1294. item.CompanyName = user.CompanyName
  1295. _, errSignup := models.CancelActivityMeetingReminder(item)
  1296. if errSignup != nil {
  1297. br.Msg = "操作失败"
  1298. br.ErrMsg = "操作失败,Err:" + errSignup.Error()
  1299. return
  1300. }
  1301. //}
  1302. resp := new(models.SignupStatus)
  1303. resp.SignupStatus = signupStatus
  1304. resp.ActivityId = activityId
  1305. br.Ret = 200
  1306. br.Success = true
  1307. br.Msg = "会议提醒已取消"
  1308. br.Data = resp
  1309. }
  1310. // @Title 敏捷搜索关键词的列表
  1311. // @Description 获取敏捷搜索关键词的列表接口
  1312. // @Success 200 {object} models.ActivityFastsearchKeywordsListResp
  1313. // @router /fastSearchKeWord [get]
  1314. func (this *ActivityABaseController) FastSearch() {
  1315. br := new(models.BaseResponse).Init()
  1316. defer func() {
  1317. this.Data["json"] = br
  1318. this.ServeJSON()
  1319. }()
  1320. resp := new(models.ActivityFastsearchKeywordsListResp)
  1321. list, err := models.GetActivityFastsearchKeywordsList()
  1322. if err != nil {
  1323. br.Msg = "获取失败"
  1324. br.ErrMsg = "获取数据失败,Err:" + err.Error()
  1325. return
  1326. }
  1327. resp.List = list
  1328. br.Ret = 200
  1329. br.Success = true
  1330. br.Msg = "获取成功"
  1331. br.Data = resp
  1332. }
  1333. // @Title 活动带问
  1334. // @Description 新增活动带问接口
  1335. // @Param request body models.AddCygxActivityHelpAsk true "type json string"
  1336. // @Success Ret=200 新增成功
  1337. // @router /askAdd [post]
  1338. func (this *ActivityCoAntroller) AskAdd() {
  1339. br := new(models.BaseResponse).Init()
  1340. defer func() {
  1341. this.Data["json"] = br
  1342. this.ServeJSON()
  1343. }()
  1344. user := this.User
  1345. if user == nil {
  1346. br.Msg = "请登录"
  1347. br.ErrMsg = "请登录,SysUser Is Empty"
  1348. br.Ret = 408
  1349. return
  1350. }
  1351. var req models.CygxActivityHelpAsk
  1352. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  1353. if err != nil {
  1354. br.Msg = "参数解析异常!"
  1355. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  1356. return
  1357. }
  1358. if req.Content == "" {
  1359. br.Msg = "建议内容不可为空"
  1360. return
  1361. }
  1362. content := req.Content
  1363. itemToken, err := services.WxGetToken()
  1364. if err != nil {
  1365. br.Msg = "GetWxAccessToken Err:" + err.Error()
  1366. return
  1367. }
  1368. if itemToken.AccessToken == "" {
  1369. br.Msg = "accessToken is empty"
  1370. return
  1371. }
  1372. commerr, err := weapp.MSGSecCheck(itemToken.AccessToken, content)
  1373. if err != nil {
  1374. br.Msg = "内容校验失败!"
  1375. br.ErrMsg = "内容校验失败,Err:" + err.Error()
  1376. return
  1377. }
  1378. if commerr.ErrCode != 0 {
  1379. br.Msg = "内容违规,请重新提交!"
  1380. br.ErrMsg = "颜文字内容违规,Err:" + commerr.ErrMSG
  1381. return
  1382. }
  1383. activityId := req.ActivityId
  1384. activityInfo, errInfo := models.GetAddActivityInfoById(activityId)
  1385. if activityInfo == nil {
  1386. br.Msg = "操作失败"
  1387. br.ErrMsg = "活动ID错误,不存在activityId:" + strconv.Itoa(activityId)
  1388. return
  1389. }
  1390. if errInfo != nil {
  1391. br.Msg = "操作失败"
  1392. br.ErrMsg = "操作失败,Err:" + errInfo.Error()
  1393. return
  1394. }
  1395. //resultTime := utils.StrTimeToTime(activityInfo.ActivityTime) //时间字符串格式转时间格式
  1396. //if activityInfo.ActivityTypeId == 1 && activityInfo.ChartPermissionId != 31 {
  1397. // if time.Now().After(resultTime.Add(-time.Minute * 15)) {
  1398. // br.Msg = "活动开始前15分钟内无法提交问题"
  1399. // return
  1400. // }
  1401. //} else {
  1402. // if time.Now().After(resultTime.Add(-time.Minute * 60)) {
  1403. // br.Msg = "活动开始前1小时内无法提交问题"
  1404. // return
  1405. // }
  1406. //}
  1407. companyDetail, err := models.GetCompanyDetailById(user.CompanyId)
  1408. if err != nil {
  1409. br.Msg = "提交失败!"
  1410. br.ErrMsg = "获取客户详情失败,Err:" + err.Error()
  1411. return
  1412. }
  1413. if companyDetail == nil {
  1414. br.Msg = "提交失败!"
  1415. br.ErrMsg = "客户不存在,uid:" + strconv.Itoa(user.UserId)
  1416. return
  1417. }
  1418. item := new(models.CygxActivityHelpAsk)
  1419. item.UserId = user.UserId
  1420. item.ActivityId = req.ActivityId
  1421. item.CompanyId = user.CompanyId
  1422. item.CompanyName = companyDetail.CompanyName
  1423. item.CreateTime = time.Now()
  1424. item.Mobile = user.Mobile
  1425. item.Email = user.Email
  1426. item.Content = content
  1427. msgId, err := models.AddActivityHelpAsk(item)
  1428. if err != nil {
  1429. br.Msg = "提交失败"
  1430. br.ErrMsg = "提交带问失败,Err:" + err.Error()
  1431. return
  1432. }
  1433. var isSendMsg bool
  1434. resultTime := utils.StrTimeToTime(activityInfo.ActivityTime) //时间字符串格式转时间格式
  1435. if activityInfo.ActivityTypeId == 1 && activityInfo.ChartPermissionId != 31 {
  1436. if time.Now().After(resultTime.Add(-time.Minute * 15)) {
  1437. isSendMsg = true
  1438. }
  1439. } else {
  1440. if time.Now().After(resultTime.Add(-time.Minute * 60)) {
  1441. isSendMsg = true
  1442. }
  1443. }
  1444. if isSendMsg {
  1445. listEmail, err := models.GetAskEmail()
  1446. if err != nil {
  1447. br.Msg = "提交失败"
  1448. br.ErrMsg = "提交带问失败,Err:" + err.Error()
  1449. return
  1450. }
  1451. var sendMobile string
  1452. for _, v := range listEmail {
  1453. if strings.Index(activityInfo.Host, v.Name) > 0 {
  1454. sendMobile = v.Mobile
  1455. }
  1456. }
  1457. //如果是研选的就推送给汪洋
  1458. if activityInfo.ChartPermissionId == 31 {
  1459. sendMobile = utils.ActSendMsgMobile
  1460. }
  1461. //获取销售信息
  1462. sellerItem, err := models.GetSellerByCompanyIdCheckFicc(user.CompanyId, 2)
  1463. if err != nil && err.Error() != utils.ErrNoRow() {
  1464. br.Msg = "提交失败"
  1465. br.ErrMsg = "获取销售信息失败,Err:" + err.Error()
  1466. return
  1467. }
  1468. //给研究员发送消息
  1469. if sendMobile != "" {
  1470. openIpItem, _ := models.GetUserRecordByMobile(4, sendMobile)
  1471. if openIpItem != nil && openIpItem.OpenId != "" {
  1472. if sellerItem != nil {
  1473. services.SendActivityAskApplyTemplateMsgV2(user.RealName+"——"+user.CompanyName+"("+sellerItem.RealName+")", "留言:"+activityInfo.ActivityName, time.Now().Format(utils.FormatDateTime), req.Content, activityInfo.ActivityName, openIpItem, activityInfo, int(msgId))
  1474. }
  1475. }
  1476. }
  1477. // 给所属销售发送消息
  1478. if sellerItem != nil {
  1479. openIpItem, _ := models.GetUserRecordByMobile(4, sellerItem.Mobile)
  1480. if openIpItem != nil && openIpItem.OpenId != "" {
  1481. services.SendActivityAskApplyTemplateMsgV2(user.RealName+"——"+user.CompanyName+"("+sellerItem.RealName+")", "留言:"+activityInfo.ActivityName, time.Now().Format(utils.FormatDateTime), req.Content, activityInfo.ActivityName, openIpItem, activityInfo, int(msgId))
  1482. }
  1483. }
  1484. }
  1485. br.Ret = 200
  1486. br.Success = true
  1487. br.Msg = "提交成功"
  1488. }
  1489. // @Title 更多主题列表(4.3版本)
  1490. // @Description 获取活动更多主题列表接口(4.3版本)
  1491. // @Success 200 {object} models.GetCygxActivityLabelListRep
  1492. // @router /labelMoreList [get]
  1493. func (this *ActivityCoAntroller) LabelMoreList() {
  1494. br := new(models.BaseResponse).Init()
  1495. defer func() {
  1496. this.Data["json"] = br
  1497. this.ServeJSON()
  1498. }()
  1499. user := this.User
  1500. if user == nil {
  1501. br.Msg = "请登录"
  1502. br.ErrMsg = "请登录,SysUser Is Empty"
  1503. return
  1504. }
  1505. userType, permissionStr, err := services.GetUserType(user.CompanyId)
  1506. if err != nil {
  1507. br.Msg = "获取失败"
  1508. br.ErrMsg = "获取失败,Err:" + err.Error()
  1509. return
  1510. }
  1511. var startSize, pageSize int
  1512. pageSize = 24
  1513. var condition string
  1514. var sortTime string
  1515. //var conditionStatus string
  1516. var pars []interface{}
  1517. //活动可见限制
  1518. var sqlExport string
  1519. resp := new(models.GetCygxActivityLabelListRep)
  1520. slicePer := strings.Split(permissionStr, ",")
  1521. var permissionSqlStr string
  1522. for _, v := range slicePer {
  1523. if userType == 1 {
  1524. //if v != "研选" {
  1525. if !strings.Contains(v, "研选") {
  1526. permissionSqlStr += "'" + v + "',"
  1527. }
  1528. } else {
  1529. permissionSqlStr += "'" + v + "',"
  1530. }
  1531. }
  1532. permissionSqlStr = strings.TrimRight(permissionSqlStr, ",")
  1533. permissionSqlStr = strings.Replace(permissionSqlStr, "(主观)", "", -1)
  1534. permissionSqlStr = strings.Replace(permissionSqlStr, "(客观)", "", -1)
  1535. permissionSqlStr = ` AND art.chart_permission_name IN (` + permissionSqlStr + `)`
  1536. sqlExport = ` AND (art.customer_type_ids LIKE '%` + strconv.Itoa(userType) + `%' `
  1537. if userType == 2 {
  1538. sqlExport += ` OR art.customer_type_ids LIKE '%3%' `
  1539. }
  1540. if (userType == 2 || userType == 3) && strings.Contains(permissionStr, "专家") {
  1541. sqlExport += ` OR art.customer_type_ids LIKE '%4%' `
  1542. }
  1543. sqlExport += `) `
  1544. //进行中的活动
  1545. condition = ` AND art.publish_status = 1 AND art.label != '' AND art.active_state = 2 `
  1546. var conditionOr string
  1547. if (userType == 2 || userType == 3 || userType == 4) && strings.Contains(permissionStr, "专家") {
  1548. conditionOr += ` OR ( art.is_limit_people = 1 AND art.customer_type_ids LIKE '%4%' ` + condition + `) `
  1549. }
  1550. if (userType == 5) && strings.Contains(permissionStr, "专家") {
  1551. conditionOr += ` OR ( art.is_limit_people = 1 AND art.customer_type_ids LIKE '%5%' ` + condition + `) `
  1552. }
  1553. if userType == 1 {
  1554. conditionOr += ` OR ( art.is_limit_people = 0 ` + condition + permissionSqlStr + `) `
  1555. } else {
  1556. conditionOr += ` OR ( art.is_limit_people = 0 ` + condition + `) `
  1557. }
  1558. //判断客户规模是否属于可见范围的活动
  1559. companyProduct, err := models.GetCompanyProductDetail(user.CompanyId, 2)
  1560. if err != nil && err.Error() != utils.ErrNoRow() {
  1561. br.Msg = "获取信息失败"
  1562. br.ErrMsg = "获取客户信息失败,Err:" + err.Error()
  1563. return
  1564. }
  1565. if companyProduct != nil {
  1566. if companyProduct.Scale != "" {
  1567. conditionOr += ` OR ( art.scale LIKE '%` + companyProduct.Scale + `%' ` + condition + `) `
  1568. }
  1569. }
  1570. condition += `AND art.is_limit_people = 1 ` + permissionSqlStr + sqlExport + conditionOr
  1571. //进行中的活动
  1572. sortTime = ` mintimesort ASC `
  1573. list, errList := models.GetActivityLabelListAll(condition, sortTime, pars, startSize, pageSize)
  1574. if errList != nil {
  1575. br.Msg = "获取失败"
  1576. br.ErrMsg = "获取失败,Err:" + errList.Error()
  1577. return
  1578. }
  1579. //已结束的活动
  1580. conditionOr = ""
  1581. condition = ` AND art.publish_status = 1 AND art.label != '' AND art.active_state = 3 `
  1582. if (userType == 2 || userType == 3 || userType == 4) && strings.Contains(permissionStr, "专家") {
  1583. conditionOr += ` OR ( art.is_limit_people = 1 AND art.customer_type_ids LIKE '%4%' ` + condition + `) `
  1584. }
  1585. if (userType == 5) && strings.Contains(permissionStr, "专家") {
  1586. conditionOr += ` OR ( art.is_limit_people = 1 AND art.customer_type_ids LIKE '%5%' ` + condition + `) `
  1587. }
  1588. if userType == 1 {
  1589. conditionOr += ` OR ( art.is_limit_people = 0 ` + condition + permissionSqlStr + `) `
  1590. } else {
  1591. conditionOr += ` OR ( art.is_limit_people = 0 ` + condition + `) `
  1592. }
  1593. condition += `AND art.is_limit_people = 1 ` + permissionSqlStr + sqlExport + conditionOr
  1594. startSize = 0
  1595. pageSize = 24 - len(list)
  1596. //已结束的活动
  1597. sortTime = ` timesort DESC `
  1598. listEnd, err := models.GetActivityLabelListAll(condition, sortTime, pars, startSize, pageSize)
  1599. if err != nil {
  1600. br.Msg = "获取失败"
  1601. br.ErrMsg = "获取失败,Err:" + err.Error()
  1602. return
  1603. }
  1604. for _, v := range listEnd {
  1605. list = append(list, v)
  1606. }
  1607. //标签字段关联的产业与标签处理
  1608. for k, v := range list {
  1609. list[k].KeyWord = services.LabelStr(v.KeyWord)
  1610. }
  1611. //添加更多主题访问记录
  1612. item := new(models.CygxPageHistoryRecord)
  1613. item.UserId = user.UserId
  1614. item.CreateTime = time.Now()
  1615. item.Mobile = user.Mobile
  1616. item.Email = user.Email
  1617. item.CompanyId = user.CompanyId
  1618. item.CompanyName = user.CompanyName
  1619. item.PageType = "LabelMore"
  1620. go models.AddCygxPageHistoryRecord(item)
  1621. resp.List = list
  1622. br.Ret = 200
  1623. br.Success = true
  1624. br.Msg = "获取成功"
  1625. br.Data = resp
  1626. }
  1627. // @Title 活动列表(4.3版本)
  1628. // @Description 获取活动列表接口(4.3版本)
  1629. // @Param PageSize query int true "每页数据条数"
  1630. // @Param CurrentIndex query int true "当前页页码,从1开始"
  1631. // @Param Label query string false "搜索主题 多个用 , 隔开"
  1632. // @Param ChartPermissionIds query string false "行业id 多个用 , 隔开"
  1633. // @Param WhichDay query string false "哪一天 1今天、2明天,3本周,4上周,5本月,6上月 多个用 , 隔开"
  1634. // @Param ActiveState query string false "活动进行状态 未开始:1、进行中2、已结束3"
  1635. // @Param ActivityTypeId query string false "活动类型id 多个用 , 隔开"
  1636. // @Param Source query int false "来源 0手机 ,1Pc 默认0"
  1637. // @Param IsPower query int false "是否选择有权限行业 ,1是 0 否 默认0"
  1638. // @Param PlayBack query int false "是否仅展示回放 1:是、0:否 默认0"
  1639. // @Param KeyWord query string false "搜索关键词 多个用 , 隔开"
  1640. // @Param ActivityId query int false "活动列表传过来的活动ID"
  1641. // @Param Filter query int false "筛选条件 0:全部 1:视频 2:音频"
  1642. // @Param TypeName query string false "电话会类型 ,1专家电话会 2分析师电话会"
  1643. // @Param IsExternalLabel query int false "是否仅展示外部资源 1:是、0:否 默认0"
  1644. // @Param IsResearchPoints query string false "是否仅展示研选扣点 1:展示研选扣点、2:展示外部资源 ,1,2两者都展示" //兼容前端
  1645. // @Param IsResearch query bool true "是否为研选"
  1646. // @Success 200 {object} models.GetCygxActivityListRep
  1647. // @router /listNew [get]
  1648. func (this *ActivityCoAntroller) ActivityListNew() {
  1649. br := new(models.BaseResponse).Init()
  1650. defer func() {
  1651. this.Data["json"] = br
  1652. this.ServeJSON()
  1653. }()
  1654. user := this.User
  1655. if user == nil {
  1656. br.Msg = "请登录"
  1657. br.ErrMsg = "请登录,SysUser Is Empty"
  1658. return
  1659. }
  1660. uid := user.UserId
  1661. pageSize, _ := this.GetInt("PageSize")
  1662. currentIndex, _ := this.GetInt("CurrentIndex")
  1663. //source, _ := this.GetInt("Source")
  1664. label := this.GetString("Label")
  1665. chartPermissionIds := this.GetString("ChartPermissionIds")
  1666. whichDay := this.GetString("WhichDay")
  1667. //whichTime := this.GetString("WhichTime")
  1668. activeState := this.GetString("ActiveState")
  1669. activityTypeId := this.GetString("ActivityTypeId")
  1670. keyWord := this.GetString("KeyWord")
  1671. playBack, _ := this.GetInt("PlayBack")
  1672. filter, _ := this.GetInt("Filter")
  1673. isPower, _ := this.GetInt("IsPower")
  1674. activityId, _ := this.GetInt("ActivityId") // 仅用于判断【新】标签
  1675. //isExternalLabel, _ := this.GetInt("IsExternalLabel") //
  1676. isResearchPoints := this.GetString("IsResearchPoints") //
  1677. isResearch, _ := this.GetBool("IsResearch", false) // 是否为研选 查研观向11.0 (研选活动独立显示)
  1678. if label == "undefined" {
  1679. label = ""
  1680. }
  1681. if chartPermissionIds == "undefined" {
  1682. chartPermissionIds = ""
  1683. }
  1684. // 查研观向7.4-始终查询宏观的活动
  1685. if chartPermissionIds != "" {
  1686. chartPermissionIds += ",1"
  1687. }
  1688. if whichDay == "undefined" {
  1689. whichDay = ""
  1690. }
  1691. if activeState == "undefined" {
  1692. activeState = ""
  1693. }
  1694. if activityTypeId == "undefined" {
  1695. activityTypeId = ""
  1696. }
  1697. var startSize int
  1698. if pageSize <= 0 {
  1699. pageSize = utils.PageSize20
  1700. }
  1701. if currentIndex <= 0 {
  1702. currentIndex = 1
  1703. }
  1704. startSize = utils.StartIndex(currentIndex, pageSize)
  1705. //userType, permissionStr, err := services.GetUserType(user.CompanyId)
  1706. var condition string
  1707. var conditioninit string //初始化搜索条件
  1708. var pars []interface{}
  1709. var activityList []*models.ActivityDetail
  1710. mapDingActivityId := make(map[int]int)
  1711. //主题
  1712. if label != "" {
  1713. conditioninit += ` AND art.label LIKE "%` + label + `%" `
  1714. }
  1715. //是否是研选
  1716. if isResearch {
  1717. chartPermissionIds = strconv.Itoa(utils.CHART_PERMISSION_ID_YANXUAN)
  1718. } else {
  1719. 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) + `) )`
  1720. conditioninit += ` AND ( art.chart_permission_id != ` + strconv.Itoa(utils.CHART_PERMISSION_ID_YANXUAN) + ` AND art.active_state != 3 )` // 研选活动结束后就不在已结束页面展示了
  1721. }
  1722. //行业名称
  1723. if len(chartPermissionIds) > 0 {
  1724. conditioninit += ` AND art.chart_permission_id IN (` + chartPermissionIds + `)`
  1725. }
  1726. //哪一天
  1727. if whichDay != "" {
  1728. var startDate string
  1729. var endDate string
  1730. if whichDay == "1" {
  1731. startDate = time.Now().Format(utils.FormatDate)
  1732. endDate = startDate
  1733. } else if whichDay == "2" {
  1734. startDate = time.Now().AddDate(0, 0, +1).Format(utils.FormatDate)
  1735. endDate = startDate
  1736. } else if whichDay == "3" {
  1737. startDate = utils.GetNowWeekMonday().Format(utils.FormatDate)
  1738. endDate = utils.GetNowWeekSunday().Format(utils.FormatDate)
  1739. } else if whichDay == "4" {
  1740. startDate = utils.GetLastWeekMonday().Format(utils.FormatDate)
  1741. endDate = utils.GetLastWeekSunday().Format(utils.FormatDate)
  1742. } else if whichDay == "5" {
  1743. startDate = utils.GetNowMonthFirstDay().Format(utils.FormatDate)
  1744. endDate = utils.GetNowMonthLastDay().Format(utils.FormatDate)
  1745. } else if whichDay == "6" {
  1746. startDate = utils.GetLastMonthFirstDay().Format(utils.FormatDate)
  1747. endDate = utils.GetLastMonthLastDay().Format(utils.FormatDate)
  1748. } else if whichDay == "1,2" {
  1749. startDate = time.Now().Format(utils.FormatDate)
  1750. endDate = time.Now().AddDate(0, 0, +1).Format(utils.FormatDate)
  1751. } else if whichDay == "3,4" {
  1752. startDate = utils.GetLastWeekMonday().Format(utils.FormatDate)
  1753. endDate = utils.GetNowWeekSunday().Format(utils.FormatDate)
  1754. } else if whichDay == "5,6" {
  1755. startDate = utils.GetLastMonthFirstDay().Format(utils.FormatDate)
  1756. endDate = utils.GetNowMonthLastDay().Format(utils.FormatDate)
  1757. } else {
  1758. startDate = time.Now().Format(utils.FormatDate)
  1759. endDate = time.Now().AddDate(0, 0, +1).Format(utils.FormatDate)
  1760. }
  1761. conditioninit += ` AND art.activity_time >= ` + "'" + startDate + " 00:00:00'"
  1762. conditioninit += ` AND art.activity_time <= ` + "'" + endDate + " 23:59:59'"
  1763. }
  1764. //活动状态搜索
  1765. if activeState != "" {
  1766. // 默认查看未开始跟进行中
  1767. if activeState == "1" {
  1768. conditioninit += ` AND art.active_state IN (1,2)`
  1769. } else {
  1770. conditioninit += ` AND art.active_state IN (` + activeState + `)`
  1771. }
  1772. } else {
  1773. conditioninit += ` AND art.active_state IN (1,2)`
  1774. }
  1775. // 如果是分析师电话会,那么可以连同C类一起查看
  1776. if activityTypeId != "" {
  1777. if activityTypeId == strconv.Itoa(utils.ANALYST_TELL_ACTIVITY_TYPE_ID) {
  1778. conditioninit += ` AND art.activity_type_id IN (` + activityTypeId + "," + strconv.Itoa(utils.C_CLASS_ACTIVITY_TYPE_ID) + `)`
  1779. } else {
  1780. conditioninit += ` AND art.activity_type_id IN (` + activityTypeId + `)`
  1781. }
  1782. }
  1783. //关键词搜索
  1784. if keyWord != "" {
  1785. conditioninit += ` AND (art.label REGEXP '` + keyWord + `' OR art.activity_name REGEXP '` + keyWord + `' ) `
  1786. }
  1787. //回放
  1788. if playBack == 1 {
  1789. //获取所有带回放的活动ID
  1790. playBackActivityIds, err := services.GetActivityPlayBackActivityIds()
  1791. if err != nil {
  1792. br.Msg = "获取失败"
  1793. br.ErrMsg = "获取失败,Err:" + err.Error()
  1794. return
  1795. }
  1796. conditioninit += ` AND art.activity_id IN ( ` + playBackActivityIds + `) `
  1797. }
  1798. //音频视频 1:视频 2:音频
  1799. if filter > 0 {
  1800. videoOrVoiceActivityIds, err := services.GetActivityVideoOrVoiceActivityIds(filter)
  1801. if err != nil {
  1802. br.Msg = "获取失败"
  1803. br.ErrMsg = "获取失败,Err:" + err.Error()
  1804. return
  1805. }
  1806. conditioninit += ` AND art.activity_id IN ( ` + videoOrVoiceActivityIds + `) `
  1807. }
  1808. //外部资源,研选扣点的并集搜索
  1809. if isResearchPoints == "1,2" || isResearchPoints == "2,1" {
  1810. conditioninit += ` AND ( art.is_external_label = 1 OR art.is_research_points = 1 )`
  1811. } else {
  1812. // 是否为研选扣点
  1813. if isResearchPoints == "1" {
  1814. conditioninit += ` AND art.is_research_points = 1 `
  1815. }
  1816. //是否为外部资源
  1817. if isResearchPoints == "2" {
  1818. conditioninit += ` AND art.is_external_label = 1 `
  1819. }
  1820. }
  1821. //活动可见限制
  1822. //conditionActivityAll, err := services.GetActivityonditionList(user, activityTypeId, chartPermissionIds, whichDay, activeState, label, 0, source, keyWord, playBack, 3)
  1823. conditionActivity, err := services.ActivityConditioninitSql(user, conditioninit, isPower)
  1824. if err != nil && err.Error() != utils.ErrNoRow() {
  1825. br.Msg = "获取失败"
  1826. br.ErrMsg = "获取活动权限数据失败,Err:" + err.Error()
  1827. return
  1828. }
  1829. condition += ` AND art.publish_status = 1 ` + conditionActivity
  1830. //var conditionCount string
  1831. //conditionCount = condition + conditionActivityAll
  1832. total, err := models.GetActivityCount(condition, playBack, pars, filter)
  1833. if err != nil {
  1834. br.Msg = "获取失败"
  1835. br.ErrMsg = "获取失败,Err:" + err.Error()
  1836. return
  1837. }
  1838. //搜索关键词初始化
  1839. //conditionActivityKey, err := services.GetActivityonditionList(user, activityTypeId, chartPermissionIds, whichDay, activeState, label, 0, source, keyWord, playBack, 1)
  1840. //if err != nil && err.Error() != utils.ErrNoRow() {
  1841. // br.Msg = "获取失败"
  1842. // br.ErrMsg = "获取失败,Err:" + err.Error()
  1843. // return
  1844. //}
  1845. var conditionOrder string
  1846. if activeState == "2" || activeState == "3" {
  1847. conditionOrder = ` ORDER BY art.activity_time DESC `
  1848. } else if activeState == "2,3" {
  1849. conditionOrder = ` ORDER BY art.active_state ASC, art.activity_time DESC `
  1850. } else {
  1851. conditionOrder = ` ORDER BY art.activity_time DESC , art.active_state ASC `
  1852. }
  1853. if label != "" && activeState == "1" {
  1854. conditionOrder = ` ORDER BY art.activity_time ASC `
  1855. }
  1856. //未开始进行中默认按照时间正序
  1857. if activeState == "1" || activeState == "1,2" || activeState == "" {
  1858. conditionOrder = ` ORDER BY art.activity_time ASC `
  1859. }
  1860. //conditionActivityKey += condition + conditionOrder
  1861. condition += conditionOrder
  1862. //fmt.Println(conditionOrder)
  1863. list, errList := models.GetActivityListNew(condition, pars, uid, startSize, pageSize, playBack, filter, "")
  1864. if errList != nil {
  1865. br.Msg = "获取失败"
  1866. br.ErrMsg = "获取失败,Err:" + errList.Error()
  1867. return
  1868. }
  1869. var isShow bool
  1870. isShow = services.GetShowSustainable()
  1871. detail, err := models.GetConfigByCode("city_img_url")
  1872. if err != nil {
  1873. br.Msg = "获取数据失败"
  1874. br.ErrMsg = "城市配置信息失败,Err:" + err.Error()
  1875. return
  1876. }
  1877. detailChart, err := models.GetConfigByCode("chart_img_url")
  1878. if err != nil {
  1879. br.Msg = "获取数据失败"
  1880. br.ErrMsg = "行业配置信息失败,Err:" + err.Error()
  1881. return
  1882. }
  1883. addressList := strings.Split(detail.ConfigValue, "{|}")
  1884. mapAddress := make(map[string]string)
  1885. chartList := strings.Split(detailChart.ConfigValue, "{|}")
  1886. mapChart := make(map[string]string)
  1887. var cityName string
  1888. var chartName string
  1889. var imgUrl string
  1890. var imgUrlChart string
  1891. var mapActivityId []int
  1892. for _, v := range addressList {
  1893. vslice := strings.Split(v, "_")
  1894. cityName = vslice[0]
  1895. imgUrl = vslice[len(vslice)-1]
  1896. mapAddress[cityName] = imgUrl
  1897. }
  1898. for _, v := range chartList {
  1899. vslice := strings.Split(v, "_")
  1900. chartName = vslice[0]
  1901. imgUrlChart = vslice[len(vslice)-1]
  1902. mapChart[chartName] = imgUrlChart
  1903. }
  1904. for k, v := range list {
  1905. if strings.Contains(v.ActivityName, "【") {
  1906. list[k].IsBrackets = 1
  1907. }
  1908. if v.SignupNum > v.LimitPeopleNum {
  1909. list[k].SignupNum = v.LimitPeopleNum
  1910. }
  1911. if isShow && strings.Contains(v.ChartPermissionName, "研选") {
  1912. list[k].IsShowSustainable = true
  1913. }
  1914. if strings.Contains(v.ChartPermissionName, "研选") && v.ActivityTypeId == 1 {
  1915. list[k].ActivityTypeName = "买方研选电话会"
  1916. //list[k].ImgUrlText = "https://hongze.oss-cn-shanghai.aliyuncs.com/static/images/202112/20211221/bIdfv8t86xrFRpDOeGGHXOmKEuKl.png"
  1917. list[k].ImgUrlText = utils.YAN_XUAN_IMG
  1918. }
  1919. if v.ActivityType == 0 {
  1920. if mapAddress[v.City] != "" {
  1921. list[k].ImgUrl = mapAddress[v.City]
  1922. } else {
  1923. list[k].ImgUrl = mapAddress["其它"]
  1924. }
  1925. } else {
  1926. if mapChart[v.ChartPermissionName] != "" {
  1927. list[k].ImgUrl = mapChart[v.ChartPermissionName]
  1928. }
  1929. }
  1930. expertTxt, _ := services.GetReportContentTextSub(v.Expert)
  1931. list[k].Expert = expertTxt
  1932. if v.IsHideAppointment == 0 {
  1933. list[k].IsShowAppointment = services.IsShowAppointment(v.ActivityTypeId, v.ChartPermissionName)
  1934. }
  1935. if v.ActivityTypeId == utils.C_CLASS_ACTIVITY_TYPE_ID {
  1936. list[k].IsCClassMeeting = true
  1937. }
  1938. mapActivityId = append(mapActivityId, v.ActivityId)
  1939. }
  1940. page := paging.GetPaging(currentIndex, pageSize, total)
  1941. resp := new(models.GetCygxActivityListRep)
  1942. resp.Label = label
  1943. if activityTypeId != "" {
  1944. activityTypeIdint, err := strconv.Atoi(activityTypeId)
  1945. if err == nil {
  1946. detail, errDetail := models.GetActivityTypeDetailById(activityTypeIdint)
  1947. if errDetail != nil {
  1948. br.Msg = "获取信息失败"
  1949. br.ErrMsg = "获取信息失败,Err:" + errDetail.Error()
  1950. return
  1951. }
  1952. resp.ImgUrl = detail.OnlineIco
  1953. resp.Label = detail.ActivityTypeName
  1954. }
  1955. }
  1956. //处理音频回放
  1957. mapActivityVoice, err := services.GetActivityVoiceResp(mapActivityId)
  1958. if err != nil {
  1959. br.Msg = "获取信息失败"
  1960. br.ErrMsg = "GetActivityVoiceResp,Err:" + err.Error()
  1961. return
  1962. }
  1963. //处理视频回放
  1964. mapActivityVideo, err := services.GetActivityVideoResp(mapActivityId)
  1965. if err != nil {
  1966. br.Msg = "获取信息失败"
  1967. br.ErrMsg = "GetActivityVideoResp,Err:" + err.Error()
  1968. return
  1969. }
  1970. //处理不同的报名方式按钮回显
  1971. mapActivitySignup, err := services.GetActivitySignupResp(mapActivityId, user)
  1972. if err != nil {
  1973. br.Msg = "获取信息失败"
  1974. br.ErrMsg = "GetActivitySignupResp,Err:" + err.Error()
  1975. return
  1976. }
  1977. for _, v := range list {
  1978. if mapDingActivityId[v.ActivityId] == 0 {
  1979. activityList = append(activityList, v)
  1980. }
  1981. v.SignupType = mapActivitySignup[v.ActivityId]
  1982. }
  1983. for k, v := range activityList {
  1984. if mapActivityVoice[v.ActivityId] != nil {
  1985. list[k].FileType = 1
  1986. list[k].AudioLink = true
  1987. list[k].VoiceList = mapActivityVoice[v.ActivityId]
  1988. }
  1989. if mapActivityVideo[v.ActivityId] != nil {
  1990. list[k].FileType = 2
  1991. list[k].AudioLink = true
  1992. list[k].VideoDetail = mapActivityVideo[v.ActivityId]
  1993. }
  1994. resp.List = append(resp.List, services.ActivityButtonShow(v))
  1995. }
  1996. // 查研观向7.4-判断标签是否为产业, 为产业时是否跳转资源包
  1997. if label != "" {
  1998. industry, e := models.GetIndustryByName(label)
  1999. if e != nil && e.Error() != utils.ErrNoRow() {
  2000. br.Msg = "获取信息失败"
  2001. br.ErrMsg = "获取标签产业失败, Err:" + e.Error()
  2002. return
  2003. }
  2004. if industry != nil {
  2005. sourceIndustry, e := models.GetSourceIndustryByName(label)
  2006. if e != nil && e.Error() != utils.ErrNoRow() {
  2007. br.Msg = "获取信息失败"
  2008. br.ErrMsg = "获取标签产业资源包失败, Err:" + e.Error()
  2009. return
  2010. }
  2011. if sourceIndustry != nil {
  2012. resp.IndustrialManagementId = sourceIndustry.IndustrialManagementId
  2013. resp.IsJump = true
  2014. // 研选产业不跳资源包
  2015. if sourceIndustry.ChartPermissionId == utils.CHART_PERMISSION_ID_YANXUAN {
  2016. resp.IsJump = false
  2017. }
  2018. }
  2019. }
  2020. // 新标签
  2021. if activityId > 0 {
  2022. activityIds := []int{activityId}
  2023. activityNewMap, _, e := services.GetActivityNewLabelMap(activityIds)
  2024. if e != nil {
  2025. br.Msg = "获取信息失败"
  2026. br.ErrMsg = "获取活动新标签失败, Err: " + e.Error()
  2027. return
  2028. }
  2029. resp.IndustryNewLabel = activityNewMap[activityId]
  2030. }
  2031. }
  2032. //添加活动搜索记录
  2033. //if keyWord != "" {
  2034. // go services.AddActivitykeyWordSearch(keyWord, user)
  2035. //}
  2036. if activityTypeId == "3" || activityTypeId == "5" {
  2037. resp.IsShowResearchPoints = true
  2038. }
  2039. resp.Paging = page
  2040. br.Ret = 200
  2041. br.Success = true
  2042. br.Msg = "获取成功"
  2043. br.Data = resp
  2044. }
  2045. // @Title 校验活动带问是否有权限
  2046. // @Description 校验活动带问是否有权限接口
  2047. // @Param request body models.ActivityIdRep true "type json string"
  2048. // @Success Ret=200 {object} models.SignupStatus
  2049. // @router /checkAsk [post]
  2050. func (this *ActivityCoAntroller) CheckAsk() {
  2051. br := new(models.BaseResponse).Init()
  2052. defer func() {
  2053. this.Data["json"] = br
  2054. this.ServeJSON()
  2055. }()
  2056. user := this.User
  2057. if user == nil {
  2058. br.Msg = "请登录"
  2059. br.ErrMsg = "请登录,用户信息为空"
  2060. br.Ret = 408
  2061. return
  2062. }
  2063. var signupStatus string
  2064. var req models.ActivityIdRep
  2065. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  2066. if err != nil {
  2067. br.Msg = "参数解析异常!"
  2068. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  2069. return
  2070. }
  2071. activityId := req.ActivityId
  2072. activityInfo, errInfo := models.GetAddActivityInfoById(activityId)
  2073. if activityInfo == nil {
  2074. br.Msg = "操作失败"
  2075. br.ErrMsg = "活动ID错误,不存在activityId:" + strconv.Itoa(activityId)
  2076. return
  2077. }
  2078. if errInfo != nil {
  2079. br.Msg = "操作失败"
  2080. br.ErrMsg = "操作失败,Err:" + errInfo.Error()
  2081. return
  2082. }
  2083. resp := new(models.SignupStatus)
  2084. hasPermission := 0
  2085. havePower, isResearchSpecial, err := services.GetActivityDetailUserPower(user, activityInfo)
  2086. if err != nil {
  2087. br.Msg = "获取信息失败"
  2088. br.ErrMsg = "校验用户权限失败,Err:" + err.Error()
  2089. return
  2090. }
  2091. resp.IsResearchSpecial = isResearchSpecial
  2092. if havePower {
  2093. hasPermission = 1
  2094. signupStatus = "Success"
  2095. resp.HaqveJurisdiction = true
  2096. resp.HasPermission = hasPermission
  2097. resp.SignupStatus = signupStatus
  2098. } else {
  2099. hasPermission, sellerName, sellerMobile, popupMsg, err := services.GetUserHasPermissionActivity(user, activityInfo)
  2100. if err != nil {
  2101. br.Msg = "获取信息失败"
  2102. br.ErrMsg = "判断是否已申请过试用失败,Err:" + err.Error()
  2103. return
  2104. }
  2105. resp.PopupMsg = popupMsg
  2106. resp.HasPermission = hasPermission
  2107. resp.SellerName = sellerName
  2108. resp.SellerMobile = sellerMobile
  2109. }
  2110. // 判断是否属于研选类型的活动
  2111. if strings.Contains(activityInfo.ChartPermissionName, utils.CHART_PERMISSION_NAME_YANXUAN) {
  2112. resp.IsResearch = true
  2113. }
  2114. resp.ActivityId = activityId
  2115. br.Ret = 200
  2116. br.Success = true
  2117. br.Data = resp
  2118. }
  2119. // @Title 活动类型下的主题列表(5.3版本)
  2120. // @Description 获取活动类型下的主题列表接口(5.3版本)
  2121. // @Param ChartPermissionIds query string false "行业id 多个用 , 隔开"
  2122. // @Param ActivityTypeIds query string false "活动类型id 多个用 , 隔开"
  2123. // @Param ActiveState query string false "活动进行状态 未开始:1、进行中2、已结束3"
  2124. // @Param WhichDay query string false "哪一天 今天:1、明天:2,多个用 , 隔开"
  2125. // @Param WhichWeek query string false "哪一周 本周:1 上周:2"
  2126. // @Param WhichMonth query string false "哪一月 本月:1 上月:2"
  2127. // @Param WhichMonth query string false "哪一月 本月:1 上月:2"
  2128. // @Param IsPower query int false "是否选择有权限行业 ,1是 0 否 默认0"
  2129. // @Param IsResearch query bool true "是否为研选"
  2130. // @Success 200 {object} models.ActivityTypeListHomeResp
  2131. // @router /labelTypeListV5 [get]
  2132. func (this *ActivityCoAntroller) LabelTypeListV5() {
  2133. br := new(models.BaseResponse).Init()
  2134. defer func() {
  2135. this.Data["json"] = br
  2136. this.ServeJSON()
  2137. }()
  2138. user := this.User
  2139. if user == nil {
  2140. br.Msg = "请登录"
  2141. br.ErrMsg = "请登录,SysUser Is Empty"
  2142. return
  2143. }
  2144. pageSize, _ := this.GetInt("PageSize")
  2145. isPower, _ := this.GetInt("IsPower")
  2146. chartPermissionIds := this.GetString("ChartPermissionIds")
  2147. whichDay := this.GetString("WhichDay")
  2148. activeState := this.GetString("ActiveState")
  2149. isResearch, _ := this.GetBool("IsResearch", false) // 是否为研选 查研观向11.0 (研选活动独立显示)
  2150. //入参为 undefined 时的处理
  2151. if chartPermissionIds == "undefined" {
  2152. chartPermissionIds = ""
  2153. }
  2154. if whichDay == "undefined" {
  2155. whichDay = ""
  2156. }
  2157. if activeState == "undefined" || activeState == "" {
  2158. activeState = "1"
  2159. }
  2160. // 查研观向7.4-始终查询宏观的活动
  2161. if chartPermissionIds != "" {
  2162. chartPermissionIds += ",1"
  2163. }
  2164. userType, _, err := services.GetUserType(user.CompanyId)
  2165. if err != nil {
  2166. br.Msg = "获取失败"
  2167. br.ErrMsg = "获取失败,Err:" + err.Error()
  2168. return
  2169. }
  2170. var startSize int
  2171. pageSize = 1000
  2172. var sortTime string
  2173. var conditioninit string
  2174. var pars []interface{}
  2175. //活动可见限制
  2176. permissionZhengShiStr, err := models.GetCompanyPermissionByUserZhengShi(user.CompanyId)
  2177. if err != nil {
  2178. br.Msg = "获取失败"
  2179. br.ErrMsg = "获取失败,Err:" + err.Error()
  2180. return
  2181. }
  2182. slicePer := strings.Split(permissionZhengShiStr, ",")
  2183. //var permissionSqlStr string
  2184. var permissionNameStr string
  2185. for _, v := range slicePer {
  2186. if userType == 1 {
  2187. //if v != "研选" {
  2188. if !strings.Contains(v, "研选") {
  2189. permissionNameStr += "'" + v + "',"
  2190. }
  2191. } else {
  2192. permissionNameStr += "'" + v + "',"
  2193. }
  2194. }
  2195. permissionNameStr = strings.Replace(permissionNameStr, "(主观)", "", -1)
  2196. permissionNameStr = strings.Replace(permissionNameStr, "(客观)", "", -1)
  2197. permissionNameStr = strings.TrimRight(permissionNameStr, ",")
  2198. if isResearch {
  2199. chartPermissionIds = strconv.Itoa(utils.CHART_PERMISSION_ID_YANXUAN)
  2200. } else {
  2201. 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) + `') )`
  2202. }
  2203. //行业名称
  2204. if len(chartPermissionIds) > 0 {
  2205. conditioninit += ` AND art.chart_permission_id IN (` + chartPermissionIds + `)`
  2206. }
  2207. //哪一天
  2208. if whichDay != "" {
  2209. var startDate string
  2210. var endDate string
  2211. if whichDay == "1" {
  2212. startDate = time.Now().Format(utils.FormatDate)
  2213. endDate = startDate
  2214. } else if whichDay == "2" {
  2215. startDate = time.Now().AddDate(0, 0, +1).Format(utils.FormatDate)
  2216. endDate = startDate
  2217. } else if whichDay == "3" {
  2218. startDate = utils.GetNowWeekMonday().Format(utils.FormatDate)
  2219. endDate = utils.GetNowWeekSunday().Format(utils.FormatDate)
  2220. } else if whichDay == "4" {
  2221. startDate = utils.GetLastWeekMonday().Format(utils.FormatDate)
  2222. endDate = utils.GetLastWeekSunday().Format(utils.FormatDate)
  2223. } else if whichDay == "5" {
  2224. startDate = utils.GetNowMonthFirstDay().Format(utils.FormatDate)
  2225. endDate = utils.GetNowMonthLastDay().Format(utils.FormatDate)
  2226. } else if whichDay == "6" {
  2227. startDate = utils.GetLastMonthFirstDay().Format(utils.FormatDate)
  2228. endDate = utils.GetLastMonthLastDay().Format(utils.FormatDate)
  2229. } else if whichDay == "1,2" {
  2230. startDate = time.Now().Format(utils.FormatDate)
  2231. endDate = time.Now().AddDate(0, 0, +1).Format(utils.FormatDate)
  2232. } else if whichDay == "3,4" {
  2233. startDate = utils.GetLastWeekMonday().Format(utils.FormatDate)
  2234. endDate = utils.GetNowWeekSunday().Format(utils.FormatDate)
  2235. } else if whichDay == "5,6" {
  2236. startDate = utils.GetLastMonthFirstDay().Format(utils.FormatDate)
  2237. endDate = utils.GetNowMonthLastDay().Format(utils.FormatDate)
  2238. } else {
  2239. startDate = time.Now().Format(utils.FormatDate)
  2240. endDate = time.Now().AddDate(0, 0, +1).Format(utils.FormatDate)
  2241. }
  2242. conditioninit += ` AND art.activity_time >= ` + "'" + startDate + " 00:00:00'"
  2243. conditioninit += ` AND art.activity_time <= ` + "'" + endDate + " 23:59:59'"
  2244. }
  2245. //活动状态搜索
  2246. if activeState != "" {
  2247. // 默认查看未开始跟进行中
  2248. if activeState == "1" {
  2249. conditioninit += ` AND art.active_state IN (1,2)`
  2250. } else {
  2251. conditioninit += ` AND art.active_state IN (` + activeState + `)`
  2252. }
  2253. } else {
  2254. conditioninit += ` AND art.active_state IN (1,2)`
  2255. }
  2256. var condition string
  2257. //conditionActivity, err := services.GetActivityonditionList(user, "", chartPermissionIds, whichDay, activeState, "", isPower, 0, "", 0, 1)
  2258. conditionActivity, err := services.ActivityConditioninitSql(user, conditioninit, isPower)
  2259. if err != nil && err.Error() != utils.ErrNoRow() {
  2260. br.Msg = "获取失败"
  2261. br.ErrMsg = "获取活动权限数据失败,Err:" + err.Error()
  2262. return
  2263. }
  2264. //condition += `AND art.is_limit_people = 1 ` + conditionActivity
  2265. condition += conditionActivity
  2266. sortTime = ` mintimesort ASC `
  2267. listActivity, err := models.GetActivityLabelListAll(condition, sortTime, pars, startSize, pageSize)
  2268. if err != nil {
  2269. br.Msg = "获取失败"
  2270. br.ErrMsg = "获取失败,Err:" + err.Error()
  2271. return
  2272. }
  2273. mapCity, err := services.GetActivityCityResp()
  2274. if err != nil {
  2275. br.Msg = "获取失败"
  2276. br.ErrMsg = "获取数据失败,Err:" + err.Error()
  2277. return
  2278. }
  2279. mapActivity := make(map[int][]*models.CygxActivityLabelList)
  2280. mapkeyWord := make(map[string]string)
  2281. activityPointsByUserAllMap := services.GetActivityPointsByUserAllMap() // 获取对用户进行研选扣点的活动
  2282. for _, v := range listActivity {
  2283. if v.KeyWord == "" {
  2284. continue
  2285. }
  2286. // 如果是C类电话会就不展示内容,且合并到分析师电话会
  2287. if v.ActivityTypeId == 7 {
  2288. v.ActivityTypeId = 2
  2289. }
  2290. item := new(models.CygxActivityLabelList)
  2291. item.IsResearchPoints = activityPointsByUserAllMap[v.ActivityId]
  2292. item.City = mapCity[fmt.Sprint(v.KeyWord, "{|}", v.ActivityTypeId)]
  2293. item.KeyWord = services.LabelStrV5(v.KeyWord, v.IsShowSubjectName, v.TemporaryLabel)
  2294. if _, ok := mapkeyWord[fmt.Sprint(v.ActivityTypeId, "-", item.KeyWord)]; ok {
  2295. continue
  2296. }
  2297. item.Resource = 1
  2298. item.ActivityId = v.ActivityId
  2299. if v.ChartPermissionId == utils.CHART_PERMISSION_ID_YANXUAN {
  2300. item.IsResearch = true
  2301. }
  2302. item.IsExternalLabel = v.IsExternalLabel
  2303. mapActivity[v.ActivityTypeId] = append(mapActivity[v.ActivityTypeId], item)
  2304. mapkeyWord[fmt.Sprint(v.ActivityTypeId, "-", item.KeyWord)] = item.KeyWord
  2305. }
  2306. //
  2307. var conditionType string
  2308. var parsType []interface{}
  2309. if isResearch {
  2310. conditionType = " AND source_type IN (0,2) "
  2311. } else {
  2312. conditionType = " AND source_type IN (0,1) "
  2313. }
  2314. list, err := models.GetActivityTypeHomeList(conditionType, parsType)
  2315. if err != nil {
  2316. br.Msg = "获取失败"
  2317. br.ErrMsg = "获取数据失败,Err:" + err.Error()
  2318. return
  2319. }
  2320. resp := new(models.ActivityTypeListHomeResp)
  2321. for k, v := range list {
  2322. if len(mapActivity[v.ActivityTypeId]) > 0 {
  2323. for _, v2 := range mapActivity[v.ActivityTypeId] {
  2324. v2.ImgUrlBg = v.ImgUrlBgs
  2325. }
  2326. }
  2327. list[k].List = mapActivity[v.ActivityTypeId]
  2328. list[k].Resource = 1
  2329. }
  2330. //获取对应活动的数量并排序
  2331. activityIds := make([]int, 0) // 用于查询活动【新】标签Map
  2332. intArr := make([]int, 0)
  2333. var items []*models.ActivityTypeHome
  2334. for _, v := range list {
  2335. item := new(models.ActivityTypeHome)
  2336. if len(v.List) > 0 {
  2337. for i := range v.List {
  2338. activityIds = append(activityIds, v.List[i].ActivityId)
  2339. }
  2340. item.List = v.List
  2341. item.ActivityTypeName = v.ActivityTypeName
  2342. item.ActivityTypeId = v.ActivityTypeId
  2343. item.ImgUrlBg = v.ImgUrlBg
  2344. item.ImgUrl = v.ImgUrl
  2345. item.Resource = v.Resource
  2346. items = append(items, item)
  2347. intArr = append(intArr, len(v.List))
  2348. }
  2349. }
  2350. sort.Sort(sort.Reverse(sort.IntSlice(intArr)))
  2351. // 活动【新】标签Map
  2352. newLabelMap, _, e := services.GetActivityNewLabelMap(activityIds)
  2353. if e != nil {
  2354. br.Msg = "获取失败"
  2355. br.ErrMsg = "获取活动【新】标签Map失败, Err: " + e.Error()
  2356. return
  2357. }
  2358. for k, _ := range list {
  2359. for k2 := range list[k].List {
  2360. list[k].List[k2].IsNew = newLabelMap[list[k].List[k2].ActivityId]
  2361. }
  2362. }
  2363. var itemsNew []*models.ActivityTypeHome
  2364. activityMap := make(map[int]int)
  2365. for _, v := range intArr {
  2366. for _, v2 := range items {
  2367. item := new(models.ActivityTypeHome)
  2368. if len(v2.List) > 0 && v == len(v2.List) && activityMap[v2.ActivityTypeId] == 0 {
  2369. item.List = v2.List
  2370. item.ActivityTypeName = v2.ActivityTypeName
  2371. item.ActivityTypeId = v2.ActivityTypeId
  2372. item.ImgUrlBg = v2.ImgUrlBg
  2373. item.ImgUrl = v2.ImgUrl
  2374. item.Resource = v2.Resource
  2375. itemsNew = append(itemsNew, item)
  2376. activityMap[v2.ActivityTypeId] = len(v2.List)
  2377. }
  2378. }
  2379. }
  2380. var lenList int
  2381. //按照像素进行排序
  2382. rowHeight := 83 //每一行的行高
  2383. basicsHeight := 178 // 基础高度
  2384. position := 1 // 初始化位置 ,1,左边, 2 右边
  2385. var leftPx, rightPx int
  2386. for k, v := range itemsNew {
  2387. if leftPx <= rightPx {
  2388. position = 1
  2389. } else {
  2390. position = 2
  2391. }
  2392. itemsNew[k].Position = position
  2393. lenList = len(v.List)
  2394. if lenList > 8 {
  2395. lenList = 8
  2396. }
  2397. if position == 1 {
  2398. leftPx += basicsHeight + rowHeight*lenList
  2399. if lenList > 8 {
  2400. lenList = leftPx - 41
  2401. }
  2402. } else {
  2403. rightPx += basicsHeight + rowHeight*lenList
  2404. if lenList > 8 {
  2405. lenList = leftPx - 41
  2406. }
  2407. }
  2408. }
  2409. //研选互动不展示专项产业调研
  2410. if !isResearch {
  2411. //查询专项产业调研展示权限 仅对大套餐客户跟永续客户展示
  2412. if whichDay == "" {
  2413. speciaItem, err := services.GetActivityLabelSpecialList(user, isPower, chartPermissionIds, permissionNameStr)
  2414. if err != nil {
  2415. br.Msg = "获取失败"
  2416. br.ErrMsg = "获取失败,Err:" + err.Error()
  2417. return
  2418. }
  2419. if leftPx > rightPx {
  2420. speciaItem.Position = 2
  2421. } else {
  2422. speciaItem.Position = 1
  2423. }
  2424. if len(speciaItem.List) > 0 {
  2425. itemsNew = append(itemsNew, speciaItem)
  2426. }
  2427. }
  2428. }
  2429. //记录用户搜索的筛选条件
  2430. item := new(models.CygxActivitySearchHistory)
  2431. item.UserId = user.UserId
  2432. item.Mobile = user.Mobile
  2433. item.CompanyId = user.CompanyId
  2434. item.CompanyName = user.CompanyName
  2435. item.CreateTime = time.Now()
  2436. item.ChartPermissionIds = chartPermissionIds
  2437. item.IsPower = isPower
  2438. item.WhichDay = whichDay
  2439. go models.AddCygxActivitySearchHistory(item)
  2440. resp.List = itemsNew
  2441. br.Ret = 200
  2442. br.Success = true
  2443. br.Msg = "获取成功"
  2444. br.Data = resp
  2445. }
  2446. // @Title 专项产业调研列表
  2447. // @Description 获取专项产业调研列表接口
  2448. // @Param PageSize query int true "每页数据条数"
  2449. // @Param CurrentIndex query int true "当前页页码,从1开始"
  2450. // @Success 200 {object} models.GetCygxActivitySpecialDetailListResp
  2451. // @router /special/del_list [get]
  2452. func (this *ActivityCoAntroller) SpecialList() {
  2453. br := new(models.BaseResponse).Init()
  2454. defer func() {
  2455. this.Data["json"] = br
  2456. this.ServeJSON()
  2457. }()
  2458. user := this.User
  2459. if user == nil {
  2460. br.Msg = "请登录"
  2461. br.ErrMsg = "请登录,SysUser Is Empty"
  2462. return
  2463. }
  2464. uid := user.UserId
  2465. pageSize, _ := this.GetInt("PageSize")
  2466. currentIndex, _ := this.GetInt("CurrentIndex")
  2467. userType, permissionStr, err := services.GetUserType(user.CompanyId)
  2468. var startSize int
  2469. if pageSize <= 0 {
  2470. pageSize = utils.PageSize20
  2471. }
  2472. if currentIndex <= 0 {
  2473. currentIndex = 1
  2474. }
  2475. startSize = utils.StartIndex(currentIndex, pageSize)
  2476. var condition string
  2477. var pars []interface{}
  2478. //活动可见限制
  2479. var sqlExport string
  2480. slicePer := strings.Split(permissionStr, ",")
  2481. var permissionSqlStr string
  2482. for _, v := range slicePer {
  2483. if userType == 1 {
  2484. //if v != "研选" {
  2485. if !strings.Contains(v, "研选") {
  2486. permissionSqlStr += "'" + v + "',"
  2487. }
  2488. } else {
  2489. permissionSqlStr += "'" + v + "',"
  2490. }
  2491. }
  2492. //判断客户规模是否属于可见范围的活动
  2493. companyProduct, err := models.GetCompanyProductDetail(user.CompanyId, 2)
  2494. if err != nil && err.Error() != utils.ErrNoRow() {
  2495. br.Msg = "获取信息失败"
  2496. br.ErrMsg = "获取客户信息失败,Err:" + err.Error()
  2497. return
  2498. }
  2499. permissionSqlStr = strings.TrimRight(permissionSqlStr, ",")
  2500. permissionSqlStr = strings.Replace(permissionSqlStr, "(主观)", "", -1)
  2501. permissionSqlStr = strings.Replace(permissionSqlStr, "(客观)", "", -1)
  2502. permissionSqlStr = ` AND art.chart_permission_name IN (` + permissionSqlStr + `)`
  2503. sqlExport = ` AND (art.customer_type_ids LIKE '%` + strconv.Itoa(userType) + `%' `
  2504. if userType == 2 {
  2505. sqlExport += ` OR art.customer_type_ids LIKE '%3%' `
  2506. }
  2507. if (userType == 2 || userType == 3) && strings.Contains(permissionStr, "专家") {
  2508. sqlExport += ` OR art.customer_type_ids LIKE '%4%' `
  2509. }
  2510. sqlExport += `) `
  2511. condition += ` AND art.publish_status = 1 `
  2512. condition = ` AND art.publish_status = 1 AND art.label != '' `
  2513. var conditionOr string
  2514. if (userType == 2 || userType == 3 || userType == 4) && strings.Contains(permissionStr, "专家") {
  2515. conditionOr += ` OR (1=1 AND art.customer_type_ids LIKE '%4%' ` + condition + `) `
  2516. }
  2517. if (userType == 5) && strings.Contains(permissionStr, "专家") {
  2518. conditionOr += ` OR (1=1 AND art.customer_type_ids LIKE '%5%' ` + condition + `) `
  2519. }
  2520. if userType == 1 {
  2521. conditionOr += ` OR ( 1=1` + condition + permissionSqlStr + `) `
  2522. }
  2523. if companyProduct != nil {
  2524. if companyProduct.Scale != "" {
  2525. conditionOr += ` OR ( art.scale LIKE '%` + companyProduct.Scale + `%' ` + condition + `) `
  2526. }
  2527. }
  2528. if companyProduct != nil {
  2529. if companyProduct.Scale != "" {
  2530. conditionOr += ` OR ( art.scale LIKE '%` + companyProduct.Scale + `%' ` + condition + `) `
  2531. }
  2532. }
  2533. condition += sqlExport + conditionOr
  2534. total, err := models.GetActivitySpecialCount(condition, pars)
  2535. if err != nil {
  2536. br.Msg = "获取失败"
  2537. br.ErrMsg = "获取失败,Err:" + err.Error()
  2538. return
  2539. }
  2540. list, errList := models.GetCygxActivitySpecialDetailList(condition, pars, uid, startSize, pageSize)
  2541. if errList != nil {
  2542. br.Msg = "获取失败"
  2543. br.ErrMsg = "获取失败,Err:" + errList.Error()
  2544. return
  2545. }
  2546. detail, err := models.GetConfigByCode("city_img_url")
  2547. if err != nil {
  2548. br.Msg = "获取数据失败"
  2549. br.ErrMsg = "城市配置信息失败,Err:" + err.Error()
  2550. return
  2551. }
  2552. detailChart, err := models.GetConfigByCode("chart_img_url")
  2553. if err != nil {
  2554. br.Msg = "获取数据失败"
  2555. br.ErrMsg = "行业配置信息失败,Err:" + err.Error()
  2556. return
  2557. }
  2558. addressList := strings.Split(detail.ConfigValue, "{|}")
  2559. mapAddress := make(map[string]string)
  2560. chartList := strings.Split(detailChart.ConfigValue, "{|}")
  2561. mapChart := make(map[string]string)
  2562. var cityName string
  2563. var chartName string
  2564. var imgUrl string
  2565. var imgUrlChart string
  2566. for _, v := range addressList {
  2567. vslice := strings.Split(v, "_")
  2568. cityName = vslice[0]
  2569. imgUrl = vslice[len(vslice)-1]
  2570. mapAddress[cityName] = imgUrl
  2571. }
  2572. for _, v := range chartList {
  2573. vslice := strings.Split(v, "_")
  2574. chartName = vslice[0]
  2575. imgUrlChart = vslice[len(vslice)-1]
  2576. mapChart[chartName] = imgUrlChart
  2577. }
  2578. for k, v := range list {
  2579. list[k].ImgUrlText = "https://hongze.oss-cn-shanghai.aliyuncs.com/static/images/202112/20211221/bIdfv8t86xrFRpDOeGGHXOmKEuKl.png"
  2580. if mapChart[v.ChartPermissionName] != "" {
  2581. list[k].ImgUrl = mapChart[v.ChartPermissionName]
  2582. }
  2583. list[k].ActivityTypeName = "专项调研"
  2584. }
  2585. page := paging.GetPaging(currentIndex, pageSize, total)
  2586. resp := new(models.GetCygxActivitySpecialDetailListResp)
  2587. count, err := models.GetCygxUserFollowSpecial(user.UserId)
  2588. if err != nil {
  2589. br.Msg = "获取数据失败!"
  2590. br.ErrMsg = "获取客户详情失败,Err:" + err.Error()
  2591. return
  2592. }
  2593. if count == 1 && user.UserId > 0 {
  2594. resp.IsFollow = true
  2595. }
  2596. if user.Mobile != "" {
  2597. resp.IsBindingMobile = true
  2598. }
  2599. resp.List = list
  2600. resp.Paging = page
  2601. br.Ret = 200
  2602. br.Success = true
  2603. br.Msg = "获取成功"
  2604. br.Data = resp
  2605. }
  2606. // @Title 专项产业调研详情
  2607. // @Description 获取专项产业调研详情接口
  2608. // @Param ActivityId query int true "活动ID"
  2609. // @Success Ret=200 {object} models.CygxActivitySpecialResp
  2610. // @router /special/detail [get]
  2611. func (this *ActivityCoAntroller) SpecialDetail() {
  2612. br := new(models.BaseResponse).Init()
  2613. defer func() {
  2614. this.Data["json"] = br
  2615. this.ServeJSON()
  2616. }()
  2617. user := this.User
  2618. if user == nil {
  2619. br.Msg = "请登录"
  2620. br.ErrMsg = "请登录,用户信息为空"
  2621. br.Ret = 408
  2622. return
  2623. }
  2624. uid := user.UserId
  2625. activityId, _ := this.GetInt("ActivityId")
  2626. if activityId < 1 {
  2627. br.Msg = "请输入活动ID"
  2628. return
  2629. }
  2630. resp := new(models.CygxActivitySpecialResp)
  2631. hasPermission := 0
  2632. activityInfo, err := models.GetCygxActivitySpecialDetailById(uid, activityId)
  2633. if err != nil && err.Error() != utils.ErrNoRow() {
  2634. br.Msg = "获取信息失败"
  2635. br.ErrMsg = "判断是否已申请过试用失败,Err:" + err.Error()
  2636. return
  2637. }
  2638. if activityInfo == nil {
  2639. br.Msg = "活动不存在"
  2640. br.ErrMsg = "活动ID错误,Err:" + "activityId:" + strconv.Itoa(activityId)
  2641. return
  2642. }
  2643. applyCount, err := models.GetApplyRecordCount(uid)
  2644. if err != nil && err.Error() != utils.ErrNoRow() {
  2645. br.Msg = "获取信息失败"
  2646. br.ErrMsg = "判断是否已申请过试用失败,Err:" + err.Error()
  2647. return
  2648. }
  2649. //获取FICC销售信息 如果是FICC的客户类型,则默认他申请过
  2650. sellerItem, err := models.GetSellerByCompanyIdCheckFicc(user.CompanyId, 1)
  2651. if err != nil && err.Error() != utils.ErrNoRow() {
  2652. br.Msg = "获取信息失败"
  2653. br.ErrMsg = "获取销售信息失败,Err:" + err.Error()
  2654. return
  2655. }
  2656. if user.CompanyId <= 1 {
  2657. //companyDetailStatus = ""
  2658. } else {
  2659. companyPermission, err := models.GetCompanyPermission(user.CompanyId)
  2660. if err != nil {
  2661. br.Msg = "获取信息失败"
  2662. br.ErrMsg = "获取客户详情失败,Err:" + err.Error()
  2663. return
  2664. }
  2665. if companyPermission == "" {
  2666. if applyCount > 0 {
  2667. hasPermission = 4
  2668. } else {
  2669. if sellerItem != nil {
  2670. hasPermission = 5
  2671. } else {
  2672. //获取权益销售信息 如果是FICC的客户类型,则默认他申请过
  2673. sellerItemQy, err := models.GetSellerByCompanyIdCheckFicc(user.CompanyId, 2)
  2674. if err != nil && err.Error() != utils.ErrNoRow() {
  2675. br.Msg = "获取信息失败"
  2676. br.ErrMsg = "获取销售信息失败,Err:" + err.Error()
  2677. return
  2678. }
  2679. if sellerItemQy != nil {
  2680. hasPermission = 2
  2681. resp.SellerMobile = sellerItemQy.Mobile
  2682. resp.SellerName = sellerItemQy.RealName
  2683. } else {
  2684. hasPermission = 3
  2685. }
  2686. }
  2687. }
  2688. resp.HasPermission = hasPermission
  2689. resp.OperationMode = "Apply"
  2690. resp.PopupMsg = "您暂无权限参加此活动,若想参加可以申请开通对应的试用权限"
  2691. br.Ret = 200
  2692. br.Success = true
  2693. br.Msg = "获取成功"
  2694. br.Data = resp
  2695. return
  2696. }
  2697. companyDetail, err := models.GetCompanyDetailById(user.CompanyId)
  2698. if err != nil {
  2699. br.Msg = "获取信息失败!"
  2700. br.ErrMsg = "获取客户详情失败,Err:" + err.Error()
  2701. return
  2702. }
  2703. if companyDetail == nil {
  2704. br.Msg = "获取信息失败!"
  2705. br.ErrMsg = "客户不存在,uid:" + strconv.Itoa(user.UserId) + "CompanyId:" + strconv.Itoa(user.CompanyId)
  2706. return
  2707. }
  2708. }
  2709. userType, permissionStr, err := services.GetUserType(user.CompanyId)
  2710. if err != nil {
  2711. br.Msg = "获取信息失败"
  2712. br.ErrMsg = "获取客户信息失败,Err:" + err.Error()
  2713. return
  2714. }
  2715. itemAct := new(models.ActivityDetail)
  2716. itemAct.CustomerTypeIds = activityInfo.CustomerTypeIds
  2717. noPower, err := services.GetShareNoPowe(itemAct, permissionStr, userType, user)
  2718. if err != nil {
  2719. br.Msg = "获取信息失败"
  2720. br.ErrMsg = "获取客户信息失败,Err:" + err.Error()
  2721. return
  2722. }
  2723. //获取用户的产业规模,判断是否允许可见
  2724. companyProduct, err := models.GetCompanyProductDetail(user.CompanyId, 2)
  2725. if err != nil && err.Error() != utils.ErrNoRow() {
  2726. br.Msg = "获取信息失败"
  2727. br.ErrMsg = "获取客户信息失败,Err:" + err.Error()
  2728. return
  2729. }
  2730. if companyProduct != nil {
  2731. if companyProduct.Scale != "" {
  2732. if strings.Count(activityInfo.Scale, companyProduct.Scale) > 0 {
  2733. noPower = false
  2734. }
  2735. }
  2736. }
  2737. if noPower {
  2738. br.Msg = "您暂无查看该活动权限"
  2739. br.ErrMsg = "被分享客户不可见,获取信息失败"
  2740. br.IsSendEmail = false
  2741. return
  2742. }
  2743. if userType == 1 && strings.Contains(activityInfo.ChartPermissionName, "研选") {
  2744. br.Msg = "您暂无查看该活动权限"
  2745. br.ErrMsg = "被分享客户不可见,永续客户无法查看研选行业"
  2746. return
  2747. }
  2748. //判断是否已经申请过
  2749. if user.CompanyId > 1 {
  2750. permissionStr, err := models.GetCompanyPermissionByUser(user.CompanyId)
  2751. if err != nil {
  2752. br.Msg = "获取信息失败"
  2753. br.ErrMsg = "获取客户权限信息失败,Err:" + err.Error()
  2754. return
  2755. }
  2756. companyItem, err := models.GetCompanyDetailById(user.CompanyId)
  2757. //冻结客户
  2758. if err != nil {
  2759. if err.Error() == utils.ErrNoRow() {
  2760. if applyCount > 0 {
  2761. hasPermission = 4
  2762. } else {
  2763. if sellerItem != nil {
  2764. hasPermission = 5
  2765. } else {
  2766. //获取权益销售信息 如果是FICC的客户类型,则默认他申请过
  2767. sellerItemQy, err := models.GetSellerByCompanyIdCheckFicc(user.CompanyId, 2)
  2768. if err != nil && err.Error() != utils.ErrNoRow() {
  2769. br.Msg = "获取信息失败"
  2770. br.ErrMsg = "获取销售信息失败,Err:" + err.Error()
  2771. return
  2772. }
  2773. if sellerItemQy != nil {
  2774. hasPermission = 2
  2775. resp.SellerMobile = sellerItemQy.Mobile
  2776. resp.SellerName = sellerItemQy.RealName
  2777. } else {
  2778. hasPermission = 3
  2779. }
  2780. }
  2781. }
  2782. resp.HasPermission = hasPermission
  2783. resp.OperationMode = "Apply"
  2784. resp.PopupMsg = "您暂无权限参加此活动,若想参加可以申请开通对应的试用权限"
  2785. br.Ret = 200
  2786. br.Success = true
  2787. br.Msg = "获取成功"
  2788. br.Data = resp
  2789. return
  2790. } else {
  2791. br.Msg = "获取信息失败"
  2792. br.ErrMsg = "获取客户公司信息失败,Err:" + err.Error()
  2793. return
  2794. }
  2795. }
  2796. var havePower bool
  2797. if strings.Contains(permissionStr, activityInfo.ActivityTypeName) {
  2798. havePower = true
  2799. }
  2800. if havePower {
  2801. hasPermission = 1
  2802. resp.HaqveJurisdiction = true
  2803. } else {
  2804. if permissionStr == "专家" {
  2805. resp.PopupMsg = "您暂无权限参加此活动,若想参加可以申请开通对应的试用权限"
  2806. resp.MsgType = "Type"
  2807. } else {
  2808. resp.PopupMsg = "您暂无权限参加此活动,若想参加可以申请开通对应的试用权限"
  2809. resp.MsgType = "Industry"
  2810. }
  2811. if companyItem.ProductId == 2 {
  2812. resp.SellerMobile = companyItem.Mobile
  2813. resp.SellerName = companyItem.SellerName
  2814. resp.OperationMode = "Call"
  2815. hasPermission = 2
  2816. } else {
  2817. hasPermission = 5
  2818. }
  2819. }
  2820. } else { //潜在客户
  2821. if applyCount > 0 {
  2822. hasPermission = 4
  2823. } else {
  2824. if sellerItem != nil {
  2825. hasPermission = 5
  2826. } else {
  2827. hasPermission = 3
  2828. }
  2829. }
  2830. resp.OperationMode = "Apply"
  2831. resp.PopupMsg = "您暂无权限参加此活动,若想参加可以申请开通对应的试用权限"
  2832. }
  2833. if hasPermission == 1 {
  2834. count, err := models.GetCygxUserFollowSpecial(user.UserId)
  2835. if err != nil {
  2836. br.Msg = "获取数据失败!"
  2837. br.ErrMsg = "获取客户详情失败,Err:" + err.Error()
  2838. return
  2839. }
  2840. if count == 1 {
  2841. resp.IsFollow = true
  2842. }
  2843. activityInfo.ActivityTypeName = "专项调研"
  2844. resp.Detail = activityInfo
  2845. }
  2846. resp.HasPermission = hasPermission
  2847. br.Ret = 200
  2848. br.Success = true
  2849. br.Msg = "获取成功"
  2850. br.Data = resp
  2851. }
  2852. // @Title 感兴趣、不感兴趣
  2853. // @Description 感兴趣、不感兴趣接口
  2854. // @Param request body models.ActivityIdRep true "type json string"
  2855. // @Success Ret=200 {object} models.SignupSpecialStatus
  2856. // @router /special/signup/add [post]
  2857. func (this *ActivityCoAntroller) SpecialSignupAdd() {
  2858. br := new(models.BaseResponse).Init()
  2859. defer func() {
  2860. this.Data["json"] = br
  2861. this.ServeJSON()
  2862. }()
  2863. user := this.User
  2864. if user == nil {
  2865. br.Msg = "请登录"
  2866. br.ErrMsg = "请登录,用户信息为空"
  2867. br.Ret = 408
  2868. return
  2869. }
  2870. uid := user.UserId
  2871. var req models.ActivityIdRep
  2872. resp := new(models.SignupSpecialStatus)
  2873. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  2874. if err != nil {
  2875. br.Msg = "参数解析异常!"
  2876. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  2877. return
  2878. }
  2879. activityId := req.ActivityId
  2880. activityInfo, errInfo := models.GetCygxActivitySpecialDetail(activityId)
  2881. if activityInfo == nil {
  2882. br.Msg = "操作失败"
  2883. br.ErrMsg = "活动ID错误,不存在activityId:" + strconv.Itoa(activityId)
  2884. return
  2885. }
  2886. if errInfo != nil {
  2887. br.Msg = "操作失败"
  2888. br.ErrMsg = "操作失败,Err:" + errInfo.Error()
  2889. return
  2890. }
  2891. havePower, err := services.GetSpecialDetailUserPower(user, activityInfo)
  2892. if err != nil {
  2893. br.Msg = "获取信息失败"
  2894. br.ErrMsg = "判断是否已申请过试用失败,Err:" + err.Error()
  2895. return
  2896. }
  2897. //判断有没有对应的权限,如果没有则给出对应的状态码
  2898. if havePower {
  2899. resp.HasPermission = 1
  2900. total, err := models.GetUserCygxActivitySpecialSignup(user.UserId, activityId)
  2901. if err != nil {
  2902. br.Msg = "获取信息失败"
  2903. br.ErrMsg = "获取日程数量信息失败,Err:" + err.Error()
  2904. return
  2905. }
  2906. resp.SignupStatus = 1
  2907. //判断是删除还是添加
  2908. if total == 0 {
  2909. //获取销售信息
  2910. sellerItem, err := models.GetSellerByCompanyIdCheckFicc(user.CompanyId, 2)
  2911. if err != nil {
  2912. br.Msg = "操作失败"
  2913. br.ErrMsg = "获取销售信息失败,Err:" + err.Error()
  2914. return
  2915. }
  2916. item := new(models.CygxActivitySpecialSignup)
  2917. item.UserId = uid
  2918. item.RealName = user.RealName
  2919. item.ActivityId = activityId
  2920. item.CreateTime = time.Now()
  2921. item.Mobile = user.Mobile
  2922. item.Email = user.Email
  2923. item.CompanyId = user.CompanyId
  2924. item.CompanyName = user.CompanyName
  2925. if sellerItem != nil {
  2926. item.SellerName = sellerItem.RealName
  2927. }
  2928. err = models.AddCygxActivitySpecialSignup(item)
  2929. if err != nil {
  2930. br.Msg = "操作失败"
  2931. br.ErrMsg = "操作失败,Err:" + err.Error()
  2932. return
  2933. }
  2934. resp.Status = 1
  2935. resp.PopupMsg = "感谢反馈"
  2936. resp.PopupMsg2 = "此调研具体行程尚未确认,待预报名人数满10人后弘则会确定行程并推送给您活动日期,只有在确认行程中再次报名才完成占位。"
  2937. //给所属销售发送消息
  2938. //if sellerItem.Mobile != "" {
  2939. // openIpItem, _ := models.GetUserRecordByMobile(4, sellerItem.Mobile)
  2940. // if openIpItem != nil && openIpItem.OpenId != "" {
  2941. // if sellerItem != nil {
  2942. // go services.SendSpecialTemplateMsg(user.RealName+"【"+user.CompanyName+"】", time.Now().Format(utils.FormatDateTime), user.Mobile, activityInfo.ResearchTheme, "sale", openIpItem)
  2943. // }
  2944. // }
  2945. //}
  2946. // 给芳姐发消息
  2947. //cnf, _ := models.GetConfigByCode("tpl_msg")
  2948. actList, _ := models.GetActivityListSpecialByActivityId(activityId)
  2949. //if cnf != nil {
  2950. // openIpItem, _ := models.GetUserRecordByMobile(4, cnf.ConfigValue)
  2951. // if openIpItem != nil && openIpItem.OpenId != "" {
  2952. // if len(actList) == 5 {
  2953. // var companyName string
  2954. // for _, v := range actList {
  2955. // companyName += "【" + v.CompanyName + "】"
  2956. // }
  2957. // go services.SendSpecialTemplateMsg(companyName, "", "", activityInfo.ResearchTheme, "", openIpItem)
  2958. // }
  2959. // }
  2960. //}
  2961. //感兴趣人数到达10人时,模板消息发送给活动负责人
  2962. if len(actList) == 10 {
  2963. go services.SendWxMsgActivitySpecial10(activityInfo)
  2964. }
  2965. //用户专项调研操作行为,模板消息推送
  2966. //go services.SpecialActivityUserRemind(user, activityInfo, 1)
  2967. //用户相关行为,给对应销售发模板消息
  2968. go services.ActivitySpecialUserRmind(user, activityId, 1)
  2969. } else {
  2970. err = models.DeleteCygxActivitySpecialSignup(user.UserId, activityId)
  2971. if err != nil {
  2972. br.Msg = "操作失败"
  2973. br.ErrMsg = "操作失败,Err:" + err.Error()
  2974. return
  2975. }
  2976. resp.Status = 2
  2977. }
  2978. } else {
  2979. hasPermission, sellerName, sellerMobile, popupMsg, err := services.GetUserHasPermission(user)
  2980. if err != nil {
  2981. br.Msg = "获取信息失败"
  2982. br.ErrMsg = "判断是否已申请过试用失败,Err:" + err.Error()
  2983. return
  2984. }
  2985. resp.PopupMsg = popupMsg
  2986. resp.HasPermission = hasPermission
  2987. resp.SellerName = sellerName
  2988. resp.SellerMobile = sellerMobile
  2989. }
  2990. br.Ret = 200
  2991. br.Success = true
  2992. br.Msg = "操作成功"
  2993. br.Data = resp
  2994. }
  2995. // @Title 新调研通知取消跟添加
  2996. // @Description 新调研通知取消跟添加接口
  2997. // @Param request body models.ArticleCollectResp true "type json string"
  2998. // @Success 200
  2999. // @router /special/follow [post]
  3000. func (this *ActivityCoAntroller) SpecialMsg() {
  3001. br := new(models.BaseResponse).Init()
  3002. defer func() {
  3003. this.Data["json"] = br
  3004. this.ServeJSON()
  3005. }()
  3006. user := this.User
  3007. if user == nil {
  3008. br.Msg = "请重新登录"
  3009. br.Ret = 408
  3010. return
  3011. }
  3012. resp := new(models.ArticleCollectResp)
  3013. count, err := models.GetCygxUserFollowSpecial(user.UserId)
  3014. if err != nil {
  3015. br.Msg = "获取数据失败!"
  3016. br.ErrMsg = "获取客户详情失败,Err:" + err.Error()
  3017. return
  3018. }
  3019. if count == 0 {
  3020. item := new(models.CygxUserFollowSpecial)
  3021. item.UserId = user.UserId
  3022. item.RealName = user.RealName
  3023. item.CreateTime = time.Now()
  3024. item.Mobile = user.Mobile
  3025. item.Email = user.Email
  3026. item.CompanyId = user.CompanyId
  3027. item.CompanyName = user.CompanyName
  3028. item.CreateTime = time.Now()
  3029. err := models.AddUserFollowSpecial(item)
  3030. if err != nil {
  3031. br.Msg = "操作失败!"
  3032. br.ErrMsg = "获取客户详情失败,Err:" + err.Error()
  3033. return
  3034. }
  3035. resp.Status = 1
  3036. } else {
  3037. err := models.DeleteCygxUserFollowSpecial(user.UserId)
  3038. if err != nil {
  3039. br.Msg = "操作失败!"
  3040. br.ErrMsg = "获取客户详情失败,Err:" + err.Error()
  3041. return
  3042. }
  3043. resp.Status = 2
  3044. }
  3045. br.Ret = 200
  3046. br.Data = resp
  3047. br.Success = true
  3048. br.Msg = "操作成功!"
  3049. }
  3050. // @Title 活动类型下的主题列表(6.0Pc版本)
  3051. // @Description 获取活动类型下的主题列表接口(6.0Pc版本)
  3052. // @Param ChartPermissionIds query string false "行业id 多个用 , 隔开"
  3053. // @Param ActivityTypeIds query string false "活动类型id 多个用 , 隔开"
  3054. // @Param ActiveState query string false "活动进行状态 未开始:1、进行中2、已结束3"
  3055. // @Param WhichDay query string false "哪一天 今天:1、明天:2,多个用 , 隔开"
  3056. // @Param IsPower query int false "是否选择有权限行业 ,1是 0 否 默认0"
  3057. // @Success 200 {object} models.ActivityTypeListHomeRespPc
  3058. // @router /labelTypeListV6Pc_del [get]
  3059. func (this *ActivityCoAntroller) LabelTypeListV6Pc() {
  3060. br := new(models.BaseResponse).Init()
  3061. defer func() {
  3062. this.Data["json"] = br
  3063. this.ServeJSON()
  3064. }()
  3065. user := this.User
  3066. if user == nil {
  3067. br.Msg = "请登录"
  3068. br.ErrMsg = "请登录,SysUser Is Empty"
  3069. return
  3070. }
  3071. pageSize, _ := this.GetInt("PageSize")
  3072. isPower, _ := this.GetInt("IsPower")
  3073. playBack, _ := this.GetInt("PlayBack")
  3074. //currentIndex, _ := this.GetInt("CurrentIndex")
  3075. chartPermissionIds := this.GetString("ChartPermissionIds")
  3076. //activityTypeIds := this.GetString("ActivityTypeIds")
  3077. whichDay := this.GetString("WhichDay")
  3078. activeState := this.GetString("ActiveState")
  3079. //入参为 undefined 时的处理
  3080. if chartPermissionIds == "undefined" {
  3081. chartPermissionIds = ""
  3082. }
  3083. // 查研观向7.4-始终查询宏观的活动
  3084. if chartPermissionIds != "" {
  3085. chartPermissionIds += ",1"
  3086. }
  3087. if whichDay == "undefined" {
  3088. whichDay = ""
  3089. }
  3090. if activeState == "undefined" || activeState == "" || activeState == "1" {
  3091. activeState = "1,2"
  3092. }
  3093. //adminIds, err := models.GetSelleridWhichGroup(user.CompanyId, 2)
  3094. //if err != nil {
  3095. // br.Msg = "获取失败"
  3096. // br.ErrMsg = "获取本组下的销售失败,Err:" + err.Error()
  3097. // return
  3098. //}
  3099. userType, permissionStr, err := services.GetUserType(user.CompanyId)
  3100. if err != nil {
  3101. br.Msg = "获取失败"
  3102. br.ErrMsg = "获取失败,Err:" + err.Error()
  3103. return
  3104. }
  3105. //isMaker := user.IsMaker
  3106. var startSize int
  3107. pageSize = 8
  3108. var sortTime string
  3109. var pars []interface{}
  3110. //活动可见限制
  3111. slicePer := strings.Split(permissionStr, ",")
  3112. var permissionNameStr string
  3113. for _, v := range slicePer {
  3114. if userType == 1 {
  3115. //if v != "研选" {
  3116. if !strings.Contains(v, "研选") {
  3117. permissionNameStr += "'" + v + "',"
  3118. }
  3119. } else {
  3120. permissionNameStr += "'" + v + "',"
  3121. }
  3122. }
  3123. permissionNameStr = strings.Replace(permissionNameStr, "(主观)", "", -1)
  3124. permissionNameStr = strings.Replace(permissionNameStr, "(客观)", "", -1)
  3125. permissionNameStr = strings.TrimRight(permissionNameStr, ",")
  3126. // 查研观向7.4-始终查询宏观的权限(无论是否有权限)
  3127. if permissionNameStr == `` {
  3128. permissionNameStr = `'宏观'`
  3129. } else {
  3130. permissionNameStr += `, '宏观'`
  3131. }
  3132. list, err := models.GetActivityTypeHomeListPc()
  3133. if err != nil {
  3134. br.Msg = "获取失败"
  3135. br.ErrMsg = "获取数据失败,Err:" + err.Error()
  3136. return
  3137. }
  3138. //判断客户规模是否属于可见范围的活动
  3139. //companyProduct, err := models.GetCompanyProductDetail(user.CompanyId, 2)
  3140. //if err != nil && err.Error() != utils.ErrNoRow() {
  3141. // br.Msg = "获取信息失败"
  3142. // br.ErrMsg = "获取客户信息失败,Err:" + err.Error()
  3143. // return
  3144. //}
  3145. var sqlExport string
  3146. //处理专家权限的查询
  3147. sqlExport = ` AND (art.customer_type_ids LIKE '%` + strconv.Itoa(userType) + `%' `
  3148. if userType == 2 {
  3149. sqlExport += ` OR art.customer_type_ids LIKE '%3%' `
  3150. }
  3151. if (userType == 2 || userType == 3) && strings.Contains(permissionStr, "专家") {
  3152. sqlExport += ` OR art.customer_type_ids LIKE '%4%' `
  3153. }
  3154. sqlExport += `) `
  3155. resp := new(models.ActivityTypeListHomeRespPc)
  3156. for k, v := range list {
  3157. // 如果是C类电话会就不展示内容,且合并到分析师电话会
  3158. if v.ActivityTypeId == utils.C_CLASS_ACTIVITY_TYPE_ID {
  3159. continue
  3160. }
  3161. var condition string
  3162. conditionActivity, err := services.GetActivityonditionList(user, strconv.Itoa(v.ActivityTypeId), chartPermissionIds, whichDay, activeState, "", isPower, 1, "", playBack, 1)
  3163. if err != nil && err.Error() != utils.ErrNoRow() {
  3164. br.Msg = "获取失败"
  3165. br.ErrMsg = "获取活动权限数据失败,Err:" + err.Error()
  3166. return
  3167. }
  3168. //condition += `AND art.is_limit_people = 1 ` + permissionSqlStr + sqlExport + conditionOr
  3169. condition += `AND art.is_limit_people = 1 AND art.yidong_activity_id = '' ` + conditionActivity
  3170. sortTime = ` mintimesort ASC `
  3171. labelList, err := models.GetActivityLabelListAll(condition, sortTime, pars, startSize, pageSize)
  3172. if err != nil {
  3173. br.Msg = "获取失败"
  3174. br.ErrMsg = "获取失败,Err:" + err.Error()
  3175. return
  3176. }
  3177. //标签字段关联的产业与标签处理
  3178. for k2, v2 := range labelList {
  3179. labelList[k2].KeyWord = services.LabelStrV5(v2.KeyWord, v2.IsShowSubjectName, v2.TemporaryLabel)
  3180. labelList[k2].Resource = 1
  3181. }
  3182. list[k].List = labelList
  3183. list[k].Resource = 1
  3184. }
  3185. if whichDay == "" {
  3186. //查询专项产业调研展示权限
  3187. //var scale string
  3188. //if companyProduct != nil {
  3189. // scale = companyProduct.Scale
  3190. //}
  3191. speciaItem, err := services.GetActivityLabelSpecialList(user, isPower, chartPermissionIds, permissionNameStr)
  3192. if err != nil {
  3193. br.Msg = "获取失败"
  3194. br.ErrMsg = "获取失败,Err:" + err.Error()
  3195. return
  3196. }
  3197. if len(speciaItem.List) > 0 {
  3198. itemList := new(models.ActivityTypeHomePc)
  3199. itemList.ActivityTypeName = "专项产业调研"
  3200. itemList.Resource = 2
  3201. itemList.List = speciaItem.List
  3202. itemList.ActivityTypeId = 7
  3203. itemList.OnlineIco = "https://hzstatic.hzinsights.com/static/temp/20220707202207/20220707/0H4md6VgZMuIttggMUnJxgrlayxC.png"
  3204. itemList.ImgUrlBgPc = "https://hzstatic.hzinsights.com/static/temp/20220707202207/20220707/rFwAM1c4fIMJM0EGoUkUYl25XH9L.png"
  3205. list = append(list, itemList)
  3206. }
  3207. }
  3208. // 查研观向7.4-活动【新】标签
  3209. activityIds := make([]int, 0)
  3210. for _, v := range list {
  3211. if len(v.List) > 0 {
  3212. for i := range v.List {
  3213. activityIds = append(activityIds, v.List[i].ActivityId)
  3214. }
  3215. }
  3216. }
  3217. newLabelMap, _, e := services.GetActivityNewLabelMap(activityIds)
  3218. if e != nil {
  3219. br.Msg = "获取失败"
  3220. br.ErrMsg = "获取活动【新】标签Map失败, Err: " + e.Error()
  3221. return
  3222. }
  3223. for k := range list {
  3224. for k2 := range list[k].List {
  3225. list[k].List[k2].IsNew = newLabelMap[list[k].List[k2].ActivityId]
  3226. }
  3227. }
  3228. //记录用户搜索的筛选条件
  3229. {
  3230. item := new(models.CygxActivitySearchHistory)
  3231. item.UserId = user.UserId
  3232. item.Mobile = user.Mobile
  3233. item.CompanyId = user.CompanyId
  3234. item.CompanyName = user.CompanyName
  3235. item.CreateTime = time.Now()
  3236. item.ChartPermissionIds = chartPermissionIds
  3237. item.IsPower = isPower
  3238. item.WhichDay = whichDay
  3239. go models.AddCygxActivitySearchHistory(item)
  3240. }
  3241. resp.List = list
  3242. br.Ret = 200
  3243. br.Success = true
  3244. br.Msg = "获取成功"
  3245. br.Data = resp
  3246. }
  3247. // @Title 预约纪要
  3248. // @Description 预约纪要接口
  3249. // @Param request body models.ActivityIdRep true "type json string"
  3250. // @Success Ret=200 {object} models.AppointmentResp
  3251. // @router /appointment/add [post]
  3252. func (this *ActivityCoAntroller) ActivityAppointmentAdd() {
  3253. br := new(models.BaseResponse).Init()
  3254. defer func() {
  3255. this.Data["json"] = br
  3256. this.ServeJSON()
  3257. }()
  3258. user := this.User
  3259. if user == nil {
  3260. br.Msg = "请登录"
  3261. br.ErrMsg = "请登录,用户信息为空"
  3262. br.Ret = 408
  3263. return
  3264. }
  3265. uid := user.UserId
  3266. signupStatus := "Success"
  3267. var req models.ActivityIdRep
  3268. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  3269. if err != nil {
  3270. br.Msg = "参数解析异常!"
  3271. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  3272. return
  3273. }
  3274. activityId := req.ActivityId
  3275. activityInfo, errInfo := models.GetAddActivityInfoById(activityId)
  3276. if activityInfo == nil {
  3277. br.Msg = "操作失败"
  3278. br.ErrMsg = "活动ID错误,不存在activityId:" + strconv.Itoa(activityId)
  3279. return
  3280. }
  3281. if errInfo != nil {
  3282. br.Msg = "操作失败"
  3283. br.ErrMsg = "操作失败,Err:" + errInfo.Error()
  3284. return
  3285. }
  3286. //判断是否已经预约过
  3287. totalAppointment, err := models.GetUserCygxActivityAppointmentCount(uid, activityId)
  3288. if err != nil {
  3289. br.Msg = "获取失败"
  3290. br.ErrMsg = "获取失败,Err:" + err.Error()
  3291. return
  3292. }
  3293. if totalAppointment > 0 {
  3294. br.Msg = "您已预约!"
  3295. return
  3296. }
  3297. //SignupStatus string `description:"报名状态:人数已满:FullStarffed、单机构超过两人:TwoPeople、爽约次数过多:BreakPromise、超时:Overtime 、成功:Success"`
  3298. item := new(models.CygxActivityAppointment)
  3299. resp := new(models.SignupStatus)
  3300. hasPermission := 0
  3301. havePower, isResearchSpecial, err := services.GetActivityDetailUserPower(user, activityInfo)
  3302. if err != nil {
  3303. br.Msg = "获取信息失败"
  3304. br.ErrMsg = "校验用户权限失败,Err:" + err.Error()
  3305. return
  3306. }
  3307. resp.IsResearchSpecial = isResearchSpecial
  3308. if havePower {
  3309. hasPermission = 1
  3310. signupStatus = "Success"
  3311. totalMeeting, errMeeting := models.GetUserCygxActivityAppointmentCount(uid, activityId)
  3312. if errMeeting != nil {
  3313. br.Msg = "获取失败"
  3314. br.ErrMsg = "获取失败,Err:" + errMeeting.Error()
  3315. return
  3316. }
  3317. if totalMeeting > 0 {
  3318. br.Msg = "您已预约,请勿重复预约"
  3319. return
  3320. }
  3321. var sellerName string
  3322. sellerName, err = models.GetCompanySellerName(user.CompanyId)
  3323. if err != nil {
  3324. br.Msg = "报名失败!"
  3325. br.ErrMsg = "获取对应销售失败,Err:" + err.Error()
  3326. return
  3327. }
  3328. item.UserId = uid
  3329. item.ActivityId = activityId
  3330. item.CreateTime = time.Now()
  3331. item.Mobile = user.Mobile
  3332. item.Email = user.Email
  3333. item.CompanyId = user.CompanyId
  3334. item.CompanyName = user.CompanyName
  3335. item.SellerName = sellerName
  3336. item.RealName = user.RealName
  3337. err = models.AddCygxActivityAppointment(item)
  3338. if err != nil {
  3339. br.Msg = "操作失败"
  3340. br.ErrMsg = "操作失败,Err:" + err.Error()
  3341. return
  3342. }
  3343. resp.HaqveJurisdiction = true
  3344. //1:预约外呼 、2:设置会议提醒 、 3:预约纪要 、4:活动报名
  3345. go services.ActivityUserRemind(user, activityInfo, 3)
  3346. resp.HasPermission = hasPermission
  3347. resp.SignupStatus = signupStatus
  3348. } else {
  3349. hasPermission, sellerName, sellerMobile, popupMsg, err := services.GetUserHasPermissionActivity(user, activityInfo)
  3350. if err != nil {
  3351. br.Msg = "获取信息失败"
  3352. br.ErrMsg = "判断是否已申请过试用失败,Err:" + err.Error()
  3353. return
  3354. }
  3355. resp.PopupMsg = popupMsg
  3356. resp.HasPermission = hasPermission
  3357. resp.SellerName = sellerName
  3358. resp.SellerMobile = sellerMobile
  3359. }
  3360. // 判断是否属于研选类型的活动
  3361. if strings.Contains(activityInfo.ChartPermissionName, utils.CHART_PERMISSION_NAME_YANXUAN) {
  3362. resp.IsResearch = true
  3363. }
  3364. resp.ActivityId = activityId
  3365. var total int
  3366. total, err = models.GetUserCygxActivityAppointmentCountByUid(user.UserId)
  3367. if err != nil {
  3368. br.Msg = "获取信息失败"
  3369. br.ErrMsg = "获取日程数量信息失败,Err:" + err.Error()
  3370. return
  3371. }
  3372. if total <= 1 {
  3373. resp.GoFollow = true
  3374. }
  3375. br.Ret = 200
  3376. br.Success = true
  3377. if hasPermission == 1 {
  3378. br.Msg = "请关注【查研观向小助手】公众号,若有调研纪要发布/更新,将及时为您推送微信消息"
  3379. resp.PopupMsg = "会议纪要预约成功<br/><br/>请关注【查研观向小助手】公众号,若有调研纪要发布/更新,将及时为您推送微信消息"
  3380. }
  3381. br.Data = resp
  3382. }
  3383. // @Title 取消预约纪要
  3384. // @Description 取消预约纪要接口
  3385. // @Param request body models.ActivityIdRep true "type json string"
  3386. // @Success Ret=200 {object} models.SignupStatus
  3387. // @router /appointment/cancel [post]
  3388. func (this *ActivityCoAntroller) ActivityAppointmentCancel() {
  3389. br := new(models.BaseResponse).Init()
  3390. defer func() {
  3391. this.Data["json"] = br
  3392. this.ServeJSON()
  3393. }()
  3394. user := this.User
  3395. if user == nil {
  3396. br.Msg = "请登录"
  3397. br.ErrMsg = "请登录,用户信息为空"
  3398. br.Ret = 408
  3399. return
  3400. }
  3401. uid := user.UserId
  3402. var req models.ActivityIdRep
  3403. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  3404. if err != nil {
  3405. br.Msg = "参数解析异常!"
  3406. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  3407. return
  3408. }
  3409. activityId := req.ActivityId
  3410. signupStatus := "Success"
  3411. item := new(models.CygxActivityAppointment)
  3412. activityInfo, errInfo := models.GetAddActivityInfoById(activityId)
  3413. if activityInfo == nil {
  3414. br.Msg = "操作失败"
  3415. br.ErrMsg = "活动ID错误,不存在activityId:" + strconv.Itoa(activityId)
  3416. return
  3417. }
  3418. if errInfo != nil {
  3419. br.Msg = "操作失败"
  3420. br.ErrMsg = "操作失败,Err:" + errInfo.Error()
  3421. return
  3422. }
  3423. total, err := models.GetUserCygxActivityAppointmentCount(uid, activityId)
  3424. if err != nil {
  3425. br.Msg = "获取失败"
  3426. br.ErrMsg = "获取失败,Err:" + err.Error()
  3427. return
  3428. }
  3429. if total == 0 {
  3430. br.Msg = "您暂未预约该纪要"
  3431. return
  3432. }
  3433. item.UserId = uid
  3434. item.ActivityId = activityId
  3435. item.CreateTime = time.Now()
  3436. item.Mobile = user.Mobile
  3437. item.Email = user.Email
  3438. item.CompanyId = user.CompanyId
  3439. item.CompanyName = user.CompanyName
  3440. _, errSignup := models.CancelcygxActivityAppointment(item)
  3441. if errSignup != nil {
  3442. br.Msg = "操作失败"
  3443. br.ErrMsg = "操作失败,Err:" + errSignup.Error()
  3444. return
  3445. }
  3446. resp := new(models.SignupStatus)
  3447. resp.SignupStatus = signupStatus
  3448. resp.ActivityId = activityId
  3449. br.Ret = 200
  3450. br.Success = true
  3451. br.Msg = "已取消"
  3452. br.Data = resp
  3453. }
  3454. // @Title 记录用户浏览音频回放接口
  3455. // @Description 记录用户浏览音频回放接口
  3456. // @Param request body models.ActivityIdRep true "type json string"
  3457. // @Success Ret=200 {object} models.AppointmentResp
  3458. // @router /voiceHistory/add [post]
  3459. func (this *ActivityCoAntroller) ActivityVoiceHistoryAdd() {
  3460. br := new(models.BaseResponse).Init()
  3461. defer func() {
  3462. this.Data["json"] = br
  3463. this.ServeJSON()
  3464. }()
  3465. user := this.User
  3466. if user == nil {
  3467. br.Msg = "请登录"
  3468. br.ErrMsg = "请登录,用户信息为空"
  3469. br.Ret = 408
  3470. return
  3471. }
  3472. uid := user.UserId
  3473. var req models.ActivityIdRep
  3474. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  3475. if err != nil {
  3476. br.Msg = "参数解析异常!"
  3477. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  3478. return
  3479. }
  3480. activityId := req.ActivityId
  3481. playSeconds := req.PlaySeconds
  3482. activityInfo, errInfo := models.GetAddActivityInfoById(activityId)
  3483. if activityInfo == nil {
  3484. br.Msg = "操作失败"
  3485. br.ErrMsg = "活动ID错误,不存在activityId:" + strconv.Itoa(activityId)
  3486. return
  3487. }
  3488. if errInfo != nil {
  3489. br.Msg = "操作失败"
  3490. br.ErrMsg = "操作失败,Err:" + errInfo.Error()
  3491. return
  3492. }
  3493. var sellerName string
  3494. sellerName, err = models.GetCompanySellerName(user.CompanyId)
  3495. if err != nil {
  3496. br.Msg = "报名失败!"
  3497. br.ErrMsg = "获取对应销售失败,Err:" + err.Error()
  3498. return
  3499. }
  3500. item := models.CygxActivityVoiceHistory{
  3501. ActivityId: activityId,
  3502. UserId: uid,
  3503. CreateTime: time.Now(),
  3504. Mobile: user.Mobile,
  3505. Email: user.Email,
  3506. CompanyId: user.CompanyId,
  3507. CompanyName: user.CompanyName,
  3508. RealName: user.RealName,
  3509. SellerName: sellerName,
  3510. PlaySeconds: strconv.Itoa(req.PlaySeconds),
  3511. ModifyTime: time.Now(),
  3512. }
  3513. if playSeconds != 0 {
  3514. lastItem, err := models.GetLastCygxActivityVoiceHistory(activityId, user.UserId)
  3515. if err != nil {
  3516. br.Msg = "操作失败"
  3517. br.ErrMsg = "操作失败,GetLastCygxActivityVoiceHistory Err:" + err.Error()
  3518. return
  3519. }
  3520. err = models.UpdateLastCygxActivityVoiceHistory(strconv.Itoa(req.PlaySeconds), lastItem.Id)
  3521. if err != nil {
  3522. br.Msg = "更新失败"
  3523. br.ErrMsg = "更新失败,UpdateLastCygxActivityVoiceHistory Err:" + err.Error()
  3524. return
  3525. }
  3526. } else {
  3527. err = models.AddCygxActivityVoiceHistory(&item)
  3528. if err != nil {
  3529. br.Msg = "操作失败"
  3530. br.ErrMsg = "操作失败,Err:" + err.Error()
  3531. return
  3532. }
  3533. err = models.UpdateCygxActivityVoiceCounts(activityId)
  3534. if err != nil {
  3535. br.Msg = "更新失败"
  3536. br.ErrMsg = "更新失败,Err:" + err.Error()
  3537. return
  3538. }
  3539. go services.ActivityVideoUserRmind(user, activityId, 2)
  3540. }
  3541. br.Ret = 200
  3542. br.Success = true
  3543. br.Msg = "操作成功"
  3544. return
  3545. }
  3546. // @Title 记录用户浏览视频回放接口
  3547. // @Description 记录用户浏览音频回放接口
  3548. // @Param request body models.ActivityIdRep true "type json string"
  3549. // @Success Ret=200 {object} models.AppointmentResp
  3550. // @router /videoHistory/add [post]
  3551. func (this *ActivityCoAntroller) ActivityVideoHistoryAdd() {
  3552. br := new(models.BaseResponse).Init()
  3553. defer func() {
  3554. this.Data["json"] = br
  3555. this.ServeJSON()
  3556. }()
  3557. user := this.User
  3558. if user == nil {
  3559. br.Msg = "请登录"
  3560. br.ErrMsg = "请登录,用户信息为空"
  3561. br.Ret = 408
  3562. return
  3563. }
  3564. uid := user.UserId
  3565. var req models.ActivityIdRep
  3566. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  3567. if err != nil {
  3568. br.Msg = "参数解析异常!"
  3569. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  3570. return
  3571. }
  3572. activityId := req.ActivityId
  3573. activityInfo, errInfo := models.GetCygxActivityVideoByActivityId(activityId)
  3574. if activityInfo == nil {
  3575. br.Msg = "操作失败"
  3576. br.ErrMsg = "活动ID错误,不存在activityId:" + strconv.Itoa(activityId)
  3577. return
  3578. }
  3579. if errInfo != nil {
  3580. br.Msg = "操作失败"
  3581. br.ErrMsg = "操作失败,Err:" + errInfo.Error()
  3582. return
  3583. }
  3584. var sellerName string
  3585. sellerName, err = models.GetCompanySellerName(user.CompanyId)
  3586. if err != nil {
  3587. br.Msg = "报名失败!"
  3588. br.ErrMsg = "获取对应销售失败,Err:" + err.Error()
  3589. return
  3590. }
  3591. item := models.CygxActivityVideoHistory{
  3592. ActivityId: activityId,
  3593. VideoId: activityInfo.VideoId,
  3594. UserId: uid,
  3595. CreateTime: time.Now(),
  3596. Mobile: user.Mobile,
  3597. Email: user.Email,
  3598. CompanyId: user.CompanyId,
  3599. CompanyName: user.CompanyName,
  3600. RealName: user.RealName,
  3601. SellerName: sellerName,
  3602. ModifyTime: time.Now(),
  3603. }
  3604. err = models.AddCygxActivityVideoHistory(&item)
  3605. if err != nil {
  3606. br.Msg = "操作失败"
  3607. br.ErrMsg = "操作失败,Err:" + err.Error()
  3608. return
  3609. }
  3610. err = models.UpdateActivityVideoCounts(activityId)
  3611. if err != nil {
  3612. br.Msg = "更新失败"
  3613. br.ErrMsg = "更新失败,Err:" + err.Error()
  3614. return
  3615. }
  3616. br.Ret = 200
  3617. br.Success = true
  3618. br.Msg = "操作成功"
  3619. return
  3620. }
  3621. // @Title 活动、专项调研搜索
  3622. // @Description 活动、专项调研搜索接口
  3623. // @Param PageSize query int true "每页数据条数"
  3624. // @Param CurrentIndex query int true "当前页页码,从1开始"
  3625. // @Param KeyWord query string false "搜索关键词 多个用 , 隔开"
  3626. // @Param IsResearch query bool true "是否为研选"
  3627. // @Success 200 {object} models.GetCygxActivityListRep
  3628. // @router /listSearch [get]
  3629. func (this *ActivityCoAntroller) ActivityListSearch() {
  3630. br := new(models.BaseResponse).Init()
  3631. defer func() {
  3632. this.Data["json"] = br
  3633. this.ServeJSON()
  3634. }()
  3635. user := this.User
  3636. if user == nil {
  3637. br.Msg = "请登录"
  3638. br.ErrMsg = "请登录,SysUser Is Empty"
  3639. return
  3640. }
  3641. pageSize, _ := this.GetInt("PageSize")
  3642. currentIndex, _ := this.GetInt("CurrentIndex")
  3643. source, _ := this.GetInt("Source")
  3644. keyWord := this.GetString("KeyWord")
  3645. playBack, _ := this.GetInt("PlayBack")
  3646. var startSize int
  3647. if pageSize <= 0 {
  3648. pageSize = utils.PageSize20
  3649. }
  3650. if currentIndex <= 0 {
  3651. currentIndex = 1
  3652. }
  3653. startSize = utils.StartIndex(currentIndex, pageSize)
  3654. var condition string
  3655. //活动可见限制
  3656. conditionActivity, err := services.GetActivityonditionList(user, "", "", "", "", "", 0, 1, keyWord, playBack, 1)
  3657. if err != nil && err.Error() != utils.ErrNoRow() {
  3658. br.Msg = "获取失败"
  3659. br.ErrMsg = "获取活动权限数据失败,Err:" + err.Error()
  3660. return
  3661. }
  3662. if source == 1 {
  3663. condition += ` AND art.yidong_activity_id = '' `
  3664. }
  3665. condition += ` AND art.is_limit_people = 1 AND art.publish_status = 1 ` + conditionActivity
  3666. list, total, err := services.GetActivitySpecialSearcheList(user, condition, startSize, pageSize, keyWord)
  3667. if err != nil {
  3668. br.Msg = "获取失败"
  3669. br.ErrMsg = "获取失败,Err:" + err.Error()
  3670. return
  3671. }
  3672. page := paging.GetPaging(currentIndex, pageSize, total)
  3673. resp := new(models.GetCygxActivityListRep)
  3674. //添加活动搜索记录
  3675. if keyWord != "" {
  3676. go services.AddActivitykeyWordSearch(keyWord, user)
  3677. }
  3678. resp.Paging = page
  3679. resp.List = list
  3680. br.Ret = 200
  3681. br.Success = true
  3682. br.Msg = "获取成功"
  3683. br.Data = resp
  3684. }
  3685. // @Title 已结束的活动
  3686. // @Description 获取已结束的活动接口
  3687. // @Param ChartPermissionIds query string false "行业id 多个用 , 隔开"
  3688. // @Param WhichDay query string false "哪一天 3本周、4上周,5本月,6上月 可多选"
  3689. // @Param IsPower query string false "是否选择有权限行业 ,1是 0 否 默认0"
  3690. // @Param TypeName query string false "电话会类型 ,1专家电话会 2分析师电话会"
  3691. // @Success 200 {object} models.GetCygxActivityLabelListRep
  3692. // @router /overActivityList [get]
  3693. func (this *ActivityCoAntroller) OverActivityList() {
  3694. br := new(models.BaseResponse).Init()
  3695. defer func() {
  3696. this.Data["json"] = br
  3697. this.ServeJSON()
  3698. }()
  3699. user := this.User
  3700. if user == nil {
  3701. br.Msg = "请登录"
  3702. br.ErrMsg = "请登录,SysUser Is Empty"
  3703. return
  3704. }
  3705. isPower, _ := this.GetInt("IsPower")
  3706. chartPermissionIds := this.GetString("ChartPermissionIds")
  3707. whichDay := this.GetString("WhichDay")
  3708. typeName := this.GetString("TypeName")
  3709. //入参为 undefined 时的处理
  3710. if chartPermissionIds == "undefined" {
  3711. chartPermissionIds = ""
  3712. }
  3713. if whichDay == "undefined" {
  3714. whichDay = ""
  3715. }
  3716. resp := new(models.GetCygxActivityLabelListRep)
  3717. if user.CompanyId <= 1 {
  3718. resp.List = make([]*models.CygxActivityLabelList, 0)
  3719. br.Ret = 200
  3720. br.Success = true
  3721. br.Msg = "获取成功"
  3722. br.Data = resp
  3723. return
  3724. }
  3725. var condition string
  3726. var conditionSpecialinit string
  3727. var conditionSpecial string
  3728. var sortTime string
  3729. var pars []interface{}
  3730. //已结束的活动 不展示研选 11.0
  3731. condition = ` AND art.publish_status = 1 AND art.label != '' AND art.active_state = 3 AND art.chart_permission_id != ` + strconv.Itoa(utils.CHART_PERMISSION_ID_YANXUAN)
  3732. if whichDay != "" {
  3733. var startDate string
  3734. var endDate string
  3735. if whichDay == "3" {
  3736. startDate = utils.GetNowWeekMonday().Format(utils.FormatDate)
  3737. endDate = utils.GetNowWeekSunday().Format(utils.FormatDate)
  3738. } else if whichDay == "4" {
  3739. startDate = utils.GetLastWeekMonday().Format(utils.FormatDate)
  3740. endDate = utils.GetLastWeekSunday().Format(utils.FormatDate)
  3741. } else if whichDay == "5" {
  3742. startDate = utils.GetNowMonthFirstDay().Format(utils.FormatDate)
  3743. endDate = utils.GetNowMonthLastDay().Format(utils.FormatDate)
  3744. } else if whichDay == "6" {
  3745. startDate = utils.GetLastMonthFirstDay().Format(utils.FormatDate)
  3746. endDate = utils.GetLastMonthLastDay().Format(utils.FormatDate)
  3747. } else if whichDay == "3,4" {
  3748. startDate = utils.GetLastWeekMonday().Format(utils.FormatDate)
  3749. endDate = utils.GetNowWeekSunday().Format(utils.FormatDate)
  3750. } else if whichDay == "5,6" {
  3751. startDate = utils.GetLastMonthFirstDay().Format(utils.FormatDate)
  3752. endDate = utils.GetNowMonthLastDay().Format(utils.FormatDate)
  3753. } else {
  3754. startDate = utils.GetNowWeekMonday().Format(utils.FormatDate)
  3755. endDate = utils.GetNowWeekSunday().Format(utils.FormatDate)
  3756. }
  3757. condition += ` AND art.activity_time >= ` + "'" + startDate + " 00:00:00'"
  3758. condition += ` AND art.activity_time <= ` + "'" + endDate + " 23:59:59'"
  3759. conditionSpecialinit += ` AND art.activity_time >= ` + "'" + startDate + " 00:00:00'"
  3760. conditionSpecialinit += ` AND art.activity_time <= ` + "'" + endDate + " 23:59:59'"
  3761. }
  3762. if len(chartPermissionIds) > 0 {
  3763. condition += ` AND art.chart_permission_id IN (` + chartPermissionIds + `)`
  3764. }
  3765. // 如果是C类电话会就不展示内容,且合并到分析师电话会
  3766. if typeName == "1" || typeName == "2" {
  3767. if typeName == strconv.Itoa(utils.ANALYST_TELL_ACTIVITY_TYPE_ID) {
  3768. condition += ` AND art.publish_status = 1 AND art.label != '' AND art.activity_type_id IN (` + typeName + "," + strconv.Itoa(utils.C_CLASS_ACTIVITY_TYPE_ID) + `)`
  3769. } else {
  3770. condition += ` AND art.publish_status = 1 AND art.label != '' AND art.activity_type_id IN (` + typeName + `)`
  3771. }
  3772. conditionSpecialinit += ` AND art.activity_id = 0 `
  3773. }
  3774. conditionActivity, err := services.ActivityConditioninitSql(user, condition, isPower)
  3775. if err != nil && err.Error() != utils.ErrNoRow() {
  3776. br.Msg = "获取失败"
  3777. br.ErrMsg = "获取活动权限数据失败,Err:" + err.Error()
  3778. return
  3779. }
  3780. sortTime = ` activity_time DESC `
  3781. //如果是永续的就按照普通的权限逻辑来查,如果不是就按照升级的逻辑来查
  3782. companyDetail, err := models.GetCompanyDetailByIdGroupTrip(user.CompanyId)
  3783. if err != nil {
  3784. br.Msg = "获取失败"
  3785. br.ErrMsg = "获取失败,Err:" + err.Error()
  3786. return
  3787. }
  3788. if companyDetail.Status == "永续" {
  3789. conditionSpecial, err = services.HandleActivityLabelSpecialPermission(user)
  3790. } else {
  3791. conditionSpecial, _, err = services.HandleActivityLabelSpecialTripPermission(user)
  3792. }
  3793. if err != nil {
  3794. br.Msg = "获取失败"
  3795. br.ErrMsg = "获取失败,Err:" + err.Error()
  3796. return
  3797. }
  3798. conditionSpecial += ` AND art.days >0 AND art.publish_status =1 AND art.is_offline = 0 `
  3799. conditionSpecial += ` AND art.activity_time_end < ` + "'" + time.Now().Format(utils.FormatDateTime) + "'"
  3800. condition += conditionActivity
  3801. list, err := models.GetActivityLabelListAllNoLimit(condition, sortTime, pars, conditionSpecialinit+conditionSpecial)
  3802. if err != nil {
  3803. br.Msg = "获取失败"
  3804. br.ErrMsg = "获取失败,Err:" + err.Error()
  3805. return
  3806. }
  3807. //标签字段关联的产业与标签处理
  3808. mapKeyWord := make(map[string]string)
  3809. for _, v := range list {
  3810. keyWord := services.LabelStr(v.KeyWord)
  3811. if _, ok := mapKeyWord[keyWord]; ok {
  3812. continue
  3813. }
  3814. if keyWord == "" {
  3815. continue
  3816. }
  3817. v.KeyWord = keyWord
  3818. resp.List = append(resp.List, v)
  3819. mapKeyWord[keyWord] = keyWord
  3820. }
  3821. if len(list) == 0 {
  3822. resp.List = make([]*models.CygxActivityLabelList, 0)
  3823. }
  3824. //添加更多主题访问记录
  3825. //item := new(models.CygxPageHistoryRecord)
  3826. //item.UserId = user.UserId
  3827. //item.CreateTime = time.Now()
  3828. //item.Mobile = user.Mobile
  3829. //item.Email = user.Email
  3830. //item.CompanyId = user.CompanyId
  3831. //item.CompanyName = user.CompanyName
  3832. //item.PageType = "OverActivity"
  3833. //go models.AddCygxPageHistoryRecord(item)
  3834. br.Ret = 200
  3835. br.Success = true
  3836. br.Msg = "获取成功"
  3837. br.Data = resp
  3838. }
  3839. // @Title 活动报名之前的校验(权限、时间、点数、邮箱)
  3840. // @Description 活动报名之前的校验(权限、时间、点数、邮箱)接口
  3841. // @Param request body models.ActivityIdRep true "type json string"
  3842. // @Success Ret=200 {object} models.SignupStatus
  3843. // @router /check [post]
  3844. func (this *ActivityCoAntroller) Check() {
  3845. br := new(models.BaseResponse).Init()
  3846. defer func() {
  3847. this.Data["json"] = br
  3848. this.ServeJSON()
  3849. }()
  3850. user := this.User
  3851. if user == nil {
  3852. br.Msg = "请登录"
  3853. br.ErrMsg = "请登录,用户信息为空"
  3854. br.Ret = 408
  3855. return
  3856. }
  3857. var req models.ActivityIdRep
  3858. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  3859. if err != nil {
  3860. br.Msg = "参数解析异常!"
  3861. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  3862. return
  3863. }
  3864. activityId := req.ActivityId
  3865. activityInfo, errInfo := models.GetAddActivityInfoById(activityId)
  3866. if activityInfo == nil {
  3867. br.Msg = "操作失败"
  3868. br.ErrMsg = "活动ID错误,不存在activityId:" + strconv.Itoa(activityId)
  3869. return
  3870. }
  3871. if errInfo != nil {
  3872. br.Msg = "操作失败"
  3873. br.ErrMsg = "操作失败,Err:" + errInfo.Error()
  3874. return
  3875. }
  3876. //这里的文案顺序提示 权限>时间>研选扣点>邮箱绑定。
  3877. resp := new(models.ActivityCheck)
  3878. resp.CancelPopupMsg, err = services.ActivityCancelDeadlineMsg(activityInfo) //处理取消报名截止时间的弹窗文案
  3879. if err != nil {
  3880. br.Msg = "操作失败"
  3881. br.ErrMsg = "操作失败,Err:" + err.Error()
  3882. return
  3883. }
  3884. hasPermission := 0
  3885. havePower, isResearchSpecial, err := services.GetActivityDetailUserPower(user, activityInfo)
  3886. if err != nil {
  3887. br.Msg = "获取信息失败"
  3888. br.ErrMsg = "校验用户权限失败,Err:" + err.Error()
  3889. return
  3890. }
  3891. resp.IsResearchSpecial = isResearchSpecial
  3892. if havePower {
  3893. hasPermission = 1
  3894. resp.CheckPermission = true
  3895. resp.HasPermission = hasPermission
  3896. } else {
  3897. hasPermission, sellerName, sellerMobile, popupMsg, err := services.GetUserHasPermissionActivity(user, activityInfo)
  3898. if err != nil {
  3899. br.Msg = "获取信息失败"
  3900. br.ErrMsg = "判断是否已申请过试用失败,Err:" + err.Error()
  3901. return
  3902. }
  3903. resp.PopupMsg = popupMsg
  3904. resp.HasPermission = hasPermission
  3905. resp.SellerName = sellerName
  3906. resp.SellerMobile = sellerMobile
  3907. }
  3908. if resp.CheckPermission {
  3909. //如果权限通过了校验,那么就来校验时间
  3910. resp.CheckTime, resp.PopupMsg = services.CheckSiginupDeadline(activityInfo)
  3911. }
  3912. if resp.CheckTime {
  3913. // 如果时间通过校验就校验点数
  3914. resp.CheckPoints, resp.PopupMsg, resp.CompanyPoints, resp.ActivityPoints, err = services.CheckActivityPoints(activityInfo, user)
  3915. if err != nil {
  3916. br.Msg = "获取信息失败"
  3917. br.ErrMsg = "CheckActivityPoints,Err:" + err.Error()
  3918. return
  3919. }
  3920. }
  3921. if resp.CheckPoints {
  3922. //如果通过点数的校验,就来校验邮箱
  3923. resp.CheckEmail, resp.PopupMsg = services.CheckActivityUserEmail(activityInfo, user)
  3924. }
  3925. // 判断是否属于研选类型的活动
  3926. if strings.Contains(activityInfo.ChartPermissionName, utils.CHART_PERMISSION_NAME_YANXUAN) {
  3927. resp.IsResearch = true
  3928. }
  3929. br.Ret = 200
  3930. br.Success = true
  3931. br.Data = resp
  3932. }