Myu: 2026

2026年9月1日火曜日

raspi3にさらにUSBカメラと人感センサーつないでみる

raspi3のUSBカメラの準備としては
sudo apt-get install fswebcam
sudo modprobe uvcvideo
ls /dev/video*　で0番のカメラが認識できていればOk
一回でうまくいかないときは、
sudo modprobe -r uvcvideo
sudo modprobe uvcvideoでリセットしてUSBカメラつなぎなおし、
再度ls /dev/video*　で　/dev/video0が出ればOk

前回のCdsセンサー、赤外線学習機能に加え、raspi2のボトルからraspi3のカメラ、人感センサも使えるようにコードを追加した。現在のカメラの静止画像と人感センサが反応したときの静止画像を遠隔で確認できるようにしてみた。raspiとセンサやカメラ組み合わせるだけでいろいろなことができて便利。

********raspi2のbottle********
RASPI3_USER = "pi"                 # Raspberry Pi 3のユーザー名
RASPI3_IP = "*.*.*.*"        # Raspberry Pi 3のIPアドレス
RASPI3_NAS_PATH = "****"      # Raspberry Pi 3側から見たNASの保存先パス（最後に / ）
monitor_thread = None
is_monitoring = False
INDEX_HTML = """
<!DOCTYPE html>
<html>
<head>
    <meta charset="utf-8">
    <title>ラズパイ遠隔カメラ管理</title>
    <meta name="viewport" content="width=device-width, initial-scale=1">
    <style>
        body { font-family: sans-serif; background: #f0f2f5; margin: 0; padding: 20px; color: #333; }
        .container { max-width: 800px; margin: 0 auto; background: #fff; padding: 20px; border-radius: 8px; box-shadow: 0 2px 4px rgba(0,0,0,0.1); }
        h1 { border-bottom: 2px solid #333; padding-bottom: 10px; margin-top: 0; }
        .status-box { padding: 15px; border-radius: 5px; font-weight: bold; margin-bottom: 20px; font-size: 1.1em; }
        .status-on { background: #d4edda; color: #155724; border: 1px solid #c3e6cb; }
        .status-off { background: #f8d7da; color: #721c24; border: 1px solid #f5c6cb; }
        .btn { display: inline-block; padding: 10px 20px; font-size: 1em; font-weight: bold; text-decoration: none; border-radius: 5px; color: #fff; border: none; cursor: pointer; margin-right: 10>
        .btn-start { background: #28a745; }
        .btn-stop { background: #dc3545; }
        .btn-shot { background: #007bff; }
        .btn-refresh { background: #6c757d; }
          
          * 写真リスト全体をキュッと小さく並べる設定 */
.grid {
    display: grid;
    grid-template-columns: repeat(auto-fill, minmax(120px, 1fr));
    gap: 10px;
    margin-top: 20px;
}

/* 表示される画像自体のサイズを小さく制限する設定 */
.card {
    background: #fff;
    border: 1px solid #ddd;
    border-radius: 5px;
    overflow: hidden;
    text-align: center;
}
.card img {
    width: 100%;
    height: 80px;
    object-fit: cover;
    background: #eaeaea;
}
.card-name {
    padding: 4px;
    font-size: 0.75em;
    word-break: break-all;
}

</style>
</head>
<body>
    <div class="container">
        <h1>📸 ラズパイ2 → ラズパイ3 遠隔カメラ管理</h1>

% if is_monitoring:
            <div class="status-box status-on">🟢 現在状態: ラズパイ3のセンサー遠隔監視中</div>
        % else:
            <div class="status-box status-off">🔴 現在状態: 遠隔監視停止中</div>
        % end

<div>
          
                   % if not is_monitoring:
                <a href="/start" class="btn btn-start">▶ 遠隔監視 開始</a>
            % else:
                <a href="/stop" class="btn btn-stop">■ 遠隔監視 停止</a>
            % end
            <a href="/shot" class="btn btn-shot">📸 リアルタイム手動撮影</a>
            <a href="/py/monitor" class="btn btn-refresh">🔄 画面更新</a>
        </div>

<h2>🗂️ NASの写真リスト (最新12枚)</h2>
        % if not files:
            <p>写真が見つかりません。マウントパスを確認するか、撮影を行ってください。</p>
        % else:
            <div class="grid">
                % for f in files:
                    <div class="card">
                        <img src="/images/{{f}}" alt="{{f}}">
                        <div class="card-name">{{f}}</div>
                    </div>
                % end
            </div>
        % end

</div>
</body>
</html>
"""

# 【設定】ラズパイ2側から見た、NASの写真保存先パス（最後に必ず / を付ける）
LOCAL_NAS_PATH = "/****/"

@app.route('/py/monitor')
def index_monitor():
    # NAS内のJPGファイルを更新日時の新しい順（降順）に取得
    search_path = os.path.join(LOCAL_NAS_PATH, "*.jpg")
    jpg_files = glob.glob(search_path)
    jpg_files.sort(key=os.path.getmtime, reverse=True)

# 画面が重くならないよう、最新の「12枚」だけを表示に回す
    latest_files = [os.path.basename(f) for f in jpg_files[:12]]

# テンプレートに状態とファイル名リストを渡す
    return template(INDEX_HTML, is_monitoring=is_monitoring, files=latest_files)

# 画像ファイルをブラウザに表示するためのルーティング（これも追記）
@app.route('/images/<filename>')
def serve_image(filename):
    return static_file(filename, root=LOCAL_NAS_PATH)

@app.route('/start')
def start_monitor():
    global is_monitoring
    print("ラズパイ3の監視プログラムをリモート起動します。")
    # SSH経由でラズパイ3内の「security_cam.py」をバックグラウンド(nohup)で実行させる
    # これにより、ラズパイ2との通信が切れてもラズパイ3が単体でセンサーを監視し続けます
    ssh_start_cmd = f"ssh {RASPI3_USER}@{RASPI3_IP} 'nohup python3 /home/pi/security_cam.py > /dev/null 2>&1 &'"
    subprocess.run(ssh_start_cmd, shell=True)
    is_monitoring = True
    redirect('/py/monitor')
  
@app.route('/stop')
def stop_monitor():
    global is_monitoring
    print("ラズパイ3の監視プログラムをリモート停止します。")
    # SSH経由でラズパイ3内で動いている「security_cam.py」のプロセスを強制終了(kill)する
    ssh_stop_cmd = f"ssh {RASPI3_USER}@{RASPI3_IP} 'pkill -f security_cam.py'"
    subprocess.run(ssh_stop_cmd, shell=True)
    is_monitoring = False
    redirect('/py/monitor')

@app.route('/shot')
def realtime_shot():
    timestamp = time.strftime("%Y%m%d_%H%M%S")
    filename = f"manual_{timestamp}.jpg"
    full_path = f"{RASPI3_NAS_PATH}{filename}"

print(f"【遠隔手動撮影】ラズパイ3に即時撮影を指示します: {filename}")
    # SSH経由でラズパイ3のUSBカメラを直接叩いてNASへ保存
    ssh_cmd = f"ssh {RASPI3_USER}@{RASPI3_IP} 'fswebcam -d /dev/video0 -r 1280x720 --no-banner -S 20 {full_path}'"
    subprocess.run(ssh_cmd, shell=True)

time.sleep(1)
    redirect('/py/monitor')

*******raspi3*******
**security_cam.py   
import time
import subprocess
import RPi.GPIO as GPIO

# 【設定】センサーの信号線を繋いだGPIO番号
INT_SENSOR_PIN = 23

# 【設定】fstabで確認したNASのマウント先フォルダのパス（最後に / を付ける）
NAS_PATH = "nas_share/Photos/"

# 【設定】撮影後の待機時間（秒）。連続撮影を防ぐため、10秒〜30秒程度がおすすめ
SLEEP_TIME = 10

GPIO.setmode(GPIO.BCM)
GPIO.setup(INT_SENSOR_PIN, GPIO.IN)

print("=== 自作防犯カメラシステム 起動 ===")
print(f"保存先: {NAS_PATH}")
print("監視を開始しました...（終了するには Ctrl + C）")

try:
    while True:
        # センサーが人を検知（HIGH）したとき
        if GPIO.input(INT_SENSOR_PIN) == GPIO.HIGH:
            # 現在の日時を取得してファイル名にする (例: capture_20260901_112530.jpg)
            timestamp = time.strftime("%Y%m%d_%H%M%S")
            filename = f"capture_{timestamp}.jpg"
            full_path = f"{NAS_PATH}{filename}"

print(f"【検知】人を感知しました。NASへ保存します: {filename}")

# 復活した /dev/video0 を使って撮影するコマンド
            cmd = f"fswebcam -d /dev/video0 -r 1280x720 --no-banner -S 20 {full_path}"

# コマンドをバックグラウンドで実行
            subprocess.run(cmd, shell=True)

print(f"{SLEEP_TIME}秒間、次の検知をウェイトします...")
            time.sleep(SLEEP_TIME)
            print("監視を再開します。")

time.sleep(0.2)

except KeyboardInterrupt:
    print("\nシステムを安全に終了します。")
    GPIO.cleanup()

************

2026年8月28日金曜日

明るさをCdsで検知(raspi3)

Cds(1MΩ)が安価だったので、1uFのコンデンサへの充電時間で、明るさをraspi3でチェックする機能を追加してみた。写真の上部のケース外が赤外線送信モジュール、電源接続付近のモジュールが受信モジュール、GPIOピンに直接基板をさしているのがCds+コンデンサの回路。

********1secごと　コマンドラインで表示
import time
import RPi.GPIO as GPIO

# ピン番号の定義
PIN_CDS = 23  # GPIO 11 (Physical Pin 23)

# GPIOの設定
GPIO.setmode(GPIO.BOARD)  # BOARDモードに変更

def measure_light():
    # 1. リセット（アーシング）：ピンを出力にしてLOW(0V)にし、コンデンサを空にする
    GPIO.setup(PIN_CDS, GPIO.OUT)
    GPIO.output(PIN_CDS, GPIO.LOW)
    time.sleep(0.1)  # 完全に電気が抜けるまで少し待つ（100ミリ秒）

# 2. 計測スタート：ピンを入力（高抵抗の電圧計）に切り替える
    GPIO.setup(PIN_CDS, GPIO.IN)

start_time = time.time()

# 3. 23番ピンが「ON(High)」になるまでループして待つ
    # 暗すぎるときに無限ループになるのを防ぐため、最大1秒で強制終了（タイムアウト）させる
    while GPIO.input(PIN_CDS) == GPIO.LOW:
        if (time.time() - start_time) > 1.0:
            return 1.0  # 1秒以上かかったら「真っ暗(1.0)」とする

# 4. ONになるまでにかかった時間を計算
    duration = time.time() - start_time
    return duration

print("明るさ計測テストを開始します。Ctrl+Cで終了します。")

try:
    while True:
        # 充電にかかった時間を取得
        charge_time = measure_light()*1000

# 【判定基準の目安】※パーツや部屋の環境に合わせて後から数値を微調整してください
        # 明るい時（照明ON）：数ミリ秒〜数十ミリ秒（0.05秒以下など）
        # 暗い時（照明OFF）：数百ミリ秒〜1秒近く（0.5秒以上など）
        if charge_time < 10:
            status = "部屋の照明：ON（明るい）"
        else:
            status = "部屋の照明：OFF（暗い）"

print(f"充電時間: {charge_time:.4f} ms ➔ {status}")

time.sleep(1)  # 1秒ごとに繰り返し計測

except KeyboardInterrupt:
    print("\n計測を終了します。")
finally:
    GPIO.cleanup()  # GPIOピンの状態を安全に解放
                            
*******measure_light.py として、raspi2のbottleから呼び出すためのコード
                            # 【Raspi3側に保存するコード: /home/pi/measure_light.py】
import time
import RPi.GPIO as GPIO

PIN_CDS = 23
GPIO.setmode(GPIO.BOARD)

# 放電リセット
GPIO.setup(PIN_CDS, GPIO.OUT)
GPIO.output(PIN_CDS, GPIO.LOW)
time.sleep(0.1)

# 計測開始
GPIO.setup(PIN_CDS, GPIO.IN)
start_time = time.time()

while GPIO.input(PIN_CDS) == GPIO.LOW:
    if (time.time() - start_time) > 1.0:
        start_time = time.time() - 1.0  # 1秒タイムアウト
        break

# ミリ秒に変換して、数値だけを出力
charge_time_ms = (time.time() - start_time) * 1000
print(f"{charge_time_ms:.2f}")

GPIO.cleanup()

########raspi2のbottleから上記コマンドを扱うためのコード
def get_raspi3_light():
    try:
        # 【重要】piユーザーの秘密鍵の絶対パスを指定（通常は /home/pi/.ssh/id_rsa）
        # ※ファイル名が id_ed25519 などの場合はそれに合わせてください
        key_path = "/home/pi/.ssh/id_rsa"

# ssh コマンドに「-i 鍵のパス」を追加します
        cmd = [
            "ssh",
            "-i",
            key_path,
            "pi@192.168.x.x",  # ※Raspi3のIPまたはホスト名
            "python3 /home/pi/measure_light.py",
        ]

result = subprocess.run(cmd, capture_output=True, text=True, timeout=3)

# 念のため、エラーログが出ていないか確認
        if result.returncode != 0:
            return f"エラー: {result.stderr.strip()}"

light_ms = result.stdout.strip()
        return f"{light_ms} ms"
    except Exception as e:
        return "取得エラー"

#######以前のindexページは以下のように変更
@route("/***/***")
def index():
    # ページを開いた瞬間にRaspi3の明るさを取得
    current_light = get_raspi3_light()

# 5段階判定（Raspi2側で判定を行います）
    try:
        val = float(current_light.replace(" ms", ""))
        if val < 1.5:
            status = "超明るい"
        elif val < 3.0:
            status = "明るい (照明ON)"
        elif val < 5.0:
            status = "普通"
        elif val < 7.0:
            status = "薄暗い"
        else:
            status = "真っ暗 (照明OFF)"
    except ValueError:
        status = "判定不能"

# HTMLに埋め込んで返す
    return f"""
        <h1>照明リモコン</h1>
        <div style="background: #f0f0f0; padding: 10px; margin-bottom: 20px; border-radius: 5px;">
            <p style="font-size: 1.2em; margin: 5px 0;">現在の明るさ: <strong>{current_light}</strong></p>
            <p style="font-size: 1.2em; margin: 5px 0;">状態の目安: <strong>{status}</strong></p>
        </div>
        <form action="/press_button" method="post">
            <button type="submit" style="font-size:2em; padding:20px 40px;">
                ON / OFF ボタンを押す
            </button>
        </form>
    """

2026年8月24日月曜日

rasp2経由でraspi3へssh

raspi2経由でraspi3へsshするには、
ssh-keygen -t rsa -b 4096　として、３回リターン
ssh-copy-id pi@raspi3のIPアドレス　ここでyesのあと、ログインのためのパスワード
ssh pi@raspi3のIPアドレス　パスワードなしでSSH使えるようになります。

これを使って、raspi2からraspi3の操作（赤外線等）をすることに。

import subprocess
from bottle import route, run, template
@route('/***/***')
def index():
return '''
<h1>照明リモコン</h1>
<form action="/press_button" method="post">
<button type="submit" style="font-size:2em; padding:20px 40px;">
ON / OFF ボタンを押す
</button>
</form>
'''

@route('/press_button', method='POST')
def press_button():
cmd = ["ssh", "pi@アドレス", "python3 /home/pi/shomei.py"]
result = subprocess.run(cmd, capture_output=True, text=True)
raspi3_reply = result.stdout
raspi3_error = result.stderr

if result.returncode == 0:
return f"<h1>送信成功！</h1><p>Raspi3からの返事: {raspi3_reply}</p>"
else:
return f"<h1>エラー発生</h1><p>理由: {raspi3_error}</p>"

# Raspi 3側の /home/pi/shomei.py の中身

import subprocess

try:

cmd = ["sudo", "ir-ctl", "-s", "/home/pi/shomei.txt", "-d", "/dev/lirc0"]

subprocess.run(cmd, check=True)

print("赤外線信号を送信しました。")

except subprocess.CalledProcessError as e:

print(f"ir-ctlの実行に失敗しました。エラーコード: {e.returncode}")

2026年8月23日日曜日

raspi3で赤外線の実験

赤外線モジュールをつないで、受信
　受信モジュールのピン　　Raspi3の接続先　　ピン番号（物理）
　VCC (または + )　　　　　　　3.3V Power　1番ピン
　GND (または -)　　　　　　　　GND　　　　　6番ピン
　OUT (または S / Data)　　　　GPIO 17　　11番ピン

送信は図のような回路をつないでみた

以下のコードで受信可能

ir-ctl -r -d /dev/lirc1 > single.txt

送信は

ir-ctl -s single.txt -d /dev/lirc0 　

sudo apt update
sudo apt install v4l-utils -y 
*********ir-ctl.py
import os
import time

# 送信デバイスのパス（環境によっては /dev/lirc1 の場合があります）
LIRC_DEV = "/dev/lirc0"

# 真似したいリモコンのパルスデータ（マイクロ秒単位の整数）
# ※先ほど画面に出た「(0, 9.02), (1, 4.45)」などのミリ秒データを
# 　マイクロ秒（1000倍）にして、数字だけを並べたものです。
# 例：[ONの時間, OFFの時間, ONの時間, OFFの時間...]
sample_signal = [
    9000, 4500,  # リーダーコード（開始の合図）
    560, 560,    # ここからデータビット（0や1の集まり）
    560, 1690,
    560, 560,
    560, 560,
    # （ここにお手持ちのリモコンのデータをずらっと並べます）
]

def send_ir(pulse_list):
    if not os.path.exists(LIRC_DEV):
        print(f"エラー: {LIRC_DEV} が見つかりません。設定か再起動を確認してください。")
        return

# パルスデータをテキスト形式に変換（ir-ctl コマンドが読める形式）
    # 例: "pulse 9000\nspace 4500\npulse 560..."
    ir_content = ""
    for i, duration in enumerate(pulse_list):
        if i % 2 == 0:
            ir_content += f"pulse {duration}\n"
        else:
            ir_content += f"space {duration}\n"
            
    # 一時ファイルに書き出し
    with open("temp_tx.txt", "w") as f:
        f.write(ir_content)
        
    # Linuxのコマンドを呼び出して、2SK4017から赤外線を発射！
    print("赤外線信号を発射します...")
    os.system(f"ir-ctl -s temp_tx.txt -d {LIRC_DEV}")
    
    # 使い終わった一時ファイルを削除
    os.remove("temp_tx.txt")

# 実行
send_ir(sample_signal)

2026年8月2日日曜日

FX-502Pでライプニッツ級数で円周率ためす

Σn=0~100 4*(-1)^n/(2n+1) をFX502Pのプログラム機能で試してみた。

分子がM2　分母がM3　　カウンタがM0　総和をM1とすると

MODE 2> P2 >Min 0 > 0 Min 1 > 4 Min 2 >1 Min 3 > LBL 0 >MR 2 ÷ MR 3 = M+ 1 >2 M+ 3> MR 2 +/- Min 2 > INV DSZ >GOTO 0 > MR 1

MODE 1>1000 > P2で実行すると 3.140592187

FX-502Pが発売当時、大型計算機のFORTRANだと、自分の知識では倍精度とかもできなかったので、ディフォルトでは桁数が小さく、すぐ精度がおちてしまって、級数計算(ミー理論と実測値の比較で使いました）は無理だった。級数計算は、大型計算機より、むしろ、プログラム電卓が重宝しました。

2026年7月27日月曜日

FX-502P 簡単なコーディング、メモリについて

・（A＋B）×C　なら

MODE 2 >P0 > ( >HLT> + >HLT> ) >× > HLT > = と数式通り入力、ちょうどHLTがinput()やscanf()にあたる働き

MODE 1 >P0>1>EXE> 2 >EXE >3 >EXE これで（１＋２）×３＝９と計算

・メモリの使い方

20 > Min > . >1 でM1に保存　　 MR>.>1 で20がM1から読み出される。　MinやMRの後に.と数字指定　　　M- M+　x⇔M　などのボタンも同様の使い方 MFメモリはEXPボタンで指定

M+は　表示中の数を指定メモリにプラス

FX-502P

学生の頃、実験レポートでよく使ったのがプログラム電卓FX-502P。棚の整理していたら、たまたま出てきた。久しぶりにいろいろ使ってみたが、完全に使い方は忘れている。英語版の説明書はかろうじてネット上で入手できたのでそれを見ながら少し使ってみた。念のため、分解してキーの接触部分に接点復活剤をかけてみた。ただ、基板の接点は金色だったので、ひょっとしたら金メッキ？。だとすると、接点復活剤は意味なかったかもしれませんが。念のため、LR44ボタン電池を交換しておいたほうがいいかもしれません。

　https://sourceforge.net/projects/uiq3/files/Documents/

最近は、関数電卓は需要があるようですが、プログラムは慣れた言語のほうがいいでしょうから、さすがにプログラム電卓はマイナーな存在のようです。

・プログラムのALL クリアは、MODE 3>INV MAC

・POプログラムのクリアは　MODE 3>P0>AC

・P0への書き込み(2倍する計算なら）は MODE 2>P0>×>2>=

・P0の実行は MODE 1>3>P0で３×２＝６という計算

今でも、電卓で三角関数や対数計算ぐらいは使うこともたまにあるので、ヤフオクで処分しようか？かどうかで、迷っています。当時、２万円以上はしましたし、今でも十分動作はしているようなので。さらに持っていれば、骨とう品としての価値があがる？

・赤、緑のLEDの抵抗計算をP0にいれてみた

MODE 2>P3>-2.1>=>÷>0.02>= 電圧を入力しP3で直列に入れる抵抗値がでる。実際は数十倍にして、少し消費電流をおさえたほうがいいようです。

・容量とインダクタンスから共振周波数を求めるものをP1にいれてみた

MODE 2>P1>HLT>Min 1>HLT>Min 2>MR 1>×>MR 2>=>√＞×>2>×>π>=>1/x>

10uF、100pFを入力すると P0> 10 EXP +/- 6 >EXE > 100 EXP +/- 12> EXE

・2sc1815をスイッチングでつかうときの抵抗計算

MODE 2>P4>HLT>Min 1>HLT>Min 2>HLT>Min 3>MR 1 - 0.7 = >÷> ( > MR 3 > ÷ > 50 > ) > = > HLT > MR 1 > - > MR 2 > - 0.1 = > ÷ > MR 3 > = > HLT

12V電源、3VのLED、流したい電流0.02Aの場合　　MODE 1>P4> 12 >EXE> 3> EXE > 0.02 >EXE で28250Ω （ベース抵抗）>EXE　で445Ω（コレクタ抵抗）

2026年5月17日日曜日

欧州の経済

　Youtubeで国際経済に詳しい藤井氏によると、このところ、英・仏・独あたりの経済があまりよくないということらしいです。
１移民問題：文化的摩擦（宗教）、教育レベル（ネイティブ言語未習得で初等教育成立しない）＞労働者の質が下がる＞経済の悪化　　最初は低賃金労働でいいと思っていたが。。。
２CO2規制のやりすぎ：電力が高くなる＞AI革命につながらない
３ロシアからの天然ガスが買えなくなる
４中国へ売ろうとしたが、買ってくれる国がなくなった。中国に依存しすぎた。その国のいうことを聞かざるをえなくなる。

　　１，２の割合大きい。

　イギリスは、国内で高炉がなくなり、鉄を作れない。唯一の産業、金融が落ち込んでいる。年金基金も、自国内の株の比率も下がっている。医療の崩壊（かつては、揺りかごから墓場までだったが）。犯罪多発で、街のビジネスも衰退。

　ドイツは、社会インフラが遅れている。光ファイバーの普及（１０～１５％普及率）が遅れている。ドイツの官僚主義＞書類、FAX中心。鉄道の定時運航率低い。原因は、財政規律を徹底しすぎたため。「貯金はあるけど、ぼろ屋に住む」みたいな感じ。イスラム移民多く、ドイツに同化してない。中国に逆に技術的に依存するようになってしまった。ドイツの技術を中国に売ってしまった。

　フランスはラグジュアリー産業を中国に依存していたが、それがだめになった。フランスは製造業がなくなってしまった。

　日本も他山の石としないといけないかと。

2026年5月13日水曜日

畑管理GASについて

畑資材の支出入をGASで管理していたものに、機能を少し追加した。これまで畑管理は、ノートに書き込んでいたが、さすがに中身が増えてくると、整理がつきにくくなったので、これもGASで管理してみることにした。

　オープンデータのＡＰＩから天気、気温、降水量、風力など、自動で入力されるようにしました。畑日記のようなものです。

code.gs*******************
  const SPREADSHEET_ID = '***************';
const SHEET_NAME = 'Records2026'; // 年度毎変更可
const SHEET_NAME_EX='Expense2026'
const SHEET_YEAR='2026';
const GOOGLE_DRIVE = '***************';　//畑画像保存用

// 野菜マスタ（名前と単価）
const vegetablePrices = {
  "トマト": 100,
  "ナス": 40,
  "キュウリ": 40,
  "ピーマン": 20,
  "ゴーヤ": 60,
  "インゲン": 5,
  "スイカ": 1000,
  "末成りスイカ":200,
  "ミニトマト": 10,
  "サツマイモ": 130,
  "サトイモ": 40,
  "シソ": 5,
  "エダマメ": 10,
  "人参":40,
  "大根":100,
  "カブ":80
};

const CultivationRecordsPerspectives = {
  "栽培":0,  "技術":1,  "その他":2
};

function weatherText(code) {
  const map = {
    0: "晴",
    1: "晴れ時々曇",
    2: "曇",
    3: "曇",
    45: "霧",
    61: "弱雨",
    63: "雨",
    65: "強雨",
    71: "雪"
  };

return map[code] || "不明";
}

function doGet(e) {

const page = e.parameter.page || "index";

return HtmlService
    .createTemplateFromFile(page)
    .evaluate();
}

// HTML読み込み用
function include(filename) {
  return HtmlService
    .createHtmlOutputFromFile(filename)
    .getContent();
}

// 検索
function searchRecords(keywordText) {

const keywords = keywordText
    .trim()
    .toLowerCase()
    .split(/\s+/);

// 現在年
  let targetYear =
    String(new Date().getFullYear());

// yyyy取得
  const yearKeyword =
    keywords.find(k =>
      /^\d{4}$/.test(k)
    );

// 指定年あれば切替
  if(yearKeyword){

targetYear = yearKeyword;
  }

// スプレッドシート
  const ss =
    SpreadsheetApp.openById(
      SPREADSHEET_ID
    );

// 年シート
  const sheet =
    ss.getSheetByName(targetYear);

if(!sheet){

throw new Error(
      'シートなし: ' + targetYear
    );
  }

const values =
    sheet.getDataRange()
      .getValues();

// 年キーワード除外
  const searchKeywords =
    keywords.filter(k =>
      !/^\d{4}$/.test(k)
    );

const results = [];

for(let i = 1; i < values.length; i++){

const row = values[i];

const comment =
      String(row[7] || "")
        .toLowerCase();

const matched =
      searchKeywords.every(k =>
        comment.includes(k)
      );

if(!matched) continue;

results.push({

date:
        Utilities.formatDate(
          row[0],
          Session.getScriptTimeZone(),
          'yyyy-MM-dd'
        ),

weather:
        String(row[1] || ""),

comment:
        String(row[7] || ""),

image:
        String(row[8] || "")

});
  }

return results;
}

function getVegetables() {
  return vegetablePrices;
}

function getCultivationRecordsPerspectives() {
  return CultivationRecordsPerspectives;
}

function getWeatherOptions() {
  const options = [];

for (let i = 0; i <= 100; i++) {
    const text = weatherText(i);

if (text !== "不明" && !options.includes(text)) {
      options.push(text);
    }
  }

return options;
}

function getWeatherData(dateStr) {
  const latitude = **.**;//畑の　緯度　と　経度　を設定
  const longitude = ***.**;

const url =
    "https://api.open-meteo.com/v1/forecast" +
    "?latitude=" + latitude +
    "&longitude=" + longitude +
    "&hourly=temperature_2m,precipitation,wind_speed_10m,weathercode" +
    "&start_date=" + dateStr +
    "&end_date=" + dateStr +
    "&timezone=Asia%2FTokyo";

const response = UrlFetchApp.fetch(url);
  const data = JSON.parse(response.getContentText());

const temps = data.hourly.temperature_2m;
  const precs = data.hourly.precipitation;
  const winds = data.hourly.wind_speed_10m;
  const codes = data.hourly.weathercode;

const tempMax = Math.max(...temps);
  const tempMin = Math.min(...temps);
  const precipitation = precs.reduce((a, b) => a + b, 0);
  const windMax = Math.max(...winds);

// 最頻出天気コード
  const weatherCode = mode(codes);

return {
    weather: weatherText(weatherCode),
    tempMax: tempMax,
    tempMin: tempMin,
    precipitation: precipitation,
    windMax: windMax
  };
}

function mode(arr) {
  const count = {};
  let max = 0;
  let result = arr[0];

arr.forEach(v => {
    count[v] = (count[v] || 0) + 1;
    if (count[v] > max) {
      max = count[v];
      result = v;
    }
  });

return result;
}

function uploadImageToDrive(base64Data, fileName) { 
  const folder = DriveApp.getFolderById(GOOGLE_DRIVE);
  const contentType =
    base64Data.match(/^data:(.*);base64,/)[1];

const bytes =
    Utilities.base64Decode(
      base64Data.split(',')[1]
    );

const blob = Utilities.newBlob(
    bytes,
    contentType,
    fileName
  );

const file = folder.createFile(blob);

return file.getUrl();
}

function init(){
  const obj= getTotalSum();  // 合計金額取得 
  return JSON.stringify({
    totalSum: obj.sum 
    ,lastDay: obj.last
    ,totalSumEx: obj.sumex 
    ,lastDayEx: obj.lastex
    ,balance:obj.balance
      });
}

function addRecord(data) {
  const ss = SpreadsheetApp.openById(SPREADSHEET_ID);
  // const ss = SpreadsheetApp.getActiveSpreadsheet();
  const sheet = ss.getSheetByName(SHEET_NAME);
  
  if (!sheet) {
    Logger.log('シート名「' + SHEET_NAME + '」は存在しません');
  } else {
    Logger.log('シート名「' + SHEET_NAME + '」が見つかりました');
  }
  
  const name = data.name;
  const count = Number(data.count);
  const unitPrice = vegetablePrices[name] || 0;
  const total = unitPrice * count;
  const date = new Date();
  const memo = data.memo;
  
  sheet.appendRow([date, name, count, unitPrice, total, memo]);
  const obj = getTotalSum();  // 合計金額取得
  sum=obj.sum;

return JSON.stringify({
    record: { 
      dateEx: "", 
      hinmei: "", 
      kingaku: 0,
      memoEx: "",
      date: date, 
      name: name, 
      count: count, 
      unitPrice: unitPrice, 
      total: total,
      memo: memo
    },
    totalSum: sum ,
    totalSumEx:0,
    balance: obj.balance
  });
}

function addRecordEx(data) {
  const ss = SpreadsheetApp.openById(SPREADSHEET_ID);
  const sheet = ss.getSheetByName(SHEET_NAME_EX);
  
  if (!sheet) {
    Logger.log('シート名「' + SHEET_NAME_EX + '」は存在しません');
  } else {
    Logger.log('シート名「' + SHEET_NAME_EX + '」が見つかりました');
  }
  
  const hinmei = data.hinmei;
  const kingaku = data.kingaku;
  const dateEx = new Date();
  const memoEx = data.memoEx;
  
  sheet.appendRow([dateEx, hinmei, kingaku, kingaku, kingaku, memoEx]);
  const obj = getTotalSum();  // 合計金額取得
  sum=obj.sumex;

return JSON.stringify({
    record: { 
      dateEx: dateEx, 
      hinmei: hinmei, 
      kingaku: kingaku,
      memoEx: memoEx,
      date: "", 
      name: "", 
      count: 0, 
      unitPrice: 0, 
      total: 0,
      memo: ""
    },
    totalSumEx: sum ,
    balance: obj.balance
  });
}

function addRecordCr(data) {
  const ss = SpreadsheetApp.openById(SPREADSHEET_ID);
  const sheet = ss.getSheetByName(SHEET_YEAR);

if (!sheet) {
    throw new Error('シート名「' + SHEET_YEAR + '」は存在しません');
  }

sheet.appendRow([
    data.cultivationRecordsDate,
    data.weather,
    data.tempMax,
    data.tempMin,
    data.precipitation,
    data.windMax,
    data.cultivationRecordsPerspective,
    data.cultivationRecordsComment,
    data.imageUrl
  ]);

return "保存しました";
}

function getTotalSum() {
  const ss = SpreadsheetApp.openById(SPREADSHEET_ID);
  const sheet = ss.getSheetByName(SHEET_NAME);
  const data = sheet.getRange(2, 5, sheet.getLastRow() - 1).getValues(); // 合計金額列
  const lastRow = sheet.getRange("A:A").getValues().filter(String).length;
  const lastValue = sheet.getRange(lastRow, 1).getValue();
  const total=data.reduce((sum, row) => sum + (Number(row[0]) || 0), 0);

const sheetEx = ss.getSheetByName(SHEET_NAME_EX);
  const dataEx = sheetEx.getRange(2, 5, sheetEx.getLastRow() - 1).getValues(); // 合計金額列
  const lastRowEx = sheetEx.getRange("A:A").getValues().filter(String).length;
  const lastValueEx = sheetEx.getRange(lastRowEx, 1).getValue();
  const totalEx=dataEx.reduce((sumex, rowex) => sumex + (Number(rowex[0]) || 0), 0);

return {sum:total,last:lastValue,sumex:totalEx  ,lastex:lastValueEx    ,balance: total-totalEx  };
 
}
  
  *******index.html
  <!DOCTYPE html>
<html>
  <head>
    <base target="_top">
    <style>

body {
  font-family: "Segoe UI", "Hiragino Kaku Gothic ProN", Meiryo, sans-serif;
  background-color: #f4f7f4;
}

table {
  border-collapse: separate;
  border-spacing: 20px;
  margin: 20px auto;
}

td {
  vertical-align: top;
}

.card {
  background: #ffffff;
  padding: 20px 24px;
  border-radius: 12px;
  box-shadow: 0 4px 10px rgba(0,0,0,0.08);
  min-width: 300px;
}

h2 {
  margin-top: 0;
  margin-bottom: 16px;
  color: #2f6f4e;
  border-bottom: 2px solid #e0eee6;
  padding-bottom: 6px;
}

label {
  display: block;
  margin-top: 10px;
  font-weight: 600;
  color: #444;
}

input, select, textarea {
  width: 100%;
  margin-top: 4px;
  padding: 6px 8px;
  border-radius: 6px;
  border: 1px solid #ccc;
  font-size: 14px;
}

textarea {
  resize: vertical;
}

button {
  margin-top: 14px;
  padding: 8px 16px;
  background-color: #4caf75;
  color: white;
  border: none;
  border-radius: 8px;
  font-size: 14px;
  cursor: pointer;
}

button:hover {
  background-color: #3f9a66;
}

h3 {
  margin-top: 16px;
  color: #333;
}

.total {
  font-weight: bold;
  color: #2f6f4e;
}

.balance {
  background: #fffbe6;
  padding: 16px;
  border-radius: 12px;
  box-shadow: 0 4px 10px rgba(0,0,0,0.08);
  font-size: 18px;
  font-weight: bold;
  text-align: center;
}
</style>

</head>
  <body>
    <table>
    <tr>
　　　<td>
      <h2>栽培記録</h2>
            　記録検索
        <input
         type="text"
         id="keyword"
         placeholder="キーワードをスペース区切り yyyyないと今年">
　　　　　<button onclick="search()">検索</button>
<h2>検索結果</h2>
<div id="resultSrch">
</div>
    
    
      <div id="resultCr"></div>
      <label>年月日：</label>
      <input type="date" id="CultivationRecordsDate">
    
      <label>天気：</label>
      <select id="Weather"></select> 
      <br> 
    
      <label>最高気温(℃)：</label>
      <input type="number" id="TempMax" value="0" />

<button type="button" onclick="uploadImage()">
  画像アップロード(数秒かかります)
</button>

<label>画像URL：</label>
<input type="text" id="ImageUrl" size="60">

</dt>

<td>
      <h2>畑の収穫記録</h2>
      <label>野菜：</label>
      <select id="vege"></select> 
    
      <label>個数：</label>
      <input type="number" id="count" min="1" value="1" />
      <br> 
    
      <label>メモ：</label>
      <ｔｅｘｔａｒｅａ id="memo" name="memo" rows="5" cols="40"></ｔｅｘｔａｒｅａ> 
    
      <button onclick="submitData()">収穫登録</button> 
    
      <div id="result"></div>
      <h3 id="totalSum">合計金額: -- 円</h3>
    </dt>
    <td>
      <h2>支出記録</h2>
      <label>品名:</label>
      <input type="text" id="hinmei"></select> 
    
      <label>金額：</label>
      <input type="number" id="kingaku" min="0" value="0" />
      <br> 
    
      <label>メモ：</label>
      <ｔｅｘｔａｒｅａ id="memoEx" name="memoEx" rows="5" cols="40"></ｔｅｘｔａｒｅａ> 
    
      <button onclick="submitDataEx()">支出登録</button> 
    
      <div id="resultEx"></div>
      <h3 id="totalSumEx">合計支出金額: -- 円</h3>
        <h3 id="balance">差引計算: -- 円</h3>
      <br>
    </td>
 
    </tr>
    </table><table>
 
    
    <a href='***********'>Sheet</a>
    
    <script>
      
      
      function search(){
  const keyword =
    document.getElementById("keyword").value;

google.script.run
  .withSuccessHandler(showResults)
  .withFailureHandler(showError)
  .searchRecords(keyword);

}

function showError(error){

console.error(error);

document.getElementById("resultSrch")
    .innerHTML =
      "エラー: " + error.message;
}

function showResults(results){

const div =
    document.getElementById("resultSrch");
  div.innerHTML = "";
  if(results.length === 0){
    div.innerHTML = "該当なし";
    return;
  }

results.forEach(r => {

console.log(r);

let imageHtml = "";

if(r.image && typeof r.image === "string"){

imageHtml = `
      <div>
        <img
          src="${r.image}"
          style="max-width:300px;">
      </div>
    `;
  }

const html = `
    <div class="card">

<div>${r.date}</div>
      <div>${r.comment}</div>

${imageHtml}

</div>
  `;

div.innerHTML += html;
});

}
      
      
      
      
      
      function setToday() {
  const today = new Date();

// ローカル日付を YYYY-MM-DD に
  const yyyy = today.getFullYear();
  const mm = String(today.getMonth() + 1).padStart(2, '0');
  const dd = String(today.getDate()).padStart(2, '0');

document.getElementById("CultivationRecordsDate").value =
    `${yyyy}-${mm}-${dd}`;
}

function uploadImage() {
  alert("uploadImage開始");

const file = document.getElementById("ImageFile").files[0];

if (!file) {
    alert("画像なし");
    return;
  }

const reader = new FileReader();

reader.onload = function(e) {
    alert("reader.onload");

google.script.run
      .withSuccessHandler(function(url) {
        console.log("SUCCESS");
        console.log(url);
        alert("SUCCESS: " + url);

const el =
          document.getElementById("ImageUrl");

alert("el=" + el);

el.value = url;
      })
      .withFailureHandler(function(err) {
        console.log("FAIL");
        console.log(err);
        alert("FAIL: " + err.message);
      })
      .uploadImageToDrive(
        e.target.result,
        file.name
      );
  };

reader.readAsDataURL(file);
}

document.getElementById("CultivationRecordsDate")
  .addEventListener("change", fetchWeather);

window.onload = function() {
         google.script.run.withSuccessHandler(displayResult2).init();
    };

data.forEach(function(item) {
      const opt = document.createElement("option");
      opt.value = item;
      opt.text = item;
      select.appendChild(opt);
    });

}).getWeatherOptions();
}

function fetchWeather() {
  const date = document.getElementById("CultivationRecordsDate").value;
  google.script.run
    .withSuccessHandler(function(result) {
      document.getElementById("Weather").value = result.weather;
      document.getElementById("TempMax").value = result.tempMax;
      document.getElementById("TempMin").value = result.tempMin;
      document.getElementById("Precipitation").value = result.precipitation;
      document.getElementById("WindMax").value = result.windMax;
    })
    .getWeatherData(date);
}

function submitDataCr() {
  const cultivationRecordsDate =
    document.getElementById("CultivationRecordsDate").value;
  const weather =
    document.getElementById("Weather").value;
  const tempMax =
    document.getElementById("TempMax").value;
  const tempMin =
    document.getElementById("TempMin").value;
  const precipitation =
    document.getElementById("Precipitation").value;
  const windMax =
    document.getElementById("WindMax").value;
  const cultivationRecordsPerspective =
    document.getElementById("CultivationRecordsPerspective").value;
  const cultivationRecordsComment =
    document.getElementById("memo").value;
  const imageUrl =
  document.getElementById("ImageUrl").value;

google.script.run
    .withSuccessHandler(displayResultCr)
    .addRecordCr({
      cultivationRecordsDate: cultivationRecordsDate,
      weather: weather,
      tempMax: tempMax,
      tempMin: tempMin,
      precipitation: precipitation,
      windMax: windMax,
      cultivationRecordsPerspective: cultivationRecordsPerspective,
      cultivationRecordsComment: cultivationRecordsComment,
      imageUrl:imageUrl
    });
}

function displayResult(res) {
        let response = JSON.parse(res);
        const r = response.record;

if (r.hinmei==""){
           const div = document.getElementById("result");
        const entry = document.createElement("div");
        entry.className = "result-entry";
        entry.innerHTML = `<strong>${new Date(r.date).toLocaleString()}</strong> - ${r.name} (${r.count}個 × ${r.unitPrice}円) = <strong>${r.total}円</strong><br>MEMO:<BR>${r.memo.replace(/\r?\n/g, "<br>")}`;
        //entry.innerHTML = `<strong>date</strong> - name  1個 × 100円) = <strong>200円</strong>`;
        div.appendChild(entry);
        
        document.getElementById("totalSum").innerText = `合計金額: ${response.totalSum} 円`;
        document.getElementById("balance").innerText = `差引計算: ${response.balance} 円`;

}else{
        const div = document.getElementById("resultEx");
        const entry = document.createElement("div");
        entry.className = "result-entry";
        entry.innerHTML = `<strong>${new Date(r.dateEx).toLocaleString()}</strong> - ${r.hinmei} (${r.kingaku}円</strong><br>MEMO:<BR>${r.memoEx.replace(/\r?\n/g, "<br>")}`;
       
        div.appendChild(entry);
        
        document.getElementById("totalSumEx").innerText = `合計金額: ${response.totalSumEx} 円`;

}
        
        document.getElementById("balance").innerText = `差引計算: ${response.balance} 円`;
     
      }

function displayResultCr(result) {
  document.getElementById("resultCr").innerText = result;
}
      
      loadVegetables();
      loadCultivationRecordsPerspective();
      loadWeather();
        setToday();
        fetchWeather();
        
    </script>
  </body>
</html>

※textareaのみ全角を半角にする必要あります。

※検索機能追加しました。

2026年5月12日火曜日

５月の苗床管理

そろそろ、ヒータを使う必要性もすくなくなってきた。

残り、サツマイモと豆類の苗準備だが、保温の必要性もへってきたかも。

BMP1,2が室温、D1やD3がヒーター温度　両者の差がなくなってきている。

ボイラー室のドアノブ固着

ボイラー室のドアノブが固着し、業者に頼んで、手間賃かなりかかったことありましたが、放置したら再び固着。どうしたものかと、大型プライヤー使いましたが、だめ。ホームセンターでパイプレンチ探してみたら８０００円近くして、あきらめましたが。ふと、モノタロウで値段を見たら２０００円台で入手可能なことを見つける。早速、購入し試してみたら、大正解。ノブに瑕はついたものの、回すことができた。今後は年１回ぐらいは動かしたほうがいいようだ。

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

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

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

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

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/7

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 で再起動。

登録: 投稿 (Atom)