From 4262bd3905d0f9982dfa265bd443c82a1fff0a00 Mon Sep 17 00:00:00 2001
From: zjj <3272660260@qq.com>
Date: 星期四, 31 十月 2024 10:15:13 +0800
Subject: [PATCH] #

---
 src/main/java/com/zy/asrs/controller/MobileController.java |   73 ++++++++++++++++++++++++++++++++++--
 1 files changed, 69 insertions(+), 4 deletions(-)

diff --git a/src/main/java/com/zy/asrs/controller/MobileController.java b/src/main/java/com/zy/asrs/controller/MobileController.java
index 99d9852..71de5e5 100644
--- a/src/main/java/com/zy/asrs/controller/MobileController.java
+++ b/src/main/java/com/zy/asrs/controller/MobileController.java
@@ -1,5 +1,6 @@
 package com.zy.asrs.controller;
 
+import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.JSONObject;
 import com.baomidou.mybatisplus.mapper.EntityWrapper;
 import com.baomidou.mybatisplus.mapper.Wrapper;
@@ -9,20 +10,21 @@
 import com.core.common.R;
 import com.core.exception.CoolException;
 import com.zy.asrs.entity.*;
-import com.zy.asrs.entity.param.CombParam;
-import com.zy.asrs.entity.param.GDYKConfirmGoodsParam;
-import com.zy.asrs.entity.param.MobileAdjustParam;
-import com.zy.asrs.entity.param.OffSaleParam;
+import com.zy.asrs.entity.param.*;
 import com.zy.asrs.entity.result.MobileAdjustResult;
 import com.zy.asrs.mapper.ManLocDetlMapper;
 import com.zy.asrs.service.*;
 import com.zy.common.model.WrkDto;
 import com.zy.common.service.CommonService;
+import com.zy.common.utils.HttpHandler;
 import com.zy.common.web.BaseController;
+import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.transaction.annotation.Transactional;
 import org.springframework.web.bind.annotation.*;
 
+import java.text.DecimalFormat;
+import java.text.SimpleDateFormat;
 import java.util.*;
 import java.util.List;
 
@@ -32,6 +34,7 @@
  */
 @RestController
 @RequestMapping("mobile")
+@Slf4j
 public class MobileController extends BaseController  {
 
     @Autowired
@@ -61,6 +64,68 @@
     @Autowired
     private CommonService commonService;
 
+    @PostMapping("/agv/start")
+    @ManagerAuth
+    public R pdaAgvStart(@RequestBody Map<String,Object> map){
+        HashMap<String, String> map1 = new HashMap<>();
+        map1.put("agv0001","sta0001");
+        String sta = map.get("sta").toString();
+
+        ForwardAGVTaskParam forwardAGVTaskParam = new ForwardAGVTaskParam();
+        getAgvTaskParam(forwardAGVTaskParam,sta,map1.get(sta));
+        String request = forwardAGVHttpRequest(forwardAGVTaskParam, "10.0.100.110:8182", "/rcms/services/rest/hikRpcService/genAgvSchedulingTask");
+        if ("SUCCESS".equals(request)) {
+            return R.ok();
+        }
+        return R.error();
+    }
+
+    private void getAgvTaskParam(ForwardAGVTaskParam agvTaskCreateParam,String agv,String sta){
+        List<ForwardAGVTaskParam.PositionCodePaths> agvTaskParamList = Arrays.asList(
+                //璧峰浣�
+                new ForwardAGVTaskParam.PositionCodePaths(agv,"05"),
+                //鐩爣浣�
+                new ForwardAGVTaskParam.PositionCodePaths(sta,"05")
+        );
+        Date date = new Date();
+        DecimalFormat df = new DecimalFormat("0000");
+        String wrkNo = "Crn"+date.getTime()/1000;
+        agvTaskCreateParam.setReqCode(wrkNo);
+        agvTaskCreateParam.setReqTime(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()));
+        agvTaskCreateParam.setTaskTyp("GT1");
+        agvTaskCreateParam.setCtnrCode("00000000");
+        agvTaskCreateParam.setPositionCodePath(agvTaskParamList);
+        agvTaskCreateParam.setCtnrTyp("1");
+        agvTaskCreateParam.setTaskCode(wrkNo);
+
+    }
+
+    private String forwardAGVHttpRequest(Object requestParam, String url, String path){
+        String response = "";
+        String success = "error";
+        try {
+            response = new HttpHandler.Builder()
+                    .setUri(url)
+//                    .setHttps(true)
+                    .setPath(path)
+                    .setJson(JSONObject.toJSONString(requestParam))
+                    .build()
+                    .doPost();
+            JSONObject jsonObject = JSON.parseObject(response);
+
+            String message = jsonObject.get("code").toString();
+            if(("0").equals(message) || ("璇锋眰缂栧彿宸插瓨鍦�").contains(message)){
+                success = "SUCCESS";
+            }else {
+                success = message;
+            }
+            log.info("杞彂agv浠诲姟锛氳姹備綋:"+JSONObject.toJSONString(requestParam)+",杩斿洖鍊�:"+jsonObject);
+        }catch (Exception e){
+
+        }
+        return success;
+    }
+
     @RequestMapping("/select/workDetl/barcode")
     @ManagerAuth
     public R selectWorkDetlBarcode(@RequestBody Map<String,Object> map) {

--
Gitblit v1.9.1