statistic_company_merge.go 48 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454
  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. //"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 == "" {
  72. startDate = "2015-01-01"
  73. }
  74. if endDate == "" {
  75. endDate = time.Now().Format(utils.FormatDate)
  76. }
  77. var startSize int
  78. if pageSize <= 0 {
  79. pageSize = utils.PageSize20
  80. }
  81. if currentIndex <= 0 {
  82. currentIndex = 1
  83. }
  84. startSize = utils.StartIndex(currentIndex, pageSize)
  85. //是否导出报表
  86. isExport, _ := this.GetBool("IsExport")
  87. if isExport {
  88. pageSize = 10000
  89. currentIndex = 1
  90. }
  91. var condition string
  92. var pars []interface{}
  93. //条件
  94. if adminId != "" {
  95. condition += ` AND c.seller_id in (` + adminId + `) `
  96. //pars = append(pars, adminId)
  97. } else {
  98. //根据当前角色来获取查询条件
  99. condition, pars = getQueryParams(condition, pars, sysUser, "c.")
  100. }
  101. if regionType != "" {
  102. condition += ` AND b.region_type = ? `
  103. pars = append(pars, regionType)
  104. }
  105. //关键字搜索
  106. if keyword != "" {
  107. condition += ` and b.company_name like "%` + keyword + `%" `
  108. }
  109. var conditionAscribRai string // 处理权益未续约客户检索列表SQL查询条件
  110. var conditionAscribRaiTotal string // 处理权益未续约客户总量查询条件
  111. var conditionAscribRaiToBeTotal string // 处理权益未续约客户待确认总量查询条件
  112. var parsAscribeRai []interface{}
  113. var parsAscribeRaiTotal []interface{} // 处理权益未续约客户总量查询条件
  114. var parsAscribeRaiTobeTotal []interface{} // 处理权益未续约客户待确认总量查询条件
  115. var conditionConfirm string
  116. var parsConfirm []interface{}
  117. companyConfirmList, err := company.GetCompanyContractNoRenewedAscribeList(conditionConfirm, parsConfirm, 0, 0)
  118. if err != nil && err.Error() != utils.ErrNoRow() {
  119. br.Msg = "获取失败"
  120. br.ErrMsg = "获取失败,GetCompanyNoRenewedAscribeList Err:" + err.Error()
  121. return
  122. }
  123. var noRenewedcompanyContractIds []int //已经确定未续约的公司ID
  124. if len(companyConfirmList) == 0 {
  125. noRenewedcompanyContractIds = append(noRenewedcompanyContractIds, 0) // 给一个不存在的ID
  126. } else {
  127. for _, v := range companyConfirmList {
  128. noRenewedcompanyContractIds = append(noRenewedcompanyContractIds, v.CompanyContractId)
  129. }
  130. }
  131. //是否确认续约 CRM 13.9
  132. conditionAscribRaiTotal += ` AND a.company_contract_id IN (` + utils.GetOrmInReplace(len(noRenewedcompanyContractIds)) + `) ` // 已确认
  133. parsAscribeRaiTotal = append(parsAscribeRaiTotal, noRenewedcompanyContractIds)
  134. conditionAscribRaiToBeTotal += ` AND a.company_contract_id NOT IN (` + utils.GetOrmInReplace(len(noRenewedcompanyContractIds)) + `) ` // 待确认
  135. parsAscribeRaiTobeTotal = append(parsAscribeRaiTobeTotal, noRenewedcompanyContractIds)
  136. if isConfirm != -1 {
  137. if isConfirm == 0 {
  138. conditionAscribRai += ` AND a.company_contract_id NOT IN (` + utils.GetOrmInReplace(len(noRenewedcompanyContractIds)) + `) ` // 待确认
  139. } else {
  140. conditionAscribRai += ` AND a.company_contract_id IN (` + utils.GetOrmInReplace(len(noRenewedcompanyContractIds)) + `) ` // 已确认
  141. }
  142. parsAscribeRai = append(parsAscribeRai, noRenewedcompanyContractIds)
  143. }
  144. //归因ID CRM 13.9
  145. if companyAscribeId > 0 {
  146. var conditionAscribe string
  147. var parsAscribe []interface{}
  148. conditionAscribe = " AND company_ascribe_id = ? "
  149. parsAscribe = append(parsAscribe, companyAscribeId)
  150. companyNoRenewedAscribeList, err := company.GetCompanyContractNoRenewedAscribeList(conditionAscribe, parsAscribe, 0, 0)
  151. if err != nil && err.Error() != utils.ErrNoRow() {
  152. br.Msg = "获取失败"
  153. br.ErrMsg = "获取失败,GetCompanyNoRenewedAscribeList Err:" + err.Error()
  154. return
  155. }
  156. var noRenewedcompanyContractIds []int
  157. if len(companyNoRenewedAscribeList) == 0 {
  158. noRenewedcompanyContractIds = append(noRenewedcompanyContractIds, 0) // 给一个不存在的ID
  159. } else {
  160. for _, v := range companyNoRenewedAscribeList {
  161. noRenewedcompanyContractIds = append(noRenewedcompanyContractIds, v.CompanyContractId)
  162. }
  163. }
  164. conditionAscribRai += ` AND a.company_contract_id IN (` + utils.GetOrmInReplace(len(noRenewedcompanyContractIds)) + `)`
  165. parsAscribeRai = append(parsAscribeRai, noRenewedcompanyContractIds)
  166. }
  167. condition += ` AND c.product_id = ? AND a.status = 1 `
  168. pars = append(pars, 2)
  169. var list []*models.IncrementalList
  170. //moreListMap := make(map[int][]*models.IncrementalList)
  171. var newCompanyTotal int //新签合同数量
  172. var notRenewalCompanyTotal int //未续约客户数已确认
  173. var notRenewalCompanyToBeConfirmTotal int //未续约客户数待确认
  174. var dataTotal, trialTotal, renewalCompanyTotal int
  175. var notRenewalTryOut, notRenewalNotTryOut int
  176. //新签客户数
  177. {
  178. condition1 := condition
  179. pars1 := pars
  180. condition1 += ` AND a.start_date >= ? AND a.start_date <= ? `
  181. pars1 = append(pars1, startDate, endDate)
  182. condition1 += ` AND a.contract_type = ? `
  183. pars1 = append(pars1, "新签合同")
  184. newCompanyTotal, err = company.GetIncrementalNewCompanyProductMergeCount(condition1, pars1)
  185. if err != nil && err.Error() != utils.ErrNoRow() {
  186. br.Msg = "获取失败"
  187. br.ErrMsg = "获取失败,Err:" + err.Error()
  188. return
  189. }
  190. if dataType == "新签客户" {
  191. //列表数据数量
  192. total, err := company.GetIncrementalNewCompanyProductMergeCount(condition1, pars1)
  193. if err != nil && err.Error() != utils.ErrNoRow() {
  194. br.Msg = "获取失败"
  195. br.ErrMsg = "获取失败,Err:" + err.Error()
  196. return
  197. }
  198. //列表页数据
  199. tmpList, err := models.GetIncrementalCompanyMergeList(condition1, pars1, startSize, pageSize)
  200. if err != nil {
  201. br.Msg = "获取失败"
  202. br.ErrMsg = "获取失败,Err:" + err.Error()
  203. return
  204. }
  205. list = tmpList
  206. dataTotal = total
  207. }
  208. }
  209. //续约客户数
  210. {
  211. condition1 := condition
  212. pars1 := pars
  213. condition1 += ` AND a.start_date >= ? AND a.start_date <= ? `
  214. pars1 = append(pars1, startDate, endDate)
  215. condition1 += ` AND a.contract_type = ? `
  216. pars1 = append(pars1, "续约合同")
  217. ////额外条件(续约合同的起始日期包含在所选时间段内且不包含在新签合同存续期内的客户)
  218. //pars1 = append(pars1, endDate)
  219. total, err := company.GetIncrementalNewCompanyProductMergeCount(condition1, pars1)
  220. if err != nil && err.Error() != utils.ErrNoRow() {
  221. br.Msg = "获取失败"
  222. br.ErrMsg = "获取失败,Err:" + err.Error()
  223. return
  224. }
  225. renewalCompanyTotal = total
  226. if dataType == "续约客户" {
  227. //续约的客户才会查询
  228. if packageDifference != "" {
  229. condition1 += ` AND a.package_difference = ? `
  230. pars1 = append(pars1, packageDifference)
  231. }
  232. //列表数据数量
  233. total, err := company.GetIncrementalRenewalCompanyProductMergeCount(condition1, pars1)
  234. if err != nil && err.Error() != utils.ErrNoRow() {
  235. br.Msg = "获取失败"
  236. br.ErrMsg = "获取失败,Err:" + err.Error()
  237. return
  238. }
  239. //列表页数据
  240. tmpList, err := models.GetIncrementalCompanyMergeList(condition1, pars1, startSize, pageSize)
  241. if err != nil {
  242. br.Msg = "获取失败"
  243. br.ErrMsg = "获取失败,Err:" + err.Error()
  244. return
  245. }
  246. list = tmpList
  247. dataTotal = total
  248. }
  249. }
  250. //未续约客户数
  251. {
  252. condition1 := condition
  253. pars1 := pars
  254. condition1 += ` AND a.end_date >= ? AND a.end_date <= ? `
  255. pars1 = append(pars1, startDate, endDate)
  256. //condition1 += ` AND a.operation = ? `
  257. //pars1 = append(pars1, "try_out")
  258. condition1 += ` AND c.status not in ("永续","正式","关闭") `
  259. //未续约已确认数量
  260. notRenewalCondition := condition1
  261. notRenewalPars := pars1
  262. notRenewalCondition += conditionAscribRaiTotal
  263. notRenewalPars = append(notRenewalPars, parsAscribeRaiTotal)
  264. total, err := company.GetIncrementalRenewalCompanyProductMergeCount(notRenewalCondition, notRenewalPars)
  265. if err != nil && err.Error() != utils.ErrNoRow() {
  266. br.Msg = "获取失败"
  267. br.ErrMsg = "获取失败,Err:" + err.Error()
  268. return
  269. }
  270. notRenewalCompanyTotal = total
  271. //未续约待确认数量
  272. notRenewalToBeCondition := condition1
  273. notRenewalToBePars := pars1
  274. notRenewalToBeCondition += conditionAscribRaiToBeTotal
  275. notRenewalToBePars = append(notRenewalToBePars, parsAscribeRaiTobeTotal)
  276. notRenewalCompanyToBeConfirmTotal, err = company.GetIncrementalRenewalCompanyProductMergeCount(notRenewalToBeCondition, notRenewalToBePars)
  277. if err != nil && err.Error() != utils.ErrNoRow() {
  278. br.Msg = "获取失败"
  279. br.ErrMsg = "获取失败,Err:" + err.Error()
  280. return
  281. }
  282. condition1 += conditionAscribRai
  283. pars1 = append(pars1, parsAscribeRai)
  284. if dataType == "未续约客户" {
  285. //统计数据
  286. for _, v := range []string{"试用", "非试用"} {
  287. totalCondition1 := condition1
  288. totalPars1 := pars1
  289. var tmpTotal int
  290. if v == "试用" {
  291. totalCondition1 += ` AND c.status = "试用" `
  292. tmpTotal, err = company.GetIncrementalRenewalCompanyProductMergeCount(totalCondition1, totalPars1)
  293. if err != nil && err.Error() != utils.ErrNoRow() {
  294. br.Msg = "获取失败"
  295. br.ErrMsg = "获取失败,Err:" + err.Error()
  296. return
  297. }
  298. notRenewalTryOut = tmpTotal
  299. } else if v == "非试用" {
  300. totalCondition1 += ` AND c.status IN ("冻结","流失") `
  301. tmpTotal, err = company.GetIncrementalRenewalCompanyProductMergeCount(totalCondition1, totalPars1)
  302. if err != nil && err.Error() != utils.ErrNoRow() {
  303. br.Msg = "获取失败"
  304. br.ErrMsg = "获取失败,Err:" + err.Error()
  305. return
  306. }
  307. notRenewalNotTryOut = tmpTotal
  308. }
  309. }
  310. //列表数据数量
  311. if tryOutType == "试用" {
  312. condition1 += ` AND c.status = "试用" `
  313. total = notRenewalTryOut
  314. } else if tryOutType == "非试用" {
  315. condition1 += ` AND c.status IN ("冻结","流失") `
  316. total = notRenewalNotTryOut
  317. }
  318. //分页total单独计算
  319. total, err = company.GetIncrementalRenewalCompanyProductMergeCount(condition1, pars1)
  320. if err != nil && err.Error() != utils.ErrNoRow() {
  321. br.Msg = "获取失败"
  322. br.ErrMsg = "获取失败,Err:" + err.Error()
  323. return
  324. }
  325. //return
  326. //列表页数据
  327. tmpList, err := models.GetIncrementalCompanyListByOperationRecordMerge(condition1, pars1, startSize, pageSize)
  328. if err != nil {
  329. br.Msg = "获取失败"
  330. br.ErrMsg = "获取失败,Err:" + err.Error()
  331. return
  332. }
  333. var ascribecompanyIds []int
  334. var companyContractIds []int
  335. for _, item := range tmpList {
  336. //endDateTime, _ := time.Parse(utils.FormatDateTime, item.CreateTime)
  337. //item.EndDate = endDateTime.Format(utils.FormatDate)
  338. ascribecompanyIds = append(ascribecompanyIds, item.CompanyId)
  339. companyContractIds = append(companyContractIds, item.CompanyContractId)
  340. }
  341. //合同归因标签
  342. mapGetCompanyAscribeContent, mapContent := services.GetCompanyContractAscribeContentMap(companyContractIds)
  343. mapNoRenewedNote := services.GetCompanyNoRenewedNoteMap(ascribecompanyIds)
  344. for _, item := range tmpList {
  345. item.AscribeContent = mapGetCompanyAscribeContent[item.CompanyContractId]
  346. item.Content = mapContent[item.CompanyContractId]
  347. item.IsShowNoRenewedNote = mapNoRenewedNote[fmt.Sprint("CID_", item.CompanyId, "PID_", item.ProductId)]
  348. }
  349. list = tmpList
  350. dataTotal = total
  351. }
  352. }
  353. listLen := len(list)
  354. if listLen == 0 {
  355. list = make([]*models.IncrementalList, 0)
  356. }
  357. var companyContractIds []int
  358. for i := 0; i < listLen; i++ {
  359. item := list[i]
  360. companyContractIds = append(companyContractIds, item.CompanyContractId)
  361. //新增试用不需要计算剩余日期
  362. if dataType != "新增试用" {
  363. //剩余可用天数
  364. endDateTime, _ := time.Parse(utils.FormatDate, item.EndDate)
  365. endDateTime = endDateTime.AddDate(0, 0, 1)
  366. sub := endDateTime.Sub(time.Now())
  367. expireDay := fmt.Sprintf("%v", int(sub.Hours()/24))
  368. list[i].ExpireDay = expireDay
  369. }
  370. }
  371. //合并合同所对应的权限
  372. mappermissionName, err := cygxService.GetCompanyContractPermissionNameMapById(companyContractIds)
  373. if err != nil {
  374. br.Msg = "获取失败"
  375. br.ErrMsg = "获取失败,Err:" + err.Error()
  376. return
  377. }
  378. for _, v := range list {
  379. v.PermissionName = mappermissionName[v.CompanyContractId]
  380. }
  381. page := paging.GetPaging(currentIndex, pageSize, dataTotal)
  382. resp := response.IncrementalCompanyListResp{
  383. Paging: page,
  384. List: list,
  385. TrialTotal: trialTotal,
  386. NewCompanyTotal: newCompanyTotal,
  387. RenewalCompanyTotal: renewalCompanyTotal,
  388. NotRenewalCompanyTotal: notRenewalCompanyTotal,
  389. NotRenewalCompanyToBeConfirmTotal: notRenewalCompanyToBeConfirmTotal,
  390. NotRenewalTryOut: notRenewalTryOut,
  391. NotRenewalNotTryOut: notRenewalNotTryOut,
  392. }
  393. //fmt.Println()
  394. //导出excel
  395. if isExport {
  396. MergeCompanyListListExport(this, dataType, resp, br)
  397. return
  398. }
  399. br.Ret = 200
  400. br.Success = true
  401. br.Msg = "获取成功"
  402. br.Data = resp
  403. }
  404. // IncrementalCompanyListExport 导出增量客户数据报表excel
  405. func MergeCompanyListListExport(this *StatisticCompanyMergerController, dataType string, resp response.IncrementalCompanyListResp, br *models.BaseResponse) {
  406. dir, err := os.Executable()
  407. exPath := filepath.Dir(dir)
  408. downLoadnFilePath := exPath + "/" + time.Now().Format(utils.FormatDateTimeUnSpace) + ".xlsx"
  409. xlsxFile := xlsx.NewFile()
  410. if err != nil {
  411. br.Msg = "生成文件失败"
  412. br.ErrMsg = "生成文件失败"
  413. return
  414. }
  415. style := xlsx.NewStyle()
  416. alignment := xlsx.Alignment{
  417. Horizontal: "center",
  418. Vertical: "center",
  419. WrapText: true,
  420. }
  421. style.Alignment = alignment
  422. style.ApplyAlignment = true
  423. sheel, err := xlsxFile.AddSheet("增量客户数据")
  424. if err != nil {
  425. br.Msg = "新增Sheet失败"
  426. br.ErrMsg = "新增Sheet失败,Err:" + err.Error()
  427. return
  428. }
  429. sheel.SetColWidth(0, 0, 30)
  430. sheel.SetColWidth(1, 1, 15)
  431. sheel.SetColWidth(2, 2, 15)
  432. sheel.SetColWidth(3, 3, 18)
  433. sheel.SetColWidth(4, 4, 40)
  434. sheel.SetColWidth(5, 5, 18)
  435. //统计数据
  436. statisticRow := sheel.AddRow()
  437. cell1 := statisticRow.AddCell()
  438. cell1.SetStyle(style)
  439. cell1.SetValue(fmt.Sprint("新增试用客户数:", resp.TrialTotal))
  440. cell2 := statisticRow.AddCell()
  441. cell2.SetStyle(style)
  442. cell2.SetValue(fmt.Sprint("新签客户数:", resp.NewCompanyTotal))
  443. cell3 := statisticRow.AddCell()
  444. cell3.SetStyle(style)
  445. cell3.SetValue(fmt.Sprint("续约客户数:", resp.RenewalCompanyTotal))
  446. cell4 := statisticRow.AddCell()
  447. cell4.SetStyle(style)
  448. cell4.SetValue(fmt.Sprint("未续约客户数:", resp.NotRenewalCompanyTotal))
  449. //表头
  450. titleRow := sheel.AddRow()
  451. cellName := titleRow.AddCell()
  452. cellName.SetStyle(style)
  453. cellName.SetValue("客户名称")
  454. cellProName := titleRow.AddCell()
  455. cellProName.SetStyle(style)
  456. cellProName.SetValue("客户类型")
  457. cellSellerName := titleRow.AddCell()
  458. cellSellerName.SetStyle(style)
  459. cellSellerName.SetValue("所属销售")
  460. cellMoney := titleRow.AddCell()
  461. cellMoney.SetStyle(style)
  462. cellMoney.SetValue("合同金额")
  463. cellTime := titleRow.AddCell()
  464. cellTime.SetStyle(style)
  465. switch dataType {
  466. case "新增试用":
  467. cellTime.SetValue("新增时间")
  468. case "新签客户":
  469. cellTime.SetValue("签约时间")
  470. case "续约客户":
  471. cellTime.SetValue("续约时间")
  472. case "未续约客户":
  473. cellTime.SetValue("最近合同到期时间")
  474. cellAscribeContent := titleRow.AddCell()
  475. cellAscribeContent.SetStyle(style)
  476. cellAscribeContent.SetValue("不续约归因")
  477. cellContent := titleRow.AddCell()
  478. cellContent.SetStyle(style)
  479. cellContent.SetValue("详细原因")
  480. }
  481. cellPermissionName := titleRow.AddCell()
  482. cellPermissionName.SetStyle(style)
  483. cellPermissionName.SetValue("签约套餐")
  484. for _, v := range resp.List {
  485. dataRow := sheel.AddRow()
  486. dataRow.SetHeight(20)
  487. cellDataName := dataRow.AddCell()
  488. cellDataName.SetStyle(style)
  489. cellDataName.SetValue(v.CompanyName)
  490. cellDataProName := dataRow.AddCell()
  491. cellDataProName.SetStyle(style)
  492. cellDataProName.SetValue(v.ProductName)
  493. cellDataSellerName := dataRow.AddCell()
  494. cellDataSellerName.SetStyle(style)
  495. cellDataSellerName.SetValue(v.SellerName)
  496. //if dataType == "新签客户" || dataType == "续约客户" {
  497. cellDataMoney := dataRow.AddCell()
  498. cellDataMoney.SetStyle(style)
  499. cellDataMoney.SetValue(v.Money)
  500. //}
  501. cellDataTime := dataRow.AddCell()
  502. cellDataTime.SetStyle(style)
  503. switch dataType {
  504. case "新增试用":
  505. cellDataTime.SetValue(v.CreateTime)
  506. case "新签客户":
  507. cellDataTime.SetValue(v.StartDate)
  508. case "续约客户":
  509. cellDataTime.SetValue(v.StartDate)
  510. case "未续约客户":
  511. cellDataTime.SetValue(v.EndDate)
  512. cellAscribeContent := dataRow.AddCell()
  513. cellAscribeContent.SetStyle(style)
  514. cellAscribeContent.SetValue(v.AscribeContent)
  515. cellContent := dataRow.AddCell()
  516. cellContent.SetStyle(style)
  517. cellContent.SetValue(v.Content)
  518. }
  519. cellDataPermissionName := dataRow.AddCell()
  520. cellDataPermissionName.SetStyle(style)
  521. cellDataPermissionName.SetValue(v.PermissionName)
  522. }
  523. err = xlsxFile.Save(downLoadnFilePath)
  524. if err != nil {
  525. br.Msg = "保存文件失败"
  526. br.ErrMsg = "保存文件失败"
  527. return
  528. }
  529. randStr := time.Now().Format(utils.FormatDateTimeUnSpace)
  530. downloadFileName := dataType + "数据_" + randStr + ".xlsx"
  531. this.Ctx.Output.Download(downLoadnFilePath, downloadFileName)
  532. defer func() {
  533. os.Remove(downLoadnFilePath)
  534. }()
  535. br.Ret = 200
  536. br.Success = true
  537. br.Msg = "导出成功"
  538. }
  539. // @Title 上一份合同详情
  540. // @Description 上一份合同详情接口
  541. // @Param CompanyContractId query int true "合同ID"
  542. // @Success Ret=200 {object} company.GetCompanyContractMergeDetailResp
  543. // @router /merge_company_previous/detail [get]
  544. func (this *StatisticCompanyMergerController) CompanyPreviousDetail() {
  545. br := new(models.BaseResponse).Init()
  546. defer func() {
  547. this.Data["json"] = br
  548. this.ServeJSON()
  549. }()
  550. AdminUser := this.SysUser
  551. if AdminUser == nil {
  552. br.Msg = "请登录"
  553. br.ErrMsg = "请登录,用户信息为空"
  554. br.Ret = 408
  555. return
  556. }
  557. resp := new(company.GetCompanyContractDetailResp)
  558. companyContractId, _ := this.GetInt("CompanyContractId")
  559. if companyContractId < 1 {
  560. br.Msg = "请输入合同ID"
  561. return
  562. }
  563. var condition string
  564. var pars []interface{}
  565. //获取最新的一条到期的合同信息
  566. condition = " AND company_contract_id = ? "
  567. pars = append(pars, companyContractId)
  568. detail, err := company.GetCompanyContracDetail(condition, pars)
  569. if err != nil {
  570. br.Msg = "详情不存在"
  571. br.ErrMsg = "获取失败,Err:" + err.Error()
  572. return
  573. }
  574. //获取前一份合同的信息
  575. pars = make([]interface{}, 0)
  576. condition = " AND company_id = ? AND company_contract_id < ? AND status = 1 AND product_id = 2 ORDER BY company_contract_id DESC LIMIT 1 "
  577. pars = append(pars, detail.CompanyId, companyContractId)
  578. detailPrevious, err := company.GetCompanyContracDetail(condition, pars)
  579. if err != nil {
  580. br.Msg = "详情不存在"
  581. br.ErrMsg = "获取失败,Err:" + err.Error()
  582. return
  583. }
  584. //合并合同所对应的权限
  585. mappermissionName, err := cygxService.GetCompanyContractPermissionNameMapById([]int{detailPrevious.CompanyContractId})
  586. if err != nil {
  587. br.Msg = "获取失败"
  588. br.ErrMsg = "获取失败,Err:" + err.Error()
  589. return
  590. }
  591. detailPrevious.PermissionName = mappermissionName[detailPrevious.CompanyContractId]
  592. resp.Detail = detailPrevious
  593. br.Ret = 200
  594. br.Success = true
  595. br.Msg = "获取成功"
  596. br.Data = resp
  597. }
  598. // @Title 权益行业套餐统计
  599. // @Description 权益客户统计列表接口
  600. // @Param PageSize query int true "每页数据条数"
  601. // @Param CurrentIndex query int true "当前页页码,从1开始"
  602. // @Param Keyword query string true "客户名称"
  603. // @Param AdminId query string true "销售id,多个用英文逗号隔开,空字符串为全部"
  604. // @Param StartDate query string false "开始日期"
  605. // @Param EndDate query string false "结束日期"
  606. // @Param DataType query string false "报表类型,枚举值:`行业新签`,`行业续约`,`行业未续约`"
  607. // @Param PermissionName query string false "行业权限名称"
  608. // @Param IsExport query bool false "是否导出excel,默认是false"
  609. // @Success 200 {object} response.IncrementalCompanyListResp
  610. // @router /merge_company/company_contract_permission/list [get]
  611. func (this *StatisticCompanyMergerController) CompanyContractPermissionList() {
  612. br := new(models.BaseResponse).Init()
  613. defer func() {
  614. this.Data["json"] = br
  615. this.ServeJSON()
  616. }()
  617. sysUser := this.SysUser
  618. if sysUser == nil {
  619. br.Msg = "请登录"
  620. br.ErrMsg = "请登录,SysUser Is Empty"
  621. br.Ret = 408
  622. return
  623. }
  624. pageSize, _ := this.GetInt("PageSize")
  625. currentIndex, _ := this.GetInt("CurrentIndex")
  626. adminId := this.GetString("AdminId")
  627. regionType := this.GetString("RegionType")
  628. //companyType := this.GetString("CompanyType")
  629. dataType := this.GetString("DataType")
  630. keyword := this.GetString("Keyword")
  631. startDate := this.GetString("StartDate")
  632. endDate := this.GetString("EndDate")
  633. permissionName := this.GetString("PermissionName")
  634. if permissionName == "" { //默认所筛选行业为医药
  635. permissionName = "医药"
  636. }
  637. //if startDate == "" || endDate == "" {
  638. // br.Msg = "获取失败,开始日期或结束日期未传"
  639. // br.ErrMsg = "获取失败,开始日期或结束日期未传"
  640. // return
  641. //}
  642. if startDate == "" {
  643. startDate = "2015-01-01"
  644. }
  645. if endDate == "" {
  646. endDate = time.Now().Format(utils.FormatDate)
  647. }
  648. var startSize int
  649. if pageSize <= 0 {
  650. pageSize = utils.PageSize20
  651. }
  652. if currentIndex <= 0 {
  653. currentIndex = 1
  654. }
  655. startSize = utils.StartIndex(currentIndex, pageSize)
  656. //是否导出报表
  657. isExport, _ := this.GetBool("IsExport")
  658. if isExport {
  659. pageSize = 10000
  660. currentIndex = 1
  661. permissionName = "" //点击下载的时候不做行业筛选
  662. }
  663. var condition string
  664. var pars []interface{}
  665. //条件
  666. if adminId != "" {
  667. condition += ` AND c.seller_id in (` + adminId + `) `
  668. //pars = append(pars, adminId)
  669. } else {
  670. //根据当前角色来获取查询条件
  671. condition, pars = getQueryParams(condition, pars, sysUser, "c.")
  672. }
  673. if regionType != "" {
  674. condition += ` AND b.region_type = ? `
  675. pars = append(pars, regionType)
  676. }
  677. //关键字搜索
  678. if keyword != "" {
  679. condition += ` and b.company_name like "%` + keyword + `%" `
  680. }
  681. var conditionAscribRai string // 处理权益未续约客户检索列表SQL查询条件
  682. var conditionAscribRaiTotal string // 处理权益未续约客户总量查询条件
  683. var parsAscribeRai []interface{}
  684. var parsAscribeRaiTotal []interface{} // 处理权益未续约客户总量查询条件
  685. condition += ` AND c.product_id = ? AND a.status = 1 `
  686. pars = append(pars, 2)
  687. var list []*models.IncrementalList
  688. var listPessionGroup []*models.CompanyContractPermissionNameGroupCountResp
  689. var newCompanyTotal int //新签合同数量
  690. var notRenewalCompanyTotal int //未续约客户数已确认
  691. var notRenewalCompanyToBeConfirmTotal int //未续约客户数待确认
  692. var dataTotal, trialTotal, renewalCompanyTotal int
  693. var notRenewalTryOut, notRenewalNotTryOut int
  694. //if dataType == "行业未续约" {
  695. // condition += ` AND a.end_date >= ? AND a.end_date <= ? `
  696. // pars = append(pars, startDate, endDate)
  697. //} else {
  698. // condition += ` AND a.start_date >= ? AND a.start_date <= ? `
  699. // pars = append(pars, startDate, endDate)
  700. //}
  701. //
  702. //conditionPerssion := condition
  703. //parsPerssion := pars
  704. //conditionPerssion += ` AND d.permission_name IN ('医药','消费','科技','智造','策略','买方研选')`
  705. //
  706. //listPessionGroup, err := models.GetCompanyContractPermissionNameGroupCount(conditionPerssion, parsPerssion)
  707. //if err != nil && err.Error() != utils.ErrNoRow() {
  708. // br.Msg = "获取失败"
  709. // br.ErrMsg = "获取失败,Err:" + err.Error()
  710. // return
  711. //}
  712. //if permissionName == "" {
  713. condition += ` AND d.permission_name IN ('医药','消费','科技','智造','策略','买方研选')`
  714. //}
  715. var err error
  716. //新签客户数
  717. {
  718. condition1 := condition
  719. pars1 := pars
  720. condition1 += ` AND a.start_date >= ? AND a.start_date <= ? `
  721. pars1 = append(pars1, startDate, endDate)
  722. condition1 += ` AND d.contract_type = ? `
  723. pars1 = append(pars1, "行业新签")
  724. newCompanyTotal, err = company.GetIncrementalNewCompanyProductPermissionCount(condition1, pars1)
  725. if err != nil && err.Error() != utils.ErrNoRow() {
  726. br.Msg = "获取失败"
  727. br.ErrMsg = "获取失败,Err:" + err.Error()
  728. return
  729. }
  730. if dataType == "行业新签" {
  731. conditionPerssion := condition1
  732. parsPerssion := pars1
  733. conditionPerssion += ` AND d.permission_name IN ('医药','消费','科技','智造','策略','买方研选')`
  734. listPessionGroup, err = models.GetCompanyContractPermissionNameGroupCount(conditionPerssion, parsPerssion)
  735. if err != nil && err.Error() != utils.ErrNoRow() {
  736. br.Msg = "获取失败"
  737. br.ErrMsg = "获取失败,Err:" + err.Error()
  738. return
  739. }
  740. //行业筛选查询
  741. if permissionName != "" {
  742. condition1 += ` AND d.permission_name = ? `
  743. pars1 = append(pars1, permissionName)
  744. }
  745. total, err := company.GetIncrementalNewCompanyProductPermissionCount(condition1, pars1)
  746. if err != nil && err.Error() != utils.ErrNoRow() {
  747. br.Msg = "获取失败"
  748. br.ErrMsg = "获取失败,Err:" + err.Error()
  749. return
  750. }
  751. //列表页数据
  752. tmpList, err := models.GetIncrementalCompanyPermissionList(condition1, pars1, startSize, pageSize)
  753. if err != nil {
  754. br.Msg = "获取失败"
  755. br.ErrMsg = "获取失败,Err:" + err.Error()
  756. return
  757. }
  758. list = tmpList
  759. dataTotal = total
  760. }
  761. }
  762. //续约客户数
  763. {
  764. condition1 := condition
  765. pars1 := pars
  766. condition1 += ` AND a.start_date >= ? AND a.start_date <= ? `
  767. pars1 = append(pars1, startDate, endDate)
  768. condition1 += ` AND d.contract_type = ? `
  769. pars1 = append(pars1, "行业续约")
  770. ////额外条件(续约合同的起始日期包含在所选时间段内且不包含在新签合同存续期内的客户)
  771. //pars1 = append(pars1, endDate)
  772. total, err := company.GetIncrementalNewCompanyProductPermissionCount(condition1, pars1)
  773. if err != nil && err.Error() != utils.ErrNoRow() {
  774. br.Msg = "获取失败"
  775. br.ErrMsg = "获取失败,Err:" + err.Error()
  776. return
  777. }
  778. renewalCompanyTotal = total
  779. if dataType == "行业续约" {
  780. conditionPerssion := condition1
  781. parsPerssion := pars1
  782. conditionPerssion += ` AND d.permission_name IN ('医药','消费','科技','智造','策略','买方研选')`
  783. listPessionGroup, err = models.GetCompanyContractPermissionNameGroupCount(conditionPerssion, parsPerssion)
  784. if err != nil && err.Error() != utils.ErrNoRow() {
  785. br.Msg = "获取失败"
  786. br.ErrMsg = "获取失败,Err:" + err.Error()
  787. return
  788. }
  789. //行业筛选查询
  790. if permissionName != "" {
  791. condition1 += ` AND d.permission_name = ? `
  792. pars1 = append(pars1, permissionName)
  793. }
  794. //列表数据数量
  795. total, err := company.GetIncrementalNewCompanyProductPermissionCount(condition1, pars1)
  796. if err != nil && err.Error() != utils.ErrNoRow() {
  797. br.Msg = "获取失败"
  798. br.ErrMsg = "获取失败,Err:" + err.Error()
  799. return
  800. }
  801. //列表页数据
  802. tmpList, err := models.GetIncrementalCompanyPermissionList(condition1, pars1, startSize, pageSize)
  803. if err != nil {
  804. br.Msg = "获取失败"
  805. br.ErrMsg = "获取失败,Err:" + err.Error()
  806. return
  807. }
  808. list = tmpList
  809. dataTotal = total
  810. }
  811. }
  812. //return
  813. //行业未续约
  814. {
  815. condition1 := condition
  816. pars1 := pars
  817. condition1 += ` AND a.end_date >= ? AND a.end_date <= ? `
  818. pars1 = append(pars1, startDate, endDate)
  819. condition1 += ` AND c.status not in ("永续","正式","关闭") `
  820. //未续约数量
  821. notRenewalCondition := condition1
  822. notRenewalPars := pars1
  823. notRenewalCondition += conditionAscribRaiTotal
  824. notRenewalPars = append(notRenewalPars, parsAscribeRaiTotal)
  825. total, err := company.GetIncrementalNewCompanyProductPermissionCount(notRenewalCondition, notRenewalPars)
  826. if err != nil && err.Error() != utils.ErrNoRow() {
  827. br.Msg = "获取失败"
  828. br.ErrMsg = "获取失败,Err:" + err.Error()
  829. return
  830. }
  831. notRenewalCompanyTotal = total
  832. condition1 += conditionAscribRai
  833. pars1 = append(pars1, parsAscribeRai)
  834. if dataType == "行业未续约" {
  835. conditionPerssion := condition1
  836. parsPerssion := pars1
  837. conditionPerssion += ` AND d.permission_name IN ('医药','消费','科技','智造','策略','买方研选')`
  838. listPessionGroup, err = models.GetCompanyContractPermissionNameGroupCount(conditionPerssion, parsPerssion)
  839. if err != nil && err.Error() != utils.ErrNoRow() {
  840. br.Msg = "获取失败"
  841. br.ErrMsg = "获取失败,Err:" + err.Error()
  842. return
  843. }
  844. //行业筛选查询
  845. if permissionName != "" {
  846. condition1 += ` AND d.permission_name = ? `
  847. pars1 = append(pars1, permissionName)
  848. }
  849. //分页total单独计算
  850. total, err = company.GetIncrementalNewCompanyProductPermissionCount(condition1, pars1)
  851. if err != nil && err.Error() != utils.ErrNoRow() {
  852. br.Msg = "获取失败"
  853. br.ErrMsg = "获取失败,Err:" + err.Error()
  854. return
  855. }
  856. //return
  857. //列表页数据
  858. tmpList, err := models.GetIncrementalCompanyPermissionList(condition1, pars1, startSize, pageSize)
  859. if err != nil {
  860. br.Msg = "获取失败"
  861. br.ErrMsg = "获取失败,Err:" + err.Error()
  862. return
  863. }
  864. list = tmpList
  865. dataTotal = total
  866. }
  867. }
  868. listLen := len(list)
  869. if listLen == 0 {
  870. list = make([]*models.IncrementalList, 0)
  871. }
  872. var companyContractIds []int
  873. var companyIds []int
  874. for i := 0; i < listLen; i++ {
  875. item := list[i]
  876. companyContractIds = append(companyContractIds, item.CompanyContractId)
  877. companyIds = append(companyIds, item.CompanyId)
  878. //新增试用不需要计算剩余日期
  879. if dataType != "新增试用" {
  880. //剩余可用天数
  881. endDateTime, _ := time.Parse(utils.FormatDate, item.EndDate)
  882. endDateTime = endDateTime.AddDate(0, 0, 1)
  883. sub := endDateTime.Sub(time.Now())
  884. expireDay := fmt.Sprintf("%v", int(sub.Hours()/24))
  885. list[i].ExpireDay = expireDay
  886. }
  887. }
  888. //行业未续约 需要处理公司对应行业权限下的权限状态
  889. if dataType == "行业未续约" {
  890. mappermissionNameStatus, err := cygxService.GetCompanyPermissionNameStatusMapByCompanyId(companyIds)
  891. if err != nil {
  892. br.Msg = "获取失败"
  893. br.ErrMsg = "获取失败,Err:" + err.Error()
  894. return
  895. }
  896. for _, v := range list {
  897. v.PermissionNameStatus = mappermissionNameStatus[fmt.Sprint(v.CompanyId, v.PermissionNameExport)]
  898. }
  899. }
  900. //合并合同所对应的权限
  901. mappermissionName, err := cygxService.GetCompanyContractPermissionNameMapById(companyContractIds)
  902. if err != nil {
  903. br.Msg = "获取失败"
  904. br.ErrMsg = "获取失败,Err:" + err.Error()
  905. return
  906. }
  907. for _, v := range list {
  908. v.PermissionName = mappermissionName[v.CompanyContractId]
  909. }
  910. //处理展示顺序
  911. permissionNameSlice := []string{"医药", "消费", "科技", "智造", "策略", "买方研选"}
  912. var itemspermissionNameSlice []*models.CompanyContractPermissionNameGroupCountResp
  913. for _, vName := range permissionNameSlice {
  914. item := new(models.CompanyContractPermissionNameGroupCountResp)
  915. for _, v := range listPessionGroup {
  916. if v.PermissionName != vName {
  917. continue
  918. }
  919. item.Total = v.Total
  920. }
  921. item.PermissionName = vName
  922. itemspermissionNameSlice = append(itemspermissionNameSlice, item)
  923. }
  924. page := paging.GetPaging(currentIndex, pageSize, dataTotal)
  925. resp := response.IncrementalCompanyListResp{
  926. Paging: page,
  927. ListPermissionName: itemspermissionNameSlice,
  928. List: list,
  929. TrialTotal: trialTotal,
  930. NewCompanyTotal: newCompanyTotal,
  931. RenewalCompanyTotal: renewalCompanyTotal,
  932. NotRenewalCompanyTotal: notRenewalCompanyTotal,
  933. NotRenewalCompanyToBeConfirmTotal: notRenewalCompanyToBeConfirmTotal,
  934. NotRenewalTryOut: notRenewalTryOut,
  935. NotRenewalNotTryOut: notRenewalNotTryOut,
  936. }
  937. //fmt.Println()
  938. //导出excel
  939. if isExport {
  940. PermissionCompanyListListExport(this, dataType, resp, br)
  941. return
  942. }
  943. br.Ret = 200
  944. br.Success = true
  945. br.Msg = "获取成功"
  946. br.Data = resp
  947. }
  948. // PermissionCompanyListListExport 导出增量客户数据报表excel
  949. func PermissionCompanyListListExport(this *StatisticCompanyMergerController, dataType string, resp response.IncrementalCompanyListResp, br *models.BaseResponse) {
  950. dir, err := os.Executable()
  951. exPath := filepath.Dir(dir)
  952. downLoadnFilePath := exPath + "/" + time.Now().Format(utils.FormatDateTimeUnSpace) + ".xlsx"
  953. xlsxFile := xlsx.NewFile()
  954. if err != nil {
  955. br.Msg = "生成文件失败"
  956. br.ErrMsg = "生成文件失败"
  957. return
  958. }
  959. style := xlsx.NewStyle()
  960. alignment := xlsx.Alignment{
  961. Horizontal: "center",
  962. Vertical: "center",
  963. WrapText: true,
  964. }
  965. permissionNameSlice := []string{"医药", "消费", "科技", "智造", "策略", "买方研选"}
  966. mapExport := make(map[string][]*models.IncrementalList)
  967. type IncrementalCompanyListExport struct {
  968. PermissionName string `description:"权限名"`
  969. List []*models.IncrementalList
  970. }
  971. for _, v := range resp.List {
  972. if v.PermissionNameExport == "" {
  973. continue
  974. }
  975. mapExport[v.PermissionNameExport] = append(mapExport[v.PermissionNameExport], v)
  976. }
  977. style.Alignment = alignment
  978. style.ApplyAlignment = true
  979. for _, vName := range permissionNameSlice {
  980. sheel, err := xlsxFile.AddSheet(vName)
  981. if err != nil {
  982. br.Msg = "新增Sheet失败"
  983. br.ErrMsg = "新增Sheet失败,Err:" + err.Error()
  984. return
  985. }
  986. sheel.SetColWidth(0, 0, 30)
  987. sheel.SetColWidth(1, 1, 15)
  988. sheel.SetColWidth(2, 2, 15)
  989. sheel.SetColWidth(3, 3, 18)
  990. sheel.SetColWidth(4, 4, 40)
  991. sheel.SetColWidth(5, 5, 18)
  992. //表头
  993. titleRow := sheel.AddRow()
  994. cellName := titleRow.AddCell()
  995. cellName.SetStyle(style)
  996. cellName.SetValue("客户名称")
  997. cellSellerName := titleRow.AddCell()
  998. cellSellerName.SetStyle(style)
  999. cellSellerName.SetValue("所属销售")
  1000. cellMoney := titleRow.AddCell()
  1001. cellMoney.SetStyle(style)
  1002. cellMoney.SetValue("合同金额")
  1003. cellTime := titleRow.AddCell()
  1004. cellTime.SetStyle(style)
  1005. cellTime.SetValue("合同期限")
  1006. cellPermissionName := titleRow.AddCell()
  1007. cellPermissionName.SetStyle(style)
  1008. cellPermissionName.SetValue("签约套餐")
  1009. if dataType == "行业未续约" {
  1010. cellPermissionNameStatus := titleRow.AddCell()
  1011. cellPermissionNameStatus.SetStyle(style)
  1012. cellPermissionNameStatus.SetValue("当前行业状态")
  1013. cellCompanyProductStatus := titleRow.AddCell()
  1014. cellCompanyProductStatus.SetStyle(style)
  1015. cellCompanyProductStatus.SetValue("当前客户状态")
  1016. }
  1017. for _, v := range mapExport[vName] {
  1018. dataRow := sheel.AddRow()
  1019. dataRow.SetHeight(20)
  1020. cellDataName := dataRow.AddCell()
  1021. cellDataName.SetStyle(style)
  1022. cellDataName.SetValue(v.CompanyName)
  1023. cellDataSellerName := dataRow.AddCell()
  1024. cellDataSellerName.SetStyle(style)
  1025. cellDataSellerName.SetValue(v.SellerName)
  1026. cellDataMoney := dataRow.AddCell()
  1027. cellDataMoney.SetStyle(style)
  1028. cellDataMoney.SetValue(v.Money)
  1029. cellDataTime := dataRow.AddCell()
  1030. cellDataTime.SetStyle(style)
  1031. cellDataTime.SetValue(v.StartDate + "~" + v.EndDate)
  1032. cellDataPermissionName := dataRow.AddCell()
  1033. cellDataPermissionName.SetStyle(style)
  1034. cellDataPermissionName.SetValue(v.PermissionName)
  1035. if dataType == "行业未续约" {
  1036. cellDataPermissionNameStatus := dataRow.AddCell()
  1037. cellDataPermissionNameStatus.SetStyle(style)
  1038. cellDataPermissionNameStatus.SetValue(v.PermissionNameStatus)
  1039. cellDataCompanyProductStatus := dataRow.AddCell()
  1040. cellDataCompanyProductStatus.SetStyle(style)
  1041. cellDataCompanyProductStatus.SetValue(v.CompanyProductStatus)
  1042. }
  1043. }
  1044. }
  1045. err = xlsxFile.Save(downLoadnFilePath)
  1046. if err != nil {
  1047. br.Msg = "保存文件失败"
  1048. br.ErrMsg = "保存文件失败"
  1049. return
  1050. }
  1051. randStr := time.Now().Format(utils.FormatDateTimeUnSpace)
  1052. downloadFileName := dataType + "数据_" + randStr + ".xlsx"
  1053. this.Ctx.Output.Download(downLoadnFilePath, downloadFileName)
  1054. defer func() {
  1055. os.Remove(downLoadnFilePath)
  1056. }()
  1057. br.Ret = 200
  1058. br.Success = true
  1059. br.Msg = "导出成功"
  1060. }
  1061. // @Title 权益客户续约率统计
  1062. // @Description 权益客户续约率统计接口
  1063. // @Param PageSize query int true "每页数据条数"
  1064. // @Param CurrentIndex query int true "当前页页码,从1开始"
  1065. // @Param AdminId query string true "销售id,多个用英文逗号隔开,空字符串为全部"
  1066. // @Param StartDate query string false "开始日期"
  1067. // @Param EndDate query string false "结束日期"
  1068. // @Param ContractDataType query string false "合同类型,枚举值:`续约合同`,`到期合同`"
  1069. // @Success 200 {object} response.IncrementalCompanyListResp
  1070. // @router /merge_company/company_contract_percentage/list [get]
  1071. func (this *StatisticCompanyMergerController) CompanyContractPercentageList() {
  1072. br := new(models.BaseResponse).Init()
  1073. defer func() {
  1074. this.Data["json"] = br
  1075. this.ServeJSON()
  1076. }()
  1077. sysUser := this.SysUser
  1078. if sysUser == nil {
  1079. br.Msg = "请登录"
  1080. br.ErrMsg = "请登录,SysUser Is Empty"
  1081. br.Ret = 408
  1082. return
  1083. }
  1084. pageSize, _ := this.GetInt("PageSize")
  1085. currentIndex, _ := this.GetInt("CurrentIndex")
  1086. adminId := this.GetString("AdminId")
  1087. contractDataType := this.GetString("ContractDataType")
  1088. startDate := this.GetString("StartDate")
  1089. endDate := this.GetString("EndDate")
  1090. if startDate == "" || endDate == "" {
  1091. br.Msg = "开始时间或结束时间不能为空"
  1092. return
  1093. }
  1094. if contractDataType == "" {
  1095. contractDataType = "续约合同"
  1096. }
  1097. var startSize int
  1098. if pageSize <= 0 {
  1099. pageSize = utils.PageSize20
  1100. }
  1101. if currentIndex <= 0 {
  1102. currentIndex = 1
  1103. }
  1104. startSize = utils.StartIndex(currentIndex, pageSize)
  1105. var condition string
  1106. var pars []interface{}
  1107. //条件
  1108. if adminId != "" {
  1109. condition += ` AND c.seller_id in (` + adminId + `) `
  1110. } else {
  1111. //根据当前角色来获取查询条件
  1112. condition, pars = getQueryParams(condition, pars, sysUser, "c.")
  1113. }
  1114. //权益有效合同
  1115. condition += ` AND c.product_id = 2 AND a.status = 1 `
  1116. var list []*models.IncrementalList
  1117. var renewalRateMoney string //合同金额续约率
  1118. var renewalRateMoneyContent string //合同金额续约率详情
  1119. var renewalRateTotal string //合同数量续约率
  1120. var renewalRateTotalContent string //合同数量续约率详情
  1121. var renewalContractTotal int //续约合同数量
  1122. var renewalContractMoney int //续约合同数量
  1123. var expireRenewalContractTotal int //到期合同数量
  1124. var expireRenewalContractMoney int //到期合同数量
  1125. var dataTotal int //分页数据
  1126. conditionRenewal := condition // 续约合同查询条件查询条件
  1127. parsRenewal := pars
  1128. conditionRenewal += ` AND a.start_date >= ? AND a.start_date <= ? `
  1129. parsRenewal = append(parsRenewal, startDate, endDate)
  1130. conditionRenewal += ` AND a.rai_contract_type = ? `
  1131. parsRenewal = append(parsRenewal, "续约合同")
  1132. totalRenewal, err := company.GetIncrementalRenewalCompanyProductMergeCount(conditionRenewal, parsRenewal)
  1133. if err != nil {
  1134. br.Msg = "获取失败"
  1135. br.ErrMsg = "获取失败,Err:" + err.Error()
  1136. return
  1137. }
  1138. totalMoneyRenewal, err := company.GetIncrementalRenewalCompanyProductMergeSumMoney(conditionRenewal, parsRenewal)
  1139. if err != nil {
  1140. br.Msg = "获取失败"
  1141. br.ErrMsg = "获取失败,Err:" + err.Error()
  1142. return
  1143. }
  1144. //续约合同查询条件查询条件 end
  1145. conditionRenewalEnd := condition // 今年结束的续约合同查询条件
  1146. parsRenewalEnd := pars
  1147. conditionRenewalEnd += ` AND a.end_date >= ? AND a.end_date <= ? `
  1148. parsRenewalEnd = append(parsRenewalEnd, startDate, endDate)
  1149. conditionRenewalEnd += ` AND a.rai_contract_type = ? `
  1150. parsRenewalEnd = append(parsRenewalEnd, "续约合同")
  1151. totalRenewalEnd, err := company.GetIncrementalRenewalCompanyProductMergeCount(conditionRenewalEnd, parsRenewalEnd)
  1152. if err != nil && err.Error() != utils.ErrNoRow() {
  1153. br.Msg = "获取失败"
  1154. br.ErrMsg = "获取失败,Err:" + err.Error()
  1155. return
  1156. }
  1157. totalMoneyRenewalEnd, err := company.GetIncrementalRenewalCompanyProductMergeSumMoney(conditionRenewalEnd, parsRenewalEnd)
  1158. if err != nil {
  1159. br.Msg = "获取失败"
  1160. br.ErrMsg = "获取失败,Err:" + err.Error()
  1161. return
  1162. } // 今年结束的续约合同查询条件end
  1163. conditionNew := condition // 新签合同查询条件
  1164. parsNew := pars
  1165. conditionNew += ` AND a.end_date >= ? AND a.end_date <= ? `
  1166. parsNew = append(parsNew, startDate, endDate)
  1167. conditionNew += ` AND a.rai_contract_type = ? `
  1168. parsNew = append(parsNew, "新签合同")
  1169. totalNew, err := company.GetIncrementalRenewalCompanyProductMergeCount(conditionNew, parsNew)
  1170. if err != nil && err.Error() != utils.ErrNoRow() {
  1171. br.Msg = "获取失败"
  1172. br.ErrMsg = "获取失败,Err:" + err.Error()
  1173. return
  1174. }
  1175. totalMoneyNew, err := company.GetIncrementalRenewalCompanyProductMergeSumMoney(conditionNew, parsNew)
  1176. if err != nil {
  1177. br.Msg = "获取失败"
  1178. br.ErrMsg = "获取失败,Err:" + err.Error()
  1179. return
  1180. } // 新签合同查询条件 end
  1181. //分子或者分母为零的时候,不做计算
  1182. if totalRenewal == 0 || totalNew+totalRenewalEnd == 0 {
  1183. renewalRateMoney = "0%"
  1184. renewalRateTotal = "0%"
  1185. } else {
  1186. renewalRateMoney = fmt.Sprint(utils.SubFloatToString(float64(totalMoneyRenewal)/float64(totalMoneyNew+totalMoneyRenewalEnd)*100, 2), "%")
  1187. renewalRateTotal = fmt.Sprint(utils.SubFloatToString(float64(totalRenewal)/float64(totalNew+totalRenewalEnd)*100, 2), "%")
  1188. }
  1189. renewalRateTotalContent = fmt.Sprint(totalMoneyRenewal/10000, "万元/", (totalMoneyNew+totalMoneyRenewalEnd)/10000, "万元")
  1190. renewalRateMoneyContent = fmt.Sprint(totalRenewal, "份/", totalNew+totalRenewalEnd, "份")
  1191. if contractDataType == "续约合同" {
  1192. condition1 := condition
  1193. pars1 := pars
  1194. condition1 += ` AND a.start_date >= ? AND a.start_date <= ? `
  1195. pars1 = append(pars1, startDate, endDate)
  1196. condition1 += ` AND a.rai_contract_type = ? `
  1197. pars1 = append(pars1, "续约合同")
  1198. total, err := company.GetIncrementalRenewalCompanyProductMergeCount(condition1, pars1)
  1199. if err != nil && err.Error() != utils.ErrNoRow() {
  1200. br.Msg = "获取失败"
  1201. br.ErrMsg = "获取失败,Err:" + err.Error()
  1202. return
  1203. }
  1204. totalMoney, err := company.GetIncrementalRenewalCompanyProductMergeSumMoney(condition1, pars1)
  1205. if err != nil && err.Error() != utils.ErrNoRow() {
  1206. br.Msg = "获取失败"
  1207. br.ErrMsg = "获取失败,Err:" + err.Error()
  1208. return
  1209. }
  1210. renewalContractTotal = total
  1211. renewalContractMoney = int(totalMoney)
  1212. //列表页数据
  1213. tmpList, err := models.GetIncrementalCompanyMergeList(condition1, pars1, startSize, pageSize)
  1214. if err != nil {
  1215. br.Msg = "获取失败"
  1216. br.ErrMsg = "获取失败,Err:" + err.Error()
  1217. return
  1218. }
  1219. list = tmpList
  1220. dataTotal = total
  1221. }
  1222. if contractDataType == "到期合同" {
  1223. condition1 := condition
  1224. pars1 := pars
  1225. //判断结束时间是否晚于当前时间,如果晚于当前时间,那么就把当前时间作为截止时间。并且当前这天的到期的合同,不查询
  1226. endDateTime, _ := time.Parse(utils.FormatDate, endDate)
  1227. if endDateTime.After(time.Now()) {
  1228. endDate = time.Now().Format(utils.FormatDate)
  1229. condition1 += ` AND a.end_date >= ? AND a.end_date < ? `
  1230. } else {
  1231. condition1 += ` AND a.end_date >= ? AND a.end_date <= ? `
  1232. }
  1233. pars1 = append(pars1, startDate, endDate)
  1234. total, err := company.GetIncrementalRenewalCompanyProductMergeCount(condition1, pars1)
  1235. if err != nil && err.Error() != utils.ErrNoRow() {
  1236. br.Msg = "获取失败"
  1237. br.ErrMsg = "获取失败,Err:" + err.Error()
  1238. return
  1239. }
  1240. totalMoney, err := company.GetIncrementalRenewalCompanyProductMergeSumMoney(condition1, pars1)
  1241. if err != nil && err.Error() != utils.ErrNoRow() {
  1242. br.Msg = "获取失败"
  1243. br.ErrMsg = "获取失败,Err:" + err.Error()
  1244. return
  1245. }
  1246. expireRenewalContractTotal = total
  1247. expireRenewalContractMoney = int(totalMoney)
  1248. //列表页数据
  1249. tmpList, err := models.GetIncrementalCompanyMergeList(condition1, pars1, startSize, pageSize)
  1250. if err != nil {
  1251. br.Msg = "获取失败"
  1252. br.ErrMsg = "获取失败,Err:" + err.Error()
  1253. return
  1254. }
  1255. list = tmpList
  1256. dataTotal = total
  1257. }
  1258. listLen := len(list)
  1259. if listLen == 0 {
  1260. list = make([]*models.IncrementalList, 0)
  1261. }
  1262. var companyContractIds []int
  1263. for i := 0; i < listLen; i++ {
  1264. item := list[i]
  1265. companyContractIds = append(companyContractIds, item.CompanyContractId)
  1266. }
  1267. //合并合同所对应的权限
  1268. mappermissionName, err := cygxService.GetCompanyContractPermissionNameMapById(companyContractIds)
  1269. if err != nil {
  1270. br.Msg = "获取失败"
  1271. br.ErrMsg = "获取失败,Err:" + err.Error()
  1272. return
  1273. }
  1274. for _, v := range list {
  1275. v.PermissionName = mappermissionName[v.CompanyContractId]
  1276. }
  1277. page := paging.GetPaging(currentIndex, pageSize, dataTotal)
  1278. resp := response.IncrementalCompanyPercentageListResp{
  1279. Paging: page,
  1280. RenewalContractTotal: renewalContractTotal,
  1281. RenewalContractMoney: renewalContractMoney,
  1282. ExpireRenewalContractTotal: expireRenewalContractTotal,
  1283. ExpireRenewalContractMoney: expireRenewalContractMoney,
  1284. RenewalRateMoney: renewalRateMoney,
  1285. RenewalRateMoneyContent: renewalRateMoneyContent,
  1286. RenewalRateTotal: renewalRateTotal,
  1287. RenewalRateTotalContent: renewalRateTotalContent,
  1288. List: list,
  1289. }
  1290. br.Ret = 200
  1291. br.Success = true
  1292. br.Msg = "获取成功"
  1293. br.Data = resp
  1294. }