package ruleserver

import (
	"basic.com/pubsub/protomsg.git"
	"github.com/golang/protobuf/proto"
	"ruleprocess/logger"
)

var TrackPond = make(map[string]*PersonTrack)

type PersonTrack struct {
	Face int // 人脸的id数组  改为数量
	Yolo int // yolo对象的id数组 改为数量
}

func (pt *PersonTrack) Set(msg protomsg.SdkMessage) {

}

// 检查是否前后两次的数据id是否完全相同（人脸和yolo）
func IsSame(msg *protomsg.SdkMessage) {
	logger.Debug("++++++++++++++++++++++++++++追踪开始+++++++++++++++++++++摄像机id为：",msg.Cid)
	for _, sdkinfo := range msg.Tasklab.Sdkinfos { // 遍历各算法的sdkData
		//if sdkinfo.Sdktype == "FaceDetect" { // 人脸检测
		//	if len(sdkinfo.Sdkdata) > 1 {
		//		faceParam := protomsg.ParamFacePos{}
		//		err := proto.Unmarshal(sdkinfo.Sdkdata, &faceParam)
		//		if err != nil {
		//			logger.Info("解析face sdk数据时出现错误", err)
		//			continue
		//		}
		//		logger.Info("================追踪之前人脸的个数：",len(faceParam.Faces))
		//		if faceParam.Faces != nil && TrackPond[msg.Cid] != nil  && len(faceParam.Faces) == TrackPond[msg.Cid].Yolo { // yolo的如果数量相同则视为不变、把yolo的sdkData清空
		//			faceParam.Faces = (faceParam.Faces)[0:0]
		//			sdkinfo.Sdkdata,err = proto.Marshal(&faceParam)
		//			if err != nil {
		//				logger.Error("人脸序列化错误",err)
		//			}
		//			logger.Info("===================追踪中途人脸的个数",len(faceParam.Faces))
		//		} else {
		//			TrackPond[msg.Cid] = &PersonTrack{Face:len(faceParam.Faces)}
		//		}
		//		//for i := 0;  i < len(faceParam.Faces); {
		//		//	if flag := IsInPond(msg.Cid,faceParam.Faces[i]);flag { // 已经存在，从msg的人脸数组中删除这个元素，不必传到下一个环节
		//		//		faceParam.Faces = append(faceParam.Faces[:i], faceParam.Faces[i+1:]...)
		//		//	} else {
		//		//		i++
		//		//	}
		//		//}
		//	} else {
		//		continue
		//	}
		//}
		if sdkinfo.Sdktype == "Yolo" {
			if len(sdkinfo.Sdkdata) > 1 {
				yoloParam := protomsg.ParamYoloObj{}
				err := proto.Unmarshal(sdkinfo.Sdkdata, &yoloParam)
				if err != nil {
					logger.Info("解析yolo数据时出现错误", err)
					continue
				}
				var yoloNum int = 0
				for i := 0;i < len(yoloParam.Infos); i++ {
					if yoloParam.Infos[i].Typ == 0 {
						yoloNum++
					}
				}
				logger.Info("================追踪之前yolo的个数：",yoloNum)
				if yoloParam.Infos != nil && TrackPond[msg.Cid] != nil && yoloNum == TrackPond[msg.Cid].Yolo { // yolo的如果数量相同则视为不变、把yolo的sdkData清空
					yoloParam.Infos = (yoloParam.Infos)[0:0]
					sdkinfo.Sdkdata,err = proto.Marshal(&yoloParam)
					if err != nil {
						logger.Error("yolo序列化错误",err)
					}
				} else {
					TrackPond[msg.Cid] = &PersonTrack{Yolo:yoloNum}
				}
			} else {
				continue
			}
		}
	}
	logger.Debug("---------------------------------------追踪结束--------------------------------------")
}
//// 判断一个人脸id在不在追踪池中
//func FaceIsInPond(cameraId string,face *protomsg.ResultFaceDetect) bool{
//	if TrackPond[cameraId].Face > 0 {
//		for key,val := range TrackPond  {
//			if key == cameraId {
//				faceFlag := false
//				for faceId := range val.Face  {
//					if face.Pos.FaceID == uint64(faceId) { // 此人脸已在池子中，不需要它到下一个环节了
//						faceFlag = true
//						return true
//					}
//				}
//				if !faceFlag { // 此人脸不在池子中
//					val.Face = append(val.Face,face.Pos.FaceID)
//					return false
//				}
//			}else {
//				return false
//			}
//		}
//	} else {
//		return false
//	}
//	return false
//}