From 0b8838c8dd02161c5e7577162d8cd3318d133b68 Mon Sep 17 00:00:00 2001
From: MrShi <1878285526@qq.com>
Date: 星期二, 16 十二月 2025 17:02:13 +0800
Subject: [PATCH] Merge branch 'wuhuyancao' of http://139.186.142.91:10010/r/productDev/dmvisit into wuhuyancao

---
 server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/thrid/BoardServiceImpl.java |  140 ++++++++++++++++++++++++++++++++++++++++++++++
 1 files changed, 140 insertions(+), 0 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 552d487..fe4025f 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
@@ -244,9 +244,45 @@
         }
         if(Constants.equalsInteger(req.getWithCameras(),Constants.ONE)){
             initReginCameralList(allList,req.getName());//鑾峰彇鍏ㄩ儴鐩戞帶鐐规暟鎹�
+        }else  if(Constants.equalsInteger(req.getWithCameras(),Constants.TWO)){
+            initReginCameralList(allList,req.getName());//鑾峰彇鍏ㄩ儴鐩戞帶鐐规暟鎹�
+            initReginFireDeviveList(allList,req.getName());//鑾峰彇鍏ㄩ儴鐩戞帶鐐规暟鎹�
+            initReginSensorList(allList,req.getName());//鑾峰彇鍏ㄩ儴鐩戞帶鐐规暟鎹�
         }
         List<PageRegionInfoResponse> data = new RegionTreeVO(allList).buildTree();
         return  data;
+    }
+    private void initReginFireDeviveList(List<PageRegionInfoResponse> allList,String name) {
+        List<CarmeraListVO> carmeraListVOList = fireDeviceList();
+        if(carmeraListVOList!=null && carmeraListVOList.size()>0){
+            for(PageRegionInfoResponse p : allList){
+                for(CarmeraListVO c : carmeraListVOList){
+                    if(StringUtils.equals(p.getIndexCode(),c.getReginCode())
+                            && (StringUtils.contains(c.getName(),name) ||StringUtils.isBlank(name))){
+                        if(p.getCarmeraList()==null){
+                            p.setCarmeraList(new ArrayList<>());
+                        }
+                        p.getCarmeraList().add(c);
+                    }
+                }
+            }
+        }
+    }
+    private void initReginSensorList(List<PageRegionInfoResponse> allList,String name) {
+        List<CarmeraListVO> carmeraListVOList = sensorList();
+        if(carmeraListVOList!=null && carmeraListVOList.size()>0){
+            for(PageRegionInfoResponse p : allList){
+                for(CarmeraListVO c : carmeraListVOList){
+                    if(StringUtils.equals(p.getIndexCode(),c.getReginCode())
+                            && (StringUtils.contains(c.getName(),name) ||StringUtils.isBlank(name))){
+                        if(p.getCarmeraList()==null){
+                            p.setCarmeraList(new ArrayList<>());
+                        }
+                        p.getCarmeraList().add(c);
+                    }
+                }
+            }
+        }
     }
     private void initReginCameralList(List<PageRegionInfoResponse> allList,String name) {
         CarmeraListVO re = new CarmeraListVO();
@@ -346,6 +382,110 @@
         }
         return  data;
     }
+    public  List<CarmeraListVO> sensorList(){
+        List<SensorStatusListResponse> allList = new ArrayList<>();
+        boolean hasNext = true;
+        int curTotal = 0;
+        int curPage = 1;
+        while (hasNext){
+            //鍒嗛〉閬嶅巻寰幆鏌ヨ鎵�鏈夐棬绂佽澶囨暟鎹�
+            SensorStatusListRequest param = new SensorStatusListRequest();
+            param.setRegionIndexCode("-1");
+            param.setPageSize(100);
+            param.setPageNo(curPage);
+            BaseResponse<BaseListPageResponse<SensorStatusListResponse>> response = HKService.sensorStatusSearch(param);
+            if(response == null || !StringUtils.equals(response.getCode(), HKConstants.RESPONSE_SUCCEE)){
+                throw  new BusinessException(ResponseStatus.SERVER_ERROR.getCode(), "瀵逛笉璧凤紝娴峰悍鍚屾鏁版嵁澶辫触~");
+            }
+            BaseListPageResponse<SensorStatusListResponse> r = response.getData();
+            curTotal += 100;
+            if(curTotal >= r.getTotal()){
+                hasNext = false;
+            }
+            if(r.getList() == null || r.getList().size()==0){
+                hasNext =false;
+            }else{
+                allList.addAll(r.getList());
+            }
+            curPage++;
+        }
+
+        List<CarmeraListVO> data = new ArrayList<>();
+        for(SensorStatusListResponse p : allList){
+                CarmeraListVO t = new CarmeraListVO();
+                t.setIndexCode(p.getIndexCode());
+                t.setReginCode(p.getRegionIndexCode());
+                t.setName(p.getCn());
+                t.setStatus(p.getUnitStatus());
+                 //0锛氭湭娉ㄥ唽 1锛氭甯� 2: 淇涓� 3锛氬紓甯哥姸鎬�
+                if(t.getStatus()!=null && t.getStatus() == 0){
+                    t.setStatusName("鏈敞鍐�");
+                }
+                if(t.getStatus()!=null && t.getStatus() == 1){
+                    t.setStatusName("姝e父");
+                }
+                if(t.getStatus()!=null && t.getStatus() == 2){
+                    t.setStatusName("淇涓�");
+                }
+                if(t.getStatus()!=null && t.getStatus() == 3){
+                    t.setStatusName("寮傚父鐘舵��");
+                }
+                data.add(t);
+        }
+        return  data;
+    }
+    public  List<CarmeraListVO> fireDeviceList(){
+        List<FireDeviceStatusListResponse> allList = new ArrayList<>();
+        boolean hasNext = true;
+        int curTotal = 0;
+        int curPage = 1;
+        while (hasNext){
+            //鍒嗛〉閬嶅巻寰幆鏌ヨ鎵�鏈夐棬绂佽澶囨暟鎹�
+            FireDeviceStatuslListRequest param = new FireDeviceStatuslListRequest();
+            param.setRegionIndexCode("-1");
+            param.setPageSize(100);
+            param.setPageNo(curPage);
+            BaseResponse<BaseListPageResponse<FireDeviceStatusListResponse>> response = HKService.fireDeviceStatusSearch(param);
+            if(response == null || !StringUtils.equals(response.getCode(), HKConstants.RESPONSE_SUCCEE)){
+                throw  new BusinessException(ResponseStatus.SERVER_ERROR.getCode(), "瀵逛笉璧凤紝娴峰悍鍚屾鏁版嵁澶辫触~");
+            }
+            BaseListPageResponse<FireDeviceStatusListResponse> r = response.getData();
+            curTotal += 100;
+            if(curTotal >= r.getTotal()){
+                hasNext = false;
+            }
+            if(r.getList() == null || r.getList().size()==0){
+                hasNext =false;
+            }else{
+                allList.addAll(r.getList());
+            }
+            curPage++;
+        }
+
+        List<CarmeraListVO> data = new ArrayList<>();
+        for(FireDeviceStatusListResponse p : allList){
+                CarmeraListVO t = new CarmeraListVO();
+                t.setIndexCode(p.getIndexCode());
+                t.setReginCode(p.getRegionIndexCode());
+                t.setName(p.getCn());
+                t.setStatus(p.getUnitStatus());
+                 //0锛氭湭娉ㄥ唽 1锛氭甯� 2: 淇涓� 3锛氬紓甯哥姸鎬�
+                if(t.getStatus()!=null && t.getStatus() == 0){
+                    t.setStatusName("鏈敞鍐�");
+                }
+                if(t.getStatus()!=null && t.getStatus() == 1){
+                    t.setStatusName("姝e父");
+                }
+                if(t.getStatus()!=null && t.getStatus() == 2){
+                    t.setStatusName("淇涓�");
+                }
+                if(t.getStatus()!=null && t.getStatus() == 3){
+                    t.setStatusName("寮傚父鐘舵��");
+                }
+                data.add(t);
+        }
+        return  data;
+    }
     @Override
     public    List<PageFireChannelInfoResponse> fireChannelList(){
         List<PageFireChannelInfoResponse> allList = new ArrayList<>();

--
Gitblit v1.9.3