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 | 42 ++++++++++++++++++++++++++++++++++++++++++
1 files changed, 42 insertions(+), 0 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 0fddf80..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
@@ -2,12 +2,15 @@
import com.google.gson.*;
import com.ks.lib.common.exception.ParamsException;
+import com.yeshi.makemoney.app.dto.mq.GoldCornSettleMQMsg;
import com.yeshi.makemoney.app.entity.goldcorn.GoldCornConsumeType;
import com.yeshi.makemoney.app.exception.goldcorn.GoldCornSettleRecordException;
import com.yeshi.makemoney.app.service.inter.goldcorn.GoldCornConsumeRecordService;
+import com.yeshi.makemoney.app.service.inter.goldcorn.GoldCornGetRecordService;
import com.yeshi.makemoney.app.service.inter.goldcorn.GoldCornSettleService;
import com.yeshi.makemoney.app.service.query.goldcorn.GoldCornConsumeRecordQuery;
import com.yeshi.makemoney.app.utils.goldcorn.GoldCornUtil;
+import com.yeshi.makemoney.app.utils.mq.CMQManager;
import com.yeshi.makemoney.app.vo.AcceptAdminData;
import net.sf.json.JSONArray;
import net.sf.json.JSONObject;
@@ -23,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;
@@ -42,6 +46,9 @@
@Resource
private GoldCornConsumeRecordService goldCornConsumeRecordService;
+
+ @Resource
+ private GoldCornGetRecordService goldCornGetRecordService;
private Gson gson = new GsonBuilder().registerTypeAdapter(Date.class, new JsonSerializer<Date>() {
@@ -91,6 +98,9 @@
} catch (ParamsException e) {
e.printStackTrace();
return JsonUtil.loadFalseResult(e.getMessage());
+ } catch (Exception e) {
+ e.printStackTrace();
+ return JsonUtil.loadFalseResult(e.getMessage());
}
}
@@ -138,4 +148,36 @@
}
+ @ResponseBody
+ @RequestMapping("retry")
+ public String retry(String id, AcceptAdminData acceptAdminData) {
+ if (id == null) {
+ return JsonUtil.loadFalseResult("ID涓嶈兘涓虹┖");
+ }
+
+ GoldCornSettleRecord record = goldCornSettleRecordService.get(id);
+ if (record == null) {
+ return JsonUtil.loadFalseResult("璁板綍涓嶅瓨鍦�");
+ }
+
+ long count = goldCornGetRecordService.countUidsByDay(record.getDay());
+ int pageSize = 16;
+ int page = (int) (count % pageSize == 0 ? count / pageSize : count / pageSize + 1);
+ 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(msgList);
+ }
+ } catch (Exception e) {
+ return JsonUtil.loadFalseResult(e.getMessage());
+ }
+ return JsonUtil.loadTrueResult(gson.toJson(record));
+ }
+
+
}
--
Gitblit v1.8.0