package com.jeesite.modules.util;

import com.jeesite.common.entity.Page;
import com.jeesite.common.lang.StringUtils;
import com.jeesite.common.service.ServiceException;
import com.jeesite.common.web.http.ServletUtils;
import com.jeesite.modules.bpm.entity.BpmTask;
import com.jeesite.modules.bpm.service.BpmTaskService;
import com.jeesite.modules.bpm.utils.BpmUtils;
import com.jeesite.modules.msg.entity.content.PcMsgContent;
import com.jeesite.modules.msg.utils.MsgPushUtils;
import org.flowable.engine.impl.persistence.entity.ExecutionEntityImpl;
import org.springframework.stereotype.Component;

import java.util.List;

/**
 * bpm流程消息提醒工具类
 *
 * @author ya_jun
 */
@Component
public class BpmMsgUtil {

    /**
     * 给某人发消息提醒
     */
    public static void remindSomeBody(ExecutionEntityImpl execution) {
        // ExecutionEntityImpl是DelegateExecution的实现类
        BpmTask task = getBpmTask(getBusinessKey(execution));
        String nextUserCodes = ServletUtils.getParameter("nextUserCodes");
        for (String userCode : nextUserCodes.split(",")) {
            PcMsgContent msgContent = new PcMsgContent();
            msgContent.setTitle("提示信息");
            msgContent.setContent("您有1条新的任务被退回");
            msgContent.addButton("去办理", "/a/pro/approval/index?procIns.name=" + task.getProcIns().getName());
            // 即时推送消息
            MsgPushUtils.push(msgContent, getBizKey(execution), "bpm_msg", userCode);
        }
    }

    /**
     * 获取businessKey，格式：fornKey:bizKey
     *
     * @param execution
     * @return
     */
    private static String getBusinessKey(ExecutionEntityImpl execution) {
        String businessKey = execution.getProcessInstance().getBusinessKey();
        return businessKey;
    }

    private static String getBizKey(ExecutionEntityImpl execution) {
        String[] split = getBusinessKey(execution).split(":");
        return split[1];
    }

    /**
     * 根据businessKey查询流程任务，businessKey格式为：formKey:bizKey
     *
     * @param businessKey
     * @return
     */
    public static BpmTask getBpmTask(String businessKey) {
        if (StringUtils.isBlank(businessKey)) {
            throw new ServiceException("businessKey不可为空！");
        }
        BpmTask bpmTask = new BpmTask();
        bpmTask.setStatus(BpmTask.STATUS_UNFINISHED);
        bpmTask.getProcIns().setBusinessKey(businessKey);
        BpmTaskService bpmTaskService = BpmUtils.getBpmTaskService();
        Page<BpmTask> taskPage = bpmTaskService.findTaskPage(bpmTask);

        List<BpmTask> taskPageList = taskPage.getList();
        // 按照businesskey查询，应该只查询到一条数据
        if (taskPageList != null && taskPageList.size() != 1) {
            return null;
        }
        BpmTask task = taskPageList.get(0);
        return task;
    }

}