hz_crm_api/services/company_contract.go

package services

import (
	"errors"
	"fmt"
	"hongze/hz_crm_api/models"
	"hongze/hz_crm_api/models/company"
	"hongze/hz_crm_api/services/alarm_msg"
	"hongze/hz_crm_api/utils"
	"strconv"
	"strings"
	"time"
)

//func init() {
//	InitCompanyContractMerge()
//	//GetCompanyContractPermissionNameMapById(map[int]string{6513: "182,183", 6663: "435,542"})
//}

// 初始化合并合同之后的数据脚本
func InitCompanyContractMerge() {

	var condition string
	var pars []interface{}
	condition = "  AND status = 1  AND  product_id = 2  ORDER BY  company_contract_id ASC  "
	companyContractList, err := company.GetCompanyContractList(condition, pars)

	if err != nil {
		fmt.Println(err)
		return
	}
	mapCompanyContractItems := make(map[int][]*company.CompanyContractResp)
	for _, v := range companyContractList {
		//fmt.Println(v)
		mapCompanyContractItems[v.CompanyId] = append(mapCompanyContractItems[v.CompanyId], v)
	}

	mapCompanyMoney := make(map[int]float64)
	var items []*company.CompanyContractMergeResp
	for _, ContractItems := range mapCompanyContractItems {
		item := new(company.CompanyContractMergeResp)
		for k, v := range ContractItems {
			item = new(company.CompanyContractMergeResp)
			item.ContractType = v.ContractType
			item.ProductId = v.ProductId
			item.ProductName = v.ProductName
			item.CompanyId = v.CompanyId
			item.CompanyProductId = v.CompanyProductId
			item.StartDate = v.StartDate
			item.EndDate = v.EndDate
			item.Money = v.Money
			item.CompanyContractIdGroup += strconv.Itoa(v.CompanyContractId) + ","
			if k == 0 {
				items = append(items, item)
				mapCompanyMoney[v.CompanyId] = item.Money
			} else {
				if v.CompanyId != items[len(items)-1].CompanyId {
					items = append(items, item)
				} else {
					//续约的合同开始时间是否＜上一次合同记录的结束时间 且间隔＞6个月（180）天，那么就对两个合同进行合并
					if item.StartDate.AddDate(0, 0, +180).Before(items[len(items)-1].EndDate) && item.StartDate.Before(items[len(items)-1].EndDate) {
						items[len(items)-1].Money += v.Money
						items[len(items)-1].EndDate = v.EndDate
						items[len(items)-1].CompanyContractIdGroup += strconv.Itoa(v.CompanyContractId) + ","
					} else {
						if item.ContractType == "续约合同" {
							if item.Money > mapCompanyMoney[v.CompanyId] {
								item.PackageDifference = "增加套餐"
							}
							if item.Money == mapCompanyMoney[v.CompanyId] {
								item.PackageDifference = "维持套餐"
							}
							if item.Money < mapCompanyMoney[v.CompanyId] {
								item.PackageDifference = "减少套餐"
							}
						}
						items = append(items, item)
						mapCompanyMoney[v.CompanyId] = item.Money
					}
				}
			}
		}
	}

	var contractMergeitems []*company.CompanyContractMerge

	var companyIds []int
	mapcompanyIds := make(map[int]bool)
	for _, v := range items {
		item := new(company.CompanyContractMerge)
		item.ContractType = v.ContractType
		item.ProductId = v.ProductId
		item.ProductName = v.ProductName
		item.CompanyId = v.CompanyId
		item.CompanyProductId = v.CompanyProductId
		item.StartDate = v.StartDate.Format(utils.FormatDate)
		item.EndDate = v.EndDate.Format(utils.FormatDate)
		item.Money = v.Money
		item.PackageDifference = v.PackageDifference
		item.CompanyContractIdGroup = strings.TrimRight(v.CompanyContractIdGroup, ",")
		item.CreateTime = time.Now()
		item.ModifyTime = time.Now()
		contractMergeitems = append(contractMergeitems, item)

		if !mapcompanyIds[v.CompanyId] {
			companyIds = append(companyIds, v.CompanyId)
			mapcompanyIds[v.CompanyId] = true
		}

	}

	err = company.MultiAddCompanyContractMerge(contractMergeitems)
	if err != nil {
		fmt.Println(err)
		return
	}

	for _, v := range companyIds {
		var condition string
		var pars []interface{}

		fmt.Println(v)
		condition = " AND company_id = ?  ORDER BY start_date DESC   LIMIT  1  "
		pars = append(pars, v)
		contractMergeInfo, err := company.GetCompanyContractMergeDetail(condition, pars)
		if err != nil {
			fmt.Println(err)
			return
		}
		err = company.UpdateCompanyContractMergeIsBestNewto1(contractMergeInfo.CompanyContractMergeId)
		if err != nil {
			fmt.Println(err)
			return
		}
	}
}

// GetCompanyContractPermissionNameMapById 获取合并之后的合同所对应的权限种类名称
func GetCompanyContractPermissionNameMapById(mapCompamy map[int]string) (mapContractResp map[int]string, err error) {
	if len(mapCompamy) == 0 {
		return
	}
	var condition string
	var pars []interface{}

	mapContracIdCompanyId := make(map[string]int) //建立合同ID与公司ID的map对应关系

	var companyContractIdGroup string //多个合同ID
	for k, v := range mapCompamy {
		companyContractIdGroup += v + ","
		sliceContract := strings.Split(v, ",")
		for _, compamyContracId := range sliceContract {
			mapContracIdCompanyId[compamyContracId] = k
		}
	}

	companyContractIdGroup = strings.TrimRight(companyContractIdGroup, ",")
	condition += " AND  company_contract_id IN (" + companyContractIdGroup + ")"
	companyContractList, e := company.GetCompanyContractList(condition, pars)
	if e != nil && e.Error() != utils.ErrNoRow() {
		err = errors.New("GetCompanyContractList, Err: " + e.Error())
		return
	}

	permissionList, e := models.GetChartPermissionList()
	if e != nil && e.Error() != utils.ErrNoRow() {
		err = errors.New("GetChartPermissionList, Err: " + e.Error())
		return
	}
	mappermissionName := make(map[int]string)
	for _, v := range permissionList {
		mappermissionName[v.ChartPermissionId] = v.Remark
	}

	mapContractIdPerssion := make(map[string]string) //单个合同ID所对应的套餐或者权限名称
	for _, v := range companyContractList {
		if v.RaiPackageType == 1 {
			mapContractIdPerssion[strconv.Itoa(v.CompanyContractId)] = "70w套餐"
		}
		if v.RaiPackageType == 2 {
			mapContractIdPerssion[strconv.Itoa(v.CompanyContractId)] = "45w套餐"
		}
	}

	companyContractPermissionList, e := company.GetCompanyContractPermissionList(condition, pars)
	if e != nil && e.Error() != utils.ErrNoRow() {
		err = errors.New("GetCompanyContractPermissionList, Err: " + e.Error())
		return
	}
	for _, v := range companyContractPermissionList {
		//如果开通的不是整个套餐，那么就做单独的子权限处理
		if strings.Count(mapContractIdPerssion[strconv.Itoa(v.CompanyContractId)], "w套餐") == 0 {
			if v.ChartPermissionId == utils.CHART_PERMISSION_ID_YANXUAN {
				if v.ExpensiveYx == 1 {
					mapContractIdPerssion[strconv.Itoa(v.CompanyContractId)] += utils.CHART_PERMISSION_NAME_MF_YANXUAN + "(5w),"
				} else {
					mapContractIdPerssion[strconv.Itoa(v.CompanyContractId)] += utils.CHART_PERMISSION_NAME_MF_YANXUAN + "(3w),"
				}
			} else {
				mapContractIdPerssion[strconv.Itoa(v.CompanyContractId)] += mappermissionName[v.ChartPermissionId] + ","
			}
		}
	}

	//合并客观权限
	for k, v := range mapContractIdPerssion {
		perssionName := v
		if strings.Count(v, utils.YI_YAO_NAME) == 2 {
			perssionName = strings.Replace(perssionName, "医药(主观)", "医药", -1)
			perssionName = strings.Replace(perssionName, "医药(客观)", "", -1)
		}
		if strings.Count(v, utils.XIAO_FEI_NAME) == 2 {
			perssionName = strings.Replace(perssionName, "消费(主观)", "消费", -1)
			perssionName = strings.Replace(perssionName, "消费(客观)", "", -1)
		}
		if strings.Count(v, utils.KE_JI_NAME) == 2 {
			perssionName = strings.Replace(perssionName, "科技(主观)", "科技", -1)
			perssionName = strings.Replace(perssionName, "科技(客观)", "", -1)
		}
		if strings.Count(v, utils.ZHI_ZAO_NAME) == 2 {
			perssionName = strings.Replace(perssionName, "智造(主观)", "智造", -1)
			perssionName = strings.Replace(perssionName, "智造(客观)", "", -1)
		}
		perssionName = strings.TrimRight(perssionName, ",")
		mapContractIdPerssion[k] = perssionName
	}
	mapContractResp = make(map[int]string, 0)
	for k, v := range mapContractIdPerssion {
		mapContractResp[mapContracIdCompanyId[k]] += v + ","
	}

	//过滤多余的","
	for k, v := range mapContractResp {
		sliceName := strings.Split(v, ",")
		var nameArr []string
		for _, vName := range sliceName {
			if vName == "" {
				continue
			}
			nameArr = append(nameArr, vName)
		}
		mapContractResp[k] = strings.Join(nameArr, ",")
	}
	return
}

//
//func init() {
//	AddCompanyContractMergeByCompanyContractId(1187)
//}

// AddCompanyContractMergeByCompanyContractId 通过合同ID对合同进行合并
func AddCompanyContractMergeByCompanyContractId(companyContractId int) {
	var err error
	defer func() {
		if err != nil {
			fmt.Println(err)
			go alarm_msg.SendAlarmMsg("通过合同ID对合同进行合并，失败"+err.Error()+fmt.Sprint("companyContractId", companyContractId), 2)
		}
	}()
	contractInfo, e := company.GetCompanyContractDetailByCompanyContractId(companyContractId)
	if e != nil {
		err = errors.New("GetCompanyContractDetailByCompanyContractId, Err: " + e.Error())
		return
	}

	var condition string
	var pars []interface{}

	condition = " AND company_id = ?  ORDER BY start_date DESC   LIMIT  1  "
	pars = append(pars, contractInfo.CompanyId)
	contractMergeInfo, e := company.GetCompanyContractMergeDetail(condition, pars)
	if e != nil && e.Error() != utils.ErrNoRow() {
		err = errors.New("GetCompanyContractMergeDetail, Err: " + e.Error())
		return
	}
	fmt.Println(contractMergeInfo)
	e = company.UpdateCompanyContractMergeIsBestNew(0, contractInfo.CompanyId)
	if e != nil {
		err = errors.New("UpdateCompanyContractMergeIsBestNew, Err: " + e.Error())
		return
	}
	item := new(company.CompanyContractMerge)
	item.ContractType = contractInfo.ContractType
	item.ProductId = contractInfo.ProductId
	item.ProductName = contractInfo.ProductName
	item.CompanyId = contractInfo.CompanyId
	item.CompanyProductId = contractInfo.CompanyProductId
	item.IsBestNew = 1
	item.CreateTime = time.Now()
	item.ModifyTime = time.Now()
	//如果不存在就是新的数据
	if contractMergeInfo == nil {
		item.StartDate = contractInfo.StartDate
		item.EndDate = contractInfo.EndDate
		item.Money = contractInfo.Money
		item.CompanyContractIdGroup = strconv.Itoa(companyContractId)
		e = company.AddCompanyContractMerge(item)
		if e != nil {
			err = errors.New("AddCompanyContractMerge, Err: " + e.Error())
			return
		}
	} else {
		newStartDate := utils.StrDateToDate(contractInfo.StartDate)
		//newEndDate := utils.StrDateToDate(contractInfo.EndDate)
		oldEndDate := utils.StrDateToDate(contractMergeInfo.EndDate)

		//续约的合同开始时间是否＜上一次合同记录的结束时间 且间隔＞6个月（180）天，那么就对两个合同进行合并
		if newStartDate.AddDate(0, 0, +180).Before(oldEndDate) && newStartDate.Before(oldEndDate) {
			item.Money = contractInfo.Money + contractMergeInfo.Money
			item.EndDate = contractInfo.EndDate
			item.CompanyContractIdGroup = contractMergeInfo.CompanyContractIdGroup + "," + strconv.Itoa(companyContractId)
			//如果是续约合同就对比跟上一份合并之后的合同的差距
			if item.ContractType == "续约合同" {
				pars = make([]interface{}, 0)
				condition = " AND company_id = ?  AND company_contract_merge_id != ?   ORDER BY start_date DESC   LIMIT  1  "
				pars = append(pars, contractMergeInfo.CompanyId, contractMergeInfo.CompanyContractMergeId)
				detailPrevious, e := company.GetCompanyContractMergeDetail(condition, pars)
				if e != nil {
					err = errors.New("GetCompanyContractMergeDetail, Err: " + e.Error())
					return
				}
				if item.Money > detailPrevious.Money {
					item.PackageDifference = "增加套餐"
				}
				if item.Money == detailPrevious.Money {
					item.PackageDifference = "维持套餐"
				}
				if item.Money < detailPrevious.Money {
					item.PackageDifference = "减少套餐"
				}
			}
			item.CompanyContractMergeId = contractMergeInfo.CompanyContractMergeId
			e = company.UpdateCompanyContractMerge(item)
			if e != nil {
				err = errors.New("AddCompanyContractMerge, Err: " + e.Error())
				return
			}
		} else {
			item.StartDate = contractInfo.StartDate
			item.EndDate = contractInfo.EndDate
			item.Money = contractInfo.Money
			item.CompanyContractIdGroup = strconv.Itoa(companyContractId)
			//如果是续约合同就对比跟上一份合并之后的合同的差距
			if item.ContractType == "续约合同" {
				pars = make([]interface{}, 0)
				condition = " AND company_id = ?  AND company_contract_merge_id != ?   ORDER BY start_date DESC   LIMIT  1  "
				pars = append(pars, contractMergeInfo.CompanyId, contractMergeInfo.CompanyContractMergeId)
				detailPrevious, e := company.GetCompanyContractMergeDetail(condition, pars)
				if e != nil {
					err = errors.New("GetCompanyContractMergeDetail, Err: " + e.Error())
					return
				}
				if item.Money > detailPrevious.Money {
					item.PackageDifference = "增加套餐"
				}
				if item.Money == detailPrevious.Money {
					item.PackageDifference = "维持套餐"
				}
				if item.Money < detailPrevious.Money {
					item.PackageDifference = "减少套餐"
				}
			}
			e = company.AddCompanyContractMerge(item)
			if e != nil {
				err = errors.New("AddCompanyContractMerge, Err: " + e.Error())
				return
			}
		}
	}

	return
}