在单体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());

    }

}