From a58208ba19f52c8d13a0ab1a88bd62ffe8802dd3 Mon Sep 17 00:00:00 2001
From: jiangping <jp@doumee.com>
Date: 星期四, 20 三月 2025 17:03:45 +0800
Subject: [PATCH] 最新版本541200007

---
 server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/thrid/BoardServiceImpl.java |   59 ++++++++++++++++++++++++++++++++++++++++++-----------------
 1 files changed, 42 insertions(+), 17 deletions(-)

diff --git a/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/thrid/BoardServiceImpl.java b/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/thrid/BoardServiceImpl.java
index 9a41523..1b3a5c0 100644
--- a/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/thrid/BoardServiceImpl.java
+++ b/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/thrid/BoardServiceImpl.java
@@ -91,6 +91,8 @@
     private PlatformGroupMapper platformGroupMapper;
     @Autowired
     private TmsService tmsService;
+    @Autowired
+    private PlatformDeviceMapper platformDeviceMapper;
 
     @Value("${debug_model}")
     private Boolean isDebug;
@@ -132,6 +134,7 @@
                         .select(PlatformJob::getTotalNum)
                         .eq(PlatformJob::getIsdeleted,Constants.ZERO)
                         .eq(PlatformJob::getOrigin,Constants.ONE)
+                        .in(PlatformJob::getType,new Integer[]{0,2,4})
                         .in(PlatformJob::getStatus, Constants.PlatformJobStatus.DONE.getKey()
                                 , Constants.PlatformJobStatus.AUTHED_LEAVE.getKey()
                                 , Constants.PlatformJobStatus.LEAVED.getKey())
@@ -801,11 +804,13 @@
                         .selectAll(PlatformJob.class)
                         .eq(PlatformJob::getIsdeleted,Constants.ZERO)
                         .eq(PlatformJob::getCarCodeFront,param.getCarCode())
-                        .in(PlatformJob::getStatus,
+                        .notIn(PlatformJob::getStatus,
                                 Constants.PlatformJobStatus.DONE.getKey(),
                                 Constants.PlatformJobStatus.LEAVED.getKey(),
                                 Constants.PlatformJobStatus.AUTHED_LEAVE.getKey(),
-                                Constants.PlatformJobStatus.CALLED.getKey())
+                                Constants.PlatformJobStatus.CANCEL.getKey()
+                        )
+                        .orderByAsc(PlatformJob::getId)
                         .last("limit 1"));
 
         dealJobDetailAndContractBiz(job,data);
@@ -951,6 +956,7 @@
                         .select(PlatformJob::getTotalNum,PlatformJob::getTotalNum)
                         .select(PlatformJob::getStatus,PlatformJob::getStatus)
                         .eq(PlatformJob::getIsdeleted,Constants.ZERO)
+                        .in(PlatformJob::getType,Constants.ONE,Constants.THREE)
                         .in(PlatformJob::getStatus,Constants.PlatformJobStatus.DONE.getKey(),
                                 Constants.PlatformJobStatus.LEAVED.getKey(),
                                 Constants.PlatformJobStatus.AUTHED_LEAVE.getKey())
@@ -1739,11 +1745,11 @@
                 .eq(Visits::getIsdeleted,Constants.ZERO)
                 .apply("to_days(create_date)=to_days(now())")
                 .in(Visits::getStatus,Constants.VisitStatus.pass,Constants.VisitStatus.xfSuccess )));//寰呰闂�
-        result.setWaitVisitNum(visitsJoinMapper.selectCount(new MPJLambdaWrapper<Visits>()
+        result.setRegisterVisitNum(visitsJoinMapper.selectCount(new MPJLambdaWrapper<Visits>()
                 .eq(Visits::getIsdeleted,Constants.ZERO)
                 .apply("to_days(create_date)=to_days(now())")
                 .in(Visits::getStatus,Constants.VisitStatus.signout,Constants.VisitStatus.signin )));//宸茬櫥璁�
-        result.setWaitVisitNum(visitsJoinMapper.selectCount(new MPJLambdaWrapper<Visits>()
+        result.setLevelNum(visitsJoinMapper.selectCount(new MPJLambdaWrapper<Visits>()
                 .eq(Visits::getIsdeleted,Constants.ZERO)
                 .apply("to_days(create_date)=to_days(now())")
                 .in(Visits::getStatus,Constants.VisitStatus.signout )));//宸茬绂�
@@ -1791,6 +1797,7 @@
                 result.getVisitRetentionDataList().add(t);
             });
         }
+        result.setRetentionNum(result.getVisitRetentionDataList().size());
         return result;
 
     }
@@ -1903,6 +1910,10 @@
                     .orderByDesc(PlatformJob::getStatus )
                     .orderByAsc(PlatformJob::getId )
             );
+            List<PlatformDevice> platformDevices = platformDeviceMapper.selectList(new QueryWrapper<PlatformDevice>().lambda().eq(PlatformDevice::getType,Constants.ONE)
+                    .eq(PlatformDevice::getIsdeleted,Constants.ZERO).isNotNull(PlatformDevice::getDeviceId));
+
+            String videoUrl = getVideoUrl();
             //鏈堝彴鐘舵�侊細0=浣滀笟涓紱1=绌洪棽涓紱2=浣滀笟瓒呮椂;3=鍙彿
             for(Platform model : platformList){
                 PlatformWorkDataVO platformDurationVO = new PlatformWorkDataVO();
@@ -1910,6 +1921,13 @@
                 platformDurationVO.setPlatformId(model.getId());
                 platformDurationVO.setPlatformCode(model.getCode());
                 platformDurationVO.setPlatformSort(model.getSortnum());
+                if(CollectionUtils.isNotEmpty(platformDevices)){
+                    List<PlatformDevice> deviceList = platformDevices.stream().filter(i->Constants.equalsInteger(i.getPlatformId(),model.getId())).collect(Collectors.toList());
+                    if (CollectionUtils.isNotEmpty(deviceList)) {
+                        platformDurationVO.setDeviceId(deviceList.get(Constants.ZERO).getDeviceId());
+                        platformDurationVO.setVideoPluginUrl(videoUrl);
+                    }
+                }
                 PlatformJob job = getJobFromListById(model.getId(),jobList);
                 if(job != null){
                     if(Constants.equalsInteger(job.getType(),Constants.ONE) || Constants.equalsInteger(job.getType(),Constants.THREE)){
@@ -1970,7 +1988,7 @@
         List<PlatformJob> jobList = platformJobMapper.selectJoinList(PlatformJob.class, new MPJLambdaWrapper<PlatformJob>()
                 .selectAll( PlatformJob.class)
 //                .select("(select sum(ifnull(a.io_qty,0)) from platform_wms_detail a where a.isdeleted=0 and a.job_id =t.id )", create_date)
-                .apply("to_days(t.create_date) = to_days(now())")
+                .apply("to_days(t.done_date) = to_days(now())")
                 .eq(Platform::getIsdeleted, Constants.ZERO)
                 .in(PlatformJob::getStatus, Constants.PlatformJobStatus.DONE.getKey()
                         , Constants.PlatformJobStatus.AUTHED_LEAVE.getKey()
@@ -2190,15 +2208,22 @@
         //宸蹭綔涓氭暟
         data.setWorkedNum(platformJobMapper.selectCount(new MPJLambdaWrapper<PlatformJob>()
                 .eq(PlatformJob::getIsdeleted,Constants.ZERO)
-                .and(w->{w.eq(PlatformJob::getStatus,Constants.PlatformJobStatus.WORKING.getKey());})
-                .and(w->{w.in(PlatformJob::getStatus,Constants.PlatformJobStatus.DONE.getKey()
+                .and(w-> w.eq(PlatformJob::getStatus,Constants.PlatformJobStatus.WORKING.getKey())
+                        .or().in(PlatformJob::getStatus,Constants.PlatformJobStatus.DONE.getKey()
                                 ,Constants.PlatformJobStatus.AUTHED_LEAVE.getKey()
-                                ,Constants.PlatformJobStatus.LEAVED.getKey())
-                        .apply("to_days(done_date) = to_days(now())");})
-                .and(w->{w.eq(PlatformJob::getStatus,Constants.PlatformJobStatus.EXCEPTION.getKey())
-                        .apply("to_days(error_date) = to_days(now())");})
-                .and(w->{w.eq(PlatformJob::getStatus,Constants.PlatformJobStatus.TRANSFERING.getKey())
-                        .apply("to_days(trans_platform_date) = to_days(now())");})
+                                ,Constants.PlatformJobStatus.LEAVED.getKey()).apply("to_days(done_date) = to_days(now())")
+                        .or().eq(PlatformJob::getStatus,Constants.PlatformJobStatus.EXCEPTION.getKey()).apply("to_days(done_date) = to_days(now())")
+                        .or().eq(PlatformJob::getStatus,Constants.PlatformJobStatus.TRANSFERING.getKey()).apply("to_days(trans_platform_date) = to_days(now())")
+                )
+//                .and(w->{w.eq(PlatformJob::getStatus,Constants.PlatformJobStatus.WORKING.getKey());})
+//                .and(w->{w.in(PlatformJob::getStatus,Constants.PlatformJobStatus.DONE.getKey()
+//                                ,Constants.PlatformJobStatus.AUTHED_LEAVE.getKey()
+//                                ,Constants.PlatformJobStatus.LEAVED.getKey())
+//                        .apply("to_days(done_date) = to_days(now())");})
+//                .and(w->{w.eq(PlatformJob::getStatus,Constants.PlatformJobStatus.EXCEPTION.getKey())
+//                        .apply("to_days(error_date) = to_days(now())");})
+//                .and(w->{w.eq(PlatformJob::getStatus,Constants.PlatformJobStatus.TRANSFERING.getKey())
+//                        .apply("to_days(trans_platform_date) = to_days(now())");})
         ).intValue());
 
         data.setVideoPluginUrl(getVideoUrl());
@@ -2633,7 +2658,7 @@
         return infoList;
     }
     /**
-     * 杩戜竷鏃ュ埌璐ф儏鍐�
+     * 杩戜竷鏃ュ埌璐ф儏鍐�-鏀规垚杩�15鏃�
      * @return
      */
     @Override
@@ -2645,17 +2670,17 @@
             param.getFacrotyCodeList().add(code);//鏌ヨ鎸囧畾鍘傚尯
         }
         Date date = new Date();
-        Date startDate = DateUtil.addDaysToDate(date,-7);
+        Date startDate = DateUtil.addDaysToDate(date,-15);
         //鐪嬫澘澶у睆杩�7鏃ュ埌璐ф儏鍐垫棩鏈� 0琛ㄧず褰撳ぉ褰撳墠鎺�7澶╋紝-1琛ㄧず鏈湀鍒�1鍙�-7鍙�
         String flag = systemDictDataBiz.queryByCode(Constants.TSM_PARAM,Constants.SCREEN_SEVENT_ARRIVAL_STARTDATE).getCode();
         if(StringUtils.equals(flag,"-1")){
             startDate =DateUtil.getBeginDayOfMonth(0);
-            date = DateUtil.addDaysToDate(startDate,7);
+            date = DateUtil.addDaysToDate(startDate,15);
         }
         param.setNcCreateDateFrom(DateUtil.getShortTime(startDate));
         param.setNcCreateDateThrough(DateUtil.getShortTime(date));
         List<TmsSevenArrivalStatusAndDetailsResponse> infoList =   tmsService.getSevenArrivalStatusAndDetails(param);//鏌ヨ鍑哄簱閲�
-        for (int i = 0; i < 7; i++) {
+        for (int i = 0; i < 15; i++) {
             LastSevenDaysOrderVo model = new LastSevenDaysOrderVo();
             Date td = DateUtil.addDaysToDate(date,-i);
             model.setDateStr(DateUtil.getShortTime(td));

--
Gitblit v1.9.3