update

api/v1/quote/quote.go

@@ -22,7 +22,7 @@ func Quote(c *gin.Context) {
 // @Security ApiKeyAuth
 // @accept   application/json
 // @Produce  application/json
-// @Param    data body     request.QuoteSubscribeReq   true "入参"
+// @Param    data body     request.QuoteSubscribeReq     true "入参1"
 // @Success  200  {object} response.Response{msg=string} "出参"
 // @Router   /Quote/QuoteSubscribe [post]
 // @Tags     实时行情
@@ -35,5 +35,7 @@ func QuoteSubscribe(c *gin.Context) {
 
 	if err := quote.QuoteSubscribe(c, req); err != nil {
 		response.FailWithMessage(err.Error(), c)
+		return
 	}
+	response.OkWithMessage("订阅成功", c)
 }

client/client.go

@@ -51,7 +51,7 @@ func (r *Client) SetQuoteSubs(req request.QuoteSubscribeReq) {
 	r.quoteSubs = req.QuoteGoodses
 
 	if r.ch != nil {
-		r.unSubscribe <- struct{}{}
+		// r.unSubscribe <- struct{}{}
 		global.M2A_Publish.Unsubscribe(publish.Topic_Quote, r.ch)
 	}
 	r.ch = global.M2A_Publish.Subscribe(publish.Topic_Quote)

docs/docs.go

@@ -220,15 +220,12 @@ const docTemplate = `{
                 "summary": "实时行情",
                 "parameters": [
                     {
-                        "description": "入参",
+                        "description": "入参1",
                         "name": "data",
                         "in": "body",
                         "required": true,
                         "schema": {
-                            "type": "array",
-                            "items": {
-                                "$ref": "#/definitions/request.QuoteSubscribeReq"
-                            }
+                            "$ref": "#/definitions/request.QuoteSubscribeReq"
                         }
                     }
                 ],

docs/swagger.json

@@ -211,15 +211,12 @@
                 "summary": "实时行情",
                 "parameters": [
                     {
-                        "description": "入参",
+                        "description": "入参1",
                         "name": "data",
                         "in": "body",
                         "required": true,
                         "schema": {
-                            "type": "array",
-                            "items": {
-                                "$ref": "#/definitions/request.QuoteSubscribeReq"
-                            }
+                            "$ref": "#/definitions/request.QuoteSubscribeReq"
                         }
                     }
                 ],

docs/swagger.yaml

@@ -217,14 +217,12 @@ paths:
       consumes:
       - application/json
       parameters:
-      - description: 入参
+      - description: 入参1
         in: body
         name: data
         required: true
         schema:
-          items:
-            $ref: '#/definitions/request.QuoteSubscribeReq'
-          type: array
+          $ref: '#/definitions/request.QuoteSubscribeReq'
       produces:
       - application/json
       responses: