| | |
| | | onUnmounted, |
| | | } from "vue"; |
| | | import dayjs from "dayjs"; |
| | | import { getRainfall } from "@/api"; |
| | | import { useSimStore } from "@/store/simulation"; |
| | | const simStore = useSimStore(); |
| | | const { rainFalls, intensityUnit } = simStore; |
| | | |
| | | let dataIntervalId = null; // 表格定时器 ID |
| | | const jsonData = ref([]); // JSON 数据 |
| | |
| | | EventBus.on("clear-echart", () => { |
| | | chart1Data.value.resetLoading(); |
| | | chart2Data.value.resetLoading(); |
| | | }); |
| | | |
| | | // 清除断面 |
| | | EventBus.on("clear-dM", () => { |
| | | chart2Data.value.stopUpdating(); |
| | | chart2Data.value.resetLoading(); |
| | | if (intervalId2) { |
| | | clearInterval(intervalId2); |
| | | intervalId2 = null; |
| | | } |
| | | if (stopNowTimeWatch) { |
| | | stopNowTimeWatch(); // 停止 nowTime 的监听 |
| | | stopNowTimeWatch = null; |
| | | } |
| | | }); |
| | | |
| | | // 重新绘制断面时,重新启动 nowTime 监听 |
| | | EventBus.on("redraw-dM", () => { |
| | | if (chart2Data.value) { |
| | | chart2Data.value.startNowTimeWatch(); |
| | | chart2Data.value.loadJsonData(); |
| | | } |
| | | }); |
| | | |
| | | // 清除威胁对象中的数据 |
| | |
| | | }, |
| | | { immediate: true } // 立即执行监听器 |
| | | ); |
| | | |
| | | // 点击数据实现面片闪动的触发函数 |
| | | function handleRowClick(row) { |
| | | console.log("Row clicked:", row); |
| | | // 触发事件,将当前行的 ID 发送到地图组件 |
| | | EventBus.emit("row-clicked", row.id); |
| | | } |
| | | const listData = cityData.listData; |
| | | const data = ref([ |
| | | 8.16, 15.38, 13.94, 9.46, 86.42, 71.32, 28.52, 25.9, 13.74, 14.54, 15.53, |
| | | 9.17, 0, 0.09, 0.86, 8.15, 44.8, 21.86, 6.2, 4.98, 2.82, 2.36, 3.1, 1.06, |
| | | ]); |
| | | |
| | | const rainChangeShow = ref(false); |
| | | const tableContainer = ref(null); |
| | | |
| | |
| | | }; |
| | | |
| | | const debuffClick = () => { |
| | | // Assuming you have access to parent components in a different way in Vue 3 |
| | | // You might need to use provide/inject or props/emits instead |
| | | console.log("Debuff click"); |
| | | }; |
| | | |
| | |
| | | |
| | | // 时间轴时间截取处理 |
| | | const syncTimeWithTimeline = () => { |
| | | // 2025-05-24 00:25 |
| | | // // 将时间字符串转换为分钟数 (格式: "YYYY-MM-DD mm:ss") |
| | | const timeParts = nowTime.value.split(" "); |
| | | const timeOnly = timeParts[1]; // 获取 "mm:ss" 部分 |
| | | return timeOnly; |
| | | if (nowTime.value) { |
| | | const timeParts = nowTime.value.split(" "); |
| | | const timeOnly = timeParts[1]; // 获取 "mm:ss" 部分 |
| | | return timeOnly; |
| | | } |
| | | }; |
| | | |
| | | //初始化并配置第一个ECharts图表(降雨数据图表) |
| | | const setEcharts1 = () => { |
| | | // 获取DOM元素并初始化ECharts实例 |
| | | const chartDom = document.getElementById("echarts1"); |
| | | myChart1 = echarts.init(chartDom); |
| | | const myChart1 = echarts.init(chartDom); |
| | | |
| | | // 响应式数据定义 |
| | | let rainfallData = ref([]); // 存储从JSON加载的原始降雨数据 |
| | | let data1 = ref([]); // 存储降雨数据(mm/min) |
| | | let data2 = ref([]); // 存储累计雨量数据(mm) |
| | | let xAxisData = ref([]); // 存储x轴时间数据 |
| | | let updateInterval = null; // 定时器ID |
| | | let dataIndex = ref(0); // 当前数据索引 |
| | | // 图表数据 |
| | | let rainfallData = ref([]); |
| | | let data1 = ref([]); |
| | | let data2 = ref([]); |
| | | let xAxisData = ref(["00:00"]); |
| | | let updateInterval = null; |
| | | let dataIndex = ref(0); |
| | | |
| | | // 从JSON文件加载降雨数据 |
| | | const loadJsonData = async () => { |
| | | try { |
| | | // 发起网络请求获取数据 |
| | | const response = await fetch("/json/rainfall.json"); |
| | | const result = await response.json(); |
| | | |
| | | // 验证数据格式 |
| | | if (result && result.data && Array.isArray(result.data)) { |
| | | rainfallData.value = result.data; |
| | | |
| | | // 计算数据的最大值用于y轴刻度 |
| | | const maxValue = Math.max( |
| | | ...rainfallData.value.map((item) => item.value) |
| | | ); |
| | | const maxTotal = Math.max( |
| | | ...rainfallData.value.map((item) => item.total) |
| | | ); |
| | | |
| | | // 初始化时间轴和第一个数据点 |
| | | xAxisData.value = ["00:00"]; // 起始时间 |
| | | if (rainfallData.value.length > 0) { |
| | | data1.value.push(rainfallData.value[0].value); // 添加第一个降雨数据 |
| | | data2.value.push(rainfallData.value[0].total); // 添加第一个累计雨量 |
| | | } |
| | | |
| | | // 计算y轴参数并更新图表 |
| | | const yAxis1Params = calculateYAxisParams(maxValue); // 左侧y轴(降雨数据) |
| | | const yAxis2Params = calculateYAxisParams(maxTotal); // 右侧y轴(累计雨量) |
| | | updateChart(yAxis1Params, yAxis2Params); |
| | | } else { |
| | | console.error( |
| | | "Invalid JSON format: 'data' is missing or not an array!" |
| | | ); |
| | | } |
| | | } catch (error) { |
| | | console.error("Error fetching data:", error); |
| | | } |
| | | }; |
| | | |
| | | /** |
| | | * 计算y轴参数(生成均匀分布的刻度) |
| | | * @param {number} max - 数据最大值 |
| | | * @returns {Object} 包含max和interval的对象 |
| | | */ |
| | | const calculateYAxisParams = (max) => { |
| | | const step = Math.ceil(max / 3); // 将范围分成3等份(产生4个刻度点) |
| | | // 动态计算Y轴范围 |
| | | const getDynamicYAxis = (dataArray) => { |
| | | const currentMax = Math.max(...dataArray, 1); |
| | | const step = Math.ceil(currentMax / 3); |
| | | return { |
| | | max: step * 3, // 确保最大值是步长的整数倍 |
| | | interval: step, // 刻度间隔 |
| | | }; |
| | | }; |
| | | |
| | | /** |
| | | * 更新图表配置 |
| | | * @param {Object} yAxis1Params - 左侧y轴参数 |
| | | * @param {Object} yAxis2Params - 右侧y轴参数 |
| | | */ |
| | | const updateChart = (yAxis1Params, yAxis2Params) => { |
| | | const option = { |
| | | animation: false, // 禁用动画提高性能 |
| | | |
| | | // 提示框配置 |
| | | tooltip: { |
| | | trigger: "axis", // 坐标轴触发 |
| | | axisPointer: { |
| | | // 指示器样式 |
| | | type: "cross", // 十字准星指示器 |
| | | crossStyle: { color: "#fff" }, // 白色线条 |
| | | }, |
| | | }, |
| | | |
| | | // 图表布局 |
| | | grid: { |
| | | left: "1%", |
| | | right: "1%", |
| | | bottom: "1%", // 边距 |
| | | containLabel: true, // 包含坐标轴标签 |
| | | }, |
| | | |
| | | // 图例配置 |
| | | legend: { |
| | | data: ["降雨数据", "累计雨量"], // 系列名称 |
| | | textStyle: { color: "#fff" }, // 白色文字 |
| | | right: "10px", // 靠右对齐 |
| | | }, |
| | | |
| | | // x轴配置(时间轴) |
| | | xAxis: [ |
| | | { |
| | | type: "category", // 类目轴 |
| | | data: xAxisData.value, // 时间数据 |
| | | axisPointer: { type: "shadow" }, // 阴影指示器 |
| | | axisLabel: { |
| | | color: "#fff", // 白色标签 |
| | | rotate: 0, // 不旋转 |
| | | }, |
| | | }, |
| | | ], |
| | | |
| | | // y轴配置(双y轴) |
| | | yAxis: [ |
| | | // 左侧y轴(降雨数据) |
| | | { |
| | | type: "value", |
| | | name: "单位:mm", |
| | | min: 0, // 最小值为0 |
| | | max: yAxis1Params.max, // 动态计算的最大值 |
| | | interval: yAxis1Params.interval, // 动态计算的间隔 |
| | | axisLabel: { |
| | | formatter: "{value}", |
| | | color: "#fff", |
| | | align: "right", // 标签右对齐 |
| | | }, |
| | | nameTextStyle: { |
| | | padding: [0, 0, 0, 30], // 名称右侧内边距 |
| | | color: "#fff", |
| | | }, |
| | | splitLine: { show: false }, // 不显示网格线 |
| | | }, |
| | | // 右侧y轴(累计雨量) |
| | | { |
| | | type: "value", |
| | | name: "单位:mm", |
| | | min: 0, |
| | | max: yAxis2Params.max, |
| | | interval: yAxis2Params.interval, |
| | | axisLabel: { |
| | | formatter: "{value}", |
| | | color: "#fff", |
| | | align: "left", // 标签左对齐 |
| | | }, |
| | | nameTextStyle: { |
| | | padding: [0, 10, 0, 0], // 名称左侧内边距 |
| | | color: "#fff", |
| | | }, |
| | | splitLine: { show: true }, // 显示网格线 |
| | | }, |
| | | ], |
| | | |
| | | // 数据系列配置 |
| | | series: [ |
| | | // 柱状图(降雨数据) |
| | | { |
| | | name: "降雨数据", |
| | | type: "bar", // 柱状图 |
| | | tooltip: { |
| | | valueFormatter: (value) => value + " mm/min", // 提示框单位 |
| | | }, |
| | | data: data1.value, // 绑定数据 |
| | | itemStyle: { color: "#3268fe" }, // 蓝色柱状图 |
| | | label: { show: false, color: "#fff" }, // 不显示数据标签 |
| | | }, |
| | | // 折线图(累计雨量) |
| | | { |
| | | name: "累计雨量", |
| | | type: "line", // 折线图 |
| | | yAxisIndex: 1, // 使用第二个y轴 |
| | | tooltip: { |
| | | valueFormatter: (value) => value + " mm", // 提示框单位 |
| | | }, |
| | | data: data2.value, // 绑定数据 |
| | | lineStyle: { color: "#ffb637" }, // 黄色线条 |
| | | label: { show: false, color: "#fff" }, // 不显示数据标签 |
| | | }, |
| | | ], |
| | | }; |
| | | |
| | | // 应用配置到图表 |
| | | myChart1.setOption(option); |
| | | }; |
| | | |
| | | // 定时更新图表数据 |
| | | const updateData = () => { |
| | | // 检查是否还有数据需要显示 |
| | | if (dataIndex.value < rainfallData.value.length) { |
| | | const newItem = rainfallData.value[dataIndex.value]; |
| | | |
| | | // 添加新数据 |
| | | data1.value.push(newItem.value); // 添加降雨数据 |
| | | data2.value.push(newItem.total); // 添加累计雨量 |
| | | xAxisData.value.push(syncTimeWithTimeline()); // 添加时间点 |
| | | |
| | | dataIndex.value++; // 递增索引 |
| | | |
| | | // 更新图表(保持原有y轴范围) |
| | | updateChart( |
| | | { |
| | | max: myChart1.getOption().yAxis[0].max, |
| | | interval: myChart1.getOption().yAxis[0].interval, |
| | | }, |
| | | { |
| | | max: myChart1.getOption().yAxis[1].max, |
| | | interval: myChart1.getOption().yAxis[1].interval, |
| | | } |
| | | ); |
| | | } else { |
| | | console.log("All data has been displayed."); |
| | | stopUpdating(); // 数据全部显示完成后停止更新 |
| | | } |
| | | }; |
| | | |
| | | //启动定时更新 |
| | | const startUpdating = (interval = 1000) => { |
| | | if (!updateInterval) { |
| | | updateInterval = setInterval(updateData, interval); |
| | | console.log("Started updating..."); |
| | | } |
| | | }; |
| | | |
| | | //停止定时更新 |
| | | const stopUpdating = () => { |
| | | if (updateInterval) { |
| | | clearInterval(updateInterval); |
| | | updateInterval = null; |
| | | console.log("Stopped updating..."); |
| | | } |
| | | }; |
| | | |
| | | //重置图表数据和状态 |
| | | const resetLoading = () => { |
| | | stopUpdating(); // 停止当前更新 |
| | | |
| | | // 重置状态 |
| | | dataIndex.value = 0; |
| | | data1.value = []; |
| | | data2.value = []; |
| | | xAxisData.value = ["00:00"]; |
| | | |
| | | // 重新加载第一个数据点(如果有数据) |
| | | if (rainfallData.value.length > 0) { |
| | | data1.value.push(rainfallData.value[0].value); |
| | | data2.value.push(rainfallData.value[0].total); |
| | | } |
| | | |
| | | // 重新绘制图表(保持原有y轴范围) |
| | | updateChart( |
| | | { |
| | | max: myChart1.getOption().yAxis[0].max, |
| | | interval: myChart1.getOption().yAxis[0].interval, |
| | | }, |
| | | { |
| | | max: myChart1.getOption().yAxis[1].max, |
| | | interval: myChart1.getOption().yAxis[1].interval, |
| | | } |
| | | ); |
| | | |
| | | console.log("Reset loading..."); |
| | | }; |
| | | |
| | | // 初始化:加载数据 |
| | | loadJsonData(); |
| | | |
| | | // 返回公共接口 |
| | | return { |
| | | myChart1, // 图表实例 |
| | | startUpdating, // 启动更新方法 |
| | | stopUpdating, // 停止更新方法 |
| | | resetLoading, // 重置方法 |
| | | }; |
| | | }; |
| | | |
| | | const setEcharts2 = () => { |
| | | const chartDom = document.getElementById("echarts2"); |
| | | myChart2 = echarts.init(chartDom); |
| | | |
| | | let jsonData = ref([]); // 存储从 JSON 文件中加载的数据 |
| | | let data1 = ref([]); // 实时流量数据 |
| | | let data2 = ref([]); // 累计流量数据 |
| | | let xAxisData = ref([]); // 动态时间轴 |
| | | let updateInterval = null; // 定时器变量 |
| | | let dataIndex = ref(0); // 当前数据索引,用于按顺序更新 |
| | | |
| | | // 加载 JSON 数据 |
| | | const loadJsonData = async () => { |
| | | try { |
| | | const response = await fetch("/json/于家西沟断面下数据.json"); |
| | | const result = await response.json(); |
| | | if (result && result.data && Array.isArray(result.data)) { |
| | | jsonData.value = result.data; |
| | | |
| | | // 计算 value 和 total 的最大值 |
| | | const maxValue = Math.max(...jsonData.value.map((item) => item.value)); |
| | | const maxTotal = Math.max(...jsonData.value.map((item) => item.total)); |
| | | |
| | | // 初始化时间轴(从00:00开始) |
| | | xAxisData.value = ["00:00"] || syncTimeWithTimeline(); // 初始时间点 |
| | | |
| | | // 初始化图表(仅加载第一个数据点) |
| | | if (jsonData.value.length > 0) { |
| | | data1.value.push(jsonData.value[0].value); // 实时流量 |
| | | data2.value.push(jsonData.value[0].total); // 累计流量 |
| | | } |
| | | |
| | | // 根据最大值设置 y 轴参数并初始化图表 |
| | | const yAxis1Params = calculateYAxisParams(maxValue); |
| | | const yAxis2Params = calculateYAxisParams(maxTotal); |
| | | updateChart(yAxis1Params, yAxis2Params); |
| | | } else { |
| | | console.error( |
| | | "Invalid JSON format: 'data' is missing or not an array!" |
| | | ); |
| | | } |
| | | } catch (error) { |
| | | console.error("Error fetching data:", error); |
| | | } |
| | | }; |
| | | |
| | | // 计算 y 轴参数(最多有 4 个点) |
| | | const calculateYAxisParams = (max) => { |
| | | const step = Math.ceil(max / 3); // 最多有 4 个点(包括 0),所以分成 3 份 |
| | | return { |
| | | max: step * 3, // 确保最大值是步长的整数倍 |
| | | max: step * 3, |
| | | interval: step, |
| | | }; |
| | | }; |
| | | |
| | | // 加载JSON数据 |
| | | const loadJsonData = async () => { |
| | | try { |
| | | const result = simStore.rainFalls; |
| | | if (result?.length) { |
| | | rainfallData.value = result; |
| | | |
| | | // 判断 intensityUnit 是否为 mm/15min |
| | | if (rainfallData.value.length > 0) { |
| | | // 如果是 mm/15min,则将所有 intensity * 60 |
| | | if (intensityUnit === "mm/15min") { |
| | | rainfallData.value = rainfallData.value.map((item) => ({ |
| | | ...item, |
| | | intensity: item.intensity * 60, |
| | | total: item.total * 60, |
| | | })); |
| | | } |
| | | |
| | | // 初始化 data1 和 data2(从 0 开始) |
| | | data1.value = [0]; |
| | | data2.value = [0]; |
| | | |
| | | // 使用第一个数据项的 time 作为初始值 |
| | | xAxisData.value = [rainfallData.value[0]?.time || "00:00"]; |
| | | |
| | | updateChart(); |
| | | } |
| | | } |
| | | } catch (error) { |
| | | console.error("数据加载失败:", error); |
| | | } |
| | | }; |
| | | |
| | | // 更新图表配置 |
| | | const updateChart = (yAxis1Params, yAxis2Params) => { |
| | | const updateChart = () => { |
| | | const option = { |
| | | animation: false, // 禁用动画 |
| | | tooltip: { |
| | | trigger: "axis", |
| | | axisPointer: { |
| | | type: "cross", |
| | | crossStyle: { |
| | | color: "#fff", |
| | | }, |
| | | }, |
| | | }, |
| | | animation: false, |
| | | tooltip: { trigger: "axis" }, |
| | | grid: { |
| | | left: "1%", |
| | | right: "1%", |
| | | bottom: "1%", |
| | | containLabel: true, |
| | | containLabel: false, |
| | | }, |
| | | legend: { |
| | | data: ["实时流量", "累计流量"], |
| | | textStyle: { |
| | | color: "#fff", |
| | | data: ["降雨数据", "累计雨量"], |
| | | textStyle: { color: "#fff" }, |
| | | right: "10px", |
| | | selected: { |
| | | 降雨数据: true, |
| | | 累计雨量: true, |
| | | }, |
| | | right: "10px", // 将图例靠右贴边 |
| | | }, |
| | | xAxis: [ |
| | | { |
| | | type: "category", |
| | | data: xAxisData.value, // 使用动态时间轴 |
| | | axisPointer: { |
| | | type: "shadow", |
| | | data: xAxisData.value, |
| | | axisLabel: { color: "#fff", rotate: 0 }, |
| | | }, |
| | | ], |
| | | yAxis: [ |
| | | { |
| | | type: "value", |
| | | name: "单位:mm", |
| | | min: 0, |
| | | ...getDynamicYAxis(data1.value), |
| | | axisLabel: { color: "#fff" }, |
| | | splitLine: { show: false }, |
| | | nameTextStyle: { |
| | | color: "#fff", |
| | | }, |
| | | }, |
| | | { |
| | | type: "value", |
| | | name: "单位:mm", |
| | | min: 0, |
| | | ...getDynamicYAxis(data2.value), |
| | | axisLabel: { color: "#fff" }, |
| | | splitLine: { show: true }, |
| | | nameTextStyle: { |
| | | color: "#fff", |
| | | }, |
| | | }, |
| | | ], |
| | | series: [ |
| | | { |
| | | name: "降雨数据", |
| | | type: "bar", |
| | | data: data1.value, |
| | | itemStyle: { color: "#3268fe" }, |
| | | }, |
| | | { |
| | | name: "累计雨量", |
| | | type: "line", |
| | | yAxisIndex: 1, |
| | | data: data2.value, |
| | | lineStyle: { color: "#ffb637" }, |
| | | }, |
| | | ], |
| | | }; |
| | | myChart1.setOption(option, true); |
| | | }; |
| | | |
| | | // 数据更新 - 每次添加一条数据 |
| | | const updateData = () => { |
| | | if (dataIndex.value < rainfallData.value.length) { |
| | | const item = rainfallData.value[dataIndex.value]; |
| | | data1.value.push(item.intensity); |
| | | data2.value.push(item.total); |
| | | xAxisData.value.push(item.time); // ✅ 改用 item.time |
| | | dataIndex.value++; |
| | | updateChart(); |
| | | } else { |
| | | stopUpdating(); |
| | | } |
| | | }; |
| | | |
| | | let fixedFrameNum = null; |
| | | let startTime = null; // 将startTime移到外层 |
| | | let elapsedBeforePause = 0; // 记录暂停前已经过去的时间 |
| | | |
| | | const startUpdating = () => { |
| | | if (updateInterval || dataIndex.value >= rainfallData.value.length) { |
| | | // console.log("Animation already running or completed"); |
| | | return; |
| | | } |
| | | |
| | | // 如果是首次启动或重新开始 |
| | | if (fixedFrameNum === null) { |
| | | fixedFrameNum = simStore.frameNum; |
| | | elapsedBeforePause = 0; |
| | | startTime = Date.now(); |
| | | } else { |
| | | // 如果是暂停后继续,调整startTime以反映已经过去的时间 |
| | | startTime = Date.now() - elapsedBeforePause; |
| | | } |
| | | |
| | | const totalDuration = fixedFrameNum * 1000; |
| | | const totalPoints = rainfallData.value.length; |
| | | |
| | | const animate = (index) => { |
| | | if (index >= totalPoints) { |
| | | console.log("Animation completed"); |
| | | stopUpdating(); |
| | | return; |
| | | } |
| | | |
| | | const now = Date.now(); |
| | | const expectedTime = (index / (totalPoints - 1)) * totalDuration; |
| | | const delay = Math.max(0, startTime + expectedTime - now); |
| | | |
| | | updateInterval = setTimeout(() => { |
| | | dataIndex.value = index; |
| | | updateData(); |
| | | animate(index + 1); |
| | | }, delay); |
| | | }; |
| | | |
| | | animate(dataIndex.value); |
| | | }; |
| | | |
| | | // 暂停函数需要记录已经过去的时间 |
| | | const stopUpdating = () => { |
| | | if (updateInterval) { |
| | | clearTimeout(updateInterval); |
| | | updateInterval = null; |
| | | // 记录暂停时已经过去的时间 |
| | | elapsedBeforePause = Date.now() - startTime; |
| | | } |
| | | }; |
| | | |
| | | const resetLoading = () => { |
| | | stopUpdating(); |
| | | fixedFrameNum = null; |
| | | startTime = null; |
| | | elapsedBeforePause = 0; |
| | | dataIndex.value = 0; |
| | | data1.value = [0]; |
| | | data2.value = [0]; |
| | | xAxisData.value = [rainfallData.value[0]?.time || "00:00"]; |
| | | updateChart(); |
| | | }; |
| | | |
| | | // 初始化 |
| | | loadJsonData(); |
| | | |
| | | return { |
| | | myChart1, |
| | | startUpdating, |
| | | stopUpdating, |
| | | resetLoading, |
| | | }; |
| | | }; |
| | | |
| | | let stopNowTimeWatch = null; // 存储 watch 的停止函数 |
| | | const setEcharts2 = () => { |
| | | const chartDom = document.getElementById("echarts2"); |
| | | const myChart2 = echarts.init(chartDom); |
| | | |
| | | // 图表数据 |
| | | let flowData = ref([]); // 原始数据 |
| | | let data1 = ref([]); // 实时流量 |
| | | let data2 = ref([]); // 流速 |
| | | let data3 = ref([]); // 深度(新增) |
| | | let xAxisData = ref(["00:00"]); |
| | | let updateInterval = ref(null); |
| | | let dataIndex = ref(0); |
| | | let lastProcessedTime = ref(0); // 记录上次处理的时间戳 |
| | | |
| | | // 将各种时间格式转换为时间戳 |
| | | const parseTimeToTimestamp = (time) => { |
| | | if (!time) return 0; |
| | | |
| | | // 如果是时间戳(毫秒) |
| | | if (typeof time === "number" && time > 1000000000000) { |
| | | return time; |
| | | } |
| | | |
| | | // 如果是Date对象 |
| | | if (time instanceof Date) { |
| | | return time.getTime(); |
| | | } |
| | | |
| | | // 如果是时间字符串(如"2023-01-01 12:00:00") |
| | | if (typeof time === "string") { |
| | | return new Date(time).getTime() || 0; |
| | | } |
| | | |
| | | return 0; |
| | | }; |
| | | |
| | | // 动态计算Y轴范围(支持深度数据特殊处理) |
| | | const calculateDynamicYAxis = (dataArray, isDepth = false) => { |
| | | const filteredData = dataArray.filter((val) => val != null && val > 0); |
| | | |
| | | if (filteredData.length === 0) { |
| | | return { |
| | | min: 0, |
| | | max: isDepth ? 10 : 0.001, // 深度默认范围更大 |
| | | interval: isDepth ? 2 : 0.0002, |
| | | }; |
| | | } |
| | | |
| | | const maxValue = Math.max(...filteredData); |
| | | const exponent = Math.floor(Math.log10(maxValue)); |
| | | const base = Math.pow(10, exponent); |
| | | let step, max; |
| | | |
| | | if (isDepth) { |
| | | // 深度数据的特殊处理 |
| | | step = Math.ceil(maxValue / 5); // 固定分为5段 |
| | | max = step * 5; |
| | | } else if (maxValue < 0.01) { |
| | | // 对于小数值,使用更精细的步长 |
| | | step = base / 5; |
| | | max = step * 5; |
| | | } else { |
| | | // 常规处理 |
| | | step = base / 2; |
| | | max = step * Math.ceil(maxValue / step) + step; |
| | | } |
| | | |
| | | const decimalPlaces = Math.max(0, -exponent + 1); |
| | | |
| | | return { |
| | | min: 0, |
| | | max: parseFloat(max.toFixed(decimalPlaces)), |
| | | interval: parseFloat(step.toFixed(decimalPlaces)), |
| | | }; |
| | | }; |
| | | |
| | | // 根据指定时间加载数据 |
| | | const loadDataByTime = (targetTime) => { |
| | | if (!flowData.value.length) return; |
| | | |
| | | const currentTimestamp = parseTimeToTimestamp(targetTime); |
| | | |
| | | // 找到当前时间及之前的所有数据 |
| | | const pastData = flowData.value.filter( |
| | | (item) => parseTimeToTimestamp(item.time) <= currentTimestamp |
| | | ); |
| | | |
| | | if (pastData.length) { |
| | | // 一次性加载历史数据 |
| | | data1.value = pastData.map((item) => item.flowRate); |
| | | data2.value = pastData.map((item) => item.velocity); |
| | | data3.value = pastData.map((item) => item.depth); |
| | | xAxisData.value = pastData.map((item) => formatTime(item.time)); |
| | | |
| | | // 设置从下一个数据点开始继续更新 |
| | | dataIndex.value = pastData.length; |
| | | |
| | | // 更新最后处理的时间 |
| | | lastProcessedTime.value = currentTimestamp; |
| | | } else { |
| | | // 没有历史数据,初始化空数据 |
| | | resetLoading(); |
| | | } |
| | | |
| | | updateChart(); |
| | | }; |
| | | |
| | | // 处理时间跳变 |
| | | const handleTimeJump = (newTime) => { |
| | | const newTimestamp = parseTimeToTimestamp(newTime); |
| | | const timeDiff = Math.abs(newTimestamp - lastProcessedTime.value); |
| | | |
| | | // 如果时间变化超过5秒,认为是大幅跳变 |
| | | if (timeDiff > 5000) { |
| | | stopUpdating(); |
| | | loadDataByTime(newTime); |
| | | |
| | | // 如果不是暂停状态,继续更新 |
| | | if (!isPaused.value) { |
| | | startUpdating(); |
| | | } |
| | | } |
| | | }; |
| | | |
| | | // 时间格式化函数(时间戳转"HH:mm:ss") |
| | | const formatTime = (timestamp) => { |
| | | const date = new Date(timestamp); |
| | | const hours = date.getHours().toString().padStart(2, "0"); |
| | | const minutes = date.getMinutes().toString().padStart(2, "0"); |
| | | const seconds = date.getSeconds().toString().padStart(2, "0"); |
| | | return `${hours}:${minutes}:${seconds}`; |
| | | }; |
| | | |
| | | const loadJsonData = () => { |
| | | const crossSectionData = simStore.crossSection; |
| | | if (crossSectionData?.length) { |
| | | flowData.value = crossSectionData; |
| | | loadDataByTime(nowTime.value); // 加载当前时间之前的数据 |
| | | } else { |
| | | resetLoading(); |
| | | } |
| | | }; |
| | | |
| | | // 图表配置(保持不变) |
| | | const updateChart = () => { |
| | | const option = { |
| | | animation: false, |
| | | tooltip: { |
| | | trigger: "axis", |
| | | axisPointer: { type: "cross" }, |
| | | }, |
| | | grid: { |
| | | bottom: "1%", |
| | | containLabel: false, |
| | | }, |
| | | legend: { |
| | | data: ["实时流量", "流速", "深度"], |
| | | textStyle: { color: "#fff" }, |
| | | right: "10px", |
| | | selected: { |
| | | 实时流量: true, |
| | | 流速: true, |
| | | 深度: true, |
| | | }, |
| | | }, |
| | | xAxis: [ |
| | | { |
| | | type: "category", |
| | | data: xAxisData.value, |
| | | axisLabel: { |
| | | color: "#fff", |
| | | rotate: 0, // 将旋转角度设置为0,取消倾斜 |
| | | rotate: 0, |
| | | }, |
| | | }, |
| | | ], |
| | | yAxis: [ |
| | | { |
| | | type: "value", |
| | | name: "单位:m³/min", |
| | | name: "流量(m³/s)", |
| | | min: 0, |
| | | max: yAxis1Params.max, |
| | | interval: yAxis1Params.interval, |
| | | axisLabel: { |
| | | formatter: "{value}", |
| | | color: "#fff", |
| | | align: "right", // 将标签右对齐 |
| | | }, |
| | | nameTextStyle: { |
| | | padding: [0, 0, 0, 20], // 在右侧添加一些内边距 |
| | | color: "#fff", |
| | | }, |
| | | splitLine: { |
| | | show: false, // 关闭左侧 y 轴的横线 |
| | | }, |
| | | ...calculateDynamicYAxis(data1.value), |
| | | axisLabel: { color: "#fff" }, |
| | | splitLine: { show: false }, |
| | | nameTextStyle: { color: "#fff" }, |
| | | }, |
| | | { |
| | | type: "value", |
| | | name: "单位:m³", |
| | | name: "流速(m/s)", |
| | | min: 0, |
| | | max: yAxis2Params.max, |
| | | interval: yAxis2Params.interval, |
| | | axisLabel: { |
| | | formatter: "{value}", |
| | | color: "#fff", |
| | | align: "left", // 将标签右对齐 |
| | | }, |
| | | nameTextStyle: { |
| | | padding: [0, 10, 0, 0], // 在右侧添加一些内边距 |
| | | color: "#fff", |
| | | }, |
| | | splitLine: { |
| | | show: true, // 保留右侧 y 轴的横线 |
| | | }, |
| | | ...calculateDynamicYAxis(data2.value), |
| | | axisLabel: { color: "#fff" }, |
| | | splitLine: { show: true }, |
| | | nameTextStyle: { color: "#fff" }, |
| | | }, |
| | | { |
| | | type: "value", |
| | | name: "深度(m)", |
| | | min: 0, |
| | | ...calculateDynamicYAxis(data3.value, true), |
| | | axisLabel: { color: "#fff" }, |
| | | splitLine: { show: false }, |
| | | nameTextStyle: { color: "#fff" }, |
| | | position: "right", |
| | | offset: 80, |
| | | }, |
| | | ], |
| | | series: [ |
| | | { |
| | | name: "实时流量", |
| | | type: "bar", |
| | | tooltip: { |
| | | valueFormatter: function (value) { |
| | | return value + " m³/min"; |
| | | }, |
| | | }, |
| | | data: data1.value, |
| | | itemStyle: { |
| | | color: "blue", // 设置柱状图颜色为蓝色 |
| | | }, |
| | | label: { |
| | | show: false, |
| | | color: "#fff", |
| | | }, |
| | | itemStyle: { color: "#3268fe" }, |
| | | }, |
| | | { |
| | | name: "累计流量", |
| | | name: "流速", |
| | | type: "line", |
| | | yAxisIndex: 1, |
| | | tooltip: { |
| | | valueFormatter: function (value) { |
| | | return value + " m³"; |
| | | }, |
| | | }, |
| | | data: data2.value, |
| | | lineStyle: { |
| | | color: "#ffb637", // 设置折线图线条颜色为黄色 |
| | | }, |
| | | label: { |
| | | show: false, // 确保标签不显示 |
| | | color: "#fff", |
| | | }, |
| | | lineStyle: { color: "#ffb637" }, |
| | | }, |
| | | { |
| | | name: "深度", |
| | | type: "line", |
| | | yAxisIndex: 2, |
| | | data: data3.value, |
| | | lineStyle: { color: "#00ff99" }, |
| | | symbol: "none", |
| | | smooth: true, |
| | | }, |
| | | ], |
| | | }; |
| | | |
| | | myChart2.setOption(option); |
| | | myChart2.setOption(option, true); |
| | | }; |
| | | |
| | | // 定义按顺序更新数据的方法 |
| | | // 数据更新(保持不变) |
| | | const updateData = () => { |
| | | if (dataIndex.value < jsonData.value.length) { |
| | | // 获取当前索引的数据项 |
| | | const newItem = jsonData.value[dataIndex.value]; |
| | | data1.value.push(newItem.value); // 添加实时流量 |
| | | data2.value.push(newItem.total); // 添加累计流量 |
| | | |
| | | const nextTime = syncTimeWithTimeline(); |
| | | xAxisData.value.push(nextTime); |
| | | |
| | | // 更新当前索引 |
| | | dataIndex.value += 2; |
| | | |
| | | // 更新图表 |
| | | updateChart( |
| | | { |
| | | max: myChart2.getOption().yAxis[0].max, |
| | | interval: myChart2.getOption().yAxis[0].interval, |
| | | }, // 左侧 y 轴保持不变 |
| | | { |
| | | max: myChart2.getOption().yAxis[1].max, |
| | | interval: myChart2.getOption().yAxis[1].interval, |
| | | } // 右侧 y 轴保持不变 |
| | | ); |
| | | if (dataIndex.value < flowData.value.length) { |
| | | const item = flowData.value[dataIndex.value]; |
| | | data1.value.push(item.flowRate); |
| | | data2.value.push(item.velocity); |
| | | data3.value.push(item.depth); |
| | | xAxisData.value.push(formatTime(item.time)); |
| | | dataIndex.value++; |
| | | lastProcessedTime.value = parseTimeToTimestamp(item.time); |
| | | updateChart(); |
| | | } else { |
| | | console.log("All data has been displayed."); |
| | | stopUpdating(); // 停止定时更新 |
| | | stopUpdating(); |
| | | } |
| | | }; |
| | | |
| | | // 启动定时更新 |
| | | // 控制方法(保持不变) |
| | | const startUpdating = (interval = 1000) => { |
| | | if (!updateInterval) { |
| | | updateInterval = setInterval(updateData, interval); // 每隔 interval 毫秒更新一次数据 |
| | | console.log("Started updating..."); |
| | | if (!updateInterval.value) { |
| | | updateInterval.value = setInterval(updateData, interval); |
| | | } |
| | | }; |
| | | |
| | | // 停止定时更新 |
| | | const stopUpdating = () => { |
| | | if (updateInterval) { |
| | | clearInterval(updateInterval); |
| | | updateInterval = null; |
| | | console.log("Stopped updating..."); |
| | | if (updateInterval.value) { |
| | | clearInterval(updateInterval.value); |
| | | updateInterval.value = null; |
| | | } |
| | | }; |
| | | |
| | | // 重置加载 |
| | | const resetLoading = () => { |
| | | stopUpdating(); // 停止定时器 |
| | | dataIndex.value = 0; // 重置数据索引 |
| | | data1.value = []; // 清空实时流量数据 |
| | | data2.value = []; // 清空累计流量数据 |
| | | xAxisData.value = ["00:00"]; // 重置时间轴 |
| | | |
| | | // 重新加载第一个数据点 |
| | | if (jsonData.value.length > 0) { |
| | | data1.value.push(jsonData.value[0].value); // 实时流量 |
| | | data2.value.push(jsonData.value[0].total); // 累计流量 |
| | | } |
| | | |
| | | // 重新绘制图表 |
| | | updateChart( |
| | | { |
| | | max: myChart2.getOption().yAxis[0].max, |
| | | interval: myChart2.getOption().yAxis[0].interval, |
| | | }, // 左侧 y 轴保持不变 |
| | | { |
| | | max: myChart2.getOption().yAxis[1].max, |
| | | interval: myChart2.getOption().yAxis[1].interval, |
| | | } // 右侧 y 轴保持不变 |
| | | ); |
| | | |
| | | console.log("Reset loading..."); |
| | | stopUpdating(); |
| | | dataIndex.value = 0; |
| | | data1.value = [0]; |
| | | data2.value = [0]; |
| | | data3.value = [0]; |
| | | xAxisData.value = ["00:00"]; |
| | | lastProcessedTime.value = 0; |
| | | updateChart(); |
| | | }; |
| | | |
| | | // 初始化加载 JSON 数据 |
| | | // 监听时间轴跳转 |
| | | const startNowTimeWatch = () => { |
| | | if (stopNowTimeWatch) stopNowTimeWatch(); // 先停止旧的监听 |
| | | stopNowTimeWatch = watch(nowTime, (newTime) => { |
| | | if (!isPaused.value) { |
| | | handleTimeJump(newTime); |
| | | } |
| | | }); |
| | | }; |
| | | |
| | | startNowTimeWatch(); |
| | | // 初始化 |
| | | loadJsonData(); |
| | | |
| | | // 监听全局暂停状态 |
| | | watch(isPaused, (newVal) => { |
| | | if (newVal) { |
| | | stopUpdating(); |
| | | } else { |
| | | startUpdating(); |
| | | } |
| | | }); |
| | | |
| | | return { |
| | | myChart2, |
| | | startUpdating, |
| | | stopUpdating, |
| | | loadJsonData, |
| | | resetLoading, |
| | | startNowTimeWatch, |
| | | }; |
| | | }; |
| | | |
| | | // 监听 simStore.crossSection 的变化 |
| | | watch( |
| | | () => simStore.crossSection, |
| | | (newVal) => { |
| | | if (newVal && !isPaused.value) { |
| | | chart2Data.value.stopUpdating(); |
| | | chart2Data.value.startUpdating(); |
| | | } |
| | | chart2Data.value.loadJsonData(); |
| | | }, |
| | | { deep: true } |
| | | ); |
| | | |
| | | const handleResize = () => { |
| | | const chartBox1 = document.getElementById("echarts1"); |
| | |
| | | onUnmounted(() => { |
| | | EventBus.off("reset-table"); // 移除事件监听 |
| | | EventBus.off("clear-echart"); |
| | | EventBus.off("clear-dM"); |
| | | EventBus.off("redraw-dM"); |
| | | EventBus.off("time-update"); // 清理事件监听 |
| | | }); |
| | | </script> |