其他组件速览

@Component
public class ReportJobs {

    /**
     * 简单定时任务：每天凌晨 2 点执行
     */
    @Scheduled(cron = "0 0 2 * * ?")
    public void generateDailyReport() {
        // 业务逻辑
    }

    /**
     * 分片任务：按 sharding 参数并行处理
     */
    @DistributedJob(name = "batch-process", shardingCount = 4)
    public ProcessResult processBatch(JobContext context) {
        int shardIndex = context.getShardingIndex();
        int shardCount = context.getShardingCount();
        // 每个人分片处理不同数据段
        return ProcessResult.success();
    }
}

@Service
public class OssService {

    @Autowired
    private OSSClient ossClient;

    /**
     * 上传文件
     */
    public String upload(String bucketName, String objectName, InputStream stream) {
        ossClient.putObject(bucketName, objectName, stream);
        return String.format("https://%s.%s/%s",
                bucketName, "oss-cn-hangzhou.aliyuncs.com", objectName);
    }

    /**
     * 生成带签名的临时访问 URL（有效期 1 小时）
     */
    public String generatePresignedUrl(String bucketName, String objectName) {
        Date expiration = new Date(System.currentTimeMillis() + 3600 * 1000);
        URL url = ossClient.generatePresignedUrl(bucketName, objectName, expiration);
        return url.toString();
    }

    /**
     * 下载文件
     */
    public void download(String bucketName, String objectName, OutputStream output) {
        OSSObject ossObject = ossClient.getObject(bucketName, objectName);
        ossObject.getObjectContent().transferTo(output);
    }
}

@Service
public class SmsService {

    @Autowired
    private ISmsService smsService;

    /**
     * 发送验证码
     */
    public void sendVerifyCode(String phoneNumber, String code) {
        smsService.send(phoneNumber, "SMS_123456789",
                Map.of("code", code));
    }

    /**
     * 批量发送通知
     */
    public void sendBatchNotice(List<String> phoneNumbers, String content) {
        // 批量发送，底层自动分批
        for (String phone : phoneNumbers) {
            smsService.send(phone, "SMS_987654321",
                    Map.of("content", content));
        }
    }
}