package com.zy.asrs.common.wms.service; import com.alibaba.fastjson.JSON; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.zy.asrs.common.domain.dto.LocTypeDto; import com.zy.asrs.common.domain.dto.StartupDto; import com.zy.asrs.common.wms.entity.LocMast; import com.zy.asrs.common.wms.entity.WrkLastno; import com.zy.asrs.common.wms.entity.WrkMast; import com.zy.asrs.framework.common.Cools; import com.zy.asrs.framework.exception.CoolException; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import java.util.ArrayList; import java.util.List; /** * 货架核心功能 * Created by vincent on 2020/6/11 */ @Slf4j @Service public class CommonService { public static final List FIRST_GROUP_ROW_LIST = new ArrayList() {{ add(1); }}; public static final List SECOND_GROUP_ROW_LIST = new ArrayList() {{ add(3);add(4); }}; public static final List THIRD_GROUP_ROW_LIST = new ArrayList() {{ add(6);add(7); }}; public static final List FOURTH_GROUP_ROW_LIST = new ArrayList() {{ add(8); }}; public static final List FIFTH_GROUP_ROW_LIST = new ArrayList() {{ add(10);add(11); }}; public static final List SIXTH_GROUP_ROW_LIST = new ArrayList() {{ add(13);add(14);add(15);add(16); }}; public static final List SEVENTH_GROUP_ROW_LIST = new ArrayList() {{ add(13);add(14); }}; public static final List EIGHTH_GROUP_ROW_LIST = new ArrayList() {{ add(16); }}; @Autowired private WrkMastService wrkMastService; @Autowired private WrkLastnoService wrkLastnoService; @Autowired private RowLastnoService rowLastnoService; @Autowired private StaDescService staDescService; @Autowired private BasDevpService basDevpService; @Autowired private LocMastService locMastService; @Autowired private LocDetlService locDetlService; /** * 生成工作号 * @param wrkMk 0:入出库 ; 1:其他 * @return workNo(工作号) */ public int getWorkNo(Integer wrkMk) { WrkLastno wrkLastno = wrkLastnoService.getById(wrkMk); if (Cools.isEmpty(wrkLastno)) { throw new CoolException("数据异常,请联系管理员"); } int workNo = 0; // 入出库类型 workNo = wrkLastno.getWrkNo(); int sNo = wrkLastno.getStartNo(); int eNo = wrkLastno.getTargetNo(); workNo = workNo>=eNo ? sNo : workNo+1; while (true) { WrkMast wrkMast = wrkMastService.getOne(new LambdaQueryWrapper().eq(WrkMast::getWrkNo, 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.getOne(new LambdaQueryWrapper().eq(WrkMast::getWrkNo, workNo)) != null) { throw new CoolException("生成工作号" + workNo + "在工作档中已存在"); } } return workNo; } public StartupDto getLocNo(Integer whsType, Integer staDescId, Integer sourceStaNo, List matNos, LocTypeDto locTypeDto, int times) { return getLocNo(staDescId, sourceStaNo, matNos, locTypeDto, times); } /** * 检索库位号 * * @param staDescId 路径ID * @param sourceStaNo 源站 * @param matNos 物料号集合 * @return locNo 检索到的库位号 */ public StartupDto getLocNo(Integer staDescId, Integer sourceStaNo, List matNos, LocTypeDto locTypeDto, int times) { // 目标库位 LocMast locMast = null; // // 靠近摆放规则 --- 空托 // locMast = getLocNoStep4(staDescId, locTypeDto); // if (locMast != null) { // //找到库位,返回dto // return getLocNoStep6(staDescId, sourceStaNo, locMast);//返回dto // } // //库位规则 // locMast = getLocNoStepRule(matNos, locTypeDto); // if (locMast != null) { // //找到库位,返回dto // return getLocNoStep6(staDescId, sourceStaNo, locMast);//返回dto // } // // 靠近摆放规则 --- 相同订单号, 同天同规格物料 // locMast = getLocNoStep3(staDescId, matNos, locTypeDto); // if (locMast != null) { // //找到库位,返回dto // return getLocNoStep6(staDescId, sourceStaNo, locMast);//返回dto // } // // //搜索单品 // locMast = getLocNoStepSingle(matNos, locTypeDto); // if (locMast != null) { // //找到库位,返回dto // return getLocNoStep6(staDescId, sourceStaNo, locMast);//返回dto // } // // //搜索混放 // locMast = getLocNoStepMixed(matNos, locTypeDto, times); // if (locMast != null) { // //找到库位,返回dto // return getLocNoStep6(staDescId, sourceStaNo, locMast);//返回dto // } //找不到库位,抛出异常 throw new CoolException("没有空库位"); } // /** // * 库位规则 // */ // private LocMast getLocNoStepRule(List matNos, LocTypeDto locTypeDto) { // LocMast locMast = null; // // //库位规则只能在单品货物中生效 // if (matNos.size() == 1) { // // 库区锁定 // List locRules = locRuleService.find(Cools.isEmpty(matNos) ? null : matNos.get(0)); // if (locRules == null || locRules.isEmpty()) { // return null;//没有库位规则,跳出当前任务 // } // // for (LocRule locRule : locRules) { // if (locRule == null) { // continue; // } // // List locMasts = locMastService.queryFreeLocMast2(locTypeDto.getLocType1(), locRule.getRowBeg(), locRule.getRowEnd(), locRule.getBayBeg(), locRule.getBayEnd(), locRule.getLevBeg(), locRule.getLevEnd()); // locMast = locFilter(locMasts, matNos,locTypeDto); // // } // // if (locRules.get(0).getKeepGo() == 0) { // //找不到空库位,且禁止继续寻找其他非混载区域库位 // //找不到库位,抛出异常 // throw new CoolException("规则区域没有空库位"); // } // } // // return locMast; // } // // 靠近摆放规则 --- 相同订单号, 同天同规格物料 // private LocMast getLocNoStep3(Integer staDescId, List matNos, LocTypeDto locTypeDto) { // LocMast locMast = null; // if (!Cools.isEmpty(matNos) && matNos.size() == 1 && staDescId == 1) { // //先判断工作档,查找主档IOType=1, wrkSts < 10的工作明细,料号相同的明细库位 // List wrkMasts = wrkMastService.selectSameMatnrs(matNos.get(0)); // for (WrkMast wrkMast : wrkMasts) { // LocMast locMast0 = locMastService.findNearloc(wrkMast.getLocNo()); // if (null != locMast0) { // // 浅库位符合尺寸检测 // if (VersionUtils.checkLocType(locMast0, locTypeDto)) { // locMast = locMast0; // } // } // } // if (Cools.isEmpty(locMast)) { // //再判断库存明细档,料号相同的明细库位 // List locNos = locDetlService.getSameDetl(matNos.get(0)); // for (String locNo : locNos) { // LocMast locMast0 = locMastService.findInnerLoc(locNo); // if (null != locMast0) { // // 浅库位符合尺寸检测 // if (VersionUtils.checkLocType(locMast0, locTypeDto)) { // locMast = locMast0; // break; // } // } // } // } // } // // return locMast; // } // // // 靠近摆放规则 --- 空托 // private LocMast getLocNoStep4(Integer staDescId, LocTypeDto locTypeDto) { // LocMast locMast = null; // // 靠近摆放规则 --- 空托 // if (staDescId == 10) { // //先判断工作档,查找主档IOType=1, wrkSts < 10的工作明细,料号相同的明细库位 // List wrkMasts = wrkMastService.selectList(new EntityWrapper().eq("io_type",10)); // for (WrkMast wrkMast : wrkMasts) { // LocMast locMast0 = locMastService.findNearloc(wrkMast.getLocNo()); // if (null != locMast0) { // // 浅库位符合尺寸检测 // if (VersionUtils.checkLocType(locMast0, locTypeDto)) { // locMast = locMast0; // break; // } // } // } // if (Cools.isEmpty(locMast)){ // List locMasts = locMastService.selectList(new EntityWrapper() // .eq("loc_sts", "O")); // if (locMasts.size() > 0) { // for (LocMast loc : locMasts) { // LocMast locMast0 = locMastService.findNearloc(loc.getLocNo()); // if (null != locMast0) { // // 浅库位符合尺寸检测 // if (VersionUtils.checkLocType(locMast0, locTypeDto)) { // locMast = locMast0; // break; // } // } // } // } // } // } // // return locMast; // } // // // 搜索混放 // private LocMast getLocNoStepMixed(List matNos, LocTypeDto locTypeDto, int times) { // LocMast locMast = null; // // if (matNos.size() > 1) { // List locMasts = locMastService.selectAreaEmpty(locTypeDto.getLocType1(), 1);//搜索混放库位 // //混放区域直接取第一个即可 // for (LocMast mast : locMasts) { // //预留空库位 // if (locMastService.checkEmptyCount(mast, 10)) { // locMast = mast; // break; // } // } // } // // // 2.库位当前所属尺寸无空库位时,调整尺寸参数,向上兼容检索库位 // if (Cools.isEmpty(locMast)) { // log.error("系统没有空库位!!! 尺寸规格: {}, 轮询次数:{}", JSON.toJSONString(locTypeDto), times); // } // // return locMast; // } // // // 搜索单品 // private LocMast getLocNoStepSingle(List matNos, LocTypeDto locTypeDto) { // LocMast locMast = null; // // 1.先搜索单品 // if (matNos.size() == 1) { // //单品 // List locMasts = locMastService.selectAreaEmpty(locTypeDto.getLocType1(), 2);//搜索单品库位 // // for (LocMast mast : locMasts) { // List groupLoc = Utils.getGroupLoc(mast.getLocNo()); // if (!locMastService.checkAllLocEmpty(groupLoc)) { // continue; // } // // LocMast tmp = null; // for (String loc : groupLoc) { // LocMast locMast1 = locMastService.selectByLoc(loc); // if (locMast1 == null) { // continue; // } // // if (!locMast1.getLocSts().equals("O")) { // continue; // } // // tmp = locMast1; // break; // } // // //预留空库位 // if (tmp != null && locMastService.checkEmptyCount(mast, 10)) { // locMast = tmp; // break; // } // } // // if (locMast == null) { // //单品找不到库位,允许尝试从混放区域中进行搜索 // List locMasts2 = locMastService.selectAreaEmpty(locTypeDto.getLocType1(), 1);//搜索单品库位 // //混放区域直接取第一个即可 // for (LocMast mast : locMasts2) { // //预留空库位 // if (locMastService.checkEmptyCount(mast, 10)) { // locMast = mast; // break; // } // } // } // } // // return locMast; // } // // /* // 库存规则搜索到的库位确认 // */ // private LocMast locFilter(List locMasts,List matNos,LocTypeDto locTypeDto){ // for (LocMast locMast0 : locMasts) { // if(!VersionUtils.checkLocType(locMast0,locTypeDto)){ // continue; // } // //单品物料 // if (matNos.size() == 1) { // //如果不是深浅,则直接返回当前库位 // if(Cools.isEmpty(Utils.getGroupDeepLoc(locMast0.getLocNo()))){ // return locMast0; // }else{ // List groupInnerLoc = Utils.getGroupInnerLoc(locMast0.getLocNo()); // //如果是深浅库位,但是内测无库位的情况下,则直接返回当前库位 // if (Cools.isEmpty(groupInnerLoc)) { // return locMast0; // }else { // //获取最深的库位 // String loc = groupInnerLoc.get(groupInnerLoc.size() - 1); // LocMast locMast1 = locMastService.selectByLoc(loc); // //如果最深测库位为空库位,则直接返回最深库位 // if("O".equals(locMast1.getLocSts())){ // return locMast1; // }else { // //如果最深库位状态不为F或者O,则跳出当前的深浅库位查找 // if(!"F".equals(locMast1.getLocSts())){ // continue; // } // List locDetls = locDetlService.selectByLocNo(loc); // //如果当前深库位物料与入库物料不相符,则跳出当前深浅库位查找 // if(!Cools.eq(locDetls.get(0).getMatnr(),matNos.get(0))){ // continue; // } // //从里往外依次遍历该组深浅库位 // for (int i=groupInnerLoc.size()-1; i>=0 ;i--){ // LocMast locMast2 = locMastService.selectByLoc(groupInnerLoc.get(i)); // if("O".equals(locMast2.getLocSts())){ // //如果深库位中含有0状态的库位,则直接返回该库位 // return locMast2; // }else if("F".equals(locMast2.getLocSts())){ // //如果对于locaMast0最近的一个库位也为F状态,则返回locaMastO // if(i==0){ // return locMast0; // }else { // //如果该组深浅库位中含有既不为F也不为O的库位,则跳出当前深浅库位查找 // continue; // } // }else { // break; // } // } // } // // } // } // }else { // if(Cools.isEmpty(Utils.getGroupDeepLoc(locMast0.getLocNo()))){ // return locMast0; // } // } // // } // return null; // } // // //返回dto // private StartupDto getLocNoStep6(Integer staDescId, Integer sourceStaNo, LocMast locMast) { // StartupDto startupDto = new StartupDto(); // String locNo = locMast.getLocNo(); // // 获取目标站 // Wrapper wrapper = new EntityWrapper() // .eq("type_no", staDescId) // .eq("stn_no", sourceStaNo) // .eq("crn_no",Utils.stnNoToLiftNo(sourceStaNo));//借用堆垛机号字段充当提升机号 // StaDesc staDesc = staDescService.selectOne(wrapper); // if (Cools.isEmpty(staDesc)) { // log.error("入库路径不存在, staDescId={}, sourceStaNo={}", staDescId, sourceStaNo); // throw new CoolException("入库路径不存在"); // } // // // 检测目标站 // BasDevp staNo = basDevpService.selectById(staDesc.getCrnStn()); // if (!staNo.getAutoing().equals("Y")) { // throw new CoolException("目标站" + staDesc.getCrnStn() + "不可用"); // } // // // 生成工作号 // int workNo = getWorkNo(0); // // 返回dto // startupDto.setWorkNo(workNo); // startupDto.setSourceStaNo(sourceStaNo); // startupDto.setStaNo(staNo.getDevNo()); // startupDto.setLocNo(locMast.getLocNo()); // return startupDto; // } }