update 一个圈圈

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"`
+}

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)