package com.kingdee.eas.custom.recuritment.task; import com.alibaba.fastjson.JSONArray; import com.alibaba.fastjson.JSONObject; import com.kingdee.bos.BOSException; import com.kingdee.bos.Context; import com.kingdee.bos.dao.IObjectPK; import com.kingdee.bos.dao.ormapping.ObjectUuidPK; import com.kingdee.bos.metadata.entity.*; import com.kingdee.bos.metadata.query.util.CompareType; import com.kingdee.bos.util.BOSUuid; import com.kingdee.eas.basedata.hraux.*; import com.kingdee.eas.basedata.org.HROrgUnitInfo; import com.kingdee.eas.basedata.person.BloodType; import com.kingdee.eas.basedata.person.Genders; import com.kingdee.eas.common.EASBizException; import com.kingdee.eas.csinterface.agent.service.base.util.DateTimeUtils; import com.kingdee.eas.custom.beisen.utils.BeisenApiClient; import com.kingdee.eas.custom.beisen.utils.BeisenParam; import com.kingdee.eas.custom.beisen.utils.BeisenParamByProperties; import com.kingdee.eas.custom.recuritment.ApplicantBeisenCollection; import com.kingdee.eas.custom.recuritment.ApplicantBeisenFactory; import com.kingdee.eas.custom.recuritment.ApplicantBeisenInfo; import com.kingdee.eas.custom.recuritment.IApplicantBeisen; import com.kingdee.eas.custom.recuritment.bizEnum.ExecuteResultEnum; import com.kingdee.eas.custom.recuritment.utils.AttachmentUtils; import com.kingdee.eas.custom.recuritment.utils.InitialValueUtils; import com.kingdee.eas.hr.base.IRelation; import com.kingdee.eas.hr.base.RelationCollection; import com.kingdee.eas.hr.base.RelationFactory; import com.kingdee.shr.recuritment.*; import com.kingdee.util.StringUtils; import org.apache.commons.lang3.ObjectUtils; import org.apache.log4j.Logger; import org.apache.logging.log4j.util.TriConsumer; import java.io.IOException; import java.text.ParseException; import java.time.LocalDate; import java.time.LocalDateTime; import java.time.format.DateTimeFormatter; import java.util.*; public class RecuritmentFacadeControllerBean extends AbstractRecuritmentFacadeControllerBean { private static final Logger logger = Logger.getLogger(RecuritmentFacadeControllerBean.class); // 北京时区/shanghai时区 // private static final ZoneId BEIJING_ZONE = ZoneId.of("Asia/Shanghai"); private static final DateTimeFormatter TIME_FORMATTER = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"); /** * 同步北森简历和附件 * * @param ctx * @param billId 单据ID * @throws BOSException * @throws EASBizException */ @Override protected void _syncBeisenResume(Context ctx, String billId) throws BOSException, EASBizException { super._syncBeisenResume(ctx, billId); //北森应聘者 IApplicantBeisen iApplicantBeisen = ApplicantBeisenFactory.getLocalInstance(ctx); FilterInfo filterInfo = new FilterInfo(); FilterItemCollection filterItems = filterInfo.getFilterItems(); if (!StringUtils.isEmpty(billId)) { filterItems.add(new FilterItemInfo("id", billId)); } else { filterItems.add(new FilterItemInfo("syncStatus", "0")); } EntityViewInfo entityViewInfo = EntityViewInfo.getInstance(filterInfo, null, null); ApplicantBeisenCollection applicantBeisenCollection = iApplicantBeisen.getApplicantBeisenCollection(entityViewInfo); //同步结果 int errorSize = 0; int successSize = 0; Map msgMap = new HashMap(); for (int i = 0; i < applicantBeisenCollection.size(); i++) { ApplicantBeisenInfo applicantBeisenInfo = applicantBeisenCollection.get(i); //申请id String applyId = applicantBeisenInfo.getApplyId(); //应聘者id String candidateId = applicantBeisenInfo.getCandidateId(); try { IResumeBaseRec iResumeBaseRec = ResumeBaseRecFactory.getLocalInstance(ctx); ResumeBaseRecCollection collection = iResumeBaseRec.getResumeBaseRecCollection("select * ,resumeState.number where applyId = '" + applyId + "'"); // 1. 获取简历基础信息 ResumeBaseRecInfo resumeInfo = collection.get(0); if (resumeInfo == null) { resumeInfo = new ResumeBaseRecInfo(); resumeInfo.put("applyId", applyId); resumeInfo.put("candidateId", candidateId); } else if (!"0001".equals(resumeInfo.getResumeState().getNumber())) { continue; } //通过申请ID获取招聘需求 RecuritmentDemandInfo recuritmentDemandInfo = getRecuritmentByApplyId(ctx, applyId); //招聘需求 resumeInfo.setRecuritmentDemand(recuritmentDemandInfo); //招聘职位 resumeInfo.setDepartment(recuritmentDemandInfo.getDepartment()); //招聘部门 resumeInfo.setRecuritPosition(recuritmentDemandInfo.getRecuritPosition()); //北森应聘者-需求管理 applicantBeisenInfo.setRecuritment(recuritmentDemandInfo); // 2. 获取 标准简历数据 JSONObject resumeJson = getResumeByApplyId(applyId); logger.error("resumeJson--" + resumeJson); Integer code = resumeJson.getInteger("code"); if (200 == code) { JSONObject data = resumeJson.getJSONObject("data"); // 3. 处理简历各部分数据 processResumeSections(ctx, data, resumeInfo); //删除附件信息 AttachmentUtils.deleteAttachment(ctx, resumeInfo.getId().toString()); // 根据申请Id获取并处理简历文件 processResumeFile(applyId, ctx, resumeInfo, "标准简历"); // 获取并处理面试评价文件 processResumeFile(applyId, ctx, resumeInfo, "面试评价"); applicantBeisenInfo.setSyncResult("同步成功!"); applicantBeisenInfo.setSyncStatus(ExecuteResultEnum.SUCCESS); successSize++; } else { throw new BOSException(resumeJson.getString("message")); } iApplicantBeisen.save(applicantBeisenInfo); } catch (Exception e) { applicantBeisenInfo.setSyncStatus(ExecuteResultEnum.ERROR); applicantBeisenInfo.setSyncResult("简历处理失败: " + e.getMessage()); iApplicantBeisen.save(applicantBeisenInfo); errorSize++; logger.error("简历处理失败: " + e.getMessage(), e); } } logger.error("成功条数" + successSize); logger.error("失败条数" + errorSize); } /** * 通过申请ID获取需求管理 * * @param applyId */ public RecuritmentDemandInfo getRecuritmentByApplyId(Context ctx, String applyId) throws IOException, BOSException { BeisenApiClient beisenApiClient = BeisenApiClient.getInstance(); JSONObject pamas = new JSONObject(); JSONArray applyIds = new JSONArray(); applyIds.add(applyId); pamas.put("applyIds", applyIds); String jobId = ""; //根据申请ID获取申请信息 JSONObject applyJson = beisenApiClient.callApi(BeisenParam.GET_APPLYLIST_APPLYID, pamas); logger.error("applyJson--" + applyJson); if (200 == applyJson.getInteger("code")) { JSONArray data = applyJson.getJSONArray("data"); JSONObject applyData = data.getJSONObject(0); //职位ID jobId = applyData.getString("jobId"); } else { throw new BOSException("根据申请ID获取申请信息失败,原因:" + applyJson.get("message")); } logger.error("jobId--" + jobId); //根据ID获取获取数据单条 JSONObject entityPamas = new JSONObject(); entityPamas.put("id", jobId); entityPamas.put("metaObjectName", "Recruitment.Job"); JSONObject entity = beisenApiClient.callApi(BeisenParam.GET_ENTITY, entityPamas); logger.error("entity--" + entity); if (200 != applyJson.getInteger("code")) { throw new BOSException("根据ID获取获取数据单条失败,原因:" + entity.get("message")); } JSONObject entityData = entity.getJSONObject("data"); //根据招聘需求ID获取招聘需求 JSONObject columns = entityData.getJSONObject("columns"); JSONObject recruit = columns.getJSONObject("RecruitRequirementIds"); if (recruit == null) { throw new BOSException("未查询到需求IDRecruitRequirementIds"); } String recruitRequirementId = recruit.getString("value"); //招聘需求 IRecuritmentDemand iRecuritmentDemand = RecuritmentDemandFactory.getLocalInstance(ctx); if (StringUtils.isEmpty(recruitRequirementId)) { throw new BOSException("通过applyId[" + applyId + "]未查询到招聘需求！"); } logger.error("requirementId--" + recruitRequirementId); //招聘需求 RecuritmentDemandCollection recuritmentDemandCollection = iRecuritmentDemand.getRecuritmentDemandCollection("where requirementId='" + recruitRequirementId + "'"); if (recuritmentDemandCollection.isEmpty()) { throw new BOSException("sHR未查询到对应的招聘需求，北森需求ID:" + recruitRequirementId); } return recuritmentDemandCollection.get(0); } /** * 处理简历文件或面试评价文件 * * @param applyId 申请ID * @param ctx 上下文 * @param resumeInfo 简历信息 * @param fileType 文件类型("标准简历"或"面试评价") */ private void processResumeFile(String applyId, Context ctx, ResumeBaseRecInfo resumeInfo, String fileType) { logger.error("processResumeFile--"); try { // 根据文件类型获取对应的文件信息 JSONObject fileInfo = "标准简历".equals(fileType) ? getStandardResumeFileUrlByApplyId(applyId) : getInterviewEvaluationFile(applyId); logger.error("fileInfo--" + fileInfo); if (fileInfo == null) { throw new BOSException("获取{}文件信息失败: 返回结果为null" + fileType); } Integer code = fileInfo.getInteger("code"); if (!Integer.valueOf(200).equals(code)) { throw new BOSException("获取{" + fileType + "}文件失败: 返回code={" + code + "}"); } JSONObject data = fileInfo.getJSONObject("data"); if (data == null) { throw new BOSException("获取{" + fileType + "}文件失败: data字段为空"); } String downloadUrl = data.getString("downloadUrl"); String dfsPath = data.getString("dfsPath"); if (com.kingdee.bos.rabbitmq.util.StringUtils.isBlank(downloadUrl) || com.kingdee.bos.rabbitmq.util.StringUtils.isBlank(dfsPath)) { throw new BOSException("获取{" + fileType + "}文件失败: downloadUrl或dfsPath为空"); } // 处理文件名 String fileName = AttachmentUtils.extractFileNameFromPath(dfsPath); String fileExtension = AttachmentUtils.extractFileExtension(fileName); String customFileName = "北森" + fileType + "." + fileExtension; // 获取文件内容并保存 byte[] fileData = AttachmentUtils.getBytesByNetURL("https:" + downloadUrl); if (fileData == null || fileData.length == 0) { throw new BOSException("获取{" + fileType + "}文件内容失败: 下载内容为空"); } AttachmentUtils.insertAttachment(ctx, customFileName, resumeInfo, fileData); logger.info("{" + fileType + "}文件处理成功: {" + customFileName + "}"); } catch (Exception e) { logger.error("处理" + fileType + "文件时发生异常", e); } } /** * 处理简历各部分数据 */ private void processResumeSections(Context ctx, JSONObject resumeJson, ResumeBaseRecInfo resumeInfo) throws BOSException, EASBizException, ParseException, IOException { JSONArray personProfile = resumeJson.getJSONArray("personProfile"); saveResumeBaseRec(ctx, personProfile, resumeInfo); JSONArray education = resumeJson.getJSONArray("education"); saveEducationExpRE(ctx, education, resumeInfo); // 使用Map定义简历部分与处理方法的对应关系 Map> sectionHandlers = new LinkedHashMap<>(); //sectionHandlers.put("personProfile", this::saveResumeBaseRec); sectionHandlers.put("workExperience", this::saveWorkingExp); //sectionHandlers.put("education", this::saveEducationExpRE); sectionHandlers.put("project", this::saveProjectExp); sectionHandlers.put("train", this::saveTrainingExp); sectionHandlers.put("certificate", this::saveCredential); sectionHandlers.put("lang", this::saveLanguageAbility); sectionHandlers.put("skill", this::saveProfessionalSkills); sectionHandlers.put("awards", this::saveResumeRewardPunish); // sectionHandlers.put("family", this::saveFamilyInfo); // 遍历处理所有简历部分 sectionHandlers.forEach((sectionKey, handler) -> { //判断是否存key if (resumeJson.containsKey(sectionKey)) { JSONArray sectionData = resumeJson.getJSONArray(sectionKey); if (sectionData != null && !sectionData.isEmpty()) { handler.accept(ctx, sectionData, resumeInfo); } } }); } /** * 根据申请Id获取标准简历文件 * * @param applyId * @return */ public JSONObject getStandardResumeFileUrlByApplyId(String applyId) throws IOException { String param = "?applyId=" + applyId; BeisenApiClient beisenApiClient = BeisenApiClient.getInstance(); JSONObject jsonObject = beisenApiClient.callGetApi(BeisenParam.GET_STANDERDRESUMEFILURLBYAPPLYID + param, new JSONObject()); return jsonObject; } /** * 根据申请Id获取标准简历文件 * * @param applyId * @return */ public JSONObject getInterviewEvaluationFile(String applyId) throws IOException { String param = "?applyId=" + applyId; BeisenApiClient beisenApiClient = BeisenApiClient.getInstance(); JSONObject jsonObject = beisenApiClient.callGetApi(BeisenParam.GET_INTERVIEWEVALUATIONFILE + param, new JSONObject()); return jsonObject; } /** * 根据申请Id获取标准简历 * * @param applyId * @return */ public JSONObject getResumeByApplyId(String applyId) throws IOException { String param = "?applyId=" + applyId; BeisenApiClient beisenApiClient = BeisenApiClient.getInstance(); JSONObject jsonObject = beisenApiClient.callGetApi(BeisenParam.GET_RESUMEBYAPPLYID + param, new JSONObject()); return jsonObject; } /** * 招聘管理简历基本信息 * * @param personProfile */ public void saveResumeBaseRec(Context ctx, JSONArray personProfile, ResumeBaseRecInfo resumeBaseRecInfo) throws BOSException, EASBizException, ParseException, IOException { logger.error("personProfile--" + personProfile); BeisenParamByProperties beisenParamByProperties = new BeisenParamByProperties(); Map config = beisenParamByProperties.getConfig(); //招聘业务组织 HROrgUnitInfo hrOrgUnitInfo = new HROrgUnitInfo(); hrOrgUnitInfo.setId(BOSUuid.read("00000000-0000-0000-0000-000000000000CCE7AED4")); resumeBaseRecInfo.setHrOrgUnit(hrOrgUnitInfo); //来源方式 INTEGRATESYSTEM=集成系统 resumeBaseRecInfo.setSourceMethod(ResumeSourceMethod.INTEGRATESYSTEM); //招聘状态 WAITING 待筛选 resumeBaseRecInfo.setResumeStatus(ResumeStatusEnum.WAITING); //招聘状态 0001 待筛选 IResumeState iResumeState = ResumeStateFactory.getLocalInstance(ctx); ResumeStateInfo resumeStateInfo = iResumeState.getResumeStateInfo("where number = '0001'"); resumeBaseRecInfo.setResumeState(resumeStateInfo); //入库时间 resumeBaseRecInfo.setWarehouseEntry(new Date()); //国籍 INationality iNationality = NationalityFactory.getLocalInstance(ctx); //学历 IDiploma iDiploma = DiplomaFactory.getLocalInstance(ctx); //政治面貌 IPoliticalFace iPoliticalFace = PoliticalFaceFactory.getLocalInstance(ctx); //民族 IFolk iFolk = FolkFactory.getLocalInstance(ctx); //婚姻状况 IWed iWed = WedFactory.getLocalInstance(ctx); //血型 Map bloodTypeMap = InitialValueUtils.bloodTypeMap; String carType = "";//证件类型 String carno = "";//证件号 for (int i = 0; i < personProfile.size(); i++) { JSONObject data = personProfile.getJSONObject(i); String name = data.getString("name"); String value = data.getString("value"); String text = data.getString("text"); //姓名 if ("Name".equals(name)) { resumeBaseRecInfo.setName(text); } //参加工作时间 if ("WorkStartTime".equals(name)) { resumeBaseRecInfo.setWorkDate(DateTimeUtils.parseDate(text, "yyyy/MM/dd")); } //参加工作年限 workSeniority if ("YearsOfWork".equals(name)) { resumeBaseRecInfo.setWorkSeniority(text); } //身份证号码 identityCardNo if ("CertificateNumber".equals(name)) { carno = text; if ("身份证".equals(carType)) { resumeBaseRecInfo.setIdentityCardNo(carno); resumeBaseRecInfo.setPassportNo(""); } else { resumeBaseRecInfo.setPassportNo(carno); } } //证件类型 if ("CertificateType".equals(name)) { carType = text; if ("身份证".equals(text)) { resumeBaseRecInfo.setIdentityCardNo(carno); resumeBaseRecInfo.setPassportNo(""); } else { resumeBaseRecInfo.setPassportNo(carno); } } //出生年月 birthday if ("Birthday".equals(name)) { resumeBaseRecInfo.setBirthday(DateTimeUtils.parseDate(text, "yyyy/MM/dd")); } //户口所在地 domicilePlace if ("AccountArea".equals(name)) { resumeBaseRecInfo.setDomicilePlace(text); } //QQ QQ if ("QQ".equals(name)) { resumeBaseRecInfo.setQQ(text); } //身高 stature if ("Height".equals(name)) { resumeBaseRecInfo.setStature(text); } //现居住地 nowResidence if ("LivingArea".equals(name)) { resumeBaseRecInfo.setNowResidence(text); } //手机号 mobilePhone if ("Mobile".equals(name)) { resumeBaseRecInfo.setMobilePhone(text); } //家庭电话 fixedPhone if ("Telephone".equals(name)) { resumeBaseRecInfo.setFixedPhone(text); } //邮件 email if ("Email".equals(name)) { resumeBaseRecInfo.setEmail(text); } //目前年薪 annualPay if ("Salary".equals(name)) { resumeBaseRecInfo.setAnnualPay(text); } //目前工作状态 currentWorkingStatus if ("JobHunting".equals(name)) { resumeBaseRecInfo.setCurrentWorkingStatus(CurrentWorkingStatusEnum.getEnum(Integer.parseInt(value) - 1)); } //期望年薪 expectantPay if ("ExpectSalary".equals(name)) { resumeBaseRecInfo.setExpectantPay(Integer.parseInt(text)); } //职业目标 careerGoal if ("CareerGoals".equals(name)) { resumeBaseRecInfo.setCareerGoal(text); } //自我评价 selfEvaluation if ("Evaluation".equals(name)) { resumeBaseRecInfo.setSelfEvaluation(text); } //国籍 national if ("Nationality".equals(name)) { NationalityCollection nationalityCollection = iNationality.getNationalityCollection("where name like '%" + text + "%'"); if (nationalityCollection.size() > 0) { resumeBaseRecInfo.setNational(nationalityCollection.get(0)); } } //籍贯 nativePlace if ("NativeArea".equals(name)) { resumeBaseRecInfo.setNativePlace(text); } //年龄 age if ("OceanAge".equals(name)) { resumeBaseRecInfo.setAge(Integer.parseInt(text)); } //最高学历 hDegree if ("EducationLevel".equals(name)) { DiplomaCollection diplomaCollection = iDiploma.getDiplomaCollection("where beisenVal = '" + value + "'"); if (!diplomaCollection.isEmpty()) { resumeBaseRecInfo.setHDegree(diplomaCollection.get(0)); } } //政治面貌 politicalFace if ("Polity".equals(name)) { PoliticalFaceCollection politicalFaceCollection = iPoliticalFace.getPoliticalFaceCollection("where beisenVal = '" + value + "'"); if (!politicalFaceCollection.isEmpty()) { resumeBaseRecInfo.setPoliticalFace(politicalFaceCollection.get(0)); } } //婚姻状况 wed 北森已停用字段 if (config.get("WedState").equals(name)) { WedCollection wedCollection = iWed.getWedCollection("where beisenVal = '" + value + "'"); if (!wedCollection.isEmpty()) { resumeBaseRecInfo.setWed(wedCollection.get(0)); } } //民族 folk if ("Nation".equals(name)) { FolkCollection folkCollection = iFolk.getFolkCollection("where beisenVal = '" + value + "'"); if (!folkCollection.isEmpty()) { resumeBaseRecInfo.setFolk(folkCollection.get(0)); } } //毕业学校 school if ("LastSchool".equals(name)) { if (StringUtils.isEmpty(text)) { throw new BOSException("毕业学校不能为空！"); } resumeBaseRecInfo.setName(text); } //血型 bloodType if ("BloodType".equals(name)) { String hDegree = bloodTypeMap.getOrDefault(value, "90"); resumeBaseRecInfo.setBloodType(BloodType.getEnum(hDegree)); } //紧急联系人 emergencyContact if ("EmergencyContact".equals(name)) { resumeBaseRecInfo.setEmergencyContact(text); } //紧急联系人电话 emergencyContactPhone if ("EmergencyPhone".equals(name)) { resumeBaseRecInfo.setEmergencyContactPhone(text); } //期望月薪 expectantPayStr if ("ExpectSalary".equals(name)) { resumeBaseRecInfo.setExpectantPayStr(text); } //最近工作单位 lastCompany if ("LastCompany".equals(name)) { resumeBaseRecInfo.setLastCompany(text); } //最近工作行业 lastIndustry if ("LastIndustry".equals(name)) { resumeBaseRecInfo.setLastIndustry(text); } //专业 major if ("LastDiscipline".equals(name)) { resumeBaseRecInfo.setMajor(text); } //性别 gender if ("Gender".equals(name)) { if ("1".equals(value) || "0".equals(value)) { resumeBaseRecInfo.setGender(Genders.getEnum(Integer.parseInt(value) + 1)); } } //更新简历时间 updateResumeDate if ("ResumeUpdateTime".equals(name)) { resumeBaseRecInfo.setUpdateResumeDate(DateTimeUtils.parseDate(text, "yyyy/MM/dd")); } //签发机关 idCardIssueOrg if ("CertificateGrantUnit".equals(name)) { resumeBaseRecInfo.setIdentityCardNo(text); } //证件有效期-开始时间 idCardBeginDate if ("CertificateValidityDate".equals(name)) { resumeBaseRecInfo.setIdCardBeginDate(DateTimeUtils.parseDate(text, "yyyy/MM/dd")); } //证件有效期-结束时间 idCardEndDate if ("CertificateValidityOverDate".equals(name)) { resumeBaseRecInfo.setIdCardEndDate(DateTimeUtils.parseDate(text, "yyyy/MM/dd")); } //到岗时间 arrivalTime if ("AvailableDate".equals(name)) { resumeBaseRecInfo.setArrivalTime(DateTimeUtils.parseDate(text, "yyyy/MM/dd")); } //英文名 EnglishName if ("NameEn".equals(name)) { resumeBaseRecInfo.setEnglishName(text); } //户籍地址 domicileAddress if ("Address".equals(name)) { resumeBaseRecInfo.setDomicileAddress(text); } } String errorMsg = "，身份证号码、手机号为必填数据，请在北森维护数据后再次同步！"; if (StringUtils.isEmpty(resumeBaseRecInfo.getIdentityCardNo()) && StringUtils.isEmpty(resumeBaseRecInfo.getPassportNo())) { throw new BOSException("身份证号码不能为空" + errorMsg); } if (StringUtils.isEmpty(resumeBaseRecInfo.getMobilePhone())) { throw new BOSException("手机号码不能为空" + errorMsg); } IResumeBaseRec iResumeBaseRec = ResumeBaseRecFactory.getLocalInstance(ctx); IObjectPK save = iResumeBaseRec.save(resumeBaseRecInfo); logger.error("resumeBaseRecId--" + save); // } catch (Exception e) { // logger.error("简历基本信息报错信息：" + e.getMessage()); // throw new RuntimeException(e); // } } /** * 简历-工作经历 * * @param workExperience */ public void saveWorkingExp(Context ctx, JSONArray workExperience, ResumeBaseRecInfo resumeBaseRecInfo) { logger.error("workExperience--" + workExperience); try { IWorkingExp iWorkingExp = WorkingExpFactory.getLocalInstance(ctx); WorkingExpCollection workingExpColl = iWorkingExp.getWorkingExpCollection("where resumeBase = '" + resumeBaseRecInfo.getId().toString() + "'"); if (!workingExpColl.isEmpty()) { iWorkingExp.delete("where resumeBase = '" + resumeBaseRecInfo.getId().toString() + "'"); } for (int i = 0; i < workExperience.size(); i++) { JSONArray array = workExperience.getJSONArray(i); WorkingExpInfo workingExpInfo = new WorkingExpInfo(); //简历基本信息 workingExpInfo.setResumeBase(resumeBaseRecInfo); for (int j = 0; j < array.size(); j++) { JSONObject data = array.getJSONObject(j); String name = data.getString("name"); String value = data.getString("value"); String text = data.getString("text"); //dateStart 开始时间 if ("StartDate".equals(name)) { workingExpInfo.setDateStart(DateTimeUtils.parseDate(text, "yyyy/MM")); } //dateEnd 结束时间 if ("EndDate".equals(name)) { if ("至今".equals(text)) { text = "2199/12"; } workingExpInfo.setDateEnd(DateTimeUtils.parseDate(text, "yyyy/MM")); } //company 公司名称 if ("CompanyName".equals(name)) { workingExpInfo.setCompany(text); } //department 任职部门 if ("Department".equals(name)) { workingExpInfo.setDepartment(text); } //jobCategory 职位类别 if ("OgJobLevel".equals(name)) { workingExpInfo.setJobCategory(text); } //industry 所属行业 if ("Industry".equals(name)) { workingExpInfo.setIndustry(text); } //position 职位名称 if ("JobTitle".equals(name)) { workingExpInfo.setPosition(text); } //underlingNumber 下属人数 if ("SubordinateNumber".equals(name)) { workingExpInfo.setUnderlingNumber(Integer.parseInt(text)); } //monthPay 税前月薪 if ("Salary".equals(name)) { workingExpInfo.setMonthPay(Integer.parseInt(text)); } //certifier 证明人 if ("ReferenceName".equals(name)) { workingExpInfo.setCertifier(text); } //leavingReason 离职原因 if ("ReasonOfLeaving".equals(name)) { workingExpInfo.setLeavingReason(text); } //certifierPhone 证明人电话 if ("ReferenceContact".equals(name)) { workingExpInfo.setCertifierPhone(text); } //monthPayStr 税前月薪 if ("Salary".equals(name)) { workingExpInfo.setMonthPayStr(text); } //unitAddress 工作地点 OgJobArea if ("JobArea".equals(name)) { workingExpInfo.setUnitAddress(text); } } iWorkingExp.save(workingExpInfo); } } catch (Exception e) { logger.error("简历-工作经历保存失败！" + e.getMessage()); } } /** * 简历-教育经历 * * @param education */ public void saveEducationExpRE(Context ctx, JSONArray education, ResumeBaseRecInfo resumeBaseRecInfo) throws BOSException, EASBizException { logger.error("education--" + education); try { IEducationExpREC iEducationExpREC = EducationExpRECFactory.getLocalInstance(ctx); EducationExpRECCollection educationExpRECCollection = iEducationExpREC.getEducationExpRECCollection("where resumeBase = '" + resumeBaseRecInfo.getId().toString() + "'"); if (!educationExpRECCollection.isEmpty()) { iEducationExpREC.delete("where resumeBase = '" + resumeBaseRecInfo.getId().toString() + "'"); } //学历 IDiploma iDiploma = DiplomaFactory.getLocalInstance(ctx); //学位 IDegree iDegree = DegreeFactory.getLocalInstance(ctx); //学院类型 Map bchoolTypeMap = InitialValueUtils.getBchoolTypeMap(); for (int i = 0; i < education.size(); i++) { JSONArray array = education.getJSONArray(i); EducationExpRECInfo educationExpRECInfo = new EducationExpRECInfo(); //简历基本信息 educationExpRECInfo.setResumeBase(resumeBaseRecInfo); for (int j = 0; j < array.size(); j++) { JSONObject data = array.getJSONObject(j); String name = data.getString("name"); String value = data.getString("value"); String text = data.getString("text"); //dateStart 开始时间 if ("StartDate".equals(name)) { educationExpRECInfo.setDateStart(DateTimeUtils.parseDate(text, "yyyy/MM")); } //dateEnd 结束时间 if ("EndDate".equals(name)) { if ("至今".equals(text)) { text = "2199/12"; } educationExpRECInfo.setDateEnd(DateTimeUtils.parseDate(text, "yyyy/MM")); } //school 毕业学校 if ("SchoolName".equals(name)) { educationExpRECInfo.setSchool(text); } //academicDiplomasF7 学位 if ("Degree".equals(name)) { DegreeCollection degreeCollection = iDegree.getDegreeCollection("where beisenVal = '" + value + "'"); if (!degreeCollection.isEmpty()) { educationExpRECInfo.setAcademicDiplomasF7(degreeCollection.get(0)); } } //major 专业 if ("MajorName".equals(name)) { educationExpRECInfo.setMajor(text); } //degreeF7 学历 if ("EducationLevel".equals(name)) { DiplomaCollection diplomaCollection = iDiploma.getDiplomaCollection("where beisenVal = '" + value + "'"); if (!diplomaCollection.isEmpty()) { educationExpRECInfo.setDegreeF7(diplomaCollection.get(0)); } } //schoolType 学院类型 if ("SchoolType".equals(name)) { if (bchoolTypeMap.containsKey(value)) { educationExpRECInfo.setSchoolType(SchoolTypeEnum.getEnum(bchoolTypeMap.get(value))); } } } String errorMsg = "，入学时间、专业、学历、毕业院校为必填数据，请在北森维护数据后再次同步！"; Date dateStart = educationExpRECInfo.getDateStart(); if (dateStart == null) { throw new BOSException("教育经历:入学时间不能为空" + errorMsg); } if (StringUtils.isEmpty(educationExpRECInfo.getMajor())) { throw new BOSException("教育经历:专业不能为空" + errorMsg); } if (StringUtils.isEmpty(educationExpRECInfo.getSchool())) { throw new BOSException("教育经历:毕业院校不能为空" + errorMsg); } if (educationExpRECInfo.getDegreeF7() == null) { throw new BOSException("教育经历:学历不能为空" + errorMsg); } iEducationExpREC.save(educationExpRECInfo); } } catch (Exception e) { IResumeBaseRec iResumeBaseRec = ResumeBaseRecFactory.getLocalInstance(ctx); iResumeBaseRec.delete(new ObjectUuidPK(resumeBaseRecInfo.getId())); logger.error("简历-教育经历保存失败！" + e.getMessage()); throw new RuntimeException(e); } } /** * 简历-获奖经历 * * @param awards */ public void saveResumeRewardPunish(Context ctx, JSONArray awards, ResumeBaseRecInfo resumeBaseRecInfo) { logger.error("awards--" + awards); try { IResumeRewardPunish iResumeRewardPunish = ResumeRewardPunishFactory.getLocalInstance(ctx); ResumeRewardPunishCollection ResumeRewardPunishCollection = iResumeRewardPunish.getResumeRewardPunishCollection("where resumeBase = '" + resumeBaseRecInfo.getId().toString() + "'"); if (!ResumeRewardPunishCollection.isEmpty()) { iResumeRewardPunish.delete("where resumeBase = '" + resumeBaseRecInfo.getId().toString() + "'"); } for (int i = 0; i < awards.size(); i++) { JSONArray array = awards.getJSONArray(i); ResumeRewardPunishInfo ResumeRewardPunishInfo = new ResumeRewardPunishInfo(); //简历基本信息 ResumeRewardPunishInfo.setResumeBase(resumeBaseRecInfo); for (int j = 0; j < array.size(); j++) { JSONObject data = array.getJSONObject(j); String name = data.getString("name"); String value = data.getString("value"); String text = data.getString("text"); //occurDate 获奖时间 if ("AwardTime".equals(name)) { ResumeRewardPunishInfo.setOccurDate(DateTimeUtils.parseDate(text, "yyyy/MM")); } //title 获奖名称 if ("AwardName".equals(name)) { ResumeRewardPunishInfo.setTitle(text); ResumeRewardPunishInfo.setName(text); } //description 描述 if ("AwardDescription".equals(name)) { ResumeRewardPunishInfo.setDescription(text); } } iResumeRewardPunish.save(ResumeRewardPunishInfo); } } catch (Exception e) { logger.error("简历-获奖经历保存失败！" + e.getMessage()); } } /** * 简历-项目经历 * * @param project */ public void saveProjectExp(Context ctx, JSONArray project, ResumeBaseRecInfo resumeBaseRecInfo) { logger.error("project--" + project); try { IProjectExp iProjectExp = ProjectExpFactory.getLocalInstance(ctx); ProjectExpCollection ProjectExpCollection = iProjectExp.getProjectExpCollection("where resumeBase = '" + resumeBaseRecInfo.getId().toString() + "'"); if (!ProjectExpCollection.isEmpty()) { iProjectExp.delete("where resumeBase = '" + resumeBaseRecInfo.getId().toString() + "'"); } for (int i = 0; i < project.size(); i++) { JSONArray array = project.getJSONArray(i); ProjectExpInfo ProjectExpInfo = new ProjectExpInfo(); //简历基本信息 ProjectExpInfo.setResumeBase(resumeBaseRecInfo); for (int j = 0; j < array.size(); j++) { JSONObject data = array.getJSONObject(j); String name = data.getString("name"); String value = data.getString("value"); String text = data.getString("text"); //dateStart 开始时间 if ("StartDate".equals(name)) { ProjectExpInfo.setDateStart(DateTimeUtils.parseDate(text, "yyyy/MM")); } //dateEnd 结束时间 if ("EndDate".equals(name)) { if ("至今".equals(text)) { text = "2199/12"; } ProjectExpInfo.setDateEnd(DateTimeUtils.parseDate(text, "yyyy/MM")); } //customer 项目名称 if ("ProjectName".equals(name)) { ProjectExpInfo.setCustomer(text); } //projectDescription 项目描述 if ("ProjectInfo".equals(name)) { ProjectExpInfo.setProjectDescription(text); } } iProjectExp.save(ProjectExpInfo); } } catch (Exception e) { logger.error("简历-项目经历保存失败！" + e.getMessage()); } } /** * 简历-培训经历 * * @param train */ public void saveTrainingExp(Context ctx, JSONArray train, ResumeBaseRecInfo resumeBaseRecInfo) { logger.error("train--" + train); try { ITrainingExp iTrainingExp = TrainingExpFactory.getLocalInstance(ctx); TrainingExpCollection TrainingExpCollection = iTrainingExp.getTrainingExpCollection("where resumeBaseInfo = '" + resumeBaseRecInfo.getId().toString() + "'"); if (!TrainingExpCollection.isEmpty()) { iTrainingExp.delete("where resumeBaseInfo = '" + resumeBaseRecInfo.getId().toString() + "'"); } for (int i = 0; i < train.size(); i++) { JSONArray array = train.getJSONArray(i); TrainingExpInfo TrainingExpInfo = new TrainingExpInfo(); //简历基本信息 TrainingExpInfo.setResumeBaseInfo(resumeBaseRecInfo); for (int j = 0; j < array.size(); j++) { JSONObject data = array.getJSONObject(j); String name = data.getString("name"); String value = data.getString("value"); String text = data.getString("text"); //dateStart 开始时间 if ("StartDate".equals(name)) { TrainingExpInfo.setDateStart(DateTimeUtils.parseDate(text, "yyyy/MM")); } //dateEnd 结束时间 if ("EndDate".equals(name)) { if ("至今".equals(text)) { text = "2199/12"; } TrainingExpInfo.setDateEnd(DateTimeUtils.parseDate(text, "yyyy/MM")); } //trainingInstitution 培训机构 if ("OrgName".equals(name)) { TrainingExpInfo.setTrainingInstitution(text); } //courseDescription 课程描述 if ("Description".equals(name)) { TrainingExpInfo.setCourseDescription(text); } } iTrainingExp.save(TrainingExpInfo); } } catch (Exception e) { logger.error("简历-培训经历保存失败！" + e.getMessage()); } } /** * 简历-获得证书 * * @param certificate */ public void saveCredential(Context ctx, JSONArray certificate, ResumeBaseRecInfo resumeBaseRecInfo) { logger.error("certificate--" + certificate); try { ICredential iCredential = CredentialFactory.getLocalInstance(ctx); CredentialCollection CredentialCollection = iCredential.getCredentialCollection("where resumeBase = '" + resumeBaseRecInfo.getId().toString() + "'"); if (!CredentialCollection.isEmpty()) { iCredential.delete("where resumeBase = '" + resumeBaseRecInfo.getId().toString() + "'"); } for (int i = 0; i < certificate.size(); i++) { JSONArray array = certificate.getJSONArray(i); CredentialInfo credentialInfo = new CredentialInfo(); //简历基本信息 credentialInfo.setResumeBase(resumeBaseRecInfo); for (int j = 0; j < array.size(); j++) { JSONObject data = array.getJSONObject(j); String name = data.getString("name"); String value = data.getString("value"); String text = data.getString("text"); //date 证书发放日期 if ("ObtainDate".equals(name)) { credentialInfo.setDate(DateTimeUtils.parseDate(text, "yyyy/MM")); } //credentialName 证书名称 if ("CertificateName".equals(name)) { credentialInfo.setCredentialName(text); } //issuer 证书发布机构 if ("Authority".equals(name)) { credentialInfo.setIssuer(text); } //grade 证书成绩 if ("Score".equals(name)) { credentialInfo.setGrade(text); } } iCredential.save(credentialInfo); } } catch (Exception e) { logger.error("简历-获得证书保存失败！" + e.getMessage()); } } /** * 简历-语言能力 * * @param lang */ public void saveLanguageAbility(Context ctx, JSONArray lang, ResumeBaseRecInfo resumeBaseRecInfo) { logger.error("lang--" + lang); try { ILanguageAbility iLanguageAbility = LanguageAbilityFactory.getLocalInstance(ctx); LanguageAbilityCollection LanguageAbilityCollection = iLanguageAbility.getLanguageAbilityCollection("where resumeBase = '" + resumeBaseRecInfo.getId().toString() + "'"); if (!LanguageAbilityCollection.isEmpty()) { iLanguageAbility.delete("where resumeBase = '" + resumeBaseRecInfo.getId().toString() + "'"); } //熟练度 Map proficiencyMap = InitialValueUtils.getProficiencyMap(); for (int i = 0; i < lang.size(); i++) { JSONArray array = lang.getJSONArray(i); LanguageAbilityInfo languageAbilityInfo = new LanguageAbilityInfo(); //简历基本信息 languageAbilityInfo.setResumeBase(resumeBaseRecInfo); for (int j = 0; j < array.size(); j++) { JSONObject data = array.getJSONObject(j); String name = data.getString("name"); String value = data.getString("value"); String text = data.getString("text"); //listeningSpeaking 听说 if ("ListeningSpeakingAbility".equals(name)) { if (proficiencyMap.containsKey(value)) { languageAbilityInfo.setListeningSpeaking(ProficiencyEnum.getEnum(proficiencyMap.get(value))); } } //readingWriting 读写 if ("ReadingWritingAbility".equals(name)) { languageAbilityInfo.setReadingWriting(ProficiencyEnum.getEnum(proficiencyMap.get(value))); } //language 语言 if ("LanguageType".equals(name)) { languageAbilityInfo.setLanguage(text); } //lv 语言等级 if ("LanguageLevel".equals(name)) { languageAbilityInfo.setLv(text); } } iLanguageAbility.save(languageAbilityInfo); } } catch (Exception e) { logger.error("简历-语言能力保存失败！" + e.getMessage()); } } /** * 简历-专业技能 * * @param skill */ public void saveProfessionalSkills(Context ctx, JSONArray skill, ResumeBaseRecInfo resumeBaseRecInfo) { logger.error("skill--" + skill); try { IProfessionalSkills iProfessionalSkills = ProfessionalSkillsFactory.getLocalInstance(ctx); ProfessionalSkillsCollection ProfessionalSkillsCollection = iProfessionalSkills.getProfessionalSkillsCollection("where resumeBase = '" + resumeBaseRecInfo.getId().toString() + "'"); if (!ProfessionalSkillsCollection.isEmpty()) { iProfessionalSkills.delete("where resumeBase = '" + resumeBaseRecInfo.getId().toString() + "'"); } for (int i = 0; i < skill.size(); i++) { JSONArray array = skill.getJSONArray(i); ProfessionalSkillsInfo professionalSkillsInfo = new ProfessionalSkillsInfo(); //简历基本信息 professionalSkillsInfo.setResumeBase(resumeBaseRecInfo); for (int j = 0; j < array.size(); j++) { JSONObject data = array.getJSONObject(j); String name = data.getString("name"); String value = data.getString("value"); String text = data.getString("text"); //skillName 技能名称 if ("SkillName".equals(name)) { professionalSkillsInfo.setSkillName(text); } //skillDescription 技能描述 if ("SkillDescription".equals(name)) { professionalSkillsInfo.setSkillDescription(text); } } iProfessionalSkills.save(professionalSkillsInfo); } } catch (Exception e) { logger.error("简历-专业技能保存失败！" + e.getMessage()); } } /** * 简历-社会关系 * * @param */ public void saveFamilyInfo(Context ctx, JSONArray family, ResumeBaseRecInfo resumeBaseRecInfo) { logger.error("family--" + family); try { IResumeFamily familyIns = ResumeFamilyFactory.getLocalInstance(ctx); ResumeFamilyCollection familyCol = familyIns.getResumeFamilyCollection("where resumeBase = '" + resumeBaseRecInfo.getId().toString() + "'"); //关系 IRelation relationIns = RelationFactory.getLocalInstance(ctx); //简历基本信息 for (int i = 0; i < family.size(); i++) { ResumeFamilyInfo familyInfo = new ResumeFamilyInfo(); if (familyCol.size() > i) { familyInfo = familyCol.get(i); } familyInfo.setResumeBase(resumeBaseRecInfo); JSONArray array = family.getJSONArray(i); for (int j = 0; j < array.size(); j++) { JSONObject data = array.getJSONObject(j); String name = data.getString("name"); String value = data.getString("value"); String text = data.getString("text"); //姓名 if ("Name".equals(name)) { familyInfo.setName(value); } // 与本人关系 if ("relation".equals(name)) { RelationCollection relationCol = relationIns.getRelationCollection("where beisenVal = '" + value + "'"); if (!relationCol.isEmpty()) { familyInfo.setRelation(relationCol.get(0)); } } if ("age".equals(name)) { familyInfo.setAge(text); } //职务 if ("JobTitle".equals(name)) { familyInfo.setSpecDuty(text); } //公司名 if ("CompanyName".equals(name)) { familyInfo.setWorkUnit(text); } //telephone if ("telephone".equals(name)) { familyInfo.setOfficePhone(text); } familyIns.save(familyInfo); } } } catch (Exception e) { logger.error("社会关系保存失败！" + e.getMessage()); throw new RuntimeException(e); } } @Override protected void _syncRecuritmentToBeisen(Context ctx, String billId) throws BOSException, EASBizException { super._syncRecuritmentToBeisen(ctx, billId); IRecuritmentDemand dIns = RecuritmentDemandFactory.getLocalInstance(ctx); RecuritmentDemandInfo recuritmentDemandInfo = dIns.getRecuritmentDemandInfo(new ObjectUuidPK(billId)); RecruitmentDemandService recruitmentDemandService = new RecruitmentDemandService(false); //更新或新增 try { Object requirementId = recuritmentDemandInfo.get("requirementId"); if (ObjectUtils.allNotNull(requirementId)) { recruitmentDemandService.updateRequirement(ctx, String.valueOf(requirementId), recuritmentDemandInfo); } else { recruitmentDemandService.createRecruitmentDemand(ctx, recuritmentDemandInfo); } } catch (Exception e) { SelectorItemCollection selectorCol = new SelectorItemCollection(); selectorCol.add(new SelectorItemInfo("syncBeisenResult")); String message = e.getMessage(); recuritmentDemandInfo.put("syncBeisenResult", "失败: " + message); dIns.updatePartial(recuritmentDemandInfo, selectorCol); throw new RuntimeException(e); } } /** * 招聘需求更新 * coyle */ @Override protected void _updateRecuritment(Context ctx, String startDate, String endDate, int offset) throws BOSException, EASBizException { super._updateRecuritment(ctx, startDate, endDate, offset); // 0. 参数校验与日期解析 DateTimeFormatter dateFormatter = DateTimeFormatter.ofPattern("yyyy-MM-dd"); LocalDate start = LocalDate.now(); LocalDate end = LocalDate.now(); //如果时间参数都为空,则使用offset参数 if (StringUtils.isEmpty(startDate) && StringUtils.isEmpty(endDate)) { if (offset > 0) { //eDate增加offset天 end = end.plusDays(offset); } else if (offset < 0) { start = start.plusDays(offset); } } if (!StringUtils.isEmpty(startDate)) { //开始日期字定义,结束日期都是今天 start = LocalDate.parse(startDate, dateFormatter); } if (!StringUtils.isEmpty(endDate)) { //开始日期,结束日期都是今天 end = LocalDate.parse(endDate, dateFormatter); } if (start.isAfter(end)) { throw new BOSException("开始日期不能晚于结束日期"); } // LocalDate 转 String (使用之前的 dateFormatter) String startStr = toStartTime(start.format(dateFormatter)); String endStr = toEndTime(end.format(dateFormatter)); IRecuritmentDemand localInstance = RecuritmentDemandFactory.getLocalInstance(ctx); EntityViewInfo ev = new EntityViewInfo(); FilterInfo filter = new FilterInfo(); filter.getFilterItems().add(new FilterItemInfo("requirementId", null, CompareType.NOTEMPTY)); filter.getFilterItems().add(new FilterItemInfo("lastUpdateTime", startStr, CompareType.GREATER_EQUALS)); filter.getFilterItems().add(new FilterItemInfo("lastUpdateTime", endStr, CompareType.LESS_EQUALS)); ev.setFilter(filter); RecuritmentDemandCollection recuritmentDemandCollection = localInstance.getRecuritmentDemandCollection(ev); for (int i = 0; i < recuritmentDemandCollection.size(); i++) { RecuritmentDemandInfo recuritmentDemandInfo = recuritmentDemandCollection.get(i); _syncRecuritmentToBeisen(ctx, recuritmentDemandInfo.getId().toString()); } } /** * 将日期字符串转换为一天的开始时间（UTC格式） * * @param dateStr "yyyy-MM-dd"格式的日期字符串 * @return Moka API要求的时间格式 */ public static String toStartTime(String dateStr) { LocalDate date = LocalDate.parse(dateStr); LocalDateTime startOfDay = date.atStartOfDay(); return TIME_FORMATTER.format(startOfDay); } /** * 将日期字符串转换为一天的结束时间（UTC格式） * * @param dateStr "yyyy-MM-dd"格式的日期字符串 * @return Moka API要求的时间格式 */ public static String toEndTime(String dateStr) { LocalDate date = LocalDate.parse(dateStr); LocalDateTime endOfDay = date.atTime(23, 59, 59); return TIME_FORMATTER.format(endOfDay); } }