From 72c82d53899d9a46ca6c97bb1755e49bfcd62609 Mon Sep 17 00:00:00 2001 From: dsutanto Date: Tue, 21 Apr 2026 10:33:20 +0700 Subject: [PATCH] Update --- frigate_counter.py | 25 +++++++++++++++++++++++++ frigate_counter.py.new | 25 +++++++++++++++++++++++++ karung_tuang.db | Bin 12288 -> 12288 bytes karung_tuang.json | 4 ++-- 4 files changed, 52 insertions(+), 2 deletions(-) diff --git a/frigate_counter.py b/frigate_counter.py index 4b25202..3080f91 100644 --- a/frigate_counter.py +++ b/frigate_counter.py @@ -47,6 +47,8 @@ DETIK_ANTAR_KARUNG = 30 RELAY_KIRI_ON = "http://192.168.192.26:5001/relay_on" RELAY_KIRI_OFF = "http://192.168.192.26:5001/relay_off" +RELAY_KANAN_ON = "http://192.168.192.26:5002/relay_on" +RELAY_KANAN_OFF = "http://192.168.192.26:5002/relay_off" def init_database(): """Initialize the SQLite database with the required table""" @@ -166,6 +168,25 @@ def relay_kiri_on(): except requests.exceptions.RequestException as e: print(e) +def relay_kanan_off(): + global RELAY_KANAN_ON, RELAY_KANAN_OFF + try: + requests.get(RELAY_KANAN_OFF, timeout=1) + print(f"Relay Kanan OFF") + except requests.exceptions.RequestException as e: + print(e) + + +def relay_kanan_on(): + global DETIK_ANTAR_KARUNG + + try: + requests.get(RELAY_KANAN_ON, timeout=1) + threading.Timer(DETIK_ANTAR_KARUNG, relay_kanan_off).start() + print(f"Relay Kanan ON -> Start Counter Kanan: {DETIK_ANTAR_KARUNG} seconds") + except requests.exceptions.RequestException as e: + print(e) + # ===================== # RESET HARIAN # ===================== @@ -335,6 +356,9 @@ def on_message(client, userdata, msg): if camera == "kandang_atas_feeder_kiri": relay_kiri_on() + if camera == "kandang_bawah_feeder_kanan": + relay_kanan_on() + except Exception as e: print("Error parsing message:", e) @@ -373,6 +397,7 @@ schedule_reset() #schedule_reset_masuk() # Pastikan Relay OFF relay_kiri_off() +relay_kanan_off() client_publish.loop_start() print(f"MQTT Publish Counter berjalan di {PUBLISH_BROKER}") diff --git a/frigate_counter.py.new b/frigate_counter.py.new index 4b25202..3080f91 100644 --- a/frigate_counter.py.new +++ b/frigate_counter.py.new @@ -47,6 +47,8 @@ DETIK_ANTAR_KARUNG = 30 RELAY_KIRI_ON = "http://192.168.192.26:5001/relay_on" RELAY_KIRI_OFF = "http://192.168.192.26:5001/relay_off" +RELAY_KANAN_ON = "http://192.168.192.26:5002/relay_on" +RELAY_KANAN_OFF = "http://192.168.192.26:5002/relay_off" def init_database(): """Initialize the SQLite database with the required table""" @@ -166,6 +168,25 @@ def relay_kiri_on(): except requests.exceptions.RequestException as e: print(e) +def relay_kanan_off(): + global RELAY_KANAN_ON, RELAY_KANAN_OFF + try: + requests.get(RELAY_KANAN_OFF, timeout=1) + print(f"Relay Kanan OFF") + except requests.exceptions.RequestException as e: + print(e) + + +def relay_kanan_on(): + global DETIK_ANTAR_KARUNG + + try: + requests.get(RELAY_KANAN_ON, timeout=1) + threading.Timer(DETIK_ANTAR_KARUNG, relay_kanan_off).start() + print(f"Relay Kanan ON -> Start Counter Kanan: {DETIK_ANTAR_KARUNG} seconds") + except requests.exceptions.RequestException as e: + print(e) + # ===================== # RESET HARIAN # ===================== @@ -335,6 +356,9 @@ def on_message(client, userdata, msg): if camera == "kandang_atas_feeder_kiri": relay_kiri_on() + if camera == "kandang_bawah_feeder_kanan": + relay_kanan_on() + except Exception as e: print("Error parsing message:", e) @@ -373,6 +397,7 @@ schedule_reset() #schedule_reset_masuk() # Pastikan Relay OFF relay_kiri_off() +relay_kanan_off() client_publish.loop_start() print(f"MQTT Publish Counter berjalan di {PUBLISH_BROKER}") diff --git a/karung_tuang.db b/karung_tuang.db index 80b89e57184156f3033dcf0bbbc3b6d78496904c..d372edaefdafe66b62da797e73afbf78233dfca5 100644 GIT binary patch delta 375 zcmZojXh@hK%_ucd#+gxSW5N=CW+Rri$?O8Y66^wOSJ-B;#j&ZdzF=L)TEuF>@`vRR zOWVdmDHbLxqsanN>Y_#l3WnxZ1_nT+XJBAxVPYm{VK_NKQWcAgx|IP~kD(>99wQTD zOBD-!pdK|5ObIJJh!zWEEr#Z%CQ25%U@e#uRyq(Z=Ez!%jEyYiEwsT}FeR+CAX?0j vwHTUPn95pcg0)~sNLgt>w3wo3F*7!juuunU!H^KMQUht(TrA!r!Ds{km{Ctw delta 43 zcmZojXh@hK%_uTa#+gxMW5N=CW;J%N$?O8Y8w