package com.vci.frameworkcore.compatibility.impl;
|
|
import com.vci.corba.common.VCIError;
|
import com.vci.starter.web.annotation.log.VciUnLog;
|
import com.vci.starter.web.exception.VciBaseException;
|
import com.vci.starter.web.interceptor.VciSessionForLoginI;
|
import com.vci.starter.web.pagemodel.SessionInfo;
|
import com.vci.starter.web.util.VciBaseUtil;
|
import com.vci.web.properties.WebProperties;
|
import com.vci.web.service.WebBoServiceI;
|
import com.vci.web.util.PlatformClientUtil;
|
import com.vci.web.util.WebUtil;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.cache.annotation.CachePut;
|
import org.springframework.cache.annotation.Cacheable;
|
import org.springframework.scheduling.annotation.Scheduled;
|
import org.springframework.stereotype.Service;
|
import org.springframework.util.CollectionUtils;
|
import plm.bs.bom.common.AttributeValue;
|
|
import javax.servlet.http.HttpServletRequest;
|
import java.util.ArrayList;
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
|
import static com.vci.web.constant.CacheNameConstant.VCI_SESSION;
|
|
/**
|
* 会话存储的服务
|
* @author weidy
|
* @date 2021/2/18
|
*/
|
@Service
|
@VciUnLog
|
public class SmSessionForLoginImpl implements VciSessionForLoginI {
|
|
/**
|
* 日志
|
*/
|
private Logger logger = LoggerFactory.getLogger(getClass());
|
|
/**
|
* 配置信息
|
*/
|
@Autowired
|
private WebProperties webProperties;
|
|
/**
|
* 业务类型服务
|
*/
|
@Autowired
|
private WebBoServiceI boService;
|
|
/**
|
* 平台的调用类
|
*/
|
@Autowired
|
private PlatformClientUtil platformClientUtil;
|
|
/**
|
* 检查用户是否登录
|
*
|
* @param userId 用户名
|
* @return 为空表示没有登录
|
*/
|
@Override
|
public String checkIsLogined(String userId) {
|
WebUtil.alertNotNull(userId,"用户名");
|
List<Map> dataList = boService.queryBySqlForMap("select JSONSTRING as JSONSTRING from VCI_SESSIONINFO where userid ='" + userId.trim() + "'", new HashMap<>());
|
if(!CollectionUtils.isEmpty(dataList)) {
|
Map data = dataList.get(0);
|
SessionInfo sessionInfo = WebUtil.jsonString2JavaBean((String)data.getOrDefault("JSONSTRING",""),SessionInfo.class);
|
return "在ip为" + sessionInfo.getIp() + "的地方已经登录";
|
}
|
return "";
|
}
|
|
/**
|
* 强制用户下线
|
*
|
* @param userId 用户名
|
*/
|
@Override
|
public void popUser(String userId) {
|
WebUtil.alertNotNull(userId,"用户名");
|
try{
|
platformClientUtil.getBOFactoryService().executeUpdateSql("delete from VCI_SESSIONINFO where userid ='" + userId.trim() + "'");
|
}catch (VCIError e){
|
throw WebUtil.getVciBaseException(e);
|
}
|
}
|
|
/**
|
* 将会话信息存储到数据库中------
|
*
|
* @param sessionInfo 会话信息
|
*/
|
@Override
|
@Deprecated
|
public void saveSessionInfo(SessionInfo sessionInfo) {
|
WebUtil.alertNotNull(sessionInfo,"会话信息");
|
try {
|
AttributeValue[] attrs = new AttributeValue[3];
|
attrs[0] = new AttributeValue("0", sessionInfo.getUserId());
|
attrs[1] = new AttributeValue("1", sessionInfo.getToken());
|
attrs[2] = new AttributeValue("2", WebUtil.getJSONStringWithDateFormat(sessionInfo));
|
platformClientUtil.getBOFactoryService().executeUpdateSqlByParams(" insert into VCI_SESSIONINFO (USERID, TOKEN, JSONSTRING,lastRequestTime\n" +
|
" )\n" +
|
" VALUES (?,?,?," + System.currentTimeMillis() + " )", attrs);
|
}catch (VCIError e){
|
throw WebUtil.getVciBaseException(e);
|
}
|
}
|
|
/**
|
* 校验请求是否符合权限验证
|
* 包含1，系统是否可以访问当前服务或者接口
|
* 2, 用户是否有权限访问当前服务
|
* 3, 用户是否有权限访问当前数据
|
*
|
* @param request 请求对象
|
* @param systemPrivateToken 系统的许可码
|
* @param sessionInfo 当前用户会话对象
|
* @param handler 执行对象
|
* @return true表示有权限，false表示没权限
|
* @throws VciBaseException 没有权限的时候会抛出异常
|
*/
|
@Override
|
public boolean checkRequestRights(HttpServletRequest request, String systemPrivateToken, SessionInfo sessionInfo, Object handler) throws VciBaseException {
|
return true;
|
}
|
|
/**
|
* 更新请求时间
|
*
|
* @param userToken 用户token
|
*/
|
@Override
|
public void updateRequestTime(String userToken) {
|
WebUtil.alertNotNull(userToken,"会话许可码");
|
try{
|
platformClientUtil.getBOFactoryService().executeUpdateSql("update VCI_SESSIONINFO set lastRequestTime = " + String.valueOf(System.currentTimeMillis()) + " where TOKEN ='" + userToken.trim() + "'");
|
}catch (VCIError e){
|
throw WebUtil.getVciBaseException(e);
|
}
|
}
|
|
/**
|
* 根据token获取用户的对象
|
*
|
* @param userToken 用户token
|
* @return 用户会话对象
|
*/
|
@Override
|
@Cacheable(value = VCI_SESSION,key = "#p0",unless = "#target == null")
|
public SessionInfo getSessionInfoByToken(String userToken) {
|
WebUtil.alertNotNull(userToken,"许可的信息");
|
List<Map> dataList = boService.queryBySqlForMap("select JSONSTRING as JSONSTRING from VCI_SESSIONINFO where TOKEN ='" + userToken.trim() + "'", new HashMap<>());
|
// List<Map> dataList = null;
|
// Map map= new HashMap<>();
|
// map.put("JSONSTRING","{\"browser\":\"122.0.0.0\",\"deptName\":\"一车间\",\"deptOid\":\"002151D0-13B9-DB23-7006-34DCAC76B3BE\",\"deviceInfo\":[],\"email\":\"\",\"functionOids\":[\"2339F262-1715-F5EE-7E50-4DD6A42B8668\",\"2EC65569-17C7-84C2-A7A6-737E1B021DC4\",\"32037B20-2F95-F4E8-6077-C0B5226B033D\",\"ADB513D3-397E-07DA-7456-992916FF12D9\",\"5D2FDBCA-E04D-B611-8311-8F06E031BF95\",\"56186AEE-80D7-2CDB-CB80-09E87CB9125F\",\"536FD86E-779E-397D-2945-69AAA942A578\",\"FDB26577-596F-CA6F-1A1F-7D68C0E0A3B9\",\"E612DAB4-B3EC-8D08-46CA-8905AC82EF2D\",\"893E5778-481C-A04E-2742-ADFDF0CE3A15\",\"297C9ED8-DF76-9D91-B041-45F1DE161FD8\",\"63A98B92-5DA8-3F23-390E-2A389C714BC1\",\"931C3199-3CA8-733B-1CF3-FE88F0258E16\",\"AC04E222-F14B-F4FF-11BB-DFE8917A2756\",\"64C6BFFD-95B2-995A-73FD-DEE8212DAA56\",\"CC5F364D-E299-81CF-0B20-4BF09956FDA3\",\"B5985BFB-F31D-05A1-9943-D43704F35EDB\",\"86BD9541-8F9B-395F-A73D-B856635EE91C\",\"72ACFF87-05B6-3D8F-4CC4-C559FE9AD372\",\"ECFA5263-AB30-78CB-6F5B-DF11BC054616\",\"88AC00BE-54CC-DE68-F31E-C3D9FAEDD902\",\"F2B19983-15EF-4DC8-0A26-AF322EC8B9D0\",\"D8C8AE63-AD0B-D567-BFBE-AE4BF302C241\",\"D0715569-0F88-5CAB-E9DB-2B93567FC610\",\"2C5FABD2-535F-8568-8E61-C643BA7D77A1\",\"E6E963E7-2DF6-80EE-2A61-FA86E0F3D5F2\",\"BDBD6CFA-2F4C-EEF7-C380-5E9BBF6A37B3\",\"7FE9306A-2659-4E62-1C2B-A09A600A1010\",\"B3EC1413-1A33-61E3-DDD1-CB4D0CFD0C6E\",\"23B65414-A7F9-21B4-A5A9-4F963B8C4ED9\",\"E1A8FA2E-6102-F4C6-209F-C589CD2149F2\",\"077A25D8-09D8-D5DE-42BC-A777BE3327D5\",\"0C8E0C13-A0C1-A4FC-F957-F595DA54E355\",\"BFB9E279-DD28-7172-4A52-2A1767AD7663\",\"CEEAE20E-D93E-2D04-13C6-B8BD5B336374\",\"E84E06C3-60AE-42B8-88BD-1BE52531C1FF\",\"CB5C52F0-5D84-0738-0DA6-0721B76AADB8\",\"C755CC24-7194-BAC4-A3C2-D79E1E3CC594\",\"D8084EB8-AAB0-75A8-7BDD-3DC075D1D919\",\"6C538322-CCFC-ABA2-3BC6-7048C9711ADF\",\"5CEEDD16-4467-2798-245F-57E63CFD7753\",\"A4853E63-0044-52F2-5420-E34B28387C9C\",\"8239D998-F8DF-10B0-24CF-4525FE03E760\",\"D0FCC667-4182-8F03-801E-22E11553B39E\",\"3CB2A1CD-83CA-C155-2675-7B7681E7B03F\",\"C15B77F2-7F7F-2385-BD1F-8A241FF7C1A3\",\"B98ABE87-00DA-4BCA-A3B3-3EB7DF9BE8D9\",\"D25A0998-D315-97F8-36DB-6951E981E54C\",\"2841A478-8E99-7A89-4879-309DFFE5DD61\",\"25C58C8A-D28B-DA99-97A3-F6544B4B8E8D\",\"2AA1BD3D-9318-431F-AB55-ECF4318BDC9F\",\"AC4084E2-06E3-FDD6-7F50-8C1E8090358C\",\"4B919471-E62F-F717-6AC8-DE2B10A2A1DC\",\"D38C457D-FC45-C068-5322-457E522651DC\",\"2DCB5CF2-8127-3826-CCAE-1C40C6746EE8\",\"21766DD3-0B62-C577-FB84-940C1B84711C\",\"ABF503E5-9741-C2BE-31B0-6E15AB50E2D6\",\"B203DE0A-EDD0-4295-1257-79A76917BE85\",\"65A88CCC-220E-3CBF-0D31-E0DF5BDD9C6F\",\"8B7DBACB-C18A-CA11-B0B8-3C481E76E30F\",\"45FB1520-F571-9E97-2EA3-B9C78AF89BEC\",\"E34E1E0D-55F8-3C19-8E7B-E42D8A3FEEB9\"],\"globalAttributeMap\":{},\"ip\":\"127.0.0.1\",\"mustChangePassword\":false,\"os\":\"Windows 10\",\"portalId\":\"1\",\"rolesName\":{\"44044800-B0EB-1003-55B5-954C3FFEA3B8\":\"EBOM导入人员\",\"38FC5CC2-D880-A1C5-5DA0-C2F8B5082B52\":\"校对\",\"BA272199-5FF5-C513-F4FA-37F13A733FE8\":\"工艺人员\",\"2761C8F4-6442-A53C-9F40-A1D5978E0799\":\"审核\",\"DCF4961B-44DE-BA5B-F73C-8AA1EF1F1DB4\":\"gy1\",\"DA2608CC-07CB-A3FF-528B-CBE040BD7353\":\"编制\",\"A70A10D5-ED69-0CF5-8491-33D955569550\":\"会签\",\"CE4A351B-3669-9722-01AC-2E472B2900A5\":\"一般用户\",\"F5E11DDB-88E5-40F8-61B9-3F9E9ADAFFBF\":\"工艺组长\",\"2DFA4811-B391-6727-33C6-697BF4E9A77D\":\"批准\",\"785F8459-DDEA-33D1-40D5-C3F6A42FABB1\":\"主数据\",\"398B28CE-B1EE-FDEA-5B11-42908B8A3076\":\"PBOM管理岗人员\"},\"sso\":false,\"token\":\"8b9f42164c6b7fd3ca532acf375626cd\",\"userId\":\"1\",\"userName\":\"测试\",\"userOid\":\"921D71F8-C2BB-3BCE-B744-AD0C3812F41A\",\"userSecret\":\"2\",\"usertype\":\"2\"}");
|
if(!CollectionUtils.isEmpty(dataList)) {
|
Map data = dataList.get(0);
|
SessionInfo sessionInfo = WebUtil.jsonString2JavaBean((String)data.getOrDefault("JSONSTRING",""),SessionInfo.class);
|
return sessionInfo;
|
}
|
return null;
|
}
|
|
/**
|
* 退出登录
|
*
|
* @param userToken 用户的会话许可
|
*/
|
@Override
|
public void logout(String userToken) {
|
WebUtil.alertNotNull(userToken,"用户许可");
|
try{
|
platformClientUtil.getBOFactoryService().executeUpdateSql("delete from VCI_SESSIONINFO where TOKEN ='" + userToken.trim() + "'");
|
}catch (VCIError e){
|
throw WebUtil.getVciBaseException(e);
|
}
|
}
|
|
/**
|
* 根据token获取用户在系统中还可以存在的时间
|
* @param userToken userToken 用户的会话许可
|
* @return 用户在系统中还可以存在的时间(毫秒)
|
*/
|
@Override
|
public long getCanAliveTime(String userToken) {
|
VciBaseUtil.alertNotNull(userToken,"用户会话许可（令牌)");
|
List<Map> dataList = boService.queryBySqlForMap("select lastRequestTime as LASTREQUESTTIME from VCI_SESSIONINFO where TOKEN ='" + userToken.trim() + "'", new HashMap<>());
|
if(!CollectionUtils.isEmpty(dataList)) {
|
Map data = dataList.get(0);
|
long lastTime = WebUtil.getLong(data.get("LASTREQUESTTIME").toString());
|
long currentTime = System.currentTimeMillis();
|
long canAliveTime = lastTime + (webProperties.getClientSessionAliveMax()*60*1000) - currentTime;
|
return canAliveTime;
|
}
|
return 0;
|
}
|
|
/**
|
* 删除超时的会话的信息
|
*/
|
@Scheduled(fixedDelay=60000)
|
public void deleteTimeoutSession(){
|
long now = System.currentTimeMillis();
|
if(webProperties.getClientSessionAliveMax() > 0) {
|
long lastValidTime = now - webProperties.getClientSessionAliveMax() * 60000;
|
if (logger.isDebugEnabled()) {
|
logger.debug("开始执行扫描超时的会话信息,其中当前时间为{},会话最后访问的有效时间应该为{}", now, lastValidTime);
|
}
|
List<Map> invalidSessionList = boService.queryBySqlForMap("select token as TOKEN from VCI_SESSIONINFO where lastRequestTime<= " + lastValidTime, null);
|
if (!CollectionUtils.isEmpty(invalidSessionList)) {
|
List<String> tokenList = new ArrayList<>();
|
invalidSessionList.stream().forEach(map -> {
|
tokenList.add(map.get("TOKEN").toString());
|
});
|
WebUtil.switchCollectionForOracleIn(tokenList).stream().forEach(tokens -> {
|
try {
|
platformClientUtil.getBOFactoryService().executeUpdateSql("delete from VCI_SESSIONINFO where TOKEN in (" + WebUtil.toInSql(tokens.toArray(new String[0])) + ")");
|
} catch (VCIError e) {
|
if (logger.isErrorEnabled()) {
|
logger.error("删除会话信息", e);
|
}
|
}
|
});
|
}
|
if (logger.isDebugEnabled()) {
|
logger.debug("开始执行扫描超时的会话信息完成，删除了{}条数据", invalidSessionList == null ? 0 : invalidSessionList.size());
|
}
|
}
|
}
|
}
|
