meidu2021/daju/src-xcgl/main/java/com/xcgl/projecttask/controller/ProjecttaskController.java

package com.xcgl.projecttask.controller;
import cn.com.lzt.common.util.CustomerConstant;
import com.aliyun.oss.OSSClient;
import com.aliyun.oss.model.OSSObject;
import com.xcgl.activititask.bean.ActivitiTaskResult;
import com.xcgl.activititask.entity.PActivitiTaskEntity;
import com.xcgl.activititask.util.ActivitiTaskHandler;
import com.xcgl.activititask.util.ActivitiTaskHandlerUtil;
import com.xcgl.projecttask.dao.ProjectTaskDao;
import com.xcgl.projecttask.entity.ProjecttaskEntity;
import com.xcgl.projecttask.service.ProjecttaskServiceI;
import com.xcgl.projecttaskplan.entity.ProjectTaskPlanEntity;
import com.xcgl.taskresult.entity.TaskResultEntity;
import com.xcgl.utils.XcglConstant;
import org.apache.commons.lang.StringUtils;
import org.apache.log4j.Logger;
import org.hibernate.criterion.Restrictions;
import org.jeecgframework.core.beanvalidator.BeanValidators;
import org.jeecgframework.core.common.controller.BaseController;
import org.jeecgframework.core.common.exception.BusinessException;
import org.jeecgframework.core.common.hibernate.qbc.CriteriaQuery;
import org.jeecgframework.core.common.model.json.AjaxJson;
import org.jeecgframework.core.common.model.json.DataGrid;
import org.jeecgframework.core.constant.Globals;
import org.jeecgframework.core.util.*;
import org.jeecgframework.poi.excel.ExcelImportUtil;
import org.jeecgframework.poi.excel.entity.ExportParams;
import org.jeecgframework.poi.excel.entity.ImportParams;
import org.jeecgframework.poi.excel.entity.vo.NormalExcelConstants;
import org.jeecgframework.tag.core.easyui.TagUtil;
import org.jeecgframework.web.system.pojo.base.TSDepart;
import org.jeecgframework.web.system.pojo.base.TSUser;
import org.jeecgframework.web.system.service.SystemService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.HttpHeaders;
import org.springframework.http.HttpStatus;
import org.springframework.http.MediaType;
import org.springframework.http.ResponseEntity;
import org.springframework.stereotype.Controller;
import org.springframework.ui.ModelMap;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.multipart.MultipartFile;
import org.springframework.web.multipart.MultipartHttpServletRequest;
import org.springframework.web.servlet.ModelAndView;
import org.springframework.web.util.UriComponentsBuilder;

import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import javax.validation.ConstraintViolation;
import javax.validation.Validator;
import java.io.BufferedInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.URI;
import java.text.SimpleDateFormat;
import java.util.*;
import java.util.zip.ZipEntry;
import java.util.zip.ZipOutputStream;

/**   
 * @Title: Controller  
 * @Description: 项目工作
 * @author onlineGenerator
 * @date 2018-09-07 18:09:01
 * @version V1.0   
 *
 */
@Controller
@RequestMapping("/projecttaskController")
public class ProjecttaskController extends BaseController {
	/**
	 * Logger for this class
	 */
	private static final Logger logger = Logger.getLogger(ProjecttaskController.class);

	@Autowired
	private ProjecttaskServiceI projecttaskService;
	@Autowired
	private SystemService systemService;
	@Autowired
	private Validator validator;

	@Autowired
	private ProjectTaskDao projectTaskDao;
	


	/**
	 * 项目工作列表 页面跳转
	 * 
	 * @return
	 */
	@RequestMapping(params = "list")
	public ModelAndView list(HttpServletRequest request) {
		
		ModelAndView mv = null;
		String plantype = request.getParameter("type");
		if(StringUtils.isNotEmpty(plantype)){
			switch (plantype) {
			case "xmpx":// 培训工作（项目培训）
				mv = new ModelAndView("com/xcgl/projecttask/projecttaskList-peixun");
				break;
			case "lzsb":// 离职上报
				mv = new ModelAndView("com/xcgl/projecttask/projecttaskList-lizhi");
				break;
			case "wlsq":// 物料申请
				mv = new ModelAndView("com/xcgl/projecttask/projecttaskList-wuliao");
				break;
			case "bjxc":// 保洁工作
				mv = new ModelAndView("com/xcgl/projecttask/projecttaskList-baojie");
				break;
			case "pmdept": //项目管理部工作
				mv =  new ModelAndView("com/xcgl/projecttask/projecttaskList-pmdept");
				break;
			case "tyrw":// 通用工作
				mv = new ModelAndView("com/xcgl/projecttask/projecttaskList");
				break;
			}
		}
		if(mv == null) 
			mv = new ModelAndView("com/xcgl/projecttask/projecttaskList");
		request.setAttribute("tasktype", plantype);
		request.setAttribute("planid", request.getParameter("planid"));
		return mv;
	}

	/**
	 * easyui AJAX请求数据
	 * 
	 * @param request
	 * @param response
	 * @param dataGrid
	 */

	@RequestMapping(params = "datagrid")
	public void datagrid(ProjecttaskEntity projecttask,HttpServletRequest request, HttpServletResponse response, DataGrid dataGrid) {
		CriteriaQuery cq = new CriteriaQuery(ProjecttaskEntity.class, dataGrid);
		//查询条件组装器
//		org.jeecgframework.core.extend.hqlsearch.HqlGenerateUtil.installHql(cq, projecttask, request.getParameterMap());
		try{
			//自定义追加查询条件
			String tasktype = request.getParameter("tasktype");
			if(StringUtils.isNotEmpty(tasktype)){
				cq.eq("tasktype", tasktype );
			}
			String query_planendtime_begin = request.getParameter("planendtime_begin1");
			String query_planendtime_end = request.getParameter("planendtime_end2");
			if(StringUtil.isNotEmpty(query_planendtime_begin)){
				cq.ge("planendtime", new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").parse(query_planendtime_begin));
			}
			if(StringUtil.isNotEmpty(query_planendtime_end)){
				cq.le("planendtime", new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").parse(query_planendtime_end));
			}
			String description =  request.getParameter("description");
			if(StringUtil.isNotEmpty(description)) {
				cq.like("description", "%"+description+"%");
			}
			String name =  request.getParameter("name");
			if(StringUtil.isNotEmpty(name)) {
				cq.like("name", "%"+name+"%");
			}
			String owner =  request.getParameter("owner");
			if(StringUtil.isNotEmpty(owner)) {
				cq.eq("owner", owner);
			}
			String taskstatus =  request.getParameter("taskstatus");
			if(StringUtil.isNotEmpty(taskstatus)) {
				cq.eq("taskstatus", taskstatus);
			}
			String projectid =  request.getParameter("projectid");
			if(StringUtil.isNotEmpty(projectid)) {
				cq.eq("projectid", projectid);
			}
			if(StringUtil.isNotEmpty(projecttask.getTaskplanid())) {
				cq.eq("taskplanid", projecttask.getTaskplanid());
			}
		}catch (Exception e) {
			throw new BusinessException(e.getMessage());
		}
		cq.add();
		this.projecttaskService.getDataGridReturn(cq, true);
		List dataList = dataGrid.getResults();
		
		String deptSql = "select id,departname from t_s_depart ";
		List<Map<String, Object>> projectinfo = systemService.findForJdbc(deptSql);
		HashMap<String, String> projectMap = new HashMap<String, String>();
		for (Map<String, Object> map : projectinfo) {
			projectMap.put(map.get("id").toString(), map.get("departname").toString());
		}
		
		String userSql = "select id,realname from t_s_base_user";
		List<Map<String, Object>> userinfo = systemService.findForJdbc(userSql);
		HashMap<String, String> userMap = new HashMap<String, String>();
		for (Map<String, Object> map : userinfo) {
			userMap.put(map.get("id").toString(), map.get("realname").toString());
		}
		
		ArrayList<String> ids = new ArrayList<String>();
		for(Object data :dataList) {
			ProjecttaskEntity task = (ProjecttaskEntity)data;
			setOutTimeMsg(task);
			task.setProjectname(projectMap.get( task.getProjectid()));
			task.setOwnername(userMap.get(task.getOwner()));
			ids.add(task.getId());
		}
		
		String qryUploadAttr = request.getParameter("qryupload");
		if(ids.size() > 0 && StringUtils.isNotEmpty(qryUploadAttr) && qryUploadAttr.equals("1")) {
			String idstr = "'"+StringUtils.join(ids,"','")+"'";
			String attrSql = "select distinct taskid from t_sys_file  file "
					+ "left join p_taskresult result on file.busi_id = result.id and file.busi_table = 'p_taskresult' "
					+ "where result.taskid  in("+idstr+") ";
			List<String> exsitID = systemService.findListbySql(attrSql);
			HashMap<String,String> exsitIDMap = new HashMap<String, String>();
			for (String id : exsitID) {
				exsitIDMap.put(id, id);
			}
			for(Object data :dataList) {
				ProjecttaskEntity task = (ProjecttaskEntity)data;
				if(exsitIDMap.containsKey(task.getId())) {
					task.setUploadattr("有附件");
				}
			}
		}
		
		dataGrid.setResults(dataList);
		TagUtil.datagrid(response, dataGrid);
	}
	
	/**
	 * 删除项目工作
	 * 
	 * @return
	 */
	@RequestMapping(params = "doDel")
	@ResponseBody
	public AjaxJson doDel(ProjecttaskEntity projecttask, HttpServletRequest request) {
		String message = null;
		AjaxJson j = new AjaxJson();
		projecttask = systemService.getEntity(ProjecttaskEntity.class, projecttask.getId());
		message = "项目工作删除成功";
		try{
			projecttaskService.delete(projecttask);
			systemService.addLog(message, Globals.Log_Type_DEL, Globals.Log_Leavel_INFO);
		}catch(Exception e){
			e.printStackTrace();
			message = "项目工作删除失败";
			throw new BusinessException(e.getMessage());
		}
		j.setMsg(message);
		return j;
	}

	@RequestMapping(params = "goCloseTask")
	public String goCloseTask(HttpServletRequest request) {
		String id = request.getParameter("id");
		if(StringUtils.isNotBlank(id)){
			ProjecttaskEntity projecttask= projecttaskService.getEntity(ProjecttaskEntity.class, id);
			request.setAttribute("task", projecttask);
		}
		return "com/xcgl/projecttask/close_task";
	}
	
	@RequestMapping(params = "doCloseTask")
	@ResponseBody
	public AjaxJson doCloseTask(String id,String msg, HttpServletRequest request) {
		AjaxJson retJson = new AjaxJson();
		TSUser tuser = (TSUser) ContextHolderUtils.getSession().getAttribute("LOCAL_CLINET_USER");
		String changeSql = "update p_projecttask set taskstatus =? ,executer = ? ,closemsg=? where id = ? ";
		systemService.executeSql(changeSql, XcglConstant.TASKSTATUS_CLOSED, tuser.getId(), msg, id);
		retJson.setMsg("工作关闭成功。");
		return retJson;
	}
	/**
	 * 批量删除项目工作
	 * 
	 * @return
	 */
	 @RequestMapping(params = "doBatchDel")
	@ResponseBody
	public AjaxJson doBatchDel(String ids,HttpServletRequest request){
		String message = null;
		AjaxJson j = new AjaxJson();
		message = "项目工作删除成功";
		try{
			for(String id:ids.split(",")){
				ProjecttaskEntity projecttask = systemService.getEntity(ProjecttaskEntity.class, 
				id
				);
				projecttaskService.delete(projecttask);
				systemService.addLog(message, Globals.Log_Type_DEL, Globals.Log_Leavel_INFO);
			}
		}catch(Exception e){
			e.printStackTrace();
			message = "项目工作删除失败";
			throw new BusinessException(e.getMessage());
		}
		j.setMsg(message);
		return j;
	}


	/**
	 * 添加项目工作
	 * 
	 * @return
	 */
	@RequestMapping(params = "doAdd")
	@ResponseBody
	public AjaxJson doAdd(ProjecttaskEntity projecttask, HttpServletRequest request) {
		String message = null;
		AjaxJson j = new AjaxJson();
		message = "项目工作添加成功";
		try{
			projecttaskService.save(projecttask);
			systemService.addLog(message, Globals.Log_Type_INSERT, Globals.Log_Leavel_INFO);
		}catch(Exception e){
			e.printStackTrace();
			message = "项目工作添加失败";
			throw new BusinessException(e.getMessage());
		}
		j.setMsg(message);
		return j;
	}
	
	/**
	 * 更新项目工作
	 * 
	 * @return
	 */
	@RequestMapping(params = "doUpdate")
	@ResponseBody
	public AjaxJson doUpdate(ProjecttaskEntity projecttask, HttpServletRequest request) {
		String message = null;
		AjaxJson j = new AjaxJson();
		message = "项目工作更新成功";
		ProjecttaskEntity t = projecttaskService.get(ProjecttaskEntity.class, projecttask.getId());
		try {
			MyBeanUtils.copyBeanNotNull2Bean(projecttask, t);
			projecttaskService.saveOrUpdate(t);
			systemService.addLog(message, Globals.Log_Type_UPDATE, Globals.Log_Leavel_INFO);
		} catch (Exception e) {
			e.printStackTrace();
			message = "项目工作更新失败";
			throw new BusinessException(e.getMessage());
		}
		j.setMsg(message);
		return j;
	}
	

	/**
	 * 项目工作新增页面跳转
	 * 
	 * @return
	 */
	@RequestMapping(params = "goAdd")
	public ModelAndView goAdd(ProjecttaskEntity projecttask, HttpServletRequest req) {
		if (StringUtil.isNotEmpty(projecttask.getId())) {
			projecttask = projecttaskService.getEntity(ProjecttaskEntity.class, projecttask.getId());
			req.setAttribute("projecttaskPage", projecttask);
		}
		return new ModelAndView("com/xcgl/projecttask/projecttask-add");
	}
	/**
	 * 项目工作编辑页面跳转
	 * 
	 * @return
	 */
	@RequestMapping(params = "goUpdate")
	public ModelAndView goUpdate(ProjecttaskEntity projecttask, HttpServletRequest req) {
		if (StringUtil.isNotEmpty(projecttask.getId())) {
			projecttask = projecttaskService.getEntity(ProjecttaskEntity.class, projecttask.getId());
			//查询名称数据
			if(StringUtils.isNotEmpty(projecttask.getOwner())) {
				TSUser owner = systemService.get(TSUser.class, projecttask.getOwner());
				projecttask.setOwnername(owner.getRealName());
			}
			if(StringUtils.isNotEmpty(projecttask.getExecuter())) {
				TSUser owner = systemService.get(TSUser.class, projecttask.getExecuter());
				projecttask.setExecutername(owner.getRealName());
			}
			if(StringUtils.isNotEmpty(projecttask.getProjectid())) {
				TSDepart dept = systemService.get(TSDepart.class, projecttask.getProjectid());
				projecttask.setProjectname(dept.getDepartname());
			}
			if(StringUtils.isNotEmpty(projecttask.getTaskplanid())) {
				ProjectTaskPlanEntity plan = systemService.get(ProjectTaskPlanEntity.class, projecttask.getTaskplanid());
				projecttask.setPlanname(plan.getName());
			}
			
			req.setAttribute("projecttaskPage", projecttask);
		}
		return new ModelAndView("com/xcgl/projecttask/projecttask-update");
	}
	
	/**
	 * 导入功能跳转
	 * 
	 * @return
	 */
	@RequestMapping(params = "upload")
	public ModelAndView upload(HttpServletRequest req) {
		req.setAttribute("controller_name","projecttaskController");
		return new ModelAndView("common/upload/pub_excel_upload");
	}
	
	/**
	 * 导出excel
	 * 
	 * @param request
	 * @param response
	 */
	@RequestMapping(params = "exportXls")
	public String exportXls(ProjecttaskEntity projecttask,HttpServletRequest request,HttpServletResponse response
			, DataGrid dataGrid,ModelMap modelMap) {
		CriteriaQuery cq = new CriteriaQuery(ProjecttaskEntity.class, dataGrid);
		//查询条件组装器
		try{
			//自定义追加查询条件
			String tasktype = request.getParameter("tasktype");
			if(StringUtils.isNotEmpty(tasktype)){
				cq.eq("tasktype", tasktype );
			}
			String query_planendtime_begin = request.getParameter("planendtime_begin1");
			String query_planendtime_end = request.getParameter("planendtime_end2");
			if(StringUtil.isNotEmpty(query_planendtime_begin)){
				cq.ge("planendtime", new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").parse(query_planendtime_begin));
			}
			if(StringUtil.isNotEmpty(query_planendtime_end)){
				cq.le("planendtime", new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").parse(query_planendtime_end));
			}
			String description =  request.getParameter("description");
			if(StringUtil.isNotEmpty(description)) {
				cq.like("description", "%"+description+"%");
			}
			String name =  request.getParameter("name");
			if(StringUtil.isNotEmpty(name)) {
				cq.like("name", "%"+name+"%");
			}
			String owner =  request.getParameter("owner");
			if(StringUtil.isNotEmpty(owner)) {
				cq.eq("owner", owner);
			}
			String taskstatus =  request.getParameter("taskstatus");
			if(StringUtil.isNotEmpty(taskstatus)) {
				cq.eq("taskstatus", owner);
			}
			String projectid =  request.getParameter("projectid");
			if(StringUtil.isNotEmpty(projectid)) {
				cq.eq("projectid", owner);
			}
			
		}catch (Exception e) {
			throw new BusinessException(e.getMessage());
		}
		cq.add();
		List<ProjecttaskEntity> projecttasks = this.projecttaskService.getListByCriteriaQuery(cq,false);
		modelMap.put(NormalExcelConstants.FILE_NAME,"项目工作");
		modelMap.put(NormalExcelConstants.CLASS,ProjecttaskEntity.class);
		modelMap.put(NormalExcelConstants.PARAMS,new ExportParams("项目工作列表", "导出人:"+ResourceUtil.getSessionUser().getRealName(),
			"导出信息"));
		modelMap.put(NormalExcelConstants.DATA_LIST,projecttasks);
		return NormalExcelConstants.JEECG_EXCEL_VIEW;
	}
	/**
	 * 导出excel 使模板
	 * 
	 * @param request
	 * @param response
	 */
	@RequestMapping(params = "exportXlsByT")
	public String exportXlsByT(ProjecttaskEntity projecttask,HttpServletRequest request,HttpServletResponse response
			, DataGrid dataGrid,ModelMap modelMap) {
    	modelMap.put(NormalExcelConstants.FILE_NAME,"项目工作");
    	modelMap.put(NormalExcelConstants.CLASS,ProjecttaskEntity.class);
    	modelMap.put(NormalExcelConstants.PARAMS,new ExportParams("项目工作列表", "导出人:"+ResourceUtil.getSessionUser().getRealName(),
    	"导出信息"));
    	modelMap.put(NormalExcelConstants.DATA_LIST,new ArrayList());
    	return NormalExcelConstants.JEECG_EXCEL_VIEW;
	}
	
	@SuppressWarnings("unchecked")
	@RequestMapping(params = "importExcel", method = RequestMethod.POST)
	@ResponseBody
	public AjaxJson importExcel(HttpServletRequest request, HttpServletResponse response) {
		AjaxJson j = new AjaxJson();
		
		MultipartHttpServletRequest multipartRequest = (MultipartHttpServletRequest) request;
		Map<String, MultipartFile> fileMap = multipartRequest.getFileMap();
		for (Map.Entry<String, MultipartFile> entity : fileMap.entrySet()) {
			MultipartFile file = entity.getValue();// 获取上传文件对象
			ImportParams params = new ImportParams();
			params.setTitleRows(2);
			params.setHeadRows(1);
			params.setNeedSave(true);
			try {
				List<ProjecttaskEntity> listProjecttaskEntitys = ExcelImportUtil.importExcel(file.getInputStream(),ProjecttaskEntity.class,params);
				for (ProjecttaskEntity projecttask : listProjecttaskEntitys) {
					projecttaskService.save(projecttask);
				}
				j.setMsg("文件导入成功！");
			} catch (Exception e) {
				j.setMsg("文件导入失败！");
				logger.error(ExceptionUtil.getExceptionMessage(e));
			}finally{
				try {
					file.getInputStream().close();
				} catch (IOException e) {
					e.printStackTrace();
				}
			}
		}
		return j;
	}
	
	@RequestMapping(method = RequestMethod.GET)
	@ResponseBody
	public List<ProjecttaskEntity> list() {
		List<ProjecttaskEntity> listProjecttasks=projecttaskService.getList(ProjecttaskEntity.class);
		return listProjecttasks;
	}
	
	@RequestMapping(value = "/{id}", method = RequestMethod.GET)
	@ResponseBody
	public ResponseEntity<?> get(@PathVariable("id") String id) {
		ProjecttaskEntity task = projecttaskService.get(ProjecttaskEntity.class, id);
		if (task == null) {
			return new ResponseEntity(HttpStatus.NOT_FOUND);
		}
		return new ResponseEntity(task, HttpStatus.OK);
	}

	@RequestMapping(method = RequestMethod.POST, consumes = MediaType.APPLICATION_JSON_VALUE)
	@ResponseBody
	public ResponseEntity<?> create(@RequestBody ProjecttaskEntity projecttask, UriComponentsBuilder uriBuilder) {
		//调用JSR303 Bean Validator进行校验，如果出错返回含400错误码及json格式的错误信息.
		Set<ConstraintViolation<ProjecttaskEntity>> failures = validator.validate(projecttask);
		if (!failures.isEmpty()) {
			return new ResponseEntity(BeanValidators.extractPropertyAndMessage(failures), HttpStatus.BAD_REQUEST);
		}

		//保存
		try{
			projecttaskService.save(projecttask);
		} catch (Exception e) {
			e.printStackTrace();
			return new ResponseEntity(HttpStatus.NO_CONTENT);
		}
		//按照Restful风格约定，创建指向新任务的url, 也可以直接返回id或对象.
		String id = projecttask.getId();
		URI uri = uriBuilder.path("/api/projecttaskController/" + id).build().toUri();
		HttpHeaders headers = new HttpHeaders();
		headers.setLocation(uri);

		return new ResponseEntity(headers, HttpStatus.CREATED);
	}

	@RequestMapping(value = "/{id}", method = RequestMethod.PUT, consumes = MediaType.APPLICATION_JSON_VALUE)
	public ResponseEntity<?> update(@RequestBody ProjecttaskEntity projecttask) {
		//调用JSR303 Bean Validator进行校验，如果出错返回含400错误码及json格式的错误信息.
		Set<ConstraintViolation<ProjecttaskEntity>> failures = validator.validate(projecttask);
		if (!failures.isEmpty()) {
			return new ResponseEntity(BeanValidators.extractPropertyAndMessage(failures), HttpStatus.BAD_REQUEST);
		}

		//保存
		try{
			projecttaskService.saveOrUpdate(projecttask);
		} catch (Exception e) {
			e.printStackTrace();
			return new ResponseEntity(HttpStatus.NO_CONTENT);
		}

		//按Restful约定，返回204状态码, 无内容. 也可以返回200状态码.
		return new ResponseEntity(HttpStatus.NO_CONTENT);
	}

	@RequestMapping(value = "/{id}", method = RequestMethod.DELETE)
	@ResponseStatus(HttpStatus.NO_CONTENT)
	public void delete(@PathVariable("id") String id) {
		projecttaskService.deleteEntityById(ProjecttaskEntity.class, id);
	}

	@RequestMapping(params = "taskUndoCountStatic")
	@ResponseBody
	public Object taskUndoCountStatic(HttpServletRequest request) {
		List<?> list =projectTaskDao.taskUndoCountStatic(ResourceUtil.getSessionUser().getId());
		return list;
	}

	@RequestMapping(params = "userTaskList")
	public String userTaskList(HttpServletRequest request) {
		return "com/xcgl/projecttask/user-task";
	}

	@RequestMapping(params = "userTaskDatagrid")
	public void userTaskDatagrid(ProjecttaskEntity projecttask,HttpServletRequest request, HttpServletResponse response, DataGrid dataGrid) {
		CriteriaQuery cq = new CriteriaQuery(ProjecttaskEntity.class, dataGrid);
		//查询条件组装器
//		org.jeecgframework.core.extend.hqlsearch.HqlGenerateUtil.installHql(cq, projecttask, request.getParameterMap());
		try{
			TSUser user = ResourceUtil.getSessionUser();
			cq.add(Restrictions.eq("owner",user.getId()));
			cq.add(Restrictions.ne("taskstatus","20"));
			String filter = request.getParameter("filter");
			if(StringUtils.isNotBlank(filter)){
				if(filter.equals("1")){//紧急
					Calendar c = Calendar.getInstance();
					c.add(Calendar.DAY_OF_MONTH,1);
					cq.add(Restrictions.gt("planendtime",new Date()));
					cq.add(Restrictions.lt("planendtime",c.getTime()));
				}
				if(filter.equals("2")){//逾期
					cq.add(Restrictions.lt("planendtime",new Date()));
				}
			}
		}catch (Exception e) {
			throw new BusinessException(e.getMessage());
		}
		cq.add();
		this.projecttaskService.getDataGridReturn(cq, true);
		List<ProjecttaskEntity> resultList =  dataGrid.getResults();
		for(ProjecttaskEntity ptask : resultList){
			String sourceType = ptask.getSourcetype();
			if(!StringUtils.equals(sourceType,"activititask")){
				ptask.setSourceid(null);
			}
		}
		TagUtil.datagrid(response, dataGrid);
	}

	//完成任务
	@RequestMapping(params = "finishTask")
	@ResponseBody
	public Object finishTask(ProjecttaskEntity projecttask,HttpServletRequest request) {
		projecttask = systemService.findUniqueByProperty(ProjecttaskEntity.class,"id" ,projecttask.getId() );
		projecttask.setExeendtime(new Date());
		projecttask.setTaskstatus(XcglConstant.TASKSTATUS_DONE);
		systemService.save(projecttask);
		return true;
	}


	//检查任务
	@RequestMapping(params = "checkResult")
	@ResponseBody
	public Object checkResult(ProjecttaskEntity projecttask,HttpServletRequest request) {
		projecttask = systemService.getEntity(ProjecttaskEntity.class,projecttask.getId());
		String activitiTaskId = projecttask.getActivitiTaskId();
		if(StringUtils.isNotBlank(activitiTaskId)){
			PActivitiTaskEntity pActivitiTaskEntity = systemService.getEntity(PActivitiTaskEntity.class,activitiTaskId);
			ActivitiTaskHandler handler = ActivitiTaskHandlerUtil.getHandler(pActivitiTaskEntity.getExecuteClass());
			return handler.checkResult(projecttask);
		}
		return new ActivitiTaskResult(true);
	}
	@RequestMapping(params = "goExeTaskView")
	public ModelAndView goExeTaskView(HttpServletRequest request) {
		
		ModelAndView mv = null;
		String id = request.getParameter("id");
		String entrance = request.getParameter("entrance");
		if(entrance == null || "".equals(entrance)){
			request.setAttribute("entrance", "other");
		}else{
			request.setAttribute("entrance", entrance);
		}
		ProjecttaskEntity task = systemService.get(ProjecttaskEntity.class, id);
		List<TaskResultEntity> taskresultList = systemService.findByProperty(TaskResultEntity.class, "taskid", id);
		try {
			if(taskresultList.size() > 0) {
				request.setAttribute("taskresult", taskresultList.get(0));
			}else {
				TaskResultEntity taskresult = new TaskResultEntity();
				taskresult.setTaskid(id);
				systemService.save(taskresult);
				request.setAttribute("taskresult", taskresult);
			}
		} catch (Exception e) {
			logger.error(e.getMessage());
		}
		mv = new ModelAndView("com/xcgl/taskresult/taskResultByTask-add");
		request.setAttribute("task", task);
		return mv;
	}
	@RequestMapping(params = "doExeTask")
	@ResponseBody
	public AjaxJson doExeTask(String id, HttpServletRequest request) {
		String msg = "工作开始执行。";
		AjaxJson retJson = new AjaxJson();
		TSUser tuser = (TSUser) ContextHolderUtils.getSession().getAttribute("LOCAL_CLINET_USER");
		ProjecttaskEntity task = systemService.get(ProjecttaskEntity.class, id);
		task.setTaskstatus(XcglConstant.TASKSTATUS_EXEING);
		task.setExecuter(tuser.getId());
		task.setExestarttime(new Date());
//		String changeSql = "update p_projecttask set taskstatus = ? ,executer = ? where id = ?";
//		systemService.executeSql(changeSql, XcglConstant.TASKSTATUS_EXEING, tuser.getId(), id);
		systemService.saveOrUpdate(task);
		retJson.setMsg(msg);
		retJson.setObj(task);
		systemService.addLog(msg+"taskid:"+id, Globals.Log_Leavel_INFO, Globals.Log_Type_OTHER);
		return retJson;
	}
	//查询业务实体的的审批流实例id（procInstId）
	@RequestMapping(params = "findProcInstId")
	@ResponseBody
	public AjaxJson findProcInstId(String sourceid,String tasktype, HttpServletRequest request) {
		String msg = "查询审批流实例成功";
		AjaxJson retJson = new AjaxJson();
		if(StringUtils.isEmpty(sourceid) || StringUtils.isEmpty(tasktype)) {
			retJson.setSuccess(false);
			retJson.setMsg("系统异常，数据错误，请联系管理员");
			return retJson;
		}
		//这两个签报类型与任务类型值不同，需要转换，其他都相同
		if(tasktype.equals("sameleveltransfer")) {
			tasktype = "samelevel_transfer_new";
		}else if(tasktype.equals("user_leave")) {
			tasktype = "leave_new";
		}
		String findtableSql = "select real_tablename from t_process_busconfig where process_type = '"+tasktype+"'";
		List<String> tables = systemService.findListbySql(findtableSql);
		if(tables == null || tables.size() == 0) {
			retJson.setSuccess(false);
			retJson.setMsg("查询不到审批流配置数据，请联系管理员");
			return retJson;
		}
		String procInstIdSql = "select proc_inst_id from "+tables.get(0)+" where id = '"+sourceid+"'";
		List<String> instIds = systemService.findListbySql(procInstIdSql);
		if(instIds == null || instIds.size() == 0) {
			retJson.setSuccess(false);
			retJson.setMsg("查询不到签报数据，请联系管理员");
			return retJson;
		}
		retJson.setObj(instIds.get(0));
		retJson.setMsg(msg);
		return retJson;
	}
	
	@RequestMapping(params = "myTaskList")
	public String myTaskList(HttpServletRequest request) {
		return "com/xcgl/projecttask/mytaskList";
	}
	@RequestMapping(params = "myTaskListDatagrid")
	public void myTaskListDatagrid(ProjecttaskEntity projecttask,HttpServletRequest request, HttpServletResponse response, DataGrid dataGrid) {
		CriteriaQuery cq = new CriteriaQuery(ProjecttaskEntity.class, dataGrid);
		// 查询条件组装器
		if (StringUtils.isNotBlank(projecttask.getCreateName())) {
			// 模糊查询
			cq.like("createName", "%" + projecttask.getCreateName() + "%");
			projecttask.setCreateName(null);
		}
		// 查询条件组装器
		if (StringUtils.isNotBlank(projecttask.getName())) {
			// 模糊查询
			cq.like("name", "%" + projecttask.getName() + "%");
			projecttask.setName(null);
		}
		//查询条件组装器
		if(StringUtils.isNotBlank(projecttask.getTaskstatus())){
			if("1".equals(projecttask.getTaskstatus())){
				//未完成(预计完成时间大于等于当前时间,Taskstatus=0,1)
				cq.in("taskstatus", new Object[]{"0", "1"});
				cq.ge("planendtime", new Date());
				projecttask.setTaskstatus(null);
			}else if("20".equals(projecttask.getTaskstatus())){
				//已完成(完成时间小于等于预计完成时间,Taskstatus=20)
				cq.eq("taskstatus", "20");
				cq.add(Restrictions.leProperty("exeendtime","planendtime"));
				projecttask.setTaskstatus(null);
			}else if("30".equals(projecttask.getTaskstatus())){
				//逾期未完成(预计完成时间小于当前时间,Taskstatus=0,1)
				cq.in("taskstatus", new Object[]{"0", "1"});
				cq.lt("planendtime", new Date());
				projecttask.setTaskstatus(null);
			}else if("40".equals(projecttask.getTaskstatus())){
				//逾期已完成(完成时间大于预计完成时间,Taskstatus=20)
				cq.eq("taskstatus", "20");
				cq.add(Restrictions.gtProperty("exeendtime","planendtime"));
				projecttask.setTaskstatus(null);
			}
		}
		//查询条件组装器
		try{
			TSUser user = ResourceUtil.getSessionUser();
			cq.add(Restrictions.eq("owner",user.getId()));
		}catch (Exception e) {
			throw new BusinessException(e.getMessage());
		}
		org.jeecgframework.core.extend.hqlsearch.HqlGenerateUtil.installHql(cq, projecttask, request.getParameterMap());
		cq.add();
		this.projecttaskService.getDataGridReturn(cq, true);
		List<ProjecttaskEntity> resultList =  dataGrid.getResults();
		for(ProjecttaskEntity ptask : resultList){
			String sourceType = ptask.getSourcetype();
			if(!StringUtils.equals(sourceType,"activititask")){
				ptask.setSourceid(null);
			}
			if("0".equals(ptask.getTaskstatus()) || "1".equals(ptask.getTaskstatus())){
				Date nowDate = new Date();
				Date endDate = ptask.getPlanendtime();
				if (nowDate.getTime() > endDate.getTime()) {
					ptask.setStateWrittenWords("逾期未完成");
				}else{
					ptask.setStateWrittenWords("未完成");
				}
			}else if("20".equals(ptask.getTaskstatus())){
				Date endTime = ptask.getExeendtime();
				if(endTime == null){
					ptask.setStateWrittenWords("已完成");
				}else{
					Date endDate = ptask.getPlanendtime();
					if(endTime.getTime() > endDate.getTime()){
						ptask.setStateWrittenWords("逾期已完成");
					}else{
						ptask.setStateWrittenWords("已完成");
					}
				}
			}else if("10".equals(ptask.getTaskstatus())){
				ptask.setStateWrittenWords("已关闭");
			}
		}
		TagUtil.datagrid(response, dataGrid);
	}
	
	// 下载附件
	@RequestMapping(params = "downloadAttr")
	public void downloadAttr(String taskid ,HttpServletRequest request, HttpServletResponse response) {
		
		String deptSql = "select  dept.departname as projectname,result.id as id  "
				+ "from p_taskresult result \n"
				+ "left join p_projecttask task on result.taskid = task.id\n"
				+ "left join t_s_depart dept on task.projectid = dept.id\n" + "where task.id =? ";
		List<Map<String, Object>> projectinfo = systemService.findForJdbc(deptSql, taskid);
		HashMap<String, String> projectMap = new HashMap<String, String>();
		for (Map<String, Object> map : projectinfo) {
			projectMap.put(map.get("id").toString(), map.get("projectname").toString());
		}
		
		List<Map<String, Object>> fileInfo = new ArrayList<Map<String, Object>>();
		String fileInfoSql = "select file_url,file_name,busi_id "
				+ "from t_sys_file  file left join p_taskresult result on file.busi_id = result.id and file.busi_table = 'p_taskresult' where result.taskid = ?";
		fileInfo = systemService.findForJdbc(fileInfoSql, taskid);
		if (fileInfo.size() == 0) {
			return;
		}
		zipfiles(fileInfo, projectMap, request, response);
	}
	
	// 下载所有附件附件
	@RequestMapping(params = "downloadAllAttr")
	public void downloadAllAttr(String planid, HttpServletRequest request, HttpServletResponse response) {
		String planEndTimeBegin = request.getParameter("planendtime_begin1");
		String planEndTImeEnd = request.getParameter("planendtime_end2");
		String taskstatus = request.getParameter("taskstatus");
		String whereStr= "";
		whereStr += StringUtils.isNotEmpty(planEndTimeBegin)?" and task.planendtime > '"+planEndTimeBegin+"'" :"";
		whereStr += StringUtils.isNotEmpty(planEndTImeEnd)?" and task.planendtime < '"+planEndTImeEnd+"'" :"";
		whereStr += StringUtils.isNotEmpty(taskstatus)?" and task.taskstatus = '"+taskstatus+"'" :"";
		String deptSql = "select  dept.departname as projectname,result.id as id  from p_taskresult result \n"
				+ "left join p_projecttask task on result.taskid = task.id \n"
				+ "left join t_s_depart dept on task.projectid = dept.id \n" + "where task.taskplanid =? "+whereStr;
		List<Map<String, Object>> projectinfo = systemService.findForJdbc(deptSql, planid);
		HashMap<String, String> projectMap = new HashMap<String, String>();
		for (Map<String, Object> map : projectinfo) {
			projectMap.put(map.get("id").toString(), map.get("projectname").toString());
		}
		String fileInfoSql = "select file_url,file_name,busi_id\n" + "from t_sys_file  file \n"
				+ "left join p_taskresult result on file.busi_id = result.id and file.busi_table = 'p_taskresult' \n"
				+ "left join p_projecttask task on result.taskid = task.id\n" + "where task.taskplanid = ?"+whereStr;
		List<Map<String, Object>> fileInfo = systemService.findForJdbc(fileInfoSql, planid);
		if (fileInfo.size() == 0) {
			return;
		}
		zipfiles(fileInfo, projectMap, request, response);
	}
	
	private void zipfiles(List<Map<String,Object>> fileInfo,HashMap<String,String> projectMap,HttpServletRequest request, HttpServletResponse response) {
		InputStream inputStream = null;
		OutputStream outputStream = null;
		ZipOutputStream zipOutputStream = null;
		String timenow = "";
		SimpleDateFormat formater = new SimpleDateFormat("yyMMddHHmmss_sss");
		try {
			timenow = formater.format(new Date());
		} catch (Exception e) {
		}
		OSSClient ossClient = null;
		try {
			outputStream=response.getOutputStream();
			String codedFileName = "任务附件下载_"+timenow+".zip";  
			if (isIE(request)) {
				codedFileName = java.net.URLEncoder.encode(codedFileName, "UTF8");
			} else {
				codedFileName = new String(codedFileName.getBytes("UTF-8"), "ISO-8859-1");
			}
			
			zipOutputStream = new ZipOutputStream(outputStream);  
			
			response.setContentType("application/octet-stream ");  
			response.setHeader("Connection", "close"); // 表示不能用浏览器直接打开  
			response.setHeader("Accept-Ranges", "bytes");// 告诉客户端允许断点续传多线程连接下载  
			response.setHeader("Content-Disposition",  
					"attachment;filename=" + codedFileName);  
			response.setCharacterEncoding("UTF-8"); 
			
			ossClient = new OSSClient(CustomerConstant.ENDPOINT, CustomerConstant.ACCESSKEY_ID, CustomerConstant.ACCESSKEY_SECRET);
			for (Map<String, Object> map : fileInfo) {
				String fileUrl = map.get("file_url").toString();
				String fileName = projectMap.get(map.get("busi_id").toString())+ "_"+map.get("file_name").toString();
				
				OSSObject ossObject = ossClient.getObject(CustomerConstant.BUCKETNAME, fileUrl);
	 			inputStream = new BufferedInputStream(ossObject.getObjectContent());
	 			
	 			ZipEntry entry = new ZipEntry(fileName);  
				zipOutputStream.putNextEntry(entry);  
				
				byte[] buf = new byte[1024];
		        int len;
		        while ((len = inputStream.read(buf)) > 0) {
		        	zipOutputStream.write(buf, 0, len);
		        }
			}
			// 关闭client
			ossClient.shutdown();
			zipOutputStream.flush();  
		} catch (Exception e) {
			logger.info("--通过流的方式获取文件异常--" + e.getMessage());
		}finally{
			try {
				if(zipOutputStream != null) {
					zipOutputStream.close(); 
				}
				if(inputStream != null){
					inputStream.close();
				}
				if(outputStream != null){
					outputStream.close();
				}
			} catch (IOException e) {
				org.jeecgframework.core.util.LogUtil.error(e.getMessage());
			}
		}
	}
	
	boolean isIE(HttpServletRequest request) {
		return (request.getHeader("USER-AGENT").toLowerCase().indexOf("msie") > 0 || request.getHeader("USER-AGENT").toLowerCase().indexOf("rv:11.0") > 0) ? true : false;
	}
	
	private void setOutTimeMsg(ProjecttaskEntity task) {
		if(task.getExeendtime() == null && task.getPlanendtime().compareTo(new Date()) < 0) {
			task.setOuttimemsg("已逾期");
		}
		if(task.getExeendtime() != null && task.getExeendtime().compareTo(task.getPlanendtime()) > 0) {
			task.setOuttimemsg("逾期完成");
		}
	}
	@RequestMapping(params = "downloadAttrByTask")
	public void downloadAttrByTask(String taskid, HttpServletRequest request, HttpServletResponse response) {
		String deptSql = "select  dept.departname as projectname ,task.taskplanid as id from p_projecttask task   \n"
				+ "left join t_s_depart dept on task.projectid = dept.id \n" + "where task.id =? " ;
		List<Map<String, Object>> projectinfo = systemService.findForJdbc(deptSql, taskid);
		HashMap<String, String> projectMap = new HashMap<String, String>();
		for (Map<String, Object> map : projectinfo) {
			projectMap.put(map.get("id").toString(), map.get("projectname").toString());
		}
		String fileInfoSql = "select file_url,file_name,busi_id\n" + "from t_sys_file  file  where file.busi_id =? ";
		List<Map<String, Object>> fileInfo = systemService.findForJdbc(fileInfoSql, projectinfo.get(0).get("id".toString()));
		if (fileInfo.size() == 0) {
			return;
		}
		zipfiles(fileInfo, projectMap, request, response);
	}
}