123

许鹏程

2024-05-12 5a7cfb9266c7e03ccee44811b0fba1d4aceae6fd

123

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

@@ -232,6 +232,8 @@
//            } while (fs != null && fs.getInteger("del_count") != null && fs.getInteger("del_count") > 0);
        } catch (Exception e) {
            e.printStackTrace();
            SpringMVCContextHolder.getSystemLogger().error("删除采集提取日志错误！！！：" + e.getMessage());
            SpringMVCContextHolder.getSystemLogger().error(e);
            throw e;
        }
    }

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

@@ -53,6 +53,14 @@
    // 采集最大批次
    public static final long COLLECT_MAX_BATCH_COUNT = 100L;

    public static void main(String[] args) {
        Calendar calendar = Calendar.getInstance();
        int hour = calendar.get(Calendar.HOUR_OF_DAY);
        int minute = calendar.get(Calendar.MINUTE);
        if (hour == 1 && minute == 10) {
                System.out.println("2222222");
        }
    }
    /**
     * 数据采集-定时任务执行方法
     *
@@ -60,6 +68,17 @@
     */
    public void dataCollect(String uuid) {
        synchronized (uuid.intern()) {
            //凌晨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();
                }
            }
            Calendar startCalendar = Calendar.getInstance();
            Date preExecuteTime = null;
            Date curExecuteTime = startCalendar.getTime();

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