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 80b89e5..d372eda 100644 Binary files a/karung_tuang.db and b/karung_tuang.db differ diff --git a/karung_tuang.json b/karung_tuang.json index ff5221a..453501e 100644 --- a/karung_tuang.json +++ b/karung_tuang.json @@ -1,8 +1,8 @@ { "kandang_atas_feeder_kiri": { - "karung": 0 + "karung": 25 }, "kandang_bawah_feeder_kanan": { - "karung": 0 + "karung": 40 } } \ No newline at end of file