CategorySubscribersGrid.java

Go to the documentation of this file.

/*
 * Turró i Cutiller Foundation. License notice.
 * Copyright (C) 2017 Lluis Turró Cutiller <http://www.turro.org/>
 *
 * This program is free software: you can redistribute it and/or modify
 * it under the terms of the GNU Affero General Public License as published by
 * the Free Software Foundation, either version 3 of the License, or
 * (at your option) any later version.
 *
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU Affero General Public License for more details.
 *
 * You should have received a copy of the GNU Affero General Public License
 * along with this program.  If not, see <http://www.gnu.org/licenses/>.
 */
 
package org.turro.queue.zul;
 
import java.util.Collection;
import java.util.List;
import org.turro.string.Strings;
import org.turro.action.Contacts;
import org.turro.action.queue.ConstraintKeys;
import org.turro.action.queue.NotificationCategory;
import org.turro.action.queue.QueuePeriod;
import org.turro.assistant.Assistant;
import org.turro.assistant.AssistantConstants;
import org.turro.assistant.AssistantDialog;
import org.turro.assistant.AssistantSet;
import org.turro.assistant.Assistants;
import org.turro.elephant.db.ElephantPU;
import org.turro.elephant.entities.db.QueueOptions;
import org.turro.elephant.util.Messages;
import org.turro.entities.Entities;
import org.turro.i18n.I_;
import org.turro.jpa.grid.RendererOnDemand;
import org.turro.mail.queue.QueueManager;
import org.turro.plugin.contacts.IContact;
import org.turro.zkoss.grid.PagingGrid;
import org.turro.zul.frame.Framework;
import org.zkoss.zk.ui.Component;
import org.zkoss.zk.ui.event.Event;
import org.zkoss.zk.ui.event.EventListener;
import org.zkoss.zk.ui.event.Events;
import org.zkoss.zul.Column;
import org.zkoss.zul.Columns;
import org.zkoss.zul.ListModelList;
import org.zkoss.zul.Row;
import org.zkoss.zul.Toolbarbutton;
 
public class CategorySubscribersGrid extends PagingGrid implements EventListener<Event> {
 
  private NotificationCategory notificationCategory;
 
  public void setNotificationCategory(NotificationCategory notificationCategory) {
    this.notificationCategory = notificationCategory;
    addColumns();
    addRows();
  }
  
  public void addContact(IContact contact) {
    if(notificationCategory != null && notificationCategory.isValid(contact) && notificationCategory.strongBond(ConstraintKeys.from(contact))) {
      notificationCategory.getNotification().subscribeIfNot(
              notificationCategory.getIdCategory(), contact, notificationCategory.getDefaultPeriod());
      addRows();
    }
  }
  
  public void pasteContacts() {
    List<Object> contacts = (List<Object>) Framework.getClipboard().get("bbf_clip_contact");
    if(contacts != null && notificationCategory != null) {
      for(Object c : contacts) {
        IContact contact = Contacts.getContact(c);
        if(notificationCategory != null && notificationCategory.isValid(contact) && notificationCategory.strongBond(ConstraintKeys.from(contact))) {
          notificationCategory.getNotification().subscribeIfNot(
                  notificationCategory.getIdCategory(), contact, notificationCategory.getDefaultPeriod());
        }
      }
      Framework.getClipboard().remove("bbf_clip_contact");
      addRows();
    }
  }
 
  public void addAttendeesByEntity(String entityPath, boolean deep) {
    if(Strings.isBlank(entityPath)) return;
    AssistantSet as = new AssistantSet();
    Assistants.addAssistants(entityPath, deep, as, deep ? AssistantConstants.all() : null);
    for(Assistant a : as) {
      IContact contact = a.contact;
      if(notificationCategory != null && notificationCategory.isValid(contact) && notificationCategory.strongBond(ConstraintKeys.from(contact))) {
        notificationCategory.getNotification().subscribe(
                notificationCategory.getIdCategory(), contact, notificationCategory.getDefaultPeriod());
      }
    }
    addRows();
  }
 
  public void addAssistantsByEntity() {
    AssistantDialog.load((as) -> {
      for(Assistant a : as) {
        IContact contact = a.contact;
        if(notificationCategory != null && notificationCategory.isValid(contact) && notificationCategory.strongBond(ConstraintKeys.from(contact))) {
          notificationCategory.getNotification().subscribe(
                  notificationCategory.getIdCategory(), contact, notificationCategory.getDefaultPeriod());
        }
      }
      addRows();
    });
  }
  
  public void checkConstraints() {
    if(notificationCategory != null) {
      Messages.confirmProcess().add(I_.get("This process will check all subscribers...")).show(() -> {
        notificationCategory.getNotification().checkConstraints(notificationCategory.getIdCategory());
        addRows();
      });
    }
  }
 
  public void removeAll() {
    if(notificationCategory != null) {
      Messages.confirmDeletion().show(() -> {
        notificationCategory.getNotification().removeAll(notificationCategory.getIdCategory());
        addRows();
      });
    }
  }
 
  public void periodToAll(final QueuePeriod period) {
    if(notificationCategory != null) {
      if(notificationCategory.getAllowedPeriods().contains(period)) {
        Messages.confirmProcess().show(() -> {
          notificationCategory.getNotification().periodToAll(notificationCategory.getIdCategory(), period);
          addRows();
        });
      }
    }
  }
 
  private void addRows() {
    getRows(true).getChildren().clear();
    
    if(notificationCategory == null) return;
 
    setRowRenderer(new RendererOnDemand<QueueOptions, Long>(() -> new ElephantPU()) {
      @Override
      protected void renderRow(final Row row, final QueueOptions qo) {
        row.appendChild((Component) Entities.getController("/contact/" + qo.getIdContact()).getLabelCtrl());
        final QueuePeriodListbox qpl = new QueuePeriodListbox(notificationCategory.getAllowedPeriods());
        qpl.afterCompose();
        qpl.setMold("select");
        qpl.setObjectValue(qo.getPeriod());
        qpl.setAttribute("options", qo);
        qpl.addEventListener(Events.ON_SELECT, CategorySubscribersGrid.this);
        row.appendChild(qpl);
        Toolbarbutton del = new Toolbarbutton();
        del.setAttribute("options", qo);
        del.setImage("/_zul/images/edit-delete.png");
        del.addEventListener(Events.ON_CLICK, CategorySubscribersGrid.this);
        row.appendChild(del);
      }
    });
    
    Collection list = new QueueManager().getSubcribers(notificationCategory.getIdCategory());
    
    setModel(new ListModelList(list));
 
    setRowCount(list.size());
  }
 
  private void addColumns() {
    Columns cols = getColumns(true);
    cols.getChildren().clear();
    
    cols.appendChild(new Column(I_.get("Contact")));
    cols.appendChild(new Column(I_.get("Period"), null, "300px"));
    cols.appendChild(new Column(null, null, "50px"));
  }
 
  @Override
  public void onEvent(Event event) throws Exception {
    if(event.getTarget() instanceof QueuePeriodListbox) {
      QueuePeriodListbox qpl = (QueuePeriodListbox) event.getTarget();
      QueueOptions qo = (QueueOptions) qpl.getAttribute("options");
      qo.setPeriod(qpl.getObjectValue());
      new QueueManager().configQueue(qo);
    } else if(event.getTarget() instanceof Toolbarbutton) {
      Toolbarbutton del = (Toolbarbutton) event.getTarget();
      QueueOptions qo = (QueueOptions) del.getAttribute("options");
      new QueueManager().removeOptions(qo);
      addRows();
    }
  }
 
}