1

13693261870

2022-09-28 9b61776c8806cc70246396d799cd403093820cce

1

 src/main/java/com/lf/server/LfApplication.java

@@ -7,8 +7,8 @@
import springfox.documentation.swagger2.annotations.EnableSwagger2;

/**
 * LandApplication
 * @author
 * Land应用程序
 * @author WWW
 */
@EnableSwagger2
@SpringBootApplication(scanBasePackages={"com.lf.server.config", "com.lf.server.mapper", "com.lf.server.service","com.lf.server.controller"})

 src/main/java/com/lf/server/aspect/LogAspect.java

@@ -12,7 +12,7 @@
import java.lang.reflect.Method;

/**
 * LogAspect
 * æ—¥å¿—切面类
 * @author WWW
 */
@Aspect

 src/main/java/com/lf/server/config/RedisConfig.java

@@ -19,7 +19,7 @@
import java.util.Map;

/**
 * RedisConfig
 * Redis配置类
 * @author WWW
 */
@Configuration

 src/main/java/com/lf/server/config/RestTemplateConfig.java

@@ -18,7 +18,7 @@
import java.util.List;

/**
 * RestTemplateConfig
 * Rest模板配置类
 * @author WWW
 */
@Configuration

 src/main/java/com/lf/server/config/ShiroConfig.java

@@ -19,7 +19,7 @@
import java.util.Map;

/**
 * ShiroConfig
 * Shiro配置类
 * @author WWW
 */
@SuppressWarnings("ALL")

 src/main/java/com/lf/server/config/SwaggerConfig.java

@@ -11,7 +11,7 @@
import springfox.documentation.swagger2.annotations.EnableSwagger2;

/**
 * SwaggerConfig
 * Swagger配置类
 * @author www
 */
@Configuration

 src/main/java/com/lf/server/config/WebConfig.java

@@ -12,7 +12,7 @@
import java.util.List;

/**
 * WebConfig
 * Web配置类
 * @author WWW
 */
@Component

 src/main/java/com/lf/server/controller/BaseController.java

@@ -7,7 +7,7 @@

/**
 * Controller基类
 * @author www
 * @author WWW
 */
public class BaseController {
    public Log log = LogFactory.getLog(getClass());

 src/main/java/com/lf/server/entity/all/HttpStatus.java

@@ -1,8 +1,8 @@
package com.lf.server.entity.all;

/**
 * HttpStatus
 * @author
 * Http状态码类
 * @author WWW
 */
public enum HttpStatus {
    /**

 src/main/java/com/lf/server/entity/all/ResponseMsg.java

@@ -1,9 +1,9 @@
package com.lf.server.entity.all;

/**
 * å“åº”消息
 * å“åº”消息类
 * @author www
 * @param <T>
 * @param <T> æ³›åž‹
 */
public class ResponseMsg<T> {
    public ResponseMsg() {

 src/main/java/com/lf/server/entity/all/StaticData.java

@@ -1,7 +1,7 @@
package com.lf.server.entity.all;

/**
 * é™æ€æ•°æ®
 * é™æ€æ•°æ®ç±»
 * @author WWW
 */
public class StaticData {
@@ -24,4 +24,14 @@
     * Cookie中令牌键
     */
    public final static String TOKEN_COOKIE_KEY = "token";

    /**
     * æ–‡æœ¬ç¼–码方式
     */
    public final static String TEXT_ENCODER = "UTF-8";

    /**
     * ç¼“存前缀
     */
    public final static String CACHE_PREFIX = "SGProxy";
}

 src/main/java/com/lf/server/entity/sys/Result.java

@@ -3,7 +3,7 @@
import com.lf.server.entity.sys.LoginInfo;

/**
 * Result
 * ç»“果类
 * @author
 */
public class Result {

 src/main/java/com/lf/server/helper/EnumHelper.java

@@ -6,7 +6,7 @@
import java.lang.reflect.Method;

/**
 * æžšä¸¾ç±»åž‹å¸®åŠ©ç±»
 * æžšä¸¾å¸®åŠ©ç±»
 * @author WWW
 */
public class EnumHelper {

 src/main/java/com/lf/server/helper/HttpHelper.java

@@ -60,8 +60,8 @@
        }

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

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

 src/main/java/com/lf/server/helper/JsonHelper.java

@@ -9,8 +9,8 @@
import java.util.List;

/**
 * JsonHelper
 * @author www
 * Json帮助类
 * @author WWW
 */
public class JsonHelper {
    /**

 src/main/java/com/lf/server/helper/RestHelper.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,241 @@
package com.lf.server.helper;

import com.lf.server.entity.all.StaticData;
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.client.entity.UrlEncodedFormEntity;
import org.apache.http.client.methods.CloseableHttpResponse;
import org.apache.http.client.methods.HttpGet;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.HttpClients;
import org.apache.http.util.EntityUtils;
import org.springframework.web.client.RestTemplate;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintStream;
import java.net.HttpURLConnection;
import java.net.URL;
import java.util.LinkedHashMap;
import java.util.List;
import java.util.Map;

/**
 * Rest服务帮助类
 * @author WWW
 */
public class RestHelper {
    private static RestTemplate restTemplate;

    private final static Log log = LogFactory.getLog(RestHelper.class);

    /**
     * èŽ·å–RestTemplate
     *
     * @return RestTemplate
     */
    public static RestTemplate getRestTemplate() {
        if (restTemplate == null) {
            restTemplate = SpringContextHelper.getBean(RestTemplate.class);
        }

        return restTemplate;
    }

    /**
     * Get请求-HttpURLConnection
     *
     * @param url URL地址
     * @return å­—符串
     * @throws IOException IO异常
     */
    public static String getForConn(String url) throws IOException {
        BufferedReader br = null;
        HttpURLConnection conn = null;

        try {
            URL restUrl = new URL(url);

            conn = (HttpURLConnection) restUrl.openConnection();
            // POST,GET,PUT,DELETE
            conn.setRequestMethod("GET");
            conn.setRequestProperty("Accept", "application/json");

            br = new BufferedReader(new InputStreamReader(conn.getInputStream()));

            String line;
            StringBuilder sb = new StringBuilder();
            while ((line = br.readLine()) != null) {
                sb.append(line);
            }

            return sb.toString();
        } finally {
            if (br != null) {
                br.close();
            }
            if (conn != null) {
                conn.disconnect();
            }
        }
    }

    /**
     * Post请求-HttpURLConnection
     *
     * @param url   URL地址
     * @param query æŸ¥è¯¢æ¡ä»¶
     * @return å­—符串
     * @throws IOException IO异常
     */
    public static String postForConn(String url, String query) throws IOException {
        BufferedReader br = null;
        HttpURLConnection conn = null;

        try {
            URL restUrl = new URL(url);

            conn = (HttpURLConnection) restUrl.openConnection();
            // POST,GET,PUT,DELETE
            conn.setRequestMethod("POST");
            conn.setRequestProperty("Content-Type", "application/json");
            conn.setDoOutput(true);

            PrintStream ps = new PrintStream(conn.getOutputStream());
            ps.print(query);
            ps.close();

            // OutputStream out = conn.getOutputStream()
            // out.write(query.getBytes())
            // out.close()

            br = new BufferedReader(new InputStreamReader(conn.getInputStream()));

            String line;
            StringBuilder sb = new StringBuilder();
            while ((line = br.readLine()) != null) {
                sb.append(line);
            }

            return sb.toString();
        } finally {
            if (br != null) {
                br.close();
            }
            if (conn != null) {
                conn.disconnect();
            }
        }
    }

    /**
     * Get请求-CloseableHttpClient
     *
     * @param uri Uri地址
     * @return å“åº”字符串
     */
    public static String get(String uri) {
        try {
            CloseableHttpClient httpClient = HttpClients.custom().build();

            HttpGet httpGet = new HttpGet(uri);

            CloseableHttpResponse closeResponse = httpClient.execute(httpGet);
            // å–出返回体
            HttpEntity entity = closeResponse.getEntity();

            return EntityUtils.toString(entity, StaticData.TEXT_ENCODER);
        } catch (Exception ex) {
            log.error(ex);

            return getErrorInfo(uri, ex);
        }
    }

    /**
     * Post请求-CloseableHttpClient
     *
     * @param uri      Uri地址
     * @param postData å¾…发送数据
     * @return å“åº”字符串
     */
    public static String post(String uri, List<NameValuePair> postData) {
        try {
            CloseableHttpClient httpClient = HttpClients.custom().build();

            UrlEncodedFormEntity postEntity = new UrlEncodedFormEntity(postData, StaticData.TEXT_ENCODER);
            HttpPost httpPost = new HttpPost(uri);
            httpPost.setEntity(postEntity);

            CloseableHttpResponse closeResponse = httpClient.execute(httpPost);
            // å–出返回体
            HttpEntity entity = closeResponse.getEntity();

            return EntityUtils.toString(entity, StaticData.TEXT_ENCODER);
        } catch (Exception ex) {
            log.error(ex);

            return getErrorInfo(uri, ex);
        }
    }

    /**
     * Get请求-RestTemplate
     *
     * @param uri Uri地址
     * @return å“åº”字符串
     */
    public static String getForRest(String uri) {
        try {
            RestTemplate rest = getRestTemplate();

            return rest.getForObject(uri, String.class);
        } catch (Exception ex) {
            log.error(ex);

            return getErrorInfo(uri, ex);
        }
    }

    /**
     * Post请求-RestTemplate
     *
     * @param uri      Uri地址
     * @param postData å¾…发送数据
     * @return å“åº”字符串
     */
    public static String postForRest(String uri, List<NameValuePair> postData) {
        try {
            RestTemplate rest = getRestTemplate();
            UrlEncodedFormEntity entity = new UrlEncodedFormEntity(postData, StaticData.TEXT_ENCODER);

            return rest.postForObject(uri, entity, String.class);
        } catch (Exception ex) {
            log.error(ex);

            return getErrorInfo(uri, ex);
        }
    }

    /**
     * èŽ·å–错误信息
     *
     * @param uri Uri地址
     * @param ex  å¼‚常
     * @return é”™è¯¯ä¿¡æ¯
     */
    public static String getErrorInfo(String uri, Exception ex) {
        Map<String, Object> map = new LinkedHashMap<>();
        map.put("result", null);
        map.put("message", ex.getMessage());
        map.put("code", 400);
        map.put("uri", uri);
        //map.put("tag", StaticData.CACHE_PREFIX)

        return map.toString();
    }
}

 src/main/java/com/lf/server/helper/SpringContextHelper.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,56 @@
package com.lf.server.helper;

import org.springframework.beans.BeansException;
import org.springframework.context.ApplicationContext;
import org.springframework.context.ApplicationContextAware;
import org.springframework.stereotype.Component;

/**
 * Spring上下文帮助类
 * @author WWW
 */
@Component
public class SpringContextHelper implements ApplicationContextAware {
    private static ApplicationContext context = null;

    /**
     * è®¾ç½®åº”用程序上下文
     *
     * @param applicationContext
     * @throws BeansException
     */
    @Override
    public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {
        context = applicationContext;
    }

    /**
     * æ ¹æ®åç§°èŽ·å–Bean
     *
     * @param name ç±»åç§°
     * @return
     */
    public static <T> T getBean(String name) {
        return (T) context.getBean(name);
    }

    /**
     * æ ¹æ®ç±»åž‹èŽ·å–Bean
     *
     * @param clazz ç±»
     * @param <T>   æ³›åž‹
     * @return
     */
    public static <T> T getBean(Class<T> clazz) {
        return context.getBean(clazz);
    }

    /**
     * èŽ·å–当前环境
     *
     * @return Profile
     */
    public static String getActiveProfile() {
        return context.getEnvironment().getActiveProfiles()[0];
    }
}

 src/main/java/com/lf/server/interceptor/CrosFilter.java

@@ -8,10 +8,9 @@


/**
 * è·¨åŸŸè¿‡æ»¤
 * @author www
 * è·¨åŸŸè¿‡æ»¤å™¨
 * @author WWW
 * @date 2022-09-27
 * @Component("CrosFilter")
 */
public class CrosFilter implements Filter {
    private static final String OPTIONS = "OPTIONS";