aa

business/jxstore/event/event.go

@@ -467,3 +467,21 @@ func DeleteMessageRecord(ctx *jxcontext.Context) (err error) {
 	_, err = dao.ExecuteSQL(db, sql, sqlParams)
 	return err
 }
+
+func UpdateUserMessageGroupRead(ctx *jxcontext.Context, reads []*model.MessageGroupRead) (err error) {
+	var (
+		db     = dao.GetDB()
+		userID = ctx.GetUserID()
+	)
+	for _, v := range reads {
+		if messageReads, err := dao.GetMessageGroupRead(db, userID, v.GroupID); err == nil {
+			if len(messageReads) > 0 {
+				messageReads[0].UnReadCount += v.UnReadCount
+				dao.UpdateEntity(db, messageReads[0], "UnReadCount")
+			} else {
+
+			}
+		}
+	}
+	return err
+}