package cn.iocoder.yudao.module.mes.service.wms.approval;

import cn.hutool.core.util.StrUtil;
import cn.iocoder.yudao.module.bpm.api.task.BpmProcessInstanceApi;
import cn.iocoder.yudao.module.bpm.api.task.dto.BpmProcessInstanceCreateReqDTO;
import cn.iocoder.yudao.module.bpm.dal.dataobject.definition.BpmProcessDefinitionInfoDO;
import cn.iocoder.yudao.module.bpm.enums.task.BpmTaskStatusEnum;
import cn.iocoder.yudao.module.bpm.service.definition.BpmCategoryService;
import cn.iocoder.yudao.module.bpm.service.definition.BpmProcessDefinitionService;
import cn.iocoder.yudao.module.mes.dal.dataobject.wms.approval.WmsWarehouseApprovalConfigDO;
import cn.iocoder.yudao.module.mes.dal.mysql.wms.approval.WmsWarehouseApprovalConfigMapper;
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.util.Collections;
import java.util.List;

import static cn.iocoder.yudao.framework.common.exception.util.ServiceExceptionUtil.exception;
import static cn.iocoder.yudao.module.mes.enums.ErrorCodeConstants.*;

/**
 * WMS 审批服务实现类
 */
@Service
@Validated
@Slf4j
public class WmsApprovalServiceImpl implements WmsApprovalService {

    /**
     * 默认BPM分类编码
     */
    private static final String DEFAULT_CATEGORY_CODE = "wms_approve";

    @Resource
    private WmsWarehouseApprovalConfigMapper approvalConfigMapper;

    @Resource
    private BpmCategoryService bpmCategoryService;

    @Resource
    private BpmProcessDefinitionService bpmProcessDefinitionService;

    @Resource
    private BpmProcessInstanceApi bpmProcessInstanceApi;

    @Override
    public WmsWarehouseApprovalConfigDO getApprovalConfig(Long warehouseId, String bizType) {
        return approvalConfigMapper.selectByWarehouseIdAndBizType(warehouseId, bizType);
    }

    @Override
    public List<WmsWarehouseApprovalConfigDO> getApprovalConfigList(Long warehouseId) {
        return approvalConfigMapper.selectListByWarehouseId(warehouseId);
    }

    @Override
    public void saveApprovalConfig(WmsWarehouseApprovalConfigDO config) {
        // 检查是否已存在
        WmsWarehouseApprovalConfigDO existing = getApprovalConfig(config.getWarehouseId(), config.getBizType());
        if (existing == null) {
            approvalConfigMapper.insert(config);
        } else {
            config.setId(existing.getId());
            approvalConfigMapper.updateById(config);
        }
    }

    @Override
    public boolean needApproval(Long warehouseId, String bizType) {
        WmsWarehouseApprovalConfigDO config = getApprovalConfig(warehouseId, bizType);
        return config != null && Boolean.TRUE.equals(config.getApprovalEnabled());
    }

    @Override
    @Transactional(rollbackFor = Exception.class)
    public String submitApproval(Long orderId, String orderType, String processDefinitionKey, Long userId) {
        log.info("[submitApproval] 提交审批，orderId={}, orderType={}", orderId, orderType);

        // 注意：此方法需要根据实际业务场景实现
        // 1. 获取单据信息和仓库ID（仓库ID在明细行中，需先查询明细）
        // 2. 获取审批配置
        // 3. 创建流程实例
        // 4. 更新单据的流程实例ID和状态

        // 当前为简化实现，实际使用时需要补充完整逻辑
        throw exception(WMS_APPROVAL_ORDER_TYPE_NOT_SUPPORTED);
    }

    @Override
    public List<BpmProcessDefinitionInfoDO> getAvailableProcessList(Long warehouseId, String bizType) {
        WmsWarehouseApprovalConfigDO config = getApprovalConfig(warehouseId, bizType);
        String categoryCode = config != null && StrUtil.isNotBlank(config.getCategoryCode())
                ? config.getCategoryCode() : DEFAULT_CATEGORY_CODE;

        // 查询分类下的流程定义
        List<BpmProcessDefinitionInfoDO> definitions = bpmProcessDefinitionService
                .getProcessDefinitionInfoListByCategory(categoryCode);
        if (definitions == null) {
            return Collections.emptyList();
        }
        return definitions;
    }

    @Override
    @Transactional(rollbackFor = Exception.class)
    public void updateAuditStatus(Long orderId, String orderType, Integer bpmStatus) {
        log.info("[updateAuditStatus] 更新审批状态，orderId={}, orderType={}, bpmStatus={}", orderId, orderType, bpmStatus);

        // 将BPM状态转换为业务状态
        Integer businessStatus = convertBpmResultToBusinessStatus(bpmStatus, orderType);
        if (businessStatus == null) {
            log.warn("[updateAuditStatus] 未知的BPM状态，bpmStatus={}", bpmStatus);
            return;
        }

        // 注意：此方法需要根据实际业务场景实现
        // 当前为简化实现，实际使用时需要补充完整逻辑
        throw exception(WMS_APPROVAL_ORDER_TYPE_NOT_SUPPORTED);
    }

    /**
     * 将BPM审批结果转换为业务状态
     */
    private Integer convertBpmResultToBusinessStatus(Integer bpmStatus, String orderType) {
        // 根据BPM审批结果返回对应状态
        // APPROVE -> 已审批状态
        // REJECT -> 草稿状态（让用户可以重新提交）
        // CANCEL -> 已取消状态
        if (BpmTaskStatusEnum.APPROVE.getStatus().equals(bpmStatus)) {
            return 20; // APPROVED 状态
        } else if (BpmTaskStatusEnum.REJECT.getStatus().equals(bpmStatus)) {
            return 0;  // PREPARE 状态
        } else if (BpmTaskStatusEnum.CANCEL.getStatus().equals(bpmStatus)) {
            return 40; // CANCELED 状态
        }
        return null;
    }

}