From 6e3f1f560d618b37ee1a47fa2b0f682b70c3ef1c Mon Sep 17 00:00:00 2001
From: jinlicong <493886250@qq.com>
Date: Wed, 19 Jun 2024 17:25:45 +0800
Subject: [PATCH] 增加OTA协议

---
 Function/WirelessRemoteComm/wireless_remote_comm.c |  176 ++++++++++++++++++++++++++++++++++++++++++++++++----------
 1 files changed, 145 insertions(+), 31 deletions(-)

diff --git a/Function/WirelessRemoteComm/wireless_remote_comm.c b/Function/WirelessRemoteComm/wireless_remote_comm.c
index 8184e3d..bf1a5ac 100644
--- a/Function/WirelessRemoteComm/wireless_remote_comm.c
+++ b/Function/WirelessRemoteComm/wireless_remote_comm.c
@@ -3,8 +3,11 @@
 #include "gpio.h"
 #include "system_mem_para.h"
 #include "wrc_sizhu_v4.h"
+#include "system_general_para.h"
+#include "linked_list.h"
+#include "sizhu_alarm_record.h"
 
-WRC_CTRL_PARA_T wrc_ctrl_para_g={.wrc_state=WRC_IDLE};
+WRC_CTRL_PARA_T wrc_ctrl_para_g={.wrc_state=WRC_IDLE,.link_status = LINK_NONE,.wrc_err_code = WRC_ERR_NONE,.report_result_flag = FAIL};
 WRC_UART_PARA_T	wrc_uart_para_g = {.recv_flag = RESET};
 LINK_INFO_T	link_info_g;
 
@@ -13,6 +16,9 @@
 {
 	OutputIO(WRC_PWR_PORT,WRC_PWR_PIN,OUT_PUSHPULL);
 	OutputIO(PWR_3V8_O_PORT,PWR_3V8_O_PIN,OUT_PUSHPULL);
+	CloseIO(PWR_3V8_EN_PORT,PWR_3V8_EN_PIN);
+	PWR_3V8_OFF;
+	WRC_PWR_OFF;
 }
 
 
@@ -36,6 +42,9 @@
 	dma_recv_cnt = dma_mar_reg_read - (uint32)WRC_recv_buff;
 	if(dma_recv_cnt)
 	{
+		if((dma_recv_cnt >= WRC_REC_BUF_LENGTH) || (dma_recv_cnt >= WRC_RECV_BUFF_LEN_MAX) )
+			return;
+		
 		wrc_ctrl_para_p->recv_length = dma_recv_cnt;
 		arrayA_2_arrayB(WRC_recv_buff , wrc_ctrl_para_p->recv_buf, dma_recv_cnt, LITTLE_ENDIAN) ;
 		wrc_ctrl_para_p->recv_flag = SET;//�������
@@ -50,9 +59,9 @@
 	uint8_t buffer[255];
 	uint8_t	i_index;
 	
-	//?�������ݴ���
-	buffer[0] = 0x1b;
-	buffer[1] = 0x1b;
+	//�������ݴ���
+	buffer[0] = WRC_MODULE_CMD_OPEN;
+	buffer[1] = WRC_MODULE_CMD_OPEN;
 	buffer[2] = 0x00;		
 	
 	arrayA_2_arrayB((uint8_t*)wrc_para_sizhu_g.ip1, &buffer[3], 4, LITTLE_ENDIAN);
@@ -94,7 +103,8 @@
 	}
 	buffer[204] = 0x16;
 	
-	WRC_SEND_NORMAL(buffer,205);
+
+	WRC_UART_SEND(buffer,205);
 }
 
 LINK_STATUS		LinkDataAnalysis(uint8_t *receive_buf)
@@ -105,7 +115,7 @@
 	LINK_STATUS	return_flag = LINK_NONE;
 	
 	for(count_i = 0;count_i< 100;count_i++){
-		if((receive_buf[count_i]==0x41)&&(receive_buf[count_i+1]==0x41))
+		if((receive_buf[count_i]==WRC_MODULE_CMD_LINK_STATUS_ACK)&&(receive_buf[count_i+1]==WRC_MODULE_CMD_LINK_STATUS_ACK))
 		{
 			buf_p = (char *)(&(receive_buf[count_i]));
 			break;
@@ -117,7 +127,10 @@
 		for(count_i = 0;count_i< 89;count_i++)
 			check_sum += *(buf_p + count_i);
 
-		if((*(buf_p + 89) == check_sum)&&(*(buf_p + 90) == 0x16)){
+		if(*(buf_p + 89) == check_sum){
+			
+			WRC_RX_DMA_CH3_reload(); //����У��ͨ��������Ϊ������Ҫ���յ������Ѿ���ɣ���Ҫ����DMA����, 
+			
 			if(*(buf_p + 2) == 1){
 				return_flag = LINK_OK;
 				if((*(buf_p+3) != 1)&&(*(buf_p+3) <0x39)){
@@ -144,18 +157,19 @@
 }
 
 
-WRC_STATUS	ProtocolDataAnalysis(uint8_t *receive_buf)
+WRC_STATUS	ProtocolDataAnalysis(uint8_t *receive_buf,uint8_t *ack_buf,uint16_t *ack_buf_length)
 {
 	char *buf_p = NULL;
 	char *buf_next_p = NULL;
 //	uint16_t check_crc = 0;
 	uint16_t count_i = 0;
 	
-	buf_p = strstr((char *)receive_buf , "+R");   
+	buf_p = strstr((char *)receive_buf , WRC_MODULE_CMD_DATA_RECV);   
 	if(buf_p != NULL){
 		buf_next_p = strstr(buf_p , ",");
 		if(buf_next_p != NULL){
-			return SizhuV4ProtocolDataAnalysis((uint8_t *)buf_next_p);
+
+			return SizhuV4ProtocolDataAnalysis((uint8_t *)buf_next_p,ack_buf,ack_buf_length);
 			
 		}
 	}
@@ -173,10 +187,12 @@
 	delay_us(10);
 	WRC_PWR_ON;
 	
-	//?��Ҫ��ͨѶ������ʼ�����Է�������,Ҳ���Է��������ɹ�֮��
+	wrc_ctrl_para_g.wrc_err_code = WRC_ERR_NONE;
+	wrc_ctrl_para_g.wrc_OFF_cnt = 0;
+	//��Ҫ��ͨѶ������ʼ�����Է�������
 	SizhuV4SendParaInit();
 	
-	return WRC_SEND_DATA;
+	return WRC_CREATE_LINK;
 }
 
 WRC_STATUS	WrcCreateLinkPro(void)
@@ -184,12 +200,14 @@
 	
 	//��������
 	WRC_uart_Init(115200,NONE,OneBit);
+	WRC_RX_DMA_CH3_Init();
+	uart_ctrl_para_g.WRC_rxto_flag =  RESET;
 	
-	
-	//?��������ʹģ�����������������
+	//��������ʹģ�����������������
 	WrcSendCreateLinkCmd();
 	wrc_ctrl_para_g.link_status = LINK_NONE;
 	
+	__SYS_DELAY_SEC_TIME_SET_(wrc_timeout_para,wrc_ctrl_para_g.time_out_time_sec);
 	
 	return WRC_WAIT_REC_DATA;
 }
@@ -197,63 +215,154 @@
 
 WRC_STATUS	WrcSendDataPro(void)
 {
+	uint8_t send_buf[3+1024] = {0};
+	uint16_t	send_length;
+	//�������ݴ���
+	send_length = SizhuV4SendNormalData2buf(&send_buf[3]);
+//	wrc_ctrl_para_g.time_out_cnt = wrc_ctrl_para_g.time_out_time_sec;
 	
-	//?�������ݴ���
+	send_buf[0] = WRC_MODULE_CMD_DATA_UP;
+	send_buf[1] = send_length &0xff;
+	send_buf[2] = send_length >>8;
 	
+	if(send_length > sizeof(send_buf)){
+		wrc_ctrl_para_g.wrc_err_code = WRC_ERR_SEND_DATA;
+		wrc_ctrl_para_g.wrc_OFF_cnt = 0;
+		return WRC_OFF;
+	}
 	
-
+	WRC_UART_SEND(send_buf,send_length + 3);
+	
+	__SYS_DELAY_SEC_TIME_SET_(wrc_timeout_para,wrc_ctrl_para_g.time_out_time_sec);
+	
 	return WRC_WAIT_REC_DATA;
 }
 
 WRC_STATUS	WrcWaitRecDataPro(void)
 {
 	WRC_STATUS	return_status;
+	uint8_t send_buf[3+1024] = {0};
+	uint16_t	send_length = 0;
+	
 	//����buf����
-	WRC_RX_DMA_check(&wrc_uart_para_g);
+	if(uart_ctrl_para_g.WRC_rxto_flag ==SET){
+		uart_ctrl_para_g.WRC_rxto_flag = RESET;
+		WRC_RX_DMA_check(&wrc_uart_para_g);
+	}
 	
 	//���������ж�
 	if(wrc_uart_para_g.recv_flag == SET){
 		wrc_uart_para_g.recv_flag = RESET;
 		if(wrc_ctrl_para_g.link_status ==LINK_NONE){
-			wrc_ctrl_para_g.link_status = LinkDataAnalysis(wrc_uart_para_g.recv_buf);
+			wrc_ctrl_para_g.link_status = LinkDataAnalysis(wrc_uart_para_g.recv_buf);//����״̬�ж�
 			if(wrc_ctrl_para_g.link_status ==LINK_OK){
 				memset(wrc_uart_para_g.recv_buf,0,sizeof(wrc_uart_para_g.recv_buf));
 				return WRC_SEND_DATA;
 			}
 		}else if(wrc_ctrl_para_g.link_status ==LINK_OK){
-			return_status = ProtocolDataAnalysis(wrc_uart_para_g.recv_buf);
+			return_status = ProtocolDataAnalysis(wrc_uart_para_g.recv_buf,&send_buf[3],&send_length);//ƽ̨�������ݷ���
+			
+			if((send_length > 0)&&(send_length < sizeof(send_buf))){ //ƽ��Ӧ������Ҫ����
+				send_buf[0] = WRC_MODULE_CMD_DATA_UP;
+				send_buf[1] = send_length &0xff;
+				send_buf[2] = send_length >>8;
+				WRC_UART_SEND(send_buf,send_length + 3);
+				__SYS_DELAY_SEC_TIME_SET_(wrc_timeout_para,wrc_ctrl_para_g.time_out_time_sec);
+			}
 			memset(wrc_uart_para_g.recv_buf,0,sizeof(wrc_uart_para_g.recv_buf));
 			return return_status;
 		}
 	}
 
+	if(__SYS_DELAY_SEC_FLAG_GET(wrc_timeout_para) == SET){
+		//�жϳ�ʱ�˳�
+		if(wrc_ctrl_para_g.link_status ==LINK_NONE)
+			wrc_ctrl_para_g.wrc_err_code = WRC_ERR_WAIT_LINK_TIME_OUT;
+		else if(wrc_ctrl_para_g.link_status ==LINK_OK)
+			wrc_ctrl_para_g.wrc_err_code = WRC_ERR_WAIT_ACK_TIME_OUT;
+		
+		wrc_ctrl_para_g.wrc_OFF_cnt = 0;
+	return WRC_OFF;
+	}
 	
-	//�жϳ�ʱ�˳�
-	return WRC_CLOSE_PWR;
+	return WRC_WAIT_REC_DATA;
 	
 }
 
 
 WRC_STATUS	WrcClosePwrPro(void)
 {
+	char	send_buf[7] = {'A','T','C','L','O','S','E'};
 	
+	
+	//��ȡ��ͬЭ���ͨѶ���
+	wrc_ctrl_para_g.wrc_result_flag = wrc_sizhuV4_result_flag;
+	wrc_ctrl_para_g.report_result_flag = (report_sizhuV4_result_flag == PASS)? PASS: wrc_ctrl_para_g.wrc_result_flag;//ֻ�гɹ��Ÿı�״̬�����򱣳�ԭֵ
+	report_sizhuV4_result_flag = FAIL;
+	
+	wrc_ctrl_para_g.wrc_OFF_cnt ++; 
+	
+	if(wrc_ctrl_para_g.wrc_OFF_cnt == 1){
+		WRC_UART_SEND((uint8_t *)send_buf,sizeof(send_buf));
+		return WRC_OFF;
+	}else if(wrc_ctrl_para_g.wrc_OFF_cnt == 3){
+		
+		//�رյ�Դ
+		WRC_PWR_OFF;
+		delay_us(10);
+		PWR_3V8_OFF;
+		return WRC_OFF;
+		
+	}else if(wrc_ctrl_para_g.wrc_OFF_cnt >= 8){
+		//�ӳ��˳�ͨѶ���̣���ʱ��Դ�Ѿ��رգ��൱�ڸ�����һ��ʱ����
+		WRC_PWR_OFF;
+		PWR_3V8_OFF;
+		
+		/*�ر���������Э�鲻ͬ*/
+		if(wrc_ctrl_para_g.wrc_result_flag == FAIL){
+			if(wrc_ctrl_para_g.wrc_start_flag != WRC_MEANS_AGAIN){
+				//������ر����������ر�����ֵ
+				wrc_ctrl_para_g.wrc_restart_num_cnt = wrc_para_sizhu_g.retransmission_num;
+			}
+		}else{
+			//�ϱ��ɹ�����Ҫ�ر�
+			wrc_ctrl_para_g.wrc_restart_num_cnt = 0;
+		}
+		
+		return WRC_IDLE; //�ػ���ϣ�����WRC_IDLE��������ͨѶ����
+	}
 
-	
-	
-
-	return WRC_IDLE; //�ػ���ϣ�����WRC_IDLE��������ͨѶ����
-	
-	return WRC_CLOSE_PWR; //�ػ�Ҫ�ȴ��Ļ����������WRC_CLOSE_PWR
-	
+	return WRC_OFF; 
 }
 
+
+//����δ�ϱ��ɹ��жϣ��жϱ�׼���Ա�ͨѶ�Ƿ�ɹ�����һ�㣬ֻҪ�������ϱ���Ӧ�����жϳɹ�����֡��������Ӧ���ý���֡��������֡����ɹ�
+void LongTimeReportFailed(BILLING_VALVE_CTRL_PATA_T	billing_valve_ctrl_para_in)
+{
+	static uint8_t report_failed_days_cnt = 0;
+	//��Ϊ�󲿷ֱ�0��֮�����һ��ͨѶ����ô�ж�ʱ�������Ӻ�����6��55�ж�
+	if((&sys_clockBCD_g)->hour == 6 && (&sys_clockBCD_g)->min == 55 && (&sys_clockBCD_g)->sec == 0 ){
+		if(billing_valve_ctrl_para_in.no_wrc_days > 0){  //����0�����ܿ���
+			if(wrc_ctrl_para_g.report_result_flag == PASS){
+				report_failed_days_cnt = 0;
+				__SYS_STATUS_BYTES_STATUS(no_gprs_date_up_to, RESET, ALARM_ID_N_DAYS_NO_REPORT_ARRIVE);
+			}else{
+				if((report_failed_days_cnt++) >= billing_valve_ctrl_para_in.no_wrc_days){ //��++����Ϊ��һ���ж�ʱ����1��
+					__SYS_STATUS_ALARM_BYTES_SET(no_gprs_date_up_to,ALARM_ID_N_DAYS_NO_REPORT_ARRIVE);				
+				}
+				
+			}
+		}
+
+	}
+}
 
 
 void WirelessRemoteCommPro(FUN_START_CTRL_PARA_T * sys_fun_run_ctrl_p)
 {
 	
-	//?��485�ɼ��������ڼ���ܽ���ͨѶ����
-	if((sys_fun_run_ctrl_p->wrc_ctrl_flag.start_flag ==SET)&&(sys_fun_run_ctrl_p->valve_ctrl_flag.running_flag == RESET)&&(sys_fun_run_ctrl_p->rs485_ctrl_flag.running_flag == RESET))//?�ж�485�ɼ���ʶ
+	//��485�ɼ��������ڼ���ܽ���ͨѶ����
+	if((sys_fun_run_ctrl_p->wrc_ctrl_flag.start_flag ==SET)&&(sys_fun_run_ctrl_p->valve_ctrl_flag.running_flag == RESET)&&(sys_fun_run_ctrl_p->rs485_ctrl_flag.running_flag == RESET))//�ж�485�ɼ���ʶ
 	{
 		sys_fun_run_ctrl_p->wrc_ctrl_flag.start_flag =RESET;
 		if(wrc_ctrl_para_g.wrc_state == WRC_IDLE)
@@ -267,7 +376,7 @@
 				case WRC_CREATE_LINK:		wrc_ctrl_para_g.wrc_state = WrcCreateLinkPro();break;
 				case WRC_SEND_DATA:			wrc_ctrl_para_g.wrc_state = WrcSendDataPro();break;
         case WRC_WAIT_REC_DATA:	wrc_ctrl_para_g.wrc_state = WrcWaitRecDataPro();break;
-        case WRC_CLOSE_PWR:			wrc_ctrl_para_g.wrc_state = WrcClosePwrPro();;break;
+        case WRC_OFF:			wrc_ctrl_para_g.wrc_state = WrcClosePwrPro();;break;
 
         default:;
     }
@@ -278,5 +387,10 @@
 	else
 		sys_fun_run_ctrl_p->wrc_ctrl_flag.running_flag = SET;
 	
+	
+	//����δ�ϱ��ɹ��жϣ���ͬЭ���жϵı�׼��ͬ
+	LongTimeReportFailed(billing_valve_ctrl_para_g);
+	
+	
 }
 

--
Gitblit v1.9.3