This commit is contained in:
parent
3f10ab9330
commit
ae74496934
|
|
@ -239,8 +239,12 @@ const (
|
|||
COLSingleDistributeHis = "single_distribute_his"
|
||||
COLSingleDistributeLock = "single_distribute_lock"
|
||||
|
||||
DBNotification = "notification"
|
||||
COLNotification = "notification"
|
||||
DBNotification = "notification"
|
||||
COLNotification = "notification"
|
||||
COLNotifReceive = "notif_receive"
|
||||
COLNotifBcst = "notif_bcst"
|
||||
COLNotifBcstVers = "notif_bcst_vers"
|
||||
COLNotifBcstReceiveVers = "notif_bcst_receive_vers"
|
||||
|
||||
DBRavenIQTest = "Raven_IQ_test"
|
||||
COLRavenIQTest = "Raven_IQ_test"
|
||||
|
|
@ -625,12 +629,32 @@ func (m *Mongo) getColSingleDistributeLock() *qmgo.Collection {
|
|||
return m.clientMix.Database(DBSingleDistributeHis).Collection(COLSingleDistributeLock)
|
||||
}
|
||||
|
||||
// 系统通知表表
|
||||
// 系统通知表
|
||||
func (m *Mongo) getColNotification() *qmgo.Collection {
|
||||
return m.clientMix.Database(DBNotification).Collection(COLNotification)
|
||||
}
|
||||
|
||||
// 瑞文智商测试表表
|
||||
// 系统通知接收表
|
||||
func (m *Mongo) getColNotifReceive() *qmgo.Collection {
|
||||
return m.clientMix.Database(DBNotification).Collection(COLNotifReceive)
|
||||
}
|
||||
|
||||
// 系统通知广播表
|
||||
func (m *Mongo) getColNotifBcst() *qmgo.Collection {
|
||||
return m.clientMix.Database(DBNotification).Collection(COLNotifBcst)
|
||||
}
|
||||
|
||||
// 系统通知广播版本号表
|
||||
func (m *Mongo) getColNotifBcstVers() *qmgo.Collection {
|
||||
return m.clientMix.Database(DBNotification).Collection(COLNotifBcstVers)
|
||||
}
|
||||
|
||||
// 系统通知广播接收版本号表
|
||||
func (m *Mongo) getColNotifBcstReceiveVers() *qmgo.Collection {
|
||||
return m.clientMix.Database(DBNotification).Collection(COLNotifBcstReceiveVers)
|
||||
}
|
||||
|
||||
// 瑞文智商测试表
|
||||
func (m *Mongo) getColRavenIQTest() *qmgo.Collection {
|
||||
return m.clientMix.Database(DBRavenIQTest).Collection(COLRavenIQTest)
|
||||
}
|
||||
|
|
@ -6271,6 +6295,32 @@ func (m *Mongo) UpdateNotificationByIds(ctx *gin.Context, notification *dbstruct
|
|||
return err
|
||||
}
|
||||
|
||||
// 通知广播版本号表
|
||||
func (m *Mongo) GetAndUpdateNotifBcstVersSeq(ctx *gin.Context, objType int64) (vers *dbstruct.NotifBcstVers, err error) {
|
||||
col := m.getColNotifBcstVers()
|
||||
|
||||
change := qmgo.Change{
|
||||
Update: qmgo.M{"$inc": qmgo.M{"vers": 1}},
|
||||
Upsert: true,
|
||||
ReturnNew: false,
|
||||
}
|
||||
|
||||
id := ""
|
||||
if objType == consts.Notification_ObjType_AllStreamer {
|
||||
id = "all_streamer"
|
||||
} else if objType == consts.Notification_ObjType_AllUser {
|
||||
id = "all_user"
|
||||
}
|
||||
|
||||
versInstance := dbstruct.NotifBcstVers{}
|
||||
if err = col.Find(ctx, qmgo.M{"_id": id}).Apply(change, &versInstance); err != nil {
|
||||
logger.Error("change error : %v", err)
|
||||
return
|
||||
}
|
||||
|
||||
return &versInstance, err
|
||||
}
|
||||
|
||||
// 瑞文智商测试表相关
|
||||
func (m *Mongo) CreateRavenIQTest(ctx *gin.Context, Raven_IQ_test *dbstruct.RavenIQTest) error {
|
||||
col := m.getColRavenIQTest()
|
||||
|
|
|
|||
|
|
@ -3,7 +3,6 @@ package dbstruct
|
|||
type Notification struct {
|
||||
Id *int64 `json:"id" bson:"_id"` // 系统通知表id
|
||||
SubMid *int64 `json:"sub_mid" bson:"sub_mid"` // 通知发送人mid
|
||||
ObjMid *int64 `json:"obj_mid" bson:"obj_mid"` // 通知接收人mid
|
||||
NType *int64 `json:"n_type" bson:"n_type"` // 消息类型
|
||||
NDesc *string `json:"n_desc" bson:"n_desc"` // 消息描述
|
||||
Message *string `json:"message" bson:"message"` // 消息内容
|
||||
|
|
@ -13,15 +12,36 @@ type Notification struct {
|
|||
Params *string `json:"params" bson:"params"` // 参数
|
||||
PushTime *int64 `json:"push_time" bson:"push_time"` // 推送时间
|
||||
Status *int64 `json:"status" bson:"status"` // 推送状态
|
||||
IsRead *int64 `json:"is_read" bson:"is_read"` // 是否已读
|
||||
Ct *int64 `json:"ct" bson:"ct"` // 创建时间
|
||||
Ut *int64 `json:"ut" bson:"ut"` // 更新时间
|
||||
DelFlag *int64 `json:"del_flag" bson:"del_flag"` // 删除标记
|
||||
}
|
||||
|
||||
func (p *Notification) GetObjMid() int64 {
|
||||
if p != nil && p.ObjMid != nil {
|
||||
return *p.ObjMid
|
||||
}
|
||||
return 0
|
||||
type NotifBcst struct {
|
||||
Id int64 `json:"id" bson:"_id"` // 通知广播表id
|
||||
Nids []int64 `json:"nids" bson:"nids"` // 系统通知表ids
|
||||
Vers int64 `json:"vers" bson:"vers"` // 通知广播表版本号
|
||||
ObjType int64 `json:"obj_type" bson:"obj_type"` // 通知接收人类型，0-所有主播，1-所有个人
|
||||
Ct int64 `json:"ct" bson:"ct"` // 创建时间
|
||||
Ut int64 `json:"ut" bson:"ut"` // 更新时间
|
||||
DelFlag int64 `json:"del_flag" bson:"del_flag"` // 删除标记
|
||||
}
|
||||
|
||||
type NotifBcstVers struct {
|
||||
Vers int64 `json:"vers" bson:"vers"` // 通知广播表版本号
|
||||
}
|
||||
|
||||
type NotifBcstReceiveVers struct {
|
||||
Id int64 `json:"id" bson:"_id"` // 通知广播接收表id(mid)
|
||||
Vers int64 `json:"vers" bson:"vers"` // 通知广播表版本号
|
||||
}
|
||||
|
||||
type NotifReceive struct {
|
||||
Id int64 `json:"id" bson:"_id"` // 通知接收表id
|
||||
ObjMid int64 `json:"obj_mid" bson:"obj_mid"` // 通知接收人mid
|
||||
Nid int64 `json:"nid" bson:"nid"` // 系统通知表id
|
||||
IsRead int64 `json:"is_read" bson:"is_read"` // 是否已读
|
||||
Ct int64 `json:"ct" bson:"ct"` // 创建时间
|
||||
Ut int64 `json:"ut" bson:"ut"` // 更新时间
|
||||
DelFlag int64 `json:"del_flag" bson:"del_flag"` // 删除标记
|
||||
}
|
||||
|
|
|
|||
Loading…
Reference in New Issue