Compare commits
11 Commits
790859c173
...
bur-64
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
e057f55c73 | ||
|
|
f4cefe376c | ||
| 646424d44f | |||
|
|
8bb19f3f9d | ||
| 4e3cc0eb33 | |||
|
|
01d05b4331 | ||
| ca78c0b17b | |||
|
|
19ca8d0885 | ||
| ba8bb6940b | |||
|
|
9ca1b2e20a | ||
| cc0de27fb6 |
@@ -1,3 +1,4 @@
|
||||
import mpegts from 'mpegts.js';
|
||||
import { useEffect, useRef, useState } from 'react';
|
||||
|
||||
type CameraViewProps = {
|
||||
@@ -11,8 +12,7 @@ export function CameraView({ title = 'Камера', wsUrl }: CameraViewProps) {
|
||||
|
||||
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;
|
||||
|
||||
if (!video) {
|
||||
return;
|
||||
@@ -22,32 +22,27 @@ 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 },
|
||||
{ liveBufferLatencyChasing: true, liveBufferLatencyMaxLatency: 1.5 },
|
||||
);
|
||||
|
||||
player = mpegts.createPlayer(
|
||||
{ type: 'mpegts', isLive: true, url: wsUrl },
|
||||
{ liveBufferLatencyChasing: true, liveBufferLatencyMaxLatency: 1.5 },
|
||||
);
|
||||
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(() => setError('Не удалось запустить воспроизведение'));
|
||||
}
|
||||
|
||||
return () => {
|
||||
cancelled = true;
|
||||
video.removeEventListener('playing', clearError);
|
||||
player?.pause();
|
||||
player?.unload();
|
||||
|
||||
@@ -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, granulate);
|
||||
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,7 +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;
|
||||
|
||||
@@ -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 {
|
||||
|
||||
@@ -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,
|
||||
})),
|
||||
});
|
||||
|
||||
|
||||
Reference in New Issue
Block a user