【真香現(xiàn)場】為老婆 DIY 一款集多功能于一身的環(huán)境檢測儀，守護家人健康全靠它！【內附原理圖+源代碼】

 /***********************************************************
 *   Function:  get_ch2o_sensor_value
 *   Input:     none
 *   Output:    none
 *   Return:    none
 *   Notice:    得到并上傳甲醛的數(shù)據(jù)
 ***********************************************************/
static VOID get_ch2o_sensor_value(VOID)
{
    UINT_T  buff_ret, find_head_index = 0;
    //甲醛數(shù)據(jù)高位，低位
    UCHAR_T ch2o_data_high, ch2o_data_low;
    //校驗和
    UCHAR_T check_sums = 0x00;    
    //串口數(shù)據(jù)緩存區(qū)
    UCHAR_T ch2o_receive_buffer[CH2O_BUFFER_SIZE];
    //指向甲醛數(shù)據(jù)頭部
    UCHAR_T *p_ch2o_value = NULL;

    memset(ch2o_receive_buffer, 0, sizeof(ch2o_receive_buffer));

    //讀取串口數(shù)據(jù)
    bk_uart_recv(CH2O_SENSOR_UART, ch2o_receive_buffer, CH2O_BUFFER_SIZE, 0xFFFF);

    // for (find_head_index = 0; find_head_index<CH2O_BUFFER_SIZE; find_head_index++) {
    //     PR_NOTICE("ch2o_receive_buffer[%d] = %02x", find_head_index, ch2o_receive_buffer[find_head_index]);
    // }

    //尋找 ch2o 傳感器發(fā)送過來的頭部
    for (find_head_index = 0; find_head_index<CH2O_BUFFER_SIZE; find_head_index++) {
        if (ch2o_receive_buffer[find_head_index] == 0xff && \
            ch2o_receive_buffer[find_head_index+1] == 0x17 && \
            ch2o_receive_buffer[find_head_index+2] == 0x04){
            //PR_NOTICE("find head is %d", find_head_index);
            break;
        }
    }

    //本次采集數(shù)據(jù)不完整
    if (find_head_index > 11) { 
        PR_ERR("ch2o get uart data no complete!");
        return;
    }

    //將指針指向 ch2o 數(shù)據(jù)中的頭部
    p_ch2o_value = ch2o_receive_buffer + find_head_index;

    //檢驗和，確認讀取的數(shù)據(jù)的準確性
    check_sums = ch2o_check_sum(p_ch2o_value, 9);
    if (check_sums != *(p_ch2o_value + 8)) {
        PR_ERR("ch2o check_sums error");
        return;
    }
    
    ch2o_data_high = *(p_ch2o_value+4);
    ch2o_data_low = *(p_ch2o_value+5);

    gs_air_box.ch2o_value = ch2o_data_high * 256 + ch2o_data_low;

    //PR_NOTICE("ch2o value is : %d .", gs_air_box.ch2o_value);

    //上傳 ch2o 數(shù)據(jù)到涂鴉云
    updata_dp_single(gs_air_box.dp_ch2o_value, PROP_VALUE, gs_air_box.ch2o_value);

    return;
}

 /***********************************************************
 *   Function:  ch2o_check_sum
 *   Input:     none
 *   Output:    none
 *   Return:    none
 *   Notice:    甲醛數(shù)據(jù)校驗和
 ***********************************************************/
static UCHAR_T ch2o_check_sum(UCHAR_T *data, UCHAR_T len)
{
    UCHAR_T i, tempq = 0;
    data += 1; //指向data[1]

    for(i=0; i<(len-2); i++)
    {
        tempq += *data;
        data++;
    }

    tempq = (~tempq) + 1;

    return (tempq);
}

/* ADC */
#define ADC_DATA_LEN    4
static  tuya_adc_dev_t  tuya_adc;

static VOID adc_init(VOID)
{
    tuya_adc.priv.pData = Malloc(ADC_DATA_LEN * sizeof(USHORT_T)); //這里一直使用tuya_adc,所有后面就沒有釋放該空間
    memset(tuya_adc.priv.pData, 0, ADC_DATA_LEN*sizeof(USHORT_T));
    tuya_adc.priv.data_buff_size = ADC_DATA_LEN; //設置數(shù)據(jù)緩存?zhèn)€數(shù)
}

 /***********************************************************
 *   Function:  get_adc_value
 *   Input:     none
 *   Output:    adc_value : 采集到的 adc 值
 *   Return:    none
 *   Notice:    得到 adc 采集的電壓值
 ***********************************************************/
VOID get_adc_value(OUT USHORT_T* adc_value) 
{
    INT_T ret;

    if (adc_value == NULL) {
        PR_ERR("pm25_adc_value is NULL");
        return;
    }
    memset(tuya_adc.priv.pData, 0, ADC_DATA_LEN*sizeof(USHORT_T));
    ret = tuya_hal_adc_init(&tuya_adc);
    if (ret != OPRT_OK) {
        PR_ERR("ADC init error : %d ", ret);
        return;
    }

    ret = ret = tuya_hal_adc_value_get(ADC_DATA_LEN, adc_value); 
    if (ret != OPRT_OK) {
        PR_ERR("ADC get value error : %d ", ret);
    }

    tuya_hal_adc_finalize(&tuya_adc);
    return;
}

/* 煙霧傳感器 */
#define SMOKE_ALARM_LIM 1.0

/***********************************************************
 *   Function:  get_smoke_sensor_value
 *   Input:     none
 *   Output:    none
 *   Return:    none
 *   Notice:    得到并上傳煙霧的數(shù)據(jù)，A1
 ***********************************************************/
static VOID get_smoke_sensor_value(VOID)
{
    USHORT_T    smoke_adc_value;
    FLOAT_T     smoke_volt; 

    //復用 adc 到 A1 
    tuya_gpio_write(RS2255_A, FALSE);
    tuya_gpio_write(RS2255_B, TRUE);

    tuya_hal_system_sleep(500);

    //得到煙霧傳感器 ad 值
    get_adc_value(&smoke_adc_value);
    //PR_NOTICE("smoke_adc_value : %d ", smoke_adc_value);

    //計算實際電壓值
    smoke_volt = (smoke_adc_value / 4095.0) * 2.4 * 2;
    //PR_NOTICE("smoke_volt : %lf ", smoke_volt);

    //判斷是否到報警門限值
    if (smoke_volt >= SMOKE_ALARM_LIM) {
        gs_air_box.smoke_state = ALARM;
    } else {
        gs_air_box.smoke_state = NORMAL;
    }

    //上傳數(shù)據(jù)
    updata_dp_single(gs_air_box.dp_smoke_state, PROP_ENUM, gs_air_box.smoke_state);

    //PR_NOTICE("get smoke value, updata...");
    return;
}

 /***********************************************************
 *   Function:  get_smoke_sensor_value
 *   Input:     none
 *   Output:    none
 *   Return:    none
 *   Notice:    得到并上傳火焰的數(shù)據(jù)
 ***********************************************************/
static VOID get_flame_sensor_value(VOID)
{
    if (FALSE == tuya_gpio_read(FLAME_SENSOR_PIN)) {
        gs_air_box.flame_state = ALARM;
        /* 檢測到火焰，拉低220V控制引腳，斷電 */
        tuya_gpio_write(POWER_OFF_220V_PIN, FALSE);
    } else {
        gs_air_box.flame_state = NORMAL;
    }

    updata_dp_single(gs_air_box.dp_flame_state, PROP_ENUM, gs_air_box.flame_state);

    return;
}

 /***********************************************************
 *   Function:  air_box_device_init
 *   Input:     none
 *   Output:    none
 *   Return:    none
 *   Notice:    環(huán)境安全衛(wèi)士設備初始化
 ***********************************************************/
VOID air_box_device_init(VOID)
{
    INT_T opRet = OPRT_OK;

    /* 火焰?zhèn)鞲衅飨嚓P外設初始化 */
    tuya_gpio_inout_set(FLAME_SENSOR_PIN, TRUE);
    tuya_gpio_inout_set(POWER_OFF_220V_PIN, FALSE);
    /* 啟動時，拉高220V控制引腳，通電 */
    tuya_gpio_write(POWER_OFF_220V_PIN, TRUE);

    /* ADC 復用，相關引腳初始化 */ 
    tuya_gpio_inout_set(RS2255_A, FALSE);
    tuya_gpio_inout_set(RS2255_B, FALSE);
    adc_init();

    /* 甲醛傳感器使用 uart2 接收數(shù)據(jù)，在函數(shù) app_init() 里面已經修改完成波特率 */
    
    /* pm2.5 傳感器 串口 初始化 */
    ty_uart_init(PM25_SENSOR_UART, TYU_RATE_9600, TYWL_8B, TYP_NONE, TYS_STOPBIT1, (PM25_BUFFER_SIZE * SIZEOF(UCHAR_T)), TRUE);

    /* 創(chuàng)建信號量 */
    opRet = tuya_hal_semaphore_create_init(&preheat_semaphore, 0, 1);
    if (opRet != OPRT_OK) {
        PR_ERR("creat preheat semaphore error : %d", opRet);
    }

    /* 預熱 60s 后釋放信號量，開始采集傳感器數(shù)據(jù) */
    opSocSWTimerStart(preheat_timer, SENSOR_PREHEAT_TIME, preheat_semaphore_post_task); 

    tuya_hal_thread_create(NULL, "acquire sensor data", 512*4, TRD_PRIO_2, acquire_data_task, NULL);
}

VOID preheat_semaphore_post_task(VOID)
{
    //預熱完成，釋放信號量
    tuya_hal_semaphore_post(preheat_semaphore);
    //關閉預熱軟件定時器
    opSocSWTimerStop(preheat_timer);

    //預熱完成，上傳預熱完成數(shù)據(jù)到涂鴉云
    gs_air_box.preheat_state = false;
    updata_dp_single(gs_air_box.dp_preheat, PROP_BOOL, gs_air_box.preheat_state);
}

 /***********************************************************
 *   Function:  acquire_data_task
 *   Input:     none
 *   Output:    none
 *   Return:    none
 *   Notice:    獲取傳感器數(shù)據(jù)任務
 ***********************************************************/
VOID acquire_data_task(VOID)
{
    //等待預熱完成
    tuya_hal_semaphore_wait(preheat_semaphore);

    while (1) {
        get_ch2o_sensor_value();
        get_flame_sensor_value();
        get_gas_sensor_value();
        get_pm25_sensor_value();
        get_smoke_sensor_value();
        tuya_hal_system_sleep(500);
    }
}