|
|
@@ -0,0 +1,444 @@
|
|
|
+package com.kingdee.eas.custom.recuritment.task;
|
|
|
+
|
|
|
+import com.alibaba.fastjson.JSONArray;
|
|
|
+import com.alibaba.fastjson.JSONObject;
|
|
|
+import com.google.common.collect.Maps;
|
|
|
+import com.kingdee.bos.metadata.entity.*;
|
|
|
+import com.kingdee.bos.metadata.query.util.CompareType;
|
|
|
+import com.kingdee.eas.basedata.person.PersonInfo;
|
|
|
+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.beisen.entity.PhaseStatusInfo;
|
|
|
+import com.kingdee.eas.hr.ats.AtsUtil;
|
|
|
+import com.kingdee.eas.hr.base.EmployeeTypeInfo;
|
|
|
+import com.kingdee.eas.hr.base.HRBillStateEnum;
|
|
|
+import com.kingdee.eas.util.app.DbUtil;
|
|
|
+import com.kingdee.shr.recuritment.*;
|
|
|
+import com.kingdee.shr.recuritment.app.OfferConfirmStateEnum;
|
|
|
+import com.kingdee.util.DateTimeUtils;
|
|
|
+import org.apache.commons.lang3.StringUtils;
|
|
|
+import org.apache.log4j.Logger;
|
|
|
+
|
|
|
+import com.kingdee.bos.*;
|
|
|
+import com.kingdee.eas.common.EASBizException;
|
|
|
+
|
|
|
+import java.io.IOException;
|
|
|
+import java.lang.String;
|
|
|
+import java.util.*;
|
|
|
+
|
|
|
+public class BeisenTransferPhaseFacadeControllerBean extends AbstractBeisenTransferPhaseFacadeControllerBean {
|
|
|
+ private static Logger logger = Logger.getLogger(BeisenTransferPhaseFacadeControllerBean.class);
|
|
|
+ private Map<String, PhaseStatusInfo> phaseStatus = Maps.newHashMap();
|
|
|
+ //待录用报批单据状态
|
|
|
+ private static Set hireApprovalBillStatusSet = new HashSet<>();
|
|
|
+ //待录用报批招聘状态
|
|
|
+ private static Set hireApprovalResumeStateSet = new HashSet<>();
|
|
|
+ //录用终止报批招聘状态
|
|
|
+ private static Set hireTerminationResumeStateSet = new HashSet<>();
|
|
|
+ //待录用报批招聘状态
|
|
|
+ private static Set hireOfferStateSet = new HashSet<>();
|
|
|
+ private static Map<String, String> beisenTransferPhaseErrorMap = new HashMap<>();
|
|
|
+
|
|
|
+
|
|
|
+ private final String RECAPPROVAL1 = "recApproval1";
|
|
|
+ private final String RECAPPROVAL2 = "recApproval2";
|
|
|
+ private final String OFFER1 = "offer1";
|
|
|
+ private final String OFFER2 = "offer2";
|
|
|
+ private final String OFFER3 = "offer3";
|
|
|
+ private final String OFFER4 = "offer4";
|
|
|
+ private final String OFFER5 = "offer5";
|
|
|
+ private final String ENROLL1 = "enroll1";
|
|
|
+ private final String ENROLL2 = "enroll2";
|
|
|
+ private final String ENROLL3 = "enroll3";
|
|
|
+
|
|
|
+ static {
|
|
|
+ hireApprovalBillStatusSet.add(HRBillStateEnum.SAVED);//未提交
|
|
|
+ hireApprovalBillStatusSet.add(HRBillStateEnum.SUBMITED);//已提交
|
|
|
+ hireApprovalBillStatusSet.add(HRBillStateEnum.AUDITING);//审批中
|
|
|
+ hireApprovalResumeStateSet.add("0009");//待报批
|
|
|
+ hireApprovalResumeStateSet.add("0010");//报批中
|
|
|
+ hireTerminationResumeStateSet.add("0012");//终止报批
|
|
|
+ hireTerminationResumeStateSet.add("0011");//报批不通过
|
|
|
+ hireOfferStateSet.add("0013");//待入职
|
|
|
+ hireOfferStateSet.add("0015");//已预入职
|
|
|
+
|
|
|
+ beisenTransferPhaseErrorMap.put("applyDeleteApplyIds", "因在当前职位下被删除而转移失败");
|
|
|
+ beisenTransferPhaseErrorMap.put("applicantDeleteApplyIds", "因应聘者被删除而转移失败");
|
|
|
+ beisenTransferPhaseErrorMap.put("applicantBlackApplyIds", "因应聘者被拉黑而转移失败");
|
|
|
+ beisenTransferPhaseErrorMap.put("applicantLockedApplyIds", "因应聘者被锁定而转移失败");
|
|
|
+ beisenTransferPhaseErrorMap.put("applyStatusChangedApplyIds", "因应聘者阶段状态已发生变化而转移失败");
|
|
|
+ beisenTransferPhaseErrorMap.put("applyOtherReasonRejectedApplyIds", "因定制功能校验失败而转移失败");
|
|
|
+ beisenTransferPhaseErrorMap.put("applyByHunterOrRPOUnAcceptedIds", "因应聘者存在猎头/RPO简历且未被接受而转移失败");
|
|
|
+ beisenTransferPhaseErrorMap.put("applyTransferRuleFailedApplyIds", "因应聘者存在不符合准入规则而转移失败");
|
|
|
+
|
|
|
+ }
|
|
|
+
|
|
|
+ public BeisenTransferPhaseFacadeControllerBean() throws IOException, BOSException {
|
|
|
+ BeisenParamByProperties properties = null;
|
|
|
+ try {
|
|
|
+ properties = new BeisenParamByProperties();
|
|
|
+ } catch (IOException e) {
|
|
|
+ logger.error("北森状态转移Facade获取配置文件报错: " + e.getMessage(), e);
|
|
|
+ throw e;
|
|
|
+ }
|
|
|
+ Map<String, String> config = properties.getConfig();
|
|
|
+ String phase1 = config.get("phase1");
|
|
|
+ String status1A = config.get("status1A");
|
|
|
+ String status1B = config.get("status1B");
|
|
|
+ String phase2 = config.get("phase2");
|
|
|
+ String status2A = config.get("status2A");
|
|
|
+ String status2B = config.get("status2B");
|
|
|
+ String status2C = config.get("status2C");
|
|
|
+ String status2D = config.get("status2D");
|
|
|
+ String status2E = config.get("status2E");
|
|
|
+ String phase3 = config.get("phase3");
|
|
|
+ String status3A = config.get("status3A");
|
|
|
+ String status3B = config.get("status3B");
|
|
|
+ String status3C = config.get("status3C");
|
|
|
+ if (StringUtils.isAnyBlank(
|
|
|
+ phase1, phase2, phase3, status1A,
|
|
|
+ status1B, status2A, status2B, status2C,
|
|
|
+ status2D, status2E, phase3, status3A,
|
|
|
+ status3B, status3C)) {
|
|
|
+ throw new BOSException("北森阶段状态为空!");
|
|
|
+ }
|
|
|
+ phaseStatus.put(RECAPPROVAL1, new PhaseStatusInfo(phase1, status1A));
|
|
|
+ phaseStatus.put(RECAPPROVAL2, new PhaseStatusInfo(phase1, status1B));
|
|
|
+ phaseStatus.put(OFFER1, new PhaseStatusInfo(phase2, status2A));
|
|
|
+ phaseStatus.put(OFFER2, new PhaseStatusInfo(phase2, status2B));
|
|
|
+ phaseStatus.put(OFFER3, new PhaseStatusInfo(phase2, status2C));
|
|
|
+ phaseStatus.put(OFFER4, new PhaseStatusInfo(phase2, status2D));
|
|
|
+ phaseStatus.put(OFFER5, new PhaseStatusInfo(phase2, status2E));
|
|
|
+ phaseStatus.put(ENROLL1, new PhaseStatusInfo(phase3, status3A));
|
|
|
+ phaseStatus.put(ENROLL2, new PhaseStatusInfo(phase3, status3B));
|
|
|
+ phaseStatus.put(ENROLL3, new PhaseStatusInfo(phase3, status3C));
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 同步录用报批状态到北森
|
|
|
+ *
|
|
|
+ * @param ctx
|
|
|
+ * @param billId
|
|
|
+ * @param preponeHours
|
|
|
+ * @throws BOSException
|
|
|
+ * @throws EASBizException
|
|
|
+ */
|
|
|
+ @Override
|
|
|
+ protected void _syncRecApprovalToBeisen(Context ctx, String billId, int preponeHours)
|
|
|
+ throws BOSException, EASBizException {
|
|
|
+ try {
|
|
|
+ super._syncRecApprovalToBeisen(ctx, billId, preponeHours);
|
|
|
+ IRecApproval iRecApproval = RecApprovalFactory.getLocalInstance(ctx);
|
|
|
+ RecApprovalCollection recApprovalCollection = null;
|
|
|
+ SelectorItemCollection sic = new SelectorItemCollection();
|
|
|
+ sic.add("*");
|
|
|
+ sic.add("resumeBaseRec.*");
|
|
|
+ sic.add("resumeBaseRec.resumeState.*");
|
|
|
+ if (StringUtils.isNotBlank(billId)) {
|
|
|
+ FilterInfo filterInfo = new FilterInfo();
|
|
|
+ FilterItemCollection filterItems = filterInfo.getFilterItems();
|
|
|
+ filterItems.add(new FilterItemInfo("id", billId));
|
|
|
+ EntityViewInfo viewInfo = EntityViewInfo.getInstance(filterInfo, sic, null);
|
|
|
+ recApprovalCollection = iRecApproval.getRecApprovalCollection(viewInfo);
|
|
|
+ if (recApprovalCollection.isEmpty()) {
|
|
|
+ logger.error("未匹配到录用报批单据，单据id： " + billId);
|
|
|
+ throw new BOSException("未匹配到录用报批单据");
|
|
|
+ }
|
|
|
+ } else {
|
|
|
+ if (preponeHours <= 0) {
|
|
|
+ preponeHours = 2;
|
|
|
+ }
|
|
|
+ Date now = new Date();
|
|
|
+ Date before = DateTimeUtils.addHour(now, -preponeHours);
|
|
|
+ //查询最近12小时内更新的录用报批
|
|
|
+ FilterInfo filterInfo = new FilterInfo();
|
|
|
+ FilterItemCollection filterItems = filterInfo.getFilterItems();
|
|
|
+ //最后更新时间大于等于
|
|
|
+ filterItems.add(new FilterItemInfo("lastUpdateTime", before, CompareType.GREATER_EQUALS));
|
|
|
+ //最后更新时间小于等于当前
|
|
|
+ filterItems.add(new FilterItemInfo("lastUpdateTime", now, CompareType.LESS_EQUALS));
|
|
|
+ EntityViewInfo viewInfo = EntityViewInfo.getInstance(filterInfo, sic, null);
|
|
|
+ recApprovalCollection = iRecApproval.getRecApprovalCollection(viewInfo);
|
|
|
+ }
|
|
|
+ if (recApprovalCollection == null || recApprovalCollection.isEmpty()) {
|
|
|
+ logger.error("录用报批为空!");
|
|
|
+ return;
|
|
|
+ }
|
|
|
+ //维护录用报批与北森申请id映射关系
|
|
|
+ Map applyIdRecApprovalMap = new HashMap();
|
|
|
+ Map<String, JSONArray> recApprovalMap = new HashMap();
|
|
|
+ IOffer iOffer = OfferFactory.getLocalInstance(ctx);
|
|
|
+ for (int i = 0; i < recApprovalCollection.size(); i++) {
|
|
|
+ RecApprovalInfo recApprovalInfo = recApprovalCollection.get(i);
|
|
|
+ String fid = recApprovalInfo.getId().toString();
|
|
|
+ //简历基本信息
|
|
|
+ ResumeBaseRecInfo resumeBaseRec = recApprovalInfo.getResumeBaseRec();
|
|
|
+ String applyId = resumeBaseRec.getString("applyId");
|
|
|
+ if (StringUtils.isEmpty(applyId)) {
|
|
|
+ String errorMsg = "北森申请id为空!";
|
|
|
+ logger.error(errorMsg);
|
|
|
+ Set set = new HashSet();
|
|
|
+ set.add(fid);
|
|
|
+ updateTable(ctx, "T_REC_RecApproval", errorMsg, "2", set);
|
|
|
+ continue;
|
|
|
+ }
|
|
|
+ applyIdRecApprovalMap.put(applyId, fid);
|
|
|
+ ResumeStateInfo resumeState = resumeBaseRec.getResumeState();
|
|
|
+ String resumeStateNumber = resumeState.getNumber();//招聘状态
|
|
|
+ String beisenStatus = null;
|
|
|
+ //单据状态
|
|
|
+ HRBillStateEnum billState = recApprovalInfo.getBillState();
|
|
|
+ if (hireApprovalBillStatusSet.contains(billState) && hireApprovalResumeStateSet.contains(resumeStateNumber)) {
|
|
|
+ //单据状态为未提交/未审批/审批中,招聘需求状态为待报批/报批中 北森录用报批状态为待录用报批
|
|
|
+ beisenStatus = RECAPPROVAL1;
|
|
|
+ } else if (HRBillStateEnum.AUDITEND.equals(billState) && hireTerminationResumeStateSet.contains(resumeStateNumber)) {
|
|
|
+ //单据状态为审批不通过,招聘需求状态为终止报批/报批不通过 北森录用报批状态为录用终止
|
|
|
+ beisenStatus = RECAPPROVAL2;
|
|
|
+ } else if (HRBillStateEnum.AUDITED.equals(billState) && "0013".equals(resumeStateNumber)) {
|
|
|
+ //单据状态为审批通过,招聘需求状态为待入职,Offer发送状态为空,北森状态为待发Offer
|
|
|
+ try {
|
|
|
+ OfferCollection offerCollection = iOffer.getOfferCollection("where resumeBaseRec ='" + resumeBaseRec.getId() + "'");
|
|
|
+ //offer发送状态
|
|
|
+ String sendState = null;
|
|
|
+ if (!offerCollection.isEmpty()) {
|
|
|
+ OfferInfo offerInfo = offerCollection.get(0);
|
|
|
+ sendState = offerInfo.getSendState();
|
|
|
+ }
|
|
|
+ if (!StringUtils.isEmpty(sendState)) {
|
|
|
+ //Offer发送状态不为空,忽略
|
|
|
+ return;
|
|
|
+ }
|
|
|
+ } catch (BOSException e) {
|
|
|
+ throw new BOSException("获取offer状态报错: " + e.getMessage());
|
|
|
+ }
|
|
|
+ beisenStatus = OFFER1;
|
|
|
+ }
|
|
|
+ if (StringUtils.isNotBlank(beisenStatus)) {
|
|
|
+ if (recApprovalMap.containsKey(beisenStatus)) {
|
|
|
+ recApprovalMap.get(beisenStatus).add(applyId);
|
|
|
+ } else {
|
|
|
+ JSONArray applyIds = new JSONArray();
|
|
|
+ applyIds.add(applyId);
|
|
|
+ recApprovalMap.put(beisenStatus, applyIds);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ //处理北森状态转移请求
|
|
|
+ handleBeisenTransferPhaseQuery(ctx, recApprovalMap, applyIdRecApprovalMap, "T_REC_RecApproval");
|
|
|
+ } catch (Exception e) {
|
|
|
+ logger.error("录用报批同步北森状态转移报错: " + e.getMessage(), e);
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 同步offer状态到北森
|
|
|
+ *
|
|
|
+ * @param ctx
|
|
|
+ * @param billId
|
|
|
+ * @throws BOSException
|
|
|
+ * @throws EASBizException
|
|
|
+ */
|
|
|
+ @Override
|
|
|
+ protected void _syncOfferToBeisen(Context ctx, String billId, int preponeHours) throws BOSException, EASBizException {
|
|
|
+ try {
|
|
|
+ super._syncOfferToBeisen(ctx, billId, preponeHours);
|
|
|
+ IOffer iOffer = OfferFactory.getLocalInstance(ctx);
|
|
|
+ OfferCollection offerCollection = null;
|
|
|
+ SelectorItemCollection sic = new SelectorItemCollection();
|
|
|
+ sic.add("*");
|
|
|
+ sic.add("resumeBaseRec.*");
|
|
|
+ sic.add("resumeBaseRec.resumeState.*");
|
|
|
+ sic.add("person.employeeType.isInCount");
|
|
|
+ if (StringUtils.isNotBlank(billId)) {
|
|
|
+ FilterInfo filterInfo = new FilterInfo();
|
|
|
+ FilterItemCollection filterItems = filterInfo.getFilterItems();
|
|
|
+ filterItems.add(new FilterItemInfo("id", billId));
|
|
|
+ EntityViewInfo viewInfo = EntityViewInfo.getInstance(filterInfo, sic, null);
|
|
|
+ offerCollection = iOffer.getOfferCollection(viewInfo);
|
|
|
+ if (offerCollection.isEmpty()) {
|
|
|
+ logger.error("未匹配到offer单据，单据id： " + billId);
|
|
|
+ throw new BOSException("未匹配到offer单据");
|
|
|
+ }
|
|
|
+ } else {
|
|
|
+ if (preponeHours <= 0) {
|
|
|
+ preponeHours = 2;
|
|
|
+ }
|
|
|
+ Date now = new Date();
|
|
|
+ Date before = DateTimeUtils.addHour(now, -preponeHours);
|
|
|
+ //查询最近12小时内更新的录用报批
|
|
|
+ FilterInfo filterInfo = new FilterInfo();
|
|
|
+ FilterItemCollection filterItems = filterInfo.getFilterItems();
|
|
|
+ //最后更新时间大于等于
|
|
|
+ filterItems.add(new FilterItemInfo("lastUpdateTime", before, CompareType.GREATER_EQUALS));
|
|
|
+ //最后更新时间小于等于当前
|
|
|
+ filterItems.add(new FilterItemInfo("lastUpdateTime", now, CompareType.LESS_EQUALS));
|
|
|
+ EntityViewInfo viewInfo = EntityViewInfo.getInstance(filterInfo, sic, null);
|
|
|
+ offerCollection = iOffer.getOfferCollection(viewInfo);
|
|
|
+ }
|
|
|
+ if (offerCollection == null || offerCollection.isEmpty()) {
|
|
|
+ logger.error("offer为空!");
|
|
|
+ return;
|
|
|
+ }
|
|
|
+ //维护OfferId与北森申请id映射关系
|
|
|
+ Map applyIdOfferMap = new HashMap();
|
|
|
+ Map<String, JSONArray> offerMap = new HashMap();
|
|
|
+ Map<String, JSONArray> recApprovalMap = new HashMap();
|
|
|
+ for (int i = 0; i < offerCollection.size(); i++) {
|
|
|
+ OfferInfo offerInfo = offerCollection.get(i);
|
|
|
+ String fid = offerInfo.getId().toString();
|
|
|
+ //简历基本信息
|
|
|
+ ResumeBaseRecInfo resumeBaseRec = offerInfo.getResumeBaseRec();
|
|
|
+ String applyId = resumeBaseRec.getString("applyId");
|
|
|
+ if (StringUtils.isEmpty(applyId)) {
|
|
|
+ String errorMsg = "北森申请id为空!";
|
|
|
+ logger.error(errorMsg);
|
|
|
+ Set set = new HashSet();
|
|
|
+ set.add(fid);
|
|
|
+ updateTable(ctx, "T_REC_Offer", errorMsg, "2", set);
|
|
|
+ continue;
|
|
|
+ }
|
|
|
+ applyIdOfferMap.put(applyId, fid);
|
|
|
+ ResumeStateInfo resumeState = resumeBaseRec.getResumeState();
|
|
|
+ String resumeStateNumber = resumeState.getNumber();//招聘状态
|
|
|
+ //发送状态
|
|
|
+ String sendState = offerInfo.getSendState();
|
|
|
+ //确认状态
|
|
|
+ OfferConfirmStateEnum confirmState = offerInfo.getConfirmState();
|
|
|
+ String beisenStatus = null;
|
|
|
+ if ("0013".equals(resumeStateNumber) && StringUtils.isBlank(sendState) || "待发送".equals(sendState)) {
|
|
|
+ //发送状态为空或待确认,招聘需求状态为待入职 北森录用报批状态为待发Offer
|
|
|
+ beisenStatus = OFFER1;
|
|
|
+ } else if ("0013".equals(resumeStateNumber) && "已发送".equals(sendState) && OfferConfirmStateEnum.TOBECONFIRM.equals(confirmState)) {
|
|
|
+ //确认结果待确认,发送状态为已发送,招聘需求状态为待入职 北森录用报批状态为已发Offer
|
|
|
+ beisenStatus = OFFER2;
|
|
|
+ } else if ("0013".equals(resumeStateNumber) && "已发送".equals(sendState) && OfferConfirmStateEnum.ACCEPTED.equals(confirmState)) {
|
|
|
+ //确认结果已接受,发送状态为已发送,招聘需求状态为待入职 北森录用报批状态为接受Offer
|
|
|
+ beisenStatus = OFFER4;
|
|
|
+ } else if ("0013".equals(resumeStateNumber) && "已发送".equals(sendState) && OfferConfirmStateEnum.REJECTED.equals(confirmState)) {
|
|
|
+ //确认结果已拒绝,发送状态为已发送,招聘需求状态为待入职 北森录用报批状态为拒绝Offer
|
|
|
+ beisenStatus = OFFER3;
|
|
|
+ } else if ("0015".equals(resumeStateNumber)) {
|
|
|
+ //招聘需求状态为已预入职 北森录用报批状态为等待入职
|
|
|
+ beisenStatus = OFFER5;
|
|
|
+ } else if ("0017".equals(resumeStateNumber)) {
|
|
|
+ //招聘需求状态为已入职 北森录用报批状态为已入职
|
|
|
+ PersonInfo person = offerInfo.getPerson();
|
|
|
+ if (person != null) {
|
|
|
+ EmployeeTypeInfo employeeType = person.getEmployeeType();
|
|
|
+ if (employeeType != null && !employeeType.isIsInCount()) {
|
|
|
+ //如果有审批通过的离职单,则忽略
|
|
|
+ return;
|
|
|
+ }
|
|
|
+ }
|
|
|
+ beisenStatus = ENROLL1;
|
|
|
+ } else if ("0016".equals(resumeStateNumber) || "0014".equals(resumeStateNumber)) {
|
|
|
+ //招聘需求状态为放弃入职或终止入职 北森录用报批状态为取消入职
|
|
|
+ beisenStatus = ENROLL2;
|
|
|
+ }
|
|
|
+ if (StringUtils.isNotBlank(beisenStatus)) {
|
|
|
+ if (recApprovalMap.containsKey(beisenStatus)) {
|
|
|
+ offerMap.get(beisenStatus).add(applyId);
|
|
|
+ } else {
|
|
|
+ JSONArray applyIds = new JSONArray();
|
|
|
+ applyIds.add(applyId);
|
|
|
+ offerMap.put(beisenStatus, applyIds);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ handleBeisenTransferPhaseQuery(ctx, applyIdOfferMap, offerMap, "T_REC_Offer");
|
|
|
+
|
|
|
+ } catch (Exception e) {
|
|
|
+ logger.error("offer同步北森状态转移报错: " + e.getMessage(), e);
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 处理北森状态转移请求
|
|
|
+ *
|
|
|
+ * @param ctx
|
|
|
+ * @param recApprovalMap
|
|
|
+ * @param applyIdStatusMap 北森状态与申请id
|
|
|
+ * @param tableName 数据库表名
|
|
|
+ * @throws BOSException
|
|
|
+ */
|
|
|
+ private void handleBeisenTransferPhaseQuery(
|
|
|
+ Context ctx,
|
|
|
+ Map<String, JSONArray> recApprovalMap,
|
|
|
+ Map applyIdStatusMap,
|
|
|
+ String tableName
|
|
|
+ ) throws BOSException, IOException {
|
|
|
+ BeisenApiClient beisenApiClient = BeisenApiClient.getInstance();
|
|
|
+ for (String statusName : recApprovalMap.keySet()) {
|
|
|
+ try {
|
|
|
+ //申请id
|
|
|
+ JSONArray applyIds = recApprovalMap.get(statusName);
|
|
|
+ PhaseStatusInfo phaseStatusInfo = phaseStatus.get(statusName);
|
|
|
+ JSONObject params = new JSONObject();
|
|
|
+ params.put("applyIds", applyIds);
|
|
|
+ params.put("phaseId", phaseStatusInfo.getPhaseId());
|
|
|
+ params.put("statusId", phaseStatusInfo.getStatusId());
|
|
|
+ JSONObject response = beisenApiClient.callApi(BeisenParam.POST_TRANSFERPHASE_URL, params);
|
|
|
+ int code = response.getIntValue("code");
|
|
|
+ String message = response.getString("message");
|
|
|
+ if (200 == code) {
|
|
|
+ JSONObject data = response.getJSONObject("data");
|
|
|
+ //转移失败数
|
|
|
+ Integer noTransferCount = data.getInteger("noTransferCount");
|
|
|
+ if (noTransferCount > 0) {
|
|
|
+ for (String key : beisenTransferPhaseErrorMap.keySet()) {
|
|
|
+ JSONArray failApplyIds = data.getJSONArray(key);
|
|
|
+ if (!failApplyIds.isEmpty()) {
|
|
|
+ String errorMsg = beisenTransferPhaseErrorMap.get(key);
|
|
|
+ Set fids = new HashSet<>();
|
|
|
+ failApplyIds.forEach((applyid) -> {
|
|
|
+ fids.add(applyIdStatusMap.get(applyid));
|
|
|
+ });
|
|
|
+ updateTable(ctx, tableName, errorMsg, "2", fids);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ } else {
|
|
|
+ Set fids = new HashSet<>();
|
|
|
+ applyIdStatusMap.values().forEach((id) -> {
|
|
|
+ fids.add(id);
|
|
|
+ });
|
|
|
+ updateTable(ctx, tableName, "成功", "1", fids);
|
|
|
+ }
|
|
|
+ } else {
|
|
|
+ Set fids = new HashSet<>();
|
|
|
+ applyIdStatusMap.values().forEach((id) -> {
|
|
|
+ fids.add(id);
|
|
|
+ });
|
|
|
+ updateTable(ctx, tableName, message, "2", fids);
|
|
|
+ }
|
|
|
+ } catch (Exception e) {
|
|
|
+ logger.error("同步北森状态转移报错: " + e.getMessage(), e);
|
|
|
+ throw e;
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 更新offer/录用报批表执行结果和状态
|
|
|
+ *
|
|
|
+ * @param ctx
|
|
|
+ * @param tableName
|
|
|
+ * @param message
|
|
|
+ * @param status
|
|
|
+ * @param fids
|
|
|
+ * @throws BOSException
|
|
|
+ */
|
|
|
+ private void updateTable(
|
|
|
+ Context ctx,
|
|
|
+ String tableName,
|
|
|
+ String message,
|
|
|
+ String status,
|
|
|
+ Set fids
|
|
|
+ ) throws BOSException {
|
|
|
+ StringBuilder updateSql = new StringBuilder();
|
|
|
+ updateSql.append("update ").append(tableName).append(" set CFsyncBeisenResult ='");
|
|
|
+ updateSql.append(message).append("' ,CFsyncStatus = '").append(status).append("'");
|
|
|
+ updateSql.append(" where fid in (").append(AtsUtil.convertSetToString(fids)).append(")");
|
|
|
+ DbUtil.execute(ctx, updateSql.toString());
|
|
|
+ }
|
|
|
+}
|
Heyuan