From 9b51a95fa8bc9b3a86108c6900e17fc55f8db467 Mon Sep 17 00:00:00 2001
From: Administrator <15274802129@163.com>
Date: Mon, 19 May 2025 17:02:07 +0800
Subject: [PATCH] refactor(vip): 优化积分和返佣计算逻辑

---
 src/main/java/cc/mrbird/febs/mall/service/impl/ScoreServiceImpl.java |   25 +++++++++++++------------
 1 files changed, 13 insertions(+), 12 deletions(-)

diff --git a/src/main/java/cc/mrbird/febs/mall/service/impl/ScoreServiceImpl.java b/src/main/java/cc/mrbird/febs/mall/service/impl/ScoreServiceImpl.java
index ed0a2b2..7393804 100644
--- a/src/main/java/cc/mrbird/febs/mall/service/impl/ScoreServiceImpl.java
+++ b/src/main/java/cc/mrbird/febs/mall/service/impl/ScoreServiceImpl.java
@@ -7,6 +7,7 @@
 import cc.mrbird.febs.common.enumerates.ScoreFlowTypeEnum;
 import cc.mrbird.febs.common.exception.FebsException;
 import cc.mrbird.febs.common.utils.LoginUserUtil;
+import cc.mrbird.febs.common.utils.MallUtils;
 import cc.mrbird.febs.mall.dto.ScoreSettingDto;
 import cc.mrbird.febs.mall.dto.signActivity.ApiSignDataDto;
 import cc.mrbird.febs.mall.dto.signActivity.ApiSignListDto;
@@ -26,6 +27,7 @@
 import cn.hutool.core.date.DateTime;
 import cn.hutool.core.date.DateUnit;
 import cn.hutool.core.date.DateUtil;
+import cn.hutool.core.util.StrUtil;
 import com.alibaba.fastjson.JSONObject;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
@@ -89,11 +91,11 @@
         long between = DateUtil.between(startTime, endTime, DateUnit.DAY);
         List<ApiGetRunDateVo> apiGetRunDateVos = generateDateList(startTime, between);
 
+        List<Integer> typeList = Arrays.asList(ScoreFlowTypeEnum.SIGN_SCORE.getValue(), ScoreFlowTypeEnum.SIGN_EXPERIENCE.getValue());
         List<MallMoneyFlow> mallMoneyFlows = mallMoneyFlowService.getBaseMapper().selectList(
                 new LambdaQueryWrapper<MallMoneyFlow>()
                         .eq(MallMoneyFlow::getMemberId, memberId)
-                        .eq(MallMoneyFlow::getFlowType, FlowTypeEnum.PRIZE_SCORE.getValue())
-                        .eq(MallMoneyFlow::getType, MoneyFlowTypeEnum.SCORE_SIGN.getValue())
+                        .in(MallMoneyFlow::getType, typeList)
                         .ge(MallMoneyFlow::getCreatedTime, startTime)
                         .le(MallMoneyFlow::getCreatedTime, endTime)
         );
@@ -166,7 +168,7 @@
         }
 
         // 若最新签到日期,与当天相差大于一天,则更新数据库(避免定时器更新失败)
-        if (DateUtil.betweenDay(mallScoreSignRecord.getSignTime(), new Date(), true) > 1 || mallScoreSignRecord.getTotalCnt() == 7) {
+        if (DateUtil.betweenDay(mallScoreSignRecord.getSignTime(), new Date(), true) > 1) {
             mallScoreSignRecord.setTotalCnt(0);
             mallScoreSignRecordMapper.updateById(mallScoreSignRecord);
         }
@@ -182,19 +184,18 @@
         // 创建分页对象,传入当前页和每页大小
         Page<MallMoneyFlow> page = new Page<>(dto.getPageNow(), dto.getPageSize());
         LambdaQueryWrapper<MallMoneyFlow> mallMoneyFlowLambdaQueryWrapper = new LambdaQueryWrapper<>();
+        List<Integer> integers = Arrays.asList(ScoreFlowTypeEnum.SIGN_SCORE.getValue(), ScoreFlowTypeEnum.SIGN_EXPERIENCE.getValue());
         mallMoneyFlowLambdaQueryWrapper
-                .select(MallMoneyFlow::getCreatedTime, MallMoneyFlow::getAmount)
+                .select(MallMoneyFlow::getCreatedTime, MallMoneyFlow::getRemark)
                 .eq(MallMoneyFlow::getMemberId, memberId)
-                .eq(MallMoneyFlow::getFlowType, FlowTypeEnum.PRIZE_SCORE.getValue())
-                .eq(MallMoneyFlow::getType, MoneyFlowTypeEnum.SCORE_SIGN.getValue())
+                .in(MallMoneyFlow::getType, integers)
                 .orderByDesc(MallMoneyFlow::getId)
         ;
-        // 调用Mapper方法获取活动分页数据
         Page<MallMoneyFlow> mallMoneyFlowPage = mallMoneyFlowService.getBaseMapper().selectPage(page, mallMoneyFlowLambdaQueryWrapper);
         if(CollUtil.isNotEmpty(mallMoneyFlowPage.getRecords())){
             mallMoneyFlowPage.getRecords().forEach(item -> {
                 ApiSignListVo apiSignListVo = new ApiSignListVo();
-                apiSignListVo.setAmount(item.getAmount());
+                apiSignListVo.setRemark(item.getRemark());
                 apiSignListVo.setCreatedTime(item.getCreatedTime());
                 apiSignListVos.add(apiSignListVo);
             });
@@ -295,9 +296,9 @@
                     member.getId(),
                     amount,
                     ScoreFlowTypeEnum.SIGN_EXPERIENCE.getValue(),
-                    mallScoreSignRecord.getId().toString(),
+                    MallUtils.getOrderNum("s"),
                     FlowTypeEnum.SCORE.getValue(),
-                    ScoreFlowTypeEnum.SIGN_EXPERIENCE.getDesc(),
+                    StrUtil.format(ScoreFlowTypeEnum.SIGN_EXPERIENCE.getDesc(),amount),
                     2);
         }
         if(mostSignIn == 2){
@@ -306,9 +307,9 @@
                     member.getId(),
                     amount,
                     ScoreFlowTypeEnum.SIGN_SCORE.getValue(),
-                    mallScoreSignRecord.getId().toString(),
+                    MallUtils.getOrderNum("s"),
                     FlowTypeEnum.PRIZE_SCORE.getValue(),
-                    ScoreFlowTypeEnum.SIGN_SCORE.getDesc(),
+                    StrUtil.format(ScoreFlowTypeEnum.SIGN_SCORE.getDesc(),amount),
                     2);
         }
 

--
Gitblit v1.9.1