11°

[Spring cloud 一步步实现广告系统] 18. 查询返回广告创意

根据三个维度继续过滤

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

  • 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;
}</code></pre> 
  • 定义三个方法实现过滤
/**
     * 获取三个维度各自满足时的广告id
     */
    private Set<Long> getOrRelationUnitIds(Set<Long> adUnitIdsSet,
                                           KeywordFeature keywordFeature,
                                           HobbyFeatrue hobbyFeatrue,
                                           DistrictFeature districtFeature) {
        if (CollectionUtils.isEmpty(adUnitIdsSet)) return Collections.EMPTY_SET;
    // 我们在处理的时候,需要对副本进行处理,大家可以考虑一下为什么需要这么做?
    Set&lt;Long&gt; keywordUnitIdSet = new HashSet&lt;&gt;(adUnitIdsSet);
    Set&lt;Long&gt; hobbyUnitIdSet = new HashSet&lt;&gt;(adUnitIdsSet);
    Set&lt;Long&gt; districtUnitIdSet = new HashSet&lt;&gt;(adUnitIdsSet);

    filterKeywordFeature(keywordUnitIdSet, keywordFeature);
    filterHobbyFeature(hobbyUnitIdSet, hobbyFeatrue);
    filterDistrictFeature(districtUnitIdSet, districtFeature);

    // 返回它们的并集
    return new HashSet&lt;&gt;(
            CollectionUtils.union(
                    CollectionUtils.union(keywordUnitIdSet, hobbyUnitIdSet),
                    districtUnitIdSet
            )
    );
}

/**
 * 根据传递的关键词过滤
 */
private void filterKeywordFeature(Collection&lt;Long&gt; adUnitIds, KeywordFeature keywordFeature) {
    if (CollectionUtils.isEmpty(adUnitIds)) return;
    if (CollectionUtils.isNotEmpty(keywordFeature.getKeywords())) {
        // 如果存在需要过滤的关键词,查找索引实例对象进行过滤处理
        CollectionUtils.filter(
                adUnitIds,
                adUnitId -&gt; IndexDataTableUtils.of(UnitKeywordIndexAwareImpl.class)
                                               .match(adUnitId, keywordFeature.getKeywords())
        );
    }
}

/**
 * 根据传递的兴趣信息过滤
 */
private void filterHobbyFeature(Collection&lt;Long&gt; adUnitIds, HobbyFeatrue hobbyFeatrue) {
    if (CollectionUtils.isEmpty(adUnitIds)) return;
    // 如果存在需要过滤的兴趣,查找索引实例对象进行过滤处理
    if (CollectionUtils.isNotEmpty(hobbyFeatrue.getHobbys())) {
        CollectionUtils.filter(
                adUnitIds,
                adUnitId -&gt; IndexDataTableUtils.of(UnitHobbyIndexAwareImpl.class)
                                               .match(adUnitId, hobbyFeatrue.getHobbys())
        );
    }
}

/**
 * 根据传递的地域信息过滤
 */
private void filterDistrictFeature(Collection&lt;Long&gt; adUnitIds, DistrictFeature districtFeature) {
    if (CollectionUtils.isEmpty(adUnitIds)) return;
    // 如果存在需要过滤的地域信息,查找索引实例对象进行过滤处理
    if (CollectionUtils.isNotEmpty(districtFeature.getProvinceAndCities())) {
        CollectionUtils.filter(
                adUnitIds,
                adUnitId -&gt; {
                    return IndexDataTableUtils.of(UnitDistrictIndexAwareImpl.class)
                                              .match(adUnitId, districtFeature.getProvinceAndCities());
                }
        );
    }
}</code></pre> 
根据推广单元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&lt;Long&gt; result = new ArrayList&lt;&gt;();
    for (AdUnitIndexObject unitIndexObject : unitIndexObjects) {
        //根据推广单元id获取推广创意
        Set&lt;Long&gt; adCreativeIds = unitRelationCreativeMap.get(unitIndexObject.getUnitId());
        if (CollectionUtils.isNotEmpty(adCreativeIds)) result.addAll(adCreativeIds);
    }

    return result;
}</code></pre> 

然后得到了推广创意的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 -&gt; unitIndexObject.getUnitStatus().equals(status.getStatus()) &amp;&amp;
                  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&lt;SearchResponse.Creative&gt; result = new ArrayList&lt;&gt;();
//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&lt;AdSlot&gt; 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&lt;String, List&lt;SearchResponse.Creative&gt;&gt; adSlotRelationAds = response.getAdSlotRelationAds();

    for (AdSlot adSlot : adSlotList) {
        Set&lt;Long&gt; targetUnitIdSet;
        //根据流量类型从缓存中获取 初始 广告信息
        Set&lt;Long&gt; 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&lt;AdUnitIndexObject&gt; unitIndexObjects = IndexDataTableUtils.of(AdUnitIndexAwareImpl.class)
                                                                      .fetch(targetUnitIdSet);
        //根据状态过滤数据
        filterAdUnitAndPlanStatus(unitIndexObjects, CommonStatus.VALID);

        //获取 推广创意 id list
        List&lt;Long&gt; creativeIds = IndexDataTableUtils.of(CreativeRelationUnitIndexAwareImpl.class)
                                                    .selectAdCreativeIds(unitIndexObjects);
        //根据 推广创意ids获取推广创意
        List&lt;CreativeIndexObject&gt; creativeIndexObjects = IndexDataTableUtils.of(CreativeIndexAwareImpl.class)
                                                                            .fetch(creativeIds);

        //根据 广告位adslot 实现对创意数据的过滤
        filterCreativeByAdSlot(creativeIndexObjects, adSlot.getWidth(), adSlot.getHeight(), adSlot.getType());

        //一个广告位可以展示多个广告,也可以仅展示一个广告,具体根据业务来定
        adSlotRelationAds.put(
                adSlot.getAdSlotCode(),
                buildCreativeResponse(creativeIndexObjects)
        );
    }

    return response;
}
...</code></pre> 
检索服务对外提供
  • 暴露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 设置的路径进行截取,默认转发会截取掉配置的前缀

本文转载自博客园,原文链接:https://www.cnblogs.com/zhangpan1244/p/11349029.html

全部评论: 0

    我有话说: