statistic_company_merge.go 25 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755
  1. package controllers
  2. import (
  3. "fmt"
  4. "github.com/rdlucklib/rdluck_tools/paging"
  5. "github.com/tealeg/xlsx"
  6. "hongze/hz_crm_api/models"
  7. "hongze/hz_crm_api/models/company"
  8. "hongze/hz_crm_api/models/response"
  9. "hongze/hz_crm_api/services"
  10. "os"
  11. "path/filepath"
  12. "strings"
  13. //"hongze/hz_crm_api/services"
  14. "hongze/hz_crm_api/utils"
  15. //"strings"
  16. "time"
  17. )
  18. // 统计报表模块下权益合同合并
  19. // StatisticReportController 统计报告基类
  20. type StatisticCompanyMergerController struct {
  21. BaseAuthController
  22. }
  23. // MergeCompanyList
  24. // @Title 权益客户统计列表(合同进行合并之后的)
  25. // @Description 权益客户统计列表接口
  26. // @Param PageSize query int true "每页数据条数"
  27. // @Param CurrentIndex query int true "当前页页码,从1开始"
  28. // @Param Keyword query string true "客户名称"
  29. // @Param CompanyType query string true "客户类型:传空字符串或者不传为全部,'ficc','权益'"
  30. // @Param AdminId query string true "销售id,多个用英文逗号隔开,空字符串为全部"
  31. // @Param RegionType query string false "所属区域:传空字符串或者不传为全部,'国内','海外'"
  32. // @Param StartDate query string false "开始日期"
  33. // @Param EndDate query string false "结束日期"
  34. // @Param DataType query string false "报表类型,枚举值:`新增试用`,`新签客户`,`续约客户`,`未续约客户`"
  35. // @Param TryOutType query string false " '试用', '非试用' 非试用即为冻结/流失"
  36. // @Param IsExport query bool false "是否导出excel,默认是false"
  37. // @Param IsConfirm query int false "是否确认续约: -1-默认全部; 0-待确认; 1-已确认"
  38. // @Param CompanyAscribeId query int false "归因ID"
  39. // @Param PackageDifference query string false "和上一份合同的区别,枚举值:`增加套餐`,`减少套餐`,`维持套餐`"
  40. // @Success 200 {object} response.IncrementalCompanyListResp
  41. // @router /merge_company_list [get]
  42. func (this *StatisticCompanyMergerController) MergeCompanyList() {
  43. br := new(models.BaseResponse).Init()
  44. defer func() {
  45. this.Data["json"] = br
  46. this.ServeJSON()
  47. }()
  48. sysUser := this.SysUser
  49. if sysUser == nil {
  50. br.Msg = "请登录"
  51. br.ErrMsg = "请登录,SysUser Is Empty"
  52. br.Ret = 408
  53. return
  54. }
  55. pageSize, _ := this.GetInt("PageSize")
  56. currentIndex, _ := this.GetInt("CurrentIndex")
  57. adminId := this.GetString("AdminId")
  58. regionType := this.GetString("RegionType")
  59. companyType := this.GetString("CompanyType")
  60. dataType := this.GetString("DataType")
  61. tryOutType := this.GetString("TryOutType")
  62. keyword := this.GetString("Keyword")
  63. packageDifference := this.GetString("PackageDifference")
  64. startDate := this.GetString("StartDate")
  65. endDate := this.GetString("EndDate")
  66. isConfirm, _ := this.GetInt("IsConfirm", -1)
  67. companyAscribeId, _ := this.GetInt("CompanyAscribeId", -1)
  68. if dataType != "续约客户" {
  69. packageDifference = "" // 只有续约客户才会有值,过滤前端传过来的脏数据
  70. }
  71. //if startDate == "" || endDate == "" {
  72. // br.Msg = "获取失败,开始日期或结束日期未传"
  73. // br.ErrMsg = "获取失败,开始日期或结束日期未传"
  74. // return
  75. //}
  76. if startDate == "" {
  77. startDate = "2015-01-01"
  78. }
  79. if endDate == "" {
  80. endDate = time.Now().Format(utils.FormatDate)
  81. }
  82. var startSize int
  83. if pageSize <= 0 {
  84. pageSize = utils.PageSize20
  85. }
  86. if currentIndex <= 0 {
  87. currentIndex = 1
  88. }
  89. startSize = utils.StartIndex(currentIndex, pageSize)
  90. //是否导出报表
  91. isExport, _ := this.GetBool("IsExport")
  92. if isExport {
  93. pageSize = 10000
  94. currentIndex = 1
  95. }
  96. var condition string
  97. var pars []interface{}
  98. //条件
  99. if adminId != "" {
  100. condition += ` AND c.seller_id in (` + adminId + `) `
  101. //pars = append(pars, adminId)
  102. } else {
  103. //根据当前角色来获取查询条件
  104. condition, pars = getQueryParams(condition, pars, sysUser, "c.")
  105. }
  106. if regionType != "" {
  107. condition += ` AND b.region_type = ? `
  108. pars = append(pars, regionType)
  109. }
  110. //关键字搜索
  111. if keyword != "" {
  112. condition += ` and b.company_name like "%` + keyword + `%" `
  113. }
  114. var conditionAscribRai string // 处理权益未续约客户检索列表SQL查询条件
  115. var conditionAscribRaiTotal string // 处理权益未续约客户总量查询条件
  116. var conditionAscribRaiToBeTotal string // 处理权益未续约客户待确认总量查询条件
  117. var parsAscribeRai []interface{}
  118. var parsAscribeRaiTotal []interface{} // 处理权益未续约客户总量查询条件
  119. var parsAscribeRaiTobeTotal []interface{} // 处理权益未续约客户待确认总量查询条件
  120. var conditionConfirm string
  121. var parsConfirm []interface{}
  122. companyConfirmList, err := company.GetCompanyNoRenewedAscribeList(conditionConfirm, parsConfirm, 0, 0)
  123. if err != nil && err.Error() != utils.ErrNoRow() {
  124. br.Msg = "获取失败"
  125. br.ErrMsg = "获取失败,GetCompanyNoRenewedAscribeList Err:" + err.Error()
  126. return
  127. }
  128. var noRenewedcompanyIds []int //已经确定未续约的公司ID
  129. if len(companyConfirmList) == 0 {
  130. noRenewedcompanyIds = append(noRenewedcompanyIds, 0) // 给一个不存在的ID
  131. } else {
  132. for _, v := range companyConfirmList {
  133. noRenewedcompanyIds = append(noRenewedcompanyIds, v.CompanyId)
  134. }
  135. }
  136. //是否确认续约 CRM 13.9
  137. conditionAscribRaiTotal += ` AND ( c.company_id IN (` + utils.GetOrmInReplace(len(noRenewedcompanyIds)) + `) OR c.product_id = 1 OR a.create_time < '2023-01-01' ) ` // 已确认
  138. parsAscribeRaiTotal = append(parsAscribeRaiTotal, noRenewedcompanyIds)
  139. conditionAscribRaiToBeTotal += ` AND ( c.company_id NOT IN (` + utils.GetOrmInReplace(len(noRenewedcompanyIds)) + `) AND c.product_id = 2 AND a.create_time >= '2023-01-01' ) ` // 待确认
  140. parsAscribeRaiTobeTotal = append(parsAscribeRaiTobeTotal, noRenewedcompanyIds)
  141. if isConfirm != -1 {
  142. if isConfirm == 0 {
  143. conditionAscribRai += ` AND ( c.company_id NOT IN (` + utils.GetOrmInReplace(len(noRenewedcompanyIds)) + `) AND c.product_id = 2 AND a.create_time >= '2023-01-01' ) ` // 待确认
  144. } else {
  145. conditionAscribRai += ` AND ( c.company_id IN (` + utils.GetOrmInReplace(len(noRenewedcompanyIds)) + `) OR c.product_id = 1 OR a.create_time < '2023-01-01' ) ` // 已确认
  146. }
  147. parsAscribeRai = append(parsAscribeRai, noRenewedcompanyIds)
  148. }
  149. //归因ID CRM 13.9
  150. if companyAscribeId > 0 {
  151. var conditionAscribe string
  152. var parsAscribe []interface{}
  153. conditionAscribe = " AND company_ascribe_id = ? "
  154. parsAscribe = append(parsAscribe, companyAscribeId)
  155. companyNoRenewedAscribeList, err := company.GetCompanyNoRenewedAscribeList(conditionAscribe, parsAscribe, 0, 0)
  156. if err != nil && err.Error() != utils.ErrNoRow() {
  157. br.Msg = "获取失败"
  158. br.ErrMsg = "获取失败,GetCompanyNoRenewedAscribeList Err:" + err.Error()
  159. return
  160. }
  161. var companyIds []int
  162. if len(companyNoRenewedAscribeList) == 0 {
  163. companyIds = append(companyIds, 0) // 给一个不存在的ID
  164. } else {
  165. for _, v := range companyNoRenewedAscribeList {
  166. companyIds = append(companyIds, v.CompanyId)
  167. }
  168. }
  169. conditionAscribRai += ` AND c.company_id IN (` + utils.GetOrmInReplace(len(companyIds)) + `)`
  170. parsAscribeRai = append(parsAscribeRai, companyIds)
  171. }
  172. switch companyType {
  173. case "ficc":
  174. condition += ` AND c.product_id = ? `
  175. pars = append(pars, 1)
  176. case "权益":
  177. condition += ` AND c.product_id = ? `
  178. pars = append(pars, 2)
  179. case "":
  180. default:
  181. br.Msg = "获取失败,客户类型异常"
  182. br.ErrMsg = "获取失败,客户类型异常"
  183. return
  184. }
  185. var list []*models.IncrementalList
  186. //moreListMap := make(map[int][]*models.IncrementalList)
  187. var newCompanyTotal int //新签合同数量
  188. var notRenewalCompanyTotal int //未续约客户数已确认
  189. var notRenewalCompanyToBeConfirmTotal int //未续约客户数待确认
  190. var dataTotal, trialTotal, renewalCompanyTotal int
  191. var notRenewalTryOut, notRenewalNotTryOut int
  192. //新签客户数
  193. {
  194. condition1 := condition
  195. pars1 := pars
  196. condition1 += ` AND a.start_date >= ? AND a.start_date <= ? `
  197. pars1 = append(pars1, startDate, endDate)
  198. condition1 += ` AND a.contract_type = ? `
  199. pars1 = append(pars1, "新签合同")
  200. condition1 += ` AND a.is_best_new = 1 `
  201. newCompanyTotal, err = company.GetIncrementalNewCompanyProductMergeCount(condition1, pars1)
  202. if err != nil && err.Error() != utils.ErrNoRow() {
  203. br.Msg = "获取失败"
  204. br.ErrMsg = "获取失败,Err:" + err.Error()
  205. return
  206. }
  207. if dataType == "新签客户" {
  208. //列表数据数量
  209. total, err := company.GetIncrementalNewCompanyProductMergeCount(condition1, pars1)
  210. if err != nil && err.Error() != utils.ErrNoRow() {
  211. br.Msg = "获取失败"
  212. br.ErrMsg = "获取失败,Err:" + err.Error()
  213. return
  214. }
  215. //列表页数据
  216. tmpList, err := models.GetIncrementalCompanyMergeList(condition1, pars1, startSize, pageSize)
  217. if err != nil {
  218. br.Msg = "获取失败"
  219. br.ErrMsg = "获取失败,Err:" + err.Error()
  220. return
  221. }
  222. list = tmpList
  223. dataTotal = total
  224. }
  225. }
  226. //续约客户数
  227. {
  228. condition1 := condition
  229. pars1 := pars
  230. condition1 += ` AND a.start_date >= ? AND a.start_date <= ? `
  231. pars1 = append(pars1, startDate, endDate)
  232. condition1 += ` AND a.contract_type = ? `
  233. pars1 = append(pars1, "续约合同")
  234. condition1 += ` AND a.is_best_new = 1 `
  235. ////额外条件(续约合同的起始日期包含在所选时间段内且不包含在新签合同存续期内的客户)
  236. //pars1 = append(pars1, endDate)
  237. total, err := company.GetIncrementalNewCompanyProductMergeCount(condition1, pars1)
  238. if err != nil && err.Error() != utils.ErrNoRow() {
  239. br.Msg = "获取失败"
  240. br.ErrMsg = "获取失败,Err:" + err.Error()
  241. return
  242. }
  243. renewalCompanyTotal = total
  244. if dataType == "续约客户" {
  245. //续约的客户才会查询
  246. if packageDifference != "" {
  247. condition1 += ` AND a.package_difference = ? `
  248. pars1 = append(pars1, packageDifference)
  249. }
  250. //列表数据数量
  251. total, err := company.GetIncrementalRenewalCompanyProductMergeCount(condition1, pars1)
  252. if err != nil && err.Error() != utils.ErrNoRow() {
  253. br.Msg = "获取失败"
  254. br.ErrMsg = "获取失败,Err:" + err.Error()
  255. return
  256. }
  257. //列表页数据
  258. tmpList, err := models.GetIncrementalCompanyMergeList(condition1, pars1, startSize, pageSize)
  259. if err != nil {
  260. br.Msg = "获取失败"
  261. br.ErrMsg = "获取失败,Err:" + err.Error()
  262. return
  263. }
  264. list = tmpList
  265. dataTotal = total
  266. }
  267. }
  268. //未续约客户数
  269. {
  270. condition1 := condition
  271. pars1 := pars
  272. endDateTime, err := time.Parse(utils.FormatDate, endDate)
  273. if err != nil {
  274. br.Msg = "结束时间异常"
  275. br.ErrMsg = "获取失败,Err:" + err.Error()
  276. return
  277. }
  278. //选择的日期加一天的原因是因为:筛选条件是截止到时分秒的,如果要把选择的这一天也统计进去,那么需要在选择的结束日期基础上加上一天
  279. tryOutEndDate := endDateTime.AddDate(0, 0, 1).Format(utils.FormatDate)
  280. condition1 += ` AND a.create_time >= ? AND a.create_time < ? `
  281. pars1 = append(pars1, startDate, tryOutEndDate)
  282. condition1 += ` AND a.operation = ? `
  283. pars1 = append(pars1, "try_out")
  284. condition1 += ` AND c.status not in ("永续","正式","关闭") `
  285. //未续约已确认数量
  286. notRenewalCondition := condition1
  287. notRenewalPars := pars1
  288. notRenewalCondition += conditionAscribRaiTotal
  289. notRenewalPars = append(notRenewalPars, parsAscribeRaiTotal)
  290. total, err := models.GetIncrementalCompanyCountByOperationRecord(notRenewalCondition, notRenewalPars)
  291. if err != nil && err.Error() != utils.ErrNoRow() {
  292. br.Msg = "获取失败"
  293. br.ErrMsg = "获取失败,Err:" + err.Error()
  294. return
  295. }
  296. notRenewalCompanyTotal = total
  297. //未续约待确认数量
  298. notRenewalToBeCondition := condition1
  299. notRenewalToBePars := pars1
  300. notRenewalToBeCondition += conditionAscribRaiToBeTotal
  301. notRenewalToBePars = append(notRenewalToBePars, parsAscribeRaiTobeTotal)
  302. notRenewalCompanyToBeConfirmTotal, err = models.GetIncrementalCompanyCountByOperationRecord(notRenewalToBeCondition, notRenewalToBePars)
  303. if err != nil && err.Error() != utils.ErrNoRow() {
  304. br.Msg = "获取失败"
  305. br.ErrMsg = "获取失败,Err:" + err.Error()
  306. return
  307. }
  308. condition1 += conditionAscribRai
  309. pars1 = append(pars1, parsAscribeRai)
  310. if dataType == "未续约客户" {
  311. //统计数据
  312. for _, v := range []string{"试用", "非试用"} {
  313. totalCondition1 := condition1
  314. totalPars1 := pars1
  315. var tmpTotal int
  316. if v == "试用" {
  317. totalCondition1 += ` AND c.status = "试用" `
  318. tmpTotal, err = models.GetIncrementalCompanyProductCountByOperationRecord(totalCondition1, totalPars1)
  319. if err != nil && err.Error() != utils.ErrNoRow() {
  320. br.Msg = "获取失败"
  321. br.ErrMsg = "获取失败,Err:" + err.Error()
  322. return
  323. }
  324. notRenewalTryOut = tmpTotal
  325. } else if v == "非试用" {
  326. totalCondition1 += ` AND c.status IN ("冻结","流失") `
  327. tmpTotal, err = models.GetIncrementalCompanyProductCountByOperationRecord(totalCondition1, totalPars1)
  328. if err != nil && err.Error() != utils.ErrNoRow() {
  329. br.Msg = "获取失败"
  330. br.ErrMsg = "获取失败,Err:" + err.Error()
  331. return
  332. }
  333. notRenewalNotTryOut = tmpTotal
  334. }
  335. }
  336. //列表数据数量
  337. if tryOutType == "试用" {
  338. condition1 += ` AND c.status = "试用" `
  339. total = notRenewalTryOut
  340. } else if tryOutType == "非试用" {
  341. condition1 += ` AND c.status IN ("冻结","流失") `
  342. total = notRenewalNotTryOut
  343. }
  344. //total, err := models.GetIncrementalCompanyProductCountByOperationRecord(condition1, pars1)
  345. //if err != nil && err.Error() != utils.ErrNoRow() {
  346. // br.Msg = "获取失败"
  347. // br.ErrMsg = "获取失败,Err:" + err.Error()
  348. // return
  349. //}
  350. //分页total单独计算
  351. total, err = models.GetIncrementalCompanyProductCountByOperationRecord(condition1, pars1)
  352. if err != nil && err.Error() != utils.ErrNoRow() {
  353. br.Msg = "获取失败"
  354. br.ErrMsg = "获取失败,Err:" + err.Error()
  355. return
  356. }
  357. //列表页数据
  358. tmpList, err := models.GetIncrementalCompanyListByOperationRecord(condition1, pars1, startSize, pageSize)
  359. if err != nil {
  360. br.Msg = "获取失败"
  361. br.ErrMsg = "获取失败,Err:" + err.Error()
  362. return
  363. }
  364. var ascribecompanyIds []int
  365. for _, item := range tmpList {
  366. endDateTime, _ := time.Parse(utils.FormatDateTime, item.CreateTime)
  367. item.EndDate = endDateTime.Format(utils.FormatDate)
  368. ascribecompanyIds = append(ascribecompanyIds, item.CompanyId)
  369. }
  370. //归因标签
  371. mapGetCompanyAscribeContent, mapContent := services.GetCompanyAscribeContentMap(ascribecompanyIds)
  372. mapNoRenewedNote := services.GetCompanyNoRenewedNoteMap(ascribecompanyIds)
  373. for _, item := range tmpList {
  374. item.AscribeContent = mapGetCompanyAscribeContent[fmt.Sprint("CID_", item.CompanyId, "PID_", item.ProductId)]
  375. item.Content = mapContent[fmt.Sprint("CID_", item.CompanyId, "PID_", item.ProductId)]
  376. item.IsShowNoRenewedNote = mapNoRenewedNote[fmt.Sprint("CID_", item.CompanyId, "PID_", item.ProductId)]
  377. }
  378. list = tmpList
  379. dataTotal = total
  380. }
  381. }
  382. listLen := len(list)
  383. if listLen == 0 {
  384. list = make([]*models.IncrementalList, 0)
  385. }
  386. mapCompamy := make(map[int]string)
  387. for i := 0; i < listLen; i++ {
  388. item := list[i]
  389. mapCompamy[item.CompanyId] = item.CompanyContractIdGroup
  390. //新增试用不需要计算剩余日期
  391. if dataType != "新增试用" {
  392. //剩余可用天数
  393. endDateTime, _ := time.Parse(utils.FormatDate, item.EndDate)
  394. endDateTime = endDateTime.AddDate(0, 0, 1)
  395. sub := endDateTime.Sub(time.Now())
  396. expireDay := fmt.Sprintf("%v", int(sub.Hours()/24))
  397. list[i].ExpireDay = expireDay
  398. }
  399. }
  400. if dataType == "新签客户" || dataType == "续约客户" {
  401. //合并合同所对应的权限
  402. mappermissionName, err := services.GetCompanyContractPermissionNameMapById(mapCompamy)
  403. if err != nil {
  404. br.Msg = "获取失败"
  405. br.ErrMsg = "获取失败,Err:" + err.Error()
  406. return
  407. }
  408. for _, v := range list {
  409. v.PermissionName = mappermissionName[v.CompanyId]
  410. }
  411. }
  412. page := paging.GetPaging(currentIndex, pageSize, dataTotal)
  413. resp := response.IncrementalCompanyListResp{
  414. Paging: page,
  415. List: list,
  416. TrialTotal: trialTotal,
  417. NewCompanyTotal: newCompanyTotal,
  418. RenewalCompanyTotal: renewalCompanyTotal,
  419. NotRenewalCompanyTotal: notRenewalCompanyTotal,
  420. NotRenewalCompanyToBeConfirmTotal: notRenewalCompanyToBeConfirmTotal,
  421. NotRenewalTryOut: notRenewalTryOut,
  422. NotRenewalNotTryOut: notRenewalNotTryOut,
  423. }
  424. //fmt.Println()
  425. //导出excel
  426. if isExport {
  427. MergeCompanyListListExport(this, dataType, resp, br)
  428. return
  429. }
  430. br.Ret = 200
  431. br.Success = true
  432. br.Msg = "获取成功"
  433. br.Data = resp
  434. }
  435. // IncrementalCompanyListExport 导出增量客户数据报表excel
  436. func MergeCompanyListListExport(this *StatisticCompanyMergerController, dataType string, resp response.IncrementalCompanyListResp, br *models.BaseResponse) {
  437. dir, err := os.Executable()
  438. exPath := filepath.Dir(dir)
  439. downLoadnFilePath := exPath + "/" + time.Now().Format(utils.FormatDateTimeUnSpace) + ".xlsx"
  440. xlsxFile := xlsx.NewFile()
  441. if err != nil {
  442. br.Msg = "生成文件失败"
  443. br.ErrMsg = "生成文件失败"
  444. return
  445. }
  446. style := xlsx.NewStyle()
  447. alignment := xlsx.Alignment{
  448. Horizontal: "center",
  449. Vertical: "center",
  450. WrapText: true,
  451. }
  452. style.Alignment = alignment
  453. style.ApplyAlignment = true
  454. sheel, err := xlsxFile.AddSheet("增量客户数据")
  455. if err != nil {
  456. br.Msg = "新增Sheet失败"
  457. br.ErrMsg = "新增Sheet失败,Err:" + err.Error()
  458. return
  459. }
  460. sheel.SetColWidth(0, 0, 30)
  461. sheel.SetColWidth(1, 1, 15)
  462. sheel.SetColWidth(2, 2, 15)
  463. sheel.SetColWidth(3, 3, 18)
  464. sheel.SetColWidth(4, 4, 40)
  465. sheel.SetColWidth(5, 5, 18)
  466. //统计数据
  467. statisticRow := sheel.AddRow()
  468. cell1 := statisticRow.AddCell()
  469. cell1.SetStyle(style)
  470. cell1.SetValue(fmt.Sprint("新增试用客户数:", resp.TrialTotal))
  471. cell2 := statisticRow.AddCell()
  472. cell2.SetStyle(style)
  473. cell2.SetValue(fmt.Sprint("新签客户数:", resp.NewCompanyTotal))
  474. cell3 := statisticRow.AddCell()
  475. cell3.SetStyle(style)
  476. cell3.SetValue(fmt.Sprint("续约客户数:", resp.RenewalCompanyTotal))
  477. cell4 := statisticRow.AddCell()
  478. cell4.SetStyle(style)
  479. cell4.SetValue(fmt.Sprint("未续约客户数:", resp.NotRenewalCompanyTotal))
  480. //表头
  481. titleRow := sheel.AddRow()
  482. cellName := titleRow.AddCell()
  483. cellName.SetStyle(style)
  484. cellName.SetValue("客户名称")
  485. cellProName := titleRow.AddCell()
  486. cellProName.SetStyle(style)
  487. cellProName.SetValue("客户类型")
  488. cellSellerName := titleRow.AddCell()
  489. cellSellerName.SetStyle(style)
  490. cellSellerName.SetValue("所属销售")
  491. permissionMap := make(map[int][]string)
  492. tmpPermissionMap := make(map[int]map[string][]string)
  493. companyContractIdList := make([]string, 0)
  494. for _, v := range resp.List {
  495. companyContractIdList = append(companyContractIdList, fmt.Sprint(v.CompanyContractId))
  496. }
  497. if dataType == "新签客户" || dataType == "续约客户" {
  498. cellMoney := titleRow.AddCell()
  499. cellMoney.SetStyle(style)
  500. cellMoney.SetValue("合同金额")
  501. cellPermission := titleRow.AddCell()
  502. cellPermission.SetStyle(style)
  503. cellPermission.SetValue("合同品种")
  504. //这么大费周章的目的是为了:权益的品种存在主观、客观的区分,如果一个品种既存在主观,又存在客观,那么就展示品种名称,否则就要列出品种名称+主、客观类型
  505. if len(companyContractIdList) > 0 {
  506. list, tmpErr := company.GetCompanyContractPermissionListByContractIds(strings.Join(companyContractIdList, ","))
  507. if tmpErr != nil {
  508. err = tmpErr
  509. return
  510. }
  511. for _, v := range list {
  512. tmpPermissionNameMap, ok := tmpPermissionMap[v.CompanyContractId]
  513. if ok {
  514. tmpPermissionNameList, ok2 := tmpPermissionNameMap[v.ChartPermissionName]
  515. if ok2 {
  516. tmpPermissionNameList = append(tmpPermissionNameList, v.PermissionRemark)
  517. } else {
  518. tmpPermissionNameList = []string{v.PermissionRemark}
  519. }
  520. tmpPermissionNameMap[v.ChartPermissionName] = tmpPermissionNameList
  521. } else {
  522. tmpPermissionNameMap = make(map[string][]string)
  523. tmpPermissionNameMap[v.ChartPermissionName] = []string{v.PermissionRemark}
  524. }
  525. tmpPermissionMap[v.CompanyContractId] = tmpPermissionNameMap
  526. }
  527. }
  528. }
  529. for companyContractId, tmpPermissionNameMap := range tmpPermissionMap {
  530. tmpPermissionName := ``
  531. tmpPermissionList := []string{}
  532. for tmpChartPermissionName, tmpChartPermissionNameList := range tmpPermissionNameMap {
  533. if len(tmpChartPermissionNameList) > 1 {
  534. tmpPermissionName = tmpChartPermissionName
  535. } else {
  536. tmpPermissionName = tmpChartPermissionNameList[0]
  537. }
  538. tmpPermissionList = append(tmpPermissionList, tmpPermissionName)
  539. }
  540. permissionMap[companyContractId] = tmpPermissionList
  541. }
  542. cellTime := titleRow.AddCell()
  543. cellTime.SetStyle(style)
  544. switch dataType {
  545. case "新增试用":
  546. cellTime.SetValue("新增时间")
  547. case "新签客户":
  548. cellTime.SetValue("签约时间")
  549. case "续约客户":
  550. cellTime.SetValue("续约时间")
  551. case "未续约客户":
  552. cellTime.SetValue("最近合同到期时间")
  553. cellAscribeContent := titleRow.AddCell()
  554. cellAscribeContent.SetStyle(style)
  555. cellAscribeContent.SetValue("不续约归因")
  556. cellContent := titleRow.AddCell()
  557. cellContent.SetStyle(style)
  558. cellContent.SetValue("详细原因")
  559. }
  560. for _, v := range resp.List {
  561. dataRow := sheel.AddRow()
  562. dataRow.SetHeight(20)
  563. cellDataName := dataRow.AddCell()
  564. cellDataName.SetStyle(style)
  565. cellDataName.SetValue(v.CompanyName)
  566. cellDataProName := dataRow.AddCell()
  567. cellDataProName.SetStyle(style)
  568. cellDataProName.SetValue(v.ProductName)
  569. cellDataSellerName := dataRow.AddCell()
  570. cellDataSellerName.SetStyle(style)
  571. cellDataSellerName.SetValue(v.SellerName)
  572. if dataType == "新签客户" || dataType == "续约客户" {
  573. cellDataMoney := dataRow.AddCell()
  574. cellDataMoney.SetStyle(style)
  575. cellDataMoney.SetValue(v.Money)
  576. cellDataPermission := dataRow.AddCell()
  577. cellDataPermission.SetStyle(style)
  578. if permissionStrList, ok := permissionMap[v.CompanyContractId]; ok {
  579. cellDataPermission.SetValue(strings.Join(permissionStrList, ","))
  580. }
  581. }
  582. cellDataTime := dataRow.AddCell()
  583. cellDataTime.SetStyle(style)
  584. switch dataType {
  585. case "新增试用":
  586. cellDataTime.SetValue(v.CreateTime)
  587. case "新签客户":
  588. cellDataTime.SetValue(v.StartDate)
  589. case "续约客户":
  590. cellDataTime.SetValue(v.StartDate)
  591. case "未续约客户":
  592. cellDataTime.SetValue(v.EndDate)
  593. cellAscribeContent := dataRow.AddCell()
  594. cellAscribeContent.SetStyle(style)
  595. cellAscribeContent.SetValue(v.AscribeContent)
  596. cellContent := dataRow.AddCell()
  597. cellContent.SetStyle(style)
  598. cellContent.SetValue(v.Content)
  599. }
  600. }
  601. err = xlsxFile.Save(downLoadnFilePath)
  602. if err != nil {
  603. br.Msg = "保存文件失败"
  604. br.ErrMsg = "保存文件失败"
  605. return
  606. }
  607. randStr := time.Now().Format(utils.FormatDateTimeUnSpace)
  608. downloadFileName := "增量客户数据_" + randStr + ".xlsx"
  609. this.Ctx.Output.Download(downLoadnFilePath, downloadFileName)
  610. defer func() {
  611. os.Remove(downLoadnFilePath)
  612. }()
  613. br.Ret = 200
  614. br.Success = true
  615. br.Msg = "导出成功"
  616. }
  617. // @Title 上一份合同详情
  618. // @Description 上一份合同详情接口
  619. // @Param ComPanyId query int true "公司ID"
  620. // @Success Ret=200 {object} company.GetCompanyContractMergeDetailResp
  621. // @router /merge_company_previous/detail [get]
  622. func (this *StatisticCompanyMergerController) CompanyPreviousDetail() {
  623. br := new(models.BaseResponse).Init()
  624. defer func() {
  625. this.Data["json"] = br
  626. this.ServeJSON()
  627. }()
  628. AdminUser := this.SysUser
  629. if AdminUser == nil {
  630. br.Msg = "请登录"
  631. br.ErrMsg = "请登录,用户信息为空"
  632. br.Ret = 408
  633. return
  634. }
  635. resp := new(company.GetCompanyContractMergeDetailResp)
  636. comPanyId, _ := this.GetInt("ComPanyId")
  637. if comPanyId < 1 {
  638. br.Msg = "请输入公司ID"
  639. return
  640. }
  641. var condition string
  642. var pars []interface{}
  643. condition = " AND company_id = ? ORDER BY start_date DESC LIMIT 1 "
  644. pars = append(pars, comPanyId)
  645. detail, err := company.GetCompanyContractMergeDetail(condition, pars)
  646. if err != nil {
  647. br.Msg = "详情不存在"
  648. br.ErrMsg = "获取失败,Err:" + err.Error()
  649. return
  650. }
  651. pars = make([]interface{}, 0)
  652. condition = " AND company_id = ? AND company_contract_merge_id != ? ORDER BY start_date DESC LIMIT 1 "
  653. pars = append(pars, comPanyId, detail.CompanyContractMergeId)
  654. detailPrevious, err := company.GetCompanyContractMergeDetail(condition, pars)
  655. if err != nil {
  656. br.Msg = "详情不存在"
  657. br.ErrMsg = "获取失败,Err:" + err.Error()
  658. return
  659. }
  660. resp.Detail = detailPrevious
  661. mappermissionName, err := services.GetCompanyContractPermissionNameMapById(map[int]string{detailPrevious.CompanyId: detailPrevious.CompanyContractIdGroup})
  662. if err != nil {
  663. br.Msg = "获取失败"
  664. br.ErrMsg = "获取失败,Err:" + err.Error()
  665. return
  666. }
  667. detailPrevious.PermissionName = mappermissionName[detailPrevious.CompanyId]
  668. br.Ret = 200
  669. br.Success = true
  670. br.Msg = "获取成功"
  671. br.Data = resp
  672. }