if (COV_Subscriptions[index].flag.valid) {
            dest = cov_address_get(COV_Subscriptions[index].dest_index);
            if (dest) {
                address_match = bacnet_address_same(src, dest);
            } else {
                /* skip address matching - we don't have an address */
                address_match = true;
            }
            if ((COV_Subscriptions[index].monitoredObjectIdentifier.type ==
                    cov_data->monitoredObjectIdentifier.type) &&
                (COV_Subscriptions[index].monitoredObjectIdentifier.instance ==
                    cov_data->monitoredObjectIdentifier.instance) &&
                (COV_Subscriptions[index].subscriberProcessIdentifier ==
                    cov_data->subscriberProcessIdentifier) &&
                address_match) {
                existing_entry = true;

typedef struct BACnet_Subscribe_COV_Data {
    uint32_t subscriberProcessIdentifier;
    BACNET_OBJECT_ID monitoredObjectIdentifier;
    bool cancellationRequest;   /* true if this is a cancellation request */
    bool issueConfirmedNotifications;   /* optional */
    uint32_t lifetime;  /* seconds, optional */
    bool covSubscribeToProperty;  /* true to use per-property subscription */
    BACNET_PROPERTY_REFERENCE monitoredProperty;
    bool covIncrementPresent;   /* true if present */
    float covIncrement; /* optional */
    BACNET_ERROR_CLASS error_class;
    BACNET_ERROR_CODE error_code;
    struct BACnet_Subscribe_COV_Data *next;
} BACNET_SUBSCRIBE_COV_DATA;

CCOV: Received Notification!
CCOV: PID=331 instance=331 WY_OBJECT_HBD_LAMP 0 time remaining=905048 seconds 
CCOV: proprietary 513  current value 0 
CCOV: Sending Simple Ack!
CCOV: Received Notification!
CCOV: PID=331 instance=331 WY_OBJECT_HBD_LAMP 0 time remaining=731141 seconds 
CCOV: proprietary 513  current value 1 
CCOV: Sending Simple Ack!

/** Handler to check the list of subscribed objects for any that have changed
 *  and so need to have notifications sent.
 * @ingroup DSCOV
 * This handler will be invoked by the main program every second or so.
 * This example only handles Binary Inputs, but can be easily extended to
 * support other types.
 * For each subscribed object,
 *  - See if the subscription has timed out
 *    - Remove it if it has timed out.
 *  - See if the subscribed object instance has changed
 *    (eg, check with Binary_Input_Change_Of_Value() )
 *  - If changed,
 *    - Clear the COV (eg, Binary_Input_Change_Of_Value_Clear() )
 *    - Send the notice with cov_send_request()
 *      - Will be confirmed or unconfirmed, as per the subscription.
 *
 * @note worst case tasking: MS/TP with the ability to send only
 *        one notification per task cycle.
 *
 * @param elapsed_seconds [in] How many seconds have elapsed since last called.
 */
void handler_cov_timer_seconds(uint32_t elapsed_seconds)

void my_task()
{
    while(1)
    {
        handler_cov_timer_seconds(1);
        wy_is_people = wy_get_is_people();
        HBD_LAMP_Is_People_Set(0, wy_is_people);
        vTaskDelay(10 / portTICK_PERIOD_MS);
        // or  vTaskDelay(1000 / portTICK_PERIOD_MS);  ?
    }
}

/**
 * @brief FreeRTOS main loop recurring task
 */
static void BACnet_Task(void *pvParameters)
{
    const portTickType xBlockTime =
        BACNET_TASK_MILLISECONDS / portTICK_RATE_MS;

    for (;;) {
        /* block to wait for a notification from either MS/TP task */
        xSemaphoreTake(BACnet_PDU_Available, xBlockTime);
        bacnet_task();
        BACnet_Task_High_Water_Mark = uxTaskGetStackHighWaterMark(NULL);
    }
    /* Should never go there */
    vTaskDelete(NULL);
}

void bacnet_task(void)
{
    ...
    if (mstimer_expired(&COV_Timer)) {
        mstimer_reset(&COV_Timer);
        handler_cov_timer_seconds(mstimer_interval(&COV_Timer)/1000);
    }
    handler_cov_fsm();
    ...
}

void wy_updata_cov(void)
{
    AIR_INFO m_air_info_data = {0};
    struct mstimer COV_Timer;
    mstimer_set(&COV_Timer, 1 * 1000);
    while(1)
    {
    if (mstimer_expired(&COV_Timer)) {
        mstimer_reset(&COV_Timer);
        handler_cov_timer_seconds(mstimer_interval(&COV_Timer)/1000);
    }
        m_air_info_data = wy_get_air_info();
        AIR_Info_Set(0, m_air_info_data);
        handler_cov_task();
        vTaskDelay(10 / portTICK_PERIOD_MS);
    }
}