From b32910bdb85c6e9d19abf97f1465c573a0bf9d38 Mon Sep 17 00:00:00 2001
From: zhangbo <zhangbo@qq.com>
Date: 星期四, 13 二月 2025 14:06:13 +0800
Subject: [PATCH] 测试版

---
 keil/include/main/main.c |  289 ++++++++++++++++++++++++++++++++++++++++++++++-----------
 1 files changed, 232 insertions(+), 57 deletions(-)

diff --git a/keil/include/main/main.c b/keil/include/main/main.c
index e2bba9d..e284128 100644
--- a/keil/include/main/main.c
+++ b/keil/include/main/main.c
@@ -67,6 +67,8 @@
 //#include "pan_param.h"
 //#include "pan_rf.h"
 #include "lora_3029.h"
+#include "pan_rf.h"
+#include "PCA9555.h"
 #define DEBUG_MODE
 extern int simple_main(void);
 extern int temp_main(void);
@@ -287,9 +289,16 @@
     nomove_count++;
 }
 uint8_t flag_sleeptimer,flag_secondtask,secondtask_count;
+uint8_t  lora_wg_up=0;
+extern uint8_t lora_tx_flag;
 static void sleep_timer_callback(void *dev, uint32_t time)
 {
     g_start_send_flag=1;
+	//		#ifdef DEBUG_BOXING
+////		gpio_pin_clr(IO_PIN_5);//测试
+	//	gpio_pin_set(IO_PIN_5);//测试
+	  // lora_wg_up=1;
+	   lora_tx_flag++;
 //    IO_control_init();
 //    UWBPoll();
 //    
@@ -514,57 +523,194 @@
 uint32_t successful_cnt=0;
 uint8_t flag_4guart_needinit=0;
 #define TX_LEN  10
-#define RX_LEN  100
+#define RX_LEN  200
 uint8_t tx_test_buf[TX_LEN] = {0, 1, 2, 3, 4, 5, 6, 7, 8, 9};
-uint8_t RF_RX_temp[RX_LEN]={0};
+extern uint8_t RX_Buffer[RX_LEN];
+extern uint16_t BufferSize;
+static uint16_t source_id;
 extern struct RxDoneMsg RxDoneParams;
 uint32_t time_flag_lorarx=0;
 uint32_t lora_huanxing_count=0;
-static void Lora_irq_handler(enum IO_PIN_T pin)
-{   
-   ceshi++;
-   
-	rf_irq_process();
-	      //g_start_send_flag=1;
-        if(rf_get_transmit_flag() == RADIO_FLAG_TXDONE)
-        {
-           rf_set_transmit_flag(RADIO_FLAG_IDLE);
-           rf_enter_continous_rx();
-        }
-				
-				
-        if(rf_get_recv_flag() == RADIO_FLAG_RXDONE)
-        {
-            rf_set_recv_flag(RADIO_FLAG_IDLE);
+uint16_t Lora_wangguanid=0;
+extern uint16_t wg_report_freq,wg_report_id;
+extern uint32_t wg_lost_count;
+wg_state_enum wg_state = WG_Lost;
+extern uint16_t current_count;
+extern uint8_t rec_index,rec_secdelay;
+extern uint8_t  yuyin_no_sleep_flag,no_rx_flag;
+uint16_t wangguan_up_id;
+uint8_t LoraUp_flag;
+uint8_t imu_enable,motor_enable;
+extern uint8_t shengji_flag;
+uint16_t rec_wenjian_daxiao;
+uint16_t recnum[3];
+uint16_t recv_flag=0;
+uint16_t tx_flag=0;
+uint16_t CRC16=0;
+uint16_t DEST_ID=0;
+uint16_t rec_value,rec_delaytime,rx_count,datalen_offset;
 
-//					  memcpy(RF_RX_temp,RxDoneParams.Payload,RxDoneParams.Size);
-//					  //OnRxDone();
-//					  if(RF_RX_temp[0]==0x04&&RF_RX_temp[1]=='I'&&RF_RX_temp[2]=='N'&&RF_RX_temp[3]=='G')
-//						{
-              lora_huanxing_count++;
-							time_flag_lorarx=phy_timer_count_get();
-					    
-				    	//LORA_REV_uwb_up=1;
-							UwbRange();
-					
-//						}
-						rf_enter_continous_rx(); //重新进入接收模式
-					//					gpio_pin_set(IO_PIN_5);//测试
-		gpio_pin_clr(IO_PIN_5);
-					  //UwbRange();
-//            DDL_Printf("Rx : SNR: %f ,RSSI: %d \r\n", RxDoneParams.Snr, RxDoneParams.Rssi);
-              //int i=0;
-//            for(i = 0; i < RxDoneParams.Size; i++)
-//            {
-//                printf("0x%02x ", RxDoneParams.Payload[i]);
-//            }
-           // error_cnt ++;
-        }
-        if((rf_get_recv_flag() == RADIO_FLAG_RXTIMEOUT) || (rf_get_recv_flag() == RADIO_FLAG_RXERR))
+//
+uint16_t Loratx_flag=0;
+uint16_t Lorarx_flag=0;
+uint16_t Lorarx_time_out_flag=0;
+static void Lora_irq_handler(enum IO_PIN_T pin)
+{
+			uint16_t checksum1;	
+			rf_irq_process();
+			//这里根据SDK的那个逻辑 用你的接口看看
+	    tx_flag=rf_get_transmit_flag();
+	    recv_flag=rf_get_recv_flag();
+			if(recv_flag == RADIO_FLAG_RXDONE)
         {
-            rf_set_recv_flag(RADIO_FLAG_IDLE);
+				 rf_set_recv_flag(RADIO_FLAG_IDLE);
+				
+				 memcpy(RX_Buffer,RxDoneParams.Payload,RxDoneParams.Size);
+					BufferSize=RxDoneParams.Size;
+					 lora_huanxing_count++;
+					if(RX_Buffer[0]==0x04&&RX_Buffer[1]=='I'&&RX_Buffer[2]=='N'&&RX_Buffer[3]=='G')
+						{
+             
+							time_flag_lorarx=phy_timer_count_get();
+							UwbRange();
+					    //rf_enter_continous_rx(); //重新进入接收模式
+				    	//LORA_REV_uwb_up=1;
+						}
+				 if(RX_Buffer[MSG_TYPE_IDX]==LORA_MSGTYPE_WGRESPTAG)
+						{
+							checksum1=Checksum_u16(RX_Buffer,BufferSize-2);
+							
+              memcpy(&DEST_ID,&RX_Buffer[DEST_ID_IDX],2);
+							memcpy(&CRC16,&RX_Buffer[BufferSize-2],2);
+							if(!memcmp(&checksum1,&RX_Buffer[BufferSize-2],2))
+							if(!memcmp(&dev_id,&RX_Buffer[DEST_ID_IDX],2))
+							{
+								memcpy(&source_id,&RX_Buffer[SOURCE_ID_IDX],2); 
+								if(wg_state==WG_Lost)
+									{
+									 wg_state = WG_Connected;
+									 wg_report_id = source_id;
+									}
+								if(!memcmp(&wg_report_id,&RX_Buffer[SOURCE_ID_IDX],2))
+								{
+										wg_lost_count = 0;
+										switch(RX_Buffer[PWTAG_RW_FLAG_IDX])
+										{
+												case WGRSP_RWTAG_NONE:
+//                        current_count = HAL_LPTIM_ReadCounter(&hlptim1);
+//                        wg_report_freq = RX_Buffer[POLL_FREQ_IDX]+400;
+//                        memcpy(&rec_delaytime,&RX_Buffer[NEXTPOLL_TIME_IDX],2);
+//                        if(report_ancnum<2)
+//                        {
+//                            datalen_offset = report_ancnum*85;
+//                        }else{
+//                            datalen_offset = (report_ancnum-1)*46+85;
+//                        }
+//                        rec_secdelay = RX_Buffer[PWTAG_SECDELAY_IDX];
+//                        if(BufferSize!=13||rec_secdelay>20)
+//                        {
+//                            rec_secdelay = 0;
+//                        }
+//                    
+//                        target_count = current_count + rec_delaytime*3.2768 - delaytime-datalen_offset;
+//                        while(target_count>=32768)
+//                            target_count-=32768;
+//                        __HAL_LPTIM_COMPARE_SET(&hlptim1, target_count);
+                       // rx_count = HAL_LPTIM_ReadCounter(&hlptim1);
+                     //   printf("tx %d,rx %d,delay %d",current_count>>5,rx_count>>5,rec_delaytime);
+                        break;
+												case WGRSP_RWTAG_READ:
+															no_rx_flag = 1;
+															LoraSendComMap(WGRSP_RWTAG_READ);
+															break;
+												case WGRSP_RWTAG_WRITE:
+														rec_index = RX_Buffer[PWTAG_WRITE_IDX_IDX];
+													switch(rec_index)
+															{
+																	case 0xdd:  //语音下发
+																			break;
+//                        case 0x20:  //蜂鸣
+//                            memcpy(&rec_value,&RX_Buffer[PWTAG_WRITE_VALUE_IDX],2);
+//                            motor_keeptime = rec_value;
+//                            break;
+                        default :
+                            memcpy(&rec_value,&RX_Buffer[PWTAG_WRITE_VALUE_IDX],2);
+                            g_com_map[rec_index/2] = rec_value;
+                            save_com_map_to_flash();
+                            LoraRspWriteCommap(SUBMSG_WRITE_ANCPARA);
+                            //flag_writepara_needreset = 1;
+                            no_rx_flag = 1;                           
+															}
+
+															break; 
+												case WGRSP_RWTAG_UPDATE:
+												rec_index = RX_Buffer[PWTAG_WRITE_IDX_IDX];
+												switch(rec_index)
+												{
+														case 0xaa:  //升级下发
+														memcpy(&rec_wenjian_daxiao,&RX_Buffer[WRITEPARA_VALUE_IDX],2);//文件大小
+														if(rec_wenjian_daxiao>0XAC00||rec_wenjian_daxiao==0)
+														{}//文件过大,超出范围
+														else
+														{
+																memcpy(&wangguan_up_id,&RX_Buffer[SOURCE_ID_IDX],2);//网关ID 占用2个字节
+																shengji_flag=1;
+																LoraUp_flag=1;   
+																imu_enable=0;                            
+														}
+//                    		  LoraUp_Poll();
+																break;                        
+												}
+														break; 
+										}
+									}
+								}
+
+							}						
+
+				
+      }
+			if(tx_flag == RADIO_FLAG_TXDONE)
+        {
+				 //rf_set_mode(RF_MODE_STB3);
+				 rf_set_transmit_flag(RADIO_FLAG_IDLE);
+					Loratx_flag++;
+
+//				#ifdef DEBUG_BOXING
+//		    //gpio_pin_clr(IO_PIN_5);//测试
+//		    gpio_pin_set(IO_PIN_5);//测试
+//				#endif
+				rf_enter_single_timeout_rx(100);
+			 // rf_enter_single_rx();
+			//		rf_enter_continous_rx();
+
         }
+        if((recv_flag == RADIO_FLAG_RXTIMEOUT))
+        {
+//							#ifdef DEBUG_BOXING
+//							gpio_pin_clr(IO_PIN_5);//测试
+//				//		gpio_pin_set(IO_PIN_5);//测试
+//							#endif
+					
+					//这个超时接收是会自动重启的,所以必须将芯片状态置成STB3这样就退出了连续接收状态
+					  rf_set_mode(RF_MODE_STB3);
+					//这个超时接收是会自动重启的,所以必须将芯片状态置成STB3这样就退出了连续接收状态
+					
+						Lorarx_time_out_flag++;
+					  rf_set_recv_flag(RADIO_FLAG_IDLE);
+					
+					//  rf_clr_irq(REG_IRQ_RX_TIMEOUT);
+				 //  rf_enter_single_timeout_rx(100);
+        }
+				if((recv_flag == RADIO_FLAG_RXERR))
+				{
+				    rf_set_recv_flag(RADIO_FLAG_IDLE);
+				}
+				
 }
+
+
+
 void Board_LORA_NVIC_Init(GPIO_IRQ_HANDLER_T irq_handler)  //LORA 中断配置
 {
 //        io_pin_mux_set(_4G_USART_RX_Pin,IO_FUNC0);//把原先io 变为普通GPIO
@@ -574,7 +720,10 @@
 }
 
 uint8_t io14_state;
-
+uint16_t  lora_freq=0;
+uint16_t  lora_up_count=0;
+uint8_t TXBuffer[8]={0,1,2,3,4,5,6,7};
+uint8_t test_buf[10]={0,1,1,1,1,1,1,1,1,1};
 int main(void)
 {
     board_clock_run();
@@ -628,12 +777,22 @@
     //board_led_init();
 
     spi_init();
+		//PCA9555_init();
     Board_LORA_NVIC_Init(Lora_irq_handler);
     Lora_init();
-    rf_set_default_para(DEFAULT_up_FREQ,DEFAULT_up_SF);
+		//lora_freq=DEFAULT_up_FREQ+g_com_map[GROUP_ID];
+    // rf_set_default_para(DEFAULT_up_FREQ+g_com_map[GROUP_ID],DEFAULT_up_SF);
+		rf_set_default_para(DEFAULT_WG_SET_FREQ,DEFAULT_WG_SET_SF);
+		//rf_enter_continous_rx();
+	//	rf_enter_continous_rx();
+//		if((rf_single_tx_data(TXBuffer,10,0))!= OK)
+//    {
+//        
+//    }
+		//rf_set_default_para(DEFAULT_WG_SET_FREQ,DEFAULT_WG_SET_SF);
 	//	rf_set_default_para(DEFAULT_up_FREQ,DEFAULT_up_SF);
 //    
-    rf_enter_continous_rx();
+    //rf_enter_continous_tx();
 //    rf_set_transmit_flag(RADIO_FLAG_TXDONE);
 //    rf_set_transmit_flag(RADIO_FLAG_TXDONE);
 //    if(rf_continous_tx_send_data(tx_test_buf, TX_LEN) != 0)
@@ -661,6 +820,9 @@
 ////加速度计初始化必须在IO_control_init之前因为复用SDA引脚
 //    adc_get(&sample[0], NUM_SAMPLES, adc_callback);//adc采样
 		   Program_Init();
+			 
+
+      // rf_single_tx_data(TXBuffer,10,2);
 //    uart_receive(UART_ID1,m_EUART_DMA_RXBuf,EUART_RX_BUF_SIZE,uart_receive_callback);
 //    
 //// Initialize low power mode
@@ -668,20 +830,38 @@
 //      AIR780E_Reset(); //4G模块重启,耗时1.5秒,这个是无法同步的关键
     sleep_timer_open(true, SLEEP_TIMER_MODE_RELOAD, sleep_timer_callback);
 
- //  sleep_timer_start(__MS_TO_32K_CNT(1000));//测试
+		sleep_timer_start(__MS_TO_32K_CNT(1000));//测试
 #ifdef DEBUG_BOXING
 		io_pin_mux_set(IO_PIN_5,IO_FUNC0);
 		gpio_pin_set_dir(IO_PIN_5,GPIO_DIR_OUT,0);
 		io_pull_set(IO_PIN_5,IO_PULL_DOWN,IO_PULL_UP_LEVEL4);
 #endif
+    //rf_enter_single_timeout_rx(1000);
 //    board_acceleration_detection_init(move_handler);
+		  //rf_enter_single_timeout_rx(900);
+		//rf_enter_single_timeout_rx(500);
+	  //rf_enter_single_rx();
     Uwbinit();
     while (1)
-    {
-		
+    { 
+//     rf_irq_process();
+
+     //rf_enter_single_rx();
+     
+	    Lora_Tx_Poll();
+//		if((rf_single_tx_data(TXBuffer,10,0))!= OK)
+//    {
+//        
+//    }
+			//		#ifdef DEBUG_BOXING
+//     	gpio_pin_clr(IO_PIN_5);//测试
+//		gpio_pin_set(IO_PIN_5);//测试
+			
 //		test_Delay_us(1000);
 //		gpio_pin_set(IO_PIN_5);//测试
-//	  test_Delay_us(1000);
+//	     test_Delay_us(100000);
+//			 test_Delay_us(100000);
+//			 test_Delay_us(100000);
 //		gpio_pin_clr(IO_PIN_5);//测试
 //		test_Delay_us(2000);
 //		gpio_pin_set(IO_PIN_5);//测试
@@ -693,13 +873,8 @@
 //				UwbRange();
 //			}
 
-//        if(g_start_send_flag)
-//        {
-//            g_start_send_flag=0;
-//           // Lora_Report_poll();
-//					 // Lora_UploadHeartBeartPoll();
-//        }
-				
+
+
         
        // UwbRange();
 //        rf_irq_process();

--
Gitblit v1.9.3