import org.activiti.engine.task.Attachment; //导入依赖的package包/类
@Test
public void taskQueryTest() {
    List<String> array = new ArrayList<>();
    array.add("001");
    array.add("002");
    List<Task> taskList = taskService.createTaskQuery()
            .processInstanceId("")
            .processDefinitionKey("请假流程")
            .processDefinitionId("")
            .processDefinitionName("")
            .processCategoryIn(array)
            .processInstanceBusinessKey("")
            // ...
            .list();
    logger.info("###================================================ taskList, {}", taskList);

    taskList = taskService.createNativeTaskQuery()
            .sql("")
            .parameter("", "")
            .list();
    logger.info("###================================================ taskList, {}", taskList);

    // 创建流程附件
    Attachment attachment = taskService.createAttachment("", "", "", "", "", "");
    logger.info("###================================================ attachment, {}", attachment);
}
 

import org.activiti.engine.task.Attachment; //导入依赖的package包/类
/**
 * 文件类型的附件
 */
@RequestMapping(value = "new/file")
public String newFile(@RequestParam("taskId") String taskId, @RequestParam(value = "processInstanceId", required = false) String processInstanceId,
                      @RequestParam("attachmentName") String attachmentName, @RequestParam(value = "attachmentDescription", required = false) String attachmentDescription,
                      @RequestParam("file") MultipartFile file, HttpSession session) {
    try {
        String attachmentType = file.getContentType() + ";" + FilenameUtils.getExtension(file.getOriginalFilename());
        identityService.setAuthenticatedUserId(UserUtil.getUserFromSession(session).getId());
        Attachment attachment = taskService.createAttachment(attachmentType, taskId, processInstanceId, attachmentName, attachmentDescription,
                file.getInputStream());
        taskService.saveAttachment(attachment);
    } catch (IOException e) {
        e.printStackTrace();
    }
    return "redirect:/chapter6/task/getform/" + taskId;
}
 

import org.activiti.engine.task.Attachment; //导入依赖的package包/类
public AttachmentDetailPopupWindow(Attachment attachment) {
  super(attachment.getName());
  
  addStyleName(Reindeer.PANEL_LIGHT);
  center();
  setModal(true);
  setResizable(false);
  
  AttachmentRenderer renderer = ExplorerApp.get().getAttachmentRendererManager().getRenderer(attachment.getType());
  Component detail = renderer.getDetailComponent(attachment);
  
  if(detail instanceof ComponentContainer) {
    setContent((ComponentContainer) detail);
  } else {
    addComponent(detail);
  }
  getContent().setSizeUndefined();
}
 

import org.activiti.engine.task.Attachment; //导入依赖的package包/类
public Component getOverviewComponent(final Attachment attachment, final RelatedContentComponent parent) {
  
  // If the attachment has no description, overview link is link to actual page
  // instead of showing popup with details.
  if(attachment.getDescription() != null && !"".equals(attachment.getDescription())) {
    Button attachmentLink = new Button(attachment.getName());
    attachmentLink.addStyleName(Reindeer.BUTTON_LINK);
    
    attachmentLink.addListener(new ClickListener() {
      private static final long serialVersionUID = 1L;
      
      public void buttonClick(ClickEvent event) {
        parent.showAttachmentDetail(attachment);
      }
    });
    return attachmentLink;
  } else {
    return new Link(attachment.getName(), new ExternalResource(attachment.getUrl()));
  }
}
 

import org.activiti.engine.task.Attachment; //导入依赖的package包/类
public Component getDetailComponent(Attachment attachment) {
  VerticalLayout verticalLayout = new VerticalLayout();
  verticalLayout.setSpacing(true);
  verticalLayout.setMargin(true);
  
  verticalLayout.addComponent(new Label(attachment.getDescription()));
  
  HorizontalLayout linkLayout = new HorizontalLayout();
  linkLayout.setSpacing(true);
  verticalLayout.addComponent(linkLayout);
  
  // Icon
  linkLayout.addComponent(new Embedded(null, Images.RELATED_CONTENT_URL));
  
  // Link
  Link link = new Link(attachment.getUrl(), new ExternalResource(attachment.getUrl()));
  link.setTargetName(ExplorerLayout.LINK_TARGET_BLANK);
  linkLayout.addComponent(link);
  
  return verticalLayout;
}
 

import org.activiti.engine.task.Attachment; //导入依赖的package包/类
public FileAttachmentEditorComponent(Attachment attachment, String taskId, String processInstanceId) {
  this.attachment = attachment;
  this.taskId = taskId;
  this.processInstanceId = processInstanceId;
  
  this.i18nManager = ExplorerApp.get().getI18nManager();
  taskService = ProcessEngines.getDefaultProcessEngine().getTaskService();
  
  form = new Form();
  form.setDescription(i18nManager.getMessage(Messages.RELATED_CONTENT_TYPE_FILE_HELP));
  setSizeFull();
  addComponent(form);
  initSuccessIndicator();
  initFileUpload();
  initName();
  initDescription();
}
 

import org.activiti.engine.task.Attachment; //导入依赖的package包/类
public Attachment getAttachment() throws InvalidValueException {
  // Force validation of the fields
  form.commit();
  
  // Check if file is uploaded
  if(!fileUploaded) {
    InvalidValueException ive = new InvalidValueException(i18nManager.getMessage(Messages.RELATED_CONTENT_TYPE_FILE_REQUIRED));
    form.setComponentError(ive);
    throw ive;
  }
  
  if(attachment != null) {
    applyValuesToAttachment();
  } else {
    // Create new attachment based on values
    // TODO: use explorerApp to get services
    attachment = taskService.createAttachment(mimeType, taskId, processInstanceId, 
        getAttachmentName(), getAttachmentDescription(), new ByteArrayInputStream(byteArrayOutputStream.toByteArray()));
  }
  return attachment;
}
 

import org.activiti.engine.task.Attachment; //导入依赖的package包/类
public void refreshTaskAttachments() {
  table.removeAllItems();
  if (noContentLabel != null) {
    contentLayout.removeComponent(noContentLabel);
  }
  
  List<Attachment> attachments = null;
  if (task.getProcessInstanceId() != null){
    attachments = (taskService.getProcessInstanceAttachments(task.getProcessInstanceId()));
  } else {
    attachments = taskService.getTaskAttachments(task.getId());
  }
  
  if(attachments.size() > 0) {
    addAttachmentsToTable(attachments);
  } else {
    table.setVisible(false);
    noContentLabel = new Label(i18nManager.getMessage(Messages.TASK_NO_RELATED_CONTENT));
    noContentLabel.addStyleName(Reindeer.LABEL_SMALL);
    contentLayout.addComponent(noContentLabel);
  }
}
 

import org.activiti.engine.task.Attachment; //导入依赖的package包/类
protected void addAttachmentsToTable(List<Attachment> attachments) {
  for (Attachment attachment : attachments) {
    AttachmentRenderer renderer = attachmentRendererManager.getRenderer(attachment);
    Item attachmentItem = table.addItem(attachment.getId());
    attachmentItem.getItemProperty("name").setValue(renderer.getOverviewComponent(attachment, this));
    attachmentItem.getItemProperty("type").setValue(new Embedded(null, renderer.getImage(attachment)));
    
    Embedded deleteButton = new Embedded(null, Images.DELETE);
    deleteButton.addStyleName(ExplorerLayout.STYLE_CLICKABLE);
    deleteButton.addListener((ClickListener) new DeleteClickedListener(attachment));
    attachmentItem.getItemProperty("delete").setValue(deleteButton);
  }
  
  if(table.getItemIds().size() > 0) {
    table.setVisible(true);
  }
  table.setPageLength(table.size());
}
 

import org.activiti.engine.task.Attachment; //导入依赖的package包/类
@Put
public AttachmentResponse addAttachment(Representation entity) {
  if(authenticate() == false) return null;
  
  String taskId = (String) getRequest().getAttributes().get("taskId");
  
  try {
    RestletFileUpload upload = new RestletFileUpload(new DiskFileItemFactory());
    List<FileItem> items = upload.parseRepresentation(entity);
    
    FileItem uploadItem = null;
    for (FileItem fileItem : items) {
      if(fileItem.getName() != null) {
        uploadItem = fileItem;
      }
    }
    
    String fileName = uploadItem.getName();
    
    Attachment attachment = ActivitiUtil.getTaskService().createAttachment(
        uploadItem.getContentType(), taskId, null, fileName, fileName, uploadItem.getInputStream());
    
    return new AttachmentResponse(attachment);
    
  } catch(Exception e) {
    throw new ActivitiException("Unable to add new attachment to task " + taskId);
  }
}
 

import org.activiti.engine.task.Attachment; //导入依赖的package包/类
public Attachment execute(CommandContext commandContext) {

    verifyParameters(commandContext);
    
    AttachmentEntity attachment = new AttachmentEntity();
    attachment.setName(attachmentName);
    attachment.setDescription(attachmentDescription);
    attachment.setType(attachmentType);
    attachment.setTaskId(taskId);
    attachment.setProcessInstanceId(processInstanceId);
    attachment.setUrl(url);
    
    DbSqlSession dbSqlSession = commandContext.getDbSqlSession();
    dbSqlSession.insert(attachment);
    
    if (content != null) {
      byte[] bytes = IoUtil.readInputStream(content, attachmentName);
      ByteArrayEntity byteArray = ByteArrayEntity.createAndInsert(bytes);
      attachment.setContentId(byteArray.getId());
    }

    commandContext.getHistoryManager()
      .createAttachmentComment(taskId, processInstanceId, attachmentName, true);
    
    return attachment;
  }
 

import org.activiti.engine.task.Attachment; //导入依赖的package包/类
@Deployment(resources = { "org/activiti/engine/test/api/oneTaskProcess.bpmn20.xml" })
public void testTaskAttachmentWithProcessInstanceId() {
  if (processEngineConfiguration.getHistoryLevel().isAtLeast(HistoryLevel.ACTIVITY)) {
    
    ProcessInstance processInstance = runtimeService.startProcessInstanceByKey("oneTaskProcess");
    
    String processInstanceId = processInstance.getId();
    taskService.createAttachment("web page", null, processInstanceId, "weatherforcast", "temperatures and more", "http://weather.com");
    Attachment attachment = taskService.getProcessInstanceAttachments(processInstanceId).get(0);
    assertEquals("weatherforcast", attachment.getName());
    assertEquals("temperatures and more", attachment.getDescription());
    assertEquals("web page", attachment.getType());
    assertEquals(processInstanceId, attachment.getProcessInstanceId());
    assertNull(attachment.getTaskId());
    assertEquals("http://weather.com", attachment.getUrl());
    assertNull(taskService.getAttachmentContent(attachment.getId()));
    
    // Finally, clean up
    taskService.deleteAttachment(attachment.getId());
    
    // TODO: Bad API design. Need to fix attachment/comment properly
    ((TaskServiceImpl) taskService).deleteComments(null, processInstanceId);
  }
}
 

import org.activiti.engine.task.Attachment; //导入依赖的package包/类
/**
 * 下载附件
 *
 * @throws IOException
 */
@RequestMapping(value = "download/{attachmentId}")
public void downloadFile(@PathVariable("attachmentId") String attachmentId, HttpServletResponse response) throws IOException {
    Attachment attachment = taskService.getAttachment(attachmentId);
    InputStream attachmentContent = taskService.getAttachmentContent(attachmentId);
    String contentType = StringUtils.substringBefore(attachment.getType(), ";");
    response.addHeader("Content-Type", contentType + ";charset=UTF-8");
    String extensionFileName = StringUtils.substringAfter(attachment.getType(), ";");
    String fileName = attachment.getName() + "." + extensionFileName;
    response.setHeader("Content-Disposition", "attachment; filename=" + fileName);
    IOUtils.copy(new BufferedInputStream(attachmentContent), response.getOutputStream());
}
 

import org.activiti.engine.task.Attachment; //导入依赖的package包/类
/**
 * 查看已结束任务
 */
@RequestMapping(value = "task/archived/{taskId}")
public ModelAndView viewHistoryTask(@PathVariable("taskId") String taskId) throws Exception {
    String viewName = "chapter6/task-form-archived";
    ModelAndView mav = new ModelAndView(viewName);
    HistoricTaskInstance task = historyService.createHistoricTaskInstanceQuery().taskId(taskId).singleResult();
    if (task.getParentTaskId() != null) {
        HistoricTaskInstance parentTask = historyService.createHistoricTaskInstanceQuery().taskId(task.getParentTaskId()).singleResult();
        mav.addObject("parentTask", parentTask);
    }
    mav.addObject("task", task);

    // 读取子任务
    List<HistoricTaskInstance> subTasks = historyService.createHistoricTaskInstanceQuery().taskParentTaskId(taskId).list();
    mav.addObject("subTasks", subTasks);

    // 读取附件
    List<Attachment> attachments = null;
    if (task.getTaskDefinitionKey() != null) {
        attachments = taskService.getTaskAttachments(taskId);
    } else {
        attachments = taskService.getProcessInstanceAttachments(task.getProcessInstanceId());
    }
    mav.addObject("attachments", attachments);

    return mav;
}