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/controller/admin/goldcorn/GoldCornSettleRecordAdminController.java | 33 +++++++++++++++++++++++++++++++++
1 files changed, 33 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..3a46b92 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;
@@ -42,6 +45,9 @@
@Resource
private GoldCornConsumeRecordService goldCornConsumeRecordService;
+
+ @Resource
+ private GoldCornGetRecordService goldCornGetRecordService;
private Gson gson = new GsonBuilder().registerTypeAdapter(Date.class, new JsonSerializer<Date>() {
@@ -138,4 +144,31 @@
}
+ @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 = 1000;
+ 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) {
+ //鍔犲叆鍒癈MQ
+ CMQManager.getInstance().addGoldCornSettleMsg(new GoldCornSettleMQMsg(record.getId(), uid, record.getDay(), System.currentTimeMillis()));
+ }
+ }
+
+ return JsonUtil.loadTrueResult(gson.toJson(record));
+ }
+
+
}
--
Gitblit v1.8.0