package com.slcf.controller;
|
|
import java.io.IOException;
|
import java.io.InputStream;
|
import java.util.HashMap;
|
import java.util.Map;
|
|
import javax.servlet.http.HttpServletRequest;
|
import javax.servlet.http.HttpServletResponse;
|
|
import org.activiti.engine.HistoryService;
|
import org.activiti.engine.ProcessEngine;
|
import org.activiti.engine.RepositoryService;
|
import org.activiti.engine.RuntimeService;
|
import org.activiti.engine.TaskService;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Controller;
|
import org.springframework.web.bind.annotation.RequestMapping;
|
import org.springframework.web.bind.annotation.RequestParam;
|
import org.springframework.web.bind.annotation.ResponseBody;
|
import org.springframework.web.multipart.MultipartFile;
|
|
import com.slcf.pojo.BillNote;
|
import com.slcf.service.ActivitiService;
|
|
@Controller
|
@RequestMapping("/activiti")
|
public class ActivitiController {
|
@Autowired
|
ActivitiService activitiService;
|
|
@Autowired
|
ProcessEngine processEngine;
|
@Autowired
|
RepositoryService repositoryService;//仓库服务对象（管理部署信息）
|
|
@Autowired
|
RuntimeService runtimeService;// 运行时服务对象（管理流程的启动，流转等操作）
|
|
@Autowired
|
HistoryService historyService;//历史服务对象
|
|
@Autowired
|
TaskService taskService;//任务服务对象（Task表中的数据是Exeuction表的扩展，任务的创建时间和办理人）
|
|
@RequestMapping("/goQuest.action")
|
public String goQuest(){
|
return "quest";
|
}
|
|
@RequestMapping("/goTask.action")
|
public String goTask(){
|
return "task";
|
}
|
|
@RequestMapping("/goProcess.action")
|
public String goProcess(){
|
return "process";
|
}
|
|
/**
|
* 添加请假单，并启动流程
|
* @param note
|
* @param request
|
* @return
|
*/
|
@ResponseBody
|
@RequestMapping("/addNote.action")
|
public boolean seveBillNote(BillNote note,HttpServletRequest request){
|
int i=activitiService.saveBill(note, runtimeService, request);
|
boolean flag=false;
|
if(i>0){
|
flag=true;
|
}
|
return flag;
|
}
|
|
/**
|
* 部署流程定义
|
* @param fileName
|
* @param file
|
* @return
|
*/
|
@ResponseBody
|
@RequestMapping("/saveAct.action")
|
public boolean saveAct(@RequestParam("fileName")String fileName,
|
@RequestParam("files")MultipartFile file){
|
|
return activitiService.saveAct(fileName, file, processEngine);
|
}
|
|
/**
|
* 查看流程定义
|
* @return
|
*/
|
@ResponseBody
|
@RequestMapping("/definition.action")
|
public Map<String,Object> queryProcessDefinition(
|
@RequestParam("pageNumber")int pageNumber,
|
@RequestParam("pageSize")int pageSize){
|
|
return activitiService.queryProcessDefinition(pageNumber, pageSize, repositoryService);
|
}
|
|
/**
|
* 删除流程
|
* @param deployment_id 流程部署id
|
*/
|
@ResponseBody
|
@RequestMapping("/delAct.action")
|
public boolean delAct(@RequestParam("deployment_id")String deployment_id){
|
// 普通删除，如果当前规则下有正在执行的流程，则抛异常
|
// repositoryService.deleteDeployment(deployment_id);
|
// 级联删除,会删除和当前规则相关的所有信息，包括历史
|
repositoryService.deleteDeployment(deployment_id, true);
|
return true;
|
}
|
|
/**
|
* 查看流程图
|
* @param deployment_id 流程部署id
|
* @param response
|
*/
|
@ResponseBody
|
@RequestMapping("/img.action")
|
public Map<String,Object> getImg(
|
@RequestParam("deployment_id")String deployment_id,
|
HttpServletResponse response,
|
HttpServletRequest request){
|
|
return activitiService.getImg(deployment_id, response, request, repositoryService);
|
}
|
|
/**
|
* 根据登陆账号查询请假单
|
* @param request
|
* @param pageNumber
|
* @param pageSize
|
* @return
|
*/
|
@ResponseBody
|
@RequestMapping("/getMyReq.action")
|
public Map<String,Object> getMyReq(HttpServletRequest request,
|
@RequestParam("pageNumber") int pageNumber,@RequestParam("pageSize") int pageSize){
|
|
return activitiService.getMyReq(request, pageNumber, pageSize, taskService, runtimeService);
|
}
|
|
/**
|
* 提交申请，指派下一个任务人
|
* @param taskId 任务id
|
* @param request
|
* @return
|
*/
|
@ResponseBody
|
@RequestMapping("/submitMyReq.action")
|
public boolean submitMyReq(@RequestParam("taskId")String taskId,HttpServletRequest request){
|
String processInstanceId=taskService.createTaskQuery().taskId(taskId).singleResult().getProcessInstanceId();
|
String businessKey=runtimeService.createProcessInstanceQuery().processInstanceId(processInstanceId).singleResult().getBusinessKey();
|
//获取请假单id
|
String[] str=businessKey.split("\\.");
|
return activitiService.submitMyReq(taskId, Integer.parseInt(str[1]), taskService, request);
|
}
|
|
/**
|
* 删除请假单
|
* @param taskId
|
* @param request
|
* @return
|
*/
|
@ResponseBody
|
@RequestMapping("/delMyReq.action")
|
public Map<String,Object> delMyReq(@RequestParam("bid")int bid){
|
|
return activitiService.delMyReq(bid, runtimeService);
|
}
|
|
/**
|
* 查询个人任务
|
* @return
|
*/
|
@ResponseBody
|
@RequestMapping("/myTask.action")
|
public Map<String,Object> getMyTask(@RequestParam("pageNumber")int pageNumber,@RequestParam("pageSize")int pageSize,HttpServletRequest request){
|
|
return activitiService.getMyTask(taskService, request, pageNumber, pageSize);
|
}
|
|
/**
|
* 查询请假单详情，动态获取按钮信息
|
* @param taskId
|
* @return
|
*/
|
@ResponseBody
|
@RequestMapping("/detailTask.action")
|
public Map<String,Object> getDetailTask(@RequestParam("taskId")String taskId){
|
|
return activitiService.getDetailTask(repositoryService, runtimeService, taskService, taskId);
|
}
|
|
/**
|
* 部门经理处理任务
|
* @param taskId
|
* @param comments
|
* @return
|
*/
|
@ResponseBody
|
@RequestMapping("/dealTask.action")
|
public boolean magDelTask(@RequestParam("buttonValue")String buttonValue,@RequestParam("taskId")String taskId,@RequestParam("comments")String comments,HttpServletRequest request){
|
|
return activitiService.magDelTask(buttonValue, taskId, comments, runtimeService, taskService, request);
|
}
|
|
|
/**
|
* 查看流程图，显示活动节点
|
* @param bid
|
* @param response
|
*/
|
@ResponseBody
|
@RequestMapping("queryProPlan.action")
|
public Map<String,Object> queryProPlan(@RequestParam("bid")String bid,HttpServletRequest request) throws IOException{
|
Map<String,Object> map=new HashMap<String,Object>();
|
boolean flag=false;
|
BillNote note=activitiService.getBillNoteByBid(Integer.parseInt(bid));
|
if(note.getStatus().equals("审核完成")){
|
map.put("msg", "任务已经结束");
|
}else{
|
flag=true;
|
String processInstanceBusinessKey="BillNote."+bid;
|
String processInstanceId =runtimeService.createProcessInstanceQuery().processInstanceBusinessKey(processInstanceBusinessKey).singleResult().getProcessInstanceId();
|
InputStream in=activitiService.getDiagram(processInstanceId, runtimeService, repositoryService);
|
map=activitiService.outProcessPic(in, request, bid);
|
}
|
map.put("flag", flag);
|
return map;
|
}
|
|
|
}
|
