From 5d5b7c2328eed45fd84cb5f45c3fe43ff6e56b08 Mon Sep 17 00:00:00 2001 From: luozukai Date: Tue, 25 Jun 2019 23:14:13 +0800 Subject: [PATCH] =?UTF-8?q?[=E6=B6=88=E6=81=AF][=E4=BF=AE=E6=94=B9][?= =?UTF-8?q?=E4=BC=98=E5=8C=96msg=5Frecord=E8=A1=A8=E6=9B=B4=E6=96=B0?= =?UTF-8?q?=E6=AD=BB=E9=94=81=E9=97=AE=E9=A2=98]?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/com/iformall/mq/impl/RabbitMqMessageProducer.java | 4 +--- .../com/iformall/service/impl/WxMsgRecordServiceImpl.java | 2 +- 2 files changed, 2 insertions(+), 4 deletions(-) diff --git a/mallinkService/src/main/java/com/iformall/mq/impl/RabbitMqMessageProducer.java b/mallinkService/src/main/java/com/iformall/mq/impl/RabbitMqMessageProducer.java index f9dd20ffd..af7cd9852 100644 --- a/mallinkService/src/main/java/com/iformall/mq/impl/RabbitMqMessageProducer.java +++ b/mallinkService/src/main/java/com/iformall/mq/impl/RabbitMqMessageProducer.java @@ -37,12 +37,10 @@ public class RabbitMqMessageProducer implements MqBaseProducer { public void sendMessage(BaseMsg data, String topic, String tags, String keys) { try { data.setUuid(UUID.randomUUID().toString()); - wxMsgRecordService.save(data); rabbitTemplate.convertAndSend(topic, JsonUtil.obj2Json(data)); - data.setMsgStatus(EnumMsgRecordStatus.SEND_SUCC.getCode()); - wxMsgRecordMapper.update(data); + wxMsgRecordService.save(data); } catch (Exception e) { log.error("RabbitMqMessageProducer: Send Message Error ", e); } diff --git a/mallinkService/src/main/java/com/iformall/service/impl/WxMsgRecordServiceImpl.java b/mallinkService/src/main/java/com/iformall/service/impl/WxMsgRecordServiceImpl.java index 714ff5b00..658cbde2d 100644 --- a/mallinkService/src/main/java/com/iformall/service/impl/WxMsgRecordServiceImpl.java +++ b/mallinkService/src/main/java/com/iformall/service/impl/WxMsgRecordServiceImpl.java @@ -46,7 +46,7 @@ public class WxMsgRecordServiceImpl implements WxMsgRecordService { msgRecord.setUuid(data.getUuid()); msgRecord.setId(idWorker.nextId()); msgRecord.setMsgJson(JsonUtil.obj2Json(data)); - msgRecord.setMsgStatus(EnumMsgRecordStatus.DEFAULT.getCode()); + msgRecord.setMsgStatus(EnumMsgRecordStatus.SEND_SUCC.getCode()); wxMsgRecordMapper.save(msgRecord); }