ad_platform/app/svc/svc_wx_data.go

package svc

import (
	"applet/app/enum"
	"applet/app/md"
	"applet/app/utils"
	db "code.fnuoos.com/zhimeng/model.git/src"
	"code.fnuoos.com/zhimeng/model.git/src/super/implement"
	"code.fnuoos.com/zhimeng/model.git/src/super/model"
	"errors"
	"time"
)

func GenerateWxAdData(req md.GenerateWxAdData) (err error, generateWxAdData model.GenerateWxAdData) {
	//1、查找原始数据记录
	originalWxAdDataDb := implement.NewOriginalWxAdDataDb(db.Db)
	originalWxAdData, err := originalWxAdDataDb.GetOriginalWxAdData(req.OriginalDataId)
	if err != nil {
		return
	}
	if originalWxAdData == nil {
		err = errors.New("未查询到原始数据记录")
		return
	}

	//2、查询对应媒体、代理的分成策略
	mediumDivisionStrategyDb := implement.NewMediumDivisionStrategyDb(db.Db)
	mediumDivisionStrategy, err := mediumDivisionStrategyDb.GetOriginalWxAdDataByMediumId(originalWxAdData.MediumId)
	if err != nil {
		return
	}
	if mediumDivisionStrategy == nil {
		err = errors.New("未查询到对应代理的分成策略")
		return
	}
	mediumDivisionStrategyWithAgentFlowDb := implement.NewMediumDivisionStrategyWithAgentFlowDb(db.Db)
	mediumDivisionStrategyWithAgentFlows, err := mediumDivisionStrategyWithAgentFlowDb.FindMediumDivisionStrategyWithAgentFlowByStrategyId(mediumDivisionStrategy.MediumId)
	if err != nil {
		return
	}

	//3、计算媒体、代理收益、平台留存、佣金留存、协议分成、协议总分成
	publisherIncome := originalWxAdData.PublisherIncome
	mediaRevenue := publisherIncome * mediumDivisionStrategy.MediaRevenueRate / 100                              //媒体收益
	agentRevenue := publisherIncome * mediumDivisionStrategy.AgentRevenueRate / 100                              //代理收益
	platformRetention := publisherIncome * mediumDivisionStrategy.PlatformRetentionRate / 100                    //平台留存
	commissionRetention := publisherIncome * mediumDivisionStrategy.CommissionRetentionRate / 100                //佣金留存
	agreementSharingTotal := (mediaRevenue + agentRevenue) / (100 - mediumDivisionStrategy.AgreementSharingRate) //协议总分成（倒推）
	agreementSharing := agreementSharingTotal - (mediaRevenue + agentRevenue)                                    //协议分成

	//3、判断是否有调价留存
	var priceAdjustmentRetention int
	if req.NowEcpm != req.OriginalEcpm || req.NowExposureCount != req.OriginalExposureCount {
		tmpMediaRevenue := int(utils.StrToFloat64(req.NowEcpm) * float64(req.NowExposureCount) / 1000)
		priceAdjustmentRetention = tmpMediaRevenue - mediaRevenue
		mediaRevenue = tmpMediaRevenue
	}

	//4、计算各代理收益
	var extraRevenue int
	var agentRevenueFlows []struct {
		AgentId          int `json:"agent_id"`
		AgentRevenueRate int `json:"agent_revenue_rate"`
		ExtraRevenueRate int `json:"extra_revenue_rate"`
		AgentRevenue     int `json:"agent_revenue"`
		ExtraRevenue     int `json:"extra_revenue"`
	}
	for _, v := range *mediumDivisionStrategyWithAgentFlows {
		tmpAgentRevenue := agentRevenue * v.AgentRevenueRate / 100
		tmpExtraRevenue := commissionRetention * v.ExtraRevenueRate / 100
		extraRevenue += tmpExtraRevenue
		agentRevenueFlows = append(agentRevenueFlows, struct {
			AgentId          int `json:"agent_id"`
			AgentRevenueRate int `json:"agent_revenue_rate"`
			ExtraRevenueRate int `json:"extra_revenue_rate"`
			AgentRevenue     int `json:"agent_revenue"`
			ExtraRevenue     int `json:"extra_revenue"`
		}{
			AgentId:          v.AgentId,
			AgentRevenueRate: v.AgentRevenueRate,
			ExtraRevenueRate: v.ExtraRevenueRate,
			AgentRevenue:     tmpAgentRevenue,
			ExtraRevenue:     tmpExtraRevenue,
		})
	}

	//5、插入 generate_wx_ad_data 、generate_wx_ad_data_with_agent_flow 数据
	session := db.Db.NewSession()
	defer session.Close()
	session.Begin()

	now := time.Now()
	generateWxAdData = model.GenerateWxAdData{
		Uuid:                     originalWxAdData.Uuid,
		AppId:                    originalWxAdData.AppId,
		OriginalDataId:           originalWxAdData.Id,
		SlotId:                   originalWxAdData.SlotId,
		AdSlot:                   originalWxAdData.AdSlot,
		Date:                     originalWxAdData.Date,
		ReqSuccCount:             originalWxAdData.ReqSuccCount,
		ExposureCount:            req.NowExposureCount, //现-曝光量
		ExposureRate:             originalWxAdData.ExposureRate,
		ClickCount:               originalWxAdData.ClickCount,
		ClickRate:                originalWxAdData.ClickRate,
		Ecpm:                     req.NowEcpm, //现-ecpm
		PlatformRetention:        platformRetention,
		CommissionRetention:      commissionRetention,
		PriceAdjustmentRetention: priceAdjustmentRetention,
		MediaRevenue:             mediaRevenue,
		AgentRevenue:             agentRevenue,
		ExtraRevenue:             extraRevenue,
		AgreementSharing:         agreementSharing,
		AgreementSharingTotal:    agreementSharingTotal,
		PlatformRetentionRate:    mediumDivisionStrategy.PlatformRetentionRate,
		CommissionRetentionRate:  mediumDivisionStrategy.CommissionRetentionRate,
		MediaRevenueRate:         mediumDivisionStrategy.MediaRevenueRate,
		AgentRevenueRate:         mediumDivisionStrategy.AgentRevenueRate,
		ExtraRevenueRate:         mediumDivisionStrategy.ExtraRevenueRate,
		AgreementSharingRate:     mediumDivisionStrategy.AgreementSharingRate,
		IsGenerateReport:         0,
		CreateAt:                 now.Format("2006-01-02 15:04:05"),
		UpdateAt:                 now.Format("2006-01-02 15:04:05"),
	}
	generateWxAdDataDb := implement.NewGenerateWxAdDataDb(db.Db)
	_, err = generateWxAdDataDb.GenerateWxAdDataInsertBySession(session, &generateWxAdData)
	if err != nil {
		_ = session.Rollback()
		return
	}

	var generateWxAdDataWithAgentFlows []*model.GenerateWxAdDataWithAgentFlow
	for _, v := range agentRevenueFlows {
		generateWxAdDataWithAgentFlows = append(generateWxAdDataWithAgentFlows, &model.GenerateWxAdDataWithAgentFlow{
			Uuid:             generateWxAdData.Uuid,
			AppId:            generateWxAdData.AppId,
			AgentId:          v.AgentId,
			GenerateDataId:   generateWxAdData.Id,
			SlotId:           generateWxAdData.SlotId,
			AdSlot:           generateWxAdData.AdSlot,
			Date:             generateWxAdData.Date,
			AgentRevenue:     v.AgentRevenue,
			AgentRevenueRate: v.AgentRevenueRate,
			ExtraRevenue:     v.ExtraRevenue,
			ExtraRevenueRate: v.ExtraRevenueRate,
			CreateAt:         now.Format("2006-01-02 15:04:05"),
			UpdateAt:         now.Format("2006-01-02 15:04:05"),
		})
	}
	generateWxAdDataWithAgentFlowDb := implement.NewGenerateWxAdDataWithAgentFlowDb(db.Db)
	_, err = generateWxAdDataWithAgentFlowDb.BatchAddGenerateWxAdDataWithAgentFlow(session, generateWxAdDataWithAgentFlows)
	if err != nil {
		_ = session.Rollback()
		return
	}

	//6、修改 original_wx_ad_data 记录中的 is_apply(是否已应用(0:未 1:已) )
	originalWxAdData.IsApply = 1
	_, err = originalWxAdDataDb.UpdateOriginalWxAdDataBySession(session, originalWxAdData, "is_apply")
	if err != nil {
		_ = session.Rollback()
		return
	}
	return session.Commit(), generateWxAdData
}

func ClacEcpm(req md.ClacEcpmReq) (err error, ecpm string) {
	//1、查找原始数据记录
	originalWxAdDataDb := implement.NewOriginalWxAdDataDb(db.Db)
	originalWxAdData, err := originalWxAdDataDb.GetOriginalWxAdData(req.GenerateDataId)
	if err != nil {
		return
	}
	if originalWxAdData == nil {
		err = errors.New("未查询到原始数据记录")
		return
	}

	//2、查询对应媒体分成策略
	mediumDivisionStrategyDb := implement.NewMediumDivisionStrategyDb(db.Db)
	mediumDivisionStrategy, err := mediumDivisionStrategyDb.GetOriginalWxAdDataByMediumId(originalWxAdData.MediumId)
	if err != nil {
		return
	}
	if mediumDivisionStrategy == nil {
		err = errors.New("未查询到对应代理的分成策略")
		return
	}

	//3、计算媒体、代理收益、协议总分成
	publisherIncome := originalWxAdData.PublisherIncome
	mediaRevenue := publisherIncome * mediumDivisionStrategy.MediaRevenueRate / 100                              //媒体收益
	agentRevenue := publisherIncome * mediumDivisionStrategy.AgentRevenueRate / 100                              //代理收益
	agreementSharingTotal := (mediaRevenue + agentRevenue) / (100 - mediumDivisionStrategy.AgreementSharingRate) //协议总分成（倒推）

	//4、倒退出当前ecpm值
	ecpm = utils.Float64ToStrPrec4(float64(agreementSharingTotal) / (float64(originalWxAdData.ExposureCount) / 1000))
	return
}

func SettlementWxAdData(req md.SettlementWxAdData) (err error) {
	//1、查找生成数据记录
	generateWxAdDataDb := implement.NewGenerateWxAdDataDb(db.Db)
	generateWxAdData, err := generateWxAdDataDb.GetGenerateWxAdData(req.GenerateDataId)
	if err != nil {
		return
	}
	if generateWxAdData == nil {
		err = errors.New("未查询到生成数据记录")
		return
	}

	originalWxAdDataDb := implement.NewOriginalWxAdDataDb(db.Db)
	originalWxAdData, err := originalWxAdDataDb.GetOriginalWxAdData(generateWxAdData.OriginalDataId)
	if err != nil {
		return
	}
	if originalWxAdData == nil {
		err = errors.New("未查询到原始数据记录")
		return
	}

	//2、查询 生成数据-代理明细 记录
	generateWxAdDataWithAgentFlowDb := implement.NewGenerateWxAdDataWithAgentFlowDb(db.Db)
	generateWxAdDataWithAgentFlow, err := generateWxAdDataWithAgentFlowDb.FindGenerateWxAdDataWithAgentFlowByStrategyId(generateWxAdData.Id)
	if err != nil {
		return
	}

	//3、查询 媒体、代理的结算方式
	mediumListDb := implement.NewMediumListDb(db.Db)
	medium, err := mediumListDb.GetMediumList(originalWxAdData.MediumId)
	if err != nil {
		return
	}
	if medium == nil {
		return errors.New("媒体：" + utils.IntToStr(originalWxAdData.MediumId) + "未查询到对应记录")
	}
	var agentMap = map[int]model.AgentList{}
	agentListDb := implement.NewAgentListDb(db.Db)
	for _, v := range *generateWxAdDataWithAgentFlow {
		agent, err1 := agentListDb.GetAgentList(v.AgentId)
		if err1 != nil {
			return err1
		}
		if agent == nil {
			return errors.New("代理：" + utils.IntToStr(v.AgentId) + "未查询到对应记录")
		}
		agentMap[v.AgentId] = *agent
	}

	//4、生成数据
	now := time.Now()
	session := db.Db.NewSession()
	defer session.Close()
	session.Begin()

	//4.1 新增/更新 medium_settlement 数据
	mediumSettlementDb := implement.NewMediumSettlementDb(db.Db)
	mediumSettlement, err := mediumSettlementDb.GetMediumSettlementForAvailable(originalWxAdData.MediumId)
	if err != nil {
		return
	}
	var basicIncomeBefore, mediumSettlementState, mediumSettlementPayState int
	//判断是否为预付结算类型
	if medium.SettlementType == enum.MediumSettlementTypeForPaymentInAdvance {
		mediumSettlementState = enum.MediumSettlementStateForCompleteSign
		mediumSettlementPayState = enum.MediumSettlementPayStateForPaymentAlready
	}

	if mediumSettlement == nil {
		//新增一条数据
		mediumSettlement = &model.MediumSettlement{
			Uuid:         originalWxAdData.Uuid,
			MediumId:     originalWxAdData.MediumId,
			AppId:        originalWxAdData.AppId,
			BusinessKind: 1,
			Kind:         medium.SettlementType,
			BasicIncome:  generateWxAdData.MediaRevenue,
			OtherIncome:  0,
			State:        mediumSettlementState,
			PayState:     mediumSettlementPayState,
			StartDate:    now.Format("2006-01-02"),
			EndDate:      "",
			CreateAt:     now.Format("2006-01-02 15:04:05"),
			UpdateAt:     now.Format("2006-01-02 15:04:05"),
		}
		_, err = mediumSettlementDb.MediumSettlementInsertBySession(session, mediumSettlement)
		if err != nil {
			_ = session.Rollback()
			return
		}
	} else {
		//更新数据
		basicIncomeBefore = mediumSettlement.BasicIncome
		mediumSettlement.BasicIncome += generateWxAdData.MediaRevenue
		mediumSettlement.State = mediumSettlementState
		mediumSettlement.PayState = mediumSettlementPayState
		_, err = mediumSettlementDb.UpdateMediumSettlementBySession(session, mediumSettlement, "basic_income", "pay_state", "state")
		if err != nil {
			_ = session.Rollback()
			return
		}
	}
	if medium.SettlementType == enum.MediumSettlementTypeForPaymentInAdvance {
		err = DealMediumAmount(session, md.DealMediumAmount{
			Mid:      utils.IntToStr(originalWxAdData.Uuid),
			Type:     md.FinMediumFlowDirectionExpenditure,
			Kind:     md.SettlementSubKindForMediumFlow,
			OrdId:    utils.IntToStr(mediumSettlement.Id),
			MediumId: originalWxAdData.MediumId,
			Amount:   float64(generateWxAdData.MediaRevenue) / 100,
			Memo:     md.SettlementSubTitleForMediumFlow,
		})
		if err != nil {
			_ = session.Rollback()
			return
		}
	}

	//4.2 新增 medium_settlement_with_flow 数据
	mediumSettlementWithFlowDb := implement.NewMediumSettlementWithFlowDb(db.Db)
	_, err = mediumSettlementWithFlowDb.MediumSettlementWithFlowInsertBySession(session, &model.MediumSettlementWithFlow{
		SettlementId:      mediumSettlement.Id,
		GenerateDataId:    generateWxAdData.Id,
		Amount:            generateWxAdData.MediaRevenue,
		BasicIncomeBefore: basicIncomeBefore,
		BasicIncomeAfter:  mediumSettlement.BasicIncome,
		OtherIncomeBefore: 0,
		OtherIncomeAfter:  0,
		Kind:              enum.MediumSettlementWithFlowKindForBasicIncome,
		CreateAt:          now.Format("2006-01-02 15:04:05"),
		UpdateAt:          now.Format("2006-01-02 15:04:05"),
	})
	if err != nil {
		_ = session.Rollback()
		return
	}
	//4.3 新增 agent_settlement、agent_settlement_with_flow 数据
	agentSettlementDb := implement.NewAgentSettlementDb(db.Db)
	agentSettlementWithFlowDb := implement.NewAgentSettlementWithFlowDb(db.Db)
	for _, v := range *generateWxAdDataWithAgentFlow {
		agentSettlement, err1 := agentSettlementDb.GetAgentSettlementForAvailable(v.AgentId)
		if err1 != nil {
			_ = session.Rollback()
			return err1
		}

		var agentBasicIncomeBefore, agentOtherIncomeBefore, agentSettlementState, agentSettlementPayState int
		//判断是否为预付结算类型
		if agentMap[v.AgentId].SettlementType == enum.AgentSettlementTypeForPaymentInAdvance {
			agentSettlementState = enum.AgentSettlementStateForCompleteSign
			agentSettlementPayState = enum.AgentSettlementPayStateForPaymentAlready
		}
		if agentSettlement == nil {
			//新增一条数据
			agentSettlement = &model.AgentSettlement{
				Uuid:         v.Uuid,
				AgentId:      v.AgentId,
				MediumId:     originalWxAdData.MediumId,
				AppId:        v.AppId,
				BusinessKind: 1,
				Kind:         agentMap[v.AgentId].SettlementType,
				BasicIncome:  v.AgentRevenue,
				OtherIncome:  v.ExtraRevenue,
				State:        agentSettlementState,
				PayState:     agentSettlementPayState,
				StartDate:    now.Format("2006-01-02"),
				EndDate:      "",
				CreateAt:     now.Format("2006-01-02 15:04:05"),
				UpdateAt:     now.Format("2006-01-02 15:04:05"),
			}
			_, err = agentSettlementDb.AgentSettlementInsertBySession(session, agentSettlement)
			if err != nil {
				_ = session.Rollback()
				return
			}
		} else {
			//更新数据
			agentBasicIncomeBefore = agentSettlement.BasicIncome
			agentOtherIncomeBefore = agentSettlement.OtherIncome
			agentSettlement.BasicIncome += v.AgentRevenue
			agentSettlement.OtherIncome += v.ExtraRevenue
			agentSettlement.State += agentSettlementState
			agentSettlement.PayState += agentSettlementPayState

			_, err = agentSettlementDb.UpdateAgentSettlementBySession(session, agentSettlement, "basic_income", "other_income", "pay_state", "state")
			if err != nil {
				_ = session.Rollback()
				return
			}
		}

		if agentMap[v.AgentId].SettlementType == enum.AgentSettlementTypeForPaymentInAdvance {
			err = DealAgentAmount(session, md.DealAgentAmount{
				Mid:    utils.IntToStr(originalWxAdData.Uuid),
				Type:   md.FinAgentFlowDirectionExpenditure,
				Kind:   md.SettlementSubKindForAgentFlow,
				OrdId:  utils.IntToStr(v.Id),
				Amount: float64(v.AgentRevenue)/100 + float64(v.ExtraRevenue)/100,
				Memo:   md.SettlementSubTitleForMediumFlow,
			})
			if err != nil {
				_ = session.Rollback()
				return
			}
		}
		_, err = agentSettlementWithFlowDb.AgentSettlementWithFlowInsertBySession(session, &model.AgentSettlementWithFlow{
			SettlementId:      mediumSettlement.Id,
			GenerateDataId:    generateWxAdData.Id,
			Amount:            v.AgentRevenue,
			BasicIncomeBefore: agentBasicIncomeBefore,
			BasicIncomeAfter:  agentSettlement.BasicIncome,
			OtherIncomeBefore: agentOtherIncomeBefore,
			OtherIncomeAfter:  agentSettlement.OtherIncome,
			Kind:              enum.AgentSettlementWithFlowKindForBasicIncome,
			CreateAt:          now.Format("2006-01-02 15:04:05"),
			UpdateAt:          now.Format("2006-01-02 15:04:05"),
		})
		if err != nil {
			_ = session.Rollback()
			return
		}
	}

	//4、修改 generate_wx_ad_data 记录中的 is_generate_report (是否已应用(0:未 1:已) )
	generateWxAdData.IsGenerateReport = 1
	_, err = generateWxAdDataDb.UpdateGenerateWxAdDataBySession(session, generateWxAdData, "is_generate_report")
	if err != nil {
		_ = session.Rollback()
		return
	}
	return session.Commit()
}