diff --git a/.gitignore b/.gitignore index 35300ae..d17affe 100644 --- a/.gitignore +++ b/.gitignore @@ -8,3 +8,4 @@ thumbs.db #storage/profiles #config.py .idea/* +state.json diff --git a/Test/test-cases.json b/Test/test-cases.json new file mode 100644 index 0000000..10f1cb6 --- /dev/null +++ b/Test/test-cases.json @@ -0,0 +1 @@ +{"data": [[0, 200], [3600, 200], [4200, 500], [10800, 500], [14400, 2250], [16400, 2000], [19400, 2250]], "type": "profile", "name": "test-fast"} diff --git a/Test/test-fast.json b/Test/test-fast.json new file mode 100644 index 0000000..1e317c5 --- /dev/null +++ b/Test/test-fast.json @@ -0,0 +1 @@ +{"data": [[0, 200], [3600, 200], [10800, 2000], [14400, 2250], [16400, 2250], [19400, 700]], "type": "profile", "name": "test-fast"} diff --git a/Test/test_Profile.py b/Test/test_Profile.py new file mode 100644 index 0000000..b82fc8d --- /dev/null +++ b/Test/test_Profile.py @@ -0,0 +1,80 @@ +from lib.oven import Profile +import os +import json + +def get_profile(file = "test-fast.json"): + profile_path = os.path.abspath(os.path.join(os.path.dirname(__file__), '..', 'Test', file)) + print(profile_path) + with open(profile_path) as infile: + profile_json = json.dumps(json.load(infile)) + profile = Profile(profile_json) + + return profile + + +def test_get_target_temperature(): + profile = get_profile() + + temperature = profile.get_target_temperature(3000) + assert int(temperature) == 200 + + temperature = profile.get_target_temperature(6004) + assert temperature == 801.0 + + +def test_find_time_from_temperature(): + profile = get_profile() + + time = profile.find_next_time_from_temperature(500) + assert time == 4800 + + time = profile.find_next_time_from_temperature(2004) + assert time == 10857.6 + + time = profile.find_next_time_from_temperature(1900) + assert time == 10400.0 + + + +def test_find_time_odd_profile(): + profile = get_profile("test-cases.json") + + time = profile.find_next_time_from_temperature(500) + assert time == 4200 + + time = profile.find_next_time_from_temperature(2023) + assert time == 16676.0 + + +def test_find_x_given_y_on_line_from_two_points(): + profile = get_profile() + + y = 500 + p1 = [3600, 200] + p2 = [10800, 2000] + time = profile.find_x_given_y_on_line_from_two_points(y, p1, p2) + + assert time == 4800 + + y = 500 + p1 = [3600, 200] + p2 = [10800, 200] + time = profile.find_x_given_y_on_line_from_two_points(y, p1, p2) + + assert time == 0 + + y = 500 + p1 = [3600, 600] + p2 = [10800, 600] + time = profile.find_x_given_y_on_line_from_two_points(y, p1, p2) + + assert time == 0 + + y = 500 + p1 = [3600, 500] + p2 = [10800, 500] + time = profile.find_x_given_y_on_line_from_two_points(y, p1, p2) + + assert time == 0 + + diff --git a/config.py b/config.py index 7077bbb..dc257b3 100644 --- a/config.py +++ b/config.py @@ -8,7 +8,7 @@ import busio # General options ### Logging -log_level = logging.INFO +log_level = logging.DEBUG log_format = '%(asctime)s %(levelname)s %(name)s: %(message)s' ### Server @@ -75,6 +75,13 @@ max31856 = 0 # ThermocoupleType.S # ThermocoupleType.T +######################################################################## +# +# If your kiln is above the scheduled starting temperature when you click the Start button this +# feature will start the schedule at that temperature. +# +seek_start = True + ######################################################################## # # duty cycle of the entire system in seconds @@ -109,7 +116,7 @@ stop_integral_windup = True # # Simulation parameters simulate = True -sim_t_env = 60.0 # deg C +sim_t_env = 255 # deg C sim_c_heat = 500.0 # J/K heat capacity of heat element sim_c_oven = 5000.0 # J/K heat capacity of oven sim_p_heat = 5450.0 # W heating power of oven diff --git a/kiln-controller.py b/kiln-controller.py index 17fc3f9..9b23c1a 100755 --- a/kiln-controller.py +++ b/kiln-controller.py @@ -73,6 +73,11 @@ def handle_api(): if 'startat' in bottle.request.json: startat = bottle.request.json['startat'] + #Shut off seek if start time has been set + allow_seek = True + if startat > 0: + allow_seek = False + # get the wanted profile/kiln schedule profile = find_profile(wanted) if profile is None: @@ -81,7 +86,7 @@ def handle_api(): # FIXME juggling of json should happen in the Profile class profile_json = json.dumps(profile) profile = Profile(profile_json) - oven.run_profile(profile,startat=startat) + oven.run_profile(profile, startat=startat, allow_seek=allow_seek) ovenWatcher.record(profile) if bottle.request.json['cmd'] == 'stop': diff --git a/lib/oven.py b/lib/oven.py index a756fe3..f5efc42 100644 --- a/lib/oven.py +++ b/lib/oven.py @@ -103,7 +103,7 @@ class TempSensorSimulated(TempSensor): '''Simulates a temperature sensor ''' def __init__(self): TempSensor.__init__(self) - self.simulated_temperature = 0 + self.simulated_temperature = config.sim_t_env def temperature(self): return self.simulated_temperature @@ -329,10 +329,28 @@ class Oven(threading.Thread): self.heat = 0 self.pid = PID(ki=config.pid_ki, kd=config.pid_kd, kp=config.pid_kp) - def run_profile(self, profile, startat=0): + @staticmethod + def get_start_from_temperature(profile, temp): + target_temp = profile.get_target_temperature(0) + if temp > target_temp + 5: + startat = profile.find_next_time_from_temperature(temp) + log.info("seek_start is in effect, starting at: {} s, {} deg".format(round(startat), round(temp))) + else: + startat = 0 + return startat + + def run_profile(self, profile, startat=0, allow_seek=True): + log.debug('run_profile run on thread' + threading.current_thread().name) + runtime = startat * 60 + if allow_seek: + if self.state == 'IDLE': + if config.seek_start: + temp = self.board.temp_sensor.temperature() # Defined in a subclass + runtime += self.get_start_from_temperature(profile, temp) + self.reset() self.startat = startat * 60 - self.runtime = self.startat + self.runtime = runtime self.start_time = datetime.datetime.now() - datetime.timedelta(seconds=self.startat) self.profile = profile self.totaltime = profile.get_duration() @@ -468,7 +486,7 @@ class Oven(threading.Thread): with open(profile_path) as infile: profile_json = json.dumps(json.load(infile)) profile = Profile(profile_json) - self.run_profile(profile,startat=startat) + self.run_profile(profile, startat=startat, allow_seek=False) # We don't want a seek on an auto restart. self.cost = d["cost"] time.sleep(1) self.ovenwatcher.record(profile) @@ -479,6 +497,7 @@ class Oven(threading.Thread): def run(self): while True: + log.debug('Oven running on ' + threading.current_thread().name) if self.state == "IDLE": if self.should_i_automatic_restart() == True: self.automatic_restart() @@ -507,7 +526,7 @@ class SimulatedOven(Oven): self.R_ho = self.R_ho_noair # set temps to the temp of the surrounding environment - self.t = self.t_env # deg C temp of oven + self.t = config.sim_t_env # deg C or F temp of oven self.t_h = self.t_env #deg C temp of heating element super().__init__() @@ -643,6 +662,28 @@ class Profile(): def get_duration(self): return max([t for (t, x) in self.data]) + # x = (y-y1)(x2-x1)/(y2-y1) + x1 + @staticmethod + def find_x_given_y_on_line_from_two_points(y, point1, point2): + if point1[0] > point2[0]: return 0 # time2 before time1 makes no sense in kiln segment + if point1[1] >= point2[1]: return 0 # Zero will crach. Negative temeporature slope, we don't want to seek a time. + x = (y - point1[1]) * (point2[0] -point1[0] ) / (point2[1] - point1[1]) + point1[0] + return x + + def find_next_time_from_temperature(self, temperature): + time = 0 # The seek function will not do anything if this returns zero, no useful intersection was found + for index, point2 in enumerate(self.data): + if point2[1] >= temperature: + if index > 0: # Zero here would be before the first segment + if self.data[index - 1][1] <= temperature: # We have an intersection + time = self.find_x_given_y_on_line_from_two_points(temperature, self.data[index - 1], point2) + if time == 0: + if self.data[index - 1][1] == point2[1]: # It's a flat segment that matches the temperature + time = self.data[index - 1][0] + break + + return time + def get_surrounding_points(self, time): if time > self.get_duration(): return (None, None) diff --git a/lib/ovenWatcher.py b/lib/ovenWatcher.py index 3e47e4f..3a420e5 100644 --- a/lib/ovenWatcher.py +++ b/lib/ovenWatcher.py @@ -79,6 +79,7 @@ class OvenWatcher(threading.Thread): def notify_all(self,message): message_json = json.dumps(message) log.debug("sending to %d clients: %s"%(len(self.observers),message_json)) + for wsock in self.observers: if wsock: try: