model

type ChildDeviceMessage struct {
	DeviceKey          string
	Timestamp          int64
	ChildDeviceKey     string
	ChildDeviceMessage Message
}

type ChildDeviceMessageReply struct {
	DeviceKey          string
	MessageId          string
	ChildDeviceKey     string
	ChildDeviceMessage Message
}

type Command struct {
	Name       string      `json:"name"`
	Argument   bool        `json:"argument"`
	Directives []Directive `json:"directives"`
}

type Common struct {
	H                Header
	DeviceKey        string
	GatewayDeviceKey string
	MessageId        string
	Timestamp        int64
}

type DataPoint struct {
	Value interface{} `json:"value"`
	Time  time.Time   `json:"time"`
}

type DataType int

type DefaultDevice struct {
	Station    int    `json:"station"`
	ProductKey string `json:"product_key"`
}

type DefaultReportFormate struct {
	Attr       map[string]interface{} `json:"attr"`
	DeviceId   string                 `json:"device_id"`
	ReturnTime string                 `json:"return_time"`
}

type DerivedMetadataMessage struct {
	DeviceKey string
	Timestamp int64
	Metadata  string
	All       bool
}

type Device struct {
	DeviceKey  string `json:"device_key"`
	TunnelId   uint64 `json:"tunnel_id" boltholdIndex:"TunnelId"`
	ProductKey string `json:"product_key"`
	Name       string `json:"name"`
	Station    int    `json:"station"`

	Disabled bool      `json:"disabled"`
	Created  time.Time `json:"created" xorm:"created"`
}

type DeviceOfflineMessage struct {
	DeviceKey  string
	ProductKey string
	Timestamp  int64
}

type DeviceOnlineMessage struct {
	DeviceKey  string
	ProductKey string
	Timestamp  int64
}

type DeviceRegisterMessage struct {
	DeviceKey string
	Timestamp int64
}

type Directive struct {
	Point string  `json:"point"`
	Value float64 `json:"value"`
	Delay int64   `json:"delay"`

	//使用表达式
	Expression string `json:"expression,omitempty"`
}

type EventMessage struct {
	H         Header
	Event     string
	Data      any
	Timestamp int64
}

type FunctionInvokeMessage struct {
	Common
	FunctionId string
	Inputs     []FunctionParameter
}

type FunctionInvokeMessageReply struct {
	Common
	Success bool
	Output  any
}

type FunctionParameter struct {
	Name  string
	Value any
}

type Header struct {
	Async                    bool `json:"async" desc:"是否异步"`
	Timeout                  int  `json:"timeout" desc:"超时时间，单位为毫秒"`
	FragMsgId                int  `json:"fragMsgId" desc:"分片主消息ID，为平台下发消息时的消息ID（messageId"`
	FragNum                  int  `json:"fragNum" desc:"分片总数"`
	FragPart                 int  `json:"fragPart" desc:"当前分片索引"`
	FragLast                 int  `` /* 184-byte string literal not displayed */
	KeepOnline               int  `` /* 144-byte string literal not displayed */
	KeepOnlineTimeoutSeconds int  `` /* 147-byte string literal not displayed */
	IgnoreStorage            int  `` /* 161-byte string literal not displayed */
	IgnoreLog                bool `json:"ignoreLog" desc:"不记录此消息的日志。如：设置为true，将不记录此消息的日志。"`
	MergeLatest              bool `` /* 164-byte string literal not displayed */
}

type HeartBeatPacket struct {
	Enable  bool   `json:"enable"`
	Timeout int64  `json:"timeout"`
	Regex   string `json:"regex,omitempty"`
	Hex     string `json:"hex,omitempty"`
	Text    string `json:"text,omitempty"`
	Length  int    `json:"length,omitempty"`
	// contains filtered or unexported fields
}

type Message any

type Point struct {
	Name         string   `json:"name"`
	Label        string   `json:"label"`
	Unit         string   `json:"unit"`
	Type         DataType `json:"type"`
	LittleEndian bool     `json:"le"`
	Precision    int      `json:"precision"`
	Code         string   `json:"code"`
	Address      string   `json:"address"`
	Store        bool     `json:"store"`
}

type Poller struct {
	Disabled bool   `json:"disabled,omitempty"`
	Interval int    `json:"interval"`
	Code     string `json:"code"`
	Address  string `json:"address"`
	Length   int    `json:"length"`
}

type Product struct {
	Id           string   `json:"id" xorm:"pk"`
	Name         string   `json:"name"`
	Manufacturer string   `json:"manufacturer"` //厂家
	Version      string   `json:"version"`      //SEMVER
	Protocol     Protocol `json:"protocol"`

	Tags     []string   `json:"tags,omitempty"`
	Pollers  []*Poller  `json:"pollers"`
	Commands []*Command `json:"commands"`

	Created time.Time `json:"created" xorm:"created"`
}

type Protocol struct {
	Name    string                 `json:"name"`
	Options map[string]interface{} `json:"options"`
}

type ReadPropertyMessage struct {
	Common
	Properties []string
}

type ReadPropertyMessageReply struct {
	Common
	Success    bool
	Properties map[string]any
}

type RegisterPacket struct {
	Regex  string `json:"regex,omitempty"`
	Length int    `json:"length,omitempty"`
	// contains filtered or unexported fields
}

type ReportPropertyMessage struct {
	Common
	Properties map[string]any
}

type Retry struct {
	Enable  bool `json:"enable"`
	Timeout int  `json:"timeout"`
	Maximum int  `json:"maximum"`
}

type SerialOptions struct {
	Port     string `json:"port"`      // /dev/tty.usb.. COM1
	BaudRate uint   `json:"baud_rate"` //9600 ... 115200 ...
	DataBits uint   `json:"data_bits"` //5 6 7 8
	StopBits uint   `json:"stop_bits"` //1 2
	Parity   uint   `json:"parity"`    // 0:NONE 1:ODD 2:EVEN

}

type Server struct {
	Id            int               `json:"id"`
	Name          string            `json:"name"`
	Type          string            `json:"type"` //tcp udp
	Addr          string            `json:"addr"`
	Register      RegisterPacket    `json:"register"`
	Heartbeat     HeartBeatPacket   `json:"heartbeat"`
	Options       map[string]string `json:"options"`
	Protocol      Protocol          `json:"protocol"`
	Devices       []DefaultDevice   `json:"devices"` //默认设备
	Disabled      bool              `json:"disabled"`
	Created       time.Time         `json:"created" xorm:"created"`
	IsTls         uint              `json:"isTls" dc:"开启TLS:1=是，0=否"`
	AuthType      int               `json:"authType" dc:"认证方式（1=Basic，2=AccessToken，3=证书）"`
	AuthUser      string            `json:"authUser" dc:"认证用户"`
	AuthPasswd    string            `json:"authPasswd" dc:"认证密码"`
	AccessToken   string            `json:"accessToken" dc:"AccessToken"`
	CertificateId int               `json:"certificateId" dc:"证书ID"`
	Stick         string            `json:"stick" dc:"粘包处理方式"`
}

type Tunnel struct {
	Id        uint64          `json:"id"`
	ServerId  int             `json:"server_id" boltholdIndex:"ServerId"`
	Name      string          `json:"name"`
	SN        string          `json:"sn" boltholdIndex:"Addr"`
	Type      string          `json:"type"` //serial tcp-client tcp-server udp-client udp-server server-tcp server-udp
	Addr      string          `json:"addr"`
	Remote    string          `json:"remote"`
	Retry     Retry           `json:"retry"`     //重试
	Heartbeat HeartBeatPacket `json:"heartbeat"` // 主要是检查设备的心跳，过滤掉心跳数据
	Serial    SerialOptions   `json:"serial"`    // 串口通信配置参数
	Protocol  Protocol        `json:"protocol"`  //协议配置，包含协议名称和配置
	//Devices   []DefaultDevice  `json:"devices"` //默认设备
	Disabled bool      `json:"disabled"`
	Last     time.Time `json:"last"`
	Created  time.Time `json:"created" xorm:"created"`
}

type TunnelEx struct {
	Tunnel  `xorm:"extends"`
	Running bool   `json:"running"`
	Online  bool   `json:"online"`
	Server  string `json:"server"`
}

type UpdateTagMessage struct {
	DeviceKey string
	Timestamp int64
	// contains filtered or unexported fields
}

type UpgradeFirmwareMessage struct {
	DeviceKey  string
	Timestamp  int64
	Url        string
	Version    string
	Parameters map[string]any
	Sign       string
	SignMethod string
	FirmwareId string
	Size       float64
}

type UpgradeFirmwareMessageReply struct {
	DeviceKey string
	Timestamp int64
	Success   bool
}

type UpgradeFirmwareProgressMessage struct {
	DeviceKey   string
	Progress    int
	Complete    bool
	Version     string
	Success     bool
	ErrorReason string
	FirmwareId  string
}

type WritePropertyMessage struct {
	Common
	Properties map[string]any
}

type WritePropertyMessageReply struct {
	Common
	Success    bool
	Properties map[string]any
}