Bonjour @Charles ,
Le module utilisé était un wemod teleinfo qui fonctionnait très bien connecté au linky de ma précédente maison (monophasé HC/HC). Le code était écrit grâce à ton aide.
En voici le code injecté : teleinfoLinky.txt
#include <LibTeleinfo.h>
// Parsing JSON
#include <ArduinoJson.h>
const size_t capacity = JSON_OBJECT_SIZE(4) + JSON_ARRAY_SIZE(4) + 60;
String chaineJSONenvoyee;
float frequenceInterro=60;
String commentairePutWS="";
int PAC = 0;
#define SERIAL_DEBUG Serial
#define SERIAL_TIC Serial1
// Teleinfo RXD pin is connected to ESP32-PICO-V3-02 GPIO8
#define TIC_RX_PIN 23
_Mode_e tinfo_mode = TINFO_MODE_HISTORIQUE;
//_Mode_e tinfo_mode = TINFO_MODE_STANDARD;
TInfo tinfo; // Teleinfo object
// Wakeup de 5 secondes
#define uS_TO_S_FACTOR 1000000ULL /* Conversion factor for micro seconds to seconds */
#define TIME_TO_SLEEP 5 /* Time ESP32 will go to sleep (in seconds) */
#define LEDPIN LED_BUILTIN
// Uptime timer
boolean tick1sec=0;// one for interrupt, don't mess with
unsigned long uptime=0; // save value we can use in sketch even if we're interrupted
String sendJSON(ValueList * me, boolean all){
bool firstdatacomplete = true;
bool firstdataenvoyee = true;
String chaineJSONenvoyee = "";
String chaineJSONcomplete = "";
String Element_Valeur = "";
String separateur = ",";
String sep;
// Got at least one ?
if (me) {
PAC = 0;
// Json start
chaineJSONenvoyee = "{\"commentaire\":" + "\"" + commentairePutWS + "\"";
chaineJSONcomplete = "{\"commentaire\":" + "\"" + commentairePutWS + "\"";
// Loop thru the node
while (me->next) {
// go to next node
me = me->next;
// uniquement sur les nouvelles valeurs ou celles modifiées
// sauf si explicitement demandé toutes
if ( all || ( me->flags & (TINFO_FLAGS_UPDATED | TINFO_FLAGS_ADDED) ) ) {
//Serial.println("|"+String(me->name)+"|") ;
/*
Serial.print(F("\"")) ;
Serial.print(me->name) ;
Serial.print(F("\":")) ;
*/
// we have at least something ?
if (me->value && strlen(me->value))
{
boolean isNumber = true;
uint8_t c;
char * p = me->value;
// check if value is number
while (*p && isNumber) {
if ( *p < '0' || *p > '9' )
isNumber = false;
p++;
}
// this will add "" on not number values
if (!isNumber) {
Element_Valeur = "\"" + String(me->name) + "\":" + "\"" + String(me->value) + "\"";
}
// this will remove leading zero on numbers
else
//Serial.print(atol(me->value));
Element_Valeur = "\"" + String(me->name) + "\":" + atol(me->value);
}
if (String(me->name) != "MSG1" &&
String(me->name) != "PJOURF+1" &&
String(me->name) != "ADSC" &&
String(me->name) != "VTIC" &&
String(me->name) != "NGTF" &&
String(me->name) != "LTARF" &&
String(me->name) != "EAST" &&
String(me->name) != "EASF01" &&
String(me->name) != "EASF02" &&
String(me->name) != "EASF03" &&
String(me->name) != "EASF04" &&
String(me->name) != "EASF05" &&
String(me->name) != "EASF06" &&
String(me->name) != "EASF07" &&
String(me->name) != "EASF08" &&
String(me->name) != "EASF09" &&
String(me->name) != "EASF10" &&
String(me->name) != "EASD01" &&
String(me->name) != "EASD02" &&
String(me->name) != "EASD03" &&
String(me->name) != "EASD04" &&
String(me->name) != "EAIT" &&
String(me->name) != "ERQ1" &&
String(me->name) != "ERQ2" &&
String(me->name) != "ERQ3" &&
String(me->name) != "ERQ4" &&
String(me->name) != "IRMS1" &&
String(me->name) != "URMS1" &&
String(me->name) != "PREF" &&
String(me->name) != "PCOUP" &&
String(me->name) != "PREF" &&
String(me->name) != "CCASN" &&
String(me->name) != "CCASN-1" &&
String(me->name) != "CCAIN" &&
String(me->name) != "CCAIN-1" &&
//String(me->name) != "UMOY1" &&
String(me->name) != "STGE" &&
String(me->name) != "PRM" &&
String(me->name) != "RELAIS" &&
String(me->name) != "NTARF" &&
String(me->name) != "NJOURF" &&
String(me->name) != "NJOURF+1"
){
chaineJSONenvoyee = chaineJSONenvoyee + separateur + Element_Valeur;
}
chaineJSONcomplete = chaineJSONcomplete + separateur + Element_Valeur;
}
}
// Json end
//Serial.println(F("}")) ;
chaineJSONenvoyee = chaineJSONenvoyee + "}";
chaineJSONcomplete = chaineJSONcomplete + "}";
Serial.println("chaineJSONcomplete = " + chaineJSONcomplete );
Serial.println("chaineJSONenvoyee = " + chaineJSONenvoyee );
return chaineJSONcomplete;
}
}
/* ======================================================================
Function: NewFrame
Purpose : callback when we received a complete teleinfo frame
Input : linked list pointer on the concerned data
Output : -
Comments: -
====================================================================== */
void NewFrame(ValueList * me){
SERIAL_DEBUG.println("NewFrame - uptime=" + String(uptime));
if (tick1sec) {
concatlog("NewFrame - uptime=" + String(uptime));
chaineJSONenvoyee = sendJSON(me, true);
postconsoWS(chaineJSONenvoyee);
postlogsindb();
logcycle="";
ledClignotte();
tick1sec = false;
}
}
/* ======================================================================
Function: UpdatedFrame
Purpose : callback when we received a complete teleinfo frame
Input : linked list pointer on the concerned data
Output : -
Comments: it's called only if one data in the frame is different than
the previous frame
====================================================================== */
void UpdatedFrame(ValueList * me){
SERIAL_DEBUG.println("UpdatedFrame - tick1sec=" + String(tick1sec));
if (tick1sec) {
concatlog("UpdatedFrame - uptime=" + String(uptime));
chaineJSONenvoyee = sendJSON(me, true);
postconsoWS(chaineJSONenvoyee);
postlogsindb();
logcycle="";
ledClignotte();
tick1sec = false;
}
}
/* ======================================================================
Function: initSerial
Purpose : Configure (or reconfigure Serial Port)
Input : -
Output : -
Comments: -
====================================================================== */
void initSerial(){
// Cleanup
SERIAL_TIC.flush();
SERIAL_TIC.end();
// Configure Teleinfo
SERIAL_DEBUG.printf_P(PSTR("TIC RX=GPIO%d Mode:"), TIC_RX_PIN);
SERIAL_TIC.begin(tinfo_mode == TINFO_MODE_HISTORIQUE ? 1200 : 9600, SERIAL_7E1, TIC_RX_PIN);
if ( tinfo_mode == TINFO_MODE_HISTORIQUE ) {
SERIAL_DEBUG.println(F("Historique"));
} else {
SERIAL_DEBUG.println(F("Standard"));
}
}
/* ======================================================================
Function: ledOff
Purpose : Setup I/O for RGB Led to be OFF
Input : -
Output : -
Comments: -
====================================================================== */
void ledClignotte(){
digitalWrite(LED_BUILTIN, HIGH); // turn the LED on (HIGH is the voltage level)
delay(1000); // wait for a second
digitalWrite(LED_BUILTIN, LOW); // turn the LED off by making the voltage LOW
}
/* ======================================================================
Function: setup
Purpose : Setup I/O and other one time startup stuff
Input : -
Output : -
Comments: -
====================================================================== */
void setup(){
SERIAL_DEBUG.begin(115200);
pinMode(LED_BUILTIN, OUTPUT);
// Serial, pour le debug
SERIAL_DEBUG.println(F("\r\n\r\n"));
SERIAL_DEBUG.println(F("================================================="));
SERIAL_DEBUG.println(F(" D1 Mini ESP32 - Teleinfo Lynky Alim WS "));
SERIAL_DEBUG.println(F("================================================="));
SERIAL_DEBUG.println(F("\r\n"));
SERIAL_DEBUG.println("[Setup] Gestion du Wifi avec WifiManager");
WifiGestion();
//SERIAL_DEBUG.println("[Setup] Récupération des paramètres de cet arduino : Fréquence d'interrogation et du commentaire de prise de mesure");
//GET_params_arduino();
SERIAL_DEBUG.println("[Setup] Alimentation des logs en BDD à travers le service REST (Requête POST)");
SERIAL_DEBUG.println("-------------------------------------------------------------------------------");
concatlog("[Setup] Alimentation des logs en BDD (Req POST)");
postlogsindb();
// Init Serial Port
initSerial();
// Init teleinfo
tinfo.init(tinfo_mode);
// Attacher les callback dont nous avons besoin
// pour cette demo, ADPS et TRAME modifiée
tinfo.attachUpdatedFrame(UpdatedFrame);
tinfo.attachNewFrame(NewFrame);
}
/* ======================================================================
Function: loop
Purpose : infinite loop main code
Input : -
Output : -
Comments: -
====================================================================== */
void loop()
{
static char c;
static unsigned long previousMillis = 0;
static uint8_t buttonState = 0;
static unsigned long lastDebounceTime = 0;
unsigned long currentMillis = millis();
/*
// Avons nous recu un ticker de seconde?
if (tick1sec) {
tick1sec = false;
uptime++;
}
*/
// On a reçu un caractère ?
if ( SERIAL_TIC.available() ) {
// Le lire
c = SERIAL_TIC.read();
// Gérer
tinfo.process(c);
// L'affcher dans la console
if (c==TINFO_STX) {
SERIAL_DEBUG.print("<STX>");
} else if (c==TINFO_ETX) {
SERIAL_DEBUG.print("<ETX>");
} else if (c==TINFO_HT) {
SERIAL_DEBUG.print("<TAB>");
} else {
SERIAL_DEBUG.print(c);
}
}
//SERIAL_DEBUG.println("currentMillis=" + String(currentMillis) + "previousMillis=" + String(previousMillis));
if (currentMillis - previousMillis > 60000 ) {
SERIAL_DEBUG.println("IL FAUT ENREGISTRER UNE MESURE");
// save the last time you blinked the LED
previousMillis = currentMillis;
tick1sec = true;
}
}
Suite à la proposition de @Nicolas-Bernaerts, j'ai commandé un Denky D4 1.3a mais ne connaissant pas du tout Tasmota, je me heurte à la configuration. Quel test rapide puis-je faire pour vérifier les valeurs récupérées du flux téléinfo ? (A terme, l'idée est de pouvoir injecter les consos de mes 3 phases toutes les minutes à ma base de données mySql (hébergée par AlwaysData)
