| | |
| | | }}; |
| | | |
| | | public static final List<Integer> STA_WORK_RU = new ArrayList<Integer>() {{ |
| | | add(120);add(121);add(122);add(123);add(171); |
| | | add(120);add(121);add(123);add(171); |
| | | }}; |
| | | |
| | | |
| | | @Scheduled(cron = "0/1 * * * * ? ") |
| | | private void execute(){ |
| | | RgvOneSign rgvTwoSign = rgvOneSignService.selectOne(new EntityWrapper<RgvOneSign>().eq("rgv_one_type","rgvTwo")); |
| | | if (Cools.isEmpty(rgvTwoSign) || rgvTwoSign.getRgvOneSign()!=0){ |
| | | return; |
| | | } |
| | | List<Integer> integersStaArr = new ArrayList<>(); |
| | | List<int[]> stalistArr = new ArrayList<>(); |
| | | for(Integer staNo : STA_WORK_CU){ |
| | |
| | | } |
| | | } |
| | | }catch (Exception e){ |
| | | log.error("自动补空板STA_WORK_RU处理失败,当前站点号:"+staNo+"异常信息"+e); |
| | | log.error("STA_WORK_RU处理失败,当前站点号:"+staNo+"异常信息"+e); |
| | | } |
| | | } |
| | | } |
| | | |
| | | @Scheduled(cron = "0/1 * * * * ? ") |
| | | private void execute2(){ |
| | | RgvOneSign rgvTwoSign = rgvOneSignService.selectOne(new EntityWrapper<RgvOneSign>().eq("rgv_one_type","rgvTwo")); |
| | | if (Cools.isEmpty(rgvTwoSign) || rgvTwoSign.getRgvOneSign()!=0){ |
| | | return; |
| | | } |
| | | try{ |
| | | List<Integer> integersStaArr = new ArrayList<>(); |
| | | List<int[]> stalistArr = new ArrayList<>(); |
| | |
| | | new EntityWrapper<WrkMast>().eq("crn_no", crnNo).eq("wrk_sts", 11L)); |
| | | stalistArr.add(new int[]{staNo, selectCount}); |
| | | } |
| | | |
| | | // 按selectCount降序排序(最大的排第一位) |
| | | Collections.sort(stalistArr, (a, b) -> b[1] - a[1]); // 降序排列 |
| | | // 如果您需要转为数组(可选) |
| | | Collections.sort(stalistArr, (a, b) -> b[1] - a[1]); |
| | | for (int[] staNowArr : stalistArr){ |
| | | integersStaArr.add(staNowArr[0]); |
| | | } |