物联网项目-智能终端程序

hzxc

室内环境实时监测系统（请勿点击代码末尾“复制代码”，手动选中程序进行复制，到BXY中修改并烧录程序）

1. #***************WIFI模块内部代码*************
   
2. class Obloq(object):
   
3.     def read_until(self, min_num_bytes, ending, timeout=10):
   
4.         timeout_count = 0
   
5.         while not uart.any():
   
6.             if timeout_count >= 1000 * timeout:
   
7.                 return ''
   
8.             sleep(1)
   
9.             timeout_count += 1
   
10.         data = str(uart.read(min_num_bytes), 'UTF-8')
    
11.         while timeout_count < 1000 * timeout:
    
12.             if type(ending) == str:
    
13.                 if data.endswith(ending):
    
14.                     break
    
15.             elif type(ending) == list:
    
16.                 end = False
    
17.                 for i in ending:
    
18.                     if data.endswith(i):
    
19.                         end = True
    
20.                         break
    
21.                 if end:
    
22.                     break
    
23.             if uart.any():
    
24.                 new_data = str(uart.read(min_num_bytes), 'UTF-8')
    
25.                 data += new_data
    
26.                 timeout_count = 0
    
27.             else:
    
28.                 sleep(1)
    
29.                 timeout_count += 1
    
30.         return data
    
31. 
    
32.     def exit_raw_repl(self):
    
33.         uart.write('+++')
    
34.         data = self.read_until(1, '+++', 1)
    
35.         if data == '':
    
36.             pass
    
37.         elif not data.endswith('+++'):
    
38.             return False
    
39.         self.in_raw_repl = False
    
40.         return True
    
41. 
    
42.     error_msg1 = 'wifi module not detected'
    
43.     error_msg2 = '...' #disconnect from USB wire & restart haoda:bit
    
44.     in_raw_repl = True
    
45.     def connectWifi(self, SSID, PASSWORD, TIMEOUT=10000):
    
46.         if self.in_raw_repl:
    
47.             while not self.exit_raw_repl():
    
48.                 pass
    
49.         uart.write('AT+RST\r\n')
    
50.         try:
    
51.             data = self.read_until(256, 'ready\r\n', 5)
    
52.         except:
    
53.             return False
    
54.         if data == '':
    
55.             display.scroll(self.error_msg1)
    
56.             return False
    
57.         elif not data.endswith('ready\r\n'):
    
58.             display.scroll(self.error_msg2)
    
59.             return False
    
60.         uart.write('AT+CWMODE_CUR=3\r\n')
    
61.         data = self.read_until(1, 'OK\r\n', 1)
    
62.         if not data.endswith('OK\r\n'):
    
63.             display.scroll(self.error_msg2)
    
64.             return False
    
65.         #设置Wi-Fi模块连接无线网络
    
66.         uart.write('AT+CWJAP_CUR="%s","%s"\r\n' %(SSID, PASSWORD))
    
67.         display.scroll('wait...')
    
68.         data = self.read_until(1, ['OK\r\n', 'FAIL\r\n'], TIMEOUT / 1000)
    
69.         if data.endswith('OK\r\n') and data.find('WIFI GOT I') > -1:
    
70.             pass
    
71.         elif data.endswith('FAIL\r\n'):
    
72.             if data.find('WIFI CONNECTED') > -1:
    
73.                 display.scroll('dhcp not available / ip conflict')
    
74.                 return False
    
75.             else:
    
76.                 display.scroll('check wifi ssid / password')
    
77.                 return False
    
78.         else:
    
79.             display.scroll(self.error_msg2)
    
80.             return False
    
81.         return True
    
82. 
    
83.     def ifconfig(self, retry=10):
    
84.         if self.in_raw_repl:
    
85.             return 'cannot get IP in raw mode'
    
86.         retry_count = 0
    
87.         while retry_count < retry:
    
88.             #设置这个后 读串口返回绑定IP
    
89.             uart.write('AT+CIFSR\r\n')
    
90.             data = self.read_until(64, 'OK\r\n', 2)
    
91.             if not data.endswith('OK\r\n'):
    
92.                 display.scroll(self.error_msg2)
    
93.             elif data.find('STAIP') > -1:
    
94.                 temp = data.split('"')
    
95.                 if len(temp) > 5:
    
96.                     ip_address = temp[5]
    
97.                     return ip_address
    
98.                 retry_count += 1
    
99.             else:
    
100.                 retry_count += 1
     
101.         return 'IP Error'
     
102. 
     
103.     def httpSet(self, IP, PORT):
     
104.         if self.in_raw_repl:
     
105.             while not self.exit_raw_repl():
     
106.                 pass
     
107.         while not self.in_raw_repl:
     
108.             uart.write('AT+CIPSTART="TCP","%s",%s\r\n' %(IP, PORT))
     
109.             data = self.read_until(1, ['CONNECT\r\n\r\nOK\r\n', 'ERROR\r\nCLOSED\r\n'], 6)
     
110.             if data.endswith('ERROR\r\nCLOSED\r\n'):
     
111.                 display.scroll('server offline')
     
112.                 continue
     
113.             elif not data.endswith('CONNECT\r\n\r\nOK\r\n'):
     
114.                 display.scroll(self.error_msg2)
     
115.                 continue
     
116.             #设置WIFI模块为透传模式
     
117.             uart.write('AT+CIPMODE=1\r\n')
     
118.             data = self.read_until(1, 'OK\r\n', 0.5)
     
119.             if not data.endswith('OK\r\n'):
     
120.                 display.scroll(self.error_msg2)
     
121.                 continue
     
122.             #在透传模式下开始发送数据
     
123.             uart.write('AT+CIPSEND\r\n')
     
124.             data = self.read_until(1, 'OK\r\n\r\n>', 3)
     
125.             if not data.endswith('OK\r\n\r\n>'):
     
126.                 display.scroll(self.error_msg2)
     
127.                 continue
     
128.             self.in_raw_repl = True
     
129.         return True
     
130. 
     
131.     def get(self, url, TIMEOUT):
     
132.         uart.write('GET /' + url + '\r\n\r\n')
     
133.         #data = self.read_until(1, '', TIMEOUT / 1000)
     
134.         timeout_count = 0
     
135.         while not uart.any():
     
136.             if timeout_count >= TIMEOUT:
     
137.                 return (404, 'Not Found')
     
138.             sleep(1)
     
139.             timeout_count += 1
     
140.         data = str(uart.read(), 'UTF-8')
     
141.         if data == '':
     
142.             pass
     
143.         elif not data.endswith('ERROR\r\n'):
     
144.             return (200, data)
     
145.         return (404, 'Not Found')
     
146. 
     
147. Obloq = Obloq()
     
148. #*************************************************
     
149. from microbit import *
     
150. #LM35连接在pin2
     
151. #设置服务器地址和端口
     
152. IP="192.168.1.10"
     
153. PORT="8080"
     
154. #设置当前环境网络账号和密码
     
155. SSID="my_wifi"
     
156. PASSWORD="1234"
     
157. #设置串口引脚，连接到wifi模块，好搭Bit发送在pin12（接模块R），接收在pin8（接模块T）
     
158. uart.init(baudrate=115200, bits=8, parity=None, stop=1, tx=pin12, rx=pin8)
     
159. 
     
160. while Obloq.connectWifi(SSID,PASSWORD,10000) != True:
     
161.     display.show(".")
     
162. #点阵屏显示wifi module not detected，未检测到wifi模块，可能是wifi模块未连接、引脚设置错误或连接线接触不良等原因
     
163. 
     
164. display.scroll(Obloq.ifconfig()) #显示连上无线网络后wifi模块获取到的IP
     
165. Obloq.httpSet(IP,PORT)
     
166. #点阵屏显示server offline，可能是服务器未开启、防火墙阻挡或无线网络需要认证等原因，使用手机尝试打开网页http://(IP):(PORT)
     
167. 
     
168. while True:
     
169.     errno,resp = Obloq.get("input?id=1&val=" + str("%.1f"%(pin2.read_analog()*3.3/10.24)), 10000)
     
170.     if errno == 200:
     
171.         display.scroll(resp)
     
172.     else:
     
173.         display.scroll(str(errno))
     
174.     sleep(1000*5)
     

复制代码