MessageCenter/entity/message.go

package entity

import (
	"app.yhyue.com/moapp/jybase/mail"
	m "app.yhyue.com/moapp/jybase/mongodb"
	"app.yhyue.com/moapp/jybase/mysql"
	"bp.jydev.jianyu360.cn/BaseService/fileCenter/rpc/filecenter"
	"github.com/ClickHouse/clickhouse-go/v2/lib/driver"
	"time"

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

// 定义orm引擎
var Engine *xorm.Engine
var Mysql *mysql.Mysql
var BaseMysql *mysql.Mysql
var BiService *mysql.Mysql
var JyBi *mysql.Mysql
var MessageColumn []map[string]interface{}
var MQFW m.MongodbSim
var Bidding m.MongodbSim
var GmailAuth []*mail.GmailAuth
var SurvivalTime int
var RollingTiming int64
var SaveConcurrencyChan chan int //  定义保存消息并发
var ClassSearchMap map[int64][]MsgClass
var ClassMap map[int64]MsgClass
var ClickhouseConn driver.Conn
var (
	OssBucketName string
	OssUrl        string
	FileCenterRpc filecenter.FileCenter
)

type MsgClass struct {
	MsgType int64  `json:"msgType"`
	Name    string `json:"name"`
	Img     string `json:"img"`
}
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"` // 创建时间
}