From d9ad431a23760672cb3d36309099f7b434df3482 Mon Sep 17 00:00:00 2001 From: faris Aljohari <83524184+farisaljohari@users.noreply.github.com> Date: Wed, 18 Jun 2025 05:33:49 -0600 Subject: [PATCH] fix: correct procedure names in energy consumption updates --- .../helper/services/power.clamp.service.ts | 39 +++++++++---------- 1 file changed, 19 insertions(+), 20 deletions(-) diff --git a/libs/common/src/helper/services/power.clamp.service.ts b/libs/common/src/helper/services/power.clamp.service.ts index b0e852f..7c83208 100644 --- a/libs/common/src/helper/services/power.clamp.service.ts +++ b/libs/common/src/helper/services/power.clamp.service.ts @@ -22,21 +22,20 @@ export class PowerClampService { }) .replace('/', '-'); // MM-YYYY - await this.executeProcedure('fact_hourly_energy_consumed_procedure', [ - deviceUuid, - dateStr, - hour, - ]); + await this.executeProcedure( + 'fact_hourly_device_energy_consumed_procedure', + [deviceUuid, dateStr, hour], + ); - await this.executeProcedure('fact_daily_energy_consumed_procedure', [ - deviceUuid, - dateStr, - ]); + await this.executeProcedure( + 'fact_daily_device_energy_consumed_procedure', + [deviceUuid, dateStr], + ); - await this.executeProcedure('fact_monthly_energy_consumed_procedure', [ - deviceUuid, - monthYear, - ]); + await this.executeProcedure( + 'fact_monthly_device_energy_consumed_procedure', + [deviceUuid, monthYear], + ); } catch (err) { console.error('Failed to insert or update energy data:', err); throw err; @@ -47,15 +46,15 @@ export class PowerClampService { procedureFileName: string, params: (string | number | null)[], ): Promise { - const query = this.loadQuery(procedureFileName); + const query = this.loadQuery( + 'fact_device_energy_consumed', + procedureFileName, + ); await this.dataSource.query(query, params); + console.log(`Procedure ${procedureFileName} executed successfully.`); } - private loadQuery(fileName: string): string { - return this.sqlLoader.loadQuery( - 'fact_energy_consumed', - fileName, - SQL_PROCEDURES_PATH, - ); + private loadQuery(folderName: string, fileName: string): string { + return this.sqlLoader.loadQuery(folderName, fileName, SQL_PROCEDURES_PATH); } }