From 6c82e309443f491eda73a95c01386becec69224b Mon Sep 17 00:00:00 2001
From: rk <94314517@qq.com>
Date: 星期三, 24 九月 2025 16:00:37 +0800
Subject: [PATCH] 自动叫号业务与WMS获取车辆是否在园接口

---
 server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/thrid/WmsServiceImpl.java |   34 ++++++++++++++++++++++++++++++++++
 1 files changed, 34 insertions(+), 0 deletions(-)

diff --git a/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/thrid/WmsServiceImpl.java b/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/thrid/WmsServiceImpl.java
index e93d5ea..03f044d 100644
--- a/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/thrid/WmsServiceImpl.java
+++ b/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/thrid/WmsServiceImpl.java
@@ -11,6 +11,7 @@
 import com.doumee.core.wms.model.request.*;
 import com.doumee.core.wms.model.response.WmsBaseDataResponse;
 import com.doumee.core.wms.model.response.WmsBaseResponse;
+import com.doumee.core.wms.model.response.WmsCarInParkDataResponse;
 import com.doumee.core.wx.wxPlat.WxPlatConstants;
 import com.doumee.core.wx.wxPlat.WxPlatNotice;
 import com.doumee.dao.business.*;
@@ -845,4 +846,37 @@
         response.getData().add(rData);
         return  response;
     }
+
+
+    @Override
+    public WmsBaseResponse<List<WmsCarInParkDataResponse>> getCarInPark(WmsBaseRequest<String> param) {
+        try {
+            WmsBaseResponse<List<WmsCarInParkDataResponse>> wmsBaseResponse = new WmsBaseResponse();
+            List<Retention> retentionList =  retentionMapper.selectList(new QueryWrapper<Retention>().lambda()
+                            .eq(Retention::getIsdeleted,Constants.ZERO)
+                    .in(Retention::getCarNo,param.getData()));
+            List  list = new ArrayList<>();
+            if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(retentionList)){
+                for (String carNo:param.getData()) {
+                    WmsCarInParkDataResponse wmsCarInParkDataResponse = new WmsCarInParkDataResponse();
+                    wmsCarInParkDataResponse.setCarNo(carNo);
+                    List<Retention> retentions = retentionList.stream().filter(i->i.getCarNo().equals(carNo)).collect(Collectors.toList());
+                    wmsCarInParkDataResponse.setInPark(retentions.size()>Constants.ZERO?true:false);
+                    if(wmsCarInParkDataResponse.getInPark()){
+                        wmsCarInParkDataResponse.setEventDate(retentions.get(Constants.ZERO).getEventDate());
+                    }
+                    list.add(wmsCarInParkDataResponse);
+                }
+
+            }
+            wmsBaseResponse.setSuccess(true);
+            wmsBaseResponse.setMessage("鑾峰彇鎴愬姛");
+            wmsBaseResponse.setData(list);
+            return wmsBaseResponse;
+        }catch (Exception e){
+            log.error("銆怶MS銆戝嚭搴撳彇娑堥�氱煡浠诲姟涓氬姟澶勭悊===============涓氬姟澶勭悊寮傚父"+e.getMessage());
+            return returnFailReuslt("涓氬姟澶勭悊寮傚父");
+        }
+    }
+
 }

--
Gitblit v1.9.3