wenlukang1
/
CTSK_DEV
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Compare commits

base: wenlukang1:477e0985776899273e61ac72bd6917f30fe87938
Branches Tags
wenlukang1:main
...
compare: wenlukang1:9cc64cd648d2807bde4562322887a62d0237ab43
Branches Tags
wenlukang1:main

2 Commits
477e098577 ... 9cc64cd648

Author SHA1 Message Date
fang 9cc64cd648 Merge remote-tracking branch 'origin/main' into main 2024-11-13 09:47:55 +08:00
fang 08beb58feb 待办_1 2024-11-13 09:47:31 +08:00
2 changed files with 159 additions and 10 deletions
Show Stats Expand all files Collapse all files

135
sys/shkd-sys-sys/src/main/java/shkd/sys/sys/midservice/test01.java Normal file
View File

@ -0,0 +1,135 @@
//package shkd.sys.sys.midservice;
//
//import org.apache.commons.lang.StringUtils;
//import org.apache.commons.logging.Log;
//import org.apache.commons.logging.LogFactory;
//import org.apache.http.HttpEntity;
//import org.apache.http.NameValuePair;
//import org.apache.http.ParseException;
//import org.apache.http.client.entity.UrlEncodedFormEntity;
//import org.apache.http.client.methods.CloseableHttpResponse;
//import org.apache.http.client.methods.HttpPost;
//import org.apache.http.impl.client.CloseableHttpClient;
//import org.apache.http.message.BasicNameValuePair;
//import org.apache.http.util.EntityUtils;
//
//import java.io.IOException;
//import java.security.MessageDigest;
//import java.security.NoSuchAlgorithmException;
//import java.util.ArrayList;
//import java.util.Iterator;
//import java.util.List;
//import java.util.Map;
//
///**
// * 单据界面
// */
//public class test01 {
//
// private static final Log LOG = LogFactory.getLog(test01.class);
// private static final CloseableHttpClient httpClient = null;
// public static final String CHARSET = "UTF-8";
//
// public static final String MD5(String s) {
// return MD5(s, "");
// }
// public static String doPost(String url, Map<String, String> header, Map<String, String> params, String charset) throws IOException {
// if (StringUtils.isBlank(url)) {
// return null;
// } else {
// List<NameValuePair> pairs = null;
// if (params != null && !params.isEmpty()) {
// pairs = new ArrayList(params.size());
// Iterator var5 = params.entrySet().iterator();
//
// while(var5.hasNext()) {
// Map.Entry<String, String> entry = (Map.Entry)var5.next();
// String value = (String)entry.getValue();
// if (value != null) {
// pairs.add(new BasicNameValuePair((String)entry.getKey(), value));
// }
// }
// }
//
// HttpPost httpPost = new HttpPost(url);
// if (null != header && header.size() > 0) {
// Iterator var17 = header.entrySet().iterator();
//
// while(var17.hasNext()) {
// Map.Entry<String, String> headerSet = (Map.Entry)var17.next();
// httpPost.setHeader((String)headerSet.getKey(), (String)headerSet.getValue());
// }
// }
//
// if (pairs != null && pairs.size() > 0) {
// httpPost.setEntity(new UrlEncodedFormEntity(pairs, "UTF-8"));
// }
//
// CloseableHttpResponse response = null;
//
// try {
// response = httpClient.execute(httpPost);
// int statusCode = response.getStatusLine().getStatusCode();
// if (statusCode != 200) {
// httpPost.abort();
// throw new RuntimeException("HttpClient,error status code :" + statusCode);
// }
//
// HttpEntity entity = response.getEntity();
// String result = null;
// if (entity != null) {
// result = EntityUtils.toString(entity, "utf-8");
// }
//
// EntityUtils.consume(entity);
// String var10 = result;
// return var10;
// } catch (ParseException var14) {
// var14.printStackTrace();
// } finally {
// if (response != null) {
// response.close();
// }
//
// }
//
// return null;
// }
// }
//
//
// public static String MD5(String strSrc, String key) {
// try {
// MessageDigest md5 = MessageDigest.getInstance("MD5");
// byte[] b = strSrc.getBytes("utf-8");
// md5.update(b);
// String result = "";
// byte[] temp = md5.digest(key.getBytes("utf-8"));
// String s = "";
// byte[] var7 = temp;
// int var8 = temp.length;
//
// for(int var9 = 0; var9 < var8; ++var9) {
// byte bb = var7[var9];
// s = s + bb + " ";
// }
//
// for(int i = 0; i < temp.length; ++i) {
// result = result + Integer.toHexString(255 & temp[i] | -256).substring(6);
// }
//
// return result;
// } catch (NoSuchAlgorithmException var11) {
// LOG.error("md5异常", var11);
// } catch (Exception var12) {
// LOG.error("md5异常", var12);
// }
//
// return "";
// }
//
//
// public static void main(String[] args) throws Exception {
// System.out.println(MD5("scicsiku"));
// }
//}

34
sys/shkd-sys-sys/src/main/java/shkd/sys/sys/midservice/utils/RequestClient.java
View File

@ -7,11 +7,13 @@ import kd.bos.servicehelper.BusinessDataServiceHelper;
import kd.bos.servicehelper.operation.SaveServiceHelper;
import kd.bos.util.HttpClientUtils;
import kd.bos.util.StringUtils;
import kd.ebg.aqap.banks.srcb.dc.services.utils.SmUtil;
import kd.data.idi.util.HexUtil;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import java.io.IOException;
import java.security.MessageDigest;
import java.security.NoSuchAlgorithmException;
import java.util.HashMap;
import java.util.Map;
@ -29,15 +31,15 @@ public class RequestClient {
private String protocal;//http
private String ip;// 域名
private String port;// 端口
private String clientKey;// clientKey
private String clientSecret_scict;// clientSecret-scict
private String clientKey;// 系统标识
// private String clientSecret_scict;// clientSecret-scict
private RequestClient() {
this.protocal = System.getProperty("backlog-protocal");
this.ip = System.getProperty("backlog-ip");
this.port = System.getProperty("backlog-port");
this.clientKey= System.getProperty("clientKey-scict");
this.clientSecret_scict= System.getProperty("clientSecret-scict");
// this.clientSecret_scict= System.getProperty("clientSecret-scict");
}
/**
* 获取中台服务客户端实例
@ -57,12 +59,14 @@ public class RequestClient {
* @param body JSON格式字符串
* @return 响应结果报文
*/
public String callService(String url, String body) {
Map<String, String> header = new HashMap<>();
public String callService(String url, String body) throws NoSuchAlgorithmException {
/*Map<String, String> header = new HashMap<>();
header.put("systemid", this.clientKey);
header.put("sign",this.clientSecret_scict);
header.put("Content-Type", "application/x-www-form-urlencoded");
header.put("Content-Type", "application/x-www-form-urlencoded");*/
// header.put("Content-Type", "application/json; charset=utf-8");
Map<String, String> headers = getHeaders();
logger.info("获得headers的方法结束"+JSON.toJSONString(headers));
StringBuffer urlStr = new StringBuffer();
urlStr.append(this.protocal).append("://").append(this.ip);
if (!StringUtils.isEmpty(this.port)) {
@ -73,14 +77,24 @@ public class RequestClient {
String responseText = null;
try {
//直接POST请求
responseText = HttpClientUtils.postjson(urlStr.toString(), header, body);
logger.info(String.format("###调用接口成功，请求URL：%s，请求Header：%s，请求Body：%s，响应报文：%s", urlStr, JSON.toJSONString(header), body, responseText));
responseText = HttpClientUtils.postjson(urlStr.toString(), headers, body);
logger.info(String.format("###调用接口成功，请求URL：%s，请求Header：%s，请求Body：%s，响应报文：%s", urlStr, JSON.toJSONString(headers), body, responseText));
} catch (IOException e) {
logger.error(String.format("###调用接口异常：%s，请求URL：%s，请求Header：%s，请求Body：%s", e.getMessage(), urlStr, JSON.toJSONString(header), body), e);
logger.error(String.format("###调用接口异常：%s，请求URL：%s，请求Header：%s，请求Body：%s", e.getMessage(), urlStr, JSON.toJSONString(headers), body), e);
}
return responseText;
}
private Map<String, String> getHeaders() throws NoSuchAlgorithmException {
MessageDigest md5 = MessageDigest.getInstance("MD5");
byte[] md5Bytes = md5.digest(this.clientKey.getBytes());
String md5Str = HexUtil.bytes2Hex(md5Bytes).toUpperCase();
HashMap<String, String> map = new HashMap();
map.put("systemid", this.clientKey);
map.put("sign", md5Str);
map.put("Content-Type", "application/x-www-form-urlencoded");
return map;
}
/***
* 保存待办日志
* @param title 标题