dtu_gateway/app/App/ec800m.h

#ifndef _EC800M_H
#define _EC800M_H
#include "gd32f10x.h"
#include "device_message.h"




#define AT(cmd) "AT+"##cmd
#define RSP_READY "RDY"
#define RSP_OK "OK"
#define RSP_CONNECT "CONNECT"

#define CLIENTID "device_test"
#define CMD_SET_PDP "AT+QICSGP=1,1,\"CTNET\",\"\",\"\",1\r\n" // UNINET?? CMNET?? CTNET??
#define CMD_SET_ACTIVE "AT+QIACT=1\r\n"
#define CMD_SET_URL "AT+QHTTPURL=%d\r\n"
#define CMD_GET "AT+QHTTPGET=100\r\n"
#define CMD_GET_TO_FILE "AT+QHTTPREADFILE=\"UFS:http.txt\",80\r\n"
#define CMD_HTTP_GET "QHTTPGET:"
#define CMD_READ_FILE "AT+QFDWL=http.txt\r\n"

#define OPEN_otaMSG_FILE "AT+QFOPEN=\"otaMSG.txt\",1\r\n"
#define WRITE_otaMSG_FILE "AT+QFWRITE=1,8,3\r\n"
#define CLOSE_otaMSG_FILE "AT+QFCLOSE=1\r\n"
#define LOAD_otaMSG_FILE "AT+QFDWL=otaMSG.txt\r\n"
#define DEL_otaMSG_FILE "AT+QFDEL=otaMSG.txt\r\n"

#define OPEN_otaDATA_FILE "AT+QFOPEN=\"otaDATA.txt\",0\r\n"
#define WRITE_otaDATA_FILE "AT+QFWRITE=1,128,2\r\n"
#define CLOSE_otaDATA_FILE "AT+QFCLOSE=1\r\n"
#define LOAD_otaDATA_FILE "AT+QFDWL=otaDATA.txt\r\n"
#define DEL_otaDATA_FILE "AT+QFDEL=otaDATA.txt\r\n"

#define READ_otaDATA_FILE "AT+QFREAD=1,1024\r\n"
#define TEST_DATA "0123456789abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ\r\n0123456789abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ\r\n"

#define ATI "ATI"

#define CMD_MQTT_DISCONNECT "AT+QMTDISC=0\r\n"
// ??MQTT??3.1.1 ??????--4(mqtt 3.1.1 )3(mqtt 3.1)
#define CMD_MQTT_VERSION "AT+QMTCFG=\"version\",0,4\r\n"
#define CMD_MQTT_KEEPALIVE "AT+QMTCFG=\"qmtping\",0,30\r\n" // 30????
#define CMD_MQTT_OPENET "AT+QMTOPEN=0,\"36.134.23.11\",1883\r\n"
// #define	CMD_MQTT_CONNECT  "AT+QMTCONN=0,\"%s\",\"%s\",\"%s\"\r\n"//  ?????clientid,username,password
#define CMD_MQTT_CONNECT "AT+QMTCONN=0,\"device_test\",\"\",\"\"\r\n"
#define CMD_MQTT_RECEIVE "AT+QMTCFG=\"recv/mode\",0,0,1\r\n"
#define CMD_MQTT_SEND "AT+QMTCFG=\"send/mode\",0,0,1\r\n"
// ???? ???????--??????--
#define CMD_MQTT_SUBSCRIBE "AT+QMTSUB=0,1,\"%s\",0\r\n" // ????????
#define CMD_SERVICE_Operatortyp						"AT+COPS?\r\n"
#define CMD_SERVICE_Networktyp						"AT+CREG?\r\n"//7
#define CMD_SERVICE_Networkstatu					"AT+COPS?\r\n"
#define CMD_SERVICE_SIMcardstatus					"AT+CLCK=\"SC\",2\r\n"
#define CMD_SERVICE_SIMcardICCID					"AT+QCCID\r\n"
#define CMD_SERVICE_IMEInumber						"AT+GSN\r\n"
#define CMD_SERVICE_Signalstrength				"AT+CSQ\r\n"


#define AT_CMD_HEAD 	"AT"
#define AT_CMD_CFG 		"+QMTCFG="
#define AT_CMD_TEST 	"?"
#define AT_CMD_VER		"version"

//#define AT_CMD_T 		"AT+QMTCFG=?\r\n"

#define AT_CMD_T 		"ATI\r\n"


#define true 1
#define false 0

void EC800MPwoerOn(void);
void EC800MSendCmd(char *buf, uint16_t len);

void EC800MWaitReady(void);

bool WaitResponse(char * expectStr, int timeout);
void ConnectMQTTSever(uint8_t *host,uint16_t port,uint8_t keepalive,uint8_t *clientid);
void EC800MSetPDP(void);

bool EC800MGetUrl(char *url,char *dmaBuffer,uint32_t bufferSize);
void MQTTPublish(void);
void MQTTSubTopic(uint8_t *commandTopic);
void ec800m_information_service(GATEWAY_PARAMS *gateway);

#endif