/**
 * Copyright (c) 2018 人人开源 All rights reserved.
 * <p>
 * https://www.renren.io
 * <p>
 * 版权所有，侵权必究！
 */

package com.zt.modules.workflow.dao;

import com.zt.common.dao.BaseDao;
import com.zt.common.entity.FlowInfo;
import com.zt.core.sys.model.SysUser;
import com.zt.modules.workflow.model.WfRunTask;
import com.zt.modules.workflow.dto.BizInfoDto;
import com.zt.modules.workflowconfig.model.WfDefStep;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param;

import java.util.List;
import java.util.Map;

/**
 * 工作流运行-log
 *
 * @author Alex
 * @since 1.0.0
 */
@Mapper
public interface WfRunTaskDao extends BaseDao<WfRunTask> {

    List<SysUser> getTaskUser(@Param("roleId") String roleId, @Param("deptIds") String deptIds);
    List<SysUser> getAssignUser(String code, String stepMarker, Long bizId);
    SysUser getUserById(Long userId);

    void setTaskStatus(@Param("bizId") Long bizId, @Param("stepId") Long stepId,
                       @Param("status") Integer status, @Param("userId") Long userId,
                       @Param("realName") String realName, @Param("taskGroup") String taskGroup,
                       @Param("option") Integer option
                       );

    List<BizInfoDto> getSqlResult(@Param(value = "script") String script);

    void exeSql(@Param(value = "script") String script);

    void deleteFlowTask(String wfIdCodes, Long bizId);

    List<WfRunTask> getFlowFinish(@Param("wfDefIdCode") String wfDefIdCode, @Param("bizId") Long bizId);

    List<WfRunTask> getSingleFlowStatus(String wfIdCodes, Long bizId);

    List<WfRunTask> getFlowStatus(@Param("wfIdCodes") String wfIdCodes, @Param("bizId") Long bizId);
    List<WfRunTask> getFlowStatus2(String wfIdCodes, Long bizGroupId);
    List<WfRunTask> getFlowStatus3(String wfIdCodes, Long biz_group_id);

    List<WfRunTask> getFlowStepStatus(@Param("wfIdCodes") String wfIdCodes, @Param("bizId") Long bizId);

    Integer isMyStep(String wfIdCode, Long bizId, String stepMarker, Long userId);
    Integer isMyStepFinish(String wfIdCode, Long bizId, String stepMarker, Long userId);

    List<WfRunTask> getStepCount(String wfIdCode, Long bizId);
    Integer getBizTaskCount(String wfIdCode, Long bizId);

    // 按 0,1 检查
    Integer getFlowStepFinish(String wfIdCode, Long bizId, String stepIdMark);
    // an 20,21,100检查
    Integer getFlowStepFinish2(String wfIdCode, Long bizId, String stepIdMark);


    void setTaskPartFinish(Long bizId, Long currentStepId, Integer status);
    void setTaskRefuse(Long bizId, Long currentStepId, Integer status);
    void setTaskRecall(Long taskId, String wfIdCode);

    List<WfDefStep> queryCurrentTaskStep(@Param("wfDefIdCode") String wfDefIdCode, @Param("bizId") Long bizId);

    List<WfDefStep> queryCurrentTaskStep100(@Param("wfDefIdCode") String wfDefIdCode, @Param("bizId") Long bizId);

    int getPlanStatus(Long bizId);

    int getRoleCount(Long userId, String code);

    List<WfRunTask> getPhaseFlowStatus(String flowCode,Long bizId);

    List<WfRunTask> getConnectInformation(String oldShipTeam);

    void updateConnect(String oldShipTeam);

    int isExistsStep(String stepMarker, Long currentStepId, Long bizId);
    int isExistsRunningStep(String stepMarker, Long currentStepId, Long bizId);

    void setReStartStatus(String wfIdCode, Long bizId);

    List<WfRunTask> getFlowTrack(String flowCode, Long bizId);

    String getFlowStepName(@Param("wfIdCodes") String wfIdCodes, @Param("bizId") Long bizId);

    void setTaskPartFinish2(@Param("bizId") Long bizId, @Param("receiveId") Long receiveId, @Param("status") Integer status);

    void setTaskPartFinish3(Long bizId, Long receiveDeptId, Integer status);

    void deleteFlowStep(@Param("wfIdCode") String wfIdCode, @Param("stepIdMark") String stepIdMark, @Param("bizId") Long bizId);

    List<FlowInfo> getRunFlow(Map<String, Object> params);
}