DWIssueModel.java

Go to the documentation of this file.

/*
 * Turró i Cutiller Foundation. License notice.
 * Copyright (C) 2016 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.dossier.dw;
 
import java.util.Collection;
import java.util.Date;
import java.util.List;
import org.turro.action.Contacts;
import org.turro.dossier.db.DossierPU;
import org.turro.dossier.entity.IssueParticipantRole;
import org.turro.dossier.entity.IssuePriority;
import org.turro.dossier.entity.IssueResolution;
import org.turro.dossier.entity.IssueStatus;
import org.turro.dossier.entity.IssueType;
import org.turro.dossier.entity.ParticipantRole;
import org.turro.elephant.db.WhereClause;
import org.turro.jpa.Dao;
import org.turro.plugin.contacts.IContact;
import org.zkoss.lang.Strings;
 
public class DWIssueModel {
  
  /* Filters */
  private String participantId, categoryPath;
  private Long dossierId, versionId;
  private Date startDate, endDate;
  private ParticipantRole participantRole;
  private IssueType type;
  private IssuePriority priority;
  private IssueStatus status;
  private IssueResolution resolution;
  
  public Long getCount() {
    WhereClause wc = new WhereClause();
    wc.addClause("select count(distinct issueId)");
    wc.addClause("from DWIssue");
    wc.addClause("where 1=1");
    addCriteria(wc);
    return (Long) getDao().getSingleResultOrNull(wc);
  }
  
  public Long getOpenedCount() {
    WhereClause wc = new WhereClause();
    wc.addClause("select count(distinct issueId)");
    wc.addClause("from DWIssue");
    wc.addClause("where status <> :status");
    wc.addNamedValue("status", IssueStatus.STATUS_CLOSED);
    addCriteria(wc);
    return (Long) getDao().getSingleResultOrNull(wc);
  }
  
  public Long getParticipantsCount() {
    WhereClause wc = new WhereClause();
    wc.addClause("select count(participantId)");
    wc.addClause("from DWIssue");
    wc.addClause("where 1=1");
    addCriteria(wc);
    return (Long) getDao().getSingleResultOrNull(wc);
  }
  
  public Long getCommentCount() {
    WhereClause wc = new WhereClause();
    wc.addClause("select sum(commentCount)");
    wc.addClause("from DWIssue");
    wc.addClause("where 1=1");
    addCriteria(wc);
    return (Long) getDao().getSingleResultOrNull(wc);
  }
  
  public List getByType() {
    WhereClause wc = new WhereClause();
    wc.addClause("select type, count(distinct issueId)");
    wc.addClause("from DWIssue");
    wc.addClause("where 1=1");
    addCriteria(wc);
    wc.addClause("group by type");
    return getDao().getResultList(wc);
  }
 
  public List getByStatus() {
    WhereClause wc = new WhereClause();
    wc.addClause("select status, count(distinct issueId)");
    wc.addClause("from DWIssue");
    wc.addClause("where 1=1");
    addCriteria(wc);
    wc.addClause("group by status");
    return getDao().getResultList(wc);
  }
 
  public List getByResolution() {
    WhereClause wc = new WhereClause();
    wc.addClause("select resolution, count(distinct issueId)");
    wc.addClause("from DWIssue");
    wc.addClause("where 1=1");
    addCriteria(wc);
    wc.addClause("group by resolution");
    return getDao().getResultList(wc);
  }
 
  public Collection<Long> getDossiersId() {
    WhereClause wc = new WhereClause();
    wc.addClause("select distinct dossierId");
    wc.addClause("from DWIssue i");
    addCriteria(wc);
    return getDao().getResultList(wc);
  }
  
  public List getResponsiblesId() {
    WhereClause wc = new WhereClause();
    wc.addClause("select distinct participantId, count(distinct issueId)");
    wc.addClause(",(select count(distinct i2.issueId) from DWIssue i2 where i2.participantId = i.participantId and i2.status <> :status2 and i2.participantRole = :participantRole2)");
    wc.addNamedValue("status2", IssueStatus.STATUS_CLOSED);
    wc.addNamedValue("participantRole2", IssueParticipantRole.ISSUE_RESPONSIBLE);
    wc.addClause("from DWIssue i");
    wc.addClause("where participantRole = :participantRole");
    wc.addNamedValue("participantRole", IssueParticipantRole.ISSUE_RESPONSIBLE);
    addCriteriaParticipantExists(wc);
    wc.addClause("group by participantId");
    wc.addClause("order by 2 desc");
    return getDao().getResultList(wc);
  }
  
  public List getReportersId() {
    WhereClause wc = new WhereClause();
    wc.addClause("select distinct participantId, count(distinct issueId)");
    wc.addClause(",(select count(distinct i2.issueId) from DWIssue i2 where i2.participantId = i.participantId and i2.status <> :status2 and i2.participantRole = :participantRole2)");
    wc.addNamedValue("status2", IssueStatus.STATUS_CLOSED);
    wc.addNamedValue("participantRole2", IssueParticipantRole.ISSUE_REPORTER);
    wc.addClause("from DWIssue i");
    wc.addClause("where participantRole = :participantRole");
    wc.addNamedValue("participantRole", IssueParticipantRole.ISSUE_REPORTER);
    addCriteriaParticipantExists(wc);
    wc.addClause("group by participantId");
    wc.addClause("order by 2 desc");
    return getDao().getResultList(wc);
  }
  
  public List getAssistantsId() {
    WhereClause wc = new WhereClause();
    wc.addClause("select distinct participantId, count(distinct issueId)");
    wc.addClause(",(select count(distinct i2.issueId) from DWIssue i2 where i2.participantId = i.participantId and i2.status <> :status2 and i2.participantRole = :participantRole2)");
    wc.addNamedValue("status2", IssueStatus.STATUS_CLOSED);
    wc.addNamedValue("participantRole2", IssueParticipantRole.ISSUE_ASSISTANT);
    wc.addClause("from DWIssue i");
    wc.addClause("where participantRole = :participantRole");
    wc.addNamedValue("participantRole", IssueParticipantRole.ISSUE_ASSISTANT);
    addCriteriaParticipantExists(wc);
    wc.addClause("group by participantId");
    wc.addClause("order by 2 desc");
    return getDao().getResultList(wc);
  }
  
  public List getQAsId() {
    WhereClause wc = new WhereClause();
    wc.addClause("select distinct participantId, count(distinct issueId)");
    wc.addClause(",(select count(distinct i2.issueId) from DWIssue i2 where i2.participantId = i.participantId and i2.status <> :status2 and i2.participantRole = :participantRole2)");
    wc.addNamedValue("status2", IssueStatus.STATUS_CLOSED);
    wc.addNamedValue("participantRole2", IssueParticipantRole.ISSUE_QA);
    wc.addClause("from DWIssue i");
    wc.addClause("where participantRole = :participantRole");
    wc.addNamedValue("participantRole", IssueParticipantRole.ISSUE_QA);
    addCriteriaParticipantExists(wc);
    wc.addClause("group by participantId");
    wc.addClause("order by 2 desc");
    return getDao().getResultList(wc);
  }
  
  /* Id to IContact for marker */
  public IContact getIContact(String contactId) {
    return Contacts.getContactById(contactId);
  }
  
  /* Id to DWDossier for marker */
  public DWDossier getDossier(Long dossierId) {
    return getDao().find(DWDossier.class, dossierId);
  }
  
  /* Id to DWIssue for marker */
  public DWIssue getIssue(Long issueId) {
    return getDao().find(DWIssue.class, issueId);
  }
  
  public String getParticipantId() {
    return participantId;
  }
 
  public void setParticipantId(String participantId) {
    this.participantId = participantId;
    resetIContact();
  }
 
  public String getCategoryPath() {
    return categoryPath;
  }
 
  public void setCategoryPath(String categoryPath) {
    this.categoryPath = categoryPath;
  }
 
  public Long getDossierId() {
    return dossierId;
  }
 
  public void setDossierId(Long dossierId) {
    this.dossierId = dossierId;
  }
 
  public Long getVersionId() {
    return versionId;
  }
 
  public void setVersionId(Long versionId) {
    this.versionId = versionId;
  }
 
  public Date getStartDate() {
    return startDate;
  }
 
  public void setStartDate(Date startDate) {
    this.startDate = startDate;
  }
 
  public Date getEndDate() {
    return endDate;
  }
 
  public void setEndDate(Date endDate) {
    this.endDate = endDate;
  }
 
  public ParticipantRole getParticipantRole() {
    return participantRole;
  }
 
  public void setParticipantRole(ParticipantRole participantRole) {
    this.participantRole = participantRole;
  }
 
  public IssueType getType() {
    return type;
  }
 
  public void setType(IssueType type) {
    this.type = type;
  }
 
  public IssuePriority getPriority() {
    return priority;
  }
 
  public void setPriority(IssuePriority priority) {
    this.priority = priority;
  }
 
  public IssueStatus getStatus() {
    return status;
  }
 
  public void setStatus(IssueStatus status) {
    this.status = status;
  }
 
  public IssueResolution getResolution() {
    return resolution;
  }
 
  public void setResolution(IssueResolution resolution) {
    this.resolution = resolution;
  }
 
  /* Dao */
  
  private Dao _dao;
  
  private Dao getDao() {
    if(_dao == null) {
      DatawarehouseUtil.generateData();
      _dao = new DossierPU();
    }
    return _dao;
  }
 
  private void addCriteria(WhereClause wc) {
    if(!Strings.isBlank(participantId)) {
      wc.addClause("and participantId = :participantId");
      wc.addNamedValue("participantId", participantId);
      if(participantRole != null) {
        wc.addClause("and participantRole = :participantRole");
        wc.addNamedValue("participantRole", participantRole);
      }
    }
    if(!Strings.isBlank(categoryPath)) {
      wc.addClause("and categoryPath = :categoryPath");
      wc.addNamedValue("categoryPath", categoryPath);
    }
    if(dossierId != null && dossierId > 0) {
      wc.addClause("and dossierId = :dossierId");
      wc.addNamedValue("dossierId", dossierId);
    }
    if(versionId != null && versionId > 0) {
      wc.addClause("and versionId = :versionId");
      wc.addNamedValue("versionId", versionId);
    }
  }
  
  private void addCriteriaParticipantExists(WhereClause wc) {
    if(!Strings.isBlank(participantId)) {
      wc.addClause("and exists(");
      wc.addClause("select i2 from DWIssue i2");
      wc.addClause("where i2.issueId = i.issueId");
      wc.addClause("and participantId = :participantId");
      wc.addNamedValue("participantId", participantId);
      if(participantRole != null) {
        wc.addClause("and participantRole = :participantRole");
        wc.addNamedValue("participantRole", participantRole);
      }
      wc.addClause(")");
    }
    if(!Strings.isBlank(categoryPath)) {
      wc.addClause("and categoryPath = :categoryPath");
      wc.addNamedValue("categoryPath", categoryPath);
    }
    if(dossierId != null && dossierId > 0) {
      wc.addClause("and dossierId = :dossierId");
      wc.addNamedValue("dossierId", dossierId);
    }
    if(versionId != null && versionId > 0) {
      wc.addClause("and versionId = :versionId");
      wc.addNamedValue("versionId", versionId);
    }
  }
  
  private transient IContact _contact;
  
  public IContact getIParticipant() {
    if(_contact == null) {
      _contact = Contacts.getContactById(participantId);
    }
    return _contact;
  }
  
  public void setIParticipant(IContact contact) {
    _contact = contact;
    participantId = _contact != null ? _contact.getId() : null;
  }
  
  private void resetIContact() {
    _contact = null;
  }
  
}