ValProductCanOnlyInOnePoConsignmentManual

package org.jleaf.erp.purch.bo.po;

import java.util.List;

import javax.persistence.Query;

import org.jleaf.core.AbstractBusinessFunction;
import org.jleaf.core.BusinessFunction;
import org.jleaf.core.CoreException;
import org.jleaf.core.Dto;
import org.jleaf.core.GeneralConstants;
import org.jleaf.core.annotation.ErrorList;
import org.jleaf.core.annotation.Info;
import org.jleaf.core.annotation.InfoIn;
import org.jleaf.core.dao.QueryBuilder;
import org.jleaf.erp.purch.entity.PurchaseOrder;
import org.jleaf.erp.purch.entity.PurchaseOrderExt;
import org.jleaf.erp.purch.entity.PurchaseOrderItem;
import org.jleaf.erp.purch.entity.PurchaseOrderBalanceItem;
import org.jleaf.erp.purch.PurchasingConstants;
import org.jleaf.erp.purch.PurchasingExceptionConstantsForCland;
import org.jleaf.erp.purch.dao.PurchaseOrderBalanceItemDao;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

/**
 * Memperbaiki pesan exception
 * modified by Adrian
 * May 28, 2018
 */

// @formatter:off
@Service
@InfoIn(value = {
        @Info(name = "productId", description = "product ID to check", type = Long.class)
})

@ErrorList(errorKeys = {
        PurchasingExceptionConstantsForCland.THERE_SOME_PRODUCT_ALREADY_USE_ANOTHER_TRANSACTION
})

// @formatter:on
public class ValProductCanOnlyInOnePoConsignmentManual extends AbstractBusinessFunction implements BusinessFunction {

    private static final Logger log = LoggerFactory.getLogger(ValProductCanOnlyInOnePoConsignmentManual.class);
    @Autowired
    private PurchaseOrderBalanceItemDao purchaseOrderBalanceItemDao;

    public String getDescription() {
        return "Validasi Produk yang ada di PO konsinyasi manual untuk produk tersebut jika status item R / I";
    }

    @SuppressWarnings("unchecked")
    public Dto execute(Dto inputDto) throws Exception {

        log.debug(" iya coy sudah masuk sini product nya " + inputDto);

        List<Object[]> result = null;

        QueryBuilder builder = new QueryBuilder();
        builder.add(" SELECT D.doc_no, f_get_product_code(B.product_id) AS product_code ")
        .add(" FROM ").add(PurchaseOrderBalanceItem.TABLE_NAME).add(" A ")
        .add(" INNER JOIN ").add(PurchaseOrderItem.TABLE_NAME).add(" B ON A.po_item_id = B.po_item_id ")
        .add(" INNER JOIN ").add(PurchaseOrderExt.TABLE_NAME).add(" C ON B.po_id = C.po_id ")
        .add(" INNER JOIN ").add(PurchaseOrder.TABLE_NAME).add(" D ON C.po_id = D.po_id ")
        .add(" WHERE A.status_item IN (:RELEASED,:INPROGRESS) AND B.product_id = :productId ")
        .add(" AND C.flg_buy_consignment = :NO ")
        .add(" AND C.flg_konsinyasi_manual = :YES ");

        Query query = purchaseOrderBalanceItemDao.createNativeQuery(builder.toString());
        query.setParameter("productId", inputDto.getLong("productId"));
        query.setParameter("RELEASED", PurchasingConstants.RELEASED_TRANSACTION);
        query.setParameter("INPROGRESS", PurchasingConstants.IN_PROGRESS_TRANSACTION);
        query.setParameter("NO", GeneralConstants.NO);
        query.setParameter("YES", GeneralConstants.YES);

        result = query.getResultList();

        List<Object[]> list = result;

        if(list.size() > 0) {
            String productCode = String.valueOf(list.get(0)[1]);
            String docNo = String.valueOf(list.get(0)[0]);
            throw new CoreException(
                    PurchasingExceptionConstantsForCland.THERE_SOME_PRODUCT_ALREADY_USE_ANOTHER_TRANSACTION,
                    productCode,
                    docNo);
        }

        return new Dto();

    }

}