activity.go 156 KB

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