频道完成

api/subscription/subscription.go

@@ -0,0 +1,16 @@
+// =================================================================================
+// Code generated and maintained by GoFrame CLI tool. DO NOT EDIT.
+// =================================================================================
+
+package subscription
+
+import (
+	"context"
+
+	"practice_Go/api/subscription/v1"
+)
+
+type ISubscriptionV1 interface {
+	AddSubscription(ctx context.Context, req *v1.AddSubscriptionReq) (res *v1.AddSubscriptionRes, err error)
+	DeleteSubscription(ctx context.Context, req *v1.DeleteSubscriptionReq) (res *v1.DeleteSubscriptionRes, err error)
+}

api/subscription/v1/subscription.go

@@ -0,0 +1,23 @@
+package v1
+
+import "github.com/gogf/gf/v2/frame/g"
+
+type AddSubscriptionReq struct {
+	g.Meta `path:"/subscription" method:"post" tags:"Subscription" summary:"添加订阅信息"`
+	Id       int `v:"required|min:1#频道ID不能为空|频道ID不能小于1" dc:"频道ID"`
+	UserId   int `v:"required|min:90000000|max:99999999#用户ID不能为空|用户ID不能小于90000000|用户ID不能大于99999999" dc:"用户ID"`
+}
+
+type AddSubscriptionRes struct {
+	Success bool   `json:"success" dc:"订阅是否成功"`
+}
+
+type DeleteSubscriptionReq struct {
+	g.Meta `path:"/subscription" method:"delete" tags:"Subscription" summary:"删除订阅信息"`
+	Id       int `v:"required|min:1#频道ID不能为空|频道ID不能小于1" dc:"频道ID"`
+	UserId   int `v:"required|min:90000000|max:99999999#用户ID不能为空|用户ID不能小于90000000|用户ID不能大于99999999" dc:"用户ID"`
+}
+
+type DeleteSubscriptionRes struct {
+	Success bool   `json:"success" dc:"取消订阅是否成功"`
+}

internal/cmd/cmd.go

@@ -3,6 +3,7 @@ package cmd
 import (
 	"context"
 	"practice_Go/internal/controller/channel"
+	"practice_Go/internal/controller/subscription"
 
 	"github.com/gogf/gf/v2/frame/g"
 	"github.com/gogf/gf/v2/net/ghttp"
@@ -20,6 +21,7 @@ var (
 				group.Middleware(ghttp.MiddlewareHandlerResponse)
 				group.Bind(
 					channel.NewV1(),
+					subscription.NewV1(),
 				)
 			})
 			s.SetServerRoot("resource/public")

internal/controller/subscription/subscription.go

@@ -0,0 +1,5 @@
+// =================================================================================
+// This is auto-generated by GoFrame CLI tool only once. Fill this file as you wish.
+// =================================================================================
+
+package subscription

internal/controller/subscription/subscription_new.go

@@ -0,0 +1,15 @@
+// =================================================================================
+// This is auto-generated by GoFrame CLI tool only once. Fill this file as you wish.
+// =================================================================================
+
+package subscription
+
+import (
+	"practice_Go/api/subscription"
+)
+
+type ControllerV1 struct{}
+
+func NewV1() subscription.ISubscriptionV1 {
+	return &ControllerV1{}
+}

internal/controller/subscription/subscription_v1_add_subscription.go

@@ -0,0 +1,21 @@
+package subscription
+
+import (
+	"context"
+
+	"practice_Go/api/subscription/v1"
+	"practice_Go/internal/dao"
+	"practice_Go/internal/model/do"
+)
+
+func (c *ControllerV1) AddSubscription(ctx context.Context, req *v1.AddSubscriptionReq) (res *v1.AddSubscriptionRes, err error) {
+	res = &v1.AddSubscriptionRes{}
+	_, err = dao.GoChannelSubscriptions.Ctx(ctx).Data(do.GoChannelSubscriptions{
+		ChannelId: req.Id,
+		UserId:    req.UserId,
+	}).Insert()
+	if err == nil {
+		res.Success = true
+	}
+	return
+}

internal/controller/subscription/subscription_v1_delete_subscription.go

@@ -0,0 +1,17 @@
+package subscription
+
+import (
+	"context"
+
+	"practice_Go/api/subscription/v1"
+	"practice_Go/internal/dao"
+)
+
+func (c *ControllerV1) DeleteSubscription(ctx context.Context, req *v1.DeleteSubscriptionReq) (res *v1.DeleteSubscriptionRes, err error) {
+	res = &v1.DeleteSubscriptionRes{}
+	_, err = dao.GoChannelSubscriptions.Ctx(ctx).Wheref("channel_id =? and user_id =?", req.Id, req.UserId).Delete()
+	if err == nil {
+		res.Success = true
+	}
+	return
+}