src/charging-station/ocpp/1.6/OCPP16RequestService.ts

   1 // Partial Copyright Jerome Benoit. 2021. All Rights Reserved.
   2
   3 import { ACElectricUtils, DCElectricUtils } from '../../../utils/ElectricUtils';
   4 import { AuthorizeRequest, OCPP16AuthorizeResponse, OCPP16StartTransactionResponse, OCPP16StopTransactionReason, OCPP16StopTransactionResponse, StartTransactionRequest, StopTransactionRequest } from '../../../types/ocpp/1.6/Transaction';
   5 import { CurrentType, Voltage } from '../../../types/ChargingStationTemplate';
   6 import { DiagnosticsStatusNotificationRequest, HeartbeatRequest, OCPP16BootNotificationRequest, OCPP16RequestCommand, StatusNotificationRequest } from '../../../types/ocpp/1.6/Requests';
   7 import { MeterValueUnit, MeterValuesRequest, OCPP16MeterValue, OCPP16MeterValueMeasurand, OCPP16MeterValuePhase } from '../../../types/ocpp/1.6/MeterValues';
   8
   9 import type ChargingStation from '../../ChargingStation';
  10 import Constants from '../../../utils/Constants';
  11 import { ErrorType } from '../../../types/ocpp/ErrorType';
  12 import MeasurandPerPhaseSampledValueTemplates from '../../../types/MeasurandPerPhaseSampledValueTemplates';
  13 import MeasurandValues from '../../../types/MeasurandValues';
  14 import { OCPP16BootNotificationResponse } from '../../../types/ocpp/1.6/Responses';
  15 import { OCPP16ChargePointErrorCode } from '../../../types/ocpp/1.6/ChargePointErrorCode';
  16 import { OCPP16ChargePointStatus } from '../../../types/ocpp/1.6/ChargePointStatus';
  17 import { OCPP16DiagnosticsStatus } from '../../../types/ocpp/1.6/DiagnosticsStatus';
  18 import { OCPP16ServiceUtils } from './OCPP16ServiceUtils';
  19 import OCPPError from '../../../exception/OCPPError';
  20 import OCPPRequestService from '../OCPPRequestService';
  21 import type OCPPResponseService from '../OCPPResponseService';
  22 import { SendParams } from '../../../types/ocpp/Requests';
  23 import Utils from '../../../utils/Utils';
  24 import logger from '../../../utils/Logger';
  25
  26 const moduleName = 'OCPP16RequestService';
  27
  28 export default class OCPP16RequestService extends OCPPRequestService {
  29   public constructor(chargingStation: ChargingStation, ocppResponseService: OCPPResponseService) {
  30     if (new.target?.name === moduleName) {
  31       throw new TypeError(`Cannot construct ${new.target?.name} instances directly`);
  32     }
  33     super(chargingStation, ocppResponseService);
  34   }
  35
  36   public async sendHeartbeat(params?: SendParams): Promise<void> {
  37     const payload: HeartbeatRequest = {};
  38     await this.sendMessage(Utils.generateUUID(), payload, OCPP16RequestCommand.HEARTBEAT, params);
  39   }
  40
  41   public async sendBootNotification(chargePointModel: string, chargePointVendor: string, chargeBoxSerialNumber?: string, firmwareVersion?: string,
  42       chargePointSerialNumber?: string, iccid?: string, imsi?: string, meterSerialNumber?: string, meterType?: string,
  43       params?: SendParams): Promise<OCPP16BootNotificationResponse> {
  44     const payload: OCPP16BootNotificationRequest = {
  45       chargePointModel,
  46       chargePointVendor,
  47       ...!Utils.isUndefined(chargeBoxSerialNumber) && { chargeBoxSerialNumber },
  48       ...!Utils.isUndefined(chargePointSerialNumber) && { chargePointSerialNumber },
  49       ...!Utils.isUndefined(firmwareVersion) && { firmwareVersion },
  50       ...!Utils.isUndefined(iccid) && { iccid },
  51       ...!Utils.isUndefined(imsi) && { imsi },
  52       ...!Utils.isUndefined(meterSerialNumber) && { meterSerialNumber },
  53       ...!Utils.isUndefined(meterType) && { meterType }
  54     };
  55     return await this.sendMessage(Utils.generateUUID(), payload, OCPP16RequestCommand.BOOT_NOTIFICATION,
  56       { ...params, skipBufferingOnError: true }) as OCPP16BootNotificationResponse;
  57   }
  58
  59   public async sendStatusNotification(connectorId: number, status: OCPP16ChargePointStatus,
  60       errorCode: OCPP16ChargePointErrorCode = OCPP16ChargePointErrorCode.NO_ERROR): Promise<void> {
  61     const payload: StatusNotificationRequest = {
  62       connectorId,
  63       errorCode,
  64       status,
  65     };
  66     await this.sendMessage(Utils.generateUUID(), payload, OCPP16RequestCommand.STATUS_NOTIFICATION);
  67   }
  68
  69   public async sendAuthorize(connectorId: number, idTag?: string): Promise<OCPP16AuthorizeResponse> {
  70     const payload: AuthorizeRequest = {
  71       ...!Utils.isUndefined(idTag) ? { idTag } : { idTag: Constants.TRANSACTION_DEFAULT_IDTAG },
  72     };
  73     this.chargingStation.getConnectorStatus(connectorId).authorizeIdTag = idTag;
  74     return await this.sendMessage(Utils.generateUUID(), payload, OCPP16RequestCommand.AUTHORIZE) as OCPP16AuthorizeResponse;
  75   }
  76
  77   public async sendStartTransaction(connectorId: number, idTag?: string): Promise<OCPP16StartTransactionResponse> {
  78     const payload: StartTransactionRequest = {
  79       connectorId,
  80       ...!Utils.isUndefined(idTag) ? { idTag } : { idTag: Constants.TRANSACTION_DEFAULT_IDTAG },
  81       meterStart: this.chargingStation.getEnergyActiveImportRegisterByConnectorId(connectorId),
  82       timestamp: new Date().toISOString(),
  83     };
  84     return await this.sendMessage(Utils.generateUUID(), payload, OCPP16RequestCommand.START_TRANSACTION) as OCPP16StartTransactionResponse;
  85   }
  86
  87   public async sendStopTransaction(transactionId: number, meterStop: number, idTag?: string,
  88       reason: OCPP16StopTransactionReason = OCPP16StopTransactionReason.NONE): Promise<OCPP16StopTransactionResponse> {
  89     let connectorId: number;
  90     for (const id of this.chargingStation.connectors.keys()) {
  91       if (id > 0 && this.chargingStation.getConnectorStatus(id)?.transactionId === transactionId) {
  92         connectorId = id;
  93         break;
  94       }
  95     }
  96     const transactionEndMeterValue = OCPP16ServiceUtils.buildTransactionEndMeterValue(this.chargingStation, connectorId, meterStop);
  97     // FIXME: should be a callback, each OCPP commands implementation must do only one job
  98     (this.chargingStation.getBeginEndMeterValues() && this.chargingStation.getOcppStrictCompliance() && !this.chargingStation.getOutOfOrderEndMeterValues())
  99         && await this.sendTransactionEndMeterValues(connectorId, transactionId, transactionEndMeterValue);
 100     const payload: StopTransactionRequest = {
 101       transactionId,
 102       ...!Utils.isUndefined(idTag) && { idTag },
 103       meterStop,
 104       timestamp: new Date().toISOString(),
 105       ...reason && { reason },
 106       ...this.chargingStation.getTransactionDataMeterValues() && { transactionData: OCPP16ServiceUtils.buildTransactionDataMeterValues(this.chargingStation.getConnectorStatus(connectorId).transactionBeginMeterValue, transactionEndMeterValue) },
 107     };
 108     return await this.sendMessage(Utils.generateUUID(), payload, OCPP16RequestCommand.STOP_TRANSACTION) as OCPP16StartTransactionResponse;
 109   }
 110
 111   public async sendMeterValues(connectorId: number, transactionId: number, interval: number, debug = false): Promise<void> {
 112     const meterValue: OCPP16MeterValue = {
 113       timestamp: new Date().toISOString(),
 114       sampledValue: [],
 115     };
 116     const connector = this.chargingStation.getConnectorStatus(connectorId);
 117     // SoC measurand
 118     const socSampledValueTemplate = this.chargingStation.getSampledValueTemplate(connectorId, OCPP16MeterValueMeasurand.STATE_OF_CHARGE);
 119     if (socSampledValueTemplate) {
 120       const socSampledValueTemplateValue = socSampledValueTemplate.value
 121         ? Utils.getRandomFloatFluctuatedRounded(parseInt(socSampledValueTemplate.value), socSampledValueTemplate.fluctuationPercent ?? Constants.DEFAULT_FLUCTUATION_PERCENT)
 122         : Utils.getRandomInteger(100);
 123       meterValue.sampledValue.push(OCPP16ServiceUtils.buildSampledValue(socSampledValueTemplate, socSampledValueTemplateValue));
 124       const sampledValuesIndex = meterValue.sampledValue.length - 1;
 125       if (Utils.convertToInt(meterValue.sampledValue[sampledValuesIndex].value) > 100 || debug) {
 126         logger.error(`${this.chargingStation.logPrefix()} MeterValues measurand ${meterValue.sampledValue[sampledValuesIndex].measurand ?? OCPP16MeterValueMeasurand.ENERGY_ACTIVE_IMPORT_REGISTER}: connectorId ${connectorId}, transaction ${connector.transactionId}, value: ${meterValue.sampledValue[sampledValuesIndex].value}/100`);
 127       }
 128     }
 129     // Voltage measurand
 130     const voltageSampledValueTemplate = this.chargingStation.getSampledValueTemplate(connectorId, OCPP16MeterValueMeasurand.VOLTAGE);
 131     if (voltageSampledValueTemplate) {
 132       const voltageSampledValueTemplateValue = voltageSampledValueTemplate.value ? parseInt(voltageSampledValueTemplate.value) : this.chargingStation.getVoltageOut();
 133       const fluctuationPercent = voltageSampledValueTemplate.fluctuationPercent ?? Constants.DEFAULT_FLUCTUATION_PERCENT;
 134       const voltageMeasurandValue = Utils.getRandomFloatFluctuatedRounded(voltageSampledValueTemplateValue, fluctuationPercent);
 135       if (this.chargingStation.getNumberOfPhases() !== 3 || (this.chargingStation.getNumberOfPhases() === 3 && this.chargingStation.getMainVoltageMeterValues())) {
 136         meterValue.sampledValue.push(OCPP16ServiceUtils.buildSampledValue(voltageSampledValueTemplate, voltageMeasurandValue));
 137       }
 138       for (let phase = 1; this.chargingStation.getNumberOfPhases() === 3 && phase <= this.chargingStation.getNumberOfPhases(); phase++) {
 139         const phaseLineToNeutralValue = `L${phase}-N`;
 140         const voltagePhaseLineToNeutralSampledValueTemplate = this.chargingStation.getSampledValueTemplate(connectorId, OCPP16MeterValueMeasurand.VOLTAGE,
 141           phaseLineToNeutralValue as OCPP16MeterValuePhase);
 142         let voltagePhaseLineToNeutralMeasurandValue: number;
 143         if (voltagePhaseLineToNeutralSampledValueTemplate) {
 144           const voltagePhaseLineToNeutralSampledValueTemplateValue = voltagePhaseLineToNeutralSampledValueTemplate.value ? parseInt(voltagePhaseLineToNeutralSampledValueTemplate.value) : this.chargingStation.getVoltageOut();
 145           const fluctuationPhaseToNeutralPercent = voltagePhaseLineToNeutralSampledValueTemplate.fluctuationPercent ?? Constants.DEFAULT_FLUCTUATION_PERCENT;
 146           voltagePhaseLineToNeutralMeasurandValue = Utils.getRandomFloatFluctuatedRounded(voltagePhaseLineToNeutralSampledValueTemplateValue, fluctuationPhaseToNeutralPercent);
 147         }
 148         meterValue.sampledValue.push(OCPP16ServiceUtils.buildSampledValue(voltagePhaseLineToNeutralSampledValueTemplate ?? voltageSampledValueTemplate,
 149           voltagePhaseLineToNeutralMeasurandValue ?? voltageMeasurandValue, null, phaseLineToNeutralValue as OCPP16MeterValuePhase));
 150         if (this.chargingStation.getPhaseLineToLineVoltageMeterValues()) {
 151           const phaseLineToLineValue = `L${phase}-L${(phase + 1) % this.chargingStation.getNumberOfPhases() !== 0 ? (phase + 1) % this.chargingStation.getNumberOfPhases() : this.chargingStation.getNumberOfPhases()}`;
 152           const voltagePhaseLineToLineSampledValueTemplate = this.chargingStation.getSampledValueTemplate(connectorId, OCPP16MeterValueMeasurand.VOLTAGE, phaseLineToLineValue as OCPP16MeterValuePhase);
 153           let voltagePhaseLineToLineMeasurandValue: number;
 154           if (voltagePhaseLineToLineSampledValueTemplate) {
 155             const voltagePhaseLineToLineSampledValueTemplateValue = voltagePhaseLineToLineSampledValueTemplate.value ? parseInt(voltagePhaseLineToLineSampledValueTemplate.value) : Voltage.VOLTAGE_400;
 156             const fluctuationPhaseLineToLinePercent = voltagePhaseLineToLineSampledValueTemplate.fluctuationPercent ?? Constants.DEFAULT_FLUCTUATION_PERCENT;
 157             voltagePhaseLineToLineMeasurandValue = Utils.getRandomFloatFluctuatedRounded(voltagePhaseLineToLineSampledValueTemplateValue, fluctuationPhaseLineToLinePercent);
 158           }
 159           const defaultVoltagePhaseLineToLineMeasurandValue = Utils.getRandomFloatFluctuatedRounded(Voltage.VOLTAGE_400, fluctuationPercent);
 160           meterValue.sampledValue.push(OCPP16ServiceUtils.buildSampledValue(voltagePhaseLineToLineSampledValueTemplate ?? voltageSampledValueTemplate,
 161             voltagePhaseLineToLineMeasurandValue ?? defaultVoltagePhaseLineToLineMeasurandValue, null, phaseLineToLineValue as OCPP16MeterValuePhase));
 162         }
 163       }
 164     }
 165     // Power.Active.Import measurand
 166     const powerSampledValueTemplate = this.chargingStation.getSampledValueTemplate(connectorId, OCPP16MeterValueMeasurand.POWER_ACTIVE_IMPORT);
 167     let powerPerPhaseSampledValueTemplates: MeasurandPerPhaseSampledValueTemplates = {};
 168     if (this.chargingStation.getNumberOfPhases() === 3) {
 169       powerPerPhaseSampledValueTemplates = {
 170         L1: this.chargingStation.getSampledValueTemplate(connectorId, OCPP16MeterValueMeasurand.POWER_ACTIVE_IMPORT, OCPP16MeterValuePhase.L1_N),
 171         L2: this.chargingStation.getSampledValueTemplate(connectorId, OCPP16MeterValueMeasurand.POWER_ACTIVE_IMPORT, OCPP16MeterValuePhase.L2_N),
 172         L3: this.chargingStation.getSampledValueTemplate(connectorId, OCPP16MeterValueMeasurand.POWER_ACTIVE_IMPORT, OCPP16MeterValuePhase.L3_N),
 173       };
 174     }
 175     if (powerSampledValueTemplate) {
 176       OCPP16ServiceUtils.checkMeasurandPowerDivider(this.chargingStation, powerSampledValueTemplate.measurand);
 177       const errMsg = `${this.chargingStation.logPrefix()} MeterValues measurand ${powerSampledValueTemplate.measurand ?? OCPP16MeterValueMeasurand.ENERGY_ACTIVE_IMPORT_REGISTER}: Unknown ${this.chargingStation.getCurrentOutType()} currentOutType in template file ${this.chargingStation.stationTemplateFile}, cannot calculate ${powerSampledValueTemplate.measurand ?? OCPP16MeterValueMeasurand.ENERGY_ACTIVE_IMPORT_REGISTER} measurand value`;
 178       const powerMeasurandValues = {} as MeasurandValues;
 179       const unitDivider = powerSampledValueTemplate?.unit === MeterValueUnit.KILO_WATT ? 1000 : 1;
 180       const maxPower = Math.round(this.chargingStation.stationInfo.maxPower / this.chargingStation.stationInfo.powerDivider);
 181       const maxPowerPerPhase = Math.round((this.chargingStation.stationInfo.maxPower / this.chargingStation.stationInfo.powerDivider) / this.chargingStation.getNumberOfPhases());
 182       switch (this.chargingStation.getCurrentOutType()) {
 183         case CurrentType.AC:
 184           if (this.chargingStation.getNumberOfPhases() === 3) {
 185             const defaultFluctuatedPowerPerPhase = powerSampledValueTemplate.value
 186                 && Utils.getRandomFloatFluctuatedRounded(parseInt(powerSampledValueTemplate.value) / this.chargingStation.getNumberOfPhases(), powerSampledValueTemplate.fluctuationPercent ?? Constants.DEFAULT_FLUCTUATION_PERCENT);
 187             const phase1FluctuatedValue = powerPerPhaseSampledValueTemplates?.L1?.value
 188                 && Utils.getRandomFloatFluctuatedRounded(parseInt(powerPerPhaseSampledValueTemplates.L1.value), powerPerPhaseSampledValueTemplates.L1.fluctuationPercent ?? Constants.DEFAULT_FLUCTUATION_PERCENT);
 189             const phase2FluctuatedValue = powerPerPhaseSampledValueTemplates?.L2?.value
 190                 && Utils.getRandomFloatFluctuatedRounded(parseInt(powerPerPhaseSampledValueTemplates.L2.value), powerPerPhaseSampledValueTemplates.L2.fluctuationPercent ?? Constants.DEFAULT_FLUCTUATION_PERCENT);
 191             const phase3FluctuatedValue = powerPerPhaseSampledValueTemplates?.L3?.value
 192                 && Utils.getRandomFloatFluctuatedRounded(parseInt(powerPerPhaseSampledValueTemplates.L3.value), powerPerPhaseSampledValueTemplates.L3.fluctuationPercent ?? Constants.DEFAULT_FLUCTUATION_PERCENT);
 193             powerMeasurandValues.L1 = (phase1FluctuatedValue ?? defaultFluctuatedPowerPerPhase) ?? Utils.getRandomFloatRounded(maxPowerPerPhase / unitDivider);
 194             powerMeasurandValues.L2 = (phase2FluctuatedValue ?? defaultFluctuatedPowerPerPhase) ?? Utils.getRandomFloatRounded(maxPowerPerPhase / unitDivider);
 195             powerMeasurandValues.L3 = (phase3FluctuatedValue ?? defaultFluctuatedPowerPerPhase) ?? Utils.getRandomFloatRounded(maxPowerPerPhase / unitDivider);
 196           } else {
 197             powerMeasurandValues.L1 = powerSampledValueTemplate.value
 198               ? Utils.getRandomFloatFluctuatedRounded(parseInt(powerSampledValueTemplate.value), powerSampledValueTemplate.fluctuationPercent ?? Constants.DEFAULT_FLUCTUATION_PERCENT)
 199               : Utils.getRandomFloatRounded(maxPower / unitDivider);
 200             powerMeasurandValues.L2 = 0;
 201             powerMeasurandValues.L3 = 0;
 202           }
 203           powerMeasurandValues.allPhases = Utils.roundTo(powerMeasurandValues.L1 + powerMeasurandValues.L2 + powerMeasurandValues.L3, 2);
 204           break;
 205         case CurrentType.DC:
 206           powerMeasurandValues.allPhases = powerSampledValueTemplate.value
 207             ? Utils.getRandomFloatFluctuatedRounded(parseInt(powerSampledValueTemplate.value), powerSampledValueTemplate.fluctuationPercent ?? Constants.DEFAULT_FLUCTUATION_PERCENT)
 208             : Utils.getRandomFloatRounded(maxPower / unitDivider);
 209           break;
 210         default:
 211           logger.error(errMsg);
 212           throw new OCPPError(ErrorType.INTERNAL_ERROR, errMsg, OCPP16RequestCommand.METER_VALUES);
 213       }
 214       meterValue.sampledValue.push(OCPP16ServiceUtils.buildSampledValue(powerSampledValueTemplate, powerMeasurandValues.allPhases));
 215       const sampledValuesIndex = meterValue.sampledValue.length - 1;
 216       const maxPowerRounded = Utils.roundTo(maxPower / unitDivider, 2);
 217       if (Utils.convertToFloat(meterValue.sampledValue[sampledValuesIndex].value) > maxPowerRounded || debug) {
 218         logger.error(`${this.chargingStation.logPrefix()} MeterValues measurand ${meterValue.sampledValue[sampledValuesIndex].measurand ?? OCPP16MeterValueMeasurand.ENERGY_ACTIVE_IMPORT_REGISTER}: connectorId ${connectorId}, transaction ${connector.transactionId}, value: ${meterValue.sampledValue[sampledValuesIndex].value}/${maxPowerRounded}`);
 219       }
 220       for (let phase = 1; this.chargingStation.getNumberOfPhases() === 3 && phase <= this.chargingStation.getNumberOfPhases(); phase++) {
 221         const phaseValue = `L${phase}-N`;
 222         meterValue.sampledValue.push(OCPP16ServiceUtils.buildSampledValue(powerPerPhaseSampledValueTemplates[`L${phase}`] ?? powerSampledValueTemplate, powerMeasurandValues[`L${phase}`], null,
 223           phaseValue as OCPP16MeterValuePhase));
 224         const sampledValuesPerPhaseIndex = meterValue.sampledValue.length - 1;
 225         const maxPowerPerPhaseRounded = Utils.roundTo(maxPowerPerPhase / unitDivider, 2);
 226         if (Utils.convertToFloat(meterValue.sampledValue[sampledValuesPerPhaseIndex].value) > maxPowerPerPhaseRounded || debug) {
 227           logger.error(`${this.chargingStation.logPrefix()} MeterValues measurand ${meterValue.sampledValue[sampledValuesPerPhaseIndex].measurand ?? OCPP16MeterValueMeasurand.ENERGY_ACTIVE_IMPORT_REGISTER}: phase ${meterValue.sampledValue[sampledValuesPerPhaseIndex].phase}, connectorId ${connectorId}, transaction ${connector.transactionId}, value: ${meterValue.sampledValue[sampledValuesPerPhaseIndex].value}/${maxPowerPerPhaseRounded}`);
 228         }
 229       }
 230     }
 231     // Current.Import measurand
 232     const currentSampledValueTemplate = this.chargingStation.getSampledValueTemplate(connectorId, OCPP16MeterValueMeasurand.CURRENT_IMPORT);
 233     let currentPerPhaseSampledValueTemplates: MeasurandPerPhaseSampledValueTemplates = {};
 234     if (this.chargingStation.getNumberOfPhases() === 3) {
 235       currentPerPhaseSampledValueTemplates = {
 236         L1: this.chargingStation.getSampledValueTemplate(connectorId, OCPP16MeterValueMeasurand.CURRENT_IMPORT, OCPP16MeterValuePhase.L1),
 237         L2: this.chargingStation.getSampledValueTemplate(connectorId, OCPP16MeterValueMeasurand.CURRENT_IMPORT, OCPP16MeterValuePhase.L2),
 238         L3: this.chargingStation.getSampledValueTemplate(connectorId, OCPP16MeterValueMeasurand.CURRENT_IMPORT, OCPP16MeterValuePhase.L3),
 239       };
 240     }
 241     if (currentSampledValueTemplate) {
 242       OCPP16ServiceUtils.checkMeasurandPowerDivider(this.chargingStation, currentSampledValueTemplate.measurand);
 243       const errMsg = `${this.chargingStation.logPrefix()} MeterValues measurand ${currentSampledValueTemplate.measurand ?? OCPP16MeterValueMeasurand.ENERGY_ACTIVE_IMPORT_REGISTER}: Unknown ${this.chargingStation.getCurrentOutType()} currentOutType in template file ${this.chargingStation.stationTemplateFile}, cannot calculate ${currentSampledValueTemplate.measurand ?? OCPP16MeterValueMeasurand.ENERGY_ACTIVE_IMPORT_REGISTER} measurand value`;
 244       const currentMeasurandValues: MeasurandValues = {} as MeasurandValues;
 245       let maxAmperage: number;
 246       switch (this.chargingStation.getCurrentOutType()) {
 247         case CurrentType.AC:
 248           maxAmperage = ACElectricUtils.amperagePerPhaseFromPower(this.chargingStation.getNumberOfPhases(), this.chargingStation.stationInfo.maxPower / this.chargingStation.stationInfo.powerDivider, this.chargingStation.getVoltageOut());
 249           if (this.chargingStation.getNumberOfPhases() === 3) {
 250             const defaultFluctuatedAmperagePerPhase = currentSampledValueTemplate.value
 251                 && Utils.getRandomFloatFluctuatedRounded(parseInt(currentSampledValueTemplate.value), currentSampledValueTemplate.fluctuationPercent ?? Constants.DEFAULT_FLUCTUATION_PERCENT);
 252             const phase1FluctuatedValue = currentPerPhaseSampledValueTemplates?.L1?.value
 253                 && Utils.getRandomFloatFluctuatedRounded(parseInt(currentPerPhaseSampledValueTemplates.L1.value), currentPerPhaseSampledValueTemplates.L1.fluctuationPercent ?? Constants.DEFAULT_FLUCTUATION_PERCENT);
 254             const phase2FluctuatedValue = currentPerPhaseSampledValueTemplates?.L2?.value
 255                 && Utils.getRandomFloatFluctuatedRounded(parseInt(currentPerPhaseSampledValueTemplates.L2.value), currentPerPhaseSampledValueTemplates.L2.fluctuationPercent ?? Constants.DEFAULT_FLUCTUATION_PERCENT);
 256             const phase3FluctuatedValue = currentPerPhaseSampledValueTemplates?.L3?.value
 257                 && Utils.getRandomFloatFluctuatedRounded(parseInt(currentPerPhaseSampledValueTemplates.L3.value), currentPerPhaseSampledValueTemplates.L3.fluctuationPercent ?? Constants.DEFAULT_FLUCTUATION_PERCENT);
 258             currentMeasurandValues.L1 = (phase1FluctuatedValue ?? defaultFluctuatedAmperagePerPhase) ?? Utils.getRandomFloatRounded(maxAmperage);
 259             currentMeasurandValues.L2 = (phase2FluctuatedValue ?? defaultFluctuatedAmperagePerPhase) ?? Utils.getRandomFloatRounded(maxAmperage);
 260             currentMeasurandValues.L3 = (phase3FluctuatedValue ?? defaultFluctuatedAmperagePerPhase) ?? Utils.getRandomFloatRounded(maxAmperage);
 261           } else {
 262             currentMeasurandValues.L1 = currentSampledValueTemplate.value
 263               ? Utils.getRandomFloatFluctuatedRounded(parseInt(currentSampledValueTemplate.value), currentSampledValueTemplate.fluctuationPercent ?? Constants.DEFAULT_FLUCTUATION_PERCENT)
 264               : Utils.getRandomFloatRounded(maxAmperage);
 265             currentMeasurandValues.L2 = 0;
 266             currentMeasurandValues.L3 = 0;
 267           }
 268           currentMeasurandValues.allPhases = Utils.roundTo((currentMeasurandValues.L1 + currentMeasurandValues.L2 + currentMeasurandValues.L3) / this.chargingStation.getNumberOfPhases(), 2);
 269           break;
 270         case CurrentType.DC:
 271           maxAmperage = DCElectricUtils.amperage(this.chargingStation.stationInfo.maxPower / this.chargingStation.stationInfo.powerDivider, this.chargingStation.getVoltageOut());
 272           currentMeasurandValues.allPhases = currentSampledValueTemplate.value
 273             ? Utils.getRandomFloatFluctuatedRounded(parseInt(currentSampledValueTemplate.value), currentSampledValueTemplate.fluctuationPercent ?? Constants.DEFAULT_FLUCTUATION_PERCENT)
 274             : Utils.getRandomFloatRounded(maxAmperage);
 275           break;
 276         default:
 277           logger.error(errMsg);
 278           throw new OCPPError(ErrorType.INTERNAL_ERROR, errMsg, OCPP16RequestCommand.METER_VALUES);
 279       }
 280       meterValue.sampledValue.push(OCPP16ServiceUtils.buildSampledValue(currentSampledValueTemplate, currentMeasurandValues.allPhases));
 281       const sampledValuesIndex = meterValue.sampledValue.length - 1;
 282       if (Utils.convertToFloat(meterValue.sampledValue[sampledValuesIndex].value) > maxAmperage || debug) {
 283         logger.error(`${this.chargingStation.logPrefix()} MeterValues measurand ${meterValue.sampledValue[sampledValuesIndex].measurand ?? OCPP16MeterValueMeasurand.ENERGY_ACTIVE_IMPORT_REGISTER}: connectorId ${connectorId}, transaction ${connector.transactionId}, value: ${meterValue.sampledValue[sampledValuesIndex].value}/${maxAmperage}`);
 284       }
 285       for (let phase = 1; this.chargingStation.getNumberOfPhases() === 3 && phase <= this.chargingStation.getNumberOfPhases(); phase++) {
 286         const phaseValue = `L${phase}`;
 287         meterValue.sampledValue.push(OCPP16ServiceUtils.buildSampledValue(currentPerPhaseSampledValueTemplates[phaseValue] ?? currentSampledValueTemplate,
 288           currentMeasurandValues[phaseValue], null, phaseValue as OCPP16MeterValuePhase));
 289         const sampledValuesPerPhaseIndex = meterValue.sampledValue.length - 1;
 290         if (Utils.convertToFloat(meterValue.sampledValue[sampledValuesPerPhaseIndex].value) > maxAmperage || debug) {
 291           logger.error(`${this.chargingStation.logPrefix()} MeterValues measurand ${meterValue.sampledValue[sampledValuesPerPhaseIndex].measurand ?? OCPP16MeterValueMeasurand.ENERGY_ACTIVE_IMPORT_REGISTER}: phase ${meterValue.sampledValue[sampledValuesPerPhaseIndex].phase}, connectorId ${connectorId}, transaction ${connector.transactionId}, value: ${meterValue.sampledValue[sampledValuesPerPhaseIndex].value}/${maxAmperage}`);
 292         }
 293       }
 294     }
 295     // Energy.Active.Import.Register measurand (default)
 296     const energySampledValueTemplate = this.chargingStation.getSampledValueTemplate(connectorId);
 297     if (energySampledValueTemplate) {
 298       OCPP16ServiceUtils.checkMeasurandPowerDivider(this.chargingStation, energySampledValueTemplate.measurand);
 299       const unitDivider = energySampledValueTemplate?.unit === MeterValueUnit.KILO_WATT_HOUR ? 1000 : 1;
 300       const maxEnergyRounded = Utils.roundTo(((this.chargingStation.stationInfo.maxPower / this.chargingStation.stationInfo.powerDivider) * interval) / (3600 * 1000), 2);
 301       const energyValueRounded = energySampledValueTemplate.value
 302       // Cumulate the fluctuated value around the static one
 303         ? Utils.getRandomFloatFluctuatedRounded(parseInt(energySampledValueTemplate.value), energySampledValueTemplate.fluctuationPercent ?? Constants.DEFAULT_FLUCTUATION_PERCENT)
 304         : Utils.getRandomFloatRounded(maxEnergyRounded);
 305         // Persist previous value on connector
 306       if (connector && !Utils.isNullOrUndefined(connector.energyActiveImportRegisterValue) && connector.energyActiveImportRegisterValue >= 0 &&
 307           !Utils.isNullOrUndefined(connector.transactionEnergyActiveImportRegisterValue) && connector.transactionEnergyActiveImportRegisterValue >= 0) {
 308         connector.energyActiveImportRegisterValue += energyValueRounded;
 309         connector.transactionEnergyActiveImportRegisterValue += energyValueRounded;
 310       } else {
 311         connector.energyActiveImportRegisterValue = 0;
 312         connector.transactionEnergyActiveImportRegisterValue = 0;
 313       }
 314       meterValue.sampledValue.push(OCPP16ServiceUtils.buildSampledValue(energySampledValueTemplate,
 315         Utils.roundTo(this.chargingStation.getEnergyActiveImportRegisterByTransactionId(transactionId) / unitDivider, 2)));
 316       const sampledValuesIndex = meterValue.sampledValue.length - 1;
 317       if (energyValueRounded > maxEnergyRounded || debug) {
 318         logger.error(`${this.chargingStation.logPrefix()} MeterValues measurand ${meterValue.sampledValue[sampledValuesIndex].measurand ?? OCPP16MeterValueMeasurand.ENERGY_ACTIVE_IMPORT_REGISTER}: connectorId ${connectorId}, transaction ${connector.transactionId}, value: ${energyValueRounded}/${maxEnergyRounded}, duration: ${Utils.roundTo(interval / (3600 * 1000), 4)}h`);
 319       }
 320     }
 321     const payload: MeterValuesRequest = {
 322       connectorId,
 323       transactionId,
 324       meterValue: [meterValue],
 325     };
 326     await this.sendMessage(Utils.generateUUID(), payload, OCPP16RequestCommand.METER_VALUES);
 327   }
 328
 329   public async sendTransactionBeginMeterValues(connectorId: number, transactionId: number, beginMeterValue: OCPP16MeterValue): Promise<void> {
 330     const payload: MeterValuesRequest = {
 331       connectorId,
 332       transactionId,
 333       meterValue: [beginMeterValue],
 334     };
 335     await this.sendMessage(Utils.generateUUID(), payload, OCPP16RequestCommand.METER_VALUES);
 336   }
 337
 338   public async sendTransactionEndMeterValues(connectorId: number, transactionId: number, endMeterValue: OCPP16MeterValue): Promise<void> {
 339     const payload: MeterValuesRequest = {
 340       connectorId,
 341       transactionId,
 342       meterValue: [endMeterValue],
 343     };
 344     await this.sendMessage(Utils.generateUUID(), payload, OCPP16RequestCommand.METER_VALUES);
 345   }
 346
 347   public async sendDiagnosticsStatusNotification(diagnosticsStatus: OCPP16DiagnosticsStatus): Promise<void> {
 348     const payload: DiagnosticsStatusNotificationRequest = {
 349       status: diagnosticsStatus
 350     };
 351     await this.sendMessage(Utils.generateUUID(), payload, OCPP16RequestCommand.DIAGNOSTICS_STATUS_NOTIFICATION);
 352   }
 353 }