| | |
|---|
| | | import com.zy.asrs.entity.result.MobileAdjustResult; |
|---|
| | | import com.zy.asrs.mapper.ManLocDetlMapper; |
|---|
| | | import com.zy.asrs.service.*; |
|---|
| | | import com.zy.common.constant.ApiInterfaceConstant; |
|---|
| | | import com.zy.common.model.WrkDto; |
|---|
| | | import com.zy.common.service.CommonService; |
|---|
| | | import com.zy.common.utils.HttpHandler; |
|---|
| | |
|---|
| | | @PostMapping("/agv/start") |
|---|
| | | @ManagerAuth |
|---|
| | | public R pdaAgvStart(@RequestBody Map<String,Object> map){ |
|---|
| | | |
|---|
| | | if (Cools.isEmpty(map.get("sta"))) { |
|---|
| | | return R.parse("暂存位不能为空"); |
|---|
| | | } else if (Cools.isEmpty(map.get("inSta"))) { |
|---|
| | | return R.parse("入库站点不能为空"); |
|---|
| | | } |
|---|
| | | // HashMap<String, String> map1 = new HashMap<>(); |
|---|
| | | // map1.put("agv0001","sta0001"); |
|---|
| | | // String sta = map.get("sta").toString(); |
|---|
| | |
|---|
| | | // return R.ok(); |
|---|
| | | // } |
|---|
| | | String sta = (String) map.get("sta"); // 暂存位 |
|---|
| | | String inSts = "1040"; // 入库站点 |
|---|
| | | String inSta = (String) map.get("inSta"); // 入库站点 |
|---|
| | | |
|---|
| | | ForwardAGVTaskParam forwardAGVTaskParam = new ForwardAGVTaskParam(); |
|---|
| | | forwardAGVTaskParam.setReqCode(UUID.randomUUID().toString().replace("-", "")); |
|---|
| | | forwardAGVTaskParam.setTaskTyp("GT3"); |
|---|
| | | forwardAGVTaskParam.setCtnrTyp("2"); |
|---|
| | | forwardAGVTaskParam.setPriority("1"); |
|---|
| | | List<ForwardAGVTaskParam.PositionCodePaths> positionCodePathsList = new ArrayList<>(); |
|---|
| | | positionCodePathsList.add(new ForwardAGVTaskParam.PositionCodePaths(sta,"05")); |
|---|
| | | positionCodePathsList.add(new ForwardAGVTaskParam.PositionCodePaths(inSts,"05")); |
|---|
| | | forwardAGVTaskParam.setPositionCodePath(positionCodePathsList); |
|---|
| | | return mobileService.inLocCallAgv(sta, inSta); |
|---|
| | | |
|---|
| | | String body = JSON.toJSONString(forwardAGVTaskParam); |
|---|
| | | String response = ""; |
|---|
| | | 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( |
|---|
| | | // "请求仓储MES盘点单上报接口", |
|---|
| | | // MesConstant.MES_CC_IP_PORT + MesConstant.MES_CC_SB_URL, |
|---|
| | | // null, |
|---|
| | | // "127.0.0.1", |
|---|
| | | // JSON.toJSONString(collect), |
|---|
| | | // response, |
|---|
| | | // success |
|---|
| | | // ); |
|---|
| | | } catch (Exception e) { log.error("", e); } |
|---|
| | | } |
|---|
| | | |
|---|
| | | return R.error(); |
|---|
| | | } |
|---|
| | | |
|---|
| | | private void getAgvTaskParam(ForwardAGVTaskParam agvTaskCreateParam,String agv,String sta){ |
|---|
