package cn.autoform.web.service.process.impl;

import cn.autoform.bean.ProcessState;
import cn.autoform.bean.page.PageResult;
import cn.autoform.db.entity.ProcessLog;
import cn.autoform.db.entity.ProcessTask;
import cn.autoform.fw.exception.FormClientException;
import cn.autoform.util.thread.Keys;
import cn.autoform.util.thread.ThreadData;
import cn.autoform.util.tool.JSONTool;
import cn.autoform.util.tool.PageUtil;
import cn.autoform.web.client.FormClient;
import cn.autoform.web.client.WorkflowClient;
import cn.autoform.web.client.util.WorkflowTool;
import cn.autoform.web.mapper.formset.FormSetMapper;
import cn.autoform.web.mapper.process.ProcessLogMapper;
import cn.autoform.web.service.process.ProcessLogService;
import lombok.extern.slf4j.Slf4j;
import net.sf.json.JSONObject;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;
import java.util.*;
import java.util.concurrent.TimeoutException;

import static cn.autoform.bean.system.PrivateRestConst.USER_NAME;

@Slf4j
@Service("processLogServiceImpl")
public class ProcessLogServiceImpl implements ProcessLogService{

	@Resource
	private ProcessLogMapper processLogMapper;

	@Resource
	private FormClient client;

	@Resource
	private FormSetMapper formSetMapper;

	@Autowired
	private WorkflowClient workflowClient;

	@Autowired
	private WorkflowTool workflowTool;

	/**
	 * 当前待办信息key
	 */
	private static  final String PROCESSINFORMATION = "processInformation";

	/**
	 *
	 * @param map
	 * @param dataType 10:审批，20:退回,30:办理中,40:办理完成
	 * @return
	 * @throws TimeoutException
	 */
	@Override
	public Integer addProcessLog(Map<String,Object> map,String dataType, String activityDefName) throws TimeoutException {
		log.debug("开始添加流程日志---本次添加状态为:"+dataType);
		String formID = Objects.toString(map.get("formID"));
		Integer dataRowNum = Integer.parseInt(Objects.toString(map.get("dataRowNum")));
		String tenantID = Objects.toString(map.get("tenantID"));
		String processIntsId = Objects.toString(map.get("processInstId"));
		ProcessLog processLog = new ProcessLog(formID
				, dataRowNum
				, tenantID
				, processIntsId
				, ThreadData.get(Keys.COMPANY_ID)
				, ThreadData.get(Keys.OPEN_ID));
		processLog.setCreateUser(client.getUserName(formID, tenantID, dataRowNum));
        processLog.setDataType(dataType);
        processLog.init();
        processLog.setActivityDefName(activityDefName);
		if(Objects.equals("30",dataType)){
			processLog.setActivityDefName(getLastLogName(processIntsId));
			//办理中log
			processLog.setFormName(getFormName(formID,tenantID));
			processLog.setNumberForm(getNumber(formID,dataRowNum,tenantID));
			processLog.setExecuteTime(new Date());
			processLogMapper.updateState(processLog);
		}else{
			//修改原有退回审批得数据状态
			processLogMapper.updateState(processLog);
			//执行，退回log,取出当前活动
			ProcessTask processTask = getProcessTask(processIntsId,Objects.toString(map.get("activityInstId")));
			System.out.println("需要得待办:"+ JSONTool.toJson(processTask));
			if(processTask == null){
				System.out.println("添加日志失败:");
				return 0;
			}
			processLog.setFormName(processTask.getProcessChName());
			processLog.setNumberForm(processTask.getProcessInstName());
			processLog.setBacklogStartTime(processTask.getProcessInstStartTime());
			processLog.setBacklogArriveTime(processTask.getStartTime());
			processLog.setIsOvertime(processTask.getIsTimeOut());
			processLog.setActivityDefName(processTask.getActivityInstName());
		}
		processLog.setInsP(ThreadData.get(Keys.USER_NAME));
		processLogMapper.addProcessLog(processLog);
		log.debug("流程日志参数:"+ JSONTool.toJson(processLog));
		log.debug("本次添加流程日志id:"+processLog.getId());
		return processLog.getId();
	}

	@Override
	public Integer updateState(ProcessLog processLog) {
		log.debug("删除重复流程日志:"+ JSONTool.toJson(processLog));
		return processLogMapper.updateState(processLog);
	}

	@Override
	public PageResult<ProcessLog> selectPage(ProcessLog processLog) {
		processLog.setOpenId(ThreadData.get(Keys.OPEN_ID));
		processLog.setCompanyId(ThreadData.get(Keys.COMPANY_ID));
		processLog.setTenantID(ThreadData.get(Keys.TENANT_ID));
		PageUtil.initPage();
		PageResult<ProcessLog> page = new PageResult<>(
				processLogMapper.selectPage(processLog)
		);

		return page;
	}

	@Override
	public Integer delProcessLog(Integer id) {
		log.debug("错误流程日志id为:"+id );
		return processLogMapper.delProcessLog(id);
	}

	@Override
	public Integer updateDataType(ProcessLog processLog) {
		log.debug("修改办理完成流程日志:"+ JSONTool.toJson(processLog));

		return processLogMapper.updateDataType(processLog);
	}


	public int getPages(int a,int b){
		if(a%b>0){
			return a/b+1;
		}else{
			return a/b;
		}
	}

	//取出表单的自动生成编号
	public String getNumber(String formID,Integer dataRowNum,String tenantID) throws TimeoutException, FormClientException {

		ProcessState pro = new ProcessState(formID,dataRowNum,tenantID);
		//取出当前流程大状态
		ProcessState p = client.selectState(pro);
		return p.getNumber();
	}

	//取出表单名称
	public String getFormName(String formID,String tenantID){
		return formSetMapper.selectBuss(formID,tenantID);
	}

	public String getLastLogName(String processIntsId) throws TimeoutException {
		JSONObject jso = new JSONObject();
		jso.put("processInstId", processIntsId);
		Map<String, Object> result = workflowClient.instLog(workflowTool.getProcess(jso));
		List<Map> data = Optional.ofNullable(result)
				.map(d->d.get("data"))
				.map(d->(Map)d)
				.map(d->d.get("data"))
				.map(d->(List)d)
				.orElse(Collections.EMPTY_LIST);
		log.debug("查询log:{}", JSONTool.toJson(data));
		if(data.size() < 1){
			return "";
		}
		return Objects.toString(data.get(data.size()-1).get("activityDefName"));
	}

	/**
	 * 取出当前待办
	 */
	public ProcessTask getProcessTask(String processIntsId,String activityInstId) throws TimeoutException {
		JSONObject jso = new JSONObject();
		jso.put("processInstId", processIntsId);
		Map<String, Object> result = workflowClient.instSeacheHandle(workflowTool.getProcess(jso));
		System.out.println("待办:"+JSONTool.toJson(result));
		Map<String,Object> res = JSONTool.toObj(JSONTool.toJson(result.get("data")),Map.class);
		List<ProcessTask> list = null;
		System.out.println("data取出1:"+ JSONTool.toJson(res));
		if(res.get("data")!=null) {
			list = JSONTool.toList(JSONTool.toJson(res.get("data")), ProcessTask.class);
			System.out.println("转换实体后:"+ JSONTool.toJson(list));
		}else{
			return null;
		}
		System.out.println("当前:"+activityInstId);
		return list.stream()
				.filter(fi-> Objects.equals(fi.getActivityInstId(),activityInstId))
					.findFirst().orElse(null);
	}
}