1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585 |
- package cygx
- import (
- "encoding/json"
- "fmt"
- "github.com/rdlucklib/rdluck_tools/paging"
- "github.com/tealeg/xlsx"
- "hongze/hz_crm_api/controllers"
- "hongze/hz_crm_api/models"
- "hongze/hz_crm_api/models/company"
- "hongze/hz_crm_api/models/cygx"
- "hongze/hz_crm_api/models/system"
- cygxService "hongze/hz_crm_api/services/cygx"
- "hongze/hz_crm_api/utils"
- "os"
- "path/filepath"
- "strings"
- "time"
- )
- // X类客户录分模块
- type EnterScoreController struct {
- controllers.BaseAuthController
- }
- // @Title X试用类客户检索
- // @Description X试用类客户检索接口
- // @Param KeyWord query string true "搜索关键词"
- // @Success 200 {object} company.CompanyNameAndIdListResp
- // @router /enterScore/company/searchlist [get]
- func (this *EnterScoreController) CompanySearchList() {
- br := new(models.BaseResponse).Init()
- defer func() {
- this.Data["json"] = br
- this.ServeJSON()
- }()
- sysUser := this.SysUser
- if sysUser == nil {
- br.Msg = "请登录"
- br.ErrMsg = "请登录,SysUser Is Empty"
- br.Ret = 408
- return
- }
- keyWord := this.GetString("KeyWord")
- keyWord = strings.Trim(keyWord, " ")
- keyWord = strings.Replace(keyWord, "'", "", -1)
- resp := new(company.CompanyNameAndIdListResp)
- var companyCondition string
- var companypars []interface{}
- var listResp []*company.CompanyNameAndId
- companyCondition += ` AND b.product_name = ? `
- companypars = append(companypars, "权益")
- companyCondition += ` AND b.status = ? `
- companypars = append(companypars, "永续")
- if keyWord != "" {
- companyCondition += ` AND a.company_name LIKE '%` + keyWord + `%' `
- }
- //权益申请销售只能看到自己名下的客户的申请
- companyIds, err := cygxService.GetAdminLookUserCompanyIdsByResearcher(sysUser)
- if err != nil {
- br.Msg = "获取失败"
- br.ErrMsg = "获取失败,GetAdminLookUserCompanyIds Err:" + err.Error()
- return
- }
- lencompanyIds := len(companyIds)
- if lencompanyIds > 0 {
- companyCondition += ` AND a.company_id IN (` + utils.GetOrmInReplace(lencompanyIds) + `)`
- companypars = append(companypars, companyIds)
- }
- companyList, err := company.GetCompanyIdListByproductName(companyCondition, companypars)
- if err != nil {
- br.Msg = "获取失败"
- br.ErrMsg = "获取失败,Err:" + err.Error()
- return
- }
- if len(companyList) == 0 {
- listResp = make([]*company.CompanyNameAndId, 0)
- } else {
- listResp = companyList
- }
- resp.List = listResp
- br.Ret = 200
- br.Success = true
- br.Msg = "获取成功"
- br.Data = resp
- }
- // @Title 详情
- // @Description 获取详情接口
- // @Param EnterScoreId query int true "录分ID"
- // @Success Ret=200 {object} cygx.CygxEnterScoreDetailResp
- // @router /enterScore/detail [get]
- func (this *EnterScoreController) EnterScoreDetail() {
- br := new(models.BaseResponse).Init()
- defer func() {
- this.Data["json"] = br
- this.ServeJSON()
- }()
- AdminUser := this.SysUser
- if AdminUser == nil {
- br.Msg = "请登录"
- br.ErrMsg = "请登录,用户信息为空"
- br.Ret = 408
- return
- }
- enterScoreId, _ := this.GetInt("EnterScoreId")
- resp := new(cygx.CygxEnterScoreDetailResp)
- var itemslistPermission []*cygx.EnterScorePermissionListResp // 权益行业
- var itemsFicclistPermission []*cygx.EnterScorePermissionListResp // FICC行业
- mapRaiUser := make(map[string][]*cygx.EnterScoreRealNameListResp) //权益研究员
- mapFiccUser := make(map[string][]*cygx.EnterScoreRealNameListResp) // FICC研究员
- var itemsGroup []*cygx.EnterScoreGroupListResp //自定义分组
- if enterScoreId == 0 {
- //权益研究员
- sysUserList, err := cygx.GetAskEmailList()
- if err != nil {
- br.Msg = "获取失败"
- br.ErrMsg = "获取失败,GetAskEmailList Err: " + err.Error()
- return
- }
- for _, v := range sysUserList {
- item := new(cygx.EnterScoreRealNameListResp)
- item.RealName = v.Name
- item.ChartPermissionName = v.ChartPermissionName
- mapRaiUser[v.ChartPermissionName] = append(mapRaiUser[v.ChartPermissionName], item)
- }
- listPermission, err := cygx.GetChartPermissionAll()
- if err != nil {
- br.Msg = "获取信息失败"
- br.ErrMsg = "获取品种信息失败,Err:" + err.Error()
- return
- }
- permissionNameArr := []string{"医药", "消费", "科技", "智造", "策略", "固收"}
- for _, v := range listPermission {
- if !utils.InArrayByStr(permissionNameArr, v.PermissionName) {
- continue
- }
- item := new(cygx.EnterScorePermissionListResp)
- item.ChartPermissionName = v.PermissionName
- if len(mapRaiUser[v.PermissionName]) == 0 {
- item.List = make([]*cygx.EnterScoreRealNameListResp, 0)
- } else {
- item.List = mapRaiUser[v.PermissionName]
- }
- itemslistPermission = append(itemslistPermission, item)
- }
- resp.EnterScoreObj.ListRai = itemslistPermission
- //ficc 研究员
- ficcUserList, err := system.GetFiccEnterScoreAdmin()
- if err != nil {
- br.Msg = "获取失败"
- br.ErrMsg = "获取失败,GetFiccEnterScoreAdmin Err: " + err.Error()
- return
- }
- for _, v := range ficcUserList {
- item := new(cygx.EnterScoreRealNameListResp)
- item.RealName = v.RealName
- item.ChartPermissionName = v.GroupName
- mapFiccUser[v.GroupName] = append(mapFiccUser[v.GroupName], item)
- }
- permissionFiccNameArr := []string{"宏观组", "建材组", "有色组", "能化组", "海外组"}
- for _, v := range permissionFiccNameArr {
- item := new(cygx.EnterScorePermissionListResp)
- item.ChartPermissionName = v
- if len(mapFiccUser[v]) == 0 {
- item.List = make([]*cygx.EnterScoreRealNameListResp, 0)
- } else {
- item.List = mapFiccUser[v]
- }
- itemsFicclistPermission = append(itemsFicclistPermission, item)
- }
- resp.EnterScoreObj.ListFicc = itemsFicclistPermission
- groupNameArr := []string{"销售分", "专题分", "专家分", "云图大拓", "艾摩宏观"}
- for _, v := range groupNameArr {
- item := new(cygx.EnterScoreGroupListResp)
- item.GroupName = v
- itemsGroup = append(itemsGroup, item)
- }
- resp.EnterScoreObj.ListGroup = itemsGroup
- resp.PercentageObj = resp.EnterScoreObj
- resp.EnterScoreType = 1
- resp.Quarter = make([]string, 0)
- } else {
- //初始化数据,方便前端渲染
- var itemslistPermissionInit []*cygx.EnterScorePermissionListResp // 权益行业
- var itemsFicclistPermissionInit []*cygx.EnterScorePermissionListResp // FICC行业
- var itemsGroupInit []*cygx.EnterScoreGroupListResp //自定义分组
- mapRaiUserInit := make(map[string][]*cygx.EnterScoreRealNameListResp) //权益研究员
- mapFiccUserInit := make(map[string][]*cygx.EnterScoreRealNameListResp) // FICC研究员
- enterScoreDetail, err := cygx.GetCygxEnterScoreInfoById(enterScoreId)
- if err != nil {
- br.Msg = "获取失败"
- br.ErrMsg = "获取失败,GetCygxEnterScoreInfoById Err: " + err.Error()
- return
- }
- resp.EnterScoreId = enterScoreDetail.EnterScoreId
- resp.CompanyId = enterScoreDetail.CompanyId
- resp.CompanyName = enterScoreDetail.CompanyName
- resp.StartDate = enterScoreDetail.StartDate
- resp.EndDate = enterScoreDetail.EndDate
- resp.Quarter = strings.Split(enterScoreDetail.Quarter, ",")
- resp.EnterScoreType = enterScoreDetail.EnterScoreType
- resp.Ranking = enterScoreDetail.Ranking
- resp.IsMergeScoring = enterScoreDetail.IsMergeScoring
- resp.SecuritiesFirmsName = enterScoreDetail.SecuritiesFirmsName
- resp.MergeProportion = enterScoreDetail.MergeProportion
- resp.ProportionTotal = enterScoreDetail.ProportionTotal
- resp.RaiProportionTotal = enterScoreDetail.RaiProportionTotal
- resp.FiccProportionTotal = enterScoreDetail.FiccProportionTotal
- listResearcher, err := cygx.GeCygxEnterScoreResearcherListById(enterScoreId)
- if err != nil {
- br.Msg = "获取失败"
- br.ErrMsg = "获取失败,GeCygxEnterScoreResearcherListById Err: " + err.Error()
- return
- }
- for _, v := range listResearcher {
- item := new(cygx.EnterScoreRealNameListResp)
- item.RealName = v.RealName
- item.ChartPermissionName = v.ChartPermissionName
- item.Proportion = v.Proportion
- if v.ProductId == utils.COMPANY_PRODUCT_RAI_ID {
- mapRaiUser[v.ChartPermissionName] = append(mapRaiUser[v.ChartPermissionName], item)
- } else {
- mapFiccUser[v.ChartPermissionName] = append(mapFiccUser[v.ChartPermissionName], item)
- }
- }
- for _, v := range listResearcher {
- item := new(cygx.EnterScoreRealNameListResp)
- item.RealName = v.RealName
- item.ChartPermissionName = v.ChartPermissionName
- if v.ProductId == utils.COMPANY_PRODUCT_RAI_ID {
- mapRaiUserInit[v.ChartPermissionName] = append(mapRaiUserInit[v.ChartPermissionName], item)
- } else {
- mapFiccUserInit[v.ChartPermissionName] = append(mapFiccUserInit[v.ChartPermissionName], item)
- }
- }
- listPermission, err := cygx.GetCygxEnterScorePermissionListById(enterScoreId)
- if err != nil {
- br.Msg = "获取失败"
- br.ErrMsg = "获取失败,GetCygxEnterScorePermissionListById Err: " + err.Error()
- return
- }
- for _, v := range listPermission {
- item := new(cygx.EnterScorePermissionListResp)
- item.ChartPermissionName = v.ChartPermissionName
- item.Proportion = v.Proportion
- if v.ProductId == utils.COMPANY_PRODUCT_RAI_ID {
- item.List = mapRaiUser[v.ChartPermissionName]
- itemslistPermission = append(itemslistPermission, item)
- } else {
- item.List = mapFiccUser[v.ChartPermissionName]
- itemsFicclistPermission = append(itemsFicclistPermission, item)
- }
- }
- for _, v := range listPermission {
- item := new(cygx.EnterScorePermissionListResp)
- item.ChartPermissionName = v.ChartPermissionName
- if v.ProductId == utils.COMPANY_PRODUCT_RAI_ID {
- item.List = mapRaiUserInit[v.ChartPermissionName]
- itemslistPermissionInit = append(itemslistPermissionInit, item)
- } else {
- item.List = mapFiccUserInit[v.ChartPermissionName]
- itemsFicclistPermissionInit = append(itemsFicclistPermissionInit, item)
- }
- }
- listGroup, err := cygx.GeCygxEnterScoreGroupListById(enterScoreId)
- if err != nil {
- br.Msg = "获取失败"
- br.ErrMsg = "获取失败,GeCygxEnterScoreGroupListById Err: " + err.Error()
- return
- }
- for _, v := range listGroup {
- item := new(cygx.EnterScoreGroupListResp)
- item.GroupName = v.GroupName
- item.Proportion = v.Proportion
- itemsGroup = append(itemsGroup, item)
- }
- for _, v := range listGroup {
- item := new(cygx.EnterScoreGroupListResp)
- item.GroupName = v.GroupName
- itemsGroupInit = append(itemsGroupInit, item)
- }
- if enterScoreDetail.EnterScoreType == 1 {
- resp.EnterScoreObj.ListGroup = itemsGroup
- resp.EnterScoreObj.ListRai = itemslistPermission
- resp.EnterScoreObj.ListFicc = itemsFicclistPermission
- resp.PercentageObj.ListGroup = itemsGroupInit
- resp.PercentageObj.ListRai = itemslistPermissionInit
- resp.PercentageObj.ListFicc = itemsFicclistPermissionInit
- } else {
- resp.PercentageObj.ListGroup = itemsGroup
- resp.PercentageObj.ListRai = itemslistPermission
- resp.PercentageObj.ListFicc = itemsFicclistPermission
- resp.EnterScoreObj.ListGroup = itemsGroupInit
- resp.EnterScoreObj.ListRai = itemslistPermissionInit
- resp.EnterScoreObj.ListFicc = itemsFicclistPermissionInit
- }
- }
- br.Ret = 200
- br.Success = true
- br.Msg = "获取成功"
- br.Data = resp
- }
- // @Title 更新录分
- // @Description 更新录分接口
- // @Param request body cygx.UpdateEnterScoreReq true "type json string"
- // @Success 200 {object} "保存成功"
- // @router /enterScore/update [post]
- func (this *EnterScoreController) EnterScoreUpdate() {
- br := new(models.BaseResponse).Init()
- defer func() {
- this.Data["json"] = br
- this.ServeJSON()
- }()
- sysUser := this.SysUser
- if sysUser == nil {
- br.Msg = "请登录"
- br.ErrMsg = "请登录,SysUser Is Empty"
- br.Ret = 408
- return
- }
- var req cygx.UpdateEnterScoreReq
- err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
- if err != nil {
- br.Msg = "参数解析异常!"
- br.ErrMsg = "参数解析失败,Err:" + err.Error()
- return
- }
- enterScoreId := req.EnterScoreId
- companyId := req.CompanyId
- if companyId == 0 {
- br.Msg = "参数错误"
- br.ErrMsg = "参数错误,companyId不可为空"
- return
- }
- startDate := req.StartDate
- endDate := req.EndDate
- if startDate == "" || endDate == "" {
- br.Msg = "请选择季度信息"
- return
- }
- var condition string
- var pars []interface{}
- condition += " AND company_id =? AND end_date BETWEEN ? AND ? "
- pars = append(pars, companyId, startDate, endDate)
- if enterScoreId > 0 {
- condition += " AND enter_score_id != ? "
- pars = append(pars, enterScoreId)
- }
- total, err := cygx.GetCygxEnterScoreCount(condition, pars)
- if err != nil {
- br.Msg = "获取失败"
- br.ErrMsg = "获取失败,Err:" + err.Error()
- return
- }
- if total > 0 {
- listEnterScore, err := cygx.GetCygxEnterScoreList(condition, pars, 0, 1)
- if err != nil {
- br.Msg = "获取失败"
- br.ErrMsg = "获取失败,Err:" + err.Error()
- return
- }
- var startDateEnter, endDateEnter string
- for _, v := range listEnterScore {
- startDateEnter = v.StartDate
- endDateEnter = v.EndDate
- }
- quarter, err := utils.GetQuarterStrStartDatesInRangeHaveYear(startDateEnter, endDateEnter)
- if err != nil {
- br.Msg = "操作失败"
- br.ErrMsg = "获取已录过分的季度失败,Err:" + err.Error()
- return
- }
- br.Msg = quarter + "季度已录过分,请核实"
- return
- }
- companyProduct, err := company.GetCompanyProductByCompanyIdAndProductId(companyId, utils.COMPANY_PRODUCT_RAI_ID)
- if err != nil {
- br.Msg = "查询客户产品信息失败"
- br.ErrMsg = "查询客户产品信息失败,Err:" + err.Error()
- return
- }
- item := new(cygx.CygxEnterScore)
- item.EnterScoreId = enterScoreId
- item.CompanyId = companyId
- item.CompanyName = req.CompanyName
- item.StartDate = req.StartDate
- item.EndDate = req.EndDate
- item.Quarter = strings.Join(req.Quarter, ",")
- quarterDate, err := utils.GetQuarterStartDatesInRange(req.StartDate, req.EndDate)
- if err != nil {
- br.Msg = "操作失败"
- br.ErrMsg = "获取对应季度信息失败,Err:" + err.Error()
- return
- }
- item.QuarterDate = strings.Join(quarterDate, ",")
- item.EnterScoreType = req.EnterScoreType
- item.Ranking = req.Ranking
- item.IsMergeScoring = req.IsMergeScoring
- item.SecuritiesFirmsName = req.SecuritiesFirmsName
- item.MergeProportion = req.MergeProportion
- item.RaiProportionTotal = req.RaiProportionTotal
- item.FiccProportionTotal = req.FiccProportionTotal
- item.ProportionTotal = req.ProportionTotal
- item.SellerId = companyProduct.SellerId
- item.SellerName = companyProduct.SellerName
- item.AdminId = sysUser.AdminId
- item.AdminName = sysUser.RealName
- item.CreateTime = time.Now()
- item.ModifyTime = time.Now()
- var itemsPermission []*cygx.CygxEnterScorePermission //行业数组
- var itemsResearcher []*cygx.CygxEnterScoreResearcher //研究员数组
- var itemsGroup []*cygx.CygxEnterScoreGroup //自定义分组
- listRai := req.ListRai
- listFicc := req.ListFicc
- listGroup := req.ListGroup
- for _, v := range listRai { // 权益数据
- itemPermission := new(cygx.CygxEnterScorePermission)
- itemPermission.ChartPermissionName = v.ChartPermissionName
- itemPermission.Proportion = v.Proportion
- itemPermission.EnterScoreId = v.EnterScoreId
- itemPermission.CompanyId = companyId
- itemPermission.AdminId = sysUser.AdminId
- itemPermission.AdminName = sysUser.RealName
- itemPermission.ProductId = utils.COMPANY_PRODUCT_RAI_ID
- itemPermission.CreateTime = time.Now()
- itemPermission.ModifyTime = time.Now()
- itemsPermission = append(itemsPermission, itemPermission)
- for _, vResearcher := range v.List {
- itemResearcher := new(cygx.CygxEnterScoreResearcher)
- itemResearcher.ChartPermissionName = v.ChartPermissionName
- itemResearcher.EnterScoreId = v.EnterScoreId
- itemResearcher.CompanyId = companyId
- itemResearcher.RealName = vResearcher.RealName
- itemResearcher.Proportion = vResearcher.Proportion
- itemResearcher.AdminId = sysUser.AdminId
- itemResearcher.AdminName = sysUser.RealName
- itemResearcher.ProductId = utils.COMPANY_PRODUCT_RAI_ID
- itemResearcher.CreateTime = time.Now()
- itemResearcher.ModifyTime = time.Now()
- itemsResearcher = append(itemsResearcher, itemResearcher)
- }
- }
- for _, v := range listFicc { // FICC数据
- itemPermission := new(cygx.CygxEnterScorePermission)
- itemPermission.ChartPermissionName = v.ChartPermissionName
- itemPermission.Proportion = v.Proportion
- itemPermission.EnterScoreId = v.EnterScoreId
- itemPermission.CompanyId = companyId
- itemPermission.AdminId = sysUser.AdminId
- itemPermission.AdminName = sysUser.RealName
- itemPermission.ProductId = utils.COMPANY_PRODUCT_FICC_ID
- itemPermission.CreateTime = time.Now()
- itemPermission.ModifyTime = time.Now()
- itemsPermission = append(itemsPermission, itemPermission)
- for _, vResearcher := range v.List {
- itemResearcher := new(cygx.CygxEnterScoreResearcher)
- itemResearcher.ChartPermissionName = v.ChartPermissionName
- itemResearcher.EnterScoreId = v.EnterScoreId
- itemResearcher.CompanyId = companyId
- itemResearcher.RealName = vResearcher.RealName
- itemResearcher.Proportion = vResearcher.Proportion
- itemResearcher.AdminId = sysUser.AdminId
- itemResearcher.AdminName = sysUser.RealName
- itemResearcher.ProductId = utils.COMPANY_PRODUCT_FICC_ID
- itemResearcher.CreateTime = time.Now()
- itemResearcher.ModifyTime = time.Now()
- itemsResearcher = append(itemsResearcher, itemResearcher)
- }
- }
- for _, v := range listGroup {
- itemGroup := new(cygx.CygxEnterScoreGroup)
- itemGroup.GroupName = v.GroupName
- itemGroup.Proportion = v.Proportion
- itemGroup.CompanyId = companyId
- itemGroup.AdminId = sysUser.AdminId
- itemGroup.AdminName = sysUser.RealName
- itemGroup.CreateTime = time.Now()
- itemGroup.ModifyTime = time.Now()
- itemsGroup = append(itemsGroup, itemGroup)
- }
- if enterScoreId == 0 { // 新增
- err = cygx.AddCygxEnterScore(item, itemsPermission, itemsResearcher, itemsGroup)
- } else { // 修改
- item.EnterScoreId = enterScoreId
- err = cygx.UpdateCygxEnterScore(item, itemsPermission, itemsResearcher, itemsGroup)
- }
- if err != nil {
- br.Msg = "操作失败"
- br.ErrMsg = "操作失败Err:" + err.Error()
- return
- }
- go cygxService.UpdateCygxallocationCompanyContractByEnterScore(itemsPermission, itemsResearcher, startDate, endDate, companyId, sysUser) //权益永续客户录分自动派点
- br.Ret = 200
- br.Success = true
- br.IsAddLog = true
- br.Msg = "操作成功"
- }
- // @Title 列表
- // @Description 列表接口
- // @Param PageSize query int true "每页数据条数"
- // @Param CurrentIndex query int true "当前页页码,从1开始"
- // @Param KeyWord query string true "搜索关键词"
- // @Param CompanyName query string true "客户名称"
- // @Param AdminId query string true "销售id,多个用英文逗号隔开,空字符串为全部"
- // @Param IsExport query bool false "是否导出excel,默认是false"
- // @Success 200 {object} cygx.GetCygxEnterScoreListRep
- // @router /enterScore/list [get]
- func (this *EnterScoreController) EnterScoreList() {
- br := new(models.BaseResponse).Init()
- defer func() {
- this.Data["json"] = br
- this.ServeJSON()
- }()
- sysUser := this.SysUser
- if sysUser == nil {
- br.Msg = "请登录"
- br.ErrMsg = "请登录,SysUser Is Empty"
- br.Ret = 408
- return
- }
- pageSize, _ := this.GetInt("PageSize")
- currentIndex, _ := this.GetInt("CurrentIndex")
- keyWord := this.GetString("KeyWord")
- adminId := this.GetString("AdminId")
- //是否导出报表
- isExport, _ := this.GetBool("IsExport")
- var startSize int
- if pageSize <= 0 {
- pageSize = utils.PageSize20
- }
- if currentIndex <= 0 {
- currentIndex = 1
- }
- fmt.Println(isExport)
- startSize = utils.StartIndex(currentIndex, pageSize)
- if isExport {
- startSize = 0
- pageSize = 9999
- }
- var condition string
- var pars []interface{}
- //如果不是权益管理员和admin、财务,就做可见权限限制
- if sysUser.RoleTypeCode != utils.ROLE_TYPE_CODE_RAI_ADMIN && sysUser.RoleTypeCode != utils.ROLE_TYPE_CODE_ADMIN && sysUser.RoleTypeCode != utils.ROLE_TYPE_CODE_RAI_RESEARCHR && sysUser.RoleTypeCode != utils.ROLE_TYPE_CODE_FINANCE {
- var conditionAdmin string
- var parsAdmin []interface{}
- conditionAdmin = " AND product_id = 2 AND status = '永续' AND seller_id = ? "
- parsAdmin = append(parsAdmin, sysUser.AdminId)
- listProduct, err := company.GetCompanyProductList(conditionAdmin, parsAdmin)
- if err != nil {
- br.Msg = "获取失败"
- br.ErrMsg = "获取失败,Err:" + err.Error()
- return
- }
- var companyIds []int
- for _, v := range listProduct {
- companyIds = append(companyIds, v.CompanyId)
- }
- companyIds = append(companyIds, 0)
- condition += ` AND company_id IN (` + utils.GetOrmInReplace(len(companyIds)) + `) `
- pars = append(pars, companyIds)
- }
- if keyWord != "" {
- condition += ` AND company_name LIKE '%` + keyWord + `%' `
- }
- if adminId != "" {
- condition += ` AND seller_id IN (` + adminId + `) `
- }
- total, err := cygx.GetCygxEnterScoreCount(condition, pars)
- if err != nil {
- br.Msg = "获取失败"
- br.ErrMsg = "获取失败,Err:" + err.Error()
- return
- }
- condition += ` ORDER BY enter_score_id DESC `
- list, err := cygx.GetCygxEnterScoreList(condition, pars, startSize, pageSize)
- if err != nil {
- br.Msg = "获取失败"
- br.ErrMsg = "获取失败,Err:" + err.Error()
- return
- }
- resp := new(cygx.GetCygxEnterScoreListRep)
- if len(list) == 0 {
- resp.List = make([]*cygx.EnterScoreListResp, 0)
- } else {
- for _, v := range list {
- item := new(cygx.EnterScoreListResp)
- item.EnterScoreId = v.EnterScoreId
- item.CompanyId = v.CompanyId
- item.CompanyName = v.CompanyName
- item.Quarter = strings.Split(v.Quarter, ",")
- item.EnterScoreType = v.EnterScoreType
- item.Ranking = v.Ranking
- item.IsMergeScoring = v.IsMergeScoring
- item.SecuritiesFirmsName = v.SecuritiesFirmsName
- item.ProportionTotal = v.ProportionTotal
- item.EnterScoreId = v.EnterScoreId
- item.SellerId = v.SellerId
- item.SellerName = v.SellerName
- item.CreateTime = v.CreateTime.Format(utils.FormatDateTime)
- item.ModifyTime = v.ModifyTime.Format(utils.FormatDateTime)
- resp.List = append(resp.List, item)
- }
- }
- //导出excel
- if isExport {
- EnterScoreScoreListExport(this, resp, br)
- return
- }
- page := paging.GetPaging(currentIndex, pageSize, total)
- resp.Paging = page
- br.Ret = 200
- br.Success = true
- br.Msg = "获取成功"
- br.Data = resp
- }
- // EnterScoreScoreListExport 导出Excel
- func EnterScoreScoreListExport(this *EnterScoreController, resp *cygx.GetCygxEnterScoreListRep, br *models.BaseResponse) {
- dir, err := os.Executable()
- exPath := filepath.Dir(dir)
- downLoadnFilePath := exPath + "/" + time.Now().Format(utils.FormatDateTimeUnSpace) + ".xlsx"
- xlsxFile := xlsx.NewFile()
- if err != nil {
- br.Msg = "生成文件失败"
- br.ErrMsg = "生成文件失败"
- return
- }
- style := xlsx.NewStyle()
- alignment := xlsx.Alignment{
- Horizontal: "center",
- Vertical: "center",
- WrapText: true,
- }
- style.Alignment = alignment
- style.ApplyAlignment = true
- sheel, err := xlsxFile.AddSheet("录分记录")
- if err != nil {
- br.Msg = "新增Sheet失败"
- br.ErrMsg = "新增Sheet失败,Err:" + err.Error()
- return
- }
- sheel.SetColWidth(0, 0, 30)
- sheel.SetColWidth(1, 1, 15)
- sheel.SetColWidth(2, 2, 15)
- sheel.SetColWidth(3, 3, 18)
- titleRow := sheel.AddRow()
- cellA := titleRow.AddCell()
- cellA.SetStyle(style)
- cellA.SetValue("客户名称")
- cellB := titleRow.AddCell()
- cellB.SetStyle(style)
- cellB.SetValue("销售")
- cellC := titleRow.AddCell()
- cellC.SetStyle(style)
- cellC.SetValue("季度")
- cellD := titleRow.AddCell()
- cellD.SetStyle(style)
- cellD.SetValue("总分")
- cellE := titleRow.AddCell()
- cellE.SetStyle(style)
- cellE.SetValue("排名")
- cellF := titleRow.AddCell()
- cellF.SetStyle(style)
- cellF.SetValue("合并打分")
- cellG := titleRow.AddCell()
- cellG.SetStyle(style)
- cellG.SetValue("券商名称")
- for _, v := range resp.List {
- dataRow := sheel.AddRow()
- dataRow.SetHeight(20)
- cellA := dataRow.AddCell()
- cellA.SetStyle(style)
- cellA.SetValue(v.CompanyName)
- cellB := dataRow.AddCell()
- cellB.SetStyle(style)
- cellB.SetValue(v.SellerName)
- cellC := dataRow.AddCell()
- cellC.SetStyle(style)
- cellC.SetValue(strings.Join(v.Quarter, ","))
- cellD := dataRow.AddCell()
- cellD.SetStyle(style)
- cellD.SetValue(v.ProportionTotal)
- cellE := dataRow.AddCell()
- cellE.SetStyle(style)
- cellE.SetValue(v.Ranking)
- cellF := dataRow.AddCell()
- cellF.SetStyle(style)
- if v.IsMergeScoring == 1 {
- cellF.SetValue("是")
- } else {
- cellF.SetValue("否")
- }
- cellG := dataRow.AddCell()
- cellG.SetStyle(style)
- cellG.SetValue(v.SecuritiesFirmsName)
- }
- err = xlsxFile.Save(downLoadnFilePath)
- if err != nil {
- br.Msg = "保存文件失败"
- br.ErrMsg = "保存文件失败"
- return
- }
- randStr := time.Now().Format(utils.FormatDateTimeUnSpace)
- downloadFileName := "录分记录导出数据_" + randStr + ".xlsx"
- this.Ctx.Output.Download(downLoadnFilePath, downloadFileName)
- defer func() {
- os.Remove(downLoadnFilePath)
- }()
- br.Ret = 200
- br.Success = true
- br.Msg = "导出成功"
- }
- // @Title 删除录分
- // @Description 删除录分接口
- // @Param request body cygx.UpdateEnterScoreReq true "type json string"
- // @Success 200 {object} "保存成功"
- // @router /enterScore/delete [post]
- func (this *EnterScoreController) EnterScoreDelete() {
- br := new(models.BaseResponse).Init()
- defer func() {
- this.Data["json"] = br
- this.ServeJSON()
- }()
- sysUser := this.SysUser
- if sysUser == nil {
- br.Msg = "请登录"
- br.ErrMsg = "请登录,SysUser Is Empty"
- br.Ret = 408
- return
- }
- var req cygx.EnterScoreIdReq
- err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
- if err != nil {
- br.Msg = "参数解析异常!"
- br.ErrMsg = "参数解析失败,Err:" + err.Error()
- return
- }
- enterScoreId := req.EnterScoreId
- if enterScoreId == 0 {
- br.Msg = "参数错误!"
- br.ErrMsg = "参数错误,EnterScoreId 不能为0"
- return
- }
- err = cygx.DeleteEnterScore(enterScoreId)
- if err != nil {
- br.Msg = "删除失败"
- br.ErrMsg = "操作失败Err:" + err.Error()
- return
- }
- br.Ret = 200
- br.Success = true
- br.IsAddLog = true
- br.Msg = "删除成功"
- }
- // @Title 评分总览
- // @Description 评分总览接口
- // @Param KeyWord query string true "搜索关键词"
- // @Param City query string true "城市"
- // @Param StartDate query string false "开始日期"
- // @Param EndDate query string false "结束日期"
- // @Param EnterScoreType query string false "展示法方式 1:按评分录入、2:按比例录入,默认1"
- // @Param IsExport query bool false "是否导出excel,默认是false"
- // @Success Ret=200 {object} cygx.ScoreOverviewListResp
- // @router /enterScore/scoreOverview [get]
- func (this *EnterScoreController) EnterScoreScoreOverview() {
- br := new(models.BaseResponse).Init()
- defer func() {
- this.Data["json"] = br
- this.ServeJSON()
- }()
- AdminUser := this.SysUser
- if AdminUser == nil {
- br.Msg = "请登录"
- br.ErrMsg = "请登录,用户信息为空"
- br.Ret = 408
- return
- }
- resp := new(cygx.ScoreOverviewListResp)
- keyWord := this.GetString("KeyWord")
- city := this.GetString("City")
- enterScoreType, _ := this.GetInt("EnterScoreType", 1)
- startDate := this.GetString("StartDate")
- endDate := this.GetString("EndDate")
- //是否导出报表
- isExport, _ := this.GetBool("IsExport")
- if startDate == "" {
- br.Msg = "请选择对应年份与季度"
- return
- }
- var companyCondition string
- var companypars []interface{}
- companyCondition += ` AND b.product_name = ? `
- companypars = append(companypars, "权益")
- companyCondition += ` AND b.status = ? `
- companypars = append(companypars, "永续")
- if city != "" {
- //传过来多个城市的时候的筛选
- citySlice := strings.Split(city, ",")
- city = strings.Join(citySlice, "','")
- city = "'" + city + "'"
- companyCondition += ` AND a.city IN (` + city + `) `
- }
- //权益申请销售只能看到自己名下的客户的申请
- companyIds, err := cygxService.GetAdminLookUserCompanyIdsByResearcher(AdminUser)
- if err != nil {
- br.Msg = "获取失败"
- br.ErrMsg = "获取失败,GetAdminLookUserCompanyIds Err:" + err.Error()
- return
- }
- var newcompanyIds []int
- var searchcompanyIds []int
- //如果机构搜索做了限制 ,那么公司列表的纵向展示也做限制
- if keyWord != "" {
- listSearchCompany, err := cygx.GetCygxEnterScoreListBySecuritiesFirmsName(keyWord)
- if err != nil && err.Error() != utils.ErrNoRow() {
- br.Msg = "获取失败"
- br.ErrMsg = "获取失败,Err:" + err.Error()
- return
- }
- if len(listSearchCompany) > 0 {
- for _, v := range listSearchCompany {
- searchcompanyIds = append(searchcompanyIds, v.CompanyId)
- }
- } else {
- searchcompanyIds = append(searchcompanyIds, 0)
- }
- if len(companyIds) > 0 {
- newcompanyIds = utils.IntersectInt(searchcompanyIds, companyIds) //获取销售可见权限,与搜索权限的交集
- } else {
- newcompanyIds = searchcompanyIds
- }
- } else {
- newcompanyIds = companyIds
- }
- newlencompanyIds := len(newcompanyIds)
- if newlencompanyIds > 0 {
- companyCondition += ` AND a.company_id IN (` + utils.GetOrmInReplace(newlencompanyIds) + `)`
- companypars = append(companypars, newcompanyIds)
- }
- companyList, err := company.GetCompanyIdListByproductName(companyCondition, companypars)
- if err != nil {
- br.Msg = "获取失败"
- br.ErrMsg = "获取失败,Err:" + err.Error()
- return
- }
- var condition string
- var pars []interface{}
- if endDate != "" {
- condition += ` AND start_date <= ? AND end_date >= ? `
- pars = append(pars, startDate, endDate)
- }
- //if enterScoreType == 2 {
- //condition += ` AND enter_score_type = 2 `
- //}
- if keyWord != "" {
- condition += ` AND securities_firms_name LIKE '%` + keyWord + `%' `
- }
- if newlencompanyIds > 0 {
- condition += ` AND company_id IN (` + utils.GetOrmInReplace(newlencompanyIds) + `)`
- pars = append(pars, newcompanyIds)
- }
- total, err := cygx.GetCygxEnterScoreCount(condition, pars)
- if err != nil {
- br.Msg = "获取失败"
- br.ErrMsg = "获取失败,Err:" + err.Error()
- return
- }
- if total > 0 {
- list, err := cygx.GetCygxEnterScoreList(condition, pars, 0, 100)
- if err != nil {
- br.Msg = "获取失败"
- br.ErrMsg = "获取失败,GetCygxEnterScoreListErr:" + err.Error()
- return
- }
- mapenterScoreTypeCompanyIds := make(map[int]bool)
- mapenterScoreProportionTotal := make(map[int]float64)
- var enterScoreIds []int
- mapenterScore := make(map[int]*cygx.CygxEnterScore) //录分详情放在map中
- for _, v := range list {
- mapenterScore[v.CompanyId] = v
- mapenterScoreProportionTotal[v.CompanyId] = v.ProportionTotal
- enterScoreIds = append(enterScoreIds, v.EnterScoreId)
- if v.EnterScoreType == 2 {
- mapenterScoreTypeCompanyIds[v.CompanyId] = true //记录按照百分比录入的公司
- }
- }
- //fmt.Println(enterScoreIds)
- listResearcher, err := cygx.GeCygxEnterScoreResearcherListByIds(enterScoreIds, newcompanyIds) //获取所有的研究员
- if err != nil {
- br.Msg = "获取失败"
- br.ErrMsg = "获取失败,GetCygxEnterScorePermissionListByIds Err:" + err.Error()
- return
- }
- mapResearcher := make(map[string][]*cygx.EnterScoreRealNameListResp)
- mapResearcherProportion := make(map[string]string)
- //mapResearcherPermission := make(map[string][]map[string]string)
- var researcherArr []string // 会出现的研究员姓名
- mapResearcherbool := make(map[string]bool)
- for _, v := range listResearcher {
- if v.Proportion == 0 {
- continue
- }
- if !mapResearcherbool[v.RealName] {
- researcherArr = append(researcherArr, v.RealName)
- mapResearcherbool[v.RealName] = true
- }
- if enterScoreType == 2 && !mapenterScoreTypeCompanyIds[v.CompanyId] {
- mapResearcherProportion[fmt.Sprint(v.RealName, "_", v.CompanyId)] = utils.SubFloatToString(v.Proportion/mapenterScoreProportionTotal[v.CompanyId]*100, 2) //研究员姓名、公司ID,占比值对应关系绑定
- } else {
- mapResearcherProportion[fmt.Sprint(v.RealName, "_", v.CompanyId)] = fmt.Sprint(v.Proportion) //研究员姓名、公司ID,占比值对应关系绑定
- }
- }
- mapResearcherProportionText := make(map[string][]string)
- for _, vC := range companyList {
- for _, vR := range researcherArr {
- var proportionText string
- if mapResearcherProportion[fmt.Sprint(vR, "_", vC.CompanyId)] != "" {
- proportionText = mapResearcherProportion[fmt.Sprint(vR, "_", vC.CompanyId)]
- } else {
- if mapenterScoreProportionTotal[vC.CompanyId] > 0 {
- proportionText = "0"
- } else {
- proportionText = ""
- }
- }
- //0与空的展示逻辑处理
- if mapenterScoreTypeCompanyIds[vC.CompanyId] || enterScoreType == 2 { //按照百分比展示的拼接 %
- if proportionText != "" {
- proportionText += "%"
- }
- }
- mapResearcherProportionText[vR] = append(mapResearcherProportionText[vR], proportionText)
- }
- }
- researcherArr = make([]string, 0)
- for _, v := range listResearcher {
- if v.Proportion == 0 {
- continue
- }
- if utils.InArrayByStr(researcherArr, v.RealName) { //避免重复合并到数组
- continue
- }
- item := new(cygx.EnterScoreRealNameListResp) // 研究员结构体数据
- item.RealName = v.RealName
- item.ChartPermissionName = v.ChartPermissionName
- item.ProportionListText = mapResearcherProportionText[v.RealName]
- mapResearcher[v.ChartPermissionName] = append(mapResearcher[v.ChartPermissionName], item)
- researcherArr = append(researcherArr, v.RealName)
- }
- listPermission, err := cygx.GetCygxEnterScorePermissionListByIds(enterScoreIds) // 获取所有的行业名称
- if err != nil {
- br.Msg = "获取失败"
- br.ErrMsg = "获取失败,GetCygxEnterScorePermissionListByIds Err:" + err.Error()
- return
- }
- mapPermissionProportion := make(map[string]string)
- for _, v := range listPermission {
- if v.Proportion == 0 {
- continue
- }
- //mapPermissionProportion[fmt.Sprint(v.ChartPermissionName, "_", v.CompanyId)] = fmt.Sprint(v.Proportion) //行业名称、公司ID,占比值对应关系绑定
- if enterScoreType == 2 && !mapenterScoreTypeCompanyIds[v.CompanyId] {
- mapPermissionProportion[fmt.Sprint(v.ChartPermissionName, "_", v.CompanyId)] = utils.SubFloatToString(v.Proportion/mapenterScoreProportionTotal[v.CompanyId]*100, 2) //研究员姓名、公司ID,占比值对应关系绑定
- } else {
- mapPermissionProportion[fmt.Sprint(v.ChartPermissionName, "_", v.CompanyId)] = fmt.Sprint(v.Proportion) //行业名称、公司ID,占比值对应关系绑定
- }
- }
- var permissionArr []string // 会出现的行业名称
- mapPermissionbool := make(map[string]bool)
- for _, v := range listPermission {
- if mapPermissionbool[v.ChartPermissionName] {
- continue
- }
- permissionArr = append(permissionArr, v.ChartPermissionName)
- mapPermissionbool[v.ChartPermissionName] = true
- }
- mapPermissionProportionText := make(map[string][]string)
- for _, vC := range companyList {
- for _, vP := range permissionArr {
- var proportionText string
- if mapPermissionProportion[fmt.Sprint(vP, "_", vC.CompanyId)] != "" {
- proportionText = mapPermissionProportion[fmt.Sprint(vP, "_", vC.CompanyId)]
- } else {
- if mapenterScoreProportionTotal[vC.CompanyId] > 0 {
- proportionText = "0"
- } else {
- proportionText = ""
- }
- }
- if mapenterScoreTypeCompanyIds[vC.CompanyId] || enterScoreType == 2 { //按照百分比展示的拼接 %
- if proportionText != "" {
- proportionText += "%"
- }
- }
- mapPermissionProportionText[vP] = append(mapPermissionProportionText[vP], proportionText)
- }
- }
- var itemsP []*cygx.EnterScorePermissionListResp
- for _, v := range permissionArr {
- itemP := new(cygx.EnterScorePermissionListResp) //行业结构体
- itemP.ChartPermissionName = v
- itemP.ProportionListText = mapPermissionProportionText[v]
- itemP.List = mapResearcher[v]
- itemsP = append(itemsP, itemP)
- }
- listGroup, err := cygx.GeCygxEnterScoreGroupListByIds(enterScoreIds) // 获取所有自定义分组名称
- if err != nil {
- br.Msg = "获取失败"
- br.ErrMsg = "获取失败,GeCygxEnterScoreGroupListByIds Err:" + err.Error()
- return
- }
- mapGroupProportion := make(map[string]string)
- var groupArr []string // 会出现的自定义分组名称
- mapGroupbool := make(map[string]bool)
- for _, v := range listGroup {
- if enterScoreType == 2 && !mapenterScoreTypeCompanyIds[v.CompanyId] {
- mapGroupProportion[fmt.Sprint(v.GroupName, "_", v.CompanyId)] = utils.SubFloatToString(v.Proportion/mapenterScoreProportionTotal[v.CompanyId]*100, 2) //自定义分组名称、公司ID,占比值对应关系绑定
- } else {
- mapGroupProportion[fmt.Sprint(v.GroupName, "_", v.CompanyId)] = fmt.Sprint(v.Proportion) //自定义分组名称、公司ID,占比值对应关系绑定
- }
- //mapGroupProportion[fmt.Sprint(v.GroupName, "_", v.CompanyId)] = fmt.Sprint(v.Proportion) //自定义分组名称、公司ID,占比值对应关系绑定
- if mapGroupbool[v.GroupName] {
- continue
- }
- groupArr = append(groupArr, v.GroupName)
- mapGroupbool[v.GroupName] = true
- }
- mapGroupProportionText := make(map[string][]string)
- for _, vC := range companyList {
- for _, vP := range groupArr {
- var proportionText string
- if mapGroupProportion[fmt.Sprint(vP, "_", vC.CompanyId)] != "" {
- proportionText = mapGroupProportion[fmt.Sprint(vP, "_", vC.CompanyId)]
- } else {
- if mapenterScoreProportionTotal[vC.CompanyId] > 0 {
- proportionText = "0"
- } else {
- proportionText = ""
- }
- }
- if mapenterScoreTypeCompanyIds[vC.CompanyId] || enterScoreType == 2 { //按照百分比展示的拼接 %
- if proportionText != "" {
- proportionText += "%"
- }
- }
- mapGroupProportionText[vP] = append(mapGroupProportionText[vP], proportionText)
- }
- }
- var itemsG []*cygx.EnterScoreGroupListResp
- for _, v := range groupArr {
- itemG := new(cygx.EnterScoreGroupListResp) //行业结构体
- itemG.GroupName = v
- itemG.ProportionListText = mapGroupProportionText[v]
- itemsG = append(itemsG, itemG)
- }
- var proportionTotalText []string //总计
- var rankingText []string //排名
- var securitiesFirmsNameText []string //券商名称
- var mergeProportionTotalText []string //占比
- for _, vC := range companyList {
- var ranking, securitiesFirmsName, proportionTotal, mergeProportionTotal string
- item := mapenterScore[vC.CompanyId]
- if item != nil {
- ranking = item.Ranking
- securitiesFirmsName = item.SecuritiesFirmsName
- proportionTotal = fmt.Sprint(item.ProportionTotal)
- mergeProportionTotal = fmt.Sprint(item.MergeProportion)
- }
- //if mapenterScoreTypeCompanyIds[vC.CompanyId] { //按照百分比展示的拼接 %
- if mapenterScoreProportionTotal[vC.CompanyId] > 0 {
- mergeProportionTotal += "%"
- }
- rankingText = append(rankingText, ranking)
- securitiesFirmsNameText = append(securitiesFirmsNameText, securitiesFirmsName)
- proportionTotalText = append(proportionTotalText, proportionTotal)
- mergeProportionTotalText = append(mergeProportionTotalText, mergeProportionTotal)
- }
- itemproportionTotal := new(cygx.EnterScoreGroupListResp) //券商名称结构体
- itemproportionTotal.GroupName = "合计"
- itemproportionTotal.ProportionListText = proportionTotalText
- itemsG = append(itemsG, itemproportionTotal)
- itemranking := new(cygx.EnterScoreGroupListResp) //排名结构体
- itemranking.GroupName = "排名"
- itemranking.ProportionListText = rankingText
- itemsG = append(itemsG, itemranking)
- itemsecuritiesFirmsName := new(cygx.EnterScoreGroupListResp) //券商名称结构体
- itemsecuritiesFirmsName.GroupName = "券商名称"
- itemsecuritiesFirmsName.ProportionListText = securitiesFirmsNameText
- itemsG = append(itemsG, itemsecuritiesFirmsName)
- itemmergeProportionTotal := new(cygx.EnterScoreGroupListResp) //券商名称结构体
- itemmergeProportionTotal.GroupName = "占比"
- itemmergeProportionTotal.ProportionListText = mergeProportionTotalText
- itemsG = append(itemsG, itemmergeProportionTotal)
- resp.ListPermission = itemsP
- resp.ListGroup = itemsG
- } else {
- listPermission, err := cygx.GetChartPermissionAll()
- if err != nil {
- br.Msg = "获取信息失败"
- br.ErrMsg = "获取品种信息失败,Err:" + err.Error()
- return
- }
- permissionNameArr := []string{"医药", "消费", "科技", "智造", "策略", "固收", "宏观组", "建材组", "有色组", "能化组"}
- for _, v := range listPermission {
- if !utils.InArrayByStr(permissionNameArr, v.PermissionName) {
- continue
- }
- item := new(cygx.EnterScorePermissionListResp)
- item.ChartPermissionName = v.PermissionName
- item.ProportionListText = make([]string, len(companyList))
- item.List = make([]*cygx.EnterScoreRealNameListResp, 0)
- resp.ListPermission = append(resp.ListPermission, item)
- }
- groupNameArr := []string{"销售分", "专题分", "专家分", "云图大拓", "艾摩宏观", "合计", "排名", "券商名称", "占比"}
- for _, v := range groupNameArr {
- item := new(cygx.EnterScoreGroupListResp)
- item.GroupName = v
- item.ProportionListText = make([]string, len(companyList))
- resp.ListGroup = append(resp.ListGroup, item)
- }
- //resp.ListPermission = make([]*cygx.EnterScorePermissionListResp, 0)
- //resp.ListGroup = make([]*cygx.EnterScoreGroupListResp, 0)
- }
- if len(companyList) == 0 {
- resp.ListCompany = make([]*company.CompanyNameAndId, 0)
- } else {
- resp.ListCompany = companyList
- }
- //导出excel
- if isExport {
- EnterScoreScoreOverviewExport(this, resp, br)
- return
- }
- br.Ret = 200
- br.Success = true
- br.Msg = "获取成功"
- br.Data = resp
- }
- // EnterScoreScoreOverviewExport 导出Excel
- func EnterScoreScoreOverviewExport(this *EnterScoreController, resp *cygx.ScoreOverviewListResp, br *models.BaseResponse) {
- dir, err := os.Executable()
- exPath := filepath.Dir(dir)
- downLoadnFilePath := exPath + "/" + time.Now().Format(utils.FormatDateTimeUnSpace) + ".xlsx"
- xlsxFile := xlsx.NewFile()
- if err != nil {
- br.Msg = "生成文件失败"
- br.ErrMsg = "生成文件失败"
- return
- }
- style := xlsx.NewStyle()
- alignment := xlsx.Alignment{
- Horizontal: "center",
- Vertical: "center",
- WrapText: true,
- }
- style.Alignment = alignment
- style.ApplyAlignment = true
- sheel, err := xlsxFile.AddSheet("评分总览")
- if err != nil {
- br.Msg = "新增Sheet失败"
- br.ErrMsg = "新增Sheet失败,Err:" + err.Error()
- return
- }
- sheel.SetColWidth(0, 0, 30)
- sheel.SetColWidth(1, 1, 15)
- sheel.SetColWidth(2, 2, 15)
- sheel.SetColWidth(3, 3, 18)
- companyList := resp.ListCompany
- listPermission := resp.ListPermission
- listGroup := resp.ListGroup
- titleRow := sheel.AddRow()
- cellNull := titleRow.AddCell()
- cellNull.SetStyle(style)
- cellNull.SetValue("")
- for _, v := range companyList { //第一行公司
- cellA := titleRow.AddCell()
- cellA.SetStyle(style)
- cellA.SetValue(v.CompanyName)
- }
- for _, v := range listPermission { // 行业排序名称
- dataRow := sheel.AddRow()
- dataRow.SetHeight(20)
- cellA := dataRow.AddCell()
- cellA.SetStyle(style)
- cellA.SetValue(v.ChartPermissionName)
- for _, vCp := range v.ProportionListText { // 行业对应的占比值
- cellP := dataRow.AddCell()
- cellP.SetStyle(style)
- cellP.SetValue(vCp)
- }
- for _, vUser := range v.List { // 研究员姓名
- dataRowName := sheel.AddRow()
- dataRowName.SetHeight(20)
- cellName := dataRowName.AddCell()
- cellName.SetStyle(style)
- cellName.SetValue(vUser.RealName)
- for _, vUp := range vUser.ProportionListText { //研究员占比值
- cellP := dataRowName.AddCell()
- cellP.SetStyle(style)
- cellP.SetValue(vUp)
- }
- }
- }
- for _, v := range listGroup { // 自定义名称
- dataRow := sheel.AddRow()
- dataRow.SetHeight(20)
- cellA := dataRow.AddCell()
- cellA.SetStyle(style)
- cellA.SetValue(v.GroupName)
- for _, vG := range v.ProportionListText { // 自定义名称所对应的值
- cellP := dataRow.AddCell()
- cellP.SetStyle(style)
- cellP.SetValue(vG)
- }
- }
- err = xlsxFile.Save(downLoadnFilePath)
- if err != nil {
- br.Msg = "保存文件失败"
- br.ErrMsg = "保存文件失败"
- return
- }
- randStr := time.Now().Format(utils.FormatDateTimeUnSpace)
- downloadFileName := "评分总览" + randStr + ".xlsx"
- this.Ctx.Output.Download(downLoadnFilePath, downloadFileName)
- defer func() {
- os.Remove(downLoadnFilePath)
- }()
- br.Ret = 200
- br.Success = true
- br.Msg = "导出成功"
- }
- // @Title 排名总览
- // @Description 排名总览接口
- // @Param AdminId query string true "销售id,多个用英文逗号隔开,空字符串为全部"
- // @Param City query string true "城市"
- // @Param IsExport query bool false "是否导出excel,默认是false"
- // @Success Ret=200 {object} cygx.CompanyNameAndIdListResp
- // @router /enterScore/rankingOverview [get]
- func (this *EnterScoreController) EnterScoreRankingOverview() {
- br := new(models.BaseResponse).Init()
- defer func() {
- this.Data["json"] = br
- this.ServeJSON()
- }()
- AdminUser := this.SysUser
- if AdminUser == nil {
- br.Msg = "请登录"
- br.ErrMsg = "请登录,用户信息为空"
- br.Ret = 408
- return
- }
- resp := new(cygx.RankingOverviewListResp)
- city := this.GetString("City")
- adminId := this.GetString("AdminId")
- //是否导出报表
- isExport, _ := this.GetBool("IsExport")
- var companyCondition string
- var companypars []interface{}
- companyCondition += ` AND b.product_name = ? `
- companypars = append(companypars, "权益")
- companyCondition += ` AND b.status = ? `
- companypars = append(companypars, "永续")
- if adminId != "" {
- companyCondition += ` AND b.seller_id IN (` + adminId + `) `
- }
- if city != "" {
- //传过来多个城市的时候的筛选
- citySlice := strings.Split(city, ",")
- city = strings.Join(citySlice, "','")
- city = "'" + city + "'"
- companyCondition += ` AND a.city IN (` + city + `) `
- }
- //权益申请销售只能看到自己名下的客户的申请
- companyIds, err := cygxService.GetAdminLookUserCompanyIdsByResearcher(AdminUser)
- if err != nil {
- br.Msg = "获取失败"
- br.ErrMsg = "获取失败,GetAdminLookUserCompanyIdsBySelf Err:" + err.Error()
- return
- }
- lencompanyIds := len(companyIds)
- if lencompanyIds > 0 {
- companyCondition += ` AND a.company_id IN (` + utils.GetOrmInReplace(lencompanyIds) + `)`
- companypars = append(companypars, companyIds)
- }
- companyList, err := company.GetCompanyIdListByproductName(companyCondition, companypars)
- if err != nil {
- br.Msg = "获取失败"
- br.ErrMsg = "获取失败,Err:" + err.Error()
- return
- }
- var condition string
- var pars []interface{}
- total, err := cygx.GetCygxEnterScoreCount(condition, pars)
- if err != nil {
- br.Msg = "获取失败"
- br.ErrMsg = "获取失败,Err:" + err.Error()
- return
- }
- dataMd := []string{"10-01", "07-01", "04-01", "01-01"}
- thisYear := time.Now().Year()
- startYear := 2018 // 自定义开始时间
- var quarterDate []string
- for _, v := range dataMd {
- dateTimeStr := fmt.Sprint(thisYear, "-", v)
- dateTime, err := time.Parse("2006-01-02", dateTimeStr)
- if err != nil {
- br.Msg = "获取失败"
- br.ErrMsg = "获取失败,Err:" + err.Error()
- return
- }
- if dateTime.After(time.Now()) {
- continue
- }
- quarterDate = append(quarterDate, dateTimeStr)
- }
- for i := thisYear - 1; i >= startYear; i-- {
- for _, v := range dataMd {
- dateTimeStr := fmt.Sprint(i, "-", v)
- quarterDate = append(quarterDate, dateTimeStr)
- }
- }
- var itemsQuarter []*cygx.QuarterDateListResp
- if total > 0 {
- list, err := cygx.GetCygxEnterScoreList(condition, pars, 0, 9999)
- if err != nil {
- br.Msg = "获取失败"
- br.ErrMsg = "获取失败,GetCygxEnterScoreList Err:" + err.Error()
- return
- }
- mapQuarter := make(map[string]string)
- for _, v := range list {
- silicequarter := strings.Split(v.QuarterDate, ",")
- for _, vQ := range silicequarter {
- mapQuarter[fmt.Sprint(vQ, "_", v.CompanyId)] = v.Ranking //季度时间、公司ID,排名对应关系绑定
- }
- }
- mapRankingText := make(map[string][]string)
- for _, vC := range companyList {
- for _, vQ := range quarterDate {
- var ranking string
- ranking = mapQuarter[fmt.Sprint(vQ, "_", vC.CompanyId)]
- mapRankingText[vQ] = append(mapRankingText[vQ], ranking)
- }
- }
- for _, v := range quarterDate {
- itemQuarter := new(cygx.QuarterDateListResp)
- quarter := v
- //时间后面的月日替换成季度 Q几
- quarter = strings.Replace(quarter, "-10-01", "Q4", -1)
- quarter = strings.Replace(quarter, "-07-01", "Q3", -1)
- quarter = strings.Replace(quarter, "-04-01", "Q2", -1)
- quarter = strings.Replace(quarter, "-01-01", "Q1", -1)
- itemQuarter.Quarter = quarter
- itemQuarter.ProportionListText = mapRankingText[v]
- itemsQuarter = append(itemsQuarter, itemQuarter)
- }
- } else {
- for _, v := range quarterDate {
- itemQuarter := new(cygx.QuarterDateListResp)
- quarter := v
- //时间后面的月日替换成季度 Q几
- quarter = strings.Replace(quarter, "-10-01", "Q4", -1)
- quarter = strings.Replace(quarter, "-07-01", "Q3", -1)
- quarter = strings.Replace(quarter, "-04-01", "Q2", -1)
- quarter = strings.Replace(quarter, "-01-01", "Q1", -1)
- itemQuarter.Quarter = quarter
- itemQuarter.ProportionListText = make([]string, len(companyList))
- itemsQuarter = append(itemsQuarter, itemQuarter)
- }
- }
- resp.ListCompany = companyList
- resp.ListQuarterDate = itemsQuarter
- //导出excel
- if isExport {
- RankingOverviewExport(this, resp, br)
- return
- }
- br.Ret = 200
- br.Success = true
- br.Msg = "获取成功"
- br.Data = resp
- }
- // RankingOverviewExport 导出Excel
- func RankingOverviewExport(this *EnterScoreController, resp *cygx.RankingOverviewListResp, br *models.BaseResponse) {
- dir, err := os.Executable()
- exPath := filepath.Dir(dir)
- downLoadnFilePath := exPath + "/" + time.Now().Format(utils.FormatDateTimeUnSpace) + ".xlsx"
- xlsxFile := xlsx.NewFile()
- if err != nil {
- br.Msg = "生成文件失败"
- br.ErrMsg = "生成文件失败"
- return
- }
- style := xlsx.NewStyle()
- alignment := xlsx.Alignment{
- Horizontal: "center",
- Vertical: "center",
- WrapText: true,
- }
- style.Alignment = alignment
- style.ApplyAlignment = true
- sheel, err := xlsxFile.AddSheet("排名总览")
- if err != nil {
- br.Msg = "新增Sheet失败"
- br.ErrMsg = "新增Sheet失败,Err:" + err.Error()
- return
- }
- sheel.SetColWidth(0, 0, 30)
- sheel.SetColWidth(1, 1, 15)
- sheel.SetColWidth(2, 2, 15)
- sheel.SetColWidth(3, 3, 18)
- companyList := resp.ListCompany
- listQuarterDate := resp.ListQuarterDate
- titleRow := sheel.AddRow()
- cellNull := titleRow.AddCell()
- cellNull.SetStyle(style)
- cellNull.SetValue("")
- for _, v := range companyList { //第一行公司
- cellA := titleRow.AddCell()
- cellA.SetStyle(style)
- cellA.SetValue(v.CompanyName)
- }
- for _, v := range listQuarterDate { // 季度排序
- dataRow := sheel.AddRow()
- dataRow.SetHeight(20)
- cellA := dataRow.AddCell()
- cellA.SetStyle(style)
- cellA.SetValue(v.Quarter)
- for _, vCp := range v.ProportionListText { // 行业对应的占比值
- cellP := dataRow.AddCell()
- cellP.SetStyle(style)
- cellP.SetValue(vCp)
- }
- }
- err = xlsxFile.Save(downLoadnFilePath)
- if err != nil {
- br.Msg = "保存文件失败"
- br.ErrMsg = "保存文件失败"
- return
- }
- randStr := time.Now().Format(utils.FormatDateTimeUnSpace)
- downloadFileName := "排名总览" + randStr + ".xlsx"
- this.Ctx.Output.Download(downLoadnFilePath, downloadFileName)
- defer func() {
- os.Remove(downLoadnFilePath)
- }()
- br.Ret = 200
- br.Success = true
- br.Msg = "导出成功"
- }
|