1

zhangc

2025-03-30 396dfb3eba1725868ab2e01d7c1af5e64bf108d3

 src/main/java/com/zy/asrs/controller/AgvMobileController.java

@@ -179,6 +179,20 @@
        }
        log.info("启动入库v2,{}", JSON.toJSONString(params));
        // 组托
        if (params.getBarcode().startsWith("30")) {
            //箱壳入库，货架上只能装一种
            if (!Cools.isEmpty(params.getCombParams())) {
                if (params.getCombParams().size() > 1) {
                    return R.error("箱壳入库，货架上只能装一种物料");
                } else {
                    List<CombParam.CombMat> combMats = params.getCombParams().get(0).getCombMats();
                    if (!Cools.isEmpty(combMats) && combMats.size() > 1) {
                        return R.error("箱壳入库，货架上只能装一种物料");
                    }
                }

            }
        }
        params.getCombParams().forEach(combParam -> {
            agvMobileService.comb(combParam, getUserId());
        });
@@ -203,7 +217,7 @@
                return R.error("缺少容器参数");
            }
            pda.setContainerType(Short.valueOf(pda.getContainerCode().substring(0, 2)));
            workService.emptyPlateIn(pda.getDevNo(), pda.getContainerCode(), pda.getContainerType(), getUserId(), false);
            workService.emptyPlateInV3(pda.getDevNo(), pda.getContainerCode(), pda.getContainerType(), getUserId(), false);
        }

        return R.ok();
@@ -401,9 +415,19 @@

        if (!Cools.isEmpty(locNo)) {
            listByLocNo = agvLocDetlService.selectList(new EntityWrapper<AgvLocDetl>().eq("loc_no", locNo));
            if (listByLocNo != null) {
                for (AgvLocDetl agvLocDetl : listByLocNo) {
                    agvLocDetl.setCount(agvLocDetl.getAnfme());
                }
            }
        }
        if (!Cools.isEmpty(containerCode)) {
            listByContainerCode = agvLocDetlService.selectList(new EntityWrapper<AgvLocDetl>().eq("supp_code", containerCode));
            if (listByContainerCode != null) {
                for (AgvLocDetl agvLocDetl : listByContainerCode) {
                    agvLocDetl.setCount(agvLocDetl.getAnfme());
                }
            }
        }

        Map<String, Object> result = new HashMap<String, Object>();
@@ -620,14 +644,14 @@
            String locNo = map.get("locNo");
            String barcode = map.get("suppCode");
            AgvWrkMast source_loc_no = agvWrkMastService.selectOne(new EntityWrapper<AgvWrkMast>().eq("source_loc_no", locNo));
            if (!Cools.isEmpty(source_loc_no)) {
            if (!Cools.isEmpty(source_loc_no) && source_loc_no.getWrkSts() < 204) {
                throw new CoolException("当前库位已生成任务！");
            }
            AgvLocMast locMastS = agvLocMastService.selectOne(new EntityWrapper<AgvLocMast>().eq("loc_no", locNo).eq("loc_sts", "F"));
            if (Cools.isEmpty(locMastS)) {
                throw new CoolException("当前库位非在库状态！库位号=" + locNo);
            }
            AgvWrkMast wrkMast = createWrkMast(ioType, 22L, locNo, "", barcode, now, getUserId(), Integer.parseInt(barcode.substring(0,2)), floor);
            AgvWrkMast wrkMast = createWrkMast(ioType, 22L, locNo, "", barcode, now, getUserId(), Integer.parseInt(barcode.substring(0, 2)), floor);
            // 同步调拨单
            long flowId = snowflakeIdWorker.nextId();
            List<AgvLocDetl> agvLocDetls = agvLocDetlService.selectList(new EntityWrapper<AgvLocDetl>().eq("loc_no", locNo));