zcloud_gbs
/
zcloud_gbs_basic_info_gwj
12
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Merge remote-tracking branch 'origin/main' into main

main
SondonYong 2025-11-03 16:56:06 +08:00
parent 1ec2d9f1fb e256b97cb3
commit ebb28a85e1
23 changed files with 19 additions and 633 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

78
web-adapter/src/main/java/com/zcloud/basic/info/web/RiskPointController.java
View File

@ -1,78 +0,0 @@
package com.zcloud.basic.info.web;
import com.alibaba.cola.dto.MultiResponse;
import com.alibaba.cola.dto.PageResponse;
import com.alibaba.cola.dto.Response;
import com.alibaba.cola.dto.SingleResponse;
import com.zcloud.basic.info.api.RiskPointServiceI;
import com.zcloud.basic.info.dto.RiskPointAddCmd;
import com.zcloud.basic.info.dto.RiskPointPageQry;
import com.zcloud.basic.info.dto.RiskPointUpdateCmd;
import com.zcloud.basic.info.dto.clientobject.RiskPointCo;
import com.jjb.saas.framework.auth.model.SSOUser;
import com.jjb.saas.framework.auth.utils.AuthContext;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import lombok.AllArgsConstructor;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.*;
import java.util.ArrayList;
/**
* @author lin
*/
@Api(tags = "风险点管理")
@RequestMapping("/risk/riskPoint")
@RestController
@AllArgsConstructor
public class RiskPointController {
private final RiskPointServiceI riskPointService;
@ApiOperation("新增")
@PostMapping("/save")
public SingleResponse<RiskPointCo> add(@Validated @RequestBody RiskPointAddCmd cmd) {
SSOUser ssoUser = AuthContext.getCurrentUser();
return riskPointService.add(cmd);
}
@ApiOperation("分页")
@PostMapping("/list")
public PageResponse<RiskPointCo> page(@RequestBody RiskPointPageQry qry) {
return riskPointService.listPage(qry);
}
@ApiOperation("所有数据")
@GetMapping("/listAll")
public MultiResponse<RiskPointCo> listAll() {
return MultiResponse.of(new ArrayList<RiskPointCo>());
}
@ApiOperation("详情")
@GetMapping("/{id}")
public SingleResponse<RiskPointCo> getInfoById(@PathVariable("id") Long id) {
return SingleResponse.of(new RiskPointCo());
}
@ApiOperation("删除")
@DeleteMapping("/{id}")
public Response remove(@PathVariable("id") Long id) {
riskPointService.remove(id);
return SingleResponse.buildSuccess();
}
@ApiOperation("删除多个")
@DeleteMapping("/ids")
public Response removeBatch(@RequestParam Long[] ids) {
riskPointService.removeBatch(ids);
return SingleResponse.buildSuccess();
}
@ApiOperation("修改")
@PutMapping("/edit")
public SingleResponse edit(@Validated @RequestBody RiskPointUpdateCmd riskPointUpdateCmd) {
riskPointService.edit(riskPointUpdateCmd);
return SingleResponse.buildSuccess();
}
}

37
web-app/src/main/java/com/zcloud/basic/info/command/RiskPointAddExe.java
View File

@ -1,37 +0,0 @@
package com.zcloud.basic.info.command;
import com.alibaba.cola.exception.BizException;
import com.zcloud.basic.info.domain.gateway.RiskPointGateway;
import com.zcloud.basic.info.domain.model.RiskPointE;
import com.zcloud.basic.info.dto.RiskPointAddCmd;
import lombok.AllArgsConstructor;
import org.springframework.beans.BeanUtils;
import org.springframework.stereotype.Component;
import org.springframework.transaction.annotation.Transactional;
/**
* 风险点新增执行器
*
* @author lin
*/
@Component
@AllArgsConstructor
public class RiskPointAddExe {
private final RiskPointGateway riskPointGateway;
@Transactional(rollbackFor = Exception.class)
public boolean execute(RiskPointAddCmd cmd) {
RiskPointE examTypeE = new RiskPointE();
BeanUtils.copyProperties(cmd, examTypeE);
boolean res = false;
try {
res = riskPointGateway.add(examTypeE);
} catch (Exception e) {
throw new RuntimeException(e);
}
if (!res) {
throw new BizException("保存失败");
}
return true;
}
}

33
web-app/src/main/java/com/zcloud/basic/info/command/RiskPointRemoveExe.java
View File

@ -1,33 +0,0 @@
package com.zcloud.basic.info.command;
import com.alibaba.cola.exception.BizException;
import com.zcloud.basic.info.domain.gateway.RiskPointGateway;
import lombok.AllArgsConstructor;
import org.springframework.stereotype.Component;
import org.springframework.transaction.annotation.Transactional;
/**
* 风险点新增执行器
* @author lin
*/
@Component
@AllArgsConstructor
public class RiskPointRemoveExe {
private final RiskPointGateway riskPointGateway;
@Transactional(rollbackFor = Exception.class)
public boolean execute(Long id) {
boolean res = riskPointGateway.deletedRiskPointById(id);
if(!res){
throw new BizException("删除失败");
}
return true;
}
@Transactional(rollbackFor = Exception.class)
public boolean execute(Long[] ids) {
boolean res = riskPointGateway.deletedRiskPointByIds(ids);
if(!res){
throw new BizException("删除失败");
}
return true;
}
}

31
web-app/src/main/java/com/zcloud/basic/info/command/RiskPointUpdateExe.java
View File

@ -1,31 +0,0 @@
package com.zcloud.basic.info.command;
import com.alibaba.cola.exception.BizException;
import com.zcloud.basic.info.domain.gateway.RiskPointGateway;
import com.zcloud.basic.info.domain.model.RiskPointE;
import com.zcloud.basic.info.dto.RiskPointUpdateCmd;
import lombok.AllArgsConstructor;
import org.springframework.beans.BeanUtils;
import org.springframework.stereotype.Component;
import org.springframework.transaction.annotation.Transactional;
/**
* 风险点修改执行器
*
* @author lin
*/
@Component
@AllArgsConstructor
public class RiskPointUpdateExe {
private final RiskPointGateway riskPointGateway;
@Transactional(rollbackFor = Exception.class)
public void execute(RiskPointUpdateCmd riskPointUpdateCmd) {
RiskPointE riskPointE = new RiskPointE();
BeanUtils.copyProperties(riskPointUpdateCmd, riskPointE);
boolean res = riskPointGateway.update(riskPointE);
if (!res) {
throw new BizException("修改失败");
}
}
}

16
web-app/src/main/java/com/zcloud/basic/info/command/convertor/RiskPointCoConvertor.java
View File

@ -1,16 +0,0 @@
package com.zcloud.basic.info.command.convertor;
import com.zcloud.basic.info.dto.clientobject.RiskPointCo;
import com.zcloud.basic.info.persistence.dataobject.RiskPointDO;
import org.mapstruct.Mapper;
import java.util.List;
@Mapper(componentModel = "spring")
public interface RiskPointCoConvertor {
/**
* @param riskPointE
* @return
*/
List<RiskPointCo> converDOsToCOs(List<RiskPointDO> riskPointE);
}

36
web-app/src/main/java/com/zcloud/basic/info/command/query/RiskPointQueryExe.java
View File

@ -1,36 +0,0 @@
package com.zcloud.basic.info.command.query;
import com.alibaba.cola.dto.PageResponse;
import com.zcloud.basic.info.command.convertor.RiskPointCoConvertor;
import com.zcloud.basic.info.dto.RiskPointPageQry;
import com.zcloud.basic.info.dto.clientobject.RiskPointCo;
import com.zcloud.basic.info.persistence.dataobject.RiskPointDO;
import com.zcloud.basic.info.persistence.repository.RiskPointRepository;
import lombok.AllArgsConstructor;
import org.springframework.stereotype.Component;
import java.util.List;
/**
* 风险点新增执行器
*
* @author lin
*/
@Component
@AllArgsConstructor
public class RiskPointQueryExe {
private final RiskPointRepository riskPointRepository;
private final RiskPointCoConvertor riskPointCoConvertor;
/**
* 分页
*
* @param riskPointPageQry
* @return
*/
public PageResponse<RiskPointCo> execute(RiskPointPageQry riskPointPageQry) {
PageResponse<RiskPointDO> pageResponse = riskPointRepository.listRiskPointPage(riskPointPageQry.toHashMap());
List<RiskPointCo> examCenterCOS = riskPointCoConvertor.converDOsToCOs(pageResponse.getData());
return PageResponse.of(examCenterCOS, pageResponse.getTotalCount(), pageResponse.getPageSize(), pageResponse.getPageIndex());
}
}

56
web-app/src/main/java/com/zcloud/basic/info/service/RiskPointServiceImpl.java
View File

@ -1,56 +0,0 @@
package com.zcloud.basic.info.service;
import com.alibaba.cola.dto.PageResponse;
import com.alibaba.cola.dto.SingleResponse;
import com.zcloud.basic.info.api.RiskPointServiceI;
import com.zcloud.basic.info.command.RiskPointAddExe;
import com.zcloud.basic.info.command.RiskPointRemoveExe;
import com.zcloud.basic.info.command.RiskPointUpdateExe;
import com.zcloud.basic.info.command.query.RiskPointQueryExe;
import com.zcloud.basic.info.dto.RiskPointAddCmd;
import com.zcloud.basic.info.dto.RiskPointPageQry;
import com.zcloud.basic.info.dto.RiskPointUpdateCmd;
import com.zcloud.basic.info.dto.clientobject.RiskPointCo;
import lombok.AllArgsConstructor;
import org.springframework.stereotype.Service;
/**
* @author lin
*/
@Service
@AllArgsConstructor
public class RiskPointServiceImpl implements RiskPointServiceI {
private final RiskPointAddExe riskPointAddExe;
private final RiskPointUpdateExe riskPointUpdateExe;
private final RiskPointRemoveExe riskPointRemoveExe;
private final RiskPointQueryExe riskPointQueryExe;
@Override
public PageResponse<RiskPointCo> listPage(RiskPointPageQry qry){
return riskPointQueryExe.execute(qry);
}
@Override
public SingleResponse add(RiskPointAddCmd cmd) {
riskPointAddExe.execute(cmd);
return SingleResponse.buildSuccess();
}
@Override
public void edit(RiskPointUpdateCmd riskPointUpdateCmd) {
riskPointUpdateExe.execute(riskPointUpdateCmd);
}
@Override
public void remove(Long id) {
riskPointRemoveExe.execute(id);
}
@Override
public void removeBatch(Long[] ids) {
riskPointRemoveExe.execute(ids);
}
}

20
web-client/src/main/java/com/zcloud/basic/info/api/RiskPointServiceI.java
View File

@ -1,20 +0,0 @@
package com.zcloud.basic.info.api;
import com.alibaba.cola.dto.PageResponse;
import com.alibaba.cola.dto.SingleResponse;
import com.zcloud.basic.info.dto.RiskPointAddCmd;
import com.zcloud.basic.info.dto.RiskPointPageQry;
import com.zcloud.basic.info.dto.RiskPointUpdateCmd;
import com.zcloud.basic.info.dto.clientobject.RiskPointCo;
public interface RiskPointServiceI {
PageResponse<RiskPointCo> listPage(RiskPointPageQry qry);
SingleResponse<RiskPointCo> add(RiskPointAddCmd cmd);
void edit(RiskPointUpdateCmd riskPointUpdateCmd);
void remove(Long id);
void removeBatch(Long[] ids);
}

30
web-client/src/main/java/com/zcloud/basic/info/dto/RiskPointAddCmd.java
View File

@ -1,30 +0,0 @@
package com.zcloud.basic.info.dto;
import com.alibaba.cola.dto.Command;
import io.swagger.annotations.ApiModelProperty;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.EqualsAndHashCode;
import lombok.NoArgsConstructor;
import javax.validation.constraints.NotEmpty;
/**
*
* @author lin
*/
@EqualsAndHashCode(callSuper = true)
@Data
@NoArgsConstructor
@AllArgsConstructor
public class RiskPointAddCmd extends Command {
@ApiModelProperty(value = "风险点名字", name = "riskPointName", required = true)
@NotEmpty(message = "风险点名字不能为空")
private String riskPointName;
// @ApiModelProperty(value = "部门Id", name = "deptId", required = true)
// @NotEmpty
// private String deptId;
@NotEmpty(message = "部门名字不能为空")
@ApiModelProperty(value = "部门名字", name = "deptName", required = true)
private String deptName;
}

46
web-client/src/main/java/com/zcloud/basic/info/dto/RiskPointPageQry.java
View File

@ -1,46 +0,0 @@
package com.zcloud.basic.info.dto;
import com.alibaba.cola.dto.PageQuery;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import java.lang.reflect.Field;
import java.util.HashMap;
import java.util.Map;
@Data
public class RiskPointPageQry extends PageQuery {
@ApiModelProperty(value = "风险点名称")
private String likeRiskPointName;
@ApiModelProperty(value = "部门名称")
private String eqDeptName;
public Map<String, Object> toHashMap() {
Map<String, Object> map = new HashMap<>();
Class<?> clazz = this.getClass();
Field[] fields = clazz.getDeclaredFields();
for (Field field : fields) {
try {
field.setAccessible(true);
map.put(field.getName(), field.get(this));
} catch (IllegalAccessException e) {
e.printStackTrace();
}
}
Class<?> superClass = clazz.getSuperclass();
if (superClass != null) {
Field[] superFields = superClass.getDeclaredFields();
for (Field field : superFields) {
try {
field.setAccessible(true);
map.put(field.getName(), field.get(this));
} catch (IllegalAccessException e) {
e.printStackTrace();
}
}
}
return map;
}
}

31
web-client/src/main/java/com/zcloud/basic/info/dto/RiskPointUpdateCmd.java
View File

@ -1,31 +0,0 @@
package com.zcloud.basic.info.dto;
import com.alibaba.cola.dto.Command;
import io.swagger.annotations.ApiModelProperty;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.EqualsAndHashCode;
import lombok.NoArgsConstructor;
import javax.validation.constraints.NotEmpty;
/**
*
* @author lin
*/
@EqualsAndHashCode(callSuper = true)
@Data
@NoArgsConstructor
@AllArgsConstructor
public class RiskPointUpdateCmd extends Command {
@ApiModelProperty(value = "风险点id", name = "id", required = true)
@NotEmpty
private String id;
@ApiModelProperty(value = "风险点名字", name = "riskPointName", required = true)
@NotEmpty
private String riskPointName;
@NotEmpty
@ApiModelProperty(value = "部门名字", name = "deptName", required = true)
private String deptName;
}

17
web-client/src/main/java/com/zcloud/basic/info/dto/clientobject/RiskPointCo.java
View File

@ -1,17 +0,0 @@
package com.zcloud.basic.info.dto.clientobject;
import com.alibaba.cola.dto.ClientObject;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
@Data
public class RiskPointCo extends ClientObject {
@ApiModelProperty(value = "id")
private Long id;
@ApiModelProperty(value = "风险点名称")
private String riskPointName;
@ApiModelProperty(value = "部门名称")
private String deptName;
@ApiModelProperty(value = "创建人")
private String createName;
}

33
web-domain/src/main/java/com/zcloud/basic/info/domain/gateway/RiskPointGateway.java
View File

@ -1,33 +0,0 @@
package com.zcloud.basic.info.domain.gateway;
import com.zcloud.basic.info.domain.model.RiskPointE;
/**
* 领域getway
* @author lin
*/
public interface RiskPointGateway {
/**
* 新增
* @param riskPointE 准考证管理
* @return 结果
*/
Boolean add(RiskPointE riskPointE) ;
/**
* 修改
* @param riskPointE 准考证管理
* @return 结果
*/
Boolean update(RiskPointE riskPointE);
/**
* 删除
* @param id
* @return 结果
*/
Boolean deletedRiskPointById(Long id);
Boolean deletedRiskPointByIds(Long[] id);
}

20
web-domain/src/main/java/com/zcloud/basic/info/domain/model/RiskPointE.java
View File

@ -1,20 +0,0 @@
package com.zcloud.basic.info.domain.model;
import com.alibaba.cola.domain.Entity;
import com.jjb.saas.framework.domain.model.BaseE;
import lombok.Data;
import lombok.EqualsAndHashCode;
/**
* 领域模型，根据领域模型驱动设计
*
* @author lin
*/
@Data
@Entity
@EqualsAndHashCode(callSuper = true)
public class RiskPointE extends BaseE {
private Long id;
private String riskPointName;
private String deptName;
}

51
web-infrastructure/src/main/java/com/zcloud/basic/info/gatewayimpl/RiskPointGatewayImpl.java
View File

@ -1,51 +0,0 @@
package com.zcloud.basic.info.gatewayimpl;
import com.zcloud.basic.info.domain.gateway.RiskPointGateway;
import com.zcloud.basic.info.domain.model.RiskPointE;
import com.zcloud.basic.info.persistence.dataobject.RiskPointDO;
import com.zcloud.basic.info.persistence.repository.RiskPointRepository;
import lombok.AllArgsConstructor;
import org.springframework.beans.BeanUtils;
import org.springframework.stereotype.Service;
import java.util.Arrays;
/**
* 持久层实现
*
* @author lin
*/
@Service
@AllArgsConstructor
public class RiskPointGatewayImpl implements RiskPointGateway {
private final RiskPointRepository riskPointRepository;
@Override
public Boolean add(RiskPointE riskPointE) {
RiskPointDO d = new RiskPointDO();
BeanUtils.copyProperties(riskPointE, d);
riskPointRepository.save(d);
return true;
}
@Override
public Boolean update(RiskPointE riskPointE) {
RiskPointDO d = new RiskPointDO();
BeanUtils.copyProperties(riskPointE, d);
riskPointRepository.updateById(d);
return true;
}
@Override
public Boolean deletedRiskPointById(Long id) {
return riskPointRepository.removeById(id);
}
@Override
public Boolean deletedRiskPointByIds(Long[] ids) {
return riskPointRepository.removeByIds(Arrays.asList(ids));
}
}

1
web-infrastructure/src/main/java/com/zcloud/basic/info/persistence/dataobject/PostDepartmentDO.java
View File

@ -9,6 +9,7 @@ import lombok.NoArgsConstructor;
/**
* web-infrastructure
*
* @Author SondonYong
* @Date 2025-10-31 17:53:11
*/

16
web-infrastructure/src/main/java/com/zcloud/basic/info/persistence/dataobject/RiskPointDO.java
View File

@ -1,16 +0,0 @@
package com.zcloud.basic.info.persistence.dataobject;
import com.baomidou.mybatisplus.annotation.TableName;
import com.jjb.saas.framework.repository.basedo.BaseDO;
import lombok.Data;
import lombok.EqualsAndHashCode;
@Data
@EqualsAndHashCode(callSuper = true)
@TableName("risk_point")
public class RiskPointDO extends BaseDO {
private String riskPointName;
private String deptName;
}

1
web-infrastructure/src/main/java/com/zcloud/basic/info/persistence/dataobject/UserQualificationInfoDO.java
View File

@ -11,6 +11,7 @@ import java.util.Date;
/**
* web-infrastructure
*
* @Author SondonYong
* @Date 2025-10-31 09:50:31
*/

1
web-infrastructure/src/main/java/com/zcloud/basic/info/persistence/mapper/PostMapper.java
View File

@ -7,6 +7,7 @@ import org.apache.ibatis.annotations.Mapper;
/**
* web-infrastructure
*
*
* @Author SondonYong
* @Date 2025-10-31 17:24:04
*/

9
web-infrastructure/src/main/java/com/zcloud/basic/info/persistence/mapper/RiskPointMapper.java
View File

@ -1,9 +0,0 @@
package com.zcloud.basic.info.persistence.mapper;
import com.zcloud.basic.info.persistence.dataobject.RiskPointDO;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import org.apache.ibatis.annotations.Mapper;
@Mapper
public interface RiskPointMapper extends BaseMapper<RiskPointDO> {
}

15
web-infrastructure/src/main/java/com/zcloud/basic/info/persistence/repository/RiskPointRepository.java
View File

@ -1,15 +0,0 @@
package com.zcloud.basic.info.persistence.repository;
import com.alibaba.cola.dto.PageResponse;
import com.zcloud.basic.info.persistence.dataobject.RiskPointDO;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.jjb.saas.framework.repository.repo.BaseRepository;
import java.util.Map;
/**
* @author lin
*/
public interface RiskPointRepository extends BaseRepository<RiskPointDO> {
PageResponse<RiskPointDO> listRiskPointPage(Map<String,Object> parmas);
}

35
web-infrastructure/src/main/java/com/zcloud/basic/info/persistence/repository/impl/RiskPointRepositoryImpl.java
View File

@ -1,35 +0,0 @@
package com.zcloud.basic.info.persistence.repository.impl;
import com.alibaba.cola.dto.PageResponse;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.jjb.saas.framework.repository.common.PageHelper;
import com.jjb.saas.framework.repository.repo.impl.BaseRepositoryImpl;
import com.zcloud.basic.info.persistence.dataobject.RiskPointDO;
import com.zcloud.basic.info.persistence.mapper.RiskPointMapper;
import com.zcloud.basic.info.persistence.repository.RiskPointRepository;
import com.zcloud.basic.info.utils.PageQueryHelper;
import com.zcloud.basic.info.utils.Query;
import lombok.RequiredArgsConstructor;
import org.springframework.stereotype.Service;
import java.util.Map;
/**
* @author lin
*/
@Service
@RequiredArgsConstructor
public class RiskPointRepositoryImpl extends BaseRepositoryImpl<RiskPointMapper, RiskPointDO> implements RiskPointRepository {
private final RiskPointMapper riskPointMapper;
@Override
public PageResponse<RiskPointDO> listRiskPointPage(Map<String, Object> parmas) {
IPage<RiskPointDO> iPage = new Query<RiskPointDO>().getPage(parmas);
QueryWrapper<RiskPointDO> queryWrapper = new QueryWrapper<>();
queryWrapper = PageQueryHelper.createPageQueryWrapper(queryWrapper, parmas);
queryWrapper.orderByDesc("create_time");
IPage<RiskPointDO> result = riskPointMapper.selectPage(iPage, queryWrapper);
return PageHelper.pageToResponse(result, result.getRecords());
}
}

7
web-infrastructure/src/main/resources/mapper/RiskPointMapper.xml
View File

@ -1,7 +0,0 @@
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
"http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.zcloud.basic.info.persistence.mapper.RiskPointMapper">
</mapper>