From 1c20c8231980a8d4b91688ff8641a06d3b2f68ab Mon Sep 17 00:00:00 2001
From: MrShi <1878285526@qq.com>
Date: 星期二, 14 十月 2025 16:34:22 +0800
Subject: [PATCH] 改bug

---
 server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/thrid/BoardServiceImpl.java |  126 +++++++++++++++++++++++++++++++++--------
 1 files changed, 101 insertions(+), 25 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 3e23799..3cef32f 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
@@ -93,7 +93,8 @@
     private TmsService tmsService;
     @Autowired
     private PlatformDeviceMapper platformDeviceMapper;
-
+    @Autowired
+    private CategoryMapper categoryMapper;
     @Value("${debug_model}")
     private Boolean isDebug;
     /**
@@ -489,6 +490,7 @@
         }*/
         return list;
     }
+
     @Override
     public  WaningEventDataVO warningEventData(Integer type){
         WaningEventDataVO lastResult = new WaningEventDataVO();
@@ -498,16 +500,39 @@
         request.setPageSize(1000);
         request.setFiledOptions(new ArrayList<>());
         request.setSorts(new ArrayList<>());
+        request.setFetchImg(true);
         RuleEventFiledOptionsRequest file = new RuleEventFiledOptionsRequest();
         file.setFieldName("event_type");
-        file.setFieldValue("131588,131593");//瀹夐槻鍛婅鍜屼汉鍛樺憡璀�
+        //瀹夐槻浜嬩欢鍒掑垎鏂瑰紡锛�
+        //閲嶇偣鍖哄煙锛氶噸鐐逛汉鍛�-1644175361銆佸尯鍩熷叆渚�-1644175361銆侀檶鐢熶汉-1644171265銆佽溅杈嗚繚鍋�-1644171265
+        //鍗遍櫓琛屼负锛氫汉鍛樺�掑湴-1644171265銆佹湭甯﹀畨鍏ㄥ附-422000002銆佹娊鐑�-422000000銆佹墦鐢佃瘽-422000001銆佺潯宀�-422400001銆佺宀�-422400000
+        file.setFieldValue("131588,131593,1644171265,422000002,422000000,422000001,422400001,422400000,1644175361,1644175361,1644171265,1644171265");//瀹夐槻鍛婅鍜屼汉鍛樺憡璀�
         file.setType("in");
         if(type == 1){
-            file.setFieldValue("131588");//瀹夐槻鍛婅
+            file.setFieldValue("131588,1644175361,1644175361,1644171265,1644171265");//瀹夐槻鍛婅 鍖哄煙鍏ヤ镜
         }else  if(type == 2){
-            file.setFieldValue("131593");//浜哄憳鍛婅
+            file.setFieldValue("131593,1644171265,422000002,422000000,422000001,422400001,422400000");//浜哄憳鍛婅 鍗遍櫓琛屼负
         }
         request.getFiledOptions().add(file);
+
+        RuleEventFiledOptionsRequest fileLte = new RuleEventFiledOptionsRequest();
+        fileLte.setFieldName("happen_time");
+        fileLte.setFieldValue(DateUtil.formatDate(Utils.Date.getEnd(new Date()),"yyyy-MM-dd HH:mm:ss"));
+        fileLte.setType("lte");
+        request.getFiledOptions().add(fileLte);
+
+        RuleEventFiledOptionsRequest fileGte = new RuleEventFiledOptionsRequest();
+        fileGte.setFieldName("happen_time");
+        fileGte.setFieldValue(DateUtil.formatDate(Utils.Date.getStart(new Date()),"yyyy-MM-dd HH:mm:ss"));
+        fileGte.setType("gte");
+        request.getFiledOptions().add(fileGte);
+
+        RuleEventFiledOptionsRequest fileStatus = new RuleEventFiledOptionsRequest();
+        fileStatus.setFieldName("handle_status");
+        fileStatus.setFieldValue("99");
+        fileStatus.setType("neq");
+        request.getFiledOptions().add(fileStatus);
+
         SortRequest sort = new SortRequest();
         sort.setSortField("happen_time");
         sort.setSortType("desc");
@@ -523,6 +548,9 @@
                     try {
                         if(DateUtil.getISO8601DateByStr(r.getHappen_time()).getTime() < Utils.Date.getStart(new Date()).getTime()){
                             continue;
+                        }
+                        if(StringUtils.equals(r.getStatus(),"99")){
+                           continue;
                         }
                     }catch (Exception e){
                     }
@@ -619,6 +647,9 @@
             BaseResponse<BaseListPageResponse<FindHomeAlarmInfoPageResponse>> response = HKService.findHomeAlarmInfoPage(param);
             if(response == null || !StringUtils.equals(response.getCode(), HKConstants.RESPONSE_SUCCEE)){
                 throw  new BusinessException(ResponseStatus.SERVER_ERROR.getCode(), "瀵逛笉璧凤紝娴峰悍鍚屾鏁版嵁澶辫触~");
+            }
+            if(Objects.nonNull(response.getData().getList())){
+                return data;
             }
             for(FindHomeAlarmInfoPageResponse r : response.getData().getList()){
                 AlarmEventDataVO t = new AlarmEventDataVO();
@@ -1000,13 +1031,21 @@
 
     /**
      * 銆愭秷闃茬鎺с�戠湅鏉�-鍛婅淇℃伅闆嗗悎
-     *
+     * @param type 0/null  = 褰撳ぉ锛�1=褰撴湀锛�2=褰撳勾
      * @return
      *
      */
     @Override
-    public   AlarmDataVO alarmDataSumByCate(){
-        AlarmDataVO alarmDataVO = getAlertDataByStartEndTime(DateUtil.getPlusTime2(Utils.Date.getStart(new Date()))
+    public   AlarmDataVO alarmDataSumByCate(Integer type){
+        Date startDate = Utils.Date.getStart(new Date());
+        if(Objects.nonNull(type)){
+            if(Constants.equalsInteger(type,Constants.TWO)){
+                startDate = Utils.Date.getStart(DateUtil.getFirstThisYearDate());
+            }else if(Constants.equalsInteger(type,Constants.ONE)){
+                startDate = Utils.Date.getStart(DateUtil.getFirstThisMonthDate());
+            }
+        }
+        AlarmDataVO alarmDataVO = getAlertDataByStartEndTime(DateUtil.getPlusTime2(startDate)
                 ,(DateUtil.getPlusTime2(new Date())));
         return  alarmDataVO;
     }
@@ -1319,28 +1358,26 @@
         }
         //鑾峰彇寮�濮嬫椂闂�
         List<Long> startTimeList = platformLogList.stream().filter(i->Objects.nonNull(i.getParam1()))
-                .filter(i->DateUtil.formatDate(null,i.getParam1()).equals(today))
+                .filter(i->Objects.nonNull(i.getParam1())&&i.getParam1().indexOf(today)>=0)
                 .map(i->DateUtil.fromStringToDate("yyyy-MM-dd HH:mm:ss",i.getParam1()).getTime()).collect(Collectors.toList());
-        Long startTime  = Collections.min(startTimeList);
+        Long startTime  = null ;
+        if(CollectionUtils.isNotEmpty(startTimeList)){
+            startTime = Collections.min(startTimeList);
+        }
         //鑾峰彇缁撴潫鏃堕棿
         List<Long> endTimeList = platformLogList.stream()
-                .filter(i->Objects.nonNull(i.getParam2())&&DateUtil.formatDate(null,i.getParam2()).equals(today))
+                .filter(i->Objects.nonNull(i.getParam2())&&i.getParam2().indexOf(today)>=0)
                 .map(i->DateUtil.fromStringToDate("yyyy-MM-dd HH:mm:ss",i.getParam2()).getTime()).collect(Collectors.toList());
-        Long endTime = Collections.max(endTimeList);
+        Long endTime = null ;
+        if(CollectionUtils.isNotEmpty(endTimeList)){
+            endTime = Collections.max(endTimeList);
+        }
         if(Objects.isNull(startTime)
             || Objects.isNull(endTime) || (startTime>=endTime)){
             return BigDecimal.ZERO;
         }
         return   totalAmount.divide(new BigDecimal(( endTime - startTime )+"").divide(new BigDecimal("3600000"),2,BigDecimal.ROUND_HALF_UP),2,BigDecimal.ROUND_HALF_UP) ;
     }
-
-
-
-
-
-
-
-
 
 
     private BigDecimal  getSumTotalByList(List<PlatformJob> list,Integer type,Integer status) {
@@ -1548,12 +1585,13 @@
         data.setDeviceTypeList(list);
         Long totalNum =hiddenDangerMapper.selectCount(new QueryWrapper<HiddenDanger>().lambda()
                 .eq(HiddenDanger::getIsdeleted,Constants.ZERO )
-                .apply("to_days(create_date) = to_days(now())" ) );
+                .apply(" DATE_FORMAT(create_date, '%Y-%m')  = DATE_FORMAT(now(), '%Y-%m')  " ) );
         data.setDangerTotalNum(totalNum !=null?totalNum.intValue():0);//浠婃棩闅愭偅鏁伴噺
         totalNum =hiddenDangerMapper.selectCount(new QueryWrapper<HiddenDanger>().lambda()
                 .eq(HiddenDanger::getIsdeleted,Constants.ZERO )
-                .in(HiddenDanger::getStatus,Constants.ONE,Constants.TWO )
-                .apply("to_days(check_date) = to_days(now())" ) );
+//                .in(HiddenDanger::getStatus,Constants.ONE,Constants.TWO )
+                .eq(HiddenDanger::getStatus,Constants.ZERO )
+                .apply(" DATE_FORMAT(create_date, '%Y-%m')  = DATE_FORMAT(now(), '%Y-%m')  " ) );
         data.setDangerDealedNum(totalNum !=null?totalNum.intValue():0);//浠婃棩澶勭悊闅愭偅鏁伴噺
         return  data;
     }
@@ -2060,7 +2098,9 @@
         data.setInParkCarTotal(
                 (int) retentionList.stream().filter(i->Constants.equalsInteger(i.getType(),Constants.THREE)).count()
         );
-        //鍦ㄥ洯杞﹁締
+        //2025骞�8鏈�4鏃�09:24:23 鏇存崲鏁版嵁婧� 涓嶄粠娴峰悍鍙�
+        data.setFreeParkingLot(data.getParkingLotTotal()<data.getInParkCarTotal()?Constants.ZERO:data.getParkingLotTotal() - data.getInParkCarTotal());
+        //褰撳墠鍦ㄥ洯璐ц溅鍙告満鎬绘暟
         data.setInParkCarUserTotal(
                 (int) retentionList.stream().filter(i->Constants.equalsInteger(i.getType(),Constants.FIVE)).count()
         );
@@ -2095,8 +2135,44 @@
                         &&Constants.equalsInteger(i.getCarType(),Constants.RetentionCarType.wxysCar)).count()
         );
         data.setVideoPluginUrl(getVideoUrl());
+
+        data.setOutHyLotTotal(Integer.valueOf(systemDictDataBiz.queryByCode(Constants.WMS_PARAM,Constants.OUT_HY_LOT_TOTAL).getCode()));
+
+
+        data.setInParkCarList(this.getInParkCars(data));
+
         return data;
     }
+
+
+    public List<Map<String,Object>> getInParkCars(SecurityBoardVO securityBoardVO){
+        List<Map<String,Object>> mapList = categoryMapper.selectJoinMaps(new MPJLambdaWrapper<Category>()
+                .select(Category::getName)
+                .select(" ( select count(1) from retention r where r.isdeleted = 0 and  r.CATEGORY_PARENT_ID = t.id and r.TYPE = 3   ) as total ")
+                .eq(Category::getType,Constants.ONE)
+                .eq(Category::getIsdeleted,Constants.ZERO)
+                .isNull(Category::getParentId)
+                .groupBy(Category::getName)
+
+        );
+        if(CollectionUtils.isEmpty(mapList)){
+            mapList = new ArrayList<>();
+        }
+        Map<String,Object> map = new HashMap<>();
+        map.put("name","鏈煡杞﹁締");
+        map.put("total", retentionMapper.selectCount(
+                new MPJLambdaWrapper<Retention>()
+                        .eq(Retention::getIsdeleted,Constants.ZERO)
+                        .isNull(Retention::getCategoryId)
+                        .eq(Retention::getCarType,Constants.SIX)
+                    )
+        );
+        mapList.add(map);
+        return mapList;
+
+    }
+
+
 
     private String getVideoUrl() {
         return  systemDictDataBiz.queryByCode(Constants.FTP,Constants.FTP_RESOURCE_PATH).getCode()+"plugin/VideoWebPlugin.exe";
@@ -2297,7 +2373,8 @@
                 .selectAs(Platform::getName,PlatformWarnEvent::getPlatformName)
                 .leftJoin(Platform.class,Platform::getId,PlatformJob::getPlatformId)
                 .eq(PlatformWarnEvent::getIsdeleted,Constants.ZERO)
-                .apply("to_days(t.create_date) = to_days(now())")
+                //.apply(" to_days(t.create_date) = to_days(now()) ")
+                .apply(" ( t.create_date > now() - INTERVAL 10 MINUTE ) ")
                 .orderByDesc(PlatformWarnEvent::getCreateDate)
                 .last(" limit "+limit)
         );
@@ -3110,7 +3187,6 @@
             }
         }
         return r ;
-
     }
 
 

--
Gitblit v1.9.3