Compare commits
17 Commits
5a81a9b78b
...
bur-58
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
f84b15b2d0 | ||
| 688e883996 | |||
|
|
e057f55c73 | ||
|
|
f4cefe376c | ||
| 646424d44f | |||
|
|
8bb19f3f9d | ||
| 4e3cc0eb33 | |||
|
|
01d05b4331 | ||
| ca78c0b17b | |||
|
|
19ca8d0885 | ||
| ba8bb6940b | |||
|
|
9ca1b2e20a | ||
| cc0de27fb6 | |||
|
|
790859c173 | ||
| 378036f4dd | |||
|
|
1a994f36bd | ||
|
|
772ba60647 |
@@ -1,3 +1,4 @@
|
||||
import mpegts from 'mpegts.js';
|
||||
import { useEffect, useRef, useState } from 'react';
|
||||
|
||||
type CameraViewProps = {
|
||||
@@ -5,14 +6,29 @@ type CameraViewProps = {
|
||||
wsUrl: string;
|
||||
};
|
||||
|
||||
const CAMERA_PLAYER_CONFIG = {
|
||||
enableWorker: true,
|
||||
enableStashBuffer: true,
|
||||
stashInitialSize: 512,
|
||||
autoCleanupSourceBuffer: true,
|
||||
autoCleanupMaxBackwardDuration: 10,
|
||||
autoCleanupMinBackwardDuration: 5,
|
||||
liveBufferLatencyChasing: true,
|
||||
liveBufferLatencyMaxLatency: 5.0,
|
||||
liveBufferLatencyMinRemain: 2.0,
|
||||
liveSync: false,
|
||||
lazyLoad: false,
|
||||
deferLoadAfterSourceOpen: false,
|
||||
};
|
||||
|
||||
export function CameraView({ title = 'Камера', wsUrl }: CameraViewProps) {
|
||||
const videoRef = useRef<HTMLVideoElement | null>(null);
|
||||
const [error, setError] = useState<string | null>(null);
|
||||
|
||||
useEffect(() => {
|
||||
const video = videoRef.current;
|
||||
let player: import('mpegts.js').default.Player | null = null;
|
||||
let cancelled = false;
|
||||
let player: ReturnType<typeof mpegts.createPlayer> | null = null;
|
||||
const handlePlayerError = () => setError('Ошибка видеопотока');
|
||||
|
||||
if (!video) {
|
||||
return;
|
||||
@@ -22,33 +38,30 @@ export function CameraView({ title = 'Камера', wsUrl }: CameraViewProps) {
|
||||
video.addEventListener('playing', clearError);
|
||||
setError(null);
|
||||
|
||||
void import('mpegts.js').then(({ default: mpegts }) => {
|
||||
if (cancelled) {
|
||||
return;
|
||||
}
|
||||
if (!mpegts.isSupported()) {
|
||||
setError('Браузер не поддерживает MPEG-TS поток');
|
||||
return () => {
|
||||
video.removeEventListener('playing', clearError);
|
||||
};
|
||||
}
|
||||
|
||||
if (!mpegts.isSupported()) {
|
||||
setError('Браузер не поддерживает MPEG-TS поток');
|
||||
return;
|
||||
}
|
||||
player = mpegts.createPlayer(
|
||||
{ type: 'mpegts', isLive: true, url: wsUrl, hasAudio: false },
|
||||
CAMERA_PLAYER_CONFIG,
|
||||
);
|
||||
|
||||
player = mpegts.createPlayer(
|
||||
{ type: 'mpegts', isLive: true, url: wsUrl },
|
||||
{ liveBufferLatencyChasing: true, liveBufferLatencyMaxLatency: 1.5 },
|
||||
);
|
||||
player.on(mpegts.Events.ERROR, handlePlayerError);
|
||||
player.attachMediaElement(video);
|
||||
player.load();
|
||||
|
||||
player.attachMediaElement(video);
|
||||
player.load();
|
||||
|
||||
const playResult = player.play();
|
||||
if (playResult instanceof Promise) {
|
||||
void playResult.then(() => setError(null)).catch(() => setError('Не удалось запустить воспроизведение'));
|
||||
}
|
||||
});
|
||||
const playResult = player.play();
|
||||
if (playResult instanceof Promise) {
|
||||
void playResult.then(() => setError(null)).catch(() => undefined);
|
||||
}
|
||||
|
||||
return () => {
|
||||
cancelled = true;
|
||||
video.removeEventListener('playing', clearError);
|
||||
player?.off(mpegts.Events.ERROR, handlePlayerError);
|
||||
player?.pause();
|
||||
player?.unload();
|
||||
player?.detachMediaElement();
|
||||
|
||||
@@ -39,6 +39,7 @@ export function EdgeDetailPage() {
|
||||
latestUpdatedAt={latestUpdatedAt}
|
||||
onOpenArchive={() => navigate(`${edgePath}/archive`)}
|
||||
onOpenIndicators={() => navigate(`${edgePath}/indicators`)}
|
||||
onOpenVideo={() => navigate(`${edgePath}/video`)}
|
||||
/>
|
||||
</EdgePageLayout>
|
||||
);
|
||||
|
||||
@@ -1,4 +1,4 @@
|
||||
import { Activity, BarChart3, CalendarClock } from 'lucide-react';
|
||||
import { Activity, BarChart3, Video } from 'lucide-react';
|
||||
import { formatDateTime } from '../../../utils/format';
|
||||
|
||||
type OverviewViewProps = {
|
||||
@@ -8,6 +8,7 @@ type OverviewViewProps = {
|
||||
totalTags: number;
|
||||
onOpenArchive: () => void;
|
||||
onOpenIndicators: () => void;
|
||||
onOpenVideo: () => void;
|
||||
};
|
||||
|
||||
export function OverviewView({
|
||||
@@ -17,6 +18,7 @@ export function OverviewView({
|
||||
totalTags,
|
||||
onOpenArchive,
|
||||
onOpenIndicators,
|
||||
onOpenVideo
|
||||
}: OverviewViewProps) {
|
||||
return (
|
||||
<section className="detail-overview">
|
||||
@@ -53,9 +55,9 @@ export function OverviewView({
|
||||
<BarChart3 size={18} />
|
||||
Архив и график
|
||||
</button>
|
||||
<button type="button">
|
||||
<CalendarClock size={18} />
|
||||
Техническое обслуживание
|
||||
<button type="button" onClick={onOpenVideo}>
|
||||
<Video size={18} />
|
||||
Видео
|
||||
</button>
|
||||
</div>
|
||||
</section>
|
||||
|
||||
@@ -1,6 +1,7 @@
|
||||
import { useCallback, useMemo, useRef } from 'react';
|
||||
import type { HistoryAxisLabelFormat } from '../../utils/historyGranularity';
|
||||
import type { DataZoomEventBatch, DataZoomState } from './chartTypes';
|
||||
import { useCallback, useEffect, useMemo, useRef, useState } from 'react';
|
||||
import type { EChartsOption } from 'echarts';
|
||||
import { getHistoryGranularity, type HistoryAxisLabelFormat } from '../../utils/historyGranularity';
|
||||
import type { DataZoomEventBatch, DataZoomState, HistoryZoomRange } from './chartTypes';
|
||||
import { HistoryChartArea } from './HistoryChartArea';
|
||||
import { createHistoryChartOptions } from './historyChartOptions';
|
||||
import { useHistoryChartQueries } from './useHistoryChartQueries';
|
||||
@@ -17,11 +18,108 @@ type HistoryChartProps = {
|
||||
tagLabels?: Record<string, string>;
|
||||
};
|
||||
|
||||
/** Контейнер истории: загружает выбранные теги и передает готовые серии в область ECharts. */
|
||||
const ZOOM_REQUEST_DELAY_MS = 350;
|
||||
|
||||
function isXAxisDataZoom(state: DataZoomState): boolean {
|
||||
return state.dataZoomId?.startsWith('history-x-') || state.dataZoomIndex === 0 || state.dataZoomIndex === 1;
|
||||
}
|
||||
|
||||
/** Собирает начальный zoom-диапазон из внешних props графика. */
|
||||
function createInitialZoomRange({
|
||||
from,
|
||||
granulate,
|
||||
labelFormat,
|
||||
tickIntervalMs,
|
||||
to,
|
||||
}: Pick<HistoryChartProps, 'from' | 'granulate' | 'labelFormat' | 'tickIntervalMs' | 'to'>): HistoryZoomRange {
|
||||
return { from, to, granulate, labelFormat, tickIntervalMs };
|
||||
}
|
||||
|
||||
/** Создает zoom-диапазон из миллисекунд и подбирает для него грануляцию. */
|
||||
function createZoomRange(fromMs: number, toMs: number): HistoryZoomRange {
|
||||
const from = new Date(fromMs).toISOString();
|
||||
const to = new Date(toMs).toISOString();
|
||||
|
||||
return {
|
||||
from,
|
||||
to,
|
||||
...getHistoryGranularity(from, to),
|
||||
};
|
||||
}
|
||||
|
||||
/** Достает подинтервал X-зума из события ECharts. */
|
||||
function getZoomRangeFromEvent(state: DataZoomState, baseRange: HistoryZoomRange): HistoryZoomRange | null {
|
||||
const baseFromMs = new Date(baseRange.from).getTime();
|
||||
const baseToMs = new Date(baseRange.to).getTime();
|
||||
const baseSpanMs = baseToMs - baseFromMs;
|
||||
|
||||
if (!Number.isFinite(baseFromMs) || !Number.isFinite(baseToMs) || baseSpanMs <= 0) {
|
||||
return null;
|
||||
}
|
||||
|
||||
const startValue = Number(state.startValue);
|
||||
const endValue = Number(state.endValue);
|
||||
let nextFromMs = Number.isFinite(startValue) ? startValue : undefined;
|
||||
let nextToMs = Number.isFinite(endValue) ? endValue : undefined;
|
||||
|
||||
// ECharts иногда не передает startValue/endValue, поэтому используем start/end.
|
||||
if (nextFromMs === undefined || nextToMs === undefined) {
|
||||
const start = Number(state.start);
|
||||
const end = Number(state.end);
|
||||
|
||||
if (!Number.isFinite(start) || !Number.isFinite(end)) {
|
||||
return null;
|
||||
}
|
||||
|
||||
nextFromMs = baseFromMs + (baseSpanMs * start) / 100;
|
||||
nextToMs = baseFromMs + (baseSpanMs * end) / 100;
|
||||
}
|
||||
|
||||
// Проверка на выход из диапазона
|
||||
const fromMs = Math.max(baseFromMs, Math.min(nextFromMs, nextToMs));
|
||||
const toMs = Math.min(baseToMs, Math.max(nextFromMs, nextToMs));
|
||||
|
||||
return toMs > fromMs ? createZoomRange(fromMs, toMs) : null;
|
||||
}
|
||||
|
||||
/** Проверяет, что lazy zoom не пытается повторно применить тот же диапазон. */
|
||||
function isSameZoomRange(left: HistoryZoomRange, right: HistoryZoomRange): boolean {
|
||||
return left.from === right.from && left.to === right.to && left.granulate === right.granulate;
|
||||
}
|
||||
|
||||
/** Вычисляет, какую часть верхнеуровневого периода занимает текущий пользовательский zoom. */
|
||||
function createDataZoomState(baseRange: HistoryZoomRange, zoomRange: HistoryZoomRange): DataZoomState {
|
||||
// Верхнеуровневый период берём из инпутов "С/По" и считаем его полными 0..100%.
|
||||
const baseFromMs = new Date(baseRange.from).getTime();
|
||||
const baseToMs = new Date(baseRange.to).getTime();
|
||||
|
||||
// Пользовательский zoom живёт внутри верхнеуровневого периода и должен быть выделен на нижней шкале.
|
||||
const zoomFromMs = new Date(zoomRange.from).getTime();
|
||||
const zoomToMs = new Date(zoomRange.to).getTime();
|
||||
const baseSpanMs = baseToMs - baseFromMs;
|
||||
|
||||
// Если даты некорректны, показываем весь период, чтобы не ломать управление графиком.
|
||||
if (
|
||||
!Number.isFinite(baseFromMs) ||
|
||||
!Number.isFinite(baseToMs) ||
|
||||
!Number.isFinite(zoomFromMs) ||
|
||||
!Number.isFinite(zoomToMs) ||
|
||||
baseSpanMs <= 0
|
||||
) {
|
||||
return { start: 0, end: 100 };
|
||||
}
|
||||
|
||||
// Переводим абсолютные даты zoom-а в проценты относительно верхнеуровневого периода.
|
||||
const start = ((zoomFromMs - baseFromMs) / baseSpanMs) * 100;
|
||||
const end = ((zoomToMs - baseFromMs) / baseSpanMs) * 100;
|
||||
|
||||
// Ограничиваем значения диапазоном 0..100, чтобы ECharts не получил выход за шкалу.
|
||||
return {
|
||||
start: Math.max(0, Math.min(100, start)),
|
||||
end: Math.max(0, Math.min(100, end)),
|
||||
};
|
||||
}
|
||||
|
||||
export function HistoryChart({
|
||||
edge,
|
||||
from,
|
||||
@@ -32,26 +130,75 @@ export function HistoryChart({
|
||||
to,
|
||||
tagLabels = {},
|
||||
}: HistoryChartProps) {
|
||||
const dataZoomRef = useRef<DataZoomState | null>(null);
|
||||
const lines = useHistoryChartQueries({ edge, from, granulate, tags, to, tagLabels });
|
||||
const series = useHistoryChartSeries(lines);
|
||||
const baseRange = useMemo(
|
||||
() => createInitialZoomRange({ from, granulate, labelFormat, tickIntervalMs, to }),
|
||||
[from, granulate, labelFormat, tickIntervalMs, to],
|
||||
);
|
||||
const [zoomRange, setZoomRange] = useState(() =>
|
||||
createInitialZoomRange({ from, granulate, labelFormat, tickIntervalMs, to }),
|
||||
);
|
||||
const baseRangeRef = useRef(baseRange);
|
||||
const zoomRangeRef = useRef(zoomRange);
|
||||
const zoomTimerRef = useRef<ReturnType<typeof setTimeout> | null>(null);
|
||||
const lastReadyOptionRef = useRef<EChartsOption | null>(null);
|
||||
const lines = useHistoryChartQueries({
|
||||
edge,
|
||||
from: zoomRange.from,
|
||||
granulate: zoomRange.granulate,
|
||||
tags,
|
||||
to: zoomRange.to,
|
||||
tagLabels,
|
||||
});
|
||||
const series = useHistoryChartSeries(lines, zoomRange.granulate);
|
||||
const legendData = useMemo(() => lines.map((line) => line.label), [lines]);
|
||||
const loading = lines.some((line) => line.loading);
|
||||
const hasData = series.length > 0;
|
||||
|
||||
useEffect(() => {
|
||||
baseRangeRef.current = baseRange;
|
||||
zoomRangeRef.current = baseRange;
|
||||
setZoomRange(baseRange);
|
||||
}, [baseRange]);
|
||||
|
||||
useEffect(() => {
|
||||
zoomRangeRef.current = zoomRange;
|
||||
}, [zoomRange]);
|
||||
|
||||
useEffect(
|
||||
() => () => {
|
||||
if (zoomTimerRef.current) {
|
||||
clearTimeout(zoomTimerRef.current);
|
||||
}
|
||||
},
|
||||
[],
|
||||
);
|
||||
|
||||
const option = useMemo(
|
||||
() =>
|
||||
createHistoryChartOptions({
|
||||
dataZoomState: dataZoomRef.current ?? {},
|
||||
from,
|
||||
to,
|
||||
labelFormat,
|
||||
dataZoomState: createDataZoomState(baseRange, zoomRange),
|
||||
from: baseRange.from,
|
||||
to: baseRange.to,
|
||||
labelFormat: zoomRange.labelFormat,
|
||||
legendData,
|
||||
series,
|
||||
tickIntervalMs,
|
||||
tickIntervalMs: zoomRange.tickIntervalMs,
|
||||
}),
|
||||
[from, labelFormat, legendData, series, tickIntervalMs, to],
|
||||
[baseRange, legendData, series, zoomRange],
|
||||
);
|
||||
|
||||
// Во время lazy-загрузки нового zoom-диапазона оставляем на экране последний готовый график.
|
||||
// Так canvas не заменяется loader-ом и пользователь не теряет визуальный контекст.
|
||||
const fallbackOption = loading && !hasData ? lastReadyOptionRef.current : null;
|
||||
const displayOption = fallbackOption ?? option;
|
||||
const displayHasData = hasData || Boolean(fallbackOption);
|
||||
|
||||
useEffect(() => {
|
||||
if (hasData) {
|
||||
lastReadyOptionRef.current = option;
|
||||
}
|
||||
}, [hasData, option]);
|
||||
|
||||
const handleDataZoom = useCallback((event: DataZoomEventBatch) => {
|
||||
const state = (event.batch ?? [event]).find(isXAxisDataZoom);
|
||||
|
||||
@@ -59,20 +206,30 @@ export function HistoryChart({
|
||||
return;
|
||||
}
|
||||
|
||||
dataZoomRef.current = {
|
||||
start: state.start,
|
||||
end: state.end,
|
||||
startValue: state.startValue,
|
||||
endValue: state.endValue,
|
||||
};
|
||||
const baseRange = baseRangeRef.current;
|
||||
const currentRange = zoomRangeRef.current;
|
||||
const nextRange = getZoomRangeFromEvent(state, baseRange);
|
||||
|
||||
if (!nextRange || isSameZoomRange(nextRange, currentRange)) {
|
||||
return;
|
||||
}
|
||||
|
||||
if (zoomTimerRef.current) {
|
||||
clearTimeout(zoomTimerRef.current);
|
||||
}
|
||||
|
||||
zoomTimerRef.current = setTimeout(() => {
|
||||
zoomRangeRef.current = nextRange;
|
||||
setZoomRange(nextRange);
|
||||
}, ZOOM_REQUEST_DELAY_MS);
|
||||
}, []);
|
||||
|
||||
return (
|
||||
<HistoryChartArea
|
||||
hasData={series.length > 0}
|
||||
hasData={displayHasData}
|
||||
hasSelection={tags.length > 0}
|
||||
loading={loading}
|
||||
option={option}
|
||||
option={displayOption}
|
||||
onDataZoom={handleDataZoom}
|
||||
/>
|
||||
);
|
||||
|
||||
@@ -31,7 +31,7 @@ export function HistoryChartArea({
|
||||
return <div className="chart-placeholder">Разверните список показателей и выберите серию для графика</div>;
|
||||
}
|
||||
|
||||
if (loading) {
|
||||
if (!hasData && loading) {
|
||||
return <div className="chart-placeholder">Загрузка графика...</div>;
|
||||
}
|
||||
|
||||
|
||||
@@ -1,5 +1,17 @@
|
||||
import type { HistoryAxisLabelFormat } from '../../utils/historyGranularity';
|
||||
|
||||
export type AvgPointValue = [time: number, avg: number, min: number, max: number, count: number];
|
||||
|
||||
export type HistoryBucketValue = [...AvgPointValue, slotMs: number];
|
||||
|
||||
export type HistoryZoomRange = {
|
||||
from: string;
|
||||
to: string;
|
||||
granulate: string;
|
||||
tickIntervalMs?: number;
|
||||
labelFormat?: HistoryAxisLabelFormat;
|
||||
};
|
||||
|
||||
export type TooltipParam = {
|
||||
color?: string;
|
||||
marker?: string;
|
||||
|
||||
@@ -1,4 +1,4 @@
|
||||
import { LineChart, ScatterChart } from 'echarts/charts';
|
||||
import { CustomChart } from 'echarts/charts';
|
||||
import {
|
||||
DataZoomComponent,
|
||||
GridComponent,
|
||||
@@ -9,8 +9,7 @@ import * as echarts from 'echarts/core';
|
||||
import { CanvasRenderer } from 'echarts/renderers';
|
||||
|
||||
echarts.use([
|
||||
LineChart,
|
||||
ScatterChart,
|
||||
CustomChart,
|
||||
GridComponent,
|
||||
LegendComponent,
|
||||
TooltipComponent,
|
||||
|
||||
@@ -60,7 +60,7 @@ function formatChartValue(value: number): string {
|
||||
}).format(value);
|
||||
}
|
||||
|
||||
/** Показывает одно значение, если min/avg/max визуально совпадают. */
|
||||
/** Форматирует значение tooltip: одно число для min=avg=max или среднее с диапазоном. */
|
||||
function formatTooltipValue(value: AvgPointValue): string {
|
||||
const avg = formatChartValue(value[1]);
|
||||
const min = formatChartValue(value[2]);
|
||||
@@ -70,7 +70,7 @@ function formatTooltipValue(value: AvgPointValue): string {
|
||||
return avg;
|
||||
}
|
||||
|
||||
return `min ${min} · avg ${avg} · max ${max}`;
|
||||
return `сред. ${avg} (${min} .. ${max})`;
|
||||
}
|
||||
|
||||
function isAvgPointValue(value: unknown): value is AvgPointValue {
|
||||
|
||||
@@ -82,6 +82,8 @@ export function createHistoryChartOptions({
|
||||
id: 'history-x-inside',
|
||||
type: 'inside',
|
||||
xAxisIndex: 0,
|
||||
zoomOnMouseWheel: true,
|
||||
moveOnMouseWheel: false,
|
||||
throttle: 80,
|
||||
start: dataZoomState.start,
|
||||
end: dataZoomState.end,
|
||||
@@ -111,6 +113,8 @@ export function createHistoryChartOptions({
|
||||
type: 'inside',
|
||||
yAxisIndex: 0,
|
||||
filterMode: 'none',
|
||||
zoomOnMouseWheel: 'shift',
|
||||
moveOnMouseWheel: false,
|
||||
throttle: 80,
|
||||
},
|
||||
{
|
||||
|
||||
@@ -1,6 +1,13 @@
|
||||
import type { SeriesOption } from 'echarts';
|
||||
import type {
|
||||
CustomSeriesRenderItemAPI,
|
||||
CustomSeriesRenderItemParams,
|
||||
CustomSeriesRenderItemReturn,
|
||||
SeriesOption,
|
||||
} from 'echarts';
|
||||
import { graphic } from 'echarts/core';
|
||||
import type { HistoryPoint } from '../../entities/history/types';
|
||||
import type { AvgPointValue } from './chartTypes';
|
||||
import { parseGranulateMs } from '../../utils/historyGranularity';
|
||||
import type { HistoryBucketValue } from './chartTypes';
|
||||
|
||||
export const SERIES_COLORS = [
|
||||
'#5B8FF9',
|
||||
@@ -13,93 +20,120 @@ export const SERIES_COLORS = [
|
||||
'#A7B3FF',
|
||||
];
|
||||
|
||||
/** Создает avg-линию, вертикальные min/max-отрезки и точки экстремумов для одной серии. */
|
||||
export function createSeriesOptions(points: HistoryPoint[], index: number, label: string): SeriesOption[] {
|
||||
type CartesianCoordSys = {
|
||||
x: number;
|
||||
y: number;
|
||||
width: number;
|
||||
height: number;
|
||||
};
|
||||
|
||||
function isFinitePoint(point: HistoryPoint): boolean {
|
||||
return [point.avg_value, point.min_value, point.max_value].every(Number.isFinite);
|
||||
}
|
||||
|
||||
/** Упаковывает один bucket API в компактный tuple для custom series ECharts. */
|
||||
function createBucketData(points: HistoryPoint[], slotMs: number): HistoryBucketValue[] {
|
||||
return points.filter(isFinitePoint).map((point) => [
|
||||
new Date(point.time).getTime(),
|
||||
point.avg_value,
|
||||
point.min_value,
|
||||
point.max_value,
|
||||
point.point_count,
|
||||
slotMs,
|
||||
]);
|
||||
}
|
||||
|
||||
/** Рисует один bucket как временной слот: затухающий min..max и яркий маркер avg. */
|
||||
function renderBucket(color: string) {
|
||||
return (params: CustomSeriesRenderItemParams, api: CustomSeriesRenderItemAPI): CustomSeriesRenderItemReturn => {
|
||||
const time = Number(api.value(0));
|
||||
const avg = Number(api.value(1));
|
||||
const min = Number(api.value(2));
|
||||
const max = Number(api.value(3));
|
||||
const slotMs = Number(api.value(5));
|
||||
|
||||
// ECharts отдает размеры области графика в runtime, но в публичных типах
|
||||
// они не описаны. Поэтому держим cast локально рядом с clipping-логикой.
|
||||
const coordSys = params.coordSys as unknown as CartesianCoordSys;
|
||||
|
||||
// Переводим координаты данных (time/value) в пиксели canvas.
|
||||
const avgPoint = api.coord([time, avg]);
|
||||
const minPoint = api.coord([time, min]);
|
||||
const maxPoint = api.coord([time, max]);
|
||||
const slotStart = api.coord([time - slotMs / 2, avg]);
|
||||
const slotEnd = api.coord([time + slotMs / 2, avg]);
|
||||
|
||||
// Слот занимает один интервал грануляции по X и диапазон min..max по Y.
|
||||
const x = Math.min(slotStart[0], slotEnd[0]);
|
||||
const rawHeight = Math.abs(maxPoint[1] - minPoint[1]);
|
||||
const width = Math.max(2, Math.abs(slotEnd[0] - slotStart[0]));
|
||||
const height = Math.max(2, rawHeight);
|
||||
const y = Math.min(minPoint[1], maxPoint[1]) - (height - rawHeight) / 2;
|
||||
const avgY = avgPoint[1];
|
||||
const chartArea = { x: coordSys.x, y: coordSys.y, width: coordSys.width, height: coordSys.height };
|
||||
|
||||
// Обрезаем фигуры, чтобы при Y-зуме они не выходили за область графика.
|
||||
const rangeShape = graphic.clipRectByRect(
|
||||
{ x, y, width, height },
|
||||
chartArea,
|
||||
);
|
||||
const avgShape = graphic.clipRectByRect(
|
||||
{ x, y: avgY - 1, width, height: 2 },
|
||||
chartArea,
|
||||
);
|
||||
|
||||
if (!rangeShape) {
|
||||
return null;
|
||||
}
|
||||
|
||||
return {
|
||||
type: 'group',
|
||||
children: [
|
||||
{
|
||||
type: 'rect',
|
||||
shape: rangeShape,
|
||||
style: {
|
||||
fill: new graphic.LinearGradient(0, 0, 0, 1, [
|
||||
{ offset: 0, color: `${color}00` },
|
||||
{ offset: 0.5, color: `${color}66` },
|
||||
{ offset: 1, color: `${color}00` },
|
||||
]),
|
||||
},
|
||||
},
|
||||
...(avgShape ? [{
|
||||
type: 'rect' as const,
|
||||
shape: avgShape,
|
||||
style: {
|
||||
fill: color,
|
||||
},
|
||||
}] : []),
|
||||
],
|
||||
};
|
||||
};
|
||||
}
|
||||
|
||||
/** Создает отдельный временной слот min..max с акцентом на avg для каждой точки history. */
|
||||
export function createSeriesOptions(points: HistoryPoint[], index: number, label: string, granulate: string): SeriesOption[] {
|
||||
const color = SERIES_COLORS[index % SERIES_COLORS.length];
|
||||
const avgData: AvgPointValue[] = points.map((point) => {
|
||||
const time = new Date(point.time).getTime();
|
||||
return [time, point.avg_value, point.min_value, point.max_value, point.point_count];
|
||||
});
|
||||
const spreadData = points.flatMap((point) => {
|
||||
const time = new Date(point.time).getTime();
|
||||
return [
|
||||
[time, point.min_value],
|
||||
[time, point.max_value],
|
||||
[time, null],
|
||||
];
|
||||
});
|
||||
const data = createBucketData(points, parseGranulateMs(granulate));
|
||||
|
||||
return [
|
||||
{
|
||||
name: label,
|
||||
type: 'line',
|
||||
data: spreadData,
|
||||
showSymbol: false,
|
||||
connectNulls: false,
|
||||
silent: true,
|
||||
tooltip: { show: false },
|
||||
legendHoverLink: false,
|
||||
lineStyle: {
|
||||
width: 1,
|
||||
opacity: 0.42,
|
||||
color,
|
||||
type: 'custom',
|
||||
data,
|
||||
renderItem: renderBucket(color),
|
||||
encode: {
|
||||
x: 0,
|
||||
y: [1, 2, 3],
|
||||
},
|
||||
emphasis: {
|
||||
disabled: true,
|
||||
},
|
||||
z: 1,
|
||||
},
|
||||
{
|
||||
name: label,
|
||||
type: 'scatter',
|
||||
data: points.map((point) => [new Date(point.time).getTime(), point.min_value]),
|
||||
symbolSize: 4,
|
||||
silent: true,
|
||||
tooltip: { show: false },
|
||||
itemStyle: {
|
||||
color,
|
||||
opacity: 0.72,
|
||||
},
|
||||
emphasis: {
|
||||
disabled: true,
|
||||
},
|
||||
z: 2,
|
||||
},
|
||||
{
|
||||
name: label,
|
||||
type: 'scatter',
|
||||
data: points.map((point) => [new Date(point.time).getTime(), point.max_value]),
|
||||
symbolSize: 4,
|
||||
silent: true,
|
||||
tooltip: { show: false },
|
||||
itemStyle: {
|
||||
color,
|
||||
opacity: 0.72,
|
||||
},
|
||||
emphasis: {
|
||||
disabled: true,
|
||||
},
|
||||
z: 2,
|
||||
},
|
||||
{
|
||||
name: label,
|
||||
type: 'line',
|
||||
showSymbol: false,
|
||||
smooth: false,
|
||||
sampling: 'lttb',
|
||||
data: avgData,
|
||||
lineStyle: {
|
||||
width: 1.8,
|
||||
color,
|
||||
},
|
||||
emphasis: {
|
||||
disabled: true,
|
||||
lineStyle: {
|
||||
width: 1.8,
|
||||
color,
|
||||
},
|
||||
},
|
||||
z: 3,
|
||||
},
|
||||
} as SeriesOption,
|
||||
];
|
||||
}
|
||||
|
||||
@@ -1,5 +1,5 @@
|
||||
import { useMemo } from 'react';
|
||||
import { useQueries } from '@tanstack/react-query';
|
||||
import { keepPreviousData, useQueries } from '@tanstack/react-query';
|
||||
import { getHistory } from '../../entities/history/api';
|
||||
import type { HistoryPoint } from '../../entities/history/types';
|
||||
|
||||
@@ -35,6 +35,7 @@ export function useHistoryChartQueries({
|
||||
queryKey: ['history', edge, tag, from, to, granulate],
|
||||
queryFn: ({ signal }: { signal: AbortSignal }) => getHistory({ edge, tag, from, to, granulate }, signal),
|
||||
enabled,
|
||||
placeholderData: keepPreviousData,
|
||||
})),
|
||||
});
|
||||
|
||||
|
||||
@@ -3,12 +3,12 @@ import type { SeriesOption } from 'echarts';
|
||||
import { createSeriesOptions } from './historyChartSeries';
|
||||
import type { HistoryChartLineData } from './useHistoryChartQueries';
|
||||
|
||||
export function useHistoryChartSeries(lines: HistoryChartLineData[]): SeriesOption[] {
|
||||
export function useHistoryChartSeries(lines: HistoryChartLineData[], granulate: string): SeriesOption[] {
|
||||
return useMemo(
|
||||
() =>
|
||||
lines.flatMap((line) =>
|
||||
line.rows.length ? createSeriesOptions(line.rows, line.index, line.label) : [],
|
||||
line.rows.length ? createSeriesOptions(line.rows, line.index, line.label, granulate) : [],
|
||||
),
|
||||
[lines],
|
||||
[granulate, lines],
|
||||
);
|
||||
}
|
||||
|
||||
@@ -25,6 +25,19 @@ const WEEK = 7 * DAY;
|
||||
const MONTH = 30 * DAY;
|
||||
const YEAR = 365 * DAY;
|
||||
|
||||
const GRANULATE_UNIT_MS: Record<string, number> = {
|
||||
second: SECOND,
|
||||
seconds: SECOND,
|
||||
minute: MINUTE,
|
||||
minutes: MINUTE,
|
||||
hour: HOUR,
|
||||
hours: HOUR,
|
||||
day: DAY,
|
||||
days: DAY,
|
||||
week: WEEK,
|
||||
weeks: WEEK,
|
||||
};
|
||||
|
||||
type Rule = {
|
||||
maxMs: number;
|
||||
granulate: string;
|
||||
@@ -60,3 +73,12 @@ export function getHistoryGranularity(from: string, to: string): HistoryGranular
|
||||
}
|
||||
);
|
||||
}
|
||||
|
||||
/** Переводит текст грануляции API вроде "10 minutes" в миллисекунды. */
|
||||
export function parseGranulateMs(granulate: string): number {
|
||||
const [amountText, unit = ''] = granulate.trim().split(/\s+/);
|
||||
const amount = Number(amountText);
|
||||
const unitMs = GRANULATE_UNIT_MS[unit.toLowerCase()];
|
||||
|
||||
return Number.isFinite(amount) && unitMs ? amount * unitMs : MINUTE;
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user