|
@ -137,6 +137,7 @@ public class CurrentMysqlToEsQuotaJob implements Job {
|
|
|
List<QuartzJobConfig> list = quartzJobConfigDao.findByIds();
|
|
|
list.stream().forEach(one -> {
|
|
|
try {
|
|
|
logger.info("========================quotaCode:" + one.getId() + " start========================");
|
|
|
QuartzJobLog tjQuotaLog = new QuartzJobLog();
|
|
|
tjQuotaLog.setJobId(one.getId());
|
|
|
tjQuotaLog.setJobStartTime(new Date());
|
|
@ -160,6 +161,7 @@ public class CurrentMysqlToEsQuotaJob implements Job {
|
|
|
tjQuotaLog.setJobEndTime(new Date());
|
|
|
tjQuotaLog.setJobContent(JSONArray.fromObject(filterModel.getErrorModels()).toString());
|
|
|
saveLog(tjQuotaLog);
|
|
|
logger.info("========================quotaCode:" + one.getId() + " end========================");
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
|
}
|