youngee_b_api/app/service/cooperation_service.go

package service

import (
	"encoding/json"
	"errors"
	"fmt"
	"gorm.io/gorm"
	"strconv"
	"time"
	"youngee_b_api/app/dao"
	"youngee_b_api/app/entity"
	"youngee_b_api/app/vo"
)

type CooperationService struct{}

// 服务商搜索
func (s CooperationService) SearchSupplier(param *vo.SupplierSearchParam) ([]*vo.ReSupplierPreview, error) {
	var reSupplierPreviews []*vo.ReSupplierPreview
	suppliers, err := dao.SupplierDao{}.GetSuppliersByMsg(param.FieldName)
	if err != nil {
		return reSupplierPreviews, err
	}
	for _, supplier := range suppliers {
		// 判断该服务商是否已在商家库
		exist, _ := dao.EnterpriseSupplierCooperateDao{}.EnterpriseDatabaseCheck(param.EnterpriseId, supplier.SupplierID)
		reSupplierPreview := &vo.ReSupplierPreview{
			SupplierId:   supplier.SupplierID,
			HeadUrl:      supplier.Avatar,
			SupplierName: supplier.SupplierName,
			SupplierType: supplier.SupplierType,
			CompanyName:  supplier.CompanyName,
			Name:         supplier.Name,
			ReviewStatus: supplier.ReviewStatus,
			Existence:    exist,
		}
		reSupplierPreviews = append(reSupplierPreviews, reSupplierPreview)
	}
	return reSupplierPreviews, nil
}

// 服务商入库批量邀请
func (s CooperationService) InviteSupplier(param *vo.SupplierInviteParam) error {
	// 要求传入的服务商都是未在该商家库的
	var records []*entity.EnterpriseSupplierCooperate
	for _, supplierId := range param.SupplierIds {
		record := &entity.EnterpriseSupplierCooperate{
			EnterpriseId:    param.EnterpriseId,
			SupplierId:      supplierId,
			CooperateNum:    1,
			CooperateStatus: 1,
			CreateTime:      time.Now(),
		}
		if param.SubAccountId == 0 {
			record.BOperator = param.EnterpriseId
			record.BOperatorType = 1
		} else {
			record.BOperator = strconv.Itoa(int(param.SubAccountId))
			record.BOperatorType = 2
		}
		records = append(records, record)
	}
	err := dao.EnterpriseSupplierCooperateDao{}.InsertBatch(records)

	return err
}

// 在库服务商列表
func (s CooperationService) GetEnterprisePoolList(param *vo.SupplierSearchInPoolParam) (vo.ResultVO, error) {
	if param.Page <= 0 {
		param.Page = 1
	}
	if param.PageSize <= 0 {
		param.PageSize = 10
	}
	var result vo.ResultVO
	var reSupplierPoolInfos []*vo.ReSupplierPoolInfo
	var enterpriseOperator string
	enterpriseSupplierCooperates, total, _ := dao.EnterpriseSupplierCooperateDao{}.GetSupplierByEnterprise(param.EnterpriseId, param.Page, param.PageSize)
	for _, enterpriseSupplierCooperate := range enterpriseSupplierCooperates {
		// 获取商家操作人姓名
		bOperator := enterpriseSupplierCooperate.BOperator
		if enterpriseSupplierCooperate.BOperatorType == 1 {
			enterprise, err := dao.EnterpriseDao{}.GetEnterprise(bOperator)
			if err == nil && enterprise != nil {
				enterpriseOperator = enterprise.BusinessName
			}
		} else if enterpriseSupplierCooperate.BOperatorType == 2 {
			subAccountId, err := strconv.ParseInt(bOperator, 10, 64)
			if err != nil {
				fmt.Println("GetEnterprisePoolList==subAccountId 转换出错:", err)
			} else {
				subAccount, err := dao.SubAccountDao{}.GetSubAccount(subAccountId)
				if err == nil && subAccount != nil {
					enterpriseOperator = subAccount.SubAccountName
				}
			}
		}
		supplier, err := dao.SupplierDao{}.GetSupplierInfoById(enterpriseSupplierCooperate.SupplierId)
		if err != nil {
			continue
		}
		supplierPreview := &vo.ReSupplierPreview{
			SupplierId:   supplier.SupplierID,
			HeadUrl:      supplier.Avatar,
			SupplierName: supplier.SupplierName,
			SupplierType: supplier.SupplierType,
			CompanyName:  supplier.CompanyName,
			Name:         supplier.Name,
			Existence:    true,
		}
		reSupplierPoolInfo := &vo.ReSupplierPoolInfo{
			SupplierPreview:    supplierPreview,
			PhoneNumber:        supplier.PhoneNumber,
			WechatId:           supplier.WechatNumber,
			WechatUrl:          supplier.WechatQrcode,
			CooperateNum:       enterpriseSupplierCooperate.CooperateNum,
			UploadTalentNum:    enterpriseSupplierCooperate.UploadTalentNum,
			CooperateTalentNum: enterpriseSupplierCooperate.CooperateTalentNum,
			AgreeTime:          enterpriseSupplierCooperate.AgreeTime.Format("2006-01-02 15:04:05"),
			EnterpriseOperator: enterpriseOperator,
		}
		reSupplierPoolInfos = append(reSupplierPoolInfos, reSupplierPoolInfo)
	}
	result = vo.ResultVO{
		Page:     param.Page,
		PageSize: param.PageSize,
		Total:    total,
		Data:     reSupplierPoolInfos,
	}
	return result, nil
}

// 服务商邀请待确认列表
func (s CooperationService) GetSupplierConfirmingList(param *vo.SupplierConfirmingParam) (vo.ResultVO, error) {
	if param.Page <= 0 {
		param.Page = 1
	}
	if param.PageSize <= 0 {
		param.PageSize = 10
	}
	var result vo.ResultVO
	var reSupplierConfirmingInfos []*vo.ReSupplierConfirmingInfo
	var enterpriseOperator string
	enterpriseSupplierCooperates, total, _ := dao.EnterpriseSupplierCooperateDao{}.GetSupplierConfirmingList(param.EnterpriseId, param.Page, param.PageSize)
	for _, enterpriseSupplierCooperate := range enterpriseSupplierCooperates {
		// 获取商家操作人姓名
		bOperator := enterpriseSupplierCooperate.BOperator
		if enterpriseSupplierCooperate.BOperatorType == 1 {
			enterprise, err := dao.EnterpriseDao{}.GetEnterprise(bOperator)
			if err == nil && enterprise != nil {
				enterpriseOperator = enterprise.BusinessName
			}
		} else if enterpriseSupplierCooperate.BOperatorType == 2 {
			subAccountId, err := strconv.ParseInt(bOperator, 10, 64)
			if err != nil {
				fmt.Println("GetSupplierConfirmingList==subAccountId 转换出错:", err)
			} else {
				subAccount, err := dao.SubAccountDao{}.GetSubAccount(subAccountId)
				if err == nil && subAccount != nil {
					enterpriseOperator = subAccount.SubAccountName
				}
			}
		}
		supplier, err := dao.SupplierDao{}.GetSupplierInfoById(enterpriseSupplierCooperate.SupplierId)
		var supplierPreview *vo.ReSupplierPreview
		var phoneNumber string
		if err == nil {
			supplierPreview = &vo.ReSupplierPreview{
				SupplierId:   supplier.SupplierID,
				HeadUrl:      supplier.Avatar,
				SupplierName: supplier.SupplierName,
				SupplierType: supplier.SupplierType,
				CompanyName:  supplier.CompanyName,
				Name:         supplier.Name,
			}
			phoneNumber = supplier.PhoneNumber
			reSupplierConfirmingInfo := &vo.ReSupplierConfirmingInfo{
				SupplierPreview:    supplierPreview,
				PhoneNumber:        phoneNumber,
				WechatId:           supplier.WechatNumber,
				WechatUrl:          supplier.WechatQrcode,
				CreateTime:         enterpriseSupplierCooperate.CreateTime.Format("2006-01-02 15:04:05"),
				Status:             enterpriseSupplierCooperate.CooperateStatus,
				EnterpriseOperator: enterpriseOperator,
			}
			reSupplierConfirmingInfos = append(reSupplierConfirmingInfos, reSupplierConfirmingInfo)
		}

	}
	result = vo.ResultVO{
		Page:     param.Page,
		PageSize: param.PageSize,
		Total:    total,
		Data:     reSupplierConfirmingInfos,
	}
	return result, nil
}

// 服务商管理-角标
func (t CooperationService) GetSupplierCount(param *vo.SupplierConfirmingParam) map[string]int64 {
	res := make(map[string]int64)
	var inPoolNum int64     // 在库服务商
	var confirmingNum int64 // 邀请待确认
	dao.Db.Model(&entity.EnterpriseSupplierCooperate{}).Where("enterprise_id = ? AND cooperate_status = 2", param.EnterpriseId).Count(&inPoolNum)
	dao.Db.Model(&entity.EnterpriseSupplierCooperate{}).Where("enterprise_id = ? AND cooperate_status = 1", param.EnterpriseId).Count(&confirmingNum)
	res["inPoolNum"] = inPoolNum
	res["confirmingNum"] = confirmingNum

	return res
}

// 达人合作数据
func (t CooperationService) GetCoopTalentData(param *vo.TalentDataParam) vo.ReTalentCoopData {
	var res vo.ReTalentCoopData
	talent, err1 := dao.TalentInfoDao{}.GetTalentInfo(param.TalentId)
	user, err2 := dao.PlatformKuaishouUserInfoDao{}.GetUserInfoById(param.PlatFormUserId)
	if err1 != nil && err2 != nil {
		return vo.ReTalentCoopData{}
	}
	talentDataPreview := &vo.TalentDataPreview{
		TalentId:   talent.ID,
		AvatarUrl:  user.HeadUri,
		Sex:        user.Gender,
		TalentName: user.NickName,
		WXAccount:  talent.WxNum,
		Phone:      talent.TalentPhoneNumber,
		Skill:      user.Skill,
		OpenId:     user.OpenID,
	}
	res.TalentDataPreview = talentDataPreview
	var applynum, executenum, endnum int64
	executenum = dao.ProjectTaskInfoDao{}.CountExcuteNumByOpenid(user.OpenID)
	applynum = dao.ProjectTaskInfoDao{}.CountAllByOpenid(user.OpenID)
	endnum = dao.ProjectTaskInfoDao{}.CountByOpenid(user.OpenID, 15)

	executenum += dao.SelectionTaskInfoDao{}.CountExcuteNumByOpenid(user.OpenID)
	applynum += dao.SelectionTaskInfoDao{}.CountAllByOpenid(user.OpenID)
	endnum += dao.SelectionTaskInfoDao{}.CountByOpenid(user.OpenID, 10)

	executenum += dao.LocalLifeTaskInfoDao{}.CountExcuteNumByOpenid(user.OpenID)
	applynum += dao.LocalLifeTaskInfoDao{}.CountAllByOpenid(user.OpenID)
	endnum += dao.LocalLifeTaskInfoDao{}.CountByOpenid(user.OpenID, 15)

	coopdata := &vo.TalentCoopData{
		SignTaskNum:     applynum,
		SelectedTaskNum: endnum + executenum,
		PerformTaskNum:  executenum,
		CompleteTaskNum: endnum,
	}
	res.TalentCoopData = coopdata
	return res
}

// 达人数据
func (t CooperationService) GetTalentData(param *vo.TalentDataParam) vo.ReTalentData {
	var res vo.ReTalentData
	talent, err1 := dao.TalentInfoDao{}.GetTalentInfo(param.TalentId)
	user, err2 := dao.PlatformKuaishouUserInfoDao{}.GetUserInfoById(param.PlatFormUserId)
	if err1 != nil && err2 != nil {
		return vo.ReTalentData{}
	}
	talentDataPreview := &vo.TalentDataPreview{
		TalentId:   talent.ID,
		AvatarUrl:  user.HeadUri,
		Sex:        user.Gender,
		TalentName: user.NickName,
		WXAccount:  talent.WxNum,
		Phone:      talent.TalentPhoneNumber,
		Skill:      user.Skill,
		OpenId:     user.OpenID,
	}
	res.TalentDataPreview = talentDataPreview
	var avgLikeNum float64
	if user.VideoNum != 0 {
		avgLikeNum = float64(user.LikeNum) / float64(user.VideoNum)
	} else {
		avgLikeNum = 0
	}
	coreData := &vo.TalentCoreData{
		FansNum:       user.Fan,
		AvgLikeNum:    avgLikeNum,
		AvgCollect:    0,
		AvgComment:    0,
		ThirtySaleNum: 0,
		SixtySaleNum:  0,
		NinetySaleNum: 0,
	}
	res.TalentCoreData = coreData
	return res
}

// 服务商管理-服务商数据卡
func (t CooperationService) GetSupplierData(param *vo.SupplierDataParam) vo.ReSupplierCoopData {
	var reSupplierCoopData vo.ReSupplierCoopData

	supplier, err1 := dao.SupplierDao{}.GetSupplierInfoById(param.SupplierId)
	if err1 != nil {
		return vo.ReSupplierCoopData{}
	}
	supplierPreview := &vo.SupplierPreview{
		SupplierId:   supplier.SupplierID,
		AvatarUrl:    supplier.Avatar,
		SupplierName: supplier.SupplierName,
		CompanyName:  supplier.CompanyName,
		WXAccount:    supplier.WechatNumber,
		CodeUrl:      supplier.WechatQrcode,
		Phone:        supplier.ContactPhone,
		Platform:     []int{1, 2, 3, 4, 5},
	}
	reSupplierCoopData.SupplierPreview = supplierPreview

	var count int64
	_ = dao.Db.Model(&entity.EnterpriseSupplierCooperate{}).Where("supplier_id = ? AND cooperate_status = 2", param.SupplierId).Count(&count).Error
	enterpriseSupplierCooperate, err2 := dao.EnterpriseSupplierCooperateDao{}.GetDataByEnterpriseAndSupplier(param.EnterpriseId, param.SupplierId)
	if err2 != nil {
		return reSupplierCoopData
	}
	coreData := &vo.CoreData{
		CooperateNum:    enterpriseSupplierCooperate.CooperateNum,
		ReportTalentNum: enterpriseSupplierCooperate.UploadTalentNum,
		TalentCoopNum:   enterpriseSupplierCooperate.CooperateTalentNum,
		PutStoreNum:     count,
	}
	var commentCount, viewCount int64
	projectTaskLinkStatistics, err3 := dao.ProjectTaskLinkStatisticDao{}.GetSupplierData(param.SupplierId)
	if err3 != nil {
		return reSupplierCoopData
	}
	localTaskLinkStatistics, err4 := dao.LocalTaskLinkStatisticDao{}.GetSupplierData(param.SupplierId)
	if err4 != nil {
		return reSupplierCoopData
	}
	for _, projectTaskLinkStatistic := range projectTaskLinkStatistics {
		commentCount += projectTaskLinkStatistic.CommitCount
		viewCount += projectTaskLinkStatistic.ViewCount
	}
	for _, localTaskLinkStatistic := range localTaskLinkStatistics {
		commentCount += localTaskLinkStatistic.CommitCount
		viewCount += localTaskLinkStatistic.ViewCount
	}
	coreData.ViewNum = viewCount
	coreData.InteractNum = commentCount
	reSupplierCoopData.CoreData = coreData

	return reSupplierCoopData
}

// 达人管理-达人数据卡列表
func (t CooperationService) GetTalentPerform(param *vo.TalentDataParam) (vo.ResultVO, error) {
	if param.Page <= 0 {
		param.Page = 1
	}
	if param.PageSize <= 0 {
		param.PageSize = 10
	}
	var talentDataParams []*vo.TalentPerformance
	var total int64
	result := vo.ResultVO{
		Page:     param.Page,
		PageSize: param.PageSize,
		Total:    total,
		Data:     talentDataParams,
	}
	//带货
	if param.TaskType == 1 {
		sectasks, total1, err1 := dao.SelectionTaskInfoDao{}.GetSecInfoByOpenId(param.TalentId, param.Others, param.SortField, param.SortOrder, param.Page, param.PageSize, param.RelType, param.EnterpriseId)
		total = total1
		if err1 != nil {
			return result, err1
		}
		for _, sectask := range sectasks {
			var perform vo.TalentPerformance
			secid := sectask.SelectionID
			sec, err2 := dao.SelectionInfoDAO{}.GetSelectionInfoById(secid)
			if err2 != nil {
				return result, err2
			}
			var product entity.Product
			var productMainPhoto entity.ProductPhoto
			err11 := json.Unmarshal([]byte(sec.ProductSnap), &product)
			err12 := json.Unmarshal([]byte(sec.ProductPhotoSnap), &productMainPhoto)
			if err11 != nil || err12 != nil {
				perform.MainImage = productMainPhoto.PhotoUrl
				perform.ProductName = product.ProductName
				perform.Price = product.ProductPrice
				perform.Category = product.ProductCategory
				perform.SalesNum = sectask.SaleActual
			}
			talentDataParams = append(talentDataParams, &perform)
		}
	} else if param.TaskType == 2 {
		prjtasks, total2, err2 := dao.ProjectTaskInfoDao{}.GetProjectInfoByTalentId(param.TalentId, param.Others, param.SortField, param.SortOrder, param.Page, param.PageSize, param.RelType, param.EnterpriseId, param.Platform)
		total = total2
		if err2 != nil {
			return result, err2
		}
		for _, sectask := range prjtasks {
			var perform vo.TalentPerformance
			secid := sectask.ProjectID
			sec, err2 := dao.ProjectDAO{}.GetProjectById(secid)
			if err2 != nil {
				return result, err2
			}
			var product entity.Product
			var productMainPhoto entity.ProductPhoto
			err11 := json.Unmarshal([]byte(sec.ProductSnap), &product)
			err12 := json.Unmarshal([]byte(sec.ProductPhotoSnap), &productMainPhoto)
			if err11 != nil || err12 != nil {
				perform.MainImage = productMainPhoto.PhotoUrl
				perform.ProductName = product.ProductName
				perform.Price = product.ProductPrice
				perform.VoteCount = sectask.VoteAvg
				perform.ViewCount = sectask.ViewNum
				perform.CollectCount = sectask.CollectNum
				perform.CommentCount = sectask.CommitAvg

			}
			talentDataParams = append(talentDataParams, &perform)
		}
	} else if param.TaskType == 3 {
		prjtasks, total3, err3 := dao.LocalLifeTaskInfoDao{}.GetLocalLifeInfoByTalentId(param.TalentId, param.Others, param.SortField, param.SortOrder, param.Page, param.PageSize, param.RelType, param.EnterpriseId, param.Platform)
		total = total3
		if err3 != nil {
			return result, err3
		}
		for _, sectask := range prjtasks {
			var perform vo.TalentPerformance
			secid := sectask.LocalID
			sec, err2 := dao.ProjectDAO{}.GetProjectById(secid)
			if err2 != nil {
				return result, err2
			}
			var product entity.Product
			var productMainPhoto entity.ProductPhoto
			err11 := json.Unmarshal([]byte(sec.ProductSnap), &product)
			err12 := json.Unmarshal([]byte(sec.ProductPhotoSnap), &productMainPhoto)
			if err11 != nil || err12 != nil {
				perform.MainImage = productMainPhoto.PhotoUrl
				perform.ProductName = product.ProductName
				perform.Price = product.ProductPrice
				perform.VoteCount = int(sectask.VoteAvg)
				perform.ViewCount = 0
				perform.CollectCount = sectask.CollectNum
				perform.CommentCount = int(sectask.CommitAvg)

			}
			talentDataParams = append(talentDataParams, &perform)
		}
	}
	result = vo.ResultVO{
		Page:     param.Page,
		PageSize: param.PageSize,
		Total:    total,
		Data:     talentDataParams,
	}
	return result, nil
}

// 服务商管理-服务商数据卡列表
func (t CooperationService) GetSupplierPerform(param *vo.SupplierDataParam) (vo.ResultVO, error) {
	if param.Page <= 0 {
		param.Page = 1
	}
	if param.PageSize <= 0 {
		param.PageSize = 10
	}
	var supplierDataParams []*vo.SupplierPerformance
	var total int64
	result := vo.ResultVO{
		Page:     param.Page,
		PageSize: param.PageSize,
		Total:    total,
		Data:     supplierDataParams,
	}
	// 获取supplierId下的所有任务，再根据任务获取数据
	if param.TaskType == 2 {
		projectTaskLinkStatistics, total1, err1 := dao.ProjectTaskLinkStatisticDao{}.GetProjectList(param.SupplierId, param.Page, param.PageSize)
		total = total1
		if err1 != nil {
			return result, err1
		}
		for _, projectTaskLinkStatistic := range projectTaskLinkStatistics {
			var perform vo.SupplierPerformance
			projectId := projectTaskLinkStatistic.ProjectID
			project, err2 := dao.ProjectDAO{}.GetProjectById(projectId)
			if err2 != nil {
				return result, err2
			}
			var product entity.Product
			var productMainPhoto entity.ProductPhoto
			err11 := json.Unmarshal([]byte(project.ProductSnap), &product)
			err12 := json.Unmarshal([]byte(project.ProductPhotoSnap), &productMainPhoto)
			if err11 != nil && err12 != nil {
				perform.MainImage = productMainPhoto.PhotoUrl
				perform.ProductName = product.ProductName
				perform.Price = product.ProductPrice
				perform.ViewCount = projectTaskLinkStatistic.ViewCount
				perform.VoteCount = projectTaskLinkStatistic.VoteCount
				perform.CollectCount = projectTaskLinkStatistic.CollectionCount
				perform.CommentCount = projectTaskLinkStatistic.CommitCount
			}
			supplierDataParams = append(supplierDataParams, &perform)
		}
	} else if param.TaskType == 3 {
		localTaskLinkStatistics, total1, err1 := dao.LocalTaskLinkStatisticDao{}.GetLocalList(param.SupplierId, param.Page, param.PageSize)
		total = total1
		if err1 != nil {
			return result, err1
		}
		for _, localTaskLinkStatistic := range localTaskLinkStatistics {
			var perform vo.SupplierPerformance
			localId := localTaskLinkStatistic.LocalID
			local, err2 := dao.LocalLifeDao{}.GetLocalById(localId)
			if err2 != nil {
				return result, err2
			}
			store, err11 := dao.StoreDao{}.GetStoreByID(local.StoreID)
			if err11 == nil && store != nil {
				photoUrl, e := dao.ProductPhotoDAO{}.GetMainPhotoByStoreID(store.StoreID)
				if e != nil {
					photoUrl = ""
				}
				perform.MainImage = photoUrl
				perform.StoreName = store.StoreName
				perform.ViewCount = localTaskLinkStatistic.ViewCount
				perform.VoteCount = localTaskLinkStatistic.VoteCount
				perform.CollectCount = localTaskLinkStatistic.CollectionCount
				perform.CommentCount = localTaskLinkStatistic.CommitCount
			}
			supplierDataParams = append(supplierDataParams, &perform)
		}
	}

	result = vo.ResultVO{
		Page:     param.Page,
		PageSize: param.PageSize,
		Total:    total,
		Data:     supplierDataParams,
	}
	return result, nil
}

// 服务商合作-服务商列表
func (s CooperationService) GetSupplierInTargetTaskList(param *vo.SupplierSearchInTargetTaskParam) (vo.ResultVO, error) {
	if param.Page <= 0 {
		param.Page = 1
	}
	if param.PageSize <= 0 {
		param.PageSize = 10
	}
	var reSupplierTargetTasks []*vo.ReSupplierTargetTask
	var total int64
	result := vo.ResultVO{
		Page:     param.Page,
		PageSize: param.PageSize,
		Total:    total,
		Data:     reSupplierTargetTasks,
	}
	var enterpriseSupplierCooperates []*entity.EnterpriseSupplierCooperate
	var sProjectInfos []*entity.SProjectInfo
	var sLocalLifeInfos []*entity.SLocalLifeInfo
	var enterpriseOperator string
	if param.Status == 1 { // 可邀约
		enterpriseSupplierCooperates, total, _ = dao.EnterpriseSupplierCooperateDao{}.GetSupplierByEnterprise(param.EnterpriseId, param.Page, param.PageSize)
		var resEnterpriseSuppliers []*entity.EnterpriseSupplierCooperate
		if param.TaskType == 2 {
			// 品牌种草
			// 去除当前project_id、supplier_id已在 s_project_info中的数据
			for _, enterpriseSupplier := range enterpriseSupplierCooperates {
				var sProject entity.SProjectInfo
				err1 := dao.Db.Model(&entity.SProjectInfo{}).Where("project_id = ? and supplier_id = ?", param.TaskId, enterpriseSupplier.SupplierId).First(&sProject).Error
				if err1 != nil {
					if errors.Is(err1, gorm.ErrRecordNotFound) {
						resEnterpriseSuppliers = append(resEnterpriseSuppliers, enterpriseSupplier)
					} else {
						// 其他错误
					}
				}
			}
		} else if param.TaskType == 3 {
			// 本地生活
			// 去除当前 local_id、supplier_id 已在 s_local_info中的数据
			for _, enterpriseSupplier := range enterpriseSupplierCooperates {
				var sLocalLifeInfo entity.SLocalLifeInfo
				err2 := dao.Db.Model(&entity.SLocalLifeInfo{}).Where("local_id = ? and supplier_id = ?", param.TaskId, enterpriseSupplier.SupplierId).First(&sLocalLifeInfo).Error
				if err2 != nil {
					if errors.Is(err2, gorm.ErrRecordNotFound) {
						resEnterpriseSuppliers = append(resEnterpriseSuppliers, enterpriseSupplier)
					} else {
						// 其他错误
					}
				}
			}
		}
		enterpriseSupplierCooperates = resEnterpriseSuppliers
		total = int64(len(enterpriseSupplierCooperates))
	} else if param.Status == 2 { // 邀约中
		if param.TaskType == 2 {
			// 品牌种草
			sProjectInfos, total, _ = dao.SProjectDao{}.GetSProjectByStatus(param.TaskId, 1, param.Page, param.PageSize)
		} else if param.TaskType == 3 {
			// 本地生活
			sLocalLifeInfos, total, _ = dao.SLocalLifeDao{}.GetSLocalLifeByStatus(param.TaskId, 1, param.Page, param.PageSize)
		}
	} else if param.Status == 3 { // 合作中
		if param.TaskType == 2 {
			// 品牌种草
			sProjectInfos, total, _ = dao.SProjectDao{}.GetSProjectByStatus(param.TaskId, 2, param.Page, param.PageSize)
		} else if param.TaskType == 3 {
			// 本地生活
			sLocalLifeInfos, total, _ = dao.SLocalLifeDao{}.GetSLocalLifeByStatus(param.TaskId, 2, param.Page, param.PageSize)
		}
	}
	// 针对邀约中、合作中情形
	if param.Status == 2 || param.Status == 3 {
		if param.TaskType == 2 { // 种草
			for _, sProjectInfo := range sProjectInfos {
				supplierId := sProjectInfo.SupplierID
				enterpriseSupplierCooperate, err1 := dao.EnterpriseSupplierCooperateDao{}.GetDataByEnterpriseAndSupplier(param.EnterpriseId, supplierId)
				if err1 != nil {
					return result, err1
				}
				enterpriseSupplierCooperates = append(enterpriseSupplierCooperates, enterpriseSupplierCooperate)
			}
		} else if param.TaskType == 3 {
			// 本地生活
			for _, sLocalLifeInfo := range sLocalLifeInfos {
				supplierId := sLocalLifeInfo.SupplierID
				enterpriseSupplierCooperate, err1 := dao.EnterpriseSupplierCooperateDao{}.GetDataByEnterpriseAndSupplier(param.EnterpriseId, supplierId)
				if err1 != nil {
					return result, err1
				}
				enterpriseSupplierCooperates = append(enterpriseSupplierCooperates, enterpriseSupplierCooperate)
			}
		}
	}
	for _, enterpriseSupplierCooperate := range enterpriseSupplierCooperates {
		// 获取商家操作人姓名
		bOperator := enterpriseSupplierCooperate.BOperator
		if enterpriseSupplierCooperate.BOperatorType == 1 {
			enterprise, err := dao.EnterpriseDao{}.GetEnterprise(bOperator)
			if err == nil && enterprise != nil {
				enterpriseOperator = enterprise.BusinessName
			}
		} else if enterpriseSupplierCooperate.BOperatorType == 2 {
			subAccountId, err := strconv.ParseInt(bOperator, 10, 64)
			if err != nil {
				fmt.Println("GetEnterprisePoolList==subAccountId 转换出错:", err)
			} else {
				subAccount, err := dao.SubAccountDao{}.GetSubAccount(subAccountId)
				if err == nil && subAccount != nil {
					enterpriseOperator = subAccount.SubAccountName
				}
			}
		}
		supplier, err := dao.SupplierDao{}.GetSupplierInfoById(enterpriseSupplierCooperate.SupplierId)
		var supplierPreview *vo.ReSupplierPreview
		var phoneNumber string
		if err == nil && supplier != nil {
			supplierPreview = &vo.ReSupplierPreview{
				SupplierId:   supplier.SupplierID,
				HeadUrl:      supplier.Avatar,
				SupplierName: supplier.SupplierName,
				SupplierType: supplier.SupplierType,
				CompanyName:  supplier.CompanyName,
				Name:         supplier.Name,
				Existence:    true,
			}
			phoneNumber = supplier.PhoneNumber
			reSupplierTargetTask := &vo.ReSupplierTargetTask{
				SupplierPreview:    supplierPreview,
				PhoneNumber:        phoneNumber,
				WechatId:           supplier.WechatNumber,
				WechatUrl:          supplier.WechatQrcode,
				CooperateNum:       enterpriseSupplierCooperate.CooperateNum,
				UploadTalentNum:    enterpriseSupplierCooperate.UploadTalentNum,
				CooperateTalentNum: enterpriseSupplierCooperate.CooperateTalentNum,
				EnterpriseOperator: enterpriseOperator,
				Status:             param.Status,
			}
			reSupplierTargetTasks = append(reSupplierTargetTasks, reSupplierTargetTask)
		}
	}
	result = vo.ResultVO{
		Page:     param.Page,
		PageSize: param.PageSize,
		Total:    total,
		Data:     reSupplierTargetTasks,
	}
	return result, nil
}

// 服务商合作-服务商列表角标
func (t CooperationService) GetSupplierInTargetCount(param *vo.SupplierSearchInTargetTaskParam) map[string]int64 {
	res := make(map[string]int64)
	var invitableNum int64   // 可邀约
	var invitingNum int64    // 邀约中
	var cooperatingNum int64 // 合作中

	if param.TaskType == 2 {
		// 品牌种草
		var enterpriseSupplierCooperates []*entity.EnterpriseSupplierCooperate
		query := dao.Db.Model(&entity.EnterpriseSupplierCooperate{}).Where("enterprise_id = ? AND cooperate_status = 2", param.EnterpriseId)
		err := query.Select("supplier_id").Find(&enterpriseSupplierCooperates).Error
		var resEnterpriseSuppliers []*entity.EnterpriseSupplierCooperate
		if err == nil {
			// 去除当前project_id、supplier_id已在 s_project_info中的数据
			for _, enterpriseSupplier := range enterpriseSupplierCooperates {
				var sProject entity.SProjectInfo
				err1 := dao.Db.Debug().Model(&entity.SProjectInfo{}).Where("project_id = ? and supplier_id = ?", param.TaskId, enterpriseSupplier.SupplierId).First(&sProject).Error
				if err1 != nil {
					if errors.Is(err1, gorm.ErrRecordNotFound) {
						resEnterpriseSuppliers = append(resEnterpriseSuppliers, enterpriseSupplier)
					} else {
						// 其他错误
					}
				}
			}
		}
		invitableNum = int64(len(resEnterpriseSuppliers))
		dao.Db.Model(&entity.SProjectInfo{}).Where("project_id = ? AND s_project_status = ?", param.TaskId, 1).Count(&invitingNum)
		dao.Db.Model(&entity.SProjectInfo{}).Where("project_id = ? AND s_project_status = ?", param.TaskId, 2).Count(&cooperatingNum)
	} else if param.TaskType == 3 {
		// 本地生活
		var enterpriseSupplierCooperates []*entity.EnterpriseSupplierCooperate
		query := dao.Db.Model(&entity.EnterpriseSupplierCooperate{}).Where("enterprise_id = ? AND cooperate_status = 2", param.EnterpriseId)
		err := query.Select("supplier_id").Find(&enterpriseSupplierCooperates).Error
		var resEnterpriseSuppliers []*entity.EnterpriseSupplierCooperate
		if err == nil {
			// 去除当前local_id、supplier_id已在 s_local_info中的数据
			for _, enterpriseSupplier := range enterpriseSupplierCooperates {
				var sLocalLifeInfo entity.SLocalLifeInfo
				err1 := dao.Db.Model(&entity.SLocalLifeInfo{}).Where("local_id = ? and supplier_id = ?", param.TaskId, enterpriseSupplier.SupplierId).First(&sLocalLifeInfo).Error
				if err1 != nil {
					if errors.Is(err1, gorm.ErrRecordNotFound) {
						resEnterpriseSuppliers = append(resEnterpriseSuppliers, enterpriseSupplier)
					} else {
						// 其他错误
					}
				}
			}
		}
		invitableNum = int64(len(resEnterpriseSuppliers))
		dao.Db.Model(&entity.SLocalLifeInfo{}).Where("local_id = ? AND s_local_status = ?", param.TaskId, 1).Count(&invitingNum)
		dao.Db.Model(&entity.SProjectInfo{}).Where("local_id = ? AND s_local_status = ?", param.TaskId, 2).Count(&cooperatingNum)

	}
	res["invitableNum"] = invitableNum
	res["invitingNum"] = invitingNum
	res["cooperatingNum"] = cooperatingNum

	return res
}

// 服务商合作-邀约合作
func (s CooperationService) InviteSupplierInTargetTask(param *vo.SupplierInviteInTargetTaskParam) error {
	var err error
	if param.TaskType == 2 {
		var sProjectInfo entity.SProjectInfo
		sProjectInfo.ProjectID = param.TaskId
		sProjectInfo.SupplierID = param.SupplierId
		sProjectInfo.SProjectStatus = 1
		t := time.Now()
		sProjectInfo.CreateTime = &t
		if param.SubAccountId == 0 {
			sProjectInfo.BOperator = param.EnterpriseId
			sProjectInfo.BOperatorType = 1
		} else {
			sProjectInfo.BOperator = strconv.Itoa(int(param.SubAccountId))
			sProjectInfo.BOperatorType = 2
		}
		// 查找该 projectId 对应的信息
		project, err1 := dao.ProjectDAO{}.GetProjectById(param.TaskId)
		if err1 != nil {
			return err1
		}
		if project != nil {
			sProjectInfo.ProductID = project.ProductID
			sProjectInfo.ProjectName = project.ProjectName
			sProjectInfo.ProjectStatus = project.ProjectStatus
			sProjectInfo.ProjectType = project.ProjectType
			sProjectInfo.ProjectPlatform = project.ProjectPlatform
			sProjectInfo.ProjectForm = project.ProjectForm
			sProjectInfo.ContentType = project.ContentType
			sProjectInfo.EnterpriseID = param.EnterpriseId
			//sProjectInfo.ApplyNum = project.ApplyNum
			//sProjectInfo.RecruitNum = project.RecruitNum
		}
		err = dao.SProjectDao{}.Insert(&sProjectInfo)

	} else if param.TaskType == 3 {
		// 本地生活
		var sLocalLifeInfo entity.SLocalLifeInfo
		sLocalLifeInfo.LocalID = param.TaskId
		sLocalLifeInfo.SupplierID = param.SupplierId
		sLocalLifeInfo.SLocalStatus = 1
		t := time.Now()
		sLocalLifeInfo.CreateTime = &t
		if param.SubAccountId == 0 {
			sLocalLifeInfo.BOperator = param.EnterpriseId
			sLocalLifeInfo.BOperatorType = 1
		} else {
			sLocalLifeInfo.BOperator = strconv.Itoa(int(param.SubAccountId))
			sLocalLifeInfo.BOperatorType = 2
		}
		// 查找该 localId 对应的信息
		localLife, err1 := dao.LocalLifeDao{}.GetLocalById(param.TaskId)
		if err1 != nil {
			return err1
		}
		if localLife != nil {
			sLocalLifeInfo.StoreID = localLife.StoreID
			sLocalLifeInfo.TeamBuyingID = localLife.TeamBuyingId
			sLocalLifeInfo.LocalName = localLife.LocalName
			sLocalLifeInfo.TaskStatus = localLife.TaskStatus
			sLocalLifeInfo.LocalType = localLife.LocalType
			sLocalLifeInfo.LocalPlatform = localLife.LocalPlatform
			sLocalLifeInfo.TaskForm = localLife.TaskForm
			sLocalLifeInfo.ContentType = localLife.ContentType
			sLocalLifeInfo.EnterpriseID = param.EnterpriseId
			//sProjectInfo.ApplyNum = project.ApplyNum
			//sProjectInfo.RecruitNum = project.RecruitNum
		}
		err = dao.SLocalLifeDao{}.Insert(&sLocalLifeInfo)
	}

	return err
}