-
- async sendStartTransaction(connectorID, idTag) {
- try {
- const payload = {
- connectorId: connectorID,
- idTag,
- meterStart: 0,
- timestamp: new Date().toISOString(),
- };
- return await this.sendMessage(Utils.generateUUID(), payload, Constants.OCPP_JSON_CALL_MESSAGE, 'StartTransaction');
- } catch (error) {
- logger.error(this._basicFormatLog() + ' Send start transaction error: ' + error);
- throw error;
- }
- }
- async sendStartTransactionWithTimeout(connectorID, idTag, timeout) {
- setTimeout(() => this.sendStartTransaction(connectorID, idTag), timeout);
- }
-
- async sendStopTransaction(transactionId) {
- try {
- const payload = {
- transactionId,
- meterStop: 0,
- timestamp: new Date().toISOString(),
- };
- await this.sendMessage(Utils.generateUUID(), payload, Constants.OCPP_JSON_CALL_MESSAGE, 'StopTransaction');
- } catch (error) {
- logger.error(this._basicFormatLog() + ' Send stop transaction error: ' + error);
- throw error;
- }
- }
-
- // eslint-disable-next-line class-methods-use-this
- async sendMeterValues(connectorID, interval, self, debug = false) {
- try {
- const sampledValueLcl = {
- timestamp: new Date().toISOString(),
- };
- const meterValuesClone = Utils.cloneJSonDocument(self._getConnector(connectorID).MeterValues);
- if (Array.isArray(meterValuesClone)) {
- sampledValueLcl.sampledValue = meterValuesClone;
- } else {
- sampledValueLcl.sampledValue = [meterValuesClone];
- }
- for (let index = 0; index < sampledValueLcl.sampledValue.length; index++) {
- const connector = self._connectors[connectorID];
- if (sampledValueLcl.sampledValue[index].measurand && sampledValueLcl.sampledValue[index].measurand === 'SoC') {
- sampledValueLcl.sampledValue[index].value = Utils.getRandomInt(100);
- if (sampledValueLcl.sampledValue[index].value > 100 || debug) {
- logger.error(`${self._basicFormatLog()} MeterValues measurand ${sampledValueLcl.sampledValue[index].measurand ? sampledValueLcl.sampledValue[index].measurand : 'Energy.Active.Import.Register'}: connectorID ${connectorID}, transaction ${connector.transactionId}, value: ${sampledValueLcl.sampledValue[index].value}`);
- }
- } else {
- // Persist previous value in connector
- const consumption = Utils.getRandomInt(self._stationInfo.maxPower / 3600000 * interval);
- if (connector && connector.lastConsumptionValue >= 0) {
- connector.lastConsumptionValue += consumption;
- } else {
- connector.lastConsumptionValue = 0;
- }
- const maxConsumption = self._stationInfo.maxPower * 3600 / interval;
- logger.info(`${self._basicFormatLog()} MeterValues measurand ${sampledValueLcl.sampledValue[index].measurand ? sampledValueLcl.sampledValue[index].measurand : 'Energy.Active.Import.Register'}: connectorID ${connectorID}, transaction ${connector.transactionId}, value ${connector.lastConsumptionValue}`);
- sampledValueLcl.sampledValue[index].value = connector.lastConsumptionValue;
- if (sampledValueLcl.sampledValue[index].value > maxConsumption || debug) {
- logger.error(`${self._basicFormatLog()} MeterValues measurand ${sampledValueLcl.sampledValue[index].measurand ? sampledValueLcl.sampledValue[index].measurand : 'Energy.Active.Import.Register'}: connectorID ${connectorID}, transaction ${connector.transactionId}, value: ${sampledValueLcl.sampledValue[index].value}/${maxConsumption}`);
- }
- }
- }
-
- const payload = {
- connectorId: connectorID,
- transactionId: self._connectors[connectorID].transactionId,
- meterValue: [sampledValueLcl],
- };
- await self.sendMessage(Utils.generateUUID(), payload, Constants.OCPP_JSON_CALL_MESSAGE, 'MeterValues');
- } catch (error) {
- logger.error(self._basicFormatLog() + ' Send MeterValues error: ' + error);
- }
- }
-
- async startMeterValues(connectorID, interval) {
- if (!this._connectors[connectorID].transactionStarted) {
- logger.error(`${this._basicFormatLog()} Trying to start MeterValues on connector ID ${connectorID} with no transaction started`);
- return;
- } else if (this._connectors[connectorID].transactionStarted && !this._connectors[connectorID].transactionId) {
- logger.error(`${this._basicFormatLog()} Trying to start MeterValues on connector ID ${connectorID} with no transaction id`);
- return;
- }
- this._connectors[connectorID].transactionSetInterval = setInterval(async () => {
- const sendMeterValues = performance.timerify(this.sendMeterValues);
- this._performanceObserver.observe({
- entryTypes: ['function'],
- });
- await sendMeterValues(connectorID, interval, this);
- }, interval);
- }
-
- hasAuthorizedTags() {
- return !Utils.isEmptyArray(this._authorizedTags);
- }
-
- getRandomTagId() {
- const index = Math.floor(Math.random() * this._authorizedTags.length);
- return this._authorizedTags[index];
- }
-
- _getConnector(number) {
- return this._stationInfo.Connectors[number];
- }
-
- _getMaxConnectors() {
- let maxConnectors = 0;
- if (Array.isArray(this._stationInfo.numberOfConnectors)) {
- // Generate some connectors
- maxConnectors = this._stationInfo.numberOfConnectors[(this._index - 1) % this._stationInfo.numberOfConnectors.length];
- } else {
- maxConnectors = this._stationInfo.numberOfConnectors;
- }
- return maxConnectors;
- }