com.hybris.ymkt.recommendationbuffer.service.impl

Class DefaultRecommendationBufferService

java.lang.Object

com.hybris.ymkt.recommendationbuffer.service.impl.DefaultRecommendationBufferService

All Implemented Interfaces:

RecommendationBufferService

public class DefaultRecommendationBufferService
extends java.lang.Object
implements RecommendationBufferService

Buffer service for reading and saving recommendation related entities.

See Also:

RecommendationBufferService

Field Summary

Fields

Modifier and Type	Field and Description
protected boolean	enableRecommendationBuffer
protected int	expiryOffset
protected ModelService	modelService
protected RecommendationBufferDao	recommendationBufferDao

Constructor Summary

Constructors

Constructor and Description
DefaultRecommendationBufferService()

Method Summary

Modifier and Type	Method and Description
protected java.lang.String	cutTo255(java.lang.String csvString) Takes a csv string and cuts it to fit in 255 characters.
java.util.List<SAPRecoImpressionAggrModel>	getAggregatedImpressions(int batchSize) Read a List of SAPRecoImpressionAggrModel.
java.util.List<SAPRecoClickthroughModel>	getClickthroughs(int readBatchSize) Read List of SAPRecoClickthroughModel.
SAPRecommendationBufferModel	getGenericRecommendation(java.lang.String scenarioId, java.lang.String leadingItems) Get recommendations with scope G
protected java.lang.String	getHashIdsForType(java.lang.String scenarioId, java.lang.String recoType)
java.lang.String	getHashIdsForUser(java.lang.String userId, java.lang.String scenarioId) Get all hash ids for user
java.util.List<SAPRecoImpressionModel>	getImpressions(int readBatchSize) Read List of SAPRecoImpressionModel.
java.util.List<SAPOfferInteractionModel>	getOfferInteractions(int batchSize) Read List of SAPOfferInteractionModel.
SAPRecommendationBufferModel	getPersonalizedRecommendation(java.lang.String userId, java.lang.String scenarioId, java.lang.String leadingItems) Get a recommendation.
SAPRecommendationBufferModel	getRestrictedRecommendation(java.lang.String scenarioId, java.lang.String leadingItems) Get recommendations with scope R
boolean	isRecommendationExpired(SAPRecommendationBufferModel recommendation) Check if a recommendation is expired.
protected void	removeExpiredAny(java.util.function.Function<java.util.Date,java.util.List<? extends ItemModel>> serviceMethod)
void	removeExpiredMappings() Remove expired mappings based on the expiry offset.
void	removeExpiredRecommendations() Remove expired recommendations based on the expiry offset.
void	removeExpiredTypeMappings() Remove expired mappings based on the expiry offset.
void	saveRecommendation(java.lang.String userId, java.lang.String scenarioId, java.lang.String hashId, java.lang.String leadingItems, java.lang.String recoList, java.lang.String recoType, java.util.Date expiresOn) Add a new recommendation entry.
protected void	saveRecommendationBuffer(java.lang.String scenarioId, java.lang.String hashId, java.lang.String leadingItems, java.lang.String recoList, java.util.Date expiresOn)
protected void	saveRecommendationMapping(java.lang.String userId, java.lang.String scenarioId, java.lang.String hashId, java.util.Date expiresOn)
protected void	saveRecommendationTypeMapping(java.lang.String scenarioId, java.lang.String hashId, java.lang.String recoType, java.util.Date expiresOn)
void	setEnableRecommendationBuffer(boolean enableRecommendationBuffer)
void	setExpiryOffset(int expiryOffset)
void	setModelService(ModelService modelService)
void	setRecommendationBufferDao(RecommendationBufferDao recommendationBufferDao)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

enableRecommendationBuffer

protected boolean enableRecommendationBuffer

expiryOffset

protected int expiryOffset

modelService

protected ModelService modelService

recommendationBufferDao

protected RecommendationBufferDao recommendationBufferDao

Constructor Detail

DefaultRecommendationBufferService

public DefaultRecommendationBufferService()

Method Detail

getAggregatedImpressions

public java.util.List<SAPRecoImpressionAggrModel> getAggregatedImpressions(int batchSize)

Description copied from interface: RecommendationBufferService

Read a List of SAPRecoImpressionAggrModel.

Specified by:

getAggregatedImpressions in interface RecommendationBufferService

Parameters:

batchSize - Batch size.

Returns:

List of SAPRecoImpressionAggrModel.

getClickthroughs

public java.util.List<SAPRecoClickthroughModel> getClickthroughs(int readBatchSize)

Description copied from interface: RecommendationBufferService

Read List of SAPRecoClickthroughModel.

Specified by:

getClickthroughs in interface RecommendationBufferService

Parameters:

readBatchSize - Batch size.

Returns:

List of SAPRecoClickthroughModel

getGenericRecommendation

public SAPRecommendationBufferModel getGenericRecommendation(java.lang.String scenarioId,
                                                             java.lang.String leadingItems)

Description copied from interface: RecommendationBufferService

Get recommendations with scope G

Specified by:

getGenericRecommendation in interface RecommendationBufferService

Parameters:

scenarioId - Scenario ID.

leadingItems - Leading items.

Returns:

SAPRecommendationBufferModel.

getRestrictedRecommendation

public SAPRecommendationBufferModel getRestrictedRecommendation(java.lang.String scenarioId,
                                                                java.lang.String leadingItems)

Description copied from interface: RecommendationBufferService

Get recommendations with scope R

Specified by:

getRestrictedRecommendation in interface RecommendationBufferService

Parameters:

scenarioId - Scenario ID.

leadingItems - Leading items.

Returns:

SAPRecommendationBufferModel.

getOfferInteractions

public java.util.List<SAPOfferInteractionModel> getOfferInteractions(int batchSize)

Description copied from interface: RecommendationBufferService

Read List of SAPOfferInteractionModel.

Specified by:

getOfferInteractions in interface RecommendationBufferService

Parameters:

batchSize - Batch size.

Returns:

List of SAPOfferInteractionModel.

getHashIdsForType

protected java.lang.String getHashIdsForType(java.lang.String scenarioId,
                                             java.lang.String recoType)

getHashIdsForUser

public java.lang.String getHashIdsForUser(java.lang.String userId,
                                          java.lang.String scenarioId)

Description copied from interface: RecommendationBufferService

Get all hash ids for user

Specified by:

getHashIdsForUser in interface RecommendationBufferService

Parameters:

userId - User ID

scenarioId - Scenario ID

Returns:

Comma separated list string of hash ids

getImpressions

public java.util.List<SAPRecoImpressionModel> getImpressions(int readBatchSize)

Description copied from interface: RecommendationBufferService

Read List of SAPRecoImpressionModel.

Specified by:

getImpressions in interface RecommendationBufferService

Parameters:

readBatchSize - Batch size.

Returns:

List of SAPRecoImpressionModel

getPersonalizedRecommendation

public SAPRecommendationBufferModel getPersonalizedRecommendation(java.lang.String userId,
                                                                  java.lang.String scenarioId,
                                                                  java.lang.String leadingItems)

Description copied from interface: RecommendationBufferService

Get a recommendation.

Specified by:

getPersonalizedRecommendation in interface RecommendationBufferService

Parameters:

userId - User ID.

scenarioId - Scenario ID.

leadingItems - Leading items.

Returns:

SAPRecommendationBufferModel.

isRecommendationExpired

public boolean isRecommendationExpired(SAPRecommendationBufferModel recommendation)

Description copied from interface: RecommendationBufferService

Check if a recommendation is expired.

Specified by:

isRecommendationExpired in interface RecommendationBufferService

Parameters:

recommendation - SAPRecommendationBufferModel.

Returns:

true if expired, false otherwise.

removeExpiredAny

protected void removeExpiredAny(java.util.function.Function<java.util.Date,java.util.List<? extends ItemModel>> serviceMethod)

removeExpiredMappings

public void removeExpiredMappings()

Description copied from interface: RecommendationBufferService

Remove expired mappings based on the expiry offset.

Specified by:

removeExpiredMappings in interface RecommendationBufferService

removeExpiredRecommendations

public void removeExpiredRecommendations()

Description copied from interface: RecommendationBufferService

Remove expired recommendations based on the expiry offset.

Specified by:

removeExpiredRecommendations in interface RecommendationBufferService

removeExpiredTypeMappings

public void removeExpiredTypeMappings()

Description copied from interface: RecommendationBufferService

Remove expired mappings based on the expiry offset.

Specified by:

removeExpiredTypeMappings in interface RecommendationBufferService

saveRecommendation

public void saveRecommendation(java.lang.String userId,
                               java.lang.String scenarioId,
                               java.lang.String hashId,
                               java.lang.String leadingItems,
                               java.lang.String recoList,
                               java.lang.String recoType,
                               java.util.Date expiresOn)

Description copied from interface: RecommendationBufferService

Add a new recommendation entry.

Specified by:

saveRecommendation in interface RecommendationBufferService

Parameters:

userId - User ID.

scenarioId - Scenario ID.

hashId - Hash ID.

leadingItems - Leading items.

recoList - Recommendation List.

recoType - Recommendation Type.

expiresOn - Expire date.

cutTo255

protected java.lang.String cutTo255(java.lang.String csvString)

Takes a csv string and cuts it to fit in 255 characters. Required to make the recommended product list fit in the column. This makes the number of products that can be buffered dependent on the product id length and the number of products returned by the SAP Marketing recommendation model.

Parameters:

csvString - List of product IDs separated by comma.

Returns:

List of product IDs separated by comma with maximum size 255.

saveRecommendationBuffer

protected void saveRecommendationBuffer(java.lang.String scenarioId,
                                        java.lang.String hashId,
                                        java.lang.String leadingItems,
                                        java.lang.String recoList,
                                        java.util.Date expiresOn)

saveRecommendationMapping

protected void saveRecommendationMapping(java.lang.String userId,
                                         java.lang.String scenarioId,
                                         java.lang.String hashId,
                                         java.util.Date expiresOn)

saveRecommendationTypeMapping

protected void saveRecommendationTypeMapping(java.lang.String scenarioId,
                                             java.lang.String hashId,
                                             java.lang.String recoType,
                                             java.util.Date expiresOn)

setEnableRecommendationBuffer

public void setEnableRecommendationBuffer(boolean enableRecommendationBuffer)

setExpiryOffset

public void setExpiryOffset(int expiryOffset)

setModelService

public void setModelService(ModelService modelService)

setRecommendationBufferDao

public void setRecommendationBufferDao(RecommendationBufferDao recommendationBufferDao)