zhimeng
/
ad_platform
2
0
Fork 0
Code Issues 0 Pull Requests 0 Releases 0 Wiki Activity
Browse Source

1

master
dengbiao 1 month ago
parent
e9a7d48fe2
commit
4356cf6683
1 changed files with 52 additions and 43 deletions
Split View
Diff Options
Show Stats Download Patch File Download Diff File
  1. +52
    -43
      app/svc/svc_wx_data.go

+ 52
- 43
app/svc/svc_wx_data.go View File

@@ -8,11 +8,12 @@ import (
"code.fnuoos.com/zhimeng/model.git/src/super/implement"
"code.fnuoos.com/zhimeng/model.git/src/super/model"
"errors"
"github.com/shopspring/decimal"
"time"
)

func GenerateWxAdData(req md.GenerateWxAdData) (err error, generateWxAdData model.GenerateWxAdData) {
//1、查找原始数据记录
// 1、查找原始数据记录
originalWxAdDataDb := implement.NewOriginalWxAdDataDb(db.Db)
originalWxAdData, err := originalWxAdDataDb.GetOriginalWxAdData(req.OriginalDataId)
if err != nil {
@@ -23,7 +24,7 @@ func GenerateWxAdData(req md.GenerateWxAdData) (err error, generateWxAdData mode
return
}

//2、查询对应媒体、代理的分成策略
// 2、查询对应媒体、代理的分成策略
mediumDivisionStrategyDb := implement.NewMediumDivisionStrategyDb(db.Db)
mediumDivisionStrategy, err := mediumDivisionStrategyDb.GetOriginalWxAdDataByMediumId(originalWxAdData.MediumId)
if err != nil {
@@ -39,16 +40,16 @@ func GenerateWxAdData(req md.GenerateWxAdData) (err error, generateWxAdData mode
return
}

//3、计算媒体、代理收益、平台留存、佣金留存、协议分成、协议总分成
// 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) //协议分成
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、判断是否有调价留存
// 3、判断是否有调价留存
var priceAdjustmentRetention int
if req.NowEcpm != req.OriginalEcpm || req.NowExposureCount != req.OriginalExposureCount {
tmpMediaRevenue := int(utils.StrToFloat64(req.NowEcpm) * float64(req.NowExposureCount) / 1000)
@@ -56,7 +57,7 @@ func GenerateWxAdData(req md.GenerateWxAdData) (err error, generateWxAdData mode
mediaRevenue = tmpMediaRevenue
}

//4、计算各代理收益
// 4、计算各代理收益
var extraRevenue int
var agentRevenueFlows []struct {
AgentId int `json:"agent_id"`
@@ -84,7 +85,7 @@ func GenerateWxAdData(req md.GenerateWxAdData) (err error, generateWxAdData mode
})
}

//5、插入 generate_wx_ad_data 、generate_wx_ad_data_with_agent_flow 数据
// 5、插入 generate_wx_ad_data 、generate_wx_ad_data_with_agent_flow 数据
session := db.Db.NewSession()
defer session.Close()
session.Begin()
@@ -100,11 +101,11 @@ func GenerateWxAdData(req md.GenerateWxAdData) (err error, generateWxAdData mode
AdSlot: originalWxAdData.AdSlot,
Date: originalWxAdData.Date,
ReqSuccCount: originalWxAdData.ReqSuccCount,
ExposureCount: req.NowExposureCount, //现-曝光量
ExposureCount: req.NowExposureCount, // 现-曝光量
ExposureRate: originalWxAdData.ExposureRate,
ClickCount: originalWxAdData.ClickCount,
ClickRate: originalWxAdData.ClickRate,
Ecpm: req.NowEcpm, //现-ecpm
Ecpm: req.NowEcpm, // 现-ecpm
PlatformRetention: platformRetention,
CommissionRetention: commissionRetention,
PriceAdjustmentRetention: priceAdjustmentRetention,
@@ -157,7 +158,7 @@ func GenerateWxAdData(req md.GenerateWxAdData) (err error, generateWxAdData mode
return
}

//6、修改 original_wx_ad_data 记录中的 is_apply(是否已应用(0:未 1:已) )
// 6、修改 original_wx_ad_data 记录中的 is_apply(是否已应用(0:未 1:已) )
originalWxAdData.IsApply = 1
_, err = originalWxAdDataDb.UpdateOriginalWxAdDataBySession(session, originalWxAdData, "is_apply")
if err != nil {
@@ -168,7 +169,7 @@ func GenerateWxAdData(req md.GenerateWxAdData) (err error, generateWxAdData mode
}

func ClacEcpm(req md.ClacEcpmReq) (err error, ecpm string) {
//1、查找原始数据记录
// 1、查找原始数据记录
originalWxAdDataDb := implement.NewOriginalWxAdDataDb(db.Db)
originalWxAdData, err := originalWxAdDataDb.GetOriginalWxAdData(req.GenerateDataId)
if err != nil {
@@ -179,7 +180,7 @@ func ClacEcpm(req md.ClacEcpmReq) (err error, ecpm string) {
return
}

//2、查询对应媒体分成策略
// 2、查询对应媒体分成策略
mediumDivisionStrategyDb := implement.NewMediumDivisionStrategyDb(db.Db)
mediumDivisionStrategy, err := mediumDivisionStrategyDb.GetOriginalWxAdDataByMediumId(originalWxAdData.MediumId)
if err != nil {
@@ -190,19 +191,27 @@ func ClacEcpm(req md.ClacEcpmReq) (err error, ecpm string) {
return
}

//3、计算媒体、代理收益、协议总分成
publisherIncome := originalWxAdData.PublisherIncome
mediaRevenue := publisherIncome * mediumDivisionStrategy.MediaRevenueRate / 100 //媒体收益
agentRevenue := publisherIncome * mediumDivisionStrategy.AgentRevenueRate / 100 //代理收益
agreementSharingTotal := (mediaRevenue + agentRevenue) / (100 - mediumDivisionStrategy.AgreementSharingRate) //协议总分成（倒推）
// 3、计算媒体、代理收益、协议总分成
publisherIncome := decimal.NewFromInt(int64(originalWxAdData.PublisherIncome))
mediaRevenueRate := decimal.NewFromInt(int64(mediumDivisionStrategy.MediaRevenueRate))
agentRevenueRate := decimal.NewFromInt(int64(mediumDivisionStrategy.AgentRevenueRate))
agreementSharingRate := decimal.NewFromInt(int64(mediumDivisionStrategy.AgreementSharingRate))
exposureCount := decimal.NewFromInt(int64(originalWxAdData.ExposureCount))
rateValue := decimal.NewFromInt(100)
thousandRateValue := decimal.NewFromInt(1000)

mediaRevenue := publisherIncome.Mul(mediaRevenueRate.Div(rateValue)) // 媒体收益
agentRevenue := publisherIncome.Mul(agentRevenueRate.Div(rateValue)) // 代理收益

agreementSharingTotal := (mediaRevenue.Add(agentRevenue)).Div(rateValue.Sub(agreementSharingRate)) // 协议总分成（倒推）

//4、倒退出当前ecpm值
ecpm = utils.Float64ToStrPrec4(float64(agreementSharingTotal) / (float64(originalWxAdData.ExposureCount) / 1000))
// 4、倒退出当前ecpm值
ecpm = agreementSharingTotal.Div(exposureCount.Div(thousandRateValue)).Round(2).String()
return
}

func SettlementWxAdData(req md.SettlementWxAdData) (err error) {
//1、查找生成数据记录
// 1、查找生成数据记录
generateWxAdDataDb := implement.NewGenerateWxAdDataDb(db.Db)
generateWxAdData, err := generateWxAdDataDb.GetGenerateWxAdData(req.GenerateDataId)
if err != nil {
@@ -223,14 +232,14 @@ func SettlementWxAdData(req md.SettlementWxAdData) (err error) {
return
}

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

//3、查询 媒体、代理的结算方式
// 3、查询 媒体、代理的结算方式
mediumListDb := implement.NewMediumListDb(db.Db)
medium, err := mediumListDb.GetMediumList(originalWxAdData.MediumId)
if err != nil {
@@ -252,27 +261,27 @@ func SettlementWxAdData(req md.SettlementWxAdData) (err error) {
agentMap[v.AgentId] = *agent
}

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

//4.1 新增/更新 medium_settlement 数据
// 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,
@@ -300,18 +309,18 @@ func SettlementWxAdData(req md.SettlementWxAdData) (err error) {
return
}
} else {
//更新数据
// 更新数据
if medium.SettlementType != mediumSettlement.Kind {
//TODO::前后结算类型不一致，之前结算单状态自动变成"核算中"
// TODO::前后结算类型不一致，之前结算单状态自动变成"核算中"
mediumSettlement.State = enum.MediumSettlementStateForAccountingInProgress
//mediumSettlement.PayState = mediumSettlementPayState
// mediumSettlement.PayState = mediumSettlementPayState
_, err = mediumSettlementDb.UpdateMediumSettlementBySession(session, mediumSettlement, "state")
if err != nil {
_ = session.Rollback()
return
}

//新增一条数据
// 新增一条数据
mediumSettlement = &model.MediumSettlement{
Uuid: originalWxAdData.Uuid,
MediumId: originalWxAdData.MediumId,
@@ -368,7 +377,7 @@ func SettlementWxAdData(req md.SettlementWxAdData) (err error) {
}
}

//4.2 新增 medium_settlement_with_flow 数据
// 4.2 新增 medium_settlement_with_flow 数据
mediumSettlementWithFlowDb := implement.NewMediumSettlementWithFlowDb(db.Db)
_, err = mediumSettlementWithFlowDb.MediumSettlementWithFlowInsertBySession(session, &model.MediumSettlementWithFlow{
SettlementId: mediumSettlement.Id,
@@ -386,7 +395,7 @@ func SettlementWxAdData(req md.SettlementWxAdData) (err error) {
_ = session.Rollback()
return
}
//4.3 新增 agent_settlement、agent_settlement_with_flow 数据
// 4.3 新增 agent_settlement、agent_settlement_with_flow 数据
agentSettlementDb := implement.NewAgentSettlementDb(db.Db)
agentSettlementWithFlowDb := implement.NewAgentSettlementWithFlowDb(db.Db)
for _, v := range *generateWxAdDataWithAgentFlow {
@@ -397,13 +406,13 @@ func SettlementWxAdData(req md.SettlementWxAdData) (err error) {
}

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,
@@ -427,9 +436,9 @@ func SettlementWxAdData(req md.SettlementWxAdData) (err error) {
return
}
} else {
//更新数据
// 更新数据
if agentMap[v.AgentId].SettlementType != agentSettlement.Kind {
//TODO::前后结算类型不一致，之前结算单状态自动变成"核算中"
// TODO::前后结算类型不一致，之前结算单状态自动变成"核算中"
agentSettlement.State = enum.AgentSettlementStateForAccountingInProgress
_, err = agentSettlementDb.UpdateAgentSettlementBySession(session, agentSettlement, "state")
if err != nil {
@@ -437,7 +446,7 @@ func SettlementWxAdData(req md.SettlementWxAdData) (err error) {
return
}

//新增一条数据
// 新增一条数据
agentSettlement = &model.AgentSettlement{
Uuid: v.Uuid,
AgentId: v.AgentId,
@@ -506,7 +515,7 @@ func SettlementWxAdData(req md.SettlementWxAdData) (err error) {
}
}

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


Write Preview
Loading…
Cancel
Save