activity_signup.go 95 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719172017211722172317241725172617271728172917301731173217331734173517361737173817391740174117421743174417451746174717481749175017511752175317541755175617571758175917601761176217631764176517661767176817691770177117721773177417751776177717781779178017811782178317841785178617871788178917901791179217931794179517961797179817991800180118021803180418051806180718081809181018111812181318141815181618171818181918201821182218231824182518261827182818291830183118321833183418351836183718381839184018411842184318441845184618471848184918501851185218531854185518561857185818591860186118621863186418651866186718681869187018711872187318741875187618771878187918801881188218831884188518861887188818891890189118921893189418951896189718981899190019011902190319041905190619071908190919101911191219131914191519161917191819191920192119221923192419251926192719281929193019311932193319341935193619371938193919401941194219431944194519461947194819491950195119521953195419551956195719581959196019611962196319641965196619671968196919701971197219731974197519761977197819791980198119821983198419851986198719881989199019911992199319941995199619971998199920002001200220032004200520062007200820092010201120122013201420152016201720182019202020212022202320242025202620272028202920302031203220332034203520362037203820392040204120422043204420452046204720482049205020512052205320542055205620572058205920602061206220632064206520662067206820692070207120722073207420752076207720782079208020812082208320842085208620872088208920902091209220932094209520962097209820992100210121022103210421052106210721082109211021112112211321142115211621172118211921202121212221232124212521262127212821292130213121322133213421352136213721382139214021412142214321442145214621472148214921502151215221532154215521562157215821592160216121622163216421652166216721682169217021712172217321742175217621772178217921802181218221832184218521862187218821892190219121922193219421952196219721982199220022012202220322042205220622072208220922102211221222132214221522162217221822192220222122222223222422252226222722282229223022312232223322342235223622372238223922402241224222432244224522462247224822492250225122522253225422552256225722582259226022612262226322642265226622672268226922702271227222732274227522762277227822792280228122822283228422852286228722882289229022912292229322942295229622972298229923002301230223032304230523062307230823092310231123122313231423152316231723182319232023212322232323242325232623272328232923302331233223332334233523362337233823392340234123422343234423452346234723482349235023512352235323542355235623572358235923602361236223632364236523662367236823692370237123722373237423752376237723782379238023812382238323842385238623872388238923902391239223932394239523962397239823992400240124022403240424052406240724082409241024112412241324142415241624172418241924202421242224232424242524262427242824292430243124322433243424352436243724382439244024412442244324442445244624472448244924502451245224532454245524562457245824592460246124622463246424652466246724682469247024712472247324742475247624772478247924802481248224832484248524862487248824892490249124922493249424952496249724982499250025012502250325042505250625072508250925102511251225132514251525162517251825192520252125222523252425252526252725282529253025312532253325342535253625372538253925402541254225432544254525462547254825492550255125522553255425552556255725582559256025612562256325642565256625672568256925702571257225732574257525762577257825792580258125822583258425852586258725882589259025912592259325942595259625972598259926002601260226032604260526062607260826092610261126122613261426152616261726182619262026212622262326242625262626272628262926302631263226332634263526362637263826392640264126422643264426452646264726482649265026512652265326542655265626572658265926602661266226632664266526662667266826692670267126722673267426752676267726782679268026812682268326842685268626872688268926902691269226932694269526962697269826992700270127022703270427052706270727082709271027112712271327142715271627172718271927202721272227232724272527262727272827292730273127322733273427352736273727382739274027412742274327442745274627472748274927502751275227532754275527562757275827592760276127622763276427652766276727682769277027712772277327742775277627772778277927802781278227832784278527862787278827892790279127922793279427952796279727982799280028012802280328042805280628072808280928102811281228132814281528162817281828192820282128222823282428252826282728282829283028312832283328342835283628372838283928402841284228432844284528462847284828492850285128522853285428552856285728582859286028612862286328642865286628672868286928702871287228732874287528762877287828792880288128822883288428852886288728882889289028912892289328942895289628972898289929002901290229032904290529062907290829092910291129122913291429152916291729182919292029212922292329242925292629272928292929302931293229332934293529362937293829392940294129422943294429452946294729482949295029512952295329542955295629572958295929602961296229632964296529662967296829692970297129722973297429752976297729782979298029812982298329842985298629872988298929902991
  1. package cygx
  2. import (
  3. "encoding/json"
  4. "fmt"
  5. "github.com/rdlucklib/rdluck_tools/paging"
  6. "github.com/tealeg/xlsx"
  7. "hongze/hz_crm_api/controllers"
  8. "hongze/hz_crm_api/models"
  9. "hongze/hz_crm_api/models/cygx"
  10. "hongze/hz_crm_api/models/system"
  11. "hongze/hz_crm_api/services"
  12. cygxService "hongze/hz_crm_api/services/cygx"
  13. "hongze/hz_crm_api/utils"
  14. "html/template"
  15. "os"
  16. "path/filepath"
  17. "strconv"
  18. "strings"
  19. "time"
  20. )
  21. // 活动
  22. type ActivitySignupCoAntroller struct {
  23. controllers.BaseAuthController
  24. }
  25. // @Title 报名管理列表
  26. // @Description 获取报名管理列表接口
  27. // @Param PageSize query int true "每页数据条数"
  28. // @Param CurrentIndex query int true "当前页页码,从1开始"
  29. // @Param ChartPermissionId query string false "行业id"
  30. // @Param ActivityTypeId query string false "活动类型id 多个用 , 隔开列如: 1,2"
  31. // @Param StartDate query string false "开始时间 ,列如2021-03-06 "
  32. // @Param EndDate query string false "结束时间,列如2021-03-06 "
  33. // @Param KeyWord query string false "搜索关键词"
  34. // @Param SearchType query int true "筛选类型 1专家/分析师电话会、2专家/分析师线下沙龙 、3公司调研/、4C类电话会"
  35. // @Param ActiveState query int false "发布状态 ,1未开始、2进行中、3已结束 ,默认1未开始"
  36. // @Param PublishStatus query int false "发布状态 ,0未发布,1已发布,3已取消,传2查询所有"
  37. // @Success 200 {object} cygx.GetCygxSignupListRep
  38. // @router /activitySignup/list [get]
  39. func (this *ActivitySignupCoAntroller) SignupList() {
  40. br := new(models.BaseResponse).Init()
  41. defer func() {
  42. this.Data["json"] = br
  43. this.ServeJSON()
  44. }()
  45. sysUser := this.SysUser
  46. if sysUser == nil {
  47. br.Msg = "请登录"
  48. br.ErrMsg = "请登录,SysUser Is Empty"
  49. return
  50. }
  51. pageSize, _ := this.GetInt("PageSize")
  52. currentIndex, _ := this.GetInt("CurrentIndex")
  53. chartPermissionId, _ := this.GetInt("ChartPermissionId")
  54. ActivityTypeId := this.GetString("ActivityTypeId")
  55. startDate := this.GetString("StartDate")
  56. endDate := this.GetString("EndDate")
  57. keyWord := this.GetString("KeyWord")
  58. activeState, _ := this.GetInt("ActiveState")
  59. searchType, _ := this.GetInt("SearchType")
  60. publishStatus, _ := this.GetInt("PublishStatus")
  61. if activeState == 0 {
  62. activeState = 1
  63. }
  64. var startSize int
  65. if pageSize <= 0 {
  66. pageSize = utils.PageSize20
  67. }
  68. if currentIndex <= 0 {
  69. currentIndex = 1
  70. }
  71. startSize = utils.StartIndex(currentIndex, pageSize)
  72. var condition string
  73. var pars []interface{}
  74. if keyWord != "" {
  75. template.HTMLEscapeString(keyWord)
  76. fmt.Println("keyWord", keyWord)
  77. keyWord = "%" + keyWord + "%"
  78. condition += ` AND (art.activity_name LIKE ? ) `
  79. pars = append(pars, keyWord)
  80. }
  81. condition += ` AND art.active_state = ? `
  82. pars = append(pars, activeState)
  83. if ActivityTypeId == "" {
  84. if searchType == 4 {
  85. condition += ` AND art.activity_type_id IN (7) `
  86. } else if searchType == 3 {
  87. condition += ` AND art.activity_type_id IN (3,4) `
  88. } else if searchType == 2 {
  89. condition += ` AND art.activity_type_id IN (5,6) `
  90. } else {
  91. condition += ` AND art.activity_type_id IN (1,2) ` //默认
  92. }
  93. }
  94. if ActivityTypeId != "" {
  95. condition += ` AND art.activity_type_id IN (` + ActivityTypeId + `) `
  96. }
  97. //行业名称
  98. if chartPermissionId > 0 {
  99. condition += ` AND art.chart_permission_id = '` + strconv.Itoa(chartPermissionId) + `'`
  100. }
  101. if startDate != "" {
  102. condition += ` AND art.activity_time >= ` + "'" + startDate + " 00:00:00'"
  103. }
  104. if endDate != "" {
  105. condition += ` AND art.activity_time <= ` + "'" + endDate + " 23:59:59'"
  106. }
  107. if publishStatus == 0 {
  108. condition += ` AND art.publish_status = 0 AND art.is_cancel = 0 `
  109. } else if publishStatus == 1 {
  110. condition += ` AND art.publish_status = 1 `
  111. } else if publishStatus == 3 {
  112. condition += ` AND art.publish_status = 0 AND art.is_cancel = 1 `
  113. }
  114. //C类电话会,仅本组销售、部门管理员、admin、权益研究员账号能看到。
  115. if sysUser.Role != "admin" {
  116. conditionPermission, err := cygxService.GetAdminActivityPermission(sysUser, condition)
  117. if err != nil {
  118. br.Msg = "获取失败"
  119. br.ErrMsg = "获取失败,GetAdminActivityPermission Err:" + err.Error()
  120. return
  121. }
  122. condition += ` AND art.visible_range != 1 `
  123. condition += conditionPermission
  124. pars = append(pars, pars)
  125. }
  126. //condition += ` AND a.publish_status = 1 `
  127. total, err := cygx.GetCygxSignupCount(condition, pars)
  128. if err != nil {
  129. br.Msg = "获取失败"
  130. br.ErrMsg = "获取失败,Err:" + err.Error()
  131. return
  132. }
  133. if activeState == 3 {
  134. condition += ` ORDER BY art.activity_time DESC `
  135. } else {
  136. condition += ` ORDER BY art.activity_time ASC `
  137. }
  138. list, errList := cygx.GetCygxSignupListAll(condition, pars, startSize, pageSize)
  139. if errList != nil {
  140. br.Msg = "获取失败"
  141. br.ErrMsg = "获取失败,Err:" + errList.Error()
  142. return
  143. }
  144. var activityIds string
  145. for k, v := range list {
  146. if v.ChartPermissionNames != "" {
  147. list[k].ChartPermissionName = v.ChartPermissionNames
  148. }
  149. //if v.IsHideAppointment == 0 {
  150. // list[k].IsShowAppointment = cygxService.IsShowAppointmentByadminSet(v.IsCanAppointmentMinutes)
  151. //}
  152. activityIds += strconv.Itoa(v.ActivityId) + ","
  153. }
  154. activityIds = strings.TrimRight(activityIds, ",")
  155. mapIndustrial := make(map[int]string)
  156. mapSubject := make(map[string]string)
  157. if activityIds != "" {
  158. industrialList, err := cygx.GetIndustrialActivityGroupListByactivityIds(activityIds)
  159. if err != nil {
  160. br.Msg = "获取失败"
  161. br.ErrMsg = "获取失败,GetIndustrialActivityGroupListByactivityIds Err:" + err.Error()
  162. return
  163. }
  164. subjectList, err := cygx.GetSubjectActivityGroupListByactivityIds(activityIds)
  165. if err != nil {
  166. br.Msg = "获取失败"
  167. br.ErrMsg = "获取失败,GetSubjectActivityGroupListByactivityIds Err:" + err.Error()
  168. return
  169. }
  170. //合并活动对应的多个标的
  171. for _, v := range subjectList {
  172. mapSubject[fmt.Sprint(v.ActivityId, "_", v.IndustrialManagementId)] += v.SubjectName + "/"
  173. }
  174. //活动对应的产业
  175. for _, v := range industrialList {
  176. var labelSubject string
  177. labelSubject = mapSubject[fmt.Sprint(v.ActivityId, "_", v.IndustrialManagementId)]
  178. if labelSubject != "" {
  179. mapIndustrial[v.ActivityId] += v.IndustryName + "--" + strings.TrimRight(labelSubject, "/") + ","
  180. } else {
  181. mapIndustrial[v.ActivityId] += v.IndustryName + ","
  182. }
  183. }
  184. }
  185. for k, v := range list {
  186. if mapIndustrial[v.ActivityId] != "" && v.TemporaryLabel == "" {
  187. list[k].Label = strings.TrimRight(mapIndustrial[v.ActivityId], ",")
  188. }
  189. if v.IsCancel == 1 {
  190. v.PublishStatus = 3
  191. }
  192. if v.YidongActivityId != "" {
  193. list[k].ActivityTypeName += utils.YI_DONG_NAME
  194. list[k].LimitPeopleNum = 10000 // 前端根据这个字段是否大于0来处理是新增报名还是预约外呼
  195. }
  196. if v.IsYidongConduct == 1 {
  197. v.ActivityTypeName += utils.YI_DONG_NAME_TWO
  198. }
  199. if v.IsCanAppointmentMinutes == 1 {
  200. v.IsShowAppointment = true
  201. }
  202. }
  203. if len(list) == 0 {
  204. list = make([]*cygx.CygxSignupList, 0)
  205. }
  206. page := paging.GetPaging(currentIndex, pageSize, total)
  207. resp := new(cygx.GetCygxSignupListRep)
  208. resp.List = list
  209. resp.Paging = page
  210. br.Ret = 200
  211. br.Success = true
  212. br.Msg = "获取成功"
  213. br.Data = resp
  214. }
  215. // @Title 几种类型报名详情列表
  216. // @Description 获取几种类型报名详情列表接口
  217. // @Param ActivityId query int true "活动ID"
  218. // @Success 200 {object} cygx.GetAppointmentListRep
  219. // @router /activitySignup/appointmentList [get]
  220. func (this *ActivitySignupCoAntroller) AppointmentList() {
  221. br := new(models.BaseResponse).Init()
  222. defer func() {
  223. this.Data["json"] = br
  224. this.ServeJSON()
  225. }()
  226. sysUser := this.SysUser
  227. if sysUser == nil {
  228. br.Msg = "请登录"
  229. br.ErrMsg = "请登录,SysUser Is Empty"
  230. return
  231. }
  232. activityId, _ := this.GetInt("ActivityId")
  233. if activityId < 1 {
  234. br.Msg = "活动不存在"
  235. return
  236. }
  237. activityInfo, _ := cygx.GetAddActivityInfoById(activityId)
  238. if activityInfo == nil {
  239. br.Msg = "活动不存在"
  240. br.ErrMsg = "活动ID错误,Err:activityId:" + strconv.Itoa(activityId)
  241. return
  242. }
  243. //超级管理员和权益管理员、权益研究员可以下载所有客户,销售组长能下载本组客户,销售只能下载本人名下客户
  244. resp := new(cygx.CanDownload)
  245. adminInfo, errAdmin := system.GetSysUserById(sysUser.AdminId)
  246. if errAdmin != nil {
  247. br.Msg = "获取失败"
  248. br.ErrMsg = "获取失败,Err:" + errAdmin.Error()
  249. return
  250. }
  251. if adminInfo.Role == "admin" || adminInfo.Role == "researcher" {
  252. resp.IsCanDownload = true
  253. }
  254. memberType := "Admin"
  255. sqlStr := ` AND s.do_fail_type = 0 `
  256. totalStr := sqlStr
  257. if resp.IsCanDownload == false && (activityInfo.ActivityTypeId == 1 || activityInfo.ActivityTypeId == 2 || activityInfo.ActivityTypeId == 3 || activityInfo.IsYidongConduct == 1) {
  258. if adminInfo.RoleTypeCode == "rai_group" {
  259. //组长查看本组所有组员
  260. memberType = "GroupLeader"
  261. sqlStr += ` AND s.company_id IN (SELECT company_id FROM user_seller_relation WHERE seller_id IN (SELECT admin_id FROM admin WHERE group_id = (SELECT group_id FROM admin WHERE admin_id = ` + strconv.Itoa(sysUser.AdminId) + ` ) )) `
  262. } else {
  263. //组员查看自己
  264. memberType = "Sale"
  265. sqlStr += ` AND s.company_id IN (SELECT company_id FROM user_seller_relation WHERE seller_id = ` + strconv.Itoa(sysUser.AdminId) + `) `
  266. }
  267. }
  268. list, err := cygx.GetCygxAppointmentList(activityId, sqlStr)
  269. if err != nil {
  270. br.Msg = "获取失败"
  271. br.ErrMsg = "获取失败,Err:" + err.Error()
  272. return
  273. }
  274. totalStr += " AND s.company_id != 16 "
  275. total, errtotal := cygx.GetCygxAppointmentCount(activityId, totalStr)
  276. if errtotal != nil {
  277. br.Msg = "获取失败"
  278. br.ErrMsg = "客户总数获取失败,Err:" + errtotal.Error()
  279. return
  280. }
  281. myTotal, errmyTotal := cygx.GetCygxAppointmentCount(activityId, sqlStr)
  282. if errmyTotal != nil {
  283. br.Msg = "获取失败"
  284. br.ErrMsg = "我的客户总数获取失败,Err:" + errmyTotal.Error()
  285. return
  286. }
  287. for k, v := range list {
  288. //公司调研电话会的活动,研选扣点的展示自主拨入,非扣点的展示预约外呼
  289. //if activityInfo.ActivityTypeId == 3 {
  290. // if activityInfo.IsResearchPoints == 1 {
  291. // v.SignupType = 2
  292. // } else {
  293. // v.SignupType = 1
  294. // }
  295. //}
  296. list[k].SellerName = v.PsellerName
  297. }
  298. respList := new(cygx.GetAppointmentListRep)
  299. respList.List = list
  300. respList.Total = total
  301. respList.MyTotal = myTotal
  302. respList.ActivityId = activityId
  303. respList.IsLimitPeople = activityInfo.IsLimitPeople
  304. respList.MemberType = memberType
  305. respList.IsResearchPoints = activityInfo.IsResearchPoints
  306. activityTypeId := activityInfo.ActivityTypeId
  307. //ExcelType string `description:"EXcel下载类型 AppointmentCall:预约外呼、ExpertSalon:专家沙龙报名、Teleconference:公司调研电话会、OfflineResearch:公司线下调研 "`
  308. if activityTypeId == 1 || activityTypeId == 2 {
  309. respList.ExcelType = "AppointmentCall"
  310. } else if activityTypeId == 5 || activityTypeId == 6 {
  311. respList.ExcelType = "ExpertSalon"
  312. } else if activityTypeId == 3 {
  313. respList.ExcelType = "Teleconference"
  314. } else if activityTypeId == 4 {
  315. respList.ExcelType = "OfflineResearch"
  316. } else if activityTypeId == 7 {
  317. respList.ExcelType = "CClass"
  318. }
  319. if activityInfo.YidongActivityId != "" {
  320. respList.ExcelType = "YiDong"
  321. }
  322. respList.IsYidongConduct = activityInfo.IsYidongConduct
  323. br.Ret = 200
  324. br.Success = true
  325. br.Msg = "获取成功"
  326. br.Data = respList
  327. }
  328. // @Title 外呼人员列表
  329. // @Description 获取外呼人员列表接口
  330. // @Param KeyWord query string false "搜索关键词"
  331. // @Success 200 {object} cygx.GetOutboundPersonnelListRep
  332. // @router /activitySignup/userList [get]
  333. func (this *ActivitySignupCoAntroller) OutboundPersonnelList() {
  334. br := new(models.BaseResponse).Init()
  335. defer func() {
  336. this.Data["json"] = br
  337. this.ServeJSON()
  338. }()
  339. keyWord := this.GetString("KeyWord")
  340. sysUser := this.SysUser
  341. if sysUser == nil {
  342. br.Msg = "请登录"
  343. br.ErrMsg = "请登录,SysUser Is Empty"
  344. return
  345. }
  346. if keyWord == "" {
  347. br.Msg = "请输入姓名"
  348. return
  349. }
  350. list, err := cygx.GetOutboundPersonnelList(keyWord)
  351. if err != nil {
  352. br.Msg = "获取失败"
  353. br.ErrMsg = "获取数据失败,Err:" + err.Error()
  354. return
  355. }
  356. for k, v := range list {
  357. if len(v.Mobile) > 7 {
  358. list[k].Mobile = v.Mobile[0:3] + "****" + v.Mobile[7:]
  359. }
  360. }
  361. resp := new(cygx.GetOutboundPersonnelListRep)
  362. resp.List = list
  363. br.Ret = 200
  364. br.Success = true
  365. br.Msg = "获取成功"
  366. br.Data = resp
  367. }
  368. // @Title 新增外呼人员
  369. // @Description 新增外呼人员接口
  370. // @Param request body cygx.AddMeetingReminderReq true "type json string"
  371. // @Success 200 操作成功
  372. // @router /activitySignup/addUser [post]
  373. func (this *ActivitySignupCoAntroller) AddUser() {
  374. br := new(models.BaseResponse).Init()
  375. defer func() {
  376. this.Data["json"] = br
  377. this.ServeJSON()
  378. }()
  379. AdminUser := this.SysUser
  380. if AdminUser == nil {
  381. br.Msg = "请登录"
  382. br.ErrMsg = "请登录,SysUser Is Empty"
  383. return
  384. }
  385. var req cygx.AddMeetingReminderReq
  386. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  387. if err != nil {
  388. br.Msg = "参数解析异常!"
  389. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  390. return
  391. }
  392. var items []*cygx.CygxActivitySignup
  393. var itemsYidong []*cygx.YidongActivitySignup
  394. var itemsAppointment []*cygx.CygxActivityAppointment
  395. activityIds := req.ActivityIds
  396. uidList := req.List
  397. if activityIds == "" {
  398. br.Msg = "请选择活动"
  399. br.ErrMsg = "活动ID不能为空"
  400. return
  401. }
  402. activityIdList := strings.Split(activityIds, ",")
  403. var uids string
  404. for _, v := range uidList {
  405. uids += strconv.Itoa(v.UserId) + ","
  406. }
  407. uids = strings.TrimRight(uids, ",")
  408. for _, v := range uidList {
  409. uid := v.UserId
  410. wxUser, userErr := models.GetWxUserByUserId(uid)
  411. if userErr != nil {
  412. br.Msg = "编辑失败!查询用户信息失败"
  413. br.ErrMsg = "查询用户信息失败,Err:" + userErr.Error() + "用户UID:" + strconv.Itoa(uid) + "不存在"
  414. return
  415. }
  416. for _, vact := range activityIdList {
  417. activityId, _ := strconv.Atoi(vact)
  418. activityInfo, err := cygx.GetAddActivityInfoById(activityId)
  419. if err != nil {
  420. br.Msg = "活动不存在"
  421. br.ErrMsg = "活动ID错误,Err:activityId:" + strconv.Itoa(activityId)
  422. return
  423. }
  424. if activityInfo.YidongActivityId != "" {
  425. errMsg := cygxService.CheckYidongActivitySignupTime(activityInfo)
  426. if errMsg != "" {
  427. br.Msg = errMsg
  428. br.ErrMsg = errMsg + "Err:activityId:" + strconv.Itoa(activityId)
  429. return
  430. }
  431. }
  432. limitPeopleNum, _ := strconv.Atoi(activityInfo.LimitPeopleNum)
  433. //if limitPeopleNum > 0 {
  434. if AdminUser.RoleTypeCode != "admin" {
  435. //havePower := cygxService.CheckaddSignuUserPower(wxUser.CompanyId, activityId, activityInfo)
  436. havePower, err := cygxService.GetActivityDetailUserPower(wxUser, AdminUser, activityInfo)
  437. if err != nil {
  438. br.Msg = "用户权限校验失败!"
  439. br.ErrMsg = "GetActivityDetailUserPower,Err:" + err.Error() + fmt.Sprint("UserId", wxUser.UserId, "ActivityId:", activityInfo.ActivityId)
  440. return
  441. }
  442. if !havePower {
  443. br.Msg = "当前活动对该客户不可见,无法报名"
  444. br.ErrMsg = "活动ID:" + strconv.Itoa(activityId) + "活动名称:" + activityInfo.ActivityName + "用户ID:" + strconv.Itoa(int(wxUser.UserId))
  445. return
  446. }
  447. //}
  448. if activityInfo.IsLimitPeople == 1 {
  449. //获取这个活动已经报名的用户数量
  450. totalSignup, errSignup := cygx.GetActivitySignupCountByActivityId(activityId)
  451. if errSignup != nil {
  452. br.Msg = "获取失败"
  453. br.ErrMsg = "获取失败,Err:" + errSignup.Error()
  454. return
  455. }
  456. //获取这个活动中输入的这些用户的报名数量
  457. totalThisUser, errThisUser := cygx.GetActivitySignupCountByThisUser(activityId, uids)
  458. if errThisUser != nil {
  459. br.Msg = "获取失败"
  460. br.ErrMsg = "获取失败,Err:" + errThisUser.Error()
  461. return
  462. }
  463. //如果是限制人数的就做报名人数限制判断
  464. if activityInfo.IsLimitPeople == 1 {
  465. if limitPeopleNum < totalSignup+len(uidList)-totalThisUser {
  466. br.Msg = "新增失败,活动人数超限"
  467. br.ErrMsg = "当前活动报名人数已满,活动:" + activityInfo.ActivityName
  468. return
  469. }
  470. }
  471. }
  472. }
  473. total, errtotal := cygx.GetActivitySignupCount(uid, activityId)
  474. if errtotal != nil {
  475. br.Msg = "获取失败"
  476. br.ErrMsg = "获取失败,Err:" + errtotal.Error()
  477. return
  478. }
  479. if total == 0 {
  480. infoUser, err := cygx.GetUserAndCompanyNameList(uid)
  481. if err != nil {
  482. br.Msg = "获取失败"
  483. br.ErrMsg = "获取数据失败,Err:" + err.Error()
  484. return
  485. }
  486. item := new(cygx.CygxActivitySignup)
  487. item.UserId = infoUser.UserId
  488. item.RealName = infoUser.RealName
  489. item.SellerName = infoUser.SellerName
  490. item.ActivityId = activityId
  491. item.CreateTime = time.Now()
  492. item.Mobile = infoUser.Mobile
  493. item.Email = infoUser.Email
  494. item.CompanyId = infoUser.CompanyId
  495. item.CompanyName = infoUser.CompanyName
  496. item.Source = 2
  497. //优先绑定用户修改过的外呼手机号
  498. if infoUser.OutboundMobile != "" {
  499. item.OutboundMobile = infoUser.OutboundMobile
  500. if infoUser.OutboundCountryCode == "" {
  501. item.CountryCode = "86"
  502. } else {
  503. item.CountryCode = infoUser.OutboundCountryCode
  504. }
  505. } else {
  506. item.OutboundMobile = infoUser.Mobile
  507. if infoUser.CountryCode == "" {
  508. item.CountryCode = "86"
  509. } else {
  510. item.CountryCode = infoUser.CountryCode
  511. }
  512. }
  513. item.SignupType = 1
  514. items = append(items, item)
  515. if activityInfo.YidongActivityId != "" {
  516. //测试环境下弘则下面的用户才收到消息
  517. if utils.RunMode != "release" && item.CompanyId == 16 {
  518. itemYidong := new(cygx.YidongActivitySignup)
  519. itemYidong.YidongActivityId = activityInfo.YidongActivityId
  520. itemYidong.Mobile = item.Mobile
  521. itemYidong.RealName = item.RealName
  522. itemYidong.CompanyName = item.CompanyName
  523. itemYidong.CountryCode = item.CountryCode
  524. itemsYidong = append(itemsYidong, itemYidong)
  525. }
  526. }
  527. }
  528. if v.IsAppointment == 1 {
  529. //var isHideAppointment bool
  530. //if activityInfo.IsHideAppointment == 0 {
  531. // isHideAppointment = cygxService.IsShowAppointmentByadminSet(activityInfo.IsCanAppointmentMinutes)
  532. //}
  533. if activityInfo.IsCanAppointmentMinutes == 0 {
  534. br.Msg = "该活动无法预约纪要"
  535. br.ErrMsg = "该活动无法预约纪要,Err:" + activityInfo.ActivityName
  536. return
  537. }
  538. total, errtotal := cygx.GetUserCygxActivityAppointmentCount(uid, activityId)
  539. if errtotal != nil {
  540. br.Msg = "获取失败"
  541. br.ErrMsg = "获取失败,Err:" + errtotal.Error()
  542. return
  543. }
  544. //判断这个用户是否报名了,如果没有报名则写入报名数据
  545. if total == 0 {
  546. infoUser, err := cygx.GetUserAndCompanyNameList(uid)
  547. if err != nil {
  548. br.Msg = "获取失败"
  549. br.ErrMsg = "获取数据失败,Err:" + err.Error()
  550. return
  551. }
  552. itemAppointment := new(cygx.CygxActivityAppointment)
  553. itemAppointment.UserId = infoUser.UserId
  554. itemAppointment.RealName = infoUser.RealName
  555. itemAppointment.SellerName = infoUser.SellerName
  556. itemAppointment.ActivityId = activityId
  557. itemAppointment.CreateTime = time.Now()
  558. itemAppointment.Mobile = infoUser.Mobile
  559. itemAppointment.Email = infoUser.Email
  560. itemAppointment.CompanyId = infoUser.CompanyId
  561. itemAppointment.CompanyName = infoUser.CompanyName
  562. itemAppointment.AdminId = AdminUser.AdminId
  563. itemAppointment.Source = 2
  564. itemsAppointment = append(itemsAppointment, itemAppointment)
  565. }
  566. }
  567. }
  568. }
  569. mapYidongActivity := make(map[int]int)
  570. err = cygx.AddCygxActivitySignup(items, itemsAppointment, mapYidongActivity)
  571. if err != nil {
  572. br.Msg = "操作失败"
  573. br.ErrMsg = "新增用户失败,Err:" + err.Error()
  574. return
  575. }
  576. //如果有值就向易董推送后台添加的报名信息
  577. if len(itemsYidong) > 0 {
  578. go cygxService.YidongActivityUserSingnUp(itemsYidong)
  579. }
  580. //添加操作日志记录
  581. br.Ret = 200
  582. br.Success = true
  583. br.Msg = "操作成功"
  584. br.IsAddLog = true
  585. }
  586. // @Title 报名失败详情列表
  587. // @Description 获取沙龙报名失败详情列表接口
  588. // @Param ActivityId query int true "活动ID"
  589. // @Success 200 {object} cygx.GetFailSignupListRep
  590. // @router /activitySignup/salonFailSignupList [get]
  591. func (this *ActivitySignupCoAntroller) SalonFailSignupList() {
  592. br := new(models.BaseResponse).Init()
  593. defer func() {
  594. this.Data["json"] = br
  595. this.ServeJSON()
  596. }()
  597. sysUser := this.SysUser
  598. if sysUser == nil {
  599. br.Msg = "请登录"
  600. br.ErrMsg = "请登录,SysUser Is Empty"
  601. return
  602. }
  603. respList := new(cygx.GetFailSignupListRep)
  604. activityId, _ := this.GetInt("ActivityId")
  605. activityInfo, _ := cygx.GetAddActivityInfoById(activityId)
  606. if activityInfo == nil {
  607. br.Msg = "活动不存在"
  608. br.ErrMsg = "活动ID错误,Err:activityId:" + strconv.Itoa(activityId)
  609. return
  610. }
  611. //超级管理员和权益管理员、权益研究员可以下载所有客户,销售组长能下载本组客户,销售只能下载本人名下客户
  612. resp := new(cygx.CanDownload)
  613. adminInfo, errAdmin := system.GetSysUserById(sysUser.AdminId)
  614. if errAdmin != nil {
  615. br.Msg = "获取失败"
  616. br.ErrMsg = "获取失败,Err:" + errAdmin.Error()
  617. return
  618. }
  619. if adminInfo.Role == "admin" || adminInfo.Role == "researcher" {
  620. resp.IsCanDownload = true
  621. }
  622. memberType := "Admin"
  623. sqlStr := ""
  624. if resp.IsCanDownload == false && (activityInfo.ActivityTypeId == 1 || activityInfo.ActivityTypeId == 2 || activityInfo.ActivityTypeId == 3) {
  625. if adminInfo.RoleTypeCode == "rai_group" {
  626. //组长查看本组所有组员
  627. memberType = "GroupLeader"
  628. sqlStr = ` AND s.user_id IN (SELECT user_id FROM user_seller_relation WHERE seller_id IN (SELECT admin_id FROM admin WHERE group_id = (SELECT group_id FROM admin WHERE admin_id = ` + strconv.Itoa(sysUser.AdminId) + ` ) )) `
  629. } else {
  630. //组员查看自己
  631. memberType = "Sale"
  632. sqlStr = ` AND s.user_id IN (SELECT user_id FROM user_seller_relation WHERE seller_id = ` + strconv.Itoa(sysUser.AdminId) + `) `
  633. }
  634. }
  635. sqlStr += ` AND s.fail_type >0 `
  636. list, err := cygx.GetFailSignupList(activityId, sqlStr)
  637. if err != nil {
  638. br.Msg = "获取失败"
  639. br.ErrMsg = "获取失败,Err:" + err.Error()
  640. return
  641. }
  642. sqlStrtotal := ` AND s.fail_type >0 `
  643. total, errtotal := cygx.GetCygxAppointmentCount(activityId, sqlStrtotal)
  644. if errtotal != nil {
  645. br.Msg = "获取失败"
  646. br.ErrMsg = "客户总数获取失败,Err:" + errtotal.Error()
  647. return
  648. }
  649. myTotalsqlStr := ` AND s.user_id IN (SELECT user_id FROM user_seller_relation WHERE seller_id = ` + strconv.Itoa(sysUser.AdminId) + `) AND s.fail_type >0 `
  650. myTotal, errmyTotal := cygx.GetCygxAppointmentCount(activityId, myTotalsqlStr)
  651. if errmyTotal != nil {
  652. br.Msg = "获取失败"
  653. br.ErrMsg = "我的客户总数获取失败,Err:" + errmyTotal.Error()
  654. return
  655. }
  656. if activityInfo.IsLimitPeople > 0 {
  657. //获取这个活动已经报名的用户数量
  658. totalSignup, errSignup := cygx.GetActivitySignupCountByActivityId(activityId)
  659. if errSignup != nil {
  660. br.Msg = "获取信息失败"
  661. br.ErrMsg = "获取数量失败,Err:" + errSignup.Error()
  662. return
  663. }
  664. limitPeopleNum, err := strconv.Atoi(activityInfo.LimitPeopleNum)
  665. if err != nil {
  666. br.Msg = "获取信息失败"
  667. br.ErrMsg = "数据转换失败,Err:" + err.Error()
  668. return
  669. }
  670. //如果报名人数不小于限制人数,则报名人数已满
  671. if limitPeopleNum <= totalSignup {
  672. respList.IsFull = true
  673. }
  674. }
  675. for k, v := range list {
  676. if v.DoFailType == 0 {
  677. list[k].SalonOperation = true
  678. list[k].CallOperation = v.SignupType
  679. } else {
  680. list[k].CallOperation = 3
  681. }
  682. }
  683. respList.List = list
  684. respList.Total = total
  685. respList.MyTotal = myTotal
  686. respList.IsLimitPeople = activityInfo.IsLimitPeople
  687. respList.MemberType = memberType
  688. activityTypeId := activityInfo.ActivityTypeId
  689. if activityTypeId == 1 || activityTypeId == 2 {
  690. respList.ExcelType = "AppointmentCall"
  691. } else if activityTypeId == 5 || activityTypeId == 6 {
  692. respList.ExcelType = "ExpertSalon"
  693. } else if activityTypeId == 3 {
  694. respList.ExcelType = "Teleconference"
  695. } else if activityTypeId == 4 {
  696. respList.ExcelType = "OfflineResearch"
  697. }
  698. br.Ret = 200
  699. br.Success = true
  700. br.Msg = "获取成功"
  701. br.Data = respList
  702. }
  703. // @Title 沙龙限制报名、加入报名
  704. // @Description 修改沙龙限制报名、加入报名接口
  705. // @Param request body cygx.SignupId true "type json string"
  706. // @Success 200 操作成功
  707. // @router /activitySignup/salonSignupEdit [post]
  708. func (this *ActivitySignupCoAntroller) SalonSignupEdit() {
  709. br := new(models.BaseResponse).Init()
  710. defer func() {
  711. this.Data["json"] = br
  712. this.ServeJSON()
  713. }()
  714. AdminUser := this.SysUser
  715. if AdminUser == nil {
  716. br.Msg = "请登录"
  717. br.ErrMsg = "请登录,SysUser Is Empty"
  718. return
  719. }
  720. var req cygx.SignupId
  721. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  722. if err != nil {
  723. br.Msg = "参数解析异常!"
  724. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  725. return
  726. }
  727. id := req.Id
  728. total, err := cygx.GetCygxSignupCountFile(id)
  729. if err != nil {
  730. br.Msg = "获取失败"
  731. br.ErrMsg = "获取失败,Err:" + err.Error()
  732. return
  733. }
  734. if total == 0 {
  735. br.Msg = "获取报名信息失败"
  736. br.ErrMsg = "获取失败,id:" + strconv.Itoa(id)
  737. return
  738. }
  739. detail, err := cygx.GetCygxSignupDetailById(id)
  740. if err != nil {
  741. br.Msg = "操作失败"
  742. br.ErrMsg = "操作失败,Err:" + err.Error()
  743. return
  744. }
  745. newIsAdminAddSignup := 0
  746. if detail.IsAdminAddSignup == 1 {
  747. newIsAdminAddSignup = 0
  748. } else {
  749. newIsAdminAddSignup = 1
  750. activityInfo, err := cygx.GetAddActivityInfoById(detail.ActivityId)
  751. if err != nil {
  752. br.Msg = "活动不存在"
  753. br.ErrMsg = "活动ID错误,Err:" + err.Error() + "activityId:" + strconv.Itoa(detail.ActivityId)
  754. return
  755. }
  756. if activityInfo.IsLimitPeople > 0 {
  757. //获取这个活动已经报名的用户数量
  758. totalSignup, errSignup := cygx.GetActivitySignupCountByActivityId(detail.ActivityId)
  759. if errSignup != nil {
  760. br.Msg = "操作失败"
  761. br.ErrMsg = "获取数量失败,Err:" + errSignup.Error()
  762. return
  763. }
  764. limitPeopleNum, err := strconv.Atoi(activityInfo.LimitPeopleNum)
  765. if err != nil {
  766. br.Msg = "操作失败"
  767. br.ErrMsg = "数据转换失败,Err:" + err.Error()
  768. return
  769. }
  770. if limitPeopleNum <= totalSignup {
  771. br.Msg = "新增失败,活动人数超限"
  772. return
  773. }
  774. adminInfo, errAdmin := system.GetSysUserById(AdminUser.AdminId)
  775. if errAdmin != nil {
  776. br.Msg = "获取失败"
  777. br.ErrMsg = "获取失败,Err:" + errAdmin.Error()
  778. return
  779. }
  780. //如果操作的不是管理员就做下面的限制
  781. if adminInfo.Role != "admin" {
  782. activityId := detail.ActivityId
  783. //单机构两人限制
  784. {
  785. totalSignupCompany, err := cygx.GetActivitySignupCompanyCount(activityId, detail.CompanyId)
  786. if err != nil {
  787. br.Msg = "获取信息失败"
  788. br.ErrMsg = "获取客户信息失败,Err:" + err.Error()
  789. return
  790. }
  791. if totalSignupCompany >= 2 {
  792. br.Msg = "新增失败,单机构最多2人报名同一活动。"
  793. br.ErrMsg = "新增失败,单机构最多2人报名同一活动。" + fmt.Sprint("activityId:", activityId, detail.Mobile)
  794. return
  795. }
  796. }
  797. //爽约限制
  798. //{
  799. // totalRestrict, err := cygx.GetUserRestrictCount(detail.Mobile)
  800. // if err != nil {
  801. // br.Msg = "获取信息失败"
  802. // br.ErrMsg = "获取客户信息失败,Err:" + err.Error()
  803. // return
  804. // }
  805. // if totalRestrict >= 1 {
  806. // br.Msg = "新增失败," + detail.RealName + "爽约次数过多。"
  807. // br.ErrMsg = detail.RealName + "由于爽约次数过多,暂时被限制报名资格"
  808. // return
  809. // }
  810. //}
  811. }
  812. }
  813. }
  814. var doFailType int
  815. if newIsAdminAddSignup == 1 {
  816. doFailType = 0
  817. } else {
  818. doFailType = detail.FailType
  819. }
  820. infoUser, err := cygx.GetUserAndCompanyNameList(detail.UserId)
  821. if err != nil {
  822. br.Msg = "获取失败"
  823. br.ErrMsg = "获取数据失败,Err:" + err.Error()
  824. return
  825. }
  826. item := new(cygx.CygxActivitySignup)
  827. item.UserId = infoUser.UserId
  828. item.RealName = infoUser.RealName
  829. item.SellerName = infoUser.SellerName
  830. item.ActivityId = detail.ActivityId
  831. item.CreateTime = time.Now()
  832. item.Mobile = infoUser.Mobile
  833. item.Email = infoUser.Email
  834. item.CompanyId = infoUser.CompanyId
  835. item.CompanyName = infoUser.CompanyName
  836. err = cygx.SalonSignupEdit(newIsAdminAddSignup, doFailType, id, item)
  837. if err != nil {
  838. br.Msg = "修改失败"
  839. br.ErrMsg = "修改失败 Err:" + err.Error()
  840. return
  841. }
  842. var itemsSendWxMsg []*cygx.CygxSignupUser
  843. itemsSendWxMsg = append(itemsSendWxMsg, &cygx.CygxSignupUser{UserId: infoUser.UserId, ActivityId: detail.ActivityId})
  844. //销售或后台管理员给用户添加报名之后,进行模版消息推送
  845. if doFailType == 0 {
  846. go cygxService.SendWxMsgWithCygxActivitySignUpBySell(itemsSendWxMsg)
  847. }
  848. //添加操作日志记录
  849. br.Ret = 200
  850. br.Success = true
  851. br.Msg = "操作成功"
  852. br.IsAddLog = true
  853. }
  854. // @Title 公司调研电话会报名失败详情列表
  855. // @Description 获取公司调研电话会报名失败详情列表接口
  856. // @Param ActivityId query int true "活动ID"
  857. // @Success 200 {object} cygx.GetFailSignupListRep
  858. // @router /activitySignup/callFailSignupList [get]
  859. func (this *ActivitySignupCoAntroller) FailSignupList() {
  860. br := new(models.BaseResponse).Init()
  861. defer func() {
  862. this.Data["json"] = br
  863. this.ServeJSON()
  864. }()
  865. sysUser := this.SysUser
  866. if sysUser == nil {
  867. br.Msg = "请登录"
  868. br.ErrMsg = "请登录,SysUser Is Empty"
  869. return
  870. }
  871. activityId, _ := this.GetInt("ActivityId")
  872. activityInfo, _ := cygx.GetAddActivityInfoById(activityId)
  873. if activityInfo == nil {
  874. br.Msg = "活动不存在"
  875. br.ErrMsg = "活动ID错误,Err:activityId:" + strconv.Itoa(activityId)
  876. return
  877. }
  878. //超级管理员和权益管理员、权益研究员可以下载所有客户,销售组长能下载本组客户,销售只能下载本人名下客户
  879. resp := new(cygx.CanDownload)
  880. adminInfo, errAdmin := system.GetSysUserById(sysUser.AdminId)
  881. if errAdmin != nil {
  882. br.Msg = "获取失败"
  883. br.ErrMsg = "获取失败,Err:" + errAdmin.Error()
  884. return
  885. }
  886. if adminInfo.Role == "admin" || adminInfo.Role == "researcher" {
  887. resp.IsCanDownload = true
  888. }
  889. var list []*cygx.FailSignupListRep
  890. memberType := "Admin"
  891. var err error
  892. sqlStr := ""
  893. if resp.IsCanDownload == false && (activityInfo.ActivityTypeId == 1 || activityInfo.ActivityTypeId == 2 || activityInfo.ActivityTypeId == 3) {
  894. if adminInfo.RoleTypeCode == "rai_group" {
  895. //组长查看本组所有组员
  896. memberType = "GroupLeader"
  897. sqlStr = ` AND s.user_id IN (SELECT user_id FROM user_seller_relation WHERE seller_id IN (SELECT admin_id FROM admin WHERE group_id = (SELECT group_id FROM admin WHERE admin_id = ` + strconv.Itoa(sysUser.AdminId) + ` ) )) `
  898. } else {
  899. //组员查看自己
  900. memberType = "Sale"
  901. sqlStr = ` AND s.user_id IN (SELECT user_id FROM user_seller_relation WHERE seller_id = ` + strconv.Itoa(sysUser.AdminId) + `) `
  902. }
  903. }
  904. sqlStr += ` AND s.fail_type >0 `
  905. listSeller, errSeller := cygx.GetFailSignupList(activityId, sqlStr)
  906. list = listSeller
  907. err = errSeller
  908. if err != nil {
  909. br.Msg = "获取失败"
  910. br.ErrMsg = "获取失败,Err:" + err.Error()
  911. return
  912. }
  913. total, errtotal := cygx.GetCygxAppointmentCount(activityId, "")
  914. if errtotal != nil {
  915. br.Msg = "获取失败"
  916. br.ErrMsg = "客户总数获取失败,Err:" + errtotal.Error()
  917. return
  918. }
  919. myTotalsqlStr := ` AND s.user_id IN (SELECT user_id FROM user_seller_relation WHERE seller_id = ` + strconv.Itoa(sysUser.AdminId) + `) `
  920. myTotal, errmyTotal := cygx.GetCygxAppointmentCount(activityId, myTotalsqlStr)
  921. if errmyTotal != nil {
  922. br.Msg = "获取失败"
  923. br.ErrMsg = "我的客户总数获取失败,Err:" + errmyTotal.Error()
  924. return
  925. }
  926. var listNew []*cygx.FailSignupListRep
  927. for k, v := range list {
  928. if k > 0 && list[k].Id == list[k-1].Id {
  929. list[k-1].SellerName = list[k-1].SellerName + "/" + v.SellerName
  930. }
  931. }
  932. for k, v := range list {
  933. if k > 0 && list[k].Id != list[k-1].Id {
  934. listNew = append(listNew, v)
  935. }
  936. if k == 0 && len(list) >= 2 && list[1].Id == list[0].Id {
  937. listNew = append(listNew, v)
  938. }
  939. }
  940. for k, v := range listNew {
  941. if v.IsAdminAddSignup == 0 {
  942. listNew[k].CallOperation = 3
  943. } else {
  944. listNew[k].CallOperation = v.MeetingType
  945. }
  946. }
  947. respList := new(cygx.GetFailSignupListRep)
  948. respList.List = listNew
  949. respList.Total = total
  950. respList.MyTotal = myTotal
  951. respList.IsLimitPeople = activityInfo.IsLimitPeople
  952. respList.MemberType = memberType
  953. activityTypeId := activityInfo.ActivityTypeId
  954. //ExcelType string `description:"EXcel下载类型 AppointmentCall:预约外呼、ExpertSalon:专家沙龙报名、Teleconference:公司调研电话会、OfflineResearch:公司线下调研 "`
  955. if activityTypeId == 1 || activityTypeId == 2 {
  956. respList.ExcelType = "AppointmentCall"
  957. } else if activityTypeId == 5 || activityTypeId == 6 {
  958. respList.ExcelType = "ExpertSalon"
  959. } else if activityTypeId == 3 {
  960. respList.ExcelType = "Teleconference"
  961. } else if activityTypeId == 4 {
  962. respList.ExcelType = "OfflineResearch"
  963. }
  964. br.Ret = 200
  965. br.Success = true
  966. br.Msg = "获取成功"
  967. br.Data = respList
  968. }
  969. // @Title 修改公司调研电话会限制报名、预约外呼、自主拨入
  970. // @Description 修改公司调研电话会限制报名、预约外呼、自主拨入接口
  971. // @Param request body cygx.SignupIdCall true "type json string"
  972. // @Success 200 操作成功
  973. // @router /activitySignup/callSignupEdit [post]
  974. func (this *ActivitySignupCoAntroller) CallSignupEdit() {
  975. br := new(models.BaseResponse).Init()
  976. defer func() {
  977. this.Data["json"] = br
  978. this.ServeJSON()
  979. }()
  980. sysUser := this.SysUser
  981. if sysUser == nil {
  982. br.Msg = "请登录"
  983. br.ErrMsg = "请登录,SysUser Is Empty"
  984. return
  985. }
  986. var req cygx.SignupIdCall
  987. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  988. if err != nil {
  989. br.Msg = "参数解析异常!"
  990. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  991. return
  992. }
  993. id := req.Id
  994. operationStatus := req.OperationStatus
  995. total, err := cygx.GetCygxSignupCountFile(id)
  996. if err != nil {
  997. br.Msg = "获取失败"
  998. br.ErrMsg = "获取失败,Err:" + err.Error()
  999. return
  1000. }
  1001. if total == 0 {
  1002. br.Msg = "获取报名信息失败"
  1003. br.ErrMsg = "获取失败,id:" + strconv.Itoa(id)
  1004. return
  1005. }
  1006. detail, err := cygx.GetCygxSignupDetailById(id)
  1007. if err != nil {
  1008. br.Msg = "操作失败"
  1009. br.ErrMsg = "操作失败,Err:" + err.Error()
  1010. return
  1011. }
  1012. uid := detail.UserId
  1013. var doFailType int
  1014. infoUser, err := cygx.GetUserAndCompanyNameList(uid)
  1015. if err != nil {
  1016. br.Msg = "获取失败"
  1017. br.ErrMsg = "获取数据失败,Err:" + err.Error()
  1018. return
  1019. }
  1020. item := new(cygx.CygxMySchedule)
  1021. item.UserId = infoUser.UserId
  1022. item.CreateTime = time.Now()
  1023. item.Mobile = infoUser.Mobile
  1024. item.ActivityId = detail.ActivityId
  1025. item.Email = infoUser.Email
  1026. item.CompanyId = infoUser.CompanyId
  1027. item.CompanyName = infoUser.CompanyName
  1028. if operationStatus == 1 {
  1029. doFailType = 0
  1030. } else {
  1031. doFailType = detail.FailType
  1032. }
  1033. var errEdit error
  1034. if operationStatus == 3 {
  1035. err3 := cygx.CallSignupEditByStatus3(id, doFailType, item)
  1036. errEdit = err3
  1037. } else {
  1038. err1_2 := cygx.CallSignupEditByStatus1_2(operationStatus, id, item)
  1039. errEdit = err1_2
  1040. }
  1041. if errEdit != nil {
  1042. br.Msg = "修改失败"
  1043. br.ErrMsg = "修改失败 Err:" + errEdit.Error()
  1044. return
  1045. }
  1046. br.Ret = 200
  1047. br.Success = true
  1048. br.Msg = "操作成功"
  1049. br.IsAddLog = true
  1050. }
  1051. // @Title 预约外呼详情、公司调研电话会excel表格下载
  1052. // @Description 获取预约外呼详情、公司调研电话会excel表格下载接口
  1053. // @Param ActivityId query int true "活动ID"
  1054. // @Success 200 导出成功
  1055. // @router /activitySignup/callExport [get]
  1056. func (this *ActivitySignupCoAntroller) CallExport() {
  1057. br := new(models.BaseResponse).Init()
  1058. defer func() {
  1059. this.Data["json"] = br
  1060. this.ServeJSON()
  1061. }()
  1062. sysUser := this.SysUser
  1063. if sysUser == nil {
  1064. br.Msg = "请登录"
  1065. br.ErrMsg = "请登录,SysUser Is Empty"
  1066. return
  1067. }
  1068. activityId, _ := this.GetInt("ActivityId")
  1069. activityInfo, _ := cygx.GetAddActivityInfoById(activityId)
  1070. if activityInfo == nil {
  1071. br.Msg = "活动不存在"
  1072. br.ErrMsg = "活动ID错误,Err:activityId:" + strconv.Itoa(activityId)
  1073. return
  1074. }
  1075. //超级管理员和权益管理员、权益研究员可以下载所有客户,销售组长能下载本组客户,销售只能下载本人名下客户
  1076. resp := new(cygx.CanDownload)
  1077. adminInfo, errAdmin := system.GetSysUserById(sysUser.AdminId)
  1078. if errAdmin != nil {
  1079. br.Msg = "获取失败"
  1080. br.ErrMsg = "获取失败,Err:" + errAdmin.Error()
  1081. return
  1082. }
  1083. if adminInfo.Role == "admin" || adminInfo.Role == "researcher" {
  1084. resp.IsCanDownload = true
  1085. }
  1086. //var err error
  1087. sqlStr := " "
  1088. //if resp.IsCanDownload == false && (activityInfo.ActivityTypeId == 1 || activityInfo.ActivityTypeId == 2 || activityInfo.ActivityTypeId == 3) {
  1089. // if adminInfo.RoleTypeCode == "rai_group" {
  1090. // //组长查看本组所有组员
  1091. // sqlStr = ` AND s.user_id IN (SELECT user_id FROM user_seller_relation WHERE seller_id IN (SELECT admin_id FROM admin WHERE group_id = (SELECT group_id FROM admin WHERE admin_id = ` + strconv.Itoa(sysUser.AdminId) + ` ) )) `
  1092. // } else {
  1093. // //组员查看自己
  1094. // sqlStr = ` AND s.user_id IN (SELECT user_id FROM user_seller_relation WHERE seller_id = ` + strconv.Itoa(sysUser.AdminId) + `) `
  1095. // }
  1096. //}
  1097. //sqlStr += ` AND s.do_fail_type = 0 GROUP BY s.id`
  1098. //list, errSeller := cygx.GetSignupExport(activityId, sqlStr)
  1099. if resp.IsCanDownload == false && (activityInfo.ActivityTypeId == 1 || activityInfo.ActivityTypeId == 2 || activityInfo.ActivityTypeId == 3) {
  1100. if adminInfo.RoleTypeCode == "rai_group" {
  1101. //组长查看本组所有组员
  1102. sqlStr += ` AND s.company_id IN (SELECT company_id FROM user_seller_relation WHERE seller_id IN (SELECT admin_id FROM admin WHERE group_id = (SELECT group_id FROM admin WHERE admin_id = ` + strconv.Itoa(sysUser.AdminId) + ` ) )) `
  1103. } else {
  1104. //组员查看自己
  1105. sqlStr += ` AND s.company_id IN (SELECT company_id FROM user_seller_relation WHERE seller_id = ` + strconv.Itoa(sysUser.AdminId) + `) `
  1106. }
  1107. }
  1108. //公司调研电话会下载全部
  1109. if activityInfo.ActivityTypeId != 3 {
  1110. sqlStr += " AND s.signup_type = 1 "
  1111. }
  1112. list, err := cygx.GetCygxAppointmentList(activityId, sqlStr)
  1113. //err = errSeller
  1114. if err != nil {
  1115. br.Msg = "获取失败"
  1116. br.ErrMsg = "获取失败,Err:" + err.Error()
  1117. return
  1118. }
  1119. //会议提醒
  1120. listReminder, err := cygx.GetCygxActivityMeetingReminderList(activityId, sqlStr)
  1121. if err != nil {
  1122. br.Msg = "获取失败"
  1123. br.ErrMsg = "获取失败,Err:" + err.Error()
  1124. return
  1125. }
  1126. //预约纪要
  1127. listSummary, err := cygx.GetCygxAppointmentSummaryList(activityId, sqlStr)
  1128. if err != nil {
  1129. br.Msg = "获取失败"
  1130. br.ErrMsg = "获取失败,Err:" + err.Error()
  1131. return
  1132. }
  1133. //创建excel
  1134. dir, err := os.Executable()
  1135. exPath := filepath.Dir(dir)
  1136. downLoadnFilePath := exPath + "/" + time.Now().Format(utils.FormatDateTimeUnSpace) + ".xlsx"
  1137. xlsxFile := xlsx.NewFile()
  1138. if err != nil {
  1139. br.Msg = "生成文件失败"
  1140. br.ErrMsg = "生成文件失败"
  1141. return
  1142. }
  1143. style := xlsx.NewStyle()
  1144. alignment := xlsx.Alignment{
  1145. Horizontal: "center",
  1146. Vertical: "center",
  1147. WrapText: true,
  1148. }
  1149. style.Alignment = alignment
  1150. style.ApplyAlignment = true
  1151. for pidIndex := 0; pidIndex <= 2; pidIndex++ {
  1152. var sheetName string
  1153. var listDate []*cygx.CygxAppointmentList
  1154. if pidIndex == 0 {
  1155. if activityInfo.ActivityTypeId == 1 || activityInfo.ActivityTypeId == 2 {
  1156. sheetName = "预约外呼"
  1157. } else {
  1158. sheetName = "名单"
  1159. }
  1160. listDate = list
  1161. } else if pidIndex == 1 {
  1162. sheetName = "会议提醒"
  1163. listDate = listReminder
  1164. } else {
  1165. sheetName = "预约纪要"
  1166. listDate = listSummary
  1167. }
  1168. sheet, err := xlsxFile.AddSheet(sheetName)
  1169. if err != nil {
  1170. br.Msg = "新增Sheet失败"
  1171. br.ErrMsg = "新增Sheet失败,Err:" + err.Error()
  1172. return
  1173. }
  1174. //标头
  1175. if pidIndex == 0 {
  1176. //如果是公司调研电话会就下载邮箱
  1177. if activityInfo.ActivityTypeId == 3 {
  1178. rowTitle := sheet.AddRow()
  1179. cellA := rowTitle.AddCell()
  1180. cellA.Value = "姓名"
  1181. cellB := rowTitle.AddCell()
  1182. cellB.Value = "外呼号码"
  1183. cellC := rowTitle.AddCell()
  1184. cellC.Value = "国际代码"
  1185. cellD := rowTitle.AddCell()
  1186. cellD.Value = "邮箱"
  1187. cellE := rowTitle.AddCell()
  1188. cellE.Value = "公司名称"
  1189. cellF := rowTitle.AddCell()
  1190. cellF.Value = "所属销售"
  1191. for _, item := range listDate {
  1192. row := sheet.AddRow()
  1193. cellA := row.AddCell()
  1194. cellA.Value = item.RealName
  1195. cellB := row.AddCell()
  1196. cellB.Value = item.OutboundMobile
  1197. cellC := row.AddCell()
  1198. if item.CountryCode == "" {
  1199. cellC.Value = "86"
  1200. } else {
  1201. cellC.Value = item.CountryCode
  1202. }
  1203. cellD := row.AddCell()
  1204. cellD.Value = item.Email
  1205. cellE := row.AddCell()
  1206. cellE.Value = item.CompanyName
  1207. cellF := row.AddCell()
  1208. cellF.Value = item.SellerName
  1209. }
  1210. } else {
  1211. rowTitle := sheet.AddRow()
  1212. cellA := rowTitle.AddCell()
  1213. cellA.Value = "姓名"
  1214. cellB := rowTitle.AddCell()
  1215. cellB.Value = "外呼号码"
  1216. cellC := rowTitle.AddCell()
  1217. cellC.Value = "国际代码"
  1218. cellD := rowTitle.AddCell()
  1219. cellD.Value = "公司名称"
  1220. cellE := rowTitle.AddCell()
  1221. cellE.Value = "所属销售"
  1222. for _, item := range listDate {
  1223. row := sheet.AddRow()
  1224. cellA := row.AddCell()
  1225. cellA.Value = item.RealName
  1226. cellB := row.AddCell()
  1227. cellB.Value = item.OutboundMobile
  1228. cellC := row.AddCell()
  1229. if item.CountryCode == "" {
  1230. cellC.Value = "86"
  1231. } else {
  1232. cellC.Value = item.CountryCode
  1233. }
  1234. cellD := row.AddCell()
  1235. cellD.Value = item.CompanyName
  1236. cellE := row.AddCell()
  1237. cellE.Value = item.SellerName
  1238. }
  1239. }
  1240. } else {
  1241. rowTitle := sheet.AddRow()
  1242. cellA := rowTitle.AddCell()
  1243. cellA.Value = "姓名"
  1244. cellB := rowTitle.AddCell()
  1245. cellB.Value = "公司名称"
  1246. cellC := rowTitle.AddCell()
  1247. cellC.Value = "所属销售"
  1248. for _, item := range listDate {
  1249. row := sheet.AddRow()
  1250. cellA := row.AddCell()
  1251. cellA.Value = item.RealName
  1252. cellB := row.AddCell()
  1253. cellB.Value = item.CompanyName
  1254. cellC := row.AddCell()
  1255. cellC.Value = item.SellerName
  1256. }
  1257. }
  1258. }
  1259. err = xlsxFile.Save(downLoadnFilePath)
  1260. if err != nil {
  1261. br.Msg = "保存文件失败"
  1262. br.ErrMsg = "保存文件失败"
  1263. return
  1264. }
  1265. //randStr := time.Now().Format(utils.FormatDateTimeUnSpace)
  1266. downloadFileName := activityInfo.ActivityName + ".xlsx"
  1267. this.Ctx.Output.Download(downLoadnFilePath, downloadFileName)
  1268. defer func() {
  1269. os.Remove(downLoadnFilePath)
  1270. }()
  1271. br.Success = true
  1272. br.Ret = 200
  1273. br.IsAddLog = true
  1274. }
  1275. // @Title 公司线下调研、报名excel表格下载
  1276. // @Description 获取公司线下调研、报名excel表格下载接口
  1277. // @Param ActivityId query int true "活动ID"
  1278. // @Param ExcelType query int true "下载方式 0:全部名单、1:预约外呼名单、2:自主入会(自主拨入)名单"
  1279. // @Success 200 导出成功
  1280. // @router /activitySignup/signupFailExport [get]
  1281. func (this *ActivitySignupCoAntroller) SignupFailExport() {
  1282. br := new(models.BaseResponse).Init()
  1283. defer func() {
  1284. this.Data["json"] = br
  1285. this.ServeJSON()
  1286. }()
  1287. AdminUser := this.SysUser
  1288. if AdminUser == nil {
  1289. br.Msg = "请登录"
  1290. br.ErrMsg = "请登录,SysUser Is Empty"
  1291. return
  1292. }
  1293. activityId, _ := this.GetInt("ActivityId")
  1294. excelType, _ := this.GetInt("ExcelType")
  1295. //signupType := this.GetString("SignupType")
  1296. activityInfo, _ := cygx.GetAddActivityInfoById(activityId)
  1297. if activityInfo == nil {
  1298. br.Msg = "活动不存在"
  1299. br.ErrMsg = "活动ID错误,Err:activityId:" + strconv.Itoa(activityId)
  1300. return
  1301. }
  1302. //超级管理员和权益管理员、权益研究员可以下载所有客户,销售组长能下载本组客户,销售只能下载本人名下客户
  1303. resp := new(cygx.CanDownload)
  1304. adminInfo, errAdmin := system.GetSysUserById(AdminUser.AdminId)
  1305. if errAdmin != nil {
  1306. br.Msg = "获取失败"
  1307. br.ErrMsg = "获取失败,Err:" + errAdmin.Error()
  1308. return
  1309. }
  1310. if adminInfo.Role == "admin" || adminInfo.Role == "researcher" {
  1311. resp.IsCanDownload = true
  1312. }
  1313. sqlStr := ""
  1314. if resp.IsCanDownload == false && (activityInfo.ActivityTypeId == 1 || activityInfo.ActivityTypeId == 2 || activityInfo.ActivityTypeId == 3 || activityInfo.IsYidongConduct == 1) {
  1315. if adminInfo.RoleTypeCode == "rai_group" {
  1316. //组长查看本组所有组员
  1317. sqlStr += ` AND s.company_id IN (SELECT company_id FROM user_seller_relation WHERE seller_id IN (SELECT admin_id FROM admin WHERE group_id = (SELECT group_id FROM admin WHERE admin_id = ` + strconv.Itoa(AdminUser.AdminId) + ` ) )) `
  1318. } else {
  1319. //组员查看自己
  1320. sqlStr += ` AND s.company_id IN (SELECT company_id FROM user_seller_relation WHERE seller_id = ` + strconv.Itoa(AdminUser.AdminId) + `) `
  1321. }
  1322. }
  1323. sqlStrOther := sqlStr
  1324. var listReminder []*cygx.CygxAppointmentList
  1325. var summaryList []*cygx.CygxAppointmentList
  1326. var err error
  1327. //消息提醒
  1328. listReminder, err = cygx.GetCygxActivityMeetingReminderList(activityId, sqlStrOther)
  1329. if err != nil {
  1330. br.Msg = "获取失败"
  1331. br.ErrMsg = "获取失败,Err:" + err.Error()
  1332. return
  1333. }
  1334. //预约纪要
  1335. summaryList, err = cygx.GetCygxAppointmentSummaryList(activityId, sqlStrOther)
  1336. if err != nil {
  1337. br.Msg = "获取失败"
  1338. br.ErrMsg = "获取失败,Err:" + err.Error()
  1339. return
  1340. }
  1341. if excelType == 1 {
  1342. sqlStr += ` AND s.signup_type = 1 `
  1343. } else if excelType == 2 {
  1344. sqlStr += ` AND s.signup_type IN (2,4) `
  1345. }
  1346. //}
  1347. list, err := cygx.GetCygxAppointmentList(activityId, sqlStr)
  1348. if err != nil {
  1349. br.Msg = "获取失败"
  1350. br.ErrMsg = "获取失败,Err:" + err.Error()
  1351. return
  1352. }
  1353. //创建excel
  1354. dir, err := os.Executable()
  1355. exPath := filepath.Dir(dir)
  1356. downLoadnFilePath := exPath + "/" + time.Now().Format(utils.FormatDateTimeUnSpace) + ".xlsx"
  1357. xlsxFile := xlsx.NewFile()
  1358. if err != nil {
  1359. br.Msg = "生成文件失败"
  1360. br.ErrMsg = "生成文件失败"
  1361. return
  1362. }
  1363. style := xlsx.NewStyle()
  1364. alignment := xlsx.Alignment{
  1365. Horizontal: "center",
  1366. Vertical: "center",
  1367. WrapText: true,
  1368. }
  1369. style.Alignment = alignment
  1370. style.ApplyAlignment = true
  1371. for pidIndex := 0; pidIndex <= 2; pidIndex++ {
  1372. //只做专家电话会,分析师电话会的多Sheel下载
  1373. if activityInfo.ActivityTypeId != 1 && activityInfo.ActivityTypeId != 2 {
  1374. if pidIndex > 0 {
  1375. continue
  1376. }
  1377. }
  1378. var sheetName string
  1379. var listDate []*cygx.CygxAppointmentList
  1380. if pidIndex == 0 {
  1381. sheetName = "报名名单"
  1382. listDate = list
  1383. } else if pidIndex == 1 {
  1384. sheetName = "消息提醒名单"
  1385. listDate = listReminder
  1386. } else if pidIndex == 2 {
  1387. sheetName = "预约纪要名单"
  1388. listDate = summaryList
  1389. }
  1390. sheet, err := xlsxFile.AddSheet(sheetName)
  1391. if err != nil {
  1392. br.Msg = "新增Sheet失败"
  1393. br.ErrMsg = "新增Sheet失败,Err:" + err.Error()
  1394. return
  1395. }
  1396. //标头
  1397. if pidIndex == 0 {
  1398. if activityInfo.ActivityTypeId == 1 || activityInfo.ActivityTypeId == 2 || activityInfo.ActivityTypeId == 3 || (activityInfo.ActivityTypeId == 7 && activityInfo.IsYidongConduct == 1) {
  1399. rowTitle := sheet.AddRow()
  1400. cellA := rowTitle.AddCell()
  1401. cellA.Value = "姓名"
  1402. cellB := rowTitle.AddCell()
  1403. cellB.Value = "外呼号码"
  1404. cellC := rowTitle.AddCell()
  1405. cellC.Value = "国际代码"
  1406. cellD := rowTitle.AddCell()
  1407. cellD.Value = "邮箱"
  1408. cellE := rowTitle.AddCell()
  1409. cellE.Value = "公司名称"
  1410. cellF := rowTitle.AddCell()
  1411. cellF.Value = "所属销售"
  1412. for _, item := range listDate {
  1413. row := sheet.AddRow()
  1414. cellA := row.AddCell()
  1415. cellA.Value = item.RealName
  1416. cellB := row.AddCell()
  1417. cellB.Value = item.OutboundMobile
  1418. cellC := row.AddCell()
  1419. cellC.Value = item.CountryCode
  1420. cellD := row.AddCell()
  1421. cellD.Value = item.Email
  1422. cellE := row.AddCell()
  1423. cellE.Value = item.CompanyName
  1424. cellF := row.AddCell()
  1425. cellF.Value = item.SellerName
  1426. }
  1427. } else {
  1428. rowTitle := sheet.AddRow()
  1429. cellA := rowTitle.AddCell()
  1430. cellA.Value = "姓名"
  1431. cellB := rowTitle.AddCell()
  1432. cellB.Value = "公司名称"
  1433. cellC := rowTitle.AddCell()
  1434. cellC.Value = "所属销售"
  1435. for _, item := range listDate {
  1436. row := sheet.AddRow()
  1437. cellA := row.AddCell()
  1438. cellA.Value = item.RealName
  1439. cellB := row.AddCell()
  1440. cellB.Value = item.CompanyName
  1441. cellC := row.AddCell()
  1442. cellC.Value = item.SellerName
  1443. }
  1444. }
  1445. } else {
  1446. rowTitle := sheet.AddRow()
  1447. cellA := rowTitle.AddCell()
  1448. cellA.Value = "姓名"
  1449. cellB := rowTitle.AddCell()
  1450. cellB.Value = "公司名称"
  1451. cellC := rowTitle.AddCell()
  1452. cellC.Value = "所属销售"
  1453. for _, item := range listDate {
  1454. row := sheet.AddRow()
  1455. cellA := row.AddCell()
  1456. cellA.Value = item.RealName
  1457. cellB := row.AddCell()
  1458. cellB.Value = item.CompanyName
  1459. cellC := row.AddCell()
  1460. cellC.Value = item.SellerName
  1461. }
  1462. }
  1463. }
  1464. err = xlsxFile.Save(downLoadnFilePath)
  1465. if err != nil {
  1466. br.Msg = "保存文件失败"
  1467. br.ErrMsg = "保存文件失败"
  1468. return
  1469. }
  1470. //randStr := time.Now().Format(utils.FormatDateTimeUnSpace)
  1471. downloadFileName := activityInfo.ActivityName + ".xlsx"
  1472. this.Ctx.Output.Download(downLoadnFilePath, downloadFileName)
  1473. defer func() {
  1474. os.Remove(downLoadnFilePath)
  1475. }()
  1476. //添加操作日志记录
  1477. br.Success = true
  1478. br.Ret = 200
  1479. br.Msg = "导出成功"
  1480. br.IsAddLog = true
  1481. }
  1482. // @Title 修改外呼号码
  1483. // @Description 修改外呼号码接口
  1484. // @Param request body cygx.OutboundMobileEditResp true "type json string"
  1485. // @Success 200 操作成功
  1486. // @router /activitySignup/outboundMobileEdit [post]
  1487. func (this *ActivitySignupCoAntroller) OutboundMobileEdit() {
  1488. br := new(models.BaseResponse).Init()
  1489. defer func() {
  1490. this.Data["json"] = br
  1491. this.ServeJSON()
  1492. }()
  1493. sysUser := this.SysUser
  1494. if sysUser == nil {
  1495. br.Msg = "请登录"
  1496. br.ErrMsg = "请登录,SysUser Is Empty"
  1497. return
  1498. }
  1499. var req cygx.OutboundMobileEditResp
  1500. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  1501. if err != nil {
  1502. br.Msg = "参数解析异常!"
  1503. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  1504. return
  1505. }
  1506. id := req.Id
  1507. outboundMobile := req.OutboundMobile
  1508. countryCode := req.CountryCode
  1509. total, err := cygx.GetCygxSignupCountFile(id)
  1510. if err != nil {
  1511. br.Msg = "获取失败"
  1512. br.ErrMsg = "获取失败,Err:" + err.Error()
  1513. return
  1514. }
  1515. if total == 0 {
  1516. br.Msg = "获取报名信息失败"
  1517. br.ErrMsg = "获取失败,id:" + strconv.Itoa(id)
  1518. return
  1519. }
  1520. err = cygx.OutboundMobileEdit(id, outboundMobile, countryCode)
  1521. if err != nil {
  1522. br.Msg = "修改失败"
  1523. br.ErrMsg = "修改失败 Err:" + err.Error()
  1524. return
  1525. }
  1526. br.Ret = 200
  1527. br.Success = true
  1528. br.Msg = "操作成功"
  1529. br.IsAddLog = true
  1530. }
  1531. // @Title 单条报名详情
  1532. // @Description 获取单条报名详情接口
  1533. // @Param Id query int true "报名ID"
  1534. // @Success Ret=200 {object} cygx.CygxActivitySignup
  1535. // @router /activitySignup/signupDetail [get]
  1536. func (this *ActivitySignupCoAntroller) SignupDetail() {
  1537. br := new(models.BaseResponse).Init()
  1538. defer func() {
  1539. this.Data["json"] = br
  1540. this.ServeJSON()
  1541. }()
  1542. AdminUser := this.SysUser
  1543. if AdminUser == nil {
  1544. br.Msg = "请登录"
  1545. br.ErrMsg = "请登录,用户信息为空"
  1546. br.Ret = 408
  1547. return
  1548. }
  1549. id, _ := this.GetInt("Id")
  1550. if id < 1 {
  1551. br.Msg = "请输入报名ID"
  1552. return
  1553. }
  1554. detail, err := cygx.GetActivitySignupInfoById(id)
  1555. if err != nil {
  1556. br.Msg = "报名信息不存在"
  1557. br.ErrMsg = "报名信息ID错误,Err:" + err.Error() + "id:" + strconv.Itoa(id)
  1558. return
  1559. }
  1560. br.Ret = 200
  1561. br.Success = true
  1562. br.Msg = "获取成功"
  1563. br.Data = detail
  1564. }
  1565. // @Title 新增报名人员
  1566. // @Description 新增报名人员接口
  1567. // @Param request body cygx.AddMeetingReminderReq true "type json string"
  1568. // @Success 200 操作成功
  1569. // @router /activitySignup/addSignuUser [post]
  1570. func (this *ActivitySignupCoAntroller) AddSignuUser() {
  1571. br := new(models.BaseResponse).Init()
  1572. defer func() {
  1573. this.Data["json"] = br
  1574. this.ServeJSON()
  1575. }()
  1576. AdminUser := this.SysUser
  1577. if AdminUser == nil {
  1578. br.Msg = "请登录"
  1579. br.ErrMsg = "请登录,SysUser Is Empty"
  1580. return
  1581. }
  1582. var req cygx.AddMeetingReminderReq
  1583. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  1584. if err != nil {
  1585. br.Msg = "参数解析异常!"
  1586. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  1587. return
  1588. }
  1589. adminInfo, err := system.GetSysUserById(AdminUser.AdminId)
  1590. if err != nil {
  1591. br.Msg = "添加失败"
  1592. br.ErrMsg = "获取管理员信息失败,Err:" + err.Error()
  1593. return
  1594. }
  1595. var items []*cygx.CygxActivitySignup
  1596. var itemsYidong []*cygx.YidongActivitySignup
  1597. var itemsAppointment []*cygx.CygxActivityAppointment
  1598. mapYidongActivity := make(map[int]int)
  1599. activityIds := req.ActivityIds
  1600. uidList := req.List
  1601. if activityIds == "" {
  1602. br.Msg = "请选择活动"
  1603. br.ErrMsg = "活动ID不能为空"
  1604. return
  1605. }
  1606. //获取已经报名成功的用户,给没有成功的或者没有报名的用户发送模版消息
  1607. mapSignupSuccess := make(map[string]int)
  1608. var itemsSendWxMsg []*cygx.CygxSignupUser
  1609. var condition string
  1610. var pars []interface{}
  1611. condition = ` AND do_fail_type = 0 AND activity_id IN (` + activityIds + `) `
  1612. listSignup, err := cygx.GetActivitySignupList(condition, pars)
  1613. if err != nil && err.Error() != utils.ErrNoRow() {
  1614. br.Msg = "添加报名失败"
  1615. br.ErrMsg = "添加报名失败,Err:GetActivitySignupList:" + err.Error()
  1616. }
  1617. for _, v := range listSignup {
  1618. mapSignupSuccess[fmt.Sprint("UID_", v.UserId, "AID_", v.ActivityId)] = v.ActivityId
  1619. }
  1620. activityIdList := strings.Split(activityIds, ",")
  1621. var uids string
  1622. for _, v := range uidList {
  1623. uids += strconv.Itoa(v.UserId) + ","
  1624. }
  1625. uids = strings.TrimRight(uids, ",")
  1626. mapCompanyPeople := make(map[string]int)
  1627. checkIsYidongConduct := make(map[string]int)
  1628. for _, v := range uidList {
  1629. uid := v.UserId
  1630. wxUser, userErr := models.GetWxUserByUserId(uid)
  1631. if userErr != nil {
  1632. br.Msg = "编辑失败!查询用户信息失败"
  1633. br.ErrMsg = "查询用户信息失败,Err:" + userErr.Error() + "用户UID:" + strconv.Itoa(uid) + "不存在"
  1634. return
  1635. }
  1636. for _, vact := range activityIdList {
  1637. activityId, _ := strconv.Atoi(vact)
  1638. activityInfo, err := cygx.GetAddActivityInfoById(activityId)
  1639. if err != nil {
  1640. br.Msg = "活动不存在"
  1641. br.ErrMsg = "活动ID错误,Err:activityId:" + strconv.Itoa(activityId)
  1642. return
  1643. }
  1644. // 如果是易董的办会,且不提供外呼,而且管理员还勾选了预约外呼,那么做判断
  1645. if activityInfo.IsYidongConduct == 1 && activityInfo.IsCanOutboundCall == 0 && v.SignupType == 1 {
  1646. br.Msg = "此活动不提供外呼"
  1647. br.ErrMsg = "此活动不提供外呼,Err:activityId:" + strconv.Itoa(activityId)
  1648. return
  1649. }
  1650. //同时 勾选一个易懂办会,一个非易懂办会的活动 的判断
  1651. checkIsYidongConduct[strconv.Itoa(activityInfo.IsYidongConduct)] = activityInfo.IsYidongConduct
  1652. if len(checkIsYidongConduct) > 1 {
  1653. br.Msg = "活动类型不同,无法同时新增报名"
  1654. br.ErrMsg = "活动类型不同,Err:activityIds:" + activityIds
  1655. return
  1656. }
  1657. if activityInfo.YidongActivityId != "" {
  1658. errMsg := cygxService.CheckYidongActivitySignupTime(activityInfo)
  1659. if errMsg != "" {
  1660. br.Msg = errMsg
  1661. br.ErrMsg = errMsg + "Err:activityId:" + strconv.Itoa(activityId)
  1662. return
  1663. }
  1664. mapYidongActivity[activityInfo.ActivityId] = activityInfo.ActivityId
  1665. }
  1666. activityTypeId := activityInfo.ActivityTypeId
  1667. if adminInfo.RoleTypeCode != "admin" {
  1668. havePower, err := cygxService.GetActivityDetailUserPower(wxUser, adminInfo, activityInfo)
  1669. if err != nil {
  1670. br.Msg = "用户权限校验失败!"
  1671. br.ErrMsg = "GetActivityDetailUserPower,Err:" + err.Error() + fmt.Sprint("UserId", wxUser.UserId, "ActivityId:", activityInfo.ActivityId)
  1672. return
  1673. }
  1674. if !havePower {
  1675. br.Msg = "当前活动对该客户不可见,无法报名"
  1676. br.ErrMsg = "活动ID:" + strconv.Itoa(activityId) + "活动名称:" + activityInfo.ActivityName + "用户ID:" + strconv.Itoa(int(wxUser.UserId))
  1677. return
  1678. }
  1679. popupMsg, err := cygxService.CheckActivityUserAll(activityInfo, wxUser)
  1680. if err != nil {
  1681. br.Msg = "报名失败!"
  1682. br.ErrMsg = "CheckActivityUserAll,Err:" + err.Error()
  1683. return
  1684. }
  1685. if popupMsg != "" {
  1686. br.Msg = fmt.Sprint("报名失败!用户:", wxUser.RealName, popupMsg)
  1687. return
  1688. }
  1689. if activityInfo.YidongActivityId == "" {
  1690. if activityTypeId == 1 || activityTypeId == 2 {
  1691. resultTime := utils.StrTimeToTime(activityInfo.ActivityTime) //时间字符串格式转时间格式
  1692. if time.Now().After(resultTime.Add(-time.Minute * 60)) {
  1693. br.Msg = "报名名单已发送至办会平台,请联系相关人员处理。"
  1694. return
  1695. }
  1696. }
  1697. }
  1698. //弘则的不做校验
  1699. if activityInfo.IsLimitPeople == 1 && wxUser.CompanyId != utils.HZ_COMPANY_ID {
  1700. //单机构两人限制
  1701. {
  1702. sqlStr := ` AND s.do_fail_type = 0`
  1703. listSignUp, err := cygx.GetCygxAppointmentList(activityId, sqlStr)
  1704. if err != nil && err.Error() != utils.ErrNoRow() {
  1705. br.Msg = "获取失败"
  1706. br.ErrMsg = "获取失败,Err:" + err.Error()
  1707. return
  1708. }
  1709. for _, v := range listSignUp {
  1710. mapCompanyPeople[fmt.Sprint("CID_", v.CompanyId, "AID_", activityId)]++
  1711. }
  1712. mapCompanyPeople[fmt.Sprint("CID_", wxUser.CompanyId, "AID_", activityId)]++
  1713. if mapCompanyPeople[fmt.Sprint("CID_", wxUser.CompanyId, "AID_", activityId)] > 2 {
  1714. br.Msg = "新增失败," + wxUser.RealName + "单机构2人限制。"
  1715. br.ErrMsg = wxUser.RealName + "单机构2人限制"
  1716. return
  1717. }
  1718. }
  1719. //爽约限制
  1720. //{
  1721. // totalRestrict, err := cygx.GetUserRestrictCount(wxUser.Mobile)
  1722. // if err != nil {
  1723. // br.Msg = "获取信息失败"
  1724. // br.ErrMsg = "获取客户信息失败,Err:" + err.Error()
  1725. // return
  1726. // }
  1727. // if totalRestrict >= 1 {
  1728. // br.Msg = "新增失败," + wxUser.RealName + "爽约次数过多。"
  1729. // br.ErrMsg = wxUser.RealName + "由于爽约次数过多,暂时被限制报名资格"
  1730. // return
  1731. // }
  1732. //}
  1733. }
  1734. }
  1735. limitPeopleNum, _ := strconv.Atoi(activityInfo.LimitPeopleNum)
  1736. //获取这个活动已经报名的用户数量
  1737. totalSignup, errSignup := cygx.GetActivitySignupCountByActivityId(activityId)
  1738. if errSignup != nil {
  1739. br.Msg = "获取失败"
  1740. br.ErrMsg = "获取失败,Err:" + errSignup.Error()
  1741. return
  1742. }
  1743. //获取这个活动中输入的这些用户的报名数量
  1744. totalThisUser, errThisUser := cygx.GetActivitySignupCountByThisUser(activityId, uids)
  1745. if errThisUser != nil {
  1746. br.Msg = "获取失败"
  1747. br.ErrMsg = "获取失败,Err:" + errThisUser.Error()
  1748. return
  1749. }
  1750. //如果是限制人数的就做报名人数限制判断
  1751. if activityInfo.IsLimitPeople == 1 {
  1752. if limitPeopleNum < totalSignup+len(uidList)-totalThisUser {
  1753. br.Msg = "新增失败,活动人数超限"
  1754. br.ErrMsg = "当前活动报名人数已满,活动:" + activityInfo.ActivityName
  1755. return
  1756. }
  1757. }
  1758. total, errtotal := cygx.GetActivitySignupCount(uid, activityId)
  1759. if errtotal != nil {
  1760. br.Msg = "获取失败"
  1761. br.ErrMsg = "获取失败,Err:" + errtotal.Error()
  1762. return
  1763. }
  1764. //判断这个用户是否报名了,如果没有报名则写入报名数据
  1765. if total == 0 {
  1766. infoUser, err := cygx.GetUserAndCompanyNameList(uid)
  1767. if err != nil {
  1768. br.Msg = "获取失败"
  1769. br.ErrMsg = "获取数据失败,Err:" + err.Error()
  1770. return
  1771. }
  1772. item := new(cygx.CygxActivitySignup)
  1773. item.UserId = infoUser.UserId
  1774. item.RealName = infoUser.RealName
  1775. item.SellerName = infoUser.SellerName
  1776. item.ActivityId = activityId
  1777. item.CreateTime = time.Now()
  1778. item.Mobile = infoUser.Mobile
  1779. item.Mobile = infoUser.Mobile
  1780. item.Email = infoUser.Email
  1781. item.CompanyId = infoUser.CompanyId
  1782. item.CompanyName = infoUser.CompanyName
  1783. //优先绑定用户修改过的外呼手机号
  1784. if infoUser.OutboundMobile != "" {
  1785. item.OutboundMobile = infoUser.OutboundMobile
  1786. if infoUser.OutboundCountryCode == "" {
  1787. item.CountryCode = "86"
  1788. } else {
  1789. item.CountryCode = infoUser.OutboundCountryCode
  1790. }
  1791. } else {
  1792. item.OutboundMobile = infoUser.Mobile
  1793. if infoUser.CountryCode == "" {
  1794. item.CountryCode = "86"
  1795. } else {
  1796. item.CountryCode = infoUser.CountryCode
  1797. }
  1798. }
  1799. //如果不填报名方式,则默认为我要报名这种方式
  1800. if v.SignupType == 0 {
  1801. item.SignupType = 3
  1802. } else {
  1803. item.SignupType = v.SignupType
  1804. }
  1805. item.Source = 2
  1806. items = append(items, item)
  1807. if activityInfo.YidongActivityId != "" {
  1808. itemYidong := new(cygx.YidongActivitySignup)
  1809. itemYidong.YidongActivityId = activityInfo.YidongActivityId
  1810. itemYidong.Mobile = item.Mobile
  1811. itemYidong.RealName = item.RealName
  1812. itemYidong.CompanyName = item.CompanyName
  1813. itemYidong.CountryCode = item.CountryCode
  1814. itemYidong.ActivityJoinType = activityInfo.ActivityJoinType
  1815. itemsYidong = append(itemsYidong, itemYidong)
  1816. }
  1817. }
  1818. if v.IsAppointment == 1 {
  1819. total, errtotal := cygx.GetUserCygxActivityAppointmentCount(uid, activityId)
  1820. if errtotal != nil {
  1821. br.Msg = "获取失败"
  1822. br.ErrMsg = "获取失败,Err:" + errtotal.Error()
  1823. return
  1824. }
  1825. //var isHideAppointment bool
  1826. //if activityInfo.IsCanAppointmentMinutes == 1 {
  1827. // isHideAppointment = cygxService.IsShowAppointmentByadminSet(activityInfo.IsCanAppointmentMinutes)
  1828. //}
  1829. if activityInfo.IsCanAppointmentMinutes == 0 {
  1830. br.Msg = "该活动无法预约纪要"
  1831. br.ErrMsg = "该活动无法预约纪要,Err:" + activityInfo.ActivityName
  1832. return
  1833. }
  1834. //判断这个用户是否报名了,如果没有报名则写入报名数据
  1835. if total == 0 {
  1836. infoUser, err := cygx.GetUserAndCompanyNameList(uid)
  1837. if err != nil {
  1838. br.Msg = "获取失败"
  1839. br.ErrMsg = "获取数据失败,Err:" + err.Error()
  1840. return
  1841. }
  1842. itemAppointment := new(cygx.CygxActivityAppointment)
  1843. itemAppointment.UserId = infoUser.UserId
  1844. itemAppointment.RealName = infoUser.RealName
  1845. itemAppointment.SellerName = infoUser.SellerName
  1846. itemAppointment.ActivityId = activityId
  1847. itemAppointment.CreateTime = time.Now()
  1848. itemAppointment.Mobile = infoUser.Mobile
  1849. itemAppointment.Email = infoUser.Email
  1850. itemAppointment.CompanyId = infoUser.CompanyId
  1851. itemAppointment.CompanyName = infoUser.CompanyName
  1852. itemAppointment.Source = 2
  1853. itemAppointment.AdminId = adminInfo.AdminId
  1854. itemsAppointment = append(itemsAppointment, itemAppointment)
  1855. }
  1856. }
  1857. if mapSignupSuccess[fmt.Sprint("UID_", uid, "AID_", activityId)] == 0 {
  1858. itemsSendWxMsg = append(itemsSendWxMsg, &cygx.CygxSignupUser{UserId: uid, ActivityId: activityId})
  1859. }
  1860. }
  1861. }
  1862. //mapYidongActivity := make(map[int]int)
  1863. err = cygx.AddCygxActivitySignup(items, itemsAppointment, mapYidongActivity)
  1864. if err != nil {
  1865. br.Msg = "操作失败"
  1866. br.ErrMsg = "新增用户失败,Err:" + err.Error()
  1867. return
  1868. }
  1869. //如果有值就向易董推送后台添加的报名信息
  1870. if len(itemsYidong) > 0 {
  1871. go cygxService.YidongActivityUserSingnUp(itemsYidong)
  1872. }
  1873. //销售或后台管理员给用户添加报名之后,进行模版消息推送
  1874. if len(itemsSendWxMsg) > 0 {
  1875. go cygxService.SendWxMsgWithCygxActivitySignUpBySell(itemsSendWxMsg)
  1876. }
  1877. if len(items) > 0 {
  1878. //1用户报名添加到处理研选扣点
  1879. for _, v := range items {
  1880. go cygxService.YanXuanActivityPointsBillSignupAdd(v.ActivityId, v.UserId, adminInfo.AdminId)
  1881. }
  1882. }
  1883. //添加操作日志记录
  1884. br.IsAddLog = true
  1885. br.IsSendEmail = false
  1886. br.Ret = 200
  1887. br.Success = true
  1888. br.Msg = "操作成功"
  1889. }
  1890. // @Title 带问列表详情
  1891. // @Description 获取带问列表详情接口
  1892. // @Param ActivityId query int true "活动ID"
  1893. // @Success 200 {object} cygx.ActivityHelpAskListResp
  1894. // @router /activitySignup/askList [get]
  1895. func (this *ActivitySignupCoAntroller) AskList() {
  1896. br := new(models.BaseResponse).Init()
  1897. defer func() {
  1898. this.Data["json"] = br
  1899. this.ServeJSON()
  1900. }()
  1901. sysUser := this.SysUser
  1902. if sysUser == nil {
  1903. br.Msg = "请登录"
  1904. br.ErrMsg = "请登录,SysUser Is Empty"
  1905. return
  1906. }
  1907. activityId, _ := this.GetInt("ActivityId")
  1908. activityInfo, _ := cygx.GetAddActivityInfoById(activityId)
  1909. if activityInfo == nil {
  1910. br.Msg = "活动不存在"
  1911. br.ErrMsg = "活动ID错误,Err:activityId:" + strconv.Itoa(activityId)
  1912. return
  1913. }
  1914. list, err := cygx.GetActivityHelpAskList(activityId)
  1915. respist := new(cygx.ActivityHelpAskListResp)
  1916. if err != nil {
  1917. br.Msg = "获取失败"
  1918. br.ErrMsg = "获取失败,Err:" + err.Error()
  1919. return
  1920. }
  1921. respist.List = list
  1922. br.Ret = 200
  1923. br.Success = true
  1924. br.Msg = "获取成功"
  1925. br.Data = respist
  1926. }
  1927. // @Title 带问详情excel表格下载
  1928. // @Description 带问详情excel表格下载接口
  1929. // @Param ActivityId query int true "活动ID"
  1930. // @Success 200 导出成功
  1931. // @router /activitySignup/askListExport [get]
  1932. func (this *ActivitySignupCoAntroller) AskListExport() {
  1933. br := new(models.BaseResponse).Init()
  1934. defer func() {
  1935. this.Data["json"] = br
  1936. this.ServeJSON()
  1937. }()
  1938. AdminUser := this.SysUser
  1939. if AdminUser == nil {
  1940. br.Msg = "请登录"
  1941. br.ErrMsg = "请登录,SysUser Is Empty"
  1942. return
  1943. }
  1944. activityId, _ := this.GetInt("ActivityId")
  1945. activityInfo, _ := cygx.GetAddActivityInfoById(activityId)
  1946. if activityInfo == nil {
  1947. br.Msg = "活动不存在"
  1948. br.ErrMsg = "活动ID错误,Err:activityId:" + strconv.Itoa(activityId)
  1949. return
  1950. }
  1951. list, err := cygx.GetActivityHelpAskList(activityId)
  1952. if err != nil {
  1953. br.Msg = "获取失败"
  1954. br.ErrMsg = "获取失败,Err:" + err.Error()
  1955. return
  1956. }
  1957. //创建excel
  1958. dir, err := os.Executable()
  1959. exPath := filepath.Dir(dir)
  1960. downLoadnFilePath := exPath + "/" + time.Now().Format(utils.FormatDateTimeUnSpace) + ".xlsx"
  1961. xlsxFile := xlsx.NewFile()
  1962. if err != nil {
  1963. br.Msg = "生成文件失败"
  1964. br.ErrMsg = "生成文件失败"
  1965. return
  1966. }
  1967. style := xlsx.NewStyle()
  1968. alignment := xlsx.Alignment{
  1969. Horizontal: "center",
  1970. Vertical: "center",
  1971. WrapText: true,
  1972. }
  1973. style.Alignment = alignment
  1974. style.ApplyAlignment = true
  1975. sheet, err := xlsxFile.AddSheet("名单")
  1976. if err != nil {
  1977. br.Msg = "新增Sheet失败"
  1978. br.ErrMsg = "新增Sheet失败,Err:" + err.Error()
  1979. return
  1980. }
  1981. //标头
  1982. rowTitle := sheet.AddRow()
  1983. cellA := rowTitle.AddCell()
  1984. cellA.Value = "姓名"
  1985. cellB := rowTitle.AddCell()
  1986. cellB.Value = "公司名称"
  1987. cellC := rowTitle.AddCell()
  1988. cellC.Value = "问题"
  1989. cellD := rowTitle.AddCell()
  1990. cellD.Value = "提交时间"
  1991. for _, item := range list {
  1992. row := sheet.AddRow()
  1993. cellA := row.AddCell()
  1994. cellA.Value = item.RealName
  1995. cellB := row.AddCell()
  1996. cellB.Value = item.CompanyName
  1997. cellC := row.AddCell()
  1998. cellC.Value = item.Content
  1999. cellD := row.AddCell()
  2000. cellD.Value = item.CreateTime
  2001. }
  2002. err = xlsxFile.Save(downLoadnFilePath)
  2003. if err != nil {
  2004. br.Msg = "保存文件失败"
  2005. br.ErrMsg = "保存文件失败"
  2006. return
  2007. }
  2008. randStr := time.Now().Format(utils.FormatDateTimeUnSpace)
  2009. downloadFileName := "问题列表" + randStr + ".xlsx"
  2010. this.Ctx.Output.Download(downLoadnFilePath, downloadFileName)
  2011. defer func() {
  2012. os.Remove(downLoadnFilePath)
  2013. }()
  2014. //添加操作日志记录
  2015. br.IsAddLog = true
  2016. br.Success = true
  2017. br.Ret = 200
  2018. br.Msg = "导出成功"
  2019. }
  2020. // @Title 新增报名人员(可择报名方式)
  2021. // @Description 新增报名人员(可择报名方式)接口
  2022. // @Param request body cygx.AddOutboundPersonnelJsonItm true "type json string"
  2023. // @Success 200 操作成功
  2024. // @router /activitySignup/addSignuUserOptType [post]
  2025. func (this *ActivitySignupCoAntroller) AddSignuUserOptType() {
  2026. br := new(models.BaseResponse).Init()
  2027. defer func() {
  2028. this.Data["json"] = br
  2029. this.ServeJSON()
  2030. }()
  2031. AdminUser := this.SysUser
  2032. if AdminUser == nil {
  2033. br.Msg = "请登录"
  2034. br.ErrMsg = "请登录,SysUser Is Empty"
  2035. return
  2036. }
  2037. var req cygx.AddOutboundPersonnelJsonItm
  2038. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  2039. if err != nil {
  2040. br.Msg = "参数解析异常!"
  2041. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  2042. return
  2043. }
  2044. adminInfo, err := system.GetSysUserById(AdminUser.AdminId)
  2045. if err != nil {
  2046. br.Msg = "添加失败"
  2047. br.ErrMsg = "获取管理员信息失败,Err:" + err.Error()
  2048. return
  2049. }
  2050. jsonStr := req.JsonStar
  2051. var config cygx.RequestCommonPolicyConfig
  2052. err = json.Unmarshal([]byte(jsonStr), &config.CommonPolicyconfigs)
  2053. if err != nil {
  2054. br.Msg = "参数解析异常!"
  2055. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  2056. return
  2057. }
  2058. var uids string
  2059. for _, v := range config.CommonPolicyconfigs {
  2060. uids += strconv.Itoa(v.Uid) + ","
  2061. }
  2062. uids = strings.TrimRight(uids, ",")
  2063. var items []*cygx.CygxActivitySignup
  2064. activityIds := req.ActivityIds
  2065. uidList := strings.Split(uids, ",")
  2066. activityIdList := strings.Split(activityIds, ",")
  2067. for _, v := range config.CommonPolicyconfigs {
  2068. uid := v.Uid
  2069. wxUser, userErr := models.GetWxUserByUserId(uid)
  2070. if userErr != nil {
  2071. br.Msg = "编辑失败!查询用户信息失败"
  2072. br.ErrMsg = "查询用户信息失败,Err:" + userErr.Error() + "用户UID:" + strconv.Itoa(uid) + "不存在"
  2073. return
  2074. }
  2075. for _, vact := range activityIdList {
  2076. activityId, _ := strconv.Atoi(vact)
  2077. activityInfo, err := cygx.GetAddActivityInfoById(activityId)
  2078. if err != nil {
  2079. br.Msg = "活动不存在"
  2080. br.ErrMsg = "活动ID错误,Err:activityId:" + strconv.Itoa(activityId)
  2081. return
  2082. }
  2083. if adminInfo.RoleTypeCode != "admin" {
  2084. havePower := cygxService.CheckaddSignuUserPower(wxUser.CompanyId, activityId, activityInfo)
  2085. if !havePower {
  2086. br.Msg = "当前活动对该客户不可见,无法报名"
  2087. br.ErrMsg = "活动ID:" + strconv.Itoa(activityId) + "活动名称:" + activityInfo.ActivityName + "用户ID:" + strconv.Itoa(int(wxUser.UserId))
  2088. return
  2089. }
  2090. }
  2091. limitPeopleNum, _ := strconv.Atoi(activityInfo.LimitPeopleNum)
  2092. //获取这个活动已经报名的用户数量
  2093. totalSignup, errSignup := cygx.GetActivitySignupCountByActivityId(activityId)
  2094. if errSignup != nil {
  2095. br.Msg = "获取失败"
  2096. br.ErrMsg = "获取失败,Err:" + errSignup.Error()
  2097. return
  2098. }
  2099. //获取这个活动中输入的这些用户的报名数量
  2100. totalThisUser, errThisUser := cygx.GetActivitySignupCountByThisUser(activityId, uids)
  2101. if errThisUser != nil {
  2102. br.Msg = "获取失败"
  2103. br.ErrMsg = "获取失败,Err:" + errThisUser.Error()
  2104. return
  2105. }
  2106. if limitPeopleNum < totalSignup+len(uidList)-totalThisUser {
  2107. br.Msg = "当前活动报名人数已满"
  2108. br.ErrMsg = "当前活动报名人数已满,活动:" + activityInfo.ActivityName
  2109. return
  2110. }
  2111. total, errtotal := cygx.GetActivitySignupCount(uid, activityId)
  2112. if errtotal != nil {
  2113. br.Msg = "获取失败"
  2114. br.ErrMsg = "获取失败,Err:" + errtotal.Error()
  2115. return
  2116. }
  2117. //判断这个用户是否报名了,如果没有报名则写入报名数据
  2118. if total == 0 {
  2119. infoUser, err := cygx.GetUserAndCompanyNameList(uid)
  2120. if err != nil {
  2121. br.Msg = "获取失败"
  2122. br.ErrMsg = "获取数据失败,Err:" + err.Error()
  2123. return
  2124. }
  2125. item := new(cygx.CygxActivitySignup)
  2126. item.UserId = infoUser.UserId
  2127. item.RealName = infoUser.RealName
  2128. item.SellerName = infoUser.SellerName
  2129. item.ActivityId = activityId
  2130. item.CreateTime = time.Now()
  2131. item.Mobile = infoUser.Mobile
  2132. item.Email = infoUser.Email
  2133. item.CompanyId = infoUser.CompanyId
  2134. item.CompanyName = infoUser.CompanyName
  2135. //优先绑定用户修改过的外呼手机号
  2136. if infoUser.OutboundMobile != "" {
  2137. item.OutboundMobile = infoUser.OutboundMobile
  2138. if infoUser.OutboundCountryCode == "" {
  2139. item.CountryCode = "86"
  2140. } else {
  2141. item.CountryCode = infoUser.OutboundCountryCode
  2142. }
  2143. } else {
  2144. item.OutboundMobile = infoUser.Mobile
  2145. if infoUser.CountryCode == "" {
  2146. item.CountryCode = "86"
  2147. } else {
  2148. item.CountryCode = infoUser.CountryCode
  2149. }
  2150. }
  2151. signupType, _ := strconv.Atoi(v.Type)
  2152. item.SignupType = signupType
  2153. item.Source = 2
  2154. items = append(items, item)
  2155. }
  2156. }
  2157. }
  2158. err = cygx.AddCygxActivitySignupUser(items)
  2159. if err != nil {
  2160. br.Msg = "操作失败"
  2161. br.ErrMsg = "新增用户失败,Err:" + err.Error()
  2162. return
  2163. }
  2164. //添加操作日志记录
  2165. br.IsAddLog = true
  2166. br.Ret = 200
  2167. br.Success = true
  2168. br.Msg = "操作成功"
  2169. }
  2170. // @Title 活动取消报名
  2171. // @Description 活动取消报名接口
  2172. // @Param request body cygx.CygxSignupId true "type json string"
  2173. // @Success Ret=200
  2174. // @router /activitySignup/cancel [post]
  2175. func (this *ActivitySignupCoAntroller) SignupCancel() {
  2176. br := new(models.BaseResponse).Init()
  2177. defer func() {
  2178. this.Data["json"] = br
  2179. this.ServeJSON()
  2180. }()
  2181. AdminUser := this.SysUser
  2182. if AdminUser == nil {
  2183. br.Msg = "请登录"
  2184. br.ErrMsg = "请登录,SysUser Is Empty"
  2185. return
  2186. }
  2187. var req cygx.CygxSignupId
  2188. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  2189. if err != nil {
  2190. br.Msg = "参数解析异常!"
  2191. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  2192. return
  2193. }
  2194. adminInfo, err := system.GetSysUserById(AdminUser.AdminId)
  2195. if err != nil {
  2196. br.Msg = "添加失败"
  2197. br.ErrMsg = "获取管理员信息失败,Err:" + err.Error()
  2198. return
  2199. }
  2200. signupId := req.SignupId
  2201. cancelClass := req.CancelClass
  2202. detail, err := cygx.GetActivitySignupInfoById(signupId)
  2203. if err != nil {
  2204. br.Msg = "报名信息不存在"
  2205. br.ErrMsg = "报名信息ID错误,Err:" + err.Error() + "id:" + strconv.Itoa(signupId)
  2206. return
  2207. }
  2208. activityInfo, err := cygx.GetAddActivityInfoById(detail.ActivityId)
  2209. if err != nil {
  2210. br.Msg = "操作失败"
  2211. br.ErrMsg = "活动ID错误,不存在activityId:" + strconv.Itoa(detail.ActivityId)
  2212. return
  2213. }
  2214. if cancelClass == 1 {
  2215. resultTime := utils.StrTimeToTime(activityInfo.ActivityTime) //时间字符串格式转时间格式
  2216. if time.Now().After(resultTime.Add(-time.Minute * 60)) {
  2217. br.Msg = "活动开始前1小时内无法取消外呼,提示:外呼名单已发送专家组,请联系专家组取消"
  2218. return
  2219. }
  2220. }
  2221. activityTypeId := activityInfo.ActivityTypeId
  2222. if adminInfo.RoleTypeCode != "admin" {
  2223. if activityTypeId == 1 || activityTypeId == 2 {
  2224. resultTime := utils.StrTimeToTime(activityInfo.ActivityTime) //时间字符串格式转时间格式
  2225. if time.Now().After(resultTime.Add(-time.Minute * 60)) {
  2226. br.Msg = "报名名单已发送至办会平台,请联系相关人员处理。"
  2227. br.ErrMsg = fmt.Sprint("UserId:", detail.UserId, "ActivityId:", detail.ActivityId)
  2228. return
  2229. }
  2230. }
  2231. //取消报名截止时间校验
  2232. //if activityInfo.CancelDeadline != utils.EmptyDateTimeStr {
  2233. // cancelDeadline := utils.StrTimeToTime(activityInfo.CancelDeadline) //时间字符串格式转时间格式
  2234. // if time.Now().After(cancelDeadline) {
  2235. // br.Msg = "当前时间晚于取消报名截止时间,已无法取消报名。"
  2236. // br.ErrMsg = fmt.Sprint("UserId:", detail.UserId, "ActivityId:", detail.ActivityId)
  2237. // return
  2238. // }
  2239. //}
  2240. }
  2241. _, err = cygx.CancelActivitySignup(detail)
  2242. if err != nil {
  2243. br.Msg = "操作失败"
  2244. br.ErrMsg = "操作失败,Err:" + err.Error()
  2245. return
  2246. }
  2247. go cygxService.YanXuanActivityPointsBillSignupCancel(detail.ActivityId, detail.UserId, adminInfo.AdminId)
  2248. //添加操作日志记录
  2249. br.IsAddLog = true
  2250. br.Ret = 200
  2251. br.Success = true
  2252. br.Msg = "操作成功"
  2253. }
  2254. // @Title 预约纪要详情
  2255. // @Description 预约纪要详情列表接口
  2256. // @Param ActivityId query int true "活动ID"
  2257. // @Success 200 {object} cygx.GetAppointmentListRep
  2258. // @router /activitySignup/appointment/summaryList [get]
  2259. func (this *ActivitySignupCoAntroller) SummaryList() {
  2260. br := new(models.BaseResponse).Init()
  2261. defer func() {
  2262. this.Data["json"] = br
  2263. this.ServeJSON()
  2264. }()
  2265. sysUser := this.SysUser
  2266. if sysUser == nil {
  2267. br.Msg = "请登录"
  2268. br.ErrMsg = "请登录,SysUser Is Empty"
  2269. return
  2270. }
  2271. activityId, _ := this.GetInt("ActivityId")
  2272. if activityId < 1 {
  2273. br.Msg = "活动不存在"
  2274. return
  2275. }
  2276. activityInfo, _ := cygx.GetAddActivityInfoById(activityId)
  2277. if activityInfo == nil {
  2278. br.Msg = "活动不存在"
  2279. br.ErrMsg = "活动ID错误,Err:activityId:" + strconv.Itoa(activityId)
  2280. return
  2281. }
  2282. var isShowMobile bool
  2283. if activityInfo.ActivityTypeId == 1 || activityInfo.ActivityTypeId == 2 || activityInfo.ActivityTypeId == 3 {
  2284. isShowMobile = true
  2285. }
  2286. //超级管理员和权益管理员、权益研究员可以下载所有客户,销售组长能下载本组客户,销售只能下载本人名下客户
  2287. resp := new(cygx.CanDownload)
  2288. adminInfo, errAdmin := system.GetSysUserById(sysUser.AdminId)
  2289. if errAdmin != nil {
  2290. br.Msg = "获取失败"
  2291. br.ErrMsg = "获取失败,Err:" + errAdmin.Error()
  2292. return
  2293. }
  2294. if adminInfo.Role == "admin" || adminInfo.Role == "researcher" {
  2295. resp.IsCanDownload = true
  2296. }
  2297. memberType := "Admin"
  2298. sqlStr := ""
  2299. totalStr := sqlStr
  2300. if isShowMobile {
  2301. if resp.IsCanDownload == false && (activityInfo.ActivityTypeId == 1 || activityInfo.ActivityTypeId == 2 || activityInfo.ActivityTypeId == 3) {
  2302. if adminInfo.RoleTypeCode == "rai_group" {
  2303. //组长查看本组所有组员
  2304. memberType = "GroupLeader"
  2305. sqlStr += ` AND s.company_id IN (SELECT company_id FROM user_seller_relation WHERE seller_id IN (SELECT admin_id FROM admin WHERE group_id = (SELECT group_id FROM admin WHERE admin_id = ` + strconv.Itoa(sysUser.AdminId) + ` ) )) `
  2306. } else {
  2307. //组员查看自己
  2308. memberType = "Sale"
  2309. sqlStr += ` AND s.company_id IN (SELECT company_id FROM user_seller_relation WHERE seller_id = ` + strconv.Itoa(sysUser.AdminId) + `) `
  2310. }
  2311. }
  2312. }
  2313. list, err := cygx.GetCygxAppointmentSummaryList(activityId, sqlStr)
  2314. if err != nil {
  2315. br.Msg = "获取失败"
  2316. br.ErrMsg = "获取失败,Err:" + err.Error()
  2317. return
  2318. }
  2319. total, errtotal := cygx.GetCygxAppointmentSummaryCount(activityId, totalStr)
  2320. if errtotal != nil {
  2321. br.Msg = "获取失败"
  2322. br.ErrMsg = "客户总数获取失败,Err:" + errtotal.Error()
  2323. return
  2324. }
  2325. myTotal, errmyTotal := cygx.GetCygxAppointmentSummaryCount(activityId, sqlStr)
  2326. if errmyTotal != nil {
  2327. br.Msg = "获取失败"
  2328. br.ErrMsg = "我的客户总数获取失败,Err:" + errmyTotal.Error()
  2329. return
  2330. }
  2331. for k, v := range list {
  2332. list[k].SellerName = v.PsellerName
  2333. if !isShowMobile {
  2334. list[k].Mobile = ""
  2335. }
  2336. }
  2337. respList := new(cygx.GetAppointmentListRep)
  2338. respList.List = list
  2339. respList.Total = total
  2340. respList.MyTotal = myTotal
  2341. respList.ActivityId = activityId
  2342. respList.IsLimitPeople = activityInfo.IsLimitPeople
  2343. respList.MemberType = memberType
  2344. activityTypeId := activityInfo.ActivityTypeId
  2345. //ExcelType string `description:"EXcel下载类型 AppointmentCall:预约外呼、ExpertSalon:专家沙龙报名、Teleconference:公司调研电话会、OfflineResearch:公司线下调研 "`
  2346. if activityTypeId == 1 || activityTypeId == 2 {
  2347. respList.ExcelType = "AppointmentCall"
  2348. } else if activityTypeId == 5 || activityTypeId == 6 {
  2349. respList.ExcelType = "ExpertSalon"
  2350. } else if activityTypeId == 3 {
  2351. respList.ExcelType = "Teleconference"
  2352. } else if activityTypeId == 4 {
  2353. respList.ExcelType = "OfflineResearch"
  2354. }
  2355. if isShowMobile {
  2356. respList.ActivityType = 1
  2357. }
  2358. br.Ret = 200
  2359. br.Success = true
  2360. br.Msg = "获取成功"
  2361. br.Data = respList
  2362. }
  2363. // @Title 新增预约纪要人员
  2364. // @Description 新增预约纪要人员接口
  2365. // @Param request body cygx.AddOutboundPersonnelItm true "type json string"
  2366. // @Success 200 操作成功
  2367. // @router /activitySignup/appointment/addSummaryUser [post]
  2368. func (this *ActivitySignupCoAntroller) AddSummaryUser() {
  2369. br := new(models.BaseResponse).Init()
  2370. defer func() {
  2371. this.Data["json"] = br
  2372. this.ServeJSON()
  2373. }()
  2374. AdminUser := this.SysUser
  2375. if AdminUser == nil {
  2376. br.Msg = "请登录"
  2377. br.ErrMsg = "请登录,SysUser Is Empty"
  2378. return
  2379. }
  2380. var req cygx.AddOutboundPersonnelItm
  2381. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  2382. if err != nil {
  2383. br.Msg = "参数解析异常!"
  2384. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  2385. return
  2386. }
  2387. adminInfo, err := system.GetSysUserById(AdminUser.AdminId)
  2388. if err != nil {
  2389. br.Msg = "添加失败"
  2390. br.ErrMsg = "获取管理员信息失败,Err:" + err.Error()
  2391. return
  2392. }
  2393. var items []*cygx.CygxActivityAppointment
  2394. uids := req.UserIds
  2395. activityIds := req.ActivityIds
  2396. uidList := strings.Split(uids, ",")
  2397. activityIdList := strings.Split(activityIds, ",")
  2398. for _, v := range uidList {
  2399. uid, err := strconv.Atoi(v)
  2400. if err != nil {
  2401. br.Msg = "操作失败"
  2402. br.ErrMsg = "查询用户信息失败,Err:" + err.Error()
  2403. return
  2404. }
  2405. wxUser, userErr := models.GetWxUserByUserId(uid)
  2406. if userErr != nil {
  2407. br.Msg = "编辑失败!查询用户信息失败"
  2408. br.ErrMsg = "查询用户信息失败,Err:" + userErr.Error() + "用户UID:" + strconv.Itoa(uid) + "不存在"
  2409. return
  2410. }
  2411. for _, vact := range activityIdList {
  2412. activityId, _ := strconv.Atoi(vact)
  2413. activityInfo, err := cygx.GetAddActivityInfoById(activityId)
  2414. if err != nil {
  2415. br.Msg = "活动不存在"
  2416. br.ErrMsg = "活动ID错误,Err:activityId:" + strconv.Itoa(activityId)
  2417. return
  2418. }
  2419. if adminInfo.RoleTypeCode != "admin" {
  2420. //havePower := cygxService.CheckaddSignuUserPower(wxUser.CompanyId, activityId, activityInfo)
  2421. havePower, err := cygxService.GetActivityDetailUserPower(wxUser, AdminUser, activityInfo)
  2422. if err != nil {
  2423. br.Msg = "用户权限校验失败!"
  2424. br.ErrMsg = "GetActivityDetailUserPower,Err:" + err.Error() + fmt.Sprint("UserId", wxUser.UserId, "ActivityId:", activityInfo.ActivityId)
  2425. return
  2426. }
  2427. if !havePower {
  2428. br.Msg = "当前活动对该客户不可见,无法报名"
  2429. br.ErrMsg = "活动ID:" + strconv.Itoa(activityId) + "活动名称:" + activityInfo.ActivityName + "用户ID:" + strconv.Itoa(int(wxUser.UserId))
  2430. return
  2431. }
  2432. }
  2433. //isHideAppointment := cygxService.IsShowAppointmentByadminSet(activityInfo.IsCanAppointmentMinutes)
  2434. if activityInfo.IsCanAppointmentMinutes == 0 {
  2435. br.Msg = "当前活动无法新增预约纪要" + activityInfo.ActivityName
  2436. return
  2437. }
  2438. //if cygxService.CheckActivityAddAppointment(activityInfo) {
  2439. // br.Msg = "当前活动无法新增预约纪要" + activityInfo.ActivityName
  2440. // return
  2441. //}
  2442. total, errtotal := cygx.GetUserCygxActivityAppointmentCount(uid, activityId)
  2443. if errtotal != nil {
  2444. br.Msg = "获取失败"
  2445. br.ErrMsg = "获取失败,Err:" + errtotal.Error()
  2446. return
  2447. }
  2448. //判断这个用户是否报名了,如果没有报名则写入报名数据
  2449. if total == 0 {
  2450. infoUser, err := cygx.GetUserAndCompanyNameList(uid)
  2451. if err != nil {
  2452. br.Msg = "获取失败"
  2453. br.ErrMsg = "获取数据失败,Err:" + err.Error()
  2454. return
  2455. }
  2456. item := new(cygx.CygxActivityAppointment)
  2457. item.UserId = infoUser.UserId
  2458. item.RealName = infoUser.RealName
  2459. item.SellerName = infoUser.SellerName
  2460. item.ActivityId = activityId
  2461. item.CreateTime = time.Now()
  2462. item.Mobile = infoUser.Mobile
  2463. item.Email = infoUser.Email
  2464. item.CompanyId = infoUser.CompanyId
  2465. item.CompanyName = infoUser.CompanyName
  2466. item.Source = 2
  2467. items = append(items, item)
  2468. }
  2469. }
  2470. }
  2471. err = cygx.AddCygxActivityAppointmentUser(items)
  2472. if err != nil {
  2473. br.Msg = "操作失败"
  2474. br.ErrMsg = "新增用户失败,Err:" + err.Error()
  2475. return
  2476. }
  2477. //添加操作日志记录
  2478. br.IsAddLog = true
  2479. br.Ret = 200
  2480. br.Success = true
  2481. br.Msg = "操作成功"
  2482. }
  2483. // @Title 取消纪要纪要预约
  2484. // @Description 取消纪要纪要预约接口
  2485. // @Param request body cygx.CygxSignupId true "type json string"
  2486. // @Success Ret=200
  2487. // @router /activitySignup/appointment/cancel [post]
  2488. func (this *ActivitySignupCoAntroller) SummaryCancel() {
  2489. br := new(models.BaseResponse).Init()
  2490. defer func() {
  2491. this.Data["json"] = br
  2492. this.ServeJSON()
  2493. }()
  2494. AdminUser := this.SysUser
  2495. if AdminUser == nil {
  2496. br.Msg = "请登录"
  2497. br.ErrMsg = "请登录,SysUser Is Empty"
  2498. return
  2499. }
  2500. var req cygx.CygxSignupId
  2501. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  2502. if err != nil {
  2503. br.Msg = "参数解析异常!"
  2504. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  2505. return
  2506. }
  2507. signupId := req.SignupId
  2508. detail, err := cygx.GetCygxAppointmentSummaryInfoById(signupId)
  2509. if err != nil {
  2510. br.Msg = "预约信息不存在"
  2511. br.ErrMsg = "预约信息ID错误,Err:" + err.Error() + "id:" + strconv.Itoa(signupId)
  2512. return
  2513. }
  2514. _, err = cygx.CancelcygxActivityAppointment(detail)
  2515. if err != nil {
  2516. br.Msg = "操作失败"
  2517. br.ErrMsg = "操作失败,Err:" + err.Error()
  2518. return
  2519. }
  2520. //添加操作日志记录
  2521. br.IsAddLog = true
  2522. br.Ret = 200
  2523. br.Success = true
  2524. br.Msg = "操作成功"
  2525. }
  2526. // @Title 会议提醒人数详情
  2527. // @Description 会议提醒人数详情列表接口
  2528. // @Param ActivityId query int true "活动ID"
  2529. // @Success 200 {object} cygx.GetAppointmentListRep
  2530. // @router /activitySignup/reminder/list [get]
  2531. func (this *ActivitySignupCoAntroller) ReminderList() {
  2532. br := new(models.BaseResponse).Init()
  2533. defer func() {
  2534. this.Data["json"] = br
  2535. this.ServeJSON()
  2536. }()
  2537. sysUser := this.SysUser
  2538. if sysUser == nil {
  2539. br.Msg = "请登录"
  2540. br.ErrMsg = "请登录,SysUser Is Empty"
  2541. return
  2542. }
  2543. activityId, _ := this.GetInt("ActivityId")
  2544. if activityId < 1 {
  2545. br.Msg = "活动不存在"
  2546. return
  2547. }
  2548. activityInfo, _ := cygx.GetAddActivityInfoById(activityId)
  2549. if activityInfo == nil {
  2550. br.Msg = "活动不存在"
  2551. br.ErrMsg = "活动ID错误,Err:activityId:" + strconv.Itoa(activityId)
  2552. return
  2553. }
  2554. //超级管理员和权益管理员、权益研究员可以下载所有客户,销售组长能下载本组客户,销售只能下载本人名下客户
  2555. resp := new(cygx.CanDownload)
  2556. adminInfo, errAdmin := system.GetSysUserById(sysUser.AdminId)
  2557. if errAdmin != nil {
  2558. br.Msg = "获取失败"
  2559. br.ErrMsg = "获取失败,Err:" + errAdmin.Error()
  2560. return
  2561. }
  2562. if adminInfo.Role == "admin" || adminInfo.Role == "researcher" {
  2563. resp.IsCanDownload = true
  2564. }
  2565. memberType := "Admin"
  2566. sqlStr := ""
  2567. totalStr := sqlStr
  2568. if resp.IsCanDownload == false && (activityInfo.ActivityTypeId == 1 || activityInfo.ActivityTypeId == 2 || activityInfo.ActivityTypeId == 3) {
  2569. if adminInfo.RoleTypeCode == "rai_group" {
  2570. //组长查看本组所有组员
  2571. memberType = "GroupLeader"
  2572. sqlStr += ` AND s.company_id IN (SELECT company_id FROM user_seller_relation WHERE seller_id IN (SELECT admin_id FROM admin WHERE group_id = (SELECT group_id FROM admin WHERE admin_id = ` + strconv.Itoa(sysUser.AdminId) + ` ) )) `
  2573. } else {
  2574. //组员查看自己
  2575. memberType = "Sale"
  2576. sqlStr += ` AND s.company_id IN (SELECT company_id FROM user_seller_relation WHERE seller_id = ` + strconv.Itoa(sysUser.AdminId) + `) `
  2577. }
  2578. }
  2579. list, err := cygx.GetCygxActivityMeetingReminderList(activityId, sqlStr)
  2580. if err != nil {
  2581. br.Msg = "获取失败"
  2582. br.ErrMsg = "获取失败,Err:" + err.Error()
  2583. return
  2584. }
  2585. total, errtotal := cygx.GetCygxActivityMeetingReminderCount(activityId, totalStr)
  2586. if errtotal != nil {
  2587. br.Msg = "获取失败"
  2588. br.ErrMsg = "客户总数获取失败,Err:" + errtotal.Error()
  2589. return
  2590. }
  2591. myTotal, errmyTotal := cygx.GetCygxActivityMeetingReminderCount(activityId, sqlStr)
  2592. if errmyTotal != nil {
  2593. br.Msg = "获取失败"
  2594. br.ErrMsg = "我的客户总数获取失败,Err:" + errmyTotal.Error()
  2595. return
  2596. }
  2597. if len(list) > 0 {
  2598. for k, v := range list {
  2599. list[k].SellerName = v.PsellerName
  2600. }
  2601. } else {
  2602. list = make([]*cygx.CygxAppointmentList, 0)
  2603. }
  2604. respList := new(cygx.GetAppointmentListRep)
  2605. respList.List = list
  2606. respList.Total = total
  2607. respList.MyTotal = myTotal
  2608. respList.ActivityId = activityId
  2609. respList.IsLimitPeople = activityInfo.IsLimitPeople
  2610. respList.MemberType = memberType
  2611. activityTypeId := activityInfo.ActivityTypeId
  2612. //ExcelType string `description:"EXcel下载类型 AppointmentCall:预约外呼、ExpertSalon:专家沙龙报名、Teleconference:公司调研电话会、OfflineResearch:公司线下调研 "`
  2613. if activityTypeId == 1 || activityTypeId == 2 {
  2614. respList.ExcelType = "AppointmentCall"
  2615. } else if activityTypeId == 5 || activityTypeId == 6 {
  2616. respList.ExcelType = "ExpertSalon"
  2617. } else if activityTypeId == 3 {
  2618. respList.ExcelType = "Teleconference"
  2619. } else if activityTypeId == 4 {
  2620. respList.ExcelType = "OfflineResearch"
  2621. }
  2622. br.Ret = 200
  2623. br.Success = true
  2624. br.Msg = "获取成功"
  2625. br.Data = respList
  2626. }
  2627. // @Title 取消会议提醒
  2628. // @Description 取消会议提醒接口
  2629. // @Param request body cygx.CygxSignupId true "type json string"
  2630. // @Success Ret=200
  2631. // @router /activitySignup/reminder/cancel [post]
  2632. func (this *ActivitySignupCoAntroller) ReminderCancel() {
  2633. br := new(models.BaseResponse).Init()
  2634. defer func() {
  2635. this.Data["json"] = br
  2636. this.ServeJSON()
  2637. }()
  2638. AdminUser := this.SysUser
  2639. if AdminUser == nil {
  2640. br.Msg = "请登录"
  2641. br.ErrMsg = "请登录,SysUser Is Empty"
  2642. return
  2643. }
  2644. var req cygx.CygxSignupId
  2645. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  2646. if err != nil {
  2647. br.Msg = "参数解析异常!"
  2648. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  2649. return
  2650. }
  2651. signupId := req.SignupId
  2652. detail, err := cygx.GetCygxActivityMeetingReminderInfoById(signupId)
  2653. if err != nil {
  2654. br.Msg = "预约信息不存在"
  2655. br.ErrMsg = "预约信息ID错误,Err:" + err.Error() + "id:" + strconv.Itoa(signupId)
  2656. return
  2657. }
  2658. _, err = cygx.CancelActivityMeetingReminder(detail)
  2659. if err != nil {
  2660. br.Msg = "操作失败"
  2661. br.ErrMsg = "操作失败,Err:" + err.Error()
  2662. return
  2663. }
  2664. //添加操作日志记录
  2665. br.IsAddLog = true
  2666. br.Ret = 200
  2667. br.Success = true
  2668. br.Msg = "操作成功"
  2669. }
  2670. // @Title 发送模版消息
  2671. // @Description 发送模版消息接口
  2672. // @Param request body cygx.AddOutboundPersonnelItm true "type json string"
  2673. // @Success 200 操作成功
  2674. // @router /activitySignup/tempMsg [post]
  2675. func (this *ActivitySignupCoAntroller) TempMsg() {
  2676. br := new(models.BaseResponse).Init()
  2677. defer func() {
  2678. this.Data["json"] = br
  2679. this.ServeJSON()
  2680. }()
  2681. AdminUser := this.SysUser
  2682. if AdminUser == nil {
  2683. br.Msg = "请登录"
  2684. br.ErrMsg = "请登录,SysUser Is Empty"
  2685. return
  2686. }
  2687. var req cygx.ActivitySignupTempMsgReq
  2688. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  2689. if err != nil {
  2690. br.Msg = "参数解析异常!"
  2691. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  2692. return
  2693. }
  2694. //adminInfo, err := system.GetSysUserById(AdminUser.AdminId)
  2695. //if err != nil {
  2696. // br.Msg = "添加失败"
  2697. // br.ErrMsg = "获取管理员信息失败,Err:" + err.Error()
  2698. // return
  2699. //}
  2700. idSlice := strings.Split(req.ActivityIds, ",")
  2701. for _, sId := range idSlice {
  2702. id, e := strconv.Atoi(sId)
  2703. if e != nil {
  2704. br.Msg = "活动Id参数异常"
  2705. br.ErrMsg = "参数解析异常, Err:" + e.Error()
  2706. return
  2707. }
  2708. var openIdList []*models.OpenIdList
  2709. idMap := make(map[string]string, 0)
  2710. if strings.Contains(req.SendGroup, "1") {
  2711. list, err := models.GetCygxUserIndustryFllowOpneidByActivityIds(id)
  2712. if err != nil {
  2713. br.Msg = "查询openId失败"
  2714. br.ErrMsg = "查询openId失败,Err:" + err.Error()
  2715. return
  2716. }
  2717. for _, idList := range list {
  2718. openIdList = append(openIdList, idList)
  2719. idMap[idList.OpenId] = idList.OpenId
  2720. }
  2721. }
  2722. if strings.Contains(req.SendGroup, "2") {
  2723. list, err := models.GetCygxForeverUserIndustryFllowOpneidByActivityIds(id)
  2724. if err != nil {
  2725. br.Msg = "查询openId失败"
  2726. br.ErrMsg = "查询openId失败,Err:" + err.Error()
  2727. return
  2728. }
  2729. for _, idList := range openIdList {
  2730. idMap[idList.OpenId] = idList.OpenId
  2731. }
  2732. for _, idList := range list {
  2733. if _, ok := idMap[idList.OpenId]; !ok {
  2734. openIdList = append(openIdList, idList)
  2735. idMap[idList.OpenId] = idList.OpenId
  2736. }
  2737. }
  2738. }
  2739. if strings.Contains(req.SendGroup, "3") {
  2740. list, err := cygxService.GetCygxBigTypeUserIndustryFllowOpneidByActivityIds(id)
  2741. if err != nil {
  2742. br.Msg = "查询openId失败"
  2743. br.ErrMsg = "查询openId失败,Err:" + err.Error()
  2744. return
  2745. }
  2746. for _, idList := range openIdList {
  2747. idMap[idList.OpenId] = idList.OpenId
  2748. }
  2749. for _, idList := range list {
  2750. if _, ok := idMap[idList.OpenId]; !ok {
  2751. openIdList = append(openIdList, idList)
  2752. idMap[idList.OpenId] = idList.OpenId
  2753. }
  2754. }
  2755. }
  2756. if strings.Contains(req.SendGroup, "4") {
  2757. list, err := cygxService.GetCygxIndustryPackageUserIndustryFllowOpneidByActivityIds(id)
  2758. if err != nil {
  2759. br.Msg = "查询openId失败"
  2760. br.ErrMsg = "查询openId失败,Err:" + err.Error()
  2761. return
  2762. }
  2763. for _, idList := range openIdList {
  2764. idMap[idList.OpenId] = idList.OpenId
  2765. }
  2766. for _, idList := range list {
  2767. if _, ok := idMap[idList.OpenId]; !ok {
  2768. openIdList = append(openIdList, idList)
  2769. idMap[idList.OpenId] = idList.OpenId
  2770. }
  2771. }
  2772. }
  2773. if strings.Contains(req.SendGroup, "5") {
  2774. list, err := cygxService.GetCygxOtherIndustryPackageUserIndustryFllowOpneidByActivityIds(id)
  2775. if err != nil {
  2776. br.Msg = "查询openId失败"
  2777. br.ErrMsg = "查询openId失败,Err:" + err.Error()
  2778. return
  2779. }
  2780. for _, idList := range openIdList {
  2781. idMap[idList.OpenId] = idList.OpenId
  2782. }
  2783. for _, idList := range list {
  2784. if _, ok := idMap[idList.OpenId]; !ok {
  2785. openIdList = append(openIdList, idList)
  2786. idMap[idList.OpenId] = idList.OpenId
  2787. }
  2788. }
  2789. }
  2790. if strings.Contains(req.SendGroup, "6") {
  2791. list, err := models.GetCygxTryOutUserIndustryFllowOpneidByActivityIds(id)
  2792. if err != nil {
  2793. br.Msg = "查询openId失败"
  2794. br.ErrMsg = "查询openId失败,Err:" + err.Error()
  2795. return
  2796. }
  2797. for _, idList := range openIdList {
  2798. idMap[idList.OpenId] = idList.OpenId
  2799. }
  2800. for _, idList := range list {
  2801. if _, ok := idMap[idList.OpenId]; !ok {
  2802. openIdList = append(openIdList, idList)
  2803. idMap[idList.OpenId] = idList.OpenId
  2804. }
  2805. }
  2806. }
  2807. if strings.Contains(req.SendGroup, "7") {
  2808. list, err := cygxService.GetCygxInteractiveUserOpneidByActivityIds(id)
  2809. if err != nil {
  2810. br.Msg = "查询openId失败"
  2811. br.ErrMsg = "查询openId失败,Err:" + err.Error()
  2812. return
  2813. }
  2814. for _, idList := range openIdList {
  2815. idMap[idList.OpenId] = idList.OpenId
  2816. }
  2817. for _, idList := range list {
  2818. if _, ok := idMap[idList.OpenId]; !ok {
  2819. openIdList = append(openIdList, idList)
  2820. idMap[idList.OpenId] = idList.OpenId
  2821. }
  2822. }
  2823. }
  2824. if len(openIdList) > 0 {
  2825. openIdArr := make([]string, len(openIdList))
  2826. for i, v := range openIdList {
  2827. openIdArr[i] = v.OpenId
  2828. }
  2829. sendInfo := new(services.SendWxTemplate)
  2830. //sendInfo.First = req.FirstText
  2831. sendInfo.Keyword1 = req.ActivityName
  2832. sendInfo.Keyword2 = req.Content
  2833. //sendInfo.Keyword3 = meetingTime
  2834. sendInfo.Remark = "点击查看活动详情"
  2835. sendInfo.TemplateId = utils.WxMsgTemplateIdActivityChangeApplyXzs
  2836. sendInfo.RedirectUrl = utils.WX_MSG_PATH_ACTIVITY_DETAIL + strconv.Itoa(id)
  2837. sendInfo.RedirectTarget = 3
  2838. sendInfo.Resource = strconv.Itoa(id)
  2839. sendInfo.SendType = utils.TEMPLATE_MSG_CYGX_ACTIVITY_CUSTOMIZE
  2840. sendInfo.OpenIdArr = openIdArr
  2841. e = services.SendTemplateMsg(sendInfo)
  2842. if e != nil {
  2843. br.Msg = "推送模板消息失败!"
  2844. br.ErrMsg = "参数解析失败,Err:" + e.Error()
  2845. return
  2846. }
  2847. }
  2848. }
  2849. br.Ret = 200
  2850. br.Success = true
  2851. br.Msg = "发送成功"
  2852. }
  2853. // @Title 模版消息发送客户类型列表
  2854. // @Description 模版消息发送客户类型列表接口
  2855. // @Success Ret=200
  2856. // @router /activitySignup/tempMsg/sendGroupList [get]
  2857. func (this *ActivitySignupCoAntroller) SendGroupList() {
  2858. br := new(models.BaseResponse).Init()
  2859. defer func() {
  2860. this.Data["json"] = br
  2861. this.ServeJSON()
  2862. }()
  2863. AdminUser := this.SysUser
  2864. if AdminUser == nil {
  2865. br.Msg = "请登录"
  2866. br.ErrMsg = "请登录,SysUser Is Empty"
  2867. return
  2868. }
  2869. list := make([]cygx.SendGroup, 0)
  2870. list = append(list, cygx.SendGroup{
  2871. Id: 1,
  2872. Name: "全部客户",
  2873. })
  2874. list = append(list, cygx.SendGroup{
  2875. Id: 2,
  2876. Name: "永续客户",
  2877. })
  2878. list = append(list, cygx.SendGroup{
  2879. Id: 3,
  2880. Name: "大套餐客户",
  2881. })
  2882. list = append(list, cygx.SendGroup{
  2883. Id: 4,
  2884. Name: "行业套餐客户",
  2885. })
  2886. list = append(list, cygx.SendGroup{
  2887. Id: 5,
  2888. Name: "其他行业正式客户",
  2889. })
  2890. list = append(list, cygx.SendGroup{
  2891. Id: 6,
  2892. Name: "试用客户",
  2893. })
  2894. list = append(list, cygx.SendGroup{
  2895. Id: 7,
  2896. Name: "已参与互动的客户",
  2897. })
  2898. br.Ret = 200
  2899. br.Success = true
  2900. br.Data = list
  2901. }