zhimeng
/
ad_platform
2
0
Fork 0
Code Issues 0 Pull Requests 0 Releases 0 Wiki Activity
广告平台(站长使用)
You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
23 Commits
1 Branch
4.2 MiB
 
 
 
 
 
Tree: 48b73fef0e
Branches Tags
${ item.name }
Create branch ${ searchTerm }
from '48b73fef0e'
${ noResults }
ad_platform/app/svc/svc_wx_data.go

434 lines
17 KiB
Raw Blame History 

  1. package svc

  2. 

  3. import (

  4. 	"applet/app/enum"

  5. 	"applet/app/md"

  6. 	"applet/app/utils"

  7. 	db "code.fnuoos.com/zhimeng/model.git/src"

  8. 	"code.fnuoos.com/zhimeng/model.git/src/super/implement"

  9. 	"code.fnuoos.com/zhimeng/model.git/src/super/model"

  10. 	"errors"

  11. 	"time"

  12. )

  13. 

  14. func GenerateWxAdData(req md.GenerateWxAdData) (err error, generateWxAdData model.GenerateWxAdData) {

  15. 	//1、查找原始数据记录

  16. 	originalWxAdDataDb := implement.NewOriginalWxAdDataDb(db.Db)

  17. 	originalWxAdData, err := originalWxAdDataDb.GetOriginalWxAdData(req.OriginalDataId)

  18. 	if err != nil {

  19. 		return

  20. 	}

  21. 	if originalWxAdData == nil {

  22. 		err = errors.New("未查询到原始数据记录")

  23. 		return

  24. 	}

  25. 

  26. 	//2、查询对应媒体、代理的分成策略

  27. 	mediumDivisionStrategyDb := implement.NewMediumDivisionStrategyDb(db.Db)

  28. 	mediumDivisionStrategy, err := mediumDivisionStrategyDb.GetOriginalWxAdDataByMediumId(originalWxAdData.MediumId)

  29. 	if err != nil {

  30. 		return

  31. 	}

  32. 	if mediumDivisionStrategy == nil {

  33. 		err = errors.New("未查询到对应代理的分成策略")

  34. 		return

  35. 	}

  36. 	mediumDivisionStrategyWithAgentFlowDb := implement.NewMediumDivisionStrategyWithAgentFlowDb(db.Db)

  37. 	mediumDivisionStrategyWithAgentFlows, err := mediumDivisionStrategyWithAgentFlowDb.FindMediumDivisionStrategyWithAgentFlowByStrategyId(mediumDivisionStrategy.MediumId)

  38. 	if err != nil {

  39. 		return

  40. 	}

  41. 

  42. 	//3、计算媒体、代理收益、平台留存、佣金留存、协议分成、协议总分成

  43. 	publisherIncome := originalWxAdData.PublisherIncome

  44. 	mediaRevenue := publisherIncome * mediumDivisionStrategy.MediaRevenueRate / 100                              //媒体收益

  45. 	agentRevenue := publisherIncome * mediumDivisionStrategy.AgentRevenueRate / 100                              //代理收益

  46. 	platformRetention := publisherIncome * mediumDivisionStrategy.PlatformRetentionRate / 100                    //平台留存

  47. 	commissionRetention := publisherIncome * mediumDivisionStrategy.CommissionRetentionRate / 100                //佣金留存

  48. 	agreementSharingTotal := (mediaRevenue + agentRevenue) / (100 - mediumDivisionStrategy.AgreementSharingRate) //协议总分成（倒推）

  49. 	agreementSharing := agreementSharingTotal - (mediaRevenue + agentRevenue)                                    //协议分成

  50. 

  51. 	//3、判断是否有调价留存

  52. 	var priceAdjustmentRetention int

  53. 	if req.NowEcpm != req.OriginalEcpm || req.NowExposureCount != req.OriginalExposureCount {

  54. 		tmpMediaRevenue := int(utils.StrToFloat64(req.NowEcpm) * float64(req.NowExposureCount) / 1000)

  55. 		priceAdjustmentRetention = tmpMediaRevenue - mediaRevenue

  56. 		mediaRevenue = tmpMediaRevenue

  57. 	}

  58. 

  59. 	//4、计算各代理收益

  60. 	var extraRevenue int

  61. 	var agentRevenueFlows []struct {

  62. 		AgentId          int `json:"agent_id"`

  63. 		AgentRevenueRate int `json:"agent_revenue_rate"`

  64. 		ExtraRevenueRate int `json:"extra_revenue_rate"`

  65. 		AgentRevenue     int `json:"agent_revenue"`

  66. 		ExtraRevenue     int `json:"extra_revenue"`

  67. 	}

  68. 	for _, v := range *mediumDivisionStrategyWithAgentFlows {

  69. 		tmpAgentRevenue := agentRevenue * v.AgentRevenueRate / 100

  70. 		tmpExtraRevenue := commissionRetention * v.ExtraRevenueRate / 100

  71. 		extraRevenue += tmpExtraRevenue

  72. 		agentRevenueFlows = append(agentRevenueFlows, struct {

  73. 			AgentId          int `json:"agent_id"`

  74. 			AgentRevenueRate int `json:"agent_revenue_rate"`

  75. 			ExtraRevenueRate int `json:"extra_revenue_rate"`

  76. 			AgentRevenue     int `json:"agent_revenue"`

  77. 			ExtraRevenue     int `json:"extra_revenue"`

  78. 		}{

  79. 			AgentId:          v.AgentId,

  80. 			AgentRevenueRate: v.AgentRevenueRate,

  81. 			ExtraRevenueRate: v.ExtraRevenueRate,

  82. 			AgentRevenue:     tmpAgentRevenue,

  83. 			ExtraRevenue:     tmpExtraRevenue,

  84. 		})

  85. 	}

  86. 

  87. 	//5、插入 generate_wx_ad_data 、generate_wx_ad_data_with_agent_flow 数据

  88. 	session := db.Db.NewSession()

  89. 	defer session.Close()

  90. 	session.Begin()

  91. 

  92. 	now := time.Now()

  93. 	generateWxAdData = model.GenerateWxAdData{

  94. 		Uuid:                     originalWxAdData.Uuid,

  95. 		AppId:                    originalWxAdData.AppId,

  96. 		OriginalDataId:           originalWxAdData.Id,

  97. 		SlotId:                   originalWxAdData.SlotId,

  98. 		AdSlot:                   originalWxAdData.AdSlot,

  99. 		Date:                     originalWxAdData.Date,

  100. 		ReqSuccCount:             originalWxAdData.ReqSuccCount,

  101. 		ExposureCount:            req.NowExposureCount, //现-曝光量

  102. 		ExposureRate:             originalWxAdData.ExposureRate,

  103. 		ClickCount:               originalWxAdData.ClickCount,

  104. 		ClickRate:                originalWxAdData.ClickRate,

  105. 		Ecpm:                     req.NowEcpm, //现-ecpm

  106. 		PlatformRetention:        platformRetention,

  107. 		CommissionRetention:      commissionRetention,

  108. 		PriceAdjustmentRetention: priceAdjustmentRetention,

  109. 		MediaRevenue:             mediaRevenue,

  110. 		AgentRevenue:             agentRevenue,

  111. 		ExtraRevenue:             extraRevenue,

  112. 		AgreementSharing:         agreementSharing,

  113. 		AgreementSharingTotal:    agreementSharingTotal,

  114. 		PlatformRetentionRate:    mediumDivisionStrategy.PlatformRetentionRate,

  115. 		CommissionRetentionRate:  mediumDivisionStrategy.CommissionRetentionRate,

  116. 		MediaRevenueRate:         mediumDivisionStrategy.MediaRevenueRate,

  117. 		AgentRevenueRate:         mediumDivisionStrategy.AgentRevenueRate,

  118. 		ExtraRevenueRate:         mediumDivisionStrategy.ExtraRevenueRate,

  119. 		AgreementSharingRate:     mediumDivisionStrategy.AgreementSharingRate,

  120. 		IsGenerateReport:         0,

  121. 		CreateAt:                 now.Format("2006-01-02 15:04:05"),

  122. 		UpdateAt:                 now.Format("2006-01-02 15:04:05"),

  123. 	}

  124. 	generateWxAdDataDb := implement.NewGenerateWxAdDataDb(db.Db)

  125. 	_, err = generateWxAdDataDb.GenerateWxAdDataInsertBySession(session, &generateWxAdData)

  126. 	if err != nil {

  127. 		_ = session.Rollback()

  128. 		return

  129. 	}

  130. 

  131. 	var generateWxAdDataWithAgentFlows []*model.GenerateWxAdDataWithAgentFlow

  132. 	for _, v := range agentRevenueFlows {

  133. 		generateWxAdDataWithAgentFlows = append(generateWxAdDataWithAgentFlows, &model.GenerateWxAdDataWithAgentFlow{

  134. 			Uuid:             generateWxAdData.Uuid,

  135. 			AppId:            generateWxAdData.AppId,

  136. 			AgentId:          v.AgentId,

  137. 			GenerateDataId:   generateWxAdData.Id,

  138. 			SlotId:           generateWxAdData.SlotId,

  139. 			AdSlot:           generateWxAdData.AdSlot,

  140. 			Date:             generateWxAdData.Date,

  141. 			AgentRevenue:     v.AgentRevenue,

  142. 			AgentRevenueRate: v.AgentRevenueRate,

  143. 			ExtraRevenue:     v.ExtraRevenue,

  144. 			ExtraRevenueRate: v.ExtraRevenueRate,

  145. 			CreateAt:         now.Format("2006-01-02 15:04:05"),

  146. 			UpdateAt:         now.Format("2006-01-02 15:04:05"),

  147. 		})

  148. 	}

  149. 	generateWxAdDataWithAgentFlowDb := implement.NewGenerateWxAdDataWithAgentFlowDb(db.Db)

  150. 	_, err = generateWxAdDataWithAgentFlowDb.BatchAddGenerateWxAdDataWithAgentFlow(session, generateWxAdDataWithAgentFlows)

  151. 	if err != nil {

  152. 		_ = session.Rollback()

  153. 		return

  154. 	}

  155. 

  156. 	//6、修改 original_wx_ad_data 记录中的 is_apply(是否已应用(0:未 1:已) )

  157. 	originalWxAdData.IsApply = 1

  158. 	_, err = originalWxAdDataDb.UpdateOriginalWxAdDataBySession(session, originalWxAdData, "is_apply")

  159. 	if err != nil {

  160. 		_ = session.Rollback()

  161. 		return

  162. 	}

  163. 	return session.Commit(), generateWxAdData

  164. }

  165. 

  166. func ClacEcpm(req md.ClacEcpmReq) (err error, ecpm string) {

  167. 	//1、查找原始数据记录

  168. 	originalWxAdDataDb := implement.NewOriginalWxAdDataDb(db.Db)

  169. 	originalWxAdData, err := originalWxAdDataDb.GetOriginalWxAdData(req.GenerateDataId)

  170. 	if err != nil {

  171. 		return

  172. 	}

  173. 	if originalWxAdData == nil {

  174. 		err = errors.New("未查询到原始数据记录")

  175. 		return

  176. 	}

  177. 

  178. 	//2、查询对应媒体分成策略

  179. 	mediumDivisionStrategyDb := implement.NewMediumDivisionStrategyDb(db.Db)

  180. 	mediumDivisionStrategy, err := mediumDivisionStrategyDb.GetOriginalWxAdDataByMediumId(originalWxAdData.MediumId)

  181. 	if err != nil {

  182. 		return

  183. 	}

  184. 	if mediumDivisionStrategy == nil {

  185. 		err = errors.New("未查询到对应代理的分成策略")

  186. 		return

  187. 	}

  188. 

  189. 	//3、计算媒体、代理收益、协议总分成

  190. 	publisherIncome := originalWxAdData.PublisherIncome

  191. 	mediaRevenue := publisherIncome * mediumDivisionStrategy.MediaRevenueRate / 100                              //媒体收益

  192. 	agentRevenue := publisherIncome * mediumDivisionStrategy.AgentRevenueRate / 100                              //代理收益

  193. 	agreementSharingTotal := (mediaRevenue + agentRevenue) / (100 - mediumDivisionStrategy.AgreementSharingRate) //协议总分成（倒推）

  194. 

  195. 	//4、倒退出当前ecpm值

  196. 	ecpm = utils.Float64ToStrPrec4(float64(agreementSharingTotal) / (float64(originalWxAdData.ExposureCount) / 1000))

  197. 	return

  198. }

  199. 

  200. func SettlementWxAdData(req md.SettlementWxAdData) (err error) {

  201. 	//1、查找生成数据记录

  202. 	generateWxAdDataDb := implement.NewGenerateWxAdDataDb(db.Db)

  203. 	generateWxAdData, err := generateWxAdDataDb.GetGenerateWxAdData(req.GenerateDataId)

  204. 	if err != nil {

  205. 		return

  206. 	}

  207. 	if generateWxAdData == nil {

  208. 		err = errors.New("未查询到生成数据记录")

  209. 		return

  210. 	}

  211. 

  212. 	originalWxAdDataDb := implement.NewOriginalWxAdDataDb(db.Db)

  213. 	originalWxAdData, err := originalWxAdDataDb.GetOriginalWxAdData(generateWxAdData.OriginalDataId)

  214. 	if err != nil {

  215. 		return

  216. 	}

  217. 	if originalWxAdData == nil {

  218. 		err = errors.New("未查询到原始数据记录")

  219. 		return

  220. 	}

  221. 

  222. 	//2、查询 生成数据-代理明细 记录

  223. 	generateWxAdDataWithAgentFlowDb := implement.NewGenerateWxAdDataWithAgentFlowDb(db.Db)

  224. 	generateWxAdDataWithAgentFlow, err := generateWxAdDataWithAgentFlowDb.FindGenerateWxAdDataWithAgentFlowByStrategyId(generateWxAdData.Id)

  225. 	if err != nil {

  226. 		return

  227. 	}

  228. 

  229. 	//3、查询 媒体、代理的结算方式

  230. 	mediumListDb := implement.NewMediumListDb(db.Db)

  231. 	medium, err := mediumListDb.GetMediumList(originalWxAdData.MediumId)

  232. 	if err != nil {

  233. 		return

  234. 	}

  235. 	if medium == nil {

  236. 		return errors.New("媒体：" + utils.IntToStr(originalWxAdData.MediumId) + "未查询到对应记录")

  237. 	}

  238. 	var agentMap = map[int]model.AgentList{}

  239. 	agentListDb := implement.NewAgentListDb(db.Db)

  240. 	for _, v := range *generateWxAdDataWithAgentFlow {

  241. 		agent, err1 := agentListDb.GetAgentList(v.AgentId)

  242. 		if err1 != nil {

  243. 			return err1

  244. 		}

  245. 		if agent == nil {

  246. 			return errors.New("代理：" + utils.IntToStr(v.AgentId) + "未查询到对应记录")

  247. 		}

  248. 		agentMap[v.AgentId] = *agent

  249. 	}

  250. 

  251. 	//4、生成数据

  252. 	now := time.Now()

  253. 	session := db.Db.NewSession()

  254. 	defer session.Close()

  255. 	session.Begin()

  256. 

  257. 	//4.1 新增/更新 medium_settlement 数据

  258. 	mediumSettlementDb := implement.NewMediumSettlementDb(db.Db)

  259. 	mediumSettlement, err := mediumSettlementDb.GetMediumSettlementForAvailable(originalWxAdData.MediumId)

  260. 	if err != nil {

  261. 		return

  262. 	}

  263. 	var basicIncomeBefore, mediumSettlementState, mediumSettlementPayState int

  264. 	//判断是否为预付结算类型

  265. 	if medium.SettlementType == enum.MediumSettlementTypeForPaymentInAdvance {

  266. 		mediumSettlementState = enum.MediumSettlementStateForCompleteSign

  267. 		mediumSettlementPayState = enum.MediumSettlementPayStateForPaymentAlready

  268. 	}

  269. 

  270. 	if mediumSettlement == nil {

  271. 		//新增一条数据

  272. 		mediumSettlement = &model.MediumSettlement{

  273. 			Uuid:         originalWxAdData.Uuid,

  274. 			MediumId:     originalWxAdData.MediumId,

  275. 			AppId:        originalWxAdData.AppId,

  276. 			BusinessKind: 1,

  277. 			Kind:         medium.SettlementType,

  278. 			BasicIncome:  generateWxAdData.MediaRevenue,

  279. 			OtherIncome:  0,

  280. 			State:        mediumSettlementState,

  281. 			PayState:     mediumSettlementPayState,

  282. 			StartDate:    now.Format("2006-01-02"),

  283. 			EndDate:      "",

  284. 			CreateAt:     now.Format("2006-01-02 15:04:05"),

  285. 			UpdateAt:     now.Format("2006-01-02 15:04:05"),

  286. 		}

  287. 		_, err = mediumSettlementDb.MediumSettlementInsertBySession(session, mediumSettlement)

  288. 		if err != nil {

  289. 			_ = session.Rollback()

  290. 			return

  291. 		}

  292. 	} else {

  293. 		//更新数据

  294. 		basicIncomeBefore = mediumSettlement.BasicIncome

  295. 		mediumSettlement.BasicIncome += generateWxAdData.MediaRevenue

  296. 		mediumSettlement.State = mediumSettlementState

  297. 		mediumSettlement.PayState = mediumSettlementPayState

  298. 		_, err = mediumSettlementDb.UpdateMediumSettlementBySession(session, mediumSettlement, "basic_income", "pay_state", "state")

  299. 		if err != nil {

  300. 			_ = session.Rollback()

  301. 			return

  302. 		}

  303. 	}

  304. 	if medium.SettlementType == enum.MediumSettlementTypeForPaymentInAdvance {

  305. 		err = DealMediumAmount(session, md.DealMediumAmount{

  306. 			Mid:      utils.IntToStr(originalWxAdData.Uuid),

  307. 			Type:     md.FinMediumFlowDirectionExpenditure,

  308. 			Kind:     md.SettlementSubKindForMediumFlow,

  309. 			OrdId:    utils.IntToStr(mediumSettlement.Id),

  310. 			MediumId: originalWxAdData.MediumId,

  311. 			Amount:   float64(generateWxAdData.MediaRevenue) / 100,

  312. 			Memo:     md.SettlementSubTitleForMediumFlow,

  313. 		})

  314. 		if err != nil {

  315. 			_ = session.Rollback()

  316. 			return

  317. 		}

  318. 	}

  319. 

  320. 	//4.2 新增 medium_settlement_with_flow 数据

  321. 	mediumSettlementWithFlowDb := implement.NewMediumSettlementWithFlowDb(db.Db)

  322. 	_, err = mediumSettlementWithFlowDb.MediumSettlementWithFlowInsertBySession(session, &model.MediumSettlementWithFlow{

  323. 		SettlementId:      mediumSettlement.Id,

  324. 		GenerateDataId:    generateWxAdData.Id,

  325. 		Amount:            generateWxAdData.MediaRevenue,

  326. 		BasicIncomeBefore: basicIncomeBefore,

  327. 		BasicIncomeAfter:  mediumSettlement.BasicIncome,

  328. 		OtherIncomeBefore: 0,

  329. 		OtherIncomeAfter:  0,

  330. 		Kind:              enum.MediumSettlementWithFlowKindForBasicIncome,

  331. 		CreateAt:          now.Format("2006-01-02 15:04:05"),

  332. 		UpdateAt:          now.Format("2006-01-02 15:04:05"),

  333. 	})

  334. 	if err != nil {

  335. 		_ = session.Rollback()

  336. 		return

  337. 	}

  338. 	//4.3 新增 agent_settlement、agent_settlement_with_flow 数据

  339. 	agentSettlementDb := implement.NewAgentSettlementDb(db.Db)

  340. 	agentSettlementWithFlowDb := implement.NewAgentSettlementWithFlowDb(db.Db)

  341. 	for _, v := range *generateWxAdDataWithAgentFlow {

  342. 		agentSettlement, err1 := agentSettlementDb.GetAgentSettlementForAvailable(v.AgentId)

  343. 		if err1 != nil {

  344. 			_ = session.Rollback()

  345. 			return err1

  346. 		}

  347. 

  348. 		var agentBasicIncomeBefore, agentOtherIncomeBefore, agentSettlementState, agentSettlementPayState int

  349. 		//判断是否为预付结算类型

  350. 		if agentMap[v.AgentId].SettlementType == enum.AgentSettlementTypeForPaymentInAdvance {

  351. 			agentSettlementState = enum.AgentSettlementStateForCompleteSign

  352. 			agentSettlementPayState = enum.AgentSettlementPayStateForPaymentAlready

  353. 		}

  354. 		if agentSettlement == nil {

  355. 			//新增一条数据

  356. 			agentSettlement = &model.AgentSettlement{

  357. 				Uuid:         v.Uuid,

  358. 				AgentId:      v.AgentId,

  359. 				MediumId:     originalWxAdData.MediumId,

  360. 				AppId:        v.AppId,

  361. 				BusinessKind: 1,

  362. 				Kind:         agentMap[v.AgentId].SettlementType,

  363. 				BasicIncome:  v.AgentRevenue,

  364. 				OtherIncome:  v.ExtraRevenue,

  365. 				State:        agentSettlementState,

  366. 				PayState:     agentSettlementPayState,

  367. 				StartDate:    now.Format("2006-01-02"),

  368. 				EndDate:      "",

  369. 				CreateAt:     now.Format("2006-01-02 15:04:05"),

  370. 				UpdateAt:     now.Format("2006-01-02 15:04:05"),

  371. 			}

  372. 			_, err = agentSettlementDb.AgentSettlementInsertBySession(session, agentSettlement)

  373. 			if err != nil {

  374. 				_ = session.Rollback()

  375. 				return

  376. 			}

  377. 		} else {

  378. 			//更新数据

  379. 			agentBasicIncomeBefore = agentSettlement.BasicIncome

  380. 			agentOtherIncomeBefore = agentSettlement.OtherIncome

  381. 			agentSettlement.BasicIncome += v.AgentRevenue

  382. 			agentSettlement.OtherIncome += v.ExtraRevenue

  383. 			agentSettlement.State += agentSettlementState

  384. 			agentSettlement.PayState += agentSettlementPayState

  385. 

  386. 			_, err = agentSettlementDb.UpdateAgentSettlementBySession(session, agentSettlement, "basic_income", "other_income", "pay_state", "state")

  387. 			if err != nil {

  388. 				_ = session.Rollback()

  389. 				return

  390. 			}

  391. 		}

  392. 

  393. 		if agentMap[v.AgentId].SettlementType == enum.AgentSettlementTypeForPaymentInAdvance {

  394. 			err = DealAgentAmount(session, md.DealAgentAmount{

  395. 				Mid:    utils.IntToStr(originalWxAdData.Uuid),

  396. 				Type:   md.FinAgentFlowDirectionExpenditure,

  397. 				Kind:   md.SettlementSubKindForAgentFlow,

  398. 				OrdId:  utils.IntToStr(v.Id),

  399. 				Amount: float64(v.AgentRevenue)/100 + float64(v.ExtraRevenue)/100,

  400. 				Memo:   md.SettlementSubTitleForMediumFlow,

  401. 			})

  402. 			if err != nil {

  403. 				_ = session.Rollback()

  404. 				return

  405. 			}

  406. 		}

  407. 		_, err = agentSettlementWithFlowDb.AgentSettlementWithFlowInsertBySession(session, &model.AgentSettlementWithFlow{

  408. 			SettlementId:      mediumSettlement.Id,

  409. 			GenerateDataId:    generateWxAdData.Id,

  410. 			Amount:            v.AgentRevenue,

  411. 			BasicIncomeBefore: agentBasicIncomeBefore,

  412. 			BasicIncomeAfter:  agentSettlement.BasicIncome,

  413. 			OtherIncomeBefore: agentOtherIncomeBefore,

  414. 			OtherIncomeAfter:  agentSettlement.OtherIncome,

  415. 			Kind:              enum.AgentSettlementWithFlowKindForBasicIncome,

  416. 			CreateAt:          now.Format("2006-01-02 15:04:05"),

  417. 			UpdateAt:          now.Format("2006-01-02 15:04:05"),

  418. 		})

  419. 		if err != nil {

  420. 			_ = session.Rollback()

  421. 			return

  422. 		}

  423. 	}

  424. 

  425. 	//4、修改 generate_wx_ad_data 记录中的 is_generate_report (是否已应用(0:未 1:已) )

  426. 	generateWxAdData.IsGenerateReport = 1

  427. 	_, err = generateWxAdDataDb.UpdateGenerateWxAdDataBySession(session, generateWxAdData, "is_generate_report")

  428. 	if err != nil {

  429. 		_ = session.Rollback()

  430. 		return

  431. 	}

  432. 	return session.Commit()

  433. }