#接口防抖

Administrator

2025-06-27 f910377a07c3ab8e428f094b4bb4d2b03ea1d1a8

 src/main/java/com/zy/asrs/service/impl/MobileServiceImpl.java

@@ -1436,7 +1436,7 @@
    @Override
    public R pdaFxprk(GwmsGenerateInventoryDto param, Long userId) {

        if (Cools.isEmpty(param)) {
        if (Cools.isEmpty(param,param.getMatList())) {
            throw new CoolException("请求参数不能为空：" + param);
        }
        if (Cools.isEmpty(param.getBarcode())) {
@@ -1468,6 +1468,7 @@
        // 生成工作档
        WrkMast wrkMast = new WrkMast();
        wrkMast.setWrkNo(workNo);
        wrkMast.setWhsType(1); // 返修入库标识
        wrkMast.setIoTime(new Date());
        wrkMast.setWrkSts(1L); // 工作状态：设备上走
        wrkMast.setIoType(iotype); // 入出库状态：1.入库
@@ -1547,10 +1548,156 @@
            throw new CoolException(dto.getLocNo() + "目标库位已被占用");
        }

        // 一楼返修入库推送mes做记录
        pushFxrkToMes(param);

        // 返回GWCS目标信息
        openServiceImpl.pushStaNoToGwcs(param.getPalletizingNo(), dto.getStaNo(), dto.getWorkNo(), param.getBarcode(), "二楼返修入库推送gwcs");
        openServiceImpl.pushStaNoToGwcs(param.getPalletizingNo(), dto.getStaNo(), dto.getWorkNo(), param.getBarcode(), "一楼返修入库推送gwcs");

        return R.ok("反修入库成功");
    }

    @Override
    public R pdaBoxIn(BoxInParam param, Long userId) {

        if (Cools.isEmpty(param.getBarcode())) {
            throw new CoolException("条码不能为空：" + param.getBarcode());
        }

        int zpalletCount = locDetlService.selectCount(new EntityWrapper<LocDetl>().eq("zpallet", param.getBarcode()));
        if (zpalletCount > 0) {
            throw new CoolException("库存托盘码已存在：" + param.getBarcode());
        }

        int barcodeCount = wrkMastService.selectCount(new EntityWrapper<WrkMast>().eq("barcode", param.getBarcode()));
        if (barcodeCount > 0) {
            throw new CoolException("工作档已存在该托盘码：" + param.getBarcode());
        }

        LocTypeDto locTypeDto = new LocTypeDto();
        locTypeDto.setLocType1((short) 1);
        int iotype = 1; //空箱

        // 根据源站点寻找库位
        StartupDto dto = commonService.getLocNo(iotype, param.getPalletizingNo(), locTypeDto, 0);

        int workNo = dto.getWorkNo();
        Date now = new Date();
        // 生成工作档
        WrkMast wrkMast = new WrkMast();
        wrkMast.setWrkNo(workNo);
        wrkMast.setIoTime(new Date());
        wrkMast.setWrkSts(1L); // 工作状态：设备上走
        wrkMast.setIoType(iotype); // 入出库状态：1.入库
        wrkMast.setIoPri(13D); // 优先级
        wrkMast.setCrnNo(dto.getCrnNo());
        wrkMast.setSourceStaNo(param.getPalletizingNo());
        wrkMast.setStaNo(dto.getStaNo());
        wrkMast.setLocNo(dto.getLocNo());
        wrkMast.setBarcode(param.getBarcode()); // 托盘码
        wrkMast.setFullPlt("Y"); // 满板：Y
        wrkMast.setPicking("N"); // 拣料
        wrkMast.setExitMk("N"); // 退出
        wrkMast.setEmptyMk("Y"); // 空板
        wrkMast.setLinkMis("Y");
        wrkMast.setCtnType(1); // 容器类型
        // 操作人员数据
        wrkMast.setAppeTime(now);
        wrkMast.setAppeUser(userId);
        wrkMast.setModiTime(now);
        wrkMast.setModiUser(userId);
        wrkMastService.insert(wrkMast);

        if (!Cools.isEmpty(param.getBatch())) {
                WrkDetl wrkDetl = new WrkDetl();
                wrkDetl.setMatnr("空箱");
                wrkDetl.setWrkNo(wrkMast.getWrkNo());
                wrkDetl.setWrkNo(wrkMast.getWrkNo());
                wrkDetl.setBatch(param.getBatch()); // 尺寸
                wrkDetl.setZpallet(param.getBarcode()); // 托盘码
                wrkDetl.setBarcode(param.getBarcode());
                wrkDetl.setMemo(param.getMemo()); //备注
                wrkDetl.setAnfme(param.getAnfme());
                wrkDetl.setIoTime(now);
                wrkDetl.setAppeTime(now);
                wrkDetl.setAppeUser(userId);
                wrkDetl.setModiUser(userId);
                wrkDetl.setModiTime(now);
                if (!wrkDetlService.insert(wrkDetl)) {
                    throw new CoolException("保存工作明细失败");
                }
        }

        // 更新目标库位状态
        LocMast locMast = locMastService.selectById(dto.getLocNo());
        if (locMast.getLocSts().equals("O")) {
            locMast.setLocSts("S"); // S.入库预约
            locMast.setModiTime(now);
            if (!locMastService.updateById(locMast)) {
                throw new CoolException("改变库位状态失败");
            }
        } else {
            throw new CoolException(dto.getLocNo() + "目标库位已被占用");
        }

        // 返回GWCS目标信息
        openServiceImpl.pushStaNoToGwcs(param.getPalletizingNo(), dto.getStaNo(), dto.getWorkNo(), param.getBarcode(), "一楼空箱入库推送gwcs");

        return R.ok("空箱入库成功");
    }

    private void pushFxrkToMes(GwmsGenerateInventoryDto param) {

        for (GwmsGenerateInventoryDto.MatList matList : param.getMatList()){
            matList.setOutOrIn("in");
            matList.setStockType("返修入库");
        }

        boolean success = false;
        // 获取请求头
        Map<String,Object> headers = new HashMap<>();
        headers.put("Content-Type","application/json;charset=UTF-8");

        // 构造请求体
        String body = JSON.toJSONString(param);
        String response = "";
        try {
            response = new HttpHandler.Builder()
                    .setUri(MesConstant.MES_CC_IP_PORT)
                    .setPath(MesConstant.MES_CC_FXRK_URL)
                    .setHeaders(headers)
                    .setJson(body)
                    .build()
                    .doGet();
            if (!Cools.isEmpty(response)) {
                JSONObject jsonObject1 = JSONObject.parseObject(response);
                int code = (int) jsonObject1.get("code");
                boolean state  = jsonObject1.getBoolean("state");
                if (code == 200 && state) {
                    success = true;
                }
            } else {
                log.error("返修入库推送mes记录失败！！！url：{}；request：{}；response：{}", MesConstant.MES_CC_IP_PORT + MesConstant.MES_CC_FXRK_URL, body, response);
            }
        } catch (Exception e) {
            log.error("返修入库推送mes记录异常：{}", e.getMessage());
        } finally {
            try {
                // 保存接口日志
                apiLogService.save(
                        "返修入库推送mes记录",
                        MesConstant.MES_CC_IP_PORT + MesConstant.MES_CC_FXRK_URL,
                        null,
                        "127.0.0.1",
                        body,
                        response,
                        success
                );
            } catch (Exception e) {
                log.error("", e);
            }
        }

    }

    @Override
@@ -1760,6 +1907,27 @@
       return R.ok("调整成功");
    }

    @Override
    public R pdaFhhd(PdaDhhdParam param, Long userId) {

        String orderNo = param.getOrderNo();

        Order order = orderService.selectByNo(orderNo);
        if (order == null) {
            return R.parse("单据编号不存在：" + orderNo);
        } else if (!order.getSettle().equals(4L)) {
            return R.parse("单据状态不为4.已完成");
        }

        order.setSettle(5L);
        order.setUpdateBy(userId);
        order.setUpdateTime(new Date());

        orderService.updateById(order);

        return R.ok("发货核对成功");
    }

    // 同步盘点异常调整结果给mes
    void kctzPushMes(JSONObject jsonObject) {
        // 接口请求结果
@@ -1850,7 +2018,7 @@
     * 调整库存明细
     */
    @Transactional
    void insertLocDetl(String locNo, String barcode, List<PdtzParam.MatList> matList) {
    public void insertLocDetl(String locNo, String barcode, List<PdtzParam.MatList> matList) {
        Date now = new Date();
        for (PdtzParam.MatList mat : matList) {
            LocDetl locDetl = new LocDetl();
@@ -1914,7 +2082,7 @@
                }
                throw new CoolException(msg);
            } else {
                log.error("返修品入库给mes推送待判失败！！！url：{}；request：{}；response：{}", MesConstant.MES_CC_IP_PORT + MesConstant.MES_CC_IP_PORT, body, response);
                log.error("返修品入库给mes推送待判失败！！！url：{}；request：{}；response：{}", MesConstant.MES_CC_IP_PORT + MesConstant.MES_CC_DP_URL, body, response);
                throw new CoolException("返修品入库给mes推送待判失败");
            }
        } catch (Exception e) {
@@ -1924,7 +2092,7 @@
                // 保存接口日志
                apiLogService.save(
                        "返修品入库给mes推送待判",
                        MesConstant.MES_CC_IP_PORT + MesConstant.MES_CC_IP_PORT,
                        MesConstant.MES_CC_IP_PORT + MesConstant.MES_CC_DP_URL,
                        null,
                        "127.0.0.1",
                        body,
@@ -2035,4 +2203,33 @@
        }
        return result;
    }

    @Override
    public List<Map<String, Object>> pdaGetMemo() {
        List<Integer> tagIds = Arrays.asList(7, 8);
        List<Map<String, Object>> raw = matMapper.getBoxMemoMap(tagIds);

        // 用 Map<String, List<String>> 分组
        Map<String, List<String>> grouped = new HashMap<>();
        for (Map<String, Object> row : raw) {
            String tagId = String.valueOf(row.get("tag_id"));
            String memo = String.valueOf(row.get("memo"));
            if (memo == null || "null".equalsIgnoreCase(memo)) continue;

            grouped.computeIfAbsent(tagId, k -> new ArrayList<>()).add(memo);
        }

        // 转成 List<Map<String, Object>> 结构返回
        List<Map<String, Object>> result = new ArrayList<>();
        for (Map.Entry<String, List<String>> entry : grouped.entrySet()) {
            Map<String, Object> item = new HashMap<>();
            item.put("tagId", entry.getKey());
            item.put("memos", entry.getValue());
            result.add(item);
        }

        return result;
    }


}