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.
315 lines
11 KiB
315 lines
11 KiB
2 years ago
|
package com.eco.plugin.xx.gfjjwhite.utils;
|
||
|
|
|
||
|
|
import com.fr.base.ServerConfig;
|
||
|
|
import com.fr.base.TableData;
|
||
|
|
import com.fr.base.TemplateUtils;
|
||
|
|
import com.fr.decision.authority.AuthorityContext;
|
||
|
|
import com.fr.decision.authority.base.constant.type.operation.ManualOperationType;
|
||
|
|
import com.fr.decision.authority.data.User;
|
||
|
|
import com.fr.decision.base.util.UUIDUtil;
|
||
|
|
import com.fr.decision.privilege.encrpt.PasswordValidator;
|
||
|
|
import com.fr.decision.webservice.bean.authentication.OriginUrlResponseBean;
|
||
|
|
import com.fr.decision.webservice.interceptor.handler.ReportTemplateRequestChecker;
|
||
|
|
import com.fr.decision.webservice.login.LogInOutResultInfo;
|
||
|
|
import com.fr.decision.webservice.utils.DecisionServiceConstants;
|
||
|
|
import com.fr.decision.webservice.utils.DecisionStatusService;
|
||
|
|
import com.fr.decision.webservice.utils.UserSourceFactory;
|
||
|
|
import com.fr.decision.webservice.v10.login.LoginService;
|
||
|
|
import com.fr.decision.webservice.v10.login.event.LogInOutEvent;
|
||
|
|
import com.fr.decision.webservice.v10.user.UserService;
|
||
|
|
import com.fr.event.EventDispatcher;
|
||
|
|
import com.fr.file.TableDataConfig;
|
||
|
|
import com.fr.general.data.DataModel;
|
||
|
|
import com.fr.log.FineLoggerFactory;
|
||
|
|
import com.fr.script.Calculator;
|
||
|
|
import com.fr.stable.StringUtils;
|
||
|
|
import com.fr.stable.query.QueryFactory;
|
||
|
|
import com.fr.stable.query.restriction.RestrictionFactory;
|
||
|
|
import com.fr.third.springframework.web.method.HandlerMethod;
|
||
|
|
import com.fr.web.controller.ReportRequestService;
|
||
|
|
import com.fr.web.utils.WebUtils;
|
||
|
|
|
||
|
|
import javax.servlet.http.Cookie;
|
||
|
|
import javax.servlet.http.HttpServletRequest;
|
||
|
|
import javax.servlet.http.HttpServletResponse;
|
||
|
|
import javax.servlet.http.HttpSession;
|
||
|
|
import java.io.IOException;
|
||
|
|
import java.util.List;
|
||
|
|
|
||
|
|
public class FRUtils {
|
||
|
|
/**
|
||
|
|
* 判断用户是否存在
|
||
|
|
* @param userName
|
||
|
|
* @return
|
||
|
|
*/
|
||
|
|
public static boolean isUserExist(String userName){
|
||
|
|
if (StringUtils.isEmpty(userName)) {
|
||
|
|
return false;
|
||
|
|
} else {
|
||
|
|
try {
|
||
|
|
List userList = AuthorityContext.getInstance().getUserController().find(QueryFactory.create().addRestriction(RestrictionFactory.eq("userName", userName)));
|
||
|
|
return userList != null && !userList.isEmpty();
|
||
|
|
} catch (Exception e) {
|
||
|
|
FineLoggerFactory.getLogger().error(e.getMessage());
|
||
|
|
return false;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
/**
|
||
|
|
* 判断是否登录FR
|
||
|
|
* @param req
|
||
|
|
* @return
|
||
|
|
*/
|
||
|
|
public static boolean isLogin(HttpServletRequest req){
|
||
|
|
return LoginService.getInstance().isLogged(req);
|
||
|
|
}
|
||
|
|
|
||
|
|
/**
|
||
|
|
* 帆软登录
|
||
|
|
* @param httpServletRequest
|
||
|
|
* @param httpServletResponse
|
||
|
|
* @param userName
|
||
|
|
* @param url
|
||
|
|
*/
|
||
|
|
public static void login(HttpServletRequest httpServletRequest,HttpServletResponse httpServletResponse,String userName,String url){
|
||
|
|
FineLoggerFactory.getLogger().info("FRLOG:用户名:"+userName+";跳转链接:"+url);
|
||
|
|
|
||
|
|
//判断用户名是否为空
|
||
|
|
if(!Utils.isNullStr(userName)){
|
||
|
|
if(isUserExist(userName)){
|
||
|
|
try {
|
||
|
|
LoginService.getInstance().login(httpServletRequest, httpServletResponse, userName);
|
||
|
|
|
||
|
|
EventDispatcher.fire(LogInOutEvent.LOGIN,new LogInOutResultInfo(httpServletRequest,httpServletResponse,userName,true));
|
||
|
|
FineLoggerFactory.getLogger().info("FRLOG:登陆成功!");
|
||
|
|
|
||
|
|
if(!Utils.isNullStr(url)){
|
||
|
|
httpServletResponse.sendRedirect(url);
|
||
|
|
}
|
||
|
|
} catch (Exception e) {
|
||
|
|
ResponseUtils.failedResponse(httpServletResponse,"登录异常，请联系管理员!");
|
||
|
|
FineLoggerFactory.getLogger().info("FRLOGException:"+e.getMessage());
|
||
|
|
}
|
||
|
|
}else{
|
||
|
|
ResponseUtils.failedResponse(httpServletResponse,"用户在报表系统中不存在!");
|
||
|
|
}
|
||
|
|
}else{
|
||
|
|
ResponseUtils.failedResponse(httpServletResponse,"用户名不能为空!");
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
/**
|
||
|
|
* 帆软登录
|
||
|
|
* @param httpServletRequest
|
||
|
|
* @param httpServletResponse
|
||
|
|
* @param token
|
||
|
|
* @param url
|
||
|
|
*/
|
||
|
|
public static void loginByToken(HttpServletRequest httpServletRequest,HttpServletResponse httpServletResponse,String token,String url){
|
||
|
|
|
||
|
|
FineLoggerFactory.getLogger().info("FRLOG:token:"+token+";跳转链接:"+url);
|
||
|
|
|
||
|
|
//判断用户名是否为空
|
||
|
|
if(!Utils.isNullStr(token)){
|
||
|
|
writeToken2Cookie(httpServletResponse,token,-1);
|
||
|
|
|
||
|
|
HttpSession session = httpServletRequest.getSession(true);
|
||
|
|
|
||
|
|
httpServletRequest.setAttribute(DecisionServiceConstants.FINE_AUTH_TOKEN_NAME,token);
|
||
|
|
|
||
|
|
session.setAttribute(DecisionServiceConstants.FINE_AUTH_TOKEN_NAME, token);
|
||
|
|
|
||
|
|
if(!Utils.isNullStr(url)){
|
||
|
|
try {
|
||
|
|
httpServletResponse.sendRedirect(url);
|
||
|
|
} catch (IOException e) {
|
||
|
|
ResponseUtils.failedResponse(httpServletResponse,"跳转异常!");
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}else{
|
||
|
|
ResponseUtils.failedResponse(httpServletResponse,"token不能为空!");
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
/**
|
||
|
|
* 获取token
|
||
|
|
* @param httpServletRequest
|
||
|
|
* @param httpServletResponse
|
||
|
|
* @param username
|
||
|
|
* @return
|
||
|
|
*/
|
||
|
|
public static String getToken(HttpServletRequest httpServletRequest,HttpServletResponse httpServletResponse,String username){
|
||
|
|
String token = "";
|
||
|
|
try {
|
||
|
|
token = LoginService.getInstance().login(httpServletRequest, httpServletResponse, username);
|
||
|
|
} catch (Exception e) {
|
||
|
|
FineLoggerFactory.getLogger().info("FRLOG:获取token失败"+e.getMessage());
|
||
|
|
}
|
||
|
|
|
||
|
|
return token;
|
||
|
|
}
|
||
|
|
|
||
|
|
private static void writeToken2Cookie(HttpServletResponse req, String token, int num) {
|
||
|
|
try {
|
||
|
|
if (StringUtils.isNotEmpty(token)) {
|
||
|
|
Cookie cookie = new Cookie("fine_auth_token", token);
|
||
|
|
long maxAge = num == -2 ? 1209600000L : (long)num;
|
||
|
|
cookie.setMaxAge((int)maxAge);
|
||
|
|
cookie.setPath(ServerConfig.getInstance().getCookiePath());
|
||
|
|
req.addCookie(cookie);
|
||
|
|
Cookie rememberCookie = new Cookie("fine_remember_login", String.valueOf(num == -2 ? -2 : -1));
|
||
|
|
rememberCookie.setMaxAge((int)maxAge);
|
||
|
|
rememberCookie.setPath(ServerConfig.getInstance().getCookiePath());
|
||
|
|
req.addCookie(rememberCookie);
|
||
|
|
} else {
|
||
|
|
FineLoggerFactory.getLogger().error("empty token cannot save.");
|
||
|
|
}
|
||
|
|
} catch (Exception e) {
|
||
|
|
FineLoggerFactory.getLogger().error(e.getMessage(), e);
|
||
|
|
}
|
||
|
|
|
||
|
|
}
|
||
|
|
|
||
|
|
/**
|
||
|
|
* 后台登出
|
||
|
|
* @param httpServletRequest
|
||
|
|
* @param httpServletResponse
|
||
|
|
*/
|
||
|
|
public static void logoutByToken(HttpServletRequest httpServletRequest,HttpServletResponse httpServletResponse,String token)
|
||
|
|
{
|
||
|
|
httpServletRequest.setAttribute("fine_auth_token",token);
|
||
|
|
logout(httpServletRequest,httpServletResponse);
|
||
|
|
}
|
||
|
|
|
||
|
|
/**
|
||
|
|
*
|
||
|
|
* @param httpServletRequest
|
||
|
|
* @param httpServletResponse
|
||
|
|
*/
|
||
|
|
public static void logout(HttpServletRequest httpServletRequest,HttpServletResponse httpServletResponse)
|
||
|
|
{
|
||
|
|
if(!isLogin(httpServletRequest)){
|
||
|
|
return ;
|
||
|
|
}
|
||
|
|
|
||
|
|
try {
|
||
|
|
LoginService.getInstance().logout(httpServletRequest,httpServletResponse);
|
||
|
|
} catch (Exception e) {
|
||
|
|
ResponseUtils.failedResponse(httpServletResponse,"登出异常，请联系管理员!");
|
||
|
|
FineLoggerFactory.getLogger().info("FRLOGException:"+e.getMessage());
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
/**
|
||
|
|
* 打印FR日志
|
||
|
|
* @param message
|
||
|
|
*/
|
||
|
|
public static void FRLogInfo(String message){
|
||
|
|
FineLoggerFactory.getLogger().info("FRLOG:"+message);
|
||
|
|
}
|
||
|
|
|
||
|
|
/**
|
||
|
|
* 打印FR日志-error
|
||
|
|
* @param message
|
||
|
|
*/
|
||
|
|
public static void FRLogError(String message){
|
||
|
|
FineLoggerFactory.getLogger().error("FRLOG:"+message);
|
||
|
|
}
|
||
|
|
|
||
|
|
|
||
|
|
/**
|
||
|
|
* 根据用户名获取用户信息
|
||
|
|
* @param userName
|
||
|
|
* @return
|
||
|
|
*/
|
||
|
|
public static User getFRUserByUserName(String userName){
|
||
|
|
try {
|
||
|
|
return UserService.getInstance().getUserByUserName(userName);
|
||
|
|
} catch (Exception e) {
|
||
|
|
FRLogInfo("获取用户信息异常:"+e.getMessage());
|
||
|
|
}
|
||
|
|
|
||
|
|
return null;
|
||
|
|
}
|
||
|
|
|
||
|
|
/**
|
||
|
|
* 解密FR密码
|
||
|
|
* @param password
|
||
|
|
* @return
|
||
|
|
*/
|
||
|
|
// public static String decryptFRPsd(String password){
|
||
|
|
// FRLogInfo("解密密码:"+password);
|
||
|
|
// return TransmissionTool.decrypt(password);
|
||
|
|
// }
|
||
|
|
|
||
|
|
/**
|
||
|
|
* 根据明文密码生成数据库中的密码，用户密码校验用
|
||
|
|
* @return
|
||
|
|
*/
|
||
|
|
public static String getDBPsd(String username,String password){
|
||
|
|
PasswordValidator pv = UserSourceFactory.getInstance().getUserSource(ManualOperationType.KEY).getPasswordValidator();
|
||
|
|
String uuid = UUIDUtil.generate();
|
||
|
|
|
||
|
|
return pv.encode(username, password, uuid);
|
||
|
|
}
|
||
|
|
|
||
|
|
/**
|
||
|
|
* 获取带参数的访问链接
|
||
|
|
* @return
|
||
|
|
*/
|
||
|
|
public static String getAllUrl(HttpServletRequest httpServletRequest){
|
||
|
|
return WebUtils.getOriginalURL(httpServletRequest);
|
||
|
|
}
|
||
|
|
|
||
|
|
/**
|
||
|
|
* 根据originKey获取源链接
|
||
|
|
* @param req
|
||
|
|
* @return
|
||
|
|
* @throws Exception
|
||
|
|
*/
|
||
|
|
public static String getOriginUrl(HttpServletRequest req) throws Exception {
|
||
|
|
String origin = req.getParameter("origin");
|
||
|
|
if (StringUtils.isNotEmpty(origin)) {
|
||
|
|
OriginUrlResponseBean originUrlResponseBean = (OriginUrlResponseBean) DecisionStatusService.originUrlStatusService().get(origin);
|
||
|
|
DecisionStatusService.originUrlStatusService().delete(origin);
|
||
|
|
if (originUrlResponseBean != null) {
|
||
|
|
return originUrlResponseBean.getOriginUrl();
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
return new OriginUrlResponseBean(TemplateUtils.render("${fineServletURL}")).getOriginUrl();
|
||
|
|
}
|
||
|
|
|
||
|
|
/**
|
||
|
|
* 判断是否开启模板认证
|
||
|
|
* @param
|
||
|
|
* @return
|
||
|
|
* @throws Exception
|
||
|
|
*/
|
||
|
|
public static boolean isTempAuth(HttpServletRequest req,HttpServletResponse res) throws Exception {
|
||
|
|
ReportTemplateRequestChecker checker = new ReportTemplateRequestChecker();
|
||
|
|
HandlerMethod hm = new HandlerMethod(new ReportRequestService(),ReportRequestService.class.getMethod("preview", HttpServletRequest.class, HttpServletResponse.class, String.class));
|
||
|
|
return checker.checkRequest(req,res,hm);
|
||
|
|
}
|
||
|
|
|
||
|
|
/**
|
||
|
|
* 获取数据集数据
|
||
|
|
* @param serverDataSetName
|
||
|
|
* @return
|
||
|
|
*/
|
||
|
|
public static DataModel getTableData(String serverDataSetName){
|
||
|
|
TableData userInfo = TableDataConfig.getInstance().getTableData(serverDataSetName);
|
||
|
|
DataModel userInfoDM = userInfo.createDataModel(Calculator.createCalculator());
|
||
|
|
// userInfoDM.getRowCount();
|
||
|
|
// userInfoDM.getColumnIndex();
|
||
|
|
// userInfoDM.getValueAt()
|
||
|
|
return userInfoDM;
|
||
|
|
}
|
||
|
|
|
||
|
|
public static String getIndex(HttpServletRequest req){
|
||
|
|
String url = req.getScheme()+"://"+req.getServerName()+":"+String.valueOf(req.getServerPort())+req.getRequestURI();
|
||
|
|
return url;
|
||
|
|
}
|
||
|
|
}
|