yc_client/main/yc_protocol.c

#include "yc_protocol.h"
#include "esp_log.h"
#include "freertos/FreeRTOS.h"
#include "freertos/task.h"
#include "freertos/queue.h"
#include "esp_mac.h"
#include "stdbool.h"
#include "esp_timer.h"
#include "list.h"
#include "user_time.h"
#include "freertos/event_groups.h"
#include "list.h"
#include "wait_list.h"

#include <stdio.h>
#include <stdlib.h>
#include <time.h>

#include "driver/uart.h"
#include "freertos/timers.h"
#include "SPIFFS.h"
// #include "user_config.h"

Screen_dis_t screen_dis_info;
// 声明一个TimerHandle_t类型的变量，用于存储定时器句柄

extern EventGroupHandle_t screen_event;

extern int retry_times;

static const char *LOG_TAG = "yc_protocol";
// esp_timer_handle_t periodic_timer;
esp_timer_handle_t lora_timer;
TERMINAL_INFO_T terminal_info; //  保存收到的lora数据

Button_Time_t last_button_info;
Button_Time_t new_button_info;

Button_Time_t _0703_button_info;

void changebintotxt(uint8_t *strb, int len);
Node *clockIn_list = NULL; // 打卡  n:crc(ID)   cmd:打卡类型  data:ID

extern char str_operation[6];     // 运行
extern char str_upKeep[6];        // 保养
extern char str_shutDown[6];      // 停机
extern char str_safeKeep[6];      // 封存
extern char str_waitMaterials[6]; // 待料
extern char str_breakDown[6];     // 故障

extern QueueHandle_t screen_queue;
uint8_t mac_addr[6];

extern QueueHandle_t yc_data_queue;
extern YC_DATA_T yc_data;

// extern ListNode *list_head;
#define LEFT_FLAG 1
#define RIGHT_FLAG 2
static uint8_t display_flag = 0; // 1:left  2:right
#if 1
#include "esp_attr.h"

RTC_FAST_ATTR Person_t person[5] =
    {
        {
            .person_type = Administrator,
        },
        {
            .person_type = product_person,
        },
        {
            .person_type = repair_person,
        },
        {
            .person_type = Maintenance_person,
        },
        {
            .person_type = check_person,
        },

};

#endif

void reset_default(bool is_dis, uint8_t power_status)
{

    extern Machine_info_t default_info;
    Machine_info_t tmp;
    memcpy(&tmp, &default_info, sizeof(Machine_info_t));
    tmp.power_status = power_status;
    esp_read_mac((uint8_t *)tmp.mac_addr, ESP_MAC_WIFI_STA);
    memcpy(&tmp.cid, &Machine_info.cid, 20);
    tmp.batt_precent = Machine_info.batt_precent;
    tmp.last_batt_precent = Machine_info.last_batt_precent;
    tmp.rssi = Machine_info.rssi;
    memcpy(&Machine_info, &tmp, sizeof(Machine_info_t)); // 恢复默认
    spiffs_write(&Machine_info);                         // 保存Machine_info
    if (!is_dis)
    {
        return;
    }
    // Paint_leftScreen_main_quick(&Machine_info);
    // Paint_rightScreen_main_quick(&Machine_info);

    screen_dis_info.is_left = true;
    screen_dis_info.is_into_sleep = false;
    // 重置快刷
    Machine_info.left_current_Quick_refresh_time = 0;
    Machine_info.right_current_Quick_refresh_time = 0;
    if (xQueueSend(screen_queue, &screen_dis_info, portMAX_DELAY) != true)
    {
        ESP_LOGE(LOG_TAG, "err:screen queue send fail");
    }
    screen_dis_info.is_left = false;
    screen_dis_info.is_into_sleep = false;
    if (xQueueSend(screen_queue, &screen_dis_info, portMAX_DELAY) != true)
    {
        ESP_LOGE(LOG_TAG, "err:screen queue send fail");
    }
}

/*
 *    使用 vTaskList() 前需使能:
 *    Enable FreeRTOS trace facility
 *    Enable FreeRTOS stats formatting functions
 */
void print_systenInfo(void)
{
    printf("=================================\r\n");
    printf("=======%s======\r\n", "2024.1.4 [11时] burn"); // 打印烧录时间
    printf("=============%s===========\r\n", __TIME__);
    printf("=================================\r\n");
    printf("========version V %d.%d.%d==========\r\n", VERSION_X, VERSION_Y, VERSION_Z);
    esp_efuse_mac_get_default((uint8_t *)mac_addr);
    esp_efuse_mac_get_default((uint8_t *)Machine_info.mac_addr);

#if 1 // 获取mac地址
    uint8_t macAddr[6];
    esp_read_mac((uint8_t *)macAddr, ESP_MAC_WIFI_STA);

    // 保留以前的mac地址段
    // mac_addr[0]+=0x02;
    {
        printf("mac addr : %02x:%02x:%02x:%02x:%02x:%02x\n", macAddr[0], macAddr[1], macAddr[2], macAddr[3], macAddr[4], macAddr[5]);
    }

    memcpy((uint8_t *)Machine_info.mac_addr, macAddr, 6);

    // Machine_info.mac_addr[0]= Machine_info.mac_addr[0]+0x02;

    printf("Machine_info mac addr : %02x:%02x:%02x:%02x:%02x:%02x\n", Machine_info.mac_addr[0], Machine_info.mac_addr[1], Machine_info.mac_addr[2], Machine_info.mac_addr[3], Machine_info.mac_addr[4], Machine_info.mac_addr[5]);

#endif

    printf("free_heap_size:%ld \r\n free_internal_heap_size:%ld \r\n minimum_free_heap_size:%ld\r\n",
           esp_get_free_heap_size(), esp_get_free_internal_heap_size(), esp_get_minimum_free_heap_size());
#if 0
    ESP_LOGW(LOG_TAG,"mac:[%02x-%02x-%02x-%02x-%02x-%02x]",\
                mac_addr[0],mac_addr[1],mac_addr[2],mac_addr[3],mac_addr[4],mac_addr[05]);
    static char InfoBuffer[512] = {0};
    vTaskList((char*)&InfoBuffer);

    ESP_LOGW(LOG_TAG,"free_heap_size:%ld \nfree_internal_heap_size:%ld \nminimum_free_heap_size:%ld",\
    esp_get_free_heap_size(),esp_get_free_internal_heap_size(),esp_get_minimum_free_heap_size());

    printf("任务名      任务状态    优先级    剩余栈   任务序号\r\n");
    printf("\r\n%s\r\n", InfoBuffer);
#endif
}
void send_update_status(void);
void send_status_duration(void);

void terminal_send_data(void)
{
    // send_rssi();
    // vTaskDelay(100 / portTICK_PERIOD_MS);
    send_status_duration();
    // vTaskDelay(50 / portTICK_PERIOD_MS);
    send_update_status();
    // vTaskDelay(100 / portTICK_PERIOD_MS);
}
void update_last_button_info(uint8_t btn)
{
#if 0
    memset(&last_button_info,0,sizeof(Button_Time_t));
    last_button_info.button_info = btn;
    
    last_button_info.Year = Machine_info.year;
    last_button_info.Month = Machine_info.month;
    last_button_info.Day = Machine_info.day;
    last_button_info.Hour = Machine_info.hour;
    last_button_info.Minute = Machine_info.min;
    last_button_info.Second = Machine_info.sec;
    ESP_LOGW(LOG_TAG,"btn = %d [%d-%d-%d]%d:%d:%d", btn, Machine_info.year,Machine_info.month,Machine_info.day,\
    Machine_info.hour, Machine_info.min,Machine_info.sec);
    //last_button_info.time_min = 0;
#else
    // 更新上次的状态
    // 获取当前时间
    getRtcTime(&Machine_info);

    Machine_info.last_button.button_info = btn;
    Machine_info.last_button.Year = Machine_info.year;
    Machine_info.last_button.Month = Machine_info.month;
    Machine_info.last_button.Day = Machine_info.day;
    Machine_info.last_button.Hour = Machine_info.hour;
    Machine_info.last_button.Minute = Machine_info.min;
    Machine_info.last_button.Second = Machine_info.sec;
    Machine_info.last_button.time_min = 0x00000000;

#endif
}
void screen_display(void)
{

    font_exit_sleep();

    EventBits_t bits = xEventGroupWaitBits(screen_event,
                                           LEFT_SCREEN_BIT | RIGHT_SCREEN_BIT,
                                           pdTRUE,
                                           pdFALSE,
                                           0);
    ESP_LOGW(LOG_TAG, "xEventGroupWaitBits bits = %ld", bits);
    /* xEventGroupWaitBits() returns the bits before the call returned, hence we can test which event actually
     * happened. */
    if (bits == 3)
    {

        screen_dis_info.is_left = true;
        screen_dis_info.is_into_sleep = false;
        if (xQueueSend(screen_queue, &screen_dis_info, portMAX_DELAY) != true)
        {
            ESP_LOGE(LOG_TAG, "err:screen queue send fail");
        }
        screen_dis_info.is_left = false;
        screen_dis_info.is_into_sleep = true;
        if (xQueueSend(screen_queue, &screen_dis_info, portMAX_DELAY) != true)
        {
            ESP_LOGE(LOG_TAG, "err:screen queue send fail");
        }
    }
    else if (bits & RIGHT_SCREEN_BIT)
    {
        ESP_LOGE(LOG_TAG, "RIGHT_SCREEN_BIT");
        screen_dis_info.is_left = false;
        screen_dis_info.is_into_sleep = true;
        if (xQueueSend(screen_queue, &screen_dis_info, portMAX_DELAY) != true)
        {
            ESP_LOGE(LOG_TAG, "err:screen queue send fail");
        }
    }
    else if (bits & LEFT_SCREEN_BIT)
    {
        ESP_LOGE(LOG_TAG, "LEFT_SCREEN_BIT");
        screen_dis_info.is_left = true;
        screen_dis_info.is_into_sleep = true;
        if (xQueueSend(screen_queue, &screen_dis_info, portMAX_DELAY) != true)
        {
            ESP_LOGE(LOG_TAG, "err:screen queue send fail");
        }
    }
    else
    {
        ESP_LOGI(LOG_TAG, "UNEXPECTED EVENT");
    }
}

void print_yc_data(const LORA_DATA_T *buf)
{

    int len = (buf->data_buf[13 + 2]) << 8 | (buf->data_buf[14 + 2]);
    ESP_LOGI(LOG_TAG, "\n总长:0x%02x,crc:0x%02x,\
    \nmac:[%02x-%02x-%02x-%02x-%02x-%02x], \
    \n组内编号:%02x,\
    cmd:0x%02x,\
    总包数:%02x, 当前包:%02x,\
    \n有效数据 len:0x%d",
             buf->data_len, buf->data_buf[4],
             buf->data_buf[5], buf->data_buf[6], buf->data_buf[7],
             buf->data_buf[8], buf->data_buf[9], buf->data_buf[10],
             buf->data_buf[11],
             buf->data_buf[12],
             buf->data_buf[13], buf->data_buf[14],
             len);

    for (int i = 0; i < buf->data_len; i++)
    {
        printf("%02x ", buf->data_buf[i]);
        if (i == (USE_DATA_LEN_INDEX + 1))
        {
            printf("data--->\n");
        }
    }
    printf("\n");
}
bool filtered_data(const LORA_DATA_T *buf)
{
    if (buf->data_buf[11] != Machine_info.eflagID)
    {
        if (Machine_info.eflagID == 0)
        {
            ESP_LOGE(LOG_TAG, "err:未分配ID");
        }

        ESP_LOGE(LOG_TAG, "err:eflagID:%02x ,is not %02x",
                 Machine_info.eflagID, buf->data_buf[11]);

        return false;
    }

    if ((buf->data_buf[5] != Machine_info.mac_addr[0]) ||
        (buf->data_buf[6] != Machine_info.mac_addr[1]) ||
        (buf->data_buf[7] != Machine_info.mac_addr[2]) ||
        (buf->data_buf[8] != Machine_info.mac_addr[3]) ||
        (buf->data_buf[9] != Machine_info.mac_addr[4]) ||
        (buf->data_buf[10] != Machine_info.mac_addr[5]))
    {
        ESP_LOGE(LOG_TAG, "err:mac addr:[%02x-%02x-%02x-%02x-%02x-%02x],\
                                    is not:[%02x-%02x-%02x-%02x-%02x-%02x]",
                 Machine_info.mac_addr[0], Machine_info.mac_addr[1], Machine_info.mac_addr[2],
                 Machine_info.mac_addr[3], Machine_info.mac_addr[4], Machine_info.mac_addr[5],
                 buf->data_buf[5], buf->data_buf[6], buf->data_buf[7],
                 buf->data_buf[8], buf->data_buf[9], buf->data_buf[10]);
        return false;
    }

    return true;
}
static int time_synchronization_func(const LORA_DATA_T *buf)
{
    int len = (buf->data_buf[USE_DATA_LEN_INDEX]) << 8 | (buf->data_buf[USE_DATA_LEN_INDEX + 1]);
    memcpy(terminal_info.time_synchronization, buf->data_buf + DATA_START_LEN, len);

    // yc_timer_restart();

    // Machine_info
    Machine_info.year = (terminal_info.time_synchronization[0] << 8) | terminal_info.time_synchronization[1];
    Machine_info.month = terminal_info.time_synchronization[2];
    Machine_info.day = terminal_info.time_synchronization[3];
    Machine_info.hour = terminal_info.time_synchronization[4];
    Machine_info.min = terminal_info.time_synchronization[5];
    Machine_info.sec = terminal_info.time_synchronization[6];
    display_flag = 0;

    setRtcTime(Machine_info.year, Machine_info.month, Machine_info.day,
               Machine_info.hour, Machine_info.min, Machine_info.sec);

    printf("TIMER SYNC YEAR = %d,MONTH =%d,DAY=%d,HOUR=%d,MIN=%d,SEC =%d\r\n",
           Machine_info.year,
           Machine_info.month,
           Machine_info.day,
           Machine_info.hour,
           Machine_info.min,
           Machine_info.sec);

    getRtcTime(&Machine_info);

    xEventGroupSetBits(screen_event, RIGHT_SCREEN_BIT);
    // printf("msg h = %02X,msg l = %02X\r\n",buf->data_buf[13],buf->data_buf[14]);
    int msg_id = (buf->data_buf[13] >> 8) | buf->data_buf[14]; // 获取当前消息id 用于删除
    // printf("msg_id =%X\r\n",msg_id);

    return msg_id;
}
static int terminal_name_func(const LORA_DATA_T *buf)
{
#define FONT_MAX_LEN 8
    uint8_t font_num = 0; // 获取当前的文字个数

    int i = 0;

    int len = (buf->data_buf[USE_DATA_LEN_INDEX]) << 8 | (buf->data_buf[USE_DATA_LEN_INDEX + 1]);
    memset(terminal_info.terminal_name, 0, 32);
    memcpy(terminal_info.terminal_name, buf->data_buf + DATA_START_LEN, len);

    // memcpy(&Machine_info.terminal_name,&terminal_info.terminal_name,len);
    memset(Machine_info.terminal_name, 0x00, sizeof(Machine_info.terminal_name)); // 清除终端名称信息

    font_num = len / 2;
    if (font_num <= FONT_MAX_LEN)
    {
        uincode2gbk((char *)terminal_info.terminal_name, len, (char *)Machine_info.terminal_name);
    }
    else
    {
        uincode2gbk((char *)terminal_info.terminal_name, FONT_MAX_LEN * 2, (char *)Machine_info.terminal_name);
        strcat((char *)Machine_info.terminal_name, "...");
    }

    // printf("unicode:");
    // for(i=0;i<len;i++)
    // {
    //     printf("%02x ",terminal_info.terminal_name[i]);
    // }
    // printf("\n");
    // printf("gbk:");
    // for(i=0;i<len;i++)
    // {
    //     printf("%02x ",Machine_info.terminal_name[i]);
    // }

    // printf("setting name %s",Machine_info.terminal_name);
    // printf("\n");

    // display_flag = RIGHT_FLAG;
    xEventGroupSetBits(screen_event, RIGHT_SCREEN_BIT);

    // printf("msg h = %02X,msg l = %02X\r\n",buf->data_buf[13],buf->data_buf[14]);
    int msg_id = (buf->data_buf[13] >> 8) | buf->data_buf[14]; // 获取当前消息id 用于删除
    // printf("msg_id =%X\r\n",msg_id);

    return msg_id;
}

static int terminal_number_func(const LORA_DATA_T *buf)
{
    int len = (buf->data_buf[USE_DATA_LEN_INDEX]) << 8 | (buf->data_buf[USE_DATA_LEN_INDEX + 1]);
    memcpy(terminal_info.terminal_number, buf->data_buf + DATA_START_LEN, len);
    // memcpy(&Machine_info.terminal_number,&terminal_info.terminal_number,len);
    memset(Machine_info.terminal_number, 0x00, sizeof(Machine_info.terminal_number)); // 清除终端名称信息

    uincode2gbk((char *)terminal_info.terminal_number, len, (char *)Machine_info.terminal_number);

    // printf("unicode:");
    // for(int i=0;i<len;i++)
    // {
    //     printf("%02x ",terminal_info.terminal_number[i]);
    // }
    // printf("\n");
    // printf("gbk:");
    // for(int i=0;i<len;i++)
    // {
    //     printf("%02x ",Machine_info.terminal_number[i]);
    // }

    printf("setting num %s", Machine_info.terminal_number);
    printf("\n");

    // display_flag = RIGHT_FLAG;
    xEventGroupSetBits(screen_event, RIGHT_SCREEN_BIT);

    // printf("msg h = %02X,msg l = %02X\r\n",buf->data_buf[13],buf->data_buf[14]);
    int msg_id = (buf->data_buf[13] >> 8) | buf->data_buf[14]; // 获取当前消息id 用于删除
    // printf("msg_id =%X\r\n",msg_id);

    return msg_id;
}
static int electric_quantity_func(const LORA_DATA_T *buf)
{
    terminal_info.batt_percent = buf->data_buf[DATA_START_LEN];

    ESP_LOGI(LOG_TAG, "batt_percent : %d", terminal_info.batt_percent);
    // display_flag = RIGHT_FLAG;
    xEventGroupSetBits(screen_event, RIGHT_SCREEN_BIT);
    // printf("msg h = %02X,msg l = %02X\r\n",buf->data_buf[13],buf->data_buf[14]);
    int msg_id = (buf->data_buf[13] >> 8) | buf->data_buf[14]; // 获取当前消息id 用于删除
    // printf("msg_id =%X\r\n",msg_id);
    return msg_id;
}
static int signal_strength_func(const LORA_DATA_T *buf)
{
    // terminal_info.rssi = buf->data_buf[DATA_START_LEN];
    // ESP_LOGI(LOG_TAG,"rssi : %d",terminal_info.rssi);

    // Machine_info.rssi = terminal_info.rssi;

    // display_flag = RIGHT_FLAG;

    // printf("msg h = %02X,msg l = %02X\r\n",buf->data_buf[13],buf->data_buf[14]);
    int msg_id = (buf->data_buf[13] >> 8) | buf->data_buf[14]; // 获取当前消息id 用于删除
    // printf("msg_id =%X\r\n",msg_id);

    return msg_id;
}

static int screen_refresh_cycle_func(const LORA_DATA_T *buf)
{
    terminal_info.refresh_cycle = buf->data_buf[DATA_START_LEN];
    ESP_LOGI(LOG_TAG, "refresh_cycle : %d", terminal_info.refresh_cycle);
    Machine_info.refresh_cycle = terminal_info.refresh_cycle;
    // display_flag = RIGHT_FLAG;
    xEventGroupSetBits(screen_event, RIGHT_SCREEN_BIT);

    // printf("msg h = %02X,msg l = %02X\r\n",buf->data_buf[13],buf->data_buf[14]);
    int msg_id = (buf->data_buf[13] >> 8) | buf->data_buf[14]; // 获取当前消息id 用于删除
    // printf("msg_id =%X\r\n",msg_id);

    return msg_id;
}

static int screen_left_func(const LORA_DATA_T *buf)
{
    terminal_info.left_epd = buf->data_buf[DATA_START_LEN];
    ESP_LOGI(LOG_TAG, "left_epd : %d", terminal_info.left_epd);
    Machine_info.left_display_mode = terminal_info.left_epd;

    // display_flag = LEFT_FLAG;
    xEventGroupSetBits(screen_event, LEFT_SCREEN_BIT);

    // printf("msg h = %02X,msg l = %02X\r\n",buf->data_buf[13],buf->data_buf[14]);
    int msg_id = (buf->data_buf[13] >> 8) | buf->data_buf[14]; // 获取当前消息id 用于删除
    // printf("msg_id =%X\r\n",msg_id);
    return msg_id;
}
static int screen_right_func(const LORA_DATA_T *buf)
{
    terminal_info.right_epd = buf->data_buf[DATA_START_LEN];
    Machine_info.right_display_mode = terminal_info.right_epd;
    ESP_LOGW(LOG_TAG, "-----right_epd : %d", terminal_info.right_epd);

    // display_flag = RIGHT_FLAG;
    xEventGroupSetBits(screen_event, RIGHT_SCREEN_BIT);

    // printf("msg h = %02X,msg l = %02X\r\n",buf->data_buf[13],buf->data_buf[14]);
    int msg_id = (buf->data_buf[13] >> 8) | buf->data_buf[14]; // 获取当前消息id 用于删除
    // printf("msg_id =%X\r\n",msg_id);

    return msg_id;
}
static int rsponsible_person_change_func(const LORA_DATA_T *buf)
{
    int len = ((buf->data_buf[USE_DATA_LEN_INDEX]) << 8) | ((buf->data_buf[USE_DATA_LEN_INDEX + 1]));

    //    for(int i = 0;i<buf->data_len;i++)
    //    {
    //         printf("%02X",buf->data_buf[i]);
    //    }

    int msg_id = (buf->data_buf[13] >> 8) | buf->data_buf[14]; // 获取当前消息id 用于删除

    ESP_LOGW(LOG_TAG, "tmp name len = %d", len);

    memcpy(terminal_info.rsponsible_person_change, buf->data_buf + DATA_START_LEN, len);
    // ESP_LOGI(LOG_TAG,"mode:[%02x] len = %d",terminal_info.rsponsible_person_change[2],len);
    uint16_t tmp_number;
    uint8_t tmp_type;

    if (len == 3)
    {
        return msg_id;
    }
    else
    {

        char *tmp_name;
        tmp_name = (char *)malloc((len - 3 + 1));

        memset(tmp_name, 0x00, (len - 3 + 1));

        uincode2gbk((char *)terminal_info.rsponsible_person_change + 3, (len - 3), tmp_name);

        // printf("tmp_name = %s\r\n",tmp_name);
        tmp_name[len - 2] = '\0';
        // memcpy(tmp_name,(char*)terminal_info.rsponsible_person_change+3,len-3);

#if 0
                for(int i=0;i<strlen(tmp_name);i++)
                {
                    printf("%02x ",tmp_name[i]);
                }
                printf("\n%d\n",strlen(tmp_name));
#endif
        tmp_number = (terminal_info.rsponsible_person_change[0] << 8) | (terminal_info.rsponsible_person_change[1] & 0xFF);
        tmp_type = terminal_info.rsponsible_person_change[2];

#if 0
                ListNode *p = newListNode(tmp_number,tmp_type,tmp_name);
                insertNode_head(list_head,p);
#else

        memset(Machine_info.person[tmp_type].string_name, 0x00, sizeof(Machine_info.person[tmp_type].string_name));
        person_add(tmp_type, tmp_number, tmp_name, Machine_info.person[tmp_type].string_name);
        ESP_LOGE(LOG_TAG, "add name = %s\r\n", Machine_info.person[tmp_type].string_name);
#endif

        // display_flag = RIGHT_FLAG;
        xEventGroupSetBits(screen_event, RIGHT_SCREEN_BIT);

        // printf("msg h = %02X,msg l = %02X\r\n",buf->data_buf[13],buf->data_buf[14]);

        // printf("msg_id =%X\r\n",msg_id);
        free(tmp_name);
        tmp_name = NULL;
    }

    return msg_id;
}

static int rsponsible_person_delete_func(const LORA_DATA_T *buf)
{
    uint16_t tmp_number;
    uint8_t tmp_type;

    int len = (buf->data_buf[USE_DATA_LEN_INDEX]) << 8 | (buf->data_buf[USE_DATA_LEN_INDEX + 1]);

    memcpy(terminal_info.rsponsible_person_delete, buf->data_buf + DATA_START_LEN, len);

    tmp_number = (terminal_info.rsponsible_person_delete[0] << 8) | (terminal_info.rsponsible_person_delete[1] & 0xFF);
    tmp_type = terminal_info.rsponsible_person_delete[2];

#if 1
    int num = person_get_num(tmp_type); // 获取当前类型人员数量

    int is_exist = person_get_num_is_exist(tmp_type, tmp_number);

    if (is_exist)
    {
        memset(Machine_info.person[tmp_type].string_name, 0x00, sizeof(Machine_info.person[tmp_type].string_name));
        person_del(tmp_type, tmp_number, NULL, Machine_info.person[tmp_type].string_name);
    }

#endif

    // display_flag = RIGHT_FLAG;
    xEventGroupSetBits(screen_event, RIGHT_SCREEN_BIT);
    xEventGroupSetBits(screen_event, LEFT_SCREEN_BIT);
    // printf("msg h = %02X,msg l = %02X\r\n",buf->data_buf[13],buf->data_buf[14]);
    int msg_id = (buf->data_buf[13] >> 8) | buf->data_buf[14]; // 获取当前消息id 用于删除
    // printf("msg_id =%X\r\n",msg_id);

    return msg_id;
}
// #define SET_BIT(flag,_bit) 			(flag |= (0x01 << _bit))
// #define CLE_BIT(flag,_bit) 			(flag &= ~(0x01 << _bit))
static int production_punch_func(const LORA_DATA_T *buf)
{
    int len = (buf->data_buf[USE_DATA_LEN_INDEX]) << 8 | (buf->data_buf[USE_DATA_LEN_INDEX + 1]);
    memcpy(terminal_info.production_punch, buf->data_buf + DATA_START_LEN, len);
    ESP_LOG_BUFFER_HEX(LOG_TAG, terminal_info.production_punch, len);
    if (terminal_info.production_punch[1] == 0)
    {
        Machine_info.checkIn_set[terminal_info.production_punch[0]].checkIn_close = true; // 关闭该类型打卡
    }
    else
    {
        Machine_info.checkIn_set[terminal_info.production_punch[0]].checkIn_close = false; // 开启该类型打卡
    }

    ESP_LOGW(LOG_TAG, "打卡设置： 类型[%d]  %s", terminal_info.production_punch[0], terminal_info.production_punch[1] ? "开启" : "关闭");

    if (len > 2) // 数据长度大于2 ，说明设置了别名
    {
        memset(Machine_info.checkIn_set[terminal_info.production_punch[0]].other_name, 0, 10);
        // memcpy(Machine_info.checkIn_set[terminal_info.production_punch[0]].other_name,terminal_info.production_punch+2,len-2);
        uincode2gbk((char *)terminal_info.production_punch + 2, len - 2, (char *)Machine_info.checkIn_set[terminal_info.production_punch[0]].other_name);
    }
    // display_flag = RIGHT_FLAG;
    xEventGroupSetBits(screen_event, RIGHT_SCREEN_BIT);
    xEventGroupSetBits(screen_event, LEFT_SCREEN_BIT);
    int msg_id = (buf->data_buf[13] >> 8) | buf->data_buf[14]; // 获取当前消息id 用于删除

    return msg_id;
}
static int personnel_check_in_func(const LORA_DATA_T *buf)
{
    // ESP_LOGI(LOG_TAG,"check in : %s,person type : 0x%02x",buf->data_buf[DATA_START_LEN+1] ? "OUT":"IN",buf->data_buf[DATA_START_LEN]);
    int len = (buf->data_buf[USE_DATA_LEN_INDEX]) << 8 | (buf->data_buf[USE_DATA_LEN_INDEX + 1]);
    memcpy(terminal_info.personnel_check_in, buf->data_buf + DATA_START_LEN, len);

    // printf("msg h = %02X,msg l = %02X\r\n",buf->data_buf[13],buf->data_buf[14]);
    int msg_id = (buf->data_buf[13] >> 8) | buf->data_buf[14]; // 获取当前消息id 用于删除
    // printf("msg_id =%X\r\n",msg_id);

    // display_flag = RIGHT_FLAG;
    xEventGroupSetBits(screen_event, RIGHT_SCREEN_BIT);
    xEventGroupSetBits(screen_event, LEFT_SCREEN_BIT);
    ESP_LOG_BUFFER_HEX(LOG_TAG, terminal_info.personnel_check_in, len);
    int ID_crc = crc8(&terminal_info.personnel_check_in[2], len - 2, 0x5a, 0x51); // lora_crc8( , ,0x5a,0x51);暂定对人员id求crc
    ESP_LOGW(LOG_TAG, "打卡类型[%d] %s ,ID_crc = %d", terminal_info.personnel_check_in[0], Machine_info.checkIn_set[terminal_info.personnel_check_in[0]].checkIn_close ? "关闭" : "开启", ID_crc);
    if (!(Machine_info.checkIn_set[terminal_info.personnel_check_in[0]].checkIn_close)) // 开启打卡
    {
        if (terminal_info.personnel_check_in[1] == 0x00) // 打卡签入
        {
            // Machine_info.personnel_check_in[terminal_info.personnel_check_in[0]]++;
            // Node *find  = findNode(Send_list,msg_id);
            Machine_info.checkIn_set[terminal_info.personnel_check_in[0]].number++;
            Node *find = findNode(clockIn_list, ID_crc);
            // printList(clockIn_list);
            if (find == NULL)
            {
                Machine_info.checkIn_set[terminal_info.personnel_check_in[0]].real_number++;
                clockIn_list = postInsert(clockIn_list, ID_crc, terminal_info.personnel_check_in[0], (&terminal_info.personnel_check_in) + 2, len - 2);
            }
            else
            {
                ESP_LOGE(LOG_TAG, "该人员已存在");
            }
        }
        else if (terminal_info.personnel_check_in[1] == 0x01) // check out
        {
            Node *find = findNode(clockIn_list, ID_crc);
            if (find != NULL)
            {
                clockIn_list = deleteNode(clockIn_list, ID_crc);
                Machine_info.checkIn_set[terminal_info.personnel_check_in[0]].real_number--;
            }
        }
        else
        {
            ESP_LOGE(LOG_TAG, "err:not in or out");
        }
    }
    // printList(clockIn_list);
    return msg_id;
}
uint8_t change_btn_reversal(uint8_t reversal_btn);
static void set_button_anotherName(void) // cmd 0x0d操作
{
    uint8_t tmp = change_btn_reversal(terminal_info.status_setting[0]);
    if ((terminal_info.status_setting[0] == 0) && (terminal_info.status_setting[1] == 0))
    { //[0]:状态  [1]:开关   ————>运行不能关闭，这两位都为0，说明没有收到信息
        // ESP_LOGW(LOG_TAG,"默认按键");
        return; // 没有cmd[0x0d]的lora信息
    }
    if (terminal_info.status_setting[1] == 0x00) // close
    {

        Machine_info.btn_dis_flag[tmp - 1] = false;
        ESP_LOGE(LOG_TAG, "按键状态关闭，清空按键文字 状态%d", tmp);
        switch (terminal_info.status_setting[0]) // 按键状态关闭，清空按键文字
        {
        case 0x00:
            memset(Machine_info.btn_operation, 0, 6);
            break;
        case 0x01:
            memset(Machine_info.btn_waitMaterials_info, 0, 6);
            break;
        case 0x02:
            memset(Machine_info.btn_safeKeep_info, 0, 6);
            break;
        case 0x03:
            memset(Machine_info.btn_breakDown_info, 0, 6);
            break;
        case 0x04:
            memset(Machine_info.btn_upKeep_info, 0, 6);
            break;
        case 0x05:
            memset(Machine_info.btn_shutDown_info, 0, 6);
            break;
        default:
            ESP_LOGE(LOG_TAG, "err:按键状态%d", __LINE__);
            break;
        }
    }
    else if (terminal_info.status_setting[1] == 0x01) // open
    {
        Machine_info.btn_dis_flag[tmp - 1] = true;
        // ESP_LOGW(LOG_TAG,"别名：[%02x %02x %02x %02x]",terminal_info.status_setting[2],terminal_info.status_setting[3],terminal_info.status_setting[4],terminal_info.status_setting[5]);
        if ((terminal_info.status_setting[2] == 0x00) && (terminal_info.status_setting[3] == 0x00))
        { // 别名为两个字，这判断第一个字为空,为空就赋值初始化的按键信息
            ESP_LOGE(LOG_TAG, "button is open[other name is NULL] %d", terminal_info.status_setting[0]);
            switch (terminal_info.status_setting[0])
            {
            case 0x00: // 运行
                printf("clear btn_operation display\r\n");
                memcpy(Machine_info.btn_operation, str_operation, 6);
                break;
            case 0x01: // 待料
                printf("clear btn_waitMaterials_info display\r\n");
                memcpy(Machine_info.btn_waitMaterials_info, str_waitMaterials, 6);
                break;
            case 0x02: // 封存
                printf("clear btn_safeKeep_info display\r\n");
                memcpy(Machine_info.btn_safeKeep_info, str_safeKeep, 6);
                break;
            case 0x03: // 故障
                printf("clear btn_breakDown_info display\r\n");
                memcpy(Machine_info.btn_breakDown_info, str_breakDown, 6);
                break;
            case 0x04: // 保养
                printf("clear btn_upKeep_info display\r\n");
                memcpy(Machine_info.btn_upKeep_info, str_upKeep, 6);
                break;
            case 0x05: // 停机
                printf("clear btn_shutDown_info display\r\n");
                memcpy(Machine_info.btn_shutDown_info, str_shutDown, 6);
                break;
            default:
                printf("other btn_operation display\r\n");
                ESP_LOGE(LOG_TAG, "err:按键状态%d", __LINE__);
                break;
            }
        }
        else
        {
            // ESP_LOGW(LOG_TAG,"button is open[other name] %d",terminal_info.status_setting[0]);
            switch (terminal_info.status_setting[0])
            {
            case 0x00:
                memset(Machine_info.btn_operation, 0, 6);
                uincode2gbk((char *)terminal_info.status_setting + 2, 4, (char *)Machine_info.btn_operation);
                // ESP_LOG_BUFFER_HEX(LOG_TAG,&Machine_info.btn_operation,6);
                break;
            case 0x01:
                memset(Machine_info.btn_waitMaterials_info, 0, 6);
                uincode2gbk((char *)terminal_info.status_setting + 2, 4, (char *)Machine_info.btn_waitMaterials_info);
                // ESP_LOG_BUFFER_HEX(LOG_TAG,&Machine_info.btn_waitMaterials_info,6);
                break;
            case 0x02:
                memset(Machine_info.btn_safeKeep_info, 0, 6);
                uincode2gbk((char *)terminal_info.status_setting + 2, 4, (char *)Machine_info.btn_safeKeep_info);
                // ESP_LOG_BUFFER_HEX(LOG_TAG,&Machine_info.btn_safeKeep_info,6);
                break;
            case 0x03:
                memset(Machine_info.btn_breakDown_info, 0, 6);
                uincode2gbk((char *)terminal_info.status_setting + 2, 4, (char *)Machine_info.btn_breakDown_info);
                // ESP_LOG_BUFFER_HEX(LOG_TAG,&Machine_info.btn_breakDown_info,6);
                break;
            case 0x04:
                memset(Machine_info.btn_upKeep_info, 0, 6);
                uincode2gbk((char *)terminal_info.status_setting + 2, 4, (char *)Machine_info.btn_upKeep_info);
                // ESP_LOG_BUFFER_HEX(LOG_TAG,&Machine_info.btn_upKeep_info,6);
                break;
            case 0x05:
                memset(Machine_info.btn_shutDown_info, 0, 6);
                uincode2gbk((char *)terminal_info.status_setting + 2, 4, (char *)Machine_info.btn_shutDown_info);
                // ESP_LOG_BUFFER_HEX(LOG_TAG,&Machine_info.btn_shutDown_info,6);
                break;
            default:
                ESP_LOGE(LOG_TAG, "err:按键状态%d", __LINE__);
                break;
            }
        }
    }
    else
    {
        ESP_LOGE(LOG_TAG, "not open or close");
    }
}
uint8_t change_btn(uint8_t btn);

static int status_setting_func(const LORA_DATA_T *buf)
{
    int len = (buf->data_buf[USE_DATA_LEN_INDEX]) << 8 | (buf->data_buf[USE_DATA_LEN_INDEX + 1]);

    memset(terminal_info.status_setting, 0x00, sizeof(terminal_info.status_setting));
    memcpy(terminal_info.status_setting, buf->data_buf + DATA_START_LEN, len); // 别名
    // ESP_LOGE(LOG_TAG,"len = %d ",len);
    ESP_LOG_BUFFER_HEX(LOG_TAG, terminal_info.status_setting, 10);
    set_button_anotherName();
    // 当前按键状态关闭了
    if ((change_btn(Machine_info.left_state) == terminal_info.status_setting[0]) && (Machine_info.btn_dis_flag[Machine_info.left_state - 1] == false))
    {
        ESP_LOGE(LOG_TAG, "按键发送");
        send_button_key_queue(STATE_OPERATION);
    }
    else
    {
        // display_flag = LEFT_FLAG;
        xEventGroupSetBits(screen_event, LEFT_SCREEN_BIT);
    }
    ESP_LOGW(LOG_TAG, "按键 :%s  %s  %s  %s  %s  %s",
             Machine_info.btn_dis_flag[0] ? "开启" : "关闭",
             Machine_info.btn_dis_flag[1] ? "开启" : "关闭",
             Machine_info.btn_dis_flag[2] ? "开启" : "关闭",
             Machine_info.btn_dis_flag[3] ? "开启" : "关闭",
             Machine_info.btn_dis_flag[4] ? "开启" : "关闭",
             Machine_info.btn_dis_flag[5] ? "开启" : "关闭");

    int msg_id = (buf->data_buf[13] >> 8) | buf->data_buf[14]; // 获取当前消息id 用于删除
    return msg_id;
}
static int status_duration_func(const LORA_DATA_T *buf)
{
    int len = (buf->data_buf[USE_DATA_LEN_INDEX]) << 8 | (buf->data_buf[USE_DATA_LEN_INDEX + 1]);
    memcpy(terminal_info.status_duration, buf->data_buf + DATA_START_LEN, len);

    // printf("msg h = %02X,msg l = %02X\r\n",buf->data_buf[13],buf->data_buf[14]);
    int msg_id = (buf->data_buf[13] >> 8) | buf->data_buf[14]; // 获取当前消息id 用于删除
    // printf("msg_id =%X\r\n",msg_id);
    return msg_id;
}

static int update_and_duration_func(const LORA_DATA_T *buf)
{
    int len = (buf->data_buf[USE_DATA_LEN_INDEX]) << 8 | (buf->data_buf[USE_DATA_LEN_INDEX + 1]);
    memcpy(terminal_info.update_and_duration, buf->data_buf + DATA_START_LEN, len);

    // printf("msg h = %02X,msg l = %02X\r\n",buf->data_buf[13],buf->data_buf[14]);
    int msg_id = (buf->data_buf[13] >> 8) | buf->data_buf[14]; // 获取当前消息id 用于删除
    // printf("msg_id =%X\r\n",msg_id);

    return msg_id;
}
static int announcement_func(const LORA_DATA_T *buf)
{
    int len = (buf->data_buf[USE_DATA_LEN_INDEX]) << 8 | (buf->data_buf[USE_DATA_LEN_INDEX + 1]);
    memcpy(terminal_info.announcement, buf->data_buf + DATA_START_LEN, len); // 拷贝公告
    ESP_LOG_BUFFER_HEX(LOG_TAG, terminal_info.announcement, len);
    ESP_LOGW(LOG_TAG, "设置公告");
    // memcpy(&Machine_info.terminal_name,&terminal_info.terminal_name,len);
    memset(Machine_info.announcement, 0x00, sizeof(Machine_info.announcement)); // 清除终端公告信息
    uincode2gbk((char *)terminal_info.announcement, len, (char *)Machine_info.announcement);

    // printf("unicode:");
    // for(i=0;i<len;i++)
    // {
    //     printf("%02x ",terminal_info.terminal_name[i]);
    // }
    // printf("\n");
    // printf("gbk:");
    // for(i=0;i<len;i++)
    // {
    //     printf("%02x ",Machine_info.terminal_name[i]);
    // }

    // printf("setting gong gao %s",Machine_info.announcement);
    // printf("\n");

    xEventGroupSetBits(screen_event, RIGHT_SCREEN_BIT);

    // printf("msg h = %02X,msg l = %02X\r\n",buf->data_buf[13],buf->data_buf[14]);
    int msg_id = (buf->data_buf[13] >> 8) | buf->data_buf[14]; // 获取当前消息id 用于删除
    // printf("msg_id =%X\r\n",msg_id);
    return msg_id;
}

void set_statisticsData(uint8_t *data)
{
// memset(&Machine_info.num_goodProducts,0,32);
// memset(&Machine_info.num_badProducts,0,32);
#define __DATA_SIZE 24
    for (int i = 0; i < 8; i++)
    {

        Machine_info.num_goodProducts[i] = (data[0 + i * __DATA_SIZE] << 24) | (data[1 + i * __DATA_SIZE] << 16) | (data[2 + i * __DATA_SIZE] << 8) | (data[3 + i * __DATA_SIZE]);
        Machine_info.num_badProducts[i] = (data[4 + i * __DATA_SIZE] << 24) | (data[5 + i * __DATA_SIZE] << 16) | (data[6 + i * __DATA_SIZE] << 8) | (data[7 + i * __DATA_SIZE]);
        Machine_info.scale_UR_int[i] = (data[8 + i * __DATA_SIZE]);
        Machine_info.scale_UR_dec[i] = (data[9 + i * __DATA_SIZE]);
        Machine_info.scale_YR_int[i] = (data[10 + i * __DATA_SIZE]);
        Machine_info.scale_YR_dec[i] = (data[11 + i * __DATA_SIZE]);
        Machine_info.num_manHour[i] = (data[12 + i * __DATA_SIZE] << 8) | (data[13 + i * __DATA_SIZE]);
        Machine_info.num_people[i] = (data[14 + i * __DATA_SIZE] << 8) | (data[15 + i * __DATA_SIZE]);
        Machine_info.num_production[i] = (data[16 + i * __DATA_SIZE] << 8) | (data[17 + i * __DATA_SIZE]);
        Machine_info.num_repair[i] = (data[18 + i * __DATA_SIZE] << 8) | (data[19 + i * __DATA_SIZE]);
        Machine_info.num_inspection[i] = (data[20 + i * __DATA_SIZE] << 8) | (data[21 + i * __DATA_SIZE]);
        Machine_info.num_upkeep[i] = (data[22 + i * __DATA_SIZE] << 8) | (data[23 + i * __DATA_SIZE]);
        // ESP_LOGW(LOG_TAG,"good:[%ld] bad[%ld]",Machine_info.num_goodProducts[i],Machine_info.num_badProducts[i]);
    }
}
static int capacity_statistics_func(const LORA_DATA_T *buf)
{
#if 1
    int len = (buf->data_buf[USE_DATA_LEN_INDEX]) << 8 | (buf->data_buf[USE_DATA_LEN_INDEX + 1]);
    memcpy(terminal_info.capacity_statistics, buf->data_buf + DATA_START_LEN, len);

#endif

    // printf("msg h = %02X,msg l = %02X\r\n",buf->data_buf[13],buf->data_buf[14]);
    int msg_id = (buf->data_buf[13] >> 8) | buf->data_buf[14]; // 获取当前消息id 用于删除
    // printf("msg_id =%X\r\n",msg_id);
    set_statisticsData(terminal_info.capacity_statistics);

    xEventGroupSetBits(screen_event, RIGHT_SCREEN_BIT);

    return msg_id;
}
static int responsible_person_synchronize_info_func(const LORA_DATA_T *buf)
{
    int len = (buf->data_buf[USE_DATA_LEN_INDEX]) << 8 | (buf->data_buf[USE_DATA_LEN_INDEX + 1]);
    memcpy(terminal_info.responsible_person_synchronize_info, buf->data_buf + DATA_START_LEN, len);

    // printf("msg h = %02X,msg l = %02X\r\n",buf->data_buf[13],buf->data_buf[14]);
    int msg_id = (buf->data_buf[13] >> 8) | buf->data_buf[14]; // 获取当前消息id 用于删除
    // printf("msg_id =%X\r\n",msg_id);

    xEventGroupSetBits(screen_event, RIGHT_SCREEN_BIT);

    return msg_id;
}
static int status_led_func(const LORA_DATA_T *buf)
{
    terminal_info.states_led = buf->data_buf[DATA_START_LEN];
    // printf("msg h = %02X,msg l = %02X\r\n",buf->data_buf[13],buf->data_buf[14]);
    int msg_id = (buf->data_buf[13] >> 8) | buf->data_buf[14]; // 获取当前消息id 用于删除
    // printf("msg_id =%X\r\n",msg_id);

    return msg_id;
}
static int logo_led_func(const LORA_DATA_T *buf)
{
    terminal_info.logo_led = buf->data_buf[DATA_START_LEN];

    // printf("msg h = %02X,msg l = %02X\r\n",buf->data_buf[13],buf->data_buf[14]);
    int msg_id = (buf->data_buf[13] >> 8) | buf->data_buf[14]; // 获取当前消息id 用于删除
    // printf("msg_id =%X\r\n",msg_id);

    return msg_id;
}
static int battery_temperature_func(const LORA_DATA_T *buf)
{
    terminal_info.batt_temperature[0] = buf->data_buf[DATA_START_LEN];
    terminal_info.batt_temperature[1] = buf->data_buf[DATA_START_LEN + 1];

    // printf("msg h = %02X,msg l = %02X\r\n",buf->data_buf[13],buf->data_buf[14]);
    int msg_id = (buf->data_buf[13] >> 8) | buf->data_buf[14]; // 获取当前消息id 用于删除
    // printf("msg_id =%X\r\n",msg_id);
    return msg_id;
}
static int station_name_func(const LORA_DATA_T *buf)
{
#define FONT_MAX_LEN 8
    uint8_t font_num = 0; // 获取当前的文字个数
    int i = 0;
    int len = (buf->data_buf[USE_DATA_LEN_INDEX]) << 8 | (buf->data_buf[USE_DATA_LEN_INDEX + 1]);
    memset(terminal_info.station_name, 0, 32);
    memcpy(terminal_info.station_name, buf->data_buf + DATA_START_LEN, len);

    // memcpy(&Machine_info.terminal_name,&terminal_info.terminal_name,len);
    memset(Machine_info.station_name, 0x00, sizeof(Machine_info.station_name)); // 清除终端名称信息

    font_num = len / 2;
    if (font_num <= FONT_MAX_LEN)
    {
        uincode2gbk((char *)terminal_info.station_name, len, (char *)Machine_info.station_name);
    }
    else
    {
        uincode2gbk((char *)terminal_info.station_name, FONT_MAX_LEN * 2, (char *)Machine_info.station_name);
        strcat((char *)Machine_info.station_name, "...");
    }

    xEventGroupSetBits(screen_event, RIGHT_SCREEN_BIT);

    int msg_id = (buf->data_buf[13] >> 8) | buf->data_buf[14]; // 获取当前消息id 用于删除
    return msg_id;
}
static int station_number_func(const LORA_DATA_T *buf)
{
    int len = (buf->data_buf[USE_DATA_LEN_INDEX]) << 8 | (buf->data_buf[USE_DATA_LEN_INDEX + 1]);
    memcpy(terminal_info.station_number, buf->data_buf + DATA_START_LEN, len);
    memset(Machine_info.station_number, 0x00, sizeof(Machine_info.station_number));

    uincode2gbk((char *)terminal_info.station_number, len, (char *)Machine_info.station_number);

    xEventGroupSetBits(screen_event, RIGHT_SCREEN_BIT);

    int msg_id = (buf->data_buf[13] >> 8) | buf->data_buf[14]; // 获取当前消息id 用于删除
    return msg_id;
}
static int responsible_person_setup_func(const LORA_DATA_T *buf)
{
    int len = (buf->data_buf[USE_DATA_LEN_INDEX]) << 8 | (buf->data_buf[USE_DATA_LEN_INDEX + 1]);

    ESP_LOG_BUFFER_HEX(LOG_TAG, buf->data_buf + DATA_START_LEN, len);
    ESP_LOGE(LOG_TAG, "设置责任人 类型[%d]%s", buf->data_buf[DATA_START_LEN], buf->data_buf[DATA_START_LEN + 1] ? "开启" : "关闭");
    if (buf->data_buf[DATA_START_LEN + 1] == 0x01) // 开
    {
        Machine_info.person[buf->data_buf[DATA_START_LEN]].Charge_close = false;
        memset(Machine_info.person[buf->data_buf[DATA_START_LEN]].other_name, 0, 16);
        uincode2gbk(buf->data_buf + DATA_START_LEN + 2, len - 2, (char *)Machine_info.person[buf->data_buf[DATA_START_LEN]].other_name);
        // ESP_LOG_BUFFER_HEX(LOG_TAG,Machine_info.person[buf->data_buf[DATA_START_LEN]].other_name,len);
    }
    else if (buf->data_buf[DATA_START_LEN + 1] == 0x00) // 关
    {
        Machine_info.person[buf->data_buf[DATA_START_LEN]].Charge_close = true;
    }
    ESP_LOGE(LOG_TAG, "Charge_close %d %d %d %d %d", Machine_info.person[0].Charge_close, Machine_info.person[1].Charge_close, Machine_info.person[2].Charge_close,
             Machine_info.person[3].Charge_close, Machine_info.person[4].Charge_close);
    // display_flag = RIGHT_FLAG;
    xEventGroupSetBits(screen_event, RIGHT_SCREEN_BIT);
    int msg_id = (buf->data_buf[13] >> 8) | buf->data_buf[14]; // 获取当前消息id 用于删除
    return msg_id;
}
static int system_bulletin_func(const LORA_DATA_T *buf)
{
    ESP_LOGE(LOG_TAG, "system_bulletin_func");
    int len = (buf->data_buf[USE_DATA_LEN_INDEX]) << 8 | (buf->data_buf[USE_DATA_LEN_INDEX + 1]);
    memcpy(terminal_info.systemMessage, buf->data_buf + DATA_START_LEN, len);
    memset(Machine_info.systemMessage, 0x00, sizeof(Machine_info.systemMessage));
    uincode2gbk((char *)terminal_info.systemMessage, len, (char *)Machine_info.systemMessage);

    int msg_id = (buf->data_buf[13] >> 8) | buf->data_buf[14]; // 获取当前消息id 用于删除
    return msg_id;
}

static int hardware_update_func(const LORA_DATA_T *buf)
{
    // printf("msg h = %02X,msg l = %02X\r\n",buf->data_buf[13],buf->data_buf[14]);
    int msg_id = (buf->data_buf[13] >> 8) | buf->data_buf[14]; // 获取当前消息id 用于删除
    // printf("msg_id =%X\r\n",msg_id);
    return msg_id;
}

/*硬件回复命令ACK*/ /*长度 返回result结果及长度*/

/*********************************************************************************
 * function   :   reply_ack_func
 * Description :  回复ACK cmd 指定命令
 * Input       :  cmd 命令  msg_id 当前的ID号 用于网关删除自身的已经接受到ACK 的数据  result 返回当前的数据
 * Output      :
 * Author      :  祁鑫                  Data : 2023 8.12
 **********************************************************************************/
int reply_ack_func(int cmd, int msg_id, bool is_send, uint8_t *result)
{

    uint8_t strlorabuf[50] = {0};
    uint8_t mac[6] = {0};

    strlorabuf[0] = 0x5A;
    strlorabuf[1] = 0x51;
    strlorabuf[2] = 0x00; // crc

    // int byteArrayLength = hexStringToByteArray((char *)C_MAC, (unsigned char *)mac);  //HEX字符串转HEX数组
    for (int i = 0; i < 6; i++)
    {
        strlorabuf[3 + i] = Machine_info.gateway_mac[i]; // 网关的mac地址
    }

    strlorabuf[9] = Machine_info.eflagID; // 组内编号

    strlorabuf[10] = cmd; // 命令

    strlorabuf[11] = (msg_id >> 8) & 0xff; // 总包
    strlorabuf[12] = msg_id & 0xff;        // 当前包

    strlorabuf[13] = 0x00; // 当前长度

    strlorabuf[14] = PROTOCOL_RSPONSIBLE_ACK; // ACK命令字段

#if 0
    //设备cid长度
    memcpy(&strlorabuf[15],cid,cid_len); //拷贝cid
    strlorabuf[13] = cid_len+1;     //重新设置当前当前长度
#endif
    int crc = 0; // 计算crc
    for (int i = 0; i < sizeof(strlorabuf); i++)
    {
        crc += strlorabuf[i];
    }
    strlorabuf[2] = crc;

    if (result != NULL)
    {
        memcpy(result, strlorabuf, 15);
    }

    if (is_send)
    {

        lora_send_data((char *)strlorabuf, 15);
        uart_wait_tx_idle_polling(UART_NUM_1);
    }

    return 15;
}

/*硬件配网回复*/ // 参数cid  cid长度 返回result    结果及长度
int reply_gwpair_ack_func(uint8_t *cid, uint8_t cid_len, uint8_t *result)
{

    uint8_t strlorabuf[50] = {0};
    uint8_t mac[6] = {0};

    strlorabuf[0] = 0x5A;
    strlorabuf[1] = 0x51;
    strlorabuf[2] = 0x00; // crc

    // int byteArrayLength = hexStringToByteArray((char *)C_MAC, (unsigned char *)mac);  //HEX字符串转HEX数组
    for (int i = 0; i < 6; i++)
    {
        strlorabuf[3 + i] = Machine_info.gateway_mac[i]; // 网关的mac地址
    }

    strlorabuf[9] = Machine_info.eflagID; // 组内编号

    strlorabuf[10] = 0x80; // 配对命令

    strlorabuf[11] = 0x01; // 总包
    strlorabuf[12] = 0x01; // 当前包

    strlorabuf[13] = 0x00; // 当前长度

    strlorabuf[14] = 0x01; // 请求成功

    // 设备cid长度
    memcpy(&strlorabuf[15], cid, cid_len); // 拷贝cid

    strlorabuf[13] = cid_len + 1; // 重新设置当前当前长度

    int crc = 0; // 计算crc
    for (int i = 0; i < sizeof(strlorabuf); i++)
    {
        crc += strlorabuf[i];
    }
    strlorabuf[2] = crc;

    memcpy(result, strlorabuf, 14 + cid_len + 1);

    return 14 + cid_len + 1;
}

/*硬件配网*/
static void hardware_gwpair_func(const LORA_DATA_T *buf)
{

    uint8_t child_mac[6] = {0};   // 子设备的mac地址
    uint8_t gateway_mac[6] = {0}; // 网关的组内编号
    int child_num = 0;
    int gateway_num = 0;

#if 0
        for(int i = 0;i<buf->data_len;i++)
        {
            printf("%02X",buf->data_buf[i]);
        }
#endif
    uint64_t time = 0x000000000000LL;
    // printf("1\r\n");
    memcpy(child_mac, &buf->data_buf[3], 6);
    // printf("2\r\n");
    gateway_num = buf->data_buf[9];
    // printf("3\r\n");
    memcpy(gateway_mac, &buf->data_buf[14], 6);
    // printf("4\r\n");
    child_num = buf->data_buf[20];
    // printf("5\r\n");
    // printf("\r\n");
    //    for(int i = 21;i<27;i++)
    //    {
    //  	  printf("%02X",buf->data_buf[i]);
    //    }
#if 0
#include <inttypes.h>
  time|=(buf->data_buf[26]<<0);
  //printf("time = %" PRIX64 "\r\n",time);
  time|=(buf->data_buf[25]<<8);
  //printf("time = %" PRIX64 "\r\n",time);
  time|=(buf->data_buf[24]<<16);
  //printf("time = %" PRIX64 "\r\n",time);
  time|=(buf->data_buf[23]<<24);
  //printf("time = %" PRIX64 "\r\n",time);
#if 0
  uint64_t temp = 0;
  temp |=(buf->data_buf[22]<<32);
  temp |=(buf->data_buf[21]<<40);
  printf("temp = %" PRIX64 "\r\n",temp);
#endif

#if 1
  int64_t temp = 0;
  temp = buf->data_buf[22];
  time|=(temp<<32);//(buf->data_buf[22]<<32);
#else
  time|=temp;
#endif
  //printf("time = %" PRIX64 "\r\n",(uint64_t)time);
#if 0
  time|=(buf->data_buf[21]<<40);
#else
  temp = 0;
  temp = buf->data_buf[21];
  time|=(temp<<40);//(buf->data_buf[22]<<32);
  //time|=(buf->data_buf[21]<<40);
#endif
  //printf("time = %" PRIX64 "\r\n",(uint64_t)time);
  //uint64_t value = 0x018B1E3D24AC;
  //printf("Value as a 64-bit integer: %" PRIu64 "\n", value);
  //printf("Value as a 64-bit integer: %" PRIX64 "\n", value);
#if 0
        time=(buf->data_buf[21]<<40)+
        (buf->data_buf[22]<<32)+
        (buf->data_buf[23]<<24)+
        (buf->data_buf[24]<<16)+
        (buf->data_buf[25]<<8) +
        (buf->data_buf[26]<<0);
#endif
#else

    Machine_info.lora_new_channel = buf->data_buf[21];
    printf("Machine_info.lora_new_channel =%d\r\n", Machine_info.lora_new_channel);

    memcpy(Machine_info.timestamp, &buf->data_buf[22], 13);

    printf("Machine_info.timestamp =%s\r\n", Machine_info.timestamp);

    int timezone_offset = 8; // 中国时区偏移为UTC+8，你可以根据需要设置不同的时区偏移
    Machine_info.time_offset = timezone_offset;

    timestamp_to_local_time(Machine_info.timestamp,
                            Machine_info.time_offset,
                            &Machine_info.year,
                            &Machine_info.month,
                            &Machine_info.day,
                            &Machine_info.hour,
                            &Machine_info.min,
                            &Machine_info.sec);
    setRtcTime(Machine_info.year, Machine_info.month, Machine_info.day,
               Machine_info.hour, Machine_info.min, Machine_info.sec);

    // 更新当前状态时间
    Machine_info.current_button.Year = Machine_info.year;
    Machine_info.current_button.Month = Machine_info.month;
    Machine_info.current_button.Day = Machine_info.day;
    Machine_info.current_button.Hour = Machine_info.hour;
    Machine_info.current_button.Minute = Machine_info.min;
    Machine_info.current_button.Second = Machine_info.sec;

    Machine_info.last_button.Year = Machine_info.year;
    Machine_info.last_button.Month = Machine_info.month;
    Machine_info.last_button.Day = Machine_info.day;
    Machine_info.last_button.Hour = Machine_info.hour;
    Machine_info.last_button.Minute = Machine_info.min;
    Machine_info.last_button.Second = Machine_info.sec;

#endif

    printf("gateway mac = ");
    for (int i = 0; i < 6; i++)
        printf("%02X", gateway_mac[i]);
    printf("\r\n");
    printf("gateway num = %d\r\n", gateway_num);
    printf("child mac = ");
    for (int i = 0; i < 6; i++)
        printf("%02X", child_mac[i]);
    printf("\r\n");
    printf("child_num num = %d\r\n", child_num);
    printf("time = %llu\r\n", time);
    printf("time = %llx\r\n", time);
    //(3000 - (480 - 1*100))

#include "user_sleep.h"
#include "esp_sleep.h"

    // 配网完成设置休眠唤醒时间
    if (Machine_info.eflagID == 0xff)
    {
#if 0
        printf("sleep time = %d ms\r\n",(TIMER_WAKEUP_TIME_US*child_num)/1000);
        esp_sleep_enable_timer_wakeup(TIMER_WAKEUP_TIME_US*child_num);  //配置当前休眠的唤醒时间
#else
        esp_sleep_enable_timer_wakeup(TIMER_WAKEUP_TIME_US); // 配置当前休眠的唤醒时间
#endif
    }

    Machine_info.eflagID = child_num; // 保存当前的子设备组内编号

    memcpy(Machine_info.gateway_mac, gateway_mac, 6);

    // 配网成功 回复 ACK 设置新的信道

    Machine_info.paired = 1; // 已配对

#if 0
    send_pair_ack();
#else
    int msg_id = (buf->data_buf[11] << 8) | buf->data_buf[12]; // 获取当前消息id 用于删除
    printf("msg_id =%X\r\n", msg_id);

    reply_ack_func(PROTOCOL_HARDWARE_GWPAIRED, msg_id, true, NULL); // 回复ack

#endif
    // vTaskDelay(200 / portTICK_PERIOD_MS);
    // //修改信道前修改设备ID 及 设备ID
    //  dymatic_change_device_id(child_num+1);
    //  dymatic_change_dst_device_id(0x00000001);
    // //切换信道
    // dymatic_change_chanel(Machine_info.lora_new_channel);  //切换信道
    // lora_get_rssi();

    vTaskDelay(200 / portTICK_PERIOD_MS);
    Machine_info.rssi = set_lora(Machine_info.lora_new_channel, Machine_info.eflagID);
    f_send_version();
    f_send_reply_status(0x01); // 回复在线状态
    send_update_status();
    // f_send_lora_rssi(Machine_info.rssi);
    f_send_lora_rssi(100); // 刚配完直接发100
    f_send_battary_vaule(Machine_info.batt_precent);

#if USER_LIGHT_SLEEP_ENABLE || USER_DEEP_SLEEP_ENABLE
    sleep_timer_start(2000); // 进入睡眠
#endif

    // printf("start timer id = %d,%d\r\n",Machine_info.eflagID,Machine_info.eflagID * TIMER_CAN_SEND_TIME);
    // Already_send_timer_start(Machine_info.eflagID * TIMER_CAN_SEND_TIME);
}

/*硬件取消配网*/
static void hardware_ungwpair_func(const LORA_DATA_T *buf)
{
    uint8_t child_mac[6] = {0};   // 子设备的mac地址
    uint8_t gateway_mac[6] = {0}; // 网关的组内编号
    int child_num = 0;
    int gateway_num = 0;

    uint64_t time = 0x000000000000LL;

    memcpy(child_mac, &buf->data_buf[3], 6);
    gateway_num = buf->data_buf[9];

    memcpy(gateway_mac, &buf->data_buf[14], 6);

    child_num = buf->data_buf[20];

#include <inttypes.h>
    time |= (buf->data_buf[26] << 0);

    time |= (buf->data_buf[25] << 8);

    time |= (buf->data_buf[24] << 16);

    time |= (buf->data_buf[23] << 24);

#if 1
    int64_t temp = 0;
    temp = buf->data_buf[22];
    time |= (temp << 32); //(buf->data_buf[22]<<32);
#else
    time |= temp;
#endif
// printf("time = %" PRIX64 "\r\n",(uint64_t)time);
#if 0
  time|=(buf->data_buf[21]<<40);
#else
    temp = 0;
    temp = buf->data_buf[21];
    time |= (temp << 40); //(buf->data_buf[22]<<32);
// time|=(buf->data_buf[21]<<40);
#endif
    // printf("time = %" PRIX64 "\r\n",(uint64_t)time);
    // uint64_t value = 0x018B1E3D24AC;
    // printf("Value as a 64-bit integer: %" PRIu64 "\n", value);
    // printf("Value as a 64-bit integer: %" PRIX64 "\n", value);

    printf("gateway mac = ");
    for (int i = 0; i < 6; i++)
        printf("%02X", gateway_mac[i]);
    printf("\r\n");
    printf("gateway num = %d\r\n", gateway_num);
    printf("child mac = ");
    for (int i = 0; i < 6; i++)
        printf("%02X", child_mac[i]);
    printf("\r\n");
    printf("child_num num = %d\r\n", child_num);
    printf("time = %llu\r\n", time);
    printf("time = %llx\r\n", time);
    //(3000 - (480 - 1*100))

#include "user_sleep.h"
#include "esp_sleep.h"

    memcpy(Machine_info.gateway_mac, gateway_mac, 6);

    // 取消配网成功 回复 ACK 设置新的信道

#if 0
    send_pair_ack();
#else
    int msg_id = (buf->data_buf[11] << 8) | buf->data_buf[12]; // 获取当前消息id 用于删除
    // printf("msg_id =%X\r\n",msg_id);

    reply_ack_func(PROTOCOL_HARDWARE_UNGWPAIRED, msg_id, true, NULL); // 回复ack

#endif

    // #include "user_sleep.h"
    // #include "esp_sleep.h"

    extern void sleep_timer_stop();
    extern void Already_send_timer_stop();

    sleep_timer_stop();
    Already_send_timer_stop();

    // 修改信道前修改设备ID 及 设备ID
    dymatic_change_device_id(0x00000001);
    dymatic_change_dst_device_id(0xFFFFFFFF);
    // 切换信道
    reset_default(true, 1);
    vTaskDelay(300 / portTICK_PERIOD_MS);
    Machine_info.lora_new_channel = LORA_CHANENL;
    // dymatic_change_chanel(Machine_info.lora_factory_channel);  //切换信道
    reset_lora(LORA_CHANENL);
}
/*网关收到终端发送的数据 ACK 终端收到用于删除当前的msgid的数据*/
static void hardware_ack_delete_msg_id(const LORA_DATA_T *buf)
{

    int msg_id = (buf->data_buf[11] >> 8) | buf->data_buf[12]; // 获取当前消息id 用于删除当前链表的数据
    ESP_LOG_BUFFER_HEX("ACK", buf->data_buf, buf->data_len);

    // int current =  countNodes(Send_list);   //获取当前节点数据
    Node *find = findNode(Send_list, msg_id);
    printf("delete list node bofore = %d\r\n", msg_id);

    if (find != NULL)
    {
        // printf("delete list node bofore = %d\r\n",msg_id);
        // printList(Send_list);
        Send_list = deleteNode(Send_list, msg_id);
        // printf("delete list node msg_id = %d\r\n",msg_id);

        // printf("delete list node after = %d\r\n",msg_id);
        // printList(Send_list);
    }
    else
    {
        ESP_LOGE(LOG_TAG, "delete fail");
    }

    display_flag = 0;
}

void business_logic_func(const LORA_DATA_T *buf, uint8_t cmd_index, int msg)
{
    int cmd = 0;    // 当前的命令
    int msg_id = 0; // 消息的id
// bool is_rsp_ack = false;
#if 0
    printf("cmd = %02X\r\n",buf->data_buf[cmd_index]);
#endif

    cmd = buf->data_buf[cmd_index];

    switch (buf->data_buf[cmd_index])
    {
    case PROTOCOL_TIME_SYNCHRONIZATION:

        msg_id = time_synchronization_func(buf);
        // is_rsp_ack = true;
        break;
    case PROTOCOL_TERMINAL_NAME:
        msg_id = terminal_name_func(buf);
        // is_rsp_ack = true;
        break;
    case PROTOCOL_TERMINAL_NUMBER:
        msg_id = terminal_number_func(buf);
        // is_rsp_ack = true;
        break;
    case PROTOCOL_ELECTRIC_QUANTITY:
        msg_id = electric_quantity_func(buf);
        // is_rsp_ack = true;
        break;
    case PROTOCOL_SIGNAL_STRENGTH:
        msg_id = signal_strength_func(buf);
        // is_rsp_ack = true;
        break;
    case PROTOCOL_SCREEN_REFRESH_CYCLE:
        msg_id = screen_refresh_cycle_func(buf);
        // is_rsp_ack = true;
        break;
    case PROTOCOL_SCREEN_LEFT:
        msg_id = screen_left_func(buf);
        // is_rsp_ack = true;
        break;
    case PROTOCOL_SCREEN_RIGHT:
        msg_id = screen_right_func(buf);
        // is_rsp_ack = true;
        break;
    case PROTOCOL_RSPONSIBLE_PERSON_CHANGE:
        msg_id = rsponsible_person_change_func(buf);
        // is_rsp_ack = true;
        break;
    case PROTOCOL_RSPONSIBLE_PERSON_DELETE:
        msg_id = rsponsible_person_delete_func(buf);
        // is_rsp_ack = true;
        break;
    case PROTOCOL_PRODUCTION_PUNCH_CARD:
        msg_id = production_punch_func(buf);
        // is_rsp_ack = true;
        break;
    case PROTOCOL_PERSONNEL_CHECK_IN:
        msg_id = personnel_check_in_func(buf);
        // is_rsp_ack = true;
        break;
    case PROTOCOL_STATUS_SETTING:
        msg_id = status_setting_func(buf);
        // is_rsp_ack = true;
        break;
    case PROTOCOL_STATUS_DURATION:
        msg_id = status_duration_func(buf);
        // is_rsp_ack = true;
        break;
    case PROTOCOL_UPDATE_AND_DURATION:
        msg_id = update_and_duration_func(buf);
        //  is_rsp_ack = true;
        break;
    case PROTOCOL_ANNOUNCEMENT:
        msg_id = announcement_func(buf);
        //  is_rsp_ack = true;
        break;
    case PROTOCOL_CAPACITY_STATISTICS:
        msg_id = capacity_statistics_func(buf);
        //  is_rsp_ack = true;
        break;
    case PROTOCOL_RESPONSIBLE_PERSON_SYNCHRONIZE_INFO:
        msg_id = responsible_person_synchronize_info_func(buf);
        //   is_rsp_ack = true;
        break;
    case PROTOCOL_STATUS_LED:
        msg_id = status_led_func(buf);
        //  is_rsp_ack = true;
        break;
    case PROTOCOL_LOG_LED:
        msg_id = logo_led_func(buf);
        //   is_rsp_ack = true;
        break;
    case PROTOCOL_BATTERY_TEMPERATURE:
        msg_id = battery_temperature_func(buf);
        //    is_rsp_ack = true;
        break;
    case PROTOCOL_STATION_NAME:
        msg_id = station_name_func(buf);
        //      is_rsp_ack = true;
        break;
    case PROTOCOL_STATION_NUMBER:
        msg_id = station_number_func(buf);
        //      is_rsp_ack = true;
        break;
    case PROTOCOL_RESPONSIBLE_PERSON_SETUP:
        msg_id = responsible_person_setup_func(buf);
        //     is_rsp_ack = true;
        break;
    case PROTOCOL_SYSTEM_BULLETIN:
        msg_id = system_bulletin_func(buf);
        //  is_rsp_ack = true;
        break;
    case PROTOCOL_HARDWARE_UPDATE:
        msg_id = hardware_update_func(buf);
        // is_rsp_ack = true;
        break;

    case PROTOCOL_HARDWARE_GWPAIRED: // 配网 暂时单独发送ack
        reset_default(false, 1);
        hardware_gwpair_func(buf);
        // Paint_leftScreen_main_quick(&Machine_info);
        // Paint_rightScreen_main_quick(&Machine_info);

        screen_dis_info.is_left = true;
        screen_dis_info.is_into_sleep = false;
        // 重置快刷
        Machine_info.left_current_Quick_refresh_time = 0;
        Machine_info.right_current_Quick_refresh_time = 0;
        if (xQueueSend(screen_queue, &screen_dis_info, portMAX_DELAY) != true)
        {
            ESP_LOGE(LOG_TAG, "err:screen queue send fail");
        }
        screen_dis_info.is_left = false;
        screen_dis_info.is_into_sleep = false;
        if (xQueueSend(screen_queue, &screen_dis_info, portMAX_DELAY) != true)
        {
            ESP_LOGE(LOG_TAG, "err:screen queue send fail");
        }
        break;

    case PROTOCOL_HARDWARE_UNGWPAIRED: // 取消配网
        printf("pair ungwpaired\r\n");
        hardware_ungwpair_func(buf);
        break;

    case PROTOCOL_RSPONSIBLE_ACK:

        printf("receive gateway ack delete data in list\r\n");
        hardware_ack_delete_msg_id(buf);

        break;

    default:
        ESP_LOGE(LOG_TAG, "ERR:CMD = 0x%02x", buf->data_buf[cmd_index]);
        break;
    }

#if USER_NOT_SLEEP_ENABLE
    send_can_I_receive(); // 发送可以接受的命令
#endif
}

void uincode2gbk(char *str, uint16_t len, char *out_buffer)
{
    char strtmp[1024];
    char str1[3];
    unsigned int iunicode, i;
    unsigned int igbk;
    memset(strtmp, 0, 1024);
    int index = 0;

    i = 0;

    int length = len;

    while (length)
    {
        if ((str[i] == 0) && (str[i + 1]) < 0x80) // ASCII 码 *text是ASCII码
        {

            str1[0] = (str[i + 1]) & 0xff;
            memcpy(&strtmp[index], str1, 1);
            index += 1;
        }
        else
        {
            iunicode = (str[i] << 8) + str[i + 1];
            igbk = U2G(iunicode);
            str1[0] = (igbk >> 8) & 0xff;
            str1[1] = igbk & 0xff;
            memcpy(&strtmp[index], str1, 2);
            index += 2;
        }
        length -= 2;
        i += 2;
    }
    // ESP_LOGW(LOG_TAG,"index:%d",index);
    memcpy(out_buffer, strtmp, index);
}
// 计算数组元素的总和
uint32_t sumArray(uint8_t array[], int size)
{
    uint32_t sum = 0;
    for (int i = 0; i < size; i++)
    {
        sum += array[i];
    }
    return sum;
}
void mac_to_hex(char *out_string, char *in_string)
{
    sprintf(out_string, "%02X:%02X:%02X:%02X:%02X:%02X",
            in_string[0],
            in_string[1],
            in_string[2],
            in_string[3],
            in_string[4],
            in_string[5]);
    // ESP_LOG_BUFFER_HEX("--->",out_string,17);
}
void qrcode_protocol_create(char *result, Machine_info_t info)
{
    // char str_https[] = "https://www.yeechart.com/antnest_download.php?data=";
    char str_https[] = "https://www.yeechart.com/yeechart_download.php?data=";
    Qrcode_protocol_t Qcode;
    char qrcode_protocol[1024] = {0};

    Qcode.head[0] = 0x5a;
    Qcode.head[1] = 0x51;
    Qcode.CRC = 0x00;

    Qcode.mac.cmd = 0x03;
    Qcode.mac.len = 0x11;
    esp_read_mac((uint8_t *)mac_addr, ESP_MAC_WIFI_STA);
    mac_to_hex((char *)Qcode.mac.mac_addr, (char *)mac_addr);
    // strcpy((char *)Qcode.mac.mac_addr,(char*)mac_addr);

    Qcode.client.cmd = 0X04;
#if 1 // 硬件设备id (qx 设置)
    strcpy((char *)Qcode.client.client_id, (char *)info.cid);
    Qcode.client.len = strlen((char *)Qcode.client.client_id);
#else // 假硬件设备id
    strcpy((char *)Qcode.client.client_id, "whc_test");
    Qcode.client.len = strlen((char *)Qcode.client.client_id);
#endif

    Qcode.product.cmd = 0x05;
    strcpy((char *)Qcode.product.product, "020101");
    Qcode.product.len = strlen((char *)Qcode.product.product);

    Qcode.time.cmd = 0x61;
    Qcode.time.len = 0x0E;

#if 1
    Qcode.time.Year = info.year;
    Qcode.time.Month = info.month;
    Qcode.time.Day = info.day;
    Qcode.time.Hour = info.hour;
    Qcode.time.Minute = info.min;
    Qcode.time.Second = info.sec;
#else
    Qcode.time.Year = 2023;
    Qcode.time.Month = 9;
    Qcode.time.Day = 19;
    Qcode.time.Hour = 19;
    Qcode.time.Minute = 30;
    Qcode.time.Second = 20;
#endif
    int time_index = 0;
    sprintf((char *)(Qcode.time.time + time_index * 2), "%02X%02X", Qcode.time.Year >> 8, Qcode.time.Year & 0xff);
    time_index += 2;
    sprintf((char *)(Qcode.time.time + time_index * 2), "%02X", Qcode.time.Month);
    time_index += 1;
    sprintf((char *)(Qcode.time.time + time_index * 2), "%02X", Qcode.time.Day);
    time_index += 1;
    sprintf((char *)(Qcode.time.time + time_index * 2), "%02X", Qcode.time.Hour);
    time_index += 1;
    sprintf((char *)(Qcode.time.time + time_index * 2), "%02X", Qcode.time.Minute);
    time_index += 1;
    sprintf((char *)(Qcode.time.time + time_index * 2), "%02X", Qcode.time.Second);

    uint32_t crc = 0;
    crc += Qcode.head[0];
    crc += Qcode.head[1];

    crc += sumArray((uint8_t *)&Qcode.mac, sizeof(Qcode.mac));

    crc += Qcode.client.cmd;
    crc += Qcode.client.len;

    int len = 0, i = 0;

    len = Qcode.client.len;

    while (len)
    {
        crc += Qcode.client.client_id[i];
        len--;
        i++;
    }

    crc += Qcode.product.cmd;
    crc += Qcode.product.len;

    i = 0;
    len = Qcode.product.len;
    while (len)
    {
        if (Qcode.product.product[i] != '0')
        {
            crc += Qcode.product.product[i];
        }
        else
        {
            break;
        }
        len--;
        i++;
    }

    i = 0;
    len = Qcode.time.len;
    while (len)
    {
        if (Qcode.time.time[i] != '0')
        {
            crc += Qcode.time.time[i];
        }
        else
        {
            break;
        }
        len--;
        i++;
    }

    Qcode.CRC = crc & 0xff;

    int index = 0;

    sprintf(qrcode_protocol + index * 2, "%02X%02X", Qcode.head[0], Qcode.head[1]);
    index += 2;
    sprintf(qrcode_protocol + index * 2, "%02X", Qcode.CRC);
    index += 1;

    sprintf(qrcode_protocol + index * 2, "%02X%02X", Qcode.mac.cmd, Qcode.mac.len);
    index += 2;
    // 转换16进制数组为ASCII字符串  mac 地址
    for (int i = 0; i < Qcode.mac.len; i++)
    {
        sprintf(qrcode_protocol + index * 2, "%02X", Qcode.mac.mac_addr[i]);
        index += 1;
    }

    sprintf(qrcode_protocol + index * 2, "%02X%02X", Qcode.client.cmd, Qcode.client.len);
    index += 2;

    // 转换16进制数组为ASCII字符串  client id
    for (int i = 0; i < Qcode.client.len; i++)
    {

        if (Qcode.client.client_id[i] != 0)
        {
            sprintf(qrcode_protocol + index * 2, "%02X", Qcode.client.client_id[i]);
            index += 1;
        }
    }

    // 转换16进制数组为ASCII字符串   product
    sprintf(qrcode_protocol + index * 2, "%02X%02X", Qcode.product.cmd, Qcode.product.len);
    index += 2;
    for (int i = 0; i < Qcode.product.len; i++)
    {

        // if(Qcode.product.product[i] != '0')
        { // 这里产品id为0也需要
            sprintf(qrcode_protocol + index * 2, "%02X", Qcode.product.product[i]);
            index += 1;
        }
    }

    // 转换16进制数组为ASCII字符串   time
    sprintf(qrcode_protocol + index * 2, "%02X%02X", Qcode.time.cmd, Qcode.time.len);
    index += 2;

    for (int i = 0; i < Qcode.time.len; i++)
    {

        // if(Qcode.time.time[i] != '0')
        { // 这里时间为0也需要
            sprintf(qrcode_protocol + index * 2, "%02X", Qcode.time.time[i]);
            index += 1;
        }
    }

    strcpy(result, str_https);
    strcat(result, qrcode_protocol);
    // ESP_LOGW(LOG_TAG,"二维码信息：%s",result);
}

// 函数用于查找字节序列在数组中出现的次数，并返回出现位置的索引
int findByteSequence(const u8 *array, int arraySize, const u8 *sequence, int sequenceSize, int **positions)
{
    int count = 0;
    int *indices = NULL;

    for (int i = 0; i <= arraySize - sequenceSize; i++)
    {
        // 检查当前位置开始的字节序列是否与目标序列匹配
        int j;
        for (j = 0; j < sequenceSize; j++)
        {
            if (array[i + j] != sequence[j])
            {
                break; // 不匹配，跳出循环
            }
        }

        if (j == sequenceSize)
        {
            count++; // 找到匹配的序列

            // 记录匹配位置的索引
            int *temp = (int *)realloc(indices, count * sizeof(int));
            if (temp == NULL)
            {
                // 内存分配失败，处理错误
                if (indices != NULL)
                {
                    free(indices);
                }
                return -1;
            }
            indices = temp;
            indices[count - 1] = i;
        }
    }

    *positions = indices; // 传递匹配位置的索引数组
    return count;
}

// 匹配mac地址是否为本机
bool mac_is_true(uint8_t *mac)
{

    if (
        (mac[0] == Machine_info.mac_addr[0]) &&
        (mac[1] == Machine_info.mac_addr[1]) &&
        (mac[2] == Machine_info.mac_addr[2]) &&
        (mac[3] == Machine_info.mac_addr[3]) &&
        (mac[4] == Machine_info.mac_addr[4]) &&
        (mac[5] == Machine_info.mac_addr[5]))
    {
        return true;
    }

    return false;
}

bool subcontract(YC_DATA_T *data)
{

    int rsp_msgid = 0;

    int index = 0;
    int all_len = data->len;
    uint8_t *buf = data->data;
    USE_DATA_T use_data;

    bool refresh_flag = false;
#if 1

    u8 targetSequence[] = {0x5A, 0x51};
    int sequenceSize = sizeof(targetSequence);

    int *positions = NULL;
    int result = findByteSequence(buf, all_len, targetSequence, sequenceSize, &positions);

    if (result > 1)
    {
        int data_len = 0;
        data_len = (buf[0] << 8) | (buf[1]);
        printf("cmd 5A 51 find times %d,all data len = %d\r\n", result, data_len);
    }

    if (result == 1)
    {
        printf("cmd 5A 51 find times %d,data len = %d\r\n", result, data->len);
        for (int index = 0; index < result; index++)
        {
            if ((buf[0] == 0x5A) && (buf[1] == 0x51) && (result == 1))
            {
                // 单条命令处理逻辑

                use_data.data_len = all_len; //(((buf[positions[index] - 2])<<8) | ((buf[positions[index] - 1])))+2;
                memcpy(use_data.data_buf, data->data, use_data.data_len);
#if 0
                printf("single cmd len =%d\r\n",use_data.data_len);
                for(int i = 0;i<use_data.data_len;i++)
                {
                    printf("%02X",use_data.data_buf[i]);
                }
                printf("\r\n");
#endif
                bool is = mac_is_true(&use_data.data_buf[3]);

                if (is)
                {
                    business_logic_func(&use_data, USE_CMD_LEN_INDEX - 2, 0);
                    refresh_flag = true;
                }
                else
                {
                    printf("mac is fail not deal\r\n");
                }
            }
            else
            {

                rsp_msgid = (buf[13] << 8) | buf[14]; // 获取当前消息id 用于删除

                printf("rsp_msgid %02x,%02x,%d\r\n", buf[13], buf[14], rsp_msgid);

                for (int index = 0; index < result; index++)
                {
                    // 多条指令处理逻辑

                    bool is = mac_is_true(&buf[positions[index] + 3]);
                    if (is)
                    {
                        use_data.data_len = (((buf[positions[index] - 2]) << 8) | ((buf[positions[index] - 1]))) + 2;
                        memcpy(use_data.data_buf, data->data + (positions[index] - 2), use_data.data_len);
                        // print_yc_data(&use_data);
                        business_logic_func(&use_data, USE_CMD_LEN_INDEX, rsp_msgid);
                        refresh_flag = true;
                    }
                    else
                    {
                        printf("mac is fail not deal\r\n");
                    }
                }

                // if(is_rsp_ack)
                {
                    reply_ack_func(0x00, rsp_msgid, true, NULL); // 回复ack
                    spiffs_write(&Machine_info);
                    ESP_LOGE(LOG_TAG, "1times  cmd = %02X  msg = %X start reply ack\r\n", 0x00, rsp_msgid);
                }
            }
        }
    }

    if (result > 1)
    {

        printf("not single cmd len =%d\r\n", use_data.data_len);

        rsp_msgid = (buf[13] << 8) | buf[14]; // 获取当前消息id 用于删除;
        ESP_LOGW(LOG_TAG, "--rsp_msgid %02x,%02x,%d\r\n", buf[13], buf[14], rsp_msgid);

        for (int index = 0; index < result; index++)
        {
            // 多条指令处理逻辑

            bool is = mac_is_true(&buf[positions[index] + 3]);
            if (is)
            {
                use_data.data_len = 15 + 2 + (((buf[positions[index] + 13]) << 8) | ((buf[positions[index] + 14])));

                use_data.data_buf[0] = 0x00;
                use_data.data_buf[1] = 0x00;

                memcpy(&use_data.data_buf[2], data->data + (positions[index]), use_data.data_len + 15);

                // printf("================last result============== len =%d\r\n",use_data.data_len);
                //     for(int i = 0;i<use_data.data_len;i++)
                //     {
                //             printf("%02x",use_data.data_buf[i]);
                //     }
                //     printf("================last result==============\r\n");

                //  print_yc_data(&use_data);
                business_logic_func(&use_data, USE_CMD_LEN_INDEX, rsp_msgid);
                refresh_flag = true;
            }
            else
            {
                printf("mac is fail not deal\r\n");
            }
        }
        // if(is_rsp_ack)
        {
            reply_ack_func(0x00, rsp_msgid, true, NULL); // 回复ack
            spiffs_write(&Machine_info);
            ESP_LOGE(LOG_TAG, "cmd = %02X  msg = %X start reply ack\r\n", 0x00, rsp_msgid);
        }
    }

#if 0
    u8 targetSequence1[] = {0x55, 0x51};
    int sequenceSize1 = sizeof(targetSequence);

    int* positions1 = NULL;
     result = findByteSequence(buf, all_len, targetSequence1, sequenceSize1, &positions1);

    if(result!=0)
    {
        printf("ack 55 51 find time %d\r\n", result);
    }

      for(int index = 0;index<result;index++)
    {
        //use_data.data_len =(((buf[positions[index] - 2])<<8) | ((buf[positions[index] - 1])))+2;
        //memcpy(use_data.data_buf,data->data + (positions[index] -2) ,use_data.data_len);
        //print_yc_data(&use_data);
        use_data.data_len = all_len;
        memcpy(use_data.data_buf,data->data + (positions1[index]) ,use_data.data_len);
        business_ack_func(&use_data);
        //refresh_flag =true;
    }
#endif

    // #if 1

    //       for (int i = 0; i < all_len; i++)
    //         {
    //             printf("%02x",buf[i]);
    //         }

    // #endif

    free(positions);

// free(positions1);
#if 0
    printf("index:");
    if (result > 0) {
        //printf("出现的位置索引：");
        for (int i = 0; i < result; i++) {
            printf("%d,", positions[i]);
        }
        printf("\n");
       
    }
#endif

#else
    while (all_len > 0)
    {
        // ESP_LOGW(LOG_TAG,"-->[%d]",all_len);
        // for(int i=0;i<all_len;i++)
        // {
        //     printf("%02x ",data->data[i]);
        // }
        // printf("\n");
        if (((buf[index + 2]) == 0x5A) && ((buf[index + 3]) == 0x51))
        {
            use_data.data_len = (((buf[index]) << 8) | ((buf[index + 1]))) + 2;
            memcpy(use_data.data_buf, data->data + index, use_data.data_len);
            all_len -= (use_data.data_len);
            index += (use_data.data_len);
            // print_yc_data(&use_data);
            business_logic_func(&use_data);
            refresh_flag = true;
        }
        else
        {
            all_len--;
            index++;
            // ESP_LOGE(LOG_TAG,"err:data");
            // break;
        }
    }
#endif

    return refresh_flag;
}

// len：有效数据长度，不是总长//
static void protocol_package(char cmd, const uint8_t *info, int len)
{
#define __PACKAGE 15
    uint8_t *__str = (uint8_t *)malloc(sizeof(uint8_t) * (__PACKAGE + len) * 2);

    __str[0] = 0x5a;
    __str[1] = 0x51;

    __str[2] = 0x00;

    __str[3] = mac_addr[0];
    __str[4] = mac_addr[1];
    __str[5] = mac_addr[2];
    __str[6] = mac_addr[3];
    __str[7] = mac_addr[4];
    __str[8] = mac_addr[5];

    __str[9] = Machine_info.eflagID;

    __str[10] = cmd;
#if 0
    __str[11] = 0x01;//当前只为一包
    __str[12] = 0x01;//当前只为一包
#else

    // 随机数
    srand((unsigned int)time(NULL));
    int time_rand = rand() % 65535 + 1; // 生成1~100的随机数
    __str[11] = (time_rand >> 8) & 0xFF;
    __str[12] = time_rand & 0xFF;
#endif
    // 分包
    __str[13] = (len >> 8) & 0xFF;
    __str[14] = len & 0xFF;

    memcpy(__str + __PACKAGE, info, len);
    int i = 0, sum = 0;
    for (i = 0; i < len + __PACKAGE; i++)
    {
        sum += __str[i];
    }
    __str[2] = sum & 0xFF;

    printf("crc=%02x ", __str[2]);

    printf("-->package:");
    for (i = 0; i < len + __PACKAGE; i++)
    {
        printf("%02x ", __str[i]);
    }
    printf("\n");

    changebintotxt(__str, len + __PACKAGE);

#if 0
    Send_list = postInsert(Send_list, time_rand,cmd,(char *)__str,(int)(len+__PACKAGE)*2);//len*2
#else
    lora_send_data((char *)__str, len + __PACKAGE);
#endif
    free(__str);
}

int txttobin(uint8_t *strlorabuf)
{
    int len = 0, i = 0;
    uint8_t strbuf[1024];
    char ch = 0, chhi = 0, chlo = 0;
    len = strlen((char *)strlorabuf);
    strcpy((char *)strbuf, (char *)strlorabuf);
    memset(strlorabuf, 0, len);
    // Serial.print("jiexishuju:");Serial.println((char *)strbuf);
    for (i = 0; i < len; i++)
    {

        ch = strbuf[i * 2];
        if ((ch >= 0x30 && ch <= 0x39) ||
            (ch >= 0x41 && ch <= 0x5a) ||
            (ch >= 0x61 && ch <= 0x7a))
        {
            {
                if (ch >= 0x30 && ch <= 0x39)
                    ch = ch - 0x30;
                else if (ch >= 0x41 && ch <= 0x5a)
                    ch = ch - 0x37;
                else
                    ch = ch - 0x57;
                ch &= 0x000f;
                chhi = (ch << 4);
            }
            ch = strbuf[i * 2 + 1];
            if ((ch >= 0x30 && ch <= 0x39) ||
                (ch >= 0x41 && ch <= 0x5a) ||
                (ch >= 0x61 && ch <= 0x7a))
            {
                if (ch >= 0x30 && ch <= 0x39)
                    ch = ch - 0x30;
                else if (ch >= 0x41 && ch <= 0x5a)
                    ch = ch - 0x37;
                else
                    ch = ch - 0x57;
                ch &= 0x000f;
                ch = chhi + ch;
            }
            strlorabuf[i] = ch;
        }
    }
    // Serial.write(strlorabuf,len);
    return i;
}
void changebintotxt(uint8_t *strb, int len)
{
    int i = 0;
    uint8_t strtxt[512];
    char ch, chhi, chlo;
    memset(strtxt, 0, 512);
    for (i = 0; i < len; i++)
    {
        ch = strb[i];
        chhi = ch;
        chhi >>= 4;
        chhi &= 0x000f;
        if (chhi <= 9)
            chhi += 0x30;
        else
            chhi += 0x37;
        strtxt[i * 2] = chhi;
        chlo = ch;
        chlo &= 0x000f;
        if (chlo <= 9)
            chlo += 0x30;
        else
            chlo += 0x37;
        strtxt[i * 2 + 1] = chlo;
    }
    strcpy((char *)strb, (char *)strtxt);
}

void f_send_get_chart_data(void)
{

    uint8_t strlorabuf[200];

    int crc16 = 0, i = 0, len = 0;

    strlorabuf[0] = 0x5A;
    strlorabuf[1] = 0x51; // 包头
    strlorabuf[2] = 0x00; // 校验和

    strlorabuf[3] = mac_addr[0];
    strlorabuf[4] = mac_addr[1];
    strlorabuf[5] = mac_addr[2];
    strlorabuf[6] = mac_addr[3];
    strlorabuf[7] = mac_addr[4];
    strlorabuf[8] = mac_addr[5];
    strlorabuf[9] = Machine_info.eflagID; // 组内编号
    strlorabuf[10] = 0x11;                // cmd命令字

    Machine_info.msg_id = allocateMsgIdNum();             // 分配ID
    strlorabuf[11] = ((Machine_info.msg_id) >> 8) & 0XFF; //
    strlorabuf[12] = ((Machine_info.msg_id) >> 0) & 0XFF; // 总包数，当前包数

    strlorabuf[13] = 0x00;
    strlorabuf[14] = 0x00; // 长度
    strlorabuf[15] = 0;

    crc16 = strlorabuf[0] + strlorabuf[1];
    for (i = 3; i < 15; i++)
        crc16 = crc16 + strlorabuf[i];
    strlorabuf[2] = crc16 & 0xff;

    changebintotxt(strlorabuf, 15);
    // Serial.println((char *)strlorabuf);
    strcat((char *)strlorabuf, (char *)Machine_info.cid);
    len = strlen((char *)strlorabuf);

    // lora_send_data((char *)strlorabuf,len);
    Send_list = postInsert(Send_list, Machine_info.msg_id, Machine_info.msg_id, (char *)strlorabuf, len); // 插入数据
}
void f_send_version(void)
{

    ESP_LOGW(LOG_TAG, "f_send_version");
    uint8_t strlorabuf[200];

    int crc16 = 0, i = 0, len = 0;

    strlorabuf[0] = 0x5A;
    strlorabuf[1] = 0x51; // 包头
    strlorabuf[2] = 0x00; // 校验和

    strlorabuf[3] = mac_addr[0];
    strlorabuf[4] = mac_addr[1];
    strlorabuf[5] = mac_addr[2];
    strlorabuf[6] = mac_addr[3];
    strlorabuf[7] = mac_addr[4];
    strlorabuf[8] = mac_addr[5];
    strlorabuf[9] = Machine_info.eflagID; // 组内编号
    strlorabuf[10] = 0x91;                // cmd命令字

    Machine_info.msg_id = allocateMsgIdNum();             // 分配ID
    strlorabuf[11] = ((Machine_info.msg_id) >> 8) & 0XFF; //
    strlorabuf[12] = ((Machine_info.msg_id) >> 0) & 0XFF; // 总包数，当前包数

    strlorabuf[13] = 0x00;
    strlorabuf[14] = 0x03; // 长度
    strlorabuf[15] = (VERSION_X) & 0xff;
    strlorabuf[16] = (VERSION_Y) & 0xff;
    strlorabuf[17] = (VERSION_Z) & 0xff;
    strlorabuf[18] = 0;

    crc16 = strlorabuf[0] + strlorabuf[1];
    for (i = 3; i < 18; i++)
        crc16 = crc16 + strlorabuf[i];
    strlorabuf[2] = crc16 & 0xff;

    changebintotxt(strlorabuf, 18);
    // Serial.println((char *)strlorabuf);
    strcat((char *)strlorabuf, (char *)Machine_info.cid);
    len = strlen((char *)strlorabuf);

    Send_list = postInsert(Send_list, Machine_info.msg_id, Machine_info.msg_id, (char *)strlorabuf, len); // 插入数据
}
void f_send_lora_rssi(int rssi)
{

    // ESP_LOGW(LOG_TAG,"f_send_lora_rssi:rssi = %d",rssi);
    uint8_t strlorabuf[200];

    int crc16 = 0, i = 0, len = 0;

    strlorabuf[0] = 0x5A;
    strlorabuf[1] = 0x51; // 包头
    strlorabuf[2] = 0x00; // 校验和

    strlorabuf[3] = mac_addr[0];
    strlorabuf[4] = mac_addr[1];
    strlorabuf[5] = mac_addr[2];
    strlorabuf[6] = mac_addr[3];
    strlorabuf[7] = mac_addr[4];
    strlorabuf[8] = mac_addr[5];
    strlorabuf[9] = Machine_info.eflagID; // 组内编号
    strlorabuf[10] = 0x05;                // cmd命令字

    Machine_info.msg_id = allocateMsgIdNum();             // 分配ID
    strlorabuf[11] = ((Machine_info.msg_id) >> 8) & 0XFF; //
    strlorabuf[12] = ((Machine_info.msg_id) >> 0) & 0XFF; // 总包数，当前包数

    strlorabuf[13] = 0x00;
    strlorabuf[14] = 0x01; // 长度
    strlorabuf[15] = (rssi) & 0xff;
    strlorabuf[16] = 0;

    crc16 = strlorabuf[0] + strlorabuf[1];
    for (i = 3; i < 16; i++)
        crc16 = crc16 + strlorabuf[i];
    strlorabuf[2] = crc16 & 0xff;

    changebintotxt(strlorabuf, 16);
    // Serial.println((char *)strlorabuf);
    strcat((char *)strlorabuf, (char *)Machine_info.cid);
    len = strlen((char *)strlorabuf);

    Send_list = postInsert(Send_list, Machine_info.msg_id, Machine_info.msg_id, (char *)strlorabuf, len); // 插入数据
}

void f_send_battary_vaule(int battry)
{

    uint8_t strlorabuf[200];

    int crc16 = 0, i = 0, len = 0;

    strlorabuf[0] = 0x5A;
    strlorabuf[1] = 0x51; // 包头
    strlorabuf[2] = 0x00; // 校验和

    strlorabuf[3] = mac_addr[0];
    strlorabuf[4] = mac_addr[1];
    strlorabuf[5] = mac_addr[2];
    strlorabuf[6] = mac_addr[3];
    strlorabuf[7] = mac_addr[4];
    strlorabuf[8] = mac_addr[5];
    strlorabuf[9] = Machine_info.eflagID; // 组内编号
    strlorabuf[10] = 0x04;                // cmd命令字

    Machine_info.msg_id = allocateMsgIdNum();             // 分配ID
    strlorabuf[11] = ((Machine_info.msg_id) >> 8) & 0XFF; //
    strlorabuf[12] = ((Machine_info.msg_id) >> 0) & 0XFF; // 总包数，当前包数

    strlorabuf[13] = 0x00;
    strlorabuf[14] = 0x01; // 长度
    strlorabuf[15] = (battry) & 0xff;
    strlorabuf[16] = 0;

    crc16 = strlorabuf[0] + strlorabuf[1];
    for (i = 3; i < 16; i++)
        crc16 = crc16 + strlorabuf[i];
    strlorabuf[2] = crc16 & 0xff;

    changebintotxt(strlorabuf, 16);
    // Serial.println((char *)strlorabuf);
    strcat((char *)strlorabuf, (char *)Machine_info.cid);
    len = strlen((char *)strlorabuf);

    Send_list = postInsert(Send_list, Machine_info.msg_id, Machine_info.msg_id, (char *)strlorabuf, len); // 插入数据
}

void f_send_reply_status(int status)
{

    uint8_t strlorabuf[200];

    int crc16 = 0, i = 0, len = 0;

    strlorabuf[0] = 0x5A;
    strlorabuf[1] = 0x51; // 包头
    strlorabuf[2] = 0x00; // 校验和

    strlorabuf[3] = mac_addr[0];
    strlorabuf[4] = mac_addr[1];
    strlorabuf[5] = mac_addr[2];
    strlorabuf[6] = mac_addr[3];
    strlorabuf[7] = mac_addr[4];
    strlorabuf[8] = mac_addr[5];
    strlorabuf[9] = Machine_info.eflagID; // 组内编号
    strlorabuf[10] = 0x06;                // cmd命令字

    Machine_info.msg_id = allocateMsgIdNum();             // 分配ID
    strlorabuf[11] = ((Machine_info.msg_id) >> 8) & 0XFF; //
    strlorabuf[12] = ((Machine_info.msg_id) >> 0) & 0XFF; // 总包数，当前包数

    strlorabuf[13] = 0x00;
    strlorabuf[14] = 0x01; // 长度
    strlorabuf[15] = (status) & 0xff;
    strlorabuf[16] = 0;

    crc16 = strlorabuf[0] + strlorabuf[1];
    for (i = 3; i < 16; i++)
        crc16 = crc16 + strlorabuf[i];
    strlorabuf[2] = crc16 & 0xff;

    changebintotxt(strlorabuf, 16);
    // Serial.println((char *)strlorabuf);
    strcat((char *)strlorabuf, (char *)Machine_info.cid);
    len = strlen((char *)strlorabuf);

    Send_list = postInsert(Send_list, Machine_info.msg_id, Machine_info.msg_id, (char *)strlorabuf, len); // 插入数据
}

// 唤醒时发送是否可以接收数据命令
void send_can_I_receive()
{
    printf("->can i\n");
    uint8_t strlorabuf[200];
    strlorabuf[0] = 0x5A;
    strlorabuf[1] = 0x51;
    strlorabuf[2] = 0x51;
    strlorabuf[3] = 0x5A;
    strlorabuf[4] = 0x00;
#if 0
     strlorabuf[5] = 0x01;
#else
    strlorabuf[5] = Machine_info.eflagID;

    if (Send_list != NULL)
    {
        strlorabuf[6] = 0x01;
    }
    else
    {
        strlorabuf[6] = 0x00;
    }

    strlorabuf[7] = Machine_info.mac_addr[0];
    strlorabuf[8] = Machine_info.mac_addr[1];
    strlorabuf[9] = Machine_info.mac_addr[2];
    strlorabuf[10] = Machine_info.mac_addr[3];
    strlorabuf[11] = Machine_info.mac_addr[4];
    strlorabuf[12] = Machine_info.mac_addr[5];

    int crc = 0;

    for (int i = 0; i < 13; i++)
    {
        crc += strlorabuf[i];
    }

    strlorabuf[13] = crc & 0xff;

#endif
    // send_lora_data(strlorabuf,len);  //不直接发送
    lora_send_data((char *)strlorabuf, 14);
}

// 发送是否可以接收数据命令
//  void send_pair_ack()
//  {
//       uint8_t strlorabuf[200];
//       strlorabuf[0] = 0x5A;
//       strlorabuf[1] = 0x51;
//       strlorabuf[2] = 0x51;
//       strlorabuf[3] = 0x5A;
//       strlorabuf[4] = 0x00;
//       #if 0
//       strlorabuf[5] = 0x01;
//       #else
//       strlorabuf[5] = Machine_info.eflagID;
//       strlorabuf[6] = lora_channel + 1;
//       #endif
//       //send_lora_data(strlorabuf,len);  //不直接发送
//       lora_send_data((char *)strlorabuf,7);
//  }

void send_rssi(void)
{
    char rssi = Machine_info.rssi;
#if 0
    protocol_package(0x05,&rssi,1);
#else

    f_send_lora_rssi(rssi);
#endif
}
// 4bytes、32bit数据大小端转化
#define L2B32(Little) (Little = ((Little & 0xff) << 24) | (((Little) & 0xff00) << 8) | (((Little) & 0xff0000) >> 8) | ((Little >> 24) & 0xff))

uint8_t change_btn_reversal(uint8_t reversal_btn) // lora收到按键，转化为本地状态
{
    uint8_t btn_tmp = 0;
    switch (reversal_btn)
    {
    case 0:
        btn_tmp = 1;
        break;
    case 1:
        btn_tmp = 6;
        break;
    case 2:
        btn_tmp = 4;
        break;
    case 3:
        btn_tmp = 3;
        break;
    case 4:
        btn_tmp = 5;
        break;
    case 5:
        btn_tmp = 2;
        break;
        break;
    default:
        btn_tmp = 1;
        break;
    }

    return btn_tmp;
}
uint8_t change_btn(uint8_t btn)
{
    uint8_t btn_tmp = 0;
    switch (btn)
    {
    case 1:
        btn_tmp = 0;
        break;
    case 2:
        btn_tmp = 5;
        break;
    case 3:
        btn_tmp = 3;
        break;
    case 4:
        btn_tmp = 2;
        break;
    case 5:
        btn_tmp = 4;
        break;
    case 6:
        btn_tmp = 1;
        break;
    default:
        btn_tmp = 0;
        break;
    }
    // ESP_LOGW(LOG_TAG,"btn = [%d] ,btn_tmp[%d]",btn,btn_tmp);
    return btn_tmp;
}
/*发送状态持续的时间  状态持续时长(0x0E)*/
void send_status_duration(void)
{
#if 0
    uint8_t* dur = (uint8_t*)malloc(sizeof(uint8_t)*(12));

    memcpy(dur,&last_button_info.button_info,1);
    memcpy(dur+1,&last_button_info.Year,2);
    memcpy(dur+3,&last_button_info.Month,1);
    memcpy(dur+4,&last_button_info.Day,1);
    memcpy(dur+5,&last_button_info.Hour,1);
    memcpy(dur+6,&last_button_info.Minute,1);
    memcpy(dur+7,&last_button_info.Second,1);

    uint32_t tmp = last_button_info.time_min;
    L2B32(tmp);
    memcpy(dur+8,&tmp,4);

    ESP_LOGW(LOG_TAG,"log  -->btn = %d [%d-%d-%d]%d:%d:%d   <%04ld>",\
                    last_button_info.button_info, last_button_info.Year,\
                    last_button_info.Month,last_button_info.Day,\
                    last_button_info.Hour, last_button_info.Minute,\
                    last_button_info.Second,last_button_info.time_min);

    protocol_package(0x0E,dur,12);
    last_button_info.time_min = 0;
    free(dur);
#else

    uint8_t strlorabuf[200];

    int crc16 = 0, i = 0, len = 0;

    // 帧头
    strlorabuf[0] = 0x5A; // 包头
    strlorabuf[1] = 0x51; // 包头
    strlorabuf[2] = 0x00; // 校验和

    strlorabuf[3] = mac_addr[0];
    strlorabuf[4] = mac_addr[1];
    strlorabuf[5] = mac_addr[2];
    strlorabuf[6] = mac_addr[3];
    strlorabuf[7] = mac_addr[4];
    strlorabuf[8] = mac_addr[5];
    strlorabuf[9] = Machine_info.eflagID; // 组内编号
    strlorabuf[10] = 0x0E;                // cmd命令字

    Machine_info.msg_id = allocateMsgIdNum();             // 分配ID
    strlorabuf[11] = ((Machine_info.msg_id) >> 8) & 0XFF; //
    strlorabuf[12] = ((Machine_info.msg_id) >> 0) & 0XFF; // 总包数，当前包数

    strlorabuf[13] = 0x00;
    strlorabuf[14] = 0x0C; // 长度

    uint8_t tmp = change_btn(Machine_info.last_button.button_info);
    strlorabuf[15] = tmp; // 上一次的状态

    if ((Machine_info.last_button.Year == 0x00) && (Machine_info.last_button.Month == 0x00) && (Machine_info.last_button.Day == 0x00))
    {

        strlorabuf[16] = 0x00;
        strlorabuf[17] = 0x00;
        strlorabuf[18] = 0x00;
        strlorabuf[19] = 0x00;
        strlorabuf[20] = 0x00;
        strlorabuf[21] = 0x00;
        strlorabuf[22] = 0x00;

        printf("time is not sync\r\n");
    }
    else
    {
        strlorabuf[16] = (Machine_info.last_button.Year >> 8) & 0xff;
        strlorabuf[17] = Machine_info.last_button.Year & 0xff;
        strlorabuf[18] = Machine_info.last_button.Month;
        strlorabuf[19] = Machine_info.last_button.Day;
        strlorabuf[20] = Machine_info.last_button.Hour;
        strlorabuf[21] = Machine_info.last_button.Minute;
        strlorabuf[22] = Machine_info.last_button.Second;
    }

    strlorabuf[23] = (Machine_info.Duration_time >> 24) & 0xff; // 分钟计算
    strlorabuf[24] = (Machine_info.Duration_time >> 16) & 0xff;
    strlorabuf[25] = (Machine_info.Duration_time >> 8) & 0xff;
    strlorabuf[26] = (Machine_info.Duration_time) & 0xff;
    strlorabuf[27] = 0;

    crc16 = strlorabuf[0] + strlorabuf[1];
    for (i = 3; i < 27; i++)
        crc16 = crc16 + strlorabuf[i];
    strlorabuf[2] = crc16 & 0xff;
    // ESP_LOGE(LOG_TAG,"{cmd:0e}send_status_duration btn -->[%d] -->Duration_time = %ld -->time :%d %d %d %d %d %d %d",strlorabuf[15],Machine_info.Duration_time,strlorabuf[16],strlorabuf[17],strlorabuf[18],strlorabuf[19],strlorabuf[20],strlorabuf[21],strlorabuf[22]);

    changebintotxt(strlorabuf, 27);

    // printf("Machine_info cid %s\r\n",Machine_info.cid);

    strcat((char *)strlorabuf, (char *)Machine_info.cid);
    len = strlen((char *)strlorabuf);

#if 0
  lora_send_data((char *)strlorabuf,len);

#else

    // printList(Send_list);

    Send_list = postInsert(Send_list, Machine_info.msg_id, Machine_info.msg_id, (char *)strlorabuf, len); // 插入数据

#endif

    // lora_send_data((char *)strlorabuf,len);

    last_button_info.time_min = 0;

#endif
}

/*当前最新的状态*/
void send_update_status(void)
{

#if 0
    uint8_t* update = (uint8_t*)malloc(sizeof(uint8_t)*(12));
    memset(&new_button_info,0,sizeof(Button_Time_t));
    new_button_info.Year = Machine_info.year;
    new_button_info.Month = Machine_info.month;
    new_button_info.Day = Machine_info.day;
    new_button_info.Hour = Machine_info.hour;
    new_button_info.Minute = Machine_info.min;
    new_button_info.Second = Machine_info.sec;
    new_button_info.time_min = 0;


    memcpy(update,&last_button_info.button_info,1);
    memcpy(update+1,&new_button_info.Year,2);
    memcpy(update+3,&new_button_info.Month,1);
    memcpy(update+4,&new_button_info.Day,1);
    memcpy(update+5,&new_button_info.Hour,1);
    memcpy(update+6,&new_button_info.Minute,1);
    memcpy(update+7,&new_button_info.Second,1);
    memcpy(update+8,&new_button_info.time_min,4);

    protocol_package(0x0F,update,12);
    free(update);
#else

    // memset(&Machine_info.current_button,0,sizeof(Button_Time_t));

    Machine_info.current_button.Year = Machine_info.year;
    Machine_info.current_button.Month = Machine_info.month;
    Machine_info.current_button.Day = Machine_info.day;
    Machine_info.current_button.Hour = Machine_info.hour;
    Machine_info.current_button.Minute = Machine_info.min;
    Machine_info.current_button.Second = Machine_info.sec;
    Machine_info.current_button.time_min = 0;

    uint8_t strlorabuf[200];

    int crc16 = 0, i = 0, len = 0;

    // 帧头                                目标地址           源地址(id)           长度              模式                具体内容 	              校验
    strlorabuf[0] = 0x5A;
    strlorabuf[1] = 0x51; // 包头
    strlorabuf[2] = 0x00; // 校验和

    strlorabuf[3] = mac_addr[0];
    strlorabuf[4] = mac_addr[1];
    strlorabuf[5] = mac_addr[2];
    strlorabuf[6] = mac_addr[3];
    strlorabuf[7] = mac_addr[4];
    strlorabuf[8] = mac_addr[5];

    strlorabuf[9] = Machine_info.eflagID; // 组内编号

    strlorabuf[10] = 0x0F; // cmd命令字

    Machine_info.msg_id = allocateMsgIdNum();             // 分配ID
    strlorabuf[11] = ((Machine_info.msg_id) >> 8) & 0XFF; //
    strlorabuf[12] = ((Machine_info.msg_id) >> 0) & 0XFF; // 总包数，当前包数

    strlorabuf[13] = 0x00;

    strlorabuf[14] = 0x0C; // 长度

    uint8_t tmp = change_btn(Machine_info.current_button.button_info);

    strlorabuf[15] = tmp; // 当前的状态

    if ((Machine_info.current_button.Year == 0x00) && (Machine_info.current_button.Month == 0x00) && (Machine_info.current_button.Day == 0x00))
    {

        strlorabuf[16] = 0x00;
        strlorabuf[17] = 0x00;
        strlorabuf[18] = 0x00;
        strlorabuf[19] = 0x00;
        strlorabuf[20] = 0x00;
        strlorabuf[21] = 0x00;
        strlorabuf[22] = 0x00;

        printf("time is not sync\r\n");
    }
    else
    {
        strlorabuf[16] = (Machine_info.current_button.Year >> 8) & 0xff;
        strlorabuf[17] = Machine_info.current_button.Year & 0xff;
        strlorabuf[18] = Machine_info.current_button.Month;
        strlorabuf[19] = Machine_info.current_button.Day;
        strlorabuf[20] = Machine_info.current_button.Hour;
        strlorabuf[21] = Machine_info.current_button.Minute;
        strlorabuf[22] = Machine_info.current_button.Second;
    }

    strlorabuf[23] = (Machine_info.current_button.time_min >> 24) & 0xff; // 分钟计算
    strlorabuf[24] = (Machine_info.current_button.time_min >> 16) & 0xff;
    strlorabuf[25] = (Machine_info.current_button.time_min >> 8) & 0xff;
    strlorabuf[26] = Machine_info.current_button.time_min & 0xff;
    strlorabuf[27] = 0;
    // ESP_LOGE(LOG_TAG,"@@send_update_status -->btn = [%d] -->time :%d %d %d %d %d %d %d",strlorabuf[15],strlorabuf[16],strlorabuf[17],strlorabuf[18],strlorabuf[19],strlorabuf[20],strlorabuf[21],strlorabuf[22]);

    crc16 = strlorabuf[0] + strlorabuf[1];
    for (i = 3; i < 27; i++)
        crc16 = crc16 + strlorabuf[i];
    strlorabuf[2] = crc16 & 0xff;

    changebintotxt(strlorabuf, 27);

    //   printf("Machine_info cid %s\r\n",Machine_info.cid);

    strcat((char *)strlorabuf, (char *)Machine_info.cid);
    len = strlen((char *)strlorabuf);

#if 0
    lora_send_data((char *)strlorabuf,len);
#else
    Send_list = postInsert(Send_list, Machine_info.msg_id, Machine_info.msg_id, (char *)strlorabuf, len); // 插入数据

#endif

    Machine_info.last_button.time_min = 0;

#endif
}

void send_ACK(char cmd, bool flag)
{
    uint8_t ack = 0;
    if (flag)
        ack = 0x01;
    else
        ack = 0x00;
    protocol_package(cmd, &ack, 1);
}

void adc1_init(void)
{
    //-------------ADC Init---------------//
    adc_oneshot_unit_init_cfg_t init_config = {
        .unit_id = ADC_UNIT_1,
        .ulp_mode = ADC_ULP_MODE_DISABLE,
    };
    ESP_ERROR_CHECK(adc_oneshot_new_unit(&init_config, &adc1_handle));
}
// void set_status_heights(void)
// {
//     extern uint32_t arr_heights[10];
//     memcpy(&_0703_button_info,&last_button_info,sizeof(Button_Time_t));
//     switch (_0703_button_info.button_info)
//     {
//         case 0:
//         case 1://yunxing
//             arr_heights[0]+=1;
//         break;
//         case 2://tingji
//             arr_heights[1]+=1;
//         break;
//         case 3://guzhang
//             arr_heights[2]+=1;
//         break;
//         case 4://fengcun
//             arr_heights[3]+=1;
//         break;
//         case 5://baoyang
//             arr_heights[4]+=1;
//         break;
//         case 6://dailiao
//             arr_heights[5]+=1;
//         break;
//         default:

//         break;
//     }
//     // ESP_LOGE(LOG_TAG,"button_info = %d ,time_min = %ld ---%ld - %ld - %ld - %ld - %ld - %ld",
//     //                 _0703_button_info.button_info,_0703_button_info.time_min,
//     //                 arr_heights[0],arr_heights[1],arr_heights[2],
//     //                 arr_heights[3],arr_heights[4],arr_heights[5]);
// }
void set_status_heights(void)
{
    //     STATE_OPERATION             = 1,        //运行
    // STATE_SHUT_DOWN             = 2,        //停机
    // STATE_BREAKDOWN             = 3,        //故障
    // STATE_SAFEKEEP              = 4,        //封存
    // STATE_UPKEEP                = 5,        //保养
    // STATE_WAIT_MATERIALS        = 6,        //待料
    extern uint32_t arr_heights[10];
    switch (Machine_info.last_button.button_info)
    {
    case 0:
    case 1: // yunxing
        arr_heights[0] += Machine_info.Duration_time;
        break;
    case 2: // tingji
        arr_heights[1] += Machine_info.Duration_time;
        break;
    case 3: // guzhang
        arr_heights[2] += Machine_info.Duration_time;
        break;
    case 4: // fengcun
        arr_heights[3] += Machine_info.Duration_time;
        break;
    case 5: // baoyang
        arr_heights[4] += Machine_info.Duration_time;
        break;
    case 6: // dailiao
        arr_heights[5] += Machine_info.Duration_time;
        break;
    default:

        break;
    }
    // ESP_LOGE(LOG_TAG,"button_info = %d ,time_min = %ld ---%ld - %ld - %ld - %ld - %ld - %ld",
    //                 _0703_button_info.button_info,_0703_button_info.time_min,
    //                 arr_heights[0],arr_heights[1],arr_heights[2],
    //                 arr_heights[3],arr_heights[4],arr_heights[5]);
}
// void periodic_timer_callback(void* arg)
// {
//     // if(++Machine_info.sec == 60)
//     // {
//     //     last_button_info.time_min+=1;
//     //     set_status_heights();
//     //     printf("time min ++\r\n");
//     //     printf("YEAR = %d,MONTH =%d,DAY=%d,HOUR=%d,MIN=%d,SEC =%d\r\n",
//     //     Machine_info.year,
//     //     Machine_info.month,
//     //     Machine_info.day,
//     //     Machine_info.hour,
//     //     Machine_info.min,
//     //     Machine_info.sec);

//     //     Machine_info.sec=0;
//     //     if(++Machine_info.min == 60)
//     //     {
//     //         Machine_info.min=0;
//     //         if(++Machine_info.hour == 24)
//     //         {
//     //             Machine_info.hour=0;
//     //             Machine_info.day++;

//     //             if(IS_FEB_MONTH && IS_LEAP_YEAR && IS_SMALL_MONTH && IS_BIG_MONTH)
//     //             {
//     //                 Machine_info.day=0;

//     //                 if(++Machine_info.month == 13)
//     //                 {
//     //                     Machine_info.month=1;
//     //                     Machine_info.year++;
//     //                 }
//     //             }
//     //         }
//     //     }
//     // }
// }

void lora_timer_callback(void *arg)
{
    ESP_LOGI(LOG_TAG, " lora_timer_callback");

    if (xQueueSend(yc_data_queue, &yc_data, 0) != true)
    {
        ESP_LOGE(LOG_TAG, "yc_data_queue send is fail");
    }
    yc_data.len = 0;
    yc_data.index = 0;
}
void timer_init(void)
{
    // const esp_timer_create_args_t periodic_timer_args = {
    //         .callback = &periodic_timer_callback,
    //         /* name is optional, but may help identify the timer when debugging */
    //         .name = "periodic"
    // };

    // ESP_ERROR_CHECK(esp_timer_create(&periodic_timer_args, &periodic_timer));
    // /* The timer has been created but is not running yet */

    // ESP_ERROR_CHECK(esp_timer_start_periodic(periodic_timer, 1*1000*1000));

    // lora timer
    const esp_timer_create_args_t lora_timer_args = {
        .callback = &lora_timer_callback,
        /* argument specified here will be passed to timer callback function */
        .name = "one-shot"};
    ESP_ERROR_CHECK(esp_timer_create(&lora_timer_args, &lora_timer));
}
// void yc_timer_restart(void)
// {
//     ESP_LOGI(LOG_TAG,"timer restart");
//     ESP_ERROR_CHECK(esp_timer_stop(periodic_timer));
//     ESP_ERROR_CHECK(esp_timer_start_periodic(periodic_timer, 1*1000*1000));
// }

void lora_timer_start(void)
{
    ESP_ERROR_CHECK(esp_timer_start_once(lora_timer, 500 * 1000)); // 500ms
}
void lora_tiemr_stop(void)
{
    ESP_ERROR_CHECK(esp_timer_stop(lora_timer));
}
void lora_timer_restart(void)
{
    ESP_ERROR_CHECK(esp_timer_stop(lora_timer));
    ESP_ERROR_CHECK(esp_timer_start_once(lora_timer, 500 * 1000)); // 500ms
}

#if 1

/*********************************************************************************
 * function   :   analysis_protocol
 * Description :  lora 接受数据解析函数
 * Input       :
 * Output      :
 * Author      :  祁鑫                  Data : 2023 9.18
 **********************************************************************************/
void analysis_protocol(char *result, int len)
{
    int index = 0;
    int length = 0;

    int count = len;

    int num = 0;

    while (count)
    {

        if (((result[index + 2]) == 0x5A) && ((result[index + 3]) == 0x51))
        {
            length = ((result[index]) << 8) | ((result[index + 1]));
            num++;
            printf("num =%d,length=%d\r\n", num, length);

#if 1
            for (int i = 0; i < length; i++)
            {
                printf("%02x", result[index + 2 + i]);
            }
#endif
            printf("\r\n");

            // 匹配mac地址    //计算校验和
            if (
                (Machine_info.mac_addr[0] == (result[index + 5])) &&
                (Machine_info.mac_addr[1] == (result[index + 6])) &&
                (Machine_info.mac_addr[2] == (result[index + 7])) &&
                (Machine_info.mac_addr[3] == (result[index + 8])) &&
                (Machine_info.mac_addr[4] == (result[index + 9])) &&
                (Machine_info.mac_addr[5] == (result[index + 10])))
            {

                // mac地址匹配
                printf("mac check ok\r\n");
                // packetparsing((unsigned char *)&result[index+2]);  //16进制解析数据
            }
            else
            {
                printf("mac = %02x%02x%02x%02x%02x%02x\r\n",
                       result[index + 5],
                       result[index + 6],
                       result[index + 7],
                       result[index + 8],
                       result[index + 9],
                       result[index + 10]);
                printf("device mac = %02x%02x%02x%02x%02x%02x\r\n",
                       Machine_info.mac_addr[0],
                       Machine_info.mac_addr[1],
                       Machine_info.mac_addr[2],
                       Machine_info.mac_addr[3],
                       Machine_info.mac_addr[4],
                       Machine_info.mac_addr[5]);
                // mac地址匹配
                printf("mac check fail\r\n");
            }
        }

        {
            index++;
        }

        count--;
    }
    // printf("num =%d\r\n",num);

#if 0
        if(left_display_refresh == true)
        {
          left_display_refresh = false;
                PIC_display((unsigned char *)dspbuf_left);
        }   
            reflashdfpr(dspbuf);
#endif
}

/*********************************************************************************
 * function   :   selectionSort
 * Description :  进行数据排序并输出排序后的数据 从小到大的索引
 * Input       :
 * Output      :
 * Author      :  祁鑫                  Data : 2023 8.12
 **********************************************************************************/
void selectionSort(int arr[], int n, int indices[])
{
    for (int i = 0; i < n - 1; i++)
    {
        int minIndex = i;
        for (int j = i + 1; j < n; j++)
        {
            if (arr[j] < arr[minIndex])
            {
                minIndex = j;
            }
        }

        // 交换元素
        int temp = arr[i];
        arr[i] = arr[minIndex];
        arr[minIndex] = temp;

        // 更新索引
        int tempIndex = indices[i];
        indices[i] = indices[minIndex];
        indices[minIndex] = tempIndex;
    }
}

/*********************************************************************************
 * function   :   person_get_num_is_exist
 * Description :  获取当前类型序号是否存在
 * Input       :
 * Output      :
 * Author      :  祁鑫                  Data : 2023 8.12
 **********************************************************************************/

int person_get_num_is_exist(uint8_t type, uint16_t num)
{
    //  uint8_t  index = 0;

    // printf("person_get_num_is_exist %d\r\n",num);

    if (type == person[type].person_type)
    {

        for (int i = 0; i < PERSON_MAX_NAME; i++)
        {
            if (person[type].person_name[i].person_num == num)
            {
                // printf("person_get_num is exist\r\n");
                return 1;
            }
        }
    }

    // printf("person_get_num not exist\r\n");
    return 0;
}

/*********************************************************************************
 * function   :   person_get_num
 * Description :  获取当前类型人员数量
 * Input       :
 * Output      :
 * Author      :  祁鑫                  Data : 2023 8.12
 **********************************************************************************/

int person_get_num(uint8_t type)
{
    uint8_t index = 0;
    // printf("person_get_num\r\n");
    if (type == person[type].person_type) // 管理员
    {

        // 查找当前不为空的字符串数组
        for (int i = 0; i < PERSON_MAX_NAME; i++)
        {
            if (strlen((char *)&person[type].person_name[i].person_name) != 0)
            {
                index++;
            }
        }
    }

    return index;
}
/*********************************************************************************
 * function   :   person_add
 * Description :  人员添加/更新
 * Input       :
 * Output      :
 * Author      :  祁鑫                  Data : 2023 8.12
 **********************************************************************************/

void person_add(uint8_t type, uint8_t num, char *in, char *out)
{
    // printf("person_add\r\n");
    if (type == person[type].person_type) // 管理员
    {
        uint8_t index = 0;

        // 查找当前不为空的字符串数组
        for (int i = 0; i < PERSON_MAX_NAME; i++)
        {
            // Serial.println(person[type].person_name[i].person_num);
            // 如果序号存在更新
            if (person[type].person_name[i].person_num == num)
            {
                // Serial.print("person_num exist = ");
                // Serial.println(person[type].person_name[i].person_num);
                index = i;
                break;
            }

            // 如果序号不存在添加
            if (strlen((char *)&person[type].person_name[i].person_name) == 0)
            {
                // Serial.print("person_num not exist = ");

                index = i;
                person[type].person_name[i].person_num = num;
                // Serial.println(person[type].person_name[i].person_num);
                break;
            }
        }
        if (index > PERSON_MAX_NAME)
        {
        }
        else
        {
            if (person[type].person_name[index].person_num == num)
            {
                memset(&person[type].person_name[index].person_name, 0x00, PERSON_NAME_MAX_LEN);
            }
            strcpy((char *)&person[type].person_name[index].person_name, in);
        }

        // Serial.println("show font");
        // 开始显示数据
        int sort_buffer[PERSON_MAX_NAME] = {0}; // 获取当前序号值

        int indices[PERSON_MAX_NAME]; // 排序后的索引值
        for (int i = 0; i < PERSON_MAX_NAME; i++)
        {
            indices[i] = i;
        }

        // 拷贝序号数据
        for (int i = 0; i < PERSON_MAX_NAME; i++)
        {
            sort_buffer[i] = person[type].person_name[i].person_num;
        }

        selectionSort(sort_buffer, PERSON_MAX_NAME, indices);

#if 0
    //Serial.print("Sorted array: ");
    for (int i = 0; i < PERSON_MAX_NAME; i++) {
        //Serial.print(sort_buffer[i]);
        //Serial.print(",");
    }
//Serial.println("");
    //Serial.print("\nOriginal indices: ");
    for (int i = 0; i < PERSON_MAX_NAME; i++) {
        //Serial.print(indices[i]);
        //Serial.print(",");
    }
//Serial.println("");
#endif
#if 0

 //进行序号排序
 bubbleSort(sort_buffer, PERSON_MAX_NAME);
#endif

        for (int i = 0; i < PERSON_MAX_NAME; i++)
        {

            int display_index = 0;

            display_index = indices[i]; // 获取当前显示的索引

            // Serial.println(person[type].person_name[display_index].person_num);
            if (strlen((char *)&person[type].person_name[display_index].person_name) != 0)
            {
                strcat(out, (char *)&person[type].person_name[display_index].person_name);
                strcat(out, " ");
            }
        }
    }
}
/*********************************************************************************
 * function   :   person_del
 * Description :  人员删除
 * Input       :
 * Output      :
 * Author      :  祁鑫                  Data : 2023 8.12
 **********************************************************************************/
void person_del(uint8_t type, uint8_t num, char *in, char *out)
{

    // printf("person_del\r\n");
    // Serial.print("delete num ");
    // Serial.println(num);

    if (type == person[type].person_type)
    {
        uint8_t index = 0;

        // 查找当前不为空的字符串数组
        for (int i = 0; i < PERSON_MAX_NAME; i++)
        {
            // 如果序号存在
            if (person[type].person_name[i].person_num == num)
            {
                printf("person_num exist \r\n");
                // Serial.println(person[type].person_name[i].person_num);
                index = i;
                break;
            }
            // return;
        }

        {
            if ((person[type].person_name[index].person_num == num))
            {
                // 清空显示
                // Serial.println("delete index data");
                printf("delete index data \r\n");
                person[type].person_name[index].person_num = 0;
                memset(&person[type].person_name[index].person_name, 0x00, PERSON_NAME_MAX_LEN);
            }
            // strcpy((char *)&person[type].person_name[index].person_name,in);
        }
        // Serial.println("show font");

#if 0
                for(int i  = 0;i<PERSON_MAX_NAME;i++)
                {

                       Serial.println(person[type].person_name[i].person_num);
                       if(strlen((char *)&person[type].person_name[i].person_name)!=0)
                       {
                            strcat(out,(char *)&person[type].person_name[i].person_name);  
                            strcat(out,"  ");   
                       }  

                }
#else
        // 开始显示数据
        int sort_buffer[PERSON_MAX_NAME] = {0}; // 获取当前序号值

        int indices[PERSON_MAX_NAME]; // 排序后的索引值
        for (int i = 0; i < PERSON_MAX_NAME; i++)
        {
            indices[i] = i;
        }

        // 拷贝序号数据
        for (int i = 0; i < PERSON_MAX_NAME; i++)
        {
            sort_buffer[i] = person[type].person_name[i].person_num;
        }

        selectionSort(sort_buffer, PERSON_MAX_NAME, indices);

#if 0
    Serial.print("Sorted array: ");
    for (int i = 0; i < PERSON_MAX_NAME; i++) {
        Serial.print(sort_buffer[i]);
        Serial.print(",");
    }
Serial.println("");
    Serial.print("\nOriginal indices: ");
    for (int i = 0; i < PERSON_MAX_NAME; i++) {
        Serial.print(indices[i]);
        Serial.print(",");
    }
Serial.println("");
#endif
        for (int i = 0; i < PERSON_MAX_NAME; i++)
        {

            int display_index = 0;

            display_index = indices[i]; // 获取当前显示的索引

            // Serial.println(person[type].person_name[display_index].person_num);
            if (strlen((char *)&person[type].person_name[display_index].person_name) != 0)
            {
                strcat(out, (char *)&person[type].person_name[display_index].person_name);
                strcat(out, " ");
                printf("out = %s\r\n", out);
            }
        }

#endif
    }
}

#endif

void loro_gwpair_ack(int destaddr, int sourceaddr, int cmd, int st, char *strd)
{
    uint8_t strlorabuf[50];
    int crc16 = 0, len, i;
    memset(strlorabuf, 0, 50);
    // 源地址 是指网关地址
    // 帧头                                                目标地址                      源地址(id)                  长度               模式           具体内容 	              校验
    strlorabuf[0] = 0x55;
    strlorabuf[1] = 0xaa;
    strlorabuf[2] = destaddr & 0xff;
    strlorabuf[3] = sourceaddr & 0xff;
    strlorabuf[4] = 0x02;
    strlorabuf[5] = cmd;
    strlorabuf[6] = st;
    strcpy((char *)(strlorabuf + 7), strd); // mac+c_id
    crc16 = strlorabuf[0] + strlorabuf[1] + strlorabuf[2] + strlorabuf[3] + strlorabuf[4] + strlorabuf[5] + strlorabuf[6];
    len = strlen(strd);
    strlorabuf[4] = 4 + len;
    for (i = 0; i < len; i++)
        crc16 = crc16 + strlorabuf[7 + len];

    strlorabuf[7 + len] = (crc16 >> 8) & 0xff;
    strlorabuf[8 + len] = crc16 & 0xff;
    strlorabuf[9 + len] = 0;
#if 0
   send_lora_data(strlorabuf,9+len);
#else
    // loraSerial.write((char *)strlorabuf,len);

    lora_send_data((char *)strlorabuf, len);
#endif
}

void lora_rev_cmd_send_ack()
{
}
void right_screen_send()
{
    screen_dis_info.is_left = false;
    screen_dis_info.is_into_sleep = true;
    if (xQueueSend(screen_queue, &screen_dis_info, portMAX_DELAY) != true)
    {
        ESP_LOGE(LOG_TAG, "err:screen queue send fail");
    }
}
void user_compare(int last, int now) // 这个函数用来比较rssi和 电量变化 刷右屏//
{
    if ((last == now) || (Machine_info.power_status == 0))
    {
        // ESP_LOGW(LOG_TAG,"last[%d]-now[%d]",last,now);
        return;
    }
    // printf("user_compare last[%d] now[%d] \n",last,now);
    bool is_send_right_screen = false;
    switch (last)
    {
    case 100:
        if (now != 100)
        {
            is_send_right_screen = true;
        }
        break;
    case 75 ... 99:
        if ((now == 100) || (now < 75))
        {
            is_send_right_screen = true;
        }
        break;
    case 50 ... 74:
        if ((now > 74) || (now < 50))
        {
            is_send_right_screen = true;
        }
        break;
    case 25 ... 49:
        if ((now > 49) || (now < 25))
        {
            is_send_right_screen = true;
        }
        break;
    case 0 ... 24:
        if ((now == 0) || (now > 24))
        {
            is_send_right_screen = true;
        }
        break;
    default:
        ESP_LOGE(LOG_TAG, "err:not 0~100");
        break;
    }
    if (is_send_right_screen)
        right_screen_send();
}

void user_compare_power_off(int last, int now) // 这个函数用来比较关机状态时电量变化 刷右屏//
{
    if ((last == now))
    {
        // ESP_LOGW(LOG_TAG,"last[%d]-now[%d]",last,now);
        return;
    }

    bool is_dis = false;
    switch (last)
    {
    case 100:
        if (now != 100)
        {
            gpio_hold_dis(PIN_R_CS);
            is_dis = true;
        }
        break;
    case 75 ... 99:
        if ((now == 100) || (now < 75))
        {
            gpio_hold_dis(PIN_R_CS);
            is_dis = true;
        }
        break;
    case 50 ... 74:
        if ((now > 74) || (now < 50))
        {
            gpio_hold_dis(PIN_R_CS);
            is_dis = true;
        }
        break;
    case 25 ... 49:
        if ((now > 49) || (now < 25))
        {
            gpio_hold_dis(PIN_R_CS);
            is_dis = true;
        }
        break;
    case 0 ... 24:
        if ((now == 0) || (now > 24))
        {
            gpio_hold_dis(PIN_R_CS);
            is_dis = true;
        }
        break;
    default:
        ESP_LOGE(LOG_TAG, "err:not 0~100");
        break;
    }
    if (is_dis)
    {
        screen_dis_info.is_left = false;
        screen_dis_info.is_into_sleep = true;
        if (xQueueSend(screen_queue, &screen_dis_info, portMAX_DELAY) != true)
        {
            ESP_LOGE(LOG_TAG, "err:screen queue send fail");
        }
    }
}