diff --git a/libs/common/src/helper/services/power.clamp.service.ts b/libs/common/src/helper/services/power.clamp.service.ts index b0e852f..b61b804 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; @@ -49,11 +48,12 @@ export class PowerClampService { ): Promise { const query = this.loadQuery(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', + 'fact_device_energy_consumed', fileName, SQL_PROCEDURES_PATH, );