Java Lambda 用法

按分组获取分组中最新一条记录

/**
 * 历史任务实体类
 */
@Data
@NoArgsConstructor
public class HistoryTask implements Serializable {
	private static final long serialVersionUID = 7925632180050362451L;
	/**
	 * 主键ID
	 */
	private String id;
  /**
   * 流程实例ID
   */
  private String orderId;
  /**
   * 任务名称
   */
	private String taskName;
	/**
	 * 任务显示名称
	 */
	private String displayName;
  /**
   * 任务处理者ID
   */
  private String operator;
  /**
   * 任务创建时间
   */
  private String createTime;
  /**
   * 任务完成时间
   */
  private String finishTime;
}

public Map<String, HistoryTask> getLatest(List<HistoryTask> historyTasks) {
  return historyTasks.stream().collect(
    // 根据任务处理者 Id 分组，获取各自分组中最新的一条记录
    Collectors.toMap(
      HistoryTask::getOperator,
      Function.identity(),
      (h1, h2) -> {
        try {
          Date date1 = DateUtil.parseDate(h1.getFinishTime(), "yyyy-MM-dd HH:mm:ss");
          Date date2 = DateUtil.parseDate(h2.getFinishTime(), "yyyy-MM-dd HH:mm:ss");
          return date1.after(date2) ? h1 : h2;
        } catch (ParseException e) {
          // ignore
        }
        return h1;
      })
  );
}

List<HistoryTask> historyTasks = ...
historyTasks = new ArrayList<>(getLatest(historyTasks).values());