gt-common/envitem/func_test.go

package envitem

import (
	"encoding/json"
	"github.com/go-redis/redis/v8"
	"testing"
	"time"
)

func TestEnvItem_GetCurrentData(t *testing.T) {
	SetOptions(Options{GtServerIp: "47.96.12.136:8788"})
	e := EnvItem{
		ProjectId: 92,
		Item:      "C.M.LT_QSC@out",
	}

	v, ht, err := e.getCurrentValue()

	t.Log(v, ht, err)

}

func TestMultiEnvItem_FillCurrentValue(t *testing.T) {
	cache := redis.NewClient(&redis.Options{Addr: "47.96.12.136:6379", Password: "", MaxRetries: 5})
	SetOptions(Options{GtServerIp: "47.96.12.136:8788", FetchMultiItem: false, Cache: cache, AdjustValue: true})
	m := make(MultiEnvItem, 2)
	m["C.M.LT_CIP@out"] = &EnvItem{
		ProjectId: 92,
		Item:      "C.M.LT_CIP@out",
	}
	m["C.M.RO1_DB@time_CS_display"] = &EnvItem{
		ProjectId: 92,
		Item:      "C.M.RO1_DB@time_CS_display",
	}

	m["C.M.LT_QSC@out"] = &EnvItem{
		ProjectId: 92,
		Item:      "C.M.LT_QSC@out",
	}

	err := m.FillCurrentValue()
	t.Log(err)

	for s, item := range m {
		t.Logf("item: %s value: %s htime: %s", s, item.Value, item.Htime)
	}

	m["C.M.LT_QSC@out"].ClearAdjust()
}

func TestMultiEnvItem_FillCurrentValue2(t *testing.T) {
	cache := redis.NewClient(&redis.Options{Addr: "47.96.12.136:6379", Password: "", MaxRetries: 5})
	SetOptions(Options{GtServerIp: "47.96.12.136:8788", FetchMultiItem: false, Cache: cache})
	js := `{"tmp":{"project_id":92,"device_code":"UF-4001A","plc_device_id":"0","item":"C.M.UF1_DB@press_PV","default_val":0},"feed_flow":{"project_id":92,"device_code":"UF-4001A","plc_device_id":"0","item":"C.M.UF1_FT_JS@out","default_val":0},"feed_pressure":{"project_id":92,"device_code":"UF-4001A","plc_device_id":"0","item":"C.M.UF1_PT_JS@out","default_val":0},"product_pressure":{"project_id":92,"device_code":"UF-4001A","plc_device_id":"0","item":"C.M.UF1_PT_CS@out","default_val":0},"feed_wq_turbidity":{"project_id":92,"device_code":"AIT-94061","plc_device_id":"0","item":"C.M.UF_Tur_ZJS@out","default_val":0},"water_temperature":{"project_id":92,"device_code":"TIT-34061","plc_device_id":"0","item":"C.M.RO_TT_ZJS@out","default_val":0},"product_wq_ph":{"project_id":92,"device_code":"AIT-95065b","plc_device_id":"0","item":"C.M.UF_PH_ZCS@out","default_val":0},"step":{"project_id":92,"device_code":"HB","plc_device_id":"0","item":"C.M.UF1_DB@word_control","default_val":0}}`
	var multiEnvItems MultiEnvItem

	_ = json.Unmarshal([]byte(js), &multiEnvItems)

	t.Log(multiEnvItems)

	_ = multiEnvItems.FillCurrentValue()

	for {
		//_ = multiEnvItems.FillCurrentValue()
		multiEnvItems.ClearValues()
		v := multiEnvItems.GetItemFloat64Value("feed_flow")
		t.Logf("item: %s, %f", "feed_flow", v)

		//for s, item := range multiEnvItems {
		//	if item != nil {
		//		t.Logf("item: %s value: %f htime: %v", s, item.GetItemFloat64Val(), item.GetItemHtime())
		//	} else {
		//		t.Logf("item: %s fetch failure", s)
		//	}
		//
		//}

		time.Sleep(2 * time.Second)

		//ms := multiEnvItems.FindString()

		//t.Logf("%+v", multiEnvItems)

		//t.Logf("step: %d", multiEnvItems.GetItemInt64Value("step"))
		//early := checkEarly(multiEnvItems.GetItemFloat64Value("Display_Time"), multiEnvItems.GetItemFloat64Value("Filter_Time_Set"), multiEnvItems.GetItemStringValue("Step"))
		//advanced := checkAdvanced(multiEnvItems.GetItemFloat64Value("Display_Time"), multiEnvItems.GetItemFloat64Value("Filter_Time_Set"), multiEnvItems.GetItemStringValue("Step"))
		//
		//t.Logf("early: %v, advanced: %v, step: %s filterNumber: %s Display_Time: %s Filter_Time_Set: %s", early, advanced, multiEnvItems.GetItemStringValue("Step"), multiEnvItems.GetItemStringValue("Filter_Number"), multiEnvItems.GetItemStringValue("Display_Time"), multiEnvItems.GetItemStringValue("Filter_Time_Set"))
		//t.Log(err)
		//for s, item := range multiEnvItems {
		//	t.Logf("item: %s value: %s htime: %s", s, item.Value, item.Htime)
		//}
	}

}

func TestEnvItem_Adjust(t *testing.T) {
	cache := redis.NewClient(&redis.Options{Addr: "47.96.12.136:6379", Password: "", MaxRetries: 5})

	SetOptions(Options{GtServerIp: "47.96.12.136:8788", Cache: cache, AdjustValue: true})
	e := EnvItem{
		ProjectId: 92,
		Item:      "C.M.LT_QSC@out",
	}

	//v, ht, err := e.getCurrentValue()

	//e.IncreAdjust(3600 * time.Second)
	//e.IncreAdjust(3600 * time.Second)
	e.IncreAdjust(3600 * time.Second)
	//
	//e.SetAdjust("65325", 3*time.Second)

	adjust, err := e.GetAdjustInt64Val()

	//t.Log(v, ht, err)

	t.Log(adjust, err)
}

func TestEnvItem_GetValueForAdjust(t *testing.T) {
	cache := redis.NewClient(&redis.Options{Addr: "47.96.12.136:6379", Password: "", MaxRetries: 5})

	SetOptions(Options{GtServerIp: "47.96.12.136:8788", Cache: cache, AdjustValue: false})
	e := EnvItem{
		ProjectId: 92,
		Item:      "C.M.LT_QSC@out",
	}

	v := e.GetItemFloat64Val()

	t.Log(v)
}