当前位置: 首页 > news >正文

Java8 根据List实体中一个字段去重取最大值,并且根据该字段进行排序

1、前言

某个功能要求需要对一个list对象里数据按照股票分组,并且取分组涨跌幅最大的,返回一个新的list对象,并且按照涨跌幅字段进行排序,这么一连串的要求,如果按照传统的写法,我们需要写一大坨的代码,代码很是啰嗦,我们可以选择使用java8中的Collectors.groupingByCollectors.maxBy 来按照某个字段先进行分组,在取分组中某个最大值,最后收集到一个列表中。话不多说,上代码!
2、主要内容

实体

@Builder
@Data
@ApiModel("个股行情")
public class StockHq implements Serializable {private static final long serialVersionUID = 5061852660593543033L;/*** 表id*/@ApiModelProperty("表id")@TableId(value = "id", type = IdType.AUTO)private Long id;/*** 交易日期*/@ApiModelProperty("交易日期 ")@TableField("trade_date")private Integer tradeDate;/*** 证券id*/@ApiModelProperty("证券id")@TableField("stock_id")private Integer stockId;/*** 股票代码*/@ApiModelProperty("交易日期  ")@TableField("stock_code")private String stockCode;/*** 股票名称*/@ApiModelProperty("股票名称")@TableField("stock_name")private String stockName;@ApiModelProperty("上榜日涨幅")@TableField("price_chg")private BigDecimal priceChg;@ApiModelProperty("收盘价")@TableField("price_now")private BigDecimal priceNow;@ApiModelProperty("成交数量")@TableField("trade_amount")private Integer tradeAmount;@NumberField(type = 1)@ApiModelProperty("成交金额")@TableField("trade_money")private BigDecimal tradeMoney;
}

使用collect方法,结合collect中的Collectors.groupingByCollectors.maxBy

      List<StockHq> stockHqList = new ArrayList<>();stockHqList.add(StockHq.builder().stockCode("603386").stockId(100603386).stockName("骏亚科技").priceChg(new BigDecimal("10.3")).tradeDate(20200101).build());stockHqList.add(StockHq.builder().stockCode("603386").stockId(100603386).stockName("骏亚科技").priceChg(new BigDecimal("9.3")).tradeDate(20200111).build());stockHqList.add(StockHq.builder().stockCode("000737").stockId(200000737).stockName("北方铜业").priceChg(new BigDecimal("1.3")).tradeDate(20240711).build());stockHqList.add(StockHq.builder().stockCode("000737").stockId(200000737).stockName("北方铜业").priceChg(new BigDecimal("134.2")).tradeDate(20240611).build());List<StockHq> lastStockHqList = stockHqList.stream().collect(Collectors.groupingBy(StockHq::getStockCode, Collectors.maxBy(Comparator.comparing(StockHq::getPriceChg)))).values().stream().map(Optional::get).sorted(Comparator.comparing(StockHq::getPriceChg).reversed())//降序.collect(Collectors.toList());//返回一个list

代码就用一行,代码简单名了,特此写文章作为笔记,希望能对你有所帮助。

http://www.lryc.cn/news/400587.html

相关文章:

  • 微服务经纬:Eureka驱动的分布式服务网格配置全解
  • 关于前端数据库可视化库的选择,vue3+antd+g2plot录课计划
  • linux进行redis的安装并使用RDB进行数据迁移
  • 深入理解Scikit-learn:决策树与随机森林算法详解
  • AutoHotKey自动热键(十一)下载SciTE4AutoHotkey-Plus的中文增强版脚本编辑器
  • Halcon与C++之间的数据转换
  • MybatisPlus 一些技巧
  • 定制化服务发现:Eureka中服务实例偏好的高级配置
  • 【实战场景】MongoDB迁移的那些事
  • 为什么要使用加密软件?
  • k8s学习笔记——dashboard安装
  • AI艺术创作:掌握Midjourney和DALL-E的技巧与策略
  • 在Mac上免费恢复误删除的Word文档
  • HarmonyOS 屏幕适配设计
  • Netfilter之连接跟踪(Connection Tracking)和反向 SNAT(Reverse SNAT)
  • Linux下使用vs code离线安装各种插件
  • 【常见开源库的二次开发】基于openssl的加密与解密——Base58比特币钱包地址——算法分析(三)
  • Linux操作系统——数据库
  • 【数据结构与算法】希尔排序:基于插入排序的高效排序算法
  • 关于正点原子的alpha开发板的启动函数(汇编,自己的认识)
  • Deep Layer Aggregation【方法部分解读】
  • 大数据面试SQL题-笔记01【运算符、条件查询、语法顺序、表连接】
  • 零基础自学爬虫技术该从哪里开始入手?
  • CV11_模型部署pytorch转ONNX
  • Redis的使用(四)常见使用场景-缓存使用技巧
  • BERT架构的深入解析
  • 数字孪生技术如何助力低空经济飞跃式发展?
  • HTTP背后的故事:理解现代网络如何工作的关键(二)
  • 数据流通环节如何规避安全风险
  • 部署k8s 1.28.9版本