report.go 55 KB

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