AnalysisAny

package
v5.4.29 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 12, 2026 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (

	//NoMqtt 是否不推送MQTT
	// 用于外部服务更新数据
	NoMqtt = false
)

Functions

func AppendAny 

func AppendAny(args *ArgsAppendAny) (err error)

AppendAny 添加新的记录 Deprecated

func CheckAnyHaveData 

func CheckAnyHaveData(args *ArgsGetAnyByMark) (haveData bool)

CheckAnyHaveData 检查条件下是否存在数据？ Deprecated

func GetAnyInt64ByMark 

func GetAnyInt64ByMark(args *ArgsGetAnyByMark) (count int64, err error)

GetAnyInt64ByMark 单独获取数据的统计数字 Deprecated

func GetAnyInt64ByMarkNoErr 

func GetAnyInt64ByMarkNoErr(args *ArgsGetAnyByMark) (count int64)

Deprecated

func Init 

func Init()

func InitConfig 

func InitConfig(args *ArgsInitConfig) (err error)

InitConfig 初始化配置设置 Deprecated

func Run 

func Run()

Types

type ArgsAppendAny 

type ArgsAppendAny struct {
	//创建时间
	// 如果给空，则默认当前时间
	CreateAt string `db:"create_at" json:"createAt"`
	//组织ID
	// 可留空
	OrgID int64 `db:"org_id" json:"orgID" check:"id" empty:"true"`
	//用户ID
	// 可留空
	UserID int64 `db:"user_id" json:"userID" check:"id" empty:"true"`
	//绑定ID
	BindID int64 `db:"bind_id" json:"bindID" check:"id" empty:"true"`
	//扩展参数1
	// 可选扩展参数，默认给0无视
	Param1 int64 `db:"params1" json:"params1" check:"id" empty:"true"`
	//扩展参数2
	// 可选扩展参数，默认给0无视
	Param2 int64 `db:"params2" json:"params2" check:"id" empty:"true"`
	//数据标识码
	Mark string `db:"mark" json:"mark" check:"mark"`
	//数据
	Data    int64  `db:"data" json:"data"`
	DataVal string `db:"data_val" json:"dataVal"`
}

ArgsAppendAny 添加新的记录参数

type ArgsGetAnyByMark 

type ArgsGetAnyByMark struct {
	//组织ID
	// 可留空，用于验证
	OrgID int64 `db:"org_id" json:"orgID" check:"id" empty:"true"`
	//用户ID
	// 可留空
	UserID int64 `db:"user_id" json:"userID" check:"id" empty:"true"`
	//数据标识码
	Mark string `db:"mark" json:"mark" check:"mark"`
	//绑定ID
	BindID int64 `db:"bind_id" json:"bindID" check:"id" empty:"true"`
	//扩展参数1
	// 可选扩展参数，默认给0无视
	Param1 int64 `db:"params1" json:"params1" check:"id" empty:"true"`
	//扩展参数2
	// 可选扩展参数，默认给0无视
	Param2 int64 `db:"params2" json:"params2" check:"id" empty:"true"`
	//时间范围
	BetweenTime CoreSQLTime.DataCoreTime `json:"betweenTime"`
}

ArgsGetAnyByMark 获取指定的记录参数

type ArgsInitConfig 

type ArgsInitConfig struct {
	//数据标识码
	Mark string `db:"mark" json:"mark" check:"mark"`
	//归档天数
	// 必须指定，小于1则强制按照3天计算
	FileDay int `db:"file_day" json:"fileDay" check:"intThan0"`
	//是否需要推送组织MQTT
	MqttOrg  bool `db:"mqtt_org" json:"mqttOrg"`
	MqttUser bool `db:"mqtt_user" json:"mqttUser"`
	MqttBind bool `db:"mqtt_bind" json:"mqttBind"`
}

ArgsInitConfig 初始化配置设置参数

type DataGetAnyByMark 

type DataGetAnyByMark struct {
	//ID
	ID int64 `db:"id" json:"id" check:"id"`
	//创建时间
	CreateAt time.Time `db:"create_at" json:"createAt"`
	//组织ID
	// 可留空
	OrgID int64 `db:"org_id" json:"orgID" check:"id" empty:"true"`
	//用户ID
	// 可留空
	UserID int64 `db:"user_id" json:"userID" check:"id" empty:"true"`
	//绑定ID
	BindID int64 `db:"bind_id" json:"bindID" check:"id" empty:"true"`
	//扩展参数1
	// 可选扩展参数，默认给0无视
	Param1 int64 `db:"params1" json:"params1" check:"id" empty:"true"`
	//扩展参数2
	// 可选扩展参数，默认给0无视
	Param2 int64 `db:"params2" json:"params2" check:"id" empty:"true"`
	//数据类型
	Mark string `db:"mark" json:"mark"`
	//数据Hash
	Hash string `db:"hash" json:"hash"`
	//数据
	Data    int64  `db:"data" json:"data"`
	DataVal string `db:"data_val" json:"dataVal"`
}

func GetAnyByMark 

func GetAnyByMark(args *ArgsGetAnyByMark) (data DataGetAnyByMark, err error)

GetAnyByMark 获取指定的记录 Deprecated

type DataGetAnySumByMark 

type DataGetAnySumByMark struct {
	//影响行数
	IDCount int64 `db:"id_count" json:"idCount"`
	//创建时间
	CreateMinAt time.Time `db:"create_min_at" json:"createMinAt"`
	CreateMaxAt time.Time `db:"create_max_at" json:"createMaxAt"`
	//组织ID
	// 可留空
	OrgID int64 `db:"org_id" json:"orgID" check:"id" empty:"true"`
	//用户ID
	// 可留空
	UserID int64 `db:"user_id" json:"userID" check:"id" empty:"true"`
	//绑定ID
	BindID int64 `db:"bind_id" json:"bindID" check:"id" empty:"true"`
	//扩展参数1
	// 可选扩展参数，默认给0无视
	Param1 int64 `db:"params1" json:"params1" check:"id" empty:"true"`
	//扩展参数2
	// 可选扩展参数，默认给0无视
	Param2 int64 `db:"params2" json:"params2" check:"id" empty:"true"`
	//数据类型
	Mark string `db:"mark" json:"mark"`
	//数据
	Data    int64  `db:"data" json:"data"`
	DataVal string `db:"data_val" json:"dataVal"`
}

func GetAnySumByMark 

func GetAnySumByMark(args *ArgsGetAnyByMark) (data DataGetAnySumByMark, err error)

GetAnySumByMark 获取指定的记录(同一个阶段的合计数) Deprecated

type FieldsAny 

type FieldsAny struct {
	//ID
	ID int64 `db:"id" json:"id" check:"id"`
	//创建时间
	CreateAt time.Time `db:"create_at" json:"createAt"`
	//组织ID
	// 可留空
	OrgID int64 `db:"org_id" json:"orgID" check:"id" empty:"true"`
	//用户ID
	// 可留空
	UserID int64 `db:"user_id" json:"userID" check:"id" empty:"true"`
	//绑定ID
	BindID int64 `db:"bind_id" json:"bindID" check:"id" empty:"true"`
	//扩展参数1
	// 可选扩展参数，默认给0无视
	Param1 int64 `db:"params1" json:"params1" check:"id" empty:"true"`
	//扩展参数2
	// 可选扩展参数，默认给0无视
	Param2 int64 `db:"params2" json:"params2" check:"id" empty:"true"`
	//数据配置ID
	ConfigID int64 `db:"config_id" json:"configID" check:"id"`
	//数据Hash
	Hash string `db:"hash" json:"hash"`
	//数据
	Data    int64  `db:"data" json:"data"`
	DataVal string `db:"data_val" json:"dataVal"`
}

FieldsAny 统计数据支持

type FieldsConfig 

type FieldsConfig struct {
	//ID
	ID int64 `db:"id" json:"id" check:"id"`
	//创建时间
	CreateAt time.Time `db:"create_at" json:"createAt"`
	//更新时间
	UpdateAt time.Time `db:"update_at" json:"updateAt"`
	//删除时间
	DeleteAt time.Time `db:"delete_at" json:"deleteAt"`
	//数据标识码
	Mark string `db:"mark" json:"mark" check:"mark"`
	//推送MQTT时间
	LastMQTT time.Time `db:"last_mqtt" json:"lastMQTT"`
	//上次推送的hash
	LastHash string `db:"last_hash" json:"lastHash"`
	//归档天数
	// 必须指定，小于1则强制按照3天计算
	FileDay int `db:"file_day" json:"fileDay" check:"intThan0"`
	//是否需要推送组织MQTT
	MqttOrg  bool `db:"mqtt_org" json:"mqttOrg"`
	MqttUser bool `db:"mqtt_user" json:"mqttUser"`
	MqttBind bool `db:"mqtt_bind" json:"mqttBind"`
}

FieldsConfig 统计配置

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.