package cn.iocoder.yudao.module.aftersales.dal.mysql.problem;
|
|
import cn.hutool.core.util.StrUtil;
|
import cn.iocoder.yudao.framework.common.pojo.PageParam;
|
import cn.iocoder.yudao.framework.common.pojo.PageResult;
|
import cn.iocoder.yudao.framework.mybatis.core.mapper.BaseMapperX;
|
import cn.iocoder.yudao.framework.mybatis.core.query.LambdaQueryWrapperX;
|
import cn.iocoder.yudao.module.aftersales.dal.dataobject.problem.AfterSaleProblemDO;
|
import cn.iocoder.yudao.module.aftersales.enums.AfterSaleProblemStatusEnum;
|
import org.apache.ibatis.annotations.Mapper;
|
|
import java.util.List;
|
|
/**
|
* 售后问题库 Mapper
|
*/
|
@Mapper
|
public interface AfterSaleProblemMapper extends BaseMapperX<AfterSaleProblemDO> {
|
|
default AfterSaleProblemDO selectByNo(String no) {
|
return selectOne(AfterSaleProblemDO::getNo, no);
|
}
|
|
default AfterSaleProblemDO selectBySourceTicketId(Long sourceTicketId) {
|
return selectOne(AfterSaleProblemDO::getSourceTicketId, sourceTicketId);
|
}
|
|
default PageResult<AfterSaleProblemDO> selectPage(PageParam pageParam, String no, String keyword,
|
Long sourceTicketId, Long itemId, String itemCode,
|
String issueCategory,
|
Integer issueType, Integer rootCauseCategory, Integer status) {
|
LambdaQueryWrapperX<AfterSaleProblemDO> query = new LambdaQueryWrapperX<AfterSaleProblemDO>()
|
.eqIfPresent(AfterSaleProblemDO::getNo, no)
|
.eqIfPresent(AfterSaleProblemDO::getSourceTicketId, sourceTicketId)
|
.eqIfPresent(AfterSaleProblemDO::getItemId, itemId)
|
.likeIfPresent(AfterSaleProblemDO::getItemCode, itemCode)
|
.eqIfPresent(AfterSaleProblemDO::getIssueCategory, issueCategory)
|
.eqIfPresent(AfterSaleProblemDO::getIssueType, issueType)
|
.eqIfPresent(AfterSaleProblemDO::getRootCauseCategory, rootCauseCategory)
|
.eqIfPresent(AfterSaleProblemDO::getStatus, status);
|
// 关键字检索：单号/标题/描述/解决方案
|
if (StrUtil.isNotBlank(keyword)) {
|
query.and(w -> w.like(AfterSaleProblemDO::getNo, keyword)
|
.or().like(AfterSaleProblemDO::getTitle, keyword)
|
.or().like(AfterSaleProblemDO::getDescription, keyword)
|
.or().like(AfterSaleProblemDO::getSolution, keyword));
|
}
|
query.orderByDesc(AfterSaleProblemDO::getUpdateTime);
|
return selectPage(pageParam, query);
|
}
|
|
/**
|
* 新工单受理参考检索：只返回已发布，按物料/分类/关键字命中，取最近更新 10 条
|
*/
|
default List<AfterSaleProblemDO> selectReferenceList(Long itemId, String issueCategory, Integer issueType,
|
Integer rootCauseCategory, String keyword) {
|
LambdaQueryWrapperX<AfterSaleProblemDO> query = new LambdaQueryWrapperX<AfterSaleProblemDO>()
|
.eq(AfterSaleProblemDO::getStatus, AfterSaleProblemStatusEnum.PUBLISHED.getStatus());
|
query.and(w -> {
|
boolean hasCond = false;
|
if (itemId != null) {
|
w.eq(AfterSaleProblemDO::getItemId, itemId);
|
hasCond = true;
|
}
|
if (StrUtil.isNotBlank(issueCategory)) {
|
if (hasCond) {
|
w.or();
|
}
|
w.eq(AfterSaleProblemDO::getIssueCategory, issueCategory);
|
hasCond = true;
|
}
|
if (issueType != null) {
|
if (hasCond) {
|
w.or();
|
}
|
w.eq(AfterSaleProblemDO::getIssueType, issueType);
|
hasCond = true;
|
}
|
if (rootCauseCategory != null) {
|
if (hasCond) {
|
w.or();
|
}
|
w.eq(AfterSaleProblemDO::getRootCauseCategory, rootCauseCategory);
|
hasCond = true;
|
}
|
if (StrUtil.isNotBlank(keyword)) {
|
if (hasCond) {
|
w.or();
|
}
|
w.like(AfterSaleProblemDO::getTitle, keyword);
|
hasCond = true;
|
}
|
if (!hasCond) {
|
w.eq(AfterSaleProblemDO::getId, -1L); // 无条件时返回空，避免全表拉取
|
}
|
});
|
query.orderByDesc(AfterSaleProblemDO::getUpdateTime).last("LIMIT 10");
|
return selectList(query);
|
}
|
|
}
|
