Compare commits
8 Commits
ba8bb6940b
...
bur-64
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
e057f55c73 | ||
|
|
f4cefe376c | ||
| 646424d44f | |||
|
|
8bb19f3f9d | ||
| 4e3cc0eb33 | |||
|
|
01d05b4331 | ||
| ca78c0b17b | |||
|
|
19ca8d0885 |
@@ -1,3 +1,4 @@
|
|||||||
|
import mpegts from 'mpegts.js';
|
||||||
import { useEffect, useRef, useState } from 'react';
|
import { useEffect, useRef, useState } from 'react';
|
||||||
|
|
||||||
type CameraViewProps = {
|
type CameraViewProps = {
|
||||||
@@ -11,8 +12,7 @@ export function CameraView({ title = 'Камера', wsUrl }: CameraViewProps) {
|
|||||||
|
|
||||||
useEffect(() => {
|
useEffect(() => {
|
||||||
const video = videoRef.current;
|
const video = videoRef.current;
|
||||||
let player: import('mpegts.js').default.Player | null = null;
|
let player: ReturnType<typeof mpegts.createPlayer> | null = null;
|
||||||
let cancelled = false;
|
|
||||||
|
|
||||||
if (!video) {
|
if (!video) {
|
||||||
return;
|
return;
|
||||||
@@ -22,14 +22,11 @@ export function CameraView({ title = 'Камера', wsUrl }: CameraViewProps) {
|
|||||||
video.addEventListener('playing', clearError);
|
video.addEventListener('playing', clearError);
|
||||||
setError(null);
|
setError(null);
|
||||||
|
|
||||||
void import('mpegts.js').then(({ default: mpegts }) => {
|
|
||||||
if (cancelled) {
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
if (!mpegts.isSupported()) {
|
if (!mpegts.isSupported()) {
|
||||||
setError('Браузер не поддерживает MPEG-TS поток');
|
setError('Браузер не поддерживает MPEG-TS поток');
|
||||||
return;
|
return () => {
|
||||||
|
video.removeEventListener('playing', clearError);
|
||||||
|
};
|
||||||
}
|
}
|
||||||
|
|
||||||
player = mpegts.createPlayer(
|
player = mpegts.createPlayer(
|
||||||
@@ -44,10 +41,8 @@ export function CameraView({ title = 'Камера', wsUrl }: CameraViewProps) {
|
|||||||
if (playResult instanceof Promise) {
|
if (playResult instanceof Promise) {
|
||||||
void playResult.then(() => setError(null)).catch(() => setError('Не удалось запустить воспроизведение'));
|
void playResult.then(() => setError(null)).catch(() => setError('Не удалось запустить воспроизведение'));
|
||||||
}
|
}
|
||||||
});
|
|
||||||
|
|
||||||
return () => {
|
return () => {
|
||||||
cancelled = true;
|
|
||||||
video.removeEventListener('playing', clearError);
|
video.removeEventListener('playing', clearError);
|
||||||
player?.pause();
|
player?.pause();
|
||||||
player?.unload();
|
player?.unload();
|
||||||
|
|||||||
@@ -1,4 +1,5 @@
|
|||||||
import { useCallback, useEffect, useMemo, useRef, useState } from 'react';
|
import { useCallback, useEffect, useMemo, useRef, useState } from 'react';
|
||||||
|
import type { EChartsOption } from 'echarts';
|
||||||
import { getHistoryGranularity, type HistoryAxisLabelFormat } from '../../utils/historyGranularity';
|
import { getHistoryGranularity, type HistoryAxisLabelFormat } from '../../utils/historyGranularity';
|
||||||
import type { DataZoomEventBatch, DataZoomState, HistoryZoomRange } from './chartTypes';
|
import type { DataZoomEventBatch, DataZoomState, HistoryZoomRange } from './chartTypes';
|
||||||
import { HistoryChartArea } from './HistoryChartArea';
|
import { HistoryChartArea } from './HistoryChartArea';
|
||||||
@@ -86,6 +87,39 @@ function isSameZoomRange(left: HistoryZoomRange, right: HistoryZoomRange): boole
|
|||||||
return left.from === right.from && left.to === right.to && left.granulate === right.granulate;
|
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({
|
export function HistoryChart({
|
||||||
edge,
|
edge,
|
||||||
from,
|
from,
|
||||||
@@ -96,11 +130,17 @@ export function HistoryChart({
|
|||||||
to,
|
to,
|
||||||
tagLabels = {},
|
tagLabels = {},
|
||||||
}: HistoryChartProps) {
|
}: HistoryChartProps) {
|
||||||
|
const baseRange = useMemo(
|
||||||
|
() => createInitialZoomRange({ from, granulate, labelFormat, tickIntervalMs, to }),
|
||||||
|
[from, granulate, labelFormat, tickIntervalMs, to],
|
||||||
|
);
|
||||||
const [zoomRange, setZoomRange] = useState(() =>
|
const [zoomRange, setZoomRange] = useState(() =>
|
||||||
createInitialZoomRange({ from, granulate, labelFormat, tickIntervalMs, to }),
|
createInitialZoomRange({ from, granulate, labelFormat, tickIntervalMs, to }),
|
||||||
);
|
);
|
||||||
|
const baseRangeRef = useRef(baseRange);
|
||||||
const zoomRangeRef = useRef(zoomRange);
|
const zoomRangeRef = useRef(zoomRange);
|
||||||
const zoomTimerRef = useRef<ReturnType<typeof setTimeout> | null>(null);
|
const zoomTimerRef = useRef<ReturnType<typeof setTimeout> | null>(null);
|
||||||
|
const lastReadyOptionRef = useRef<EChartsOption | null>(null);
|
||||||
const lines = useHistoryChartQueries({
|
const lines = useHistoryChartQueries({
|
||||||
edge,
|
edge,
|
||||||
from: zoomRange.from,
|
from: zoomRange.from,
|
||||||
@@ -112,12 +152,13 @@ export function HistoryChart({
|
|||||||
const series = useHistoryChartSeries(lines, zoomRange.granulate);
|
const series = useHistoryChartSeries(lines, zoomRange.granulate);
|
||||||
const legendData = useMemo(() => lines.map((line) => line.label), [lines]);
|
const legendData = useMemo(() => lines.map((line) => line.label), [lines]);
|
||||||
const loading = lines.some((line) => line.loading);
|
const loading = lines.some((line) => line.loading);
|
||||||
|
const hasData = series.length > 0;
|
||||||
|
|
||||||
useEffect(() => {
|
useEffect(() => {
|
||||||
const nextRange = createInitialZoomRange({ from, granulate, labelFormat, tickIntervalMs, to });
|
baseRangeRef.current = baseRange;
|
||||||
zoomRangeRef.current = nextRange;
|
zoomRangeRef.current = baseRange;
|
||||||
setZoomRange(nextRange);
|
setZoomRange(baseRange);
|
||||||
}, [from, granulate, labelFormat, tickIntervalMs, to]);
|
}, [baseRange]);
|
||||||
|
|
||||||
useEffect(() => {
|
useEffect(() => {
|
||||||
zoomRangeRef.current = zoomRange;
|
zoomRangeRef.current = zoomRange;
|
||||||
@@ -135,17 +176,29 @@ export function HistoryChart({
|
|||||||
const option = useMemo(
|
const option = useMemo(
|
||||||
() =>
|
() =>
|
||||||
createHistoryChartOptions({
|
createHistoryChartOptions({
|
||||||
dataZoomState: { start: 0, end: 100 },
|
dataZoomState: createDataZoomState(baseRange, zoomRange),
|
||||||
from: zoomRange.from,
|
from: baseRange.from,
|
||||||
to: zoomRange.to,
|
to: baseRange.to,
|
||||||
labelFormat: zoomRange.labelFormat,
|
labelFormat: zoomRange.labelFormat,
|
||||||
legendData,
|
legendData,
|
||||||
series,
|
series,
|
||||||
tickIntervalMs: zoomRange.tickIntervalMs,
|
tickIntervalMs: zoomRange.tickIntervalMs,
|
||||||
}),
|
}),
|
||||||
[legendData, series, zoomRange],
|
[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 handleDataZoom = useCallback((event: DataZoomEventBatch) => {
|
||||||
const state = (event.batch ?? [event]).find(isXAxisDataZoom);
|
const state = (event.batch ?? [event]).find(isXAxisDataZoom);
|
||||||
|
|
||||||
@@ -153,8 +206,9 @@ export function HistoryChart({
|
|||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
const baseRange = baseRangeRef.current;
|
||||||
const currentRange = zoomRangeRef.current;
|
const currentRange = zoomRangeRef.current;
|
||||||
const nextRange = getZoomRangeFromEvent(state, currentRange);
|
const nextRange = getZoomRangeFromEvent(state, baseRange);
|
||||||
|
|
||||||
if (!nextRange || isSameZoomRange(nextRange, currentRange)) {
|
if (!nextRange || isSameZoomRange(nextRange, currentRange)) {
|
||||||
return;
|
return;
|
||||||
@@ -172,10 +226,10 @@ export function HistoryChart({
|
|||||||
|
|
||||||
return (
|
return (
|
||||||
<HistoryChartArea
|
<HistoryChartArea
|
||||||
hasData={series.length > 0}
|
hasData={displayHasData}
|
||||||
hasSelection={tags.length > 0}
|
hasSelection={tags.length > 0}
|
||||||
loading={loading}
|
loading={loading}
|
||||||
option={option}
|
option={displayOption}
|
||||||
onDataZoom={handleDataZoom}
|
onDataZoom={handleDataZoom}
|
||||||
/>
|
/>
|
||||||
);
|
);
|
||||||
|
|||||||
@@ -31,7 +31,7 @@ export function HistoryChartArea({
|
|||||||
return <div className="chart-placeholder">Разверните список показателей и выберите серию для графика</div>;
|
return <div className="chart-placeholder">Разверните список показателей и выберите серию для графика</div>;
|
||||||
}
|
}
|
||||||
|
|
||||||
if (loading) {
|
if (!hasData && loading) {
|
||||||
return <div className="chart-placeholder">Загрузка графика...</div>;
|
return <div className="chart-placeholder">Загрузка графика...</div>;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -60,7 +60,7 @@ function formatChartValue(value: number): string {
|
|||||||
}).format(value);
|
}).format(value);
|
||||||
}
|
}
|
||||||
|
|
||||||
/** Показывает одно значение, если min/avg/max визуально совпадают. */
|
/** Форматирует значение tooltip: одно число для min=avg=max или среднее с диапазоном. */
|
||||||
function formatTooltipValue(value: AvgPointValue): string {
|
function formatTooltipValue(value: AvgPointValue): string {
|
||||||
const avg = formatChartValue(value[1]);
|
const avg = formatChartValue(value[1]);
|
||||||
const min = formatChartValue(value[2]);
|
const min = formatChartValue(value[2]);
|
||||||
@@ -70,7 +70,7 @@ function formatTooltipValue(value: AvgPointValue): string {
|
|||||||
return avg;
|
return avg;
|
||||||
}
|
}
|
||||||
|
|
||||||
return `min ${min} · avg ${avg} · max ${max}`;
|
return `сред. ${avg} (${min} .. ${max})`;
|
||||||
}
|
}
|
||||||
|
|
||||||
function isAvgPointValue(value: unknown): value is AvgPointValue {
|
function isAvgPointValue(value: unknown): value is AvgPointValue {
|
||||||
|
|||||||
@@ -1,5 +1,5 @@
|
|||||||
import { useMemo } from 'react';
|
import { useMemo } from 'react';
|
||||||
import { useQueries } from '@tanstack/react-query';
|
import { keepPreviousData, useQueries } from '@tanstack/react-query';
|
||||||
import { getHistory } from '../../entities/history/api';
|
import { getHistory } from '../../entities/history/api';
|
||||||
import type { HistoryPoint } from '../../entities/history/types';
|
import type { HistoryPoint } from '../../entities/history/types';
|
||||||
|
|
||||||
@@ -35,6 +35,7 @@ export function useHistoryChartQueries({
|
|||||||
queryKey: ['history', edge, tag, from, to, granulate],
|
queryKey: ['history', edge, tag, from, to, granulate],
|
||||||
queryFn: ({ signal }: { signal: AbortSignal }) => getHistory({ edge, tag, from, to, granulate }, signal),
|
queryFn: ({ signal }: { signal: AbortSignal }) => getHistory({ edge, tag, from, to, granulate }, signal),
|
||||||
enabled,
|
enabled,
|
||||||
|
placeholderData: keepPreviousData,
|
||||||
})),
|
})),
|
||||||
});
|
});
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user