| | |
| | | import java.util.stream.Collectors; |
| | | |
| | | /** |
| | | * 示例带参定时任务 |
| | | * influxdb定时任务 |
| | | * |
| | | * @Author Scott |
| | | */ |
| | |
| | | // 转换为 LocalDateTime |
| | | LocalDateTime dateTime = LocalDateTime.parse(influxdbList.get(0).getAcquisitionTime(), formatter); |
| | | values[influxdbList.size() + 1] = dateTime; |
| | | values[influxdbList.size()] = tableName.replace("-", "_"); |
| | | int index = tableName.indexOf("_"); |
| | | if (index != -1) { |
| | | values[influxdbList.size()] = tableName.substring(index + 1); |
| | | } |
| | | // 插入数据 |
| | | if (databaseType.equals("SqlServer")) { |
| | | equipmentService.insertSqlServerData(tableName, columns, values); |