123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373 |
- 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
- }
|