|
|
@@ -28,7 +28,7 @@ func ZhiosWithdrawReward(queue md.MqQueue) { |
|
|
|
//1、将自己绑定到交换机上 |
|
|
|
ch.Bind(queue.Name, queue.ExchangeName, queue.RoutKey) |
|
|
|
//2、取出数据进行消费 |
|
|
|
ch.Qos(1) |
|
|
|
ch.Qos(20) |
|
|
|
delivery := ch.Consume(queue.Name, false) |
|
|
|
|
|
|
|
var res amqp.Delivery |
|
|
@@ -108,6 +108,7 @@ func handleZhiosWithdrawReward(msg []byte) error { |
|
|
|
if utils.StrToFloat64(publicWithdrawTeamBili) > 0 && utils.StrToFloat64(publicWithdrawTeamCount) > 0 { |
|
|
|
//分给粉丝 |
|
|
|
user, _ := rule.FindRandUser(eg, utils.StrToInt(publicWithdrawTeamCount)) |
|
|
|
fmt.Println("=zhe", utils.SerializeStr(user)) |
|
|
|
money := utils.FloatFormat(utils.StrToFloat64(apply.Amount)*(utils.StrToFloat64(publicWithdrawTeamBili)/100)/float64(len(user)), 6) |
|
|
|
comm(eg, canalMsg.Id, user, money, "公排团队提现分红", "withdraw_team_reward", "93") |
|
|
|
} |
|
|
|