event

type ActorBase struct {
	EventStepNum int //当前步骤
}

type DataDBModel interface {
}

type HTTPcall func(et JsonMap, w http.ResponseWriter)

type IActor interface {
	//当前要运行的步骤
	GetStepNum() int
	//运行步骤成功就进入下一步，失败就开始执行回滚，成功失败内部处理
	RunNext()
	//是否已完成
	IsEnd() bool
	//拿到要返回用的JSON对象，或不用这个直接推信息
	GetResult() JsonMap
}

type IMemoryModel interface {
	//放入管理器的KEY
	GetKey() string
	//确认加入到了管理器中后，用来开启，这个数据的一些自动任务
	//如果用这个方法本自来启动任务，就可以用对应的这些方法来关闭自动任务
	RunAutoEvents()
	//时间到时，运行的方法,如果发出了委托，就返回true
	UnloadRun() bool
	//当服务关闭时，运行的方法，这个时候可能就不清内存了，只是关一些自动任务
	DoneRun()
}

type IMsgEvent interface {
	GetAction() int    //消息号
	GetActionKey() int //消息序号
	GetMemberID() int  //用户ID
	GetHash() string   //发回给用户信息用的钥匙
}

type INsqdMessage interface {
	GetSendID() int
	GetSendSID() string
	SetSendSID(sid string)
	GetActionID() int
	GetData() interface{}
	GetTopic() string
}

type ISqlDataModel interface {
	//用户主键,一般一个用户需要一个专门的协程来负责对他进行保存操作
	//这个ID就是用来确认这件事的
	GetKeyID() int
	//数据表,如果你的表放入时，不是马上保存的，那么后续可以用这个KEY来进行覆盖，
	//这样就可以实现多次修改一次保存的功能
	GetDataKey() string
	//保存时间，每次过来的时候，需要告诉我，你需要最长的保存时间，
	//如果下次保存时间比你的大，那就用你的这个时间 替换掉
	GetUpTime() time.Duration
	//这是被调用的方法
	UpDataSave(conndb model.IConnDB) error
}

type IStructSql interface {
	//表名
	GetTableName() string
	//保存参数列表
	ParmArray() []interface{}
	//查询的参数列表
	QueryArray() []interface{}
}

type JsonArray []interface{}

type JsonMap map[string]interface{}

type LogicModel interface {
	KeyID() string //所在协程的KEY
	Run()          //调用方法
}

type MemoryMsg struct {
	IMemoryModel
	CmdType int //消息命令类型，1：添加；2：删除；
}

type NsqdHander func(msg INsqdMessage)

type NsqdMessage struct {
	SendID   int         //发信息用户ID
	SendSID  string      //发信息服务器（回复用的信息）
	ActionID int         //消息号
	Data     interface{} //消息数据
	Topic    string      //目标
}

type SqlDataModel struct {
	KeyID       int           //用户主键
	DataKey     string        //数据表
	UpTime      time.Duration //保存时间
	SaveFun     UpDataSave    //保存方法
	DataDBModel DataDBModel   //要保存的东西
}

type SqlDataStructModel struct {
	KeyID       int           //用户主键
	DataKey     string        //数据表
	UpTime      time.Duration //保存时间
	DataDBModel IStructSql    //要保存的东西
}

type UpDataSave func(conndb model.IConnDB, datamd DataDBModel) error

type WebSocketCall func(et JsonMap, wsmd *WebSocketModel, runobj *threads.ThreadGo)

type WebSocketClose func(wsmd *WebSocketModel)

type WebSocketModel struct {
	*websocket.Conn
	CloseFun WebSocketClose //关闭连接时的方法
	ConInfo  interface{}    //自定义的连接信息，给上层逻辑使用
	KeyID    int            //用来标记的ID
}