|
@@ -97,20 +97,29 @@ func initConfig(name string) {
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// 设备->平台 激活网关
|
|
|
|
+func AiotSwitchActiva() {
|
|
|
|
+
|
|
// nats 注册 服务
|
|
// nats 注册 服务
|
|
type Struct struct {
|
|
type Struct struct {
|
|
- T_name string
|
|
|
|
- T_SwitchConfig map[string]map[string]string
|
|
|
|
|
|
+ T_SwitchName string
|
|
|
|
+ T_SwitchConnect string
|
|
|
|
+ T_SwitchDescribe string
|
|
|
|
+ T_SwitchConfig map[string]map[string]string
|
|
}
|
|
}
|
|
- b, _ := msgpack.Marshal(&Struct{T_name: SwitchName, T_SwitchConfig: SwitchConfig})
|
|
|
|
|
|
+ b, _ := msgpack.Marshal(&Struct{T_SwitchName: SwitchName, T_SwitchConnect: SwitchConnect, T_SwitchDescribe: SwitchDescribe, T_SwitchConfig: SwitchConfig})
|
|
|
|
|
|
// 请求-响应, 向 test3 发布一个 `help me` 请求数据,设置超时间3秒,如果有多个响应,只接收第一个收到的消息
|
|
// 请求-响应, 向 test3 发布一个 `help me` 请求数据,设置超时间3秒,如果有多个响应,只接收第一个收到的消息
|
|
- ns.Request("/Switch/Init", b, 3*time.Second)
|
|
|
|
|
|
+ msg, err := ns.Request("/Switch/Init", b, 3*time.Second)
|
|
if err != nil {
|
|
if err != nil {
|
|
fmt.Println(err)
|
|
fmt.Println(err)
|
|
panic(any("nats 注册失败!"))
|
|
panic(any("nats 注册失败!"))
|
|
}
|
|
}
|
|
-
|
|
|
|
|
|
+ if len(msg.Data) != 0 {
|
|
|
|
+ panic(any(string(msg.Data)))
|
|
|
|
+ }
|
|
}
|
|
}
|
|
|
|
|
|
// 设备->平台 设备状态 1 在线 2 离线
|
|
// 设备->平台 设备状态 1 在线 2 离线
|