智能管家（原型）

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 += "关灯";
else
cmd += "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
#include
#include
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 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 reconnected
while (!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 APIKey
Serial.println("connected");
// Once connected, publish an announcement...
mqttClient.publish("outTopic", "hello world");
// ... and resubscribe
mqttClient.subscribe("inTopic");
} else {
Serial.print("failed, rc=");
Serial.print(mqttClient.state());
Serial.println(" try again in 5 seconds");
// Wait 5 seconds before retrying
delay(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 type2
msg_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());
}