From 6494d25e5677f2e81c898006b3aada6260511f33 Mon Sep 17 00:00:00 2001 From: lty <876263681@qq.com> Date: 星期四, 24 七月 2025 09:41:32 +0800 Subject: [PATCH] # --- src/main/java/com/zy/common/service/CommonService.java | 209 ++++++++++++++++++++++++++++++++------------------- 1 files changed, 130 insertions(+), 79 deletions(-) diff --git a/src/main/java/com/zy/common/service/CommonService.java b/src/main/java/com/zy/common/service/CommonService.java index b1b5b76..ddd63f7 100644 --- a/src/main/java/com/zy/common/service/CommonService.java +++ b/src/main/java/com/zy/common/service/CommonService.java @@ -7,7 +7,9 @@ import com.core.common.Cools; import com.core.exception.CoolException; import com.zy.asrs.entity.*; +import com.zy.asrs.entity.result.KeyValueVo; import com.zy.asrs.service.*; +import com.zy.asrs.service.impl.MatServiceImpl; import com.zy.asrs.utils.Utils; import com.zy.asrs.utils.VersionUtils; import com.zy.common.model.LocTypeDto; @@ -19,6 +21,10 @@ import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; +import java.time.LocalDate; +import java.time.format.DateTimeFormatter; +import java.time.temporal.ChronoUnit; +import java.util.ArrayList; import java.util.List; /** @@ -47,10 +53,11 @@ private LocDetlService locDetlService; @Autowired private SlaveProperties slaveProperties; + @Autowired + private MatServiceImpl matService; /** * 鐢熸垚宸ヤ綔鍙� - * * @param wrkMk * @return workNo(宸ヤ綔鍙�) */ @@ -63,17 +70,17 @@ int workNo = wrkLastno.getWrkNo(); int sNo = wrkLastno.getSNo(); int eNo = wrkLastno.getENo(); - workNo = workNo >= eNo ? sNo : workNo + 1; + workNo = workNo>=eNo ? sNo : workNo+1; while (true) { WrkMast wrkMast = wrkMastService.selectById(workNo); if (null != wrkMast) { - workNo = workNo >= eNo ? sNo : workNo + 1; + workNo = workNo>=eNo ? sNo : workNo+1; } else { break; } } // 淇敼搴忓彿璁板綍 - if (workNo > 0) { + if (workNo > 0){ wrkLastno.setWrkNo(workNo); wrkLastnoService.updateById(wrkLastno); } @@ -81,11 +88,27 @@ if (workNo == 0) { throw new CoolException("鐢熸垚宸ヤ綔鍙峰け璐ワ紝璇疯仈绯荤鐞嗗憳"); } else { - if (wrkMastService.selectById(workNo) != null) { + if (wrkMastService.selectById(workNo)!=null) { throw new CoolException("鐢熸垚宸ヤ綔鍙�" + workNo + "鍦ㄥ伐浣滄。涓凡瀛樺湪"); } } return workNo; + } + + //鎷嗙洏鏈哄绌烘澘鎵爜锛岄┍鍔ㄦ墭鐩樺悜鐮佸灈浣嶏紝涓嶅叆搴� + @Transactional + public StartupDto getScanBarcodeEmptyBoard(){ + StartupDto startupDto = new StartupDto(); + Integer staNo = 0; + if (wrkMastService.selectCount(new EntityWrapper<WrkMast>().eq("io_type", 201).eq("staNo", 216))<2){ + staNo=216; + } + if (wrkMastService.selectCount(new EntityWrapper<WrkMast>().eq("io_type", 201).eq("staNo", 220))<2){ + staNo=220; + } + + startupDto.setStaNo(staNo); + return startupDto; } /** @@ -99,6 +122,7 @@ */ @Transactional public StartupDto getLocNo(Integer whsType, Integer staDescId, Integer sourceStaNo, String matnr, String batch, String grade, LocTypeDto locTypeDto) { + whsType = Utils.GetWhsType(sourceStaNo); return getLocNoRun(whsType,staDescId,sourceStaNo,matnr,batch,grade,0,locTypeDto,0); } @@ -113,8 +137,12 @@ */ @Transactional public StartupDto getLocNoRun(Integer whsType, Integer staDescId, Integer sourceStaNo, String matnr, String batch, String grade, Integer moveCrnNo, LocTypeDto locTypeDto, int times) { + long start = System.currentTimeMillis(); + int tagId = 0; if (Cools.isEmpty(matnr)) { //鐗╂枡鍙� matnr = ""; + }else{ + tagId = matService.getTagIdByMatnr(matnr); } if (Cools.isEmpty(batch)) { //绠卞彿 batch = ""; @@ -135,7 +163,6 @@ int sRow = rowLastno.getsRow(); int eRow = rowLastno.geteRow(); int crnNumber = rowLastno.getCrnQty(); - if (Cools.isEmpty(rowLastno)) { throw new CoolException("鏁版嵁寮傚父锛岃鑱旂郴绠$悊鍛�"); } @@ -144,65 +171,71 @@ if (!Cools.isEmpty(moveCrnNo) && moveCrnNo!=0){ crnNumber = moveCrnNo; - if (times==0){ - curRow = moveCrnNo*4-1; - }else { - curRow = moveCrnNo*4-2; - } + curRow = eRow; } //姝ょ▼搴忕敤浜庝紭鍖栧爢鍨涙満寮傚父鏃剁殑杩愯鏃堕棿 - for (int i = times; i < crnNumber; i++) { + for (int i = times; i < crnNumber*2; i++) { int[] locNecessaryParameters = Utils.LocNecessaryParameters(whsType, curRow, crnNumber); curRow = locNecessaryParameters[1]; crnNo = locNecessaryParameters[2]; if (basCrnpService.checkSiteError(crnNo, true)) { rowCount = locNecessaryParameters[0]; nearRow = locNecessaryParameters[3]; + List<LocMast> locMasts = locMastService.selectList(new EntityWrapper<LocMast>().eq("row1", nearRow).eq("loc_sts", "O")); + int crnCountO = wrkMastService.selectCount(new EntityWrapper<WrkMast>().eq("crn_no", crnNo).le("io_type",100)); + if (locMasts.size()-crnCountO<=0){ + times++; + continue; + } break; } else { times++; } } - if (nearRow == 0) { - throw new CoolException("鏃犲彲鐢ㄥ爢鍨涙満"); - } +// if (nearRow == 0) { +// throw new CoolException("鏃犲彲鐢ㄥ爢鍨涙満"); +// } boolean signRule1 = false; boolean signRule2 = false; - // 闈犺繎鎽嗘斁瑙勫垯 --- 鍚屽ぉ鍚岃鏍肩墿鏂� //鍒嗙鐗� -// if (!Cools.isEmpty(matnr) && (staDescId == 1)){ -// signRule1 = true; -// } - // 闈犺繎鎽嗘斁瑙勫垯 --- 鍚屽ぉ鍚岃鏍肩墿鏂� //浜掗�氱増 - if (!Cools.isEmpty(matnr) && staDescId == 1) { - signRule2 = true; - } + if (Utils.BooleanWhsTypeStaIoType(whsType)){ + // 闈犺繎鎽嗘斁瑙勫垯 --- 鍚屽ぉ鍚岃鏍肩墿鏂� //鍒嗙鐗� + if (!Cools.isEmpty(matnr) && staDescId == 1){ + signRule1 = false; + } + // 闈犺繎鎽嗘斁瑙勫垯 --- 鍚屽ぉ鍚岃鏍肩墿鏂� //浜掗�氱増 + if (!Cools.isEmpty(matnr) && staDescId == 1) { + signRule2 = true; + } - if (!Cools.isEmpty(matnr) && (staDescId == 11 || staDescId == 111)) { - signRule1 = true; + if (!Cools.isEmpty(matnr) && (staDescId == 11 || staDescId == 111)) { + signRule1 = true; + } } if (signRule1){ - List<LocMast> locMasts = locMastService.selectList(new EntityWrapper<LocMast>().eq("row1", nearRow).eq("loc_sts", "O")); - for (LocMast locMast1:locMasts){ - if (VersionUtils.locMoveCheckLocTypeComplete(locMast1, locTypeDto)) { - continue; - } - String shallowLoc = Utils.getDeepLoc(slaveProperties,locMast1.getLocNo()); - LocMast locMast2 = locMastService.selectOne(new EntityWrapper<LocMast>().eq("loc_no",shallowLoc)); - if (!Cools.isEmpty(locMast2) && locMast2.getLocSts().equals("F")){ - LocDetl locDetl = locDetlService.selectOne(new EntityWrapper<LocDetl>().eq("loc_no", locMast2.getLocNo())); - if (!Cools.isEmpty(locDetl) && matnr.equals(locDetl.getMatnr())) { - locMast = locMast1; - break; + if (nearRow!=curRow){ + List<LocMast> locMasts = locMastService.selectList(new EntityWrapper<LocMast>().eq("row1", nearRow).eq("loc_sts", "O")); + for (LocMast locMast1:locMasts){ + //鑾峰彇宸烽亾 + List<String> groupOutsideLocCrn = Utils.getGroupOutLocCrn(curRow,nearRow,locMast1.getLocNo(), curRow>nearRow); + //鑾峰彇鐩爣搴撲綅鎵�鍦ㄥ贩閬撴渶娴呴潪绌哄簱浣� + LocMast locMastF = locMastService.selectLocByLocStsPakInF(curRow,nearRow,groupOutsideLocCrn); + if (!Cools.isEmpty(locMastF) && locMastF.getLocSts().equals("F")){ + LocDetl locDetl = locDetlService.selectOne(new EntityWrapper<LocDetl>().eq("loc_no", locMastF.getLocNo())); + if (!Cools.isEmpty(locDetl) && matnr.equals(locDetl.getMatnr()) && batch.equals(Cools.isEmpty(locDetl.getBatch()) ? "" : locDetl.getBatch()) && grade.equals(Cools.isEmpty(locDetl.getBrand()) ? "" : locDetl.getBrand())) { + //鑾峰彇鐩爣搴撲綅鎵�鍦ㄥ贩閬撴渶娴呴潪绌哄簱浣� + locMast = locMastService.selectLocByLocStsPakInO(curRow,nearRow,groupOutsideLocCrn); + break; + } } } } }else if (signRule2){ - List<String> locNos = locDetlService.getSameDetlToday(matnr,batch, sRow, eRow); + List<String> locNos = locDetlService.getSameDetlToday(matnr, sRow, eRow); for (String locNo : locNos) { if (Utils.isShallowLoc(slaveProperties, locNo)) { continue; @@ -222,24 +255,10 @@ } } -// // 闈犺繎鎽嗘斁瑙勫垯 --- 绌烘墭 //鍒嗙鐗� -// if (staDescId == 10) { -// List<LocMast> locMasts = locMastService.selectList(new EntityWrapper<LocMast>().eq("row1", nearRow).eq("loc_sts", "O")); -// for (LocMast locMast1:locMasts){ -// if (VersionUtils.locMoveCheckLocTypeComplete(locMast1, locTypeDto)) { -// continue; -// } -// String shallowLoc = Utils.getDeepLoc(slaveProperties,locMast1.getLocNo()); -// LocMast locMast2 = locMastService.selectOne(new EntityWrapper<LocMast>().eq("loc_no",shallowLoc)); -// if (!Cools.isEmpty(locMast2) && locMast2.getLocSts().equals("D")){ -// locMast = locMast1; -// break; -// } -// } -// } + // 闈犺繎鎽嗘斁瑙勫垯 --- 绌烘墭 //浜掗�氱増 - if (staDescId == 10) { + if (staDescId == 10 && Utils.BooleanWhsTypeStaIoType(whsType)) { List<LocMast> locMasts = locMastService.selectList(new EntityWrapper<LocMast>().eq("loc_sts", "D").ge("row1", sRow).le("row1", eRow)); if (locMasts.size() > 0) { for (LocMast loc : locMasts) { @@ -277,17 +296,19 @@ log.error("type_no={},stn_no={},crn_no={}", staDescId, sourceStaNo, crnNo); // throw new CoolException("鍏ュ簱璺緞涓嶅瓨鍦�"); crnNo = 0; - } - staNo = basDevpService.selectById(staDesc.getCrnStn()); - if (!staNo.getAutoing().equals("Y")) { + }else { + staNo = basDevpService.selectById(staDesc.getCrnStn()); + if (!staNo.getAutoing().equals("Y")) { + log.error("鐩爣绔�"+staDesc.getCrnStn()+"涓嶅彲鐢�"); // throw new CoolException("鐩爣绔�"+staDesc.getCrnStn()+"涓嶅彲鐢�"); - crnNo = 0; + crnNo = 0; + } + startupDto.setStaNo(staNo.getDevNo()); } - startupDto.setStaNo(staNo.getDevNo()); } // 鏇存柊搴撲綅鎺掑彿 - if (Utils.BooleanWhsTypeSta(whsType, staDescId)) { + if (Utils.BooleanWhsTypeSta(whsType, staDescId) && Cools.isEmpty(locMast)) { rowLastno.setCurrentRow(curRow); rowLastnoService.updateById(rowLastno); } @@ -296,39 +317,67 @@ // 1.鎸夎鍒欐煡鎵惧簱浣� if (Cools.isEmpty(locMast) && crnNo != 0) { - List<LocMast> locMasts = locMastService.selectList(new EntityWrapper<LocMast>().eq("row1", nearRow).eq("loc_sts", "O")); - for (LocMast locMast1 : locMasts) { - if (VersionUtils.locMoveCheckLocTypeComplete(locMast1, locTypeDto)) { - continue; + List<LocMast> locMasts = null; + if(sourceStaNo % 100 > 10){ + locMasts = locMastService.selectList(new EntityWrapper<LocMast>() + .eq("row1", nearRow) + .eq("loc_sts", "O") + .orderBy("lev1",true).orderBy("bay1",false)); + }else{ + locMasts = locMastService.selectList(new EntityWrapper<LocMast>() + .eq("row1", nearRow) + .eq("loc_sts", "O") + .orderBy("lev1",true).orderBy("bay1",true)); + } + + + if (Cools.isEmpty(locMast) && Utils.BooleanWhsTypeStaIoType(whsType)){ + if(tagId == 226){ + List<LocMast> filteredLocMasts = new ArrayList<>(); + for (LocMast loc : locMasts) { + Integer lev = loc.getLev1(); + if (lev != null && lev >= 6 && lev <= 10) { + filteredLocMasts.add(loc); + } + } + locMasts = filteredLocMasts; + }else{ + List<LocMast> filteredLocMasts = new ArrayList<>(); + for (LocMast loc : locMasts) { + Integer lev = loc.getLev1(); + if (lev != null && lev >= 1 && lev <= 5) { + filteredLocMasts.add(loc); + } + } + locMasts = filteredLocMasts; } - String shallowLoc = Utils.getDeepLoc(slaveProperties, locMast1.getLocNo()); - LocMast locMast2 = locMastService.selectOne(new EntityWrapper<LocMast>().eq("loc_no", shallowLoc).eq("loc_sts", "O")); - if (!Cools.isEmpty(locMast2)) { - locMast = locMast2; - break; + for (LocMast locMast1 : locMasts) { + if (!VersionUtils.locMoveCheckLocTypeComplete(locMast1, locTypeDto)) { + continue; + } + + if (!Cools.isEmpty(locMast1)) { + locMast = locMast1; + break; + } + } } } - if (!Cools.isEmpty(locMast) && !basCrnpService.checkSiteError(crnNo, true)) { + if (!basCrnpService.checkSiteError(crnNo, true)) { locMast = null; } // 閫掑綊鏌ヨ if (Cools.isEmpty(locMast) || !locMast.getLocSts().equals("O")) { // 褰撳墠宸烽亾鏃犵┖搴撲綅鏃讹紝閫掑綊璋冩暣鑷充笅涓�宸烽亾锛屾绱㈠叏閮ㄥ贩閬撴棤鏋滃悗锛岃烦鍑洪�掑綊 - if (times < rowCount) { + if (times < 1) { times = times + 1; - return getLocNoRun(1, staDescId, sourceStaNo, matnr, batch, grade,moveCrnNo, locTypeDto, times); + return getLocNoRun(whsType, staDescId, sourceStaNo, matnr, batch, grade,moveCrnNo+1, locTypeDto, times); } -// // 2.搴撲綅褰撳墠鎵�灞炲昂瀵告棤绌哄簱浣嶆椂锛岃皟鏁村昂瀵稿弬鏁帮紝鍚戜笂鍏煎妫�绱㈠簱浣� -// if (locTypeDto.getLocType1() < 2) { -// int i = locTypeDto.getLocType1() + 1; -// locTypeDto.setLocType1((short)i); -// return getLocNo(1, staDescId, sourceStaNo, matnr,batch,grade, locTypeDto, 0); -// } log.error("绯荤粺娌℃湁绌哄簱浣嶏紒锛侊紒 灏哄瑙勬牸锛� {}锛� 杞娆℃暟锛歿}", JSON.toJSONString(locTypeDto), times); - throw new CoolException("娌℃湁绌哄簱浣�"); + throw new CoolException("娌℃湁绌哄簱浣嶆垨鍫嗗灈鏈哄紓甯�"); } String locNo = locMast.getLocNo(); @@ -339,6 +388,8 @@ startupDto.setCrnNo(crnNo); startupDto.setSourceStaNo(sourceStaNo); startupDto.setLocNo(locNo); + log.info("搴撲綅妫�绱㈣�楁椂: {} ms", System.currentTimeMillis() - start); + return startupDto; } } -- Gitblit v1.9.1