123

许鹏程

2024-05-12 5a7cfb9266c7e03ccee44811b0fba1d4aceae6fd

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

@@ -363,6 +363,17 @@
         WriteExtractUtil.append("已有任务在运行跳过此次运行！！！！！！！！！！！！！！！！！！！！！！！！！！！！！！！:::" + uuid);
         return;
      }
      //凌晨1点10分开始进入此方法的休眠到1点20分
      Calendar calendar = Calendar.getInstance();
      int hour = calendar.get(Calendar.HOUR_OF_DAY);
      int minute = calendar.get(Calendar.MINUTE);
      if (hour == 1 && minute == 10) {
         try {
            Thread.sleep(600000);
         } catch (InterruptedException e) {
            e.printStackTrace();
         }
      }
      WriteExtractUtil.append("开始提取！！！！！！！！！！！！！！！！！！！！！！！！！！！！！！！:::" + uuid);
      TimeInterval tempTestTimer = DateUtil.timer();
      WriteExtractUtil.append("提取-等待耗时：" + tempTestTimer.intervalMs() + ",:::" + uuid);
@@ -533,7 +544,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();