MTP20_ACCESS/global/client.go

package global

import (
	"bytes"
	"encoding/json"
	"fmt"
	"sync"

	"github.com/mitchellh/mapstructure"
)

type LoginRedis struct {
	LoginID   string `json:"loginId" redis:"loginId"`     // 登陆账号
	UserID    string `json:"userId" redis:"userId"`       // 用户ID
	SessionID string `json:"sessionId" redis:"sessionId"` // 终端sid
	Token     string `json:"token" redis:"token"`         // 令牌
	Group     string `json:"group" redis:"group"`         // 终端分组
	Addr      string `json:"addr" redis:"addr"`           // 客户端地址信息 // FIXME: 由于本服务改用短连，所以每次提交请交请求可能会不一样，后期可判断是否在中间件中进行拦截
}

// FromMap Map to Struct
func (r *LoginRedis) FromMap(val map[string]interface{}) error {
	return mapstructure.Decode(val, r)
}

// ToMap Struct to Map
func (r *LoginRedis) ToMap() (val map[string]interface{}, err error) {
	if marshalContent, err := json.Marshal(r); err != nil {
		return nil, err
	} else {
		d := json.NewDecoder(bytes.NewReader(marshalContent))
		d.UseNumber() // 设置将float64转为一个number
		if err := d.Decode(&val); err != nil {
			fmt.Println(err)
		} else {
			for k, v := range val {
				val[k] = v
			}
		}
	}

	return
}

type Client struct {
	LoginRedis

	CurSerialNumber uint32 // 当前业务流水号
}

// MQPacket 与总线交互的数据体
type MQPacket struct {
	FunCode   uint32 // 功能码
	SessionId uint32 // 数据包的sid
	Data      []byte // 业务数据体
}

// AsyncTask 异步任务结构体
type AsyncTask struct {
	Packet       chan MQPacket // 总线数据处理通道
	SerialNumber uint32        // 通信流水号
	doClose      sync.Once     // 仅关闭通道一次
}

// Run 启动异步任务
func (r *AsyncTask) Run() (p *MQPacket, isTimeOut bool) {
	select {}

	return
}

// close 结束异步任务的方法
// func (r *AsyncTask) close() {
// 	r.doClose.Do(
// 		func() {
// 			close(r.C) // FIXME: - 注意这里是否可以close，后期处理
// 		}
// 	)
// }