From 9dcbdad3da9dd97bc015002d3a09ee68d5eb18de Mon Sep 17 00:00:00 2001
From: liukangdong <898885815@qq.com>
Date: 星期四, 12 十二月 2024 19:49:32 +0800
Subject: [PATCH] Merge branch 'master' of http://139.186.142.91:10010/r/productDev/dmvisit

---
 server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/thrid/BoardServiceImpl.java |   33 +++++++++++++++++++++++++--------
 1 files changed, 25 insertions(+), 8 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 af2e92e..a062be4 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
@@ -22,6 +22,7 @@
 import com.doumee.core.wms.model.response.WmsInventoryDataResponse;
 import com.doumee.core.wms.model.response.WmsInventoryJsonResponse;
 import com.doumee.dao.business.*;
+import com.doumee.dao.business.join.PlatformWarnEventJoinMapper;
 import com.doumee.dao.business.join.VisitsJoinMapper;
 import com.doumee.dao.business.model.*;
 import com.doumee.dao.web.reqeust.CarsJobAndContractDTO;
@@ -60,7 +61,7 @@
     @Autowired
     private SystemDictDataBiz systemDictDataBiz;
     @Autowired
-    private PlatformWarnEventMapper platformWarnEventMapper;
+    private PlatformWarnEventJoinMapper platformWarnEventJoinMapper;
     @Autowired
     private PlatformJobMapper platformJobMapper;
     @Autowired
@@ -314,7 +315,10 @@
     public  List<PlatformGroupFinishVO> platformGroupFinish(){
         List<PlatformGroupFinishVO> data = new ArrayList<>();
         List<PlatformGroup> groups = platformGroupMapper.selectJoinList(PlatformGroup.class, new MPJLambdaWrapper<PlatformGroup>()
-                .select("(select sum(a.TOTAL_NUM) from platform_job a where a.PLATFORM_GROUP_ID=t.id and a.isdeleted=0   and a.status in(6,9,10) and to_days(a.done_date) = to_days(now()))",PlatformGroup::getOrtherTotalNum)
+                .select("(select sum(case when a.total_num is null  then ( select sum(pwd.IO_QTY) from platform_wms_detail pwd where pwd.JOB_ID = a.id  ) else a.total_num end) from platform_job a where a.PLATFORM_GROUP_ID=t.id and a.isdeleted=0   and a.status in(6,9,10) and to_days(a.done_date) = to_days(now()))",PlatformGroup::getOrtherTotalNum)
+                //.select("(select sum(a.TOTAL_NUM) from platform_job a where a.PLATFORM_GROUP_ID=t.id and a.isdeleted=0   and a.status in(6,9,10) and to_days(a.done_date) = to_days(now()))",PlatformGroup::getOrtherTotalNum)
+
+                //.select(" case when t.total_num is null  then ( select sum(pwd.IO_QTY) from platform_wms_detail pwd where pwd.JOB_ID = t.id  ) else t.total_num end ioQty ")
                 .selectAll(PlatformGroup.class)
                 .eq(PlatformGroup::getIsdeleted,Constants.ZERO)
         );
@@ -400,12 +404,13 @@
         request.setSorts(new ArrayList<>());
         RuleEventFiledOptionsRequest file = new RuleEventFiledOptionsRequest();
         file.setFieldName("event_type");
-        file.setFieldValue("131588");//瀹夐槻鍛婅
+        file.setFieldValue("131588,131593");//瀹夐槻鍛婅鍜屼汉鍛樺憡璀�
         file.setType("in");
         if(type == 1){
+            file.setFieldValue("131588");//瀹夐槻鍛婅
+        }else  if(type == 2){
 
-        }else  if(type == 1){
-
+            file.setFieldValue("131593");//浜哄憳鍛婅
         }
         request.getFiledOptions().add(file);
         SortRequest sort = new SortRequest();
@@ -1444,7 +1449,12 @@
                 (int) retentionList.stream().filter(i->Constants.equalsInteger(i.getType(),Constants.THREE)
                         &&Constants.equalsInteger(i.getCarType(),Constants.RetentionCarType.outTruck)).count()
         );
+        data.setVideoPluginUrl(getVideoUrl());
         return data;
+    }
+
+    private String getVideoUrl() {
+        return  systemDictDataBiz.queryByCode(Constants.FTP,Constants.FTP_RESOURCE_PATH).getCode()+"plugin/VideoWebPlugin.exe";
     }
 
     private void getParkingCarsNum(SecurityBoardVO data) {
@@ -1475,7 +1485,8 @@
             List<PlatformJob> jobList = platformJobMapper.selectJoinList(PlatformJob.class, new MPJLambdaWrapper<PlatformJob>()
                     .selectAll( PlatformJob.class)
                     .select("( select pl.CREATE_DATE from platform_log pl where t.id = pl.obj_id and pl.OBJ_TYPE = "+Constants.PlatformJobLogType.WORKING.getKey()+"  order by pl.CREATE_DATE desc  limit 1  ) as newStartDate")
-                    .select(" (select sum(ifnull(pl.IO_QTY , 0 ))   from platform_wms_detail pl  where   pl.job_id = t.id and pl.isdeleted=0 )",PlatformJob::getWorkNum)
+                    //.select(" (  select sum(ifnull(pl.IO_QTY , 0 ))   from platform_wms_detail pl  where   pl.job_id = t.id and pl.isdeleted=0 )",PlatformJob::getWorkNum)
+                    .select(" (  case when t.total_num is null  then ( select sum(pwd.IO_QTY) from platform_wms_detail pwd where pwd.JOB_ID = t.id  ) else a.total_num end )",PlatformJob::getWorkNum)
                     .apply("to_days(t.create_date) = to_days(now())")
                     .eq(Platform::getIsdeleted, Constants.ZERO)
                     .in(PlatformJob ::getStatus,new Integer[]{Constants.PlatformJobStatus.WORKING.getKey(),Constants.PlatformJobStatus.CALLED.getKey() })
@@ -1612,9 +1623,13 @@
     }
     @Override
     public      List<PlatformWarnEvent> warningList(int limit){
-        List<PlatformWarnEvent> platformLogList = platformWarnEventMapper.selectList(new QueryWrapper<PlatformWarnEvent>().lambda()
+        List<PlatformWarnEvent> platformLogList = platformWarnEventJoinMapper
+                .selectJoinList(PlatformWarnEvent.class,new MPJLambdaWrapper<PlatformWarnEvent>()
+                .selectAll(PlatformWarnEvent.class)
+                .selectAs(Platform::getName,PlatformWarnEvent::getPlatformName)
+                .leftJoin(Platform.class,Platform::getId,PlatformJob::getPlatformId)
                 .eq(PlatformWarnEvent::getIsdeleted,Constants.ZERO)
-                .apply("to_days(create_date) = to_days(now())")
+                .apply("to_days(t.create_date) = to_days(now())")
                 .orderByDesc(PlatformWarnEvent::getCreateDate)
                 .last(" limit "+limit)
         );
@@ -1665,12 +1680,14 @@
                 if( Constants.equalsInteger(model.getStatus(),Constants.PlatformJobStatus.IN_WAIT.getKey())){
                     data.setSignedNum(data.getSignedNum()+Constants.formatIntegerNum(model.getCountum()));
                     data.setReservationCar(data.getReservationCar()+Constants.formatIntegerNum(model.getCountum()));
+                    data.setLineUpCar(data.getLineUpCar()+Constants.formatIntegerNum(model.getCountum()));
                 }
                 //宸插彨鍙凤紙棰勭害杞︺�佺鍒版暟銆佸凡鍙彿锛�
                 if(Constants.equalsInteger(model.getStatus(),Constants.PlatformJobStatus.CALLED.getKey()) ){
                     data.setSignedNum(data.getSignedNum()+Constants.formatIntegerNum(model.getCountum()));
                     data.setReservationCar(data.getReservationCar()+Constants.formatIntegerNum(model.getCountum()));
                     data.setCalledNum(data.getCalledNum()+Constants.formatIntegerNum(model.getCountum()));
+                    data.setLineUpCar(data.getLineUpCar()+Constants.formatIntegerNum(model.getCountum()));
                 }
                 // 浣滀笟杞﹁締锛堥绾﹁溅銆佺鍒版暟銆佸凡鍙彿銆佷綔涓氳溅锛�
                 if(Constants.equalsInteger(model.getStatus(),Constants.PlatformJobStatus.WORKING.getKey())){

--
Gitblit v1.9.3