package com.gkhy.hazmat.system.service.impl;
|
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
import com.gkhy.hazmat.common.api.CommonPage;
|
import com.gkhy.hazmat.common.constant.Constant;
|
import com.gkhy.hazmat.common.domain.entity.SysUser;
|
import com.gkhy.hazmat.common.enums.UserTypeEnum;
|
import com.gkhy.hazmat.common.exception.ApiException;
|
import com.gkhy.hazmat.common.service.RedisService;
|
import com.gkhy.hazmat.common.utils.PageUtils;
|
import com.gkhy.hazmat.common.utils.SecurityUtils;
|
import com.gkhy.hazmat.system.domain.HzProduct;
|
import com.gkhy.hazmat.system.domain.SysConfig;
|
import com.gkhy.hazmat.system.domain.TaBooComparison;
|
import com.gkhy.hazmat.system.mapper.TaBooComparisonMapper;
|
import com.gkhy.hazmat.system.service.TaBooComparisonService;
|
import org.springframework.stereotype.Service;
|
|
import javax.annotation.PostConstruct;
|
import javax.annotation.Resource;
|
import java.util.List;
|
import java.util.Map;
|
import java.util.Objects;
|
import java.util.stream.Collectors;
|
|
/**
|
* <p>
|
* 系统配置表 服务实现类
|
* </p>
|
*
|
* @author kzy
|
* @since 2023-11-13 08:39:55
|
*/
|
@Service
|
public class TaBooComparisonServiceImpl extends ServiceImpl<TaBooComparisonMapper, TaBooComparison> implements TaBooComparisonService {
|
|
@Resource
|
private RedisService redisService;
|
|
@PostConstruct
|
public void init(){
|
loadingTaBooCache();
|
}
|
|
|
@Override
|
public CommonPage selectTaBooComparisonList(TaBooComparison taBooComparison) {
|
PageUtils.startPage();
|
List<TaBooComparison> taBooComparisonList=baseMapper.selectTaBooComparisonList(taBooComparison);
|
return CommonPage.restPage(taBooComparisonList);
|
}
|
|
@Override
|
public int insertTaBooComparison(TaBooComparison taBooComparison) {
|
checkUserAllowed();
|
checkData(taBooComparison);
|
taBooComparison.setCreateBy(SecurityUtils.getUsername());
|
taBooComparison.setUniqueCode(taBooComparison.getLeftCode()+"_"+taBooComparison.getTopCode());
|
int row=baseMapper.insert(taBooComparison);
|
if(row<1){
|
throw new ApiException("新增失败");
|
}
|
// 更新缓存
|
loadingTaBooCache();
|
return row;
|
}
|
|
@Override
|
public int updateTaBooComparison(TaBooComparison taBooComparison) {
|
checkUserAllowed();
|
checkData(taBooComparison);
|
taBooComparison.setUpdateBy(SecurityUtils.getUsername());
|
taBooComparison.setUniqueCode(taBooComparison.getLeftCode()+"_"+taBooComparison.getTopCode());
|
int row=baseMapper.updateById(taBooComparison);
|
if(row<1){
|
throw new ApiException("更新失败");
|
}
|
// 更新缓存
|
loadingTaBooCache();
|
return row;
|
}
|
|
public void checkUserAllowed() {
|
if (SecurityUtils.isAdmin(SecurityUtils.getUserId())) {
|
throw new ApiException("管理员不能操作");
|
}
|
}
|
@Override
|
public void loadingTaBooCache(){
|
List<TaBooComparison> taBooComparisons=baseMapper.selectTaBooComparison();
|
Map<String, Long> collect = taBooComparisons.stream()
|
.collect(Collectors.toMap(
|
TaBooComparison::getUniqueCode,
|
TaBooComparison::getWarningType
|
));
|
redisService.set(Constant.TABOO_UNIQUE_KEY,collect);
|
// DictUtils.setTabooCache("TABOO_UNIQUE_KEY",collect);
|
}
|
|
@Override
|
public void deleteTaBooComparisonById(Long taBooComparisonId) {
|
checkUserAllowed();
|
baseMapper.deleteById(taBooComparisonId);
|
// 更新缓存
|
loadingTaBooCache();
|
}
|
|
private void checkData(TaBooComparison taBooComparison){
|
LambdaQueryWrapper<TaBooComparison> lambdaQueryWrapper = Wrappers.<TaBooComparison>lambdaQuery()
|
.and(wrapper -> wrapper.eq(TaBooComparison::getLeftCode, taBooComparison.getLeftCode())
|
.or()
|
.eq(TaBooComparison::getLeftCode, taBooComparison.getTopCode()))
|
.and(wrapper -> wrapper.eq(TaBooComparison::getTopCode, taBooComparison.getLeftCode())
|
.or()
|
.eq(TaBooComparison::getTopCode, taBooComparison.getTopCode()));
|
if (taBooComparison.getId() != null){
|
lambdaQueryWrapper.ne(TaBooComparison::getId, taBooComparison.getId());
|
}
|
Long l = baseMapper.selectCount(lambdaQueryWrapper);
|
if (l > 0){
|
throw new ApiException("该数据已存在");
|
}
|
|
|
|
}
|
|
}
|
