first

controllers/exchange_crawler.go

@@ -0,0 +1,51 @@
+package controllers
+
+import (
+	"encoding/json"
+	"eta/eta_index_lib/models"
+	"fmt"
+	"github.com/rdlucklib/rdluck_tools/http"
+)
+
+// 交易所爬虫
+type ExchangeCrawler struct {
+	BaseAuthController
+}
+
+// @Title 刷新数据
+// @Description 刷新数据接口
+// @Param	request	body models.AddEdbClassifyReq true "type json string"
+// @Success 200 {object} models.EdbClassify
+// @router /refresh [post]
+func (this *ExchangeCrawler) GetOrAdd() {
+	br := new(models.BaseResponse).Init()
+	defer func() {
+		this.Data["json"] = br
+		this.ServeJSON()
+	}()
+	var req models.RefreshExchangeoReq
+	err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
+	if err != nil {
+		br.Msg = "参数解析异常！"
+		br.ErrMsg = "参数解析失败，Err:" + err.Error()
+		return
+	}
+	if req.Url == "" {
+		br.Msg = "交易所链接错误"
+		br.IsSendEmail = false
+		return
+	}
+
+	body, e := http.Get(req.Url)
+	if e != nil {
+		err = e
+		fmt.Println("err:", err)
+		return
+	}
+
+
+	br.Ret = 200
+	br.Msg = "获取成功"
+	br.Success = true
+	br.Data = body
+}

models/base_from_sh.go

@@ -262,3 +262,7 @@ func RefreshEdbDataFromSh(edbInfoId int, edbCode, startDate string) (err error)
 	}
 	return
 }
+
+type RefreshExchangeoReq struct {
+	Url string `description:"交易所链接"`
+}

routers/commentsRouter.go

@@ -286,6 +286,15 @@ func init() {
             Filters: nil,
             Params: nil})
 
+    beego.GlobalControllerRouter["eta/eta_index_lib/controllers:ExchangeCrawler"] = append(beego.GlobalControllerRouter["eta/eta_index_lib/controllers:ExchangeCrawler"],
+        beego.ControllerComments{
+            Method: "GetOrAdd",
+            Router: `/refresh`,
+            AllowHTTPMethods: []string{"post"},
+            MethodParams: param.Make(),
+            Filters: nil,
+            Params: nil})
+
     beego.GlobalControllerRouter["eta/eta_index_lib/controllers:FuBaoController"] = append(beego.GlobalControllerRouter["eta/eta_index_lib/controllers:FuBaoController"],
         beego.ControllerComments{
             Method: "Add",

routers/router.go

@@ -186,6 +186,11 @@ func init() {
 				&controllers.EdbInfoCalculateController{},
 			),
 		),
+		beego.NSNamespace("/exchange_crawler",
+			beego.NSInclude(
+				&controllers.ExchangeCrawler{},
+			),
+		),
 	)
 	beego.AddNamespace(ns)
 }