手持机部分

ruoyi-admin/src/main/java/com/ruoyi/pda/service/PdaServiceImp.java

@@ -5,8 +5,11 @@ import cn.hutool.core.convert.Convert;
 import cn.hutool.core.util.StrUtil;
 import com.ruoyi.bas.cargoSpace.domain.BasCargoSpace;
 import com.ruoyi.bas.cargoSpace.service.IBasCargoSpaceService;
+import com.ruoyi.bas.container.domain.BasContainer;
 import com.ruoyi.bas.containerDetails.domain.BasContainerDetails;
 import com.ruoyi.bas.containerDetails.service.IBasContainerDetailsService;
+import com.ruoyi.bas.port.domain.BasProductPort;
+import com.ruoyi.bas.port.mapper.BasProductPortMapper;
 import com.ruoyi.check.commit.domain.CheckCommitRecord;
 import com.ruoyi.check.commit.service.ICheckCommitRecordService;
 import com.ruoyi.common.core.domain.AjaxResult;
@@ -70,6 +73,8 @@ public class PdaServiceImp implements PdaService {
     @Autowired
     private IOutStockoutDetailService outStockoutDetailService;
     @Autowired
+    private BasProductPortMapper basProductPortMapper;
+    @Autowired
     private IBasStockService basStockService;
 
     /**
@@ -420,4 +425,64 @@ public class PdaServiceImp implements PdaService {
             throw  new RuntimeException(map.get("v_resultmsg").toString());
         }
     }
+
+    @Override
+    public AjaxResult pkIn(TrayCodeMsg trayCodeMsg) {
+        HashMap<String, Object> map = new HashMap<>();
+        map.put("v_stockin_detail_id", trayCodeMsg.getStockinDetailId());
+        map.put("v_in_quantity", Integer.parseInt(trayCodeMsg.getInQuantity()));
+
+        pdaMapper.pkIn(map);
+        String result = map.get("v_result").toString();
+        if ("10".equals(result)) {
+            return AjaxResult.success(map.get("v_resultmsg").toString());
+        } else {
+            return AjaxResult.warn(map.get("v_resultmsg").toString());
+        }
+
+    }
+
+
+    @Override
+    public AjaxResult pkout(TrayCodeMsg trayCodeMsg) {
+        HashMap<String, Object> map = new HashMap<>();
+        map.put("v_stockout_detail_id", trayCodeMsg.getStockinDetailId());
+        pdaMapper.pkOut(map);
+        String result = map.get("v_result").toString();
+        if ("10".equals(result)) {
+            return AjaxResult.success(map.get("v_resultmsg").toString());
+        } else {
+            return AjaxResult.warn(map.get("v_resultmsg").toString());
+        }
+
+    }
+
+    @Override
+    public AjaxResult agvRequest(BasContainer basContainer) {
+        //缓存站点
+        String endPoint = "456";
+        //判断details中的数量是否都为0
+        if (CollUtil.isNotEmpty(basContainer.getDetails())) {
+            for (BasContainerDetails detail : basContainer.getDetails()) {
+               //如果存在数量不为0的
+                if (detail.getQuantity() != 0) {
+
+                    if(StrUtil.isEmpty(basContainer.getSpare1())){
+                        return AjaxResult.warn("请选择退料仓库");
+                    }
+                    //去ctu库站点
+                    BasProductPort basProductPort = new BasProductPort();
+                    basProductPort.setWarehouseId(basContainer.getSpare1());
+                    List<BasProductPort> basProductPorts = basProductPortMapper.selectBasProductPortList(basProductPort);
+                     endPoint=basProductPorts.get(0).getId();
+
+                }
+
+            }
+        }
+        //todo 调用agv搬运接口
+
+
+        return null;
+    }
 }