statistic_company_merge.go 25 KB

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