浏览代码

fix bug

release_toaliyun_real
zhengfangyuan 3 年前
父节点
当前提交
1f0a55893f
共有 2 个文件被更改,包括 6 次插入1 次删除
  1. +5
    -0
      mallinkMQConsumer/src/main/java/com/iformall/mq/MqBaseConsumer.java
  2. +1
    -1
      mallinkService/src/main/java/com/iformall/service/impl/WxCashOutServiceImpl.java

+ 5
- 0
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 {


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


正在加载...
取消
保存