mirror of
https://github.com/donavon04/licensetrackerbackend.git
synced 2025-01-18 08:40:57 -07:00
Trying to add time data
This commit is contained in:
parent
ce54772119
commit
fcbda0bf9e
50
app.js
50
app.js
@ -393,6 +393,56 @@ const addProgram = async (programName, machineName) => {
|
||||
}
|
||||
};
|
||||
|
||||
async function recordTimeSeriesData() {
|
||||
// Get the current timestamp and timestamp for 5 minutes ago
|
||||
const now = new Date();
|
||||
const localPollrate = new Date(now.getTime() - pollrate);
|
||||
|
||||
// Format dates for MySQL
|
||||
const nowFormatted = now.toISOString().slice(0, 19).replace('T', ' ');
|
||||
const fiveMinutesAgoFormatted = localPollrate.toISOString().slice(0, 19).replace('T', ' ');
|
||||
|
||||
// Query to count records within the last 5 minutes
|
||||
const countQuery = `
|
||||
SELECT program, COUNT(*) as count
|
||||
FROM usedLicences
|
||||
WHERE date >= ?
|
||||
GROUP BY program
|
||||
`;
|
||||
|
||||
// Query to insert data into time_data
|
||||
const insertQuery = `
|
||||
INSERT INTO time_data (name, count, date)
|
||||
VALUES (?, ?, ?)
|
||||
`;
|
||||
|
||||
connection.connect();
|
||||
|
||||
connection.query(countQuery, [fiveMinutesAgoFormatted], (err, results) => {
|
||||
if (err) {
|
||||
console.error('Error querying count:', err);
|
||||
connection.end();
|
||||
return;
|
||||
}
|
||||
|
||||
// Insert aggregated data into time_data
|
||||
results.forEach(row => {
|
||||
connection.query(insertQuery, [row.program, row.count, nowFormatted], (err) => {
|
||||
if (err) {
|
||||
console.error('Error inserting data:', err);
|
||||
}
|
||||
});
|
||||
});
|
||||
|
||||
console.log('Time series data recorded successfully.');
|
||||
connection.end();
|
||||
});
|
||||
}
|
||||
|
||||
setTimeout(() => {
|
||||
recordTimeSeriesData();
|
||||
}, pollrate);
|
||||
|
||||
setTimeout(() => {
|
||||
testDatabaseConnection();
|
||||
}, 1000);
|
||||
|
Loading…
Reference in New Issue
Block a user