PortfolioProcess.java

Go to the documentation of this file.

/*
 * Turró i Cutiller Foundation. License notice.
 * Copyright (C) 2011 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.portfolio;
 
import java.util.ArrayList;
import java.util.Collection;
import java.util.Date;
import java.util.HashMap;
import java.util.Iterator;
import java.util.List;
import java.util.TreeSet;
import org.turro.command.Command;
import org.turro.command.Context;
import org.turro.elephant.zkoss.Modal;
import org.turro.elephant.zkoss.ModalWindow;
import org.turro.financials.document.logic.DocumentWrapper;
import org.turro.financials.entity.Contract;
import org.turro.financials.entity.Document;
import org.turro.financials.entity.DocumentDefinition;
import org.turro.financials.entity.DocumentLine;
import org.turro.financials.menu.FinancialsMenu;
import org.zkoss.zul.Grid;
 
public class PortfolioProcess extends TreeSet<PortfolioAction> {
 
  private boolean wasCancelled = false;
  private PortfolioOptions po = null;
  private ModalWindow portForm = null;
 
  Contract contract = null;
  DocumentDefinition documentDefinition = null;
  Boolean direction = null;
  List<PortfolioAction> list = new ArrayList<>();
 
  public void doIt(Grid grid) {
 
    wasCancelled = false;
 
    contract = null;
    documentDefinition = null;
    direction = null;
    list = new ArrayList<>();
 
    Iterator<PortfolioAction> it = iterator();
    
    if(it.hasNext()) {
      doNext(it);
    } else {
      processList(null);
    }
  // fill the list until there is a break, then process
//    for(PortfolioAction pa : this) {
//      if(isBreak(pa, contract, direction, documentDefinition)) {
//        processList(list, contract, documentDefinition);
//      }
//      contract = pa.getDocument().getContract();
//      direction = pa.isForward();
//      documentDefinition = pa.getDocumentDefinition();
//      list.add(pa);
//    }    
    
  }
 
  private void doNext(final Iterator<PortfolioAction> it) {
    final PortfolioAction pa = it.next();
    if(isBreak(pa)) {
      processList(new Command() {
        @Override
        public Object execute(Context context) {
          contract = pa.getDocument().getContract();
          direction = pa.isForward();
          documentDefinition = pa.getDocumentDefinition();
          list.add(pa);
          if(it.hasNext()) {
            doNext(it);
          } else {
            processList(null);
          }
          return null;
        }
      });
      return;
    }
    contract = pa.getDocument().getContract();
    direction = pa.isForward();
    documentDefinition = pa.getDocumentDefinition();
    list.add(pa);
    if(it.hasNext()) {
      doNext(it);
    } else {
      processList(null);
    }
  }
 
  private boolean isBreak(PortfolioAction pa) {
    if(contract != null && contract.getId() != pa.getDocument().getContract().getId() && (po == null || po.isStopOnContract())) {
      return true;
    }
    if(direction != null && !direction.equals(pa.isForward())) {
      return true;
    }
    if(documentDefinition != null && documentDefinition.getId() != pa.getDocumentDefinition().getId()) {
      return true;
    }      
    return false;
  }
  
  private void processList(final Command command) {
    if(list.isEmpty() || wasCancelled) return;
    portForm = null;
    final Date now = new Date();
    if(po == null || po.isStopOnContract()) {
      HashMap args = new HashMap();
      Collection<Document> docs = getDocuments(list);
      args.put("portfolioDocs", docs);
      args.put("portfolioOptions", new PortfolioOptions(documentDefinition, contract));
      portForm = Modal.getModal("/WEB-INF/_zul/financials/document/portfolioAction.zul", null, args);
      Modal.doModal(portForm, new Command() {
        @Override
        public Object execute(Context context) {
          processResult(portForm.getResult(), portForm, list, now);
          list.clear();
          portForm.detach();
          if(command != null) command.execute(context);
          return null;
        }
      });
    } else {
      processResult(1, portForm, list, now);
      list.clear();
    }
  }
 
  private boolean processResult(int result, ModalWindow portForm, List<PortfolioAction> list, Date now) {
    if (result == 2) {
      wasCancelled = true;
      return true;
    } else if (result == 1) {
      if(po == null || po.isStopOnContract()) {
        po = (PortfolioOptions) portForm.getResultValue();
      }
      Document nd = null;
      if(po.isAccumulated()) {
        nd = new Document();
      }
      for(PortfolioAction pa : list) {
        if(!po.isAccumulated()) {
          nd = new Document();
        }
        nd.conciliateRegister = po.isConciliateRegister();
        if(pa.isForward()) {
          nd.flowFrom(pa.getDocument(), new DocumentWrapper(pa.getDocument()).getDocDescription(), pa.getWorkflow());
          nd.setDocumentNumber(pa.getDocument().getDocumentNumber() + "/1");
        } else {
          nd.backFrom(pa.getDocument(), new DocumentWrapper(pa.getDocument()).getDocDescription(), pa.getWorkflow());
          nd.setDocumentNumber(pa.getDocument().getDocumentNumber() + "\\1");
        }
        if(po.getDateMode() == 0) {
          nd.setDocumentDate(now);
          nd.setReceiptDate(now);
        } else if(po.getDateMode() == 2) {
          nd.setDocumentDate(po.getDate());
          nd.setReceiptDate(po.getDate());
        }
        if(po.getStoreMode() == 2) {
          for(DocumentLine dl : nd.getDocumentLines()) {
            dl.setStore(po.getStore());
          }
        }
        if(!po.isAccumulated()) {
          if(po.isAutosave()) {
            new DocumentWrapper(nd).save(new ArrayList(nd.getDocumentLines()), null);
          } else {
            FinancialsMenu.showDocument(nd);
          }
        }
        pa.getRow().detach();
      }
      if(po.isAccumulated()) {
        if(po.isAutosave()) {
          new DocumentWrapper(nd).save(new ArrayList(nd.getDocumentLines()), null);
        } else {
          FinancialsMenu.showDocument(nd);
        }
      }
      return true;
    }
    return false;
  }
 
  private Collection<Document> getDocuments(List<PortfolioAction> list) {
    ArrayList<Document> docs = new ArrayList<>();
    for(PortfolioAction pa : list) {
      docs.add(pa.getDocument());
    }
    return docs;
  }
 
}