diff --git a/md/mq.go b/md/mq.go index d243062..ca73399 100644 --- a/md/mq.go +++ b/md/mq.go @@ -19,3 +19,8 @@ type OneCirclesStructForAutoExchangeGreenEnergy struct { MasterId string `json:"master_id"` Uid int `json:"uid"` } +type OneCirclesStructForStarLevelDividends struct { + MasterId string `json:"master_id"` + Uid int `json:"uid"` + SignDividend float64 `json:"sign_dividend"` +} diff --git a/rule/one_circles/one_circles_star_level_dividends.go b/rule/one_circles/one_circles_star_level_dividends.go index 604a49e..c53a54d 100644 --- a/rule/one_circles/one_circles_star_level_dividends.go +++ b/rule/one_circles/one_circles_star_level_dividends.go @@ -352,9 +352,10 @@ func SettlementStarLevelDividends(engine *xorm.Engine, masterId string, ch *rabb siginDividend, _ := siginDividendValue.Float64() if siginDividend > 0 { //TODO::推入rabbitmq 异步处理 - ch.Publish(md.OneCirclesExchange, md.OneCirclesStructForAutoExchangeGreenEnergy{ - MasterId: masterId, - Uid: item.Uid, + ch.Publish(md.OneCirclesExchange, md.OneCirclesStructForStarLevelDividends{ + MasterId: masterId, + Uid: item.Uid, + SignDividend: siginDividend, }, md.OneCirclesRoutKeyForStarLevelDividend) totalDividendValue = totalDividendValue.Add(siginDividendValue)