From 0228e6fe7a5293f866460cb837914829022c5e0f Mon Sep 17 00:00:00 2001
From: lsh <lsh@163.com>
Date: 星期二, 09 九月 2025 08:47:49 +0800
Subject: [PATCH] *

---
 src/main/java/com/zy/core/thread/RoboticArmThread.java         |    2 
 src/main/java/com/zy/asrs/controller/OpenController.java       |   84 ++++++++++++++++++++++++++++
 src/main/java/com/zy/asrs/entity/param/ArmPrecomputeParam.java |   34 +++++++++++
 src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java    |   25 ++++++++
 src/main/java/com/zy/asrs/service/OpenService.java             |    8 ++
 5 files changed, 152 insertions(+), 1 deletions(-)

diff --git a/src/main/java/com/zy/asrs/controller/OpenController.java b/src/main/java/com/zy/asrs/controller/OpenController.java
new file mode 100644
index 0000000..a07109a
--- /dev/null
+++ b/src/main/java/com/zy/asrs/controller/OpenController.java
@@ -0,0 +1,84 @@
+package com.zy.asrs.controller;
+
+import com.baomidou.mybatisplus.mapper.EntityWrapper;
+import com.core.annotations.AppAuth;
+import com.core.common.BaseRes;
+import com.core.common.Cools;
+import com.core.common.R;
+import com.core.exception.CoolException;
+import com.zy.asrs.entity.WrkMast;
+import com.zy.asrs.entity.param.ArmPrecomputeParam;
+import com.zy.asrs.service.OpenService;
+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 javax.servlet.http.HttpServletRequest;
+import java.util.ArrayList;
+import java.util.Date;
+import java.util.List;
+
+/**
+ * Created by vincent on 2024/10/16
+ */
+@Slf4j
+@RestController
+@RequestMapping("open/hd")
+public class OpenController extends BaseController {
+
+    private static final boolean auth = true;
+    public static final ArrayList<String> APP_KEY_LIST = new ArrayList<String>() {{
+        add("ea1f0459efc02a79f046f982767939ae");
+    }};
+
+    @Autowired
+    private OpenService openService;
+
+    /**
+     * 娣诲姞鍑哄簱鍗�
+     */
+    @PostMapping("/task/cs/down/default/v1")
+    @AppAuth(memo = "WCS浠诲姟涓嬪彂")
+    public synchronized R wcsTaskDistribution(@RequestHeader(required = false) String appkey,
+                                              @RequestBody ArmPrecomputeParam param,
+                                              HttpServletRequest request) {
+        try{
+            auth(appkey, param, request);
+        } catch (Exception e){
+            return new R(403,e.getMessage());
+        }
+        if (Cools.isEmpty(param)) {
+            return R.parse(BaseRes.PARAM);
+        }
+//        if (Cools.isEmpty(param.getTaskNo())) {
+//            return R.error("宸ヤ綔鍙穂taskNo]涓嶈兘涓虹┖");
+//        }
+//        if (Cools.isEmpty(param.getStartSta()) || param.getStartSta$()==0) {
+//            return R.error("璧风偣[startSta]涓嶈兘涓虹┖");
+//        }
+//        if (Cools.isEmpty(param.getEndSta())  || param.getEndSta$()==0) {
+//            return R.error("缁堢偣[endSta]涓嶈兘涓虹┖");
+//        }
+
+        return R.ok().add(param);
+    }
+
+
+    private void auth(String appkey, Object obj, HttpServletRequest request) {
+//        log.info("{}鎺ュ彛琚闂紱appkey:{}锛涜姹傛暟鎹細{}", "open/sensorType/list/auth/v1", appkey, JSON.toJSONString(obj));
+        request.setAttribute("cache", obj);
+        if (!auth) {
+            return;
+        }
+        if (Cools.isEmpty(appkey)) {
+            throw new CoolException("璁よ瘉澶辫触锛岃纭appkey鏃犺锛�");
+        }
+        if (!APP_KEY_LIST.contains(appkey)) {
+            throw new CoolException("璁よ瘉澶辫触锛岃纭appkey鏃犺锛�");
+        }
+    }
+
+
+}
diff --git a/src/main/java/com/zy/asrs/entity/param/ArmPrecomputeParam.java b/src/main/java/com/zy/asrs/entity/param/ArmPrecomputeParam.java
new file mode 100644
index 0000000..a5430e8
--- /dev/null
+++ b/src/main/java/com/zy/asrs/entity/param/ArmPrecomputeParam.java
@@ -0,0 +1,34 @@
+package com.zy.asrs.entity.param;
+
+import lombok.Data;
+
+import java.util.List;
+
+/*
+ *  Created by Monkey D. Luffy on 2025.09.09
+ * */
+@Data
+public class ArmPrecomputeParam {
+
+    private List<CombMat> matList;
+
+    @Data
+    public static class CombMat {
+
+        // 闀垮害
+        private Double material_length;
+
+        // 瀹藉害
+        private Double material_width;
+
+        // 楂樺害
+        private Double material_height;
+
+        // 閲嶉噺
+        private Double material_weight;
+
+        // 鏁伴噺
+        private Double material_number = 10.0;
+
+    }
+}
diff --git a/src/main/java/com/zy/asrs/service/OpenService.java b/src/main/java/com/zy/asrs/service/OpenService.java
new file mode 100644
index 0000000..b722018
--- /dev/null
+++ b/src/main/java/com/zy/asrs/service/OpenService.java
@@ -0,0 +1,8 @@
+package com.zy.asrs.service;
+
+import com.core.common.R;
+import com.zy.asrs.entity.param.ArmPrecomputeParam;
+
+public interface OpenService {
+
+}
diff --git a/src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java b/src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java
new file mode 100644
index 0000000..c68de35
--- /dev/null
+++ b/src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java
@@ -0,0 +1,25 @@
+package com.zy.asrs.service.impl;
+
+import com.core.common.R;
+import com.zy.asrs.entity.param.ArmPrecomputeParam;
+import com.zy.asrs.service.OpenService;
+import com.zy.asrs.service.WrkMastService;
+import com.zy.core.properties.SlaveProperties;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.stereotype.Service;
+
+import java.util.ArrayList;
+import java.util.Date;
+import java.util.List;
+
+/**
+ * Created by vincent on 2022/4/9
+ */
+@Slf4j
+@Service
+public class OpenServiceImpl implements OpenService {
+
+
+}
diff --git a/src/main/java/com/zy/core/thread/RoboticArmThread.java b/src/main/java/com/zy/core/thread/RoboticArmThread.java
index b624888..654ba98 100644
--- a/src/main/java/com/zy/core/thread/RoboticArmThread.java
+++ b/src/main/java/com/zy/core/thread/RoboticArmThread.java
@@ -42,7 +42,7 @@
         new Thread(this::roboticArmConnect).start();
 
         // 鍚姩璇绘暟鎹嚎绋�
-        new Thread(this::readStatusRoboticArm).start();
+//        new Thread(this::readStatusRoboticArm).start();
 
         // 鍚姩浠诲姟涓嬪彂绾跨▼
         new Thread(this::taskIssued).start();

--
Gitblit v1.9.1