package com.ruoyi.system.service.impl; 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.ruoyi.common.basic.PageDTO; import com.ruoyi.common.enums.CalculateTypeEnum; import com.ruoyi.common.enums.ShowStatusEnum; import com.ruoyi.common.exception.ServiceException; import com.ruoyi.common.utils.BeanUtils; import com.ruoyi.common.utils.Checker; import com.ruoyi.common.utils.CollUtils; import com.ruoyi.common.utils.StringUtils; import com.ruoyi.system.domain.TbBasicDataConfig; import com.ruoyi.system.domain.TbBasicDataConfigDetail; import com.ruoyi.system.domain.TbField; import com.ruoyi.system.dto.BasicDataConfigDTO; import com.ruoyi.system.dto.CalculateDTO; import com.ruoyi.system.dto.ShowHideDTO; import com.ruoyi.system.dto.update.BasicDataConfigUpdateDTO; import com.ruoyi.system.mapper.TbBasicDataConfigMapper; import com.ruoyi.system.mapper.TbFieldMapper; import com.ruoyi.system.query.BasicDataConfigQuery; import com.ruoyi.system.query.ScoreCalculateQuery; import com.ruoyi.system.service.TbBasicDataConfigDetailService; import com.ruoyi.system.service.TbBasicDataConfigService; import com.ruoyi.system.vo.BasicDataConfigDetailVO; import com.ruoyi.system.vo.BasicDataConfigVO; import com.ruoyi.system.vo.CalculateVO; import com.ruoyi.system.vo.ScoreCalculateVO; import lombok.RequiredArgsConstructor; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import java.util.Arrays; import java.util.List; import java.util.Objects; import java.util.stream.Collectors; /** *

* 基础数据配置表 服务实现类 *

* * @author mitao * @since 2024-03-18 */ @Service @RequiredArgsConstructor public class TbBasicDataConfigServiceImpl extends ServiceImpl implements TbBasicDataConfigService { private final TbBasicDataConfigDetailService tbBasicDataConfigDetailService; private final TbFieldMapper fieldMapper; @Override @Transactional(rollbackFor = Exception.class) public void add(BasicDataConfigDTO dto) { TbBasicDataConfig tbBasicDataConfig = BeanUtils.copyBean(dto, TbBasicDataConfig.class); //参数校验 CalculateTypeEnum calculateType = tbBasicDataConfig.getCalculateType(); List dtoList = dto.getDtoList(); if (CalculateTypeEnum.NUMBER.equals(calculateType) && StringUtils.isBlank(dto.getNumberCalculateFormula())) { throw new ServiceException("计算公式不能为空"); } boolean verify = (CalculateTypeEnum.TEXT.equals(calculateType) || CalculateTypeEnum.PERCENTAGE.equals(calculateType)) && CollUtils.isNotEmpty(dtoList); if (verify) { CollUtils.check(dto.getDtoList(), new Checker() { @Override public void check(CalculateDTO data) { if (StringUtils.isBlank(data.getKey())) { throw new ServiceException("基础数据配置key不能为空"); } if (StringUtils.isBlank(data.getValue())) { throw new ServiceException("基础数据配置value不能为空"); } } }); } else { throw new ServiceException("计算公式不能为空"); } this.save(tbBasicDataConfig); if (verify) { List details = BeanUtils.copyList(dtoList, TbBasicDataConfigDetail.class); List collect = details.stream().peek(item -> item.setBasicDataConfigId(tbBasicDataConfig.getId())).collect(Collectors.toList()); tbBasicDataConfigDetailService.saveBatch(collect); } } @Override @Transactional(rollbackFor = Exception.class) public void edit(BasicDataConfigUpdateDTO dto) { TbBasicDataConfig tbBasicDataConfig = BeanUtils.copyBean(dto, TbBasicDataConfig.class); //参数校验 CalculateTypeEnum calculateType = tbBasicDataConfig.getCalculateType(); List dtoList = dto.getDtoList(); if (CalculateTypeEnum.NUMBER.equals(calculateType) && StringUtils.isBlank(dto.getNumberCalculateFormula())) { throw new ServiceException("计算公式不能为空"); } boolean verify = CalculateTypeEnum.TEXT.equals(calculateType) || CalculateTypeEnum.PERCENTAGE.equals(calculateType); if (verify && CollUtils.isEmpty(dtoList)) { throw new ServiceException("计算公式不能为空"); } this.updateById(tbBasicDataConfig); if (verify) { //删除原来的配置信息,重新添加新的 tbBasicDataConfigDetailService.lambdaUpdate().eq(TbBasicDataConfigDetail::getBasicDataConfigId, tbBasicDataConfig.getId()).remove(); List details = BeanUtils.copyList(dtoList, TbBasicDataConfigDetail.class); List collect = details.stream().peek(item -> item.setBasicDataConfigId(tbBasicDataConfig.getId())).collect(Collectors.toList()); tbBasicDataConfigDetailService.saveBatch(collect); } } @Override public BasicDataConfigDetailVO getDetails(Integer id) { TbBasicDataConfig config = this.getById(id); if (Objects.isNull(config)) { throw new ServiceException("非法参数"); } BasicDataConfigDetailVO vo = BeanUtils.copyBean(config, BasicDataConfigDetailVO.class); Integer code = vo.getCalculateType().getCode(); if ((CalculateTypeEnum.TEXT.getCode().equals(code) || CalculateTypeEnum.PERCENTAGE.getCode().equals(code))) { List list = tbBasicDataConfigDetailService.lambdaQuery().eq(TbBasicDataConfigDetail::getBasicDataConfigId, config.getId()).list(); List calculateVOS = BeanUtils.copyList(list, CalculateVO.class); vo.setDtoList(calculateVOS); } return vo; } @Override public void delete(Integer id) { TbBasicDataConfig config = this.getById(id); if (Objects.isNull(config)) { throw new ServiceException("非法参数"); } this.removeById(id); } @Override public PageDTO queryPage(BasicDataConfigQuery query) { Page page = this.lambdaQuery() .like(StringUtils.isNotBlank(query.getBasicDataConfigName()), TbBasicDataConfig::getTypeName, query.getBasicDataConfigName()) .eq(Objects.nonNull(query.getCalculateType()), TbBasicDataConfig::getCalculateType, query.getCalculateType()) .eq(Objects.nonNull(query.getStatus()), TbBasicDataConfig::getStatus, query.getStatus()).page(new Page<>(query.getPageNum(), query.getPageSize())); return PageDTO.of(page, BasicDataConfigVO.class); } @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 list = fieldMapper.selectList(Wrappers.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 scoreCalculatePage(ScoreCalculateQuery query, Page page) { return baseMapper.scoreCalculatePage(query, page); } }