From 836e019db92b9871cba9d440c8159b35f79e1726 Mon Sep 17 00:00:00 2001
From: xiaoyong931011 <15274802129@163.com>
Date: Thu, 30 Mar 2023 09:32:42 +0800
Subject: [PATCH] 根据补贴记录，减少用户贡献值
---
src/main/java/cc/mrbird/febs/mall/service/impl/MemberProfitServiceImpl.java | 32 ++++++++++++++++++++++++++++++++
1 files changed, 32 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..b71bb06 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)
@@ -685,6 +688,8 @@
//减少补贴额度
mallMemberWalletMapper.reduceTotalScoreById(offLinePerkAmountSum, mallMemberWallet.getId());
+ iAgentService.reduceStar(mallMemberWallet.getMemberId(),offLinePerkAmountSum);
+
mallMemberWalletMapper.addBalanceById(offLinePerkAmountSum, mallMemberWallet.getId());
mallMoneyFlowService.addMoneyFlow(
@@ -732,6 +737,8 @@
//减少补贴额度
mallMemberWalletMapper.reduceTotalScoreById(teamEqualsPerkAmount, mallMemberWallet.getId());
+ iAgentService.reduceStar(mallMemberWallet.getMemberId(),teamEqualsPerkAmount);
+
mallMemberWalletMapper.addBalanceById(teamEqualsPerkAmount, mallMemberWallet.getId());
//
// mallMoneyFlowService.addMoneyFlow(
@@ -757,4 +764,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