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. newCompanyTotal, err = company.GetIncrementalNewCompanyProductMergeCount(condition1, pars1)
  201. if err != nil && err.Error() != utils.ErrNoRow() {
  202. br.Msg = "获取失败"
  203. br.ErrMsg = "获取失败,Err:" + err.Error()
  204. return
  205. }
  206. if dataType == "新签客户" {
  207. //列表数据数量
  208. total, err := company.GetIncrementalNewCompanyProductMergeCount(condition1, pars1)
  209. if err != nil && err.Error() != utils.ErrNoRow() {
  210. br.Msg = "获取失败"
  211. br.ErrMsg = "获取失败,Err:" + err.Error()
  212. return
  213. }
  214. //列表页数据
  215. tmpList, err := models.GetIncrementalCompanyMergeList(condition1, pars1, startSize, pageSize)
  216. if err != nil {
  217. br.Msg = "获取失败"
  218. br.ErrMsg = "获取失败,Err:" + err.Error()
  219. return
  220. }
  221. list = tmpList
  222. dataTotal = total
  223. }
  224. }
  225. //续约客户数
  226. {
  227. condition1 := condition
  228. pars1 := pars
  229. condition1 += ` AND a.start_date >= ? AND a.start_date <= ? `
  230. pars1 = append(pars1, startDate, endDate)
  231. condition1 += ` AND a.contract_type = ? `
  232. pars1 = append(pars1, "续约合同")
  233. //续约的客户才会查询
  234. if packageDifference != "" {
  235. condition1 += ` AND a.package_difference = ? `
  236. pars1 = append(pars1, packageDifference)
  237. }
  238. ////额外条件(续约合同的起始日期包含在所选时间段内且不包含在新签合同存续期内的客户)
  239. //pars1 = append(pars1, endDate)
  240. total, err := company.GetIncrementalNewCompanyProductMergeCount(condition1, pars1)
  241. if err != nil && err.Error() != utils.ErrNoRow() {
  242. br.Msg = "获取失败"
  243. br.ErrMsg = "获取失败,Err:" + err.Error()
  244. return
  245. }
  246. renewalCompanyTotal = total
  247. if dataType == "续约客户" {
  248. //列表数据数量
  249. total, err := company.GetIncrementalRenewalCompanyProductMergeCount(condition1, pars1)
  250. if err != nil && err.Error() != utils.ErrNoRow() {
  251. br.Msg = "获取失败"
  252. br.ErrMsg = "获取失败,Err:" + err.Error()
  253. return
  254. }
  255. //列表页数据
  256. tmpList, err := models.GetIncrementalCompanyMergeList(condition1, pars1, startSize, pageSize)
  257. if err != nil {
  258. br.Msg = "获取失败"
  259. br.ErrMsg = "获取失败,Err:" + err.Error()
  260. return
  261. }
  262. list = tmpList
  263. dataTotal = total
  264. }
  265. }
  266. //未续约客户数
  267. {
  268. condition1 := condition
  269. pars1 := pars
  270. endDateTime, err := time.Parse(utils.FormatDate, endDate)
  271. if err != nil {
  272. br.Msg = "结束时间异常"
  273. br.ErrMsg = "获取失败,Err:" + err.Error()
  274. return
  275. }
  276. //选择的日期加一天的原因是因为:筛选条件是截止到时分秒的,如果要把选择的这一天也统计进去,那么需要在选择的结束日期基础上加上一天
  277. tryOutEndDate := endDateTime.AddDate(0, 0, 1).Format(utils.FormatDate)
  278. condition1 += ` AND a.create_time >= ? AND a.create_time < ? `
  279. pars1 = append(pars1, startDate, tryOutEndDate)
  280. condition1 += ` AND a.operation = ? `
  281. pars1 = append(pars1, "try_out")
  282. condition1 += ` AND c.status not in ("永续","正式","关闭") `
  283. //未续约已确认数量
  284. notRenewalCondition := condition1
  285. notRenewalPars := pars1
  286. notRenewalCondition += conditionAscribRaiTotal
  287. notRenewalPars = append(notRenewalPars, parsAscribeRaiTotal)
  288. total, err := models.GetIncrementalCompanyCountByOperationRecord(notRenewalCondition, notRenewalPars)
  289. if err != nil && err.Error() != utils.ErrNoRow() {
  290. br.Msg = "获取失败"
  291. br.ErrMsg = "获取失败,Err:" + err.Error()
  292. return
  293. }
  294. notRenewalCompanyTotal = total
  295. //未续约待确认数量
  296. notRenewalToBeCondition := condition1
  297. notRenewalToBePars := pars1
  298. notRenewalToBeCondition += conditionAscribRaiToBeTotal
  299. notRenewalToBePars = append(notRenewalToBePars, parsAscribeRaiTobeTotal)
  300. notRenewalCompanyToBeConfirmTotal, err = models.GetIncrementalCompanyCountByOperationRecord(notRenewalToBeCondition, notRenewalToBePars)
  301. if err != nil && err.Error() != utils.ErrNoRow() {
  302. br.Msg = "获取失败"
  303. br.ErrMsg = "获取失败,Err:" + err.Error()
  304. return
  305. }
  306. condition1 += conditionAscribRai
  307. pars1 = append(pars1, parsAscribeRai)
  308. if dataType == "未续约客户" {
  309. //统计数据
  310. for _, v := range []string{"试用", "非试用"} {
  311. totalCondition1 := condition1
  312. totalPars1 := pars1
  313. var tmpTotal int
  314. if v == "试用" {
  315. totalCondition1 += ` AND c.status = "试用" `
  316. tmpTotal, err = models.GetIncrementalCompanyProductCountByOperationRecord(totalCondition1, totalPars1)
  317. if err != nil && err.Error() != utils.ErrNoRow() {
  318. br.Msg = "获取失败"
  319. br.ErrMsg = "获取失败,Err:" + err.Error()
  320. return
  321. }
  322. notRenewalTryOut = tmpTotal
  323. } else if v == "非试用" {
  324. totalCondition1 += ` AND c.status IN ("冻结","流失") `
  325. tmpTotal, err = models.GetIncrementalCompanyProductCountByOperationRecord(totalCondition1, totalPars1)
  326. if err != nil && err.Error() != utils.ErrNoRow() {
  327. br.Msg = "获取失败"
  328. br.ErrMsg = "获取失败,Err:" + err.Error()
  329. return
  330. }
  331. notRenewalNotTryOut = tmpTotal
  332. }
  333. }
  334. //列表数据数量
  335. if tryOutType == "试用" {
  336. condition1 += ` AND c.status = "试用" `
  337. total = notRenewalTryOut
  338. } else if tryOutType == "非试用" {
  339. condition1 += ` AND c.status IN ("冻结","流失") `
  340. total = notRenewalNotTryOut
  341. }
  342. //total, err := models.GetIncrementalCompanyProductCountByOperationRecord(condition1, pars1)
  343. //if err != nil && err.Error() != utils.ErrNoRow() {
  344. // br.Msg = "获取失败"
  345. // br.ErrMsg = "获取失败,Err:" + err.Error()
  346. // return
  347. //}
  348. //分页total单独计算
  349. total, err = models.GetIncrementalCompanyProductCountByOperationRecord(condition1, pars1)
  350. if err != nil && err.Error() != utils.ErrNoRow() {
  351. br.Msg = "获取失败"
  352. br.ErrMsg = "获取失败,Err:" + err.Error()
  353. return
  354. }
  355. //列表页数据
  356. tmpList, err := models.GetIncrementalCompanyListByOperationRecord(condition1, pars1, startSize, pageSize)
  357. if err != nil {
  358. br.Msg = "获取失败"
  359. br.ErrMsg = "获取失败,Err:" + err.Error()
  360. return
  361. }
  362. var ascribecompanyIds []int
  363. for _, item := range tmpList {
  364. endDateTime, _ := time.Parse(utils.FormatDateTime, item.CreateTime)
  365. item.EndDate = endDateTime.Format(utils.FormatDate)
  366. ascribecompanyIds = append(ascribecompanyIds, item.CompanyId)
  367. }
  368. //归因标签
  369. mapGetCompanyAscribeContent, mapContent := services.GetCompanyAscribeContentMap(ascribecompanyIds)
  370. mapNoRenewedNote := services.GetCompanyNoRenewedNoteMap(ascribecompanyIds)
  371. for _, item := range tmpList {
  372. item.AscribeContent = mapGetCompanyAscribeContent[fmt.Sprint("CID_", item.CompanyId, "PID_", item.ProductId)]
  373. item.Content = mapContent[fmt.Sprint("CID_", item.CompanyId, "PID_", item.ProductId)]
  374. item.IsShowNoRenewedNote = mapNoRenewedNote[fmt.Sprint("CID_", item.CompanyId, "PID_", item.ProductId)]
  375. }
  376. list = tmpList
  377. dataTotal = total
  378. }
  379. }
  380. listLen := len(list)
  381. if listLen == 0 {
  382. list = make([]*models.IncrementalList, 0)
  383. }
  384. mapCompamy := make(map[int]string)
  385. for i := 0; i < listLen; i++ {
  386. item := list[i]
  387. mapCompamy[item.CompanyId] = item.CompanyContractIdGroup
  388. //新增试用不需要计算剩余日期
  389. if dataType != "新增试用" {
  390. //剩余可用天数
  391. endDateTime, _ := time.Parse(utils.FormatDate, item.EndDate)
  392. endDateTime = endDateTime.AddDate(0, 0, 1)
  393. sub := endDateTime.Sub(time.Now())
  394. expireDay := fmt.Sprintf("%v", int(sub.Hours()/24))
  395. list[i].ExpireDay = expireDay
  396. }
  397. }
  398. if dataType == "新签客户" || dataType == "续约客户" {
  399. //合并合同所对应的权限
  400. mappermissionName, err := services.GetCompanyContractPermissionNameMapById(mapCompamy)
  401. if err != nil {
  402. br.Msg = "获取失败"
  403. br.ErrMsg = "获取失败,Err:" + err.Error()
  404. return
  405. }
  406. for _, v := range list {
  407. v.PermissionName = mappermissionName[v.CompanyId]
  408. }
  409. }
  410. page := paging.GetPaging(currentIndex, pageSize, dataTotal)
  411. resp := response.IncrementalCompanyListResp{
  412. Paging: page,
  413. List: list,
  414. TrialTotal: trialTotal,
  415. NewCompanyTotal: newCompanyTotal,
  416. RenewalCompanyTotal: renewalCompanyTotal,
  417. NotRenewalCompanyTotal: notRenewalCompanyTotal,
  418. NotRenewalCompanyToBeConfirmTotal: notRenewalCompanyToBeConfirmTotal,
  419. NotRenewalTryOut: notRenewalTryOut,
  420. NotRenewalNotTryOut: notRenewalNotTryOut,
  421. }
  422. //fmt.Println()
  423. //导出excel
  424. if isExport {
  425. MergeCompanyListListExport(this, dataType, resp, br)
  426. return
  427. }
  428. br.Ret = 200
  429. br.Success = true
  430. br.Msg = "获取成功"
  431. br.Data = resp
  432. }
  433. // IncrementalCompanyListExport 导出增量客户数据报表excel
  434. func MergeCompanyListListExport(this *StatisticCompanyMergerController, dataType string, resp response.IncrementalCompanyListResp, br *models.BaseResponse) {
  435. dir, err := os.Executable()
  436. exPath := filepath.Dir(dir)
  437. downLoadnFilePath := exPath + "/" + time.Now().Format(utils.FormatDateTimeUnSpace) + ".xlsx"
  438. xlsxFile := xlsx.NewFile()
  439. if err != nil {
  440. br.Msg = "生成文件失败"
  441. br.ErrMsg = "生成文件失败"
  442. return
  443. }
  444. style := xlsx.NewStyle()
  445. alignment := xlsx.Alignment{
  446. Horizontal: "center",
  447. Vertical: "center",
  448. WrapText: true,
  449. }
  450. style.Alignment = alignment
  451. style.ApplyAlignment = true
  452. sheel, err := xlsxFile.AddSheet("增量客户数据")
  453. if err != nil {
  454. br.Msg = "新增Sheet失败"
  455. br.ErrMsg = "新增Sheet失败,Err:" + err.Error()
  456. return
  457. }
  458. sheel.SetColWidth(0, 0, 30)
  459. sheel.SetColWidth(1, 1, 15)
  460. sheel.SetColWidth(2, 2, 15)
  461. sheel.SetColWidth(3, 3, 18)
  462. sheel.SetColWidth(4, 4, 40)
  463. sheel.SetColWidth(5, 5, 18)
  464. //统计数据
  465. statisticRow := sheel.AddRow()
  466. cell1 := statisticRow.AddCell()
  467. cell1.SetStyle(style)
  468. cell1.SetValue(fmt.Sprint("新增试用客户数:", resp.TrialTotal))
  469. cell2 := statisticRow.AddCell()
  470. cell2.SetStyle(style)
  471. cell2.SetValue(fmt.Sprint("新签客户数:", resp.NewCompanyTotal))
  472. cell3 := statisticRow.AddCell()
  473. cell3.SetStyle(style)
  474. cell3.SetValue(fmt.Sprint("续约客户数:", resp.RenewalCompanyTotal))
  475. cell4 := statisticRow.AddCell()
  476. cell4.SetStyle(style)
  477. cell4.SetValue(fmt.Sprint("未续约客户数:", resp.NotRenewalCompanyTotal))
  478. //表头
  479. titleRow := sheel.AddRow()
  480. cellName := titleRow.AddCell()
  481. cellName.SetStyle(style)
  482. cellName.SetValue("客户名称")
  483. cellProName := titleRow.AddCell()
  484. cellProName.SetStyle(style)
  485. cellProName.SetValue("客户类型")
  486. cellSellerName := titleRow.AddCell()
  487. cellSellerName.SetStyle(style)
  488. cellSellerName.SetValue("所属销售")
  489. permissionMap := make(map[int][]string)
  490. tmpPermissionMap := make(map[int]map[string][]string)
  491. companyContractIdList := make([]string, 0)
  492. for _, v := range resp.List {
  493. companyContractIdList = append(companyContractIdList, fmt.Sprint(v.CompanyContractId))
  494. }
  495. if dataType == "新签客户" || dataType == "续约客户" {
  496. cellMoney := titleRow.AddCell()
  497. cellMoney.SetStyle(style)
  498. cellMoney.SetValue("合同金额")
  499. cellPermission := titleRow.AddCell()
  500. cellPermission.SetStyle(style)
  501. cellPermission.SetValue("合同品种")
  502. //这么大费周章的目的是为了:权益的品种存在主观、客观的区分,如果一个品种既存在主观,又存在客观,那么就展示品种名称,否则就要列出品种名称+主、客观类型
  503. if len(companyContractIdList) > 0 {
  504. list, tmpErr := company.GetCompanyContractPermissionListByContractIds(strings.Join(companyContractIdList, ","))
  505. if tmpErr != nil {
  506. err = tmpErr
  507. return
  508. }
  509. for _, v := range list {
  510. tmpPermissionNameMap, ok := tmpPermissionMap[v.CompanyContractId]
  511. if ok {
  512. tmpPermissionNameList, ok2 := tmpPermissionNameMap[v.ChartPermissionName]
  513. if ok2 {
  514. tmpPermissionNameList = append(tmpPermissionNameList, v.PermissionRemark)
  515. } else {
  516. tmpPermissionNameList = []string{v.PermissionRemark}
  517. }
  518. tmpPermissionNameMap[v.ChartPermissionName] = tmpPermissionNameList
  519. } else {
  520. tmpPermissionNameMap = make(map[string][]string)
  521. tmpPermissionNameMap[v.ChartPermissionName] = []string{v.PermissionRemark}
  522. }
  523. tmpPermissionMap[v.CompanyContractId] = tmpPermissionNameMap
  524. }
  525. }
  526. }
  527. for companyContractId, tmpPermissionNameMap := range tmpPermissionMap {
  528. tmpPermissionName := ``
  529. tmpPermissionList := []string{}
  530. for tmpChartPermissionName, tmpChartPermissionNameList := range tmpPermissionNameMap {
  531. if len(tmpChartPermissionNameList) > 1 {
  532. tmpPermissionName = tmpChartPermissionName
  533. } else {
  534. tmpPermissionName = tmpChartPermissionNameList[0]
  535. }
  536. tmpPermissionList = append(tmpPermissionList, tmpPermissionName)
  537. }
  538. permissionMap[companyContractId] = tmpPermissionList
  539. }
  540. cellTime := titleRow.AddCell()
  541. cellTime.SetStyle(style)
  542. switch dataType {
  543. case "新增试用":
  544. cellTime.SetValue("新增时间")
  545. case "新签客户":
  546. cellTime.SetValue("签约时间")
  547. case "续约客户":
  548. cellTime.SetValue("续约时间")
  549. case "未续约客户":
  550. cellTime.SetValue("最近合同到期时间")
  551. cellAscribeContent := titleRow.AddCell()
  552. cellAscribeContent.SetStyle(style)
  553. cellAscribeContent.SetValue("不续约归因")
  554. cellContent := titleRow.AddCell()
  555. cellContent.SetStyle(style)
  556. cellContent.SetValue("详细原因")
  557. }
  558. for _, v := range resp.List {
  559. dataRow := sheel.AddRow()
  560. dataRow.SetHeight(20)
  561. cellDataName := dataRow.AddCell()
  562. cellDataName.SetStyle(style)
  563. cellDataName.SetValue(v.CompanyName)
  564. cellDataProName := dataRow.AddCell()
  565. cellDataProName.SetStyle(style)
  566. cellDataProName.SetValue(v.ProductName)
  567. cellDataSellerName := dataRow.AddCell()
  568. cellDataSellerName.SetStyle(style)
  569. cellDataSellerName.SetValue(v.SellerName)
  570. if dataType == "新签客户" || dataType == "续约客户" {
  571. cellDataMoney := dataRow.AddCell()
  572. cellDataMoney.SetStyle(style)
  573. cellDataMoney.SetValue(v.Money)
  574. cellDataPermission := dataRow.AddCell()
  575. cellDataPermission.SetStyle(style)
  576. if permissionStrList, ok := permissionMap[v.CompanyContractId]; ok {
  577. cellDataPermission.SetValue(strings.Join(permissionStrList, ","))
  578. }
  579. }
  580. cellDataTime := dataRow.AddCell()
  581. cellDataTime.SetStyle(style)
  582. switch dataType {
  583. case "新增试用":
  584. cellDataTime.SetValue(v.CreateTime)
  585. case "新签客户":
  586. cellDataTime.SetValue(v.StartDate)
  587. case "续约客户":
  588. cellDataTime.SetValue(v.StartDate)
  589. case "未续约客户":
  590. cellDataTime.SetValue(v.EndDate)
  591. cellAscribeContent := dataRow.AddCell()
  592. cellAscribeContent.SetStyle(style)
  593. cellAscribeContent.SetValue(v.AscribeContent)
  594. cellContent := dataRow.AddCell()
  595. cellContent.SetStyle(style)
  596. cellContent.SetValue(v.Content)
  597. }
  598. }
  599. err = xlsxFile.Save(downLoadnFilePath)
  600. if err != nil {
  601. br.Msg = "保存文件失败"
  602. br.ErrMsg = "保存文件失败"
  603. return
  604. }
  605. randStr := time.Now().Format(utils.FormatDateTimeUnSpace)
  606. downloadFileName := "增量客户数据_" + randStr + ".xlsx"
  607. this.Ctx.Output.Download(downLoadnFilePath, downloadFileName)
  608. defer func() {
  609. os.Remove(downLoadnFilePath)
  610. }()
  611. br.Ret = 200
  612. br.Success = true
  613. br.Msg = "导出成功"
  614. }
  615. // @Title 上一份合同详情
  616. // @Description 上一份合同详情接口
  617. // @Param ComPanyId query int true "公司ID"
  618. // @Success Ret=200 {object} company.GetCompanyContractMergeDetailResp
  619. // @router /merge_company_previous/detail [get]
  620. func (this *StatisticCompanyMergerController) CompanyPreviousDetail() {
  621. br := new(models.BaseResponse).Init()
  622. defer func() {
  623. this.Data["json"] = br
  624. this.ServeJSON()
  625. }()
  626. AdminUser := this.SysUser
  627. if AdminUser == nil {
  628. br.Msg = "请登录"
  629. br.ErrMsg = "请登录,用户信息为空"
  630. br.Ret = 408
  631. return
  632. }
  633. resp := new(company.GetCompanyContractMergeDetailResp)
  634. comPanyId, _ := this.GetInt("ComPanyId")
  635. if comPanyId < 1 {
  636. br.Msg = "请输入公司ID"
  637. return
  638. }
  639. var condition string
  640. var pars []interface{}
  641. condition = " AND company_id = ? ORDER BY start_date DESC LIMIT 1 "
  642. pars = append(pars, comPanyId)
  643. detail, err := company.GetCompanyContractMergeDetail(condition, pars)
  644. if err != nil {
  645. br.Msg = "详情不存在"
  646. br.ErrMsg = "获取失败,Err:" + err.Error()
  647. return
  648. }
  649. pars = make([]interface{}, 0)
  650. condition = " AND company_id = ? AND company_contract_merge_id != ? ORDER BY start_date DESC LIMIT 1 "
  651. pars = append(pars, comPanyId, detail.CompanyContractMergeId)
  652. detailPrevious, err := company.GetCompanyContractMergeDetail(condition, pars)
  653. if err != nil {
  654. br.Msg = "详情不存在"
  655. br.ErrMsg = "获取失败,Err:" + err.Error()
  656. return
  657. }
  658. resp.Detail = detailPrevious
  659. mappermissionName, err := services.GetCompanyContractPermissionNameMapById(map[int]string{detailPrevious.CompanyId: detailPrevious.CompanyContractIdGroup})
  660. if err != nil {
  661. br.Msg = "获取失败"
  662. br.ErrMsg = "获取失败,Err:" + err.Error()
  663. return
  664. }
  665. detailPrevious.PermissionName = mappermissionName[detailPrevious.CompanyId]
  666. br.Ret = 200
  667. br.Success = true
  668. br.Msg = "获取成功"
  669. br.Data = resp
  670. }