ammar/backend
1
0
Fork 0
mirror of https://github.com/SyncrowIOT/backend.git synced 2025-11-27 10:14:54 +00:00
Code Issues Packages Projects Releases Wiki Activity

refactor: update procedure names in PowerClampService for clarity

Browse Source
This commit is contained in:
faris Aljohari
2025-05-02 01:57:12 +03:00
parent a12046eee2
commit aee6b8df69
1 changed files with 14 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files

28
libs/common/src/helper/services/power.clamp.service.ts
View File

@ -22,21 +22,20 @@ export class PowerClampService {
}) })
.replace('/', '-'); // MM-YYYY .replace('/', '-'); // MM-YYYY
await this.executeProcedure('fact_hourly_energy_consumed_procedure', [ await this.executeProcedure(
deviceUuid, 'fact_hourly_device_energy_consumed_procedure',
dateStr, [deviceUuid, dateStr, hour],
hour, );
]);
await this.executeProcedure('fact_daily_energy_consumed_procedure', [ await this.executeProcedure(
deviceUuid, 'fact_daily_device_energy_consumed_procedure',
dateStr, [deviceUuid, dateStr],
]); );
await this.executeProcedure('fact_monthly_energy_consumed_procedure', [ await this.executeProcedure(
deviceUuid, 'fact_monthly_device_energy_consumed_procedure',
monthYear, [deviceUuid, monthYear],
]); );
} catch (err) { } catch (err) {
console.error('Failed to insert or update energy data:', err); console.error('Failed to insert or update energy data:', err);
throw err; throw err;
@ -49,11 +48,12 @@ export class PowerClampService {
): Promise<void> { ): Promise<void> {
const query = this.loadQuery(procedureFileName); const query = this.loadQuery(procedureFileName);
await this.dataSource.query(query, params); await this.dataSource.query(query, params);
console.log(`Procedure ${procedureFileName} executed successfully.`);
} }
private loadQuery(fileName: string): string { private loadQuery(fileName: string): string {
return this.sqlLoader.loadQuery( return this.sqlLoader.loadQuery(
'fact_energy_consumed', 'fact_device_energy_consumed',
fileName, fileName,
SQL_PROCEDURES_PATH, SQL_PROCEDURES_PATH,
); );