Extending the data reader class to extract category-level SKUs

Name the class ExtCatalogEntryReaderMediator.

The new class must:

• Override the getDataObject(String beginIndex, String pageSize, String storeId) method in the CatalogEntryReaderMediator class.
• Invoke the newly created Get service to retrieve the necessary information.

Here is an example of this extended class:

public class ExtCatalogEntryReaderMediator extends CatalogEntryReaderMediator {
     /*
     * Logger used for logging.
     */
     private   static   final  Logger LOGGER  = LoggingHelper. getLogger (ExtCatalogEntryReaderMediator. class );
    
     /*
     * Class name used for trace and logging.
     */
     private   static   final  String CLASSNAME  = ExtCatalogEntryReaderMediator.  class .getName();
     
     /*
     * The catalog entry xpath  expression
     */
     private   static   final  String CATALOG_ENTRY_XPATH_EXPRESSION  = "/CatalogEntry[CatalogEntryIdentifier[ExternalIdentifier[StoreIdentifier[(UniqueID={0})]]] and CategoryLevelSKU]" ;
     
     protected  Object getDataObject(String beginIndex, String pageSize, String storeId) throws  AbstractBusinessObjectDocumentException, DataLoadException {
          final  String METHODNAME = "getDataObject" ;
          if (LoggingHelper. isEntryExitTraceEnabled ( LOGGER )) {
               LOGGER .entering( CLASSNAME , METHODNAME, new  Object[]{beginIndex, pageSize, storeId}); 
          }
          
          GetType getVerb = Oagis9Factory. eINSTANCE .createGetType();
          String accessProfile = getAccessProfile();
          
          // Instantiate SelectionCriteriaHelper object
          SelectionCriteriaHelper selectionCriteriaHelper = new  SelectionCriteriaHelper(MessageFormat. format ( CATALOG_ENTRY_XPATH_EXPRESSION , new  Object[]{storeId.trim()})); 
          
          selectionCriteriaHelper.addAccessProfile(accessProfile); 
          selectionCriteriaHelper.setDataLanguageIds(getLanguageId());
          
          if (isCloudscape()){
               getVerb.setRecordSetStartNumber( new  BigInteger(beginIndex));
               getVerb.setMaxItems( new  BigInteger(pageSize));
          }
          else {
               // Set the control parameter, beginIndex
               selectionCriteriaHelper.addNameValuePair( new  RelationalExpression(DataExtractConstants. DE_CONTROL_PARAMETER_BEGIN_INDEX , beginIndex));
               
               // Set the control parameter, maxItems
               selectionCriteriaHelper.addNameValuePair( new  RelationalExpression(DataExtractConstants. DE_CONTROL_PARAMETER_MAX_ITEMS , pageSize));
          }
          
          // Set the Currency as a control parameter
          selectionCriteriaHelper.addNameValuePair( new  RelationalExpression(DataExtractConstants. DE_CONTROL_PARAMETER_CURRENCY , getCurrency()));
          
          // Set the control parameters from the control parameters map in the request
          Map controlParametersMap = getControlParametrs();
          Iterator it = controlParametersMap.entrySet().iterator();
          while  (it.hasNext()) {
             Map.Entry pairs = (Map.Entry)it.next();
             selectionCriteriaHelper.addNameValuePair( new  RelationalExpression((String)pairs.getKey(), (String)pairs.getValue()));
          }
          
          ExpressionType queryExpression = selectionCriteriaHelper.getSelectionCriteriaExpression(); 
          queryExpression.setExpressionLanguage(DataExtractConstants. DE_EXPRESSION_LANGUAGE_XPATH );
          getVerb.getExpression().add(queryExpression);
          
          CatalogEntryFacadeClient catEntryClient = new  CatalogEntryFacadeClient(getBusinessContext(), getCallBackHandler());
          ShowCatalogEntryDataAreaType result = catEntryClient.getCatalogEntry(getVerb);
          
          if (LoggingHelper. isEntryExitTraceEnabled ( LOGGER )) {
               LOGGER .exiting( CLASSNAME , METHODNAME, result);
          }
          return  result;
     }
}