package rule

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

//
//// 检查规则表书否存在异常
//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() {
	//进出异常布控任务，暂时归类到标签计算部分
	fmt.Println("进出异常开始入口！！！！！！")
	tasks, err := db.GetAllTaskData()
	if err != nil {
		logger.Error("GetAllTaskData Error", err)
	}
	var tkInfo db.Task
	for _, taskInfo := range tasks {
		if taskInfo.Name == "进出异常" {
			tkInfo.Id = taskInfo.Id
			tkInfo.Name = taskInfo.Name
		}
	}
	fmt.Println("tkInfo: ", tkInfo)
	days := config.Api.AInterval
	docNumIdMap, err := db.QueryLastIdByDayRange(days, days-1)
	if err != nil {
		logger.Error("QueryByDayRange err: ", err)
	}
	fmt.Println("docNumIdMap: ", len(docNumIdMap))
	for docNumber, id := range docNumIdMap {
		//fmt.Println(docNumber, id)
		alarmRules := make([]db.AlarmRule, 0)
		flag := task.EnteringButNotLeaving(docNumber, id, days)
		if flag == true {
			alarmRules = append(alarmRules, db.AlarmRule{RuleId: strconv.Itoa(tkInfo.Id), RuleText: tkInfo.Name, AlarmLevel: "0"})
		}
		addFlag, err := db.AddAlarmRules(alarmRules, id)
		if err != nil {
			logger.Error("AddAlarmRules err: ", err)
		}
		if addFlag == true {
			logger.Info("AddAlarmRules success: ", id)
		}
	}

	//return
	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)
	}
	labeManage, err := db.GetLabelManageIdentity(2)
	if err != nil {
		logger.Error("GetDBPersonStatusData Error", err)
	}
	//fmt.Println(labeManage)
	for _, communityID := range communityIDs {
		//万全社区
		//if communityID != "50010101010000001001" {
		//	continue
		//}
		//查询社区内人员档案，方便数据更新
		personStatus, err := db.GetDBPersonStatusData(communityID)
		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)
		//residentCount := 0
		for i := range captureInfos {
			//fmt.Println(captureInfos[i].DocumentNumber)
			captureDays, overnightCount := data.CalculateCaptureDays(captureInfos[i].CaptureDetail)
			captureInfos[i].CaptureDays = captureDays
			captureInfos[i].OvernightStays = overnightCount

			//if captureInfos[i].CaptureDays <= 10 && captureInfos[i].OvernightStays >= 1 {
			//	fmt.Println(captureInfos[i].DocumentNumber)
			//	fmt.Println("该人员出现天数为", captureInfos[i].CaptureDays)
			//	fmt.Println("该人员过夜天数为", captureInfos[i].OvernightStays)
			//}

			captureInfos[i].Status = data.SetStatus(captureDays, ruleInfo)
			if captureInfos[i].OvernightStays >= 5 && (captureInfos[i].CaptureDays <= 14 && captureInfos[i].CaptureDays >= 5) {
				captureInfos[i].Status = "resident"
			}
			//if captureInfos[i].Status == "resident" {
			//	residentCount++
			//}
			age, err := db.QueryAgeById(captureInfos[i].DocumentNumber)
			if err != nil {
				logger.Error("QueryAgeById ERROR", err)
			}
			captureInfos[i].Age = age
			data.SetFrequentAddress(&captureInfos[i])
			//fmt.Println("captureInfos[i].Age: ", captureInfos[i].Age)
		}
		//fmt.Println("residentCount: ", residentCount)
		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, identity.Id)
				errIdentity := db.UpdateDBPersonLabel(identity)
				if errIdentity != nil {
					logger.Error("UpdateDBPersonLabel Error", errIdentity)
				}
				captureInfos = attribute

			}
		}
		identity := CreateProcessModel(captureInfos, 30, communityID, labeManage)
		errIdentity := db.UpdateDBPersonLabel(identity)
		if errIdentity != nil {
			logger.Error("UpdateDBPersonLabel Error", errIdentity)
		}
		//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)
		//fmt.Println(resident)
		//return
		if DocNumberErr != nil {
			logger.Error("GetDocNumberFromPersonStatus Error: ", DocNumberErr)
		}

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