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

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

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

追加で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"] ] 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"], ] 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(); 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 += "\"d1\":" + String(d5temp, 1) + ","; json += "\"d2\":" + String(d6temp, 1) ; 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(); } //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);

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

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

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

 

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> <script> const btn = document.getElementById('btn'); const repeat=document.getElementById('repeat'); const status = document.getElementById('status'); const wordText = document.getElementById('word-text'); const defText = document.getElementById('def-text'); let meaning=""; let word=""; // 音声認識の設定 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>

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関連、２，３行目が苗床ヒーター管理

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の意見も聞きながらも、そのままだとうまくいかないところもあったので、やはり、人間の判断も入れながら適宜修正は必要なようだ。