Myu: 2026

2026年2月8日日曜日

esp32温度センサ動作で苦労する

カメラも動作させているためか、FNK0060なるESP32 は、BMP280ライブラリの中の名称のダブりなどでうまくビルドできず、苦労した。google AIからかなりハードよりのコードを出してもらいなんとか解決。　また、I2Cは、２つが限度らしく、リレー動作がひとつあまってしまう。

#include "esp_camera.h"
#include <WiFi.h>
#include <ESPAsyncWebServer.h>
#include "SPIFFS.h"
//for BMP280
#include <Wire.h>
#include <Preferences.h>

Preferences prefs;

#define BMP_ADDR1 0x76
#define BMP_ADDR2 0x77

// 各センサー用の補正係数構造体
struct BMP280_Trim {
  uint16_t dig_T1, dig_P1;
  int16_t  dig_T2, dig_T3, dig_P2, dig_P3, dig_P4, dig_P5, dig_P6, dig_P7, dig_P8, dig_P9;
  int32_t  t_fine;
} trim1, trim2;

// 書き込み・読み取り関数に「アドレス」を引数で渡せるようにします
void writeReg(uint8_t addr, uint8_t reg, uint8_t data) {
  Wire.beginTransmission(addr);
  Wire.write(reg);
  Wire.write(data);
  Wire.endTransmission();
}

struct BME280_Data {
  float temp;
  float pres;
};

BME280_Data getBMPData(uint8_t addr, BMP280_Trim *trim);

float setTempA1 = 25.0;
float setTempA2 = 25.0;
float hysteresis = 0.5;

unsigned long lastStatsTime = 0;
unsigned long A1_on_accum_ms = 0;
unsigned long A2_on_accum_ms = 0;
uint32_t A1_on_count = 0;
uint32_t A2_on_count = 0;

unsigned long a1_on_time = 0;  // A1がONになった時刻
unsigned long a2_on_time = 0;  // A1がONになった時刻
const unsigned long MAX_ON_MS = 10UL * 60UL * 1000UL; // 10分

// 補正係数読み取り
void readTrim(uint8_t addr, BMP280_Trim *trim) {
  uint8_t data[24]; // 一時的なバッファ

Wire.beginTransmission(addr);
  Wire.write(0x88); // 補正データ開始レジスタ
  Wire.endTransmission();  
  Wire.requestFrom(addr, (uint8_t)24);
  if (Wire.available() == 24) {
    for(int i = 0; i < 24; i++) {
      data[i] = Wire.read();
    }    
    // 各係数をリトルエンディアンで結合して構造体に格納
trim->dig_T1 = (uint16_t)((data[1] << 8) | data[0]);
trim->dig_T2 = (int16_t)((data[3] << 8) | data[2]);
trim->dig_T3 = (int16_t)((data[5] << 8) | data[4]);
trim->dig_P1 = (uint16_t)((data[7] << 8) | data[6]);
trim->dig_P2 = (int16_t)((data[9] << 8) | data[8]);
trim->dig_P3 = (int16_t)((data[11] << 8) | data[10]);
trim->dig_P4 = (int16_t)((data[13] << 8) | data[12]);
trim->dig_P5 = (int16_t)((data[15] << 8) | data[14]);
trim->dig_P6 = (int16_t)((data[17] << 8) | data[16]);
trim->dig_P7 = (int16_t)((data[19] << 8) | data[18]);
trim->dig_P8 = (int16_t)((data[21] << 8) | data[20]);
trim->dig_P9 = (int16_t)((data[23] << 8) | data[22]);
  }
}

// --- データ取得と計算のメイン関数 ---
BME280_Data getBMPData(uint8_t addr, BMP280_Trim *trim) {
  uint8_t data[6];
  Wire.beginTransmission(addr);
  Wire.write(0xF7); // 気圧(3byte) + 温度(3byte) の開始レジスタ
  Wire.endTransmission();
  Wire.requestFrom(addr, (uint8_t)6);
  for(int i=0; i<6; i++) data[i] = Wire.read();
  int32_t adc_P = ((uint32_t)data[0] << 12) | ((uint32_t)data[1] << 4) | ((data[2] >> 4) & 0x0F);
  int32_t adc_T = ((uint32_t)data[3] << 12) | ((uint32_t)data[4] << 4) | ((data[5] >> 4) & 0x0F);
  // --- 温度計算 ---
  int32_t var1T, var2T;
  var1T = ((((adc_T >> 3) - ((int32_t)trim->dig_T1 << 1))) * ((int32_t)trim->dig_T2)) >> 11;
  var2T = (((((adc_T >> 4) - ((int32_t)trim->dig_T1)) * ((adc_T >> 4) - ((int32_t)trim->dig_T1))) >> 12) * ((int32_t)trim->dig_T3)) >> 14;
  trim->t_fine = var1T + var2T;
  float temp = (trim->t_fine * 5 + 128) >> 8;
  // --- 気圧計算 ---
  int64_t var1P, var2P, p;
  var1P = ((int64_t)trim->t_fine) - 128000;
  var2P = var1P * var1P * (int64_t)trim->dig_P6;
  var2P = var2P + ((var1P * (int64_t)trim->dig_P5) << 17);
  var2P = var2P + (((int64_t)trim->dig_P4) << 35);
  var1P = ((var1P * var1P * (int64_t)trim->dig_P3) >> 8) + ((var1P * (int64_t)trim->dig_P2) << 12);
  var1P = (((((int64_t)1) << 47) + var1P)) * ((int64_t)trim->dig_P1) >> 33;  
  if (var1P == 0) return {0, 0}; // ゼロ除算防止
  p = 1048576 - adc_P;
  p = (((p << 31) - var2P) * 3125) / var1P;
  var1P = (((int64_t)trim->dig_P9) * (p >> 13) * (p >> 13)) >> 25;
  var2P = (((int64_t)trim->dig_P8) * p) >> 19;
  p = ((p + var1P + var2P) >> 8) + (((int64_t)trim->dig_P7) << 4);
  return { temp / 100.0f, (float)p / 25600.0f };
}

// ===== WiFi設定 =====

struct WifiCred {
  String ssid;
  String pass;
};
// 先に空のStringで宣言
String ssid1, ssid2, password,lineToken;
WifiCred wifiList[2]; // 配列だけ先に作っておく
void loadConfig() {
  if(!SPIFFS.begin(true)) return;
  File file = SPIFFS.open("/config.txt");
  if(!file) return;
  while(file.available()){
    String line = file.readStringUntil('\n');
    line.trim();
    if(line.startsWith("SSID1=")) ssid1 = line.substring(6);
    else if(line.startsWith("SSID2=")) ssid2 = line.substring(6);
    else if(line.startsWith("PASS=")) password = line.substring(5);
    else if(line.startsWith("LINE_TOKEN=")) lineToken = line.substring(11);
  }
  file.close();
  // 読み込んだ後に配列にセット
  wifiList[0] = {ssid1, password};
  wifiList[1] = {ssid2, password};
}
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);
  }
}

IPAddress local_IP(192,168,1,30);
IPAddress gateway(192,168,1,1);
IPAddress subnet(255,255,255,0);

AsyncWebServer server(80);

#define A1_PIN 14  // A1 Line
#define A2_PIN 2  // 内蔵LED A2 Line
//#define B_PIN 13  // B Line 使わない

bool BState = false;  // LEDの現在状態
bool A1State = false;
bool A2State = false;

// ===== カメラピン定義（FNK0060 / WROVER-KIT） =====
#define CAMERA_MODEL_WROVER_KIT

#if defined(CAMERA_MODEL_WROVER_KIT)
#define PWDN_GPIO_NUM  -1
#define RESET_GPIO_NUM -1
#define XCLK_GPIO_NUM  21
#define SIOD_GPIO_NUM  26
#define SIOC_GPIO_NUM  27

#define Y9_GPIO_NUM    35
#define Y8_GPIO_NUM    34
#define Y7_GPIO_NUM    39
#define Y6_GPIO_NUM    36
#define Y5_GPIO_NUM    19
#define Y4_GPIO_NUM    18
#define Y3_GPIO_NUM    5
#define Y2_GPIO_NUM    4
#define VSYNC_GPIO_NUM 25
#define HREF_GPIO_NUM  23
#define PCLK_GPIO_NUM  22
#endif

// ===== カメラ初期化 =====
void initCamera() {
  camera_config_t config;
  config.ledc_channel = LEDC_CHANNEL_0;
  config.ledc_timer   = LEDC_TIMER_0;

config.pin_d0 = Y2_GPIO_NUM;
  config.pin_d1 = Y3_GPIO_NUM;
  config.pin_d2 = Y4_GPIO_NUM;
  config.pin_d3 = Y5_GPIO_NUM;
  config.pin_d4 = Y6_GPIO_NUM;
  config.pin_d5 = Y7_GPIO_NUM;
  config.pin_d6 = Y8_GPIO_NUM;
  config.pin_d7 = Y9_GPIO_NUM;

config.pin_xclk     = XCLK_GPIO_NUM;
  config.pin_pclk     = PCLK_GPIO_NUM;
  config.pin_vsync    = VSYNC_GPIO_NUM;
  config.pin_href     = HREF_GPIO_NUM;
  config.pin_sccb_sda = SIOD_GPIO_NUM;
  config.pin_sccb_scl = SIOC_GPIO_NUM;
  config.pin_pwdn     = PWDN_GPIO_NUM;
  config.pin_reset    = RESET_GPIO_NUM;

config.xclk_freq_hz = 20000000;
  config.pixel_format = PIXFORMAT_JPEG;
  config.frame_size   = FRAMESIZE_VGA;
  config.jpeg_quality = 15;
  config.fb_count     = 1; // 最小構成で安定

Serial.println("Camera init start");
  esp_err_t err = esp_camera_init(&config);
  if(err != ESP_OK){
    Serial.printf("Camera init failed: 0x%x\n", err);
  } else {
    Serial.println("Camera init OK");
  }
}

// ===== キャプチャタスク =====
void captureTask(void *pvParameters) {
  while(true){
    camera_fb_t * fb = esp_camera_fb_get();
    if(fb){
      File f = SPIFFS.open("/latest.jpg", FILE_WRITE);
      if(f){
        f.write(fb->buf, fb->len);
        f.close();
        Serial.printf("Saved latest.jpg (%d bytes)\n", fb->len);
      } else {
        Serial.println("SPIFFS open failed");
      }
      esp_camera_fb_return(fb);
    } else {
      Serial.println("Camera capture failed");
    }
    vTaskDelay(pdMS_TO_TICKS(10000)); // 10秒毎
  }
}

// ===== setup =====
void setup() {
  Serial.begin(115200);

prefs.begin("heater", false);
setTempA1 = prefs.getFloat("setA1", 25.0);
setTempA2 = prefs.getFloat("setA2", 25.0);
hysteresis = prefs.getFloat("hys", 0.5);
prefs.end();
  
   
  Wire.begin(33, 32);
  delay(100);
  
   // センサー1 (0x76) 初期化
  writeReg(BMP_ADDR1, 0xF4, 0x27);
  readTrim(BMP_ADDR1, &trim1); 
  
  // センサー2 (0x77) 初期化
  writeReg(BMP_ADDR2, 0xF4, 0x27);
  readTrim(BMP_ADDR2, &trim2);

Serial.println("Dual BMP280 Init OK");

if(!SPIFFS.begin(true)){
    Serial.println("LittleFS Mount Failed");
    return;
  }
    loadConfig();

initCamera();

WiFi.mode(WIFI_STA);
  WiFi.config(local_IP, gateway, subnet);
  
  //WiFi.begin(ssid, password);  
  connectBestWiFi();
  
  while(WiFi.status() != WL_CONNECTED){
    delay(500);
  }
  Serial.print("WiFi connected: ");
  Serial.println(WiFi.localIP());

// /index.html を返す
  server.on("/", HTTP_GET, [](AsyncWebServerRequest *request){
    request->send(SPIFFS, "/index.html", "text/html");
  });

server.on("/config.html", HTTP_GET, [](AsyncWebServerRequest *request){
  request->send(SPIFFS, "/config.html", "text/html");
});

// /latest.jpg はキャプチャ画像
  server.on("/latest.jpg", HTTP_GET, [](AsyncWebServerRequest *request){
    if(!SPIFFS.exists("/latest.jpg")){
      request->send(503, "text/plain", "Image not ready");
      return;
    }
    request->send(SPIFFS, "/latest.jpg", "image/jpeg");
  });

//pinMode(B_PIN, OUTPUT);
  pinMode(A1_PIN, OUTPUT);
  pinMode(A2_PIN, OUTPUT);
 //  digitalWrite(B_PIN,  LOW);
  digitalWrite(A1_PIN,  LOW);
  digitalWrite(A2_PIN,  LOW);

server.on("/heatera1", HTTP_GET, [](AsyncWebServerRequest *request){
    if(request->hasParam("toggle")){
        A1State = !A1State;
        digitalWrite(A1_PIN, A1State ? HIGH : LOW);
    }
    String stateStr = A1State ? "on" : "off";
    request->send(200, "text/plain", stateStr);
});

server.on("/heatera2", HTTP_GET, [](AsyncWebServerRequest *request){
    if(request->hasParam("toggle")){
        A2State = !A2State;
        digitalWrite(A2_PIN, A2State ? HIGH : LOW);
    }
    String stateStr = A2State ? "on" : "off";
    request->send(200, "text/plain", stateStr);
});

// 全ボタンの状態をまとめて返す API
server.on("/allHeaterStatus", HTTP_GET, [](AsyncWebServerRequest *request){
    String json = "{";
   // json += "\"b\":\"" + String(BState ? "on" : "off") + "\",";
    json += "\"a1\":\"" + String(A1State ? "on" : "off") + "\",";
    json += "\"a2\":\"" + String(A2State ? "on" : "off") + "\"";
    json += "}";
    request->send(200, "application/json", json);
});

server.on("/data", HTTP_GET, [](AsyncWebServerRequest *request){
  BME280_Data s1 = getBMPData(0x76, &trim1);
  BME280_Data s2 = getBMPData(0x77, &trim2);  
  String json = "{";
  json += "\"temp1\":" + String(s1.temp, 2) + ",";
  json += "\"pres1\":" + String(s1.pres, 2) + ",";
  json += "\"temp2\":" + String(s2.temp, 2) + ",";
  json += "\"pres2\":" + String(s2.pres, 2);
  json += "}";  
  request->send(200, "application/json", json);
});

server.on("/setConfig", HTTP_GET, [](AsyncWebServerRequest *request){

bool updated = false;

if(request->hasParam("setA1")){
    setTempA1 = request->getParam("setA1")->value().toFloat();
    updated = true;
  }
  if(request->hasParam("setA2")){
    setTempA2 = request->getParam("setA2")->value().toFloat();
    updated = true;
  }
  if(request->hasParam("hys")){
    hysteresis = request->getParam("hys")->value().toFloat();
    updated = true;
  }

if(updated){
    prefs.begin("heater", false);
    prefs.putFloat("setA1", setTempA1);
    prefs.putFloat("setA2", setTempA2);
    prefs.putFloat("hys", hysteresis);
    prefs.end();
  }

request->send(200, "text/plain", "OK");
});

server.on("/getConfig", HTTP_GET, [](AsyncWebServerRequest *request){

String json = "{";
  json += "\"setA1\":" + String(setTempA1, 2) + ",";
  json += "\"setA2\":" + String(setTempA2, 2) + ",";
  json += "\"hysteresis\":" + String(hysteresis, 2);
  json += "}";

request->send(200, "application/json", json);
});

server.on("/heaterStats", HTTP_GET, [](AsyncWebServerRequest *request){
  unsigned long now = millis();
  unsigned long dt = now - lastStatsTime;
  lastStatsTime = now;

// 現在の温度もついでに取得
  BME280_Data s1 = getBMPData(BMP_ADDR1, &trim1);
  BME280_Data s2 = getBMPData(BMP_ADDR2, &trim2);

String json = "{";
  json += "\"dt_ms\":" + String(dt) + ",";
  json += "\"a1_on_time_ms\":" + String(A1_on_accum_ms) + ",";
  json += "\"a2_on_time_ms\":" + String(A2_on_accum_ms) + ",";
  json += "\"a1_on_count\":" + String(A1_on_count) + ",";
  json += "\"a2_on_count\":" + String(A2_on_count) + ",";
  json += "\"temp1\":" + String(s1.temp, 2) + ",";
  json += "\"temp2\":" + String(s2.temp, 2);
  json += "}";

// ★ リセット（次の区間のため）
  A1_on_accum_ms = 0;
  A2_on_accum_ms = 0;
  A1_on_count = 0;
  A2_on_count = 0;

request->send(200, "application/json", json);
});

server.onNotFound([](AsyncWebServerRequest *request){
    request->send(404, "text/plain", "Not found");
  });

server.begin();

// キャプチャタスクを Core 1 で開始
xTaskCreatePinnedToCore(
    captureTask,
    "capture",
    8192,
    NULL,
    1,
    NULL,
    1
  );
}

//temp control
void controlHeaterGeneric(float currentTemp,
                           float setTemp,
                           bool &state,
                           uint8_t pin,
                           unsigned long &on_time
                           )
{

if (currentTemp < 0.0 || currentTemp > 40.0) {
    state = false;
    digitalWrite(pin, LOW);
    return;  // これで他の制御をスキップ
  }  
  
  bool newState = state;

if (currentTemp < setTemp - hysteresis) {
    newState = true;
  }
  else if (currentTemp > setTemp + hysteresis) {
    newState = false;
  }

// リレーがONになった時刻を記録
    if (!state && newState) on_time = millis();

// 安全対策: 10分以上ONはOFF
    if (state && millis() - on_time > MAX_ON_MS) newState = false;

if (newState != state ) {
    state = newState;
    digitalWrite(pin, state ? HIGH : LOW);
    if (pin == A1_PIN) A1_on_count++;
    if (pin == A2_PIN) A2_on_count++;
  }

}

void loop() {
  static unsigned long lastLoop = millis();
  unsigned long now = millis();
  unsigned long dt = now - lastLoop;
  lastLoop = now;

BME280_Data s1 = getBMPData(BMP_ADDR1, &trim1);
  BME280_Data s2 = getBMPData(BMP_ADDR2, &trim2);

// ON時間の積算（RasPiが取りに来るまで）
  if (A1State) A1_on_accum_ms += dt;
  if (A2State) A2_on_accum_ms += dt;

Serial.printf("Sensor1: %.2f C, %.2f hPa\n", s1.temp, s1.pres);
  Serial.printf("Sensor2: %.2f C, %.2f hPa\n", s2.temp, s2.pres);
 Serial.printf("A1State:%s A2State:%s\n",
  A1State ? "ON" : "OFF",
  A2State ? "ON" : "OFF"
);

controlHeaterGeneric(s1.temp, setTempA1, A1State, A1_PIN,a1_on_time);
  controlHeaterGeneric(s2.temp, setTempA2, A2State, A2_PIN,a2_on_time);
  delay(2000);
}

********bottle*********
  ESP32 = "http://192.168.*.*"

CSV_FILE = "heater_log.csv"

MAX_LINES = 432   # ← 最大行数 ３日分

@app.route('/py/collect')
def collect():
    ts = time.strftime("%Y-%m-%d %H:%M:%S")
    rstatus="ok"
    try:
        r = requests.get(f"{ESP32}/heaterStats", timeout=5)
        r.raise_for_status()   # 200以外なら例外
        data = r.json()
        a1_ratio = 100*data["a1_on_time_ms"] / data["dt_ms"] if data["dt_ms"] > 0 else 0
        a2_ratio = 100*data["a2_on_time_ms"] / data["dt_ms"] if data["dt_ms"] > 0 else 0
        row = [
         ts,
         data["dt_ms"],
         data["temp1"],
         data["temp2"],
         data["a1_on_time_ms"],
         data["a2_on_time_ms"],
         data["a1_on_count"],
         data["a2_on_count"],
         round(a1_ratio, 1),
         round(a2_ratio, 1),
         ]
    except Exception as e:
        # 失敗時のログだけ残して、サーバは止めない
        print(f"[WARN] ESP32 unreachable: {e}")
        row = [
         ts,
         0,
         -9.99,   # temp1（欠測の目印）
         -9.99,   # temp2
         0, 0, 0, 0,
         0.0, 0.0,
         ]
        rstatus="ng"
        #return {"status": "ng", "error": "esp32 unreachable"}
  
  　# ① まず「追記」
    with open(CSV_FILE, "a", newline="") as f:
        writer = csv.writer(f)
        writer.writerow(row)

# ② 行数を制限（超えたら古い行を削除）
    with open(CSV_FILE, "r") as f:
        lines = f.readlines()

if len(lines) > MAX_LINES:
        lines = lines[-MAX_LINES:]

with open(CSV_FILE, "w", newline="") as f:
            f.writelines(lines)

return {"status": rstatus, "saved": row, "lines": min(len(lines), MAX_LINES)}

@app.get("/py/heaterStats")
def heater_stats():
    LOG_FILE = "/home/pi/heater_log.csv"
    n = 100  # 最新100件とか、必要に応じて可変
    lines = read_file(LOG_FILE)
    start = max(0, len(lines) - n)
    latest_lines = lines[start:]
    
    response.content_type = 'application/json'
    result = []
    for line in latest_lines:
        # CSVの列に合わせて分割
        dt_str, dt_ms , tempA1 , tempA2 , a1_ms ,a2_ms , a1_count , a2_count , on_percent_a1 , on_percent_a2 = line.strip().split(',', 9)
        result.append({
            "datetime": dt_str,
            "dt_ms":int(dt_ms),
            "tempA1": float(tempA1),
            "tempA2": float(tempA2),
            "a1_ms":int(a1_ms),
            "a2_ms":int(a2_ms),
            "a1_count": int(a1_count),
            "a2_count": int(a2_count),
            "on_percent_a1": float(on_percent_a1),
            "on_percent_a2": float(on_percent_a2)
        })
    return json.dumps(result)
  *****heater_graph.html******
  <!DOCTYPE html>
<html lang="ja">
<head>
<meta charset="UTF-8">
<title>heater graph</title>

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

<body>
<h3>温度 / 気圧 /　リレー動作 / On割合グラフ</h3>
<canvas id="capChart"></canvas>

let capChart = null;  
async function loadGraphData() {
    const res = await fetch('/py/heaterStats');  
    const data = await res.json();

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

const temp1  = data.map(d => d.tempA1);
    const temp2 = data.map(d => d.tempA2);
    const ratio1  = data.map(d => d.on_percent_a1/4);
    const ratio2  = data.map(d => d.on_percent_a2/4);

if (capChart) {
        capChart.destroy();
    }
    new Chart(document.getElementById('capChart'), {
        type: 'line',
        data: {
            labels: labels,
            datasets: [
                { label: 'A1温度',     data: temp1,  borderColor: 'red',    borderWidth: 2, fill: false },
                { label: 'A2温度',    data: temp2, borderColor: 'blue',   borderWidth: 2, fill: false },
                { label: 'A1On%/4',      data: ratio1,  borderColor: 'orange', borderWidth: 2, fill: false },
                { label: 'A2On%/4',      data: ratio2,  borderColor: 'gray', borderWidth: 2, fill: false },

]
        },
        options: {
            responsive: true,
            plugins: {
                legend: { position: 'top' }
            },
            scales: {
                x: {
                    title: { display: true, text: '日時' },
                    ticks: {
                        autoSkip: true,
                        maxTicksLimit: 30,
                        maxRotation: 45,
                    }
                },
                y: {
                    beginAtZero: false,
                    title: { display: true, text: '値' }
                }
            }
        }
    });
}

loadGraphData();
</script>
</body>
</html>
  
  ********heater_stats.html**********
  <!DOCTYPE html>
<html lang="ja">
<head>
  <meta charset="UTF-8">
  <title>Heater Stats</title>
  <style>
    table { border-collapse: collapse; width: 100%; }
    th, td { border: 1px solid #aaa; padding: 4px 8px; text-align: center; }
    th { background-color: #ddd; }
  </style>
</head>
<body>
  <h2>Heater Statistics</h2>
  <table id="heaterTable">
    <thead>
      <tr>
        <th>Datetime</th>
        <th>Dt_ms</th>
        <th>Temp A1</th>
        <th>Temp A2</th>
        <th>a1_ms</th>
        <th>a2_ms</th>
        <th>A1 Count</th>
        <th>A2 Count</th>
        <th>A1 On %</th>
        <th>A2 On %</th>
      </tr>
    </thead>
    <tbody>
      
    </tbody>
  </table>

const tbody = document.querySelector('#heaterTable tbody');
        tbody.innerHTML = '';  // 既存をクリア

// 最新を上に表示したい場合は reverse
        data.slice().reverse().forEach(item => {
          const tr = document.createElement('tr');
          tr.innerHTML = `
            <td>${item.datetime}</td>
<td>${item.dt_ms}</td>
            <td>${item.tempA1.toFixed(2)}</td>
            <td>${item.tempA2.toFixed(2)}</td>
<td>${item.a1_ms}</td>
<td>${item.a2_ms}</td>            
<td>${item.a1_count}</td>
            <td>${item.a2_count}</td>
            <td>${item.on_percent_a1.toFixed(2)}</td>
            <td>${item.on_percent_a2.toFixed(2)}</td>
          `;
          tbody.appendChild(tr);
        });
      } catch (err) {
        console.error('Failed to load heater stats:', err);
      }
    }

// ページロード時に取得
    loadHeaterStats();

// 10秒ごとに更新（必要なら）
    setInterval(loadHeaterStats, 10000);
  </script>
</body>
</html>

いくつか動作させるためのポイントがあった。

・BMP280は、SDO端子をアースするか、電源につなぐかで、２つのセンサを判別する。

・GPIO３３，３２は、プルアップ４．７KΩを入れたほうがいい。

2026年2月7日土曜日

苗床温度調整をesp32で

3月ぐらいから、小さめの衣装ケースに発泡スチロールを入れ、5Vヒーターで温度調整しながら、試してみようかと思い準備中。念のため、ヒーターには７０度ぐらいの温度ヒューズを直列に入れるといいらしい。コードはこれから考える予定。ハードは、センサ部分の残してほぼできてきた。

　配線図では、１２Vを降圧コンバータで５VにしてたものをEsp32に使っているが、安定せずうまくいかなかったので、専用の５Vを用意する予定。

2026年2月3日火曜日

（備忘録）sqliteでのデータのコピー

GUIのsqlite3ブラウザでデータコピーする方法を忘れないようにメモしておこうと思います。

・B Browser for SQLiteを使う場合

1) コピー先を開く

2) コピー元を Attach（別名を付ける）

　「データベースに接続」（「開く」ではないので注意！）で →ソースのデータベースを追加

　　Alias（別名）に src と入力

※ この段階で「src」という別DBとして認識される

3) SQL 実行（INSERT のみ）

「SQL実行」タブで以下を実行

INSERT INTO shishutunyu1 (date, sishutu, shunyu, zandaka, himoku, biko)

SELECT date, sishutu, shunyu, zandaka, himoku, biko

FROM src.shishutunyu1

WHERE date BETWEEN '2025-01-01' AND '2026-02-03';

4)変更を書き込み

2026年2月1日日曜日

Qtによる家計簿アプリ公開

　まだ、インポート関係で多少バグもありそうな気もしますが、念のため、インポート失敗したら、インポート直前にUndoできるようメニュー追加しました。いったん公開したいと思います。また、セルの編集がすぐ反映しないときは、再計算をクリックする仕様にしました。
　こちらにあります。（マニュアル・ヘルプ等はまだつくっていませんが。）
　1 銀行からのCSVインポート機能（極力汎用性もたせて、現段階では３～４つぐらいのところには対応させました）　2 スマホで入力したデータの転記機能
など追加しました。
　2のためには、 raspiのbottleとandroid studioが必要です。参考までにコードは以下のとおり。

bottle

@app.route('/py/vckake')
def vckake():
    key = request.query.key 
    date = request.query.date
    if key == "":
        f = open("vckakeMemo.txt") 
        data=f.read()
        f.close
    else:
        if key == "delete":
                with open("vckakeMemo.txt", 'w') as open_file:
                    pass
                data="deleted!"
        else:
            try:
          # ファイルに書き込む処理
                with open("vckakeMemo.txt", 'a') as open_file:
                    open_file.write(","+key + "_" + date )  # 改行を追加して新しい行として追加
                data="added!"
            except Exception as e:
        # ファイル操作でエラーが発生した場合
                data=f"Error occurred: {str(e)}"
    return template('vckake.html',txt=data)
    
# DB 接続関数
def get_db():
    conn = sqlite3.connect(DB_FILE)
    conn.row_factory = sqlite3.Row
    return conn

# DB 初期化関数
def init_db():
    if not os.path.exists(DB_FILE):
        conn = get_db()
        conn.execute("""
            CREATE TABLE expenses (
                id INTEGER PRIMARY KEY AUTOINCREMENT,
                amount REAL,
                memo TEXT,
                date TEXT,
                category TEXT,
                payee TEXT,
                method TEXT
            )
        """)
        conn.commit()
        conn.close()

# 初回アクセス時に DB 初期化
def init_db_once():
    global db_initialized
    if not db_initialized:
        init_db()
        db_initialized = True

# GET API
@app.get('/api/items')
def get_items():
    init_db_once()  # 初回だけ DB 作成
    conn = get_db()
    cur = conn.execute("SELECT * FROM expenses ORDER BY date DESC")
    rows = [dict(row) for row in cur.fetchall()]
    conn.close()
    response.content_type = 'application/json'
    return json.dumps(rows)

# POST API
@app.post('/api/items')
def create_item():
    init_db_once()  # 初回だけ DB 作成
    data = request.json
    if not data:
        response.status = 400
        return {"error": "Invalid JSON"}

conn = get_db()
    cur = conn.cursor()
    cur.execute(
        "INSERT INTO expenses (amount, memo, date, category, payee, method) VALUES (?,?,?,?,?,?)",
        (
            data.get("amount", 0),
            data.get("memo", ""),
            data.get("date", ""),
            data.get("category", ""),
            data.get("payee", ""),
            data.get("method", "")
        )
    )
    conn.commit()
    last_id = cur.lastrowid
    conn.close()
    response.content_type = 'application/json'
    return {"id": last_id}

# DB接続用関数
def get_db():
    conn = sqlite3.connect(DB_FILE)
    conn.row_factory = sqlite3.Row
    return conn

@app.delete('/api/items/<item_id:int>')
def delete_item(item_id):
    conn = get_db()
    cur = conn.cursor()
    cur.execute("DELETE FROM expenses WHERE id=?", (item_id,))
    conn.commit()
    conn.close()

response.content_type = 'application/json'
    return {"status": "ok"}
    
@app.put('/api/items/<item_id:int>')
def update_item(item_id):
    data = request.json
    if not data:
        response.status = 400
        return {"error": "Invalid JSON"}

conn = get_db()
    cur = conn.cursor()
    cur.execute(
        "UPDATE expenses SET amount=?, memo=? ,date=? ,category=?,method=? WHERE id=?",
        (data.get("amount", 0), data.get("memo", ""), data.get("date", ""),data.get("category", ""),data.get("method", ""),item_id)
    )
    conn.commit()
    conn.close()

response.content_type = 'application/json'
    return {"status": "ok"}

android

**********ApiClient**********
  import android.content.Context;
import android.net.ConnectivityManager;
import android.net.NetworkCapabilities;
import android.util.Log;
import android.widget.Toast;

import retrofit2.Retrofit;
import retrofit2.converter.gson.GsonConverterFactory;

public class ApiClient {
//private static final String BASE_URL = "https://ホスト名.ドメイン/api/";
    private static Retrofit retrofit = null;

/*public static ApiService getApiService(Context context) {
        if (retrofit == null) {
            retrofit = new Retrofit.Builder()
                    //.baseUrl(BASE_URL)
                    .baseUrl(getBaseUrl(context))
                    .addConverterFactory(GsonConverterFactory.create())
                    .build();
        }
        return retrofit.create(ApiService.class);
    }*/
    public static ApiService getApiService(Context context) {
        Retrofit retrofit = new Retrofit.Builder()
                .baseUrl(getBaseUrl(context))
                .addConverterFactory(GsonConverterFactory.create())
                .build();
        // URL を取得
        String url = getBaseUrl(context);

// Toast も渡された Context を使う
        Toast.makeText(context, "URL: " + url, Toast.LENGTH_LONG).show();

return retrofit.create(ApiService.class);
    }

private static String getBaseUrl(Context context) {

if (isWifi(context)) {
            Log.d("NETWORK_TYPE", "現在の接続は: WIFI");
            return "http://ローカルアドレス/api/";

} else {
            Log.d("NETWORK_TYPE", "現在の接続は: MOBILE");
            return "https://ホスト名/api/";
        }
    }
    private static boolean isWifi(Context context) {
        ConnectivityManager cm =
                (ConnectivityManager) context.getSystemService(Context.CONNECTIVITY_SERVICE);
        if (cm == null) return false;  // 予期せぬ null 対策

NetworkCapabilities caps =
                cm.getNetworkCapabilities(cm.getActiveNetwork());

return caps != null &&
                caps.hasTransport(NetworkCapabilities.TRANSPORT_WIFI);
    }

}
  
  ******************ApiService**********
  package com.example.vckake5.api;

import com.example.vckake5.model.Expense;
import retrofit2.Call;
import retrofit2.http.Body;
import retrofit2.http.DELETE;
import retrofit2.http.GET;
import retrofit2.http.POST;
import retrofit2.http.PUT;
import retrofit2.http.Path;

import java.util.List;

public interface ApiService {

@POST("items")
    Call<ExpenseResponse> addExpense(@Body Expense expense);

@GET("items")
    Call<List<Expense>> getExpenses();

@DELETE("/api/items/{id}")
    Call<Void> deleteExpense(@Path("id") int id);

@PUT("/api/items/{id}")
    Call<ExpenseResponse> updateExpense(@Path("id") int id, @Body Expense expense);

}

*****************ExpenseResponse***********
  package com.example.vckake5.api;

public class ExpenseResponse {
    private int id;

public int getId() { return id; }
    public void setId(int id) { this.id = id; }
}
  
  ***************Expnese*******
  example.vckake5.model;

public class Expense {
    private int id;
    private int amount;
    private String memo;
    private String date;
    private String category;
    private String method;
    private String payee;   // 支払先

public Expense(int amount, String memo, String date, String category, String method, String payee) {
        this.amount = amount;
        this.memo = memo;
        this.date = date;
        this.category = category;
        this.method = method;
        this.payee = payee;
    }

// getter / setter
    public int getAmount() { return amount; }
    public void setAmount(int amount) { this.amount = amount; }

public String getMemo() { return memo; }
    public void setMemo(String memo) { this.memo = memo; }

public String getDate() { return date; }
    public void setDate(String date) { this.date = date; }

public String getCategory() { return category; }
    public void setCategory(String category) { this.category = category; }

public String getMethod() { return method; }
    public void setMethod(String method) { this.method = method; }

public String getPayee() { return payee; }
    public void setPayee(String payee) { this.payee = payee; }
    public void setId(int id) {
        this.id = id;
    }

public int getId() {
        return id;
    }
}

**************ExpneseAdapter**********
  package com.example.vckake5;

import android.view.LayoutInflater;
import android.view.View;
import android.view.ViewGroup;
import android.widget.TextView;
import android.widget.Toast;

import androidx.annotation.NonNull;
import androidx.recyclerview.widget.RecyclerView;
import com.example.vckake5.model.Expense;
import java.util.List;

public class ExpenseAdapter extends RecyclerView.Adapter<ExpenseAdapter.ExpenseViewHolder> {
    private List<Expense> expenseList;
    private OnItemLongClickListener longClickListener;
    public interface OnItemLongClickListener {
        void onItemLongClick(Expense expense);
    }
    public void setOnItemLongClickListener(OnItemLongClickListener listener) {
        this.longClickListener = listener;
    }

public ExpenseAdapter(List<Expense> expenseList) {
        this.expenseList = expenseList;
    }

@NonNull
    @Override
    public ExpenseViewHolder onCreateViewHolder(@NonNull ViewGroup parent, int viewType) {
        View view = LayoutInflater.from(parent.getContext())
                .inflate(R.layout.item_expense, parent, false);
        return new ExpenseViewHolder(view);
    }

@Override
    public void onBindViewHolder(@NonNull ExpenseViewHolder holder, int position) {
        Expense expense = expenseList.get(position);
        holder.tvDate.setText(expense.getDate());
        holder.tvCategory.setText(expense.getCategory());
        holder.tvAmount.setText(String.valueOf(expense.getAmount()));
        holder.tvMemo.setText(expense.getMemo());  // ←追加
        holder.tvMethod.setText(expense.getMethod());  // ←追加

holder.itemView.setOnLongClickListener(v -> {
            if (longClickListener != null) {
                longClickListener.onItemLongClick(expense); // IDを含むExpenseオブジェクトを渡す
            }
            return true; // イベントを消費
        });

// 長押し操作の案内を表示（1回だけでもOK）
        holder.itemView.setOnClickListener(v -> {
            Toast.makeText(v.getContext(), "長押しで編集・削除可能", Toast.LENGTH_SHORT).show();
        });

}

@Override
    public int getItemCount() {
        return expenseList.size();
    }

public static class ExpenseViewHolder extends RecyclerView.ViewHolder {
        TextView tvDate, tvCategory, tvAmount,tvMemo,tvMethod;

public ExpenseViewHolder(@NonNull View itemView) {
            super(itemView);
            tvDate = itemView.findViewById(R.id.tvDate);
            tvCategory = itemView.findViewById(R.id.tvCategory);
            tvAmount = itemView.findViewById(R.id.tvAmount);
            tvMemo = itemView.findViewById(R.id.tvMemo);  // ←追加
            tvMethod = itemView.findViewById(R.id.tvMethod);  // ←追加
        }
    }

}

**************MainAcitivity
  package com.example.vckake5;

import android.app.AlertDialog;
import android.app.DatePickerDialog;

import android.os.Bundle;
import android.widget.Button;
import android.widget.EditText;
import android.widget.TextView;
import android.widget.Toast;
import androidx.appcompat.app.AppCompatActivity;

import com.example.vckake5.api.ApiService;
import com.example.vckake5.api.ApiClient;
import com.example.vckake5.api.ExpenseResponse;
import com.example.vckake5.model.Expense;

import java.text.SimpleDateFormat;
import java.util.Calendar;
import java.util.List;

import retrofit2.Call;
import retrofit2.Callback;
import retrofit2.Response;

import androidx.recyclerview.widget.RecyclerView;
import androidx.recyclerview.widget.LinearLayoutManager;
import java.util.ArrayList;
import java.util.Locale;

import android.widget.Spinner;
import android.widget.ArrayAdapter;

public class MainActivity extends AppCompatActivity {

private EditText inputAmount, inputMemo, inputDate;
    private Button btnAdd, btnClear;
    private TextView txtView;

private ApiService api;

private Expense editingExpense = null;

@Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);

// --- View 取得 (1回だけ) ---
        inputAmount = findViewById(R.id.inputAmount);
        inputMemo = findViewById(R.id.inputMemo);
        inputDate = findViewById(R.id.inputDate);
        btnAdd = findViewById(R.id.btnAdd);
        btnClear = findViewById(R.id.btnClear);
        txtView = findViewById(R.id.txtView);
        RecyclerView recyclerView = findViewById(R.id.recyclerView);
        Spinner spinnerCategory = findViewById(R.id.spinnerCategory);
        Spinner spinnerMethod = findViewById(R.id.spinnerMethod);

// --- Spinner セット ---
        ArrayAdapter<CharSequence> categoryAdapter = ArrayAdapter.createFromResource(
                this, R.array.categories_array, android.R.layout.simple_spinner_item);
        categoryAdapter.setDropDownViewResource(android.R.layout.simple_spinner_dropdown_item);
        spinnerCategory.setAdapter(categoryAdapter);

ArrayAdapter<CharSequence> methodAdapter = ArrayAdapter.createFromResource(
                this, R.array.method_array, android.R.layout.simple_spinner_item);
        methodAdapter.setDropDownViewResource(android.R.layout.simple_spinner_dropdown_item);
        spinnerMethod.setAdapter(methodAdapter);

// --- RecyclerView セット ---
        List<Expense> expenseList = new ArrayList<>();
        ExpenseAdapter expenseAdapter = new ExpenseAdapter(expenseList);
        recyclerView.setAdapter(expenseAdapter);
        recyclerView.setLayoutManager(new LinearLayoutManager(this));

// --- API ---
        //api = ApiClient.getApiService();
        api = ApiClient.getApiService(this);
        api.getExpenses().enqueue(new Callback<List<Expense>>() {
            @Override
            public void onResponse(Call<List<Expense>> call, Response<List<Expense>> response) {
                if (response.isSuccessful() && response.body() != null) {
                    expenseList.clear();
                    expenseList.addAll(response.body());
                    expenseAdapter.notifyDataSetChanged();
                }
            }

@Override
            public void onFailure(Call<List<Expense>> call, Throwable t) {
                t.printStackTrace();
            }
        });

// --- 初期日付セット ---
        if (editingExpense == null) {
            String today = new SimpleDateFormat("yyyy-MM-dd", Locale.getDefault())
                    .format(Calendar.getInstance().getTime());
            inputDate.setText(today);
        } else {
            inputDate.setText(editingExpense.getDate());
        }

// --- 日付ピッカー ---
        inputDate.setOnClickListener(v -> {
            Calendar calendar = Calendar.getInstance();
            int year = calendar.get(Calendar.YEAR);
            int month = calendar.get(Calendar.MONTH);
            int day = calendar.get(Calendar.DAY_OF_MONTH);

DatePickerDialog datePickerDialog = new DatePickerDialog(MainActivity.this,
                    (view, year1, month1, dayOfMonth) -> {
                        String selectedDate = String.format("%04d-%02d-%02d", year1, month1 + 1, dayOfMonth);
                        inputDate.setText(selectedDate);
                    }, year, month, day);
            datePickerDialog.show();
        });

// --- 追加 / 更新ボタン ---
        btnAdd.setOnClickListener(v -> {
            String amountStr = inputAmount.getText().toString().trim();
            String memoStr = inputMemo.getText().toString().trim();
            String dateStr = inputDate.getText().toString().trim();
            String category = spinnerCategory.getSelectedItem().toString();
            String method = spinnerMethod.getSelectedItem().toString();

// 日付が空なら今日の日付をセット
            if (dateStr.isEmpty()) {
                dateStr = new SimpleDateFormat("yyyy-MM-dd", Locale.getDefault())
                        .format(Calendar.getInstance().getTime());
                inputDate.setText(dateStr);
            }

if (!amountStr.isEmpty() && !memoStr.isEmpty()) {
                int amount = Integer.parseInt(amountStr);

if (editingExpense == null) {
                    Expense newExpense = new Expense(amount, memoStr, dateStr, category, method, "payee");
                    api.addExpense(newExpense).enqueue(new Callback<ExpenseResponse>() {
                        @Override
                        public void onResponse(Call<ExpenseResponse> call, Response<ExpenseResponse> response) {
                            if (response.isSuccessful() && response.body() != null) {
                                newExpense.setId(response.body().getId());
                                runOnUiThread(() -> {
                                    expenseList.add(newExpense);
                                    expenseAdapter.notifyItemInserted(expenseList.size() - 1);

inputMemo.setText("");
                                    inputAmount.setText("");
                                    // 日付とSpinnerは保持したまま

});
                            }
                        }

@Override
                        public void onFailure(Call<ExpenseResponse> call, Throwable t) {
                            t.printStackTrace();
                            runOnUiThread(() -> Toast.makeText(MainActivity.this, "追加に失敗", Toast.LENGTH_SHORT).show());
                        }
                    });
                } else {
                    // 編集モード
                    editingExpense.setAmount(amount);
                    editingExpense.setMemo(memoStr);
                    editingExpense.setDate(dateStr);
                    editingExpense.setCategory(category);
                    editingExpense.setMethod(method);

api.updateExpense(editingExpense.getId(), editingExpense).enqueue(new Callback<ExpenseResponse>() {
                        @Override
                        public void onResponse(Call<ExpenseResponse> call, Response<ExpenseResponse> response) {
                            if (response.isSuccessful()) {
                                runOnUiThread(() -> {
                                    expenseAdapter.notifyDataSetChanged();
                                    Toast.makeText(MainActivity.this, "更新しました", Toast.LENGTH_SHORT).show();
                                    editingExpense = null;
                                    btnAdd.setText("Add");

inputMemo.setText("");
                                    inputAmount.setText("");
                                    // 日付とSpinnerは保持したまま
                                });
                            }
                        }

@Override
                        public void onFailure(Call<ExpenseResponse> call, Throwable t) {
                            runOnUiThread(() -> Toast.makeText(MainActivity.this, "更新失敗", Toast.LENGTH_SHORT).show());
                        }
                    });
                }
            } else {
                Toast.makeText(MainActivity.this, "金額とメモを入力してください", Toast.LENGTH_SHORT).show();
            }
        });

// --- クリアボタン ---
        btnClear.setOnClickListener(v -> {
            inputAmount.setText("");
            inputMemo.setText("");
            // 日付は今日を保持
            inputDate.setText(new SimpleDateFormat("yyyy-MM-dd", Locale.getDefault()).format(Calendar.getInstance().getTime()));
            spinnerCategory.setSelection(0);
            spinnerMethod.setSelection(0);
            editingExpense = null;
            Toast.makeText(MainActivity.this, "入力欄をクリアしました", Toast.LENGTH_SHORT).show();
        });

// --- RecyclerView 長押しで編集 / 削除 ---
        expenseAdapter.setOnItemLongClickListener(expense -> {
            int id = expense.getId();
            String[] options = {"削除", "編集"};
            new AlertDialog.Builder(MainActivity.this)
                    .setTitle("操作を選択")
                    .setItems(options, (dialog, which) -> {
                        if (which == 0) {
                            new AlertDialog.Builder(MainActivity.this)
                                    .setTitle("削除確認")
                                    .setMessage("この支出を削除しますか？")
                                    .setPositiveButton("削除", (d, w) -> {
                                        api.deleteExpense(id).enqueue(new Callback<Void>() {
                                            @Override
                                            public void onResponse(Call<Void> call, Response<Void> response) {
                                                if (response.isSuccessful()) {
                                                    expenseList.remove(expense);
                                                    expenseAdapter.notifyDataSetChanged();
                                                    Toast.makeText(MainActivity.this, "削除しました", Toast.LENGTH_SHORT).show();
                                                }
                                            }

@Override
                                            public void onFailure(Call<Void> call, Throwable t) {
                                                Toast.makeText(MainActivity.this, "削除失敗", Toast.LENGTH_SHORT).show();
                                            }
                                        });
                                    })
                                    .setNegativeButton("キャンセル", null)
                                    .show();
                        } else if (which == 1) {
                            inputAmount.setText(String.valueOf(expense.getAmount()));
                            inputMemo.setText(expense.getMemo());
                            inputDate.setText(expense.getDate());

spinnerCategory.setSelection(((ArrayAdapter<String>) spinnerCategory.getAdapter()).getPosition(expense.getCategory()));
                            spinnerMethod.setSelection(((ArrayAdapter<String>) spinnerMethod.getAdapter()).getPosition(expense.getMethod()));

editingExpense = expense;
                            btnAdd.setText("Update");
                            Toast.makeText(MainActivity.this, "編集モードです", Toast.LENGTH_SHORT).show();
                        }
                    })
                    .show();
        });

}
*****************AndroidManifest.xml
  <?xml version="1.0" encoding="utf-8"?>
<manifest xmlns:android="http://schemas.android.com/apk/res/android"
    xmlns:tools="http://schemas.android.com/tools">

<uses-permission android:name="android.permission.INTERNET" />
    <uses-permission android:name="android.permission.ACCESS_NETWORK_STATE"/>

</application>
</manifest>

※今は、Windowsで使用していますが、Qtで作成したので、将来的にはLinuxでも使用することを考えています。

2026年1月30日金曜日

android自作アプリがWIFIで内部サーバに接続できない問題

　外部からは、モバイル回線だと接続できるけれど、家でWIFIだと内部サーバに接続できないという問題があり、いろいろ解決まで時間がかかった。ちなみに、Chromeなどでは問題なく接続できるので、自作アプリに問題あるのは予想できた。

　ChatGPTでも解決できず、googleAIに質問したところ、解決。android:networkSecurityConfig="@xml/network_security_config"が厳格すぎたせいだった。自作アプリには、かなりセキュリティ対策を厳密にしているらしい。もともと、androidはgoogle製なので、的確な回答ができたのだと思う。

　WIFIかどうかをアプリ内で判別し、URLを切り替えたり、ポート制限もしているので、合わせて、network_security_configでLocalIpの設定を入れたらOkだった。

2026年1月27日火曜日

スマホから支払記録のセキュリティ改善

　買い物などしたとき、少し時間あるときはスマホで支出内容をraspiにネット経由で記録して、あとでPCで自作家計簿を開くと確認ボタンですぐ反映できるようにしている。転記したら一時置き場所のraspiのデータは削除します。これまでは、一時的データなのでとくに認証とかしてなかったのですが。少し工夫してみました。

　C＃版とQt版としばらく併用していて、先々Qt版に切り替える予定ですが、いずれもデータ取り込みについては、同じraspiサーバ(bottle)を使っているので、大幅に作り変えたくないと考えました。家計簿ソフトはさわらず、bottleのみ改善しました。

　いったん外部から接続できなくして、認証ページをつくり、指定した時間、認証ページが使っているアドレスからのアクセスのみ受け付けるような仕組みを組み込みました。これによって、一定時間のみスマホからデータ入力ができるようになりました。入力が終わって、指定時間がすぎれば、自動的にまた接続できなくなるので、それほど手間なくできそうです。

2026年1月26日月曜日

raspiにbind9

LAN内のラズパイ、ルータ、プリンタ、アクセスポイントなど、ホスト名でアクセスできるように内部DNSにしてみた。以前行ったbind9の設定の仕方を思い出しながら、うまくいかなかったところは、chatGPTの助けも借りながら、なんとか完了。

・ルータは静的ルーティング設定で、自分のドメインのものはすべて、ルータに行くように設定。LAN側サーバアドレスをラズパイにして、ラズパイにbind9を入れます。

・ufwで、tcp,udpでローカル内からの53番ポートのアクセスを許可します。

・各種設定はネット上の情報を参照して行った。 host コマンドで最後に確認。

※今回、/etc/resolv.conf に問題があることがchatGPTから指摘受ける。どうやらnetworkManagerから生成されたものが、ルーターに行くようになっていて、raspi(127.0.0.1)が使われてないことがわかる。ただ、/etc/resolv.conf は直接編集できず、

nmcli connection showでeth0でいいか確認して、

sudo nmcli connection modify "eth0" \

ipv4.ignore-auto-dns yes \

ipv4.dns 127.0.0.1 \

ipv6.ignore-auto-dns yes \

ipv6.dns ::1

これを反映

sudo nmcli connection down "eth0"

sudo nmcli connection up "eth0"

確認するとcat /etc/resolv.confー＞nameserver 127.0.0.1

まだ、よくわからないところもあるが、とりあえず、指定したホスト名で内部はアクセスできるようになった。

※さらに、これだけではよくないらしくnamed.conf.optionsに追加して

options {

directory "/var/cache/bind";

recursion yes;　　clientが「全部教えて」＞BINDは、自分の zone を探し、なければ、無ければ権威DNS …を最後まで代行して答える。これが無いと「権威サーバーに聞いてね」で終わる。

allow-recursion { localnets; localhost; };再帰を誰に許すか。localnets とは？BINDが認識している直結ネットワーク　　

allow-query { localnets; localhost; };DNS問い合わせそのものを誰に許すか。LAN内 → 正引き・逆引きともにOK　　外部 → そもそも答えない　　内部専用DNSなら必須

# 外向きは forwarder に任せる（安定）

forwarders {

1.1.1.1;

8.8.8.8;

};

dnssec-validation auto;

listen-on { 127.0.0.1; 192.168.1.0/24; };BINDがどのIPアドレスで待ち受けるか。

挙動　　　127.0.0.1 → 自分自身

192.168.1.x → LANからのDNS

書かないと？　デフォルトで全インターフェース　IPv6含めて全部待ち受けることも

不要な露出を防ぐため明示推奨

};

2026年1月25日日曜日

raspiでcloudflareのリバースプロキシを使うためにufwいれてみた

raspiの外部公開もそろそろセキュリティが気になってきたのでOS更新にあわせて、cloudflareを使ってみることした。そのためにufwを設定する必要があった。

sudo ufw allow sshをまず最初に入れるのが鉄則
curl https://ifconfig.meで、グローバルIp確認、それを次にいれる
sudo ufw allow from <自分のIP> to any port 443 proto tcp
sudo ufw allow from 192.168.1.0/24 to any port 22 proto tcpで、LAN限定にしたいなら
sudo ufw delete allow sshで、最初の設定削除
cloudflareのリバースプロキシを使うのが目的なので、そちらにのみ許可する設定です
# IPv4
curl https://www.cloudflare.com/ips-v4
# IPv6
curl https://www.cloudflare.com/ips-v6 でIp確認
これをみて
sudo ufw allow from 173.245.48.0/20 to any port 443 proto tcpを続ける
sudo ufw allow from 2400:cb00::/32 to any port 443 proto tcpも同様
ここまでの確認は　sudo ufw status numbered この時表示なる番号をもとに、削除もできる

例。sudo ufw delete 2 # ルール番号指定で削除

sudo ufw allow from 192.168.1.0/24 to any port 80 proto tcp

sudo ufw allow from 192.168.1.0/24 to any port 443 proto tcp

sudo ufw allow from 192.168.1.0/24 to any port 8080 proto tcp(bottle確認用)

でLAN内からのWEBアクセスは可能にしておく

注意：Cloudflare IPは変わることがある→ cron スクリプトで自動更新

そこで、このあとは、次のようなスクリプトを用意

#!/bin/bash

# ファイル名: update-cloudflare-ufw-home.sh

# LAN内 + Cloudflare + WAN自動IP用 ufw 443自動更新

# cronやsudoでも安全に動作

# --- 設定 ---

LAN_CIDR="192.168.1.0/24" # LAN内ネットワーク

UFW_PORT=443

TMP_DIR="$HOME/tmp"

# --- 0. 一時ディレクトリ作成 ---

mkdir -p $TMP_DIR

# --- 1. Cloudflare IP取得 ---

curl -s https://www.cloudflare.com/ips-v4 > $TMP_DIR/cf-ips-v4.txt

curl -s https://www.cloudflare.com/ips-v6 > $TMP_DIR/cf-ips-v6.txt

# --- 2. 既存Cloudflare 443ルール削除（LANルールは残す） ---

# IPv4

if [ -f "$TMP_DIR/cf-ips-v4.txt" ]; then

for ip in $(cat $TMP_DIR/cf-ips-v4.txt); do

sudo ufw delete allow from $ip to any port $UFW_PORT proto tcp 2>/dev/null || true

done

# IPv6

if [ -f "$TMP_DIR/cf-ips-v6.txt" ]; then

for ip in $(cat $TMP_DIR/cf-ips-v6.txt); do

sudo ufw delete allow from $ip to any port $UFW_PORT proto tcp 2>/dev/null || true

done

# --- 3. LAN内ルール再登録（もしまだない場合） ---

sudo ufw allow from $LAN_CIDR to any port $UFW_PORT proto tcp

# --- 4. Cloudflareルール追加 ---

if [ -f "$TMP_DIR/cf-ips-v4.txt" ]; then

for ip in $(cat $TMP_DIR/cf-ips-v4.txt); do

sudo ufw allow from $ip to any port $UFW_PORT proto tcp

done

if [ -f "$TMP_DIR/cf-ips-v6.txt" ]; then

for ip in $(cat $TMP_DIR/cf-ips-v6.txt); do

sudo ufw allow from $ip to any port $UFW_PORT proto tcp

done

# --- 5. WAN自分IP取得・追加 ---

MYIP=$(curl -s https://ipinfo.io/ip)

if [ -n "$MYIP" ]; then

sudo ufw allow from $MYIP to any port $UFW_PORT proto tcp

# --- 6. 状態確認 ---

sudo ufw status verbose

以上のスクリプトをcronに追加

crontab -e

0 6 * * * /home/pi/update-cloudflare-ufw-home.sh

※対策はあくまでインバウンドのみです。インバウンドのみcloudflareのセキュリティ対策を経たトンネルを使います。アウトバウンドは通常の経路です。ルータは443のみオープンにして、80は閉じても大丈夫です。SSL更新もcloudflareにまかせるか、こちらでやる(DNS-01というらしい。数日前設定したばかりだが。）か、選べる。

※cloudflareにまかせるには　AやCNAMEをproxiedにして

sudo systemctl status certbot.timerでこちら管理しているようならとめて、起動しないように

sudo systemctl stop certbot.timer

sudo systemctl disable certbot.timer

確認はsudo systemctl status certbot.timer

sudo systemctl is-enabled certbot.timerでinactive ,disabledならok

cloudflare側は「SSL/TLS」メニュー＞ Origin Certificate を入れている場合 → Full (strict)
・「Edge Certificates」タブ＞Always Use HTTPS：オンにすると自動で HTTPS にリダイレクト
・ Cloudflare → SSL/TLS → Origin Server＞「Create Certificate」で Origin Certificate を作成＞サーバに設置、この証明書があれば Let’s Encrypt は不要になる

sudo a2enmod ssl
sudo a2ensite default-ssl
sudo systemctl reload apache2
sudo mkdir -p /etc/ssl/cloudflare
sudo chmod 700 /etc/ssl/cloudflare

origin_cert.pemとorigin_key.pemとして保存
sudo chmod 600 /etc/ssl/cloudflare/*

sudo nano /etc/apache2/sites-available/default-ssl.conf
SSLEngine on
SSLCertificateFile /etc/ssl/cloudflare/origin_cert.pem
SSLCertificateKeyFile /etc/ssl/cloudflare/origin_key.pem
# 推奨の TLS 設定
SSLProtocol all -SSLv2 -SSLv3
SSLCipherSuite HIGH:!aNULL:!MD5

このあと、以下のコマンドで完了

sudo a2enmod ssl

sudo a2ensite default-ssl

sudo systemctl reload apache2

※最後に、lan内でrapsiのhttpsにアクセスするとその都度警告がでますが、requestlyという拡張機能をchromeに入れると文字置換https://ホスト名>http://192.168~のような感じにできて解決できるようです。

2026年1月24日土曜日

raspi復旧マニュアル

今回、raspi2のSSL更新を簡潔にするために、OSのクリーンインストールをしたため、その後のハードよりの設定でだいぶ苦労しました。OSが違うと、いろいろ大変なようです。念のため、備忘録つくりました。他にも、いろいろひっかるところはありましたが、とりあえず、GPIO周りがとくに大変だったので、関連操作まとめました。

１　Python スクリプト (ssr_control.py)
保存場所: /home/pi/ssr_control.py
#!/usr/bin/env python3
# -*- coding: utf-8 -*-
# SSR制御スクリプト
# 指定曜日・時間のみSSRをONにし、それ以外はOFF
# 対象GPIO: 17 (BCM)
import RPi.GPIO as GPIO
import datetime
import time
# GPIO 設定
GPIO.setmode(GPIO.BCM)
GPIO.setup(17, GPIO.OUT)

try:
while True:
now = datetime.datetime.now()
weekday = now.weekday() # 月曜=0, 日曜=6

# 水曜(2)と土曜(5)の6時〜7時にON、それ以外はOFF
if (weekday == 2 or weekday == 5) and 6 <= now.hour < 7:
GPIO.output(17, GPIO.HIGH) # SSR ON
else:
GPIO.output(17, GPIO.LOW) # SSR OFF

time.sleep(30) # 30秒ごとにチェック

finally:
GPIO.cleanup()
ポイント:
時間は 6 <= now.hour < 7 で 1時間だけ ON。
曜日は weekday() の値を確認（0=月曜, 6=日曜）。
30秒ごとにチェックするループ。

２　systemd サービス設定 (ssr_control.service)
保存場所: /etc/systemd/system/ssr_control.service
[Unit]
Description=SSR Control
After=network.target

[Service]
Type=simple
User=pi
WorkingDirectory=/home/pi
ExecStart=/home/pi/bottle-env/bin/python /home/pi/ssr_control.py
Restart=on-failure

[Install]
WantedBy=multi-user.target
ポイント:
User=pi にして仮想環境（bottle-env）の Python を使用。
WorkingDirectory はスクリプトのあるディレクトリ。
失敗時に自動再起動。

３　 systemd の操作コマンド
# サービスを再読み込み（設定変更後は必須）
sudo systemctl daemon-reload
# サービスを有効化（起動時に自動開始）
sudo systemctl enable ssr_control.service
# サービス起動
sudo systemctl start ssr_control.service
# 状態確認
sudo systemctl status ssr_control.service
# サービス停止
sudo systemctl stop ssr_control.service
# ログ確認
journalctl -u ssr_control.service -b
※ バックアップ・復旧のコツ
/home/pi/ssr_control.py と /etc/systemd/system/ssr_control.service を両方コピーして保存。
Python 仮想環境 (bottle-env) も丸ごとバックアップしておくと、ライブラリの問題で復旧に悩まなくて済む。
OSアップデート後は、GPIOライブラリや Python バージョンを確認してから systemd サービスを再有効化。

2026年1月18日日曜日

FreeNove Esp32 Wroverで間欠WebCam動作テスト

Freenoveのesp32 wroverについては、ストリーミングだと負荷がかかりすぎるし、付属のサンプルコードはカメラとGPIOを同時に細かい制御ができないコードのようなので、間欠で静止画をWebで表示しつつ、GPIOの操作するようなコードを試してみた。FNK0060というパッケージに合わせてライブラリなどそろえる必要あるようだった。

index.htmlは、IDEがver2だとアップロードできないので、Ver1を使う必要があった。

************ino file**************
  #include "esp_camera.h"
#include <WiFi.h>
#include <ESPAsyncWebServer.h>
#include "SPIFFS.h"

// ===== WiFi設定 =====
const char* ssid = "****";
const char* password = "*******";

IPAddress local_IP(192,168,1,30);
IPAddress gateway(192,168,1,1);
IPAddress subnet(255,255,255,0);

AsyncWebServer server(80);

#define LED_PIN 2  // 内蔵LED
bool ledState = false;  // LEDの現在状態

// ===== カメラピン定義（FNK0060 / WROVER-KIT） =====
#define CAMERA_MODEL_WROVER_KIT

#if defined(CAMERA_MODEL_WROVER_KIT)
#define PWDN_GPIO_NUM  -1
#define RESET_GPIO_NUM -1
#define XCLK_GPIO_NUM  21
#define SIOD_GPIO_NUM  26
#define SIOC_GPIO_NUM  27

// ===== カメラ初期化 =====
void initCamera() {
  camera_config_t config;
  config.ledc_channel = LEDC_CHANNEL_0;
  config.ledc_timer   = LEDC_TIMER_0;

config.xclk_freq_hz = 20000000;
  config.pixel_format = PIXFORMAT_JPEG;
  config.frame_size   = FRAMESIZE_VGA;
  config.jpeg_quality = 15;
  config.fb_count     = 1; // 最小構成で安定

// ===== setup =====
void setup() {
  Serial.begin(115200);
  delay(1000);

if(!SPIFFS.begin(true)){
    Serial.println("SPIFFS Mount Failed");
    return;
  }

initCamera();

WiFi.mode(WIFI_STA);
  WiFi.config(local_IP, gateway, subnet);
  WiFi.begin(ssid, password);
  while(WiFi.status() != WL_CONNECTED){
    delay(500);
  }
  Serial.print("WiFi connected: ");
  Serial.println(WiFi.localIP());

// /index.html を返す
  server.on("/", HTTP_GET, [](AsyncWebServerRequest *request){
    request->send(SPIFFS, "/index.html", "text/html");
  });

pinMode(LED_PIN, OUTPUT);

server.on("/led", HTTP_GET, [](AsyncWebServerRequest *request){
    if(request->hasParam("toggle")) {
        // ボタン押下で切り替え
        ledState = !ledState;
        digitalWrite(LED_PIN, ledState ? HIGH : LOW);
    }
    // 現在の状態を返す
    String stateStr = ledState ? "on" : "off";
    request->send(200, "text/plain", stateStr);
});

server.onNotFound([](AsyncWebServerRequest *request){
    request->send(404, "text/plain", "Not found");
  });

server.begin();

// キャプチャタスクを Core 1 で開始
  xTaskCreatePinnedToCore(
    captureTask,
    "capture",
    8192,
    NULL,
    1,
    NULL,
    1
  );
}

void loop(){}
  *************index.html******************
  <!DOCTYPE html>
<html lang="ja">
<head>
<meta charset="UTF-8">
<title>ESP32 Camera</title>
<style>
  body { margin:0; background:#000; color:#fff; font-family:sans-serif; }
  #camera { display:block; margin:auto; max-width:100%; }
  #timestamp {
    position: fixed;
    left: 10px;
    bottom: 10px;
    background: rgba(0,0,0,0.5);
    padding: 3px 6px;
    border-radius: 4px;
    font-size: 14px;
  }
</style>
</head>
<body>

<img id="camera" src="/latest.jpg" alt="Camera">
<div id="timestamp"></div>
<button id="ledBtn">Toggle LED</button>

function updateImage() {
  const t = new Date();
  ts.textContent = t.toLocaleString(); // PC側日時表示
  img.src = '/latest.jpg?t=' + t.getTime(); // キャッシュ回避
}

updateImage();
setInterval(updateImage, interval);

</script>

</body>
</html>

2026年1月14日水曜日

外気温　温度計の液晶修理

接触不良を接点復活材で直した液晶温度計も、今度は中心部が黒っぽくなり見づらくなってきた。たまたま、Youtubeで修理方法出ていたので試してみた。反射フィルムと偏光フィルムをはがして、ガラス板（中に液晶があると思われる）だけにしてから、アルミテープと購入した偏光フィルム（amazonn等でも入手可）を入れなおしたらうまくいった。偏光フィルムは角度を調整して、一番見やすい角度にしてから、枠に合わせて切り取る必要があります。ちょっとしたことだけれど、毎日見るものでもあるので、少しでも見やすくすることは大事かもしれない。

2026年1月13日火曜日

半田ごて温度調整器をつくってみた

以前、作成したCWキーヤーは使わなくなったので（発振器が不安定？になった）、その中のPIC12F675を有効活用するため、はんだごて温度調整器を作ってみた。壊れたWIFI＿APの12Vアダプタと、ジャンクのアンテナチューナのリレー、３端子レギュレータ、ダイオード等を使ってみた。たまたま廃品からかき集めた部品をうまく活用できた。PICは、書き込み時はずさなくてもいいように、PICKitとつなげるPINソケットをつけた。

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

#pragma config FOSC = INTRCIO
#pragma config WDTE = ON // WDT???????while(1)?reset
//#pragma config WDTE = OFF 
#pragma config PWRTE = ON
#pragma config MCLRE = OFF
#pragma config BOREN = OFF
#pragma config CP = OFF
#pragma config CPD = OFF

#define _XTAL_FREQ 4000000

// --- GPIO?? ---
#define CMD    GP5
#define NUM    GP4
#define MORSE   GP1
#define HEATER  GP2

#define EEPROM_INIT  0xA5

// ---- prototypes ----
void dot(void);
void dash(void);
void playMorse(unsigned char num) ;
void heaterControl(unsigned char sec);
void tick_1s(unsigned char val);

const char morseTbl[10][6] = {
    "-----",".----","..---","...--","....-",
    ".....","-....","--...","---..","----."
};

unsigned char value = 9;  
unsigned char tmpValue=0;
unsigned char numFlg=0; //num input flg
unsigned char numFlg2=0; //cmd input flg
unsigned char utime=1; // Sec Per Count
unsigned char initTime=2;//minuts
unsigned char sleepTime=5;//minuts
unsigned char sleepValue=3;//value during sleep
unsigned char shutdownTime=30;//minuts
unsigned char elapsedMinutes=0;
unsigned char elapsedSeconds=0;

void main(void)
{
    ANSEL = 0x00;
    CMCON = 0x07;

TRISIO = 0b00110000; // GP4,5 input
    GPIO = 0x00;
    __delay_ms(100);

if (eeprom_read(0x01) != EEPROM_INIT) {
     eeprom_write(0x00, 9);        
     eeprom_write(0x01, EEPROM_INIT); // ????????
    }
    value = eeprom_read(0x00);
    __delay_ms(100);
    playMorse(value);

while (1)
    {
        CLRWDT();

if (NUM && !CMD) {            
            numFlg=1;
            __delay_ms(20);
            if (NUM) {
                tmpValue++;
                if (tmpValue > 9) tmpValue = 0;
                dot();
                while (NUM){
                    CLRWDT();   
                    if(CMD){
                        while(1){  //rest                        
                        }
                    }
                }
            }
        }

if (CMD && !NUM) {
            numFlg2=1;
            __delay_ms(20);
            if (CMD) {
                if (numFlg){
                    value=tmpValue;
                    if (value != eeprom_read(0x00)) {
                    __delay_ms(100); 
                    eeprom_write(0x00, value);
                    __delay_ms(100);
                    playMorse(value);      
                   }
                    numFlg=0;
                    tmpValue=0;
                }                                                
         
                while (CMD){
                    CLRWDT();  
                  
                }
                numFlg2=0;
            }
        }
        
       
        
        if(numFlg2==0 && numFlg==0){  
          if(elapsedMinutes<initTime)  {
            utime=1;
            heaterControl(9);  //9=100%
           // playMorse(9);   
          }else if(elapsedMinutes<sleepTime){
            utime=10;//????
            heaterControl(value); 
           // playMorse(value);   
          }else if(elapsedMinutes<shutdownTime){
            utime=10;           
            heaterControl(sleepValue); 
           // playMorse(sleepValue);   
          }else{
            utime=10;
            heaterControl(0);
           // playMorse(0);   
          }             
            
        }else{     
                HEATER = 0;
        }
        
    }
}

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

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

void playMorse(unsigned char num)
{
    for (unsigned char i = 0; morseTbl[num][i]; i++) {
             CLRWDT();
        if (morseTbl[num][i] == '.') dot();
        else dash();
    }
}

void heaterControl(unsigned char secO)
{
    unsigned char sec=secO*utime;
    if (sec > 9*utime) sec = 9*utime;

if(sec>0) HEATER = 1;
    for (unsigned char i = 0; i < sec; i++) {
         CLRWDT();
       if (NUM || CMD) {
           break;
       }
       tick_1s(secO);
       __delay_ms(1000);     
    }
    if ( 9*utime - sec>0){
         HEATER = 0;
    }
    for (unsigned char i = 0; i < (9*utime - sec); i++){
         CLRWDT();
        if (NUM || CMD) {
            break;
        }
        tick_1s(secO);
        __delay_ms(1000);
    }
}

void tick_1s(unsigned char val) {
    elapsedSeconds++;
  if ((elapsedSeconds % 10) == 0) {
    playMorse(val);   // LED morse
   }
    CLRWDT();
    if (elapsedSeconds >= 60) {
        elapsedSeconds = 0;
        if (elapsedMinutes < 255) elapsedMinutes++;        
    }
}

・赤LEDで、半田ごてがOnになる状況を把握。

・GPIO1の緑LEDは、モールス符号で数値０～９を読み取り。

・入力はGPIO4を押した回数（ただし、１０回だと０）がリレーがOnになる割合を表す。

・GPIO5は入力が終わったら押すことで、EPROMに保存。

・utimeは9*utimeが、リレー調整の周期（秒）となる。回数が7、utime=10なら９０秒中７０秒Onという形式。

・initTimeまで100%で、このとき設定可能。sleepTimeまでが、入力してあるvalueをもとにした割合でon。shutdownTimeまでは、sleepValueの値を使う。shutdownTime以後はOff。

・GP4おしながらGP5おすと、リセット、再起動。

2026年1月10日土曜日

dfplayerをesp32C3で動かしてみた

dfplayerはネットラジオをraspiでタイマー録音した英語教材をmicroSDにもってきて再生、whisper使って音声認識したテキストをrapiにおいてwifiで読み取ったものをOLEDで表示できるようにしてみた（Qtで準備のためのツールも作成）。LGT8F328Pを使っていたけれど動作が不安定になってきたので、esp32c3に置き換えたついでに、テキスト表示できるようにバージョンアップしてみた。数百円で入手できるので、コスパがとてもよくなっていると思う。

GPIO5:IN2 ...file番号２桁を順に長押しで入れる。モード切り替えたら、テキスト番号のインクリメントをする。

GPIO6:IN1 ...Cmd機能とし、長押し１回でファイル番号をインクリメント、長押し２回でデクリメント。モード切り替えたら、テキスト番号のデクリメント

GPIO7:IN3 ...モード切替。テキスト番号を変更して表示するようにした。

esp32C3は小型のわりに機能満載で、便利に使える。

***********code for esp32C3*****************************
   #include <Wire.h>
#include <WiFi.h>
#include <HTTPClient.h>
#include <ArduinoJson.h>
#include <Adafruit_GFX.h>
#include <Adafruit_SSD1306.h>
#include <HardwareSerial.h>
#include <Preferences.h>
#include <DFRobotDFPlayerMini.h>
#include <WebServer.h>
//#include <AsyncTCP.h>
//#include <ESPAsyncWebServer.h>
DFRobotDFPlayerMini dfplayer;
const char* NVS_NS = "config";
#define SCREEN_WIDTH 128
#define SCREEN_HEIGHT 64
#define IN1 6
#define IN2 5
#define IN3 7
#define OUT 3
#define MODE_SERVER 0
#define MODE_NORMAL 1

Adafruit_SSD1306 display(SCREEN_WIDTH, SCREEN_HEIGHT, &Wire, -1);
HardwareSerial dfSerial(1);   // UART1
WebServer server(80);
//WiFiServer server(80);   
//AsyncWebServer server(80);
String ssid     = "****";
String pass = "****";
String url = "http://192.168.1.103:8888/py/srt?srt=/mnt/oldnas/RadioEnglish_txt/";

String espSsid="ESP32_Config";
String espPass="12345678";

unsigned char flg=0;
unsigned char cnum=0;  
unsigned char cnumA;
unsigned char cketa=2;
unsigned char cfnum=0; //command
unsigned char shokaif=1;
unsigned char dispmodeFlg = 0;
int number = 0;  // 表示用カウンタ
unsigned char vol=18; //volume
unsigned char dcount=0;
char buf[64];
unsigned char svmodeFlg;

String loadString(const char* name, const String& def = "") {
  Preferences prefs;
  prefs.begin(NVS_NS, true);
  String v = prefs.getString(name, def);
  prefs.end();
  return v;
}

void saveStringIfChanged(const char* name, const String& v) {
  Preferences prefs;
  prefs.begin(NVS_NS, false);

String old = prefs.getString(name, "");
  if (old != v) {
    prefs.putString(name, v);
  }

prefs.end();
}

void setup() {

svmodeFlg=loadValue("svmodeFlg",MODE_SERVER); //0:serverMode 1:normalMOde
 //svmodeFlg=MODE_NORMAL;
 delay(500);
 if(svmodeFlg==MODE_NORMAL){
  setup_normalMode(); 
 }else if(svmodeFlg==MODE_SERVER){
  setup_serverMode();
  //setup_normalMode(); 
 }
 
}

void setup_normalMode(){
 ssid = loadString("ssid",ssid);
 delay(500);
 pass = loadString("pass",pass);
 delay(500);
 url  = loadString("url",url);
delay(500);
  Serial.begin(115200);
  delay(1000);
  WiFi.mode(WIFI_STA);
  Wire.begin(8, 9); // SDA=8, SCL=9（ESP32-C系ならOK）
  if (!display.begin(SSD1306_SWITCHCAPVCC, 0x3C)) {
    Serial.println("SSD1306 init failed");
    while (true);
  }
  display.clearDisplay();
  display.setTextSize(1);      // 文字サイズ（1～2程度が実用）
  display.setTextColor(SSD1306_WHITE);
  display.setCursor(0, 0);
  display.println("OLED Ready");
  display.display();
 if (WiFi.status() != WL_CONNECTED) {
    delay(500);
    WiFi.begin(ssid, pass);
    WiFi.setTxPower(WIFI_POWER_8_5dBm); // 出力を約半分に落とす
    delay(100);
    char unsigned ci=0;
    while (WiFi.status() != WL_CONNECTED && ci<12) {
      ci++;
      delay(500);
       display.print(".");
       display.display();
       if (ci>10){
        display.print("cannot Connect WIFI. Change SSID&PW");
        display.display();

}
    }
  }

pinMode(IN1, INPUT_PULLDOWN);
  pinMode(IN2, INPUT_PULLDOWN);
  pinMode(IN3, INPUT_PULLDOWN);
  pinMode(OUT, OUTPUT);
  digitalWrite(OUT, LOW);
   // UART1: RX=21, TX=20
  dfSerial.begin(9600, SERIAL_8N1, 21, 20);
  delay(50);
  if(!dfplayer.begin(dfSerial)) {
    Serial.print("fail");   
  }
    
  vol = loadValue("vol",18);
  dfplayer.volume(vol);   // 0～30
  delay(500); 
 cnumA = loadValue("cnumA",0);
 delay(500); 
 inputNum();
}

void setup_serverMode() {

delay(2000);
  Serial.begin(115200);
  delay(1000);
  // ---- WiFi AFTER display ----
  WiFi.mode(WIFI_AP);
  //WiFi.softAP("ESP32_Config"); // 192.168.4.1
  WiFi.softAP(espSsid,espPass);
  delay(500);
  WiFi.setTxPower(WIFI_POWER_8_5dBm);
  delay(500);
  Serial.println(WiFi.softAPIP());

server.on("/", HTTP_GET, []() {
  String html =
    "<!DOCTYPE html><html><head><meta charset='utf-8'></head><body>"
    "<h2>ESP32 Config</h2>"
    "<form action='/save' method='POST'>"
    "SSID:<br><input name='ssid'><br><br>"
    "Password:<br><input name='pass' type='password'><br><br>"
    "URL:<br><input name='url' size='40'><br><br>"
    "<input type='submit' value='Save'>"
    "</form>"
    "</body></html>";

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

server.on("/save", HTTP_POST, []() {
  String ssid = server.arg("ssid");
  String pass = server.arg("pass");
  String url  = server.arg("url");

saveStringIfChanged("ssid", ssid);
  saveStringIfChanged("pass", pass);
  saveStringIfChanged("url",  url);

server.send(200, "text/html",
    "<html><body>"
    "<h3>Saved</h3>"
    "<a href='/exit'>Exit & Reboot</a>"
    "</body></html>");
});

server.on("/exit", HTTP_GET, []() {
  saveValueIfChanged("svmodeFlg", MODE_NORMAL);
  server.send(200, "text/plain", "Rebooting...");
  delay(1000);
  ESP.restart();
});
  delay(500);
  server.begin();
  delay(500);
    Serial.println("server start");
}

void loop(){ 
  delay(10); 
  if (svmodeFlg == MODE_SERVER) {
    server.handleClient();
    delay(10);   // watchdog対策
     // Serial.println("loop alive");
  } else {
   
  }
}

void check(){
    char numStr[4];
    sprintf(numStr, "%03d", cnumA);
    sprintf(buf, "%s.srt&number=%d", numStr, number);
    resp(buf);  // 送信
}

void resp(String param){
  HTTPClient http;
  http.begin(url+param);
  int code = http.GET();
  if (code == 200) {
    String payload = http.getString();
    display.clearDisplay();
    display.setTextSize(1);
    display.setCursor(0, 0);
    display.print("No.:");
    display.print(cnumA);
    display.print("---");
    display.println(number);
    display.println("---");
    display.println(payload);
    display.display();
  }else{
     display.clearDisplay();
     display.setTextSize(2);
    display.setCursor(0, 0);
    display.print("No.:");
    display.println(cnumA);
    display.setTextSize(1);
    display.println("File Not Exist.");
  
    display.display();
  }

http.end();

}

int inputNum(){
   //dfplayer.stop();
  while(1){
   //RA2 LED          
    if(flg==0 ){  //最初のみ点滅
                digitalWrite(OUT, HIGH);
              delay(1);
                digitalWrite(OUT, LOW);
             delay(1000);
          }       
          
    while (digitalRead(IN1) == HIGH && digitalRead(IN2) == LOW && dispmodeFlg==0){  //長押し　command   1回：次へ　２回以上：前にもどる &再生開始
         cfnum++;
         dash();      
          delay(200);
          if(cfnum==1){
              cnumA++;
          }else if(cfnum==2){
              cnumA=cnumA-cfnum;
          }
          cketa=2;          
          shokaif=0;
     }

while (digitalRead(IN1) == LOW && digitalRead(IN2) == HIGH && dispmodeFlg==0){  //長押し　ファイルカウント 10の位　少し時間おいて　1の位
         cnum++;
         dot();
         flg=1;
         delay(200);
         if(cnum==10){cnum=0;} //十の位が０にしたいとき         
         if(cketa==0&&cnumA>0){cnumA=0;} //dotにふれたら、cnumAは初期化　ただし、累積中はそのまま
      }

if (digitalRead(IN3) == HIGH &&(dispmodeFlg==0 || dispmodeFlg==3)){  //mode change  &  vol change(mode3)
        delay(500);
        if (digitalRead(IN1) == LOW && digitalRead(IN2) == LOW){ //disp mode
         
            dot();
            dcount++;
            if(dcount>1) {
              dispmodeFlg=1;
              dcount=0;
              display.clearDisplay();
              display.setCursor(0, 0);
              display.setTextSize(2);
              display.println("+/- To Change Txt");
              display.display();
            }else{
              dispmodeFlg=3;
            }

}else if(digitalRead(IN1) == LOW && digitalRead(IN2) == HIGH){  // vol+
            display.clearDisplay();
            display.setCursor(0, 0);
            vol++;
            display.setTextSize(2);
            display.println(vol);
            display.setTextSize(1);
            display.println(" Volume changed");
            display.display();
            dot();
            delay(500);
            saveValueIfChanged("vol", vol);
            delay(500);
        }else if(digitalRead(IN1) == HIGH && digitalRead(IN2) == LOW){  // vol-
            display.clearDisplay();
            display.setCursor(0, 0);
            vol--;
            display.setTextSize(2);
            display.println(vol);
            display.setTextSize(1);
            display.println("Volume changed");
            display.display();
            dot();    
            delay(500);
            saveValueIfChanged("vol", vol);
            delay(500);
        }else if(digitalRead(IN1) == HIGH && digitalRead(IN2) == HIGH){
           display.clearDisplay();
           display.setCursor(0, 0);
           display.setTextSize(1);
           display.println("Reboot into ServerMode");
           display.println("*Make A Note!!*");
           display.print("SSID:");
           display.println(espSsid);
           display.print("PASS:");  
           display.println(espPass);  
           display.println("URL:192.168.4.1");  
           display.display();
           saveValueIfChanged("svmodeFlg", MODE_SERVER);
           delay(1000);
           ESP.restart();
        }
    
        flg=1;
      }

if(dispmodeFlg==1 && digitalRead(IN1) == HIGH && digitalRead(IN2) == LOW ){        
        //　prev
         if(number>1){
          number--;  
          dot();
          delay(50);
          check();     
          delay(50);
         }
        
 
       }

if(dispmodeFlg==1 && digitalRead(IN1) == LOW && digitalRead(IN2) == HIGH ){  //　next
         number++;
         dot();
         delay(50);
         check();     
         delay(50);
       }

if(flg && dispmodeFlg==0){  
        flg=0; 
         delay(500);
         cnumA=cnumA*10+cnum;
         cketa++;
         cnum=0;
      }
        
      if((cketa==2||shokaif==1)&& dispmodeFlg==0){
         cketa=0;
         cfnum=0;         
         delay(500);
         char morseCode[15];
         convertToMorse(cnumA,morseCode);
         playMorse(morseCode);   
         delay(50);
        display.clearDisplay();  
        display.setCursor(0, 0);
        display.setTextSize(1);
        display.print("current No.");
        display.println(cnumA);
        display.setTextSize(2);
        display.println("Play:Cmd");
        display.setTextSize(1);
        display.println("OrVolChange:Dsp+-/+");
        display.println("OrTxtChange:Dsp->-/+");
        display.println("OrServerMod:Dsp+(+-)");
        display.display();

delay(500);
             
         if(shokaif==0){  //立ち上げ時は、再生しないように
                //play(1,cnumA);         
                saveValueIfChanged("cnumA", cnumA);
                delay(500); 
                display.clearDisplay();
                display.setCursor(0, 0);
                display.println("fileNum:");
                display.setTextSize(3);
                display.print("   ");
                display.println(cnumA);
                display.setTextSize(1);
                display.println("        --Saved");
                display.display();
                dfplayer.playFolder(1, cnumA);                 
                delay(100);      
           }
         shokaif=0;            
        }  
      delay(300);
   }
}

void dot() {
     digitalWrite(OUT, HIGH);
    delay(100);
     digitalWrite(OUT, LOW);
    delay(100);
}

void dash() {
     digitalWrite(OUT, HIGH);
    delay(300);
     digitalWrite(OUT, LOW);
    delay(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(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;                      // 次の桁へ
    }
}

int loadValue(const char* name,unsigned char df) {
  Preferences prefs;
  prefs.begin(NVS_NS, true);
  int v = prefs.getInt(name, df);
  prefs.end();
  return v;
}

void saveValueIfChanged(const char* name, int v) {
  Preferences prefs;
  prefs.begin(NVS_NS, false);

if (!prefs.isKey(name)) {
    prefs.putInt(name, v);   // 初回は必ず保存
  } else {
    int old = prefs.getInt(name, v);
    if (old != v) {
      prefs.putInt(name, v);
    }
  }

prefs.end();
}

※GPIO7を長押し（2回Beep）で、テキスト番号指定表示可能に変更。GPIO7を押しながら、GPIO5,6を押すことで、音量調整可能にした。

※GPIO７を押しながら、GPIO5,6両方押すと、サーバーモードになり、SSID:ESP32_Config, Pass:12345678で192.168.4.1にアクセスでSSID,Pass,URLを設定変更可能にした。ただ、スマホ（android)では、うまくいかず、PCのChromeだと設定できた。

＊サーバーモードにすると、OLEDを使えなくなるようだったので、あらかじめ、サーバーモード時のSSID、パスワード、URLはどこかにメモしておく必要あり。

2026年1月8日木曜日

esp32-c3のWIFI不具合

アリエクで購入したESP32-C3は、大丈夫だったのですが、某サイトで購入したほうは、WIFIがだめで、ハードの不具合かと別のもの注文してしまったのですが、どうやら、原因は送信出力にあるようで、半分の出力にしたらうまく動作しました。

  WiFi.setTxPower(WIFI_POWER_8_5dBm); // 出力を約半分に落とす

2026年1月5日月曜日

関数解析P69　閉包による集合の包含関係

Aの閉包＋Aの閉包⊂A＋Aの閉包　という性質を使っている式の変形があり、なぜだろうと気になり、調べてみた。

　A={(x,0)|x∈Ｒ}　　B={(x,1/x)|x>0} (双曲線の正の部分）

・Ａ＋Ｂ＝{(x+u,1/u)|x∈R,u>0} これは、よく考えたら、y>0の上半面で、ｘ軸は除く領域

・Ａ＋Ｂの閉包は、ｘ軸も入る。

・ＡもＢも閉集合なのでＡの閉包＋Ｂの閉包＝Ａ＋Ｂ

　　よって　Ａの閉包＋Ｂの閉包⊂Ａ＋Ｂの閉包

今回は、chatGPTよりもgoogleのＡＩのほうが、的確な回答がもらえた。

2026年1月1日木曜日

SO-02Lスマホがなぜか、突然WIFI接続できなくなる

古いスマホなので、新しいWIFIアクセスポイントと合わなくなってきたようだ。これまでWPA/WPA2-PSK（AES）からWPA2-PSK(AES)にしてみたら解決。複雑なネゴシエーションがあると、うまくいかないこともあるから？かもしれません。また、SSIDも同じでないほうがいいようです。以前は、同じにしてローミングできるようにしていましたが、家庭用レベルでは、最近はあまり推奨されないようです。業務等ではきちんと本格的なシステムにしないとローミングは難しいようです。

※その後、よく確認したら、どうもアクセスポイントの故障のようでした。新しいアクセスポイントに変えたら、動作Okでした。ローミングが原因かとうかは、よく確認していませんが、いずれにしろ、SSIDのローミングは、家庭用では、今回のような不具合があると原因がつかみにくいので、やめたほうがいいかもしれません。