HydroBot/hydrobot-software Changeset - 653da092aa96

Changeset - 653da092aa96

Parent rev.

Child rev.

[Not reviewed]

default

0 2 0

matthewreed - 9 years ago 2016-07-23 17:28:55

Added inteval-based scheduling

2 files changed with 48 insertions and 15 deletions:

hydrobot.py

hydrobot_example.conf

0 comments (0 inline, 0 general)

hydrobot.py

➞

Show inline comments

 import sys
 import time
 import _thread
 import ast
 import configparser
 import datetime
 from canard import can, messaging
 from canard.hw import socketcan
 from canard.file import jsondb
 from influxdb import InfluxDBClient
 from apscheduler.schedulers.background import BackgroundScheduler
 #TODO
 #fix temperature offset
 #database series helper
 #database time interval logging
 #add system name to database
 config = configparser.ConfigParser(allow_no_value = True)
 config.read("hydrobot.conf")
 DEBUG_CAN = config.getboolean("debug", "can")
 DEBUG_CAN_DETAIL = config.getboolean("debug", "can_detail")
 class Database:
     def __init__(self):
         host = config.get("database", "host")
         port = config.get("database", "port")
         username = config.get("database", "username")
@@ @@ -127,55 +127,88 @@ class CanBus: @@
         self.relay_send_msg.Output2.value = 1
         self.relay_send_msg.Output3.value = 1
         self.relay_send_msg.Output4.value = 1
         if DEBUG_CAN:
             print("Send CAN message! ID: " + hex(self.relay_send_msg.id))
         if DEBUG_CAN_DETAIL:
             print(self.relay_send_msg)
         self.dev.send(self.relay_send_msg.encode())
     def set_output(self, module, output, state):
         msg = self.msgdb.lookup_message(module)
         msg.lookup_signal(output).value = state
         print(msg)
+        #print(msg)
         self.dev.send(msg.encode())
-def main():
+class Scheduler:
     database = Database()
     canbus = CanBus(database)
     canbus.start()
     canbus.start_receive()
     def __init__(self, canbus):
         self.canbus = canbus
         self.apscheduler = BackgroundScheduler()
     scheduler = BackgroundScheduler()
     def start(self):
         self.apscheduler.start()
     for section in config.sections():
         if "timer" in section:
             items = config.items(section)
             for item in items:
                 if item[0] == 'trigger':
                     trigger = item[1]
                 if item[0] == 'module':
                     module = item[1]
                 if item[0] == 'output':
                     output = item[1]
                 if item[0] == 'on_time':
                     on_time = ast.literal_eval(item[1])
                 if item[0] == 'off_time':
                     off_time = ast.literal_eval(item[1])
                 if item[0] == 'on_duration':
                     on_duration = ast.literal_eval(item[1])
                     if item[0] == 'off_duration':
                         off_duration = ast.literal_eval(item[1])
             if trigger == 'cron':
                 scheduler.add_job(canbus.set_output, trigger, [module, output, 1], day = on_time[0], day_of_week = on_time[1], hour = on_time[2], minute = on_time[3], second = on_time[4])
                 scheduler.add_job(canbus.set_output, trigger, [module, output, 0], day = off_time[0], day_of_week = off_time[1], hour = off_time[2], minute = off_time[3], second = off_time[4])
                     self.apscheduler.add_job(self.canbus.set_output, trigger, [module, output, 1], day = on_time[0], day_of_week = on_time[1], hour = on_time[2], minute = on_time[3], second = on_time[4])
                     self.apscheduler.add_job(self.canbus.set_output, trigger, [module, output, 0], day = off_time[0], day_of_week = off_time[1], hour = off_time[2], minute = off_time[3], second = off_time[4])
             if trigger == 'interval':
                 scheduler.add_job(canbus.set_output, trigger, [module, output, 1], weeks = on_duration[0], days = on_duration[1], hours = on_duration[2], minutes = on_duration[3], seconds = on_duration[4])
                     self.apscheduler.add_job(self.interval_off, trigger, [module, output, section + "_off", section + "_on", on_duration], id = section + "_off", weeks = off_duration[0], days = off_duration[1], hours = off_duration[2], minutes = off_duration[3], seconds = off_duration[4])
                     timer = self.apscheduler.add_job(self.interval_on, trigger, [module, output, section + "_off", section + "_on", off_duration], id = section + "_on", weeks = on_duration[0], days = on_duration[1], hours = on_duration[2], minutes = on_duration[3], seconds = on_duration[4])
                     timer.pause()
                     print(off_duration[4])
                     print(on_duration[4])
     def interval_off(self, module, output, timer_off, timer_on, on_duration):
         self.canbus.set_output(module, output, 1)
         self.apscheduler.get_job(timer_on).reschedule("interval", weeks = on_duration[0], days = on_duration[1], hours = on_duration[2], minutes = on_duration[3], seconds = on_duration[4])
         self.apscheduler.get_job(timer_on).resume()
         self.apscheduler.get_job(timer_off).pause()
         print("turning on " + timer_on + "! " + str(datetime.datetime.now().time()))
     def interval_on(self, module, output, timer_off, timer_on, off_duration):
         self.canbus.set_output(module, output, 0)
         self.apscheduler.get_job(timer_off).reschedule("interval", weeks = off_duration[0], days = off_duration[1], hours = off_duration[2], minutes = off_duration[3], seconds = off_duration[4])
         self.apscheduler.get_job(timer_off).resume()
         self.apscheduler.get_job(timer_on).pause()
         print("turning off " + timer_off + "! " + str(datetime.datetime.now().time()))
 def func():
     print(1)
 def main():
     database = Database()
     canbus = CanBus(database)
     canbus.start()
     canbus.start_receive()
     scheduler = Scheduler(canbus)
     scheduler.start()
     while True:
         time.sleep(1)
 if __name__ == "__main__":
     main()

hydrobot_example.conf

➞

Show inline comments

@@ @@ -14,16 +14,16 @@ can_detail: False @@
 [timer1]
 module: RelayDriveOut
 output: Output1
 trigger: cron
 #day(1-31), weekday(0-6), hour(0-23), minute(0-59), second(0-59)
 on_time: [None, None, None, None, 0]
 off_time: [None, None, None, None, 30]
 [timer2]
 module: RelayDriveOut
 output: Output2
 trigger: cron
 #day(1-31), weekday(0-6), hour(0-23), minute(0-59), second(0-59)
 on_time: [None, None, None, None, 0]
 off_time: [None, None, None, None, 15]
 trigger: interval
 #weeks, days, hours, minutes, seconds
 on_duration: [0, 0, 0, 0, 20]
 off_duration: [0, 0, 0, 0, 10]

0 comments (0 inline, 0 general)