| | |
| | | if (wrkMastExecuteService.getWrkMastExecuteByJarIdCount(jarSlave.getId())!=0){ |
| | | return false; |
| | | } |
| | | List<BasJarMast> basJarMastList1 = basJarMastService.getJarMastByJarIdAndStatusList(jarSlave.getJarOtherId(), new ArrayList<Integer>() {{ |
| | | add(0);add(1);add(2);add(3); |
| | | }}); |
| | | if (!basJarMastList1.isEmpty()){ |
| | | return false; |
| | | BasJar basJarOther11 = basJarMapper.selectById(jarSlave.getJarOtherId()); |
| | | if (!Cools.isEmpty(basJarOther11) && basJarOther11.getJarMode()==2){ |
| | | List<BasJarMast> basJarMastList1 = basJarMastService.getJarMastByJarIdAndStatusList(jarSlave.getJarOtherId(), new ArrayList<Integer>() {{ |
| | | add(0);add(1);add(2);add(3); |
| | | }}); |
| | | if (!basJarMastList1.isEmpty()){ |
| | | return false; |
| | | } |
| | | |
| | | List<BasJarMast> basJarMastList2 = basJarMastService.getJarMastByJarIdAndStatusList(jarSlave.getJarOtherId(), new ArrayList<Integer>() {{ |
| | | add(8);add(9);add(10);add(11);add(12); |
| | | }}); |
| | | if (!basJarMastList2.isEmpty() && basJarMastList2.size()!=basJarOther11.getJarCount()){ |
| | | return false; |
| | | } |
| | | |
| | | } |
| | | |
| | | |
| | | List<BasJarMast> basJarMastList = basJarMastService.getJarMastByJarIdAndStatusList(jarSlave.getId(), new ArrayList<Integer>() {{ |
| | | add(8); |
| | | }}); |
| | |
| | | } |
| | | break; |
| | | } |
| | | } else if (staProtocol.isAutoing() |
| | | && !staProtocol.isLoading() |
| | | && staProtocol.getWorkNo() == 0 |
| | | && staProtocol.isPakMk()) { |
| | | for (DevpSlave.Jar jar : inSta.getJarList()) { |
| | | SteThread steThread = (SteThread) SlaveConnection.get(SlaveType.Ste, jar.getJarNo()<3? 1:2); |
| | | if (steThread == null) { |
| | | continue; |
| | | } |
| | | SteProtocol steProtocol = steThread.getSteProtocol(); |
| | | if (steProtocol == null) { |
| | | continue; |
| | | } |
| | | if (!Cools.isEmpty(steProtocol.getLocaType()) && !steProtocol.getLocaType().equals(SteLocaType.NONE) && steProtocol.getStatusType().equals(SteStatusType.IDLE)) { |
| | | // 判断重复工作档 |
| | | List<BasJarMast> basJarMastList = basJarMastService.getJarMastByJarIdAndStatusListB(jar.getBurial(), new ArrayList<Integer>() {{ |
| | | add(9); |
| | | add(11); |
| | | }}); |
| | | if (basJarMastList.isEmpty()){ |
| | | continue; |
| | | } |
| | | BasJarMast jarMastByWrkNo = basJarMastList.get(0); |
| | | WrkMastExecute wrkMastExecute = wrkMastExecuteService.selectOne(new EntityWrapper<WrkMastExecute>().eq("wrk_no", jarMastByWrkNo.getWrkNo())); |
| | | if (Cools.isEmpty(wrkMastExecute)){ |
| | | jarMastByWrkNo.setStatus(jarMastByWrkNo.getStatusComplete(6)); |
| | | if (!basJarMastService.updateById(jarMastByWrkNo)){ |
| | | log.error("硫化区域分段任务完成异常,BasJarMast={},异常信息={}",JSON.toJSONString(jarMastByWrkNo),"更新basJarMast失败"); |
| | | // throw new CoolException("更新basJarMast失败"); |
| | | } |
| | | } |
| | | break; |
| | | } |
| | | } |
| | | } |
| | | } |
| | | } |