From 0e9b6603d4ae9d11c1fbc90257ce816c5807b8ff Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期五, 28 十月 2022 16:55:02 +0800
Subject: [PATCH] 批量添加结算消息
---
app/src/main/java/com/yeshi/makemoney/app/service/impl/goldcorn/GoldCornSettleServiceImpl.java | 23 +++++++++++++----------
1 files changed, 13 insertions(+), 10 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 bba65c7..b226e36 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
@@ -30,11 +30,13 @@
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
+import org.yeshi.utils.JsonUtil;
import org.yeshi.utils.ThreadUtil;
import javax.annotation.Resource;
import java.math.BigDecimal;
import java.math.RoundingMode;
+import java.util.ArrayList;
import java.util.Date;
import java.util.List;
import java.util.Map;
@@ -47,7 +49,7 @@
*/
@Service
public class GoldCornSettleServiceImpl implements GoldCornSettleService {
- Logger settleLogger= LoggerFactory.getLogger("settleLog");
+ Logger settleLogger = LoggerFactory.getLogger("settleLog");
@Resource
private GoldCornGetRecordService goldCornGetRecordService;
@@ -74,7 +76,7 @@
private GoldCornSettleRecordService goldCornSettleRecordService;
@Override
- public void startSettle(Date date, String remarks, SystemEnum system) throws GoldCornSettleRecordException, ParamsException {
+ public void startSettle(Date date, String remarks, SystemEnum system) throws Exception {
String day = GoldCornUtil.getFormatDay(date);
if (GoldCornUtil.convertFormatDay(day).getTime() >= GoldCornUtil.convertFormatDay(GoldCornUtil.getFormatDay(new Date())).getTime()) {
@@ -108,18 +110,19 @@
record.setSettledUserCount(0L);
goldCornSettleRecordService.add(record);
- int pageSize = 1000;
+ int pageSize = 16;
int page = (int) (count % pageSize == 0 ? count / pageSize : count / pageSize + 1);
for (int i = 0; i < page; i++) {
- List<Long> list = goldCornGetRecordService.getUidsByDay(day, i + 1, pageSize);
+ List<Long> list = goldCornGetRecordService.getUidsByDay(record.getDay(), i + 1, pageSize);
+ List<GoldCornSettleMQMsg> msgList = new ArrayList<>();
for (Long uid : list) {
- //鍔犲叆鍒癈MQ
- GoldCornSettleMQMsg msg= new GoldCornSettleMQMsg(record.getId(), uid, day, System.currentTimeMillis());
- settleLogger.info("鍔犲叆缁撶畻闃熷垪锛歿}",new Gson().toJson(msg));
- CMQManager.getInstance().addGoldCornSettleMsg(msg);
+ GoldCornSettleMQMsg msg = new GoldCornSettleMQMsg(record.getId(), uid, day, System.currentTimeMillis());
+ msgList.add(msg);
+ settleLogger.info("鍔犲叆缁撶畻闃熷垪锛歿}", new Gson().toJson(msg));
}
+ //鍔犲叆鍒癈MQ
+ CMQManager.getInstance().addGoldCornSettleMsg(msgList);
}
-
}
@@ -129,7 +132,7 @@
long cornNum = goldCornGetRecordService.getGoldCornByDay(uid, GoldCornUtil.convertFormatDay(day));
//閲戝竵鏁伴噺
GoldCornConsumeRecord record = GoldCornConsumeRecordFactory.createExchange(uid, day, (int) cornNum, rate, settleId);
- if(goldCornConsumeRecordService.get(record.getId())!=null){
+ if (goldCornConsumeRecordService.get(record.getId()) != null) {
//宸茬粡缁撶畻杩囦簡
return;
}
--
Gitblit v1.8.0