From 75d0daa4f8dc2010ec92f35cac08a19d240ca45d Mon Sep 17 00:00:00 2001
From: ynhfasrs <ynhfasrs@qq.com>
Date: 星期五, 27 六月 2025 14:23:37 +0800
Subject: [PATCH] #

---
 src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java |  122 ++++++++++++++++++++++++++++++----------
 1 files changed, 91 insertions(+), 31 deletions(-)

diff --git a/src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java b/src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java
index cd5f403..4986366 100644
--- a/src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java
+++ b/src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java
@@ -2,9 +2,12 @@
 
 import com.baomidou.mybatisplus.mapper.EntityWrapper;
 import com.core.common.Cools;
+import com.core.common.R;
 import com.zy.asrs.domain.enums.TaskStatusType;
 import com.zy.asrs.domain.enums.WorkNoType;
 import com.zy.asrs.entity.*;
+import com.zy.asrs.entity.param.CrnStatusParam;
+import com.zy.asrs.entity.param.StationStatusParam;
 import com.zy.asrs.entity.param.TaskCreateInParam;
 import com.zy.asrs.entity.param.TaskCreateParam;
 import com.zy.asrs.service.*;
@@ -23,15 +26,18 @@
     private CommonService commonService;
     @Autowired
     private LocMastService locMastService;
+    @Autowired
+    private BasDevpService basDevpService;
+    @Autowired
+    private BasCrnpService basCrnpService;
+    @Autowired
+    private BasCrnErrorService basCrnErrorService;
 
     @Override
-    public HashMap<String, Object> taskCreate(TaskCreateParam param) {
-        HashMap<String,Object> map=new HashMap<>();
+    public R taskCreate(TaskCreateParam param) {
         TaskWrk taskWrk = taskWrkService.selectByTaskNo(param.getTaskNo());
         if (taskWrk != null) {
-            map.put("Code","0");
-            map.put("Msg",param.getTaskNo()+"浠诲姟宸茬粡鐢熸垚锛�");
-            return map;
+            return R.error(param.getTaskNo() + "浠诲姟宸茬粡鐢熸垚锛�");
         }
 
         Date now = new Date();
@@ -42,14 +48,6 @@
         taskWrk.setWrkNo(workNo1);
         taskWrk.setStatus(TaskStatusType.RECEIVE.id);//浠诲姟鐘舵�侊細鎺ユ敹
         taskWrk.setCreateTime(now);
-        try {
-            if (param.getIoType() > 1) {
-                if (Utils.locNoRowBoolean(locMast.getRow1())) {
-                    param.setTaskPriority(11);
-                }
-            }
-        } catch (Exception e) {
-        }
         taskWrk.setIoType(param.getIoType());//浠诲姟绫诲瀷
         taskWrk.setIoPri(param.getTaskPriority());//浼樺厛绾�
         taskWrk.setBarcode(param.getBarcode());//鏉$爜
@@ -68,42 +66,60 @@
                 taskWrk.setTargetPoint(param.getTargetPoint());
             }
             taskWrk.setTargetPoint(param.getTargetPoint());
+
+            locMast.setLocSts("R");
+            locMast.setModiTime(new Date());
+            locMastService.updateById(locMast);
+
         } else if (param.getIoType() == 3) {
             taskWrk.setWrkSts(11);
             if (!Cools.isEmpty(param.getStartPoint())) {
                 taskWrk.setStartPoint(param.getStartPoint());//璧风偣
                 taskWrk.setTargetPoint(param.getTargetPoint());
             }
-        }
 
+            locMast.setLocSts("R");
+            locMast.setModiTime(new Date());
+            locMastService.updateById(locMast);
+
+            LocMast locMast2 = locMastService.selectOne(new EntityWrapper<LocMast>().eq("loc_no", param.getTargetPoint()));
+            locMast2.setLocSts("S");
+            locMast2.setModiTime(new Date());
+            locMastService.updateById(locMast2);
+        }
 
         if (!Cools.isEmpty(param.getMemo())) {
             taskWrk.setMemo(param.getMemo());//澶囨敞
         }
 
         if (!taskWrkService.insert(taskWrk)) {
-            map.put("Code","0");
-            map.put("Msg",param.getTaskNo()+"鍒涘缓浠诲姟澶辫触锛�");
-            return map;
+            return R.error(param.getTaskNo() + "鍒涘缓浠诲姟澶辫触锛�");
         }
-        map.put("Code","1");
-        map.put("Msg","ok");
-        return map;
+        return R.ok();
     }
 
     @Override
-    public HashMap<String, Object> taskCreateIn(TaskCreateInParam param) {
-        HashMap<String, Object> map = new HashMap<>();
+    public R taskCreateIn(TaskCreateInParam param) {
         TaskWrk taskWrk = taskWrkService.selectByTaskNo(param.getTaskNo());
         if (taskWrk != null) {
-            map.put("Code","0");
-            map.put("Msg", param.getTaskNo() + "浠诲姟宸茬粡鐢熸垚锛�");
-            return map;
+            return R.error(param.getTaskNo() + "浠诲姟宸茬粡鐢熸垚锛�");
         }
 
         Date now = new Date();
         taskWrk = new TaskWrk();
         LocMast locMast = locMastService.selectOne(new EntityWrapper<LocMast>().eq("loc_no", param.getTargetPoint()));
+        if (locMast == null) {
+            return R.error(param.getTaskNo() + "搴撲綅涓嶅瓨鍦紒");
+        }
+
+        if (!locMast.getLocSts().equals("O")) {
+            return R.error(param.getTaskNo() + "搴撲綅涓嶅浜庣┖搴撲綅锛�");
+        }
+
+        locMast.setLocSts("S");
+        locMast.setModiTime(new Date());
+        locMastService.updateById(locMast);
+
         int workNo1 = commonService.getWorkNo(WorkNoType.PAKIN.type);//鑾峰彇鍏ュ簱宸ヤ綔鍙�
         taskWrk.setTaskNo(param.getTaskNo());//浠诲姟鍙�
         taskWrk.setWrkNo(workNo1);
@@ -121,12 +137,56 @@
         }
 
         if (!taskWrkService.insert(taskWrk)) {
-            map.put("Code", "0");
-            map.put("Msg", param.getTaskNo() + "鍒涘缓浠诲姟澶辫触锛�");
-            return map;
+            return R.error(param.getTaskNo() + "鍒涘缓浠诲姟澶辫触锛�");
         }
-        map.put("Code","1");
-        map.put("Msg","ok");
-        return map;
+        return R.ok();
+    }
+
+    @Override
+    public List<StationStatusParam> getStationStatus() {
+        List<StationStatusParam> data = new ArrayList<>();
+        List<BasDevp> list = basDevpService.selectList(new EntityWrapper<BasDevp>()
+                .in("dev_no", 102, 104, 106, 108, 203, 206, 209, 212));
+        for (BasDevp basDevp : list) {
+            String taskNo = "";
+            String barcode = "";
+            if (basDevp.getWrkNo() > 0) {
+                TaskWrk taskWrk = taskWrkService.selectByWrkNo(basDevp.getWrkNo());
+                if (taskWrk != null) {
+                    taskNo = taskWrk.getTaskNo();
+                    barcode = taskWrk.getBarcode();
+                }
+            }
+
+            StationStatusParam param = new StationStatusParam();
+            param.setStaNo(basDevp.getDevNo());
+            param.setTaskNo(taskNo);
+            param.setLoading(basDevp.getLoading());
+            param.setBarcode(barcode);
+
+            data.add(param);
+        }
+        return data;
+    }
+
+    @Override
+    public List<CrnStatusParam> getCrnStatus() {
+        List<CrnStatusParam> crnStatusParams = new ArrayList<>();
+        List<BasCrnp> basCrnps = basCrnpService.selectList(new EntityWrapper<>());
+        for (BasCrnp basCrnp:basCrnps){
+            CrnStatusParam crnStatusParam=new CrnStatusParam();
+            crnStatusParam.setCrnNo(basCrnp.getCrnNo());
+            crnStatusParam.setCrnSts(basCrnp.getCrnSts());
+            crnStatusParam.setErrorCode(basCrnp.getCrnErr());
+            BasCrnError error=basCrnErrorService.selectOne(new EntityWrapper<BasCrnError>().eq("error_code",basCrnp.getCrnErr()));
+            if(Cools.isEmpty(error)){
+                crnStatusParam.setErrorMsg("");
+            }else {
+                crnStatusParam.setErrorMsg(error.getErrName());
+            }
+            crnStatusParams.add(crnStatusParam);
+        }
+
+        return crnStatusParams;
     }
 }

--
Gitblit v1.9.1