|
|
@@ -0,0 +1,67 @@
|
|
|
+import _thread
|
|
|
+import time
|
|
|
+
|
|
|
+import utils
|
|
|
+from config import getConfig
|
|
|
+from httpServer import startHttpServer,closeHttpServer
|
|
|
+# 硬重启
|
|
|
+import machine
|
|
|
+
|
|
|
+
|
|
|
+def taskCheck():
|
|
|
+ """
|
|
|
+ 定时检查连接
|
|
|
+ :return:
|
|
|
+ """
|
|
|
+ time_sleep = 10
|
|
|
+ count = 0
|
|
|
+ config = getConfig()
|
|
|
+ while True:
|
|
|
+ if getConfig().runTask:
|
|
|
+ try:
|
|
|
+ if utils.getStatus():
|
|
|
+ print('WiFi 正常', utils.getWifiConnectInfo())
|
|
|
+ if getConfig().mqttStatus :
|
|
|
+ print('MQTT 正常', getConfig().mqtt.host, getConfig().mqtt.port,getConfig().mqtt.subTopic)
|
|
|
+ if getConfig().mqtt.clientId is "":
|
|
|
+ print("设备未绑定")
|
|
|
+ utils.send_ping()
|
|
|
+ else:
|
|
|
+ # 有变化就上报一次
|
|
|
+ if config != getConfig():
|
|
|
+ print("上报数据")
|
|
|
+ utils.reportConfig()
|
|
|
+ config = getConfig()
|
|
|
+ else:
|
|
|
+ utils.send_ping()
|
|
|
+ count = 0
|
|
|
+ else:
|
|
|
+ print('MQTT 未连接', getConfig().mqtt.host, getConfig().mqtt.port,getConfig().mqtt.subTopic)
|
|
|
+ utils.connectMQTT(time_sleep)
|
|
|
+ else:
|
|
|
+ print('WiFi 未连接')
|
|
|
+ if utils.autoConnectWifi():
|
|
|
+ utils.connectMQTT(time_sleep)
|
|
|
+
|
|
|
+ # 没有客户的id表示没被绑定
|
|
|
+ if not utils.getStatus() or not getConfig().mqttStatus or getConfig().mqtt.clientId is "":
|
|
|
+ count += 1
|
|
|
+ # 连接失败开启热点
|
|
|
+ utils.openAp()
|
|
|
+ startHttpServer()
|
|
|
+ else:
|
|
|
+ closeHttpServer()
|
|
|
+ utils.closeAp()
|
|
|
+
|
|
|
+ if count > 60:
|
|
|
+ machine.reset()
|
|
|
+ except Exception as e:
|
|
|
+ print(f"连接失败：未知错误 - {e}")
|
|
|
+
|
|
|
+ time.sleep(time_sleep)
|
|
|
+
|
|
|
+
|
|
|
+try:
|
|
|
+ _thread.start_new_thread(taskCheck, ())
|
|
|
+except:
|
|
|
+ machine.reset()
|
