rai_data_summary.go 22 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564
  1. package statistic
  2. import (
  3. "fmt"
  4. "github.com/rdlucklib/rdluck_tools/paging"
  5. "hongze/hz_crm_api/controllers"
  6. "hongze/hz_crm_api/models"
  7. "hongze/hz_crm_api/models/company"
  8. "hongze/hz_crm_api/models/fms"
  9. "hongze/hz_crm_api/models/statistic_report"
  10. "hongze/hz_crm_api/models/system"
  11. cygxService "hongze/hz_crm_api/services/cygx"
  12. "hongze/hz_crm_api/utils"
  13. "strconv"
  14. "strings"
  15. "time"
  16. )
  17. // 权益数据汇总
  18. // StatisticRaiDataSummaryController 权益数据汇总基类
  19. type StatisticRaiDataSummaryController struct {
  20. controllers.BaseAuthController
  21. }
  22. // MergeCompanyList
  23. // @Title 权益数据汇总
  24. // @Description 权益数据汇总统计列表接口
  25. // @Param AdminId query string true "开拓组销售id,多个用英文逗号隔开,空字符串为全部"
  26. // @Param ServiceAdminId query string true "服务组销售id,多个用英文逗号隔开,空字符串为全部"
  27. // @Param StartYear query int false "开始日期(年份)"
  28. // @Param EndYear query int false "结束日期(年份)"
  29. // @Param DataType query string false "报表类型,枚举值:`季度`,`年度`,`半年度`"
  30. // @Param DevelopButton query int false "开拓组开关,枚举值:1:开启,0:关闭 ,默认关闭"
  31. // @Param ServerButton query int false "服务组开关,枚举值:1:开启,0:关闭 ,默认关闭"
  32. // @Param ContractButtonType query string false "开关类型,:`新签`,`续约`,`收入` 多个用英文逗号隔开, "
  33. // @Param IsExport query bool false "是否导出excel,默认是false"
  34. // @Success 200 {object} statistic_report.RaiDataSummaryListResp
  35. // @router /rai_data_summary/list [get]
  36. func (this *StatisticRaiDataSummaryController) RaiDataSummaryList() {
  37. br := new(models.BaseResponse).Init()
  38. defer func() {
  39. this.Data["json"] = br
  40. this.ServeJSON()
  41. }()
  42. sysUser := this.SysUser
  43. if sysUser == nil {
  44. br.Msg = "请登录"
  45. br.ErrMsg = "请登录,SysUser Is Empty"
  46. br.Ret = 408
  47. return
  48. }
  49. //adminId := this.GetString("AdminId")
  50. dataType := this.GetString("DataType")
  51. adminId := this.GetString("AdminId")
  52. serviceAdminId := this.GetString("ServiceAdminId")
  53. startYear, _ := this.GetInt("StartYear")
  54. endYear, _ := this.GetInt("EndYear")
  55. developButton, _ := this.GetInt("DevelopButton")
  56. serverButton, _ := this.GetInt("ServerButton")
  57. dataTypeArr := []string{}
  58. //var dateIntervalArr []statistic_report.DateInterval //时间区间
  59. if dataType == "季度" {
  60. dataTypeArr = []string{"Q1", "Q2", "Q3", "Q4"}
  61. //dateIntervalArr = []statistic_report.DateInterval{statistic_report.DateInterval{StartDate: "01-01", EndDate: "03-31"}, statistic_report.DateInterval{StartDate: "04-01", EndDate: "06-30"}, statistic_report.DateInterval{StartDate: "07-01", EndDate: "09-30"}, statistic_report.DateInterval{StartDate: "10-01", EndDate: "12-31"}}
  62. } else if dataType == "半年度" {
  63. dataTypeArr = []string{"H1", "H2"}
  64. //dateIntervalArr = []statistic_report.DateInterval{statistic_report.DateInterval{StartDate: "01-01", EndDate: "06-30"}, statistic_report.DateInterval{StartDate: "07-01", EndDate: "12-31"}}
  65. } else {
  66. dataTypeArr = []string{""}
  67. //dateIntervalArr = []statistic_report.DateInterval{statistic_report.DateInterval{StartDate: "01-01", EndDate: "12-31"}}
  68. }
  69. condition := " AND role_type_code IN ('rai_seller','rai_group') AND enabled = 1 AND rai_enabled = 1"
  70. var pars []interface{}
  71. if adminId != "" {
  72. serviceAdminId = ""
  73. condition += " AND admin_id IN (" + adminId + ") "
  74. }
  75. if serviceAdminId != "" {
  76. condition += " AND admin_id IN (" + serviceAdminId + ") "
  77. }
  78. if developButton == 1 && serverButton == 0 && adminId == "" && serviceAdminId == "" { //开拓组筛选条件
  79. condition += " AND real_name NOT LIKE '%6%' "
  80. }
  81. if developButton == 0 && serverButton == 1 && adminId == "" && serviceAdminId == "" { //服务组筛选条件
  82. condition += " AND real_name LIKE '%6%' "
  83. }
  84. sellerList, err := system.GetSysUserItemsOrderByCreated(condition, pars)
  85. if err != nil {
  86. br.Msg = "获取管理账号失败"
  87. br.ErrMsg = "获取管理账号失败,Err:" + err.Error()
  88. return
  89. }
  90. //拼接起始时间查询
  91. startDate := fmt.Sprintf("%d-01-01", startYear)
  92. endDate := fmt.Sprintf("%d-12-31", endYear)
  93. var conditionRai string
  94. var parsRai []interface{}
  95. conditionRai = " AND a.product_id = 2 AND a.status = 1 AND a.start_date >= ? AND a.start_date <= ? "
  96. parsRai = append(parsRai, startDate, endDate)
  97. listRaiData, err := statistic_report.GetRaiDataSummaryList(conditionRai, parsRai)
  98. if err != nil {
  99. br.Msg = "获取数据信息失败"
  100. br.ErrMsg = "获取数据信息失败,Err:" + err.Error()
  101. return
  102. }
  103. var conditionConfirm string
  104. var parsConfirm []interface{}
  105. mapNoRenewedcompanyContractIds := make(map[int]bool) //已经确定未续约的合同ID
  106. conditionConfirm = " AND company_ascribe_id != 9 "
  107. companyConfirmList, err := company.GetCompanyContractNoRenewedAscribeList(conditionConfirm, parsConfirm, 0, 0)
  108. if err != nil && err.Error() != utils.ErrNoRow() {
  109. br.Msg = "获取失败"
  110. br.ErrMsg = "获取失败,GetCompanyNoRenewedAscribeList Err:" + err.Error()
  111. return
  112. }
  113. for _, v := range companyConfirmList {
  114. mapNoRenewedcompanyContractIds[v.CompanyContractId] = true
  115. }
  116. mapAddTrialNum := make(map[string]float64) // 新增试用-(数据)
  117. mapNewContractMoney := make(map[string]float64) // 新签合同(金额)
  118. mapNewContractNum := make(map[string]int) // 新签合同(数量)
  119. mapExpiredContractMoney := make(map[string]float64) // 到期合同(金额)
  120. mapExpiredContractNum := make(map[string]int) // 到期合同(数量)
  121. mapRenewedContractMoney := make(map[string]float64) // 续约合同(金额)
  122. mapRenewedContractNum := make(map[string]int) // 续约合同(数量)
  123. confirmedNoRenewalContractMoney := make(map[string]float64) // 确认不续约合同(金额)
  124. confirmedNoRenewalContractNum := make(map[string]int) // 确认不续约合同(数量)
  125. mapSignedClientNum := make(map[string]int) // 签约客户(数量)
  126. mapSignedClientMoney := make(map[string]float64) // 签约客户(金额)
  127. mapInvoiceAmountMoney := make(map[string]float64) // 财务系统开票金额(金额)
  128. mapPaymentAmountMoney := make(map[string]float64) // 财务系统到款金额(金额)
  129. mapNewCustomerInvoicingMoney := make(map[string]float64) // 财务系统新客开票金额(金额)
  130. mapNewCustomerPaymentsReceivedMoney := make(map[string]float64) // 财务系统新客到款金额(金额)
  131. for _, v := range listRaiData {
  132. startDateTime := utils.StrDateToDate(v.StartDate)
  133. monthNum := startDateTime.Month()
  134. yearStr := strconv.Itoa(startDateTime.Year())
  135. if dataType == "季度" {
  136. if monthNum < 4 {
  137. yearStr += "Q1"
  138. } else if monthNum > 3 && monthNum < 7 {
  139. yearStr += "Q2"
  140. } else if monthNum > 6 && monthNum < 10 {
  141. yearStr += "Q3"
  142. } else if monthNum > 9 {
  143. yearStr += "Q4"
  144. }
  145. } else if dataType == "半年度" {
  146. if monthNum < 7 {
  147. yearStr += "H1"
  148. } else {
  149. yearStr += "H2"
  150. }
  151. }
  152. keyMap := fmt.Sprint(yearStr, "_", v.SellerIdLast)
  153. if v.RaiContractType == "新签合同" {
  154. mapNewContractMoney[keyMap] += v.Money
  155. mapNewContractNum[keyMap]++
  156. } else if v.RaiContractType == "续约合同" {
  157. mapRenewedContractMoney[keyMap] += v.Money
  158. mapRenewedContractNum[keyMap]++
  159. }
  160. if startDateTime.Before(time.Now().AddDate(0, 0, -1)) { //到期合同数据
  161. mapExpiredContractMoney[keyMap] += v.Money
  162. mapExpiredContractNum[keyMap]++
  163. }
  164. if mapNoRenewedcompanyContractIds[v.CompanyContractId] { // 确认不续约合同
  165. confirmedNoRenewalContractMoney[keyMap] += v.Money
  166. confirmedNoRenewalContractNum[keyMap]++
  167. }
  168. mapSignedClientMoney[keyMap] += v.Money
  169. mapSignedClientNum[keyMap]++
  170. }
  171. listFmsData, err := fms.GetContractRegisterListByStartDate(startDate)
  172. if err != nil {
  173. br.Msg = "获取数据信息失败"
  174. br.ErrMsg = "获取财务系统数据信息失败,Err:" + err.Error()
  175. return
  176. }
  177. for _, v := range listFmsData {
  178. startDateTime := v.StartDate
  179. monthNum := startDateTime.Month()
  180. yearStr := strconv.Itoa(startDateTime.Year())
  181. if dataType == "季度" {
  182. if monthNum < 4 {
  183. yearStr += "Q1"
  184. } else if monthNum > 3 && monthNum < 7 {
  185. yearStr += "Q2"
  186. } else if monthNum > 6 && monthNum < 10 {
  187. yearStr += "Q3"
  188. } else if monthNum > 9 {
  189. yearStr += "Q4"
  190. }
  191. } else if dataType == "半年度" {
  192. if monthNum < 7 {
  193. yearStr += "H1"
  194. } else {
  195. yearStr += "H2"
  196. }
  197. }
  198. keyMap := fmt.Sprint(yearStr, "_", v.RaiSellerId)
  199. mapInvoiceAmountMoney[keyMap] += v.InvoicedAmount
  200. mapPaymentAmountMoney[keyMap] += v.PaymentAmount
  201. if v.ContractType == 1 {
  202. mapNewCustomerInvoicingMoney[keyMap] += v.InvoicedAmount
  203. mapNewCustomerPaymentsReceivedMoney[keyMap] += v.PaymentAmount
  204. }
  205. }
  206. conditionTry := ` AND a.create_time >= ? AND a.create_time <= ? AND a.operation in ( "add","receive","apply_receive" ) AND a.sys_user_id IN ( SELECT admin_id FROM admin WHERE role_type_code IN ( 'rai_seller', 'rai_group' , 'rai_admin') ) `
  207. var parsTry []interface{}
  208. parsTry = append(parsTry, startDate, endDate)
  209. //列表页数据
  210. tryList, err := models.GetIncrementalCompanyListByOperationRecordRai(conditionTry, parsTry, 0, 9999)
  211. if err != nil {
  212. br.Msg = "获取失败"
  213. br.ErrMsg = "获取失败,Err:" + err.Error()
  214. return
  215. }
  216. for _, v := range tryList {
  217. startDateTime := utils.StrTimeToTime(v.CreateTime)
  218. monthNum := startDateTime.Month()
  219. yearStr := strconv.Itoa(startDateTime.Year())
  220. if dataType == "季度" {
  221. if monthNum < 4 {
  222. yearStr += "Q1"
  223. } else if monthNum > 3 && monthNum < 7 {
  224. yearStr += "Q2"
  225. } else if monthNum > 6 && monthNum < 10 {
  226. yearStr += "Q3"
  227. } else if monthNum > 9 {
  228. yearStr += "Q4"
  229. }
  230. } else if dataType == "半年度" {
  231. if monthNum < 7 {
  232. yearStr += "H1"
  233. } else {
  234. yearStr += "H2"
  235. }
  236. }
  237. keyMap := fmt.Sprint(yearStr, "_", v.SysUserId)
  238. mapAddTrialNum[keyMap]++
  239. }
  240. //fmt.Println(time.Now().AddDate(0, 0, -1))
  241. //return
  242. var sellerDevelop []*system.AdminItem // 开拓组销售
  243. var sellerService []*system.AdminItem // 服务组销售
  244. for _, v := range sellerList {
  245. if strings.Contains(v.RealName, "6") {
  246. sellerService = append(sellerService, v)
  247. } else {
  248. sellerDevelop = append(sellerDevelop, v)
  249. }
  250. }
  251. //for _, v := range dateIntervalArr {
  252. // fmt.Println(v)
  253. //}
  254. resp := new(statistic_report.RaiDataSummaryListResp)
  255. var items []*statistic_report.RaiDataSummaryResp
  256. for i := startYear; i <= endYear; i++ {
  257. //if len(dataTypeArr) > 0 {
  258. for _, Dv := range dataTypeArr {
  259. item := new(statistic_report.RaiDataSummaryResp)
  260. item.DataType = fmt.Sprint(i, Dv)
  261. //fmt.Println("DataType", item.DataType)
  262. for _, vS := range sellerDevelop {
  263. keyMap := fmt.Sprint(item.DataType, "_", vS.AdminId)
  264. sellerItem := new(statistic_report.RaiDataSummaryDetail)
  265. sellerItem.SellerId = vS.AdminId
  266. sellerItem.SellerName = vS.RealName
  267. sellerItem.AddTrialCount = fmt.Sprint(mapAddTrialNum[keyMap])
  268. sellerItem.NewContractData = fmt.Sprint(utils.SubFloatToString(mapNewContractMoney[keyMap], 2), " / ", mapNewContractNum[keyMap]) // 新签合同(金额/数量)-(数据)
  269. sellerItem.ExpiredContractData = fmt.Sprint(utils.SubFloatToString(mapExpiredContractMoney[keyMap], 2), " / ", mapExpiredContractNum[keyMap]) //"到期合同(金额/数量)-(数据)"
  270. sellerItem.RenewedContractData = fmt.Sprint(utils.SubFloatToString(mapRenewedContractMoney[keyMap], 2), " / ", mapRenewedContractNum[keyMap]) // "续约合同(金额/数量)-(数据)"
  271. var renewalRateMoey string
  272. var renewalRateNum string
  273. if mapRenewedContractMoney[keyMap] == 0 || mapExpiredContractMoney[keyMap] == 0 {
  274. renewalRateMoey = "0%"
  275. } else {
  276. renewalRateMoey = utils.SubFloatToString(mapRenewedContractMoney[keyMap]/mapExpiredContractMoney[keyMap]*100, 2) + "%"
  277. }
  278. if mapRenewedContractNum[keyMap] == 0 || mapExpiredContractNum[keyMap] == 0 {
  279. renewalRateNum = "0%"
  280. } else {
  281. renewalRateNum = utils.SubFloatToString(float64(mapRenewedContractNum[keyMap])/float64(mapExpiredContractNum[keyMap])*100, 2) + "%"
  282. }
  283. sellerItem.RenewalRateData = fmt.Sprint(renewalRateMoey, " / ", renewalRateNum) //"续约率(金额/数量)-(数据)"
  284. sellerItem.ConfirmedNoRenewalContractData = fmt.Sprint(utils.SubFloatToString(confirmedNoRenewalContractMoney[keyMap], 2), " / ", confirmedNoRenewalContractNum[keyMap]) //"确认不续约合同(金额/数量)-(数据)"
  285. var confirmNonRenewalRateMoey string
  286. var confirmNonRenewalRateNum string
  287. if confirmedNoRenewalContractMoney[keyMap] == 0 || mapExpiredContractMoney[keyMap] == 0 {
  288. confirmNonRenewalRateMoey = "0%"
  289. } else {
  290. confirmNonRenewalRateMoey = utils.SubFloatToString(confirmedNoRenewalContractMoney[keyMap]/mapExpiredContractMoney[keyMap]*100, 2) + "%"
  291. }
  292. if confirmedNoRenewalContractNum[keyMap] == 0 || mapExpiredContractNum[keyMap] == 0 {
  293. confirmNonRenewalRateNum = "0%"
  294. } else {
  295. confirmNonRenewalRateNum = utils.SubFloatToString(float64(confirmedNoRenewalContractNum[keyMap])/float64(mapExpiredContractNum[keyMap])*100, 2) + "%"
  296. }
  297. sellerItem.ConfirmNonRenewalRateData = fmt.Sprint(confirmNonRenewalRateMoey, " / ", confirmNonRenewalRateNum) //确认不续约率(金额/数量)-(数据)"
  298. sellerItem.SignedClientCount = fmt.Sprint(mapSignedClientNum[keyMap]) // 签约客户数量
  299. if mapSignedClientNum[keyMap] == 0 || mapSignedClientMoney[keyMap] == 0 {
  300. sellerItem.AverageRevenueCount = "0"
  301. } else {
  302. sellerItem.AverageRevenueCount = utils.SubFloatToString(mapSignedClientMoney[keyMap]/float64(mapSignedClientNum[keyMap]), 2) //客单价
  303. }
  304. sellerItem.InvoiceAmountCount = utils.SubFloatToString(mapInvoiceAmountMoney[keyMap], 2) //"开票金额-(数据)"
  305. sellerItem.PaymentReceivedCount = utils.SubFloatToString(mapPaymentAmountMoney[keyMap], 2) //"开票金额-(数据)"
  306. if mapInvoiceAmountMoney[keyMap] == 0 || mapPaymentAmountMoney[keyMap] == 0 {
  307. sellerItem.UnpaidRatioCount = "0%"
  308. } else {
  309. sellerItem.UnpaidRatioCount = utils.SubFloatToString((mapInvoiceAmountMoney[keyMap]-mapPaymentAmountMoney[keyMap])/mapInvoiceAmountMoney[keyMap]*100, 2) + "%" //"未到款比例-(数据)"
  310. }
  311. sellerItem.NewCustomerInvoicingCount = utils.SubFloatToString(mapNewCustomerInvoicingMoney[keyMap], 2) // "新客开票-(数据)"
  312. sellerItem.NewCustomerPaymentsReceivedCount = utils.SubFloatToString(mapNewCustomerPaymentsReceivedMoney[keyMap], 2) // "新客到款-(数据)"
  313. item.DataList = append(item.DataList, sellerItem)
  314. }
  315. if len(sellerDevelop) > 0 {
  316. sellerItem := new(statistic_report.RaiDataSummaryDetail)
  317. sellerItem.SellerName = "开拓组合计"
  318. item.DataList = append(item.DataList, sellerItem)
  319. }
  320. for _, vS := range sellerService {
  321. sellerItem := new(statistic_report.RaiDataSummaryDetail)
  322. sellerItem.SellerId = vS.AdminId
  323. sellerItem.SellerName = vS.RealName
  324. sellerItem.AddTrialCount = "新增试用-(数据)"
  325. sellerItem.NewContractData = "新签合同(金额/数量)-(数据)"
  326. sellerItem.ExpiredContractData = "到期合同(金额/数量)-(数据)"
  327. sellerItem.RenewedContractData = "续约合同(金额/数量)-(数据)"
  328. sellerItem.RenewalRateData = "续约率(金额/数量)-(数据)"
  329. sellerItem.ConfirmedNoRenewalContractData = "确认不续约合同(金额/数量)-(数据)"
  330. sellerItem.ConfirmNonRenewalRateData = "确认不续约率(金额/数量)-(数据)"
  331. sellerItem.SignedClientCount = "签约客户数量-(数据)"
  332. sellerItem.AverageRevenueCount = "客单价-(数据)"
  333. sellerItem.InvoiceAmountCount = "开票金额-(数据)"
  334. sellerItem.PaymentReceivedCount = "到款金额-(数据)"
  335. sellerItem.UnpaidRatioCount = "未到款比例-(数据)"
  336. sellerItem.NewCustomerInvoicingCount = "新客开票-(数据)"
  337. sellerItem.NewCustomerPaymentsReceivedCount = "新客到款-(数据)"
  338. item.DataList = append(item.DataList, sellerItem)
  339. }
  340. if len(sellerService) > 0 {
  341. sellerItem := new(statistic_report.RaiDataSummaryDetail)
  342. sellerItem.SellerName = "服务组合计"
  343. item.DataList = append(item.DataList, sellerItem)
  344. }
  345. items = append(items, item)
  346. }
  347. }
  348. resp.List = items
  349. br.Ret = 200
  350. br.Success = true
  351. br.Msg = "获取成功"
  352. br.Data = resp
  353. }
  354. // MergeCompanyList
  355. // @Title 权益数据汇总弹窗详情
  356. // @Description 权益数据汇总弹窗详情接口
  357. // @Param SellerId query int true "销售ID"
  358. // @Param DataType query string false "报表类型,枚举值:`季度`,`年度`,`半年度`"
  359. // @Param PopupType query string false "弹窗数据类型,枚举值:"
  360. // @Param PageSize query int true "每页数据条数"
  361. // @Param CurrentIndex query int true "当前页页码,从1开始"
  362. // @Success 200 {object} statistic_report.RaiDataSummaryPopupTypeResp
  363. // @router /rai_data_summary/detail [get]
  364. func (this *StatisticRaiDataSummaryController) RaiDataSummaryDetail() {
  365. br := new(models.BaseResponse).Init()
  366. defer func() {
  367. this.Data["json"] = br
  368. this.ServeJSON()
  369. }()
  370. sysUser := this.SysUser
  371. if sysUser == nil {
  372. br.Msg = "请登录"
  373. br.ErrMsg = "请登录,SysUser Is Empty"
  374. br.Ret = 408
  375. return
  376. }
  377. pageSize, _ := this.GetInt("PageSize")
  378. currentIndex, _ := this.GetInt("CurrentIndex")
  379. dataType := this.GetString("DataType")
  380. sellerId, _ := this.GetInt("SellerId")
  381. popupType := this.GetString("PopupType")
  382. var startSize int
  383. if pageSize <= 0 {
  384. pageSize = utils.PageSize20
  385. }
  386. if currentIndex <= 0 {
  387. currentIndex = 1
  388. }
  389. startSize = utils.StartIndex(currentIndex, pageSize)
  390. var startDate string
  391. var endDate string
  392. year := (dataType[:4])
  393. if strings.Contains(dataType, "Q1") {
  394. startDate = year + "-01-01"
  395. endDate = year + "-03-31"
  396. } else if strings.Contains(dataType, "Q2") {
  397. startDate = year + "-04-01"
  398. endDate = year + "-06-30"
  399. } else if strings.Contains(dataType, "Q3") {
  400. startDate = year + "-07-01"
  401. endDate = year + "-09-30"
  402. } else if strings.Contains(dataType, "Q4") {
  403. startDate = year + "-10-01"
  404. endDate = year + "-12-31"
  405. } else if strings.Contains(dataType, "H1") {
  406. startDate = year + "-01-01"
  407. endDate = year + "-06-31"
  408. } else if strings.Contains(dataType, "H2") {
  409. startDate = year + "-07-01"
  410. endDate = year + "-12-31"
  411. } else {
  412. startDate = year + "-01-01"
  413. endDate = year + "-12-31"
  414. }
  415. fmt.Println(startDate)
  416. fmt.Println(endDate)
  417. resp := new(statistic_report.RaiDataSummaryPopupTypeResp)
  418. var listResp []*statistic_report.RaiDataSummaryDetailResp
  419. var trialTotal int
  420. var condition string
  421. var pars []interface{}
  422. switch popupType {
  423. case "新增试用":
  424. var parsTry []interface{}
  425. var conditionTry string
  426. if sellerId > 0 {
  427. conditionTry += ` AND a.sys_user_id = ? `
  428. parsTry = append(parsTry, sellerId)
  429. }
  430. conditionTry += ` AND a.create_time >= ? AND a.create_time <= ? AND a.operation in ( "add","receive","apply_receive" ) AND a.sys_user_id IN ( SELECT admin_id FROM admin WHERE role_type_code IN ( 'rai_seller', 'rai_group' , 'rai_admin') ) `
  431. parsTry = append(parsTry, startDate, endDate)
  432. total, err := models.GetIncrementalCompanyCountByOperationRecordRai(conditionTry, parsTry)
  433. if err != nil {
  434. br.Msg = "获取失败"
  435. br.ErrMsg = "获取新增试用客户数量失败,Err:" + err.Error()
  436. return
  437. }
  438. trialTotal = total
  439. //列表页数据
  440. tryList, err := models.GetIncrementalCompanyListByOperationRecordRai(conditionTry, parsTry, startSize, pageSize)
  441. if err != nil {
  442. br.Msg = "获取失败"
  443. br.ErrMsg = "获取失败,Err:" + err.Error()
  444. return
  445. }
  446. if len(tryList) > 0 {
  447. for _, v := range tryList {
  448. item := new(statistic_report.RaiDataSummaryDetailResp)
  449. v.SellerName = v.SysRealName
  450. if v.Operation == "add" {
  451. item.AddType = "新建"
  452. } else if v.Operation == "receive" || v.Operation == "apply_receive" {
  453. item.AddType = "领取"
  454. }
  455. item.CompanyName = v.CompanyName
  456. item.SellerName = v.SellerName
  457. item.CreateTime = v.CreateTime
  458. listResp = append(listResp, item)
  459. }
  460. }
  461. case "新签合同":
  462. if sellerId > 0 {
  463. condition += ` AND a.seller_id_init = ? `
  464. pars = append(pars, sellerId)
  465. }
  466. condition += ` AND a.status = 1 AND a.start_date >= ? AND a.start_date <= ? `
  467. pars = append(pars, startDate, endDate)
  468. condition += ` AND a.rai_contract_type = ? `
  469. pars = append(pars, "新签合同")
  470. total, err := company.GetIncrementalNewCompanyProductMergeCount(condition, pars)
  471. if err != nil && err.Error() != utils.ErrNoRow() {
  472. br.Msg = "获取失败"
  473. br.ErrMsg = "获取失败,Err:" + err.Error()
  474. return
  475. }
  476. trialTotal = total
  477. //列表页数据
  478. tmpList, err := models.GetIncrementalCompanyMergeList(condition, pars, startSize, pageSize)
  479. if err != nil {
  480. br.Msg = "获取失败"
  481. br.ErrMsg = "获取失败,Err:" + err.Error()
  482. return
  483. }
  484. if len(tmpList) > 0 {
  485. var companyContractIds []int
  486. for _, v := range tmpList {
  487. companyContractIds = append(companyContractIds, v.CompanyContractId)
  488. }
  489. //合并合同所对应的权限
  490. mappermissionName, err := cygxService.GetCompanyContractPermissionNameMapById(companyContractIds)
  491. if err != nil {
  492. br.Msg = "获取失败"
  493. br.ErrMsg = "获取失败,Err:" + err.Error()
  494. return
  495. }
  496. for _, v := range tmpList {
  497. item := new(statistic_report.RaiDataSummaryDetailResp)
  498. item.CompanyName = v.CompanyName
  499. item.SellerName = v.SellerNameInit
  500. item.StartDate = v.StartDate
  501. item.EndDate = v.EndDate
  502. item.Money = v.Money
  503. item.PermissionName = mappermissionName[v.CompanyContractId]
  504. listResp = append(listResp, item)
  505. }
  506. }
  507. }
  508. if len(listResp) == 0 {
  509. listResp = make([]*statistic_report.RaiDataSummaryDetailResp, 0)
  510. }
  511. resp.List = listResp
  512. page := paging.GetPaging(currentIndex, pageSize, trialTotal)
  513. resp.Paging = page
  514. br.Ret = 200
  515. br.Success = true
  516. br.Msg = "获取成功"
  517. br.Data = resp
  518. }