<!-- Spring Boot Starter -->
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-web</artifactId>
    </dependency>

    <!-- Spring Data JPA -->
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-data-jpa</artifactId>
    </dependency>

    <!-- MySQL Connector -->
    <dependency>
        <groupId>mysql</groupId>
        <artifactId>mysql-connector-java</artifactId>
        <scope>runtime</scope>
    </dependency>

    <!-- ElasticJob Lite Core -->
    <dependency>
        <groupId>com.dangdang</groupId>
        <artifactId>elastic-job-lite-core</artifactId>
        <version>2.1.5</version>
    </dependency>

    <!-- ElasticJob Lite Spring Boot Starter -->
    <dependency>
        <groupId>com.dangdang</groupId>
        <artifactId>elastic-job-lite-spring-boot-starter</artifactId>
        <version>2.1.5</version>
    </dependency>

    <!-- Zookeeper Client -->
    <dependency>
        <groupId>org.apache.curator</groupId>
        <artifactId>curator-framework</artifactId>
        <version>4.2.0</version>
    </dependency>
    <dependency>
        <groupId>org.apache.curator</groupId>
        <artifactId>curator-recipes</artifactId>
        <version>4.2.0</version>
    </dependency>

server:
  port:8080

spring:
datasource:
    url:jdbc:mysql://localhost:3306/order_db?useSSL=false&serverTimezone=UTC
    username:root
    password:123456
    driver-class-name:com.mysql.cj.jdbc.Driver

jpa:
    hibernate:
      ddl-auto:update
    show-sql:true
    properties:
      hibernate:
        dialect:org.hibernate.dialect.MySQL5InnoDBDialect

elasticjob:
regCenter:
    serverLists:localhost:2181# ZooKeeper服務(wù)器地址
    namespace:elastic-job-demo   # 命名空間
jobs:
    orderStatusUpdateJob:
      cron: 0 0 * * * ?     # Cron表達(dá)式，每小時(shí)執(zhí)行一次
      shardingTotalCount:5   # 分片總數(shù)
      jobClass:com.example.job.OrderStatusUpdateJob# 任務(wù)類全限定名
      description:"更新訂單狀態(tài)"# 任務(wù)描述

package com.example;

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

@SpringBootApplication
@EnableScheduling  // 啟用定時(shí)任務(wù)調(diào)度
public class Application {
    public static void main(String[] args) {
        SpringApplication.run(Application.class, args);
    }
}

package com.example.job;

import com.dangdang.ddframe.job.api.ShardingContext;
import com.dangdang.ddframe.job.simple.api.SimpleJob;
import com.example.service.OrderService;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

/**
 * 訂單狀態(tài)更新任務(wù)類
 * 實(shí)現(xiàn)SimpleJob接口，用于定期更新訂單狀態(tài)
 */
@Component
publicclass OrderStatusUpdateJob implements SimpleJob {

    privatestaticfinal Logger log = LoggerFactory.getLogger(OrderStatusUpdateJob.class);

    @Autowired
    private OrderService orderService;  // 注入OrderService服務(wù)

    /**
     * 執(zhí)行任務(wù)的方法
     * @param context 分片上下文
     */
    @Override
    public void execute(ShardingContext context) {
        int shardingItem = context.getShardingItem();  // 獲取當(dāng)前分片項(xiàng)
        int shardingTotalCount = context.getShardingTotalCount();  // 獲取總分片數(shù)
        long maxOrderId = orderService.getMaxOrderId();  // 獲取最大訂單ID

        // 計(jì)算當(dāng)前分片需要處理的訂單范圍
        long startId = (long) shardingItem * (maxOrderId / shardingTotalCount);
        long endId = Math.min(startId + (maxOrderId / shardingTotalCount), maxOrderId);

        log.info("Processing orders from {} to {}", startId, endId);  // 記錄處理的訂單范圍
        int updatedCount = orderService.updateStatusInRange(startId, endId, "Processed");  // 更新訂單狀態(tài)

        log.info("Updated {} orders in range {} to {}", updatedCount, startId, endId);  // 記錄更新結(jié)果
    }
}

package com.example.model;

import javax.persistence.Entity;
import javax.persistence.GeneratedValue;
import javax.persistence.GenerationType;
import javax.persistence.Id;

/**
 * 訂單實(shí)體類
 * 映射到數(shù)據(jù)庫(kù)中的order表
 */
@Entity
publicclass Order {

    @Id
    @GeneratedValue(strategy = GenerationType.IDENTITY)
    private Long id;  // 訂單ID

    private String status;  // 訂單狀態(tài)

    public Long getId() {
        return id;
    }

    public void setId(Long id) {
        this.id = id;
    }

    public String getStatus() {
        return status;
    }

    public void setStatus(String status) {
        this.status = status;
    }
}

package com.example.repository;

import com.example.model.Order;
import org.springframework.data.jpa.repository.JpaRepository;
import org.springframework.data.jpa.repository.Modifying;
import org.springframework.data.jpa.repository.Query;
import org.springframework.data.repository.query.Param;
import org.springframework.transaction.annotation.Transactional;

import java.util.List;

/**
 * 訂單Repository接口
 * 提供基本的CRUD操作和自定義查詢
 */
publicinterface OrderRepository extends JpaRepository<Order, Long> {

    /**
     * 根據(jù)ID范圍查找訂單
     * @param startId 開始ID
     * @param endId 結(jié)束ID
     * @return 訂單列表
     */
    List<Order> findByIdBetween(Long startId, Long endId);

    /**
     * 根據(jù)ID范圍更新訂單狀態(tài)
     * @param startId 開始ID
     * @param endId 結(jié)束ID
     * @param newStatus 新狀態(tài)
     * @return 更新的訂單數(shù)量
     */
    @Modifying
    @Transactional
    @Query("UPDATE Order o SET o.status = :newStatus WHERE o.id BETWEEN :startId AND :endId")
    int updateStatusInRange(@Param("startId") Long startId, @Param("endId") Long endId, @Param("newStatus") String newStatus);
}

package com.example.service;

import com.example.model.Order;
import com.example.repository.OrderRepository;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.util.List;

/**
 * 訂單服務(wù)類
 * 處理訂單相關(guān)的業(yè)務(wù)邏輯
 */
@Service
publicclass OrderService {

    @Autowired
    private OrderRepository orderRepository;  // 注入OrderRepository

    /**
     * 根據(jù)ID范圍獲取訂單
     * @param startId 開始ID
     * @param endId 結(jié)束ID
     * @return 訂單列表
     */
    public List<Order> getOrdersByRange(Long startId, Long endId) {
        return orderRepository.findByIdBetween(startId, endId);
    }

    /**
     * 根據(jù)ID范圍更新訂單狀態(tài)
     * @param startId 開始ID
     * @param endId 結(jié)束ID
     * @param newStatus 新狀態(tài)
     * @return 更新的訂單數(shù)量
     */
    public int updateStatusInRange(Long startId, Long endId, String newStatus) {
        return orderRepository.updateStatusInRange(startId, endId, newStatus);
    }

    /**
     * 獲取最大訂單ID
     * @return 最大訂單ID
     */
    public long getMaxOrderId() {
        return orderRepository.findAll().stream()
                .mapToLong(Order::getId)
                .max()
                .orElse(0L);
    }
}