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