[update] update cali value

python/biopro/controller.py

@@ -1586,6 +1586,9 @@ class ControlAPI(metaclass=Router):
     def stop_project(self, project) -> bool:
         raise NotImplementedError()
     
+    def set_project(self, project, content) -> bool:
+        raise NotImplementedError()
+    
     def show_device_data(self, device) -> bool:
         raise NotImplementedError()
 

python/biopro/device/device_cc2650.py

@@ -662,7 +662,7 @@ class CC2650Device(Device):
         elif device_type == 'EISZeroOne':
             i = 0
             request_times = 0
-            while i < 7:
+            while i < 13:
                 try:
                     # send
                     code = self._encode_instruction(DeviceInstruction.TYP_CIS, DeviceInstruction.CIS_CALI, i)

python/biopro/devlib/data.py

@@ -1,6 +1,7 @@
 import abc
 import struct
 import math
+import numpy
 from typing import Optional, TypeVar, Generic, Tuple, Dict, List, AnyStr
 from datetime import datetime
 
@@ -894,6 +895,10 @@ class I4V4Z4T4DataDecoder(RecDataDecoder):
         finish_mode_falg = data[22]
         battery = struct.unpack('<i', data[23:27])[0]
         elite_notify_times = data[27]
+        notify_one = struct.unpack('<i', data[28:32])[0]
+        notify_two = struct.unpack('<i', data[32:36])[0]
+        notify_three = struct.unpack('<i', data[36:40])[0]
+        # self._show_data = True
 
         mem_wrong_information = struct.unpack('<i', data[43:47])[0] # mem_wrong_information = green retry, green wrong, red retry, red wrong
         ram_num = data[47]
@@ -919,8 +924,9 @@ class I4V4Z4T4DataDecoder(RecDataDecoder):
             else:
                 if self._show_data:
                     print('|', time_stamp, '|', delta, '|', int(time_stamp * 1000 / 2),
-                        '|', current, '|', voltage, '|', impedance,
-                        '|', cycle_number, '|', finishMode, '@', str(self.device))
+                        '|', current, '|', voltage, '|', impedance, '|', cycle_number, 
+                        '|', notify_one, '|', notify_two, '|', notify_three, 
+                        '|', finishMode, '@', str(self.device))
 
                 # print('|', '{:10}'.format(time_stamp),
                 #       '|', '{:4}'.format(delta),
@@ -949,6 +955,9 @@ class I4V4Z4T4DataDecoder(RecDataDecoder):
         ret.append_data(1, voltage)
         ret.append_data(2, impedance)
         ret.append_data(3, cycle_number)
+        ret.append_data(4, notify_one)
+        ret.append_data(5, notify_two)
+        ret.append_data(6, notify_three)
         # ret.append_data(4, battery)
         # ret.append_data(5, elite_notify_times)
         # ret.append_data(6, mem_cnt)
@@ -1372,12 +1381,27 @@ class EISZeroOneDataDecoder(RecDataDecoder):
     def _decode_cali_coeff(cali_coeff: bytes) -> Optional[List[Tuple[int, int]]]:
         if cali_coeff != b'':
             cali_table = []
-            phase_para_a = []
-            phase_para_b = []
             hsrtia_a = []
             hsrtia_b = []
             hsrtia_c = []
             hsrtia_d = []
+            phase_coeff = []
+            phase_offset = []
+            
+            # phase_coeff = [[0]*4 for i in range(4)]
+            # phase_offset = [[0]*4 for i in range(4)]
+
+            phase_coeff = numpy.zeros([4, 4], dtype = int)
+            phase_offset = numpy.zeros([4, 4], dtype = int)  
+
+            ########################################
+            # phase_coeff
+            # [[gain0, g1, g2, g3] ----->最高頻
+            #  [gain0, g1, g2, g3] ----->中頻
+            #  [gain0, g1, g2, g3] ----->低頻
+            #  [gain0, g1, g2, g3] ----->最低頻
+            # ]
+            #######################################
 
             # print('cali_coeff', cali_coeff)
             cutoff_freq = struct.unpack('>I', cali_coeff[1:5])[0] * 100     #4
@@ -1388,15 +1412,19 @@ class EISZeroOneDataDecoder(RecDataDecoder):
             # hsrtia_160k = struct.unpack('>I', cali_coeff[8:12])[0]         #4
 
             index = 20
-            for i in range(index, index+16, 8):
-                phase_para_a.append(struct.unpack('>i', cali_coeff[i+1:i+5])[0])
-                phase_para_b.append(struct.unpack('>i', cali_coeff[i+5:i+9])[0])
-
+            g = 0
+            phase_coeff[0][g] = struct.unpack('>i', cali_coeff[index+1:index+5])[0]
+            phase_offset[0][g] = struct.unpack('>i', cali_coeff[index+5:index+9])[0]
+            phase_coeff[1][g] = struct.unpack('>i', cali_coeff[index+9:index+13])[0]
+            phase_offset[1][g] = struct.unpack('>i', cali_coeff[index+13:index+17])[0]
+            
             index = 40
-            for i in range(index, index+16, 8):
-                phase_para_a.append(struct.unpack('>i', cali_coeff[i+1:i+5])[0])
-                phase_para_b.append(struct.unpack('>i', cali_coeff[i+5:i+9])[0]) 
-
+            g = 0
+            phase_coeff[2][g] = struct.unpack('>i', cali_coeff[index+1:index+5])[0]
+            phase_offset[2][g] = struct.unpack('>i', cali_coeff[index+5:index+9])[0]
+            phase_coeff[3][g] = struct.unpack('>i', cali_coeff[index+9:index+13])[0]
+            phase_offset[3][g] = struct.unpack('>i', cali_coeff[index+13:index+17])[0]
+            
             #Lv[0] 160k
             index = 60
             hsrtia_a.append(struct.unpack('>i', cali_coeff[index+1:index+5])[0]/1e8)
@@ -1421,18 +1449,58 @@ class EISZeroOneDataDecoder(RecDataDecoder):
             hsrtia_b.append(struct.unpack('>i', cali_coeff[index+5:index+9])[0]/1e8)
             hsrtia_c.append(struct.unpack('>i', cali_coeff[index+9:index+13])[0]/1e4)
 
-            # hsrtia_a.append(struct.unpack('>I', cali_coeff[index+1:index+5])[0])
-            # hsrtia_b.append(struct.unpack('>I', cali_coeff[index+5:index+9])[0]/1e6)
-            # hsrtia_c.append(struct.unpack('>I', cali_coeff[index+9:index+13])[0]/1e5)
+            index = 140
+            g = 1
+            phase_coeff[0][g] = struct.unpack('>i', cali_coeff[index+1:index+5])[0]
+            phase_offset[0][g] = struct.unpack('>i', cali_coeff[index+5:index+9])[0]
+            phase_coeff[1][g] = struct.unpack('>i', cali_coeff[index+9:index+13])[0]
+            phase_offset[1][g] = struct.unpack('>i', cali_coeff[index+13:index+17])[0]
+            
+            index = 160
+            g = 1
+            phase_coeff[2][g] = struct.unpack('>i', cali_coeff[index+1:index+5])[0]
+            phase_offset[2][g] = struct.unpack('>i', cali_coeff[index+5:index+9])[0]
+            phase_coeff[3][g] = struct.unpack('>i', cali_coeff[index+9:index+13])[0]
+            phase_offset[3][g] = struct.unpack('>i', cali_coeff[index+13:index+17])[0]
+            
+            index = 180
+            g = 2
+            phase_coeff[0][g] = struct.unpack('>i', cali_coeff[index+1:index+5])[0]
+            phase_offset[0][g] = struct.unpack('>i', cali_coeff[index+5:index+9])[0]
+            phase_coeff[1][g] = struct.unpack('>i', cali_coeff[index+9:index+13])[0]
+            phase_offset[1][g] = struct.unpack('>i', cali_coeff[index+13:index+17])[0]
+            
+            index = 200
+            g = 2
+            phase_coeff[2][g] = struct.unpack('>i', cali_coeff[index+1:index+5])[0]
+            phase_offset[2][g] = struct.unpack('>i', cali_coeff[index+5:index+9])[0]
+            phase_coeff[3][g] = struct.unpack('>i', cali_coeff[index+9:index+13])[0]
+            phase_offset[3][g] = struct.unpack('>i', cali_coeff[index+13:index+17])[0]
+            
+            index = 220
+            g = 3
+            phase_coeff[0][g] = struct.unpack('>i', cali_coeff[index+1:index+5])[0]
+            phase_offset[0][g] = struct.unpack('>i', cali_coeff[index+5:index+9])[0]
+            phase_coeff[1][g] = struct.unpack('>i', cali_coeff[index+9:index+13])[0]
+            phase_offset[1][g] = struct.unpack('>i', cali_coeff[index+13:index+17])[0]
+            
+            index = 240
+            g = 3
+            phase_coeff[2][g] = struct.unpack('>i', cali_coeff[index+1:index+5])[0]
+            phase_offset[2][g] = struct.unpack('>i', cali_coeff[index+5:index+9])[0]
+            phase_coeff[3][g] = struct.unpack('>i', cali_coeff[index+9:index+13])[0]
+            phase_offset[3][g] = struct.unpack('>i', cali_coeff[index+13:index+17])[0]
 
             # print('cutoff_freq', cutoff_freq)
             # print('hsrtia_a', hsrtia_a)
             # print('hsrtia_b', hsrtia_b)
             # print('hsrtia_c', hsrtia_c)
-            # print('phase_para_a', phase_para_a)
-            # print('phase_para_b', phase_para_b)
+            # print('phase_coeff')
+            # print(phase_coeff)
+            # print('phase_offset')
+            # print(phase_offset)
 
-            cali_table.append((cutoff_freq, phase_para_a, phase_para_b, hsrtia_a, hsrtia_b, hsrtia_c, hsrtia_d))
+            cali_table.append((cutoff_freq, phase_coeff, phase_offset, hsrtia_a, hsrtia_b, hsrtia_c, hsrtia_d))
 
             return cali_table
         else:
@@ -1482,13 +1550,12 @@ class EISZeroOneDataDecoder(RecDataDecoder):
                 return None
             else:
                 if self.cali_coeff is not None and self._mode == 0:
-                    phase_para_a = []
-                    phase_para_b = []
                     hsrtia_a = []
                     hsrtia_b = []
                     hsrtia_c = []
                     hsrtia_d = []
-                    cutoff_freq, phase_para_a, phase_para_b, hsrtia_a, hsrtia_b, hsrtia_c, hsrtia_d = self.cali_coeff[0]
+                    cutoff_freq, phase_coeff, phase_offset, hsrtia_a, hsrtia_b, hsrtia_c, hsrtia_d = self.cali_coeff[0]
+
                     voltage_amp = round(self._ac_amp * 800 / 2047) # use UI value
                     if (self._freq_start > self._freq_stop):
                         self._freq_direction = 0
@@ -1499,6 +1566,7 @@ class EISZeroOneDataDecoder(RecDataDecoder):
                     img = ch1
                     real = ch2
                     freq = ch3
+                    fre_idx = 0
 
                     voltage_mag = math.sqrt(img ** 2 + real ** 2) * (1 + freq ** 2 / cutoff_freq ** 2)
 
@@ -1526,22 +1594,22 @@ class EISZeroOneDataDecoder(RecDataDecoder):
                         raw_phase = math.atan(img / real) * 180 / math.pi + 180
 
                     if (freq >= 1000000): # 10000 Hz
-                        i = 0
+                        fre_idx = 0
                     elif (freq >= 10000): # 100 Hz
-                        i = 1
+                        fre_idx = 1
                     elif (freq >= 1000): # 10 Hz
-                        i = 2
+                        fre_idx = 2
                     elif (freq >= 1): # 0.01 Hz
-                        i = 3
+                        fre_idx = 3
                     
-                    ideal_raw_phase = phase_para_a[i] /1e10 * freq + phase_para_b[i] / 1e6
+                    ideal_raw_phase = phase_coeff[fre_idx][gain] /1e10 * freq + phase_offset[fre_idx][gain] / 1e6
 
                     phase = raw_phase - ideal_raw_phase
 
                     if (self._first_phase_flag):
                         self._last_phase = phase
                         self._first_phase_flag = 0
-                    elif (abs(phase - self._last_phase) >= 200):
+                    elif (abs(phase - self._last_phase) >= 90):
                         phase -= 360
                         self._last_phase = phase
 

python/biopro/devlib/library.py

@@ -1105,6 +1105,8 @@ class CompletedDevice(Device):
         return self._configuration.get_parameter(name, False)
     
     def set_multi_parameters(self, parameter):
+        if len(parameter) == 0:
+            return
         for (name, value) in parameter[0].items():
             if name != 'target':
                 self.set_parameter(name, value)
@@ -1128,6 +1130,11 @@ class CompletedDevice(Device):
                 self._parameter.set_parameter(name, value)
                 # raise RuntimeError('illegal parameter value : ' + value) from e
             else:
+                if name == 'MODE':
+                    if self.library_name.startswith('Elite_EDC'):
+                        self.set_parameter('CTRL_HIGH_Z_15', self.get_parameter('HIGHZ_TABLE')[value])
+                        self.set_parameter('TIME_DURATION', 0)
+
                 self._parameter.set_parameter(name, value)
 
         on_change = info.on_change

python/biopro/impl/ext_mem.py

@@ -35,7 +35,7 @@ class MultiExtMemSpiInterface(LowLevelHardwareInterface):
                  '_pin_ram_sel_value', '_pin_mem_sel_value', '_pin_mem_req_value',
                  '_read_green_times','_read_red_times',
                  '_elite_data_len', '_mem_header_len', '_mem_tailer_len', '_single_data_len',
-                 '_head_wrong_cnt')
+                 '_head_wrong_cnt', '_pin_busy_value')
 
     def __init__(self,
                  select: Selector,
@@ -50,11 +50,11 @@ class MultiExtMemSpiInterface(LowLevelHardwareInterface):
         self._single_data_len = self._elite_data_len + self._mem_header_len + self._mem_tailer_len
 
         # buffer
-        self._tx_buffer_header = [0] * 19
+        self._tx_buffer_header = [0] * 64
         self._tx_buffer_data = [0] * (self._single_data_len * 10 + 3)
 
         # memory control pin
-        self.pin_busy = OutputPin.get_used(P3Pin.MEM_BZY, True)
+        self.pin_busy: Optional[InputPin] = InputPin.get_used(P3Pin.MEM_BZY)
         self.pin_mem_req = OutputPin.get_used(P3Pin.MEM_REQ, False)
         self.pin_mem_sel = OutputPin.get_used(P3Pin.MEM_RST, True) # MEM_RST -> actually which memory board is assign
         self.pin_ram_sel: Optional[InputPin] = InputPin.get_used(P3Pin.MEM_SEL) # MEM_SEL -> actually is RAM_SEL, which RAM is assign
@@ -62,6 +62,7 @@ class MultiExtMemSpiInterface(LowLevelHardwareInterface):
         self._pin_ram_sel_value = [bool(self.pin_ram_sel) for _ in range(Selector.SIZE)]
         self._pin_mem_sel_value = [bool(self.pin_mem_sel) for _ in range(Selector.SIZE)]
         self._pin_mem_req_value = [bool(self.pin_mem_req) for _ in range(Selector.SIZE)]
+        self._pin_busy_value = [bool(self.pin_busy) for _ in range(Selector.SIZE)]
 
         self._read_green_times = 0
         self._read_red_times = 0
@@ -98,6 +99,14 @@ class MultiExtMemSpiInterface(LowLevelHardwareInterface):
             self._pin_ram_sel_value[channel] = True
         return self._pin_ram_sel_value[channel]
 
+    def get_pin_busy(self):
+        channel = self.select
+        if self.pin_busy.input() == 0:
+            self._pin_busy_value[channel] = False
+        else:
+            self._pin_busy_value[channel] = True
+        return self._pin_busy_value[channel]
+
     @property
     def select(self) -> int:
         return self._selector.channel
@@ -216,7 +225,9 @@ class MultiExtMemSpiInterface(LowLevelHardwareInterface):
         return
 
     def recv_memory(self, device: int) -> Optional[bytes]:
-        self.pin_busy.output(False)
+        # self.pin_busy.output(False)
+
+        print('mem_req==ram_sel,[', self._pin_mem_req_value[device], ',', self._pin_ram_sel_value[device], ']')
 
         rx = []
 
@@ -300,6 +311,9 @@ class MultiExtMemSpiInterface(LowLevelHardwareInterface):
                 print("green data print:", data, device, datetime.now())
                 return None
 
+            # print('data=', list(data))
+            print('Ram:', data[62])
+
             if (length >= 4000):
                 flag_print = True
                 print("green data: big length:", length)
@@ -415,9 +429,9 @@ class MultiExtMemSpiInterface(LowLevelHardwareInterface):
         except BaseException as e:
             print(e)
 
-        finally:
-            # print("\n")
-            self.pin_busy.output(True)
+        # finally:
+        #     # print("\n")
+        #     self.pin_busy.output(True)
 
         return bytes(rx)
 

python/biopro/project/action.py

@@ -24,3 +24,11 @@ class Action():
     @property
     def condition(self):
         return self._condition
+    
+    def as_json(self):
+        return {
+            'id': self._id,
+            'type': self._type,
+            'target': self._target,
+            'condition': self._condition
+        }

python/biopro/project/condition.py

@@ -56,7 +56,8 @@ class Condition():
         return getattr(self, self.type)(**kwargs)
        
     def absolute_time(self, **kwargs):
-        now = int(time())
+        # now = int(time())
+        now = round(time(), 1)
         time_condition = round(self.datetime_to_timestamp(self.str_to_datetime(self._value)))
 
         return self.compareWith(self.comparsion, now, time_condition)
@@ -65,8 +66,9 @@ class Condition():
         project_start_time = kwargs['project_start_time']
         delay_time = kwargs['delay_time']
 
-        time_diff = int(time() - project_start_time - delay_time)
-        return self.compareWith(self.comparsion, time_diff, int(self._value))
+        # time_diff = int(time() - project_start_time - delay_time)
+        time_diff = round(time() - project_start_time - delay_time, 1)
+        return self.compareWith(self.comparsion, time_diff, round(int(self._value), 1))
     
     def after_task_run(self, **kwargs):
         # print('relative_time_from_task', kwargs,kwargs['task_start_time'],kwargs['delay_time'])
@@ -75,22 +77,60 @@ class Condition():
         task_start_time = kwargs['task_start_time'][-1]
         delay_time = kwargs['delay_time']
 
-        time_diff = int(time() - task_start_time - delay_time)
-        # print('time_diff',  time_diff)
-        return self.compareWith(self.comparsion, time_diff, int(self._value))
+        time_diff = round(time() - task_start_time - delay_time, 1)
+        return self.compareWith(self.comparsion, time_diff, round(int(self._value), 1))
     
     def device(self, **kwargs):
         print('device')
     
-    def previous_task_done(self, **kwargs):
+    """ def previous_task_done(self, **kwargs):
         running_task = kwargs['running_task']
         if running_task.status == 2 and self._active == False:
             self._active = True
             return True
+        return False """
+
+    def previous_task_done(self, **kwargs):
+        running_task = kwargs['running_task']
+        self_task = kwargs['self_task']
+        # if running_task != None and self_task != None:
+        # print('\nprevious_task_done: ', running_task.status, ' ', self._active)
+        if running_task != self_task:
+            if running_task == None:
+                return True
+            if running_task.status == 2 and self._active == False:
+                # self._active = True
+                return True
         return False
 
+    def until_button_trigger(self, **kwargs):
+        running_task = kwargs['running_task']
+        if running_task != None:
+            if running_task.button_trigger == True:
+                running_task.button_trigger = False
+                return True
+        return False 
+    
+    """ def cycle(self, **kwargs):
+        running_task = kwargs['running_task']
+        self_task = kwargs['self_task']
+        if running_task != self_task:
+            if running_task.status == 2 and self._active == False:
+                # self._active = True
+                return True
+        return False """
+
     def str_to_datetime(self, time_str):
         return datetime.strptime(time_str,'%Y-%m-%dT%H:%M')
 
     def datetime_to_timestamp(self, date):
-        return datetime.timestamp(date)
+        return datetime.timestamp(date)
+
+    def as_json(self):
+        return {
+            'id': self._id,
+            'type': self._type,
+            'comparsion': self._comparsion,
+            'value': self._value,
+            'active': self._active
+        }

python/biopro/project/instruction.py

@@ -22,6 +22,7 @@ class Instruction():
     
         self._start_instruction = list(map(lambda ins: self._instruction_set[ins] ,['set_file_name', 'set_parent', 'set_parameter', 'call_instruction']))
         self._stop_instruction = list(map(lambda ins: self._instruction_set[ins] ,['call_instruction']))
+        self._idle_instruction = []
     
     @property
     def start(self) -> list:
@@ -29,4 +30,8 @@ class Instruction():
     
     @property
     def stop(self) -> list:
-        return self._stop_instruction
+        return self._stop_instruction
+
+    @property
+    def idle(self) -> list:
+        return self.idle_instruction

python/biopro/project/project.py

@@ -24,7 +24,7 @@ class Project(threading.Thread):
     self._project = project
     self._device_manager = device_manager
     self._mqtt_thread = mqttThread
-    self._time_interval = 1
+    self._time_interval = 0.1
     self._start_time = None
     self._end_time = None
 
@@ -117,6 +117,10 @@ class Project(threading.Thread):
   def mqtt_thread(self):
     return self._mqtt_thread
 
+  @property
+  def running_task(self):
+    return self._task_manager.running_task
+
   def run(self):
       self._status = 1
       self._start_time = time()
@@ -139,23 +143,42 @@ class Project(threading.Thread):
               project_start_time = self._start_time,
               delay_time = delay_time,
               running_task= self._task_manager.running_task,
-              previous_task =  self._task_manager.prev_task
+              previous_task =  self._task_manager.prev_task,
+              self_task = task
             )
             # print('match_condition_list', match_condition_list)
             for condition in match_condition_list:
+              # print('\ncondition.type: ', condition.type)
               match_action_list = task.get_match_action(condition.id)
+              # print('match_action_list', match_action_list)
               for action in match_action_list:
-                # print('match_action', action.type, action.target)
+                # print('action type', action.type)
+                # print('match_action_list len: ', len(match_action_list))
                 if action.type == 'start' and task.status != 1:
                   self._task_manager.set_running_task(task)
+                  # Trace
                   self.mqtt_thread.broadcast_command('project:task ' + task.name + ' start at ' + datetime.now().strftime('%Y-%m-%d %H:%M:%S.%f')[:-3])
+                elif action.type == 'cycle' and task.status != 1:
+                  # TODO: directly goto next without swich cycle as running task
+                  """ if task._cycle_count < task._cycle - 1:
+                    task._cycle_count += 1
+                    cycle_target = self._task_manager.task_list[task._cycle_next - 1] # TODO: not sure deep or shallow
+                    cycle_target.reset()
+                    task = cycle_target """
+                  self._task_manager.set_running_task(task)
+                elif action.type == 'stop' and len(self._task_manager.running_task.parameter_set) == 0:
+                  self.mqtt_thread.broadcast_command('project:task ' + str(self._task_manager.running_task.name) + ' stop at ' + datetime.now().strftime('%Y-%m-%d %H:%M:%S.%f')[:-3])
+                  self._task_manager.running_task.stop()
+
+                elif action.type == 'idle':
+                  self._task_manager.running_task.stop()
 
                 device = self._complete_device[action.target]
                 task_info = task.get_task_info(action)
                 instruction_set = getattr(self._instruction_set, action.type, None)
-                # print('instruction_set',instruction_set)
-                
-                if instruction_set != None:
+                # print('instruction_set', instruction_set, '\n', action.type)
+                # if instruction_set != None and task.cycle == -1:
+                if instruction_set != None and len(task.parameter_set) > 0:
                   for instruction in instruction_set:
                     args = list(map(lambda arg: task_info[arg], instruction['arguments']))
                     threading.Thread(target=getattr(device, instruction['method'])(*args))
@@ -164,8 +187,10 @@ class Project(threading.Thread):
 
         # check task not running then stop
         if self.check_running_task_not_run() == True:
-          self.mqtt_thread.broadcast_command('project:task ' + str(self._task_manager.running_task.name) + ' stop at ' + datetime.now().strftime('%Y-%m-%d %H:%M:%S.%f')[:-3])
+          if self._task_manager.running_task.cycle == -1:
+            self.mqtt_thread.broadcast_command('project:task ' + str(self._task_manager.running_task.name) + ' stop at ' + datetime.now().strftime('%Y-%m-%d %H:%M:%S.%f')[:-3])
           self._task_manager.running_task.stop()
+          # self._task_manager.set_running_task(task)
         
         # check project done then close project
         if self.check_project_done() == True:
@@ -200,11 +225,21 @@ class Project(threading.Thread):
         return False
     return True
   
+  def set_content(self, content):
+    self.running_task.button_trigger = True
+  
   def check_running_task_not_run(self):
     # if no running task
     if self._task_manager.running_task == None:
       return False
-
+    
+    for key in self._task_manager.running_task.action:
+      # print('action key', key, self._task_manager.running_task, self._task_manager.running_task.action[key])
+      if len(self._task_manager.running_task.parameter_set) == 0 and self._task_manager.running_task.action[key]['type'] == 'stop':
+        return False
+      if len(self._task_manager.running_task.parameter_set) == 0 and self._task_manager.running_task.action[key]['type'] == 'idle':
+        return False
+      
     for device in self._task_manager.running_task.device:
       if self._complete_device[device].status == 1:
         return False

python/biopro/project/project_manager.py

@@ -37,3 +37,7 @@ class ProjectManager():
     def stop_project(self, project):
       _project = self.get(project)
       _project.stop()
+    
+    def set_project(self, project_uuid, content):
+      _project = self.get(project_uuid)
+      _project.set_content(content)

python/biopro/project/task.py

@@ -15,26 +15,34 @@ class Task:
     self._name = None
     self._parent = None
     self._cycle = None
+    self._cycle_count = 0
+    self._cycle_next = None
+    self._cycle_next_uuid = None
     self._device = None
     self._event = None
     self._trigger = None
     self._parameter_set = None
     self._condition = None
     self._action = None
-    # -1: initial 0: start(idle), 1: running, 2: close(idle)
+    # -1: init 0: start(idle), 1: run, 2: close(idle)
     self._status = 0
     self._next = None
 
+    # action & condition info
     self._condition_list: List[Condition] = []
     self._action_list: List[Action] = []
     self._instruction_list = []
     self._record_list = []
 
+    # time info
     self._start_time = []
     self._idle_time = []
     self._end_time = []
     self._period = None
 
+    # trigger info
+    self._button_trigger = False
+
     self.load_task(task)
   
   def load_task(self, task) -> None:
@@ -100,6 +108,31 @@ class Task:
   @cycle.setter
   def cycle(self, new_cycle):
     self._cycle = new_cycle
+
+  # TODO: not sure needed?
+  @property
+  def cycle_count(self) -> int:
+    return self._cycle_count
+  
+  @cycle_count.setter
+  def cycle_count(self, new_cycle_count):
+    self._cycle_count = new_cycle_count
+    
+  @property
+  def cycle_next(self) -> str:
+    return self._cycle_next
+  
+  @cycle_next.setter
+  def cycle_next(self, new_cycle_next):
+    self._cycle_next = new_cycle_next
+
+  @property
+  def cycle_next_uuid(self) -> str:
+    return self._cycle_next_uuid
+  
+  @cycle_next_uuid.setter
+  def cycle_next_uuid(self, new_cycle_next_uuid):
+    self._cycle_next_uuid = new_cycle_next_uuid
   
   @property
   def device(self) -> dict:
@@ -177,6 +210,14 @@ class Task:
   def end_time(self) -> List:
     return self._end_time
   
+  @property
+  def button_trigger(self) -> List:
+    return self._button_trigger
+  
+  @button_trigger.setter
+  def button_trigger(self, button_trigger):
+    self._button_trigger = button_trigger
+  
   def new_start_time(self):
     self._start_time.append(time())
   
@@ -207,6 +248,10 @@ class Task:
   
   def stop(self):
     self.status = 2
+  
+  def reset(self):
+    self.status = -1
+    # self.status = 0
 
   def get_match_action_list(self, match_condition_list):
     return map(lambda condition: [x for x in self._action_list if condition.id in x.get_condition_list()], match_condition_list)
@@ -241,6 +286,9 @@ class Task:
       'name': self.name,
       'parent': self.parent,
       'cycle': self.cycle,
+      'cycle_count': self.cycle_count,
+      'cycle_next': self.cycle_next,
+      'cycle_next_uuid': self.cycle_next_uuid,
       'device': self.device,
       'event': self.event,
       'trigger': self.trigger,

python/biopro/project/task_manager.py

@@ -57,7 +57,8 @@ class TaskManager():
         task = Task(task) 
         self._task_list.append(task)
     
-    def set_running_task(self, task):
+    # original version
+    """ def set_running_task(self, task):
       try:
         # if there is task running & same task active ,then reject
         if self._running_task != None and self._running_task.uuid == task.uuid:
@@ -80,6 +81,44 @@ class TaskManager():
           _task = next((task for task in self._task_list if task.uuid == task_uuid), None)
           if _task != None:
             self._next_task.append(_task)
+      except RuntimeError as e:
+        print(e) """
+
+    def set_running_task(self, task):
+      try:
+        # if there is task running & same task active ,then reject
+        if self._running_task != None and self._running_task.uuid == task.uuid:
+          # print('set_running_task return false: ', self._running_task.name)
+          return False
+
+        # save running task
+        self._prev_task = self._running_task
+        # clear next task list
+        self._next_task.clear()
+        self._running_task = task
+        self._running_task.run()
+
+        if self._prev_task != None:
+          # if previous task is still running, then need to close
+          if self._prev_task.status == 1:
+            self._prev_task.stop()
+          print('prev', 'run', self._prev_task.name, self._running_task.name)
+
+        # print(f'!!@#!set_running_task\n\n\n{task._cycle_count}\n{task._cycle}\n\n\n')
+        if task._cycle_count < task._cycle - 1:
+          task._cycle_count += 1
+          # use uuid to get the cycle next task
+          cycle_target = [_task_next for _task_next in self._task_list if _task_next.uuid == task._cycle_next_uuid]
+          # cycle_target = self._task_list[task._cycle_next - 1]  # original use index version
+          cycle_target[0].reset()
+          self._next_task.append(cycle_target[0])
+        else:
+          task._cycle_count = 0
+          for task_uuid in self._running_task.next:
+            _task = next((task for task in self._task_list if task.uuid == task_uuid), None)
+            if _task != None:
+              _task.reset()
+              self._next_task.append(_task)
       except RuntimeError as e:
         print(e)
 

python/biopro/server/data.py

@@ -646,6 +646,7 @@ class DataServer(SocketServer, DataAPI):
     def whether_to_record(self, device):
         # if user click "start", return True; if user click "stop", return False;
         if device in self._configurations.keys() and self._configurations[device] is not None:
+            # print(self._configurations.keys(), ',', device, datetime.now())
             return True
         else:
             return False
@@ -654,6 +655,9 @@ class DataServer(SocketServer, DataAPI):
         ret = False
         sync = self.get_spi_obj()
 
+        busy = sync.get_pin_busy()
+        print('pin_busy=', busy, device, datetime.now())
+
         if sync.get_pin_mem_req() == sync.get_pin_ram_sel():
             spi_data = sync.recv_memory(device)
             signal = sync.get_pin_mem_req()
@@ -662,6 +666,7 @@ class DataServer(SocketServer, DataAPI):
 
         else:
             data = None
+            print('data=None, mem_req!=ram_sel, [', sync.get_pin_mem_req(), ', ', sync.get_pin_ram_sel(), ']', device, datetime.now())
 
         if data is not None:
             if self._configurations[device].queue_flag:

python/biopro/server/main.py

@@ -819,12 +819,18 @@ class ControlServer(SocketServer, ControlServerAPI):
         return True
 
     @logging_info
-    def device_battery(self) -> List[int]:
-        device_list = self.device_manager.list_device()
-        if len(device_list) > 0:
-            battery_list = list(map(lambda x: self.device_manager.get_device(x).battery, device_list))
-
-        return battery_list
+    def device_battery(self, device:int) -> List[int]:
+        battery = {}
+        if device == 'all':
+            device_list = self.device_manager.list_device()
+            if len(device_list) > 0:
+                battery = list(map(lambda x: {"device": x.memory_board, "battery":self.device_manager.get_device(x).battery}, device_list))
+        else:
+            battery = {
+                "device": device,
+                "battery": self.device_manager.get_device(device).battery
+            }
+        return battery
 
     @logging_info
     def device_parent(self, device: int, content: Optional[str] = None) -> List[int]:
@@ -1015,6 +1021,7 @@ class ControlServer(SocketServer, ControlServerAPI):
     @logging_info
     def run_project(self, project) -> bool:
         if project is not None:
+            # print(project)
             project = self._project_manager.create(project)
             self._project_manager.run_project(project)
         return  project.as_json()
@@ -1024,6 +1031,12 @@ class ControlServer(SocketServer, ControlServerAPI):
         if project is not None:
             self._project_manager.stop_project(project)
         return True
+    
+    @logging_info
+    def set_project(self, project, content) -> bool:
+        if project is not None:
+            self._project_manager.set_project(project, content)
+        return True
 
     @logging_info
     def get_running_project(self) -> bool:

python/res/devlib/json/Elite_EDC_1.5.devlib.json

@@ -15,6 +15,33 @@
     "BLE_WRITE_MAX": 255
   },
   "parameters": {
+    "HIGHZ_TABLE": {
+      "initial": [
+        1,
+        1,
+        1,
+        1,
+        0,
+        1,
+        1,
+        1,
+        1,
+        1,
+        1,
+        1,
+        1,
+        0,
+        1,
+        1,
+        1
+      ],
+      "domain": {
+        "list": [
+          100
+        ]
+      },
+      "value": "VALUE"
+    },
     "DPV_e_init": {
       "description": "DPV initial voltage ",
       "record_meta": true,
@@ -1081,7 +1108,7 @@
     "cali_Vout": {
       "type": "RIS",
       "parameter": {
-        "v": "DAC_VOLT_BUTTON" 
+        "v": "DAC_VOLT_BUTTON"
       },
       "data": [
         "XF1;B>ADC_DAC_CHANNEL_15;B>v"

python/res/devlib/json/Elite_EDC_1.5r2.devlib.json

@@ -15,6 +15,33 @@
     "BLE_WRITE_MAX": 255
   },
   "parameters": {
+    "HIGHZ_TABLE": {
+      "initial": [
+        1,
+        1,
+        1,
+        1,
+        0,
+        1,
+        1,
+        1,
+        1,
+        1,
+        1,
+        1,
+        1,
+        0,
+        1,
+        1,
+        1
+      ],
+      "domain": {
+        "list": [
+          100
+        ]
+      },
+      "value": "VALUE"
+    },
     "DPV_e_init": {
       "description": "DPV initial voltage ",
       "record_meta": true,
@@ -1081,7 +1108,7 @@
     "cali_Vout": {
       "type": "RIS",
       "parameter": {
-        "v": "DAC_VOLT_BUTTON" 
+        "v": "DAC_VOLT_BUTTON"
       },
       "data": [
         "XF1;B>ADC_DAC_CHANNEL_15;B>v"

python/res/devlib/json/Elite_EDC_1.5re.devlib.json

@@ -15,6 +15,33 @@
     "BLE_WRITE_MAX": 255
   },
   "parameters": {
+    "HIGHZ_TABLE": {
+      "initial": [
+        1,
+        1,
+        1,
+        1,
+        0,
+        1,
+        1,
+        1,
+        1,
+        1,
+        1,
+        1,
+        1,
+        0,
+        1,
+        1,
+        1
+      ],
+      "domain": {
+        "list": [
+          100
+        ]
+      },
+      "value": "VALUE"
+    },
     "DPV_e_init": {
       "description": "DPV initial voltage ",
       "record_meta": true,
@@ -1081,7 +1108,7 @@
     "cali_Vout": {
       "type": "RIS",
       "parameter": {
-        "v": "DAC_VOLT_BUTTON" 
+        "v": "DAC_VOLT_BUTTON"
       },
       "data": [
         "XF1;B>ADC_DAC_CHANNEL_15;B>v"

python/res/devlib/json/Elite_EIS_1.1.devlib.json

@@ -70,7 +70,7 @@
       "description": "DPV current recording period start",
       "record_meta": true,
       "initial": [
-        13422819,
+        13333333,
         7
       ],
       "domain": {