package com.zy.asrs.task; import com.baomidou.mybatisplus.mapper.EntityWrapper; import com.core.common.Cools; import com.zy.asrs.entity.WrkMast; import com.zy.asrs.service.WrkMastService; import com.zy.asrs.task.core.ReturnT; import com.zy.asrs.task.handler.WCSReportHandler; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Value; import org.springframework.scheduling.annotation.Scheduled; import org.springframework.stereotype.Component; import java.util.List; @Component public class WCSReportScheduler { private static final Logger log = LoggerFactory.getLogger(WorkMastScheduler.class); @Autowired private WrkMastService wrkMastService; @Autowired private WCSReportHandler wcsReportHandler; @Value("${wcs-slave.workIssued-fig}") private Boolean workIssuedFig; /** * 下发任务给WCS */ @Scheduled(cron = "0/3 * * * * ? ") public synchronized void execute (){ if (!workIssuedFig){ return; } List wrkMastList=wrkMastService.selectList(new EntityWrapper()); int i=1; for(WrkMast wrkMast:wrkMastList){ if (wrkMast.getWrkSts()==0){ wcsReportHandler.start(wrkMast,i); i++; } } } }