From 5e9d22696494cc5217247b701bb7f1c3129479a1 Mon Sep 17 00:00:00 2001 From: luozukai Date: Thu, 23 May 2019 16:01:32 +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=96=E9=87=8D=E8=AF=95=E6=9C=BA=E5=88=B6]?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../src/main/java/com/iformall/mq/MqBaseConsumer.java | 11 ++++++++--- 1 file changed, 8 insertions(+), 3 deletions(-) diff --git a/mallinkMQConsumer/src/main/java/com/iformall/mq/MqBaseConsumer.java b/mallinkMQConsumer/src/main/java/com/iformall/mq/MqBaseConsumer.java index 3dc26cf88..d9a0b3ff3 100644 --- a/mallinkMQConsumer/src/main/java/com/iformall/mq/MqBaseConsumer.java +++ b/mallinkMQConsumer/src/main/java/com/iformall/mq/MqBaseConsumer.java @@ -107,11 +107,16 @@ public class MqBaseConsumer { wxMsgRecordMapper.update(baseMsg); if(null != baseMsg){ - if(baseMsg.getDelayTimeLevel() < 4){ + if(baseMsg.getDelayTimeLevel() > 0){ log.info("消息重试,DelayTimeLevel: "+baseMsg.getDelayTimeLevel()); Thread.sleep(5000); - baseMsg.setDelayTimeLevel(baseMsg.getDelayTimeLevel()+1); - mqBaseProducer.sendMessage(baseMsg, EnumMsgMqTopic.DEFAULT.getCode(), EnumMsgMqTag.DEFAULT.getCode(), EnumMsgMqKey.DEFAULT.getCode()); + baseMsg.setDelayTimeLevel(baseMsg.getDelayTimeLevel()-1); + + if(EnumMsgRecordType.INSIDE_NOTIFY_REFUND_SUCCESS.getCode().equals(baseMsg.getMsgType())) { + // 内部消息 - 微信退款通知 + FmInsideNotifyRefundSuccessMsg msg = (FmInsideNotifyRefundSuccessMsg)JsonUtil.readValue(message,FmInsideNotifyRefundSuccessMsg.class); + mqBaseProducer.sendMessage(msg, EnumMsgMqTopic.DEFAULT.getCode(), EnumMsgMqTag.DEFAULT.getCode(), EnumMsgMqKey.DEFAULT.getCode()); + } }else{ baseMsg.setStatusMessage("重试次数超过3次"); baseMsg.setMsgStatus(EnumMsgRecordStatus.CONSUME_FAIL.getCode());