20 Commits

Author SHA1 Message Date
Первов Артем
3d395aaa8d BUR-61 добавлена возможность сохранять и отображать current.value = null значений 2026-07-05 21:43:32 +03:00
e396fbbb8a Merge pull request 'BUR-39 Добавлена возможность вертикального и горизонтального зума без эффекта друг дргуа' (#21) from bur-39 into dev
Reviewed-on: #21
2026-07-05 18:15:29 +00:00
Первов Артем
c6e073c5dd BUR-39 Добавлена возможность вертикального и горизонтального зума без эффекта друг дргуа 2026-07-05 21:12:07 +03:00
2750f0efaf Merge pull request 'BUR-58 Добавлена оптимальная конфигурация для потока видео' (#20) from bur-58 into dev
Reviewed-on: #20
2026-07-05 14:46:19 +00:00
Первов Артем
f84b15b2d0 BUR-58 Добавлена оптимальная конфигурация для потока видео 2026-07-05 17:41:34 +03:00
688e883996 Merge pull request 'bur-64' (#19) from bur-64 into dev
Reviewed-on: #19
2026-07-05 13:52:32 +00:00
Первов Артем
e057f55c73 BUR-64 Убран loader с графика. Во время зума храним предыдущее состояние до тех пор, пока не пришла новая серия 2026-07-05 16:24:46 +03:00
Первов Артем
f4cefe376c BUR-64 Скорректирован зум-графика с сохранением изначального периода 2026-07-05 16:01:13 +03:00
646424d44f Merge pull request 'BUR-64 синхронизировал изменение input date/time полей с масштабированием графика.' (#18) from bur-64 into dev
Reviewed-on: #18
2026-07-05 10:49:04 +00:00
Первов Артем
8bb19f3f9d BUR-64 синхронизировал изменение input date/time полей с масштабированием графика. 2026-07-05 13:46:51 +03:00
4e3cc0eb33 Merge pull request 'BUR-37 привел тултип к шаблону "сред. ${avg} (${min} .. ${max})"' (#17) from bur-37 into dev
Reviewed-on: #17
2026-07-05 10:31:42 +00:00
Первов Артем
01d05b4331 BUR-37 привел тултип к шаблону "сред. ${avg} (${min} .. ${max})" 2026-07-05 13:29:05 +03:00
ca78c0b17b Merge pull request 'BUR-58 исправлен import mpegts.' (#16) from bur-58 into dev
Reviewed-on: #16
2026-07-05 10:05:03 +00:00
Первов Артем
19ca8d0885 BUR-58 исправлен import mpegts. 2026-07-05 13:03:26 +03:00
ba8bb6940b Merge pull request 'BUR-64 Улучшено масштабирование. Добавлен перерендер для согласованности отображения графика при приближении/отдалении' (#15) from bur-64 into dev
Reviewed-on: #15
2026-07-05 09:49:34 +00:00
Первов Артем
9ca1b2e20a BUR-64 Улучшено масштабирование. Добавлен перерендер для согласованности отображения графика при приближении/отдалении 2026-07-05 12:38:37 +03:00
cc0de27fb6 Merge pull request 'BUR-39 скорректировал зум по Y через SHIFT+mw' (#14) from bur-39 into dev
Reviewed-on: #14
2026-07-05 08:25:25 +00:00
Первов Артем
790859c173 BUR-39 скорректировал зум по Y через SHIFT+mw 2026-07-05 11:20:57 +03:00
378036f4dd Merge pull request 'BUR-62 переработана отрисовка графика на отрезки по грануляции' (#13) from bur-62 into dev
Reviewed-on: #13
2026-07-05 08:05:36 +00:00
Первов Артем
1a994f36bd BUR-62 переработана отрисовка графика на отрезки по грануляции 2026-07-05 09:54:05 +03:00
17 changed files with 463 additions and 143 deletions

View File

@@ -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 = {
@@ -5,14 +6,29 @@ type CameraViewProps = {
wsUrl: string; 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) { export function CameraView({ title = 'Камера', wsUrl }: CameraViewProps) {
const videoRef = useRef<HTMLVideoElement | null>(null); const videoRef = useRef<HTMLVideoElement | null>(null);
const [error, setError] = useState<string | null>(null); const [error, setError] = useState<string | null>(null);
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; const handlePlayerError = () => setError('Ошибка видеопотока');
if (!video) { if (!video) {
return; return;
@@ -22,33 +38,30 @@ 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 (!mpegts.isSupported()) {
if (cancelled) { setError('Браузер не поддерживает MPEG-TS поток');
return; return () => {
} video.removeEventListener('playing', clearError);
};
}
if (!mpegts.isSupported()) { player = mpegts.createPlayer(
setError('Браузер не поддерживает MPEG-TS поток'); { type: 'mpegts', isLive: true, url: wsUrl, hasAudio: false },
return; CAMERA_PLAYER_CONFIG,
} );
player = mpegts.createPlayer( player.on(mpegts.Events.ERROR, handlePlayerError);
{ type: 'mpegts', isLive: true, url: wsUrl }, player.attachMediaElement(video);
{ liveBufferLatencyChasing: true, liveBufferLatencyMaxLatency: 1.5 }, player.load();
);
player.attachMediaElement(video); const playResult = player.play();
player.load(); if (playResult instanceof Promise) {
void playResult.then(() => setError(null)).catch(() => undefined);
const playResult = player.play(); }
if (playResult instanceof Promise) {
void playResult.then(() => setError(null)).catch(() => setError('Не удалось запустить воспроизведение'));
}
});
return () => { return () => {
cancelled = true;
video.removeEventListener('playing', clearError); video.removeEventListener('playing', clearError);
player?.off(mpegts.Events.ERROR, handlePlayerError);
player?.pause(); player?.pause();
player?.unload(); player?.unload();
player?.detachMediaElement(); player?.detachMediaElement();

View File

@@ -1,7 +1,7 @@
export type CurrentItem = { export type CurrentItem = {
edge: string; edge: string;
tag: string; tag: string;
value: number; value: number | null;
createdAt: string; createdAt: string;
updatedAt: string; updatedAt: string;
time: string; time: string;

View File

@@ -5,7 +5,7 @@ import { CalendarDays, CalendarClock, Check, ChevronDown, Clock3, DatabaseZap, S
import type { CurrentItem } from '../../../entities/current/types'; import type { CurrentItem } from '../../../entities/current/types';
import { HistoryChart } from '../../../features/history-chart/HistoryChart'; import { HistoryChart } from '../../../features/history-chart/HistoryChart';
import { RANGE_PRESETS, createRange, type DateRangeState } from '../../../features/history/dateRange'; import { RANGE_PRESETS, createRange, type DateRangeState } from '../../../features/history/dateRange';
import { toIsoFromInput } from '../../../utils/format'; import { formatNumber, toIsoFromInput } from '../../../utils/format';
import type { HistoryGranularity } from '../../../utils/historyGranularity'; import type { HistoryGranularity } from '../../../utils/historyGranularity';
type ArchiveViewProps = { type ArchiveViewProps = {
@@ -191,7 +191,7 @@ export function ArchiveView({
{label !== item.tag ? <small>{item.tag}</small> : null} {label !== item.tag ? <small>{item.tag}</small> : null}
</span> </span>
<span className="tag-select-item__side"> <span className="tag-select-item__side">
<strong>{item.value.toLocaleString('ru-RU', { maximumFractionDigits: item.precision ?? 3 })}</strong> <strong>{formatNumber(item.value)}</strong>
{selected ? <Check size={15} /> : null} {selected ? <Check size={15} /> : null}
</span> </span>
</button> </button>

View File

@@ -29,8 +29,8 @@ export function ElectricalNode({ liveValues, node, ownerEdgeId }: ElectricalNode
? getLiveValue(liveValues, node.edgeId || ownerEdgeId, node.tagId) ? getLiveValue(liveValues, node.edgeId || ownerEdgeId, node.tagId)
: getLiveValue(liveValues, bindingEdgeId, bindings?.stateTagId); : getLiveValue(liveValues, bindingEdgeId, bindings?.stateTagId);
const alarmValue = node.kind === 'decoration' ? getLiveValue(liveValues, bindingEdgeId, bindings?.alarmTagId) : undefined; const alarmValue = node.kind === 'decoration' ? getLiveValue(liveValues, bindingEdgeId, bindings?.alarmTagId) : undefined;
const alarmActive = Boolean(alarmValue && Number(alarmValue.value) !== 0); const alarmActive = Boolean(alarmValue && alarmValue.value !== null && alarmValue.value !== 0);
const stateActive = Boolean(mainValue && Number(mainValue.value) !== 0); const stateActive = Boolean(mainValue && mainValue.value !== null && mainValue.value !== 0);
const title = getNodeTitle(node, mainValue); const title = getNodeTitle(node, mainValue);
const style: CSSProperties = { const style: CSSProperties = {
left: node.position.x, left: node.position.x,

View File

@@ -1,6 +1,7 @@
import { useCallback, useMemo, useRef } from 'react'; import { useCallback, useEffect, useMemo, useRef, useState } from 'react';
import type { HistoryAxisLabelFormat } from '../../utils/historyGranularity'; import type { EChartsOption } from 'echarts';
import type { DataZoomEventBatch, DataZoomState } from './chartTypes'; import { getHistoryGranularity, type HistoryAxisLabelFormat } from '../../utils/historyGranularity';
import type { DataZoomEventBatch, DataZoomState, HistoryZoomRange } from './chartTypes';
import { HistoryChartArea } from './HistoryChartArea'; import { HistoryChartArea } from './HistoryChartArea';
import { createHistoryChartOptions } from './historyChartOptions'; import { createHistoryChartOptions } from './historyChartOptions';
import { useHistoryChartQueries } from './useHistoryChartQueries'; import { useHistoryChartQueries } from './useHistoryChartQueries';
@@ -17,11 +18,108 @@ type HistoryChartProps = {
tagLabels?: Record<string, string>; tagLabels?: Record<string, string>;
}; };
/** Контейнер истории: загружает выбранные теги и передает готовые серии в область ECharts. */ const ZOOM_REQUEST_DELAY_MS = 350;
function isXAxisDataZoom(state: DataZoomState): boolean { function isXAxisDataZoom(state: DataZoomState): boolean {
return state.dataZoomId?.startsWith('history-x-') || state.dataZoomIndex === 0 || state.dataZoomIndex === 1; 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({ export function HistoryChart({
edge, edge,
from, from,
@@ -32,26 +130,75 @@ export function HistoryChart({
to, to,
tagLabels = {}, tagLabels = {},
}: HistoryChartProps) { }: HistoryChartProps) {
const dataZoomRef = useRef<DataZoomState | null>(null); const baseRange = useMemo(
const lines = useHistoryChartQueries({ edge, from, granulate, tags, to, tagLabels }); () => createInitialZoomRange({ from, granulate, labelFormat, tickIntervalMs, to }),
const series = useHistoryChartSeries(lines); [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 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(() => {
baseRangeRef.current = baseRange;
zoomRangeRef.current = baseRange;
setZoomRange(baseRange);
}, [baseRange]);
useEffect(() => {
zoomRangeRef.current = zoomRange;
}, [zoomRange]);
useEffect(
() => () => {
if (zoomTimerRef.current) {
clearTimeout(zoomTimerRef.current);
}
},
[],
);
const option = useMemo( const option = useMemo(
() => () =>
createHistoryChartOptions({ createHistoryChartOptions({
dataZoomState: dataZoomRef.current ?? {}, dataZoomState: createDataZoomState(baseRange, zoomRange),
from, from: baseRange.from,
to, to: baseRange.to,
labelFormat, labelFormat: zoomRange.labelFormat,
legendData, legendData,
series, 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 handleDataZoom = useCallback((event: DataZoomEventBatch) => {
const state = (event.batch ?? [event]).find(isXAxisDataZoom); const state = (event.batch ?? [event]).find(isXAxisDataZoom);
@@ -59,20 +206,30 @@ export function HistoryChart({
return; return;
} }
dataZoomRef.current = { const baseRange = baseRangeRef.current;
start: state.start, const currentRange = zoomRangeRef.current;
end: state.end, const nextRange = getZoomRangeFromEvent(state, baseRange);
startValue: state.startValue,
endValue: state.endValue, 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 ( 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}
/> />
); );

View File

@@ -1,6 +1,7 @@
import type { EChartsOption } from 'echarts'; import type { EChartsOption } from 'echarts';
import ReactEChartsCore from 'echarts-for-react/esm/core.js'; 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 type { DataZoomEventBatch } from './chartTypes';
import { echarts } from './historyChartEcharts'; import { echarts } from './historyChartEcharts';
@@ -12,6 +13,21 @@ type HistoryChartAreaProps = {
onDataZoom: (event: DataZoomEventBatch) => void; 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. */ /** Отвечает только за визуальную область графика: placeholder или ECharts canvas. */
export function HistoryChartArea({ export function HistoryChartArea({
hasData, hasData,
@@ -20,18 +36,61 @@ export function HistoryChartArea({
option, option,
onDataZoom, onDataZoom,
}: HistoryChartAreaProps) { }: HistoryChartAreaProps) {
const chartRef = useRef<InstanceType<typeof ReactEChartsCore> | null>(null);
const xWheelZoomEnabledRef = useRef(true);
const onChartEvents = useMemo( const onChartEvents = useMemo(
() => ({ () => ({
datazoom: onDataZoom, datazoom: onDataZoom,
}), }),
[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) { if (!hasSelection) {
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>;
} }
@@ -39,5 +98,16 @@ export function HistoryChartArea({
return <div className="chart-placeholder">Нет данных для выбранного диапазона</div>; 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>
);
} }

View File

@@ -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 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 = { export type TooltipParam = {
color?: string; color?: string;
marker?: string; marker?: string;

View File

@@ -1,4 +1,4 @@
import { LineChart, ScatterChart } from 'echarts/charts'; import { CustomChart } from 'echarts/charts';
import { import {
DataZoomComponent, DataZoomComponent,
GridComponent, GridComponent,
@@ -9,8 +9,7 @@ import * as echarts from 'echarts/core';
import { CanvasRenderer } from 'echarts/renderers'; import { CanvasRenderer } from 'echarts/renderers';
echarts.use([ echarts.use([
LineChart, CustomChart,
ScatterChart,
GridComponent, GridComponent,
LegendComponent, LegendComponent,
TooltipComponent, TooltipComponent,

View File

@@ -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 {

View File

@@ -82,6 +82,8 @@ export function createHistoryChartOptions({
id: 'history-x-inside', id: 'history-x-inside',
type: 'inside', type: 'inside',
xAxisIndex: 0, xAxisIndex: 0,
zoomOnMouseWheel: true,
moveOnMouseWheel: false,
throttle: 80, throttle: 80,
start: dataZoomState.start, start: dataZoomState.start,
end: dataZoomState.end, end: dataZoomState.end,
@@ -111,6 +113,8 @@ export function createHistoryChartOptions({
type: 'inside', type: 'inside',
yAxisIndex: 0, yAxisIndex: 0,
filterMode: 'none', filterMode: 'none',
zoomOnMouseWheel: 'shift',
moveOnMouseWheel: false,
throttle: 80, throttle: 80,
}, },
{ {

View File

@@ -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 { HistoryPoint } from '../../entities/history/types';
import type { AvgPointValue } from './chartTypes'; import { parseGranulateMs } from '../../utils/historyGranularity';
import type { HistoryBucketValue } from './chartTypes';
export const SERIES_COLORS = [ export const SERIES_COLORS = [
'#5B8FF9', '#5B8FF9',
@@ -13,93 +20,120 @@ export const SERIES_COLORS = [
'#A7B3FF', '#A7B3FF',
]; ];
/** Создает avg-линию, вертикальные min/max-отрезки и точки экстремумов для одной серии. */ type CartesianCoordSys = {
export function createSeriesOptions(points: HistoryPoint[], index: number, label: string): SeriesOption[] { 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 color = SERIES_COLORS[index % SERIES_COLORS.length];
const avgData: AvgPointValue[] = points.map((point) => { const data = createBucketData(points, parseGranulateMs(granulate));
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],
];
});
return [ return [
{ {
name: label, name: label,
type: 'line', type: 'custom',
data: spreadData, data,
showSymbol: false, renderItem: renderBucket(color),
connectNulls: false, encode: {
silent: true, x: 0,
tooltip: { show: false }, y: [1, 2, 3],
legendHoverLink: false,
lineStyle: {
width: 1,
opacity: 0.42,
color,
}, },
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: { itemStyle: {
color, color,
opacity: 0.72,
}, },
emphasis: { emphasis: {
disabled: true, 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, z: 3,
}, } as SeriesOption,
]; ];
} }

View File

@@ -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,
})), })),
}); });

View File

@@ -3,12 +3,12 @@ import type { SeriesOption } from 'echarts';
import { createSeriesOptions } from './historyChartSeries'; import { createSeriesOptions } from './historyChartSeries';
import type { HistoryChartLineData } from './useHistoryChartQueries'; import type { HistoryChartLineData } from './useHistoryChartQueries';
export function useHistoryChartSeries(lines: HistoryChartLineData[]): SeriesOption[] { export function useHistoryChartSeries(lines: HistoryChartLineData[], granulate: string): SeriesOption[] {
return useMemo( return useMemo(
() => () =>
lines.flatMap((line) => 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],
); );
} }

View File

@@ -1,8 +1,14 @@
.history-chart-shell,
.history-chart { .history-chart {
width: 100%; width: 100%;
height: 440px; height: 440px;
} }
.history-chart-shell .history-chart {
height: 100%;
}
.chart-section--archive .history-chart-shell,
.chart-section--archive .history-chart { .chart-section--archive .history-chart {
flex: 1; flex: 1;
min-height: 520px; min-height: 520px;
@@ -67,6 +73,7 @@
} }
@media (max-width: 680px) { @media (max-width: 680px) {
.chart-section--archive .history-chart-shell,
.chart-section--archive .history-chart, .chart-section--archive .history-chart,
.chart-section--archive .chart-placeholder { .chart-section--archive .chart-placeholder {
min-height: 420px; min-height: 420px;

View File

@@ -1,7 +1,7 @@
/** Форматирует числовое значение показателя для карточек и мини-плиток. */ /** Форматирует числовое значение показателя для карточек и мини-плиток. */
export function formatNumber(value: number): string { export function formatNumber(value: number | null): string {
if (!Number.isFinite(value)) { if (value === null || !Number.isFinite(value)) {
return '-'; return '';
} }
return new Intl.NumberFormat('ru-RU', { return new Intl.NumberFormat('ru-RU', {

View File

@@ -25,6 +25,19 @@ const WEEK = 7 * DAY;
const MONTH = 30 * DAY; const MONTH = 30 * DAY;
const YEAR = 365 * 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 = { type Rule = {
maxMs: number; maxMs: number;
granulate: string; 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;
}

View File

@@ -16,8 +16,9 @@ function isConfiguredLimit(value: number | null): value is number {
export function getMetricStatus(item: CurrentItem, now = Date.now()): MetricStatusInfo { export function getMetricStatus(item: CurrentItem, now = Date.now()): MetricStatusInfo {
const measuredAt = new Date(item.time).getTime(); const measuredAt = new Date(item.time).getTime();
const ageSeconds = Number.isFinite(measuredAt) ? Math.max(0, Math.round((now - measuredAt) / 1000)) : Number.POSITIVE_INFINITY; const ageSeconds = Number.isFinite(measuredAt) ? Math.max(0, Math.round((now - measuredAt) / 1000)) : Number.POSITIVE_INFINITY;
const belowMin = isConfiguredLimit(item.min) && item.value < item.min; const value = item.value;
const aboveMax = isConfiguredLimit(item.max) && item.value > item.max; const belowMin = isConfiguredLimit(value) && isConfiguredLimit(item.min) && value < item.min;
const aboveMax = isConfiguredLimit(value) && isConfiguredLimit(item.max) && value > item.max;
if (belowMin || aboveMax) { if (belowMin || aboveMax) {
return { status: 'critical', label: 'за пределами уставки', ageSeconds }; return { status: 'critical', label: 'за пределами уставки', ageSeconds };