From 42c0d595c6ab74396416028dffa398a31da1b335 Mon Sep 17 00:00:00 2001 From: WXK <287788329@qq.com> Date: 星期三, 24 一月 2024 10:29:10 +0800 Subject: [PATCH] 1 --- Src/radio/Lora.c | 275 ++++++++++++++++++++++++------------------------------ 1 files changed, 123 insertions(+), 152 deletions(-) diff --git a/Src/radio/Lora.c b/Src/radio/Lora.c index 38449a6..ca0bc06 100644 --- a/Src/radio/Lora.c +++ b/Src/radio/Lora.c @@ -9,11 +9,10 @@ #include "string.h" #include "stdio.h" #include "delay.h" -static RadioEvents_t RadioEvents; +#include "dw_mbx_anc.h" #define USE_MODEM_LORA //#define USE_MODEM_FSK #define REGION_CN779 - #if defined( REGION_AS923 ) #define RF_FREQUENCY 923000000 // Hz @@ -71,6 +70,56 @@ */ static RadioEvents_t RadioEvents; +/** + * @brief Update CRC16 for input byte + * @param CRC input value + * @param input byte + * @retval Updated CRC value + */ +uint16_t UpdateCRC16(uint16_t crcIn, uint8_t byte) +{ + uint32_t crc = crcIn; + uint32_t in = byte|0x100; + + do + { + crc <<= 1; + in <<= 1; + + if(in&0x100) + { + ++crc; + } + + if(crc&0x10000) + { + crc ^= 0x1021; + } + } while(!(in&0x10000)); + + return (crc&0xffffu); +} + +/** + * @brief Cal CRC16 for YModem Packet + * @param data + * @param length + * @retval CRC value + */ +uint16_t Cal_CRC16(const uint8_t* data, uint32_t size) +{ + uint32_t crc = 0; + const uint8_t* dataEnd = data+size; + + while(data<dataEnd) + { + crc = UpdateCRC16(crc,*data++); + } + crc = UpdateCRC16(crc,0); + crc = UpdateCRC16(crc,0); + + return (crc&0xffffu); +} #if defined( USE_MODEM_LORA ) @@ -89,7 +138,7 @@ #define LORA_SYMBOL_TIMEOUT 0 // Symbols #define LORA_FIX_LENGTH_PAYLOAD_ON false #define LORA_IQ_INVERSION_ON_T false -#define LORA_IQ_INVERSION_ON_R true +#define LORA_IQ_INVERSION_ON_R false #elif defined( USE_MODEM_FSK ) @@ -115,7 +164,9 @@ TX_TIMEOUT, }States_t; -#define RX_TIMEOUT_VALUE 1000 +static uint8_t flag_lora_wait_sync = 0; + +#define RX_TIMEOUT_VALUE 9999 #define BUFFER_SIZE 64 // Define the payload size here const uint8_t PingMsg[] = "PING"; @@ -145,91 +196,40 @@ - +uint8_t LoraUp_flag; void OnTxDone( void ) { // T_R_Init(0); // Radio.Standby(); // Radio.Rx( RX_TIMEOUT_VALUE ); //进入接收 Radio.Sleep( ); + if(LoraUp_flag) + { + Radio.Rx( RX_TIMEOUT_VALUE ); + } //printf("TX SUCCESS2\r\n"); +} +static uint8_t rxbuffer[255],rxbuff_len; +static uint16_t rec_lp_count; +uint8_t GetLoraBufferAndLen(uint8_t* buffer,uint16_t* lp_count) +{ + memcpy(buffer,rxbuffer,rxbuff_len); + memcpy(lp_count,&rec_lp_count,2); + return rxbuff_len; } extern uint16_t tx_num; void OnRxDone( uint8_t *payload, uint16_t size, int16_t rssi, int8_t snr ) { - BufferSize = size; - memcpy( RX_Buffer, payload, BufferSize ); + rec_lp_count = HAL_LPTIM_ReadCounter(&hlptim1); + rxbuff_len = size; + memcpy( rxbuffer, payload, BufferSize ); RssiValue = rssi; SnrValue = snr; Radio.Standby(); - if(EnableMaster) - { - if(memcmp(RX_Buffer,PongMsg,4)==0) - { - LedToggle();//LED闪烁 - printf("Master RXD PONG!\r\n"); - - } - - -// HAL_Delay_nMS(1000); -// -// TX_Buffer[0] = 'P'; -// TX_Buffer[1] = 'I'; -// TX_Buffer[2] = 'N'; -// TX_Buffer[3] = 'G'; -// -//// crc_value=RadioComputeCRC(TX_Buffer,4,CRC_TYPE_IBM);//计算得出要发送数据包CRC值 -//// TX_Buffer[4]=crc_value>>8; -//// TX_Buffer[5]=crc_value; -//// //Radio.Send( TX_Buffer, 6); -// Radio.Send( TX_Buffer, 4); - -// HAL_GPIO_WritePin( OUT1_GPIO_Port, OUT1_Pin,GPIO_PIN_SET); -// printf("Master TXD PING!\r\n"); -// HAL_Delay_nMS( 1 ); -// HAL_GPIO_WritePin( OUT1_GPIO_Port, OUT1_Pin,GPIO_PIN_RESET); - - //printf("Master TXD PING!\r\n"); - } - else - { - if(memcmp(RX_Buffer,PingMsg,4)==0) - { - -// HAL_GPIO_WritePin( OUT1_GPIO_Port, OUT1_Pin,GPIO_PIN_SET); - printf("Slave RXD PING!\r\n"); -// HAL_Delay_nMS( 1 ); -// HAL_GPIO_WritePin( OUT1_GPIO_Port, OUT1_Pin,GPIO_PIN_RESET); - -// LedToggle();//LED闪烁 - //printf("Slave RXD PING!\r\n"); - -// T_R_Init(1); - -// TX_Buffer[0] = 'P'; -// TX_Buffer[1] = 'O'; -// TX_Buffer[2] = 'N'; -// TX_Buffer[3] = 'G'; - - -// crc_value=RadioComputeCRC(TX_Buffer,4,CRC_TYPE_IBM);//计算得出要发送数据包CRC值 -// TX_Buffer[4]=crc_value>>8; -// TX_Buffer[5]=crc_value; -// //Radio.Send( TX_Buffer, 6); - - - Radio.Send( TX_Buffer, 4); - printf("Slave TXD PONG!\r\n"); - } - else - { - Radio.Rx( RX_TIMEOUT_VALUE ); - printf("Slave TXD XXXX\r\n"); - } - } + flag_lora_wait_sync = 0; + SetFlagSyncSuccess(1); } void OnTxTimeout( void ) @@ -240,90 +240,13 @@ void OnRxTimeout( void ) { Radio.Standby(); - if(EnableMaster) - { - TX_Buffer[0] = 'P'; - TX_Buffer[1] = 'I'; - TX_Buffer[2] = 'N'; - TX_Buffer[3] = 'G'; - -// crc_value=RadioComputeCRC(TX_Buffer,4,CRC_TYPE_IBM);//计算得出要发送数据包CRC值 -// TX_Buffer[4]=crc_value>>8; -// TX_Buffer[5]=crc_value; - //Radio.Send( TX_Buffer, 6); - Radio.Send( TX_Buffer, 4); - -// HAL_GPIO_WritePin( OUT1_GPIO_Port, OUT1_Pin,GPIO_PIN_SET); -// HAL_Delay_nMS( 1 ); -// HAL_GPIO_WritePin( OUT1_GPIO_Port, OUT1_Pin,GPIO_PIN_RESET); - printf("Master TXD PING!\r\n"); - } - else - { - Radio.Rx( RX_TIMEOUT_VALUE ); - } + flag_lora_wait_sync = 0; } void OnRxError( void ) { - + flag_lora_wait_sync = 0; Radio.Standby(); - if(EnableMaster) - { - TX_Buffer[0] = 'P'; - TX_Buffer[1] = 'I'; - TX_Buffer[2] = 'N'; - TX_Buffer[3] = 'G'; - -// crc_value=RadioComputeCRC(TX_Buffer,4,CRC_TYPE_IBM);//计算得出要发送数据包CRC值 -// TX_Buffer[4]=crc_value>>8; -// TX_Buffer[5]=crc_value; - //Radio.Send( TX_Buffer, 6); - Radio.Send( TX_Buffer, 4); -// HAL_GPIO_WritePin( OUT1_GPIO_Port, OUT1_Pin,GPIO_PIN_SET); -// HAL_Delay_nMS( 1 ); -// HAL_GPIO_WritePin( OUT1_GPIO_Port, OUT1_Pin,GPIO_PIN_RESET); - printf("Master TXD PING!\r\n"); - } - else - { - Radio.Rx( RX_TIMEOUT_VALUE ); - } - -} - - - -void T_R_Init(uint8_t kind) -{ -// Radio.Init( &RadioEvents ); -// if(kind==1) //1:Txd config -// { -// Radio.SetChannel( RF_FREQUENCY ); -// Radio.SetTxConfig( MODEM_LORA, TX_OUTPUT_POWER, 0, LORA_BANDWIDTH, -// LORA_SPREADING_FACTOR, LORA_CODINGRATE, -// LORA_PREAMBLE_LENGTH_T, LORA_FIX_LENGTH_PAYLOAD_ON, -// false, 0, 0, LORA_IQ_INVERSION_ON_T, 1000 ); - -// } -// else //0:Rxd config -// { -// Radio.SetChannel( RF_FREQUENCY ); -// Radio.SetRxConfig( MODEM_LORA, LORA_BANDWIDTH, LORA_SPREADING_FACTOR, -// LORA_CODINGRATE, 0, LORA_PREAMBLE_LENGTH_R, -// LORA_SYMBOL_TIMEOUT, LORA_FIX_LENGTH_PAYLOAD_ON, -// 0, false, 0, 0, LORA_IQ_INVERSION_ON_R, false ); -// } -// -//// Radio.SetTxConfig( MODEM_LORA, TX_OUTPUT_POWER, 0, LORA_BANDWIDTH, -//// LORA_SPREADING_FACTOR, LORA_CODINGRATE, -//// LORA_PREAMBLE_LENGTH_T, LORA_FIX_LENGTH_PAYLOAD_ON, -//// false, 0, 0, LORA_IQ_INVERSION_ON_T, 1000 ); - -//// Radio.SetRxConfig( MODEM_LORA, LORA_BANDWIDTH, LORA_SPREADING_FACTOR, -//// LORA_CODINGRATE, 0, LORA_PREAMBLE_LENGTH_R, -//// LORA_SYMBOL_TIMEOUT, LORA_FIX_LENGTH_PAYLOAD_ON, -//// 0, false, 0, 0, LORA_IQ_INVERSION_ON_R, false ); } void Lora_Init(void) @@ -378,3 +301,51 @@ // TX_Buffer[5]=crc_value; } +uint8_t GetFlagLoraWaitSync(void) +{ + return flag_lora_wait_sync; +} +void SwitchLoraToSyncRec(uint32_t freq,uint8_t sf) +{ + RadioEvents.RxDone = OnRxDone; + RadioEvents.RxTimeout = OnRxTimeout; + RadioEvents.RxError = OnRxError; + Radio.Init( &RadioEvents ); + Radio.SetChannel( freq ); + flag_lora_wait_sync = 1; + + Radio.SetTxConfig( MODEM_LORA, TX_OUTPUT_POWER, 0, 2, + sf, LORA_CODINGRATE,LORA_PREAMBLE_LENGTH_T, LORA_FIX_LENGTH_PAYLOAD_ON, + false, 0, 0, LORA_IQ_INVERSION_ON_T, 3000 ); + + Radio.SetRxConfig( MODEM_LORA, LORA_BANDWIDTH, + sf,LORA_CODINGRATE, 0, LORA_PREAMBLE_LENGTH_R, + LORA_SYMBOL_TIMEOUT, LORA_FIX_LENGTH_PAYLOAD_ON, + 0, false, 0, 0, LORA_IQ_INVERSION_ON_R, 1 ); + +} + +uint16_t rec_wenjian_daxiao; +uint16_t wangguan_up_id; +uint8_t send_lora_data[250]; +extern uint8_t lora_recbuffer[255]; +uint8_t mudeshengjibao; +void LoraUp_Poll() +{ + uint16_t crc16; + rec_wenjian_daxiao=lora_recbuffer[WRITEPATE_VALUE_IDX]; + wangguan_up_id=lora_recbuffer[WG_ID_IDX]; + send_lora_data[MSG_TYPE_IDX]=LORA_MSGTYPE_UPDATE_CONFIRM; + memcpy(&send_lora_data[WANGGUAN_ID],&wangguan_up_id,2);//网关ID 占用2个字节 + memcpy(&send_lora_data[JIZHAN_ID],&dev_id,2);//标签或者基站的设备ID 2个字节 + crc16=Cal_CRC16(send_lora_data,5); + memcpy(&send_lora_data[5],&crc16,2); + LoraUp_flag=1; + Radio.Send(send_lora_data,7);//基站发送升级确认回复 + while(1) + { + + send_lora_data[MSG_TYPE_IDX]=LORA_MSGTYPE_UPDATEFILE_REQUEST; + send_lora_data[MUQIAN_BAG]=mudeshengjibao; + } +} \ No newline at end of file -- Gitblit v1.9.3