report.go 56 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732
  1. package roadshow
  2. import (
  3. "encoding/json"
  4. "github.com/rdlucklib/rdluck_tools/paging"
  5. "hongze/hz_crm_api/models"
  6. "hongze/hz_crm_api/models/company"
  7. "hongze/hz_crm_api/models/overseas_custom"
  8. "hongze/hz_crm_api/models/roadshow"
  9. "hongze/hz_crm_api/models/system"
  10. "hongze/hz_crm_api/services"
  11. roadshowService "hongze/hz_crm_api/services/roadshow"
  12. "hongze/hz_crm_api/utils"
  13. "strconv"
  14. "strings"
  15. "time"
  16. )
  17. // ResearcherReportList
  18. // @Title 研究员路演统计
  19. // @Description 研究员路演统计接口
  20. // @Param DataType query string true "枚举值:week、month、time_interval"
  21. // @Param StartDate query string true "开始日期,格式:2022-04-06"
  22. // @Param EndDate query string true "结束日期,格式:2022-04-06"
  23. // @Success 200 {object} roadshow.RsReportRecordResp
  24. // @router /report/researcher/list [get]
  25. func (this *CalendarController) ResearcherReportList() {
  26. br := new(models.BaseResponse).Init()
  27. defer func() {
  28. this.Data["json"] = br
  29. this.ServeJSON()
  30. }()
  31. sysUser := this.SysUser
  32. if sysUser == nil {
  33. br.Msg = "请登录"
  34. br.ErrMsg = "请登录,SysUser Is Empty"
  35. br.Ret = 408
  36. return
  37. }
  38. dataType := this.GetString("DataType")
  39. startDate := this.GetString("StartDate")
  40. endDate := this.GetString("EndDate")
  41. var adminDataList []roadshowService.AdminDataMap
  42. var err error
  43. //var firstDate time.Time
  44. //获取列表
  45. switch dataType {
  46. case "week":
  47. adminDataList, _, err = roadshowService.GetWeekData("researcher", "company_status")
  48. if err != nil {
  49. br.Msg = "数据异常"
  50. br.ErrMsg = "数据异常,Err:" + err.Error()
  51. return
  52. }
  53. case "month":
  54. adminDataList, _, err = roadshowService.GetMonthData("researcher", "company_status")
  55. if err != nil {
  56. br.Msg = "数据异常"
  57. br.ErrMsg = "数据异常,Err:" + err.Error()
  58. return
  59. }
  60. case "time_interval":
  61. if startDate == `` || endDate == `` {
  62. br.Msg = "开始日期或结束日期不能为空"
  63. br.ErrMsg = "开始日期或结束日期不能为空,Err:" + err.Error()
  64. return
  65. }
  66. adminDataList, _, err = roadshowService.GetTimeIntervalData(startDate, endDate, "researcher", "company_status")
  67. if err != nil {
  68. br.Msg = "数据异常"
  69. br.ErrMsg = "数据异常,Err:" + err.Error()
  70. return
  71. }
  72. }
  73. group, err := roadshow.GetResearcherGroup()
  74. if err != nil {
  75. br.Msg = "获取信息失败!"
  76. br.ErrMsg = "获取分组信息失败!Err:" + err.Error()
  77. return
  78. }
  79. researcherList, err := roadshow.GetResearcherV2()
  80. if err != nil {
  81. br.Msg = "获取信息失败!"
  82. br.ErrMsg = "获取分组信息失败!,GetResearcherV2 Err:" + err.Error()
  83. return
  84. }
  85. groupMap := make(map[int][]*roadshow.ResearcherGroup)
  86. for _, v := range researcherList {
  87. item := &roadshow.ResearcherGroup{
  88. GroupId: v.GroupId,
  89. GroupName: v.GroupName,
  90. AdminId: v.AdminId,
  91. RealName: v.RealName,
  92. RoleTypeCode: v.RoleTypeCode,
  93. }
  94. if findItems, ok := groupMap[v.GroupId]; ok {
  95. findItems = append(findItems, item)
  96. groupMap[v.GroupId] = findItems
  97. } else {
  98. findItems = append(findItems, item)
  99. groupMap[v.GroupId] = findItems
  100. }
  101. //}
  102. }
  103. for _, v := range group {
  104. v.ResearcherList = groupMap[v.GroupId]
  105. }
  106. groupReportRecordList := make([]roadshow.GroupReportRecord, 0)
  107. rsAllReportRecordNumList := make([]roadshow.RsReportRecordNum, 0)
  108. RsReportRecordResp := roadshow.RsReportRecordResp{
  109. List: groupReportRecordList,
  110. RsReportRecordNumList: rsAllReportRecordNumList,
  111. }
  112. startDateIndexList := make(map[int]string) //开始时间间隔map
  113. endDateIndexList := make(map[int]string) //结束时间间隔map
  114. tmpAllTryOutNumMap := make(map[int]int)
  115. tmpAllFormalNumMap := make(map[int]int)
  116. tmpAllMeetingNumMap := make(map[int]int)
  117. for _, v := range group {
  118. v.ResearcherList = groupMap[v.GroupId]
  119. tmpGroupAdminReportRecord := make([]roadshow.AdminReportRecord, 0)
  120. tmpGroupRsReportRecordNumList := make([]roadshow.RsReportRecordNum, 0)
  121. tmpGroupTryOutNumMap := make(map[int]int)
  122. tmpGroupFormalNumMap := make(map[int]int)
  123. tmpGroupMeetingNumMap := make(map[int]int)
  124. for _, researcher := range groupMap[v.GroupId] {
  125. //组内研究员数据
  126. //每个区间的数据
  127. tmpAdminRsReportRecordNumList := make([]roadshow.RsReportRecordNum, 0)
  128. for index, adminData := range adminDataList {
  129. startDateIndexList[index] = adminData.StartDate
  130. endDateIndexList[index] = adminData.EndDate
  131. var tmpTryOutNum, tmpFormalNum, tmpMeetingNum int
  132. if num, ok := adminData.TryOutMap[researcher.AdminId]; ok {
  133. tmpTryOutNum = num
  134. }
  135. if num, ok := adminData.FormalMap[researcher.AdminId]; ok {
  136. tmpFormalNum = num
  137. }
  138. if num, ok := adminData.MeetingMap[researcher.AdminId]; ok {
  139. tmpMeetingNum = num
  140. }
  141. tmpAdminRsReportRecordNum := roadshow.RsReportRecordNum{
  142. TryOutNum: tmpTryOutNum,
  143. FormalNum: tmpFormalNum,
  144. MeetingNum: tmpMeetingNum,
  145. StartDate: adminData.StartDate,
  146. EndDate: adminData.EndDate,
  147. }
  148. tmpAdminRsReportRecordNumList = append(tmpAdminRsReportRecordNumList, tmpAdminRsReportRecordNum)
  149. //组内数据汇总
  150. if _, ok := tmpGroupTryOutNumMap[index]; !ok {
  151. tmpGroupTryOutNumMap[index] = 0
  152. }
  153. if _, ok := tmpGroupFormalNumMap[index]; !ok {
  154. tmpGroupFormalNumMap[index] = 0
  155. }
  156. if _, ok := tmpGroupMeetingNumMap[index]; !ok {
  157. tmpGroupMeetingNumMap[index] = 0
  158. }
  159. tmpGroupTryOutNumMap[index] += tmpTryOutNum
  160. tmpGroupFormalNumMap[index] += tmpFormalNum
  161. tmpGroupMeetingNumMap[index] += tmpMeetingNum
  162. //总数据汇总
  163. if _, ok := tmpAllTryOutNumMap[index]; !ok {
  164. tmpAllTryOutNumMap[index] = 0
  165. }
  166. if _, ok := tmpAllFormalNumMap[index]; !ok {
  167. tmpAllFormalNumMap[index] = 0
  168. }
  169. if _, ok := tmpAllMeetingNumMap[index]; !ok {
  170. tmpAllMeetingNumMap[index] = 0
  171. }
  172. tmpAllTryOutNumMap[index] += tmpTryOutNum
  173. tmpAllFormalNumMap[index] += tmpFormalNum
  174. tmpAllMeetingNumMap[index] += tmpMeetingNum
  175. }
  176. tmpAdminReportRecord := roadshow.AdminReportRecord{
  177. Name: researcher.RealName,
  178. AdminId: researcher.AdminId,
  179. RsReportRecordNumList: tmpAdminRsReportRecordNumList,
  180. }
  181. tmpGroupAdminReportRecord = append(tmpGroupAdminReportRecord, tmpAdminReportRecord)
  182. }
  183. for i := 0; i < len(tmpGroupMeetingNumMap); i++ {
  184. tmpGroupRsReportRecordNum := roadshow.RsReportRecordNum{
  185. TryOutNum: tmpGroupTryOutNumMap[i],
  186. FormalNum: tmpGroupFormalNumMap[i],
  187. MeetingNum: tmpGroupMeetingNumMap[i],
  188. StartDate: startDateIndexList[i],
  189. EndDate: endDateIndexList[i],
  190. }
  191. tmpGroupRsReportRecordNumList = append(tmpGroupRsReportRecordNumList, tmpGroupRsReportRecordNum)
  192. }
  193. groupReportRecord := roadshow.GroupReportRecord{
  194. Item: tmpGroupAdminReportRecord,
  195. Name: v.GroupName,
  196. RsReportRecordNumList: tmpGroupRsReportRecordNumList,
  197. }
  198. RsReportRecordResp.List = append(RsReportRecordResp.List, groupReportRecord)
  199. }
  200. //总体汇总数据
  201. for i := 0; i < len(tmpAllFormalNumMap); i++ {
  202. tmpGroupRsReportRecordNum := roadshow.RsReportRecordNum{
  203. TryOutNum: tmpAllTryOutNumMap[i],
  204. FormalNum: tmpAllFormalNumMap[i],
  205. MeetingNum: tmpAllMeetingNumMap[i],
  206. StartDate: startDateIndexList[i],
  207. EndDate: endDateIndexList[i],
  208. }
  209. rsAllReportRecordNumList = append(rsAllReportRecordNumList, tmpGroupRsReportRecordNum)
  210. }
  211. RsReportRecordResp.RsReportRecordNumList = rsAllReportRecordNumList
  212. br.Ret = 200
  213. br.Success = true
  214. br.Msg = "获取成功"
  215. br.Data = RsReportRecordResp
  216. return
  217. }
  218. // SellerReportList
  219. // @Title 销售路演统计
  220. // @Description 销售路演统计接口
  221. // @Param DataType query string true "枚举值:week、month、time_interval、online、offline"
  222. // @Param DimensionType query string true "维度枚举值:company_status、roadshow_type"
  223. // @Param StartDate query string true "开始日期,格式:2022-04-06"
  224. // @Param EndDate query string true "结束日期,格式:2022-04-06"
  225. // @Success 200 {object} roadshow.RsReportRecordResp
  226. // @router /report/seller/list [get]
  227. func (this *CalendarController) SellerReportList() {
  228. br := new(models.BaseResponse).Init()
  229. defer func() {
  230. this.Data["json"] = br
  231. this.ServeJSON()
  232. }()
  233. sysUser := this.SysUser
  234. if sysUser == nil {
  235. br.Msg = "请登录"
  236. br.ErrMsg = "请登录,SysUser Is Empty"
  237. br.Ret = 408
  238. return
  239. }
  240. dataType := this.GetString("DataType")
  241. dimensionType := this.GetString("DimensionType")
  242. startDate := this.GetString("StartDate")
  243. endDate := this.GetString("EndDate")
  244. if dimensionType == "" {
  245. dimensionType = "company_status"
  246. }
  247. var adminDataList []roadshowService.AdminDataMap
  248. var err error
  249. var firstDate time.Time
  250. //获取列表
  251. switch dataType {
  252. case "week":
  253. adminDataList, firstDate, err = roadshowService.GetWeekDataV2("seller", dimensionType, 6)
  254. if err != nil {
  255. br.Msg = "数据异常"
  256. br.ErrMsg = "数据异常,Err:" + err.Error()
  257. return
  258. }
  259. case "month":
  260. adminDataList, firstDate, err = roadshowService.GetMonthDataV2("seller", dimensionType, 6)
  261. if err != nil {
  262. br.Msg = "数据异常"
  263. br.ErrMsg = "数据异常,Err:" + err.Error()
  264. return
  265. }
  266. case "time_interval":
  267. if startDate == `` || endDate == `` {
  268. br.Msg = "开始日期或结束日期不能为空"
  269. br.ErrMsg = "开始日期或结束日期不能为空,Err:" + err.Error()
  270. return
  271. }
  272. adminDataList, firstDate, err = roadshowService.GetTimeIntervalData(startDate, endDate, "seller", dimensionType)
  273. if err != nil {
  274. br.Msg = "数据异常"
  275. br.ErrMsg = "数据异常,Err:" + err.Error()
  276. return
  277. }
  278. }
  279. group, groupIdRelationMap, err := services.GetFiccSystemGroup()
  280. if err != nil {
  281. br.Msg = "获取信息失败!"
  282. br.ErrMsg = "获取分组信息失败!Err:" + err.Error()
  283. return
  284. }
  285. researcherList, err := services.GetFiccSeller(firstDate, groupIdRelationMap)
  286. groupMap := make(map[int][]*roadshow.Researcher)
  287. for _, v := range researcherList {
  288. if v.RoleTypeCode == "ficc_admin" {
  289. findItems := groupMap[1]
  290. findItems = append(findItems, v)
  291. groupMap[1] = findItems
  292. } else {
  293. if findItems, ok := groupMap[v.GroupId]; ok {
  294. findItems = append(findItems, v)
  295. groupMap[v.GroupId] = findItems
  296. } else {
  297. findItems = append(findItems, v)
  298. groupMap[v.GroupId] = findItems
  299. }
  300. }
  301. }
  302. groupReportRecordList := make([]roadshow.GroupReportRecord, 0)
  303. rsAllReportRecordNumList := make([]roadshow.RsReportRecordNum, 0)
  304. RsReportRecordResp := roadshow.RsReportRecordResp{
  305. List: groupReportRecordList,
  306. RsReportRecordNumList: rsAllReportRecordNumList,
  307. }
  308. startDateIndexList := make(map[int]string) //开始时间间隔map
  309. endDateIndexList := make(map[int]string) //结束时间间隔map
  310. tmpAllTryOutNumMap := make(map[int]int)
  311. tmpAllFormalNumMap := make(map[int]int)
  312. tmpAllMeetingNumMap := make(map[int]int)
  313. tmpAllOnlineNumMap := make(map[int]int)
  314. tmpAllOfflineNumMap := make(map[int]int)
  315. for _, v := range group {
  316. v.ResearcherList = groupMap[v.GroupId]
  317. tmpGroupAdminReportRecord := make([]roadshow.AdminReportRecord, 0)
  318. tmpGroupRsReportRecordNumList := make([]roadshow.RsReportRecordNum, 0)
  319. tmpGroupTryOutNumMap := make(map[int]int)
  320. tmpGroupFormalNumMap := make(map[int]int)
  321. tmpGroupMeetingNumMap := make(map[int]int)
  322. tmpGroupOnlineNumMap := make(map[int]int)
  323. tmpGroupOfflineNumMap := make(map[int]int)
  324. for _, researcher := range groupMap[v.GroupId] {
  325. //组内研究员数据
  326. //每个区间的数据
  327. tmpAdminRsReportRecordNumList := make([]roadshow.RsReportRecordNum, 0)
  328. for index, adminData := range adminDataList {
  329. startDateIndexList[index] = adminData.StartDate
  330. endDateIndexList[index] = adminData.EndDate
  331. var tmpTryOutNum, tmpFormalNum, tmpMeetingNum, tmpOnlineNum, tmpOfflineNum int
  332. if num, ok := adminData.TryOutMap[researcher.AdminId]; ok {
  333. tmpTryOutNum = num
  334. }
  335. if num, ok := adminData.FormalMap[researcher.AdminId]; ok {
  336. tmpFormalNum = num
  337. }
  338. if num, ok := adminData.MeetingMap[researcher.AdminId]; ok {
  339. tmpMeetingNum = num
  340. }
  341. if num, ok := adminData.OnlineMap[researcher.AdminId]; ok {
  342. tmpOnlineNum = num
  343. }
  344. if num, ok := adminData.OfflineMap[researcher.AdminId]; ok {
  345. tmpOfflineNum = num
  346. }
  347. tmpAdminRsReportRecordNum := roadshow.RsReportRecordNum{
  348. TryOutNum: tmpTryOutNum,
  349. FormalNum: tmpFormalNum,
  350. MeetingNum: tmpMeetingNum,
  351. OnlineNum: tmpOnlineNum,
  352. OfflineNum: tmpOfflineNum,
  353. StartDate: adminData.StartDate,
  354. EndDate: adminData.EndDate,
  355. }
  356. tmpAdminRsReportRecordNumList = append(tmpAdminRsReportRecordNumList, tmpAdminRsReportRecordNum)
  357. //组内数据汇总
  358. if _, ok := tmpGroupTryOutNumMap[index]; !ok {
  359. tmpGroupTryOutNumMap[index] = 0
  360. }
  361. if _, ok := tmpGroupFormalNumMap[index]; !ok {
  362. tmpGroupFormalNumMap[index] = 0
  363. }
  364. if _, ok := tmpGroupMeetingNumMap[index]; !ok {
  365. tmpGroupMeetingNumMap[index] = 0
  366. }
  367. if _, ok := tmpGroupOnlineNumMap[index]; !ok {
  368. tmpGroupOnlineNumMap[index] = 0
  369. }
  370. if _, ok := tmpGroupOfflineNumMap[index]; !ok {
  371. tmpGroupOfflineNumMap[index] = 0
  372. }
  373. tmpGroupTryOutNumMap[index] += tmpTryOutNum
  374. tmpGroupFormalNumMap[index] += tmpFormalNum
  375. tmpGroupMeetingNumMap[index] += tmpMeetingNum
  376. tmpGroupOnlineNumMap[index] += tmpOnlineNum
  377. tmpGroupOfflineNumMap[index] += tmpOfflineNum
  378. //总数据汇总
  379. if _, ok := tmpAllTryOutNumMap[index]; !ok {
  380. tmpAllTryOutNumMap[index] = 0
  381. }
  382. if _, ok := tmpAllFormalNumMap[index]; !ok {
  383. tmpAllFormalNumMap[index] = 0
  384. }
  385. if _, ok := tmpAllMeetingNumMap[index]; !ok {
  386. tmpAllMeetingNumMap[index] = 0
  387. }
  388. if _, ok := tmpAllOnlineNumMap[index]; !ok {
  389. tmpAllOnlineNumMap[index] = 0
  390. }
  391. if _, ok := tmpAllOfflineNumMap[index]; !ok {
  392. tmpAllOfflineNumMap[index] = 0
  393. }
  394. tmpAllTryOutNumMap[index] += tmpTryOutNum
  395. tmpAllFormalNumMap[index] += tmpFormalNum
  396. tmpAllMeetingNumMap[index] += tmpMeetingNum
  397. tmpAllOnlineNumMap[index] += tmpOnlineNum
  398. tmpAllOfflineNumMap[index] += tmpOfflineNum
  399. }
  400. tmpAdminReportRecord := roadshow.AdminReportRecord{
  401. Name: researcher.RealName,
  402. AdminId: researcher.AdminId,
  403. RsReportRecordNumList: tmpAdminRsReportRecordNumList,
  404. }
  405. tmpGroupAdminReportRecord = append(tmpGroupAdminReportRecord, tmpAdminReportRecord)
  406. }
  407. for i := 0; i < len(tmpGroupMeetingNumMap); i++ {
  408. tmpGroupRsReportRecordNum := roadshow.RsReportRecordNum{
  409. TryOutNum: tmpGroupTryOutNumMap[i],
  410. FormalNum: tmpGroupFormalNumMap[i],
  411. MeetingNum: tmpGroupMeetingNumMap[i],
  412. OnlineNum: tmpGroupOnlineNumMap[i],
  413. OfflineNum: tmpGroupOfflineNumMap[i],
  414. StartDate: startDateIndexList[i],
  415. EndDate: endDateIndexList[i],
  416. }
  417. tmpGroupRsReportRecordNumList = append(tmpGroupRsReportRecordNumList, tmpGroupRsReportRecordNum)
  418. }
  419. groupReportRecord := roadshow.GroupReportRecord{
  420. Item: tmpGroupAdminReportRecord,
  421. Name: v.GroupName,
  422. GruopId: v.GroupId,
  423. RsReportRecordNumList: tmpGroupRsReportRecordNumList,
  424. }
  425. groupReportRecordList = append(groupReportRecordList, groupReportRecord)
  426. }
  427. //总体汇总数据
  428. for i := 0; i < len(tmpAllFormalNumMap); i++ {
  429. tmpGroupRsReportRecordNum := roadshow.RsReportRecordNum{
  430. TryOutNum: tmpAllTryOutNumMap[i],
  431. FormalNum: tmpAllFormalNumMap[i],
  432. MeetingNum: tmpAllMeetingNumMap[i],
  433. OnlineNum: tmpAllOnlineNumMap[i],
  434. OfflineNum: tmpAllOfflineNumMap[i],
  435. StartDate: startDateIndexList[i],
  436. EndDate: endDateIndexList[i],
  437. }
  438. rsAllReportRecordNumList = append(rsAllReportRecordNumList, tmpGroupRsReportRecordNum)
  439. }
  440. RsReportRecordResp.RsReportRecordNumList = rsAllReportRecordNumList
  441. //tmpList := groupReportRecordList
  442. //因为RoleTypeCode不一样,所以需要重新从数据库取数据
  443. //adminInfo, _ := system.GetSysAdminById(sysUser.AdminId)
  444. //adminGroupId := adminInfo.GroupId
  445. //if tmpGroupId, ok := groupIdRelationMap[adminGroupId]; ok {
  446. // adminGroupId = tmpGroupId
  447. //}
  448. //switch adminInfo.RoleTypeCode {
  449. //case utils.ROLE_TYPE_CODE_FICC_GROUP, utils.ROLE_TYPE_CODE_FICC_TEAM:
  450. // for index, v := range tmpList {
  451. // //如果不是同一个分组,那么就移除该分组下的人员数据
  452. // if v.GruopId != adminGroupId {
  453. // tmpList[index].Item = make([]roadshow.AdminReportRecord, 0)
  454. // }
  455. // }
  456. // RsReportRecordResp.List = tmpList
  457. //case utils.ROLE_TYPE_CODE_FICC_ADMIN, utils.ROLE_TYPE_CODE_ADMIN:
  458. // //管理员、超管看全部数据
  459. // RsReportRecordResp.List = groupReportRecordList
  460. //}
  461. // 20230529-有权限查看该页面的用户权限同admin
  462. RsReportRecordResp.List = groupReportRecordList
  463. br.Ret = 200
  464. br.Success = true
  465. br.Msg = "获取成功"
  466. br.Data = RsReportRecordResp
  467. return
  468. }
  469. // ReportCalendarList
  470. // @Title 路演详情列表
  471. // @Description 路演详情列表接口
  472. // @Param AdminType query string true "枚举值:researcher、seller、 special:专项路演"
  473. // @Param DataType query string true "枚举值:try_out、formal、meeting、online、offline"
  474. // @Param AdminId query int true "用户id"
  475. // @Param StartDate query string true "开始日期,格式:2022-04-06"
  476. // @Param EndDate query string true "结束日期,格式:2022-04-06"
  477. // @Success 200 {object} []roadshow.RsReportRecordList
  478. // @router /report/calendar/list [get]
  479. func (this *CalendarController) ReportCalendarList() {
  480. br := new(models.BaseResponse).Init()
  481. defer func() {
  482. this.Data["json"] = br
  483. this.ServeJSON()
  484. }()
  485. sysUser := this.SysUser
  486. if sysUser == nil {
  487. br.Msg = "请登录"
  488. br.ErrMsg = "请登录,SysUser Is Empty"
  489. br.Ret = 408
  490. return
  491. }
  492. adminType := this.GetString("AdminType")
  493. dataType := this.GetString("DataType")
  494. startDate := this.GetString("StartDate")
  495. endDate := this.GetString("EndDate")
  496. adminId, _ := this.GetInt("AdminId")
  497. if adminId <= 0 {
  498. br.Msg = "请传入对应的人员"
  499. return
  500. }
  501. //正式客户
  502. var condition string
  503. var pars []interface{}
  504. condition = ` and a.start_date >= ? and a.end_date <= ? `
  505. pars = append(pars, startDate, endDate)
  506. //选择的人员类型(发起人还是被发起人)
  507. if adminType == "seller" {
  508. condition += ` and a.seller_id = ? `
  509. } else if adminType == "special" {
  510. condition += ` and a.seller_id = ? `
  511. detail, err := company.GetConfigDetailByCode("choice_researcher_adminid")
  512. if err != nil {
  513. br.Msg = "获取研究员信息失败!"
  514. br.ErrMsg = "选择研究员失败,Err:" + err.Error()
  515. return
  516. }
  517. condition += ` and a.researcher_id IN (` + detail.ConfigValue + `) `
  518. } else {
  519. condition += ` and a.researcher_id = ? `
  520. }
  521. pars = append(pars, adminId)
  522. //获取列表
  523. switch dataType {
  524. case "try_out":
  525. condition += ` and a.company_status = ? `
  526. pars = append(pars, "试用")
  527. case "formal":
  528. condition += ` and a.company_status = ? `
  529. pars = append(pars, "正式")
  530. case "meeting":
  531. condition += ` and a.activity_type = ? `
  532. pars = append(pars, "公开会议")
  533. case "online":
  534. condition += ` and a.roadshow_type = ? `
  535. pars = append(pars, "线上")
  536. case "offline":
  537. condition += ` and a.roadshow_type = ? `
  538. pars = append(pars, "线下")
  539. default:
  540. br.Msg = "请传入类型"
  541. br.ErrMsg = "请传入类型DataType"
  542. return
  543. }
  544. list, err := roadshow.GetRsReportRecordList(condition, pars)
  545. if err != nil {
  546. br.Msg = "获取失败"
  547. br.ErrMsg = "获取失败,ERR:" + err.Error()
  548. return
  549. }
  550. br.Ret = 200
  551. br.Success = true
  552. br.Msg = "获取成功"
  553. br.Data = list
  554. return
  555. }
  556. // ChoiceResearcher
  557. // @Title 选择的研究员
  558. // @Description 选择的研究员接口
  559. // @Param AdminIds query string true "研究员ID ,多个用 , 隔开"
  560. // @Success 200 操作成功
  561. // @router /report/choice/researcher [post]
  562. func (this *CalendarController) ChoiceResearcher() {
  563. br := new(models.BaseResponse).Init()
  564. defer func() {
  565. this.Data["json"] = br
  566. this.ServeJSON()
  567. }()
  568. sysUser := this.SysUser
  569. if sysUser == nil {
  570. br.Msg = "请登录"
  571. br.ErrMsg = "请登录,SysUser Is Empty"
  572. br.Ret = 408
  573. return
  574. }
  575. var req roadshow.ResearcherIds
  576. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  577. if err != nil {
  578. br.Msg = "参数解析异常!"
  579. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  580. return
  581. }
  582. if req.AdminIds == "" {
  583. req.AdminIds = "0"
  584. }
  585. adminIdArr := strings.Split(req.AdminIds, ",")
  586. for _, v := range adminIdArr {
  587. _, err := strconv.Atoi(v)
  588. if err != nil {
  589. br.Msg = "选择研究员失败!"
  590. br.ErrMsg = "选择研究员失败,Err:" + err.Error()
  591. return
  592. }
  593. }
  594. err = company.CrmConfigUpdate(req.AdminIds, "choice_researcher_adminid")
  595. if err != nil {
  596. br.Msg = "操作失败"
  597. br.ErrMsg = "操作失败,Err:" + err.Error()
  598. return
  599. }
  600. br.Ret = 200
  601. br.Success = true
  602. br.Msg = "操作成功"
  603. return
  604. }
  605. // AdminList
  606. // @Title 选择的研究员列表
  607. // @Description 获取选择的研究员列表
  608. // @Success 200 {object} roadshow.Researcher
  609. // @Success 200 操作成功
  610. // @router /report/admin/list [get]
  611. func (this *CalendarController) AdminList() {
  612. br := new(models.BaseResponse).Init()
  613. defer func() {
  614. this.Data["json"] = br
  615. this.ServeJSON()
  616. }()
  617. sysUser := this.SysUser
  618. if sysUser == nil {
  619. br.Msg = "请登录"
  620. br.ErrMsg = "请登录,SysUser Is Empty"
  621. br.Ret = 408
  622. return
  623. }
  624. detail, err := company.GetConfigDetailByCode("choice_researcher_adminid")
  625. if err != nil {
  626. br.Msg = "获取研究员信息失败!"
  627. br.ErrMsg = "选择研究员失败,Err:" + err.Error()
  628. return
  629. }
  630. list, err := roadshow.GetChoiceResearcher(detail.ConfigValue)
  631. if err != nil {
  632. br.Msg = "操作失败"
  633. br.ErrMsg = "操作失败,Err:" + err.Error()
  634. return
  635. }
  636. br.Ret = 200
  637. br.Success = true
  638. br.Msg = "操作成功"
  639. br.Data = list
  640. return
  641. }
  642. // SellerReportList
  643. // @Title 专项路演统计
  644. // @Description 专项路演统计接口
  645. // @Success 200 {object} roadshow.RsReportRecordResp
  646. // @router /report/special/list [get]
  647. func (this *CalendarController) SpecialReportList() {
  648. br := new(models.BaseResponse).Init()
  649. defer func() {
  650. this.Data["json"] = br
  651. this.ServeJSON()
  652. }()
  653. sysUser := this.SysUser
  654. if sysUser == nil {
  655. br.Msg = "请登录"
  656. br.ErrMsg = "请登录,SysUser Is Empty"
  657. br.Ret = 408
  658. return
  659. }
  660. dimensionType := this.GetString("DimensionType")
  661. if dimensionType == "" {
  662. dimensionType = "seller_special"
  663. }
  664. var adminDataList []roadshowService.AdminDataMap
  665. var err error
  666. var firstDate time.Time
  667. //获取列表
  668. adminDataList, firstDate, err = roadshowService.GetWeekData("seller", dimensionType)
  669. if err != nil {
  670. br.Msg = "数据异常"
  671. br.ErrMsg = "数据异常,Err:" + err.Error()
  672. return
  673. }
  674. var haveData bool
  675. detail, err := company.GetConfigDetailByCode("choice_researcher_adminid")
  676. if err != nil {
  677. br.Msg = "获取信息失败!"
  678. br.ErrMsg = "获取选择研究员信息失败,Err:" + err.Error()
  679. return
  680. }
  681. adminMap := make(map[int]int)
  682. adminIdArr := strings.Split(detail.ConfigValue, ",")
  683. for _, v := range adminIdArr {
  684. adminId, err := strconv.Atoi(v)
  685. if err != nil {
  686. br.Msg = "获取信息失败!"
  687. br.ErrMsg = "获取选择研究员信息失败,Err:" + err.Error()
  688. return
  689. }
  690. adminMap[adminId] = adminId
  691. }
  692. group, groupIdRelationMap, err := services.GetFiccSystemGroup()
  693. if err != nil {
  694. br.Msg = "获取信息失败!"
  695. br.ErrMsg = "获取分组信息失败!Err:" + err.Error()
  696. return
  697. }
  698. researcherList, err := services.GetFiccSeller(firstDate, groupIdRelationMap)
  699. groupMap := make(map[int][]*roadshow.Researcher)
  700. for _, v := range researcherList {
  701. //if v.RoleTypeCode == "ficc_admin" {
  702. // findItems := groupMap[1]
  703. // findItems = append(findItems, v)
  704. // groupMap[1] = findItems
  705. //} else {
  706. if findItems, ok := groupMap[v.GroupId]; ok {
  707. findItems = append(findItems, v)
  708. groupMap[v.GroupId] = findItems
  709. } else {
  710. findItems = append(findItems, v)
  711. groupMap[v.GroupId] = findItems
  712. }
  713. //}
  714. }
  715. groupReportRecordList := make([]roadshow.GroupReportRecord, 0)
  716. rsAllReportRecordNumList := make([]roadshow.RsReportRecordNum, 0)
  717. RsReportRecordResp := roadshow.RsReportRecordResp{
  718. List: groupReportRecordList,
  719. RsReportRecordNumList: rsAllReportRecordNumList,
  720. }
  721. startDateIndexList := make(map[int]string) //开始时间间隔map
  722. endDateIndexList := make(map[int]string) //结束时间间隔map
  723. tmpAllTryOutNumMap := make(map[int]int)
  724. tmpAllFormalNumMap := make(map[int]int)
  725. tmpAllMeetingNumMap := make(map[int]int)
  726. tmpAllOnlineNumMap := make(map[int]int)
  727. tmpAllOfflineNumMap := make(map[int]int)
  728. for _, v := range group {
  729. v.ResearcherList = groupMap[v.GroupId]
  730. tmpGroupAdminReportRecord := make([]roadshow.AdminReportRecord, 0)
  731. tmpGroupRsReportRecordNumList := make([]roadshow.RsReportRecordNum, 0)
  732. tmpGroupTryOutNumMap := make(map[int]int)
  733. tmpGroupFormalNumMap := make(map[int]int)
  734. tmpGroupMeetingNumMap := make(map[int]int)
  735. tmpGroupOnlineNumMap := make(map[int]int)
  736. tmpGroupOfflineNumMap := make(map[int]int)
  737. for _, researcher := range groupMap[v.GroupId] {
  738. //组内研究员数据
  739. var isLook bool
  740. //如果是管理员或者本组的可以查看详情
  741. if sysUser.GroupId == v.GroupId || sysUser.RoleTypeCode == utils.ROLE_TYPE_CODE_ADMIN {
  742. isLook = true
  743. }
  744. //每个区间的数据
  745. tmpAdminRsReportRecordNumList := make([]roadshow.RsReportRecordNum, 0)
  746. var isAppend bool
  747. for index, adminData := range adminDataList {
  748. startDateIndexList[index] = adminData.StartDate
  749. endDateIndexList[index] = adminData.EndDate
  750. var tmpTryOutNum, tmpFormalNum, tmpMeetingNum, tmpOnlineNum, tmpOfflineNum int
  751. if num, ok := adminData.TryOutMap[researcher.AdminId]; ok {
  752. tmpTryOutNum = num
  753. }
  754. if num, ok := adminData.FormalMap[researcher.AdminId]; ok {
  755. tmpFormalNum = num
  756. }
  757. if num, ok := adminData.MeetingMap[researcher.AdminId]; ok {
  758. tmpMeetingNum = num
  759. }
  760. if num, ok := adminData.OnlineMap[researcher.AdminId]; ok {
  761. tmpOnlineNum = num
  762. }
  763. if num, ok := adminData.OfflineMap[researcher.AdminId]; ok {
  764. tmpOfflineNum = num
  765. }
  766. tmpAdminRsReportRecordNum := roadshow.RsReportRecordNum{
  767. TryOutNum: tmpTryOutNum,
  768. FormalNum: tmpFormalNum,
  769. MeetingNum: tmpMeetingNum,
  770. OnlineNum: tmpOnlineNum,
  771. OfflineNum: tmpOfflineNum,
  772. StartDate: adminData.StartDate,
  773. EndDate: adminData.EndDate,
  774. IsLook: isLook,
  775. }
  776. if tmpTryOutNum > 0 || tmpFormalNum > 0 || tmpMeetingNum > 0 || tmpOnlineNum > 0 || tmpOfflineNum > 0 {
  777. isAppend = true
  778. haveData = true
  779. }
  780. tmpAdminRsReportRecordNumList = append(tmpAdminRsReportRecordNumList, tmpAdminRsReportRecordNum)
  781. //组内数据汇总
  782. if _, ok := tmpGroupTryOutNumMap[index]; !ok {
  783. tmpGroupTryOutNumMap[index] = 0
  784. }
  785. if _, ok := tmpGroupFormalNumMap[index]; !ok {
  786. tmpGroupFormalNumMap[index] = 0
  787. }
  788. if _, ok := tmpGroupMeetingNumMap[index]; !ok {
  789. tmpGroupMeetingNumMap[index] = 0
  790. }
  791. if _, ok := tmpGroupOnlineNumMap[index]; !ok {
  792. tmpGroupOnlineNumMap[index] = 0
  793. }
  794. if _, ok := tmpGroupOfflineNumMap[index]; !ok {
  795. tmpGroupOfflineNumMap[index] = 0
  796. }
  797. tmpGroupTryOutNumMap[index] += tmpTryOutNum
  798. tmpGroupFormalNumMap[index] += tmpFormalNum
  799. tmpGroupMeetingNumMap[index] += tmpMeetingNum
  800. tmpGroupOnlineNumMap[index] += tmpOnlineNum
  801. tmpGroupOfflineNumMap[index] += tmpOfflineNum
  802. //总数据汇总
  803. if _, ok := tmpAllTryOutNumMap[index]; !ok {
  804. tmpAllTryOutNumMap[index] = 0
  805. }
  806. if _, ok := tmpAllFormalNumMap[index]; !ok {
  807. tmpAllFormalNumMap[index] = 0
  808. }
  809. if _, ok := tmpAllMeetingNumMap[index]; !ok {
  810. tmpAllMeetingNumMap[index] = 0
  811. }
  812. if _, ok := tmpAllOnlineNumMap[index]; !ok {
  813. tmpAllOnlineNumMap[index] = 0
  814. }
  815. if _, ok := tmpAllOfflineNumMap[index]; !ok {
  816. tmpAllOfflineNumMap[index] = 0
  817. }
  818. tmpAllTryOutNumMap[index] += tmpTryOutNum
  819. tmpAllFormalNumMap[index] += tmpFormalNum
  820. tmpAllMeetingNumMap[index] += tmpMeetingNum
  821. tmpAllOnlineNumMap[index] += tmpOnlineNum
  822. tmpAllOfflineNumMap[index] += tmpOfflineNum
  823. }
  824. tmpAdminReportRecord := roadshow.AdminReportRecord{
  825. Name: researcher.RealName,
  826. AdminId: researcher.AdminId,
  827. RsReportRecordNumList: tmpAdminRsReportRecordNumList,
  828. }
  829. if isAppend {
  830. tmpGroupAdminReportRecord = append(tmpGroupAdminReportRecord, tmpAdminReportRecord)
  831. }
  832. }
  833. for i := 0; i < len(tmpGroupMeetingNumMap); i++ {
  834. tmpGroupRsReportRecordNum := roadshow.RsReportRecordNum{
  835. TryOutNum: tmpGroupTryOutNumMap[i],
  836. FormalNum: tmpGroupFormalNumMap[i],
  837. MeetingNum: tmpGroupMeetingNumMap[i],
  838. OnlineNum: tmpGroupOnlineNumMap[i],
  839. OfflineNum: tmpGroupOfflineNumMap[i],
  840. StartDate: startDateIndexList[i],
  841. EndDate: endDateIndexList[i],
  842. }
  843. tmpGroupRsReportRecordNumList = append(tmpGroupRsReportRecordNumList, tmpGroupRsReportRecordNum)
  844. }
  845. groupReportRecord := roadshow.GroupReportRecord{
  846. Item: tmpGroupAdminReportRecord,
  847. Name: v.GroupName,
  848. GruopId: v.GroupId,
  849. RsReportRecordNumList: tmpGroupRsReportRecordNumList,
  850. }
  851. if len(tmpGroupAdminReportRecord) > 0 {
  852. groupReportRecordList = append(groupReportRecordList, groupReportRecord)
  853. }
  854. }
  855. //总体汇总数据
  856. for i := 0; i < len(tmpAllFormalNumMap); i++ {
  857. tmpGroupRsReportRecordNum := roadshow.RsReportRecordNum{
  858. TryOutNum: tmpAllTryOutNumMap[i],
  859. FormalNum: tmpAllFormalNumMap[i],
  860. MeetingNum: tmpAllMeetingNumMap[i],
  861. OnlineNum: tmpAllOnlineNumMap[i],
  862. OfflineNum: tmpAllOfflineNumMap[i],
  863. StartDate: startDateIndexList[i],
  864. EndDate: endDateIndexList[i],
  865. }
  866. rsAllReportRecordNumList = append(rsAllReportRecordNumList, tmpGroupRsReportRecordNum)
  867. }
  868. RsReportRecordResp.RsReportRecordNumList = rsAllReportRecordNumList
  869. tmpList := groupReportRecordList
  870. //因为RoleTypeCode不一样,所以需要重新从数据库取数据
  871. adminInfo, _ := system.GetSysAdminById(sysUser.AdminId)
  872. adminGroupId := adminInfo.GroupId
  873. if tmpGroupId, ok := groupIdRelationMap[adminGroupId]; ok {
  874. adminGroupId = tmpGroupId
  875. }
  876. switch adminInfo.RoleTypeCode {
  877. case utils.ROLE_TYPE_CODE_FICC_GROUP, utils.ROLE_TYPE_CODE_FICC_TEAM:
  878. for index, v := range tmpList {
  879. //如果不是同一个分组,那么就移除该分组下的人员数据
  880. if v.GruopId != adminGroupId {
  881. tmpList[index].Item = make([]roadshow.AdminReportRecord, 0)
  882. }
  883. }
  884. RsReportRecordResp.List = tmpList
  885. case utils.ROLE_TYPE_CODE_FICC_ADMIN, utils.ROLE_TYPE_CODE_ADMIN:
  886. //管理员、超管看全部数据
  887. RsReportRecordResp.List = groupReportRecordList
  888. }
  889. //判断是否有数据如果没有,处理数据为空
  890. if !haveData {
  891. RsReportRecordResp = roadshow.RsReportRecordResp{
  892. List: make([]roadshow.GroupReportRecord, 0),
  893. RsReportRecordNumList: make([]roadshow.RsReportRecordNum, 0),
  894. }
  895. }
  896. br.Ret = 200
  897. br.Success = true
  898. br.Msg = "获取成功"
  899. br.Data = RsReportRecordResp
  900. return
  901. }
  902. // ResearcherReportList
  903. // @Title 研究员出差表
  904. // @Description 研究员出差表接口
  905. // @Param AdminId query int true "研究员id"
  906. // @Param WeekQuery query int false "周查询: 0-本期(本周及下周); 1-前两周; 2-后两周"
  907. // @Param BaseQueryDate query string false "周查询时的开始日期"
  908. // @Success 200 {object} roadshow.BusinessTripResp
  909. // @router /report/researcher/business_trip [get]
  910. func (this *CalendarController) ResearcherBusinessTrip() {
  911. br := new(models.BaseResponse).Init()
  912. defer func() {
  913. this.Data["json"] = br
  914. this.ServeJSON()
  915. }()
  916. sysUser := this.SysUser
  917. if sysUser == nil {
  918. br.Msg = "请登录"
  919. br.ErrMsg = "请登录,SysUser Is Empty"
  920. br.Ret = 408
  921. return
  922. }
  923. adminId, _ := this.GetInt("AdminId")
  924. weekQuery, _ := this.GetInt("WeekQuery")
  925. baseQueryDate := this.GetString("BaseQueryDate")
  926. //fmt.Println(adminId)
  927. group, err := roadshow.GetResearcherGroup()
  928. if err != nil {
  929. br.Msg = "获取信息失败!"
  930. br.ErrMsg = "获取分组信息失败!Err:" + err.Error()
  931. return
  932. }
  933. researcherList, err := roadshow.GetBusinessTripResearcher()
  934. if err != nil {
  935. br.Msg = "获取信息失败!"
  936. br.ErrMsg = "获取分组信息失败!,GetBusinessTripResearcher Err:" + err.Error()
  937. return
  938. }
  939. ////获取当天周日期
  940. //nowWeekStart := utils.GetNowWeekMonday().AddDate(0, 0, -2)
  941. ////nowWeekEnd := utils.GetNowWeekLastDay()
  942. ////获取下周日期
  943. //nextWeekStart := utils.GetNextWeekMonday().AddDate(0, 0, -2)
  944. //nextWeekEnd := utils.GetNextWeekLastDay().AddDate(0, 0, -2)
  945. var nowWeekStart time.Time
  946. if baseQueryDate == "" {
  947. now := time.Now()
  948. weekDay := int(now.Weekday())
  949. if weekDay == 6 {
  950. nowWeekStart, _ = time.ParseInLocation(utils.FormatDate, now.Format(utils.FormatDate), time.Local)
  951. } else {
  952. nowWeekStart, _ = time.ParseInLocation(utils.FormatDate, now.AddDate(0, 0, -(weekDay+1)).Format(utils.FormatDate), time.Local)
  953. }
  954. }
  955. // 查询需求是可以无限往前后两周查询, 以入参为本周开始日期
  956. if baseQueryDate != "" {
  957. t, e := time.ParseInLocation(utils.FormatDate, baseQueryDate, time.Local)
  958. if e != nil {
  959. br.Msg = "查询开始日期格式有误"
  960. return
  961. }
  962. nowWeekStart = t
  963. }
  964. // 前/后两周
  965. if weekQuery == 1 {
  966. nowWeekStart = nowWeekStart.AddDate(0, 0, -14)
  967. }
  968. if weekQuery == 2 {
  969. nowWeekStart = nowWeekStart.AddDate(0, 0, +14)
  970. }
  971. //nowWeekEnd := utils.GetNowWeekLastDay()
  972. //获取下周日期
  973. nextWeekStart := nowWeekStart.AddDate(0, 0, +7)
  974. nextWeekEnd := nowWeekStart.AddDate(0, 0, +13)
  975. //获取路演信息
  976. roadshowList, err := roadshow.GetBusinessTripList(adminId, nowWeekStart.Format(utils.FormatDate), nextWeekEnd.Format(utils.FormatDateTime))
  977. if err != nil {
  978. br.Msg = "获取信息失败!"
  979. br.ErrMsg = "获取路演信息失败!,GetBusinessTripList Err:" + err.Error()
  980. return
  981. }
  982. roadshowMap := make(map[int][]*roadshow.BusinessTripResearcherList)
  983. for _, v := range roadshowList {
  984. if findVals, ok := roadshowMap[v.ResearcherId]; ok {
  985. findVals = append(findVals, v)
  986. roadshowMap[v.ResearcherId] = findVals
  987. } else {
  988. roadsItems := make([]*roadshow.BusinessTripResearcherList, 0)
  989. roadsItems = append(roadsItems, v)
  990. roadshowMap[v.ResearcherId] = roadsItems
  991. }
  992. }
  993. //fmt.Println("roadshow json start")
  994. //jsonBody, err := json.Marshal(roadshowMap)
  995. //fmt.Println("json body:" + string(jsonBody))
  996. //fmt.Println("roadshow json end")
  997. groupMap := make(map[int][]*roadshow.BusinessTripResearcher)
  998. for _, v := range researcherList {
  999. if findRoadshowList, ok := roadshowMap[v.AdminId]; ok {
  1000. tripList := make([]*roadshow.BusinessTrip, 0)
  1001. researcherMap := make(map[string]string)
  1002. for i := 0; i < 7; i++ {
  1003. newDay, _ := time.ParseInLocation(utils.FormatDate, nowWeekStart.AddDate(0, 0, i).Format(utils.FormatDate), time.Local)
  1004. weekDate := newDay.Format(utils.FormatDate)
  1005. tripItem := new(roadshow.BusinessTrip)
  1006. for _, r := range findRoadshowList {
  1007. startDateT, _ := time.ParseInLocation(utils.FormatDate, r.StartDate, time.Local)
  1008. endDateT, _ := time.ParseInLocation(utils.FormatDate, r.EndDate, time.Local)
  1009. if int(endDateT.Sub(startDateT)) <= 0 {
  1010. skey := strconv.Itoa(r.ResearcherId) + r.StartDate
  1011. if _, sok := researcherMap[skey]; !sok {
  1012. if r != nil && (newDay.Equal(startDateT) || (newDay.Equal(endDateT)) || (newDay.Before(endDateT) && newDay.After(startDateT))) {
  1013. tripItem.City = r.City
  1014. researcherMap[skey] = skey
  1015. }
  1016. }
  1017. } else {
  1018. if r != nil && (newDay.Equal(startDateT) || (newDay.Equal(endDateT)) || (newDay.Before(endDateT) && newDay.After(startDateT))) {
  1019. tripItem.City = r.City
  1020. //researcherMap[skey] = skey
  1021. }
  1022. }
  1023. }
  1024. tripItem.WeekDate = weekDate
  1025. tripItem.WeekType = "current"
  1026. tripItem.Week = newDay.Weekday().String()
  1027. tripList = append(tripList, tripItem)
  1028. }
  1029. for i := 0; i < 7; i++ {
  1030. newDay := nextWeekStart.AddDate(0, 0, i)
  1031. weekDate := newDay.Format(utils.FormatDate)
  1032. tripItem := new(roadshow.BusinessTrip)
  1033. for _, r := range findRoadshowList {
  1034. startDateT, _ := time.ParseInLocation(utils.FormatDate, r.StartDate, time.Local)
  1035. endDateT, _ := time.ParseInLocation(utils.FormatDate, r.EndDate, time.Local)
  1036. if int(endDateT.Sub(startDateT)) <= 0 {
  1037. skey := strconv.Itoa(r.ResearcherId) + r.StartDate
  1038. if _, sok := researcherMap[skey]; !sok {
  1039. if r != nil && (newDay.Equal(startDateT) || (newDay.Equal(endDateT)) || (newDay.Before(endDateT) && newDay.After(startDateT))) {
  1040. tripItem.City = r.City
  1041. researcherMap[skey] = skey
  1042. }
  1043. }
  1044. } else {
  1045. if r != nil && (newDay.Equal(startDateT) || (newDay.Equal(endDateT)) || (newDay.Before(endDateT) && newDay.After(startDateT))) {
  1046. tripItem.City = r.City
  1047. //researcherMap[skey] = skey
  1048. }
  1049. }
  1050. }
  1051. tripItem.WeekDate = weekDate
  1052. tripItem.WeekType = "next"
  1053. tripItem.Week = newDay.Weekday().String()
  1054. tripList = append(tripList, tripItem)
  1055. }
  1056. v.BusinessTripList = tripList
  1057. //if v.RoleTypeCode == "ficc_admin" {
  1058. // findItems := groupMap[1]
  1059. // findItems = append(findItems, v)
  1060. // groupMap[1] = findItems
  1061. //} else {
  1062. if findItems, ok := groupMap[v.GroupId]; ok {
  1063. findItems = append(findItems, v)
  1064. groupMap[v.GroupId] = findItems
  1065. } else {
  1066. findItems = append(findItems, v)
  1067. groupMap[v.GroupId] = findItems
  1068. }
  1069. //}
  1070. }
  1071. }
  1072. groupList := make([]*roadshow.BusinessTripGroup, 0)
  1073. for _, v := range group {
  1074. item := new(roadshow.BusinessTripGroup)
  1075. item.GroupName = v.GroupName
  1076. item.GroupId = v.GroupId
  1077. item.ResearcherList = groupMap[v.GroupId]
  1078. groupList = append(groupList, item)
  1079. }
  1080. resp := new(roadshow.BusinessTripResp)
  1081. resp.GroupList = groupList
  1082. resp.BaseDate = nowWeekStart.Format(utils.FormatDate)
  1083. br.Ret = 200
  1084. br.Success = true
  1085. br.Msg = "获取成功"
  1086. br.Data = resp
  1087. return
  1088. }
  1089. // OverseasCustomReportCalendarList
  1090. // @Title 路演详情列表
  1091. // @Description 路演详情列表接口
  1092. // @Param Keyword query string true "关键字:客户名称"
  1093. // @Param CompanyStatus query string true "客户状态,枚举值:正式、试用、关闭"
  1094. // @Param SellerId query int true "销售id列表;多个用英文,分割"
  1095. // @Param ResearcherId query int true "销售id列表;多个用英文,分割"
  1096. // @Param StartDate query string true "开始日期,格式:2022-04-06"
  1097. // @Param EndDate query string true "结束日期,格式:2022-04-06"
  1098. // @Param SortField query string false "排序字段:start_date"
  1099. // @Param SortDesc query int false "1:降序,默认,2:升序"
  1100. // @Success 200 {object} []roadshow.RsReportRecordList
  1101. // @router /overseas_custom/calendar/list [get]
  1102. func (this *CalendarController) OverseasCustomReportCalendarList() {
  1103. br := new(models.BaseResponse).Init()
  1104. defer func() {
  1105. this.Data["json"] = br
  1106. this.ServeJSON()
  1107. }()
  1108. sysUser := this.SysUser
  1109. if sysUser == nil {
  1110. br.Msg = "请登录"
  1111. br.ErrMsg = "请登录,SysUser Is Empty"
  1112. br.Ret = 408
  1113. return
  1114. }
  1115. keyword := this.GetString("Keyword")
  1116. companyStatus := this.GetString("CompanyStatus")
  1117. startDate := this.GetString("StartDate")
  1118. endDate := this.GetString("EndDate")
  1119. sellerId := this.GetString("SellerId")
  1120. researcherId := this.GetString("ResearcherId")
  1121. pageSize, _ := this.GetInt("PageSize")
  1122. currentIndex, _ := this.GetInt("CurrentIndex")
  1123. sortField := this.GetString("SortField")
  1124. sortDesc, _ := this.GetInt("SortDesc")
  1125. var startSize int
  1126. if pageSize <= 0 {
  1127. pageSize = utils.PageSize20
  1128. }
  1129. if currentIndex <= 0 {
  1130. currentIndex = 1
  1131. }
  1132. startSize = paging.StartIndex(currentIndex, pageSize)
  1133. switch sortField {
  1134. case "start_date":
  1135. default:
  1136. sortField = "start_date"
  1137. }
  1138. // "1:降序,默认,2:升序"
  1139. sortDesStr := ` desc `
  1140. switch sortDesc {
  1141. case 2:
  1142. sortDesStr = ` asc `
  1143. default:
  1144. sortDesStr = "desc"
  1145. }
  1146. total, list, err := roadshow.GetOverseaCustomCalendarList(keyword, sellerId, researcherId, startDate, endDate, companyStatus, sortField, sortDesStr, startSize, pageSize)
  1147. if err != nil {
  1148. br.Msg = "获取失败"
  1149. br.ErrMsg = "获取失败,ERR:" + err.Error()
  1150. return
  1151. }
  1152. page := paging.GetPaging(currentIndex, pageSize, total)
  1153. resp := new(roadshow.OverseaCustomRecordInfoResp)
  1154. resp.Paging = page
  1155. resp.List = list
  1156. br.Ret = 200
  1157. br.Success = true
  1158. br.Msg = "获取成功"
  1159. br.Data = resp
  1160. return
  1161. }
  1162. // OverseasCustomCalendarAdminList
  1163. // @Title 海外客户路演用户列表接口
  1164. // @Description 海外客户路演用户列表接口
  1165. // @Param AdminType query string true "枚举值:researcher、seller"
  1166. // @Success 200 {object} []roadshow.AdminInfo
  1167. // @router /overseas_custom/sys_user/list [get]
  1168. func (this *CalendarController) OverseasCustomCalendarAdminList() {
  1169. br := new(models.BaseResponse).Init()
  1170. defer func() {
  1171. this.Data["json"] = br
  1172. this.ServeJSON()
  1173. }()
  1174. sysUser := this.SysUser
  1175. if sysUser == nil {
  1176. br.Msg = "请登录"
  1177. br.ErrMsg = "请登录,SysUser Is Empty"
  1178. br.Ret = 408
  1179. return
  1180. }
  1181. adminType := this.GetString("AdminType")
  1182. var list []*roadshow.AdminInfo
  1183. var err error
  1184. //选择的人员类型(发起人还是被发起人)
  1185. if adminType == "seller" {
  1186. list, err = roadshow.GetOverseaCustomCalendarSellerList()
  1187. } else if adminType == "researcher" {
  1188. list, err = roadshow.GetOverseaCustomCalendarResearcherList()
  1189. } else {
  1190. br.Msg = "错误的类型"
  1191. br.IsSendEmail = false
  1192. }
  1193. if err != nil {
  1194. br.Msg = "获取失败"
  1195. br.ErrMsg = "获取失败,ERR:" + err.Error()
  1196. return
  1197. }
  1198. br.Ret = 200
  1199. br.Success = true
  1200. br.Msg = "获取成功"
  1201. br.Data = list
  1202. return
  1203. }
  1204. // OverseasSellerReportList
  1205. // @Title 海外客户销售路演统计
  1206. // @Description 海外客户销售路演统计接口
  1207. // @Param DataType query string true "枚举值:week、month、time_interval、online、offline"
  1208. // @Param DimensionType query string true "维度枚举值:company_status、roadshow_type"
  1209. // @Param StartDate query string true "开始日期,格式:2022-04-06"
  1210. // @Param EndDate query string true "结束日期,格式:2022-04-06"
  1211. // @Success 200 {object} roadshow.RsReportRecordResp
  1212. // @router /overseas_custom/seller/list [get]
  1213. func (this *CalendarController) OverseasSellerReportList() {
  1214. br := new(models.BaseResponse).Init()
  1215. defer func() {
  1216. this.Data["json"] = br
  1217. this.ServeJSON()
  1218. }()
  1219. sysUser := this.SysUser
  1220. if sysUser == nil {
  1221. br.Msg = "请登录"
  1222. br.ErrMsg = "请登录,SysUser Is Empty"
  1223. br.Ret = 408
  1224. return
  1225. }
  1226. dataType := this.GetString("DataType")
  1227. dimensionType := this.GetString("DimensionType")
  1228. startDate := this.GetString("StartDate")
  1229. endDate := this.GetString("EndDate")
  1230. if dimensionType == "" {
  1231. dimensionType = "company_status"
  1232. }
  1233. var adminDataList []roadshowService.OverseasAdminDataMap
  1234. var err error
  1235. //获取列表
  1236. switch dataType {
  1237. case "week":
  1238. adminDataList, _, err = roadshowService.GetOverseasWeekDataV2("seller", dimensionType, 6)
  1239. if err != nil {
  1240. br.Msg = "数据异常"
  1241. br.ErrMsg = "数据异常,Err:" + err.Error()
  1242. return
  1243. }
  1244. case "month":
  1245. adminDataList, _, err = roadshowService.GetOverseasMonthDataV2("seller", dimensionType, 6)
  1246. if err != nil {
  1247. br.Msg = "数据异常"
  1248. br.ErrMsg = "数据异常,Err:" + err.Error()
  1249. return
  1250. }
  1251. case "time_interval":
  1252. if startDate == `` || endDate == `` {
  1253. br.Msg = "开始日期或结束日期不能为空"
  1254. br.ErrMsg = "开始日期或结束日期不能为空,Err:" + err.Error()
  1255. return
  1256. }
  1257. adminDataList, _, err = roadshowService.GetOverseasTimeIntervalData(startDate, endDate, "seller", dimensionType)
  1258. if err != nil {
  1259. br.Msg = "数据异常"
  1260. br.ErrMsg = "数据异常,Err:" + err.Error()
  1261. return
  1262. }
  1263. }
  1264. sellerList, err := roadshow.GetOverseaCustomCalendarSellerList()
  1265. adminReportRecordList := make([]roadshow.OverseasAdminReportRecord, 0)
  1266. rsAllReportRecordNumList := make([]roadshow.RsOverseasReportRecordNum, 0)
  1267. RsReportRecordResp := roadshow.RsOverseasReportRecordResp{
  1268. List: adminReportRecordList,
  1269. RsReportRecordNumList: rsAllReportRecordNumList,
  1270. }
  1271. startDateIndexList := make(map[int]string) //开始时间间隔map
  1272. endDateIndexList := make(map[int]string) //结束时间间隔map
  1273. tmpAllTryOutNumMap := make(map[int]int)
  1274. tmpAllFormalNumMap := make(map[int]int)
  1275. tmpAllCloseNumMap := make(map[int]int)
  1276. tmpAllOnlineNumMap := make(map[int]int)
  1277. tmpAllOfflineNumMap := make(map[int]int)
  1278. for _, researcher := range sellerList {
  1279. //每个区间的数据
  1280. tmpAdminRsReportRecordNumList := make([]roadshow.RsOverseasReportRecordNum, 0)
  1281. for index, adminData := range adminDataList {
  1282. startDateIndexList[index] = adminData.StartDate
  1283. endDateIndexList[index] = adminData.EndDate
  1284. var tmpTryOutNum, tmpFormalNum, tmpCloseNum, tmpOnlineNum, tmpOfflineNum int
  1285. if num, ok := adminData.TryOutMap[researcher.AdminId]; ok {
  1286. tmpTryOutNum = num
  1287. }
  1288. if num, ok := adminData.FormalMap[researcher.AdminId]; ok {
  1289. tmpFormalNum = num
  1290. }
  1291. if num, ok := adminData.CloseMap[researcher.AdminId]; ok {
  1292. tmpCloseNum = num
  1293. }
  1294. if num, ok := adminData.OnlineMap[researcher.AdminId]; ok {
  1295. tmpOnlineNum = num
  1296. }
  1297. if num, ok := adminData.OfflineMap[researcher.AdminId]; ok {
  1298. tmpOfflineNum = num
  1299. }
  1300. tmpAdminRsReportRecordNum := roadshow.RsOverseasReportRecordNum{
  1301. TryOutNum: tmpTryOutNum,
  1302. FormalNum: tmpFormalNum,
  1303. CloseNum: tmpCloseNum,
  1304. OnlineNum: tmpOnlineNum,
  1305. OfflineNum: tmpOfflineNum,
  1306. StartDate: adminData.StartDate,
  1307. EndDate: adminData.EndDate,
  1308. }
  1309. tmpAdminRsReportRecordNumList = append(tmpAdminRsReportRecordNumList, tmpAdminRsReportRecordNum)
  1310. //总数据汇总
  1311. if _, ok := tmpAllTryOutNumMap[index]; !ok {
  1312. tmpAllTryOutNumMap[index] = 0
  1313. }
  1314. if _, ok := tmpAllFormalNumMap[index]; !ok {
  1315. tmpAllFormalNumMap[index] = 0
  1316. }
  1317. if _, ok := tmpAllCloseNumMap[index]; !ok {
  1318. tmpAllCloseNumMap[index] = 0
  1319. }
  1320. if _, ok := tmpAllOnlineNumMap[index]; !ok {
  1321. tmpAllOnlineNumMap[index] = 0
  1322. }
  1323. if _, ok := tmpAllOfflineNumMap[index]; !ok {
  1324. tmpAllOfflineNumMap[index] = 0
  1325. }
  1326. tmpAllTryOutNumMap[index] += tmpTryOutNum
  1327. tmpAllFormalNumMap[index] += tmpFormalNum
  1328. tmpAllCloseNumMap[index] += tmpCloseNum
  1329. tmpAllOnlineNumMap[index] += tmpOnlineNum
  1330. tmpAllOfflineNumMap[index] += tmpOfflineNum
  1331. }
  1332. // 数据都为0的时候不显示
  1333. adminTotalNum := 0
  1334. for _, v := range tmpAdminRsReportRecordNumList {
  1335. adminTotalNum += v.TryOutNum + v.CloseNum + v.FormalNum
  1336. }
  1337. if adminTotalNum > 0 {
  1338. tmpAdminReportRecord := roadshow.OverseasAdminReportRecord{
  1339. Name: researcher.RealName,
  1340. AdminId: researcher.AdminId,
  1341. RsReportRecordNumList: tmpAdminRsReportRecordNumList,
  1342. }
  1343. RsReportRecordResp.List = append(RsReportRecordResp.List, tmpAdminReportRecord)
  1344. }
  1345. }
  1346. //总体汇总数据
  1347. for i := 0; i < len(tmpAllFormalNumMap); i++ {
  1348. tmpGroupRsReportRecordNum := roadshow.RsOverseasReportRecordNum{
  1349. TryOutNum: tmpAllTryOutNumMap[i],
  1350. FormalNum: tmpAllFormalNumMap[i],
  1351. CloseNum: tmpAllCloseNumMap[i],
  1352. OnlineNum: tmpAllOnlineNumMap[i],
  1353. OfflineNum: tmpAllOfflineNumMap[i],
  1354. StartDate: startDateIndexList[i],
  1355. EndDate: endDateIndexList[i],
  1356. }
  1357. rsAllReportRecordNumList = append(rsAllReportRecordNumList, tmpGroupRsReportRecordNum)
  1358. }
  1359. RsReportRecordResp.RsReportRecordNumList = rsAllReportRecordNumList
  1360. br.Ret = 200
  1361. br.Success = true
  1362. br.Msg = "获取成功"
  1363. br.Data = RsReportRecordResp
  1364. return
  1365. }
  1366. // OverseasResearcherReportList
  1367. // @Title 研究员路演统计
  1368. // @Description 研究员路演统计接口
  1369. // @Param DataType query string true "枚举值:week、month、time_interval"
  1370. // @Param StartDate query string true "开始日期,格式:2022-04-06"
  1371. // @Param EndDate query string true "结束日期,格式:2022-04-06"
  1372. // @Success 200 {object} roadshow.RsReportRecordResp
  1373. // @router /overseas_custom/researcher/list [get]
  1374. func (this *CalendarController) OverseasResearcherReportList() {
  1375. br := new(models.BaseResponse).Init()
  1376. defer func() {
  1377. this.Data["json"] = br
  1378. this.ServeJSON()
  1379. }()
  1380. sysUser := this.SysUser
  1381. if sysUser == nil {
  1382. br.Msg = "请登录"
  1383. br.ErrMsg = "请登录,SysUser Is Empty"
  1384. br.Ret = 408
  1385. return
  1386. }
  1387. dataType := this.GetString("DataType")
  1388. startDate := this.GetString("StartDate")
  1389. endDate := this.GetString("EndDate")
  1390. var adminDataList []roadshowService.OverseasAdminDataMap
  1391. var err error
  1392. //var firstDate time.Time
  1393. //获取列表
  1394. switch dataType {
  1395. case "week":
  1396. adminDataList, _, err = roadshowService.GetOverseasWeekData("researcher", "company_status")
  1397. if err != nil {
  1398. br.Msg = "数据异常"
  1399. br.ErrMsg = "数据异常,Err:" + err.Error()
  1400. return
  1401. }
  1402. case "month":
  1403. adminDataList, _, err = roadshowService.GetOverseasMonthData("researcher", "company_status")
  1404. if err != nil {
  1405. br.Msg = "数据异常"
  1406. br.ErrMsg = "数据异常,Err:" + err.Error()
  1407. return
  1408. }
  1409. case "time_interval":
  1410. if startDate == `` || endDate == `` {
  1411. br.Msg = "开始日期或结束日期不能为空"
  1412. br.ErrMsg = "开始日期或结束日期不能为空,Err:" + err.Error()
  1413. return
  1414. }
  1415. adminDataList, _, err = roadshowService.GetOverseasTimeIntervalData(startDate, endDate, "researcher", "company_status")
  1416. if err != nil {
  1417. br.Msg = "数据异常"
  1418. br.ErrMsg = "数据异常,Err:" + err.Error()
  1419. return
  1420. }
  1421. }
  1422. researcherList, err := roadshow.GetOverseaCustomCalendarResearcherList()
  1423. if err != nil {
  1424. br.Msg = "获取信息失败!"
  1425. br.ErrMsg = "获取分组信息失败!,GetResearcherV2 Err:" + err.Error()
  1426. return
  1427. }
  1428. adminReportRecordList := make([]roadshow.OverseasAdminReportRecord, 0)
  1429. rsAllReportRecordNumList := make([]roadshow.RsOverseasReportRecordNum, 0)
  1430. RsReportRecordResp := roadshow.RsOverseasReportRecordResp{
  1431. List: adminReportRecordList,
  1432. RsReportRecordNumList: rsAllReportRecordNumList,
  1433. }
  1434. startDateIndexList := make(map[int]string) //开始时间间隔map
  1435. endDateIndexList := make(map[int]string) //结束时间间隔map
  1436. tmpAllTryOutNumMap := make(map[int]int)
  1437. tmpAllFormalNumMap := make(map[int]int)
  1438. tmpAllMeetingNumMap := make(map[int]int)
  1439. for _, researcher := range researcherList {
  1440. //组内研究员数据
  1441. //每个区间的数据
  1442. tmpAdminRsReportRecordNumList := make([]roadshow.RsOverseasReportRecordNum, 0)
  1443. for index, adminData := range adminDataList {
  1444. startDateIndexList[index] = adminData.StartDate
  1445. endDateIndexList[index] = adminData.EndDate
  1446. var tmpTryOutNum, tmpFormalNum, tmpCloseNum int
  1447. if num, ok := adminData.TryOutMap[researcher.AdminId]; ok {
  1448. tmpTryOutNum = num
  1449. }
  1450. if num, ok := adminData.FormalMap[researcher.AdminId]; ok {
  1451. tmpFormalNum = num
  1452. }
  1453. if num, ok := adminData.CloseMap[researcher.AdminId]; ok {
  1454. tmpCloseNum = num
  1455. }
  1456. tmpAdminRsReportRecordNum := roadshow.RsOverseasReportRecordNum{
  1457. TryOutNum: tmpTryOutNum,
  1458. FormalNum: tmpFormalNum,
  1459. CloseNum: tmpCloseNum,
  1460. StartDate: adminData.StartDate,
  1461. EndDate: adminData.EndDate,
  1462. }
  1463. tmpAdminRsReportRecordNumList = append(tmpAdminRsReportRecordNumList, tmpAdminRsReportRecordNum)
  1464. //总数据汇总
  1465. if _, ok := tmpAllTryOutNumMap[index]; !ok {
  1466. tmpAllTryOutNumMap[index] = 0
  1467. }
  1468. if _, ok := tmpAllFormalNumMap[index]; !ok {
  1469. tmpAllFormalNumMap[index] = 0
  1470. }
  1471. if _, ok := tmpAllMeetingNumMap[index]; !ok {
  1472. tmpAllMeetingNumMap[index] = 0
  1473. }
  1474. tmpAllTryOutNumMap[index] += tmpTryOutNum
  1475. tmpAllFormalNumMap[index] += tmpFormalNum
  1476. tmpAllMeetingNumMap[index] += tmpCloseNum
  1477. }
  1478. tmpAdminReportRecord := roadshow.OverseasAdminReportRecord{
  1479. Name: researcher.RealName,
  1480. AdminId: researcher.AdminId,
  1481. RsReportRecordNumList: tmpAdminRsReportRecordNumList,
  1482. }
  1483. RsReportRecordResp.List = append(RsReportRecordResp.List, tmpAdminReportRecord)
  1484. }
  1485. //总体汇总数据
  1486. for i := 0; i < len(tmpAllFormalNumMap); i++ {
  1487. tmpGroupRsReportRecordNum := roadshow.RsOverseasReportRecordNum{
  1488. TryOutNum: tmpAllTryOutNumMap[i],
  1489. FormalNum: tmpAllFormalNumMap[i],
  1490. CloseNum: tmpAllMeetingNumMap[i],
  1491. StartDate: startDateIndexList[i],
  1492. EndDate: endDateIndexList[i],
  1493. }
  1494. rsAllReportRecordNumList = append(rsAllReportRecordNumList, tmpGroupRsReportRecordNum)
  1495. }
  1496. RsReportRecordResp.RsReportRecordNumList = rsAllReportRecordNumList
  1497. br.Ret = 200
  1498. br.Success = true
  1499. br.Msg = "获取成功"
  1500. br.Data = RsReportRecordResp
  1501. return
  1502. }
  1503. // OverseasCalendarList
  1504. // @Title 海外客户路演详情列表
  1505. // @Description 海外客户路演详情列表接口
  1506. // @Param AdminType query string true "枚举值:researcher、seller、 special:专项路演"
  1507. // @Param DataType query string true "枚举值:try_out、formal、close、online、offline"
  1508. // @Param AdminIds query string true "用户ids"
  1509. // @Param StartDate query string true "开始日期,格式:2022-04-06"
  1510. // @Param EndDate query string true "结束日期,格式:2022-04-06"
  1511. // @Success 200 {object} []roadshow.RsReportRecordList
  1512. // @router /overseas/calendar/list [get]
  1513. func (this *CalendarController) OverseasCalendarList() {
  1514. br := new(models.BaseResponse).Init()
  1515. defer func() {
  1516. this.Data["json"] = br
  1517. this.ServeJSON()
  1518. }()
  1519. sysUser := this.SysUser
  1520. if sysUser == nil {
  1521. br.Msg = "请登录"
  1522. br.ErrMsg = "请登录,SysUser Is Empty"
  1523. br.Ret = 408
  1524. return
  1525. }
  1526. adminType := this.GetString("AdminType")
  1527. dataType := this.GetString("DataType")
  1528. startDate := this.GetString("StartDate")
  1529. endDate := this.GetString("EndDate")
  1530. adminIds := this.GetString("AdminIds")
  1531. if adminIds == "" {
  1532. br.Msg = "请传入对应的人员"
  1533. return
  1534. }
  1535. adminIdsArr := make([]int, 0)
  1536. adminIdSlice := strings.Split(adminIds, ",")
  1537. for _, v := range adminIdSlice {
  1538. id,_ := strconv.Atoi(v)
  1539. adminIdsArr = append(adminIdsArr, id)
  1540. }
  1541. //客户状态维度
  1542. companylist, err := overseas_custom.GetOverseasCustomList("", nil)
  1543. if err != nil {
  1544. return
  1545. }
  1546. formalIdsArr := make([]int, 0)
  1547. tryoutIdsArr := make([]int, 0)
  1548. closeIdsArr := make([]int, 0)
  1549. for _, v := range companylist {
  1550. if v.OverseasStatus == "正式" {
  1551. formalIdsArr = append(formalIdsArr, v.CompanyId)
  1552. } else if v.OverseasStatus == "试用" {
  1553. tryoutIdsArr = append(tryoutIdsArr, v.CompanyId)
  1554. } else if v.OverseasStatus == "关闭" {
  1555. closeIdsArr = append(closeIdsArr, v.CompanyId)
  1556. }
  1557. }
  1558. //正式客户
  1559. var condition string
  1560. var pars []interface{}
  1561. condition = ` and a.start_date >= ? and a.end_date <= ? `
  1562. pars = append(pars, startDate, endDate)
  1563. //选择的人员类型(发起人还是被发起人)
  1564. if adminType == "seller" {
  1565. condition += ` and a.seller_id IN (` + utils.GetOrmInReplace(len(adminIdsArr)) + `)`
  1566. } else if adminType == "special" {
  1567. condition += ` and a.seller_id (` + utils.GetOrmInReplace(len(adminIdsArr)) + `)`
  1568. detail, err := company.GetConfigDetailByCode("choice_researcher_adminid")
  1569. if err != nil {
  1570. br.Msg = "获取研究员信息失败!"
  1571. br.ErrMsg = "选择研究员失败,Err:" + err.Error()
  1572. return
  1573. }
  1574. condition += ` and a.researcher_id IN (` + detail.ConfigValue + `) `
  1575. } else {
  1576. condition += ` and a.researcher_id IN (` + utils.GetOrmInReplace(len(adminIdsArr)) + `)`
  1577. }
  1578. pars = append(pars, adminIdsArr)
  1579. //获取列表
  1580. switch dataType {
  1581. case "try_out":
  1582. condition += ` and a.company_status = ? and a.company_id IN (` + utils.GetOrmInReplace(len(tryoutIdsArr)) + `)`
  1583. pars = append(pars, "试用", tryoutIdsArr)
  1584. case "formal":
  1585. condition += ` and a.company_status = ? and a.company_id IN (` + utils.GetOrmInReplace(len(formalIdsArr)) + `)`
  1586. pars = append(pars, "正式", formalIdsArr)
  1587. case "close":
  1588. condition += ` and a.company_status = ? and a.company_id IN (` + utils.GetOrmInReplace(len(closeIdsArr)) + `)`
  1589. pars = append(pars, "关闭", closeIdsArr)
  1590. case "online":
  1591. condition += ` and a.roadshow_type = ? `
  1592. pars = append(pars, "线上")
  1593. case "offline":
  1594. condition += ` and a.roadshow_type = ? `
  1595. pars = append(pars, "线下")
  1596. default:
  1597. br.Msg = "请传入类型"
  1598. br.ErrMsg = "请传入类型DataType"
  1599. return
  1600. }
  1601. list, err := roadshow.GetRsReportRecordList(condition, pars)
  1602. if err != nil {
  1603. br.Msg = "获取失败"
  1604. br.ErrMsg = "获取失败,ERR:" + err.Error()
  1605. return
  1606. }
  1607. br.Ret = 200
  1608. br.Success = true
  1609. br.Msg = "获取成功"
  1610. br.Data = list
  1611. return
  1612. }