rabin 7 jaren geleden
bovenliggende
commit
eb49cd2ff8
1 gewijzigde bestanden met toevoegingen van 41 en 41 verwijderingen
  1. 41 41
      control.py

+ 41 - 41
control.py

@@ -1,42 +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),
-	])
-
+#!/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()