订阅中心

controllers/order/subscribe_controller.go

@@ -3,6 +3,7 @@ package order
 import (
 	"eta/eta_mini_ht_api/common/exception"
 	"eta/eta_mini_ht_api/controllers"
+	"eta/eta_mini_ht_api/domian/merchant"
 	"eta/eta_mini_ht_api/service/facade"
 	"eta/eta_mini_ht_api/service/order"
 	"eta/eta_mini_ht_api/service/user"
@@ -175,6 +176,21 @@ func (sc *SubscribeController) SubscribeProduct() {
 	})
 }
 
+// SubscribeList  用户订阅列表
+// @Summary  用户订阅列表
+// @Description  用户订阅列表
+// @Success 200 {object} controllers.BaseResponse
+// @router /subscribeList [get]
+func (sc *SubscribeController) SubscribeList(productType string) {
+	controllers.Wrap(&sc.BaseController, func() (result *controllers.WrapData, err error) {
+		result = sc.InitWrapData("查询订阅列表失败")
+		userInfo := sc.Data["user"].(user.User)
+		list, err := merchant.SubscribeList(userInfo.Id, productType)
+		sc.SuccessResult("查询订阅列表成功", list, result)
+		return
+	})
+}
+
 type SubscribeRequest struct {
 	ProductId int    `json:"productId"`
 	OrderNo   string `json:"orderNo"`

domian/merchant/user_access_service.go

@@ -32,3 +32,7 @@ func CloseProduct(templateUserId int, productOrderNo string, product MerchantPro
 	}
 	return merchant.InsertOrUpdateUserSubscribe(userAccess)
 }
+
+//func SubscribeList(templateUserId int, productType string) (list[], err error) {
+//	return merchant.SubscribeList(templateUserId, productType)
+//}

models/merchant/user_subscription_access_list.go

@@ -91,3 +91,7 @@ func CloseUserAccess(access UserSubscriptionAccessList) (err error) {
 	// 执行批量插入或更新操作
 	return
 }
+
+//func SubscribeList(id int, productType string) (interface{}, error) {
+//
+//}

routers/commentsRouter.go

@@ -112,6 +112,17 @@ func init() {
             Filters: nil,
             Params: nil})
 
+    beego.GlobalControllerRouter["eta/eta_mini_ht_api/controllers/order:SubscribeController"] = append(beego.GlobalControllerRouter["eta/eta_mini_ht_api/controllers/order:SubscribeController"],
+        beego.ControllerComments{
+            Method: "SubscribeList",
+            Router: `/subscribeList`,
+            AllowHTTPMethods: []string{"get"},
+            MethodParams: param.Make(
+				param.New("productType"),
+			),
+            Filters: nil,
+            Params: nil})
+
     beego.GlobalControllerRouter["eta/eta_mini_ht_api/controllers/payment:PaymentController"] = append(beego.GlobalControllerRouter["eta/eta_mini_ht_api/controllers/payment:PaymentController"],
         beego.ControllerComments{
             Method: "PayOrder",