增加接口定时任务入口

czt

2025-06-05 8460849733838c9e84d1016c51f5a0e6875d0a78

增加接口定时任务入口

 igds-dzhwk-inte/src/main/java/com/fzzy/igds/dzhwk/v1/timer/JobV1JcService.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,61 @@
package com.fzzy.igds.dzhwk.v1.timer;

import com.fzzy.igds.dzhwk.v1.ApiV1Server;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.time.DateUtils;
import org.springframework.stereotype.Service;
import javax.annotation.Resource;
import java.util.Date;

/**
 * @Description åŸºç¡€ä¿¡æ¯-定时获取任务入口，默认每天获取一次
 * @Author CZT
 * @Date 2025/6/5 19:53
 */
@Slf4j
@Service("JobMwJcService")
public class JobV1JcService {

    @Resource
    private ApiV1Server apiV1Server;

    /**
     * å®šæ—¶èŽ·å–业务信息
     *
     * @param startTimeStr èµ·å§‹æ—¶é—´å­—符串
     */
    public void timer(String startTimeStr) {

        try {
            log.info("===========================系统定时获取基础信息======================");

            Date startTime = DateUtils.parseDate(startTimeStr, "yyyy-MM-dd HH:mm:ss");
            Date endTime = new Date();

            log.info("===========================系统定时获取仓储单位数据======================");
            //获取仓储单位数据
            apiV1Server.pullData("1001", startTime, endTime);

            log.info("===========================系统定时获取库区数据======================");
            //获取库区数据
            apiV1Server.pullData("1002", startTime, endTime);

            log.info("===========================系统定时获取仓房数据======================");
            //获取仓房数据
            apiV1Server.pullData("1003", startTime, endTime);

            log.info("===========================系统定时获取廒间数据======================");
            //获取廒间数据
            apiV1Server.pullData("1004", startTime, endTime);

            log.info("===========================系统定时获取货位数据======================");
            //获取货位数据
            apiV1Server.pullData("1005", startTime, endTime);

        }catch (Exception e){
            log.error("定时获取基础信息异常", e);
        }

    }

}

 igds-dzhwk-inte/src/main/java/com/fzzy/igds/dzhwk/v1/timer/JobV1YwService.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,66 @@
package com.fzzy.igds.dzhwk.v1.timer;

import com.fzzy.igds.dzhwk.v1.ApiV1Server;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.time.DateUtils;
import org.springframework.stereotype.Service;
import javax.annotation.Resource;
import java.util.Date;

/**
 * @Description ä¸šåŠ¡ä¿¡æ¯-定时获取任务入口，根据传递的参数
 * @Author CZT
 * @Date 2025/6/5 19:53
 */
@Slf4j
@Service("JobMwYwService")
public class JobV1YwService {

    @Resource
    private ApiV1Server apiV1Server;

    /**
     * å®šæ—¶èŽ·å–业务信息
     *
     * @param num é—´éš”小时，负数
     */
    public void timer(Integer num) {

        log.info("===========================系统定时获取业务信息======================");

        Date endTime = new Date();
        Date startTime = DateUtils.addHours(endTime, num);

        log.info("===========================系统定时获取粮情数据======================");
        //获取粮情数据
        apiV1Server.pullData("2001", startTime, endTime);

        log.info("===========================系统定时获取气体信息======================");
        //获取气体信息
        apiV1Server.pullData("2002", startTime, endTime);

        log.info("===========================系统定时质检设备信息======================");
        //获取质检信息
        apiV1Server.pullData("2003", startTime, endTime);

        log.info("===========================系统定时获取进出仓记录信息======================");
        //获取进出仓记录信息
        apiV1Server.pullData("2004", startTime, endTime);

        log.info("===========================系统定时获取机械通风信息======================");
        //获取机械通风信息
        apiV1Server.pullData("2005", startTime, endTime);

        log.info("===========================系统定时获取熏蒸作业信息======================");
        //获取熏蒸作业信息
        apiV1Server.pullData("2006", startTime, endTime);

        log.info("===========================系统定时获取谷冷作业信息======================");
        //获取谷冷作业信息
        apiV1Server.pullData("2007", startTime, endTime);

        log.info("===========================系统定时获取充氮气调信息======================");
        //获取充氮气调信息
        apiV1Server.pullData("2008", startTime, endTime);
    }
}

 igds-dzhwk-inte/src/main/java/com/fzzy/igds/dzhwk/v1/timer/TestV1Scheduled.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,34 @@
package com.fzzy.igds.dzhwk.v1.timer;

import com.fzzy.igds.dzhwk.v1.ApiV1Server;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.time.DateUtils;
import org.springframework.stereotype.Service;
import javax.annotation.Resource;

/**
 * @Description å®šæ—¶æµ‹è¯•
 * @Author CZT
 * @Date 2025/6/5 19:53
 */
@Slf4j
@Service("TestScheduled")
public class TestV1Scheduled {

    @Resource
    private ApiV1Server apiV1Server;

    /**
     *
     * @param interfaceId æŽ¥å£ç¼–码
     * @param startTime   èµ·å§‹æ—¶é—´
     * @param endTime     æˆªæ­¢æ—¶é—´
     * @throws Exception
     */
    public void scheduled(String interfaceId, String startTime, String endTime) throws Exception {

        log.info("=====手动获取数据，接口编码={}，时间段={}-->{}======", interfaceId, startTime, endTime);

        apiV1Server.pullData(interfaceId, DateUtils.parseDate(startTime, "yyyy-MM-dd HH:mm:ss"), DateUtils.parseDate(endTime, "yyyy-MM-dd HH:mm:ss"));
    }
}