report.go 56 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719172017211722172317241725172617271728172917301731173217331734
  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. // 数据都为0的时候不显示
  1474. adminTotalNum := 0
  1475. for _, v := range tmpAdminRsReportRecordNumList {
  1476. adminTotalNum += v.TryOutNum + v.CloseNum + v.FormalNum
  1477. }
  1478. if adminTotalNum > 0 {
  1479. tmpAdminReportRecord := roadshow.OverseasAdminReportRecord{
  1480. Name: researcher.RealName,
  1481. AdminId: researcher.AdminId,
  1482. RsReportRecordNumList: tmpAdminRsReportRecordNumList,
  1483. }
  1484. RsReportRecordResp.List = append(RsReportRecordResp.List, tmpAdminReportRecord)
  1485. }
  1486. }
  1487. //总体汇总数据
  1488. for i := 0; i < len(tmpAllFormalNumMap); i++ {
  1489. tmpGroupRsReportRecordNum := roadshow.RsOverseasReportRecordNum{
  1490. TryOutNum: tmpAllTryOutNumMap[i],
  1491. FormalNum: tmpAllFormalNumMap[i],
  1492. CloseNum: tmpAllMeetingNumMap[i],
  1493. StartDate: startDateIndexList[i],
  1494. EndDate: endDateIndexList[i],
  1495. }
  1496. rsAllReportRecordNumList = append(rsAllReportRecordNumList, tmpGroupRsReportRecordNum)
  1497. }
  1498. RsReportRecordResp.RsReportRecordNumList = rsAllReportRecordNumList
  1499. br.Ret = 200
  1500. br.Success = true
  1501. br.Msg = "获取成功"
  1502. br.Data = RsReportRecordResp
  1503. return
  1504. }
  1505. // OverseasCalendarList
  1506. // @Title 海外客户路演详情列表
  1507. // @Description 海外客户路演详情列表接口
  1508. // @Param AdminType query string true "枚举值:researcher、seller、 special:专项路演"
  1509. // @Param DataType query string true "枚举值:try_out、formal、close、online、offline"
  1510. // @Param AdminIds query string true "用户ids"
  1511. // @Param StartDate query string true "开始日期,格式:2022-04-06"
  1512. // @Param EndDate query string true "结束日期,格式:2022-04-06"
  1513. // @Success 200 {object} []roadshow.RsReportRecordList
  1514. // @router /overseas/calendar/list [get]
  1515. func (this *CalendarController) OverseasCalendarList() {
  1516. br := new(models.BaseResponse).Init()
  1517. defer func() {
  1518. this.Data["json"] = br
  1519. this.ServeJSON()
  1520. }()
  1521. sysUser := this.SysUser
  1522. if sysUser == nil {
  1523. br.Msg = "请登录"
  1524. br.ErrMsg = "请登录,SysUser Is Empty"
  1525. br.Ret = 408
  1526. return
  1527. }
  1528. adminType := this.GetString("AdminType")
  1529. dataType := this.GetString("DataType")
  1530. startDate := this.GetString("StartDate")
  1531. endDate := this.GetString("EndDate")
  1532. adminIds := this.GetString("AdminIds")
  1533. if adminIds == "" {
  1534. br.Msg = "请传入对应的人员"
  1535. return
  1536. }
  1537. adminIdsArr := make([]int, 0)
  1538. adminIdSlice := strings.Split(adminIds, ",")
  1539. for _, v := range adminIdSlice {
  1540. id,_ := strconv.Atoi(v)
  1541. adminIdsArr = append(adminIdsArr, id)
  1542. }
  1543. //客户状态维度
  1544. companylist, err := overseas_custom.GetOverseasCustomList("", nil)
  1545. if err != nil {
  1546. return
  1547. }
  1548. formalIdsArr := make([]int, 0)
  1549. tryoutIdsArr := make([]int, 0)
  1550. closeIdsArr := make([]int, 0)
  1551. for _, v := range companylist {
  1552. if v.OverseasStatus == "正式" {
  1553. formalIdsArr = append(formalIdsArr, v.CompanyId)
  1554. } else if v.OverseasStatus == "试用" {
  1555. tryoutIdsArr = append(tryoutIdsArr, v.CompanyId)
  1556. } else if v.OverseasStatus == "关闭" {
  1557. closeIdsArr = append(closeIdsArr, v.CompanyId)
  1558. }
  1559. }
  1560. //正式客户
  1561. var condition string
  1562. var pars []interface{}
  1563. condition = ` and a.start_date >= ? and a.end_date <= ? `
  1564. pars = append(pars, startDate, endDate)
  1565. //选择的人员类型(发起人还是被发起人)
  1566. if adminType == "seller" {
  1567. condition += ` and a.seller_id IN (` + utils.GetOrmInReplace(len(adminIdsArr)) + `)`
  1568. } else if adminType == "special" {
  1569. condition += ` and a.seller_id (` + utils.GetOrmInReplace(len(adminIdsArr)) + `)`
  1570. detail, err := company.GetConfigDetailByCode("choice_researcher_adminid")
  1571. if err != nil {
  1572. br.Msg = "获取研究员信息失败!"
  1573. br.ErrMsg = "选择研究员失败,Err:" + err.Error()
  1574. return
  1575. }
  1576. condition += ` and a.researcher_id IN (` + detail.ConfigValue + `) `
  1577. } else {
  1578. condition += ` and a.researcher_id IN (` + utils.GetOrmInReplace(len(adminIdsArr)) + `)`
  1579. }
  1580. pars = append(pars, adminIdsArr)
  1581. //获取列表
  1582. switch dataType {
  1583. case "try_out":
  1584. condition += ` and a.company_status = ? and a.company_id IN (` + utils.GetOrmInReplace(len(tryoutIdsArr)) + `)`
  1585. pars = append(pars, "试用", tryoutIdsArr)
  1586. case "formal":
  1587. condition += ` and a.company_status = ? and a.company_id IN (` + utils.GetOrmInReplace(len(formalIdsArr)) + `)`
  1588. pars = append(pars, "正式", formalIdsArr)
  1589. case "close":
  1590. condition += ` and a.company_status = ? and a.company_id IN (` + utils.GetOrmInReplace(len(closeIdsArr)) + `)`
  1591. pars = append(pars, "关闭", closeIdsArr)
  1592. case "online":
  1593. condition += ` and a.roadshow_type = ? `
  1594. pars = append(pars, "线上")
  1595. case "offline":
  1596. condition += ` and a.roadshow_type = ? `
  1597. pars = append(pars, "线下")
  1598. default:
  1599. br.Msg = "请传入类型"
  1600. br.ErrMsg = "请传入类型DataType"
  1601. return
  1602. }
  1603. list, err := roadshow.GetRsReportRecordList(condition, pars)
  1604. if err != nil {
  1605. br.Msg = "获取失败"
  1606. br.ErrMsg = "获取失败,ERR:" + err.Error()
  1607. return
  1608. }
  1609. br.Ret = 200
  1610. br.Success = true
  1611. br.Msg = "获取成功"
  1612. br.Data = list
  1613. return
  1614. }