release13.07/applications/content/src/org/ofbiz/content/content/ContentServicesComplex.java - ofbiz - Git at Google

 /*******************************************************************************
  * Licensed to the Apache Software Foundation (ASF) under one
  * or more contributor license agreements.  See the NOTICE file
  * distributed with this work for additional information
  * regarding copyright ownership.  The ASF licenses this file
  * to you under the Apache License, Version 2.0 (the
  * "License"); you may not use this file except in compliance
  * with the License.  You may obtain a copy of the License at
  *
  * http://www.apache.org/licenses/LICENSE-2.0
  *
  * Unless required by applicable law or agreed to in writing,
  * software distributed under the License is distributed on an
  * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
  * KIND, either express or implied.  See the License for the
  * specific language governing permissions and limitations
  * under the License.
  *******************************************************************************/
 package org.ofbiz.content.content;

 import java.sql.Timestamp;
 import java.util.List;
 import java.util.Locale;
 import java.util.Map;

 import javolution.util.FastList;
 import javolution.util.FastMap;

 import org.ofbiz.base.util.Debug;
 import org.ofbiz.base.util.StringUtil;
 import org.ofbiz.base.util.UtilDateTime;
 import org.ofbiz.base.util.UtilGenerics;
 import org.ofbiz.base.util.UtilMisc;
 import org.ofbiz.base.util.UtilValidate;
 import org.ofbiz.entity.Delegator;
 import org.ofbiz.entity.GenericEntityException;
 import org.ofbiz.entity.GenericValue;
 import org.ofbiz.entity.condition.EntityCondition;
 import org.ofbiz.entity.condition.EntityConditionList;
 import org.ofbiz.entity.condition.EntityExpr;
 import org.ofbiz.entity.condition.EntityOperator;
 import org.ofbiz.entity.util.EntityUtil;
 import org.ofbiz.minilang.MiniLangException;
 import org.ofbiz.minilang.SimpleMapProcessor;
 import org.ofbiz.service.DispatchContext;
 import org.ofbiz.service.ServiceUtil;


 /**
  * ContentServicesComplex Class
  */
 public class ContentServicesComplex {

     public static final String module = ContentServicesComplex.class.getName();


    /*
     * A service that returns a list of ContentAssocDataResourceViewFrom/To views that are
     * associated with the passed in contentId. Other conditions are also applied, including:
     * a list of contentAssocTypeIds or contentTypeIds that the result set views must match.
     * A direction (From or To - case insensitive).
     * From and thru dates or date strings.
     * A mapKey value.
     */
     public static Map<String, Object> getAssocAndContentAndDataResource(DispatchContext dctx, Map<String, ? extends Object> context) {
         Delegator delegator = dctx.getDelegator();
         List<String> assocTypes = UtilGenerics.checkList(context.get("assocTypes"));
         List<String> contentTypes = UtilGenerics.checkList(context.get("contentTypes"));
         Timestamp fromDate = (Timestamp)context.get("fromDate");
         Timestamp thruDate = (Timestamp)context.get("thruDate");
         String fromDateStr = (String)context.get("fromDateStr");
         String thruDateStr = (String)context.get("thruDateStr");
         String contentId = (String)context.get("contentId");
         String direction = (String)context.get("direction");
         String mapKey = (String)context.get("mapKey");
         // Boolean nullThruDatesOnly = (Boolean)context.get("nullThruDatesOnly");
         Map<String, Object> results = getAssocAndContentAndDataResourceMethod(delegator, contentId, mapKey, direction, fromDate, thruDate, fromDateStr, thruDateStr, assocTypes, contentTypes);
         return results;
     }

     @SuppressWarnings("unchecked")
     public static Map<String, Object> getAssocAndContentAndDataResourceMethod(Delegator delegator, String contentId, String mapKey, String direction, Timestamp fromDate, Timestamp thruDate, String fromDateStr, String thruDateStr, List<String> assocTypes, List<String> contentTypes) {
         List exprList = FastList.newInstance();
         EntityExpr joinExpr = null;
         String viewName = null;
         if (mapKey != null) {
             EntityExpr mapKeyExpr = EntityCondition.makeCondition("caMapKey", EntityOperator.EQUALS, mapKey);
             exprList.add(mapKeyExpr);
         }
         if (direction != null && direction.equalsIgnoreCase("From")) {
             joinExpr = EntityCondition.makeCondition("caContentIdTo", EntityOperator.EQUALS, contentId);
             viewName = "ContentAssocDataResourceViewFrom";
         } else {
             joinExpr = EntityCondition.makeCondition("caContentId", EntityOperator.EQUALS, contentId);
             viewName = "ContentAssocDataResourceViewTo";
         }
         exprList.add(joinExpr);
         if (UtilValidate.isNotEmpty(assocTypes)) {
             exprList.add(EntityCondition.makeCondition("caContentAssocTypeId", EntityOperator.IN, assocTypes));
         }
         if (UtilValidate.isNotEmpty(contentTypes)) {
             exprList.add(EntityCondition.makeCondition("contentTypeId", EntityOperator.IN, contentTypes));
         }

         if (fromDate == null && fromDateStr != null) {
             fromDate = UtilDateTime.toTimestamp(fromDateStr);
         }
         if (thruDate == null && thruDateStr != null) {
             thruDate = UtilDateTime.toTimestamp(thruDateStr);
         }

         if (fromDate != null) {
             EntityExpr fromExpr = EntityCondition.makeCondition("caFromDate", EntityOperator.LESS_THAN, fromDate);
             exprList.add(fromExpr);
         }
         if (thruDate != null) {
             List<EntityExpr> thruList = FastList.newInstance();
             //thruDate = UtilDateTime.getDayStart(thruDate, daysLater);

             EntityExpr thruExpr = EntityCondition.makeCondition("caThruDate", EntityOperator.LESS_THAN, thruDate);
             thruList.add(thruExpr);
             EntityExpr thruExpr2 = EntityCondition.makeCondition("caThruDate", EntityOperator.EQUALS, null);
             thruList.add(thruExpr2);
             EntityConditionList<EntityExpr> thruExprList = EntityCondition.makeCondition(thruList, EntityOperator.OR);
             exprList.add(thruExprList);
         } else if (fromDate != null) {
             List<EntityExpr> thruList = FastList.newInstance();

             EntityExpr thruExpr = EntityCondition.makeCondition("caThruDate", EntityOperator.GREATER_THAN, fromDate);
             thruList.add(thruExpr);
             EntityExpr thruExpr2 = EntityCondition.makeCondition("caThruDate", EntityOperator.EQUALS, null);
             thruList.add(thruExpr2);
             EntityConditionList<EntityExpr> thruExprList = EntityCondition.makeCondition(thruList, EntityOperator.OR);
             exprList.add(thruExprList);
         }
         EntityConditionList<EntityExpr> assocExprList = EntityCondition.makeCondition(exprList, EntityOperator.AND);
         List<GenericValue> relatedAssocs = null;
         try {
             relatedAssocs = delegator.findList(viewName, assocExprList, null,UtilMisc.toList("caFromDate"), null, false);
         } catch (GenericEntityException e) {
             return ServiceUtil.returnError(e.getMessage());
         }
         for (int i=0; i < relatedAssocs.size(); i++) {
             GenericValue a = relatedAssocs.get(i);
             Debug.logVerbose(" contentId:" + a.get("contentId") + " To:" + a.get("caContentIdTo") + " fromDate:" + a.get("caFromDate") + " thruDate:" + a.get("caThruDate") + " AssocTypeId:" + a.get("caContentAssocTypeId"), null);
         }
         Map<String, Object> results = FastMap.newInstance();
         results.put("entityList", relatedAssocs);
         return results;
     }

    /*
     * A service that returns a list of ContentAssocDataResourceViewFrom/To views that are
     * associated with the passed in contentId. Other conditions are also applied, including:
     * a list of contentAssocTypeIds or contentTypeIds that the result set views must match.
     * A direction (From or To - case insensitive).
     * From and thru dates or date strings.
     * A mapKey value.
     */
     public static Map<String, Object> getAssocAndContentAndDataResourceCache(DispatchContext dctx, Map<String, ? extends Object> context) {
         Delegator delegator = dctx.getDelegator();
         List<String> assocTypes = UtilGenerics.checkList(context.get("assocTypes"));
         String assocTypesString = (String)context.get("assocTypesString");
         if (UtilValidate.isNotEmpty(assocTypesString)) {
             List<String> lst = StringUtil.split(assocTypesString, "|");
             if (assocTypes == null) {
                 assocTypes = FastList.newInstance();
             }
             assocTypes.addAll(lst);
         }
         List<String> contentTypes = UtilGenerics.checkList(context.get("contentTypes"));
         String contentTypesString = (String)context.get("contentTypesString");
         if (UtilValidate.isNotEmpty(contentTypesString)) {
             List<String> lst = StringUtil.split(contentTypesString, "|");
             if (contentTypes == null) {
                 contentTypes = FastList.newInstance();
             }
             contentTypes.addAll(lst);
         }
         Timestamp fromDate = (Timestamp)context.get("fromDate");
         String fromDateStr = (String)context.get("fromDateStr");
         String contentId = (String)context.get("contentId");
         String direction = (String)context.get("direction");
         String mapKey = (String)context.get("mapKey");
         String contentAssocPredicateId = (String)context.get("contentAssocPredicateId");
         Boolean nullThruDatesOnly = (Boolean)context.get("nullThruDatesOnly");
         Map<String, Object> results = null;
         try {
             results = getAssocAndContentAndDataResourceCacheMethod(delegator, contentId, mapKey, direction, fromDate, fromDateStr, assocTypes, contentTypes, nullThruDatesOnly, contentAssocPredicateId);
         } catch (GenericEntityException e) {
             return ServiceUtil.returnError(e.getMessage());
         } catch (MiniLangException e2) {
             return ServiceUtil.returnError(e2.getMessage());
         }
         return results;
     }


     public static Map<String, Object> getAssocAndContentAndDataResourceCacheMethod(Delegator delegator, String contentId, String mapKey, String direction,
                           Timestamp fromDate, String fromDateStr, List<String> assocTypes, List<String> contentTypes, Boolean nullThruDatesOnly, String contentAssocPredicateId) throws GenericEntityException, MiniLangException {
             Map<String, Object> results = getAssocAndContentAndDataResourceCacheMethod(delegator, contentId, mapKey, direction, fromDate, fromDateStr, assocTypes, contentTypes, nullThruDatesOnly, contentAssocPredicateId, null);
             return results;
     }

     public static Map<String, Object> getAssocAndContentAndDataResourceCacheMethod(Delegator delegator, String contentId, String mapKey, String direction,
                           Timestamp fromDate, String fromDateStr, List<String> assocTypes, List<String> contentTypes, Boolean nullThruDatesOnly, String contentAssocPredicateId, String orderBy) throws GenericEntityException, MiniLangException {

         //List exprList = FastList.newInstance();
         //EntityExpr joinExpr = null;
         //EntityExpr expr = null;
         String viewName = null;
         String contentFieldName = null;
         if (direction != null && direction.equalsIgnoreCase("From")) {
             contentFieldName = "contentIdTo";
         } else {
             contentFieldName = "contentId";
         }
         if (direction != null && direction.equalsIgnoreCase("From")) {
             viewName = "ContentAssocDataResourceViewFrom";
         } else {
             viewName = "ContentAssocDataResourceViewTo";
         }
         //if (Debug.infoOn()) Debug.logInfo("in getAssocAndContent...Cache, assocTypes:" + assocTypes, module);
         Map<String, Object> fieldMap = UtilMisc.<String, Object>toMap(contentFieldName, contentId);
         if (assocTypes != null && assocTypes.size() == 1) {
             fieldMap.putAll(UtilMisc.<String, Object>toMap("contentAssocTypeId", assocTypes.get(0)));
         }
         if (UtilValidate.isNotEmpty(mapKey)) {
             if (mapKey.equalsIgnoreCase("is null"))
                 fieldMap.putAll(UtilMisc.<String, Object>toMap("mapKey", null));
             else
                 fieldMap.putAll(UtilMisc.<String, Object>toMap("mapKey", mapKey));
         }
         if (UtilValidate.isNotEmpty(contentAssocPredicateId)) {
             if (contentAssocPredicateId.equalsIgnoreCase("is null"))
                 fieldMap.putAll(UtilMisc.<String, Object>toMap("contentAssocPredicateId", null));
             else
                 fieldMap.putAll(UtilMisc.<String, Object>toMap("contentAssocPredicateId", contentAssocPredicateId));
         }
         if (nullThruDatesOnly != null && nullThruDatesOnly.booleanValue()) {
             fieldMap.putAll(UtilMisc.<String, Object>toMap("thruDate", null));
         }
         List<GenericValue> contentAssocsUnfiltered = null;

         //if (Debug.infoOn()) Debug.logInfo("in getAssocAndContent...Cache, fieldMap:" + fieldMap, module);
         contentAssocsUnfiltered = delegator.findByAnd("ContentAssoc", fieldMap, UtilMisc.toList("-fromDate"), true);

         //if (Debug.infoOn()) Debug.logInfo("in getAssocAndContent...Cache, contentAssocsUnfiltered:" + contentAssocsUnfiltered, module);
         if (fromDate == null && fromDateStr != null) {
             fromDate = UtilDateTime.toTimestamp(fromDateStr);
         }
         List<GenericValue> contentAssocsDateFiltered2 = EntityUtil.filterByDate(contentAssocsUnfiltered, fromDate);
         List<GenericValue> contentAssocsDateFiltered = EntityUtil.orderBy(contentAssocsDateFiltered2, UtilMisc.toList("sequenceNum", "fromDate DESC"));

         String contentAssocTypeId = null;
         List<GenericValue> contentAssocsTypeFiltered = FastList.newInstance();
         if (assocTypes != null && assocTypes.size() > 1) {
             for(GenericValue contentAssoc : contentAssocsDateFiltered) {
                 contentAssocTypeId = (String)contentAssoc.get("contentAssocTypeId");
                 if (assocTypes.contains(contentAssocTypeId)) {
                     contentAssocsTypeFiltered.add(contentAssoc);
                 }
             }
         } else {
             contentAssocsTypeFiltered = contentAssocsDateFiltered;
         }

         String assocRelationName = null;
         if (direction != null && direction.equalsIgnoreCase("To")) {
             assocRelationName = "ToContent";
         } else {
             assocRelationName = "FromContent";
         }

         GenericValue contentAssocDataResourceView = null;
         GenericValue content = null;
         GenericValue dataResource = null;
         List<GenericValue> contentAssocDataResourceList = FastList.newInstance();
         Locale locale = Locale.getDefault(); // TODO: this needs to be passed in
         for(GenericValue contentAssoc : contentAssocsTypeFiltered) {
             content = contentAssoc.getRelatedOne(assocRelationName, true);
             if (UtilValidate.isNotEmpty(contentTypes)) {
                 String contentTypeId = (String)content.get("contentTypeId");
                 if (contentTypes.contains(contentTypeId)) {
                     contentAssocDataResourceView = delegator.makeValue(viewName);
                     contentAssocDataResourceView.setAllFields(content, true, null, null);
                 }
             } else {
                 contentAssocDataResourceView = delegator.makeValue(viewName);
                 contentAssocDataResourceView.setAllFields(content, true, null, null);
             }
             SimpleMapProcessor.runSimpleMapProcessor("component://content/script/org/ofbiz/content/ContentManagementMapProcessors.xml", "contentAssocOut", contentAssoc, contentAssocDataResourceView, FastList.newInstance(), locale);
             //if (Debug.infoOn()) Debug.logInfo("contentAssoc:" + contentAssoc, module);
             //contentAssocDataResourceView.setAllFields(contentAssoc, false, null, null);
             String dataResourceId = content.getString("dataResourceId");
             if (UtilValidate.isNotEmpty(dataResourceId))
                 dataResource = content.getRelatedOne("DataResource", true);
             //if (Debug.infoOn()) Debug.logInfo("dataResource:" + dataResource, module);
             //if (Debug.infoOn()) Debug.logInfo("contentAssocDataResourceView:" + contentAssocDataResourceView, module);
             if (dataResource != null) {
                 //contentAssocDataResourceView.setAllFields(dataResource, false, null, null);
                 SimpleMapProcessor.runSimpleMapProcessor("component://content/script/org/ofbiz/content/ContentManagementMapProcessors.xml", "dataResourceOut", dataResource, contentAssocDataResourceView, FastList.newInstance(), locale);
             }
             //if (Debug.infoOn()) Debug.logInfo("contentAssocDataResourceView:" + contentAssocDataResourceView, module);
             contentAssocDataResourceList.add(contentAssocDataResourceView);
         }

         List<String> orderByList = null;
         if (UtilValidate.isNotEmpty(orderBy)) {
            orderByList = StringUtil.split(orderBy, "|");
            contentAssocDataResourceList = EntityUtil.orderBy(contentAssocDataResourceList, orderByList);
         }
         Map<String, Object> results = FastMap.newInstance();
         results.put("entityList", contentAssocDataResourceList);
         if (UtilValidate.isNotEmpty(contentAssocDataResourceList)) {
             results.put("view", contentAssocDataResourceList.get(0));
         }
         return results;
     }

 /*
     public static Map getSubContentAndDataResource(Delegator delegator, String contentId, String direction, Timestamp fromDate,  String assocType, String contentType, String orderBy) throws GenericEntityException {

         List exprList = FastList.newInstance();
         EntityExpr joinExpr = null;
         EntityExpr expr = null;
         String viewName = null;
         GenericValue contentAssoc = null;
         String contentFieldName = null;
         if (direction != null && direction.equalsIgnoreCase("From")) {
             viewName = "ContentAssocDataResourceViewFrom";
             contentFieldName = "contentIdTo";
             joinExpr = EntityCondition.makeCondition("caContentIdTo", EntityOperator.EQUALS, contentId);
         } else {
             viewName = "ContentAssocDataResourceViewTo";
             contentFieldName = "contentId";
             joinExpr = EntityCondition.makeCondition("caContentId", EntityOperator.EQUALS, contentId);
         }
         exprList.add(joinExpr);

         if (UtilValidate.isNotEmpty(assocType)) {
             expr = EntityCondition.makeCondition("caContentAssocTypeId", EntityOperator.EQUALS, assocType);
             exprList.add(expr);
         }

         if (UtilValidate.isNotEmpty(contentType)) {
             expr = EntityCondition.makeCondition("caContentTypeId", EntityOperator.EQUALS, contentType);
             exprList.add(expr);
         }

         List orderByList = null;
         if (UtilValidate.isNotEmpty(orderBy)) {
            orderByList = StringUtil.split(orderBy, "|");
            contentAssocDataResourceList = EntityUtil.orderBy(contentAssocDataResourceList, orderByList);
         }
         HashMap results = FastMap.newInstance();
         results.put("entityList", contentAssocDataResourceList);
         return results;
     }
 */
 }
	/*******************************************************************************
	* Licensed to the Apache Software Foundation (ASF) under one
	* or more contributor license agreements. See the NOTICE file
	* distributed with this work for additional information
	* regarding copyright ownership. The ASF licenses this file
	* to you under the Apache License, Version 2.0 (the
	* "License"); you may not use this file except in compliance
	* with the License. You may obtain a copy of the License at
	*
	* http://www.apache.org/licenses/LICENSE-2.0
	*
	* Unless required by applicable law or agreed to in writing,
	* software distributed under the License is distributed on an
	* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
	* KIND, either express or implied. See the License for the
	* specific language governing permissions and limitations
	* under the License.
	*******************************************************************************/
	package org.ofbiz.content.content;

	import java.sql.Timestamp;
	import java.util.List;
	import java.util.Locale;
	import java.util.Map;

	import javolution.util.FastList;
	import javolution.util.FastMap;

	import org.ofbiz.base.util.Debug;
	import org.ofbiz.base.util.StringUtil;
	import org.ofbiz.base.util.UtilDateTime;
	import org.ofbiz.base.util.UtilGenerics;
	import org.ofbiz.base.util.UtilMisc;
	import org.ofbiz.base.util.UtilValidate;
	import org.ofbiz.entity.Delegator;
	import org.ofbiz.entity.GenericEntityException;
	import org.ofbiz.entity.GenericValue;
	import org.ofbiz.entity.condition.EntityCondition;
	import org.ofbiz.entity.condition.EntityConditionList;
	import org.ofbiz.entity.condition.EntityExpr;
	import org.ofbiz.entity.condition.EntityOperator;
	import org.ofbiz.entity.util.EntityUtil;
	import org.ofbiz.minilang.MiniLangException;
	import org.ofbiz.minilang.SimpleMapProcessor;
	import org.ofbiz.service.DispatchContext;
	import org.ofbiz.service.ServiceUtil;


	/**
	* ContentServicesComplex Class
	*/
	public class ContentServicesComplex {

	public static final String module = ContentServicesComplex.class.getName();


	/*
	* A service that returns a list of ContentAssocDataResourceViewFrom/To views that are
	* associated with the passed in contentId. Other conditions are also applied, including:
	* a list of contentAssocTypeIds or contentTypeIds that the result set views must match.
	* A direction (From or To - case insensitive).
	* From and thru dates or date strings.
	* A mapKey value.
	*/
	public static Map<String, Object> getAssocAndContentAndDataResource(DispatchContext dctx, Map<String, ? extends Object> context) {
	Delegator delegator = dctx.getDelegator();
	List<String> assocTypes = UtilGenerics.checkList(context.get("assocTypes"));
	List<String> contentTypes = UtilGenerics.checkList(context.get("contentTypes"));
	Timestamp fromDate = (Timestamp)context.get("fromDate");
	Timestamp thruDate = (Timestamp)context.get("thruDate");
	String fromDateStr = (String)context.get("fromDateStr");
	String thruDateStr = (String)context.get("thruDateStr");
	String contentId = (String)context.get("contentId");
	String direction = (String)context.get("direction");
	String mapKey = (String)context.get("mapKey");
	// Boolean nullThruDatesOnly = (Boolean)context.get("nullThruDatesOnly");
	Map<String, Object> results = getAssocAndContentAndDataResourceMethod(delegator, contentId, mapKey, direction, fromDate, thruDate, fromDateStr, thruDateStr, assocTypes, contentTypes);
	return results;
	}

	@SuppressWarnings("unchecked")
	public static Map<String, Object> getAssocAndContentAndDataResourceMethod(Delegator delegator, String contentId, String mapKey, String direction, Timestamp fromDate, Timestamp thruDate, String fromDateStr, String thruDateStr, List<String> assocTypes, List<String> contentTypes) {
	List exprList = FastList.newInstance();
	EntityExpr joinExpr = null;
	String viewName = null;
	if (mapKey != null) {
	EntityExpr mapKeyExpr = EntityCondition.makeCondition("caMapKey", EntityOperator.EQUALS, mapKey);
	exprList.add(mapKeyExpr);
	}
	if (direction != null && direction.equalsIgnoreCase("From")) {
	joinExpr = EntityCondition.makeCondition("caContentIdTo", EntityOperator.EQUALS, contentId);
	viewName = "ContentAssocDataResourceViewFrom";
	} else {
	joinExpr = EntityCondition.makeCondition("caContentId", EntityOperator.EQUALS, contentId);
	viewName = "ContentAssocDataResourceViewTo";
	}
	exprList.add(joinExpr);
	if (UtilValidate.isNotEmpty(assocTypes)) {
	exprList.add(EntityCondition.makeCondition("caContentAssocTypeId", EntityOperator.IN, assocTypes));
	}
	if (UtilValidate.isNotEmpty(contentTypes)) {
	exprList.add(EntityCondition.makeCondition("contentTypeId", EntityOperator.IN, contentTypes));
	}

	if (fromDate == null && fromDateStr != null) {
	fromDate = UtilDateTime.toTimestamp(fromDateStr);
	}
	if (thruDate == null && thruDateStr != null) {
	thruDate = UtilDateTime.toTimestamp(thruDateStr);
	}

	if (fromDate != null) {
	EntityExpr fromExpr = EntityCondition.makeCondition("caFromDate", EntityOperator.LESS_THAN, fromDate);
	exprList.add(fromExpr);
	}
	if (thruDate != null) {
	List<EntityExpr> thruList = FastList.newInstance();
	//thruDate = UtilDateTime.getDayStart(thruDate, daysLater);

	EntityExpr thruExpr = EntityCondition.makeCondition("caThruDate", EntityOperator.LESS_THAN, thruDate);
	thruList.add(thruExpr);
	EntityExpr thruExpr2 = EntityCondition.makeCondition("caThruDate", EntityOperator.EQUALS, null);
	thruList.add(thruExpr2);
	EntityConditionList<EntityExpr> thruExprList = EntityCondition.makeCondition(thruList, EntityOperator.OR);
	exprList.add(thruExprList);
	} else if (fromDate != null) {
	List<EntityExpr> thruList = FastList.newInstance();

	EntityExpr thruExpr = EntityCondition.makeCondition("caThruDate", EntityOperator.GREATER_THAN, fromDate);
	thruList.add(thruExpr);
	EntityExpr thruExpr2 = EntityCondition.makeCondition("caThruDate", EntityOperator.EQUALS, null);
	thruList.add(thruExpr2);
	EntityConditionList<EntityExpr> thruExprList = EntityCondition.makeCondition(thruList, EntityOperator.OR);
	exprList.add(thruExprList);
	}
	EntityConditionList<EntityExpr> assocExprList = EntityCondition.makeCondition(exprList, EntityOperator.AND);
	List<GenericValue> relatedAssocs = null;
	try {
	relatedAssocs = delegator.findList(viewName, assocExprList, null,UtilMisc.toList("caFromDate"), null, false);
	} catch (GenericEntityException e) {
	return ServiceUtil.returnError(e.getMessage());
	}
	for (int i=0; i < relatedAssocs.size(); i++) {
	GenericValue a = relatedAssocs.get(i);
	Debug.logVerbose(" contentId:" + a.get("contentId") + " To:" + a.get("caContentIdTo") + " fromDate:" + a.get("caFromDate") + " thruDate:" + a.get("caThruDate") + " AssocTypeId:" + a.get("caContentAssocTypeId"), null);
	}
	Map<String, Object> results = FastMap.newInstance();
	results.put("entityList", relatedAssocs);
	return results;
	}

	/*
	* A service that returns a list of ContentAssocDataResourceViewFrom/To views that are
	* associated with the passed in contentId. Other conditions are also applied, including:
	* a list of contentAssocTypeIds or contentTypeIds that the result set views must match.
	* A direction (From or To - case insensitive).
	* From and thru dates or date strings.
	* A mapKey value.
	*/
	public static Map<String, Object> getAssocAndContentAndDataResourceCache(DispatchContext dctx, Map<String, ? extends Object> context) {
	Delegator delegator = dctx.getDelegator();
	List<String> assocTypes = UtilGenerics.checkList(context.get("assocTypes"));
	String assocTypesString = (String)context.get("assocTypesString");
	if (UtilValidate.isNotEmpty(assocTypesString)) {
	List<String> lst = StringUtil.split(assocTypesString, "\|");
	if (assocTypes == null) {
	assocTypes = FastList.newInstance();
	}
	assocTypes.addAll(lst);
	}
	List<String> contentTypes = UtilGenerics.checkList(context.get("contentTypes"));
	String contentTypesString = (String)context.get("contentTypesString");
	if (UtilValidate.isNotEmpty(contentTypesString)) {
	List<String> lst = StringUtil.split(contentTypesString, "\|");
	if (contentTypes == null) {
	contentTypes = FastList.newInstance();
	}
	contentTypes.addAll(lst);
	}
	Timestamp fromDate = (Timestamp)context.get("fromDate");
	String fromDateStr = (String)context.get("fromDateStr");
	String contentId = (String)context.get("contentId");
	String direction = (String)context.get("direction");
	String mapKey = (String)context.get("mapKey");
	String contentAssocPredicateId = (String)context.get("contentAssocPredicateId");
	Boolean nullThruDatesOnly = (Boolean)context.get("nullThruDatesOnly");
	Map<String, Object> results = null;
	try {
	results = getAssocAndContentAndDataResourceCacheMethod(delegator, contentId, mapKey, direction, fromDate, fromDateStr, assocTypes, contentTypes, nullThruDatesOnly, contentAssocPredicateId);
	} catch (GenericEntityException e) {
	return ServiceUtil.returnError(e.getMessage());
	} catch (MiniLangException e2) {
	return ServiceUtil.returnError(e2.getMessage());
	}
	return results;
	}


	public static Map<String, Object> getAssocAndContentAndDataResourceCacheMethod(Delegator delegator, String contentId, String mapKey, String direction,
	Timestamp fromDate, String fromDateStr, List<String> assocTypes, List<String> contentTypes, Boolean nullThruDatesOnly, String contentAssocPredicateId) throws GenericEntityException, MiniLangException {
	Map<String, Object> results = getAssocAndContentAndDataResourceCacheMethod(delegator, contentId, mapKey, direction, fromDate, fromDateStr, assocTypes, contentTypes, nullThruDatesOnly, contentAssocPredicateId, null);
	return results;
	}

	public static Map<String, Object> getAssocAndContentAndDataResourceCacheMethod(Delegator delegator, String contentId, String mapKey, String direction,
	Timestamp fromDate, String fromDateStr, List<String> assocTypes, List<String> contentTypes, Boolean nullThruDatesOnly, String contentAssocPredicateId, String orderBy) throws GenericEntityException, MiniLangException {

	//List exprList = FastList.newInstance();
	//EntityExpr joinExpr = null;
	//EntityExpr expr = null;
	String viewName = null;
	String contentFieldName = null;
	if (direction != null && direction.equalsIgnoreCase("From")) {
	contentFieldName = "contentIdTo";
	} else {
	contentFieldName = "contentId";
	}
	if (direction != null && direction.equalsIgnoreCase("From")) {
	viewName = "ContentAssocDataResourceViewFrom";
	} else {
	viewName = "ContentAssocDataResourceViewTo";
	}
	//if (Debug.infoOn()) Debug.logInfo("in getAssocAndContent...Cache, assocTypes:" + assocTypes, module);
	Map<String, Object> fieldMap = UtilMisc.<String, Object>toMap(contentFieldName, contentId);
	if (assocTypes != null && assocTypes.size() == 1) {
	fieldMap.putAll(UtilMisc.<String, Object>toMap("contentAssocTypeId", assocTypes.get(0)));
	}
	if (UtilValidate.isNotEmpty(mapKey)) {
	if (mapKey.equalsIgnoreCase("is null"))
	fieldMap.putAll(UtilMisc.<String, Object>toMap("mapKey", null));
	else
	fieldMap.putAll(UtilMisc.<String, Object>toMap("mapKey", mapKey));
	}
	if (UtilValidate.isNotEmpty(contentAssocPredicateId)) {
	if (contentAssocPredicateId.equalsIgnoreCase("is null"))
	fieldMap.putAll(UtilMisc.<String, Object>toMap("contentAssocPredicateId", null));
	else
	fieldMap.putAll(UtilMisc.<String, Object>toMap("contentAssocPredicateId", contentAssocPredicateId));
	}
	if (nullThruDatesOnly != null && nullThruDatesOnly.booleanValue()) {
	fieldMap.putAll(UtilMisc.<String, Object>toMap("thruDate", null));
	}
	List<GenericValue> contentAssocsUnfiltered = null;

	//if (Debug.infoOn()) Debug.logInfo("in getAssocAndContent...Cache, fieldMap:" + fieldMap, module);
	contentAssocsUnfiltered = delegator.findByAnd("ContentAssoc", fieldMap, UtilMisc.toList("-fromDate"), true);

	//if (Debug.infoOn()) Debug.logInfo("in getAssocAndContent...Cache, contentAssocsUnfiltered:" + contentAssocsUnfiltered, module);
	if (fromDate == null && fromDateStr != null) {
	fromDate = UtilDateTime.toTimestamp(fromDateStr);
	}
	List<GenericValue> contentAssocsDateFiltered2 = EntityUtil.filterByDate(contentAssocsUnfiltered, fromDate);
	List<GenericValue> contentAssocsDateFiltered = EntityUtil.orderBy(contentAssocsDateFiltered2, UtilMisc.toList("sequenceNum", "fromDate DESC"));

	String contentAssocTypeId = null;
	List<GenericValue> contentAssocsTypeFiltered = FastList.newInstance();
	if (assocTypes != null && assocTypes.size() > 1) {
	for(GenericValue contentAssoc : contentAssocsDateFiltered) {
	contentAssocTypeId = (String)contentAssoc.get("contentAssocTypeId");
	if (assocTypes.contains(contentAssocTypeId)) {
	contentAssocsTypeFiltered.add(contentAssoc);
	}
	}
	} else {
	contentAssocsTypeFiltered = contentAssocsDateFiltered;
	}

	String assocRelationName = null;
	if (direction != null && direction.equalsIgnoreCase("To")) {
	assocRelationName = "ToContent";
	} else {
	assocRelationName = "FromContent";
	}

	GenericValue contentAssocDataResourceView = null;
	GenericValue content = null;
	GenericValue dataResource = null;
	List<GenericValue> contentAssocDataResourceList = FastList.newInstance();
	Locale locale = Locale.getDefault(); // TODO: this needs to be passed in
	for(GenericValue contentAssoc : contentAssocsTypeFiltered) {
	content = contentAssoc.getRelatedOne(assocRelationName, true);
	if (UtilValidate.isNotEmpty(contentTypes)) {
	String contentTypeId = (String)content.get("contentTypeId");
	if (contentTypes.contains(contentTypeId)) {
	contentAssocDataResourceView = delegator.makeValue(viewName);
	contentAssocDataResourceView.setAllFields(content, true, null, null);
	}
	} else {
	contentAssocDataResourceView = delegator.makeValue(viewName);
	contentAssocDataResourceView.setAllFields(content, true, null, null);
	}
	SimpleMapProcessor.runSimpleMapProcessor("component://content/script/org/ofbiz/content/ContentManagementMapProcessors.xml", "contentAssocOut", contentAssoc, contentAssocDataResourceView, FastList.newInstance(), locale);
	//if (Debug.infoOn()) Debug.logInfo("contentAssoc:" + contentAssoc, module);
	//contentAssocDataResourceView.setAllFields(contentAssoc, false, null, null);
	String dataResourceId = content.getString("dataResourceId");
	if (UtilValidate.isNotEmpty(dataResourceId))
	dataResource = content.getRelatedOne("DataResource", true);
	//if (Debug.infoOn()) Debug.logInfo("dataResource:" + dataResource, module);
	//if (Debug.infoOn()) Debug.logInfo("contentAssocDataResourceView:" + contentAssocDataResourceView, module);
	if (dataResource != null) {
	//contentAssocDataResourceView.setAllFields(dataResource, false, null, null);
	SimpleMapProcessor.runSimpleMapProcessor("component://content/script/org/ofbiz/content/ContentManagementMapProcessors.xml", "dataResourceOut", dataResource, contentAssocDataResourceView, FastList.newInstance(), locale);
	}
	//if (Debug.infoOn()) Debug.logInfo("contentAssocDataResourceView:" + contentAssocDataResourceView, module);
	contentAssocDataResourceList.add(contentAssocDataResourceView);
	}

	List<String> orderByList = null;
	if (UtilValidate.isNotEmpty(orderBy)) {
	orderByList = StringUtil.split(orderBy, "\|");
	contentAssocDataResourceList = EntityUtil.orderBy(contentAssocDataResourceList, orderByList);
	}
	Map<String, Object> results = FastMap.newInstance();
	results.put("entityList", contentAssocDataResourceList);
	if (UtilValidate.isNotEmpty(contentAssocDataResourceList)) {
	results.put("view", contentAssocDataResourceList.get(0));
	}
	return results;
	}

	/*
	public static Map getSubContentAndDataResource(Delegator delegator, String contentId, String direction, Timestamp fromDate, String assocType, String contentType, String orderBy) throws GenericEntityException {

	List exprList = FastList.newInstance();
	EntityExpr joinExpr = null;
	EntityExpr expr = null;
	String viewName = null;
	GenericValue contentAssoc = null;
	String contentFieldName = null;
	if (direction != null && direction.equalsIgnoreCase("From")) {
	viewName = "ContentAssocDataResourceViewFrom";
	contentFieldName = "contentIdTo";
	joinExpr = EntityCondition.makeCondition("caContentIdTo", EntityOperator.EQUALS, contentId);
	} else {
	viewName = "ContentAssocDataResourceViewTo";
	contentFieldName = "contentId";
	joinExpr = EntityCondition.makeCondition("caContentId", EntityOperator.EQUALS, contentId);
	}
	exprList.add(joinExpr);

	if (UtilValidate.isNotEmpty(assocType)) {
	expr = EntityCondition.makeCondition("caContentAssocTypeId", EntityOperator.EQUALS, assocType);
	exprList.add(expr);
	}

	if (UtilValidate.isNotEmpty(contentType)) {
	expr = EntityCondition.makeCondition("caContentTypeId", EntityOperator.EQUALS, contentType);
	exprList.add(expr);
	}

	List orderByList = null;
	if (UtilValidate.isNotEmpty(orderBy)) {
	orderByList = StringUtil.split(orderBy, "\|");
	contentAssocDataResourceList = EntityUtil.orderBy(contentAssocDataResourceList, orderByList);
	}
	HashMap results = FastMap.newInstance();
	results.put("entityList", contentAssocDataResourceList);
	return results;
	}
	*/
	}