项目已经正常跑的代码

常量定义

/**
 * NS全局常量定义
 *
 * @author zhangbs
 * @version 2021-05-28
 */
public class NsConstant {
    public final static String URL = "xxxx";
    public final static String REALM = "xxx";
    public final static String ACCESS_TOKEN = "xxx";
    public final static String TOKEN_SECRET = "xxx";
    public final static String CONSUMER_KEY = "xxx";
    public final static String CONSUMER_SECRET = "xxx";
    public final static String SUCCESS_OK = "200";
}

请求工具类

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import xxx.MapUtils;
import xxx.DateUtils;
import xxx.StringUtils;
import xxx.NsAuthInfo;
import xxx.EipDateUtils;
import org.apache.commons.codec.binary.Base64;
import org.apache.http.HttpEntity;
import org.apache.http.HttpResponse;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.entity.ContentType;
import org.apache.http.entity.StringEntity;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.HttpClientBuilder;
import org.apache.http.util.EntityUtils;

import javax.crypto.Mac;
import javax.crypto.spec.SecretKeySpec;
import java.io.UnsupportedEncodingException;
import java.net.URLEncoder;
import java.util.Arrays;
import java.util.Date;
import java.util.HashMap;
import java.util.Map;

/**
 * NS请求工具类
 *
 * @author zhangbs
 * @version 2021-05-28
 */
public class NsRequestUtils {


    /**
     * 发送请求并返回响应结果
     *
     * @param url           请求url
     * @param requestMethod 请求方式
     * @param paramsMap     参数
     * @param authInfo      认证信息
     * @return 请求响应结果
     */
    public static Map<String, Object> executeRequest(String url, String requestMethod, Map<String, Object> paramsMap, NsAuthInfo authInfo) {
        Map<String, Object> resultMap = MapUtils.newHashMap();
        try {
            String authorization = NsRequestUtils.constructAuthHeader(authInfo, requestMethod);

            CloseableHttpClient httpClient = HttpClientBuilder.create().build();
            HttpPost httpPost = new HttpPost(url);
            httpPost.setHeader("Content-Type", "application/json");
            httpPost.setHeader("Accept", "*/*");
            httpPost.setHeader("Authorization", authorization);

            String jsonParams = JSON.toJSONString(paramsMap);
            HttpEntity entityParam = new StringEntity(jsonParams, ContentType.create("application/json", "UTF-8"));
            httpPost.setEntity(entityParam);
            HttpResponse response = httpClient.execute(httpPost);

            // 状态码
            resultMap.put("code", response.getStatusLine().getStatusCode() + "");
            // 返回结果
            resultMap.put("result", EntityUtils.toString(response.getEntity(), "utf-8"));
        } catch (Exception e) {
            resultMap.put("code", "400");
        }

        return resultMap;
    }

    /**
     * 生成签名并组合Authorization头
     * 如"/", 编码后为: %2F
     *
     * @return 编码后的字符串
     */
    public static String constructAuthHeader(NsAuthInfo auth, String method) throws Exception {
        // 基础信息
        String url = auth.getUrl();
        // 时间戳
        long timestamp = new Date().getTime() / 1000;
        // 转成大写
        method = method.toUpperCase();
        // 签名方法
        String signatureMethod = "HMAC-SHA256", signatureMethodCode = "HmacSHA256";
        // 基础信息
        String accessToken = auth.getAccessToken(), tokenSecret = auth.getTokenSecret(),
                consumerKey = auth.getConsumerKey(), consumerSecret = auth.getConsumerSecret(),
                realm = auth.getRealm(), nonce = StringUtils.getRandomStr(32);
        // 组合Key
        String key = consumerSecret + '&' + tokenSecret;
        // 截取问号前的URL
        String encodeURL = url.split("\\?")[0];

        // 获取URL参数
        Map<String, String> parameters = urlSplit(url);
        parameters.put("oauth_consumer_key", consumerKey);
        parameters.put("oauth_nonce", nonce);
        parameters.put("oauth_signature_method", signatureMethod);
        parameters.put("oauth_timestamp", String.valueOf(timestamp));
        parameters.put("oauth_token", accessToken);
        parameters.put("oauth_version", "1.0");
        String parameterString = sortAndConcat(parameters);
        // 组合待签字符串
        StringBuilder signatureBaseString = new StringBuilder(100);
        signatureBaseString.append(method.toUpperCase());
        signatureBaseString.append('&');
        signatureBaseString.append(urlEncode(encodeURL));
        signatureBaseString.append('&');
        signatureBaseString.append(urlEncode(parameterString));
        // 转换成String类型
        String signatureString = signatureBaseString.toString();
        // 生成签名
        byte[] bytesToSign = signatureString.getBytes("UTF-8");
        byte[] keyBytes = key.getBytes("UTF-8");
        SecretKeySpec signingKey = new SecretKeySpec(keyBytes, signatureMethodCode);
        Mac mac = Mac.getInstance(signatureMethodCode);
        mac.init(signingKey);
        byte[] signedBytes = mac.doFinal(bytesToSign);
        String signature = urlEncode(new String(Base64.encodeBase64(signedBytes, false)));

        return new StringBuilder().append("OAuth ")
                .append("realm").append("=\"").append(realm)
                .append("\",").append("oauth_consumer_key").append("=\"").append(consumerKey)
                .append("\",").append("oauth_token").append("=\"").append(accessToken)
                .append("\",").append("oauth_signature_method").append("=\"").append(signatureMethod)
                .append("\",").append("oauth_timestamp").append("=\"").append(timestamp)
                .append("\",").append("oauth_nonce").append("=\"").append(nonce)
                .append("\",").append("oauth_version").append("=\"").append("1.0")
                .append("\",").append("oauth_signature").append("=\"").append(signature)
                .append("\"").toString();
    }


    /**
     * 返回参数double的空处理
     *
     * @param jsonObject json对象
     * @param key
     * @return
     */
    public static Double killNullDouble(JSONObject jsonObject, String key) {
        Double result = jsonObject.getDouble(key);
        return result == null ? 0.0D : result;
    }

    /**
     * 获取加上指定月份的开始日期 格式yyyy/MM/dd
     *
     * @param month
     * @return
     */
    public static String getStartDate(int month, String append) {
        Date monthAdd = DateUtils.addMonths(new Date(), month);
        String yearMonth = DateUtils.formatDate(monthAdd, "yyyy/MM");
        return yearMonth + append;
    }

    /**
     * 获取加上指定月份的结束日期 格式yyyy/MM/dd
     *
     * @param month
     * @return
     */
    public static String getEndDate(int month) {
        if (month < 0) {
            Date monthAdd = DateUtils.addMonths(new Date(), month);
            String yearMonth = DateUtils.formatDate(monthAdd, "yyyy/MM");
            return yearMonth + "/" + EipDateUtils.getMonthHasDays(monthAdd);
        } else {
            return DateUtils.formatDate(new Date(), "yyyy/MM/dd");
        }
    }

    /**
     * 解析出url参数中的键值对
     * 如 "restlet.nl?script=248&deploy=1"，解析出script:24,deploy:1存入map中
     *
     * @param URL url地址
     * @return url请求参数部分
     */
    public static Map<String, String> urlSplit(String URL) {
        Map<String, String> mapRequest = new HashMap<String, String>();
        String[] arrSplit = null;
        String strUrlParam = TruncateUrlPage(URL);
        if (strUrlParam == null) {
            return mapRequest;
        }
        arrSplit = strUrlParam.split("[&]");
        for (String strSplit : arrSplit) {
            String[] arrSplitEqual = null;
            arrSplitEqual = strSplit.split("[=]");
            //解析出键值
            if (arrSplitEqual.length > 1) {
                //正确解析
                mapRequest.put(arrSplitEqual[0], arrSplitEqual[1]);
            } else {
                if (arrSplitEqual[0] != "") {
                    //只有参数没有值，不加入
                    mapRequest.put(arrSplitEqual[0], "");
                }
            }
        }
        return mapRequest;
    }

    /**
     * 去掉url中的路径，留下请求参数部分
     *
     * @param strURL url地址
     * @return url请求参数部分
     */
    private static String TruncateUrlPage(String strURL) {
        String strAllParam = null;
        String[] arrSplit = null;
        strURL = strURL.trim().toLowerCase();
        arrSplit = strURL.split("[?]");
        if (strURL.length() > 1) {
            if (arrSplit.length > 1) {
                for (int i = 1; i < arrSplit.length; i++) {
                    strAllParam = arrSplit[i];
                }
            }
        }
        return strAllParam;
    }


    /**
     * 对URL参数进行排序
     * 如"script:248,deploy:1", 排序后deploy=1&script=248
     *
     * @param parameters 参数的键值对
     * @return 排序后的字符串
     */
    private static String sortAndConcat(Map<String, String> parameters) {
        StringBuilder encodedParams = new StringBuilder(100);
        Object[] arr = parameters.keySet().toArray();
        Arrays.sort(arr);
        for (Object key : arr) {
            if (encodedParams.length() > 0) {
                encodedParams.append('&');
            }
            encodedParams.append(key).append('=').append(parameters.get(key));
        }
        return encodedParams.toString();
    }

    /**
     * 对字符串进行URL编码
     * 如"/", 编码后为: %2F
     *
     * @param str 传入字符串
     * @return 编码后的字符串
     */
    private static String urlEncode(String str) {
        try {
            return URLEncoder.encode(str, "UTF-8")
                    .replace("+", "%20")
                    .replace("*", "%2A")
                    .replace("%7E", "~");
        } catch (UnsupportedEncodingException e) {
            throw new IllegalArgumentException(e);
        }
    }

认证参数信息

/**
 * NS认证信息
 *
 * @author zhangbs
 * @version 2021-05-28
 */
public class NsAuthInfo {

    public NsAuthInfo(String realm, String url, String accessToken, String tokenSecret, String consumerKey, String consumerSecret) {
        setRealm(realm);
        setUrl(url);
        setAccessToken(accessToken);
        setTokenSecret(tokenSecret);
        setConsumerKey(consumerKey);
        setConsumerSecret(consumerSecret);
    }

    private String url;
    private String accessToken;
    private String tokenSecret;
    private String consumerKey;
    private String consumerSecret;
    private String realm;

    public String getUrl() {
        return url;
    }

    public void setUrl(String url) {
        this.url = url;
    }

    public String getAccessToken() {
        return accessToken;
    }

    public void setAccessToken(String accessToken) {
        this.accessToken = accessToken;
    }

    public String getTokenSecret() {
        return tokenSecret;
    }

    public void setTokenSecret(String tokenSecret) {
        this.tokenSecret = tokenSecret;
    }

    public String getConsumerKey() {
        return consumerKey;
    }

    public void setConsumerKey(String consumerKey) {
        this.consumerKey = consumerKey;
    }

    public String getConsumerSecret() {
        return consumerSecret;
    }

    public void setConsumerSecret(String consumerSecret) {
        this.consumerSecret = consumerSecret;
    }

    public String getRealm() {
        return realm;
    }

    public void setRealm(String realm) {
        this.realm = realm;
    }

请求参考

import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import xxx.NsAuthInfo;
import xxx.NsConstant;
import xxx.NsRequestUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import java.util.Date;
import java.util.List;
import java.util.Map;
    /**
     * 执行定时任务(默认跑昨天至今天的数据)
     */
    public void execute(String systemCode, String date) {
        // 参数放置
        Map<String, Object> paramsMap = MapUtils.newHashMap();
        String startDate = StringUtils.isNotEmpty(date) ? date : DateUtils.formatDate(DateUtils.addDays(new Date(), -1), "yyyy/MM/dd");
        String endDate = StringUtils.isNotEmpty(date) ? date : DateUtils.formatDate(DateUtils.addDays(new Date(), -0), "yyyy/MM/dd");

        paramsMap.put("startDate", startDate);
        paramsMap.put("endtDate", endDate);
        paramsMap.put("subsidiary", systemCode);

        String url = NsConstant.URL + "&script=701";
        // 构建认证信息
        NsAuthInfo authInfo = new NsAuthInfo(NsConstant.REALM, url, NsConstant.ACCESS_TOKEN, NsConstant.TOKEN_SECRET,
                NsConstant.CONSUMER_KEY, NsConstant.CONSUMER_SECRET);

        Map<String, Object> result = NsRequestUtils.executeRequest(url, "POST", paramsMap, authInfo);

        // 构建保存信息
        if (NsConstant.SUCCESS_OK.equals(result.get("code"))) {
            // 做业务处理
        }
    }