Bluesun
/
BCU
forked from gary/BCU
2
0
Fork 0
Code Pull Requests Activity
BCU/library/drv_peripheral/drv_qfc41d.c

356 lines
8.7 KiB
C
Raw Normal View History

高压堆叠融合wifi功能，成功，第一版
2025-05-13 16:37:29 +08:00
/******************************************************************************
* @file drv_qfc41d.c
* @brief drv_qfc41d driver
* @version V1.0
* @author Gary
* @copyright
******************************************************************************/
#include "drv_qfc41d.h"
uint8_t rev_buff[QFC41D_MAX_RECV_SIZE] = {0};
uint8_t send_buff[QFC41D_MAX_SEND_SIZE] = {0};
配置下发主题分类
2025-05-29 18:13:04 +08:00
”实现了bluesun/bms/control/sn的主题配置“
2025-05-29 15:52:09 +08:00
#define MAX_PAYLOAD_LEN 128
高压堆叠融合wifi功能，成功，第一版
2025-05-13 16:37:29 +08:00
char cmd[1000] = {0}; //<2F><><EFBFBD><EFBFBD>ջ<EFBFBD>ռ<EFBFBD>ʹ<EFBFBD><CAB9>
与张工重新核对了一遍mqtt上传的数据--第一版
2025-05-17 08:27:05 +08:00
”实现了bluesun/bms/control/sn的主题配置“
2025-05-29 15:52:09 +08:00
#define TX_DMA_BUFFER_SIZE 2000
与张工重新核对了一遍mqtt上传的数据--第一版
2025-05-17 08:27:05 +08:00
volatile uint8_t dma_tx_busy = 0;
配置下发的驱动基本完成，配置下发成功后可以读取到ok
2025-06-04 13:18:56 +08:00
uint8_t dma_tx_buffer[2][TX_DMA_BUFFER_SIZE];
volatile uint8_t current_buffer = 0; // 0<><30>ʾ<EFBFBD><CABE><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>1<EFBFBD><31>ʾ<EFBFBD><CABE><EFBFBD><EFBFBD><EFBFBD>ȼ<EFBFBD><C8BC><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>
与张工重新核对了一遍mqtt上传的数据--第一版
2025-05-17 08:27:05 +08:00
高压堆叠融合wifi功能，成功，第一版
2025-05-13 16:37:29 +08:00
//<2F><><EFBFBD><EFBFBD>
WifiBleItem qfc41dItem = {
.dev = QFC41D_UART_PORT,
.buf_pos = 0,
.buf_size = QFC41D_MAX_RECV_SIZE,
.buf = rev_buff,
.sendCall = NULL,
};
”实现了bluesun/bms/control/sn的主题配置“
2025-05-29 15:52:09 +08:00
void parse_mqtt_message(char* message)
{
// ʾ<><CABE><EFBFBD><EFBFBD>Ϣ: +QMTRECV: 0,31,"bluesun/bms/control/123",11,"MQ3156+1MQ"
uint16_t first = 0;
uint16_t second = 0;
char* quotes[4] = {0};
int quote_count = 0;
for(char* p = message; *p && quote_count < 4; p++)
{
if(*p == '\"')
{
quotes[quote_count++] = p;
}
}
if(quote_count < 4)
{
return;
}
char* payload_start = quotes[2] + 1;
char* payload_end = quotes[3];
size_t payload_len = payload_end - payload_start;
if(payload_len >= MAX_PAYLOAD_LEN)
{
return;
}
char payload[MAX_PAYLOAD_LEN];
strncpy(payload, payload_start, payload_len);
payload[payload_len] = '\0';
char* processed = payload;
size_t len = strlen(processed);
// ȥ<><C8A5><EFBFBD><EFBFBD>ͷ"MQ"
if(len >= 2 && strncmp(processed, "MQ", 2) == 0)
{
processed += 2;
len -= 2;
}
// ȥ<><C8A5><EFBFBD><EFBFBD>β"MQ"
if(len >= 2 && strcmp(processed + len - 2, "MQ") == 0)
{
processed[len - 2] = '\0';
len -= 2;
}
配置下发主题分类
2025-05-29 18:13:04 +08:00
”实现了bluesun/bms/control/sn的主题配置“
2025-05-29 15:52:09 +08:00
char* plus_pos = strchr(processed, '+');
if(!plus_pos)
{
return;
}
配置下发主题分类
2025-05-29 18:13:04 +08:00
*plus_pos = '\0';
”实现了bluesun/bms/control/sn的主题配置“
2025-05-29 15:52:09 +08:00
first = atoi(processed);
second = atoi(plus_pos + 1);
配置下发主题分类
2025-05-29 18:13:04 +08:00
if(strstr(message, "control") != NULL)
{
if((first >= 3000) && (first <= 3168))
{
bcu_data_set_0x06_msg(first, second);
}
else if ((first >= 4000) && (first <= 4999))
{
hmi_write_modbus_cfg(first - 4000, second);
}
配置下发的驱动基本完成，配置下发成功后可以读取到ok
2025-06-04 13:18:56 +08:00
drv_mqtt_publish_control_no_respose("ok", 2);
配置下发主题分类
2025-05-29 18:13:04 +08:00
}
else if (strstr(message, "read") != NULL)
”实现了bluesun/bms/control/sn的主题配置“
2025-05-29 15:52:09 +08:00
{
配置下发主题分类
2025-05-29 18:13:04 +08:00
//<2F><>Ҫ<EFBFBD><D2AA><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>͹<EFBFBD><CDB9><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ʵʱֵDMA<4D>ϴ<EFBFBD><CFB4>ij<EFBFBD>ͻ<EFBFBD><CDBB><EFBFBD>⣬<EFBFBD><E2A3AC><EFBFBD>Գ<EFBFBD><D4B3>Ա<EFBFBD>־λ<D6BE><CEBB><EFBFBD>߶<EFBFBD><DFB6>еķ<D0B5>ʽ
drv_mqtt_publish_read_no_respose("1", 1);
”实现了bluesun/bms/control/sn的主题配置“
2025-05-29 15:52:09 +08:00
}
配置下发主题分类
2025-05-29 18:13:04 +08:00
”实现了bluesun/bms/control/sn的主题配置“
2025-05-29 15:52:09 +08:00
}
高压堆叠融合wifi功能，成功，第一版
2025-05-13 16:37:29 +08:00
static void drv_qfc41d_push_data(WifiBleItem* item, uint8_t *buf, uint16_t len)
{
uint16_t i = 0;
if((item != NULL) && (item->buf_pos + len < item->buf_size))
{
item->buf[item->buf_pos++] = buf[i];
// <20><><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>з<EFBFBD><D0B7><EFBFBD><EFBFBD><EFBFBD>ʾһ<CABE><D2BB><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD> AT ָ<><EFBFBD><EEB7B5>
if (buf[i] == '\n')
{
item->buf[item->buf_pos] = '\0'; // <20><><EFBFBD>ӽ<EFBFBD><D3BD><EFBFBD><EFBFBD><EFBFBD>
”实现了bluesun/bms/control/sn的主题配置“
2025-05-29 15:52:09 +08:00
if (item->buf_pos < 100)
{
parse_mqtt_message(item->buf); // <20><><EFBFBD><EFBFBD><EFBFBD><EFBFBD>Ϣ
}
高压堆叠融合wifi功能，成功，第一版
2025-05-13 16:37:29 +08:00
item->buf_pos = 0; // <20><><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>׼<EFBFBD><D7BC><EFBFBD><EFBFBD>һ<EFBFBD><D2BB><EFBFBD><EFBFBD><EFBFBD><EFBFBD>
}
}
}
static void drv_qf41d_uart_rx_it_call(kit_ret_e res, void *data)
{
OS_TRACE_ISR_ENTER();
drv_qfc41d_push_data(&qfc41dItem, data, 1);
OS_TRACE_ISR_EXIT();
}
// <20><><EFBFBD>͵<EFBFBD><CDB5><EFBFBD><EFBFBD>ַ<EFBFBD>
void drv_wireless_send_char(char c)
{
while (!(USART2->SR & USART_SR_TXE)); // <20>ȴ<EFBFBD><C8B4><EFBFBD><EFBFBD>ͻ<EFBFBD><CDBB><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>
USART2->DR = c;
}
// <20><><EFBFBD><EFBFBD><EFBFBD>ַ<EFBFBD><D6B7><EFBFBD>
void drv_wireless_send_string(const char *str)
{
while (*str)
{
drv_wireless_send_char(*str++);
}
drv_wireless_send_char('\r'); // <20><><EFBFBD><EFBFBD> CR
drv_wireless_send_char('\n'); // <20><><EFBFBD><EFBFBD> LF
}
配置下发的驱动基本完成，配置下发成功后可以读取到ok
2025-06-04 13:18:56 +08:00
void drv_wireless_send_string_dma_high_priority(const char *str)
与张工重新核对了一遍mqtt上传的数据--第一版
2025-05-17 08:27:05 +08:00
{
配置下发的驱动基本完成，配置下发成功后可以读取到ok
2025-06-04 13:18:56 +08:00
uint32_t timeout = 0;
uint32_t start_time = kit_time_get_tick();
while (dma_tx_busy && current_buffer == 0)
{
if (kit_time_get_tick() - start_time > 100)
{
DMA1_Stream6->CR &= ~DMA_SxCR_EN;
while (DMA1_Stream6->CR & DMA_SxCR_EN);
// <20><><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ܵ<EFBFBD><DCB5>жϱ<D0B6>־
DMA1->HIFCR |= DMA_HIFCR_CTCIF6 | DMA_HIFCR_CTEIF6;
dma_tx_busy = 0;
current_buffer = 0;
USART2->CR3 &= ~USART_CR3_DMAT;
break;
}
}
uint16_t len = 0;
while (*str && len < TX_DMA_BUFFER_SIZE - 2) {
dma_tx_buffer[1][len++] = *str++;
}
dma_tx_buffer[1][len++] = '\r';
dma_tx_buffer[1][len++] = '\n';
// <20><><EFBFBD><EFBFBD> DMA <20><><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>
DMA1_Stream6->CR &= ~DMA_SxCR_EN;
while (DMA1_Stream6->CR & DMA_SxCR_EN);
DMA1_Stream6->M0AR = (uint32_t)dma_tx_buffer[1];
DMA1_Stream6->NDTR = len;
dma_tx_busy = 1;
current_buffer = 1;
DMA1_Stream6->CR |= DMA_SxCR_EN;
USART2->CR3 |= USART_CR3_DMAT; // <20><><EFBFBD><EFBFBD> DMA <20><><EFBFBD><EFBFBD>
}
与张工重新核对了一遍mqtt上传的数据--第一版
2025-05-17 08:27:05 +08:00
配置下发的驱动基本完成，配置下发成功后可以读取到ok
2025-06-04 13:18:56 +08:00
void drv_wireless_send_string_dma(const char *str)
{
if (dma_tx_busy || current_buffer == 1) return; // <20><><EFBFBD>ڷ<EFBFBD><DAB7>ͻ<EFBFBD><CDBB><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ȼ<EFBFBD><C8BC><EFBFBD><EFBFBD><EFBFBD><EFBFBD>У<EFBFBD><D0A3><EFBFBD><EFBFBD><EFBFBD>
bsp_task_delay_ms(250);
与张工重新核对了一遍mqtt上传的数据--第一版
2025-05-17 08:27:05 +08:00
uint16_t len = 0;
// <20><><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ݵ<EFBFBD> DMA <20><><EFBFBD><EFBFBD><EFBFBD><EFBFBD>
配置下发的驱动基本完成，配置下发成功后可以读取到ok
2025-06-04 13:18:56 +08:00
while (*str && len < TX_DMA_BUFFER_SIZE - 2)
{
dma_tx_buffer[0][len++] = *str++;
与张工重新核对了一遍mqtt上传的数据--第一版
2025-05-17 08:27:05 +08:00
}
配置下发的驱动基本完成，配置下发成功后可以读取到ok
2025-06-04 13:18:56 +08:00
dma_tx_buffer[0][len++] = '\r';
dma_tx_buffer[0][len++] = '\n';
与张工重新核对了一遍mqtt上传的数据--第一版
2025-05-17 08:27:05 +08:00
// <20><><EFBFBD><EFBFBD> DMA <20><><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>
DMA1_Stream6->CR &= ~DMA_SxCR_EN;
while (DMA1_Stream6->CR & DMA_SxCR_EN);
配置下发的驱动基本完成，配置下发成功后可以读取到ok
2025-06-04 13:18:56 +08:00
DMA1_Stream6->M0AR = (uint32_t)dma_tx_buffer[0];
与张工重新核对了一遍mqtt上传的数据--第一版
2025-05-17 08:27:05 +08:00
DMA1_Stream6->NDTR = len;
dma_tx_busy = 1;
配置下发的驱动基本完成，配置下发成功后可以读取到ok
2025-06-04 13:18:56 +08:00
current_buffer = 0;
与张工重新核对了一遍mqtt上传的数据--第一版
2025-05-17 08:27:05 +08:00
DMA1_Stream6->CR |= DMA_SxCR_EN;
USART2->CR3 |= USART_CR3_DMAT; // <20><><EFBFBD><EFBFBD> DMA <20><><EFBFBD><EFBFBD>
}
高压堆叠融合wifi功能，成功，第一版
2025-05-13 16:37:29 +08:00
// <20><><EFBFBD><EFBFBD> AT ָ<><EFBFBD>ȴ<EFBFBD><C8B4><EFBFBD><EFBFBD><EFBFBD>ֵ
int drv_at_send_cmd(const char *cmd, const char *response, uint32_t timeout)
{
memset(qfc41dItem.buf, 0, QFC41D_MAX_RECV_SIZE);
qfc41dItem.buf_pos = 0; // <20><><EFBFBD>ս<EFBFBD><D5BD>ջ<EFBFBD><D5BB><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>
drv_wireless_send_string(cmd);
uint32_t start_time = kit_time_get_tick(); // <20><>ȡ<EFBFBD><C8A1>ǰʱ<C7B0><CAB1>
while (kit_time_get_tick() - start_time < timeout)
{
if (strstr((char *)qfc41dItem.buf, response))
{
return 1; // <20>ɹ<EFBFBD>ƥ<EFBFBD>䷵<EFBFBD><E4B7B5>ֵ
}
}
return 0; // <20><>ʱδ<CAB1>յ<EFBFBD><D5B5><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>
}
static uint8_t drv_wifi_init()
{
配置下发的驱动基本完成，配置下发成功后可以读取到ok
2025-06-04 13:18:56 +08:00
高压堆叠融合wifi功能，成功，第一版
2025-05-13 16:37:29 +08:00
if (!drv_at_send_cmd("AT", "OK", WIFI_TIMEOUT))
{
return 1 ;
}
if (!drv_at_send_cmd("AT+QSTASTOP", "OK", WIFI_TIMEOUT))
{
return 1;
}
if (!drv_at_send_cmd("AT+QSOFTAPSTOP", "OK", WIFI_TIMEOUT))
{
return 1;
}
return 0;
}
增加蓝牙消失检测，检测蓝牙消失后，重新初始化蓝牙
2025-05-19 08:44:03 +08:00
uint8_t drv_ble_init()
高压堆叠融合wifi功能，成功，第一版
2025-05-13 16:37:29 +08:00
{
if (!drv_at_send_cmd("AT+QBLEINIT=3", "OK", WIFI_TIMEOUT))
{
return 1;
}
//<2F><><EFBFBD><EFBFBD>wifi<66><69><EFBFBD>ƣ<EFBFBD><C6A3><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>BSM<53><4D>ͷ<EFBFBD><CDB7><EFBFBD><EFBFBD>׺<EFBFBD><D7BA><EFBFBD>Լ<EFBFBD>sn<73><6E>
增加蓝牙消失检测，检测蓝牙消失后，重新初始化蓝牙
2025-05-19 08:44:03 +08:00
if (!drv_at_send_cmd("AT+QBLENAME=BSM11223344", "OK", WIFI_TIMEOUT))
高压堆叠融合wifi功能，成功，第一版
2025-05-13 16:37:29 +08:00
{
return 1;
}
return 0;
}
uint8_t drv_qfc41d_init(void)
{
//<2F><>ʼ<EFBFBD><CABC><EFBFBD><EFBFBD><EFBFBD><EFBFBD>
drv_uart_init((UartDev)qfc41dItem.dev, 115200, 0 | UART_CFG_STOP_BIT_1, kGpioType_WIRELESSUart_Tx, kGpioType_WIRELESSUart_Rx);
USART2->CR1 = USART_CR1_TE | USART_CR1_RE | USART_CR1_RXNEIE | USART_CR1_UE;
//<2F><><EFBFBD>ý<EFBFBD><C3BD>ջص<D5BB><D8B5><EFBFBD><EFBFBD><EFBFBD>
drv_uart_set_interrupt(QFC41D_UART_PORT, kUartInterrupt_Rx, APP_CFG_INT_PRIO_UART2_RX, drv_qf41d_uart_rx_it_call);//#define SIM_UART_PORT kUartDev_2
//<2F><>ʼ<EFBFBD><CABC><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>BLE<4C><45>
if (drv_ble_init() != 0)
{
return 1;
}
return 0;
}
#define MQTT_BROKER "47.120.14.45" // <20><><EFBFBD><EFBFBD> MQTT <20><><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ַ
#define MQTT_PORT 3011 // MQTT <20>˿<EFBFBD>
#define MQTT_CLIENT_ID "fc41d_client" // <20>ͻ<EFBFBD><CDBB><EFBFBD> ID
#define MQTT_USER "user" // MQTT <20>û<EFBFBD><C3BB><EFBFBD>
#define MQTT_PASSWORD "password" // MQTT <20><><EFBFBD><EFBFBD>
配置下发主题分类
2025-05-29 18:13:04 +08:00
#define MQTT_TOPIC "bluesun/bms/period/11223344"
#define MQTT_TOPIC_control "bluesun/bms/control/reply/11223344"
#define MQTT_TOPIC_read "bluesun/bms/read/reply/11223344"
高压堆叠融合wifi功能，成功，第一版
2025-05-13 16:37:29 +08:00
static uint8_t drv_mqtt_subscribe()
{
snprintf(cmd, sizeof(cmd), "AT+MQTTSUB=0,1,\"%s\",2", MQTT_TOPIC);
drv_wireless_send_string(cmd);
return 0;
}
uint8_t drv_mqtt_publish(char* str,uint16_t length)
{
”实现了bluesun/bms/control/sn的主题配置“
2025-05-29 15:52:09 +08:00
snprintf(cmd, sizeof(cmd), "AT+QMTPUB=1,1,2,0,%s,%d,%s",MQTT_TOPIC, length, str);
与张工重新核对了一遍mqtt上传的数据--第一版
2025-05-17 08:27:05 +08:00
if (!drv_at_send_cmd(cmd, "OK\0", WIFI_TIMEOUT))
高压堆叠融合wifi功能，成功，第一版
2025-05-13 16:37:29 +08:00
{
return 1;
}
return 0;
}
uint8_t drv_mqtt_publish_no_respose(char* str,uint16_t length)
{
// snprintf(cmd, sizeof(cmd), "AT+QMTPUB=0,1,2,0,%s,%d,%s",MQTT_TOPIC, length, str);
”实现了bluesun/bms/control/sn的主题配置“
2025-05-29 15:52:09 +08:00
snprintf(cmd, sizeof(cmd), "AT+QMTPUB=1,1,2,0,\"%s\",%d,\"%s\"", MQTT_TOPIC, length, str);
mqtt上传数据的方式使用DMA，避免占用cpu
2025-05-19 11:40:39 +08:00
// drv_wireless_send_string(cmd); // δʹ<CEB4><CAB9>DMA
drv_wireless_send_string_dma(cmd); // ʹ<><CAB9>DMA
高压堆叠融合wifi功能，成功，第一版
2025-05-13 16:37:29 +08:00
return 0;
}
配置下发主题分类
2025-05-29 18:13:04 +08:00
uint8_t drv_mqtt_publish_control_no_respose(char* str,uint16_t length)
{
snprintf(cmd, sizeof(cmd), "AT+QMTPUB=1,1,2,0,\"%s\",%d,\"%s\"", MQTT_TOPIC_control, length, str);
配置下发的驱动基本完成，配置下发成功后可以读取到ok
2025-06-04 13:18:56 +08:00
drv_wireless_send_string_dma_high_priority(cmd);
配置下发主题分类
2025-05-29 18:13:04 +08:00
return 0;
}
uint8_t drv_mqtt_publish_read_no_respose(char* str,uint16_t length)
{
snprintf(cmd, sizeof(cmd), "AT+QMTPUB=1,1,2,0,\"%s\",%d,\"%s\"", MQTT_TOPIC_read, length, str);
配置下发的驱动基本完成，配置下发成功后可以读取到ok
2025-06-04 13:18:56 +08:00
drv_wireless_send_string_dma_high_priority(cmd);
配置下发主题分类
2025-05-29 18:13:04 +08:00
return 0;
}