YHGW/tcpserver.go

package main

import (
	"log"
	"net"
	//"os"
	// "strconv"
	// "log"
	//"strings"
	"time"
	// "go-study/socket/config"
	"bytes"
	"strconv"

)

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])
    for i, b := range data[:reqLen] {

				if reqLen<7{
					break
				}

			  if continueCount>0{
					continueCount--
					continue;
				}

        s := strconv.FormatInt(int64(b&0xff), 16)
        if len(s) == 1 {
            buffer.WriteString("0")
        }
        buffer.WriteString(s)

				// log.Println("========================",data[reqLen-2:reqLen])

				// log.Println(b)
				// log.Println("$$$$$$$$$$$$$$$$$$$$$$$$$",i,reqLen)
				// log.Println("$$$$$$$$$$$$$$$$$$$$$$$$$",data[reqLen])
				end :=0
				//254为分隔符
				if b==254 && i>3{
					addrs := data[i-4:i]
					//尿布台数据，地址1位 数据2位
					dataType := data[i+1]
					values := make([]byte,0)
					if data[i+1] == 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 = 18
						end = 19
						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])
						pm25data := uint32(data[i+15])*256+uint32(data[i+16])
						log.Println("pm25data",pm25data)

						//8E 3C 00 00 47 46
						var green []byte = []byte{0x8E,0x3C,0x00,0x00,0x47,0x46}
						var red []byte = []byte{0x8E,0x3C,0x00,0x00,0x52,0x46}
						var writedata []byte =[]byte{}
						if pm25data>200{
							writedata = red
						}else{
							writedata = green
						}
						v, err := connTest.Write(writedata)
						log.Println("send.msg.conn.RemoteAddr",connTest.RemoteAddr())
						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)
					// log.Println("yunhorndeug.push.data.tcp.addr",addrs)
					// log.Println("yunhorndeug.push.data.tcp.type",dataType)
					// log.Println("yunhorndeug.push.data.tcp.values",values)

					buffer = new(bytes.Buffer)
					if(dataType ==1 || dataType ==2 ){
					 	go dealDatav3(data[i-4:i+end])
					}

				}
    }

    // 转化为字符串
    // 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
}