RequisitionActionHandler 5

package org.wirabumi.gen.oez.porting;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;

import org.hibernate.criterion.Restrictions;
import org.openbravo.base.exception.OBException;
import org.openbravo.base.model.Entity;
import org.openbravo.base.secureApp.VariablesSecureApp;
import org.openbravo.base.structure.BaseOBObject;
import org.openbravo.dal.service.OBCriteria;
import org.openbravo.dal.service.OBDal;
import org.openbravo.database.ConnectionProvider;
import org.openbravo.erpCommon.utility.OBError;
import org.openbravo.exception.NoConnectionAvailableException;
import org.openbravo.model.ad.datamodel.Table;
import org.openbravo.model.ad.ui.Tab;
import org.openbravo.model.ad.utility.Attachment;
import org.openbravo.model.common.plm.ProductCategory;
import org.openbravo.model.materialmgmt.transaction.ShipmentInOut;
import org.openbravo.model.procurement.Requisition;
import org.openbravo.model.procurement.RequisitionLine;
import org.openbravo.service.db.DalConnectionProvider;
import org.wirabumi.gen.oez.event.DocumentRoutingHandlerAction;

import com.sun.corba.se.spi.orbutil.fsm.Guard.Result;

public class RequisitionActionHandler extends DocumentRoutingHandlerAction {
    private final String reactiveStatus="RE";
    private final String completeStatus="CO";
    private final String draftStatus="DR";
    private final String closedStatus="CL";
    private final String voidStatus="VO";
    private final String processID="1004400003";

    /*tiko [langkah-langkah]

      1. jika tabel null maka
      2. seleksi list  untuk ambil id requisition,  dan line dari requisition yang sedang approval dengan record id
      3. seleksi apak line memiliki product category search key "INVESTASI" atau tidak? * done
      4. jika bernilai investasi dan tidak memiliki attachments maka OBException * done
     */

    @Override
    public void doRouting(String adWindowId, String adTabId,
            String doc_status_to, VariablesSecureApp vars, List<String> recordId) {
        if (doc_status_to.equalsIgnoreCase(voidStatus))
            throw new OBException("@ActionNotAllowedHere@"); //requisition tidak boleh di void

        for (String requisitionID : recordId){

            /*tiko*/
            Tab tab = OBDal.getInstance().get(Tab.class, adTabId);
            Table table = tab.getTable();
            String tableid = table.getId();


            Requisition requi = OBDal.getInstance().get(Requisition.class, requisitionID);
            List <RequisitionLine> requiL = requi.getProcurementRequisitionLineList();

            for (RequisitionLine re : requiL) {
                if (re.getProduct().getProductCategory().getSearchKey().equalsIgnoreCase("INVESTASI") ==true) {

                    /*OBCriteria<Attachment> attachCriteria = OBDal.getInstance().createCriteria(Attachment.class);
                    attachCriteria.add(Restrictions.eq(Attachment.PROPERTY_TABLE, tableid));
                    BaseOBObject baseobobject = OBDal.getInstance().get(BaseOBObject.class, re.getId());
                    attachCriteria.add(Restrictions.eq(Attachment.PROPERTY_RECORD, baseobobject));
                    List<Attachment> attachList = attachCriteria.list();
                    if (attachList.size()==0)
                        throw new OBException("Attachment document is required for procurement of this product");
                     */

                    String sqlquery = "select count(*) from c_file"
                            + " where ad_table_id= ?"
                            + " and ad_record_id= ?";
                    ConnectionProvider conn = new DalConnectionProvider();
                    Connection connection;
                    boolean hasAttachment = false;
                    try {
                        connection = conn.getConnection();
                        PreparedStatement ps = connection.prepareStatement(sqlquery);
                        ps.setString(1, tableid);
                        ps.setString(2, re.getId());
                        ResultSet rs = ps.executeQuery();
                        while (rs.next())
                            hasAttachment=true;

                    } catch (NoConnectionAvailableException e) {
                        e.printStackTrace();
                        throw new OBException(e.getMessage());
                    } catch (SQLException e) {
                        e.printStackTrace();
                        throw new OBException("Attachment document is required for procurement of this product");
                    }
                }
            }
            /*tiko*/

            if (doc_status_to.equalsIgnoreCase(completeStatus)){
                Requisition requisition = OBDal.getInstance().get(Requisition.class, requisitionID);
                //cek apakah dari CL atau VO, jika ya, maka exception
                if (requisition.getDocumentStatus().equalsIgnoreCase(closedStatus)||
                        requisition.getDocumentStatus().equalsIgnoreCase(voidStatus))
                    throw new OBException("@ActionNotAllowedHere@");

                //ubdah dulu docstatus menjadi DR, baru di complete
                requisition.setDocumentStatus(draftStatus);
                requisition.setDocumentAction(doc_status_to);
                OBDal.getInstance().save(requisition);
                OBDal.getInstance().flush();

            } else if (doc_status_to.equalsIgnoreCase(reactiveStatus)){
                //cek apakah doc status adalah CO, jika tidak maka exception
                Requisition requisition = OBDal.getInstance().get(Requisition.class, requisitionID);
                if (!requisition.getDocumentStatus().equalsIgnoreCase(completeStatus))
                    throw new OBException("@ActionNotAllowedHere@");
                requisition.setDocumentAction(doc_status_to);
                OBDal.getInstance().save(requisition);
                OBDal.getInstance().flush();

            }
            doExecuteProcedureCall(requisitionID, processID);

        }


    }

    @Override
    public String getCoDocumentNo(String recordID, Tab tab) {
        // TODO sementara null dulu
        return null;
    }

    @Override
    public Boolean updateDocumentStatus(Entity entity,  List<String> RecordId, String document_status_to,String column){
        if (document_status_to.equalsIgnoreCase(completeStatus)||
                document_status_to.equalsIgnoreCase(closedStatus))
            return true;
        else
            return super.updateDocumentStatus(entity, RecordId, document_status_to, column);

    }

}