我们现在讨论一下系统找库位方案， 如何实现，对现有找库位规则进行整改，数据库也要整改 1、要能方便的填写单伸堆垛机或双伸堆垛机的深浅库位配置 2、根据...

zwl

16 小时以前 b176072388747abb438990157bfa305b215b4b90

 src/main/java/com/zy/asrs/utils/Utils.java

@@ -29,6 +29,7 @@
import java.util.LinkedHashSet;
import java.util.List;
import java.util.Map;
import java.util.Objects;
import java.util.Locale;

/**
@@ -45,10 +46,10 @@
        return (float) Arith.multiplys(2, f, 1);
    }

    public static int armStaNo(int armNo,int staNo) {
        switch (armNo){
    public static int armStaNo(int armNo, int staNo) {
        switch (armNo) {
            case 1:
                switch (staNo){
                switch (staNo) {
                    case 0:
                        return 7;
                    case 1:
@@ -61,7 +62,7 @@
                        return 0;
                }
            case 2:
                switch (staNo){
                switch (staNo) {
                    case 0:
                        return 5;
                    case 1:
@@ -74,7 +75,7 @@
                        return 0;
                }
            case 3:
                switch (staNo){
                switch (staNo) {
                    case 0:
                        return 3;
                    case 1:
@@ -87,7 +88,7 @@
                        return 0;
                }
            case 4:
                switch (staNo){
                switch (staNo) {
                    case 0:
                        return 1;
                    case 1:
@@ -100,7 +101,7 @@
                        return 0;
                }
            case 5:
                switch (staNo){
                switch (staNo) {
                    case 0:
                        return 11;
                    case 1:
@@ -113,7 +114,7 @@
                        return 0;
                }
            case 6:
                switch (staNo){
                switch (staNo) {
                    case 0:
                        return 13;
                    case 1:
@@ -131,104 +132,220 @@
    }


    public static Integer getStationStorageArea(Integer stationId) {
    public static List<Integer> getStationStorageAreas(Integer stationId) {
        if (stationId == null || stationId <= 0) {
            return null;
            return new ArrayList<>();
        }
        BasDevpService basDevpService = SpringUtils.getBean(BasDevpService.class);
        BasDevp station = basDevpService.selectById(stationId);
        if (station == null) {
            return new ArrayList<>();
        }
        return parseStorageAreas(station.getArea());
    }

    public static Integer getStationStorageArea(Integer stationId) {
        List<Integer> storageAreas = getStationStorageAreas(stationId);
        if (Cools.isEmpty(storageAreas)) {
            return null;
        }
        return parseStorageArea(station.getArea());
        return storageAreas.get(0);
    }

    /**
     * 生成入库找库位时的堆垛机优先顺序。
     *
     * <p>处理规则：
     * 1. 先根据入库站点查询所属库区。
     * 2. 先提取该库区内的堆垛机，并按可用空库位过滤不可用堆垛机。
     * 3. 若当前库区没有满足条件的空库位，再补充其他库区的堆垛机。
     * 4. 当 {@code locType1 = 1} 时，先返回低库位堆垛机，再把同批堆垛机的高库位追加到后面。
     * 5. 对不存在、故障、不可入以及无空库位的堆垛机直接剔除。
     *
     * <p>这里是只读排序工具，不再写回 {@code asr_row_lastno.crn_qty}。
     * {@code crn_qty} 在主数据里表示“堆垛机数量”，不能再被拿来当轮询游标，否则会把整仓配置写坏。
     * <p>当前语义已经切换为“站点第一优先池 + 第二优先池”的配置预览，
     * 不再沿用旧的 area 顺序。
     *
     * <p>返回结果中的每一项格式为：
     * {@code {crnNo: 堆垛机号, locType1: 库位高低类型}}
     * {@code {pool: 优先池编号, seq: 池内顺序, crnNo: 堆垛机号}}
     *
     * @param stationId 入库站点
     * @param locType1 目标库位高低类型，1=低库位，2=高库位
     * @param matnr 物料编码，传入 {@code emptyPallet} 时使用空板排序规则
     * @return 按优先级排好序的堆垛机列表
     * @param locType1  保留兼容参数，当前不参与排序
     * @param matnr     保留兼容参数，当前不参与排序
     * @return 按优先池顺序排好的堆垛机列表
     */
    public static List<Map<String, Integer>> getStationStorageAreaName(Integer stationId, Integer locType1, String matnr) {
        List<Map<String, Integer>> result = new ArrayList<>();
        // 先定位入库站点所属库区。
        Integer storageArea = getStationStorageArea(stationId);
        Integer whsType = GetWhsType(stationId);
        if (storageArea == null || whsType == null || whsType <= 0) {
        BasDevpService basDevpService = SpringUtils.getBean(BasDevpService.class);
        BasDevp station = basDevpService.selectById(stationId);
        if (station == null) {
            return result;
        }
        RowLastnoService rowLastnoService = SpringUtils.getBean(RowLastnoService.class);
        RowLastno rowLastno = rowLastnoService.selectById(whsType);
        if (rowLastno == null) {
            return result;
        }

        BasCrnpService basCrnpService = SpringUtils.getBean(BasCrnpService.class);
        LocMastService locMastService = SpringUtils.getBean(LocMastService.class);
        boolean emptyPallet = "emptyPallet".equalsIgnoreCase(matnr);

        // 先取当前库区对应的堆垛机。
        List<Integer> preferredCrnNos = getAreaCrnNos(storageArea, rowLastno);
        List<Integer> preferredAvailableCrnNos = getAvailableCrnNos(preferredCrnNos, locType1, emptyPallet, basCrnpService, locMastService);
        appendCrnLocTypeEntries(result, preferredAvailableCrnNos, locType1, locMastService);

        // 当前库区没有可用容量时，再补充其他库区堆垛机。
        if (!hasAvailableCapacity(preferredCrnNos, locType1, basCrnpService, locMastService)) {
            List<Integer> otherAreaCrnNos = getOtherAreaCrnNos(storageArea, rowLastno);
            List<Integer> otherAvailableCrnNos = getAvailableCrnNos(otherAreaCrnNos, locType1, emptyPallet, basCrnpService, locMastService);
            appendCrnLocTypeEntries(result, otherAvailableCrnNos, locType1, locMastService);
        }
        appendCrnPoolEntries(result, 1, distinctCrnNos(station.getInFirstCrnCsv()));
        appendCrnPoolEntries(result, 2, distinctCrnNos(station.getInSecondCrnCsv()));
        return result;
    }
    private static void appendCrnLocTypeEntries(List<Map<String, Integer>> result, List<Integer> crnNos, Integer locType1, LocMastService locMastService) {
        Short normalizedLocType1 = normalizeLocType1(locType1);
        if (normalizedLocType1 == null) {
            appendCrnLocTypeEntries(result, crnNos, (short) 1, locMastService);
            appendCrnLocTypeEntries(result, crnNos, (short) 2, locMastService);

    public static List<Integer> parseCrnNos(String csv) {
        List<Integer> crnNos = new ArrayList<>();
        if (Cools.isEmpty(csv)) {
            return crnNos;
        }
        String normalized = csv.replace("，", ",")
                .replace("；", ",")
                .replace("、", ",")
                .replaceAll("\\s+", "");
        if (normalized.isEmpty()) {
            return crnNos;
        }
        for (String segment : normalized.split("[,;]")) {
            if (segment == null || segment.isEmpty()) {
                continue;
            }
            Integer crnNo = safeParseInt(segment);
            if (crnNo == null || crnNo <= 0) {
                throw new CoolException("堆垛机号格式错误：" + segment);
            }
            crnNos.add(crnNo);
        }
        return crnNos;
    }

    public static List<Integer> distinctCrnNos(String csv) {
        return distinctCrnNos(parseCrnNos(csv));
    }

    public static List<Integer> distinctCrnNos(List<Integer> crnNos) {
        List<Integer> result = new ArrayList<>();
        if (Cools.isEmpty(crnNos)) {
            return result;
        }
        LinkedHashSet<Integer> orderedCrnNos = new LinkedHashSet<>();
        for (Integer crnNo : crnNos) {
            if (crnNo == null || crnNo <= 0) {
                continue;
            }
            orderedCrnNos.add(crnNo);
        }
        result.addAll(orderedCrnNos);
        return result;
    }

    public static String normalizeCrnCsv(String csv) {
        return normalizeCrnCsv(parseCrnNos(csv));
    }

    public static String normalizeCrnCsv(List<Integer> crnNos) {
        return joinCrnNos(distinctCrnNos(crnNos));
    }

    public static String joinCrnNos(List<Integer> crnNos) {
        if (Cools.isEmpty(crnNos)) {
            return "";
        }
        StringBuilder builder = new StringBuilder();
        for (Integer crnNo : crnNos) {
            if (crnNo == null || crnNo <= 0) {
                continue;
            }
            if (builder.length() > 0) {
                builder.append(",");
            }
            builder.append(crnNo);
        }
        return builder.toString();
    }

    private static void appendCrnPoolEntries(List<Map<String, Integer>> result, int pool, List<Integer> crnNos) {
        if (result == null || Cools.isEmpty(crnNos)) {
            return;
        }
        appendCrnLocTypeEntries(result, crnNos, normalizedLocType1, locMastService);
        if (normalizedLocType1 == 1) {
            appendCrnLocTypeEntries(result, crnNos, (short) 2, locMastService);
        int seq = 1;
        for (Integer crnNo : crnNos) {
            if (crnNo == null || crnNo <= 0) {
                continue;
            }
            Map<String, Integer> item = new LinkedHashMap<>();
            item.put("pool", pool);
            item.put("seq", seq++);
            item.put("crnNo", crnNo);
            result.add(item);
        }
    }

    private static void appendCrnLocTypeEntries(List<Map<String, Integer>> result, List<Integer> crnNos, Short targetLocType1, LocMastService locMastService) {
    public static List<Integer> parseStorageAreas(String area) {
        List<Integer> areas = new ArrayList<>();
        if (Cools.isEmpty(area)) {
            return areas;
        }
        LinkedHashSet<Integer> orderedAreas = new LinkedHashSet<>();
        String normalized = area.replace("，", ",")
                .replace("；", ";")
                .replace("、", ",")
                .replaceAll("\\s+", "");
        if (normalized.isEmpty()) {
            return areas;
        }
        for (String segment : normalized.split("[,;]")) {
            if (segment == null || segment.isEmpty()) {
                continue;
            }
            Integer areaNo = parseStorageArea(segment);
            if (areaNo != null) {
                orderedAreas.add(areaNo);
            }
        }
        areas.addAll(orderedAreas);
        return areas;
    }

    public static String formatStorageArea(Integer area) {
        if (area == null) {
            return "";
        }
        switch (area) {
            case 1:
                return "A库区";
            case 2:
                return "B库区";
            case 3:
                return "C库区";
            default:
                return String.valueOf(area);
        }
    }

    private static void appendCrnLocTypeEntries(List<Map<String, Integer>> result, List<Integer> crnNos, Integer locType1,
                                                boolean emptyPallet, LocMastService locMastService, Integer area) {
        Short normalizedLocType1 = normalizeLocType1(locType1);
        if (normalizedLocType1 == null) {
            appendCrnLocTypeEntries(result, crnNos, (short) 1, emptyPallet, locMastService, area);
            appendCrnLocTypeEntries(result, crnNos, (short) 2, emptyPallet, locMastService, area);
            return;
        }
        appendCrnLocTypeEntries(result, crnNos, normalizedLocType1, emptyPallet, locMastService, area);
        if (normalizedLocType1 == 1) {
            appendCrnLocTypeEntries(result, crnNos, (short) 2, emptyPallet, locMastService, area);
        }
    }

    private static void appendCrnLocTypeEntries(List<Map<String, Integer>> result, List<Integer> crnNos, Short targetLocType1,
                                                boolean emptyPallet, LocMastService locMastService, Integer area) {
        if (targetLocType1 == null || Cools.isEmpty(crnNos)) {
            return;
        }
        for (Integer crnNo : crnNos) {
            if (!hasAvailableLoc(crnNo, targetLocType1, locMastService) || containsCrnLocType(result, crnNo, targetLocType1)) {
            if (!hasAvailableLoc(crnNo, targetLocType1, emptyPallet, locMastService) || containsCrnLocType(result, area, crnNo, targetLocType1)) {
                continue;
            }
            Map<String, Integer> item = new LinkedHashMap<>();
            item.put("area", area);
            item.put("crnNo", crnNo);
            item.put("locType1", targetLocType1.intValue());
            result.add(item);
        }
    }

    private static boolean containsCrnLocType(List<Map<String, Integer>> result, Integer crnNo, Short locType1) {
    private static boolean containsCrnLocType(List<Map<String, Integer>> result, Integer area, Integer crnNo, Short locType1) {
        for (Map<String, Integer> item : result) {
            if (item == null) {
                continue;
            }
            if (crnNo.equals(item.get("crnNo")) && locType1.intValue() == item.get("locType1")) {
            if (crnNo.equals(item.get("crnNo"))
                    && locType1.intValue() == item.get("locType1")
                    && Objects.equals(area, item.get("area"))) {
                return true;
            }
        }
@@ -240,7 +357,7 @@
    }

    private static List<Integer> getAvailableCrnNos(List<Integer> candidateCrnNos, Integer locType1, boolean emptyPallet,
                                                     BasCrnpService basCrnpService, LocMastService locMastService) {
                                                    BasCrnpService basCrnpService, LocMastService locMastService) {
        LinkedHashSet<Integer> availableCrnNos = new LinkedHashSet<>();
        if (Cools.isEmpty(candidateCrnNos)) {
            return new ArrayList<>();
@@ -249,7 +366,7 @@
            if (crnNo == null || !basCrnpService.checkSiteError(crnNo, true)) {
                continue;
            }
            if (!hasAvailableLocForRequest(crnNo, locType1, locMastService)) {
            if (!hasAvailableLocForRequest(crnNo, locType1, emptyPallet, locMastService)) {
                continue;
            }
            availableCrnNos.add(crnNo);
@@ -274,25 +391,30 @@
        return "Y".equalsIgnoreCase(basCrnp.getEmpIn()) ? 1 : 0;
    }

    private static boolean hasAvailableLocForRequest(Integer crnNo, Integer locType1, LocMastService locMastService) {
    private static boolean hasAvailableLocForRequest(Integer crnNo, Integer locType1, boolean emptyPallet, LocMastService locMastService) {
        Short normalizedLocType1 = normalizeLocType1(locType1);
        if (normalizedLocType1 == null) {
            return hasAvailableLoc(crnNo, (short) 1, locMastService) || hasAvailableLoc(crnNo, (short) 2, locMastService);
            return hasAvailableLoc(crnNo, (short) 1, emptyPallet, locMastService)
                    || hasAvailableLoc(crnNo, (short) 2, emptyPallet, locMastService);
        }
        if (hasAvailableLoc(crnNo, normalizedLocType1, locMastService)) {
        if (hasAvailableLoc(crnNo, normalizedLocType1, emptyPallet, locMastService)) {
            return true;
        }
        return normalizedLocType1 == 1 && hasAvailableLoc(crnNo, (short) 2, locMastService);
        return normalizedLocType1 == 1 && hasAvailableLoc(crnNo, (short) 2, emptyPallet, locMastService);
    }

    private static boolean hasAvailableLoc(Integer crnNo, Short locType1, LocMastService locMastService) {
    private static boolean hasAvailableLoc(Integer crnNo, Short locType1, boolean emptyPallet, LocMastService locMastService) {
        if (crnNo == null || locType1 == null) {
            return false;
        }
        return locMastService.selectCount(new EntityWrapper<LocMast>()
                .eq("crn_no", crnNo)
                .eq("loc_sts", "O")
                .eq("loc_type1", locType1)) > 0;
        EntityWrapper<LocMast> wrapper = new EntityWrapper<LocMast>();
        wrapper.eq("crn_no", crnNo);
        wrapper.eq("loc_sts", "O");
        wrapper.eq("loc_type1", locType1);
        if (!emptyPallet) {
            wrapper.ne("loc_type2", 1);
        }
        return locMastService.selectCount(wrapper) > 0;
    }

    private static Short normalizeLocType1(Integer locType1) {
@@ -340,11 +462,11 @@
            return defaultRowLastno;
        }
        RowLastnoService rowLastnoService = SpringUtils.getBean(RowLastnoService.class);
        List<RowLastno> typeMatched = rowLastnoService.selectList(new EntityWrapper<RowLastno>()
                .eq("type_id", area));
        if (!Cools.isEmpty(typeMatched)) {
            return typeMatched.get(0);
        }
//        List<RowLastno> typeMatched = rowLastnoService.selectList(new EntityWrapper<RowLastno>()
//                .eq("type_id", area));
//        if (!Cools.isEmpty(typeMatched)) {
//            return typeMatched.get(0);
//        }
        List<RowLastno> whsMatched = rowLastnoService.selectList(new EntityWrapper<RowLastno>()
                .eq("whs_type", area));
        if (!Cools.isEmpty(whsMatched)) {
@@ -544,6 +666,7 @@
            return null;
        }
    }

    private static Integer parseStorageArea(String area) {
        if (Cools.isEmpty(area)) {
            return null;
@@ -569,6 +692,7 @@
        }
        return null;
    }

    public static String zerofill(String msg, Integer count) {
        if (msg.length() == count) {
            return msg;
@@ -683,8 +807,8 @@
     */
    public static String getDeepLoc(SlaveProperties slaveProperties, String shallowLoc) {
        int row = getRow(shallowLoc);
        boolean deepLocLeft = isDeepLocLeft(slaveProperties, row-1);
        boolean deepLocRight = isDeepLocRight(slaveProperties, row+1);
        boolean deepLocLeft = isDeepLocLeft(slaveProperties, row - 1);
        boolean deepLocRight = isDeepLocRight(slaveProperties, row + 1);
        int targetRow;
        if (deepLocLeft) {
            targetRow = row - 1;
@@ -713,8 +837,8 @@
     * 获取 浅库位排对应的深库位排
     */
    public static Integer getDeepRow(SlaveProperties slaveProperties, Integer shallowRow) {
        boolean deepLocLeft = isDeepLocLeft(slaveProperties, shallowRow-1);
        boolean deepLocRight = isDeepLocRight(slaveProperties, shallowRow+1);
        boolean deepLocLeft = isDeepLocLeft(slaveProperties, shallowRow - 1);
        boolean deepLocRight = isDeepLocRight(slaveProperties, shallowRow + 1);
        int targetRow;
        if (deepLocLeft) {
            targetRow = shallowRow - 1;
@@ -872,13 +996,13 @@
            if (curRow < sRow || curRow > (crnNumber * 4 + sRow - 1)) {
                throw new CoolException("库位排号异常：排号：" + curRow);
            }
            if ((curRow - (sRow-1)) % 4 == 0) {
            if ((curRow - (sRow - 1)) % 4 == 0) {
                necessaryParameters[1] = curRow;    //curRow   最深库位排
                necessaryParameters[2] = (curRow - (sRow-1)) / 4 + sCrnNo - 1;     //crnNo     堆垛机号
                necessaryParameters[2] = (curRow - (sRow - 1)) / 4 + sCrnNo - 1;     //crnNo     堆垛机号
                necessaryParameters[3] = curRow - 1;    //nearRow  最浅库位排
            } else if ((curRow - (sRow-1)-1) % 4 == 0) {
            } else if ((curRow - (sRow - 1) - 1) % 4 == 0) {
                necessaryParameters[1] = curRow;    //curRow   最深库位排
                necessaryParameters[2] = (curRow - (sRow-1)-1) / 4 + sCrnNo;     //crnNo     堆垛机号
                necessaryParameters[2] = (curRow - (sRow - 1) - 1) / 4 + sCrnNo;     //crnNo     堆垛机号
                necessaryParameters[3] = curRow + 1;    //nearRow  最浅库位排
            } else {
                throw new CoolException("库位排号异常：排号：" + curRow);
@@ -1046,6 +1170,7 @@

        return necessaryParameters;
    }

    //四向库（牛眼\光泰）
    public static int[] LocNecessaryParametersDoubleExtension6(RowLastno rowLastno, Integer curRow, Integer crnNumber) {
        int[] necessaryParameters = new int[]{0, 0, 0, 0};
@@ -1055,7 +1180,7 @@
        necessaryParameters[0] = crnNumber; // 轮询次数
        curRow = curRow - offset;
        //满板正常入库
        switch (curRow){
        switch (curRow) {
            case 1:
                necessaryParameters[1] = 4;    //curRow   最深库位排
                necessaryParameters[2] = sCrnNo;     //crnNo     堆垛机号
@@ -1101,7 +1226,7 @@
        Integer sCrnNo = rowLastno.getsCrnNo();//起始堆垛机号
        necessaryParameters[0] = crnNumber; // 轮询次数
        //满板正常入库
        if (curRow.equals(rowLastno.geteRow())){
        if (curRow.equals(rowLastno.geteRow())) {
            necessaryParameters[1] = sRow;    //curRow   最深库位排
            necessaryParameters[2] = sCrnNo;     //crnNo     堆垛机号
            necessaryParameters[3] = sRow;    //nearRow  最浅库位排
@@ -1176,22 +1301,23 @@
    // 外侧方向的货位  优先入库方向 ===>> 反之
    public static List<String> getGroupOutLocCrn(Integer curRow, Integer nearRow, String locNo, boolean pakin) {
        List<String> result = new ArrayList<>();
        if (pakin){
            for (int row = curRow;row>=nearRow;row--){
        if (pakin) {
            for (int row = curRow; row >= nearRow; row--) {
                result.add(zerofill(String.valueOf(row), 2) + locNo.substring(2));
            }
        }else {
            for (int row = curRow;row<=nearRow;row++){
        } else {
            for (int row = curRow; row <= nearRow; row++) {
                result.add(zerofill(String.valueOf(row), 2) + locNo.substring(2));
            }
        }
        return result;
    }

    //erp庫位轉換
    public static String ERPLocToWMSLoc(String locNo) {
        String WmsLoc = locNo.substring(1);
        String[] split = locNo.split("-");
        WmsLoc = split[0].substring(1)+split[1]+split[2];
        WmsLoc = split[0].substring(1) + split[1] + split[2];

        return WmsLoc;
    }
@@ -1203,7 +1329,7 @@
        for (char c : row.toCharArray()) {
            if (c == '0') {
                i++;
            }else {
            } else {
                break;
            }
        }
@@ -1213,7 +1339,7 @@
        for (char c : boy.toCharArray()) {
            if (c == '0') {
                j++;
            }else {
            } else {
                break;
            }
        }
@@ -1223,14 +1349,14 @@
        for (char c : lev.toCharArray()) {
            if (c == '0') {
                k++;
            }else {
            } else {
                break;
            }
        }
        lev = lev.substring(k);
        return row + "-" + boy + "-" + lev;
    }
    

}