Commit f52e8fe0 by guanchen

修复奖励计数bug

parent 8e84f6b9
...@@ -144,6 +144,7 @@ public class AgentRewardQueueTask { ...@@ -144,6 +144,7 @@ public class AgentRewardQueueTask {
rewardCnt++; rewardCnt++;
} else if (rewardCnt < 3){ } else if (rewardCnt < 3){
rewardList.add(agent); rewardList.add(agent);
rewardCnt++;
} else { } else {
break; break;
} }
...@@ -197,6 +198,7 @@ public class AgentRewardQueueTask { ...@@ -197,6 +198,7 @@ public class AgentRewardQueueTask {
doPush(reward); doPush(reward);
} }
} catch (Exception e) { } catch (Exception e) {
logger.error(e.getMessage(), e);
logger.error("插入代理商分成奖励失败, 奖励 {}", message); logger.error("插入代理商分成奖励失败, 奖励 {}", message);
/** /**
* 回滚事务 * 回滚事务
...@@ -247,7 +249,7 @@ public class AgentRewardQueueTask { ...@@ -247,7 +249,7 @@ public class AgentRewardQueueTask {
agentReward.setSourceUserLevel(sourceUserLevel); agentReward.setSourceUserLevel(sourceUserLevel);
agentReward.setCreatedAt(System.currentTimeMillis() / 1000L); agentReward.setCreatedAt(System.currentTimeMillis() / 1000L);
agentReward.setCommissionRate(commissionRate); agentReward.setCommissionRate(commissionRate);
agentReward.setRewardTypeChild(message.getRewardTypeChild()); agentReward.setRewardTypeChild(message.getRewardTypeChild() == null ? "" : message.getRewardTypeChild());
/** /**
* agent_reward里: * agent_reward里:
* money 面额(message里, 需要上供的代理商自己获得的奖励) * money 面额(message里, 需要上供的代理商自己获得的奖励)
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment