3 Commits 0cd670b060 ... c9d63bbbb8

Autore SHA1 Messaggio Data
  jinshihui c9d63bbbb8 优化代码 4 giorni fa
  jinshihui c2d63b1173 Merge remote-tracking branch 'origin/point_dev' into point_dev 4 giorni fa
  jinshihui 39021ada2e 优化代码 4 giorni fa

+ 2 - 1
nightFragrance-massage/src/main/java/com/ylx/massage/service/impl/ProductOrderInfoServiceImpl.java

@@ -29,6 +29,7 @@ import com.ylx.massage.mapper.ProductOrderItemMapper;
 import com.ylx.massage.mapper.ProductSkuMapper;
 import com.ylx.massage.service.*;
 import com.ylx.massage.utils.OrderNumberGenerator;
+import com.ylx.point.enums.TaskNameEnum;
 import com.ylx.point.service.IPointAccountService;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.lang3.StringUtils;
@@ -297,7 +298,7 @@ public class ProductOrderInfoServiceImpl extends ServiceImpl<ProductOrderInfoMap
             }
         }else{
             //积分支付
-            pointAccountService.deductPoints(orderInfo.getOpenId(), orderInfo.getPointsUsed(), orderInfo.getOrderNo(), "积分商品下单");
+            pointAccountService.deductPoints(orderInfo.getOpenId(), orderInfo.getPointsUsed(), orderInfo.getOrderNo(), TaskNameEnum.GOODS_CONSUME.getInfo());
             return R.ok();
         }
     }

+ 8 - 3
nightFragrance-massage/src/main/java/com/ylx/point/enums/ActivityNameEnum.java → nightFragrance-massage/src/main/java/com/ylx/point/enums/TaskNameEnum.java

@@ -1,9 +1,11 @@
 package com.ylx.point.enums;
-
 import lombok.Getter;
 
+/**
+ * 任务名称枚举
+ */
 @Getter
-public enum ActivityNameEnum {
+public enum TaskNameEnum {
 
     COMPLETE_ORDER(1, "完成订单"),
 
@@ -19,6 +21,9 @@ public enum ActivityNameEnum {
 
     GOODS_REFUND(7, "商品退款"),
 
+    /**
+     * 商城消费(用于积分下单)
+     */
     GOODS_CONSUME(8, "商城消费"),
 
     POINT_EXPIRE(9, "积分到期");
@@ -26,7 +31,7 @@ public enum ActivityNameEnum {
     private final Integer code;
     private final String info;
 
-    ActivityNameEnum(Integer code, String info) {
+    TaskNameEnum(Integer code, String info) {
         this.code = code;
         this.info = info;
     }

+ 2 - 2
nightFragrance-massage/src/main/java/com/ylx/point/service/IPointAccountService.java

@@ -24,10 +24,10 @@ public interface IPointAccountService {
      * @param openId         用户openId
      * @param pointsToDeduct 需要扣减的积分数量(正数)
      * @param bizOrderNo     业务订单号
-     * @param activityName   活动名称(如:积分商品兑换)
+     * @param taskName   任务名称(如:积分商品兑换)
      * @return Integer 变动后的余额
      */
-    Integer deductPoints(String openId, int pointsToDeduct, String bizOrderNo, String activityName);
+    Integer deductPoints(String openId, int pointsToDeduct, String bizOrderNo, String taskName);
 
     /**
      * 退款积分(用于积分商品退款)

+ 4 - 4
nightFragrance-massage/src/main/java/com/ylx/point/service/impl/PointAccountServiceImpl.java

@@ -6,7 +6,7 @@ import com.ylx.common.exception.ServiceException;
 import com.ylx.point.domain.PointActivity;
 import com.ylx.point.domain.PointActivityExpirePolicy;
 import com.ylx.point.domain.PointUserLog;
-import com.ylx.point.enums.ActivityNameEnum;
+import com.ylx.point.enums.TaskNameEnum;
 import com.ylx.point.enums.PointActivityExpirePolicyEnum;
 import com.ylx.point.mapper.PointUserLogMapper;
 import com.ylx.point.service.IPointAccountService;
@@ -84,7 +84,7 @@ public class PointAccountServiceImpl implements IPointAccountService {
      */
     @Override
     @Transactional(rollbackFor = Exception.class)
-    public Integer deductPoints(String openId, int pointsToDeduct, String bizOrderNo, String activityName) {
+    public Integer deductPoints(String openId, int pointsToDeduct, String bizOrderNo, String taskName) {
 
         // 1. 获取当前积分余额
         Integer currentBalance = getBalance(openId);
@@ -140,7 +140,7 @@ public class PointAccountServiceImpl implements IPointAccountService {
             deductLog.setOpType(2);  // 2-支出
             deductLog.setBizOrderId(bizOrderNo);
             deductLog.setSourceLogId(sourceLog.getId());  // 关联到收入记录
-            deductLog.setActivityName(activityName);
+            deductLog.setActivityName(taskName);
             deductLog.setMonth(DateUtil.format(new Date(), "yyyyMM"));
 
             // 计算扣减后的余额
@@ -187,7 +187,7 @@ public class PointAccountServiceImpl implements IPointAccountService {
         log.setBizOrderId(bizOrderNo);
         log.setSourceLogId(null);
         log.setIsExpired(0);  // 0-未过期
-        log.setActivityName(ActivityNameEnum.GOODS_REFUND.getInfo());
+        log.setActivityName(TaskNameEnum.GOODS_REFUND.getInfo());
         log.setExpireTime(null);  // 退款积分没有过期时间
         log.setMonth(DateUtil.format(new Date(), "yyyyMM"));
 

+ 2 - 3
nightFragrance-massage/src/main/java/com/ylx/point/service/impl/PointActivityServiceImpl.java

@@ -18,7 +18,7 @@ import com.ylx.point.domain.*;
 import com.ylx.point.domain.dto.*;
 import com.ylx.point.domain.vo.*;
 import com.ylx.point.enums.ActivityCompletionTaskTypeEnum;
-import com.ylx.point.enums.ActivityNameEnum;
+import com.ylx.point.enums.TaskNameEnum;
 import com.ylx.point.enums.PointActivityStatusEnum;
 import com.ylx.point.enums.PointActivityTypeEnum;
 import com.ylx.point.mapper.PointActivityMapper;
@@ -29,7 +29,6 @@ import org.springframework.transaction.annotation.Transactional;
 
 import javax.annotation.Resource;
 import java.time.*;
-import java.time.temporal.ChronoUnit;
 import java.util.*;
 import java.util.stream.Collectors;
 
@@ -586,7 +585,7 @@ public class PointActivityServiceImpl extends ServiceImpl<PointActivityMapper, P
 
         // 6. 发放积分
         try {
-            pointAccountService.addPoints(openId, rewardPoints, activityName, null, activityId, taskId, taskType, ActivityNameEnum.USER_SIGN_IN.name());
+            pointAccountService.addPoints(openId, rewardPoints, activityName, null, activityId, taskId, taskType, TaskNameEnum.USER_SIGN_IN.name());
         } catch (Exception e) {
             log.error("签到发放积分异常 openid:{}", openId, e);
             throw new ServiceException("签到成功,但积分发放失败,请联系客服");

+ 11 - 10
nightFragrance-massage/src/main/java/com/ylx/point/service/impl/PointUserActivityTaskCompletionServiceImpl.java

@@ -16,10 +16,11 @@ import com.ylx.point.domain.PointActivity;
 import com.ylx.point.domain.PointActivityTask;
 import com.ylx.point.domain.PointUserActivityTaskCompletion;
 import com.ylx.point.domain.vo.PointActivityOverviewVO;
-import com.ylx.point.enums.ActivityNameEnum;
+import com.ylx.point.enums.TaskNameEnum;
 import com.ylx.point.enums.PointActivityStatusEnum;
 import com.ylx.point.enums.PointActivityTaskTypeEnum;
 import com.ylx.point.enums.PointActivityTypeEnum;
+import com.ylx.point.enums.TaskNameEnum;
 import com.ylx.point.mapper.PointUserActivityTaskCompletionMapper;
 import com.ylx.point.service.IPointAccountService;
 import com.ylx.point.service.IPointActivityService;
@@ -172,7 +173,7 @@ public class PointUserActivityTaskCompletionServiceImpl extends ServiceImpl<Poin
         // 4. 任务校验逻辑
         if (activityTypeEnum == PointActivityTypeEnum.SIGN_TASK) {
             // 签到任务:今日未完成才可领取
-            taskName = ActivityNameEnum.USER_SIGN_IN.getInfo();
+            taskName = TaskNameEnum.USER_SIGN_IN.getInfo();
             if (isTodayCompleted(openId, activityId, taskId, taskTypeEnum.getCode())) {
                 throw new ServiceException("今日已签到,请勿重复操作");
             }
@@ -216,15 +217,15 @@ public class PointUserActivityTaskCompletionServiceImpl extends ServiceImpl<Poin
      */
     private String getTaskNameByType(PointActivityTaskTypeEnum taskType) {
         if (taskType == PointActivityTaskTypeEnum.COMPLETE_ORDER) {
-            return ActivityNameEnum.COMPLETE_ORDER.getInfo();
+            return TaskNameEnum.COMPLETE_ORDER.getInfo();
         } else if (taskType == PointActivityTaskTypeEnum.RECHARGE_TASK) {
-            return ActivityNameEnum.RECHARGE_TASK.getInfo();
+            return TaskNameEnum.RECHARGE_TASK.getInfo();
         } else if (taskType == PointActivityTaskTypeEnum.SHARE_SERVICE) {
-            return ActivityNameEnum.SHARE_ACCOUNT.getInfo();
+            return TaskNameEnum.SHARE_ACCOUNT.getInfo();
         } else if (taskType == PointActivityTaskTypeEnum.BROWLE_NEWS) {
-            return ActivityNameEnum.BROWSE_DYNAMIC.getInfo();
+            return TaskNameEnum.BROWSE_DYNAMIC.getInfo();
         } else if (taskType == PointActivityTaskTypeEnum.BROWLE_MERCHANT) {
-            return ActivityNameEnum.BROWSE_MERCHANT.getInfo();
+            return TaskNameEnum.BROWSE_MERCHANT.getInfo();
         } else {
             throw new ServiceException("不支持的任务类型: " + taskType);
         }
@@ -291,7 +292,7 @@ public class PointUserActivityTaskCompletionServiceImpl extends ServiceImpl<Poin
     /**
      * 通用优先级任务完成方法
      */
-    private void completeTaskByPriority(String openId, ActivityNameEnum activityNameEnum,
+    private void completeTaskByPriority(String openId, TaskNameEnum activityNameEnum,
                                         PointActivityTaskTypeEnum taskTypeEnum,
                                         Function<Date, Integer> countFunction) {
         // 批量查询所有有效任务
@@ -362,7 +363,7 @@ public class PointUserActivityTaskCompletionServiceImpl extends ServiceImpl<Poin
     @Override
     @Transactional(rollbackFor = Exception.class)
     public void completeOrderTaskByPriority(String openId) {
-        completeTaskByPriority(openId, ActivityNameEnum.COMPLETE_ORDER,
+        completeTaskByPriority(openId, TaskNameEnum.COMPLETE_ORDER,
                 PointActivityTaskTypeEnum.COMPLETE_ORDER,
                 new Function<Date, Integer>() {
                     @Override
@@ -375,7 +376,7 @@ public class PointUserActivityTaskCompletionServiceImpl extends ServiceImpl<Poin
     @Override
     @Transactional(rollbackFor = Exception.class)
     public void completeRechargeTaskByPriority(String openId) {
-        completeTaskByPriority(openId, ActivityNameEnum.RECHARGE_TASK,
+        completeTaskByPriority(openId, TaskNameEnum.RECHARGE_TASK,
                 PointActivityTaskTypeEnum.RECHARGE_TASK,
                 new Function<Date, Integer>() {
                     @Override