From 00bae666d8f117abe0e8f8613df428d236c92cef Mon Sep 17 00:00:00 2001
From: xiaoyong931011 <15274802129@163.com>
Date: Mon, 20 Mar 2023 17:36:30 +0800
Subject: [PATCH] 后台修改
---
src/main/java/cc/mrbird/febs/mall/service/impl/MemberProfitServiceImpl.java | 28 ++++++++++++++++++++++++++++
1 files changed, 28 insertions(+), 0 deletions(-)
diff --git a/src/main/java/cc/mrbird/febs/mall/service/impl/MemberProfitServiceImpl.java b/src/main/java/cc/mrbird/febs/mall/service/impl/MemberProfitServiceImpl.java
index d032da7..810a8b8 100644
--- a/src/main/java/cc/mrbird/febs/mall/service/impl/MemberProfitServiceImpl.java
+++ b/src/main/java/cc/mrbird/febs/mall/service/impl/MemberProfitServiceImpl.java
@@ -12,6 +12,7 @@
import cc.mrbird.febs.mall.mapper.*;
import cc.mrbird.febs.mall.service.*;
import cc.mrbird.febs.mall.vo.AdminTeamEqualsPerkVo;
+import cc.mrbird.febs.rabbit.producter.AgentProducer;
import cn.hutool.core.collection.CollUtil;
import cn.hutool.core.date.DateField;
import cn.hutool.core.date.DateTime;
@@ -56,6 +57,8 @@
private final MallMemberWalletMapper mallMemberWalletMapper;
private final IAgentService iAgentService;
private final IMallMoneyFlowService mallMoneyFlowService;
+ private final MallMqRecordMapper mallMqRecordMapper;
+ private final AgentProducer agentProducer;
@Override
@Transactional(rollbackFor = Exception.class)
@@ -757,4 +760,29 @@
}
}
+
+ @Override
+ public void mqPerkRetryJob() {
+ /**
+ * 每次拿重试次数大于零
+ * 按ID asc排序的十条数据
+ */
+ List<MallMqRecord> mallMqRecords = mallMqRecordMapper.selectByStateLimitTen(2);
+ if(CollUtil.isEmpty(mallMqRecords)){
+ return;
+ }
+ for(MallMqRecord mallMqRecord : mallMqRecords){
+ Integer retryTimes = mallMqRecord.getRetryTimes();
+ if(retryTimes <= 0){
+ continue;
+ }
+ retryTimes = retryTimes - 1;
+ mallMqRecord.setRetryTimes(retryTimes);
+ mallMqRecordMapper.updateById(mallMqRecord);
+
+ Long orderId = mallMqRecord.getOrderId();
+ agentProducer.sendPerkMoneyMsg(orderId);
+ }
+ }
+
}
--
Gitblit v1.9.1