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());
    }

}