![](/media/cache/img/default_profile.jpg.50x50_q85.jpg)
1218
Dependencies: mbed-os-example-wifi-DISCO_IOTBOARD_MQTT MQTT
Diff: main.cpp
- Revision:
- 60:5e586131c009
- Parent:
- 59:9bbcc1b368ba
--- a/main.cpp Tue Apr 23 09:45:23 2019 +0000 +++ b/main.cpp Wed Dec 18 04:09:32 2019 +0000 @@ -1,19 +1,3 @@ -/* WiFi Example - * Copyright (c) 2018 ARM Limited - * - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - //MQTT+WIFI @@ -50,9 +34,9 @@ void messageArrived(MQTT::MessageData& md) { MQTT::Message &message = md.message; - logMessage("Message arrived: qos %d, retained %d, dup %d, packetid %d\r\n", message.qos, message.retained, message.dup, message.id); - logMessage("Payload %.*s\r\n", message.payloadlen, (char*)message.payload); - ++arrivedcount; + //logMessage("Message arrived: qos %d, retained %d, dup %d, packetid %d\r\n", message.qos, message.retained, message.dup, message.id); + //logMessage("Payload %.*s\r\n", message.payloadlen, (char*)message.payload); + //++arrivedcount; } @@ -131,6 +115,7 @@ size -= response; // Check if entire message was sent or not printf("sent %d [%.*s]\n", response, strstr(sbuffer, "\r\n")-sbuffer, sbuffer); + } } @@ -147,8 +132,89 @@ socket.close(); } + +Serial particle_sensor(PA_0,PA_1);//TX,RX +Serial pc(USBTX,USBRX); + +float SDS018 () +{ + uint8_t oneByte =0, myData[10],mCheck =0; + uint32_t samples_par = 1000; + int aux=0, t_init =0,i=0; + float PM2_5_A = 0, PM10_A = 0, PM2_5_sum = 0, PM10_sum = 0,PM2_5_avg = 0, PM10_avg = 0,PM2_5,PM10; + Timer t; + + time_t seconds = time(NULL); + //printf("Unix Epoch time = %d\r\n", seconds); + //while(true){ + // t.start(); + // int time_start=t.read_ms(); + //pc.printf("\nPARTICLE\n\r"); + while (aux < samples_par) //while(t.read_ms()-t_init < time_avg) + { + if (aux==0) + t_init = t.read_ms(); + while (particle_sensor.readable()) { // whenever sensor transmits packet (every 1 s) + oneByte = particle_sensor.getc(); + if(oneByte == 0xAA) { + myData[0] = oneByte; + oneByte = particle_sensor.getc(); + if(oneByte == 0xC0) { + myData[1] = oneByte; + mCheck = 0; + for(i=0; i < 6; i++) { // DATA 1-6 received and crc calc + myData[i+2] = particle_sensor.getc(); + //wait_ms(2); + mCheck += myData[i+2]; + if(myData[6]==0x91) + { + //pc.printf("91\n\r"); + } + if(myData[7]==0xA1) + { + //pc.printf("A1\n\r"); + } + } + myData[8] = particle_sensor.getc(); + myData[9] = particle_sensor.getc(); // tail (AB) + if(mCheck == myData[8]) { // if checksum OK + PM2_5 = ((uint16_t)myData[2] | (uint16_t)(myData[3]<<8)); + PM10 = ((uint16_t)myData[4] | (uint16_t)(myData[5]<<8)); + PM2_5_A = (float) PM2_5/10; + PM10_A = (float) PM10/10; + if(PM2_5_A*10 > 9999) + PM2_5_A = 999.9; + if(PM10_A*10 > 9999) + PM10_A = 999.9; + aux++; + PM2_5_sum+=PM2_5_A; // sum samples for future averaging + + PM10_sum+=PM10_A; // sum samples for future averaging + //printf("%3.2f,\t%3.2f\n\r", PM2_5_A, PM10_A); // CSV print: PM2.5, PM10 + //printf("PM2_5_A = %3.2f", PM2_5_A); //PM2.5 + return PM2_5_A; + } + } // head2 + } // head1 + + } // while readable() + + } +} + + + + + + int main() -{ + +{ + + + + pc.baud (115200) ; + int count = 0; printf("WiFi example\n\n"); @@ -182,9 +248,9 @@ // MQTT Example Start float version = 0.6; - char* topic = "test1"; + char* topic = "test"; - logMessage("HelloMQTT: version is %.2f\r\n", version); + //logMessage("HelloMQTT: version is %.2f\r\n", version); NetworkInterface* network = &wifi; if (!network) { @@ -195,10 +261,14 @@ MQTT::Client<MQTTNetwork, Countdown> client(mqttNetwork); - const char* hostname = "192.168.0.120"; + const char* hostname = "172.20.10.3"; int port = 1883; logMessage("Connecting to %s:%d\r\n", hostname, port); + + + int rc = mqttNetwork.connect(hostname, port); + if (rc != 0) logMessage("rc from TCP connect is %d\r\n", rc); @@ -213,47 +283,34 @@ if ((rc = client.subscribe(topic, MQTT::QOS2, messageArrived)) != 0) logMessage("rc from MQTT subscribe is %d\r\n", rc); + + + + + + while(1) + { + MQTT::Message message; - // QoS 0 - char buf[100]; - sprintf(buf, "Hello World! QoS 0 message from app version %f\r\n", version); - message.qos = MQTT::QOS0; + + + char buf[100]; + printf("PM2.5 = %3.2f\r\n",SDS018 ()); + sprintf(buf, "PM2.5 = %3.2f\r\n",SDS018 ()); + + + message.qos = MQTT::QOS1; message.retained = false; message.dup = false; message.payload = (void*)buf; message.payloadlen = strlen(buf)+1; rc = client.publish(topic, message); - while (arrivedcount < 1) - client.yield(100); - - // QoS 1 - sprintf(buf, "Hello World! QoS 1 message from app version %f\r\n", version); - message.qos = MQTT::QOS1; - message.payloadlen = strlen(buf)+1; - rc = client.publish(topic, message); - while (arrivedcount < 2) - client.yield(100); - - // QoS 2 - sprintf(buf, "Hello World! QoS 2 message from app version %f\r\n", version); - message.qos = MQTT::QOS2; - message.payloadlen = strlen(buf)+1; - rc = client.publish(topic, message); - while (arrivedcount < 3) - client.yield(100); - - if ((rc = client.unsubscribe(topic)) != 0) - logMessage("rc from unsubscribe was %d\r\n", rc); - - if ((rc = client.disconnect()) != 0) - logMessage("rc from disconnect was %d\r\n", rc); - - mqttNetwork.disconnect(); - - logMessage("Version %.2f: finish %d msgs\r\n", version, arrivedcount); - - return 0; + client.yield(100); + - + } + + + }