package cn.iocoder.yudao.module.bpm.service.attach;

import cn.hutool.core.collection.CollUtil;
import cn.hutool.core.util.ObjUtil;
import cn.hutool.core.util.StrUtil;
import cn.iocoder.yudao.framework.common.enums.CommonStatusEnum;
import cn.iocoder.yudao.framework.common.exception.ServiceException;
import cn.iocoder.yudao.framework.common.pojo.PageResult;
import cn.iocoder.yudao.framework.common.util.object.BeanUtils;
import cn.iocoder.yudao.module.bpm.controller.admin.attach.vo.attach.BpmBusinessAttachImportExcelVO;
import cn.iocoder.yudao.module.bpm.controller.admin.attach.vo.attach.BpmBusinessAttachImportReqVO;
import cn.iocoder.yudao.module.bpm.controller.admin.attach.vo.attach.BpmBusinessAttachImportRespVO;
import cn.iocoder.yudao.module.bpm.controller.admin.attach.vo.attach.BpmBusinessAttachPageReqVO;
import cn.iocoder.yudao.module.bpm.controller.admin.attach.vo.attach.BpmBusinessAttachSaveReqVO;
import cn.iocoder.yudao.module.bpm.controller.admin.definition.vo.process.BpmProcessDefinitionRespVO;
import cn.iocoder.yudao.module.bpm.dal.dataobject.definition.BpmBusinessAttachDO;
import cn.iocoder.yudao.module.bpm.dal.mysql.attach.BpmBusinessAttachMapper;
import cn.iocoder.yudao.module.bpm.enums.definition.BpmModelFormTypeEnum;
import jakarta.annotation.Resource;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.validation.annotation.Validated;

import java.util.ArrayList;
import java.util.LinkedHashMap;
import java.util.List;
import java.util.Objects;

import static cn.iocoder.yudao.framework.common.exception.util.ServiceExceptionUtil.exception;
import static cn.iocoder.yudao.framework.common.util.collection.CollectionUtils.filterList;
import static cn.iocoder.yudao.module.bpm.enums.ErrorCodeConstants.BUSINESS_ATTACH_IMPORT_EXISTS;
import static cn.iocoder.yudao.module.bpm.enums.ErrorCodeConstants.BUSINESS_ATTACH_IMPORT_LIST_IS_EMPTY;
import static cn.iocoder.yudao.module.bpm.enums.ErrorCodeConstants.BUSINESS_ATTACH_NOT_EXISTS;
import static cn.iocoder.yudao.module.bpm.enums.ErrorCodeConstants.BUSINESS_ATTACH_PROCESS_DEFINITION_KEY_DUPLICATE;

/**
 * BPM 业务附件配置 Service 实现类
 *
 * @author 超级管理员
 */
@Service
@Validated
public class BpmBusinessAttachServiceImpl implements BpmBusinessAttachService {

    @Resource
    private BpmBusinessAttachMapper businessAttachMapper;

    @Override
    public Long createBusinessAttach(BpmBusinessAttachSaveReqVO createReqVO) {
        // 校验流程定义 Key 唯一
        validateProcessDefinitionKeyUnique(createReqVO);
        // 插入
        BpmBusinessAttachDO attach = BeanUtils.toBean(createReqVO, BpmBusinessAttachDO.class);
        businessAttachMapper.insert(attach);
        return attach.getId();
    }

    @Override
    public void updateBusinessAttach(BpmBusinessAttachSaveReqVO updateReqVO) {
        // 校验存在
        validateBusinessAttachExists(updateReqVO.getId());
        // 校验流程定义 Key 唯一
        validateProcessDefinitionKeyUnique(updateReqVO);
        // 更新
        BpmBusinessAttachDO updateObj = BeanUtils.toBean(updateReqVO, BpmBusinessAttachDO.class);
        businessAttachMapper.updateById(updateObj);
    }

    private void validateProcessDefinitionKeyUnique(BpmBusinessAttachSaveReqVO reqVO) {
        BpmBusinessAttachDO attach = businessAttachMapper.selectByProcessDefinitionKey(reqVO.getProcessDefinitionKey());
        if (attach == null || ObjUtil.equal(attach.getId(), reqVO.getId())) {
            return;
        }
        throw exception(BUSINESS_ATTACH_PROCESS_DEFINITION_KEY_DUPLICATE, reqVO.getProcessDefinitionKey());
    }

    @Override
    public void deleteBusinessAttach(Long id) {
        // 校验存在
        validateBusinessAttachExists(id);
        // 删除
        businessAttachMapper.deleteById(id);
    }

    private BpmBusinessAttachDO validateBusinessAttachExists(Long id) {
        BpmBusinessAttachDO attach = businessAttachMapper.selectById(id);
        if (attach == null) {
            throw exception(BUSINESS_ATTACH_NOT_EXISTS);
        }
        return attach;
    }

    @Override
    public BpmBusinessAttachDO getBusinessAttach(Long id) {
        return businessAttachMapper.selectById(id);
    }

    @Override
    public PageResult<BpmBusinessAttachDO> getBusinessAttachPage(BpmBusinessAttachPageReqVO pageReqVO) {
        return businessAttachMapper.selectPage(pageReqVO);
    }

    @Override
    public BpmBusinessAttachDO getBusinessAttachByProcessDefinitionKey(String processDefinitionKey) {
        return businessAttachMapper.selectByProcessDefinitionKey(processDefinitionKey);
    }

    @Override
    public void fillBusinessForm(BpmProcessDefinitionRespVO definitionResp, String processDefinitionKey, String businessKey) {
        // 未发起 / 无业务主键：不注入
        if (definitionResp == null || StrUtil.isBlank(businessKey)) {
            return;
        }
        // 非 NORMAL 流程表单（已手动配置 CUSTOM）：不覆盖
        if (!Objects.equals(definitionResp.getFormType(), BpmModelFormTypeEnum.NORMAL.getType())) {
            return;
        }
        // 未命中配置 / 配置被禁用：保持原样
        BpmBusinessAttachDO attach = getBusinessAttachByProcessDefinitionKey(processDefinitionKey);
        if (attach == null || !Objects.equals(attach.getStatus(), CommonStatusEnum.ENABLE.getStatus())) {
            return;
        }
        // 覆盖为 CUSTOM，注入业务详情组件路径
        definitionResp.setFormType(BpmModelFormTypeEnum.CUSTOM.getType());
        definitionResp.setFormCustomViewPath(attach.getComponentPath());
        // 清空普通表单字段：详情页 CUSTOM 分支不读；打印页按 formFields.length == 0 判断渲染业务组件
        definitionResp.setFormFields(null);
        definitionResp.setFormConf(null);
    }

    @Override
    @Transactional(rollbackFor = Exception.class)
    public BpmBusinessAttachImportRespVO importBusinessAttachList(List<BpmBusinessAttachImportExcelVO> importBusinessAttaches,
                                                                 BpmBusinessAttachImportReqVO importReqVO) {
        // 1. 校验非空
        importBusinessAttaches = filterList(importBusinessAttaches,
                item -> StrUtil.isNotBlank(item.getProcessDefinitionKey()));
        if (CollUtil.isEmpty(importBusinessAttaches)) {
            throw exception(BUSINESS_ATTACH_IMPORT_LIST_IS_EMPTY);
        }
        // 2. 逐条处理
        BpmBusinessAttachImportRespVO respVO = BpmBusinessAttachImportRespVO.builder()
                .createBusinessAttachKeys(new ArrayList<>())
                .updateBusinessAttachKeys(new ArrayList<>())
                .failureBusinessAttachKeys(new LinkedHashMap<>())
                .build();
        importBusinessAttaches.forEach(importBusinessAttach -> {
            try {
                // 2.1 按流程定义 Key 匹配已存在记录
                BpmBusinessAttachDO existAttach = businessAttachMapper.selectByProcessDefinitionKey(
                        importBusinessAttach.getProcessDefinitionKey());
                if (existAttach == null) {
                    BpmBusinessAttachDO attach = BeanUtils.toBean(importBusinessAttach, BpmBusinessAttachDO.class);
                    businessAttachMapper.insert(attach);
                    respVO.getCreateBusinessAttachKeys().add(importBusinessAttach.getProcessDefinitionKey());
                    return;
                }
                // 2.2 已存在，判断是否允许更新
                if (!importReqVO.getUpdateSupport()) {
                    respVO.getFailureBusinessAttachKeys().put(importBusinessAttach.getProcessDefinitionKey(),
                            StrUtil.format(BUSINESS_ATTACH_IMPORT_EXISTS.getMsg(), importBusinessAttach.getProcessDefinitionKey()));
                    return;
                }
                BpmBusinessAttachDO updateAttach = BeanUtils.toBean(importBusinessAttach, BpmBusinessAttachDO.class)
                        .setId(existAttach.getId());
                businessAttachMapper.updateById(updateAttach);
                respVO.getUpdateBusinessAttachKeys().add(importBusinessAttach.getProcessDefinitionKey());
            } catch (ServiceException ex) {
                respVO.getFailureBusinessAttachKeys().put(importBusinessAttach.getProcessDefinitionKey(), ex.getMessage());
            }
        });
        return respVO;
    }

}