Update of
/var/cvs/contributions/CMSContainer_Portlets/portlets-newsletter/src/java/com/finalist/newsletter/cao/impl
In directory
james.mmbase.org:/tmp/cvs-serv7519/java/com/finalist/newsletter/cao/impl
Modified Files:
NewsLetterStatisticCAOImpl.java NewsletterCAOImpl.java
NewsletterPublicationCAOImpl.java
NewsletterSubscriptionCAOImpl.java
Log Message:
CMSC-1085 Newsletter publication should be emailed from Live environment
See also:
http://cvs.mmbase.org/viewcvs/contributions/CMSContainer_Portlets/portlets-newsletter/src/java/com/finalist/newsletter/cao/impl
See also: http://www.mmbase.org/jira/browse/CMSC-1085
Index: NewsLetterStatisticCAOImpl.java
===================================================================
RCS file:
/var/cvs/contributions/CMSContainer_Portlets/portlets-newsletter/src/java/com/finalist/newsletter/cao/impl/NewsLetterStatisticCAOImpl.java,v
retrieving revision 1.18
retrieving revision 1.19
diff -u -b -r1.18 -r1.19
--- NewsLetterStatisticCAOImpl.java 14 Oct 2008 11:22:44 -0000 1.18
+++ NewsLetterStatisticCAOImpl.java 27 Oct 2008 05:56:30 -0000 1.19
@@ -8,7 +8,6 @@
import java.util.Map;
import org.apache.commons.lang.time.DateUtils;
-import org.mmbase.bridge.Cloud;
import org.mmbase.bridge.Node;
import org.mmbase.bridge.NodeList;
import org.mmbase.bridge.NodeManager;
@@ -24,24 +23,22 @@
import org.mmbase.storage.search.implementation.BasicFieldValueConstraint;
import org.mmbase.util.logging.Logger;
import org.mmbase.util.logging.Logging;
+
+import com.finalist.newsletter.cao.AbstractCAO;
import com.finalist.newsletter.cao.NewsLetterStatisticCAO;
import com.finalist.newsletter.cao.util.StatisticUtil;
import com.finalist.newsletter.domain.StatisticResult;
import com.finalist.newsletter.domain.StatisticResult.HANDLE;
-public class NewsLetterStatisticCAOImpl implements NewsLetterStatisticCAO {
+public class NewsLetterStatisticCAOImpl extends AbstractCAO implements
NewsLetterStatisticCAO {
- private Cloud cloud;
- private static Logger log =
Logging.getLoggerInstance(NewsLetterStatisticCAOImpl.class.getName());
- public void setCloud(Cloud cloud) {
- this.cloud = cloud;
- }
+ private static Logger log =
Logging.getLoggerInstance(NewsLetterStatisticCAOImpl.class.getName());
public List<StatisticResult> getAllRecords() {
- NodeQuery query = cloud.createNodeQuery();
- Step step = query.addStep(cloud.getNodeManager("newsletterdailylog"));
+ NodeQuery query = getCloud().createNodeQuery();
+ Step step =
query.addStep(getCloud().getNodeManager("newsletterdailylog"));
query.setNodeStep(step);
NodeList list = query.getList();
StatisticUtil util = new StatisticUtil();
@@ -49,8 +46,8 @@
}
public List<StatisticResult> getRecordsByNewsletter(int newsletter) {
- NodeQuery query = cloud.createNodeQuery();
- NodeManager manager = cloud.getNodeManager("newsletterdailylog");
+ NodeQuery query = getCloud().createNodeQuery();
+ NodeManager manager = getCloud().getNodeManager("newsletterdailylog");
Step step1 = query.addStep(manager);
StepField field1 = query.addField(step1, manager.getField("newsletter"));
query.addField(step1, manager.getField("subscribe"));
@@ -68,8 +65,8 @@
}
public List<StatisticResult> getAllRecordsByPeriod(Date start, Date end) {
- NodeQuery query = cloud.createNodeQuery();
- NodeManager manager = cloud.getNodeManager("newsletterdailylog");
+ NodeQuery query = getCloud().createNodeQuery();
+ NodeManager manager = getCloud().getNodeManager("newsletterdailylog");
Step step1 = query.addStep(manager);
query.addField(step1, manager.getField("subscribe"));
query.addField(step1, manager.getField("post"));
@@ -144,8 +141,8 @@
Date now = new Date();
Date startDate = DateUtils.addHours(now, -23);
Date endDate = DateUtils.addDays(now, 0);
- NodeQuery query = cloud.createNodeQuery();
- NodeManager manager = cloud.getNodeManager("newsletterdailylog");
+ NodeQuery query = getCloud().createNodeQuery();
+ NodeManager manager = getCloud().getNodeManager("newsletterdailylog");
Step step = query.addStep(manager);
StepField field = query.addField(step, manager.getField("logdate"));
StepField field1 = query.addField(step, manager.getField("post"));
@@ -186,8 +183,8 @@
}
public List<StatisticResult> getRecordsByNewsletterAndPeriod(Date start,
Date end, int newsletter) {
- NodeQuery query = cloud.createNodeQuery();
- NodeManager manager = cloud.getNodeManager("newsletterdailylog");
+ NodeQuery query = getCloud().createNodeQuery();
+ NodeManager manager = getCloud().getNodeManager("newsletterdailylog");
Step step1 = query.addStep(manager);
query.addField(step1, manager.getField("subscribe"));
query.addField(step1, manager.getField("post"));
@@ -221,8 +218,8 @@
logNode.setDateValue("logdate", new Date());
logNode.commit();
} else {
- NodeManager logManager = cloud.getNodeManager("newsletterdailylog");
- // Node newsletter = cloud.getNode(newsletterId);
+ NodeManager logManager =
getCloud().getNodeManager("newsletterdailylog");
+ // Node newsletter = getRemoteCloud().getNode(newsletterId);
logNode = logManager.createNode();
logNode.setIntValue("newsletter", newsletterId);
logNode.setIntValue("post", 0);
@@ -255,8 +252,8 @@
}
boolean isLog = false;
- NodeManager logNodeManager = cloud.getNodeManager("newsletterdailylog");
- NodeQuery query = cloud.createNodeQuery();
+ NodeManager logNodeManager =
getCloud().getNodeManager("newsletterdailylog");
+ NodeQuery query = getCloud().createNodeQuery();
Step parameterStep = query.addStep(logNodeManager);
query.setNodeStep(parameterStep);
Queries.addSortOrders(query, "logdate", "DOWN");
@@ -285,9 +282,9 @@
public Node getLogNode(int userId, int newsletterId) {
log.info("-------------------logPubliction -in
process...getLogNode....: ");
- NodeManager logNodeManager = cloud.getNodeManager("newsletterdailylog");
+ NodeManager logNodeManager =
getCloud().getNodeManager("newsletterdailylog");
Node logNode = null;
- NodeQuery query = cloud.createNodeQuery();
+ NodeQuery query = getCloud().createNodeQuery();
Step parameterStep = query.addStep(logNodeManager);
query.setNodeStep(parameterStep);
Queries.addSortOrders(query, "logdate", "DOWN");
@@ -312,7 +309,7 @@
*/
public int insertSumedLogs(List<StatisticResult> logsList) {
int i = 0;
- NodeManager logManager = cloud.getNodeManager("newsletterdailylog");
+ NodeManager logManager = getCloud().getNodeManager("newsletterdailylog");
Node logNode;
Date now = new Date();
Date start = DateUtils.addHours(now, -12);
Index: NewsletterCAOImpl.java
===================================================================
RCS file:
/var/cvs/contributions/CMSContainer_Portlets/portlets-newsletter/src/java/com/finalist/newsletter/cao/impl/NewsletterCAOImpl.java,v
retrieving revision 1.25
retrieving revision 1.26
diff -u -b -r1.25 -r1.26
--- NewsletterCAOImpl.java 22 Oct 2008 06:41:05 -0000 1.25
+++ NewsletterCAOImpl.java 27 Oct 2008 05:56:30 -0000 1.26
@@ -32,8 +32,8 @@
}
public List<Term> getALLTerm() {
- NodeQuery query = cloud.createNodeQuery();
- Step step = query.addStep(cloud.getNodeManager("term"));
+ NodeQuery query = getCloud().createNodeQuery();
+ Step step = query.addStep(getCloud().getNodeManager("term"));
query.setNodeStep(step);
NodeList list = query.getList();
return MMBaseNodeMapper.convertList(list, Term.class);
@@ -42,8 +42,8 @@
public List<Newsletter> getNewsletterByConstraint(String property, String
constraintType, String value,
boolean paging) {
PagingStatusHolder pagingHolder = PagingUtils.getStatusHolder();
- NodeQuery query = cloud.createNodeQuery();
- NodeManager nodeManager = cloud.getNodeManager("newsletter");
+ NodeQuery query = getCloud().createNodeQuery();
+ NodeManager nodeManager = getCloud().getNodeManager("newsletter");
Step step = query.addStep(nodeManager);
query.setNodeStep(step);
if (StringUtils.isNotBlank(property)) {
@@ -67,7 +67,7 @@
public int getNewsletterIdBySubscription(int id) {
log.debug("Get newsletter by subsription " + id);
- Node subscriptionNode = cloud.getNode(id);
+ Node subscriptionNode = getCloud().getNode(id);
NodeList nodes = subscriptionNode.getRelatedNodes("newsletter");
if (nodes.size() > 0) {
@@ -78,11 +78,11 @@
}
public Node getNewsletterNodeById(int newsletterId) {
- return cloud.getNode(newsletterId);
+ return getCloud().getNode(newsletterId);
}
public Newsletter getNewsletterById(int id) {
- Node newsletterNode = cloud.getNode(id);
+ Node newsletterNode = getCloud().getNode(id);
Newsletter newsletter = convertFromNode(newsletterNode);
NodeList terms = newsletterNode.getRelatedNodes("term");
@@ -107,10 +107,10 @@
public List<Term> getNewsletterTermsByName(int newsletterId, String name,
boolean paging) {
PagingStatusHolder pagingHolder = PagingUtils.getStatusHolder();
- NodeManager termNodeManager = cloud.getNodeManager("term");
- NodeManager newsletterNodeManager = cloud.getNodeManager("newsletter");
+ NodeManager termNodeManager = getCloud().getNodeManager("term");
+ NodeManager newsletterNodeManager =
getCloud().getNodeManager("newsletter");
- NodeQuery query = cloud.createNodeQuery();
+ NodeQuery query = getCloud().createNodeQuery();
Step newsletterStep = query.addStep(newsletterNodeManager);
query.setNodeStep(newsletterStep);
Constraint idConstraint = SearchUtil.createEqualConstraint(query,
newsletterNodeManager.getField("number"),
@@ -143,7 +143,7 @@
}
public void processBouncesOfPublication(String publicationId, String
userId, String bounceContent) {
- NodeManager bounceManager = cloud.getNodeManager("newsletterbounce");
+ NodeManager bounceManager =
getCloud().getNodeManager("newsletterbounce");
Node node = bounceManager.createNode();
if (StringUtils.isNotEmpty(publicationId)) {
node.setIntValue("newsletter", Integer.parseInt(publicationId));
Index: NewsletterPublicationCAOImpl.java
===================================================================
RCS file:
/var/cvs/contributions/CMSContainer_Portlets/portlets-newsletter/src/java/com/finalist/newsletter/cao/impl/NewsletterPublicationCAOImpl.java,v
retrieving revision 1.25
retrieving revision 1.26
diff -u -b -r1.25 -r1.26
--- NewsletterPublicationCAOImpl.java 14 Oct 2008 11:22:44 -0000 1.25
+++ NewsletterPublicationCAOImpl.java 27 Oct 2008 05:56:30 -0000 1.26
@@ -1,19 +1,19 @@
package com.finalist.newsletter.cao.impl;
-import com.finalist.cmsc.beans.MMBaseNodeMapper;
-import com.finalist.cmsc.navigation.NavigationUtil;
-import com.finalist.cmsc.paging.PagingStatusHolder;
-import com.finalist.cmsc.paging.PagingUtils;
-import com.finalist.newsletter.cao.NewsletterPublicationCAO;
-import com.finalist.newsletter.domain.Newsletter;
-import com.finalist.newsletter.domain.Publication;
-import com.finalist.newsletter.domain.Term;
-import com.finalist.newsletter.util.NewsletterUtil;
-import com.finalist.newsletter.util.POConvertUtils;
+import java.util.ArrayList;
+import java.util.Date;
+import java.util.HashSet;
+import java.util.Iterator;
+import java.util.List;
+import java.util.Set;
import org.apache.commons.lang.StringUtils;
import org.apache.commons.lang.time.DateFormatUtils;
-import org.mmbase.bridge.*;
+import org.mmbase.bridge.Field;
+import org.mmbase.bridge.Node;
+import org.mmbase.bridge.NodeList;
+import org.mmbase.bridge.NodeManager;
+import org.mmbase.bridge.NodeQuery;
import org.mmbase.bridge.util.Queries;
import org.mmbase.bridge.util.SearchUtil;
import org.mmbase.storage.search.Constraint;
@@ -21,23 +21,27 @@
import org.mmbase.util.logging.Logger;
import org.mmbase.util.logging.Logging;
-import java.util.*;
+import com.finalist.cmsc.beans.MMBaseNodeMapper;
+import com.finalist.cmsc.navigation.NavigationUtil;
+import com.finalist.cmsc.paging.PagingStatusHolder;
+import com.finalist.cmsc.paging.PagingUtils;
+import com.finalist.newsletter.cao.AbstractCAO;
+import com.finalist.newsletter.cao.NewsletterPublicationCAO;
+import com.finalist.newsletter.domain.Newsletter;
+import com.finalist.newsletter.domain.Publication;
+import com.finalist.newsletter.domain.Term;
+import com.finalist.newsletter.util.NewsletterUtil;
+import com.finalist.newsletter.util.POConvertUtils;
-public class NewsletterPublicationCAOImpl implements NewsletterPublicationCAO {
+public class NewsletterPublicationCAOImpl extends AbstractCAO implements
NewsletterPublicationCAO {
private static Logger log =
Logging.getLoggerInstance(NewsletterPublicationCAOImpl.class.getName());
- Cloud cloud;
-
- public void setCloud(Cloud cloud) {
- this.cloud = cloud;
- }
-
public List<Integer> getIntimePublicationIds() {
- NodeQuery query = cloud.createNodeQuery();
+ NodeQuery query = getCloud().createNodeQuery();
- NodeManager pubManager = cloud.getNodeManager("newsletterpublication");
+ NodeManager pubManager =
getCloud().getNodeManager("newsletterpublication");
Step theStep = query.addStep(pubManager);
query.setNodeStep(theStep);
@@ -56,13 +60,13 @@
}
public void setStatus(int publicationId, Publication.STATUS status) {
- Node publicationNode = cloud.getNode(publicationId);
+ Node publicationNode = getCloud().getNode(publicationId);
publicationNode.setStringValue("status", status.toString());
publicationNode.commit();
}
public Publication getPublication(int number) {
- Node newsletterPublicationNode = cloud.getNode(number);
+ Node newsletterPublicationNode = getCloud().getNode(number);
List<Node> relatedNewsletters =
newsletterPublicationNode.getRelatedNodes("newsletter");
log.debug("Get " + relatedNewsletters.size() + " related newsletter");
@@ -84,19 +88,19 @@
}
public Node getPublicationNode(int number) {
- return cloud.getNode(number);
+ return getCloud().getNode(number);
}
public String getPublicationURL(int publciationId) {
- Node publicationNode = cloud.getNode(publciationId);
+ Node publicationNode = getCloud().getNode(publciationId);
String hostUrl = NewsletterUtil.getServerURL();
String newsletterPath = getNewsletterPath(publicationNode);
return "".concat(hostUrl).concat(newsletterPath);
}
public int getNewsletterId(int publicationId) {
- Node newsletterPublicationNode = cloud.getNode(publicationId);
+ Node newsletterPublicationNode = getCloud().getNode(publicationId);
NodeList relatedNewsletters =
newsletterPublicationNode.getRelatedNodes("newsletter");
log.debug("Get " + relatedNewsletters.size() + " related newsletter");
@@ -105,15 +109,15 @@
}
public List<Publication> getAllPublications() {
- NodeQuery query = cloud.createNodeQuery();
- Step step = query.addStep(cloud.getNodeManager("newsletterpublication"));
+ NodeQuery query = getCloud().createNodeQuery();
+ Step step =
query.addStep(getCloud().getNodeManager("newsletterpublication"));
query.setNodeStep(step);
NodeList list = query.getList();
return MMBaseNodeMapper.convertList(list, Publication.class);
}
public List<Publication> getPublicationsByNewsletter(int id,
Publication.STATUS status) {
- Node newsletterNode = cloud.getNode(id);
+ Node newsletterNode = getCloud().getNode(id);
List<Node> publicationNodes =
newsletterNode.getRelatedNodes("newsletterpublication");
Set<Publication> publications = new HashSet<Publication>();
@@ -137,7 +141,7 @@
}
public Set<Term> getTermsByPublication(int publicationId) {
- Node newsletterPublicationNode = cloud.getNode(publicationId);
+ Node newsletterPublicationNode = getCloud().getNode(publicationId);
NodeList relatedNewsletters =
newsletterPublicationNode.getRelatedNodes("newsletter");
NodeList terms = relatedNewsletters.getNode(0).getRelatedNodes("term");
@@ -154,7 +158,7 @@
public void renamePublicationTitle(int publicationId) {
String now = DateFormatUtils.format(new Date(), "dd-MM-yyyy hh:mm");
- Node publicationNode = cloud.getNode(publicationId);
+ Node publicationNode = getCloud().getNode(publicationId);
String oldTitle = publicationNode.getStringValue("title");
String newTile = oldTitle;
String dateTime = "";
@@ -181,8 +185,8 @@
public List<Publication> getPublicationsByNewsletterAndPeriod(
int newsletterId, String title, String subject, Date startDate,
Date endDate, boolean paging) {
- NodeManager manager = cloud.getNodeManager("newsletterpublication");
- Node newsletterNode = cloud.getNode(newsletterId);
+ NodeManager manager = getCloud().getNodeManager("newsletterpublication");
+ Node newsletterNode = getCloud().getNode(newsletterId);
NodeQuery nodeQuery =
SearchUtil.createRelatedNodeListQuery(newsletterNode, "newsletterpublication",
"related");
@@ -205,8 +209,8 @@
public List<Publication> getPublications(String title, String subject,
String description, String intro,
boolean paging) {
PagingStatusHolder pagingHolder = PagingUtils.getStatusHolder();
- NodeManager publicationManager =
cloud.getNodeManager("newsletterpublication");
- NodeQuery query = cloud.createNodeQuery();
+ NodeManager publicationManager =
getCloud().getNodeManager("newsletterpublication");
+ NodeQuery query = getCloud().createNodeQuery();
Step step = query.addStep(publicationManager);
query.setNodeStep(step);
if (StringUtils.isNotBlank(title)) {
Index: NewsletterSubscriptionCAOImpl.java
===================================================================
RCS file:
/var/cvs/contributions/CMSContainer_Portlets/portlets-newsletter/src/java/com/finalist/newsletter/cao/impl/NewsletterSubscriptionCAOImpl.java,v
retrieving revision 1.33
retrieving revision 1.34
diff -u -b -r1.33 -r1.34
--- NewsletterSubscriptionCAOImpl.java 24 Oct 2008 02:19:03 -0000 1.33
+++ NewsletterSubscriptionCAOImpl.java 27 Oct 2008 05:56:30 -0000 1.34
@@ -51,14 +51,10 @@
this.cloud = cloud;
}
- public void setCloud(Cloud cloud) {
- this.cloud = cloud;
- }
-
public List<Node> querySubcriptionByUser(int userId) {
- NodeManager recordManager = cloud.getNodeManager("subscriptionrecord");
- NodeQuery query = cloud.createNodeQuery();
+ NodeManager recordManager =
getCloud().getNodeManager("subscriptionrecord");
+ NodeQuery query = getCloud().createNodeQuery();
String subscriber = "subscriber";
Step theStep = null;
@@ -73,7 +69,7 @@
public void addSubscriptionRecord(Subscription subscription, int userId) {
String nodeType = "subscriptionrecord";
- NodeManager subscriptionrecordNodeManager =
cloud.getNodeManager(nodeType);
+ NodeManager subscriptionrecordNodeManager =
getCloud().getNodeManager(nodeType);
Node subscriptionrecordNode = subscriptionrecordNodeManager.createNode();
subscriptionrecordNode.setIntValue("subscriber", userId);
@@ -83,8 +79,8 @@
// add Relation to newsletter
int nodeNumber = subscription.getNewsletter().getId();
- Node newsletternode = cloud.getNode(nodeNumber);
- RelationManager insrel = cloud.getRelationManager("subscriptionrecord",
"newsletter", "newslettered");
+ Node newsletternode = getCloud().getNode(nodeNumber);
+ RelationManager insrel =
getCloud().getRelationManager("subscriptionrecord", "newsletter",
"newslettered");
subscriptionrecordNode.createRelation(newsletternode, insrel).commit();
subscription.setId(subscriptionrecordNode.getNumber());
}
@@ -93,7 +89,7 @@
log.debug("Modify subscription status " + subscription.getId() + " to "
+ subscription.getStatus());
String stauts = subscription.getStatus().toString();
- Node record = cloud.getNode(subscription.getId());
+ Node record = getCloud().getNode(subscription.getId());
record.setStringValue("status", stauts);
record.commit();
@@ -105,14 +101,14 @@
}
public void pause(int subscriptionId) {
- Node record = cloud.getNode(subscriptionId);
+ Node record = getCloud().getNode(subscriptionId);
record.setStringValue("status", "PAUSED");
record.commit();
}
public void modifySubscriptionFormat(Subscription subscription) {
int recordId = subscription.getId();
- Node record = cloud.getNode(recordId);
+ Node record = getCloud().getNode(recordId);
String format = subscription.getMimeType();
record.setStringValue("format", format);
@@ -121,16 +117,16 @@
public void addSubscriptionTerm(Subscription subscription, int termId) {
int recordId = subscription.getId();
- Node record = cloud.getNode(recordId);
- Node term = cloud.getNode(termId);
+ Node record = getCloud().getNode(recordId);
+ Node term = getCloud().getNode(termId);
- RelationManager insrel = cloud.getRelationManager("subscriptionrecord",
"term", "termed");
+ RelationManager insrel =
getCloud().getRelationManager("subscriptionrecord", "term", "termed");
record.createRelation(term, insrel).commit();
}
public void removeSubscriptionTerm(Subscription subscription, int termId) {
int recordId = subscription.getId();
- Node record = cloud.getNode(recordId);
+ Node record = getCloud().getNode(recordId);
List<Node> terms = record.getRelatedNodes("term");
Iterator<Node> termsit = terms.iterator();
@@ -138,7 +134,7 @@
for (int i = 0; i < terms.size(); i++) {
Node term = termsit.next();
if (termId != term.getNumber()) {
- RelationManager insrel =
cloud.getRelationManager("subscriptionrecord", "term", "termed");
+ RelationManager insrel =
getCloud().getRelationManager("subscriptionrecord", "term", "termed");
record.createRelation(term, insrel).commit();
}
}
@@ -148,7 +144,7 @@
log.debug("getSubscriptionrecord that newsletterId=" + newsletterId);
Node subscriptionNode = null;
- List<Node> records =
cloud.getNode(newsletterId).getRelatedNodes("subscriptionrecord");
+ List<Node> records =
getCloud().getNode(newsletterId).getRelatedNodes("subscriptionrecord");
for (Node record : records) {
if
(record.getStringValue("subscriber").equals(Integer.toString(userId))) {
subscriptionNode = record;
@@ -182,7 +178,7 @@
public Set<Term> getTerms(int subscriptionId) {
- List<Node> termList =
cloud.getNode(subscriptionId).getRelatedNodes("term");
+ List<Node> termList =
getCloud().getNode(subscriptionId).getRelatedNodes("term");
Set<Term> terms = new HashSet<Term>();
for (Node termNode : termList) {
@@ -198,7 +194,7 @@
public List<Subscription> getSubscription(int newsletterId) {
- List<Node> records =
cloud.getNode(newsletterId).getRelatedNodes("subscriptionrecord");
+ List<Node> records =
getCloud().getNode(newsletterId).getRelatedNodes("subscriptionrecord");
log.debug("Get subscriptions of newsletter:" + newsletterId + " and get
" + records.size() + " records in all");
List<Subscription> subscribers = new ArrayList<Subscription>();
for (Node record : records) {
@@ -214,8 +210,8 @@
public void createSubscription(int userId, int newsletterId) {
log.debug("Create subscription user:" + userId + " newsletter:" +
newsletterId);
- NodeManager recordManager = cloud.getNodeManager("subscriptionrecord");
- Node newsletter = cloud.getNode(newsletterId);
+ NodeManager recordManager =
getCloud().getNodeManager("subscriptionrecord");
+ Node newsletter = getCloud().getNode(newsletterId);
Node recordNode = recordManager.createNode();
recordNode.setStringValue("status",
Subscription.STATUS.ACTIVE.toString());
@@ -223,13 +219,13 @@
recordNode.setStringValue("format", "text/html");
recordNode.commit();
- RelationManager insrel = cloud.getRelationManager("subscriptionrecord",
"newsletter", "newslettered");
+ RelationManager insrel =
getCloud().getRelationManager("subscriptionrecord", "newsletter",
"newslettered");
recordNode.createRelation(newsletter, insrel).commit();
}
public Subscription getSubscriptionById(int id) {
- Node subscriptionNode = cloud.getNode(id);
+ Node subscriptionNode = getCloud().getNode(id);
Subscription subscription = convertFromNode(subscriptionNode);
List<Node> newsletterNodes =
subscriptionNode.getRelatedNodes("newsletter");
@@ -241,7 +237,7 @@
}
public void updateSubscription(Subscription subscription) {
- Node node = cloud.getNode(subscription.getId());
+ Node node = getCloud().getNode(subscription.getId());
node.setStringValue("status", subscription.getStatus().toString());
node.setDateValue("pausetill", subscription.getPausedTill());
node.commit();
@@ -250,7 +246,7 @@
public List<Subscription> getSubscriptionByUserIdAndStatus(int userId,
STATUS status) {
- NodeManager recordManager = cloud.getNodeManager("subscriptionrecord");
+ NodeManager recordManager =
getCloud().getNodeManager("subscriptionrecord");
Query query = recordManager.createQuery();
if (null != status) {
@@ -270,8 +266,8 @@
public List<Node> getAllSubscriptions() {
- NodeQuery query = cloud.createNodeQuery();
- Step step = query.addStep(cloud.getNodeManager("subscriptionrecord"));
+ NodeQuery query = getCloud().createNodeQuery();
+ Step step =
query.addStep(getCloud().getNodeManager("subscriptionrecord"));
query.setNodeStep(step);
List<Node> list = query.getList();
@@ -279,8 +275,8 @@
}
public Set<Node> getRecordByNewsletterAndName(int newsletterId, String
termName) {
- NodeManager manager = cloud.getNodeManager("term");
- Node newsletterNode = cloud.getNode(newsletterId);
+ NodeManager manager = getCloud().getNodeManager("term");
+ Node newsletterNode = getCloud().getNode(newsletterId);
NodeQuery nodeQuery =
SearchUtil.createRelatedNodeListQuery(newsletterNode, "term", "posrel");
if (StringUtils.isNotBlank(termName)) {
@@ -308,7 +304,7 @@
}
public Set<Node> getNewslettersByScriptionRecord(int authenticationId) {
- NodeManager recordManager = cloud.getNodeManager("subscriptionrecord");
+ NodeManager recordManager =
getCloud().getNodeManager("subscriptionrecord");
Query query = recordManager.createQuery();
SearchUtil.addEqualConstraint(query,
recordManager.getField("subscriber"), Integer.toString(authenticationId));
List<Node> subscriptions = query.getList();
@@ -326,9 +322,9 @@
public List<Newsletter> getNewslettersByScription(int subscriberId, String
title, boolean paging) {
PagingStatusHolder pagingHolder = PagingUtils.getStatusHolder();
- NodeManager subscriptionNodeManager =
cloud.getNodeManager("subscriptionrecord");
- NodeManager newsletterNodeManager = cloud.getNodeManager("newsletter");
- NodeQuery query = cloud.createNodeQuery();
+ NodeManager subscriptionNodeManager =
getCloud().getNodeManager("subscriptionrecord");
+ NodeManager newsletterNodeManager =
getCloud().getNodeManager("newsletter");
+ NodeQuery query = getCloud().createNodeQuery();
Step subscriptionStep = query.addStep(subscriptionNodeManager);
query.setNodeStep(subscriptionStep);
if (subscriberId > 0) {
@@ -353,7 +349,7 @@
}
public Set<Node> getTermsByScriptionRecord(int authenticationId) {
- NodeManager recordManager = cloud.getNodeManager("subscriptionrecord");
+ NodeManager recordManager =
getCloud().getNodeManager("subscriptionrecord");
Query query = recordManager.createQuery();
SearchUtil.addEqualConstraint(query,
recordManager.getField("subscriber"), Integer.toString(authenticationId));
List<Node> subscriptions = query.getList();
@@ -381,13 +377,13 @@
}
private Node getSubscriptionNodeById(int subscriptionId) {
- return cloud.getNode(subscriptionId);
+ return getCloud().getNode(subscriptionId);
}
public Node getSubscriptionNode(int newsletterId, int userId) {
Node subscriptionNode = null;
- List<Node> records =
cloud.getNode(newsletterId).getRelatedNodes("subscriptionrecord");
+ List<Node> records =
getCloud().getNode(newsletterId).getRelatedNodes("subscriptionrecord");
for (Node record : records) {
if
(record.getStringValue("subscriber").equals(Integer.toString(userId))) {
subscriptionNode = record;
@@ -404,11 +400,11 @@
}
public List<Node> getSubscriptionsByTerms(int newsletterId, String terms) {
- NodeManager termNodeManager = cloud.getNodeManager("term");
- NodeManager newsletterNodeManager = cloud.getNodeManager("newsletter");
- NodeManager subscriptionNodeManger =
cloud.getNodeManager("subscriptionrecord");
+ NodeManager termNodeManager = getCloud().getNodeManager("term");
+ NodeManager newsletterNodeManager =
getCloud().getNodeManager("newsletter");
+ NodeManager subscriptionNodeManger =
getCloud().getNodeManager("subscriptionrecord");
- NodeQuery query = cloud.createNodeQuery();
+ NodeQuery query = getCloud().createNodeQuery();
List<Node> subscriptions;
if (StringUtils.isNotBlank(terms)) {
Step termStep = query.addStep(termNodeManager);
@@ -428,7 +424,7 @@
query.setNodeStep(subscriptionStep);
subscriptions = query.getList();
} else {
- Node newsletterNode = cloud.getNode(newsletterId);
+ Node newsletterNode = getCloud().getNode(newsletterId);
subscriptions =
newsletterNode.getRelatedNodes(subscriptionNodeManger, "newslettered",
"destination");
}
_______________________________________________
Cvs mailing list
[email protected]
http://lists.mmbase.org/mailman/listinfo/cvs
