You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
342 lines
13 KiB
342 lines
13 KiB
package com.fr.plugin.third.party.jsdbabbe; |
|
|
|
import com.fanruan.api.log.LogKit; |
|
import com.fanruan.api.util.StringKit; |
|
import com.fr.decision.authority.data.User; |
|
import com.fr.decision.webservice.bean.user.UserBean; |
|
import com.fr.decision.webservice.bean.user.UserUpdateBean; |
|
import com.fr.decision.webservice.impl.user.UserPageQueryAuthorityParam; |
|
import com.fr.decision.webservice.utils.ControllerFactory; |
|
import com.fr.decision.webservice.utils.controller.UserController; |
|
import com.fr.decision.webservice.v10.user.UserService; |
|
import com.fr.plugin.third.party.jsdbabbe.config.CustomDataConfig; |
|
import com.fr.stable.StringUtils; |
|
import com.fr.stable.query.data.DataList; |
|
import com.fr.stable.query.restriction.Restriction; |
|
import com.fr.third.org.apache.http.HttpEntity; |
|
import com.fr.third.org.apache.http.HttpStatus; |
|
import com.fr.third.org.apache.http.client.config.RequestConfig; |
|
import com.fr.third.org.apache.http.client.methods.CloseableHttpResponse; |
|
import com.fr.third.org.apache.http.client.methods.HttpGet; |
|
import com.fr.third.org.apache.http.client.methods.HttpPost; |
|
import com.fr.third.org.apache.http.conn.ssl.NoopHostnameVerifier; |
|
import com.fr.third.org.apache.http.conn.ssl.SSLConnectionSocketFactory; |
|
import com.fr.third.org.apache.http.entity.StringEntity; |
|
import com.fr.third.org.apache.http.impl.client.CloseableHttpClient; |
|
import com.fr.third.org.apache.http.impl.client.HttpClients; |
|
import com.fr.third.org.apache.http.ssl.SSLContextBuilder; |
|
import com.fr.third.org.apache.http.ssl.TrustStrategy; |
|
import com.fr.third.org.apache.http.util.EntityUtils; |
|
|
|
import javax.net.ssl.HostnameVerifier; |
|
import javax.net.ssl.SSLContext; |
|
import javax.servlet.http.HttpServletRequest; |
|
import javax.servlet.http.HttpServletResponse; |
|
import java.io.IOException; |
|
import java.security.cert.CertificateException; |
|
import java.security.cert.X509Certificate; |
|
import java.util.ArrayList; |
|
import java.util.List; |
|
import java.util.Map; |
|
import java.util.UUID; |
|
|
|
public class Utils { |
|
public static String DEFAULT_USER_AGENT = "Mozilla/5.0 (Windows NT 6.1; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/83.0.4103.61 Safari/537.36"; |
|
public static RequestConfig REQUEST_CONFIG = RequestConfig.custom() |
|
.setConnectionRequestTimeout(30000) |
|
.setSocketTimeout(30000) // 服务端相应超时 |
|
.setConnectTimeout(30000) // 建立socket链接超时时间 |
|
.build(); |
|
|
|
public static CloseableHttpClient createSslHttpClient() { |
|
try { |
|
SSLContext sslContext = new SSLContextBuilder().loadTrustMaterial(null, new TrustStrategy() { |
|
|
|
@Override |
|
public boolean isTrusted(X509Certificate[] chain, String authType) throws CertificateException { |
|
return true; |
|
} |
|
}).build(); |
|
HostnameVerifier hostnameVerifier = NoopHostnameVerifier.INSTANCE; |
|
SSLConnectionSocketFactory sslsf = new SSLConnectionSocketFactory(sslContext, hostnameVerifier); |
|
return HttpClients.custom() |
|
.setSSLSocketFactory(sslsf) |
|
.build(); |
|
} catch (Exception e) { |
|
LogKit.error(e.getMessage(), e); |
|
} |
|
return HttpClients.createDefault(); |
|
} |
|
|
|
public static CloseableHttpClient createDefaultHttpClient() { |
|
CloseableHttpClient httpClient = HttpClients.custom() |
|
.build(); |
|
return httpClient; |
|
} |
|
|
|
public static synchronized CloseableHttpClient createHttpClient(String url) { |
|
CloseableHttpClient httpClient = null; |
|
if (StringKit.isEmpty(url)) { |
|
httpClient = createDefaultHttpClient(); |
|
return httpClient; |
|
} |
|
|
|
if (url.startsWith("https://")) { |
|
httpClient = createSslHttpClient(); |
|
return httpClient; |
|
} |
|
httpClient = createDefaultHttpClient(); |
|
return httpClient; |
|
} |
|
|
|
public static synchronized String createHttpGetContent(CloseableHttpClient httpClient, String url, String basicAuth) throws IOException { |
|
if ((httpClient == null) || (StringKit.isEmpty(url))) { |
|
return ""; |
|
} |
|
|
|
HttpGet httpGet = new HttpGet(url); |
|
httpGet.addHeader("User-Agent", Utils.DEFAULT_USER_AGENT); |
|
if (StringKit.isNotEmpty(basicAuth)) { |
|
httpGet.addHeader("Authorization", basicAuth); |
|
} |
|
|
|
httpGet.setConfig(Utils.REQUEST_CONFIG); |
|
CloseableHttpResponse response = httpClient.execute(httpGet); |
|
int statusCode = response.getStatusLine().getStatusCode(); |
|
if (statusCode != HttpStatus.SC_OK) { |
|
response.close(); |
|
LogKit.info("http请求出错,http status:" + statusCode); |
|
return ""; |
|
} |
|
|
|
HttpEntity httpEntity = response.getEntity(); |
|
if (httpEntity == null) { |
|
response.close(); |
|
LogKit.info("http请求出错,http响应内容为空"); |
|
return ""; |
|
} |
|
String responseContent = EntityUtils.toString(httpEntity, "UTF-8"); |
|
response.close(); |
|
if (StringKit.isEmpty(responseContent)) { |
|
LogKit.info("http请求出错,http响应内容为空1"); |
|
return ""; |
|
} |
|
return responseContent; |
|
} |
|
|
|
public static synchronized String createHttpPostContent(CloseableHttpClient httpClient, String url, String bodyContent, String basicAuth, String contentType, Map<String, String> headers) throws IOException { |
|
if ((httpClient == null) || (StringKit.isEmpty(url))) { |
|
return ""; |
|
} |
|
|
|
HttpPost httpPost = new HttpPost(url); |
|
httpPost.addHeader("User-Agent", Utils.DEFAULT_USER_AGENT); |
|
httpPost.setConfig(Utils.REQUEST_CONFIG); |
|
if (StringKit.isNotEmpty(basicAuth)) { |
|
httpPost.addHeader("Authorization", basicAuth); |
|
} |
|
if ((headers != null) && (headers.size() >= 1)) { |
|
for (Map.Entry<String,String> entry: headers.entrySet()) { |
|
httpPost.addHeader(entry.getKey(), entry.getValue()); |
|
} |
|
} |
|
|
|
if (StringKit.isNotEmpty(contentType)) { |
|
httpPost.addHeader("Content-Type", contentType); |
|
} |
|
StringEntity bodyEntity = new StringEntity(bodyContent, "UTF-8"); |
|
httpPost.setEntity(bodyEntity); |
|
CloseableHttpResponse response = httpClient.execute(httpPost); |
|
int statusCode = response.getStatusLine().getStatusCode(); |
|
if (statusCode != HttpStatus.SC_OK) { |
|
response.close(); |
|
LogKit.info("http请求出错,http status:" + statusCode); |
|
return ""; |
|
} |
|
|
|
HttpEntity httpEntity = response.getEntity(); |
|
if (httpEntity == null) { |
|
response.close(); |
|
LogKit.info("http请求出错,http响应内容为空"); |
|
return ""; |
|
} |
|
String responseContent = EntityUtils.toString(httpEntity, "UTF-8"); |
|
response.close(); |
|
if (StringKit.isEmpty(responseContent)) { |
|
LogKit.info("http请求出错,http响应内容为空1"); |
|
return ""; |
|
} |
|
return responseContent; |
|
} |
|
|
|
|
|
/** |
|
* 获取完整请求链接 |
|
* |
|
* @param req 请求 |
|
* @return |
|
*/ |
|
public static String getFullRequestUrl(HttpServletRequest req) { |
|
if (req == null) { |
|
return ""; |
|
} |
|
String url = req.getRequestURL().toString(); |
|
String queryUrl = req.getQueryString(); |
|
if ((queryUrl == null) || "null".equalsIgnoreCase(queryUrl)) { |
|
queryUrl = ""; |
|
} else { |
|
queryUrl = "?" + queryUrl; |
|
} |
|
String fullUrl = url + queryUrl; |
|
return fullUrl; |
|
} |
|
|
|
|
|
/** |
|
* 重定向 |
|
* |
|
* @param res |
|
* @param url |
|
*/ |
|
public static void sendRedirect(HttpServletResponse res, String url) { |
|
if ((res == null) || (StringKit.isEmpty(url))) { |
|
return; |
|
} |
|
res.setStatus(HttpServletResponse.SC_MOVED_TEMPORARILY); |
|
res.setHeader("Location", url); |
|
} |
|
|
|
|
|
public static synchronized String getUuid() { |
|
String uuid = UUID.randomUUID().toString().replace("-", ""); |
|
return uuid; |
|
} |
|
|
|
|
|
/** |
|
* 获取用户信息 |
|
* |
|
* @param userCount 用户数,-1为不限制用户数 |
|
* @param isAdminContained 是否包含管理员用户 |
|
* @return |
|
* @throws Exception |
|
*/ |
|
public static List<UserBean> getAllUsers(int userCount, boolean isAdminContained) throws Exception { |
|
List<UserBean> userBeans = new ArrayList<>(); |
|
if (userCount == 0) { |
|
return userBeans; |
|
} |
|
int limitCount = userCount; |
|
if (userCount <= -1) { |
|
limitCount = Integer.MAX_VALUE; |
|
} |
|
List<String> adminUserIds = UserService.getInstance().getAdminUserIdList(); |
|
if ((adminUserIds == null) || (adminUserIds.size() <= 0)) { |
|
return userBeans; |
|
} |
|
String adminUserId = adminUserIds.get(0); |
|
|
|
UserController userController = ControllerFactory.getInstance().getUserController(adminUserId); |
|
|
|
DataList dataList = userController.findPageUsersPerfectMatch(adminUserId, new UserPageQueryAuthorityParam(1, limitCount, "", null), new Restriction[0]); |
|
if (dataList == null) { |
|
return userBeans; |
|
} |
|
List users = dataList.getList(); |
|
if ((users == null) || (users.size() <= 0)) { |
|
return userBeans; |
|
} |
|
User user; |
|
UserBean userBean; |
|
String userId; |
|
for (int i = 0, max = users.size() - 1; i <= max; i++) { |
|
user = (User) users.get(i); |
|
userId = user.getId(); |
|
if ((!isAdminContained) && (adminUserIds.contains(userId))) { |
|
continue; |
|
} |
|
userBean = new UserBean(user.getEmail(), user.isEnable(), user.getMobile(), user.getRealName(), user.getUserName(), user.getId()); |
|
userBean.setCreationType(user.getCreationType().toInteger()); |
|
userBeans.add(userBean); |
|
} |
|
return userBeans; |
|
} |
|
|
|
|
|
/** |
|
* 获取不包含管理员的用户信息 |
|
* |
|
* @param userCount |
|
* @return |
|
* @throws Exception |
|
*/ |
|
public static List<UserBean> getAllUsersWithoutAdmin(int userCount) throws Exception { |
|
return getAllUsers(userCount, false); |
|
} |
|
|
|
public static List<String> getAllUserNames(int userCount, boolean isAdminContained) throws Exception { |
|
List<String> userNames = new ArrayList<>(); |
|
List<UserBean> userBeans = getAllUsers(userCount, isAdminContained); |
|
UserBean userBean; |
|
for (int i = 0, max = userBeans.size() - 1; i <= max; i++) { |
|
userBean = userBeans.get(i); |
|
userNames.add(userBean.getUsername()); |
|
} |
|
return userNames; |
|
} |
|
|
|
public static List<String> getAllUserNamesWithoutAdmin(int userCount) throws Exception { |
|
return getAllUserNames(userCount, false); |
|
} |
|
|
|
/** |
|
* 通过用户名删除用户,管理员用户无法删除 |
|
* |
|
* @param username 用户名 |
|
* @return |
|
* @throws Exception |
|
*/ |
|
public static int deleteUsersByUsername(String username) throws Exception { |
|
if (StringUtils.isEmpty(username)) { |
|
return 0; |
|
} |
|
User user = UserService.getInstance().getUserByUserName(username); |
|
if (user == null) { |
|
return 0; |
|
} |
|
String userId = user.getId(); |
|
List<String> adminUserIds = UserService.getInstance().getAdminUserIdList(); |
|
if ((adminUserIds != null) && (adminUserIds.size() >= 1) && (adminUserIds.contains(userId))) { |
|
return 0; |
|
} |
|
UserUpdateBean userUpdateBean = new UserUpdateBean(); |
|
userUpdateBean.setRemoveUserIds(new String[]{userId}); |
|
return UserService.getInstance().deleteUsers(userUpdateBean); |
|
} |
|
|
|
public static int deleteUsersByUsernames(List<String> usernames) throws Exception { |
|
if ((usernames == null) || (usernames.size() <= 0)) { |
|
return 0; |
|
} |
|
String username; |
|
int totalCount = 0, count; |
|
for (int i = 0, max = usernames.size() - 1; i <= max; i++) { |
|
username = usernames.get(i); |
|
count = deleteUsersByUsername(username); |
|
totalCount = totalCount + count; |
|
} |
|
return totalCount; |
|
} |
|
|
|
public static void editRealNameByUsername(String username, String realName) throws Exception { |
|
if (StringUtils.isEmpty(username) || StringUtils.isEmpty(realName)) { |
|
return; |
|
} |
|
User user = UserService.getInstance().getUserByUserName(username); |
|
if (user == null) { |
|
return; |
|
} |
|
UserBean userBean = new UserBean(user.getEmail(), user.isEnable(), user.getMobile(), realName, user.getUserName(), user.getId()); |
|
UserService.getInstance().editAccount(username, userBean); |
|
} |
|
}
|
|
|