枚举是实现接口，匿名内部类扩展function实现

/** * 回传事件接口 * 用于构建参数 * * @Author */ public interface EventBase { /** * 构建参数 * @return */ Function<CallBackParamDataBO,Map<String, Object>> buildParam(); /** * 获取验重值 * @return */ Function<CallBackParamDataBO,String> getRepeatValue(); /** * 获取前置事件（每个事件自己定义依赖关系） */ EventBase getPreEvents(); String getCode(); String getName(); }

@Getter @AllArgsConstructor public enum AFS2SEventNewEnum implements EventBase { PURCHASE("af_purchase", "购买") { @Override public Function<CallBackParamDataBO, Map<String, Object>> buildParam() { return data -> { CallBackParamDataBO.OrderInfo orderBaseInfo = data.getOrderBaseInfo(); String afContentType = null; String afContent = null; if (Objects.nonNull(orderBaseInfo)) { //C币充值 if (Integer.valueOf(1).equals(orderBaseInfo.getOrderType())) { afContentType = "C币充值"; afContent = "C币充值:充值" + orderBaseInfo.getRealityNum() + "币"; } //会员充值 if (Integer.valueOf(2).equals(orderBaseInfo.getOrderType())) { afContentType = "会员充值"; afContent = switch (orderBaseInfo.getValidTimeType()) { case 1 -> "周会员"; case 2 -> "月会员"; case 3 -> "季会员"; case 4 -> "年会员"; case 5 -> "天会员"; default -> "会员充值"; }; if ("sign".equals(orderBaseInfo.getPayType())) { afContent += "(自动续期)"; } } //看点充值 if (Integer.valueOf(3).equals(orderBaseInfo.getOrderType())) { afContentType = "整剧购买"; afContent = "整剧购买:" + orderBaseInfo.getVideoName(); } //3日金币包 if (Integer.valueOf(4).equals(orderBaseInfo.getOrderType())) { afContentType = "3日金币包"; afContent = "3日金币包:充值" + orderBaseInfo.getRealityNum() + "币"; } } return MapUtil.<String, Object>builder() .put("af_revenue", Optional.ofNullable(data.getOrderBaseInfo()) .map(CallBackParamDataBO.OrderInfo::getOrderAmountYuan) .orElse("0"))//订单总额 // .put("af_price",Optional.ofNullable(data.getOrderBaseInfo()) // .map(CallBackParamDataBO.OrderInfo::getCurrencyAmount) // .orElse(BigDecimal.ZERO))//订单总额 .put("af_currency", "USD") .put("af_content_type", StringUtils.isNotBlank(afContentType)?afContentType:"整剧购买")//产品品类： 会员充值、看点充值、整剧购买 .put("af_content_id", String.valueOf(Optional.ofNullable(data.getOrderBaseInfo()) .map(CallBackParamDataBO.OrderInfo::getOrderId) .orElse(0L))) //订单号 .put("af_content", afContent)//内容标题 会员充值：周会员（自动续期）/月会员（自动续期）/季会员（自动续期）/年会员（自动续期）； 看点充值：充值1000看点； 注：1000为充值C币额度，此额度为实际充值到账金额； 整剧购买：购买剧名； .build(); }; } @Override public Function<CallBackParamDataBO, String> getRepeatValue() { return data -> { long orderId = Optional.ofNullable(data.getOrderBaseInfo()) .map(CallBackParamDataBO.OrderInfo::getOrderId) .orElse(0L); return orderId + "_" + this.getCode(); }; } } }