This commit is contained in:
苏尹岚
2020-12-30 18:03:10 +08:00
parent d3966a8e29
commit 786ac3f365

View File

@@ -678,7 +678,7 @@ func TransferMessageGroupMaster(ctx *jxcontext.Context, groupID int, userID stri
} }
func SendSysMessageSimple(content, toUserID string) (err error) { func SendSysMessageSimple(content, toUserID string) (err error) {
return SendSysMessage(nil, &model.ImMessageRecord{ return SendSysMessage(jxcontext.AdminCtx, &model.ImMessageRecord{
Content: sysMessageTitle + " " + content, Content: sysMessageTitle + " " + content,
ToUserID: toUserID, ToUserID: toUserID,
GroupID: model.SysGroupID, GroupID: model.SysGroupID,
@@ -692,11 +692,13 @@ func SendSysMessage(ctx *jxcontext.Context, imMessageRecord *model.ImMessageReco
userID = imMessageRecord.ToUserID userID = imMessageRecord.ToUserID
groupID = imMessageRecord.GroupID groupID = imMessageRecord.GroupID
) )
imMessageRecord = &model.ImMessageRecord{}
if groupID != model.SysGroupID { if groupID != model.SysGroupID {
return fmt.Errorf("只能给系统组发消息!") return fmt.Errorf("只能给系统组发消息!")
} }
dao.WrapAddIDCULEntity(imMessageRecord, ctx.GetUserName()) imMessageRecord.CreatedAt = time.Now()
imMessageRecord.LastOperator = ctx.GetUserName()
imMessageRecord.DeletedAt = utils.DefaultTimeValue
imMessageRecord.UpdatedAt = utils.DefaultTimeValue
err = dao.CreateEntity(db, imMessageRecord) err = dao.CreateEntity(db, imMessageRecord)
if userID == "" { if userID == "" {
//循环map客户端 //循环map客户端