From ac519f0b7919f2e80d70b23e95e82bc8111dd0c3 Mon Sep 17 00:00:00 2001 From: zoujiangtao Date: Fri, 14 Nov 2025 14:23:48 +0800 Subject: [PATCH 1/2] =?UTF-8?q?=E6=8F=90=E4=BA=A4=E5=86=85=E5=AE=B9?= =?UTF-8?q?=EF=BC=9A=E5=8D=95=E7=82=B9=E5=88=87=E6=8D=A2=E4=B8=BA=E6=89=8B?= =?UTF-8?q?=E6=9C=BA=E5=8F=B7=E9=AA=8C=E8=AF=81=E3=80=81url=E7=BC=96?= =?UTF-8?q?=E7=A0=81URLEncoder.encode(redirect,=20"UTF-8")=E3=80=81?= =?UTF-8?q?=E6=97=A5=E5=BF=97=E9=A1=BA=E5=BA=8F=E8=B0=83=E6=95=B4=EF=BC=88?= =?UTF-8?q?=E5=85=88=E6=89=93=E6=97=A5=E5=BF=97=E5=86=8D=E9=87=8D=E5=AE=9A?= =?UTF-8?q?=E5=90=91=EF=BC=89=20=E6=97=B6=E9=97=B4=EF=BC=9A2025-11-14=2014?= =?UTF-8?q?=EF=BC=9A23=20=E6=8F=90=E4=BA=A4=E4=BA=BA=EF=BC=9A=E9=82=B9?= =?UTF-8?q?=E6=B1=9F=E6=B6=9B?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/shkd/sys/sys/eoss/AuthService.java | 3 ++- .../shkd/sys/sys/eoss/SSOPluginLogin.java | 25 +++++++++++-------- 2 files changed, 17 insertions(+), 11 deletions(-) diff --git a/sys/shkd-sys-sys/src/main/java/shkd/sys/sys/eoss/AuthService.java b/sys/shkd-sys-sys/src/main/java/shkd/sys/sys/eoss/AuthService.java index d034d8d..2ea8114 100644 --- a/sys/shkd-sys-sys/src/main/java/shkd/sys/sys/eoss/AuthService.java +++ b/sys/shkd-sys-sys/src/main/java/shkd/sys/sys/eoss/AuthService.java @@ -79,7 +79,8 @@ public class AuthService { logger.info(String.format("getUserInfo→返回结果:%s",jsonObject)); JSONObject obj = jsonObject.getJSONObject("data"); if (obj!=null){ - return obj.getString("loginName"); +// return obj.getString("loginName"); + return obj.getString("phone"); } return null; } diff --git a/sys/shkd-sys-sys/src/main/java/shkd/sys/sys/eoss/SSOPluginLogin.java b/sys/shkd-sys-sys/src/main/java/shkd/sys/sys/eoss/SSOPluginLogin.java index da65942..0c5d277 100644 --- a/sys/shkd-sys-sys/src/main/java/shkd/sys/sys/eoss/SSOPluginLogin.java +++ b/sys/shkd-sys-sys/src/main/java/shkd/sys/sys/eoss/SSOPluginLogin.java @@ -10,8 +10,10 @@ import kd.bos.login.thirdauth.UserProperType; import kd.bos.servicehelper.user.UserServiceHelper; import org.apache.commons.lang3.StringUtils; -import javax.servlet.http.*; +import javax.servlet.http.HttpServletRequest; +import javax.servlet.http.HttpServletResponse; import java.io.IOException; +import java.net.URLEncoder; import java.nio.charset.StandardCharsets; import java.util.Base64; @@ -38,6 +40,9 @@ public class SSOPluginLogin implements ThirdSSOAuthHandler { public void callTrdSSOLogin(HttpServletRequest httpServletRequest, HttpServletResponse httpServletResponse, String s) { logger.info(String.format("callTrdSSOLogin→httpServletRequest：%s", httpServletRequest)); + logger.info("CLIENT_ID:{}\nCLIENT_SECRET:{}\nEOSS_IP:{}\nCLIENT_ID2:{}\nCLIENT_SECRET2:{}\nEOSS_IP2:{}\nskIP:{}", + CLIENT_ID, CLIENT_SECRET, EOSS_IP, CLIENT_ID2, CLIENT_SECRET2, EOSS_IP2, skIP); + String ip; String client; String secret; @@ -46,8 +51,8 @@ public class SSOPluginLogin implements ThirdSSOAuthHandler { if (queryUrlOld != null && queryUrlOld.contains("code") && queryUrlOld.contains("sessionId")) { String replace = queryUrlOld.replace("sessionId", "eossSessionId"); try { - httpServletResponse.sendRedirect(httpServletRequest.getRequestURI() + "?" + replace); logger.info(String.format("callTrdSSOLogin→sendRedirect：%s", httpServletRequest.getRequestURI() + "?" + replace)); + httpServletResponse.sendRedirect(httpServletRequest.getRequestURI() + "?" + replace); } catch (IOException e) { throw new RuntimeException(e); } @@ -74,7 +79,7 @@ public class SSOPluginLogin implements ThirdSSOAuthHandler { try { //退出系统 if (httpServletRequest.getRequestURI().contains("/auth/logout.do")) { - String userName = UserServiceHelper.getCurrentUser("name").getString("name"); + String userName = UserServiceHelper.getCurrentUser("phone").getString("phone"); DistributeSessionlessCache cache = CacheFactory.getCommonCacheFactory().getDistributeSessionlessCache("customRegion"); String userKey = "user_sessionId_" + userName; // 构造存储sessionId的键 String sessionId = cache.get(userKey); @@ -82,7 +87,7 @@ public class SSOPluginLogin implements ThirdSSOAuthHandler { if (sessionId != null) { AuthService.logout(ip, sessionId); } - if (StringUtils.equals("true",isNew)){ + if (StringUtils.equals("true", isNew)) { ip = EOSS_IP2; } //退出系统跳转到eoss登录页 @@ -90,10 +95,10 @@ public class SSOPluginLogin implements ThirdSSOAuthHandler { } else { //重定向到eoss统一认证的地址 获取授权码code ssoUrl = String.format("%s/sso2/authCenter/authorize?client_id=%s&response_type=code&sessionKeep=true&authType=0&redirect_uri=%s", - ip, client, redirect); + ip, client, URLEncoder.encode(redirect, "UTF-8")); } - httpServletResponse.sendRedirect(ssoUrl); logger.info(String.format("callTrdSSOLogin→sendRedirect：%s", ssoUrl)); + httpServletResponse.sendRedirect(ssoUrl); } catch (IOException e) { logger.info(String.format("callTrdSSOLogin→sendRedirect异常：%s", e)); throw new RuntimeException(e); @@ -142,16 +147,16 @@ public class SSOPluginLogin implements ThirdSSOAuthHandler { //如果直接携带了code与session，并且未通过加密成param，需要去除session参数，并将其key替换为eossSessionId即可 if (StringUtils.isNotEmpty(code) && StringUtils.isNotEmpty(sessionId) && StringUtils.isEmpty(param)) { String replace = queryUrlOld.replace("sessionId", "eossSessionId"); - httpServletResponse.sendRedirect(requestURI + "?" + replace); logger.info(String.format("getTrdSSOAuth→sendRedirect：%s", replace)); + httpServletResponse.sendRedirect(requestURI + "?" + replace); } //携带了code，并且加密成param，解密param，并重定向进入司库 else if (StringUtils.isNotEmpty(param)) { //解码 byte[] decodedBytes = Base64.getDecoder().decode(param); String queryUrlNew = new String(decodedBytes, StandardCharsets.UTF_8); - httpServletResponse.sendRedirect(requestURI + "?" + queryUrlNew + "&code=" + code + "&eossSessionId=" + sessionId); logger.info(String.format("getTrdSSOAuth→sendRedirect：%s", requestURI + "?" + queryUrlNew + "&code=" + code + "&eossSessionId=" + sessionId)); + httpServletResponse.sendRedirect(requestURI + "?" + queryUrlNew + "&code=" + code + "&eossSessionId=" + sessionId); } } catch (IOException e) { logger.info(String.format("getTrdSSOAuth→sendRedirect异常：%s", e)); @@ -166,12 +171,12 @@ public class SSOPluginLogin implements ThirdSSOAuthHandler { String user = AuthService.getUserInfo(access_token, ip, client, secret); logger.info(String.format("getTrdSSOAuth→getUserInfo返回数据：%s", user)); String userKey = "user_sessionId_" + user; - if(httpServletRequest.getParameter("eossSessionId")!=null){ + if (httpServletRequest.getParameter("eossSessionId") != null) { //存储sessionId用于退出系统 cache.put(userKey, httpServletRequest.getParameter("eossSessionId")); } //当前返回类型手机，用户名，email，工号 - result.setUserType(UserProperType.UserName); + result.setUserType(UserProperType.Mobile); result.setUser(user); result.setSucess(true); logger.info("SSO用户登录成功，进入苍穹系统"); From 82883674e037a582921b2044fdfb5945288b24e1 Mon Sep 17 00:00:00 2001 From: 16358 <1635849544@qq.com> Date: Fri, 14 Nov 2025 17:01:24 +0800 Subject: [PATCH 2/2] =?UTF-8?q?=E6=8F=90=E4=BA=A4=E4=BA=BA=EF=BC=9A?= =?UTF-8?q?=E5=88=98=E6=A3=AE=E6=BE=B3=20=E6=97=A5=E6=9C=9F=EF=BC=9A2025/1?= =?UTF-8?q?1/14=2017:01=20=E5=86=85=E5=AE=B9=EF=BC=9A=E6=8B=85=E4=BF=9D?= =?UTF-8?q?=E5=90=88=E5=90=8C=E6=B7=BB=E5=8A=A0=E9=BB=98=E8=AE=A4=E5=AD=97?= =?UTF-8?q?=E6=AE=B5=E8=B5=8B=E5=80=BC?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../report/GuaranteeContractPatchPlugin.java | 29 ++++++++++++------- 1 file changed, 19 insertions(+), 10 deletions(-) diff --git a/sys/shkd-sys-sys/src/main/java/shkd/sys/sys/plugin/report/GuaranteeContractPatchPlugin.java b/sys/shkd-sys-sys/src/main/java/shkd/sys/sys/plugin/report/GuaranteeContractPatchPlugin.java index 65e1fd4..c70de95 100644 --- a/sys/shkd-sys-sys/src/main/java/shkd/sys/sys/plugin/report/GuaranteeContractPatchPlugin.java +++ b/sys/shkd-sys-sys/src/main/java/shkd/sys/sys/plugin/report/GuaranteeContractPatchPlugin.java @@ -48,7 +48,8 @@ public class GuaranteeContractPatchPlugin extends AbstractReportListDataPluginEx " a.fbillno AS guaranteedOriBillno,\n" + " a.fisexceedstock AS shkd_fisexceedstock,\n" + " a.fk_shkd_sfwslqy AS shkd_sfwslqy,\n" + - " b.fguaranteequotaid AS shkd_guaranteequotaid\n" + + " b.fguaranteequotaid AS shkd_guaranteequotaid,\n" + + " b.fgratio AS shkd_gratio\n" + "FROM \n" + " t_gm_guarcontract AS a\n" + " LEFT JOIN t_gm_guaranteed_entry AS b \n" + @@ -137,13 +138,14 @@ public class GuaranteeContractPatchPlugin extends AbstractReportListDataPluginEx entry.set("shkd_gdebtbalance", debtBalance); } } - //补充债券余额 - Object shkdGdebtamount = entry.get("shkd_gdebtamount"); - Object shkdGdebtbalance = entry.get("shkd_gdebtbalance"); - BigDecimal debtAmountTemp = shkdGdebtamount != null ? new BigDecimal(shkdGdebtamount.toString()) : BigDecimal.ZERO; - BigDecimal debtBalanceTemp = shkdGdebtbalance != null ? new BigDecimal(shkdGdebtbalance.toString()) : BigDecimal.ZERO; - BigDecimal difference = debtAmountTemp.subtract(debtBalanceTemp); - entry.set("shkd_gdebalanceamount", difference); + //补充债券余额 责任金额 - 担保责任金额 = 责任余额 + //FIXME:逻辑修改：改为 责任余额 = 担保责任金额 / 担保比例 ；并且逻辑时机挪到最终dataset组成完成之后 +// Object shkdGdebtamount = entry.get("shkd_gdebtamount");//责任金额 +// Object shkdGdebtbalance = entry.get("shkd_gdebtbalance");//担保责任金额 +// BigDecimal debtAmountTemp = shkdGdebtamount != null ? new BigDecimal(shkdGdebtamount.toString()) : BigDecimal.ZERO; +// BigDecimal debtBalanceTemp = shkdGdebtbalance != null ? new BigDecimal(shkdGdebtbalance.toString()) : BigDecimal.ZERO; +// BigDecimal difference = debtAmountTemp.subtract(debtBalanceTemp); +// entry.set("shkd_gdebalanceamount", difference); entry.set("shkd_gcomment", gcBIll.get("gcomment")); entry.set("shkd_gstatus", gcBIll.getBigDecimal("gratio").compareTo(BigDecimal.ZERO) == 0 ? "C" : (BigDecimal.ZERO.compareTo(debtBalance) != 0 ? "A" : "B")); @@ -166,11 +168,18 @@ public class GuaranteeContractPatchPlugin extends AbstractReportListDataPluginEx } - //3、根据参数进行过滤和排序 + //3、补充债券余额 + try { + finish = finish.addField("(shkd_gdebtbalance*100)/shkd_gratio", "shkd_gdebalanceamount"); + } catch (Exception e) { + finish = finish.addField("0", "shkd_gdebalanceamount"); + } + + //4、根据参数进行过滤和排序 reportQueryParam = event.getReportQueryParam(); DataSet newFinish = refreshDataSet(reportQueryParam, finish, "gm_guaranteecontract"); - //4、注入整合后的table数据 + //5、注入整合后的table数据 event.setDataSet(newFinish); }