Spring cloud 查询返回创意实例代码

 更新时间:2019年08月14日 08:30:11   作者:zhangpan0614   我要评论
在本篇文章里小编给大家整理的是关于Spring cloud 查询返回创意实例代码,需要的朋友们可以跟着学习下。

根据三个维度继续过滤

在上一节中我们实现了根据流量信息过滤的代码,但是我们的条件有可能是多条件一起传给我们的检索服务的,本节我们继续实现根据单元的三个维度条件的过滤。

在SearchImpl类中添加过滤方法

public class SearchImpl implements ISearch {
  @Override
  public SearchResponse fetchAds(SearchRequest request) {
    ...
      // 根据三个维度过滤
      if (featureRelation == FeatureRelation.AND) {
        filterKeywordFeature(adUnitIdSet, keywordFeature);
        filterHobbyFeature(adUnitIdSet, hobbyFeatrue);
        filterDistrictFeature(adUnitIdSet, districtFeature);
        targetUnitIdSet = adUnitIdSet;
      } else {
        getOrRelationUnitIds(adUnitIdSet, keywordFeature, hobbyFeatrue, districtFeature);
      }
    }
    return null;
  }

定义三个方法实现过滤

/**
   * 获取三个维度各自满足时的id
   */
  private Set<Long> getOrRelationUnitIds(Set<Long> adUnitIdsSet,
                      KeywordFeature keywordFeature,
                      HobbyFeatrue hobbyFeatrue,
                      DistrictFeature districtFeature) {
    if (CollectionUtils.isEmpty(adUnitIdsSet)) return Collections.EMPTY_SET;
    // 我们在处理的时候,需要对副本进行处理,大家可以考虑一下为什么需要这么做?
    Set<Long> keywordUnitIdSet = new HashSet<>(adUnitIdsSet);
    Set<Long> hobbyUnitIdSet = new HashSet<>(adUnitIdsSet);
    Set<Long> districtUnitIdSet = new HashSet<>(adUnitIdsSet);
    filterKeywordFeature(keywordUnitIdSet, keywordFeature);
    filterHobbyFeature(hobbyUnitIdSet, hobbyFeatrue);
    filterDistrictFeature(districtUnitIdSet, districtFeature);
    // 返回它们的并集
    return new HashSet<>(
        CollectionUtils.union(
            CollectionUtils.union(keywordUnitIdSet, hobbyUnitIdSet),
            districtUnitIdSet
        )
    );
  }
  /**
   * 根据传递的关键词过滤
   */
  private void filterKeywordFeature(Collection<Long> adUnitIds, KeywordFeature keywordFeature) {
    if (CollectionUtils.isEmpty(adUnitIds)) return;
    if (CollectionUtils.isNotEmpty(keywordFeature.getKeywords())) {
      // 如果存在需要过滤的关键词,查找索引实例对象进行过滤处理
      CollectionUtils.filter(
          adUnitIds,
          adUnitId -> IndexDataTableUtils.of(UnitKeywordIndexAwareImpl.class)
                          .match(adUnitId, keywordFeature.getKeywords())
      );
    }
  }
  /**
   * 根据传递的兴趣信息过滤
   */
  private void filterHobbyFeature(Collection<Long> adUnitIds, HobbyFeatrue hobbyFeatrue) {
    if (CollectionUtils.isEmpty(adUnitIds)) return;
    // 如果存在需要过滤的兴趣,查找索引实例对象进行过滤处理
    if (CollectionUtils.isNotEmpty(hobbyFeatrue.getHobbys())) {
      CollectionUtils.filter(
          adUnitIds,
          adUnitId -> IndexDataTableUtils.of(UnitHobbyIndexAwareImpl.class)
                          .match(adUnitId, hobbyFeatrue.getHobbys())
      );
    }
  }
  /**
   * 根据传递的地域信息过滤
   */
  private void filterDistrictFeature(Collection<Long> adUnitIds, DistrictFeature districtFeature) {
    if (CollectionUtils.isEmpty(adUnitIds)) return;
    // 如果存在需要过滤的地域信息,查找索引实例对象进行过滤处理
    if (CollectionUtils.isNotEmpty(districtFeature.getProvinceAndCities())) {
      CollectionUtils.filter(
          adUnitIds,
          adUnitId -> {
            return IndexDataTableUtils.of(UnitDistrictIndexAwareImpl.class)
                         .match(adUnitId, districtFeature.getProvinceAndCities());
          }
      );
    }
  }

根据单元id获取创意

我们知道,单元和创意的关系是多对多,从上文我们查询到了单元ids,接下来我们实现根据单元id获取创意的代码,let's code.

首先,我们需要在com.sxzhongf.ad.index.creative_relation_unit.CreativeRelationUnitIndexAwareImpl 关联索引中查到创意的ids

/**
   * 通过单元id获取创意id
   */
  public List<Long> selectAdCreativeIds(List<AdUnitIndexObject> unitIndexObjects) {
    if (CollectionUtils.isEmpty(unitIndexObjects)) return Collections.emptyList();
    //获取要返回的创意ids
    List<Long> result = new ArrayList<>();
    for (AdUnitIndexObject unitIndexObject : unitIndexObjects) {
      //根据单元id获取创意
      Set<Long> adCreativeIds = unitRelationCreativeMap.get(unitIndexObject.getUnitId());
      if (CollectionUtils.isNotEmpty(adCreativeIds)) result.addAll(adCreativeIds);
    }
    return result;
  }

然后得到了创意的id list后,我们在创意索引实现类com.sxzhongf.ad.index.creative.CreativeIndexAwareImpl中定义根据ids查询创意的方法。

/**
 * 根据ids获取创意list
 */
public List<CreativeIndexObject> findAllByIds(Collection<Long> ids) {
  if (CollectionUtils.isEmpty(ids)) return Collections.emptyList();
  List<CreativeIndexObject> result = new ArrayList<>();
  for (Long id : ids) {
    CreativeIndexObject object = get(id);
    if (null != object)
      result.add(object);
  }
  return result;
}

自此,我们已经得到了想要的单元和创意,因为单元包含了计划,所以我们想要的数据已经全部可以获取到了,接下来,我们还得过滤一次当前我们查询到的数据的状态,因为有的数据,我们可能已经进行过逻辑删除了,因此还需要判断获取的数据是否有效。在SearchImpl类中实现。

 /**
  * 根据状态信息过滤数据
  */
 private void filterAdUnitAndPlanStatus(List<AdUnitIndexObject> unitIndexObjects, CommonStatus status) {
   if (CollectionUtils.isEmpty(unitIndexObjects)) return;
   //同时判断单元和计划的状态
   CollectionUtils.filter(
       unitIndexObjects,
       unitIndexObject -> unitIndexObject.getUnitStatus().equals(status.getStatus()) &&
           unitIndexObject.getAdPlanIndexObject().getPlanStatus().equals(status.getStatus())
   );
 }

在SearchImpl中我们实现创意的查询.

...
//获取 计划 对象list
List<AdUnitIndexObject> unitIndexObjects = IndexDataTableUtils.of(AdUnitIndexAwareImpl.class).fetch(adUnitIdSet);
//根据状态过滤数据
filterAdUnitAndPlanStatus(unitIndexObjects, CommonStatus.VALID);
//获取 创意 id list
List<Long> creativeIds = IndexDataTableUtils.of(CreativeRelationUnitIndexAwareImpl.class)
                      .selectAdCreativeIds(unitIndexObjects);
//根据 创意ids获取创意
List<CreativeIndexObject> creativeIndexObjects = IndexDataTableUtils.of(CreativeIndexAwareImpl.class)
...

根据位adslot 实现对创意数据的过滤

因为我们的位是有不同的大小,不同的类型,因此,我们在获取到所有符合我们查询维度以及流量类型的条件后,还需要针对不同的位来展示不同的创意信息。

/**
* 根据位类型以及参数获取展示的合适信息
*
* @param creativeIndexObjects 所有创意
* @param width        位width
* @param height        位height
*/
private void filterCreativeByAdSlot(List<CreativeIndexObject> creativeIndexObjects,
                 Integer width,
                 Integer height,
                 List<Integer> type) {
 if (CollectionUtils.isEmpty(creativeIndexObjects)) return;
 CollectionUtils.filter(
     creativeIndexObjects,
     creative -> {
       //审核状态必须是通过
       return creative.getAuditStatus().equals(CommonStatus.VALID.getStatus())
           && creative.getWidth().equals(width)
           && creative.getHeight().equals(height)
           && type.contains(creative.getType());
     }
 );
}

组建搜索返回对象

正常业务场景中,同一个位可以展示多个信息,也可以只展示一个信息,这个需要根据具体的业务场景来做不同的处理,本次为了演示方便,会从返回的创意列表中随机选择一个创意信息进行展示,当然大家也可以根据业务类型,设置不同的优先级或者权重值来进行选择。

/**
 * 从创意列表中随机获取一条创意返回出去
 *
 * @param creativeIndexObjects 创意list
 */
private List<SearchResponse.Creative> buildCreativeResponse(List<CreativeIndexObject> creativeIndexObjects) {
  if (CollectionUtils.isEmpty(creativeIndexObjects)) return Collections.EMPTY_LIST;
  //随机获取一个创意,也可以实现优先级排序,也可以根据权重值等等,具体根据业务
  CreativeIndexObject randomObject = creativeIndexObjects.get(
      Math.abs(new Random().nextInt()) % creativeIndexObjects.size()
  );
  //List<SearchResponse.Creative> result = new ArrayList<>();
  //result.add(SearchResponse.convert(randomObject));
  return Collections.singletonList(
      SearchResponse.convert(randomObject)
  );
}

完整的请求过滤实现方法:

@Service
@Slf4j
public class SearchImpl implements ISearch {
  @Override
  public SearchResponse fetchAds(SearchRequest request) {
    //获取请求位信息
    List<AdSlot> adSlotList = request.getRequestInfo().getAdSlots();
    //获取三个Feature信息
    KeywordFeature keywordFeature = request.getFeatureInfo().getKeywordFeature();
    HobbyFeatrue hobbyFeatrue = request.getFeatureInfo().getHobbyFeatrue();
    DistrictFeature districtFeature = request.getFeatureInfo().getDistrictFeature();
    //Feature关系
    FeatureRelation featureRelation = request.getFeatureInfo().getRelation();
    //构造响应对象
    SearchResponse response = new SearchResponse();
    Map<String, List<SearchResponse.Creative>> adSlotRelationAds = response.getAdSlotRelationAds();
    for (AdSlot adSlot : adSlotList) {
      Set<Long> targetUnitIdSet;
      //根据流量类型从缓存中获取 初始 信息
      Set<Long> adUnitIdSet = IndexDataTableUtils.of(
          AdUnitIndexAwareImpl.class
      ).match(adSlot.getPositionType());
      // 根据三个维度过滤
      if (featureRelation == FeatureRelation.AND) {
        filterKeywordFeature(adUnitIdSet, keywordFeature);
        filterHobbyFeature(adUnitIdSet, hobbyFeatrue);
        filterDistrictFeature(adUnitIdSet, districtFeature);
        targetUnitIdSet = adUnitIdSet;
      } else {
        targetUnitIdSet = getOrRelationUnitIds(adUnitIdSet, keywordFeature, hobbyFeatrue, districtFeature);
      }
      //获取 计划 对象list
      List<AdUnitIndexObject> unitIndexObjects = IndexDataTableUtils.of(AdUnitIndexAwareImpl.class)
                                     .fetch(targetUnitIdSet);
      //根据状态过滤数据
      filterAdUnitAndPlanStatus(unitIndexObjects, CommonStatus.VALID);
      //获取 创意 id list
      List<Long> creativeIds = IndexDataTableUtils.of(CreativeRelationUnitIndexAwareImpl.class)
                            .selectAdCreativeIds(unitIndexObjects);
      //根据 创意ids获取创意
      List<CreativeIndexObject> creativeIndexObjects = IndexDataTableUtils.of(CreativeIndexAwareImpl.class)
                                        .fetch(creativeIds);
      //根据 位adslot 实现对创意数据的过滤
      filterCreativeByAdSlot(creativeIndexObjects, adSlot.getWidth(), adSlot.getHeight(), adSlot.getType());
      //一个位可以展示多个,也可以仅展示一个,具体根据业务来定
      adSlotRelationAds.put(
          adSlot.getAdSlotCode(),
          buildCreativeResponse(creativeIndexObjects)
      );
    }
    return response;
  }
  ...

检索服务对外提供

暴露API接口
上文中,我们实现了检索服务的核心逻辑,接下来,我们需要对外暴露我们的检索服务接口,在SearchController中提供:

@PostMapping("/fetchAd")
  public SearchResponse fetchAdCreative(@RequestBody SearchRequest request) {
    log.info("ad-serach: fetchAd ->{}", JSON.toJSONString(request));
    return search.fetchAds(request);
  }

实现API网关配置

zuul:
routes:
  sponsor: #在路由中自定义服务路由名称
  path: /ad-sponsor/**
  serviceId: mscx-ad-sponsor #微服务name
  strip-prefix: false
  search: #在路由中自定义服务路由名称
  path: /ad-search/**
  serviceId: mscx-ad-search #微服务name
  strip-prefix: false
prefix: /gateway/api
strip-prefix: true #不对 prefix: /gateway/api 设置的路径进行截取,默认转发会截取掉配置的前缀

以上就是本次分享的全部知识点内容,感谢大家对澳门金沙网上娱乐的支持

相关文章

  • RestTemplate集成Ribbbon的示例代码

    RestTemplate集成Ribbbon的示例代码

    这篇文章主要介绍了RestTemplate集成Ribbbon的示例代码,小编觉得挺不错的,现在分享给大家,也给大家做个参考。一起跟随小编过来看看吧
    2018-08-08
  • spring框架配置实体类复杂属性注入xml文件过程详解

    spring框架配置实体类复杂属性注入xml文件过程详解

    这篇文章主要介绍了spring框架配置实体类复杂属性注入xml文件过程详解,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
    2019-09-09
  • 详解 Java Maximum redirects (100) exceeded

    详解 Java Maximum redirects (100) exceeded

    这篇文章主要介绍了详解 Java Maximum redirects (100) exceeded的相关资料,需要的朋友可以参考下
    2017-05-05
  • SpringCloud整合分布式服务跟踪zipkin的实现

    SpringCloud整合分布式服务跟踪zipkin的实现

    这篇文章主要介绍了SpringCloud整合分布式服务跟踪zipkin的实现,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2019-09-09
  • 实例总结Java多线程编程的方法

    实例总结Java多线程编程的方法

    在本篇文章里我们给大家总结了Java多线程编程的方法以及相关实例代码,需要的朋友们可以学习下。
    2018-10-10
  • 详解SpringBoot下文件上传与下载的实现

    详解SpringBoot下文件上传与下载的实现

    这篇文章主要介绍了SpringBoot下文件上传与下载的实现,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2019-05-05
  • java设计模式学习之简单工厂模式

    java设计模式学习之简单工厂模式

    这篇文章主要为大家详细介绍了java设计模式学习之简单工厂模式,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2017-10-10
  • JavaMe开发绘制文本框TextEdit

    JavaMe开发绘制文本框TextEdit

    在JavaMe连载(3)-也说MVC设计模式 一文中提到了一个TextEdit类,但没有给出具体实现,TextEdit是采用GameCanvas绘制的文本编辑器。本文结合实例给出实现的方法。
    2015-09-09
  • Java 关键字 volatile 的理解与正确使用

    Java 关键字 volatile 的理解与正确使用

    本文主要介绍 volatile 的使用准则,以及使用过程中需注意的地方,感兴趣的朋友一起看看吧
    2017-06-06
  • 利用Thumbnailator轻松实现图片缩放、旋转与加水印

    利用Thumbnailator轻松实现图片缩放、旋转与加水印

    java开发中经常遇到对图片的处理,JDK中也提供了对应的工具类,不过处理起来很麻烦,Thumbnailator是一个优秀的图片处理的开源Java类库,处理效果远比Java API的好,这篇文章主要介绍了利用Thumbnailator如何轻松的实现图片缩放、旋转与加水印,需要的朋友可以参考下
    2017-01-01

最新评论