Compare commits

..

No commits in common. "f83f8cb3235f798a5e227ce1c0e5f1fe798641f1" and "396c045704e273c1fd2b25dbfc32e1bc7a3680fc" have entirely different histories.

10 changed files with 36 additions and 110 deletions

View File

@ -1,7 +1,6 @@
package com.zcloud.basic.info.web; package com.zcloud.basic.info.web;
import cn.hutool.core.util.StrUtil;
import com.alibaba.cola.exception.BizException; import com.alibaba.cola.exception.BizException;
import com.zcloud.basic.info.api.PostServiceI; import com.zcloud.basic.info.api.PostServiceI;
import com.zcloud.basic.info.dto.*; import com.zcloud.basic.info.dto.*;
@ -17,8 +16,6 @@ import lombok.AllArgsConstructor;
import org.springframework.validation.annotation.Validated; import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.*; import org.springframework.web.bind.annotation.*;
import java.util.Arrays;
/** /**
* web-adapter * web-adapter
@ -52,11 +49,6 @@ public class PostController {
if(qry.getCorpFlag() == 2){ if(qry.getCorpFlag() == 2){
qry.setEqCorpinfoId(AuthContext.getTenantId()); qry.setEqCorpinfoId(AuthContext.getTenantId());
} }
// 数据类型转换
if(StrUtil.isNotBlank(qry.getDepartmentIdString())){
qry.setEqDepartmentId(Long.parseLong(qry.getDepartmentIdString()));
}
return postService.listPage(qry); return postService.listPage(qry);
} }
@ -66,15 +58,6 @@ public class PostController {
if(qry.getCorpFlag() == 2){ if(qry.getCorpFlag() == 2){
qry.setCorpinfoId(AuthContext.getTenantId()); qry.setCorpinfoId(AuthContext.getTenantId());
} }
// 数据类型转换
if(StrUtil.isNotBlank(qry.getDepartmentIdString())){
qry.setDepartmentId(Long.parseLong(qry.getDepartmentIdString()));
}
if(qry.getPostIdsString() != null && qry.getPostIdsString().length > 0){
qry.setPostIds(Arrays.stream(qry.getPostIdsString())
.map(Long::valueOf)
.toArray(Long[]::new));
}
return postService.list(qry); return postService.list(qry);
} }
@ -96,18 +79,6 @@ public class PostController {
@ApiOperation("删除多个") @ApiOperation("删除多个")
@PutMapping("/removeBatch") @PutMapping("/removeBatch")
public Response removeBatch(@Validated @RequestBody PostRemoveCmd cmd) { public Response removeBatch(@Validated @RequestBody PostRemoveCmd cmd) {
if(cmd.getIdsString()== null || cmd.getIdsString().length == 0){
throw new BizException("请选择要删除的项。");
}
// 数据类型转换
if(cmd.getIdsString() != null && cmd.getIdsString().length > 0){
cmd.setIds(Arrays.stream(cmd.getIdsString())
.map(Long::valueOf)
.toArray(Long[]::new));
}
postService.removeBatch(cmd.getIds()); postService.removeBatch(cmd.getIds());
return SingleResponse.buildSuccess(); return SingleResponse.buildSuccess();
} }

View File

@ -1,7 +1,6 @@
package com.zcloud.basic.info.command; package com.zcloud.basic.info.command;
import cn.hutool.core.collection.CollUtil; import cn.hutool.core.collection.CollUtil;
import cn.hutool.core.util.StrUtil;
import com.zcloud.basic.info.domain.gateway.PostDepartmentGateway; import com.zcloud.basic.info.domain.gateway.PostDepartmentGateway;
import com.zcloud.basic.info.domain.gateway.PostGateway; import com.zcloud.basic.info.domain.gateway.PostGateway;
import com.zcloud.basic.info.domain.model.PostDepartmentE; import com.zcloud.basic.info.domain.model.PostDepartmentE;
@ -13,7 +12,6 @@ import org.springframework.beans.BeanUtils;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
import org.springframework.transaction.annotation.Transactional; import org.springframework.transaction.annotation.Transactional;
import java.util.Arrays;
import java.util.List; import java.util.List;
import java.util.Objects; import java.util.Objects;
@ -32,17 +30,6 @@ public class PostAddExe {
@Transactional(rollbackFor = Exception.class) @Transactional(rollbackFor = Exception.class)
public boolean execute(PostAddCmd cmd) { public boolean execute(PostAddCmd cmd) {
// 数据类型转换
if(StrUtil.isNotBlank(cmd.getDepartmentIdString())){
cmd.setDepartmentId(Long.parseLong(cmd.getDepartmentIdString()));
}
if(cmd.getDepartmentIdsString() != null && cmd.getDepartmentIdsString().length > 0){
cmd.setDepartmentIds(Arrays.stream(cmd.getDepartmentIdsString())
.map(Long::valueOf)
.toArray(Long[]::new));
}
PostE postE = new PostE(); PostE postE = new PostE();
BeanUtils.copyProperties(cmd, postE); BeanUtils.copyProperties(cmd, postE);
boolean res = false; boolean res = false;

View File

@ -41,13 +41,13 @@ public class PostRemoveExe {
@Transactional(rollbackFor = Exception.class) @Transactional(rollbackFor = Exception.class)
public boolean execute(Long id) { public boolean execute(Long id) {
// 这段代码后续放到user的方法中, 校验是否有人员使用该岗位 // 这段代码后续放到user的方法中, 校验是否有人员使用该岗位
// QueryWrapper queryWrapper = new QueryWrapper(); QueryWrapper queryWrapper = new QueryWrapper();
// queryWrapper.eq("post_id", id); queryWrapper.eq("post_id", id);
// queryWrapper.eq("delete_enum", "FALSE"); queryWrapper.eq("delete_enum", "FALSE");
// List userPostList = userRepository.list(queryWrapper); List userPostList = userRepository.list(queryWrapper);
// if (userPostList != null && userPostList.size() > 0) { if (userPostList != null && userPostList.size() > 0) {
// throw new BizException("岗位有相应人员,请解除相关岗位信息后删除。"); throw new BizException("岗位有相应人员,请解除相关岗位信息后删除。");
// } }
boolean res = postGateway.deletedPostById(id); boolean res = postGateway.deletedPostById(id);
postDepartmentGateway.deletedPostDepartment(id); postDepartmentGateway.deletedPostDepartment(id);
@ -65,13 +65,13 @@ public class PostRemoveExe {
throw new BizException("岗位ID不能为空"); throw new BizException("岗位ID不能为空");
} }
// 这段代码后续放到user的方法中, 校验是否有人员使用该岗位 // 这段代码后续放到user的方法中, 校验是否有人员使用该岗位
// QueryWrapper<UserDO> queryWrapper = new QueryWrapper(); QueryWrapper<UserDO> queryWrapper = new QueryWrapper();
// queryWrapper.in("post_id", ids); queryWrapper.in("post_id", ids);
// queryWrapper.eq("delete_enum", "FALSE"); queryWrapper.eq("delete_enum", "FALSE");
// List<UserDO> userPostList = userRepository.list(queryWrapper); List<UserDO> userPostList = userRepository.list(queryWrapper);
// if (userPostList != null && userPostList.size() > 0) { if (userPostList != null && userPostList.size() > 0) {
// throw new BizException("岗位有相应人员,请解除相关岗位信息后删除。"); throw new BizException("岗位有相应人员,请解除相关岗位信息后删除。");
// } }
boolean res = postGateway.deletedPostByIds(ids); boolean res = postGateway.deletedPostByIds(ids);
postDepartmentGateway.deletedPostDepartment(ids); postDepartmentGateway.deletedPostDepartment(ids);

View File

@ -1,7 +1,6 @@
package com.zcloud.basic.info.command; package com.zcloud.basic.info.command;
import cn.hutool.core.collection.CollUtil; import cn.hutool.core.collection.CollUtil;
import cn.hutool.core.util.StrUtil;
import com.alibaba.cola.exception.BizException; import com.alibaba.cola.exception.BizException;
import com.zcloud.basic.info.domain.gateway.PostDepartmentGateway; import com.zcloud.basic.info.domain.gateway.PostDepartmentGateway;
import com.zcloud.basic.info.domain.gateway.PostGateway; import com.zcloud.basic.info.domain.gateway.PostGateway;
@ -18,7 +17,6 @@ import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
import org.springframework.transaction.annotation.Transactional; import org.springframework.transaction.annotation.Transactional;
import java.util.Arrays;
import java.util.List; import java.util.List;
@ -38,25 +36,10 @@ public class PostUpdateExe {
private ZcloudRedisUtil zcloudRedisUtil; private ZcloudRedisUtil zcloudRedisUtil;
@Transactional(rollbackFor = Exception.class) @Transactional(rollbackFor = Exception.class)
public void execute(PostUpdateCmd postUpdateCmd) { public void execute(PostUpdateCmd postUpdateCmd) {
// 数据类型转换
if(StrUtil.isNotBlank(postUpdateCmd.getIdString())){
postUpdateCmd.setId(Long.parseLong(postUpdateCmd.getIdString()));
}
if(StrUtil.isNotBlank(postUpdateCmd.getDepartmentIdString())){
postUpdateCmd.setDepartmentId(Long.parseLong(postUpdateCmd.getDepartmentIdString()));
}
if(postUpdateCmd.getDepartmentIdsString() != null && postUpdateCmd.getDepartmentIdsString().length > 0){
postUpdateCmd.setDepartmentIds(Arrays.stream(postUpdateCmd.getDepartmentIdsString())
.map(Long::valueOf)
.toArray(Long[]::new));
}
PostDO postDO = postRepository.getById(postUpdateCmd.getId()); PostDO postDO = postRepository.getById(postUpdateCmd.getId());
if (postDO == null) { if (postDO == null) {
throw new BizException("岗位不存在"); throw new BizException("岗位不存在");
} }
PostE postE = new PostE(); PostE postE = new PostE();
BeanUtils.copyProperties(postUpdateCmd, postE); BeanUtils.copyProperties(postUpdateCmd, postE);
boolean res = postGateway.update(postE); boolean res = postGateway.update(postE);

View File

@ -24,7 +24,10 @@ import lombok.AllArgsConstructor;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
import org.springframework.beans.BeanUtils; import org.springframework.beans.BeanUtils;
import java.util.*; import java.util.Arrays;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.stream.Collectors; import java.util.stream.Collectors;
@ -54,11 +57,6 @@ public class PostQueryExe {
Map<String, Object> params = PageQueryHelper.toHashMap(postPageQry); Map<String, Object> params = PageQueryHelper.toHashMap(postPageQry);
PageResponse<PostDO> pageResponse = postRepository.listPage(params); PageResponse<PostDO> pageResponse = postRepository.listPage(params);
if(CollUtil.isEmpty(pageResponse.getData())){
List<PostCO> postCOList = new ArrayList<>();
return PageResponse.of(postCOList, pageResponse.getTotalCount(), pageResponse.getPageSize(), pageResponse.getPageIndex());
}
Long[] departmentIds = pageResponse.getData().stream().map(PostDO::getDepartmentId).toArray(Long[]::new); Long[] departmentIds = pageResponse.getData().stream().map(PostDO::getDepartmentId).toArray(Long[]::new);
List<DepartmentDO> departmentDOList = departmentRepository.listByIds(Arrays.asList(departmentIds)); List<DepartmentDO> departmentDOList = departmentRepository.listByIds(Arrays.asList(departmentIds));

View File

@ -20,17 +20,15 @@ import javax.validation.constraints.*;
@NoArgsConstructor @NoArgsConstructor
@AllArgsConstructor @AllArgsConstructor
public class PostAddCmd extends Command { public class PostAddCmd extends Command {
@ApiModelProperty(value = "部门id", name = "departmentIdString", required = true) @ApiModelProperty(value = "部门id", name = "departmentId", required = true)
@NotEmpty(message = "部门id不能为空") @NotNull(message = "部门id不能为空")
private String departmentIdString;
private Long departmentId; private Long departmentId;
@ApiModelProperty(value = "岗位名称", name = "postName", required = true) @ApiModelProperty(value = "岗位名称", name = "postName", required = true)
@NotEmpty(message = "岗位名称不能为空") @NotEmpty(message = "岗位名称不能为空")
private String postName; private String postName;
@ApiModelProperty(value = "岗位职责", name = "remarks", required = true) @ApiModelProperty(value = "岗位职责", name = "remarks")
@NotEmpty(message = "岗位职责不能为空")
private String remarks; private String remarks;
// @ApiModelProperty(value = "状态 1-启用, 2-禁用", name = "status", required = true) // @ApiModelProperty(value = "状态 1-启用, 2-禁用", name = "status", required = true)
@ -48,11 +46,10 @@ public class PostAddCmd extends Command {
@ApiModelProperty(value = "是否监管岗位 0-否, 1-是", name = "supervisionFlag") @ApiModelProperty(value = "是否监管岗位 0-否, 1-是", name = "supervisionFlag")
private Integer supervisionFlag; private Integer supervisionFlag;
@ApiModelProperty(value = "岗位-部门权限", name = "departmentIdsString") @ApiModelProperty(value = "岗位-部门权限", name = "departmentIds")
private String[] departmentIdsString;
private Long[] departmentIds; private Long[] departmentIds;
@ApiModelProperty(value = "监管端/企业端标识,1-监管端, 2-企业端", name = "corpFlag", required = true) @ApiModelProperty(value = "监管端/企业端标识,1-监管端, 2-企业端", name = "corpFlag")
@NotNull(message = "监管端/企业端标识不能为空") @NotNull(message = "监管端/企业端标识不能为空")
private Integer corpFlag; private Integer corpFlag;
} }

View File

@ -3,7 +3,6 @@ package com.zcloud.basic.info.dto;
import io.swagger.annotations.ApiModelProperty; import io.swagger.annotations.ApiModelProperty;
import lombok.Data; import lombok.Data;
import javax.validation.constraints.NotEmpty;
import javax.validation.constraints.NotNull; import javax.validation.constraints.NotNull;
@ -32,15 +31,13 @@ public class PostListQry {
// 监管端/企业端标识,1-监管端, 2-企业端 // 监管端/企业端标识,1-监管端, 2-企业端
private Integer corpFlag; private Integer corpFlag;
@ApiModelProperty(value = "主键id集合", name = "postIdsString") @ApiModelProperty(value = "主键id集合", name = "postIds", required = true)
// 主键id集合 // 主键id集合
private String[] postIdsString;
private Long[] postIds; private Long[] postIds;
@ApiModelProperty(value = "部门id", name = "departmentIdString", required = true) @ApiModelProperty(value = "部门id", name = "departmentId", required = true)
@NotEmpty(message = "部门id不能为空") @NotNull(message = "部门id不能为空")
// 部门id // 部门id
private String departmentIdString;
private Long departmentId; private Long departmentId;
@ApiModelProperty(value = "企业id", name = "corpinfoId", required = true) @ApiModelProperty(value = "企业id", name = "corpinfoId", required = true)

View File

@ -4,7 +4,6 @@ import com.alibaba.cola.dto.PageQuery;
import io.swagger.annotations.ApiModelProperty; import io.swagger.annotations.ApiModelProperty;
import lombok.Data; import lombok.Data;
import javax.validation.constraints.NotEmpty;
import javax.validation.constraints.NotNull; import javax.validation.constraints.NotNull;
@ -33,10 +32,9 @@ public class PostPageQry extends PageQuery {
// 监管端/企业端标识,1-监管端, 2-企业端 // 监管端/企业端标识,1-监管端, 2-企业端
private Integer corpFlag; private Integer corpFlag;
@ApiModelProperty(value = "部门id", name = "departmentIdString", required = true) @ApiModelProperty(value = "部门id", name = "eqDepartmentId", required = true)
@NotEmpty(message = "部门id不能为空") @NotNull(message = "部门id不能为空")
// 部门id // 部门id
private String departmentIdString;
private Long eqDepartmentId; private Long eqDepartmentId;
@ApiModelProperty(value = "企业id", name = "eqCorpinfoId") @ApiModelProperty(value = "企业id", name = "eqCorpinfoId")

View File

@ -21,9 +21,8 @@ import javax.validation.constraints.*;
@AllArgsConstructor @AllArgsConstructor
public class PostRemoveCmd extends Command { public class PostRemoveCmd extends Command {
@ApiModelProperty(value = "主键", name = "idsString", required = true) @ApiModelProperty(value = "主键", name = "ids", required = true)
@NotEmpty(message = "主键不能为空") @NotNull(message = "主键不能为空")
private String[] idsString;
private Long[] ids; private Long[] ids;
} }

View File

@ -20,22 +20,19 @@ import javax.validation.constraints.*;
@NoArgsConstructor @NoArgsConstructor
@AllArgsConstructor @AllArgsConstructor
public class PostUpdateCmd extends Command { public class PostUpdateCmd extends Command {
@ApiModelProperty(value = "主键", name = "idString", required = true) @ApiModelProperty(value = "主键", name = "id", required = true)
@NotEmpty(message = "主键不能为空") @NotNull(message = "主键不能为空")
private String idString;
private Long id; private Long id;
@ApiModelProperty(value = "部门id", name = "departmentIdString", required = true) @ApiModelProperty(value = "部门id", name = "departmentId", required = true)
@NotEmpty(message = "部门id不能为空") @NotNull(message = "部门id不能为空")
private String departmentIdString;
private Long departmentId; private Long departmentId;
@ApiModelProperty(value = "岗位名称", name = "postName", required = true) @ApiModelProperty(value = "岗位名称", name = "postName", required = true)
@NotEmpty(message = "岗位名称不能为空") @NotEmpty(message = "岗位名称不能为空")
private String postName; private String postName;
@ApiModelProperty(value = "岗位职责", name = "remarks", required = true) @ApiModelProperty(value = "岗位职责", name = "remarks")
@NotEmpty(message = "岗位职责不能为空")
private String remarks; private String remarks;
// @ApiModelProperty(value = "状态 1-启用, 2-禁用", name = "status", required = true) // @ApiModelProperty(value = "状态 1-启用, 2-禁用", name = "status", required = true)
@ -53,8 +50,7 @@ public class PostUpdateCmd extends Command {
@ApiModelProperty(value = "是否监管岗位 0-否, 1-是", name = "supervisionFlag") @ApiModelProperty(value = "是否监管岗位 0-否, 1-是", name = "supervisionFlag")
private Integer supervisionFlag; private Integer supervisionFlag;
@ApiModelProperty(value = "岗位 部门权限", name = "departmentIdsString") @ApiModelProperty(value = "岗位 部门权限", name = "departmentIds")
private String[] departmentIdsString;
private Long[] departmentIds; private Long[] departmentIds;
@ApiModelProperty(value = "监管端/企业端标识,1-监管端, 2-企业端", name = "corpFlag", required = true) @ApiModelProperty(value = "监管端/企业端标识,1-监管端, 2-企业端", name = "corpFlag", required = true)