// Code generated by protoc-gen-go-grpc. DO NOT EDIT.

package data

import (
	context "context"
	grpc "google.golang.org/grpc"
	codes "google.golang.org/grpc/codes"
	status "google.golang.org/grpc/status"
)

// This is a compile-time assertion to ensure that this generated file
// is compatible with the grpc package it is being compiled against.
// Requires gRPC-Go v1.32.0 or later.
const _ = grpc.SupportPackageIsVersion7

// DataClient is the client API for Data service.
//
// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
type DataClient interface {
	// group: base
	InitDatabase(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*BaseResp, error)
	// DeviceDuration management
	// group: device_duration
	CreateDeviceDuration(ctx context.Context, in *DeviceDurationInfo, opts ...grpc.CallOption) (*BaseIDResp, error)
	// group: device_duration
	UpdateDeviceDuration(ctx context.Context, in *DeviceDurationInfo, opts ...grpc.CallOption) (*BaseResp, error)
	// group: device_duration
	GetDeviceDurationList(ctx context.Context, in *DeviceDurationListReq, opts ...grpc.CallOption) (*DeviceDurationListResp, error)
	// group: device_duration
	GetDeviceDurationById(ctx context.Context, in *IDReq, opts ...grpc.CallOption) (*DeviceDurationInfo, error)
	// group: device_duration
	DeleteDeviceDuration(ctx context.Context, in *IDsReq, opts ...grpc.CallOption) (*BaseResp, error)
	// group: device_duration
	AnalyseDeviceDuration(ctx context.Context, in *AnalyseDeviceDurationReq, opts ...grpc.CallOption) (*BaseResp, error)
	// DeviceDurationElephant management
	// group: device_duration_elephant
	CreateDeviceDurationElephant(ctx context.Context, in *DeviceDurationElephantInfo, opts ...grpc.CallOption) (*BaseIDResp, error)
	// group: device_duration_elephant
	UpdateDeviceDurationElephant(ctx context.Context, in *DeviceDurationElephantInfo, opts ...grpc.CallOption) (*BaseResp, error)
	// group: device_duration_elephant
	GetDeviceDurationElephantList(ctx context.Context, in *DeviceDurationElephantListReq, opts ...grpc.CallOption) (*DeviceDurationElephantListResp, error)
	// group: device_duration_elephant
	GetDeviceDurationElephantById(ctx context.Context, in *IDReq, opts ...grpc.CallOption) (*DeviceDurationElephantInfo, error)
	// group: device_duration_elephant
	DeleteDeviceDurationElephant(ctx context.Context, in *IDsReq, opts ...grpc.CallOption) (*BaseResp, error)
	// group: device_duration_elephant
	AnalyseDeviceDurationElephant(ctx context.Context, in *AnalyseDeviceDurationElephantReq, opts ...grpc.CallOption) (*BaseResp, error)
	// DeviceEvent management
	// group: device_event
	CreateDeviceEvent(ctx context.Context, in *DeviceEventInfo, opts ...grpc.CallOption) (*BaseIDResp, error)
	// group: device_event
	UpdateDeviceEvent(ctx context.Context, in *DeviceEventInfo, opts ...grpc.CallOption) (*BaseResp, error)
	// group: device_event
	GetDeviceEventList(ctx context.Context, in *DeviceEventListReq, opts ...grpc.CallOption) (*DeviceEventListResp, error)
	// group: device_event
	GetDeviceEventById(ctx context.Context, in *IDReq, opts ...grpc.CallOption) (*DeviceEventInfo, error)
	// group: device_event
	DeleteDeviceEvent(ctx context.Context, in *IDsReq, opts ...grpc.CallOption) (*BaseResp, error)
	// group: device_event
	SyncDeviceEvent(ctx context.Context, in *SyncDeviceEventReq, opts ...grpc.CallOption) (*BaseResp, error)
	// DeviceKpi management
	// group: device_kpi
	CreateDeviceKpi(ctx context.Context, in *DeviceKpiInfo, opts ...grpc.CallOption) (*BaseIDResp, error)
	// group: device_kpi
	UpdateDeviceKpi(ctx context.Context, in *DeviceKpiInfo, opts ...grpc.CallOption) (*BaseResp, error)
	// group: device_kpi
	GetDeviceKpiList(ctx context.Context, in *DeviceKpiListReq, opts ...grpc.CallOption) (*DeviceKpiListResp, error)
	// group: device_kpi
	GetDeviceKpiById(ctx context.Context, in *IDReq, opts ...grpc.CallOption) (*DeviceKpiInfo, error)
	// group: device_kpi
	GetDeviceKpiByIotID(ctx context.Context, in *KpiIotIDReq, opts ...grpc.CallOption) (*DeviceKpiInfo, error)
	// group: device_kpi
	DeleteDeviceKpi(ctx context.Context, in *IDsReq, opts ...grpc.CallOption) (*BaseResp, error)
	// group: device_kpi
	AnalyseDeviceKpi(ctx context.Context, in *AnalyseDeviceKpiReq, opts ...grpc.CallOption) (*BaseResp, error)
	// DeviceOfflineTime management
	// group: device_offline_time
	CreateDeviceOfflineTime(ctx context.Context, in *DeviceOfflineTimeInfo, opts ...grpc.CallOption) (*BaseIDResp, error)
	// group: device_offline_time
	UpdateDeviceOfflineTime(ctx context.Context, in *DeviceOfflineTimeInfo, opts ...grpc.CallOption) (*BaseResp, error)
	// group: device_offline_time
	GetDeviceOfflineTimeList(ctx context.Context, in *DeviceOfflineTimeListReq, opts ...grpc.CallOption) (*DeviceOfflineTimeListResp, error)
	// group: device_offline_time
	GetDeviceOfflineTimeById(ctx context.Context, in *IDReq, opts ...grpc.CallOption) (*DeviceOfflineTimeInfo, error)
	// group: device_offline_time
	DeleteDeviceOfflineTime(ctx context.Context, in *IDsReq, opts ...grpc.CallOption) (*BaseResp, error)
	// group: device_offline_time
	SyncDeviceOfflineTime(ctx context.Context, in *SyncDeviceOfflineTimeReq, opts ...grpc.CallOption) (*BaseResp, error)
	// DeviceOnlineTime management
	// group: device_online_time
	CreateDeviceOnlineTime(ctx context.Context, in *DeviceOnlineTimeInfo, opts ...grpc.CallOption) (*BaseIDResp, error)
	// group: device_online_time
	UpdateDeviceOnlineTime(ctx context.Context, in *DeviceOnlineTimeInfo, opts ...grpc.CallOption) (*BaseResp, error)
	// group: device_online_time
	GetDeviceOnlineTimeList(ctx context.Context, in *DeviceOnlineTimeListReq, opts ...grpc.CallOption) (*DeviceOnlineTimeListResp, error)
	// group: device_online_time
	GetDeviceOnlineTimeById(ctx context.Context, in *IDReq, opts ...grpc.CallOption) (*DeviceOnlineTimeInfo, error)
	// group: device_online_time
	DeleteDeviceOnlineTime(ctx context.Context, in *IDsReq, opts ...grpc.CallOption) (*BaseResp, error)
	// group: device_online_time
	SyncDeviceOnlineTime(ctx context.Context, in *SyncDeviceOnlineTimeReq, opts ...grpc.CallOption) (*BaseResp, error)
	// DeviceOnTimeDaily management
	// group: device_on_time_daily
	CreateDeviceOnTimeDaily(ctx context.Context, in *DeviceOnTimeDailyInfo, opts ...grpc.CallOption) (*BaseIDResp, error)
	// group: device_on_time_daily
	UpdateDeviceOnTimeDaily(ctx context.Context, in *DeviceOnTimeDailyInfo, opts ...grpc.CallOption) (*BaseResp, error)
	// group: device_on_time_daily
	GetDeviceOnTimeDailyList(ctx context.Context, in *DeviceOnTimeDailyListReq, opts ...grpc.CallOption) (*DeviceOnTimeDailyListResp, error)
	// group: device_on_time_daily
	GetDeviceOnTimeDailyById(ctx context.Context, in *IDReq, opts ...grpc.CallOption) (*DeviceOnTimeDailyInfo, error)
	// group: device_on_time_daily
	DeleteDeviceOnTimeDaily(ctx context.Context, in *IDsReq, opts ...grpc.CallOption) (*BaseResp, error)
	// group: device_on_time_daily
	SyncDeviceOnTimeDaily(ctx context.Context, in *SyncDeviceOnTimeDailyReq, opts ...grpc.CallOption) (*BaseResp, error)
	// DeviceProperty management
	// group: device_property
	SyncDeviceProperty(ctx context.Context, in *SyncDevicePropertyReq, opts ...grpc.CallOption) (*SyncDevicePropertyResp, error)
	// group: device_tag
	AnalyseDeviceTag(ctx context.Context, in *AnalyseDeviceTagReq, opts ...grpc.CallOption) (*BaseResp, error)
	// DeviceUpsterCycle management
	// group: device_upster_cycle
	CreateDeviceUpsterCycle(ctx context.Context, in *DeviceUpsterCycleInfo, opts ...grpc.CallOption) (*BaseIDResp, error)
	// group: device_upster_cycle
	UpdateDeviceUpsterCycle(ctx context.Context, in *DeviceUpsterCycleInfo, opts ...grpc.CallOption) (*BaseResp, error)
	// group: device_upster_cycle
	GetDeviceUpsterCycleList(ctx context.Context, in *DeviceUpsterCycleListReq, opts ...grpc.CallOption) (*DeviceUpsterCycleListResp, error)
	// group: device_upster_cycle
	GetDeviceUpsterCycleById(ctx context.Context, in *IDReq, opts ...grpc.CallOption) (*DeviceUpsterCycleInfo, error)
	// group: device_upster_cycle
	DeleteDeviceUpsterCycle(ctx context.Context, in *IDsReq, opts ...grpc.CallOption) (*BaseResp, error)
	// group: device_upster_cycle
	SyncDeviceUpsterCycle(ctx context.Context, in *SyncDeviceUpsterCycleReq, opts ...grpc.CallOption) (*BaseResp, error)
	// DeviceUpsterStatistics management
	// group: device_upster_statistics
	CreateDeviceUpsterStatistics(ctx context.Context, in *DeviceUpsterStatisticsInfo, opts ...grpc.CallOption) (*BaseIDResp, error)
	// group: device_upster_statistics
	UpdateDeviceUpsterStatistics(ctx context.Context, in *DeviceUpsterStatisticsInfo, opts ...grpc.CallOption) (*BaseResp, error)
	// group: device_upster_statistics
	GetDeviceUpsterStatisticsList(ctx context.Context, in *DeviceUpsterStatisticsListReq, opts ...grpc.CallOption) (*DeviceUpsterStatisticsListResp, error)
	// group: device_upster_statistics
	GetDeviceUpsterStatisticsById(ctx context.Context, in *IDReq, opts ...grpc.CallOption) (*DeviceUpsterStatisticsInfo, error)
	// group: device_upster_statistics
	DeleteDeviceUpsterStatistics(ctx context.Context, in *IDsReq, opts ...grpc.CallOption) (*BaseResp, error)
	// group: device_upster_statistics
	AnalyseDeviceUpsterStatistics(ctx context.Context, in *AnalyseDeviceUpsterStatisticsReq, opts ...grpc.CallOption) (*BaseResp, error)
}

type dataClient struct {
	cc grpc.ClientConnInterface
}

func NewDataClient(cc grpc.ClientConnInterface) DataClient {
	return &dataClient{cc}
}

func (c *dataClient) InitDatabase(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*BaseResp, error) {
	out := new(BaseResp)
	err := c.cc.Invoke(ctx, "/data.Data/initDatabase", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *dataClient) CreateDeviceDuration(ctx context.Context, in *DeviceDurationInfo, opts ...grpc.CallOption) (*BaseIDResp, error) {
	out := new(BaseIDResp)
	err := c.cc.Invoke(ctx, "/data.Data/createDeviceDuration", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *dataClient) UpdateDeviceDuration(ctx context.Context, in *DeviceDurationInfo, opts ...grpc.CallOption) (*BaseResp, error) {
	out := new(BaseResp)
	err := c.cc.Invoke(ctx, "/data.Data/updateDeviceDuration", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *dataClient) GetDeviceDurationList(ctx context.Context, in *DeviceDurationListReq, opts ...grpc.CallOption) (*DeviceDurationListResp, error) {
	out := new(DeviceDurationListResp)
	err := c.cc.Invoke(ctx, "/data.Data/getDeviceDurationList", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *dataClient) GetDeviceDurationById(ctx context.Context, in *IDReq, opts ...grpc.CallOption) (*DeviceDurationInfo, error) {
	out := new(DeviceDurationInfo)
	err := c.cc.Invoke(ctx, "/data.Data/getDeviceDurationById", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *dataClient) DeleteDeviceDuration(ctx context.Context, in *IDsReq, opts ...grpc.CallOption) (*BaseResp, error) {
	out := new(BaseResp)
	err := c.cc.Invoke(ctx, "/data.Data/deleteDeviceDuration", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *dataClient) AnalyseDeviceDuration(ctx context.Context, in *AnalyseDeviceDurationReq, opts ...grpc.CallOption) (*BaseResp, error) {
	out := new(BaseResp)
	err := c.cc.Invoke(ctx, "/data.Data/analyseDeviceDuration", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *dataClient) CreateDeviceDurationElephant(ctx context.Context, in *DeviceDurationElephantInfo, opts ...grpc.CallOption) (*BaseIDResp, error) {
	out := new(BaseIDResp)
	err := c.cc.Invoke(ctx, "/data.Data/createDeviceDurationElephant", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *dataClient) UpdateDeviceDurationElephant(ctx context.Context, in *DeviceDurationElephantInfo, opts ...grpc.CallOption) (*BaseResp, error) {
	out := new(BaseResp)
	err := c.cc.Invoke(ctx, "/data.Data/updateDeviceDurationElephant", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *dataClient) GetDeviceDurationElephantList(ctx context.Context, in *DeviceDurationElephantListReq, opts ...grpc.CallOption) (*DeviceDurationElephantListResp, error) {
	out := new(DeviceDurationElephantListResp)
	err := c.cc.Invoke(ctx, "/data.Data/getDeviceDurationElephantList", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *dataClient) GetDeviceDurationElephantById(ctx context.Context, in *IDReq, opts ...grpc.CallOption) (*DeviceDurationElephantInfo, error) {
	out := new(DeviceDurationElephantInfo)
	err := c.cc.Invoke(ctx, "/data.Data/getDeviceDurationElephantById", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *dataClient) DeleteDeviceDurationElephant(ctx context.Context, in *IDsReq, opts ...grpc.CallOption) (*BaseResp, error) {
	out := new(BaseResp)
	err := c.cc.Invoke(ctx, "/data.Data/deleteDeviceDurationElephant", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *dataClient) AnalyseDeviceDurationElephant(ctx context.Context, in *AnalyseDeviceDurationElephantReq, opts ...grpc.CallOption) (*BaseResp, error) {
	out := new(BaseResp)
	err := c.cc.Invoke(ctx, "/data.Data/analyseDeviceDurationElephant", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *dataClient) CreateDeviceEvent(ctx context.Context, in *DeviceEventInfo, opts ...grpc.CallOption) (*BaseIDResp, error) {
	out := new(BaseIDResp)
	err := c.cc.Invoke(ctx, "/data.Data/createDeviceEvent", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *dataClient) UpdateDeviceEvent(ctx context.Context, in *DeviceEventInfo, opts ...grpc.CallOption) (*BaseResp, error) {
	out := new(BaseResp)
	err := c.cc.Invoke(ctx, "/data.Data/updateDeviceEvent", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *dataClient) GetDeviceEventList(ctx context.Context, in *DeviceEventListReq, opts ...grpc.CallOption) (*DeviceEventListResp, error) {
	out := new(DeviceEventListResp)
	err := c.cc.Invoke(ctx, "/data.Data/getDeviceEventList", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *dataClient) GetDeviceEventById(ctx context.Context, in *IDReq, opts ...grpc.CallOption) (*DeviceEventInfo, error) {
	out := new(DeviceEventInfo)
	err := c.cc.Invoke(ctx, "/data.Data/getDeviceEventById", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *dataClient) DeleteDeviceEvent(ctx context.Context, in *IDsReq, opts ...grpc.CallOption) (*BaseResp, error) {
	out := new(BaseResp)
	err := c.cc.Invoke(ctx, "/data.Data/deleteDeviceEvent", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *dataClient) SyncDeviceEvent(ctx context.Context, in *SyncDeviceEventReq, opts ...grpc.CallOption) (*BaseResp, error) {
	out := new(BaseResp)
	err := c.cc.Invoke(ctx, "/data.Data/syncDeviceEvent", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *dataClient) CreateDeviceKpi(ctx context.Context, in *DeviceKpiInfo, opts ...grpc.CallOption) (*BaseIDResp, error) {
	out := new(BaseIDResp)
	err := c.cc.Invoke(ctx, "/data.Data/createDeviceKpi", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *dataClient) UpdateDeviceKpi(ctx context.Context, in *DeviceKpiInfo, opts ...grpc.CallOption) (*BaseResp, error) {
	out := new(BaseResp)
	err := c.cc.Invoke(ctx, "/data.Data/updateDeviceKpi", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *dataClient) GetDeviceKpiList(ctx context.Context, in *DeviceKpiListReq, opts ...grpc.CallOption) (*DeviceKpiListResp, error) {
	out := new(DeviceKpiListResp)
	err := c.cc.Invoke(ctx, "/data.Data/getDeviceKpiList", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *dataClient) GetDeviceKpiById(ctx context.Context, in *IDReq, opts ...grpc.CallOption) (*DeviceKpiInfo, error) {
	out := new(DeviceKpiInfo)
	err := c.cc.Invoke(ctx, "/data.Data/getDeviceKpiById", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *dataClient) GetDeviceKpiByIotID(ctx context.Context, in *KpiIotIDReq, opts ...grpc.CallOption) (*DeviceKpiInfo, error) {
	out := new(DeviceKpiInfo)
	err := c.cc.Invoke(ctx, "/data.Data/getDeviceKpiByIotID", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *dataClient) DeleteDeviceKpi(ctx context.Context, in *IDsReq, opts ...grpc.CallOption) (*BaseResp, error) {
	out := new(BaseResp)
	err := c.cc.Invoke(ctx, "/data.Data/deleteDeviceKpi", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *dataClient) AnalyseDeviceKpi(ctx context.Context, in *AnalyseDeviceKpiReq, opts ...grpc.CallOption) (*BaseResp, error) {
	out := new(BaseResp)
	err := c.cc.Invoke(ctx, "/data.Data/analyseDeviceKpi", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *dataClient) CreateDeviceOfflineTime(ctx context.Context, in *DeviceOfflineTimeInfo, opts ...grpc.CallOption) (*BaseIDResp, error) {
	out := new(BaseIDResp)
	err := c.cc.Invoke(ctx, "/data.Data/createDeviceOfflineTime", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *dataClient) UpdateDeviceOfflineTime(ctx context.Context, in *DeviceOfflineTimeInfo, opts ...grpc.CallOption) (*BaseResp, error) {
	out := new(BaseResp)
	err := c.cc.Invoke(ctx, "/data.Data/updateDeviceOfflineTime", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *dataClient) GetDeviceOfflineTimeList(ctx context.Context, in *DeviceOfflineTimeListReq, opts ...grpc.CallOption) (*DeviceOfflineTimeListResp, error) {
	out := new(DeviceOfflineTimeListResp)
	err := c.cc.Invoke(ctx, "/data.Data/getDeviceOfflineTimeList", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *dataClient) GetDeviceOfflineTimeById(ctx context.Context, in *IDReq, opts ...grpc.CallOption) (*DeviceOfflineTimeInfo, error) {
	out := new(DeviceOfflineTimeInfo)
	err := c.cc.Invoke(ctx, "/data.Data/getDeviceOfflineTimeById", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *dataClient) DeleteDeviceOfflineTime(ctx context.Context, in *IDsReq, opts ...grpc.CallOption) (*BaseResp, error) {
	out := new(BaseResp)
	err := c.cc.Invoke(ctx, "/data.Data/deleteDeviceOfflineTime", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *dataClient) SyncDeviceOfflineTime(ctx context.Context, in *SyncDeviceOfflineTimeReq, opts ...grpc.CallOption) (*BaseResp, error) {
	out := new(BaseResp)
	err := c.cc.Invoke(ctx, "/data.Data/syncDeviceOfflineTime", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *dataClient) CreateDeviceOnlineTime(ctx context.Context, in *DeviceOnlineTimeInfo, opts ...grpc.CallOption) (*BaseIDResp, error) {
	out := new(BaseIDResp)
	err := c.cc.Invoke(ctx, "/data.Data/createDeviceOnlineTime", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *dataClient) UpdateDeviceOnlineTime(ctx context.Context, in *DeviceOnlineTimeInfo, opts ...grpc.CallOption) (*BaseResp, error) {
	out := new(BaseResp)
	err := c.cc.Invoke(ctx, "/data.Data/updateDeviceOnlineTime", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *dataClient) GetDeviceOnlineTimeList(ctx context.Context, in *DeviceOnlineTimeListReq, opts ...grpc.CallOption) (*DeviceOnlineTimeListResp, error) {
	out := new(DeviceOnlineTimeListResp)
	err := c.cc.Invoke(ctx, "/data.Data/getDeviceOnlineTimeList", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *dataClient) GetDeviceOnlineTimeById(ctx context.Context, in *IDReq, opts ...grpc.CallOption) (*DeviceOnlineTimeInfo, error) {
	out := new(DeviceOnlineTimeInfo)
	err := c.cc.Invoke(ctx, "/data.Data/getDeviceOnlineTimeById", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *dataClient) DeleteDeviceOnlineTime(ctx context.Context, in *IDsReq, opts ...grpc.CallOption) (*BaseResp, error) {
	out := new(BaseResp)
	err := c.cc.Invoke(ctx, "/data.Data/deleteDeviceOnlineTime", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *dataClient) SyncDeviceOnlineTime(ctx context.Context, in *SyncDeviceOnlineTimeReq, opts ...grpc.CallOption) (*BaseResp, error) {
	out := new(BaseResp)
	err := c.cc.Invoke(ctx, "/data.Data/syncDeviceOnlineTime", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *dataClient) CreateDeviceOnTimeDaily(ctx context.Context, in *DeviceOnTimeDailyInfo, opts ...grpc.CallOption) (*BaseIDResp, error) {
	out := new(BaseIDResp)
	err := c.cc.Invoke(ctx, "/data.Data/createDeviceOnTimeDaily", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *dataClient) UpdateDeviceOnTimeDaily(ctx context.Context, in *DeviceOnTimeDailyInfo, opts ...grpc.CallOption) (*BaseResp, error) {
	out := new(BaseResp)
	err := c.cc.Invoke(ctx, "/data.Data/updateDeviceOnTimeDaily", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *dataClient) GetDeviceOnTimeDailyList(ctx context.Context, in *DeviceOnTimeDailyListReq, opts ...grpc.CallOption) (*DeviceOnTimeDailyListResp, error) {
	out := new(DeviceOnTimeDailyListResp)
	err := c.cc.Invoke(ctx, "/data.Data/getDeviceOnTimeDailyList", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *dataClient) GetDeviceOnTimeDailyById(ctx context.Context, in *IDReq, opts ...grpc.CallOption) (*DeviceOnTimeDailyInfo, error) {
	out := new(DeviceOnTimeDailyInfo)
	err := c.cc.Invoke(ctx, "/data.Data/getDeviceOnTimeDailyById", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *dataClient) DeleteDeviceOnTimeDaily(ctx context.Context, in *IDsReq, opts ...grpc.CallOption) (*BaseResp, error) {
	out := new(BaseResp)
	err := c.cc.Invoke(ctx, "/data.Data/deleteDeviceOnTimeDaily", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *dataClient) SyncDeviceOnTimeDaily(ctx context.Context, in *SyncDeviceOnTimeDailyReq, opts ...grpc.CallOption) (*BaseResp, error) {
	out := new(BaseResp)
	err := c.cc.Invoke(ctx, "/data.Data/syncDeviceOnTimeDaily", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *dataClient) SyncDeviceProperty(ctx context.Context, in *SyncDevicePropertyReq, opts ...grpc.CallOption) (*SyncDevicePropertyResp, error) {
	out := new(SyncDevicePropertyResp)
	err := c.cc.Invoke(ctx, "/data.Data/syncDeviceProperty", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *dataClient) AnalyseDeviceTag(ctx context.Context, in *AnalyseDeviceTagReq, opts ...grpc.CallOption) (*BaseResp, error) {
	out := new(BaseResp)
	err := c.cc.Invoke(ctx, "/data.Data/analyseDeviceTag", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *dataClient) CreateDeviceUpsterCycle(ctx context.Context, in *DeviceUpsterCycleInfo, opts ...grpc.CallOption) (*BaseIDResp, error) {
	out := new(BaseIDResp)
	err := c.cc.Invoke(ctx, "/data.Data/createDeviceUpsterCycle", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *dataClient) UpdateDeviceUpsterCycle(ctx context.Context, in *DeviceUpsterCycleInfo, opts ...grpc.CallOption) (*BaseResp, error) {
	out := new(BaseResp)
	err := c.cc.Invoke(ctx, "/data.Data/updateDeviceUpsterCycle", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *dataClient) GetDeviceUpsterCycleList(ctx context.Context, in *DeviceUpsterCycleListReq, opts ...grpc.CallOption) (*DeviceUpsterCycleListResp, error) {
	out := new(DeviceUpsterCycleListResp)
	err := c.cc.Invoke(ctx, "/data.Data/getDeviceUpsterCycleList", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *dataClient) GetDeviceUpsterCycleById(ctx context.Context, in *IDReq, opts ...grpc.CallOption) (*DeviceUpsterCycleInfo, error) {
	out := new(DeviceUpsterCycleInfo)
	err := c.cc.Invoke(ctx, "/data.Data/getDeviceUpsterCycleById", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *dataClient) DeleteDeviceUpsterCycle(ctx context.Context, in *IDsReq, opts ...grpc.CallOption) (*BaseResp, error) {
	out := new(BaseResp)
	err := c.cc.Invoke(ctx, "/data.Data/deleteDeviceUpsterCycle", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *dataClient) SyncDeviceUpsterCycle(ctx context.Context, in *SyncDeviceUpsterCycleReq, opts ...grpc.CallOption) (*BaseResp, error) {
	out := new(BaseResp)
	err := c.cc.Invoke(ctx, "/data.Data/syncDeviceUpsterCycle", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *dataClient) CreateDeviceUpsterStatistics(ctx context.Context, in *DeviceUpsterStatisticsInfo, opts ...grpc.CallOption) (*BaseIDResp, error) {
	out := new(BaseIDResp)
	err := c.cc.Invoke(ctx, "/data.Data/createDeviceUpsterStatistics", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *dataClient) UpdateDeviceUpsterStatistics(ctx context.Context, in *DeviceUpsterStatisticsInfo, opts ...grpc.CallOption) (*BaseResp, error) {
	out := new(BaseResp)
	err := c.cc.Invoke(ctx, "/data.Data/updateDeviceUpsterStatistics", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *dataClient) GetDeviceUpsterStatisticsList(ctx context.Context, in *DeviceUpsterStatisticsListReq, opts ...grpc.CallOption) (*DeviceUpsterStatisticsListResp, error) {
	out := new(DeviceUpsterStatisticsListResp)
	err := c.cc.Invoke(ctx, "/data.Data/getDeviceUpsterStatisticsList", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *dataClient) GetDeviceUpsterStatisticsById(ctx context.Context, in *IDReq, opts ...grpc.CallOption) (*DeviceUpsterStatisticsInfo, error) {
	out := new(DeviceUpsterStatisticsInfo)
	err := c.cc.Invoke(ctx, "/data.Data/getDeviceUpsterStatisticsById", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *dataClient) DeleteDeviceUpsterStatistics(ctx context.Context, in *IDsReq, opts ...grpc.CallOption) (*BaseResp, error) {
	out := new(BaseResp)
	err := c.cc.Invoke(ctx, "/data.Data/deleteDeviceUpsterStatistics", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *dataClient) AnalyseDeviceUpsterStatistics(ctx context.Context, in *AnalyseDeviceUpsterStatisticsReq, opts ...grpc.CallOption) (*BaseResp, error) {
	out := new(BaseResp)
	err := c.cc.Invoke(ctx, "/data.Data/analyseDeviceUpsterStatistics", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

// DataServer is the server API for Data service.
// All implementations must embed UnimplementedDataServer
// for forward compatibility
type DataServer interface {
	// group: base
	InitDatabase(context.Context, *Empty) (*BaseResp, error)
	// DeviceDuration management
	// group: device_duration
	CreateDeviceDuration(context.Context, *DeviceDurationInfo) (*BaseIDResp, error)
	// group: device_duration
	UpdateDeviceDuration(context.Context, *DeviceDurationInfo) (*BaseResp, error)
	// group: device_duration
	GetDeviceDurationList(context.Context, *DeviceDurationListReq) (*DeviceDurationListResp, error)
	// group: device_duration
	GetDeviceDurationById(context.Context, *IDReq) (*DeviceDurationInfo, error)
	// group: device_duration
	DeleteDeviceDuration(context.Context, *IDsReq) (*BaseResp, error)
	// group: device_duration
	AnalyseDeviceDuration(context.Context, *AnalyseDeviceDurationReq) (*BaseResp, error)
	// DeviceDurationElephant management
	// group: device_duration_elephant
	CreateDeviceDurationElephant(context.Context, *DeviceDurationElephantInfo) (*BaseIDResp, error)
	// group: device_duration_elephant
	UpdateDeviceDurationElephant(context.Context, *DeviceDurationElephantInfo) (*BaseResp, error)
	// group: device_duration_elephant
	GetDeviceDurationElephantList(context.Context, *DeviceDurationElephantListReq) (*DeviceDurationElephantListResp, error)
	// group: device_duration_elephant
	GetDeviceDurationElephantById(context.Context, *IDReq) (*DeviceDurationElephantInfo, error)
	// group: device_duration_elephant
	DeleteDeviceDurationElephant(context.Context, *IDsReq) (*BaseResp, error)
	// group: device_duration_elephant
	AnalyseDeviceDurationElephant(context.Context, *AnalyseDeviceDurationElephantReq) (*BaseResp, error)
	// DeviceEvent management
	// group: device_event
	CreateDeviceEvent(context.Context, *DeviceEventInfo) (*BaseIDResp, error)
	// group: device_event
	UpdateDeviceEvent(context.Context, *DeviceEventInfo) (*BaseResp, error)
	// group: device_event
	GetDeviceEventList(context.Context, *DeviceEventListReq) (*DeviceEventListResp, error)
	// group: device_event
	GetDeviceEventById(context.Context, *IDReq) (*DeviceEventInfo, error)
	// group: device_event
	DeleteDeviceEvent(context.Context, *IDsReq) (*BaseResp, error)
	// group: device_event
	SyncDeviceEvent(context.Context, *SyncDeviceEventReq) (*BaseResp, error)
	// DeviceKpi management
	// group: device_kpi
	CreateDeviceKpi(context.Context, *DeviceKpiInfo) (*BaseIDResp, error)
	// group: device_kpi
	UpdateDeviceKpi(context.Context, *DeviceKpiInfo) (*BaseResp, error)
	// group: device_kpi
	GetDeviceKpiList(context.Context, *DeviceKpiListReq) (*DeviceKpiListResp, error)
	// group: device_kpi
	GetDeviceKpiById(context.Context, *IDReq) (*DeviceKpiInfo, error)
	// group: device_kpi
	GetDeviceKpiByIotID(context.Context, *KpiIotIDReq) (*DeviceKpiInfo, error)
	// group: device_kpi
	DeleteDeviceKpi(context.Context, *IDsReq) (*BaseResp, error)
	// group: device_kpi
	AnalyseDeviceKpi(context.Context, *AnalyseDeviceKpiReq) (*BaseResp, error)
	// DeviceOfflineTime management
	// group: device_offline_time
	CreateDeviceOfflineTime(context.Context, *DeviceOfflineTimeInfo) (*BaseIDResp, error)
	// group: device_offline_time
	UpdateDeviceOfflineTime(context.Context, *DeviceOfflineTimeInfo) (*BaseResp, error)
	// group: device_offline_time
	GetDeviceOfflineTimeList(context.Context, *DeviceOfflineTimeListReq) (*DeviceOfflineTimeListResp, error)
	// group: device_offline_time
	GetDeviceOfflineTimeById(context.Context, *IDReq) (*DeviceOfflineTimeInfo, error)
	// group: device_offline_time
	DeleteDeviceOfflineTime(context.Context, *IDsReq) (*BaseResp, error)
	// group: device_offline_time
	SyncDeviceOfflineTime(context.Context, *SyncDeviceOfflineTimeReq) (*BaseResp, error)
	// DeviceOnlineTime management
	// group: device_online_time
	CreateDeviceOnlineTime(context.Context, *DeviceOnlineTimeInfo) (*BaseIDResp, error)
	// group: device_online_time
	UpdateDeviceOnlineTime(context.Context, *DeviceOnlineTimeInfo) (*BaseResp, error)
	// group: device_online_time
	GetDeviceOnlineTimeList(context.Context, *DeviceOnlineTimeListReq) (*DeviceOnlineTimeListResp, error)
	// group: device_online_time
	GetDeviceOnlineTimeById(context.Context, *IDReq) (*DeviceOnlineTimeInfo, error)
	// group: device_online_time
	DeleteDeviceOnlineTime(context.Context, *IDsReq) (*BaseResp, error)
	// group: device_online_time
	SyncDeviceOnlineTime(context.Context, *SyncDeviceOnlineTimeReq) (*BaseResp, error)
	// DeviceOnTimeDaily management
	// group: device_on_time_daily
	CreateDeviceOnTimeDaily(context.Context, *DeviceOnTimeDailyInfo) (*BaseIDResp, error)
	// group: device_on_time_daily
	UpdateDeviceOnTimeDaily(context.Context, *DeviceOnTimeDailyInfo) (*BaseResp, error)
	// group: device_on_time_daily
	GetDeviceOnTimeDailyList(context.Context, *DeviceOnTimeDailyListReq) (*DeviceOnTimeDailyListResp, error)
	// group: device_on_time_daily
	GetDeviceOnTimeDailyById(context.Context, *IDReq) (*DeviceOnTimeDailyInfo, error)
	// group: device_on_time_daily
	DeleteDeviceOnTimeDaily(context.Context, *IDsReq) (*BaseResp, error)
	// group: device_on_time_daily
	SyncDeviceOnTimeDaily(context.Context, *SyncDeviceOnTimeDailyReq) (*BaseResp, error)
	// DeviceProperty management
	// group: device_property
	SyncDeviceProperty(context.Context, *SyncDevicePropertyReq) (*SyncDevicePropertyResp, error)
	// group: device_tag
	AnalyseDeviceTag(context.Context, *AnalyseDeviceTagReq) (*BaseResp, error)
	// DeviceUpsterCycle management
	// group: device_upster_cycle
	CreateDeviceUpsterCycle(context.Context, *DeviceUpsterCycleInfo) (*BaseIDResp, error)
	// group: device_upster_cycle
	UpdateDeviceUpsterCycle(context.Context, *DeviceUpsterCycleInfo) (*BaseResp, error)
	// group: device_upster_cycle
	GetDeviceUpsterCycleList(context.Context, *DeviceUpsterCycleListReq) (*DeviceUpsterCycleListResp, error)
	// group: device_upster_cycle
	GetDeviceUpsterCycleById(context.Context, *IDReq) (*DeviceUpsterCycleInfo, error)
	// group: device_upster_cycle
	DeleteDeviceUpsterCycle(context.Context, *IDsReq) (*BaseResp, error)
	// group: device_upster_cycle
	SyncDeviceUpsterCycle(context.Context, *SyncDeviceUpsterCycleReq) (*BaseResp, error)
	// DeviceUpsterStatistics management
	// group: device_upster_statistics
	CreateDeviceUpsterStatistics(context.Context, *DeviceUpsterStatisticsInfo) (*BaseIDResp, error)
	// group: device_upster_statistics
	UpdateDeviceUpsterStatistics(context.Context, *DeviceUpsterStatisticsInfo) (*BaseResp, error)
	// group: device_upster_statistics
	GetDeviceUpsterStatisticsList(context.Context, *DeviceUpsterStatisticsListReq) (*DeviceUpsterStatisticsListResp, error)
	// group: device_upster_statistics
	GetDeviceUpsterStatisticsById(context.Context, *IDReq) (*DeviceUpsterStatisticsInfo, error)
	// group: device_upster_statistics
	DeleteDeviceUpsterStatistics(context.Context, *IDsReq) (*BaseResp, error)
	// group: device_upster_statistics
	AnalyseDeviceUpsterStatistics(context.Context, *AnalyseDeviceUpsterStatisticsReq) (*BaseResp, error)
	mustEmbedUnimplementedDataServer()
}

// UnimplementedDataServer must be embedded to have forward compatible implementations.
type UnimplementedDataServer struct {
}

func (UnimplementedDataServer) InitDatabase(context.Context, *Empty) (*BaseResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method InitDatabase not implemented")
}
func (UnimplementedDataServer) CreateDeviceDuration(context.Context, *DeviceDurationInfo) (*BaseIDResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method CreateDeviceDuration not implemented")
}
func (UnimplementedDataServer) UpdateDeviceDuration(context.Context, *DeviceDurationInfo) (*BaseResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method UpdateDeviceDuration not implemented")
}
func (UnimplementedDataServer) GetDeviceDurationList(context.Context, *DeviceDurationListReq) (*DeviceDurationListResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetDeviceDurationList not implemented")
}
func (UnimplementedDataServer) GetDeviceDurationById(context.Context, *IDReq) (*DeviceDurationInfo, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetDeviceDurationById not implemented")
}
func (UnimplementedDataServer) DeleteDeviceDuration(context.Context, *IDsReq) (*BaseResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method DeleteDeviceDuration not implemented")
}
func (UnimplementedDataServer) AnalyseDeviceDuration(context.Context, *AnalyseDeviceDurationReq) (*BaseResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method AnalyseDeviceDuration not implemented")
}
func (UnimplementedDataServer) CreateDeviceDurationElephant(context.Context, *DeviceDurationElephantInfo) (*BaseIDResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method CreateDeviceDurationElephant not implemented")
}
func (UnimplementedDataServer) UpdateDeviceDurationElephant(context.Context, *DeviceDurationElephantInfo) (*BaseResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method UpdateDeviceDurationElephant not implemented")
}
func (UnimplementedDataServer) GetDeviceDurationElephantList(context.Context, *DeviceDurationElephantListReq) (*DeviceDurationElephantListResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetDeviceDurationElephantList not implemented")
}
func (UnimplementedDataServer) GetDeviceDurationElephantById(context.Context, *IDReq) (*DeviceDurationElephantInfo, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetDeviceDurationElephantById not implemented")
}
func (UnimplementedDataServer) DeleteDeviceDurationElephant(context.Context, *IDsReq) (*BaseResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method DeleteDeviceDurationElephant not implemented")
}
func (UnimplementedDataServer) AnalyseDeviceDurationElephant(context.Context, *AnalyseDeviceDurationElephantReq) (*BaseResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method AnalyseDeviceDurationElephant not implemented")
}
func (UnimplementedDataServer) CreateDeviceEvent(context.Context, *DeviceEventInfo) (*BaseIDResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method CreateDeviceEvent not implemented")
}
func (UnimplementedDataServer) UpdateDeviceEvent(context.Context, *DeviceEventInfo) (*BaseResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method UpdateDeviceEvent not implemented")
}
func (UnimplementedDataServer) GetDeviceEventList(context.Context, *DeviceEventListReq) (*DeviceEventListResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetDeviceEventList not implemented")
}
func (UnimplementedDataServer) GetDeviceEventById(context.Context, *IDReq) (*DeviceEventInfo, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetDeviceEventById not implemented")
}
func (UnimplementedDataServer) DeleteDeviceEvent(context.Context, *IDsReq) (*BaseResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method DeleteDeviceEvent not implemented")
}
func (UnimplementedDataServer) SyncDeviceEvent(context.Context, *SyncDeviceEventReq) (*BaseResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method SyncDeviceEvent not implemented")
}
func (UnimplementedDataServer) CreateDeviceKpi(context.Context, *DeviceKpiInfo) (*BaseIDResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method CreateDeviceKpi not implemented")
}
func (UnimplementedDataServer) UpdateDeviceKpi(context.Context, *DeviceKpiInfo) (*BaseResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method UpdateDeviceKpi not implemented")
}
func (UnimplementedDataServer) GetDeviceKpiList(context.Context, *DeviceKpiListReq) (*DeviceKpiListResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetDeviceKpiList not implemented")
}
func (UnimplementedDataServer) GetDeviceKpiById(context.Context, *IDReq) (*DeviceKpiInfo, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetDeviceKpiById not implemented")
}
func (UnimplementedDataServer) GetDeviceKpiByIotID(context.Context, *KpiIotIDReq) (*DeviceKpiInfo, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetDeviceKpiByIotID not implemented")
}
func (UnimplementedDataServer) DeleteDeviceKpi(context.Context, *IDsReq) (*BaseResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method DeleteDeviceKpi not implemented")
}
func (UnimplementedDataServer) AnalyseDeviceKpi(context.Context, *AnalyseDeviceKpiReq) (*BaseResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method AnalyseDeviceKpi not implemented")
}
func (UnimplementedDataServer) CreateDeviceOfflineTime(context.Context, *DeviceOfflineTimeInfo) (*BaseIDResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method CreateDeviceOfflineTime not implemented")
}
func (UnimplementedDataServer) UpdateDeviceOfflineTime(context.Context, *DeviceOfflineTimeInfo) (*BaseResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method UpdateDeviceOfflineTime not implemented")
}
func (UnimplementedDataServer) GetDeviceOfflineTimeList(context.Context, *DeviceOfflineTimeListReq) (*DeviceOfflineTimeListResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetDeviceOfflineTimeList not implemented")
}
func (UnimplementedDataServer) GetDeviceOfflineTimeById(context.Context, *IDReq) (*DeviceOfflineTimeInfo, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetDeviceOfflineTimeById not implemented")
}
func (UnimplementedDataServer) DeleteDeviceOfflineTime(context.Context, *IDsReq) (*BaseResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method DeleteDeviceOfflineTime not implemented")
}
func (UnimplementedDataServer) SyncDeviceOfflineTime(context.Context, *SyncDeviceOfflineTimeReq) (*BaseResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method SyncDeviceOfflineTime not implemented")
}
func (UnimplementedDataServer) CreateDeviceOnlineTime(context.Context, *DeviceOnlineTimeInfo) (*BaseIDResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method CreateDeviceOnlineTime not implemented")
}
func (UnimplementedDataServer) UpdateDeviceOnlineTime(context.Context, *DeviceOnlineTimeInfo) (*BaseResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method UpdateDeviceOnlineTime not implemented")
}
func (UnimplementedDataServer) GetDeviceOnlineTimeList(context.Context, *DeviceOnlineTimeListReq) (*DeviceOnlineTimeListResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetDeviceOnlineTimeList not implemented")
}
func (UnimplementedDataServer) GetDeviceOnlineTimeById(context.Context, *IDReq) (*DeviceOnlineTimeInfo, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetDeviceOnlineTimeById not implemented")
}
func (UnimplementedDataServer) DeleteDeviceOnlineTime(context.Context, *IDsReq) (*BaseResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method DeleteDeviceOnlineTime not implemented")
}
func (UnimplementedDataServer) SyncDeviceOnlineTime(context.Context, *SyncDeviceOnlineTimeReq) (*BaseResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method SyncDeviceOnlineTime not implemented")
}
func (UnimplementedDataServer) CreateDeviceOnTimeDaily(context.Context, *DeviceOnTimeDailyInfo) (*BaseIDResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method CreateDeviceOnTimeDaily not implemented")
}
func (UnimplementedDataServer) UpdateDeviceOnTimeDaily(context.Context, *DeviceOnTimeDailyInfo) (*BaseResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method UpdateDeviceOnTimeDaily not implemented")
}
func (UnimplementedDataServer) GetDeviceOnTimeDailyList(context.Context, *DeviceOnTimeDailyListReq) (*DeviceOnTimeDailyListResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetDeviceOnTimeDailyList not implemented")
}
func (UnimplementedDataServer) GetDeviceOnTimeDailyById(context.Context, *IDReq) (*DeviceOnTimeDailyInfo, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetDeviceOnTimeDailyById not implemented")
}
func (UnimplementedDataServer) DeleteDeviceOnTimeDaily(context.Context, *IDsReq) (*BaseResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method DeleteDeviceOnTimeDaily not implemented")
}
func (UnimplementedDataServer) SyncDeviceOnTimeDaily(context.Context, *SyncDeviceOnTimeDailyReq) (*BaseResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method SyncDeviceOnTimeDaily not implemented")
}
func (UnimplementedDataServer) SyncDeviceProperty(context.Context, *SyncDevicePropertyReq) (*SyncDevicePropertyResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method SyncDeviceProperty not implemented")
}
func (UnimplementedDataServer) AnalyseDeviceTag(context.Context, *AnalyseDeviceTagReq) (*BaseResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method AnalyseDeviceTag not implemented")
}
func (UnimplementedDataServer) CreateDeviceUpsterCycle(context.Context, *DeviceUpsterCycleInfo) (*BaseIDResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method CreateDeviceUpsterCycle not implemented")
}
func (UnimplementedDataServer) UpdateDeviceUpsterCycle(context.Context, *DeviceUpsterCycleInfo) (*BaseResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method UpdateDeviceUpsterCycle not implemented")
}
func (UnimplementedDataServer) GetDeviceUpsterCycleList(context.Context, *DeviceUpsterCycleListReq) (*DeviceUpsterCycleListResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetDeviceUpsterCycleList not implemented")
}
func (UnimplementedDataServer) GetDeviceUpsterCycleById(context.Context, *IDReq) (*DeviceUpsterCycleInfo, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetDeviceUpsterCycleById not implemented")
}
func (UnimplementedDataServer) DeleteDeviceUpsterCycle(context.Context, *IDsReq) (*BaseResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method DeleteDeviceUpsterCycle not implemented")
}
func (UnimplementedDataServer) SyncDeviceUpsterCycle(context.Context, *SyncDeviceUpsterCycleReq) (*BaseResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method SyncDeviceUpsterCycle not implemented")
}
func (UnimplementedDataServer) CreateDeviceUpsterStatistics(context.Context, *DeviceUpsterStatisticsInfo) (*BaseIDResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method CreateDeviceUpsterStatistics not implemented")
}
func (UnimplementedDataServer) UpdateDeviceUpsterStatistics(context.Context, *DeviceUpsterStatisticsInfo) (*BaseResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method UpdateDeviceUpsterStatistics not implemented")
}
func (UnimplementedDataServer) GetDeviceUpsterStatisticsList(context.Context, *DeviceUpsterStatisticsListReq) (*DeviceUpsterStatisticsListResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetDeviceUpsterStatisticsList not implemented")
}
func (UnimplementedDataServer) GetDeviceUpsterStatisticsById(context.Context, *IDReq) (*DeviceUpsterStatisticsInfo, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetDeviceUpsterStatisticsById not implemented")
}
func (UnimplementedDataServer) DeleteDeviceUpsterStatistics(context.Context, *IDsReq) (*BaseResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method DeleteDeviceUpsterStatistics not implemented")
}
func (UnimplementedDataServer) AnalyseDeviceUpsterStatistics(context.Context, *AnalyseDeviceUpsterStatisticsReq) (*BaseResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method AnalyseDeviceUpsterStatistics not implemented")
}
func (UnimplementedDataServer) mustEmbedUnimplementedDataServer() {}

// UnsafeDataServer may be embedded to opt out of forward compatibility for this service.
// Use of this interface is not recommended, as added methods to DataServer will
// result in compilation errors.
type UnsafeDataServer interface {
	mustEmbedUnimplementedDataServer()
}

func RegisterDataServer(s grpc.ServiceRegistrar, srv DataServer) {
	s.RegisterService(&Data_ServiceDesc, srv)
}

func _Data_InitDatabase_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(Empty)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DataServer).InitDatabase(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/data.Data/initDatabase",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DataServer).InitDatabase(ctx, req.(*Empty))
	}
	return interceptor(ctx, in, info, handler)
}

func _Data_CreateDeviceDuration_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(DeviceDurationInfo)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DataServer).CreateDeviceDuration(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/data.Data/createDeviceDuration",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DataServer).CreateDeviceDuration(ctx, req.(*DeviceDurationInfo))
	}
	return interceptor(ctx, in, info, handler)
}

func _Data_UpdateDeviceDuration_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(DeviceDurationInfo)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DataServer).UpdateDeviceDuration(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/data.Data/updateDeviceDuration",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DataServer).UpdateDeviceDuration(ctx, req.(*DeviceDurationInfo))
	}
	return interceptor(ctx, in, info, handler)
}

func _Data_GetDeviceDurationList_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(DeviceDurationListReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DataServer).GetDeviceDurationList(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/data.Data/getDeviceDurationList",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DataServer).GetDeviceDurationList(ctx, req.(*DeviceDurationListReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _Data_GetDeviceDurationById_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(IDReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DataServer).GetDeviceDurationById(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/data.Data/getDeviceDurationById",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DataServer).GetDeviceDurationById(ctx, req.(*IDReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _Data_DeleteDeviceDuration_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(IDsReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DataServer).DeleteDeviceDuration(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/data.Data/deleteDeviceDuration",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DataServer).DeleteDeviceDuration(ctx, req.(*IDsReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _Data_AnalyseDeviceDuration_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(AnalyseDeviceDurationReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DataServer).AnalyseDeviceDuration(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/data.Data/analyseDeviceDuration",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DataServer).AnalyseDeviceDuration(ctx, req.(*AnalyseDeviceDurationReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _Data_CreateDeviceDurationElephant_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(DeviceDurationElephantInfo)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DataServer).CreateDeviceDurationElephant(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/data.Data/createDeviceDurationElephant",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DataServer).CreateDeviceDurationElephant(ctx, req.(*DeviceDurationElephantInfo))
	}
	return interceptor(ctx, in, info, handler)
}

func _Data_UpdateDeviceDurationElephant_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(DeviceDurationElephantInfo)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DataServer).UpdateDeviceDurationElephant(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/data.Data/updateDeviceDurationElephant",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DataServer).UpdateDeviceDurationElephant(ctx, req.(*DeviceDurationElephantInfo))
	}
	return interceptor(ctx, in, info, handler)
}

func _Data_GetDeviceDurationElephantList_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(DeviceDurationElephantListReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DataServer).GetDeviceDurationElephantList(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/data.Data/getDeviceDurationElephantList",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DataServer).GetDeviceDurationElephantList(ctx, req.(*DeviceDurationElephantListReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _Data_GetDeviceDurationElephantById_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(IDReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DataServer).GetDeviceDurationElephantById(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/data.Data/getDeviceDurationElephantById",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DataServer).GetDeviceDurationElephantById(ctx, req.(*IDReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _Data_DeleteDeviceDurationElephant_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(IDsReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DataServer).DeleteDeviceDurationElephant(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/data.Data/deleteDeviceDurationElephant",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DataServer).DeleteDeviceDurationElephant(ctx, req.(*IDsReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _Data_AnalyseDeviceDurationElephant_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(AnalyseDeviceDurationElephantReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DataServer).AnalyseDeviceDurationElephant(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/data.Data/analyseDeviceDurationElephant",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DataServer).AnalyseDeviceDurationElephant(ctx, req.(*AnalyseDeviceDurationElephantReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _Data_CreateDeviceEvent_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(DeviceEventInfo)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DataServer).CreateDeviceEvent(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/data.Data/createDeviceEvent",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DataServer).CreateDeviceEvent(ctx, req.(*DeviceEventInfo))
	}
	return interceptor(ctx, in, info, handler)
}

func _Data_UpdateDeviceEvent_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(DeviceEventInfo)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DataServer).UpdateDeviceEvent(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/data.Data/updateDeviceEvent",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DataServer).UpdateDeviceEvent(ctx, req.(*DeviceEventInfo))
	}
	return interceptor(ctx, in, info, handler)
}

func _Data_GetDeviceEventList_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(DeviceEventListReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DataServer).GetDeviceEventList(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/data.Data/getDeviceEventList",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DataServer).GetDeviceEventList(ctx, req.(*DeviceEventListReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _Data_GetDeviceEventById_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(IDReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DataServer).GetDeviceEventById(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/data.Data/getDeviceEventById",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DataServer).GetDeviceEventById(ctx, req.(*IDReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _Data_DeleteDeviceEvent_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(IDsReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DataServer).DeleteDeviceEvent(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/data.Data/deleteDeviceEvent",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DataServer).DeleteDeviceEvent(ctx, req.(*IDsReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _Data_SyncDeviceEvent_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(SyncDeviceEventReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DataServer).SyncDeviceEvent(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/data.Data/syncDeviceEvent",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DataServer).SyncDeviceEvent(ctx, req.(*SyncDeviceEventReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _Data_CreateDeviceKpi_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(DeviceKpiInfo)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DataServer).CreateDeviceKpi(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/data.Data/createDeviceKpi",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DataServer).CreateDeviceKpi(ctx, req.(*DeviceKpiInfo))
	}
	return interceptor(ctx, in, info, handler)
}

func _Data_UpdateDeviceKpi_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(DeviceKpiInfo)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DataServer).UpdateDeviceKpi(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/data.Data/updateDeviceKpi",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DataServer).UpdateDeviceKpi(ctx, req.(*DeviceKpiInfo))
	}
	return interceptor(ctx, in, info, handler)
}

func _Data_GetDeviceKpiList_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(DeviceKpiListReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DataServer).GetDeviceKpiList(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/data.Data/getDeviceKpiList",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DataServer).GetDeviceKpiList(ctx, req.(*DeviceKpiListReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _Data_GetDeviceKpiById_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(IDReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DataServer).GetDeviceKpiById(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/data.Data/getDeviceKpiById",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DataServer).GetDeviceKpiById(ctx, req.(*IDReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _Data_GetDeviceKpiByIotID_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(KpiIotIDReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DataServer).GetDeviceKpiByIotID(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/data.Data/getDeviceKpiByIotID",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DataServer).GetDeviceKpiByIotID(ctx, req.(*KpiIotIDReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _Data_DeleteDeviceKpi_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(IDsReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DataServer).DeleteDeviceKpi(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/data.Data/deleteDeviceKpi",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DataServer).DeleteDeviceKpi(ctx, req.(*IDsReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _Data_AnalyseDeviceKpi_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(AnalyseDeviceKpiReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DataServer).AnalyseDeviceKpi(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/data.Data/analyseDeviceKpi",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DataServer).AnalyseDeviceKpi(ctx, req.(*AnalyseDeviceKpiReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _Data_CreateDeviceOfflineTime_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(DeviceOfflineTimeInfo)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DataServer).CreateDeviceOfflineTime(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/data.Data/createDeviceOfflineTime",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DataServer).CreateDeviceOfflineTime(ctx, req.(*DeviceOfflineTimeInfo))
	}
	return interceptor(ctx, in, info, handler)
}

func _Data_UpdateDeviceOfflineTime_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(DeviceOfflineTimeInfo)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DataServer).UpdateDeviceOfflineTime(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/data.Data/updateDeviceOfflineTime",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DataServer).UpdateDeviceOfflineTime(ctx, req.(*DeviceOfflineTimeInfo))
	}
	return interceptor(ctx, in, info, handler)
}

func _Data_GetDeviceOfflineTimeList_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(DeviceOfflineTimeListReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DataServer).GetDeviceOfflineTimeList(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/data.Data/getDeviceOfflineTimeList",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DataServer).GetDeviceOfflineTimeList(ctx, req.(*DeviceOfflineTimeListReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _Data_GetDeviceOfflineTimeById_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(IDReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DataServer).GetDeviceOfflineTimeById(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/data.Data/getDeviceOfflineTimeById",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DataServer).GetDeviceOfflineTimeById(ctx, req.(*IDReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _Data_DeleteDeviceOfflineTime_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(IDsReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DataServer).DeleteDeviceOfflineTime(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/data.Data/deleteDeviceOfflineTime",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DataServer).DeleteDeviceOfflineTime(ctx, req.(*IDsReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _Data_SyncDeviceOfflineTime_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(SyncDeviceOfflineTimeReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DataServer).SyncDeviceOfflineTime(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/data.Data/syncDeviceOfflineTime",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DataServer).SyncDeviceOfflineTime(ctx, req.(*SyncDeviceOfflineTimeReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _Data_CreateDeviceOnlineTime_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(DeviceOnlineTimeInfo)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DataServer).CreateDeviceOnlineTime(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/data.Data/createDeviceOnlineTime",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DataServer).CreateDeviceOnlineTime(ctx, req.(*DeviceOnlineTimeInfo))
	}
	return interceptor(ctx, in, info, handler)
}

func _Data_UpdateDeviceOnlineTime_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(DeviceOnlineTimeInfo)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DataServer).UpdateDeviceOnlineTime(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/data.Data/updateDeviceOnlineTime",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DataServer).UpdateDeviceOnlineTime(ctx, req.(*DeviceOnlineTimeInfo))
	}
	return interceptor(ctx, in, info, handler)
}

func _Data_GetDeviceOnlineTimeList_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(DeviceOnlineTimeListReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DataServer).GetDeviceOnlineTimeList(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/data.Data/getDeviceOnlineTimeList",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DataServer).GetDeviceOnlineTimeList(ctx, req.(*DeviceOnlineTimeListReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _Data_GetDeviceOnlineTimeById_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(IDReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DataServer).GetDeviceOnlineTimeById(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/data.Data/getDeviceOnlineTimeById",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DataServer).GetDeviceOnlineTimeById(ctx, req.(*IDReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _Data_DeleteDeviceOnlineTime_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(IDsReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DataServer).DeleteDeviceOnlineTime(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/data.Data/deleteDeviceOnlineTime",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DataServer).DeleteDeviceOnlineTime(ctx, req.(*IDsReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _Data_SyncDeviceOnlineTime_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(SyncDeviceOnlineTimeReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DataServer).SyncDeviceOnlineTime(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/data.Data/syncDeviceOnlineTime",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DataServer).SyncDeviceOnlineTime(ctx, req.(*SyncDeviceOnlineTimeReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _Data_CreateDeviceOnTimeDaily_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(DeviceOnTimeDailyInfo)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DataServer).CreateDeviceOnTimeDaily(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/data.Data/createDeviceOnTimeDaily",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DataServer).CreateDeviceOnTimeDaily(ctx, req.(*DeviceOnTimeDailyInfo))
	}
	return interceptor(ctx, in, info, handler)
}

func _Data_UpdateDeviceOnTimeDaily_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(DeviceOnTimeDailyInfo)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DataServer).UpdateDeviceOnTimeDaily(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/data.Data/updateDeviceOnTimeDaily",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DataServer).UpdateDeviceOnTimeDaily(ctx, req.(*DeviceOnTimeDailyInfo))
	}
	return interceptor(ctx, in, info, handler)
}

func _Data_GetDeviceOnTimeDailyList_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(DeviceOnTimeDailyListReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DataServer).GetDeviceOnTimeDailyList(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/data.Data/getDeviceOnTimeDailyList",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DataServer).GetDeviceOnTimeDailyList(ctx, req.(*DeviceOnTimeDailyListReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _Data_GetDeviceOnTimeDailyById_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(IDReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DataServer).GetDeviceOnTimeDailyById(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/data.Data/getDeviceOnTimeDailyById",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DataServer).GetDeviceOnTimeDailyById(ctx, req.(*IDReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _Data_DeleteDeviceOnTimeDaily_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(IDsReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DataServer).DeleteDeviceOnTimeDaily(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/data.Data/deleteDeviceOnTimeDaily",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DataServer).DeleteDeviceOnTimeDaily(ctx, req.(*IDsReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _Data_SyncDeviceOnTimeDaily_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(SyncDeviceOnTimeDailyReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DataServer).SyncDeviceOnTimeDaily(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/data.Data/syncDeviceOnTimeDaily",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DataServer).SyncDeviceOnTimeDaily(ctx, req.(*SyncDeviceOnTimeDailyReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _Data_SyncDeviceProperty_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(SyncDevicePropertyReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DataServer).SyncDeviceProperty(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/data.Data/syncDeviceProperty",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DataServer).SyncDeviceProperty(ctx, req.(*SyncDevicePropertyReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _Data_AnalyseDeviceTag_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(AnalyseDeviceTagReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DataServer).AnalyseDeviceTag(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/data.Data/analyseDeviceTag",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DataServer).AnalyseDeviceTag(ctx, req.(*AnalyseDeviceTagReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _Data_CreateDeviceUpsterCycle_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(DeviceUpsterCycleInfo)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DataServer).CreateDeviceUpsterCycle(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/data.Data/createDeviceUpsterCycle",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DataServer).CreateDeviceUpsterCycle(ctx, req.(*DeviceUpsterCycleInfo))
	}
	return interceptor(ctx, in, info, handler)
}

func _Data_UpdateDeviceUpsterCycle_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(DeviceUpsterCycleInfo)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DataServer).UpdateDeviceUpsterCycle(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/data.Data/updateDeviceUpsterCycle",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DataServer).UpdateDeviceUpsterCycle(ctx, req.(*DeviceUpsterCycleInfo))
	}
	return interceptor(ctx, in, info, handler)
}

func _Data_GetDeviceUpsterCycleList_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(DeviceUpsterCycleListReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DataServer).GetDeviceUpsterCycleList(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/data.Data/getDeviceUpsterCycleList",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DataServer).GetDeviceUpsterCycleList(ctx, req.(*DeviceUpsterCycleListReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _Data_GetDeviceUpsterCycleById_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(IDReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DataServer).GetDeviceUpsterCycleById(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/data.Data/getDeviceUpsterCycleById",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DataServer).GetDeviceUpsterCycleById(ctx, req.(*IDReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _Data_DeleteDeviceUpsterCycle_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(IDsReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DataServer).DeleteDeviceUpsterCycle(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/data.Data/deleteDeviceUpsterCycle",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DataServer).DeleteDeviceUpsterCycle(ctx, req.(*IDsReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _Data_SyncDeviceUpsterCycle_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(SyncDeviceUpsterCycleReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DataServer).SyncDeviceUpsterCycle(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/data.Data/syncDeviceUpsterCycle",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DataServer).SyncDeviceUpsterCycle(ctx, req.(*SyncDeviceUpsterCycleReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _Data_CreateDeviceUpsterStatistics_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(DeviceUpsterStatisticsInfo)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DataServer).CreateDeviceUpsterStatistics(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/data.Data/createDeviceUpsterStatistics",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DataServer).CreateDeviceUpsterStatistics(ctx, req.(*DeviceUpsterStatisticsInfo))
	}
	return interceptor(ctx, in, info, handler)
}

func _Data_UpdateDeviceUpsterStatistics_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(DeviceUpsterStatisticsInfo)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DataServer).UpdateDeviceUpsterStatistics(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/data.Data/updateDeviceUpsterStatistics",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DataServer).UpdateDeviceUpsterStatistics(ctx, req.(*DeviceUpsterStatisticsInfo))
	}
	return interceptor(ctx, in, info, handler)
}

func _Data_GetDeviceUpsterStatisticsList_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(DeviceUpsterStatisticsListReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DataServer).GetDeviceUpsterStatisticsList(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/data.Data/getDeviceUpsterStatisticsList",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DataServer).GetDeviceUpsterStatisticsList(ctx, req.(*DeviceUpsterStatisticsListReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _Data_GetDeviceUpsterStatisticsById_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(IDReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DataServer).GetDeviceUpsterStatisticsById(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/data.Data/getDeviceUpsterStatisticsById",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DataServer).GetDeviceUpsterStatisticsById(ctx, req.(*IDReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _Data_DeleteDeviceUpsterStatistics_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(IDsReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DataServer).DeleteDeviceUpsterStatistics(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/data.Data/deleteDeviceUpsterStatistics",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DataServer).DeleteDeviceUpsterStatistics(ctx, req.(*IDsReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _Data_AnalyseDeviceUpsterStatistics_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(AnalyseDeviceUpsterStatisticsReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DataServer).AnalyseDeviceUpsterStatistics(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/data.Data/analyseDeviceUpsterStatistics",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DataServer).AnalyseDeviceUpsterStatistics(ctx, req.(*AnalyseDeviceUpsterStatisticsReq))
	}
	return interceptor(ctx, in, info, handler)
}

// Data_ServiceDesc is the grpc.ServiceDesc for Data service.
// It's only intended for direct use with grpc.RegisterService,
// and not to be introspected or modified (even as a copy)
var Data_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "data.Data",
	HandlerType: (*DataServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "initDatabase",
			Handler:    _Data_InitDatabase_Handler,
		},
		{
			MethodName: "createDeviceDuration",
			Handler:    _Data_CreateDeviceDuration_Handler,
		},
		{
			MethodName: "updateDeviceDuration",
			Handler:    _Data_UpdateDeviceDuration_Handler,
		},
		{
			MethodName: "getDeviceDurationList",
			Handler:    _Data_GetDeviceDurationList_Handler,
		},
		{
			MethodName: "getDeviceDurationById",
			Handler:    _Data_GetDeviceDurationById_Handler,
		},
		{
			MethodName: "deleteDeviceDuration",
			Handler:    _Data_DeleteDeviceDuration_Handler,
		},
		{
			MethodName: "analyseDeviceDuration",
			Handler:    _Data_AnalyseDeviceDuration_Handler,
		},
		{
			MethodName: "createDeviceDurationElephant",
			Handler:    _Data_CreateDeviceDurationElephant_Handler,
		},
		{
			MethodName: "updateDeviceDurationElephant",
			Handler:    _Data_UpdateDeviceDurationElephant_Handler,
		},
		{
			MethodName: "getDeviceDurationElephantList",
			Handler:    _Data_GetDeviceDurationElephantList_Handler,
		},
		{
			MethodName: "getDeviceDurationElephantById",
			Handler:    _Data_GetDeviceDurationElephantById_Handler,
		},
		{
			MethodName: "deleteDeviceDurationElephant",
			Handler:    _Data_DeleteDeviceDurationElephant_Handler,
		},
		{
			MethodName: "analyseDeviceDurationElephant",
			Handler:    _Data_AnalyseDeviceDurationElephant_Handler,
		},
		{
			MethodName: "createDeviceEvent",
			Handler:    _Data_CreateDeviceEvent_Handler,
		},
		{
			MethodName: "updateDeviceEvent",
			Handler:    _Data_UpdateDeviceEvent_Handler,
		},
		{
			MethodName: "getDeviceEventList",
			Handler:    _Data_GetDeviceEventList_Handler,
		},
		{
			MethodName: "getDeviceEventById",
			Handler:    _Data_GetDeviceEventById_Handler,
		},
		{
			MethodName: "deleteDeviceEvent",
			Handler:    _Data_DeleteDeviceEvent_Handler,
		},
		{
			MethodName: "syncDeviceEvent",
			Handler:    _Data_SyncDeviceEvent_Handler,
		},
		{
			MethodName: "createDeviceKpi",
			Handler:    _Data_CreateDeviceKpi_Handler,
		},
		{
			MethodName: "updateDeviceKpi",
			Handler:    _Data_UpdateDeviceKpi_Handler,
		},
		{
			MethodName: "getDeviceKpiList",
			Handler:    _Data_GetDeviceKpiList_Handler,
		},
		{
			MethodName: "getDeviceKpiById",
			Handler:    _Data_GetDeviceKpiById_Handler,
		},
		{
			MethodName: "getDeviceKpiByIotID",
			Handler:    _Data_GetDeviceKpiByIotID_Handler,
		},
		{
			MethodName: "deleteDeviceKpi",
			Handler:    _Data_DeleteDeviceKpi_Handler,
		},
		{
			MethodName: "analyseDeviceKpi",
			Handler:    _Data_AnalyseDeviceKpi_Handler,
		},
		{
			MethodName: "createDeviceOfflineTime",
			Handler:    _Data_CreateDeviceOfflineTime_Handler,
		},
		{
			MethodName: "updateDeviceOfflineTime",
			Handler:    _Data_UpdateDeviceOfflineTime_Handler,
		},
		{
			MethodName: "getDeviceOfflineTimeList",
			Handler:    _Data_GetDeviceOfflineTimeList_Handler,
		},
		{
			MethodName: "getDeviceOfflineTimeById",
			Handler:    _Data_GetDeviceOfflineTimeById_Handler,
		},
		{
			MethodName: "deleteDeviceOfflineTime",
			Handler:    _Data_DeleteDeviceOfflineTime_Handler,
		},
		{
			MethodName: "syncDeviceOfflineTime",
			Handler:    _Data_SyncDeviceOfflineTime_Handler,
		},
		{
			MethodName: "createDeviceOnlineTime",
			Handler:    _Data_CreateDeviceOnlineTime_Handler,
		},
		{
			MethodName: "updateDeviceOnlineTime",
			Handler:    _Data_UpdateDeviceOnlineTime_Handler,
		},
		{
			MethodName: "getDeviceOnlineTimeList",
			Handler:    _Data_GetDeviceOnlineTimeList_Handler,
		},
		{
			MethodName: "getDeviceOnlineTimeById",
			Handler:    _Data_GetDeviceOnlineTimeById_Handler,
		},
		{
			MethodName: "deleteDeviceOnlineTime",
			Handler:    _Data_DeleteDeviceOnlineTime_Handler,
		},
		{
			MethodName: "syncDeviceOnlineTime",
			Handler:    _Data_SyncDeviceOnlineTime_Handler,
		},
		{
			MethodName: "createDeviceOnTimeDaily",
			Handler:    _Data_CreateDeviceOnTimeDaily_Handler,
		},
		{
			MethodName: "updateDeviceOnTimeDaily",
			Handler:    _Data_UpdateDeviceOnTimeDaily_Handler,
		},
		{
			MethodName: "getDeviceOnTimeDailyList",
			Handler:    _Data_GetDeviceOnTimeDailyList_Handler,
		},
		{
			MethodName: "getDeviceOnTimeDailyById",
			Handler:    _Data_GetDeviceOnTimeDailyById_Handler,
		},
		{
			MethodName: "deleteDeviceOnTimeDaily",
			Handler:    _Data_DeleteDeviceOnTimeDaily_Handler,
		},
		{
			MethodName: "syncDeviceOnTimeDaily",
			Handler:    _Data_SyncDeviceOnTimeDaily_Handler,
		},
		{
			MethodName: "syncDeviceProperty",
			Handler:    _Data_SyncDeviceProperty_Handler,
		},
		{
			MethodName: "analyseDeviceTag",
			Handler:    _Data_AnalyseDeviceTag_Handler,
		},
		{
			MethodName: "createDeviceUpsterCycle",
			Handler:    _Data_CreateDeviceUpsterCycle_Handler,
		},
		{
			MethodName: "updateDeviceUpsterCycle",
			Handler:    _Data_UpdateDeviceUpsterCycle_Handler,
		},
		{
			MethodName: "getDeviceUpsterCycleList",
			Handler:    _Data_GetDeviceUpsterCycleList_Handler,
		},
		{
			MethodName: "getDeviceUpsterCycleById",
			Handler:    _Data_GetDeviceUpsterCycleById_Handler,
		},
		{
			MethodName: "deleteDeviceUpsterCycle",
			Handler:    _Data_DeleteDeviceUpsterCycle_Handler,
		},
		{
			MethodName: "syncDeviceUpsterCycle",
			Handler:    _Data_SyncDeviceUpsterCycle_Handler,
		},
		{
			MethodName: "createDeviceUpsterStatistics",
			Handler:    _Data_CreateDeviceUpsterStatistics_Handler,
		},
		{
			MethodName: "updateDeviceUpsterStatistics",
			Handler:    _Data_UpdateDeviceUpsterStatistics_Handler,
		},
		{
			MethodName: "getDeviceUpsterStatisticsList",
			Handler:    _Data_GetDeviceUpsterStatisticsList_Handler,
		},
		{
			MethodName: "getDeviceUpsterStatisticsById",
			Handler:    _Data_GetDeviceUpsterStatisticsById_Handler,
		},
		{
			MethodName: "deleteDeviceUpsterStatistics",
			Handler:    _Data_DeleteDeviceUpsterStatistics_Handler,
		},
		{
			MethodName: "analyseDeviceUpsterStatistics",
			Handler:    _Data_AnalyseDeviceUpsterStatistics_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "data.proto",
}