Minwei

Connection.cpp

@@ -1,9 +1,9 @@
 #include "Connection.h"
-
+#include <syslog.h>
 #include <cassert>
 
 Connection::Connection() {
-
+times=0;
 }
 
 void Connection::attach(Device *device) {
@@ -16,7 +16,7 @@ void Connection::detach(Device *device) {
 }
 
 void Connection::notify(const std::string &ip, int id,
-                        const std::vector<char> &buf) {
+                        const uint16_t buf[]) {
   for(Device *dev : devices_) {
     if(dev->equalIP(ip))
       dev->update(id, buf);

Connection.h

@@ -8,12 +8,12 @@
 class Connection {
  private:
   std::vector<Device*> devices_;
+  int times;
  public:
   Connection();
   void attach(Device *device);
   void detach(Device *device);
-  void notify(const std::string &ip, int id,
-              const std::vector<char> &buf);
+  void notify(const std::string &ip, int id,const uint16_t buf[]);
 };
 
 #endif

Device.cpp

@@ -5,29 +5,32 @@
 #include <sstream>
 #include <string>
 #include <cassert>
+#include <sys/time.h>
 #include "json.hpp"
+#include "ZLServer.h"
 #include <iostream>
 using json = nlohmann::json;
-Device::Device(const char ip[], const char id[]):ip_(ip), id_(id) {
+Device::Device(const char ip[], const char id[],const char type[],const char relationship[]):ip_(ip), id_(id),type_(type),relationship_(relationship) {
 
 }
 
 Device::~Device() {
   clearOpers();
 }
 
-void Device::update(int sid, const std::vector<char> &stats) {
-  int idx = 0;
+void Device::update(int sid,const uint16_t stats[]) {
+  if(equalType("controllableDevice")) syslog(LOG_INFO,"是按钮灯的函数哦%d",sid);
   bool newst = false;
-  for(char s : stats) {
-    for(Operation *oper : opers_) {
-      if(oper->equalPort(sid) && oper->equalAddr(idx)) {
-        newst |= oper->execute(s);
-        break; //TODO one state for one operation
+    int idx = 0;
+    for(int i=0;i<sizeof(stats);i++) {
+      for(Operation *oper : opers_) {
+        if(oper->equalPort(sid) && oper->equalAddr(idx)&&oper->isRead()) {
+          newst |= oper->execute(stats[i]);
+          break; //TODO one state for one operation
+        }
       }
+      idx += 1;
     }
-    idx += 1;
-  }
   if(newst) {
     for(Messager *mes : messagers_) {
       if(mes != nullptr) {
@@ -68,6 +71,26 @@ std::string Device::stateStr(Messager *mes) {
     assert(oper != nullptr);
     oper->stateStr(mes);
   }
+  mes->setDID(relationship_);
+  gchar *time_str = NULL;
+  GDateTime *time = NULL;
+  time = g_date_time_new_now_local();
+  time_str = g_date_time_format(time, "%Y/%m/%d %H:%M:%S");
+  mes->setTime(time_str);
+  g_free(time_str);
+  g_date_time_unref(time);
+
+  mes->dump();
+  return "";
+}
+
+std::string Device::stateStrSmartMeter(Messager *mes) {
+  mes->setID(id_);
+  mes->setDID(relationship_);
+  for(Operation* oper : opers_) {
+    assert(oper != nullptr);
+    oper->stateStr(mes);
+  }
 
   gchar *time_str = NULL;
   GDateTime *time = NULL;
@@ -86,6 +109,54 @@ void Device::clearOpers() {
     delete oper;
   opers_.clear();
 }
+///////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
+
+AGVLight::AGVLight(const char ip[], const char id[],const char type[],const char relationship[]):Device(ip,id,type,relationship) {
+syslog(LOG_INFO,"现在创建可操控设备:%s",id);
+}
+
+AGVLight::~AGVLight() {
+
+}
+void AGVLight::update(int sid,const uint16_t stats[])
+{
+//  syslog(LOG_INFO,"现在调用的是按钮灯的函数哦%d",sid);
+  for(Operation *oper : opers_) {
+    if(oper->equalName("lightflashing")) {
+        oper->execute(server_,ip_,"light1","off");
+    }
+  }
+}
+///////////////////////////////////////////////////////////////////////////////////////////////////////////////////
+SmartMeter::SmartMeter(const char ip[], const char id[],const char type[],const char relationship[]):Device(ip,id,type,relationship) {
+syslog(LOG_INFO,"现在创建电表设备:%s",id);
+}
+SmartMeter::~SmartMeter(){
+
+}
+void SmartMeter::update(int sid,const uint16_t stats[])
+{
+  //syslog(LOG_INFO,"现在调用的是电表的函数哦%d",sid);
+  bool newst = false;
+  for(Operation *oper : opers_) {
+    if(oper->equalPort(sid)&&oper->isRead()) {
+      if(oper->execute(stats))
+        newst=true;
+         }
+    }
+    if(newst) {
+      for(Messager *mes : messagers_) {
+        if(mes != nullptr) {
+          stateStr(mes);
+          for(Broker *bk : brokers_) {
+            if(bk != nullptr) {
+              mes->send(bk);
+            }
+          }
+        }
+      }
+    }
+}
 
 ///////////////////////////////////////////////////////////////////////
 DeviceFactory::DeviceFactory() {
@@ -106,21 +177,28 @@ std::vector<Device*> DeviceFactory::createDevices() {
     syslog(LOG_CRIT, "Device configure fail!");
     return devs; //TODO sth will do
   }
-  else 
+  else
   {
     syslog(LOG_CRIT, "Device configure success!");
   }
   OperationDefine opdef;
-    for (auto& element : js_["devices"]){ 
+    for (auto& element : js_["devices"]){
       std::string str_id=element["id"];
       char* id=(char*)str_id.c_str();
       syslog(LOG_CRIT,"Device has loded !!! id: %s",id);
       std::string str_ip=element["ip"];
       char* ip=(char*)str_ip.c_str();
       std::string str_type=element["type"];
       char* type=(char*)str_type.c_str();
-
-    Device *dev = new Device(ip, id);
+      std::string str_relationship=element["relationship"].dump();
+      char* relationship=(char*)str_relationship.c_str();
+    Device *dev;
+    if(strcmp(type,"controllableDevice")==0)
+    dev = new AGVLight(ip, id,type,relationship);
+    else if(strcmp(type,"electricMeter")==0)
+     dev = new SmartMeter(ip, id,type,relationship);
+    else
+    dev = new Device(ip, id,type,relationship);
     Broker *bro = kafDef_->getBroker(id);
     dev->attach(bro);
     Messager *mes = kafDef_->getMessager(id);
@@ -131,4 +209,3 @@ std::vector<Device*> DeviceFactory::createDevices() {
   }
   return devs;
 }
-

Device.h

@@ -1,22 +1,25 @@
 #ifndef _DEVICE_H_
 #define _DEVICE_H_
-
+class Connection;
 #include <string>
 #include <vector>
 #include <glib.h>
 #include "Operation.h"
 #include "Broker.h"
 #include "Messager.hpp"
-
+class ZLServer;
 class Device {
- private:
+protected:
   const std::string ip_;
   const std::string id_;
+  const std::string type_;
+  const std::string relationship_;
   std::vector<Operation*> opers_;
   std::vector<Broker*> brokers_;
   std::vector<Messager*> messagers_;
+  ZLServer* server_;
  public:
-  Device(const char ip[], const char id[]);
+  Device(const char ip[], const char id[],const char type[],const char relationship[]);
   ~Device();
   ////////////////////////////////////////////
   Device* equalIP(const std::string &ip) {
@@ -25,6 +28,13 @@ class Device {
   Device* equalID(const std::string &id) {
     return id_ == id ? this : nullptr;
   }
+
+  Device* equalType(const std::string &type) {
+    return type_ == type ? this : nullptr;
+  }
+  void setServer(ZLServer* server) {
+    server_=server;
+  }
   void setOpers(std::vector<Operation*> &opers) {
     clearOpers();
     opers_ = opers;
@@ -37,13 +47,37 @@ class Device {
     if(mes != nullptr)
       messagers_.push_back(mes);
   }
+
   //////////////////////////////////////////////////////
-  void update(int sid, const std::vector<char> &stats);
+  virtual void update(int sid, const uint16_t stats[]);
+
   std::string stateStr();
   std::string stateStr(Messager *mes);
+  std::string stateStrSmartMeter(Messager *mes);
  private:
   void clearOpers();
 };
+///////////////////////////////////////////下面是闪烁灯的创建////////////////////////////////////////////////////////////////////////////////
+
+  class AGVLight:public Device{
+  private:
+
+  public:
+    AGVLight(const char ip[], const char id[],const char type[],const char relationship[]);
+    ~AGVLight();
+    virtual void update(int sid, const uint16_t stats[]);
+  };
+
+//////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
+
+class SmartMeter:public Device{
+private:
+public:
+  SmartMeter(const char ip[], const char id[],const char type[],const char relationship[]);
+  ~SmartMeter();
+  virtual void update(int sid, const uint16_t stats[]);
+};
+//////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
 
 class DeviceFactory {
  private: