#include <rtthread.h>
#include <board.h>
#include <rtdevice.h>
#include <rtconfig.h>
#include <rtdbg.h>
#include <at_device_ml307.h>
#include "task_ML307A.h"
/*初始化ML307A at_client*/
static int ml307_device_register(void)
{
    at_client_init("uart2", ML307_SAMPLE_RECV_BUFF_LEN);
    return RT_EOK;
}
INIT_APP_EXPORT(ml307_device_register);
/*ML307A结构体回调函数 */
void CallBack(char *Cmd, float Cycle)
{
}
/*初始化ML307A命令结构体，回调函数暂时没用到 */
typML307A_t typML307ACmdTable[] =
{
        { "AT+MIPOPEN=0,\"TCP\",\"8.135.10.183\",39982,60,0", CallBack },          //5：连接服务器IP端口，数据发送
        { "AT+MIPSEND=0,11,\"12345678900\"",                  CallBack },          //6：发送数据
};
/*重新配置ML307A */
int ML307A_init_Reconfiguring(void)
{
    at_response_t resp = RT_NULL;
    const char *line_buffer = RT_NULL;
    /* 创建响应结构体，设置最大支持响应数据长度为 512 字节，响应数据行数无限制，超时时间为5 秒 */
    resp = at_create_resp(512, 0, rt_tick_from_millisecond(5000));
    if (!resp)
    {
        LOG_E("No memory for response structure!");
        return -RT_ENOMEM;
    }
    /* 发送 AT 命令并接收 AT Server 响应数据，数据及信息存放在 resp 结构体中并打印出来 */
    for (int i = 0; i < array_sizeof(typML307ACmdTable); i++)
    {
        if (at_exec_cmd(resp, typML307ACmdTable[i].CmdString) != RT_EOK)               //发送AT指令
        {
            LOG_E("%s Command not received response from ML307A", typML307ACmdTable[i].CmdString);
        }
        else
        {
            for (rt_size_t line_num = 1; line_num <= resp->line_counts; line_num++)      //将回应的数据打印出来
            {
                if ((line_buffer = at_resp_get_line(resp, line_num)) != RT_NULL)
                {
                    LOG_D("%s line%d Response buf: %s",typML307ACmdTable[i].CmdString,line_num, line_buffer);
                }
                else
                {
                    LOG_E("Parse line buffer error!");
                }
            }
        }
    }
    /* 命令发送成功 */
    LOG_D("AT Client send commands to AT Server success!");
    /* 删除响应结构体 */
    at_delete_resp(resp);
    return RT_EOK;
}

int main(void)
{
    int count = 1;
    ML307A_init_Reconfiguring();
    while (count++)
    {
        rt_thread_mdelay(1000);
    }
    return RT_EOK;
}