package com.slcf.service.impl;

import java.io.File;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Collections;
import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.zip.ZipInputStream;

import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;

import org.activiti.bpmn.model.BpmnModel;
import org.activiti.engine.ProcessEngine;
import org.activiti.engine.RepositoryService;
import org.activiti.engine.RuntimeService;
import org.activiti.engine.TaskService;
import org.activiti.engine.impl.persistence.entity.ProcessDefinitionEntity;
import org.activiti.engine.impl.pvm.PvmTransition;
import org.activiti.engine.impl.pvm.process.ActivityImpl;
import org.activiti.engine.repository.Deployment;
import org.activiti.engine.repository.DeploymentBuilder;
import org.activiti.engine.repository.ProcessDefinition;
import org.activiti.engine.repository.ProcessDefinitionQuery;
import org.activiti.engine.runtime.ProcessInstance;
import org.activiti.engine.task.Task;
import org.activiti.image.impl.DefaultProcessDiagramGenerator;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.web.multipart.MultipartFile;

import com.slcf.dao.ActivitiDao;
import com.slcf.pojo.BillNote;
import com.slcf.pojo.DefinitionBean;
import com.slcf.pojo.PersonTask;
import com.slcf.pojo.UserBean;
import com.slcf.service.ActivitiService;

@Service
public class ActivitiServiceImpl implements ActivitiService {

	@Autowired
	ActivitiDao activitiDao;
	
	/**
	 * 添加请假单,并启动流程
	 * @param note
	 * @return
	 */
//	@Override
	public int saveBill(BillNote note,RuntimeService runtimeService,HttpServletRequest request) {
		//获取申请人名称
		String name=(String)request.getSession().getAttribute("NAME");
		String account=(String)request.getSession().getAttribute("ACCOUNT");
		Integer idStr=(Integer)request.getSession().getAttribute("ID");
		note.setStatus("初始录入");
		note.setName(name);
		note.setUser_id(idStr);
		
		int i=activitiDao.saveBill(note);
		if(i>0){
			BillNote newNote=activitiDao.singleResult(idStr);
			Map<String, Object> variables = new HashMap<String,Object>();
			String objId=newNote.getClass().getSimpleName()+"."+newNote.getBill_id();
			String key=newNote.getClass().getSimpleName();
			System.out.println(key);
			//流程变量  指派下一节点任务人
			variables.put("user", account);//用登陆账号表示惟一用户
			variables.put("objId", objId);
			runtimeService.startProcessInstanceByKey(key, objId,variables);//启动
		}
		return i;
	}

	
	/**
	 * 部署流程定义
	 * @param fileName
	 * @param file
	 * @param processEngine
	 * @return
	 */
//	@Override
	public boolean saveAct(String fileName, MultipartFile file, ProcessEngine processEngine) {
		boolean flag=false;
		//ZipInputStream zipInputStream;
		//1)     部署，也是往数据库中存储流程定义的过程。
		//2)     这一步在数据库中将操作三张表：
		//　　　　a) act_re_deployment
		// 　　　　 存放流程定义的显示名和部署时间，每部署一次增加一条记录
		//　　　   b) act_re_procdef
		// 　　　　 存放流程定义的属性信息，部署每个新的流程定义都会在这张表中增加一条记录。
		//　　　   c) act_ge_bytearray
		DeploymentBuilder deploymentBuilder = processEngine.getRepositoryService().createDeployment();
		ZipInputStream zipInputStream;
		try {
			zipInputStream = new ZipInputStream(file.getInputStream());
			deploymentBuilder.addZipInputStream(zipInputStream);
			Deployment deployment=deploymentBuilder.deploy();
			System.out.println(deployment.getId());
		} catch (IOException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
			flag=true;
		return flag;
	}


	/**
	 * 查看流程定义
	 * @param pageNumber
	 * @param pageSize
	 * @return
	 */
//	@Override
	public Map<String, Object> queryProcessDefinition(int pageNumber, int pageSize,RepositoryService repositoryService) {
		Map<String,Object> map=new HashMap<String,Object>();
		SimpleDateFormat s=new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
		List<DefinitionBean> list=new ArrayList<DefinitionBean>();
		// 获取流程定义查询对象
		ProcessDefinitionQuery  processDefinitionQuery=repositoryService.createProcessDefinitionQuery();
		
		// 配置查询对象
		  processDefinitionQuery
		      //添加过滤条件
//		     .processDefinitionName(processDefinitionName)
//		     .processDefinitionId(processDefinitionId)
//		     .processDefinitionKey(processDefinitionKey)
		     //分页条件
//		     .listPage(firstResult, maxResults)
		      //排序条件
		     .orderByProcessDefinitionVersion().desc();
		  
		  //执行查询
		  List<ProcessDefinition> pds = processDefinitionQuery.listPage((pageNumber-1)*pageSize, pageNumber*pageSize);
		  Long count=processDefinitionQuery.count();
		  for (ProcessDefinition processDefinition : pds) {
			  
			  // 流程定义的key+版本+随机生成数
			  System.out.println("流程定义ID:" + processDefinition.getId());
			  // 对应hello.bpmn文件中的name属性值
			  System.out.println("流程定义的名称:" + processDefinition.getName());
			  // 对应hello.bpmn文件中的id属性值
			  System.out.println("流程定义的key:" + processDefinition.getKey());
			  // 当流程定义的key值相同的相同下，版本升级，默认1
			  System.out.println("流程定义的版本:" + processDefinition.getVersion());
			  System.out.println("资源名称bpmn文件:" + processDefinition.getResourceName());
			  System.out.println("资源名称png文件:" + processDefinition.getDiagramResourceName());
			  System.out.println("部署对象ID：" + processDefinition.getDeploymentId());
			   
			  DefinitionBean definitionBean = new DefinitionBean();
              Deployment singleResult = repositoryService.createDeploymentQuery().deploymentId(processDefinition.getDeploymentId()).singleResult();
              definitionBean.setId(processDefinition.getId());
              definitionBean.setKey(processDefinition.getKey());
              definitionBean.setPro_defi_name(processDefinition.getName());
              definitionBean.setPro_devl_name(singleResult.getName());
              definitionBean.setPro_devl_time(s.format(singleResult.getDeploymentTime()));
              definitionBean.setVersion(processDefinition.getVersion()+"");
              definitionBean.setDeployment_id(processDefinition.getDeploymentId());
              definitionBean.setResourcename(processDefinition.getDiagramResourceName());
			   list.add(definitionBean);
			  }
		  map.put("rows", list);
		  map.put("total", count);
		  return map;
	}


	/**
	 * 查看流程图
	 */
//	@Override
	public Map<String, Object> getImg(String deployment_id, HttpServletResponse response, HttpServletRequest request,
			RepositoryService repositoryService) {

		//根据流程部署id 获取流程定义查询对象
		ProcessDefinition processDefinition=repositoryService.createProcessDefinitionQuery().deploymentId(deployment_id).singleResult();
		//根据流程部署id和png文件名称查询
		InputStream in=repositoryService.getResourceAsStream(deployment_id, processDefinition.getDiagramResourceName());
		
      // 获取项目所在服务器的路径
	  String path = request.getSession().getServletContext().getRealPath("/");
	  System.out.println(path);
	  // 获取服务器的webapps文件夹
	  String newpath = new File(path).getParent() + "/activitiImgs/";
	  System.out.println(newpath);
	  // 获取上文件名
	  String newfilename = processDefinition.getDiagramResourceName();
	  String uploadpath = newpath + newfilename;
	  // 判断上传文件夹是否存在
	  // 如果上传文件夹不存在
	  File ff = new File(uploadpath);
	  if (!ff.getParentFile().exists()) {
		  // 创建applicants文件夹
		  ff.getParentFile().mkdirs();
	  	}
	  File end = new File(uploadpath);
		if(in!=null){
			byte[] bt = new byte[1024];
			int len=-1;
			try {
				FileOutputStream fo = new FileOutputStream(end);
				while((len=(in.read(bt))) != -1) {
					fo.write(bt,0,len); 
					}
				fo.flush();
				fo.close();
				in.close();
			} catch (IOException e) {
				e.printStackTrace();
			}
		}
		Map<String,Object>map=new HashMap<String,Object>();
		map.put("msg", "../activitiImgs/"+newfilename);
		return map;
	}


	/**
	 * 根据用户id查询用户请假单
	 * @param request
	 * @param pageNumber
	 * @param pageSize
	 * @return
	 */
//	@Override
	public Map<String, Object> getMyReq(HttpServletRequest request, int pageNumber, int pageSize,
			TaskService taskService,RuntimeService runtimeService) {
		
		Integer idStr=(Integer)request.getSession().getAttribute("ID");
		String account=(String)request.getSession().getAttribute("ACCOUNT");
		
		List<BillNote>list=activitiDao.getMyReq(idStr, (pageNumber-1)*pageSize, pageNumber*pageSize);
		int count =activitiDao.getCountByUserId(idStr);
		
		List<org.activiti.engine.task.Task>taskList=taskService.createTaskQuery().taskAssignee(account).list();
		for(BillNote b:list){
			for(org.activiti.engine.task.Task t:taskList){
			//流程实例id
			String processInstanceId=t.getProcessInstanceId();
			ProcessInstance processInstance=runtimeService.createProcessInstanceQuery().processInstanceId(processInstanceId).singleResult();
			String businessKey=processInstance.getBusinessKey();
			String[] s=businessKey.split("\\.");
			int billId=Integer.parseInt(s[1]);
			if(b.getBill_id().equals(billId)){
				b.setTaskId(t.getId());
				continue;
			}else{
				continue;
			}
			}
		}
		Map<String,Object>map=new HashMap<String,Object>();
		map.put("total", count);
		map.put("rows", list);
		return map;
	}


	/**
	 * 提交请假单
	 * @param taskId
	 * @param bid
	 * @return
	 */
//	@Override
	public boolean submitMyReq(String taskId, int bid,TaskService taskService,HttpServletRequest request) {
		boolean flag=false;
		Integer uid=(Integer)request.getSession().getAttribute("ID");
		String account=(String)request.getSession().getAttribute("ACCOUNT");
		int i=activitiDao.upBill("审核中", bid);
		if(i>0){
			
			Map<String,Object>map=new HashMap<String,Object>();
			//查询用户所在部门的部门经理
			UserBean user=activitiDao.queryUserSingleResult(activitiDao.queryDeptId(uid));
			if(user!=null){//如果有部门经理就指派经理
				map.put("deptMag", user.getUser_account());
			}else{//如果没有部门经理就指自己
				map.put("deptMag",account);
			}
			taskService.complete(taskId,map);//完成任务，指派下一任务人variables
			flag=true;
		}
		return flag;
	}


//	@Override
	public Map<String, Object> delMyReq( int bid,RuntimeService runtimeService) {
				Map<String,Object>map=new HashMap<String,Object>();
		boolean flag=false;
		BillNote note=activitiDao.queryBillById(bid);
		if(note.getStatus().equals("初始录入")||note.getStatus().equals("审核完成")||note.getStatus().contains("驳回")){
				flag=true;
				if(note.getStatus().equals("初始录入")||note.getStatus().contains("驳回")){
					String processInstanceBusinessKey=activitiDao.queryBillById(bid).getClass().getSimpleName()+"."+bid;
					String processInstanceId =runtimeService.createProcessInstanceQuery().processInstanceBusinessKey(processInstanceBusinessKey).singleResult().getProcessInstanceId();
					runtimeService.deleteProcessInstance(processInstanceId, "删除原因");//删除一个流程实例
				}
				activitiDao.delBillById(bid);
		}else{
			map.put("msg", "正在审核中，您无法删除");
		}
		map.put("flag", flag);
		return map;
	}

//	@Override
	public Map<String, Object> getMyTask(TaskService taskService,HttpServletRequest request,int pageNumber,int pageSize) {
		String account=(String)request.getSession().getAttribute("ACCOUNT");
		List<Task>list=taskService.createTaskQuery().taskAssignee(account).listPage((pageNumber-1)*pageSize, pageNumber*pageSize);
		Long count=taskService.createTaskQuery().taskAssignee(account).count();
		List<PersonTask>taskList=new ArrayList<PersonTask>();
		for(Task t:list){
			
			PersonTask task=new PersonTask();
			task.setId(t.getId());
			task.setName(t.getName());
			task.setAssignee(t.getAssignee());
			SimpleDateFormat sm=new SimpleDateFormat("yyyy-MM-dd hh:mm:ss");
			task.setCreatetime(sm.format(t.getCreateTime()));
			task.setExcutionId(t.getExecutionId());
			task.setProcessDefinitionId(t.getProcessDefinitionId());
			task.setProcessInstanceId(t.getProcessInstanceId());
			taskList.add(task);
		}
		Map<String,Object>map=new HashMap<String,Object>();
		map.put("total", count);
		map.put("rows", taskList);
		return map;
	}


//	@Override
	public Map<String, Object> getDetailTask(RepositoryService repositoryService,RuntimeService runtimeService,TaskService taskService,String taskId) {
		List<String> list =new ArrayList<String>();
		
		Task task=taskService.createTaskQuery().taskId(taskId).singleResult();
		String processInstanceId=task.getProcessInstanceId();
		ProcessInstance processInstance=runtimeService.createProcessInstanceQuery().processInstanceId(processInstanceId).singleResult();
		String businessKey=processInstance.getBusinessKey();
		String strs[]=businessKey.split("\\.");
		//请假人信息
		BillNote note=activitiDao.queryBillById(Integer.parseInt(strs[1]));
		String activityId=processInstance.getActivityId();
		ProcessDefinitionEntity processDefinitionEntity = (ProcessDefinitionEntity) repositoryService.getProcessDefinition(task.getProcessDefinitionId());
		 //当前活动对象
		  ActivityImpl activityImpl = processDefinitionEntity.findActivity(activityId);
		  // 通过活动对象找当前活动的所有出口
	       List<PvmTransition> transitions =  activityImpl.getOutgoingTransitions();
	    // 提取所有出口的名称，封装成集合
	       // 提取所有出口的名称，封装成集合
	         for (PvmTransition trans : transitions) {
	             String transName = (String) trans.getProperty("name");
	             if(StringUtils.isNotBlank(transName)){
	            	 list.add(transName);
	             }
	        }
	         if(list.size()==0){
	        	 list.add("批准");//默认
	         }
	         Map<String,Object>valmap=new HashMap<String, Object>();
	         valmap.put("note", note);
	         valmap.put("list", list);
	         return valmap;
	}


//	@Override
	public boolean magDelTask(String buttonValue,String taskId, String comments, RuntimeService runtimeService, TaskService taskService,
			HttpServletRequest request) {
		String userName=(String)request.getSession().getAttribute("NAME");
		
		boolean flag=false;
		String msg="";
		if(buttonValue.equals("批准")){
			if(userName.equals(activitiDao.getAdmin().getUser_name())){
				msg="审核完成";
			}else if(userName.equals(activitiDao.getPersonel().getUser_name())){
				msg="审核完成";
			}else{
				msg="部门经理已批准";
			}
		}else{
			if(userName.equals(activitiDao.getAdmin().getUser_name())){
				msg="总经理已驳回";
			}else if(userName.equals(activitiDao.getPersonel().getUser_name())){
				msg="人事经理已驳回";
			}else{
				msg="部门经理已驳回";
			}
		}
		Task task=taskService.createTaskQuery().taskId(taskId).singleResult();
		//流程实例id
		String processInstanceId=task.getProcessInstanceId();
		//任务ID，根据流程实例ID，评论的消息，保存申请的评论信息
		taskService.addComment(taskId, processInstanceId, comments);
		ProcessInstance processInstance=runtimeService.createProcessInstanceQuery().processInstanceId(processInstanceId).singleResult();
		String businessKey=processInstance.getBusinessKey();
		String strs[]=businessKey.split("\\.");
		BillNote note=activitiDao.queryBillById(Integer.parseInt(strs[1]));
		int i=activitiDao.upBillByTask(userName, Integer.parseInt(strs[1]), msg);
		if(i>0){
			flag=true;
		}
		Map<String,Object> variables=new HashMap<String,Object>();
		Date date1=null,date2=null;
		try {
			date1 = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").parse(note.getStartTime());
			date2 = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").parse(note.getEndTime());
			//日期相减得到相差的日期
			long day = 1+(date1.getTime()-date2.getTime())/(24*60*60*1000)>0 ? (date1.getTime()-date2.getTime())/(24*60*60*1000):(date2.getTime()-date1.getTime())/(24*60*60*1000);
			variables.put("days", day);
			if(day<=3){//人事经理
				variables.put("personnel", activitiDao.getPersonel().getUser_account());
			}else{//总经理
				variables.put("admins", activitiDao.getAdmin().getUser_account());
			}
		} catch (java.text.ParseException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		variables.put("outcome", buttonValue);
		taskService.complete(taskId, variables);
		return flag;
	}


//	@Override
	public InputStream getProcessPic(String procDefId,RepositoryService repositoryService) {

		ProcessDefinition procDef = repositoryService.createProcessDefinitionQuery().processDefinitionId(procDefId).singleResult();
		String diagramResourceName = procDef.getDiagramResourceName();
		InputStream inputStream = repositoryService.getResourceAsStream(procDef.getDeploymentId(), diagramResourceName);
		return inputStream;
	
	}


//	@Override
	public InputStream getDiagram(String processInstanceId,RuntimeService runtimeService,RepositoryService repositoryService) {

		// 查询流程实例
		ProcessInstance pi = runtimeService.createProcessInstanceQuery().processInstanceId(processInstanceId).singleResult();
		BpmnModel bpmnModel = repositoryService.getBpmnModel(pi.getProcessDefinitionId());
		// 得到正在执行的环节
		List<String> activeIds = runtimeService.getActiveActivityIds(pi.getId());
		InputStream is = new DefaultProcessDiagramGenerator().generateDiagram(bpmnModel, "png", activeIds, Collections.<String> emptyList(),"黑体", "黑体", null,null, 1.0);
		return is;
	
	}


//	@Override
	public Map<String, Object> outProcessPic(InputStream inputStream, HttpServletRequest request, String bid) {

		Map<String,Object>map=new HashMap<String, Object>();
		
		// 获取项目所在服务器的路径
		  String path = request.getSession().getServletContext().getRealPath("/");
		  // 获取服务器的webapps文件夹
		  String newpath = new File(path).getParent() + "/taskProgress/";
		  // 获取上文件名
		  String name=bid+".png";
		  String newfilename = newpath + bid+".png";
		  // 判断上传文件夹是否存在
		  // 如果上传文件夹不存在
		  File ff = new File(newfilename);
		  if (!ff.getParentFile().exists()) {
			  // 创建applicants文件夹
			  ff.getParentFile().mkdirs();
		  	}
		  File end = new File(newfilename);
		
		  if(inputStream!=null){
				byte[] bt = new byte[1024];
				int len=-1;
				try {
					FileOutputStream fo = new FileOutputStream(end);
					while((len=(inputStream.read(bt))) != -1) {
						fo.write(bt,0,len); 
						}
					fo.flush();
					fo.close();
					inputStream.close();
				} catch (IOException e) {
					e.printStackTrace();
				}
			}
		map.put("msg", "../taskProgress/"+ name);
		return map;
	
	}


//	@Override
	public BillNote getBillNoteByBid(int bid) {
		// TODO Auto-generated method stub
		return activitiDao.queryBillById(bid);
	}

	
}