From ad410e0ce185481c77c8a5e97d3de9f8e1ea011d Mon Sep 17 00:00:00 2001
From: jiangping <jp@doumee.com>
Date: 星期六, 12 十月 2024 18:13:45 +0800
Subject: [PATCH] 最新版本

---
 server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/hksync/HkSyncPushServiceImpl.java |   15 +++++++++++++--
 1 files changed, 13 insertions(+), 2 deletions(-)

diff --git a/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/hksync/HkSyncPushServiceImpl.java b/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/hksync/HkSyncPushServiceImpl.java
index e7c783d..2edaf6b 100644
--- a/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/hksync/HkSyncPushServiceImpl.java
+++ b/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/hksync/HkSyncPushServiceImpl.java
@@ -403,6 +403,7 @@
             List<VisitEvent> list = new ArrayList<>();
             List<Integer> delRetentionLis = new ArrayList<>();
             List<Retention> retentionList = new ArrayList<>();
+            InoutDayCount inoutDayCount = new InoutDayCount();
             for(EventVisitIccmInfoRequest request : events){
                 if(request.getData() ==null || request.getData().getVisitorInvoices() ==null){
                     continue;
@@ -411,7 +412,7 @@
                     continue;
                 }
                 //娴峰悍璁垮璁板綍缂栫爜
-                dealVisitDataByRequstIccm(request,delRetentionLis,retentionList);
+                dealVisitDataByRequstIccm(request,delRetentionLis,retentionList,inoutDayCount);
                 list.add(getVisitEventModelByRequestIccm(request,request.getData().getVisitorInformationList().get(0)));
             }
             if(list.size()>0){
@@ -428,6 +429,7 @@
                 //鍐嶆彃鍏ユ渶鏂扮殑鍦ㄥ巶浜哄憳
                 retentionMapper.insert(retentionList);
             }
+            dealInoutDayCountBiz(inoutDayCount);
             log.info("銆愭捣搴疯瀹簨浠舵帹閫併��========鎴愬姛=======");
         }catch (Exception e){
             log.error("銆愭捣搴疯瀹簨浠舵帹閫併��========澶辫触=======锛歕n"+e.getMessage());
@@ -440,7 +442,7 @@
     /**
      *  鏍规嵁璁垮鎺ㄩ�佽瀹㈣褰曠紪鐮侊紝澶勭悊璁垮璁板綍銆佸湪鍦轰汉鍛樼瓑淇℃伅
      */
-    private void dealVisitDataByRequstIccm(EventVisitIccmInfoRequest request, List<Integer> delRetentionLis, List<Retention> retentionList ) {
+    private void dealVisitDataByRequstIccm(EventVisitIccmInfoRequest request, List<Integer> delRetentionLis, List<Retention> retentionList,  InoutDayCount inoutDayCount) {
 
         EventVisitIccmDataRequest model = request.getData();
         EventVisitIccmInvoiceParamRequest data =  request.getData().getVisitorInvoices();
@@ -462,6 +464,7 @@
                 //濡傛灉鏄瀹㈢櫥璁帮紝褰曞叆浜哄憳鐨勫湪鍦烘暟鎹褰�
 //                retentionList.add(getRetentionModelByVisitRequest(visits, request.getHappenTime(),request.getSrcType()));
                 //鏉ヨ鏃堕棿
+                inoutDayCount.setSigninVisitorNum(Constants.formatIntegerNum(inoutDayCount.getSigninVisitorNum())+1);
                 updateVistis.setStatus(Constants.VisitStatus.signin);
                 updateVistis.setInDate(DateUtil.getISO8601DateByStr(data.getBeginTime()));
                 updateVistis.setOutDate(DateUtil.getISO8601DateByStr(data.getFinishTime()));
@@ -472,6 +475,7 @@
                 memberMapper.updateById(member);
             }else if (Constants.formatIntegerNum(request.getEventType()) == HKConstants.EventTypes.VISIT_SIGN_ICCM_OUT.getKey())  {
                 //濡傛灉鏄瀹㈢绂讳簨浠�
+                inoutDayCount.setLeaveVisitorNum(Constants.formatIntegerNum(inoutDayCount.getLeaveVisitorNum())+1);
                 updateVistis.setStatus(Constants.VisitStatus.signout);
                 updateVistis.setInDate(DateUtil.getISO8601DateByStr(data.getBeginTime()));
                 updateVistis.setOutDate(DateUtil.getISO8601DateByStr(data.getFinishTime()));
@@ -490,6 +494,11 @@
                     r.setDeviceName(request.getData().getParamValues().getSrcName());
                     r.setDeviceIndex(request.getData().getParamValues().getSrcIndex());
                     retentionList.add(r);
+                    inoutDayCount.setInVisitorNum(Constants.formatIntegerNum(inoutDayCount.getInVisitorNum())+1);
+                }
+                if(request.getData()!=null&&request.getData().getParamValues()!=null &&
+                         StringUtils.equals(request.getData().getParamValues().getInOrOut(),"2")){
+                    inoutDayCount.setOutVisitorNum(Constants.formatIntegerNum(inoutDayCount.getOutVisitorNum())+1);
                 }
             }
             updateVistis.setEditDate(new Date());
@@ -824,9 +833,11 @@
                 //濡傛灉鏄叆鍘傛斁琛�
                 delRetentionList.add(event.getPlateNos());
                 retentionList.add(getRetentionModelByParkRequest(request));
+                inoutDayCount.setInCarNum(Constants.formatIntegerNum(inoutDayCount.getInCarNum())+1);
             }else if(Constants.formatIntegerNum(request.getEventType()) == HKConstants.EventTypes.PARK_PASS_OUT.getKey()){
                 //濡傛灉鏄嚭鍦烘斁琛�
                 delRetentionList.add(event.getPlateNos());
+                inoutDayCount.setOutCarNum(Constants.formatIntegerNum(inoutDayCount.getOutCarNum())+1);
             }
         }
         return event;

--
Gitblit v1.9.3