From 3aab2c8a37ef8bb95ab8c995610d794720cc166d Mon Sep 17 00:00:00 2001
From: douxu <douxu@clea.com.cn>
Date: Mon, 1 Sep 2025 16:15:30 +0800
Subject: [PATCH] add telemetry machine code

---
 constants/measurement.go            | 31 +++++++++++++++++++++++++++++
 database/filling_attr_model_info.go |  6 +++---
 database/query_grid.go              |  4 ++--
 database/query_station.go           |  4 ++--
 database/query_zone.go              |  4 ++--
 5 files changed, 40 insertions(+), 9 deletions(-)
 create mode 100644 constants/measurement.go

diff --git a/constants/measurement.go b/constants/measurement.go
new file mode 100644
index 0000000..991ad9d
--- /dev/null
+++ b/constants/measurement.go
@@ -0,0 +1,31 @@
+// Package constants define constant variable
+package constants
+
+const (
+	// DataSourceTypeCL3611 define CL3611 type
+	DataSourceTypeCL3611 = 1
+	// DataSourceTypePower104 define electricity 104 protocol type
+	DataSourceTypePower104 = 2
+)
+
+// channel name prefix
+const (
+	ChannelPrefixTelemetry     = "Telemetry"
+	ChannelPrefixTelesignal    = "Telesignal"
+	ChannelPrefixTelecommand   = "Telecommand"
+	ChannelPrefixTeleadjusting = "Teleadjusting"
+	ChannelPrefixSetpoints     = "Setpoints"
+)
+
+// channel name suffix
+const (
+	ChannelP      = "P"
+	ChannelQ      = "Q"
+	ChannelS      = "S"
+	ChannelPS     = "PS"
+	ChannelF      = "F"
+	ChannelDeltaF = "deltaF"
+	ChannelUAB    = "UAB"
+	ChannelUBC    = "UBC"
+	ChannelUCA    = "UCA"
+)
diff --git a/database/filling_attr_model_info.go b/database/filling_attr_model_info.go
index f48dd7e..e9d5c5a 100644
--- a/database/filling_attr_model_info.go
+++ b/database/filling_attr_model_info.go
@@ -67,17 +67,17 @@ func FillingShortAttrModel(ctx context.Context, tx *gorm.DB, attrItems []string,
 
 // FillingLongAttrModel define filling long attribute model info
 func FillingLongAttrModel(ctx context.Context, tx *gorm.DB, attrItems []string, attrModel *model.LongAttrInfo) error {
-	grid, err := QueryGridByName(ctx, tx, attrItems[0])
+	grid, err := QueryGridByTagName(ctx, tx, attrItems[0])
 	if err != nil {
 		return err
 	}
 	attrModel.GridInfo = &grid
-	zone, err := QueryZoneByName(ctx, tx, attrItems[1])
+	zone, err := QueryZoneByTagName(ctx, tx, attrItems[1])
 	if err != nil {
 		return err
 	}
 	attrModel.ZoneInfo = &zone
-	station, err := QueryStationByName(ctx, tx, attrItems[2])
+	station, err := QueryStationByTagName(ctx, tx, attrItems[2])
 	if err != nil {
 		return err
 	}
diff --git a/database/query_grid.go b/database/query_grid.go
index 233ac2e..ae6b28d 100644
--- a/database/query_grid.go
+++ b/database/query_grid.go
@@ -11,8 +11,8 @@ import (
 	"gorm.io/gorm/clause"
 )
 
-// QueryGridByName return the result of query circuit diagram grid info by tagName from postgresDB
-func QueryGridByName(ctx context.Context, tx *gorm.DB, tagName string) (orm.Grid, error) {
+// QueryGridByTagName return the result of query circuit diagram grid info by tagName from postgresDB
+func QueryGridByTagName(ctx context.Context, tx *gorm.DB, tagName string) (orm.Grid, error) {
 	var grid orm.Grid
 	// ctx超时判断
 	cancelCtx, cancel := context.WithTimeout(ctx, 5*time.Second)
diff --git a/database/query_station.go b/database/query_station.go
index 79dc6ec..2642f82 100644
--- a/database/query_station.go
+++ b/database/query_station.go
@@ -11,8 +11,8 @@ import (
 	"gorm.io/gorm/clause"
 )
 
-// QueryStationByName return the result of query circuit diagram Station info by tagName from postgresDB
-func QueryStationByName(ctx context.Context, tx *gorm.DB, tagName string) (orm.Station, error) {
+// QueryStationByTagName return the result of query circuit diagram Station info by tagName from postgresDB
+func QueryStationByTagName(ctx context.Context, tx *gorm.DB, tagName string) (orm.Station, error) {
 	var station orm.Station
 	// ctx超时判断
 	cancelCtx, cancel := context.WithTimeout(ctx, 5*time.Second)
diff --git a/database/query_zone.go b/database/query_zone.go
index 4c0a67f..2be3489 100644
--- a/database/query_zone.go
+++ b/database/query_zone.go
@@ -11,8 +11,8 @@ import (
 	"gorm.io/gorm/clause"
 )
 
-// QueryZoneByName return the result of query circuit diagram Zone info by tagName from postgresDB
-func QueryZoneByName(ctx context.Context, tx *gorm.DB, tagName string) (orm.Zone, error) {
+// QueryZoneByTagName return the result of query circuit diagram Zone info by tagName from postgresDB
+func QueryZoneByTagName(ctx context.Context, tx *gorm.DB, tagName string) (orm.Zone, error) {
 	var zone orm.Zone
 	// ctx超时判断
 	cancelCtx, cancel := context.WithTimeout(ctx, 5*time.Second)