| | |
|---|
| | | 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 && minute <= 20)) { |
|---|
| | | return; |
|---|
| | | } |
|---|
| | | WriteExtractUtil.append("开始提取！！！！！！！！！！！！！！！！！！！！！！！！！！！！！！！:::" + uuid); |
|---|
| | | TimeInterval tempTestTimer = DateUtil.timer(); |
|---|
| | | WriteExtractUtil.append("提取-等待耗时：" + tempTestTimer.intervalMs() + ",:::" + uuid); |
|---|
| | |
|---|
| | | |
|---|
| | | 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(); |
|---|
| | | } |
|---|
| | | |
|---|
| | | if (!DataTableEntity.isEmpty(data)) { |
|---|
