package service

import (
	"encoding/json"
	"fmt"
	"git.quantgroup.cn/DevOps/enoch/service/end_points"
	"github.com/influxdata/influxdb/client/v2"
	"math/big"
	"net"
	"time"
)

var sysNameIndex = make(map[int64]bool)
var metricsPointSlice = make([]*client.Point, 0, batchSize)
var healthPointSlice = make([]*client.Point, 0, batchSize)

func AgentMsgProcess(msg string) {
	chunkMsg := end_points.ChunkMsg{}
	err := json.Unmarshal([]byte(msg), &chunkMsg)
	if err != nil {
		fmt.Println(err)
	}
	buildMsg(chunkMsg)
}

func buildHealthInfluxMsg(appName string, ip string, timestamp time.Time, submitLimit int, db map[string]end_points.DBDetail) {
	tags := make(map[string]string, )
	tags["sys_name"] = appName
	tags["host"] = ip
	fields := make(map[string]interface{})

	for k, v := range db {
		var fieldName = v.Details.Database + "—" + k
		fields[fieldName] = isOK(v.Status.Code)
	}
	if len(healthPointSlice) >= submitLimit {
		go batchWrite(healthPointSlice)
		healthPointSlice = make([]*client.Point, 0, batchSize)
	}
	point, _ := client.NewPoint("health_info", tags, fields, timestamp)
	healthPointSlice = append(healthPointSlice, point)
}

func buildMetricsInfluxMsg(appName string, ip string, timestamp time.Time, submitLimit int, health end_points.Health, metrics end_points.MetricsInfo) {
	tags := make(map[string]string, )
	fields := make(map[string]interface{})
	tags["sys_name"] = appName
	tags["host"] = ip

	var status = health.Status
	fields["sever_status"] = isOK(status.Code)

	var diskSpace = health.Details.DiskSpace.Details

	fields["disk_tol"] = diskSpace.Total
	fields["disk_free"] = diskSpace.Free
	fields["disk_threshold"] = diskSpace.Threshold

	fields["mem_tol"] = metrics.Mem
	fields["mem_free"] = metrics.MemFree

	fields["heap_tol"] = metrics.Heap
	fields["heap_init"] = metrics.HeapInit
	fields["heap_used"] = metrics.HeapUsed

	fields["nonheap_tol"] = metrics.Nonheap
	fields["nonheap_init"] = metrics.NonheapInit
	fields["nonheap_used"] = metrics.NonheapUsed
	fields["nonheap_commit"] = metrics.NonheapCommitted

	fields["thread_tol"] = metrics.ThreadsTotalStarted
	fields["thread_peak"] = metrics.ThreadsPeak
	fields["thread_daemon"] = metrics.ThreadsDaemon

	fields["class_tol"] = metrics.Classes
	fields["class_loaded"] = metrics.ClassesLoaded
	fields["class_unloaded"] = metrics.ClassesUnloaded

	fields["gc_parnew_count"] = metrics.GcParnewCount
	fields["gc_parnew_time"] = metrics.GcParnewTime
	fields["gc_concurrent_mark_sweep"] = metrics.GcConcurrentmarksweepCount
	fields["gc_concurrent_mark_time"] = metrics.GcConcurrentmarksweepTime

	fields["uptime"] = metrics.Uptime
	fields["instance_uptime"] = metrics.InstanceUptime
	fields["system_load_average"] = metrics.SystemloadAverage

	if len(metricsPointSlice) >= submitLimit {
		go batchWrite(metricsPointSlice)
		metricsPointSlice = make([]*client.Point, 0, batchSize)
	}
	point, _ := client.NewPoint("machine_info", tags, fields, timestamp)
	metricsPointSlice = append(metricsPointSlice, point)
}

func buildMsg(chunkMsg end_points.ChunkMsg) {
	var ip = inetAtoN(chunkMsg.Ip)
	sysNameIndex[ip] = true
	var sysNameCount = len(sysNameIndex)
	for _, p := range chunkMsg.EndPoints {

		var appName = chunkMsg.AppName
		var ip = chunkMsg.Ip

		unix := time.Unix(0, p.Timestamp*1000000)
		//metricsInfo
		buildMetricsInfluxMsg(appName, ip, unix, sysNameCount, p.Health, p.Metrics)

		//health_info
		buildHealthInfluxMsg(appName, ip, unix, sysNameCount, p.Health.Details.Db.Details)
	}
}

func inetAtoN(ip string) int64 {
	ret := big.NewInt(0)
	ret.SetBytes(net.ParseIP(ip).To4())
	return ret.Int64()
}

func isOK(code string) int {
	if "UP" == code {
		return 1
	}
	return 0
}
