在单体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.Scheduled;
import org.springframework.stereotype.Component;
import java.time.LocalDate;
import java.time.temporal.ChronoUnit;

@Component
public class OrderNotificationScheduler {

    // 每天上午9点15分在亚洲/加尔各答时区执行
    @Scheduled(cron = "0 15 9 ? * ?", zone = "Asia/Calcutta")
    public void processDelayedNotifications() {
        System.out.println("定时任务开始执行：检查待发送通知 - " + LocalDate.now());
        // 1. 查询所有订单或需要处理的数据
        // 假设有一个方法可以获取所有待处理的订单
        // List<Order> orders = orderService.getOrdersNeedingNotification();

        // 2. 遍历数据，应用业务逻辑
        // 示例：检查订单支付日期是否已过去3天
        LocalDate currentDate = LocalDate.now();
        // 实际应用中，这里会从数据库查询订单
        // for (Order order : orders) {
        //     LocalDate orderDate = order.getPaymentDate(); // 假设有支付日期字段
        //     long daysBetween = ChronoUnit.DAYS.between(orderDate, currentDate);
        //
        //     if (daysBetween == 3) {
        //         // 3. 准备数据并调用外部API发送通知
        //         sendNotificationToExternalAPI(order);
        //     }
        // }

        // 模拟业务逻辑
        System.out.println("正在处理符合条件的订单...");
        // 假设这里调用了一个外部API
        callExternalNotificationService("订单ID: 123, 通知内容: 支付成功3天提醒");
        System.out.println("定时任务执行完毕。");
    }

    private void callExternalNotificationService(String notificationPayload) {
        // 实际中，这里会使用 RestTemplate 或 WebClient 调用外部API
        // 例如：
        // restTemplate.postForObject("http://external-api.com/notify", notificationPayload, String.class);
        System.out.println("调用外部通知服务，发送数据: " + notificationPayload);
    }
}

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.scheduling.annotation.Async; // 导入Async注解
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
import java.time.LocalDate;
import java.time.temporal.ChronoUnit;

@Component
public class OrderNotificationScheduler {

    // 每天上午9点15分在亚洲/加尔各答时区执行
    @Scheduled(cron = "0 15 9 ? * ?", zone = "Asia/Calcutta")
    @Async // 将此方法标记为异步执行，避免阻塞调度器
    public void processDelayedNotifications() {
        System.out.println("定时任务开始执行（异步）：检查待发送通知 - " + LocalDate.now() + " - Thread: " + Thread.currentThread().getName());
        // ... (业务逻辑同上)
        try {
            // 模拟耗时操作
            Thread.sleep(5000);
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
        }
        callExternalNotificationService("订单ID: 456, 通知内容: 支付成功3天提醒 (异步)");
        System.out.println("定时任务执行完毕（异步）。");
    }

    private void callExternalNotificationService(String notificationPayload) {
        System.out.println("调用外部通知服务，发送数据: " + notificationPayload + " - Thread: " + Thread.currentThread().getName());
    }
}