lucas2
/
goInOut
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Compare commits

base: lucas2:488d17078787bf50545a23c488fdbe4c75dfa32f
Branches Tags
lucas2:dev
lucas2:master
...
compare: lucas2:88325ae70daed063b6f079b7637e78885f0af3c8
Branches Tags
lucas2:dev
lucas2:master

3 Commits
488d170787 ... 88325ae70d

Author SHA1 Message Date
zhangyuxiang 88325ae70d 针对esTo广东平台上隆江新增的监测因素处理
2 weeks ago
zhangyuxiang 3a458ad674 Merge branch 'dev' of https://gitea.anxinyun.cn/lucas2/goInOut into dev
2 weeks ago
zhangyuxiang 5b1d7faca8 修改广东大宝山上报测点信息
1 month ago
3 changed files with 23 additions and 14 deletions
Whitespace
Show all changes Ignore whitespace when comparing lines Ignore changes in amount of whitespace Ignore changes in whitespace at EOL
Unified View
Diff Options
Show Stats
  1. 2
      consumers/consumerAXYES2GDJKJC.go
  2. 24
      consumers/consumerGDKS.go
  3. 11
      utils/anxinyunEsAggQuery.go

2
consumers/consumerAXYES2GDJKJC.go
View File

@ -140,7 +140,7 @@ func (the *consumerAXYES2GDJKJC) getStructIdsBySlope() []int {
func (the *consumerAXYES2GDJKJC) getEs1HourAggData() { func (the *consumerAXYES2GDJKJC) getEs1HourAggData() {
start, end := utils.GetTimeRangeByHour(-1) start, end := utils.GetTimeRangeByHour(-1)
log.Printf("查询数据时间范围 %s - %s", start, end) log.Printf("查询数据时间范围 %s - %s", start, end)
hourFactorIds := []int{11, 15, 18, 63} //应变11 桥墩倾斜15 裂缝监测18 支护结构变形63 hourFactorIds := []int{11, 15, 18, 63, 31} //应变11 桥墩倾斜15 裂缝监测18 支护结构变形63 水位 31
structIds := the.getStructIdsByBridge() structIds := the.getStructIdsByBridge()
the.handlerHourAggData(start, end, "bridge", structIds, hourFactorIds) the.handlerHourAggData(start, end, "bridge", structIds, hourFactorIds)
} }

24
consumers/consumerGDKS.go
View File

@ -118,18 +118,18 @@ func (the *consumerGDKS) saveConfig() {
"2025-12-22 15:00:00" //数据上传时间 "2025-12-22 15:00:00" //数据上传时间
contentConfigBody := "" + contentConfigBody := "" +
//测点编码;测点名称;系统编码;露天矿山编码;边坡编号;传感器类型;测点数值类型;测点数值单位;埋深;一级阈值;二级阈值;三级阈值;四级阈值;测点安装位置;位置X;位置Y;位置Z;安装日期;生产厂家;量程;在用状态;故障状态;数据时间 //测点编码;测点名称;系统编码;露天矿山编码;边坡编号;传感器类型;测点数值类型;测点数值单位;埋深;一级阈值;二级阈值;三级阈值;四级阈值;测点安装位置;位置X;位置Y;位置Z;安装日期;生产厂家;量程;在用状态;故障状态;数据时间
"^44020500500102100011;757_G1;01;440205005001;0201;2001;;mm;;;;;;排土场;113.71655000;24.55281252;767;2023-05-01;司南导航;15;1;0;2025-12-22 10:00:00" + "^4402050050012001100011;757_G1;01;440205005001;0201;2001;;mm;;;;;;排土场;113.71655000;24.55281252;767;2023-05-01;司南导航;15;1;0;2025-12-22 10:00:00" +
"^44020500500102100012;757_G2;01;440205005001;0201;2001;;mm;;;;;;排土场;113.71533904;24.55295121;767;2023-05-01;司南导航;15;1;0;2025-12-22 10:00:00" + "^4402050050012001100012;757_G2;01;440205005001;0201;2001;;mm;;;;;;排土场;113.71533904;24.55295121;767;2023-05-01;司南导航;15;1;0;2025-12-22 10:00:00" +
"^44020500500102100021;757_G3;01;440205005001;0201;2001;;mm;;;;;;排土场;113.71460937;24.55365389;767;2023-05-01;司南导航;15;1;0;2025-12-22 10:00:00" + "^4402050050012001100021;757_G3;01;440205005001;0201;2001;;mm;;;;;;排土场;113.71460937;24.55365389;767;2023-05-01;司南导航;15;1;0;2025-12-22 10:00:00" +
"^44020500500102100022;757_G4;01;440205005001;0201;2001;;mm;;;;;;排土场;113.71425361;24.55447242;767;2023-05-01;司南导航;15;1;0;2025-12-22 10:00:00" + "^4402050050012001100022;757_G4;01;440205005001;0201;2001;;mm;;;;;;排土场;113.71425361;24.55447242;767;2023-05-01;司南导航;15;1;0;2025-12-22 10:00:00" +
"^44020500500102100031;757_G5;01;440205005001;0201;2001;;mm;;;;;;排土场;113.71396365;24.55502772;767;2023-05-01;司南导航;15;1;0;2025-12-22 10:00:00" + "^4402050050012001100031;757_G5;01;440205005001;0201;2001;;mm;;;;;;排土场;113.71396365;24.55502772;767;2023-05-01;司南导航;15;1;0;2025-12-22 10:00:00" +
"^44020500500102100032;757_G6;01;440205005001;0201;2001;;mm;;;;;;排土场;113.71318562;24.55588272;767;2023-05-01;司南导航;15;1;0;2025-12-22 10:00:00" + "^4402050050012001100032;757_G6;01;440205005001;0201;2001;;mm;;;;;;排土场;113.71318562;24.55588272;767;2023-05-01;司南导航;15;1;0;2025-12-22 10:00:00" +
"^44020500500102100071;681_G1;01;440205005001;0201;2001;;mm;;;;;;排土场;113.71450034;24.55077052;681;2023-05-01;司南导航;15;1;0;2025-12-22 10:00:00" + "^4402050050012001100071;681_G1;01;440205005001;0201;2001;;mm;;;;;;排土场;113.71450034;24.55077052;681;2023-05-01;司南导航;15;1;0;2025-12-22 10:00:00" +
"^44020500500102100041;681_G2;01;440205005001;0201;2001;;mm;;;;;;排土场;113.71363350;24.55145886;681;2023-05-01;司南导航;15;1;0;2025-12-22 10:00:00" + "^4402050050012001100041;681_G2;01;440205005001;0201;2001;;mm;;;;;;排土场;113.71363350;24.55145886;681;2023-05-01;司南导航;15;1;0;2025-12-22 10:00:00" +
"^44020500500102100042;681_G3;01;440205005001;0201;2001;;mm;;;;;;排土场;113.71295301;24.55210073;681;2023-05-01;司南导航;15;1;0;2025-12-22 10:00:00" + "^4402050050012001100042;681_G3;01;440205005001;0201;2001;;mm;;;;;;排土场;113.71295301;24.55210073;681;2023-05-01;司南导航;15;1;0;2025-12-22 10:00:00" +
"^44020500500102100043;625_G1;01;440205005001;0201;2001;;mm;;;;;;排土场;113.71642567;24.54860382;633;2023-05-01;司南导航;15;1;0;2025-12-22 10:00:00" + "^4402050050012001100043;625_G1;01;440205005001;0201;2001;;mm;;;;;;排土场;113.71642567;24.54860382;633;2023-05-01;司南导航;15;1;0;2025-12-22 10:00:00" +
"^44020500500102100051;625_G2;01;440205005001;0201;2001;;mm;;;;;;排土场;113.71498554;24.54938638;633;2023-05-01;司南导航;15;1;0;2025-12-22 10:00:00" + "^4402050050012001100051;625_G2;01;440205005001;0201;2001;;mm;;;;;;排土场;113.71498554;24.54938638;633;2023-05-01;司南导航;15;1;0;2025-12-22 10:00:00" +
"^44020500500102100052;625_G3;01;440205005001;0201;2001;;mm;;;;;;排土场;113.71398753;24.54990754;633;2023-05-01;司南导航;15;1;0;2025-12-22 10:00:00" + "^4402050050012001100052;625_G3;01;440205005001;0201;2001;;mm;;;;;;排土场;113.71398753;24.54990754;633;2023-05-01;司南导航;15;1;0;2025-12-22 10:00:00" +
"^]]]" "^]]]"
contentConfig = contentConfigHead + contentConfigBody contentConfig = contentConfigHead + contentConfigBody
} }

11
utils/anxinyunEsAggQuery.go
View File

@ -64,7 +64,7 @@ func GetEsAggSubSqlByAxyFactorId(factorId int) string {
} }
} }
}` }`
case 28: case 25, 28:
subAggSQl = ` subAggSQl = `
{ {
"x": { "x": {
@ -77,6 +77,15 @@ func GetEsAggSubSqlByAxyFactorId(factorId int) string {
"field": "data.trms" "field": "data.trms"
} }
} }
}`
case 31:
subAggSQl = `
{
"x": {
"extended_stats": {
"field": "data.waterLevel"
}
}
}` }`
case 592: case 592:
subAggSQl = ` subAggSQl = `

Write Preview
Loading…
Cancel
Save