69 lines
2.1 KiB
Java
69 lines
2.1 KiB
Java
package org.gcube.portlets.user.newsfeed.server;
|
|
|
|
import java.util.HashSet;
|
|
import java.util.List;
|
|
|
|
import org.gcube.applicationsupportlayer.social.NotificationsManager;
|
|
import org.gcube.portal.databook.server.DatabookStore;
|
|
import org.gcube.portal.databook.shared.Comment;
|
|
import org.gcube.vomanagement.usermanagement.UserManager;
|
|
import org.gcube.vomanagement.usermanagement.impl.liferay.LiferayUserManager;
|
|
import org.slf4j.Logger;
|
|
import org.slf4j.LoggerFactory;
|
|
|
|
/**
|
|
*
|
|
* @author Massimiliano Assante ISTI-CNR
|
|
*
|
|
*/
|
|
public class CommentNotificationsThread implements Runnable {
|
|
|
|
private static final Logger _log = LoggerFactory.getLogger(CommentNotificationsThread.class);
|
|
|
|
String commenterUserId;
|
|
String commentedFeedId;
|
|
private String commentText;
|
|
private String feedOwnerId;
|
|
private NotificationsManager nm;
|
|
private HashSet<String> userIdsToNotify;
|
|
|
|
|
|
public CommentNotificationsThread(DatabookStore storeInstance, String commenterUserId, String commentedFeedId, String commentText, NotificationsManager nm, String feedOwnerId) {
|
|
super();
|
|
this.nm = nm;
|
|
this.commenterUserId = commenterUserId;
|
|
this.commentedFeedId = commentedFeedId;
|
|
this.commentText = commentText;
|
|
this.feedOwnerId = feedOwnerId;
|
|
|
|
userIdsToNotify = new HashSet<String>();
|
|
List<Comment> feedComments = storeInstance.getAllCommentByFeed(commentedFeedId);
|
|
for (Comment comment : feedComments) {
|
|
if (comment.getUserid().compareTo(commenterUserId) != 0) {
|
|
userIdsToNotify.add(comment.getUserid());
|
|
}
|
|
}
|
|
|
|
//clean
|
|
//this.comments = comments;
|
|
}
|
|
|
|
@Override
|
|
public void run() {
|
|
String feedOwnerFullName = "";
|
|
UserManager um = new LiferayUserManager();
|
|
try {
|
|
feedOwnerFullName = um.getUserByScreenName(feedOwnerId).getFullname();
|
|
} catch (Exception e) {
|
|
feedOwnerFullName = feedOwnerId;
|
|
}
|
|
if (userIdsToNotify != null) {
|
|
for (String userId : userIdsToNotify) {
|
|
boolean result = nm.notifyCommentReply(userId, commentedFeedId, commentText, feedOwnerFullName);
|
|
_log.trace("Sending Notification for also commented to: " + feedOwnerFullName + " result?"+ result);
|
|
}
|
|
}
|
|
|
|
}
|
|
}
|