#

zhou zhou

1 天以前 25e47300d32d8781d96340e6663596ce270cafd3

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

@@ -141,6 +141,93 @@
    }

    @Override
    public R FinishedCall(Map<String, Object> map) {
        String orgSite =  map.get("orgSite").toString();
        String tarSite = map.get("tarSite").toString();
        if (Cools.isEmpty(orgSite) || Cools.isEmpty(tarSite)) {
            return R.error("数据为空");
        }
        if (orgSite.charAt(0) != 'd'){
            throw new CoolException("站点异常，只允许d开头站点");
        }
//        呼叫agv
        boolean success = sendAgvTask2(orgSite, tarSite,"GT6");
        if (!success){
            throw new CoolException("呼叫agv失败");
        }

        return R.ok();
    }

    @Override
    public R agv2fPack(Map<String, Object> map) {
        String orgSite =  map.get("orgSite").toString();
        String tarSite = map.get("tarSite").toString();
        if (Cools.isEmpty(orgSite) || Cools.isEmpty(tarSite)) {
            return R.error("数据为空");
        }
        if (orgSite.charAt(0) != 'd'){
            throw new CoolException("站点异常，只允许d开头站点");
        }
//        呼叫agv
        boolean success = sendAgvTask2(orgSite, tarSite,"GT5");
        if (!success){
            throw new CoolException("呼叫agv失败");
        }

        return R.ok();
    }

    @Override
    public List<ManLocDetl> pingKuGetList(PKInventoryAdjustment combParam) {
        Node node = nodeService.selectOne(new EntityWrapper<Node>().eq("name", combParam.getLocno()).eq("type", 3));
        if (Cools.isEmpty(node)){
            throw new CoolException("未找到平库库位信息");
        }
        EntityWrapper<ManLocDetl> manLocDetlEntityWrapper = new EntityWrapper<>();
        manLocDetlEntityWrapper.eq("loc_no", node.getName());
        manLocDetlEntityWrapper.eq(!Cools.isEmpty(combParam.getMatnr()),"matnr", combParam.getMatnr());
        List<ManLocDetl> manLocDetls = manLocDetlService.selectList(manLocDetlEntityWrapper);
        if (Cools.isEmpty(manLocDetls)){
            throw new CoolException("未找到库存信息");
        }
        return manLocDetls;
    }

    @Override
    @Transactional(rollbackFor = Exception.class)
    public void pingKuInventoryAdjustment(PKInventoryAdjustment combParam) {
        Node node = nodeService.selectOne(new EntityWrapper<Node>().eq("name", combParam.getLocno()).eq("type", 3));
        if (Cools.isEmpty(node)){
            throw new CoolException("未找到平库库位信息");
        }
        for (ManLocDetl manLocDetl :combParam.getManLocDetls()){
            EntityWrapper<ManLocDetl> manLocDetlEntityWrapper = new EntityWrapper<>();
            manLocDetlEntityWrapper.eq("loc_no", manLocDetl.getLocNo());
            manLocDetlEntityWrapper.eq("matnr", manLocDetl.getMatnr());
            manLocDetlEntityWrapper.eq("batch", manLocDetl.getBatch());
            List<ManLocDetl> manLocDetls = manLocDetlService.selectList(manLocDetlEntityWrapper);
            if (Cools.isEmpty(manLocDetls) || manLocDetls.size() > 1){
                throw new CoolException("数据错误");
            }

            ManLocDetl manLocDetl1 = manLocDetls.get(0);
            BigDecimal adjustBigDecimal = new BigDecimal(manLocDetl.getAnfme().toString());
            BigDecimal orgBigDecimal = new BigDecimal(manLocDetl1.getAnfme().toString());
            if (orgBigDecimal.compareTo(adjustBigDecimal) == 0){
                continue;
            }
            manLocDetl1.setAnfme(adjustBigDecimal.doubleValue());
            if (!manLocDetlService.update(manLocDetl1,manLocDetlEntityWrapper)){
                throw new CoolException("更新数据失败");
            }



        }
    }

    @Override
    public R inLocCallAgv(String sta, String inSta) {

        BasDevp basDevp = basDevpMapper.selectById(inSta);
@@ -160,6 +247,10 @@
                break;
            case "3010":
                wrapper.in("source_sta_no", "3013", "3014");
                break;
            case "1000":
            case "1035":
                wrapper.in("source_sta_no", "1024", "1028");
                break;
            default:
        }
@@ -201,8 +292,12 @@
            if (jsonObject.getInteger("code").equals(0)) {
                success = true;
                // 入库暂存+1
                basDevp.setInQty(basDevp.getInQty() + 1);
                basDevpMapper.updateById(basDevp);
                if (!inSta.equals("1000") && !inSta.equals("1035")){
                    basDevp.setInQty(basDevp.getInQty() + 1);
                    basDevpMapper.updateById(basDevp);
                    log.info("入库呼叫，"+basDevp.getDevNo()+"+1");
                }

            } else {
                message = jsonObject.getString("message");
                log.error("入库呼叫agv失败！！！url：{}；request：{}；response：{}", ApiInterfaceConstant.AGV_IP + ApiInterfaceConstant.AGV_CALL_IN_PATH, body, response);
@@ -253,7 +348,7 @@
                    .build()
                    .doPost();
            JSONObject res = JSON.parseObject(response);
            message = jsonObject.getString("message");
            message = res.getString("message");
            if (res.getInteger("code").equals(0)) {
                success = true;
            } else {
@@ -280,12 +375,64 @@
        return success ? R.ok("解绑成功") : R.parse(message);
    }

    public boolean sendAgvTask(String org,String tar){
    public boolean sendAgvTask2(String org,String tar,String type){

        ForwardAGVTaskParam forwardAGVTaskParam = new ForwardAGVTaskParam();
        forwardAGVTaskParam.setReqCode(UUID.randomUUID().toString().replace("-", ""));
        forwardAGVTaskParam.setClientCode("IWMS");
        forwardAGVTaskParam.setTaskTyp("GT3");
        forwardAGVTaskParam.setTaskTyp(type);
        forwardAGVTaskParam.setCtnrTyp("2");
        forwardAGVTaskParam.setPriority("1");
        List<ForwardAGVTaskParam.PositionCodePaths> positionCodePathsList = new ArrayList<>();
        positionCodePathsList.add(new ForwardAGVTaskParam.PositionCodePaths(org, "05"));
        positionCodePathsList.add(new ForwardAGVTaskParam.PositionCodePaths(tar, "04"));
        forwardAGVTaskParam.setPositionCodePath(positionCodePathsList);

        String body = JSON.toJSONString(forwardAGVTaskParam);
        String response = "";
        String message = "";
        boolean success = false;
        try {
            response = new HttpHandler.Builder()
                    .setUri(ApiInterfaceConstant.AGV_IP)
                    .setPath(ApiInterfaceConstant.AGV_CALL_IN_PATH)
                    .setJson(body)
                    .build()
                    .doPost();
            JSONObject jsonObject = JSON.parseObject(response);
            if (jsonObject.getInteger("code").equals(0)) {
                success = true;
            } else {

                log.error("呼叫agv失败！！！url：{}；request：{}；response：{}", ApiInterfaceConstant.AGV_IP + ApiInterfaceConstant.AGV_CALL_IN_PATH, body, response);
            }
        } catch (Exception e) {
            log.error("入库呼叫agv异常", e);
        } finally {
            try {
                // 保存接口日志
                apiLogService.save(
                        "入库呼叫agv",
                        ApiInterfaceConstant.AGV_IP + ApiInterfaceConstant.AGV_CALL_IN_PATH,
                        null,
                        "127.0.0.1",
                        body,
                        response,
                        success
                );
            } catch (Exception e) {
                log.error("", e);
            }
        }
        return success;
    }

    public boolean sendAgvTask(String org,String tar,String type){

        ForwardAGVTaskParam forwardAGVTaskParam = new ForwardAGVTaskParam();
        forwardAGVTaskParam.setReqCode(UUID.randomUUID().toString().replace("-", ""));
        forwardAGVTaskParam.setClientCode("IWMS");
        forwardAGVTaskParam.setTaskTyp(type);
        forwardAGVTaskParam.setCtnrTyp("2");
        forwardAGVTaskParam.setPriority("1");
        List<ForwardAGVTaskParam.PositionCodePaths> positionCodePathsList = new ArrayList<>();
@@ -331,8 +478,8 @@
        }
        return success;
    }

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

@@ -1362,28 +1509,37 @@
        }
        AgvSite orgAgvSite = agvSiteService.selectOne(new EntityWrapper<AgvSite>().eq("name", orgSite));

        AgvSite tarAgvSite = agvSiteService.selectOne(new EntityWrapper<AgvSite>().eq("name", tarSite));
        if (Cools.isEmpty(orgAgvSite) || Cools.isEmpty(tarAgvSite)) {
//        AgvSite tarAgvSite = agvSiteService.selectOne(new EntityWrapper<AgvSite>().eq("name", tarSite));
        if (Cools.isEmpty(orgAgvSite)) {
            return R.error("站点数据错误");
        }

        //更新tar站点状态
        tarAgvSite.setWorkNo(orgAgvSite.getWorkNo());
        tarAgvSite.setStatus(2);
        if (!agvSiteService.updateById(tarAgvSite)){
            throw new CoolException("叫料站更新失败");
//        tarAgvSite.setWorkNo(orgAgvSite.getWorkNo());
//        tarAgvSite.setStatus(2);
//        if (!agvSiteService.updateById(tarAgvSite)){
//            throw new CoolException("叫料站更新失败");
//        }
        WrkMast wrkMast = wrkMastService.selectById(orgAgvSite.getWorkNo());
        if (!Cools.isEmpty(wrkMast)){
            wrkMast.setWrkSts(5L);
            wrkMastService.updateById(wrkMast);
        }

        //更新org站点状态
        orgAgvSite.setStatus(2);
        orgAgvSite.setStatus(0);
        orgAgvSite.setWorkNo(null);
        if (!agvSiteService.updateById(orgAgvSite)){
            throw new CoolException("源站更新失败");
        }

        //呼叫agv
//        boolean success = sendAgvTask(orgSite, tarSite);
//        if (!success){
//            throw new CoolException("呼叫agv失败");
//        }


//        呼叫agv
        boolean success = sendAgvTask(orgSite, tarSite,"GT6");
        if (!success){
            throw new CoolException("呼叫agv失败");
        }

        return R.ok();
    }