diff --git a/src/com/engine/recruit/conn/CheckRepeatResume.java b/src/com/engine/recruit/conn/CheckRepeatResume.java index 3dcba11..65b0f96 100644 --- a/src/com/engine/recruit/conn/CheckRepeatResume.java +++ b/src/com/engine/recruit/conn/CheckRepeatResume.java @@ -108,7 +108,7 @@ public class CheckRepeatResume { * @param mainId * @param sourceId */ - public void insertResumeDetailTable(List> detailDataList, String tableName, String mainId, String sourceId) { + public synchronized void insertResumeDetailTable(List> detailDataList, String tableName, String mainId, String sourceId) { if (CollectionUtils.isEmpty(detailDataList)) { return; } @@ -141,7 +141,7 @@ public class CheckRepeatResume { * @param param 数据集合 * @return 简历插入信息 */ - public Map insertResumeAndReturn(Map param) { + public synchronized Map insertResumeAndReturn(Map param) { Map returnMap = new HashMap<>(); int mainId = -1; String sourceId; diff --git a/src/weaver/interfaces/recruit/cronjob/ResumeExtractionJob.java b/src/weaver/interfaces/recruit/cronjob/ResumeExtractionJob.java index 69ccbbd..65c4bcd 100644 --- a/src/weaver/interfaces/recruit/cronjob/ResumeExtractionJob.java +++ b/src/weaver/interfaces/recruit/cronjob/ResumeExtractionJob.java @@ -15,7 +15,7 @@ public class ResumeExtractionJob extends BaseCronJob { public void execute() { // 抽取千里聆同步简历 ExtractQllResumeThread qllResumeThread = new ExtractQllResumeThread(); - qllResumeThread.start(); + qllResumeThread.run(); //// 抽取OCR解析简历 //ExtractOcrResumeThread ocrResumeThread = new ExtractOcrResumeThread();