|
|
@@ -7,9 +7,6 @@
|
|
|
"""
|
|
|
import time
|
|
|
from demeter.core import *
|
|
|
-from gevent import monkey; monkey.patch_socket()
|
|
|
-import gevent
|
|
|
-from demeter.mqtt import *
|
|
|
# 处理定时命令、周期命令、条件控制、消息、设备状态等
|
|
|
timeSleep = 10
|
|
|
|
|
|
@@ -33,10 +30,6 @@ def control():
|
|
|
msg = '1'
|
|
|
service.mul(v, '', True)
|
|
|
model.update(exp=msg, oper=False, operdate=Demeter.time())
|
|
|
-
|
|
|
-def handle():
|
|
|
- gevent.joinall([
|
|
|
- gevent.spawn(control),
|
|
|
- ])
|
|
|
-
|
|
|
-handle()
|
|
|
+while 1:
|
|
|
+ control()
|
|
|
+ time.sleep(timeSleep)
|
rabin