diff --git a/src/weaver/interfaces/shuzhi/cronjob/EcologyToDelicloudUtil.java b/src/weaver/interfaces/shuzhi/cronjob/EcologyToDelicloudUtil.java new file mode 100644 index 0000000..4ff66ab --- /dev/null +++ b/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+"
"); + bb.writeLog("secret:"+secret+"
"); + + if(StringUtils.isNotBlank(key) && StringUtils.isNotBlank(secret)){ + + String sjc = String.valueOf(Calendar.getInstance().getTimeInMillis()); + String appSig = getAppSigData(path,key,secret,sjc); + + Map heads = new HashMap(); + 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 dataMap = new HashMap(); + 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 headers) { + if (!MapUtils.isEmpty(headers)) { + for (Map.Entry entry : headers.entrySet()) { + httpRequest.addHeader(entry.getKey(), entry.getValue()); + } + } + } + + + public static String doPostJsonRequest(String url, Map 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 socketFactoryRegistry = RegistryBuilder.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; + } + + + +} diff --git a/src/weaver/interfaces/shuzhi/cronjob/RelationshipReminderJob.java b/src/weaver/interfaces/shuzhi/cronjob/RelationshipReminderJob.java index 917b47a..59219bc 100644 --- a/src/weaver/interfaces/shuzhi/cronjob/RelationshipReminderJob.java +++ b/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"; }