瞧瞧别人家的优惠券过期方案，那叫一个优雅！

@Service
public class BasicBatchExpireService {
    @Autowired
    private JdbcTemplate jdbcTemplate;
    
    public void expireCouponsBatch() {
        int totalUpdated = 0;
        int batchSize = 5000; // 每批处理量
        boolean hasMore = true;
        
        while (hasMore) {
            // 使用分页思想，每次选取一批未过期的优惠券ID
            String sql = "SELECT id FROM coupon WHERE status = 'ACTIVE' " +
                         "AND expire_time <= NOW() LIMIT ?";
            List<Long> couponIds = jdbcTemplate.queryForList(sql, Long.class, batchSize);
            
            if (couponIds.isEmpty()) {
                hasMore = false;
            } else {
                // 批量更新状态
                String updateSql = "UPDATE coupon SET status = 'EXPIRED' WHERE id IN (?)";
                // 注意：实际中需根据ORM框架或数据库支持来构造IN语句
                // 这里使用MyBatis等框架的批量操作更佳
                int[] updateCounts = jdbcTemplate.batchUpdate(updateSql, 
                    couponIds.stream().map(id -> new Object[]{id}).collect(Collectors.toList()));
                
                totalUpdated += couponIds.size();
                System.out.println("已过期处理: " + totalUpdated + " 张");
                
                // 每批处理后短暂休眠，让数据库喘口气
                try { Thread.sleep(100); } catch (InterruptedException e) { /* 处理异常 */ }
            }
        }
    }
}

@Service  
public class TimeSliceExpireService {
    @Autowired
    private JdbcTemplate jdbcTemplate;
    
    public void expireCouponsByTimeSlice() {
        Long lastMaxId = 0L; // 或使用最后处理时间
        int batchSize = 5000;
        boolean hasMore = true;
        
        while (hasMore) {
            // 关键：使用id > ? 替代 LIMIT offset，利用索引避免深分页
            String querySql = "SELECT id FROM coupon WHERE id > ? AND status = 'ACTIVE' " +
                              "AND expire_time <= NOW() ORDER BY id ASC LIMIT ?";
            List<Long> couponIds = jdbcTemplate.queryForList(
                querySql, Long.class, lastMaxId, batchSize);
            
            if (couponIds.isEmpty()) {
                hasMore = false;
            } else {
                // 批量更新（此处简写，实际应用PreparedStatement批量操作）
                expireBatch(couponIds);
                
                lastMaxId = couponIds.get(couponIds.size() - 1); // 移动游标
                System.out.println("进度游标移至 ID: " + lastMaxId);
                
                // 更动态的休眠：根据处理时间调整，实现“匀速”处理
                // 或者引入更复杂的流控机制
            }
        }
    }
    
    private void expireBatch(List<Long> ids) {
        // 具体的批量更新逻辑，可使用MyBatis-Plus的updateBatchById等
    }
}

// 触发器：负责发送消息
@Component
public class CouponExpireTrigger {
    @Autowired
    private RocketMQTemplate rocketMQTemplate;
    
    @Scheduled(cron = "0 0 0 * * ?") // 每天零点执行
    public void triggerExpire() {
        Long lastMaxId = 0L;
        int batchSize = 10000;
        
        while (true) {
            List<Long> expireIds = findExpiredIds(lastMaxId, batchSize);
            if (expireIds.isEmpty()) break;
            
            // 将一批ID发送到消息队列
            rocketMQTemplate.syncSend("COUPON_EXPIRE_TOPIC", expireIds);
            
            lastMaxId = expireIds.get(expireIds.size() - 1);
        }
        System.out.println("过期ID发送完毕，开始异步处理。");
    }
}

// 消费者：负责处理具体过期逻辑
@Component
@RocketMQMessageListener(topic = "COUPON_EXPIRE_TOPIC", consumerGroup = "coupon-expire-group")
public class CouponExpireConsumer implements RocketMQListener<List<Long>> {
    
    @Override
    public void onMessage(List<Long> couponIds) {
        // 在这里执行复杂的过期逻辑：更新状态、发通知、更新用户权益等
        for (Long id : couponIds) {
            processSingleCoupon(id);
        }
    }
    
    private void processSingleCoupon(Long couponId) {
        // 1. 更新优惠券状态为过期 (原子操作，使用乐观锁避免重复处理)
        // 2. 如果更新成功，进行后续操作
        // 3. 记录日志或发送事件
    }
}

// 用户使用优惠券时的校验逻辑
public Coupon validateCoupon(Long userId, Long couponId) {
    Coupon coupon = couponMapper.selectById(couponId);
    // 关键判断：状态为“活跃” AND （过期时间为空 OR 过期时间 > 当前时间）
    if (coupon.getStatus() == CouponStatus.ACTIVE 
        && (coupon.getExpireTime() == null 
            || coupon.getExpireTime().after(new Date()))) {
        return coupon; // 有效
    }
    // 如果发现已过期（根据expire_time判断），可以异步触发一个状态更新
    if (coupon.getExpireTime() != null && coupon.getExpireTime().before(new Date())) {
        // 异步调用，将状态改为过期，避免阻塞主流程
        asyncUpdateCouponStatus(couponId, CouponStatus.EXPIRED);
    }
    throw new BusinessException("优惠券无效或已过期");
}