package com.mzl.flower.service.impl;
|
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import com.mzl.flower.config.exception.ValidationException;
|
import com.mzl.flower.dto.request.configParam.QueryConfigParamDTO;
|
import com.mzl.flower.dto.request.configParam.UpdateConfigParamDTO;
|
import com.mzl.flower.entity.configParam.ConfigParamDO;
|
import com.mzl.flower.enums.ConfigParamEnum;
|
import com.mzl.flower.mapper.configParam.ConfigParamMapper;
|
import com.mzl.flower.mapper.configParam.ConfigParamMapperCustom;
|
import com.mzl.flower.service.ConfigParamService;
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
import org.apache.commons.collections4.CollectionUtils;
|
import org.apache.commons.lang3.StringUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import java.util.*;
|
import java.util.stream.Collectors;
|
|
/**
|
* <p>
|
* 服务实现类
|
* </p>
|
*
|
* @author @TaoJie
|
* @since 2024-12-02
|
*/
|
@Service
|
public class ConfigParamServiceImpl extends ServiceImpl<ConfigParamMapper, ConfigParamDO> implements ConfigParamService {
|
|
@Autowired
|
private ConfigParamMapperCustom configParamMapperCustom;
|
|
@Override
|
public List<ConfigParamDO> getList(QueryConfigParamDTO dto) {
|
QueryWrapper<ConfigParamDO> queryWrapper = new QueryWrapper<>();
|
queryWrapper.lambda().eq(ConfigParamDO::getDeleted,false)
|
.eq(Objects.nonNull(dto.getParamGroupId()),ConfigParamDO::getParamGroupId,dto.getParamGroupId())
|
.eq(StringUtils.isNotBlank(dto.getParamKey()),ConfigParamDO::getParamKey,dto.getParamKey())
|
.eq(StringUtils.isNotBlank(dto.getParamGroup()),ConfigParamDO::getParamGroup,dto.getParamGroup())
|
.eq(StringUtils.isNotBlank(dto.getParamGroupName()),ConfigParamDO::getParamGroupName,dto.getParamGroupName())
|
.eq(StringUtils.isNotBlank(dto.getParamName()),ConfigParamDO::getParamName,dto.getParamName())
|
;
|
return list(queryWrapper);
|
}
|
|
@Transactional
|
@Override
|
public boolean updateConfigParamBatch(UpdateConfigParamDTO dto) {
|
|
if(CollectionUtils.isNotEmpty(dto.getParamList())){
|
// 遍历循环查找是否存在
|
List<ConfigParamDO> configParamUpdateList = dto.getParamList().stream().map(configParamDO -> {
|
final ConfigParamDO configParamForUpdate = configParamMapperCustom.selectById(configParamDO.getId());
|
if (null == configParamForUpdate) {
|
throw new ValidationException(String.format("ID:{}不存在！", configParamDO.getId()));
|
}
|
configParamForUpdate.setParamValue(configParamDO.getParamValue());
|
return configParamForUpdate;
|
}).collect(Collectors.toList());
|
|
if(CollectionUtils.isNotEmpty(configParamUpdateList)){
|
return saveOrUpdateBatch(configParamUpdateList);
|
}
|
|
}
|
return false;
|
}
|
|
@Override
|
public Map<String,Object> getBaseInfo() {
|
QueryConfigParamDTO dto=new QueryConfigParamDTO();
|
dto.setParamGroup(ConfigParamEnum.BASE.getName());
|
final List<ConfigParamDO> list = getList(dto);
|
// 把数据转换成map ,只需要获取list中单个item的paramKey ，paramValue
|
Map<String, Object> resultMap=new HashMap<>();
|
list.stream().forEach(item -> {
|
resultMap.put(item.getParamKey(),item.getParamValue());
|
});
|
|
return resultMap;
|
}
|
}
|
