123

许鹏程

2024-07-29 a3ba5db359871eb7846882ae58a96ffa08816a44

 product-server-data-center/src/main/java/com/product/data/center/service/DataExtractService.java

@@ -533,7 +533,7 @@

                           maybeUpdate.getData().sort((o1, o2) -> DateUtil.compare(o1.getDate(extractUpdateTimeField), o2.getDate(extractUpdateTimeField)));

                           batchResultEntity = targetNewDao.updateBatch(maybeUpdate, updateFilterEntity, false);
                           batchResultEntity = targetNewDao.updateBatch(maybeUpdate, updateFilterEntity, true);

                           WriteExtractUtil.append("更新提取过滤后数据：" + extractTargetTable + ",需要更新的条数：" + maybeUpdate.getRows() + ",耗时：" + tempTestTimer2.intervalMs());
                           targetNewDao.closeConnection();