| | |
| | | import org.springframework.stereotype.Component; |
| | | import org.springframework.transaction.interceptor.TransactionAspectSupport; |
| | | |
| | | import java.util.Date; |
| | | import java.util.Map; |
| | | |
| | | /** |
| | |
| | | continue; |
| | | } |
| | | if (!staProtocol.isAutoing()) { |
| | | News.error("{}:站点:{},非自动", config.getMark(), staProtocol.getSiteId()); |
| | | //News.error("{}:站点:{},非自动", config.getMark(), staProtocol.getSiteId()); |
| | | continue; |
| | | } |
| | | if (!staProtocol.isLoading()) { |
| | |
| | | continue; |
| | | } |
| | | if (jobByJobNo.getJobSts() != ConveyorStateType.OUTBOUND.getStatus()) { |
| | | if (jobByJobNo.getJobSts() == ConveyorStateType.STARTUP.getStatus()){ |
| | | if (jobByJobNo.getJobSts() == ConveyorStateType.STARTUP.getStatus()) { |
| | | continue; |
| | | } |
| | | News.error("{}:站点:{},任务状态不对,{}", config.getMark(), staProtocol.getSiteId(), JSON.toJSON(jobByJobNo)); |
| | |
| | | } |
| | | staProtocol.setStaNo(inSta.getStaNo()); |
| | | redis.push(RedisConveyorConstant.CONVEYOR_TASK_FLAG, staProtocol); |
| | | |
| | | jobByJobNo.setStartTime(new Date()); |
| | | jobByJobNo.setJobSts(ConveyorStateType.STARTUP.getStatus()); |
| | | if (!jobService.updateById(jobByJobNo)) { |
| | | News.info("{},启动入库:{},{}", config.getMark(), staProtocol.getWorkNo(), staProtocol.getStaNo()); |