From 1ccfcc18ec0bdbb8ca2a2a1beaf0867d93f0d59b Mon Sep 17 00:00:00 2001 From: dxfeng Date: Mon, 13 May 2024 10:49:25 +0800 Subject: [PATCH] =?UTF-8?q?BUG--=E7=AE=80=E5=8E=86=E5=88=A4=E9=87=8D?= =?UTF-8?q?=EF=BC=8C=E7=BA=BF=E7=A8=8B=E5=AE=89=E5=85=A8?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/com/engine/recruit/conn/CheckRepeatResume.java | 4 ++-- .../interfaces/recruit/cronjob/ResumeExtractionJob.java | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) 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();