获取胜算账单数据【奇门接口】

官方API ：获取胜算账单数据【奇门接口】-聚水潭ERP开放平台

对接胜算接口的时候，需要注意无法直接使用奇门的JKD ，需要重写奇门的请求方法，
因为有部分参数，奇门JDK中不存在，需要手动填写。
比如：target_app_key 等。

测试DEMO:

import com.ruoyi.common.utils.StringUtils;import java.io.IOException;
import java.util.*;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.Reader;
import java.net.HttpURLConnection;
import java.net.URL;
import java.net.URLEncoder;
import java.security.GeneralSecurityException;
import java.security.MessageDigest;
import java.text.DateFormat;
import java.text.SimpleDateFormat;
import java.util.HashMap;
import java.util.Map.Entry;
import java.util.zip.GZIPInputStream;import javax.crypto.Mac;
import javax.crypto.SecretKey;
import javax.crypto.spec.SecretKeySpec;/*
*
* 对接聚水潭-胜算接口测试DEMO 
*
*/
public class jushuitanTest {// 验签参数private static final String SIGN_METHOD_MD5 = "md5";private static final String SIGN_METHOD_HMAC = "hmac";private static final String CHARSET_UTF8 = "utf-8";private static final String CONTENT_ENCODING_GZIP = "gzip";// 请求地址private static final String serverUrl = "http://a1q40taq0j.api.taobao.com/router/qm";private static final String appKey = "28xxx94"; // 可替换为您的应用的appKeyprivate static final String appSecret = "2exxxxxxxxxxxxxxxxxxxxxxx3"; // 可替换为您的应用的appSecret// 奇门自定义场景id (聚水潭客服开通自定义场景后提供)private static final String customerId = "1xxxxx98";public static void main(String[] args) throws Exception {System.out.println(getSellerItem());}private static String getSellerItem() throws IOException {Map<String, String> params = new HashMap<String, String>();// 公共参数params.put("method", "jushuitan.shengsuan.billreocrdfee.query");params.put("customer_id", customerId);// target_app_key 固定参数params.put("target_app_key", "23060081");params.put("app_key", appKey);DateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");params.put("timestamp", df.format(new Date()));params.put("format", "json");params.put("v", "2.0");params.put("sign_method", "hmac");/************自定义参数*************/Map<String , Object> data = new HashMap<>();//第几页params.put("page_index", "1");//页大小；默认30条最大500条params.put("page_size", "30");//费用发生开始时间params.put("start_time", "2023-05-30 00:00:00");//费用发生结束时间；最大查询范围1个月params.put("end_time", "2023-05-31 23:59:59");//聚水潭 - 第三方平台管理主键List<String> shopIds = new ArrayList<>();shopIds.add("14xxxx9");shopIds.add("15xxxx9");params.put("shop_ids", StringUtils.join(shopIds, ","));// 请用APIparams.put("sign", signTopRequest(params, appSecret, SIGN_METHOD_HMAC));System.out.println("params=========");System.out.println(params);String msg = callApi(new URL(serverUrl), params);System.out.println("返回参数=================");return msg;}/*** 对TOP请求进行签名。*/private static String signTopRequest(Map<String, String> params, String secret, String signMethod) throws IOException {// 第一步：检查参数是否已经排序String[] keys = params.keySet().toArray(new String[0]);Arrays.sort(keys);// 第二步：把所有参数名和参数值串在一起StringBuilder query = new StringBuilder();if (SIGN_METHOD_MD5.equals(signMethod)) {query.append(secret);}for (String key : keys) {String value = params.get(key);if (isNotEmpty(key) && isNotEmpty(value)) {query.append(key).append(value);}}// 第三步：使用MD5/HMAC加密byte[] bytes;if (SIGN_METHOD_HMAC.equals(signMethod)) {bytes = encryptHMAC(query.toString(), secret);} else {query.append(secret);bytes = encryptMD5(query.toString());}// 第四步：把二进制转化为大写的十六进制return byte2hex(bytes);}/*** 对字节流进行HMAC_MD5摘要。*/private static byte[] encryptHMAC(String data, String secret) throws IOException {byte[] bytes = null;try {SecretKey secretKey = new SecretKeySpec(secret.getBytes(CHARSET_UTF8), "HmacMD5");Mac mac = Mac.getInstance(secretKey.getAlgorithm());mac.init(secretKey);bytes = mac.doFinal(data.getBytes(CHARSET_UTF8));} catch (GeneralSecurityException gse) {throw new IOException(gse.toString());}return bytes;}/*** 对字符串采用UTF-8编码后，用MD5进行摘要。*/private static byte[] encryptMD5(String data) throws IOException {return encryptMD5(data.getBytes(CHARSET_UTF8));}/*** 对字节流进行MD5摘要。*/private static byte[] encryptMD5(byte[] data) throws IOException {byte[] bytes = null;try {MessageDigest md = MessageDigest.getInstance("MD5");bytes = md.digest(data);} catch (GeneralSecurityException gse) {throw new IOException(gse.toString());}return bytes;}/*** 把字节流转换为十六进制表示方式。*/private static String byte2hex(byte[] bytes) {StringBuilder sign = new StringBuilder();for (int i = 0; i < bytes.length; i++) {String hex = Integer.toHexString(bytes[i] & 0xFF);if (hex.length() == 1) {sign.append("0");}sign.append(hex.toUpperCase());}return sign.toString();}private static String callApi(URL url, Map<String, String> params) throws IOException {String query = buildQuery(params, CHARSET_UTF8);// 请求参数byte[] content = {};if (query != null) {content = query.getBytes(CHARSET_UTF8);}HttpURLConnection conn = null;OutputStream out = null;String rsp = null;try {conn = (HttpURLConnection) url.openConnection();conn.setRequestMethod("POST");conn.setDoInput(true);conn.setDoOutput(true);conn.setRequestProperty("Host", url.getHost());conn.setRequestProperty("Accept", "text/xml,text/javascript");conn.setRequestProperty("User-Agent", "top-sdk-java");conn.setRequestProperty("Content-Type", "application/x-www-form-urlencoded;charset=" + CHARSET_UTF8);out = conn.getOutputStream();out.write(content);rsp = getResponseAsString(conn);} finally {if (out != null) {out.close();}if (conn != null) {conn.disconnect();}}return rsp;}private static String buildQuery(Map<String, String> params, String charset) throws IOException {if (params == null || params.isEmpty()) {return null;}StringBuilder query = new StringBuilder();Set<Entry<String, String>> entries = params.entrySet();boolean hasParam = false;for (Entry<String, String> entry : entries) {String name = entry.getKey();String value = entry.getValue();// 忽略参数名或参数值为空的参数if (isNotEmpty(name) && isNotEmpty(value)) {if (hasParam) {query.append("&");} else {hasParam = true;}query.append(name).append("=").append(URLEncoder.encode(value, charset));}}return query.toString();}private static String getResponseAsString(HttpURLConnection conn) throws IOException {String charset = getResponseCharset(conn.getContentType());if (conn.getResponseCode() < 400) {String contentEncoding = conn.getContentEncoding();if (CONTENT_ENCODING_GZIP.equalsIgnoreCase(contentEncoding)) {return getStreamAsString(new GZIPInputStream(conn.getInputStream()), charset);} else {return getStreamAsString(conn.getInputStream(), charset);}} else {// Client Error 4xx and Server Error 5xxthrow new IOException(conn.getResponseCode() + " " + conn.getResponseMessage());}}private static String getStreamAsString(InputStream stream, String charset) throws IOException {try {Reader reader = new InputStreamReader(stream, charset);StringBuilder response = new StringBuilder();final char[] buff = new char[1024];int read = 0;while ((read = reader.read(buff)) > 0) {response.append(buff, 0, read);}return response.toString();} finally {if (stream != null) {stream.close();}}}private static String getResponseCharset(String ctype) {String charset = CHARSET_UTF8;if (isNotEmpty(ctype)) {String[] params = ctype.split(";");for (String param : params) {param = param.trim();if (param.startsWith("charset")) {String[] pair = param.split("=", 2);if (pair.length == 2) {if (isNotEmpty(pair[1])) {charset = pair[1].trim();}}break;}}}return charset;}private static boolean isNotEmpty(String value) {int strLen;if (value == null || (strLen = value.length()) == 0) {return false;}for (int i = 0; i < strLen; i++) {if ((Character.isWhitespace(value.charAt(i)) == false)) {return true;}}return false;}}