From ffc56f912da5d6d842142ae4ea1856bc56f8bcb9 Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期五, 30 九月 2022 19:20:23 +0800
Subject: [PATCH] 结算日志添加
---
app/src/main/java/com/yeshi/makemoney/app/service/impl/goldcorn/GoldCornSettleServiceImpl.java | 13 ++++++++++++-
1 files changed, 12 insertions(+), 1 deletions(-)
diff --git a/app/src/main/java/com/yeshi/makemoney/app/service/impl/goldcorn/GoldCornSettleServiceImpl.java b/app/src/main/java/com/yeshi/makemoney/app/service/impl/goldcorn/GoldCornSettleServiceImpl.java
index 01c88b2..bba65c7 100644
--- a/app/src/main/java/com/yeshi/makemoney/app/service/impl/goldcorn/GoldCornSettleServiceImpl.java
+++ b/app/src/main/java/com/yeshi/makemoney/app/service/impl/goldcorn/GoldCornSettleServiceImpl.java
@@ -1,5 +1,6 @@
package com.yeshi.makemoney.app.service.impl.goldcorn;
+import com.google.gson.Gson;
import com.ks.lib.common.exception.ParamsException;
import com.ks.push.exception.BPushTaskException;
import com.yeshi.makemoney.app.dto.mq.GoldCornSettleMQMsg;
@@ -25,6 +26,8 @@
import com.yeshi.makemoney.app.utils.factory.msg.UserMsgFactory;
import com.yeshi.makemoney.app.utils.goldcorn.GoldCornUtil;
import com.yeshi.makemoney.app.utils.mq.CMQManager;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import org.yeshi.utils.ThreadUtil;
@@ -44,6 +47,7 @@
*/
@Service
public class GoldCornSettleServiceImpl implements GoldCornSettleService {
+ Logger settleLogger= LoggerFactory.getLogger("settleLog");
@Resource
private GoldCornGetRecordService goldCornGetRecordService;
@@ -110,7 +114,9 @@
List<Long> list = goldCornGetRecordService.getUidsByDay(day, i + 1, pageSize);
for (Long uid : list) {
//鍔犲叆鍒癈MQ
- CMQManager.getInstance().addGoldCornSettleMsg(new GoldCornSettleMQMsg(record.getId(), uid, day, System.currentTimeMillis()));
+ GoldCornSettleMQMsg msg= new GoldCornSettleMQMsg(record.getId(), uid, day, System.currentTimeMillis());
+ settleLogger.info("鍔犲叆缁撶畻闃熷垪锛歿}",new Gson().toJson(msg));
+ CMQManager.getInstance().addGoldCornSettleMsg(msg);
}
}
@@ -123,6 +129,11 @@
long cornNum = goldCornGetRecordService.getGoldCornByDay(uid, GoldCornUtil.convertFormatDay(day));
//閲戝竵鏁伴噺
GoldCornConsumeRecord record = GoldCornConsumeRecordFactory.createExchange(uid, day, (int) cornNum, rate, settleId);
+ if(goldCornConsumeRecordService.get(record.getId())!=null){
+ //宸茬粡缁撶畻杩囦簡
+ return;
+ }
+
try {
UserMoneyRecord moneyRecord = UserMoneyRecordFactory.createGoldCornExchange(record);
userMoneyService.addUserMoney(moneyRecord);
--
Gitblit v1.8.0