From de61feb06c164238302da048c2f05789911e1d17 Mon Sep 17 00:00:00 2001
From: 罗广辉 <guanghui.luo@foxmail.com>
Date: Wed, 02 Apr 2025 19:12:58 +0800
Subject: [PATCH] feat: 事件聚合80%

---
 src/views/Home/useUavHome/useUavHome.js |  289 +++++++++++++++++++++++++++++++++++----------------------
 1 files changed, 178 insertions(+), 111 deletions(-)

diff --git a/src/views/Home/useUavHome/useUavHome.js b/src/views/Home/useUavHome/useUavHome.js
index 655b589..0e7d984 100644
--- a/src/views/Home/useUavHome/useUavHome.js
+++ b/src/views/Home/useUavHome/useUavHome.js
@@ -1,31 +1,51 @@
 import * as Cesium from 'cesium';
 import aggregationImg from '@/assets/images/home/useUavHome/aggregation.png';
 import uavImg from '@/assets/images/home/useUavHome/uavImg.png';
-import MapPopUpBox from '@/views/Home/useUavHome/MapPopUpBox.vue';
+
+import eventImg from '@/assets/images/home/useEventOperate/event.png';
+
+import DevicePopUpBox from '@/views/Home/useUavHome/DevicePopUpBox.vue';
+import EventPopUpBox from '@/views/Home/useEventOperate/EventPopUpBox.vue';
+
 import { render } from 'vue';
 import { useStore } from 'vuex';
 import { getCenterPoint } from '@/utils/cesium/mapUtil';
 import cesiumOperation from '@/utils/cesium-tsa';
-import { HeadingPitchRange } from 'cesium';
-import { getDeviceRegion, getDeviceRegionCount } from '@/api/home/aggregation';
-
+import { getDeviceRegion, getDeviceRegionCount, getEventDetails, getMapEvents } from '@/api/home/aggregation';
 
 /**
  * 机巢聚合功能
  */
-export const useUavHome = () => {
+export const useUavHome = type => {
   const { flyTo } = cesiumOperation();
 
+  const singleImg = type === 'device' ? uavImg : eventImg;
+  const mergeImg = type === 'device' ? aggregationImg : aggregationImg;
+  const MapPopUpBox = type === 'device' ? DevicePopUpBox : EventPopUpBox;
+  const styleTransform = type === 'device' ? 'translateY(-50%)' : 'translate(-50%,-110%)';
+
   let scalingJudgment = [
-    { name: '县', splashedList: [], gJson: null, show: false,outline:{}, value: [0, 48651], height: 31753 },
-    { name: '市', splashedList: [], gJson: null, show: false,outline:{}, value: [48651, 314863], height: 257731 },
-    { name: '省', splashedList: [], gJson: null, show: false,outline:{}, value: [314863, 3796280000], height: 1987280 },
+    { name: '县', splashedList: [], gJson: null, show: false, outline: {}, value: [0, 48651], height: 31753 },
+    { name: '市', splashedList: [], gJson: null, show: false, outline: {}, value: [48651, 314863], height: 257731 },
+    {
+      name: '省',
+      splashedList: [],
+      gJson: null,
+      show: false,
+      outline: {},
+      value: [314863, 3796280000],
+      height: 1987280,
+    },
   ];
   let viewer = null;
   let active = null;
   let handler = null;
   let positionC3 = null;
   let currentEntity = null;
+
+  const store = useStore();
+  const userAreaCode = computed(() => store.state.user.userInfo.detail.areaCode);
+  const selectedAreaCode = computed(() => store.state.user.selectedAreaCode);
   const listenerHeight = () => {
     determineScaling();
     viewer.camera.moveEnd.addEventListener(determineScaling);
@@ -44,8 +64,8 @@
         active = item.name;
         removeEntities();
         removeLabel();
-        item.gJson ?  aggregation(item) :  splashed(item)
-        renderOutline(item)
+        item.gJson ? aggregation(item) : splashed(item);
+        renderOutline(item);
         break;
       }
     }
@@ -63,100 +83,134 @@
     return [provinceCode, cityCode, code];
   }
 
-  const store = useStore();
-  const selectedAreaCode = computed(() => store.state.user.selectedAreaCode);
-
   function getDeviceCount(areaCode) {
-    return getDeviceRegionCount({areaCode}).then(res => {
-      return res?.data?.data || [];
+    return getDeviceRegionCount({ areaCode }).then(res => {
+      return (res?.data?.data || []).map(i=>({...i,type:'deviceAggregation'}));
     });
   }
 
   function getDeviceList(areaCode) {
-    return getDeviceRegion({areaCode}).then(res => {
-      return res?.data?.data || [];
+    return getDeviceRegion({ areaCode }).then(res => {
+      return (res?.data?.data || []).map(i =>({...i,type}));
     });
   }
+
+  let eventList = []
+  function processChildren(childrens) {
+    return (childrens || []).map(item => {
+      const arr = processChildren(item.childrens);
+      if (item.data){
+        eventList = eventList.concat(item.data)
+      }
+      const returnObj = {
+        total_device_count: item.number,
+        region_code: item.id,
+        region_name: item.name,
+        type:'eventAggregation'
+      };
+      if (arr.length !== 0) {
+        returnObj.childrens = arr;
+      }
+      return returnObj;
+    });
+  }
+
+  function getMapEventCount(areaCode) {
+    return getMapEvents({ areaCode }).then(res => {
+      return processChildren(res?.data?.data?.childrens || []);
+    });
+  }
+  function getEventDetailsFun(areaCode){
+    return getEventDetails({areaCode}).then(res => {
+      console.log(res.data.data,'getEventDetailsFun');
+    });
+  }
+
   const findFun = (featItem, numItem) => Number(featItem.region_code.slice(0, 6)) === numItem.properties.adcode;
   const { VITE_APP_BASE } = import.meta.env;
   const defaultDir = `${VITE_APP_BASE}public/geoJson/100000/`;
 
-  const getFiler = async (url) => {
+  const getFiler = async url => {
     const gJson = await import(/* @vite-ignore */ url);
     return JSON.parse(JSON.stringify(gJson));
-  }
-  const getOutLine = async (jsonPathPre,hierarchy) => {
-    const parentGJson = await getFiler(`${defaultDir}${jsonPathPre}/index.json`)
+  };
+  const getOutLine = async (jsonPathPre, hierarchy) => {
+    const parentGJson = await getFiler(`${defaultDir}${jsonPathPre}/index.json`);
     let features = parentGJson.features.find(
       item => item.properties.adcode === Number(hierarchy[hierarchy.length - 1])
     );
-    return  { type: "FeatureCollection", features: [features] }
-  }
+    return { type: 'FeatureCollection', features: [features] };
+  };
 
-  const injectData = (gJson,dataList) => {
+  const injectData = (gJson, dataList) => {
     return {
       ...gJson,
       features: gJson.features.map(item => ({ ...item, data: dataList.find(item1 => findFun(item1, item)) })),
+    };
+  };
+
+  const initMapData = async areaCode => {
+    if (!areaCode) return;
+    const list = type === 'device' ? await getDeviceCount(areaCode) : await getMapEventCount(areaCode);
+    const splashedList = type === 'device'
+      ? await getDeviceList(areaCode)
+      : eventList.map(i=>({eventId:i.id,latitude:Number(i.latitude),longitude:Number(i.longitude),type:'event'}))
+    console.log(list, 'list');
+    console.log(splashedList, 'splashedList');
+    const hierarchy = convertToHierarchy(areaCode.slice(0, 6));
+    const jsonPath = hierarchy.join('/');
+    const jsonPathPre = hierarchy.slice(0, hierarchy.length - 1).join('/');
+    scalingJudgment = scalingJudgment.map(item => ({ ...item, show: true }));
+    scalingJudgment[0].gJson = null;
+    scalingJudgment[0].splashedList = splashedList;
+    active = null;
+    console.log(hierarchy);
+
+    // 省
+    if (hierarchy.length === 1) {
+      const gJson1 = await getFiler(`${defaultDir}${jsonPath}/indexDistrict.json`);
+      const gJson2 = await getFiler(`${defaultDir}${jsonPath}/index.json`);
+      scalingJudgment[1].gJson = {
+        ...gJson1,
+        features: gJson1.features.map(item => ({
+          ...item,
+          data: list.flatMap(item => item.childrens || []).find(item1 => findFun(item1, item)),
+        })),
+      };
+      scalingJudgment[2].gJson = injectData(gJson2, list);
+      const { lng, lat } = getCenterPoint(gJson2.features.map(item => item.properties.center));
+      flyTo({ longitude: lng, latitude: lat }, 0, scalingJudgment[2].height);
     }
-  }
-
-
+    // 市
+    if (hierarchy.length === 2) {
+      scalingJudgment[2].gJson = null;
+      scalingJudgment[2].show = false;
+      const gJson1 = await getFiler(`${defaultDir}${jsonPath}/index.json`);
+      scalingJudgment[1].gJson = injectData(gJson1, list);
+      const center = getCenterPoint(gJson1.features.map(item => item.properties.center));
+      flyTo({ longitude: center.lng, latitude: center.lat }, 0, scalingJudgment[1].height);
+    }
+    // 区县
+    if (hierarchy.length === 3) {
+      scalingJudgment[1].gJson = null;
+      scalingJudgment[1].show = false;
+      scalingJudgment[2].gJson = null;
+      scalingJudgment[2].show = false;
+      const outlineGJson = await getOutLine(jsonPathPre, hierarchy);
+      const center = outlineGJson.features[0].properties.center;
+      flyTo({ longitude: center[0], latitude: center[1] }, 0, scalingJudgment[0].height);
+    }
+    // 轮廓
+    const outlineGJson = await getOutLine(jsonPathPre, hierarchy);
+    scalingJudgment.forEach(item => item.show && (item.outline = outlineGJson));
+  };
 
   watch(
     selectedAreaCode,
     async (newValue, oldValue) => {
-      if (newValue) {
-        const list = await getDeviceCount(newValue);
-        const splashedList = await getDeviceList(newValue);
-        console.log(list);
-        console.log(splashedList);
-        const hierarchy = convertToHierarchy(newValue.slice(0, 6));
-        const jsonPath = hierarchy.join('/');
-        const jsonPathPre = hierarchy.slice(0, hierarchy.length - 1).join('/');
-        scalingJudgment = scalingJudgment.map(item => ({ ...item, show: true }));
-        scalingJudgment[0].gJson = null;
-        scalingJudgment[0].splashedList = splashedList;
-        active = null
-        // 省
-        if (hierarchy.length === 1) {
-          const gJson1 = await getFiler(`${defaultDir}${jsonPath}/indexDistrict.json`)
-          const gJson2 = await getFiler(`${defaultDir}${jsonPath}/index.json`)
-          scalingJudgment[1].gJson = {
-            ...gJson1,
-            features: gJson1.features.map(item => ({
-              ...item,
-              data: list.flatMap(item => item.childrens || []).find(item1 => findFun(item1, item)),
-            })),
-          };
-          scalingJudgment[2].gJson = injectData(gJson2,list);
-          const { lng, lat } = getCenterPoint(gJson2.features.map(item => item.properties.center));
-          flyTo({ longitude: lng, latitude: lat }, 0, scalingJudgment[2].height);
-        }
-        // 市
-        if (hierarchy.length === 2) {
-          scalingJudgment[2].gJson = null;
-          scalingJudgment[2].show = false;
-          const gJson1 = await getFiler(`${defaultDir}${jsonPath}/index.json`)
-          scalingJudgment[1].gJson = injectData(gJson1,list);
-          const center = getCenterPoint(gJson1.features.map(item => item.properties.center));
-          flyTo({ longitude: center.lng, latitude: center.lat }, 0, scalingJudgment[1].height);
-        }
-        // 区县
-        if (hierarchy.length === 3) {
-          scalingJudgment[1].gJson = null;
-          scalingJudgment[1].show = false;
-          scalingJudgment[2].gJson = null;
-          scalingJudgment[2].show = false;
-          const outlineGJson = await getOutLine(jsonPathPre,hierarchy)
-          const center = outlineGJson.features[0].properties.center;
-          flyTo({ longitude: center[0], latitude: center[1] }, 0, scalingJudgment[0].height);
-        }
-        // 轮廓
-        const outlineGJson = await getOutLine(jsonPathPre,hierarchy)
-        scalingJudgment.forEach(item => item.show &&(item.outline = outlineGJson))
-      }
+      initMapData(newValue);
     },
-    { immediate: true, deep: true }
+    { deep: true }
   );
 
   //散点机巢
@@ -176,7 +230,7 @@
           pixelOffset: new Cesium.Cartesian2(0, -9),
         },
         billboard: {
-          image: new Cesium.ConstantProperty(uavImg),
+          image: new Cesium.ConstantProperty(singleImg),
           width: 24,
           height: 24,
         },
@@ -190,29 +244,30 @@
   }
 
   // 渲染轮廓
-  const renderOutline = (item) => {
-    item.outline && Cesium.GeoJsonDataSource.load(item.outline).then(dataSource => {
-      viewer.dataSources.add(dataSource);
-      const entities = dataSource.entities.values;
-      entities.forEach(entity => {
-        // 隐藏多边形填充
-        entity.polygon.material = Cesium.Color.TRANSPARENT;
-        entity.polygon.outline = false; // 关闭原生轮廓
-        // 创建独立折线作为轮廓
-        const positions = entity.polygon.hierarchy.getValue().positions;
-        viewer.entities.add({
-          polyline: {
-            positions: positions,
-            width: 5, // 直接设置宽度
-            material: new Cesium.PolylineGlowMaterialProperty({
-              glowPower: 0.5,
-              color: Cesium.Color.AQUA
-            }),
-            clampToGround: true // 贴地显示
-          }
+  const renderOutline = item => {
+    item.outline &&
+      Cesium.GeoJsonDataSource.load(item.outline).then(dataSource => {
+        viewer.dataSources.add(dataSource);
+        const entities = dataSource.entities.values;
+        entities.forEach(entity => {
+          // 隐藏多边形填充
+          entity.polygon.material = Cesium.Color.TRANSPARENT;
+          entity.polygon.outline = false; // 关闭原生轮廓
+          // 创建独立折线作为轮廓
+          const positions = entity.polygon.hierarchy.getValue().positions;
+          viewer.entities.add({
+            polyline: {
+              positions: positions,
+              width: 5, // 直接设置宽度
+              material: new Cesium.PolylineGlowMaterialProperty({
+                glowPower: 0.5,
+                color: Cesium.Color.AQUA,
+              }),
+              clampToGround: true, // 贴地显示
+            },
+          });
         });
       });
-    });
   };
 
   // 聚合机巢
@@ -239,20 +294,20 @@
           style: Cesium.LabelStyle.FILL_AND_OUTLINE,
           verticalOrigin: Cesium.VerticalOrigin.BOTTOM,
           pixelOffset: new Cesium.Cartesian2(0, -9),
-        }
+        },
       });
       viewer.entities.add({
         id: feature.id,
         position: position,
         label: {
-          text: feature.data.total_device_count,
+          text: feature.data.total_device_count.toString(),
           font: '12pt Source Han Sans CN',
           fillColor: Cesium.Color.BLACK,
           style: Cesium.LabelStyle.FILL_AND_OUTLINE,
           eyeOffset: new Cesium.Cartesian3(0, 0, -10), // 让label "浮" 在广告牌前面
         },
         billboard: {
-          image: new Cesium.ConstantProperty(aggregationImg),
+          image: new Cesium.ConstantProperty(mergeImg),
           width: 35,
           height: 35,
         },
@@ -276,7 +331,7 @@
           Cesium.Color.YELLOW.withAlpha(0) // 透明填充
         );
         entity.polygon.outline = new Cesium.ConstantProperty(true); // 显示边框
-        entity.polygon.outlineColor = new Cesium.ConstantProperty(Cesium.Color.AQUAMARINE );
+        entity.polygon.outlineColor = new Cesium.ConstantProperty(Cesium.Color.AQUAMARINE);
       });
       flyTo &&
         viewer.flyTo(dataSource, {
@@ -296,7 +351,7 @@
     const tooltipContainer = document.createElement('div');
     tooltipContainer.id = 'mapPopUpBox';
     tooltipContainer.style.position = 'absolute';
-    tooltipContainer.style.transform = 'translateY(-50%)';
+    tooltipContainer.style.transform = styleTransform;
     tooltipContainer.style.pointerEvents = 'none';
     document.querySelector('.page-index').append(tooltipContainer);
     render(vNode, tooltipContainer);
@@ -326,13 +381,23 @@
       positionC3 = entity?.position?._value;
       if (!positionC3) return;
       removeLabel();
-      const customData = entity.properties.customData._value.data
-      console.log(customData);
-      if (customData.device_sn){
-        store.commit('setSingleUavHome', { id: '123' });
-        return
+      const customData = entity.properties.customData._value.data;
+
+      switch (customData.type) {
+        case 'deviceAggregation':
+          viewer.scene.postRender.addEventListener(labelBoxRender);
+          break;
+        case 'device':
+          store.commit('setSingleUavHome', { id: '123' });
+          break;
+        case 'eventAggregation':
+          break;
+        case 'event':
+          viewer.scene.postRender.addEventListener(labelBoxRender);
+          break;
+        default:
+          break;
       }
-      viewer.scene.postRender.addEventListener(labelBoxRender);
     }
   };
 
@@ -368,11 +433,13 @@
     currentEntity = null;
   };
   const init = () => {
+    initMapData(selectedAreaCode.value || userAreaCode.value);
     viewer = window.$viewer;
     handler = new Cesium.ScreenSpaceEventHandler(viewer.scene.canvas);
     handler.setInputAction(singleMachineEvent, Cesium.ScreenSpaceEventType.LEFT_CLICK);
     listenerHeight();
   };
+  onBeforeUnmount(() => {});
   // onMounted(() => {
   //   nextTick(() => {
   //     viewer = window.$viewer;

--
Gitblit v1.9.3