From 4fc23693b6b856f6d774827073514d926c98cc3e Mon Sep 17 00:00:00 2001
From: dxfeng <dongxuefengdd@163.com>
Date: Mon, 13 May 2024 10:57:26 +0800
Subject: [PATCH] =?UTF-8?q?=E7=AE=80=E5=8E=86=E5=88=A4=E9=87=8D=E7=BA=BF?=
 =?UTF-8?q?=E7=A8=8B=E5=AE=89=E5=85=A8=EF=BC=8C=E6=97=B6=E9=97=B4=E6=A0=BC?=
 =?UTF-8?q?=E5=BC=8F=E4=BC=98=E5=8C=96?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../recruit/conn/CheckRepeatResume.java       | 53 +++++++++++--------
 .../recruit/cronjob/ResumeExtractionJob.java  |  2 +-
 2 files changed, 31 insertions(+), 24 deletions(-)

diff --git a/src/com/engine/recruit/conn/CheckRepeatResume.java b/src/com/engine/recruit/conn/CheckRepeatResume.java
index 3dcba11..9d97752 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<RecruitDataMap<Object>> detailDataList, String tableName, String mainId, String sourceId) {
+    public synchronized void insertResumeDetailTable(List<RecruitDataMap<Object>> detailDataList, String tableName, String mainId, String sourceId) {
         if (CollectionUtils.isEmpty(detailDataList)) {
             return;
         }
@@ -141,7 +141,7 @@ public class CheckRepeatResume {
      * @param param 数据集合
      * @return 简历插入信息
      */
-    public Map<String, Object> insertResumeAndReturn(Map<String, Object> param) {
+    public synchronized Map<String, Object> insertResumeAndReturn(Map<String, Object> param) {
         Map<String, Object> returnMap = new HashMap<>();
         int mainId = -1;
         String sourceId;
@@ -289,33 +289,40 @@ public class CheckRepeatResume {
      * @return
      */
     public static RecruitDataMap<Object> getDateRange(String date, boolean isStudy) {
-        RecruitDataMap<Object> dataRangeMap = new RecruitDataMap<>();
+        RecruitDataMap<Object> dataRangeMap = new RecruitDataMap();
         if (StringUtils.isBlank(date)) {
             return dataRangeMap;
-        }
-        String[] split = date.split("-");
-        if (split.length == 2) {
-            String start = getFormatDate(split[0]);
-            String end = getFormatDate(split[1]);
-            if (start.length() == 4) {
-                if (isStudy) {
-                    start += "-09-01";
-                } else {
-                    start = "";
-                }
-            }
-            if (end.length() == 4) {
-                if (isStudy) {
-                    end += "-07-01";
-                } else {
-                    end = "";
+        } else {
+            String[] split = date.split("-");
+            String end;
+            if (split.length > 0) {
+                end = getFormatDate(split[0]);
+                if (end.length() == 4) {
+                    if (isStudy) {
+                        end = end + "-09-01";
+                    } else {
+                        end = "";
+                    }
                 }
+
+                dataRangeMap.put("kssj", end);
             }
 
-            dataRangeMap.put("kssj", start);
-            dataRangeMap.put("jssj", end);
+            if (split.length > 1) {
+                end = getFormatDate(split[1]);
+                if (end.length() == 4) {
+                    if (isStudy) {
+                        end = end + "-07-01";
+                    } else {
+                        end = "";
+                    }
+                }
+
+                dataRangeMap.put("jssj", end);
+            }
+
+            return dataRangeMap;
         }
-        return dataRangeMap;
     }
 
     /**
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();