根據(jù)三個(gè)維度繼續(xù)過(guò)濾
讓客戶(hù)滿(mǎn)意是我們工作的目標(biāo),不斷超越客戶(hù)的期望值來(lái)自于我們對(duì)這個(gè)行業(yè)的熱愛(ài)。我們立志把好的技術(shù)通過(guò)有效、簡(jiǎn)單的方式提供給客戶(hù),將通過(guò)不懈努力成為客戶(hù)在信息化領(lǐng)域值得信任、有價(jià)值的長(zhǎng)期合作伙伴,公司提供的服務(wù)項(xiàng)目有:國(guó)際域名空間、虛擬空間、營(yíng)銷(xiāo)軟件、網(wǎng)站建設(shè)、豐寧網(wǎng)站維護(hù)、網(wǎng)站推廣。
在上一節(jié)中我們實(shí)現(xiàn)了根據(jù)流量信息過(guò)濾的代碼,但是我們的條件有可能是多條件一起傳給我們的檢索服務(wù)的,本節(jié)我們繼續(xù)實(shí)現(xiàn)根據(jù)推廣單元的三個(gè)維度條件的過(guò)濾。
在SearchImpl類(lèi)中添加過(guò)濾方法
public class SearchImpl implements ISearch { @Override public SearchResponse fetchAds(SearchRequest request) { ... // 根據(jù)三個(gè)維度過(guò)濾 if (featureRelation == FeatureRelation.AND) { filterKeywordFeature(adUnitIdSet, keywordFeature); filterHobbyFeature(adUnitIdSet, hobbyFeatrue); filterDistrictFeature(adUnitIdSet, districtFeature); targetUnitIdSet = adUnitIdSet; } else { getOrRelationUnitIds(adUnitIdSet, keywordFeature, hobbyFeatrue, districtFeature); } } return null; }
定義三個(gè)方法實(shí)現(xiàn)過(guò)濾
/** * 獲取三個(gè)維度各自滿(mǎn)足時(shí)的廣告id */ private SetgetOrRelationUnitIds(Set adUnitIdsSet, KeywordFeature keywordFeature, HobbyFeatrue hobbyFeatrue, DistrictFeature districtFeature) { if (CollectionUtils.isEmpty(adUnitIdsSet)) return Collections.EMPTY_SET; // 我們?cè)谔幚淼臅r(shí)候,需要對(duì)副本進(jìn)行處理,大家可以考慮一下為什么需要這么做? Set keywordUnitIdSet = new HashSet<>(adUnitIdsSet); Set hobbyUnitIdSet = new HashSet<>(adUnitIdsSet); Set 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)鍵詞過(guò)濾 */ private void filterKeywordFeature(Collection adUnitIds, KeywordFeature keywordFeature) { if (CollectionUtils.isEmpty(adUnitIds)) return; if (CollectionUtils.isNotEmpty(keywordFeature.getKeywords())) { // 如果存在需要過(guò)濾的關(guān)鍵詞,查找索引實(shí)例對(duì)象進(jìn)行過(guò)濾處理 CollectionUtils.filter( adUnitIds, adUnitId -> IndexDataTableUtils.of(UnitKeywordIndexAwareImpl.class) .match(adUnitId, keywordFeature.getKeywords()) ); } } /** * 根據(jù)傳遞的興趣信息過(guò)濾 */ private void filterHobbyFeature(Collection adUnitIds, HobbyFeatrue hobbyFeatrue) { if (CollectionUtils.isEmpty(adUnitIds)) return; // 如果存在需要過(guò)濾的興趣,查找索引實(shí)例對(duì)象進(jìn)行過(guò)濾處理 if (CollectionUtils.isNotEmpty(hobbyFeatrue.getHobbys())) { CollectionUtils.filter( adUnitIds, adUnitId -> IndexDataTableUtils.of(UnitHobbyIndexAwareImpl.class) .match(adUnitId, hobbyFeatrue.getHobbys()) ); } } /** * 根據(jù)傳遞的地域信息過(guò)濾 */ private void filterDistrictFeature(Collection adUnitIds, DistrictFeature districtFeature) { if (CollectionUtils.isEmpty(adUnitIds)) return; // 如果存在需要過(guò)濾的地域信息,查找索引實(shí)例對(duì)象進(jìn)行過(guò)濾處理 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)系是多對(duì)多,從上文我們查詢(xún)到了推廣單元ids,接下來(lái)我們實(shí)現(xiàn)根據(jù)推廣單元id獲取推廣創(chuàng)意的代碼,let's code.
首先,我們需要在com.sxzhongf.ad.index.creative_relation_unit.CreativeRelationUnitIndexAwareImpl 關(guān)聯(lián)索引中查到推廣創(chuàng)意的ids
/** * 通過(guò)推廣單元id獲取推廣創(chuàng)意id */ public ListselectAdCreativeIds(List unitIndexObjects) { if (CollectionUtils.isEmpty(unitIndexObjects)) return Collections.emptyList(); //獲取要返回的廣告創(chuàng)意ids List result = new ArrayList<>(); for (AdUnitIndexObject unitIndexObject : unitIndexObjects) { //根據(jù)推廣單元id獲取推廣創(chuàng)意 Set adCreativeIds = unitRelationCreativeMap.get(unitIndexObject.getUnitId()); if (CollectionUtils.isNotEmpty(adCreativeIds)) result.addAll(adCreativeIds); } return result; }
然后得到了推廣創(chuàng)意的id list后,我們?cè)趧?chuàng)意索引實(shí)現(xiàn)類(lèi)com.sxzhongf.ad.index.creative.CreativeIndexAwareImpl中定義根據(jù)ids查詢(xún)創(chuàng)意的方法。
/** * 根據(jù)ids獲取創(chuàng)意list */ public ListfindAllByIds(Collection ids) { if (CollectionUtils.isEmpty(ids)) return Collections.emptyList(); List result = new ArrayList<>(); for (Long id : ids) { CreativeIndexObject object = get(id); if (null != object) result.add(object); } return result; }
自此,我們已經(jīng)得到了想要的推廣單元和推廣創(chuàng)意,因?yàn)橥茝V單元包含了推廣計(jì)劃,所以我們想要的數(shù)據(jù)已經(jīng)全部可以獲取到了,接下來(lái),我們還得過(guò)濾一次當(dāng)前我們查詢(xún)到的數(shù)據(jù)的狀態(tài),因?yàn)橛械臄?shù)據(jù),我們可能已經(jīng)進(jìn)行過(guò)邏輯刪除了,因此還需要判斷獲取的數(shù)據(jù)是否有效。在SearchImpl類(lèi)中實(shí)現(xiàn)。
/** * 根據(jù)狀態(tài)信息過(guò)濾數(shù)據(jù) */ private void filterAdUnitAndPlanStatus(ListunitIndexObjects, CommonStatus status) { if (CollectionUtils.isEmpty(unitIndexObjects)) return; //同時(shí)判斷推廣單元和推廣計(jì)劃的狀態(tài) CollectionUtils.filter( unitIndexObjects, unitIndexObject -> unitIndexObject.getUnitStatus().equals(status.getStatus()) && unitIndexObject.getAdPlanIndexObject().getPlanStatus().equals(status.getStatus()) ); }
在SearchImpl中我們實(shí)現(xiàn)廣告創(chuàng)意的查詢(xún).
... //獲取 推廣計(jì)劃 對(duì)象list ListunitIndexObjects = IndexDataTableUtils.of(AdUnitIndexAwareImpl.class).fetch(adUnitIdSet); //根據(jù)狀態(tài)過(guò)濾數(shù)據(jù) filterAdUnitAndPlanStatus(unitIndexObjects, CommonStatus.VALID); //獲取 推廣創(chuàng)意 id list List creativeIds = IndexDataTableUtils.of(CreativeRelationUnitIndexAwareImpl.class) .selectAdCreativeIds(unitIndexObjects); //根據(jù) 推廣創(chuàng)意ids獲取推廣創(chuàng)意 List creativeIndexObjects = IndexDataTableUtils.of(CreativeIndexAwareImpl.class) ...
根據(jù)廣告位adslot 實(shí)現(xiàn)對(duì)創(chuàng)意數(shù)據(jù)的過(guò)濾
因?yàn)槲覀兊膹V告位是有不同的大小,不同的類(lèi)型,因此,我們?cè)讷@取到所有符合我們查詢(xún)維度以及流量類(lèi)型的條件后,還需要針對(duì)不同的廣告位來(lái)展示不同的廣告創(chuàng)意信息。
/** * 根據(jù)廣告位類(lèi)型以及參數(shù)獲取展示的合適廣告信息 * * @param creativeIndexObjects 所有廣告創(chuàng)意 * @param width 廣告位width * @param height 廣告位height */ private void filterCreativeByAdSlot(ListcreativeIndexObjects, Integer width, Integer height, List type) { if (CollectionUtils.isEmpty(creativeIndexObjects)) return; CollectionUtils.filter( creativeIndexObjects, creative -> { //審核狀態(tài)必須是通過(guò) return creative.getAuditStatus().equals(CommonStatus.VALID.getStatus()) && creative.getWidth().equals(width) && creative.getHeight().equals(height) && type.contains(creative.getType()); } ); }
組建搜索返回對(duì)象
正常業(yè)務(wù)場(chǎng)景中,同一個(gè)廣告位可以展示多個(gè)廣告信息,也可以只展示一個(gè)廣告信息,這個(gè)需要根據(jù)具體的業(yè)務(wù)場(chǎng)景來(lái)做不同的處理,本次為了演示方便,會(huì)從返回的創(chuàng)意列表中隨機(jī)選擇一個(gè)創(chuàng)意廣告信息進(jìn)行展示,當(dāng)然大家也可以根據(jù)業(yè)務(wù)類(lèi)型,設(shè)置不同的優(yōu)先級(jí)或者權(quán)重值來(lái)進(jìn)行廣告選擇。
/** * 從創(chuàng)意列表中隨機(jī)獲取一條創(chuàng)意廣告返回出去 * * @param creativeIndexObjects 創(chuàng)意廣告list */ private ListbuildCreativeResponse(List creativeIndexObjects) { if (CollectionUtils.isEmpty(creativeIndexObjects)) return Collections.EMPTY_LIST; //隨機(jī)獲取一個(gè)廣告創(chuàng)意,也可以實(shí)現(xiàn)優(yōu)先級(jí)排序,也可以根據(jù)權(quán)重值等等,具體根據(jù)業(yè)務(wù) CreativeIndexObject randomObject = creativeIndexObjects.get( Math.abs(new Random().nextInt()) % creativeIndexObjects.size() ); //List result = new ArrayList<>(); //result.add(SearchResponse.convert(randomObject)); return Collections.singletonList( SearchResponse.convert(randomObject) ); }
完整的請(qǐng)求過(guò)濾實(shí)現(xiàn)方法:
@Service @Slf4j public class SearchImpl implements ISearch { @Override public SearchResponse fetchAds(SearchRequest request) { //獲取請(qǐng)求廣告位信息 ListadSlotList = request.getRequestInfo().getAdSlots(); //獲取三個(gè)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)對(duì)象 SearchResponse response = new SearchResponse(); Map > adSlotRelationAds = response.getAdSlotRelationAds(); for (AdSlot adSlot : adSlotList) { Set targetUnitIdSet; //根據(jù)流量類(lèi)型從緩存中獲取 初始 廣告信息 Set adUnitIdSet = IndexDataTableUtils.of( AdUnitIndexAwareImpl.class ).match(adSlot.getPositionType()); // 根據(jù)三個(gè)維度過(guò)濾 if (featureRelation == FeatureRelation.AND) { filterKeywordFeature(adUnitIdSet, keywordFeature); filterHobbyFeature(adUnitIdSet, hobbyFeatrue); filterDistrictFeature(adUnitIdSet, districtFeature); targetUnitIdSet = adUnitIdSet; } else { targetUnitIdSet = getOrRelationUnitIds(adUnitIdSet, keywordFeature, hobbyFeatrue, districtFeature); } //獲取 推廣計(jì)劃 對(duì)象list List unitIndexObjects = IndexDataTableUtils.of(AdUnitIndexAwareImpl.class) .fetch(targetUnitIdSet); //根據(jù)狀態(tài)過(guò)濾數(shù)據(jù) filterAdUnitAndPlanStatus(unitIndexObjects, CommonStatus.VALID); //獲取 推廣創(chuàng)意 id list List creativeIds = IndexDataTableUtils.of(CreativeRelationUnitIndexAwareImpl.class) .selectAdCreativeIds(unitIndexObjects); //根據(jù) 推廣創(chuàng)意ids獲取推廣創(chuàng)意 List creativeIndexObjects = IndexDataTableUtils.of(CreativeIndexAwareImpl.class) .fetch(creativeIds); //根據(jù) 廣告位adslot 實(shí)現(xiàn)對(duì)創(chuàng)意數(shù)據(jù)的過(guò)濾 filterCreativeByAdSlot(creativeIndexObjects, adSlot.getWidth(), adSlot.getHeight(), adSlot.getType()); //一個(gè)廣告位可以展示多個(gè)廣告,也可以?xún)H展示一個(gè)廣告,具體根據(jù)業(yè)務(wù)來(lái)定 adSlotRelationAds.put( adSlot.getAdSlotCode(), buildCreativeResponse(creativeIndexObjects) ); } return response; } ...
檢索服務(wù)對(duì)外提供
暴露API接口
上文中,我們實(shí)現(xiàn)了檢索服務(wù)的核心邏輯,接下來(lái),我們需要對(duì)外暴露我們的廣告檢索服務(wù)接口,在SearchController中提供:
@PostMapping("/fetchAd") public SearchResponse fetchAdCreative(@RequestBody SearchRequest request) { log.info("ad-serach: fetchAd ->{}", JSON.toJSONString(request)); return search.fetchAds(request); }
實(shí)現(xiàn)API網(wǎng)關(guān)配置
zuul: routes: sponsor: #在路由中自定義服務(wù)路由名稱(chēng) path: /ad-sponsor/** serviceId: mscx-ad-sponsor #微服務(wù)name strip-prefix: false search: #在路由中自定義服務(wù)路由名稱(chēng) path: /ad-search/** serviceId: mscx-ad-search #微服務(wù)name strip-prefix: false prefix: /gateway/api strip-prefix: true #不對(duì) prefix: /gateway/api 設(shè)置的路徑進(jìn)行截取,默認(rèn)轉(zhuǎn)發(fā)會(huì)截取掉配置的前綴
以上就是本次分享的全部知識(shí)點(diǎn)內(nèi)容,感謝大家對(duì)創(chuàng)新互聯(lián)的支持