package com.ruoyi.sales.service.impl;

import cn.hutool.core.bean.BeanUtil;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.ruoyi.basic.enums.ApplicationTypeEnum;
import com.ruoyi.basic.enums.RecordTypeEnum;
import com.ruoyi.basic.dto.StorageBlobDTO;
import com.ruoyi.basic.dto.StorageBlobVO;
import com.ruoyi.basic.utils.FileUtil;
import com.ruoyi.framework.web.domain.AjaxResult;
import com.ruoyi.common.utils.StringUtils;
import com.ruoyi.sales.dto.SalesLawsuitDTO;
import com.ruoyi.sales.mapper.SalesLawsuitMapper;
import com.ruoyi.sales.pojo.SalesLawsuit;
import com.ruoyi.sales.service.ISalesLawsuitService;
import com.ruoyi.sales.vo.SalesLawsuitVO;
import jakarta.annotation.Resource;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.util.CollectionUtils;

import java.time.LocalDateTime;
import java.util.ArrayList;
import java.util.List;
import java.util.stream.Collectors;

/**
 * 诉讼管理 Service 实现
 */
@Slf4j
@Service
public class SalesLawsuitServiceImpl extends ServiceImpl<SalesLawsuitMapper, SalesLawsuit> implements ISalesLawsuitService {

    @Resource
    private FileUtil fileUtil;

    @Override
    public IPage<SalesLawsuitVO> listPage(Page<SalesLawsuit> page, SalesLawsuitDTO dto) {
        LambdaQueryWrapper<SalesLawsuit> queryWrapper = buildQueryWrapper(dto);
        IPage<SalesLawsuit> iPage = this.page(page, queryWrapper);

        IPage<SalesLawsuitVO> voPage = iPage.convert(item -> {
            SalesLawsuitVO vo = BeanUtil.copyProperties(item, SalesLawsuitVO.class);
            return vo;
        });

        return voPage;
    }

    @Override
    public AjaxResult getDetail(Long id) {
        SalesLawsuit lawsuit = this.getById(id);
        if (lawsuit == null) {
            return AjaxResult.error("数据不存在");
        }
        SalesLawsuitVO vo = BeanUtil.copyProperties(lawsuit, SalesLawsuitVO.class);

        // 组装附件
        List<StorageBlobVO> storageBlobVOs = fileUtil.getStorageBlobVOsByApplicationAndRecordTypeAndRecordId(
                ApplicationTypeEnum.FILE,
                RecordTypeEnum.SALES_LAWSUIT,
                id
        );
        vo.setStorageBlobVOs(storageBlobVOs != null ? storageBlobVOs : new ArrayList<>());

        return AjaxResult.success(vo);
    }

    @Override
    @Transactional(rollbackFor = Exception.class)
    public AjaxResult addOrUpdate(SalesLawsuitDTO dto) {
        SalesLawsuit lawsuit = BeanUtil.copyProperties(dto, SalesLawsuit.class);
        boolean isUpdate = lawsuit.getId() != null;

        if (isUpdate) {
            this.updateById(lawsuit);
            log.info("TODO: 同步更新项目时间轴中对应的诉讼事件节点 (projectId: {}, lawsuitId: {})", lawsuit.getProjectId(), lawsuit.getId());
        } else {
            this.save(lawsuit);
            log.info("TODO: 在项目时间轴中追加一条诉讼节点 (projectId: {}, lawsuitId: {})", lawsuit.getProjectId(), lawsuit.getId());
        }

        // 处理附件
        List<StorageBlobDTO> storageBlobDTOs = dto.getStorageBlobDTOs();
        if (storageBlobDTOs == null) {
            storageBlobDTOs = new ArrayList<>();
        }
        fileUtil.saveStorageAttachment(
                ApplicationTypeEnum.FILE,
                RecordTypeEnum.SALES_LAWSUIT,
                lawsuit.getId(),
                storageBlobDTOs
        );

        return AjaxResult.success();
    }

    @Override
    @Transactional(rollbackFor = Exception.class)
    public AjaxResult del(List<Long> ids) {
        if (CollectionUtils.isEmpty(ids)) {
            return AjaxResult.error("参数不能为空");
        }
        List<SalesLawsuit> lawsuits = this.listByIds(ids);

        this.removeByIds(ids);

        for (SalesLawsuit lawsuit : lawsuits) {
            log.info("TODO: 同步移除项目时间轴中对应的诉讼事件节点 (projectId: {}, lawsuitId: {})", lawsuit.getProjectId(), lawsuit.getId());
        }

        return AjaxResult.success();
    }

    @Override
    public List<SalesLawsuit> selectList(SalesLawsuitDTO dto) {
        return this.list(buildQueryWrapper(dto));
    }

    /**
     * 构建查询条件
     */
    private LambdaQueryWrapper<SalesLawsuit> buildQueryWrapper(SalesLawsuitDTO dto) {
        LambdaQueryWrapper<SalesLawsuit> queryWrapper = new LambdaQueryWrapper<>();
        if (dto == null) {
            return queryWrapper;
        }
        queryWrapper.like(StringUtils.isNotBlank(dto.getCaseNo()), SalesLawsuit::getCaseNo, dto.getCaseNo());
        queryWrapper.eq(dto.getProjectId() != null, SalesLawsuit::getProjectId, dto.getProjectId());
        queryWrapper.like(StringUtils.isNotBlank(dto.getProjectName()), SalesLawsuit::getProjectName, dto.getProjectName());
        queryWrapper.eq(dto.getContractId() != null, SalesLawsuit::getContractId, dto.getContractId());
        queryWrapper.like(StringUtils.isNotBlank(dto.getContractNo()), SalesLawsuit::getContractNo, dto.getContractNo());
        queryWrapper.eq(StringUtils.isNotBlank(dto.getLawsuitStatus()), SalesLawsuit::getLawsuitStatus, dto.getLawsuitStatus());
        queryWrapper.like(StringUtils.isNotBlank(dto.getLawyer()), SalesLawsuit::getLawyer, dto.getLawyer());
        queryWrapper.ge(dto.getFilingDateStart() != null, SalesLawsuit::getFilingDate, dto.getFilingDateStart());
        queryWrapper.le(dto.getFilingDateEnd() != null, SalesLawsuit::getFilingDate, dto.getFilingDateEnd());

        queryWrapper.orderByDesc(SalesLawsuit::getCreateTime);
        return queryWrapper;
    }
}