Merge pull request #79 from gskjold/dev-v1.3.0

Dev v1.3.0
Support for Kamstrup IT meters
2026-03-11 21:15:30 +00:00 · 2020-06-06 20:30:47 +02:00 · 2020-05-28 18:44:38 +02:00 · 2020-05-28 14:19:03 +02:00 · 2020-05-27 08:38:59 +02:00
7 changed files with 105 additions and 31 deletions
--- a/.github/workflows/build.yml
+++ b/.github/workflows/build.yml
@@ -9,7 +9,7 @@ on:
      - web/**
      - platformio.ini
    branches:
-      - master
+      - '*'
    tags:
      - '*'
      - '!v*.*.*'
--- a/lib/HanReader/src/Kamstrup.h
+++ b/lib/HanReader/src/Kamstrup.h
@@ -5,10 +5,12 @@

 enum class Kamstrup
 {
+	List1PhaseShort = 0x11,
+	List1PhaseLong  = 0x1B,
 	List3PhaseShort = 0x19,
 	List3PhaseLong  = 0x23,
-	List1PhaseShort = 0x11,
-	List1PhaseLong  = 0x1B
+	List3PhaseITShort = 0x17,
+	List3PhaseITLong  = 0x21
 };

 enum class Kamstrup_List3Phase
@@ -83,5 +85,43 @@ enum class Kamstrup_List1Phase
 	CumulativeReactiveExportEnergy
 };

+enum class Kamstrup_List3PhaseIT
+{
+	ListSize,
+	ListVersionIdentifier,
+	MeterID_OBIS,
+	MeterID,
+	MeterType_OBIS,
+	MeterType,
+	ActiveImportPower_OBIS,
+	ActiveImportPower,
+	ActiveExportPower_OBIS,
+	ActiveExportPower,
+	ReactiveImportPower_OBIS,
+	ReactiveImportPower,
+	ReactiveExportPower_OBIS,
+	ReactiveExportPower,
+	CurrentL1_OBIS,
+	CurrentL1,
+	CurrentL3_OBIS,
+	CurrentL3,
+	VoltageL1_OBIS,
+	VoltageL1,
+	VoltageL2_OBIS,
+	VoltageL2,
+	VoltageL3_OBIS,
+	VoltageL3,
+	MeterClock_OBIS,
+	MeterClock,
+	CumulativeActiveImportEnergy_OBIS,
+	CumulativeActiveImportEnergy,
+	CumulativeActiveExportEnergy_OBIS,
+	CumulativeActiveExportEnergy,
+	CumulativeReactiveImportEnergy_OBIS,
+	CumulativeReactiveImportEnergy,
+	CumulativeReactiveExportEnergy_OBIS,
+	CumulativeReactiveExportEnergy
+};
+
 #endif

--- a/platformio.ini
+++ b/platformio.ini
@@ -7,7 +7,7 @@ framework = arduino
 lib_deps = HanReader@1.0.1, ArduinoJson@6.14.1, MQTT@2.4.7, DallasTemperature@3.8.1, EspSoftwareSerial@6.7.1, Base64@1.0.0, RemoteDebug@3.0.5, Time@1.6

 [env:hw1esp12e]
-platform = espressif8266@2.3.3
+platform = espressif8266@2.5.1
 board = esp12e
 framework = ${common.framework}
 lib_deps = ${common.lib_deps}
@@ -18,7 +18,7 @@ extra_scripts =
    scripts/makeweb.py

 [env:esp12e]
-platform = espressif8266@2.3.3
+platform = espressif8266@2.5.1
 board = esp12e
 framework = ${common.framework}
 lib_deps = ${common.lib_deps}
@@ -27,7 +27,7 @@ extra_scripts =
    scripts/makeweb.py

 [env:d1mini]
-platform = espressif8266@2.3.3
+platform = espressif8266@2.5.1
 board = d1_mini
 framework = ${common.framework}
 lib_deps = ${common.lib_deps}
@@ -36,7 +36,7 @@ extra_scripts =
    scripts/makeweb.py

 [env:esp32]
-platform = espressif32@1.11.2
+platform = espressif32@1.12.1
 board = esp32dev
 framework = ${common.framework}
 lib_deps = ${common.lib_deps}
@@ -45,7 +45,7 @@ extra_scripts =
    scripts/makeweb.py

 [env:lolind32]
-platform = espressif32@1.11.2
+platform = espressif32@1.12.1
 board = lolin_d32
 framework = ${common.framework}
 lib_deps = ${common.lib_deps}
@@ -54,7 +54,7 @@ extra_scripts =
    scripts/makeweb.py

 [env:featheresp32]
-platform = espressif32@1.11.2
+platform = espressif32@1.12.1
 board = featheresp32
 framework = ${common.framework}
 lib_deps = ${common.lib_deps}
@@ -63,7 +63,7 @@ extra_scripts =
    scripts/makeweb.py

 [env:az-delivery-devkit-v4]
-platform = espressif32@1.11.2
+platform = espressif32@1.12.1
 board = az-delivery-devkit-v4
 framework = ${common.framework}
 lib_deps = ${common.lib_deps}
@@ -72,7 +72,7 @@ extra_scripts =
    scripts/makeweb.py

 [env:esp32doit-devkit-v1]
-platform = espressif32@1.11.2
+platform = espressif32@1.12.1
 board = esp32doit-devkit-v1
 framework = ${common.framework}
 lib_deps = ${common.lib_deps}
--- a/src/AmsData.cpp
+++ b/src/AmsData.cpp
@@ -18,7 +18,7 @@ AmsData::AmsData(int meterType, bool substituteMissing, HanReader& hanReader) {
 			extractFromAidon(hanReader, listSize, substituteMissing);
            break;
 		case METER_TYPE_KAMSTRUP:
-			extractFromKamstrup(hanReader, listSize);
+			extractFromKamstrup(hanReader, listSize, substituteMissing);
            break;

    }
@@ -176,13 +176,15 @@ void AmsData::extractFromAidon(HanReader& hanReader, int listSize, bool substitu
    }
 }

-void AmsData::extractFromKamstrup(HanReader& hanReader, int listSize) {
+void AmsData::extractFromKamstrup(HanReader& hanReader, int listSize, bool substituteMissing) {
    switch(listSize) {
+        case (int)Kamstrup::List3PhaseITShort:
        case (int)Kamstrup::List3PhaseShort:
            threePhase = true;
        case (int)Kamstrup::List1PhaseShort:
            listType = 2;
            break;
+        case (int)Kamstrup::List3PhaseITLong:
        case (int)Kamstrup::List3PhaseLong:
            threePhase = true;
        case (int)Kamstrup::List1PhaseLong:
@@ -191,6 +193,23 @@ void AmsData::extractFromKamstrup(HanReader& hanReader, int listSize) {
    }

    switch(listSize) {
+        case (int)Kamstrup::List1PhaseLong:
+            meterTimestamp        = hanReader.getTime(         (int)Kamstrup_List1Phase::MeterClock);
+            activeImportCounter   = ((double) hanReader.getInt((int)Kamstrup_List1Phase::CumulativeActiveImportEnergy)) / 100;
+            activeExportCounter   = ((double) hanReader.getInt((int)Kamstrup_List1Phase::CumulativeActiveExportEnergy)) / 100;
+            reactiveImportCounter = ((double) hanReader.getInt((int)Kamstrup_List1Phase::CumulativeReactiveImportEnergy)) / 100;
+            reactiveExportCounter = ((double) hanReader.getInt((int)Kamstrup_List1Phase::CumulativeReactiveExportEnergy)) / 100;
+        case (int)Kamstrup::List1PhaseShort:
+            listId                = hanReader.getString(       (int)Kamstrup_List1Phase::ListVersionIdentifier);
+            meterId               = hanReader.getString(       (int)Kamstrup_List1Phase::MeterID);
+            meterType             = hanReader.getString(       (int)Kamstrup_List1Phase::MeterType);
+            activeImportPower     = hanReader.getInt(          (int)Kamstrup_List1Phase::ActiveImportPower);
+            reactiveImportPower   = hanReader.getInt(          (int)Kamstrup_List1Phase::ReactiveImportPower);
+            activeExportPower     = hanReader.getInt(          (int)Kamstrup_List1Phase::ActiveExportPower);
+            reactiveExportPower   = hanReader.getInt(          (int)Kamstrup_List1Phase::ReactiveExportPower);
+            l1current             = ((double) hanReader.getInt((int)Kamstrup_List1Phase::CurrentL1)) / 100;
+            l1voltage             = hanReader.getInt(          (int)Kamstrup_List1Phase::VoltageL1);
+            break;
        case (int)Kamstrup::List3PhaseLong:
            meterTimestamp        = hanReader.getTime(         (int)Kamstrup_List3Phase::MeterClock);
            activeImportCounter   = ((double) hanReader.getInt((int)Kamstrup_List3Phase::CumulativeActiveImportEnergy)) / 100;
@@ -212,22 +231,29 @@ void AmsData::extractFromKamstrup(HanReader& hanReader, int listSize) {
            l2voltage             = hanReader.getInt(          (int)Kamstrup_List3Phase::VoltageL2);
            l3voltage             = hanReader.getInt(          (int)Kamstrup_List3Phase::VoltageL3);
            break;
-        case (int)Kamstrup::List1PhaseLong:
-            meterTimestamp        = hanReader.getTime(         (int)Kamstrup_List1Phase::MeterClock);
-            activeImportCounter   = ((double) hanReader.getInt((int)Kamstrup_List1Phase::CumulativeActiveImportEnergy)) / 100;
-            activeExportCounter   = ((double) hanReader.getInt((int)Kamstrup_List1Phase::CumulativeActiveExportEnergy)) / 100;
-            reactiveImportCounter = ((double) hanReader.getInt((int)Kamstrup_List1Phase::CumulativeReactiveImportEnergy)) / 100;
-            reactiveExportCounter = ((double) hanReader.getInt((int)Kamstrup_List1Phase::CumulativeReactiveExportEnergy)) / 100;
-        case (int)Kamstrup::List1PhaseShort:
-            listId                = hanReader.getString(       (int)Kamstrup_List1Phase::ListVersionIdentifier);
-            meterId               = hanReader.getString(       (int)Kamstrup_List1Phase::MeterID);
-            meterType             = hanReader.getString(       (int)Kamstrup_List1Phase::MeterType);
-            activeImportPower     = hanReader.getInt(          (int)Kamstrup_List1Phase::ActiveImportPower);
-            reactiveImportPower   = hanReader.getInt(          (int)Kamstrup_List1Phase::ReactiveImportPower);
-            activeExportPower     = hanReader.getInt(          (int)Kamstrup_List1Phase::ActiveExportPower);
-            reactiveExportPower   = hanReader.getInt(          (int)Kamstrup_List1Phase::ReactiveExportPower);
-            l1current             = ((double) hanReader.getInt((int)Kamstrup_List1Phase::CurrentL1)) / 100;
-            l1voltage             = hanReader.getInt(          (int)Kamstrup_List1Phase::VoltageL1);
+        case (int)Kamstrup::List3PhaseITLong:
+            meterTimestamp        = hanReader.getTime(         (int)Kamstrup_List3Phase::MeterClock);
+            activeImportCounter   = ((double) hanReader.getInt((int)Kamstrup_List3Phase::CumulativeActiveImportEnergy)) / 100;
+            activeExportCounter   = ((double) hanReader.getInt((int)Kamstrup_List3Phase::CumulativeActiveExportEnergy)) / 100;
+            reactiveImportCounter = ((double) hanReader.getInt((int)Kamstrup_List3Phase::CumulativeReactiveImportEnergy)) / 100;
+            reactiveExportCounter = ((double) hanReader.getInt((int)Kamstrup_List3Phase::CumulativeReactiveExportEnergy)) / 100;
+        case (int)Kamstrup::List3PhaseITShort:
+            listId                = hanReader.getString(       (int)Kamstrup_List3Phase::ListVersionIdentifier);
+            meterId               = hanReader.getString(       (int)Kamstrup_List3Phase::MeterID);
+            meterType             = hanReader.getString(       (int)Kamstrup_List3Phase::MeterType);
+            activeImportPower     = hanReader.getInt(          (int)Kamstrup_List3Phase::ActiveImportPower);
+            reactiveImportPower   = hanReader.getInt(          (int)Kamstrup_List3Phase::ReactiveImportPower);
+            activeExportPower     = hanReader.getInt(          (int)Kamstrup_List3Phase::ActiveExportPower);
+            reactiveExportPower   = hanReader.getInt(          (int)Kamstrup_List3Phase::ReactiveExportPower);
+            l1current             = ((double) hanReader.getInt((int)Kamstrup_List3Phase::CurrentL1)) / 100;
+            l2current             = 0;
+            l3current             = ((double) hanReader.getInt((int)Kamstrup_List3Phase::CurrentL3)) / 100;
+            l1voltage             = hanReader.getInt(          (int)Kamstrup_List3Phase::VoltageL1);
+            l2voltage             = hanReader.getInt(          (int)Kamstrup_List3Phase::VoltageL2);
+            l3voltage             = hanReader.getInt(          (int)Kamstrup_List3Phase::VoltageL3);
+            if(substituteMissing) {
+                l2current         = ((activeImportPower * sqrt(3)) - (l1voltage * l1current) - (l3voltage * l3current)) / l2voltage;
+            }
            break;
    }
 }
--- a/src/AmsData.h
+++ b/src/AmsData.h
@@ -61,7 +61,7 @@ private:

    void extractFromKaifa(HanReader& hanReader, int listSize);
    void extractFromAidon(HanReader& hanReader, int listSize, bool substituteMissing);
-    void extractFromKamstrup(HanReader& hanReader, int listSize);
+    void extractFromKamstrup(HanReader& hanReader, int listSize, bool substituteMissing);
 };

 #endif
--- a/src/web/AmsWebServer.cpp
+++ b/src/web/AmsWebServer.cpp
@@ -557,6 +557,14 @@ void AmsWebServer::handleSetup() {
 		server.sendHeader("Location", String("/"), true);
 		server.send (302, "text/plain", "");
 	} else {
+		config->setLedPin(0xFF);
+		config->setLedPinRed(0xFF);
+		config->setLedPinGreen(0xFF);
+		config->setLedPinBlue(0xFF);
+		config->setApPin(0xFF);
+		config->setTempSensorPin(0xFF);
+		config->setVccPin(0xFF);
+
 		config->setBoardType(server.arg("board").toInt());
 		config->setVccMultiplier(1.0);
 		config->setVccBootLimit(0);
--- a/web/application.js
+++ b/web/application.js
@@ -59,7 +59,7 @@ $(function() {
    // For config-meter
    $('.subtitute-dependent').on('change', function() {
        console.log("test");
-        if($('#meterType').val() == 2 && $('#distributionSystem').val() == 1) {
+        if(($('#meterType').val() == 2 || $('#meterType').val() == 3) && $('#distributionSystem').val() == 1) {
            $('#substitute').show();
        } else {
            $('#substitute').hide();
Author	SHA1	Message	Date
Gunnar Skjold	38eb2d8c19	Merge pull request #79 from gskjold/dev-v1.3.0 Dev v1.3.0	2020-06-06 20:30:47 +02:00
Gunnar Skjold	d95137adbc	Support for Kamstrup IT meters	2020-05-28 18:44:38 +02:00
Gunnar Skjold	cde3f80fca	Ensure that GPIO is correctly set after setup	2020-05-28 14:19:03 +02:00
Gunnar Skjold	cdc012743f	Changes for building on GitHub actions for all branches	2020-05-27 08:38:59 +02:00