#WEAVER-SHUZHI-01# 人员离职和得力云集成

src/weaver/interfaces/shuzhi/cronjob/EcologyToDelicloudUtil.java

@@ -0,0 +1,249 @@
+package weaver.interfaces.shuzhi.cronjob;
+
+import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONObject;
+import org.apache.commons.collections.MapUtils;
+import org.apache.commons.lang3.StringUtils;
+import org.apache.http.Consts;
+import org.apache.http.HttpEntity;
+import org.apache.http.StatusLine;
+import org.apache.http.client.methods.CloseableHttpResponse;
+import org.apache.http.client.methods.HttpPost;
+import org.apache.http.client.methods.HttpRequestBase;
+import org.apache.http.config.Registry;
+import org.apache.http.config.RegistryBuilder;
+import org.apache.http.conn.socket.ConnectionSocketFactory;
+import org.apache.http.conn.socket.PlainConnectionSocketFactory;
+import org.apache.http.conn.ssl.NoopHostnameVerifier;
+import org.apache.http.conn.ssl.SSLConnectionSocketFactory;
+import org.apache.http.entity.StringEntity;
+import org.apache.http.impl.client.CloseableHttpClient;
+import org.apache.http.impl.client.HttpClients;
+import org.apache.http.impl.conn.PoolingHttpClientConnectionManager;
+import org.apache.http.util.EntityUtils;
+import weaver.conn.RecordSet;
+import weaver.general.BaseBean;
+import weaver.general.MD5;
+import weaver.general.Util;
+import javax.net.ssl.SSLContext;
+import javax.net.ssl.TrustManager;
+import javax.net.ssl.X509TrustManager;
+import java.io.IOException;
+import java.security.KeyManagementException;
+import java.security.NoSuchAlgorithmException;
+import java.security.cert.CertificateException;
+import java.util.Calendar;
+import java.util.HashMap;
+import java.util.Map;
+import java.util.Scanner;
+
+public class EcologyToDelicloudUtil {
+
+    public void updateEmployeeResign(String userid){
+
+        BaseBean bb = new BaseBean();
+        RecordSet rs = new RecordSet();
+
+        String path = "/v2.0/employee/delete";
+        String url = "http://v2-api.delicloud.com"+path;
+
+        try {
+            String workcode = "";
+            if(StringUtils.isNotBlank(userid)){
+                String sql = " select workcode from hrmresource where id = "+userid+" and status=5 ";
+                rs.executeQuery(sql);
+                if(rs.next()){
+                    workcode = Util.null2String(rs.getString("workcode"));
+                }
+            }
+            if(StringUtils.isNotBlank(workcode)){
+                String key = bb.getPropValue("deliCloud","key");
+                String secret = bb.getPropValue("deliCloud","secret");
+
+                bb.writeLog("key:"+key+"</br>");
+                bb.writeLog("secret:"+secret+"</br>");
+
+                if(StringUtils.isNotBlank(key) && StringUtils.isNotBlank(secret)){
+
+                    String sjc = String.valueOf(Calendar.getInstance().getTimeInMillis());
+                    String appSig = getAppSigData(path,key,secret,sjc);
+
+                    Map<String, String> heads = new HashMap<String, String>();
+                    heads.put("App-Key", key);
+                    heads.put("App-Timestamp", sjc);
+                    heads.put("App-Sig", appSig);
+                    heads.put("Api-Module", "CHECKIN");
+                    heads.put("Api-Cmd", "checkin_query");
+
+                    Map<String, Object> dataMap = new HashMap<String, Object>();
+                    dataMap.put("employee_ext_id", workcode);
+
+                    bb.writeLog("headers:" + JSONObject.toJSONString(heads));
+                    bb.writeLog("body:" + JSONObject.toJSONString(dataMap));
+
+                    String back = doPostJsonRequest(url, heads, JSON.toJSONString(dataMap));
+                    bb.writeLog("response:" + back);
+                    JSONObject backObj = JSONObject.parseObject(back);
+                    String code = backObj.getString("code");
+                    String msg = backObj.getString("msg");
+                    bb.writeLog("code:" + code);
+                    if ("0".equals(code)) {
+                        bb.writeLog(userid+"调用delicloud接口成功");
+                    } else {
+                        bb.writeLog(userid+"调用delicloud接口失败:"+msg);
+                    }
+                }
+            }
+        } catch (Exception e) {
+            bb.writeLog("数据异常!");
+            bb.writeLog(e.getMessage());
+        }
+    }
+
+    /***
+     *
+     * @param path
+     * @param key
+     * @param sercet
+     * @param sjc
+     * @return
+     */
+    public String getAppSigData(String path,String key,String sercet,String sjc){
+
+        String appSig = "";
+        BaseBean bb = new BaseBean();
+        try{
+            MD5 md5 = new MD5();
+            String all = path + sjc + key + sercet;
+            String sig = md5.getMD5ofStr(all);
+            bb.writeLog("sig:" + sig);
+            Scanner sc = new Scanner(md5.getMD5ofStr(all));
+            String str = sc.next();
+            char[] arrays = str.toCharArray();
+
+            for (int i = 0; i < arrays.length; i++) {
+                char c1 = arrays[i];
+                if (c1 >= 65 && c1 <= 90) {
+                    char c2 = toLowerCase(c1);//如果输入是大写  ,则调用toLowerCase方法
+                    appSig = appSig + c2;
+                } else {
+                    appSig = appSig + c1;
+                }
+            }
+            bb.writeLog("appSig:" + appSig);
+        }catch (Exception e){
+
+        }
+        return appSig;
+    }
+
+
+    /***
+     *
+     * @param c1
+     * @return
+     */
+    public static char toLowerCase(char c1){
+        int a = (int) c1;//将接收到的小写字符c1转换成int类型的数据给a
+        int b =a+32;     //a+32得出大写写对应小写的ascll数值
+        char bb = (char)b;//最后将b转换成char类型字符给bb
+        return bb;        //返回bb；就是返回字母小写的字符
+
+    }
+
+
+    private static void prepareHeaders(HttpRequestBase httpRequest, Map<String, String> headers) {
+        if (!MapUtils.isEmpty(headers)) {
+            for (Map.Entry<String, String> entry : headers.entrySet()) {
+                httpRequest.addHeader(entry.getKey(), entry.getValue());
+            }
+        }
+    }
+
+
+    public static String doPostJsonRequest(String url, Map<String, String> headers, String jsonStr) throws IOException {
+        HttpPost httpost = new HttpPost(url);
+        prepareHeaders(httpost, headers);
+        StringEntity entity = new StringEntity(jsonStr, Consts.UTF_8);
+        entity.setContentEncoding("UTF-8");
+        entity.setContentType("application/json");
+        httpost.setEntity(entity);
+        return sendRequest(httpost);
+    }
+
+
+    private static String sendRequest(HttpRequestBase httpRequest) throws IOException {
+        String result = null;
+        CloseableHttpClient httpclient = creteClient();
+        try (CloseableHttpResponse resp = httpclient.execute(httpRequest)) {
+            HttpEntity entity = resp.getEntity();
+            result = (entity == null ? null : EntityUtils.toString(entity, Consts.UTF_8));
+            StatusLine statusLine = resp.getStatusLine();
+            if (statusLine.getStatusCode() >= 300) {
+                EntityUtils.consume(entity);
+//                String errorMsg = Strings.lenientFormat("Http status abnormal-status code is %s, response is %s", resp.getStatusLine().getStatusCode(), result);
+            }
+        }
+        return result;
+    }
+
+
+    public static CloseableHttpClient creteClient() {
+        //采用绕过验证的方式处理https请求
+        try {
+            SSLContext sslcontext = createIgnoreVerifySSL();
+            // 设置协议http和https对应的处理socket链接工厂的对象
+            Registry<ConnectionSocketFactory> socketFactoryRegistry = RegistryBuilder.<ConnectionSocketFactory>create()
+                    .register("http", PlainConnectionSocketFactory.INSTANCE)
+                    .register("https", new SSLConnectionSocketFactory(sslcontext, NoopHostnameVerifier.INSTANCE))
+                    .build();
+            PoolingHttpClientConnectionManager connManager = new PoolingHttpClientConnectionManager(socketFactoryRegistry);
+            HttpClients.custom().setConnectionManager(connManager);
+
+            //创建自定义的httpclient对象
+            CloseableHttpClient client = HttpClients.custom().setConnectionManager(connManager).build();
+            return client;
+        } catch (Exception e) {
+            return null;
+        }
+
+    }
+
+
+    /**
+     * 绕过验证
+     *
+     * @return
+     * @throws NoSuchAlgorithmException
+     * @throws KeyManagementException
+     */
+    public static SSLContext createIgnoreVerifySSL() throws NoSuchAlgorithmException, KeyManagementException {
+        SSLContext sc = SSLContext.getInstance("SSLv3");
+
+        // 实现一个X509TrustManager接口，用于绕过验证，不用修改里面的方法
+        X509TrustManager trustManager = new X509TrustManager() {
+            @Override
+            public void checkClientTrusted(
+                    java.security.cert.X509Certificate[] paramArrayOfX509Certificate,
+                    String paramString) throws CertificateException {
+            }
+
+            @Override
+            public void checkServerTrusted(
+                    java.security.cert.X509Certificate[] paramArrayOfX509Certificate,
+                    String paramString) throws CertificateException {
+            }
+
+            @Override
+            public java.security.cert.X509Certificate[] getAcceptedIssuers() {
+                return null;
+            }
+        };
+
+        sc.init(null, new TrustManager[]{trustManager}, null);
+        return sc;
+    }
+
+
+
+}

src/weaver/interfaces/shuzhi/cronjob/RelationshipReminderJob.java

@@ -193,11 +193,15 @@ public class RelationshipReminderJob extends BaseCronJob {
     private String updateLZHrmStatus(String userid, String status, String date) {
         RecordSet rs = new RecordSet();
         String sql = "update hrmresource set status = '" + status + "' where id = '" + userid + "'";
-        rs.execute(sql);
+        boolean isTrue = rs.executeUpdate(sql);
 
         sql = "update uf_rzgljmb set  ygzt = '3' , lzrq = '" + date + "' where ygrlzy = '" + userid + "'";
         rs.execute(sql);
 
+        if(isTrue){
+            EcologyToDelicloudUtil EcologyToDelicloudUtil = new EcologyToDelicloudUtil();
+            EcologyToDelicloudUtil.updateEmployeeResign(userid);
+        }
         return "update";
     }