1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
	UsartPrintf(USART_DEBUG, "1. ATrn");//检查AT指令是否可用
	while(ESP8266_SendCmd("ATrn", "OK"))
		DelayXms(500);
	
	UsartPrintf(USART_DEBUG, "2. CWMODErn");//将8266设置为STA模式
	while(ESP8266_SendCmd("AT+CWMODE=1rn", "OK"))
		DelayXms(500);
	
	UsartPrintf(USART_DEBUG, "3. AT+CWDHCPrn");//开启DHCP
	while(ESP8266_SendCmd("AT+CWDHCP=1,1rn", "OK"))
		DelayXms(500);
		

	UsartPrintf(USART_DEBUG, "4. CWJAPrn");//设置要连接的WIFID的SSID和密码
	//ESP8266_WIFI_INFO		"AT+CWJAP="Lord AC","19981220"rn"
	while(ESP8266_SendCmd(ESP8266_WIFI_INFO, "OK"))
		DelayXms(500);
	
	UsartPrintf(USART_DEBUG, "5. CIPSTARTrn");//设置为TCP连接，并设定IP和端口号
	//ESP8266_ONENET_INFO		"AT+CIPSTART="TCP","183.230.40.39",6002rn"
	while(ESP8266_SendCmd(ESP8266_ONENET_INFO, "CONNECT"))
		DelayXms(500);
	
	UsartPrintf(USART_DEBUG, "6. ESP8266 Init OKrn");//初始化完成

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
#define PROID		"367119"

#define AUTH_INFO	"test"

#define DEVID		"619588959"

	if(MQTT_PacketConnect(PROID, AUTH_INFO, DEVID, 256, 0, MQTT_QOS_LEVEL0, NULL, NULL, 0, &mqttPacket) == 0)
	{
		ESP8266_SendData(mqttPacket._data, mqttPacket._len);			//上传平台
		
		dataPtr = ESP8266_GetIPD(250);									//等待平台响应
		if(dataPtr != NULL)
		{
			if(MQTT_UnPacketRecv(dataPtr) == MQTT_PKT_CONNACK)
			{
				switch(MQTT_UnPacketConnectAck(dataPtr))
				{
					case 0:UsartPrintf(USART_DEBUG, "Tips:	连接成功rn");status = 0;break;
					
					case 1:UsartPrintf(USART_DEBUG, "WARN:	连接失败：协议错误rn");break;
					case 2:UsartPrintf(USART_DEBUG, "WARN:	连接失败：非法的clientidrn");break;
					case 3:UsartPrintf(USART_DEBUG, "WARN:	连接失败：服务器失败rn");break;
					case 4:UsartPrintf(USART_DEBUG, "WARN:	连接失败：用户名或密码错误rn");break;
					case 5:UsartPrintf(USART_DEBUG, "WARN:	连接失败：非法链接(比如token非法)rn");break;
					
					default:UsartPrintf(USART_DEBUG, "ERR:	连接失败：未知错误rn");break;
				}
			}
		}
		
		MQTT_DeleteBuffer(&mqttPacket);								//删包
	}

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
unsigned char OneNet_FillBuf(char *buf)
{
	char text[48];
	
	memset(text, 0, sizeof(text));
	
		strcpy(buf, "{");
	
    memset(text, 0, sizeof(text));
		sprintf(text, ""test":%d,",666); 
    strcat(buf, text);
		
		memset(text, 0, sizeof(text));
		sprintf(text, ""test2":%d",888); 
    strcat(buf, text);
	
		strcat(buf, "}");
	
	return strlen(buf);
}


void OneNet_SendData(void)
{
	
	MQTT_PACKET_STRUCTURE mqttPacket = {NULL, 0, 0, 0};												//协议包
	
	char buf[128];
	
	short body_len = 0, i = 0;
	
	UsartPrintf(USART_DEBUG, "Tips:	OneNet_SendData-MQTTrn");
	
	memset(buf, 0, sizeof(buf));
	
	body_len = OneNet_FillBuf(buf);																	//获取当前需要发送的数据流的总长度
	
	if(body_len)
	{
		if(MQTT_PacketSaveData(DEVID, body_len, NULL, 3, &mqttPacket) == 0)							//封包
		{
			for(; i < body_len; i++)
				mqttPacket._data[mqttPacket._len++] = buf[i];
			
			ESP8266_SendData(mqttPacket._data, mqttPacket._len);									//上传数据到平台
			UsartPrintf(USART_DEBUG, "Send %d Bytesrn", mqttPacket._len);
			
			MQTT_DeleteBuffer(&mqttPacket);															//删包
		}
		else
			UsartPrintf(USART_DEBUG, "WARN:	EDP_NewBuffer Failedrn");
	}
	
}