Compare commits
6 Commits
646424d44f
...
bur-39
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
c6e073c5dd | ||
| 2750f0efaf | |||
|
|
f84b15b2d0 | ||
| 688e883996 | |||
|
|
e057f55c73 | ||
|
|
f4cefe376c |
@@ -6,6 +6,21 @@ 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);
|
||||
@@ -13,6 +28,7 @@ export function CameraView({ title = 'Камера', wsUrl }: CameraViewProps) {
|
||||
useEffect(() => {
|
||||
const video = videoRef.current;
|
||||
let player: ReturnType<typeof mpegts.createPlayer> | null = null;
|
||||
const handlePlayerError = () => setError('Ошибка видеопотока');
|
||||
|
||||
if (!video) {
|
||||
return;
|
||||
@@ -30,20 +46,22 @@ export function CameraView({ title = 'Камера', wsUrl }: CameraViewProps) {
|
||||
}
|
||||
|
||||
player = mpegts.createPlayer(
|
||||
{ type: 'mpegts', isLive: true, url: wsUrl },
|
||||
{ liveBufferLatencyChasing: true, liveBufferLatencyMaxLatency: 1.5 },
|
||||
{ type: 'mpegts', isLive: true, url: wsUrl, hasAudio: false },
|
||||
CAMERA_PLAYER_CONFIG,
|
||||
);
|
||||
|
||||
player.on(mpegts.Events.ERROR, handlePlayerError);
|
||||
player.attachMediaElement(video);
|
||||
player.load();
|
||||
|
||||
const playResult = player.play();
|
||||
if (playResult instanceof Promise) {
|
||||
void playResult.then(() => setError(null)).catch(() => setError('Не удалось запустить воспроизведение'));
|
||||
void playResult.then(() => setError(null)).catch(() => undefined);
|
||||
}
|
||||
|
||||
return () => {
|
||||
video.removeEventListener('playing', clearError);
|
||||
player?.off(mpegts.Events.ERROR, handlePlayerError);
|
||||
player?.pause();
|
||||
player?.unload();
|
||||
player?.detachMediaElement();
|
||||
|
||||
@@ -4,9 +4,8 @@ import { useRef } from 'react';
|
||||
import { CalendarDays, CalendarClock, Check, ChevronDown, Clock3, DatabaseZap, Search } from 'lucide-react';
|
||||
import type { CurrentItem } from '../../../entities/current/types';
|
||||
import { HistoryChart } from '../../../features/history-chart/HistoryChart';
|
||||
import type { HistoryZoomRange } from '../../../features/history-chart/chartTypes';
|
||||
import { RANGE_PRESETS, createRange, type DateRangeState } from '../../../features/history/dateRange';
|
||||
import { toInputDateTimeValue, toIsoFromInput } from '../../../utils/format';
|
||||
import { toIsoFromInput } from '../../../utils/format';
|
||||
import type { HistoryGranularity } from '../../../utils/historyGranularity';
|
||||
|
||||
type ArchiveViewProps = {
|
||||
@@ -109,12 +108,6 @@ export function ArchiveView({
|
||||
[rangePart]: updateRangeInputPart(range[rangePart], inputPart, value),
|
||||
});
|
||||
};
|
||||
const updateRangeFromZoom = (nextRange: HistoryZoomRange) => {
|
||||
onRangeChange({
|
||||
from: toInputDateTimeValue(new Date(nextRange.from)),
|
||||
to: toInputDateTimeValue(new Date(nextRange.to)),
|
||||
});
|
||||
};
|
||||
|
||||
return (
|
||||
<section className="chart-section chart-section--archive">
|
||||
@@ -270,7 +263,6 @@ export function ArchiveView({
|
||||
labelFormat={historyAxis.labelFormat}
|
||||
tags={selectedTags}
|
||||
tagLabels={tagLabels}
|
||||
onZoomRangeChange={updateRangeFromZoom}
|
||||
/>
|
||||
) : (
|
||||
<div className="chart-placeholder">Разверните список показателей и выберите серию для графика</div>
|
||||
|
||||
@@ -1,4 +1,5 @@
|
||||
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';
|
||||
@@ -15,7 +16,6 @@ type HistoryChartProps = {
|
||||
tickIntervalMs?: number;
|
||||
to: string;
|
||||
tagLabels?: Record<string, string>;
|
||||
onZoomRangeChange?: (range: HistoryZoomRange) => void;
|
||||
};
|
||||
|
||||
const ZOOM_REQUEST_DELAY_MS = 350;
|
||||
@@ -87,6 +87,39 @@ function isSameZoomRange(left: HistoryZoomRange, right: HistoryZoomRange): boole
|
||||
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,
|
||||
@@ -96,13 +129,18 @@ export function HistoryChart({
|
||||
tickIntervalMs,
|
||||
to,
|
||||
tagLabels = {},
|
||||
onZoomRangeChange,
|
||||
}: HistoryChartProps) {
|
||||
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,
|
||||
@@ -114,12 +152,13 @@ export function HistoryChart({
|
||||
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(() => {
|
||||
const nextRange = createInitialZoomRange({ from, granulate, labelFormat, tickIntervalMs, to });
|
||||
zoomRangeRef.current = nextRange;
|
||||
setZoomRange(nextRange);
|
||||
}, [from, granulate, labelFormat, tickIntervalMs, to]);
|
||||
baseRangeRef.current = baseRange;
|
||||
zoomRangeRef.current = baseRange;
|
||||
setZoomRange(baseRange);
|
||||
}, [baseRange]);
|
||||
|
||||
useEffect(() => {
|
||||
zoomRangeRef.current = zoomRange;
|
||||
@@ -137,17 +176,29 @@ export function HistoryChart({
|
||||
const option = useMemo(
|
||||
() =>
|
||||
createHistoryChartOptions({
|
||||
dataZoomState: { start: 0, end: 100 },
|
||||
from: zoomRange.from,
|
||||
to: zoomRange.to,
|
||||
dataZoomState: createDataZoomState(baseRange, zoomRange),
|
||||
from: baseRange.from,
|
||||
to: baseRange.to,
|
||||
labelFormat: zoomRange.labelFormat,
|
||||
legendData,
|
||||
series,
|
||||
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 state = (event.batch ?? [event]).find(isXAxisDataZoom);
|
||||
|
||||
@@ -155,8 +206,9 @@ export function HistoryChart({
|
||||
return;
|
||||
}
|
||||
|
||||
const baseRange = baseRangeRef.current;
|
||||
const currentRange = zoomRangeRef.current;
|
||||
const nextRange = getZoomRangeFromEvent(state, currentRange);
|
||||
const nextRange = getZoomRangeFromEvent(state, baseRange);
|
||||
|
||||
if (!nextRange || isSameZoomRange(nextRange, currentRange)) {
|
||||
return;
|
||||
@@ -169,16 +221,15 @@ export function HistoryChart({
|
||||
zoomTimerRef.current = setTimeout(() => {
|
||||
zoomRangeRef.current = nextRange;
|
||||
setZoomRange(nextRange);
|
||||
onZoomRangeChange?.(nextRange);
|
||||
}, ZOOM_REQUEST_DELAY_MS);
|
||||
}, [onZoomRangeChange]);
|
||||
}, []);
|
||||
|
||||
return (
|
||||
<HistoryChartArea
|
||||
hasData={series.length > 0}
|
||||
hasData={displayHasData}
|
||||
hasSelection={tags.length > 0}
|
||||
loading={loading}
|
||||
option={option}
|
||||
option={displayOption}
|
||||
onDataZoom={handleDataZoom}
|
||||
/>
|
||||
);
|
||||
|
||||
@@ -1,6 +1,7 @@
|
||||
import type { EChartsOption } from 'echarts';
|
||||
import ReactEChartsCore from 'echarts-for-react/esm/core.js';
|
||||
import { useMemo } from 'react';
|
||||
import { useCallback, useEffect, useMemo, useRef } from 'react';
|
||||
import type { WheelEvent } from 'react';
|
||||
import type { DataZoomEventBatch } from './chartTypes';
|
||||
import { echarts } from './historyChartEcharts';
|
||||
|
||||
@@ -12,6 +13,21 @@ type HistoryChartAreaProps = {
|
||||
onDataZoom: (event: DataZoomEventBatch) => void;
|
||||
};
|
||||
|
||||
/** Включает или выключает нативный X-зум колесом, чтобы Shift + колесо работал только по Y. */
|
||||
function setXAxisWheelZoom(chart: ReturnType<ReactEChartsCore['getEchartsInstance']>, enabled: boolean): void {
|
||||
chart.setOption(
|
||||
{
|
||||
dataZoom: [
|
||||
{
|
||||
id: 'history-x-inside',
|
||||
zoomOnMouseWheel: enabled,
|
||||
},
|
||||
],
|
||||
},
|
||||
{ lazyUpdate: true },
|
||||
);
|
||||
}
|
||||
|
||||
/** Отвечает только за визуальную область графика: placeholder или ECharts canvas. */
|
||||
export function HistoryChartArea({
|
||||
hasData,
|
||||
@@ -20,18 +36,61 @@ export function HistoryChartArea({
|
||||
option,
|
||||
onDataZoom,
|
||||
}: HistoryChartAreaProps) {
|
||||
const chartRef = useRef<InstanceType<typeof ReactEChartsCore> | null>(null);
|
||||
const xWheelZoomEnabledRef = useRef(true);
|
||||
const onChartEvents = useMemo(
|
||||
() => ({
|
||||
datazoom: onDataZoom,
|
||||
}),
|
||||
[onDataZoom],
|
||||
);
|
||||
const updateXAxisWheelZoom = useCallback((enabled: boolean) => {
|
||||
const chart = chartRef.current?.getEchartsInstance();
|
||||
|
||||
if (!chart || xWheelZoomEnabledRef.current === enabled) {
|
||||
return;
|
||||
}
|
||||
|
||||
xWheelZoomEnabledRef.current = enabled;
|
||||
setXAxisWheelZoom(chart, enabled);
|
||||
}, []);
|
||||
|
||||
useEffect(() => {
|
||||
const handleKeyDown = (event: KeyboardEvent) => {
|
||||
if (event.key === 'Shift') {
|
||||
updateXAxisWheelZoom(false);
|
||||
}
|
||||
};
|
||||
const handleKeyUp = (event: KeyboardEvent) => {
|
||||
if (event.key === 'Shift') {
|
||||
updateXAxisWheelZoom(true);
|
||||
}
|
||||
};
|
||||
const handleBlur = () => updateXAxisWheelZoom(true);
|
||||
|
||||
window.addEventListener('keydown', handleKeyDown);
|
||||
window.addEventListener('keyup', handleKeyUp);
|
||||
window.addEventListener('blur', handleBlur);
|
||||
|
||||
return () => {
|
||||
window.removeEventListener('keydown', handleKeyDown);
|
||||
window.removeEventListener('keyup', handleKeyUp);
|
||||
window.removeEventListener('blur', handleBlur);
|
||||
};
|
||||
}, [updateXAxisWheelZoom]);
|
||||
|
||||
const handleWheelCapture = useCallback(
|
||||
(event: WheelEvent<HTMLDivElement>) => {
|
||||
updateXAxisWheelZoom(!event.shiftKey);
|
||||
},
|
||||
[updateXAxisWheelZoom],
|
||||
);
|
||||
|
||||
if (!hasSelection) {
|
||||
return <div className="chart-placeholder">Разверните список показателей и выберите серию для графика</div>;
|
||||
}
|
||||
|
||||
if (loading) {
|
||||
if (!hasData && loading) {
|
||||
return <div className="chart-placeholder">Загрузка графика...</div>;
|
||||
}
|
||||
|
||||
@@ -39,5 +98,16 @@ export function HistoryChartArea({
|
||||
return <div className="chart-placeholder">Нет данных для выбранного диапазона</div>;
|
||||
}
|
||||
|
||||
return <ReactEChartsCore echarts={echarts} option={option} className="history-chart" onEvents={onChartEvents} lazyUpdate />;
|
||||
return (
|
||||
<div className="history-chart-shell" onWheelCapture={handleWheelCapture}>
|
||||
<ReactEChartsCore
|
||||
ref={chartRef}
|
||||
echarts={echarts}
|
||||
option={option}
|
||||
className="history-chart"
|
||||
onEvents={onChartEvents}
|
||||
lazyUpdate
|
||||
/>
|
||||
</div>
|
||||
);
|
||||
}
|
||||
|
||||
@@ -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,
|
||||
})),
|
||||
});
|
||||
|
||||
|
||||
@@ -1,8 +1,14 @@
|
||||
.history-chart-shell,
|
||||
.history-chart {
|
||||
width: 100%;
|
||||
height: 440px;
|
||||
}
|
||||
|
||||
.history-chart-shell .history-chart {
|
||||
height: 100%;
|
||||
}
|
||||
|
||||
.chart-section--archive .history-chart-shell,
|
||||
.chart-section--archive .history-chart {
|
||||
flex: 1;
|
||||
min-height: 520px;
|
||||
@@ -67,6 +73,7 @@
|
||||
}
|
||||
|
||||
@media (max-width: 680px) {
|
||||
.chart-section--archive .history-chart-shell,
|
||||
.chart-section--archive .history-chart,
|
||||
.chart-section--archive .chart-placeholder {
|
||||
min-height: 420px;
|
||||
|
||||
Reference in New Issue
Block a user