简历判重线程安全,时间格式优化

This commit is contained in:
dxfeng 2024-05-13 10:57:26 +08:00
parent 230f55fb10
commit 4fc23693b6
2 changed files with 31 additions and 24 deletions

View File

@ -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;
}
/**

View File

@ -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();