python通过upd获取温湿度数据以及通过红外控制普通空调

zhaopengxslc

1. #include <DHT.h>
   
2. #include <SPI.h>         // needed for Arduino versions later than 0018
   
3. #include <Ethernet.h>
   
4. #include <EthernetUdp.h>         // UDP library from: [email][email protected][/email] 12/30/2008
   
5. #include <SoftwareSerial.h>
   
6. 
   
7. #define DHTPIN 2     // what pin we're connected to
   
8. #define DHTTYPE DHT11   // DHT 11
   
9. 
   
10. // Enter a MAC address and IP address for your controller below.
    
11. // The IP address will be dependent on your local network:
    
12. byte mac[] = {  
    
13.   0xDE, 0xAD, 0xBE, 0xEF, 0xFE, 0xED };
    
14. IPAddress ip(192, 168, 2, 177);
    
15. unsigned int localPort = 8000;      // local port to listen on
    
16. 
    
17. // buffers for receiving and sending data
    
18. char packetBuffer[UDP_TX_PACKET_MAX_SIZE]; //buffer to hold incoming packet,
    
19. char  ReplyBuffer[UDP_TX_PACKET_MAX_SIZE];       // a string to send back
    
20. char tempBuf[UDP_TX_PACKET_MAX_SIZE];
    
21. 
    
22. // An EthernetUDP instance to let us send and receive packets over UDP
    
23. EthernetUDP Udp;
    
24. DHT dht(DHTPIN, DHTTYPE);
    
25. 
    
26. //Infrared communation infomation
    
27. byte InfrInitStart[]={0xAA,0xAA,0x08,0x08,0x00};
    
28. byte InfrInitEnd[]={0xCC,0xCC,0x08,0x08,0x00};
    
29. byte AirConVerion[]={0x02,0x00,0x2C,0x08,0x26};
    
30. //fit the air condition type code 0x2C is 044 (meidi KFR-72LW)
    
31. //if you want to control another air condition , you should change 0x2c
    
32. byte AirConTrunOn[]={0x04,0xff,0x08,0x08,0xfb};
    
33. byte AirConTurnOff[]={0x04,0x00,0x08,0x08,0x04};
    
34. 
    
35. //use pin 6 as receivepin and use pin  as transmitpin
    
36. SoftwareSerial serial(6,7);
    
37. 
    
38. 
    
39. void setup() {
    
40.   // start the Ethernet and UDP:
    
41.   Ethernet.begin(mac,ip);
    
42.   Udp.begin(localPort);
    
43.   dht.begin();
    
44.   Serial.begin(9600);
    
45.   serial.begin(9600);
    
46.   
    
47.    delay(1000);  
    
48.   //Initialize the infrared mode start
    
49.   serial.write(InfrInitStart,5);
    
50.   if(checkRespondeCode())
    
51.   {
    
52.   //Initialize the infread mode end
    
53.     serial.write(InfrInitEnd,5);
    
54.   }
    
55.   else
    
56.   {
    
57.     exit(0);
    
58.   }
    
59.   if(checkRespondeCode())
    
60.   {
    
61.    //set the air condition mode version
    
62.      serial.write(AirConVerion,5);
    
63.   }  
    
64.   else
    
65.   {
    
66.     exit(1);
    
67.   }
    
68.   if(checkRespondeCode()==false)
    
69.   {
    
70.     exit(2);
    
71.   }
    
72. }
    
73. 
    
74. 
    
75. boolean checkRespondeCode()
    
76. {
    
77.   byte RXData;
    
78.   delay(1000);
    
79.   //Serial.println("check response code");
    
80.   if(serial.available())
    
81.   {
    
82.     delay(200);
    
83.     RXData=serial.read();
    
84.     //Serial.println(RXData,HEX);
    
85.     if(RXData==0x89)
    
86.     {
    
87.       //serial.println();
    
88.       Serial.println("xiang ying 89");
    
89.       return true;
    
90.     }
    
91.     else
    
92.     {
    
93.       Serial.println(RXData,HEX);
    
94.     }
    
95.   }
    
96.   Serial.println("no xiang ying");
    
97.   return false;
    
98. }
    
99. 
    
100. float getnum(char* strcmd)
     
101. {
     
102.   int i=0;
     
103.   char temp[100];
     
104.   for(i=3;i<strlen(strcmd);i++)
     
105.   {
     
106.     temp[i-3]=strcmd[i];
     
107.   }
     
108.   temp[i-3]='\0';
     
109.   return atof(temp);
     
110. }
     
111. 
     
112. 
     
113. float getHumidity()
     
114. {
     
115.   float h = dht.readHumidity();
     
116.   if(isnan(h))
     
117.   {
     
118.     return 0;
     
119.   }
     
120.   return h;
     
121. }
     
122. 
     
123. float getTemperature()
     
124. {
     
125.   float t = dht.readTemperature();
     
126.   if(isnan(t))
     
127.   {
     
128.     return 0;
     
129.   }
     
130.   return t;
     
131. }
     
132. 
     
133. void loop() {
     
134.   float h=0.0,t=0.0;
     
135.   //float h = dht.readHumidity();
     
136.   //float t = dht.readTemperature();
     
137. /* if (isnan(t) || isnan(h))
     
138.   {
     
139.     Serial.println("Failed to read from DHT");
     
140.   }
     
141.   else
     
142.   {
     
143.     Serial.print("Humidity: ");
     
144.     Serial.print(h);
     
145.     Serial.print(" %\t");
     
146.     Serial.print("Temperature: ");
     
147.     Serial.print(t);
     
148.     Serial.println(" *C");
     
149.   }*/
     
150.   
     
151.   
     
152.   // if there's data available, read a packet
     
153.   int packetSize = Udp.parsePacket();
     
154.   if(packetSize)
     
155.   {
     
156.     Serial.print("Received packet of size ");
     
157.     Serial.println(packetSize);
     
158.     Serial.print("From ");
     
159.     IPAddress remote = Udp.remoteIP();
     
160.     for (int i =0; i < 4; i++)
     
161.     {
     
162.       Serial.print(remote[i], DEC);
     
163.       if (i < 3)
     
164.       {
     
165.         Serial.print(".");
     
166.       }
     
167.     }
     
168.     Serial.print(", port ");
     
169.     Serial.println(Udp.remotePort());
     
170. 
     
171.     // read the packet into packetBufffer
     
172.     Udp.read(packetBuffer,UDP_TX_PACKET_MAX_SIZE);
     
173.    
     
174.     switch(packetBuffer[0])
     
175.     {
     
176.       case '0':  //control
     
177.         switch(packetBuffer[1])
     
178.         {
     
179.           case '0': //temperature and humility
     
180.             break;
     
181.           case '2': //air controler
     
182.             switch(packetBuffer[2])
     
183.             {
     
184.               case '0':
     
185.                 if(getnum(packetBuffer)==0.0)
     
186.                  {
     
187.                    Serial.println("turn on the air condition");
     
188.                    sprintf(ReplyBuffer,"turn on the air condition");
     
189.                    serial.write(AirConTrunOn,5);
     
190.                    Serial.println("0x04,0xff,0x08,0x08,0xfb");
     
191.                   
     
192.                  }
     
193.                  else if(getnum(packetBuffer)==1.0)
     
194.                  {
     
195.                    Serial.println("turn off the air condition");
     
196.                    sprintf(ReplyBuffer,"turn off the air condition");
     
197.                    serial.write(AirConTurnOff,5);
     
198.                    Serial.println("0x04,0x00,0x08,0x08,0x04");
     
199.                  }
     
200.                 break;
     
201.               case '1':
     
202.                 break;
     
203.               default:
     
204.                 break;
     
205.             }
     
206.             break;
     
207.           default:
     
208.             break;
     
209.            
     
210.         }
     
211.         break;
     
212.       case '1':  //informaiton
     
213.         switch(packetBuffer[1])
     
214.         {
     
215.           case '0': //temperature and humility
     
216.             switch(packetBuffer[2])
     
217.             {
     
218.                case '1':
     
219.                  h=getHumidity();
     
220.                  dtostrf(h,10,2,tempBuf);
     
221.                  sprintf(ReplyBuffer,"100humidity:%s",tempBuf);                 
     
222.                  break;
     
223.               case '0':  //temperature
     
224.                 t=getTemperature();
     
225.                 dtostrf(t,10,2,tempBuf);
     
226.                 sprintf(ReplyBuffer,"100Temperature:%s",tempBuf);               
     
227.                 break;
     
228. 
     
229.               /*case :  //humility
     
230.                 float h=getHumidity();
     
231.                 sprintf(ReplyBuffer,"101Humidity:%f\n",h);
     
232.                 break;*/
     
233.             }
     
234.             break;
     
235.            case '2': //air controler
     
236.              break;
     
237.         }
     
238.         break;
     
239.       default:
     
240.         Serial.println("Error");
     
241.     }
     
242.    
     
243.     Serial.println("Contents:");
     
244.     Serial.println(packetBuffer);
     
245.     memset(packetBuffer,'\0',UDP_TX_PACKET_MAX_SIZE);
     
246. 
     
247.     // send a reply, to the IP address and port that sent us the packet we received
     
248.     Serial.println(ReplyBuffer);
     
249.     Udp.beginPacket(Udp.remoteIP(),Udp.remotePort());
     
250.     Udp.write(ReplyBuffer);
     
251.     Udp.endPacket();
     
252.   }
     
253.   delay(10);
     
254. }
     

复制代码

[pre lang="python" line="1"]from socket import *

HOST="192.168.2.177"
PORT=8000
BUFSIZE=1024
ADDR=(HOST,PORT)

udpCliSock=socket(AF_INET,SOCK_DGRAM)
while True:
    data=raw_input(">")
    if not data:
        break
    udpCliSock.sendto(data,ADDR)
    data,ADDR=udpCliSock.recvfrom(BUFSIZE)
    if not data:
        break
    print data,ADDR
udpCliSock.close()
[/code]

说明：
输入100获取温度信息
输入101获取湿度信息
输入0200 打开空调
输入0201 关闭空调