feat: 添加deleteItemKq (#63)

CloudStriver · Feb 17, 2024 · aa8e10a · aa8e10a
1 parent f763466
commit aa8e10a
Show file tree

Hide file tree

Showing 12 changed files with 93 additions and 202 deletions.
diff --git a/biz/application/service/auth.go b/biz/application/service/auth.go
@@ -13,9 +13,11 @@ import (
 	"github.com/CloudStriver/cloudmind-core-api/biz/infrastructure/rpc/cloudmind_trade"
 	"github.com/CloudStriver/cloudmind-core-api/biz/infrastructure/utils/oauth"
 	"github.com/CloudStriver/cloudmind-mq/app/util/message"
+	"github.com/CloudStriver/go-pkg/utils/pconvertor"
 	"github.com/CloudStriver/service-idl-gen-go/kitex_gen/cloudmind/content"
 	"github.com/CloudStriver/service-idl-gen-go/kitex_gen/cloudmind/sts"
 	"github.com/CloudStriver/service-idl-gen-go/kitex_gen/cloudmind/trade"
+	"github.com/bytedance/sonic"
 	"github.com/golang-jwt/jwt/v4"
 	"github.com/google/wire"
 	"github.com/samber/lo"
@@ -46,7 +48,7 @@ type AuthService struct {
 	CloudMindContent cloudmind_content.ICloudMindContent
 	CloudMindSts     cloudmind_sts.ICloudMindSts
 	CloudMindTrade   cloudmind_trade.ICloudMindTrade
-	CreateItemsKq    *kq.CreateItemsKq
+	CreateItemKq     *kq.CreateItemKq
 
 	Redis *redis.Redis
 }
@@ -224,12 +226,11 @@ func (s *AuthService) Register(ctx context.Context, req *core_api.RegisterReq) (
 	}
 	resp.UserId = createAuthResp.UserId
 
-	if err = s.CreateItemsKq.Add(createAuthResp.UserId, &message.CreateItemsMessage{
-		Item: &content.Item{
-			ItemId:   createAuthResp.UserId,
-			Category: core_api.Category_name[int32(core_api.Category_UserCategory)],
-		},
-	}); err != nil {
+	data, _ := sonic.Marshal(&message.CreateItemMessage{
+		ItemId:   createAuthResp.UserId,
+		Category: core_api.Category_name[int32(core_api.Category_UserCategory)],
+	})
+	if err = s.CreateItemKq.Push(pconvertor.Bytes2String(data)); err != nil {
 		return resp, err
 	}
 

diff --git a/biz/application/service/post.go b/biz/application/service/post.go
@@ -11,9 +11,11 @@ import (
 	"github.com/CloudStriver/cloudmind-core-api/biz/infrastructure/rpc/cloudmind_content"
 	"github.com/CloudStriver/cloudmind-core-api/biz/infrastructure/rpc/platform_relation"
 	"github.com/CloudStriver/cloudmind-mq/app/util/message"
+	"github.com/CloudStriver/go-pkg/utils/pconvertor"
 	"github.com/CloudStriver/service-idl-gen-go/kitex_gen/basic"
 	"github.com/CloudStriver/service-idl-gen-go/kitex_gen/cloudmind/content"
 	"github.com/CloudStriver/service-idl-gen-go/kitex_gen/platform/relation"
+	"github.com/bytedance/sonic"
 	"github.com/google/wire"
 	"github.com/samber/lo"
 	"github.com/zeromicro/go-zero/core/mr"
@@ -37,7 +39,7 @@ type PostService struct {
 	CloudMindContent  cloudmind_content.ICloudMindContent
 	PostDomainService service.IPostDomainService
 	PLatFromRelation  platform_relation.IPlatFormRelation
-	CreateItemsKq     *kq.CreateItemsKq
+	CreateItemKq      *kq.CreateItemKq
 	UpdateItemKq      *kq.UpdateItemKq
 	DeleteItemKq      *kq.DeleteItemKq
 }
@@ -60,14 +62,13 @@ func (s *PostService) CreatePost(ctx context.Context, req *core_api.CreatePostRe
 		return resp, err
 	}
 
-	if err = s.CreateItemsKq.Add(userData.UserId, &message.CreateItemsMessage{
-		Item: &content.Item{
-			ItemId:   createPostResp.PostId,
-			IsHidden: req.Status == int64(core_api.PostStatus_PrivatePostStatus),
-			Labels:   req.Tags,
-			Category: core_api.Category_name[int32(core_api.Category_PostCategory)],
-		},
-	}); err != nil {
+	data, _ := sonic.Marshal(&message.CreateItemMessage{
+		ItemId:   createPostResp.PostId,
+		IsHidden: req.Status == int64(core_api.PostStatus_PrivatePostStatus),
+		Labels:   req.Tags,
+		Category: core_api.Category_name[int32(core_api.Category_PostCategory)],
+	})
+	if err = s.CreateItemKq.Push(pconvertor.Bytes2String(data)); err != nil {
 		return resp, err
 	}
 	return resp, nil
@@ -99,11 +100,13 @@ func (s *PostService) UpdatePost(ctx context.Context, req *core_api.UpdatePostRe
 		if req.Status != 0 {
 			isHidden = lo.ToPtr(req.Status == int64(core_api.PostStatus_PrivatePostStatus))
 		}
-		if err = s.UpdateItemKq.Add(userData.UserId, &message.UpdateItemMessage{
+
+		data, _ := sonic.Marshal(&message.UpdateItemMessage{
 			ItemId:   req.PostId,
 			IsHidden: isHidden,
 			Labels:   req.Tags,
-		}); err != nil {
+		})
+		if err = s.UpdateItemKq.Push(pconvertor.Bytes2String(data)); err != nil {
 			return resp, err
 		}
 	}
@@ -127,9 +130,10 @@ func (s *PostService) DeletePost(ctx context.Context, req *core_api.DeletePostRe
 		return resp, err
 	}
 
-	if err = s.DeleteItemKq.Add(userData.UserId, &message.DeleteItemMessage{
+	data, _ := sonic.Marshal(&message.DeleteItemMessage{
 		ItemId: req.PostId,
-	}); err != nil {
+	})
+	if err = s.DeleteItemKq.Push(pconvertor.Bytes2String(data)); err != nil {
 		return resp, err
 	}
 

diff --git a/biz/application/service/product.go b/biz/application/service/product.go
@@ -7,8 +7,10 @@ import (
 	"github.com/CloudStriver/cloudmind-core-api/biz/infrastructure/kq"
 	"github.com/CloudStriver/cloudmind-core-api/biz/infrastructure/rpc/cloudmind_trade"
 	"github.com/CloudStriver/cloudmind-mq/app/util/message"
+	"github.com/CloudStriver/go-pkg/utils/pconvertor"
 	"github.com/CloudStriver/service-idl-gen-go/kitex_gen/basic"
 	"github.com/CloudStriver/service-idl-gen-go/kitex_gen/cloudmind/trade"
+	"github.com/bytedance/sonic"
 
 	"github.com/CloudStriver/cloudmind-core-api/biz/application/dto/cloudmind/core_api"
 	"github.com/CloudStriver/cloudmind-core-api/biz/infrastructure/config"
@@ -38,7 +40,7 @@ type ProductService struct {
 	CloudMindContent     cloudmind_content.ICloudMindContent
 	ProductDomainService service.IProductDomainService
 	CloudMindTrade       cloudmind_trade.ICloudMindTrade
-	CreateItemsKq        *kq.CreateItemsKq
+	CreateItemKq         *kq.CreateItemKq
 	UpdateItemKq         *kq.UpdateItemKq
 	DeleteItemKq         *kq.DeleteItemKq
 }
@@ -106,14 +108,13 @@ func (s *ProductService) CreateProduct(ctx context.Context, req *core_api.Create
 		return resp, err
 	}
 
-	if err = s.CreateItemsKq.Add(user.UserId, &message.CreateItemsMessage{
-		Item: &content.Item{
-			ItemId:   createProductResp.ProductId,
-			IsHidden: req.Status == int64(core_api.ProductStatus_PrivateProductStatus),
-			Labels:   req.Tags,
-			Category: core_api.Category_name[int32(core_api.Category_ProductCategory)],
-		},
-	}); err != nil {
+	data, _ := sonic.Marshal(&message.CreateItemMessage{
+		ItemId:   createProductResp.ProductId,
+		IsHidden: req.Status == int64(core_api.ProductStatus_PrivateProductStatus),
+		Labels:   req.Tags,
+		Category: core_api.Category_name[int32(core_api.Category_ProductCategory)],
+	})
+	if err = s.CreateItemKq.Push(pconvertor.Bytes2String(data)); err != nil {
 		return resp, err
 	}
 	return resp, nil
@@ -200,11 +201,13 @@ func (s *ProductService) UpdateProduct(ctx context.Context, req *core_api.Update
 		if req.Status != 0 {
 			isHidden = lo.ToPtr(req.Status == int64(core_api.ProductStatus_PrivateProductStatus))
 		}
-		if err = s.UpdateItemKq.Add(user.UserId, &message.UpdateItemMessage{
+
+		data, _ := sonic.Marshal(&message.UpdateItemMessage{
 			ItemId:   req.ProductId,
 			IsHidden: isHidden,
 			Labels:   req.Tags,
-		}); err != nil {
+		})
+		if err = s.UpdateItemKq.Push(pconvertor.Bytes2String(data)); err != nil {
 			return resp, err
 		}
 	}
@@ -228,9 +231,10 @@ func (s *ProductService) DeleteProduct(ctx context.Context, req *core_api.Delete
 		return resp, err
 	}
 
-	if err = s.DeleteItemKq.Add(userData.UserId, &message.DeleteItemMessage{
+	data, _ := sonic.Marshal(&message.DeleteItemMessage{
 		ItemId: req.ProductId,
-	}); err != nil {
+	})
+	if err = s.DeleteItemKq.Push(pconvertor.Bytes2String(data)); err != nil {
 		return resp, err
 	}
 

diff --git a/biz/application/service/recommend.go b/biz/application/service/recommend.go
@@ -10,8 +10,10 @@ import (
 	"github.com/CloudStriver/cloudmind-core-api/biz/infrastructure/kq"
 	"github.com/CloudStriver/cloudmind-core-api/biz/infrastructure/rpc/cloudmind_content"
 	"github.com/CloudStriver/cloudmind-mq/app/util/message"
+	"github.com/CloudStriver/go-pkg/utils/pconvertor"
 	"github.com/CloudStriver/service-idl-gen-go/kitex_gen/basic"
 	"github.com/CloudStriver/service-idl-gen-go/kitex_gen/cloudmind/content"
+	"github.com/bytedance/sonic"
 	"github.com/google/wire"
 	"github.com/samber/lo"
 	"github.com/zeromicro/go-zero/core/mr"
@@ -34,7 +36,7 @@ type RecommendService struct {
 	Config            *config.Config
 	CloudMindContent  cloudmind_content.ICloudMindContent
 	PostDomainService service.IPostDomainService
-	CreateFeedBacks   *kq.CreateFeedBacksKq
+	CreateFeedBackKq  *kq.CreateFeedBackKq
 	UserDomainService service.IUserDomainService
 }
 
@@ -85,13 +87,12 @@ func (s *RecommendService) GetPopularRecommend(ctx context.Context, req *core_ap
 
 func (s *RecommendService) CreateFeedBack(ctx context.Context, req *core_api.CreateFeedBackReq) (resp *core_api.CreateFeedBackResp, err error) {
 	user := adaptor.ExtractUserMeta(ctx)
-	if err = s.CreateFeedBacks.Add(req.ItemId, &message.CreateFeedBacksMessage{
-		FeedBack: &content.FeedBack{
-			FeedbackType: req.FeedbackType,
-			UserId:       user.GetUserId(),
-			ItemId:       req.ItemId,
-		},
-	}); err != nil {
+	data, _ := sonic.Marshal(&message.CreateFeedBackMessage{
+		FeedbackType: req.FeedbackType,
+		UserId:       user.GetUserId(),
+		ItemId:       req.ItemId,
+	})
+	if err = s.CreateFeedBackKq.Push(pconvertor.Bytes2String(data)); err != nil {
 		return resp, err
 	}
 	return resp, nil

diff --git a/biz/application/service/relation.go b/biz/application/service/relation.go
@@ -40,7 +40,7 @@ type RelationService struct {
 	CloudMindContent     cloudmind_content.ICloudMindContent
 	PostDomainService    service.IPostDomainService
 	CreateNotificationKq *kq.CreateNotificationsKq
-	CreateFeedBacksKq    *kq.CreateFeedBacksKq
+	CreateFeedBackKq     *kq.CreateFeedBackKq
 }
 
 func (s *RelationService) GetFromRelations(ctx context.Context, req *core_api.GetFromRelationsReq) (resp *core_api.GetFromRelationsResp, err error) {
@@ -259,7 +259,7 @@ func (s *RelationService) CreateRelation(ctx context.Context, req *core_api.Crea
 		FromName: userinfo.Name,
 		ToName:   toName,
 	})
-	data, _ := sonic.Marshal(&message.CreateNotificationsMessage{
+	data, _ := sonic.Marshal(&message.CreateNotificationMessage{
 		TargetUserId:    userId,
 		SourceUserId:    user.UserId,
 		SourceContentId: req.ToId,
@@ -271,13 +271,12 @@ func (s *RelationService) CreateRelation(ctx context.Context, req *core_api.Crea
 		return resp, err
 	}
 
-	if err = s.CreateFeedBacksKq.Add(user.UserId, &message.CreateFeedBacksMessage{
-		FeedBack: &content.FeedBack{
-			FeedbackType: core_api.RelationType_name[int32(req.RelationType)],
-			UserId:       user.UserId,
-			ItemId:       req.ToId,
-		},
-	}); err != nil {
+	data, _ = sonic.Marshal(&message.CreateFeedBackMessage{
+		FeedbackType: core_api.RelationType_name[int32(req.RelationType)],
+		UserId:       user.UserId,
+		ItemId:       req.ToId,
+	})
+	if err = s.CreateFeedBackKq.Push(pconvertor.Bytes2String(data)); err != nil {
 		return resp, err
 	}
 	return resp, nil

diff --git a/biz/application/service/user.go b/biz/application/service/user.go
@@ -13,9 +13,11 @@ import (
 	"github.com/CloudStriver/cloudmind-core-api/biz/infrastructure/rpc/cloudmind_sts"
 	"github.com/CloudStriver/cloudmind-core-api/biz/infrastructure/rpc/cloudmind_trade"
 	"github.com/CloudStriver/cloudmind-mq/app/util/message"
+	"github.com/CloudStriver/go-pkg/utils/pconvertor"
 	"github.com/CloudStriver/service-idl-gen-go/kitex_gen/cloudmind/content"
 	"github.com/CloudStriver/service-idl-gen-go/kitex_gen/cloudmind/sts"
 	"github.com/CloudStriver/service-idl-gen-go/kitex_gen/cloudmind/trade"
+	"github.com/bytedance/sonic"
 	"github.com/google/wire"
 	"github.com/samber/lo"
 	"github.com/zeromicro/go-zero/core/mr"
@@ -102,10 +104,11 @@ func (s *UserService) UpdateUser(ctx context.Context, req *core_api.UpdateUserRe
 		return resp, err
 	}
 	if len(req.Labels) != 0 {
-		if err = s.UpdateItemKq.Add(userData.UserId, &message.UpdateItemMessage{
+		data, _ := sonic.Marshal(&message.UpdateItemMessage{
 			ItemId: userData.UserId,
 			Labels: req.Labels,
-		}); err != nil {
+		})
+		if err = s.UpdateItemKq.Push(pconvertor.Bytes2String(data)); err != nil {
 			return resp, err
 		}
 	}
@@ -188,7 +191,6 @@ func (s *UserService) SearchUser(ctx context.Context, req *core_api.SearchUserRe
 	resp.Users = lo.Map[*content.User, *core_api.User](users.Users, func(user *content.User, _ int) *core_api.User {
 		return convertor.UserDetailToUser(user)
 	})
-	resp.Total = users.Total
 	resp.LastToken = users.LastToken
 	return resp, nil
 }
diff --git a/biz/infrastructure/config/config.go b/biz/infrastructure/config/config.go
@@ -38,8 +38,8 @@ type Config struct {
 	Redis                 redis.RedisConf
 	CreateNotificationsKq KqConfig
 	UpdateNotificationsKq KqConfig
-	CreateItemsKq         KqConfig
-	CreateFeedBacksKq     KqConfig
+	CreateItemKq          KqConfig
+	CreateFeedBackKq      KqConfig
 	UpdateItemKq          KqConfig
 	DeleteItemKq          KqConfig
 	BaseUrl               string