| | |
| | | addFileMd5(md5); |
| | | |
| | | try { |
| | | logger.info("loadVocSync:" + filePath); |
| | | EasyCsv.read(filePath, VocVals.class, new VocParser(vocValsService, calendar.getTime())).doRead(); |
| | | } catch (Exception e) { |
| | | logger.error(e.getMessage(), e); |
| | |
| | | |
| | | suYuanService.createNewTable(newTableName); |
| | | dictRecordService.insertDictRecord(new DictRecord(1L, newTableName, Long.parseLong(time), "")); |
| | | |
| | | logger.info("loadCsvSync:" + filePath); |
| | | EasyCsv.read(filePath, SuYuan.class, new CsvParser(suYuanService, time)).doRead(); |
| | | |
| | | try { |
| | | // 计算预警/报警,并且进行入库操作 |
| | | Thread.sleep(60000); |
| | | Thread.sleep(10000); // 60000 |
| | | } catch (InterruptedException e) { |
| | | logger.error("睡眠一分钟后执行预警/报警计算,并且进行入库操作出现异常,异常原因是:", e); |
| | | e.printStackTrace(); |