From 6682a037f43649d40a94dbf59e40a5b2cc59dc37 Mon Sep 17 00:00:00 2001 From: LSH Date: 星期二, 29 十一月 2022 16:51:20 +0800 Subject: [PATCH] #取消用户编号 直接获取用户码 --- src/main/java/com/zy/common/service/CommonService.java | 245 +++++++++++++++++++++--------------------------- 1 files changed, 109 insertions(+), 136 deletions(-) diff --git a/src/main/java/com/zy/common/service/CommonService.java b/src/main/java/com/zy/common/service/CommonService.java index 20ba532..496755b 100644 --- a/src/main/java/com/zy/common/service/CommonService.java +++ b/src/main/java/com/zy/common/service/CommonService.java @@ -1,15 +1,21 @@ package com.zy.common.service; +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.service.*; import com.zy.asrs.utils.Utils; +import com.zy.asrs.utils.VersionUtils; +import com.zy.common.entity.Parameter; +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 lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; @@ -20,6 +26,7 @@ * 璐ф灦鏍稿績鍔熻兘 * Created by vincent on 2020/6/11 */ +@Slf4j @Service public class CommonService { @@ -86,29 +93,14 @@ * @param whsType 绫诲瀷 1:鍙屾繁寮忚揣鏋� * @param staDescId 璺緞宸ヤ綔绫诲瀷 * @param sourceStaNo 婧愮珯 - * @param matNos 鐗╂枡鍙烽泦鍚� + * @param matNos 鍟嗗搧缂栧彿闆嗗悎 * @return locNo 妫�绱㈠埌鐨勫簱浣嶅彿 */ @Transactional - public StartupDto getLocNo(Integer whsType, Integer staDescId, Integer sourceStaNo, List<String> matNos, LocTypeDto locTypeDto) { + public StartupDto getLocNo(Integer whsType, Integer staDescId, Integer sourceStaNo, List<String> matNos, LocTypeDto locTypeDto, int times) { +// whsType = getWhsType(sourceStaNo, times); StartupDto startupDto = new StartupDto(); - // 鐢熸垚宸ヤ綔鍙� - int workNo = getWorkNo(0); - switch (sourceStaNo) { - case 202: - whsType = 2; - break; - case 205: - whsType = 1; - break; - case 126: - whsType = 3; - break; - default: - throw new CoolException("搴撲綅鎺掑彿鍒嗛厤閿欒, 婧愮珯鍙凤細" + sourceStaNo); - } - startupDto.setWorkNo(workNo); RowLastno rowLastno = rowLastnoService.selectById(whsType); if (Cools.isEmpty(rowLastno)) { throw new CoolException("鏁版嵁寮傚父锛岃鑱旂郴绠$悊鍛�"); @@ -121,99 +113,55 @@ int crn_qty = rowLastno.getCrnQty(); int rowCount = eRow - sRow + 1; // 鐩爣鍫嗗灈鏈哄彿 - int crnNo = 0; + int crnNo = crn_qty; // 鐩爣搴撲綅 LocMast locMast = null; - // 闈犺繎鎽嗘斁瑙勫垯 --- 鍚屽ぉ鍚岃鏍肩墿鏂� - if (!Cools.isEmpty(matNos)) { - List<String> locNos = locDetlService.getSameDetlToday(matNos.get(0)); - for (String locNo : locNos) { - if (Utils.isShallowLoc(slaveProperties, locNo)) { - continue; - } - String shallowLocNo = Utils.getShallowLoc(slaveProperties, locNo); - // 妫�娴嬬洰鏍囧簱浣嶆槸鍚︿负绌哄簱浣� - LocMast shallowLoc = locMastService.selectById(shallowLocNo); - if (shallowLoc != null && shallowLoc.getLocSts().equals("O")) { - locMast = shallowLoc; - crnNo = locMast.getCrnNo(); - break; - } - } - } - - // 闈犺繎鎽嗘斁瑙勫垯 --- 绌烘墭 - if (staDescId == 10) { - List<LocMast> locMasts = locMastService.selectList(new EntityWrapper<LocMast>().eq("loc_sts", "D")); - if (locMasts.size() > 0) { - for (LocMast loc : locMasts) { - if (Utils.isShallowLoc(slaveProperties, loc.getLocNo())) { - continue; - } - String shallowLocNo = Utils.getShallowLoc(slaveProperties, loc.getLocNo()); - // 妫�娴嬬洰鏍囧簱浣嶆槸鍚︿负绌哄簱浣� - LocMast shallowLoc = locMastService.selectById(shallowLocNo); - if (shallowLoc != null && shallowLoc.getLocSts().equals("O")) { - locMast = shallowLoc; - crnNo = locMast.getCrnNo(); - break; - } - } - } - } - // 濡傛灉娌℃湁鐩歌繎鐗╂枡锛屽垯鎸夎鍒欒疆璇㈣揣鏋� if (null == locMast) { - // 1-4鎺� - if (whsType == 1) { - // 鑾峰彇鐩爣绔欐墍鍦ㄨ揣鏋舵帓鍙� - Shelves shelves = new Shelves(rowCount, crn_qty); - curRow = shelves.start(curRow); - if (curRow < 0) { - throw new CoolException("妫�绱㈠簱浣嶅け璐ワ紝璇疯仈绯荤鐞嗗憳"); - } - for (List<Integer> node : shelves.nodes){ - if (node.contains(curRow)) { - crnNo = shelves.nodes.indexOf(node) + 1; - break; - } - } - // 5-8鎺� - } else if (whsType == 2) { - // 鑾峰彇鐩爣绔欐墍鍦ㄨ揣鏋舵帓鍙� - Shelves shelves = new Shelves(rowCount, crn_qty); - curRow = shelves.start(curRow - 4); - if (curRow < 0) { - throw new CoolException("妫�绱㈠簱浣嶅け璐ワ紝璇疯仈绯荤鐞嗗憳"); - } - for (List<Integer> node : shelves.nodes){ - if (node.contains(curRow)) { - crnNo = shelves.nodes.indexOf(node) + 1; - break; - } - } - // 鍋忕Щ閲忚ˉ鍋� - curRow = curRow + 4; - crnNo = crnNo + 1; - // 126绌烘澘鍏� 1-8鎺� - } else { - // 鑾峰彇鐩爣绔欐墍鍦ㄨ揣鏋舵帓鍙� - Shelves shelves = new Shelves(rowCount, crn_qty); - curRow = shelves.start(curRow); - if (curRow < 0) { - throw new CoolException("妫�绱㈠簱浣嶅け璐ワ紝璇疯仈绯荤鐞嗗憳"); - } - for (List<Integer> node : shelves.nodes){ - if (node.contains(curRow)) { - crnNo = shelves.nodes.indexOf(node) + 1; - break; - } - } + switch (curRow){ + case 2: + curRow = 4; + break; + case 4: + curRow = 6; + break; + case 6: + curRow = 8; + break; + case 8: + curRow = 11; + break; + case 11: + curRow = 13; + break; + case 13: + curRow = 3; + break; + case 3: + curRow = 5; + break; + case 5: + curRow = 7; + break; + case 7: + curRow = 9; + break; + case 9: + curRow = 12; + break; + case 12: + curRow = 14; + break; + case 14: + curRow = 2; + break; } } - basCrnpService.checkSiteStatus(crnNo); + if (crnNo == 0) { + throw new CoolException("娌℃湁鍙敤鐨勫爢鍨涙満"); + } // 鑾峰彇鐩爣绔� Wrapper<StaDesc> wrapper = new EntityWrapper<StaDesc>() .eq("type_no", staDescId) @@ -221,43 +169,68 @@ .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("鍏ュ簱璺緞涓嶅瓨鍦�"); } BasDevp staNo = basDevpService.selectById(staDesc.getCrnStn()); - int inQty = staNo.getInQty()==null?0:staNo.getInQty(); - if (staNo.getAutoing().equals("Y") && inQty<2) { - // 鏌ユ壘搴撲綅 - if (locMast == null) { - if (Utils.isShallowLoc(slaveProperties, curRow)) { - Integer deepRow = Utils.getDeepRow(slaveProperties, curRow); - locMast = locMastService.queryFreeLocMast(deepRow, locTypeDto.getLocType1()); - } - if (Cools.isEmpty(locMast)) { - locMast = locMastService.queryFreeLocMast(curRow, locTypeDto.getLocType1()); - } - } - if (Cools.isEmpty(locMast)) { - // 杞昏揣鐗╂壘杞诲簱浣嶄负绌烘椂锛屽彲浠ュ幓鎵鹃噸搴撲綅浠� - if (locTypeDto.getLocType1() == 1) { - locTypeDto.setLocType1((short) 2); - return getLocNo(null, staDescId, sourceStaNo, matNos, locTypeDto); - } - throw new CoolException("娌℃湁绌哄簱浣�"); - } - String locNo = locMast.getLocNo(); - - // 鏇存柊搴撲綅鎺掑彿 - rowLastno.setCurrentRow(curRow); - rowLastnoService.updateById(rowLastno); - - // 杩斿洖dto - startupDto.setCrnNo(crnNo); - startupDto.setSourceStaNo(sourceStaNo); - startupDto.setStaNo(staNo.getDevNo()); - startupDto.setLocNo(locNo); - } else { + if (!staNo.getAutoing().equals("Y")) { throw new CoolException("鐩爣绔�"+staDesc.getCrnStn()+"涓嶅彲鐢�"); } + + // 鏇存柊搴撲綅鎺掑彿 + 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; +// } +// } + if (Cools.isEmpty(locMast)) { + + Integer ruleId = Integer.parseInt(Parameter.get().getFindLocRule()); + if (ruleId == 0){//榛樿瑙勫垯 + locMast = locMastService.queryFreeLocMast(2, locTypeDto.getLocType1()); + } else if (ruleId == 1){ //鎸夋祴璇曡澶囨帓搴忥紝浼樺厛鎺掓弧鍗曞彴璁惧 + locMast = locMastService.queryFreeLocMast1(2, locTypeDto.getLocType1()); + } else if (ruleId == 2){//鎸夐�氶亾鎺掑簭锛屽潎鍖�鍒嗛厤姣忓彴璁惧 + locMast = locMastService.queryFreeLocMast2(2, locTypeDto.getLocType1(), curRow); + } else { + locMast = locMastService.queryFreeLocMast(2, locTypeDto.getLocType1()); + } + + } +// } + + // 2.搴撲綅褰撳墠鎵�灞炲昂瀵告棤绌哄簱浣嶆椂锛岃皟鏁村昂瀵稿弬鏁帮紝鍚戜笂鍏煎妫�绱㈠簱浣� + if (Cools.isEmpty(locMast)) { + // 褰撳墠宸烽亾鏃犵┖搴撲綅鏃讹紝閫掑綊璋冩暣鑷充笅涓�宸烽亾锛屾绱㈠叏閮ㄥ贩閬撴棤鏋滃悗锛岃烦鍑洪�掑綊 + if (times < rowCount) { + times = times + 1; + return getLocNo(1, staDescId, sourceStaNo, matNos, 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; } @@ -276,4 +249,4 @@ } } -} \ No newline at end of file +} -- Gitblit v1.9.1