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
for _, v := range sellerList {
if strings.Contains(v.RealName, "6") {
sellerService = append(sellerService, v)
} else {
sellerDevelop = append(sellerDevelop, v)
sellerDevelopIds[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 <= ? "
parsRai = append(parsRai, startDate, endDate)
listRaiData, err := statistic_report.GetRaiDataSummaryList(conditionRai, parsRai)
if err != nil {
br.Msg = "获取数据信息失败"
br.ErrMsg = "获取数据信息失败,Err:" + err.Error()
return
}
//续约部分的数据
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 <= ? "
parsInherit = append(parsInherit, startDate, endDate)
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) // 到期合同（数量)
mapRenewedContractMoney := make(map[string]float64) // 续约合同（金额)
mapRenewedContractNum := make(map[string]int) // 续约合同（数量)
confirmedNoRenewalContractMoney := make(map[string]float64) // 确认不续约合同（金额)
confirmedNoRenewalContractNum := 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
//新签部分的数据
for _, v := range listRaiData {
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)
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]++
}
//else if v.RaiContractType == "续约合同" {
// mapRenewedContractMoney[keyMap] += v.Money
// mapRenewedContractNum[keyMap]++
//
// mapRenewedContractMoney[keyMapTtoal] += v.Money
// mapRenewedContractNum[keyMapTtoal]++
//}
//if startDateTime.Before(time.Now().AddDate(0, 0, -1)) { //到期合同数据
// mapExpiredContractMoney[keyMap] += v.Money
// mapExpiredContractNum[keyMap]++
//
// mapExpiredContractMoney[keyMapTtoal] += v.Money
// mapExpiredContractNum[keyMapTtoal]++
//}
//
//if mapNoRenewedcompanyContractIds[v.CompanyContractId] { // 确认不续约合同
// confirmedNoRenewalContractMoney[keyMap] += v.Money
// confirmedNoRenewalContractNum[keyMap]++
//
// confirmedNoRenewalContractMoney[keyMapTtoal] += v.Money
// confirmedNoRenewalContractNum[keyMapTtoal]++
//}
mapSignedClientMoney[keyMap] += v.Money
mapSignedClientNum[keyMap]++
mapSignedClientMoney[keyMapTtoal] += v.Money
mapSignedClientNum[keyMapTtoal]++
}
//续约部分的数据
for _, v := range listInheritData {
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)
if sellerDevelopIds[v.SellerIdLast] == true {
keyMapTtoal = fmt.Sprint(yearStr, "_Develop")
} else {
keyMapTtoal = fmt.Sprint(yearStr, "_Service")
}
//续约合同 数据
mapRenewedContractMoney[keyMap] += v.Money
mapRenewedContractNum[keyMap]++
mapRenewedContractMoney[keyMapTtoal] += v.Money
mapRenewedContractNum[keyMapTtoal]++
}
//确认不续约、到期合同部分的数据
for _, v := range listEndData {
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)
if sellerDevelopIds[v.SellerIdLast] == true {
keyMapTtoal = fmt.Sprint(yearStr, "_Develop")
} else {
keyMapTtoal = fmt.Sprint(yearStr, "_Service")
}
//到期合同数据
mapExpiredContractMoney[keyMap] += v.Money
mapExpiredContractNum[keyMap]++
mapExpiredContractMoney[keyMapTtoal] += v.Money
mapExpiredContractNum[keyMapTtoal]++
if mapNoRenewedcompanyContractIds[v.CompanyContractId] { // 确认不续约合同
confirmedNoRenewalContractMoney[keyMap] += v.Money
confirmedNoRenewalContractNum[keyMap]++
confirmedNoRenewalContractMoney[keyMapTtoal] += v.Money
confirmedNoRenewalContractNum[keyMapTtoal]++
}
}
listFmsData, err := fms.GetContractRegisterListByStartDate(startDate, endDate)
if err != nil {
br.Msg = "获取数据信息失败"
br.ErrMsg = "获取财务系统数据信息失败,Err:" + err.Error()
return
}
for _, v := range listFmsData {
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[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")
for _, vS := range sellerDevelop {
keyMap = fmt.Sprint(item.DataType, "_", vS.AdminId)
sellerItem := new(statistic_report.RaiDataSummaryDetail)
sellerItem.SellerId = vS.AdminId
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 mapRenewedContractNum[keyMap] == 0 || mapExpiredContractNum[keyMap] == 0 {
renewalRateNum = "0%"
} else {
renewalRateNum = utils.SubFloatToString(float64(mapRenewedContractNum[keyMap])/float64(mapExpiredContractNum[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 confirmedNoRenewalContractNum[keyMap] == 0 || mapExpiredContractNum[keyMap] == 0 {
confirmNonRenewalRateNum = "0%"
} else {
confirmNonRenewalRateNum = utils.SubFloatToString(float64(confirmedNoRenewalContractNum[keyMap])/float64(mapExpiredContractNum[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) // "新客到款-(数据)"
item.DataList = append(item.DataList, sellerItem)
}
if len(sellerDevelop) > 0 {
sellerItem := new(statistic_report.RaiDataSummaryDetail)
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 mapRenewedContractNum[keyMapTtoal] == 0 || mapExpiredContractNum[keyMapTtoal] == 0 {
renewalRateNum = "0%"
} else {
renewalRateNum = utils.SubFloatToString(float64(mapRenewedContractNum[keyMapTtoal])/float64(mapExpiredContractNum[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 confirmedNoRenewalContractNum[keyMapTtoal] == 0 || mapExpiredContractNum[keyMapTtoal] == 0 {
confirmNonRenewalRateNum = "0%"
} else {
confirmNonRenewalRateNum = utils.SubFloatToString(float64(confirmedNoRenewalContractNum[keyMapTtoal])/float64(mapExpiredContractNum[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 = vS.AdminId
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 mapRenewedContractNum[keyMap] == 0 || mapExpiredContractNum[keyMap] == 0 {
renewalRateNum = "0%"
} else {
renewalRateNum = utils.SubFloatToString(float64(mapRenewedContractNum[keyMap])/float64(mapExpiredContractNum[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 confirmedNoRenewalContractNum[keyMap] == 0 || mapExpiredContractNum[keyMap] == 0 {
confirmNonRenewalRateNum = "0%"
} else {
confirmNonRenewalRateNum = utils.SubFloatToString(float64(confirmedNoRenewalContractNum[keyMap])/float64(mapExpiredContractNum[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) // "新客到款-(数据)"
item.DataList = append(item.DataList, sellerItem)
}
if len(sellerService) > 0 {
sellerItem := new(statistic_report.RaiDataSummaryDetail)
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 mapRenewedContractNum[keyMapTtoalServer] == 0 || mapExpiredContractNum[keyMapTtoalServer] == 0 {
renewalRateNum = "0%"
} else {
renewalRateNum = utils.SubFloatToString(float64(mapRenewedContractNum[keyMapTtoalServer])/float64(mapExpiredContractNum[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 confirmedNoRenewalContractNum[keyMapTtoalServer] == 0 || mapExpiredContractNum[keyMapTtoalServer] == 0 {
confirmNonRenewalRateNum = "0%"
} else {
confirmNonRenewalRateNum = utils.SubFloatToString(float64(confirmedNoRenewalContractNum[keyMapTtoalServer])/float64(mapExpiredContractNum[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.GetInt("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{}
switch popupType {
case "新增试用":
var parsTry []interface{}
var conditionTry string
if sellerId > 0 {
conditionTry += ` AND a.sys_user_id = ? `
parsTry = append(parsTry, 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 > 0 {
condition += ` AND a.seller_id_init = ? `
pars = append(pars, 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 > 0 {
condition += ` AND a.seller_id_last = ? `
pars = append(pars, 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 > 0 {
condition += ` AND a.seller_id_last = ? `
pars = append(pars, sellerId)
}
condition += ` AND a.status = 1 AND a.inherit_end_date >= ? AND a.inherit_end_date <= ? AND inherit_company_contract_id > 0 `
pars = append(pars, startDate, endDate)
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 > 0 {
condition += ` AND a.seller_id_last = ? `
pars = append(pars, sellerId)
conditionEnd += ` AND a.seller_id_last = ? `
parsEnd = append(parsEnd, sellerId)
}
condition += ` AND a.status = 1 AND a.inherit_end_date >= ? AND a.inherit_end_date <= ? AND inherit_company_contract_id > 0 `
pars = append(pars, startDate, endDate)
listRaiData, err := statistic_report.GetRaiDataSummaryList(condition, pars)
if err != nil {
br.Msg = "获取数据信息失败"
br.ErrMsg = "获取数据信息失败,Err:" + err.Error()
return
}
fmt.Println("listRaiData", len(listRaiData))
//到期合同数据
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 > 0 {
condition += ` AND a.seller_id_last = ? `
pars = append(pars, 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()
if sellerId > 0 {
condition += ` AND a.seller_id_last = ? `
pars = append(pars, sellerId)
}
condition += ` AND a.product_id = 2 AND a.status = 1 AND a.start_date >= ? AND a.start_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
}
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
}
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
}
}
}
}
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 "签约客户数量":
if sellerId > 0 {
condition += ` AND a.seller_id_last = ? `
pars = append(pars, sellerId)
}
condition += " AND a.product_id = 2 AND a.status = 1 AND a.start_date >= ? AND a.start_date <= ? "
pars = append(pars, startDate, endDate)
listRaiData, err := statistic_report.GetRaiDataSummaryList(condition, pars)
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
}
}
}
item := new(statistic_report.RaiDataSummaryDetailResp)
item.RenewedContractCompany = renewedContractCompany
item.RenewedContract = renewedContract
item.NewContractCompany = newContractCompany
item.NewContract = newContract
listResp = append(listResp, item)
case "客单价":
if sellerId > 0 {
condition += ` AND a.seller_id_last = ? `
pars = append(pars, sellerId)
}
condition += " AND a.product_id = 2 AND a.status = 1 AND a.start_date >= ? AND a.start_date <= ? "
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 // 签约客户数
for _, v := range listRaiData {
ontractMoney += v.Money
contractNum++
}
item := new(statistic_report.RaiDataSummaryDetailResp)
item.ContractMoney = fmt.Sprint(utils.SubFloatToString(ontractMoney, 2))
item.ContractNum = contractNum
listResp = append(listResp, item)
case "开票金额":
if sellerId > 0 {
condition += ` AND a.rai_seller_id = ? `
pars = append(pars, 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
}
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 = v.CreateTime.Format(utils.FormatDate)
listResp = append(listResp, item)
}
case "到款金额":
if sellerId > 0 {
condition += ` AND a.rai_seller_id = ? `
pars = append(pars, 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
}
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 > 0 {
condition += ` AND a.rai_seller_id = ? `
pars = append(pars, 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 > 0 {
condition += ` AND a.rai_seller_id = ? `
pars = append(pars, 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
}
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 > 0 {
condition += ` AND a.rai_seller_id = ? `
pars = append(pars, 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
}
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)
}
}
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
}