根據(jù)三個維度繼續(xù)過濾

在上一節(jié)中我們實現(xiàn)了根據(jù)流量信息過濾的代碼，但是我們的條件有可能是多條件一起傳給我們的檢索服務(wù)的，本節(jié)我們繼續(xù)實現(xiàn)根據(jù)推廣單元的三個維度條件的過濾。

• 在SearchImpl類中添加過濾方法

public class SearchImpl implements ISearch {@Overridepublic SearchResponse fetchAds(SearchRequest request) {...// 根據(jù)三個維度過濾if (featureRelation == FeatureRelation.AND) {filterKeywordFeature(adUnitIdSet, keywordFeature);filterHobbyFeature(adUnitIdSet, hobbyFeatrue);filterDistrictFeature(adUnitIdSet, districtFeature);targetUnitIdSet = adUnitIdSet;} else {getOrRelationUnitIds(adUnitIdSet, keywordFeature, hobbyFeatrue, districtFeature);}}return null;}

• 定義三個方法實現(xiàn)過濾

/*** 獲取三個維度各自滿足時的廣告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));}/*** 根據(jù)傳遞的關(guān)鍵詞過濾*/private void filterKeywordFeature(Collection<Long> adUnitIds, KeywordFeature keywordFeature) {if (CollectionUtils.isEmpty(adUnitIds)) return;if (CollectionUtils.isNotEmpty(keywordFeature.getKeywords())) {// 如果存在需要過濾的關(guān)鍵詞，查找索引實例對象進行過濾處理CollectionUtils.filter(adUnitIds,adUnitId -> IndexDataTableUtils.of(UnitKeywordIndexAwareImpl.class).match(adUnitId, keywordFeature.getKeywords()));}}/*** 根據(jù)傳遞的興趣信息過濾*/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()));}}/*** 根據(jù)傳遞的地域信息過濾*/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());});}}

根據(jù)推廣單元id獲取推廣創(chuàng)意

我們知道，推廣單元和推廣創(chuàng)意的關(guān)系是多對多，從上文我們查詢到了推廣單元ids,接下來我們實現(xiàn)根據(jù)推廣單元id獲取推廣創(chuàng)意的代碼，let's code.
首先，我們需要在com.sxzhongf.ad.index.creative_relation_unit.CreativeRelationUnitIndexAwareImpl 關(guān)聯(lián)索引中查到推廣創(chuàng)意的ids

/*** 通過推廣單元id獲取推廣創(chuàng)意id*/public List<Long> selectAdCreativeIds(List<AdUnitIndexObject> unitIndexObjects) {if (CollectionUtils.isEmpty(unitIndexObjects)) return Collections.emptyList();//獲取要返回的廣告創(chuàng)意idsList<Long> result = new ArrayList<>();for (AdUnitIndexObject unitIndexObject : unitIndexObjects) {//根據(jù)推廣單元id獲取推廣創(chuàng)意Set<Long> adCreativeIds = unitRelationCreativeMap.get(unitIndexObject.getUnitId());if (CollectionUtils.isNotEmpty(adCreativeIds)) result.addAll(adCreativeIds);}return result;}

然后得到了推廣創(chuàng)意的id list后，我們在創(chuàng)意索引實現(xiàn)類com.sxzhongf.ad.index.creative.CreativeIndexAwareImpl中定義根據(jù)ids查詢創(chuàng)意的方法。

/*** 根據(jù)ids獲取創(chuàng)意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; }

自此，我們已經(jīng)得到了想要的推廣單元和推廣創(chuàng)意，因為推廣單元包含了推廣計劃，所以我們想要的數(shù)據(jù)已經(jīng)全部可以獲取到了，接下來，我們還得過濾一次當(dāng)前我們查詢到的數(shù)據(jù)的狀態(tài)，因為有的數(shù)據(jù)，我們可能已經(jīng)進行過邏輯刪除了，因此還需要判斷獲取的數(shù)據(jù)是否有效。在SearchImpl類中實現(xiàn)。

/*** 根據(jù)狀態(tài)信息過濾數(shù)據(jù)*/private void filterAdUnitAndPlanStatus(List<AdUnitIndexObject> unitIndexObjects, CommonStatus status) {if (CollectionUtils.isEmpty(unitIndexObjects)) return;//同時判斷推廣單元和推廣計劃的狀態(tài)CollectionUtils.filter(unitIndexObjects,unitIndexObject -> unitIndexObject.getUnitStatus().equals(status.getStatus()) &&unitIndexObject.getAdPlanIndexObject().getPlanStatus().equals(status.getStatus()));}

在SearchImpl中我們實現(xiàn)廣告創(chuàng)意的查詢.

...//獲取 推廣計劃 對象list List<AdUnitIndexObject> unitIndexObjects = IndexDataTableUtils.of(AdUnitIndexAwareImpl.class).fetch(adUnitIdSet); //根據(jù)狀態(tài)過濾數(shù)據(jù) filterAdUnitAndPlanStatus(unitIndexObjects, CommonStatus.VALID); //獲取 推廣創(chuàng)意 id list List<Long> creativeIds = IndexDataTableUtils.of(CreativeRelationUnitIndexAwareImpl.class).selectAdCreativeIds(unitIndexObjects); //根據(jù) 推廣創(chuàng)意ids獲取推廣創(chuàng)意 List<CreativeIndexObject> creativeIndexObjects = IndexDataTableUtils.of(CreativeIndexAwareImpl.class) ...

根據(jù)廣告位adslot 實現(xiàn)對創(chuàng)意數(shù)據(jù)的過濾

因為我們的廣告位是有不同的大小，不同的類型，因此，我們在獲取到所有符合我們查詢維度以及流量類型的條件后，還需要針對不同的廣告位來展示不同的廣告創(chuàng)意信息。

/** * 根據(jù)廣告位類型以及參數(shù)獲取展示的合適廣告信息 * * @param creativeIndexObjects 所有廣告創(chuàng)意 * @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 -> {//審核狀態(tài)必須是通過return creative.getAuditStatus().equals(CommonStatus.VALID.getStatus())&& creative.getWidth().equals(width)&& creative.getHeight().equals(height)&& type.contains(creative.getType());}); }

• 組建搜索返回對象
  正常業(yè)務(wù)場景中，同一個廣告位可以展示多個廣告信息，也可以只展示一個廣告信息，這個需要根據(jù)具體的業(yè)務(wù)場景來做不同的處理，本次為了演示方便，會從返回的創(chuàng)意列表中隨機選擇一個創(chuàng)意廣告信息進行展示，當(dāng)然大家也可以根據(jù)業(yè)務(wù)類型，設(shè)置不同的優(yōu)先級或者權(quán)重值來進行廣告選擇。

/*** 從創(chuàng)意列表中隨機獲取一條創(chuàng)意廣告返回出去** @param creativeIndexObjects 創(chuàng)意廣告list*/ private List<SearchResponse.Creative> buildCreativeResponse(List<CreativeIndexObject> creativeIndexObjects) {if (CollectionUtils.isEmpty(creativeIndexObjects)) return Collections.EMPTY_LIST;//隨機獲取一個廣告創(chuàng)意，也可以實現(xiàn)優(yōu)先級排序，也可以根據(jù)權(quán)重值等等，具體根據(jù)業(yè)務(wù)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)); }

完整的請求過濾實現(xiàn)方法：

@Service @Slf4j public class SearchImpl implements ISearch {@Overridepublic 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關(guān)系FeatureRelation featureRelation = request.getFeatureInfo().getRelation();//構(gòu)造響應(yīng)對象SearchResponse response = new SearchResponse();Map<String, List<SearchResponse.Creative>> adSlotRelationAds = response.getAdSlotRelationAds();for (AdSlot adSlot : adSlotList) {Set<Long> targetUnitIdSet;//根據(jù)流量類型從緩存中獲取 初始 廣告信息Set<Long> adUnitIdSet = IndexDataTableUtils.of(AdUnitIndexAwareImpl.class).match(adSlot.getPositionType());// 根據(jù)三個維度過濾if (featureRelation == FeatureRelation.AND) {filterKeywordFeature(adUnitIdSet, keywordFeature);filterHobbyFeature(adUnitIdSet, hobbyFeatrue);filterDistrictFeature(adUnitIdSet, districtFeature);targetUnitIdSet = adUnitIdSet;} else {targetUnitIdSet = getOrRelationUnitIds(adUnitIdSet, keywordFeature, hobbyFeatrue, districtFeature);}//獲取 推廣計劃 對象listList<AdUnitIndexObject> unitIndexObjects = IndexDataTableUtils.of(AdUnitIndexAwareImpl.class).fetch(targetUnitIdSet);//根據(jù)狀態(tài)過濾數(shù)據(jù)filterAdUnitAndPlanStatus(unitIndexObjects, CommonStatus.VALID);//獲取 推廣創(chuàng)意 id listList<Long> creativeIds = IndexDataTableUtils.of(CreativeRelationUnitIndexAwareImpl.class).selectAdCreativeIds(unitIndexObjects);//根據(jù) 推廣創(chuàng)意ids獲取推廣創(chuàng)意List<CreativeIndexObject> creativeIndexObjects = IndexDataTableUtils.of(CreativeIndexAwareImpl.class).fetch(creativeIds);//根據(jù) 廣告位adslot 實現(xiàn)對創(chuàng)意數(shù)據(jù)的過濾filterCreativeByAdSlot(creativeIndexObjects, adSlot.getWidth(), adSlot.getHeight(), adSlot.getType());//一個廣告位可以展示多個廣告，也可以僅展示一個廣告，具體根據(jù)業(yè)務(wù)來定adSlotRelationAds.put(adSlot.getAdSlotCode(),buildCreativeResponse(creativeIndexObjects));}return response;}...

檢索服務(wù)對外提供

• 暴露API接口
  上文中，我們實現(xiàn)了檢索服務(wù)的核心邏輯，接下來，我們需要對外暴露我們的廣告檢索服務(wù)接口，在SearchController中提供：

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

• 實現(xiàn)API網(wǎng)關(guān)配置

  zuul: routes:sponsor: #在路由中自定義服務(wù)路由名稱path: /ad-sponsor/**serviceId: mscx-ad-sponsor #微服務(wù)namestrip-prefix: falsesearch: #在路由中自定義服務(wù)路由名稱path: /ad-search/**serviceId: mscx-ad-search #微服務(wù)namestrip-prefix: false prefix: /gateway/api strip-prefix: true #不對 prefix: /gateway/api 設(shè)置的路徑進行截取，默認轉(zhuǎn)發(fā)會截取掉配置的前綴

轉(zhuǎn)載于:https://www.cnblogs.com/zhangpan1244/p/11349029.html

總結(jié)

以上是生活随笔為你收集整理的[Spring cloud 一步步实现广告系统] 18. 查询返回广告创意的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。