dxfeng
/
weaver-hrm-recruit
generated from dxfeng/secondev-chapanda-feishu
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

千里聆职位发布、职位下架

This commit is contained in:
dxfeng 2023-10-09 10:31:12 +08:00
parent b7c5156d0c
commit ada279bb19
5 changed files with 407 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

42
src/com/engine/recruit/enums/PositionThirdChannelEnum.java Normal file
View File

@ -0,0 +1,42 @@
package com.engine.recruit.enums;
/**
* 发布渠道枚举类
*
* @author:dxfeng
* @createTime: 2023/10/08
* @version: 1.0
*/
public enum PositionThirdChannelEnum {
/**
* 发布渠道
*/
BOSS("0"),
ZHI_LIAN("1"),
D51_JOB("2"),
LA_GOU("3"),
LIE_PIN("4");
PositionThirdChannelEnum(String value) {
this.value = value;
}
private String value;
public String getValue() {
return value;
}
public void setValue(String value) {
this.value = value;
}
public static PositionThirdChannelEnum getEnum(String value) {
for (PositionThirdChannelEnum item : PositionThirdChannelEnum.values()) {
if (item.value.equalsIgnoreCase(value)) {
return item;
}
}
throw new RuntimeException("不支持的发布渠道");
}
}

56
src/weaver/formmode/recruit/modeexpand/position/ClosePositionModeExpand.java Normal file
View File

@ -0,0 +1,56 @@
package weaver.formmode.recruit.modeexpand.position;
import com.weaver.rpa.sdk.clients.application.resume.ERPAResumeSDKClient;
import com.weaver.rpa.sdk.clients.core.ERPASDKClients;
import weaver.conn.RecordSet;
import weaver.formmode.customjavacode.AbstractModeExpandJavaCodeNew;
import weaver.general.BaseBean;
import weaver.general.Util;
import weaver.hrm.User;
import weaver.soa.workflow.request.RequestInfo;
import java.util.HashMap;
import java.util.Map;
/**
* @author:dxfeng
* @createTime: 2023/10/07
* @version: 1.0
*/
public class ClosePositionModeExpand extends AbstractModeExpandJavaCodeNew {
@Override
public Map<String, String> doModeExpand(Map<String, Object> param) {
String tableName = "uf_jcl_zp_zpzw";
Map<String, String> result = new HashMap<>(16);
try {
User user = (User) param.get("user");
int billId;
int modeId;
RequestInfo requestInfo = (RequestInfo) param.get("RequestInfo");
if (requestInfo != null) {
billId = Util.getIntValue(requestInfo.getRequestid());
modeId = Util.getIntValue(requestInfo.getWorkflowid());
if (billId > 0 && modeId > 0) {
RecordSet rs = new RecordSet();
rs.executeQuery("select qllgwid from " + tableName + " where id = ?", billId);
if (rs.next()) {
long jobId = Long.parseLong(rs.getString("qllgwid"));
ERPAResumeSDKClient client = ERPASDKClients.getResumeSDKClient();
client.start();
String userId = String.valueOf(user.getUID());
client.closeResumeJob(userId, jobId);
rs.executeUpdate("update " + tableName + " set qdfbzt = ? where id = ?", jobId, 5, billId);
}
}
}
} catch (Exception e) {
new BaseBean().writeLog(e);
result.put("errmsg", e.getMessage());
result.put("flag", "false");
}
return result;
}
}

90
src/weaver/formmode/recruit/modeexpand/position/ReleasePositionModeExpand.java Normal file
View File

@ -0,0 +1,90 @@
package weaver.formmode.recruit.modeexpand.position;
import com.weaver.rpa.sdk.clients.application.resume.ERPAResumeSDKClient;
import com.weaver.rpa.sdk.clients.application.resume.entity.ResumeJobDto;
import com.weaver.rpa.sdk.clients.core.ERPASDKClients;
import weaver.conn.RecordSet;
import weaver.formmode.customjavacode.AbstractModeExpandJavaCodeNew;
import weaver.formmode.recruit.modeexpand.util.RecruitPositionUtil;
import weaver.general.BaseBean;
import weaver.general.Util;
import weaver.hrm.User;
import weaver.soa.workflow.request.MainTableInfo;
import weaver.soa.workflow.request.Property;
import weaver.soa.workflow.request.RequestInfo;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
/**
* @author:dxfeng
* @createTime: 2023/10/07
* @version: 1.0
*/
public class ReleasePositionModeExpand extends AbstractModeExpandJavaCodeNew {
@Override
public Map<String, String> doModeExpand(Map<String, Object> param) {
String tableName = "uf_jcl_zp_zpzw";
Map<String, String> result = new HashMap<>(16);
try {
User user = (User) param.get("user");
int billId;
int modeId;
RequestInfo requestInfo = (RequestInfo) param.get("RequestInfo");
if (requestInfo != null) {
billId = Util.getIntValue(requestInfo.getRequestid());
modeId = Util.getIntValue(requestInfo.getWorkflowid());
if (billId > 0 && modeId > 0) {
long jobId = -1;
RecordSet rs = new RecordSet();
rs.executeQuery("select qllgwid from " + tableName + " where id = ?", billId);
if (rs.next()) {
jobId = Long.parseLong(rs.getString("qllgwid"));
}
ERPAResumeSDKClient client = ERPASDKClients.getResumeSDKClient();
Map<String, Object> map = new HashMap<>(16);
MainTableInfo mainTableInfo = requestInfo.getMainTableInfo();
Property[] properties = mainTableInfo.getProperty();
for (Property property : properties) {
map.put(property.getName(), property.getValue());
}
ResumeJobDto resumeJobDto = RecruitPositionUtil.convertMap2ResumeJobDto(map);
// 发布千里聆职位
if (!RecruitPositionUtil.checkAvailable(client)) {
new BaseBean().writeLog("千里聆未开通简历应用。");
result.put("errmsg", "千里聆未开通简历应用。");
result.put("flag", "false");
}
String userId = String.valueOf(user.getUID());
// TODO 测试数据 userId = "26";
// 未创建职位，则先创建职位
if (jobId == -1) {
// 创建千里聆职位
jobId = client.addResumeJob(userId, resumeJobDto);
// 更新千里聆ID到建模表单
rs.executeUpdate("update " + tableName + " set qllgwid = ? where id = ?", jobId, billId);
}
// 发布职位
client.setRobotAuthority(userId,userId,false);
client.start();
List<Integer> platformIds = resumeJobDto.getPlatformIds();
for (Integer platformId : platformIds) {
client.releaseResumeJob(userId, jobId, platformId);
}
// 更新状态为已发布
rs.executeUpdate("update " + tableName + " set qdfbzt = ? where id = ?", 2, billId);
}
}
} catch (Exception e) {
new BaseBean().writeLog(e);
result.put("errmsg", e.getMessage());
result.put("flag", "false");
}
return result;
}
}

29
src/weaver/formmode/recruit/modeexpand/util/ApplicantCommonInfo.java
View File

@ -1,7 +1,11 @@
package weaver.formmode.recruit.modeexpand.util;
import org.apache.commons.lang3.StringUtils;
import weaver.conn.RecordSet;
import java.util.ArrayList;
import java.util.List;
/**
* @author:dxfeng
* @createTime: 2023/09/27
@ -40,7 +44,7 @@ public class ApplicantCommonInfo {
/**
* 获取取消理由
* 获取表单下拉框展示文本
*
* @param formId 表单ID
* @param fieldName 字段明湖曾
@ -56,4 +60,27 @@ public class ApplicantCommonInfo {
}
return cancelReason;
}
/**
* 获取招聘通用浏览按钮展示内容
*
* @param id 浏览按钮ID
* @return 浏览按钮展示文本
*/
public static String getRecruitCommonBrowserValue(String id) {
if (StringUtils.isBlank(id)) {
return "";
}
List<String> value = new ArrayList<>();
RecordSet rs = new RecordSet();
String[] split = id.split(",");
for (String s : split) {
rs.executeQuery("select xxnr from uf_sjzd where id = ?", id);
if (rs.next()) {
value.add(rs.getString("xxnr"));
}
}
return StringUtils.join(value, ",");
}
}

191
src/weaver/formmode/recruit/modeexpand/util/RecruitPositionUtil.java Normal file
View File

@ -0,0 +1,191 @@
package weaver.formmode.recruit.modeexpand.util;
import cn.hutool.core.convert.Convert;
import com.alibaba.fastjson.JSON;
import com.engine.recruit.enums.PositionThirdChannelEnum;
import com.weaver.rpa.sdk.clients.application.resume.ERPAResumeSDKClient;
import com.weaver.rpa.sdk.clients.application.resume.common.ResumePlatform;
import com.weaver.rpa.sdk.clients.application.resume.entity.ResumeJobDto;
import com.weaver.rpa.sdk.utils.HttpClientUtils;
import weaver.general.BaseBean;
import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.*;
/**
* 招聘职位工具类
*
* @author:dxfeng
* @createTime: 2023/10/08
* @version: 1.0
*/
public class RecruitPositionUtil {
/**
* 将Map转换成ResumeJobDto对象
*
* @param map 数据集合
* @return ResumeJobDto对象
*/
public static ResumeJobDto convertMap2ResumeJobDto(Map<String, Object> map) {
String positionName = Convert.toStr(map.get("zpzwmc"));//职位名称
String positionDuty = Convert.toStr(map.get("gwzz"));//职位职责
String finishTime = Convert.toStr(map.get("zpjzrq"));//完成时间
String education = ApplicantCommonInfo.getRecruitCommonBrowserValue(Convert.toStr(map.get("zdxlyq")));//学历要求
String workYears = ApplicantCommonInfo.getRecruitCommonBrowserValue(Convert.toStr(map.get("gznx")));//工作年限
String positionNature = ApplicantCommonInfo.getRecruitCommonBrowserValue(Convert.toStr(map.get("zwxz")));//职位性质
Integer salaryMin = Convert.toInt(map.get("zdxzk"), 0);//最低薪酬
Integer salaryMax = Convert.toInt(map.get("zgxzk"), 0);// 最高薪酬
Integer xcyfs = Convert.toInt(map.get("xzyfs"), 12);// 薪酬月份数
Integer workingDays = Convert.toInt(map.get("sxmzdgts"), 1);// 实习每周到岗天数
Integer internshipDuration = Convert.toInt(map.get("sxscy"), 1);// 实习时长（月）
String jobCategory = "不限";//职位类别
int experienceValue = -1;//不限
if ("应届毕业生".equals(workYears)) {
experienceValue = 1;
} else if ("一年以内".equals(workYears)) {
experienceValue = 1;
} else if ("1-3年".equals(workYears)) {
experienceValue = 2;
} else if ("3-5年".equals(workYears)) {
experienceValue = 3;
} else if ("5-10年".equals(workYears)) {
experienceValue = 5;
} else if ("10年以上".equals(workYears)) {
experienceValue = 6;
}
int educationValue = -1; //不限
if ("博士".equals(education)) {
educationValue = 8;
} else if ("MBA/EMBA".equals(education)) {
educationValue = 7;
} else if ("硕士".equals(education)) {
educationValue = 6;
} else if ("本科".equals(education)) {
educationValue = 5;
} else if ("大专".equals(education)) {
educationValue = 4;
} else if ("中专/中技".equals(education)) {
educationValue = 3;
} else if ("高中".equals(education)) {
educationValue = 2;
} else if ("初中及以下".equals(education)) {
educationValue = 1;
}
int resumeType = 1;// 兼职、全职
if ("实习".equals(positionNature)) {
resumeType = 3;
} else if ("校招".equals(positionNature)) {
resumeType = 2;
}
// 招聘职位类型与特殊设置字段
ResumeJobDto resumeJobDto = new ResumeJobDto();
resumeJobDto.setResumeType(resumeType); // (必填,默认社招)招聘类型 1:社招 2:校招 3:实习
resumeJobDto.setStopReumeTimeLong(stringTurnLong(finishTime));// (校招必填)仅校招: 招聘截止时间(时间戳)
resumeJobDto.setRequirementsTime(internshipDuration); // (实习必填,默认1个月)仅实习: 实习时长 1~12 单位:(月)
resumeJobDto.setWorkDate(workingDays); // (实习必填,默认1天)仅实习: 每周到岗天数 1~7 单位:(天)
// 招聘职位基本描述
resumeJobDto.setJobname(positionName); // 配置职位名称
resumeJobDto.setJobdesc(positionDuty); // 配置职位描述
resumeJobDto.setJobType(jobCategory); // 配置职位类别
// 招聘职位条件
//resumeJobDto.setKeywordStr(Lists.newArrayList("java")); // 职位关键词
resumeJobDto.setExperience(experienceValue); // (必填,默认不限)经验要求(实习无此字段) -1:不限 1:一年以下 2:1~3年 3:3~5年 5:5~10年 6:10年以上
resumeJobDto.setEducation(educationValue); // (必填,默认不限)学历要求 -1:不限 1:初中及以下 2:高中 3:中专/中技 4:大专 5:本科 6:硕士 7:MBA/EMBA 8:博士
//薪资福利
resumeJobDto.setExpectSalaryStart(salaryMin); // (必填)薪资范围开始 单位:(社招/校招: 千元/月 实习:元/日)
resumeJobDto.setExpectSalaryStop(salaryMax); // (必填)薪资范围截止 单位:(社招/校招: 千元/月 实习:元/日)
resumeJobDto.setExpectSalaryMonth(xcyfs); // (必填,默认12个月)薪资月份数(实习无此字段) 12～24
// (必填)要发布的渠道（平台）Id
List<Integer> platformIds = matchPlatform(Convert.toStr(map.get("dsfqd")));
resumeJobDto.setPlatformIds(platformIds);
// 简历匹配度设置
resumeJobDto.setMappingageStart(-1); // (必填,默认不限)匹配年龄age开始 -1:不限
resumeJobDto.setMappingageStop(-1);// (必填,默认不限)匹配年龄age开始 -1:不限
resumeJobDto.setMappingSex(-1);// (必填,默认不限)匹配性别 -1:不限 0:女 1:男
resumeJobDto.setMappingeducationStr(Collections.singletonList(-1));// (必填,默认不限)匹配学历 -1:不限 1:初中及以下 2:高中 3:中专/中技 4:大专 5:本科 6:硕士 7:MBA/EMBA 8:博士
resumeJobDto.setMappingexperienceStr(Collections.singletonList(-1));// (必填,默认不限)匹配经验 -1:不限 1:1年内 2:1~3年 3:3~5年 4:5~10年 5:10年以上
// resumeJobDto.setMappingKeywordStr(Lists.newArrayList()); // 匹配关键词内容
resumeJobDto.setMappingStatus(1); // (必填,默认任一命中)匹配模式 1:任一命中 2:全部命中
return resumeJobDto;
}
/**
* 将字符串形式的时间转换为长整型时间戳
*
* @param timeString 字符串形式的时间
* @return 长整型时间戳
*/
private static long stringTurnLong(String timeString) {
try {
SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd");
Date date = dateFormat.parse(timeString);
return date.getTime();
} catch (ParseException e) {
//e.printStackTrace();
new BaseBean().writeLog(e);
}
return 0;
}
/**
* 匹配三方发布平台
*
* @param platformIds 发布平台ids
* @return 发布平台
*/
private static List<Integer> matchPlatform(String platformIds) {
String[] split = platformIds.split(",");
List<Integer> platformIdList = new ArrayList<>();
for (String platformId : split) {
if (platformId == null) {
continue;
}
PositionThirdChannelEnum channelEnum = PositionThirdChannelEnum.getEnum(platformId);
switch (channelEnum) {
case BOSS:
platformIdList.add(ResumePlatform.BOSSZHIPIN);
break;
case LIE_PIN:
platformIdList.add(ResumePlatform.LIEPIN);
break;
case LA_GOU:
platformIdList.add(ResumePlatform.LAGO);
break;
case D51_JOB:
platformIdList.add(ResumePlatform.QIANCHENGWUYOU);
break;
case ZHI_LIAN:
platformIdList.add(ResumePlatform.ZHILIANZHAOPIN);
break;
default:
break;
}
}
return platformIdList;
}
public static boolean checkAvailable(ERPAResumeSDKClient client) {
HttpClientUtils.setTimeout(10000);//默认10秒
if (client == null || !client.available()) {
new BaseBean().writeLog("checkAvailable！client=" + JSON.toJSONString(client));
return false;
} else {
return true;
}
}
}