package cn.stylefeng.guns.workflow.modular.controller;

import cn.stylefeng.guns.base.auth.context.LoginContextHolder;
import cn.stylefeng.guns.base.pojo.page.LayuiPageInfo;
import cn.stylefeng.guns.workflow.modular.controller.base.ActBaseController;
import cn.stylefeng.guns.workflow.core.cache.TempAssignCache;
import cn.stylefeng.guns.workflow.core.consts.ActConst;
import cn.stylefeng.guns.workflow.core.util.ImageAnd64Binary;
import cn.stylefeng.guns.workflow.core.util.PathUtil;
import cn.stylefeng.guns.workflow.core.util.TimeCalcUtil;
import cn.stylefeng.guns.workflow.modular.model.params.ActHandleDto;
import cn.stylefeng.guns.workflow.modular.model.params.TaskParam;
import cn.stylefeng.guns.workflow.modular.service.ProcessService;
import cn.stylefeng.guns.workflow.modular.service.TaskWaitingService;
import cn.stylefeng.roses.core.util.ToolUtil;
import cn.stylefeng.roses.kernel.model.exception.RequestEmptyException;
import cn.stylefeng.roses.kernel.model.response.ResponseData;
import cn.stylefeng.roses.kernel.model.response.SuccessResponseData;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.ui.Model;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.ResponseBody;

import java.net.URLDecoder;
import java.util.HashMap;
import java.util.LinkedHashMap;
import java.util.List;
import java.util.Map;


/**
 * 待办任务控制器
 *
 * @author fengshuonan
 * @Date 2019-08-19 16:17:40
 */
@Controller
@RequestMapping("/taskWaiting")
@Slf4j
public class TaskWaitingController extends ActBaseController {

    private String PREFIX = "/modular/act/taskWaiting";

    @Autowired
    private TaskWaitingService taskWaitingService;

    @Autowired
    private ProcessService processService;

    /**
     * 跳转到主页面
     *
     * @author fengshuonan
     * @Date 2019-08-19
     */
    @RequestMapping("")
    public String index() {
        return PREFIX + "/taskWaiting.html";
    }

    /**
     * 委派页面
     *
     * @author fengshuonan
     * @Date 2019-08-19
     */
    @RequestMapping("/delegatePage")
    public String delegatePage(@RequestParam("ID_") String id, Model model) {
        if (ToolUtil.isEmpty(id)) {
            throw new RequestEmptyException("id不能为空");
        }
        model.addAttribute("ID_", id);
        return PREFIX + "/delegate.html";
    }

    /**
     * 办理页面
     *
     * @author fengshuonan
     * @Date 2019-08-19
     */
    @RequestMapping("/handlePage")
    public String handlePage(@RequestParam("ID_") String id,
                             @RequestParam("DGRM_RESOURCE_NAME_") String dgrmResourceName,
                             @RequestParam("PROC_INST_ID_") String procInstId,
                             Model model) {

        if (ToolUtil.isEmpty(id) || ToolUtil.isEmpty(procInstId)) {
            throw new RequestEmptyException("id不能为空");
        }

        model.addAttribute("ID_", id);
        model.addAttribute("DGRM_RESOURCE_NAME_", dgrmResourceName);
        model.addAttribute("PROC_INST_ID_", procInstId);

        return PREFIX + "/handle.html";
    }

    /**
     * 委派人员页面
     *
     * @author fengshuonan
     * @Date 2019-08-19
     */
    @RequestMapping("/delegateUserPage")
    public String delegateUserPage(@RequestParam("ID_") String id, Model model) {
        if (ToolUtil.isEmpty(id)) {
            throw new RequestEmptyException("id不能为空");
        }
        model.addAttribute("ID_", id);
        return PREFIX + "/user.html";
    }

    /**
     * 选择办理人
     *
     * @author fengshuonan
     * @Date 2019-8-22 19:01
     */
    @RequestMapping("/selectDealer")
    public String selectDealer() {
        return PREFIX + "/selectDealer.html";
    }

    /**
     * 选择角色
     *
     * @author fengshuonan
     * @Date 2019-8-22 19:01
     */
    @RequestMapping("/selectRole")
    public String selectRole() {
        return PREFIX + "/selectRole.html";
    }

    /**
     * 待办任务查询列表
     *
     * @author fengshuonan
     * @Date 2019-08-20
     */
    @ResponseBody
    @RequestMapping("/list")
    public LayuiPageInfo list(TaskParam taskParam) {

        LayuiPageInfo pageBySpec = this.taskWaitingService.findPageBySpec(taskParam);

        //添加流程申请人
        if (ToolUtil.isNotEmpty(pageBySpec.getData())) {
            List<Map<String, Object>> maps = pageBySpec.getData();
            for (int i = 0; i < maps.size(); i++) {
                maps.get(i).put("initator", getInitiator((String) maps.get(i).get("proc_inst_id_")));
            }
        }

        return pageBySpec;
    }


    /**
     * 办理任务
     *
     * @author fengshuonan
     * @Date 2019-08-21
     */
    @RequestMapping(value = "/handle")
    @ResponseBody
    public ResponseData handle(ActHandleDto actHandleDto) {

        //任务ID
        String taskId = actHandleDto.getID_();

        //审批结果
        String sfrom = "";
        Object ofrom = getVariablesByTaskIdAsMap(taskId, "审批结果");
        if (null != ofrom) {
            sfrom = ofrom.toString();
        }

        Map<String, Object> map = new LinkedHashMap<>();

        //审批结果+审批人的姓名+审批意见
        String opinion = sfrom + LoginContextHolder.getContext().getUser().getName() + "," + actHandleDto.getOPINION();

        String msg = actHandleDto.getMsg();

        //批准
        if ("yes".equals(msg)) {

            //审批结果
            map.put("审批结果", "【批准】" + opinion);

            //设置流程变量
            setVariablesByTaskIdAsMap(taskId, map);
            setVariablesByTaskId(taskId, "RESULT", "批准");
            completeMyPersonalTask(taskId);
        } else {

            //驳回
            map.put("审批结果", "【驳回】" + opinion);

            //设置流程变量
            setVariablesByTaskIdAsMap(taskId, map);
            setVariablesByTaskId(taskId, "RESULT", "驳回");
            completeMyPersonalTask(taskId);
        }

        try {
            //移除流程变量(从正在运行中)
            removeVariablesByPROC_INST_ID_(actHandleDto.getPROC_INST_ID_(), "RESULT");
        } catch (Exception e) {
            log.error("移除流程变量错误，此流程变量在历史中", e);
        }

        try {
            //下一待办对象
            String assignee = actHandleDto.getASSIGNEE_();
            if (ToolUtil.isNotEmpty(assignee)) {

                //指定下一任务待办对象
                setAssignee(TempAssignCache.get(), assignee);
            }
        } catch (Exception e) {
            //手动指定下一待办人，才会触发此异常
            //任务结束不需要指定下一步办理人了,发送站内信通知任务发起人
            log.error("指定下一代办人错误", e);
        }

        return new SuccessResponseData();
    }

    /**
     * 去办理任务页面获取数据
     *
     * @author fengshuonan
     * @Date 2019-08-28 13:46
     */
    @RequestMapping(value = "/getHandleData")
    @ResponseBody
    public ResponseData getHandleData(@RequestParam("fileName") String fileName,
                                      @RequestParam("id") String id,
                                      @RequestParam("procInstId") String procInstId) throws Exception {

        if (ToolUtil.isEmpty(id) || ToolUtil.isEmpty(procInstId)) {
            throw new RequestEmptyException("id或procInstId不能为空");
        }
        Map<String, Object> map = new HashMap<>();
        String errInfo = "success";

        //列出流程变量列表
        Map<String, Object> varList = processService.varList(procInstId);

        //历史任务节点列表
        List<Map<String, Object>> hitaskList = processService.hitoryTaskList(procInstId);

        //根据耗时的毫秒数计算天时分秒
        for (int i = 0; i < hitaskList.size(); i++) {
            if (null != hitaskList.get(i).get("duration_")) {
                Long ztime = Long.parseLong(hitaskList.get(i).get("duration_").toString());
                hitaskList.get(i).put("ztime", TimeCalcUtil.calc(ztime));
            }
        }

        String filename = URLDecoder.decode(fileName, "UTF-8");

        //生成当前任务节点的流程图片
        createXmlAndPngAtNowTask(procInstId, filename);
        String imgSrcPath = PathUtil.getProjectpath() + ActConst.FILEACTIVITI + filename;

        //解决图片src中文乱码，把图片转成base64格式显示
        map.put("imgSrc", "data:image/jpeg;base64," + ImageAnd64Binary.getImageStr(imgSrcPath));

        //流程变量列表
        map.put("varList", varList);

        //审批记录表格
        map.put("hitaskList", hitaskList);

        //返回结果
        map.put("result", errInfo);

        return ResponseData.success(map);
    }

}