static void show_result(char *string, char is_over)
{COORD orig, current;CONSOLE_SCREEN_BUFFER_INFO info;HANDLE w = GetStdHandle(STD_OUTPUT_HANDLE);GetConsoleScreenBufferInfo(w, &info);current = info.dwCursorPosition;if (current.X == last_pos.X && current.Y == last_pos.Y) {SetConsoleCursorPosition(w, begin_pos);}else {/* changed by other routines, use the new pos as start */begin_pos = current;}if (is_over)SetConsoleTextAttribute(w, FOREGROUND_GREEN);//printf("Result: [ %s ]\n", string);printf(string);if (is_over){CString s = CString(string);//AfxMessageBox(LPCTSTR(s));HWND m_hWnd = pFrame->m_hWnd;//->GetMainWnd()->m_hWnd;SetDlgItemText(m_hWnd, IDC_STATIC, LPCTSTR(s));SetDlgItemText(m_hWnd, IDC_STATIC_ACTION, LPCTSTR(s));CString cmd = CString("C:\\Users\\Danny\\Desktop\\research\\Windows_iat1220_5c82a0db\\samples\\mqtt-publish\\bin\\Debug\\mqtt-publish.exe ");if(s.Find(_T("开"))>=0&& s.Find(_T("灯")) >= 0)cmd += "开灯";else if (s.Find(_T("关")) >= 0 && s.Find(_T("灯")) >= 0)cmd += "关灯";elsecmd += "UNKNOWN";USES_CONVERSION;LPCSTR lpcstr = (LPCSTR)T2A(cmd);WinExec(lpcstr, SW_HIDE);//PostMessage(pFrame->GetMainWnd()->m_hWnd, WM_MY_MESSAGE, NULL, NULL);}if (is_over)SetConsoleTextAttribute(w, info.wAttributes);GetConsoleScreenBufferInfo(w, &info);last_pos = info.dwCursorPosition;
}　　

static void Main(string[] args){if (args.Length == 0)return;string cmd = args[0];SendCmdRequest request = new SendCmdRequest();request.CmdContent = cmd;request.DeviceID = 520355898;request.IsByte = true;request.Protocol = Scheme.HTTP;DefaultOneNETClient client = new DefaultOneNETClient("api.heclouds.com", "vYKWEtx7jELTP2V4o=s1NgE1EdA=");var response=client.Execute(request);Console.WriteLine(response.Body);}

#include <ESP8266WiFi.h>
#include <ESP8266HTTPClient.h>
#include <PubSubClient.h>const char *ssid = "你的wifi name";
const char *password = "你的wifi密码";const char* mqtt_server = "183.230.40.39";
const char* mqtt_device_id="520355898";
const char* mqtt_product_id="223168";
const char* mqtt_api_key="vYKWEtx7jELTP2V4o=s1NgE1EdA=";WiFiClient client;
PubSubClient mqttClient(client);long lastMsg = 0;
char msg_buf[200];
char dataTemplete[]="{\"kq\":%d}";
char msgJson[75];
char debug_buf[200];
int i;
unsigned short json_len=0;
uint8_t* packet_p;
uint8_t debug_buffer_start_index = 0;void setup() {Serial.begin(115200);pinMode(BUILTIN_LED, OUTPUT);delay(10);WifiConnected();initMQTT();
}void initMQTT()
{mqttClient.setServer(mqtt_server, 6002);mqttClient.connect(mqtt_device_id,mqtt_product_id,mqtt_api_key);mqttClient.setCallback(callback);
}void callback(char* topic, byte* payload, unsigned int length) {Serial.print("Message arrived [");Serial.print(topic);Serial.print("] ");for (int i = 0; i < length; i++) {Serial.print((char)payload[i]);}Serial.println();String s_payload=String((char *)payload).substring(0, length);Serial.println(s_payload);//开灯命令？   if (s_payload.equals("关灯")||s_payload.equals("\"关灯\"")) {digitalWrite(BUILTIN_LED, LOW);} else if (s_payload.equals("开灯")||s_payload.equals("\"开灯\"")){digitalWrite(BUILTIN_LED, HIGH);}}void reconnect() {// Loop until we're reconnectedwhile (!mqttClient.connected()) {Serial.print("Attempting MQTT connection...");if (mqttClient.connect(mqtt_device_id,mqtt_product_id,mqtt_api_key)) {  //One net user name as product ID , and password as APIKeySerial.println("connected");// Once connected, publish an announcement...mqttClient.publish("outTopic", "hello world");// ... and resubscribemqttClient.subscribe("inTopic");} else {Serial.print("failed, rc=");Serial.print(mqttClient.state());Serial.println(" try again in 5 seconds");// Wait 5 seconds before retryingdelay(5000);}}
}void loop() {if (!mqttClient.connected()) {reconnect();}mqttClient.loop();long now = millis();if (now - lastMsg > 2000) {lastMsg = now;int kqValue=analogRead(A0);snprintf(msgJson,sizeof(msgJson),dataTemplete,kqValue);json_len=strlen(msgJson); //packet length count the end char '\0'msg_buf[0]=char(0x03);  //palyLoad packet byte 1, one_net mqtt Publish packet payload byte 1, type3 , json type2msg_buf[1]=char(json_len>>8);  //high 8 bits of json_len (16bits as short int type)msg_buf[2]=char(json_len&0xff); //low 8 bits of json_len (16bits as short int type)// snprintf(msg_buf+3,40,dataTemplete,value);memcpy(msg_buf+3,msgJson,strlen(msgJson));msg_buf[3+strlen(msgJson)] = 0;Serial.print("Publish message: ");Serial.println(msgJson);mqttClient.publish("$dp",(uint8_t*)msg_buf,3+strlen(msgJson),false); }
}void WifiConnected()
{WiFi.disconnect();WiFi.mode(WIFI_STA);Serial.println();Serial.print("Connecting to");Serial.println(ssid);WiFi.begin(ssid, password);while (WiFi.status() != WL_DISCONNECTED){delay(500);Serial.print(".");}randomSeed(micros());Serial.println(""); Serial.println("WIFI connected"); Serial.println(WiFi.localIP());}