增加OTA协议

jinlicong

2024-06-19 6e3f1f560d618b37ee1a47fa2b0f682b70c3ef1c

 Function/WirelessRemoteComm/wrc_sizhu_v4.c

@@ -10,11 +10,14 @@
#include "system_general_para.h"
#include "linked_list.h"
#include "uart.h"
#include "sizhu_event_record.h"
#include "sizhu_history_record.h"
#include "bootloader_iap.h"

static   SIZHU_V4_PROTOCOL_HEAD_T   protocol_head_up_g ={.frame_start_code = SIZHU_FRAME_HEAD,.data_start_code = SIZHU_DATA_HEAD};
static   SIZHU_V4_PROTOCOL_NORMAL_DATA_HEAD_T   up_data_head_g;
static   SIZHU_V4_PROTOCOL_TAIL_T   proto_tail_up_g = {.frame_end_code = SIZHU_FRAME_TAIL};
static   SIZHU_V4_REPORT_CTRL_PARA_T   report_ctrl_para_g;
static   SIZHU_V4_REPORT_CTRL_PARA_T __attribute__ ((aligned (4)))    report_ctrl_para_g;
ErrorStatus   wrc_sizhuV4_result_flag = FAIL;    //×îÖÕµÄͨѶ½á¹ûÅжϣ¬³õʼÖÃFAIL£¬×îÖÕ¸ù¾ÝЭÒéÈ·Èϱ¾´ÎͨѶÊÇ·ñ³É¹¦£¬±ÈÈç˼ÖþµÄЭÒéͨ¹ý½áÊøÖ¡ÅжÏÊÇ·ñ×îÖճɹ¦
ErrorStatus   report_sizhuV4_result_flag = FAIL; //Éϱ¨ÊÇ·ñ³É¹¦±êÖ¾£¬ÓÃÓÚÒ»ÌìÖ®ÄÚÓÐûÓÐÉÏ´«³É¹¦¹ý£¬¸úwrc_sizhuV4_result_flagͨѶÊÇ·ñ³É¹¦²»Ò»Ñù£¬¿íËÉÒ»µã£¬Ö»ÒªÊý¾ÝÉϱ¨ÏìÓ¦³É¹¦¼´´ú±íÉϱ¨³É¹¦£¬ÊÕµ½½áÊøÖ¡Ò²´ú±í³É¹¦

@@ -25,14 +28,53 @@
   uint32_t   read_start_addr ;
   //?»ñÈ¡ÆðʼµØÖ·£¬Ã»Ð´Íê
   read_start_addr = current_save_addr;
   if(data_num == 0)
      return read_start_addr;
   
   while(data_num--){
      if(read_start_addr <= HISTORY_INTERVAL_START_ADDR){
         read_start_addr = HISTORY_INTERVAL_END_ADDR;
      }else{
         read_start_addr -= HISTORY_INTERVAL_LENGTH;
      }
   }
   return read_start_addr;
}


//´Ó´æ´¢ÀïÃæ¶ÁÈ¡Êý¾Ý£¬Í¬Ê±µØÖ·Ö¸ÏòºóÒ»ÌõÊý¾Ý
void ReadDataFromRecord(uint32_t * read_addr ,uint8_t *buf)
{
   SIZHU_HISTORY_INTERVAL_T   history_interval_l;
   SIZHU_V4_PROTOCOL_NORMAL_DATA_PACK_T   up_data_pack_l;
   //?´Ó´æ´¢ÀïÃæ¶ÁÈ¡Êý¾Ýµ½buf,Èç¹ûÅжϴ洢¶ÁÈ¡µÄÊý¾ÝÒì³££¬ÔòÌî³ä0»òÕßÈÝÒ×ʶ±ðµÄÊý¾Ý
   //read_addr++
   if(FlashMultipleReadAndCrcCheck((uint8_t *)&history_interval_l,*read_addr,HISTORY_INTERVAL_LENGTH)== PASS){
      arrayA_2_arrayB((uint8_t *)&history_interval_l.record_time_BCD, (uint8_t *)&up_data_pack_l.sample_time, sizeof(up_data_pack_l.sample_time), LITTLE_ENDIAN);
      up_data_pack_l.sc_cumulate = history_interval_l.forward_cumulate_sc * 10000;
      up_data_pack_l.wc_cumulate = history_interval_l.forward_cumulate_wc * 10000;
      up_data_pack_l.sc_instant = history_interval_l.instant_sc * 10000;
      up_data_pack_l.wc_instant = history_interval_l.instant_wc * 10000;
      up_data_pack_l.pressure = history_interval_l.pressure;
      up_data_pack_l.temperature = history_interval_l.temperature;
      up_data_pack_l.balance = history_interval_l.residual_amount * 1000;
      up_data_pack_l.uint_price = history_interval_l.current_price;
      up_data_pack_l.lith_vcc = history_interval_l.lith_bat_v;
      up_data_pack_l.lith_vcc_per = history_interval_l.lith_bat_per;
      up_data_pack_l.alka_vcc = history_interval_l.alka_bat_v;
      up_data_pack_l.alka_vcc_per = history_interval_l.alka_bat_per;
      arrayA_2_arrayB((uint8_t *)&history_interval_l.status_word, (uint8_t *)&up_data_pack_l.status, 12, LITTLE_ENDIAN);
		
      arrayA_2_arrayB((uint8_t *)&up_data_pack_l, buf, DATA_PACKET_LENGTH, LITTLE_ENDIAN);
   }else{
      memset(buf,0,DATA_PACKET_LENGTH);
   }
	
   if(*read_addr >= HISTORY_INTERVAL_END_ADDR){
      *read_addr = HISTORY_INTERVAL_START_ADDR;
   }else{
      *read_addr += HISTORY_INTERVAL_LENGTH;
   }
   
}

@@ -85,7 +127,7 @@
   #else
   report_ctrl_para_g.current_report_data_num = wrc_data_num_ctrl_para_sizhu_g.report_data_save_num + wrc_data_num_ctrl_para_sizhu_g.report_data_left_num ;
   report_ctrl_para_g.current_report_data_num = (report_ctrl_para_g.current_report_data_num > ONCE_REPORT_MAX_NUM)? ONCE_REPORT_MAX_NUM:report_ctrl_para_g.current_report_data_num; //ÏÞÖÆÉϱ¨ÌõÊý
//?   report_ctrl_para_g.report_data_read_addr = (current_save_addr,report_ctrl_para_g.current_report_data_num);
   report_ctrl_para_g.report_data_read_addr = DataReadAddrInit(log_sizhu_history_ctrl_g.per_interval_log.log_addr_save,report_ctrl_para_g.current_report_data_num);
   wrc_data_num_ctrl_para_sizhu_g.report_data_save_num =0 ;
   wrc_data_num_ctrl_para_sizhu_g.report_data_left_num = report_ctrl_para_g.current_report_data_num;
   //?wrc_data_num_ctrl_para_sizhu_g´æ´¢
@@ -195,8 +237,7 @@
   arrayA_2_arrayB((uint8_t*)&one_pack_data, (uint8_t*)&send_buf[FIRST_DATA_SHIFT_SIZHU + DATA_PACKET_HEAD_LENGTH], DATA_PACKET_LENGTH, LITTLE_ENDIAN);
   
   #else
   //?´Ó´æ´¢ÀïÃæ¶ÁÈ¡¶³½á¼Ç¼½øÐÐÉϱ¨
	
   //´Ó´æ´¢ÀïÃæ¶ÁÈ¡¼ä¸ô¶³½á¼Ç¼½øÐÐÉϱ¨
   current_frame_data_num = (protocol_head_up_g.frame_num < protocol_head_up_g.frame_sum)? FRAME_DATA_MAX:report_ctrl_para_g.last_frame_data_num;
   
   for(uint8_t count_i =0;count_i < current_frame_data_num;count_i++ ){
@@ -266,6 +307,7 @@
{
   WRC_STATUS   return_code = WRC_OFF;
   int difference_value;
   sClockBCD   time_after_cali;
   
   wrc_sizhuV4_result_flag = PASS;
   report_sizhuV4_result_flag = PASS;
@@ -281,6 +323,10 @@
   if(difference_value >= 300){
      Set_Extern_Rtc_Time(receive_buf[0],receive_buf[1],receive_buf[2],1,receive_buf[3],receive_buf[4],receive_buf[5]);
   }
	
   //´æ´¢Ð£Ê±¼Ç¼
   arrayA_2_arrayB(receive_buf,(uint8_t *)&time_after_cali,sizeof(time_after_cali),LITTLE_ENDIAN);
   sizhuSetTimeLogHandle(SET_TIME_SOURCE_AUTO , 0, time_after_cali);

   //ÒÅÁôÊý¾ÝÇå¿Õ   
   wrc_data_num_ctrl_para_sizhu_g.report_data_left_num = 0;
@@ -378,6 +424,109 @@
}



//OTA
WRC_STATUS   OTA_config(uint8_t *receive_buf,uint16_t receive_data_length,uint8_t *ack_buf,uint16_t *ack_buf_length)
{
   WRC_STATUS   return_code = WRC_WAIT_REC_DATA;
   uint8_t return_flag = SUCCESS_0;
   ack_buf[0]   = 0;//³É¹¦
	
   return_flag = BootLoader_IapConfigSetHander(receive_buf,receive_data_length);
   if(return_flag == SUCCESS_0){
      ack_buf[0] = 0;
   }else{
      ack_buf[0] = return_flag;
   }
	
//   ack_buf[0]   = 0;//³É¹¦
   *ack_buf_length = 1; //¼ÓÃÜÇ°µÄÊý¾Ý³¤¶È
   return return_code;
}

//OTA
WRC_STATUS   OTA_DiffData(uint8_t *receive_buf,uint16_t receive_data_length,uint8_t *ack_buf,uint16_t *ack_buf_length)
{
   WRC_STATUS   return_code = WRC_WAIT_REC_DATA;
   uint8_t return_flag = SUCCESS_0;
   uint32_t offset_addr = (receive_buf[3] << 24) | (receive_buf[2] << 16) | (receive_buf[1] << 8) | receive_buf[0];
   uint32_t data_len = receive_data_length - 4; //¼õÈ¥µØÖ·
   ack_buf[0]   = 0;//³É¹¦
	
   //Êý¾Ý´Ó[4]¿ªÊ¼
   return_flag = BootLoader_IapDiffDataHandler(&receive_buf[4],offset_addr,data_len);
   if(return_flag == SUCCESS_0){
      ack_buf[0] = 0;
   }else{
      ack_buf[0] = return_flag;
   }
	
//   ack_buf[0]   = 0;//³É¹¦
   *ack_buf_length = 1; //¼ÓÃÜÇ°µÄÊý¾Ý³¤¶È
   return return_code;
}

//OTA
WRC_STATUS   OTA_check(uint8_t *receive_buf,uint16_t receive_data_length,uint8_t *ack_buf,uint16_t *ack_buf_length)
{
   WRC_STATUS   return_code = WRC_WAIT_REC_DATA;
   uint8_t return_flag = SUCCESS_0;
   ack_buf[0]   = 0;//³É¹¦
	
   return_flag = BootLoader_IapConfigCheckHandler();
   if(return_flag == SUCCESS_0){
      ack_buf[0] = 0;
   }else{
      ack_buf[0] = return_flag;
   }
	
//   ack_buf[0]   = 0;//³É¹¦
   *ack_buf_length = 1; //¼ÓÃÜÇ°µÄÊý¾Ý³¤¶È
   return return_code;
}

//OTA
WRC_STATUS   OTA_DiffMap(uint8_t *receive_buf,uint16_t receive_data_length,uint8_t *ack_buf,uint16_t *ack_buf_length)
{
   WRC_STATUS   return_code = WRC_WAIT_REC_DATA;
   uint8_t return_flag = SUCCESS_0;
   uint32_t offset_addr = (receive_buf[3] << 24) | (receive_buf[2] << 16) | (receive_buf[1] << 8) | receive_buf[0];
   uint32_t data_len = receive_data_length - 4; //¼õÈ¥µØÖ·
   ack_buf[0]   = 0;//³É¹¦
	
   //Êý¾Ý´Ó[4]¿ªÊ¼
   return_flag = BootLoader_IapDiffMapSetHandler(&receive_buf[4],offset_addr,data_len);
   if(return_flag == SUCCESS_0){
      ack_buf[0] = 0;
   }else{
      ack_buf[0] = return_flag;
   }
	
//   ack_buf[0]   = 0;//³É¹¦
   *ack_buf_length = 1; //¼ÓÃÜÇ°µÄÊý¾Ý³¤¶È
   return return_code;
}

//OTA
WRC_STATUS   OTA_config_bsdiff_lzma(uint8_t *receive_buf,uint16_t receive_data_length,uint8_t *ack_buf,uint16_t *ack_buf_length)
{
   WRC_STATUS   return_code = WRC_WAIT_REC_DATA;
   uint8_t return_flag = SUCCESS_0;
   ack_buf[0]   = 0;//³É¹¦
	
   return_flag = BootLoader_IapConfigLzmaSetHander(receive_buf,receive_data_length);
   if(return_flag == SUCCESS_0){
      ack_buf[0] = 0;
   }else{
      ack_buf[0] = return_flag;
   }
	
//   ack_buf[0]   = 0;//³É¹¦
   *ack_buf_length = 1; //¼ÓÃÜÇ°µÄÊý¾Ý³¤¶È
   return return_code;
}


WRC_STATUS   SizhuV4ProtocolDataAnalysis(uint8_t *receive_buf,uint8_t *ack_buf,uint16_t *ack_buf_length)
{
   uint8_t *buf_p = NULL;
@@ -423,6 +572,12 @@
         
         case SIZHU_CONTROL_CODE_SET_BALANCE_INSUF_CLOSE_VALVE : return_code = SetBalanceValveClosePro((uint8_t*)(buf_p + FIRST_DATA_SHIFT_SIZHU),ack_buf + FIRST_DATA_SHIFT_SIZHU,&ack_data_length);   break;
         //?´ý²¹³ä
			
         case SIZHU_CONTROL_OTA_CONFIG : return_code = OTA_config((uint8_t*)(buf_p + FIRST_DATA_SHIFT_SIZHU),protocol_head_rec.data_length,ack_buf + FIRST_DATA_SHIFT_SIZHU,&ack_data_length);   break;
         case SIZHU_CONTROL_OTA_DIFF_DATA : return_code = OTA_DiffData((uint8_t*)(buf_p + FIRST_DATA_SHIFT_SIZHU),protocol_head_rec.data_length,ack_buf + FIRST_DATA_SHIFT_SIZHU,&ack_data_length);   break;
         case SIZHU_CONTROL_OTA_CHECK : return_code = OTA_check((uint8_t*)(buf_p + FIRST_DATA_SHIFT_SIZHU),protocol_head_rec.data_length,ack_buf + FIRST_DATA_SHIFT_SIZHU,&ack_data_length);   break;
         case SIZHU_CONTROL_OTA_DIFF_MAP : return_code = OTA_DiffMap((uint8_t*)(buf_p + FIRST_DATA_SHIFT_SIZHU),protocol_head_rec.data_length,ack_buf + FIRST_DATA_SHIFT_SIZHU,&ack_data_length);   break;
         case SIZHU_CONTROL_OTA_CONFIG_BSDIFF_LZMA : return_code = OTA_config_bsdiff_lzma((uint8_t*)(buf_p + FIRST_DATA_SHIFT_SIZHU),protocol_head_rec.data_length,ack_buf + FIRST_DATA_SHIFT_SIZHU,&ack_data_length);   break;
         default: break;
      }