简历卡片OCR

src/com/api/recruit/controller/ResumeRecognitionController.java

@@ -0,0 +1,12 @@
+package com.api.recruit.controller;
+
+import javax.ws.rs.Path;
+
+/**
+ * @author:dxfeng
+ * @createTime: 2023/12/12
+ * @version: 1.0
+ */
+@Path("/jcl/recruit/resume")
+public class ResumeRecognitionController extends com.engine.recruit.controller.ResumeRecognitionController {
+}

src/com/engine/recruit/conn/ApplicantCommonInfo.java

@@ -63,6 +63,41 @@ public class ApplicantCommonInfo {
         return cancelReason;
     }
 
+    /**
+     * 获取表单下拉框值
+     *
+     * @param formId     表单ID
+     * @param fieldName  字段明湖曾
+     * @param selectName 下拉框展示内容
+     * @return
+     */
+    public static String getSelectValue(String formId, String fieldName, String selectName) {
+        String selectValue = "";
+        RecordSet rs = new RecordSet();
+        rs.executeQuery("select selectvalue from workflow_selectitem where fieldid =( select id from workflow_billfield where billid = ? and fieldname = ? ) and selectname = ?", formId, fieldName, selectName);
+        if (rs.next()) {
+            selectValue = rs.getString("selectvalue");
+        }
+        return selectValue;
+    }
+
+    /**
+     * 获取表单下拉框展示文本
+     *
+     * @param formId    表单ID
+     * @param fieldName 字段明湖曾
+     * @return
+     */
+    public static Map<String, String> getSelectMap(String formId, String fieldName) {
+        Map<String, String> selectMap = new HashMap<>();
+        RecordSet rs = new RecordSet();
+        rs.executeQuery("select selectvalue,selectname from workflow_selectitem where fieldid =( select id from workflow_billfield where billid = ? and fieldname = ? ) ", formId, fieldName);
+        while (rs.next()) {
+            selectMap.put(rs.getString("selectvalue"), rs.getString("selectname"));
+        }
+        return selectMap;
+    }
+
 
     /**
      * 获取招聘通用浏览按钮展示内容
@@ -78,7 +113,7 @@ public class ApplicantCommonInfo {
         RecordSet rs = new RecordSet();
         String[] split = id.split(",");
         for (String s : split) {
-            rs.executeQuery("select xxnr from uf_sjzd where id = ?", id);
+            rs.executeQuery("select xxnr from uf_sjzd where id = ?", s);
             if (rs.next()) {
                 value.add(rs.getString("xxnr"));
             }
@@ -238,4 +273,52 @@ public class ApplicantCommonInfo {
         }
         return null;
     }
+
+    /**
+     * 获取ImageField
+     *
+     * @param docId
+     * @return
+     */
+    public static int getImageFieldByDocId(String docId) {
+        RecordSet rs = new RecordSet();
+        rs.executeQuery("select imagefileid from docimagefile where docid = ? ", docId);
+        if (rs.next()) {
+            return rs.getInt("imagefileid");
+        }
+        return -1;
+    }
+
+    /**
+     * 根据customSearchCode获取查询列表的id
+     *
+     * @param customSearchCode customSearchCode
+     * @return ID
+     */
+    public static String getCustomSearchId(String customSearchCode) {
+        RecordSet rs = new RecordSet();
+        rs.executeQuery("select id from mode_customsearch where customsearchcode = ? ", customSearchCode);
+        if (rs.next()) {
+            return rs.getString("id");
+        }
+        return "";
+    }
+
+    /**
+     * 根据customSearchCode获取查询列表的地址
+     *
+     * @param customSearchCode customSearchCode
+     * @param linkUrl          自定义的URL
+     * @return 查询列表的地址
+     */
+    public static String getCustomSearchLink(String customSearchCode, String linkUrl) {
+        if (StringUtils.isNotBlank(linkUrl)) {
+            return linkUrl;
+        }
+        String customSearchId = getCustomSearchId(customSearchCode);
+        if (StringUtils.isNotBlank(customSearchId)) {
+            return "/spa/cube/index.html#/main/cube/search?customid=" + customSearchId;
+        }
+        return "";
+    }
 }

src/com/engine/recruit/constant/RecruitConstant.java

@@ -0,0 +1,193 @@
+package com.engine.recruit.constant;
+
+import com.engine.recruit.conn.ApplicantCommonInfo;
+import com.engine.recruit.exception.CustomizeRunTimeException;
+import org.apache.commons.lang.StringUtils;
+import weaver.general.BaseBean;
+
+import java.net.URI;
+import java.nio.charset.StandardCharsets;
+
+/**
+ * @author:dxfeng
+ * @createTime: 2024/01/17
+ * @version: 1.0
+ */
+public class RecruitConstant {
+    /**
+     * URL分隔符
+     */
+    private static final String URL_SPLIT = "/";
+
+
+    public static final String HTTP_URL;
+    public static final String RECRUIT_MESSAGE_TYPE;
+    public static final String INTERVIEW_MESSAGE_TYPE;
+    public static final String INTERVIEW_ADD_MESSAGE_TITLE;
+    public static final String INTERVIEW_CANCEL_MESSAGE_TITLE;
+    public static final String INTERVIEW_EVALUATE_MESSAGE_TITLE;
+    public static final String INTERVIEW_ADJUSTMENT_MESSAGE_TITLE;
+    public static final String JOIN_BLACKLIST_MESSAGE_TITLE;
+    public static final String SCREENING_MESSAGE_TYPE;
+    public static final String SCREENING_MESSAGE_TITLE;
+    public static final String SCREENING_MESSAGE_URL;
+    public static final String MOBILE_APPID_COLLECT;
+    public static final String COLLECT_MESSAGE_LINK;
+    public static final String MOBILE_APPID_OFFER;
+    public static final String OFFER_MOBILE_URL;
+    public static final String APPLICANTS_RESUMES_CATEGORY;
+    public static final String INTERVIEW_FEEDBACK_URL;
+    public static final String REMIND_SEARCH_LINK;
+    public static final String OCR_TYPE;
+    public static final String OCR_URL;
+    public static final String APP_ID;
+    public static final String APP_SECRET;
+
+    public static final String MODE_APP_NAME;
+
+    static BaseBean baseBean = new BaseBean();
+
+    static {
+
+        HTTP_URL = getRecruitPropValue("HTTP_URL");
+        RECRUIT_MESSAGE_TYPE = getRecruitPropValue("RECRUIT_MESSAGE_TYPE");
+
+        MOBILE_APPID_COLLECT = getRecruitPropValue("MOBILE_APPID_COLLECT");
+        // 信息采集移动建模地址
+        COLLECT_MESSAGE_LINK = getCompleteUrl(getRecruitPropValue("COLLECT_MESSAGE_LINK"));
+        MOBILE_APPID_OFFER = getRecruitPropValue("MOBILE_APPID_OFFER");
+        // offer反馈移动建模地址
+        OFFER_MOBILE_URL = getCompleteUrl(getRecruitPropValue("OFFER_MOBILE_URL"));
+        APPLICANTS_RESUMES_CATEGORY = getRecruitPropValue("APPLICANTS_RESUMES_CATEGORY");
+
+        // 简历订阅相关
+        REMIND_SEARCH_LINK = getCompleteUrl(getRecruitPropValue("REMIND_SEARCH_LINK"));
+        // OCR相关
+        OCR_TYPE = getRecruitPropValue("OCR_TYPE");
+        OCR_URL = getRecruitPropValue("OCR_URL");
+        APP_ID = getRecruitPropValue("APP_ID");
+        APP_SECRET = getRecruitPropValue("APP_SECRET");
+
+        /*处理非必填字段，为空的话，指定默认值*/
+
+        // 面试反馈消息提醒，消息来源
+        String interviewMessageType = getRecruitPropValue("INTERVIEW_MESSAGE_TYPE");
+        if (StringUtils.isBlank(interviewMessageType)) {
+            interviewMessageType = RECRUIT_MESSAGE_TYPE;
+        }
+        INTERVIEW_MESSAGE_TYPE = interviewMessageType;
+
+        // 添加面试消息提醒标题
+        String interviewAddMessageTitle = getRecruitPropValue("INTERVIEW_ADD_MESSAGE_TITLE");
+        if (StringUtils.isBlank(interviewAddMessageTitle)) {
+            interviewAddMessageTitle = "面试安排提醒";
+        }
+        INTERVIEW_ADD_MESSAGE_TITLE = interviewAddMessageTitle;
+
+        // 取消面试消息提醒标题
+        String interviewCancelMessageTitle = getRecruitPropValue("INTERVIEW_CANCEL_MESSAGE_TITLE");
+        if (StringUtils.isBlank(interviewCancelMessageTitle)) {
+            interviewCancelMessageTitle = "取消面试提醒";
+        }
+        INTERVIEW_CANCEL_MESSAGE_TITLE = interviewCancelMessageTitle;
+
+        // 面试评价消息提醒标题
+        String interviewEvaluateMessageTitle = getRecruitPropValue("INTERVIEW_EVALUATE_MESSAGE_TITLE");
+        if (StringUtils.isBlank(interviewEvaluateMessageTitle)) {
+            interviewEvaluateMessageTitle = "面试评价提醒";
+        }
+        INTERVIEW_EVALUATE_MESSAGE_TITLE = interviewEvaluateMessageTitle;
+
+        // 调整面试消息提醒标题
+        String interviewAdjustmentMessageTitle = getRecruitPropValue("INTERVIEW_ADJUSTMENT_MESSAGE_TITLE");
+        if (StringUtils.isBlank(interviewAdjustmentMessageTitle)) {
+            interviewAdjustmentMessageTitle = "面试调整提醒";
+        }
+        INTERVIEW_ADJUSTMENT_MESSAGE_TITLE = interviewAdjustmentMessageTitle;
+
+        // 人才黑名单通知,消息提醒标题
+        String joinBlacklistMessageTitle = getRecruitPropValue("JOIN_BLACKLIST_MESSAGE_TITLE");
+        if (StringUtils.isBlank(joinBlacklistMessageTitle)) {
+            joinBlacklistMessageTitle = "人才黑名单通知";
+        }
+        JOIN_BLACKLIST_MESSAGE_TITLE = joinBlacklistMessageTitle;
+
+        // 筛选反馈消息提醒，消息来源
+        String screeningMessageType = getRecruitPropValue("SCREENING_MESSAGE_TYPE");
+        if (StringUtils.isBlank(screeningMessageType)) {
+            screeningMessageType = RECRUIT_MESSAGE_TYPE;
+        }
+        SCREENING_MESSAGE_TYPE = screeningMessageType;
+
+        // 筛选反馈，消息提醒标题
+        String screeningMessageTitle = getRecruitPropValue("SCREENING_MESSAGE_TITLE");
+        if (StringUtils.isBlank(screeningMessageTitle)) {
+            screeningMessageTitle = "简历筛选";
+        }
+        SCREENING_MESSAGE_TITLE = screeningMessageTitle;
+
+        // 筛选反馈，消息提醒链接地址
+        String screeningMessageUrl = getRecruitPropValue("SCREENING_MESSAGE_URL");
+        if (StringUtils.isBlank(screeningMessageUrl)) {
+            // 根据customSearchCode，获取默认的查询列表
+            screeningMessageUrl = "/wui/index.html#/main/cube/search?customid=" + ApplicantCommonInfo.getCustomSearchId("b746e3cf80454289a3ade2b17147e297");
+        }
+        SCREENING_MESSAGE_URL = screeningMessageUrl;
+
+        // 面试反馈地址
+        String interviewFeedbackUrl = getRecruitPropValue("INTERVIEW_FEEDBACK_URL");
+        if (StringUtils.isBlank(interviewFeedbackUrl)) {
+            interviewFeedbackUrl = "/spa/custom/static/index.html#/main/cs/app/9277c228302347dc88a958b69ee96234_Interview";
+        }
+        INTERVIEW_FEEDBACK_URL = getCompleteUrl(interviewFeedbackUrl);
+
+        String modeAppName = getRecruitPropValue("MODE_APP_NAME");
+        if (StringUtils.isBlank(modeAppName)) {
+            modeAppName = "JCL_招聘管理";
+        }
+        MODE_APP_NAME = modeAppName;
+    }
+
+    /**
+     * 读取jclRecruit.properties配置文件的配置项
+     *
+     * @param key
+     * @return
+     */
+    public static String getRecruitPropValue(String key) {
+        String value = baseBean.getPropValue("jclRecruit", key);
+        value = new String(value.getBytes(StandardCharsets.ISO_8859_1), StandardCharsets.UTF_8);
+        return value;
+    }
+
+
+    /**
+     * 对外发布的URL地址，处理域名
+     *
+     * @param url
+     * @return
+     */
+    public static String getCompleteUrl(String url) {
+        if (StringUtils.isBlank(url)) {
+            return "";
+        }
+        try {
+            URI u = new URI(url);
+            // 如果URL对象的getHost()方法获取到了域名，则直接返回原始URL
+            if (u.getHost() != null) {
+                return url;
+            } else {
+                // 否则，判断URL是否以"/"开头，如果是则在它前面拼接上域名
+                if (url.startsWith(URL_SPLIT)) {
+                    return HTTP_URL + url;
+                } else {
+                    // 如果URL既不是完整URL也不是以"/"开头，则在URL开头添加"/"，再拼接上域名
+                    return HTTP_URL + URL_SPLIT + url;
+                }
+            }
+        } catch (Exception e) {
+            throw new CustomizeRunTimeException(e);
+        }
+    }
+
+}

src/com/engine/recruit/controller/ResumeRecognitionController.java

@@ -0,0 +1,56 @@
+package com.engine.recruit.controller;
+
+import com.engine.common.util.ParamUtil;
+import com.engine.common.util.ServiceUtil;
+import com.engine.recruit.util.ResponseResult;
+import com.engine.recruit.wrapper.ResumeRecognitionWrapper;
+import weaver.hrm.HrmUserVarify;
+import weaver.hrm.User;
+
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+import javax.ws.rs.GET;
+import javax.ws.rs.POST;
+import javax.ws.rs.Path;
+import javax.ws.rs.Produces;
+import javax.ws.rs.core.Context;
+import javax.ws.rs.core.MediaType;
+import java.util.Map;
+
+/**
+ * @author:dxfeng
+ * @createTime: 2023/12/12
+ * @version: 1.0
+ */
+public class ResumeRecognitionController {
+    public ResumeRecognitionWrapper getResumeRecognitionWrapper(User user) {
+        return ServiceUtil.getService(ResumeRecognitionWrapper.class, user);
+    }
+
+    @POST
+    @Path("/resumeUpload")
+    @Produces(MediaType.APPLICATION_JSON)
+    public String resumeUpload(@Context HttpServletRequest request, @Context HttpServletResponse response) {
+        User user = HrmUserVarify.getUser(request, response);
+        Map<String, Object> param = ParamUtil.request2Map(request);
+        return new ResponseResult<Map<String, Object>, Map<String, Object>>(user).run(getResumeRecognitionWrapper(user)::resumeUpload, param);
+    }
+
+    @POST
+    @Path("/importResume")
+    @Produces(MediaType.APPLICATION_JSON)
+    public String importResume(@Context HttpServletRequest request, @Context HttpServletResponse response) {
+        User user = HrmUserVarify.getUser(request, response);
+        Map<String, Object> param = ParamUtil.request2Map(request);
+        return new ResponseResult<Map<String, Object>, Map<String, Object>>(user).run(getResumeRecognitionWrapper(user)::importResume, param);
+    }
+
+    @GET
+    @Path("/fetchResume")
+    @Produces(MediaType.APPLICATION_JSON)
+    public String fetchResume(@Context HttpServletRequest request, @Context HttpServletResponse response) {
+        User user = HrmUserVarify.getUser(request, response);
+        Map<String, Object> param = ParamUtil.request2Map(request);
+        return new ResponseResult<Map<String, Object>, Map<String, Object>>(user).run(getResumeRecognitionWrapper(user)::fetchResume, param);
+    }
+}

src/com/engine/recruit/factory/ResumeRecognitionFactory.java

@@ -0,0 +1,37 @@
+package com.engine.recruit.factory;
+
+import com.engine.core.impl.Service;
+import com.engine.recruit.exception.CustomizeRunTimeException;
+import com.engine.recruit.service.ResumeRecognitionService;
+import weaver.general.BaseBean;
+
+/**
+ * @author:dxfeng
+ * @createTime: 2024/01/09
+ * @version: 1.0
+ */
+public class ResumeRecognitionFactory {
+
+    /**
+     * 根据类的全路径获取类对象
+     *
+     * @param className 类全路径
+     * @param <T>
+     * @return
+     */
+    public static <T extends Service> Class<T> getClass(String className) {
+        Class<?> clazz;
+        try {
+            clazz = Class.forName(className);
+            if (!ResumeRecognitionService.class.isAssignableFrom(clazz)) {
+                throw new IllegalArgumentException("该类未实现ResumeRecognitionService");
+            }
+            return (Class<T>) clazz;
+        } catch (ClassNotFoundException e) {
+            new BaseBean().writeLog(e);
+            throw new CustomizeRunTimeException("简历识别配置出错，未获取到解析实现类[" + className + "]");
+        }
+
+
+    }
+}

src/com/engine/recruit/service/ResumeRecognitionService.java

@@ -0,0 +1,38 @@
+package com.engine.recruit.service;
+
+import java.util.Map;
+
+/**
+ * 简历识别服务类
+ *
+ * @author:dxfeng
+ * @createTime: 2023/12/12
+ * @version: 1.0
+ */
+public interface ResumeRecognitionService {
+
+    /**
+     * 简历上传、简历解析
+     *
+     * @param param
+     * @return
+     */
+    Map<String, Object> resumeUpload(Map<String, Object> param);
+
+    /**
+     * 简历上传、解析
+     *
+     * @param param
+     * @return
+     */
+    Map<String, Object> importResume(Map<String, Object> param);
+
+
+    /**
+     * 获取简历
+     *
+     * @param param
+     * @return
+     */
+    Map<String, Object> fetchResume(Map<String, Object> param);
+}

src/com/engine/recruit/service/impl/ResumeRecognitionServiceImpl.java

@@ -0,0 +1,575 @@
+package com.engine.recruit.service.impl;
+
+import cn.hutool.core.convert.Convert;
+import com.alibaba.fastjson.JSONArray;
+import com.alibaba.fastjson.JSONObject;
+import com.engine.core.impl.Service;
+import com.engine.recruit.conn.*;
+import com.engine.recruit.constant.RecruitConstant;
+import com.engine.recruit.enums.ApplicationStatusEnum;
+import com.engine.recruit.exception.CustomizeRunTimeException;
+import com.engine.recruit.service.ResumeRecognitionService;
+import com.weaver.formmodel.data.model.Formfield;
+import org.apache.commons.collections.CollectionUtils;
+import org.apache.commons.lang3.StringUtils;
+import org.apache.http.HttpEntity;
+import org.apache.http.client.methods.CloseableHttpResponse;
+import org.apache.http.client.methods.HttpPost;
+import org.apache.http.entity.ContentType;
+import org.apache.http.entity.mime.MultipartEntityBuilder;
+import org.apache.http.impl.client.CloseableHttpClient;
+import org.apache.http.impl.client.HttpClients;
+import org.apache.http.util.EntityUtils;
+import weaver.common.DateUtil;
+import weaver.conn.RecordSet;
+import weaver.file.ImageFileManager;
+import weaver.formmode.recruit.modeexpand.util.RecruitModeUtil;
+import weaver.general.BaseBean;
+import weaver.general.Util;
+
+import java.math.BigInteger;
+import java.security.MessageDigest;
+import java.security.NoSuchAlgorithmException;
+import java.text.DateFormat;
+import java.text.SimpleDateFormat;
+import java.util.*;
+import java.util.function.Function;
+import java.util.stream.Collectors;
+
+/**
+ * @author:dxfeng
+ * @createTime: 2023/12/12
+ * @version: 1.0
+ */
+public class ResumeRecognitionServiceImpl extends Service implements ResumeRecognitionService {
+
+
+    @Override
+    public Map<String, Object> resumeUpload(Map<String, Object> param) {
+        Map<String, Object> returnMap = new HashMap<>(16);
+        String resumeId = Util.null2String(param.get("resumeId"));
+        int imageField = ApplicantCommonInfo.getImageFieldByDocId(resumeId);
+        if (-1 == imageField) {
+            throw new CustomizeRunTimeException("原始简历文件获取失败,请重新上传原始简历");
+        }
+        qllResumeUpload(imageField, returnMap, true);
+        returnMap.put("isOcr", true);
+        return returnMap;
+    }
+
+    @Override
+    public Map<String, Object> importResume(Map<String, Object> param) {
+        Map<String, Object> returnMap = new HashMap<>();
+        String resumeId = Util.null2String(param.get("resumeId"));
+        Map<String, Object> uploadDataMap = new HashMap<>();
+        qllResumeUpload(Convert.toInt(resumeId), uploadDataMap, false);
+        Map<String, Object> resumeData = (Map<String, Object>) uploadDataMap.get("data");
+        // 添加原始附件字段信息
+        int secCategory = Convert.toInt(RecruitConstant.APPLICANTS_RESUMES_CATEGORY);
+        try {
+            int docId = RecruitModeUtil.createDocId(secCategory, Convert.toInt(resumeId), user);
+            resumeData.put("ysjl", docId);
+        } catch (Exception e) {
+            throw new RuntimeException(e);
+        }
+        List<RecruitDataMap<Object>> studyList = (List<RecruitDataMap<Object>>) resumeData.remove("jyjl");
+        List<RecruitDataMap<Object>> workList = (List<RecruitDataMap<Object>>) resumeData.remove("gzjl");
+        List<RecruitDataMap<Object>> projectList = (List<RecruitDataMap<Object>>) resumeData.remove("xmjy");
+
+        // 状态
+        resumeData.put("zt", ApplicationStatusEnum.DISTRIBUTION.getValue());
+
+        List<Formfield> fieldList = RecruitModeUtil.getFieldList("uf_jcl_yppc");
+        Set<String> keySet = fieldList.stream().map(Formfield::getFieldname).collect(Collectors.toSet());
+
+        // 移除不在 keySet 中的键值对
+        resumeData.entrySet().removeIf(entry -> !keySet.contains(entry.getKey()));
+
+
+        // 判断简历信息
+        CheckRepeatResume instance = CheckRepeatResume.getInstance();
+        Map<String, Object> map = instance.insertResumeAndReturn(resumeData);
+        String mainId = Util.null2String(map.get("mainId"));
+        String sourceId = Util.null2String(map.get("sourceId"));
+        returnMap.put("mainId", mainId);
+        returnMap.put("sourceId", sourceId);
+        returnMap.put("id", StringUtils.isNotBlank(sourceId) ? sourceId : mainId);
+        instance.insertResumeDetailTable(studyList, "uf_jcl_yppc_dt1", mainId, sourceId);
+        instance.insertResumeDetailTable(workList, "uf_jcl_yppc_dt2", mainId, sourceId);
+        instance.insertResumeDetailTable(projectList, "uf_jcl_yppc_dt3", mainId, sourceId);
+        return returnMap;
+    }
+
+    @Override
+    public Map<String, Object> fetchResume(Map<String, Object> param) {
+        String id = Util.null2String(param.get("id"));
+        String sql = "select * from uf_jcl_yppc where id = ? ";
+        RecordSet rs = new RecordSet();
+        rs.executeQuery(sql, id);
+        Map<String, Object> dataMap = RecruitRecordSet.getSingleRecordMap(rs);
+
+        List<Formfield> fieldList = RecruitModeUtil.getFieldList("uf_jcl_yppc");
+        Map<String, Formfield> fieldMap = fieldList.stream().collect(Collectors.toMap(Formfield::getFieldname, item -> item, (k1, k2) -> k1));
+
+        for (String key : dataMap.keySet()) {
+            Object value = dataMap.get(key);
+            if (StringUtils.isBlank(Convert.toStr(value))) {
+                continue;
+            }
+            // 计算新的value值
+            Formfield formfield = fieldMap.get(key);
+            value = RecruitModeUtil.getFieldShowName(formfield, Convert.toStr(value)).replaceAll("<[^>]*>", "");
+            // 更新value值
+            dataMap.put(key, value);
+        }
+
+        return dataMap;
+    }
+
+
+    /**
+     * @param resumeId  简历ID
+     * @param returnMap 响应集合
+     */
+    private void qllResumeUpload(int resumeId, Map<String, Object> returnMap, boolean isCard) {
+        String response = doQllPost(resumeId);
+        if (StringUtils.isBlank(response)) {
+            throw new CustomizeRunTimeException("千里聆接口调用失败，响应结果为空");
+        }
+
+        BaseBean baseBean = new BaseBean();
+        JSONObject all = JSONObject.parseObject(response);
+        if (!all.getBoolean("isSuccess")) {
+            baseBean.writeLog("千里聆响应数据：" + all);
+            throw new CustomizeRunTimeException(all.getString("errorMsg"));
+        }
+        JSONObject resultall = all.getJSONObject("data");
+        String status = resultall.getString("state");
+        if ("fail".equals(status)) {
+            throw new CustomizeRunTimeException("调用千里聆接口失败，失败原因：" + resultall.getString("info"));
+        }
+        JSONObject result = resultall.getJSONObject("result");
+        baseBean.writeLog("千里聆OCR解析数据：" + result);
+        Map<String, Object> dataMap = parseQllJsonToMapV2(result, isCard);
+        returnMap.put("data", dataMap);
+    }
+
+
+
+    /**
+     * 千里聆解析字段内容处理(V2)
+     *
+     * @param obj
+     * @return
+     */
+    private Map<String, Object> parseQllJsonToMapV2(JSONObject obj, boolean isCard) {
+        Map<String, Object> dataMap = new HashMap<>(16);
+        JSONObject personalInformation = obj.getJSONObject("个人信息");
+        // 投递时间
+        dataMap.put("tdsj", DateUtil.getDateTime());
+        // 姓名
+        String xm = personalInformation.getString("姓名");
+        dataMap.put("xm", xm);
+        // 电子邮箱
+        String dzyx = personalInformation.getString("电子邮箱");
+        dataMap.put("dzyx", dzyx);
+        // 手机号码
+        String sjhm = personalInformation.getString("手机号");
+        dataMap.put("sjhm", sjhm);
+        // 年龄
+        String nl = personalInformation.getString("年龄");
+        if(StringUtils.isNotBlank(nl)) {
+            dataMap.put("nl", nl);
+        }
+        // 出生日期
+        String csrq = personalInformation.getString("出生日期");
+        dataMap.put("csrq", parseDateObject(csrq));
+        // 性别 默认为男
+        String xb = personalInformation.getString("性别");
+        if ("女".equals(xb)) {
+            dataMap.put("xb", 1);
+        } else if("男".equals(xb)){
+            dataMap.put("xb", 0);
+        }else{
+            dataMap.put("xb", null);
+        }
+        // 体重（KG）
+        String tz = personalInformation.getString("体重");
+        dataMap.put("tzkg", Convert.toDouble(tz));
+        // 身高（CM）
+        String sg = personalInformation.getString("身高");
+        dataMap.put("sgcm", Convert.toDouble(sg));
+        // 籍贯(字段类型不支持)
+        String jg = personalInformation.getString("籍贯");
+        //dataMap.put("jg", parseArray(obj.getJSONArray("籍贯")));
+        // 婚姻状况
+        List<Map<String, String>> hyzk = getBrowserArray(personalInformation.getString("婚姻状况"), ModeBrowserCommonInfo.TYPE_MARITAL_STATUS);
+        if (CollectionUtils.isNotEmpty(hyzk)) {
+            dataMap.put("hyzk", hyzk);
+            if (!isCard) {
+                dataMap.put("hyzk", hyzk.stream().map(item -> item.get("id")).collect(Collectors.joining(",")));
+            }
+        }
+        // 当前所在地(字段类型不支持)
+        String jdz = personalInformation.getString("现居住地");
+        //dataMap.put("jzd", parseArray(obj.getJSONArray("现居住地")));
+        // 政治面貌
+        List<Map<String, String>> zzmm = getBrowserArray(personalInformation.getString("政治面貌"), ModeBrowserCommonInfo.TYPE_POLITICAL_LANDSCAPE);
+        if (CollectionUtils.isNotEmpty(zzmm)) {
+            dataMap.put("zzmm", zzmm);
+            if (!isCard) {
+                dataMap.put("zzmm", zzmm.stream().map(item -> item.get("id")).collect(Collectors.joining(",")));
+            }
+        }
+        // 在职状态
+        List<Map<String, String>> zzzt = getBrowserArray(personalInformation.getString("在职状态"), ModeBrowserCommonInfo.TYPE_ON_THE_JOB_STATUS);
+        if (CollectionUtils.isNotEmpty(zzzt)) {
+            dataMap.put("zzzt", zzzt);
+            if (!isCard) {
+                dataMap.put("zzzt", zzzt.stream().map(item -> item.get("id")).collect(Collectors.joining(",")));
+            }
+        }
+
+        // 工作经验
+        String gzjyStr = personalInformation.getString("工作经验");
+        if(StringUtils.isNotBlank(gzjyStr)) {
+            if (gzjyStr.contains("到")) {
+                String[] split = gzjyStr.split("到");
+                if (split.length == 2) {
+                    gzjyStr = split[1];
+                }
+            }
+        }
+        List<Map<String, String>> gzjy = getBrowserArray(gzjyStr, ModeBrowserCommonInfo.TYPE_WORK_EXPERIENCE);
+        if (CollectionUtils.isNotEmpty(gzjy)) {
+            dataMap.put("gzjy", gzjy);
+            if (!isCard) {
+                dataMap.put("gzjy", gzjy.stream().map(item -> item.get("id")).collect(Collectors.joining(",")));
+            }
+        }
+        // 最高学位
+        List<Map<String, String>> zgxw = getBrowserArray(personalInformation.getString("最高学位"), ModeBrowserCommonInfo.TYPE_DEGREE);
+        if (CollectionUtils.isNotEmpty(zgxw)) {
+            dataMap.put("zgxw", zgxw);
+            if (!isCard) {
+                dataMap.put("zgxw", zgxw.stream().map(item -> item.get("id")).collect(Collectors.joining(",")));
+            }
+        }
+        // 最高学历
+        String highestEduLevel = personalInformation.getString("最高学历");
+        List<Map<String, String>> zgxl = getBrowserArray(highestEduLevel, this::getEducationLevelArray);
+        if (CollectionUtils.isNotEmpty(zgxl)) {
+            dataMap.put("zgxl", zgxl);
+            if (!isCard) {
+                dataMap.put("zgxl", zgxl.stream().map(item -> item.get("id")).collect(Collectors.joining(",")));
+            }
+        }
+
+        // 毕业院校
+        String byyx = personalInformation.getString("毕业院校");
+        dataMap.put("byyx", byyx);
+        // 现税前月薪（K）
+        // 自我评价
+        String zwpj = personalInformation.getString("个人评价");
+        dataMap.put("zwpj", zwpj);
+        // 民族
+        dataMap.put("mz", personalInformation.getString("民族"));
+
+        JSONObject jobSearchInformation = obj.getJSONObject("求职信息");
+        // 期望税前月薪（K）
+        String qwxz = jobSearchInformation.getString("期望薪资");
+        dataMap.put("qwxz", qwxz);
+
+
+        // 明细表数据
+        // 教育经历
+        JSONArray jyjl = obj.getJSONArray("学业信息");
+        List<RecruitDataMap<Object>> studyList = new ArrayList<>();
+        if (null != jyjl && jyjl.size() > 0) {
+            for (int i = 0; i < jyjl.size(); i++) {
+                JSONObject o = (JSONObject) jyjl.get(i);
+                String studyDate = o.getString("就读时期");
+                RecruitDataMap<Object> studyMap = new RecruitDataMap<>();
+                studyMap.putAll(getDateRange(studyDate, true));
+                String schoolName = o.getString("学校名称");
+                studyMap.put("xxmc", schoolName);
+                String educationLevel = o.getString("学历");
+                List<Map<String, String>> xl = getBrowserArray(educationLevel, this::getEducationLevelArray);
+                studyMap.put("xl", xl);
+                if (!isCard && CollectionUtils.isNotEmpty(xl)) {
+                    studyMap.put("xl", xl.stream().map(item -> item.get("id")).collect(Collectors.joining(",")));
+                }
+                String professionalName = o.getString("专业名称");
+                studyMap.put("zy", professionalName);
+                // 主表 专业字段
+                if (byyx.equals(schoolName) && highestEduLevel.equals(educationLevel)) {
+                    dataMap.put("zy", professionalName);
+                }
+                studyList.add(studyMap);
+            }
+        }
+        dataMap.put("jyjl", studyList);
+
+        // 工作经历
+        JSONArray gzjl = obj.getJSONArray("工作经历");
+        List<RecruitDataMap<Object>> workList = new ArrayList<>();
+        if (null != gzjl && gzjl.size() > 0) {
+            for (int i = 0; i < gzjl.size(); i++) {
+                JSONObject o = (JSONObject) gzjl.get(i);
+                String workDate = o.getString("工作时间");
+                RecruitDataMap<Object> workMap = new RecruitDataMap<>();
+                workMap.putAll(getDateRange(workDate, false));
+                workMap.put("gsmc", o.getString("工作单位"));
+                workMap.put("gw", o.getString("岗位名称"));
+                workMap.put("gzzz", o.getString("工作内容"));
+                workList.add(workMap);
+            }
+        }
+
+        dataMap.put("gzjl", workList);
+
+        // 项目经验
+        JSONArray xmjy = obj.getJSONArray("项目经验");
+        List<RecruitDataMap<Object>> projectList = new ArrayList<>();
+        if (null != xmjy && xmjy.size() > 0) {
+            for (int i = 0; i < xmjy.size(); i++) {
+                JSONObject o = (JSONObject) xmjy.get(i);
+                String startDate = getFormatDate(o.getString("开始时间"));
+                String endDate = getFormatDate(o.getString("结束时间"));
+                RecruitDataMap<Object> projectMap = new RecruitDataMap<>();
+                projectMap.put("kssj",startDate);
+                projectMap.put("jssj",endDate);
+                projectMap.put("xmmc", o.getString("项目名称"));
+                projectMap.put("drjs", o.getString("担任角色"));
+                projectMap.put("xmms", o.getString("项目描述"));
+                projectList.add(projectMap);
+            }
+        }
+
+        dataMap.put("xmjy", projectList);
+
+
+        return dataMap;
+    }
+
+    /**
+     * @param resumeId
+     * @return
+     */
+    private String doQllPost(int resumeId) {
+        String url = RecruitConstant.OCR_URL;
+        String appId = RecruitConstant.APP_ID;
+        String appSecret = RecruitConstant.APP_SECRET;
+        if (StringUtils.isAnyBlank(url, appId, appSecret)) {
+            throw new CustomizeRunTimeException("千里聆配置出错，请检查配置文件");
+        }
+
+        long currentTime = System.currentTimeMillis();
+        ImageFileManager manager = new ImageFileManager();
+        manager.getImageFileInfoById(resumeId);
+
+        HttpPost postRequest = new HttpPost(url);
+        postRequest.addHeader("sign", getSign(appId, appSecret, currentTime));
+        postRequest.addHeader("appId", appId);
+        postRequest.addHeader("timestamp", String.valueOf(currentTime));
+        MultipartEntityBuilder builder = MultipartEntityBuilder.create();
+        String fileName = manager.getImageFileName();
+        builder.addTextBody("type", fileName.substring(fileName.lastIndexOf('.') + 1));
+        // 对接新版抽取服务
+        builder.addTextBody("version", "V2");
+        builder.addBinaryBody("resume", manager.getInputStream(), ContentType.APPLICATION_OCTET_STREAM, manager.getImageFileName());
+        HttpEntity entity = builder.build();
+        postRequest.setEntity(entity);
+        try {
+            CloseableHttpClient httpClient = HttpClients.createDefault();
+            CloseableHttpResponse response = httpClient.execute(postRequest);
+            HttpEntity responseEntity = response.getEntity();
+            return EntityUtils.toString(responseEntity);
+        } catch (Exception e) {
+            throw new CustomizeRunTimeException(e);
+        }
+    }
+
+
+    /**
+     * 千里聆签名
+     *
+     * @param appId     开发者AppId
+     * @param appSecret 开发者appSecret
+     * @param timestamp 当前时间戳(毫秒数)
+     * @return
+     */
+    private static String getSign(String appId, String appSecret, long timestamp) {
+        if (appId != null && appId.length() != 0) {
+            if (appSecret != null && appSecret.length() != 0) {
+                try {
+                    MessageDigest md5 = MessageDigest.getInstance("MD5");
+                    md5.update(appId.getBytes());
+                    md5.update((timestamp + "").getBytes());
+                    md5.update(appSecret.getBytes());
+                    byte[] bytes = md5.digest();
+                    return (new BigInteger(1, bytes)).toString(16);
+                } catch (NoSuchAlgorithmException var8) {
+                    throw new CustomizeRunTimeException("不支持的加密算法", var8);
+                }
+            } else {
+                throw new CustomizeRunTimeException("appSecret不能为空");
+            }
+        } else {
+            throw new CustomizeRunTimeException("appId不能为空");
+        }
+    }
+
+
+
+    /**
+     * 转换日期对象
+     *
+     * @param value
+     * @return
+     */
+    private String parseDateObject(String value) {
+        if (StringUtils.isBlank(value)) {
+            return null;
+        }
+        value = value.replace(".", "-");
+        DateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
+        sdf.setLenient(false);
+        try {
+            sdf.parse(value);
+        } catch (Exception e) {
+            new BaseBean().writeLog("日期格式化失败", e);
+            value = null;
+        }
+        return value;
+    }
+
+    /**
+     * 获取开始时间和结束时间
+     *
+     * @param date
+     * @return
+     */
+    private RecruitDataMap<Object> getDateRange(String date, boolean isStudy) {
+        RecruitDataMap<Object> dataRangeMap = new RecruitDataMap();
+        if (StringUtils.isBlank(date)) {
+            return dataRangeMap;
+        } 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);
+            }
+
+            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;
+        }
+    }
+
+    /**
+     * 获取yyyy-MM-dd时间格式日期
+     *
+     * @param dateStr
+     * @return
+     */
+    private String getFormatDate(String dateStr) {
+        dateStr = dateStr.replace(".", "-").replace("\\/", "-");
+        if (dateStr.length() == 7) {
+            return dateStr + "-01";
+        } else if (dateStr.length() == 10) {
+            return dateStr;
+        } else if (dateStr.length() == 4) {
+            return dateStr;
+        }
+        return "";
+    }
+
+
+    /**
+     * 构建浏览按钮字段信息格式
+     *
+     * @param text
+     * @param fun
+     * @return
+     */
+    private List<Map<String, String>> getBrowserArray(String text, Function<String, Map<String, String>> fun) {
+        List<Map<String, String>> list = new ArrayList<>();
+        if (StringUtils.isNotBlank(text)) {
+            String[] split = text.split(",");
+            for (String s : split) {
+                Map<String, String> apply = fun.apply(s);
+                list.add(apply);
+            }
+        }
+
+        return list;
+    }
+
+    /**
+     * 构建浏览按钮字段信息格式
+     *
+     * @param text
+     * @param browserType
+     * @return
+     */
+    private List<Map<String, String>> getBrowserArray(String text, String browserType) {
+        List<Map<String, String>> list = new ArrayList<>();
+        if (StringUtils.isNotBlank(text)) {
+            String[] split = text.split(",");
+            for (String s : split) {
+                Map<String, String> map = new HashMap<>(2);
+                if (StringUtils.isNotBlank(text)) {
+                    String id = ModeBrowserCommonInfo.getBrowserId(browserType, text);
+                    if (StringUtils.isNotBlank(id)) {
+                        map.put("id", id);
+                        map.put("name", text);
+                    }
+                }
+                list.add(map);
+            }
+        }
+
+        return list;
+    }
+
+    /**
+     * 构建学历字段信息
+     *
+     * @param text
+     * @return
+     */
+    private Map<String, String> getEducationLevelArray(String text) {
+        Map<String, String> map = new HashMap<>(2);
+        if (StringUtils.isNotBlank(text)) {
+            String id = ModeBrowserCommonInfo.getEducationLevelId(text);
+            if (StringUtils.isNotBlank(id)) {
+                map.put("id", id);
+                map.put("name", text);
+            }
+        }
+        return map;
+    }
+
+
+}

src/com/engine/recruit/wrapper/ResumeRecognitionWrapper.java

@@ -0,0 +1,44 @@
+package com.engine.recruit.wrapper;
+
+import com.engine.common.util.ServiceUtil;
+import com.engine.core.impl.Service;
+import com.engine.recruit.constant.RecruitConstant;
+import com.engine.recruit.factory.ResumeRecognitionFactory;
+import com.engine.recruit.service.ResumeRecognitionService;
+import org.apache.commons.lang3.StringUtils;
+import weaver.hrm.User;
+
+import java.util.Map;
+
+/**
+ * @author:dxfeng
+ * @createTime: 2023/12/12
+ * @version: 1.0
+ */
+public class ResumeRecognitionWrapper extends Service {
+
+    private ResumeRecognitionService getResumeRecognitionService(User user) {
+        return ServiceUtil.getService(ResumeRecognitionFactory.getClass(RecruitConstant.OCR_TYPE), user);
+    }
+
+    public Map<String, Object> resumeUpload(Map<String, Object> param) {
+        if (StringUtils.isBlank(RecruitConstant.OCR_TYPE)) {
+            return null;
+        }
+        return getResumeRecognitionService(user).resumeUpload(param);
+    }
+
+    public Map<String, Object> importResume(Map<String, Object> param) {
+        if (StringUtils.isBlank(RecruitConstant.OCR_TYPE)) {
+            return null;
+        }
+        return getResumeRecognitionService(user).importResume(param);
+    }
+
+    public Map<String, Object> fetchResume(Map<String, Object> param) {
+        if (StringUtils.isBlank(RecruitConstant.OCR_TYPE)) {
+            return null;
+        }
+        return getResumeRecognitionService(user).fetchResume(param);
+    }
+}