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 33a4a1a..4c233a4 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
@@ -165,7 +165,7 @@ public class OracleToInfluxDBServiceImpl implements OracleToInfluxDBService {
                             }).collect(Collectors.toList());
                             //插入influxdb
                             influxDBBaseService.insertBatchBySlice(tableName, list1, 10000);
-                            size = list1.size();
+//                            size = list1.size();
                             //最后一片时修改状态
                         }
                         //手动执行GC
@@ -173,7 +173,7 @@ public class OracleToInfluxDBServiceImpl implements OracleToInfluxDBService {
                         if (i == 0) {
                             jobDetailInfluxDB.setRowCount(0);
                         }
-                        jobDetailInfluxDB.setRowCount(jobDetailInfluxDB.getRowCount() + size* TableEnum.getMultipleByCode(tableName));
+                        jobDetailInfluxDB.setRowCount(jobDetailInfluxDB.getRowCount() + size*TableEnum.getMultipleByCode(tableName));
                         jobDetailInfluxDB.setUpdateTime(LocalDateTime.now());
                         jobDetailInfluxDBService.updateByMultiId(jobDetailInfluxDB);
                         if (i + 1 == slice && Objects.nonNull(jobDetailInfluxDB)) {
@@ -186,7 +186,7 @@ public class OracleToInfluxDBServiceImpl implements OracleToInfluxDBService {
                     } catch (Exception exception) {
                         exception.printStackTrace();
                         if (Objects.isNull(jobDetailInfluxDB)) {
-                            jobDetailInfluxDB = new JobDetailInfluxDB(tableName, date, size);
+                            jobDetailInfluxDB = new JobDetailInfluxDB(tableName, date, size*TableEnum.getMultipleByCode(tableName));
                         }
                         jobDetailInfluxDB.setState(2);
                         jobDetailInfluxDB.setUpdateTime(LocalDateTime.now());