| | |
| | | import org.slf4j.Logger; |
| | | import org.slf4j.LoggerFactory; |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | | import org.springframework.scheduling.annotation.Scheduled; |
| | | import org.springframework.stereotype.Component; |
| | | |
| | | import java.util.ArrayList; |
| | |
| | | |
| | | |
| | | public static final List<Integer> STA_WORK_CU = new ArrayList<Integer>() {{ |
| | | add(101);add(102);add(104);add(105);add(107);add(108);add(110);add(111);add(113);add(114);add(116);add(117); |
| | | add(101);add(102);add(104);add(105);add(107);add(108); |
| | | }}; |
| | | |
| | | public static final List<Integer> STA_WORK_CU_CAR = new ArrayList<Integer>() {{ |
| | | add(118);add(119);add(120);add(121); |
| | | add(119);add(118); |
| | | }}; |
| | | |
| | | public static final List<Integer> STA_WORK_CU_CAR_TWO = new ArrayList<Integer>() {{ |
| | | add(120);add(121); |
| | | |
| | | }}; |
| | | public static final List<Integer> STA_WORK_CU_CAR_THREE = new ArrayList<Integer>() {{ |
| | | add(118);add(120); |
| | | add(118); |
| | | }}; |
| | | public static final List<Integer> STA_WORK_CU_CAR_FOUR = new ArrayList<Integer>() {{ |
| | | add(119);add(121); |
| | | add(119); |
| | | }}; |
| | | |
| | | public static final List<Integer> STA_WORK_RU = new ArrayList<Integer>() {{ |
| | | add(118);add(119);add(120);add(121);add(122);add(123); |
| | | add(119);add(118);add(122); |
| | | }}; |
| | | |
| | | |
| | | @Scheduled(cron = "0/3 * * * * ? ") |
| | | // @Scheduled(cron = "0/3 * * * * ? ") |
| | | private void execute(){ |
| | | for(Integer staNo : STA_WORK_CU){ |
| | | BasDevp basDevp = basDevpService.selectById(staNo); |
| | | if (basDevp.getWrkNo()!=0 && basDevp.getLoading().equals("Y") && basDevp.getAutoing().equals("Y")){ |
| | | WrkMast wrkMast = wrkMastService.selectOne(new EntityWrapper<WrkMast>().eq("wrk_no", basDevp.getWrkNo())); |
| | | if(Cools.isEmpty(wrkMast)){ |
| | | continue; |
| | | } |
| | | if (wrkMast.getIoType()<100 || wrkMast.getIoType()==110){ |
| | | if (!wrkMast.getStaNo().equals(122)){ |
| | | try{ |
| | | BasDevp basDevp = basDevpService.selectById(staNo); |
| | | if (basDevp.getWrkNo()!=0 && basDevp.getLoading().equals("Y") && basDevp.getAutoing().equals("Y")){ |
| | | WrkMast wrkMast = wrkMastService.selectOne(new EntityWrapper<WrkMast>().eq("wrk_no", basDevp.getWrkNo())); |
| | | if(Cools.isEmpty(wrkMast)){ |
| | | continue; |
| | | } |
| | | } |
| | | if (wrkMast.getWrkSts()!=14 && wrkMast.getWrkSts()!=15){ |
| | | continue; |
| | | } |
| | | if (wrkMast.getStaNo()==118 || wrkMast.getStaNo()==119 || wrkMast.getStaNo()==120 || wrkMast.getStaNo()==121){ |
| | | continue; |
| | | } |
| | | boolean wrkTypeSign = fullKM(wrkMast); |
| | | if (!Cools.isEmpty(wrkMast)){ |
| | | if (wrkTypeSign) { |
| | | ReturnT<String> result = wrkMastStaInItHandler.start(wrkMast,basDevp,13);//3:取放 |
| | | if (result.getCode()==200){ |
| | | if (wrkMast.getIoType()<100 || wrkMast.getIoType()==110){ |
| | | if (!wrkMast.getStaNo().equals(122)){ |
| | | continue; |
| | | }else { |
| | | System.out.println(staNo+"失败!"); |
| | | } |
| | | } else { |
| | | ReturnT<String> result = wrkMastStaInItHandler.start(wrkMast,basDevp,23);//5:满取 |
| | | if (result.getCode()==200){ |
| | | continue; |
| | | }else { |
| | | System.out.println(staNo+"失败!"); |
| | | } |
| | | if (wrkMast.getWrkSts()!=14 && wrkMast.getWrkSts()!=15){ |
| | | continue; |
| | | } |
| | | if (wrkMast.getStaNo()==118 || wrkMast.getStaNo()==119 || wrkMast.getStaNo()==120 || wrkMast.getStaNo()==121){ |
| | | continue; |
| | | } |
| | | boolean wrkTypeSign = fullKM(wrkMast); |
| | | if (!Cools.isEmpty(wrkMast)){ |
| | | if (wrkTypeSign) { |
| | | ReturnT<String> result = wrkMastStaInItHandler.start(wrkMast,basDevp,13);//3:取放 |
| | | if (result.getCode()==200){ |
| | | continue; |
| | | }else { |
| | | System.out.println(staNo+"失败!"); |
| | | } |
| | | } else { |
| | | ReturnT<String> result = wrkMastStaInItHandler.start(wrkMast,basDevp,23);//5:满取 |
| | | if (result.getCode()==200){ |
| | | continue; |
| | | }else { |
| | | System.out.println(staNo+"失败!"); |
| | | } |
| | | } |
| | | } |
| | | } |
| | | }catch (Exception e){ |
| | | log.error("自动补空板STA_WORK_CU处理失败,当前站点号:"+staNo+"异常信息"+e); |
| | | } |
| | | } |
| | | |
| | | for(Integer staNo : STA_WORK_RU){ |
| | | BasDevp basDevp = basDevpService.selectById(staNo); |
| | | if (basDevp.getWrkNo()!=0 && basDevp.getLoading().equals("Y") && basDevp.getAutoing().equals("Y")){ |
| | | WrkMast wrkMast = wrkMastService.selectOne(new EntityWrapper<WrkMast>().eq("wrk_no", basDevp.getWrkNo())); |
| | | if (Cools.isEmpty(wrkMast)){ |
| | | continue; |
| | | } |
| | | try{ |
| | | BasDevp basDevp = basDevpService.selectById(staNo); |
| | | if (basDevp.getWrkNo()!=0 && basDevp.getLoading().equals("Y") && basDevp.getAutoing().equals("Y")){ |
| | | WrkMast wrkMast = wrkMastService.selectOne(new EntityWrapper<WrkMast>().eq("wrk_no", basDevp.getWrkNo())); |
| | | if (Cools.isEmpty(wrkMast)){ |
| | | continue; |
| | | } |
| | | |
| | | if (wrkMast.getWrkSts()!=2 || wrkMast.getIoType()==10){ |
| | | continue; |
| | | } |
| | | if (wrkMast.getWrkSts()!=2 || wrkMast.getIoType()==10){ |
| | | continue; |
| | | } |
| | | // boolean wrkTypeSign = fullKM(wrkMast); |
| | | |
| | | if (!Cools.isEmpty(wrkMast)){ |
| | | if (!Cools.isEmpty(wrkMast)){ |
| | | // if (wrkTypeSign){ |
| | | ReturnT<String> result = wrkMastStaInItHandler.start(wrkMast,basDevp,13); |
| | | if (result.getCode()==200) { |
| | |
| | | } else { |
| | | System.out.println(staNo+"失败!"); |
| | | } |
| | | } |
| | | } |
| | | }catch (Exception e){ |
| | | log.error("自动补空板STA_WORK_RU处理失败,当前站点号:"+staNo+"异常信息"+e); |
| | | } |
| | | } |
| | | } |
| | | |
| | | @Scheduled(cron = "0/3 * * * * ? ") |
| | | // @Scheduled(cron = "0/3 * * * * ? ") |
| | | private void execute2(){ |
| | | try{ |
| | | for(Integer staNo : STA_WORK_CU){ |