diff --git a/configFiles/config_知物云_组合告警.yaml b/configFiles/config_知物云_组合告警.yaml index c0902e4..01cfe02 100644 --- a/configFiles/config_知物云_组合告警.yaml +++ b/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: diff --git a/consumers/consumerAlarmCombination.go b/consumers/consumerAlarmCombination.go index fd5188e..50c3100 100644 --- a/consumers/consumerAlarmCombination.go +++ b/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())