332 lines
7.8 KiB
Go
332 lines
7.8 KiB
Go
package main
|
||
|
||
import (
|
||
"log"
|
||
"net"
|
||
//"os"
|
||
// "strconv"
|
||
// "log"
|
||
//"strings"
|
||
"time"
|
||
// "go-study/socket/config"
|
||
"bytes"
|
||
"strconv"
|
||
)
|
||
|
||
/**
|
||
* 从loragw的组中获取到范围内的所有node，给符合addr的node发送command
|
||
**/
|
||
|
||
func sendCommand(addr string, command int) {
|
||
log.Println("begin sendCommand")
|
||
log.Println("yunhorn.loragw.sendCommand|", addr, command)
|
||
commands := []byte{0x01}
|
||
byteAddr, ok := sensorMap.Load(addr)
|
||
if !ok {
|
||
log.Println("send command fail,invalid addr|", addr)
|
||
return
|
||
}
|
||
|
||
loraNode, ok := loraNodeMap.Load(addr)
|
||
if !ok {
|
||
log.Println("send command fail,invalid addr|", addr)
|
||
return
|
||
}
|
||
if command == 1 {
|
||
commands = []byte{0x01}
|
||
} else if command == 2 {
|
||
commands = []byte{0x02}
|
||
} else {
|
||
log.Println("send command fail,invalid command|", command)
|
||
return
|
||
}
|
||
|
||
// strconv.Itoa
|
||
var buffer bytes.Buffer
|
||
buffer.Write(byteAddr.([]byte))
|
||
buffer.Write(commands)
|
||
|
||
// log.Println("loragws ",loraNode.(LoraNode).LORA_GWS)
|
||
|
||
for _, loragwip := range loraNode.(LoraNode).LORA_GWS {
|
||
loraconn, ok := loragwMap.Load(loragwip)
|
||
if ok {
|
||
log.Println("yunhorn.loragw.begin push tcp command ", buffer.Bytes())
|
||
_, err := loraconn.(net.Conn).Write(buffer.Bytes())
|
||
if err != nil {
|
||
log.Println("yunhorn.loragw.write msg error!", err)
|
||
return
|
||
}
|
||
}
|
||
}
|
||
}
|
||
|
||
func handleConn(conn net.Conn) {
|
||
|
||
if connTest == nil {
|
||
connTest = conn
|
||
}
|
||
|
||
log.Println("yunhorndeug.push.data.tcp.begin handleConn,cliendAddr:", conn.RemoteAddr())
|
||
|
||
defer conn.Close()
|
||
|
||
readChan := make(chan []byte)
|
||
//writeChan := make(chan string)
|
||
stopChan := make(chan bool)
|
||
|
||
go readConn(conn, readChan, stopChan)
|
||
// go writeConn(conn, writeChan, stopChan)
|
||
|
||
var heartbeat []byte = []byte{0x01}
|
||
|
||
for {
|
||
select {
|
||
case readStr := <-readChan:
|
||
//log.Println("readStr:",readStr)
|
||
//upper := strings.ToUpper(readStr)
|
||
//writeChan <- upper
|
||
|
||
// go yunhorn_ys_l_v1(readStr)
|
||
go yunhorn_wireless(readStr)
|
||
case stop := <-stopChan:
|
||
if stop {
|
||
log.Println("stop channel")
|
||
break
|
||
}
|
||
case <-time.After(5000 * time.Millisecond):
|
||
_, err := conn.Write(heartbeat)
|
||
if err != nil {
|
||
log.Println("write msg error!", err)
|
||
stopChan <- true
|
||
} else {
|
||
//log.Println("write msg success!", conn.RemoteAddr())
|
||
|
||
//暂时写死，演示用 lora心跳包给云端
|
||
var device Device
|
||
device.Lock()
|
||
device.ID = "6F3A8B2D-B0DF-404A-AA7E-4A4086BD0B56"
|
||
device.VERSION = "yunhorn_lora_l_v1"
|
||
device.ONLINE = true
|
||
device.DATA = make(map[string]interface{})
|
||
device.DATA["data"] = 1
|
||
//go send_data(1005, device)
|
||
}
|
||
}
|
||
}
|
||
}
|
||
|
||
func readConn(conn net.Conn, readChan chan<- []byte, stopChan chan<- bool) {
|
||
|
||
data := make([]byte, 256)
|
||
Rdata2 := make([]byte, 0)
|
||
|
||
for {
|
||
reqLen, err := conn.Read(data)
|
||
if err != nil {
|
||
log.Println(err)
|
||
break
|
||
}
|
||
|
||
buffer := new(bytes.Buffer)
|
||
continueCount := 0
|
||
// log.Println("yunhorndeug.push.data.tcp.reqLen|data",reqLen,data)
|
||
log.Println("$$$$$$$$$$$$$$$$$$$$$$$$$", data[:reqLen])
|
||
now := time.Now()
|
||
// log.Println("yunhorndeug.push.data.tcp.begin handleConn,cliendAddr:", conn.RemoteAddr())
|
||
|
||
for i, b := range data[:reqLen] {
|
||
|
||
if reqLen < 7 {
|
||
break
|
||
}
|
||
|
||
if continueCount > 0 {
|
||
continueCount--
|
||
continue
|
||
}
|
||
|
||
if b != 254 {
|
||
s := strconv.FormatInt(int64(b&0xff), 16)
|
||
if len(s) == 1 {
|
||
buffer.WriteString("0")
|
||
}
|
||
buffer.WriteString(s)
|
||
}
|
||
|
||
end := 0
|
||
//254为分隔符
|
||
if b == 254 && i > 3 {
|
||
addrs := data[i-4 : i]
|
||
|
||
//尿布台数据，地址1位 数据2位
|
||
dataType := data[i+1]
|
||
|
||
//0是通用类型 命令交互
|
||
if dataType != 0 && dataType != 1 && dataType != 2 && dataType != 3 && dataType != 4 {
|
||
continue
|
||
}
|
||
|
||
values := make([]byte, 0)
|
||
|
||
if dataType == 0 {
|
||
continueCount = 2
|
||
end = 3
|
||
values = data[i+2 : i+3]
|
||
} else if dataType == 1 {
|
||
|
||
continueCount = 3
|
||
end = 4
|
||
|
||
if i+4 > reqLen {
|
||
log.Println("yunhorndeug.push.data.tcp.fq", buffer.String(), addrs, dataType)
|
||
continue
|
||
}
|
||
|
||
//类型为1 数据量为2
|
||
values = data[i+2 : i+4]
|
||
|
||
} else if dataType == 2 {
|
||
//类型为2 数据量位1
|
||
|
||
continueCount = 2
|
||
end = 3
|
||
|
||
if i+3 > reqLen {
|
||
log.Println("yunhorndeug.push.data.tcp.fq", buffer.String(), addrs, dataType)
|
||
continue
|
||
}
|
||
values = data[i+2 : i+3]
|
||
} else if dataType == 4 {
|
||
//空气质量
|
||
continueCount = 19
|
||
end = 20
|
||
if i+end > reqLen {
|
||
log.Println("yunhorndeug.push.data.tcp.fq", buffer.String(), addrs, dataType)
|
||
continue
|
||
}
|
||
values = data[i+2 : i+end]
|
||
// log.Println("pm25data1",data[i+15])
|
||
// log.Println("pm25data2",data[i+16])
|
||
// nh3data := uint32(data[i+7])*256+uint32(data[i+8])
|
||
// pm25data := uint32(data[i+15])*256+uint32(data[i+16])
|
||
// log.Println("nh3data",data[i+7])
|
||
// log.Println("pm25data",pm25data)
|
||
//8E 3C 00 00 47 46
|
||
// var close []byte = []byte{0x8E,0x3C,0x00,0x00,0x43,0x46}
|
||
// var open []byte = []byte{0x8E,0x3C,0x00,0x00,0x4F,0x46}
|
||
// var writedata []byte =[]byte{}
|
||
//i+7 氨气
|
||
//i+14 tvoc 甲醛
|
||
// if pm25data>100 || data[i+7]>=3 || data[i+14]>=2 {
|
||
// writedata = open
|
||
// }else{
|
||
// writedata = close
|
||
// }
|
||
// v, err := connTest.Write(writedata)
|
||
// log.Println("send.msg.conn.RemoteAddr:",connTest.RemoteAddr(),writedata)
|
||
// log.Println("send.msg.conn.v",v)
|
||
// if err != nil {
|
||
// log.Println("write msg error!", err)
|
||
// }
|
||
} else if dataType == 3 {
|
||
continueCount = 2
|
||
end = 3
|
||
|
||
if i+3 > reqLen {
|
||
log.Println("yunhorndeug.push.data.tcp.fq", buffer.String(), addrs, dataType)
|
||
continue
|
||
}
|
||
|
||
values = data[i+2 : i+end]
|
||
// values = data[i+2]
|
||
|
||
//28 3C 00 00 47 46
|
||
// var green []byte = []byte{0x28,0x3C,0x00,0x00,0x47,0x46}
|
||
// var red []byte = []byte{0x28,0x3C,0x00,0x00,0x52,0x46}
|
||
// var yellow []byte = []byte{0x28,0x3C,0x00,0x00,0x59,0x46}
|
||
// var writedata []byte =[]byte{}
|
||
// writedata = green
|
||
// if values == 2{
|
||
// writedata = red
|
||
// }else if values == 1{
|
||
// writedata = green
|
||
// }else if values == 4{
|
||
// writedata = yellow
|
||
// }
|
||
// log.Println("send.msg.conn.RemoteAddr|writedata",connTest.RemoteAddr(),writedata)
|
||
// v, err := connTest.Write(writedata)
|
||
// log.Println("send.msg.conn.v",v)
|
||
// if err != nil {
|
||
// log.Println("write msg error!", err)
|
||
// }
|
||
}
|
||
|
||
log.Println("yunhorndeug.push.data.tcp:", buffer.String(), addrs, dataType, values)
|
||
|
||
loraNode, ok := loraNodeMap.Load(buffer.String())
|
||
if !ok {
|
||
log.Println("yunhorndeug.push.data.tcp.dev not exist:", buffer.String(), dataType, values)
|
||
buffer = new(bytes.Buffer)
|
||
continue
|
||
}
|
||
|
||
if !loraNode.(LoraNode).UPDATE_TIME.IsZero() {
|
||
var duration = now.Sub(loraNode.(LoraNode).UPDATE_TIME).Seconds()
|
||
var durationAsInt64 = int(duration)
|
||
if durationAsInt64 <= 1 {
|
||
log.Println("repeat.sensor.data:", addrs)
|
||
continue
|
||
}
|
||
}
|
||
|
||
sensorMap.Store(buffer.String(), addrs)
|
||
|
||
buffer = new(bytes.Buffer)
|
||
|
||
if conf.RECORD_LOG_PATH != "" {
|
||
go write_log_channel(data[i-4 : i+end])
|
||
}
|
||
|
||
go dealDatav3(data[i-4:i+end], conn.RemoteAddr().String())
|
||
|
||
}
|
||
}
|
||
|
||
// 转化为字符串
|
||
// log.Println("yunhorndeug.push.data.tcp.16data:",buffer.String())
|
||
|
||
Rdata2 = make([]byte, reqLen)
|
||
for i, v := range data[:reqLen] {
|
||
Rdata2[i] = v
|
||
}
|
||
|
||
// log.Println("===========================yunhorndeug.push.data.tcp.origin.Rdata:",Rdata2)
|
||
|
||
// Rdata2 = make([]byte, count)
|
||
|
||
// log.Println("read.data:%d,%s", Bytes2Bits(data[3:4])[0],conn.RemoteAddr())
|
||
|
||
// data_buf <- data
|
||
|
||
data = make([]byte, 256)
|
||
}
|
||
|
||
stopChan <- true
|
||
}
|
||
|
||
func writeConn(conn net.Conn, writeChan <-chan string, stopChan chan<- bool) {
|
||
for {
|
||
strData := <-writeChan
|
||
_, err := conn.Write([]byte(strData))
|
||
if err != nil {
|
||
log.Println(err)
|
||
break
|
||
}
|
||
|
||
log.Println("Send:", strData)
|
||
}
|
||
|
||
stopChan <- true
|
||
}
|