update

consume/egg_energy_settlement_public_give_activity_coin_consume.go

@@ -71,11 +71,13 @@ func handleEggEnergySettlementPublicGiveActivityCoinConsume(msgData []byte) erro
 	}()
 	session.Begin()
 
-	//3、给相应的用户加上个人的团队活跃积分
+	//2、给相应的用户加上个人的团队活跃积分
 	err = rule.DealUserVirtualCoin(session, *msg)
 	if err != nil {
 		session.Rollback()
 		return err
 	}
+
+	//3、判断是否今天已
 	return session.Commit()
 }

consume/egg_energy_start_exchange_green_energy.go

@@ -43,7 +43,10 @@ func EggEnergyStartExchangeGreenEnergyConsume(queue md.MqQueue) {
 					"body": res.Body,
 					"err":  err.Error(),
 				}))
-				_ = res.Reject(true) //TODO::拒绝
+				_ = res.Reject(false) //TODO::拒绝 true
+				var msg *md2.EggEnergyStructForStartExchangeGreenEnergy
+				json.Unmarshal(res.Body, &msg)
+				ch.Publish(queue.ExchangeName, msg, queue.RoutKey)
 			} else {
 				err = res.Ack(true)
 				fmt.Println("err ::: ", err)