AIoT应用创新大赛-基于TencentOS Tiny的护眼台灯

void mqttclient_task(void)
{
    int error;
    mqtt_client_t *client = NULL;
    mqtt_message_t msg;
    k_event_flag_t match_flag;
    char  host_ip[20];
    uint16_t lux;
    memset(&msg, 0, sizeof(msg));
    esp8266_sal_init(HAL_UART_PORT_2);
    esp8266_join_ap("*******", "*******");//WiFi SSID, WiFi Password
    bh1750_init();
    mqtt_log_init();
    client = mqtt_lease();  
    tos_event_create(&report_result_event, (k_event_flag_t)0u);    
    /* Domain Format: <your product ID>.iotcloud.tencentdevices.com */
    tos_sal_module_parse_domain("7VIN7U0AXQ.iotcloud.tencentdevices.com",host_ip,sizeof(host_ip));
    
    /*
        These infomation is generated by mqtt_config_gen.py tool in "TencentOS-tiny\tools" directory.
    */
    mqtt_set_port(client, "1883");
    mqtt_set_host(client, host_ip);
    mqtt_set_client_id(client, "7VIN7U0AXQdev001");
    mqtt_set_user_name(client, "7VIN7U0AXQdev001;21010406;12365;4294967295");
    mqtt_set_password(client,  "8d5dfc28d97785d5b0b57fcfd449485c18a0a998;hmacsha1");
    mqtt_set_clean_session(client, 1);

    error = mqtt_connect(client);
    
    MQTT_LOG_D("mqtt connect error is %#0x", error);
    
    error = mqtt_subscribe(client, "$thing/down/property/7VIN7U0AXQ/dev001", QOS0, tos_topic_handler);
    
    MQTT_LOG_D("mqtt subscribe error is %#0x", error);
    
    while (1) {
        bh1750_start(ONCE_H_MODE);
        tos_task_delay(160);
        bh1750_read_lux(&lux);
        printf("bh1750 lux is %d\r\n",lux);
        
        memset(&msg, 0, sizeof(msg));
        snprintf(report_buf, sizeof(report_buf), REPORT_DATA_TEMPLATE,lux);
 		
			/*光亮度数据参考：
			*晚上： 0.001-0.02；
			*月夜： 0.02-0.3；
			*多云室内： 5-50；
			*多云室外： 50-500；
			*晴天室内： 100-1000；
			*阅读书籍时的照明度：50-60；
			*家庭录像标准照明度：1400
			*/
				if(lux <= 50){								
					GPIO_PinWrite(GPIO3, 2, 1);
				}else{
					GPIO_PinWrite(GPIO3, 2, 0);
				}
				
        msg.qos = QOS0;
        msg.payload = (void *) report_buf;
        error = mqtt_publish(client, "$thing/up/property/7VIN7U0AXQ/dev001", &msg);
        MQTT_LOG_D("mqtt publish error is %#0x", error);
        
        tos_event_pend(&report_result_event, 
                       report_success|report_fail,
                       &match_flag,
                       TOS_TIME_FOREVER,
                       TOS_OPT_EVENT_PEND_ANY | TOS_OPT_EVENT_PEND_CLR);
        
        if (match_flag == report_success) {
            printf("report to Tencent IoT Explorer success\r\n");
        
        }else if (match_flag == report_fail){
            printf("report to Tencent IoT Explorer fail\r\n");
        }
        
        tos_task_delay(2000); 
    }
}

void blink_entry(void *arg){
		while(1){
			if(lastbrightness < brightness){
				for(temp = lastbrightness ; temp < brightness ; temp++){
					PWM_UpdatePwmDutycycle(PWM4, kPWM_Module_3, kPWM_PwmA, kPWM_SignedCenterAligned, temp);//更新占空比 
					PWM_SetPwmLdok(PWM4,kPWM_Control_Module_3, true);
					tos_task_delay(5);
				}
			}else if(lastbrightness > brightness){
				for(temp = lastbrightness ; temp > brightness ; temp--){
					PWM_UpdatePwmDutycycle(PWM4, kPWM_Module_3, kPWM_PwmA, kPWM_SignedCenterAligned, temp);//更新占空比 
					PWM_SetPwmLdok(PWM4,kPWM_Control_Module_3, true);
					tos_task_delay(5);
				}
			}
			lastbrightness = brightness;		
		}	 
}

void Distance_judge_entry(void *arg){
	int distance_flag;
	while(1){
		Distance_measurement();//超声波测距
					
		if(distance < 1000){
			distance_flag++;
		}
		
		if(distance_flag >= 10){
			GPIO_PinWrite(GPIO2, 29, 0U);
			delay_us(500000);
			distance_flag = 0;
		}
		else if(distance_flag < 10){
			GPIO_PinWrite(GPIO2, 29, 1U);
		}			
		PRINTF("%d\n",distance);					
	}
}