| | |
| | | |
| | | @Slf4j |
| | | @Component |
| | | public class OutOperationHandler implements OperationHandler { |
| | | public class OutOperationHandler implements OperationHandler { |
| | | |
| | | @Autowired |
| | | private SlaveProperties slaveProperties; |
| | |
| | | } |
| | | String seqNum = ctuMainService.checkStationStatus(releaseSta.getStaNo()); |
| | | if (seqNum != null) { |
| | | Job jobBySeqNum = jobService.getJobByTaskNo(seqNum); |
| | | if (jobBySeqNum == null) { |
| | | if (jobService.getJobByTaskNo(seqNum) == null) { |
| | | int workNo = wrkLastnoService.nextWorkNo(WorkNoTypeType.WORK_NO_TYPE.type); |
| | | // 下发移动 且 下发plc命令 |
| | | staProtocol.setWorkNo(workNo); |
| | |
| | | job.setJobNo(workNo); |
| | | job.setJobSts(ConveyorStateType.OUTBOUND.getStatus()); |
| | | if (!jobService.insert(job)) { |
| | | throw new CoolException("插入输送线任务失败," + jobBySeqNum + " - " + workNo); |
| | | throw new CoolException("插入输送线任务失败," + seqNum + " - " + workNo); |
| | | } |
| | | redis.push(RedisConveyorConstant.CONVEYOR_TASK_FLAG, staProtocol); |
| | | log.info("输送线下发:{},{}", staProtocol.getWorkNo(), releaseSta.getTargetSta()); |