| | |
| | | package com.zy.acs.conveyor.core.operation.handler; |
| | | |
| | | import com.alibaba.fastjson.JSON; |
| | | import com.zy.acs.common.utils.News; |
| | | import com.zy.acs.common.utils.RedisSupport; |
| | | import com.zy.acs.conveyor.core.constant.RedisConveyorConstant; |
| | |
| | | // News.error("{}:站点:{},任务状态不对,{}", config.getMark(), staProtocol.getSiteId(), JSON.toJSON(jobByJobNo)); |
| | | // continue; |
| | | // } |
| | | if (staProtocol.getWorkNo() == 0) { |
| | | Job job = initJob(getWorkNo(), staProtocol.getSiteId() + ""); |
| | | |
| | | |
| | | if (staProtocol.getWorkNo() == 0 && staProtocol.isStartUpFlag()) { |
| | | Job job = initJob(getWorkNo()); |
| | | staProtocol.setWorkNo(job.getJobNo()); |
| | | staProtocol.setStaNo(inSta.getStaNo()); |
| | | staProtocol.setStartUpFlag(false); |
| | |
| | | } |
| | | } |
| | | |
| | | private Job initJob(Integer workNo, String staNo) { |
| | | private Job initJob(Integer workNo) { |
| | | Job job = new Job(); |
| | | job.setStaNo(staNo); |
| | | job.setJobNo(workNo); |
| | | job.setJobSts(ConveyorStateType.STARTUP.getStatus()); |
| | | job.setStartTime(new Date()); |
| | | job.setCreateTime(new Date()); |
| | | return job; |
| | | } |
| | | |
| | | private Integer getWorkNo() { |
| | | return wrkLastnoService.nextWorkNo(WorkNoTypeType.WORK_NO_TYPE.type); |
| | | return wrkLastnoService.nextWorkNo(WorkNoTypeType.WORK_NO_IN_TYPE.type); |
| | | } |
| | | } |