nothing modified
Dependencies: mbed-src WizFi310Interface_Legacy_ DHT MQTT
main.cpp
- Committer:
- irayya
- Date:
- 2019-01-10
- Revision:
- 18:0596e033d027
- Parent:
- 16:2794fcca7629
- Child:
- 19:2e11b8a64d23
File content as of revision 18:0596e033d027:
#include "mbed.h" #include "WizFi310Interface.h" #include "DHT.h" #include "MQTTClient.h" #include "MQTTmbed.h" #include "MQTTSocket.h" #include "string.h" #define SECURE WizFi310::SEC_WPA2_MIXED #define SSID "CDI_STAFF" #define PASS "uDQmAfJY" // should use perticular passd for each wizfi-310 device with CDI_STAFF network DigitalOut led1(D0); char msg[16]; char result[10]; /* SET DHCP */ #define USE_DHCP 1 //--------- Have to modify the mac address------------- unsigned char MAC_Addr[6] = {0x00,0x08,0xDC,0x12,0x34,0x56}; #if defined(TARGET_WIZwiki_W7500) WizFi310Interface wizfi310(D1, D0, D7, D6, D8, NC, 115200); Serial pc(USBTX, USBRX); #endif int arrivedcount = 0; void messageArrived(MQTT::MessageData& md) { MQTT::Message &message = md.message; sprintf(result, "%.*s", message.payloadlen,(char*)message.payload); if(strcmp(result,"on") == 0) { led1 = 1; printf("LED blink \n"); } if(strcmp(result,"off")== 0) { led1 = 0; printf("buzz\n"); } memset(result,'\0', sizeof(result)); printf("Message arrived: qos %d, retained %d, dup %d, packetid %d\n", message.qos, message.retained, message.dup, message.id); printf("Payload %.*s\n", message.payloadlen, (char*)message.payload); ++arrivedcount; } class MQTTWIZ: public MQTTSocket { public: MQTTWIZ() { wait(1); this->createSocket(); } }; int main() { pc.baud(115200); char* topicfan = "/led"; printf("WizFi310 STATION. \r\n"); wizfi310.init(); printf("After Initialisation. \r\n"); printf("After Set Address. \r\n"); if ( wizfi310.connect(SECURE, SSID, PASS, WizFi310::WM_STATION)) return -1; printf("After Connect. \r\n"); printf("IP Address is %s\r\n", wizfi310.getIPAddress()); MQTTWIZ ipstack = MQTTWIZ(); MQTT::Client<MQTTWIZ, Countdown> client = MQTT::Client<MQTTWIZ, Countdown>(ipstack); DHT sensor(D14, DHT11); char* hostname = "172.16.73.4"; int port = 1883; int rc = ipstack.connect(hostname, port); if (rc != 0) printf("rc from TCP connect is %d\n", rc); printf("rc from TCP connect is %d\n", rc); char MQTTClientID[30]; //MQTTPacket_connectData data = MQTTPacket_connectData_initializer; // data.MQTTVersion = 3; // sprintf(MQTTClientID,"WIZwiki-W7500-client-%d",rand()%1000); // data.clientID.cstring = MQTTClientID; // data.username.cstring = "testuser"; // data.password.cstring = "testpassword"; MQTTPacket_connectData data = MQTTPacket_connectData_initializer; data.MQTTVersion = 3; data.clientID.cstring = "parents"; if ((rc = client.connect(data)) != 0) printf("rc from MQTT connect is %d\n", rc); if ((rc = client.subscribe(topicfan, MQTT::QOS1, messageArrived)) == 0) printf("rc from MQTT subscribe for fan is %d\n", rc); MQTT::Message message; char buf[100]; int error = 0; float hum = 0.0f, temp = 0.0f; char i = 0; while (true) { if(i > 100) i = 0; error = sensor.readData(); if (0 == error) { hum = sensor.ReadHumidity(); temp = sensor.ReadTemperature(CELCIUS); } message.qos = MQTT::QOS0; message.retained = false; message.dup = false; sprintf(buf, "%3.1f", hum); message.payload = (void*)buf; message.payloadlen = strlen(buf); rc = client.publish("Wiz/humidity", message); printf("Wiz/humidity : %s\r\n",message.payload); sprintf(buf, "%3.1f", temp); message.payload = (void*)buf; message.payloadlen = strlen(buf); rc = client.publish("Wiz/temperature", message); printf("Wiz/temperature : %s\r\n",message.payload); client.yield(1000); } }