| | |
| | | package com.dy.pipIrrBase.user; |
| | | |
| | | import com.dy.common.aop.SsoAop; |
| | | import com.dy.common.multiDataSource.DataSourceContext; |
| | | import com.dy.common.mybatis.envm.Deleted; |
| | | import com.dy.common.mybatis.envm.Disabled; |
| | | import com.dy.common.util.MD5; |
| | | import com.dy.common.webUtil.BaseResponse; |
| | | import com.dy.common.webUtil.BaseResponseUtils; |
| | | import com.dy.common.webUtil.QueryResultVo; |
| | | import com.dy.common.webUtil.ResultCodeMsg; |
| | | import com.dy.pipIrrGlobal.pojoBa.BaUser; |
| | | import com.mysql.cj.util.StringUtils; |
| | | import io.swagger.v3.oas.annotations.Operation; |
| | | import io.swagger.v3.oas.annotations.Parameter; |
| | | import io.swagger.v3.oas.annotations.media.Content; |
| | |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | | import org.springframework.http.MediaType; |
| | | import org.springframework.validation.BindingResult; |
| | | import org.springframework.web.bind.annotation.GetMapping; |
| | | import org.springframework.web.bind.annotation.PostMapping; |
| | | import org.springframework.web.bind.annotation.RequestMapping; |
| | | import org.springframework.web.bind.annotation.RestController; |
| | | import org.springframework.web.bind.annotation.*; |
| | | |
| | | import java.util.List; |
| | | import java.util.Objects; |
| | |
| | | schema = @Schema(implementation = BaUser.class))} |
| | | ) |
| | | }) |
| | | @PostMapping(path = "some") |
| | | @PostMapping(path = "some", consumes = MediaType.MULTIPART_FORM_DATA_VALUE) |
| | | @SsoAop("-1") |
| | | public BaseResponse<QueryResultVo<List<BaUser>>> some(QueryVo vo){ |
| | | //如果前端请求数据是json,则要加上注解@RequestBody |
| | | //public BaseResponse<QueryResultVo<List<BaUser>>> some(@RequestBody @Parameter(description = "查询form表单数据", required = true) @Valid QueryVo vo){ |
| | | public BaseResponse<QueryResultVo<List<BaUser>>> some(@Parameter(description = "查询form表单数据", required = true) @Valid QueryVo vo){ |
| | | try { |
| | | QueryResultVo<List<BaUser>> res = this.sv.selectSome(vo) ; |
| | | return BaseResponseUtils.buildSuccess(res); |
| | |
| | | }) |
| | | @GetMapping(path = "one") |
| | | @SsoAop("-1") |
| | | public BaseResponse<BaUser> one(@Parameter(description = "实体id", required = true) Long id){ |
| | | return BaseResponseUtils.buildSuccess(this.sv.selectById(id)); |
| | | public BaseResponse<BaUser> one(@Parameter(description = "实体id", required = true) String id){ |
| | | return BaseResponseUtils.buildSuccess(this.sv.selectById(Long.parseLong(id))); |
| | | } |
| | | |
| | | /** |
| | |
| | | po.id = null ; |
| | | int count; |
| | | try { |
| | | po.disabled = Disabled.NO ;//默认不禁用 |
| | | po.deleted = Deleted.NO ;//默认不删除 |
| | | po.orgTag = DataSourceContext.get() ;//机构标签 |
| | | if(!StringUtils.isNullOrEmpty(po.password)){ |
| | | /* |
| | | 如果前端进行了base64加密 |
| | | po.password = new String(Base64.getDecoder().decode(po.password)) ; |
| | | */ |
| | | po.password = MD5.encrypt(po.password) ;//进行加密码 |
| | | } |
| | | count = this.sv.save(po); |
| | | } catch (Exception e) { |
| | | log.error("保存用户异常", e); |
| | |
| | | } |
| | | int count; |
| | | try { |
| | | po.deleted = null ;//设置为null,不做更新 |
| | | po.orgTag = null ;//设置为null,不做更新 |
| | | count = this.sv.update(po); |
| | | } catch (Exception e) { |
| | | log.error("保存用户异常", e); |
| | |
| | | }else{ |
| | | return BaseResponseUtils.buildSuccess(true) ; |
| | | } |
| | | } |
| | | |
| | | |
| | | /** |
| | | * 修改密码 |
| | | * @param id 用户ID |
| | | * @return 是否成功 |
| | | */ |
| | | @Operation(summary = "修改密码", description = "提交用户ID、旧密码、新密码,进行改密码") |
| | | @ApiResponses(value = { |
| | | @ApiResponse( |
| | | responseCode = ResultCodeMsg.RsCode.SUCCESS_CODE, |
| | | description = "操作结果:true:成功,false:失败(BaseResponse.content)", |
| | | content = {@Content(mediaType = MediaType.APPLICATION_JSON_VALUE, |
| | | schema = @Schema(implementation = Boolean.class))} |
| | | ) |
| | | }) |
| | | @GetMapping(path = "changePassword", consumes = MediaType.TEXT_PLAIN_VALUE) |
| | | @SsoAop("-1")//@SsoAop(power = "-1") |
| | | public BaseResponse<Boolean> changePassword(@Parameter(description = "实体id", required = true) String id, |
| | | @Parameter(description = "旧密码", required = true) String oldPassword, |
| | | @Parameter(description = "新密码", required = true) String newPassword) throws Exception{ |
| | | if(id == null){ |
| | | return BaseResponseUtils.buildFail("id不能为空") ; |
| | | } |
| | | if(StringUtils.isNullOrEmpty(oldPassword)){ |
| | | return BaseResponseUtils.buildFail("旧密码不能为空") ; |
| | | } |
| | | if(StringUtils.isNullOrEmpty(newPassword)){ |
| | | return BaseResponseUtils.buildFail("新密码不能为空") ; |
| | | } |
| | | /* |
| | | 如果前端进行了base64加密 |
| | | oldPassword = new String(Base64.getDecoder().decode(oldPassword)) ; |
| | | newPassword = new String(Base64.getDecoder().decode(newPassword)) ; |
| | | */ |
| | | oldPassword = MD5.encrypt(oldPassword) ;//进行加密码 |
| | | newPassword = MD5.encrypt(newPassword) ;//进行加密码 |
| | | |
| | | Long idLg = Long.parseLong(id) ; |
| | | int count ; |
| | | try { |
| | | BaUser po = this.sv.selectById(idLg); |
| | | if(Objects.isNull(po)){ |
| | | return BaseResponseUtils.buildFail("未得到用户,请求失败") ; |
| | | }else{ |
| | | if(!po.password.equalsIgnoreCase(oldPassword)){ |
| | | return BaseResponseUtils.buildFail("旧密码不正确,请求失败") ; |
| | | }else{ |
| | | count = this.sv.changePassword(idLg, newPassword) ; |
| | | } |
| | | } |
| | | } catch (Exception e) { |
| | | log.error("保存用户异常", e); |
| | | return BaseResponseUtils.buildException(e.getMessage()) ; |
| | | } |
| | | if(count <= 0){ |
| | | return BaseResponseUtils.buildFail("数据库存储失败") ; |
| | | }else{ |
| | | return BaseResponseUtils.buildSuccess(true) ; |
| | | } |
| | | } |
| | | |
| | | |
| | | /** |
| | | * 设置用户角色 |
| | | * @param id 用户ID |
| | | * @return 是否成功 |
| | | */ |
| | | @Operation(summary = "设置用户角色", description = "提交用户ID,及所选择的角色ID集合(数组)") |
| | | @ApiResponses(value = { |
| | | @ApiResponse( |
| | | responseCode = ResultCodeMsg.RsCode.SUCCESS_CODE, |
| | | description = "操作结果:true:成功,false:失败(BaseResponse.content)", |
| | | content = {@Content(mediaType = MediaType.APPLICATION_JSON_VALUE, |
| | | schema = @Schema(implementation = Boolean.class))} |
| | | ) |
| | | }) |
| | | @GetMapping(path = "setRoles", consumes = MediaType.MULTIPART_FORM_DATA_VALUE) |
| | | @SsoAop("-1")//@SsoAop(power = "-1") |
| | | public BaseResponse<Boolean> setRoles(@Parameter(description = "实体id", required = true) String id, |
| | | @Parameter(description = "角色id数组") String[] roleIds){ |
| | | Long[] roleId_lg = null ; |
| | | if(roleIds != null && roleIds.length > 0){ |
| | | roleId_lg = new Long[roleIds.length] ; |
| | | int index = 0 ; |
| | | for(String roleId : roleIds){ |
| | | roleId_lg[index++] = Long.parseLong(roleId) ; |
| | | } |
| | | } |
| | | try { |
| | | this.sv.setRoles(Long.parseLong(id), roleId_lg); |
| | | } catch (Exception e) { |
| | | log.error("保存用户异常", e); |
| | | return BaseResponseUtils.buildException(e.getMessage()) ; |
| | | } |
| | | return BaseResponseUtils.buildSuccess(true) ; |
| | | } |
| | | |
| | | |
| | |
| | | }) |
| | | @GetMapping(path = "delete", consumes = MediaType.TEXT_PLAIN_VALUE) |
| | | @SsoAop("-1")//@SsoAop(power = "-1") |
| | | public BaseResponse<Boolean> delete(@Parameter(description = "实体id", required = true) Long id){ |
| | | public BaseResponse<Boolean> delete(@Parameter(description = "实体id", required = true) String id){ |
| | | if(id == null){ |
| | | return BaseResponseUtils.buildFail("id不能为空") ; |
| | | } |
| | | int count; |
| | | try { |
| | | count = this.sv.delete(id); |
| | | count = this.sv.delete(Long.parseLong(id)); |
| | | } catch (Exception e) { |
| | | log.error("保存用户异常", e); |
| | | return BaseResponseUtils.buildException(e.getMessage()) ; |