mirror of
https://github.com/abcv7/sfbx-cloud.git
synced 2026-08-16 11:47:00 +00:00
功能：添加核心框架组件、规则引擎以及各种微服务的初步实现，包括保险、安全、积分、短信、文件和交易。
This commit is contained in:
abcv7
-119
@@ -1,123 +1,4 @@
|
||||
package com.itheima.sfbx.insurance.web;
|
||||
|
||||
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
||||
import com.github.xiaoymin.knife4j.annotations.ApiOperationSupport;
|
||||
import com.itheima.sfbx.framework.commons.basic.ResponseResult;
|
||||
import com.itheima.sfbx.framework.commons.utils.ResponseResultBuild;
|
||||
import com.itheima.sfbx.insurance.dto.SafeguardVO;
|
||||
import com.itheima.sfbx.insurance.service.ISafeguardService;
|
||||
import io.swagger.annotations.Api;
|
||||
import io.swagger.annotations.ApiImplicitParam;
|
||||
import io.swagger.annotations.ApiImplicitParams;
|
||||
import io.swagger.annotations.ApiOperation;
|
||||
import lombok.extern.slf4j.Slf4j;
|
||||
import org.springframework.beans.factory.annotation.Autowired;
|
||||
import org.springframework.web.bind.annotation.*;
|
||||
|
||||
import java.util.List;
|
||||
|
||||
/**
|
||||
* @Description：保障项响应接口
|
||||
*/
|
||||
@Slf4j
|
||||
@Api(tags = "保障项")
|
||||
@RestController
|
||||
@RequestMapping("safeguard")
|
||||
public class SafeguardController {
|
||||
|
||||
@Autowired
|
||||
ISafeguardService safeguardService;
|
||||
|
||||
/***
|
||||
* @description 多条件查询保障项分页
|
||||
* @param safeguardVO 保障项VO查询条件
|
||||
* @param pageNum 页码
|
||||
* @param pageSize 每页条数
|
||||
* @return: Page<SafeguardVO>
|
||||
*/
|
||||
@PostMapping("page/{pageNum}/{pageSize}")
|
||||
@ApiOperation(value = "保障项分页",notes = "保障项分页")
|
||||
@ApiImplicitParams({
|
||||
@ApiImplicitParam(name = "safeguardVO",value = "保障项VO对象",required = true,dataType = "SafeguardVO"),
|
||||
@ApiImplicitParam(paramType = "path",name = "pageNum",value = "页码",example = "1",dataType = "Integer"),
|
||||
@ApiImplicitParam(paramType = "path",name = "pageSize",value = "每页条数",example = "10",dataType = "Integer")
|
||||
})
|
||||
@ApiOperationSupport(includeParameters = {"safeguardVO.dataState","safeguardVO.safeguardKey","safeguardVO.safeguardKeyName","safeguardVO.safeguardVal","safeguardVO.safeguardType","safeguardVO.sortNo","safeguardVO.remake"})
|
||||
public ResponseResult<Page<SafeguardVO>> findSafeguardVOPage(
|
||||
@RequestBody SafeguardVO safeguardVO,
|
||||
@PathVariable("pageNum") int pageNum,
|
||||
@PathVariable("pageSize") int pageSize) {
|
||||
Page<SafeguardVO> safeguardVOPage = safeguardService.findPage(safeguardVO, pageNum, pageSize);
|
||||
return ResponseResultBuild.successBuild(safeguardVOPage);
|
||||
}
|
||||
|
||||
/**
|
||||
* @Description 保存保障项
|
||||
* @param safeguardVO 保障项VO对象
|
||||
* @return SafeguardVO
|
||||
*/
|
||||
@PutMapping
|
||||
@ApiOperation(value = "保存Safeguard",notes = "添加Safeguard")
|
||||
@ApiImplicitParam(name = "safeguardVO",value = "保障项VO对象",required = true,dataType = "SafeguardVO")
|
||||
@ApiOperationSupport(includeParameters = {"safeguardVO.dataState","safeguardVO.safeguardKey","safeguardVO.safeguardKeyName","safeguardVO.safeguardVal","safeguardVO.safeguardType","safeguardVO.sortNo","safeguardVO.remake"})
|
||||
public ResponseResult<SafeguardVO> createSafeguard(@RequestBody SafeguardVO safeguardVO) {
|
||||
SafeguardVO safeguardVOResult = safeguardService.save(safeguardVO);
|
||||
return ResponseResultBuild.successBuild(safeguardVOResult);
|
||||
}
|
||||
|
||||
/**
|
||||
* @Description 修改保障项
|
||||
* @param safeguardVO 保障项VO对象
|
||||
* @return Boolean 是否修改成功
|
||||
*/
|
||||
@PatchMapping
|
||||
@ApiOperation(value = "修改保障项",notes = "修改保障项")
|
||||
@ApiImplicitParam(name = "safeguardVO",value = "保障项VO对象",required = true,dataType = "SafeguardVO")
|
||||
@ApiOperationSupport(includeParameters = {"safeguardVO.id","safeguardVO.dataState","safeguardVO.safeguardKey","safeguardVO.safeguardKeyName","safeguardVO.safeguardVal","safeguardVO.safeguardType","safeguardVO.sortNo","safeguardVO.remake"})
|
||||
public ResponseResult<Boolean> updateSafeguard(@RequestBody SafeguardVO safeguardVO) {
|
||||
Boolean flag = safeguardService.update(safeguardVO);
|
||||
return ResponseResultBuild.successBuild(flag);
|
||||
}
|
||||
|
||||
/**
|
||||
* @Description 删除保障项
|
||||
* @param safeguardVO 刪除条件：checkedIds 不可为空
|
||||
* @return
|
||||
*/
|
||||
@DeleteMapping
|
||||
@ApiOperation(value = "删除保障项",notes = "删除保障项")
|
||||
@ApiImplicitParam(name = "safeguardVO",value = "保障项VO对象",required = true,dataType = "SafeguardVO")
|
||||
@ApiOperationSupport(includeParameters = {"safeguardVO.checkedIds"})
|
||||
public ResponseResult<Boolean> deleteSafeguard(@RequestBody SafeguardVO safeguardVO) {
|
||||
Boolean flag = safeguardService.delete(safeguardVO.getCheckedIds());
|
||||
return ResponseResultBuild.successBuild(flag);
|
||||
}
|
||||
|
||||
/***
|
||||
* @description 多条件查询保障项列表
|
||||
* @param safeguardVO 保障项VO对象
|
||||
* @return List<SafeguardVO>
|
||||
*/
|
||||
@PostMapping("list")
|
||||
@ApiOperation(value = "多条件查询保障项列表",notes = "多条件查询保障项列表")
|
||||
@ApiImplicitParam(name = "safeguardVO",value = "保障项VO对象",required = true,dataType = "SafeguardVO")
|
||||
@ApiOperationSupport(includeParameters = {"safeguardVO.dataState","safeguardVO.safeguardKey","safeguardVO.safeguardKeyName","safeguardVO.safeguardVal","safeguardVO.safeguardType","safeguardVO.sortNo","safeguardVO.remake"})
|
||||
public ResponseResult<List<SafeguardVO>> safeguardList(@RequestBody SafeguardVO safeguardVO) {
|
||||
List<SafeguardVO> safeguardVOList = safeguardService.findList(safeguardVO);
|
||||
return ResponseResultBuild.successBuild(safeguardVOList);
|
||||
}
|
||||
|
||||
/***
|
||||
* @description 按safeguardKey查询SafeguardVO
|
||||
* @param safeguardKey 保障项key
|
||||
* @return SafeguardVO
|
||||
*/
|
||||
@PostMapping("safeguard-key/{safeguardKey}")
|
||||
@ApiOperation(value = "保障项key查询SafeguardVO",notes = "保障项key查询SafeguardVO")
|
||||
@ApiImplicitParam(paramType = "path",name = "safeguardKey",value = "保障项key",dataType = "String")
|
||||
public ResponseResult<SafeguardVO> findBySafeguardKey(@PathVariable("safeguardKey") String safeguardKey) {
|
||||
SafeguardVO safeguardVO = safeguardService.findBySafeguardKey(safeguardKey);
|
||||
return ResponseResultBuild.successBuild(safeguardVO);
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
+1
-217
@@ -1,220 +1,4 @@
|
||||
package com.itheima.sfbx.insurance.service.impl;
|
||||
|
||||
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
||||
import com.itheima.sfbx.framework.commons.constant.basic.SuperConstant;
|
||||
import com.itheima.sfbx.insurance.pojo.Safeguard;
|
||||
import com.itheima.sfbx.insurance.mapper.SafeguardMapper;
|
||||
import com.itheima.sfbx.insurance.service.ISafeguardService;
|
||||
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
||||
import org.springframework.stereotype.Service;
|
||||
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
||||
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
||||
import org.springframework.transaction.annotation.Transactional;
|
||||
import com.itheima.sfbx.insurance.constant.SafeguardCacheConstant;
|
||||
import com.itheima.sfbx.insurance.dto.SafeguardVO;
|
||||
import com.itheima.sfbx.insurance.enums.SafeguardEnum;
|
||||
import com.itheima.sfbx.framework.commons.utils.BeanConv;
|
||||
import com.itheima.sfbx.framework.commons.utils.EmptyUtil;
|
||||
import com.itheima.sfbx.framework.commons.utils.ExceptionsUtil;
|
||||
import com.itheima.sfbx.framework.commons.exception.ProjectException;
|
||||
import com.google.common.collect.Lists;
|
||||
|
||||
import java.time.LocalDateTime;
|
||||
import java.util.ArrayList;
|
||||
import java.util.Arrays;
|
||||
import java.util.List;
|
||||
import java.util.Set;
|
||||
import java.util.stream.Collectors;
|
||||
import lombok.extern.slf4j.Slf4j;
|
||||
import org.springframework.beans.factory.annotation.Autowired;
|
||||
import org.springframework.cache.annotation.CacheEvict;
|
||||
import org.springframework.cache.annotation.CachePut;
|
||||
import org.springframework.cache.annotation.Cacheable;
|
||||
import org.springframework.cache.annotation.Caching;
|
||||
import lombok.extern.slf4j.Slf4j;
|
||||
/**
|
||||
* @Description：保障项服务实现类
|
||||
*/
|
||||
@Slf4j
|
||||
@Service
|
||||
public class SafeguardServiceImpl extends ServiceImpl<SafeguardMapper, Safeguard> implements ISafeguardService {
|
||||
|
||||
|
||||
/***
|
||||
* @description 保障项多条件组合
|
||||
* @param safeguardVO 保障项
|
||||
* @return QueryWrapper查询条件
|
||||
*/
|
||||
private QueryWrapper<Safeguard> queryWrapper(SafeguardVO safeguardVO){
|
||||
QueryWrapper<Safeguard> queryWrapper = new QueryWrapper<>();
|
||||
//条例键查询
|
||||
if (!EmptyUtil.isNullOrEmpty(safeguardVO.getSafeguardKey())) {
|
||||
queryWrapper.lambda().eq(Safeguard::getSafeguardKey,safeguardVO.getSafeguardKey());
|
||||
}
|
||||
//条例键名称查询
|
||||
if (!EmptyUtil.isNullOrEmpty(safeguardVO.getSafeguardKeyName())) {
|
||||
queryWrapper.lambda().eq(Safeguard::getSafeguardKeyName,safeguardVO.getSafeguardKeyName());
|
||||
}
|
||||
//条例值查询
|
||||
if (!EmptyUtil.isNullOrEmpty(safeguardVO.getSafeguardVal())) {
|
||||
queryWrapper.lambda().eq(Safeguard::getSafeguardVal,safeguardVO.getSafeguardVal());
|
||||
}
|
||||
//排序查询
|
||||
if (!EmptyUtil.isNullOrEmpty(safeguardVO.getSortNo())) {
|
||||
queryWrapper.lambda().eq(Safeguard::getSortNo,safeguardVO.getSortNo());
|
||||
}
|
||||
//备注查询
|
||||
if (!EmptyUtil.isNullOrEmpty(safeguardVO.getRemake())) {
|
||||
queryWrapper.lambda().eq(Safeguard::getRemake,safeguardVO.getRemake());
|
||||
}
|
||||
//状态查询
|
||||
if (!EmptyUtil.isNullOrEmpty(safeguardVO.getDataState())) {
|
||||
queryWrapper.lambda().eq(Safeguard::getDataState,safeguardVO.getDataState());
|
||||
}
|
||||
//按创建时间降序
|
||||
queryWrapper.lambda().orderByDesc(Safeguard::getCreateTime);
|
||||
return queryWrapper;
|
||||
}
|
||||
|
||||
@Override
|
||||
@Cacheable(value = SafeguardCacheConstant.PAGE,key ="#pageNum+'-'+#pageSize+'-'+#safeguardVO.hashCode()")
|
||||
public Page<SafeguardVO> findPage(SafeguardVO safeguardVO, int pageNum, int pageSize) {
|
||||
try {
|
||||
//构建分页对象
|
||||
Page<Safeguard> SafeguardPage = new Page<>(pageNum,pageSize);
|
||||
//构建查询条件
|
||||
QueryWrapper<Safeguard> queryWrapper = queryWrapper(safeguardVO);
|
||||
//执行分页查询
|
||||
Page<SafeguardVO> safeguardVOPage = BeanConv.toPage(
|
||||
page(SafeguardPage, queryWrapper), SafeguardVO.class);
|
||||
//返回结果
|
||||
return safeguardVOPage;
|
||||
}catch (Exception e){
|
||||
log.error("保障项分页查询异常：{}", ExceptionsUtil.getStackTraceAsString(e));
|
||||
throw new ProjectException(SafeguardEnum.PAGE_FAIL);
|
||||
}
|
||||
}
|
||||
|
||||
@Override
|
||||
@Cacheable(value = SafeguardCacheConstant.BASIC,key ="#safeguardId")
|
||||
public SafeguardVO findById(String safeguardId) {
|
||||
try {
|
||||
//执行查询
|
||||
return BeanConv.toBean(getById(safeguardId),SafeguardVO.class);
|
||||
}catch (Exception e){
|
||||
log.error("保障项单条查询异常：{}", ExceptionsUtil.getStackTraceAsString(e));
|
||||
throw new ProjectException(SafeguardEnum.FIND_ONE_FAIL);
|
||||
}
|
||||
}
|
||||
|
||||
@Override
|
||||
@Transactional
|
||||
@Caching(evict = {@CacheEvict(value = SafeguardCacheConstant.PAGE,allEntries = true),
|
||||
@CacheEvict(value = SafeguardCacheConstant.LIST,allEntries = true)},
|
||||
put={@CachePut(value =SafeguardCacheConstant.BASIC,key = "#result.id")})
|
||||
public SafeguardVO save(SafeguardVO safeguardVO) {
|
||||
try {
|
||||
//转换SafeguardVO为Safeguard
|
||||
Safeguard safeguard = BeanConv.toBean(safeguardVO, Safeguard.class);
|
||||
boolean flag = save(safeguard);
|
||||
if (!flag){
|
||||
throw new RuntimeException("保存保障项失败");
|
||||
}
|
||||
//转换返回对象SafeguardVO
|
||||
SafeguardVO safeguardVOHandler = BeanConv.toBean(safeguard, SafeguardVO.class);
|
||||
return safeguardVOHandler;
|
||||
}catch (Exception e){
|
||||
log.error("保存保障项异常：{}", ExceptionsUtil.getStackTraceAsString(e));
|
||||
throw new ProjectException(SafeguardEnum.SAVE_FAIL);
|
||||
}
|
||||
}
|
||||
|
||||
@Override
|
||||
@Transactional
|
||||
@Caching(evict = {@CacheEvict(value = SafeguardCacheConstant.PAGE,allEntries = true),
|
||||
@CacheEvict(value = SafeguardCacheConstant.LIST,allEntries = true),
|
||||
@CacheEvict(value = SafeguardCacheConstant.BASIC,key = "#safeguardVO.id")})
|
||||
public Boolean update(SafeguardVO safeguardVO) {
|
||||
try {
|
||||
//转换SafeguardVO为Safeguard
|
||||
Safeguard safeguard = BeanConv.toBean(safeguardVO, Safeguard.class);
|
||||
boolean flag = updateById(safeguard);
|
||||
if (!flag){
|
||||
throw new RuntimeException("修改保障项失败");
|
||||
}
|
||||
return flag;
|
||||
}catch (Exception e){
|
||||
log.error("修改保障项异常：{}", ExceptionsUtil.getStackTraceAsString(e));
|
||||
throw new ProjectException(SafeguardEnum.UPDATE_FAIL);
|
||||
}
|
||||
}
|
||||
|
||||
@Override
|
||||
@Transactional
|
||||
@Caching(evict = {@CacheEvict(value = SafeguardCacheConstant.PAGE,allEntries = true),
|
||||
@CacheEvict(value = SafeguardCacheConstant.LIST,allEntries = true),
|
||||
@CacheEvict(value = SafeguardCacheConstant.BASIC,allEntries = true)})
|
||||
public Boolean delete(String[] checkedIds) {
|
||||
try {
|
||||
List<Long> idsLong = Arrays.asList(checkedIds)
|
||||
.stream().map(Long::new).collect(Collectors.toList());
|
||||
boolean flag = removeByIds(idsLong);
|
||||
if (!flag){
|
||||
throw new RuntimeException("删除保障项失败");
|
||||
}
|
||||
return flag;
|
||||
}catch (Exception e){
|
||||
log.error("删除保障项异常：{}", ExceptionsUtil.getStackTraceAsString(e));
|
||||
throw new ProjectException(SafeguardEnum.DEL_FAIL);
|
||||
}
|
||||
}
|
||||
|
||||
@Override
|
||||
@Cacheable(value = SafeguardCacheConstant.LIST,key ="#safeguardVO.hashCode()")
|
||||
public List<SafeguardVO> findList(SafeguardVO safeguardVO) {
|
||||
try {
|
||||
//构建查询条件
|
||||
QueryWrapper<Safeguard> queryWrapper = queryWrapper(safeguardVO);
|
||||
//执行列表查询
|
||||
List<SafeguardVO> safeguardVOs = BeanConv.toBeanList(list(queryWrapper),SafeguardVO.class);
|
||||
return safeguardVOs;
|
||||
}catch (Exception e){
|
||||
log.error("保障项列表查询异常：{}", ExceptionsUtil.getStackTraceAsString(e));
|
||||
throw new ProjectException(SafeguardEnum.LIST_FAIL);
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
@Override
|
||||
@Cacheable(value = SafeguardCacheConstant.LIST,key ="#safeguardKeyList.hashCode()")
|
||||
public List<SafeguardVO> findShowPageItemByKey(List<String> safeguardKeyList) {
|
||||
try {
|
||||
//构建查询条件
|
||||
LambdaQueryWrapper<Safeguard> queryWrapper = new LambdaQueryWrapper<>();
|
||||
queryWrapper.in(Safeguard::getSafeguardKey,safeguardKeyList);
|
||||
queryWrapper.eq(Safeguard::getDataState, SuperConstant.DATA_STATE_0);
|
||||
//执行列表查询
|
||||
List<SafeguardVO> safeguardVOs = BeanConv.toBeanList(list(queryWrapper),SafeguardVO.class);
|
||||
return safeguardVOs;
|
||||
}catch (Exception e){
|
||||
log.error("保障项列表查询异常：{}", ExceptionsUtil.getStackTraceAsString(e));
|
||||
throw new ProjectException(SafeguardEnum.LIST_FAIL);
|
||||
}
|
||||
}
|
||||
|
||||
@Override
|
||||
@Cacheable(value = SafeguardCacheConstant.BASIC,key ="#safeguardKey")
|
||||
public SafeguardVO findBySafeguardKey(String safeguardKey) {
|
||||
try {
|
||||
//构建查询条件
|
||||
LambdaQueryWrapper<Safeguard> queryWrapper = new LambdaQueryWrapper<>();
|
||||
queryWrapper.eq(Safeguard::getSafeguardKey,safeguardKey);
|
||||
queryWrapper.eq(Safeguard::getDataState, SuperConstant.DATA_STATE_0);
|
||||
//执行列表查询
|
||||
return BeanConv.toBean(getOne(queryWrapper),SafeguardVO.class);
|
||||
}catch (Exception e){
|
||||
log.error("保障项列表查询异常：{}", ExceptionsUtil.getStackTraceAsString(e));
|
||||
throw new ProjectException(SafeguardEnum.FIND_ONE_FAIL);
|
||||
}
|
||||
}
|
||||
public class SafeguardServiceImpl {
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user