邀请功能代码

alien-entity/src/main/java/shop/alien/entity/store/ActivityInviteConfig.java

@@ -23,15 +23,6 @@ public class ActivityInviteConfig {
     @ApiModelProperty(value = "活动类型：1，邀请好友，2.其他")
     private Integer activityType;
 
-    @ApiModelProperty(value = "活动时限：1，永久有效，2.限时活动")
-    private Integer activityTimeType;
-
-    @ApiModelProperty(value = "活动开始时间")
-    private Date activityStartTime;
-
-    @ApiModelProperty(value = "活动结束时间")
-    private Date activityEndTime;
-
     @ApiModelProperty(value = "活动规则")
     private String activityRule;
 
@@ -54,7 +45,7 @@ public class ActivityInviteConfig {
     private Integer invitedRewardType;
 
     @ApiModelProperty(value = "被邀请奖励")
-    private String invitedRewardContent;
+    private Integer invitedRewardContent;
 
     @ApiModelProperty(value = "每天最大邀请人数")
     private Integer maxInviteNum;

alien-entity/src/main/java/shop/alien/entity/store/ActivityInviteLog.java

@@ -0,0 +1,69 @@
+package shop.alien.entity.store;
+
+import com.baomidou.mybatisplus.annotation.*;
+import com.fasterxml.jackson.annotation.JsonFormat;
+import com.fasterxml.jackson.annotation.JsonInclude;
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+import java.util.Date;
+
+@Data
+@JsonInclude
+@TableName("Activity_invite_log")
+@ApiModel(value = "ActivityInviteLog", description = "邀请记录表")
+public class ActivityInviteLog {
+    @ApiModelProperty(value = "主键")
+    @TableId(value = "id", type = IdType.AUTO)
+    private Integer id;
+
+    @ApiModelProperty(value = "活动ID")
+    private Integer activityId;
+
+    @ApiModelProperty(value = "邀请人用户ID")
+    private Integer inviteUserId;
+
+
+    @ApiModelProperty(value = "昵称")
+    private String nickName;
+
+    @ApiModelProperty(value = "邀请时间")
+    private Date inviteTime;
+
+    @ApiModelProperty(value = "被邀请人用户ID")
+    private Integer invitedUserId;
+
+    @ApiModelProperty(value = "邀请奖励类型：1.积分，2.其他")
+    private Integer inviteRewardType;
+
+    @ApiModelProperty(value = "邀请奖励")
+    private String inviteRewardContent;
+
+    @ApiModelProperty(value = "被邀请奖励类型：1.优惠券，2.其他")
+    private Integer invitedRewardType;
+
+    @ApiModelProperty(value = "被邀请奖励")
+    private Integer invitedRewardContent;
+
+    @ApiModelProperty(value = "创建时间")
+    @TableField(value = "created_time", fill = FieldFill.INSERT)
+    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8")
+    private Date createdTime;
+
+    @ApiModelProperty(value = "创建人ID")
+    private Integer createdUserId;
+
+    @ApiModelProperty(value = "修改时间")
+    @TableField(value = "updated_time", fill = FieldFill.INSERT_UPDATE)
+    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8")
+    private Date updatedTime;
+
+    @ApiModelProperty(value = "修改人ID")
+    private Integer updatedUserId;
+
+    @ApiModelProperty(value = "删除标记, 0:未删除, 1:已删除")
+    @TableField("delete_flag")
+    @TableLogic
+    private Integer deleteFlag;
+}

alien-entity/src/main/java/shop/alien/entity/store/LifeUser.java

@@ -113,4 +113,8 @@ public class LifeUser implements Serializable {
     @ApiModelProperty(value = "打卡广场小人图片id")
     @TableField("clock_img_id")
     private Integer clockImgId;
+
+    @ApiModelProperty(value = "个人邀请码")
+    @TableField("invite_code")
+    private String inviteCode;
 }

alien-entity/src/main/java/shop/alien/entity/store/vo/ActivityInviteInfoVo.java

@@ -0,0 +1,31 @@
+package shop.alien.entity.store.vo;
+
+import com.fasterxml.jackson.annotation.JsonInclude;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import shop.alien.entity.store.ActivityPeriod;
+import shop.alien.entity.store.ActivitySignInConfig;
+import shop.alien.entity.store.ActivitySignInReward;
+
+import java.util.List;
+
+/**
+ * @author zhangchen
+ * @version 1.0
+ * @date 2025/9/8 10:00
+ */
+@EqualsAndHashCode(callSuper = false)
+@Data
+@JsonInclude
+public class ActivityInviteInfoVo {
+
+    @ApiModelProperty(value = "邀请码")
+    private String inviteCode;
+
+    @ApiModelProperty(value = "邀请数量")
+    private Integer inviteCount;
+
+    @ApiModelProperty(value = "邀请奖励积分")
+    private Integer invitePoint;
+}

alien-entity/src/main/java/shop/alien/mapper/ActivityInviteLogMapper.java

@@ -0,0 +1,14 @@
+package shop.alien.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import org.apache.ibatis.annotations.Mapper;
+import shop.alien.entity.store.ActivityInviteConfig;
+import shop.alien.entity.store.ActivityInviteLog;
+
+/**
+ * 邀请活动记录mapper
+ */
+@Mapper
+public interface ActivityInviteLogMapper extends BaseMapper<ActivityInviteLog> {
+
+}

alien-store/src/main/java/shop/alien/store/controller/ActivityInviteConfigController.java

@@ -8,9 +8,11 @@ import org.apache.commons.lang.StringUtils;
 import org.springframework.web.bind.annotation.*;
 import shop.alien.entity.result.R;
 import shop.alien.entity.store.ActivityInviteConfig;
+import shop.alien.entity.store.ActivityInviteLog;
 import shop.alien.entity.store.ActivitySignInConfig;
 import shop.alien.entity.store.vo.ActivityConfigVo;
 import shop.alien.entity.store.vo.ActivityInviteConfigVo;
+import shop.alien.entity.store.vo.ActivityInviteInfoVo;
 import shop.alien.entity.store.vo.ActivityPeriodVo;
 import shop.alien.store.service.ActivityConfigService;
 import shop.alien.store.service.ActivityInviteConfigService;
@@ -101,4 +103,31 @@ public class ActivityInviteConfigController {
         return R.data(activityInviteConfigService.deleteInviteActivity(id));
     }
 
+    @ApiOperation("获取个人邀请码")
+    @ApiOperationSupport(order = 6)
+    @ApiImplicitParams({@ApiImplicitParam(name = "userId", value = "用户ID", dataType = "Integer", paramType = "query", required = true)})
+    @GetMapping("/getInviteInfo")
+    public R<ActivityInviteInfoVo> getInviteInfo(Integer userId) {
+        return R.data(activityInviteConfigService.getInviteInfo(userId));
+    }
+
+
+    /**
+     * web-分页查询邀请活动
+     */
+    @ApiOperation("分页查询邀请记录")
+    @ApiOperationSupport(order = 2)
+    @ApiImplicitParams({
+            @ApiImplicitParam(name = "pageNum", value = "页数", dataType = "int", paramType = "query", required = true),
+            @ApiImplicitParam(name = "pageSize", value = "页容", dataType = "int", paramType = "query", required = true),
+            @ApiImplicitParam(name = "userId", value = "用户ID", dataType = "Integer", paramType = "query")
+    })
+    @GetMapping("/getInviteActivityLogList")
+    public R<IPage<ActivityInviteLog>> getInviteActivityLogList(@RequestParam(defaultValue = "1") int pageNum,
+                                                                @RequestParam(defaultValue = "10") int pageSize,
+                                                                @RequestParam(required = false) Integer userId){
+        IPage<ActivityInviteLog> activityLogList = activityInviteConfigService.getInviteActivityLogList(pageNum, pageSize, userId);
+        return R.data(activityLogList);
+    }
+
 }

alien-store/src/main/java/shop/alien/store/controller/LifeDiscountCouponController.java

@@ -395,4 +395,23 @@ public class LifeDiscountCouponController {
         return R.data(lifeDiscountCouponService.getPlatformCouponLogList(pageNum, pageSize, userName, phone, couponId));
     }
 
+    /**
+     * 获取平台优惠券列表
+     *
+     * @param couponId 优惠券ID
+     * @param couponType 类型:(1,优惠券 2,红包 3,平台优惠券)
+     * @return List<LifeDiscountCoupon>
+     */
+    @ApiOperation("获取平台优惠券列表")
+    @ApiOperationSupport(order = 15)
+    @GetMapping("/getPlatformCoupon")
+    @ApiImplicitParams({
+            @ApiImplicitParam(name = "couponId", value = "优惠券ID", dataType = "Integer", paramType = "query"),
+            @ApiImplicitParam(name = "couponType", value = "优惠券类型", dataType = "Integer", paramType = "query")
+    })
+    public R<List<LifeDiscountCoupon>> getPlatformCoupon(@RequestParam(value = "couponId") Integer couponId,
+                                                         @RequestParam(defaultValue = "3") Integer couponType) {
+        return R.data(lifeDiscountCouponService.getPlatformCoupon(couponId, couponType));
+    }
+
 }

alien-store/src/main/java/shop/alien/store/service/ActivityInviteConfigService.java

@@ -2,11 +2,10 @@ package shop.alien.store.service;
 
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.extension.service.IService;
-import shop.alien.entity.store.ActivityInviteConfig;
-import shop.alien.entity.store.ActivitySignInConfig;
-import shop.alien.entity.store.ActivitySignInReward;
+import shop.alien.entity.store.*;
 import shop.alien.entity.store.vo.ActivityConfigVo;
 import shop.alien.entity.store.vo.ActivityInviteConfigVo;
+import shop.alien.entity.store.vo.ActivityInviteInfoVo;
 import shop.alien.entity.store.vo.ActivityPeriodVo;
 
 import java.util.List;
@@ -42,4 +41,11 @@ public interface ActivityInviteConfigService extends IService<ActivityInviteConf
      * 删除活动
      */
     boolean deleteInviteActivity(Integer id);
+
+    ActivityInviteInfoVo getInviteInfo(Integer userId);
+
+    IPage<ActivityInviteLog> getInviteActivityLogList(int pageNum, int pageSize, Integer status);
+
+    String bindInviteCode(Integer userId, String inviteCode);
+
 }

alien-store/src/main/java/shop/alien/store/service/LifeDiscountCouponService.java

@@ -151,4 +151,12 @@ public interface LifeDiscountCouponService extends IService<LifeDiscountCoupon>
      * @return IPage<LifeDiscountCouponUserWebVo>
      */
     IPage<LifeDiscountCouponUserWebVo> getPlatformCouponLogList(Integer pageNum, Integer pageSize, String userName, String phone, Integer couponId);
+
+    /**
+     * 查询平台优惠券
+     *
+     * @param couponType 优惠券类型
+     * @return List<LifeDiscountCoupon>
+     */
+    List<LifeDiscountCoupon> getPlatformCoupon(Integer couponId, Integer couponType);
 }

alien-store/src/main/java/shop/alien/store/service/impl/ActivityInviteConfigServiceImpl.java

@@ -1,5 +1,6 @@
 package shop.alien.store.service.impl;
 
+import com.alibaba.nacos.common.utils.CollectionUtils;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
@@ -9,13 +10,15 @@ import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.lang.StringUtils;
 import org.springframework.beans.BeanUtils;
 import org.springframework.stereotype.Service;
-import shop.alien.entity.store.ActivityPeriod;
-import shop.alien.entity.store.ActivitySignInConfig;
+import shop.alien.entity.store.*;
 import shop.alien.entity.store.vo.ActivityConfigVo;
 import shop.alien.entity.store.vo.ActivityInviteConfigVo;
-import shop.alien.entity.store.ActivityInviteConfig;
+import shop.alien.entity.store.vo.ActivityInviteInfoVo;
 import shop.alien.mapper.ActivityInviteConfigMapper;
+import shop.alien.mapper.ActivityInviteLogMapper;
+import shop.alien.mapper.LifeUserMapper;
 import shop.alien.store.service.ActivityInviteConfigService;
+import shop.alien.util.common.RandomCreateUtil;
 
 import java.util.ArrayList;
 import java.util.Comparator;
@@ -28,6 +31,10 @@ public class ActivityInviteConfigServiceImpl extends ServiceImpl<ActivityInviteC
 
    private final ActivityInviteConfigMapper activityInviteConfigMapper;
 
+   private final LifeUserMapper lifeUserMapper;
+
+   private final ActivityInviteLogMapper activityInviteLogMapper;
+
     @Override
     public ActivityInviteConfigVo createOrUpdateInviteActivity(ActivityInviteConfigVo activityInviteConfigVo) {
 
@@ -41,30 +48,16 @@ public class ActivityInviteConfigServiceImpl extends ServiceImpl<ActivityInviteC
 
         ActivityInviteConfig activityInviteConfig = new ActivityInviteConfig();
         if(activityInviteConfigVo.getId() == null) {
-            if(activityInviteConfigVo.getActivityTimeType()!=null && activityInviteConfigVo.getActivityTimeType() == 1){
-                //永久邀请活动，不重复
-                LambdaQueryWrapper<ActivityInviteConfig> activityInviteConfigLambdaQueryWrapper = new LambdaQueryWrapper<>();
-                activityInviteConfigLambdaQueryWrapper.eq(ActivityInviteConfig::getDeleteFlag, 0);
-                activityInviteConfigLambdaQueryWrapper.eq(ActivityInviteConfig::getActivityTimeType,1);
-                int count = activityInviteConfigMapper.selectCount(activityInviteConfigLambdaQueryWrapper);
-                if(count > 0){
-                    log.error("存在永久邀请活动，请修改。");
-                    activityInviteConfigVo = new ActivityInviteConfigVo();
-                    activityInviteConfigVo.setErrorMessage("存在永久邀请活动");
-                    return activityInviteConfigVo;
-                }
-            } else {
-                // 限时活动，校验时间段不重复
-                LambdaQueryWrapper<ActivityInviteConfig> limitedTimeActivityInviteConfigLambdaQueryWrapper = new LambdaQueryWrapper<>();
-                limitedTimeActivityInviteConfigLambdaQueryWrapper.eq(ActivityInviteConfig::getDeleteFlag, 0);
-                limitedTimeActivityInviteConfigLambdaQueryWrapper.eq(ActivityInviteConfig::getActivityTimeType,2);
-                List<ActivityInviteConfig> activityInviteConfigList = activityInviteConfigMapper.selectList(limitedTimeActivityInviteConfigLambdaQueryWrapper);
-                boolean checkResult = checkTime(activityInviteConfigList);
-                if(!checkResult){
-                    activityInviteConfigVo.setErrorMessage("方案时间重叠");
-                    return activityInviteConfigVo;
-                }
+            LambdaQueryWrapper<ActivityInviteConfig> activityInviteConfigLambdaQueryWrapper = new LambdaQueryWrapper<>();
+            activityInviteConfigLambdaQueryWrapper.eq(ActivityInviteConfig::getDeleteFlag, 0);
+            int count = activityInviteConfigMapper.selectCount(activityInviteConfigLambdaQueryWrapper);
+            if(count > 0){
+                log.error("存在有效的邀请活动。");
+                activityInviteConfigVo = new ActivityInviteConfigVo();
+                activityInviteConfigVo.setErrorMessage("存在有效的邀请活动");
+                return activityInviteConfigVo;
             }
+
             BeanUtils.copyProperties(activityInviteConfigVo, activityInviteConfig);
             int insertCount = activityInviteConfigMapper.insert(activityInviteConfig);
             if(insertCount == 0){
@@ -75,18 +68,6 @@ public class ActivityInviteConfigServiceImpl extends ServiceImpl<ActivityInviteC
             }
         } else {
             BeanUtils.copyProperties(activityInviteConfigVo, activityInviteConfig);
-            if(activityInviteConfigVo.getActivityTimeType()!=null && activityInviteConfigVo.getActivityTimeType() == 2) {
-                LambdaQueryWrapper<ActivityInviteConfig> limitedTimeUpdateActivityInviteConfigLambdaQueryWrapper = new LambdaQueryWrapper<>();
-                limitedTimeUpdateActivityInviteConfigLambdaQueryWrapper.eq(ActivityInviteConfig::getDeleteFlag, 0);
-                limitedTimeUpdateActivityInviteConfigLambdaQueryWrapper.eq(ActivityInviteConfig::getActivityTimeType,2);
-                limitedTimeUpdateActivityInviteConfigLambdaQueryWrapper.ne(ActivityInviteConfig::getId,activityInviteConfig.getId());
-                List<ActivityInviteConfig> activityInviteConfigList = activityInviteConfigMapper.selectList(limitedTimeUpdateActivityInviteConfigLambdaQueryWrapper);
-                boolean checkResult = checkTime(activityInviteConfigList);
-                if(!checkResult){
-                    activityInviteConfigVo.setErrorMessage("方案时间重叠");
-                    return activityInviteConfigVo;
-                }
-            }
             int updateCount = activityInviteConfigMapper.updateById(activityInviteConfig);
             if(updateCount == 0){
                 //更新活动配置数据失败，返回
@@ -148,23 +129,82 @@ public class ActivityInviteConfigServiceImpl extends ServiceImpl<ActivityInviteC
         return false;
     }
 
-    private boolean checkTime(List<ActivityInviteConfig> activityInviteConfigList){
-        if (activityInviteConfigList == null || activityInviteConfigList.size() <= 1) {
-            return true;
+    @Override
+    public ActivityInviteInfoVo getInviteInfo(Integer userId) {
+        LifeUser lifeUser = lifeUserMapper.selectById(userId);
+        String inviteCode = "";
+
+        if(lifeUser != null && StringUtils.isNotBlank(lifeUser.getInviteCode())){
+            inviteCode = lifeUser.getInviteCode();
+        } else{
+            int count = 1;
+            while (count <= 5) {
+                count++;
+                inviteCode = RandomCreateUtil.getRandomNStr(6);
+                LambdaQueryWrapper<LifeUser> lifeUserLambdaQueryWrapper = new LambdaQueryWrapper<>();
+                lifeUserLambdaQueryWrapper.eq(LifeUser::getInviteCode, inviteCode);
+                lifeUserLambdaQueryWrapper.eq(LifeUser::getDeleteFlag, 0);
+                int repeatCount = lifeUserMapper.selectCount(lifeUserLambdaQueryWrapper);
+                if(repeatCount == 0) {
+                    LifeUser updateLifeUser = new LifeUser();
+                    updateLifeUser.setId(userId);
+                    updateLifeUser.setInviteCode(inviteCode);
+                    lifeUserMapper.updateById(updateLifeUser);
+                    break;
+                }
+            }
+        }
+
+        LambdaQueryWrapper<ActivityInviteLog> activityInviteLogLambdaQueryWrapper = new LambdaQueryWrapper<>();
+        activityInviteLogLambdaQueryWrapper.eq(ActivityInviteLog::getInviteUserId, userId);
+        activityInviteLogLambdaQueryWrapper.eq(ActivityInviteLog::getDeleteFlag, 0);
+        List<ActivityInviteLog> activityInviteLogList = activityInviteLogMapper.selectList(activityInviteLogLambdaQueryWrapper);
+        int inviteCount = 0;
+        int invitePoint = 0;
+        if(CollectionUtils.isNotEmpty(activityInviteLogList)){
+            inviteCount = activityInviteLogList.size();
+//            invitePoint = activityInviteLogList.stream()
+//                    .mapToInt(ActivityInviteLog::getInvitePoint) // 将 Entity 流转换为 int 流
+//                    .sum();
+        }
+        ActivityInviteInfoVo activityInviteInfoVo = new ActivityInviteInfoVo();
+        activityInviteInfoVo.setInviteCode(inviteCode);
+        activityInviteInfoVo.setInviteCount(inviteCount);
+        activityInviteInfoVo.setInvitePoint(invitePoint);
+
+        return activityInviteInfoVo;
+    }
+
+    @Override
+    public IPage<ActivityInviteLog> getInviteActivityLogList(int pageNum, int pageSize, Integer userId) {
+
+        IPage<ActivityInviteLog> iPage = new Page<>(pageNum, pageSize);
+        LambdaQueryWrapper<ActivityInviteLog> activityInviteLogLambdaQueryWrapper = new LambdaQueryWrapper<>();
+        if(userId != null) {
+            activityInviteLogLambdaQueryWrapper.eq(ActivityInviteLog::getInvitedUserId, userId);
         }
+        activityInviteLogLambdaQueryWrapper.eq(ActivityInviteLog::getDeleteFlag, 0 );
+        return activityInviteLogMapper.selectPage(iPage, activityInviteLogLambdaQueryWrapper);
+    }
 
-        // 按开始时间排序
-        List<ActivityInviteConfig> sorted = new ArrayList<>(activityInviteConfigList);
-        sorted.sort(Comparator.comparing(ActivityInviteConfig::getActivityStartTime));
-        for (int i = 0; i < sorted.size() - 1; i++) {
-            ActivityInviteConfig current = sorted.get(i);
-            ActivityInviteConfig next = sorted.get(i + 1);
+    @Override
+    public String bindInviteCode(Integer userId, String inviteCode) {
+        if(StringUtils.isNotBlank(inviteCode)){
+           LifeUser originalLifeUser =  lifeUserMapper.selectById(userId);
+           if(originalLifeUser!=null && StringUtils.isNotBlank(originalLifeUser.getInviteCode())){
+               return "已经绑定邀请码";
+           } else {
+               LambdaQueryWrapper<ActivityInviteConfig> activityInviteConfigLambdaQueryWrapper = new LambdaQueryWrapper<>();
+               activityInviteConfigLambdaQueryWrapper.eq(ActivityInviteConfig::getDeleteFlag,0);
+               List<ActivityInviteConfig> activityInviteConfigList = activityInviteConfigMapper.selectList(activityInviteConfigLambdaQueryWrapper);
+               if(CollectionUtils.isNotEmpty(activityInviteConfigList)){
+                   ActivityInviteConfig activityInviteConfig = activityInviteConfigList.get(0);
+
+
+               }
+           }
 
-            // 检查重叠条件：当前结束时间 > 下一个开始时间
-            if (current.getActivityEndTime().compareTo(next.getActivityStartTime()) > 0) {
-                return false; // 存在重叠
-            }
         }
-        return true;
+        return "";
     }
 }

alien-store/src/main/java/shop/alien/store/service/impl/LifeDiscountCouponServiceImpl.java

@@ -8,6 +8,7 @@ import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import lombok.RequiredArgsConstructor;
+import org.apache.poi.util.StringUtil;
 import org.springframework.beans.BeanUtils;
 import org.springframework.beans.BeansException;
 import org.springframework.stereotype.Service;
@@ -1171,5 +1172,17 @@ public class LifeDiscountCouponServiceImpl extends ServiceImpl<LifeDiscountCoupo
                 .like(!StringUtils.isEmpty(phone), "b.user_phone", phone));
     }
 
-
+    @Override
+    public List<LifeDiscountCoupon> getPlatformCoupon(Integer couponId, Integer couponType) {
+        LambdaQueryWrapper<LifeDiscountCoupon> lifeDiscountCouponLambdaQueryWrapper = new LambdaQueryWrapper<>();
+        if(couponId != null){
+            lifeDiscountCouponLambdaQueryWrapper.eq(LifeDiscountCoupon::getId, couponId);
+        }
+        if(couponType != null){
+            lifeDiscountCouponLambdaQueryWrapper.eq(LifeDiscountCoupon::getType, couponType);
+        }
+        lifeDiscountCouponLambdaQueryWrapper.eq(LifeDiscountCoupon::getDeleteFlag, 0);
+        lifeDiscountCouponLambdaQueryWrapper.eq(LifeDiscountCoupon::getGetStatus,1);
+        return lifeDiscountCouponMapper.selectList(lifeDiscountCouponLambdaQueryWrapper);
+    }
 }