package com.finance.system.service.impl;
|
|
import com.alibaba.fastjson2.JSON;
|
import com.alibaba.fastjson2.JSONArray;
|
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
import com.finance.common.basic.PageDTO;
|
import com.finance.common.enums.CalculateTypeEnum;
|
import com.finance.common.enums.ShowStatusEnum;
|
import com.finance.common.enums.ValueTypeEnum;
|
import com.finance.common.exception.ServiceException;
|
import com.finance.common.utils.BeanUtils;
|
import com.finance.common.utils.CalculateUtil;
|
import com.finance.common.utils.Checker;
|
import com.finance.common.utils.CollUtils;
|
import com.finance.common.utils.StringUtils;
|
import com.finance.system.domain.TbBasicDataCategory;
|
import com.finance.system.domain.TbBasicDataConfig;
|
import com.finance.system.domain.TbBasicDataConfigDetail;
|
import com.finance.system.domain.TbField;
|
import com.finance.system.dto.BasicDataConfigDTO;
|
import com.finance.system.dto.CalculateDTO;
|
import com.finance.system.dto.CalculateItemDTO;
|
import com.finance.system.dto.ShowHideDTO;
|
import com.finance.system.dto.update.BasicDataConfigUpdateDTO;
|
import com.finance.system.mapper.TbBasicDataConfigMapper;
|
import com.finance.system.mapper.TbFieldMapper;
|
import com.finance.system.query.BasicDataConfigQuery;
|
import com.finance.system.query.ScoreCalculateQuery;
|
import com.finance.system.service.TbBasicDataCategoryService;
|
import com.finance.system.service.TbBasicDataConfigDetailService;
|
import com.finance.system.service.TbBasicDataConfigService;
|
import com.finance.system.vo.BasicDataConfigDetailVO;
|
import com.finance.system.vo.BasicDataConfigVO;
|
import com.finance.system.vo.CalculateVO;
|
import com.finance.system.vo.ScoreCalculateVO;
|
import java.util.Arrays;
|
import java.util.List;
|
import java.util.Map;
|
import java.util.Objects;
|
import java.util.function.Function;
|
import java.util.stream.Collectors;
|
import lombok.RequiredArgsConstructor;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
|
/**
|
* <p>
|
* 基础数据配置表 服务实现类
|
* </p>
|
*
|
* @author mitao
|
* @since 2024-03-18
|
*/
|
@Service
|
@RequiredArgsConstructor
|
public class TbBasicDataConfigServiceImpl extends
|
ServiceImpl<TbBasicDataConfigMapper, TbBasicDataConfig> implements
|
TbBasicDataConfigService {
|
|
private final TbBasicDataConfigDetailService tbBasicDataConfigDetailService;
|
private final TbFieldMapper fieldMapper;
|
private final TbBasicDataCategoryService tbBasicDataCategoryService;
|
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public void add(BasicDataConfigDTO dto) {
|
TbBasicDataConfig tbBasicDataConfig = BeanUtils.copyBean(dto, TbBasicDataConfig.class);
|
List<CalculateItemDTO> calculateItemList = dto.getCalculateItemList();
|
CalculateTypeEnum calculateType = tbBasicDataConfig.getCalculateType();
|
List<CalculateDTO> dtoList = dto.getDtoList();
|
this.save(tbBasicDataConfig);
|
if (CalculateTypeEnum.NUMBER.equals(calculateType)) {
|
String fieldIdStr = getFieldIdStr(calculateItemList, tbBasicDataConfig);
|
tbBasicDataConfig.setFieldIdStr(fieldIdStr);
|
this.updateById(tbBasicDataConfig);
|
} else {
|
if (CollUtils.isEmpty(dtoList)) {
|
throw new ServiceException("基础数据配置不能为空");
|
} else {
|
CollUtils.check(dto.getDtoList(), new Checker<CalculateDTO>() {
|
@Override
|
public void check(CalculateDTO data) {
|
if (StringUtils.isBlank(data.getKey())) {
|
throw new ServiceException("基础数据配置key不能为空");
|
}
|
if (StringUtils.isBlank(data.getValue())) {
|
throw new ServiceException("基础数据配置value不能为空");
|
}
|
}
|
});
|
if (StringUtils.isBlank(dto.getFieldIdStr())) {
|
throw new ServiceException("字段id不能为空");
|
}
|
List<TbBasicDataConfigDetail> details = BeanUtils.copyList(dtoList,
|
TbBasicDataConfigDetail.class);
|
List<TbBasicDataConfigDetail> collect = details.stream()
|
.peek(item -> item.setBasicDataConfigId(tbBasicDataConfig.getId()))
|
.collect(Collectors.toList());
|
tbBasicDataConfigDetailService.saveBatch(collect);
|
}
|
}
|
}
|
|
public static boolean hasConsecutiveDuplicates(List<CalculateItemDTO> calculateItemList) {
|
for (int i = 0; i < calculateItemList.size() - 1; i++) {
|
if (calculateItemList.get(i).getValueType()
|
.equals(calculateItemList.get(i + 1).getValueType()) && !calculateItemList.get(
|
i + 1)
|
.getContent().equals("(")) {
|
return true;
|
}
|
}
|
return false;
|
}
|
|
|
private String getFieldIdStr(List<CalculateItemDTO> calculateItemList,
|
TbBasicDataConfig tbBasicDataConfig) {
|
if (CollUtils.isEmpty(calculateItemList)) {
|
throw new ServiceException("计算公式不能为空");
|
}
|
CollUtils.check(calculateItemList, new Checker<CalculateItemDTO>() {
|
@Override
|
public void check(CalculateItemDTO data) {
|
if (Objects.isNull(data.getValueType())) {
|
throw new ServiceException("基础数据配置计算规则值类型不能为空");
|
}
|
if (StringUtils.isBlank(data.getContent())) {
|
throw new ServiceException("基础数据配置计算规则值内容不能为空");
|
}
|
}
|
});
|
boolean result = hasConsecutiveDuplicates(calculateItemList);
|
if (result) {
|
throw new ServiceException("计算表达式有误，请修改");
|
}
|
// 参数校验
|
String numberCalculateFormulaStr = calculateItemList.stream()
|
.map(CalculateItemDTO::getContent)
|
.collect(Collectors.joining());
|
// 校验表达式是否正确
|
try {
|
CalculateUtil.calculate(numberCalculateFormulaStr);
|
} catch (Exception e) {
|
throw new ServiceException("计算表达式有误，请修改");
|
}
|
String numberCalculateFormulaJsonStr = JSON.toJSONString(calculateItemList);
|
tbBasicDataConfig.setNumberCalculateFormula(numberCalculateFormulaJsonStr);
|
String fieldIdStr = calculateItemList.stream()
|
.filter(item -> ValueTypeEnum.FIELD.equals(item.getValueType()))
|
.map(CalculateItemDTO::getContent).collect(
|
Collectors.joining(","));
|
return fieldIdStr;
|
}
|
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public void edit(BasicDataConfigUpdateDTO dto) {
|
TbBasicDataConfig tbBasicDataConfig = BeanUtils.copyBean(dto, TbBasicDataConfig.class);
|
// 参数校验
|
CalculateTypeEnum calculateType = tbBasicDataConfig.getCalculateType();
|
List<CalculateDTO> dtoList = dto.getDtoList();
|
if (CalculateTypeEnum.NUMBER.equals(calculateType)) {
|
tbBasicDataConfig.setFieldIdStr(
|
getFieldIdStr(dto.getCalculateItemList(), tbBasicDataConfig));
|
} else {
|
if (StringUtils.isEmpty(dto.getFieldIdStr())) {
|
throw new ServiceException("字段id不能为空");
|
}
|
if (CollUtils.isEmpty(dtoList)) {
|
throw new ServiceException("计算公式不能为空");
|
}
|
// 删除原来的配置信息，重新添加新的
|
tbBasicDataConfigDetailService.lambdaUpdate()
|
.eq(TbBasicDataConfigDetail::getBasicDataConfigId, tbBasicDataConfig.getId())
|
.remove();
|
List<TbBasicDataConfigDetail> details = BeanUtils.copyList(dtoList,
|
TbBasicDataConfigDetail.class);
|
List<TbBasicDataConfigDetail> collect = details.stream()
|
.peek(item -> item.setBasicDataConfigId(tbBasicDataConfig.getId()))
|
.collect(Collectors.toList());
|
tbBasicDataConfigDetailService.saveBatch(collect);
|
}
|
this.updateById(tbBasicDataConfig);
|
}
|
|
@Override
|
public BasicDataConfigDetailVO getDetails(Long id) {
|
TbBasicDataConfig config = this.getById(id);
|
if (Objects.isNull(config)) {
|
throw new ServiceException("非法参数");
|
}
|
BasicDataConfigDetailVO vo = BeanUtils.copyBean(config, BasicDataConfigDetailVO.class);
|
|
CalculateTypeEnum type = vo.getCalculateType();
|
if (CalculateTypeEnum.NUMBER.equals(type)) {
|
List<CalculateItemDTO> calculateItemDTOS = JSONArray.parseArray(
|
config.getNumberCalculateFormula(),
|
CalculateItemDTO.class);
|
vo.setCalculateItemList(calculateItemDTOS);
|
}
|
if ((CalculateTypeEnum.TEXT.equals(type) || CalculateTypeEnum.PERCENTAGE.equals(type))) {
|
List<TbBasicDataConfigDetail> list = tbBasicDataConfigDetailService.lambdaQuery()
|
.eq(TbBasicDataConfigDetail::getBasicDataConfigId, config.getId()).list();
|
List<CalculateVO> calculateVOS = BeanUtils.copyList(list, CalculateVO.class);
|
vo.setDtoList(calculateVOS);
|
}
|
return vo;
|
}
|
|
@Override
|
public void delete(Long id) {
|
TbBasicDataConfig config = this.getById(id);
|
if (Objects.isNull(config)) {
|
throw new ServiceException("非法参数");
|
}
|
this.removeById(id);
|
}
|
|
@Override
|
public PageDTO<BasicDataConfigVO> queryPage(BasicDataConfigQuery query) {
|
Page<Object> page = new Page<>(query.getPageNum(), query.getPageSize());
|
Page<BasicDataConfigVO> pageVO = this.queryPage(
|
new Page<>(query.getPageNum(), query.getPageSize()), query);
|
return PageDTO.of(pageVO);
|
}
|
|
@Override
|
public void showHide(ShowHideDTO dto) {
|
TbBasicDataConfig config = this.getById(dto.getId());
|
if (Objects.isNull(config)) {
|
throw new ServiceException("非法参数");
|
}
|
if (ShowStatusEnum.SHOW.equals(dto.getStatus())) {
|
// 查询改配置所使用字段状态
|
String fieldIdStr = config.getFieldIdStr();
|
String[] split = fieldIdStr.split(",");
|
List<TbField> list = fieldMapper.selectList(
|
Wrappers.<TbField>lambdaQuery().in(TbField::getId, Arrays.asList(split))
|
.eq(TbField::getStatus, ShowStatusEnum.HIDE));
|
if (CollUtils.isNotEmpty(list)) {
|
String fieldNames = list.stream().map(TbField::getFieldName)
|
.collect(Collectors.joining(","));
|
throw new ServiceException(
|
String.format("字段“%s”已被隐藏，请重新配置后再次操作！", fieldNames));
|
}
|
}
|
this.lambdaUpdate().set(TbBasicDataConfig::getStatus, dto.getStatus())
|
.eq(TbBasicDataConfig::getId, dto.getId()).update();
|
}
|
|
@Override
|
public Page<ScoreCalculateVO> scoreCalculatePage(ScoreCalculateQuery query,
|
Page<ScoreCalculateVO> page) {
|
return baseMapper.scoreCalculatePage(query, page);
|
}
|
|
@Override
|
public Page<BasicDataConfigVO> queryPage(Page<BasicDataConfigVO> page,
|
BasicDataConfigQuery query) {
|
return baseMapper.queryPage(page, query);
|
}
|
|
@Override
|
public List<BasicDataConfigVO> getFixedRulesConfigList() {
|
List<TbBasicDataConfig> configList = this.lambdaQuery()
|
.le(TbBasicDataConfig::getId, 24).list();
|
Map<Long, TbBasicDataCategory> configCategoryMap = tbBasicDataCategoryService.list()
|
.stream()
|
.collect(Collectors.toMap(TbBasicDataCategory::getId,
|
Function.identity()));
|
List<BasicDataConfigVO> configVOList = BeanUtils.copyList(configList,
|
BasicDataConfigVO.class);
|
configVOList = configVOList.stream().map(c -> {
|
TbBasicDataCategory tbBasicDataCategory2 = configCategoryMap.get(
|
c.getBasicDataCategoryId());
|
if (Objects.nonNull(tbBasicDataCategory2)) {
|
c.setBasicDataCategory(tbBasicDataCategory2.getBasicDataCategoryName());
|
TbBasicDataCategory tbBasicDataCategory1 = configCategoryMap.get(
|
tbBasicDataCategory2.getParentId());
|
if (Objects.nonNull(tbBasicDataCategory1)) {
|
c.setBasicDataCategoryOne(tbBasicDataCategory1.getBasicDataCategoryName());
|
}
|
}
|
return c;
|
}).collect(Collectors.toList());
|
return configVOList;
|
}
|
}
|
