#

zhou zhou

8 小时以前 dda2e4a84cbf54262fd465718b769eb50676977a

#

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

@@ -151,6 +151,19 @@
        return mobileService.unbind(site);
    }

    @PostMapping("/agv/unbind2")
    @ManagerAuth
    public R pdaAgvUnbind2(@RequestBody Map<String,Object> map){

        String site = (String) map.get("site"); // 暂存位

        if (Cools.isEmpty(site)) {
            return R.parse("暂存位不能为空");
        }

        return mobileService.unbind2(site);
    }

    @PostMapping("/agv/bind")
    @ManagerAuth
    public R pdaAgvBind(@RequestBody Map<String,Object> map){

 src/main/java/com/zy/asrs/service/MobileService.java

@@ -77,4 +77,6 @@
    void pingKuInventoryAdjustment(PKInventoryAdjustment combParam);

    boolean bindPodAndBerth(String site);

    R unbind2(String site);
}

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

@@ -325,6 +325,57 @@
    }

    @Override
    public R unbind2(String site) {
        String staMap = AgvSiteConstant.SiteMap.get(site);
        if (staMap == null) {
            return R.parse("没有找到该站点的入库映射：" + site);
        }
        JSONObject jsonObject = new JSONObject();
        jsonObject.put("reqCode",UUID.randomUUID().toString().replace("-", "")); // 请求唯一值
        jsonObject.put("ctnrTyp","3"); // 容器类型2
        jsonObject.put("stgBinCode",staMap); // 仓位编号，根据客仓编号转换
        jsonObject.put("indBind","0"); // 1绑定，0解绑

        String body = jsonObject.toJSONString();
        String response = "";
        String message = "";
        boolean success = false;
        try {
            response = new HttpHandler.Builder()
                    .setUri(ApiInterfaceConstant.AGV_IP)
                    .setPath(ApiInterfaceConstant.AGV_BIND_PATH)
                    .setJson(body)
                    .build()
                    .doPost();
            JSONObject res = JSON.parseObject(response);
            message = res.getString("message");
            if (res.getInteger("code").equals(0)) {
                success = true;
            } else {
                log.error("调用agv解绑暂存位失败！！！url：{}；request：{}；response：{}", ApiInterfaceConstant.AGV_IP + ApiInterfaceConstant.AGV_BIND_PATH, body, response);
            }
        } catch (Exception e) {
            log.error("调用agv解绑暂存位异常", e);
        } finally {
            try {
                // 保存接口日志
                apiLogService.save(
                        "调用agv解绑暂存位",
                        ApiInterfaceConstant.AGV_IP + ApiInterfaceConstant.AGV_BIND_PATH,
                        null,
                        "127.0.0.1",
                        body,
                        response,
                        success
                );
            } catch (Exception e) {
                log.error("", e);
            }
        }
        return success ? R.ok("解绑成功") : R.parse(message);
    }

    @Override
    public R unbind(String site) {
        String staMap = AgvSiteConstant.SiteMap.get(site);
        if (staMap == null) {