241215 外调程序

admin

py程序文件

admin

1. #  -*- coding: UTF-8 -*-
   
2. 
   
3. # MindPlus
   
4. # Python
   
5. import siot
   
6. from unihiker import GUI
   
7. from cfg import *
   
8. import json
   
9. 
   
10. 
    
11. # 自定义函数
    
12. def init():
    
13.     # siot.init(client_id="",server=iserver,port=iport,user=iuser,password=ipwd)
    
14.     siot.init(CLIENT_ID, SERVER, user=IOT_UserName, password=IOT_PassWord, port=IOT_PORT)
    
15.     siot.connect()
    
16.     siot.loop()
    
17.     siot.getsubscribe(IOT_TOPIC)
    
18.     siot.set_callback(on_message_callback)
    
19.    
    
20. def siotpub(msg):
    
21.     # print("程序开始")
    
22.     siot.init(CLIENT_ID, SERVER, user=IOT_UserName, password=IOT_PassWord, port=IOT_PORT)  # 初始化MQTT参数
    
23.     # 连接MQTT服务器
    
24.     siot.connect()
    
25.     print(msg)
    
26.     siot.getsubscribe(IOT_TOPIC)
    
27.     # print("连接完成connected")
    
28.     siot.publish(IOT_TOPIC, msg)  # siot1.0发布信息
    
29.     return msg
    
30. 
    
31. def MQTT(ZhuTi, ZuoPin):   
    
32.     siot.getsubscribe(topic=ZhuTi)
    
33.     siot.publish(topic=ZhuTi, data=ZuoPin)
    
34. def GP(msg):
    
35.     print(msg)
    
36.     return msg
    
37. def FaSong(msg, topic):
    
38.     siot.publish(topic=topic, data=msg)
    
39.     return msg
    
40. def fun_DongTai(msg):
    
41.     # 动态.config(text=msg)
    
42.     return msg
    
43. 
    
44. def Rjson(FJson, K):
    
45.     fileObj = open(FJson, "r", encoding="UTF8")
    
46.     pyObj = json.loads(fileObj.read())
    
47.     fileObj.close()
    
48.     G_KEY = pyObj
    
49.     return (G_KEY[K])
    
50.    
    
51. def RJD(Fjson):
    
52.     fileObj = open(Fjson, "r", encoding="UTF8")
    
53.     pyObj = json.loads(fileObj.read())
    
54.     fileObj.close()
    
55.     G_KEY = pyObj
    
56.     return G_KEY
    
57. 
    
58. # 事件回调函数
    
59. def on_message_callback(client, userdata, msg):
    
60.     fun_DongTai(GP((str(msg.payload.decode()))))
    
61. 
    
62. 
    
63. 
    
64. # u_gui1=GUI()
    
65. # 动态=u_gui1.draw_text(text="行空板",x=0,y=0,font_size=20, color="#0000FF")
    
66. # init()
    
67. # siotpub('代码导入调用 ')
    
68. # init('i.37ck.cn',1883,'37ck','20200808')
    
69. # MQTT('37ck/1215','37ck')
    
70. # while True:
    
71. #     pass
    

复制代码