|
|
@@ -1,16 +1,29 @@
|
|
|
package com.kingdee.shr.recuritment.web.handler;
|
|
|
|
|
|
+import com.kingdee.bos.BOSException;
|
|
|
import com.kingdee.bos.Context;
|
|
|
+import com.kingdee.bos.ctrl.reportone.r1.form.engine.x.util.StringUtil;
|
|
|
+import com.kingdee.bos.dao.ormapping.ObjectUuidPK;
|
|
|
+import com.kingdee.bos.metadata.entity.*;
|
|
|
+import com.kingdee.bos.metadata.query.util.CompareType;
|
|
|
+import com.kingdee.eas.common.EASBizException;
|
|
|
import com.kingdee.eas.custom.recuritment.task.BeisenTransferPhaseFacadeFactory;
|
|
|
import com.kingdee.eas.custom.recuritment.task.IBeisenTransferPhaseFacade;
|
|
|
+import com.kingdee.shr.base.syssetting.api.bean.BatchMessageTipsBody;
|
|
|
+import com.kingdee.shr.base.syssetting.api.bean.BatchMessageTipsHeader;
|
|
|
import com.kingdee.shr.base.syssetting.context.SHRContext;
|
|
|
import com.kingdee.shr.base.syssetting.exception.SHRWebException;
|
|
|
import com.kingdee.shr.base.syssetting.exception.ShrWebBizException;
|
|
|
+import com.kingdee.shr.recuritment.*;
|
|
|
+import com.kingdee.shr.recuritment.service.offer.SyncResumeToPreServiceEx;
|
|
|
import com.kingdee.util.StringUtils;
|
|
|
+import org.apache.log4j.Logger;
|
|
|
import org.springframework.ui.ModelMap;
|
|
|
|
|
|
import javax.servlet.http.HttpServletRequest;
|
|
|
import javax.servlet.http.HttpServletResponse;
|
|
|
+import java.util.HashMap;
|
|
|
+import java.util.Map;
|
|
|
|
|
|
/**
|
|
|
* @Description offer列表
|
|
|
@@ -18,6 +31,7 @@ import javax.servlet.http.HttpServletResponse;
|
|
|
* @Created by Heyuan
|
|
|
*/
|
|
|
public class OfferListHandlerEx extends OfferListHandler {
|
|
|
+ private static final Logger logger = Logger.getLogger(OfferListHandlerEx.class);
|
|
|
private Context ctx = SHRContext.getInstance().getContext();
|
|
|
|
|
|
/**
|
|
|
@@ -82,12 +96,19 @@ public class OfferListHandlerEx extends OfferListHandler {
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
- * 转标准预备入职
|
|
|
+ * 将指定的录用单据转为标准预备入职状态。
|
|
|
+ * <p>
|
|
|
+ * 该方法会根据传入的 billId 参数，批量处理多个录用单据。对每个单据执行以下操作：
|
|
|
+ * 1. 验证单据是否满足转预备入职条件；
|
|
|
+ * 2. 若验证通过且未放弃入职，则调用服务将简历同步至标准预备入职；
|
|
|
+ * 3. 记录每条数据的处理结果（成功或失败）；
|
|
|
+ * 4. 最后尝试将录用状态同步到北森系统。
|
|
|
+ * </p>
|
|
|
*
|
|
|
- * @param request
|
|
|
- * @param response
|
|
|
- * @param modelMap
|
|
|
- * @throws SHRWebException
|
|
|
+ * @param request HTTP 请求对象，用于获取请求参数（如 billId）
|
|
|
+ * @param response HTTP 响应对象，用于输出响应内容
|
|
|
+ * @param modelMap Spring MVC 的模型映射对象，可用于传递数据到视图层（本方法未使用）
|
|
|
+ * @throws SHRWebException 当业务处理过程中发生异常时抛出
|
|
|
*/
|
|
|
@Override
|
|
|
public void toPrePersonAction(
|
|
|
@@ -95,11 +116,90 @@ public class OfferListHandlerEx extends OfferListHandler {
|
|
|
HttpServletResponse response,
|
|
|
ModelMap modelMap
|
|
|
) throws SHRWebException {
|
|
|
- super.toPrePersonAction(request, response, modelMap);
|
|
|
+ // 获取请求中的 billId 参数
|
|
|
String billIds = request.getParameter("billId");
|
|
|
+ Context ctx = getContext();
|
|
|
+ IOffer iOffer;
|
|
|
+ try {
|
|
|
+ // 获取 Offer 服务实例
|
|
|
+ iOffer = OfferFactory.getLocalInstance(ctx);
|
|
|
+ } catch (BOSException e) {
|
|
|
+ logger.error(e.getMessage(), e);
|
|
|
+ throw new SHRWebException("系统错误，请联系管理员");
|
|
|
+ }
|
|
|
+ int success = 0;
|
|
|
+ int failure = 0;
|
|
|
+ BatchMessageTipsHeader batchMessageTipsHeader = new BatchMessageTipsHeader();
|
|
|
+
|
|
|
+ // 如果 billIds 不为空，则按逗号分割并逐个处理
|
|
|
+ if (org.apache.commons.lang3.StringUtils.isNotEmpty(billIds)) {
|
|
|
+ String[] ids = billIds.split(",");
|
|
|
+ for (int i = 0; i < ids.length; ++i) {
|
|
|
+ BatchMessageTipsBody body = new BatchMessageTipsBody();
|
|
|
+ body.setId(ids[i]);
|
|
|
+ Map<String, Object> map = new HashMap();
|
|
|
+
|
|
|
+ try {
|
|
|
+ // 执行校验逻辑
|
|
|
+ this.checkPass(ids[i], map);
|
|
|
+ String error = (String) map.get("errorMsg");
|
|
|
+
|
|
|
+ // 如果没有错误信息，则继续处理
|
|
|
+ if (org.apache.commons.lang3.StringUtils.isEmpty(error)) {
|
|
|
+ // 查询 Offer 信息
|
|
|
+ OfferInfo offer = iOffer.getOfferInfo("select resumeBaseRec,preEntry.*,preEntry.talent.*,preEntryDate where id = '" + ids[i] + "' ");
|
|
|
+
|
|
|
+ // 如果该 Offer 没有被放弃入职
|
|
|
+ if (!offer.isGiveUpEntry()) {
|
|
|
+ SyncResumeToPreServiceEx syncResumeToPreServiceEx = new SyncResumeToPreServiceEx();
|
|
|
+ // 添加标准预备入职记录
|
|
|
+ syncResumeToPreServiceEx.addNewPreEntryByResume(ctx, offer, false);
|
|
|
+ }
|
|
|
+
|
|
|
+ ++success;
|
|
|
+ body.setMuitTipsState(Boolean.TRUE);
|
|
|
+ body.setMuitTipsMessage("操作成功！");
|
|
|
+ batchMessageTipsHeader.addResult(body);
|
|
|
+ } else {
|
|
|
+ // 校验失败，记录失败原因
|
|
|
+ ++failure;
|
|
|
+ body.setMuitTipsState(Boolean.FALSE);
|
|
|
+ body.setMuitTipsMessage(error);
|
|
|
+ batchMessageTipsHeader.addResult(body);
|
|
|
+ }
|
|
|
+ } catch (EASBizException e) {
|
|
|
+ logger.error(e.getMessage(), e);
|
|
|
+ ++failure;
|
|
|
+ body.setMuitTipsState(Boolean.FALSE);
|
|
|
+ body.setMuitTipsMessage("预入职失败！" + e.getMessage());
|
|
|
+ batchMessageTipsHeader.addResult(body);
|
|
|
+ } catch (BOSException e) {
|
|
|
+ logger.error(e.getMessage(), e);
|
|
|
+ ++failure;
|
|
|
+ body.setMuitTipsState(Boolean.FALSE);
|
|
|
+ body.setMuitTipsMessage("预入职失败！" + e.getMessage());
|
|
|
+ batchMessageTipsHeader.addResult(body);
|
|
|
+ } catch (SHRWebException e) {
|
|
|
+ logger.error(e.getMessage(), e);
|
|
|
+ ++failure;
|
|
|
+ body.setMuitTipsState(Boolean.FALSE);
|
|
|
+ body.setMuitTipsMessage("预入职失败！" + e.getMessage());
|
|
|
+ batchMessageTipsHeader.addResult(body);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ // 设置批量处理结果统计信息
|
|
|
+ batchMessageTipsHeader.setBillId(billIds);
|
|
|
+ batchMessageTipsHeader.setFailureCount(failure);
|
|
|
+ batchMessageTipsHeader.setSuccessCount(success);
|
|
|
+
|
|
|
+ // 输出处理结果
|
|
|
+ this.writeSuccessData(batchMessageTipsHeader);
|
|
|
+
|
|
|
+ // 同步录用报批状态至北森系统
|
|
|
try {
|
|
|
if (!StringUtils.isEmpty(billIds)) {
|
|
|
- //同步录用报批状态至北森
|
|
|
IBeisenTransferPhaseFacade iBeisenTransferPhaseFacade =
|
|
|
BeisenTransferPhaseFacadeFactory.getLocalInstance(ctx);
|
|
|
iBeisenTransferPhaseFacade.syncOfferToBeisen(billIds, 0);
|
|
|
@@ -110,6 +210,126 @@ public class OfferListHandlerEx extends OfferListHandler {
|
|
|
}
|
|
|
}
|
|
|
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 检查候选人是否可以进入下一步流程（如简历投递等），主要判断该候选人是否正在被其他职位流程占用。
|
|
|
+ * 如果候选人当前处于“简历筛选”或其他招聘环节，则不允许重复使用，并提示相关信息。
|
|
|
+ *
|
|
|
+ * @param billId 候选人简历的唯一标识ID
|
|
|
+ * @param map 用于返回错误信息的Map对象，若检查不通过会填充state和errorMsg字段
|
|
|
+ * @return true表示可以通过，false表示已被占用或存在冲突
|
|
|
+ * @throws SHRWebException 当业务逻辑异常或系统异常时抛出
|
|
|
+ */
|
|
|
+ private boolean checkPass(String billId, Map<String, Object> map) throws SHRWebException {
|
|
|
+ StringBuffer msgBuffer = new StringBuffer("");
|
|
|
+ try {
|
|
|
+ // 获取当前简历在途的应聘记录集合
|
|
|
+ ResumeBaseRecCollection resumeColl = this.getOnWayResume(billId);
|
|
|
+ if (resumeColl != null && resumeColl.size() > 0) {
|
|
|
+ ResumeBaseRecInfo resumeBaseRec = resumeColl.get(0);
|
|
|
+ // 判断当前简历所处的状态是否为“简历筛选”
|
|
|
+ if ("简历筛选".equals(resumeBaseRec.getResumeState().getResumeStateType().getName())) {
|
|
|
+ msgBuffer.append("当前候选人已被：");
|
|
|
+ String positionName = "";
|
|
|
+ // 获取职位名称（优先取recuritPosition，其次hrJob）
|
|
|
+ if (resumeBaseRec.getRecuritPosition() != null) {
|
|
|
+ positionName = resumeBaseRec.getRecuritPosition().getName();
|
|
|
+ } else if (resumeBaseRec.getHrJob() != null) {
|
|
|
+ positionName = resumeBaseRec.getHrJob().getName();
|
|
|
+ }
|
|
|
+ msgBuffer.append(positionName);
|
|
|
+ msgBuffer.append("职位(");
|
|
|
+ msgBuffer.append(resumeBaseRec.getDepartment().getName());
|
|
|
+ msgBuffer.append("部门)");
|
|
|
+ msgBuffer.append("的简历筛选环节所抢,可联系操作人");
|
|
|
+
|
|
|
+ // 添加操作人信息
|
|
|
+ if (resumeBaseRec.getProposer() != null) {
|
|
|
+ msgBuffer.append(resumeBaseRec.getProposer().getName() + "解锁！");
|
|
|
+ } else {
|
|
|
+ msgBuffer.append("解锁！");
|
|
|
+ }
|
|
|
+ } else {
|
|
|
+ // 当前简历处于其他招聘环节
|
|
|
+ msgBuffer.append("当前候选人正在：");
|
|
|
+ String positionName = "";
|
|
|
+
|
|
|
+ // 获取职位名称（优先取recuritPosition，其次hrJob）
|
|
|
+ if (resumeBaseRec.getRecuritPosition() != null) {
|
|
|
+ positionName = resumeBaseRec.getRecuritPosition().getName();
|
|
|
+ } else if (resumeBaseRec.getHrJob() != null) {
|
|
|
+ positionName = resumeBaseRec.getHrJob().getName();
|
|
|
+ }
|
|
|
+ msgBuffer.append(positionName);
|
|
|
+ msgBuffer.append("职位(");
|
|
|
+ msgBuffer.append(resumeBaseRec.getDepartment().getName());
|
|
|
+ msgBuffer.append("部门)的");
|
|
|
+ msgBuffer.append(resumeBaseRec.getResumeState().getResumeStateType().getName());
|
|
|
+ msgBuffer.append("环节应聘！当在该职位上应聘不通过，才可释放使用！");
|
|
|
+ // 查询最近处理人信息
|
|
|
+ ApplyRecordCollection applyRecordCollection = ApplyRecordFactory.getRemoteInstance().getApplyRecordCollection("select creator.name where resumeBaseRec ='" + resumeBaseRec.getId() + "' order by createTime desc");
|
|
|
+ if (null != applyRecordCollection && applyRecordCollection.size() > 0) {
|
|
|
+ msgBuffer.append("可联系简历当前或者上一处理人：”" + applyRecordCollection.get(0).getCreator().getName() + "“释放");
|
|
|
+ }
|
|
|
+ }
|
|
|
+ // 将错误信息放入map中返回
|
|
|
+ map.put("state", "error");
|
|
|
+ map.put("errorMsg", msgBuffer.toString());
|
|
|
+ return false;
|
|
|
+ } else {
|
|
|
+ // 无在途应聘记录，允许继续操作
|
|
|
+ return true;
|
|
|
+ }
|
|
|
+ } catch (EASBizException e) {
|
|
|
+ logger.error(e.getMessage(), e);
|
|
|
+ throw new ShrWebBizException(e.getMessage(), e);
|
|
|
+ } catch (BOSException e) {
|
|
|
+ logger.error(e.getMessage(), e);
|
|
|
+ throw new ShrWebBizException(e.getMessage(), e);
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 获取在途简历信息
|
|
|
+ *
|
|
|
+ * @param offerId 申请单ID
|
|
|
+ * @return 简历基础信息集合
|
|
|
+ * @throws BOSException 业务对象服务异常
|
|
|
+ * @throws EASBizException EAS业务异常
|
|
|
+ */
|
|
|
+ private ResumeBaseRecCollection getOnWayResume(String offerId) throws BOSException, EASBizException {
|
|
|
+ ResumeBaseRecCollection resumeColl = null;
|
|
|
+ SelectorItemCollection sel = new SelectorItemCollection();
|
|
|
+ sel.add(new SelectorItemInfo("*"));
|
|
|
+ sel.add(new SelectorItemInfo("resumeBaseRec.*"));
|
|
|
+ // 根据offerId获取申请单信息
|
|
|
+ OfferInfo offer = OfferFactory.getRemoteInstance().getOfferInfo(new ObjectUuidPK(offerId), sel);
|
|
|
+ String ifSimplePerson = offer.getResumeBaseRec().getIfSimplePerson();
|
|
|
+ if (!StringUtil.isEmpty(ifSimplePerson)) {
|
|
|
+ // 构造查询条件：相同简单人员标识、已处理状态、排除当前记录
|
|
|
+ EntityViewInfo evi = new EntityViewInfo();
|
|
|
+ FilterInfo filter = new FilterInfo();
|
|
|
+ filter.getFilterItems().add(new FilterItemInfo("ifSimplePerson", ifSimplePerson, CompareType.EQUALS));
|
|
|
+ filter.getFilterItems().add(new FilterItemInfo("TransactionState", TransactionStateEnum.PROCESSED.getValue(), CompareType.EQUALS));
|
|
|
+ filter.getFilterItems().add(new FilterItemInfo("id", offer.getResumeBaseRec().getId().toString(), CompareType.NOTEQUALS));
|
|
|
+ // 设置需要查询的字段
|
|
|
+ SelectorItemCollection sic = evi.getSelector();
|
|
|
+ sic.add(new SelectorItemInfo("department.name"));
|
|
|
+ sic.add(new SelectorItemInfo("recuritPosition.name"));
|
|
|
+ sic.add(new SelectorItemInfo("hrJob.name"));
|
|
|
+ sic.add(new SelectorItemInfo("resumeState.resumeStateType.name"));
|
|
|
+ sic.add(new SelectorItemInfo("proposer.name"));
|
|
|
+ evi.setFilter(filter);
|
|
|
+ evi.setSelector(sic);
|
|
|
+ // 执行查询获取在途简历集合
|
|
|
+ IResumeBaseRec iResumeBaseRec = ResumeBaseRecFactory.getRemoteInstance();
|
|
|
+ resumeColl = iResumeBaseRec.getResumeBaseRecCollection(evi);
|
|
|
+ }
|
|
|
+ return resumeColl;
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
/**
|
|
|
* 反终止
|
|
|
*
|
heyuan