sgd.git - Gitblit

			@@ -1,13 +1,31 @@
			package com.ruoyi.common.core.utils;

			import java.io.IOException;
			import java.io.UnsupportedEncodingException;
			import java.net.URLDecoder;
			import java.net.URLEncoder;
			import java.util.Collections;
			import java.util.Enumeration;
			import java.util.HashMap;
			import java.util.Map;
			import javax.servlet.ServletRequest;
			import javax.servlet.http.HttpServletRequest;
			import javax.servlet.http.HttpServletResponse;
			import javax.servlet.http.HttpSession;
			import org.springframework.core.io.buffer.DataBuffer;
			import org.springframework.http.HttpHeaders;
			import org.springframework.http.HttpStatus;
			import org.springframework.http.MediaType;
			import org.springframework.http.server.reactive.ServerHttpResponse;
			import org.springframework.util.LinkedCaseInsensitiveMap;
			import org.springframework.web.context.request.RequestAttributes;
			import org.springframework.web.context.request.RequestContextHolder;
			import org.springframework.web.context.request.ServletRequestAttributes;
			import com.alibaba.fastjson2.JSON;
			import com.ruoyi.common.core.constant.Constants;
			import com.ruoyi.common.core.domain.R;
			import com.ruoyi.common.core.text.Convert;
			import reactor.core.publisher.Mono;

			/**
			* 客户端工具类
			@@ -49,11 +67,62 @@
			}

			/**
			* 获取Boolean参数
			*/
			public static Boolean getParameterToBool(String name)
			{
			return Convert.toBool(getRequest().getParameter(name));
			}

			/**
			* 获取Boolean参数
			*/
			public static Boolean getParameterToBool(String name, Boolean defaultValue)
			{
			return Convert.toBool(getRequest().getParameter(name), defaultValue);
			}

			/**
			* 获得所有请求参数
			*
			* @param request 请求对象{@link ServletRequest}
			* @return Map
			*/
			public static Map<String, String[]> getParams(ServletRequest request)
			{
			final Map<String, String[]> map = request.getParameterMap();
			return Collections.unmodifiableMap(map);
			}

			/**
			* 获得所有请求参数
			*
			* @param request 请求对象{@link ServletRequest}
			* @return Map
			*/
			public static Map<String, String> getParamMap(ServletRequest request)
			{
			Map<String, String> params = new HashMap<>();
			for (Map.Entry<String, String[]> entry : getParams(request).entrySet())
			{
			params.put(entry.getKey(), StringUtils.join(entry.getValue(), ","));
			}
			return params;
			}

			/**
			* 获取request
			*/
			public static HttpServletRequest getRequest()
			{
			return getRequestAttributes().getRequest();
			try
			{
			return getRequestAttributes().getRequest();
			}
			catch (Exception e)
			{
			return null;
			}
			}

			/**
			@@ -61,7 +130,14 @@
			*/
			public static HttpServletResponse getResponse()
			{
			return getRequestAttributes().getResponse();
			try
			{
			return getRequestAttributes().getResponse();
			}
			catch (Exception e)
			{
			return null;
			}
			}

			/**
			@@ -74,8 +150,41 @@

			public static ServletRequestAttributes getRequestAttributes()
			{
			RequestAttributes attributes = RequestContextHolder.getRequestAttributes();
			return (ServletRequestAttributes) attributes;
			try
			{
			RequestAttributes attributes = RequestContextHolder.getRequestAttributes();
			return (ServletRequestAttributes) attributes;
			}
			catch (Exception e)
			{
			return null;
			}
			}

			public static String getHeader(HttpServletRequest request, String name)
			{
			String value = request.getHeader(name);
			if (StringUtils.isEmpty(value))
			{
			return StringUtils.EMPTY;
			}
			return urlDecode(value);
			}

			public static Map<String, String> getHeaders(HttpServletRequest request)
			{
			Map<String, String> map = new LinkedCaseInsensitiveMap<>();
			Enumeration<String> enumeration = request.getHeaderNames();
			if (enumeration != null)
			{
			while (enumeration.hasMoreElements())
			{
			String key = enumeration.nextElement();
			String value = request.getHeader(key);
			map.put(key, value);
			}
			}
			return map;
			}

			/**
			@@ -83,9 +192,8 @@
			*
			* @param response 渲染对象
			* @param string 待渲染的字符串
			* @return null
			*/
			public static String renderString(HttpServletResponse response, String string)
			public static void renderString(HttpServletResponse response, String string)
			{
			try
			{
			@@ -98,7 +206,6 @@
			{
			e.printStackTrace();
			}
			return null;
			}

			/**
			@@ -109,13 +216,13 @@
			public static boolean isAjaxRequest(HttpServletRequest request)
			{
			String accept = request.getHeader("accept");
			if (accept != null && accept.indexOf("application/json") != -1)
			if (accept != null && accept.contains("application/json"))
			{
			return true;
			}

			String xRequestedWith = request.getHeader("X-Requested-With");
			if (xRequestedWith != null && xRequestedWith.indexOf("XMLHttpRequest") != -1)
			if (xRequestedWith != null && xRequestedWith.contains("XMLHttpRequest"))
			{
			return true;
			}
			@@ -127,10 +234,100 @@
			}

			String ajax = request.getParameter("__ajax");
			if (StringUtils.inStringIgnoreCase(ajax, "json", "xml"))
			return StringUtils.inStringIgnoreCase(ajax, "json", "xml");
			}

			/**
			* 内容编码
			*
			* @param str 内容
			* @return 编码后的内容
			*/
			public static String urlEncode(String str)
			{
			try
			{
			return true;
			return URLEncoder.encode(str, Constants.UTF8);
			}
			return false;
			catch (UnsupportedEncodingException e)
			{
			return StringUtils.EMPTY;
			}
			}

			/**
			* 内容解码
			*
			* @param str 内容
			* @return 解码后的内容
			*/
			public static String urlDecode(String str)
			{
			try
			{
			return URLDecoder.decode(str, Constants.UTF8);
			}
			catch (UnsupportedEncodingException e)
			{
			return StringUtils.EMPTY;
			}
			}

			/**
			* 设置webflux模型响应
			*
			* @param response ServerHttpResponse
			* @param value 响应内容
			* @return Mono<Void>
			*/
			public static Mono<Void> webFluxResponseWriter(ServerHttpResponse response, Object value)
			{
			return webFluxResponseWriter(response, HttpStatus.OK, value, R.FAIL);
			}

			/**
			* 设置webflux模型响应
			*
			* @param response ServerHttpResponse
			* @param code 响应状态码
			* @param value 响应内容
			* @return Mono<Void>
			*/
			public static Mono<Void> webFluxResponseWriter(ServerHttpResponse response, Object value, int code)
			{
			return webFluxResponseWriter(response, HttpStatus.OK, value, code);
			}

			/**
			* 设置webflux模型响应
			*
			* @param response ServerHttpResponse
			* @param status http状态码
			* @param code 响应状态码
			* @param value 响应内容
			* @return Mono<Void>
			*/
			public static Mono<Void> webFluxResponseWriter(ServerHttpResponse response, HttpStatus status, Object value, int code)
			{
			return webFluxResponseWriter(response, MediaType.APPLICATION_JSON_VALUE, status, value, code);
			}

			/**
			* 设置webflux模型响应
			*
			* @param response ServerHttpResponse
			* @param contentType content-type
			* @param status http状态码
			* @param code 响应状态码
			* @param value 响应内容
			* @return Mono<Void>
			*/
			public static Mono<Void> webFluxResponseWriter(ServerHttpResponse response, String contentType, HttpStatus status, Object value, int code)
			{
			response.setStatusCode(status);
			response.getHeaders().add(HttpHeaders.CONTENT_TYPE, contentType);
			R<?> result = R.fail(code, value.toString());
			DataBuffer dataBuffer = response.bufferFactory().wrap(JSON.toJSONString(result).getBytes());
			return response.writeWith(Mono.just(dataBuffer));
			}
			}