设置内转开关

xiaoyong931011

2023-04-08 4070c23c641af2f3e4d5024cc25500e711064c1e

 src/main/java/cc/mrbird/febs/mall/service/impl/MemberProfitServiceImpl.java

@@ -775,7 +775,11 @@
        if(CollUtil.isEmpty(mallMqRecords)){
            return;
        }
        DateTime dateTime = DateUtil.offsetMinute(new Date(), -5);
        for(MallMqRecord mallMqRecord : mallMqRecords){
            if(DateUtil.compare(dateTime,mallMqRecord.getCreateTime()) <= 0){
                continue;
            }
            Integer retryTimes = mallMqRecord.getRetryTimes();
            if(retryTimes <= 0){
                continue;
@@ -785,7 +789,9 @@
            mallMqRecordMapper.updateById(mallMqRecord);

            Long orderId = mallMqRecord.getOrderId();
            agentProducer.sendPerkMoneyMsg(orderId);
            if(mallMqRecord.getState() == 2){
                agentProducer.sendPerkMoneyMsg(orderId);
            }
        }
    }