From c0bc040bd3ccf8a484478e4770cb5c3bc6dda3fb Mon Sep 17 00:00:00 2001 From: howec <> Date: Thu, 19 Oct 2023 17:02:02 +0800 Subject: [PATCH] =?UTF-8?q?=E6=99=BA=E8=81=94=E6=8B=9B=E8=81=98=E6=A0=A1?= =?UTF-8?q?=E6=8B=9B=E5=AF=B9=E6=8E=A5?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/com/weaver/sxjg/esb/EsbRpcPositionZhilian.java | 28 +++++++++---- .../java/com/weaver/sxjg/esb/EsbRpcPositionZhilianSz.java | 34 +++++++++++---- .../src/main/java/com/weaver/sxjg/util/SxjgUtil.java | 41 +++++++++++++------ 3 files changed, 74 insertions(+), 29 deletions(-) diff --git a/陕建智联对接和短信对接源码/src/main/java/com/weaver/sxjg/esb/EsbRpcPositionZhilian.java b/陕建智联对接和短信对接源码/src/main/java/com/weaver/sxjg/esb/EsbRpcPositionZhilian.java index 1a17c58..5b4947f 100644 --- a/陕建智联对接和短信对接源码/src/main/java/com/weaver/sxjg/esb/EsbRpcPositionZhilian.java +++ b/陕建智联对接和短信对接源码/src/main/java/com/weaver/sxjg/esb/EsbRpcPositionZhilian.java @@ -103,7 +103,10 @@ public class EsbRpcPositionZhilian implements EsbRpcRemoteInterface { //1更新字典 if("1".equals(operate_flag)) { log.error("定时更新字典启动：>>>>>>>>>>>>>>>>>>>>>>"); - updateRefreshDict(params,jdbcTemplate,"0000"); + Thread t = new Thread(() -> { + updateRefreshDict(params,jdbcTemplate,"0000"); + }); + t.start(); return SxjgUtil.ok(); } //2 岗位新增,编辑，删除 @@ -113,7 +116,7 @@ public class EsbRpcPositionZhilian implements EsbRpcRemoteInterface { return SxjgUtil.ok(); }catch (Exception e){ e.printStackTrace(); - return SxjgUtil.err(e.getMessage()); + throw new RuntimeException(e.getMessage()); } } //3 简历获取 @@ -132,7 +135,7 @@ public class EsbRpcPositionZhilian implements EsbRpcRemoteInterface { publishjob(params,jdbcTemplate); return SxjgUtil.ok(); }catch (Exception e){ - return SxjgUtil.err(e.getMessage()); + throw new RuntimeException(e.getMessage()); } } //refresh token 定时 @@ -146,10 +149,10 @@ public class EsbRpcPositionZhilian implements EsbRpcRemoteInterface { downjob(params,jdbcTemplate); return SxjgUtil.ok(); }catch (Exception e){ - return SxjgUtil.err(e.getMessage()); + throw new RuntimeException(e.getMessage()); } } else { - return SxjgUtil.err("配置不正确，请检查参数：operate_flag"); + throw new RuntimeException("配置不对，请联系管理员"); } } @@ -290,15 +293,21 @@ public class EsbRpcPositionZhilian implements EsbRpcRemoteInterface { if(city.contains("市")) { city= city.split("市")[0]; } + String salary_type = (String)params.get("salary_type");//薪酬范围 String jobAddress = (String)params.get("jobAddress");//工作地址 + boolean salaryNegotiable = false; + if("面议".equals(salary_type)) { + salaryNegotiable = true; + }else { + salaryNegotiable = false; + } BigDecimal maxSalary = new BigDecimal("2"); BigDecimal minSalary = new BigDecimal("1.5"); - boolean salaryNegotiable = false; try{ maxSalary = new BigDecimal((String)params.get("maxSalary"));//最大月薪 minSalary = new BigDecimal((String)params.get("minSalary"));//最小月薪 }catch (Exception e){ - salaryNegotiable = true; + } String quantity1 = (String)params.get("quantity");//招聘人数 int quantity = Double.valueOf(quantity1).intValue(); @@ -307,7 +316,10 @@ public class EsbRpcPositionZhilian implements EsbRpcRemoteInterface { String jobDescription = (String)params.get("jobDescription");//职位描述 //转换智联 int jobNature1 = "实习".equals(jobNature) ? 4 : 2; - long cityId = SxjgUtil.getCityId(jdbcTemplate,city); + + Map cityall = SxjgUtil.getCityId(jdbcTemplate,city); + long cityId = cityall.get("code"); + long shengid = cityall.get("parentCode"); long maxSalary1 =maxSalary.multiply(new BigDecimal(1000)).longValue(); long minSalary1 =minSalary.multiply(new BigDecimal(1000)).longValue(); if((minSalary1*2) < maxSalary1) { diff --git a/陕建智联对接和短信对接源码/src/main/java/com/weaver/sxjg/esb/EsbRpcPositionZhilianSz.java b/陕建智联对接和短信对接源码/src/main/java/com/weaver/sxjg/esb/EsbRpcPositionZhilianSz.java index 7f22fd6..f0cee37 100644 --- a/陕建智联对接和短信对接源码/src/main/java/com/weaver/sxjg/esb/EsbRpcPositionZhilianSz.java +++ b/陕建智联对接和短信对接源码/src/main/java/com/weaver/sxjg/esb/EsbRpcPositionZhilianSz.java @@ -87,8 +87,7 @@ public class EsbRpcPositionZhilianSz implements EsbRpcRemoteInterface { jobAdd(params,jdbcTemplate); return SxjgUtil.ok(); }catch (Exception e){ - e.printStackTrace(); - return SxjgUtil.err(e.getMessage()); + throw new RuntimeException(e.getMessage()); } } //3 发布同步下线删除 @@ -97,7 +96,7 @@ public class EsbRpcPositionZhilianSz implements EsbRpcRemoteInterface { updateJob(params,jdbcTemplate); return SxjgUtil.ok(); }catch (Exception e){ - return SxjgUtil.err(e.getMessage()); + throw new RuntimeException(e.getMessage()); } } //4 简历获取 @@ -504,17 +503,26 @@ public class EsbRpcPositionZhilianSz implements EsbRpcRemoteInterface { } log.error("职位所属公司code对应智联code："+companyId); log.error("发布渠道："+qudao); - + String salary_type = (String)params.get("salary_type");//薪酬范围 + log.error("薪酬范围："+salary_type); + boolean isSalaryView; + if("面议".equals(salary_type)) { + isSalaryView = true; + }else { + isSalaryView = false; + } String jobTitle = (String)params.get("jobTitle");//职位名称 String quantity1 = (String)params.get("quantity");//招聘人数 int quantity = Double.valueOf(quantity1).intValue(); String education = (String)params.get("education");//最低学历 int education1 = SxjgUtil.getEducodesz(education); String city = (String)params.get("city");//工作城市 + String aname=(String)params.get("aname");//工作省 if(city.contains("市")) { city= city.split("市")[0]; } long cityId = SxjgUtil.getCityIdsz(jdbcTemplate,city); + long shengid = SxjgUtil.getPrivinceIdsz(jdbcTemplate,aname); String jobAddress = (String)params.get("jobAddress");//工作地址 String jobType = SxjgUtil.getTypeList((String)params.get("jobType"),"/"); String workAge = (String)params.get("workAge");//工作年限 @@ -522,20 +530,27 @@ public class EsbRpcPositionZhilianSz implements EsbRpcRemoteInterface { String jobNature = (String)params.get("jobNature");//职位属性 //转换智联 int jobNature1 = "实习".equals(jobNature) ? 4 : 2; - boolean salaryNegotiable = false; - BigDecimal maxSalary = new BigDecimal("8"); + BigDecimal maxSalary = new BigDecimal("3"); BigDecimal minSalary = new BigDecimal("5"); + String monthsalary1 = ""; + if(params.get("monthsalary")!=null) { + monthsalary1 = (String)params.get("monthsalary");//月数 + if(monthsalary1.length()==0) { + monthsalary1 = "12"; + } + } try{ maxSalary = new BigDecimal((String)params.get("maxSalary"));//最大月薪 minSalary = new BigDecimal((String)params.get("minSalary"));//最小月薪 }catch (Exception e){ - salaryNegotiable = true; + maxSalary = new BigDecimal("15"); + minSalary = new BigDecimal("10"); } long maxSalary1 =maxSalary.multiply(new BigDecimal(1000)).longValue(); long minSalary1 =minSalary.multiply(new BigDecimal(1000)).longValue(); maxSalary1 = maxSalary1>210000l ? 210000l :maxSalary1; minSalary1 = minSalary1>210000l ? 210000l :minSalary1; - String monthsalary1 = (String)params.get("monthsalary");//招聘人数 + int monthsalary = Double.valueOf(monthsalary1).intValue(); monthsalary = monthsalary >22 ? 22 : monthsalary; monthsalary = monthsalary <12 ? 12 : monthsalary; @@ -549,13 +564,14 @@ public class EsbRpcPositionZhilianSz implements EsbRpcRemoteInterface { jsonObject.put("cityCode",cityId); jsonObject.put("address",jobAddress); jsonObject.put("positionType",jobType); - jsonObject.put("salaryNegotiable",salaryNegotiable); jsonObject.put("workYear",workAge1); jsonObject.put("employmentType",jobNature1); jsonObject.put("salaryMin",minSalary1); jsonObject.put("salaryMax",maxSalary1); jsonObject.put("salaryMonth",monthsalary); jsonObject.put("jobDescription",jobDescription); + jsonObject.put("provinceCode",shengid); + jsonObject.put("isSalaryView",isSalaryView); String rs = SxjgUtil.doJsonPostSz(this.getJobaddurl(),this.getAppid(),this.getAppReferer(),this.getToken(),jsonObject.toJSONString(),jdbcTemplate); if(SxjgUtil.isSuccessSz(rs)) { if(isAdd) { diff --git a/陕建智联对接和短信对接源码/src/main/java/com/weaver/sxjg/util/SxjgUtil.java b/陕建智联对接和短信对接源码/src/main/java/com/weaver/sxjg/util/SxjgUtil.java index d55ad46..5df906e 100644 --- a/陕建智联对接和短信对接源码/src/main/java/com/weaver/sxjg/util/SxjgUtil.java +++ b/陕建智联对接和短信对接源码/src/main/java/com/weaver/sxjg/util/SxjgUtil.java @@ -139,18 +139,23 @@ public class SxjgUtil { * 校招 * 根据城市名称获取城市code */ - public static long getCityId(JdbcTemplate jdbcTemplate,String name){ + public static Map getCityId(JdbcTemplate jdbcTemplate,String name){ + Map rs = new HashMap<>(); String sql = "select count(id) as sums from zhilian_zidian where cnName like '%"+name+"%' and type='REGIONS' and attribute in ('CITY','DISTRICT')"; Map map = jdbcTemplate.queryForMap(sql); long sums = (long)map.get("sums"); if(sums==0l) { - return 512l;//其他 + rs.put("code",512l); + rs.put("parentCode",0l); + return rs;//其他 } - sql = "select code from zhilian_zidian where cnName like '%"+name+"%' and type = 'REGIONS' and attribute in ('CITY','DISTRICT') limit 1"; + sql = "select code,parentCode from zhilian_zidian where cnName like '%"+name+"%' and type = 'REGIONS' and attribute in ('CITY','DISTRICT') limit 1"; map = jdbcTemplate.queryForMap(sql); String code = (String)map.get("code"); - long code1 = Long.parseLong(code); - return code1; + String parentCode = (String)map.get("parentCode"); + rs.put("code",Long.parseLong(code)); + rs.put("parentCode",Long.parseLong(parentCode)); + return rs; } /** @@ -171,6 +176,18 @@ public class SxjgUtil { return code1; } + /** + * 社招 + * 根据省名称获取省code + */ + public static long getPrivinceIdsz(JdbcTemplate jdbcTemplate,String name1){ + String sql = "select code from zhilian_zidiansz where name like '%"+name1+"%' and is_delete = '0' and type = 'province' limit 1"; + Map map = jdbcTemplate.queryForMap(sql); + String code = (String)map.get("code"); + long code1 = Long.parseLong(code); + return code1; + } + public static void updateToken(String at1,String rt1,JdbcTemplate jdbcTemplate,String orgCodes){ String sql = "select id from zhilian_token where orgcode = '"+orgCodes+"' limit 1"; Map map = jdbcTemplate.queryForMap(sql); @@ -368,27 +385,27 @@ public class SxjgUtil { */ public static int getWordExpCode(String name){ if("不限".equals(name)) { - return 0000; + return 0; } if("应届毕业生".equals(name)) { - return 0000; + return 0; } if("一年以内".equals(name)) { - return 0001; + return 1; } if("1~3年".equals(name)) { - return 0103; + return 103; } if("3~5年".equals(name)) { - return 0305; + return 305; } if("5~10年".equals(name)) { - return 0510; + return 510; } if("10年以上".equals(name)) { return 1099; } - return 0000; + return 0; } public static Map ok() {