package DatastatisticService

import (
	"dsSupport/MyModel/AccessSystem/AccessSystemDao"
	"dsSupport/MyModel/DataSource/DatasourceService"
	"dsSupport/MyModel/MySwagger"
	"dsSupport/Utils/ES7Util"
)

type ESDataContent struct {
	Address  string `json:"address"`
	AreaCode string `json:"area_code"`
	OrgName  string `json:"org_name"`
}

func GetESDocCount() (bool, []map[string]interface{}) {
	var datas []map[string]interface{}
	var data map[string]interface{}

	linksystems, c, _ := AccessSystemDao.ListApp("", 1, 1000)
	if c > 0 {
		for _, v := range linksystems {
			var num int64 = 0
			var sw MySwagger.DatasourceSwag
			sw.SystemId = v["app_id"].(string)
			rr, _, _, datasources, _ := DatasourceService.GetDatasourceResults(sw)
			if rr == true {
				for _, vv := range datasources {
					result, _ := ES7Util.GetDocCount(vv["datasource_code"].(string))
					num += result
					_, _, esdata := ES7Util.GetLatestDoc(vv["datasource_code"].(string))

					data = make(map[string]interface{})
					data["system_name"] = v["app_name"]
					data["system_id"] = v["app_id"]
					data["datasource_code"] = vv["datasource_code"]
					data["datasource_name"] = vv["datasource_name"]
					data["datasource_id"] = vv["id"]
					data["storage_time"] = esdata.BeginTime
					data["num"] = result
					datas = append(datas, data)
				}
			}

			//data = make(map[string]interface{})
			//data["system_name"] = v["app_name"]
			//data["system_id"] = v["app_id"]
			//data["num"] = num
			//datas = append(datas, data)
		}
	} else {
		return false, datas
	}

	return true, datas
}