activity.go 129 KB

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