From 82fbbf24939e150ee3cef90dc0dd843c9897a7e6 Mon Sep 17 00:00:00 2001
From: kimi <kimi42345@gmail.com>
Date: 星期六, 23 五月 2020 12:27:13 +0800
Subject: [PATCH] 添加 log前 去除bak文件前的备份
---
src/main/java/com/highdatas/mdm/util/pool/MqMessage.java | 5 ++++-
1 files changed, 4 insertions(+), 1 deletions(-)
diff --git a/src/main/java/com/highdatas/mdm/util/pool/MqMessage.java b/src/main/java/com/highdatas/mdm/util/pool/MqMessage.java
index b05dc65..42f2ea0 100644
--- a/src/main/java/com/highdatas/mdm/util/pool/MqMessage.java
+++ b/src/main/java/com/highdatas/mdm/util/pool/MqMessage.java
@@ -109,6 +109,7 @@
object.fluentPut("pages", page.getPageCount());
object.fluentPut("current", page.getPageNo());
object.fluentPut("records", maps);
+ mqEntity.getMsgBody().setTotal(Long.valueOf(page.getRecordCount()).intValue());
content = JSONObject.toJSONString(object);
} else {
Result result = DbUtils.masterDataService.selectListByPageByVersion(user, maintain.getTableName(), fieldList, filter, pageNo.get(), pageSize.get(), maintain.getVersion(), false);
@@ -121,6 +122,7 @@
object.fluentPut("current", grid.get("current"));
object.fluentPut("records", grid.get("record"));
+ mqEntity.getMsgBody().setTotal(grid.getInteger("total"));
content = JSONObject.toJSONString(object);
}
@@ -164,6 +166,7 @@
private void sendOneViewPackage(AtomicInteger pageNo, AtomicInteger pageSize, SysView sysView) throws Exception {
Result viewData = DbUtils.viewService.getViewData(sysView, pageNo.get(), pageSize.get());
JSONObject object = (JSONObject) viewData.getData();
+ mqEntity.getMsgBody().setTotal(object.getInteger("total"));
String content = JSONObject.toJSONString(object);
sendMqBody(pageSize.get(), content);
}
@@ -190,7 +193,7 @@
// String mqBody = content;
MqEntity.MsgBodyBean msgBody = mqEntity.getMsgBody();
msgBody.setData(mqBody);
- msgBody.setTotal(pageSize);
+
mqEntity.setMsgBody(msgBody);
// Thread.sleep(1000 * 60 * 3);
mqEntity.send2Mq();
--
Gitblit v1.8.0