#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 #include #include #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;idata_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;idata_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;idata_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;idata_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;idata_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;idata_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 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 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;indexdata ,use_data.data_len); #if 0 printf("single cmd len =%d\r\n",use_data.data_len); for(int i = 0;idata + (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;indexdata +(positions[index]) ,use_data.data_len + 15); // printf("================last result============== len =%d\r\n",use_data.data_len); // for(int i = 0;idata + (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;idata[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;ipackage:"); for(i=0;i=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>= 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]=0x01;//长度 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>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"); } } }