Compare commits
No commits in common. "d81ef73bcff9f8b1539f884076d2d21fff1f58a7" and "7476c939c3b363d4033288f57e7e8dacaec2793b" have entirely different histories.
d81ef73bcf
...
7476c939c3
|
|
@ -1,6 +0,0 @@
|
|||
namespace InnovEnergy.App.KacoCommunication.ESS;
|
||||
|
||||
public enum EssMode
|
||||
{
|
||||
|
||||
}
|
||||
|
|
@ -1,4 +1,3 @@
|
|||
using InnovEnergy.App.KacoCommunication.System;
|
||||
using InnovEnergy.App.KacoCommunication.SystemConfig;
|
||||
using InnovEnergy.Lib.Devices.BatteryDeligreen;
|
||||
using InnovEnergy.Lib.Devices.Kaco92L3;
|
||||
|
|
@ -6,19 +5,19 @@ using InnovEnergy.Lib.Devices.PLVario2Meter;
|
|||
using InnovEnergy.Lib.Devices.Trumpf.TruConvertDc;
|
||||
|
||||
namespace InnovEnergy.App.KacoCommunication.ESS;
|
||||
using ListOfBatteriesRecord = List<BatteryDeligreenRecords>;
|
||||
|
||||
public class StatusRecord
|
||||
{
|
||||
public required KacoRecord? InverterRecord { get; set; }
|
||||
public required PlVarioMeterRecord? GridMeterRecord { get; set; }
|
||||
public required DcDcDevicesRecord? DcDc { get; init; }
|
||||
public required ListOfBatteriesRecord? ListOfBatteriesRecord { get; set; }
|
||||
// public required BatteryDeligreenRecords? BatteryKabinet1 { get; set; }
|
||||
// public required BatteryDeligreenRecords? BatteryKabinet2 { get; set; }
|
||||
// public required BatteryDeligreenRecords? BatteryKabinet3 { get; set; }
|
||||
|
||||
public required BatteryDeligreenRecords? BatteryKabinet1 { get; set; }
|
||||
public required BatteryDeligreenRecords? BatteryKabinet2 { get; set; }
|
||||
public required BatteryDeligreenRecords? BatteryKabinet3 { get; set; }
|
||||
|
||||
|
||||
|
||||
public required Config Config { get; set; }
|
||||
public required StateMachine StateMachine { get; init; }
|
||||
|
||||
}
|
||||
|
||||
|
|
|
|||
|
|
@ -1,4 +1,5 @@
|
|||
// See https://aka.ms/new-console-template for more information
|
||||
|
||||
using System.IO.Compression;
|
||||
using System.Reactive.Linq;
|
||||
using System.Reactive.Threading.Tasks;
|
||||
|
|
@ -10,21 +11,16 @@ using InnovEnergy.App.KacoCommunication.DataTypes;
|
|||
using InnovEnergy.App.KacoCommunication.Devices;
|
||||
using InnovEnergy.App.KacoCommunication.ESS;
|
||||
using InnovEnergy.App.KacoCommunication.MiddlewareClasses;
|
||||
using InnovEnergy.App.KacoCommunication.System;
|
||||
using InnovEnergy.App.KacoCommunication.SystemConfig;
|
||||
using InnovEnergy.Lib.Devices.BatteryDeligreen;
|
||||
using InnovEnergy.Lib.Devices.Kaco92L3;
|
||||
using InnovEnergy.Lib.Devices.Kaco92L3.DataType;
|
||||
using InnovEnergy.Lib.Devices.PLVario2Meter;
|
||||
using InnovEnergy.Lib.Devices.Trumpf.SystemControl;
|
||||
using InnovEnergy.Lib.Devices.Trumpf.SystemControl.DataTypes;
|
||||
using InnovEnergy.Lib.Devices.Trumpf.TruConvertDc;
|
||||
using InnovEnergy.Lib.Devices.Trumpf.TruConvertDc.Control;
|
||||
using InnovEnergy.Lib.Protocols.Modbus.Channels;
|
||||
using InnovEnergy.Lib.Units;
|
||||
using InnovEnergy.Lib.Utils;
|
||||
using Newtonsoft.Json;
|
||||
using DeviceState = InnovEnergy.App.KacoCommunication.Devices.DeviceState;
|
||||
using Formatting = Newtonsoft.Json.Formatting;
|
||||
using JsonSerializer = System.Text.Json.JsonSerializer;
|
||||
|
||||
|
|
@ -37,6 +33,7 @@ internal static class Program
|
|||
private static UInt16 _fileCounter = 0;
|
||||
|
||||
|
||||
|
||||
private static SodistoreAlarmState _prevSodiohomeAlarmState = SodistoreAlarmState.Green;
|
||||
private static SodistoreAlarmState _sodiAlarmState = SodistoreAlarmState.Green;
|
||||
|
||||
|
|
@ -77,11 +74,13 @@ internal static class Program
|
|||
KacoChannel = CreateChannel(d.KacoIp);
|
||||
GridMeterChannel = CreateChannel(d.GridMeterIp);
|
||||
DcDcChannel = CreateChannel(d.DcDcIp);
|
||||
|
||||
}
|
||||
|
||||
|
||||
public static async Task Main(String[] args)
|
||||
{
|
||||
|
||||
while (true)
|
||||
{
|
||||
try
|
||||
|
|
@ -90,7 +89,7 @@ internal static class Program
|
|||
}
|
||||
catch (Exception e)
|
||||
{
|
||||
e.LogError();
|
||||
// e.LogError();
|
||||
}
|
||||
}
|
||||
// ReSharper disable once FunctionNeverReturns
|
||||
|
|
@ -106,12 +105,9 @@ internal static class Program
|
|||
var gridMeterDevice = new PlVarioMeterDevice(GridMeterChannel);
|
||||
var dcDcDevices = new TruConvertDcDcDevices(DcDcChannel);
|
||||
|
||||
var firstCabinetBatteriesDevice =
|
||||
BatteryNodes.Select(n => new BatteryDeligreenDevice(Port1Cabinet, n)).ToList();
|
||||
var secondCabinetBatteriesDevice =
|
||||
BatteryNodes.Select(n => new BatteryDeligreenDevice(Port2Cabinet, n)).ToList();
|
||||
var thirdCabinetBatteriesDevice =
|
||||
BatteryNodes.Select(n => new BatteryDeligreenDevice(Port3Cabinet, n)).ToList();
|
||||
var firstCabinetBatteriesDevice = BatteryNodes.Select(n => new BatteryDeligreenDevice(Port1Cabinet, n)).ToList();
|
||||
var secondCabinetBatteriesDevice = BatteryNodes.Select(n => new BatteryDeligreenDevice(Port2Cabinet, n)).ToList();
|
||||
var thirdCabinetBatteriesDevice = BatteryNodes.Select(n => new BatteryDeligreenDevice(Port3Cabinet, n)).ToList();
|
||||
|
||||
var batteryDevices1 = new BatteryDeligreenDevices(firstCabinetBatteriesDevice);
|
||||
var batteryDevices2 = new BatteryDeligreenDevices(secondCabinetBatteriesDevice);
|
||||
|
|
@ -124,7 +120,6 @@ internal static class Program
|
|||
var kacoRecord = kacoDevice.Read();
|
||||
var gridrawRecord = gridMeterDevice.Read();
|
||||
var dcDcRecord = dcDcDevices.Read();
|
||||
|
||||
if (gridrawRecord != null)
|
||||
{
|
||||
gridRecord = new PlVarioMeterRecord(gridrawRecord);
|
||||
|
|
@ -134,20 +129,14 @@ internal static class Program
|
|||
var batteryKabinet2 = batteryDevices2.Read();
|
||||
var batteryKabinet3 = batteryDevices3.Read();
|
||||
|
||||
var listOfBatteriesRecord = new List<BatteryDeligreenRecords>();
|
||||
if (batteryKabinet1 != null) listOfBatteriesRecord.Add(batteryKabinet1);
|
||||
if (batteryKabinet2 != null) listOfBatteriesRecord.Add(batteryKabinet2);
|
||||
if (batteryKabinet3 != null) listOfBatteriesRecord.Add(batteryKabinet3);
|
||||
|
||||
|
||||
return new StatusRecord
|
||||
{
|
||||
InverterRecord = kacoRecord,
|
||||
GridMeterRecord = gridRecord,
|
||||
DcDc = dcDcRecord,
|
||||
ListOfBatteriesRecord = listOfBatteriesRecord,
|
||||
StateMachine = StateMachine.Default,
|
||||
|
||||
BatteryKabinet1 = batteryKabinet1,
|
||||
BatteryKabinet2 = batteryKabinet2,
|
||||
BatteryKabinet3 = batteryKabinet3,
|
||||
Config = config // load from disk every iteration, so config can be changed while running
|
||||
};
|
||||
}
|
||||
|
|
@ -180,25 +169,35 @@ internal static class Program
|
|||
var statusrecord = ReadStatus();
|
||||
statusrecord?.CreateSimpleTopologyTextBlock().WriteLine();
|
||||
|
||||
statusrecord?.StateMachine.State.WriteLine(" state");
|
||||
statusrecord?.StateMachine.Message.WriteLine(" Message");
|
||||
|
||||
statusrecord?.InverterRecord?.BatteryLimitsEnable.WriteLine(" BatteryLimitsEnable");
|
||||
// statusrecord?.DcDc?.Dc.Battery.Power .WriteLine(" Power");
|
||||
// statusrecord?.DcDc?.Dc.Battery.Voltage .WriteLine(" Voltage");
|
||||
// statusrecord?.DcDc?.Dc.Battery.Current .WriteLine(" Current");
|
||||
// statusrecord?.DcDc?.Dc.Link.Voltage .WriteLine(" Dc link Voltage");
|
||||
|
||||
Console.WriteLine(" **************** DcDc **********************");
|
||||
statusrecord?.DcDc?.Dc.Battery.Power .WriteLine(" DC Battery Power");
|
||||
statusrecord?.DcDc?.Dc.Battery.Voltage .WriteLine("DC Battery Voltage");
|
||||
statusrecord?.DcDc?.Dc.Battery.Current .WriteLine("DC Battery Current");
|
||||
statusrecord?.DcDc?.Dc.Link.Voltage .WriteLine(" Dc link Voltage");
|
||||
|
||||
Console.WriteLine(" ********************************* Kaco Inverter *********************************");
|
||||
statusrecord?.GridMeterRecord?.Frequency .WriteLine(" Frequency");
|
||||
statusrecord?.GridMeterRecord?.VoltageU1 .WriteLine(" VoltageU1");
|
||||
statusrecord?.GridMeterRecord?.VoltageU2 .WriteLine(" VoltageU2");
|
||||
statusrecord?.GridMeterRecord?.VoltageU3 .WriteLine(" VoltageU3");
|
||||
|
||||
statusrecord?.GridMeterRecord?.CurrentI1 .WriteLine(" CurrentI1");
|
||||
statusrecord?.GridMeterRecord?.CurrentI2 .WriteLine(" CurrentI2");
|
||||
statusrecord?.GridMeterRecord?.CurrentI3 .WriteLine(" CurrentI3");
|
||||
|
||||
statusrecord?.GridMeterRecord?.ActivePowerL1 .WriteLine(" ActivePowerL1");
|
||||
statusrecord?.GridMeterRecord?.ActivePowerL2 .WriteLine(" ActivePowerL2");
|
||||
statusrecord?.GridMeterRecord?.ActivePowerL3 .WriteLine(" ActivePowerL3");
|
||||
statusrecord?.GridMeterRecord?.ActivePowerTotal .WriteLine(" ActivePowerTotal");
|
||||
|
||||
statusrecord?.InverterRecord?.ActivePowerW.WriteLine(" Inverter Power");
|
||||
statusrecord?.InverterRecord?.CurrentState.WriteLine(" CurrentState");
|
||||
statusrecord?.InverterRecord?.RequestedState.WriteLine(" RequestedState");
|
||||
statusrecord?.InverterRecord?.PcuError.WriteLine(" PcuError");
|
||||
statusrecord?.InverterRecord?.PcuState.WriteLine(" PcuState");
|
||||
|
||||
statusrecord?.InverterRecord?.BattCharId.WriteLine(" _battCharId");
|
||||
statusrecord?.InverterRecord?.BattCharLength.WriteLine(" _battCharLength");
|
||||
|
||||
statusrecord?.InverterRecord?.MinDischargeVoltage.WriteLine(" MinDischargeVoltage");
|
||||
statusrecord?.InverterRecord?.MaxDischargeCurrent.WriteLine(" MaxDischargeCurrent");
|
||||
statusrecord?.InverterRecord?.DischargeCutoffCurrent.WriteLine(" DischargeCutoffCurrent");
|
||||
|
|
@ -206,31 +205,17 @@ internal static class Program
|
|||
statusrecord?.InverterRecord?.MaxChargeVoltage.WriteLine(" MaxChargeVoltage");
|
||||
statusrecord?.InverterRecord?.MaxChargeCurrent.WriteLine(" MaxChargeCurrent");
|
||||
statusrecord?.InverterRecord?.ChargeCutoffCurrent.WriteLine(" ChargeCutoffCurrent");
|
||||
statusrecord?.InverterRecord?.ActivePowerSetPercent.WriteLine( "ActivePowerSetPercent");
|
||||
|
||||
statusrecord?.ControlSystemState();
|
||||
var i = 0;
|
||||
foreach (var d in statusrecord.DcDc.Devices)
|
||||
{
|
||||
i++;
|
||||
Console.WriteLine("before DcDc is " + i + d.Control.PowerStageEnable);
|
||||
d.Control.ResetAlarmsAndWarnings = true;
|
||||
d.Control.PowerStageEnable = true;
|
||||
}
|
||||
|
||||
|
||||
statusrecord?.DcDc?.SystemControl.ApplyDcDcDefaultSettings();
|
||||
statusrecord?.InverterRecord?.ActivePowerSetPercent.WriteLine(" ActivePowerSetPercent");
|
||||
statusrecord?.InverterRecord?.ReactivePowerSetPercent.WriteLine(" ReactivePowerSetPercent");
|
||||
statusrecord?.InverterRecord?.WatchdogSeconds.WriteLine(" WatchdogSeconds");
|
||||
InitializeKacoStartup(statusrecord);
|
||||
foreach (var d in statusrecord.DcDc.Devices)
|
||||
{
|
||||
Console.WriteLine("After DcDc is " + d.Control.PowerStageEnable);
|
||||
}
|
||||
|
||||
|
||||
Console.WriteLine(" ************************************ We are writing ************************************");
|
||||
Console.WriteLine( " ************************************ We are writing ************************************");
|
||||
|
||||
statusrecord?.Config.Save(); // save the config file
|
||||
if (statusrecord?.InverterRecord != null) kacoDevice.Write(statusrecord.InverterRecord);
|
||||
Console.WriteLine(DateTime.Now.ToString("HH:mm:ss.fff"));
|
||||
|
||||
return statusrecord;
|
||||
}
|
||||
|
|
@ -245,7 +230,8 @@ internal static class Program
|
|||
|
||||
private static async Task SavingLocalCsvFile(Int64 timestamp, String csv)
|
||||
{
|
||||
var directoryPath = Path.Combine(AppDomain.CurrentDomain.BaseDirectory, "csvFiles");
|
||||
const String directoryPath = "/home/inesco/salimax/csvFile";
|
||||
|
||||
// Ensure directory exists
|
||||
if (!Directory.Exists(directoryPath))
|
||||
{
|
||||
|
|
@ -382,7 +368,6 @@ internal static class Program
|
|||
return false;
|
||||
}
|
||||
}
|
||||
|
||||
_fileCounter++;
|
||||
return true;
|
||||
}
|
||||
|
|
@ -431,8 +416,7 @@ internal static class Program
|
|||
//Create a zip directory and put the compressed file inside
|
||||
using (var archive = new ZipArchive(memoryStream, ZipArchiveMode.Create, true))
|
||||
{
|
||||
var entry = archive.CreateEntry("data.json",
|
||||
CompressionLevel.SmallestSize); // Add JSON data to the ZIP archive
|
||||
var entry = archive.CreateEntry("data.json", CompressionLevel.SmallestSize); // Add JSON data to the ZIP archive
|
||||
using (var entryStream = entry.Open())
|
||||
using (var writer = new StreamWriter(entryStream))
|
||||
{
|
||||
|
|
@ -490,16 +474,14 @@ internal static class Program
|
|||
var modbusData = new Dictionary<String, UInt16>();
|
||||
|
||||
// SYSTEM DATA
|
||||
var result1 =
|
||||
ConvertToModbusRegisters((status.Config.MinSoc * 10), "UInt16",
|
||||
30001); // this to be updated to modbusTCP version
|
||||
var result1 = ConvertToModbusRegisters((status.Config.MinSoc * 10), "UInt16", 30001); // this to be updated to modbusTCP version
|
||||
var result2 = ConvertToModbusRegisters(status.InverterRecord!.PcuError, "UInt32", 30002);
|
||||
|
||||
// Merge all results into one dictionary
|
||||
|
||||
var allResults = new[]
|
||||
{
|
||||
result1, result2
|
||||
result1,result2
|
||||
};
|
||||
|
||||
foreach (var result in allResults)
|
||||
|
|
@ -509,7 +491,6 @@ internal static class Program
|
|||
modbusData[entry.Key] = entry.Value;
|
||||
}
|
||||
}
|
||||
|
||||
// Write to JSON
|
||||
var json = JsonSerializer.Serialize(modbusData, new JsonSerializerOptions { WriteIndented = true });
|
||||
await File.WriteAllTextAsync("/home/inesco/SodiStoreHome/ModbusTCP/modbus_tcp_data.json", json);
|
||||
|
|
@ -517,7 +498,7 @@ internal static class Program
|
|||
//Console.WriteLine("JSON file written successfully.");
|
||||
//Console.WriteLine(json);
|
||||
var stopTime = DateTime.Now;
|
||||
Console.WriteLine(stopTime.ToString("HH:mm:ss.fff") + " Finish the loop");
|
||||
Console.WriteLine(stopTime.ToString("HH:mm:ss.fff" )+ " Finish the loop");
|
||||
return true;
|
||||
}
|
||||
|
||||
|
|
@ -553,15 +534,9 @@ internal static class Program
|
|||
default:
|
||||
throw new ArgumentException("Unsupported output type: " + outputType);
|
||||
}
|
||||
|
||||
return registers;
|
||||
}
|
||||
|
||||
private static void ForAll<T>(this IEnumerable<T> ts, Action<T> action)
|
||||
{
|
||||
foreach (var t in ts)
|
||||
action(t);
|
||||
}
|
||||
|
||||
private static void InitializeKacoStartup(StatusRecord? statusRecord)
|
||||
{
|
||||
|
|
@ -569,23 +544,12 @@ internal static class Program
|
|||
// 1. Apply DC – This part is physical and cannot be done in software.
|
||||
// We assume DC power is already present.
|
||||
//
|
||||
Console.WriteLine("1. Apply DC");
|
||||
//
|
||||
statusRecord?.DcDc?.Devices
|
||||
.Select(d => d.Control)
|
||||
.ForAll(c => c.PowerStageEnable = true);
|
||||
|
||||
statusRecord?.DcDc?.Devices
|
||||
.Select(d => d.Control )
|
||||
.ForAll(c => c.ControlMode = DcControlMode.VoltageDroop);
|
||||
//
|
||||
// // 2. Send valid battery limits (Model 64202)
|
||||
// 2. Send valid battery limits (Model 64202)
|
||||
// All values temporarily set to "1" as requested.
|
||||
// You will replace them later with real values.
|
||||
//
|
||||
|
||||
Console.WriteLine("2. Send real value");
|
||||
|
||||
if (statusRecord?.InverterRecord != null)
|
||||
{
|
||||
statusRecord.InverterRecord.MinDischargeVoltage = 700f; // 64202.DisMinV
|
||||
|
|
@ -600,8 +564,7 @@ internal static class Program
|
|||
|
||||
//
|
||||
// 3. Enable limits (EnLimit)
|
||||
|
||||
Console.WriteLine("3. Enable limits ");
|
||||
//
|
||||
statusRecord.InverterRecord.BatteryLimitsEnable = EnableDisableEnum.Enabled;
|
||||
|
||||
//
|
||||
|
|
@ -616,9 +579,6 @@ internal static class Program
|
|||
// - Then after grid/DC conditions: CurrentState == 1 (OFF) or 11 (GRID_CONNECTED)
|
||||
//
|
||||
|
||||
Console.WriteLine("3. Read current state");
|
||||
|
||||
|
||||
var state = statusRecord.InverterRecord.CurrentState;
|
||||
|
||||
Console.WriteLine($"KACO 64201.CurrentState = {state}");
|
||||
|
|
@ -626,7 +586,6 @@ internal static class Program
|
|||
switch (state)
|
||||
{
|
||||
case CurrentState.Standby:
|
||||
|
||||
Console.WriteLine("Device is in STANDBY (8) — battery limits accepted.");
|
||||
break;
|
||||
|
||||
|
|
@ -642,26 +601,9 @@ internal static class Program
|
|||
Console.WriteLine("Device in unexpected state: " + state);
|
||||
break;
|
||||
}
|
||||
//Thread.Sleep(2000);
|
||||
}
|
||||
}
|
||||
|
||||
private static void ApplyDcDcDefaultSettings(this SystemControlRegisters? sc)
|
||||
{
|
||||
|
||||
if (sc is null)
|
||||
return;
|
||||
|
||||
sc.SystemConfig = Lib.Devices.Trumpf.SystemControl.DataTypes.SystemConfig.DcDcOnly;
|
||||
sc.CommunicationTimeout = TimeSpan.FromSeconds(20);
|
||||
|
||||
sc.PowerSetPointActivation = PowerSetPointActivation.Immediate;
|
||||
sc.UseSlaveIdForAddressing = true;
|
||||
sc.SlaveErrorHandling = SlaveErrorHandling.Relaxed;
|
||||
sc.SubSlaveErrorHandling = SubSlaveErrorHandling.Off;
|
||||
sc.TargetSlave = 0;
|
||||
sc.ResetAlarmsAndWarnings = true;
|
||||
}
|
||||
|
||||
private static void InsertIntoJson(Dictionary<String, Object> jsonDict, String[] keys, String value)
|
||||
{
|
||||
var currentDict = jsonDict;
|
||||
|
|
@ -675,10 +617,11 @@ internal static class Program
|
|||
|
||||
if (i == keys.Length - 1) // Last key, store the value
|
||||
{
|
||||
if (!value.Contains(",") &&
|
||||
double.TryParse(value, out Double doubleValue)) // Try to parse value as a number
|
||||
|
||||
if (!value.Contains(",") && double.TryParse(value, out Double doubleValue)) // Try to parse value as a number
|
||||
{
|
||||
currentDict[key] = Math.Round(doubleValue, 2); // Round to 2 decimal places
|
||||
|
||||
}
|
||||
else
|
||||
{
|
||||
|
|
|
|||
|
|
@ -1,376 +0,0 @@
|
|||
using InnovEnergy.App.KacoCommunication.ESS;
|
||||
using InnovEnergy.Lib.Devices.Kaco92L3.DataType;
|
||||
#pragma warning disable CS8602 // Dereference of a possibly null reference.
|
||||
|
||||
namespace InnovEnergy.App.KacoCommunication.System;
|
||||
|
||||
public static class KacoCurrentStateController
|
||||
{
|
||||
// Call every 2 seconds
|
||||
public static Boolean ControlSystemState(this StatusRecord s)
|
||||
{
|
||||
var cs = s.InverterRecord.CurrentState; // 64201.CurrentState (1..12)
|
||||
s.StateMachine.State = (int)cs;
|
||||
|
||||
return cs switch
|
||||
{
|
||||
CurrentState.Off => State_Off(s),
|
||||
CurrentState.Sleeping => State_Sleeping(s),
|
||||
CurrentState.Starting => State_Starting(s),
|
||||
CurrentState.Mppt => State_Mppt(s),
|
||||
CurrentState.Throttled => State_Throttled(s),
|
||||
CurrentState.ShuttingDown => State_ShuttingDown(s),
|
||||
CurrentState.Fault => State_Fault(s),
|
||||
CurrentState.Standby => State_Standby(s),
|
||||
CurrentState.Precharge => State_Precharge(s),
|
||||
CurrentState.GridPreConnected=> State_GridPreConnected(s),
|
||||
CurrentState.GridConnected => State_GridConnected(s),
|
||||
CurrentState.NoErrorPending => State_NoErrorPending(s),
|
||||
_ => UnknownState(s)
|
||||
};
|
||||
}
|
||||
|
||||
// ─────────────────────────────────────────────
|
||||
// Global rule: only allow power writes in 11 or 5
|
||||
// ─────────────────────────────────────────────
|
||||
private static void EnforcePowerRules(StatusRecord s)
|
||||
{
|
||||
var cs = s.InverterRecord.CurrentState;
|
||||
if (cs is not (CurrentState.GridConnected or CurrentState.Throttled))
|
||||
{
|
||||
// must be 0 outside (11) or (5)
|
||||
s.InverterRecord.ActivePowerSetPercent = 0f;
|
||||
//s.InverterRecord.ReactivePowerSetPercent = 0f;
|
||||
}
|
||||
}
|
||||
|
||||
// ─────────────────────────────────────────────
|
||||
// State handlers (based purely on CurrentState)
|
||||
// ─────────────────────────────────────────────
|
||||
|
||||
private static bool State_Off(StatusRecord s)
|
||||
{
|
||||
s.StateMachine.Message = "OFF: write limits (once) and request connect (11).";
|
||||
EnforcePowerRules(s);
|
||||
|
||||
// Write limits (ignore details)
|
||||
// WriteLimits();
|
||||
|
||||
// Always aim for running
|
||||
s.InverterRecord.RequestedState = ReuqestedState.GridConnected;
|
||||
return false;
|
||||
}
|
||||
|
||||
private static bool State_Sleeping(StatusRecord s)
|
||||
{
|
||||
s.StateMachine.Message = "SLEEPING: write limits (once) and request connect (11).";
|
||||
EnforcePowerRules(s);
|
||||
|
||||
// s.InverterRecord.WriteLimits();
|
||||
s.InverterRecord.RequestedState = ReuqestedState.GridConnected;
|
||||
return false;
|
||||
}
|
||||
|
||||
private static bool State_Standby(StatusRecord s)
|
||||
{
|
||||
s.StateMachine.Message = "STANDBY: write limits (once) and request connect (11).";
|
||||
EnforcePowerRules(s);
|
||||
|
||||
// s.InverterRecord.WriteLimits();
|
||||
s.InverterRecord.RequestedState = ReuqestedState.GridConnected;
|
||||
return false;
|
||||
}
|
||||
|
||||
private static bool State_Mppt(StatusRecord s)
|
||||
{
|
||||
s.StateMachine.Message = "MPPT: keep requesting connect (11).";
|
||||
EnforcePowerRules(s);
|
||||
|
||||
s.InverterRecord.RequestedState = ReuqestedState.GridConnected;
|
||||
return false;
|
||||
}
|
||||
|
||||
private static bool State_Starting(StatusRecord s)
|
||||
{
|
||||
s.StateMachine.Message = "STARTING: keep requesting connect (11), wait for 10/11/5.";
|
||||
EnforcePowerRules(s);
|
||||
|
||||
s.InverterRecord.RequestedState = ReuqestedState.GridConnected;
|
||||
return false;
|
||||
}
|
||||
|
||||
private static bool State_Precharge(StatusRecord s)
|
||||
{
|
||||
s.StateMachine.Message = "PRECHARGE: keep requesting connect (11), wait.";
|
||||
EnforcePowerRules(s);
|
||||
|
||||
s.InverterRecord.RequestedState = ReuqestedState.GridConnected;
|
||||
return false;
|
||||
}
|
||||
|
||||
private static bool State_GridPreConnected(StatusRecord s)
|
||||
{
|
||||
s.StateMachine.Message = "GRID_PRE_CONNECTED: keep requesting connect (11), wait for 11/5.";
|
||||
EnforcePowerRules(s);
|
||||
|
||||
s.InverterRecord.RequestedState = ReuqestedState.GridConnected;
|
||||
return false;
|
||||
}
|
||||
|
||||
private static bool State_GridConnected(StatusRecord s)
|
||||
{
|
||||
s.StateMachine.Message = "GRID_CONNECTED: running. Power writes allowed.";
|
||||
|
||||
// Keep request latched
|
||||
s.InverterRecord.RequestedState = ReuqestedState.GridConnected;
|
||||
|
||||
// Here you may write power setpoints (your own targets)
|
||||
// Example:
|
||||
// s.InverterRecord.ControlMode = ControlModeEnum.RpcRemote;
|
||||
s.InverterRecord.ActivePowerSetPercent = s.Config.ActivePowerPercent;
|
||||
// s.InverterRecord.ReactivePowerSetPercent = s.Targets.ReactivePowerPercent;
|
||||
|
||||
return true; // end goal reached
|
||||
}
|
||||
|
||||
private static bool State_Throttled(StatusRecord s)
|
||||
{
|
||||
s.StateMachine.Message = "THROTTLED: still running. Power writes allowed.";
|
||||
s.InverterRecord.RequestedState = ReuqestedState.GridConnected;
|
||||
|
||||
// Power writes allowed here too
|
||||
return true;
|
||||
}
|
||||
|
||||
private static bool State_ShuttingDown(StatusRecord s)
|
||||
{
|
||||
s.StateMachine.Message = "SHUTTING_DOWN: keep requesting connect (11); will reconnect after reaching 8/1.";
|
||||
EnforcePowerRules(s);
|
||||
|
||||
s.InverterRecord.RequestedState = ReuqestedState.GridConnected;
|
||||
return false;
|
||||
}
|
||||
|
||||
private static bool State_Fault(StatusRecord s)
|
||||
{
|
||||
s.StateMachine.Message = "FAULT: power=0 and acknowledge with RequestedState=1 (OFF).";
|
||||
EnforcePowerRules(s);
|
||||
|
||||
// Per doc: acknowledge uses RequestedState=1
|
||||
s.InverterRecord.RequestedState = ReuqestedState.Off;
|
||||
return false;
|
||||
}
|
||||
|
||||
private static bool State_NoErrorPending(StatusRecord s)
|
||||
{
|
||||
s.StateMachine.Message = "NO_ERROR_PENDING: acknowledge with RequestedState=1 then controller will request 11 next cycles.";
|
||||
EnforcePowerRules(s);
|
||||
|
||||
// Per doc Step 8: set RequestedState to 1 to acknowledge
|
||||
s.InverterRecord.RequestedState = ReuqestedState.Off;
|
||||
return false;
|
||||
}
|
||||
|
||||
private static bool UnknownState(StatusRecord s)
|
||||
{
|
||||
s.StateMachine.Message = $"UNKNOWN CurrentState={s.InverterRecord.CurrentState}. For safety, power=0 and request 11.";
|
||||
EnforcePowerRules(s);
|
||||
|
||||
s.InverterRecord.RequestedState = ReuqestedState.GridConnected;
|
||||
return false;
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
/*
|
||||
|
||||
public static class Controller
|
||||
{
|
||||
private static UInt16 GetSystemState(this StatusRecord r)
|
||||
{
|
||||
if (r.InverterRecord != null)
|
||||
{
|
||||
return (UInt16)r.InverterRecord.CurrentState;
|
||||
}
|
||||
else
|
||||
{
|
||||
return (UInt16)StateMachine.Default.State;
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
public static Boolean ControlSystemState(this StatusRecord s)
|
||||
{
|
||||
s.StateMachine.State = s.GetSystemState();
|
||||
|
||||
var cs = s.InverterRecord?.CurrentState; // 64201.CurrentState (1..12)
|
||||
s.StateMachine.State = (UInt16)cs;
|
||||
|
||||
return s.StateMachine.State switch
|
||||
{
|
||||
1 => State_Off(s),
|
||||
2 => State_Sleeping(s),
|
||||
3 => State_Starting(s),
|
||||
4 => State_Mppt(s),
|
||||
5 => State_Throttled(s),
|
||||
6 => State_ShuttingDown(s),
|
||||
7 => State_Fault(s),
|
||||
8 => State_Standby(s),
|
||||
9 => State_Precharge(s),
|
||||
10 => State_GridPreConnected(s),
|
||||
11 => State_GridConnected(s),
|
||||
12 => State_NoErrorPending(s),
|
||||
_ => UnknownState(s)
|
||||
};
|
||||
}
|
||||
|
||||
// ─────────────────────────────────────────────
|
||||
// Global rule: only allow power writes in 11 or 5
|
||||
// ─────────────────────────────────────────────
|
||||
private static void EnforcePowerRules(StatusRecord s)
|
||||
{
|
||||
var cs = s.InverterRecord?.CurrentState;
|
||||
|
||||
// must be 0 outside (11) or (5)
|
||||
s.InverterRecord.ActivePowerSetPercent = 0f;
|
||||
s.InverterRecord.ReactivePowerSetPercent = 0f; }
|
||||
}
|
||||
|
||||
// ─────────────────────────────────────────────
|
||||
// State handlers (based purely on CurrentState)
|
||||
// ─────────────────────────────────────────────
|
||||
|
||||
private static Boolean State_Off(StatusRecord s)
|
||||
{
|
||||
s.StateMachine.Message = "OFF: write limits (once) and request connect (11).";
|
||||
EnforcePowerRules(s);
|
||||
|
||||
// Write limits (ignore details)
|
||||
s.InverterRecord.WriteLimits();
|
||||
|
||||
// Always aim for running
|
||||
s.InverterRecord.RequestedState = ReuqestedState.GridConnected;
|
||||
return false;
|
||||
}
|
||||
|
||||
|
||||
private static bool State_Sleeping(StatusRecord s)
|
||||
{
|
||||
s.StateMachine.Message = "SLEEPING: write limits (once) and request connect (11).";
|
||||
EnforcePowerRules(s);
|
||||
|
||||
s.InverterRecord.WriteLimits();
|
||||
s.InverterRecord.RequestedState = ReuqestedState.GridConnected;
|
||||
return false;
|
||||
}
|
||||
|
||||
private static bool State_Standby(StatusRecord s)
|
||||
{
|
||||
s.StateMachine.Message = "STANDBY: write limits (once) and request connect (11).";
|
||||
EnforcePowerRules(s);
|
||||
|
||||
s.InverterRecord.WriteLimits();
|
||||
s.InverterRecord.RequestedState = ReuqestedState.GridConnected;
|
||||
return false;
|
||||
}
|
||||
|
||||
private static bool State_Mppt(StatusRecord s)
|
||||
{
|
||||
s.StateMachine.Message = "MPPT: keep requesting connect (11).";
|
||||
EnforcePowerRules(s);
|
||||
|
||||
s.InverterRecord.RequestedState = ReuqestedState.GridConnected;
|
||||
return false;
|
||||
}
|
||||
|
||||
private static bool State_Starting(StatusRecord s)
|
||||
{
|
||||
s.StateMachine.Message = "STARTING: keep requesting connect (11), wait for 10/11/5.";
|
||||
EnforcePowerRules(s);
|
||||
|
||||
s.InverterRecord.RequestedState = ReuqestedState.GridConnected;
|
||||
return false;
|
||||
}
|
||||
|
||||
private static bool State_Precharge(StatusRecord s)
|
||||
{
|
||||
s.StateMachine.Message = "PRECHARGE: keep requesting connect (11), wait.";
|
||||
EnforcePowerRules(s);
|
||||
|
||||
s.InverterRecord.RequestedState = ReuqestedState.GridConnected;
|
||||
return false;
|
||||
}
|
||||
|
||||
private static bool State_GridPreConnected(StatusRecord s)
|
||||
{
|
||||
s.StateMachine.Message = "GRID_PRE_CONNECTED: keep requesting connect (11), wait for 11/5.";
|
||||
EnforcePowerRules(s);
|
||||
|
||||
s.InverterRecord.RequestedState = ReuqestedState.GridConnected;
|
||||
return false;
|
||||
}
|
||||
|
||||
private static bool State_GridConnected(StatusRecord s)
|
||||
{
|
||||
s.StateMachine.Message = "GRID_CONNECTED: running. Power writes allowed.";
|
||||
|
||||
// Keep request latched
|
||||
s.InverterRecord.RequestedState = ReuqestedState.GridConnected;
|
||||
|
||||
// Here you may write power setpoints (your own targets)
|
||||
// Example:
|
||||
// s.InverterRecord.ControlMode = ControlModeEnum.RpcRemote;
|
||||
// s.InverterRecord.ActivePowerSetPercent = s.Targets.ActivePowerPercent;
|
||||
// s.InverterRecord.ReactivePowerSetPercent = s.Targets.ReactivePowerPercent;
|
||||
|
||||
return true; // end goal reached
|
||||
}
|
||||
|
||||
private static bool State_Throttled(StatusRecord s)
|
||||
{
|
||||
s.StateMachine.Message = "THROTTLED: still running. Power writes allowed.";
|
||||
s.InverterRecord.RequestedState = ReuqestedState.GridConnected;
|
||||
|
||||
// Power writes allowed here too
|
||||
return true;
|
||||
}
|
||||
|
||||
private static bool State_ShuttingDown(StatusRecord s)
|
||||
{
|
||||
s.StateMachine.Message = "SHUTTING_DOWN: keep requesting connect (11); will reconnect after reaching 8/1.";
|
||||
EnforcePowerRules(s);
|
||||
|
||||
s.InverterRecord.RequestedState = ReuqestedState.GridConnected;
|
||||
return false;
|
||||
}
|
||||
|
||||
private static bool State_Fault(StatusRecord s)
|
||||
{
|
||||
s.StateMachine.Message = "FAULT: power=0 and acknowledge with RequestedState=1 (OFF).";
|
||||
EnforcePowerRules(s);
|
||||
|
||||
// Per doc: acknowledge uses RequestedState=1
|
||||
s.InverterRecord.RequestedState = ReuqestedState.Off;
|
||||
return false;
|
||||
}
|
||||
|
||||
private static bool State_NoErrorPending(StatusRecord s)
|
||||
{
|
||||
s.StateMachine.Message = "NO_ERROR_PENDING: acknowledge with RequestedState=1 then controller will request 11 next cycles.";
|
||||
EnforcePowerRules(s);
|
||||
|
||||
// Per doc Step 8: set RequestedState to 1 to acknowledge
|
||||
s.InverterRecord.RequestedState = ReuqestedState.Off;
|
||||
return false;
|
||||
}
|
||||
|
||||
private static bool UnknownState(StatusRecord s)
|
||||
{
|
||||
s.StateMachine.Message = $"UNKNOWN CurrentState={s.InverterRecord.CurrentState}. For safety, power=0 and request 11.";
|
||||
EnforcePowerRules(s);
|
||||
|
||||
s.InverterRecord.RequestedState = ReuqestedState.GridConnected;
|
||||
return false;
|
||||
}
|
||||
|
||||
}*/
|
||||
|
|
@ -1,9 +0,0 @@
|
|||
namespace InnovEnergy.App.KacoCommunication.System;
|
||||
|
||||
public record StateMachine
|
||||
{
|
||||
public required String Message { get; set; } // TODO: init only
|
||||
public required Int32 State { get; set; } // TODO: init only
|
||||
|
||||
public static StateMachine Default { get; } = new StateMachine { State = 100, Message = "Unknown State" };
|
||||
}
|
||||
|
|
@ -14,7 +14,6 @@ public class Config
|
|||
private static readonly JsonSerializerOptions JsonOptions = new() { WriteIndented = true };
|
||||
|
||||
public required Double MinSoc { get; set; }
|
||||
public required float ActivePowerPercent { get; set; }
|
||||
|
||||
/* public required Double MaximumDischargingCurrent { get; set; }
|
||||
public required Double MaximumChargingCurrent { get; set; }
|
||||
|
|
@ -30,8 +29,8 @@ public class Config
|
|||
public static Config Default => new()
|
||||
{
|
||||
MinSoc = 20,
|
||||
ActivePowerPercent = 0f,
|
||||
/* MaximumDischargingCurrent = 180,
|
||||
/* MaximumChargingCurrent = 180,
|
||||
MaximumDischargingCurrent = 180,
|
||||
BatteriesCount = 0,
|
||||
ModbusProtcolNumber = 1.2,*/
|
||||
Devices = new ()
|
||||
|
|
|
|||
|
|
@ -176,11 +176,6 @@ public partial class KacoRecord
|
|||
/// </summary>
|
||||
public Int16 BatteryCurrentScaleFactor => _battCharASf;
|
||||
|
||||
|
||||
public Int16 ActivePowerW => _activePowerW;
|
||||
public Int16 ReactivePowerVar => _reactivePowerVar;
|
||||
public Int16 LineFrequencyHz => _lineFrequencyHz;
|
||||
|
||||
// Helper wrappers for scaled values
|
||||
private float ScaleBattVoltage(UInt16 raw) => ScaleSunspec(raw, _battCharVSf);
|
||||
private float ScaleBattCurrent(UInt16 raw) => ScaleSunspec(raw, _battCharASf);
|
||||
|
|
|
|||
|
|
@ -21,7 +21,7 @@ public partial class KacoRecord
|
|||
// State control
|
||||
[HoldingRegister<UInt16>(41065, writable: true)] private UInt16 _requestedState; // 0xA069 – RequestedState (enum16, RW)
|
||||
[HoldingRegister<UInt16>(41066)] private UInt16 _currentState; // 0xA06A – CurrentState (enum16, R)
|
||||
[HoldingRegister<UInt16>(41067, writable: true)] private UInt16 _controlMode; // 0xA06B – ControlMode (enum16, RW) Power Control mode (zunächst 0=Q RPC_Local / 1 RPC_Remote Qfix 64201)
|
||||
[HoldingRegister<UInt16>(41067, writable: true)] private UInt16 _controlMode; // 0xA06B – ControlMode (enum16, RW)
|
||||
[HoldingRegister<UInt16>(41068)] private UInt16 _reserved7; // 0xA06C – Reserved
|
||||
|
||||
// Watchdog / setpoints
|
||||
|
|
|
|||
Loading…
Reference in New Issue