【腾讯连连IoT开发大赛】移动物联网环境监测站

发送的数据：
#define REPORT_DATA_TEMPLATE    "{\\\"method\\\":\\\"report\\\"\\,\\\"clientToken\\\":\\\"00000001\\\"\\,\\\"params\\\":{\\\"countdata\\\":%d,\\\"Humidity\\\":%d,\\\"brightness\\\":%d,\\\"Temperature\\\":%0.2f,\\\"Latitude\\\":%f,\\\"longitude\\\":%f,\\\"GPS_Ext\\\": \\\"lat:%f;lon:%f\\\" }}"

该段代码是从TencentOS tiny的源码中移植过来的
void mqtt_demo_task(void)
{
    int ret = 0;
    int size = 0;
//    int lightness = 0;
    mqtt_state_t state;
    
    char *product_id = PRODUCT_ID;
    char *device_name = DEVICE_NAME;
    char *key = DEVICE_KEY;
    
    device_info_t dev_info;
    memset(&dev_info, 0, sizeof(device_info_t));   
    int  data_count=0 ;
	printf("Init........................................\r\n");
	while(1)
		{
  l610_sal_init(HAL_UART_PORT_1);
	tos_task_delay(1000);
	  
    ret = L610_tencent_firmware_sal_init(HAL_UART_PORT_1);
   
    if (ret < 0) {
        printf("L610 tencent firmware sal init fail, ret is %d\r\n", ret);
    }

    strncpy(dev_info.product_id, product_id, PRODUCT_ID_MAX_SIZE);
    strncpy(dev_info.device_name, device_name, DEVICE_NAME_MAX_SIZE);
    strncpy(dev_info.device_serc, key, DEVICE_SERC_MAX_SIZE);
		
    tos_tf_module_info_set(&dev_info, TLS_MODE_PSK);

    mqtt_param_t init_params = DEFAULT_MQTT_PARAMS;
    if (tos_tf_module_mqtt_conn(init_params) != 0) {
        printf("module mqtt conn fail\n");
    } else {
        printf("module mqtt conn success\n");
    }

    if (tos_tf_module_mqtt_state_get(&state) != -1) {
        printf("MQTT: %s\n", state == MQTT_STATE_CONNECTED ? "CONNECTED" : "DISCONNECTED");
    }
    
    /* 开始订阅topic*/
    size = snprintf(sub_topic_name, TOPIC_NAME_MAX_SIZE, "$thing/down/property/%s/%s", product_id, device_name);

    if (size < 0 || size > sizeof(sub_topic_name) - 1) {
        printf("sub topic content length not enough! content size:%d  buf size:%d", size, (int)sizeof(sub_topic_name));
    }
    if (tos_tf_module_mqtt_sub(sub_topic_name, QOS1, default_message_handler) != 0) {
        printf("module mqtt sub fail\n");
    } else {
        printf("module mqtt sub success\n");
    }
    
    memset(report_topic_name, sizeof(report_topic_name), 0);
    size = snprintf(report_topic_name, TOPIC_NAME_MAX_SIZE, "$thing/up/property/%s/%s", product_id, device_name);

    if (size < 0 || size > sizeof(report_topic_name) - 1) {
        printf("pub topic content length not enough! content size:%d  buf size:%d", size, (int)sizeof(report_topic_name));
    }
    

    while (1) {
            
        /* 上报值 */
        memset(payload, 0, sizeof(payload));
        snprintf(payload, sizeof(payload), REPORT_DATA_TEMPLATE, data_count++,
					(int)E53_IA1_Data.Humidity,(int)E53_IA1_Data.Lux,E53_IA1_Data.Temperature,
					E53_ST1_Data.Latitude,E53_ST1_Data.Longitude,E53_ST1_Data.Latitude,E53_ST1_Data.Longitude);
 
        
        if (tos_tf_module_mqtt_pub(report_topic_name, QOS0, payload) != 0) {
            printf("module mqtt pub fail\n");
					//HAL_GPIO_WritePin(IA1_Light_GPIO_Port,IA1_Light_Pin,GPIO_PIN_SET);
            break;
        } else {
					HAL_GPIO_TogglePin(LED_B_GPIO_Port,LED_B_Pin);
					Light_Toggle();
          printf("module mqtt pub success\n");
        }

        tos_sleep_ms(500);
    }
		//HAL_GPIO_WritePin(IA1_Light_GPIO_Port,IA1_Light_Pin,GPIO_PIN_RESET);
	}

}

数据采集和报警控制：
    void task1(void *pdata)
   {
     int count = 1;
		 Init_E53_IA1();
		 Init_E53_ST1();
       while(1)
       {
         E53_IA1_Read_Data();
				 E53_ST1_Read_Data();
			   printf("----------------------\r\nHumidity:%0.2f\r\nLux:%0.2f\r\nTemperature:%0.2f\r\n----------------------\r\n",
				 E53_IA1_Data.Humidity,E53_IA1_Data.Lux,E53_IA1_Data.Temperature);
				 printf("+++++++++++++++++++++++\r\nLatitude:%f\r\nLongitude:%f\r\n++++++++++++++++++++++\r\n",
				E53_ST1_Data.Latitude,E53_ST1_Data.Longitude);
                HAL_GPIO_TogglePin(LED_B_GPIO_Port,LED_B_Pin);
				 if(E53_IA1_Data.Temperature>33.0||E53_IA1_Data.Temperature<10.0)
				 {
				   E53_ST1_Beep();
				  tos_sleep_ms(100);
				 }
				else
          tos_sleep_ms(1000);
       }
   }