1

api/consts/option.go

@@ -98,3 +98,10 @@ const (
 	StreamerAuthApproval_OneOffVersion   = 0
 	StreamerAuthApproval_SeparateVersion = 1
 )
+
+const (
+	Notification_ObjType_AllStreamer        = 0
+	Notification_ObjType_AllUser            = 1
+	Notification_ObjType_AllStreamerAndUser = 2
+	Notification_ObjType_Customized         = 3
+)

api/proto/notification/proto/not_null_def_op.go

@@ -0,0 +1,20 @@
+package proto
+
+import (
+	"service/api/consts"
+	"service/bizcommon/util"
+	"service/library/validator"
+)
+
+func (p *OpCreateReq) ProvideNotNullValue() (params []*validator.JsonParam) {
+	params = make([]*validator.JsonParam, 0)
+
+	params = append(params, validator.NewInt64PtrParam("请确认通知接收人类型！", p.ObjType))
+	if util.DerefInt64(p.ObjType) == consts.Notification_ObjType_Customized {
+		params = append(params, validator.NewInt64SliceParam("请确认通知接收人mids！", p.ObjMids))
+	}
+	params = append(params, validator.NewInt64PtrParam("请确认消息类型！", p.NType))
+	params = append(params, validator.NewStringPtrParam("请确认消息内容！", p.Message))
+
+	return
+}

api/proto/notification/proto/notification_op.go

@@ -9,6 +9,8 @@ import (
 type OpCreateReq struct {
 	base.BaseRequest
 	*dbstruct.Notification
+	ObjType *int64  `json:"obj_type"` // 通知接收人类型
+	ObjMids []int64 `json:"obj_mids"` // 通知接收人mids
 }
 
 type OpCreateData struct {

app/mix/service/service.go

@@ -5021,14 +5021,6 @@ func (s *Service) OpCreateNotification(ctx *gin.Context, req *notificationproto.
 		return
 	}
 
-	// 加载进redis
-	_, err = redis.GetRedisClient().Incr(logic.GetNotificationCountIdForRedis(req.Notification.GetObjMid()))
-	if err != nil {
-		logger.Error("Redis Incr fail, req: %v, err: %v", util.ToJson(req), err)
-		ec = errcode.ErrCodeNotificationCountRedisCacheInvalid
-		return
-	}
-
 	return
 }