BaseService

Documentation

Index

• Variables
• func Init()
• func SetService(args *ArgsSetService) (err error)
• func SetServiceMarge(args *ArgsSetService, ...) (err error)
• type ArgsGetAnalysisList
• type ArgsGetServiceByID
• type ArgsGetServiceList
• type ArgsSetService
• type FieldsAnalysis
  • func GetAnalysisList(args *ArgsGetAnalysisList) (dataList []FieldsAnalysis, dataCount int64, err error)
• type FieldsService
  • func GetServiceByID(args *ArgsGetServiceByID) (data FieldsService, err error)
  • func GetServiceList(args *ArgsGetServiceList) (dataList []FieldsService, dataCount int64, err error)

Variables

var (

	//OpenSub 订阅服务
	OpenSub = false
	//WaitDBConnect 临时拦截设计
	// 刚启动服务，如没有及时连接到数据库，可能出现异常，所以需暂时性拦截请求，等待数据库连接成功后再处理
	WaitDBConnect = false
)

Functions

func Init

func Init()

Init 初始化

func SetService

func SetService(args *ArgsSetService) (err error)

SetService 设置Service

func SetServiceMarge

func SetServiceMarge(args *ArgsSetService, cb func(msg *nats.Msg, action string, id int64, mark string, data []byte)) (err error)

SetServiceMarge 融合设置Service 同时给予触发方法，自动构建sub订阅服务 注意，推送服务还需要自行触发

Types

type ArgsGetAnalysisList

type ArgsGetAnalysisList struct {
	//服务ID
	ServiceID int64 `json:"serviceID" check:"id"`
	//时间段
	BetweenAt CoreSQL2.ArgsTimeBetween `json:"betweenAt"`
}

ArgsGetAnalysisList 获取分析列表参数

type ArgsGetServiceByID

type ArgsGetServiceByID struct {
	//ID
	ID int64 `db:"id" json:"id" check:"id"`
}

ArgsGetServiceByID 获取Service数据包参数

type ArgsGetServiceList

type ArgsGetServiceList struct {
	//分页参数
	Pages CoreSQL2.ArgsPages `json:"pages"`
	//事件编码
	Code string `db:"code" json:"code" check:"des" min:"1" max:"300" empty:"true"`
	//是否删除
	IsRemove bool `json:"isRemove" check:"bool"`
	//搜索
	Search string `json:"search" check:"search" empty:"true"`
}

ArgsGetServiceList 获取服务列表参数

type ArgsSetService

type ArgsSetService struct {
	//过期时间
	ExpireAt time.Time `db:"expire_at" json:"expireAt"`
	//名称
	Name string `db:"name" json:"name" check:"des" min:"1" max:"300"`
	//描述
	Description string `db:"description" json:"description" check:"des" min:"1" max:"500" empty:"true"`
	//事件订阅方式
	// server 服务器订阅; client 客户端订阅; all 服务器和客户端都订阅
	EventSubType string `db:"event_sub_type" json:"eventSubType" check:"intThan0"`
	//事件编码
	Code string `db:"code" json:"code" check:"des" min:"1" max:"300"`
	//事件类型
	// nats - NATS事件
	EventType string `db:"event_type" json:"eventType" check:"intThan0"`
	//事件地址
	// nats - 触发的地址
	EventURL string `db:"event_url" json:"eventURL" check:"des" min:"1" max:"600"`
	//事件固定参数
	// nats - 事件附带的固定参数，如果为空则根据流程阶段事件触发填入
	// <<action>>:[new]:预设添加动作 - 固定的参数结构体，0代表参数名称；1代表参数类型和可使用值；2代表参数描述
	// 固定参数支持：<<action>>/<<id>>/<<mark>>/<<data>>
	// 固定参数的值类型支持string/int64/float64/bool/[]，其中[]代表枚举值，用/分割
	// data 较为特殊，默认为json结构体，也可以直接给与上述固定类型，将采用{}包裹，解析后与json完全一致
	// data整体支持： json/[]/string/int64/float64/bool
	// data描述结构1：<<data>>:值类型(非json):描述
	// data描述结构2：<<data>>:值类型(json):{}采用json描述默认值结构体:{"a": {"val_default": "默认值", "val_enum": [枚举值], "val_type": "值类型", "val_desc: "描述", "val_mod": "指向模块标识码，可以用于前端解析，如用户ID指向到用户选择组件"}}采用json描述
	// data的json内容可能采用单引号描述，如技术存在限制的端，请自行替换为双引号后解析
	// 如果固定参数没有指定，代表该参数不存在
	// 固定参数采用::;::分割
	// eg1: <<action>>:string:基础服务code::;::<<mark>>:string:订阅服务类型(sub/push)
	// eg2: <<action>>:string:基础服务code::;::<<mark>>:string:订阅服务类型(sub/push)::;::<<data>>:json:{"a": {"val_default": "new", "val_enum": ["new", "del"], "val_type": "[]", "val_desc: "描述"}, "c": {"val_default": 0", "val_enum": [], "val_type": "int", "val_desc: "描述"}}
	// eg3: <<action>>:string:基础服务code::;::<<mark>>:string:订阅服务类型(sub/push)::;::<<data>>:string:字符串用于XXX目标
	EventParams string `db:"event_params" json:"eventParams" check:"des" min:"1" max:"1000" empty:"true"`
}

ArgsSetService 设置Service参数

type FieldsAnalysis

type FieldsAnalysis struct {
	//ID
	ID int64 `db:"id" json:"id" check:"id"`
	//创建时间
	// 每小时创建一次
	CreateAt time.Time `db:"create_at" json:"createAt"`
	//服务ID
	ServiceID int64 `db:"service_id" json:"serviceID" check:"id"`
	//服务端发送消息次数
	SendCount int64 `db:"send_count" json:"sendCount" check:"intThan0"`
	//服务端接收次数
	ReceiveCount int64 `db:"receive_count" json:"receiveCount" check:"intThan0"`
}

FieldsAnalysis 服务统计

func GetAnalysisList

func GetAnalysisList(args *ArgsGetAnalysisList) (dataList []FieldsAnalysis, dataCount int64, err error)

GetAnalysisList 获取分析列表

type FieldsService

type FieldsService 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"`
	//过期时间
	ExpireAt time.Time `db:"expire_at" json:"expireAt"`
	//名称
	Name string `db:"name" json:"name" check:"des" min:"1" max:"300"`
	//描述
	Description string `db:"description" json:"description" check:"des" min:"1" max:"500" empty:"true"`
	//事件订阅方式
	// server 服务器订阅; client 客户端订阅; all 服务器和客户端都订阅
	EventSubType string `db:"event_sub_type" json:"eventSubType" check:"intThan0"`
	//事件编码
	Code string `db:"code" json:"code" check:"des" min:"1" max:"300"`
	//事件类型
	// nats - NATS事件
	EventType string `db:"event_type" json:"eventType" check:"intThan0"`
	//事件地址
	// nats - 触发的地址
	EventURL string `db:"event_url" json:"eventURL" check:"des" min:"1" max:"600"`
	//事件固定参数
	// nats - 事件附带的固定参数，如果为空则根据流程阶段事件触发填入
	EventParams string `db:"event_params" json:"eventParams" check:"des" min:"1" max:"1000" empty:"true"`
}

FieldsService 服务信息

func GetServiceByID

func GetServiceByID(args *ArgsGetServiceByID) (data FieldsService, err error)

GetServiceByID 获取Service数

func GetServiceList

func GetServiceList(args *ArgsGetServiceList) (dataList []FieldsService, dataCount int64, err error)

GetServiceList 获取服务列表