在上一節(jié)中我們實(shí)現(xiàn)了根據(jù)流量信息過(guò)濾的代碼，但是我們的條件有可能是多條件一起傳給我們的檢索服務(wù)的，本節(jié)我們繼續(xù)實(shí)現(xiàn)根據(jù)推廣單元的三個(gè)維度條件的過(guò)濾。
義縣ssl適用于網(wǎng)站、小程序/APP、API接口等需要進(jìn)行數(shù)據(jù)傳輸應(yīng)用場(chǎng)景，ssl證書(shū)未來(lái)市場(chǎng)廣闊！成為創(chuàng)新互聯(lián)建站的ssl證書(shū)銷(xiāo)售渠道，可以享受市場(chǎng)價(jià)格4-6折優(yōu)惠！如果有意向歡迎電話(huà)聯(lián)系或者加微信：18980820575（備注：SSL證書(shū)合作）期待與您的合作！
重慶分公司
重慶分公司
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è)維度各自滿(mǎn)足時(shí)的廣告id
*/
private Set getOrRelationUnitIds(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());
}
);
}
} 我們知道，推廣單元和推廣創(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 List selectAdCreativeIds(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 List findAllByIds(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(List unitIndexObjects, 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
List unitIndexObjects = 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)
...
因?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(List creativeIndexObjects,
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());
}
);
} /**
* 從創(chuàng)意列表中隨機(jī)獲取一條創(chuàng)意廣告返回出去
*
* @param creativeIndexObjects 創(chuàng)意廣告list
*/
private List buildCreativeResponse(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)求廣告位信息
List adSlotList = 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;
}
... 暴露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ì)截取掉配置的前綴
