From bd4d6ee6e9e303e6fdbf05fede63dc3cd50263c3 Mon Sep 17 00:00:00 2001
From: KKSU <15274802129@163.com>
Date: Mon, 30 Dec 2024 17:33:30 +0800
Subject: [PATCH] feat(mall): 添加节点业绩累计功能

---
 src/main/java/cc/mrbird/febs/mall/service/impl/AdminMallMemberServiceImpl.java |   37 +++++++++++++++++++++++++++++++++----
 1 files changed, 33 insertions(+), 4 deletions(-)

diff --git a/src/main/java/cc/mrbird/febs/mall/service/impl/AdminMallMemberServiceImpl.java b/src/main/java/cc/mrbird/febs/mall/service/impl/AdminMallMemberServiceImpl.java
index ed6031a..3fd94d1 100644
--- a/src/main/java/cc/mrbird/febs/mall/service/impl/AdminMallMemberServiceImpl.java
+++ b/src/main/java/cc/mrbird/febs/mall/service/impl/AdminMallMemberServiceImpl.java
@@ -2,9 +2,7 @@
 
 import cc.mrbird.febs.common.entity.FebsResponse;
 import cc.mrbird.febs.common.entity.QueryRequest;
-import cc.mrbird.febs.common.enumerates.AgentLevelEnum;
-import cc.mrbird.febs.common.enumerates.MoneyFlowTypeEnum;
-import cc.mrbird.febs.common.enumerates.YesOrNoEnum;
+import cc.mrbird.febs.common.enumerates.*;
 import cc.mrbird.febs.common.exception.FebsException;
 import cc.mrbird.febs.common.utils.AppContants;
 import cc.mrbird.febs.common.utils.MallUtils;
@@ -94,6 +92,17 @@
         }
         mallMember.setAccountStatus(YesOrNoEnum.NO.getValue());
         mallMemberMapper.updateById(mallMember);
+
+        String redisKey = AppContants.APP_LOGIN_PREFIX + mallMember.getId();
+        String existToken = redisUtils.getString(redisKey);
+        if (StrUtil.isNotBlank(existToken)) {
+            Object o = redisUtils.get(existToken);
+            if (ObjectUtil.isNotEmpty(o)) {
+                redisUtils.del(existToken);
+            }
+        }
+        redisUtils.del(AppContants.APP_LOGIN_PREFIX + id);
+        redisUtils.del(AppContants.XCX_LOGIN_PHONE_PREFIX + id);
         return new FebsResponse().success();
     }
 
@@ -118,6 +127,7 @@
 
         if (type == 1) {
             mallMember.setDirector(value);
+            mallMember.setDirectorTime(DateUtil.date());
         } else if (type == 2){
             mallMember.setStoreMaster(value);
         } else {
@@ -503,11 +513,20 @@
         }
 
         Integer type = mallSystemPayDto.getType();
+        Integer flowType = 0;
+        Integer moneyType = 0;
+        String moneyTypeDec = "";
         String filedType = "";
         if (type == 1) {
             filedType = "balance";
+            flowType = FlowTypeEnum.BALANCE.getValue();
+            moneyType = RunVipMoneyFlowTypeEnum.SYS_BALANCE.getValue();
+            moneyTypeDec = RunVipMoneyFlowTypeEnum.SYS_BALANCE.getDescription();
         } else if (type == 2) {
             filedType = "score";
+            flowType = FlowTypeEnum.SCORE.getValue();
+            moneyType = RunVipMoneyFlowTypeEnum.SYS_SCORE.getValue();
+            moneyTypeDec = RunVipMoneyFlowTypeEnum.SYS_SCORE.getDescription();
         } else if (type == 3) {
             filedType = "prizeScore";
         } else {
@@ -523,7 +542,17 @@
         } else {
             iApiMallMemberWalletService.add(mallSystemPayDto.getAddBalance(), mallSystemPayDto.getId(), filedType);
         }
-        mallMoneyFlowService.addMoneyFlow(memberId, bigDecimal, MoneyFlowTypeEnum.SYSTEM.getValue(), MallUtils.getOrderNum(), type, null,2);
+        String orderNo = MallUtils.getOrderNum("SYS");
+        mallMoneyFlowService.runVipMoneyFlowAdd(
+                mallMember.getId(),
+                mallMember.getId(),
+                orderNo,
+                flowType,
+                moneyType,
+                bigDecimal,
+                StrUtil.format(moneyTypeDec,bigDecimal),
+                YesOrNoEnum.YES.getValue()
+        );
         return new FebsResponse().success();
     }
 

--
Gitblit v1.9.1