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/controller/admin/goldcorn/GoldCornSettleRecordAdminController.java | 21 +++++++++++++++------
1 files changed, 15 insertions(+), 6 deletions(-)
diff --git a/app/src/main/java/com/yeshi/makemoney/app/controller/admin/goldcorn/GoldCornSettleRecordAdminController.java b/app/src/main/java/com/yeshi/makemoney/app/controller/admin/goldcorn/GoldCornSettleRecordAdminController.java
index 3a46b92..118692b 100644
--- a/app/src/main/java/com/yeshi/makemoney/app/controller/admin/goldcorn/GoldCornSettleRecordAdminController.java
+++ b/app/src/main/java/com/yeshi/makemoney/app/controller/admin/goldcorn/GoldCornSettleRecordAdminController.java
@@ -26,6 +26,7 @@
import javax.servlet.http.HttpSession;
import java.lang.reflect.Type;
import java.math.BigDecimal;
+import java.util.ArrayList;
import java.util.Date;
import java.util.List;
@@ -97,6 +98,9 @@
} catch (ParamsException e) {
e.printStackTrace();
return JsonUtil.loadFalseResult(e.getMessage());
+ } catch (Exception e) {
+ e.printStackTrace();
+ return JsonUtil.loadFalseResult(e.getMessage());
}
}
@@ -157,16 +161,21 @@
}
long count = goldCornGetRecordService.countUidsByDay(record.getDay());
- 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(record.getDay(), i + 1, pageSize);
- for (Long uid : list) {
+ try {
+ for (int i = 0; i < page; i++) {
+ List<Long> list = goldCornGetRecordService.getUidsByDay(record.getDay(), i + 1, pageSize);
+ List<GoldCornSettleMQMsg> msgList = new ArrayList<>();
+ for (Long uid : list) {
+ msgList.add(new GoldCornSettleMQMsg(record.getId(), uid, record.getDay(), System.currentTimeMillis()));
+ }
//鍔犲叆鍒癈MQ
- CMQManager.getInstance().addGoldCornSettleMsg(new GoldCornSettleMQMsg(record.getId(), uid, record.getDay(), System.currentTimeMillis()));
+ CMQManager.getInstance().addGoldCornSettleMsg(msgList);
}
+ } catch (Exception e) {
+ return JsonUtil.loadFalseResult(e.getMessage());
}
-
return JsonUtil.loadTrueResult(gson.toJson(record));
}
--
Gitblit v1.8.0