Browse Source

修改监测因素

dev
zhangyuxiang 1 day ago
parent
commit
4dbba6eb06
  1. 4
      consumers/consumerZWYHBJCAS.go

4
consumers/consumerZWYHBJCAS.go

@ -154,7 +154,7 @@ func (the *consumerZWYHBJCAS) getStructIds() []int64 {
func (the *consumerZWYHBJCAS) getEs1HourAggData() {
start, end := utils.GetTimeRangeByHour(-1)
log.Printf("查询数据时间范围 %s - %s", start, end)
hourFactorIds := []int{15, 18, 20}
hourFactorIds := []int{102, 1914, 1917}
structIds := the.getStructIds()
for _, structId := range structIds {
for _, factorId := range hourFactorIds {
@ -182,7 +182,7 @@ func (the *consumerZWYHBJCAS) getEs10minAggData() {
//utils.GetTimeRangeBy10min() 由于振动数据实时性问题 改用一小时统一上报
start, end := utils.GetTimeRangeByHour(-1)
log.Printf("查询10min数据时间范围 %s - %s", start, end)
factorIds := []int{28, 592}
factorIds := []int{1919, 1920}
structIds := the.getStructIds()
for _, structId := range structIds {
for _, factorId := range factorIds {

Loading…
Cancel
Save