智联招聘校招对接

e10dev/src/main/java/com/weaver/sxjg/config/EbDbDataSourceConfig.java

@@ -0,0 +1,149 @@
+package com.weaver.sxjg.config;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.boot.jdbc.DataSourceBuilder;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.stereotype.Component;
+
+import javax.sql.DataSource;
+
+
+@Configuration
+@Component
+public class EbDbDataSourceConfig {
+    private static final Logger log = LoggerFactory.getLogger(EbDbDataSourceConfig.class);
+    @Value("${spring.datasource.urlebdesign}")
+    private String url;
+    @Value("${spring.datasource.driver-class-name}")
+    private String driverClassName;
+    @Value("${spring.datasource.username}")
+    private String username;
+    @Value("${spring.datasource.password}")
+    private String password;
+
+    public DataSource dbDataSource() {
+        log.error("database:::::::::url"+url);
+        log.error("database:::::::::driverClassName"+driverClassName);
+        log.error("database:::::::::username"+username);
+        log.error("database:::::::::password"+password);
+        return DataSourceBuilder.create().driverClassName(this.driverClassName).username(this.username).password(this.password).url(this.url).build();
+    }
+
+    public EbDbDataSourceConfig() {
+    }
+
+    public String getUrl() {
+        return this.url;
+    }
+
+    public String getDriverClassName() {
+        return this.driverClassName;
+    }
+
+    public String getUsername() {
+        return this.username;
+    }
+
+    public String getPassword() {
+        return this.password;
+    }
+
+    public void setUrl(String url) {
+        this.url = url;
+    }
+
+    public void setDriverClassName(String driverClassName) {
+        this.driverClassName = driverClassName;
+    }
+
+    public void setUsername(String username) {
+        this.username = username;
+    }
+
+    public void setPassword(String password) {
+        this.password = password;
+    }
+
+    public boolean equals(Object o) {
+        if (o == this) {
+            return true;
+        } else if (!(o instanceof EbDbDataSourceConfig)) {
+            return false;
+        } else {
+            EbDbDataSourceConfig other = (EbDbDataSourceConfig)o;
+            if (!other.canEqual(this)) {
+                return false;
+            } else {
+                label59: {
+                    Object this$url = this.getUrl();
+                    Object other$url = other.getUrl();
+                    if (this$url == null) {
+                        if (other$url == null) {
+                            break label59;
+                        }
+                    } else if (this$url.equals(other$url)) {
+                        break label59;
+                    }
+
+                    return false;
+                }
+
+                Object this$driverClassName = this.getDriverClassName();
+                Object other$driverClassName = other.getDriverClassName();
+                if (this$driverClassName == null) {
+                    if (other$driverClassName != null) {
+                        return false;
+                    }
+                } else if (!this$driverClassName.equals(other$driverClassName)) {
+                    return false;
+                }
+
+                Object this$username = this.getUsername();
+                Object other$username = other.getUsername();
+                if (this$username == null) {
+                    if (other$username != null) {
+                        return false;
+                    }
+                } else if (!this$username.equals(other$username)) {
+                    return false;
+                }
+
+                Object this$password = this.getPassword();
+                Object other$password = other.getPassword();
+                if (this$password == null) {
+                    if (other$password != null) {
+                        return false;
+                    }
+                } else if (!this$password.equals(other$password)) {
+                    return false;
+                }
+
+                return true;
+            }
+        }
+    }
+
+    protected boolean canEqual(Object other) {
+        return other instanceof EbDbDataSourceConfig;
+    }
+
+    public int hashCode() {
+        boolean PRIME = true;
+        int result = 1;
+        Object $url = this.getUrl();
+        result = result * 59 + ($url == null ? 43 : $url.hashCode());
+        Object $driverClassName = this.getDriverClassName();
+        result = result * 59 + ($driverClassName == null ? 43 : $driverClassName.hashCode());
+        Object $username = this.getUsername();
+        result = result * 59 + ($username == null ? 43 : $username.hashCode());
+        Object $password = this.getPassword();
+        result = result * 59 + ($password == null ? 43 : $password.hashCode());
+        return result;
+    }
+
+    public String toString() {
+        return "EbDbDataSourceConfig(url=" + this.getUrl() + ", driverClassName=" + this.getDriverClassName() + ", username=" + this.getUsername() + ", password=" + this.getPassword() + ")";
+    }
+}

e10dev/src/main/java/com/weaver/sxjg/esb/EsbRpcPositionZhilian.java

@@ -0,0 +1,552 @@
+package com.weaver.sxjg.esb;
+
+import cn.hutool.core.collection.CollectionUtil;
+import com.alibaba.fastjson.JSONArray;
+import com.alibaba.fastjson.JSONObject;
+import com.weaver.ebuilder.common.exception.BusinessException;
+import com.weaver.esb.api.rpc.EsbRpcRemoteInterface;
+import com.weaver.sxjg.config.EbDbDataSourceConfig;
+import com.weaver.sxjg.util.SxjgUtil;
+import org.apache.commons.configuration.ConfigurationException;
+import org.apache.commons.configuration.PropertiesConfiguration;
+import org.apache.commons.httpclient.NameValuePair;
+import org.apache.commons.httpclient.methods.PostMethod;
+import org.junit.Test;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.jdbc.DataSourceBuilder;
+import org.springframework.jdbc.core.JdbcTemplate;
+import org.springframework.stereotype.Service;
+
+import javax.sql.DataSource;
+import java.math.BigDecimal;
+import java.util.Date;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * @author liuhao
+ * @use:  职位-新增，修改，发布，下线  接口对接智联招聘
+ * @date
+ */
+@Service("esbRpcPositionZhilian_sj")
+public class EsbRpcPositionZhilian implements EsbRpcRemoteInterface {
+
+    private static final Logger log = LoggerFactory.getLogger(EsbRpcPositionZhilian.class);
+    private String zlTokenUrl;
+    private String clientId;
+    private String clientSecret;
+    private String dicturl;
+    private String jobaddurl;
+    private String jobupdateurl;
+    private String jobpublishurl;
+    private String joboffline;
+    private String wslburl;
+    private String wslbxqurl;
+    @Autowired
+    public EbDbDataSourceConfig ebDbDataSourceConfig;
+
+    public EsbRpcPositionZhilian() {
+        PropertiesConfiguration p = null;
+        try {
+            p = new PropertiesConfiguration();
+            p.setEncoding("utf-8");
+            p.setFileName("config/sxjg.properties");
+            p.load();
+            this.setClientId(p.getString("sxjg.client_id"));
+            this.setClientSecret(p.getString("sxjg.client_secret"));
+            this.setZlTokenUrl(p.getString("sxjg.refreshtokenurl"));
+            this.setDicturl(p.getString("sxjg.dicturl"));
+            this.setJobaddurl(p.getString("sxjg.jobadd"));
+            this.setJobupdateurl(p.getString("sxjg.jobupdate"));
+            this.setJobpublishurl(p.getString("sxjg.jobpublish"));
+            this.setJoboffline(p.getString("sxjg.joboffline"));
+            this.setWslburl(p.getString("sxjg.wslburl"));
+            this.setWslbxqurl(p.getString("sxjg.wslbxqurl"));
+        }catch (ConfigurationException e) {
+            throw new BusinessException("获取sxjg.properties配置文件失败，", e);
+        }
+    }
+
+    @Override
+    public Map<String, Object> execute(Map<String, Object> params) {
+        String operate_flag = (String)params.get("operate_flag");
+        //1更新字典
+        if("1".equals(operate_flag)) {
+            log.error("定时更新字典启动：>>>>>>>>>>>>>>>>>>>>>>");
+            JdbcTemplate jdbcTemplate = new JdbcTemplate(ebDbDataSourceConfig.dbDataSource());
+            updateRefreshDict(params,jdbcTemplate,"0000");
+            return SxjgUtil.ok();
+        }
+        //2 岗位新增,编辑，删除
+        else if("2".equals(operate_flag)) {
+            JdbcTemplate jdbcTemplate = new JdbcTemplate(ebDbDataSourceConfig.dbDataSource());
+            try {
+                jobAdd(params,jdbcTemplate);
+                return SxjgUtil.ok();
+            }catch (Exception e){
+                e.printStackTrace();
+                return SxjgUtil.err(e.getMessage());
+            }
+        }
+        //3 简历获取
+        else if("3".equals(operate_flag)) {
+            log.error("简历获取：>>>>>>>>>>>>>>>>>>>>>>");
+            JdbcTemplate jdbcTemplate = new JdbcTemplate(ebDbDataSourceConfig.dbDataSource());
+            synchronJobTitle(jdbcTemplate);
+            return SxjgUtil.ok();
+        }
+        //4 岗位发布
+        else if("4".equals(operate_flag)) {
+            log.error("职位发布：>>>>>>>>>>>>>>>>>>>>>>");
+            JdbcTemplate jdbcTemplate = new JdbcTemplate(ebDbDataSourceConfig.dbDataSource());
+            try{
+                publishjob(params,jdbcTemplate);
+                return SxjgUtil.ok();
+            }catch (Exception e){
+                return SxjgUtil.err(e.getMessage());
+            }
+        }
+        //refresh token  定时
+        else if("5".equals(operate_flag)) {
+            log.error("定时刷新token启动：>>>>>>>>>>>>>>>>>>>>>>");
+            JdbcTemplate jdbcTemplate = new JdbcTemplate(ebDbDataSourceConfig.dbDataSource());
+            refreshToken(jdbcTemplate,"0000");
+            return SxjgUtil.ok();
+        }
+        else if("6".equals(operate_flag)) {//职位下线
+            JdbcTemplate jdbcTemplate = new JdbcTemplate(ebDbDataSourceConfig.dbDataSource());
+            try{
+                downjob(params,jdbcTemplate);
+                return SxjgUtil.ok();
+            }catch (Exception e){
+                return SxjgUtil.err(e.getMessage());
+            }
+        }
+        else {
+            return SxjgUtil.err("配置不正确，请检查参数：operate_flag");
+        }
+    }
+
+    private void synchronJobTitle(JdbcTemplate jdbcTemplate){
+        List<Map<String,Object>> rs = SxjgUtil.getZlTblist(jdbcTemplate);
+        if(CollectionUtil.isNotEmpty(rs)) {
+           for(Map<String,Object> m : rs) {
+               BigDecimal id = (BigDecimal)m.get("id");
+               String jobNumber = (String)m.get("zlzwid");
+               String subcompany = (String)m.get("sub_company");
+               String companyId = SxjgUtil.getZlbh(subcompany,jdbcTemplate);
+               String jobsyctime = (String)m.get("jobsyctime");//上一次更新时间
+               Date preTimesql = SxjgUtil.getDateByTimestr(jobsyctime,"yyyy-MM-dd HH:mm:ss");
+               String preTimejk = SxjgUtil.getTimeStrByDate(preTimesql,"yyyy/MM/dd HH:mm");
+               Date now = new Date();
+               String nowTimejk = SxjgUtil.getTimeStrByDate(now,"yyyy/MM/dd HH:mm");
+               String nowTimeSql = SxjgUtil.getTimeStrByDate(now,"yyyy-MM-dd HH:mm:ss");
+               try{
+                   getWsList(jobNumber,companyId,preTimejk,nowTimejk,jdbcTemplate);//一批量 有任何一次失败，则不更新时间
+                   //更新该岗位的最后获取时间
+                   SxjgUtil.updateLastTime(id,nowTimeSql,jdbcTemplate);
+               }catch (Exception e){
+                    log.error("根据jobNumber"+jobNumber+"获取网申列表失败，失败原因："+e.getMessage());
+               }
+           }
+        }
+    }
+
+    private void downjob(Map<String, Object> params, JdbcTemplate jdbcTemplate) throws Exception{
+        String id = (String)params.get("id");
+        log.error("职位下线,职位id：>>>>>>>>>>>>>>>>>>>>>>"+id);
+        String jobNumber = SxjgUtil.getJobNumber(id,jdbcTemplate);
+        if(jobNumber.length()==0) {
+            log.error("当前职位id："+id+" 并未找到jobNumber，请先新增职位！");
+            throw new Exception("当前职位并未找到jobNumber！");
+        }
+        String orgCode = (String)params.get("orgcode");
+        String companyId = SxjgUtil.getZlbh(orgCode,jdbcTemplate);
+        long companyId1 = Long.parseLong(companyId);
+        if(companyId.length()==0){
+            throw new Exception("当前岗位所属组织并未配置，请联系管理员！");
+        }
+        JSONObject jsonObject = new JSONObject();
+        jsonObject.put("jobNumber",jobNumber);
+        jsonObject.put("companyId",companyId1);
+        String rs = SxjgUtil.doJsonPost(joboffline,this.getClientId(),jsonObject.toJSONString(),jdbcTemplate,"0000");
+        if(SxjgUtil.isSuccess(rs)) {
+            JSONObject r1 =SxjgUtil.getInterfaceData(rs);
+            SxjgUtil.updateStatus(id,jdbcTemplate,"2");
+        }else {
+            throw new Exception("职位下线失败："+rs);
+        }
+    }
+
+
+    private void publishjob(Map<String, Object> params, JdbcTemplate jdbcTemplate) throws Exception{
+        String id = (String)params.get("id");
+        String jobNumber = SxjgUtil.getJobNumber(id,jdbcTemplate);
+        if(jobNumber.length()==0) {
+            log.error("当前职位id："+id+" 并未找到jobNumber，请先新增职位！");
+           throw new Exception("当前职位并未找到jobNumber！");
+        }
+        String orgCode = (String)params.get("orgcode");
+        String companyId = SxjgUtil.getZlbh(orgCode,jdbcTemplate);
+        long companyId1 = Long.parseLong(companyId);
+        if(companyId.length()==0){
+            throw new Exception("当前岗位所属组织并未配置，请联系管理员！");
+        }
+        String qudao = (String)params.get("qudao");
+        if(!qudao.contains("智联招聘")) {
+            return;
+        }
+        JSONObject jsonObject = new JSONObject();
+        jsonObject.put("jobNumber",jobNumber);
+        jsonObject.put("intoReview",0);
+        jsonObject.put("companyId",companyId1);
+        String rs = SxjgUtil.doJsonPost(jobpublishurl,this.getClientId(),jsonObject.toJSONString(),jdbcTemplate,"0000");
+        if(SxjgUtil.isSuccess(rs)) {
+            SxjgUtil.updateStatus(id,jdbcTemplate,"1");
+        }else {
+            throw new Exception("职位发布失败："+rs);
+        }
+    }
+
+    /**
+     * isAdd 是新增 ，否更新
+     */
+    private void jobAdd(Map<String, Object> params, JdbcTemplate jdbcTemplate) throws Exception {
+        boolean isAdd = true;
+        Map<String, Object> res = new HashMap<>();
+        String id = (String)params.get("id");
+        String qudao = (String)params.get("qudao");
+        if(!qudao.contains("智联招聘")){
+            throw new Exception("没有勾选智联招聘，当前数据不走同步接口");
+        }
+        String orgCode = (String)params.get("orgcode");
+        log.error("职位id："+id);
+        log.error("职位所属公司code："+orgCode);
+        String companyId = SxjgUtil.getZlbh(orgCode,jdbcTemplate);
+        long companyId1 = Long.parseLong(companyId);
+        if(companyId.length()==0){
+            throw new Exception("当前岗位所属组织并未配置，请联系管理员！");
+        }
+
+        String jobNumber = SxjgUtil.getJobNumber(id,jdbcTemplate);
+        if(jobNumber.length()>0) {
+            isAdd = false;
+        }
+        log.error("职位所属公司code对应智联code："+companyId);
+        log.error("发布渠道："+qudao);
+        String jobNature = (String)params.get("jobNature");//职位属性
+        long jobType = SxjgUtil.getLastValuekey((String)params.get("jobType"),"/");
+        String jobTitle = (String)params.get("jobTitle");//职位名称
+        String city = (String)params.get("city");//工作城市
+        if(city.contains("市")) {
+            city= city.split("市")[0];
+        }
+        String jobAddress = (String)params.get("jobAddress");//工作地址
+        BigDecimal maxSalary = new BigDecimal((String)params.get("maxSalary"));//最大月薪
+        BigDecimal minSalary = new BigDecimal((String)params.get("minSalary"));//最小月薪
+        String quantity1 = (String)params.get("quantity");//招聘人数
+        int quantity = Double.valueOf(quantity1).intValue();
+        String education = (String)params.get("education");//最低学历
+        String workAge = (String)params.get("workAge");//工作年限
+        String jobDescription = (String)params.get("jobDescription");//职位描述
+        //转换智联
+        int jobNature1 = "实习".equals(jobNature) ? 4 : 2;
+        long cityId = SxjgUtil.getCityId(jdbcTemplate,city);
+        long maxSalary1 =maxSalary.multiply(new BigDecimal(1000)).longValue();
+        long minSalary1 =minSalary.multiply(new BigDecimal(1000)).longValue();
+        if((minSalary1*2) < maxSalary1) {
+            log.error("智联岗位新增：最大薪资不能超过最小薪资的2倍");
+            throw new Exception("智联岗位新增：最大薪资不能超过最小薪资的2倍");
+        }
+        if(jobDescription.length()<10) {
+            throw new Exception("智联岗位新增：岗位描述不能小于十个字");
+        }
+        if(minSalary1<1000l){
+            log.error("智联岗位新增：最低薪资不能小于1000");
+            throw new Exception("智联岗位新增：最低薪资不能小于1000");
+        }
+        int education1 = SxjgUtil.getEducode(education);
+        int workAge1 = SxjgUtil.getWordExpCode(workAge);
+        JSONObject jsonObject = new JSONObject();
+        if(!isAdd){
+            jsonObject.put("jobNumber",jobNumber);
+        }
+        jsonObject.put("jobNature",jobNature1);
+        jsonObject.put("jobType",jobType);
+        jsonObject.put("jobTitle",jobTitle);
+        jsonObject.put("cityId",cityId);
+        jsonObject.put("jobAddress",jobAddress);
+        jsonObject.put("maxSalary",maxSalary1);
+        jsonObject.put("companyId",companyId1);
+        jsonObject.put("minSalary",minSalary1);
+        jsonObject.put("quantity",quantity);
+        jsonObject.put("education",education1);
+        jsonObject.put("workAge",workAge1);
+        jsonObject.put("jobDescription",jobDescription);
+        String url1 = isAdd ? this.getJobaddurl() : this.getJobupdateurl();
+        String rs = SxjgUtil.doJsonPost(url1,this.getClientId(),jsonObject.toJSONString(),jdbcTemplate,"0000");
+        if(SxjgUtil.isSuccess(rs)) {
+            if(isAdd) {
+                JSONObject r1 =SxjgUtil.getInterfaceData(rs);
+                SxjgUtil.updateZhilianId(id,r1.getString("jobNumber"),jdbcTemplate);
+            }
+        }else {
+            throw new Exception("职位新增接口异常！");
+        }
+    }
+
+    /**
+     * 更新token，并且更新字典
+     */
+    private Map<String, Object> updateRefreshDict(Map<String, Object> params,JdbcTemplate jdbcTemplate,String orgcode) {
+        Map<String, Object> res = new HashMap<>();
+        res.put("result",false);
+        res.put("description","");
+        JSONObject json1 = new JSONObject();
+        json1.put("dicType","REGIONS");
+        json1.put("page",1);
+        String s1 = SxjgUtil.doJsonPost(getDicturl(),getClientId(),json1.toJSONString(),jdbcTemplate,orgcode);
+        JSONObject rs1 = JSONObject.parseObject(s1);
+        JSONObject r11 = rs1.getJSONObject("data");
+        int total = r11.getInteger("total");
+        int yeshu = 0;
+        if(total%100 == 0) {
+            yeshu = total/100;
+        }else {
+            yeshu = total/100;
+            yeshu = yeshu+1;
+        }
+        for(int j = 1;j<=yeshu;j++) {
+            JSONObject json = new JSONObject();
+            json.put("dicType","REGIONS");
+            json.put("page",j);
+            String s = SxjgUtil.doJsonPost(getDicturl(),getClientId(),json.toJSONString(),jdbcTemplate,"0000");
+            JSONObject rs = JSONObject.parseObject(s);
+            JSONObject r1 = rs.getJSONObject("data");
+            JSONArray r2 = r1.getJSONArray("dataList");
+            for(int i = 0; i<r2.size();i++) {
+                JSONObject r3 = r2.getJSONObject(i);
+                String attribute = r3.getString("attribute");
+                String cnName = r3.getString("cnName");
+                String code = r3.getString("code");
+                String enName = r3.getString("enName");
+                String parentCode = r3.getString("parentCode");
+                String pyName = r3.getString("pyName");
+                String querysql = "select count(id) as sums from zhilian_zidian where code = "+code;
+                Map<String,Object> rs0 = jdbcTemplate.queryForMap(querysql);
+                long v = (Long) rs0.get("sums");
+                if(v==0l) {
+                    String updateSql = "insert into zhilian_zidian(code,cnName,enName,parentCode,pyName," +
+                            "attribute,type)values('"+code+"','"+cnName+"','"+enName+"','"+parentCode+"','"+pyName+"','"+attribute+"','"+"REGIONS"+"')";
+                    jdbcTemplate.execute(updateSql);
+                }
+            }
+            res.put("result",true);
+        }
+        return res;
+    }
+
+    /**
+     * use:获取网申列表，自行分页，从第一页开始，每次获取100条
+     */
+    private void getWsList(String jobNumber,String companyId,String starttime,String endtime,JdbcTemplate jdbcTemplate) throws Exception{
+        JSONObject json1 = new JSONObject();
+        json1.put("page",1);
+        json1.put("pageSize",100);
+        json1.put("dateStart",starttime);
+        json1.put("dateEnd",endtime);
+        json1.put("jobNumber",jobNumber);
+        json1.put("companyId",companyId);
+        String s1 = SxjgUtil.doJsonPost(getWslburl(),getClientId(),json1.toJSONString(),jdbcTemplate,"0000");
+        JSONArray jsonArray = new JSONArray();
+        if(SxjgUtil.isSuccess(s1)) {
+            JSONObject data = SxjgUtil.getInterfaceData(s1);
+            int total = data.getInteger("total");
+            if(total == 0){
+                return;
+            }
+            int yeshu = 0;
+            if(total%100 == 0) {
+                yeshu = total/100;
+            }else {
+                yeshu = total/100;
+                yeshu = yeshu+1;
+            }
+            //进入分页
+            for(int j = 1;j<=yeshu;j++) {
+                if(yeshu == 1) {
+                    jsonArray = data.getJSONArray("dataList");
+                    dealJsonArrayGetDetail(jsonArray,companyId,jobNumber,jdbcTemplate);
+                    continue;
+                }
+                json1 = new JSONObject();
+                json1.put("page",j);
+                json1.put("pageSize",100);
+                json1.put("dateStart",starttime);
+                json1.put("dateEnd",endtime);
+                json1.put("jobNumber",jobNumber);
+                json1.put("companyId",companyId);
+                s1 = SxjgUtil.doJsonPost(getWslburl(),getClientId(),json1.toJSONString(),jdbcTemplate,"0000");
+                if(SxjgUtil.isSuccess(s1)) {
+                    data = SxjgUtil.getInterfaceData(s1);
+                    jsonArray = data.getJSONArray("dataList");
+                    dealJsonArrayGetDetail(jsonArray,companyId,jobNumber,jdbcTemplate);
+                }
+            }
+        }else {
+            throw new Exception("获取网申列表详情失败，失败原因看日志！");
+        }
+    }
+
+    /**
+     * 获取到时间段内的简历
+     */
+    public void dealJsonArrayGetDetail(JSONArray jsonArray,String companyid,String jobNumber,JdbcTemplate jdbcTemplate) throws Exception{
+        for(int i = 0; i < jsonArray.size();i++) {
+            JSONObject jsonObject = jsonArray.getJSONObject(i);
+            String jobResumeId = jsonObject.getString("jobResumeId");
+            JSONObject json1 = new JSONObject();
+            json1.put("jobResumeId",jobResumeId);
+            json1.put("companyId",companyid);
+            String s1 = SxjgUtil.doJsonPost(getWslbxqurl(),getClientId(),json1.toJSONString(),jdbcTemplate,"0000");
+            if(SxjgUtil.isSuccess(s1)) {
+                //处理批次
+                if(!SxjgUtil.existPc(jobResumeId,jobNumber,jdbcTemplate)) {
+                    //成功录入批次后
+                    // TODO: 2023/9/15 需要调用批次录用，成功后处理
+                    String pcid = "";
+                    //录入中间表，将已经成功同步的批次记录  记录批次编号，简历编号（智联）
+                    SxjgUtil.insertSyn(jobResumeId,pcid,jobNumber,jdbcTemplate);
+                }
+            }else {
+                throw new Exception("获取简历详情失败！具体明细请看日志");
+            }
+        }
+    }
+
+    @Test
+//   public void test1(){
+//        DataSource db = DataSourceBuilder.create().driverClassName("com.mysql.cj.jdbc.Driver").username("ecology").password("uxJhLJn4%NpWxujAYyKsTpxP").url("jdbc:mysql://10.70.11.12:3306/ec_ebuilder_designer?characterEncoding=utf8&useSSL=false&autoReconnect=true&failOverReadOnly=false&serverTimezone=Asia/Shanghai&allowPublicKeyRetrieval=true&allowMultiQueries=true").build();
+//        JdbcTemplate jdbcTemplate = new JdbcTemplate(db);
+//        refreshToken(jdbcTemplate,"0000");
+//   }
+
+    private boolean refreshToken(JdbcTemplate jdbcTemplate,String orgcodes) {
+        boolean flag = false;
+        try {
+            String postURL;
+            PostMethod postMethod = null;
+            postMethod = new PostMethod(getZlTokenUrl());
+            System.out.println(getZlTokenUrl());
+            postMethod.setRequestHeader("Content-Type", "application/x-www-form-urlencoded;charset=utf-8");
+            NameValuePair[] data = {
+                    new NameValuePair("client_id",getClientId()),
+                    new NameValuePair("client_secret",getClientSecret()),
+                    new NameValuePair("grant_type","refresh_token"),
+                    new NameValuePair("refresh_token",SxjgUtil.getRt(jdbcTemplate,orgcodes))
+            };
+
+            postMethod.setRequestBody(data);
+
+            org.apache.commons.httpclient.HttpClient httpClient = new org.apache.commons.httpclient.HttpClient();
+            int response = httpClient.executeMethod(postMethod); // 执行POST方法
+            String result = postMethod.getResponseBodyAsString() ;
+            System.out.println(result);
+//            log.error("调用智联刷新token接口，返回值：>>>>>>>>>>>>>>>>>>>>>>"+result);
+            Map<String,String> rs1 = SxjgUtil.parseXmlToToken(result);
+            SxjgUtil.updateToken(rs1.get("at"),rs1.get("rt"),jdbcTemplate,orgcodes);
+            flag = true;
+        } catch (Exception e) {
+            e.printStackTrace();
+            throw new RuntimeException(e.getMessage());
+        }
+        return flag;
+    }
+
+    /**
+     * 获取字典并更新数据库
+     */
+    public boolean getDictUp() {
+       return true;
+    }
+    public void setZlTokenUrl(String zlTokenUrl) {
+        this.zlTokenUrl = zlTokenUrl;
+    }
+
+    public String getClientId() {
+        return clientId;
+    }
+
+    public void setClientId(String clientId) {
+        this.clientId = clientId;
+    }
+
+    public String getClientSecret() {
+        return clientSecret;
+    }
+
+    public void setClientSecret(String clientSecret) {
+        this.clientSecret = clientSecret;
+    }
+    public String getZlTokenUrl() {
+        return zlTokenUrl;
+    }
+
+    public String getDicturl() {
+        return dicturl;
+    }
+
+    public void setDicturl(String dicturl) {
+        this.dicturl = dicturl;
+    }
+
+    public String getJobaddurl() {
+        return jobaddurl;
+    }
+
+    public void setJobaddurl(String jobaddurl) {
+        this.jobaddurl = jobaddurl;
+    }
+    public String getJobupdateurl() {
+        return jobupdateurl;
+    }
+
+    public void setJobupdateurl(String jobupdateurl) {
+        this.jobupdateurl = jobupdateurl;
+    }
+
+    public String getJobpublishurl() {
+        return jobpublishurl;
+    }
+
+    public void setJobpublishurl(String jobpublishurl) {
+        this.jobpublishurl = jobpublishurl;
+    }
+
+    public String getJoboffline() {
+        return joboffline;
+    }
+
+    public void setJoboffline(String joboffline) {
+        this.joboffline = joboffline;
+    }
+
+    public String getWslburl() {
+        return wslburl;
+    }
+
+    public void setWslburl(String wslburl) {
+        this.wslburl = wslburl;
+    }
+
+    public String getWslbxqurl() {
+        return wslbxqurl;
+    }
+
+    public void setWslbxqurl(String wslbxqurl) {
+        this.wslbxqurl = wslbxqurl;
+    }
+}

e10dev/src/main/java/com/weaver/sxjg/util/SxjgUtil.java

@@ -0,0 +1,334 @@
+package com.weaver.sxjg.util;
+
+import com.alibaba.fastjson.JSONObject;
+import com.weaver.sxjg.config.EbDbDataSourceConfig;
+import org.apache.http.HttpResponse;
+import org.apache.http.client.methods.HttpPost;
+import org.apache.http.entity.StringEntity;
+import org.apache.http.impl.client.CloseableHttpClient;
+import org.apache.http.impl.client.HttpClients;
+import org.dom4j.Document;
+import org.dom4j.DocumentException;
+import org.dom4j.DocumentHelper;
+import org.dom4j.Element;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.jdbc.core.JdbcTemplate;
+
+import javax.crypto.*;
+import javax.crypto.spec.SecretKeySpec;
+import java.io.*;
+import java.math.BigDecimal;
+import java.security.InvalidKeyException;
+import java.security.NoSuchAlgorithmException;
+import java.text.SimpleDateFormat;
+import java.util.*;
+
+public class SxjgUtil {
+    private static final Logger log = LoggerFactory.getLogger(SxjgUtil.class);
+
+    @Autowired
+    public static EbDbDataSourceConfig ebDbDataSourceConfig;
+    /**
+     * 解析xml获取返回值
+     */
+    public static Map<String,String> parseXmlToToken(String xml) throws Exception {
+        Map<String,String>rs = new HashMap<>();
+        Document document = null;
+        try {
+            document = DocumentHelper.parseText(xml);
+        } catch (DocumentException e) {
+            e.printStackTrace();
+        }
+        //获取根节点A的下一个子节点B
+        Element B_element = document.getRootElement().element("data");
+        //可判断节点是否存在，存在再去获取节点内容
+        if (B_element != null) {
+            //根据B节点再获取其子节点C
+            Element rt = B_element.element("rt");
+            String rtstr = rt.getText();
+            Element at = B_element.element("at");
+            String atstr = at.getText();
+            rs.put("rt",rtstr);
+            rs.put("at",atstr);
+        } else {
+            throw new Exception("获取失败！");
+        }
+        return rs;
+    }
+
+    public  static String getToken(JdbcTemplate jdbcTemplate,String orgCodes){
+        String sql = "select at from zhilian_token where orgcode = '"+orgCodes+"'";
+        Map map = jdbcTemplate.queryForMap(sql);
+        String token = map.get("at").toString();
+        return token;
+    }
+
+    public  static String getRt(JdbcTemplate jdbcTemplate,String orgCodes){
+        String sql = "select rt from zhilian_token  where orgcode = '"+orgCodes+"'";
+        Map map = jdbcTemplate.queryForMap(sql);
+        String rt = map.get("rt").toString();
+        return rt;
+    }
+
+    public static long getCityId(JdbcTemplate jdbcTemplate,String name){
+        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;//其他
+        }
+        sql = "select code 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;
+    }
+
+    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);
+        String id = map.get("id").toString();
+        String updatesql = "update zhilian_token set rt='"+rt1+"',at = '"+at1+"' where id = "+id;
+        jdbcTemplate.execute(updatesql);
+    }
+
+    public static String doJsonPost(String url,String clientid,String json,JdbcTemplate jdbcTemplate,String orgcode) {
+        log.error("智联接口"+url+"，推送报文：>>>>>>>>>>>>>>>>>>>>>>"+json);
+        CloseableHttpClient client = HttpClients.createDefault();
+        HttpPost post = new HttpPost(url);
+        post.setHeader("Content-Type", "application/json;charset=utf-8");
+        post.setHeader("clientId", clientid);
+        post.setHeader("accessToken",SxjgUtil.getToken(jdbcTemplate,orgcode));
+        String result="";
+        try {
+            StringEntity s = new StringEntity(json,"UTF-8");
+            s.setContentEncoding("utf-8");
+            s.setContentType("application/json");
+            post.setEntity(s);
+            // 发送请求
+            HttpResponse httpResponse = client.execute(post);
+            // 获取响应输入流
+            InputStream inStream = httpResponse.getEntity().getContent();
+            BufferedReader reader = new BufferedReader(new InputStreamReader(
+                    inStream,"utf-8"));
+            StringBuilder strber = new StringBuilder();
+            String line;
+            while ((line = reader.readLine()) != null)
+                strber.append(line + "\n");
+            inStream.close();
+            result = strber.toString();
+            log.error("智联接口"+url+"，返回值：>>>>>>>>>>>>>>>>>>>>>>"+result);
+        } catch (Exception e) {
+            log.error("智联接口"+url+"，返回值：>>>>>>>>>>>>>>>>>>>>>>"+e.getMessage());
+            e.printStackTrace();
+        }
+        return result;
+    }
+
+    /**
+     * 智联字典 [{"attribute":"11","cnName":"博士","code":"1","enName":"Doctor","parentCode":"0","pyName":"boshi"},{"attribute":"8","cnName":"硕士","code":"3","enName":"Master","parentCode":"0","pyName":"shuoshi"},{"attribute":"7","cnName":"本科","code":"4","enName":"Bachelor","parentCode":"0","pyName":"benke"},{"attribute":"5","cnName":"大专","code":"5","enName":"Associate","parentCode":"0","pyName":"dazhuan"},{"attribute":"3","cnName":"高中","code":"7","enName":" Senior High","parentCode":"0","pyName":"gaozhong"},{"attribute":"1","cnName":"初中及以下","code":"9","enName":"junior high","parentCode":"0","pyName":"chuzhongjiyixia"},{"attribute":"9","cnName":"MBA/EMBA","code":"10","enName":"MBA/EMBA","parentCode":"0","pyName":"MBA/EMBA"},{"attribute":"4","cnName":"中专/中技","code":"12","enName":"Secondary Specialized/Skilled Workers Training","parentCode":"0","pyName":"zhongzhuan/zhongji"}]
+     */
+    public static int getEducode(String name) {
+        if("不限".equals(name)) {
+            return 9;//初中及以下
+        }
+        if("初中及以下".equals(name)) {
+            return 9;
+        }
+        if("中专/中技".equals(name)) {
+            return 12;
+        }
+        if("高中".equals(name)) {
+            return 7;
+        }
+        if("大专".equals(name)) {
+            return 5;
+        }
+        if("本科".equals(name)) {
+            return 4;
+        }
+        if("硕士".equals(name)) {
+            return 3;
+        }
+        if("博士".equals(name)) {
+            return 1;
+        }
+        if("MBA".equals(name)) {
+            return 10;
+        }
+        if("其他".equals(name)) {
+            return 9;
+        }
+        return 9;
+    }
+
+    /**
+     * 智联字典：[{"cnName":"无经验","code":"0000","enName":"No experience","parentCode":"0","pyName":"wujingyan"},{"cnName":"1年以下","code":"0001","enName":"Below 1 Year","parentCode":"0","pyName":"nianyixia"},{"cnName":"1-3年","code":"0103","enName":"1-3 Year","parentCode":"0","pyName":"nian"},{"cnName":"3-5年","code":"0305","enName":"3-5 Year","parentCode":"0","pyName":"nian"},{"cnName":"5-10年","code":"0510","enName":"5-10 Year","parentCode":"0","pyName":"nian"},{"cnName":"10年以上","code":"1099","enName":"Above 10 Year","parentCode":"0","pyName":"nianyishang"}]
+     */
+    public static int getWordExpCode(String name){
+        if("不限".equals(name)) {
+            return 0000;
+        }
+        if("应届毕业生".equals(name)) {
+            return 0000;
+        }
+        if("一年以内".equals(name)) {
+            return 0001;
+        }
+        if("1~3年".equals(name)) {
+            return 0103;
+        }
+        if("3~5年".equals(name)) {
+            return 0305;
+        }
+        if("5~10年".equals(name)) {
+            return 0510;
+        }
+        if("10年以上".equals(name)) {
+            return 1099;
+        }
+        return 0000;
+    }
+
+    public static Map<String, Object> ok() {
+        Map<String, Object> rs = new HashMap<>();
+        rs.put("result",true);
+        rs.put("description","");
+        return rs;
+    }
+
+    public static Map<String, Object> err(String msg) {
+        Map<String, Object> rs = new HashMap<>();
+        rs.put("result",false);
+        rs.put("description",msg);
+        return rs;
+    }
+
+    public static JSONObject getInterfaceData(String s) {
+        JSONObject r1 = JSONObject.parseObject(s);
+        return r1.getJSONObject("data");
+    }
+    public static  boolean isSuccess(String s) {
+        if(s.length()==0)return false;
+        JSONObject r1 = JSONObject.parseObject(s);
+        return "成功".equals(r1.getString("message")) ? true : false;
+    }
+
+    public static void updateZhilianId(String id1,String zwid1,JdbcTemplate jdbcTemplate) {
+        String sql = "update uf_rcrt_position set zlzwid = '"+zwid1+"' where id = "+id1;
+        jdbcTemplate.execute(sql);
+    }
+
+    public static long getLastValuekey(String str,String spe) {
+        String[] res = str.split(spe);
+        String rs = res[res.length-1];
+        return Long.parseLong(rs);
+    }
+
+    public static String getJobNumber(String id1, JdbcTemplate jdbcTemplate) {
+        String sql = "select zlzwid from uf_rcrt_position where id = "+id1;
+        try {
+            Map<String, Object> rs = jdbcTemplate.queryForMap(sql);
+            if(rs.get("zlzwid")==null) {
+                return "";
+            }
+            String jobNumber = (String)rs.get("zlzwid");
+            return jobNumber;
+        }catch (Exception e){
+            return "";
+        }
+    }
+
+    public static String getZlbh(String orgcode,JdbcTemplate jdbcTemplate) {
+        String sql = "select zlbh from uf_rcrt_zhilianzh where ssfb = '"+orgcode+"' and IS_DELETE = 0 and qyzt = '1' limit 1";
+        try {
+            Map<String, Object> rs = jdbcTemplate.queryForMap(sql);
+            String zlbh = (String)rs.get("zlbh");
+            return zlbh;
+        }catch (Exception e){
+            return "";
+        }
+    }
+
+    public static String decrypt(String secretKey, String content) {
+        byte[] code = Base64.getDecoder().decode(content);
+        try {
+            SecretKey decryptKey = new SecretKeySpec(Base64.getDecoder().decode(secretKey), "aes");
+            Cipher aesCipher = Cipher.getInstance("aes");
+            aesCipher.init(Cipher.DECRYPT_MODE, decryptKey);
+            byte[] result = aesCipher.doFinal(code);
+            return new String(result, "UTF-8");
+        } catch (NoSuchPaddingException | NoSuchAlgorithmException | InvalidKeyException |
+                 UnsupportedEncodingException | IllegalBlockSizeException | BadPaddingException e) {
+            throw new RuntimeException();
+        }
+    }
+
+    //1已发布  2已下架
+    public static void updateStatus(String id, JdbcTemplate jdbcTemplate,String status) {
+        String sql = "";
+        if("1".equals(status)) {//更新发布时间和状态
+            String nowTime = getTimeStrByDate(new Date(),"yyyy-MM-dd HH:mm:ss");
+            sql = "update uf_rcrt_position set jobsyctime = '"+nowTime+"',sfyfbzl = '"+status+"' where id = "+id;
+        }else {
+            sql = "update uf_rcrt_position set sfyfbzl = '"+status+"' where id = "+id;
+        }
+        jdbcTemplate.execute(sql);
+    }
+
+    public static List<Map<String,Object>> getZlTblist(JdbcTemplate jdbcTemplate) {
+        String sql = "select id,zlzwid,sub_company,jobsyctime from uf_rcrt_position where zlzwid is not null and sfyfbzl = '1'";
+        List<Map<String,Object>> rs = jdbcTemplate.queryForList(sql);
+        return rs;
+    }
+
+//    public static void main(String[] args) {
+//        DataSource db = DataSourceBuilder.create().driverClassName("com.mysql.cj.jdbc.Driver").username("ecology").password("uxJhLJn4%NpWxujAYyKsTpxP").url("jdbc:mysql://10.70.11.12:3306/ec_ebuilder_designer?characterEncoding=utf8&useSSL=false&autoReconnect=true&failOverReadOnly=false&serverTimezone=Asia/Shanghai&allowPublicKeyRetrieval=true&allowMultiQueries=true").build();
+//        JdbcTemplate jdbcTemplate = new JdbcTemplate(db);
+//        List<Map<String,Object>> rs = getZlTblist(jdbcTemplate);
+//        for(Map<String, Object> a1 : rs) {
+//            BigDecimal id = (BigDecimal)a1.get("id");
+//            String jobNumber  = (String)a1.get("zlzwid");
+//            String company = (String)a1.get("sub_company");
+//            System.out.println(id);
+//            System.out.println(jobNumber);
+//            System.out.println(company);
+//        }
+//    }
+
+    public static Date getDateByTimestr(String datatime,String format) {
+        SimpleDateFormat sdf2 = new SimpleDateFormat(format);
+        Date myDate2 = null;
+        try {
+            myDate2 = sdf2.parse(datatime);
+            return myDate2;
+        }catch (Exception e){
+            return null;
+        }
+    }
+
+    public static String getTimeStrByDate(Date date,String formate) {
+        SimpleDateFormat sdf2 = new SimpleDateFormat(formate);
+        String strDate2 = sdf2.format(date);
+        return strDate2;
+    }
+
+    public static void updateLastTime(BigDecimal id, String nowTimeSql,JdbcTemplate jdbcTemplate) {
+        String sql = "update uf_rcrt_position set jobsyctime = '"+nowTimeSql+"' where id = "+id;
+        jdbcTemplate.execute(sql);
+    }
+
+    public static void insertSyn(String jobResumeId1, String pcid1, String jobNumber1,JdbcTemplate jdbcTemplate) {
+        String sql = "INSERT INTO zhilian_jianlisyn(jobResumeId,pcid,jobNumber) VALUES ('"+jobResumeId1+"', '"+pcid1+"', '"+jobNumber1+"')";
+        jdbcTemplate.execute(sql);
+    }
+
+    public static boolean existPc(String jobResumeId,String jobNumber,JdbcTemplate jdbcTemplate) {
+        String sql = "select count(id) as nums from zhilian_jianlisyn where jobResumeId = '"+jobResumeId+"' and jobNumber = '"+jobNumber+"'";
+        Map<String,Object> rs = jdbcTemplate.queryForMap(sql);
+        long sums = (long)rs.get("nums");
+        return sums>0l;
+    }
+}