uspa登录，获得登录菜单

location-rescue-service/src/main/java/com/ai/bss/location/rescue/controller/LoginController.java

@@ -0,0 +1,84 @@
package com.ai.bss.location.rescue.controller;
import com.ai.abc.api.model.CommonResponse;
import com.ai.bss.location.rescue.model.User;
import com.ai.bss.location.rescue.service.interfaces.LoginService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;
import javax.servlet.http.Cookie;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
/**
 * @Auther: 王超
 * @Date: 2020/12/24 14:05
 * @Description:
 */
@RequestMapping("/login")
@Controller
public class LoginController {
    @Autowired
    LoginService loginService;
    /**
     * 登录
     *
     * @return
     * @throws Exception
     */
    @ResponseBody
    @RequestMapping("/login")
    public Map<String, Object> login(@RequestBody User user,HttpServletResponse response){
        Map<String, Object> login = loginService.login(user);
        if(login!=null&&login.size()>0){
            Map result = (Map)login.get("RESULT");
            if(result!=null&&result.size()>0){
                Cookie userCookie1=new Cookie("session_id",(String) result.get("GLOBAL_SESSION_ID"));
                userCookie1.setMaxAge(30*60);   //存活期为30分钟
                userCookie1.setPath("/");
                response.addCookie(userCookie1);
                Cookie userCookie2=new Cookie("sign",(String) result.get("GLOBAL_SIGN"));
                userCookie2.setMaxAge(30*60);   //存活期为30分钟
                userCookie2.setPath("/");
                response.addCookie(userCookie2);
                Cookie userCookie3=new Cookie("sign_key",(String) result.get("TENANT_CODE"));
                userCookie3.setMaxAge(30*60);   //存活期为30分钟
                userCookie3.setPath("/");
                response.addCookie(userCookie3);
            }
        }
        return login;
    }
    /**
     *  获取菜单
     *
     * @return
     * @throws Exception
     */
    @ResponseBody
    @RequestMapping("/findMenus")
    public Map<String, Object> findMenus(@RequestBody User user, HttpServletRequest request){
        Map<String, Object> menus = loginService.findMenus(user,request);
        return menus;
    }
}

location-rescue-service/src/main/java/com/ai/bss/location/rescue/model/User.java

@@ -0,0 +1,24 @@
package com.ai.bss.location.rescue.model;
import lombok.Data;
/**
 * @Auther: 王超
 * @Date: 2020/12/24 15:07
 * @Description:
 */
@Data
public class User {
    //用户名
    private String userName;
    //用户编码
    private String userCode;
    //密码
    private String passWord;
    //根模块
    private String root_module;
}

location-rescue-service/src/main/java/com/ai/bss/location/rescue/service/impl/LoginServiceImpl.java

@@ -0,0 +1,115 @@
package com.ai.bss.location.rescue.service.impl;
import com.ai.abc.api.model.CommonResponse;
import com.ai.bss.location.rescue.model.User;
import com.ai.bss.location.rescue.service.interfaces.LoginService;
import com.ai.bss.location.rescue.util.HttpServiceUtil;
import com.alibaba.fastjson.JSON;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service;
import javax.servlet.http.Cookie;
import javax.servlet.http.HttpServletRequest;
import java.nio.charset.Charset;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
/**
 * @Auther: 王超
 * @Date: 2020/12/24 15:13
 * @Description:
 */
@Service
public class LoginServiceImpl implements LoginService {
    Logger logger = LoggerFactory.getLogger(LoginServiceImpl.class);
    @Value("${uspa.login.vercode}")
    private String verCode;
    @Value("${uspa.login.url}")
    private String url;
    @Value("${uspa.login.menuUrl}")
    private String menuUrl;
    @Override
    public Map<String, Object> login(User user) {
        Map resultMap=null;
        try {
            HashMap<String, Object> paramsMap = new HashMap<>();
            paramsMap.put("userCode",user.getUserCode());
            paramsMap.put("passWord",user.getPassWord());
            paramsMap.put("vercode",verCode);
            // (1)设置字符集
            Charset charset = Charset.forName("utf-8");
            String result = HttpServiceUtil.sendPost(url, paramsMap, charset);
            resultMap = JSON.parseObject(result, Map.class);
        } catch (Exception e) {
            logger.error("调用uspa登录接口失败: " + e.getMessage());
            return resultMap;
        }
        return resultMap;
    }
    @Override
    public Map<String, Object> findMenus(User user, HttpServletRequest request) {
        Map resultMap=null;
        try {
            HashMap<String, Object> paramsMap = new HashMap<>();
            paramsMap.put("root_module","0000");
            paramsMap.put("userCode",user.getUserCode());
            Map<String, String> headerMap=new HashMap<>();
            // 取得cookie
            Cookie[] cookies = request.getCookies();
            if (cookies != null) {
                for (Cookie cookie : cookies) {
                    if (cookie.getName().equals("session_id")) {
                        headerMap.put("session_id", cookie.getValue());
                    }
                    if (cookie.getName().equals("sign")) {
                        headerMap.put("sign", cookie.getValue());
                    }
                    if (cookie.getName().equals("sign_key")) {
                        headerMap.put("sign_key", cookie.getValue());
                    }
                }
            }
            Map<String, String> headerMap1=new HashMap<>();
            //将设置拼接cookie
            headerMap1.put("Cookie","session_id="+headerMap.get("session_id")+";"+"sign="+headerMap.get("sign")+";"+"sign_key="+headerMap.get("sign_key"));
            // (1)设置字符集
            Charset charset = Charset.forName("utf-8");
            String result = HttpServiceUtil.sendPost(menuUrl, paramsMap, charset,headerMap1 );
            //将返回结果转为map
            resultMap = JSON.parseObject(result, Map.class);
            String result1 = (String)resultMap.get("RESULT");
            if(null!=result1&&!"".equals(result1)){
                //如果result有值返回正确，将返回结果转为List
                List<Map<String,List<Map>>> list = JSON.parseObject(result1, List.class);
                resultMap.put("RESULT",list);
            }
        } catch (Exception e) {
            logger.error("调用uspa获取菜单接口失败: " + e.getMessage());
            return resultMap;
        }
        return resultMap;
    }
}

location-rescue-service/src/main/java/com/ai/bss/location/rescue/service/interfaces/LoginService.java

@@ -0,0 +1,22 @@
package com.ai.bss.location.rescue.service.interfaces;
import com.ai.abc.api.model.CommonResponse;
import com.ai.bss.location.rescue.model.User;
import javax.servlet.http.HttpServletRequest;
import java.util.List;
import java.util.Map;
/**
 * @Auther: 王超
 * @Date: 2020/12/24 15:12
 * @Description:
 */
public interface LoginService {
    Map<String, Object> findMenus(User user, HttpServletRequest request);
    Map<String, Object> login(User user);
}

location-rescue-service/src/main/resources/application.properties

@@ -64,4 +64,9 @@ logging.level.com.ai=debug
logging.level.org.springframework.data=debug
# \u5f15\u5165gis\u548ciot\u7684\u914d\u7f6e\u6587\u4ef6
spring.profiles.active=iot,gis
spring.profiles.active=iot,gis
uspa.login.url=http://10.19.90.34:20000/usermng/login
uspa.login.vercode=Hiz#8uAqkjhoPmXu8%aaa
uspa.login.menuUrl=http://10.19.90.34:20000/usermng/process/com.wframe.usermanager.services.impl.QueryMenuByUser

security-protection-service/pom.xml

@@ -134,12 +134,11 @@
		</dependency>
        <!-- uspa登录拦截效验-->
<!--        <dependency>-->
<!--            <groupId>com.wframe</groupId>-->
<!--            <artifactId>sso-util</artifactId>-->
<!--            <version>1.2</version>-->
<!--        </dependency>-->
        <dependency>
            <groupId>com.wframe</groupId>
            <artifactId>sso-util</artifactId>
            <version>1.2</version>
        </dependency>
        <!-- 缓存 -->
        <dependency>

security-protection-service/src/main/java/com/ai/bss/security/protection/config/MyCorsFilter.java

@@ -0,0 +1,60 @@
package com.ai.bss.security.protection.config;
import com.ai.sso.filter.SessionUserFilter;
import org.springframework.boot.web.servlet.FilterRegistrationBean;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.web.cors.CorsConfiguration;
import org.springframework.web.cors.UrlBasedCorsConfigurationSource;
import org.springframework.web.filter.CorsFilter;
import java.util.Arrays;
import java.util.HashMap;
import java.util.Map;
/**
 * 解决接口跨域问题
 *
 * @Auther: lihousheng
 * @Date: 2018/8/17 14:05
 */
@Configuration
public class MyCorsFilter {
    /**
     * attention:简单跨域就是GET，HEAD和POST请求，但是POST请求的"Content-Type"只能是application/x-www-form-urlencoded, multipart/form-data 或 text/plain
     * 反之，就是非简单跨域，此跨域有一个预检机制，说直白点，就是会发两次请求，一次OPTIONS请求，一次真正的请求
     */
    @Bean
    public CorsFilter corsFilter() {
        final UrlBasedCorsConfigurationSource source = new UrlBasedCorsConfigurationSource();
        final CorsConfiguration config = new CorsConfiguration();
        config.setAllowCredentials(true); // 允许cookies跨域
        config.addAllowedOrigin("*");// #允许向该服务器提交请求的URI，*表示全部允许，在SpringMVC中，如果设成*，会自动转成当前请求头中的Origin
        config.addAllowedHeader("*");// #允许访问的头信息,*表示全部
        config.setMaxAge(18000L);// 预检请求的缓存时间（秒），即在这个时间段里，对于相同的跨域请求不会再预检了
        config.addAllowedMethod("OPTIONS");// 允许提交请求的方法，*表示全部允许
        config.addAllowedMethod("HEAD");
        config.addAllowedMethod("GET");// 允许Get的请求方法
        config.addAllowedMethod("PUT");
        config.addAllowedMethod("POST");
        config.addAllowedMethod("DELETE");
        config.addAllowedMethod("PATCH");
        source.registerCorsConfiguration("/**", config);
        return new CorsFilter(source);
    }
    @Bean
    public FilterRegistrationBean mySessionUserFilter(){
        FilterRegistrationBean registrationBean = new FilterRegistrationBean();
        registrationBean.setFilter(new SessionUserFilter());
        registrationBean.setUrlPatterns(Arrays.asList("/mySessionUserFilter"));
        Map<String, String> initParameters = new HashMap<String,String>();
        initParameters.put("impl-classname","com.ai.sso.external.DefaultPopedomImpl");
        initParameters.put("ALLOWPATH","gif;jpg;jpeg;png;login;checkLogin;genVerificationCode;logout;");
        registrationBean.setInitParameters(initParameters);
        return registrationBean;
    }
}

security-protection-service/src/main/java/com/ai/bss/security/protection/controller/AiAlarmManageController.java

@@ -1,5 +1,6 @@
package com.ai.bss.security.protection.controller;
import java.util.ArrayList;
import java.util.Date;
import java.util.HashMap;
import java.util.Map;
@@ -55,6 +56,8 @@ public class AiAlarmManageController {
		// 每页条数
		int pageSize = aiQuery.getPageSize() < 1 ? EbcConstant.DEFAULT_PAGE_SIZE : aiQuery.getPageSize();
		ArrayList<Object> statusList = new ArrayList<>();
		statusList.add(aiQuery.getStatusList());
		Map<String, Object> params = new HashMap<>();
		params.put("workOrgRoleId", aiQuery.getWorkOrgRoleId());
		params.put("alarmTypeCode", aiQuery.getAlarmTypeCode());
@@ -62,7 +65,7 @@ public class AiAlarmManageController {
		params.put("workEmployeeRoleId", aiQuery.getWorkEmployeeRoleId());
		params.put("beginTime", aiQuery.getBeginTime());
		params.put("endTime", aiQuery.getEndTime());
		params.put("statusList", aiQuery.getStatusList());
		params.put("statusList",statusList);
		CommonResponse<PageBean<Map<String, Object>>> commonResponse = aiAlarmManageService.queryPageAiAlarm(params,
				pageNumber, pageSize);

security-protection-service/src/main/java/com/ai/bss/security/protection/controller/LoginController.java

@@ -0,0 +1,81 @@
package com.ai.bss.security.protection.controller;
import com.ai.bss.security.protection.model.User;
import com.ai.bss.security.protection.service.interfaces.LoginService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;
import javax.servlet.http.Cookie;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.util.Map;
/**
 * @Auther: 王超
 * @Date: 2020/12/24 14:05
 * @Description:
 */
@RequestMapping("/login")
@Controller
public class LoginController {
    @Autowired
    LoginService loginService;
    /**
     * 登录
     *
     * @return
     * @throws Exception
     */
    @ResponseBody
    @RequestMapping("/login")
    public Map<String, Object> login(@RequestBody User user, HttpServletResponse response){
        Map<String, Object> login = loginService.login(user);
        if(login!=null&&login.size()>0){
            Map result = (Map)login.get("RESULT");
            if(result!=null&&result.size()>0){
                Cookie userCookie1=new Cookie("session_id",(String) result.get("GLOBAL_SESSION_ID"));
                userCookie1.setMaxAge(30*60);   //存活期为30分钟
                userCookie1.setPath("/");
                response.addCookie(userCookie1);
                Cookie userCookie2=new Cookie("sign",(String) result.get("GLOBAL_SIGN"));
                userCookie2.setMaxAge(30*60);   //存活期为30分钟
                userCookie2.setPath("/");
                response.addCookie(userCookie2);
                Cookie userCookie3=new Cookie("sign_key",(String) result.get("TENANT_CODE"));
                userCookie3.setMaxAge(30*60);   //存活期为30分钟
                userCookie3.setPath("/");
                response.addCookie(userCookie3);
            }
        }
        return login;
    }
    /**
     *  获取菜单
     *
     * @return
     * @throws Exception
     */
    @ResponseBody
    @RequestMapping("/findMenus")
    public Map<String, Object> findMenus(@RequestBody User user, HttpServletRequest request){
        Map<String, Object> menus = loginService.findMenus(user,request);
        return menus;
    }
}

security-protection-service/src/main/java/com/ai/bss/security/protection/model/AiQuery.java

@@ -5,6 +5,8 @@ import lombok.Getter;
import lombok.NoArgsConstructor;
import lombok.Setter;
import java.util.List;
/**
 * @Auther: 王超
 * @Date: 2020/12/8 17:37

security-protection-service/src/main/java/com/ai/bss/security/protection/model/User.java

@@ -0,0 +1,24 @@
package com.ai.bss.security.protection.model;
import lombok.Data;
/**
 * @Auther: 王超
 * @Date: 2020/12/24 15:07
 * @Description:
 */
@Data
public class User {
    //用户名
    private String userName;
    //用户编码
    private String userCode;
    //密码
    private String passWord;
    //根模块
    private String root_module;
}

security-protection-service/src/main/java/com/ai/bss/security/protection/service/impl/LoginServiceImpl.java

@@ -0,0 +1,115 @@
package com.ai.bss.security.protection.service.impl;
import com.ai.bss.security.protection.model.User;
import com.ai.bss.security.protection.service.interfaces.LoginService;
import com.ai.bss.security.protection.utils.HttpServiceUtil;
import com.alibaba.fastjson.JSON;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service;
import javax.servlet.http.Cookie;
import javax.servlet.http.HttpServletRequest;
import java.nio.charset.Charset;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
/**
 * @Auther: 王超
 * @Date: 2020/12/24 15:13
 * @Description:
 */
@Service
public class LoginServiceImpl implements LoginService {
    Logger logger = LoggerFactory.getLogger(LoginServiceImpl.class);
    @Value("${uspa.login.vercode}")
    private String verCode;
    @Value("${uspa.login.url}")
    private String url;
    @Value("${uspa.login.menuUrl}")
    private String menuUrl;
    @Override
    public Map<String, Object> login(User user) {
        Map resultMap=null;
        try {
            HashMap<String, Object> paramsMap = new HashMap<>();
            paramsMap.put("userCode",user.getUserCode());
            paramsMap.put("passWord",user.getPassWord());
            paramsMap.put("vercode",verCode);
            // (1)设置字符集
            Charset charset = Charset.forName("utf-8");
            String result = HttpServiceUtil.sendPost(url, paramsMap, charset);
            resultMap = JSON.parseObject(result, Map.class);
        } catch (Exception e) {
            logger.error("调用uspa登录接口失败: " + e.getMessage());
            return resultMap;
        }
        return resultMap;
    }
    @Override
    public Map<String, Object> findMenus(User user, HttpServletRequest request) {
        Map resultMap=null;
        try {
            HashMap<String, Object> paramsMap = new HashMap<>();
            paramsMap.put("root_module","0000");
            paramsMap.put("userCode",user.getUserCode());
            Map<String, String> headerMap=new HashMap<>();
            // 取得cookie
            Cookie[] cookies = request.getCookies();
            if (cookies != null) {
                for (Cookie cookie : cookies) {
                    if (cookie.getName().equals("session_id")) {
                        headerMap.put("session_id", cookie.getValue());
                    }
                    if (cookie.getName().equals("sign")) {
                        headerMap.put("sign", cookie.getValue());
                    }
                    if (cookie.getName().equals("sign_key")) {
                        headerMap.put("sign_key", cookie.getValue());
                    }
                }
            }
            Map<String, String> headerMap1=new HashMap<>();
            //将设置拼接cookie
            headerMap1.put("Cookie","session_id="+headerMap.get("session_id")+";"+"sign="+headerMap.get("sign")+";"+"sign_key="+headerMap.get("sign_key"));
            // (1)设置字符集
            Charset charset = Charset.forName("utf-8");
            String result = HttpServiceUtil.sendPost(menuUrl, paramsMap, charset,headerMap1 );
            //将返回结果转为map
            resultMap = JSON.parseObject(result, Map.class);
            String result1 = (String)resultMap.get("RESULT");
            if(null!=result1&&!"".equals(result1)){
                //如果result有值返回正确，将返回结果转为List
                List<Map<String,List<Map>>> list = JSON.parseObject(result1, List.class);
                resultMap.put("RESULT",list);
            }
        } catch (Exception e) {
            logger.error("调用uspa获取菜单接口失败: " + e.getMessage());
            return resultMap;
        }
        return resultMap;
    }
}

security-protection-service/src/main/java/com/ai/bss/security/protection/service/interfaces/LoginService.java

@@ -0,0 +1,22 @@
package com.ai.bss.security.protection.service.interfaces;
import com.ai.bss.security.protection.model.User;
import javax.servlet.http.HttpServletRequest;
import java.util.Map;
/**
 * @Auther: 王超
 * @Date: 2020/12/24 15:12
 * @Description:
 */
public interface LoginService {
    Map<String, Object> findMenus(User user, HttpServletRequest request);
    Map<String, Object> login(User user);
}

security-protection-service/src/main/java/com/ai/bss/security/protection/utils/HttpServiceUtil.java

@@ -0,0 +1,295 @@
package com.ai.bss.security.protection.utils;
import com.alibaba.fastjson.JSONObject;
import org.apache.http.HttpEntity;
import org.apache.http.HttpStatus;
import org.apache.http.client.ClientProtocolException;
import org.apache.http.client.HttpClient;
import org.apache.http.client.config.RequestConfig;
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.client.methods.HttpPut;
import org.apache.http.entity.StringEntity;
import org.apache.http.entity.mime.MultipartEntityBuilder;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.HttpClients;
import org.apache.http.protocol.HTTP;
import org.apache.http.util.EntityUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.util.CollectionUtils;
import java.io.*;
import java.net.HttpURLConnection;
import java.net.URL;
import java.net.URLEncoder;
import java.nio.charset.Charset;
import java.util.Iterator;
import java.util.Map;
import java.util.Set;
/**
 * http服务请求工具类
 *
 * @author chencai
 */
public class HttpServiceUtil {
	static Logger log = LoggerFactory.getLogger(HttpServiceUtil.class);
	private static final String HTTP_CONTENT_TYPE_JSON = "application/json; charset=utf-8";
	public static String buildUrl(Map<String, String> paramMap, String serviceUrl) {
		String url = null;
		StringBuffer urlString = new StringBuffer();
		urlString.append(serviceUrl);
		if (!paramMap.isEmpty()) {
			// 参数列表不为空，地址尾部增加'?'
			urlString.append('?');
			// 拼接参数
			Set<Map.Entry<String, String>> entrySet = paramMap.entrySet();
			for (Map.Entry<String, String> entry : entrySet) {
				try {
					urlString.append(entry.getKey()).append('=').append(URLEncoder.encode(entry.getValue(), "UTF-8"))
							.append('&');
				} catch (UnsupportedEncodingException e) {
					log.error(" Exception: " + e);
				}
			}
			// 去掉最后一个字符“&”
			url = urlString.substring(0, urlString.length() - 1);
		}
		return url;
	}
	public static String sendRequest(String url) {
		InputStream inputStream = null;
		BufferedReader bufferedReader = null;
		HttpURLConnection httpURLConnection = null;
		try {
			log.error("It's not error. request url: " + url);
			URL requestURL = new URL(url);
			// 获取连接
			httpURLConnection = (HttpURLConnection) requestURL.openConnection();
			httpURLConnection.setConnectTimeout(10000); // 建立连接的超时时间，毫秒
			httpURLConnection.setReadTimeout(25000); // 获得返回的超时时间，毫秒
			httpURLConnection.setRequestMethod("GET");
			httpURLConnection.setRequestProperty("Content-type", "text/html;charset=UTF-8");
			httpURLConnection.setRequestProperty("Accept",
					"text/html,application/xhtml+xml,application/xml;q=0.9,image/webp,image/apng,*/*;q=0.8");
			// 通过输入流获取请求的内容
			inputStream = httpURLConnection.getInputStream();
			bufferedReader = new BufferedReader(new InputStreamReader(inputStream, "UTF-8"));
			String temp = null;
			StringBuffer stringBuffer = new StringBuffer();
			// 循环读取返回的结果
			while ((temp = bufferedReader.readLine()) != null) {
				stringBuffer.append(temp);
			}
			return stringBuffer.toString();
		} catch (Exception e) {
			log.error("sendRequest Exception: " + e);
		} finally {
			// 断开连接
			if (httpURLConnection != null) {
				httpURLConnection.disconnect();
			}
			// 关闭流
			if (bufferedReader != null) {
				try {
					bufferedReader.close();
				} catch (IOException e) {
					log.error("bufferedReader Exception: " + e);
				}
			}
			if (inputStream != null) {
				try {
					inputStream.close();
				} catch (IOException e) {
					log.error("inputStream Exception: " + e);
				}
			}
		}
		return null;
	}
	public static String sendPostRequest(String url, Map<String, String> map, String encoding) {
		String retStr = "";
		try {
			retStr = sendPostRequest(url, map, encoding, 0, 0);
		} catch (Exception ex) {
			log.error("sendPostRequest error: " + ex);
		}
		return retStr;
	}
	public static String sendPostRequest(String url, Map<String, String> map, String encoding, int ebossConnectTimeout,
			int ebossServiceTimeout) {
		CloseableHttpClient httpClient = HttpClients.createDefault();
		HttpPost httpPost = new HttpPost(url);
		String body = "";
		try {
			MultipartEntityBuilder multipartEntityBuilder = MultipartEntityBuilder.create();
			if (map != null) {
				for (Map.Entry<String, String> entry : map.entrySet()) {
					multipartEntityBuilder.addTextBody(entry.getKey(), entry.getValue());
				}
			}
			log.debug("ebossConnectTimeout:" + ebossConnectTimeout);
			log.debug("ebossServiceTimeout:" + ebossServiceTimeout);
			httpPost.setEntity(multipartEntityBuilder.build());
			if (ebossConnectTimeout != 0 && ebossServiceTimeout != 0) {
				RequestConfig requestConfig = RequestConfig.custom().setSocketTimeout(ebossServiceTimeout)
						.setConnectTimeout(ebossConnectTimeout).build();// 设置请求和传输超时时间
				httpPost.setConfig(requestConfig);
			}
			CloseableHttpResponse response = httpClient.execute(httpPost);
			if (response.getStatusLine().getStatusCode() == HttpStatus.SC_OK) {
				HttpEntity entity = response.getEntity();
				if (entity != null) {
					// 按指定编码转换结果实体为String类型
					body = EntityUtils.toString(entity, encoding);
				}
				EntityUtils.consume(entity);
			}
		} catch (ClientProtocolException e) {
			log.error("ClientProtocolException Exception: " + e);
		} catch (UnsupportedEncodingException e) {
			log.error("UnsupportedEncodingException Exception: " + e);
		} catch (IOException e) {
			log.error("IOException Exception: " + e);
			// throw new BaseException("10", "调用Eboss超时");
		} finally {
			// 关闭连接,释放资源
			try {
				httpClient.close();
			} catch (IOException e) {
				log.error("httpClient Exception: " + e);
			}
		}
		return body;
	}
	public static String sendGet(String url, Charset encoding, Map<String, String> headerMap) {
		HttpClient httpClient = HttpClients.createDefault();
		HttpGet httpGet = new HttpGet(url);
		httpGet.addHeader(HTTP.CONTENT_TYPE, HTTP_CONTENT_TYPE_JSON);
		CloseableHttpResponse response = null;
		try {
			log.debug("执行GET请求：url= " + url);
			response = (CloseableHttpResponse) httpClient.execute(httpGet);
		} catch (Exception e) {
			log.error("sendGet Exception: " + e.getMessage());
			return "{}";
		}
		return responseEx(httpClient, response, encoding);
	}
	public static String sendPost(String url, Map<String, Object> paramsMap, Charset encoding) {
		HttpClient httpClient = HttpClients.createDefault();
		HttpPost httpPost = new HttpPost(url);
		httpPost.addHeader(HTTP.CONTENT_TYPE, HTTP_CONTENT_TYPE_JSON);
		if (!CollectionUtils.isEmpty(paramsMap)) {
			StringEntity se = new StringEntity(JSONObject.toJSONString(paramsMap), encoding);
			httpPost.setEntity(se);
		}
		CloseableHttpResponse response = null;
		try {
			log.debug("执行POST无参请求：url= " + url);
			response = (CloseableHttpResponse) httpClient.execute(httpPost);
		} catch (Exception e) {
			log.error("sendPost Exception: " + e.getMessage());
			return "{}";
		}
		return responseEx(httpClient, response, encoding);
	}
	public static String sendPost(String url, Map<String, Object> paramsMap, Charset encoding,
			Map<String, String> headerMap) {
		HttpClient httpClient = HttpClients.createDefault();
		HttpPost httpPost = new HttpPost(url);
		Iterator<String> iter = headerMap.keySet().iterator();
		String key = "";
		String value = "";
		while (iter.hasNext()) {
			key = iter.next();
			value = headerMap.get(key);
			httpPost.setHeader(key, value);
		}
		httpPost.addHeader(HTTP.CONTENT_TYPE, HTTP_CONTENT_TYPE_JSON);
		if (!CollectionUtils.isEmpty(paramsMap)) {
			log.debug("执行POST请求：url= " + url + ",参数= " + JSONObject.toJSONString(paramsMap));
			StringEntity se = new StringEntity(JSONObject.toJSONString(paramsMap), encoding);
			httpPost.setEntity(se);
		}
		CloseableHttpResponse response = null;
		try {
			response = (CloseableHttpResponse) httpClient.execute(httpPost);
		} catch (Exception e) {
			log.error("sendPost Exception: " + e.getMessage());
			return "{}";
		}
		return responseEx(httpClient, response, encoding);
	}
	public static String sendPut(String url, Map<String, Object> paramsMap, Charset encoding) {
		HttpClient httpClient = HttpClients.createDefault();
		String resp = "";
		HttpPut httpPut = new HttpPut(url);
		httpPut.addHeader(HTTP.CONTENT_TYPE, HTTP_CONTENT_TYPE_JSON);
		if (!CollectionUtils.isEmpty(paramsMap)) {
			StringEntity se = new StringEntity(JSONObject.toJSONString(paramsMap), encoding);
			httpPut.setEntity(se);
		}
		CloseableHttpResponse response = null;
		try {
			log.debug("执行PUT请求：url= " + url + ",参数= " + JSONObject.toJSONString(paramsMap));
			response = (CloseableHttpResponse) httpClient.execute(httpPut);
		} catch (Exception e) {
			log.error("sendPut Exception: " + e.getMessage());
			return "{}";
		}
		return responseEx(httpClient, response, encoding);
	}
	private static String responseEx(HttpClient httpClient, CloseableHttpResponse response, Charset encoding) {
		String resp = "";
		try {
			if (response == null) {
				resp = "{}";
				log.error("请求执行失败，无返回信息");
			} else if (200 != response.getStatusLine().getStatusCode()) {
				resp = "{}";
				log.error("请求执行失败，状态码=" + response.getStatusLine().getStatusCode() + "，返回信息="
						+ EntityUtils.toString(response.getEntity(), encoding));
			} else {
				log.debug("请求执行成功");
				resp = EntityUtils.toString(response.getEntity(), encoding);
			}
		} catch (Exception e) {
			log.error("responseEx Exception: " + e.getMessage());
		} finally {
			if (response != null) {
				try {
					response.close();
				} catch (Exception e) {
					log.error("responseEx Exception: " + e.getMessage());
				}
			}
		}
		return resp;
	}
}

security-protection-service/src/main/resources/application.properties

@@ -89,3 +89,8 @@ spring.servlet.multipart.resolve-lazily=false
# LOGGING
logging.level.com.ai=debug
logging.level.org.springframework.data=debug
uspa.login.url=http://10.19.90.34:20000/usermng/login
uspa.login.vercode=Hiz#8uAqkjhoPmXu8%aaa
uspa.login.menuUrl=http://10.19.90.34:20000/usermng/process/com.wframe.usermanager.services.impl.QueryMenuByUser