在单体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.";

    }

}