| | |
| | | if (staNo != null) { |
| | | staProtocol.setStaNo(staNo); |
| | | } |
| | | staProtocol.setStartUpFlag(true); |
| | | redis.push(RedisConveyorConstant.CONVEYOR_TASK_FLAG, staProtocol); |
| | | return R.ok(); |
| | | |
| | |
| | | // News.error("{}:站点:{},任务状态不对,{}", config.getMark(), staProtocol.getSiteId(), JSON.toJSON(jobByJobNo)); |
| | | // continue; |
| | | // } |
| | | if (staProtocol.getWorkNo() == 0) { |
| | | |
| | | |
| | | if (staProtocol.getWorkNo() == 0 && !staProtocol.isStartUpFlag()) { |
| | | Job job = initJob(getWorkNo(), staProtocol.getSiteId() + ""); |
| | | staProtocol.setWorkNo(job.getJobNo()); |
| | | staProtocol.setStaNo(inSta.getStaNo()); |
| | |
| | | staProtocol.setSegApply(status2[2]); |
| | | staProtocol.setApplyErr(status2[3]); |
| | | |
| | | if (!status2[1] && !status[0]) { |
| | | if (!status2[1] && !status[1]) { |
| | | staProtocol.setStartUpFlag(true); |
| | | } |
| | | |