Browse Source

订阅数一致修改

dev
majun 7 months ago
parent
commit
013a8d612c
  1. 1
      internal/controller/subscription/subscription_v1_add_subscription.go
  2. 1
      internal/controller/subscription/subscription_v1_delete_subscription.go

1
internal/controller/subscription/subscription_v1_add_subscription.go

@ -15,6 +15,7 @@ func (c *ControllerV1) AddSubscription(ctx context.Context, req *v1.AddSubscript
ChannelId: req.Id, ChannelId: req.Id,
UserId: req.UserId, UserId: req.UserId,
}).Insert() }).Insert()
_, err = dao.GoChannels.Ctx(ctx).Where("id",req.Id).Increment("subscription_count",1)
if err != nil { if err != nil {
return dto.Error(err.Error()), nil return dto.Error(err.Error()), nil
} }

1
internal/controller/subscription/subscription_v1_delete_subscription.go

@ -11,6 +11,7 @@ import (
func (c *ControllerV1) DeleteSubscription(ctx context.Context, req *v1.DeleteSubscriptionReq) (*dto.Result, error) { func (c *ControllerV1) DeleteSubscription(ctx context.Context, req *v1.DeleteSubscriptionReq) (*dto.Result, error) {
res := &v1.DeleteSubscriptionRes{} res := &v1.DeleteSubscriptionRes{}
_, err := dao.GoChannelSubscriptions.Ctx(ctx).Wheref("channel_id =? and user_id =?", req.Id, req.UserId).Delete() _, err := dao.GoChannelSubscriptions.Ctx(ctx).Wheref("channel_id =? and user_id =?", req.Id, req.UserId).Delete()
_, err = dao.GoChannels.Ctx(ctx).Where("id",req.Id).Decrement("subscription_count",1)
if err != nil { if err != nil {
return dto.Error(err.Error()), nil return dto.Error(err.Error()), nil
} }

Loading…
Cancel
Save