| | |
| | | // 转换为 LocalDateTime |
| | | LocalDateTime dateTime = LocalDateTime.parse(influxdbList.get(0).getAcquisitionTime(), formatter); |
| | | values[influxdbList.size() + 1] = dateTime; |
| | | int index = tableName.indexOf("_"); |
| | | if (index != -1) { |
| | | values[influxdbList.size()] = tableName.substring(index + 1); |
| | | } |
| | | values[influxdbList.size()] = equipment.getEqptCode(); |
| | | // 插入数据 |
| | | if (databaseType.equals("SqlServer")) { |
| | | equipmentService.insertSqlServerData(tableName, columns, values); |
| | |
| | | // 验证是否报警 |
| | | EquipmentAlarm equipmentAlarm = new EquipmentAlarm(); |
| | | equipmentAlarm.setEquipmentid(equipment.getEqptCode()); |
| | | equipmentAlarm.setCollecttime(Date.from(dateTime.atZone(java.time.ZoneId.systemDefault()).toInstant())); |
| | | equipmentAlarm.setCollecttime(Date.from(dateTime.atZone(ZoneId.systemDefault()).toInstant())); |
| | | equipmentAlarm.setAlarmNo(alarm); |
| | | equipmentAlarm.setAlarmContent(alarmContent); |
| | | equipmentAlarmService.save(equipmentAlarm); |