Revision 0:f0ae089c9363, committed 2015-08-12

Comitter:

ericliang

Date:

Wed Aug 12 02:44:16 2015 +0000

Commit message:

SmartTraffic

Changed in this revision

--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/MQTT_G_SENSOR.lib	Wed Aug 12 02:44:16 2015 +0000
@@ -0,0 +1,1 @@
+https://developer.mbed.org/users/ericliang/code/MQTT_G_SENSOR/#67520755e27e

--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/WISEAgent.cpp	Wed Aug 12 02:44:16 2015 +0000
@@ -0,0 +1,83 @@
+#include "WISEAgent.h"
+
+void messageCbf(MQTT::MessageData& md)
+{
+    MQTT::Message &message = md.message;
+    printf("Message arrived: qos %d, retained %d, dup %d, packetid %d\n", message.qos, message.retained, message.dup, message.id);
+    printf("Payload %.*s\n", message.payloadlen, (char*)message.payload);
+}
+
+MQTT::Client<MQTTEthernet, Countdown> *pMQTTClient;
+
+void Init(MQTTEthernet ipstack)
+{
+    if( !pMQTTClient )
+        pMQTTClient = new MQTT::Client<MQTTEthernet, Countdown>(ipstack);    
+}
+
+int WISEAgentConnect(const char *ip, char *uid)
+{
+    int rc = 0;
+    MQTT::Message message;
+        
+    // Register
+    char topic[128]={0};
+    char buf[256]={0};
+        
+    //snprintf(buf,sizeof(topic),RegistJson,uid, uid, uid, 0, uid, 1436160081000);
+        
+    MQTTPacket_connectData data = MQTTPacket_connectData_initializer;       
+    data.MQTTVersion = 3;   
+    data.clientID.cstring= uid;//mac;
+    data.username.cstring = "ral";
+    data.password.cstring = "123";
+    // willmessage
+    data.will.topicName.cstring = DEF_WILLMSG_TOPIC;
+    data.will.message.cstring = buf;
+    
+    memset(topic, 0, sizeof(topic));
+    memset(buf, 0, sizeof(buf)); 
+        
+    if ((rc = pMQTTClient->connect(data)) != 0) {
+       printf("rc from MQTT connect is %d\n", rc);
+       return rc;
+    }
+           
+    snprintf(topic,sizeof(topic),WA_PUB_CONNECT_TOPIC,uid);
+    //snprintf(buf,sizeof(topic),RegistJson,uid, uid, uid, 1, uid, 1436160081020);
+    
+    message.qos = MQTT::QOS0;
+    message.retained = false;
+    message.dup = false;
+    message.payload = (void*)buf;
+    message.payloadlen = strlen(buf)+1;
+            
+    if( rc = pMQTTClient->publish(topic, message) != 0 ) {
+       printf("rc from MQTT publish topic=%s rc= %d\n", topic, rc);
+       return rc;        
+    }
+    
+    memset(topic, 0, sizeof(topic));
+    memset(buf, 0, sizeof(buf)); 
+
+    snprintf(topic,sizeof(topic),WA_PUB_ACTION_TOPIC,uid);
+    //snprintf(buf,sizeof(topic),OSInfoJson,ip, uid, 1436160081030);   
+
+    message.payloadlen = strlen(buf)+1;
+            
+    if( rc = pMQTTClient->publish(topic, message) != 0 ) {
+       printf("rc from MQTT publish topic=%s rc= %d\n", topic, rc);
+       return rc;        
+    }        
+    
+    memset(topic, 0, sizeof(topic));
+    memset(buf, 0, sizeof(buf));     
+    snprintf(topic,sizeof(topic),WA_SUB_CBK_TOPIC,uid);    
+
+    if ((rc = pMQTTClient->subscribe(topic, MQTT::QOS1, messageCbf)) != 0) {
+        printf("rc from MQTT subscribe is %d\n", rc);     
+        return rc;
+    }
+    
+    return rc;
+}
\ No newline at end of file

--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/WISEAgent.h	Wed Aug 12 02:44:16 2015 +0000
@@ -0,0 +1,27 @@
+#ifndef WISEAGENT_CLIENT_H
+#define WISEAGENT_CLIENT_H
+
+#include "MQTTEthernet.h"
+#include "MQTTClient.h"
+
+#define DEV_UNID "0014DAE996BE8899"
+#define SENHUB_UNID "000EC6F0F831"
+
+
+// Public
+#define DEF_WILLMSG_TOPIC    "/cagent/admin/devId/willmessage"  /*publish*/
+#define WA_PUB_CONNECT_TOPIC "/cagent/admin/%s/agentinfoack"
+#define WA_PUB_ACTION_TOPIC  "/cagent/admin/%s/agentactionreq"
+#define WA_PUB_DEVINFO_TOPIC "/cagent/admin/%s/deviceinfo"
+
+                               
+
+// Subscribe
+#define WA_SUB_CBK_TOPIC "/cagent/admin/%s/agentcallbackreq"
+
+
+
+void Init(MQTTEthernet ipstack);
+int WISEAgentConnect(const char *ip, char *uid);
+
+#endif