IT/licensetrackerbackend
4
0
Fork 0
mirror of https://github.com/donavon04/licensetrackerbackend.git synced 2025-01-18 16:50:56 -07:00
Code Issues Actions Packages Projects Releases Wiki Activity

Updated app.js

Browse Source
This commit is contained in:
Donny 2024-08-30 10:50:20 -06:00
parent fcbda0bf9e
commit b3858567c6
1 changed files with 0 additions and 50 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

50
app.js
View File

@ -393,56 +393,6 @@ 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(() => { setTimeout(() => {
testDatabaseConnection(); testDatabaseConnection();
}, 1000); }, 1000);