From b3b3987e17a80b4fe6bc29f3835429058eb2e0fc Mon Sep 17 00:00:00 2001
From: xiaoyong931011 <15274802129@163.com>
Date: Tue, 21 Mar 2023 10:26:59 +0800
Subject: [PATCH] 后台修改
---
src/main/java/cc/mrbird/febs/mall/service/impl/MemberProfitServiceImpl.java | 42 +++++++++++++++++++++++++++++++++++++++++-
1 files changed, 41 insertions(+), 1 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 7411b14..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)
@@ -733,16 +736,53 @@
mallMemberWalletMapper.reduceTotalScoreById(teamEqualsPerkAmount, mallMemberWallet.getId());
mallMemberWalletMapper.addBalanceById(teamEqualsPerkAmount, mallMemberWallet.getId());
+//
+// mallMoneyFlowService.addMoneyFlow(
+// adminTeamEqualsPerkVo.getRtMemberId(),
+// teamEqualsPerkAmount,
+// MoneyFlowTypeEnum.TEAM_EQUALS_PERK.getValue(),
+// MallUtils.getOrderNum("TEP"),
+// FlowTypeEnum.BALANCE.getValue());
mallMoneyFlowService.addMoneyFlow(
adminTeamEqualsPerkVo.getRtMemberId(),
teamEqualsPerkAmount,
MoneyFlowTypeEnum.TEAM_EQUALS_PERK.getValue(),
MallUtils.getOrderNum("TEP"),
- FlowTypeEnum.BALANCE.getValue());
+ "平级奖励补贴",
+ "补贴额度："+mallMemberWallet.getTotalScore(),
+ adminTeamEqualsPerkVo.getMemberId(),
+ 2,
+ FlowTypeEnum.BALANCE.getValue(),
+ 1);
}
}
}
}
+
+ @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