From fe95ee4bc430e3f6eeea2db73b13ab3a2258f2e7 Mon Sep 17 00:00:00 2001 From: zhaoqiaobo <583671871@qq.com> Date: Sat, 17 Aug 2024 15:04:12 +0800 Subject: [PATCH] =?UTF-8?q?feat(all):=20=E4=BF=AE=E6=94=B9=E6=A2=A6?= =?UTF-8?q?=E5=A4=A9=E5=9B=9E=E6=8E=A8=E6=97=B6=E9=87=8D=E5=A4=8D=E6=8E=A8?= =?UTF-8?q?=E9=80=81=E8=80=81=E7=B3=BB=E7=BB=9F=E9=97=AE=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../logpm/factorydata/base/service/impl/MqServiceImpl.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/blade-service/logpm-factory-data/logpm-factory-data-base/src/main/java/com/logpm/factorydata/base/service/impl/MqServiceImpl.java b/blade-service/logpm-factory-data/logpm-factory-data-base/src/main/java/com/logpm/factorydata/base/service/impl/MqServiceImpl.java index 92a77f6ea..a54be3907 100644 --- a/blade-service/logpm-factory-data/logpm-factory-data-base/src/main/java/com/logpm/factorydata/base/service/impl/MqServiceImpl.java +++ b/blade-service/logpm-factory-data/logpm-factory-data-base/src/main/java/com/logpm/factorydata/base/service/impl/MqServiceImpl.java @@ -4,6 +4,7 @@ import cn.hutool.core.exceptions.ExceptionUtil; import cn.hutool.core.util.CharsetUtil; import cn.hutool.core.util.IdUtil; import cn.hutool.core.util.StrUtil; +import cn.hutool.json.JSONConfig; import cn.hutool.json.JSONUtil; import com.logpm.factorydata.base.constant.MqConstants; import com.logpm.factorydata.base.entity.FailMsgEntity; @@ -57,7 +58,8 @@ public class MqServiceImpl implements MqService { @Override public Boolean sendMsg(String exchange, String routingKey, Object msg, int delay) { // 1.获取消息内容，如果非字符串将其序列化 - String jsonMsg = (msg instanceof String) ? (String) msg : JSONUtil.toJsonStr(msg); + JSONConfig jsonConfig = JSONConfig.create().setDateFormat("yyyy-MM-dd HH:mm:ss"); + String jsonMsg = (msg instanceof String) ? (String) msg : JSONUtil.toJsonStr(msg,jsonConfig); String msgId = IdUtil.simpleUUID(); log.info("消息发送！exchange = {}, routingKey = {}, msg = {}, msgId = {}", exchange, routingKey, jsonMsg, msgId); // 2.全局唯一的消息ID，需要封装到CorrelationData中