MessageCenter/entity/message.go

package entity

import (
	m "app.yhyue.com/moapp/jybase/mongodb"
	"app.yhyue.com/moapp/jybase/mysql"
	"database/sql"
	clientv3 "go.etcd.io/etcd/client/v3"
	"time"

	"github.com/go-xorm/xorm"
)

// 定义orm引擎
var Engine *xorm.Engine
var EtcdCli *clientv3.Client
var Mysql *mysql.Mysql
var MessageColumn []map[string]interface{}
var Mysql11 *sql.DB
var MQFW m.MongodbSim

var SurvivalTime int
var SaveConcurrencyChan chan int //  定义保存消息并发

type Message struct {
	Id            string    `xorm:"id" form:"id" json:"id"`
	AppId         string    `xorm:"appid" form:"appid" json:"appid"`
	ReceiveUserid string    `xorm:"receive_userid" form:"receive_userid" json:"receive_userid"` // 接收方用户id
	ReceiveName   string    `xorm:"receive_name" form:"receive_name" json:"receive_name"`
	SendUserid    string    `xorm:"send_userid" form:"send_userid" json:"send_userid"` // 消息id
	SendName      string    `xorm:"send_name" form:"send_name" json:"send_name"`
	CreateTime    time.Time `xorm:"createtime" form:"createtime" json:"createtime"` // 创建时间
	Title         string    `xorm:"title" form:"title" json:"title"`
	MsgType       int       `xorm:"msg_type" form:"msg_type" json:"msg_type"`
	Link          string    `xorm:"link" form:"link" json:"link"`
	CiteId        int       `xorm:"cite_id" form:"cite_id" json:"cite_id"`
	Content       string    `xorm:"content" form:"content" json:"content"`    // '内容
	IsRead        int       `xorm:"isRead" form:"isRead" json:"isRead"`       //  '0：未读  1：已读'
	Isdel         int       `xorm:"isdel" form:"isdel" json:"isdel"`          // 1：未删除  -1：已删除
	MsgLogId      int64     `xorm:"msgLogId" form:"msgLogId" json:"msgLogId"` //记录表id
}

type Conversation struct {
	Id          string    `xorm:"id" form:"id" json:"id"`
	AppId       string    `xorm:"appid" form:"appid" json:"appid"`
	SecretKey   string    `xorm:"secret_key" form:"secret_key" json:"secret_key"`
	UserId      string    `xorm:"user_id" form:"user_id" json:"user_id"`
	ReceiveId   string    `xorm:"receive_id" form:"receive_id" json:"receive_id"`
	ReceiveName string    `xorm:"receive_name" form:"receive_name" json:"receive_name"`
	SendId      string    `xorm:"send_id" form:"send_id" json:"send_id"`
	SendName    string    `xorm:"send_name" form:"send_name" json:"send_name"`
	Sort        int       `xorm:"sort" form:"sort" json:"sort"`
	CreateTime  time.Time `xorm:"createtime" form:"createtime" json:"createtime"` // 创建时间
}