Updated front-end for salidomo installations

Fixed zoom-in problem
Added log tab for salidomo installations
This commit is contained in:
Noe 2024-05-21 11:42:24 +02:00
parent bde392e35d
commit aa912e5fe8
14 changed files with 297 additions and 36 deletions

View File

@ -109,7 +109,7 @@ public static partial class Db
} }
else else
{ {
Console.WriteLine("---------------Added the new Error to the database-----------------"); Console.WriteLine("---------------Added the new Warning to the database-----------------");
Create(newWarning); Create(newWarning);
} }
} }

View File

@ -51,6 +51,8 @@ public static class RabbitMqManager
//A message can be an alarm, a warning or a heartbit //A message can be an alarm, a warning or a heartbit
StatusMessage? receivedStatusMessage = JsonSerializer.Deserialize<StatusMessage>(message); StatusMessage? receivedStatusMessage = JsonSerializer.Deserialize<StatusMessage>(message);
lock (WebsocketManager.InstallationConnections) lock (WebsocketManager.InstallationConnections)
{ {
//Consumer received a message //Consumer received a message
@ -73,6 +75,7 @@ public static class RabbitMqManager
//Traverse the Warnings list, and store each of them to the database //Traverse the Warnings list, and store each of them to the database
if (receivedStatusMessage.Warnings != null) if (receivedStatusMessage.Warnings != null)
{ {
foreach (var warning in receivedStatusMessage.Warnings) foreach (var warning in receivedStatusMessage.Warnings)
{ {
Warning newWarning = new Warning Warning newWarning = new Warning
@ -85,6 +88,7 @@ public static class RabbitMqManager
Seen = false Seen = false
}; };
//Create a new warning and add it to the database //Create a new warning and add it to the database
Console.WriteLine("Add a warning for installation "+installationId);
Db.HandleWarning(newWarning, installationId); Db.HandleWarning(newWarning, installationId);
} }
} }
@ -93,7 +97,7 @@ public static class RabbitMqManager
//Traverse the Alarm list, and store each of them to the database //Traverse the Alarm list, and store each of them to the database
if (receivedStatusMessage.Alarms != null) if (receivedStatusMessage.Alarms != null)
{ {
Console.WriteLine("Add an alarm for installation "+installationId);
foreach (var alarm in receivedStatusMessage.Alarms) foreach (var alarm in receivedStatusMessage.Alarms)
{ {
Error newError = new Error Error newError = new Error
@ -104,7 +108,7 @@ public static class RabbitMqManager
Time = alarm.Time, Time = alarm.Time,
DeviceCreatedTheMessage = alarm.CreatedBy, DeviceCreatedTheMessage = alarm.CreatedBy,
Seen = false Seen = false
}; }; Console.WriteLine("Add an alarm for installation "+installationId);
//Create a new error and add it to the database //Create a new error and add it to the database
Db.HandleError(newError, installationId); Db.HandleError(newError, installationId);
} }
@ -139,6 +143,7 @@ public static class RabbitMqManager
} }
} }
} }
}; };
Channel.BasicConsume(queue: "statusQueue", autoAck: true, consumer: consumer); Channel.BasicConsume(queue: "statusQueue", autoAck: true, consumer: consumer);

View File

@ -4,7 +4,8 @@ namespace InnovEnergy.App.Backend.Websockets;
public class StatusMessage public class StatusMessage
{ {
public required Int32 InstallationId { get; set; } public required Int32 InstallationId { get; set; }
public required int Status { get; set; } public required Int32 Product { get; set; }
public required Int32 Status { get; set; }
public required MessageType Type { get; set; } public required MessageType Type { get; set; }
public List<AlarmOrWarning>? Warnings { get; set; } public List<AlarmOrWarning>? Warnings { get; set; }
public List<AlarmOrWarning>? Alarms { get; set; } public List<AlarmOrWarning>? Alarms { get; set; }

View File

@ -5,6 +5,7 @@ namespace InnovEnergy.App.SaliMax.DataTypes;
public class StatusMessage public class StatusMessage
{ {
public required Int32 InstallationId { get; set; } public required Int32 InstallationId { get; set; }
public required Int32 Product { get; set; }
public required SalimaxAlarmState Status { get; set; } public required SalimaxAlarmState Status { get; set; }
public required MessageType Type { get; set; } public required MessageType Type { get; set; }
public List<AlarmOrWarning>? Warnings { get; set; } public List<AlarmOrWarning>? Warnings { get; set; }

View File

@ -1,4 +1,4 @@
#undef Amax #define Amax
#undef GridLimit #undef GridLimit
using System.IO.Compression; using System.IO.Compression;

Binary file not shown.

View File

@ -114,6 +114,16 @@ function MainStats(props: MainStatsProps) {
}); });
}, []); }, []);
const [isZooming, setIsZooming] = useState(false);
useEffect(() => {
if (isZooming) {
setLoading(true);
} else if (!isZooming && batteryViewDataArray.length > 0) {
setLoading(false);
}
}, [isZooming, batteryViewDataArray]);
function generateSeries(chartData, category, color) { function generateSeries(chartData, category, color) {
const series = []; const series = [];
const pathsToSearch = [ const pathsToSearch = [
@ -223,11 +233,14 @@ function MainStats(props: MainStatsProps) {
setErrorDateModalOpen(false); setErrorDateModalOpen(false);
}; };
const startZoom = () => {
setIsZooming(true);
};
const handleBeforeZoom = (chartContext, { xaxis }) => { const handleBeforeZoom = (chartContext, { xaxis }) => {
const startX = parseInt(xaxis.min) / 1000; const startX = parseInt(xaxis.min) / 1000;
const endX = parseInt(xaxis.max) / 1000; const endX = parseInt(xaxis.max) / 1000;
setLoading(true);
const resultPromise: Promise<{ const resultPromise: Promise<{
chartData: BatteryDataInterface; chartData: BatteryDataInterface;
chartOverview: BatteryOverviewInterface; chartOverview: BatteryOverviewInterface;
@ -246,7 +259,7 @@ function MainStats(props: MainStatsProps) {
}) })
); );
setLoading(false); setIsZooming(false);
setChartState(batteryViewDataArray.length); setChartState(batteryViewDataArray.length);
}) })
.catch((error) => { .catch((error) => {
@ -509,7 +522,10 @@ function MainStats(props: MainStatsProps) {
), ),
chart: { chart: {
events: { events: {
beforeZoom: handleBeforeZoom beforeZoom: (chartContext, options) => {
startZoom();
handleBeforeZoom(chartContext, options);
}
} }
} }
}} }}
@ -568,7 +584,10 @@ function MainStats(props: MainStatsProps) {
), ),
chart: { chart: {
events: { events: {
beforeZoom: handleBeforeZoom beforeZoom: (chartContext, options) => {
startZoom();
handleBeforeZoom(chartContext, options);
}
} }
} }
}} }}
@ -626,7 +645,10 @@ function MainStats(props: MainStatsProps) {
), ),
chart: { chart: {
events: { events: {
beforeZoom: handleBeforeZoom beforeZoom: (chartContext, options) => {
startZoom();
handleBeforeZoom(chartContext, options);
}
} }
} }
}} }}
@ -684,7 +706,10 @@ function MainStats(props: MainStatsProps) {
), ),
chart: { chart: {
events: { events: {
beforeZoom: handleBeforeZoom beforeZoom: (chartContext, options) => {
startZoom();
handleBeforeZoom(chartContext, options);
}
} }
} }
}} }}
@ -742,7 +767,10 @@ function MainStats(props: MainStatsProps) {
), ),
chart: { chart: {
events: { events: {
beforeZoom: handleBeforeZoom beforeZoom: (chartContext, options) => {
startZoom();
handleBeforeZoom(chartContext, options);
}
} }
} }
}} }}

View File

@ -288,6 +288,26 @@ function InformationSalidomo(props: InformationSalidomoProps) {
/> />
</div> </div>
<div>
<TextField
label="S3 Write Key"
name="s3writesecretkey"
value={formValues.s3WriteKey}
variant="outlined"
fullWidth
/>
</div>
<div>
<TextField
label="S3 Write Key"
name="s3writesecretkey"
value={formValues.s3WriteKey}
variant="outlined"
fullWidth
/>
</div>
<div <div
style={{ style={{
display: 'flex', display: 'flex',

View File

@ -34,7 +34,7 @@ function InstallationTabs() {
useContext(InstallationsContext); useContext(InstallationsContext);
const webSocketsContext = useContext(WebSocketContext); const webSocketsContext = useContext(WebSocketContext);
const { socket, openSocket } = webSocketsContext; const { socket, openSocket, closeSocket } = webSocketsContext;
useEffect(() => { useEffect(() => {
let path = location.pathname.split('/'); let path = location.pathname.split('/');
@ -50,7 +50,11 @@ function InstallationTabs() {
}, [location]); }, [location]);
useEffect(() => { useEffect(() => {
if (!socket && salimaxInstallations.length > 0) { if (salimaxInstallations && salimaxInstallations.length > 0) {
if (socket) {
closeSocket();
}
openSocket(salimaxInstallations); openSocket(salimaxInstallations);
} }
}, [salimaxInstallations]); }, [salimaxInstallations]);

View File

@ -71,6 +71,15 @@ function Overview(props: OverviewProps) {
const [startDate, setStartDate] = useState(dayjs().add(-1, 'day')); const [startDate, setStartDate] = useState(dayjs().add(-1, 'day'));
const [endDate, setEndDate] = useState(dayjs()); const [endDate, setEndDate] = useState(dayjs());
const [isZooming, setIsZooming] = useState(false);
useEffect(() => {
if (isZooming) {
setLoading(true);
} else if (!isZooming && dailyDataArray.length > 0) {
setLoading(false);
}
}, [isZooming, dailyDataArray]);
useEffect(() => { useEffect(() => {
const resultPromise: Promise<{ const resultPromise: Promise<{
@ -97,11 +106,14 @@ function Overview(props: OverviewProps) {
}); });
}, []); }, []);
const startZoom = () => {
setIsZooming(true);
};
const handleBeforeZoom = (chartContext, { xaxis }) => { const handleBeforeZoom = (chartContext, { xaxis }) => {
const startX = parseInt(xaxis.min) / 1000; const startX = parseInt(xaxis.min) / 1000;
const endX = parseInt(xaxis.max) / 1000; const endX = parseInt(xaxis.max) / 1000;
setLoading(true);
const resultPromise: Promise<{ const resultPromise: Promise<{
chartData: chartDataInterface; chartData: chartDataInterface;
chartOverview: overviewInterface; chartOverview: overviewInterface;
@ -111,21 +123,31 @@ function Overview(props: OverviewProps) {
UnixTime.fromTicks(endX) UnixTime.fromTicks(endX)
); );
let isComponentMounted = true;
resultPromise resultPromise
.then((result) => { .then((result) => {
if (isComponentMounted) {
setDailyDataArray((prevData) => setDailyDataArray((prevData) =>
prevData.concat({ prevData.concat({
chartData: result.chartData, chartData: result.chartData,
chartOverview: result.chartOverview chartOverview: result.chartOverview
}) })
); );
setIsZooming(false);
setLoading(false);
setChartState(dailyDataArray.length); setChartState(dailyDataArray.length);
}
}) })
.catch((error) => { .catch((error) => {
if (isComponentMounted) {
console.error('Error:', error); console.error('Error:', error);
setLoading(false); // Ensure loading is turned off even if there is an error
}
}); });
return () => {
isComponentMounted = false;
};
}; };
const handle24HourData = () => { const handle24HourData = () => {
@ -595,7 +617,10 @@ function Overview(props: OverviewProps) {
), ),
chart: { chart: {
events: { events: {
beforeZoom: handleBeforeZoom beforeZoom: (chartContext, options) => {
startZoom();
handleBeforeZoom(chartContext, options);
}
} }
} }
}} }}
@ -761,7 +786,10 @@ function Overview(props: OverviewProps) {
), ),
chart: { chart: {
events: { events: {
beforeZoom: handleBeforeZoom beforeZoom: (chartContext, options) => {
startZoom();
handleBeforeZoom(chartContext, options);
}
} }
} }
}} }}
@ -851,7 +879,10 @@ function Overview(props: OverviewProps) {
), ),
chart: { chart: {
events: { events: {
beforeZoom: handleBeforeZoom beforeZoom: (chartContext, options) => {
startZoom();
handleBeforeZoom(chartContext, options);
}
} }
} }
}} }}
@ -982,7 +1013,10 @@ function Overview(props: OverviewProps) {
), ),
chart: { chart: {
events: { events: {
beforeZoom: handleBeforeZoom beforeZoom: (chartContext, options) => {
startZoom();
handleBeforeZoom(chartContext, options);
}
} }
} }
}} }}
@ -1040,7 +1074,10 @@ function Overview(props: OverviewProps) {
), ),
chart: { chart: {
events: { events: {
beforeZoom: handleBeforeZoom beforeZoom: (chartContext, options) => {
startZoom();
handleBeforeZoom(chartContext, options);
}
} }
} }
}} }}
@ -1111,7 +1148,10 @@ function Overview(props: OverviewProps) {
), ),
chart: { chart: {
events: { events: {
beforeZoom: handleBeforeZoom beforeZoom: (chartContext, options) => {
startZoom();
handleBeforeZoom(chartContext, options);
}
} }
} }
}} }}
@ -1196,7 +1236,10 @@ function Overview(props: OverviewProps) {
), ),
chart: { chart: {
events: { events: {
beforeZoom: handleBeforeZoom beforeZoom: (chartContext, options) => {
startZoom();
handleBeforeZoom(chartContext, options);
}
} }
} }
}} }}

View File

@ -1,6 +1,7 @@
import React, { useContext, useState } from 'react'; import React, { useContext, useState } from 'react';
import { import {
Card, Card,
CircularProgress,
Grid, Grid,
Table, Table,
TableBody, TableBody,
@ -16,6 +17,7 @@ import { WebSocketContext } from 'src/contexts/WebSocketContextProvider';
import { FormattedMessage } from 'react-intl'; import { FormattedMessage } from 'react-intl';
import { useLocation, useNavigate } from 'react-router-dom'; import { useLocation, useNavigate } from 'react-router-dom';
import routes from '../../../Resources/routes.json'; import routes from '../../../Resources/routes.json';
import CancelIcon from '@mui/icons-material/Cancel';
interface FlatInstallationViewProps { interface FlatInstallationViewProps {
installations: I_Installation[]; installations: I_Installation[];
@ -29,6 +31,21 @@ const FlatInstallationView = (props: FlatInstallationViewProps) => {
const [selectedInstallation, setSelectedInstallation] = useState<number>(-1); const [selectedInstallation, setSelectedInstallation] = useState<number>(-1);
const currentLocation = useLocation(); const currentLocation = useLocation();
const sortedInstallations = [...props.installations].sort((a, b) => {
// Compare the status field of each installation and sort them based on the status.
//Installations with alarms go first
let a_status = getStatus(a.id);
let b_status = getStatus(b.id);
if (a_status > b_status) {
return -1;
}
if (a_status < b_status) {
return 1;
}
return 0;
});
const handleSelectOneInstallation = (installationID: number): void => { const handleSelectOneInstallation = (installationID: number): void => {
if (selectedInstallation != installationID) { if (selectedInstallation != installationID) {
setSelectedInstallation(installationID); setSelectedInstallation(installationID);
@ -95,10 +112,13 @@ const FlatInstallationView = (props: FlatInstallationViewProps) => {
<TableCell> <TableCell>
<FormattedMessage id="VRM Link" defaultMessage="VRM Link" /> <FormattedMessage id="VRM Link" defaultMessage="VRM Link" />
</TableCell> </TableCell>
<TableCell>
<FormattedMessage id="status" defaultMessage="Status" />
</TableCell>
</TableRow> </TableRow>
</TableHead> </TableHead>
<TableBody> <TableBody>
{props.installations.map((installation) => { {sortedInstallations.map((installation) => {
const isInstallationSelected = const isInstallationSelected =
installation.s3BucketId === selectedInstallation; installation.s3BucketId === selectedInstallation;
@ -200,6 +220,57 @@ const FlatInstallationView = (props: FlatInstallationViewProps) => {
</a> </a>
</Typography> </Typography>
</TableCell> </TableCell>
<TableCell>
<div
style={{
display: 'flex',
alignItems: 'center',
marginLeft: '15px'
}}
>
{status === -1 ? (
<CancelIcon
style={{
width: '23px',
height: '23px',
color: 'red',
borderRadius: '50%'
}}
/>
) : (
''
)}
{status === -2 ? (
<CircularProgress
size={20}
sx={{
color: '#f7b34d'
}}
/>
) : (
''
)}
<div
style={{
width: '20px',
height: '20px',
marginLeft: '2px',
borderRadius: '50%',
backgroundColor:
status === 2
? 'red'
: status === 1
? 'orange'
: status === -1 || status === -2
? 'transparent'
: 'green'
}}
/>
</div>
</TableCell>
</TableRow> </TableRow>
); );
})} })}

View File

@ -1,5 +1,5 @@
import React, { useContext, useEffect, useState } from 'react'; import React, { useContext, useEffect, useState } from 'react';
import { Card, Grid, Typography } from '@mui/material'; import { Card, CircularProgress, Grid, Typography } from '@mui/material';
import { I_Installation } from 'src/interfaces/InstallationTypes'; import { I_Installation } from 'src/interfaces/InstallationTypes';
import { UserContext } from 'src/contexts/userContext'; import { UserContext } from 'src/contexts/userContext';
import { TimeSpan, UnixTime } from 'src/dataCache/time'; import { TimeSpan, UnixTime } from 'src/dataCache/time';
@ -15,6 +15,8 @@ import { Navigate, Route, Routes, useLocation } from 'react-router-dom';
import routes from '../../../Resources/routes.json'; import routes from '../../../Resources/routes.json';
import InformationSalidomo from '../Information/InformationSalidomo'; import InformationSalidomo from '../Information/InformationSalidomo';
import BatteryView from '../BatteryView/BatteryView'; import BatteryView from '../BatteryView/BatteryView';
import Log from '../Log/Log';
import CancelIcon from '@mui/icons-material/Cancel';
interface singleInstallationProps { interface singleInstallationProps {
current_installation?: I_Installation; current_installation?: I_Installation;
@ -174,6 +176,69 @@ function Installation(props: singleInstallationProps) {
{props.current_installation.installationName} {props.current_installation.installationName}
</Typography> </Typography>
</div> </div>
<div style={{ display: 'flex', alignItems: 'center' }}>
<Typography
fontWeight="bold"
color="text.primary"
noWrap
sx={{
marginTop: '0px',
marginBottom: '10px',
fontSize: '14px'
}}
>
Status:
</Typography>
<div
style={{
display: 'flex',
alignItems: 'center',
marginLeft: '75px',
marginTop: '-10px'
}}
>
{status === -1 ? (
<CancelIcon
style={{
width: '23px',
height: '23px',
color: 'red',
borderRadius: '50%'
}}
/>
) : (
''
)}
{status === -2 ? (
<CircularProgress
size={20}
sx={{
color: '#f7b34d'
}}
/>
) : (
''
)}
<div
style={{
width: '20px',
height: '20px',
marginLeft: '2px',
borderRadius: '50%',
backgroundColor:
status === 2
? 'red'
: status === 1
? 'orange'
: status === -1 || status === -2
? 'transparent'
: 'green'
}}
/>
</div>
</div>
<Card variant="outlined"> <Card variant="outlined">
<Grid <Grid
@ -195,6 +260,16 @@ function Installation(props: singleInstallationProps) {
} }
/> />
<Route
path={routes.log}
element={
<Log
errorLoadingS3Data={errorLoadingS3Data}
id={props.current_installation.id}
></Log>
}
/>
<Route <Route
path={routes.batteryview + '*'} path={routes.batteryview + '*'}
element={ element={

View File

@ -23,7 +23,7 @@ function SalidomoInstallationTabs() {
useContext(InstallationsContext); useContext(InstallationsContext);
const webSocketsContext = useContext(WebSocketContext); const webSocketsContext = useContext(WebSocketContext);
const { socket, openSocket } = webSocketsContext; const { socket, openSocket, closeSocket } = webSocketsContext;
useEffect(() => { useEffect(() => {
let path = location.pathname.split('/'); let path = location.pathname.split('/');
@ -43,6 +43,15 @@ function SalidomoInstallationTabs() {
} }
}, [salidomoInstallations]); }, [salidomoInstallations]);
useEffect(() => {
if (salidomoInstallations && salidomoInstallations.length > 0) {
if (socket) {
closeSocket();
}
openSocket(salidomoInstallations);
}
}, [salidomoInstallations]);
const handleTabsChange = (_event: ChangeEvent<{}>, value: string): void => { const handleTabsChange = (_event: ChangeEvent<{}>, value: string): void => {
setCurrentTab(value); setCurrentTab(value);
}; };
@ -83,6 +92,10 @@ function SalidomoInstallationTabs() {
/> />
) )
}, },
{
value: 'log',
label: <FormattedMessage id="log" defaultMessage="Log" />
},
{ {
value: 'information', value: 'information',