enter_score.go 49 KB

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