hz_crm_api/controllers/statistic/rai_data_summary.go

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/statistic_report"
	"hongze/hz_crm_api/models/system"
	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
	}

	//adminId := this.GetString("AdminId")
	dataType := this.GetString("DataType")
	adminId := this.GetString("AdminId")
	serviceAdminId := this.GetString("ServiceAdminId")
	startYear, _ := this.GetInt("StartYear")
	endYear, _ := this.GetInt("EndYear")
	developButton, _ := this.GetInt("DevelopButton")
	serverButton, _ := this.GetInt("ServerButton")

	dataTypeArr := []string{}
	//var dateIntervalArr []statistic_report.DateInterval //时间区间
	if dataType == "季度" {
		dataTypeArr = []string{"Q1", "Q2", "Q3", "Q4"}
		//dateIntervalArr = []statistic_report.DateInterval{statistic_report.DateInterval{StartDate: "01-01", EndDate: "03-31"}, statistic_report.DateInterval{StartDate: "04-01", EndDate: "06-30"}, statistic_report.DateInterval{StartDate: "07-01", EndDate: "09-30"}, statistic_report.DateInterval{StartDate: "10-01", EndDate: "12-31"}}
	} else if dataType == "半年度" {
		dataTypeArr = []string{"H1", "H2"}
		//dateIntervalArr = []statistic_report.DateInterval{statistic_report.DateInterval{StartDate: "01-01", EndDate: "06-30"}, statistic_report.DateInterval{StartDate: "07-01", EndDate: "12-31"}}
	} else {
		dataTypeArr = []string{""}
		//dateIntervalArr = []statistic_report.DateInterval{statistic_report.DateInterval{StartDate: "01-01", EndDate: "12-31"}}
	}

	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 == 1 && serverButton == 0 && adminId == "" && serviceAdminId == "" { //开拓组筛选条件
		condition += " AND  real_name   NOT LIKE '%6%' "
	}

	if developButton == 0 && serverButton == 1 && 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
	}

	//拼接起始时间查询
	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 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)            // 签约客户（金额)

	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 v.RaiContractType == "新签合同" {
			mapNewContractMoney[keyMap] += v.Money
			mapNewContractNum[keyMap]++
		} else if v.RaiContractType == "续约合同" {
			mapRenewedContractMoney[keyMap] += v.Money
			mapRenewedContractNum[keyMap]++
		}

		if startDateTime.Before(time.Now().AddDate(0, 0, -1)) { //到期合同数据
			mapExpiredContractMoney[keyMap] += v.Money
			mapExpiredContractNum[keyMap]++
		}

		if mapNoRenewedcompanyContractIds[v.CompanyContractId] { // 确认不续约合同
			confirmedNoRenewalContractMoney[keyMap] += v.Money
			confirmedNoRenewalContractNum[keyMap]++
		}

		mapSignedClientMoney[keyMap] += v.Money
		mapSignedClientNum[keyMap]++
	}

	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]++
	}

	//fmt.Println(time.Now().AddDate(0, 0, -1))
	//return
	var sellerDevelop []*system.AdminItem // 开拓组销售
	var sellerService []*system.AdminItem // 服务组销售
	for _, v := range sellerList {
		if strings.Contains(v.RealName, "6") {
			sellerService = append(sellerService, v)
		} else {
			sellerDevelop = append(sellerDevelop, v)
		}
	}

	//for _, v := range dateIntervalArr {
	//	fmt.Println(v)
	//}

	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)
			//fmt.Println("DataType", item.DataType)

			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 = "开票金额-(数据)"
				sellerItem.PaymentReceivedCount = "到款金额-(数据)"
				sellerItem.UnpaidRatioCount = "未到款比例-(数据)"
				sellerItem.NewCustomerInvoicingCount = "新客开票-(数据)"
				sellerItem.NewCustomerPaymentsReceivedCount = "新客到款-(数据)"
				item.DataList = append(item.DataList, sellerItem)
			}
			if len(sellerDevelop) > 0 {
				sellerItem := new(statistic_report.RaiDataSummaryDetail)
				sellerItem.SellerName = "开拓组合计"
				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 = "新增试用-(数据)"
				sellerItem.NewContractData = "新签合同（金额/数量)-(数据)"
				sellerItem.ExpiredContractData = "到期合同（金额/数量)-(数据)"
				sellerItem.RenewedContractData = "续约合同（金额/数量)-(数据)"
				sellerItem.RenewalRateData = "续约率（金额/数量)-(数据)"
				sellerItem.ConfirmedNoRenewalContractData = "确认不续约合同（金额/数量)-(数据)"
				sellerItem.ConfirmNonRenewalRateData = "确认不续约率（金额/数量)-(数据)"
				sellerItem.SignedClientCount = "签约客户数量-(数据)"
				sellerItem.AverageRevenueCount = "客单价-(数据)"
				sellerItem.InvoiceAmountCount = "开票金额-(数据)"
				sellerItem.PaymentReceivedCount = "到款金额-(数据)"
				sellerItem.UnpaidRatioCount = "未到款比例-(数据)"
				sellerItem.NewCustomerInvoicingCount = "新客开票-(数据)"
				sellerItem.NewCustomerPaymentsReceivedCount = "新客到款-(数据)"
				item.DataList = append(item.DataList, sellerItem)
			}
			if len(sellerService) > 0 {
				sellerItem := new(statistic_report.RaiDataSummaryDetail)
				sellerItem.SellerName = "服务组合计"
				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"
	}
	fmt.Println(startDate)
	fmt.Println(endDate)
	resp := new(statistic_report.RaiDataSummaryPopupTypeResp)
	var listResp []*statistic_report.RaiDataSummaryDetailResp
	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)
			}
		}
	}

	if len(listResp) == 0 {
		listResp = make([]*statistic_report.RaiDataSummaryDetailResp, 0)
	}
	resp.List = listResp
	page := paging.GetPaging(currentIndex, pageSize, trialTotal)
	resp.Paging = page
	br.Ret = 200
	br.Success = true
	br.Msg = "获取成功"
	br.Data = resp
}