package cn.stylefeng.guns.workflow.modular.service.impl;

import cn.stylefeng.guns.base.auth.context.LoginContextHolder;
import cn.stylefeng.guns.base.pojo.page.LayuiPageFactory;
import cn.stylefeng.guns.base.pojo.page.LayuiPageInfo;
import cn.stylefeng.guns.workflow.core.util.TimeCalcUtil;
import cn.stylefeng.guns.workflow.modular.entity.RuTask;
import cn.stylefeng.guns.workflow.modular.mapper.TaskHistoryMapper;
import cn.stylefeng.guns.workflow.modular.mapper.TaskRunningMapper;
import cn.stylefeng.guns.workflow.modular.service.TaskHistoryService;
import cn.stylefeng.guns.workflow.modular.service.TaskWaitingService;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import org.activiti.bpmn.model.BpmnModel;
import org.activiti.bpmn.model.FlowNode;
import org.activiti.engine.HistoryService;
import org.activiti.engine.RepositoryService;
import org.activiti.engine.history.HistoricActivityInstance;
import org.activiti.engine.history.HistoricProcessInstance;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

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

/**
 * 历史任务
 *
 * @author fengshuonan
 * @Date 2019-08-28 17:54
 */
@Service
public class TaskHistoryServiceImpl extends ServiceImpl<TaskRunningMapper, RuTask> implements TaskHistoryService {

    @Autowired
    private TaskHistoryMapper ruprocdefMapper;

    @Autowired
    private HistoryService historyService;

    @Autowired
    private RepositoryService repositoryService;

    @Autowired
    private TaskWaitingService taskService;

    @Override
    public LayuiPageInfo historyTaskListPage(Map<String, Object> map) {

        map.put("username", LoginContextHolder.getContext().getUser().getAccount());

        String userRoleString = taskService.getUserRoleString();

        map.put("rnumbers", userRoleString);

        Page pageContext = LayuiPageFactory.defaultPage();
        List<Map<String, Object>> list = this.baseMapper.hitasklist(pageContext, map);

        for (int i = 0; i < list.size(); i++) {
            Long ztime = Long.parseLong(list.get(i).get("duration_").toString());
            list.get(i).put("ztime", TimeCalcUtil.calc(ztime));

            //流程申请人
            list.get(i).put("initator", getInitiator(String.valueOf(list.get(i).get("proc_inst_id_"))));
        }

        pageContext.setRecords(list);
        return LayuiPageFactory.createPageInfo(pageContext);
    }

    @Override
    public List<Map<String, Object>> historyTaskList(String procInstId) {
        return ruprocdefMapper.historyTaskList(procInstId);
    }

    /**
     * 获取发起人
     *
     * @author fengshuonan
     * @Date 2019-8-23 17:37
     */
    private String getInitiator(String procInstId) {

        //获取历史流程实例
        HistoricProcessInstance hip = historyService.createHistoricProcessInstanceQuery().processInstanceId(procInstId).singleResult();
        List<HistoricActivityInstance> hais = historyService.createHistoricActivityInstanceQuery().processInstanceId(procInstId)

                //获取流程中已经执行的节点，按照执行先后顺序排序
                .orderByHistoricActivityInstanceId().asc().list();

        // 获取bpmnModel
        BpmnModel bpmnModel = repositoryService.getBpmnModel(hip.getProcessDefinitionId());

        //全部活动实例
        List<FlowNode> historicFlowNodeList = new LinkedList<FlowNode>();
        for (HistoricActivityInstance hai : hais) {
            historicFlowNodeList.add((FlowNode) bpmnModel.getMainProcess().getFlowElement(hai.getActivityId(), true));
            if (hai.getAssignee() != null) {

                //不为空的第一个节点办理人就是发起人
                return hai.getAssignee();
            }
        }

        return null;
    }
}