From f6bde002739b7f7a1f48dddab9fab4959f286668 Mon Sep 17 00:00:00 2001 From: pjb <pjb123456> Date: 星期二, 22 七月 2025 16:36:06 +0800 Subject: [PATCH] 回滚订单完成扣减数量 --- src/main/java/com/zy/common/service/CommonService.java | 1288 +++++++++++++++++++++++++++++++++++++++++++++++++++------ 1 files changed, 1,139 insertions(+), 149 deletions(-) diff --git a/src/main/java/com/zy/common/service/CommonService.java b/src/main/java/com/zy/common/service/CommonService.java index cd4b253..4a39889 100644 --- a/src/main/java/com/zy/common/service/CommonService.java +++ b/src/main/java/com/zy/common/service/CommonService.java @@ -3,23 +3,28 @@ import com.alibaba.fastjson.JSON; import com.baomidou.mybatisplus.mapper.EntityWrapper; import com.baomidou.mybatisplus.mapper.Wrapper; -import com.core.common.Arith; import com.core.common.Cools; import com.core.exception.CoolException; import com.zy.asrs.entity.*; +import com.zy.asrs.entity.result.FindLocNoAttributeVo; +import com.zy.asrs.mapper.LocMastMapper; +import com.zy.asrs.mapper.WrkMastMapper; import com.zy.asrs.service.*; import com.zy.asrs.utils.Utils; import com.zy.asrs.utils.VersionUtils; import com.zy.common.model.LocTypeDto; -import com.zy.common.model.Shelves; import com.zy.common.model.StartupDto; import com.zy.common.properties.SlaveProperties; +import com.zy.common.web.param.SearchLocParam; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; +import org.springframework.transaction.annotation.Propagation; import org.springframework.transaction.annotation.Transactional; -import java.util.List; +import javax.annotation.Resource; +import java.util.*; +import java.util.stream.Collectors; /** * 璐ф灦鏍稿績鍔熻兘 @@ -36,6 +41,8 @@ @Autowired private RowLastnoService rowLastnoService; @Autowired + private RowLastnoTypeService rowLastnoTypeService; + @Autowired private BasCrnpService basCrnpService; @Autowired private StaDescService staDescService; @@ -47,10 +54,19 @@ private LocDetlService locDetlService; @Autowired private SlaveProperties slaveProperties; + @Autowired + private WrkDetlService wrkDetlService; + + @Resource + private WrkMastMapper wrkMastMapper; + + @Resource + private LocMastMapper locMastMapper; /** * 鐢熸垚宸ヤ綔鍙� - * @param wrkMk 0:鍏ュ簱 1 - 3000 ; 1:鎷f枡/骞舵澘/鐩樼偣 3001 - 6000 ; 2: 鍑哄簱 6001 -9000 ; 3:鍏朵粬 9001 -9999 + * + * @param wrkMk * @return workNo(宸ヤ綔鍙�) */ public int getWorkNo(Integer wrkMk) { @@ -62,17 +78,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); } @@ -80,46 +96,466 @@ 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; + } + /** * 妫�绱㈠簱浣嶅彿 - * @param whsType 绫诲瀷 1:鍙屾繁寮忚揣鏋� - * @param staDescId 璺緞宸ヤ綔绫诲瀷 - * @param sourceStaNo 婧愮珯 - * @param matNos 鍟嗗搧缂栧彿闆嗗悎 + * + * @param staDescId 璺緞ID + * @param sourceStaNo 婧愮珯 + * @param findLocNoAttributeVo 灞炴�� + * @param locTypeDto 绫诲瀷 * @return locNo 妫�绱㈠埌鐨勫簱浣嶅彿 */ @Transactional - public StartupDto getLocNo(Integer whsType, Integer staDescId, Integer sourceStaNo, List<String> matNos, LocTypeDto locTypeDto, int times) { - whsType = getWhsType(sourceStaNo, times); + public StartupDto getLocNo(Integer staDescId, Integer sourceStaNo, FindLocNoAttributeVo findLocNoAttributeVo, LocTypeDto locTypeDto) { + try { + Integer whsType = Utils.GetWhsType(sourceStaNo); + RowLastno rowLastno = rowLastnoService.selectById(whsType); + RowLastnoType rowLastnoType = rowLastnoTypeService.selectById(rowLastno.getTypeId()); + /** + * 搴撳瀷 1: 鏍囧噯鍫嗗灈鏈哄簱 2: 骞冲簱 3: 绌挎鏉� 4: 鍥涘悜杞� 5: AGV 0: 鏈煡 + */ + switch (rowLastnoType.getType()) { + case 1: + return getLocNoRun(whsType, staDescId, sourceStaNo, findLocNoAttributeVo, 0, locTypeDto, 0); + case 2: + log.error("绔欑偣={} 鏈煡璇㈠埌瀵瑰簲鐨勮鍒�", sourceStaNo); + break; + case 3: + log.error("绔欑偣={} 鏈煡璇㈠埌瀵瑰簲鐨勮鍒�", sourceStaNo); + break; + case 4: + return getLocNoRun4(whsType, staDescId, sourceStaNo, findLocNoAttributeVo, 4, locTypeDto, 0); + case 5: + return getLocNoRun5(whsType, staDescId, sourceStaNo, findLocNoAttributeVo, 0, locTypeDto, 0); + default: + log.error("绔欑偣={} 鏈煡璇㈠埌瀵瑰簲鐨勮鍒�", sourceStaNo); + break; + } + + } catch (Exception e) { + log.error("绔欑偣={} 鏈煡璇㈠埌瀵瑰簲鐨勮鍒�", sourceStaNo); + } + return null; + } + + @Transactional(propagation = Propagation.REQUIRED) + public StartupDto getLocNoNew(Integer staDescId, Integer sourceStaNo, FindLocNoAttributeVo findLocNoAttributeVo, int locArea) { + + // 鐩爣搴撲綅 + LocMast locMast; + + // 鍏ョ┖妗跺簱 + if (staDescId == 1 && locArea == 2) { + List<WrkMast> wrkMastList = wrkMastMapper.selectLastInEmptyLoc(); // 鍓嶉潰鍏ョ┖妗跺簱鐨勪换鍔�(鏈墽琛屽爢鍨涙満鍏ュ簱) + + if (wrkMastList.size() == 0) { + // 鍙栨柊搴撲綅缁勭殑绗竴涓簱浣� + List<LocMast> locMasts = locMastService.selectList(new EntityWrapper<LocMast>().eq("crn_no", 4).eq("loc_sts", "O")); + List<LocMast> collect = locMasts.stream().filter(locMast1 -> locMast1.getRow1() == 9 || locMast1.getRow1() == 11).collect(Collectors.toList()); + List<LocMast> collect1 = locMasts.stream().filter(locMast1 -> locMast1.getRow1() == 10 || locMast1.getRow1() == 12).collect(Collectors.toList()); // 绗竴涓厛鏀捐繖涓ゆ帓 + if (collect.size() == 0 || collect1.size() == 0) { + log.error("-----绌烘《搴撴棤绌哄簱浣�----"); + throw new CoolException("绌烘《搴撴棤绌哄簱浣�"); + } + // 鍙敤搴撲綅缁� + List<LocMast> locMastList = new ArrayList<>(); + for(LocMast locMast1:collect) { + Optional<LocMast> first = collect1.stream().filter(locMast2 -> locMast1.getRow1() + 1 == locMast2.getRow1() && Objects.equals(locMast1.getLev1(), locMast2.getLev1()) + && Objects.equals(locMast1.getBay1(), locMast2.getBay1())).findFirst(); + first.ifPresent(locMastList::add); + } + + if (locMastList.size() == 0) { + log.error("-----绌烘《搴撴棤瀵瑰簲绌虹┖妗剁粍----"); + throw new CoolException("绌烘《搴撴棤瀵瑰簲绌虹┖妗剁粍"); + } + String model = findLocNoAttributeVo.getModel(); // 褰撳墠妗剁被鍨� + if (model.equals("208L") && locMastList.size() <= 40 * 2 * 2) { // 鏈�涓婇潰涓�灞傚彧鑳芥斁208L锛屽簱浣嶅墿浣欓噺涓嶅鏃讹紝濡傛灉鏄�208L妗跺叆搴擄紝鍒欏厛浠庢渶椤跺眰鏀� + locMastList = locMastList.stream().sorted(Comparator.comparing(LocMast::getLev1).reversed().thenComparing(LocMast::getBay1).thenComparing(LocMast::getRow1)).collect(Collectors.toList()); + } else { + locMastList = locMastList.stream().sorted(Comparator.comparing(LocMast::getLev1).thenComparing(LocMast::getBay1).thenComparing(LocMast::getRow1)).collect(Collectors.toList()); + } + locMast = locMastList.get(0); + + } else { + WrkMast wrkMast = wrkMastList.get(0); // 鏈�鍚庝竴涓叆绌烘《搴撲换鍔� + // 鍓嶄竴涓换鍔℃《绫诲瀷 + String oldModel = wrkMast.getPdcType(); + // 鍓嶄竴涓换鍔″熬鎵樻爣璇� + Integer oldCtnType = wrkMast.getCtnType(); + // 褰撳墠妗剁被鍨� + String matnr = findLocNoAttributeVo.getMatnr(); + if(findLocNoAttributeVo.getMatnr().equals(wrkMast.getPdcType())) { // 褰撳墠妗朵笌鍓嶆《鏄竴绉嶇被鍨� + // 褰撳墠妗剁被鍨嬬殑浠诲姟鏈夊嚑涓� + long count = wrkMastList.stream().filter(wrkMast1 -> wrkMast1.getPdcType().equals(matnr)).count(); + if (count % 2 == 0) { // 鍋舵暟锛屽彇涓�缁勬柊搴撲綅 + // 鍙栨柊搴撲綅缁勭殑绗竴涓簱浣� + List<LocMast> locMasts = locMastService.selectList(new EntityWrapper<LocMast>().eq("crn_no", 4).eq("loc_sts", "O")); + List<LocMast> collect = locMasts.stream().filter(locMast1 -> locMast1.getRow1() == 9 || locMast1.getRow1() == 11).collect(Collectors.toList()); + List<LocMast> collect1 = locMasts.stream().filter(locMast1 -> locMast1.getRow1() == 10 || locMast1.getRow1() == 12).collect(Collectors.toList()); // 绗竴涓厛鏀捐繖涓ゆ帓 + if (collect.size() == 0 || collect1.size() == 0) { + log.error("-----绌烘《搴撴棤绌哄簱浣�----"); + throw new CoolException("绌烘《搴撴棤绌哄簱浣�"); + } + // 鍙敤搴撲綅缁� + List<LocMast> locMastList = new ArrayList<>(); + for(LocMast locMast1:collect) { + Optional<LocMast> first = collect1.stream().filter(locMast2 -> locMast1.getRow1() + 1 == locMast2.getRow1() && Objects.equals(locMast1.getLev1(), locMast2.getLev1()) + && Objects.equals(locMast1.getBay1(), locMast2.getBay1())).findFirst(); + first.ifPresent(locMastList::add); + } + + if (locMastList.size() == 0) { + log.error("-----绌烘《搴撴棤瀵瑰簲绌虹┖妗剁粍----"); + throw new CoolException("绌烘《搴撴棤瀵瑰簲绌虹┖妗剁粍"); + } + String model = findLocNoAttributeVo.getModel(); // 褰撳墠妗剁被鍨� + if (model.equals("208L") && locMastList.size() <= 40 * 2 * 2) { // 鏈�涓婇潰涓�灞傚彧鑳芥斁208L锛屽簱浣嶅墿浣欓噺涓嶅鏃讹紝濡傛灉鏄�208L妗跺叆搴擄紝鍒欏厛浠庢渶椤跺眰鏀� + locMastList = locMastList.stream().sorted(Comparator.comparing(LocMast::getLev1).reversed().thenComparing(LocMast::getBay1).thenComparing(LocMast::getRow1)).collect(Collectors.toList()); + } else { + locMastList = locMastList.stream().sorted(Comparator.comparing(LocMast::getLev1).thenComparing(LocMast::getBay1).thenComparing(LocMast::getRow1)).collect(Collectors.toList()); + } + locMast = locMastList.get(0); + } else { // 濂囨暟锛屽彇鍓嶄竴搴撲綅瀵瑰簲鐨勭┖搴撲綅 + String locNo = wrkMast.getLocNo(); + int row = Integer.parseInt(locNo.substring(0, 2)); + if(row == 10 || row == 12) { + String newLocNo =(row == 10 ? "09" : "11") + locNo.substring(2); + locMast = locMastService.selectOne(new EntityWrapper<LocMast>().eq("loc_no", newLocNo).eq("loc_sts","O")); + if (locMast == null) { + log.error("-----涓庡墠闈㈡《绫诲瀷涓�鏍凤紝鍓嶉潰璇ユ《绫诲瀷浠诲姟鏁版槸濂囨暟锛�10锛�12鎺�,浣嗘槸瀵瑰簲搴撲綅涓嶄负绌�----"); + throw new CoolException("涓庡墠闈㈡《绫诲瀷涓�鏍凤紝鍓嶉潰璇ユ《绫诲瀷浠诲姟鏁版槸濂囨暟锛屾槸10锛�12鎺�,浣嗘槸瀵瑰簲搴撲綅涓嶄负绌�"); + } + } else { + log.error("-----涓庡墠闈㈡《绫诲瀷涓�鏍凤紝鍓嶉潰璇ユ《绫诲瀷浠诲姟鏁版槸濂囨暟锛屼絾鏄笉鏄�10锛�12鎺�----"); + throw new CoolException("涓庡墠闈㈡《绫诲瀷涓�鏍凤紝鍓嶉潰璇ユ《绫诲瀷浠诲姟鏁版槸濂囨暟锛屼絾鏄笉鏄�10锛�12鎺�"); + } + } + } else { // 褰撳墠妗朵笌鍓嶆《涓嶆槸涓�绉嶇被鍨� + if(oldCtnType == 1) { // 鍓嶉潰鏄熬妗� + // 鍙栨柊搴撲綅缁勭殑绗竴涓簱浣� + List<LocMast> locMasts = locMastService.selectList(new EntityWrapper<LocMast>().eq("crn_no", 4).eq("loc_sts", "O")); + List<LocMast> collect = locMasts.stream().filter(locMast1 -> locMast1.getRow1() == 9 || locMast1.getRow1() == 11).collect(Collectors.toList()); + List<LocMast> collect1 = locMasts.stream().filter(locMast1 -> locMast1.getRow1() == 10 || locMast1.getRow1() == 12).collect(Collectors.toList()); // 绗竴涓厛鏀捐繖涓ゆ帓 + if (collect.size() == 0 || collect1.size() == 0) { + log.error("-----绌烘《搴撴棤绌哄簱浣�----"); + throw new CoolException("绌烘《搴撴棤绌哄簱浣�"); + } + // 鍙敤搴撲綅缁� + List<LocMast> locMastList = new ArrayList<>(); + for(LocMast locMast1:collect) { + Optional<LocMast> first = collect1.stream().filter(locMast2 -> locMast1.getRow1() + 1 == locMast2.getRow1() && Objects.equals(locMast1.getLev1(), locMast2.getLev1()) + && Objects.equals(locMast1.getBay1(), locMast2.getBay1())).findFirst(); + first.ifPresent(locMastList::add); + } + + if (locMastList.size() == 0) { + log.error("-----绌烘《搴撴棤瀵瑰簲绌虹┖妗剁粍----"); + throw new CoolException("绌烘《搴撴棤瀵瑰簲绌虹┖妗剁粍"); + } + String model = findLocNoAttributeVo.getModel(); // 褰撳墠妗剁被鍨� + if (model.equals("208L") && locMastList.size() <= 40 * 2 * 2) { // 鏈�涓婇潰涓�灞傚彧鑳芥斁208L锛屽簱浣嶅墿浣欓噺涓嶅鏃讹紝濡傛灉鏄�208L妗跺叆搴擄紝鍒欏厛浠庢渶椤跺眰鏀� + locMastList = locMastList.stream().sorted(Comparator.comparing(LocMast::getLev1).reversed().thenComparing(LocMast::getBay1).thenComparing(LocMast::getRow1)).collect(Collectors.toList()); + } else { + locMastList = locMastList.stream().sorted(Comparator.comparing(LocMast::getLev1).thenComparing(LocMast::getBay1).thenComparing(LocMast::getRow1)).collect(Collectors.toList()); + } + locMast = locMastList.get(0); + } else { // 鍓嶉潰涓嶆槸灏炬《 + // 鍒ゆ柇鍓嶉潰鍏ョ┖妗跺簱浠诲姟鏁伴噺(鏈墽琛屽爢鍨涙満鍏ュ簱) + long count = wrkMastList.stream().filter(wrkMast1 -> wrkMast1.getPdcType().equals(oldModel)).count(); + if (count % 2 == 0) { // 鍋舵暟锛屽彲浠ュ叆搴� + // 鍙栨柊搴撲綅缁勭殑绗竴涓簱浣� + List<LocMast> locMasts = locMastService.selectList(new EntityWrapper<LocMast>().eq("crn_no", 4).eq("loc_sts", "O")); + List<LocMast> collect = locMasts.stream().filter(locMast1 -> locMast1.getRow1() == 9 || locMast1.getRow1() == 11).collect(Collectors.toList()); + List<LocMast> collect1 = locMasts.stream().filter(locMast1 -> locMast1.getRow1() == 10 || locMast1.getRow1() == 12).collect(Collectors.toList()); // 绗竴涓厛鏀捐繖涓ゆ帓 + if (collect.size() == 0 || collect1.size() == 0) { + log.error("-----绌烘《搴撴棤绌哄簱浣�----"); + throw new CoolException("绌烘《搴撴棤绌哄簱浣�"); + } + // 鍙敤搴撲綅缁� + List<LocMast> locMastList = new ArrayList<>(); + for(LocMast locMast1:collect) { + Optional<LocMast> first = collect1.stream().filter(locMast2 -> locMast1.getRow1() + 1 == locMast2.getRow1() && Objects.equals(locMast1.getLev1(), locMast2.getLev1()) + && Objects.equals(locMast1.getBay1(), locMast2.getBay1())).findFirst(); + first.ifPresent(locMastList::add); + } + + if (locMastList.size() == 0) { + log.error("-----绌烘《搴撴棤瀵瑰簲绌虹┖妗剁粍----"); + throw new CoolException("绌烘《搴撴棤瀵瑰簲绌虹┖妗剁粍"); + } + String model = findLocNoAttributeVo.getModel(); // 褰撳墠妗剁被鍨� + if (model.equals("208L") && locMastList.size() <= 40 * 2 * 2) { // 鏈�涓婇潰涓�灞傚彧鑳芥斁208L锛屽簱浣嶅墿浣欓噺涓嶅鏃讹紝濡傛灉鏄�208L妗跺叆搴擄紝鍒欏厛浠庢渶椤跺眰鏀� + locMastList = locMastList.stream().sorted(Comparator.comparing(LocMast::getLev1).reversed().thenComparing(LocMast::getBay1).thenComparing(LocMast::getRow1)).collect(Collectors.toList()); + } else { + locMastList = locMastList.stream().sorted(Comparator.comparing(LocMast::getLev1).thenComparing(LocMast::getBay1).thenComparing(LocMast::getRow1)).collect(Collectors.toList()); + } + locMast = locMastList.get(0); + } else { // 濂囨暟锛屼笉鍙互鍏ュ簱 + // 鑷姩缁欏墠闈换鍔¤ˉ灏炬《淇″彿 + wrkMastService.updateCtnType(wrkMast); + log.error("-----涓庡墠闈㈡《绫诲瀷涓嶄竴鏍凤紝鍓嶉潰妗朵笉鏄熬妗讹紝鍓嶉潰璇ユ《绫诲瀷浠诲姟鏁颁笉鏄伓鏁帮紝涓嶈兘鍏ュ簱----"); + throw new CoolException("涓庡墠闈㈡《绫诲瀷涓嶄竴鏍凤紝鍓嶉潰妗朵笉鏄熬妗讹紝鍓嶉潰璇ユ《绫诲瀷浠诲姟鏁颁笉鏄伓鏁帮紝涓嶈兘鍏ュ簱"); + } + } + } + } + + } else if ((staDescId == 1 && locArea == 1) || staDescId == 10) { // 婊℃澘鍏ユ垚鍝佸簱鎴栬�呯┖鏉垮叆鎴愬搧搴� + + // 鍏ユ垚鍝佸簱鎽嗘斁瑙勫垯 鍒ゆ柇鍙敤鍫嗗灈鏈鸿嚜鍔�-鏃犳姤璀� 鎸夊眰鍒楁帓椤哄簭浠庝笅寰�涓婏紝浠庡墠寰�鍚庢帓 鍏堟繁搴撲綅鍦ㄦ祬搴撲綅 鏈�涓婇潰涓�灞傚彧鑳芥斁208L妗�(鍓╀綑搴撲綅杈惧埌涓�涓槇鍊�208L灏卞厛浠庢渶涓婇潰寮�濮嬫斁锛屼笅闈㈢暀缁欏叾浠栬揣鐗�-鍚庣画浼樺寲) + + List<BasCrnp> basCrnps = basCrnpService.selectList(new EntityWrapper<BasCrnp>().eq("crn_sts", 3).eq("crn_err", 0).in("crn_no",1,2,3) + .eq("in_enable","Y")); + if (basCrnps.size() == 0) { + log.error("鍏ュ簱璇锋眰搴撲綅澶辫触锛屾病鏈夎仈鏈哄爢鍨涙満鎴栧爢鍨涙満寮傚父"); + throw new CoolException("鍏ュ簱璇锋眰搴撲綅澶辫触锛屾病鏈夎仈鏈哄爢鍨涙満鎴栧爢鍨涙満寮傚父"); + } + + List<BasCrnp> basCrnpList = new ArrayList<>(); + for(BasCrnp basCrnp: basCrnps) { + Integer count = locMastMapper.selectCount(new EntityWrapper<LocMast>().eq("crn_no", basCrnp.getCrnNo()).eq("loc_sts", "S")); + basCrnp.setWrkNo(count); + basCrnpList.add(basCrnp); + } + + basCrnpList = basCrnpList.stream().sorted(Comparator.comparing(BasCrnp::getWrkNo).thenComparing(BasCrnp::getCrnNo,((o1, o2) -> { + // 瀹氫箟 2 鈫� 3 鈫� 1 鐨勪紭鍏堢骇 + int order1 = getCustomOrder(o1); + int order2 = getCustomOrder(o2); + return Integer.compare(order1, order2); + }))).collect(Collectors.toList()); + + // 鍏ュ簱妗跺瀷 + String model = findLocNoAttributeVo.getModel(); + + locMast = null; + + for(BasCrnp basCrnp:basCrnpList) { + Integer crnNo = basCrnp.getCrnNo(); + Wrapper<LocMast> wrapper = new EntityWrapper<LocMast>().eq("loc_sts", 'O') + .eq("crn_no", crnNo).orderBy("lev1").orderBy("bay1").orderBy("row1"); + // 鍏ュ簱妗跺瀷鏄笉鏄�208L + if (model == null || !model.equals("208L")) { + wrapper.ne("lev1", 11); + } + if (crnNo == 1) { + wrapper.in("row1", 1, 4); + } + locMast = locMastService.selectOne(wrapper); + if (locMast != null) { + break; + } + // 娣卞簱浣嶆病鏈変簡鍒欒幏鍙栦竴涓祬搴撲綅 + if (crnNo == 1) { + locMast = locMastService.selectOne(wrapper.in("row1", 2, 3)); + if (locMast != null) { + int count = locMastService.selectCount(wrapper); + if (count <= 10) { + locMast = null; + } else { + break; + } + } + } + } + + if (locMast == null) { + List<Integer> collect = basCrnps.stream().map(BasCrnp::getCrnNo).collect(Collectors.toList()); + log.error("-----{}鍫嗗灈鏈哄簱浣嶄笉瓒�----",collect.toString()); + throw new CoolException(collect.toString() + "鍫嗗灈鏈哄簱浣嶄笉瓒�"); + } + } else { + log.error("鍏ュ簱绫诲瀷閿欒锛宻taDescId={}", staDescId); + throw new CoolException("鍏ュ簱绫诲瀷閿欒锛宻taDescId=" + staDescId); + } + // 杩斿洖dto StartupDto startupDto = new StartupDto(); - // 鐢熸垚宸ヤ綔鍙� - int workNo = getWorkNo(0); - RowLastno rowLastno = rowLastnoService.selectById(whsType); - if (Cools.isEmpty(rowLastno)) { - throw new CoolException("鏁版嵁寮傚父锛岃鑱旂郴绠$悊鍛�"); + StaDesc staDesc = staDescService.selectOne(new EntityWrapper<StaDesc>() + .eq("type_no", staDescId) + .eq("stn_no", sourceStaNo) + .eq("crn_no", locMast.getCrnNo())); + if (Cools.isEmpty(staDesc)) { + log.error("type_no={},stn_no={},crn_no={}", staDescId, sourceStaNo, locMast.getCrnNo()); + throw new CoolException("鍏ュ簱璺緞涓嶅瓨鍦�"); + } else { + BasDevp staNo = basDevpService.selectById(staDesc.getCrnStn()); + if (!staNo.getAutoing().equals("Y")) { + log.error("鐩爣绔�" + staDesc.getCrnStn() + "涓嶅彲鐢�"); + throw new CoolException("鐩爣绔�" + staDesc.getCrnStn() + "涓嶅彲鐢�"); + } + startupDto.setStaNo(staNo.getDevNo()); } - // ===============>>>> 寮�濮嬫墽琛� - int curRow = rowLastno.getCurrentRow(); + // 鐢熸垚宸ヤ綔鍙� + int workNo = getWorkNo(0); + startupDto.setWorkNo(workNo); + startupDto.setCrnNo(locMast.getCrnNo()); + startupDto.setSourceStaNo(sourceStaNo); + startupDto.setLocNo(locMast.getLocNo()); + return startupDto; + } + + // 杈呭姪鏂规硶锛氬畾涔� crn_no 鐨勬帓搴忎紭鍏堢骇 + private static int getCustomOrder(Integer crnNo) { + switch (crnNo) { + case 2: return 1; // 2 鎺掔涓� + case 3: return 2; // 3 鎺掔浜� + case 1: return 3; // 1 鎺掔涓� + default: return 4; // 鍏朵粬鍊兼帓鏈�鍚庯紙濡傛灉鏈夛級 + } + } + + @Transactional(propagation = Propagation.REQUIRED) + public StartupDto getLocNo(SearchLocParam param, Integer staNo) { + + // 杩斿洖dto + StartupDto startupDto = new StartupDto(); + + startupDto.setWorkNo(getWorkNo(0)); // 宸ヤ綔鍙� + startupDto.setSourceStaNo(param.getSourceStaNo()); // 婧愮珯鐐� + startupDto.setStaNo(staNo); // 鐩爣绔欑偣 + return startupDto; + } + + /** + * 妫�绱㈠簱浣嶅彿 + * + * @param whsType 绫诲瀷 1:鍙屾繁寮忚揣鏋� + * @param staDescId 璺緞ID + * @param sourceStaNo 婧愮珯 + * @param findLocNoAttributeVo 灞炴�� + * @param moveCrnNo 婧� + * @param locTypeDto 绫诲瀷 + * @param times 杞娆℃暟 + * @return locNo 妫�绱㈠埌鐨勫簱浣嶅彿 + */ + @Transactional + public StartupDto getLocNoRun(Integer whsType, Integer staDescId, Integer sourceStaNo, FindLocNoAttributeVo findLocNoAttributeVo, Integer moveCrnNo, LocTypeDto locTypeDto, int times) { + + // 鍒濆鍖栧弬鏁� + int crnNo = 0; //鍫嗗灈鏈哄彿 + int nearRow = 0; //鏈�娴呭簱浣嶆帓 + int curRow = 0; //鏈�娣卞簱浣嶆帓 + int rowCount = 0; //杞杞 + LocMast locMast = null; // 鐩爣搴撲綅 + + StartupDto startupDto = new StartupDto(); + RowLastno rowLastno = rowLastnoService.selectById(whsType); + if (Cools.isEmpty(rowLastno)) { + throw new CoolException("鏁版嵁寮傚父锛岃鑱旂郴绠$悊鍛�===>搴撲綅瑙勫垯鏈煡"); + } + RowLastnoType rowLastnoType = rowLastnoTypeService.selectById(rowLastno.getTypeId()); + if (Cools.isEmpty(rowLastnoType)) { + throw new CoolException("鏁版嵁寮傚父锛岃鑱旂郴绠$悊鍛�===銆嬪簱浣嶈鍒欑被鍨嬫湭鐭�"); + } int sRow = rowLastno.getsRow(); int eRow = rowLastno.geteRow(); - int crn_qty = rowLastno.getCrnQty(); - int rowCount = eRow - sRow + 1; - // 鐩爣鍫嗗灈鏈哄彿 - int crnNo = 0; - // 鐩爣搴撲綅 - LocMast locMast = null; + int crnNumber = rowLastno.getCrnQty(); - // 闈犺繎鎽嗘斁瑙勫垯 --- 鍚屽ぉ鍚岃鏍肩墿鏂� - if (!Cools.isEmpty(matNos)) { - List<String> locNos = locDetlService.getSameDetlToday(matNos.get(0), sRow, eRow); + + // ===============>>>> 寮�濮嬫墽琛� + curRow = rowLastno.getCurrentRow(); + + if (!Cools.isEmpty(moveCrnNo) && moveCrnNo != 0) { + crnNumber = moveCrnNo; + if (times == 0) { + curRow = moveCrnNo * 4 - 1; + } else { + curRow = moveCrnNo * 4 - 2; + } + } + + //姝ょ▼搴忕敤浜庝紭鍖栧爢鍨涙満寮傚父鏃剁殑杩愯鏃堕棿 + for (int i = times; i < crnNumber * 2; i++) { + int[] locNecessaryParameters = Utils.LocNecessaryParameters(rowLastno, 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").eq("whs_type", rowLastnoType.getType().longValue())); + int crnCountO = wrkMastService.selectCount(new EntityWrapper<WrkMast>().eq("crn_no", crnNo).le("io_type", 100)); + if (locMasts.size() - crnCountO <= 2) { + log.error(crnNo + "鍙峰爢鍨涙満娌℃湁绌哄簱浣嶏紒锛侊紒 灏哄瑙勬牸锛� {}锛� 杞娆℃暟锛歿}", JSON.toJSONString(locTypeDto), times); + nearRow = 0; + times++; + continue; + } + break; + } else { + times++; + } + } + if (nearRow == 0) { + throw new CoolException("鏃犲彲鐢ㄥ爢鍨涙満"); + } + + boolean signRule1 = false; + boolean signRule2 = false; + + + if (Utils.BooleanWhsTypeStaIoType(rowLastno)) { + // 闈犺繎鎽嗘斁瑙勫垯 --- 鍚屽ぉ鍚岃鏍肩墿鏂� //鍒嗙鐗� + if (!Cools.isEmpty(findLocNoAttributeVo.getMatnr()) && staDescId == 1) { + signRule1 = true; + } + // 闈犺繎鎽嗘斁瑙勫垯 --- 鍚屽ぉ鍚岃鏍肩墿鏂� //浜掗�氱増 + if (!Cools.isEmpty(findLocNoAttributeVo.getMatnr()) && staDescId == 1) { + signRule2 = true; + } + + if (!Cools.isEmpty(findLocNoAttributeVo.getMatnr()) && (staDescId == 11 || staDescId == 111)) { + signRule1 = true; + } + } + + if (signRule1) { + if (nearRow != curRow) { + List<LocMast> locMasts = locMastService.selectList(new EntityWrapper<LocMast>() + .eq("row1", nearRow).eq("loc_sts", "O").eq("whs_type", rowLastnoType.getType().longValue())); + for (LocMast locMast1 : locMasts) { + //鑾峰彇宸烽亾 +// List<String> groupOutsideLocCrn = Utils.getGroupOutLocCrn(curRow,nearRow,locMast1.getLocNo(), curRow>nearRow); +// LocMast locMastGro = locMastService.selectById(wrkMast.getLocNo()); + //鑾峰彇鐩爣搴撲綅鎵�鍦ㄥ贩閬撴渶娴呴潪绌哄簱浣� + LocMast locMastF = locMastService.selectLocByLocStsPakInF(curRow, nearRow, locMast1, rowLastnoType.getType().longValue()); + if (!Cools.isEmpty(locMastF) && locMastF.getLocSts().equals("F")) { + LocDetl locDetl = locDetlService.selectOne(new EntityWrapper<LocDetl>().eq("loc_no", locMastF.getLocNo())); + if (!Cools.isEmpty(locDetl) && findLocNoAttributeVo.beSimilar(locDetl)) { + //鑾峰彇鐩爣搴撲綅鎵�鍦ㄥ贩閬撴渶娣辩┖搴撲綅 + locMast = locMastService.selectLocByLocStsPakInO(curRow, nearRow, locMast1, rowLastnoType.getType().longValue()); + break; + } + } + } + } + } else if (signRule2) { + List<String> locNos = locDetlService.getSameDetlToday(findLocNoAttributeVo.getMatnr(), sRow, eRow); for (String locNo : locNos) { if (Utils.isShallowLoc(slaveProperties, locNo)) { continue; @@ -128,7 +564,7 @@ // 妫�娴嬬洰鏍囧簱浣嶆槸鍚︿负绌哄簱浣� LocMast shallowLoc = locMastService.selectById(shallowLocNo); if (shallowLoc != null && shallowLoc.getLocSts().equals("O")) { - if (VersionUtils.locMoveCheckLocType(shallowLoc, locTypeDto)) { + if (VersionUtils.locMoveCheckLocTypeComplete(shallowLoc, locTypeDto)) { if (basCrnpService.checkSiteError(shallowLoc.getCrnNo(), true)) { locMast = shallowLoc; crnNo = locMast.getCrnNo(); @@ -139,21 +575,136 @@ } } - // 闈犺繎鎽嗘斁瑙勫垯 --- 绌烘墭 - if (staDescId == 10) { - List<LocMast> locMasts = locMastService.selectList(new EntityWrapper<LocMast>().eq("loc_sts", "D").ge("row1", sRow).le("row1", eRow)); - if (locMasts.size() > 0) { +// // 闈犺繎鎽嗘斁瑙勫垯 --- 绌烘墭 //鍒嗙鐗� +// if (staDescId == 10 && Utils.BooleanWhsTypeStaIoType(whsType)) { +// 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 && Utils.BooleanWhsTypeStaIoType(rowLastno)) { + List<LocMast> locMasts = locMastService.selectList(new EntityWrapper<LocMast>() + .eq("loc_sts", "D").ge("row1", sRow).le("row1", eRow).eq("whs_type", rowLastnoType.getType().longValue())); + if (!locMasts.isEmpty()) { for (LocMast loc : locMasts) { if (Utils.isShallowLoc(slaveProperties, loc.getLocNo())) { continue; } - String shallowLocNo = Utils.getShallowLoc(slaveProperties, loc.getLocNo()); + String shallowLocNo = Utils.getShallowLoc(slaveProperties, loc.getLocNo()); // 妫�娴嬬洰鏍囧簱浣嶆槸鍚︿负绌哄簱浣� LocMast shallowLoc = locMastService.selectById(shallowLocNo); if (shallowLoc != null && shallowLoc.getLocSts().equals("O")) { - if (basCrnpService.checkSiteError(shallowLoc.getCrnNo(), true)) { - locMast = shallowLoc; - crnNo = locMast.getCrnNo(); + if (VersionUtils.locMoveCheckLocTypeComplete(shallowLoc, locTypeDto)) { + if (basCrnpService.checkSiteError(shallowLoc.getCrnNo(), true)) { + locMast = shallowLoc; + crnNo = locMast.getCrnNo(); + break; + } + } + } + } + } + } + + Wrapper<StaDesc> wrapper = null; + StaDesc staDesc = null; + BasDevp staNo = null; + + if (Utils.BooleanWhsTypeSta(rowLastno, staDescId)) { + // 鑾峰彇鐩爣绔� + wrapper = new EntityWrapper<StaDesc>() + .eq("type_no", staDescId) + .eq("stn_no", sourceStaNo) + .eq("crn_no", crnNo); + staDesc = staDescService.selectOne(wrapper); + if (Cools.isEmpty(staDesc)) { + log.error("type_no={},stn_no={},crn_no={}", staDescId, sourceStaNo, crnNo); +// throw new CoolException("鍏ュ簱璺緞涓嶅瓨鍦�"); + crnNo = 0; + } else { + staNo = basDevpService.selectById(staDesc.getCrnStn()); + if (!staNo.getAutoing().equals("Y")) { + log.error("鐩爣绔�" + staDesc.getCrnStn() + "涓嶅彲鐢�"); +// throw new CoolException("鐩爣绔�"+staDesc.getCrnStn()+"涓嶅彲鐢�"); + crnNo = 0; + } + startupDto.setStaNo(staNo.getDevNo()); + } + // 鏇存柊搴撲綅鎺掑彿 + if (Cools.isEmpty(locMast)) { + rowLastno.setCurrentRow(curRow); + rowLastnoService.updateById(rowLastno); + } + } + + // 寮�濮嬫煡鎵惧簱浣� ==============================>> + + // 1.鎸夎鍒欐煡鎵惧簱浣� + if (Cools.isEmpty(locMast) && crnNo != 0) { + List<LocMast> locMasts = locMastService.selectList(new EntityWrapper<LocMast>() + .eq("row1", nearRow) + .eq("loc_sts", "O").eq("whs_type", rowLastnoType.getType().longValue()) + .orderBy("lev1", true).orderBy("bay1", true)); + for (LocMast locMast1 : locMasts) { + if (!VersionUtils.locMoveCheckLocTypeComplete(locMast1, locTypeDto)) { + continue; + } + if (Utils.BooleanWhsTypeStaIoType(rowLastno)) { + String shallowLoc = Utils.getDeepLoc(slaveProperties, locMast1.getLocNo()); + LocMast locMast2 = locMastService.selectOne(new EntityWrapper<LocMast>() + .eq("loc_no", shallowLoc).eq("loc_sts", "O").eq("whs_type", rowLastnoType.getType().longValue())); + if (!Cools.isEmpty(locMast2)) { + locMast = locMast2; + break; + } + } else { + if (!Cools.isEmpty(locMast1)) { + locMast = locMast1; + break; + } + } + } + + if (Cools.isEmpty(locMast) && Utils.BooleanWhsTypeStaIoType(rowLastno)) { + for (LocMast locMast1 : locMasts) { + if (!VersionUtils.locMoveCheckLocTypeComplete(locMast1, locTypeDto)) { + continue; + } + if (Utils.BooleanWhsTypeStaIoType(rowLastno)) { + String shallowLoc = Utils.getDeepLoc(slaveProperties, locMast1.getLocNo()); + LocMast locMast2 = locMastService.selectOne(new EntityWrapper<LocMast>() + .eq("loc_no", shallowLoc).eq("loc_sts", "O").eq("whs_type", rowLastnoType.getType().longValue())); + if (!Cools.isEmpty(locMast2)) { + locMast = locMast2; + break; + } else { + locMast2 = locMastService.selectOne(new EntityWrapper<LocMast>() + .eq("loc_no", shallowLoc).eq("loc_sts", "F").eq("whs_type", rowLastnoType.getType().longValue())); + if (!Cools.isEmpty(locMast2)) { + locMast = locMast1; + break; + } else { + locMast2 = locMastService.selectOne(new EntityWrapper<LocMast>() + .eq("loc_no", shallowLoc).eq("loc_sts", "D").eq("whs_type", rowLastnoType.getType().longValue())); + if (!Cools.isEmpty(locMast2)) { + locMast = locMast1; + break; + } + } + } + } else { + if (!Cools.isEmpty(locMast1)) { + locMast = locMast1; break; } } @@ -161,126 +712,595 @@ } } - // 濡傛灉娌℃湁鐩歌繎鐗╂枡锛屽垯鎸夎鍒欒疆璇㈣揣鏋� - if (null == locMast) { - Shelves shelves = new Shelves(rowCount, crn_qty); - if (whsType != 4) { - int divides = (int) Arith.divides(1, curRow - 1, 16); - curRow = (int) Arith.remainder(curRow, 16); - if (curRow == 0) { - curRow = 16; + if (!Cools.isEmpty(locMast) && !basCrnpService.checkSiteError(crnNo, true)) { + locMast = null; + } + + // 閫掑綊鏌ヨ + if (Cools.isEmpty(locMast) || !locMast.getLocSts().equals("O")) { + // 褰撳墠宸烽亾鏃犵┖搴撲綅鏃讹紝閫掑綊璋冩暣鑷充笅涓�宸烽亾锛屾绱㈠叏閮ㄥ贩閬撴棤鏋滃悗锛岃烦鍑洪�掑綊 + if (times < rowCount * 2) { + times = times + 1; + return getLocNoRun(whsType, staDescId, sourceStaNo, findLocNoAttributeVo, moveCrnNo, 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("娌℃湁绌哄簱浣�"); + } + String locNo = locMast.getLocNo(); + + // 鐢熸垚宸ヤ綔鍙� + int workNo = getWorkNo(0); + // 杩斿洖dto + startupDto.setWorkNo(workNo); + startupDto.setCrnNo(crnNo); + startupDto.setSourceStaNo(sourceStaNo); + startupDto.setLocNo(locNo); + return startupDto; + } + + public StartupDto getLocNoRun4(Integer whsType, Integer staDescId, Integer sourceStaNo, FindLocNoAttributeVo findLocNoAttributeVo, Integer moveCrnNo, LocTypeDto locTypeDto, int times) { + + // 鍒濆鍖栧弬鏁� + int crnNo = 0; //鍫嗗灈鏈哄彿 + int nearRow = 0; //鏈�娴呭簱浣嶆帓 + int curRow = 0; //鏈�娣卞簱浣嶆帓 + int rowCount = 0; //杞杞 + LocMast locMast = null; // 鐩爣搴撲綅 + + StartupDto startupDto = new StartupDto(); + RowLastno rowLastno = rowLastnoService.selectById(whsType); + if (Cools.isEmpty(rowLastno)) { + throw new CoolException("鏁版嵁寮傚父锛岃鑱旂郴绠$悊鍛�===>搴撲綅瑙勫垯鏈煡"); + } + RowLastnoType rowLastnoType = rowLastnoTypeService.selectById(rowLastno.getTypeId()); + if (Cools.isEmpty(rowLastnoType)) { + throw new CoolException("鏁版嵁寮傚父锛岃鑱旂郴绠$悊鍛�===銆嬪簱浣嶈鍒欑被鍨嬫湭鐭�"); + } + int sRow = rowLastno.getsRow(); + int eRow = rowLastno.geteRow(); + int crnNumber = rowLastno.getCrnQty(); + + // ===============>>>> 寮�濮嬫墽琛� + curRow = rowLastno.getCurrentRow(); + + if (!Cools.isEmpty(moveCrnNo) && moveCrnNo != 0) { + crnNumber = moveCrnNo; +// if (times==0){ +// curRow = moveCrnNo*4-1; +// }else { +// curRow = moveCrnNo*4-2; +// } + } + + //姝ょ▼搴忕敤浜庝紭鍖栧爢鍨涙満寮傚父鏃剁殑杩愯鏃堕棿 + for (int i = times; i < crnNumber * 2; i++) { + int[] locNecessaryParameters = Utils.LocNecessaryParameters(rowLastno, curRow, crnNumber); + rowCount = locNecessaryParameters[0]; + curRow = locNecessaryParameters[1]; + crnNo = locNecessaryParameters[2]; + nearRow = locNecessaryParameters[3]; + List<LocMast> locMasts = locMastService.selectList(new EntityWrapper<LocMast>() + .eq("crn_no", crnNo).eq("loc_sts", "O").eq("whs_type", rowLastnoType.getType().longValue())); + if (locMasts.size() <= 5) { + nearRow = 0; + times++; + continue; + } + break; + + } + if (crnNo == 0) { + throw new CoolException("鏃犲彲鐢ㄥ簱浣�"); + } + + + // 鐩镐技宸ヤ綔妗f --- 鍚屽ぉ鍚岃鏍肩墿鏂� + if (!Cools.isEmpty(findLocNoAttributeVo.getMatnr()) && (staDescId == 1 || staDescId == 11 || staDescId == 111)) { + //鏌ヨ鐩镐技宸ヤ綔妗f + List<WrkMast> wrkMasts = wrkMastService.selectWrkMastWrkDetl(staDescId, findLocNoAttributeVo, crnNo); + int nearbay = 0; //鐩镐技宸ヤ綔妗f 鐩爣搴撲綅鍒� + int nearlev = 0; //鐩镐技宸ヤ綔妗f 鐩爣搴撲綅灞� + for (WrkMast wrkMast : wrkMasts) { + int curRowW = curRow; //鐩镐技宸ヤ綔妗f 鏈�娣卞簱浣嶆帓 + int nearRowW = nearRow; //鐩镐技宸ヤ綔妗f 鏈�娴呭簱浣嶆帓 + if (Cools.isEmpty(wrkMast.getLocNo())) { + continue; } - for (int i = 0; i < shelves.group; i ++) { - curRow = shelves.start(curRow); - if (curRow < 0) { - throw new CoolException("妫�绱㈠簱浣嶅け璐ワ紝璇疯仈绯荤鐞嗗憳"); - } - Integer crnNo1 = shelves.get(curRow); - crnNo1 = crnNo1 + divides*4; - if (basCrnpService.checkSiteError(crnNo1, true)) { - crnNo = crnNo1; + //鐩爣鎺掍负鏈�澶栧眰鎺� + if (Utils.getRow(wrkMast.getLocNo()) == nearRow) { + continue; + } + //璧峰绔欎笉涓�鑷� + if (!wrkMast.getSourceStaNo().equals(sourceStaNo)) { + continue; + } + //鐩稿悓鍒椼�佸眰杩囨护 + if (Utils.getBay(wrkMast.getLocNo()) == nearbay && Utils.getLev(wrkMast.getLocNo()) == nearlev) { + continue; + } else { + nearbay = Utils.getBay(wrkMast.getLocNo()); + nearlev = Utils.getLev(wrkMast.getLocNo()); + } + + //鑾峰彇鐩爣搴撲綅鎵�鍦ㄥ贩閬撳苟鎺掑簭 +// List<String> groupOutsideLocCrn = Utils.getGroupOutLocCrn(curRow,nearRow,wrkMast.getLocNo(), curRow>nearRow); + LocMast locMastGro = locMastService.selectById(wrkMast.getLocNo()); + + for (int i = 0; i < crnNumber * 2; i++) { + if (!(Utils.getRow(locMastGro.getLocNo()) > nearRowW && Utils.getRow(locMastGro.getLocNo()) <= curRowW) && !(Utils.getRow(locMastGro.getLocNo()) < nearRowW && Utils.getRow(locMastGro.getLocNo()) >= curRowW)) { + int[] locNecessaryParameters = Utils.LocNecessaryParameters(rowLastno, curRowW, crnNumber); + curRowW = locNecessaryParameters[1]; + nearRowW = locNecessaryParameters[3]; + } else { break; } } - } else { - for (int i = 0; i < shelves.group; i ++) { - curRow = shelves.start(curRow); - if (curRow < 0) { - throw new CoolException("妫�绱㈠簱浣嶅け璐ワ紝璇疯仈绯荤鐞嗗憳"); - } - Integer crnNo1 = shelves.get(curRow); - if (basCrnpService.checkSiteError(crnNo1, true)) { - crnNo = crnNo1; + + //鑾峰彇鐩爣搴撲綅鎵�鍦ㄥ贩閬撴渶娴呴潪绌哄簱浣� + LocMast locMast2 = locMastService.selectLocByLocStsPakInF(curRowW, nearRowW, locMastGro, rowLastnoType.getType().longValue()); + + //鐩爣搴撲綅鎵�鍦ㄥ贩閬撴渶娴呴潪绌哄簱浣嶅瓨鍦�&&闈炴渶澶栦晶搴撲綅&&鍏ュ簱鐘舵�� + if (!Cools.isEmpty(locMast2) && Utils.getRow(locMast2.getLocNo()) != nearRowW && (locMast2.getLocSts().equals("S") || locMast2.getLocSts().equals("Q"))) { + //鑾峰彇搴撳瓨鏄庣粏 + WrkDetl wrkDetl = wrkDetlService.selectOne(new EntityWrapper<WrkDetl>().eq("wrk_no", wrkMast.getWrkNo())); + //鍒ゆ柇鍚岃鏍肩墿鏂� + if (!Cools.isEmpty(wrkDetl) && findLocNoAttributeVo.beSimilar(wrkDetl)) { + int row2 = 0; + if (Utils.getRow(locMast2.getLocNo()) > nearRowW) { + row2 = Utils.getRow(locMast2.getLocNo()) - 1; + } else { + row2 = Utils.getRow(locMast2.getLocNo()) + 1; + } + String targetLocNo = zerofill(String.valueOf(row2), 2) + locMast2.getLocNo().substring(2); + locMast = locMastService.selectOne(new EntityWrapper<LocMast>().eq("loc_no", targetLocNo).eq("loc_sts", "O")); + if (Cools.isEmpty(locMast)) { + continue; + } break; } } } + } - if (crnNo == 0) { - throw new CoolException("娌℃湁鍙敤鐨勫爢鍨涙満"); + // 鐩镐技宸ヤ綔妗� --- 绌烘墭 + if (Cools.isEmpty(locMast) && staDescId == 10) { + List<WrkMast> wrkMasts = wrkMastService.selectList(new EntityWrapper<WrkMast>().eq("io_type", 10).eq("crn_no", crnNo).eq("whs_type", rowLastnoType.getType().longValue())); + int nearbay = 0; + int nearlev = 0; + for (WrkMast wrkMast : wrkMasts) { + int curRowW = curRow; //鐩镐技宸ヤ綔妗f 鏈�娣卞簱浣嶆帓 + int nearRowW = nearRow; //鐩镐技宸ヤ綔妗f 鏈�娴呭簱浣嶆帓 + if (Cools.isEmpty(wrkMast.getLocNo())) { + continue; + } + if (Utils.getRow(wrkMast.getLocNo()) == nearRow) { + continue; + } + //璧峰绔欎笉涓�鑷� + if (!wrkMast.getSourceStaNo().equals(sourceStaNo)) { + continue; + } + if (Utils.getBay(wrkMast.getLocNo()) == nearbay && Utils.getLev(wrkMast.getLocNo()) == nearlev) { + continue; + } else { + nearbay = Utils.getBay(wrkMast.getLocNo()); + nearlev = Utils.getLev(wrkMast.getLocNo()); + } +// List<String> groupOutsideLocCrn = Utils.getGroupOutLocCrn(curRow,nearRow,wrkMast.getLocNo(), curRow>nearRow); + LocMast locMastGro = locMastService.selectById(wrkMast.getLocNo()); + + for (int i = 0; i < crnNumber * 2; i++) { + if (!(Utils.getRow(locMastGro.getLocNo()) > nearRowW && Utils.getRow(locMastGro.getLocNo()) <= curRowW) && !(Utils.getRow(locMastGro.getLocNo()) < nearRowW && Utils.getRow(locMastGro.getLocNo()) >= curRowW)) { + int[] locNecessaryParameters = Utils.LocNecessaryParameters(rowLastno, curRowW, crnNumber); + curRowW = locNecessaryParameters[1]; + nearRowW = locNecessaryParameters[3]; + } else { + break; + } + } + + LocMast locMast2 = locMastService.selectLocByLocStsPakInF(curRowW, nearRowW, locMastGro, rowLastnoType.getType().longValue()); + + if (!Cools.isEmpty(locMast2) && Utils.getRow(locMast2.getLocNo()) != nearRowW && locMast2.getLocSts().equals("S")) { + int row2 = 0; + if (Utils.getRow(locMast2.getLocNo()) > nearRowW) { + row2 = Utils.getRow(locMast2.getLocNo()) - 1; + } else { + row2 = Utils.getRow(locMast2.getLocNo()) + 1; + } + String targetLocNo = zerofill(String.valueOf(row2), 2) + locMast2.getLocNo().substring(2); + locMast = locMastService.selectOne(new EntityWrapper<LocMast>().eq("loc_no", targetLocNo).eq("loc_sts", "O")); + if (Cools.isEmpty(locMast)) { + continue; + } + break; + } + } } - // 鑾峰彇鐩爣绔� - Wrapper<StaDesc> wrapper = new EntityWrapper<StaDesc>() - .eq("type_no", staDescId) - .eq("stn_no", sourceStaNo) - .eq("crn_no", crnNo); - StaDesc staDesc = staDescService.selectOne(wrapper); - if (Cools.isEmpty(staDesc)) { - log.error("type_no={},stn_no={},crn_no={}", staDescId, sourceStaNo, crnNo); - throw new CoolException("鍏ュ簱璺緞涓嶅瓨鍦�"); + + boolean signRule1 = false; + boolean signRule2 = false; + + + if (Utils.BooleanWhsTypeStaIoType(rowLastno)) { + // 闈犺繎鎽嗘斁瑙勫垯 --- 鍚屽ぉ鍚岃鏍肩墿鏂� //鍒嗙鐗� + if (!Cools.isEmpty(findLocNoAttributeVo.getMatnr()) && staDescId == 1) { +// signRule1 = true; + } + // 闈犺繎鎽嗘斁瑙勫垯 --- 鍚屽ぉ鍚岃鏍肩墿鏂� //浜掗�氱増 + if (!Cools.isEmpty(findLocNoAttributeVo.getMatnr()) && staDescId == 1) { + signRule2 = true; + } + + if (!Cools.isEmpty(findLocNoAttributeVo.getMatnr()) && (staDescId == 11 || staDescId == 111)) { + signRule1 = true; + } } - BasDevp staNo = basDevpService.selectById(staDesc.getCrnStn()); - if (!staNo.getAutoing().equals("Y")) { - throw new CoolException("鐩爣绔�"+staDesc.getCrnStn()+"涓嶅彲鐢�"); + + if (signRule1) { + if (nearRow != curRow) { + List<LocMast> locMasts = locMastService.selectList(new EntityWrapper<LocMast>() + .eq("row1", nearRow).eq("loc_sts", "O").eq("whs_type", rowLastnoType.getType().longValue())); + for (LocMast locMast1 : locMasts) { + //鑾峰彇宸烽亾 +// List<String> groupOutsideLocCrn = Utils.getGroupOutLocCrn(curRow,nearRow,locMast1.getLocNo(), curRow>nearRow); + //鑾峰彇鐩爣搴撲綅鎵�鍦ㄥ贩閬撴渶娴呴潪绌哄簱浣� + LocMast locMastF = locMastService.selectLocByLocStsPakInF(curRow, nearRow, locMast1, rowLastnoType.getType().longValue()); + if (!Cools.isEmpty(locMastF) && locMastF.getLocSts().equals("F")) { + LocDetl locDetl = locDetlService.selectOne(new EntityWrapper<LocDetl>().eq("loc_no", locMastF.getLocNo())); + if (!Cools.isEmpty(locDetl) && findLocNoAttributeVo.beSimilar(locDetl)) { + //鑾峰彇鐩爣搴撲綅鎵�鍦ㄥ贩閬撴渶娣辩┖搴撲綅 + locMast = locMastService.selectLocByLocStsPakInO(curRow, nearRow, locMast1, rowLastnoType.getType().longValue()); + break; + } + } + } + } + } else if (signRule2) { + List<String> locNos = locDetlService.getSameDetlToday(findLocNoAttributeVo.getMatnr(), sRow, eRow); + int nearbay = 0; + int nearlev = 0; + for (String locNo : locNos) { + int curRowW = curRow; //鐩镐技宸ヤ綔妗f 鏈�娣卞簱浣嶆帓 + int nearRowW = nearRow; //鐩镐技宸ヤ綔妗f 鏈�娴呭簱浣嶆帓 + if (Cools.isEmpty(locNo)) { + continue; + } + if (Utils.getRow(locNo) == nearRow) { + continue; + } + if (Utils.getBay(locNo) == nearbay && Utils.getLev(locNo) == nearlev) { + continue; + } else { + nearbay = Utils.getBay(locNo); + nearlev = Utils.getLev(locNo); + } +// List<String> groupOutsideLocCrn = Utils.getGroupOutLocCrn(curRow,nearRow,wrkMast.getLocNo(), curRow>nearRow); + LocMast locMastGro = locMastService.selectById(locNo); + + for (int i = 0; i < crnNumber * 2; i++) { + if (!(Utils.getRow(locMastGro.getLocNo()) > nearRowW && Utils.getRow(locMastGro.getLocNo()) <= curRowW) && !(Utils.getRow(locMastGro.getLocNo()) < nearRowW && Utils.getRow(locMastGro.getLocNo()) >= curRowW)) { + int[] locNecessaryParameters = Utils.LocNecessaryParameters(rowLastno, curRowW, crnNumber); + curRowW = locNecessaryParameters[1]; + nearRowW = locNecessaryParameters[3]; + } else { + break; + } + } + + LocMast locMast2 = locMastService.selectLocByLocStsPakInF(curRowW, nearRowW, locMastGro, rowLastnoType.getType().longValue()); + + if (!Cools.isEmpty(locMast2) && Utils.getRow(locMast2.getLocNo()) != nearRowW && locMast2.getLocSts().equals("S")) { + int row2 = 0; + if (Utils.getRow(locMast2.getLocNo()) > nearRowW) { + row2 = Utils.getRow(locMast2.getLocNo()) - 1; + } else { + row2 = Utils.getRow(locMast2.getLocNo()) + 1; + } + String targetLocNo = zerofill(String.valueOf(row2), 2) + locMast2.getLocNo().substring(2); + locMast = locMastService.selectOne(new EntityWrapper<LocMast>().eq("loc_no", targetLocNo).eq("loc_sts", "O")); + if (Cools.isEmpty(locMast)) { + continue; + } + break; + } + } } + +// // 闈犺繎鎽嗘斁瑙勫垯 --- 绌烘墭 //鍒嗙鐗� +// if (staDescId == 10 && Utils.BooleanWhsTypeStaIoType(rowLastno)) { +// 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,locMast1,rowLastnoType.getType().longValue()); +// if (!Cools.isEmpty(locMastF) && locMastF.getLocSts().equals("D")){ +// //鑾峰彇鐩爣搴撲綅鎵�鍦ㄥ贩閬撴渶娴呴潪绌哄簱浣� +// locMast = locMastService.selectLocByLocStsPakInO(curRow,nearRow,locMast1,rowLastnoType.getType().longValue()); +// break; +// } +// } +// } + + // 闈犺繎鎽嗘斁瑙勫垯 --- 绌烘墭 //浜掗�氱増 + if (staDescId == 10 && Utils.BooleanWhsTypeStaIoType(rowLastno)) { + List<LocMast> locMasts = locMastService.selectList(new EntityWrapper<LocMast>().eq("loc_sts", "D").ge("row1", sRow).le("row1", eRow)); + int nearbay = 0; + int nearlev = 0; + for (LocMast locMastSign : locMasts) { + int curRowW = curRow; //鐩镐技宸ヤ綔妗f 鏈�娣卞簱浣嶆帓 + int nearRowW = nearRow; //鐩镐技宸ヤ綔妗f 鏈�娴呭簱浣嶆帓 + if (Cools.isEmpty(locMastSign.getLocNo())) { + continue; + } + if (Utils.getRow(locMastSign.getLocNo()) == nearRow) { + continue; + } + if (Utils.getBay(locMastSign.getLocNo()) == nearbay && Utils.getLev(locMastSign.getLocNo()) == nearlev) { + continue; + } else { + nearbay = Utils.getBay(locMastSign.getLocNo()); + nearlev = Utils.getLev(locMastSign.getLocNo()); + } +// List<String> groupOutsideLocCrn = Utils.getGroupOutLocCrn(curRow,nearRow,wrkMast.getLocNo(), curRow>nearRow); + LocMast locMastGro = locMastService.selectById(locMastSign.getLocNo()); + + for (int i = 0; i < crnNumber * 2; i++) { + if (!(Utils.getRow(locMastGro.getLocNo()) > nearRowW && Utils.getRow(locMastGro.getLocNo()) <= curRowW) && !(Utils.getRow(locMastGro.getLocNo()) < nearRowW && Utils.getRow(locMastGro.getLocNo()) >= curRowW)) { + int[] locNecessaryParameters = Utils.LocNecessaryParameters(rowLastno, curRowW, crnNumber); + curRowW = locNecessaryParameters[1]; + nearRowW = locNecessaryParameters[3]; + } else { + break; + } + } + + LocMast locMast2 = locMastService.selectLocByLocStsPakInF(curRowW, nearRowW, locMastGro, rowLastnoType.getType().longValue()); + + if (!Cools.isEmpty(locMast2) && Utils.getRow(locMast2.getLocNo()) != nearRowW && locMast2.getLocSts().equals("S")) { + int row2 = 0; + if (Utils.getRow(locMast2.getLocNo()) > nearRowW) { + row2 = Utils.getRow(locMast2.getLocNo()) - 1; + } else { + row2 = Utils.getRow(locMast2.getLocNo()) + 1; + } + String targetLocNo = zerofill(String.valueOf(row2), 2) + locMast2.getLocNo().substring(2); + locMast = locMastService.selectOne(new EntityWrapper<LocMast>().eq("loc_no", targetLocNo).eq("loc_sts", "O")); + if (Cools.isEmpty(locMast)) { + continue; + } + break; + } + } + } + + Wrapper<StaDesc> wrapper = null; + StaDesc staDesc = null; + BasDevp staNo = null; + + if (Utils.BooleanWhsTypeSta(rowLastno, staDescId)) { + // 鑾峰彇鐩爣绔� + wrapper = new EntityWrapper<StaDesc>() + .eq("type_no", staDescId) + .eq("stn_no", sourceStaNo) + .eq("crn_no", crnNo); + staDesc = staDescService.selectOne(wrapper); + if (Cools.isEmpty(staDesc)) { + log.error("鍏ュ簱璺緞涓嶅瓨鍦�:type_no={},stn_no={},crn_no={}", staDescId, sourceStaNo, crnNo); + crnNo = 0; + } else { + staNo = basDevpService.selectById(staDesc.getCrnStn()); + if (!staNo.getAutoing().equals("Y")) { + log.error("鐩爣绔�" + staDesc.getCrnStn() + "涓嶅彲鐢�"); + crnNo = 0; + } + startupDto.setStaNo(staNo.getDevNo()); + } + } + // 鏇存柊搴撲綅鎺掑彿 - rowLastno.setCurrentRow(curRow); - rowLastnoService.updateById(rowLastno); + if (Utils.BooleanWhsTypeSta(rowLastno, staDescId) && Cools.isEmpty(locMast)) { + rowLastno.setCurrentRow(curRow); + rowLastnoService.updateById(rowLastno); + } // 寮�濮嬫煡鎵惧簱浣� ==============================>> - // 1.褰撴绱㈠簱鎺掍负娴呭簱浣嶆帓鏃讹紝浼樺厛瀵绘壘褰撳墠搴撴帓鐨勬繁搴撲綅鎺� - if (locMast == null) { - if (Utils.isShallowLoc(slaveProperties, curRow)) { - Integer deepRow = Utils.getDeepRow(slaveProperties, curRow); - locMast = locMastService.queryFreeLocMast(deepRow, locTypeDto.getLocType1()); - // todo:luxiaotao 濡傛灉鐢ㄦ祬鎺掓壘鍒扮殑娣卞簱浣嶏紝閭d箞鍒欓渶瑕佸垽鏂繖涓繁搴撲綅瀵瑰簲鐨勬祬搴撲綅鏄惁鏈夎揣锛團銆乆銆丏锛� - // 鍥犲簱浣嶇Щ杞�侀渶棰勭暀绌哄簱浣� - if (!locMastService.checkEmptyCount(locMast)) { - locMast = null; + // 1.鎸夎鍒欐煡鎵惧簱浣� + if (Cools.isEmpty(locMast) && crnNo != 0) { + List<LocMast> locMasts = locMastService.selectList(new EntityWrapper<LocMast>() + .eq("row1", nearRow) + .eq("loc_sts", "O").eq("whs_type", rowLastnoType.getType().longValue()) + .orderBy("lev1", true).orderBy("bay1", true));//鏈�娴呭簱浣� + for (LocMast locMast1 : locMasts) { + if (!VersionUtils.locMoveCheckLocTypeComplete(locMast1, locTypeDto)) { + continue; + } + if (Utils.BooleanWhsTypeStaIoType(rowLastno)) { + //鑾峰彇鐩爣搴撲綅鎵�鍦ㄥ贩閬撴渶娣辩┖搴撲綅 + LocMast locMast2 = locMastService.selectLocByLocStsPakInO(curRow, nearRow, locMast1, rowLastnoType.getType().longValue()); + if (!Cools.isEmpty(locMast2) && locMast2.getBay1() == curRow) { + locMast = locMast2; + break; + } + } } - if (Cools.isEmpty(locMast)) { - locMast = locMastService.queryFreeLocMast(curRow, locTypeDto.getLocType1()); - // 鍥犲簱浣嶇Щ杞�侀渶棰勭暀绌哄簱浣� - if (!locMastService.checkEmptyCount(locMast)) { - locMast = null; - } - // 鐩爣搴撲綅 ===>> 娴呭簱浣嶏紝 鍒欐牎楠屽叾娣卞簱浣嶆槸鍚︿负 F D X - if (null != locMast && Utils.isShallowLoc(slaveProperties, locMast.getLocNo())) { - LocMast deepLoc = locMastService.selectById(Utils.getDeepLoc(slaveProperties, locMast.getLocNo())); - if (!deepLoc.getLocSts().equals("F") && !deepLoc.getLocSts().equals("D") && !deepLoc.getLocSts().equals("X")) { - locMast = null; + + //鏈壘鍒� 鍏佽娣锋枡 + if (Cools.isEmpty(locMast) && Utils.BooleanWhsTypeStaIoType(rowLastno)) { + for (LocMast locMast1 : locMasts) { + if (!VersionUtils.locMoveCheckLocTypeComplete(locMast1, locTypeDto)) { + continue; } - } - // 鐩爣搴撲綅 ===>> 娣卞簱浣嶏紝 鍒欐牎楠屽叾娴呭簱浣嶆槸鍚︿负 O - if (null != locMast && Utils.isDeepLoc(slaveProperties, locMast.getLocNo())) { - LocMast shallowLoc = locMastService.selectById(Utils.getShallowLoc(slaveProperties, locMast.getLocNo())); - if (!shallowLoc.getLocSts().equals("O")) { - locMast = null; + if (Utils.BooleanWhsTypeStaIoType(rowLastno)) { + //鑾峰彇鐩爣搴撲綅鎵�鍦ㄥ贩閬撳苟鎺掑簭 +// List<String> groupOutsideLocCrn = Utils.getGroupOutLocCrn(curRow,nearRow,locMast1.getLocNo(), curRow>nearRow); + + //鑾峰彇鐩爣搴撲綅鎵�鍦ㄥ贩閬撴渶娴呴潪绌哄簱浣� + LocMast locMast2 = locMastService.selectLocByLocStsPakInF(curRow, nearRow, locMast1, rowLastnoType.getType().longValue()); + if (Cools.isEmpty(locMast2)) { + LocMast locMast3 = locMastService.selectLocByLocStsPakInO(curRow, nearRow, locMast1, rowLastnoType.getType().longValue()); + if (!Cools.isEmpty(locMast3)) { + locMast = locMast3; + break; + } + } else { + if ((locMast2.getLocSts().equals("F") && staDescId == 1) || (locMast2.getLocSts().equals("D") && staDescId == 10)) { + LocMast locMast3 = locMastService.selectLocByLocStsPakInO(curRow, nearRow, locMast1, rowLastnoType.getType().longValue()); + if (!Cools.isEmpty(locMast3)) { + locMast = locMast3; + break; + } + } + } } } } } - // 2.搴撲綅褰撳墠鎵�灞炲昂瀵告棤绌哄簱浣嶆椂锛岃皟鏁村昂瀵稿弬鏁帮紝鍚戜笂鍏煎妫�绱㈠簱浣� - if (Cools.isEmpty(locMast)) { + // 閫掑綊鏌ヨ + if (Cools.isEmpty(locMast) || !locMast.getLocSts().equals("O")) { // 褰撳墠宸烽亾鏃犵┖搴撲綅鏃讹紝閫掑綊璋冩暣鑷充笅涓�宸烽亾锛屾绱㈠叏閮ㄥ贩閬撴棤鏋滃悗锛岃烦鍑洪�掑綊 - if (times < rowCount) { + if (times < rowCount * 2) { times = times + 1; - return getLocNo(1, staDescId, sourceStaNo, matNos, locTypeDto, times); - } - - // 杞昏揣鐗╂壘杞诲簱浣嶄负绌烘椂锛屽彲浠ュ幓鎵鹃噸搴撲綅浠� - if (locTypeDto.getLocType1() == 1) { - locTypeDto.setLocType1((short) 2); - return getLocNo(1, staDescId, sourceStaNo, matNos, locTypeDto, times); + return getLocNoRun4(whsType, staDescId, sourceStaNo, findLocNoAttributeVo, moveCrnNo, locTypeDto, times); } log.error("绯荤粺娌℃湁绌哄簱浣嶏紒锛侊紒 灏哄瑙勬牸锛� {}锛� 杞娆℃暟锛歿}", JSON.toJSONString(locTypeDto), times); throw new CoolException("娌℃湁绌哄簱浣�"); } String locNo = locMast.getLocNo(); + // 鐢熸垚宸ヤ綔鍙� + int workNo = getWorkNo(0); // 杩斿洖dto startupDto.setWorkNo(workNo); startupDto.setCrnNo(crnNo); startupDto.setSourceStaNo(sourceStaNo); - startupDto.setStaNo(staNo.getDevNo()); startupDto.setLocNo(locNo); return startupDto; } + public StartupDto getLocNoRun5(Integer whsType, Integer staDescId, Integer sourceStaNo, FindLocNoAttributeVo findLocNoAttributeVo, Integer moveCrnNo, LocTypeDto locTypeDto, int times) { + + // 鍒濆鍖栧弬鏁� + int crnNo = 0; //鍫嗗灈鏈哄彿 + int nearRow = 0; //鏈�娴呭簱浣嶆帓 + int curRow = 0; //鏈�娣卞簱浣嶆帓 + int rowCount = 0; //杞杞 + LocMast locMast = null; // 鐩爣搴撲綅 + + StartupDto startupDto = new StartupDto(); + RowLastno rowLastno = rowLastnoService.selectById(whsType); + if (Cools.isEmpty(rowLastno)) { + throw new CoolException("鏁版嵁寮傚父锛岃鑱旂郴绠$悊鍛�===>搴撲綅瑙勫垯鏈煡"); + } + RowLastnoType rowLastnoType = rowLastnoTypeService.selectById(rowLastno.getTypeId()); + if (Cools.isEmpty(rowLastnoType)) { + throw new CoolException("鏁版嵁寮傚父锛岃鑱旂郴绠$悊鍛�===銆嬪簱浣嶈鍒欑被鍨嬫湭鐭�"); + } + int sRow = rowLastno.getsRow(); + int eRow = rowLastno.geteRow(); + int crnNumber = eRow - sRow + 1; + + // ===============>>>> 寮�濮嬫墽琛� + curRow = rowLastno.getCurrentRow(); + + if (!Cools.isEmpty(moveCrnNo) && moveCrnNo != 0) { + crnNumber = moveCrnNo; + } + + //姝ょ▼搴忕敤浜庝紭鍖栧爢鍨涙満寮傚父鏃剁殑杩愯鏃堕棿 + int[] locNecessaryParameters = Utils.LocNecessaryParameters(rowLastno, curRow, crnNumber); + curRow = locNecessaryParameters[1]; + crnNo = locNecessaryParameters[2]; + rowCount = locNecessaryParameters[0]; + nearRow = locNecessaryParameters[3]; + + Wrapper<StaDesc> wrapper = null; + StaDesc staDesc = null; + BasDevp staNo = null; + + if (Utils.BooleanWhsTypeSta(rowLastno, staDescId)) { + // 鑾峰彇鐩爣绔� + wrapper = new EntityWrapper<StaDesc>() + .eq("type_no", staDescId) + .eq("stn_no", sourceStaNo) + .eq("crn_no", crnNo); + staDesc = staDescService.selectOne(wrapper); + if (Cools.isEmpty(staDesc)) { + log.error("type_no={},stn_no={},crn_no={}", staDescId, sourceStaNo, crnNo); +// throw new CoolException("鍏ュ簱璺緞涓嶅瓨鍦�"); + crnNo = 0; + } else { + staNo = basDevpService.selectById(staDesc.getCrnStn()); + if (!staNo.getAutoing().equals("Y")) { + log.error("鐩爣绔�" + staDesc.getCrnStn() + "涓嶅彲鐢�"); +// throw new CoolException("鐩爣绔�"+staDesc.getCrnStn()+"涓嶅彲鐢�"); + crnNo = 0; + } + startupDto.setStaNo(staNo.getDevNo()); + } + } + + // 鏇存柊搴撲綅鎺掑彿 + if (Utils.BooleanWhsTypeSta(rowLastno, staDescId) && Cools.isEmpty(locMast)) { + rowLastno.setCurrentRow(curRow); + rowLastnoService.updateById(rowLastno); + } + + // 寮�濮嬫煡鎵惧簱浣� ==============================>> + + // 1.鎸夎鍒欐煡鎵惧簱浣� + if (Cools.isEmpty(locMast) && crnNo != 0) { + List<LocMast> locMasts = locMastService.selectList(new EntityWrapper<LocMast>() + .eq("row1", nearRow) + .eq("loc_sts", "O").eq("whs_type", rowLastnoType.getType().longValue()) + .orderBy("lev1", true).orderBy("bay1", true));//鏈�娴呭簱浣� + for (LocMast locMast1 : locMasts) { + if (!VersionUtils.locMoveCheckLocTypeComplete(locMast1, locTypeDto)) { + continue; + } + if (Utils.BooleanWhsTypeStaIoType(rowLastno)) { + //鑾峰彇鐩爣搴撲綅鎵�鍦ㄥ贩閬撴渶娣辩┖搴撲綅 + LocMast locMast2 = locMastService.selectLocByLocStsPakInO(curRow, nearRow, locMast1, rowLastnoType.getType().longValue()); + if (!Cools.isEmpty(locMast2) && locMast2.getBay1() == curRow) { + locMast = locMast2; + break; + } + } + } + } + + // 閫掑綊鏌ヨ + if (Cools.isEmpty(locMast) || !locMast.getLocSts().equals("O")) { + // 褰撳墠宸烽亾鏃犵┖搴撲綅鏃讹紝閫掑綊璋冩暣鑷充笅涓�宸烽亾锛屾绱㈠叏閮ㄥ贩閬撴棤鏋滃悗锛岃烦鍑洪�掑綊 + if (times < rowCount * 2) { + times = times + 1; + return getLocNoRun5(whsType, staDescId, sourceStaNo, findLocNoAttributeVo, moveCrnNo, locTypeDto, times); + } + log.error("绯荤粺娌℃湁绌哄簱浣嶏紒锛侊紒 灏哄瑙勬牸锛� {}锛� 杞娆℃暟锛歿}", JSON.toJSONString(locTypeDto), times); + throw new CoolException("娌℃湁绌哄簱浣�"); + } + String locNo = locMast.getLocNo(); + + // 鐢熸垚宸ヤ綔鍙� + int workNo = getWorkNo(0); + // 杩斿洖dto + startupDto.setWorkNo(workNo); + startupDto.setCrnNo(crnNo); + startupDto.setSourceStaNo(sourceStaNo); + startupDto.setLocNo(locNo); + return startupDto; + } public static String zerofill(String msg, Integer count) { if (msg.length() == count) { @@ -289,40 +1309,10 @@ return msg.substring(0, 16); } else { StringBuilder msgBuilder = new StringBuilder(msg); - for(int i = 0; i < count - msg.length(); ++i) { + for (int i = 0; i < count - msg.length(); ++i) { msgBuilder.insert(0, "0"); } return msgBuilder.toString(); - } - } - - /** - * 鏍规嵁鍏ュ簱绔欒幏鍙栧簱浣嶆帓鍙峰垎閰� - */ - private Integer getWhsType(Integer sourceStaNo, int times) { - if (times >= 16) { - return 4; - } - switch (sourceStaNo) { - case 173: - case 176: - case 180: - case 185: - return 1; - case 189: - case 194: - case 198: - case 202: - return 2; - case 206: -// case 211: -// case 215: -// case 219: -// case 223: - case 227: - return 3; - default: - throw new CoolException("鏍规嵁鍏ュ簱绔欒幏鍙栧簱浣嶆帓鍙峰垎閰嶅け璐ワ紝鍏ュ簱绔欙細" + sourceStaNo); } } -- Gitblit v1.9.1