diff --git a/api/app/lib/schedule/alarms_push.js b/api/app/lib/schedule/alarms_push.js index c16ac4a..ac1b873 100644 --- a/api/app/lib/schedule/alarms_push.js +++ b/api/app/lib/schedule/alarms_push.js @@ -27,9 +27,9 @@ module.exports = function (app, opts) { const { pushBySms, pushByEmail, sendNoticeToWeb } = app.fs.utils const curMinOfYear = moment().diff(moment().startOf('year'), 'minutes') - const pLog = (msg) => { + const pLog = (msg1,msg2) => { if (proDebug) { - console.log(msg) + console.log(msg1,msg2) } } @@ -288,7 +288,7 @@ module.exports = function (app, opts) { let deviceCountRes = strucThingId.length ? await clickHouse.iot.query(` - SELECT count(id) AS count FROM Device WHERE thingId IN (${strucThingId.map(t => `'${t}'`).join(',')}, '-1') + SELECT count(id) AS count FROM Device WHERE thingId IN (${strucThingId.map(t => `'${t}'`).join(',')}, -1) `).toPromise() : [] deviceCount = deviceCountRes.length ? deviceCountRes[0].count : 0 @@ -556,7 +556,9 @@ module.exports = function (app, opts) { `).toPromise() : [] //合并本地化和安心云的告警 dataAlarms=[...dataAlarms,...dataAlarmsLocal] - pLog('合并的告警列表(安心云+本地)',dataAlarms.length,dataAlarmsLocal.length) + pLog('合并的告警列表(安心云+本地)',dataAlarms.length) + pLog('合并的告警列表(安心云+本地)',dataAlarmsLocal.length) + } @@ -924,7 +926,7 @@ module.exports = function (app, opts) { dataAlarmDetails = await clickHouse.dataAlarm.query(` SELECT * FROM alarm_details - WHERE AlarmId IN (${alarmIds.join(',')}, '-1') + WHERE AlarmId IN (${alarmIds.join(',')}, -1) AND AlarmState = 0 `).toPromise() } @@ -1177,7 +1179,7 @@ module.exports = function (app, opts) { LEFT JOIN t_factor ON t_factor.id = t_structure_factor.factor WHERE - t_structure_factor.structure IN (${[...dataAlarmG1StructureId].join(',')},'-1') + t_structure_factor.structure IN (${[...dataAlarmG1StructureId].join(',')},-1) ` ).toPromise() || [] //查询结构物的监测因素(本地化项目) @@ -1186,7 +1188,7 @@ module.exports = function (app, opts) { StructId AS structureId,SafetyFactorTypeName AS name,SafetyFactorTypeId AS id FROM sensors - WHERE sensors.StructId in (${[...dataAlarmStructureId].join(',')},'-1')` + WHERE sensors.StructId in (${[...dataAlarmStructureId].join(',')},-1)` ).toPromise() || [] pLog('安心云项目监测因素',factorData.length) pLog('本地化项目监测因素',factorDataLocal) @@ -1208,7 +1210,7 @@ module.exports = function (app, opts) { LEFT JOIN t_device_sensor ON t_device_sensor.sensor = t_sensor.id WHERE - t_sensor.structure IN (${[...dataAlarmG1StructureId].join(',')},'-1') + t_sensor.structure IN (${[...dataAlarmG1StructureId].join(',')},-1) AND t_sensor.factor IN (${factorId.join(',')}) ` @@ -1221,8 +1223,8 @@ module.exports = function (app, opts) { SafetyFactorTypeId AS factorId, SensorId AS iotaDeviceId FROM sensors - WHERE sensors.StructId IN (${[...dataAlarmStructureId].join(',')},'-1') - AND sensors.SafetyFactorTypeId IN (${factorIdLocal.join(',')},'-1') + WHERE sensors.StructId IN (${[...dataAlarmStructureId].join(',')},-1) + AND sensors.SafetyFactorTypeId IN (${factorIdLocal.join(',')},-1) ` ).toPromise() || [] pLog('安心云项目测点',equipment.length) @@ -1245,7 +1247,7 @@ module.exports = function (app, opts) { FROM alarms WHERE - alarms.StructureId In (${[...dataAlarmG1StructureId,...dataAlarmStructureId].join(',')},'-1') + alarms.StructureId In (${[...dataAlarmG1StructureId,...dataAlarmStructureId].join(',')},-1) AND alarms.AlarmGroup = 1 AND