From 1f0a55893fd8c43e7c232dfcad8174d3952d80f1 Mon Sep 17 00:00:00 2001 From: zhengfangyuan Date: Thu, 28 Jul 2022 12:25:39 +0800 Subject: [PATCH] fix bug --- .../src/main/java/com/iformall/mq/MqBaseConsumer.java | 5 +++++ .../java/com/iformall/service/impl/WxCashOutServiceImpl.java | 2 +- 2 files changed, 6 insertions(+), 1 deletion(-) diff --git a/mallinkMQConsumer/src/main/java/com/iformall/mq/MqBaseConsumer.java b/mallinkMQConsumer/src/main/java/com/iformall/mq/MqBaseConsumer.java index 1ceeb0376..c4b7fe85f 100644 --- a/mallinkMQConsumer/src/main/java/com/iformall/mq/MqBaseConsumer.java +++ b/mallinkMQConsumer/src/main/java/com/iformall/mq/MqBaseConsumer.java @@ -65,6 +65,11 @@ public class MqBaseConsumer { public void doMessage(String message) { log.info("received message: {}", message); + //因为数据库读写同步时间可能在毫秒,此处暂停1秒后再开始处理 + try { + Thread.sleep(1000); + } catch (InterruptedException e) { + } BaseMsg baseMsg = null; try { diff --git a/mallinkService/src/main/java/com/iformall/service/impl/WxCashOutServiceImpl.java b/mallinkService/src/main/java/com/iformall/service/impl/WxCashOutServiceImpl.java index 1607f0209..ee1d8b357 100644 --- a/mallinkService/src/main/java/com/iformall/service/impl/WxCashOutServiceImpl.java +++ b/mallinkService/src/main/java/com/iformall/service/impl/WxCashOutServiceImpl.java @@ -175,7 +175,7 @@ public class WxCashOutServiceImpl implements WxCashOutService { wxFlowService.start(map, buser.getId(), buser.getName(), buser); return new ResultData(Result.SUCCESS,"提现提交审批成功",olderCashOutNumber-record.getTotalFee()); }else { - //没有审批则发送消息 + //没有审批则发送消息,延停一段时间发消息 sendCashOutMsg(merchant, cashout.getId(),payWay); }