/******************************************************************************
 * @file      drv_eg25gminipice.c
 * @brief     drv_eg25gminipice.c drivers
 * @version   V1.0
 * @author    Gary
 * @copyright
 ******************************************************************************/

#include "drv_eg25gminipice.h"

#define UART2_BAUDRATE 115200
#define MAX_RETRY 3

//4G实例化
static uint8_t sim_rec_buf[MAX_RECV_LEN] = {0};
LTE4G_STATIC_INIT(sim_item, 1, 0, 0, 1024,sim_rec_buf);


void drv_sim_push_data(Lte4GItem* item, uint8_t *buf, uint16_t len)
{
    uint16_t i = 0;

    if((item != NULL) && (item->buf_pos + len < item->buf_size))
    {
        for (i = 0; i < len; i++)
        {
            item->buf[item->buf_pos++] = buf[i];
        }
    }
}

void drv_uart2_Init(void) 
{
    RCC->APB1ENR |= RCC_APB1ENR_USART2EN;  // 使能 USART2 时钟
    RCC->AHB1ENR |= RCC_AHB1ENR_GPIOAEN;   // 使能 GPIOA 时钟

    GPIOA->MODER |= (2 << (2 * 2)) | (2 << (3 * 2));  // PA2(TX), PA3(RX) 复用模式
    GPIOA->AFR[0] |= (7 << (2 * 4)) | (7 << (3 * 4)); // 复用 AF7 (USART2)

    USART2->BRR = SystemCoreClock / UART2_BAUDRATE;
    USART2->CR1 = USART_CR1_TE | USART_CR1_RE | USART_CR1_UE;  // 使能串口、发送和接收
}

void drv_uart2_sendbyte(char c) 
{
    while (!(USART2->SR & USART_SR_TXE));  // 等待发送完成
    USART2->DR = c;
}

void drv_uart2_sendString(const char *str) 
{
    while (*str) {
        drv_uart2_sendbyte(*str++);
    }
}

void drv_send_at_cmd(const char *cmd, int delay_ms) 
{
    drv_uart2_sendString(cmd);
    drv_uart2_sendString("\r\n");  // AT 指令以 "\r\n" 结尾
    kit_time_dly_ms(30);
}



void drv_eg25g_init(void) 
{
    drv_send_at_cmd("AT", 500);                   // 1. 测试 AT 指令
    drv_send_at_cmd("AT+CPIN?", 500);             // 2. 查询 SIM 卡状态
    drv_send_at_cmd("AT+COPS=0", 500);            // 3. 让模块自动选择运营商
    drv_send_at_cmd("AT+CEREG?", 1000);           // 4. 查询 4G 注册状态
    // drv_send_at_cmd("AT+CGDCONT=1,\"IP\",\"your_apn\"", 500);  // 5. 设置 APN  如果支持自动识别则不需要设置apn
    drv_send_at_cmd("AT+CGACT=1,1", 1000);        // 6. 激活 PDP（获取 IP）
    drv_send_at_cmd("AT+CGPADDR=1", 500);         // 7. 查询分配的 IP 地址
}

// 发送 AT 指令并等待返回值,可用于此优化初始化函数
int drv_send_at_cmd2(const char *cmd, int delay_ms) 
{
    for (int i = 0; i < MAX_RETRY; i++)  // 失败最多重试 MAX_RETRY 次
    {
		drv_uart2_sendString(cmd);
		drv_uart2_sendString("\r\n");  // AT 指令以 "\r\n" 结尾
		kit_time_dly_ms(30);
        
        if (sim_item.buf_pos > 0 && strstr((const char*)sim_item.buf, "OK"))  // 解析返回值
        {
			sim_item.buf_pos = 0;
			memset(sim_item.buf,0x00,MAX_RECV_LEN);
            return 1;  // 成功
        }
    }
    return 0;  // 失败
}

void drv_eg25g_init2(void) 
{
    if (!drv_send_at_cmd2("AT", 500)) return;                   // 1. 测试 AT 指令
    if (!drv_send_at_cmd2("AT+CPIN?", 500)) return;             // 2. 查询 SIM 卡状态
    if (!drv_send_at_cmd2("AT+COPS=0", 500)) return;            // 3. 让模块自动选择运营商
    if (!drv_send_at_cmd2("AT+CEREG?", 1000)) return;           // 4. 查询 4G 注册状态
    if (!drv_send_at_cmd2("AT+CGDCONT=1,\"IP\",\"your_apn\"", 500)) return;  // 5. 设置 APN
    if (!drv_send_at_cmd2("AT+CGACT=1,1", 1000)) return;        // 6. 激活 PDP（获取 IP）
    if (!drv_send_at_cmd2("AT+CGPADDR=1", 500)) return;         // 7. 查询分配的 IP 地址
}

void drv_mqtt_connect(void) 
{
    drv_send_at_cmd("AT+QMTCFG=\"recv/mode\",0,0,1", 500);
    drv_send_at_cmd("AT+QMTOPEN=0,\"mqtt.example.com\",1883", 5000);
    drv_send_at_cmd("AT+QMTCONN=0,\"client_id\",\"username\",\"password\"", 5000);
}

void drv_mqtt_publish(const char *topic, const char *message) 
{
    char cmd[128];
    sprintf(cmd, "AT+QMTPUB=0,0,0,0,\"%s\",\"%s\"", topic, message);
    drv_send_at_cmd(cmd, 500);
}


/*

int main(void) {
    SystemInit();
    drv_uart2_Init();
    drv_eg25g_init();
    drv_mqtt_connect();
    
    while (1) 
	{
        drv_mqtt_publish("sensor/data", "{\"temperature\":25.3}");
        for (volatile int i = 0; i < 10000000; i++);  // 发送间隔
    }
}

*/