package device
|
|
import (
|
"encoding/json"
|
"fmt"
|
"net"
|
|
MQTT "github.com/eclipse/paho.mqtt.golang"
|
"vamicro/iotData-service/model"
|
"vamicro/iotData-service/mqtt"
|
|
"basic.com/valib/logger.git"
|
)
|
|
const RT02_MQTT_MSG_TOPIC = "/demo/device/helmetPos"
|
|
func RT02MsgServer() {
|
// 订阅mqtt信息
|
msgChan := make(chan MQTT.Message, 10)
|
go mqtt.Client.Subscribe(RT02_MQTT_MSG_TOPIC, msgChan)
|
|
for {
|
select {
|
case msg := <-msgChan:
|
var devInfo model.Device
|
var warnInfo model.Warning
|
|
payload := msg.Payload()
|
if err := json.Unmarshal(payload, &devInfo); err != nil {
|
logger.Error(err)
|
} else {
|
// 上报数据
|
CollectorMsgChan <- devInfo
|
logger.Debug("接收到 安全帽 msg", string(payload))
|
|
// 项目测试推送安全帽数据
|
RT02DataPush(payload)
|
|
warnInfo.Battery = devInfo.Battery
|
warnInfo.SN = devInfo.SN
|
warnInfo.GpsType = devInfo.GpsType
|
warnInfo.High = devInfo.High
|
warnInfo.Lat = devInfo.Lat
|
warnInfo.Lng = devInfo.Lng
|
devInfo.LocateState = "单向定位"
|
devInfo.Mac = "ec:da:da:da:ed:98"
|
devInfo.Ip = "192.168.1.2"
|
// if err := devInfo.HandleDevice(); err != nil {
|
// fmt.Println(err)
|
// }
|
if err := warnInfo.HandleWarning(); err != nil {
|
fmt.Println(err)
|
}
|
}
|
}
|
}
|
}
|
|
// 安全帽数据推送测试
|
func RT02DataPush(data []byte) {
|
var serverAddr = "113.205.255.118:8888"
|
|
conn, err := net.Dial("tcp", serverAddr)
|
if err != nil {
|
logger.Error(err)
|
return
|
}
|
|
_, err = conn.Write(data)
|
if err != nil {
|
logger.Error(err)
|
}
|
}
|
