package jnpf.flowable.controller;

import jnpf.base.ActionResult;
import jnpf.flowable.entity.TaskEntity;
import jnpf.flowable.enums.EventEnum;
import jnpf.flowable.enums.TaskStatusEnum;
import jnpf.flowable.model.task.AuditModel;
import jnpf.flowable.model.task.FlowModel;
import jnpf.flowable.model.task.TaskTo;
import jnpf.flowable.service.TaskService;
import jnpf.flowable.util.OperatorUtil;
import jnpf.flowable.TaskApi;
import lombok.RequiredArgsConstructor;
import org.springframework.web.bind.annotation.*;


/**
 * 类的描述
 *
 * @author JNPF@YinMai Info. Co., Ltd
 * @version 5.0.x
 * @since 2024/5/28 14:32
 */
@RestController
@RequestMapping("/task")
@RequiredArgsConstructor
public class TaskForFileController implements TaskApi {

    private final TaskService taskService;

    private final  OperatorUtil operatorUtil;

    @Override
    @PostMapping("/saveDraft")
    public ActionResult<AuditModel> saveDraft(@RequestBody FlowModel flowModel) {
        try {
            flowModel.setServerAutoDraft(true);
            taskService.batchSaveOrSubmit(flowModel);
            operatorUtil.handleOperator();
            if (TaskStatusEnum.RUNNING.getCode().equals(flowModel.getStatus())) {
                operatorUtil.handleTaskStatusThenEvent(flowModel, EventEnum.INIT.getStatus());
            }
            TaskEntity taskEntity = flowModel.getTaskEntity();
            if (taskEntity.getRejectDataId() == null) {
                operatorUtil.autoAudit(flowModel);
                operatorUtil.launchTrigger(flowModel);
                operatorUtil.handleOperator();
                operatorUtil.handleTaskStatusThenEvent();
            } else {
                operatorUtil.handleTaskStatus();
            }
            TaskEntity savedTask = taskService.getById(taskEntity.getId());
            AuditModel model = operatorUtil.getAuditModel(
                    savedTask == null ? taskEntity.getId() : savedTask.getId(), flowModel, null);
            return ActionResult.success(model);
        } catch (Exception exception) {
            return ActionResult.fail(exception.getMessage());
        }
    }

    @Override
    @PostMapping("/launchFlow")
    public ActionResult launchFlow(@RequestBody FlowModel flowModel) {
        try {
            return operatorUtil.launchFlow(flowModel);
        } catch (Exception e) {
            e.printStackTrace();
            return ActionResult.fail(e.getMessage());
        }
    }

    @Override
    @PostMapping("/getFlowTodoCount")
    public TaskTo getFlowTodoCount(@RequestBody TaskTo taskTo) {
        return taskService.getFlowTodoCount(taskTo);
    }

}