enter_score.go 43 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315
  1. package cygx
  2. import (
  3. "encoding/json"
  4. "fmt"
  5. "github.com/rdlucklib/rdluck_tools/paging"
  6. "github.com/tealeg/xlsx"
  7. "hongze/hz_crm_api/controllers"
  8. "hongze/hz_crm_api/models"
  9. "hongze/hz_crm_api/models/company"
  10. "hongze/hz_crm_api/models/cygx"
  11. "hongze/hz_crm_api/models/system"
  12. cygxService "hongze/hz_crm_api/services/cygx"
  13. "hongze/hz_crm_api/utils"
  14. "os"
  15. "path/filepath"
  16. "strings"
  17. "time"
  18. )
  19. // X类客户录分模块
  20. type EnterScoreController struct {
  21. controllers.BaseAuthController
  22. }
  23. // @Title X试用类客户检索
  24. // @Description X试用类客户检索接口
  25. // @Param KeyWord query string true "搜索关键词"
  26. // @Success 200 {object} company.CompanyNameAndIdListResp
  27. // @router /enterScore/company/searchlist [get]
  28. func (this *EnterScoreController) CompanySearchList() {
  29. br := new(models.BaseResponse).Init()
  30. defer func() {
  31. this.Data["json"] = br
  32. this.ServeJSON()
  33. }()
  34. sysUser := this.SysUser
  35. if sysUser == nil {
  36. br.Msg = "请登录"
  37. br.ErrMsg = "请登录,SysUser Is Empty"
  38. br.Ret = 408
  39. return
  40. }
  41. keyWord := this.GetString("KeyWord")
  42. keyWord = strings.Trim(keyWord, " ")
  43. keyWord = strings.Replace(keyWord, "'", "", -1)
  44. resp := new(company.CompanyNameAndIdListResp)
  45. var companyCondition string
  46. var companypars []interface{}
  47. var listResp []*company.CompanyNameAndId
  48. companyCondition += ` AND b.product_name = ? `
  49. companypars = append(companypars, "权益")
  50. companyCondition += ` AND b.status = ? `
  51. companypars = append(companypars, "永续")
  52. if keyWord != "" {
  53. companyCondition += ` AND a.company_name LIKE '%` + keyWord + `%' `
  54. }
  55. //权益申请销售只能看到自己名下的客户的申请
  56. companyIds, err := cygxService.GetAdminLookUserCompanyIdsBySelf(sysUser)
  57. if err != nil {
  58. br.Msg = "获取失败"
  59. br.ErrMsg = "获取失败,GetAdminLookUserCompanyIds Err:" + err.Error()
  60. return
  61. }
  62. lencompanyIds := len(companyIds)
  63. if lencompanyIds > 0 {
  64. companyCondition += ` AND a.company_id IN (` + utils.GetOrmInReplace(lencompanyIds) + `)`
  65. companypars = append(companypars, companyIds)
  66. }
  67. companyList, err := company.GetCompanyIdListByproductName(companyCondition, companypars)
  68. if err != nil {
  69. br.Msg = "获取失败"
  70. br.ErrMsg = "获取失败,Err:" + err.Error()
  71. return
  72. }
  73. if len(companyList) == 0 {
  74. listResp = make([]*company.CompanyNameAndId, 0)
  75. } else {
  76. listResp = companyList
  77. }
  78. resp.List = listResp
  79. br.Ret = 200
  80. br.Success = true
  81. br.Msg = "获取成功"
  82. br.Data = resp
  83. }
  84. // @Title 详情
  85. // @Description 获取详情接口
  86. // @Param EnterScoreId query int true "录分ID"
  87. // @Success Ret=200 {object} cygx.CygxEnterScoreDetailResp
  88. // @router /enterScore/detail [get]
  89. func (this *EnterScoreController) EnterScoreDetail() {
  90. br := new(models.BaseResponse).Init()
  91. defer func() {
  92. this.Data["json"] = br
  93. this.ServeJSON()
  94. }()
  95. AdminUser := this.SysUser
  96. if AdminUser == nil {
  97. br.Msg = "请登录"
  98. br.ErrMsg = "请登录,用户信息为空"
  99. br.Ret = 408
  100. return
  101. }
  102. enterScoreId, _ := this.GetInt("EnterScoreId")
  103. resp := new(cygx.CygxEnterScoreDetailResp)
  104. var itemslistPermission []*cygx.EnterScorePermissionListResp // 权益行业
  105. var itemsFicclistPermission []*cygx.EnterScorePermissionListResp // FICC行业
  106. mapRaiUser := make(map[string][]*cygx.EnterScoreRealNameListResp) //权益研究员
  107. mapFiccUser := make(map[string][]*cygx.EnterScoreRealNameListResp) // FICC研究员
  108. var itemsGroup []*cygx.EnterScoreGroupListResp //自定义分组
  109. if enterScoreId == 0 {
  110. //权益研究员
  111. sysUserList, err := cygx.GetAskEmailList()
  112. if err != nil {
  113. br.Msg = "获取失败"
  114. br.ErrMsg = "获取失败,GetAskEmailList Err: " + err.Error()
  115. return
  116. }
  117. for _, v := range sysUserList {
  118. item := new(cygx.EnterScoreRealNameListResp)
  119. item.RealName = v.Name
  120. item.ChartPermissionName = v.ChartPermissionName
  121. mapRaiUser[v.ChartPermissionName] = append(mapRaiUser[v.ChartPermissionName], item)
  122. }
  123. listPermission, err := cygx.GetChartPermissionAll()
  124. if err != nil {
  125. br.Msg = "获取信息失败"
  126. br.ErrMsg = "获取品种信息失败,Err:" + err.Error()
  127. return
  128. }
  129. permissionNameArr := []string{"医药", "消费", "科技", "智造", "策略", "固收"}
  130. for _, v := range listPermission {
  131. if !utils.InArrayByStr(permissionNameArr, v.PermissionName) {
  132. continue
  133. }
  134. item := new(cygx.EnterScorePermissionListResp)
  135. item.ChartPermissionName = v.PermissionName
  136. item.List = mapRaiUser[v.PermissionName]
  137. itemslistPermission = append(itemslistPermission, item)
  138. }
  139. resp.EnterScoreObj.ListRai = itemslistPermission
  140. //ficc 研究员
  141. ficcUserList, err := system.GetFiccEnterScoreAdmin()
  142. if err != nil {
  143. br.Msg = "获取失败"
  144. br.ErrMsg = "获取失败,GetFiccEnterScoreAdmin Err: " + err.Error()
  145. return
  146. }
  147. for _, v := range ficcUserList {
  148. item := new(cygx.EnterScoreRealNameListResp)
  149. item.RealName = v.RealName
  150. item.ChartPermissionName = v.GroupName
  151. mapFiccUser[v.GroupName] = append(mapFiccUser[v.GroupName], item)
  152. }
  153. permissionFiccNameArr := []string{"宏观组", "建材组", "有色组", "能化组"}
  154. for _, v := range permissionFiccNameArr {
  155. item := new(cygx.EnterScorePermissionListResp)
  156. item.ChartPermissionName = v
  157. item.List = mapFiccUser[v]
  158. itemsFicclistPermission = append(itemsFicclistPermission, item)
  159. }
  160. resp.EnterScoreObj.ListFicc = itemsFicclistPermission
  161. groupNameArr := []string{"销售分", "专题分", "专家分", "云图大拓", "艾摩宏观"}
  162. for _, v := range groupNameArr {
  163. item := new(cygx.EnterScoreGroupListResp)
  164. item.GroupName = v
  165. itemsGroup = append(itemsGroup, item)
  166. }
  167. resp.EnterScoreObj.ListGroup = itemsGroup
  168. resp.PercentageObj = resp.EnterScoreObj
  169. resp.EnterScoreType = 1
  170. resp.Quarter = make([]string, 0)
  171. } else {
  172. //初始化数据,方便前端渲染
  173. var itemslistPermissionInit []*cygx.EnterScorePermissionListResp // 权益行业
  174. var itemsFicclistPermissionInit []*cygx.EnterScorePermissionListResp // FICC行业
  175. var itemsGroupInit []*cygx.EnterScoreGroupListResp //自定义分组
  176. mapRaiUserInit := make(map[string][]*cygx.EnterScoreRealNameListResp) //权益研究员
  177. mapFiccUserInit := make(map[string][]*cygx.EnterScoreRealNameListResp) // FICC研究员
  178. enterScoreDetail, err := cygx.GetCygxEnterScoreInfoById(enterScoreId)
  179. if err != nil {
  180. br.Msg = "获取失败"
  181. br.ErrMsg = "获取失败,GetCygxEnterScoreInfoById Err: " + err.Error()
  182. return
  183. }
  184. resp.EnterScoreId = enterScoreDetail.EnterScoreId
  185. resp.CompanyId = enterScoreDetail.CompanyId
  186. resp.CompanyName = enterScoreDetail.CompanyName
  187. resp.StartDate = enterScoreDetail.StartDate
  188. resp.EndDate = enterScoreDetail.EndDate
  189. resp.Quarter = strings.Split(enterScoreDetail.Quarter, ",")
  190. resp.EnterScoreType = enterScoreDetail.EnterScoreType
  191. resp.Ranking = enterScoreDetail.Ranking
  192. resp.IsMergeScoring = enterScoreDetail.IsMergeScoring
  193. resp.SecuritiesFirmsName = enterScoreDetail.SecuritiesFirmsName
  194. resp.MergeProportion = enterScoreDetail.MergeProportion
  195. resp.ProportionTotal = enterScoreDetail.ProportionTotal
  196. resp.RaiProportionTotal = enterScoreDetail.RaiProportionTotal
  197. resp.FiccProportionTotal = enterScoreDetail.FiccProportionTotal
  198. listResearcher, err := cygx.GeCygxEnterScoreResearcherListById(enterScoreId)
  199. if err != nil {
  200. br.Msg = "获取失败"
  201. br.ErrMsg = "获取失败,GeCygxEnterScoreResearcherListById Err: " + err.Error()
  202. return
  203. }
  204. for _, v := range listResearcher {
  205. item := new(cygx.EnterScoreRealNameListResp)
  206. item.RealName = v.RealName
  207. item.ChartPermissionName = v.ChartPermissionName
  208. item.Proportion = v.Proportion
  209. if v.ProductId == utils.COMPANY_PRODUCT_RAI_ID {
  210. mapRaiUser[v.ChartPermissionName] = append(mapRaiUser[v.ChartPermissionName], item)
  211. } else {
  212. mapFiccUser[v.ChartPermissionName] = append(mapFiccUser[v.ChartPermissionName], item)
  213. }
  214. }
  215. for _, v := range listResearcher {
  216. item := new(cygx.EnterScoreRealNameListResp)
  217. item.RealName = v.RealName
  218. item.ChartPermissionName = v.ChartPermissionName
  219. if v.ProductId == utils.COMPANY_PRODUCT_RAI_ID {
  220. mapRaiUserInit[v.ChartPermissionName] = append(mapRaiUserInit[v.ChartPermissionName], item)
  221. } else {
  222. mapFiccUserInit[v.ChartPermissionName] = append(mapFiccUserInit[v.ChartPermissionName], item)
  223. }
  224. }
  225. listPermission, err := cygx.GetCygxEnterScorePermissionListById(enterScoreId)
  226. if err != nil {
  227. br.Msg = "获取失败"
  228. br.ErrMsg = "获取失败,GetCygxEnterScorePermissionListById Err: " + err.Error()
  229. return
  230. }
  231. for _, v := range listPermission {
  232. item := new(cygx.EnterScorePermissionListResp)
  233. item.ChartPermissionName = v.ChartPermissionName
  234. item.Proportion = v.Proportion
  235. if v.ProductId == utils.COMPANY_PRODUCT_RAI_ID {
  236. item.List = mapRaiUser[v.ChartPermissionName]
  237. itemslistPermission = append(itemslistPermission, item)
  238. } else {
  239. item.List = mapFiccUser[v.ChartPermissionName]
  240. itemsFicclistPermission = append(itemsFicclistPermission, item)
  241. }
  242. }
  243. for _, v := range listPermission {
  244. item := new(cygx.EnterScorePermissionListResp)
  245. item.ChartPermissionName = v.ChartPermissionName
  246. if v.ProductId == utils.COMPANY_PRODUCT_RAI_ID {
  247. item.List = mapRaiUserInit[v.ChartPermissionName]
  248. itemslistPermissionInit = append(itemslistPermissionInit, item)
  249. } else {
  250. item.List = mapFiccUserInit[v.ChartPermissionName]
  251. itemsFicclistPermissionInit = append(itemsFicclistPermissionInit, item)
  252. }
  253. }
  254. listGroup, err := cygx.GeCygxEnterScoreGroupListById(enterScoreId)
  255. if err != nil {
  256. br.Msg = "获取失败"
  257. br.ErrMsg = "获取失败,GeCygxEnterScoreGroupListById Err: " + err.Error()
  258. return
  259. }
  260. for _, v := range listGroup {
  261. item := new(cygx.EnterScoreGroupListResp)
  262. item.GroupName = v.GroupName
  263. item.Proportion = v.Proportion
  264. itemsGroup = append(itemsGroup, item)
  265. }
  266. for _, v := range listGroup {
  267. item := new(cygx.EnterScoreGroupListResp)
  268. item.GroupName = v.GroupName
  269. itemsGroupInit = append(itemsGroupInit, item)
  270. }
  271. if enterScoreDetail.EnterScoreType == 1 {
  272. resp.EnterScoreObj.ListGroup = itemsGroup
  273. resp.EnterScoreObj.ListRai = itemslistPermission
  274. resp.EnterScoreObj.ListFicc = itemsFicclistPermission
  275. resp.PercentageObj.ListGroup = itemsGroupInit
  276. resp.PercentageObj.ListRai = itemslistPermissionInit
  277. resp.PercentageObj.ListFicc = itemsFicclistPermissionInit
  278. } else {
  279. resp.PercentageObj.ListGroup = itemsGroup
  280. resp.PercentageObj.ListRai = itemslistPermission
  281. resp.PercentageObj.ListFicc = itemsFicclistPermission
  282. resp.EnterScoreObj.ListGroup = itemsGroupInit
  283. resp.EnterScoreObj.ListRai = itemslistPermissionInit
  284. resp.EnterScoreObj.ListFicc = itemsFicclistPermissionInit
  285. }
  286. }
  287. br.Ret = 200
  288. br.Success = true
  289. br.Msg = "获取成功"
  290. br.Data = resp
  291. }
  292. // @Title 更新录分
  293. // @Description 更新录分接口
  294. // @Param request body cygx.UpdateEnterScoreReq true "type json string"
  295. // @Success 200 {object} "保存成功"
  296. // @router /enterScore/update [post]
  297. func (this *EnterScoreController) EnterScoreUpdate() {
  298. br := new(models.BaseResponse).Init()
  299. defer func() {
  300. this.Data["json"] = br
  301. this.ServeJSON()
  302. }()
  303. sysUser := this.SysUser
  304. if sysUser == nil {
  305. br.Msg = "请登录"
  306. br.ErrMsg = "请登录,SysUser Is Empty"
  307. br.Ret = 408
  308. return
  309. }
  310. var req cygx.UpdateEnterScoreReq
  311. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  312. if err != nil {
  313. br.Msg = "参数解析异常!"
  314. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  315. return
  316. }
  317. enterScoreId := req.EnterScoreId
  318. companyId := req.CompanyId
  319. if companyId == 0 {
  320. br.Msg = "参数错误"
  321. br.ErrMsg = "参数错误,companyId不可为空"
  322. return
  323. }
  324. startDate := req.StartDate
  325. endDate := req.EndDate
  326. if startDate == "" || endDate == "" {
  327. br.Msg = "请选择季度信息"
  328. return
  329. }
  330. companyProduct, err := company.GetCompanyProductByCompanyIdAndProductId(companyId, utils.COMPANY_PRODUCT_RAI_ID)
  331. if err != nil {
  332. br.Msg = "查询客户产品信息失败"
  333. br.ErrMsg = "查询客户产品信息失败,Err:" + err.Error()
  334. return
  335. }
  336. item := new(cygx.CygxEnterScore)
  337. item.EnterScoreId = enterScoreId
  338. item.CompanyId = companyId
  339. item.CompanyName = req.CompanyName
  340. item.StartDate = req.StartDate
  341. item.EndDate = req.EndDate
  342. item.Quarter = strings.Join(req.Quarter, ",")
  343. quarterDate, err := utils.GetQuarterStartDatesInRange(req.StartDate, req.EndDate)
  344. if err != nil {
  345. br.Msg = "操作失败"
  346. br.ErrMsg = "获取对应季度信息失败,Err:" + err.Error()
  347. return
  348. }
  349. item.QuarterDate = strings.Join(quarterDate, ",")
  350. item.EnterScoreType = req.EnterScoreType
  351. item.Ranking = req.Ranking
  352. item.IsMergeScoring = req.IsMergeScoring
  353. item.SecuritiesFirmsName = req.SecuritiesFirmsName
  354. item.MergeProportion = req.MergeProportion
  355. item.RaiProportionTotal = req.RaiProportionTotal
  356. item.FiccProportionTotal = req.FiccProportionTotal
  357. item.ProportionTotal = req.ProportionTotal
  358. item.SellerId = companyProduct.SellerId
  359. item.SellerName = companyProduct.SellerName
  360. item.AdminId = sysUser.AdminId
  361. item.AdminName = sysUser.RealName
  362. item.CreateTime = time.Now()
  363. item.ModifyTime = time.Now()
  364. var itemsPermission []*cygx.CygxEnterScorePermission //行业数组
  365. var itemsResearcher []*cygx.CygxEnterScoreResearcher //研究员数组
  366. var itemsGroup []*cygx.CygxEnterScoreGroup //自定义分组
  367. listRai := req.ListRai
  368. listFicc := req.ListFicc
  369. listGroup := req.ListGroup
  370. for _, v := range listRai { // 权益数据
  371. itemPermission := new(cygx.CygxEnterScorePermission)
  372. itemPermission.ChartPermissionName = v.ChartPermissionName
  373. itemPermission.Proportion = v.Proportion
  374. itemPermission.EnterScoreId = v.EnterScoreId
  375. itemPermission.CompanyId = companyId
  376. itemPermission.AdminId = sysUser.AdminId
  377. itemPermission.AdminName = sysUser.RealName
  378. itemPermission.ProductId = utils.COMPANY_PRODUCT_RAI_ID
  379. itemPermission.CreateTime = time.Now()
  380. itemPermission.ModifyTime = time.Now()
  381. itemsPermission = append(itemsPermission, itemPermission)
  382. for _, vResearcher := range v.List {
  383. itemResearcher := new(cygx.CygxEnterScoreResearcher)
  384. itemResearcher.ChartPermissionName = v.ChartPermissionName
  385. itemResearcher.EnterScoreId = v.EnterScoreId
  386. itemResearcher.CompanyId = companyId
  387. itemResearcher.RealName = vResearcher.RealName
  388. itemResearcher.Proportion = vResearcher.Proportion
  389. itemResearcher.AdminId = sysUser.AdminId
  390. itemResearcher.AdminName = sysUser.RealName
  391. itemResearcher.ProductId = utils.COMPANY_PRODUCT_RAI_ID
  392. itemResearcher.CreateTime = time.Now()
  393. itemResearcher.ModifyTime = time.Now()
  394. itemsResearcher = append(itemsResearcher, itemResearcher)
  395. }
  396. }
  397. for _, v := range listFicc { // FICC数据
  398. itemPermission := new(cygx.CygxEnterScorePermission)
  399. itemPermission.ChartPermissionName = v.ChartPermissionName
  400. itemPermission.Proportion = v.Proportion
  401. itemPermission.EnterScoreId = v.EnterScoreId
  402. itemPermission.CompanyId = companyId
  403. itemPermission.AdminId = sysUser.AdminId
  404. itemPermission.AdminName = sysUser.RealName
  405. itemPermission.ProductId = utils.COMPANY_PRODUCT_FICC_ID
  406. itemPermission.CreateTime = time.Now()
  407. itemPermission.ModifyTime = time.Now()
  408. itemsPermission = append(itemsPermission, itemPermission)
  409. for _, vResearcher := range v.List {
  410. itemResearcher := new(cygx.CygxEnterScoreResearcher)
  411. itemResearcher.ChartPermissionName = v.ChartPermissionName
  412. itemResearcher.EnterScoreId = v.EnterScoreId
  413. itemResearcher.CompanyId = companyId
  414. itemResearcher.RealName = vResearcher.RealName
  415. itemResearcher.Proportion = vResearcher.Proportion
  416. itemResearcher.AdminId = sysUser.AdminId
  417. itemResearcher.AdminName = sysUser.RealName
  418. itemResearcher.ProductId = utils.COMPANY_PRODUCT_FICC_ID
  419. itemResearcher.CreateTime = time.Now()
  420. itemResearcher.ModifyTime = time.Now()
  421. itemsResearcher = append(itemsResearcher, itemResearcher)
  422. }
  423. }
  424. for _, v := range listGroup {
  425. itemGroup := new(cygx.CygxEnterScoreGroup)
  426. itemGroup.GroupName = v.GroupName
  427. itemGroup.Proportion = v.Proportion
  428. itemGroup.CompanyId = companyId
  429. itemGroup.AdminId = sysUser.AdminId
  430. itemGroup.AdminName = sysUser.RealName
  431. itemGroup.CreateTime = time.Now()
  432. itemGroup.ModifyTime = time.Now()
  433. itemsGroup = append(itemsGroup, itemGroup)
  434. }
  435. if enterScoreId == 0 { // 新增
  436. err = cygx.AddCygxEnterScore(item, itemsPermission, itemsResearcher, itemsGroup)
  437. } else { // 修改
  438. item.EnterScoreId = enterScoreId
  439. err = cygx.UpdateCygxEnterScore(item, itemsPermission, itemsResearcher, itemsGroup)
  440. }
  441. if err != nil {
  442. br.Msg = "操作失败"
  443. br.ErrMsg = "操作失败Err:" + err.Error()
  444. return
  445. }
  446. br.Ret = 200
  447. br.Success = true
  448. br.IsAddLog = true
  449. br.Msg = "操作成功"
  450. }
  451. // @Title 列表
  452. // @Description 列表接口
  453. // @Param PageSize query int true "每页数据条数"
  454. // @Param CurrentIndex query int true "当前页页码,从1开始"
  455. // @Param KeyWord query string true "搜索关键词"
  456. // @Param CompanyName query string true "客户名称"
  457. // @Param AdminId query string true "销售id,多个用英文逗号隔开,空字符串为全部"
  458. // @Success 200 {object} cygx.GetCygxEnterScoreListRep
  459. // @router /enterScore/list [get]
  460. func (this *EnterScoreController) EnterScoreList() {
  461. br := new(models.BaseResponse).Init()
  462. defer func() {
  463. this.Data["json"] = br
  464. this.ServeJSON()
  465. }()
  466. sysUser := this.SysUser
  467. if sysUser == nil {
  468. br.Msg = "请登录"
  469. br.ErrMsg = "请登录,SysUser Is Empty"
  470. br.Ret = 408
  471. return
  472. }
  473. pageSize, _ := this.GetInt("PageSize")
  474. currentIndex, _ := this.GetInt("CurrentIndex")
  475. keyWord := this.GetString("KeyWord")
  476. adminId := this.GetString("AdminId")
  477. var startSize int
  478. if pageSize <= 0 {
  479. pageSize = utils.PageSize20
  480. }
  481. if currentIndex <= 0 {
  482. currentIndex = 1
  483. }
  484. startSize = utils.StartIndex(currentIndex, pageSize)
  485. var condition string
  486. var pars []interface{}
  487. //如果不是权益管理员和admin,就做可见权限限制
  488. if sysUser.RoleTypeCode != utils.ROLE_TYPE_CODE_RAI_ADMIN && sysUser.RoleTypeCode != utils.ROLE_TYPE_CODE_ADMIN {
  489. var conditionAdmin string
  490. var parsAdmin []interface{}
  491. conditionAdmin = " AND product_id = 2 AND status = '永续' AND seller_id = ? "
  492. parsAdmin = append(parsAdmin, sysUser.AdminId)
  493. listProduct, err := company.GetCompanyProductList(conditionAdmin, parsAdmin)
  494. if err != nil {
  495. br.Msg = "获取失败"
  496. br.ErrMsg = "获取失败,Err:" + err.Error()
  497. return
  498. }
  499. var companyIds []int
  500. for _, v := range listProduct {
  501. companyIds = append(companyIds, v.CompanyId)
  502. }
  503. companyIds = append(companyIds, 0)
  504. condition += ` AND company_id IN (` + utils.GetOrmInReplace(len(companyIds)) + `) `
  505. pars = append(pars, companyIds)
  506. }
  507. if keyWord != "" {
  508. condition += ` AND company_name LIKE '%` + keyWord + `%' `
  509. }
  510. if adminId != "" {
  511. condition += ` AND seller_id IN (` + adminId + `) `
  512. }
  513. total, err := cygx.GetCygxEnterScoreCount(condition, pars)
  514. if err != nil {
  515. br.Msg = "获取失败"
  516. br.ErrMsg = "获取失败,Err:" + err.Error()
  517. return
  518. }
  519. list, err := cygx.GetCygxEnterScoreList(condition, pars, startSize, pageSize)
  520. if err != nil {
  521. br.Msg = "获取失败"
  522. br.ErrMsg = "获取失败,Err:" + err.Error()
  523. return
  524. }
  525. resp := new(cygx.GetCygxEnterScoreListRep)
  526. if len(list) == 0 {
  527. resp.List = make([]*cygx.EnterScoreListResp, 0)
  528. } else {
  529. for _, v := range list {
  530. item := new(cygx.EnterScoreListResp)
  531. item.EnterScoreId = v.EnterScoreId
  532. item.CompanyId = v.CompanyId
  533. item.CompanyName = v.CompanyName
  534. item.Quarter = strings.Split(v.Quarter, ",")
  535. item.EnterScoreType = v.EnterScoreType
  536. item.Ranking = v.Ranking
  537. item.IsMergeScoring = v.IsMergeScoring
  538. item.SecuritiesFirmsName = v.SecuritiesFirmsName
  539. item.ProportionTotal = v.ProportionTotal
  540. item.EnterScoreId = v.EnterScoreId
  541. item.SellerId = v.SellerId
  542. item.SellerName = v.SellerName
  543. item.CreateTime = v.CreateTime.Format(utils.FormatDateTime)
  544. item.ModifyTime = v.ModifyTime.Format(utils.FormatDateTime)
  545. resp.List = append(resp.List, item)
  546. }
  547. }
  548. page := paging.GetPaging(currentIndex, pageSize, total)
  549. resp.Paging = page
  550. br.Ret = 200
  551. br.Success = true
  552. br.Msg = "获取成功"
  553. br.Data = resp
  554. }
  555. // @Title 删除录分
  556. // @Description 删除录分接口
  557. // @Param request body cygx.UpdateEnterScoreReq true "type json string"
  558. // @Success 200 {object} "保存成功"
  559. // @router /enterScore/delete [post]
  560. func (this *EnterScoreController) EnterScoreDelete() {
  561. br := new(models.BaseResponse).Init()
  562. defer func() {
  563. this.Data["json"] = br
  564. this.ServeJSON()
  565. }()
  566. sysUser := this.SysUser
  567. if sysUser == nil {
  568. br.Msg = "请登录"
  569. br.ErrMsg = "请登录,SysUser Is Empty"
  570. br.Ret = 408
  571. return
  572. }
  573. var req cygx.EnterScoreIdReq
  574. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  575. if err != nil {
  576. br.Msg = "参数解析异常!"
  577. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  578. return
  579. }
  580. enterScoreId := req.EnterScoreId
  581. if enterScoreId == 0 {
  582. br.Msg = "参数错误!"
  583. br.ErrMsg = "参数错误,EnterScoreId 不能为0"
  584. return
  585. }
  586. err = cygx.DeleteEnterScore(enterScoreId)
  587. if err != nil {
  588. br.Msg = "删除失败"
  589. br.ErrMsg = "操作失败Err:" + err.Error()
  590. return
  591. }
  592. br.Ret = 200
  593. br.Success = true
  594. br.IsAddLog = true
  595. br.Msg = "删除成功"
  596. }
  597. // @Title 评分总览
  598. // @Description 评分总览接口
  599. // @Param KeyWord query string true "搜索关键词"
  600. // @Param City query string true "城市"
  601. // @Param StartDate query string false "开始日期"
  602. // @Param EndDate query string false "结束日期"
  603. // @Param EnterScoreType query string false "展示法方式 1:按评分录入、2:按比例录入,默认1"
  604. // @Param IsExport query bool false "是否导出excel,默认是false"
  605. // @Success Ret=200 {object} cygx.ScoreOverviewListResp
  606. // @router /enterScore/scoreOverview [get]
  607. func (this *EnterScoreController) EnterScoreScoreOverview() {
  608. br := new(models.BaseResponse).Init()
  609. defer func() {
  610. this.Data["json"] = br
  611. this.ServeJSON()
  612. }()
  613. AdminUser := this.SysUser
  614. if AdminUser == nil {
  615. br.Msg = "请登录"
  616. br.ErrMsg = "请登录,用户信息为空"
  617. br.Ret = 408
  618. return
  619. }
  620. resp := new(cygx.ScoreOverviewListResp)
  621. keyWord := this.GetString("KeyWord")
  622. city := this.GetString("City")
  623. enterScoreType, _ := this.GetInt("EnterScoreType", 1)
  624. startDate := this.GetString("StartDate")
  625. endDate := this.GetString("EndDate")
  626. //是否导出报表
  627. isExport, _ := this.GetBool("IsExport")
  628. if startDate == "" {
  629. br.Msg = "请选择对应年份与季度"
  630. return
  631. }
  632. var condition string
  633. var pars []interface{}
  634. if endDate != "" {
  635. condition += ` AND start_date <= ? AND end_date >= ? `
  636. pars = append(pars, startDate, endDate)
  637. }
  638. //if enterScoreType == 2 {
  639. //condition += ` AND enter_score_type = 2 `
  640. //}
  641. if keyWord != "" {
  642. condition += ` AND securities_firms_name LIKE '%` + keyWord + `%' `
  643. }
  644. total, err := cygx.GetCygxEnterScoreCount(condition, pars)
  645. if err != nil {
  646. br.Msg = "获取失败"
  647. br.ErrMsg = "获取失败,Err:" + err.Error()
  648. return
  649. }
  650. if total > 0 {
  651. list, err := cygx.GetCygxEnterScoreList(condition, pars, 0, 100)
  652. if err != nil {
  653. br.Msg = "获取失败"
  654. br.ErrMsg = "获取失败,GetCygxEnterScoreListErr:" + err.Error()
  655. return
  656. }
  657. mapenterScoreTypeCompanyIds := make(map[int]bool)
  658. mapenterScoreProportionTotal := make(map[int]float64)
  659. var enterScoreIds []int
  660. mapenterScore := make(map[int]*cygx.CygxEnterScore) //录分详情放在map中
  661. for _, v := range list {
  662. mapenterScore[v.CompanyId] = v
  663. mapenterScoreProportionTotal[v.CompanyId] = v.ProportionTotal
  664. enterScoreIds = append(enterScoreIds, v.EnterScoreId)
  665. if v.EnterScoreType == 2 {
  666. mapenterScoreTypeCompanyIds[v.CompanyId] = true //记录按照百分比录入的公司
  667. }
  668. }
  669. var companyCondition string
  670. var companypars []interface{}
  671. companyCondition += ` AND b.product_name = ? `
  672. companypars = append(companypars, "权益")
  673. companyCondition += ` AND b.status = ? `
  674. companypars = append(companypars, "永续")
  675. //权益申请销售只能看到自己名下的客户的申请
  676. companyIds, err := cygxService.GetAdminLookUserCompanyIdsBySelf(AdminUser)
  677. if err != nil {
  678. br.Msg = "获取失败"
  679. br.ErrMsg = "获取失败,GetAdminLookUserCompanyIds Err:" + err.Error()
  680. return
  681. }
  682. var newcompanyIds []int
  683. lencompanyIds := len(companyIds)
  684. var searchcompanyIds []int
  685. //如果机构搜索做了限制 ,那么公司列表的纵向展示也做限制
  686. if keyWord != "" {
  687. for _, v := range list {
  688. searchcompanyIds = append(searchcompanyIds, v.CompanyId)
  689. }
  690. if lencompanyIds > 0 {
  691. newcompanyIds = utils.IntersectInt(searchcompanyIds, companyIds) //获取销售可见权限,与搜索权限的交集
  692. } else {
  693. newcompanyIds = searchcompanyIds
  694. }
  695. } else {
  696. newcompanyIds = companyIds
  697. }
  698. newlencompanyIds := len(newcompanyIds)
  699. if newlencompanyIds > 0 {
  700. companyCondition += ` AND a.company_id IN (` + utils.GetOrmInReplace(newlencompanyIds) + `)`
  701. companypars = append(companypars, newcompanyIds)
  702. }
  703. if city != "" {
  704. //传过来多个城市的时候的筛选
  705. citySlice := strings.Split(city, ",")
  706. city = strings.Join(citySlice, "','")
  707. city = "'" + city + "'"
  708. companyCondition += ` AND a.city IN (` + city + `) `
  709. }
  710. companyList, err := company.GetCompanyIdListByproductName(companyCondition, companypars)
  711. if err != nil {
  712. br.Msg = "获取失败"
  713. br.ErrMsg = "获取失败,Err:" + err.Error()
  714. return
  715. }
  716. //fmt.Println(enterScoreIds)
  717. listResearcher, err := cygx.GeCygxEnterScoreResearcherListByIds(enterScoreIds, newcompanyIds) //获取所有的研究员
  718. if err != nil {
  719. br.Msg = "获取失败"
  720. br.ErrMsg = "获取失败,GetCygxEnterScorePermissionListByIds Err:" + err.Error()
  721. return
  722. }
  723. mapResearcher := make(map[string][]*cygx.EnterScoreRealNameListResp)
  724. mapResearcherProportion := make(map[string]string)
  725. //mapResearcherPermission := make(map[string][]map[string]string)
  726. var researcherArr []string // 会出现的研究员姓名
  727. mapResearcherbool := make(map[string]bool)
  728. for _, v := range listResearcher {
  729. if v.Proportion == 0 {
  730. continue
  731. }
  732. if !mapResearcherbool[v.RealName] {
  733. researcherArr = append(researcherArr, v.RealName)
  734. mapResearcherbool[v.RealName] = true
  735. }
  736. if enterScoreType == 2 && !mapenterScoreTypeCompanyIds[v.CompanyId] {
  737. mapResearcherProportion[fmt.Sprint(v.RealName, "_", v.CompanyId)] = utils.SubFloatToString(v.Proportion/mapenterScoreProportionTotal[v.CompanyId]*100, 2) //研究员姓名、公司ID,占比值对应关系绑定
  738. } else {
  739. mapResearcherProportion[fmt.Sprint(v.RealName, "_", v.CompanyId)] = fmt.Sprint(v.Proportion) //研究员姓名、公司ID,占比值对应关系绑定
  740. }
  741. }
  742. mapResearcherProportionText := make(map[string][]string)
  743. for _, vC := range companyList {
  744. for _, vR := range researcherArr {
  745. var proportionText string
  746. if mapResearcherProportion[fmt.Sprint(vR, "_", vC.CompanyId)] != "" {
  747. proportionText = mapResearcherProportion[fmt.Sprint(vR, "_", vC.CompanyId)]
  748. } else {
  749. proportionText = "0"
  750. }
  751. if mapenterScoreTypeCompanyIds[vC.CompanyId] || enterScoreType == 2 { //按照百分比展示的拼接 %
  752. proportionText += "%"
  753. }
  754. mapResearcherProportionText[vR] = append(mapResearcherProportionText[vR], proportionText)
  755. }
  756. }
  757. researcherArr = make([]string, 0)
  758. for _, v := range listResearcher {
  759. if v.Proportion == 0 {
  760. continue
  761. }
  762. if utils.InArrayByStr(researcherArr, v.RealName) { //避免重复合并到数组
  763. continue
  764. }
  765. item := new(cygx.EnterScoreRealNameListResp) // 研究员结构体数据
  766. item.RealName = v.RealName
  767. item.ChartPermissionName = v.ChartPermissionName
  768. item.ProportionListText = mapResearcherProportionText[v.RealName]
  769. mapResearcher[v.ChartPermissionName] = append(mapResearcher[v.ChartPermissionName], item)
  770. researcherArr = append(researcherArr, v.RealName)
  771. }
  772. listPermission, err := cygx.GetCygxEnterScorePermissionListByIds(enterScoreIds) // 获取所有的行业名称
  773. if err != nil {
  774. br.Msg = "获取失败"
  775. br.ErrMsg = "获取失败,GetCygxEnterScorePermissionListByIds Err:" + err.Error()
  776. return
  777. }
  778. mapPermissionProportion := make(map[string]string)
  779. for _, v := range listPermission {
  780. if v.Proportion == 0 {
  781. continue
  782. }
  783. //mapPermissionProportion[fmt.Sprint(v.ChartPermissionName, "_", v.CompanyId)] = fmt.Sprint(v.Proportion) //行业名称、公司ID,占比值对应关系绑定
  784. if enterScoreType == 2 && !mapenterScoreTypeCompanyIds[v.CompanyId] {
  785. mapPermissionProportion[fmt.Sprint(v.ChartPermissionName, "_", v.CompanyId)] = utils.SubFloatToString(v.Proportion/mapenterScoreProportionTotal[v.CompanyId]*100, 2) //研究员姓名、公司ID,占比值对应关系绑定
  786. } else {
  787. mapPermissionProportion[fmt.Sprint(v.ChartPermissionName, "_", v.CompanyId)] = fmt.Sprint(v.Proportion) //行业名称、公司ID,占比值对应关系绑定
  788. }
  789. }
  790. var permissionArr []string // 会出现的行业名称
  791. mapPermissionbool := make(map[string]bool)
  792. for _, v := range listPermission {
  793. if mapPermissionbool[v.ChartPermissionName] {
  794. continue
  795. }
  796. permissionArr = append(permissionArr, v.ChartPermissionName)
  797. mapPermissionbool[v.ChartPermissionName] = true
  798. }
  799. mapPermissionProportionText := make(map[string][]string)
  800. for _, vC := range companyList {
  801. for _, vP := range permissionArr {
  802. var proportionText string
  803. if mapPermissionProportion[fmt.Sprint(vP, "_", vC.CompanyId)] != "" {
  804. proportionText = mapPermissionProportion[fmt.Sprint(vP, "_", vC.CompanyId)]
  805. } else {
  806. proportionText = "0"
  807. }
  808. if mapenterScoreTypeCompanyIds[vC.CompanyId] || enterScoreType == 2 { //按照百分比展示的拼接 %
  809. proportionText += "%"
  810. }
  811. mapPermissionProportionText[vP] = append(mapPermissionProportionText[vP], proportionText)
  812. }
  813. }
  814. var itemsP []*cygx.EnterScorePermissionListResp
  815. for _, v := range permissionArr {
  816. itemP := new(cygx.EnterScorePermissionListResp) //行业结构体
  817. itemP.ChartPermissionName = v
  818. itemP.ProportionListText = mapPermissionProportionText[v]
  819. itemP.List = mapResearcher[v]
  820. itemsP = append(itemsP, itemP)
  821. }
  822. listGroup, err := cygx.GeCygxEnterScoreGroupListByIds(enterScoreIds) // 获取所有自定义分组名称
  823. if err != nil {
  824. br.Msg = "获取失败"
  825. br.ErrMsg = "获取失败,GeCygxEnterScoreGroupListByIds Err:" + err.Error()
  826. return
  827. }
  828. mapGroupProportion := make(map[string]string)
  829. var groupArr []string // 会出现的自定义分组名称
  830. mapGroupbool := make(map[string]bool)
  831. for _, v := range listGroup {
  832. if enterScoreType == 2 && !mapenterScoreTypeCompanyIds[v.CompanyId] {
  833. mapGroupProportion[fmt.Sprint(v.GroupName, "_", v.CompanyId)] = utils.SubFloatToString(v.Proportion/mapenterScoreProportionTotal[v.CompanyId]*100, 2) //自定义分组名称、公司ID,占比值对应关系绑定
  834. } else {
  835. mapGroupProportion[fmt.Sprint(v.GroupName, "_", v.CompanyId)] = fmt.Sprint(v.Proportion) //自定义分组名称、公司ID,占比值对应关系绑定
  836. }
  837. //mapGroupProportion[fmt.Sprint(v.GroupName, "_", v.CompanyId)] = fmt.Sprint(v.Proportion) //自定义分组名称、公司ID,占比值对应关系绑定
  838. if mapGroupbool[v.GroupName] {
  839. continue
  840. }
  841. groupArr = append(groupArr, v.GroupName)
  842. mapGroupbool[v.GroupName] = true
  843. }
  844. mapGroupProportionText := make(map[string][]string)
  845. for _, vC := range companyList {
  846. for _, vP := range groupArr {
  847. var proportionText string
  848. if mapGroupProportion[fmt.Sprint(vP, "_", vC.CompanyId)] != "" {
  849. proportionText = mapGroupProportion[fmt.Sprint(vP, "_", vC.CompanyId)]
  850. } else {
  851. proportionText = "0"
  852. }
  853. if mapenterScoreTypeCompanyIds[vC.CompanyId] || enterScoreType == 2 { //按照百分比展示的拼接 %
  854. proportionText += "%"
  855. }
  856. mapGroupProportionText[vP] = append(mapGroupProportionText[vP], proportionText)
  857. }
  858. }
  859. var itemsG []*cygx.EnterScoreGroupListResp
  860. for _, v := range groupArr {
  861. itemG := new(cygx.EnterScoreGroupListResp) //行业结构体
  862. itemG.GroupName = v
  863. itemG.ProportionListText = mapGroupProportionText[v]
  864. itemsG = append(itemsG, itemG)
  865. }
  866. var rankingText []string //排名
  867. var securitiesFirmsNameText []string //券商名称
  868. var proportionTotalText []string //占比
  869. for _, vC := range companyList {
  870. var ranking, securitiesFirmsName, proportionTotal string
  871. item := mapenterScore[vC.CompanyId]
  872. if item != nil {
  873. ranking = item.Ranking
  874. securitiesFirmsName = item.SecuritiesFirmsName
  875. proportionTotal = fmt.Sprint(item.MergeProportion)
  876. }
  877. if mapenterScoreTypeCompanyIds[vC.CompanyId] { //按照百分比展示的拼接 %
  878. proportionTotal += "%"
  879. }
  880. rankingText = append(rankingText, ranking)
  881. securitiesFirmsNameText = append(securitiesFirmsNameText, securitiesFirmsName)
  882. proportionTotalText = append(proportionTotalText, proportionTotal)
  883. }
  884. itemranking := new(cygx.EnterScoreGroupListResp) //排名结构体
  885. itemranking.GroupName = "排名"
  886. itemranking.ProportionListText = rankingText
  887. itemsG = append(itemsG, itemranking)
  888. itemsecuritiesFirmsName := new(cygx.EnterScoreGroupListResp) //券商名称结构体
  889. itemsecuritiesFirmsName.GroupName = "券商名称"
  890. itemsecuritiesFirmsName.ProportionListText = securitiesFirmsNameText
  891. itemsG = append(itemsG, itemsecuritiesFirmsName)
  892. itemproportionTotal := new(cygx.EnterScoreGroupListResp) //券商名称结构体
  893. itemproportionTotal.GroupName = "占比"
  894. itemproportionTotal.ProportionListText = proportionTotalText
  895. itemsG = append(itemsG, itemproportionTotal)
  896. resp.ListPermission = itemsP
  897. resp.ListGroup = itemsG
  898. resp.ListCompany = companyList
  899. } else {
  900. resp.ListPermission = make([]*cygx.EnterScorePermissionListResp, 0)
  901. resp.ListGroup = make([]*cygx.EnterScoreGroupListResp, 0)
  902. resp.ListCompany = make([]*company.CompanyNameAndId, 0)
  903. }
  904. //导出excel
  905. if isExport {
  906. EnterScoreScoreOverviewExport(this, resp, br)
  907. return
  908. }
  909. br.Ret = 200
  910. br.Success = true
  911. br.Msg = "获取成功"
  912. br.Data = resp
  913. }
  914. // EnterScoreScoreOverviewExport 导出Excel
  915. func EnterScoreScoreOverviewExport(this *EnterScoreController, resp *cygx.ScoreOverviewListResp, br *models.BaseResponse) {
  916. dir, err := os.Executable()
  917. exPath := filepath.Dir(dir)
  918. downLoadnFilePath := exPath + "/" + time.Now().Format(utils.FormatDateTimeUnSpace) + ".xlsx"
  919. xlsxFile := xlsx.NewFile()
  920. if err != nil {
  921. br.Msg = "生成文件失败"
  922. br.ErrMsg = "生成文件失败"
  923. return
  924. }
  925. style := xlsx.NewStyle()
  926. alignment := xlsx.Alignment{
  927. Horizontal: "center",
  928. Vertical: "center",
  929. WrapText: true,
  930. }
  931. style.Alignment = alignment
  932. style.ApplyAlignment = true
  933. sheel, err := xlsxFile.AddSheet("评分总览")
  934. if err != nil {
  935. br.Msg = "新增Sheet失败"
  936. br.ErrMsg = "新增Sheet失败,Err:" + err.Error()
  937. return
  938. }
  939. sheel.SetColWidth(0, 0, 30)
  940. sheel.SetColWidth(1, 1, 15)
  941. sheel.SetColWidth(2, 2, 15)
  942. sheel.SetColWidth(3, 3, 18)
  943. companyList := resp.ListCompany
  944. listPermission := resp.ListPermission
  945. listGroup := resp.ListGroup
  946. titleRow := sheel.AddRow()
  947. cellNull := titleRow.AddCell()
  948. cellNull.SetStyle(style)
  949. cellNull.SetValue("")
  950. for _, v := range companyList { //第一行公司
  951. cellA := titleRow.AddCell()
  952. cellA.SetStyle(style)
  953. cellA.SetValue(v.CompanyName)
  954. }
  955. for _, v := range listPermission { // 行业排序名称
  956. dataRow := sheel.AddRow()
  957. dataRow.SetHeight(20)
  958. cellA := dataRow.AddCell()
  959. cellA.SetStyle(style)
  960. cellA.SetValue(v.ChartPermissionName)
  961. for _, vCp := range v.ProportionListText { // 行业对应的占比值
  962. cellP := dataRow.AddCell()
  963. cellP.SetStyle(style)
  964. cellP.SetValue(vCp)
  965. }
  966. for _, vUser := range v.List { // 研究员姓名
  967. dataRowName := sheel.AddRow()
  968. dataRowName.SetHeight(20)
  969. cellName := dataRowName.AddCell()
  970. cellName.SetStyle(style)
  971. cellName.SetValue(vUser.RealName)
  972. for _, vUp := range vUser.ProportionListText { //研究员占比值
  973. cellP := dataRowName.AddCell()
  974. cellP.SetStyle(style)
  975. cellP.SetValue(vUp)
  976. }
  977. }
  978. }
  979. for _, v := range listGroup { // 自定义名称
  980. dataRow := sheel.AddRow()
  981. dataRow.SetHeight(20)
  982. cellA := dataRow.AddCell()
  983. cellA.SetStyle(style)
  984. cellA.SetValue(v.GroupName)
  985. for _, vG := range v.ProportionListText { // 自定义名称所对应的值
  986. cellP := dataRow.AddCell()
  987. cellP.SetStyle(style)
  988. cellP.SetValue(vG)
  989. }
  990. }
  991. err = xlsxFile.Save(downLoadnFilePath)
  992. if err != nil {
  993. br.Msg = "保存文件失败"
  994. br.ErrMsg = "保存文件失败"
  995. return
  996. }
  997. randStr := time.Now().Format(utils.FormatDateTimeUnSpace)
  998. downloadFileName := "评分总览" + randStr + ".xlsx"
  999. this.Ctx.Output.Download(downLoadnFilePath, downloadFileName)
  1000. defer func() {
  1001. os.Remove(downLoadnFilePath)
  1002. }()
  1003. br.Ret = 200
  1004. br.Success = true
  1005. br.Msg = "导出成功"
  1006. }
  1007. // @Title 排名总览
  1008. // @Description 排名总览接口
  1009. // @Param AdminId query string true "销售id,多个用英文逗号隔开,空字符串为全部"
  1010. // @Param City query string true "城市"
  1011. // @Param IsExport query bool false "是否导出excel,默认是false"
  1012. // @Success Ret=200 {object} cygx.CompanyNameAndIdListResp
  1013. // @router /enterScore/rankingOverview [get]
  1014. func (this *EnterScoreController) EnterScoreRankingOverview() {
  1015. br := new(models.BaseResponse).Init()
  1016. defer func() {
  1017. this.Data["json"] = br
  1018. this.ServeJSON()
  1019. }()
  1020. AdminUser := this.SysUser
  1021. if AdminUser == nil {
  1022. br.Msg = "请登录"
  1023. br.ErrMsg = "请登录,用户信息为空"
  1024. br.Ret = 408
  1025. return
  1026. }
  1027. resp := new(cygx.RankingOverviewListResp)
  1028. city := this.GetString("City")
  1029. adminId := this.GetString("AdminId")
  1030. //是否导出报表
  1031. isExport, _ := this.GetBool("IsExport")
  1032. var companyCondition string
  1033. var companypars []interface{}
  1034. companyCondition += ` AND b.product_name = ? `
  1035. companypars = append(companypars, "权益")
  1036. companyCondition += ` AND b.status = ? `
  1037. companypars = append(companypars, "永续")
  1038. if adminId != "" {
  1039. companyCondition += ` AND b.seller_id IN (` + adminId + `) `
  1040. }
  1041. if city != "" {
  1042. //传过来多个城市的时候的筛选
  1043. citySlice := strings.Split(city, ",")
  1044. city = strings.Join(citySlice, "','")
  1045. city = "'" + city + "'"
  1046. companyCondition += ` AND a.city IN (` + city + `) `
  1047. }
  1048. //权益申请销售只能看到自己名下的客户的申请
  1049. companyIds, err := cygxService.GetAdminLookUserCompanyIdsBySelf(AdminUser)
  1050. if err != nil {
  1051. br.Msg = "获取失败"
  1052. br.ErrMsg = "获取失败,GetAdminLookUserCompanyIdsBySelf Err:" + err.Error()
  1053. return
  1054. }
  1055. lencompanyIds := len(companyIds)
  1056. if lencompanyIds > 0 {
  1057. companyCondition += ` AND a.company_id IN (` + utils.GetOrmInReplace(lencompanyIds) + `)`
  1058. companypars = append(companypars, companyIds)
  1059. }
  1060. companyList, err := company.GetCompanyIdListByproductName(companyCondition, companypars)
  1061. if err != nil {
  1062. br.Msg = "获取失败"
  1063. br.ErrMsg = "获取失败,Err:" + err.Error()
  1064. return
  1065. }
  1066. var condition string
  1067. var pars []interface{}
  1068. total, err := cygx.GetCygxEnterScoreCount(condition, pars)
  1069. if err != nil {
  1070. br.Msg = "获取失败"
  1071. br.ErrMsg = "获取失败,Err:" + err.Error()
  1072. return
  1073. }
  1074. dataMd := []string{"10-01", "07-01", "04-01", "01-01"}
  1075. thisYear := time.Now().Year()
  1076. startYear := 2018 // 自定义开始时间
  1077. var quarterDate []string
  1078. for _, v := range dataMd {
  1079. dateTimeStr := fmt.Sprint(thisYear, "-", v)
  1080. dateTime, err := time.Parse("2006-01-02", dateTimeStr)
  1081. if err != nil {
  1082. br.Msg = "获取失败"
  1083. br.ErrMsg = "获取失败,Err:" + err.Error()
  1084. return
  1085. }
  1086. if dateTime.After(time.Now()) {
  1087. continue
  1088. }
  1089. quarterDate = append(quarterDate, dateTimeStr)
  1090. }
  1091. for i := thisYear - 1; i >= startYear; i-- {
  1092. for _, v := range dataMd {
  1093. dateTimeStr := fmt.Sprint(i, "-", v)
  1094. quarterDate = append(quarterDate, dateTimeStr)
  1095. }
  1096. }
  1097. var itemsQuarter []*cygx.QuarterDateListResp
  1098. if total > 0 {
  1099. list, err := cygx.GetCygxEnterScoreList(condition, pars, 0, 9999)
  1100. if err != nil {
  1101. br.Msg = "获取失败"
  1102. br.ErrMsg = "获取失败,GetCygxEnterScoreList Err:" + err.Error()
  1103. return
  1104. }
  1105. mapQuarter := make(map[string]string)
  1106. for _, v := range list {
  1107. silicequarter := strings.Split(v.QuarterDate, ",")
  1108. for _, vQ := range silicequarter {
  1109. mapQuarter[fmt.Sprint(vQ, "_", v.CompanyId)] = v.Ranking //季度时间、公司ID,排名对应关系绑定
  1110. }
  1111. }
  1112. mapRankingText := make(map[string][]string)
  1113. for _, vC := range companyList {
  1114. for _, vQ := range quarterDate {
  1115. var ranking string
  1116. ranking = mapQuarter[fmt.Sprint(vQ, "_", vC.CompanyId)]
  1117. mapRankingText[vQ] = append(mapRankingText[vQ], ranking)
  1118. }
  1119. }
  1120. for _, v := range quarterDate {
  1121. itemQuarter := new(cygx.QuarterDateListResp)
  1122. quarter := v
  1123. //时间后面的月日替换成季度 Q几
  1124. quarter = strings.Replace(quarter, "-10-01", "Q4", -1)
  1125. quarter = strings.Replace(quarter, "-07-01", "Q3", -1)
  1126. quarter = strings.Replace(quarter, "-04-01", "Q2", -1)
  1127. quarter = strings.Replace(quarter, "-01-01", "Q1", -1)
  1128. itemQuarter.Quarter = quarter
  1129. itemQuarter.ProportionListText = mapRankingText[v]
  1130. itemsQuarter = append(itemsQuarter, itemQuarter)
  1131. }
  1132. }
  1133. resp.ListCompany = companyList
  1134. resp.ListQuarterDate = itemsQuarter
  1135. //导出excel
  1136. if isExport {
  1137. RankingOverviewExport(this, resp, br)
  1138. return
  1139. }
  1140. br.Ret = 200
  1141. br.Success = true
  1142. br.Msg = "获取成功"
  1143. br.Data = resp
  1144. }
  1145. // RankingOverviewExport 导出Excel
  1146. func RankingOverviewExport(this *EnterScoreController, resp *cygx.RankingOverviewListResp, br *models.BaseResponse) {
  1147. dir, err := os.Executable()
  1148. exPath := filepath.Dir(dir)
  1149. downLoadnFilePath := exPath + "/" + time.Now().Format(utils.FormatDateTimeUnSpace) + ".xlsx"
  1150. xlsxFile := xlsx.NewFile()
  1151. if err != nil {
  1152. br.Msg = "生成文件失败"
  1153. br.ErrMsg = "生成文件失败"
  1154. return
  1155. }
  1156. style := xlsx.NewStyle()
  1157. alignment := xlsx.Alignment{
  1158. Horizontal: "center",
  1159. Vertical: "center",
  1160. WrapText: true,
  1161. }
  1162. style.Alignment = alignment
  1163. style.ApplyAlignment = true
  1164. sheel, err := xlsxFile.AddSheet("排名总览")
  1165. if err != nil {
  1166. br.Msg = "新增Sheet失败"
  1167. br.ErrMsg = "新增Sheet失败,Err:" + err.Error()
  1168. return
  1169. }
  1170. sheel.SetColWidth(0, 0, 30)
  1171. sheel.SetColWidth(1, 1, 15)
  1172. sheel.SetColWidth(2, 2, 15)
  1173. sheel.SetColWidth(3, 3, 18)
  1174. companyList := resp.ListCompany
  1175. listQuarterDate := resp.ListQuarterDate
  1176. titleRow := sheel.AddRow()
  1177. cellNull := titleRow.AddCell()
  1178. cellNull.SetStyle(style)
  1179. cellNull.SetValue("")
  1180. for _, v := range companyList { //第一行公司
  1181. cellA := titleRow.AddCell()
  1182. cellA.SetStyle(style)
  1183. cellA.SetValue(v.CompanyName)
  1184. }
  1185. for _, v := range listQuarterDate { // 季度排序
  1186. dataRow := sheel.AddRow()
  1187. dataRow.SetHeight(20)
  1188. cellA := dataRow.AddCell()
  1189. cellA.SetStyle(style)
  1190. cellA.SetValue(v.Quarter)
  1191. for _, vCp := range v.ProportionListText { // 行业对应的占比值
  1192. cellP := dataRow.AddCell()
  1193. cellP.SetStyle(style)
  1194. cellP.SetValue(vCp)
  1195. }
  1196. }
  1197. err = xlsxFile.Save(downLoadnFilePath)
  1198. if err != nil {
  1199. br.Msg = "保存文件失败"
  1200. br.ErrMsg = "保存文件失败"
  1201. return
  1202. }
  1203. randStr := time.Now().Format(utils.FormatDateTimeUnSpace)
  1204. downloadFileName := "排名总览" + randStr + ".xlsx"
  1205. this.Ctx.Output.Download(downLoadnFilePath, downloadFileName)
  1206. defer func() {
  1207. os.Remove(downLoadnFilePath)
  1208. }()
  1209. br.Ret = 200
  1210. br.Success = true
  1211. br.Msg = "导出成功"
  1212. }