smgp

package
v0.4.1 Latest Latest
Warning

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

 Go to latest Published: Aug 5, 2022 License: MIT Imports: 12 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	LoginLen     = 42
	LoginRespLen = 33
)
View Source 
const (
	V30 Version = 0x30
	V20 Version = 0x20
	V13 Version = 0x13

	TP_pid           = uint16(0x0001)
	TP_udhi          = uint16(0x0002)
	PkTotal          = uint16(0x0009)
	PkNumber         = uint16(0x000A)
	LinkID           = uint16(0x0003)
	ChargeUserType   = uint16(0x0004)
	ChargeTermType   = uint16(0x0005)
	ChargeTermPseudo = uint16(0x0006)
	DestTermType     = uint16(0x0007)
	DestTermPseudo   = uint16(0x0008)
	SubmitMsgType    = uint16(0x000B)
	SPDealReslt      = uint16(0x000C)
	SrcTermType      = uint16(0x000D)
	SrcTermPseudo    = uint16(0x000E)
	NodesCount       = uint16(0x000F)
	MsgSrc           = uint16(0x0010)
	SrcType          = uint16(0x0011)
	MServiceID       = uint16(0x0012)
)
View Source 
const MtBaseLen = 126
View Source 
const RptLen = 10 + 3 + 3 + 10 + 10 + 7 + 3 + 20 + len("id: sub: dlvrd: submit date: done date: stat: err: text:")

Variables

View Source 
var (
	GbEncoder = simplifiedchinese.GB18030.NewEncoder()
	GbDecoder = simplifiedchinese.GB18030.NewDecoder()
)
View Source 
var StatMap = map[uint32]string{
	0:  "成功",
	1:  "系统忙",
	2:  "超过最大连接数",
	10: "消息结构错",
	11: "命令字错",
	12: "序列号重复",
	20: "IP地址错",
	21: "认证错",
	22: "版本太高",
	30: "非法消息类型（MsgType）",
	31: "非法优先级（LruPriority）",
	32: "非法资费类型（FeeType）",
	33: "非法资费代码（FeeCode）",
	34: "非法短消息格式（MsgFormat）",
	35: "非法时间格式",
	36: "非法短消息长度（MsgLength）",
	37: "有效期已过",
	38: "非法查询类别（QueryType）",
	39: "路由错误",
	40: "非法包月费/封顶费（FixedFee）",
	41: "非法更新类型（UpdateType）",
	42: "非法路由编号（RouteId）",
	43: "非法服务代码（ServiceId）",
	44: "非法有效期（ValidTime）",
	45: "非法定时发送时间（AtTime）",
	46: "非法发送用户号码（SrcTermId）",
	47: "非法接收用户号码（DestTermId）",
	48: "非法计费用户号码（ChargeTermId）",
	49: "非法SP服务代码（SPCode）",
	56: "非法源网关代码（SrcGatewayID）",
	57: "非法查询号码（QueryTermID）",
	58: "没有匹配路由",
	59: "非法SP类型（SPType）",
	60: "非法上一条路由编号（LastRouteID）",
	61: "非法路由类型（RouteType）",
	62: "非法目标网关代码（DestGatewayID）",
	63: "非法目标网关IP（DestGatewayIP）",
	64: "非法目标网关端口（DestGatewayPort）",
	65: "非法路由号码段（TermRangeID）",
	66: "非法终端所属省代码（ProvinceCode）",
	67: "非法用户类型（UserType）",
	68: "本节点不支持路由更新",
	69: "非法SP企业代码（SPID）",
	70: "非法SP接入类型（SPAccessType）",
	71: "路由信息更新失败",
	72: "非法时间戳（Time）",
	73: "非法业务代码（MServiceID）",
	74: "SP禁止下发时段",
	75: "SP发送超过日流量",
	76: "SP帐号过有效期",
}

Functions

func NewDeliver 

func NewDeliver(cli *auth.Client, phone string, destNo string, txt string, seq uint32) codec.RequestPdu

func NewSubmit 

func NewSubmit(cli *auth.Client, phones []string, content string, seq uint32, options MtOptions) (messages []codec.RequestPdu)

Types

type ActiveTest 

type ActiveTest MessageHeader

func NewActiveTest 

func NewActiveTest(seq uint32) *ActiveTest

func (*ActiveTest) Decode 

func (t *ActiveTest) Decode(seq uint32, _ []byte) error

func (*ActiveTest) Encode 

func (t *ActiveTest) Encode() []byte

func (*ActiveTest) Log 

func (t *ActiveTest) Log() []log.Field

func (*ActiveTest) String 

func (t *ActiveTest) String() string

func (*ActiveTest) ToResponse 

func (t *ActiveTest) ToResponse(_ uint32) codec.Pdu

type ActiveTestRsp 

type ActiveTestRsp MessageHeader

func (*ActiveTestRsp) Decode 

func (r *ActiveTestRsp) Decode(seq uint32, _ []byte) error

func (*ActiveTestRsp) Encode 

func (r *ActiveTestRsp) Encode() []byte

func (*ActiveTestRsp) Log 

func (r *ActiveTestRsp) Log() []log.Field

func (*ActiveTestRsp) String 

func (r *ActiveTestRsp) String() string

type CommandId 

type CommandId uint32

CommandId 命令定义 

const (
	SMGP_REQUEST_MIN, SMGP_RESPONSE_MIN CommandId = iota, 0x80000000 + iota
	SMGP_LOGIN, SMGP_LOGIN_RESP
	SMGP_SUBMIT, SMGP_SUBMIT_RESP
	SMGP_DELIVER, SMGP_DELIVER_RESP
	SMGP_ACTIVE_TEST, SMGP_ACTIVE_TEST_RESP

	SMGP_EXIT, SMGP_EXIT_RESP
	SMGP_REQUEST_MAX, SMGP_RESPONSE_MAX
)

func (CommandId) OpLog 

func (id CommandId) OpLog() log.Field

func (CommandId) String 

func (id CommandId) String() string

func (CommandId) ToInt 

func (id CommandId) ToInt() uint32

type DeliverRsp 

type DeliverRsp struct {
	MessageHeader

	// 协议版本,不是报文内容，但在调用encode方法前需要设置此值
	Version Version
	// contains filtered or unexported fields
}

func (*DeliverRsp) Decode 

func (r *DeliverRsp) Decode(seq uint32, frame []byte) error

func (*DeliverRsp) Encode 

func (r *DeliverRsp) Encode() []byte

func (*DeliverRsp) Log 

func (r *DeliverRsp) Log() (rt []log.Field)

func (*DeliverRsp) MsgId 

func (r *DeliverRsp) MsgId() string

func (*DeliverRsp) Status 

func (r *DeliverRsp) Status() Status

func (*DeliverRsp) String 

func (r *DeliverRsp) String() string

type Delivery added in v0.4.0 

type Delivery struct {
	MessageHeader

	// 协议版本,不是报文内容，但在调用encode方法前需要设置此值
	Version Version
	// contains filtered or unexported fields
}

func NewDeliveryReport 

func NewDeliveryReport(cli *auth.Client, mt *Submit, seq uint32, msgId []byte) *Delivery

func (*Delivery) Decode added in v0.4.0 

func (d *Delivery) Decode(seq uint32, frame []byte) error

func (*Delivery) DestTermID added in v0.4.0 

func (d *Delivery) DestTermID() string

func (*Delivery) Encode added in v0.4.0 

func (d *Delivery) Encode() []byte

func (*Delivery) IsReport added in v0.4.0 

func (d *Delivery) IsReport() bool

func (*Delivery) Log added in v0.4.0 

func (d *Delivery) Log() []log.Field

func (*Delivery) MsgBytes added in v0.4.0 

func (d *Delivery) MsgBytes() []byte

func (*Delivery) MsgContent added in v0.4.0 

func (d *Delivery) MsgContent() string

func (*Delivery) MsgFormat added in v0.4.0 

func (d *Delivery) MsgFormat() byte

func (*Delivery) MsgId added in v0.4.0 

func (d *Delivery) MsgId() []byte

func (*Delivery) MsgLength added in v0.4.0 

func (d *Delivery) MsgLength() byte

func (*Delivery) RecvTime added in v0.4.0 

func (d *Delivery) RecvTime() string

func (*Delivery) Report added in v0.4.0 

func (d *Delivery) Report() *Report

func (*Delivery) Reserve added in v0.4.0 

func (d *Delivery) Reserve() string

func (*Delivery) SrcTermID added in v0.4.0 

func (d *Delivery) SrcTermID() string

func (*Delivery) String added in v0.4.0 

func (d *Delivery) String() string

func (*Delivery) TlvList added in v0.4.0 

func (d *Delivery) TlvList() *utils.TlvList

func (*Delivery) ToResponse added in v0.4.0 

func (d *Delivery) ToResponse(code uint32) codec.Pdu

type Exit 

type Exit MessageHeader

func NewExit 

func NewExit(seq uint32) *Exit

func (*Exit) Decode 

func (t *Exit) Decode(seq uint32, _ []byte) error

func (*Exit) Encode 

func (t *Exit) Encode() []byte

func (*Exit) Log 

func (t *Exit) Log() []log.Field

func (*Exit) String 

func (t *Exit) String() string

func (*Exit) ToResponse 

func (t *Exit) ToResponse(_ uint32) codec.Pdu

type ExitRsp 

type ExitRsp MessageHeader

func (*ExitRsp) Decode 

func (r *ExitRsp) Decode(seq uint32, _ []byte) error

func (*ExitRsp) Encode 

func (r *ExitRsp) Encode() []byte

func (*ExitRsp) Log 

func (r *ExitRsp) Log() []log.Field

func (*ExitRsp) String 

func (r *ExitRsp) String() string

type Login 

type Login struct {
	MessageHeader //  【12字节】消息头

	Version Version //  【1字节】客户端支持的协议版本号
	// contains filtered or unexported fields
}

func NewLogin 

func NewLogin(cl *auth.Client, seq uint32) *Login

func (*Login) AuthenticatorClient 

func (l *Login) AuthenticatorClient() []byte

func (*Login) Check 

func (l *Login) Check(cli *auth.Client) Status

func (*Login) ClientID 

func (l *Login) ClientID() string

func (*Login) Decode 

func (l *Login) Decode(seq uint32, frame []byte) error

func (*Login) Encode 

func (l *Login) Encode() []byte

func (*Login) Log 

func (l *Login) Log() []log.Field

func (*Login) LoginMode 

func (l *Login) LoginMode() byte

func (*Login) SetSecret 

func (l *Login) SetSecret(secret string)

func (*Login) String 

func (l *Login) String() string

func (*Login) Timestamp 

func (l *Login) Timestamp() uint32

func (*Login) ToResponse 

func (l *Login) ToResponse(code uint32) codec.Pdu

type LoginRsp 

type LoginRsp struct {
	MessageHeader // 协议头, 12字节

	Version Version // 版本，1字节
	// contains filtered or unexported fields
}

func (*LoginRsp) AuthenticatorServer 

func (r *LoginRsp) AuthenticatorServer() []byte

func (*LoginRsp) Decode 

func (r *LoginRsp) Decode(seq uint32, frame []byte) error

func (*LoginRsp) Encode 

func (r *LoginRsp) Encode() []byte

func (*LoginRsp) Log 

func (r *LoginRsp) Log() []log.Field

func (*LoginRsp) Status 

func (r *LoginRsp) Status() Status

func (*LoginRsp) String 

func (r *LoginRsp) String() string

type MessageHeader 

type MessageHeader struct {
	PacketLength uint32
	RequestId    CommandId
	SequenceId   uint32
}

func (*MessageHeader) Decode 

func (h *MessageHeader) Decode(frame []byte) error

func (*MessageHeader) Encode 

func (h *MessageHeader) Encode() []byte

func (*MessageHeader) Log 

func (h *MessageHeader) Log() []log.Field

func (*MessageHeader) String 

func (h *MessageHeader) String() string

type MtOptions 

type MtOptions struct {
	NeedReport    byte          // SP是否要求返回状态报告
	Priority      byte          // 短消息发送优先级,0-3
	ServiceID     string        // 业务代码
	AtTime        time.Time     // 短消息定时发送时间
	ValidDuration time.Duration // 短消息有效时长
	SrcTermID     string        // 会拼接到配置文件的sms-display-no后面
}

type Report 

type Report struct {
	// contains filtered or unexported fields
}

func NewReport 

func NewReport(id []byte) *Report

func (*Report) Decode 

func (rt *Report) Decode(frame []byte) error

func (*Report) Dlvrd added in v0.4.0 

func (rt *Report) Dlvrd() string

func (*Report) DoneDate added in v0.4.0 

func (rt *Report) DoneDate() string

func (*Report) Encode 

func (rt *Report) Encode() []byte

func (*Report) Id added in v0.4.0 

func (rt *Report) Id() []byte

func (*Report) Stat added in v0.4.0 

func (rt *Report) Stat() string

func (*Report) String 

func (rt *Report) String() string

func (*Report) Sub added in v0.4.0 

func (rt *Report) Sub() string

func (*Report) SubmitDate added in v0.4.0 

func (rt *Report) SubmitDate() string

type Status 

type Status uint32

Status 状态码

func (Status) String 

func (s Status) String() string

type Submit 

type Submit struct {
	MessageHeader

	// 协议版本,不是报文内容，但在调用encode方法前需要设置此值
	Version Version
	// contains filtered or unexported fields
}

func (*Submit) AtTime 

func (s *Submit) AtTime() string

func (*Submit) ChargeTermID 

func (s *Submit) ChargeTermID() string

func (*Submit) Decode 

func (s *Submit) Decode(seq uint32, frame []byte) error

func (*Submit) DestTermID 

func (s *Submit) DestTermID() []string

func (*Submit) DestTermIDCount 

func (s *Submit) DestTermIDCount() byte

func (*Submit) Encode 

func (s *Submit) Encode() []byte

func (*Submit) FeeCode 

func (s *Submit) FeeCode() string

func (*Submit) FeeType 

func (s *Submit) FeeType() string

func (*Submit) FixedFee 

func (s *Submit) FixedFee() string

func (*Submit) Log 

func (s *Submit) Log() []log.Field

func (*Submit) MsgBytes 

func (s *Submit) MsgBytes() []byte

func (*Submit) MsgContent 

func (s *Submit) MsgContent() string

func (*Submit) MsgFormat 

func (s *Submit) MsgFormat() byte

func (*Submit) MsgLength 

func (s *Submit) MsgLength() byte

func (*Submit) MsgType 

func (s *Submit) MsgType() byte

func (*Submit) NeedReport 

func (s *Submit) NeedReport() byte

func (*Submit) Priority 

func (s *Submit) Priority() byte

func (*Submit) Reserve 

func (s *Submit) Reserve() string

func (*Submit) ServiceID 

func (s *Submit) ServiceID() string

func (*Submit) SetOptions 

func (s *Submit) SetOptions(cli *auth.Client, options MtOptions)

func (*Submit) SrcTermID 

func (s *Submit) SrcTermID() string

func (*Submit) String 

func (s *Submit) String() string

func (*Submit) TlvList 

func (s *Submit) TlvList() *utils.TlvList

func (*Submit) ToResponse 

func (s *Submit) ToResponse(code uint32) codec.Pdu

func (*Submit) ValidTime 

func (s *Submit) ValidTime() string

type SubmitRsp 

type SubmitRsp struct {
	MessageHeader

	// 协议版本,不是报文内容，但在调用encode方法前需要设置此值
	Version Version
	// contains filtered or unexported fields
}

func (*SubmitRsp) Decode 

func (r *SubmitRsp) Decode(seq uint32, frame []byte) error

func (*SubmitRsp) Encode 

func (r *SubmitRsp) Encode() []byte

func (*SubmitRsp) Log 

func (r *SubmitRsp) Log() (rt []log.Field)

func (*SubmitRsp) MsgId 

func (r *SubmitRsp) MsgId() []byte

func (*SubmitRsp) Status 

func (r *SubmitRsp) Status() Status

func (*SubmitRsp) String 

func (r *SubmitRsp) String() string

type Version 

type Version uint8

func (Version) MajorMatch 

func (t Version) MajorMatch(v uint8) bool

MajorMatch 主版本相匹配

func (Version) MajorMatchV 

func (t Version) MajorMatchV(v Version) bool

MajorMatchV 主版本相匹配

func (Version) String 

func (t Version) String() string

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.