commit

T100738

2024-04-16 eeb86aaf2f73a02600195ce2637dde6caf858a88

 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();