From 62654cb7d3e23074278c7c061bef8f6cbee90d73 Mon Sep 17 00:00:00 2001 From: ludc Date: 星期五, 10 十一月 2023 09:48:21 +0800 Subject: [PATCH] 修改历史数据导入时限制单次导入通过配置做限制,开启多线程分批并行执行insert,注解开启事务回滚失效,对象方式开启事务实现手动提交事务,异常回滚事务 --- Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/service/impl/PasswordFreeLoginServiceImpl.java | 27 ++++++++++++++------------- 1 files changed, 14 insertions(+), 13 deletions(-) diff --git a/Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/service/impl/PasswordFreeLoginServiceImpl.java b/Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/service/impl/PasswordFreeLoginServiceImpl.java index 752bf91..3b4a571 100644 --- a/Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/service/impl/PasswordFreeLoginServiceImpl.java +++ b/Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/service/impl/PasswordFreeLoginServiceImpl.java @@ -4,6 +4,7 @@ import com.vci.ubcs.code.entity.TokenUserObject; import com.vci.ubcs.code.service.IPasswordFreeLoginService; import com.vci.ubcs.starter.util.HttpUtils; +import com.vci.ubcs.system.cache.NacosConfigCache; import io.jsonwebtoken.Claims; import lombok.extern.slf4j.Slf4j; import org.apache.http.auth.AuthenticationException; @@ -66,6 +67,7 @@ @Value("${password-free.secret-key:9fbd170bd83eb869}") private String secretKey;//搴旂敤绉橀挜 + @Autowired private BladeRedis bladeRedis; @@ -106,7 +108,7 @@ String token2 = JwtUtil.getToken(authToken); BladeUser user = this.getUser(token2); //涓嶅瓨鍦ㄥ氨璇锋眰 - if(Func.isEmpty(authToken) || Func.isEmpty(user)){ + if(Func.isEmpty(authToken) || Func.isEmpty(user) || !user.getTenantId().equals(NacosConfigCache.getAdminUserInfo().getTenantId())){ String responseBody = this.passwordFreeLogin(userName); //鎷垮埌鍝嶅簲浣撳叾涓寘鍚玹oken,鐢╮equest涓殑ip鍦板潃浣滀负閿�硷紝灏唗oken瀛樺叆缂撳瓨 TokenUserObject tokenUserObject = null; @@ -161,26 +163,25 @@ /** * 鍗曠偣鐧诲綍 - * @param servletRequest + * @param empCode * @return * @throws Exception */ @Override - public String ssoFreeLogin(ServletRequest servletRequest) throws Exception { - HttpServletRequest request = (HttpServletRequest) servletRequest; - String content = request.getHeader("empCode"); - if(Func.isBlank(content)){ + public String ssoFreeLogin(String empCode) throws Exception { + if(Func.isBlank(empCode)){ throw new ServiceException("鏈幏鍙栧埌empCode鍙傛暟"); } - //鍔犲瘑 - String str1 = aesEncrypt(content, clientId); - String str2 = aesEncrypt(str1, secretKey); - - String enStr1 = aesDecrypt(str2, secretKey); - String enStr2 = aesDecrypt(enStr1, clientId); + String enStr2; + try { + String enStr1 = aesDecrypt(empCode, secretKey); + enStr2 = aesDecrypt(enStr1, clientId); + }catch (Exception e){ + throw new ServiceException("empCode鍙傛暟瑙e瘑澶辫触锛佸師鍥�:"+e.getMessage()); + } // 瑙e瘑 log.debug("鍗曠偣鐧诲綍鍙傛暟瑙e瘑鍚庯細"+enStr2); - String token = this.passwordFreeLogin("pwdfree"); + String token = this.passwordFreeLogin(enStr2); return token; } -- Gitblit v1.9.3