新增企业微信的接口

tjx

2 天以前 b839bdc85e784e545cb5d371ed3f638747fb6a06

 src/main/java/com/gs/xky/task/PurchaseOrderSyncTask.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,96 @@
package com.gs.xky.task;

import com.gs.xky.service.PurchaseService;
import lombok.RequiredArgsConstructor;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;

import java.io.IOException;
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.Executor;
import java.util.concurrent.atomic.AtomicBoolean;

/**
 * é‡‡è´­è®¢å•åŒæ­¥å®šæ—¶ä»»åŠ¡
 */
@Component
@RequiredArgsConstructor
public class PurchaseOrderSyncTask {
    private static final Logger log = LoggerFactory.getLogger(PurchaseOrderSyncTask.class);

    private final PurchaseService purchaseService;
    private final Executor purchaseTaskExecutor; // æ³¨å…¥ä¸“用线程池

    // ç”¨äºŽæ ‡è®°ä»»åŠ¡æ˜¯å¦æ­£åœ¨æ‰§è¡Œ
    private final AtomicBoolean isRunning = new AtomicBoolean(false);

    /**
     * å®šæ—¶æ‰§è¡Œé‡‡è´­è®¢å•åŒæ­¥ä»»åŠ¡
     * æ¯å¤©12点整执行一次
     * è®¾ç½®ä¸º12点05分执行，避免与其他定时任务冲突
     * ä½¿ç”¨å¼‚步执行，防止阻塞其他定时任务
     */
    @Scheduled(cron = "0 5 12 * * ?")
    public void syncPurchaseOrders() {
        // å¦‚果任务已经在运行，则跳过本次执行
        if (!isRunning.compareAndSet(false, true)) {
            log.info("【syncPurchaseOrders】上一次任务还在执行中，跳过本次执行");
            return;
        }

        log.info("【syncPurchaseOrders】开始执行采购订单同步任务");

        // ä½¿ç”¨ä¸“用线程池执行异步任务
        CompletableFuture.runAsync(() -> {
            try {
                log.info("【syncPurchaseOrders】异步线程开始执行采购订单同步");
                purchaseService.syncPurchaseOrderDetails();
                log.info("【syncPurchaseOrders】采购订单同步任务执行成功");
            } catch (IOException e) {
                log.error("【syncPurchaseOrders】采购订单同步任务执行异常: {}", e.getMessage(), e);
            } finally {
                // æ— è®ºæˆåŠŸè¿˜æ˜¯å¤±è´¥ï¼Œéƒ½å°†è¿è¡ŒçŠ¶æ€é‡ç½®
                isRunning.set(false);
                log.info("【syncPurchaseOrders】任务状态已重置，可以接受新的任务");
            }
        }, purchaseTaskExecutor);

        // ä¸ç­‰å¾…任务完成，立即返回，避免阻塞调度线程
        log.info("【syncPurchaseOrders】采购订单同步任务已提交到异步线程执行");
    }

    /**
     * æ‰‹åŠ¨è§¦å‘采购订单同步任务
     * ç”¨äºŽç³»ç»Ÿç®¡ç†å‘˜æ‰‹åŠ¨è§¦å‘同步
     *
     * @return ä»»åŠ¡æ˜¯å¦å·²æäº¤æ‰§è¡Œ
     */
    public boolean manualSyncPurchaseOrders() {
        // å¦‚果任务已经在运行，则拒绝本次执行
        if (!isRunning.compareAndSet(false, true)) {
            log.info("【manualSyncPurchaseOrders】上一次任务还在执行中，拒绝本次执行");
            return false;
        }

        log.info("【manualSyncPurchaseOrders】手动触发采购订单同步任务");

        // ä½¿ç”¨ä¸“用线程池执行异步任务
        CompletableFuture.runAsync(() -> {
            try {
                log.info("【manualSyncPurchaseOrders】异步线程开始执行采购订单同步");
                purchaseService.syncPurchaseOrderDetails();
                log.info("【manualSyncPurchaseOrders】采购订单同步任务执行成功");
            } catch (IOException e) {
                log.error("【manualSyncPurchaseOrders】采购订单同步任务执行异常: {}", e.getMessage(), e);
            } finally {
                // æ— è®ºæˆåŠŸè¿˜æ˜¯å¤±è´¥ï¼Œéƒ½å°†è¿è¡ŒçŠ¶æ€é‡ç½®
                isRunning.set(false);
                log.info("【manualSyncPurchaseOrders】任务状态已重置，可以接受新的任务");
            }
        }, purchaseTaskExecutor);

        return true;
    }
}