package com.mzl.flower.service.impl;
|
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
import com.mzl.flower.config.exception.ValidationException;
|
import com.mzl.flower.config.security.SecurityUtils;
|
import com.mzl.flower.dto.request.configParam.ConfigParamDTO;
|
import com.mzl.flower.dto.request.configParam.QueryConfigParamDTO;
|
import com.mzl.flower.dto.request.configParam.UpdateConfigParamDTO;
|
import com.mzl.flower.dto.response.configParam.ConfigCustomerServiceVO;
|
import com.mzl.flower.dto.response.configParam.ConfigParamVO;
|
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 lombok.RequiredArgsConstructor;
|
import org.apache.commons.collections4.CollectionUtils;
|
import org.apache.commons.lang3.StringUtils;
|
import org.redisson.api.RBucket;
|
import org.redisson.api.RedissonClient;
|
import org.springframework.beans.BeanUtils;
|
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
|
@RequiredArgsConstructor
|
public class ConfigParamServiceImpl extends ServiceImpl<ConfigParamMapper, ConfigParamDO> implements ConfigParamService {
|
|
private final ConfigParamMapperCustom configParamMapperCustom;
|
|
private final ConfigParamMapper configParamMapper;
|
private final RedissonClient redissonClient;
|
private static final String CONFIG_PARAM= "com.mzl.flower.service.impl:config_param:%s";
|
|
@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());
|
|
//更新订单自动取消（分钟）; 订单自动收货（天）
|
if ("order".equals(configParamForUpdate.getParamGroup())) {
|
// 设置值到 Redis
|
RBucket<String> bucket = redissonClient.getBucket(CONFIG_PARAM + configParamForUpdate.getParamGroup() + configParamForUpdate.getParamKey());
|
bucket.set(configParamForUpdate.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;
|
}
|
|
@Override
|
public String getBaseString(String paramGroup, String paramKey) {
|
|
String bucketName = CONFIG_PARAM + paramGroup + paramKey;
|
RBucket<String> bucket = redissonClient.getBucket(bucketName);
|
String value = bucket.get();
|
|
if (StringUtils.isNotBlank(value)) {
|
return value;
|
} else {
|
String baseString = configParamMapper.getBaseString(paramGroup, paramKey);
|
if (StringUtils.isNotBlank(baseString)) {
|
return baseString;
|
} else {
|
if ("order_cancel_time".equals(paramKey) && "order".equals(paramGroup)) {
|
// 默认15分钟
|
return "15";
|
}
|
if ("order_auto_receive".equals(paramKey) && "order".equals(paramGroup)) {
|
// 默认5前的订单自动收货
|
return "5";
|
}
|
}
|
}
|
return null;
|
}
|
|
@Override
|
public void saveConfigParam(ConfigParamDTO dto) {
|
ConfigParamDO configParamDO = new ConfigParamDO();
|
BeanUtils.copyProperties(dto, configParamDO);
|
configParamDO.create(SecurityUtils.getUserId());
|
configParamMapper.insert(configParamDO);
|
}
|
|
@Override
|
public void updateConfigParam(ConfigParamDTO dto) {
|
ConfigParamDO configParamDO = configParamMapper.selectById(dto.getId());
|
BeanUtils.copyProperties(dto, configParamDO);
|
configParamDO.update(SecurityUtils.getUserId());
|
configParamMapper.updateById(configParamDO);
|
}
|
|
@Override
|
public void deleteConfigParam(Long id) {
|
configParamMapper.deleteById(id);
|
}
|
|
@Override
|
public Page<ConfigParamVO> queryPage(QueryConfigParamDTO dto, Page page) {
|
List<ConfigParamVO> list = configParamMapper.queryPage(dto, page);
|
page.setRecords(list);
|
return page;
|
}
|
|
}
|
