|
|
@ -15,7 +15,7 @@ char cmd_str[100] = {0}; |
|
|
|
|
|
|
|
|
/*关闭TCP连接*/ |
|
|
/*关闭TCP连接*/ |
|
|
void client_tcp_close(Cclient_t *client) { |
|
|
void client_tcp_close(Cclient_t *client) { |
|
|
sprintf(cmd_str, AT_QICLOSE, client->connect_ID); |
|
|
|
|
|
|
|
|
rt_sprintf(cmd_str, AT_QICLOSE, client->connect_ID); |
|
|
BSP_LTE_SendCmd(cmd_str, DEFAULT_EXPECT, DEFAULT_ERROR, LTE_CMD_WAIT_NORMAL); |
|
|
BSP_LTE_SendCmd(cmd_str, DEFAULT_EXPECT, DEFAULT_ERROR, LTE_CMD_WAIT_NORMAL); |
|
|
// client->connect_sta = false;
|
|
|
// client->connect_sta = false;
|
|
|
// client->error_cnt = 0;
|
|
|
// client->error_cnt = 0;
|
|
|
@ -112,9 +112,9 @@ int16_t client_tcp_connect(Cclient_t *client) { |
|
|
// 2, 打开链接
|
|
|
// 2, 打开链接
|
|
|
memset(cmd_cmd, 0, sizeof(cmd_cmd)); |
|
|
memset(cmd_cmd, 0, sizeof(cmd_cmd)); |
|
|
memset(cmd_str, 0, sizeof(cmd_str)); |
|
|
memset(cmd_str, 0, sizeof(cmd_str)); |
|
|
sprintf(cmd_cmd, AT_QIOPEN_TRANS /*AT_QIOPEN_FORW*/, client->connect_ID, |
|
|
|
|
|
|
|
|
rt_sprintf(cmd_cmd, AT_QIOPEN_TRANS /*AT_QIOPEN_FORW*/, client->connect_ID, |
|
|
client->mode, client->ip, client->port); |
|
|
client->mode, client->ip, client->port); |
|
|
sprintf(cmd_str, "+QIOPEN: %d,0", client->connect_ID); |
|
|
|
|
|
|
|
|
rt_sprintf(cmd_str, "+QIOPEN: %d,0", client->connect_ID); |
|
|
|
|
|
|
|
|
/*打开socket, 这个模块他不返回+QIOPEN:字符串*/ |
|
|
/*打开socket, 这个模块他不返回+QIOPEN:字符串*/ |
|
|
while (0 != BSP_LTE_SendCmd(cmd_cmd, CONNECTE_OK, DEFAULT_ERROR, |
|
|
while (0 != BSP_LTE_SendCmd(cmd_cmd, CONNECTE_OK, DEFAULT_ERROR, |
|
|
@ -142,7 +142,7 @@ int16_t client_tcp_connect(Cclient_t *client) { |
|
|
|
|
|
|
|
|
#ifdef LINK_4G |
|
|
#ifdef LINK_4G |
|
|
char buf[128] = {0}; |
|
|
char buf[128] = {0}; |
|
|
sprintf(buf, "{\"sn\":\"%s\",\"client_id\":\"%s\",\"csq\":\"%d\"}\r\n", lte_dev.iccid, |
|
|
|
|
|
|
|
|
rt_sprintf(buf, "{\"sn\":\"%s\",\"client_id\":\"%s\",\"csq\":\"%d\"}\r\n", lte_dev.iccid, |
|
|
lte_dev.imei,lte_dev.csq); |
|
|
lte_dev.imei,lte_dev.csq); |
|
|
|
|
|
|
|
|
rt_device_write(lte_dev.com_dev, 0, buf, sizeof(buf)); |
|
|
rt_device_write(lte_dev.com_dev, 0, buf, sizeof(buf)); |
|
|
@ -179,7 +179,7 @@ int16_t client_yield(CLte_dev_t *pLte_dev) { |
|
|
/*收到TCP关闭的消息*/ |
|
|
/*收到TCP关闭的消息*/ |
|
|
if (strstr((const char *)pLte_dev->at_buf, CLOSED)) { |
|
|
if (strstr((const char *)pLte_dev->at_buf, CLOSED)) { |
|
|
memset(cmd_str, 0, sizeof(cmd_str)); |
|
|
memset(cmd_str, 0, sizeof(cmd_str)); |
|
|
sprintf(cmd_str, "\"closed\",%d", pLte_dev->client1->connect_ID); |
|
|
|
|
|
|
|
|
rt_sprintf(cmd_str, "\"closed\",%d", pLte_dev->client1->connect_ID); |
|
|
if (NULL != strstr((char *)lte_dev.at_buf, cmd_str)) { |
|
|
if (NULL != strstr((char *)lte_dev.at_buf, cmd_str)) { |
|
|
EC800K_Reset(); |
|
|
EC800K_Reset(); |
|
|
pLte_dev->client1->connect_sta = false; |
|
|
pLte_dev->client1->connect_sta = false; |
|
|
|