edit

control.py

@@ -0,0 +1,42 @@
+#!/usr/bin/env python
+# -*- coding: utf-8 -*-
+"""
+    demeter web
+    name:admin.py
+    author:rabin
+"""
+import time
+from demeter.core import *
+from gevent import monkey; monkey.patch_socket()
+import gevent
+from demeter.mqtt import *
+# 处理定时命令、周期命令、条件控制、消息、设备状态等
+timeSleep = 10
+
+# 更改控制设备的超时状态
+def control():
+	model = Demeter.model('device_info')
+	cur = Demeter.time() - 10
+	model.operdate.assgin(cur, '<=')
+	model.oper = True
+	model.hardware_type = 3
+	service = Demeter.service('device')
+	data = model.select()
+	if data:
+		for v in data:
+			model.id = v['id']
+			if v['exp'] == '-1':
+				msg = service.notice('timeout')
+				service.mul(v, v['name'] + '失败:' + msg, False)
+				model.update(exp=msg, oper=True, operdate=Demeter.time())
+			else:
+				msg = '1'
+				service.mul(v, '', True)
+				model.update(exp=msg, oper=False, operdate=Demeter.time())
+
+def handle():
+	gevent.joinall([
+		gevent.spawn(control),
+	])
+
+handle()

cron.py

@@ -183,7 +183,7 @@ def handle():
 		gevent.spawn(loop),
 		gevent.spawn(device),
 		gevent.spawn(savePic),
-		gevent.spawn(control),
+		#gevent.spawn(control),
 		gevent.spawn(timeSync),
 		gevent.spawn(mulQueue),
 		gevent.spawn(mulQueueDrop),