package com.zy.common.service; import com.baomidou.mybatisplus.mapper.EntityWrapper; import com.baomidou.mybatisplus.mapper.Wrapper; import com.core.common.Cools; import com.core.exception.CoolException; import com.sun.org.apache.bcel.internal.generic.IF_ACMPEQ; 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.model.LocTypeDto; 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 java.util.ArrayList; import java.util.Arrays; import java.util.List; import java.util.Random; /** * 货架核心功能 * Created by vincent on 2020/6/11 */ @Slf4j @Service public class CommonService { public static final List FIRST_GROUP_ROW_LIST = new ArrayList() {{ add(2);add(3);add(4);add(5);add(6);add(7);add(8);add(9);add(10); add(11);add(12);add(13);add(14);add(15);add(16);add(17); }}; public static final List SECOND_GROUP_ROW_LIST = new ArrayList() {{ add(18);add(19);add(20); add(21);add(22);add(23);add(24);add(25);add(26);add(27);add(28);add(29);add(30); }}; @Autowired private WrkMastService wrkMastService; @Autowired private WrkLastnoService wrkLastnoService; @Autowired private RowLastnoService rowLastnoService; @Autowired private BasCrnpService basCrnpService; @Autowired private StaDescService staDescService; @Autowired private BasDevpService basDevpService; @Autowired private LocMastService locMastService; @Autowired private LocDetlService locDetlService; @Autowired private SlaveProperties slaveProperties; @Autowired private MatService matService; @Autowired private LocRuleService locRuleService; /** * 生成工作号 * @param wrkMk 0:入出库 ; 1:其他 * @return workNo(工作号) */ public int getWorkNo(Integer wrkMk) { WrkLastno wrkLastno = wrkLastnoService.selectById(wrkMk); if (Cools.isEmpty(wrkLastno)) { throw new CoolException("数据异常，请联系管理员"); } int workNo = 0; // 入出库类型 workNo = wrkLastno.getWrkNo(); int sNo = wrkLastno.getSNo(); int eNo = wrkLastno.getENo(); workNo = workNo>=eNo ? sNo : workNo+1; while (true) { WrkMast wrkMast = wrkMastService.selectById(workNo); if (null != wrkMast) { workNo = workNo>=eNo ? sNo : workNo+1; } else { break; } } if (workNo > 0){ wrkLastno.setWrkNo(workNo); wrkLastnoService.updateById(wrkLastno); } if (workNo == 0) { throw new CoolException("生成工作号失败，请联系管理员"); } else { if (wrkMastService.selectById(workNo)!=null) { throw new CoolException("生成工作号" + workNo + "在工作档中已存在"); } } return workNo; } /** * 检索库位号 * @param whsType 类型 1:双深式货架 * @param staDescId 路径ID * @param sourceStaNo 源站 * @param matNos 物料号集合 * @return locNo 检索到的库位号 */ public StartupDto getLocNo(Integer whsType, Integer staDescId, Integer sourceStaNo, List matNos, LocTypeDto locTypeDto) { int start; int end; Integer matType = null;//物料类型 Integer crnNo = 0; //根据入库站，决定搜索指定堆垛机 ArrayList crnNos = new ArrayList<>(); //根据入库站，找到库位组最内侧排 ArrayList rows = new ArrayList<>(); switch (sourceStaNo) { case 103://103入库站 whsType = 1; start = 1; end = 14; //103站分配1，2堆垛机 crnNos.add(1); crnNos.add(2); //分配1，7，8，14排 rows.add(1); rows.add(7); rows.add(8); rows.add(14); crnNo = 1; break; case 203://203入库站 whsType = 2; start = 8; end = 21; //203站分配2，3堆垛机 crnNos.add(2); crnNos.add(3); //分配8，14，15，21排 rows.add(8); rows.add(14); rows.add(15); rows.add(21); crnNo = 3; break; default: throw new CoolException("检索库位失败，请联系管理员"); } RowLastno rowLastno = rowLastnoService.selectById(whsType); if (Cools.isEmpty(rowLastno)) { throw new CoolException("数据异常，请联系管理员"); } // 目标库位 LocMast locMast = null; boolean sign = false; // 靠近摆放规则 --- 空托 locMast = getLocNoStep1(staDescId, locTypeDto, start, end); if (locMast != null) { //找到库位，返回dto sign=true; } //3号可以入库前必须打开控制 if (!Cools.isEmpty(matNos)) { for (String matNo : matNos) { Mat mat = matService.selectByMatnr(matNo); if (matType == null) { matType = mat.getMatType(); } if (!matType.equals(mat.getMatType())) { throw new CoolException("混放物料类型不一致"); } } if (matNos.size() > 1 && matType == 1) { //物料为单品类型，且物料种类超过1(实际为高频混放)，则禁止入库 throw new CoolException("物料类型和实际种类不一致"); } } if (!sign && matType != null) { if (matType == 1) {//单品类型入库 locMast = getLocNoStep2(locTypeDto, matNos, rows, crnNos); if (locMast != null) { //找到库位，返回dto sign=true; } else { //单品没有找到库位，找高频混放区域库位 locMast = getLocNoStep3(locTypeDto, crnNos); if (locMast != null) { //找到库位，返回dto sign=true; } } } else if (matType == 2) {//高频类型入最外侧库位 locMast = getLocNoStep3(locTypeDto, crnNos); if (locMast == null) { //高频没有找到库位，找低频混放区域库位 locMast = getLocNoStep4(locTypeDto, crnNos); } if (locMast != null) { //找到库位，返回dto sign=true; } } else if (matType == 3) {//低频混放类型 locMast = getLocNoStep4(locTypeDto, crnNos); if (locMast != null) { //找到库位，返回dto sign=true; } } } // if (!sign){ // //----------------2023.06.02兼容代码，后期库位规则符合要求后可删除------------------------ // //如果以上都找不到库位，则强制搜索2堆垛机空库位进行入库，保障3号堆垛机库位都是符合要求的 // EntityWrapper wrapper = new EntityWrapper<>(); // wrapper.eq("loc_type1", locTypeDto.getLocType1()); // wrapper.in("crn_no", "2"); // wrapper.eq("loc_sts", "O"); // List locMasts = locMastService.selectList(wrapper); // for (LocMast mast : locMasts) { // //检测当前库位内侧其他库位是否为D、F、X // if (Utils.checkInsideLocIsDFX(mast.getLocNo())) { // //内侧其他库位不是D、F、X。不能选取该库位 // continue; // } // if(sourceStaNo==103 && mast.getRow1()>14) continue; // if(sourceStaNo==103 && mast.getRow1()<8) continue; // if(sourceStaNo==203 && mast.getRow1()<15) continue; // //找到库位，返回dto // locMast=mast; // sign = true; // } // } if (sign){ return getLocNoFinalStep(staDescId, sourceStaNo, locMast);//返回dto } //----------------2023.06.02兼容代码end--------------------- throw new CoolException("检索库位失败，请联系管理员"); } // 靠近摆放规则 --- 空托 private LocMast getLocNoStep1(Integer staDescId, LocTypeDto locTypeDto,int start,int end) { LocMast locMast = null; if (staDescId == 10) { List locMasts = locMastService.selectList(new EntityWrapper() .eq("loc_sts", "D").ge("row1", start).le("row1", end)); if (locMasts.size() > 0) { for (LocMast loc : locMasts) { List groupLoc = Utils.getGroupLoc(loc.getLocNo()); LocMast locMast0 = locMastService.findOutMost(groupLoc); if (null != locMast0) { // 浅库位符合尺寸检测 if (VersionUtils.locMoveCheckLocType(locMast0, locTypeDto)) { // 浅库位对应堆垛机必须可用且无异常 if (basCrnpService.checkSiteError(locMast0.getCrnNo(), true)) { // 因库位移转、需预留空库位 if (locMastService.checkEmptyCount(locMast0, 10)) { locMast = locMast0; break; } } } } } } } return locMast; } //单品类型入库 private LocMast getLocNoStep2(LocTypeDto locTypeDto, List matNos, List rows, List crnNos) { LocMast locMast = null; //先找工作档 List wrkMasts = wrkMastService.selectSameWrkMast(matNos.get(0)); for (WrkMast wrkMast : wrkMasts) { List groupLoc = Utils.getGroupLoc(wrkMast.getLocNo()); //随机可用堆垛机号 Integer randomCrnNo = Utils.getRandomCrnNo(crnNos, locTypeDto.getLocType1()); for (Integer crnNo : crnNos) { List locMasts = locMastService.findEmptyLocMastByLocNos(locTypeDto.getLocType1(), groupLoc, crnNo); for (LocMast locMast0 : locMasts) { //检测当前库位内侧其他库位是否为D、F、X、S if (Utils.checkInsideLocIsDFXS(locMast0.getLocNo())) { //内侧其他库位不是D、F、X、S。不能选取该库位 continue; } // 浅库位符合尺寸检测 if (VersionUtils.locMoveCheckLocType(locMast0, locTypeDto)) { // 浅库位对应堆垛机必须可用且无异常 if (basCrnpService.checkSiteError(locMast0.getCrnNo(), true)) { // 因库位移转、需预留空库位 if (locMastService.checkEmptyCount(locMast0, 10)) { locMast = locMast0; break; } } } } } } //找内侧空库位(非最外侧库位) if (locMast == null) { List locNos = locDetlService.getSameDetl(matNos.get(0)); for (String locNo : locNos) { List groupLoc = Utils.getGroupLoc(locNo); List locMasts = locMastService.findEmptyLocMastByLocNos(locTypeDto.getLocType1(), groupLoc, null); for (LocMast locMast0 : locMasts) { //检测当前库位内侧其他库位是否为D、F、X if (Utils.checkInsideLocIsDFX(locMast0.getLocNo())) { //内侧其他库位不是D、F、X。不能选取该库位 continue; } // 浅库位符合尺寸检测 if (VersionUtils.locMoveCheckLocType(locMast0, locTypeDto)) { // 浅库位对应堆垛机必须可用且无异常 if (basCrnpService.checkSiteError(locMast0.getCrnNo(), true)) { // 因库位移转、需预留空库位 if (locMastService.checkEmptyCount(locMast0, 10)) { locMast = locMast0; break; } } } } } } //未找到巷道，找一条新的空巷道 if (locMast == null) { //随机可用堆垛机号 Integer randomCrnNo = Utils.getRandomCrnNo(crnNos, locTypeDto.getLocType1()); for (Integer crnNo : crnNos) { List locMasts = locMastService.findInEmptyLocMast(locTypeDto.getLocType1(), rows, crnNo);//找一条新的空巷道 for (LocMast locMast0 : locMasts) { //检测当前库位内侧其他库位是否为D、F、X if (Utils.checkInsideLocIsDFX(locMast0.getLocNo())) { //内侧其他库位不是D、F、X。不能选取该库位 continue; } // 浅库位符合尺寸检测 if (VersionUtils.locMoveCheckLocType(locMast0, locTypeDto)) { // 浅库位对应堆垛机必须可用且无异常 if (basCrnpService.checkSiteError(locMast0.getCrnNo(), true)) { // 因库位移转、需预留空库位 if (locMastService.checkEmptyCount(locMast0, 10)) { locMast = locMast0; break; } } } } } } return locMast; } //高频类型入最外侧库位 private LocMast getLocNoStep3(LocTypeDto locTypeDto, List crnNos) { LocMast locMast = null; //随机可用堆垛机号 Integer randomCrnNo = Utils.getRandomCrnNo(crnNos, locTypeDto.getLocType1()); if (randomCrnNo == null) { return locMast; } ArrayList randomCrnNos = new ArrayList<>(); randomCrnNos.add(randomCrnNo); //找最外侧空库位 List locMasts = locMastService.findOutMast(locTypeDto.getLocType1(), randomCrnNos); for (LocMast locMast0 : locMasts) { //检测当前库位内侧其他库位是否为D、F、X if (Utils.checkInsideLocIsDFX(locMast0.getLocNo())) { //内侧其他库位不是D、F、X。不能选取该库位 continue; } // 浅库位符合尺寸检测 if (VersionUtils.locMoveCheckLocType(locMast0, locTypeDto)) { // 浅库位对应堆垛机必须可用且无异常 if (basCrnpService.checkSiteError(locMast0.getCrnNo(), true)) { // 因库位移转、需预留空库位 if (locMastService.checkEmptyCount(locMast0, 10)) { locMast = locMast0; } } } } return locMast; } //低频类型，直接找混放区域 private LocMast getLocNoStep4(LocTypeDto locTypeDto, List crnNos) { LocMast locMast = null; //随机可用堆垛机号 Integer randomCrnNo = Utils.getRandomCrnNo(crnNos, locTypeDto.getLocType1()); List locMasts = locMastService.findEmptyLowFrequencyLocMast(locTypeDto.getLocType1(), randomCrnNo); for (LocMast locMast0 : locMasts) { //检测当前库位内侧其他库位是否为D、F、X if (Utils.checkInsideLocIsDFX2(locMast0.getLocNo())) { //内侧其他库位不是D、F、X。不能选取该库位 continue; } //检测当前库位外侧库位是否为O(空库位) boolean flag = false; List outerLoc = Utils.getGroupOuterLoc(locMast0.getLocNo()); if (outerLoc.size() > 0) { List outerLocMast = locMastService.selectByLocNos(outerLoc); for (LocMast mast : outerLocMast) { if (!mast.getLocSts().equals("O")) { //不是空库位，找下一个 flag = true; break; } } } if (flag) { continue; } // 浅库位符合尺寸检测 if (VersionUtils.locMoveCheckLocType(locMast0, locTypeDto)) { // 浅库位对应堆垛机必须可用且无异常 if (basCrnpService.checkSiteError(locMast0.getCrnNo(), true)) { Integer outermostRow = Utils.getOutermostRow(locMast0.getLocNo(), true); LocMast locMast1 = locMastService.selectOne(new EntityWrapper().eq("row1", outermostRow).eq("bay1", locMast0.getBay1()).eq("lev1", locMast0.getLev1())); if (!locMast1.getLocSts().equals("O") && !locMast0.getRow1().equals(outermostRow)){ // 因库位移转、需预留空库位 if (locMastService.checkEmptyCount0(locMast0, 5)) { locMast = locMast0; } }else { locMast = locMast0; } } } } return locMast; } //返回dto private StartupDto getLocNoFinalStep(Integer staDescId, Integer sourceStaNo, LocMast locMast) { // 获取目标站 Wrapper wrapper = new EntityWrapper() .eq("type_no", staDescId) .eq("stn_no", sourceStaNo) .eq("crn_no", locMast.getCrnNo()); StaDesc staDesc = staDescService.selectOne(wrapper); if (Cools.isEmpty(staDesc)) { log.error("入库路径不存在, staDescId={}, sourceStaNo={}, crnNo={}", staDescId, sourceStaNo, locMast.getCrnNo()); if (sourceStaNo==103 && locMast.getCrnNo()==3){ throw new CoolException("请放到203入库口"); }else if (sourceStaNo==203 && locMast.getCrnNo()==1){ throw new CoolException("请放到103入库口"); }else { throw new CoolException("入库路径不存在"); } } // 检测目标站 BasDevp staNo = basDevpService.selectById(staDesc.getCrnStn()); if (!staNo.getAutoing().equals("Y")) { throw new CoolException("目标站" + staDesc.getCrnStn() + "不可用"); } String locNo = locMast.getLocNo(); // 生成工作号 int workNo = getWorkNo(0); // 返回dto StartupDto startupDto = new StartupDto(); startupDto.setWorkNo(workNo); startupDto.setCrnNo(locMast.getCrnNo()); startupDto.setSourceStaNo(sourceStaNo); startupDto.setStaNo(staNo.getDevNo()); startupDto.setLocNo(locNo); return startupDto; } public static String zerofill(String msg, Integer count) { if (msg.length() == count) { return msg; } else if (msg.length() > count) { return msg.substring(0, 16); } else { StringBuilder msgBuilder = new StringBuilder(msg); for(int i = 0; i < count - msg.length(); ++i) { msgBuilder.insert(0, "0"); } return msgBuilder.toString(); } } public int getCurRow(int curRow){ switch (curRow){ case 1: case 2: case 8: case 9: case 10: case 15: case 16: case 17: return curRow+1; case 5: case 6: case 7: case 13: case 14: case 20: case 21: return curRow-1; default: return 0; } } }