From 5ebf8df590e50db08e018372e3b62bc281d062b5 Mon Sep 17 00:00:00 2001
From: zjj <3272660260@qq.com>
Date: 星期一, 12 五月 2025 16:44:52 +0800
Subject: [PATCH] #Agv解绑

---
 rsf-server/src/main/java/com/vincent/rsf/server/api/service/impl/AgvServiceImpl.java |   75 +++++++++++++++++++++++++++++++++++++
 1 files changed, 75 insertions(+), 0 deletions(-)

diff --git a/rsf-server/src/main/java/com/vincent/rsf/server/api/service/impl/AgvServiceImpl.java b/rsf-server/src/main/java/com/vincent/rsf/server/api/service/impl/AgvServiceImpl.java
index 3e87aed..11eba46 100644
--- a/rsf-server/src/main/java/com/vincent/rsf/server/api/service/impl/AgvServiceImpl.java
+++ b/rsf-server/src/main/java/com/vincent/rsf/server/api/service/impl/AgvServiceImpl.java
@@ -7,9 +7,11 @@
 import com.vincent.rsf.server.api.service.AgvService;
 import com.vincent.rsf.server.manager.entity.BasStation;
 import com.vincent.rsf.server.manager.entity.WaitPakin;
+import com.vincent.rsf.server.manager.entity.WaitPakinItem;
 import com.vincent.rsf.server.manager.enums.PakinIOStatus;
 import com.vincent.rsf.server.manager.enums.StaUseStatusType;
 import com.vincent.rsf.server.manager.service.BasStationService;
+import com.vincent.rsf.server.manager.service.WaitPakinItemService;
 import com.vincent.rsf.server.manager.service.WaitPakinService;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
@@ -25,6 +27,77 @@
     private WaitPakinService waitPakinService;
     @Autowired
     private BasStationService basStationService;
+    @Autowired
+    private WaitPakinItemService waitPakinItemService;
+
+    @Override
+    public R AGVStaUnBind(Map<String, Object> params) {
+        String sta = params.get("sta").toString();
+        if (Cools.isEmpty(sta)){
+            throw new CoolException("鎺ラ┏浣嶆潯鐮佷笉鑳戒负绌�");
+        }
+        BasStation basStation = basStationService.getOne(new LambdaQueryWrapper<BasStation>()
+                .eq(BasStation::getStationName, sta)
+                .eq(BasStation::getUseStatus,StaUseStatusType.TYPE_F.type)
+        );
+        if (Cools.isEmpty(basStation)){
+            throw new CoolException("鏈壘鍒版帴椹崇珯鐐逛俊鎭紝璇锋鏌ョ珯鐐圭姸鎬�");
+        }
+        if (Cools.isEmpty(basStation.getBarcode())){
+            throw new CoolException("鏁版嵁閿欒锛屾帴椹崇珯鏃犳潯鐮佷俊鎭�");
+        }
+        WaitPakin waitPakin = waitPakinService.getOne(new LambdaQueryWrapper<WaitPakin>()
+                .eq(WaitPakin::getBarcode, basStation.getBarcode())
+                .eq(WaitPakin::getIoStatus,PakinIOStatus.PAKIN_IO_STATUS_DONE.val)
+        );
+        if (Cools.isEmpty(waitPakin)){
+            throw new CoolException("鏈壘鍒扮粍鎵樻暟鎹�,璇锋鏌ョ姸鎬�");
+        }
+        basStation.setBarcode(null);
+        basStation.setUseStatus(StaUseStatusType.TYPE_O.type);
+        if (!basStationService.updateById(basStation)){
+            throw new CoolException("鏇存柊绔欑偣鐘舵�佸け璐�");
+        }
+        return R.ok("瑙g粦鎴愬姛");
+    }
+
+    @Override
+    public R getStaBindList(Map<String, Object> params) {
+        String sta = params.get("sta").toString();
+        if (Cools.isEmpty(sta)){
+            throw new CoolException("鎺ラ┏浣嶆潯鐮佷笉鑳戒负绌�");
+        }
+        BasStation basStation = basStationService.getOne(new LambdaQueryWrapper<BasStation>()
+                .eq(BasStation::getStationName, sta)
+                .eq(BasStation::getUseStatus,StaUseStatusType.TYPE_F.type)
+        );
+        if (Cools.isEmpty(basStation)){
+            throw new CoolException("鏈壘鍒版帴椹崇珯鐐逛俊鎭紝璇锋鏌ョ珯鐐圭姸鎬�");
+        }
+        if (Cools.isEmpty(basStation.getBarcode())){
+            throw new CoolException("鏁版嵁閿欒锛屾帴椹崇珯鏃犳潯鐮佷俊鎭�");
+        }
+        WaitPakin waitPakin = waitPakinService.getOne(new LambdaQueryWrapper<WaitPakin>()
+                .eq(WaitPakin::getBarcode, basStation.getBarcode())
+                .eq(WaitPakin::getIoStatus,PakinIOStatus.PAKIN_IO_STATUS_DONE.val)
+        );
+        if (Cools.isEmpty(waitPakin)){
+            throw new CoolException("鏈壘鍒扮粍鎵樻暟鎹�,璇锋鏌ョ姸鎬�");
+        }
+        List<WaitPakinItem> waitPakinItems = waitPakinItemService.list(new LambdaQueryWrapper<WaitPakinItem>().eq(WaitPakinItem::getPakinId, waitPakin.getId()));
+        if (Cools.isEmpty(waitPakinItems)){
+            throw new CoolException("鏁版嵁閿欒锛屾湭鎵惧埌缁勬墭鏄庣粏");
+        }
+
+
+
+        return R.ok(Cools
+                .add("barcode", basStation.getBarcode())
+                .add("list", waitPakinItems)
+        );
+    }
+
+
 
     @Override
     @Transactional(rollbackFor = Exception.class)
@@ -42,6 +115,8 @@
         return R.ok("缁戝畾鎴愬姛");
     }
 
+
+
     private BasStation checkStaStatus(String barcode, String sta){
         if (Cools.isEmpty(barcode)){
             throw new CoolException("瀹瑰櫒鐮佷笉鑳戒负绌�");

--
Gitblit v1.9.1