diff --git a/influx-data/influx-source/src/main/java/com/njcn/influx/service/impl/OracleToInfluxDBServiceImpl.java b/influx-data/influx-source/src/main/java/com/njcn/influx/service/impl/OracleToInfluxDBServiceImpl.java index afab797..22f8727 100644 --- a/influx-data/influx-source/src/main/java/com/njcn/influx/service/impl/OracleToInfluxDBServiceImpl.java +++ b/influx-data/influx-source/src/main/java/com/njcn/influx/service/impl/OracleToInfluxDBServiceImpl.java @@ -174,9 +174,7 @@ public class OracleToInfluxDBServiceImpl implements OracleToInfluxDBService { jobDetailInfluxDB.setRowCount(0); } jobDetailInfluxDB.setRowCount(jobDetailInfluxDB.getRowCount() + size*TableEnum.getMultipleByCode(tableName)); - jobDetailInfluxDB.setUpdateTime(LocalDateTime.now()); - jobDetailInfluxDBService.updateByMultiId(jobDetailInfluxDB); - if (i + 1 == slice && Objects.nonNull(jobDetailInfluxDB)) { + if (i + 1 == slice) { stopWatch.stop(); jobDetailInfluxDB.setState(1); jobDetailInfluxDB.setDuration(stopWatch.getTotalTimeSeconds()); @@ -185,9 +183,6 @@ public class OracleToInfluxDBServiceImpl implements OracleToInfluxDBService { jobDetailInfluxDBService.updateByMultiId(jobDetailInfluxDB); } catch (Exception exception) { exception.printStackTrace(); - if (Objects.isNull(jobDetailInfluxDB)) { - jobDetailInfluxDB = new JobDetailInfluxDB(tableName, date, size*TableEnum.getMultipleByCode(tableName)); - } jobDetailInfluxDB.setState(2); jobDetailInfluxDB.setUpdateTime(LocalDateTime.now()); jobDetailInfluxDBService.updateByMultiId(jobDetailInfluxDB);