package com.ruoyi.system.service.impl.config;
|
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
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.core.exception.ServiceException;
|
import com.ruoyi.common.core.utils.StringUtils;
|
import com.ruoyi.system.api.constant.AppErrorConstant;
|
import com.ruoyi.system.api.domain.poji.config.SysTag;
|
import com.ruoyi.system.api.service.RemoteGoodsService;
|
import com.ruoyi.system.api.service.RemoteMemberService;
|
import com.ruoyi.system.api.service.RemoteShopService;
|
import com.ruoyi.system.domain.dto.MgtTagEditDto;
|
import com.ruoyi.system.domain.dto.MgtTagImportDto;
|
import com.ruoyi.system.domain.dto.MgtTagPageDto;
|
import com.ruoyi.system.domain.vo.MgtTagPageVo;
|
import com.ruoyi.system.mapper.config.SysTagMapper;
|
import com.ruoyi.system.service.config.SysTagService;
|
import org.springframework.scheduling.annotation.Async;
|
import org.springframework.stereotype.Service;
|
|
import javax.annotation.Resource;
|
import java.util.Date;
|
import java.util.List;
|
import java.util.Objects;
|
|
/**
|
* <p>
|
* 系统标签 服务实现类
|
* </p>
|
*
|
* @author jqs
|
* @since 2023-04-25
|
*/
|
@Service
|
public class SysTagServiceImpl extends ServiceImpl<SysTagMapper, SysTag> implements SysTagService {
|
|
@Resource
|
private SysTagMapper sysTagMapper;
|
|
@Resource
|
private RemoteGoodsService remoteGoodsService;
|
|
@Resource
|
private RemoteShopService remoteShopService;
|
|
@Resource
|
private RemoteMemberService remoteMemberService;
|
|
|
|
/**
|
* 通过id获取系统标签
|
* @param tagId
|
* @return
|
*/
|
@Override
|
public SysTag getByTagId(Long tagId){
|
return this.getById(tagId);
|
}
|
|
/**
|
* 通过type获取系统标签列表
|
* @param tagType
|
* @return
|
*/
|
@Override
|
public List<SysTag> listByType(Integer tagType){
|
LambdaQueryWrapper<SysTag> queryWrapper = Wrappers.lambdaQuery();
|
queryWrapper.eq(SysTag::getDelFlag, 0).eq(SysTag::getTagType, 1);
|
List<SysTag> sysTagsList = this.list(queryWrapper);
|
return sysTagsList;
|
}
|
|
/**
|
* @description 标签管理
|
* @author jqs
|
* @date 2023/6/8 14:09
|
* @param page
|
* @param mgtTagPageDto
|
* @return List<MgtTagPageVo>
|
*/
|
@Override
|
public List<MgtTagPageVo> pageTag(Page page, MgtTagPageDto mgtTagPageDto){
|
return sysTagMapper.pageTag(page, mgtTagPageDto);
|
}
|
|
/**
|
* @description 修改标签
|
* @author jqs
|
* @date 2023/6/8 15:01
|
* @param mgtTagEditDto
|
* @return void
|
*/
|
@Override
|
public void editTag(MgtTagEditDto mgtTagEditDto){
|
// 创建LambdaQueryWrapper对象，用于构建查询条件
|
LambdaQueryWrapper<SysTag> queryWrapper = new LambdaQueryWrapper<>();
|
queryWrapper.eq(SysTag::getDelFlag, 0) // 查询条件：delFlag=0
|
.eq(SysTag::getTagType, mgtTagEditDto.getTagType()) // 查询条件：tagType=mgtTagEditDto的tagType属性
|
.eq(SysTag::getTagName, mgtTagEditDto.getTagName()); // 查询条件：tagName=mgtTagEditDto的tagName属性
|
// 执行查询，获取与查询条件匹配的SysTag对象
|
SysTag sysTagSame = this.getOne(queryWrapper);
|
// 获取mgtTagEditDto的tagId属性
|
Long tagId = mgtTagEditDto.getTagId();
|
// 定义SysTag对象
|
SysTag sysTag;
|
if (tagId != null) { // 如果tagId不为空
|
// 如果存在同类名同分类类型的分类，但是分类ID不同，抛出异常
|
if (sysTagSame != null && !Objects.equals(sysTagSame.getTagId(), tagId)) {
|
throw new ServiceException(AppErrorConstant.TAG_DOUBLE);
|
}
|
// 根据tagId获取要修改的分类
|
sysTag = this.getById(tagId);
|
} else { // 如果tagId为空
|
// 如果存在同类名同分类类型的分类，抛出异常
|
if (sysTagSame != null) {
|
throw new ServiceException(AppErrorConstant.TAG_DOUBLE);
|
}
|
// 新建分类
|
sysTag = new SysTag();
|
sysTag.setDelFlag(0);
|
}
|
// 设置sysTag的属性
|
sysTag.setTagType(mgtTagEditDto.getTagType());
|
sysTag.setTagName(mgtTagEditDto.getTagName());
|
sysTag.setCreateTime(new Date());
|
sysTag.setSynFlag(0);
|
// 执行保存或更新操作
|
this.saveOrUpdate(sysTag);
|
}
|
|
/**
|
* @description 删除标签
|
* @author jqs
|
* @date 2023/6/8 15:09
|
* @param tagId
|
* @return void
|
*/
|
@Override
|
public void deleteTag(Long tagId){
|
SysTag sysTag = this.getById(tagId);
|
sysTag.setDelFlag(1);
|
this.saveOrUpdate(sysTag);
|
handleDeleteTag(sysTag.getTagType(),sysTag.getTagName());
|
}
|
|
@Async
|
protected void handleDeleteTag(Integer tagType, String tagName){
|
//标签类型1用户2合作商3商品4建议
|
switch (tagType){
|
case 1:
|
remoteMemberService.deleteMemberTag(tagName);
|
break;
|
case 2:
|
remoteShopService.deleteShopTag(tagName);
|
break;
|
case 3:
|
remoteGoodsService.deleteGoodsTag(tagName);
|
break;
|
case 4:
|
remoteMemberService.deleteMemberSuggestTag(tagName);
|
remoteShopService.deleteShopSuggestTag(tagName);
|
sysTagMapper.deleteStaffSuggestTag(tagName);
|
break;
|
default:
|
break;
|
}
|
}
|
|
/**
|
* @description importTag
|
* @param tagList
|
* @param tagType
|
* @param operName
|
* @return String
|
* @author jqs34
|
* @date 2023/6/24 17:32
|
*/
|
@Override
|
public String importTag(List<MgtTagImportDto> tagList, Integer tagType, String operName) {
|
if (StringUtils.isNull(tagList) || tagList.size() == 0) {
|
throw new ServiceException("导入标签数据不能为空！");
|
}
|
int successNum = 0;
|
int failureNum = 0;
|
StringBuilder successMsg = new StringBuilder();
|
StringBuilder failureMsg = new StringBuilder();
|
String tagName;
|
LambdaQueryWrapper<SysTag> queryWrapper;
|
SysTag sysTagSame;
|
SysTag sysTagNew;
|
Date nowTime = new Date();
|
for (MgtTagImportDto entity : tagList) {
|
try {
|
tagName = entity.getTagName();
|
sysTagSame = null;
|
// 验证是否存在这个用户
|
queryWrapper = new LambdaQueryWrapper<>();
|
queryWrapper.eq(SysTag::getDelFlag, 0) // 查询条件：delFlag=0
|
.eq(SysTag::getTagType, tagType) // 查询条件：tagType=mgtTagEditDto的tagType属性
|
.eq(SysTag::getTagName, tagName); // 查询条件：tagName=mgtTagEditDto的tagName属性
|
// 执行查询，获取与查询条件匹配的SysTag对象
|
sysTagSame = this.getOne(queryWrapper);
|
if (sysTagSame == null) {
|
sysTagNew = new SysTag();
|
sysTagNew.setDelFlag(0);
|
sysTagNew.setTagType(tagType);
|
sysTagNew.setTagName(tagName);
|
sysTagNew.setCreateTime(nowTime);
|
sysTagNew.setSynFlag(0);
|
this.save(sysTagNew);
|
successNum++;
|
successMsg.append("<br/>" + successNum + "、标签 " + sysTagNew.getTagName() + " 导入成功");
|
} else {
|
failureNum++;
|
failureMsg.append("<br/>" + failureNum + "、标签 " + sysTagSame.getTagName() + " 已存在");
|
}
|
} catch (Exception e) {
|
failureNum++;
|
String msg = "<br/>" + failureNum + "、标签 " + entity.getTagName() + " 导入失败：";
|
failureMsg.append(msg + e.getMessage());
|
log.error(msg, e);
|
}
|
}
|
if (failureNum > 0) {
|
failureMsg.insert(0, "很抱歉，导入失败！共 " + failureNum + " 条数据格式不正确，错误如下：");
|
throw new ServiceException(failureMsg.toString());
|
} else {
|
successMsg.insert(0, "恭喜您，数据已全部导入成功！共 " + successNum + " 条，数据如下：");
|
}
|
return successMsg.toString();
|
}
|
}
|
