statistic_company_merge.go 25 KB

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