activity_signup.go 102 KB

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