package cn.iocoder.yudao.module.aftersales.service.visit;
|
|
import cn.hutool.core.collection.CollUtil;
|
import cn.iocoder.yudao.framework.common.pojo.PageResult;
|
import cn.iocoder.yudao.framework.common.util.object.BeanUtils;
|
import cn.iocoder.yudao.module.aftersales.controller.admin.visit.vo.AfterSaleVisitCreateReqVO;
|
import cn.iocoder.yudao.module.aftersales.controller.admin.visit.vo.AfterSaleVisitPageReqVO;
|
import cn.iocoder.yudao.module.aftersales.dal.dataobject.ticket.AfterSaleTicketDO;
|
import cn.iocoder.yudao.module.aftersales.dal.dataobject.visit.AfterSaleVisitDO;
|
import cn.iocoder.yudao.module.aftersales.dal.mysql.ticket.AfterSaleTicketMapper;
|
import cn.iocoder.yudao.module.aftersales.dal.mysql.visit.AfterSaleVisitMapper;
|
import cn.iocoder.yudao.module.aftersales.enums.AfterSaleTicketStatusEnum;
|
import cn.iocoder.yudao.module.aftersales.enums.AfterSaleVisitStatusEnum;
|
import cn.iocoder.yudao.module.system.api.storage.StorageAttachmentApi;
|
import jakarta.annotation.Resource;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
import org.springframework.validation.annotation.Validated;
|
|
import java.time.LocalDateTime;
|
import java.util.List;
|
|
import static cn.iocoder.yudao.framework.common.exception.util.ServiceExceptionUtil.exception;
|
import static cn.iocoder.yudao.module.aftersales.enums.ErrorCodeConstants.TICKET_NOT_EXISTS;
|
import static cn.iocoder.yudao.module.aftersales.enums.ErrorCodeConstants.VISIT_CREATE_FAIL_STATUS;
|
import static cn.iocoder.yudao.module.aftersales.enums.ErrorCodeConstants.VISIT_NOT_EXISTS;
|
|
/**
|
* 售后回访记录 Service 实现类
|
*/
|
@Service
|
@Validated
|
@Slf4j
|
public class AfterSaleVisitServiceImpl implements AfterSaleVisitService {
|
|
@Resource
|
private AfterSaleVisitMapper visitMapper;
|
@Resource
|
private AfterSaleTicketMapper ticketMapper;
|
@Resource
|
private StorageAttachmentApi storageAttachmentApi;
|
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public Long createVisit(AfterSaleVisitCreateReqVO createReqVO, Long userId) {
|
// 1. 校验工单：必须存在且处于已完结(待回访)状态
|
AfterSaleTicketDO ticket = ticketMapper.selectById(createReqVO.getTicketId());
|
if (ticket == null) {
|
throw exception(TICKET_NOT_EXISTS);
|
}
|
if (!AfterSaleTicketStatusEnum.COMPLETED.getStatus().equals(ticket.getStatus())) {
|
throw exception(VISIT_CREATE_FAIL_STATUS);
|
}
|
|
// 2. 插入回访记录
|
AfterSaleVisitDO visitDO = BeanUtils.toBean(createReqVO, AfterSaleVisitDO.class)
|
.setVisitorUserId(userId)
|
.setVisitTime(LocalDateTime.now());
|
visitMapper.insert(visitDO);
|
|
// 3. 绑定附件
|
if (CollUtil.isNotEmpty(createReqVO.getBlobIds())) {
|
storageAttachmentApi.bindAttachments("file", "aftersales_after_sale_visit",
|
visitDO.getId(), createReqVO.getBlobIds());
|
}
|
|
// 4. 推进工单回访状态：满意且未复发 → 通过；不满意或复发 → 回退处理中重新处理
|
boolean satisfied = Boolean.TRUE.equals(createReqVO.getSatisfied());
|
boolean recurred = Boolean.TRUE.equals(createReqVO.getRecurred());
|
AfterSaleTicketDO update = new AfterSaleTicketDO().setId(ticket.getId())
|
.setLastVisitTime(visitDO.getVisitTime())
|
.setLastVisitSatisfied(satisfied)
|
.setLastVisitRecurred(recurred);
|
if (satisfied && !recurred) {
|
update.setVisitStatus(AfterSaleVisitStatusEnum.PASSED.getStatus());
|
} else {
|
update.setStatus(AfterSaleTicketStatusEnum.PROCESSING.getStatus())
|
.setResolvedTime(null)
|
.setVisitStatus(AfterSaleVisitStatusEnum.WAITING.getStatus());
|
}
|
ticketMapper.updateById(update);
|
return visitDO.getId();
|
}
|
|
@Override
|
public AfterSaleVisitDO getVisit(Long id) {
|
AfterSaleVisitDO visitDO = visitMapper.selectById(id);
|
if (visitDO == null) {
|
throw exception(VISIT_NOT_EXISTS);
|
}
|
return visitDO;
|
}
|
|
@Override
|
public List<AfterSaleVisitDO> getVisitListByTicketId(Long ticketId) {
|
return visitMapper.selectListByTicketId(ticketId);
|
}
|
|
@Override
|
public PageResult<AfterSaleVisitDO> getVisitPage(AfterSaleVisitPageReqVO pageReqVO) {
|
return visitMapper.selectPage(pageReqVO, pageReqVO.getTicketId(),
|
pageReqVO.getVisitType(), pageReqVO.getSatisfied());
|
}
|
|
}
|
