RT-Thread-[第二期空气质量分析仪] 第二周作业RT-Thread问答社区

[第二期空气质量分析仪] 第二周作业

发布于 2019-09-06 23:01:47 浏览：945 订阅该版

+ RW007 连接 onenet  成功 ，但温湿度气压数据没配置上传
![QQ截图20190906225958.png](/uploads/201909/06/230109hh3oqsykc8yass1c.png)

![QQ截图20190906225344.png](/uploads/201909/06/225436myh0lf2j7nnyohfg.png)

```/*
 * Copyright (c) 2006-2018, RT-Thread Development Team
 *
 * SPDX-License-Identifier: Apache-2.0
 *
 * Change Logs:
 * Date             Author      Notes
 *
 */

#include <rtthread.h>
#include "sensor.h"
#include <sys/socket.h> /* 使用BSD socket，需要包含sockets.h头文件 */
#include <netdb.h>
#include <string.h>
#include "bme280.h"

#define SENSOR_NAME   "temp_bme"

static char send_buf[100]; /* 发送用到的数据 */
#if 0
struct bme280_data {
	/*! Compensated pressure */
	uint32_t pressure;
	/*! Compensated temperature */
	int32_t temperature;
	/*! Compensated humidity */
	uint32_t humidity;
};
#endif
uint8_t sensor_comp;
struct bme280_data comp_data[1];
struct bme280_dev bme_dev[1];

void udp_update(int argc, char **argv)
{
    int sock, port, count;
    struct hostent *host;
    struct sockaddr_in server_addr;
    const char *url;
    rt_device_t dev = RT_NULL;
    struct rt_sensor_data data;
    rt_size_t res, i;

if (argc < 3)
    {
        rt_kprintf("Usage: udp_update URL PORT [COUNT = 10]<br>");
        rt_kprintf("Like: udp_update 192.168.12.44 5000<br>");
        return ;
    }

url = argv[1];
    port = strtoul(argv[2], 0, 10);

if (argc > 3)
        count = strtoul(argv[3], 0, 10);
    else
        count = 10;

/* 通过函数入口参数url获得host地址（如果是域名，会做域名解析） */
    host = (struct hostent *) gethostbyname(url);

/* 创建一个socket，类型是SOCK_DGRAM，UDP类型 */
    if ((sock = socket(AF_INET, SOCK_DGRAM, 0)) == -1)
    {
        rt_kprintf("Socket error<br>");
        return;
    }

/* 初始化预连接的服务端地址 */
    server_addr.sin_family = AF_INET;
    server_addr.sin_port = htons(port);
    server_addr.sin_addr = *((struct in_addr *)host->h_addr);
    rt_memset(&(server_addr.sin_zero), 0, sizeof(server_addr.sin_zero));
/*
    dev = rt_device_find(SENSOR_NAME);
    if (dev == RT_NULL)
    {
        rt_kprintf("Can't find device:%s", SENSOR_NAME);
        return;
    }
    if (rt_device_open(dev, RT_DEVICE_FLAG_RDWR) != RT_EOK)
    {
        rt_kprintf("open device failed!");
        return;
    }
    rt_device_control(dev, RT_SENSOR_CTRL_SET_ODR, (void *)100);
   */ 
    /* 总计发送count次数据 */
    for(i = 0; i < count; i ++)
    {
        //res = rt_device_read(dev, 0, &data, 1);
        //if (res != 1)
       // {
      //      rt_kprintf("read data failed!size is %d", res);
      //  }
       // else
        //{
					//	bme280_get_sensor_data(sensor_comp,comp_data,bme_dev);
            rt_sprintf(send_buf, "num:%3d, x:%5d, y:%5d, z:%5d, timestamp:%5d<br>"
                               , i, data.data.mag.x, data.data.mag.y, data.data.mag.z, data.timestamp);
      //  }
        /* 发送数据到服务远端 */
        sendto(sock, send_buf, strlen(send_buf), 0,
               (struct sockaddr *)&server_addr, sizeof(struct sockaddr));

/* 线程休眠一段时间 */
        rt_thread_mdelay(100);
    }
   // rt_device_close(dev);

/* 关闭这个socket */
    closesocket(sock);
}

MSH_CMD_EXPORT(udp_update, a udp update sample);
```