循环处理进程

hfv/workProcess.py

+'''
+****************************************************
+*             任务执行模块                         *          
+*          1. 检查任务队列是否存在任务             *
+*          2. 从任务队列中取任务并执行             *
+*          3. 发送控制命令到指定的智能体           *
+*          4. 未来或许可以根据配置的智能体参数，   *
+*             动态修改智能体的计算资源等           *
+*                                                  *
+*             author： joliu<joliu@s-an.org>       *
+*             date: 2018-3-22                      *
+****************************************************
+'''
+
+from listenSer import sendBySocket
+from listenSer import sendCommandToDevice
+
+import sqlite3
+import time
+
+def findTask():
+    try:
+        sql = "select * from task LIMIT 1"
+        conn = sqlite3.connect("task.db")
+        cursor = conn.cursor()
+        cursor.execute(sql)
+        data = cursor.fetchone()
+        if data is None:
+            (status, output) = (-1, 'database is empty!')
+        else:
+            (status, output) = (1, data)
+    except sqlite3.Error as err_msg:
+        (status, output) = (-1, err_msg)
+    except Exception as err_msg:
+        (status, output) = (-1, err_msg)
+    finally:
+        return (status, output)
+
+
+# 根据符号来比较两个数值的大小
+def compare(signal, value1, value2):
+    if signal == '>':
+        return value1 > value2
+    elif signal == '<':
+        return value1 < value2
+    elif signal == '=':
+        return value1 == value2
+    else:
+        return False
+
+
+def mainWhileProcess(input_ctime):
+    ctime = input_ctime
+    while True:
+        print(ctime)
+        time.sleep(ctime)
+        (status, output) = findTask()
+        if status == -1:
+            print(output)
+            # 如果数据库为空，或者错误，恢复初始设置
+            ctime = input_ctime
+            continue
+
+        (task, taskid, ctime) = output
+        if len(task.split(';')) != 2 or len(task.split(':')) != 3:
+            print("Error task: %s" % task)
+            continue
+    
+        # 初步定义task字符串模式 eg: >30;192.168.1.1:3000:off
+    
+        (condition, command) = task.split(';')
+        (ip, port, method) = command.split(':')
+        # 读取传感器数值
+        (status, output) = sendCommandToDevice('1')
+        if status == -1:
+            print("get device data failed! ip: %s, method: %s" % (ip, method))
+            continue
+
+        if compare(condition[0], float(output), float(condition[1:])):
+            # 当结果为真，向目标传感器发出指令
+            (status, output) = sendBySocket(ip, port, method)
+            print(output)
+        else:
+            pass
+
+
+if __name__ == "__main__":
+    mainWhileProcess(5)