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