一个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;

/* 

 * [url=home.php?mod=space&uid=247401]@brief[/url]   定义AT控制器

 */

static at_obj_t at;



const at_adapter_t adap = {  //AT适配器接口

 //适配GPRS模块的串口读写接口

 .write       = uart_write,

 .read        = uart_read

 ...

};

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);

}