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);
|
}
|
}
|
