用户积分系统设计：积分有效性维护与提醒功能全方案

-- 积分有效期规则配置表CREATE TABLE point_valid_rule (    id BIGINT AUTO_INCREMENT PRIMARY KEY,    point_type INT NOT NULL COMMENT '积分类型（1-消费积分，2-签到积分，3-活动积分）',    valid_type INT NOT NULL COMMENT '有效期类型（1-固定天数，2-固定日期，3-动态关联活动）',    valid_value INT NOT NULL COMMENT '有效期值（如valid_type=1时，值为365表示365天）',    activity_id BIGINT DEFAULT NULL COMMENT '关联活动ID（valid_type=3时必填）',    status TINYINT DEFAULT 1 COMMENT '状态（1-生效，0-失效）',    create_time DATETIME DEFAULT CURRENT_TIMESTAMP,    update_time DATETIME DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,    UNIQUE KEY uk_type_status (point_type, status) -- 同一积分类型仅生效一条规则) ENGINE=InnoDB COMMENT '积分有效期规则配置表';

-- 1. 用户当前积分余额表（高频查询，如用户查看积分余额）CREATE TABLE user_point_balance (    user_id BIGINT NOT NULL COMMENT '用户ID',    total_available INT DEFAULT 0 COMMENT '当前可用积分',    total_frozen INT DEFAULT 0 COMMENT '当前冻结积分（如退款中）',    total_expired INT DEFAULT 0 COMMENT '历史累计过期积分',    last_update_time DATETIME DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,    PRIMARY KEY (user_id)) ENGINE=InnoDB COMMENT '用户积分余额表';-- 2. 积分明细记录表（追溯每笔积分的生命周期）CREATE TABLE user_point_detail (    id BIGINT AUTO_INCREMENT PRIMARY KEY,    user_id BIGINT NOT NULL COMMENT '用户ID',    point_type INT NOT NULL COMMENT '积分类型（1-消费，2-签到，3-活动）',    point_amount INT NOT NULL COMMENT '积分数量（正数-获取，负数-消耗）',    source_type INT NOT NULL COMMENT '积分来源（1-购物，2-签到，3-活动，4-兑换，5-过期扣减）',    source_id BIGINT DEFAULT NULL COMMENT '关联业务ID（如购物订单ID、活动ID）',    valid_start_time DATETIME NOT NULL COMMENT '积分生效时间',    valid_end_time DATETIME NOT NULL COMMENT '积分过期时间（根据规则计算）',    status TINYINT NOT NULL COMMENT '状态（1-可用，2-冻结，3-已消耗，4-已过期）',    create_time DATETIME DEFAULT CURRENT_TIMESTAMP COMMENT '记录创建时间',    update_time DATETIME DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,    INDEX idx_user_valid (user_id, valid_end_time, status) -- 用于查询用户即将过期的积分) ENGINE=InnoDB COMMENT '用户积分明细记录表';

/** * 生成积分并计算有效期 * @param userId 用户ID * @param pointType 积分类型（1-消费，2-签到） * @param amount 积分数量（正数） * @param sourceType 来源类型（1-购物） * @param sourceId 关联业务ID（如订单ID） */public void generatePoint(Long userId, Integer pointType, Integer amount, Integer sourceType, Long sourceId) {    // 1. 查询该积分类型的生效规则    PointValidRule rule = pointValidRuleMapper.getValidRuleByType(pointType);    if (rule == null) {        throw new BusinessException("积分类型[" + pointType + "]无生效的有效期规则");    }    // 2. 计算积分生效时间与过期时间    LocalDateTime validStartTime = LocalDateTime.now();    LocalDateTime validEndTime = calculateValidEndTime(rule, validStartTime);    // 3. 插入积分明细记录（状态：可用）    UserPointDetail detail = new UserPointDetail();    detail.setUserId(userId);    detail.setPointType(pointType);    detail.setPointAmount(amount);    detail.setSourceType(sourceType);    detail.setSourceId(sourceId);    detail.setValidStartTime(validStartTime);    detail.setValidEndTime(validEndTime);    detail.setStatus(1); // 1-可用    pointDetailMapper.insert(detail);    // 4. 更新用户当前积分余额（使用乐观锁避免并发问题）    int rows = pointBalanceMapper.increaseAvailable(userId, amount);    if (rows == 0) {        // 若余额记录不存在，初始化记录        UserPointBalance balance = new UserPointBalance();        balance.setUserId(userId);        balance.setTotalAvailable(amount);        pointBalanceMapper.insert(balance);    }}/** * 根据规则计算积分过期时间 */private LocalDateTime calculateValidEndTime(PointValidRule rule, LocalDateTime startTime) {    switch (rule.getValidType()) {        case 1: // 固定天数            return startTime.plusDays(rule.getValidValue());        case 2: // 固定日期（如2024-12-31）            return LocalDateTime.of(                Integer.parseInt(rule.getValidValue() / 10000), // 年（如20241231→2024）                Integer.parseInt((rule.getValidValue() / 100) % 100), // 月（20241231→12）                Integer.parseInt(rule.getValidValue() % 100), // 日（20241231→31）                23, 59, 59            );        case 3: // 关联活动（活动结束后N天）            Activity activity = activityMapper.getById(rule.getActivityId());            return activity.getEndTime().plusDays(rule.getValidValue());        default:            throw new BusinessException("不支持的有效期类型：" + rule.getValidType());    }}

/** * 积分过期处理定时任务 */@Componentpublic class PointExpireJob {    @Autowired    private UserPointDetailMapper detailMapper;    @Autowired    private UserPointBalanceMapper balanceMapper;    @Autowired    private SqlSessionTemplate sqlSessionTemplate; // 用于手动控制事务    @Scheduled(cron = "0 0 2 * * ?") // 每日凌晨2点执行    public void execute() {        // 1. 定义时间范围：处理截至昨日23:59:59已过期的积分        LocalDateTime expireTime = LocalDate.now().atStartOfDay(); // 今日0点        LocalDateTime startTime = LocalDateTime.of(2000, 1, 1, 0, 0, 0); // 历史所有        // 2. 分页查询待过期的积分明细（避免一次性查询过多数据，导致内存溢出）        int pageNum = 1;        int pageSize = 1000;        while (true) {            Page<UserPointDetail> page = new Page<>(pageNum, pageSize);            List<UserPointDetail> expireDetails = detailMapper.selectExpireList(                page, startTime, expireTime, 1 // status=1（可用）            );            if (CollectionUtils.isEmpty(expireDetails)) {                break; // 无数据，退出循环            }            // 3. 批量处理过期积分（手动控制事务，确保原子性）            SqlSession session = sqlSessionTemplate.getSqlSessionFactory().openSession(ExecutorType.BATCH, false);            try {                UserPointDetailMapper batchDetailMapper = session.getMapper(UserPointDetailMapper.class);                UserPointBalanceMapper batchBalanceMapper = session.getMapper(UserPointBalanceMapper.class);                // 按用户分组，统计每个用户的过期积分总数（避免同一用户多次扣减）                Map<Long, Integer> userExpireMap = expireDetails.stream()                    .collect(Collectors.groupingBy(                        UserPointDetail::getUserId,                        Collectors.summingInt(UserPointDetail::getPointAmount)                    ));                // 4. 1：更新积分明细状态为“已过期”                for (UserPointDetail detail : expireDetails) {                    detail.setStatus(4); // 4-已过期                    detail.setUpdateTime(LocalDateTime.now());                    batchDetailMapper.updateStatusById(detail);                }                // 4. 2：扣减用户可用积分，累计过期积分                for (Map.Entry<Long, Integer> entry : userExpireMap.entrySet()) {                    Long userId = entry.getKey();                    Integer expireAmount = entry.getValue();                    // 扣减可用积分（乐观锁：where total_available >= expireAmount，避免超扣）                    int rows = batchBalanceMapper.decreaseAvailableAndIncreaseExpired(                        userId, expireAmount, expireAmount                    );                    if (rows == 0) {                        throw new BusinessException("用户[" + userId + "]可用积分不足，过期处理失败");                    }                }                session.commit(); // 批量提交事务            } catch (Exception e) {                session.rollback(); // 异常回滚                log.error("积分过期处理失败，pageNum={}", pageNum, e);            } finally {                session.close();            }            pageNum++;        }        log.info("积分过期处理完成，处理时间：{}", LocalDateTime.now());    }}

// 1. 定义积分变动事件@Datapublic class PointChangeEvent {    private Long userId; // 用户ID    private String userPhone; // 用户手机号（用于短信）    private String userPushToken; // APP推送Token    private Integer changeType; // 变动类型（1-到账，2-消耗，3-冻结，4-解冻）    private Integer pointAmount; // 变动积分数量    private LocalDateTime validEndTime; // 积分过期时间（仅到账时非空）    private String bizDesc; // 业务描述（如“购物订单12345得100积分”）}// 2. 积分变动时发送事件@Servicepublic class PointEventService {    @Autowired    private StreamBridge streamBridge;    // 积分到账时发送事件    public void sendPointArriveEvent(UserPointDetail detail, User user) {        PointChangeEvent event = new PointChangeEvent();        event.setUserId(detail.getUserId());        event.setUserPhone(user.getPhone());        event.setUserPushToken(user.getPushToken());        event.setChangeType(1); // 1-到账        event.setPointAmount(detail.getPointAmount());        event.setValidEndTime(detail.getValidEndTime());        event.setBizDesc(getBizDesc(detail.getSourceType(), detail.getSourceId()));        // 发送到消息队列（主题：point-change-event）        streamBridge.send("pointChangeOutput", event);    }    // 生成业务描述（如“购物订单12345得100积分”）    private String getBizDesc(Integer sourceType, Long sourceId) {        switch (sourceType) {            case 1: return "购物订单" + sourceId + "获得积分";            case 2: return "每日签到获得积分";            case 3: return "活动" + sourceId + "获得积分";            default: return "积分变动";        }    }}// 3. 消费事件，发送提醒@Servicepublic class PointRemindConsumer {    @Autowired    private AppPushService appPushService; // APP推送服务    @Autowired    private SmsService smsService; // 短信服务    @Autowired    private MessageService messageService; // 站内信服务    @Autowired    private UserPreferenceMapper preferenceMapper; // 用户提醒偏好配置    @Bean    public Consumer<PointChangeEvent> pointChangeConsumer() {        return event -> {            // 1. 查询用户提醒偏好（如用户仅开启APP推送，关闭短信）            UserRemindPreference preference = preferenceMapper.getByUserId(event.getUserId());            if (preference == null) {                preference = new UserRemindPreference(); // 默认配置：开启APP+站内信                preference.setAppPush(1);                preference.setSms(0);                preference.setInnerMessage(1);            }            // 2. 构建提醒内容            String title = getRemindTitle(event.getChangeType());            String content = getRemindContent(event);            // 3. 按偏好发送提醒            if (preference.getAppPush() == 1 && StringUtils.isNotBlank(event.getUserPushToken())) {                appPushService.sendPush(event.getUserPushToken(), title, content);            }            if (preference.getSms() == 1 && StringUtils.isNotBlank(event.getUserPhone())) {                smsService.sendSms(event.getUserPhone(), "【XX平台】" + content);            }            if (preference.getInnerMessage() == 1) {                messageService.sendInnerMessage(event.getUserId(), title, content);            }        };    }    // 构建提醒标题    private String getRemindTitle(Integer changeType) {        switch (changeType) {            case 1: return "积分到账通知";            case 2: return "积分消耗通知";            case 3: return "积分冻结通知";            case 4: return "积分解冻通知";            default: return "积分变动通知";        }    }    // 构建提醒内容（个性化，包含关键信息）    private String getRemindContent(PointChangeEvent event) {        switch (event.getChangeType()) {            case 1: // 积分到账                return String.format(                    "%s，共%d积分，该积分将于%s过期，请及时使用～",                    event.getBizDesc(),                    event.getPointAmount(),                    event.getValidEndTime().format(DateTimeFormatter.ofPattern("yyyy-MM-dd"))                );            case 2: // 积分消耗                return String.format("您已消耗%d积分%s，当前可用积分请在APP内查看。",                    event.getPointAmount(), event.getBizDesc());            default:                return event.getBizDesc() + "，积分变动：" + event.getPointAmount() + "。";        }    }}

/** * 积分即将过期提醒定时任务（每日早9点执行） */@Componentpublic class PointWillExpireRemindJob {    @Autowired    private UserPointDetailMapper detailMapper;    @Autowired    private UserMapper userMapper;    @Autowired    private AppPushService appPushService;    @Autowired    private MessageService messageService;    @Scheduled(cron = "0 0 9 * * ?") // 每日早9点执行    public void execute() {        // 1. 定义即将过期的时间范围：未来3天内过期（今日~3天后）        LocalDateTime now = LocalDateTime.now();        LocalDateTime threeDaysLater = now.plusDays(3);        // 2. 分页查询符合条件的积分明细（status=1-可用，有效期在范围内）        int pageNum = 1;        int pageSize = 1000;        while (true) {            Page<UserPointDetail> page = new Page<>(pageNum, pageSize);            List<UserPointDetail> willExpireDetails = detailMapper.selectWillExpireList(                page, now, threeDaysLater, 1            );            if (CollectionUtils.isEmpty(willExpireDetails)) {                break;            }            // 3. 按用户分组，统计每个用户的即将过期积分（避免同一用户多次提醒）            Map<Long, Map<String, Object>> userRemindMap = willExpireDetails.stream()                .collect(Collectors.groupingBy(                    UserPointDetail::getUserId,                    Collectors.collectingAndThen(                        Collectors.toList(),                        list -> {                            Map<String, Object> data = new HashMap<>();                            // 总即将过期积分                            int totalAmount = list.stream().mapToInt(UserPointDetail::getPointAmount).sum();                            // 最早过期时间                            LocalDateTime earliestExpire = list.stream()                                .map(UserPointDetail::getValidEndTime)                                .min(LocalDateTime::compareTo)                                .orElse(threeDaysLater);                            data.put("totalAmount", totalAmount);                            data.put("earliestExpire", earliestExpire);                            return data;                        }                    )                ));            // 4. 批量发送提醒            for (Map.Entry<Long, Map<String, Object>> entry : userRemindMap.entrySet()) {                Long userId = entry.getKey();                Map<String, Object> data = entry.getValue();                int totalAmount = (int) data.get("totalAmount");                LocalDateTime earliestExpire = (LocalDateTime) data.get("earliestExpire");                User user = userMapper.getById(userId);                if (user == null) {                    continue;                }                // 构建提醒内容                String title = "积分即将过期提醒";                String content = String.format(                    "您有%d积分将于%s过期，请尽快前往APP【积分商城】兑换商品或抵现消费～",                    totalAmount,                    earliestExpire.format(DateTimeFormatter.ofPattern("yyyy-MM-dd"))                );                // 发送提醒（按用户偏好）                if (StringUtils.isNotBlank(user.getPushToken())) {                    appPushService.sendPush(user.getPushToken(), title, content);                }                messageService.sendInnerMessage(userId, title, content);            }            pageNum++;        }        log.info("积分即将过期提醒完成，处理时间：{}", LocalDateTime.now());    }}