From 60c4588643b878cc7aa8822ea9f40bde2a6e3e75 Mon Sep 17 00:00:00 2001 From: zhubaomin <zhubaomin> Date: 星期四, 29 八月 2024 10:03:29 +0800 Subject: [PATCH] 2024-08-29 朱宝民 监测控制模块增加代用户开关阀功能 --- pipIrr-platform/pipIrr-web/pipIrr-web-sso/src/main/java/com/dy/sso/busi/SsoCtrl.java | 62 ++++++++++++++++++++++++++----- 1 files changed, 52 insertions(+), 10 deletions(-) diff --git a/pipIrr-platform/pipIrr-web/pipIrr-web-sso/src/main/java/com/dy/sso/busi/SsoCtrl.java b/pipIrr-platform/pipIrr-web/pipIrr-web-sso/src/main/java/com/dy/sso/busi/SsoCtrl.java index 194490c..47d2e2f 100644 --- a/pipIrr-platform/pipIrr-web/pipIrr-web-sso/src/main/java/com/dy/sso/busi/SsoCtrl.java +++ b/pipIrr-platform/pipIrr-web/pipIrr-web-sso/src/main/java/com/dy/sso/busi/SsoCtrl.java @@ -7,7 +7,6 @@ import com.dy.common.webUtil.BaseResponseUtils; import com.dy.common.webUtil.ResultCodeMsg; import com.dy.pipIrrGlobal.pojoBa.BaUser; -import com.dy.pipIrrGlobal.util.DistrictLevel; import com.dy.pipIrrGlobal.util.Org; import com.mysql.cj.util.StringUtils; import io.swagger.v3.oas.annotations.Hidden; @@ -22,12 +21,10 @@ import jakarta.validation.Valid; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Autowired; -//import org.springframework.cache.CacheManager; import org.springframework.http.MediaType; import org.springframework.validation.BindingResult; import org.springframework.web.bind.annotation.*; -import java.util.Arrays; import java.util.List; import java.util.Objects; import java.util.UUID; @@ -71,9 +68,9 @@ ) }) @GetMapping(path = "allOrg") - public BaseResponse<List<Org>> allOrg(){ - List<Org> list = Arrays.asList(Org.Ym, Org.Pj) ; - return BaseResponseUtils.buildSuccess(list); + public BaseResponse<List<Org.OrgVo>> allOrg(){ + //List<Org> list = Arrays.asList(Org.Ym, Org.Pj) ; + return BaseResponseUtils.buildSuccess(Org.OrgList); } /** @@ -105,6 +102,9 @@ if(bindingResult != null && bindingResult.hasErrors()){ return BaseResponseUtils.buildFail(Objects.requireNonNull(bindingResult.getFieldError()).getDefaultMessage()); } + if(vo.phone == null || vo.phone.trim().length() == 0){ + return BaseResponseUtils.buildFail("鎵嬫満鍙蜂笉鑳戒负绌�"); + } if(!vo.phone.equals("admin")){ if(vo.phone.length() != 11){ return BaseResponseUtils.buildFail("鎵嬫満鍙凤紙闀垮害涓嶆槸11浣嶏級涓嶆纭�"); @@ -115,6 +115,12 @@ } //鎶婄粍缁囧崟浣嶆爣绛句綔涓烘暟鎹簮鍚嶇О DataSourceContext.set(vo.orgTag); + + //寰楀埌鎵�鏈夌敤鎴疯处鍙� + List<String> phones = sv.getPhones(); + if(!phones.contains(vo.phone)){ + return BaseResponseUtils.buildFail("璐﹀彿涓嶅瓨鍦�"); + } String uuid ; BaUser userPo ; @@ -139,7 +145,7 @@ uVo.token = uuid ; return BaseResponseUtils.buildSuccess(uVo); }else{ - return BaseResponseUtils.buildFail("鐧诲綍澶辫触"); + return BaseResponseUtils.buildFail("瀵嗙爜閿欒"); } } @@ -232,7 +238,27 @@ BaUser userPo = this.sv.getByUuid(token) ; return userPo == null ? null : userPo.id ; } - + /** + * 姝ゆ柟娉曚緵瀛愭ā鍧楃郴缁熻皟鐢紝鎵�浠ヤ笉鍏紑鍦ˋPI鎺ュ彛涓� + * 鏂规硶鍔熻兘锛氶獙璇佹槸鍚﹀凡缁忕櫥褰� + * @param token 鐧诲綍鐢ㄦ埛token + * @return SsoVo + */ + @Hidden + @GetMapping(path = "ssoCheck") + public SsoVo ssoCheck(String token){ + BaUser userPo = this.sv.getByUuid(token) ; + SsoVo vo = new SsoVo(); + if(userPo != null){ + vo.dataSourceName = userPo.orgTag ; + vo.logined = true ; + vo.hasPower = true ;//榛樿鏈夋潈闄愩��2023-12-21 缁忓晢璁紝鐢卞墠绔壌鏉� + }else{ + vo.logined = false ; + vo.hasPower = true ;//榛樿鏈夋潈闄愩��2023-12-21 缁忓晢璁紝鐢卞墠绔壌鏉� + } + return vo ; + } /** * 姝ゆ柟娉曚緵瀛愭ā鍧楃郴缁熻皟鐢紝鎵�浠ヤ笉鍏紑鍦ˋPI鎺ュ彛涓� * 鏂规硶鍔熻兘锛氶獙璇佹槸鍚﹀凡缁忕櫥褰曪紝濡傛灉鐧诲綍浜嗭紝鍐嶉獙璇佹潈闄� @@ -243,8 +269,8 @@ * @return SsoVo */ @Hidden - @GetMapping(path = "ssoCheck") - public SsoVo ssoCheck(String token, String privilege, String[] allPrivilege, String[] anyPrivilege){ + @GetMapping(path = "ssoPowerCheck") + public SsoVo ssoPowerCheck(String token, String privilege, String[] allPrivilege, String[] anyPrivilege){ BaUser userPo = this.sv.getByUuid(token) ; SsoVo vo = new SsoVo(); if(userPo != null){ @@ -276,6 +302,22 @@ return vo ; } + /** + * 鑾峰緱褰撳墠鐧诲綍鐢ㄦ埛 + * @param token 鐧诲綍鐢ㄦ埛token + * @return SsoVo + */ + @Hidden + @GetMapping(path = "ssoCurUser") + public CurUserVo ssoCurUser(String token){ + BaUser userPo = this.sv.getByUuid(token) ; + CurUserVo vo = new CurUserVo(); + if(userPo != null){ + vo.id = userPo.id ; + vo.name = userPo.userName; + } + return vo ; + } ///////////////////////////////////////////////////////////////// // // 浠ヤ笅绉佹湁鏂规硶 -- Gitblit v1.8.0