package rule

import (
	"basic.com/valib/logger.git"
	"fmt"
	"ruleModelEngine/data"
	"ruleModelEngine/db"
)

//func PrintFilteredPersonnelInfo(filteredPersonnelInfo []db.PersonnelInfo) {
//	for _, pi := range filteredPersonnelInfo {
//		fmt.Printf("DocumentNumber: %s\n", pi.DocumentNumber)
//		fmt.Printf("TotalCaptureCount: %d\n", pi.TotalCaptureCount)
//		fmt.Printf("TotalCaptureDays: %d\n", pi.TotalCaptureDays)
//		fmt.Printf("PersonnelStatus: %s\n", pi.PersonnelStatus)
//
//		fmt.Println("CaptureDetails:")
//		for _, cd := range pi.CaptureDetails {
//			fmt.Printf("  Date: %s\n", cd.Date)
//			fmt.Printf("  TotalCaptureCount: %d\n", cd.TotalCaptureCount)
//			fmt.Println("  Captures:")
//			for _, c := range cd.Captures {
//				fmt.Printf("    DataTime: %s\n", c.DataTime)
//				fmt.Printf("    Location: %s\n", c.Location)
//			}
//		}
//		fmt.Println()
//	}
//}

// 计算常用地址
//func assignFrequentAddress(personnelInfo []db.PersonnelInfo) []db.PersonnelInfo {
//	for i := range personnelInfo {
//		addressCounts := make(map[string]int)
//		var maxAddress string
//		maxCount := 0
//		for _, detail := range personnelInfo[i].CaptureDetails {
//			for _, capture := range detail.Captures {
//				addressCounts[capture.Location]++
//				if addressCounts[capture.Location] > maxCount {
//					maxCount = addressCounts[capture.Location]
//					maxAddress = capture.Location
//				}
//			}
//		}
//		personnelInfo[i].FrequentAddress = maxAddress
//	}
//	return personnelInfo
//}

// 检查规则表书否存在异常
func checkRuleValidity(rules []db.PersonnelStatusRule) bool {
	for i := 0; i < len(rules); i++ {
		for j := i + 1; j < len(rules); j++ {
			ruleI := rules[i]
			ruleJ := rules[j]
			//fmt.Println(ruleI.DetectionDaysStart,ruleI.DetectionDaysEnd)
			//fmt.Println(ruleJ.DetectionDaysStart,ruleJ.DetectionDaysEnd)
			if (ruleI.DetectionDaysStart <= ruleJ.DetectionDaysEnd && ruleI.DetectionDaysStart >= ruleJ.DetectionDaysStart) ||
				(ruleI.DetectionDaysEnd <= ruleJ.DetectionDaysEnd && ruleI.DetectionDaysEnd >= ruleJ.DetectionDaysStart) ||
				(ruleI.DetectionDaysStart <= ruleJ.DetectionDaysStart && ruleI.DetectionDaysEnd >= ruleJ.DetectionDaysEnd) {
				return false
			}
		}
	}
	return true
}

// 执行程序入口
func ExecuteTask() {
	ruleInfo, err := db.GetAllData()
	if err != nil {
		logger.Error("GetAllData Error", err)
	}
	fmt.Println("ruleInfo: ", ruleInfo)
	communityIDs, err := db.GetCommunityIDs()
	//fmt.Println("communityIDs:", communityIDs)
	if err != nil {
		logger.Error("GetCommunityIDs Error", err)
	}
	for _, communityID := range communityIDs {
		//查询社区内人员档案，方便数据更新
		personStatus, err := db.GetDBPersonStatusData(communityID)
		if err != nil {
			logger.Error("GetDBPersonStatusData Error", err)
		}
		labeManage, err := db.GetLabelManageIdentity(2)
		if err != nil {
			logger.Error("GetDBPersonStatusData Error", err)
		}
		//fmt.Println(labeManage)
		//fmt.Println("personStatus: ", personStatus)
		//fmt.Println("CcmmunityIDs: ", cmmunityID)
		//按社区id查询近一个月es数据
		captureInfos, err := db.Query1MDataByCommunityId(communityID)
		//fmt.Println("captureInfos: ", captureInfos)
		for i := range captureInfos {
			captureDays := data.CalculateCaptureDays(captureInfos[i].CaptureDetail)
			captureInfos[i].CaptureDays = captureDays
			//fmt.Println("该人员出现天数为", captureInfos[i].CaptureDays)
			captureInfos[i].Status = data.SetStatus(captureDays, ruleInfo)
			data.SetFrequentAddress(&captureInfos[i])
		}
		if err != nil {
			logger.Error("MatchAllTargets Error", err)
		}
		if len(captureInfos) == 0 {
			continue
		}
		//fmt.Println("captureInfosQ: ", captureInfos)
		for _, identity := range labeManage {
			switch identity.Name {
			case "服务人员":
				identity, attribute := CreateLinearModel(captureInfos, communityID, 2.68, identity.ValidDays)
				errIdentity := db.UpdateDBPersonLabel(identity)
				if errIdentity != nil {
					logger.Error("UpdateDBPersonLabel Error", errIdentity)
				}
				captureInfos = attribute

			}
		}
		//CreateProcessModel(captureInfos, 30)
		//continue
		//fmt.Println("captureInfos: ", captureInfos)
		postCaptureInfos := data.ProcessData(captureInfos, personStatus, ruleInfo, communityID)
		//fmt.Println("postCaptureInfos: ", postCaptureInfos)
		//fmt.Println("共过滤条数：", len(captureInfos)-len(postCaptureInfos))
		UpdatePersonInfoErr := db.UpdatePersonInfo(postCaptureInfos, communityID)
		if UpdatePersonInfoErr != nil {
			logger.Error("MatchPermanentResidentTargets Error: ", UpdatePersonInfoErr)
		}

		resident, DocNumberErr := db.GetResidentData("resident", communityID)
		if DocNumberErr != nil {
			logger.Error("GetDocNumberFromPersonStatus Error: ", DocNumberErr)
		}
		//fmt.Println(resident)
		mio := processResidentStatus(resident)
		//fmt.Println("mip: ", mio)
		UpdateMoveInoutErr := db.UpdateMoveInout(mio)
		if UpdateMoveInoutErr != nil {
			logger.Error("UpdateMoveInoutErr Error: ", UpdateMoveInoutErr)
		}
	}

}