fms_api/controller/crm/contract.go

package crm

import (
	"github.com/gin-gonic/gin"
	"github.com/go-playground/validator/v10"
	"hongze/fms_api/controller/resp"
	"hongze/fms_api/global"
	"hongze/fms_api/models/base"
	"hongze/fms_api/models/crm"
	"hongze/fms_api/models/fms"
	"hongze/fms_api/models/system"
	crmService "hongze/fms_api/services/crm"
	"hongze/fms_api/utils"
	"strings"
)

// ContractController CRM系统合同
type ContractController struct{}

// SearchList
// @Title 搜索合同
// @Description 搜索合同
// @Param   Keyword		query	string	false	"关键词"
// @Param   ProductId	query	int		false	"合同类型: 0-全部; 1-FICC; 2-权益"
// @Success 200 {object} crm.ContractSearchListResp
// @router /crm/contract/search_list [get]
func (rg *ContractController) SearchList(c *gin.Context) {
	var req crm.ContractSearchListReq
	if e := c.BindQuery(&req); e != nil {
		err, ok := e.(validator.ValidationErrors)
		if !ok {
			resp.FailData("参数解析失败", "Err:"+e.Error(), c)
			return
		}
		resp.FailData("参数解析失败", err.Translate(global.Trans), c)
		return
	}

	cond := `status IN ('已审批', '已签回') AND contract_type IN ('新签合同', '续约合同', '补充协议')`
	pars := make([]interface{}, 0)
	if req.Keyword != "" {
		kw := "%" + req.Keyword + "%"
		cond += ` AND (company_name LIKE ? OR contract_code LIKE ?)`
		pars = append(pars, kw, kw)
	}
	if req.ProductId > 0 {
		cond += ` AND product_id = ?`
		pars = append(pars, req.ProductId)
	}
	page := new(base.Page)
	page.SetPageSize(req.PageSize)
	page.SetCurrent(req.Current)
	page.AddOrderItem(base.OrderItem{Column: "create_time", Asc: false})

	ob := new(crm.Contract)
	total, list, e := ob.PageList(page, cond, pars)
	if e != nil {
		resp.FailMsg("获取失败", "获取合同列表失败, Err: "+e.Error(), c)
		return
	}

	// 获取代付合同实际使用方
	peyContractIds := make([]int, 0)
	for i := range list {
		if list[i].ContractBusinessType == crm.ContractTypePayment {
			peyContractIds = append(peyContractIds, list[i].ContractId)
		}
	}
	payCompanyMap := make(map[int]string, 0)      // 代付合同实际使用方
	payContractCodeMap := make(map[int]string, 0) // 代付合同实际使用方合同编号
	if len(peyContractIds) > 0 {
		payCond := `a.status IN ('已签回', '已审批') AND b.payment_on_behalf_contract_id IN ?`
		payPars := make([]interface{}, 0)
		payPars = append(payPars, peyContractIds)
		payList, e := crm.GetPayCompanyByContractIds(payCond, payPars)
		if e != nil {
			resp.FailMsg("获取失败", "获取代付合同信息失败, Err: "+e.Error(), c)
			return
		}
		for i := range payList {
			payCompanyMap[payList[i].PaymentOnBehalfContractId] = payList[i].CompanyName
			payContractCodeMap[payList[i].PaymentOnBehalfContractId] = payList[i].ContractCode
		}
	}

	respList := make([]*crm.ContractSearchListResp, 0)
	for i := range list {
		contractType := list[i].ContractType
		contractTypeKey := crm.ContractTypeFmsMap[list[i].ContractType]
		if list[i].ContractBusinessType == crm.ContractTypePayment {
			contractType = crm.ContractTypePayment
			contractTypeKey = fms.ContractTypeAgentPay
		}

		respItem := &crm.ContractSearchListResp{
			ContractId:              list[i].ContractId,
			ContractCode:            list[i].ContractCode,
			ProductId:               list[i].ProductId,
			CompanyName:             list[i].CompanyName,
			RelateContractCode:      payContractCodeMap[list[i].ContractId],
			ActualCompanyName:       payCompanyMap[list[i].ContractId],
			SellerId:                list[i].SellerId,
			SellerName:              list[i].SellerName,
			ContractTypeKey:         contractTypeKey,
			ContractType:            contractType,
			ContractBusinessTypeInt: 0,
			Price:                   list[i].Price,
			StartDate:               utils.TimeTransferString(utils.FormatDate, list[i].StartDate),
			EndDate:                 utils.TimeTransferString(utils.FormatDate, list[i].EndDate),
		}
		if list[i].ContractBusinessType == crm.ContractTypePayment {
			respItem.ContractBusinessTypeInt = 2
		}else {
			respItem.ContractBusinessTypeInt = 1
		}
		if list[i].ContractType == "新签合同"{
			respItem.ContractTypeInt = 1
		} else if list[i].ContractType == "续约合同"{
			respItem.ContractTypeInt = 2
		} else if list[i].ContractType == "补充协议"{
			respItem.ContractTypeInt = 3
		}
		respList = append(respList, respItem)

	}

	page.SetTotal(total)
	baseData := new(base.BaseData)
	baseData.SetPage(page)
	baseData.SetList(respList)
	resp.OkData("获取成功", baseData, c)
}

// PermissionList
// @Title 合同品种列表
// @Description 合同品种列表
// @Param   ProductId  query  int  false  "品种类型: 1-FICC(默认); 2-权益"
// @Success 200 {object} crm.PermissionSetResp
// @router /crm/contract/permission_list [get]
func (rg *ContractController) PermissionList(c *gin.Context) {
	var req crm.ContractPermissionListReq
	if e := c.BindQuery(&req); e != nil {
		err, ok := e.(validator.ValidationErrors)
		if !ok {
			resp.FailData("参数解析失败", "Err:"+e.Error(), c)
			return
		}
		resp.FailData("参数解析失败", err.Translate(global.Trans), c)
		return
	}
	// 默认FICC
	productId := req.ProductId
	if productId == 0 {
		productId = 1
	}
	respList := new(crm.PermissionSetResp)

	// FICC
	if productId == 1 {
		// 获取品种分类配置
		sysConf := new(system.SysConfig)
		confCond := `config_code = ?`
		confPars := make([]interface{}, 0)
		confPars = append(confPars, system.ConfigKeyCrmPermissionFiccClassify)
		confItem, e := sysConf.FetchByCondition(confCond, confPars)
		if e != nil {
			resp.FailData("获取失败", "Err:"+e.Error(), c)
			return
		}
		if confItem.ConfigValue == "" {
			resp.FailData("获取失败", "FICC品种分类配置为空", c)
			return
		}
		classifyArr := strings.Split(confItem.ConfigValue, ",")
		if len(classifyArr) == 0 {
			resp.FailData("获取失败", "FICC品种分类配置为空", c)
			return
		}

		// 获取FICC权限
		ficcCond := `enabled = 1 AND permission_type = 0 AND product_id = ? AND classify_name IN ?`
		ficcPars := make([]interface{}, 0)
		ficcPars = append(ficcPars, productId, classifyArr)
		items, e := crm.GetPermissionSetItemsByCondition(ficcCond, ficcPars)
		if e != nil {
			resp.FailData("获取失败", "获取FICC权限信息失败, Err: "+e.Error(), c)
			return
		}
		ficcItemMap := make(map[string][]*crm.PermissionSetItem, 0)
		for i := range items {
			if ficcItemMap[items[i].ClassifyName] == nil {
				ficcItemMap[items[i].ClassifyName] = make([]*crm.PermissionSetItem, 0)
			}
			ficcItemMap[items[i].ClassifyName] = append(ficcItemMap[items[i].ClassifyName], items[i])
		}

		for i := range classifyArr {
			if classifyArr[i] == "市场策略" {
				continue
			}
			checkList := make([]int, 0)
			if classifyArr[i] == "宏观经济" {
				checkList = append(checkList, 1)
			}
			p := new(crm.PermissionSetList)
			p.ClassifyName = classifyArr[i]
			p.Items = ficcItemMap[classifyArr[i]]
			p.CheckList = make([]int, 0)
			respList.List = append(respList.List, p)
		}
	}

	// 权益
	if productId == 2 {
		raiCond := `enabled = 1 AND permission_type = 0 AND product_id = ? AND classify_name = ?`
		raiPars := make([]interface{}, 0)
		raiPars = append(raiPars, productId, crm.CompanyProductRaiName)
		items, e := crm.GetPermissionSetItemsByCondition(raiCond, raiPars)
		if e != nil {
			resp.FailData("获取失败", "获取权益权限信息失败, Err: "+e.Error(), c)
			return
		}

		p := new(crm.PermissionSetList)
		p.ClassifyName = crm.CompanyProductRaiName
		p.Items = items
		p.CheckList = make([]int, 0)
		respList.List = append(respList.List, p)
	}
	resp.OkData("获取成功", respList, c)
}

// ServiceDetail
// @Title 获取合同的套餐及品种权限
// @Description 获取合同的套餐及品种权限
// @Param   ContractId  query  int  true  "合同ID"
// @Success 200 {object} crm.ContractDetail
// @router /crm/contract/service_detail [get]
func (rg *ContractController) ServiceDetail(c *gin.Context) {
	var req crm.ContractServiceDetailReq
	if e := c.BindQuery(&req); e != nil {
		err, ok := e.(validator.ValidationErrors)
		if !ok {
			resp.FailData("参数解析失败", "Err:"+e.Error(), c)
			return
		}
		resp.FailData("参数解析失败", err.Translate(global.Trans), c)
		return
	}

	contractDetail, e := crmService.GetContractDetail(req.ContractId)
	if e != nil {
		global.LOG.Error(e.Error())
		resp.FailMsg("获取失败", "获取合同套餐及品种信息失败, Err: "+e.Error(), c)
		return
	}

	// 获取合同服务中的权限ID, 填充contractDetail.Service.ChartPermissionIds字段
	_, e = crmService.GetServicePermissionMap(contractDetail.Service)
	if e != nil {
		resp.FailMsg("获取失败", "获取合同服务中的权限ID失败, Err: "+e.Error(), c)
		return
	}

	resp.OkData("获取成功", contractDetail, c)
}