chore

xh-polaris · Dec 9, 2023 · c09b3a4 · c09b3a4
1 parent 9bb35c2
commit c09b3a4
Show file tree

Hide file tree

Showing 6 changed files with 0 additions and 94 deletions.
diff --git a/biz/application/service/cat.go b/biz/application/service/cat.go
@@ -3,8 +3,6 @@ package service
 import (
 	"context"
 
-	"github.com/apache/rocketmq-client-go/v2"
-
 	"github.com/xh-polaris/meowchat-content/biz/infrastructure/consts"
 	catmapper "github.com/xh-polaris/meowchat-content/biz/infrastructure/mapper/cat"
 
@@ -26,7 +24,6 @@ type ICatService interface {
 type CatService struct {
 	CatMongoMapper catmapper.IMongoMapper
 	CatEsMapper    catmapper.IEsMapper
-	MqProducer     rocketmq.Producer
 }
 
 var CatSet = wire.NewSet(
@@ -39,9 +36,6 @@ func (s *CatService) SearchCat(ctx context.Context, req *content.SearchCatReq) (
 	if err != nil {
 		return nil, err
 	}
-	if err != nil {
-		return nil, err
-	}
 	var cats []*content.Cat
 	for _, val := range data {
 		cat := &content.Cat{}

diff --git a/biz/application/service/image.go b/biz/application/service/image.go
@@ -3,8 +3,6 @@ package service
 import (
 	"context"
 
-	"github.com/apache/rocketmq-client-go/v2"
-
 	imagemapper "github.com/xh-polaris/meowchat-content/biz/infrastructure/mapper/image"
 
 	"github.com/google/wire"
@@ -19,7 +17,6 @@ type IImageService interface {
 
 type ImageService struct {
 	ImageModel imagemapper.IMongoMapper
-	MqProducer rocketmq.Producer
 }
 
 var ImageSet = wire.NewSet(

diff --git a/biz/application/service/moment.go b/biz/application/service/moment.go
@@ -5,9 +5,6 @@ import (
 	"strconv"
 	"time"
 
-	"github.com/apache/rocketmq-client-go/v2"
-	mqprimitive "github.com/apache/rocketmq-client-go/v2/primitive"
-	"github.com/bytedance/sonic"
 	"github.com/google/wire"
 	"github.com/samber/lo"
 	"github.com/xh-polaris/gopkg/pagination/esp"
@@ -39,7 +36,6 @@ type MomentService struct {
 	MomentEsMapper    moment.IEsMapper
 	ImageMapper       image.IMongoMapper
 	Redis             *redis.Redis
-	MqProducer        rocketmq.Producer
 }
 
 var MomentSet = wire.NewSet(
@@ -146,14 +142,6 @@ func (s *MomentService) CreateMoment(ctx context.Context, req *content.CreateMom
 
 	resp.MomentId = data.ID.Hex()
 
-	//发送使用url信息
-	//var urls []url.URL
-	//for _, u := range m.Photos {
-	//	sendUrl, _ := url.Parse(u)
-	//	urls = append(urls, *sendUrl)
-	//}
-	//go s.SendDelayMessage(urls)
-
 	//小鱼干奖励
 	t, err := s.Redis.GetCtx(ctx, "contentTimes"+m.UserId)
 	if err != nil {
@@ -235,15 +223,6 @@ func (s *MomentService) UpdateMoment(ctx context.Context, req *content.UpdateMom
 	if err != nil {
 		return nil, err
 	}
-
-	//发送使用url信息
-	//var urls []url.URL
-	//for _, u := range m.Photos {
-	//	sendUrl, _ := url.Parse(u)
-	//	urls = append(urls, *sendUrl)
-	//}
-	//go s.SendDelayMessage(urls)
-
 	return &content.UpdateMomentResp{}, nil
 }
 
@@ -254,21 +233,3 @@ func (s *MomentService) DeleteMoment(ctx context.Context, req *content.DeleteMom
 	}
 	return &content.DeleteMomentResp{}, nil
 }
-
-func (s *MomentService) SendDelayMessage(message interface{}) {
-	json, _ := sonic.Marshal(message)
-	msg := &mqprimitive.Message{
-		Topic: "sts_used_url",
-		Body:  json,
-	}
-
-	res, err := s.MqProducer.SendSync(context.Background(), msg)
-	if err != nil || res.Status != mqprimitive.SendOK {
-		for i := 0; i < 2; i++ {
-			res, err := s.MqProducer.SendSync(context.Background(), msg)
-			if err == nil && res.Status == mqprimitive.SendOK {
-				break
-			}
-		}
-	}
-}
diff --git a/biz/application/service/plan.go b/biz/application/service/plan.go
@@ -4,7 +4,6 @@ import (
 	"context"
 	"time"
 
-	"github.com/apache/rocketmq-client-go/v2"
 	"github.com/google/wire"
 	"github.com/xh-polaris/gopkg/pagination/esp"
 	"github.com/xh-polaris/gopkg/pagination/mongop"
@@ -41,7 +40,6 @@ type PlanService struct {
 	PlanEsMapper      plan.IEsMapper
 	DonateMongoMapper donate.IMongoMapper
 	FishMongoMapper   fish.IMongoMapper
-	MqProducer        rocketmq.Producer
 }
 
 var PlanSet = wire.NewSet(

diff --git a/biz/application/service/post.go b/biz/application/service/post.go
@@ -5,9 +5,6 @@ import (
 	"strconv"
 	"time"
 
-	"github.com/apache/rocketmq-client-go/v2"
-	mqprimitive "github.com/apache/rocketmq-client-go/v2/primitive"
-	"github.com/bytedance/sonic"
 	"github.com/google/wire"
 	"github.com/xh-polaris/gopkg/pagination/esp"
 	"github.com/xh-polaris/gopkg/pagination/mongop"
@@ -36,7 +33,6 @@ type PostService struct {
 	PostMongoMapper post.IMongoMapper
 	PostEsMapper    post.IEsMapper
 	Redis           *redis.Redis
-	MqProducer      rocketmq.Producer
 }
 
 var PostSet = wire.NewSet(
@@ -59,12 +55,6 @@ func (s *PostService) CreatePost(ctx context.Context, req *content.CreatePostReq
 	}
 	resp.PostId = p.ID.Hex()
 
-	//发送使用url信息
-	//var urls []url.URL
-	//u, _ := url.Parse(req.CoverUrl)
-	//urls = append(urls, *u)
-	//go s.SendDelayMessage(urls)
-
 	//小鱼干奖励
 	data, err := s.Redis.GetCtx(ctx, "contentTimes"+req.UserId)
 	if err != nil {
@@ -155,12 +145,6 @@ func (s *PostService) UpdatePost(ctx context.Context, req *content.UpdatePostReq
 		return nil, err
 	}
 
-	//发送使用url信息
-	//var urls []url.URL
-	//u, _ := url.Parse(req.CoverUrl)
-	//urls = append(urls, *u)
-	//go s.SendDelayMessage(urls)
-
 	return &content.UpdatePostResp{}, nil
 }
 
@@ -245,21 +229,3 @@ func (s *PostService) SetOfficial(ctx context.Context, req *content.SetOfficialR
 	}
 	return &content.SetOfficialResp{}, nil
 }
-
-func (s *PostService) SendDelayMessage(message interface{}) {
-	json, _ := sonic.Marshal(message)
-	msg := &mqprimitive.Message{
-		Topic: "sts_used_url",
-		Body:  json,
-	}
-
-	res, err := s.MqProducer.SendSync(context.Background(), msg)
-	if err != nil || res.Status != mqprimitive.SendOK {
-		for i := 0; i < 2; i++ {
-			res, err := s.MqProducer.SendSync(context.Background(), msg)
-			if err == nil && res.Status == mqprimitive.SendOK {
-				break
-			}
-		}
-	}
-}
diff --git a/provider/wire_gen.go b/provider/wire_gen.go