activity.go 149 KB

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