base

Documentation

Index

• func MergeData(events []*ent.DeviceEvent, endTime time.Time) map[string][]DataType
• func MergeDataElephant(events []*ent.DeviceEvent, endTime time.Time) map[string][]DataType
• func SplitData(dataArr map[string][]DataType) map[string][]DataType
• type CalculateElephantType
• type CalculateType
• type DataType
• type DayJsonElephantType
• type DayJsonType
• type DurationValueType
• type InitDatabaseLogic
  • func NewInitDatabaseLogic(ctx context.Context, svcCtx *svc.ServiceContext) *InitDatabaseLogic
  • func (l *InitDatabaseLogic) InitDatabase(in *data.Empty) (*data.BaseResp, error)
• type TypeCalculate
• type TypeHourJson
• type TypeRefer
• type ValueType

Functions

func MergeData

func MergeData(events []*ent.DeviceEvent, endTime time.Time) map[string][]DataType

MergeData

* 冒泡排序合并相邻元素 * * 取下一条元素时间作为结束时间，最后一条才加上默认5分钟的设定值 * 两条时间差异大于5分钟的隔断重新计算

func MergeDataElephant

func MergeDataElephant(events []*ent.DeviceEvent, endTime time.Time) map[string][]DataType

func SplitData

func SplitData(dataArr map[string][]DataType) map[string][]DataType

SplitData * * 超出1小时数据拆分

Types

type CalculateElephantType

type CalculateElephantType struct {
	Connected int32
	Running   int32
	Ebutton   int32
	DayJson   []DayJsonElephantType
}

type CalculateType

type CalculateType struct {
	StandBy     int32
	Preparation int32
	Waiting     int32
	WashingCold int32
	Washing     int32
	Ebutton     int32
	DayJson     []DayJsonType
}

type DataType

type DataType struct {
	Name  string
	Value DurationValueType
}

type DayJsonElephantType

type DayJsonElephantType struct {
	Hour      int
	Connected int32
	Running   int32
	Ebutton   int32
}

type DayJsonType

type DayJsonType struct {
	Hour        int
	StandBy     int32
	Preparation int32
	Waiting     int32
	WashingCold int32
	Washing     int32
	Ebutton     int32
}

type DurationValueType

type DurationValueType struct {
	Hour        int
	StartMinute string
	EndMinute   string
	StartTime   string
	EndTime     string
	Time        time.Time
	TimeNext    time.Time
}

type InitDatabaseLogic

type InitDatabaseLogic struct {
	logx.Logger
	// contains filtered or unexported fields
}

func NewInitDatabaseLogic

func NewInitDatabaseLogic(ctx context.Context, svcCtx *svc.ServiceContext) *InitDatabaseLogic

func (*InitDatabaseLogic) InitDatabase

func (l *InitDatabaseLogic) InitDatabase(in *data.Empty) (*data.BaseResp, error)

type TypeCalculate

type TypeCalculate struct {
	DiffNum1  int32
	DiffNum2  int32
	DiffNum3  int32
	DiffCycle int32
}

type TypeHourJson

type TypeHourJson struct {
	NumberOfProgramButton1 int32
	NumberOfProgramButton2 int32
	NumberOfProgramButton3 int32
}

type TypeRefer

type TypeRefer struct {
	NumberOfProgramButton1 int32
	NumberOfProgramButton2 int32
	NumberOfProgramButton3 int32
}

type ValueType

type ValueType struct {
	IotId                  string
	Timestamp              string
	NumberOfProgramButton1 int32
	NumberOfProgramButton2 int32
	NumberOfProgramButton3 int32
	NumberOfWashingCycles  int32
	NumberOfRegeneration   int32
	NumberOfRinsingCycles  int32
	TotalOfOperatingTime   int32
}