package com.ld.igds.timer; import com.bstek.bdf2.core.model.DefaultCompany; import com.ld.igds.common.CoreCommonService; import com.ld.igds.view.manager.TempManager; import lombok.extern.slf4j.Slf4j; import org.springframework.scheduling.annotation.Scheduled; import org.springframework.stereotype.Component; import javax.annotation.Resource; import java.util.List; /** * 基础模块标准定时器业务配置 */ @Slf4j @Component(ScheduledBasic.BEAN_ID) public class ScheduledBasic { public static final String BEAN_ID = "basic.scheduled"; @Resource private TempManager thManager; @Resource private CoreCommonService coreCommonService; @Resource private WeatherTimerService weatherTimerService; /** * 每间隔30分钟执行一次 */ @Scheduled(cron = "0 0/30 * * * ?") public void scheduled30() { //定时获取分机的温湿度检测结果 doExeTh(); //定时获取气象信息 weatherTimerService.doExe(); } /** * 定时获取分机的温湿度检测结果 */ private void doExeTh() { List list = coreCommonService.getCompanyList(); if (null == list || list.isEmpty()) return; try { for (DefaultCompany company : list) { log.info("===================系统定时获取分机下的温湿度信息-{}=======================", company.getId()); thManager.scheduledCheck(company.getId()); Thread.sleep(500); } } catch (Exception e) { e.getStackTrace(); } } }