integrate meter module with evse
This commit is contained in:
@@ -1,233 +0,0 @@
|
||||
#include <memory.h>
|
||||
#include <math.h>
|
||||
#include <stdbool.h> // <- Necessário para bool
|
||||
#include "freertos/FreeRTOS.h"
|
||||
#include "freertos/semphr.h"
|
||||
#include "esp_log.h"
|
||||
#include "esp_timer.h"
|
||||
#include "nvs.h"
|
||||
|
||||
#include "energy_meter.h"
|
||||
#include "meter.h"
|
||||
#include "serial_mdb.h"
|
||||
|
||||
#define NVS_NAMESPACE "evse_emeter"
|
||||
#define NVS_MODEL "model"
|
||||
#define NVS_STATE "state"
|
||||
|
||||
static const char *TAG = "energy_meter";
|
||||
|
||||
static nvs_handle nvs;
|
||||
|
||||
static bool state = false;
|
||||
static meter_model_t model = ENERGY_METER_NONE;
|
||||
|
||||
static uint16_t power = 0;
|
||||
static bool has_session = false;
|
||||
static int64_t start_time = 0;
|
||||
static uint32_t charging_time = 0; // ms
|
||||
static uint32_t consumption = 0; // Ws
|
||||
static float cur[3] = {0, 0, 0};
|
||||
static float vlt[3] = {0, 0, 0};
|
||||
static int64_t prev_time = 0;
|
||||
|
||||
static void set_calc_power(float p, uint32_t delta_ms)
|
||||
{
|
||||
consumption += roundf((p * delta_ms) / 1000.0f);
|
||||
power = roundf(p);
|
||||
}
|
||||
|
||||
void energy_meter_init(void)
|
||||
{
|
||||
ESP_LOGI(TAG, "energy_meter_init");
|
||||
ESP_ERROR_CHECK(nvs_open(NVS_NAMESPACE, NVS_READWRITE, &nvs));
|
||||
|
||||
uint8_t u8 = ENERGY_METER_NONE;
|
||||
nvs_get_u8(nvs, NVS_MODEL, &u8);
|
||||
model = u8;
|
||||
}
|
||||
|
||||
bool meter_get_state(void)
|
||||
{
|
||||
return serial_mdb_get_meter_state();
|
||||
}
|
||||
|
||||
esp_err_t meter_set_state(bool _state)
|
||||
{
|
||||
state = _state;
|
||||
nvs_set_u8(nvs, NVS_STATE, state);
|
||||
nvs_commit(nvs);
|
||||
return ESP_OK;
|
||||
}
|
||||
|
||||
meter_model_t meter_get_model(void)
|
||||
{
|
||||
return model;
|
||||
}
|
||||
|
||||
esp_err_t meter_set_model(meter_model_t _model)
|
||||
{
|
||||
ESP_LOGI(TAG, "meter_set_model");
|
||||
|
||||
if (_model < 0 || _model > ENERGY_METER_ORNO_517) {
|
||||
ESP_LOGE(TAG, "Model out of range");
|
||||
return ESP_ERR_INVALID_ARG;
|
||||
}
|
||||
|
||||
model = _model;
|
||||
nvs_set_u8(nvs, NVS_MODEL, model);
|
||||
nvs_commit(nvs);
|
||||
serial_mdb_set_model(model != ENERGY_METER_NONE);
|
||||
return ESP_OK;
|
||||
}
|
||||
|
||||
void energy_meter_start_session(void)
|
||||
{
|
||||
if (!has_session) {
|
||||
ESP_LOGI(TAG, "Start session");
|
||||
start_time = esp_timer_get_time();
|
||||
has_session = true;
|
||||
//meter_start();
|
||||
}
|
||||
}
|
||||
|
||||
void energy_meter_stop_session(void)
|
||||
{
|
||||
if (has_session) {
|
||||
ESP_LOGI(TAG, "Stop session");
|
||||
start_time = 0;
|
||||
consumption = 0;
|
||||
charging_time = 0;
|
||||
has_session = false;
|
||||
//meter_stop();
|
||||
}
|
||||
}
|
||||
|
||||
void energy_meter_process(bool charging, uint16_t charging_current)
|
||||
{
|
||||
int64_t now = esp_timer_get_time();
|
||||
uint32_t delta_ms = (now - prev_time) / 1000;
|
||||
|
||||
if (charging && meter_is_running()) {
|
||||
MeterData data = meter_getData();
|
||||
|
||||
vlt[0] = data.vrmsA;
|
||||
vlt[1] = data.vrmsB;
|
||||
vlt[2] = data.vrmsC;
|
||||
|
||||
cur[0] = data.irmsA;
|
||||
cur[1] = data.irmsB;
|
||||
cur[2] = data.irmsC;
|
||||
|
||||
uint32_t total_power = data.wattA + data.wattB + data.wattC;
|
||||
|
||||
set_calc_power((float)total_power, delta_ms);
|
||||
charging_time += delta_ms;
|
||||
} else {
|
||||
vlt[0] = vlt[1] = vlt[2] = 0;
|
||||
cur[0] = cur[1] = cur[2] = 0;
|
||||
power = 0;
|
||||
}
|
||||
|
||||
prev_time = now;
|
||||
}
|
||||
|
||||
uint32_t energy_meter_get_power(void)
|
||||
{
|
||||
return power;
|
||||
}
|
||||
|
||||
uint32_t energy_meter_get_session_time(void)
|
||||
{
|
||||
return has_session ? (esp_timer_get_time() - start_time) / 1000000 : 0;
|
||||
}
|
||||
|
||||
uint32_t energy_meter_get_charging_time(void)
|
||||
{
|
||||
return charging_time / 1000;
|
||||
}
|
||||
|
||||
uint32_t energy_meter_get_consumption(void)
|
||||
{
|
||||
return consumption / 3600;
|
||||
}
|
||||
|
||||
void energy_meter_get_voltage(float *voltage)
|
||||
{
|
||||
memcpy(voltage, vlt, sizeof(vlt));
|
||||
}
|
||||
|
||||
float energy_meter_get_l1_voltage(void)
|
||||
{
|
||||
return vlt[0];
|
||||
}
|
||||
|
||||
float energy_meter_get_l2_voltage(void)
|
||||
{
|
||||
return vlt[1];
|
||||
}
|
||||
|
||||
float energy_meter_get_l3_voltage(void)
|
||||
{
|
||||
return vlt[2];
|
||||
}
|
||||
|
||||
void energy_meter_get_current(float *current)
|
||||
{
|
||||
memcpy(current, cur, sizeof(cur));
|
||||
}
|
||||
|
||||
float energy_meter_get_l1_current(void)
|
||||
{
|
||||
return cur[0];
|
||||
}
|
||||
|
||||
float energy_meter_get_l2_current(void)
|
||||
{
|
||||
return cur[1];
|
||||
}
|
||||
|
||||
float energy_meter_get_l3_current(void)
|
||||
{
|
||||
return cur[2];
|
||||
}
|
||||
|
||||
|
||||
const char *meter_state_to_str(bool state)
|
||||
{
|
||||
return state == true ? "CONNECTED" : "NOT CONNECTED";
|
||||
}
|
||||
|
||||
const char *meter_model_to_str(meter_model_t mode)
|
||||
{
|
||||
|
||||
switch (mode)
|
||||
{
|
||||
case ENERGY_METER_NONE:
|
||||
return "NONE";
|
||||
case ENERGY_METER_ORNO_515:
|
||||
return "OR-WE-515";
|
||||
case ENERGY_METER_ORNO_517:
|
||||
return "OR-WE-517";
|
||||
default:
|
||||
return "NONE";
|
||||
}
|
||||
}
|
||||
|
||||
meter_model_t meter_str_to_model(const char *str)
|
||||
{
|
||||
if (!strcmp(str, "NONE"))
|
||||
{
|
||||
return ENERGY_METER_NONE;
|
||||
}
|
||||
if (!strcmp(str, "OR-WE-515"))
|
||||
{
|
||||
return ENERGY_METER_ORNO_515;
|
||||
}
|
||||
if (!strcmp(str, "OR-WE-517"))
|
||||
{
|
||||
return ENERGY_METER_ORNO_517;
|
||||
}
|
||||
|
||||
return ENERGY_METER_NONE;
|
||||
}
|
||||
@@ -7,7 +7,7 @@
|
||||
#include "ac_relay.h"
|
||||
#include "socket_lock.h"
|
||||
#include "rcm.h"
|
||||
#include "energy_meter.h"
|
||||
#include "meter.h"
|
||||
#include "aux_io.h"
|
||||
#include "ntc_sensor.h"
|
||||
|
||||
|
||||
Reference in New Issue
Block a user