From ae79af45d720a2d96c05799af01d7065e65becd0 Mon Sep 17 00:00:00 2001 From: dxfeng Date: Wed, 15 May 2024 17:24:21 +0800 Subject: [PATCH] =?UTF-8?q?BUG-=E8=81=8C=E4=BD=8D=E5=8C=B9=E9=85=8D?= =?UTF-8?q?=EF=BC=8C=E6=B7=BB=E5=8A=A0=E6=8A=95=E9=80=92=E8=81=8C=E4=BD=8D?= =?UTF-8?q?=E7=AC=AC=E4=B8=89=E6=96=B9?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../recruit/thread/ExtractQllResumeThread.java | 17 +++++++++++++++-- 1 file changed, 15 insertions(+), 2 deletions(-) diff --git a/src/weaver/interfaces/recruit/thread/ExtractQllResumeThread.java b/src/weaver/interfaces/recruit/thread/ExtractQllResumeThread.java index 1694781..46d8168 100644 --- a/src/weaver/interfaces/recruit/thread/ExtractQllResumeThread.java +++ b/src/weaver/interfaces/recruit/thread/ExtractQllResumeThread.java @@ -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 map : mapList) { QllResumePo qllResumePo = RecruitUtil.parseMap2Object(map, QllResumePo.class); try { + baseBean.writeLog("千里聆简历解析开始，中间表ID=【" + qllResumePo.getId() + "】"); RecruitDataMap dataMap = buildApplicantMap(qllResumePo); + baseBean.writeLog("千里聆简历主表数据解析完成==" + JSON.toJSONString(dataMap)); // 校验简历信息、并插入 CheckRepeatResume instance = CheckRepeatResume.getInstance(); Map 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 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)) {