123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411 |
- #include "main.h"
- #include "lte.h"
- #include "myFIle.h"
- #include "malloc.h"
- #include "LTE_MQTT.h"
- #include "usart.h"
- uint8_t config_flag = 0;
- uint8_t UART6_RxCounter = 0;
- int socket;
- //PG6 初始化、拉低
- void SIM_CD_config()
- {
- GPIO_InitTypeDef GPIO_InitStruct = {0};
- __HAL_RCC_GPIOG_CLK_ENABLE();
- GPIO_InitStruct.Pin = GPIO_PIN_6;
- GPIO_InitStruct.Mode = GPIO_MODE_INPUT;
- GPIO_InitStruct.Pull = GPIO_PULLUP;
- GPIO_InitStruct.Speed = GPIO_SPEED_FREQ_HIGH;
- HAL_GPIO_Init(GPIOF, &GPIO_InitStruct);
- HAL_GPIO_WritePin(GPIOG,GPIO_PIN_6,GPIO_PIN_RESET);
- }
- // 模块上电
- // 拉高PA4,给EC800M上电
- void VBAT_config()
- {
- GPIO_InitTypeDef GPIO_InitStructure;
- __HAL_RCC_GPIOA_CLK_ENABLE();
- GPIO_InitStructure.Pin = GPIO_PIN_4;
- GPIO_InitStructure.Mode = GPIO_MODE_OUTPUT_PP;
- GPIO_InitStructure.Pull = GPIO_PULLUP;
- GPIO_InitStructure.Speed = GPIO_SPEED_FREQ_LOW;
- HAL_GPIO_Init(GPIOA, &GPIO_InitStructure);
- HAL_GPIO_WritePin(GPIOA,GPIO_PIN_4,GPIO_PIN_SET);
- }
- // 拉高PB12脚
- // 开机:需要在稳定的高电平时,拉低一段时间,再拉高
- // 本机因为初始化前为高电平,只需要拉低后即可开机
- //PWRKEY1电平与GPIOB12电平同步
- void EC800M_open()
- {
- VBAT_config(); // 模块上电
-
- GPIO_InitTypeDef GPIO_InitStructure;
- __HAL_RCC_GPIOB_CLK_ENABLE();
- GPIO_InitStructure.Pin = GPIO_PIN_12 ;
- GPIO_InitStructure.Mode = GPIO_MODE_OUTPUT_PP;
- GPIO_InitStructure.Pull = GPIO_PULLDOWN;
- GPIO_InitStructure.Speed = GPIO_SPEED_FREQ_HIGH;
- HAL_GPIO_Init(GPIOB, &GPIO_InitStructure);
- //当GPIO引脚初始化前为低电平时,需要进行下列步骤
- // delay_ms(35);
- // GPIO_WriteBit(GPIOB,GPIO_Pin_12,1);
- // GPIO_WriteBit(GPIOB,GPIO_Pin_13,1);
- // delay_ms(500);
- //
- // GPIO_WriteBit(GPIOB,GPIO_Pin_12,0);
- // GPIO_WriteBit(GPIOB,GPIO_Pin_13,0);
- delay_ms(1000); // 延时一段时间
- HAL_GPIO_WritePin(GPIOB,GPIO_PIN_12,GPIO_PIN_SET);
- }
- // 发送AT指令并对RX数据进行匹配
- int Iot_SendCmd(char* cmd, char* reply, int wait)
- {
- uint8_t i=0;
- int time = wait * 100;
- int rssi,res;
- memset(UART6_RX_BUF, 0, BUFF_SIZE);
- HAL_UART_Transmit(&USART_InitStruct_DEBUG, (uint8_t*)cmd, strlen(cmd), HAL_MAX_DELAY);
-
- LTE_Delay(time);
- while(UART6_RX_STAT != 1) // 判断是否接收数据
- {
- LTE_Delay(1);
- i++;
- if(i >= wait){
- printf("cat1 check out\r\n");
- return -1;
- }
- }
- UART6_RX_STAT = 0;
-
- if (!strcmp(reply,"+CSQ"))
- {
- char* rss_str = strstr((char*)UART6_RX_BUF, "+CSQ:");
- if (!rss_str) return 1;
-
- sscanf(rss_str, "+CSQ:%d,%d", &rssi, &res);
- if (rssi != 99) return 0;
-
- }
- else if (!strcmp(reply,"+QMTPUBEX"))
- {
- char MQ_str[64] = {0};
- sprintf(MQ_str,"%s",UART6_RX_BUF);
- char* MQ_send = strstr(MQ_str + 5, ">");
- if (MQ_send){
- // HAL_UART_Transmit(&USART_InitStruct_DEBUG, (uint8_t*)pubJsonString, strlen(pubJsonString), HAL_MAX_DELAY);
- return 0;
- }
- }
- if (strstr((char*)UART6_RX_BUF, reply))
- {
- return 0;
- }
- return 1;
- }
- // EC800M 的初始化
- void ec800_init()
- {
- uint16_t cat1_timeout = 0;
- while(Iot_SendCmd("AT\r\n","OK", 1)){
- LTE_Delay(1);
- cat1_timeout ++;
- if(cat1_timeout >= 2000){
- return;
- }
- }
- cat1_timeout = 0;
- while(Iot_SendCmd("AT+CFUN?\r\n","OK", 1)){
- LTE_Delay(1);
- cat1_timeout ++;
- if(cat1_timeout >= 2000){
- printf(" uart false\r\n");
- return;
- }
- }
- cat1_timeout = 0;
- Iot_SendCmd("AT+QCFG=\"nat\",0\r\n","OK", 1);
- while(Iot_SendCmd("AT+QCFG=\"nat\"\r\n","OK", 1)){
- LTE_Delay(1);
- cat1_timeout ++;
- if(cat1_timeout >= 2000){
- printf(" uart false\r\n");
- return;
- }
- }
- cat1_timeout = 0;
- printf("uart ok\r\n");
- while(Iot_SendCmd("AT+CPIN?\r\n","READY", 1)){
- LTE_Delay(1);
- cat1_timeout ++;
- if(cat1_timeout >= 2000){
- return;
- }
- }
- cat1_timeout = 0;
- printf("simcard ok\r\n");
- while(Iot_SendCmd("AT+CSQ\r\n","+CSQ", 1)){
- LTE_Delay(1);
- cat1_timeout ++;
- if(cat1_timeout >= 2000){
- return;
- }
- }
- // cat1_timeout = 0;
- // while(Iot_SendCmd("AT+COPS?\r\n","0,0", 1)){
- // LTE_Delay(1);
- // cat1_timeout ++;
- // if(cat1_timeout >= 2000){
- // return;
- // }
- // }
-
- cat1_timeout = 0;
- while(Iot_SendCmd("AT+COPS=0,0,\"CHN-CT\",7\r\n","0,0", 1)){
- LTE_Delay(1);
- cat1_timeout ++;
- if(cat1_timeout >= 2000){
- return;
- }
- }
-
- cat1_timeout = 0;
- while(Iot_SendCmd("AT+CEREG?\r\n","0,1", 1)){
- LTE_Delay(1);
- cat1_timeout ++;
- if(cat1_timeout >= 2000){
- return;
- }
- }
- printf("网络注册 ok\r\n");
- cat1_timeout = 0;
- while(Iot_SendCmd("AT+CGATT?\r\n","+CGATT: 1", 1)){
- LTE_Delay(1);
- cat1_timeout ++;
- if(cat1_timeout >= 2000){
- return;
- }
- }
- printf(" 网络附着 ok\r\n");
- }
- // TCP初始化
- void ec800_TCP(){
- uint16_t cat1_timeout = 0;
- while(Iot_SendCmd("AT+QHTTPCFG=\"contextid\",1\r\n","OK", 1)){
- LTE_Delay(1);
- cat1_timeout ++;
- if(cat1_timeout >= 2000){
- return;
- }
- }
-
- cat1_timeout = 0;
- while(Iot_SendCmd("AT+QHTTPCFG=\"contenttype\",1\r\n","OK", 3)){
- LTE_Delay(1);
- cat1_timeout ++;
- if(cat1_timeout >= 2000){
- return;
- }
- }
-
- // APN 联通:UNINET 移动:CMNET 电信:CTNET
- cat1_timeout = 0;
- while(Iot_SendCmd("AT+QICSGP=1,1,\"CTNET\",\"\",\"\",1\r\n","OK", 3)){
- LTE_Delay(1);
- cat1_timeout ++;
- if(cat1_timeout >= 2000){
- return;
- }
- }
-
- cat1_timeout = 0;
- while(Iot_SendCmd("AT+QIACT?\r\n","+QIACT", 3)){
- LTE_Delay(1);
- cat1_timeout ++;
- if(cat1_timeout >= 2000){
- return;
- }
- }
-
- cat1_timeout = 0;
- while(Iot_SendCmd("AT+QIACT=1\r\n","OK", 1)){
- LTE_Delay(1);
- cat1_timeout ++;
- if(cat1_timeout >= 2000){
- return;
- }
- }
-
- cat1_timeout = 0;
- while(Iot_SendCmd("AT+QIACT?\r\n","OK", 3)){
- LTE_Delay(1);
- cat1_timeout ++;
- if(cat1_timeout >= 2000){
- return;
- }
- }
- // 周期性发送心跳包
- // cat1_timeout = 0;
- // char message[64];
- // memset(message, 0, sizeof(message));
- // snprintf(message, sizeof(message), "AT+QICFG=\"send/auto\",1,120,\"C000\"\r\n");
- // while(Iot_SendCmd(message,"OK",2)){
- // LTE_Delay(1);
- // cat1_timeout ++;
- // if(cat1_timeout >= 2000){
- // return;
- // }
- // }
- }
- // 连接网址
- void http_set_url(char *url)
- {
- uint16_t cat1_timeout = 0;
- char message[32];
- snprintf(message, sizeof(message), "AT+QHTTPURL=%d,%d\r\n", strlen(url), 5);
- while(Iot_SendCmd(message,"CONNECT", 2)){
- LTE_Delay(1);
- cat1_timeout ++;
- if(cat1_timeout >= 2000){
- return;
- }
- }
- cat1_timeout = 0;
- printf("ready to send url\r\n");
- while(Iot_SendCmd(url,"OK", 5)){
- LTE_Delay(1);
- cat1_timeout ++;
- if(cat1_timeout >= 2000){
- return;
- }
- }
- cat1_timeout = 0;
- printf("url set OK\r\n");
- }
- //定义通过串口6发送AT指令命令
- int LTE_SendCmd(char *cmd, char* reply)
- {
- UART6_RxCounter = 0;
- int timeout = 10;
- memset(UART6_RX_BUF, 0, BUFF_SIZE);
- HAL_UART_Transmit(&USART_InitStruct_DEBUG, (uint8_t*)cmd, strlen(cmd), HAL_MAX_DELAY);
- while(timeout--) {
- LTE_Delay(1);
- if(strstr((char*)&UART6_RX_BUF, reply))
- break;
- printf("time = %d ", timeout);
- }
- printf("\r\n");
- if(timeout <= 0)
- return 1;
- return 0;
- }
- // HTTP获取数据
- int LTE_HTTP_get()
- {
- uint16_t cat1_timeout;
- int err,httprspcode,content_length,fd;
- __start:
- //发送 HTTP GET 请求,最大响应时间为 80 秒
- cat1_timeout = 0;
- while(Iot_SendCmd("AT+QHTTPGET=80\r\n","OK",1)){
- LTE_Delay(1);
- cat1_timeout ++;
- if(cat1_timeout >= 2000){
- goto __start;
- }
- }
- LTE_Delay(500);
- char* getStr = mymalloc(SRAMEX, 64);
- getStr = strstr((char*)&UART6_RX_BUF,"+QHTTPGET:");
- if (!getStr) {
- myfree(SRAMEX, getStr);
- goto __start;
- }
- sscanf(getStr, "+QHTTPGET: %d,%d,%d ", &err, &httprspcode, &content_length);
- if(200 == httprspcode)
- {
- printf("connect OK\r\n");
- myfree(SRAMEX, getStr);
- }
- else
- {
- myfree(SRAMEX, getStr);
- goto __start;
- }
- // 读取 HTTP 响应信息并将其储存到 UFS 文件中
- cat1_timeout = 0;
- while(Iot_SendCmd("AT+QHTTPREADFILE=\"UFS:test.txt\",80 \r\n","OK",20)){
- LTE_Delay(1);
- cat1_timeout ++;
- if(cat1_timeout >= 2000){
- return TIMEOUT;
- }
- }
-
- cat1_timeout = 0;
- // 打开文件
- while(Iot_SendCmd("AT+QFOPEN=\"test.txt\",2\r\n","OK",5)){
- LTE_Delay(1);
- cat1_timeout ++;
- if(cat1_timeout >= 2000){
- return TIMEOUT;
- }
- }
- char* readStr = mymalloc(SRAMEX, 128);
- readStr = strstr((char*)&UART6_RX_BUF,"+QFOPEN:");
- if(!readStr)
- {
- myfree(SRAMEX, readStr);
- goto __start;
- }
- sscanf(readStr, "+QFOPEN:%d ", &fd);// 获取文件指针
- myfree(SRAMEX, readStr);
-
- // 读取文件
- char* readMessage = mymalloc(SRAMEX, 32);
- sprintf(readMessage,"AT+QFREAD=%d\r\n", fd);
- while(Iot_SendCmd(readMessage,"OK",40)){
- printf("%s\n",UART6_RX_BUF);
- LTE_Delay(1);
- cat1_timeout ++;
- if(cat1_timeout >= 2000){
- myfree(SRAMEX, readMessage);
- goto __start;
- }
- }
- myfree(SRAMEX, readMessage);
- DeleteDirFile("device.txt");
- write_file("device.txt",(char*)&UART6_RX_BUF,strlen((char*)&UART6_RX_BUF));
- config_flag = 1;
-
- cat1_timeout = 0;
- // 关闭文件
- char closeCMD[32];
- sprintf(closeCMD,"AT+QFCLOSE=%d\r\n", fd);
- while(Iot_SendCmd(closeCMD,"OK",1)){
- LTE_Delay(1);
- cat1_timeout ++;
- if(cat1_timeout >= 2000){
- myfree(SRAMEX, closeCMD);
- return TIMEOUT;
- }
- }
- return SUCCESS;
- }
|