From 96279191d9fe0e80123c557f1c7dafb2e74ed195 Mon Sep 17 00:00:00 2001
From: wujingjing <gersonwu@qq.com>
Date: 星期五, 10 一月 2025 10:01:29 +0800
Subject: [PATCH] 单位支持

---
 src/components/chat/chatComponents/summaryCom/components/recordSet/RecordSet.vue |  334 +++++++++++++++++++++++++++++++++++++++----------------
 1 files changed, 238 insertions(+), 96 deletions(-)

diff --git a/src/components/chat/chatComponents/summaryCom/components/recordSet/RecordSet.vue b/src/components/chat/chatComponents/summaryCom/components/recordSet/RecordSet.vue
index e9a7bd2..2f082a3 100644
--- a/src/components/chat/chatComponents/summaryCom/components/recordSet/RecordSet.vue
+++ b/src/components/chat/chatComponents/summaryCom/components/recordSet/RecordSet.vue
@@ -1,12 +1,12 @@
 <!-- 鏄ㄦ棩渚涙按绠$綉姒傚喌 -->
 <template>
-	<div class="w-full">
-		<div class="flex mb-4 flex-wrap">
+	<div class="w-full flex-column">
+		<div class="flex mb-4 flex-wrap flex-0">
 			<!-- TimeRange v-model 璺� @change 涓殑鍊间細涓嶄竴鏍凤紝浠change 涓负鍑� -->
-			<template v-if="visibleParams && visibleParams.length > 0">
+			<template v-if="visibleParams && visibleParams.length > 0 && showFilter">
 				<component
 					class="flex-0 m-2"
-					v-model="paramsValueList[index].value"
+					v-model="visibleParams[index].value"
 					v-for="(item, index) in visibleParams as any"
 					:key="item.id"
 					:id="item.id"
@@ -14,7 +14,7 @@
 					:data="item"
 					:originData="originData"
 					@change="(val) => handleQueryChange(val, item)"
-					:disabled="chartLoading"
+					:disabled="chartLoading || disabled"
 				></component>
 			</template>
 			<slot> </slot>
@@ -34,8 +34,20 @@
 			<DisplayMode class="ml-auto" v-model="showMode" @change="displayModeChange" />
 		</div>
 
-		<RecordSetTable :data="tableData" v-if="tableIsShow" :key="tableKey" />
-		<div v-show="!tableIsShow" :style="{ height: chartHeight }" v-resize="chartContainerResize" v-loading="chartLoading">
+		<RecordSetTable
+			:data="tableData"
+			v-if="tableIsShow"
+			:key="tableKey"
+			:tableLimitHeight="tableLimitHeight"
+			:class="{ 'flex-auto': chartHeight == undefined }"
+		/>
+		<div
+			v-show="!tableIsShow"
+			:style="{ height: chartHeight }"
+			:class="{ 'flex-auto': chartHeight == undefined }"
+			v-resize="chartContainerResize"
+			v-loading="chartLoading"
+		>
 			<div ref="chartRef"></div>
 		</div>
 	</div>
@@ -43,7 +55,6 @@
 
 <script setup lang="ts">
 import type * as echarts from 'echarts';
-import _ from 'lodash';
 import moment from 'moment';
 import type { PropType } from 'vue';
 import { computed, ref, shallowRef, watch } from 'vue';
@@ -53,6 +64,7 @@
 import RecordSetTable from '../recordSetTable/RecordSetTable.vue';
 import DisplayMode from './components/DisplayMode.vue';
 import YRange from './components/YRange.vue';
+import { IS_DAY_LIST } from './components/constants';
 import { DisplayModeType } from './components/types';
 import type { RecordSetParamsItem } from './types';
 import { RecordSetParamsType, recordSetMapCom, scoreMap } from './types';
@@ -60,6 +72,7 @@
 import { axisLabelFormatter } from '/@/utils/chart';
 import { deepClone } from '/@/utils/other';
 import { debounce } from '/@/utils/util';
+import { defaultsDeep, groupBy, random } from 'lodash-es';
 const chartRef = ref<HTMLDivElement>(null);
 
 const showMode = ref(DisplayModeType.Chart);
@@ -85,12 +98,31 @@
 	},
 	chartHeight: {
 		type: String,
-		default: '20rem',
+		required: false,
 	},
-}) as {
-	data: any;
-	summaryIndex:number
-};
+	tableHeight: {
+		type: Number,
+		default: document.body.clientHeight * 0.7,
+	},
+	showFilter: {
+		type: Boolean,
+		default: true,
+	},
+	disabled: {
+		type: Boolean,
+		default: false,
+	},
+	reportIndex: {
+		type: Number,
+		default: 0,
+	},
+	historyId: {
+		type: String,
+	},
+});
+
+const tableLimitHeight = props.chartHeight == undefined ? undefined : props.tableHeight;
+
 const chartLoading = ref(false);
 
 const stepOptions = [
@@ -104,10 +136,13 @@
 const getVisibleParams = (data) => {
 	// const visibleList = props.data?.params?.filter((item) => !item?.hide) ?? [];
 	// index 浣滀负 id
-	const visibleList = (data?.filter ?? []).map((item, index) => ({
-		id: index + '',
-		...item,
-	}));
+	const dataFilter = data?.filter ?? [];
+	const visibleList = (data?.filter ?? []).map((item, index) => {
+		// 涓嶄慨鏀瑰師濮嬪湴鍧�
+		item.id = index + '';
+
+		return item;
+	});
 	const newList: RecordSetParamsItem[] = [];
 	for (let index = 0; index < visibleList.length; index++) {
 		const current = visibleList[index];
@@ -126,7 +161,7 @@
 					id: current.id,
 					type: RecordSetParamsType.Step,
 					origin: current,
-					value: current.value,
+					value: current.step_value,
 					list: stepOptions,
 					title: current.title,
 				});
@@ -140,8 +175,33 @@
 	return newList;
 };
 
+// 鏇存敼 value 鍊硷紝瀹屽叏瑕嗙洊浼氫涪澶卞搷搴旀�э紝鍙慨鏀� value
+const updateVisibleParams = (data) => {
+	const filter = data?.filter ?? [];
+
+	filter.map((newItem, index) => {
+		const currentItem = visibleParams.value.find((item) => item.id === index + '');
+
+		if (currentItem) {
+			if (newItem.type === RecordSetParamsType.TimeRange) {
+				currentItem.value = [newItem.start_value, newItem.end_value];
+			} else {
+				currentItem.value = newItem.step_value;
+			}
+		}
+	});
+};
 const visibleParams = ref(getVisibleParams(props.data));
-const paramsValueList = ref(deepClone(visibleParams.value));
+
+const checkIsDayTime = () => {
+	if (!props.showFilter) return false;
+	const stepFilter = visibleParams.value.find((item) => item.type === RecordSetParamsType.Step);
+	if (!stepFilter.origin.step_value) return false;
+
+	return IS_DAY_LIST.includes(stepFilter.origin.step_value);
+};
+// 璺ㄥ害鏄惁鏄棩鏈熷舰寮�
+// const isDayTime = checkIsDayTime();
 let groupedValues = null;
 let timeIndex = undefined;
 let valueIndex = undefined;
@@ -151,7 +211,6 @@
 let valueCol = null;
 
 let preData = null;
-
 
 let activeChartType: ChartTypeEnum = props.data?.chart_type ?? ChartTypeEnum.Line;
 let originChartType = activeChartType;
@@ -208,7 +267,11 @@
 			const values = groupedValues[item];
 			return {
 				name: item === 'default' ? '' : item,
-				data: values.map((item) => [item[timeIndex], item[valueIndex]]),
+				data: values
+					.map((item) => [item[timeIndex], item[valueIndex]])
+					.toSorted((b, a) => {
+						return b[timeIndex].localeCompare(a[timeIndex]);
+					}),
 				...getChartTypeSeriesOption(activeChartType),
 			};
 		});
@@ -221,12 +284,10 @@
 			  }
 			: axisLabelFormatter;
 
-	const tooltipValueFormatter =
-		originChartType === ChartTypeEnum.Score
-			? (value) => {
-					return scoreMap[value];
-			  }
-			: undefined;
+	const tooltipValueFormatter = (value) => {
+		const realValue = originChartType === ChartTypeEnum.Score ? scoreMap[value] : value;
+		return realValue + (props.data.unit ? ` ${props.data.unit}` : '');
+	};
 
 	const scoreYAxisOption: echarts.YAXisComponentOption = {
 		min: 0,
@@ -236,7 +297,7 @@
 			formatter: yAxisFormatter,
 		},
 	};
-	const combineOption = _.defaultsDeep(
+	const combineOption = defaultsDeep(
 		{
 			grid: {
 				bottom: 20,
@@ -297,7 +358,8 @@
 				name: timeCol?.title,
 			},
 			yAxis: {
-				name: valueCol?.title,
+				name: props.data.unit ? `${props.data.unit}` : valueCol?.title,
+
 				/** @description 涓嶅己鍒朵繚鐣� */
 				scale: true,
 				...(originChartType === ChartTypeEnum.Score ? scoreYAxisOption : {}),
@@ -338,7 +400,7 @@
 			nameIndex = 1;
 		}
 		nameCol = data.cols[nameIndex];
-		groupedValues = _.groupBy(data.values, (item) => item[nameIndex]);
+		groupedValues = groupBy(data.values, (item) => item[nameIndex]);
 	} else if (data.chart === 'single_line') {
 		groupedValues = {
 			default: data.values,
@@ -350,7 +412,7 @@
 			nameIndex = 1;
 		}
 		nameCol = data.cols[nameIndex];
-		groupedValues = _.groupBy(data.values, (item) => item[nameIndex]);
+		groupedValues = groupBy(data.values, (item) => item[nameIndex]);
 	}
 };
 
@@ -358,77 +420,110 @@
 	if (!data || !data.cols || !data.values) {
 		return;
 	}
+
 	handleData();
 	setNewOption();
 };
 const { chartContainerResize, chartInstance } = useDrawChatChart({ chartRef, drawChart });
 
-
-const updateCurrent = (res) =>{
+const updateCurrent = (res, isNew = false) => {
 	const title = res?.title;
 	const values = res?.values ?? [];
-	groupedValues = _.groupBy(values, (item) => item[nameIndex]);
+	//#region ====================== 鍒锋柊褰撳墠 filter ======================
+	// 鍙洿鏂� value锛屼笉鐩存帴瑕嗙洊锛岄槻姝涪澶卞搷搴旀��
+	// updateVisibleParams(res);
+	//#endregion
+	groupedValues = groupBy(values, (item) => item[nameIndex]);
 	if (isMultiCompare.value) {
 		handleMultiCompare();
 	} else {
-		(currentSeries.value =
-			groupedValues &&
-			Object.keys(groupedValues).map((item) => {
-				const values = groupedValues[item];
-				return {
-					data: values.map((item) => [item[timeIndex], item[valueIndex]]),
-				};
-			})),
-			chartInstance.value.setOption({
-				title: {
-					text: title,
-				},
-				series: currentSeries.value,
-			});
+		if (isNew) {
+			setNewOption();
+		} else {
+			(currentSeries.value =
+				groupedValues &&
+				Object.keys(groupedValues).map((item, index) => {
+					const values = groupedValues[item];
+					return {
+						name: item === 'default' ? '' : item,
+						data: values
+							.map((item) => [item[timeIndex], item[valueIndex]])
+							.toSorted((b, a) => {
+								return b[timeIndex].localeCompare(a[timeIndex]);
+							}),
+					};
+				})),
+				chartInstance.value?.setOption({
+					title: {
+						text: title,
+					},
+					series: currentSeries.value,
+				});
+		}
 	}
-}
+};
 
-// 鏇存崲鍒楄〃
-const changeMap = new Map<string, any>(null);
+const getFilterList = () => {
+	const curAgentKey = props.data.agent_key;
+
+	// 鐩稿悓 agent_key 涓嬫墍鏈� filter 璇锋眰鍙傛暟
+	const filterList = ((props as any).originData?.content?.origin?.summary ?? []).reduce((preVal, curVal) => {
+		if (curVal.agent_key !== curAgentKey) return preVal;
+
+		const filter = (curVal.filter ?? []).reduce((subPreVal, subCurVal) => {
+			if (subCurVal.type === RecordSetParamsType.TimeRange) {
+				subPreVal.push(
+					...[
+						{
+							update: subCurVal.update,
+							value: subCurVal.start_value,
+							path: subCurVal.start_path,
+						},
+						{
+							update: subCurVal.update,
+							value: subCurVal.end_value,
+							path: subCurVal.end_path,
+						},
+					]
+				);
+			} else {
+				subPreVal.push({
+					update: subCurVal.update,
+					value: subCurVal.step_value,
+					path: subCurVal.step_path,
+				});
+			}
+
+			return subPreVal;
+		}, []);
+
+		preVal = preVal.concat(filter);
+
+		return preVal;
+	}, []);
+	return filterList;
+};
 const handleQueryChange = async (val: any, item: RecordSetParamsItem) => {
 	if (!val) return;
-	const historyId = (props as any).originData.historyId;
+	const historyId = props.historyId;
 	let res = null;
+
+	// 鏀瑰彉鍘熷鍊�
+	if (item.type === RecordSetParamsType.TimeRange) {
+		item.origin.start_value = val[0];
+		item.origin.end_value = val[1];
+	} else {
+		item.origin.step_value = val;
+	}
+
+	const filterList = getFilterList();
 	try {
-		if (item.type === RecordSetParamsType.TimeRange) {
-			item.origin.start_value = val[0];
-			item.origin.end_value = val[1];
-			changeMap.set(item.id, [
-				{
-					update: item.origin.update,
-					value: item.origin.start_value,
-					path: item.origin.start_path,
-				},
-				{
-					update: item.origin.update,
-					value: item.origin.end_value,
-					path: item.origin.end_path,
-				},
-			]);
-		} else {
-			item.origin.value = val;
-			changeMap.set(item.id, [
-				{
-					update: item.origin.update,
-					value: item.origin.value,
-					path: item.origin.path,
-				},
-			]);
-		}
-		const filterObj = Array.from(changeMap.values()).reduce((preVal, curVal) => {
-			preVal.push(...curVal);
-			return preVal;
-		}, []);
 		const params = {
 			history_id: historyId,
 			// 鏌ヨ鍓嶅悗 agent_key 涓嶄細鍙�
 			agent_key: props.data.agent_key,
-			filter_json: JSON.stringify(filterObj),
+			filter_json: JSON.stringify(filterList),
+			result_group_index: props.reportIndex,
 		};
 		res = await curveQuery(params);
 		chartLoading.value = true;
@@ -436,11 +531,9 @@
 		chartLoading.value = false;
 	}
 
-	emits('updateQuery',res)
+	emits('updateQuery', res);
 
 	return;
-
-	
 };
 
 let realRange = {
@@ -522,7 +615,7 @@
 	const seriesData = Object.keys(cloneData).reduce((preVal, curVal, curIndex, arr) => {
 		const values = cloneData[curVal];
 		const isMulti = arr.length > 1;
-		const groupByDateValues = _.groupBy(values, (item) => moment(item[timeIndex]).format('YYYY-MM-DD'));
+		const groupByDateValues = groupBy(values, (item) => moment(item[timeIndex]).format('YYYY-MM-DD'));
 		for (const key in groupByDateValues) {
 			if (Object.prototype.hasOwnProperty.call(groupByDateValues, key)) {
 				const val = groupByDateValues[key];
@@ -541,7 +634,11 @@
 	}, []);
 	const series = seriesData.map<echarts.SeriesOption>((item) => ({
 		name: item[0]?.[nameIndex],
-		data: item.map((item) => [item[timeIndex], item[valueIndex]]),
+		data: item
+			.map((item) => [item[timeIndex], item[valueIndex]])
+			.toSorted((b, a) => {
+				return b[timeIndex].localeCompare(a[timeIndex]);
+			}),
 		...getChartTypeSeriesOption(activeChartType),
 	}));
 	setNewOption(series, getSingleDayOption());
@@ -594,11 +691,23 @@
 		return preVal;
 	}, {});
 
-	const data = Object.keys(timeDataMap).map((item) => [item, ...timeDataMap[item]]);
+	// 鏃堕棿鏈�鏃╁埌鏈�鏅氭帓搴�
+	const data = Object.keys(timeDataMap)
+		.map((item) => [item, ...timeDataMap[item]])
+		.toSorted((b, a) => {
+			return b[0].localeCompare(a[0]);
+		});
+	const getColName = (name) => {
+		if (props.data.unit) {
+			return `${name}锛�${props.data.unit}锛塦;
+		}
+		return name;
+	};
 	const cols = currentSeries.value.map((item, index) => ({
-		title: item.name ?? `鍊�${index + 1}`,
+		title: getColName(item.name ?? `鍊�${index + 1}`),
 		type: 'text',
 	}));
+
 	cols.unshift({
 		title: '鏃堕棿',
 		type: 'time',
@@ -611,7 +720,6 @@
 		cols: cols,
 		values: data,
 	};
-
 	return result;
 });
 //#endregion
@@ -620,21 +728,53 @@
 watch(
 	() => currentSeries.value,
 	(val) => {
-		tableKey.value = _.random(0, 100000) + '';
+		tableKey.value = random(0, 100000) + '';
 	}
 );
 
-const updateAll = (triggerIndex,res) => {
+const updateAll = (triggerIndex, res) => {
 	// 褰撳墠 agent_key
 	const curAgentKey = props.data.agent_key;
-	const triggerAgentKey = res?.summary?.[triggerIndex]?.agent_key;
-	if(curAgentKey !==triggerAgentKey){
+	const triggerAgentKey = (props as any).originData?.content?.origin?.summary?.[triggerIndex]?.agent_key;
+	if (curAgentKey !== triggerAgentKey) {
 		return;
 	}
-	const newSummary = res?.summary?.[props.summaryIndex]
-	if(!newSummary) return;
+	if (!curAgentKey) {
+		return;
+	}
+
+	// 褰撳墠椤规墍鍦ㄧ储寮�
+	let currentIndex = -1;
+	for (let index = 0; index < (props as any).originData.content.origin.summary.length; index++) {
+		const item = (props as any).originData.content.origin.summary[index];
+		if (item.agent_key === curAgentKey) {
+			currentIndex++;
+			if (index === props.summaryIndex) {
+				break;
+			}
+		}
+	}
+
+	const newSummary = res?.summary?.[currentIndex];
+	if (!newSummary) return;
 
 	updateCurrent(newSummary);
+};
+
+const updateIndexSummary = (summary) => {
+	updateCurrent(summary?.[props.summaryIndex], true);
+};
+
+const clearChart = () => {
+	chartInstance.value.setOption(
+		{
+			title: {
+				text: '',
+			},
+			series: [],
+		},
+		true
+	);
 };
 
 defineExpose({
@@ -643,6 +783,8 @@
 	handleMultiCompare,
 	handleData,
 	updateAll,
+	clearChart,
+	updateIndexSummary,
 });
 </script>
 <style scoped lang="scss"></style>

--
Gitblit v1.9.3