From 0afba31001bcc9cc05af2b9061aa32bf7bd83b0b Mon Sep 17 00:00:00 2001 From: yxFwq <1> Date: 星期五, 03 一月 2025 14:28:27 +0800 Subject: [PATCH] # --- src/main/java/com/zy/asrs/task/handler/WrkMastCrnHandler.java | 64 ++++++++-------- src/main/java/com/zy/asrs/task/WrkMastSplitTwinInItScheduler.java | 50 ++++++------ src/main/java/com/zy/asrs/task/WrkMastCrnScheduler.java | 92 +++++++++++----------- 3 files changed, 103 insertions(+), 103 deletions(-) diff --git a/src/main/java/com/zy/asrs/task/WrkMastCrnScheduler.java b/src/main/java/com/zy/asrs/task/WrkMastCrnScheduler.java index 3b38656..ddc92e5 100644 --- a/src/main/java/com/zy/asrs/task/WrkMastCrnScheduler.java +++ b/src/main/java/com/zy/asrs/task/WrkMastCrnScheduler.java @@ -101,15 +101,15 @@ @Scheduled(cron = "0/3 * * * * ? ") private void execute2(){ for(Integer staNo : CRN_WORK_CU) { - try{ - for(Integer staNo1 : CRN_WORK_CU_SMA) { - RgvOneSign trunSma = rgvOneSignService.selectOne(new EntityWrapper<RgvOneSign>().eq("rgv_one_type","TrunSma"+staNo1)); - trunSma.setRgvOneSign(0); - rgvOneSignService.updateById(trunSma); - } - } catch (Exception e){ - - } +// try{ +// for(Integer staNo1 : CRN_WORK_CU_SMA) { +// RgvOneSign trunSma = rgvOneSignService.selectOne(new EntityWrapper<RgvOneSign>().eq("rgv_one_type","TrunSma"+staNo1)); +// trunSma.setRgvOneSign(0); +// rgvOneSignService.updateById(trunSma); +// } +// } catch (Exception e){ +// +// } List<WrkMastCrn> wrkMastCrnList = wrkMastCrnService.selectList(new EntityWrapper<WrkMastCrn>().eq("source_sta_no",staNo)); if (Cools.isEmpty(wrkMastCrnList)){ List<WrkMast> wrkMasts = wrkMastService.selectList(new EntityWrapper<WrkMast>() @@ -123,43 +123,43 @@ // continue; // } boolean sign = true; - if ((wrkMast.getIoType()==101 || wrkMast.getIoType() == 110) && wrkMast.booleanStaNoSign()){ - RgvOneSign rgvOneSign = rgvOneSignService.selectOne(new EntityWrapper<RgvOneSign>().eq("rgv_one_type","LineUp"+wrkMast.getStaNo())); - if (Cools.isEmpty(rgvOneSign)){ - continue; - } - RgvOneSign trunSma = rgvOneSignService.selectOne(new EntityWrapper<RgvOneSign>().eq("rgv_one_type","TrunSma"+wrkMast.getStaNo())); - if (Cools.isEmpty(trunSma)){ - continue; - } - int wrkCount = wrkMastService.selectCount(new EntityWrapper<WrkMast>().eq("sta_no", wrkMast.getStaNo()).eq("wrk_sts",12L)); - int wrkCountCrn = wrkMastCrnService.selectCount(new EntityWrapper<WrkMastCrn>().eq("sta_no", wrkMast.getStaNo())); - if (wrkCountCrn*2+wrkCount+rgvOneSign.getRgvOneSign()+trunSma.getRgvOneSign()>1){ - continue; - } - int wrkCountGt = wrkMastService.selectCount(new EntityWrapper<WrkMast>().eq("sta_no", wrkMast.getStaNo()).gt("wrk_sts",11L)); - if (wrkCountGt > 1){ - continue; - } - sign = false; -// BasDevp basDevp = basDevpService.selectById(wrkMast.getStaNoBying()); -// if (basDevp.getLoading().equals("Y") -// || !basDevp.getAutoing().equals("Y") -// || (!Cools.isEmpty(basDevp.getWrkNo()) && basDevp.getWrkNo()!=0) ){ -// continue; -// } -// int loadIngCount = basDevpService.selectCount(new EntityWrapper<BasDevp>().ge("dev_no", 103).le("dev_no", 121).eq("loading", "Y")); -// if (loadIngCount>8){ -// continue; -// } -// RgvOneSign smallTurn = rgvOneSignService.selectOne(new EntityWrapper<RgvOneSign>().eq("rgv_one_type","smallTurn")); -// if (Cools.isEmpty(smallTurn)){ -// continue; -// } -// if (smallTurn.getRgvOneSign()>15){ -// continue; -// } - } +// if ((wrkMast.getIoType()==101 || wrkMast.getIoType() == 110) && wrkMast.booleanStaNoSign()){ +//// RgvOneSign rgvOneSign = rgvOneSignService.selectOne(new EntityWrapper<RgvOneSign>().eq("rgv_one_type","LineUp"+wrkMast.getStaNo())); +//// if (Cools.isEmpty(rgvOneSign)){ +//// continue; +//// } +//// RgvOneSign trunSma = rgvOneSignService.selectOne(new EntityWrapper<RgvOneSign>().eq("rgv_one_type","TrunSma"+wrkMast.getStaNo())); +//// if (Cools.isEmpty(trunSma)){ +//// continue; +//// } +//// int wrkCount = wrkMastService.selectCount(new EntityWrapper<WrkMast>().eq("sta_no", wrkMast.getStaNo()).eq("wrk_sts",12L)); +//// int wrkCountCrn = wrkMastCrnService.selectCount(new EntityWrapper<WrkMastCrn>().eq("sta_no", wrkMast.getStaNo())); +//// if (wrkCountCrn*2+wrkCount+rgvOneSign.getRgvOneSign()+trunSma.getRgvOneSign()>1){ +//// continue; +//// } +//// int wrkCountGt = wrkMastService.selectCount(new EntityWrapper<WrkMast>().eq("sta_no", wrkMast.getStaNo()).gt("wrk_sts",11L)); +//// if (wrkCountGt > 1){ +//// continue; +//// } +//// sign = false; +//// BasDevp basDevp = basDevpService.selectById(wrkMast.getStaNoBying()); +//// if (basDevp.getLoading().equals("Y") +//// || !basDevp.getAutoing().equals("Y") +//// || (!Cools.isEmpty(basDevp.getWrkNo()) && basDevp.getWrkNo()!=0) ){ +//// continue; +//// } +//// int loadIngCount = basDevpService.selectCount(new EntityWrapper<BasDevp>().ge("dev_no", 103).le("dev_no", 121).eq("loading", "Y")); +//// if (loadIngCount>8){ +//// continue; +//// } +//// RgvOneSign smallTurn = rgvOneSignService.selectOne(new EntityWrapper<RgvOneSign>().eq("rgv_one_type","smallTurn")); +//// if (Cools.isEmpty(smallTurn)){ +//// continue; +//// } +//// if (smallTurn.getRgvOneSign()>15){ +//// continue; +//// } +// } try{ int row = Utils.getRow(wrkMast.getSourceLocNo()); if (row == wrkMast.getCrnNo()*4 || row == wrkMast.getCrnNo()*4-3){ diff --git a/src/main/java/com/zy/asrs/task/WrkMastSplitTwinInItScheduler.java b/src/main/java/com/zy/asrs/task/WrkMastSplitTwinInItScheduler.java index c56f182..8f532b7 100644 --- a/src/main/java/com/zy/asrs/task/WrkMastSplitTwinInItScheduler.java +++ b/src/main/java/com/zy/asrs/task/WrkMastSplitTwinInItScheduler.java @@ -117,37 +117,37 @@ // if (wrkMast.getStaNoSign().equals(signBigTurn)){ // continue; // } - if (wrkMast.booleanStaNoSign() && wrkMast.booleanStaNoSign()){ - RgvOneSign rgvOneSign = rgvOneSignService.selectOne(new EntityWrapper<RgvOneSign>().eq("rgv_one_type","LineUp"+wrkMast.getStaNo())); - if (Cools.isEmpty(rgvOneSign)){ - continue; - } - int wrkCount = wrkMastService.selectCount(new EntityWrapper<WrkMast>().eq("sta_no", wrkMast.getStaNo()).eq("wrk_sts",12L)); - if (wrkCount+rgvOneSign.getRgvOneSign()>2){ - continue; - } - int wrkCountGt = wrkMastService.selectCount(new EntityWrapper<WrkMast>().eq("sta_no", wrkMast.getStaNo()).gt("wrk_sts",11L)); - if (wrkCountGt > 2){ - continue; - } -// int wrkCount = wrkMastService.selectCount(new EntityWrapper<WrkMast>().eq("io_type", 110).gt("sta_no", 309).lt("sta_no", 314).gt("wrk_sts",11L)); -// if (wrkCount>=12){ +// if (wrkMast.booleanStaNoSign() && wrkMast.booleanStaNoSign()){ +// RgvOneSign rgvOneSign = rgvOneSignService.selectOne(new EntityWrapper<RgvOneSign>().eq("rgv_one_type","LineUp"+wrkMast.getStaNo())); +// if (Cools.isEmpty(rgvOneSign)){ // continue; // } -// RgvOneSign bigTurn = rgvOneSignService.selectOne(new EntityWrapper<RgvOneSign>().eq("rgv_one_type","bigTurn")); -// if (Cools.isEmpty(bigTurn)){ +// int wrkCount = wrkMastService.selectCount(new EntityWrapper<WrkMast>().eq("sta_no", wrkMast.getStaNo()).eq("wrk_sts",12L)); +// if (wrkCount+rgvOneSign.getRgvOneSign()>2){ // continue; // } -// if (bigTurn.getRgvOneSign()>13){ +// int wrkCountGt = wrkMastService.selectCount(new EntityWrapper<WrkMast>().eq("sta_no", wrkMast.getStaNo()).gt("wrk_sts",11L)); +// if (wrkCountGt > 2){ // continue; // } -// BasDevp basDevp = basDevpService.selectById(wrkMast.getStaNoBying()); -// if (basDevp.getLoading().equals("Y") -// || !basDevp.getAutoing().equals("Y") -// || (!Cools.isEmpty(basDevp.getWrkNo()) && basDevp.getWrkNo()!=0) ){ -// continue; -// } - } +//// int wrkCount = wrkMastService.selectCount(new EntityWrapper<WrkMast>().eq("io_type", 110).gt("sta_no", 309).lt("sta_no", 314).gt("wrk_sts",11L)); +//// if (wrkCount>=12){ +//// continue; +//// } +//// RgvOneSign bigTurn = rgvOneSignService.selectOne(new EntityWrapper<RgvOneSign>().eq("rgv_one_type","bigTurn")); +//// if (Cools.isEmpty(bigTurn)){ +//// continue; +//// } +//// if (bigTurn.getRgvOneSign()>13){ +//// continue; +//// } +//// BasDevp basDevp = basDevpService.selectById(wrkMast.getStaNoBying()); +//// if (basDevp.getLoading().equals("Y") +//// || !basDevp.getAutoing().equals("Y") +//// || (!Cools.isEmpty(basDevp.getWrkNo()) && basDevp.getWrkNo()!=0) ){ +//// continue; +//// } +// } wrkMastSplitTwinInItHandler.start(wrkMastSplitTwin,wrkMast,2); // signBigTurn++; // if (signBigTurn > 2){ diff --git a/src/main/java/com/zy/asrs/task/handler/WrkMastCrnHandler.java b/src/main/java/com/zy/asrs/task/handler/WrkMastCrnHandler.java index 57359ec..667b84a 100644 --- a/src/main/java/com/zy/asrs/task/handler/WrkMastCrnHandler.java +++ b/src/main/java/com/zy/asrs/task/handler/WrkMastCrnHandler.java @@ -122,38 +122,38 @@ } WrkMast wrkMastOther = wrkMastService.selectOne(new EntityWrapper<WrkMast>().eq("source_loc_no", deepLocOther).eq("wrk_sts", 11L)); if (!Cools.isEmpty(wrkMastOther)){ - if (!sign) { - RgvOneSign trunSma = rgvOneSignService.selectOne(new EntityWrapper<RgvOneSign>().eq("rgv_one_type","TrunSma"+wrkMast.getStaNo())); - trunSma.setRgvOneSign(trunSma.getRgvOneSign()+1); - rgvOneSignService.updateById(trunSma); - } - if ((wrkMastOther.getIoType()==101 || wrkMastOther.getIoType() == 110) && wrkMastOther.booleanStaNoSign() && wrkMastOther.booleanStaNoSignOther()){ - if (sign){ - RgvOneSign rgvOneSign = rgvOneSignService.selectOne(new EntityWrapper<RgvOneSign>().eq("rgv_one_type","LineUp"+wrkMastOther.getStaNo())); - if (Cools.isEmpty(rgvOneSign)){ - return FAIL; - } - RgvOneSign trunSma = rgvOneSignService.selectOne(new EntityWrapper<RgvOneSign>().eq("rgv_one_type","TrunSma"+wrkMastOther.getStaNo())); - if (Cools.isEmpty(trunSma)){ - return FAIL; - } - int wrkCount = wrkMastService.selectCount(new EntityWrapper<WrkMast>().eq("sta_no", wrkMastOther.getStaNo()).eq("wrk_sts",12L)); - int wrkCountCrn = wrkMastCrnService.selectCount(new EntityWrapper<WrkMastCrn>().eq("sta_no", wrkMastOther.getStaNo())); - if (wrkCountCrn*2+wrkCount+rgvOneSign.getRgvOneSign()+trunSma.getRgvOneSign()>1){ - return FAIL; - } - int wrkCountGt = wrkMastService.selectCount(new EntityWrapper<WrkMast>().eq("sta_no", wrkMastOther.getStaNo()).gt("wrk_sts",11L)); - if (wrkCountGt > 1){ - return FAIL; - } - trunSma.setRgvOneSign(trunSma.getRgvOneSign()+1); - rgvOneSignService.updateById(trunSma); - } else { - RgvOneSign trunSma = rgvOneSignService.selectOne(new EntityWrapper<RgvOneSign>().eq("rgv_one_type","TrunSma"+wrkMastOther.getStaNo())); - trunSma.setRgvOneSign(trunSma.getRgvOneSign()+1); - rgvOneSignService.updateById(trunSma); - } - } +// if (!sign) { +// RgvOneSign trunSma = rgvOneSignService.selectOne(new EntityWrapper<RgvOneSign>().eq("rgv_one_type","TrunSma"+wrkMast.getStaNo())); +// trunSma.setRgvOneSign(trunSma.getRgvOneSign()+1); +// rgvOneSignService.updateById(trunSma); +// } +// if ((wrkMastOther.getIoType()==101 || wrkMastOther.getIoType() == 110) && wrkMastOther.booleanStaNoSign() && wrkMastOther.booleanStaNoSignOther()){ +// if (sign){ +// RgvOneSign rgvOneSign = rgvOneSignService.selectOne(new EntityWrapper<RgvOneSign>().eq("rgv_one_type","LineUp"+wrkMastOther.getStaNo())); +// if (Cools.isEmpty(rgvOneSign)){ +// return FAIL; +// } +// RgvOneSign trunSma = rgvOneSignService.selectOne(new EntityWrapper<RgvOneSign>().eq("rgv_one_type","TrunSma"+wrkMastOther.getStaNo())); +// if (Cools.isEmpty(trunSma)){ +// return FAIL; +// } +// int wrkCount = wrkMastService.selectCount(new EntityWrapper<WrkMast>().eq("sta_no", wrkMastOther.getStaNo()).eq("wrk_sts",12L)); +// int wrkCountCrn = wrkMastCrnService.selectCount(new EntityWrapper<WrkMastCrn>().eq("sta_no", wrkMastOther.getStaNo())); +// if (wrkCountCrn*2+wrkCount+rgvOneSign.getRgvOneSign()+trunSma.getRgvOneSign()>1){ +// return FAIL; +// } +// int wrkCountGt = wrkMastService.selectCount(new EntityWrapper<WrkMast>().eq("sta_no", wrkMastOther.getStaNo()).gt("wrk_sts",11L)); +// if (wrkCountGt > 1){ +// return FAIL; +// } +// trunSma.setRgvOneSign(trunSma.getRgvOneSign()+1); +// rgvOneSignService.updateById(trunSma); +// } else { +// RgvOneSign trunSma = rgvOneSignService.selectOne(new EntityWrapper<RgvOneSign>().eq("rgv_one_type","TrunSma"+wrkMastOther.getStaNo())); +// trunSma.setRgvOneSign(trunSma.getRgvOneSign()+1); +// rgvOneSignService.updateById(trunSma); +// } +// } WrkMastCrn wrkMastCrn = new WrkMastCrn(wrkMast,wrkMastOther,now); wrkMastCrnService.insert(wrkMastCrn); }else { -- Gitblit v1.9.1