rai_serve.go 31 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036
  1. package cygx
  2. import (
  3. "errors"
  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/cygx"
  10. "hongze/hz_crm_api/models/roadshow"
  11. cygxService "hongze/hz_crm_api/services/cygx"
  12. "hongze/hz_crm_api/utils"
  13. "os"
  14. "path/filepath"
  15. "strconv"
  16. "strings"
  17. "time"
  18. )
  19. // 权益服务类型
  20. type RaiServeCoAntroller struct {
  21. controllers.BaseAuthController
  22. }
  23. // @Title 服务类型列表
  24. // @Description 服务类型列表接口
  25. // @Success 200 {object} cygx.RaiServeTypeListResp
  26. // @router /rai_serve/type_list [get]
  27. func (this *RaiServeCoAntroller) TypeList() {
  28. br := new(models.BaseResponse).Init()
  29. defer func() {
  30. this.Data["json"] = br
  31. this.ServeJSON()
  32. }()
  33. sysUser := this.SysUser
  34. if sysUser == nil {
  35. br.Msg = "请登录"
  36. br.ErrMsg = "请登录,SysUser Is Empty"
  37. br.Ret = 408
  38. return
  39. }
  40. resp := new(cygx.RaiServeTypeListResp)
  41. var condition string
  42. list, err := cygx.GetRaiServeTypeRespList(condition)
  43. if err != nil {
  44. br.Msg = "获取失败"
  45. br.ErrMsg = "获取数据失败,Err:" + err.Error()
  46. return
  47. }
  48. resp.List = list
  49. br.Ret = 200
  50. br.Success = true
  51. br.Msg = "获取成功"
  52. br.Data = resp
  53. }
  54. // @Title 标签搜索
  55. // @Description 标签搜索接口
  56. // @Param KeyWord query string false "搜索关键词"
  57. // @Success 200 {object} cygx.RaiServeTagListResp
  58. // @router /rai_serve/search_tag [get]
  59. func (this *RaiServeCoAntroller) SearchTag() {
  60. br := new(models.BaseResponse).Init()
  61. defer func() {
  62. this.Data["json"] = br
  63. this.ServeJSON()
  64. }()
  65. sysUser := this.SysUser
  66. if sysUser == nil {
  67. br.Msg = "请登录"
  68. br.ErrMsg = "请登录,SysUser Is Empty"
  69. br.Ret = 408
  70. return
  71. }
  72. keyWord := this.GetString("KeyWord")
  73. if keyWord == "" {
  74. br.Msg = "请输入搜索关键词"
  75. return
  76. }
  77. resp := new(cygx.RaiServeTagListResp)
  78. list, err := cygx.GetRaiServeSearchTagRespList(keyWord)
  79. if err != nil {
  80. br.Msg = "获取失败"
  81. br.ErrMsg = "获取数据失败,Err:" + err.Error()
  82. return
  83. }
  84. //如果有固收或者策略就去查询行业表
  85. if strings.Contains("固收", keyWord) || strings.Contains("策略", keyWord) {
  86. var condition string
  87. var pars []interface{}
  88. keyWord = "%" + keyWord + "%"
  89. condition = ` AND product_id = 2 AND permission_name IN ('策略','固收') AND permission_name LIKE ? `
  90. pars = append(pars, keyWord)
  91. listChartPermission, err := models.GetChartPermissionListByCondition(condition, pars)
  92. if err != nil {
  93. br.Msg = "获取失败"
  94. br.ErrMsg = "获取数据失败,GetChartPermissionListByCondition Err:" + err.Error()
  95. return
  96. }
  97. for _, v := range listChartPermission {
  98. item := new(cygx.RaiServeTagResp)
  99. item.TagType = 3
  100. item.TagId = v.ChartPermissionId
  101. item.TagName = v.PermissionName
  102. list = append(list, item)
  103. }
  104. }
  105. if len(list) == 0 {
  106. list = make([]*cygx.RaiServeTagResp, 0)
  107. } else {
  108. mapUniqueKey := make(map[string]bool)
  109. for _, v := range list {
  110. uniqueKey := fmt.Sprintf("K_", v.TagType, "V_", v.TagName)
  111. if mapUniqueKey[uniqueKey] {
  112. continue
  113. }
  114. v.Md5Key = utils.MD5(fmt.Sprintf("K_", v.TagType, "V_", v.TagId))
  115. mapUniqueKey[uniqueKey] = true
  116. resp.List = append(resp.List, v)
  117. }
  118. }
  119. br.Ret = 200
  120. br.Success = true
  121. br.Msg = "获取成功"
  122. br.Data = resp
  123. }
  124. // @Title 标签搜索(研究员日历添加到会信息)
  125. // @Description 标签搜索接口
  126. // @Param KeyWord query string false "搜索关键词"
  127. // @Param ResearcherId query int false "研究员ID"
  128. // @Success 200 {object} cygx.RaiServeTagListResp
  129. // @router /rai_serve/search_tag_by_calendar [get]
  130. func (this *RaiServeCoAntroller) SearchTagCalendar() {
  131. br := new(models.BaseResponse).Init()
  132. defer func() {
  133. this.Data["json"] = br
  134. this.ServeJSON()
  135. }()
  136. sysUser := this.SysUser
  137. if sysUser == nil {
  138. br.Msg = "请登录"
  139. br.ErrMsg = "请登录,SysUser Is Empty"
  140. br.Ret = 408
  141. return
  142. }
  143. keyWord := this.GetString("KeyWord")
  144. researcherId := this.GetString("ResearcherId")
  145. askEmailList, err := cygx.GetAskEmailListByAdminIds(researcherId)
  146. if err != nil {
  147. br.Msg = "获取失败"
  148. br.ErrMsg = "GetAskEmailCountByCelue,Err:" + err.Error()
  149. return
  150. }
  151. var hasCelue bool
  152. var permissionName []string
  153. for _, v := range askEmailList {
  154. permissionName = append(permissionName, v.ChartPermissionName)
  155. if v.ChartPermissionName == "策略" || v.ChartPermissionName == "固收" {
  156. hasCelue = true
  157. }
  158. }
  159. var permissionNameSql []string
  160. for _, v := range permissionName {
  161. permissionNameSql = append(permissionNameSql, "'"+v+"'")
  162. }
  163. chartList, err := models.GetChartPermissionByNamesByRai(permissionNameSql)
  164. if err != nil {
  165. br.Msg = "获取失败"
  166. br.ErrMsg = "获取数据失败,GetChartPermissionByNames Err:" + err.Error()
  167. return
  168. }
  169. var list []*cygx.RaiServeTagResp
  170. resp := new(cygx.RaiServeTagListResp)
  171. if hasCelue {
  172. for _, v := range chartList {
  173. item := new(cygx.RaiServeTagResp)
  174. item.TagType = 3
  175. item.TagId = v.ChartPermissionId
  176. item.TagName = v.PermissionName
  177. list = append(list, item)
  178. }
  179. } else {
  180. if keyWord == "" {
  181. br.Msg = "请输入搜索关键词"
  182. return
  183. }
  184. keyWordSlice := strings.Split(keyWord, ",")
  185. var conditionindustrial string
  186. var conditionsubject string
  187. for _, v := range keyWordSlice {
  188. conditionindustrial += ` OR i.industry_name LIKE '%` + v + `%' `
  189. conditionsubject += ` OR s.subject_name LIKE '%` + v + `%' `
  190. }
  191. var permissionId []string
  192. for _, v := range chartList {
  193. permissionId = append(permissionId, strconv.Itoa(v.ChartPermissionId))
  194. }
  195. list, err = cygx.GetRaiServeSearchTagRespListBycharId(keyWord, strings.Join(permissionId, ","), conditionindustrial, conditionsubject)
  196. if err != nil {
  197. br.Msg = "获取失败"
  198. br.ErrMsg = "获取数据失败,GetRaiServeSearchTagRespListBycharId Err:" + err.Error()
  199. return
  200. }
  201. }
  202. if len(list) == 0 {
  203. list = make([]*cygx.RaiServeTagResp, 0)
  204. } else {
  205. mapUniqueKey := make(map[string]bool)
  206. for _, v := range list {
  207. uniqueKey := fmt.Sprintf("K_", v.TagType, "V_", v.TagName)
  208. if mapUniqueKey[uniqueKey] {
  209. continue
  210. }
  211. v.Md5Key = utils.MD5(fmt.Sprintf("K_", v.TagType, "V_", v.TagId))
  212. mapUniqueKey[uniqueKey] = true
  213. resp.List = append(resp.List, v)
  214. }
  215. }
  216. br.Ret = 200
  217. br.Success = true
  218. br.Msg = "获取成功"
  219. br.Data = resp
  220. }
  221. // @Title 校验是否属于策略固收
  222. // @Description 校验是否属于策略固收接口
  223. // @Param ResearcherId query int false "研究员ID"
  224. // @Success 200 {object} cygx.RaiServeTagListResp
  225. // @router /rai_serve/chcck_PermissionName [get]
  226. func (this *RaiServeCoAntroller) ChcckPermissionName() {
  227. br := new(models.BaseResponse).Init()
  228. defer func() {
  229. this.Data["json"] = br
  230. this.ServeJSON()
  231. }()
  232. sysUser := this.SysUser
  233. if sysUser == nil {
  234. br.Msg = "请登录"
  235. br.ErrMsg = "请登录,SysUser Is Empty"
  236. br.Ret = 408
  237. return
  238. }
  239. researcherId := this.GetString("ResearcherId")
  240. askEmailList, err := cygx.GetAskEmailListByAdminIds(researcherId)
  241. if err != nil {
  242. br.Msg = "获取失败"
  243. br.ErrMsg = "GetAskEmailCountByCelue,Err:" + err.Error()
  244. return
  245. }
  246. var belong bool
  247. var permissionNameResp []string
  248. var permissionNames []string
  249. for _, v := range askEmailList {
  250. permissionNames = append(permissionNames, v.ChartPermissionName)
  251. if v.ChartPermissionName == "策略" || v.ChartPermissionName == "固收" {
  252. belong = true
  253. permissionNameResp = append(permissionNameResp, v.ChartPermissionName)
  254. }
  255. }
  256. var list []*cygx.RaiServeTagResp
  257. if belong {
  258. var permissionNameSql []string
  259. for _, v := range permissionNameResp {
  260. permissionNameSql = append(permissionNameSql, "'"+v+"'")
  261. }
  262. chartList, err := models.GetChartPermissionByNamesByRai(permissionNameSql)
  263. if err != nil {
  264. br.Msg = "获取失败"
  265. br.ErrMsg = "获取数据失败,GetChartPermissionByNames Err:" + err.Error()
  266. return
  267. }
  268. for _, v := range chartList {
  269. item := new(cygx.RaiServeTagResp)
  270. item.TagType = 3
  271. item.TagId = v.ChartPermissionId
  272. item.TagName = v.PermissionName
  273. item.Md5Key = utils.MD5(fmt.Sprintf("K_", item.TagType, "V_", item.TagId))
  274. list = append(list, item)
  275. }
  276. }
  277. resp := new(cygx.ChekChartPermissionNameResp)
  278. if len(list) == 0 {
  279. list = make([]*cygx.RaiServeTagResp, 0)
  280. }
  281. resp.List = list
  282. resp.Belong = belong
  283. resp.ChartPermissionName = strings.Join(permissionNameResp, ",")
  284. br.Ret = 200
  285. br.Success = true
  286. br.Msg = "获取成功"
  287. br.Data = resp
  288. }
  289. // @Title 权益服务统计列表
  290. // @Description 权益服务统计列表接口
  291. // @Param PageSize query int true "每页数据条数"
  292. // @Param CurrentIndex query int true "当前页页码,从1开始"
  293. // @Param SellerId query string false "销售id"
  294. // @Param ShareSellerId query string false "共享销售ID"
  295. // @Param ServeTypeId int int false "服务类型ID"
  296. // @Param TagType int string false "标签类型"
  297. // @Param TagId int string false "标签ID"
  298. // @Param Status query string false "客户状态,正式、未续约(除了正式之外的所有)"
  299. // @Param SortType query string true "如何排序,是正序还是倒序,枚举值:`asc 正序`,`desc 倒叙`"
  300. // @Param KeyWord query string false "搜索关键词"
  301. // @Param IsExport query bool false "是否导出excel,默认是false"
  302. // @Success 200 {object} cygx.RaiServeTagListResp
  303. // @router /rai_serve/list [get]
  304. func (this *RaiServeCoAntroller) List() {
  305. br := new(models.BaseResponse).Init()
  306. defer func() {
  307. this.Data["json"] = br
  308. this.ServeJSON()
  309. }()
  310. sysUser := this.SysUser
  311. if sysUser == nil {
  312. br.Msg = "请登录"
  313. br.ErrMsg = "请登录,SysUser Is Empty"
  314. br.Ret = 408
  315. return
  316. }
  317. pageSize, _ := this.GetInt("PageSize")
  318. currentIndex, _ := this.GetInt("CurrentIndex")
  319. status := this.GetString("Status")
  320. sellerId := this.GetString("SellerId")
  321. shareSellerId := this.GetString("ShareSellerId")
  322. sortType := this.GetString("SortType")
  323. tagType, _ := this.GetInt("TagType")
  324. tagId, _ := this.GetInt("TagId")
  325. serveTypeId, _ := this.GetInt("ServeTypeId")
  326. keyWord := this.GetString("KeyWord")
  327. isExport, _ := this.GetBool("IsExport")
  328. resp := new(cygx.CygxRaiServeCompanyListResp)
  329. if isExport {
  330. pageSize = 999
  331. }
  332. var startSize int
  333. if pageSize <= 0 {
  334. pageSize = utils.PageSize20
  335. }
  336. if currentIndex <= 0 {
  337. currentIndex = 1
  338. }
  339. startSize = utils.StartIndex(currentIndex, pageSize)
  340. var condition string
  341. var sortStr string
  342. var pars []interface{}
  343. if status != "" {
  344. if status == "正式" {
  345. condition += " AND status = '正式' "
  346. } else {
  347. condition += " AND status != '正式' "
  348. }
  349. }
  350. if sellerId != "" {
  351. condition += " AND seller_id IN (" + sellerId + ") "
  352. //pars = append(pars, sellerId)
  353. }
  354. if shareSellerId != "" {
  355. condition += " AND share_seller_id IN (" + shareSellerId + ") "
  356. //pars = append(pars, shareSellerId)
  357. }
  358. if sortType != "" {
  359. if sortType == "asc" {
  360. sortStr = " ORDER BY money ASC "
  361. } else if sortType == "desc" {
  362. sortStr = " ORDER BY money DESC "
  363. }
  364. } else {
  365. sortStr = " ORDER BY end_date DESC "
  366. }
  367. //如果不是权益管理员和admin、财务,就做可见权限限制
  368. if sysUser.RoleTypeCode != utils.ROLE_TYPE_CODE_RAI_ADMIN && sysUser.RoleTypeCode != utils.ROLE_TYPE_CODE_ADMIN && sysUser.RoleTypeCode != utils.ROLE_TYPE_CODE_RAI_RESEARCHR {
  369. if sysUser.RoleTypeCode == utils.ROLE_TYPE_CODE_RAI_SELLER {
  370. condition += " AND (seller_id = ? OR share_seller_id = ? ) "
  371. pars = append(pars, sysUser.AdminId, sysUser.AdminId)
  372. }
  373. if sysUser.RoleTypeCode == utils.ROLE_TYPE_CODE_RAI_GROUP {
  374. condition += " AND ( seller_id = ? OR share_seller_id = ? OR group_id = ? OR share_group_id = ? ) "
  375. pars = append(pars, sysUser.AdminId, sysUser.AdminId, sysUser.GroupId, sysUser.GroupId)
  376. }
  377. }
  378. //公司名称搜索
  379. if keyWord != "" {
  380. keyWord = "%" + keyWord + "%"
  381. condition += ` AND company_name LIKE ? `
  382. pars = append(pars, keyWord)
  383. }
  384. total, err := cygx.GetCygxRaiServeCompanyCount(condition, pars)
  385. if err != nil {
  386. br.Msg = "获取失败"
  387. br.ErrMsg = "获取失败,GetCygxRaiServeCompanyCountErr:" + err.Error()
  388. return
  389. }
  390. listRaiServeCompany, err := cygx.GetCygxRaiServeCompanyList(condition+sortStr, pars, startSize, pageSize)
  391. if err != nil {
  392. br.Msg = "获取失败"
  393. br.ErrMsg = "获取失败,Err:" + err.Error()
  394. return
  395. }
  396. var companyIds []int
  397. for _, v := range listRaiServeCompany {
  398. companyIds = append(companyIds, v.CompanyId)
  399. }
  400. mapWeekAmount := make(map[string]float64) //周度服务量
  401. weeks := 4
  402. if isExport {
  403. weeks = 12 // 下载获取近12周的数据
  404. }
  405. lencompanyIds := len(companyIds)
  406. if lencompanyIds > 0 {
  407. var conditionBill string
  408. var parsBill []interface{}
  409. conditionBill, parsBill, err = getServeBillTag(tagType, tagId) // 标签ID搜索语句处理
  410. if err != nil {
  411. br.Msg = "获取信息失败!"
  412. br.ErrMsg = "获取用户信息失败-getServeBillTag!Err:" + err.Error()
  413. return
  414. }
  415. //服务类型筛选
  416. if serveTypeId > 0 {
  417. conditionBill += ` AND serve_type_id = ? `
  418. parsBill = append(parsBill, serveTypeId)
  419. }
  420. conditionBill += " AND company_id IN (" + utils.GetOrmInReplace(lencompanyIds) + ") "
  421. parsBill = append(parsBill, companyIds)
  422. listBill, err := cygx.GetCygxRaiServeBillListAll(conditionBill, parsBill)
  423. if err != nil {
  424. br.Msg = "获取信息失败!"
  425. br.ErrMsg = "获取用户信息失败-GetCygxRaiServeBillListAll!Err:" + err.Error()
  426. return
  427. }
  428. now := time.Now()
  429. for _, v := range listBill {
  430. for i := 0; i < weeks; i++ {
  431. // 计算当前周的周一
  432. monday := now.AddDate(0, 0, -int(now.Weekday()-time.Monday)-i*7)
  433. weekmonday := monday.Format(utils.FormatDate)
  434. if v.WeekStartDate == weekmonday {
  435. mapWeekAmount[fmt.Sprintf("CID_", v.CompanyId, "WEEK_", i)] += v.ServeCount
  436. }
  437. }
  438. }
  439. }
  440. for _, v := range listRaiServeCompany {
  441. item := new(cygx.CygxRaiServeCompanyResp)
  442. item.CompanyId = v.CompanyId
  443. item.CompanyName = v.CompanyName
  444. item.Money = v.Money
  445. item.ServeCoverageRate = v.ServeCoverageRate + "%"
  446. item.SellerId = v.SellerId
  447. item.SellerName = v.SellerName
  448. item.StartDate = v.StartDate
  449. item.StartDate = v.StartDate
  450. item.EndDate = v.EndDate
  451. item.ShareSeller = v.ShareSeller
  452. item.ShareSellerId = v.ShareSellerId
  453. item.Status = v.Status
  454. item.PermissionName = v.PermissionName
  455. if v.IsUserMaker == 0 {
  456. item.IsRed = true
  457. }
  458. item.ThisWeekAmount = mapWeekAmount[fmt.Sprintf("CID_", v.CompanyId, "WEEK_", 0)]
  459. item.LastWeekAmount = mapWeekAmount[fmt.Sprintf("CID_", v.CompanyId, "WEEK_", 1)]
  460. item.TwoWeekAmount = mapWeekAmount[fmt.Sprintf("CID_", v.CompanyId, "WEEK_", 2)]
  461. item.ThreeWeekAmount = mapWeekAmount[fmt.Sprintf("CID_", v.CompanyId, "WEEK_", 3)]
  462. resp.List = append(resp.List, item)
  463. }
  464. //导出excel
  465. if isExport {
  466. RaiServeListExport(this, resp, mapWeekAmount, br)
  467. return
  468. }
  469. page := paging.GetPaging(currentIndex, pageSize, total)
  470. resp.Paging = page
  471. br.Ret = 200
  472. br.Success = true
  473. br.Msg = "获取成功"
  474. br.Data = resp
  475. }
  476. // EnterScoreScoreListExport 导出Excel
  477. func RaiServeListExport(this *RaiServeCoAntroller, resp *cygx.CygxRaiServeCompanyListResp, mapWeekAmount map[string]float64, br *models.BaseResponse) {
  478. weeks := 12 // 下载获取近12周的数据
  479. mapWeekFormat := make(map[int]string)
  480. now := time.Now()
  481. for i := 0; i < weeks; i++ {
  482. // 计算当前周的周一
  483. monday := now.AddDate(0, 0, -int(now.Weekday()-time.Monday)-i*7)
  484. sunday := monday.AddDate(0, 0, 6)
  485. weekmonday := monday.Format(utils.FormatMonthDayUnSpace2)
  486. weeksunday := sunday.Format(utils.FormatMonthDayUnSpace2)
  487. mapWeekFormat[i] = weekmonday + "~" + weeksunday
  488. }
  489. dir, err := os.Executable()
  490. exPath := filepath.Dir(dir)
  491. downLoadnFilePath := exPath + "/" + time.Now().Format(utils.FormatDateTimeUnSpace) + ".xlsx"
  492. xlsxFile := xlsx.NewFile()
  493. if err != nil {
  494. br.Msg = "生成文件失败"
  495. br.ErrMsg = "生成文件失败"
  496. return
  497. }
  498. style := xlsx.NewStyle()
  499. border := xlsx.NewBorder("thin", "thin", "thin", "thin")
  500. alignment := xlsx.Alignment{
  501. Horizontal: "center",
  502. Vertical: "center",
  503. WrapText: true,
  504. }
  505. redStyle := xlsx.NewStyle()
  506. redStyle.Alignment = alignment
  507. redStyle.ApplyAlignment = true
  508. redStyle.Font.Color = "ff0000"
  509. redStyle.Border = *border
  510. style.Alignment = alignment
  511. style.ApplyAlignment = true
  512. sheel, err := xlsxFile.AddSheet("权益服务统计")
  513. if err != nil {
  514. br.Msg = "新增Sheet失败"
  515. br.ErrMsg = "新增Sheet失败,Err:" + err.Error()
  516. return
  517. }
  518. sheel.SetColWidth(0, 0, 30)
  519. sheel.SetColWidth(1, 1, 15)
  520. sheel.SetColWidth(2, 2, 15)
  521. sheel.SetColWidth(3, 3, 18)
  522. titleRow := sheel.AddRow()
  523. cellA := titleRow.AddCell()
  524. cellA.SetStyle(style)
  525. cellA.SetValue("客户名称")
  526. cellWeek := titleRow.AddCell()
  527. cellWeek.SetStyle(style)
  528. cellWeek.SetValue("近4周平均服务覆盖率")
  529. cellB := titleRow.AddCell()
  530. cellB.SetStyle(style)
  531. cellB.SetValue("当前状态")
  532. cellC := titleRow.AddCell()
  533. cellC.SetStyle(style)
  534. cellC.SetValue("所属销售")
  535. cellD := titleRow.AddCell()
  536. cellD.SetStyle(style)
  537. cellD.SetValue("咨询销售")
  538. cellE := titleRow.AddCell()
  539. cellE.SetStyle(style)
  540. cellE.SetValue("合同期限")
  541. cellF := titleRow.AddCell()
  542. cellF.SetStyle(style)
  543. cellF.SetValue("合同金额")
  544. cellG := titleRow.AddCell()
  545. cellG.SetStyle(style)
  546. cellG.SetValue("签约套餐")
  547. cellWe1 := titleRow.AddCell()
  548. cellWe1.SetStyle(style)
  549. cellWe1.SetValue("本周服务量(" + mapWeekFormat[0] + ")")
  550. cellWe2 := titleRow.AddCell()
  551. cellWe2.SetStyle(style)
  552. cellWe2.SetValue("上周服务量(" + mapWeekFormat[1] + ")")
  553. cellWe3 := titleRow.AddCell()
  554. cellWe3.SetStyle(style)
  555. cellWe3.SetValue("上上周服务量(" + mapWeekFormat[2] + ")")
  556. cellWe4 := titleRow.AddCell()
  557. cellWe4.SetStyle(style)
  558. cellWe4.SetValue("上三周服务量(" + mapWeekFormat[3] + ")")
  559. for i := 0; i < weeks; i++ {
  560. if i < 4 {
  561. continue
  562. }
  563. // 计算当前周的周一
  564. cellWei := titleRow.AddCell()
  565. cellWei.SetStyle(style)
  566. cellWei.SetValue(mapWeekFormat[i])
  567. }
  568. for _, v := range resp.List {
  569. dataRow := sheel.AddRow()
  570. dataRow.SetHeight(20)
  571. cellA := dataRow.AddCell()
  572. if v.IsRed {
  573. cellA.SetStyle(redStyle)
  574. } else {
  575. cellA.SetStyle(style)
  576. }
  577. cellA.SetValue(v.CompanyName)
  578. cellWeekData := dataRow.AddCell()
  579. cellWeekData.SetStyle(style)
  580. cellWeekData.SetValue(v.ServeCoverageRate)
  581. cellB := dataRow.AddCell()
  582. cellB.SetStyle(style)
  583. cellB.SetValue(v.Status)
  584. cellC := dataRow.AddCell()
  585. cellC.SetStyle(style)
  586. cellC.SetValue(v.SellerName)
  587. cellD := dataRow.AddCell()
  588. cellD.SetStyle(style)
  589. cellD.SetValue(v.ShareSeller)
  590. cellE := dataRow.AddCell()
  591. cellE.SetStyle(style)
  592. cellE.SetValue(v.StartDate + "~" + v.EndDate)
  593. cellF := dataRow.AddCell()
  594. cellF.SetStyle(style)
  595. cellF.SetValue(v.Money)
  596. cellG := dataRow.AddCell()
  597. cellG.SetStyle(style)
  598. cellG.SetValue(v.PermissionName)
  599. for i := 0; i < weeks; i++ {
  600. cellWei := dataRow.AddCell()
  601. cellWei.SetStyle(style)
  602. cellWei.SetValue(mapWeekAmount[fmt.Sprintf("CID_", v.CompanyId, "WEEK_", i)])
  603. }
  604. }
  605. err = xlsxFile.Save(downLoadnFilePath)
  606. if err != nil {
  607. br.Msg = "保存文件失败"
  608. br.ErrMsg = "保存文件失败"
  609. return
  610. }
  611. randStr := time.Now().Format(utils.FormatDateTimeUnSpace)
  612. downloadFileName := "权益服务统计导出数据_" + randStr + ".xlsx"
  613. this.Ctx.Output.Download(downLoadnFilePath, downloadFileName)
  614. defer func() {
  615. os.Remove(downLoadnFilePath)
  616. }()
  617. br.Ret = 200
  618. br.Success = true
  619. br.Msg = "导出成功"
  620. }
  621. // 标签搜索语句筛选
  622. func getServeBillTag(tagType, tagId int) (conditionBill string, parsBill []interface{}, err error) {
  623. if tagType == 0 {
  624. return
  625. }
  626. var activityIds []int
  627. var activitySpecialIds []int
  628. var articleIds []int
  629. var rsCalendarIds []int
  630. switch tagType {
  631. case 1:
  632. listGroupActivity, e := cygx.GetIndustrialActivityGroupManagementListByIndustriaId(tagId, 1) // 关联的活动
  633. if e != nil {
  634. err = errors.New("GetIndustrialActivityGroupManagementListByIndustriaId, Err: " + e.Error())
  635. return
  636. }
  637. for _, v := range listGroupActivity {
  638. activityIds = append(activityIds, v.ActivityId)
  639. }
  640. listGroupActivitySpecial, e := cygx.GetIndustrialActivityGroupManagementListByIndustriaId(tagId, 2) // 关联的产业
  641. if e != nil {
  642. err = errors.New("GetIndustrialActivityGroupManagementListByIndustriaId, Err: " + e.Error())
  643. return
  644. }
  645. for _, v := range listGroupActivitySpecial {
  646. activitySpecialIds = append(activitySpecialIds, v.ActivityId)
  647. }
  648. listGroupArticle, e := cygx.GetIndustrialArticleGroupManagementListByindustrialId(tagId) // 关联的产业
  649. if e != nil {
  650. err = errors.New("GetIndustrialArticleGroupManagementListByindustrialId, Err: " + e.Error())
  651. return
  652. }
  653. for _, v := range listGroupArticle {
  654. articleIds = append(articleIds, v.ArticleId)
  655. }
  656. listGroupRsCalendar, e := roadshow.GetRsCalendarMeetingLabelGroupDetailByTag(tagType, tagId)
  657. if e != nil {
  658. err = errors.New("GetRsCalendarMeetingLabelGroupDetailByTag, Err: " + e.Error())
  659. return
  660. }
  661. for _, v := range listGroupRsCalendar {
  662. rsCalendarIds = append(rsCalendarIds, v.RsCalendarId)
  663. }
  664. case 2:
  665. //通过ID获取标的名称
  666. detailSubjecj, e := cygx.GetIndustrialSubjectDetailById(tagId)
  667. if e != nil {
  668. err = errors.New("GetIndustrialSubjectDetailById, Err: " + e.Error())
  669. return
  670. }
  671. //通过名称获取所有相同名称的标的
  672. listSubject, e := cygx.GetListIndustrialSubjectDetailByName(detailSubjecj.SubjectName)
  673. if e != nil {
  674. err = errors.New("GetIndustrialSubjectDetailById, Err: " + e.Error())
  675. return
  676. }
  677. var industrialSubjectIds []int
  678. for _, v := range listSubject {
  679. industrialSubjectIds = append(industrialSubjectIds, v.IndustrialSubjectId)
  680. }
  681. listGroupActivity, e := cygx.GetSubjectActivityGroupManagementListBySubjectIds(industrialSubjectIds, 1) // 关联的活动
  682. if e != nil {
  683. err = errors.New("GetSubjectActivityGroupManagementListBySubjectId, Err: " + e.Error())
  684. return
  685. }
  686. for _, v := range listGroupActivity {
  687. activityIds = append(activityIds, v.ActivityId)
  688. }
  689. listGroupActivitySpecial, e := cygx.GetSubjectActivityGroupManagementListBySubjectIds(industrialSubjectIds, 2) // 关联的专项调研活动
  690. if e != nil {
  691. err = errors.New("GetSubjectActivityGroupManagementListBySubjectIds, Err: " + e.Error())
  692. return
  693. }
  694. for _, v := range listGroupActivitySpecial {
  695. activitySpecialIds = append(activitySpecialIds, v.ActivityId)
  696. }
  697. listGroupArticle, e := cygx.GetSubjectArticleGroupManagementListBysubjectIds(industrialSubjectIds) // 关联的报告
  698. if e != nil {
  699. err = errors.New("GetSubjectArticleGroupManagementListBysubjectIds, Err: " + e.Error())
  700. return
  701. }
  702. for _, v := range listGroupArticle {
  703. articleIds = append(articleIds, v.ArticleId)
  704. }
  705. listGroupRsCalendar, e := roadshow.GetRsCalendarMeetingLabelGroupDetailByTagIds(tagType, industrialSubjectIds)
  706. if e != nil {
  707. err = errors.New("GetRsCalendarMeetingLabelGroupDetailByTagIds, Err: " + e.Error())
  708. return
  709. }
  710. for _, v := range listGroupRsCalendar {
  711. rsCalendarIds = append(rsCalendarIds, v.RsCalendarId)
  712. }
  713. activityIds = append(activityIds, 0)
  714. lenactivityIds := len(activityIds)
  715. //if lenactivityIds > 0 {
  716. conditionBill += ` AND IF ( source = 'activity', source_id IN (` + utils.GetOrmInReplace(lenactivityIds) + `) , 1 = 1 ) `
  717. parsBill = append(parsBill, activityIds)
  718. //}
  719. activitySpecialIds = append(activitySpecialIds, 0)
  720. lenactivitySpecialIds := len(activitySpecialIds)
  721. //if lenactivitySpecialIds > 0 {
  722. conditionBill += ` AND IF ( source = 'activityspecial', source_id IN (` + utils.GetOrmInReplace(lenactivitySpecialIds) + `) , 1 = 1 ) `
  723. parsBill = append(parsBill, activitySpecialIds)
  724. //}
  725. articleIds = append(articleIds, 0)
  726. lenarticleIds := len(articleIds)
  727. //if lenarticleIds > 0 {
  728. conditionBill += ` AND IF ( source = 'article', source_id IN (` + utils.GetOrmInReplace(lenarticleIds) + `) , 1 = 1 ) `
  729. parsBill = append(parsBill, articleIds)
  730. //}
  731. rsCalendarIds = append(rsCalendarIds, 0)
  732. lenrsCalendarIds := len(rsCalendarIds)
  733. //if lenrsCalendarIds > 0 {
  734. conditionBill += ` AND IF ( source = 'rscalendar', source_id IN (` + utils.GetOrmInReplace(lenrsCalendarIds) + `) , 1 = 1 ) `
  735. parsBill = append(parsBill, rsCalendarIds)
  736. case 3:
  737. conditionBill += " AND chart_permission_id = ? "
  738. parsBill = append(parsBill, tagId)
  739. }
  740. //}
  741. conditionBill += ` AND source != 'yanxuanspecial' AND source != 'userfeedback' `
  742. return
  743. }
  744. // @Title 近四周覆盖率
  745. // @Description 近四周覆盖率接口
  746. // @Param CompanyId query int false "公司ID"
  747. // @Success 200 {object} cygx.RaiServeTagListResp
  748. // @router /rai_serve/coverage_rate [get]
  749. func (this *RaiServeCoAntroller) CoverageRate() {
  750. br := new(models.BaseResponse).Init()
  751. defer func() {
  752. this.Data["json"] = br
  753. this.ServeJSON()
  754. }()
  755. sysUser := this.SysUser
  756. if sysUser == nil {
  757. br.Msg = "请登录"
  758. br.ErrMsg = "请登录,SysUser Is Empty"
  759. br.Ret = 408
  760. return
  761. }
  762. companyId, _ := this.GetInt("CompanyId")
  763. listWeekBill, err := cygx.GetCygxRaiServeBillListWeek4(companyId)
  764. if err != nil {
  765. br.Msg = "获取信息失败!"
  766. br.ErrMsg = "获取用户信息失败-GetCygxRaiServeBillListWeek4!Err:" + err.Error()
  767. return
  768. }
  769. mapWeek := make(map[int]string)
  770. for k, v := range listWeekBill {
  771. mapWeek[k] = utils.SubFloatToString(v.CoverageRate, 2)
  772. }
  773. resp := new(cygx.RaiServeCoverageRateResp)
  774. resp.ThisWeekAmount = mapWeek[0] + "%"
  775. resp.LastWeekAmount = mapWeek[1] + "%"
  776. resp.TwoWeekAmount = mapWeek[2] + "%"
  777. resp.ThreeWeekAmount = mapWeek[3] + "%"
  778. br.Ret = 200
  779. br.Success = true
  780. br.Msg = "获取成功"
  781. br.Data = resp
  782. }
  783. // @Title 明细列表
  784. // @Description 明细列表接口
  785. // @Param PageSize query int true "每页数据条数"
  786. // @Param CurrentIndex query int true "当前页页码,从1开始"
  787. // @Param CompanyId query int false "公司ID"
  788. // @Param TagType query int false "标签类型"
  789. // @Param TagId query int false "标签ID"
  790. // @Param ServeTypeId int int false "服务类型ID"
  791. // @Param WhatWeek query int false "哪一周 ,1:本周、2:上周、3:上上周、4上三周"
  792. // @Success 200 {object} cygx.RaiServeTagListResp
  793. // @router /rai_serve/bill_list [get]
  794. func (this *RaiServeCoAntroller) BillList() {
  795. br := new(models.BaseResponse).Init()
  796. defer func() {
  797. this.Data["json"] = br
  798. this.ServeJSON()
  799. }()
  800. sysUser := this.SysUser
  801. if sysUser == nil {
  802. br.Msg = "请登录"
  803. br.ErrMsg = "请登录,SysUser Is Empty"
  804. br.Ret = 408
  805. return
  806. }
  807. pageSize, _ := this.GetInt("PageSize")
  808. currentIndex, _ := this.GetInt("CurrentIndex")
  809. companyId, _ := this.GetInt("CompanyId")
  810. tagType, _ := this.GetInt("TagType")
  811. tagId, _ := this.GetInt("TagId")
  812. serveTypeId, _ := this.GetInt("ServeTypeId")
  813. whatWeek, _ := this.GetInt("WhatWeek")
  814. var startSize int
  815. if pageSize <= 0 {
  816. pageSize = utils.PageSize20
  817. }
  818. if currentIndex <= 0 {
  819. currentIndex = 1
  820. }
  821. startSize = utils.StartIndex(currentIndex, pageSize)
  822. if companyId == 0 {
  823. br.Msg = "请选择对应公司ID"
  824. return
  825. }
  826. var condition string
  827. var pars []interface{}
  828. var err error
  829. condition, pars, err = getServeBillTag(tagType, tagId) // 标签ID搜索语句处理
  830. if err != nil {
  831. br.Msg = "获取信息失败!"
  832. br.ErrMsg = "获取用户信息失败-getServeBillTag!Err:" + err.Error()
  833. return
  834. }
  835. if whatWeek > 0 {
  836. now := time.Now()
  837. // 计算所选周的周一
  838. monday := now.AddDate(0, 0, -int(now.Weekday()-time.Monday)-(whatWeek-1)*7)
  839. condition += " AND week_start_date = ? "
  840. pars = append(pars, monday.Format(utils.FormatDate))
  841. }
  842. condition += " AND company_id = ? "
  843. pars = append(pars, companyId)
  844. if serveTypeId > 0 {
  845. condition += " AND serve_type_id = ? "
  846. pars = append(pars, serveTypeId)
  847. }
  848. total, err := cygx.GetCygxRaiServeBillCount(condition, pars)
  849. if err != nil {
  850. br.Msg = "获取失败"
  851. br.ErrMsg = "获取失败,GetCygxRaiServeBillCount:" + err.Error()
  852. return
  853. }
  854. list, err := cygx.GetCygxRaiServeBillRespList(condition, pars, startSize, pageSize)
  855. if err != nil {
  856. br.Msg = "获取失败"
  857. br.ErrMsg = "获取失败,GetCygxRaiServeBillRespList:" + err.Error()
  858. return
  859. }
  860. page := paging.GetPaging(currentIndex, pageSize, total)
  861. resp := new(cygx.CygxRaiServeBillListResp)
  862. resp.Paging = page
  863. if len(list) == 0 {
  864. resp.List = make([]*cygx.CygxRaiServeBillResp, 0)
  865. } else {
  866. var activityIds []int
  867. var activitySpecialIds []int
  868. var articleIds []int
  869. var rsCalendarIds []int
  870. for _, v := range list {
  871. switch v.Source {
  872. case utils.CYGX_OBJ_ARTICLE:
  873. articleIds = append(articleIds, v.SourceId)
  874. case utils.CYGX_OBJ_ACTIVITY:
  875. activityIds = append(activityIds, v.SourceId)
  876. case utils.CYGX_OBJ_ACTIVITYSPECIAL:
  877. activitySpecialIds = append(activitySpecialIds, v.SourceId)
  878. case utils.CYGX_OBJ_RS_CALENDAR:
  879. rsCalendarIds = append(rsCalendarIds, v.SourceId)
  880. }
  881. }
  882. maparticleIndustrialLabel := make(map[int][]string) //文章产业标签
  883. maparticleSubjectLabel := make(map[int][]string) // 文章行业标签
  884. if len(articleIds) > 0 {
  885. maparticleIndustrialLabel = cygxService.GetArticleIndustrialLabelByArticleId(articleIds) // 关联产业
  886. maparticleSubjectLabel = cygxService.GetArticleSubjectLabelByArticleId(articleIds) // 关联标的
  887. }
  888. mapActivityIndustrialLabel := make(map[int][]string) //活动产业标签
  889. mapActivitySubjectLabel := make(map[int][]string) //活动标的标签
  890. mapActivityIndustrialLabel = cygxService.GetActivityIndustrialLabelByActivityIds(activityIds, 1)
  891. mapActivitySubjectLabel = cygxService.GetActivitySubjectLabelByActivityIds(activityIds, 1)
  892. mapActivitySpeicalIndustrialLabel := make(map[int][]string) //活动产业标签
  893. mapActivitySpeicalSubjectLabel := make(map[int][]string) //活动标的标签
  894. mapActivitySpeicalIndustrialLabel = cygxService.GetActivityIndustrialLabelByActivityIds(activityIds, 2)
  895. mapActivitySpeicalSubjectLabel = cygxService.GetActivitySubjectLabelByActivityIds(activityIds, 2)
  896. mapRsCalendarLabel := make(map[int][]string) //1v1 路演标签
  897. mapRsCalendarLabel = cygxService.GetRsCalendarLabelByRsCalendarIds(rsCalendarIds)
  898. for _, v := range list {
  899. switch v.Source {
  900. case utils.CYGX_OBJ_ARTICLE:
  901. if v.ChartPermissionName == utils.GU_SHOU_NAME || v.ChartPermissionName == utils.CE_LUE_NAME {
  902. v.Tag = v.ChartPermissionName
  903. } else {
  904. v.Tag = strings.Join(maparticleIndustrialLabel[v.SourceId], ",")
  905. if len(maparticleSubjectLabel[v.SourceId]) > 0 {
  906. v.Tag += "," + strings.Join(maparticleSubjectLabel[v.SourceId], ",")
  907. }
  908. }
  909. case utils.CYGX_OBJ_ACTIVITY:
  910. if v.ChartPermissionName == utils.GU_SHOU_NAME || v.ChartPermissionName == utils.CE_LUE_NAME {
  911. v.Tag = v.ChartPermissionName
  912. } else {
  913. v.Tag = strings.Join(mapActivityIndustrialLabel[v.SourceId], ",")
  914. if len(mapActivitySubjectLabel[v.SourceId]) > 0 {
  915. v.Tag += "," + strings.Join(mapActivitySubjectLabel[v.SourceId], ",")
  916. }
  917. }
  918. case utils.CYGX_OBJ_ACTIVITYSPECIAL:
  919. if v.ChartPermissionName == utils.GU_SHOU_NAME || v.ChartPermissionName == utils.CE_LUE_NAME {
  920. v.Tag = v.ChartPermissionName
  921. } else {
  922. v.Tag = strings.Join(mapActivitySpeicalIndustrialLabel[v.SourceId], ",")
  923. if len(mapActivitySpeicalSubjectLabel[v.SourceId]) > 0 {
  924. v.Tag += "," + strings.Join(mapActivitySpeicalSubjectLabel[v.SourceId], ",")
  925. }
  926. }
  927. case utils.CYGX_OBJ_RS_CALENDAR:
  928. if v.ChartPermissionName == utils.GU_SHOU_NAME || v.ChartPermissionName == utils.CE_LUE_NAME {
  929. v.Tag = v.ChartPermissionName
  930. } else {
  931. v.Tag = strings.Join(mapRsCalendarLabel[v.SourceId], ",")
  932. }
  933. }
  934. }
  935. resp.List = list
  936. }
  937. br.Ret = 200
  938. br.Success = true
  939. br.Msg = "获取成功"
  940. br.Data = resp
  941. }