diff --git a/src/com/engine/recruit/conn/RecruitRecordSet.java b/src/com/engine/recruit/conn/RecruitRecordSet.java index 9adc278..5357264 100644 --- a/src/com/engine/recruit/conn/RecruitRecordSet.java +++ b/src/com/engine/recruit/conn/RecruitRecordSet.java @@ -84,14 +84,12 @@ public class RecruitRecordSet { public static void updateDataById(Map dataMap, String tableName) { List fieldList = new ArrayList<>(); List dataList = new ArrayList<>(); - List paramList = new ArrayList<>(); String id = Util.null2String(dataMap.get("id")); dataMap.remove("id"); dataMap.forEach((key, value) -> { fieldList.add(key + " = ? "); dataList.add(value); - paramList.add("?"); }); dataList.add(id); String updateSql = "update " + tableName + " set " + StringUtils.join(fieldList, ",") + " where id = ? "; @@ -102,6 +100,20 @@ public class RecruitRecordSet { } } + /** + * 删除数据 + * + * @param deleteSql + */ + public static void deleteData(String deleteSql) { + RecordSet rs = new RecordSet(); + rs.executeUpdate(deleteSql); + if (StringUtils.isNotBlank(rs.getExceptionMsg())) { + throw new CustomizeRunTimeException(rs.getExceptionMsg()); + } + } + + /** * 构建建模表基本数据 * diff --git a/src/com/engine/recruit/controller/RecruitFlowController.java b/src/com/engine/recruit/controller/RecruitFlowController.java index 0d0c5d7..3490b67 100644 --- a/src/com/engine/recruit/controller/RecruitFlowController.java +++ b/src/com/engine/recruit/controller/RecruitFlowController.java @@ -10,6 +10,7 @@ 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; @@ -43,4 +44,13 @@ public class RecruitFlowController { Map params = ParamUtil.request2Map(request); return new ResponseResult, Map>(user).run(getRecruitFlowWrapper(user)::getRecruitStepList, params); } + + @POST + @Path("/syncRecruitStepInfo") + @Produces(MediaType.APPLICATION_JSON) + public String syncRecruitStepInfo(@Context HttpServletRequest request, @Context HttpServletResponse response) { + User user = HrmUserVarify.getUser(request, response); + Map params = ParamUtil.request2Map(request); + return new ResponseResult, Map>(user).run(getRecruitFlowWrapper(user)::syncRecruitStepInfo, params); + } } diff --git a/src/com/engine/recruit/entity/recruitflow/po/RecruitStepDt1.java b/src/com/engine/recruit/entity/recruitflow/po/RecruitStepDt1.java new file mode 100644 index 0000000..3268b10 --- /dev/null +++ b/src/com/engine/recruit/entity/recruitflow/po/RecruitStepDt1.java @@ -0,0 +1,42 @@ +package com.engine.recruit.entity.recruitflow.po; + +import lombok.*; + +import java.util.Objects; + +/** + * @author:dxfeng + * @createTime: 2024/02/29 + * @version: 1.0 + */ +@Data +@Builder +@AllArgsConstructor +@NoArgsConstructor +public class RecruitStepDt1 { + private String id; + private String mainid; + private String czan; + private String zdyxsmc; + private String tzymdz; + private String sfqy; + private String tzymbt; + private String zssx; + + @Override + public boolean equals(Object o) { + if (this == o) { + return true; + } + if (o == null || getClass() != o.getClass()) { + return false; + } + RecruitStepDt1 stepDt1 = (RecruitStepDt1) o; + return czan.equals(stepDt1.czan); + } + + @Override + public int hashCode() { + return Objects.hash(czan); + } +} diff --git a/src/com/engine/recruit/entity/recruitflow/po/RecruitStepDt2.java b/src/com/engine/recruit/entity/recruitflow/po/RecruitStepDt2.java new file mode 100644 index 0000000..d0fd482 --- /dev/null +++ b/src/com/engine/recruit/entity/recruitflow/po/RecruitStepDt2.java @@ -0,0 +1,23 @@ +package com.engine.recruit.entity.recruitflow.po; + +import lombok.AllArgsConstructor; +import lombok.Builder; +import lombok.Data; +import lombok.NoArgsConstructor; + +/** + * @author:dxfeng + * @createTime: 2024/02/29 + * @version: 1.0 + */ +@Data +@Builder +@AllArgsConstructor +@NoArgsConstructor +public class RecruitStepDt2 { + private String id; + private String mainid; + private String ymbt; + private String ymdz; + private String zssx; +} diff --git a/src/com/engine/recruit/service/RecruitFlowService.java b/src/com/engine/recruit/service/RecruitFlowService.java index 63a7ec9..9ddc439 100644 --- a/src/com/engine/recruit/service/RecruitFlowService.java +++ b/src/com/engine/recruit/service/RecruitFlowService.java @@ -26,4 +26,13 @@ public interface RecruitFlowService { * @return 招聘阶段 */ Map getRecruitStepList(Map param); + + + /** + * 同步招聘阶段 + * + * @param param + * @return + */ + Map syncRecruitStepInfo(Map param); } diff --git a/src/com/engine/recruit/service/impl/InitRecruitDataServiceImpl.java b/src/com/engine/recruit/service/impl/InitRecruitDataServiceImpl.java index 930aaad..dbdca73 100644 --- a/src/com/engine/recruit/service/impl/InitRecruitDataServiceImpl.java +++ b/src/com/engine/recruit/service/impl/InitRecruitDataServiceImpl.java @@ -73,7 +73,9 @@ public class InitRecruitDataServiceImpl extends Service implements InitRecruitDa searchCodeMap.put("招聘需求管理", "b129634bf72d46b8bed0291f84efd2e0"); searchCodeMap.put("招聘职位", "c024e527c964437bb568bebbb48d89a5"); searchCodeMap.put("应聘者", "1d48211cd1634b19bdc6f7df40cd1337"); - searchCodeMap.put("筛选反馈", "b746e3cf80454289a3ade2b17147e297"); + //searchCodeMap.put("筛选反馈", "b746e3cf80454289a3ade2b17147e297"); + // TODO 改造为筛选反馈树 + searchCodeMap.put("筛选反馈", "669a72259c0c47e49a97f5b68692ed34"); searchCodeMap.put("笔试结果", "1b56a7492fb84f2b9e5ae022fde333f0"); searchCodeMap.put("面试", "496ecc32a87045888f224ad3151e635b"); searchCodeMap.put("薪酬谈判", "ffe1bafcef5942f5853e68b76e5098d2"); diff --git a/src/com/engine/recruit/service/impl/RecruitFlowServiceImpl.java b/src/com/engine/recruit/service/impl/RecruitFlowServiceImpl.java index 5a3f84b..b95cecc 100644 --- a/src/com/engine/recruit/service/impl/RecruitFlowServiceImpl.java +++ b/src/com/engine/recruit/service/impl/RecruitFlowServiceImpl.java @@ -1,12 +1,14 @@ package com.engine.recruit.service.impl; +import cn.hutool.core.convert.Convert; import com.engine.core.impl.Service; -import com.engine.recruit.entity.recruitflow.po.RecruitButton; -import com.engine.recruit.entity.recruitflow.po.RecruitStepPo; -import com.engine.recruit.entity.recruitflow.po.RecruitTabPo; +import com.engine.recruit.conn.RecruitDataMap; +import com.engine.recruit.conn.RecruitRecordSet; +import com.engine.recruit.entity.recruitflow.po.*; import com.engine.recruit.exception.CustomizeRunTimeException; import com.engine.recruit.service.RecruitFlowService; import com.engine.recruit.util.RecruitFlowUtil; +import org.apache.commons.collections.CollectionUtils; import org.apache.commons.lang3.StringUtils; import weaver.conn.RecordSet; import weaver.general.Util; @@ -15,6 +17,7 @@ import java.util.ArrayList; import java.util.HashMap; import java.util.List; import java.util.Map; +import java.util.stream.Collectors; /** * @author:dxfeng @@ -127,4 +130,238 @@ public class RecruitFlowServiceImpl extends Service implements RecruitFlowServic returnMap.put("currentStageId", currentStageId); return returnMap; } + + @Override + public Map syncRecruitStepInfo(Map param) { + String stepId = Util.null2String(param.get("stepId")); + String recruitFlowId = Util.null2String(param.get("recruitFlowId")); + String checkedValue = Util.null2String(param.get("checkedValue")); + + if (StringUtils.isBlank(stepId)) { + throw new CustomizeRunTimeException("未获取到所选招聘阶段,请刷新后重试"); + } + if (StringUtils.isBlank(recruitFlowId)) { + throw new CustomizeRunTimeException("同步流程为空，请选择同步流程"); + } + if (StringUtils.isBlank(checkedValue)) { + throw new CustomizeRunTimeException("请选择同步选项"); + } + + // 判断该流程是否有该阶段，没有该阶段的不做操作 + String flowStepId = getFlowStepId(stepId, recruitFlowId); + if (StringUtils.isBlank(flowStepId)) { + throw new CustomizeRunTimeException("所选流程不具备当前招聘阶段，同步失败"); + } + + + switch (checkedValue) { + case "syncAdd": + syncAdd(stepId, flowStepId); + break; + case "syncOrder": + syncOrder(stepId, flowStepId); + break; + case "syncAll": + syncAll(stepId, flowStepId); + break; + case "syncTab": + syncTab(stepId, flowStepId); + break; + default: + throw new CustomizeRunTimeException("未识别的同步方式"); + } + return null; + } + + /** + * 同步新增操作 + * 直接将缺失的操作按钮追加在原有按钮后方 + * + * @param stepId + * @param flowStepId + */ + private void syncAdd(String stepId, String flowStepId) { + List stepDt1List = getStepDt1List(stepId); + List flowStepDt1List = getStepDt1List(flowStepId); + + // 比较差异,只保留flowStepDt1List中没有的元素 + List result = stepDt1List.stream() + .filter(item -> !flowStepDt1List.contains(item)) + .collect(Collectors.toList()); + + // 元素追加 + Integer order = 0; + if (CollectionUtils.isNotEmpty(flowStepDt1List)) { + String zssx = flowStepDt1List.get(flowStepDt1List.size() - 1).getZssx(); + if (StringUtils.isNotBlank(zssx)) { + order = Convert.toInt(zssx); + } + } + + for (RecruitStepDt1 stepDt1 : result) { + order += 10; + RecruitDataMap dataMap = new RecruitDataMap<>(); + dataMap.put("mainid", flowStepId); + dataMap.put("czan", stepDt1.getCzan()); + dataMap.put("zdyxsmc", stepDt1.getZdyxsmc()); + dataMap.put("tzymdz", stepDt1.getTzymdz()); + dataMap.put("sfqy", stepDt1.getSfqy()); + dataMap.put("tzymbt", stepDt1.getTzymbt()); + dataMap.put("zssx", order.toString()); + RecruitRecordSet.insertData(dataMap, "uf_jcl_zpjdsz_dt1"); + } + } + + /** + * 同步操作顺序 + * 比较差异、按顺序插空进入 + * + * @param stepId + * @param flowStepId + */ + private void syncOrder(String stepId, String flowStepId) { + List stepDt1List = getStepDt1List(stepId); + List flowStepDt1List = getStepDt1List(flowStepId); + + // 只保留stepDt1List中相同的元素 + flowStepDt1List.retainAll(stepDt1List); + + int index = 0; + for (int i = 0; i < stepDt1List.size(); i++) { + RecruitStepDt1 character = stepDt1List.get(i); + if (flowStepDt1List.contains(character)) { + RecruitStepDt1 remove = flowStepDt1List.get(index++); + stepDt1List.set(i, remove); + } + } + + // 调整展示顺序 + int order = 0; + for (RecruitStepDt1 stepDt1 : stepDt1List) { + RecruitDataMap dataMap = new RecruitDataMap<>(); + dataMap.put("zssx", order += 10); + dataMap.put("id", stepDt1.getId()); + RecruitRecordSet.updateDataById(dataMap, "uf_jcl_zpjdsz_dt1"); + } + + } + + /** + * 同步所有操作（覆盖替换） + * + * @param stepId + * @param flowStepId + */ + private void syncAll(String stepId, String flowStepId) { + List stepDt1List = getStepDt1List(stepId); + + // 删除原有的数据 + String deleteSql = "delete from uf_jcl_zpjdsz_dt1 where mainid = " + flowStepId; + RecruitRecordSet.deleteData(deleteSql); + for (RecruitStepDt1 stepDt1 : stepDt1List) { + RecruitDataMap dataMap = new RecruitDataMap<>(); + dataMap.put("mainid", flowStepId); + dataMap.put("czan", stepDt1.getCzan()); + dataMap.put("zdyxsmc", stepDt1.getZdyxsmc()); + dataMap.put("tzymdz", stepDt1.getTzymdz()); + dataMap.put("sfqy", stepDt1.getSfqy()); + dataMap.put("tzymbt", stepDt1.getTzymbt()); + dataMap.put("zssx", stepDt1.getZssx()); + RecruitRecordSet.insertData(dataMap, "uf_jcl_zpjdsz_dt1"); + } + + } + + /** + * 同步卡片展示tab页面 + * + * @param stepId + * @param flowStepId + */ + private void syncTab(String stepId, String flowStepId) { + List stepDt2List = getStepDt2List(stepId); + + // 删除原有的数据 + String deleteSql = "delete from uf_jcl_zpjdsz_dt2 where mainid = " + flowStepId; + RecruitRecordSet.deleteData(deleteSql); + int order = 0; + for (RecruitStepDt2 stepDt2 : stepDt2List) { + order += 10; + RecruitDataMap dataMap = new RecruitDataMap<>(); + dataMap.put("mainid", flowStepId); + dataMap.put("ymbt", stepDt2.getYmbt()); + dataMap.put("ymdz", stepDt2.getYmdz()); + dataMap.put("zssx", Integer.toString(order)); + RecruitRecordSet.insertData(dataMap, "uf_jcl_zpjdsz_dt2"); + } + } + + + /** + * 获取流程对应的当前阶段ID + * + * @param stepId + * @param recruitFlowId + * @return + */ + private String getFlowStepId(String stepId, String recruitFlowId) { + RecordSet rs = new RecordSet(); + rs.executeQuery("select id from uf_jcl_zpjdsz where zplc = ? and zpjd = ?", recruitFlowId, stepId); + if (rs.next()) { + return rs.getString("id"); + } + return ""; + } + + + /** + * 根据阶段ID，获取该阶段所有的按钮配置集合 + * + * @param stepId + * @return + */ + private List getStepDt1List(String stepId) { + List list = new ArrayList<>(); + RecordSet rs = new RecordSet(); + rs.executeQuery("select * from uf_jcl_zpjdsz_dt1 where mainid = ? order by zssx", stepId); + while (rs.next()) { + RecruitStepDt1 stepDt1 = RecruitStepDt1.builder() + .id(rs.getString("id")) + .mainid(rs.getString("mainid")) + .czan(rs.getString("czan")) + .zdyxsmc(rs.getString("zdyxsmc")) + .tzymdz(rs.getString("tzymdz")) + .sfqy(rs.getString("sfqy")) + .tzymbt(rs.getString("tzymbt")) + .zssx(rs.getString("zssx")) + .build(); + list.add(stepDt1); + } + return list; + } + + + /** + * 根据阶段ID，获取该阶段所有的tab页面配置集合 + * + * @param stepId + * @return + */ + private List getStepDt2List(String stepId) { + List list = new ArrayList<>(); + RecordSet rs = new RecordSet(); + rs.executeQuery("select * from uf_jcl_zpjdsz_dt2 where mainid = ? order by zssx", stepId); + while (rs.next()) { + RecruitStepDt2 stepDt1 = RecruitStepDt2.builder() + .id(rs.getString("id")) + .mainid(rs.getString("mainid")) + .ymbt(rs.getString("ymbt")) + .ymdz(rs.getString("ymdz")) + .zssx(rs.getString("zssx")) + .build(); + list.add(stepDt1); + } + return list; + } + } diff --git a/src/com/engine/recruit/wrapper/RecruitFlowWrapper.java b/src/com/engine/recruit/wrapper/RecruitFlowWrapper.java index e6ae5c9..092d203 100644 --- a/src/com/engine/recruit/wrapper/RecruitFlowWrapper.java +++ b/src/com/engine/recruit/wrapper/RecruitFlowWrapper.java @@ -25,4 +25,8 @@ public class RecruitFlowWrapper extends Service { public Map getRecruitStepList(Map param) { return getRecruitFlowService(user).getRecruitStepList(param); } + + public Map syncRecruitStepInfo(Map param) { + return getRecruitFlowService(user).syncRecruitStepInfo(param); + } } diff --git a/src/weaver/interfaces/gsjrkg/action/SyncCertificateAction.java b/src/weaver/interfaces/gsjrkg/action/SyncCertificateAction.java new file mode 100644 index 0000000..3eed22c --- /dev/null +++ b/src/weaver/interfaces/gsjrkg/action/SyncCertificateAction.java @@ -0,0 +1,144 @@ +package weaver.interfaces.gsjrkg.action; + +import com.alibaba.fastjson.JSON; +import org.apache.commons.collections.CollectionUtils; +import org.apache.commons.lang3.StringUtils; +import weaver.conn.RecordSet; +import weaver.general.BaseBean; +import weaver.general.Util; +import weaver.interfaces.workflow.action.Action; +import weaver.soa.workflow.request.MainTableInfo; +import weaver.soa.workflow.request.Property; +import weaver.soa.workflow.request.RequestInfo; + +import java.util.*; + +/** + * @Description: 同步证书到人员卡片个人信息 + * @author:dxfeng + * @createTime: 2023/02/20 + * @version: 1.0 + */ +public class SyncCertificateAction implements Action { + /** + * 建模表表名 + */ + private String modeTableName; + + /** + * 参数名称：建模表字段名：人员表字段名 + */ + private String params; + + private String resourceFieldGroup; + + @Override + public String execute(RequestInfo requestInfo) { + BaseBean baseBean = new BaseBean(); + if (StringUtils.isBlank(params)) { + requestInfo.getRequestManager().setMessagecontent("自定义接口参数值配置错误"); + return Action.FAILURE_AND_CONTINUE; + } + if (StringUtils.isBlank(resourceFieldGroup)) { + // -1:基本信息,1:个人信息,3:工作信息 + resourceFieldGroup = "1"; + } + Map fieldMap = new HashMap<>(); + String[] fieldsArray = params.split(";"); + for (String fields : fieldsArray) { + String[] field = fields.split(":"); + if (field.length == 2) { + fieldMap.put(field[0], field[1]); + } + } + if (fieldMap.size() != fieldsArray.length) { + requestInfo.getRequestManager().setMessagecontent("自定义接口参数值格式错误,请检查"); + return Action.FAILURE_AND_CONTINUE; + } + baseBean.writeLog("fieldMap==" + JSON.toJSONString(fieldMap)); + Set modeFields = fieldMap.keySet(); + Map> modeMap = new HashMap<>(); + + RecordSet rs = new RecordSet(); + String resourceId = ""; + MainTableInfo mainTableInfo = requestInfo.getMainTableInfo(); + Property[] property = mainTableInfo.getProperty(); + for (Property item : property) { + String name = item.getName(); + String value = Util.null2String(item.getValue()); + if (StringUtils.isNotBlank(name) && StringUtils.isNotBlank(value)) { + if ("xm".equals(name)) { + resourceId = value; + } + } + } + // 查询当前人员的所有数据 + StringBuilder sqlBuilder = new StringBuilder("select ").append(StringUtils.join(modeFields, ",")).append(" from ").append(modeTableName).append(" where xm = ").append(resourceId).append(" order by id"); + baseBean.writeLog("selectSql===" + sqlBuilder); + rs.executeQuery(sqlBuilder.toString()); + while (rs.next()) { + appendIds(modeFields, rs, modeMap); + } + baseBean.writeLog("modeMap===" + JSON.toJSONString(modeMap)); + // 判断有无数据，没有的话插入数据 + sqlBuilder = new StringBuilder("SELECT id FROM CUS_FIELDDATA where scope ='HrmCustomFieldByInfoType' and scopeid = '").append(resourceFieldGroup).append("' and id =? "); + rs.executeQuery(sqlBuilder.toString(), resourceId); + if (!rs.next()) { + // 插入人员信息数据 + rs.executeUpdate("insert into cus_fielddata (scope,scopeid,id) values ('HrmCustomFieldByInfoType','" + resourceFieldGroup + "',?)", resourceId); + } + // 组装更新SQL语句 + sqlBuilder = new StringBuilder("update cus_fielddata set "); + for (Map.Entry entry : fieldMap.entrySet()) { + Set valueSet = modeMap.get(entry.getKey()); + String values = CollectionUtils.isEmpty(valueSet) ? "" : StringUtils.join(valueSet, ","); + sqlBuilder.append(" ").append(entry.getValue()).append(" = '").append(values).append("',"); + } + sqlBuilder.deleteCharAt(sqlBuilder.length() - 1); + sqlBuilder.append(" where scope ='HrmCustomFieldByInfoType' and scopeid = ").append(resourceFieldGroup).append(" and id = ").append(resourceId); + baseBean.writeLog("updateSql===" + sqlBuilder); + rs.executeUpdate(sqlBuilder.toString()); + + return Action.SUCCESS; + } + + + private void appendIds(Set modeFields, RecordSet rs, Map> modeMap) { + BaseBean baseBean = new BaseBean(); + for (String modeField : modeFields) { + String ids = rs.getString(modeField); + baseBean.writeLog("modeField==【" + modeField + "】,getString==【" + ids + "】"); + if (StringUtils.isBlank(ids)) { + continue; + } + if (CollectionUtils.isEmpty(modeMap.get(modeField))) { + modeMap.put(modeField, new HashSet<>()); + } + modeMap.get(modeField).addAll(Arrays.asList(ids.split(","))); + } + } + + public String getParams() { + return params; + } + + public void setParams(String params) { + this.params = params; + } + + public String getModeTableName() { + return modeTableName; + } + + public void setModeTableName(String modeTableName) { + this.modeTableName = modeTableName; + } + + public String getResourceFieldGroup() { + return resourceFieldGroup; + } + + public void setResourceFieldGroup(String resourceFieldGroup) { + this.resourceFieldGroup = resourceFieldGroup; + } +}