【IoT应用创新大赛】基于TencentOS的智能环境监测系统

/*
_init_data_template主要用于初始化传感器数据。
根据上述功能描述，本方案包含5个数据属性：
电机开关motor_power_switch、电灯开关light_power_switch、光强luminance、温度temperature、湿度humidity
*/
static void _init_data_template(void)
{
	  Init_E53_IA1();	//初始化E53_IA1模块	
	  E53_IA1_Read_Data();	//读取传感器数据
	  
    sg_ProductData.m_motor_power_switch = 0;
    sg_DataTemplate[0].data_property.data = &sg_ProductData.m_motor_power_switch;
    sg_DataTemplate[0].data_property.key  = "motor_power_switch";
    sg_DataTemplate[0].data_property.type = TYPE_TEMPLATE_BOOL;
	
    sg_ProductData.m_light_power_switch = 0;
    sg_DataTemplate[1].data_property.data = &sg_ProductData.m_light_power_switch;
    sg_DataTemplate[1].data_property.key  = "light_power_switch";
    sg_DataTemplate[1].data_property.type = TYPE_TEMPLATE_BOOL;

    sg_ProductData.m_luminance = (int)E53_IA1_Data.Lux;
    sg_DataTemplate[2].data_property.data = &sg_ProductData.m_luminance;
    sg_DataTemplate[2].data_property.key  = "luminance";
    sg_DataTemplate[2].data_property.type = TYPE_TEMPLATE_INT;

    sg_ProductData.m_temperature = (int)E53_IA1_Data.Temperature;
    sg_DataTemplate[3].data_property.data = &sg_ProductData.m_temperature;
    sg_DataTemplate[3].data_property.key  = "temperature";
    sg_DataTemplate[3].data_property.type = TYPE_TEMPLATE_INT;
	
    sg_ProductData.m_humidity = (int)E53_IA1_Data.Humidity;
    sg_DataTemplate[4].data_property.data = &sg_ProductData.m_humidity;
    sg_DataTemplate[4].data_property.key  = "humidity";
    sg_DataTemplate[4].data_property.type = TYPE_TEMPLATE_INT;

};

__weak void OLED_Clear(void) //清屏操作
{
    printf("OLED Clear\n");
}

__weak void OLED_ShowString(int x, int y, uint8_t *str, int bold) //显示字符串
{
    printf("OLED ShowString: %s\n", (char *)str);
}

static void motor_power_on(void) //打开电机操作
{
    char *info = "motor on ";
    //OLED_Clear();
    OLED_ShowString(0, 0, (uint8_t *)info, 16); //OLED显示
	HAL_GPIO_WritePin(IA1_Motor_GPIO_Port, IA1_Motor_Pin, GPIO_PIN_SET); //写入引脚，打开电机
}

#ifdef USE_ESP8266
    extern int esp8266_sal_init(hal_uart_port_t uart_port);
    extern int esp8266_join_ap(const char *ssid, const char *pwd);
    esp8266_sal_init(HAL_UART_PORT_0);
    esp8266_join_ap("wifi_name", "password");
#endif

#ifdef DEBUG_DEV_INFO_USED
/* product Id  */
static char sg_product_id[MAX_SIZE_OF_PRODUCT_ID + 1]	 = "PRODUCT_ID";

/* device name */
static char sg_device_name[MAX_SIZE_OF_DEVICE_NAME + 1]  = "DEVICE_NAME";

#ifdef DEV_DYN_REG_ENABLED
/* product secret for device dynamic Registration  */
static char sg_product_secret[MAX_SIZE_OF_PRODUCT_SECRET + 1]  = "YOUR_PRODUCT_SECRET";
#endif

#ifdef AUTH_MODE_CERT
/* public cert file name of certificate device */
static char sg_device_cert_file_name[MAX_SIZE_OF_DEVICE_CERT_FILE_NAME + 1]      = "YOUR_DEVICE_NAME_cert.crt";
/* private key file name of certificate device */
static char sg_device_privatekey_file_name[MAX_SIZE_OF_DEVICE_SECRET_FILE_NAME + 1] = "YOUR_DEVICE_NAME_private.key";
#else
/* device secret of PSK device */
static char sg_device_secret[MAX_SIZE_OF_DEVICE_SECRET + 1] = "DEVICE_SECRET";
#endif

// register data template properties
static int _register_data_template_property(void *pTemplate_client)
{
	int i,rc;

    for (i = 0; i < TOTAL_PROPERTY_COUNT; i++) {
	    rc = IOT_Template_Register_Property(pTemplate_client, &sg_DataTemplate[i].data_property, OnControlMsgCallback);
	    if (rc != QCLOUD_RET_SUCCESS) {
	        rc = IOT_Template_Destroy(pTemplate_client);
	        Log_e("register device data template property failed, err: %d", rc);
	        return rc;
	    } else {
	        Log_i("data template property=%s registered.", sg_DataTemplate[i].data_property.key);
	    }
    }

	return QCLOUD_RET_SUCCESS;
}

//用户下发指令处理逻辑
void deal_down_stream_user_logic(void *client, ProductDataDefine   * pData)
{
	Log_d("someting about your own product logic wait to be done");

    if (sg_ProductData.m_motor_power_switch == 1) {
        motor_power_on();
    } else {
        motor_power_off();
    }
    if (sg_ProductData.m_light_power_switch == 1) {
        light_power_on();
    } else {
        light_power_off();
    }
}

//主处理函数
...{
		...
		/* handle control msg from server */
		if (sg_control_msg_arrived) {

			deal_down_stream_user_logic(client, &sg_ProductData);

			/* control msg should reply, otherwise server treat device didn't receive and retain the msg which would be get by  get status*/
			memset((char *)&replyPara, 0, sizeof(sReplyPara));
			replyPara.code = eDEAL_SUCCESS;
			replyPara.timeout_ms = QCLOUD_IOT_MQTT_COMMAND_TIMEOUT;
			replyPara.status_msg[0] = '\0';			//add extra info to replyPara.status_msg when error occured

			rc = IOT_Template_ControlReply(client, sg_data_report_buffer, sg_data_report_buffersize, &replyPara);
            if (rc == QCLOUD_RET_SUCCESS) {
				Log_d("Contol msg reply success");
				sg_control_msg_arrived = false;
            } else {
                Log_e("Contol msg reply failed, err: %d", rc);
            }
		}	else{
			Log_d("No control msg received...");
		}
		...
}