|
61 | 61 | #define IDX_WALLBOX_LAST_ENERGY_SOLAR 18 |
62 | 62 | #define IDX_PM_POWER 100 |
63 | 63 | #define IDX_PM_ENERGY 200 |
| 64 | +#define IDX_PVI_ENERGY 300 |
| 65 | +#define IDX_PVI_ENERGY_START 400 |
64 | 66 |
|
65 | 67 | namespace RSCP_MQTT { |
66 | 68 |
|
@@ -112,6 +114,13 @@ typedef struct _date_t { |
112 | 114 | std::queue<date_t> requestQ; |
113 | 115 | std::queue<date_t> paramQ; |
114 | 116 |
|
| 117 | +typedef struct _mqtt_data_t { |
| 118 | + char *topic; |
| 119 | + char *payload; |
| 120 | +} mqtt_data_t; |
| 121 | + |
| 122 | +std::queue<mqtt_data_t> mqttQ; |
| 123 | + |
115 | 124 | typedef struct _cache_t { |
116 | 125 | uint32_t container; |
117 | 126 | uint32_t tag; |
@@ -399,6 +408,8 @@ cache_t templates[] = { |
399 | 408 | { TAG_PVI_DC_VOLTAGE, TAG_PVI_VALUE, 1, "pvi/voltage/string_%d", "", F_FLOAT_0, UNIT_V, 1, 0, false, false, false }, |
400 | 409 | { TAG_PVI_DC_CURRENT, TAG_PVI_VALUE, 1, "pvi/current/string_%d", "", F_FLOAT_2, UNIT_A, 1, 0, false, false, false }, |
401 | 410 | { TAG_PVI_DC_STRING_ENERGY_ALL, TAG_PVI_VALUE, 1, "pvi/energy_all/string_%d", "", F_FLOAT_0, UNIT_WH, 1, 0, false, false, false }, |
| 411 | + { 0, 0, IDX_PVI_ENERGY, "pvi/energy/string_%d", "", F_AUTO, UNIT_WH, 1, 0, false, false, false }, |
| 412 | + { 0, 0, IDX_PVI_ENERGY_START, "pvi/energy_start/string_%d", "", F_AUTO, UNIT_WH, 1, 0, false, false, false }, |
402 | 413 | // PM |
403 | 414 | { 0, 0, IDX_PM_POWER, "%s/power", "", F_FLOAT_0, UNIT_W, 1, 0, false, false, false }, |
404 | 415 | { 0, 0, IDX_PM_ENERGY, "%s/energy", "", F_FLOAT_2, UNIT_KWH, 1, 0, false, false, false }, |
|
0 commit comments