package cn.iocoder.yudao.module.ums.service.application;

import cn.iocoder.yudao.module.bpm.service.task.BpmTaskApprovalValidator;
import cn.iocoder.yudao.module.ums.dal.dataobject.application.UmsApplicationDO;
import cn.iocoder.yudao.module.ums.dal.mysql.application.UmsApplicationMapper;
import jakarta.annotation.Resource;
import org.flowable.engine.runtime.ProcessInstance;
import org.flowable.task.api.Task;
import org.springframework.stereotype.Component;
import static cn.iocoder.yudao.framework.common.exception.util.ServiceExceptionUtil.exception;
import static cn.iocoder.yudao.module.ums.enums.ErrorCodeConstants.*;

@Component
public class UmsApplicationApprovalValidator implements BpmTaskApprovalValidator {
    @Resource private UmsApplicationMapper mapper;

    @Override
    public void validate(Long userId, Task task, ProcessInstance instance) {
        if (!"ums_membership_approve".equals(instance.getProcessDefinitionKey())) return;
        // 发起人节点由 BPM 在流程启动时自动提交；缴费由后续审批人确认。
        if ("StartUserNode".equals(task.getTaskDefinitionKey())) return;
        Long id;
        try { id = Long.valueOf(instance.getBusinessKey()); }
        catch (Exception e) { throw exception(APPLICATION_NOT_EXISTS); }
        UmsApplicationDO application = mapper.selectById(id);
        if (application == null) throw exception(APPLICATION_NOT_EXISTS);
        if (application.getFeePaid() == null) throw exception(APPLICATION_FEE_CONFIRM_REQUIRED);
    }
}