enter_score.go 46 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443
  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. // @Param IsExport query bool false "是否导出excel,默认是false"
  459. // @Success 200 {object} cygx.GetCygxEnterScoreListRep
  460. // @router /enterScore/list [get]
  461. func (this *EnterScoreController) EnterScoreList() {
  462. br := new(models.BaseResponse).Init()
  463. defer func() {
  464. this.Data["json"] = br
  465. this.ServeJSON()
  466. }()
  467. sysUser := this.SysUser
  468. if sysUser == nil {
  469. br.Msg = "请登录"
  470. br.ErrMsg = "请登录,SysUser Is Empty"
  471. br.Ret = 408
  472. return
  473. }
  474. pageSize, _ := this.GetInt("PageSize")
  475. currentIndex, _ := this.GetInt("CurrentIndex")
  476. keyWord := this.GetString("KeyWord")
  477. adminId := this.GetString("AdminId")
  478. //是否导出报表
  479. isExport, _ := this.GetBool("IsExport")
  480. var startSize int
  481. if pageSize <= 0 {
  482. pageSize = utils.PageSize20
  483. }
  484. if currentIndex <= 0 {
  485. currentIndex = 1
  486. }
  487. fmt.Println(isExport)
  488. startSize = utils.StartIndex(currentIndex, pageSize)
  489. if isExport {
  490. startSize = 0
  491. pageSize = 9999
  492. }
  493. var condition string
  494. var pars []interface{}
  495. //如果不是权益管理员和admin,就做可见权限限制
  496. if sysUser.RoleTypeCode != utils.ROLE_TYPE_CODE_RAI_ADMIN && sysUser.RoleTypeCode != utils.ROLE_TYPE_CODE_ADMIN {
  497. var conditionAdmin string
  498. var parsAdmin []interface{}
  499. conditionAdmin = " AND product_id = 2 AND status = '永续' AND seller_id = ? "
  500. parsAdmin = append(parsAdmin, sysUser.AdminId)
  501. listProduct, err := company.GetCompanyProductList(conditionAdmin, parsAdmin)
  502. if err != nil {
  503. br.Msg = "获取失败"
  504. br.ErrMsg = "获取失败,Err:" + err.Error()
  505. return
  506. }
  507. var companyIds []int
  508. for _, v := range listProduct {
  509. companyIds = append(companyIds, v.CompanyId)
  510. }
  511. companyIds = append(companyIds, 0)
  512. condition += ` AND company_id IN (` + utils.GetOrmInReplace(len(companyIds)) + `) `
  513. pars = append(pars, companyIds)
  514. }
  515. if keyWord != "" {
  516. condition += ` AND company_name LIKE '%` + keyWord + `%' `
  517. }
  518. if adminId != "" {
  519. condition += ` AND seller_id IN (` + adminId + `) `
  520. }
  521. total, err := cygx.GetCygxEnterScoreCount(condition, pars)
  522. if err != nil {
  523. br.Msg = "获取失败"
  524. br.ErrMsg = "获取失败,Err:" + err.Error()
  525. return
  526. }
  527. list, err := cygx.GetCygxEnterScoreList(condition, pars, startSize, pageSize)
  528. if err != nil {
  529. br.Msg = "获取失败"
  530. br.ErrMsg = "获取失败,Err:" + err.Error()
  531. return
  532. }
  533. resp := new(cygx.GetCygxEnterScoreListRep)
  534. if len(list) == 0 {
  535. resp.List = make([]*cygx.EnterScoreListResp, 0)
  536. } else {
  537. for _, v := range list {
  538. item := new(cygx.EnterScoreListResp)
  539. item.EnterScoreId = v.EnterScoreId
  540. item.CompanyId = v.CompanyId
  541. item.CompanyName = v.CompanyName
  542. item.Quarter = strings.Split(v.Quarter, ",")
  543. item.EnterScoreType = v.EnterScoreType
  544. item.Ranking = v.Ranking
  545. item.IsMergeScoring = v.IsMergeScoring
  546. item.SecuritiesFirmsName = v.SecuritiesFirmsName
  547. item.ProportionTotal = v.ProportionTotal
  548. item.EnterScoreId = v.EnterScoreId
  549. item.SellerId = v.SellerId
  550. item.SellerName = v.SellerName
  551. item.CreateTime = v.CreateTime.Format(utils.FormatDateTime)
  552. item.ModifyTime = v.ModifyTime.Format(utils.FormatDateTime)
  553. resp.List = append(resp.List, item)
  554. }
  555. }
  556. //导出excel
  557. if isExport {
  558. EnterScoreScoreListExport(this, resp, br)
  559. return
  560. }
  561. page := paging.GetPaging(currentIndex, pageSize, total)
  562. resp.Paging = page
  563. br.Ret = 200
  564. br.Success = true
  565. br.Msg = "获取成功"
  566. br.Data = resp
  567. }
  568. // EnterScoreScoreListExport 导出Excel
  569. func EnterScoreScoreListExport(this *EnterScoreController, resp *cygx.GetCygxEnterScoreListRep, br *models.BaseResponse) {
  570. dir, err := os.Executable()
  571. exPath := filepath.Dir(dir)
  572. downLoadnFilePath := exPath + "/" + time.Now().Format(utils.FormatDateTimeUnSpace) + ".xlsx"
  573. xlsxFile := xlsx.NewFile()
  574. if err != nil {
  575. br.Msg = "生成文件失败"
  576. br.ErrMsg = "生成文件失败"
  577. return
  578. }
  579. style := xlsx.NewStyle()
  580. alignment := xlsx.Alignment{
  581. Horizontal: "center",
  582. Vertical: "center",
  583. WrapText: true,
  584. }
  585. style.Alignment = alignment
  586. style.ApplyAlignment = true
  587. sheel, err := xlsxFile.AddSheet("录分记录")
  588. if err != nil {
  589. br.Msg = "新增Sheet失败"
  590. br.ErrMsg = "新增Sheet失败,Err:" + err.Error()
  591. return
  592. }
  593. sheel.SetColWidth(0, 0, 30)
  594. sheel.SetColWidth(1, 1, 15)
  595. sheel.SetColWidth(2, 2, 15)
  596. sheel.SetColWidth(3, 3, 18)
  597. titleRow := sheel.AddRow()
  598. cellA := titleRow.AddCell()
  599. cellA.SetStyle(style)
  600. cellA.SetValue("客户名称")
  601. cellB := titleRow.AddCell()
  602. cellB.SetStyle(style)
  603. cellB.SetValue("销售")
  604. cellC := titleRow.AddCell()
  605. cellC.SetStyle(style)
  606. cellC.SetValue("季度")
  607. cellD := titleRow.AddCell()
  608. cellD.SetStyle(style)
  609. cellD.SetValue("总分")
  610. cellE := titleRow.AddCell()
  611. cellE.SetStyle(style)
  612. cellE.SetValue("排名")
  613. cellF := titleRow.AddCell()
  614. cellF.SetStyle(style)
  615. cellF.SetValue("合并打分")
  616. cellG := titleRow.AddCell()
  617. cellG.SetStyle(style)
  618. cellG.SetValue("券商名称")
  619. for _, v := range resp.List {
  620. dataRow := sheel.AddRow()
  621. dataRow.SetHeight(20)
  622. cellA := dataRow.AddCell()
  623. cellA.SetStyle(style)
  624. cellA.SetValue(v.CompanyName)
  625. cellB := dataRow.AddCell()
  626. cellB.SetStyle(style)
  627. cellB.SetValue(v.SellerName)
  628. cellC := dataRow.AddCell()
  629. cellC.SetStyle(style)
  630. cellC.SetValue(strings.Join(v.Quarter, ","))
  631. cellD := dataRow.AddCell()
  632. cellD.SetStyle(style)
  633. cellD.SetValue(v.ProportionTotal)
  634. cellE := dataRow.AddCell()
  635. cellE.SetStyle(style)
  636. cellE.SetValue(v.Ranking)
  637. cellF := dataRow.AddCell()
  638. cellF.SetStyle(style)
  639. if v.IsMergeScoring == 1 {
  640. cellF.SetValue("是")
  641. } else {
  642. cellF.SetValue("否")
  643. }
  644. cellG := dataRow.AddCell()
  645. cellG.SetStyle(style)
  646. cellG.SetValue(v.SecuritiesFirmsName)
  647. }
  648. err = xlsxFile.Save(downLoadnFilePath)
  649. if err != nil {
  650. br.Msg = "保存文件失败"
  651. br.ErrMsg = "保存文件失败"
  652. return
  653. }
  654. randStr := time.Now().Format(utils.FormatDateTimeUnSpace)
  655. downloadFileName := "录分记录导出数据_" + randStr + ".xlsx"
  656. this.Ctx.Output.Download(downLoadnFilePath, downloadFileName)
  657. defer func() {
  658. os.Remove(downLoadnFilePath)
  659. }()
  660. br.Ret = 200
  661. br.Success = true
  662. br.Msg = "导出成功"
  663. }
  664. // @Title 删除录分
  665. // @Description 删除录分接口
  666. // @Param request body cygx.UpdateEnterScoreReq true "type json string"
  667. // @Success 200 {object} "保存成功"
  668. // @router /enterScore/delete [post]
  669. func (this *EnterScoreController) EnterScoreDelete() {
  670. br := new(models.BaseResponse).Init()
  671. defer func() {
  672. this.Data["json"] = br
  673. this.ServeJSON()
  674. }()
  675. sysUser := this.SysUser
  676. if sysUser == nil {
  677. br.Msg = "请登录"
  678. br.ErrMsg = "请登录,SysUser Is Empty"
  679. br.Ret = 408
  680. return
  681. }
  682. var req cygx.EnterScoreIdReq
  683. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  684. if err != nil {
  685. br.Msg = "参数解析异常!"
  686. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  687. return
  688. }
  689. enterScoreId := req.EnterScoreId
  690. if enterScoreId == 0 {
  691. br.Msg = "参数错误!"
  692. br.ErrMsg = "参数错误,EnterScoreId 不能为0"
  693. return
  694. }
  695. err = cygx.DeleteEnterScore(enterScoreId)
  696. if err != nil {
  697. br.Msg = "删除失败"
  698. br.ErrMsg = "操作失败Err:" + err.Error()
  699. return
  700. }
  701. br.Ret = 200
  702. br.Success = true
  703. br.IsAddLog = true
  704. br.Msg = "删除成功"
  705. }
  706. // @Title 评分总览
  707. // @Description 评分总览接口
  708. // @Param KeyWord query string true "搜索关键词"
  709. // @Param City query string true "城市"
  710. // @Param StartDate query string false "开始日期"
  711. // @Param EndDate query string false "结束日期"
  712. // @Param EnterScoreType query string false "展示法方式 1:按评分录入、2:按比例录入,默认1"
  713. // @Param IsExport query bool false "是否导出excel,默认是false"
  714. // @Success Ret=200 {object} cygx.ScoreOverviewListResp
  715. // @router /enterScore/scoreOverview [get]
  716. func (this *EnterScoreController) EnterScoreScoreOverview() {
  717. br := new(models.BaseResponse).Init()
  718. defer func() {
  719. this.Data["json"] = br
  720. this.ServeJSON()
  721. }()
  722. AdminUser := this.SysUser
  723. if AdminUser == nil {
  724. br.Msg = "请登录"
  725. br.ErrMsg = "请登录,用户信息为空"
  726. br.Ret = 408
  727. return
  728. }
  729. resp := new(cygx.ScoreOverviewListResp)
  730. keyWord := this.GetString("KeyWord")
  731. city := this.GetString("City")
  732. enterScoreType, _ := this.GetInt("EnterScoreType", 1)
  733. startDate := this.GetString("StartDate")
  734. endDate := this.GetString("EndDate")
  735. //是否导出报表
  736. isExport, _ := this.GetBool("IsExport")
  737. if startDate == "" {
  738. br.Msg = "请选择对应年份与季度"
  739. return
  740. }
  741. var condition string
  742. var pars []interface{}
  743. if endDate != "" {
  744. condition += ` AND start_date <= ? AND end_date >= ? `
  745. pars = append(pars, startDate, endDate)
  746. }
  747. //if enterScoreType == 2 {
  748. //condition += ` AND enter_score_type = 2 `
  749. //}
  750. if keyWord != "" {
  751. condition += ` AND securities_firms_name LIKE '%` + keyWord + `%' `
  752. }
  753. total, err := cygx.GetCygxEnterScoreCount(condition, pars)
  754. if err != nil {
  755. br.Msg = "获取失败"
  756. br.ErrMsg = "获取失败,Err:" + err.Error()
  757. return
  758. }
  759. if total > 0 {
  760. list, err := cygx.GetCygxEnterScoreList(condition, pars, 0, 100)
  761. if err != nil {
  762. br.Msg = "获取失败"
  763. br.ErrMsg = "获取失败,GetCygxEnterScoreListErr:" + err.Error()
  764. return
  765. }
  766. mapenterScoreTypeCompanyIds := make(map[int]bool)
  767. mapenterScoreProportionTotal := make(map[int]float64)
  768. var enterScoreIds []int
  769. mapenterScore := make(map[int]*cygx.CygxEnterScore) //录分详情放在map中
  770. for _, v := range list {
  771. mapenterScore[v.CompanyId] = v
  772. mapenterScoreProportionTotal[v.CompanyId] = v.ProportionTotal
  773. enterScoreIds = append(enterScoreIds, v.EnterScoreId)
  774. if v.EnterScoreType == 2 {
  775. mapenterScoreTypeCompanyIds[v.CompanyId] = true //记录按照百分比录入的公司
  776. }
  777. }
  778. var companyCondition string
  779. var companypars []interface{}
  780. companyCondition += ` AND b.product_name = ? `
  781. companypars = append(companypars, "权益")
  782. companyCondition += ` AND b.status = ? `
  783. companypars = append(companypars, "永续")
  784. //权益申请销售只能看到自己名下的客户的申请
  785. companyIds, err := cygxService.GetAdminLookUserCompanyIdsBySelf(AdminUser)
  786. if err != nil {
  787. br.Msg = "获取失败"
  788. br.ErrMsg = "获取失败,GetAdminLookUserCompanyIds Err:" + err.Error()
  789. return
  790. }
  791. var newcompanyIds []int
  792. lencompanyIds := len(companyIds)
  793. var searchcompanyIds []int
  794. //如果机构搜索做了限制 ,那么公司列表的纵向展示也做限制
  795. if keyWord != "" {
  796. for _, v := range list {
  797. searchcompanyIds = append(searchcompanyIds, v.CompanyId)
  798. }
  799. if lencompanyIds > 0 {
  800. newcompanyIds = utils.IntersectInt(searchcompanyIds, companyIds) //获取销售可见权限,与搜索权限的交集
  801. } else {
  802. newcompanyIds = searchcompanyIds
  803. }
  804. } else {
  805. newcompanyIds = companyIds
  806. }
  807. newlencompanyIds := len(newcompanyIds)
  808. if newlencompanyIds > 0 {
  809. companyCondition += ` AND a.company_id IN (` + utils.GetOrmInReplace(newlencompanyIds) + `)`
  810. companypars = append(companypars, newcompanyIds)
  811. }
  812. if city != "" {
  813. //传过来多个城市的时候的筛选
  814. citySlice := strings.Split(city, ",")
  815. city = strings.Join(citySlice, "','")
  816. city = "'" + city + "'"
  817. companyCondition += ` AND a.city IN (` + city + `) `
  818. }
  819. companyList, err := company.GetCompanyIdListByproductName(companyCondition, companypars)
  820. if err != nil {
  821. br.Msg = "获取失败"
  822. br.ErrMsg = "获取失败,Err:" + err.Error()
  823. return
  824. }
  825. //fmt.Println(enterScoreIds)
  826. listResearcher, err := cygx.GeCygxEnterScoreResearcherListByIds(enterScoreIds, newcompanyIds) //获取所有的研究员
  827. if err != nil {
  828. br.Msg = "获取失败"
  829. br.ErrMsg = "获取失败,GetCygxEnterScorePermissionListByIds Err:" + err.Error()
  830. return
  831. }
  832. mapResearcher := make(map[string][]*cygx.EnterScoreRealNameListResp)
  833. mapResearcherProportion := make(map[string]string)
  834. //mapResearcherPermission := make(map[string][]map[string]string)
  835. var researcherArr []string // 会出现的研究员姓名
  836. mapResearcherbool := make(map[string]bool)
  837. for _, v := range listResearcher {
  838. if v.Proportion == 0 {
  839. continue
  840. }
  841. if !mapResearcherbool[v.RealName] {
  842. researcherArr = append(researcherArr, v.RealName)
  843. mapResearcherbool[v.RealName] = true
  844. }
  845. if enterScoreType == 2 && !mapenterScoreTypeCompanyIds[v.CompanyId] {
  846. mapResearcherProportion[fmt.Sprint(v.RealName, "_", v.CompanyId)] = utils.SubFloatToString(v.Proportion/mapenterScoreProportionTotal[v.CompanyId]*100, 2) //研究员姓名、公司ID,占比值对应关系绑定
  847. } else {
  848. mapResearcherProportion[fmt.Sprint(v.RealName, "_", v.CompanyId)] = fmt.Sprint(v.Proportion) //研究员姓名、公司ID,占比值对应关系绑定
  849. }
  850. }
  851. mapResearcherProportionText := make(map[string][]string)
  852. for _, vC := range companyList {
  853. for _, vR := range researcherArr {
  854. var proportionText string
  855. if mapResearcherProportion[fmt.Sprint(vR, "_", vC.CompanyId)] != "" {
  856. proportionText = mapResearcherProportion[fmt.Sprint(vR, "_", vC.CompanyId)]
  857. } else {
  858. proportionText = "0"
  859. }
  860. if mapenterScoreTypeCompanyIds[vC.CompanyId] || enterScoreType == 2 { //按照百分比展示的拼接 %
  861. proportionText += "%"
  862. }
  863. mapResearcherProportionText[vR] = append(mapResearcherProportionText[vR], proportionText)
  864. }
  865. }
  866. researcherArr = make([]string, 0)
  867. for _, v := range listResearcher {
  868. if v.Proportion == 0 {
  869. continue
  870. }
  871. if utils.InArrayByStr(researcherArr, v.RealName) { //避免重复合并到数组
  872. continue
  873. }
  874. item := new(cygx.EnterScoreRealNameListResp) // 研究员结构体数据
  875. item.RealName = v.RealName
  876. item.ChartPermissionName = v.ChartPermissionName
  877. item.ProportionListText = mapResearcherProportionText[v.RealName]
  878. mapResearcher[v.ChartPermissionName] = append(mapResearcher[v.ChartPermissionName], item)
  879. researcherArr = append(researcherArr, v.RealName)
  880. }
  881. listPermission, err := cygx.GetCygxEnterScorePermissionListByIds(enterScoreIds) // 获取所有的行业名称
  882. if err != nil {
  883. br.Msg = "获取失败"
  884. br.ErrMsg = "获取失败,GetCygxEnterScorePermissionListByIds Err:" + err.Error()
  885. return
  886. }
  887. mapPermissionProportion := make(map[string]string)
  888. for _, v := range listPermission {
  889. if v.Proportion == 0 {
  890. continue
  891. }
  892. //mapPermissionProportion[fmt.Sprint(v.ChartPermissionName, "_", v.CompanyId)] = fmt.Sprint(v.Proportion) //行业名称、公司ID,占比值对应关系绑定
  893. if enterScoreType == 2 && !mapenterScoreTypeCompanyIds[v.CompanyId] {
  894. mapPermissionProportion[fmt.Sprint(v.ChartPermissionName, "_", v.CompanyId)] = utils.SubFloatToString(v.Proportion/mapenterScoreProportionTotal[v.CompanyId]*100, 2) //研究员姓名、公司ID,占比值对应关系绑定
  895. } else {
  896. mapPermissionProportion[fmt.Sprint(v.ChartPermissionName, "_", v.CompanyId)] = fmt.Sprint(v.Proportion) //行业名称、公司ID,占比值对应关系绑定
  897. }
  898. }
  899. var permissionArr []string // 会出现的行业名称
  900. mapPermissionbool := make(map[string]bool)
  901. for _, v := range listPermission {
  902. if mapPermissionbool[v.ChartPermissionName] {
  903. continue
  904. }
  905. permissionArr = append(permissionArr, v.ChartPermissionName)
  906. mapPermissionbool[v.ChartPermissionName] = true
  907. }
  908. mapPermissionProportionText := make(map[string][]string)
  909. for _, vC := range companyList {
  910. for _, vP := range permissionArr {
  911. var proportionText string
  912. if mapPermissionProportion[fmt.Sprint(vP, "_", vC.CompanyId)] != "" {
  913. proportionText = mapPermissionProportion[fmt.Sprint(vP, "_", vC.CompanyId)]
  914. } else {
  915. proportionText = "0"
  916. }
  917. if mapenterScoreTypeCompanyIds[vC.CompanyId] || enterScoreType == 2 { //按照百分比展示的拼接 %
  918. proportionText += "%"
  919. }
  920. mapPermissionProportionText[vP] = append(mapPermissionProportionText[vP], proportionText)
  921. }
  922. }
  923. var itemsP []*cygx.EnterScorePermissionListResp
  924. for _, v := range permissionArr {
  925. itemP := new(cygx.EnterScorePermissionListResp) //行业结构体
  926. itemP.ChartPermissionName = v
  927. itemP.ProportionListText = mapPermissionProportionText[v]
  928. itemP.List = mapResearcher[v]
  929. itemsP = append(itemsP, itemP)
  930. }
  931. listGroup, err := cygx.GeCygxEnterScoreGroupListByIds(enterScoreIds) // 获取所有自定义分组名称
  932. if err != nil {
  933. br.Msg = "获取失败"
  934. br.ErrMsg = "获取失败,GeCygxEnterScoreGroupListByIds Err:" + err.Error()
  935. return
  936. }
  937. mapGroupProportion := make(map[string]string)
  938. var groupArr []string // 会出现的自定义分组名称
  939. mapGroupbool := make(map[string]bool)
  940. for _, v := range listGroup {
  941. if enterScoreType == 2 && !mapenterScoreTypeCompanyIds[v.CompanyId] {
  942. mapGroupProportion[fmt.Sprint(v.GroupName, "_", v.CompanyId)] = utils.SubFloatToString(v.Proportion/mapenterScoreProportionTotal[v.CompanyId]*100, 2) //自定义分组名称、公司ID,占比值对应关系绑定
  943. } else {
  944. mapGroupProportion[fmt.Sprint(v.GroupName, "_", v.CompanyId)] = fmt.Sprint(v.Proportion) //自定义分组名称、公司ID,占比值对应关系绑定
  945. }
  946. //mapGroupProportion[fmt.Sprint(v.GroupName, "_", v.CompanyId)] = fmt.Sprint(v.Proportion) //自定义分组名称、公司ID,占比值对应关系绑定
  947. if mapGroupbool[v.GroupName] {
  948. continue
  949. }
  950. groupArr = append(groupArr, v.GroupName)
  951. mapGroupbool[v.GroupName] = true
  952. }
  953. mapGroupProportionText := make(map[string][]string)
  954. for _, vC := range companyList {
  955. for _, vP := range groupArr {
  956. var proportionText string
  957. if mapGroupProportion[fmt.Sprint(vP, "_", vC.CompanyId)] != "" {
  958. proportionText = mapGroupProportion[fmt.Sprint(vP, "_", vC.CompanyId)]
  959. } else {
  960. proportionText = "0"
  961. }
  962. if mapenterScoreTypeCompanyIds[vC.CompanyId] || enterScoreType == 2 { //按照百分比展示的拼接 %
  963. proportionText += "%"
  964. }
  965. mapGroupProportionText[vP] = append(mapGroupProportionText[vP], proportionText)
  966. }
  967. }
  968. var itemsG []*cygx.EnterScoreGroupListResp
  969. for _, v := range groupArr {
  970. itemG := new(cygx.EnterScoreGroupListResp) //行业结构体
  971. itemG.GroupName = v
  972. itemG.ProportionListText = mapGroupProportionText[v]
  973. itemsG = append(itemsG, itemG)
  974. }
  975. var rankingText []string //排名
  976. var securitiesFirmsNameText []string //券商名称
  977. var proportionTotalText []string //占比
  978. for _, vC := range companyList {
  979. var ranking, securitiesFirmsName, proportionTotal string
  980. item := mapenterScore[vC.CompanyId]
  981. if item != nil {
  982. ranking = item.Ranking
  983. securitiesFirmsName = item.SecuritiesFirmsName
  984. proportionTotal = fmt.Sprint(item.MergeProportion)
  985. }
  986. if mapenterScoreTypeCompanyIds[vC.CompanyId] { //按照百分比展示的拼接 %
  987. proportionTotal += "%"
  988. }
  989. rankingText = append(rankingText, ranking)
  990. securitiesFirmsNameText = append(securitiesFirmsNameText, securitiesFirmsName)
  991. proportionTotalText = append(proportionTotalText, proportionTotal)
  992. }
  993. itemranking := new(cygx.EnterScoreGroupListResp) //排名结构体
  994. itemranking.GroupName = "排名"
  995. itemranking.ProportionListText = rankingText
  996. itemsG = append(itemsG, itemranking)
  997. itemsecuritiesFirmsName := new(cygx.EnterScoreGroupListResp) //券商名称结构体
  998. itemsecuritiesFirmsName.GroupName = "券商名称"
  999. itemsecuritiesFirmsName.ProportionListText = securitiesFirmsNameText
  1000. itemsG = append(itemsG, itemsecuritiesFirmsName)
  1001. itemproportionTotal := new(cygx.EnterScoreGroupListResp) //券商名称结构体
  1002. itemproportionTotal.GroupName = "占比"
  1003. itemproportionTotal.ProportionListText = proportionTotalText
  1004. itemsG = append(itemsG, itemproportionTotal)
  1005. resp.ListPermission = itemsP
  1006. resp.ListGroup = itemsG
  1007. resp.ListCompany = companyList
  1008. } else {
  1009. resp.ListPermission = make([]*cygx.EnterScorePermissionListResp, 0)
  1010. resp.ListGroup = make([]*cygx.EnterScoreGroupListResp, 0)
  1011. resp.ListCompany = make([]*company.CompanyNameAndId, 0)
  1012. }
  1013. //导出excel
  1014. if isExport {
  1015. EnterScoreScoreOverviewExport(this, resp, br)
  1016. return
  1017. }
  1018. br.Ret = 200
  1019. br.Success = true
  1020. br.Msg = "获取成功"
  1021. br.Data = resp
  1022. }
  1023. // EnterScoreScoreOverviewExport 导出Excel
  1024. func EnterScoreScoreOverviewExport(this *EnterScoreController, resp *cygx.ScoreOverviewListResp, br *models.BaseResponse) {
  1025. dir, err := os.Executable()
  1026. exPath := filepath.Dir(dir)
  1027. downLoadnFilePath := exPath + "/" + time.Now().Format(utils.FormatDateTimeUnSpace) + ".xlsx"
  1028. xlsxFile := xlsx.NewFile()
  1029. if err != nil {
  1030. br.Msg = "生成文件失败"
  1031. br.ErrMsg = "生成文件失败"
  1032. return
  1033. }
  1034. style := xlsx.NewStyle()
  1035. alignment := xlsx.Alignment{
  1036. Horizontal: "center",
  1037. Vertical: "center",
  1038. WrapText: true,
  1039. }
  1040. style.Alignment = alignment
  1041. style.ApplyAlignment = true
  1042. sheel, err := xlsxFile.AddSheet("评分总览")
  1043. if err != nil {
  1044. br.Msg = "新增Sheet失败"
  1045. br.ErrMsg = "新增Sheet失败,Err:" + err.Error()
  1046. return
  1047. }
  1048. sheel.SetColWidth(0, 0, 30)
  1049. sheel.SetColWidth(1, 1, 15)
  1050. sheel.SetColWidth(2, 2, 15)
  1051. sheel.SetColWidth(3, 3, 18)
  1052. companyList := resp.ListCompany
  1053. listPermission := resp.ListPermission
  1054. listGroup := resp.ListGroup
  1055. titleRow := sheel.AddRow()
  1056. cellNull := titleRow.AddCell()
  1057. cellNull.SetStyle(style)
  1058. cellNull.SetValue("")
  1059. for _, v := range companyList { //第一行公司
  1060. cellA := titleRow.AddCell()
  1061. cellA.SetStyle(style)
  1062. cellA.SetValue(v.CompanyName)
  1063. }
  1064. for _, v := range listPermission { // 行业排序名称
  1065. dataRow := sheel.AddRow()
  1066. dataRow.SetHeight(20)
  1067. cellA := dataRow.AddCell()
  1068. cellA.SetStyle(style)
  1069. cellA.SetValue(v.ChartPermissionName)
  1070. for _, vCp := range v.ProportionListText { // 行业对应的占比值
  1071. cellP := dataRow.AddCell()
  1072. cellP.SetStyle(style)
  1073. cellP.SetValue(vCp)
  1074. }
  1075. for _, vUser := range v.List { // 研究员姓名
  1076. dataRowName := sheel.AddRow()
  1077. dataRowName.SetHeight(20)
  1078. cellName := dataRowName.AddCell()
  1079. cellName.SetStyle(style)
  1080. cellName.SetValue(vUser.RealName)
  1081. for _, vUp := range vUser.ProportionListText { //研究员占比值
  1082. cellP := dataRowName.AddCell()
  1083. cellP.SetStyle(style)
  1084. cellP.SetValue(vUp)
  1085. }
  1086. }
  1087. }
  1088. for _, v := range listGroup { // 自定义名称
  1089. dataRow := sheel.AddRow()
  1090. dataRow.SetHeight(20)
  1091. cellA := dataRow.AddCell()
  1092. cellA.SetStyle(style)
  1093. cellA.SetValue(v.GroupName)
  1094. for _, vG := range v.ProportionListText { // 自定义名称所对应的值
  1095. cellP := dataRow.AddCell()
  1096. cellP.SetStyle(style)
  1097. cellP.SetValue(vG)
  1098. }
  1099. }
  1100. err = xlsxFile.Save(downLoadnFilePath)
  1101. if err != nil {
  1102. br.Msg = "保存文件失败"
  1103. br.ErrMsg = "保存文件失败"
  1104. return
  1105. }
  1106. randStr := time.Now().Format(utils.FormatDateTimeUnSpace)
  1107. downloadFileName := "评分总览" + randStr + ".xlsx"
  1108. this.Ctx.Output.Download(downLoadnFilePath, downloadFileName)
  1109. defer func() {
  1110. os.Remove(downLoadnFilePath)
  1111. }()
  1112. br.Ret = 200
  1113. br.Success = true
  1114. br.Msg = "导出成功"
  1115. }
  1116. // @Title 排名总览
  1117. // @Description 排名总览接口
  1118. // @Param AdminId query string true "销售id,多个用英文逗号隔开,空字符串为全部"
  1119. // @Param City query string true "城市"
  1120. // @Param IsExport query bool false "是否导出excel,默认是false"
  1121. // @Success Ret=200 {object} cygx.CompanyNameAndIdListResp
  1122. // @router /enterScore/rankingOverview [get]
  1123. func (this *EnterScoreController) EnterScoreRankingOverview() {
  1124. br := new(models.BaseResponse).Init()
  1125. defer func() {
  1126. this.Data["json"] = br
  1127. this.ServeJSON()
  1128. }()
  1129. AdminUser := this.SysUser
  1130. if AdminUser == nil {
  1131. br.Msg = "请登录"
  1132. br.ErrMsg = "请登录,用户信息为空"
  1133. br.Ret = 408
  1134. return
  1135. }
  1136. resp := new(cygx.RankingOverviewListResp)
  1137. city := this.GetString("City")
  1138. adminId := this.GetString("AdminId")
  1139. //是否导出报表
  1140. isExport, _ := this.GetBool("IsExport")
  1141. var companyCondition string
  1142. var companypars []interface{}
  1143. companyCondition += ` AND b.product_name = ? `
  1144. companypars = append(companypars, "权益")
  1145. companyCondition += ` AND b.status = ? `
  1146. companypars = append(companypars, "永续")
  1147. if adminId != "" {
  1148. companyCondition += ` AND b.seller_id IN (` + adminId + `) `
  1149. }
  1150. if city != "" {
  1151. //传过来多个城市的时候的筛选
  1152. citySlice := strings.Split(city, ",")
  1153. city = strings.Join(citySlice, "','")
  1154. city = "'" + city + "'"
  1155. companyCondition += ` AND a.city IN (` + city + `) `
  1156. }
  1157. //权益申请销售只能看到自己名下的客户的申请
  1158. companyIds, err := cygxService.GetAdminLookUserCompanyIdsBySelf(AdminUser)
  1159. if err != nil {
  1160. br.Msg = "获取失败"
  1161. br.ErrMsg = "获取失败,GetAdminLookUserCompanyIdsBySelf Err:" + err.Error()
  1162. return
  1163. }
  1164. lencompanyIds := len(companyIds)
  1165. if lencompanyIds > 0 {
  1166. companyCondition += ` AND a.company_id IN (` + utils.GetOrmInReplace(lencompanyIds) + `)`
  1167. companypars = append(companypars, companyIds)
  1168. }
  1169. companyList, err := company.GetCompanyIdListByproductName(companyCondition, companypars)
  1170. if err != nil {
  1171. br.Msg = "获取失败"
  1172. br.ErrMsg = "获取失败,Err:" + err.Error()
  1173. return
  1174. }
  1175. var condition string
  1176. var pars []interface{}
  1177. total, err := cygx.GetCygxEnterScoreCount(condition, pars)
  1178. if err != nil {
  1179. br.Msg = "获取失败"
  1180. br.ErrMsg = "获取失败,Err:" + err.Error()
  1181. return
  1182. }
  1183. dataMd := []string{"10-01", "07-01", "04-01", "01-01"}
  1184. thisYear := time.Now().Year()
  1185. startYear := 2018 // 自定义开始时间
  1186. var quarterDate []string
  1187. for _, v := range dataMd {
  1188. dateTimeStr := fmt.Sprint(thisYear, "-", v)
  1189. dateTime, err := time.Parse("2006-01-02", dateTimeStr)
  1190. if err != nil {
  1191. br.Msg = "获取失败"
  1192. br.ErrMsg = "获取失败,Err:" + err.Error()
  1193. return
  1194. }
  1195. if dateTime.After(time.Now()) {
  1196. continue
  1197. }
  1198. quarterDate = append(quarterDate, dateTimeStr)
  1199. }
  1200. for i := thisYear - 1; i >= startYear; i-- {
  1201. for _, v := range dataMd {
  1202. dateTimeStr := fmt.Sprint(i, "-", v)
  1203. quarterDate = append(quarterDate, dateTimeStr)
  1204. }
  1205. }
  1206. var itemsQuarter []*cygx.QuarterDateListResp
  1207. if total > 0 {
  1208. list, err := cygx.GetCygxEnterScoreList(condition, pars, 0, 9999)
  1209. if err != nil {
  1210. br.Msg = "获取失败"
  1211. br.ErrMsg = "获取失败,GetCygxEnterScoreList Err:" + err.Error()
  1212. return
  1213. }
  1214. mapQuarter := make(map[string]string)
  1215. for _, v := range list {
  1216. silicequarter := strings.Split(v.QuarterDate, ",")
  1217. for _, vQ := range silicequarter {
  1218. mapQuarter[fmt.Sprint(vQ, "_", v.CompanyId)] = v.Ranking //季度时间、公司ID,排名对应关系绑定
  1219. }
  1220. }
  1221. mapRankingText := make(map[string][]string)
  1222. for _, vC := range companyList {
  1223. for _, vQ := range quarterDate {
  1224. var ranking string
  1225. ranking = mapQuarter[fmt.Sprint(vQ, "_", vC.CompanyId)]
  1226. mapRankingText[vQ] = append(mapRankingText[vQ], ranking)
  1227. }
  1228. }
  1229. for _, v := range quarterDate {
  1230. itemQuarter := new(cygx.QuarterDateListResp)
  1231. quarter := v
  1232. //时间后面的月日替换成季度 Q几
  1233. quarter = strings.Replace(quarter, "-10-01", "Q4", -1)
  1234. quarter = strings.Replace(quarter, "-07-01", "Q3", -1)
  1235. quarter = strings.Replace(quarter, "-04-01", "Q2", -1)
  1236. quarter = strings.Replace(quarter, "-01-01", "Q1", -1)
  1237. itemQuarter.Quarter = quarter
  1238. itemQuarter.ProportionListText = mapRankingText[v]
  1239. itemsQuarter = append(itemsQuarter, itemQuarter)
  1240. }
  1241. }
  1242. resp.ListCompany = companyList
  1243. resp.ListQuarterDate = itemsQuarter
  1244. //导出excel
  1245. if isExport {
  1246. RankingOverviewExport(this, resp, br)
  1247. return
  1248. }
  1249. br.Ret = 200
  1250. br.Success = true
  1251. br.Msg = "获取成功"
  1252. br.Data = resp
  1253. }
  1254. // RankingOverviewExport 导出Excel
  1255. func RankingOverviewExport(this *EnterScoreController, resp *cygx.RankingOverviewListResp, br *models.BaseResponse) {
  1256. dir, err := os.Executable()
  1257. exPath := filepath.Dir(dir)
  1258. downLoadnFilePath := exPath + "/" + time.Now().Format(utils.FormatDateTimeUnSpace) + ".xlsx"
  1259. xlsxFile := xlsx.NewFile()
  1260. if err != nil {
  1261. br.Msg = "生成文件失败"
  1262. br.ErrMsg = "生成文件失败"
  1263. return
  1264. }
  1265. style := xlsx.NewStyle()
  1266. alignment := xlsx.Alignment{
  1267. Horizontal: "center",
  1268. Vertical: "center",
  1269. WrapText: true,
  1270. }
  1271. style.Alignment = alignment
  1272. style.ApplyAlignment = true
  1273. sheel, err := xlsxFile.AddSheet("排名总览")
  1274. if err != nil {
  1275. br.Msg = "新增Sheet失败"
  1276. br.ErrMsg = "新增Sheet失败,Err:" + err.Error()
  1277. return
  1278. }
  1279. sheel.SetColWidth(0, 0, 30)
  1280. sheel.SetColWidth(1, 1, 15)
  1281. sheel.SetColWidth(2, 2, 15)
  1282. sheel.SetColWidth(3, 3, 18)
  1283. companyList := resp.ListCompany
  1284. listQuarterDate := resp.ListQuarterDate
  1285. titleRow := sheel.AddRow()
  1286. cellNull := titleRow.AddCell()
  1287. cellNull.SetStyle(style)
  1288. cellNull.SetValue("")
  1289. for _, v := range companyList { //第一行公司
  1290. cellA := titleRow.AddCell()
  1291. cellA.SetStyle(style)
  1292. cellA.SetValue(v.CompanyName)
  1293. }
  1294. for _, v := range listQuarterDate { // 季度排序
  1295. dataRow := sheel.AddRow()
  1296. dataRow.SetHeight(20)
  1297. cellA := dataRow.AddCell()
  1298. cellA.SetStyle(style)
  1299. cellA.SetValue(v.Quarter)
  1300. for _, vCp := range v.ProportionListText { // 行业对应的占比值
  1301. cellP := dataRow.AddCell()
  1302. cellP.SetStyle(style)
  1303. cellP.SetValue(vCp)
  1304. }
  1305. }
  1306. err = xlsxFile.Save(downLoadnFilePath)
  1307. if err != nil {
  1308. br.Msg = "保存文件失败"
  1309. br.ErrMsg = "保存文件失败"
  1310. return
  1311. }
  1312. randStr := time.Now().Format(utils.FormatDateTimeUnSpace)
  1313. downloadFileName := "排名总览" + randStr + ".xlsx"
  1314. this.Ctx.Output.Download(downLoadnFilePath, downloadFileName)
  1315. defer func() {
  1316. os.Remove(downLoadnFilePath)
  1317. }()
  1318. br.Ret = 200
  1319. br.Success = true
  1320. br.Msg = "导出成功"
  1321. }