dxfeng
/
weaver-hrm-recruit
generated from dxfeng/secondev-chapanda-feishu
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

BUG-职位匹配，添加投递职位第三方

This commit is contained in:
dxfeng 2024-05-15 17:24:21 +08:00
parent 6e3b9a3c43
commit ae79af45d7
1 changed files with 15 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
src/weaver/interfaces/recruit/thread/ExtractQllResumeThread.java
View File

@ -1,5 +1,6 @@
package weaver.interfaces.recruit.thread;
import cn.hutool.core.convert.Convert;
import com.alibaba.fastjson.JSON;
import com.engine.recruit.conn.*;
import com.engine.recruit.entity.resume.QllResumePo;
@ -21,6 +22,8 @@ import java.util.Map;
* @version: 1.0
*/
public class ExtractQllResumeThread extends Thread {
BaseBean baseBean = new BaseBean();
@Override
public void run() {
RecordSet rs = new RecordSet();
@ -32,20 +35,26 @@ public class ExtractQllResumeThread extends Thread {
for (Map<String, Object> map : mapList) {
QllResumePo qllResumePo = RecruitUtil.parseMap2Object(map, QllResumePo.class);
try {
baseBean.writeLog("千里聆简历解析开始，中间表ID=【" + qllResumePo.getId() + "】");
RecruitDataMap<Object> dataMap = buildApplicantMap(qllResumePo);
baseBean.writeLog("千里聆简历主表数据解析完成==" + JSON.toJSONString(dataMap));
// 校验简历信息、并插入
CheckRepeatResume instance = CheckRepeatResume.getInstance();
Map<String, Object> checkMap = instance.insertResumeAndReturn(dataMap);
String mainId = Util.null2String(checkMap.get("mainId"));
String sourceId = Util.null2String(checkMap.get("sourceId"));
rs.executeUpdate("update uf_jcl_jlzjb set cqzt = 1 where id = ? ", qllResumePo.getId());
baseBean.writeLog("千里聆简历主表数据插入完成，mainId==【" + mainId + "】，sourceId==【" + sourceId + "】");
// 数据写入完成后，更新抽取状态为新插入的数据ID
rs.executeUpdate("update uf_jcl_jlzjb set cqzt = 1 ,mainid = ? ,sourceid = ? where id = ? ", Convert.toInt(mainId,0), Convert.toInt(sourceId,0), qllResumePo.getId());
// 插入明细表数据
instance.insertResumeDetailTable(qllResumePo.getJyjl(), "uf_jcl_yppc_dt1", mainId, sourceId);
instance.insertResumeDetailTable(qllResumePo.getGzjl(), "uf_jcl_yppc_dt2", mainId, sourceId);
instance.insertResumeDetailTable(qllResumePo.getXmjl(), "uf_jcl_yppc_dt3", mainId, sourceId);
baseBean.writeLog("千里聆简历解析完成，mainId==【" + mainId + "】，sourceId==【" + sourceId + "】");
} catch (Exception e) {
new BaseBean().writeLog("简历解析失败" + JSON.toJSONString(qllResumePo), e);
baseBean.writeLog("简历解析失败" + JSON.toJSONString(qllResumePo), e);
}
}
@ -81,15 +90,19 @@ public class ExtractQllResumeThread extends Thread {
insertMap.put("tdsj", DateUtil.getDateTime());
// 原始简历
insertMap.put("ysjl", qllResumePo.getJlfj());
// 投递职位（第三方）
insertMap.put("tdzwdsf", qllResumePo.getYpzw());
String zt = ApplicationStatusEnum.DISTRIBUTION.getValue();
// 应聘职位
String ypzw = PositionCommonInfo.getPositionIdByName(qllResumePo.getYpzw(), qllResumePo.getGjrsjh());
baseBean.writeLog("投递职位==【" + qllResumePo.getYpzw() + "】,投递职位ID==【" + ypzw + "】");
if (StringUtils.isNotBlank(ypzw)) {
String flowId = PositionCommonInfo.getRecruitFlowId(ypzw);
Map<String, String> initialStage = ApplicantCommonInfo.getInitialStage(flowId);
if (null != initialStage) {
baseBean.writeLog("initialStage===" + JSON.toJSONString(initialStage));
String zpjd = initialStage.get("zpjd");
String dqypjd = initialStage.get("jdlx");
if (StringUtils.isNotBlank(zpjd) && StringUtils.isNotBlank(dqypjd)) {