mirror of
https://github.com/UtilitechAS/amsreader-firmware.git
synced 2026-01-19 17:48:30 +00:00
c648546b61
* 15min prices WIP * WIP more changes for 15min prices * More work on 15min pricing * Fixed some errors * Some changes after testing * Graphical changes for 15min pricing * Adjustments on MQTT handlers after switching to 15min prices * Reverted some MQTT changes * Adapted HA integration for 15min pricing * Adapted JSON payload for 15min * Adjustments during testing * Set default price interval * Fixed refresh of price graph when data changes * Bugfixes * Fixed some issues with raw payload * Adjustments for meter timestamp from Kamstrup * Updated readme * Added detailed breakdown of payloads coming from Norwegian meters * Minor changes relating to price * Fixed byte alignment on price config * Changes to support RC upgraders
146 lines
3.6 KiB
C++
146 lines
3.6 KiB
C++
/**
|
|
* @copyright Utilitech AS 2023
|
|
* License: Fair Source
|
|
*
|
|
*/
|
|
|
|
#ifndef _PRICESERVICE_H
|
|
#define _PRICESERVICE_H
|
|
|
|
#include <vector>
|
|
|
|
#include "TimeLib.h"
|
|
#include "Timezone.h"
|
|
#if defined(AMS_REMOTE_DEBUG)
|
|
#include "RemoteDebug.h"
|
|
#endif
|
|
#include "AmsConfiguration.h"
|
|
#include "EntsoeA44Parser.h"
|
|
|
|
#if defined(ESP8266)
|
|
#include <ESP8266HTTPClient.h>
|
|
#elif defined(ESP32) // ARDUINO_ARCH_ESP32
|
|
#include <HTTPClient.h>
|
|
#else
|
|
#warning "Unsupported board type"
|
|
#endif
|
|
|
|
#define SSL_BUF_SIZE 512
|
|
|
|
#define PRICE_DAY_MO 0x01
|
|
#define PRICE_DAY_TU 0x02
|
|
#define PRICE_DAY_WE 0x04
|
|
#define PRICE_DAY_TH 0x08
|
|
#define PRICE_DAY_FR 0x10
|
|
#define PRICE_DAY_SA 0x12
|
|
#define PRICE_DAY_SU 0x14
|
|
|
|
#define PRICE_TYPE_FIXED 0x00
|
|
#define PRICE_TYPE_ADD 0x01
|
|
#define PRICE_TYPE_PCT 0x02
|
|
#define PRICE_TYPE_SUBTRACT 0x03
|
|
|
|
struct PriceConfig {
|
|
char name[32];
|
|
uint8_t direction;
|
|
uint8_t days;
|
|
uint32_t hours;
|
|
uint8_t type;
|
|
uint32_t value;
|
|
uint8_t start_month;
|
|
uint8_t start_dayofmonth;
|
|
uint8_t end_month;
|
|
uint8_t end_dayofmonth;
|
|
};
|
|
|
|
struct AmsPriceV2Header {
|
|
char currency[4];
|
|
char measurementUnit[4];
|
|
char source[4];
|
|
uint8_t resolutionInMinutes;
|
|
bool differentExportPrices;
|
|
uint8_t numberOfPoints;
|
|
};
|
|
|
|
class PriceService {
|
|
public:
|
|
#if defined(AMS_REMOTE_DEBUG)
|
|
PriceService(RemoteDebug*);
|
|
#else
|
|
PriceService(Stream*);
|
|
#endif
|
|
void setup(PriceServiceConfig&);
|
|
void setTimezone(Timezone* tz);
|
|
bool loop();
|
|
|
|
char* getToken();
|
|
char* getCurrency();
|
|
char* getArea();
|
|
char* getSource();
|
|
|
|
uint8_t getResolutionInMinutes();
|
|
uint8_t getNumberOfPointsAvailable();
|
|
uint8_t getCurrentPricePointIndex();
|
|
|
|
bool isExportPricesDifferentFromImport();
|
|
|
|
bool hasPrice() { return hasPrice(PRICE_DIRECTION_IMPORT); }
|
|
bool hasPrice(uint8_t direction) { return getCurrentPrice(direction) != PRICE_NO_VALUE; }
|
|
bool hasPricePoint(uint8_t direction, int8_t point) { return getPricePoint(direction, point) != PRICE_NO_VALUE; }
|
|
|
|
float getCurrentPrice(uint8_t direction);
|
|
float getPricePoint(uint8_t direction, uint8_t point);
|
|
float getPriceForRelativeHour(uint8_t direction, int8_t hour); // If not 60min interval, average
|
|
|
|
std::vector<PriceConfig>& getPriceConfig();
|
|
void setPriceConfig(uint8_t index, PriceConfig &priceConfig);
|
|
void cropPriceConfig(uint8_t size);
|
|
|
|
int16_t getLastError();
|
|
|
|
bool load();
|
|
bool save();
|
|
|
|
private:
|
|
#if defined(AMS_REMOTE_DEBUG)
|
|
RemoteDebug* debugger;
|
|
#else
|
|
Stream* debugger;
|
|
#endif
|
|
PriceServiceConfig* config = NULL;
|
|
HTTPClient* http = NULL;
|
|
|
|
uint8_t currentDay = 0, currentPricePoint = 0;
|
|
uint8_t tomorrowFetchMinute = 15; // How many minutes over 13:00 should it fetch prices
|
|
uint8_t nextFetchDelayMinutes = 15;
|
|
uint64_t lastTodayFetch = 0;
|
|
uint64_t lastTomorrowFetch = 0;
|
|
uint64_t lastCurrencyFetch = 0;
|
|
PricesContainer* today = NULL;
|
|
PricesContainer* tomorrow = NULL;
|
|
|
|
std::vector<PriceConfig> priceConfig;
|
|
|
|
Timezone* tz = NULL;
|
|
Timezone* entsoeTz = NULL;
|
|
|
|
static const uint16_t BufferSize = 256;
|
|
char* buf;
|
|
|
|
bool hub = false;
|
|
uint8_t* key = NULL;
|
|
uint8_t* auth = NULL;
|
|
|
|
float currencyMultiplier = 0;
|
|
|
|
int16_t lastError = 0;
|
|
|
|
PricesContainer* fetchPrices(time_t);
|
|
bool retrieve(const char* url, Stream* doc);
|
|
float getCurrencyMultiplier(const char* from, const char* to, time_t t);
|
|
bool timeIsInPeriod(tmElements_t tm, PriceConfig pc);
|
|
float getFixedPrice(uint8_t direction, int8_t hour);
|
|
float getEnergyPricePoint(uint8_t direction, uint8_t point);
|
|
};
|
|
#endif
|