|
|
@@ -19,7 +19,7 @@ type (
|
|
|
DcItemHistoryDataModel interface {
|
|
|
dcItemHistoryDataModel
|
|
|
MultiInsert(ctx context.Context, projectId int64, datas []*pb.ItemHistoryData) (int64, error)
|
|
|
- QueryHistoryDataByTime(ctx context.Context, in *pb.ItemHistoryDataByTimeReq) ([]ItemHistoryData, error)
|
|
|
+ QueryHistoryDataByTime(ctx context.Context, in *pb.ItemHistoryDataByTimeReq) ([]*ItemHistoryData, error)
|
|
|
QueryHistoryDataMaxMinByTime(ctx context.Context, in *pb.ItemHistoryDataByTimeReq) (*MaxMinData, error)
|
|
|
}
|
|
|
|
|
|
@@ -63,8 +63,8 @@ func (m *defaultDcItemHistoryDataModel) MultiInsert(ctx context.Context, project
|
|
|
}
|
|
|
}
|
|
|
|
|
|
-func (m *defaultDcItemHistoryDataModel) QueryHistoryDataByTime(ctx context.Context, in *pb.ItemHistoryDataByTimeReq) ([]ItemHistoryData, error) {
|
|
|
- resp := make([]ItemHistoryData, 0)
|
|
|
+func (m *defaultDcItemHistoryDataModel) QueryHistoryDataByTime(ctx context.Context, in *pb.ItemHistoryDataByTimeReq) ([]*ItemHistoryData, error) {
|
|
|
+ resp := make([]*ItemHistoryData, 0)
|
|
|
var err error
|
|
|
query := fmt.Sprintf("SELECT * FROM %s AS hd "+
|
|
|
" LEFT JOIN dc_item_config as ic ON hd.item_name = ic.item_name "+
|
songxiaohang