【RT-Thread作品秀】多功能气压计设计

/**

  * @brief  A thread entry, used to capture temperature[degC] and pressure[hPa].

  *         Call at task_init function in task module.

  * @param  void* RT_NULL.

  * @retval int32_t

  */

int sensor_monitor_entry(void *parameter)

{

    axis1bit32_t data_raw_pressure ={0};

    axis1bit16_t data_raw_temperature ={0};

    uint32_t pressure =0;

    uint16_t temperature =0;

    uint8_t floor =0;

    while (1)

    {

        /* read pressure from lps22hh */

        rt_memset(data_raw_pressure.u8bit, 0x00, sizeof(int32_t));

        lps22hh_pressure_raw_get(&dev_ctx, data_raw_pressure.u8bit);

        pressure =data_raw_pressure.i32bit *1.0 / 4096.0;

        DBG_SENSOR_PRINTF("pressure:%dn", pressure);

        /* write pressure into mailbox, offset: PRESSURE_OFFSET */

        if (ld3320_assert(pressure, temperature) == 1)

        {

            mailbox_write(pressure, PRESSURE_OFFSET);

        }

        rt_thread_mdelay(10);

        /* read temperature from lps22hh */

        rt_memset(data_raw_temperature.u8bit, 0x00, sizeof(int16_t));

        lps22hh_temperature_raw_get(&dev_ctx, data_raw_temperature.u8bit);

        temperature =data_raw_temperature.i16bit *1.0 / 100.0;

        DBG_SENSOR_PRINTF("temperature:%dn", temperature);

        /* write temperature into mailbox, offset: TEMPERATURE_OFFSET */

        if (ld3320_assert(pressure, temperature) == 1)

        {

            mailbox_write(temperature, TEMPERATURE_OFFSET);

        }

        rt_thread_mdelay(10);

        /* calculate floor by location algorithm */

        floor =location_algorithm(pressure, temperature);

        DBG_SENSOR_PRINTF("floor:%dn", floor);

        /* write floor into mailbox, offset: TEMPERATURE_OFFSET */

        if (floor !=255)

        {

            mailbox_write(floor, FLOOR_OFFSET);

        }

        rt_thread_mdelay(500);

    }

    return RT_EOK;

}

/**

  * @brief  IAP move update-firmware from download part to app part.

  *         Call at main.c.

  * @param  None.

  * @retval Not used.

  */

rt_uint8_t iap_move(void)

{

    int ret = 0;

    int file_size = 0, length = 0, total_length = 0;

    const struct fal_partition * dl_part = RT_NULL;

    /* find download part */

    if ((dl_part = fal_partition_find("download")) == RT_NULL)

    {

        rt_kprintf("Firmware download find error!");

        ret = -RT_ERROR;

        goto __exit;

    }

    /* get filesize of firmware */

    fal_partition_read(dl_part, dl_part->len-4, (rt_uint8_t*)&file_size, 4);

    if (file_size ==0xFFFFFFFF)

    {

        ret = -RT_ERROR;

        goto __exit;

    }

    /* erase app partition */

    rt_kprintf("start erase appn");

    W25QXX_ChipErase();

    rt_kprintf("erase app finishedn");

    /*moved download to app */

    rt_kprintf("start moven");

    do

    {

        /*read data from download part */

        length = fal_partition_read(dl_part, total_length, buffer_read,

                file_size - total_length > 4096 ? 4096 : file_size - total_length);

        if (length > 0)

        {

            /* write data into app part */

            W25QXX_Write_NoCheck(buffer_read, total_length, length);

            total_length += length;

            rt_kprintf("process: %dn", total_length);

        }

        else

        {

            rt_kprintf("Exit: server return err (%d)!", length);

            ret = -RT_ERROR;

            goto __exit;

        }

    } while(total_length != file_size);

    rt_kprintf("move finished n");

    /* check data between download and app part */

    total_length = 0;

    do{

        length = fal_partition_read(dl_part, total_length, buffer_read,

                file_size - total_length > 4096 ? 4096 : file_size - total_length);

        if (length > 0)

        {

            W25QXX_Read(buffer_temp, total_length, length);

            if (rt_strncmp(buffer_read, buffer_temp, length) ==0)

            {

                total_length += length;

                rt_kprintf("check: %dn", total_length);

            }

            else

            {

                for(int i = 0; i < length; i++)

                {

                    rt_kprintf("-%x-%x-n", buffer_temp[i], buffer_read[i]);

                }

                rt_kprintf("process: %d check errorn", total_length);

            }

        }

        else

        {

            rt_kprintf("Exit: return err (%d)!", length);

            ret = -RT_ERROR;

            goto __exit;

        }

    } while(total_length != file_size);

    /* clear update flag */

    if (total_length == file_size)

    {

        rt_kprintf("Start erase flash (%s) partition!", dl_part->name);

        if (fal_partition_erase(dl_part, 0, dl_part->len) < 0)

        {

            LOG_E("Firmware download failed! Partition (%s) erase error!", dl_part->name);

            ret = -RT_ERROR;

            goto __exit;

        }

        rt_kprintf("Erase flash (%s) partition success!", dl_part->name);

    }

    rt_kprintf("start jumpn");

__exit:

    return ret;

}

/**

  * @brief  A thread entry, used to upload temperature and pressure.

  *         Call at task_init function in task module.

  * @param  void* RT_NULL.

  * @retval int32_t

  */

int net_terminal_entry(void *parameter)

{

    uint32_t value =0;

    while (1)

    {

        /* get pressure in a mailbox from sensor */

        value =mailbox_read(PRESSURE_OFFSET);

        /* upload pressure to onenet cloud */

        if (onenet_mqtt_upload_digit("pressure", value) < 0)

        {

            DBG_TERMINAL_PRINTF("upload has an error, stop uploadingn");

        }

        else

        {

            DBG_TERMINAL_PRINTF("buffer : {"pressure":%d}n", value);

        }

        /* get temperature in a mailbox from sensor */

        value =mailbox_read(TEMPERATURE_OFFSET);

        /* upload temperature to onenet cloud */

        if (onenet_mqtt_upload_digit("temperature", value) < 0)

        {

            DBG_TERMINAL_PRINTF("upload has an error, stop uploadingn");

        }

        else

        {

            DBG_TERMINAL_PRINTF("buffer : {"temperature":%d}n", value);

        }

        /* get floor in a mailbox from sensor */

        value =mailbox_read(FLOOR_OFFSET);

        /* upload floor to onenet cloud */

        if (onenet_mqtt_upload_digit("floor", value) < 0)

        {

            DBG_TERMINAL_PRINTF("upload has an error, stop uploadingn");

        }

        else

        {

            DBG_TERMINAL_PRINTF("buffer : {"floor":%d}n", value);

        }

        rt_thread_mdelay(5000);

    }

    return RT_EOK;

}

int audio_telling_entry(void *parameter)

{

    uint8_t nAsrRes = 0;

    LD_init();

    while(1)

    {

        switch(nAsrStatus)

        {

            case LD_ASR_RUNING:

            case LD_ASR_ERROR:

                break;

            case LD_ASR_NONE:

                nAsrStatus=LD_ASR_RUNING;

                if (LD_ASR()==0)

                    nAsrStatus = LD_ASR_ERROR;

                break;

            case LD_ASR_FOUNDOK:

                nAsrRes = LD_GetResult();

                switch(nAsrRes)

                {

                case CODE_CALLED:

                    rt_kprintf("CODE_CALLEDn");

                    break;

                case CODE_REBOOT:

                    /* reset cpu */

                    rt_kprintf("CODE_REBOOTn");

                    rt_hw_cpu_reset();

                    break;

                case CODE_UPDATE:

                    /* update app */

                    rt_kprintf("CODE_UPDATEn");

                    extern int http_ota_fw_download(const char* uri);

                    http_ota_fw_download(PKG_HTTP_OTA_URL);

                    rt_kprintf("CODE_UPDATE ENDn");

                    break;

                case CODE_PLAY:

                    rt_kprintf("CODE_PLAYn");

                    break;

                default:

                    break;

                }

                nAsrStatus = LD_ASR_NONE;

                nAsrRes = 0;

                break;

            case LD_ASR_FOUNDZERO:

            default:

                nAsrStatus = LD_ASR_NONE;

                break;

        }

        rt_thread_mdelay(1000);

    }

    return RT_EOK;

}