|  |  | 
 |  |  |  | 
 |  |  | import com.dy.common.aop.SsoVo; | 
 |  |  | import com.dy.common.multiDataSource.DataSourceContext; | 
 |  |  | import com.dy.common.util.MD5; | 
 |  |  | import com.dy.common.webUtil.BaseResponse; | 
 |  |  | 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; | 
 |  |  | import io.swagger.v3.oas.annotations.Operation; | 
 |  |  | import io.swagger.v3.oas.annotations.Parameter; | 
 |  |  | 
 |  |  | 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; | 
 |  |  |  | 
 |  |  | 
 |  |  |  | 
 |  |  |  | 
 |  |  |     /** | 
 |  |  |      * 客户端请求得到所有组织机构 | 
 |  |  |      * @return 所有组织机构数据 | 
 |  |  |      */ | 
 |  |  |     @Operation(summary = "所有组织机构", description = "返回所有所有组织机构数据") | 
 |  |  |     @ApiResponses(value = { | 
 |  |  |             @ApiResponse( | 
 |  |  |                     responseCode = ResultCodeMsg.RsCode.SUCCESS_CODE, | 
 |  |  |                     description = "返回所有组织机构数据(BaseResponse.content:[ { \"tag\":\"ym\", \"name\":\"元谋\" }, { \"tag\":\"片角\", \"name\":\"片角镇\" }])", | 
 |  |  |                     content = {@Content(mediaType = MediaType.APPLICATION_JSON_VALUE, | 
 |  |  |                             schema = @Schema(implementation = Org.class))} | 
 |  |  |             ) | 
 |  |  |     }) | 
 |  |  |     @GetMapping(path = "allOrg") | 
 |  |  |     public BaseResponse<List<Org>> allOrg(){ | 
 |  |  |         //List<Org> list = Arrays.asList(Org.Ym, Org.Pj) ; | 
 |  |  |         return BaseResponseUtils.buildSuccess(Org.OrgList); | 
 |  |  |     } | 
 |  |  |  | 
 |  |  |     /** | 
 |  |  |      * 客户端请求用户登录,客户端提交Json数据 | 
 |  |  |      * @param vo 用户登录值对象 | 
 |  |  |      * @param bindingResult 输入验证 | 
 |  |  | 
 |  |  |             ) | 
 |  |  |     }) | 
 |  |  |     @PostMapping(path = "loginJson", consumes = MediaType.APPLICATION_JSON_VALUE) | 
 |  |  |     public BaseResponse<UserVo> loginJson(@Valid @RequestBody LoginVo vo,  @Parameter(hidden = true) BindingResult bindingResult) { | 
 |  |  |     public BaseResponse<UserVo> loginJson(@RequestBody @Parameter(description = "登录json数据", required = true) @Valid LoginVo vo,  @Parameter(hidden = true) BindingResult bindingResult) { | 
 |  |  |         if(bindingResult != null && bindingResult.hasErrors()){ | 
 |  |  |             return BaseResponseUtils.buildFail(Objects.requireNonNull(bindingResult.getFieldError()).getDefaultMessage()); | 
 |  |  |         } | 
 |  |  |         if(!vo.phone.equals("admin")){ | 
 |  |  |             if(vo.phone.length() != 11){ | 
 |  |  |                 return BaseResponseUtils.buildFail("手机号(长度不是11位)不正确"); | 
 |  |  |             } | 
 |  |  |         } | 
 |  |  |         if(vo.orgTag == null || vo.orgTag.trim().length() == 0){ | 
 |  |  |             return BaseResponseUtils.buildFail("未选择组织单位"); | 
 |  |  |         } | 
 |  |  |         //把组织单位标签作为数据源名称 | 
 |  |  |         DataSourceContext.set(vo.orgTag); | 
 |  |  |  | 
 |  |  |         String uuid ; | 
 |  |  |         BaUser userPo ; | 
 |  |  |         try { | 
 |  |  |             //Boolean flag = cacheManager.getCacheNames().isEmpty() ; | 
 |  |  |             uuid = UUID.randomUUID().toString(); | 
 |  |  |             if(!StringUtils.isNullOrEmpty(vo.password)){ | 
 |  |  |                 /* | 
 |  |  |                 如果前端进行了base64加密 | 
 |  |  |                 po.password = new String(Base64.getDecoder().decode(po.password)) ; | 
 |  |  |                 */ | 
 |  |  |                 vo.password = MD5.encrypt(vo.password) ; | 
 |  |  |             } | 
 |  |  |             userPo = this.sv.loginWithMapperXml(uuid, vo.phone, vo.password); | 
 |  |  |         } catch (Exception e) { | 
 |  |  |             log.error("用户登录异常", e); | 
 |  |  | 
 |  |  |         try { | 
 |  |  |             //Boolean flag = cacheManager.getCacheNames().isEmpty() ; | 
 |  |  |             uuid = UUID.randomUUID().toString(); | 
 |  |  |             if(!StringUtils.isNullOrEmpty(vo.password)){ | 
 |  |  |                 /* | 
 |  |  |                 如果前端进行了base64加密 | 
 |  |  |                 po.password = new String(Base64.getDecoder().decode(po.password)) ; | 
 |  |  |                 */ | 
 |  |  |                 vo.password = MD5.encrypt(vo.password) ; | 
 |  |  |             } | 
 |  |  |             userPo = this.sv.loginWithMapperXml(uuid, vo.phone, vo.password); | 
 |  |  |         } catch (Exception e) { | 
 |  |  |             log.error("用户登录异常", e); | 
 |  |  | 
 |  |  |         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.name ; | 
 |  |  |         } | 
 |  |  |         return vo ; | 
 |  |  |     } | 
 |  |  |     ///////////////////////////////////////////////////////////////// | 
 |  |  |     // | 
 |  |  |     // 以下私有方法 |