feat:新增eia stero报告

controllers/base_from_eia_stero.go

@@ -14,8 +14,8 @@ type EiaSteroController struct {
 }
 
 // Add
-// @Title 新增钢联化工指标接口
-// @Description 新增钢联化工指标接口
+// @Title 新增Eia Stero指标接口
+// @Description 新增Eia Stero指标接口
 // @Success 200 {object} models.AddEdbInfoReq
 // @router /add [post]
 func (this *EiaSteroController) Add() {
@@ -59,8 +59,8 @@ func (this *EiaSteroController) Add() {
 }
 
 // Refresh
-// @Title 刷新钢联化工指标接口
-// @Description 刷新钢联化工指标接口
+// @Title 刷新Eia Stero指标接口
+// @Description 刷新Eia Stero指标接口
 // @Success 200 {object} models.RefreshEdbInfoReq
 // @router /refresh [post]
 func (this *EiaSteroController) Refresh() {
@@ -71,7 +71,7 @@ func (this *EiaSteroController) Refresh() {
 		this.Data["json"] = br
 		this.ServeJSON()
 	}()
-	source := utils.DATA_SOURCE_MYSTEEL_CHEMICAL
+	source := utils.DATA_SOURCE_EIA_STERO
 	var req models.RefreshEdbInfoReq
 	err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
 	if err != nil {
@@ -109,7 +109,7 @@ func (this *EiaSteroController) Refresh() {
 	err = models.RefreshEdbDataFromEiaStero(req.EdbInfoId, req.EdbCode, req.StartDate)
 	if err != nil && err.Error() != utils.ErrNoRow() {
 		br.Msg = "刷新指标信息失败！"
-		br.ErrMsg = "刷新指标信息失败 RefreshEdbDataFromMysteel，Err:" + err.Error()
+		br.ErrMsg = "刷新指标信息失败 RefreshEdbDataFromEiaStero，Err:" + err.Error()
 		return
 	}
 	// 更新指标最大最小值

models/base_from_eia_stero.go

@@ -83,7 +83,7 @@ func AddEdbDataFromEiaStero(edbCode string) (err error) {
 
 // RefreshEdbDataFromEiaStero 刷新钢联指标数据
 func RefreshEdbDataFromEiaStero(edbInfoId int, edbCode, startDate string) (err error) {
-	source := utils.DATA_SOURCE_MYSTEEL_CHEMICAL
+	source := utils.DATA_SOURCE_EIA_STERO
 	o := orm.NewOrm()
 	if err != nil {
 		return

routers/commentsRouter.go

@@ -106,6 +106,24 @@ func init() {
             Filters: nil,
             Params: nil})
 
+    beego.GlobalControllerRouter["hongze/hongze_edb_lib/controllers:EiaSteroController"] = append(beego.GlobalControllerRouter["hongze/hongze_edb_lib/controllers:EiaSteroController"],
+        beego.ControllerComments{
+            Method: "Add",
+            Router: `/add`,
+            AllowHTTPMethods: []string{"post"},
+            MethodParams: param.Make(),
+            Filters: nil,
+            Params: nil})
+
+    beego.GlobalControllerRouter["hongze/hongze_edb_lib/controllers:EiaSteroController"] = append(beego.GlobalControllerRouter["hongze/hongze_edb_lib/controllers:EiaSteroController"],
+        beego.ControllerComments{
+            Method: "Refresh",
+            Router: `/refresh`,
+            AllowHTTPMethods: []string{"post"},
+            MethodParams: param.Make(),
+            Filters: nil,
+            Params: nil})
+
     beego.GlobalControllerRouter["hongze/hongze_edb_lib/controllers:GieController"] = append(beego.GlobalControllerRouter["hongze/hongze_edb_lib/controllers:GieController"],
         beego.ControllerComments{
             Method: "Add",

routers/router.go

@@ -120,6 +120,11 @@ func init() {
 				&controllers.PredictCalculateController{},
 			),
 		),
+		beego.NSNamespace("/eia_stero",
+			beego.NSInclude(
+				&controllers.EiaSteroController{},
+			),
+		),
 	)
 	beego.AddNamespace(ns)
 }