阅读量:2
1、前言
某个功能要求需要对一个list对象里数据按照股票分组,并且取分组涨跌幅最大的,返回一个新的list对象,并且按照涨跌幅字段进行排序,这么一连串的要求,如果按照传统的写法,我们需要写一大坨的代码,代码很是啰嗦,我们可以选择使用java8中的Collectors.groupingBy和
Collectors.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.groupingBy和
Collectors.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
代码就用一行,代码简单名了,特此写文章作为笔记,希望能对你有所帮助。