package FLXNetworkController

import (
	"flx/Common"
	"fmt"
	"net"
	"strings"

	log "github.com/sirupsen/logrus"
)

type FlxNetworkCmdTCPLisen struct {
	BufferMaxLength    int //最大缓冲长度
	SocketID           string
	TCPConn            net.Conn
	RecThreadIsWorking bool //是否开始接受
	TCPWorking         bool
	tmpRecDataBuffer   []byte          //缓冲字节
	InvokeOnReviceData func(Compacket) //外部委托

}

// func (para *FlxNetworkCmdTCPLisen) StartTCPListen() {
// 	// 绑定监听地址
// 	var err error
// 	para.TCPlistener, err = net.Listen("tcp", ":9667")
// 	if err != nil {
// 		log.Fatal(fmt.Sprintf("listen err: %v", err))
// 	}
// 	defer para.TCPlistener.Close()
// 	log.Println(fmt.Sprintln("bind:start listening..."))

// 	for {
// 		// Accept 会一直阻塞直到有新的连接建立或者listen中断才会返回
// 		conn, err := para.TCPlistener.Accept()
// 		if err != nil {
// 			// 通常是由于listener被关闭无法继续监听导致的错误
// 			log.Fatal(fmt.Sprintf("accept err: %v", err))
// 		}
// 		// 开启新的 goroutine 处理该连接
// 		go para.Handle(conn)
// 	}
// }

func (para *FlxNetworkCmdTCPLisen) Handle(conn net.Conn) {

	defer func() {
		if r := recover(); r != nil {
			log.Error("Handle:", r)
		}
	}()

	// defer conn.Close()
	para.SocketID = Common.GetGUID().Hex()
	para.TCPConn = conn
	for {
		var buf [65535]byte
		n, err := conn.Read(buf[:])
		if err != nil {
			fmt.Println("Read from tcp server failed,err:", err)
			break
		}
		para.ProcessRecvBuff(buf[:n])
	}
}

func (para *FlxNetworkCmdTCPLisen) ProcessRecvBuff(RecvBuffer []byte) {

	defer func() {
		if r := recover(); r != nil {
			log.Error("ProcessRecvBuff:", r)
		}
	}()

	startIndex := 0
	curIndex := 0
	length := 0
	//判断是否大于14字节
	for curIndex <= len(RecvBuffer)-7 {
		//判断是否出现 7E开头
		if RecvBuffer[curIndex] == FlxNetworkComPara_CMD_HEAD {
			if RecvBuffer[curIndex+3] > 8 {

				//System.Windows.Forms.CMessageBox.Show("数据出错！");
				curIndex++
				continue
			}
			length = int(RecvBuffer[curIndex+3])*256 + int(RecvBuffer[curIndex+4]) + 7
			if length <= len(RecvBuffer)-curIndex {
				para.ValidateRecvBuffer(length, RecvBuffer, curIndex)
				curIndex = curIndex + length
				startIndex = curIndex
			} else {
				para.tmpRecDataBuffer = append(para.tmpRecDataBuffer, RecvBuffer[curIndex:]...)
				startIndex = -1
			}
		} else {
			curIndex++
		}
	}

	if startIndex >= 0 && startIndex < len(RecvBuffer) {
		para.tmpRecDataBuffer = append(para.tmpRecDataBuffer, RecvBuffer[curIndex:]...)
	}

}

func (para *FlxNetworkCmdTCPLisen) ValidateRecvBuffer(packLen int, RecvBuffer []byte, startIndex int) bool {

	defer func() {
		if r := recover(); r != nil {
			log.Error("ValidateRecvBuffer:", r)
		}
	}()

	PackBuff := make([]byte, packLen)
	PackBuff = RecvBuffer[startIndex : startIndex+packLen]
	//校验CRC
	CRCBuff := CRCCheck12(PackBuff[:packLen-2])

	if CRCBuff[0] != PackBuff[packLen-2] || CRCBuff[1] != PackBuff[packLen-1] {
		//InvokeOnDataReciveLogHandler(string.Format(FlxNetCCUConstantText.ReciveDataBufferImperfect_Error, "飞利信网口中控机")); //--写日志
		return false
	} else {
		para.InvokeOnReviceData(CreatCMDPack(strings.Split(para.TCPConn.RemoteAddr().String(), ":")[0], PackBuff))
		// para.InvokeOnReviceData(CreatCMDPack(PackBuff, packLen-2))
		//外发事件。

		return true
	}

}

func (para *FlxNetworkCmdTCPLisen) SendToClient(dataMsg []byte) {

	defer func() {
		if r := recover(); r != nil {
			log.Error("SendToClient:", r)
		}
	}()

	if dataMsg == nil {
		fmt.Printf("不能向远程端口发送空数据！")
		return
	}

	if len(dataMsg) < 5 {
		fmt.Printf("不能向远程端口发送不完整的数据5！")
		return
	}
	dataMsg = FullCheckSum(dataMsg)
	para.TCPConn.Write(dataMsg)
}

// 服务器发送结束会议指令
func (para *FlxNetworkCmdTCPLisen) StopAgenda() {

	defer func() {
		if r := recover(); r != nil {
			log.Error("StopAgenda:", r)
		}
	}()

	var ary = make([]byte, 7)

	ary[0] = FlxNetworkComPara_CMD_HEAD
	ary[1] = FlxNetworkComPara_Meeting //cmd
	ary[2] = FlxNetworkComPara_Meeting_Close
	para.SendToClient(ary)
}

// 服务器发送会议状态指令
func (para *FlxNetworkCmdTCPLisen) SendToClientCongresStatus(SoftStatus string) {

	defer func() {
		if r := recover(); r != nil {
			log.Error("SendToClientCongresStatus:", r)
		}
	}()

	sendValue := []byte(SoftStatus)

	slen := len(sendValue) + 7
	var buff = make([]byte, slen)

	buff[0] = FlxNetworkComPara_CMD_HEAD
	buff[1] = FlxNetworkComPara_Server_Congress_Status
	buff[2] = FlxNetworkComPara_Server_RetStatus
	if len(sendValue) > 255 {
		buff[3] = (byte)(len(sendValue) / 255)
		buff[4] = (byte)(len(sendValue) % 255)
	} else {
		buff[4] = (byte)(len(sendValue))
	}
	buff = insertSlice(5, sendValue, buff)
	para.SendToClient(buff)
}

// 服务器发送开始报到指令
func (para *FlxNetworkCmdTCPLisen) StartCheckInStart() {

	defer func() {
		if r := recover(); r != nil {
			log.Error("StartCheckInStart:", r)
		}
	}()

	var ary = make([]byte, 7)

	ary[0] = FlxNetworkComPara_CMD_HEAD
	ary[1] = FlxNetworkComPara_Main_Start_Register //cmd
	ary[2] = 0
	para.SendToClient(ary)
}

// 服务器发送开始报到指令
func (para *FlxNetworkCmdTCPLisen) ServerSendToClientStartCheckIn(ClientIP string) {

	defer func() {
		if r := recover(); r != nil {
			log.Error("ServerSendToClientStartCheckIn:", r)
		}
	}()

	var ary = make([]byte, 7)

	ary[0] = FlxNetworkComPara_CMD_HEAD
	ary[1] = FlxNetworkComPara_Main_Start_Register //cmd
	ary[2] = 0
	para.SendToClient(ary)
}

// 服务器发送结束报到指令
func (para *FlxNetworkCmdTCPLisen) StartCheckInStop() {

	defer func() {
		if r := recover(); r != nil {
			log.Error("StartCheckInStop:", r)
		}
	}()

	var ary = make([]byte, 7)

	ary[0] = FlxNetworkComPara_CMD_HEAD
	ary[1] = FlxNetworkComPara_Main_Stop_Register //cmd
	ary[2] = 0
	para.SendToClient(ary)
}

// 服务器发送人员报到指令
func (para *FlxNetworkCmdTCPLisen) SendToClientPersonCheckIn(AP_ID string) {

	defer func() {
		if r := recover(); r != nil {
			log.Error("SendToClientPersonCheckIn:", r)
		}
	}()

	sendValue := []byte(AP_ID)

	slen := len(sendValue) + 7
	var buff = make([]byte, slen)

	buff[0] = FlxNetworkComPara_CMD_HEAD
	buff[1] = FlxNetworkComPara_Un_Register
	buff[2] = FlxNetworkComPara_CheckIn_Sub_Signed
	if len(sendValue) > 255 {
		buff[3] = (byte)(len(sendValue) / 255)
		buff[4] = (byte)(len(sendValue) % 255)
	} else {
		buff[4] = (byte)(len(sendValue))
	}
	buff = insertSlice(5, sendValue, buff)
	para.SendToClient(buff)
}

// 服务器发送人员消报指令
func (para *FlxNetworkCmdTCPLisen) SendToClientPersonCheckOut(AP_ID string) {

	defer func() {
		if r := recover(); r != nil {
			log.Error("SendToClientPersonCheckOut:", r)
		}
	}()

	sendValue := []byte(AP_ID)

	slen := len(sendValue) + 7
	var buff = make([]byte, slen)

	buff[0] = FlxNetworkComPara_CMD_HEAD
	buff[1] = FlxNetworkComPara_Un_Register
	buff[2] = FlxNetworkComPara_CheckIn_Sub_Cancel
	if len(sendValue) > 255 {
		buff[3] = (byte)(len(sendValue) / 255)
		buff[4] = (byte)(len(sendValue) % 255)
	} else {
		buff[4] = (byte)(len(sendValue))
	}
	buff = insertSlice(5, sendValue, buff)
	para.SendToClient(buff)
}