Myu: 12月 2025

2025年12月24日水曜日

OpenAIのwhisperで、処理した音声認識テキストを表示するアプリ（Qt版）

OpenAIのwhisperで音声認識処理すると.srtというファイルができますが。これと音声ファイル（mp3)を一緒のフォルダに置いて使えるようにしてみました。ちょうど、映画の字幕のような感じで表示できます。-smallのオプションで、処理したものだと、たまに認識が間違って、若干ずれることもありますが、日本語以外等でいろいろ使えそうです。

2025年12月22日月曜日

灯油残量 WIFI　OLEDで表示

ewp32-c3を表示用に使ってみた、センサーからのデータを蓄積しているraspiからWIFIで読み出すようにした。

#include <Wire.h>
#include <Adafruit_SSD1306.h>
#include <WiFi.h>
#include <HTTPClient.h>
#include <ArduinoJson.h>              // ← これがJSON用
#include <U8g2_for_Adafruit_GFX.h>    // 文字・描画
#include <Adafruit_GFX.h>
#include <math.h>
#include <Preferences.h>
#include <WebServer.h>

Preferences prefs;
WebServer server(80);
String ssid,ssid2,pass,rurl;
struct WifiCred {
  String ssid;
  String pass;
};
WifiCred wifiList[2];

U8G2_FOR_ADAFRUIT_GFX u8g2;
Adafruit_SSD1306 display(128, 64, &Wire, -1);
const int GX = 0;
const int GY = 14;     // ← 上に詰める
const int GW = 128;
const int GH = 50;     // ← 縦を大きく
float prevFiltered = 0.0;
float alpha = 0.07;
float threshold = 20;
float aval=1.4;
float eval=2.05;
float hval=51;
float jval=0.6;
int lval=45;
float d1=0;
float d2=0;
float d3=0;
float d4=0;

void drawLineStyled(
  int x1, int y1, int x2, int y2, uint8_t style
) {
  if (style == 0) {
    display.drawLine(x1, y1, x2, y2, SSD1306_WHITE); // 実線
  } else if (style == 1) {
    for (int i = 0; i < 6; i++) {                    // 点線
      display.drawPixel(
        x1 + (x2 - x1) * i / 6,
        y1 + (y2 - y1) * i / 6,
        SSD1306_WHITE
      );
    }
  } else if (style == 2) {
    for (int i = 0; i < 6; i += 2) {                 // 破線
      display.drawLine(
        x1 + (x2 - x1) * i / 6,
        y1 + (y2 - y1) * i / 6,
        x1 + (x2 - x1) * (i + 1) / 6,
        y1 + (y2 - y1) * (i + 1) / 6,
        SSD1306_WHITE
      );
    }
  }
}

void setup() {
  loadConfig();
  Wire.begin(4, 5);
  display.begin(SSD1306_SWITCHCAPVCC, 0x3C);
  u8g2.begin(display);      
  connectBestWiFi();
  int cnt = 0;
  while (WiFi.status() != WL_CONNECTED) {
   delay(500);
   displayMsg("Wifi Connecting..");
   cnt++;
   if (cnt >= 10) {   // 500ms × 10 = 約5秒
    startAPMode();  
    return;          // setup()ならreturnでOK
   }
  }
  displayMsg("Wifi Connected!!");
  // HTTPアクセス
  delay(100); 
  loadParams();
  delay(100);
  loadNaedoko();

displayMsg("data loading..");

String url = "http://"+rurl+"/py/cap?cap=list"+String(lval);
   String fullUrl = "http://" + rurl + "/api/get_params";
   Serial.begin(115200); 
   Serial.print("fullUrl=[");
   Serial.print(fullUrl);
   Serial.println("]");
   Serial.print("length=");
   Serial.println(fullUrl.length());

HTTPClient http;
   http.begin(url);
   int httpCode = http.GET();
   if (httpCode > 0) {
    String payload = http.getString();
    StaticJsonDocument<4096> doc;
    if (deserializeJson(doc, payload)) {
    displayMsg("JSON error");
    return;
    }

JsonArray arr = doc.as<JsonArray>();
int n = arr.size();
if (n == 0) return;
JsonObject latest = arr[n - 1];
String datetime = latest["datetime"];
float cap  = latest["cap"];
float cap2 = latest["cap2"];
float temp=latest["temp"];
int hpa=latest["hpa"];
float hum=latest["hum"];
float oil_cm=0;
for (int i = 0; i < n; i++) {
 oil_cm=cap2cmConv(arr[i]["cap"],arr[i]["cap2"],arr[i]["temp"],arr[i]["hum"]);
}
display.clearDisplay();

u8g2.setFont(u8g2_font_9x15_tf);
char line[32];
String mdhm = datetime.substring(8, 10) + " " + datetime.substring(11, 16);
sprintf(line, "%s H%.0f%%",mdhm.c_str(),hum);
u8g2.drawStr(0, 14, line);

u8g2.setFont(u8g2_font_6x13_tf);
char line2[15];
sprintf(line2, "%dhPa N%.0f %.0f %.0f %.0f",  (int)(hpa + 0.5),d1,d2,d3,d4);
u8g2.drawStr(3,62, line2);

u8g2.setFont(u8g2_font_10x20_tf);
char line3[15];
sprintf(line3, "%.0fcm%d%% T%.0f",  oil_cm,(int)(oil_cm/60.0*100),temp);
u8g2.drawStr(5, 30, line3);

for (int i = 1; i < n; i++) {
  JsonObject p0 = arr[i-1];
  JsonObject p1 = arr[i];
  int x1 = map(i-1, 0, n-1, GX, GX+GW);
  int x2 = map(i,   0, n-1, GX, GX+GW); 
  // hpa-950
  drawLineStyled(
    x1, yMap(p0["hpa"].as<float>()-950, 50, 100),
    x2, yMap(p1["hpa"].as<float>()-950, 50, 100),
    0
  );
 }
 display.display();
} else {
 displayMsg("request failed");
 startAPMode();
 return;
}
  http.end();
}

void displayMsg(char *msg){
     display.clearDisplay();
     u8g2.setFont(u8g2_font_9x15_tf);
     u8g2.drawStr(0,10,msg);
     display.display();
}

void loop(){
 server.handleClient();
}

int yMap(float v, float minV, float maxV) {
  if (v < minV) v = minV;
  if (v > maxV) v = maxV;
  return GY + GH - (v - minV) * GH / (maxV - minV);
}

float cap2cmConv(float cap, float cap2, float ondo, float hum) {
    if (cap == 0) return 0.0;

//float rawValue = 1.4 * (1/cap - 2.05/cap2) * 100000 + 51 - 0.6 * hum;
    float rawValue = aval * (1/cap - eval/cap2) * 100000 + hval - jval * hum;
    // 初回はそのまま
    if (prevFiltered ==0.0) {
        prevFiltered = rawValue;
        return rawValue;
    }
    // 給油などの急増は即追従
    if (rawValue - prevFiltered > threshold) {
        prevFiltered = rawValue;
    } else {
        prevFiltered = alpha * rawValue + (1 - alpha) * prevFiltered;
    }

return prevFiltered;
}

const int WIFI_NUM = 2;

void connectBestWiFi() {
  int n = WiFi.scanNetworks();

int best = -1;
  int bestRssi = -1000;

for (int i = 0; i < n; i++) {
    for (int j = 0; j < WIFI_NUM; j++) {
      if (WiFi.SSID(i) == wifiList[j].ssid) {
        int rssi = WiFi.RSSI(i);
        if (rssi > bestRssi) {
          bestRssi = rssi;
          best = j;
        }
      }
    }
  }

if (best >= 0) {
    WiFi.begin(wifiList[best].ssid, wifiList[best].pass);
  }
}

void loadParams() {
  HTTPClient http2;
  http2.begin("http://"+rurl+"/api/get_params");
  int httpCode = http2.GET();
  if (httpCode == 200) {
    String payload2 = http2.getString();
    StaticJsonDocument<384> doc2;  
    DeserializationError error = deserializeJson(doc2, payload2);
    if (!error) {
      aval      = doc2["aval"].as<float>()      ?: 1.4;
      eval     = doc2["eval"].as<float>()      ?: 2.05;
      hval      = doc2["hval"].as<int>()        ?: 51;
      jval      = doc2["jval"].as<float>()      ?: 0.6;
      alpha     = doc2["alpha"].as<float>()     ?: 0.07;
      threshold = doc2["threshold"].as<int>()   ?: 20;
      lval      = doc2["lval"].as<int>()        ?: 45;
    } else {
     // Serial.println("JSON parse error");
    }
  } else {
   // Serial.println("HTTP error");
   startAPMode(); //if can't access,start apMode.
  }
  http2.end();
}

void loadNaedoko() {
  HTTPClient http3;
  http3.begin("http://192.168.1.30/data");
  int httpCode = http3.GET();
  if (httpCode == 200) {
    String payload3 = http3.getString();
    StaticJsonDocument<384> doc3;  
    DeserializationError error = deserializeJson(doc3, payload3);
    if (!error) {
      d1      = doc3["d1"].as<float>()      ?: 0;
      d2     = doc3["d2"].as<float>()      ?: 0;
      d3      = doc3["d3"].as<int>()        ?: 0;
      d4      = doc3["d4"].as<int>()        ?: 0;     
    } 
  } 
  http3.end();
}

void saveConfig(String s,String s2, String p,String rurl) {
  prefs.begin("config", false);
  prefs.putString("ssid", s);
  prefs.putString("ssid2", s2);
  prefs.putString("pass", p);
  prefs.putString("rurl", rurl);
  prefs.end();
}

void loadConfig() {
  prefs.begin("config", true);
  ssid = prefs.getString("ssid", "");
  ssid2 = prefs.getString("ssid2", "");
  pass = prefs.getString("pass", "");
  rurl = prefs.getString("rurl", "");
  rurl.trim();
  rurl.replace("\r", "");      // CR除去
  rurl.replace("\n", "");      // LF除去
  prefs.end();

wifiList[0] = {ssid, pass};
wifiList[1] = {ssid2, pass};

}

void handleRoot() {
  String page = R"rawliteral(
    <html>
    <body>
      <h2>WiFi Setup</h2>
      <form action="/save" method="post">
        SSID:<br>
        <input name="ssid"><br>
        SSID2:<br>
        <input name="ssid2"><br>
        PASS:<br>
        <input name="pass" type="password"><br>
        RaspiURL(ex.192.168.*.*:8080):<br>
        <input name="rurl"><br><br>
        <input type="submit" value="Save">
      </form>
    </body>
    </html>
  )rawliteral";

server.send(200, "text/html", page);
}

void handleSave() {
  String newSsid = server.arg("ssid");
  String newSsid2 = server.arg("ssid2");
  String newPass = server.arg("pass");
  String newRurl = server.arg("rurl");
  saveConfig(newSsid, newSsid2,newPass,newRurl);

server.send(200, "text/html", "Saved. Rebooting...");
  delay(1000);
  ESP.restart();
}

void startAPMode() {
  WiFi.mode(WIFI_AP);
  WiFi.softAP("ESP32-Setup", "12345678");

server.on("/", handleRoot);
  server.on("/save", HTTP_POST, handleSave);
  server.begin();

display.clearDisplay();
    u8g2.setFont(u8g2_font_6x10_tf);
    u8g2.drawStr(0, 14, "SSID:ESP32-Setup");
    u8g2.drawStr(0, 28, "Pass:12345678");
    u8g2.drawStr(0, 42, "access192.168.4.1");
    display.display();

//Serial.println("AP Mode");
  //Serial.println(WiFi.softAPIP());  // 192.168.4.1
}

　とりあえず、補正計算した残量に加えて、気温・気圧表示し、気圧変化のグラフも表示させてみた。スイッチオンで手軽に見ることができて便利。降圧コンバータが容量大きすぎてもったいないので、これは、１２Vバッテリーを５Vモーターでドリルに使うことにした。代わりに小型のコンバータにして、さらに小さいケースに後日変更。

　※灯油残量とは関係ないけれど、苗床ヒーターの温度調整Esp32の温度データもついでに表示できるように、コードを追加した。

※その後、コードにSSIDを３つ登録して、電波が一番強いところに接続できるようにしました。

※変換のための計算パラメータも、raspiにあるデータに追随するようにした。また、raspiのURL、SSIDとパスワードなどもPreferencesに保存可能にした。（アクセスエラーのとき、設定できるようにサーバモードになるようにした。）

2025年12月21日日曜日

pic16f628AによるDFplayer改良

EEPROMで、どの番号まで再生したか、不揮発メモリに記録できるようにした。フォルダは01のみとした。以前のフォルダ番号用スイッチを制御用（1回タッチで番号を進める、２回タッチで番号を減らす）とし、ファイル番号用スイッチは、１回目の連続タッチで１０の位、２回目の連続タッチで１の位を指定して入力できるようにした。（ただし、１０未満は、１回目のタッチを１０回タッチすると０になるようにした。）

dfPlayer、しかもPIC利用だとやはり、かなり制限があって、コーディングも難しかった。

#define _XTAL_FREQ 4000000
#pragma config FOSC = INTOSCCLK // Oscillator Selection bits (INTOSC oscillator: CLKOUT function on RA6/OSC2/CLKOUT pin, I/O function on RA7/OSC1/CLKIN)
#pragma config WDTE = OFF
#pragma config PWRTE = OFF
#pragma config MCLRE = OFF
#pragma config BOREN = ON
#pragma config LVP = ON
#pragma config CPD = OFF
#pragma config CP = OFF

#include <xc.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>

void dfply(char, unsigned char);
void dfply_(char, unsigned char,unsigned char) ;

void convertToMorse(unsigned char,char * ) ;
void playMorse(char* ) ;
void dash();
void dot();
void play(unsigned char ,unsigned char);
int dfply_qry(char, unsigned char, unsigned char );

unsigned char flg=0;
unsigned char cnum=0;  
unsigned char cnumA=0;
unsigned char cketa=2;
unsigned char cfnum=0; //command
unsigned char shokaif=1;

int main(int argc, char** argv) {
    
    TRISA = 0b00011000;  //  RA3,4 input Ok
    TRISB = 0b00000010 ; // RB1(RX)はINPUT　RB2(TX)とその他は全てOUTPUT
    PORTA = 0b00000000;
    PCON   = 0b00001000 ;//4MHz 内部クロックは４ＭＨｚとする
    CMCON  = 0b00000111 ;     // コンパレータは使用しない(RA0-RA4はデジタルピンで使用)
    VRCON  = 0b00000000 ;     // RA2はデジタルピンで使用する            
    TXSTA = 0b00100100; // 高速ボーレート、送信有効  
    RCSTA = 0b10010000; // 受信有効、シリアルポート有効
    SPBRG=25; //クロック数4Mhzなら：25、8Mhz：51、16:Mhz：103、32Mhz:207
    __delay_ms(2000);
    dfply(0x06, 0x14);  // vol 20
    __delay_ms(1000);   
 
cnumA = eeprom_read(0x00);
if (cnumA == 0xFF) {
    cnumA = 1;
    eeprom_write(0x00, 1);
    cketa=0;
}
    
   while (1) {
   //RA2 LED          
    if(flg==0 ){  //最初のみ点滅
              RA2=1;
              __delay_ms(1);
              RA2=0;
             __delay_ms(1000);
          }       
          
    while (RA3==1 && RA4==0 ){  //長押し　command
         cfnum++;
         dash();      
          __delay_ms(200);
          if(cfnum==1){
              cnumA++;
          }else if(cfnum==2){
              cnumA=cnumA-cfnum;
          }
          cketa=2;          
     }

while (RA3 == 0 && RA4==1){  //長押し　ファイルカウント 1の位
         cnum++;
         dot();
         flg=1;
         __delay_ms(200);
         if(cnum==10){cnum=0;} //十の位が０にしたいとき         
         if(cketa==0&&cnumA>0){cnumA=0;} //dotにふれたら、cnumAは初期化　ただし、累積中はそのまま
      }   
 
     if(flg){  
        flg=0; 
         __delay_ms(500);
         cnumA=cnumA*10+cnum;
         cketa++;
         cnum=0;
      }
        
      if(cketa==2||shokaif==1){
         cketa=0;
         cfnum=0;         
         __delay_ms(500);
         char morseCode[15];
         convertToMorse(cnumA,morseCode);
         playMorse(morseCode);   
         __delay_ms(100);
             
         if(shokaif==0){  //立ち上げ時は、再生しないように
                play(1,cnumA);               
                __delay_ms(100);
                eeprom_write(0x00, cnumA);     
                __delay_ms(100);
           }
         shokaif=0;      
      
        }  
      __delay_ms(300);
   }
   return (EXIT_SUCCESS);
}

void play(unsigned char cfnum_,unsigned char cnum_){
           dfply_(0x0f, cnum_, cfnum_); // 初期化再生
           dfply(0x0d, 0); // 再生コマンド
    }

void dfply(char cmd, unsigned char parameter){
    dfply_(cmd,parameter,0);    
}

void dfply_(char cmd, unsigned char file, unsigned char folder)
{
    while (!TXIF); TXREG = 0x7E;
    while (!TRMT);

while (!TXIF); TXREG = 0xFF;
    while (!TRMT);

while (!TXIF); TXREG = 0x06;
    while (!TRMT);

while (!TXIF); TXREG = cmd;
    while (!TRMT);

while (!TXIF); TXREG = 0x00;     // Param MSB
    while (!TRMT);

while (!TXIF); TXREG = folder;  // フォルダ
    while (!TRMT);

while (!TXIF); TXREG = file;    // ファイル
    while (!TRMT);

while (!TXIF); TXREG = 0xEF;
    while (!TRMT);
}

void dot() {
    RA2=1;
    __delay_ms(100);
    RA2=0;
    __delay_ms(100);
}

void dash() {
    RA2=1;
    __delay_ms(300);
    RA2=0;
    __delay_ms(100);
}

void playMorse(char* morseCode) {
int i = 0; // ループカウンタを初期化
while (morseCode[i] != '\0') { // 終端文字である '\0' をチェック
    if (morseCode[i] == '.') {
        dot(); // 点を表す関数を呼び出し
    } else if (morseCode[i] == '-') {
        dash(); // 線を表す関数を呼び出し
    } else if (morseCode[i] == ' ') {
        __delay_ms(300); // スペースの場合は遅延
    }
    i++; // 次の文字へ進む
}
}

void convertToMorse(unsigned char num, char* result) {
    // Morse code for numbers 0-9
    char* morseNumbers[] = {
        "-----",  // 0
        ".----",  // 1
        "..---",  // 2
        "...--",  // 3
        "....-",  // 4
        ".....",  // 5
        "-....",  // 6
        "--...",  // 7
        "---..",  // 8
        "----."   // 9
    };

char temp[20] = "";  // 一時的な結果を保存する配列
    result[0] = '\0';    // 結果を初期化

// 処理対象の数字が 0 の場合は特別扱い
    if (num == 0) {
        strcpy(result, morseNumbers[0]);
        return;
    }

while (num > 0) {
        int digit = num % 10;           // 現在の桁を取得
        strcpy(temp, morseNumbers[digit]); // 桁のモールスコードを取得
        strcat(temp, " ");              // 桁ごとにスペースを追加
        strcat(temp, result);           // 既存の結果に連結
        strcpy(result, temp);           // 結果を更新
        num /= 10;                      // 次の桁へ
    }
}

2025年12月19日金曜日

OpenAIのWhisperがローカル実行でかなりの認識率

最近は、音声認識が、無料でしかもローカル実行で正確に認識できるのには驚きました。コマンドラインで実行できるので、アプリの中で活用できてとても便利だと思います。

バッチファイルです。途中のパスを通すところは、ffmpegのあるパスです。

radio2text.bat

.m4aなど、いったん.wavに変換してから処理しています。

LANGはenが英語、jaが日本語　--languageないとどちらも出します

--output_format srt で時間付き字幕

Qt使えば

if (line.contains(QRegularExpression("[ぁ-んァ-ン一-龯]"))) {

// 日本語

} else {

// 英語

}

のように分けたりもできそうです。

※なお、準備としては ffmpeg以外に、python3.9以上で

pip install -U openai-whisper

をインストールするだけで動くようです。

2025年12月17日水曜日

ESP32灯油残量センサー　実験

まだ、測定値が安定しないので、新たに容量カウント補正用のセンサ（タンク入口までの短い線）を追加して、しばらくデータをとってみることにした。追加PINはGPIO15。esp32から外に出ている線がぬれるだけで、測定値に影響するので、補正できないか試す予定。

*******esp32
  #include <WiFi.h>
#include <WiFiClient.h>
#include "esp_sleep.h"
#include <Wire.h>
#include "SparkFunBME280.h"

#define TOUCH_PIN 12
#define TOUCH_PIN2 15
#define LED_PIN 2
#define SLEEP_SECONDS 21600   // 6時間

#define SERIAL_EN 0   // 1=debug, 0=off
#if SERIAL_EN
  #define S_BEGIN(...)   Serial.begin(__VA_ARGS__)
  #define S_PRINT(...)   Serial.print(__VA_ARGS__)
  #define S_PRINTLN(...) Serial.println(__VA_ARGS__)
    #define S_PRINTF(...)  Serial.printf(__VA_ARGS__)
  #define S_END(...) Serial.end()
#else
  #define S_BEGIN(...)
  #define S_PRINT(...)
  #define S_PRINTLN(...)
    #define S_PRINTF(...)
  #define S_END(...)
#endif

const char* ssid     = "***";
const char* password = "********";

const char* host = "*.*.*.*";  // Raspberry Pi IP
const int   port = 8888;
const char* path = "/py/cap";

String url;
String cprint;

BME280 bme;

void setup() {

S_BEGIN(115200);

delay(100);
   uint16_t capValue= readTouchStable(TOUCH_PIN);
   delay(300);
   uint16_t capValue2= readTouchStable(TOUCH_PIN2);
   delay(100);

Wire.begin(21, 22);  // SDA=21, SCL=22(SCKは間違い)
    bme.setI2CAddress(0x76);

if (bme.beginI2C() == false) {
       S_PRINTLN("BME280 not detected!");
    } else {
      
      S_PRINTLN("BME280 connected.");
    }

WiFi.begin(ssid, password);
  
   S_PRINTLN("Connecting to WiFi");
    while (WiFi.status() != WL_CONNECTED) {
        delay(500);
   
      S_PRINTLN(".");
    }

S_PRINTLN("\nWiFi connected");

// uint16_t capValue = touchRead(TOUCH_PIN);

S_PRINTF("Touch value: %d\n", capValue);
  S_PRINTF("Touch2 value: %d\n", capValue2);

float tempC = bme.readTempC();
    float humidity = bme.readFloatHumidity();
    float pressure_hPa = bme.readFloatPressure() / 100.0;

S_PRINTF("Temp: %.2f C, Humidity: %.2f %%, Pressure: %.2f hPa\n", tempC, humidity, pressure_hPa);
 
    url  = String(path)
         + "?cap=" + String(capValue)
         + "&t="   + String(tempC, 1)
         + "&h="   + String(humidity, 1)
         + "&p="   + String(pressure_hPa, 1)
         + "&cap2=" + String(capValue2);

cprint = String("GET ") + url + " HTTP/1.1\r\n" +
             "Host: " + host + "\r\n" +
             "Connection: close\r\n\r\n";

WiFiClient client;
    if (client.connect(host, port)) {
        
        S_PRINTLN("Connected to server");
        client.print(cprint);

while (client.connected() || client.available()) {
            if (client.available()) {
                String line = client.readStringUntil('\n');
             
              S_PRINTLN(line);
            }
        }
        client.stop();
    } else {
      
      S_PRINTLN("Connection failed url=" + url);
    }

S_PRINTLN("Going to sleep...");
    delay(100);

WiFi.disconnect(true);
    WiFi.mode(WIFI_OFF);

digitalWrite(LED_PIN, LOW);

S_END();

esp_sleep_enable_timer_wakeup(SLEEP_SECONDS * 1000000ULL);
    esp_deep_sleep_start();
}

void loop() {

}

int readTouchStable(int pin) {
   // チャネル切替直後の捨て読み
  (void)touchRead(pin);
  delay(5);

int sum = 0;
    for (int i = 0; i < 8; i++) {
        sum += touchRead(pin);
        delay(5); // ほんの少し間隔
    }
    return sum / 8;
}

*******bottle

@app.route('/py/cap') 
@local_only
def cap_handler():

cap_value = request.query.cap  # ?cap=123 または ?cap=list10   list10だと最新の１０個データ表示
    if cap_value:
        if cap_value.startswith("list"):
            # ?cap=listN の場合
            try:
                n = int(cap_value[4:])
                lines = read_file(LOG_FILE_CAP)
                start = max(0, len(lines) - n)
                latest_lines = lines[start:]
                response.content_type = 'application/json'
                # JSON形式で返す
                result = []
                for line in latest_lines:
                    dt_str,value_str,value_t,value_p,value_h,value_str2 = line.strip().split(',', 5)
                    result.append({
                     "datetime": dt_str,
                     "cap": int(value_str),
                     "temp": float(value_t),
                     "hpa": float(value_p),
                     "hum": float(value_h),
                     "cap2":int(value_str2)
                     })
                return json.dumps(result)
            except ValueError:
                response.status = 400
                return "Invalid list parameter"
        else:
            # 数値の場合
            try:
                t_value= request.query.t
                p_value= request.query.p
                h_value= request.query.h
                cap2_value= request.query.cap2

latest_cap = int(cap_value)
                latest_t=float(t_value)
                latest_p=float(p_value)
                latest_h=float(h_value)
                #latest_cap2=int(cap2_value)
                latest_cap2 = int(cap2_value) if cap2_value else 0
                now_str = datetime.now().strftime("%Y-%m-%d %H:%M:%S")
                line = f"{now_str},{latest_cap},{latest_t},{latest_p},{latest_h},{latest_cap2}\n"
                
                # ログを読み込んで追記
                lines = read_file(LOG_FILE_CAP)
                lines.append(line)
                # 最大行数を維持
                if len(lines) > MAX_LINES:
                    lines = lines[-MAX_LINES:]
                write_log(lines)

@app.route('/py/captable')
@local_only
def captable():
    return """
<!DOCTYPE html>
<html lang="ja">
<head>
<meta charset="UTF-8">
<meta name="viewport" content="width=device-width, initial-scale=1"> 
<title>灯油タンク残量概算</title>
<style>
body {
  font-family: sans-serif;
  margin: 1em;
}

/* 入力エリア */
.controls {
  display: flex;
  flex-wrap: wrap;
  gap: 0.5em;
  align-items: center;
}
.controls label, .controls button {
  font-size: 1em;
}

/* テーブル */
table {
  border-collapse: collapse;
  width: 100%;
  margin-top: 1em;
  font-size: 0.95em;
}
th, td {
  border: 1px solid #999;
  padding: 0.5em;
  text-align: center;
}

/* スマホ向け：フォント少し小さく、テーブル横スクロール可 */
@media (max-width: 600px) {
  body { font-size: 0.9em; }
  .controls { flex-direction: column; align-items: flex-start; }
  table { display: block; overflow-x: auto; white-space: nowrap; }
  th, td { padding: 0.4em 0.6em; }
}
</style>
</head>
<body>
<h3>残量データ一覧</h3>

let prevFiltered = null;
let alpha = 0.07;
let threshold = 20;

let aval=1.4;
let eval=2.05;
let hval=51;
let jval=0.6;
let lval="45";

async function loadParams(){
    const response = await fetch("/api/get_params");
    const data = await response.json();

return {
        aval: Number(data.aval)  || 1.4,
        eval: Number(data.eval)  || 2.05,
        hval: Number(data.hval)  || 51,
        jval: Number(data.jval)  || 0.6,
        alpha: Number(data.alpha) || 0.07,
        threshold: Number(data.threshold) || 20,
        lval: data.lval || "45"
    };
}

function capToLevel(cap, cap2, ondo, hum) {
    if (cap === 0) return 0.0;

//let rawValue = 1.4 * (1/cap - 2.05/cap2) * 100000 + 51 - 0.6 * hum;
    let rawValue = aval * (1/cap - eval/cap2) * 100000 + hval - jval * hum;

// 初回はそのまま
    if (prevFiltered === null) {
        prevFiltered = rawValue;
        return rawValue;
    }

//let alpha = 0.07;

// 給油などの急増は即追従
    if (rawValue - prevFiltered > threshold) {
        prevFiltered = rawValue;
    } else {
        prevFiltered = alpha * rawValue + (1 - alpha) * prevFiltered;
    }

return prevFiltered;
}

async function loadData() {
  prevFiltered = null;

const params = await loadParams();

const lval2 = params.lval;

threshold=params.threshold;
    aval=params.aval;
    eval=params.eval;
    hval=params.hval;
    jval=params.jval;
    alpha=params.alpha;

const res = await fetch('/py/cap?cap=list'+lval2);

const data = await res.json();
  const tbody = document.querySelector('#capTable tbody');
  tbody.innerHTML = '';

// 最新を上に
  data.slice().forEach(item => {
    const tr = document.createElement('tr');
    const conv = capToLevel(item.cap,item.cap2,item.temp,item.hum);
    tr.innerHTML = `
      <td>${item.datetime}</td>
      <td>${item.cap}</td>
      <td>${conv.toFixed(2)}</td>
      <td>${item.temp}</td>
      <td>${item.hpa}</td>
      <td>${item.hum}</td>
      <td>${item.cap2}</td>
    `;
    tbody.appendChild(tr);
  });
}

loadData();
</script>
</body>
</html>
"""

@app.route('/py/dashboard2')
@local_only
def dashboard2():
    return """
<!DOCTYPE html>
<html lang="ja">
<head>
<meta charset="UTF-8">
<title>Dashboard</title>

.framebox {
  display: flex;
    flex-direction: column;  /* ← iframe を縦方向に並べたい場合 */
    align-items: center;     /* ← 横方向の中央に配置 */
}
/* 画面幅に応じて伸縮し、横スクロールが出ないようにする */
.framebox iframe {
    width: 90%;
    aspect-ratio: 16 / 9;   /* ← 高さ400pxの代わりにコレ！ */
    border: 1px solid #ccc;

}
</style>
</head>

<body>
<h2>Dashboard</h2>

<form id="paramForm">
  aval:<input type="text" id="aval" name="aval">
  eval:<input type="text" id="eval" name="eval">
  hval:<input type="text" id="hval" name="hval">
  jval:<input type="text" id="jval" name="jval">
  alpha:<input type="text" id="alpha" name="alpha">
  threshold:<input type="text" id="threshold" name="threshold">
  lval:<input type="text" id="lval" name="lval">
  <br>

Conversion formula:
  aval*(1/c-eval/c2)*10^5+hval-jval*hum　
  RawVal*alpha+(1-alpha)*PrevVal　lval=listCnt
  <br>
  <button type="submit">パラメータ更新</button>
</form>

document.addEventListener("DOMContentLoaded", function() {

fetch("/api/get_params")
    .then(response => response.json())
    .then(data => {

document.getElementById("aval").value  = data.aval  || "1.4";
        document.getElementById("eval").value  = data.eval  || "2.05";
        document.getElementById("hval").value  = data.hval  || "51";
        document.getElementById("jval").value  = data.jval  || "0.6";
        document.getElementById("alpha").value = data.alpha || "0.07";
        document.getElementById("threshold").value = data.threshold || "20";
        document.getElementById("lval").value = data.lval || "45";
      })
    .catch(error => {
        console.error("読み込みエラー:", error);
    });

});

document.getElementById("paramForm").addEventListener("submit", function(e) {
    e.preventDefault();  // フォームの通常送信を止める

const data = {
        aval: document.getElementById("aval").value,
        eval: document.getElementById("eval").value,
        hval: document.getElementById("hval").value,
        jval: document.getElementById("jval").value,
        alpha: document.getElementById("alpha").value,
        threshold: document.getElementById("threshold").value,
        lval: document.getElementById("lval").value
    };

fetch("/api/update_params", {
        method: "POST",
        headers: {
            "Content-Type": "application/json"
        },
        body: JSON.stringify(data)
    })
    .then(response => response.json())
    .then(result => {
        document.getElementById("result").innerHTML =
            "保存結果: " + result.message;
    })
    .catch(error => {
        document.getElementById("result").innerHTML =
            "エラーが発生しました";
        console.error(error);
    });
});
</script>

</body>
</html>
"""

@app.post('/api/update_params')
def update_params():
    data = request.json
    # 保存（例：jsonファイルに保存）
    with open("params.json", "w") as f:
        json.dump(data, f)

return {"message": "パラメータを保存しました"}

@app.get('/api/get_params')
def get_params():
    if not os.path.exists("params.json"):
        return {
            "aval": "",
            "eval": "",
            "hval": "",
            "jval": "",
            "alpha": "",
            "threshold":"",
            "lval": ""

}

with open("params.json", "r") as f:
        return json.load(f)

@app.route('/py/capgraph')
@local_only
def capgraph():
    return """
<!DOCTYPE html>
<html lang="ja">
<head>
<meta charset="UTF-8">
<title>残量グラフ</title>

<script src="https://cdn.jsdelivr.net/npm/chart.js@3.9.1/dist/chart.min.js"></script>

let prevFiltered = null;
let alpha = 0.07;
let threshold = 20;   // 給油判定（例）

// aval*(1/c-eval/c2)*10^5+hval-jval*hum
let aval=1.4;
let eval=2.05;
let hval=51;
let jval=0.6;
let lval="45";

async function loadParams(){
    const response = await fetch("/api/get_params");
    const data = await response.json();

function capToLevel(cap, cap2, ondo, hum) {
    if (cap === 0) return 0.0;

let rawValue = aval * (1/cap - eval/cap2) * 100000 + hval - jval * hum;

// 初回はそのまま
    if (prevFiltered === null) {
        prevFiltered = rawValue;
        return rawValue;
    }

//let alpha = 0.03;

return prevFiltered;
}

function capToLevel2(cap) {
    if (cap !== 0) {
        return 56450.0 / cap;
    } else {
        return 0.0;
    }
}

let capChart = null;

async function loadGraphData() {

prevFiltered = null;

const params = await loadParams();

const lval2= params.lval

threshold=params.threshold;
    aval=params.aval;
    eval=params.eval;
    hval=params.hval;
    jval=params.jval;
    alpha=params.alpha;

const res = await fetch('/py/cap?cap=list'+lval2);
    const data = await res.json();

// x軸ラベル
    const labels = data.map(d => d.datetime.slice(5, 16));  // "12-06 15:22"

loadGraphData();
</script>
</body>
</html>
"""

</script>
</body>
</html>
"""

※その後、測定用のCPSをc1、補正用のCPSをc2とすると、容量がカウントの逆数なので、(1/c1-2.05/c2)*10^5*係数a+切片bで近似すると、比較的うまくいくようだった。残量との差をエクセルで計算して、分散が最小になるように、aとbを調整してみた。この値をグラフにしてみると、ほぼ湿度と逆相関のようだったので、最終的に（上記の値）+51-0.6*湿度とするとさらに近似できそうだった。（このときも分散を見ながら手作業で調整。２次の項も入れてみたがかえってよくなかった。）

　これでも、変動が多いけれど、おそらく空気中の湿度というより、表面の水滴などが影響しているのでないかとも予想？されます。（湿度と相関あっても、完全な相関でないので）そこで、平均すればあるていど変動を抑えられるかと思い、移動平均的な計算を入れることにした。ChatGPTによると、 Value=RawValue*0.07+PrevValue*0.93のように前回データとその時の測定値に重みを付けながら足していくといいらしい。これで、しばらく様子をみることにした。

　今のところ、この移動平均を取り入れたら、以下のグラフ（赤い線）のようになり、わりと実測値に近くなった気がした。

　ChatGPTによると指数移動平均というらしい。低い周波数（残量の変化はかなりゆっくり進むので、あうらしい）を通すフィルターと同じ効果あるのだそう。ある意味LPFのようなものだとか。

※ただ、その後、最初のほうのデータにより、前半の状況が変わってくることもあるようなので、まだ十分とはいえないよう。

※変換式のパラメータをWebで変更できるようにして、実測値と計算値の分散が最小なるようにときどき調整している。残量が少なくなってきたときのほうが、データが多く蓄積してくるので、平均化されて誤差は減っている気もする。大事なのは、灯油がなくなりつつある頃の状況を知ることなので、そういう意味では、なんとか使える？かも。

2025年12月15日月曜日

Qtで最下行へスクロールする方法について

Qtでは、行数が多くなると最下行へのスクロールが難しい仕様？のようです。

　実際のWigetの行サイズとかもあり、すべてを反映して正確なスクロール量を割り出すのが難しいという問題もある？ちょうど、エクセルなどで印刷イメージと編集画面で微妙にずれたりするのと同じ困難さかもしれませんが。

　こういうときは、泥臭い方法で、実際に繰り返し試しながらスクロール量を割り出すしかないのかもしれません。その旨、ChatGPTに伝えたところ、以下のコードを作ってくれました。なんとか、うまくいきました。

void KakeiboTable::scrollDown(){
QScrollBar* bar = view->verticalScrollBar();
if (!bar) return;
int lastMax = -1;
QTimer* timer = new QTimer(this);
connect(timer, &QTimer::timeout, this, [=]() mutable {
int curMax = bar->maximum();
bar->setValue(curMax);
if (curMax == lastMax) {
timer->stop();
timer->deleteLater();
}
lastMax = curMax;
});
timer->start(0);
}

2025年12月11日木曜日

Unityで縦列駐車シミュレーションをつくってみた

WebGLで縦列駐車のシミュレーションできるようにしてみた。実車の運転前に、シミュレーションでコツをつかんでおくと役立つかもしれません。

https://github.com/gh6141/Parking.git(source code)

https://gh6141.github.io/WebGL-Parking/(シミュレーション)

上下左右の矢印で操作し、Spaceでブレーキです

ホンダのサイトで縦列駐車の方法が出ていました

※Github PageでWebGLを使うには、zip圧縮はしないほうがいいようです。パフォーマンスレベルはできるだけLow側にするとうまく動作するようです。

2025年12月10日水曜日

釣り竿アンテナの接触不良対策

釣り竿アンテナ(カーボン）に銅箔テープを貼ったものをアンテナとして使っていましたが、接続部がどうしても接触不良起こしやすく、SWRも安定しにくくなってきたので、試しに金属クリップを使ったら比較的調子がよくなり５９＋レポートもらえるようになりました。境目よりなるべくぎりぎり上のほうをはさむとうまくいくようです。

関数解析（宮寺功著）

文庫本で関数解析が読めるということで購入してみました。早速、壁にぶつかりましたが。

P40　定理２．２で、(x,y)=||(x+y)/2||^2-||(x-y)/2||^2+i||(x+iy)/2||^2-i||(x-iy)/2||^2の定義で(x,y)=(y,x)の共役　が言えるのかどうか？　||x+y||^2+||x-y||^2=2||x||^2+2||y||^2を使うとうまくできるようです。

注意が必要なのは、(x,y)=||(x+y)/2||^2-||(x-y)/2||^2+i||(x+iy)/2||^2-i||(x-iy)/2||^2の共役をとるとき、|| ||のなかにあるiの符号は変えてはいけないということ？うっかりけてしまいそうですが、外側のiは符号変えてもいいですが、ここがたぶん注意点？

Unityを久しぶり少し使ってみました

基本的なことを忘れていて思い出すの時間はかかりましたが、以前作りかけていたものを少しだけ手を加えてみました。文字式の計算を動物キャラクタで、できないか、試しに作ってみたものです。導入等に使えないかと。使う機会もないので、まだ中途半端の状態ですが。同類項＝同じ種類の動物を重ねて計算します。＋ーゼロだと爆発して消えるようにしています。

https://github.com/gh6141/WebGL_MathBoxSrc2.git(code)

https://gh6141.github.io/WebGL_mathBox/(WebGL)

こういうゲームでも誰か作ってくれれば、文字式や方程式の抽象概念も多少は理解促進の助けになるのでないかと思っていますが。

2025年12月6日土曜日

ESP32＋BME280　bottleコードの調整

ESP32からのデータをbottleで表示するコードを少し調整。スマホでの表示が見ずらいので少し調整してみたのがこちら

latest_cap = None
LOG_FILE = "cap_log.txt"
MAX_LINES = 200

def read_log():
    if not os.path.exists(LOG_FILE):
        return []
    with open(LOG_FILE, "r") as f:
        return f.readlines()

def write_log(lines):
    with open(LOG_FILE, "w") as f:
        f.writelines(lines)

latest_cap = None
LOG_FILE = "cap_log.txt"
MAX_LINES = 200
def read_log():
    if not os.path.exists(LOG_FILE):
        return []
    with open(LOG_FILE, "r") as f:
        return f.readlines()
def write_log(lines):
    with open(LOG_FILE, "w") as f:
        f.writelines(lines)
@app.route('/py/cap') 
def cap_handler():
    global latest_cap,latest_t,latest_p,latest_h
    latest_cap = None
    latest_t = None
    latest_p = None
    latest_h = None
    cap_value = request.query.cap  # ?cap=123 または ?cap=list10   list10だと最新の１０個データ表示
    
    t_value= request.query.t
    p_value= request.query.p
    h_value= request.query.h

if cap_value:
        if cap_value.startswith("list"):
            # ?cap=listN の場合
            try:
                n = int(cap_value[4:])
                lines = read_log()
                #latest_lines = lines[-n:] if n > 0 else []
                start = max(0, len(lines) - n)
                latest_lines = lines[start:]
                response.content_type = 'application/json'
                # JSON形式で返す
                result = []
                for line in latest_lines:
                    dt_str, value_str,value_t,value_p,value_h = line.strip().split(',', 4)
                    result.append({
                     "datetime": dt_str,
                     "cap": int(value_str),
                     "temp": float(value_t),
                     "hpa": float(value_p),
                     "hum": float(value_h)
                     })
                return json.dumps(result)
            except ValueError:
                response.status = 400
                return "Invalid list parameter"
        else:
            # 数値の場合
            try:
                latest_cap = int(cap_value)
                latest_t=float(t_value)
                latest_p=float(p_value)
                latest_h=float(h_value)
                now_str = datetime.now().strftime("%Y-%m-%d %H:%M:%S")
                line = f"{now_str},{latest_cap},{latest_t},{latest_p},{latest_h}\n"
                
                # ログを読み込んで追記
                lines = read_log()
                lines.append(line)
                # 最大行数を維持
                if len(lines) > MAX_LINES:
                    lines = lines[-MAX_LINES:]
                write_log(lines)

return f"Cap value {latest_cap} saved.\n"
            except ValueError:
                response.status = 400
                return "Invalid value"
    else:
        # パラメータなし → 最新値返す
        if latest_cap is not None:
            response.content_type = 'application/json'
            return json.dumps({"latest_cap": latest_cap})
        else:
            response.status = 404
            return "No data yet"
@app.route('/py/captable')
def captable():
    return """
<!DOCTYPE html>
<html lang="ja">
<head>
<meta charset="UTF-8">
<meta name="viewport" content="width=device-width, initial-scale=1"> 
<title>灯油タンク残量概算</title>
<style>
body {
  font-family: sans-serif;
  margin: 1em;
}

/* 入力エリア */
.controls {
  display: flex;
  flex-wrap: wrap;
  gap: 0.5em;
  align-items: center;
}
.controls label, .controls button {
  font-size: 1em;
}

/* テーブル */
table {
  border-collapse: collapse;
  width: 100%;
  margin-top: 1em;
  font-size: 0.95em;
}
th, td {
  border: 1px solid #999;
  padding: 0.5em;
  text-align: center;
}

const a = parseFloat(document.querySelector('#a').value);
  const b = parseFloat(document.querySelector('#b').value);

// 最新を上に
  data.slice().reverse().forEach(item => {
    const tr = document.createElement('tr');
    const conv = a * item.cap + b;
    tr.innerHTML = `
      <td>${item.datetime}</td>
      <td>${item.cap}</td>
      <td>${conv.toFixed(2)}</td>
      <td>${item.temp}</td>
      <td>${item.hpa}</td>
      <td>${item.hum}</td>
    `;
    tbody.appendChild(tr);
  });
}

document.querySelector('#reload').addEventListener('click', loadData);
loadData();
</script>
</body>
</html>
"""

@app.route('/py/dashboard2')
def dashboard2():
    return """
<!DOCTYPE html>
<html lang="ja">
<head>
<meta charset="UTF-8">
<title>Dashboard</title>

}
</style>
</head>

<body>
<h2>Dashboard</h2>

</body>
</html>
"""

@app.route('/py/capgraph')
def capgraph():
    return """
<!DOCTYPE html>
<html lang="ja">
<head>
<meta charset="UTF-8">
<title>残量グラフ</title>

<script src="https://cdn.jsdelivr.net/npm/chart.js@3.9.1/dist/chart.min.js"></script>

// x軸ラベル
    const labels = data.map(d => d.datetime.slice(5, 16));  // "12-06 15:22"

loadGraphData();
</script>
</body>
</html>
"""

2025年12月3日水曜日

ESP32にBME280追加

キャパシティのカウントに、温度影響などあれば、補正の可能性もあるかと思い、温度等もロギングすることにしてみた。ついでも、気圧、湿度も計測できるセンサが安く入手できたのでつないでみた。ロギングはbottleサーバで行い、PCから確認できるようにした。esp32のコードもそれに合わせて書き換えた。

補足：容量カウントのピンはGPIO4からノイズが少なめのGPIO12に変更した。また、容量カウントは、WIFIやBME280の起動前に行い、ノイズの影響を除くようにコードを修正。シリアル通信も同様の理由で削除(2025.12.5)(ChatGPTのよると、GPIO12,~~GPIO33~~,GPIO32,GPIO13,GPIO15の順でノイズが少ないらしい）

SparkFunBME280というライブラリを追加する必要があります。

# esp32 Code 
#include <WiFi.h>
#include <WiFiClient.h>
#include "esp_sleep.h"
#include <Wire.h>
#include "SparkFunBME280.h"

#define TOUCH_PIN 12
#define LED_PIN 2
#define SLEEP_SECONDS 21600   // 6時間

const char* ssid     = "****"
const char* password = "********"

const char* host = "*.*.*.*"//Raspberry Pi IP
const int   port = 8888;
const char* path = "/py/cap";

String url;
String cprint;

BME280 bme;

void setup() {
  //  Serial.begin(115200);
   delay(100);
   uint16_t capValue= readTouchStable(TOUCH_PIN);
   delay(100);

Wire.begin(21, 22);  // SDA=21, SCL=22(SCKは間違い)
    bme.setI2CAddress(0x76);

if (bme.beginI2C() == false) {
      //  Serial.println("BME280 not detected!");
    } else {
      //  Serial.println("BME280 connected.");
    }

WiFi.begin(ssid, password);
   // Serial.print("Connecting to WiFi");
    while (WiFi.status() != WL_CONNECTED) {
        delay(500);
      //  Serial.print(".");
    }
   // Serial.println("\nWiFi connected");

// uint16_t capValue = touchRead(TOUCH_PIN);
   
  //  Serial.printf("Touch value: %d\n", capValue);

float tempC = bme.readTempC();
    float humidity = bme.readFloatHumidity();
    float pressure_hPa = bme.readFloatPressure() / 100.0;

// Serial.printf("Temp: %.2f C, Humidity: %.2f %%, Pressure: %.2f hPa\n", tempC, humidity, pressure_hPa);
 
    url  = String(path)
         + "?cap=" + String(capValue)
         + "&t="   + String(tempC, 1)
         + "&h="   + String(humidity, 1)
         + "&p="   + String(pressure_hPa, 1);

cprint = String("GET ") + url + " HTTP/1.1\r\n" +
             "Host: " + host + "\r\n" +
             "Connection: close\r\n\r\n";

WiFiClient client;
    if (client.connect(host, port)) {
        Serial.println("Connected to server");
        client.print(cprint);

while (client.connected() || client.available()) {
            if (client.available()) {
                String line = client.readStringUntil('\n');
              //  Serial.println(line);
            }
        }
        client.stop();
    } else {
      //  Serial.println("Connection failed url=" + url);
    }

// Serial.println("Going to sleep...");
    delay(100);

WiFi.disconnect(true);
    WiFi.mode(WIFI_OFF);

digitalWrite(LED_PIN, LOW);

//  Serial.end();

esp_sleep_enable_timer_wakeup(SLEEP_SECONDS * 1000000ULL);
    esp_deep_sleep_start();
}

void loop() {

}

int readTouchStable(int pin) {
    int sum = 0;
    for (int i = 0; i < 8; i++) {
        sum += touchRead(pin);
        delay(5); // ほんの少し間隔
    }
    return sum / 8;
}

************以下は、bottleのコード*************

latest_cap = None
LOG_FILE = "cap_log.txt"
MAX_LINES = 200

def read_log():
    if not os.path.exists(LOG_FILE):
        return []
    with open(LOG_FILE, "r") as f:
        return f.readlines()

def write_log(lines):
    with open(LOG_FILE, "w") as f:
        f.writelines(lines)

if cap_value:
        if cap_value.startswith("list"):
            # ?cap=listN の場合
            try:
                n = int(cap_value[4:])
                lines = read_log()
                latest_lines = lines[-n:] if n > 0 else []
                response.content_type = 'application/json'
                # JSON形式で返す
                result = []
                for line in latest_lines:
                    dt_str, value_str,value_t,value_p,value_h = line.strip().split(',', 4)
                    result.append({
                     "datetime": dt_str,
                     "cap": int(value_str),
                     "temp": float(value_t),
                     "hpa": float(value_p),
                     "hum": float(value_h)
                     })
                return json.dumps(result)
            except ValueError:
                response.status = 400
                return "Invalid list parameter"
        else:
            # 数値の場合
            try:
                latest_cap = int(cap_value)
                latest_t=float(t_value)
                latest_p=float(p_value)
                latest_h=float(h_value)
                now_str = datetime.now().strftime("%Y-%m-%d %H:%M:%S")
                line = f"{now_str},{latest_cap},{latest_t},{latest_p},{latest_h}\n"
                
                # ログを読み込んで追記
                lines = read_log()
                lines.append(line)
                # 最大行数を維持
                if len(lines) > MAX_LINES:
                    lines = lines[-MAX_LINES:]
                write_log(lines)

/* 入力エリア */
.controls {
  display: flex;
  flex-wrap: wrap;
  gap: 0.5em;
  align-items: center;
}
.controls label, .controls button {
  font-size: 1em;
}

/* テーブル */
table {
  border-collapse: collapse;
  width: 100%;
  margin-top: 1em;
  font-size: 0.95em;
}
th, td {
  border: 1px solid #999;
  padding: 0.5em;
  text-align: center;
}

const a = parseFloat(document.querySelector('#a').value);
  const b = parseFloat(document.querySelector('#b').value);

document.querySelector('#reload').addEventListener('click', loadData);
loadData();
</script>
</body>
</html>
"""

@app.route('/py/dashboard2')
def dashboard2():
    return """
<!DOCTYPE html>
<html lang="ja">
<head>
<meta charset="UTF-8">
<title>複数 iframe</title>
<style>
.framebox {
    display: flex;
    gap: 10px;
}
iframe {
    flex: 1;
    height: 500px;
    border: 1px solid #555;
}
</style>
</head>
<body>

<h2>残量推移 ダッシュボード</h2>

</body>
</html>
"""

@app.route('/py/capgraph')
def capgraph():
    return """
<!DOCTYPE html>
<html lang="ja">
<head>
<meta charset="UTF-8">
<title>残量グラフ</title>

<script src="https://cdn.jsdelivr.net/npm/chart.js@3.9.1/dist/chart.min.js"></script>

// x軸は文字列ラベルとしてそのまま使用
    const labels = data.map(d => d.datetime);

loadGraphData();
</script>
</body>
</html>
"""

BME280のI2C接続図

　アクリルだと、紫外線で脆くなるだろうと考え、塩ビパイプをヒートガンで平面にしたものを加工して作ってみた。

Web確認すると推移グラフもチェックできるようにした(2025.12.6)

(12/7)湿度が容量に影響しているような様子も見られ、もう少し分析が必要と思われる。

(12/8)湿度との相関もはっきりしないところもある。タンク内と外では湿度が同じでないことも影響しているかもしれないので、補正も難しさがありそう。