Merge branch 'master' of http://120.55.44.4:10080/gaoyagang/gt-common

datacenter_client/types.go

@@ -192,6 +192,16 @@ type (
 	MultiAddReq struct {
 		List []ItemHistoryData `json:"list"`
 	}
+
+	ItemHistoryListReq struct {
+		ProjectId int
+		ItemName  string
+		Stime     string
+		Etime     string
+		Size      int
+		Interval  string // 时间单位 minute,h,day,s
+		Aggregator string // 聚合方式 min,max,avg，sum，realtime, new
+	}
 )
 
 type (
@@ -252,6 +262,16 @@ type (
 		List []ItemHistoryResp
 	}
 
+	ItemHistoryListResp struct {
+		Name   string `json:"name"`
+		Htime  string `json:"htime_at"`
+		Val    float64 `json:"val"`
+	}
+
+	ItemHistoryListRespList struct {
+		List []ItemHistoryListResp
+	}
+
 	MultiAddBody struct {
 		Code int    `json:"code"`
 		Msg  string `json:"msg"`
@@ -262,6 +282,14 @@ type (
 		Msg  string              `json:"msg"`
 		Data ItemHistoryRespList `json:"data"`
 	}
+
+	ItemHistoryListBody struct {
+		Code int                 `json:"code"`
+		Msg  string              `json:"msg"`
+		Data ItemHistoryListRespList `json:"data"`
+	}
+
+
 )
 
 type (
@@ -288,5 +316,7 @@ type (
 		GetWorkingChestByCode(DcWorkingReq) (*GetWorkingChestByCodeResp, error)
 		// GetWorkingPumpByCode 查询泵类工况数据
 		GetWorkingPumpByCode(DcWorkingReq) (*GetWorkingPumpByCodeResp, error)
+		// 平替双胞胎图表接口(时间区间内按要求聚合)
+		GetItemHistoryList(ItemHistoryListReq) (resp []ItemHistoryListResp, err error)
 	}
 )

datacenter_client/v1/GetItemHistoryList.go

@@ -0,0 +1,34 @@
+package v1
+
+import (
+	"errors"
+	"fmt"
+	"log"
+	"metawant.greentech.com.cn/gaoyagang/gt-common/datacenter_client"
+	"metawant.greentech.com.cn/gaoyagang/gt-common/httplib"
+)
+
+func (d *DcApi) GetItemHistoryList(req datacenter_client.ItemHistoryListReq) (resp []datacenter_client.ItemHistoryListResp, err error) {
+	url := d.serviceUrl("/item-history/list")
+	h := httplib.Get(url)
+	h.Param("project_id", fmt.Sprintf("%d", req.ProjectId))
+	h.Param("item_name", req.ItemName)
+	h.Param("stime", req.Stime)
+	h.Param("etime", req.Etime)
+	h.Param("size", fmt.Sprintf("%d", req.Size))
+	h.Param("interval", req.Interval)
+	h.Param("aggregator", req.Aggregator)
+
+	result := &datacenter_client.ItemHistoryListBody{}
+	err = d.call(h, result)
+	if err != nil {
+		log.Println("GetItemHistoryList Unmarshal Error:", err)
+		return
+	}
+	if result.Code != 200 {
+		err = errors.New(result.Msg)
+		return
+	}
+	resp = result.Data.List
+	return
+}