From 37f97c17a695aacd4f658eb86483558ba62374cd Mon Sep 17 00:00:00 2001
From: lsh <lsh@163.com>
Date: 星期五, 31 五月 2024 17:56:13 +0800
Subject: [PATCH] #1

---
 src/main/java/com/zy/asrs/controller/AgvOpenController.java |   58 +++++++++++++++++++++++++++++++++++++++++-----------------
 1 files changed, 41 insertions(+), 17 deletions(-)

diff --git a/src/main/java/com/zy/asrs/controller/AgvOpenController.java b/src/main/java/com/zy/asrs/controller/AgvOpenController.java
index f6439dd..bb077b8 100644
--- a/src/main/java/com/zy/asrs/controller/AgvOpenController.java
+++ b/src/main/java/com/zy/asrs/controller/AgvOpenController.java
@@ -6,7 +6,10 @@
 import com.core.annotations.AppAuth;
 import com.core.common.Cools;
 import com.core.common.R;
+import com.zy.asrs.entity.AgvBasDevp;
+import com.zy.asrs.entity.AgvLocMast;
 import com.zy.asrs.entity.AgvWrkMast;
+import com.zy.asrs.entity.WrkMastExecute;
 import com.zy.asrs.entity.param.AgvTaskCallBackParam;
 import com.zy.asrs.service.*;
 import com.zy.asrs.utils.AppAuthUtil;
@@ -53,6 +56,10 @@
     AgvWrkMastService agvWrkMastService;
     @Autowired
     ApiLogService apiLogService;
+    @Autowired
+    private WrkMastExecuteService wrkMastExecuteService;
+    @Autowired
+    private AgvBasDevpService agvBasDevpService;
 
     @PostMapping("/task/event/status")
     @AppAuth(memo = "ESS浠诲姟鍥炶皟")
@@ -83,24 +90,41 @@
                 return R.error("浠诲姟缂栧彿閿欒");
             }
         }
+        if (agvWrkMast.getIoType().equals(121)){
+            try{
+                if (agvWrkMast.getWrkSts().equals(12L)){
+                    WrkMastExecute wrkMastExecute = wrkMastExecuteService.selectOne(new EntityWrapper<WrkMastExecute>().eq("wrk_no", wrkNo));
+                    if (Cools.isEmpty(wrkMastExecute) || wrkMastExecute.getWrkSts()!=1){
+                        return R.error("浠诲姟鐘舵�乄rkSts鍙傛暟鏈夎,WrkSts:"+wrkMastExecute.getWrkSts$());
+                    } else {
+                        wrkMastExecute.setWrkSts(wrkMastExecute.getWrkStsCode());
+                        wrkMastExecuteService.updateById(wrkMastExecute);
+                    }
+                }else {
+                    return R.error("浠诲姟寮傚父");
+                }
+            }catch (Exception e){
+                return R.error(""+e.getMessage());
+            }
+        }else {
+            if(agvWrkMast.getWrkSts() >= 205){
+                return R.error("褰撳墠浠诲姟宸插畬鎴�");
+            }
 
-        if(agvWrkMast.getWrkSts() >= 205){
-            return R.error("褰撳墠浠诲姟宸插畬鎴�");
-        }
-
-        AgvTask agvTask = AgvTask.valueOf(param.getMethod());
-        Class<AgvTask> clz = AgvTask.class;
-        try {
-            Method method = clz.getDeclaredMethod("success", AgvWrkMast.class, AgvTaskCallBackParam.class);
-            method.invoke(agvTask,agvWrkMast,param);
-        } catch (NoSuchMethodException e) {
-            return R.error("浠诲姟鐘舵�乻tatus鍙傛暟鏈夎");
-        } catch (InvocationTargetException e) {
-            log.error(e.getMessage());
-            return R.error();
-        } catch (IllegalAccessException e) {
-            log.error(e.getMessage());
-            return R.error();
+            AgvTask agvTask = AgvTask.valueOf(param.getMethod());
+            Class<AgvTask> clz = AgvTask.class;
+            try {
+                Method method = clz.getDeclaredMethod("success", AgvWrkMast.class, AgvTaskCallBackParam.class);
+                method.invoke(agvTask,agvWrkMast,param);
+            } catch (NoSuchMethodException e) {
+                return R.error("浠诲姟鐘舵�乻tatus鍙傛暟鏈夎");
+            } catch (InvocationTargetException e) {
+                log.error(e.getMessage());
+                return R.error();
+            } catch (IllegalAccessException e) {
+                log.error(e.getMessage());
+                return R.error();
+            }
         }
         return new R(0, "鎴愬姛");
     }

--
Gitblit v1.9.1