|
|
@@ -0,0 +1,1593 @@
|
|
|
+package statistic
|
|
|
+
|
|
|
+import (
|
|
|
+ "fmt"
|
|
|
+ "github.com/rdlucklib/rdluck_tools/paging"
|
|
|
+ "hongze/hz_crm_api/controllers"
|
|
|
+ "hongze/hz_crm_api/models"
|
|
|
+ "hongze/hz_crm_api/models/company"
|
|
|
+ "hongze/hz_crm_api/models/fms"
|
|
|
+ "hongze/hz_crm_api/models/statistic_report"
|
|
|
+ "hongze/hz_crm_api/models/system"
|
|
|
+ "hongze/hz_crm_api/services"
|
|
|
+ cygxService "hongze/hz_crm_api/services/cygx"
|
|
|
+ "hongze/hz_crm_api/utils"
|
|
|
+ "strconv"
|
|
|
+ "strings"
|
|
|
+ "time"
|
|
|
+)
|
|
|
+
|
|
|
+// 权益数据汇总
|
|
|
+// StatisticRaiDataSummaryController 权益数据汇总基类
|
|
|
+type StatisticRaiDataSummaryController struct {
|
|
|
+ controllers.BaseAuthController
|
|
|
+}
|
|
|
+
|
|
|
+// MergeCompanyList
|
|
|
+// @Title 权益数据汇总
|
|
|
+// @Description 权益数据汇总统计列表接口
|
|
|
+// @Param AdminId query string true "开拓组销售id，多个用英文逗号隔开，空字符串为全部"
|
|
|
+// @Param ServiceAdminId query string true "服务组销售id，多个用英文逗号隔开，空字符串为全部"
|
|
|
+// @Param StartYear query int false "开始日期(年份)"
|
|
|
+// @Param EndYear query int false "结束日期(年份)"
|
|
|
+// @Param DataType query string false "报表类型，枚举值：`季度`，`年度`，`半年度`"
|
|
|
+// @Param DevelopButton query int false "开拓组开关，枚举值：1:开启，0：关闭 ，默认关闭"
|
|
|
+// @Param ServerButton query int false "服务组开关，枚举值：1:开启，0：关闭 ，默认关闭"
|
|
|
+// @Param ContractButtonType query string false "开关类型，：`新签`，`续约`，`收入` 多个用英文逗号隔开， "
|
|
|
+// @Param IsExport query bool false "是否导出excel，默认是false"
|
|
|
+// @Success 200 {object} statistic_report.RaiDataSummaryListResp
|
|
|
+// @router /rai_data_summary/list [get]
|
|
|
+func (this *StatisticRaiDataSummaryController) RaiDataSummaryList() {
|
|
|
+ br := new(models.BaseResponse).Init()
|
|
|
+ defer func() {
|
|
|
+ this.Data["json"] = br
|
|
|
+ this.ServeJSON()
|
|
|
+ }()
|
|
|
+
|
|
|
+ sysUser := this.SysUser
|
|
|
+ if sysUser == nil {
|
|
|
+ br.Msg = "请登录"
|
|
|
+ br.ErrMsg = "请登录，SysUser Is Empty"
|
|
|
+ br.Ret = 408
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ dataType := this.GetString("DataType")
|
|
|
+ adminId := this.GetString("AdminId")
|
|
|
+ serviceAdminId := this.GetString("ServiceAdminId")
|
|
|
+ startYear, _ := this.GetInt("StartYear")
|
|
|
+ endYear, _ := this.GetInt("EndYear")
|
|
|
+ developButton, _ := this.GetBool("DevelopButton")
|
|
|
+ serverButton, _ := this.GetBool("ServerButton")
|
|
|
+
|
|
|
+ dataTypeArr := []string{}
|
|
|
+ if dataType == "季度" {
|
|
|
+ dataTypeArr = []string{"Q1", "Q2", "Q3", "Q4"}
|
|
|
+ } else if dataType == "半年度" {
|
|
|
+ dataTypeArr = []string{"H1", "H2"}
|
|
|
+ } else {
|
|
|
+ dataTypeArr = []string{""}
|
|
|
+ }
|
|
|
+
|
|
|
+ condition := " AND role_type_code IN ('rai_seller','rai_group') AND enabled = 1 AND rai_enabled = 1 "
|
|
|
+ var pars []interface{}
|
|
|
+ if adminId != "" {
|
|
|
+ serviceAdminId = ""
|
|
|
+ condition += " AND admin_id IN (" + adminId + ") "
|
|
|
+ }
|
|
|
+ if serviceAdminId != "" {
|
|
|
+ condition += " AND admin_id IN (" + serviceAdminId + ") "
|
|
|
+ }
|
|
|
+
|
|
|
+ if developButton && !serverButton && adminId == "" && serviceAdminId == "" { //开拓组筛选条件
|
|
|
+ condition += " AND real_name NOT LIKE '%6%' "
|
|
|
+ }
|
|
|
+
|
|
|
+ if !developButton && serverButton && adminId == "" && serviceAdminId == "" { //服务组筛选条件
|
|
|
+ condition += " AND real_name LIKE '%6%' "
|
|
|
+ }
|
|
|
+
|
|
|
+ sellerList, err := system.GetSysUserItemsOrderByCreated(condition, pars)
|
|
|
+ if err != nil {
|
|
|
+ br.Msg = "获取管理账号失败"
|
|
|
+ br.ErrMsg = "获取管理账号失败,Err:" + err.Error()
|
|
|
+ return
|
|
|
+ }
|
|
|
+ var sellerDevelop []*system.AdminItem // 开拓组销售
|
|
|
+ var sellerService []*system.AdminItem // 服务组销售
|
|
|
+ var sellerDevelopIds = make(map[int]bool) // 开拓组销售的map
|
|
|
+ mapsellerId := make(map[int]bool) // 权益销售map
|
|
|
+ for _, v := range sellerList {
|
|
|
+ if strings.Contains(v.RealName, "6") {
|
|
|
+ sellerService = append(sellerService, v)
|
|
|
+ } else {
|
|
|
+ sellerDevelop = append(sellerDevelop, v)
|
|
|
+ sellerDevelopIds[v.AdminId] = true
|
|
|
+ }
|
|
|
+ mapsellerId[v.AdminId] = true
|
|
|
+ }
|
|
|
+
|
|
|
+ //拼接起始时间查询
|
|
|
+ startDate := fmt.Sprintf("%d-01-01", startYear)
|
|
|
+ endDate := fmt.Sprintf("%d-12-31", endYear)
|
|
|
+
|
|
|
+ //新签部分的数据
|
|
|
+ var conditionRai string
|
|
|
+ var parsRai []interface{}
|
|
|
+ conditionRai = " AND a.product_id = 2 AND a.status = 1 AND a.start_date >= ? AND a.start_date <= ? AND a.rai_contract_type = '新签合同' "
|
|
|
+ parsRai = append(parsRai, startDate, endDate)
|
|
|
+ listRaiData, err := statistic_report.GetRaiDataSummaryList(conditionRai, parsRai)
|
|
|
+ if err != nil {
|
|
|
+ br.Msg = "获取数据信息失败"
|
|
|
+ br.ErrMsg = "获取数据信息失败,Err:" + err.Error()
|
|
|
+ return
|
|
|
+ }
|
|
|
+ var companyIds []int
|
|
|
+ for _, v := range listRaiData {
|
|
|
+ companyIds = append(companyIds, v.CompanyId)
|
|
|
+ }
|
|
|
+ companyIds = append(companyIds, 0)
|
|
|
+
|
|
|
+ //续约部分的数据
|
|
|
+ var conditionInherit string
|
|
|
+ var parsInherit []interface{}
|
|
|
+ conditionInherit = ` AND a.product_id = 2 AND a.status = 1 AND a.inherit_end_date >= ? AND a.inherit_end_date <= ? AND a.rai_contract_type = '续约合同' AND a.company_id NOT IN (` + utils.GetOrmInReplace(len(companyIds)) + `) `
|
|
|
+ parsInherit = append(parsInherit, startDate, endDate, companyIds)
|
|
|
+ listInheritData, err := statistic_report.GetRaiDataSummaryInheritList(conditionInherit, parsInherit)
|
|
|
+ if err != nil {
|
|
|
+ br.Msg = "获取数据信息失败"
|
|
|
+ br.ErrMsg = "获取数据信息失败,Err:" + err.Error()
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ //确认不续约、到期合同部分的数据
|
|
|
+ var conditionEnd string
|
|
|
+ var parsEnd []interface{}
|
|
|
+ conditionEnd = " AND a.product_id = 2 AND a.status = 1 AND a.end_date >= ? AND a.end_date <= ? AND a.end_date <= ? "
|
|
|
+ parsEnd = append(parsEnd, startDate, endDate, time.Now().Format(utils.FormatDate))
|
|
|
+ listEndData, err := statistic_report.GetRaiDataSummaryList(conditionEnd, parsEnd)
|
|
|
+ if err != nil {
|
|
|
+ br.Msg = "获取数据信息失败"
|
|
|
+ br.ErrMsg = "获取数据信息失败,Err:" + err.Error()
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ var conditionConfirm string
|
|
|
+ var parsConfirm []interface{}
|
|
|
+ mapNoRenewedcompanyContractIds := make(map[int]bool) //已经确定未续约的合同ID
|
|
|
+ conditionConfirm = " AND company_ascribe_id != 9 "
|
|
|
+ companyConfirmList, err := company.GetCompanyContractNoRenewedAscribeList(conditionConfirm, parsConfirm, 0, 0)
|
|
|
+ if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
+ br.Msg = "获取失败"
|
|
|
+ br.ErrMsg = "获取失败，GetCompanyNoRenewedAscribeList Err:" + err.Error()
|
|
|
+ return
|
|
|
+ }
|
|
|
+ for _, v := range companyConfirmList {
|
|
|
+ mapNoRenewedcompanyContractIds[v.CompanyContractId] = true
|
|
|
+ }
|
|
|
+
|
|
|
+ mapAddTrialNum := make(map[string]float64) // 新增试用-(数据)
|
|
|
+ mapNewContractMoney := make(map[string]float64) // 新签合同（金额)
|
|
|
+ mapNewContractNum := make(map[string]int) // 新签合同（数量)
|
|
|
+ mapExpiredContractMoney := make(map[string]float64) // 到期合同（金额)
|
|
|
+ mapExpiredContractNum := make(map[string]int) // 到期合同（数量)
|
|
|
+ mapExpiredContractCompanyNum := make(map[string]int) // 到期公司（数量)
|
|
|
+ mapRenewedContractMoney := make(map[string]float64) // 续约合同（金额)
|
|
|
+ mapRenewedContractNum := make(map[string]int) // 续约合同（数量)
|
|
|
+ mapRenewedContractCompanyNum := make(map[string]int) // 续约公司（数量)
|
|
|
+ confirmedNoRenewalContractMoney := make(map[string]float64) // 确认不续约合同（金额)
|
|
|
+ confirmedNoRenewalContractNum := make(map[string]int) // 确认不续约合同（数量)
|
|
|
+ confirmedNoRenewalContractCompanyNum := make(map[string]int) // 确认不续约公司（数量)
|
|
|
+ mapSignedClientNum := make(map[string]int) // 签约客户（数量)
|
|
|
+ mapSignedClientMoney := make(map[string]float64) // 签约客户（金额)
|
|
|
+ mapInvoiceAmountMoney := make(map[string]float64) // 财务系统开票金额（金额)
|
|
|
+ mapPaymentAmountMoney := make(map[string]float64) // 财务系统到款金额（金额)
|
|
|
+ mapNewCustomerInvoicingMoney := make(map[string]float64) // 财务系统新客开票金额（金额)
|
|
|
+ mapNewCustomerPaymentsReceivedMoney := make(map[string]float64) // 财务系统新客到款金额（金额)
|
|
|
+
|
|
|
+ var keyMap string
|
|
|
+ var keyMapTtoal string
|
|
|
+ var keyMapTtoalServer string
|
|
|
+ var keyMapCompany string
|
|
|
+ var keyMapCompanyNo string
|
|
|
+ var keySigned string
|
|
|
+
|
|
|
+ mapCompanyData := make(map[string]bool)
|
|
|
+ //新签部分的数据
|
|
|
+ for _, v := range listRaiData {
|
|
|
+ if !mapsellerId[v.SellerIdLast] {
|
|
|
+ continue
|
|
|
+ }
|
|
|
+ startDateTime := utils.StrDateToDate(v.StartDate)
|
|
|
+ monthNum := startDateTime.Month()
|
|
|
+ yearStr := strconv.Itoa(startDateTime.Year())
|
|
|
+ if dataType == "季度" {
|
|
|
+ if monthNum < 4 {
|
|
|
+ yearStr += "Q1"
|
|
|
+ } else if monthNum > 3 && monthNum < 7 {
|
|
|
+ yearStr += "Q2"
|
|
|
+ } else if monthNum > 6 && monthNum < 10 {
|
|
|
+ yearStr += "Q3"
|
|
|
+ } else if monthNum > 9 {
|
|
|
+ yearStr += "Q4"
|
|
|
+ }
|
|
|
+ } else if dataType == "半年度" {
|
|
|
+ if monthNum < 7 {
|
|
|
+ yearStr += "H1"
|
|
|
+ } else {
|
|
|
+ yearStr += "H2"
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ keyMap = fmt.Sprint(yearStr, "_", v.SellerIdLast)
|
|
|
+ keySigned = fmt.Sprint(yearStr, "_", "_CID_", v.CompanyId, "_SID_", v.SellerIdLast)
|
|
|
+
|
|
|
+ if sellerDevelopIds[v.SellerIdLast] == true {
|
|
|
+ keyMapTtoal = fmt.Sprint(yearStr, "_Develop")
|
|
|
+ } else {
|
|
|
+ keyMapTtoal = fmt.Sprint(yearStr, "_Service")
|
|
|
+ }
|
|
|
+
|
|
|
+ if v.RaiContractType == "新签合同" {
|
|
|
+ mapNewContractMoney[keyMap] += v.Money
|
|
|
+ mapNewContractNum[keyMap]++
|
|
|
+
|
|
|
+ mapNewContractMoney[keyMapTtoal] += v.Money
|
|
|
+ mapNewContractNum[keyMapTtoal]++
|
|
|
+ }
|
|
|
+
|
|
|
+ mapSignedClientMoney[keyMap] += v.Money
|
|
|
+ mapSignedClientMoney[keyMapTtoal] += v.Money
|
|
|
+
|
|
|
+ if !mapCompanyData[keySigned] && v.RaiContractType == "新签合同" {
|
|
|
+ mapSignedClientNum[keyMap]++
|
|
|
+ mapSignedClientNum[keyMapTtoal]++
|
|
|
+ mapCompanyData[keySigned] = true
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ //续约部分的数据
|
|
|
+ mapKeyMapCompanyData := make(map[string]bool)
|
|
|
+ for _, v := range listInheritData {
|
|
|
+ if !mapsellerId[v.SellerIdLast] {
|
|
|
+ continue
|
|
|
+ }
|
|
|
+ startDateTime := utils.StrDateToDate(v.InheritEndDate)
|
|
|
+ monthNum := startDateTime.Month()
|
|
|
+ yearStr := strconv.Itoa(startDateTime.Year())
|
|
|
+ if dataType == "季度" {
|
|
|
+ if monthNum < 4 {
|
|
|
+ yearStr += "Q1"
|
|
|
+ } else if monthNum > 3 && monthNum < 7 {
|
|
|
+ yearStr += "Q2"
|
|
|
+ } else if monthNum > 6 && monthNum < 10 {
|
|
|
+ yearStr += "Q3"
|
|
|
+ } else if monthNum > 9 {
|
|
|
+ yearStr += "Q4"
|
|
|
+ }
|
|
|
+ } else if dataType == "半年度" {
|
|
|
+ if monthNum < 7 {
|
|
|
+ yearStr += "H1"
|
|
|
+ } else {
|
|
|
+ yearStr += "H2"
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ keyMap = fmt.Sprint(yearStr, "_", v.SellerIdLast)
|
|
|
+ keyMapCompany = fmt.Sprint(yearStr, "_", v.SellerIdLast, "_CID_", v.CompanyId)
|
|
|
+ if sellerDevelopIds[v.SellerIdLast] == true {
|
|
|
+ keyMapTtoal = fmt.Sprint(yearStr, "_Develop")
|
|
|
+ } else {
|
|
|
+ keyMapTtoal = fmt.Sprint(yearStr, "_Service")
|
|
|
+ }
|
|
|
+
|
|
|
+ //续约合同 数据
|
|
|
+ mapRenewedContractMoney[keyMap] += v.Money
|
|
|
+
|
|
|
+ mapRenewedContractMoney[keyMapTtoal] += v.Money
|
|
|
+
|
|
|
+ //一家公司同一个时间纬度，只统计一次
|
|
|
+ //if !mapKeyMapCompanyData[keyMapCompany] {
|
|
|
+ mapRenewedContractNum[keyMap]++
|
|
|
+ mapRenewedContractNum[keyMapTtoal]++
|
|
|
+ //mapKeyMapCompanyData[keyMapCompany] = true
|
|
|
+ //}
|
|
|
+ if !mapKeyMapCompanyData[keyMapCompany] {
|
|
|
+ mapRenewedContractCompanyNum[keyMap]++
|
|
|
+ mapRenewedContractCompanyNum[keyMapTtoal]++
|
|
|
+ mapKeyMapCompanyData[keyMapCompany] = true
|
|
|
+ }
|
|
|
+ if !mapCompanyData[keySigned] && v.RaiContractType == "续约合同" {
|
|
|
+ mapSignedClientNum[keyMap]++
|
|
|
+ mapSignedClientNum[keyMapTtoal]++
|
|
|
+ mapCompanyData[keySigned] = true
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ //确认不续约、到期合同部分的数据
|
|
|
+ mapKeyMapCompanyEndData := make(map[string]bool)
|
|
|
+ mapKeyMapCompanyNoData := make(map[string]bool)
|
|
|
+ for _, v := range listEndData {
|
|
|
+ if !mapsellerId[v.SellerIdLast] {
|
|
|
+ continue
|
|
|
+ }
|
|
|
+ startDateTime := utils.StrDateToDate(v.EndDate)
|
|
|
+ monthNum := startDateTime.Month()
|
|
|
+ yearStr := strconv.Itoa(startDateTime.Year())
|
|
|
+ if dataType == "季度" {
|
|
|
+ if monthNum < 4 {
|
|
|
+ yearStr += "Q1"
|
|
|
+ } else if monthNum > 3 && monthNum < 7 {
|
|
|
+ yearStr += "Q2"
|
|
|
+ } else if monthNum > 6 && monthNum < 10 {
|
|
|
+ yearStr += "Q3"
|
|
|
+ } else if monthNum > 9 {
|
|
|
+ yearStr += "Q4"
|
|
|
+ }
|
|
|
+ } else if dataType == "半年度" {
|
|
|
+ if monthNum < 7 {
|
|
|
+ yearStr += "H1"
|
|
|
+ } else {
|
|
|
+ yearStr += "H2"
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ keyMap = fmt.Sprint(yearStr, "_", v.SellerIdLast)
|
|
|
+ keyMapCompany = fmt.Sprint(yearStr, "_", v.SellerIdLast, "_CID_", v.CompanyId)
|
|
|
+ keyMapCompanyNo = fmt.Sprint(yearStr, "_", v.SellerIdLast, "_CID_NO", v.CompanyId)
|
|
|
+ if sellerDevelopIds[v.SellerIdLast] == true {
|
|
|
+ keyMapTtoal = fmt.Sprint(yearStr, "_Develop")
|
|
|
+ } else {
|
|
|
+ keyMapTtoal = fmt.Sprint(yearStr, "_Service")
|
|
|
+ }
|
|
|
+
|
|
|
+ //到期合同数据
|
|
|
+ mapExpiredContractMoney[keyMap] += v.Money
|
|
|
+ mapExpiredContractMoney[keyMapTtoal] += v.Money
|
|
|
+
|
|
|
+ //一家公司同一个时间纬度，只统计一次
|
|
|
+ //if !mapKeyMapCompanyEndData[keyMapCompany] {
|
|
|
+ mapExpiredContractNum[keyMap]++
|
|
|
+ mapExpiredContractNum[keyMapTtoal]++
|
|
|
+ //mapKeyMapCompanyEndData[keyMapCompany] = true
|
|
|
+ //}
|
|
|
+
|
|
|
+ //一家公司同一个时间纬度，只统计一次
|
|
|
+ if !mapKeyMapCompanyEndData[keyMapCompany] {
|
|
|
+ mapExpiredContractCompanyNum[keyMap]++
|
|
|
+ mapExpiredContractCompanyNum[keyMapTtoal]++
|
|
|
+ mapKeyMapCompanyEndData[keyMapCompany] = true
|
|
|
+ }
|
|
|
+
|
|
|
+ if mapNoRenewedcompanyContractIds[v.CompanyContractId] { // 确认不续约合同
|
|
|
+ confirmedNoRenewalContractMoney[keyMap] += v.Money
|
|
|
+
|
|
|
+ confirmedNoRenewalContractMoney[keyMapTtoal] += v.Money
|
|
|
+
|
|
|
+ //一家公司同一个时间纬度，只统计一次
|
|
|
+ //if !mapKeyMapCompanyNoData[keyMapCompanyNo] {
|
|
|
+ confirmedNoRenewalContractNum[keyMap]++
|
|
|
+ confirmedNoRenewalContractNum[keyMapTtoal]++
|
|
|
+ //mapKeyMapCompanyNoData[keyMapCompanyNo] = true
|
|
|
+ //}
|
|
|
+
|
|
|
+ if !mapKeyMapCompanyNoData[keyMapCompanyNo] {
|
|
|
+ confirmedNoRenewalContractCompanyNum[keyMap]++
|
|
|
+ confirmedNoRenewalContractCompanyNum[keyMapTtoal]++
|
|
|
+ mapKeyMapCompanyNoData[keyMapCompanyNo] = true
|
|
|
+ }
|
|
|
+
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ listFmsData, err := fms.GetContractRegisterListByStartDate(startDate, endDate)
|
|
|
+ if err != nil {
|
|
|
+ br.Msg = "获取数据信息失败"
|
|
|
+ br.ErrMsg = "获取财务系统数据信息失败,Err:" + err.Error()
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ for _, v := range listFmsData {
|
|
|
+ if !mapsellerId[v.RaiSellerId] {
|
|
|
+ continue
|
|
|
+ }
|
|
|
+ startDateTime := v.StartDate
|
|
|
+ monthNum := startDateTime.Month()
|
|
|
+ yearStr := strconv.Itoa(startDateTime.Year())
|
|
|
+ if dataType == "季度" {
|
|
|
+ if monthNum < 4 {
|
|
|
+ yearStr += "Q1"
|
|
|
+ } else if monthNum > 3 && monthNum < 7 {
|
|
|
+ yearStr += "Q2"
|
|
|
+ } else if monthNum > 6 && monthNum < 10 {
|
|
|
+ yearStr += "Q3"
|
|
|
+ } else if monthNum > 9 {
|
|
|
+ yearStr += "Q4"
|
|
|
+ }
|
|
|
+ } else if dataType == "半年度" {
|
|
|
+ if monthNum < 7 {
|
|
|
+ yearStr += "H1"
|
|
|
+ } else {
|
|
|
+ yearStr += "H2"
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ keyMap = fmt.Sprint(yearStr, "_", v.RaiSellerId)
|
|
|
+
|
|
|
+ if sellerDevelopIds[v.RaiSellerId] == true {
|
|
|
+ keyMapTtoal = fmt.Sprint(yearStr, "_Develop")
|
|
|
+ } else {
|
|
|
+ keyMapTtoal = fmt.Sprint(yearStr, "_Service")
|
|
|
+ }
|
|
|
+
|
|
|
+ mapInvoiceAmountMoney[keyMap] += v.InvoicedAmount
|
|
|
+ mapPaymentAmountMoney[keyMap] += v.PaymentAmount
|
|
|
+
|
|
|
+ mapInvoiceAmountMoney[keyMapTtoal] += v.InvoicedAmount
|
|
|
+ mapPaymentAmountMoney[keyMapTtoal] += v.PaymentAmount
|
|
|
+
|
|
|
+ if v.ContractType == 1 {
|
|
|
+ mapNewCustomerInvoicingMoney[keyMap] += v.InvoicedAmount
|
|
|
+ mapNewCustomerPaymentsReceivedMoney[keyMap] += v.PaymentAmount
|
|
|
+ mapNewCustomerInvoicingMoney[keyMapTtoal] += v.InvoicedAmount
|
|
|
+ mapNewCustomerPaymentsReceivedMoney[keyMapTtoal] += v.PaymentAmount
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ 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') ) `
|
|
|
+ var parsTry []interface{}
|
|
|
+ parsTry = append(parsTry, startDate, endDate)
|
|
|
+ //列表页数据
|
|
|
+ tryList, err := models.GetIncrementalCompanyListByOperationRecordRai(conditionTry, parsTry, 0, 9999)
|
|
|
+ if err != nil {
|
|
|
+ br.Msg = "获取失败"
|
|
|
+ br.ErrMsg = "获取失败，Err:" + err.Error()
|
|
|
+ return
|
|
|
+ }
|
|
|
+ for _, v := range tryList {
|
|
|
+ startDateTime := utils.StrTimeToTime(v.CreateTime)
|
|
|
+ monthNum := startDateTime.Month()
|
|
|
+ yearStr := strconv.Itoa(startDateTime.Year())
|
|
|
+ if dataType == "季度" {
|
|
|
+ if monthNum < 4 {
|
|
|
+ yearStr += "Q1"
|
|
|
+ } else if monthNum > 3 && monthNum < 7 {
|
|
|
+ yearStr += "Q2"
|
|
|
+ } else if monthNum > 6 && monthNum < 10 {
|
|
|
+ yearStr += "Q3"
|
|
|
+ } else if monthNum > 9 {
|
|
|
+ yearStr += "Q4"
|
|
|
+ }
|
|
|
+ } else if dataType == "半年度" {
|
|
|
+ if monthNum < 7 {
|
|
|
+ yearStr += "H1"
|
|
|
+ } else {
|
|
|
+ yearStr += "H2"
|
|
|
+ }
|
|
|
+ }
|
|
|
+ keyMap = fmt.Sprint(yearStr, "_", v.SysUserId)
|
|
|
+ mapAddTrialNum[keyMap]++
|
|
|
+
|
|
|
+ //var keyMapTtoal string
|
|
|
+ sysUserId, _ := strconv.Atoi(v.SysUserId)
|
|
|
+ if sellerDevelopIds[sysUserId] == true {
|
|
|
+ keyMapTtoal = fmt.Sprint(yearStr, "_Develop")
|
|
|
+ } else {
|
|
|
+ keyMapTtoal = fmt.Sprint(yearStr, "_Service")
|
|
|
+ }
|
|
|
+ mapAddTrialNum[keyMapTtoal]++
|
|
|
+ }
|
|
|
+
|
|
|
+ resp := new(statistic_report.RaiDataSummaryListResp)
|
|
|
+ var items []*statistic_report.RaiDataSummaryResp
|
|
|
+ for i := startYear; i <= endYear; i++ {
|
|
|
+ //if len(dataTypeArr) > 0 {
|
|
|
+ for _, Dv := range dataTypeArr {
|
|
|
+ item := new(statistic_report.RaiDataSummaryResp)
|
|
|
+ item.DataType = fmt.Sprint(i, Dv)
|
|
|
+ keyMapTtoal = fmt.Sprint(item.DataType, "_Develop")
|
|
|
+ keyMapTtoalServer = fmt.Sprint(item.DataType, "_Server")
|
|
|
+ var sellerIds []string
|
|
|
+ var sellerServiceIds []string
|
|
|
+ for _, vS := range sellerDevelop {
|
|
|
+ keyMap = fmt.Sprint(item.DataType, "_", vS.AdminId)
|
|
|
+ sellerItem := new(statistic_report.RaiDataSummaryDetail)
|
|
|
+ sellerItem.SellerId = strconv.Itoa(vS.AdminId)
|
|
|
+ sellerIds = append(sellerIds, sellerItem.SellerId)
|
|
|
+ sellerItem.SellerName = vS.RealName
|
|
|
+ sellerItem.AddTrialCount = fmt.Sprint(mapAddTrialNum[keyMap])
|
|
|
+ sellerItem.NewContractData = fmt.Sprint(utils.SubFloatToString(mapNewContractMoney[keyMap], 2), " / ", mapNewContractNum[keyMap]) // 新签合同（金额/数量)-(数据)
|
|
|
+ sellerItem.ExpiredContractData = fmt.Sprint(utils.SubFloatToString(mapExpiredContractMoney[keyMap], 2), " / ", mapExpiredContractNum[keyMap]) //"到期合同（金额/数量)-(数据)"
|
|
|
+ sellerItem.RenewedContractData = fmt.Sprint(utils.SubFloatToString(mapRenewedContractMoney[keyMap], 2), " / ", mapRenewedContractNum[keyMap]) // "续约合同（金额/数量)-(数据)"
|
|
|
+ var renewalRateMoey string
|
|
|
+ var renewalRateNum string
|
|
|
+ if mapRenewedContractMoney[keyMap] == 0 || mapExpiredContractMoney[keyMap] == 0 {
|
|
|
+ renewalRateMoey = "0%"
|
|
|
+ } else {
|
|
|
+ renewalRateMoey = utils.SubFloatToString(mapRenewedContractMoney[keyMap]/mapExpiredContractMoney[keyMap]*100, 2) + "%"
|
|
|
+ }
|
|
|
+ if mapRenewedContractCompanyNum[keyMap] == 0 || mapExpiredContractCompanyNum[keyMap] == 0 {
|
|
|
+ renewalRateNum = "0%"
|
|
|
+ } else {
|
|
|
+ renewalRateNum = utils.SubFloatToString(float64(mapRenewedContractCompanyNum[keyMap])/float64(mapExpiredContractCompanyNum[keyMap])*100, 2) + "%"
|
|
|
+ }
|
|
|
+ sellerItem.RenewalRateData = fmt.Sprint(renewalRateMoey, " / ", renewalRateNum) //"续约率（金额/数量)-(数据)"
|
|
|
+ sellerItem.ConfirmedNoRenewalContractData = fmt.Sprint(utils.SubFloatToString(confirmedNoRenewalContractMoney[keyMap], 2), " / ", confirmedNoRenewalContractNum[keyMap]) //"确认不续约合同（金额/数量)-(数据)"
|
|
|
+
|
|
|
+ var confirmNonRenewalRateMoey string
|
|
|
+ var confirmNonRenewalRateNum string
|
|
|
+ if confirmedNoRenewalContractMoney[keyMap] == 0 || mapExpiredContractMoney[keyMap] == 0 {
|
|
|
+ confirmNonRenewalRateMoey = "0%"
|
|
|
+ } else {
|
|
|
+ confirmNonRenewalRateMoey = utils.SubFloatToString(confirmedNoRenewalContractMoney[keyMap]/mapExpiredContractMoney[keyMap]*100, 2) + "%"
|
|
|
+ }
|
|
|
+ if confirmedNoRenewalContractCompanyNum[keyMap] == 0 || mapExpiredContractCompanyNum[keyMap] == 0 {
|
|
|
+ confirmNonRenewalRateNum = "0%"
|
|
|
+ } else {
|
|
|
+ confirmNonRenewalRateNum = utils.SubFloatToString(float64(confirmedNoRenewalContractCompanyNum[keyMap])/float64(mapExpiredContractCompanyNum[keyMap])*100, 2) + "%"
|
|
|
+ }
|
|
|
+ sellerItem.ConfirmNonRenewalRateData = fmt.Sprint(confirmNonRenewalRateMoey, " / ", confirmNonRenewalRateNum) //确认不续约率（金额/数量)-(数据)"
|
|
|
+
|
|
|
+ sellerItem.SignedClientCount = fmt.Sprint(mapSignedClientNum[keyMap]) // 签约客户数量
|
|
|
+ if mapSignedClientNum[keyMap] == 0 || mapSignedClientMoney[keyMap] == 0 {
|
|
|
+ sellerItem.AverageRevenueCount = "0"
|
|
|
+ } else {
|
|
|
+ sellerItem.AverageRevenueCount = utils.SubFloatToString(mapSignedClientMoney[keyMap]/float64(mapSignedClientNum[keyMap]), 2) //客单价
|
|
|
+ }
|
|
|
+
|
|
|
+ sellerItem.InvoiceAmountCount = utils.SubFloatToString(mapInvoiceAmountMoney[keyMap], 2) //"开票金额-(数据)"
|
|
|
+ sellerItem.PaymentReceivedCount = utils.SubFloatToString(mapPaymentAmountMoney[keyMap], 2) //"开票金额-(数据)"
|
|
|
+ if mapInvoiceAmountMoney[keyMap] == 0 || mapPaymentAmountMoney[keyMap] == 0 {
|
|
|
+ sellerItem.UnpaidRatioCount = "0%"
|
|
|
+ } else {
|
|
|
+ sellerItem.UnpaidRatioCount = utils.SubFloatToString((mapInvoiceAmountMoney[keyMap]-mapPaymentAmountMoney[keyMap])/mapInvoiceAmountMoney[keyMap]*100, 2) + "%" //"未到款比例-(数据)"
|
|
|
+ }
|
|
|
+ sellerItem.NewCustomerInvoicingCount = utils.SubFloatToString(mapNewCustomerInvoicingMoney[keyMap], 2) // "新客开票-(数据)"
|
|
|
+ sellerItem.NewCustomerPaymentsReceivedCount = utils.SubFloatToString(mapNewCustomerPaymentsReceivedMoney[keyMap], 2) // "新客到款-(数据)"
|
|
|
+ if developButton || serverButton || adminId != "" {
|
|
|
+ item.DataList = append(item.DataList, sellerItem)
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ if len(sellerDevelop) > 0 {
|
|
|
+ sellerItem := new(statistic_report.RaiDataSummaryDetail)
|
|
|
+ sellerItem.SellerId = strings.Join(sellerIds, ",")
|
|
|
+ sellerItem.SellerName = "开拓组合计"
|
|
|
+ sellerItem.AddTrialCount = fmt.Sprint(mapAddTrialNum[keyMapTtoal])
|
|
|
+ sellerItem.NewContractData = fmt.Sprint(utils.SubFloatToString(mapNewContractMoney[keyMapTtoal], 2), " / ", mapNewContractNum[keyMapTtoal]) // 新签合同（金额/数量)-(数据)
|
|
|
+ sellerItem.ExpiredContractData = fmt.Sprint(utils.SubFloatToString(mapExpiredContractMoney[keyMapTtoal], 2), " / ", mapExpiredContractNum[keyMapTtoal]) //"到期合同（金额/数量)-(数据)"
|
|
|
+ sellerItem.RenewedContractData = fmt.Sprint(utils.SubFloatToString(mapRenewedContractMoney[keyMapTtoal], 2), " / ", mapRenewedContractNum[keyMapTtoal]) // "续约合同（金额/数量)-(数据)"
|
|
|
+ var renewalRateMoey string
|
|
|
+ var renewalRateNum string
|
|
|
+ if mapRenewedContractMoney[keyMapTtoal] == 0 || mapExpiredContractMoney[keyMapTtoal] == 0 {
|
|
|
+ renewalRateMoey = "0%"
|
|
|
+ } else {
|
|
|
+ renewalRateMoey = utils.SubFloatToString(mapRenewedContractMoney[keyMapTtoal]/mapExpiredContractMoney[keyMapTtoal]*100, 2) + "%"
|
|
|
+ }
|
|
|
+ if mapRenewedContractCompanyNum[keyMapTtoal] == 0 || mapExpiredContractCompanyNum[keyMapTtoal] == 0 {
|
|
|
+ renewalRateNum = "0%"
|
|
|
+ } else {
|
|
|
+ renewalRateNum = utils.SubFloatToString(float64(mapRenewedContractCompanyNum[keyMapTtoal])/float64(mapExpiredContractCompanyNum[keyMapTtoal])*100, 2) + "%"
|
|
|
+ }
|
|
|
+ sellerItem.RenewalRateData = fmt.Sprint(renewalRateMoey, " / ", renewalRateNum) //"续约率（金额/数量)-(数据)"
|
|
|
+ sellerItem.ConfirmedNoRenewalContractData = fmt.Sprint(utils.SubFloatToString(confirmedNoRenewalContractMoney[keyMapTtoal], 2), " / ", confirmedNoRenewalContractNum[keyMapTtoal]) //"确认不续约合同（金额/数量)-(数据)"
|
|
|
+
|
|
|
+ var confirmNonRenewalRateMoey string
|
|
|
+ var confirmNonRenewalRateNum string
|
|
|
+ if confirmedNoRenewalContractMoney[keyMapTtoal] == 0 || mapExpiredContractMoney[keyMapTtoal] == 0 {
|
|
|
+ confirmNonRenewalRateMoey = "0%"
|
|
|
+ } else {
|
|
|
+ confirmNonRenewalRateMoey = utils.SubFloatToString(confirmedNoRenewalContractMoney[keyMapTtoal]/mapExpiredContractMoney[keyMapTtoal]*100, 2) + "%"
|
|
|
+ }
|
|
|
+ if confirmedNoRenewalContractCompanyNum[keyMapTtoal] == 0 || mapExpiredContractCompanyNum[keyMapTtoal] == 0 {
|
|
|
+ confirmNonRenewalRateNum = "0%"
|
|
|
+ } else {
|
|
|
+ confirmNonRenewalRateNum = utils.SubFloatToString(float64(confirmedNoRenewalContractCompanyNum[keyMapTtoal])/float64(mapExpiredContractCompanyNum[keyMapTtoal])*100, 2) + "%"
|
|
|
+ }
|
|
|
+ sellerItem.ConfirmNonRenewalRateData = fmt.Sprint(confirmNonRenewalRateMoey, " / ", confirmNonRenewalRateNum) //确认不续约率（金额/数量)-(数据)"
|
|
|
+
|
|
|
+ sellerItem.SignedClientCount = fmt.Sprint(mapSignedClientNum[keyMapTtoal]) // 签约客户数量
|
|
|
+ if mapSignedClientNum[keyMapTtoal] == 0 || mapSignedClientMoney[keyMapTtoal] == 0 {
|
|
|
+ sellerItem.AverageRevenueCount = "0"
|
|
|
+ } else {
|
|
|
+ sellerItem.AverageRevenueCount = utils.SubFloatToString(mapSignedClientMoney[keyMapTtoal]/float64(mapSignedClientNum[keyMapTtoal]), 2) //客单价
|
|
|
+ }
|
|
|
+
|
|
|
+ sellerItem.InvoiceAmountCount = utils.SubFloatToString(mapInvoiceAmountMoney[keyMapTtoal], 2) //"开票金额-(数据)"
|
|
|
+ sellerItem.PaymentReceivedCount = utils.SubFloatToString(mapPaymentAmountMoney[keyMapTtoal], 2) //"开票金额-(数据)"
|
|
|
+ if mapInvoiceAmountMoney[keyMapTtoal] == 0 || mapPaymentAmountMoney[keyMapTtoal] == 0 {
|
|
|
+ sellerItem.UnpaidRatioCount = "0%"
|
|
|
+ } else {
|
|
|
+ sellerItem.UnpaidRatioCount = utils.SubFloatToString((mapInvoiceAmountMoney[keyMapTtoal]-mapPaymentAmountMoney[keyMapTtoal])/mapInvoiceAmountMoney[keyMapTtoal]*100, 2) + "%" //"未到款比例-(数据)"
|
|
|
+ }
|
|
|
+ sellerItem.NewCustomerInvoicingCount = utils.SubFloatToString(mapNewCustomerInvoicingMoney[keyMapTtoal], 2) // "新客开票-(数据)"
|
|
|
+ sellerItem.NewCustomerPaymentsReceivedCount = utils.SubFloatToString(mapNewCustomerPaymentsReceivedMoney[keyMapTtoal], 2) // "新客到款-(数据)"
|
|
|
+ item.DataList = append(item.DataList, sellerItem)
|
|
|
+ }
|
|
|
+
|
|
|
+ for _, vS := range sellerService {
|
|
|
+ sellerItem := new(statistic_report.RaiDataSummaryDetail)
|
|
|
+ sellerItem.SellerId = strconv.Itoa(vS.AdminId)
|
|
|
+ sellerServiceIds = append(sellerServiceIds, sellerItem.SellerId)
|
|
|
+ sellerItem.SellerName = vS.RealName
|
|
|
+ sellerItem.AddTrialCount = fmt.Sprint(mapAddTrialNum[keyMap])
|
|
|
+ sellerItem.NewContractData = fmt.Sprint(utils.SubFloatToString(mapNewContractMoney[keyMap], 2), " / ", mapNewContractNum[keyMap]) // 新签合同（金额/数量)-(数据)
|
|
|
+ sellerItem.ExpiredContractData = fmt.Sprint(utils.SubFloatToString(mapExpiredContractMoney[keyMap], 2), " / ", mapExpiredContractNum[keyMap]) //"到期合同（金额/数量)-(数据)"
|
|
|
+ sellerItem.RenewedContractData = fmt.Sprint(utils.SubFloatToString(mapRenewedContractMoney[keyMap], 2), " / ", mapRenewedContractNum[keyMap]) // "续约合同（金额/数量)-(数据)"
|
|
|
+ var renewalRateMoey string
|
|
|
+ var renewalRateNum string
|
|
|
+ if mapRenewedContractMoney[keyMap] == 0 || mapExpiredContractMoney[keyMap] == 0 {
|
|
|
+ renewalRateMoey = "0%"
|
|
|
+ } else {
|
|
|
+ renewalRateMoey = utils.SubFloatToString(mapRenewedContractMoney[keyMap]/mapExpiredContractMoney[keyMap]*100, 2) + "%"
|
|
|
+ }
|
|
|
+ if mapRenewedContractCompanyNum[keyMap] == 0 || mapExpiredContractCompanyNum[keyMap] == 0 {
|
|
|
+ renewalRateNum = "0%"
|
|
|
+ } else {
|
|
|
+ renewalRateNum = utils.SubFloatToString(float64(mapRenewedContractCompanyNum[keyMap])/float64(mapExpiredContractCompanyNum[keyMap])*100, 2) + "%"
|
|
|
+ }
|
|
|
+ sellerItem.RenewalRateData = fmt.Sprint(renewalRateMoey, " / ", renewalRateNum) //"续约率（金额/数量)-(数据)"
|
|
|
+ sellerItem.ConfirmedNoRenewalContractData = fmt.Sprint(utils.SubFloatToString(confirmedNoRenewalContractMoney[keyMap], 2), " / ", confirmedNoRenewalContractNum[keyMap]) //"确认不续约合同（金额/数量)-(数据)"
|
|
|
+
|
|
|
+ var confirmNonRenewalRateMoey string
|
|
|
+ var confirmNonRenewalRateNum string
|
|
|
+ if confirmedNoRenewalContractMoney[keyMap] == 0 || mapExpiredContractMoney[keyMap] == 0 {
|
|
|
+ confirmNonRenewalRateMoey = "0%"
|
|
|
+ } else {
|
|
|
+ confirmNonRenewalRateMoey = utils.SubFloatToString(confirmedNoRenewalContractMoney[keyMap]/mapExpiredContractMoney[keyMap]*100, 2) + "%"
|
|
|
+ }
|
|
|
+ if confirmedNoRenewalContractCompanyNum[keyMap] == 0 || mapExpiredContractCompanyNum[keyMap] == 0 {
|
|
|
+ confirmNonRenewalRateNum = "0%"
|
|
|
+ } else {
|
|
|
+ confirmNonRenewalRateNum = utils.SubFloatToString(float64(confirmedNoRenewalContractCompanyNum[keyMap])/float64(mapExpiredContractCompanyNum[keyMap])*100, 2) + "%"
|
|
|
+ }
|
|
|
+ sellerItem.ConfirmNonRenewalRateData = fmt.Sprint(confirmNonRenewalRateMoey, " / ", confirmNonRenewalRateNum) //确认不续约率（金额/数量)-(数据)"
|
|
|
+
|
|
|
+ sellerItem.SignedClientCount = fmt.Sprint(mapSignedClientNum[keyMap]) // 签约客户数量
|
|
|
+ if mapSignedClientNum[keyMap] == 0 || mapSignedClientMoney[keyMap] == 0 {
|
|
|
+ sellerItem.AverageRevenueCount = "0"
|
|
|
+ } else {
|
|
|
+ sellerItem.AverageRevenueCount = utils.SubFloatToString(mapSignedClientMoney[keyMap]/float64(mapSignedClientNum[keyMap]), 2) //客单价
|
|
|
+ }
|
|
|
+
|
|
|
+ sellerItem.InvoiceAmountCount = utils.SubFloatToString(mapInvoiceAmountMoney[keyMap], 2) //"开票金额-(数据)"
|
|
|
+ sellerItem.PaymentReceivedCount = utils.SubFloatToString(mapPaymentAmountMoney[keyMap], 2) //"开票金额-(数据)"
|
|
|
+ if mapInvoiceAmountMoney[keyMap] == 0 || mapPaymentAmountMoney[keyMap] == 0 {
|
|
|
+ sellerItem.UnpaidRatioCount = "0%"
|
|
|
+ } else {
|
|
|
+ sellerItem.UnpaidRatioCount = utils.SubFloatToString((mapInvoiceAmountMoney[keyMap]-mapPaymentAmountMoney[keyMap])/mapInvoiceAmountMoney[keyMap]*100, 2) + "%" //"未到款比例-(数据)"
|
|
|
+ }
|
|
|
+ sellerItem.NewCustomerInvoicingCount = utils.SubFloatToString(mapNewCustomerInvoicingMoney[keyMap], 2) // "新客开票-(数据)"
|
|
|
+ sellerItem.NewCustomerPaymentsReceivedCount = utils.SubFloatToString(mapNewCustomerPaymentsReceivedMoney[keyMap], 2) // "新客到款-(数据)"
|
|
|
+ if developButton || serverButton || serviceAdminId != "" {
|
|
|
+ item.DataList = append(item.DataList, sellerItem)
|
|
|
+ }
|
|
|
+ }
|
|
|
+ if len(sellerService) > 0 {
|
|
|
+ sellerItem := new(statistic_report.RaiDataSummaryDetail)
|
|
|
+ sellerItem.SellerId = strings.Join(sellerServiceIds, ",")
|
|
|
+ sellerItem.SellerName = "服务组合计"
|
|
|
+ sellerItem.AddTrialCount = fmt.Sprint(mapAddTrialNum[keyMapTtoalServer])
|
|
|
+ sellerItem.NewContractData = fmt.Sprint(utils.SubFloatToString(mapNewContractMoney[keyMapTtoalServer], 2), " / ", mapNewContractNum[keyMapTtoalServer]) // 新签合同（金额/数量)-(数据)
|
|
|
+ sellerItem.ExpiredContractData = fmt.Sprint(utils.SubFloatToString(mapExpiredContractMoney[keyMapTtoalServer], 2), " / ", mapExpiredContractNum[keyMapTtoalServer]) //"到期合同（金额/数量)-(数据)"
|
|
|
+ sellerItem.RenewedContractData = fmt.Sprint(utils.SubFloatToString(mapRenewedContractMoney[keyMapTtoalServer], 2), " / ", mapRenewedContractNum[keyMapTtoalServer]) // "续约合同（金额/数量)-(数据)"
|
|
|
+ var renewalRateMoey string
|
|
|
+ var renewalRateNum string
|
|
|
+ if mapRenewedContractMoney[keyMapTtoalServer] == 0 || mapExpiredContractMoney[keyMapTtoalServer] == 0 {
|
|
|
+ renewalRateMoey = "0%"
|
|
|
+ } else {
|
|
|
+ renewalRateMoey = utils.SubFloatToString(mapRenewedContractMoney[keyMapTtoalServer]/mapExpiredContractMoney[keyMapTtoalServer]*100, 2) + "%"
|
|
|
+ }
|
|
|
+ if mapRenewedContractCompanyNum[keyMapTtoalServer] == 0 || mapExpiredContractCompanyNum[keyMapTtoalServer] == 0 {
|
|
|
+ renewalRateNum = "0%"
|
|
|
+ } else {
|
|
|
+ renewalRateNum = utils.SubFloatToString(float64(mapRenewedContractCompanyNum[keyMapTtoalServer])/float64(mapExpiredContractCompanyNum[keyMapTtoalServer])*100, 2) + "%"
|
|
|
+ }
|
|
|
+ sellerItem.RenewalRateData = fmt.Sprint(renewalRateMoey, " / ", renewalRateNum) //"续约率（金额/数量)-(数据)"
|
|
|
+ sellerItem.ConfirmedNoRenewalContractData = fmt.Sprint(utils.SubFloatToString(confirmedNoRenewalContractMoney[keyMapTtoalServer], 2), " / ", confirmedNoRenewalContractNum[keyMapTtoalServer]) //"确认不续约合同（金额/数量)-(数据)"
|
|
|
+
|
|
|
+ var confirmNonRenewalRateMoey string
|
|
|
+ var confirmNonRenewalRateNum string
|
|
|
+ if confirmedNoRenewalContractMoney[keyMapTtoalServer] == 0 || mapExpiredContractMoney[keyMapTtoalServer] == 0 {
|
|
|
+ confirmNonRenewalRateMoey = "0%"
|
|
|
+ } else {
|
|
|
+ confirmNonRenewalRateMoey = utils.SubFloatToString(confirmedNoRenewalContractMoney[keyMapTtoalServer]/mapExpiredContractMoney[keyMapTtoalServer]*100, 2) + "%"
|
|
|
+ }
|
|
|
+ if confirmedNoRenewalContractCompanyNum[keyMapTtoalServer] == 0 || mapExpiredContractCompanyNum[keyMapTtoalServer] == 0 {
|
|
|
+ confirmNonRenewalRateNum = "0%"
|
|
|
+ } else {
|
|
|
+ confirmNonRenewalRateNum = utils.SubFloatToString(float64(confirmedNoRenewalContractCompanyNum[keyMapTtoalServer])/float64(mapExpiredContractCompanyNum[keyMapTtoalServer])*100, 2) + "%"
|
|
|
+ }
|
|
|
+ sellerItem.ConfirmNonRenewalRateData = fmt.Sprint(confirmNonRenewalRateMoey, " / ", confirmNonRenewalRateNum) //确认不续约率（金额/数量)-(数据)"
|
|
|
+
|
|
|
+ sellerItem.SignedClientCount = fmt.Sprint(mapSignedClientNum[keyMapTtoalServer]) // 签约客户数量
|
|
|
+ if mapSignedClientNum[keyMapTtoalServer] == 0 || mapSignedClientMoney[keyMapTtoalServer] == 0 {
|
|
|
+ sellerItem.AverageRevenueCount = "0"
|
|
|
+ } else {
|
|
|
+ sellerItem.AverageRevenueCount = utils.SubFloatToString(mapSignedClientMoney[keyMapTtoalServer]/float64(mapSignedClientNum[keyMapTtoalServer]), 2) //客单价
|
|
|
+ }
|
|
|
+
|
|
|
+ sellerItem.InvoiceAmountCount = utils.SubFloatToString(mapInvoiceAmountMoney[keyMapTtoalServer], 2) //"开票金额-(数据)"
|
|
|
+ sellerItem.PaymentReceivedCount = utils.SubFloatToString(mapPaymentAmountMoney[keyMapTtoalServer], 2) //"开票金额-(数据)"
|
|
|
+ if mapInvoiceAmountMoney[keyMapTtoalServer] == 0 || mapPaymentAmountMoney[keyMapTtoalServer] == 0 {
|
|
|
+ sellerItem.UnpaidRatioCount = "0%"
|
|
|
+ } else {
|
|
|
+ sellerItem.UnpaidRatioCount = utils.SubFloatToString((mapInvoiceAmountMoney[keyMapTtoalServer]-mapPaymentAmountMoney[keyMapTtoalServer])/mapInvoiceAmountMoney[keyMapTtoalServer]*100, 2) + "%" //"未到款比例-(数据)"
|
|
|
+ }
|
|
|
+ sellerItem.NewCustomerInvoicingCount = utils.SubFloatToString(mapNewCustomerInvoicingMoney[keyMapTtoalServer], 2) // "新客开票-(数据)"
|
|
|
+ sellerItem.NewCustomerPaymentsReceivedCount = utils.SubFloatToString(mapNewCustomerPaymentsReceivedMoney[keyMapTtoalServer], 2) // "新客到款-(数据)"
|
|
|
+ item.DataList = append(item.DataList, sellerItem)
|
|
|
+ }
|
|
|
+ items = append(items, item)
|
|
|
+ }
|
|
|
+ }
|
|
|
+ resp.List = items
|
|
|
+ br.Ret = 200
|
|
|
+ br.Success = true
|
|
|
+ br.Msg = "获取成功"
|
|
|
+ br.Data = resp
|
|
|
+}
|
|
|
+
|
|
|
+// MergeCompanyList
|
|
|
+// @Title 权益数据汇总弹窗详情
|
|
|
+// @Description 权益数据汇总弹窗详情接口
|
|
|
+// @Param SellerId query int true "销售ID"
|
|
|
+// @Param DataType query string false "报表类型，枚举值：`季度`，`年度`，`半年度`"
|
|
|
+// @Param PopupType query string false "弹窗数据类型，枚举值："
|
|
|
+// @Param PageSize query int true "每页数据条数"
|
|
|
+// @Param CurrentIndex query int true "当前页页码，从1开始"
|
|
|
+// @Success 200 {object} statistic_report.RaiDataSummaryPopupTypeResp
|
|
|
+// @router /rai_data_summary/detail [get]
|
|
|
+func (this *StatisticRaiDataSummaryController) RaiDataSummaryDetail() {
|
|
|
+ br := new(models.BaseResponse).Init()
|
|
|
+ defer func() {
|
|
|
+ this.Data["json"] = br
|
|
|
+ this.ServeJSON()
|
|
|
+ }()
|
|
|
+
|
|
|
+ sysUser := this.SysUser
|
|
|
+ if sysUser == nil {
|
|
|
+ br.Msg = "请登录"
|
|
|
+ br.ErrMsg = "请登录，SysUser Is Empty"
|
|
|
+ br.Ret = 408
|
|
|
+ return
|
|
|
+ }
|
|
|
+ pageSize, _ := this.GetInt("PageSize")
|
|
|
+ currentIndex, _ := this.GetInt("CurrentIndex")
|
|
|
+ dataType := this.GetString("DataType")
|
|
|
+ sellerId := this.GetString("SellerId")
|
|
|
+ popupType := this.GetString("PopupType")
|
|
|
+
|
|
|
+ var startSize int
|
|
|
+ if pageSize <= 0 {
|
|
|
+ pageSize = utils.PageSize20
|
|
|
+ }
|
|
|
+ if currentIndex <= 0 {
|
|
|
+ currentIndex = 1
|
|
|
+ }
|
|
|
+ startSize = utils.StartIndex(currentIndex, pageSize)
|
|
|
+
|
|
|
+ var startDate string
|
|
|
+ var endDate string
|
|
|
+ year := (dataType[:4])
|
|
|
+ if strings.Contains(dataType, "Q1") {
|
|
|
+ startDate = year + "-01-01"
|
|
|
+ endDate = year + "-03-31"
|
|
|
+ } else if strings.Contains(dataType, "Q2") {
|
|
|
+ startDate = year + "-04-01"
|
|
|
+ endDate = year + "-06-30"
|
|
|
+ } else if strings.Contains(dataType, "Q3") {
|
|
|
+ startDate = year + "-07-01"
|
|
|
+ endDate = year + "-09-30"
|
|
|
+ } else if strings.Contains(dataType, "Q4") {
|
|
|
+ startDate = year + "-10-01"
|
|
|
+ endDate = year + "-12-31"
|
|
|
+ } else if strings.Contains(dataType, "H1") {
|
|
|
+ startDate = year + "-01-01"
|
|
|
+ endDate = year + "-06-31"
|
|
|
+ } else if strings.Contains(dataType, "H2") {
|
|
|
+ startDate = year + "-07-01"
|
|
|
+ endDate = year + "-12-31"
|
|
|
+ } else {
|
|
|
+ startDate = year + "-01-01"
|
|
|
+ endDate = year + "-12-31"
|
|
|
+ }
|
|
|
+
|
|
|
+ resp := new(statistic_report.RaiDataSummaryPopupTypeResp)
|
|
|
+ var listResp []*statistic_report.RaiDataSummaryDetailResp
|
|
|
+ var listGroup []*models.CompanyContractGroupList
|
|
|
+ var trialTotal int
|
|
|
+
|
|
|
+ var condition string
|
|
|
+ var pars []interface{}
|
|
|
+
|
|
|
+ //新签合同的客户ID
|
|
|
+ var companyIdsNew []int
|
|
|
+ {
|
|
|
+ var conditionNew string
|
|
|
+ var parsNew []interface{}
|
|
|
+ if sellerId != "" {
|
|
|
+ conditionNew += ` AND a.sys_user_id IN (` + sellerId + `) `
|
|
|
+ }
|
|
|
+ conditionNew = " AND a.product_id = 2 AND a.status = 1 AND a.start_date >= ? AND a.start_date <= ? AND a.rai_contract_type = '新签合同' "
|
|
|
+ parsNew = append(parsNew, startDate, endDate)
|
|
|
+ listNewData, err := statistic_report.GetRaiDataSummaryList(conditionNew, parsNew)
|
|
|
+ if err != nil {
|
|
|
+ br.Msg = "获取数据信息失败"
|
|
|
+ br.ErrMsg = "获取数据信息失败,Err:" + err.Error()
|
|
|
+ return
|
|
|
+ }
|
|
|
+ for _, v := range listNewData {
|
|
|
+ companyIdsNew = append(companyIdsNew, v.CompanyId)
|
|
|
+ }
|
|
|
+ }
|
|
|
+ companyIdsNew = append(companyIdsNew, 0)
|
|
|
+ lenArrCompany := len(companyIdsNew)
|
|
|
+
|
|
|
+ switch popupType {
|
|
|
+ case "新增试用":
|
|
|
+ var parsTry []interface{}
|
|
|
+ var conditionTry string
|
|
|
+ if sellerId != "" {
|
|
|
+ conditionTry += ` AND a.sys_user_id IN (` + sellerId + `) `
|
|
|
+ }
|
|
|
+ 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') ) `
|
|
|
+
|
|
|
+ parsTry = append(parsTry, startDate, endDate)
|
|
|
+ total, err := models.GetIncrementalCompanyCountByOperationRecordRai(conditionTry, parsTry)
|
|
|
+ if err != nil {
|
|
|
+ br.Msg = "获取失败"
|
|
|
+ br.ErrMsg = "获取新增试用客户数量失败，Err:" + err.Error()
|
|
|
+ return
|
|
|
+ }
|
|
|
+ trialTotal = total
|
|
|
+
|
|
|
+ //列表页数据
|
|
|
+ tryList, err := models.GetIncrementalCompanyListByOperationRecordRai(conditionTry, parsTry, startSize, pageSize)
|
|
|
+ if err != nil {
|
|
|
+ br.Msg = "获取失败"
|
|
|
+ br.ErrMsg = "获取失败，Err:" + err.Error()
|
|
|
+ return
|
|
|
+ }
|
|
|
+ if len(tryList) > 0 {
|
|
|
+ for _, v := range tryList {
|
|
|
+ item := new(statistic_report.RaiDataSummaryDetailResp)
|
|
|
+ v.SellerName = v.SysRealName
|
|
|
+ if v.Operation == "add" {
|
|
|
+ item.AddType = "新建"
|
|
|
+ } else if v.Operation == "receive" || v.Operation == "apply_receive" {
|
|
|
+ item.AddType = "领取"
|
|
|
+ }
|
|
|
+ item.CompanyName = v.CompanyName
|
|
|
+ item.SellerName = v.SellerName
|
|
|
+ item.CreateTime = v.CreateTime
|
|
|
+ listResp = append(listResp, item)
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ case "新签合同":
|
|
|
+ if sellerId != "" {
|
|
|
+ condition += ` AND a.seller_id_init IN (` + sellerId + `) `
|
|
|
+ }
|
|
|
+
|
|
|
+ condition += ` AND a.status = 1 AND a.start_date >= ? AND a.start_date <= ? `
|
|
|
+ pars = append(pars, startDate, endDate)
|
|
|
+ condition += ` AND a.rai_contract_type = ? `
|
|
|
+ pars = append(pars, "新签合同")
|
|
|
+
|
|
|
+ total, err := company.GetIncrementalNewCompanyProductMergeCount(condition, pars)
|
|
|
+ if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
+ br.Msg = "获取失败"
|
|
|
+ br.ErrMsg = "获取失败，Err:" + err.Error()
|
|
|
+ return
|
|
|
+ }
|
|
|
+ trialTotal = total
|
|
|
+ //列表页数据
|
|
|
+ tmpList, err := models.GetIncrementalCompanyMergeList(condition, pars, startSize, pageSize)
|
|
|
+ if err != nil {
|
|
|
+ br.Msg = "获取失败"
|
|
|
+ br.ErrMsg = "获取失败，Err:" + err.Error()
|
|
|
+ return
|
|
|
+ }
|
|
|
+ if len(tmpList) > 0 {
|
|
|
+ var companyContractIds []int
|
|
|
+ for _, v := range tmpList {
|
|
|
+ companyContractIds = append(companyContractIds, v.CompanyContractId)
|
|
|
+ }
|
|
|
+
|
|
|
+ //合并合同所对应的权限
|
|
|
+ mappermissionName, err := cygxService.GetCompanyContractPermissionNameMapById(companyContractIds)
|
|
|
+ if err != nil {
|
|
|
+ br.Msg = "获取失败"
|
|
|
+ br.ErrMsg = "获取失败，Err:" + err.Error()
|
|
|
+ return
|
|
|
+ }
|
|
|
+ for _, v := range tmpList {
|
|
|
+ item := new(statistic_report.RaiDataSummaryDetailResp)
|
|
|
+ item.CompanyName = v.CompanyName
|
|
|
+ item.SellerName = v.SellerNameInit
|
|
|
+ item.StartDate = v.StartDate
|
|
|
+ item.EndDate = v.EndDate
|
|
|
+ item.Money = v.Money
|
|
|
+ item.PermissionName = mappermissionName[v.CompanyContractId]
|
|
|
+ listResp = append(listResp, item)
|
|
|
+ }
|
|
|
+
|
|
|
+ listGroup, err = models.GetCompanyContractGroupList(condition, pars)
|
|
|
+ if err != nil {
|
|
|
+ br.Msg = "获取失败"
|
|
|
+ br.ErrMsg = "获取失败，Err:" + err.Error()
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ }
|
|
|
+
|
|
|
+ case "到期合同":
|
|
|
+
|
|
|
+ if sellerId != "" {
|
|
|
+ condition += ` AND a.seller_id_last IN (` + sellerId + `) `
|
|
|
+ }
|
|
|
+
|
|
|
+ condition += ` AND a.status = 1 AND a.end_date >= ? AND a.end_date <= ? AND a.end_date < ? `
|
|
|
+ pars = append(pars, startDate, endDate, time.Now().Format(utils.FormatDate))
|
|
|
+
|
|
|
+ total, err := company.GetIncrementalNewCompanyProductMergeCount(condition, pars)
|
|
|
+ if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
+ br.Msg = "获取失败"
|
|
|
+ br.ErrMsg = "获取失败，Err:" + err.Error()
|
|
|
+ return
|
|
|
+ }
|
|
|
+ trialTotal = total
|
|
|
+ //列表页数据
|
|
|
+ tmpList, err := models.GetIncrementalCompanyMergeList(condition, pars, startSize, pageSize)
|
|
|
+ if err != nil {
|
|
|
+ br.Msg = "获取失败"
|
|
|
+ br.ErrMsg = "获取失败，Err:" + err.Error()
|
|
|
+ return
|
|
|
+ }
|
|
|
+ if len(tmpList) > 0 {
|
|
|
+ var companyContractIds []int
|
|
|
+ for _, v := range tmpList {
|
|
|
+ companyContractIds = append(companyContractIds, v.CompanyContractId)
|
|
|
+ }
|
|
|
+
|
|
|
+ //合并合同所对应的权限
|
|
|
+ mappermissionName, err := cygxService.GetCompanyContractPermissionNameMapById(companyContractIds)
|
|
|
+ if err != nil {
|
|
|
+ br.Msg = "获取失败"
|
|
|
+ br.ErrMsg = "获取失败，Err:" + err.Error()
|
|
|
+ return
|
|
|
+ }
|
|
|
+ for _, v := range tmpList {
|
|
|
+ item := new(statistic_report.RaiDataSummaryDetailResp)
|
|
|
+ item.CompanyName = v.CompanyName
|
|
|
+ item.SellerName = v.SellerNameLast
|
|
|
+ item.StartDate = v.StartDate
|
|
|
+ item.EndDate = v.EndDate
|
|
|
+ item.Money = v.Money
|
|
|
+ item.PermissionName = mappermissionName[v.CompanyContractId]
|
|
|
+ listResp = append(listResp, item)
|
|
|
+ }
|
|
|
+ listGroup, err = models.GetCompanyContractGroupList(condition, pars)
|
|
|
+ if err != nil {
|
|
|
+ br.Msg = "获取失败"
|
|
|
+ br.ErrMsg = "获取失败，Err:" + err.Error()
|
|
|
+ return
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ case "续约合同":
|
|
|
+ if sellerId != "" {
|
|
|
+ condition += ` AND a.seller_id_last IN (` + sellerId + `) `
|
|
|
+ }
|
|
|
+
|
|
|
+ condition += ` AND a.status = 1 AND a.inherit_end_date >= ? AND a.inherit_end_date <= ? AND a.inherit_company_contract_id > 0 AND a.rai_contract_type = '续约合同' AND a.company_id NOT IN (` + utils.GetOrmInReplace(lenArrCompany) + `) `
|
|
|
+ pars = append(pars, startDate, endDate, companyIdsNew)
|
|
|
+
|
|
|
+ total, err := company.GetIncrementalNewCompanyProductMergeCount(condition, pars)
|
|
|
+ if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
+ br.Msg = "获取失败"
|
|
|
+ br.ErrMsg = "获取失败，Err:" + err.Error()
|
|
|
+ return
|
|
|
+ }
|
|
|
+ trialTotal = total
|
|
|
+ //列表页数据
|
|
|
+ tmpList, err := models.GetIncrementalCompanyMergeList(condition, pars, startSize, pageSize)
|
|
|
+ if err != nil {
|
|
|
+ br.Msg = "获取失败"
|
|
|
+ br.ErrMsg = "获取失败，Err:" + err.Error()
|
|
|
+ return
|
|
|
+ }
|
|
|
+ if len(tmpList) > 0 {
|
|
|
+ var companyContractIds []int
|
|
|
+ for _, v := range tmpList {
|
|
|
+ companyContractIds = append(companyContractIds, v.CompanyContractId)
|
|
|
+ }
|
|
|
+
|
|
|
+ //合并合同所对应的权限
|
|
|
+ mappermissionName, err := cygxService.GetCompanyContractPermissionNameMapById(companyContractIds)
|
|
|
+ if err != nil {
|
|
|
+ br.Msg = "获取失败"
|
|
|
+ br.ErrMsg = "获取失败，Err:" + err.Error()
|
|
|
+ return
|
|
|
+ }
|
|
|
+ for _, v := range tmpList {
|
|
|
+ item := new(statistic_report.RaiDataSummaryDetailResp)
|
|
|
+ item.CompanyName = v.CompanyName
|
|
|
+ item.SellerName = v.SellerNameLast
|
|
|
+ item.StartDate = v.StartDate
|
|
|
+ item.EndDate = v.EndDate
|
|
|
+ item.Money = v.Money
|
|
|
+ item.PermissionName = mappermissionName[v.CompanyContractId]
|
|
|
+ listResp = append(listResp, item)
|
|
|
+ }
|
|
|
+ listGroup, err = models.GetCompanyContractGroupList(condition, pars)
|
|
|
+ if err != nil {
|
|
|
+ br.Msg = "获取失败"
|
|
|
+ br.ErrMsg = "获取失败，Err:" + err.Error()
|
|
|
+ return
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ case "续约率":
|
|
|
+ var conditionEnd string
|
|
|
+ var parsEnd []interface{}
|
|
|
+ if sellerId != "" {
|
|
|
+ condition += ` AND a.seller_id_last IN (` + sellerId + `) `
|
|
|
+
|
|
|
+ conditionEnd += ` AND a.seller_id_last IN (` + sellerId + `) `
|
|
|
+ }
|
|
|
+
|
|
|
+ condition += ` AND a.status = 1 AND a.inherit_end_date >= ? AND a.inherit_end_date <= ? AND inherit_company_contract_id > 0 AND a.rai_contract_type = '续约合同' AND a.company_id NOT IN (` + utils.GetOrmInReplace(lenArrCompany) + `) `
|
|
|
+ pars = append(pars, startDate, endDate, companyIdsNew)
|
|
|
+ listRaiData, err := statistic_report.GetRaiDataSummaryList(condition, pars)
|
|
|
+ if err != nil {
|
|
|
+ br.Msg = "获取数据信息失败"
|
|
|
+ br.ErrMsg = "获取数据信息失败,Err:" + err.Error()
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ //到期合同数据
|
|
|
+ conditionEnd += ` AND a.status = 1 AND a.end_date >= ? AND a.end_date <= ? AND a.end_date < ? `
|
|
|
+ parsEnd = append(parsEnd, startDate, endDate, time.Now().Format(utils.FormatDate))
|
|
|
+ listEndData, err := statistic_report.GetRaiDataSummaryList(conditionEnd, parsEnd)
|
|
|
+ if err != nil {
|
|
|
+ br.Msg = "获取数据信息失败"
|
|
|
+ br.ErrMsg = "获取数据信息失败,Err:" + err.Error()
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ var renewedContractMoney float64 // 续约金额
|
|
|
+ var renewedContractCompany float64 // 续约客户数
|
|
|
+ maprenewedContractCompany := make(map[int]bool)
|
|
|
+
|
|
|
+ var expiredContractMoney float64 //到期金额
|
|
|
+ var expiredContractCompany float64 // 到期客户数
|
|
|
+ mapexpiredContractCompany := make(map[int]bool)
|
|
|
+
|
|
|
+ for _, v := range listRaiData {
|
|
|
+ renewedContractMoney += v.Money
|
|
|
+ if !maprenewedContractCompany[v.CompanyId] {
|
|
|
+ renewedContractCompany++
|
|
|
+ maprenewedContractCompany[v.CompanyId] = true
|
|
|
+ }
|
|
|
+ //startDateTime := utils.StrDateToDate(v.StartDate)
|
|
|
+ //if startDateTime.Before(time.Now().AddDate(0, 0, -1)) { //到期合同数据
|
|
|
+ // expiredContractMoney += v.Money
|
|
|
+ // if !mapexpiredContractCompany[v.CompanyId] {
|
|
|
+ // expiredContractCompany++
|
|
|
+ // mapexpiredContractCompany[v.CompanyId] = true
|
|
|
+ // }
|
|
|
+ //}
|
|
|
+ }
|
|
|
+
|
|
|
+ for _, v := range listEndData {
|
|
|
+ expiredContractMoney += v.Money
|
|
|
+ if !mapexpiredContractCompany[v.CompanyId] {
|
|
|
+ expiredContractCompany++
|
|
|
+ mapexpiredContractCompany[v.CompanyId] = true
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ item := new(statistic_report.RaiDataSummaryDetailResp)
|
|
|
+ item.TbaleNameAText = "金额续约率"
|
|
|
+ item.RenewedContractMoney = fmt.Sprint(utils.SubFloatToString(renewedContractMoney, 2))
|
|
|
+ item.ExpiredContractMoney = fmt.Sprint(utils.SubFloatToString(expiredContractMoney, 2))
|
|
|
+ if renewedContractMoney == 0 || expiredContractMoney == 0 {
|
|
|
+ item.RenewalRate = "0%"
|
|
|
+ } else {
|
|
|
+ item.RenewalRate = fmt.Sprint(utils.SubFloatToString(renewedContractMoney/expiredContractMoney*100, 2), "%")
|
|
|
+ }
|
|
|
+
|
|
|
+ listResp = append(listResp, item)
|
|
|
+
|
|
|
+ item2 := new(statistic_report.RaiDataSummaryDetailResp)
|
|
|
+ item2.TbaleNameAText = "客户续约率"
|
|
|
+ item2.RenewedContractMoney = fmt.Sprint(renewedContractCompany)
|
|
|
+ item2.ExpiredContractMoney = fmt.Sprint(expiredContractCompany)
|
|
|
+ if renewedContractCompany == 0 || expiredContractCompany == 0 {
|
|
|
+ item2.RenewalRate = "0%"
|
|
|
+ } else {
|
|
|
+ item2.RenewalRate = fmt.Sprint(utils.SubFloatToString(renewedContractCompany/expiredContractCompany*100, 2), "%")
|
|
|
+ }
|
|
|
+
|
|
|
+ listResp = append(listResp, item2)
|
|
|
+
|
|
|
+ case "确认不续约合同":
|
|
|
+ noRenewedcompanyContractIds := services.GetCompanyContractNoRenewedAscribeListArr()
|
|
|
+ condition += ` AND a.company_contract_id IN (` + utils.GetOrmInReplace(len(noRenewedcompanyContractIds)) + `) ` // 已确认
|
|
|
+ pars = append(pars, noRenewedcompanyContractIds)
|
|
|
+ if sellerId != "" {
|
|
|
+ condition += ` AND a.seller_id_last IN (` + sellerId + `) `
|
|
|
+ }
|
|
|
+ condition += ` AND a.product_id = 2 AND a.status = 1 AND a.end_date >= ? AND a.end_date <= ? AND a.end_date <= ? `
|
|
|
+ pars = append(pars, startDate, endDate, time.Now().Format(utils.FormatDate))
|
|
|
+
|
|
|
+ total, err := company.GetIncrementalNewCompanyProductMergeCount(condition, pars)
|
|
|
+ if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
+ br.Msg = "获取失败"
|
|
|
+ br.ErrMsg = "获取失败，Err:" + err.Error()
|
|
|
+ return
|
|
|
+ }
|
|
|
+ trialTotal = total
|
|
|
+ //列表页数据
|
|
|
+ tmpList, err := models.GetIncrementalCompanyMergeList(condition, pars, startSize, pageSize)
|
|
|
+ if err != nil {
|
|
|
+ br.Msg = "获取失败"
|
|
|
+ br.ErrMsg = "获取失败，Err:" + err.Error()
|
|
|
+ return
|
|
|
+ }
|
|
|
+ if len(tmpList) > 0 {
|
|
|
+ var companyContractIds []int
|
|
|
+ for _, v := range tmpList {
|
|
|
+ companyContractIds = append(companyContractIds, v.CompanyContractId)
|
|
|
+ }
|
|
|
+
|
|
|
+ //合并合同所对应的权限
|
|
|
+ mappermissionName, err := cygxService.GetCompanyContractPermissionNameMapById(companyContractIds)
|
|
|
+ if err != nil {
|
|
|
+ br.Msg = "获取失败"
|
|
|
+ br.ErrMsg = "获取失败，Err:" + err.Error()
|
|
|
+ return
|
|
|
+ }
|
|
|
+ for _, v := range tmpList {
|
|
|
+ item := new(statistic_report.RaiDataSummaryDetailResp)
|
|
|
+ item.CompanyName = v.CompanyName
|
|
|
+ item.SellerName = v.SellerNameInit
|
|
|
+ item.StartDate = v.StartDate
|
|
|
+ item.EndDate = v.EndDate
|
|
|
+ item.Money = v.Money
|
|
|
+ item.PermissionName = mappermissionName[v.CompanyContractId]
|
|
|
+ listResp = append(listResp, item)
|
|
|
+ }
|
|
|
+
|
|
|
+ listGroup, err = models.GetCompanyContractGroupList(condition, pars)
|
|
|
+ if err != nil {
|
|
|
+ br.Msg = "获取失败"
|
|
|
+ br.ErrMsg = "获取失败，Err:" + err.Error()
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ }
|
|
|
+
|
|
|
+ case "确认不续约率":
|
|
|
+ noRenewedcompanyContractIdsMap := services.GetCompanyContractNoRenewedAscribeListMap()
|
|
|
+ var conditionEnd string
|
|
|
+ var parsEnd []interface{}
|
|
|
+ if sellerId != "" {
|
|
|
+ condition += ` AND a.seller_id_last IN (` + sellerId + `) `
|
|
|
+
|
|
|
+ conditionEnd += ` AND a.seller_id_last IN (` + sellerId + `) `
|
|
|
+ }
|
|
|
+
|
|
|
+ condition += ` AND a.product_id = 2 AND a.status = 1 AND a.end_date >= ? AND a.end_date <= ? AND a.end_date <= ? `
|
|
|
+ pars = append(pars, startDate, endDate, time.Now().Format(utils.FormatDate))
|
|
|
+ listRaiData, err := statistic_report.GetRaiDataSummaryList(condition, pars)
|
|
|
+ if err != nil {
|
|
|
+ br.Msg = "获取数据信息失败"
|
|
|
+ br.ErrMsg = "获取数据信息失败,Err:" + err.Error()
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ conditionEnd += ` AND a.product_id = 2 AND a.status = 1 AND a.end_date >= ? AND a.end_date <= ? AND a.end_date < ? `
|
|
|
+ parsEnd = append(parsEnd, startDate, endDate, time.Now().Format(utils.FormatDate))
|
|
|
+
|
|
|
+ listEndData, err := statistic_report.GetRaiDataSummaryList(conditionEnd, parsEnd)
|
|
|
+ if err != nil {
|
|
|
+ br.Msg = "获取数据信息失败"
|
|
|
+ br.ErrMsg = "获取数据信息失败,Err:" + err.Error()
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ var norenewedContractMoney float64 // 不续约金额
|
|
|
+ var norenewedContractCompany float64 // 不续约客户数
|
|
|
+ mapnorenewedContractCompany := make(map[int]bool)
|
|
|
+
|
|
|
+ var expiredContractMoney float64 //到期金额
|
|
|
+ var expiredContractCompany float64 // 到期客户数
|
|
|
+ mapexpiredContractCompany := make(map[int]bool)
|
|
|
+
|
|
|
+ for _, v := range listRaiData {
|
|
|
+ if noRenewedcompanyContractIdsMap[v.CompanyContractId] {
|
|
|
+ norenewedContractMoney += v.Money
|
|
|
+ if !mapnorenewedContractCompany[v.CompanyId] {
|
|
|
+ norenewedContractCompany++
|
|
|
+ mapnorenewedContractCompany[v.CompanyId] = true
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ for _, v := range listEndData {
|
|
|
+ expiredContractMoney += v.Money
|
|
|
+ if !mapexpiredContractCompany[v.CompanyId] {
|
|
|
+ expiredContractCompany++
|
|
|
+ mapexpiredContractCompany[v.CompanyId] = true
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ item := new(statistic_report.RaiDataSummaryDetailResp)
|
|
|
+ item.TbaleNameAText = "金额不续约率"
|
|
|
+ item.RenewedContractMoney = fmt.Sprint(utils.SubFloatToString(norenewedContractMoney, 2))
|
|
|
+ item.ExpiredContractMoney = fmt.Sprint(utils.SubFloatToString(expiredContractMoney, 2))
|
|
|
+ if norenewedContractMoney == 0 || expiredContractMoney == 0 {
|
|
|
+ item.RenewalRate = "0%"
|
|
|
+ } else {
|
|
|
+ item.RenewalRate = fmt.Sprint(utils.SubFloatToString(norenewedContractMoney/expiredContractMoney*100, 2), "%")
|
|
|
+ }
|
|
|
+ listResp = append(listResp, item)
|
|
|
+
|
|
|
+ item2 := new(statistic_report.RaiDataSummaryDetailResp)
|
|
|
+ item2.TbaleNameAText = "客户不续约率"
|
|
|
+ item2.RenewedContractMoney = fmt.Sprint(norenewedContractCompany)
|
|
|
+ item2.ExpiredContractMoney = fmt.Sprint(expiredContractCompany)
|
|
|
+ if norenewedContractCompany == 0 || expiredContractCompany == 0 {
|
|
|
+ item2.RenewalRate = "0%"
|
|
|
+ } else {
|
|
|
+ item2.RenewalRate = fmt.Sprint(utils.SubFloatToString(norenewedContractCompany/expiredContractCompany*100, 2), "%")
|
|
|
+ }
|
|
|
+ listResp = append(listResp, item2)
|
|
|
+
|
|
|
+ case "签约客户数量":
|
|
|
+ var conditionInherit string
|
|
|
+ var parsInherit []interface{}
|
|
|
+ if sellerId != "" {
|
|
|
+ condition += ` AND a.seller_id_last IN (` + sellerId + `) `
|
|
|
+
|
|
|
+ conditionInherit += ` AND a.seller_id_last IN (` + sellerId + `) `
|
|
|
+ }
|
|
|
+ condition += " AND a.product_id = 2 AND a.status = 1 AND a.start_date >= ? AND a.start_date <= ? AND a.rai_contract_type = '新签合同' "
|
|
|
+ pars = append(pars, startDate, endDate)
|
|
|
+ listRaiData, err := statistic_report.GetRaiDataSummaryList(condition, pars)
|
|
|
+ if err != nil {
|
|
|
+ br.Msg = "获取数据信息失败"
|
|
|
+ br.ErrMsg = "获取数据信息失败,Err:" + err.Error()
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ //续约部分的数据
|
|
|
+ conditionInherit += ` AND a.product_id = 2 AND a.status = 1 AND a.inherit_end_date >= ? AND a.inherit_end_date <= ? AND a.inherit_company_contract_id > 0 AND a.rai_contract_type = '续约合同' AND a.company_id NOT IN (` + utils.GetOrmInReplace(lenArrCompany) + `) `
|
|
|
+ parsInherit = append(parsInherit, startDate, endDate, companyIdsNew)
|
|
|
+ listInheritData, err := statistic_report.GetRaiDataSummaryInheritList(conditionInherit, parsInherit)
|
|
|
+ if err != nil {
|
|
|
+ br.Msg = "获取数据信息失败"
|
|
|
+ br.ErrMsg = "获取数据信息失败,Err:" + err.Error()
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ var renewedContractCompany int // 续约客户数
|
|
|
+ var renewedContract int // 续约合同数
|
|
|
+ maprenewedContractCompany := make(map[int]bool)
|
|
|
+
|
|
|
+ var newContractCompany int // 新签客户数
|
|
|
+ var newContract int // 新签合同数
|
|
|
+ mapenewContractCompany := make(map[int]bool)
|
|
|
+ for _, v := range listRaiData {
|
|
|
+ if v.RaiContractType == "新签合同" {
|
|
|
+ newContract++
|
|
|
+ if !mapenewContractCompany[v.CompanyId] {
|
|
|
+ newContractCompany++
|
|
|
+ mapenewContractCompany[v.CompanyId] = true
|
|
|
+ }
|
|
|
+ }
|
|
|
+ //else if v.RaiContractType == "续约合同" {
|
|
|
+ // renewedContract++
|
|
|
+ // if !maprenewedContractCompany[v.CompanyId] {
|
|
|
+ // renewedContractCompany++
|
|
|
+ // maprenewedContractCompany[v.CompanyId] = true
|
|
|
+ // }
|
|
|
+ //}
|
|
|
+ }
|
|
|
+
|
|
|
+ for _, v := range listInheritData {
|
|
|
+ renewedContract++
|
|
|
+ if !maprenewedContractCompany[v.CompanyId] {
|
|
|
+ renewedContractCompany++
|
|
|
+ maprenewedContractCompany[v.CompanyId] = true
|
|
|
+ }
|
|
|
+
|
|
|
+ }
|
|
|
+
|
|
|
+ item := new(statistic_report.RaiDataSummaryDetailResp)
|
|
|
+ item.RenewedContractCompany = renewedContractCompany
|
|
|
+ item.RenewedContract = renewedContract
|
|
|
+ item.NewContractCompany = newContractCompany
|
|
|
+ item.NewContract = newContract
|
|
|
+ listResp = append(listResp, item)
|
|
|
+
|
|
|
+ case "客单价":
|
|
|
+ //续约部分的数据
|
|
|
+ var conditionInherit string
|
|
|
+ var parsInherit []interface{}
|
|
|
+ if sellerId != "" {
|
|
|
+ condition += ` AND a.seller_id_last IN (` + sellerId + `) `
|
|
|
+ conditionInherit += ` AND a.seller_id_last IN (` + sellerId + `) `
|
|
|
+ }
|
|
|
+ condition += " AND a.product_id = 2 AND a.status = 1 AND a.start_date >= ? AND a.start_date <= ? AND a.rai_contract_type = '新签合同' "
|
|
|
+ pars = append(pars, startDate, endDate)
|
|
|
+ listRaiData, err := statistic_report.GetRaiDataSummaryList(condition, pars)
|
|
|
+ if err != nil {
|
|
|
+ br.Msg = "获取数据信息失败"
|
|
|
+ br.ErrMsg = "获取数据信息失败,Err:" + err.Error()
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ var ontractMoney float64 // 签约总金额
|
|
|
+ var contractNum int // 签约客户数
|
|
|
+ mapCompany := make(map[int]bool)
|
|
|
+
|
|
|
+ for _, v := range listRaiData {
|
|
|
+ if v.RaiContractType != "新签合同" {
|
|
|
+ continue
|
|
|
+ }
|
|
|
+ ontractMoney += v.Money
|
|
|
+ if !mapCompany[v.CompanyId] {
|
|
|
+ contractNum++
|
|
|
+ mapCompany[v.CompanyId] = true
|
|
|
+ }
|
|
|
+ }
|
|
|
+ conditionInherit += ` AND a.product_id = 2 AND a.status = 1 AND a.inherit_end_date >= ? AND a.inherit_end_date <= ? AND a.rai_contract_type = '续约合同' AND a.company_id NOT IN (` + utils.GetOrmInReplace(lenArrCompany) + `) `
|
|
|
+ parsInherit = append(parsInherit, startDate, endDate, companyIdsNew)
|
|
|
+ listInheritData, err := statistic_report.GetRaiDataSummaryInheritList(conditionInherit, parsInherit)
|
|
|
+ if err != nil {
|
|
|
+ br.Msg = "获取数据信息失败"
|
|
|
+ br.ErrMsg = "获取数据信息失败,Err:" + err.Error()
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ for _, v := range listInheritData {
|
|
|
+ ontractMoney += v.Money
|
|
|
+ if !mapCompany[v.CompanyId] && v.RaiContractType == "续约合同" {
|
|
|
+ contractNum++
|
|
|
+ mapCompany[v.CompanyId] = true
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ item := new(statistic_report.RaiDataSummaryDetailResp)
|
|
|
+ item.ContractMoney = fmt.Sprint(utils.SubFloatToString(ontractMoney, 2))
|
|
|
+ item.ContractNum = contractNum
|
|
|
+ listResp = append(listResp, item)
|
|
|
+
|
|
|
+ case "开票金额":
|
|
|
+ if sellerId != "" {
|
|
|
+ condition += ` AND a.rai_seller_id IN (` + sellerId + `) `
|
|
|
+ }
|
|
|
+ condition += " AND a.is_deleted = 0 AND a.start_date >= ? AND a.start_date <= ? AND invoiced_amount > 0 AND product_ids LIKE '%2%' "
|
|
|
+ pars = append(pars, startDate, endDate)
|
|
|
+ listFmsData, err := fms.GetContractRegisterList(condition, pars, startSize, pageSize)
|
|
|
+ if err != nil {
|
|
|
+ br.Msg = "获取数据信息失败"
|
|
|
+ br.ErrMsg = "获取数据信息失败,Err:" + err.Error()
|
|
|
+ return
|
|
|
+ }
|
|
|
+ if len(listFmsData) > 0 {
|
|
|
+ var contractRegisterId []int
|
|
|
+ for _, v := range listFmsData {
|
|
|
+ contractRegisterId = append(contractRegisterId, v.ContractRegisterId)
|
|
|
+ }
|
|
|
+ lenArr := len(contractRegisterId)
|
|
|
+ var conditionFms string
|
|
|
+ var parsFms []interface{}
|
|
|
+ conditionFms += ` AND contract_register_id IN (` + utils.GetOrmInReplace(lenArr) + `) GROUP BY contract_register_id `
|
|
|
+ parsFms = append(parsFms, contractRegisterId)
|
|
|
+ listInvoiceData, err := fms.GetContractInvoiceList(conditionFms, parsFms, 0, lenArr)
|
|
|
+ if err != nil {
|
|
|
+ br.Msg = "获取数据信息失败"
|
|
|
+ br.ErrMsg = "获取数据信息失败,Err:" + err.Error()
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ mapInvoiceTime := make(map[int]string)
|
|
|
+ for _, v := range listInvoiceData {
|
|
|
+ mapInvoiceTime[v.ContractRegisterId] = v.InvoiceTime.Format(utils.FormatDate)
|
|
|
+ }
|
|
|
+
|
|
|
+ for _, v := range listFmsData {
|
|
|
+ item := new(statistic_report.RaiDataSummaryDetailResp)
|
|
|
+ item.CompanyName = v.CompanyName
|
|
|
+ item.SellerName = v.RaiSellerName
|
|
|
+ item.ContractCode = v.ContractCode
|
|
|
+ item.InvoicedAmount = v.InvoicedAmount
|
|
|
+ item.CreateTime = mapInvoiceTime[v.ContractRegisterId]
|
|
|
+ listResp = append(listResp, item)
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ case "到款金额":
|
|
|
+ if sellerId != "" {
|
|
|
+ condition += ` AND a.rai_seller_id IN (` + sellerId + `) `
|
|
|
+ }
|
|
|
+ condition += " AND a.is_deleted = 0 AND a.start_date >= ? AND a.start_date <= ? AND payment_amount > 0 AND product_ids LIKE '%2%' "
|
|
|
+ pars = append(pars, startDate, endDate)
|
|
|
+ listFmsData, err := fms.GetContractRegisterList(condition, pars, startSize, pageSize)
|
|
|
+ if err != nil {
|
|
|
+ br.Msg = "获取数据信息失败"
|
|
|
+ br.ErrMsg = "获取数据信息失败,Err:" + err.Error()
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ if len(listFmsData) > 0 {
|
|
|
+ var contractRegisterId []int
|
|
|
+ for _, v := range listFmsData {
|
|
|
+ contractRegisterId = append(contractRegisterId, v.ContractRegisterId)
|
|
|
+ }
|
|
|
+ lenArr := len(contractRegisterId)
|
|
|
+ var conditionFms string
|
|
|
+ var parsFms []interface{}
|
|
|
+ conditionFms += ` AND contract_register_id IN (` + utils.GetOrmInReplace(lenArr) + `) GROUP BY contract_register_id `
|
|
|
+ parsFms = append(parsFms, contractRegisterId)
|
|
|
+ listInvoiceData, err := fms.GetContractInvoiceList(conditionFms, parsFms, 0, lenArr)
|
|
|
+ if err != nil {
|
|
|
+ br.Msg = "获取数据信息失败"
|
|
|
+ br.ErrMsg = "获取数据信息失败,Err:" + err.Error()
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ mapInvoiceTime := make(map[int]string)
|
|
|
+ for _, v := range listInvoiceData {
|
|
|
+ mapInvoiceTime[v.ContractRegisterId] = v.InvoiceTime.Format(utils.FormatDate)
|
|
|
+ }
|
|
|
+
|
|
|
+ for _, v := range listFmsData {
|
|
|
+ item := new(statistic_report.RaiDataSummaryDetailResp)
|
|
|
+ item.CompanyName = v.CompanyName
|
|
|
+ item.SellerName = v.RaiSellerName
|
|
|
+ item.ContractCode = v.ContractCode
|
|
|
+ item.PaymentAmount = v.PaymentAmount
|
|
|
+ item.CreateTime = v.CreateTime.Format(utils.FormatDate)
|
|
|
+ listResp = append(listResp, item)
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ case "未到款比例":
|
|
|
+ if sellerId != "" {
|
|
|
+ condition += ` AND a.rai_seller_id IN (` + sellerId + `) `
|
|
|
+ }
|
|
|
+ condition += " AND a.is_deleted = 0 AND a.start_date >= ? AND a.start_date <= ? AND product_ids LIKE '%2%' "
|
|
|
+ pars = append(pars, startDate, endDate)
|
|
|
+ listFmsData, err := fms.GetContractRegisterAmountList(condition, pars)
|
|
|
+ if err != nil {
|
|
|
+ br.Msg = "获取数据信息失败"
|
|
|
+ br.ErrMsg = "获取数据信息失败,Err:" + err.Error()
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ for _, v := range listFmsData {
|
|
|
+ item := new(statistic_report.RaiDataSummaryDetailResp)
|
|
|
+ item.InvoicedAmount = v.InvoicedAmount
|
|
|
+ item.PaymentAmount = v.PaymentAmount
|
|
|
+ item.NotReceivedtAmount = v.InvoicedAmount - v.PaymentAmount
|
|
|
+ item.CreateTime = v.CreateTime.Format(utils.FormatDate)
|
|
|
+ listResp = append(listResp, item)
|
|
|
+ }
|
|
|
+
|
|
|
+ case "新客开票":
|
|
|
+ if sellerId != "" {
|
|
|
+ condition += ` AND a.rai_seller_id IN (` + sellerId + `) `
|
|
|
+ }
|
|
|
+ condition += " AND a.is_deleted = 0 AND contract_type = 1 AND a.start_date >= ? AND a.start_date <= ? AND product_ids LIKE '%2%' "
|
|
|
+ pars = append(pars, startDate, endDate)
|
|
|
+ listFmsData, err := fms.GetContractRegisterList(condition, pars, startSize, pageSize)
|
|
|
+ if err != nil {
|
|
|
+ br.Msg = "获取数据信息失败"
|
|
|
+ br.ErrMsg = "获取数据信息失败,Err:" + err.Error()
|
|
|
+ return
|
|
|
+ }
|
|
|
+ if len(listFmsData) > 0 {
|
|
|
+ var contractRegisterId []int
|
|
|
+ for _, v := range listFmsData {
|
|
|
+ contractRegisterId = append(contractRegisterId, v.ContractRegisterId)
|
|
|
+ }
|
|
|
+ lenArr := len(contractRegisterId)
|
|
|
+ var conditionFms string
|
|
|
+ var parsFms []interface{}
|
|
|
+ conditionFms += ` AND contract_register_id IN (` + utils.GetOrmInReplace(lenArr) + `) GROUP BY contract_register_id `
|
|
|
+ parsFms = append(parsFms, contractRegisterId)
|
|
|
+ listInvoiceData, err := fms.GetContractInvoiceList(conditionFms, parsFms, 0, lenArr)
|
|
|
+ if err != nil {
|
|
|
+ br.Msg = "获取数据信息失败"
|
|
|
+ br.ErrMsg = "获取数据信息失败,Err:" + err.Error()
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ mapInvoiceTime := make(map[int]string)
|
|
|
+ for _, v := range listInvoiceData {
|
|
|
+ mapInvoiceTime[v.ContractRegisterId] = v.InvoiceTime.Format(utils.FormatDate)
|
|
|
+ }
|
|
|
+
|
|
|
+ for _, v := range listFmsData {
|
|
|
+ item := new(statistic_report.RaiDataSummaryDetailResp)
|
|
|
+ item.CompanyName = v.CompanyName
|
|
|
+ item.SellerName = v.RaiSellerName
|
|
|
+ item.ContractCode = v.ContractCode
|
|
|
+ item.InvoicedAmount = v.InvoicedAmount
|
|
|
+ item.CreateTime = mapInvoiceTime[v.ContractRegisterId]
|
|
|
+ listResp = append(listResp, item)
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ case "新客到款":
|
|
|
+ if sellerId != "" {
|
|
|
+ condition += ` AND a.rai_seller_id IN (` + sellerId + `) `
|
|
|
+ }
|
|
|
+ condition += " AND a.is_deleted = 0 AND contract_type = 1 AND a.start_date >= ? AND a.start_date <= ? AND payment_amount > 0 AND product_ids LIKE '%2%' "
|
|
|
+ pars = append(pars, startDate, endDate)
|
|
|
+ listFmsData, err := fms.GetContractRegisterList(condition, pars, startSize, pageSize)
|
|
|
+ if err != nil {
|
|
|
+ br.Msg = "获取数据信息失败"
|
|
|
+ br.ErrMsg = "获取数据信息失败,Err:" + err.Error()
|
|
|
+ return
|
|
|
+ }
|
|
|
+ if len(listFmsData) > 0 {
|
|
|
+ var contractRegisterId []int
|
|
|
+ for _, v := range listFmsData {
|
|
|
+ contractRegisterId = append(contractRegisterId, v.ContractRegisterId)
|
|
|
+ }
|
|
|
+ lenArr := len(contractRegisterId)
|
|
|
+ var conditionFms string
|
|
|
+ var parsFms []interface{}
|
|
|
+ conditionFms += ` AND contract_register_id IN (` + utils.GetOrmInReplace(lenArr) + `) GROUP BY contract_register_id `
|
|
|
+ parsFms = append(parsFms, contractRegisterId)
|
|
|
+ listInvoiceData, err := fms.GetContractInvoiceList(conditionFms, parsFms, 0, lenArr)
|
|
|
+ if err != nil {
|
|
|
+ br.Msg = "获取数据信息失败"
|
|
|
+ br.ErrMsg = "获取数据信息失败,Err:" + err.Error()
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ mapInvoiceTime := make(map[int]string)
|
|
|
+ for _, v := range listInvoiceData {
|
|
|
+ mapInvoiceTime[v.ContractRegisterId] = v.InvoiceTime.Format(utils.FormatDate)
|
|
|
+ }
|
|
|
+
|
|
|
+ for _, v := range listFmsData {
|
|
|
+ item := new(statistic_report.RaiDataSummaryDetailResp)
|
|
|
+ item.CompanyName = v.CompanyName
|
|
|
+ item.SellerName = v.RaiSellerName
|
|
|
+ item.ContractCode = v.ContractCode
|
|
|
+ item.PaymentAmount = v.PaymentAmount
|
|
|
+ item.CreateTime = mapInvoiceTime[v.ContractRegisterId]
|
|
|
+ listResp = append(listResp, item)
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ }
|
|
|
+
|
|
|
+ if len(listResp) == 0 {
|
|
|
+ listResp = make([]*statistic_report.RaiDataSummaryDetailResp, 0)
|
|
|
+ }
|
|
|
+ if len(listGroup) > 0 {
|
|
|
+ for _, v := range listGroup {
|
|
|
+ if v.CompanyCount > 1 {
|
|
|
+ resp.CompanyMultiple++
|
|
|
+ }
|
|
|
+ }
|
|
|
+ resp.CompanyNum = len(listGroup)
|
|
|
+ }
|
|
|
+ resp.List = listResp
|
|
|
+ page := paging.GetPaging(currentIndex, pageSize, trialTotal)
|
|
|
+ resp.Paging = page
|
|
|
+ br.Ret = 200
|
|
|
+ br.Success = true
|
|
|
+ br.Msg = "获取成功"
|
|
|
+ br.Data = resp
|
|
|
+}
|
