Browse Source

update 删除无用的调试部分

dev
lucas 3 days ago
parent
commit
f9f9004081
  1. 6
      configFiles/config_知物云_组合告警.yaml
  2. 3
      consumers/consumerAlarmCombination.go

6
configFiles/config_知物云_组合告警.yaml

@ -2,7 +2,7 @@ consumer: consumerAlarmCombination
ioConfig:
in:
http:
url: https://esproxy.anxinyun.cn/savoir_alarms/_search
url: https://esproxy.anxinyun.cn/savoir_alarms/_search #商用替换为内网
out:
kafka:
brokers: ["10.8.30.160:30992"]
@ -10,12 +10,12 @@ ioConfig:
topics:
- zuhe_alarm
monitor:
cron: 31 0/1 * * * #6/10 * * * *
cron: 46 0/1 * * * #6/10 * * * *
info:
queryComponent:
postgres:
connect: "host=10.8.30.166 port=5432 user=FashionAdmin password=123456 dbname=SavoirCloud sslmode=disable"
#点位id对应信息
pointInfo: #测点类型支持 桥墩倾斜 15 裂缝18 支座位移20 桥面振动28 加速度三项监测592(承德隧道专用)
pointInfo:

3
consumers/consumerAlarmCombination.go

@ -144,8 +144,7 @@ func (the *consumerAlarmCombination) updateCombinationInfo() {
sql := `SELECT a.*,s."name" as struct_name FROM "t_alarm_combination" as a
left join t_structure as s
ON a.struct_id=s."id"`
sql += " where a.id=1" //测试用
//var CombinationInfos []AlarmCombination.CombinationInfo
//sql += " where a.id=1" //测试用
err := the.infoPg.Query(&the.combinationInfo, sql)
if err != nil {
log.Printf("查询数据库异常:err-> %s", err.Error())

Loading…
Cancel
Save