knet-ore: STM32F103

心臓部は Neocatさんの
http://neocat.hatenablog.com/entry/20160110/1452407542
そのままです。
Nodemcu-Wroom2はDC50V配電のロガーと同じ形式。

/*
smartmeter logger for STM32duino
With NodeMCU and BP35A1 for use InfluxDB and Grafana

created by http://d.hatena.ne.jp/NeoCat/20160110/1452407542
           for Alduino and 7seg.LED
modified 04 Nov. 2018
       by knet-ore.no-ip.biz
           for SMT32duino and Nodemcu-firm.(WROOM-02 ESP01 etc.)
*/
//-----------------------------------------------------------
// Configurations
//-----------------------------------------------------------
#include "SPI.h"
#include "Wire.h"
const int chipSelect = 4;
const int pinCount = 2;
// B-route ID and Password (PANA authentication)
#define ID "000000##########################"
#define PASSWORD "############"

//Serial1 pins to BP35A1
// define txPin PA9   // -> BP35A1's RXD
// define rxPin PA10 // <- bp35a1="" br="" s="" txd="">
//Serial1 pins to Nodemcu
// define txPin PB10 // -> Nodemcu's RXD
// define rxPin PB11 // <- br="" nodemcu="" s="" txd="">
//Serial1 pins to monitor
// define txPin PA2   // -> Serialmonitor's RXD
// define rxPin PA3   // <- br="" s="" serialmonitor="" txd="">
//-----------------------------------------------------------
// data trasnfer buffer
//-----------------------------------------------------------
const int bufsize = 122;
char buf[bufsize];
const int size = bufsize - 1;

//-----------------------------------------------------------
// debug message utilities
//-----------------------------------------------------------
//#define DEBUG

char errbuf[80]; // error message buffer

#define error0(fmt) Serial3.println(F(fmt));
#define error1(fmt, str) Serial3.print(F(fmt)), Serial3.println(str)
#define error(fmt, ...) sprintf(errbuf, fmt "\r\n", __VA_ARGS__), Serial3.print(errbuf)
#define log0(fmt) Serial3.println(F(fmt))
#define log1(fmt, str) Serial3.print(F(fmt)), Serial3.println(str)
#define log(fmt, ...) sprintf(errbuf, fmt "\r\n", __VA_ARGS__), Serial3.print(errbuf)
#ifdef DEBUG
#define debug0(fmt, ...) Serial3.println(F(fmt))
#define debug1(fmt, str) Serial3.print(F(fmt)), Serial3.println(str)
#define debug(fmt, ...) sprintf(errbuf, fmt "\r\n", __VA_ARGS__), Serial3.print(errbuf)
#else
#define debug0(fmt)
#define debug1(fmt, str)
#define debug(fmt, ...)
#endif

//-----------------------------------------------------------
// BP35A1 communication class
//-----------------------------------------------------------
// Note: Before using this class, BP35A1 UART must be set to
//       9600 bps / 400us pause by "WUART 43" command to
//       ensure software Serial12 to work properly.
//-----------------------------------------------------------

このあと心臓部〜略
シリアルはSerial1

//-----------------------------------------------------------
// Main routine
//-----------------------------------------------------------
BP35A1 wisun; // BP35A1 instance
String Date;
String Wptime;
String Wntime;
int Wpwh;
int Wnwh;
void setup() {

Serial1.begin(9600);
Serial2.begin(9600);
Serial3.begin(9600);

Serial3.println("Start");

buf[size] = 0;

if (!wisun.setup(ID, PASSWORD, buf, size)) {
    error0("setup failed");
    Serial3.print("eeee");
    for (;;); // stop forever on error
}

Serial3.print("cccc");
while (!wisun.connect(buf, size))
    delay(5000); // reconnect on error after 5 sec

// check if the smart meter is in running state (EPC 0x80 = 0x30)
byte val = 0;
if (wisun.epc_get(0x80, buf, size))
    val = (wisun.hex(buf[28]) << 4) | wisun.hex(buf[29]);
if (val != 0x30)
    error0("SmartMeter is not working!");

// check if the smart meter is not in error state (EPC 0x88 = 0x42)
val = 0;
if (wisun.epc_get(0x88, buf, size))
    val = (wisun.hex(buf[28]) << 4) | wisun.hex(buf[29]);
if (val != 0x42)
    error0("SmartMeter is in error state!");

}

void read_date() {
String Year;
String Month;
String Day;
String Hour;
String Min;
String Sec;

long val = 0;
for (int i = 28; i < 32; i++) {
    val <<= 4;
    val |= wisun.hex(buf[i]);
}
Year = String(val);
val = 0;
for (int i = 32; i < 34; i++) {
    val <<= 4;
    val |= wisun.hex(buf[i]);
}
Month = String(val);
val = 0;
for (int i = 34; i < 36; i++) {
    val <<= 4;
    val |= wisun.hex(buf[i]);
}
Day = String(val);
val = 0;
for (int i = 36; i < 38; i++) {
    val <<= 4;
    val |= wisun.hex(buf[i]);
}
Hour = String(val);
val = 0;
for (int i = 38; i < 40; i++) {
    val <<= 4;
    val |= wisun.hex(buf[i]);
}
Min = String(val);
val = 0;
for (int i = 40; i < 42; i++) {
    val <<= 4;
    val |= wisun.hex(buf[i]);
}
Sec = String(val);
Date = (Year + "/" + Month + "/" + Day + " " + Hour + ":" + Min + ":" + Sec);
}

void loop() {
static int err_cnt = 0;

log0("getting EPC 0xe7 ...");
bool ret = wisun.epc_get(0xe7, buf, size);
if (ret) {
    // convert hex string into long not unsigned-long
    long val = 0;
    for (int i = 28; buf[i]; i++) {
      val <<= 4;
      val |= wisun.hex(buf[i]);
    }
    // print immediate power value to Nodemcu and Serialmonitor
    Serial3.print(F("Power = "));
    Serial3.print(val);
    Serial3.println(F(" Watt"));
    Serial3.print("\r\n");

    Serial2.print("\r\n");
    Serial2.print("a1=");
    Serial2.print(val);
    Serial2.print("\r\n");

    log0("getting EPC 0xea ...");
    bool ret = wisun.epc_get(0xea, buf, size);
    if (ret) {

      read_date();
      Serial3.print(Date);
      Serial3.print("\r\n");

      val = 0;
      for (int i = 42; buf[i]; i++) {
        val <<= 4;
        val |= wisun.hex(buf[i]);
      }
      Serial3.print(F("+Power = "));
      Serial3.print(-Wpwh+val);
      Serial3.println(F(" kWh"));
      Serial3.print("\r\n");
      if (Wptime != Date) {
        Serial2.print("\r\n");
        Serial2.print("a2=");
        Serial2.print(val);
        Serial2.print("\r\n");
        Wptime = Date;
        Wpwh=val;
      }
      log0("getting EPC 0xeb ...");
      bool ret = wisun.epc_get(0xeb, buf, size);
      if (ret) {
        long val = 0;
        for (int i = 28; i < 42; i++) {
          val <<= 4;
          val |= wisun.hex(buf[i]);
        }

        read_date();
        Serial3.print(Date);
        Serial3.print("\r\n");

        val = 0;
        for (int i = 42; buf[i]; i++) {
          val <<= 4;
          val |= wisun.hex(buf[i]);
        }
        Serial3.print(F("-Power = "));
        Serial3.print(Wnwh-val);
        Serial3.println(F(" kWh"));
        Serial3.print("\r\n");
        Serial3.println(Date);
        Serial3.print("\r\n");
        if (Wntime != Date) {
          Serial2.print("\r\n");
          Serial2.print("a3=");
          Serial2.print(-val);
          Serial2.print("\r\n");
          Wntime = Date;
          Wnwh=val;
        }
        err_cnt = 0;
      } else {
        err_cnt++;
        error0("EPC get failed");
        if (err_cnt >= 5) {
          err_cnt = 0;
          Serial3.print("cccc");
          Serial3.print("\r\n");
          log0("reconnecting ...");
          wisun.disconnect(buf, size);
          wisun.connect(buf, size);
        }
      }
      bool ok;
      unsigned long end = millis() + 10000; // wait 10 sec
      while (long(millis() - end) < 0) {
        //    wisun.wait_udp(buf, size, 3, ok);
      }
    }
}
}