kern/krn/kmodule/mod_stat/mod_stat_sec/mod_stat_sec.go

// package mod_stat_sec -- статистика модуля за первые 60 сек
package mod_stat_sec

import (
	"bytes"
	"fmt"
	"math"

	// "strings"
	"sync"
	"time"

	"github.com/ajstarks/svgo"
)

// ModStatSec -- статистика модуля за первые 60 сек
type ModStatSec struct {
	sync.RWMutex
	lst      []int // Список значений за последние 60 сек
	momentAt int64 // Метка времени для учёта текущей секунды
	bufSvg   *bytes.Buffer
}

// NewModStatSec -- возвращает новую статистику модуля за последние 60 сек
func NewModStatSec() *ModStatSec {
	sf := &ModStatSec{
		lst:      []int{},
		bufSvg:   bytes.NewBufferString(""),
		momentAt: time.Now().Local().Unix(),
	}
	return sf
}

// Sum -- возвращает сумму элементов по требованию
func (sf *ModStatSec) Sum() int {
	sf.RLock()
	defer sf.RUnlock()
	sum := 0
	for _, val := range sf.lst {
		sum += val
	}
	return sum
}

// Add -- добавляет значение в минутный срез
func (sf *ModStatSec) Add(val int) {
	sf.Lock()
	defer sf.Unlock()

	for len(sf.lst) < 60 {
		sf.lst = append(sf.lst, 0)
	}

	momentNow := time.Now().Local().Unix()
	isSameSec := momentNow == sf.momentAt
	switch isSameSec {
	case true:
		_val := sf.lst[59]
		_val += val
		sf.lst[59] = _val
	default:
		sf.momentAt = momentNow
		sf.lst = append(sf.lst, val)
		if len(sf.lst) > 60 {
			sf.lst = sf.lst[1:]
		}
	}
}

// const (
// 	strCut = `<?xml version="1.0"?>
// <!-- Generated by SVGo -->`
// )

// Svg -- возвращает сгенерированный SVG по минутному срезу
func (sf *ModStatSec) Svg() string {
	sf.Lock()
	defer sf.Unlock()
	sf.bufSvg.Reset()
	cnv := svg.New(sf.bufSvg)
	cnv.Start(480, 320)
	cnv.Title("Last 60 sec")
	cnv.Desc("Graphic of last 60 sec")
	// cnv.Text(20, 20, "Last 60 sec", "text-anchor:middle;font-size:14px;fill:white")
	cnv.Text(20, 20, "Last 60 sec", "")
	// cnv.Circle(250, 250, 125, "fill:none;stroke:black")
	var (
		valMin = math.MaxInt64
		valMax = math.MinInt64
	)
	fnGetMinMax := func() { // Вычисляет максимальное и минимальное значение в графике
		for _, val := range sf.lst {
			if val < valMin {
				valMin = val
			}
			if val > valMax {
				valMax = val
			}
		}
	}
	fnGetMinMax()
	for i, val := range sf.lst {
		x1 := int(float32(i)*6) + 42
		y1 := int(240 * float32(valMax) / float32(val))
		cnv.Rect(x1, 280-y1, 5, y1, "fill:true;stroke:red;")
	}
	fnDrawNet := func() {
		// Метки величины
		if valMin == math.MaxInt64 {
			valMin = 0
		}

		if valMax == math.MinInt64 {
			valMax = 1
		}
		cnv.Text(25, 285, fmt.Sprint(valMin), "")
		cnv.Text(25, 45, fmt.Sprint(valMax), "")

		// Метки времени
		timeNow := time.Now().Local()
		timeSub60 := timeNow.Add(-60 * time.Second).Format("05")
		cnv.Text(40, 295, timeSub60, "")

		timeSub45 := timeNow.Add(-45 * time.Second).Format("05")
		cnv.Text(128, 295, timeSub45, "")

		timeSub30 := timeNow.Add(-30 * time.Second).Format("05")
		cnv.Text(216, 295, timeSub30, "")

		timeSub15 := timeNow.Add(-15 * time.Second).Format("05")
		cnv.Text(304, 295, timeSub15, "")

		timeSub0 := time.Now().Format("05")
		cnv.Text(392, 295, timeSub0, "")
		cnv.Line(40, 280, 40, 38, "fill:true;stroke:black;stroke-width:4")
		cnv.Line(40, 280, 442, 280, "fill:true;stroke:black;stroke-width:4")
		count := 0
		for x := 40; x < 460; x += 20 {
			cnv.Line(x, 40, x, 280, "fill:true;stroke:gray")
			if count%5 == 0 {
				cnv.Text(x+3, 278, fmt.Sprint(x), "fill:white;stroke:gray")
			}
			count++
		}
		count = 0
		for y := 40; y < 300; y += 20 {
			cnv.Line(40, y, 440, y, "fill:true;stroke:gray")
			if count%5 == 0 {
				cnv.Text(43, y+12, fmt.Sprint(y), "fill:white;stroke:gray")
			}
			count++
		}
	}
	fnDrawNet()
	cnv.End()
	strOut := sf.bufSvg.String()
	// strOut = strings.ReplaceAll(strOut, strCut, "")
	return strOut
}