ContractItemSet.java

Go to the documentation of this file.

/*
 * Turró i Cutiller Foundation. License notice.
 * Copyright (C) 2013 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.financials.operating;
 
import java.util.ArrayList;
import java.util.Date;
import java.util.List;
import java.util.TreeSet;
import org.amic.util.date.CheckDate;
import org.turro.elephant.db.WhereClause;
import org.turro.financials.db.FinancialsPU;
import org.turro.financials.entity.Account;
import org.turro.jpa.Dao;
import org.turro.util.CompareUtil;
 
public class ContractItemSet extends TreeSet<ContractItem> {
  
  private Date start, end;
  
  public ContractItem getContract(long id) {
    ContractItem ci = ceiling(new ContractItem(id));
    if(ci != null && ci.getId() == id) {
      return ci;
    } else {
      ci = new ContractItem(id);
      add(ci);
      return ci;
    }
  }
  
  public void loadPeriod(Date start, Date end) {
    if(CompareUtil.compare(this.start, start) != 0 || CompareUtil.compare(this.end, end) != 0) {
      this.start = start;
      this.end = end;
      this.clear();
      processData(loadData());
    }
  }
 
  private List<Object[]> loadData() {
    Dao dao = new FinancialsPU();
    return dao.getResultList(getCriteria());
  }
  
  private WhereClause getCriteria() {
    WhereClause wc = new WhereClause();
    wc.addClause("select r.id, r.registerDate, re.account, re.debit, re.credit"); 
    wc.addClause("from Register as r");
    wc.addClause("join r.registerEntries re");
    wc.addClause("where r.registerDate >= :start");
    wc.addNamedValue("start", start);
    wc.addClause("and r.registerDate <= :end");
    wc.addNamedValue("end", end);
    wc.addClause("and (re.account like '6%'");
    wc.addClause("or re.account like '7%'");
    wc.addClause("or re.account like '400%'");
    wc.addClause("or re.account like '410%'");
    wc.addClause("or re.account like '430%'");
    wc.addClause("or re.account like '440%')");
    return wc;
  }
 
  private long currentId = 0;
  private List<RegisterItem> register;
  
  private void processData(List<Object[]> data) {
    currentId = 0;
    for(Object[] o : data) {      
      processLines(o);
    }
    processList();
  }
  
  private void processLines(Object[] data) {
    long regId = (long) data[0];
    if(regId != currentId) {
      processList();
      register = new ArrayList<>();
      currentId = regId;
    }
    RegisterItem ri = new RegisterItem();
    ri.regId = regId;
    ri.date = new CheckDate((Date) data[1]);
    ri.account = (Account) data[2];
    ri.debit = (double) data[3];
    ri.credit = (double) data[4];
    register.add(ri);
  }
 
  private RegisterItem participant;
  private final List<RegisterItem> stores = new ArrayList<>();
  
  private void processList() {
    stores.clear();
    participant = null;
    if(register != null && !register.isEmpty()) {
      findPrimaryStore();
      findParticipant();
      if(!stores.isEmpty() && participant != null) {
        for(RegisterItem store : stores) {
          ContractItem ci = getContract(store.getContractId());
          if(ci.getName() == null) {
            ci.setName(null);
          }
          MonthItem mi = ci.getMonths().getMonth(store.getYear(), store.getMonth());
          ValueItem vi = mi.getMovements().getValues().getItem(store.account.getId().substring(0, 5));
          if(vi.getName() == null) {
            vi.setName(store.account.getParent().getDescription());
          }
          vi.setValue(vi.getValue() + store.getValue());
          // Clear '9' for 4xx9
          String major = participant.account.getId();
          if(major.charAt(3) == '9') {
            major = major.substring(0, 3) + "0" + major.substring(4);
          }
          vi = mi.getMovements().getParticipants().getItem(major);
          if(vi.getName() == null) {
            vi.setName(participant.account.getDescription());
          }
          vi.setValue(vi.getValue() + store.getValue());
        }
      }
    }
  }
 
  private void findPrimaryStore() {
    for(RegisterItem ri : register) {
      if(ri.account.getId().matches("6.*") && ri.debit != 0.0) {
        stores.add(ri);
      } if(ri.account.getId().matches("7.*") && ri.credit != 0.0) {
        stores.add(ri);
      }
    }
  }
 
  private void findParticipant() {
    double max = 0;
    for(RegisterItem ri : register) {
      if(ri.account.getId().matches("4[34]0.*") && ri.debit != 0.0) {
        if(max < Math.abs(ri.debit)) {
          participant = ri;
          max = Math.abs(ri.debit);
        }
      } if(ri.account.getId().matches("4[01]0.*") && ri.credit != 0.0) {
        if(max < Math.abs(ri.credit)) {
          participant = ri;
          max = Math.abs(ri.credit);
        }
      }
    }
  }
 
}