/*
 *      Copyright (c) 2018-2028, Chill Zhuang All rights reserved.
 *
 *  Redistribution and use in source and binary forms, with or without
 *  modification, are permitted provided that the following conditions are met:
 *
 *  Redistributions of source code must retain the above copyright notice,
 *  this list of conditions and the following disclaimer.
 *  Redistributions in binary form must reproduce the above copyright
 *  notice, this list of conditions and the following disclaimer in the
 *  documentation and/or other materials provided with the distribution.
 *  Neither the name of the dreamlu.net developer nor the names of its
 *  contributors may be used to endorse or promote products derived from
 *  this software without specific prior written permission.
 *  Author: Chill 庄骞 (smallchill@163.com)
 */
package com.vci.ubcs.flow.engine.service.impl;

import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.vci.ubcs.flow.core.dto.FlowTaskDTO;
import com.vci.ubcs.flow.core.entity.FlowTaskUser;
import com.vci.ubcs.flow.core.entity.ProcessTemplate;
import com.vci.ubcs.flow.core.utils.TaskUtil;
import com.vci.ubcs.flow.engine.entity.*;
import com.vci.ubcs.flow.engine.mapper.FlowTaskUserMapper;
import com.vci.ubcs.flow.engine.mapper.ProcessTemplateMapper;
import com.vci.ubcs.flow.engine.service.FlowEngineService;
import com.vci.ubcs.flow.engine.service.FlowTaskUserService;
import lombok.AllArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springblade.core.log.exception.ServiceException;
import org.springblade.core.mp.support.Condition;
import org.springframework.stereotype.Service;

import java.util.*;

/**
 * 工作流服务实现类
 *
 * @author wang1
 */
@Slf4j
@Service
@AllArgsConstructor
public class FlowTaskUserServiceImpl extends ServiceImpl<FlowTaskUserMapper, FlowTaskUser> implements FlowTaskUserService {

	private FlowEngineService flowEngineService;
	private FlowTaskUserMapper flowTaskUserMapper;
	private ProcessTemplateMapper processTemplateMapper;

	/**
	 * 查询当前登陆人对这个流程的taskUser
	 * @param type ProcessTemplateTypeEnum
	 * @return
	 */
	@Override
	public Object getUser(String type,String templateId){
		Map kv = new HashMap();

		//根据type查询top流程数据
		Map<String, Object> m = new HashMap<>();
		m.put("button_type_key", type);
		m.put("template_id", templateId);
		List<ProcessTemplate> processTemplates = processTemplateMapper.selectByMap(m);
 		if(processTemplates.size()==0){
			throw new ServiceException("主题库定义-模板管理-流程模板，没有绑定流程!");
		}
		ProcessTemplate processTemplate = processTemplates.get(0);
		kv.put("flow",processTemplate);


		//top收藏部分数据
		QueryWrapper<FlowTaskUser> queryWrapper = new QueryWrapper<>();
		queryWrapper.eq("CREATED_BY", TaskUtil.getTaskUser());
		List<FlowTaskUser> flowTaskUsers = baseMapper.selectList(queryWrapper);
		List<FlowTaskDTO> cl = new ArrayList<>();

		Map<String,List<FlowTaskUser>> nameMap = new HashMap<>();
		for(FlowTaskUser flowTaskUser:flowTaskUsers){
			String name = flowTaskUser.getName();//收藏名称
			List<FlowTaskUser> flowTaskUserListo = null;
			if(nameMap.get(name)==null){
				flowTaskUserListo = new ArrayList<>();
			}else {
				flowTaskUserListo = nameMap.get(name);
			}
			flowTaskUserListo.add(flowTaskUser);
			nameMap.put(name,flowTaskUserListo);
		}

		for (String name:nameMap.keySet()){
			FlowTaskDTO flowTaskUserCR = new FlowTaskDTO();
			flowTaskUserCR.setName(name);//收藏名称
			flowTaskUserCR.setModelKey(nameMap.get(name).get(0).getModelKey());
			flowTaskUserCR.setModelName(nameMap.get(name).get(0).getModelName());
			flowTaskUserCR.setFlowTaskUsers(nameMap.get(name));
			cl.add(flowTaskUserCR);
		}
		kv.put("collect",cl);

		//数据节点数据
		List<FlowTaskDTO> tl = flowEngineService.getNodeByFlowableKey(processTemplate.getModelKey());
		kv.put("user",tl);
		return kv;
	}

	@Override
	public void saveOrUpdateUser(FlowTaskDTO flowTaskUserC){
		List<FlowTaskUser> flowTaskUsers = flowTaskUserC.getFlowTaskUsers();
		String name = flowTaskUserC.getName();//收藏名称

		//新增情况下验证收藏名称不重复
		Map<String, Object> m = new HashMap<>();
		m.put("name", name);
		m.put("created_by", TaskUtil.getTaskUser());
		QueryWrapper q = Condition.getQueryWrapper(m, FlowTaskUser.class)
			.select("1");
		if(flowTaskUserMapper.selectCount(q)>0){
			throw new ServiceException("收藏名称已经存在!");
		}

		for (FlowTaskUser flowTaskUseri:flowTaskUsers){
			flowTaskUseri.setName(name);
			flowTaskUseri.setCreatedBy(TaskUtil.getTaskUser());
			flowTaskUseri.setTemplateId(flowTaskUserC.getTemplateId());
			flowTaskUseri.setModelKey(flowTaskUserC.getModelKey());
		}
		//新增、修改
		this.saveOrUpdateBatch(flowTaskUsers);

	}


	@Override
	public void deleteUser(String name){
		Map<String, Object> m = new HashMap<>();
		m.put("name", name);
		m.put("created_by", TaskUtil.getTaskUser());
		baseMapper.deleteByMap(m);
	}

	public List<FlowTaskUser> getTaskUserByTemplateAndModelKey(String templateId,String modelKey){
		Map<String, Object> m = new HashMap<>();
		m.put("template_id", templateId);
		m.put("model_key", modelKey);
		return baseMapper.selectByMap(m);
	}
}