statistic_company_merge.go 25 KB

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