一种AT命令通信解析模块,支持裸机(at_chat)和OS版本(at)

/*AT作业项*/
typedef struct {
    unsigned int  state : 3;
    unsigned int  type  : 3;                                 /* 作业类型*/
    unsigned int  abort : 1; 
    void          *param;                                    /* 通用参数*/
 void          *info;                                     /* 通用信息指针*/
    struct list_head node;                                   /* 链表结点*/
}at_item_t;

/* 
 * @brief   定义AT控制器
 */
static at_obj_t at;

const at_adapter_t adap = {  //AT适配器接口
 //适配GPRS模块的串口读写接口
 .write       = uart_write,
 .read        = uart_read
 ...
};

/* 
 * @brief    wifi初始化
 */
void wifi_init(void)
{
 at_obj_init(&at, &adap);
 /*...*/
}driver_init("wifi", wifi_init); 

/* 
 * @brief    wifi任务(10ms 轮询1次)
 */
void wifi_task(void)
{
    at_poll_task(&at);
}task_register("wifi", wifi_task, 10);

//WIFI IO配置命令
=> AT+GPIO_TEST_EN=1\r\n

<= OK\r\n

/**
 * @brief AT执行回调处理程序
 */
static void test_gpio_callback(at_response_t *r)
{
 if (r->ret == AT_RET_OK ) {
     printf("Execute successfully\r\n");
 } else {
     printf("Execute failure\r\n");
 }
}
at_send_singlline(&at, test_gpio_callback, "AT+GPIO_TEST_EN=1");

static at_obj_t at;          //定义AT控制器对象

static char urc_buf[128];    //URC主动上报缓冲区

utc_item_t utc_tbl[] = {     //定义URC表
 "+CSQ: ", csq_updated_handler
}

const at_adapter_t adap = {  //AT适配器接口
 .urc_buf     = urc_buf,
 .urc_bufsize = sizeof(urc_buf),
 .utc_tbl     = utc_tbl,
 .urc_tbl_count = sizeof(utc_tbl) / sizeof(utc_item_t), 
 //debug调试接口
 .debug       = at_debug, 
 //适配GPRS模块的串口读写接口
 .write       = uart_write,
 .read        = uart_read
};

void at_thread(void)
{
 at_obj_create(&at, &adap);
    while (1) {        
        at_process(&at);
    }
}

/** at_do_cmd 接口使用演示
    查询GPRS模组信号质量命令
 => AT+CSQ
 
 <= +CSQ: 24, 0
 <= OK
*/

/* 
 * @brief    获取csq值
 */ 
bool read_csq_value(at_obj_t *at, int *rssi, int *error_rate)
{
 //接收缓冲区
 unsigned char recvbuf[32];
 //AT应答
 at_respond_t r = {"OK", recvbuf, sizeof(recvbuf), 3000};
 //
 if (at_do_cmd(at, &r, "AT+CSQ") != AT_RET_OK)
  return false;
 //提取出响应数据
 return (sscanf(recv, "%*[^+]+CSQ: %d,%d", rssi, error_rate) == 2);

}

/** at_do_work 接口使用演示
    参考自hl8518模组Socket 数据发送命令
 => AT+KTCPSND=<session_id>,<ndata>
 
 <= CONNECT
 
 => <data>
 
 <= OK
*/

/*
 * @brief       数据发送处理
 * @retval      none
 */
static bool socket_send_handler(at_work_ctx_t *e)
{
    struct socket_info *i = (struct socket_info *)e->params;
    struct ril_sock *s    = i->s;
    
    if (s->type == SOCK_TYPE_TCP)
        e->printf(e, "AT+KTCPSND=%d,%d", s->session, i->bufsize);
    else
        e->printf(e, "AT+KUDPSND=%d,%s,%d,%d",s->session, s->host, 
        s->port, i->bufsize);        

    if (e->wait_resp(e, "CONNECT", 5000) != AT_RET_OK) {      //等待提示符
       goto Error;
    }         
    e->write(i->buf, i->bufsize);                             //发送数据
    
    e->write("--EOF--Pattern--", strlen("--EOF--Pattern--")); //发送结束符

    if (e->wait_resp(e, "OK", 5000) == AT_RET_OK)
        return true;
    else {   
Error:
        e->write("--EOF--Pattern--", strlen("--EOF--Pattern--"));
        return false;
    }
}

/**
 * @brief       socket 数据发送
 * @param[in]   s   - socket
 * @param[in]   buf - 数据缓冲区
 * @param[in]   len - 缓冲区长度
 */
static bool hl8518_sock_send(ril_obj_t *r, struct ril_sock *s, const void *buf, 
                       unsigned int len)
{
    struct socket_info info = {s, (unsigned char *)buf, len, 0};
    if (len == 0)
        return false;       
    return at_do_work(&r->at, (at_work)socket_send_handler, &info);
}

git clone https://gitee.com/morixinguan/AT-Command.git