在单体Spring Boot应用中实现定时任务与外部API调用

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.scheduling.annotation.EnableScheduling;

@SpringBootApplication
@EnableScheduling // 启用调度功能
public class MonolithicApplication {
    public static void main(String[] args) {
        SpringApplication.run(MonolithicApplication.class, args);
    }
}

import org.springframework.scheduling.annotation.Async;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;

@Component
public class PaymentNotificationScheduler {

    /**
     * 每天上午9:15（印度时区）执行一次任务。
     * Cron表达式格式：秒 分 时 日 月 周几。
     * "0 15 9 ? * ?" 表示：
     * 秒：0
     * 分：15
     * 时：9
     * 日：? (不指定具体某天，由月和周几决定)
     * 月：* (每月)
     * 周几：? (不指定具体某周几，由日决定)
     *
     * 注意：如果使用外部调度服务（如AWS EventBridge），则不应同时使用此注解。
     */
    @Scheduled(cron = "0 15 9 ? * ?", zone = "Asia/Calcutta") // 示例：印度时区每天9:15 AM
    @Async // 将此方法放入后台线程异步执行，避免阻塞主线程
    public void processDelayedNotifications() {
        // 您的业务逻辑：
        // 1. 查询所有订单，筛选出当前日期 - 订单日期 = 3天的订单。
        // 2. 根据筛选出的订单发送通知（例如，调用外部通知API）。
        System.out.println("执行延迟通知处理任务...");
        // 模拟耗时操作或外部API调用
        try {
            Thread.sleep(2000);
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
        }
        System.out.println("延迟通知处理任务完成。");
    }
}

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.scheduling.annotation.EnableAsync; // 启用异步执行
import org.springframework.scheduling.annotation.EnableScheduling;

@SpringBootApplication
@EnableScheduling
@EnableAsync // 启用异步执行
public class MonolithicApplication {
    public static void main(String[] args) {
        SpringApplication.run(MonolithicApplication.class, args);
    }
}

import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.scheduling.annotation.Async; // 仍然可以考虑异步处理

@RestController
@RequestMapping("/api/v1")
public class NotificationController {

    @PostMapping("/process-notifications")
    @Async // 异步处理API请求，避免阻塞HTTP线程
    public String triggerDelayedNotifications() {
        System.out.println("接收到外部调度请求，开始处理延迟通知...");
        // 您的业务逻辑，与上述@Scheduled方法中的逻辑类似
        // 1. 查询所有订单，筛选出当前日期 - 订单日期 = 3天的订单。
        // 2. 根据筛选出的订单发送通知。
        try {
            Thread.sleep(2000); // 模拟耗时操作
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
            return "Error: Interrupted";
        }
        System.out.println("延迟通知处理完成。");
        return "Delayed notifications processing initiated.";
    }
}