1

13693261870

2024-11-11 71c8abe501481f2029df623976f240d197edcfe8

1

 src/main/java/com/se/simu/controller/DbController.java

对比新文件
@@ -0,0 +1,35 @@
package com.se.simu.controller;

import com.se.simu.helper.WebHelper;
import com.se.simu.service.DbService;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import lombok.extern.slf4j.Slf4j;
import org.springframework.http.HttpStatus;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import javax.annotation.Resource;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;

@Api(tags = "鏁版嵁绠＄悊")
@Slf4j
@RestController
@RequestMapping("/db")
@SuppressWarnings("ALL")
public class DbController extends BaseController {
    @Resource
    DbService dbService;

    @ApiOperation(value = "info")
    @GetMapping(value = "/info")
    public void info(HttpServletRequest req, HttpServletResponse res) {
        try {
            dbService.info(req, res);
        } catch (Exception ex) {
            WebHelper.writeJson2Page(res, HttpStatus.BAD_REQUEST, ex.getMessage());
        }
    }
}

 src/main/java/com/se/simu/helper/HttpHelper.java

对比新文件
@@ -0,0 +1,269 @@
package com.se.simu.helper;

import org.apache.http.*;
import org.apache.http.client.config.CookieSpecs;
import org.apache.http.client.config.RequestConfig;
import org.apache.http.client.utils.URIUtils;
import org.apache.http.entity.InputStreamEntity;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.HttpClients;
import org.apache.http.message.BasicHeader;
import org.apache.http.message.BasicHttpEntityEnclosingRequest;
import org.apache.http.message.BasicHttpRequest;
import org.apache.http.message.HeaderGroup;
import org.apache.http.util.EntityUtils;

import javax.servlet.ServletException;
import javax.servlet.http.Cookie;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.io.IOException;
import java.net.HttpCookie;
import java.net.URI;
import java.net.URISyntaxException;
import java.util.Enumeration;

@SuppressWarnings("ALL")
public class HttpHelper {
    private final static String HTTP_SLASH2 = "://";

    private final static String HTTP_SLASH = "/";

    private final static Integer THREE = 3;

    protected static final HeaderGroup HOP_HEADERS;

    static {
        HOP_HEADERS = new HeaderGroup();

        String[] headers = new String[]{
                "Connection", "Keep-Alive", "Proxy-Authenticate", "Proxy-Authorization",
                "TE", "Trailers", "Transfer-Encoding", "Upgrade",
                //"X-RateLimit-Burst-Capacity", "X-RateLimit-Remaining", "X-RateLimit-Replenish-Rate",
                "Access-Control-Allow-Origin", "Access-Control-Allow-Credentials", "Access-Control-Allow-Headers"};

        for (String header : headers) {
            HOP_HEADERS.addHeader(new BasicHeader(header, null));
        }
    }

    public void service(HttpServletRequest request, HttpServletResponse response, String url) throws ServletException, IOException {
        HttpRequest proxyRequest;
        if (request.getHeader(HttpHeaders.CONTENT_LENGTH) != null || request.getHeader(HttpHeaders.TRANSFER_ENCODING) != null) {
            proxyRequest = newProxyRequestWithEntity(request, url);
        } else {
            proxyRequest = new BasicHttpRequest(request.getMethod(), url);
        }

        HttpHost host = this.getTargetHost(url);
        // copyRequestHeaders(request, proxyRequest, host);
        //setXrForwardedForHeader(request, proxyRequest);

        // if (!StringHelper.isEmpty(cookie)) proxyRequest.addHeader("Cookie", cookie + "; ")

        CloseableHttpClient client = null;
        HttpResponse proxyResponse = null;
        try {
            client = this.createHttpClient();
            proxyResponse = client.execute(host, proxyRequest);

            int statusCode = proxyResponse.getStatusLine().getStatusCode();
            // response.setStatus(statusCode, proxyResponse.getStatusLine().getReasonPhrase())
            response.setStatus(statusCode);

            copyResponseHeaders(proxyResponse, request, response, url);

            if (statusCode == HttpServletResponse.SC_NOT_MODIFIED) {
                response.setIntHeader(HttpHeaders.CONTENT_LENGTH, 0);
            } else {
                copyResponseEntity(proxyResponse, request, response);
            }
        } catch (Exception ex) {
            throw new ServletException(ex.getMessage());
        } finally {
            if (proxyResponse != null) {
                EntityUtils.consumeQuietly(proxyResponse.getEntity());
            }
            if (client != null) {
                client.close();
            }
        }
    }

    protected HttpRequest newProxyRequestWithEntity(HttpServletRequest request, String url) throws IOException {
        String method = request.getMethod();
        HttpEntityEnclosingRequest proxyRequest = new BasicHttpEntityEnclosingRequest(method, url);
        proxyRequest.setEntity(new InputStreamEntity(request.getInputStream(), getContentLength(request)));
        //String str = EntityUtils.toString(proxyRequest.getEntity(), "UTF-8")

        return proxyRequest;
    }

    private long getContentLength(HttpServletRequest request) {
        String contentLengthHeader = request.getHeader("Content-Length");
        if (contentLengthHeader != null) {
            return Long.parseLong(contentLengthHeader);
        }

        return -1L;
    }

    protected void copyRequestHeaders(HttpServletRequest request, HttpRequest proxyRequest, HttpHost host) {
        @SuppressWarnings("unchecked")
        Enumeration<String> enumerationOfHeaderNames = request.getHeaderNames();

        while (enumerationOfHeaderNames.hasMoreElements()) {
            String headerName = enumerationOfHeaderNames.nextElement();
            copyRequestHeader(request, proxyRequest, host, headerName);
        }
    }

    protected void copyRequestHeader(HttpServletRequest request, HttpRequest proxyRequest, HttpHost host, String headerName) {
        if (headerName.equalsIgnoreCase(HttpHeaders.CONTENT_LENGTH) || HOP_HEADERS.containsHeader(headerName)) {
            return;
        }

        @SuppressWarnings("unchecked")
        Enumeration<String> headers = request.getHeaders(headerName);
        while (headers.hasMoreElements()) {
            String headerValue = headers.nextElement();
            if (headerName.equalsIgnoreCase(HttpHeaders.HOST)) {
                headerValue = host.getHostName();
                if (host.getPort() != -1) {
                    headerValue += ":" + host.getPort();
                }
            } else if (headerName.equalsIgnoreCase(org.apache.http.cookie.SM.COOKIE)) {
                headerValue = getRealCookie(headerValue);
            }

            proxyRequest.addHeader(headerName, headerValue);
        }
    }

    protected HttpHost getTargetHost(String url) throws ServletException {
        try {
            URI uri = new URI(url);

            return URIUtils.extractHost(uri);
        } catch (URISyntaxException ex) {
            throw new ServletException(ex.getMessage());
        }
    }

    protected String getRealCookie(String cookieValue) {
        StringBuilder escapedCookie = new StringBuilder();
        String[] cookies = cookieValue.split("[;,]");
        for (String cookie : cookies) {
            String[] cookieSplit = cookie.split("=");
            if (cookieSplit.length == 2) {
                String cookieName = cookieSplit[0].trim();
                if (cookieName.startsWith(cookieName)) {
                    cookieName = cookieName.substring(cookieName.length());
                    if (escapedCookie.length() > 0) {
                        escapedCookie.append("; ");
                    }
                    escapedCookie.append(cookieName).append("=").append(cookieSplit[1].trim());
                }
            }
        }

        return escapedCookie.toString();
    }

    private void setXrForwardedForHeader(HttpServletRequest request, HttpRequest proxyRequest) {
        String forHeaderName = "X-Forwarded-For";
        String forHeader = request.getRemoteAddr();
        String existingForHeader = request.getHeader(forHeaderName);
        if (existingForHeader != null) {
            forHeader = existingForHeader + ", " + forHeader;
        }
        proxyRequest.setHeader(forHeaderName, forHeader);

        String protoHeaderName = "X-Forwarded-Proto";
        String protoHeader = request.getScheme();
        proxyRequest.setHeader(protoHeaderName, protoHeader);
    }

    protected CloseableHttpClient createHttpClient() {
        RequestConfig requestConfig = RequestConfig.custom()
                .setRedirectsEnabled(false)
                .setCookieSpec(CookieSpecs.IGNORE_COOKIES)
                .setConnectTimeout(-1)
                .setSocketTimeout(-1)
                .build();

        // return HttpClientBuilder.create().setDefaultRequestConfig(requestConfig).build()
        return HttpClients.custom()
                .setDefaultRequestConfig(requestConfig)
                .build();
    }

    protected void copyResponseHeaders(HttpResponse proxyResponse, HttpServletRequest request, HttpServletResponse response, String url) {
        for (Header header : proxyResponse.getAllHeaders()) {
            copyResponseHeader(request, response, header, url);
        }
    }

    protected void copyResponseHeader(HttpServletRequest request, HttpServletResponse response, Header header, String url) {
        String headerName = header.getName();
        if (HOP_HEADERS.containsHeader(headerName)) {
            return;
        }

        String headerValue = header.getValue();
        if (headerName.equalsIgnoreCase(org.apache.http.cookie.SM.SET_COOKIE) || headerName.equalsIgnoreCase(org.apache.http.cookie.SM.SET_COOKIE2)) {
            copyProxyCookie(request, response, headerValue);
        } else if (headerName.equalsIgnoreCase(HttpHeaders.LOCATION)) {
            response.addHeader(headerName, rewriteUrlFromResponse(request, url, headerValue));
        } else {
            response.addHeader(headerName, headerValue);
        }
    }

    protected void copyProxyCookie(HttpServletRequest request, HttpServletResponse response, String headerValue) {
        String path = request.getContextPath() + request.getServletPath();
        if (path.isEmpty()) {
            path = "/";
        }

        for (HttpCookie cookie : HttpCookie.parse(headerValue)) {
            Cookie servletCookie = new Cookie(cookie.getName(), cookie.getValue());
            servletCookie.setComment(cookie.getComment());
            servletCookie.setMaxAge((int) cookie.getMaxAge());
            servletCookie.setPath(path);

            servletCookie.setSecure(cookie.getSecure());
            servletCookie.setVersion(cookie.getVersion());
            response.addCookie(servletCookie);
        }
    }

    protected String rewriteUrlFromResponse(HttpServletRequest request, String targetUri, String theUrl) {
        if (theUrl.startsWith(targetUri)) {
            StringBuffer curUrl = request.getRequestURL();

            int pos;
            if ((pos = curUrl.indexOf(HTTP_SLASH2)) >= 0) {
                if ((pos = curUrl.indexOf(HTTP_SLASH, pos + THREE)) >= 0) {
                    curUrl.setLength(pos);
                }
            }

            curUrl.append(request.getContextPath());
            curUrl.append(request.getServletPath());
            curUrl.append(theUrl, targetUri.length(), theUrl.length());

            return curUrl.toString();
        }

        return theUrl;
    }

    protected void copyResponseEntity(HttpResponse proxyResponse, HttpServletRequest request, HttpServletResponse response) throws IOException {
        HttpEntity entity = proxyResponse.getEntity();
        if (null == entity) {
            return;
        }
        entity.writeTo(response.getOutputStream());
    }
}

 src/main/java/com/se/simu/service/DbService.java

对比新文件
@@ -0,0 +1,37 @@
package com.se.simu.service;

import com.se.simu.config.PropertiesConfig;
import com.se.simu.domain.dto.GeDb;
import com.se.simu.helper.HttpHelper;
import com.se.simu.helper.StringHelper;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.util.Date;

@Slf4j
@Service
@SuppressWarnings("ALL")
public class DbService {
    @Resource
    PropertiesConfig config;

    @Resource
    GedbService gedbService;

    private final static long ONE_DAY = 24 * 60 * 60 * 1000;

    public void info(HttpServletRequest req, HttpServletResponse res) throws Exception {
        String token = gedbService.getToken();
        GeDb db = gedbService.getSeDb(token);
        String date = StringHelper.YMD_FORMAT.format(new Date(System.currentTimeMillis() - ONE_DAY));

        String uri = String.format("%sgeo-service/statis/layer/data/info?dbid=%s&token=%s&caldate=%s", config.getHost(), db.getDbid(), token, date);

        HttpHelper helper = new HttpHelper();
        helper.service(req, res, uri);
    }
}