Myu: 2026

2026年4月5日日曜日

マウスのクリックボタン修理

マウスの左クリックが急に反応が悪くなる。買い替えようとも思ったけれど、だめもとで、修理してみた。最初は、スイッチボックスのカバーをはずして、接点復活剤をかけてみたが、変わらず。よくみると、スイッチを押すプラスチックの部分がへこんでいて、うまく押せてないことに気づく。長年、押し続けてプラスチックが変形しへこんだと思われます。へこんだ部分にセロテープを何枚か重ねて貼ったら、うまく反応するようになった。

2026年3月31日火曜日

国債の利率高いと円安？

　巷では、国債の利率を高くして円高にしようとするのが常識らしいですが、意外と逆でないかという方もいますね。債券市場では、利率上がれば債券価値は下がるわけで、円安になりやすいのでないかということらしいです。

　円高だと海外のものが安く買えていいと思いがちだけど、日本は、物を作って加工貿易のほうが豊かになるともいえそう。日本は、古い理論に沿って、利率を下げたら円安になると考えていたようです。実際は、利率下げたために円高になり、不況の原因にもなっていた。

　今後は、インフレもあるので、日本は金利は上げざるを得ないとすれば、今後は円安が続き、輸出が好調になりそうな感じもありますね。米国には、不利ですが、米国はそれに気づいてないのかもしれませんね。それで、日本は円高にしたがっていますが、それなら利率下げるべきなんでしょうが。逆のことをやろうとしているという皮肉な結果になりそうです。

　利率上げて円安にして輸出重視で行くほうが、国内に仕事がもどってくるという意味ではいいでしょうね。輸出が好調ならそれに伴い、産業への投資は進みそうですし、供給力増強にもつながりそうです。利率下げて円高にすると、この３０年間見る通り、外に仕事でていってしまって、内需拡大でもしないとなかなか厳しい感じはしますね。(でも、内需拡大すると、バブルがはじけて、また緊縮とか言い出しそうな日本なので、やめておいたほうがいい？）

捨てようか迷っていたタイマーを改造してみた

　キー入力は待ち受け電力が多いためか、電池があまり持たないタイマーだったので、しょっちゅう電池交換も面倒で、いつのまにか使わなくなったタイマーでしたが、そのまま捨てるのももったいない気がして、試しにTTP223と2sc1815で使うときだけOnにするようにしてみた。　　

　TTP223も3uA程度は消費するようので、はたして長持ちするかどうか試してみないとわからないけれど。

　赤色LEDが見えないとOnOffがわかりにくかったので、写真のように、上部からタッチセンサーが見えるように加工した。（タッチセンサの端にハンダが見えますが。これは、センサ本体を中におさめて、延長した導線で、外にタッチ部をだすことを試みたときのもの。あまりうまくいかなかったので、あきらめました。）

　オンのたびモード切替など操作が必要なったり、Offしてから数分置いて完全に電荷が抜けないと再度Onにはできなかったりということはありますが、それでも、少し省エネにはなったのでないかと思います。

※その後、１週間くらいしたら、OFFが完全にならなくなりました。どうも、タッチセンサも若干不安定なようです。原因はよくわかりませんが。

2026年3月27日金曜日

苗床管理Esp32c3による温度調整

しばらく利用してみたが、手元から温度を細かく調整できるのは便利。外気温によって、リレーonの比率が変わるのもグラフから一目瞭然で、異様に比率が高いときは、熱が逃げている可能性もあったりするので、それをみて再度苗床をセットしなおしたりしている。

D2,D3はそれぞれヒーターに密着したセンサーのためかなり高めの温度になっている。D1,D3が制御用のセンサー。発芽までは温度高くてもいいけれど、発芽後はあまり温度が高くても徒長しやすいらしいので、途中から少しさげるようにしている。

2026年3月23日月曜日

追加でEsp32C3を苗床管理用に利用することに

Esp32C3へのマイク、アンプ追加の実験はうまくいかなかったので、マイクは取り除き、センサとSSRをつなげて、苗床管理用に使うことに。ヒーターと白色LED（徒長防止）どちらにも使えるように考えてみた。管理用のアプリは、すでにあるものを若干拡張して使用予定。

bottleの一部

ESP32 = "http://ipad1"
ESP32B = "http://ipad2"
CSV_FILE = "heater_log.csv"
CSV_FILEB = "heater_logB.csv"
MAX_LINES = 432   # ← 最大行数 ３日分

@app.route('/py/collect')
def collectA():
    collectBase(ESP32,CSV_FILE,0)

@app.route('/py/collectB')
def collectB():
    collectBase(ESP32B,CSV_FILEB,1)

def collectBase(esp32,csvfile,flg):
    ts = time.strftime("%Y-%m-%d %H:%M:%S")
    rstatus="ok"
    try:
        #r = requests.get(f"{ESP32}/heaterStats", timeout=5)
        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
        if flg == 0:
         a3_ratio = 100*data["a3_on_time_ms"] / data["dt_ms"] if data["dt_ms"] > 0 else 0
         #{"dt_ms","a1_on_time_ms","a2_on_time_ms","a3_on_time_ms","a1_on_count","a2_on_count","a3_on_count","temp1","temp2","builtin","d1","d2","d3","d4"}
         row = [
          ts,
          data["dt_ms"],
          data["temp1"],
          data["temp2"],
          data["a1_on_time_ms"],
          data["a2_on_time_ms"],
          data["a3_on_time_ms"],
          data["a1_on_count"],
          data["a2_on_count"],
          data["a3_on_count"],
          round(a1_ratio, 1),
          round(a2_ratio, 1),
          round(a3_ratio, 1),
          data["builtin"],
          data["d1"],
          data["d2"],
          data["d3"],
          data["d4"]
          ]
         if data["d1"] > 30  or data["d3"] >  30  : #d1 d3はコントロール対象　３０℃超えないように
          alarmW("heaterHot.wav")
        else:
         row = [
          ts,
          data["dt_ms"],
          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),
          data["d1"],
          data["d2"],
          ]
         if data["d1"]  >  30 or data["d2"]  >  30  : #d1 d2はコントロール対象　３０℃こえないように
          alarmW("heaterHot.wav")

except Exception as e:
        # 失敗時のログだけ残して、サーバは止めない
        print(f"[WARN] ESP32 unreachable: {e}")        
        if flg == 0:
         row = [
          ts,
          0,
          -9.99,   # temp1（欠測の目印）
          -9.99,   # temp2
          0, 0, 0,   0, 0,0, 
          0.0, 0.0, 0.0,
          0.0, 0.0, 0.0, 0.0, 0.0
          ]
        else:
         row = [
          ts,
          0,
          0, 0, 0, 0,
          0.0, 0.0,
          0.0, 0.0
          ]
        rstatus="ng"

# ① まず「追記」
    #with open(CSV_FILE, "a", newline="") as f:
    with open(csvfile, "a", newline="") as f:
        writer = csv.writer(f)
        writer.writerow(row)

# ② 行数を制限（超えたら古い行を削除）
    #with open(CSV_FILE, "r") as f:
    with open(csvfile, "r") as f:
        lines = f.readlines()
    if len(lines) > MAX_LINES:
        lines = lines[-MAX_LINES:]   # ← 最新200行だけ残す
        with open(csvfile, "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():
    resultA = heater_statsBase("/home/pi/heater_log.csv",0)
    response.content_type = 'application/json'
    return json.dumps(resultA)

@app.get("/py/heaterStatsB")
def heater_statsB():
    resultB = heater_statsBase("/home/pi/heater_logB.csv",1)
    response.content_type = 'application/json'
    return json.dumps(resultB)

def heater_statsBase(logfile,flg):
    n = 144  # 6*24=144で１日　必要に応じて可変
    lines = read_file(logfile)
    start = max(0, len(lines) - n)
    latest_lines = lines[start:]
    result = []
    for line in latest_lines:
        # CSVの列に合わせて分割
        if flg == 0:
         dt_str, dt_ms , tempA1 , tempA2 , a1_ms ,a2_ms ,a3_ms, a1_count , a2_count,a3_count , on_percent_a1 , on_percent_a2,on_percent_a3,builtin,d1,d2,d3,d4 = line.strip().split(',', 17)
         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),
            "a3_ms":int(a3_ms),
            "a1_count": int(a1_count),
            "a2_count": int(a2_count),
            "a3_count": int(a3_count),
            "on_percent_a1": float(on_percent_a1),
            "on_percent_a2": float(on_percent_a2),
            "on_percent_a3": float(on_percent_a3),
            "builtin": float(builtin),
            "d1": float(d1),
            "d2": float(d2),
            "d3": float(d3),
            "d4": float(d4)
         })
        else:
         dt_str, dt_ms , a1_ms ,a2_ms , a1_count , a2_count, on_percent_a1 , on_percent_a2,d1,d2 = line.strip().split(',', 9)
         result.append({
            "datetime": dt_str,
            "dt_ms":int(dt_ms),
            "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),
            "d1": float(d1),
            "d2": float(d2)
         }) 
    return result

@app.get("/py/alarm")
@local_only
def alarm():
    # wavファイル名取得
    wav_file = request.query.wav
    alarmW(wav_file)

def alarmW(wav_file):
    file_path = os.path.join("/home/pi", wav_file)
    if not os.path.isfile(file_path):
        return f"File not found: {wav_file}"
    try:
        # リレーON（アンプON）
        GPIO.output(RELAY_PIN, GPIO.HIGH)
        # アンプ安定待ち（重要：ポップノイズ防止）
        time.sleep(0.2)
        # wav再生
        proc = subprocess.Popen(["aplay", file_path])
        proc.wait()
        GPIO.output(RELAY_PIN, GPIO.LOW)

with open("wavlog.txt", "a", newline="") as f:
         writer = csv.writer(f)
         now_str = datetime.now().strftime('%Y-%m-%d %H:%M:%S')
         writer.writerow([now_str, wav_file])
        with open("wavlog.txt", "r") as f:
         lines = f.readlines()
        if len(lines) > MAX_LINES:
          lines = lines[-MAX_LINES:]   # ← 最新2maxlines行だけ残す
          with open("wavlog.txt", "w", newline="") as f:
           f.writelines(lines)  
  
        return f"Played {wav_file}"
    except Exception as e:
        GPIO.output(RELAY_PIN, GPIO.LOW)
        return f"Error: {e}"
  
@app.route('/py/wavlog')
def show_wavlogs():
    logs = []
    try:
        with open('wavlog.txt', 'r', encoding='utf-8') as f:
            reader = csv.reader(f)
            all_logs = list(reader)
            logs = all_logs[-5:]
    except FileNotFoundError:
        return "ログファイルが見つかりません。"

html = """
    <h1>最新のAlarm</h1>
    <ul>
    % for row in reversed(logs):
        <li>時刻: {{row[0]}} | ファイル: {{row[1]}}</li>
    % end
    </ul>
    """
    return template(html, logs=logs)

last_ping = None       # 最後のping時刻
ALARM_THRESHOLD = 30   # 秒（例: 60秒）

# ESPからのGET受信
@app.route('/py/ping')
def ping():
    global last_ping
    last_ping = time.time()
    #log.debug(f"ESP ping at {time.strftime('%X')}")
    return "OK"

# 監視スレッド
def monitor():
    global last_ping
    alarm_on = False
    while True:
        time.sleep(5)  # 5秒ごとチェック
        if last_ping is None:
            # まだESPから来ていない場合は何もしない
            alarm_on = False
            continue

elapsed = time.time() - last_ping
        if elapsed > ALARM_THRESHOLD:
            if not alarm_on:
                print("ESP途切れ! アラーム鳴動")
                #ここで、GPIO27でアンプ電源On
                os.system("aplay /home/pi/espStop.wav &")
                alarm_on = True
        else:
            alarm_on = False

# 監視をバックグラウンドで開始
threading.Thread(target=monitor, daemon=True).start()

last_pingB = None       # 最後のping時刻
ALARM_THRESHOLDB = 30   # 秒（例: 60秒）

# ESPからのGET受信
@app.route('/py/pingB')
def pingB():
    global last_pingB
    last_pingB = time.time()
    #log.debug(f"ESP ping at {time.strftime('%X')}")
    return "OK"

# 監視スレッド
def monitorB():
    global last_pingB
    alarm_onB = False
    while True:
        time.sleep(5)  # 5秒ごとチェック
        if last_pingB is None:
            # まだESPから来ていない場合は何もしない
            alarm_onB = False
            continue

elapsedB = time.time() - last_pingB
        if elapsedB > ALARM_THRESHOLDB:
            if not alarm_onB:
                print("ESP途切れ! アラーム鳴動")
                #ここで、GPIO27でアンプ電源On
                os.system("aplay /home/pi/espStop.wav &")
                alarm_onB = True
        else:
            alarm_onB = False

# 監視をバックグラウンドで開始
threading.Thread(target=monitorB, daemon=True).start()

esp32c3

/* esp32c3+MAX98357A+MCP970+DS18B20+AkitukiSSR********
MAX98357A: DIN-GPIO7  DBCLK-GPIO4  LRC-GPIO5  
TTP223: GPIO10,GPIO20
DS18B20 A1: data-GPIO6
MCP970 A2: data-GPIO3
Akituki: A1-GPIO1  A2-GPIO21
*/

#include <HTTPClient.h>
#include <WiFi.h>
#include <ESPAsyncWebServer.h>
//#include <Wire.h>
#include <Preferences.h>
#include <OneWire.h>
#include <DallasTemperature.h>
Preferences prefs;
#define ONE_WIRE_BUS 6 // データ(黄)で使用するポート番号
#define SENSER_BIT    9      // 精度の設定bit
OneWire oneWire(ONE_WIRE_BUS);
DallasTemperature sensors(&oneWire);
DeviceAddress tempd5 = { 0x28, 0xAB, 0xCA, 0xB2, 0x00, 0x00, 0x00, 0xB3}; //5つ目のDS18B20のアドレス

String ssid1, ssid2, password;

// heaterが使うセンサ
int htr[2] = {1,2};
float d5temp=0.0;
float d6temp=0.0;
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になった時刻

int newMinutes = 10;
unsigned long maxonms = newMinutes * 60UL * 1000UL; // 10分

// ===== WiFi設定 =====
struct WifiCred {
  String ssid;
  String pass;
};
// 先に空のStringで宣言

WifiCred wifiList[2]; // 配列だけ先に作っておく
void loadConfig() {
  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,31);
IPAddress gateway(192,168,1,1);
IPAddress subnet(255,255,255,0);

AsyncWebServer server(80);

bool isAPMode = false;
const char config_page[] PROGMEM = R"rawliteral(
<!DOCTYPE html><html><head><meta charset="UTF-8"><title>WiFi Config</title></head>
<body>
  <h2>WiFi設定モード</h2>
  <form action="/save" method="get">
    SSID1: <input type="text" name="ssid1"><br>
    SSID2: <input type="text" name="ssid2"><br>
    PASS: <input type="password" name="pass"><br>
    <input type="submit" value="保存して再起動">
  </form>
</body></html>
)rawliteral";

#define A1_PIN 1  // SSR
#define A2_PIN 21  // SSR
const int PIN_T1 = 10; // TTP223を接続したピン番号
const int PIN_T2 = 20; // TTP223を接続したピン番号

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

void dtemp(){
  sensors.requestTemperatures();              // 温度取得要求 ds18b20
    delay(800);
    d5temp=sensors.getTempC(tempd5);

// --- MCP9700 (GPIO 3) の処理 ---
  long sum = 0;
  const int samples = 20; // 20回読んで平均化
  for (int i = 0; i < samples; i++) {
    sum += analogRead(3);
    delay(2);
  }
  float raw = sum / (float)samples;  
  float voltage = (raw * 3.3) / 4096.0;  
  d6temp = (voltage - 0.5) / 0.01-4;//補正のため-4
    delay(200); 
}
//*************************index
const char index_html[] PROGMEM = R"rawliteral( 
<!DOCTYPE html>
<html lang="ja">
<head>
<meta charset="UTF-8">
<title>ESP32 Sensor B</title>
<style>
  body { margin:0; background:#000; color:#fff; font-family:sans-serif; }
  #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>

<div id="timestamp"></div>
<table><tr>
<td>
<button id="a1Btn">A1</button><span id="htr1"></span>(<span id="setA1"></span>℃)
</td>
<td>
<button id="a2Btn">A2</button><span id="htr2"></span>(<span id="setA2"></span>℃)
</td>
</tr></table>
<p>　 <span id="builtin">--</span>　<span id="d1">--</span>　<span id="d2">--</span>　　hys:<span id="hys"></span></p>
<p id="msg"></p>
<hr>
<h3>ヒーター設定</h3>
<a href="/config.html">設定画面へ</a>
<hr>
<script>
const interval = 10000; // ESP32側キャプチャ間隔と同じに
const ts = document.getElementById('timestamp');
function updateSensorData() {
  fetch('/data')
    .then(response => response.json())
    .then(data => {    
      
      document.getElementById('d1').textContent = `d1: ${data.d1.toFixed(1)} °C`;
      document.getElementById('d2').textContent = `d2: ${data.d2.toFixed(1)} °C`;
    })
    .catch(err => console.error('Sensor fetch error:', err));
}
function updateImage() {
  const t = new Date();
  ts.textContent = t.toLocaleString(); // PC側日時表示
  updateSensorData();
  loadConfig();
}
function loadConfig(){
  document.getElementById("msg").textContent = "読み込み中...";
  fetch("/getConfig")
    .then(res => res.json())
    .then(data => {
      document.getElementById("setA1").textContent = data.setA1;
      document.getElementById("setA2").textContent = data.setA2;
      document.getElementById("htr1").textContent = sensStats(data.htr1);
      document.getElementById("htr2").textContent = sensStats(data.htr2);
      document.getElementById("hys").textContent = data.hysteresis;
      document.getElementById("msg").textContent = "読み込みOK";
    })
    .catch(err => {
      document.getElementById("msg").textContent = "エラー: " + err;
    });
}
function sensStats(num){
 switch (num){
   case 0:
    stats="None";
    break;
   case 1:
    stats=document.getElementById('d1').textContent;
    break;
   case 2:
    stats=document.getElementById('d2').textContent;
    break;
   default:   
  }
 return stats;
}
const btnMap = {
  a1: document.getElementById('a1Btn'),
  a2: document.getElementById('a2Btn')
};
const apiMap = {
  a1: '/heatera1',
  a2: '/heatera2'
};
// ボタン押下で toggle & 状態更新
for (const key in btnMap) {
  const btn = btnMap[key];
  const url = apiMap[key];
  btn.addEventListener('click', () => {
    fetch(`${url}?toggle=1`)
      .then(response => response.text())
      .then(() => updateButtons());  // 全ボタン状態を取得して反映
  });
}
// 状態取得・ボタン更新
function updateButtons() {
  fetch('/allHeaterStatus')  // 全部まとめて返すサーバAPI
    .then(response => response.json())
    .then(data => {
      for (const key in btnMap) {
        const btn = btnMap[key];
        if (data[key] === 'on') {
          btn.style.backgroundColor = 'red';
          btn.textContent = `${key.toUpperCase()} On`;
        } else {
          btn.style.backgroundColor = '';
          btn.textContent = `${key.toUpperCase()} OFF`;
        }
      }
    });
}
// ページロード時に初期状態反映
updateButtons();
updateImage();
setInterval(updateImage, interval);
</script>
</body>
</html>
)rawliteral";////////////////////////////////////

// config.html の中身///////////////////////////////////
const char config_html[] PROGMEM = R"rawliteral(
<!DOCTYPE html>
<html>
<head>
<meta charset="utf-8">
<title>Heater Config B</title>
<style>
body {
  font-family: Arial, sans-serif;
  margin: 20px;
  background: #f4f4f4;
}
.card {
  background: white;
  padding: 15px;
  border-radius: 8px;
  box-shadow: 0 0 5px rgba(0,0,0,0.1);
  max-width: 420px;
}
h2 {
  margin-top: 0;
}
input {
  width: 80px;
}
.row {
  margin: 8px 0;
}
button {
  margin-top: 10px;
  margin-right: 5px;
}
#msg {
  margin-top: 10px;
  font-size: 0.9em;
}
.nav {
  margin-bottom: 15px;
}
</style>
</head>
<body>
<div class="nav">
  <a href="/">⬅ 戻る（トップへ）</a>
</div>
<div class="card">
<h2>ヒーター設定 B</h2>
<div class="row">
  A1 設定温度:
  <input id="setA1" type="number" step="0.1"> ℃
  　使用センサ：<select id="htr1">
    <option value="0">None</option>
    <option value="1">D1</option>
    <option value="2">D2</option>
  </select>
</div>
<div class="row">
  A2 設定温度:
  <input id="setA2" type="number" step="0.1"> ℃
　使用センサ：<select id="htr2">
    <option value="0">None</option>
    <option value="1">D1</option>
    <option value="2">D2</option>
  </select>
</div>
<div class="row">
  ヒステリシス:
  <input id="hys" type="number" step="0.1"> ℃
</div>
<div class="row">
  ヒータ継続制限時間:
  <input id="newMinutes" type="number" step="1">分
</div>
<button onclick="loadConfig()">読み込み</button>
<button onclick="saveConfig()">保存</button>
<p id="msg"></p></div>
<script>
// ===== 設定を読み込む =====
function loadConfig(){
  document.getElementById("msg").textContent = "読み込み中...";
  fetch("/getConfig")
    .then(res => res.json())
    .then(data => {
      document.getElementById("setA1").value = data.setA1;
      document.getElementById("setA2").value = data.setA2;
      document.getElementById("newMinutes").value = data.newMinutes;
      document.getElementById("htr1").value = data.htr1;
      document.getElementById("htr2").value = data.htr2;
      document.getElementById("hys").value = data.hysteresis;
      document.getElementById("msg").textContent = "読み込みOK";
    })
    .catch(err => {
      document.getElementById("msg").textContent = "エラー: " + err;
    });
}
// ===== 設定を保存する =====
function saveConfig(){
  const a1 = document.getElementById("setA1").value;
  const a2 = document.getElementById("setA2").value;
  const h  = document.getElementById("hys").value;
  const newMinutes  = document.getElementById("newMinutes").value;
  const htr1 = document.getElementById("htr1").value;
  const htr2 = document.getElementById("htr2").value;
  document.getElementById("msg").textContent = "送信中...";
  const url = `/setConfig?setA1=${a1}&setA2=${a2}&hys=${h}&newMinutes=${newMinutes}&htr1=${htr1}&htr2=${htr2}`;
  fetch(url)
    .then(() => {
      document.getElementById("msg").textContent = "保存しました";
    })
    .catch(err => {
      document.getElementById("msg").textContent = "保存エラー: " + err;
    });
}
// ページ表示時に自動読み込み
window.onload = loadConfig;
</script>
</body>
</html>
)rawliteral";/////////////////////////////////////////////////

// ===== setup =====
void setup() {
  Serial.begin(115200);
  delay(500);
  pinMode(PIN_T1, INPUT); 
  pinMode(PIN_T2, INPUT);

// --- タッチセンサによる同時長押し判定 ---
  unsigned long startMs = millis();
  bool pressed = true;
  
  Serial.println("同時押しをチェック中...");
while (millis() - startMs < 3000) { // 3秒間チェック
  // TTP223がHigh(触れている)かチェック。どちらか一瞬でもLowになったら失敗
  if (digitalRead(PIN_T1) == LOW || digitalRead(PIN_T2) == LOW) {
    pressed = false;
    break;
  }
  delay(10);
}

if (pressed) {
    startAPMode(); // 設定モードへ
    return; // ★ここでloopを抜ける
  } else {
    startSTAMode(); // 通常モードへ
  }

}

void startAPMode() {
  isAPMode = true;
  Serial.println("AP Mode: ESP32-Config");

WiFi.disconnect(true);
  delay(500);
  WiFi.mode(WIFI_AP);
  delay(500);
  //esp_wifi_set_country_code("JP", true);
  WiFi.setTxPower(WIFI_POWER_8_5dBm);

WiFi.softAP("ESP32-Config", "12345678",6, false);

delay(500);

server.on("/", HTTP_GET, [](AsyncWebServerRequest *request){
    request->send_P(200, "text/html", config_page);
  });

server.on("/save", HTTP_GET, [](AsyncWebServerRequest *request){
    ssid1 = request->getParam("ssid1")->value();
    ssid2= request->getParam("ssid2")->value();
    password = request->getParam("pass")->value();
    prefs.begin("wifi-config", false);
    prefs.putString("ssid1", ssid1);
    prefs.putString("ssid2", ssid2);
    prefs.putString("pass", password);
    prefs.end();
    
    request->send(200, "text/plain", "保存しました。再起動します...");
    delay(2000);
    ESP.restart();
  });
  server.begin();
}

void startSTAMode() {
  prefs.begin("wifi-config", false);
  ssid1 = prefs.getString("ssid1", "");
  ssid2 = prefs.getString("ssid2", "");
  password = prefs.getString("pass", "");
  prefs.end();
  if (ssid1 == "") {
    Serial.println("設定がないためAPモードへ移行します.pw:1~8 192.168.4.1");
    startAPMode();
    return;
  }
  //WiFi.begin(s.c_str(), p.c_str());
  // ここに通常のWiFi接続処理と、元のセンサー用server.onコードを書く
   sensors.setResolution(SENSER_BIT); //ds18b20　精度セット
    delay(1000);

prefs.begin("heater", false);
setTempA1 = prefs.getFloat("setA1", 25.0);
setTempA2 = prefs.getFloat("setA2", 25.0);
hysteresis = prefs.getFloat("hys", 0.5);
newMinutes=prefs.getInt("newMinutes",10);
htr[0]= prefs.getInt("htr1", 1);
htr[1] = prefs.getInt("htr2", 2);
prefs.end();     
  //Wire.begin(33, 32);
  delay(100); 
  loadConfig();
  
  WiFi.disconnect(true);
  delay(500);
  //WiFi.mode(WIFI_AP);
  WiFi.mode(WIFI_STA);
  delay(500);
  //esp_wifi_set_country_code("JP", true);
  WiFi.setTxPower(WIFI_POWER_8_5dBm);

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

Serial.println("Closing Serial for Analog Measurement...");
  delay(100); 
  Serial.end(); // ★シリアル通信を終了し、ピンを解放  
  // 以降、GPIO 3をアナログ入力として使用可能にする
  pinMode(3, ANALOG);

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

// /config.html を返す
server.on("/config.html", HTTP_GET, [](AsyncWebServerRequest *request){
  request->send_P(200, "text/html", config_html);
});
  
  pinMode(A1_PIN, OUTPUT);
  pinMode(A2_PIN, OUTPUT);
  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 += "\"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){
  dtemp();
  String json = "{";  
  json += "\"d1\":" + String(d5temp, 1) + ",";
  json += "\"d2\":" + String(d6temp, 1)  ;
  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(request->hasParam("htr1")){
    htr[0] = request->getParam("htr1")->value().toInt();
    updated = true;
  }

if(request->hasParam("htr2")){
    htr[1] = request->getParam("htr2")->value().toInt();
    updated = true;
  }

if(request->hasParam("newMinutes")){
    newMinutes = request->getParam("newMinutes")->value().toInt();
    updated = true;
  }

if(updated){
    prefs.begin("heater", false);
    prefs.putFloat("setA1", setTempA1);
    prefs.putFloat("setA2", setTempA2);
    prefs.putFloat("hys", hysteresis);
    prefs.putInt("newMinutes", newMinutes);
    for(int i=0; i<2; i++){
     prefs.putInt(("htr" + String(i+1)).c_str(), htr[i]);
    }
    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 += "\"newMinutes\":" + String(newMinutes) + ",";
  for(int i=0; i<2; i++){
   json += "\"htr" + String(i+1) + "\":" + String(htr[i]) + ",";
  }
  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;
  dtemp();

// ★ リセット（次の区間のため）
  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();

}

//temp control
void controlHeaterGeneric(float currentTemp,
                           float setTemp,
                           bool &state,
                           uint8_t pin,
                           unsigned long &on_time
                           )
{
  if (currentTemp <= 0.0 || currentTemp > 45.0) {
    state = false;
    digitalWrite(pin, LOW);
    if(currentTemp>45){
      HTTPClient http;
          http.begin("http://*.*.*.*:8080/py/alarm?wav=heaterHot.wav");
          http.GET();
          http.end();
    }      
    return;  // これで他の制御をスキップ
  }    
  bool newState = state;
  if (currentTemp < setTemp - hysteresis) {
    newState = true;
  }
  else if (currentTemp > setTemp + hysteresis) {
    newState = false;
  }
  // リレーがONになった時刻を記録
  if (!state && newState) on_time = millis();
  // 安全対策: newMinutes分以上ONはOFF
  maxonms = newMinutes * 60UL * 1000UL; 
  if (state && millis() - on_time > maxonms) {
    newState = false;
    HTTPClient http2;
    http2.begin("http://*.*.*.*:8080/py/alarm?wav=relayOn.wav");
    http2.GET();
    http2.end();
  }
  if (newState != state ) {
    state = newState;
    digitalWrite(pin, state ? HIGH : LOW);
    if (pin == A1_PIN) A1_on_count++;
    if (pin == A2_PIN) A2_on_count++;
  }  
}

float ctemp(int sensorNo)
{    if (sensorNo == 0) return -9.99;  // 無効
    switch(sensorNo)
    {       
        case 1:
            return d5temp;
        case 2:
            return d6temp;
        default:
            return -9.99;  // 範囲外
    }
}

void loop() {
   if (isAPMode) return; // APモード時は何もしない
   
  static unsigned long lastLoop = millis();
  unsigned long now = millis();
  unsigned long dt = now - lastLoop;
  lastLoop = now;
   // ON時間の積算（RasPiが取りに来るまで）
  if (A1State) A1_on_accum_ms += dt;
  if (A2State) A2_on_accum_ms += dt;
 dtemp();

//引数　(float)現在温度,(float)設定温度,onoff状態(bool),pin,on_time(リレーon時刻保持) 
 controlHeaterGeneric(ctemp(htr[0]), setTempA1, A1State, A1_PIN,a1_on_time); 
 controlHeaterGeneric(ctemp(htr[1]), setTempA2, A2State, A2_PIN,a2_on_time); 
  
 if(WiFi.status() == WL_CONNECTED){
    HTTPClient http3;
    http3.begin("http://*.*.*.*:8080/py/ping"); // 生存確認
    int httpCode = http3.GET();                   // これで送信
    
    http3.end();
  } 
  
  delay(9800);
}

※esp32c3のAPモードで苦労する。SSIDやパスワードはAPモードで設定したかったのですが、いろいろ注意が必要なようで、うまく切り替えがいかないときは、以下の点の確認が必要なようです。

IDEの設定：

　Board：ESP32C3 Dev Module CPU:160MHz Flash Mode :DIO Flash Freq :80MHz Upload Speed :460800 USB CDC On Boot :Enabled Partition :Default Erase Flash :Only Sketch 変な時 :All Flash

モードの確認：　WiFi.mode(WIFI_AP);

出力は適切か： WiFi.setTxPower(WIFI_POWER_19_5dBm);　8_5dBmで安定する場合も

チャンネル6でSSID非表示をfalseなら: WiFi.softAP("ESP32_AP", "12345678", 6, false);

※調整器はケースをアクリル板にしているので、風除室だと紫外線で脆くなりやすいかと思い、車用の塗装スプレーをかけている。

※４月になると、日差しが強いと３０度ごえになることもあるので、苗の近くが３０度超えたらアラーム再生するように機能追加した。（これまではヒーター故障想定して、ヒータ近くのセンサが４５℃超えたらアラームとしていたが、それだけではだめだと気付きました。）

2026年3月22日日曜日

トルバムビガーは成長がゆっくり

せっかく、ESP32の温度調整で芽が出たトルバムビガーですが、光が不足すると徒長しやすいので、LEDテープ（昼光色）の利用も検討中。それまでの間、窓際で少しでも光をあてています。（すでに徒長してしまったので、土を追加していますが、今後どうなるか？）

※その後、なかなか大きくならず、逆に穂木のほうが大きくなりつつあるので、どうしたものかと思っていましたが、台木と穂木はそれぞれ温度を調整して、成長度合いを合わせることが必要なようです。

2026年3月17日火曜日

ESP32にマイクとアンプは、負荷が高く断念

esp32C3のハードの能力ではデジタルで音声処理は難しそうで、せっかくの部品購入ではありましたが、諦めて、別の方法に切り替えました。esp32はテキスト処理にとどめておいたほうがい無難なようです。目的は音声認識英英辞典だったので、GithubPagesに、Javascriptでこちらにサイトをつくってみました。スマホなどからアクセスすると便利に使えそうです。

最初からこの方法を思いついていれば、わざわざesp32で難しいことしなくても、実現できたのですが、、、。

<!DOCTYPE html>
<html lang="en">
<head>
    <meta charset="UTF-8">
    <meta name="viewport" content="width=device-width, initial-scale=1.0, maximum-scale=1.0, user-scalable=no">
    <title>Voice Dict</title>
    <style>
        body { display: flex; flex-direction: column; align-items: center; justify-content: center; min-height: 100vh; margin: 0; background: #f0f2f5; font-family: sans-serif; text-align: center; }
        #btn,#repeat { width: 200px; height: 200px; border-radius: 50%; border: 8px solid #fff; background: #007bff; color: white; font-size: 22px; font-weight: bold; cursor: pointer; box-shadow: 0 8px 15px rgba(0,0,0,0.1); transition: 0.2s; -webkit-tap-highlight-color: transparent; }
        #btn:active { transform: scale(0.9); background: #0056b3; }
        #status { margin-top: 15px; color: #666; font-size: 14px; height: 20px; }
        #result-box { margin: 20px; padding: 20px; background: white; border-radius: 15px; width: 85%; max-width: 500px; box-shadow: 0 4px 6px rgba(0,0,0,0.05); min-height: 120px; }
        #word-text { font-size: 26px; color: #333; margin-bottom: 10px; font-weight: bold; text-transform: capitalize; }
        #def-text { font-size: 17px; color: #555; line-height: 1.6; text-align: left; }
    </style>
</head>
<body>

<button id="btn">PUSH & SPEAK</button>
    <div id="status">Ready</div>

<div id="result-box">
        <div id="word-text">English Dictionary</div>
        <div id="def-text">Tap the button and say a word. (e.g., "Apple")</div>
        <button id="repeat">Repeat</button>
    </div>

// 音声認識の設定
        const SpeechRecognition = window.SpeechRecognition || window.webkitSpeechRecognition;
        const recognition = new SpeechRecognition();
        recognition.lang = 'en-US';
        recognition.interimResults = false;

btn.onclick = () => {
            window.speechSynthesis.cancel(); // 再生中の音声を停止
            try {
                recognition.start();
                status.innerText = "Listening...";
                btn.style.background = "#ff4757";
            } catch (e) {
                console.log("Recognition already started");
            }
        };
        
         repeat.onclick = () => {
             speak(word + ". " + meaning);
        };

recognition.onresult = async (event) => {
            word = event.results[0][0].transcript.toLowerCase().trim();
            wordText.innerText = word;
            defText.innerText = "Searching...";
            btn.style.background = "#007bff";

try {
                //const res = await fetch(`https://dictionaryapi.dev{word}`);
                const res = await fetch('https://api.dictionaryapi.dev/api/v2/entries/en/' + word);
                
                const data = await res.json();
                 //speak("Under analysis");
                
                // APIが配列で返ってこない（エラー）場合
                if (!Array.isArray(data) || data.length === 0) {
                    const msg = "Sorry, no definition found for " + word;
                    defText.innerText = msg;
                    speak(msg);
                } else {
                    // ★重要：階層を安全にたどる
                    meaning = data[0].meanings[0].definitions[0].definition;
                    defText.innerText = meaning;
                    speak(word + ". " + meaning);
                }
            } catch (e) {
                defText.innerText = "Error: Check your internet connection.";
                speak("Connection error.");
            }
            status.innerText = "Done";
        };

recognition.onend = () => {
            btn.style.background = "#007bff";
            if (status.innerText === "Listening...") status.innerText = "Ready";
        };

function speak(text) {
            const uttr = new SpeechSynthesisUtterance(text);
            uttr.lang = 'en-US';
            uttr.rate = 0.9;
            window.speechSynthesis.speak(uttr);
        }
    </script>
</body>
</html>

2026年3月15日日曜日

ESP32にスピーカとマイクをつけて実験

短い音の録音再生（エコー）が可能か実験してみた。今後、raspi経由でいろいろ処理を予定していますが。

　配線の数が多いときは、意外とエナメル線が使いやすい。裏表に通したりしてなるべく干渉しないようにした。PCB等の発注も考えたけれど、配線の変更の可能性もあるし、それなりの料金はかかるので、最小限のユニバーサル基板にしてみた。モジュールが基板からはみ出しているところは、あとでサイズがあいそうな百均のケースに固定できないか、考えたい。

/* esp32c3+INMP441+0802A_LCD+MAX98357A********
INMP441:
SD-GPIO6
L/R-Ground
WS-GPIO5
SCK-GPIO4

MAX98357A:
DIN-GPIO7
DBCLK-GPIO4
LRC-GPIO5

0802A:
RS-GPIO0
E-GPIO1
D4-GPIO2
D5-GPIO3
D6-GPIO8
D7-GPIO9
*/

#include <Arduino.h>
#include <driver/i2s.h>
#include <LiquidCrystal.h>

#define I2S_BCLK 4
#define I2S_LRC  5
#define I2S_DIN  6
#define I2S_DOUT 7

#define SAMPLE_RATE 16000
#define BUFFER_SIZE 256

#define RECORD_SECONDS 3

LiquidCrystal lcd(0,1,2,3,8,9);

int32_t micBuffer[BUFFER_SIZE];
int16_t spkBuffer[BUFFER_SIZE];

int16_t audioBuffer[SAMPLE_RATE * RECORD_SECONDS];

bool recording=false;
int recIndex=0;
unsigned long lastSound=0;

void setup(){

Serial.begin(115200);

lcd.begin(8,2);
lcd.print("READY");

i2s_config_t i2s_config = {
.mode=(i2s_mode_t)(I2S_MODE_MASTER|I2S_MODE_RX|I2S_MODE_TX),
.sample_rate=SAMPLE_RATE,
.bits_per_sample=I2S_BITS_PER_SAMPLE_32BIT,
.channel_format=I2S_CHANNEL_FMT_ONLY_LEFT,
.communication_format=I2S_COMM_FORMAT_STAND_I2S,
.intr_alloc_flags=0,
.dma_buf_count=8,
.dma_buf_len=256
};

i2s_pin_config_t pin_config = {
.bck_io_num=I2S_BCLK,
.ws_io_num=I2S_LRC,
.data_out_num=I2S_DOUT,
.data_in_num=I2S_DIN
};

i2s_driver_install(I2S_NUM_0,&i2s_config,0,NULL);
i2s_set_pin(I2S_NUM_0,&pin_config);

i2s_set_clk(I2S_NUM_0,16000,I2S_BITS_PER_SAMPLE_32BIT,I2S_CHANNEL_MONO);

}

void loop(){

size_t bytesRead;

i2s_read(I2S_NUM_0,micBuffer,sizeof(micBuffer),&bytesRead,portMAX_DELAY);

int samples=bytesRead/4;

int32_t energy=0;

for(int i=0;i<samples;i++){

int16_t s=micBuffer[i]>>14;

energy+=s*s;

spkBuffer[i]=s;

if(recording){
audioBuffer[recIndex++]=s;
}

}

energy/=samples;

if(!recording && energy>200000){

recording=true;
recIndex=0;
lastSound=millis();

lcd.clear();
lcd.print("REC");
lcd.setCursor(0,1);
lcd.print("START");

}

if(recording){

if(energy>200000){
lastSound=millis();
}

if(millis()-lastSound>2000){

recording=false;

lcd.clear();
lcd.print("SAVING");

delay(500);

playAudio();

lcd.clear();
lcd.print("READY");

}

void playAudio(){

lcd.clear();
lcd.print("PLAYING");

size_t written;

for(int i=0;i<recIndex;i+=BUFFER_SIZE){

int n=min(BUFFER_SIZE,recIndex-i);

i2s_write(I2S_NUM_0,&audioBuffer[i],n*2,&written,portMAX_DELAY);

}

raspiで音声アラームをスケジュールに従い起動

アラームをスケジュールで起動する仕組みを考えてみた。

wavplay.py**********************

import os
import sys
import time
import subprocess
import RPi.GPIO as GPIO
RELAY_PIN = 27

MAX_LINES = 200
def play_wav(wav_file):
file_path = os.path.join("/home/pi", wav_file)
if not os.path.isfile(file_path):
return f"File not found: {file_path}"
GPIO.setmode(GPIO.BCM)
GPIO.setup(RELAY_PIN, GPIO.OUT)
try:
GPIO.output(RELAY_PIN, GPIO.HIGH)
time.sleep(0.2)
proc = subprocess.Popen(["aplay", file_path])
proc.wait()

with open("wavlog.txt", "a", newline="") as f:

writer = csv.writer(f)

now_str = datetime.now().strftime('%Y-%m-%d %H:%M:%S')

writer.writerow([now_str, wav_file])

with open("wavlog.txt", "r") as f:

lines = f.readlines()

if len(lines) > MAX_LINES:

lines = lines[-MAX_LINES:] # ← 最新2maxlines行だけ残す

with open("wavlog.txt", "w", newline="") as f:

f.writelines(lines)

return f"Played {wav_file}"
except Exception as e:
return f"Error: {e}"
finally:
GPIO.output(RELAY_PIN, GPIO.LOW)
GPIO.cleanup(RELAY_PIN)
if __name__ == "__main__":
if len(sys.argv) < 2:
print("Usage: python script.py <waveFilename>")
sys.exit(1)
filename = sys.argv[1]
result = play_wav(filename)
print(result)

crontab -e******************

0 17-19 10 11-12 * /usr/bin/python3 /home/pi/wavplay.py PurchaseKerosene.wav

ちなみに、現在のcrontabの一部

5 6 * * * /home/pi/update-cloudflare-ufw.sh >> /home/pi/tmp/ufw-cron.log 2>&1

*/10 * 13-29 2 * curl -s http://localhost:8080/py/collect >/dev/null

0 8 13-29 2 * curl "http://*.*.*.*/setConfig?setA1=21.5&setA2=21.4&setA3=21.5"

１行目cloudflare関連、２，３行目が苗床ヒーター管理

2026年3月4日水曜日

IPoE接続に変えてみた

　 PPPoE接続をしばらく使ってきたが、最近土日や夜間がネット途切れるぐらい混雑してきたので、思い切ってIPoEに変えてみたら夜間でもダウンロード220Mbpsアップロード150Mbpsとだいぶ快適になった。

　ルータをどうするかで迷ったが、最近WIFI-Apを交換したばかりだし、WIFI付きの家庭用ルータはどうしても熱のためか、寿命が短いように思われたので、頑丈な有線ルータということで中古のIX2106をヤフオクで入手。希望小売価格が89000円ということなので、6000円ちょっとで購入でき、コスパはいいのでないかと思う。

　ただ、設定は情報集めがなかなか大変だった。ネットのNECの設定例も、ONU接続用の設定？のような感じだったので、PR400NEの内臓ONUを使うには不安があった。（電話はPR400NEから接続しているので、これを使わざるを得ない）　ChatGPTとGoogleAIの助けを借りてなんとか、解決。

注意点としては

・PR400NEの接続１を停止　sshで設定するために、念のためUSBシリアルコンソール（1500円ほど）用意

・NECのサンプルの変更したところ

ip-ad subscriber Giga~は削除　※
interface GigaEthernet0.0

no ip addressip address 192.168.2.2/24
ipv6 enable
ipv6 address autoconfig ※のかわり追加
ipv6 dhcp client dhcpv6-cl
no shutdown

ip dhcp profile dhcpv4-sv

assignable-range 192.168.1.50 192.168.1.70 　::dhcpの範囲を指定できる

dns-server 192.168.1.1

interface Tunnel0.0
tunnel mode 4-over-6
tunnel destination fqdn gw.transix.jp
~~tunnel source GigaEthernet1.0~~ → tunnel source GigaEthernet0.0 に変更
~~ip unnumbered GigaEthernet1.0~~　これはなしで→ ip address 192.0.0.2/29 に変更
ip tcp adjust-mss auto
no shutdown

※内部DNSサーバをうまく扱うことができなかったが、その後、「proxy-dns server ipアドレス priority 優先度」を設定することで、使えるようになった。

　また、bottleサーバでは、cloudflareからの外部アクセス制限をipアドレスで行う方法が使えず、別の方法に変更した。どうしても複雑化しているので細かいところに影響はでてしまうようだ。

※中古のため、縦置きスタンドがなかったため、不要になったアクリルボックスの破片からミニルータでL型に切り抜き、ねじ止めしたら安定するようになる。横置きより縦置きのほうが、熱は逃げやすいと思われるので、縦置きにした。

※念のため、使わずにいた廃品からはずした冷却ファンと使わずにいた温度センサーW1209、それにハードオフの330円の12Vアダプタで冷却もできるようにした。冷却ファンを最初はひもでしばっていたが、どうも不安定なので、あり合わせのアクリル破片をリベットでつないで、縦置き上部に載せられるように、フレームをつくってみた。

※PR400NE側の192.168.2.0/24側に192.168.1.0/24側からアクセスできず、HGWの管理画面が出せず不便だったが、以下の確認することで、なんとか解決できた。

1.PR-400NEの静的ルート: 192.168.1.0/24 宛を 192.168.2.2 へ

2.PR-400NEのipv4パケットフィルタ: 192.168.1.0/24 からの通信を許可

IX2106のマニュアルでは、２つのLANを接続するには、それぞれのインターフェースに ip address 192.168.1.254/24等を記述する例がでていたが、複数のルータが絡む場合はそれぞれきちんと確認が必要だということのようだ。

※結局、上記の設定では、ipv6がつながらないことが判明、再度、こちらの設定例１をもとに修正したらうまくいった。192.168.2.0/24というゾーンはつくらないほうがシンプルでいいようだ。ただ、HGWの管理画面を出すには、なぜかipv4ではだめで、ipv6のグローバルアドレス（たまに更新されるらしい）を指定必要だった。AIの意見も聞きながらも、そのままだとうまくいかないところもあったので、やはり、人間の判断も入れながら適宜修正は必要なようだ。

2026年3月1日日曜日

久しぶりの移動運用

外の気温は6度と、まだ風が冷たかったけれど、比較的電波状況もよく、それほど強い風でもなかったので、久しぶりの移動運用。前回、ダイポールアンテナの実験失敗していたので、再チャレンジ。今回は、NanoVNAで慎重に長さを調整してみたところ、なんとかアンテナチューナで整合できた。末端が地面に近いこともあってか、かなり短めにする必要があった。とりあえず、１エリアの移動局と５９で交信することができた。

　（ヒートガンで柔らかくした）塩ビパイプで、不要になった物干しパイプ、壊れた雪はねの柄、つっぱり棒をつなげて作ったポールなので、かなりしなっていますがなんとか持ちこたえています。近くに１ｍ程度の杭があったので、ひもを結ぶのに使わせてもらいました。

　たまたま、河川公園に来ていた方から、声をかけられ、アマチュア無線だという話をしたところ、以前免許を取ったけど今はやってない方のようでした。受信の様子など、見てもらいながら、少しの間、アイボール。

2026年2月27日金曜日

cloudflareのトンネル利用

これまで、cloudflareのプロキシーは利用していたが、グローバルIpアドレスをルータのものをDNSに設定していたので、Ipアドレスが変更になった途端、外部からアクセスできなくなった。自分では、自動更新の設定なっていたつもりだったけど、よく調べたら、なってなかったようで、結局は、トンネルを作らないとだめだったよう。cloudflareとraspiの間で独自プロトコルでトンネルを作り、常時接続状態にする仕組みのよう。早速、AIに聞きながらraspiにツールをいれ、設定変更。これで、Ipアドレス変更を気にしなくてもよくなり、だいぶ管理は楽になる。

※この方式にしたところ、外部からのアクセスログが正しく記録されなくなってしまった。いろいろ、試行錯誤した結果わかったことは。ヘッダー名: Cloudflareの仕様により、元のIPは CF-Connecting-IP という名前で送られてくるので、それを使うようにする設定が必要らしい。

・sudo a2enmod remoteip

・トンネルでlocalhost:8080でbottleを指定したのがよくなかった。apacheのログを取りたい場合はapache経由のためlocalhost:80にする必要あった。

・ログ形式(apache2.conf)で

LogFormat "%v:%p %a %l %u %t \"%r\" %>s %O \"%{Referer}i\" \"%{User-Agent}i\"" vhost_combined
LogFormat "%a %l %u %t \"%r\" %>s %O \"%{Referer}i\" \"%{User-Agent}i\"" combined
LogFormat "%a %l %u %t \"%r\" %>s %O" common

内部設定(000-default.conf)で

RemoteIPHeader CF-Connecting-IP
RemoteIPInternalProxy 127.0.0.1

変更が必要。

sudo systemctl restart apache2 で再起動。

2026年2月26日木曜日

bottleのformで文字化け

bottleのformのPostで全角文字が文字化けしてしまい、原因がつかめず苦労しました。結局は、対症療法的ですが、以下のようにして解決。

def schedule_edit_post():

　 schedules = load_schedule()

　 new_schedules = []

　 for i, s in enumerate(schedules):

　　　 start = request.forms.get(f"start{i}")

　　　 end = request.forms.get(f"end{i}")

　　　 #title = request.forms.get(f"title{i}")

　　　 title = request.forms.get(f"title{i}").encode('latin1').decode('utf-8')

　いったん、latin1だったものをutf-8にデコードするという、二段構えで解決。bottleのバージョンが古くなってきたから？

2026年2月22日日曜日

raspiでＰＣのタイマー起動2

複数の予約できるようにアップデートしてみた。（一部<textarea>タグを半角にする必要あり）

**********bottle******
#PC on off schedule
SCHEDULE_FILE = "/home/pi/schedule.json"
def load_schedule():
    if not os.path.exists(SCHEDULE_FILE):
        return {}
    with open(SCHEDULE_FILE, "r") as f:
        return json.load(f)
def save_schedule(s):
    tmp = SCHEDULE_FILE + ".tmp"
    with open(tmp, "w") as f:
        json.dump(s, f, indent=2)
    os.replace(tmp, SCHEDULE_FILE)
# 現在のschedule取得
@app.get("/py/schedule")
@local_only
def get_schedule():
    response.content_type = "application/json"
    return load_schedule()

@app.get("/py/schedule/edit")
@local_only
def schedule_edit():
    week_labels = ["日", "月", "火", "水", "木", "金", "土"]
    s = load_schedule()
    html = "<html><head><meta charset='UTF-8'></head><body><h2>スケジュール設定</h2><form method='post'>"
    for i, sched in enumerate(s):
      start = sched["start"]
      end = sched["end"]
      title = sched["title"]
      weekdays = sched["weekdays"]
      html += f"""
      <span>sched{i+1}</span>　開始:<input type="datetime-local" id="start{i}" name="start{i}" value="{start.replace(' ', 'T') if start else ''}" data-index="{i}">　　終了:
      <input type="datetime-local" id="end{i}" name="end{i}" value="{end.replace(' ', 'T') if end else ''}" data-index="{i}">　<input type="text" name="title{i}" id="title{i}" value="{title}" data-index="{i}">
      　曜日:"""

for d, label in enumerate(week_labels):
        checked = "checked" if weekdays[d] else ""
        html += f"""
        <label>
            <input type="checkbox" name="weekday{i}_{d}" {checked}>{label}
        </label>
        """

html += "<br><br>"

html += r"""
    <select id="targetIndex">
    """
    for j in range(len(s)):
     html += f"""
     <option value="{j}">sched{j+1}</option>
    """

html += """
    </select>
    　＜ｔｅｘｔａｒｅａ id="pasteArea" rows="3" cols="60"
  placeholder="ここに貼り付け"></ｔｅｘｔａａｒｅａ>
　<button type="button" onclick="parsePaste()">反映</button>

<h4>新しいスケジュール</h4>　
    開始:<input type="datetime-local" name="start_new">　終了:<input type="datetime-local" name="end_new">
    　<input type="submit" value="保存">
    </form>
    <script>

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

let repeated = false;

for (let d = 0; d < 7; d++) {
        const cb = document.getElementsByName("weekday" + index + "_" + d)[0];
        if (cb && cb.checked) {
            repeated = true;
            break;
        }
    }

return repeated;
}

function checkDateTime(input,i) {
    if (!input.value) return;

const inputDate = new Date(input.value);
    const now = new Date();

if (inputDate < now && !RepeatedReservFlg(i) ) {
      input.style.backgroundColor = "#d3d3d3";  // グレー
    } else {
      input.style.backgroundColor = "";  // 元に戻す
    }
  }

// すべてのdatetime-localを取得
  const inputs = document.querySelectorAll("input[type='datetime-local']");

inputs.forEach(function(input) {
    const index = input.dataset.index;
    // 初期表示時チェック
    checkDateTime(input,index);

// 変更時にもチェック
    input.addEventListener("change", function() {
      checkDateTime(input,index);
    });
  });

});

function parsePaste()
{
    const text = document.getElementById("pasteArea").value.trim();
    const lines = text.split("\\n");
    let start, end,title="";

// パターン① 両方に日付あり
   let r1 = /(\d{4})\/(\d{2})\/(\d{2}).*?(\d{2}):(\d{2}).*?(\d{4})\/(\d{2})\/(\d{2}).*?(\d{2}):(\d{2})/;

// パターン② 終了に日付なし
    let r2 =
    /(\d{4})\/(\d{2})\/(\d{2}).*?(\d{2}):(\d{2}).*?[～~\-]\s*(\d{2}):(\d{2})/;

let m;

if (m = text.match(r1))
    {
        start = new Date(m[1], m[2]-1, m[3], m[4], m[5]);
        end   = new Date(m[6], m[7]-1, m[8], m[9], m[10]);

const lineIndex = lines.findIndex(line => r1.test(line));
        if (lineIndex >= 0 && lines[lineIndex + 1])
         title = lines[lineIndex + 1].trim();
    }
    else if (m = text.match(r2))
    {
        start = new Date(m[1], m[2]-1, m[3], m[4], m[5]);
        end   = new Date(m[1], m[2]-1, m[3], m[6], m[7]);

// 日跨ぎ対応
        if (end <= start)
            end.setDate(end.getDate() + 1);

const lineIndex = lines.findIndex(line => r2.test(line));
        if (lineIndex >= 0 && lines[lineIndex + 2])
         title = lines[lineIndex + 2].trim();

}
    else
    {
        alert("日付形式が認識できません");
        return;
    }

// 開始4分前
    start.setMinutes(start.getMinutes() - 4);

let duration = (end - start) / 60000;

// 25％余裕
    let margin = Math.min(30, Math.max(5, Math.ceil(duration * 0.25)));

end.setMinutes(end.getMinutes() + margin);

const index = document.getElementById("targetIndex").value;

document.getElementById("start"+index).value = toLocal(start);
    document.getElementById("end"+index).value   = toLocal(end);
    document.getElementById("title"+index).value   = title;
}

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

@app.post("/py/schedule/edit")
@local_only
def schedule_edit_post():
    schedules = load_schedule()
    new_schedules = []

for i, s in enumerate(schedules):

start = request.forms.get(f"start{i}")
        end   = request.forms.get(f"end{i}")
        title = request.forms.get(f"title{i}")
        title = title.encode('latin1').decode('utf-8') if title else ""

# ★ 曜日配列を取得
        weekdays = []
        for d in range(7):
            val = request.forms.get(f"weekday{i}_{d}")
            weekdays.append(bool(val))   # チェックされていればTrue

if start and end:
            start = start.replace("T", " ") + ":00"
            end   = end.replace("T", " ") + ":00"

new_schedules.append({
                "start": start,
                "end": end,
                "title": title,
                "weekdays": weekdays
            })
        else:
            # 繰り返しだけ（日時なし）も許可するならここで追加
            if any(weekdays):
                new_schedules.append({
                    "start": "",
                    "end": "",
                    "title": title,
                    "weekdays": weekdays
                })

save_schedule(new_schedules)

return """
    <html><head><meta charset="UTF-8"></head><body>
    保存しました<br>
    <a href="/py/schedule/edit">戻る</a>
    </body></html>
    """

*********gpio_control.py***********

import RPi.GPIO as GPIO
import time
import subprocess
import json
from datetime import datetime, timedelta
import os
IN_PIN = 22       # タッチセンサー入力
OUT_PIN = 4       # ON/OFFパルス出力
SCHEDULE_FILE = "/home/pi/schedule.json"  # タイマー用JSON
PC_IP = "192.168.*.*"  # PINGチェックするPC
GPIO.setmode(GPIO.BCM)
GPIO.setup(IN_PIN, GPIO.IN, pull_up_down=GPIO.PUD_DOWN)
GPIO.setup(OUT_PIN, GPIO.OUT, initial=GPIO.LOW)
def trigger(tm):
    GPIO.output(OUT_PIN, GPIO.HIGH)
    time.sleep(tm)
    GPIO.output(OUT_PIN, GPIO.LOW)
    print(f"{datetime.now()} Trigger executed")
def is_pc_on():
    try:
        result = subprocess.run(
            ["ping", "-c", "1", "-W", "1", PC_IP],
            stdout=subprocess.DEVNULL,
            stderr=subprocess.DEVNULL
        )
        return result.returncode == 0
    except:
        return False
def load_schedule():
    if not os.path.exists(SCHEDULE_FILE):
        return []
    with open(SCHEDULE_FILE) as f:
        return json.load(f)
def check_timer(schedules):

now = datetime.now()
    now_time = now.strftime("%H:%M:%S")

# Python weekday(): 月=0 ... 日=6
    today_index = (now.weekday() + 1) % 7  # あなた形式：日=0

for sched in schedules:

weekdays = sched.get("weekdays", [False]*7)

# ?? 繰り返しスケジュール
        if any(weekdays):

if not weekdays[today_index]:
                continue

start_time = sched["start"][-8:] if sched["start"] else None
            end_time   = sched["end"][-8:]   if sched["end"]   else None

if start_time and end_time:
                if start_time <= now_time <= end_time:
                    return True

# ?? 単発スケジュール
        else:
            start = datetime.strptime(sched["start"], "%Y-%m-%d %H:%M:%S")
            end   = datetime.strptime(sched["end"],   "%Y-%m-%d %H:%M:%S")

if start <= now <= end:
                return True

return False

prevflg = False  # 直前のON/OFF状態
try:
    while True:
        schedules = load_schedule()
        timer_flag = check_timer(schedules)
        touch_flag = GPIO.input(IN_PIN) == GPIO.HIGH
        curflg = timer_flag or touch_flag
        if curflg != prevflg:
          if curflg == False :
             if is_pc_on(): #touch_flg:falseでも、すぐにはping onにならないので反応せず
               trigger(5.0)
          else :
             if is_pc_on()==False:
               trigger(0.1)
          prevflg = curflg
        time.sleep(1)  # 1秒ごとにチェック
finally:
    GPIO.cleanup()

・複数にすることで、複雑度が増して解決が難しかった。そこで、タイマーにしても、タッチセンサーにしても、統一したflagを使うことにして、単純化したらうまくいった。flagがon->offになる場合は、pingでPCをチェックしoffならそのまま、onならoffにするためのHigh信号triggerとし、flagがoff->onになる場合は、pingによりPCチェックをして、onならそのまま、offならonにするためのHigh信号triggerとする。

・offにするためのHigh信号triggerは、長めの1秒にしてやる必要があった。

・曜日による繰り返し設定もできるようにした。(2026/3/5)

raspiでPCのタイマー起動

PCをraspiからタイマー起動、Offできるようにしてみた。

*********gpio_control.py
  
import RPi.GPIO as GPIO
import time
import json
from datetime import datetime, timedelta
import subprocess

IN_PIN = 22
OUT_PIN = 4
SCHEDULE_FILE = "/home/pi/schedule.json"

GPIO.setmode(GPIO.BCM)
GPIO.setup(IN_PIN, GPIO.IN, pull_up_down=GPIO.PUD_DOWN)
GPIO.setup(OUT_PIN, GPIO.OUT, initial=GPIO.LOW)

start_done = False
end_done = False
trigger_active_until = None

PC_IP = "192.168.1.21"   # ←PCのIP

def is_pc_on():
    try:
        result = subprocess.run(
            ["ping", "-c", "1", "-W", "1", PC_IP],
            stdout=subprocess.DEVNULL,
            stderr=subprocess.DEVNULL
        )
        return result.returncode == 0
    except:
        return False

def load_schedule():
    try:
        with open(SCHEDULE_FILE) as f:
            s = json.load(f)
        start = datetime.strptime(s["start"], "%Y-%m-%d %H:%M:%S")
        end   = datetime.strptime(s["end"], "%Y-%m-%d %H:%M:%S")
        return start, end
    except:
        return None, None
  
  
def trigger():
    global trigger_active_until
    GPIO.output(OUT_PIN, GPIO.HIGH)
    trigger_active_until = datetime.now() + timedelta(seconds=1)
    print("Trigger executed")

try:
    while True:
        start, end = load_schedule()
        now = datetime.now()

# ★追加：未来スケジュールならリセット
        if start and now < start:
            start_done = False

if end and now < end:
            end_done = False

# 開始トリガー
        if start and not start_done and start <= now <= start + timedelta(seconds=30):
            print("Start trigger")
            trigger()
            start_done = True
        # 終了トリガー
        if end and not end_done and end <= now <= end + timedelta(seconds=30):
            print("End trigger")
            trigger()
            end_done = True
        # trigger期間中は監視をスキップ
        if trigger_active_until and now < trigger_active_until:
            pass
        else:
            if trigger_active_until:
               GPIO.output(OUT_PIN, GPIO.LOW)
               trigger_active_until = None

# 通常監視
            if GPIO.input(IN_PIN) == GPIO.HIGH:
               GPIO.output(OUT_PIN, GPIO.HIGH)
            else:
               GPIO.output(OUT_PIN, GPIO.LOW)

time.sleep(1)

finally:
    GPIO.cleanup()
                                                               
***********gpio_control.service
                                               
Description=GPIO制御スクリプト
After=network.target

[Service]
ExecStart=/usr/bin/python3 /home/gpio_control.py
WorkingDirectory=/home
StandardOutput=inherit
StandardError=inherit
Restart=always
User=root

[Install]
WantedBy=multi-user.target
                                                               
***********bottle
                                                               #PC on off schedule
SCHEDULE_FILE = "/home/pi/schedule.json"
def load_schedule():
    if not os.path.exists(SCHEDULE_FILE):
        return {}
    with open(SCHEDULE_FILE, "r") as f:
        return json.load(f)
def save_schedule(s):
    tmp = SCHEDULE_FILE + ".tmp"
    with open(tmp, "w") as f:
        json.dump(s, f, indent=2)
    os.replace(tmp, SCHEDULE_FILE)
# 現在のschedule取得
@app.get("/py/schedule")
def get_schedule():
    response.content_type = "application/json"
    return load_schedule()
# schedule設定
@app.post("/py/schedule")
def set_schedule():
    data = request.json
    # 形式チェック＆統一
    start = datetime.strptime(data["start"], "%Y-%m-%d %H:%M:%S")
    end   = datetime.strptime(data["end"], "%Y-%m-%d %H:%M:%S")
    schedule = {
        "start": start.strftime("%Y-%m-%d %H:%M:%S"),
        "end":   end.strftime("%Y-%m-%d %H:%M:%S")
    }
    save_schedule(schedule)
    return {"status": "ok", "schedule": schedule}
@app.get("/py/schedule/edit")
def schedule_edit():

s = load_schedule()

start = s.get("start", "")
    end   = s.get("end", "")

return f"""
    <html>
    <body>
    <h2>スケジュール設定</h2>

開始:<br>
      <input type="datetime-local" name="start" value="{start.replace(' ', 'T') if start else ''}">
      <br><br>

終了:<br>
      <input type="datetime-local" name="end" value="{end.replace(' ', 'T') if end else ''}">
      <br><br>

</form>

</body>
    </html>
    """

@app.post("/py/schedule/edit")
def schedule_edit_post():

start = request.forms.get("start")
    end   = request.forms.get("end")

# datetime-local → json形式へ変換
    start = start.replace("T", " ") + ":00"
    end   = end.replace("T", " ") + ":00"

schedule = {
        "start": start,
        "end": end
    }

save_schedule(schedule)

return """
    <html>
    <body>
    保存しました<br>
    <a href="/py/schedule/edit">戻る</a>
    </body>
    </html>
    """

すでに、22番号Pinをタッチセンサで起動させるようにしていたので、それとの絡みで少し複雑になってしまった。raspiからWeb画面で日時を設定できるようにしてみた。複数セットできると便利かもしれない。

2026年2月8日日曜日

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

カメラも動作させているためか、FNK0060なるESP32 は、BMP280ライブラリの中の名称のダブりなどでうまくビルドできず、苦労した。google AIからかなりハードよりのコードを出してもらいなんとか解決。　また、I2Cは、２つが限度らしく、リレー動作がひとつあまってしまう。結局、DS18B20(苗床には土にさせるし、3個以上も追加できるのでこちらのほうがいい）、SSRも使用することに。

*********esp32***********
  #include <HTTPClient.h>
#include <Arduino_ESP32_OTA.h>

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

//for ds18b20
#include <OneWire.h>
#include <DallasTemperature.h>

struct BME280_Data {
  float temp;
  float pres;
  float builtin;
};

Preferences prefs;

#define ONE_WIRE_BUS 13 // データ(黄)で使用するポート番号
#define SENSER_BIT    9      // 精度の設定bit
OneWire oneWire(ONE_WIRE_BUS);
DallasTemperature sensors(&oneWire);
DeviceAddress tempd1 = { 0x28, 0xBC, 0x04, 0xB4, 0x00, 0x00, 0x00, 0xE4 }; //1つ目のDS18B20のアドレス
DeviceAddress tempd2 = { 0x28, 0x4B, 0x0A, 0xB3, 0x00, 0x00, 0x00, 0x37}; //2つ目のDS18B20のアドレス
DeviceAddress tempd3 = { 0x28, 0x11, 0x26, 0xB3, 0x00, 0x00, 0x00, 0x0F}; //3つ目のDS18B20のアドレス
DeviceAddress tempd4 = { 0x28, 0x25, 0x0D, 0xB4, 0x00, 0x00, 0x00, 0x30}; //4つ目のDS18B20のアドレス

// heaterが使うセンサ
int htr[3] = {3,4,5};

#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();
}

float d1temp=0.0;
float d2temp=0.0;
float d3temp=0.0;
float d4temp=0.0;

BME280_Data getBMPData(uint8_t addr, BMP280_Trim *trim);

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

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

unsigned long a1_on_time = 0;  // A1がONになった時刻
unsigned long a2_on_time = 0;  // A1がONになった時刻
unsigned long a3_on_time = 0;  // A1がONになった時刻

int newMinutes = 10;
unsigned long maxonms = newMinutes * 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);
   //内蔵温度計
  float builtin = temperatureRead();
  float heater=0.0; //工事中  
  return { temp / 100.0f, (float)p / 25600.0f,builtin};
}

// ===== 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 使わない  13はDs18b20で使用
#define A3_PIN 15 //SSR

bool BState = false;  // LEDの現在状態
bool A1State = false;
bool A2State = false;
bool A3State = 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秒毎
  }
}

void dtemp(){
  sensors.requestTemperatures();              // 温度取得要求 ds18b20
    delay(800);
    d1temp=sensors.getTempC(tempd1);
    delay(200);
    d2temp=sensors.getTempC(tempd2);
    delay(200);
    d3temp=sensors.getTempC(tempd3);
    delay(200);
    d4temp=sensors.getTempC(tempd4);
 
}

// ===== setup =====
void setup() {
  Serial.begin(115200);
  delay(500);
   sensors.setResolution(SENSER_BIT); //ds18b20　精度セット
    delay(1000);

prefs.begin("heater", false);
setTempA1 = prefs.getFloat("setA1", 25.0);
setTempA2 = prefs.getFloat("setA2", 25.0);
hysteresis = prefs.getFloat("hys", 0.5);
newMinutes=prefs.getInt("newMinutes",10);
htr[0]= prefs.getInt("htr1", 3);
htr[1] = prefs.getInt("htr2", 4);
htr[2] = prefs.getInt("htr3", 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);
  pinMode(A3_PIN, OUTPUT);
  digitalWrite(A1_PIN,  LOW);
  digitalWrite(A2_PIN,  LOW);
  digitalWrite(A3_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("/heatera3", HTTP_GET, [](AsyncWebServerRequest *request){
    if(request->hasParam("toggle")){
        A3State = !A3State;
        digitalWrite(A3_PIN, A3State ? HIGH : LOW);
    }
    String stateStr = A3State ? "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 += "\"a3\":\"" + String(A3State ? "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);  
   dtemp();

String json = "{";
  json += "\"temp1\":" + String(s1.temp, 2) + ",";
  json += "\"pres1\":" + String(s1.pres, 2) + ",";
  json += "\"temp2\":" + String(s2.temp, 2) + ",";
  json += "\"builtin\":" + String(s1.builtin, 2) + ",";
  json += "\"pres2\":" + String(s2.pres, 2) + ",";
  json += "\"d1\":" + String(d1temp, 1) + ",";
  json += "\"d2\":" + String(d2temp, 1) + ",";
  json += "\"d3\":" + String(d3temp, 1) + ",";
  json += "\"d4\":" + String(d4temp, 1) ;
  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("setA3")){
    setTempA3 = request->getParam("setA3")->value().toFloat();
    updated = true;
  }
  if(request->hasParam("hys")){
    hysteresis = request->getParam("hys")->value().toFloat();
    updated = true;
  }

if(request->hasParam("htr1")){
    htr[0] = request->getParam("htr1")->value().toInt();
    updated = true;
  }

if(request->hasParam("htr2")){
    htr[1] = request->getParam("htr2")->value().toInt();
    updated = true;
  }

if(request->hasParam("htr3")){
    htr[2] = request->getParam("htr3")->value().toInt();
    updated = true;
  }

if(request->hasParam("newMinutes")){
    newMinutes = request->getParam("newMinutes")->value().toInt();
    updated = true;
  }

if(updated){
    prefs.begin("heater", false);
    prefs.putFloat("setA1", setTempA1);
    prefs.putFloat("setA2", setTempA2);
    prefs.putFloat("setA3", setTempA3);
    prefs.putFloat("hys", hysteresis);
    prefs.putInt("newMinutes", newMinutes);
    for(int i=0; i<3; i++){
     prefs.putInt(("htr" + String(i+1)).c_str(), htr[i]);
    }

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 += "\"setA3\":" + String(setTempA3, 2) + ",";
  json += "\"newMinutes\":" + String(newMinutes) + ",";
  for(int i=0; i<3; i++){
   json += "\"htr" + String(i+1) + "\":" + String(htr[i]) + ",";
  }

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);
  dtemp();

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 += "\"a3_on_time_ms\":" + String(A3_on_accum_ms) + ",";
  json += "\"a1_on_count\":" + String(A1_on_count) + ",";
  json += "\"a2_on_count\":" + String(A2_on_count) + ",";
  json += "\"a3_on_count\":" + String(A3_on_count) + ",";
  json += "\"temp1\":" + String(s1.temp, 2) + ",";
  json += "\"temp2\":" + String(s2.temp, 2) + ",";
  json += "\"builtin\":" + String(s2.builtin, 2)+ ",";
  json += "\"d1\":" + String(d1temp, 1) + ",";
  json += "\"d2\":" + String(d2temp, 1) + ",";
  json += "\"d3\":" + String(d3temp, 1) + ",";
  json += "\"d4\":" + String(d4temp, 1) ;
  json += "}";

// ★ リセット（次の区間のため）
  A1_on_accum_ms = 0;
  A2_on_accum_ms = 0;
  A3_on_accum_ms = 0;
  A1_on_count = 0;
  A2_on_count = 0;  
  A3_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 > 45.0) {
    state = false;
    digitalWrite(pin, LOW);
    if(currentTemp>45){
      HTTPClient http;
          http.begin("http://*.*.*.*:8080/py/alarm?wav=heaterHot.wav");
          http.GET();
          http.end();
    }
      
    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
  maxonms = newMinutes * 60UL * 1000UL;
  if (state && millis() - on_time > maxonms) {
    newState = false;
    HTTPClient http2;
    http2.begin("http://*.*.*.*:8080/py/alarm?wav=relayOn.wav");
    http2.GET();
    http2.end();
  }

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

float ctemp(int sensorNo,BME280_Data s1,BME280_Data s2)
{
    if (sensorNo == 0) return -9.99;  // 無効

switch(sensorNo)
    {
        case 1:
            return s1.temp;
        case 2:
            return s2.temp;
        case 3:
            return d1temp;
        case 4:
             return d2temp;
        case 5:
             return d3temp;
        case 6:
            return d4temp;

default:
            return -9.99;  // 範囲外
    }
}

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;
  if (A3State) A3_on_accum_ms += dt;

dtemp(); 
 Serial.printf("d1~4: %.1fC  %.1fC %.1fC %.1fC\n",d1temp,d2temp,d3temp,d4temp); 
 Serial.printf("A1: %.2f C, %.0f hPa　(BltIn %.0fC）\n", s1.temp, s1.pres,s1.builtin);
 Serial.printf("A2: %.2f C, %.0f hPa　 \n", s2.temp, s2.pres);
 Serial.printf("A1State:%s A2State:%s A3State:%s\n",
  A1State ? "ON" : "OFF",
  A2State ? "ON" : "OFF",
  A3State ? "ON" : "OFF"  
);

//引数　(float)現在温度,(float)設定温度,onoff状態(bool),pin,on_time(リレーon時刻保持) 
 controlHeaterGeneric(ctemp(htr[0],s1,s2), setTempA1, A1State, A1_PIN,a1_on_time); 
 controlHeaterGeneric(ctemp(htr[1],s1,s2), setTempA2, A2State, A2_PIN,a2_on_time); 
 controlHeaterGeneric(ctemp(htr[2],s1,s2), setTempA3, A3State, A3_PIN,a3_on_time);

if(WiFi.status() == WL_CONNECTED){
    HTTPClient http3;
    http3.begin("http://*.*.*.*:8080/py/ping"); // 生存確認
    int httpCode = http3.GET();                   // これで送信
    Serial.println(httpCode);        
    http3.end();
  }

delay(9800);
}

*****esp32 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>

<td>
<button id="a1Btn">A1</button><span id="htr1"></span>(<span id="setA1"></span>℃)
</td>
<td>
<button id="a2Btn">A2</button><span id="htr2"></span>(<span id="setA2"></span>℃)

</td>
<td>
<button id="a3Btn">A3</button><span id="htr3"></span>(<span id="setA3"></span>℃)
</td>
</tr></table>
<p><span id="temp1">--</span>　<span id="pres1">--</span> 　<span id="temp2">--</span>　<span id="pres2">--</span>　<span id="builtin">--</span>　<span id="d1">--</span>　<span id="d2">--</span>　<span id="d3">--</span>　 <span id="d4">--</span>　hys:<span id="hys"></span></p>
<p id="msg"></p>
<hr>
<h3>ヒーター設定</h3>
<a href="/config.html">設定画面へ</a>
<hr>

const interval = 10000; // ESP32側キャプチャ間隔と同じに
const img = document.getElementById('camera');
const ts = document.getElementById('timestamp');

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

loadConfig();
}

function sensStats(num){
 switch (num){
   case 0:
    stats="None";
    break;
   case 1:
    stats=document.getElementById('temp1').textContent;
    break;
   case 2:
    stats=document.getElementById('temp2').textContent;
    break;
   case 3:
    stats=document.getElementById('d1').textContent;
    break;

case 4:
    stats=document.getElementById('d2').textContent;
    break;

case 5:
    stats=document.getElementById('d3').textContent;
    break;

case 6:
    stats=document.getElementById('d4').textContent;
    break;

default:

}
 return stats;
}

const btnMap = {
  a1: document.getElementById('a1Btn'),
  a2: document.getElementById('a2Btn'),
  a3: document.getElementById('a3Btn')
};

const apiMap = {
  a1: '/heatera1',
  a2: '/heatera2',
  a3: '/heatera3',
};

// ボタン押下で toggle & 状態更新
for (const key in btnMap) {
  const btn = btnMap[key];
  const url = apiMap[key];
  btn.addEventListener('click', () => {
    fetch(`${url}?toggle=1`)
      .then(response => response.text())
      .then(() => updateButtons());  // 全ボタン状態を取得して反映
  });
}

// 状態取得・ボタン更新
function updateButtons() {
  fetch('/allHeaterStatus')  // 全部まとめて返すサーバAPI
    .then(response => response.json())
    .then(data => {
      for (const key in btnMap) {
        const btn = btnMap[key];
        if (data[key] === 'on') {
          btn.style.backgroundColor = 'red';
          btn.textContent = `${key.toUpperCase()} On`;
        } else {
          btn.style.backgroundColor = '';
          btn.textContent = `${key.toUpperCase()} OFF`;
        }
      }
    });
}

// ページロード時に初期状態反映
updateButtons();

updateImage();

setInterval(updateImage, interval);

</script>

</body>
</html>

******esp32 config.html********
<!DOCTYPE html>
<html>
<head>
<meta charset="utf-8">
<title>Heater Config</title>
<style>
body {
  font-family: Arial, sans-serif;
  margin: 20px;
  background: #f4f4f4;
}
.card {
  background: white;
  padding: 15px;
  border-radius: 8px;
  box-shadow: 0 0 5px rgba(0,0,0,0.1);
  max-width: 420px;
}
h2 {
  margin-top: 0;
}
input {
  width: 80px;
}
.row {
  margin: 8px 0;
}
button {
  margin-top: 10px;
  margin-right: 5px;
}
#msg {
  margin-top: 10px;
  font-size: 0.9em;
}
.nav {
  margin-bottom: 15px;
}
</style>
</head>

<body>

<div class="card">
<h2>ヒーター設定</h2>

<div class="row">
  A1 設定温度:
  <input id="setA1" type="number" step="0.1"> ℃
  　使用センサ：<select id="htr1">
    <option value="0">None</option>
    <option value="1">BMP1</option>
    <option value="2">BMP2</option>
    <option value="3">D1</option>
    <option value="4">D2</option>
    <option value="5">D3</option>
    <option value="6">D4</option>
  </select>
</div>

<div class="row">
  A2 設定温度:
  <input id="setA2" type="number" step="0.1"> ℃
　使用センサ：<select id="htr2">
    <option value="0">None</option>
    <option value="1">BMP1</option>
    <option value="2">BMP2</option>
    <option value="3">D1</option>
    <option value="4">D2</option>
    <option value="5">D3</option>
    <option value="6">D4</option>
  </select>
</div>

<div class="row">
  A3 設定温度:
  <input id="setA3" type="number" step="0.1"> ℃
　使用センサ：<select id="htr3">
    <option value="0">None</option>
    <option value="1">BMP1</option>
    <option value="2">BMP2</option>
    <option value="3">D1</option>
    <option value="4">D2</option>
    <option value="5">D3</option>
    <option value="6">D4</option>
  </select>
</div>

<div class="row">
  ヒステリシス:
  <input id="hys" type="number" step="0.1"> ℃
</div>

<div class="row">
  ヒータ継続制限時間:
  <input id="newMinutes" type="number" step="1">分
</div>

// ===== 設定を読み込む =====
function loadConfig(){
  document.getElementById("msg").textContent = "読み込み中...";

fetch("/getConfig")
    .then(res => res.json())
    .then(data => {
      document.getElementById("setA1").value = data.setA1;
      document.getElementById("setA2").value = data.setA2;
      document.getElementById("setA3").value = data.setA3;
      document.getElementById("newMinutes").value = data.newMinutes;
      document.getElementById("htr1").value = data.htr1;
      document.getElementById("htr2").value = data.htr2;
      document.getElementById("htr3").value = data.htr3;
      document.getElementById("hys").value = data.hysteresis;
      document.getElementById("msg").textContent = "読み込みOK";
    })
    .catch(err => {
      document.getElementById("msg").textContent = "エラー: " + err;
    });
}

// ===== 設定を保存する =====
function saveConfig(){
  const a1 = document.getElementById("setA1").value;
  const a2 = document.getElementById("setA2").value;
  const a3 = document.getElementById("setA3").value;
  const h  = document.getElementById("hys").value;
  const newMinutes  = document.getElementById("newMinutes").value;
  const htr1 = document.getElementById("htr1").value;
  const htr2 = document.getElementById("htr2").value;
  const htr3 = document.getElementById("htr3").value;

document.getElementById("msg").textContent = "送信中...";

const url = `/setConfig?setA1=${a1}&setA2=${a2}&setA3=${a3}&hys=${h}&newMinutes=${newMinutes}&htr1=${htr1}&htr2=${htr2}&htr3=${htr3}`;

fetch(url)
    .then(() => {
      document.getElementById("msg").textContent = "保存しました";
    })
    .catch(err => {
      document.getElementById("msg").textContent = "保存エラー: " + err;
    });
}

// ページ表示時に自動読み込み
window.onload = loadConfig;
</script>

</body>
</html>

// ===== 設定を読み込む =====
function loadConfig(){
  document.getElementById("msg").textContent = "読み込み中...";

fetch("/getConfig")
    .then(res => res.json())
    .then(data => {
      document.getElementById("setA1").value = data.setA1;
      document.getElementById("setA2").value = data.setA2;
      document.getElementById("setA3").value = data.setA3;
      document.getElementById("htr1").value = data.htr1;
      document.getElementById("htr2").value = data.htr2;
      document.getElementById("htr3").value = data.htr3;
      document.getElementById("hys").value = data.hysteresis;
      document.getElementById("msg").textContent = "読み込みOK";
    })
    .catch(err => {
      document.getElementById("msg").textContent = "エラー: " + err;
    });
}

// ===== 設定を保存する =====
function saveConfig(){
  const a1 = document.getElementById("setA1").value;
  const a2 = document.getElementById("setA2").value;
  const a3 = document.getElementById("setA3").value;
  const h  = document.getElementById("hys").value;
  const htr1 = document.getElementById("htr1").value;
  const htr2 = document.getElementById("htr2").value;
  const htr3 = document.getElementById("htr3").value;

document.getElementById("msg").textContent = "送信中...";

const url = `/setConfig?setA1=${a1}&setA2=${a2}&setA3=${a3}&hys=${h}&htr1=${htr1}&htr2=${htr2}&htr3=${htr3}`;

// ページ表示時に自動読み込み
window.onload = loadConfig;
</script>

</body>
</html>
 
  
  *****esp32 config.txt******
  
  SSID1=*****
SSID2=****
PASS=****  
  
  ********bottle*********
#他にも下記コードに応じて適宜import必要
import RPi.GPIO as GPIO

#for alarm speaker relay
GPIO.setmode(GPIO.BCM)      # GPIO番号方式
GPIO.setwarnings(False)
RELAY_PIN = 27
GPIO.setup(RELAY_PIN, GPIO.OUT)
GPIO.output(RELAY_PIN, GPIO.LOW)   # 初期状態：OFF
  
  
ESP32 = "http://192.168.*.*"
CSV_FILE = "heater_log.csv"
MAX_LINES = 432   # ← 最大行数 ３日分
  
# エラーカウント保持用の辞書（関数の外、またはクラス内で1回だけ初期化）
sensor_errors = {"D1": 0, "D2": 0, "D3": 0, "D4": 0}
def check_sensor_health(data, error_dict):
    targets = ["D1", "D2", "D3", "D4"]
    current_hour = datetime.now().hour
    if current_hour >= 22 or current_hour < 6:
     thresholdt = 4  # 就寝時は4回
    else:
     thresholdt = 1  # 日中は1回

r = requests.get(f"{ESP32}/getConfig", timeout=5)
    r.raise_for_status()   # 200以外なら例外
    data = r.json()
    htr = [data["htr1"], data["htr2"], data["htr3"]]
    heater_sensors = {f"D{h-2}" for h in htr}    
    for key in targets:
        # データの存在確認
        val = data.get(key)
        if val == -127:
            error_dict[key] += 1
            print(f"Warning: Sensor {key} error count: {error_dict[key]}")
        else:
            error_dict[key] = 0 # 正常ならリセット
        if error_dict[key] == thresholdt and key in heater_sensors:
            print(f"Alert: Sensor {key} has failed {thresholdt} times!")
            alarmW("sensor_error.wav")
            error_dict[key] = 100

@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
        a3_ratio = 100*data["a3_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["a3_on_time_ms"],
         data["a1_on_count"],
         data["a2_on_count"],
         data["a3_on_count"],
         round(a1_ratio, 1),
         round(a2_ratio, 1),
         round(a3_ratio, 1),
         data["builtin"],
         data["d1"],
         data["d2"],
         data["d3"],
         data["d4"]
         ]
        check_sensor_health(data, sensor_errors)
  
  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, 0.0, 0.0,
         0.0, 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:]   # ← 最新200行だけ残す

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 ,a3_ms, a1_count , a2_count,a3_count , on_percent_a1 , on_percent_a2,on_percent_a3,builtin,d1,d2,d3,d4 = line.strip().split(',', 17)
        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),
            "a3_ms":int(a3_ms),
            "a1_count": int(a1_count),
            "a2_count": int(a2_count),
            "a3_count": int(a3_count),
            "on_percent_a1": float(on_percent_a1),
            "on_percent_a2": float(on_percent_a2),
            "on_percent_a3": float(on_percent_a3),
            "builtin": float(builtin),
            "d1": float(d1),
            "d2": float(d2),
            "d3": float(d3),
            "d4": float(d4)
        })
    return json.dumps(result)

@app.get("/py/alarm")
@local_only
def alarm():
    # wavファイル名取得
    wav_file = request.query.wav
    file_path = os.path.join("/home/pi", wav_file)

if not os.path.isfile(file_path):
        return f"File not found: {wav_file}"

try:
        # リレーON（speaker ON）
        GPIO.output(RELAY_PIN, GPIO.HIGH)

# アンプ安定待ち
        time.sleep(0.2)

# wav再生
        proc = subprocess.Popen(["aplay", file_path])
        proc.wait()

GPIO.output(RELAY_PIN, GPIO.LOW)

return f"Played {wav_file}"

except Exception as e:
        GPIO.output(RELAY_PIN, GPIO.LOW)
        return f"Error: {e}"

last_ping = None       # 最後のping時刻
ALARM_THRESHOLD = 30   # 秒（例: 60秒）

# ESPからのGET受信
@app.route('/py/ping')
def ping():
    global last_ping
    last_ping = time.time()
    #log.debug(f"ESP ping at {time.strftime('%X')}")
    return "OK"

# 監視をバックグラウンドで開始
threading.Thread(target=monitor, daemon=True).start()

*****heater_graph.html******
  ESP32 = "http://*.*.*.*"

CSV_FILE = "heater_log.csv"

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

]
    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, 0.0, 0.0,
         0.0, 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:]   # ← 最新200行だけ残す

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/alarm")
@local_only
def alarm():
    #GPIO27でアンプ電源on
    wav_file = request.query.wav  # URLの ?wav=ファイル名
    # ファイルパスを作成
    file_path = os.path.join("/home/pi", wav_file)
    
    # ファイル存在確認
    if not os.path.isfile(file_path):
        return f"File not found: {wav_file}"
    
    # aplayで再生（非同期で鳴らす場合は Popen）
    try:
        subprocess.Popen(["aplay", file_path])
        return f"Playing {wav_file}"
    except Exception as e:
        return f"Error: {e}"

last_ping = None       # 最後のping時刻
ALARM_THRESHOLD = 30   # 秒（例: 60秒）

# ESPからのGET受信
@app.route('/py/ping')
def ping():
    global last_ping
    last_ping = time.time()
    #log.debug(f"ESP ping at {time.strftime('%X')}")
    return "OK"

# 監視をバックグラウンドで開始
threading.Thread(target=monitor, daemon=True).start()

********heater_stats.html**********
ESP32 = "http://*.*.*.*"