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); }