package netService

import (
	"encoding/hex"
	"gitee.com/ling-bin/network/netInterface"
	"time"
)

//客户端请求内容
type ReceiveTask struct {
	conn        netInterface.IConnection     //已经和客户端建立好的 链接
	data        []byte                       //客户端请求的数据
	count       int                          //数据长度
	OnCompleted func(data []byte, count int) //接收到一次数据(未分包开始处理不确定是否完成)
	duration    time.Duration                //超时时间
}

//获取连接id
func (r *ReceiveTask) GetTaskId() uint64 {
	return r.conn.GetConnId()
}

//处理数据
func (r *ReceiveTask) RunTask() {
	r.OnCompleted(r.data,r.count)
}

func (r *ReceiveTask) GetDuration() time.Duration {
	return r.duration
}

//任务超时
func (r *ReceiveTask)  CallOutTime() {
	r.conn.CallLogHandle(netInterface.Error, "[tcp]数据处理超时:", "远程地址=>", r.conn.GetRemoteAddr(), " 任务ID=> ", r.GetTaskId(), " 数据 =>", hex.EncodeToString(r.data[0:r.count]))
}