Myu: 追加で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();

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

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

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

Myu

2026年3月23日月曜日

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

0 件のコメント:

コメントを投稿