package com.vci.frameworkcore.compatibility.impl; import com.vci.corba.common.PLException; import com.vci.corba.omd.data.AttributeValue; 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.scheduling.annotation.Scheduled; import org.springframework.stereotype.Service; import org.springframework.util.CollectionUtils; import javax.servlet.http.HttpServletRequest; import java.util.ArrayList; import java.util.HashMap; import java.util.List; import java.util.Map; /** * 会话存储的服务 * @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 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 (PLException 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 (PLException 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 (PLException e){ throw WebUtil.getVciBaseException(e); } } /** * 根据token获取用户的对象 * * @param userToken 用户token * @return 用户会话对象 */ @Override public SessionInfo getSessionInfoByToken(String userToken) { WebUtil.alertNotNull(userToken,"许可的信息"); List dataList = boService.queryBySqlForMap("select JSONSTRING as JSONSTRING from VCI_SESSIONINFO where TOKEN ='" + userToken.trim() + "'", new HashMap<>()); // List 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 (PLException e){ throw WebUtil.getVciBaseException(e); } } /** * 根据token获取用户在系统中还可以存在的时间 * @param userToken userToken 用户的会话许可 * @return 用户在系统中还可以存在的时间(毫秒) */ @Override public long getCanAliveTime(String userToken) { VciBaseUtil.alertNotNull(userToken,"用户会话许可（令牌)"); List 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 invalidSessionList = boService.queryBySqlForMap("select token as TOKEN from VCI_SESSIONINFO where lastRequestTime<= " + lastValidTime, null); if (!CollectionUtils.isEmpty(invalidSessionList)) { List 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 (PLException e) { if (logger.isErrorEnabled()) { logger.error("删除会话信息", e); } } }); } if (logger.isDebugEnabled()) { logger.debug("开始执行扫描超时的会话信息完成，删除了{}条数据", invalidSessionList == null ? 0 : invalidSessionList.size()); } } } }