Subversion Repositories SmartDukaan

package in.shop2020.inventory.controllers;

import in.shop2020.model.v1.catalog.InventoryType;
import in.shop2020.model.v1.catalog.Item;
import in.shop2020.model.v1.catalog.ItemType;
import in.shop2020.model.v1.catalog.Warehouse;
import in.shop2020.model.v1.catalog.WarehouseType;
import in.shop2020.model.v1.order.LineItem;
import in.shop2020.purchase.PurchaseOrder;
import in.shop2020.purchase.PurchaseServiceException;
import in.shop2020.thrift.clients.CatalogClient;
import in.shop2020.thrift.clients.PurchaseClient;
import in.shop2020.thrift.clients.WarehouseClient;
import in.shop2020.utils.ModelUtils;
import in.shop2020.warehouse.InventoryItem;
import in.shop2020.warehouse.ScanType;
import in.shop2020.warehouse.WarehouseService.Client;
import in.shop2020.warehouse.WarehouseServiceException;

import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

import javax.servlet.ServletContext;

import org.apache.struts2.convention.annotation.Result;
import org.apache.struts2.convention.annotation.Results;
import org.apache.thrift.TException;
import org.apache.thrift.transport.TTransportException;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

@SuppressWarnings("serial")
@Results({ @Result(name = "redirect", type = "redirectAction", params = {
        "actionName", "warehouse" }) })
public class PurchaseController extends BaseController {
    /**
     * 
     */
    private static final int NUM_BULK__SCAN_ITEMS = 10;
    private static Logger logger = LoggerFactory.getLogger(PurchaseController.class);
    private static enum ScanRecordType { VALID, BLANK };

    private ServletContext context;
    private String id;
    private String itemId;
    private String itemNo;
    private String errorMsg = "";
    private List<Item> items;
    private List<LineItem> lineItems;

    private String purchaseOrderId;
    private Warehouse warehouse;

    public String editNew() {
        purchaseOrderId = request.getParameter("poId");
        return "new";
    }

    public String create() {
        this.purchaseOrderId = request.getParameter("poId");
        long poId = Long.parseLong(purchaseOrderId);
        String invoiceNumber = request.getParameter("invoiceNo");
        String fc = request.getParameter("freightCharges").trim();
        double freightCharges = 0;
        if (fc != null && !fc.isEmpty())
            freightCharges = Double.parseDouble(fc);
        try {
            PurchaseClient purchaseClient = new PurchaseClient();
            in.shop2020.purchase.PurchaseService.Client client = purchaseClient
                    .getClient();
            id = "" + client.startPurchase(poId, invoiceNumber, freightCharges);
        } catch (TTransportException e) {
            errorMsg = "Error while establishing connection to the warehouse server";
            logger.error(errorMsg, e);
        } catch (TException e) {
            errorMsg = "Error while scanning in the item";
            logger.error(errorMsg, e);
        } catch (PurchaseServiceException e) {
            errorMsg = e.getMessage();
            logger.error(errorMsg, e);
        }

        if (errorMsg.isEmpty())
            return "create";
        else {
            addActionError(errorMsg);
            return "new";
        }

    }

    public String show() {
        resetLineItems();
        setItemsFromPO(Long.parseLong(id));
        return SHOW;
    }

    private void resetLineItems() {
        lineItems = new ArrayList<LineItem>();

        for (int i = 0; i < NUM_BULK__SCAN_ITEMS; i++) {
            LineItem lineItem = new LineItem();
            lineItem.setId(i);
            lineItem.setExtra_info("");
            lineItem.setSerial_number("");
            lineItem.setItem_number("");
            lineItem.setQuantity(1);
            lineItem.setItem_id(-1);
            lineItems.add(lineItem);
        }
    }

    public String update() {
        long id = Long.parseLong(this.id);
        setItemsFromPO(id);

        try {
            if (!areValidScans()) {
                return SHOW;
            }

            WarehouseClient warehouseClient = new WarehouseClient();
            Client client = warehouseClient.getClient();

            for (LineItem lineItem : lineItems) {
                if (ScanRecordType.BLANK.name().equals(lineItem.getExtra_info())) {
                    continue;
                }

                if (ItemType.SERIALIZED.name().equals(lineItem.getProductGroup())) {
                    InventoryItem inventoryItem = client.createSerializedInventoryItem(lineItem.getItem_id(), lineItem.getItem_number(), lineItem.getSerial_number(), id);
                    client.scanSerializedItem(inventoryItem, ScanType.PURCHASE, PurchaseOrderController.WAREHOUSE_ID);
                }
                else {
                    InventoryItem inventoryItem = client.createInventoryItem(lineItem.getItem_id(), new Double(lineItem.getQuantity()).longValue(), id);
                    client.scan(inventoryItem, ScanType.PURCHASE, new Double(lineItem.getQuantity()).longValue()
                            , PurchaseOrderController.WAREHOUSE_ID);
                }
            }

            resetLineItems();
        } catch (TTransportException e) {
            errorMsg = "Error while establishing connection to the warehouse server";
            logger.error(errorMsg, e);
        } catch (WarehouseServiceException e) {
            errorMsg = e.getMessage();
            logger.error(errorMsg, e);
        } catch (TException e) {
            errorMsg = "Error while scanning in the item";
            logger.error(errorMsg, e);
        }

        if (!errorMsg.isEmpty()) {
            addActionError(errorMsg);
        }

        return SHOW;
    }

    /**
     * @return
     * @throws TException 
     * @throws NumberFormatException 
     */
    private boolean areValidScans() throws NumberFormatException, TException {
        boolean areValidScans = true;
        in.shop2020.purchase.PurchaseService.Client purchaseClient = new PurchaseClient().getClient();
        PurchaseOrder purchaseOrder = purchaseClient.getPurchaseOrderForPurchase(Long.parseLong(id));
        Map<Long, Long> itemsQuantityMapFromPO = new HashMap<Long, Long>();
        for (in.shop2020.purchase.LineItem lineItem : purchaseOrder.getLineitems()) {
            itemsQuantityMapFromPO.put(lineItem.getItemId(), (long) lineItem.getUnfulfilledQuantity());
        }

        Client warehouseClient = new WarehouseClient().getClient();

        for (LineItem lineItem : lineItems) {
            if (lineItem.getItem_id() == -1 && lineItem.getItem_number().isEmpty() && lineItem.getSerial_number().isEmpty()) {
                lineItem.setExtra_info(ScanRecordType.BLANK.name());
            }
            else {
                lineItem.setExtra_info(ScanRecordType.VALID.name());
                if (ItemType.SERIALIZED.name().equals(lineItem.getProductGroup())) {
                    if (lineItem.getSerial_number().isEmpty()) {
                        lineItem.setExtra_info("Serial number not present.");
                        areValidScans = false;
                        continue;
                    }

                    try {
                        warehouseClient.getInventoryItem(lineItem.getSerial_number());
                        lineItem.setExtra_info("Item scanned already.");
                        areValidScans = false;
                        continue;
                    }
                    catch (Exception e) {
                    }
                }

                if (lineItem.getItem_id() == -1 && lineItem.getItem_number().isEmpty()) {
                    lineItem.setExtra_info("Item not selected/Item number not present.");
                    areValidScans = false;
                    continue;
                }

                if (lineItem.getItem_id() == -1) {
                    List<Long> itemIds = warehouseClient.getItemIds(lineItem.getItem_number());
                    if (itemIds.isEmpty()) {
                        lineItem.setExtra_info("Unknown item number");
                        areValidScans = false;
                        continue;
                    }

                    if (itemIds.size() > 0) {
                        int numItemsInPO = 0;
                        for (long itemId : itemIds) {
                            if (itemsQuantityMapFromPO.containsKey(itemId)) {
                                numItemsInPO++;
                                lineItem.setItem_id(itemId);
                            }
                        }
                        
                        if (numItemsInPO > 1) {
                            lineItem.setExtra_info("Multiple items found for given item Number. Choose item explicitly.");
                            areValidScans = false;
                            continue;
                        }
                    }
                }

                if (!itemsQuantityMapFromPO.containsKey(lineItem.getItem_id())) {
                    lineItem.setExtra_info("Item not present in PO.");
                    areValidScans = false;
                    continue;
                }

                itemsQuantityMapFromPO.put(lineItem.getItem_id(),
                        itemsQuantityMapFromPO.get(lineItem.getItem_id()) - new Double(lineItem.getQuantity()).longValue());

                if (itemsQuantityMapFromPO.get(lineItem.getItem_id()) < 0) {
                    lineItem.setExtra_info("Item already fulfilled in PO.");
                    areValidScans = false;
                    continue;
                }
            }
        }

        return areValidScans;
    }

    private void setItemsFromPO(long id) {
        try {
            items = new ArrayList<Item>();
            in.shop2020.purchase.PurchaseService.Client purchaseClient = new PurchaseClient().getClient();
            PurchaseOrder purchaseOrder = purchaseClient.getPurchaseOrderForPurchase(id);
            in.shop2020.model.v1.catalog.InventoryService.Client catalogClient = new CatalogClient().getClient();

            for (in.shop2020.purchase.LineItem lineItem : purchaseOrder.getLineitems()) {
                Item item = new Item();
                item.setId(lineItem.getItemId());
                item.setBrand(lineItem.getBrand());
                item.setModelName(lineItem.getModelName());
                item.setModelNumber(lineItem.getModelNumber());
                item.setColor(lineItem.getColor());
                item.setProductGroup(catalogClient.getItem(lineItem.getItemId()).getType().name());                
                items.add(item);
            }
            
            warehouse = catalogClient.getWarehouses(WarehouseType.OURS, InventoryType.GOOD, purchaseOrder.getSupplierId(), PurchaseOrderController.WAREHOUSE_ID, PurchaseOrderController.WAREHOUSE_ID).get(0);
        } catch (Exception e) {
            logger.error("Could not find items in PO with purchase: " + id, e);
        }
    }

    public String destroy() {
        long id = Long.parseLong(this.id);

        try {
            PurchaseClient warehouseClient = new PurchaseClient();
            in.shop2020.purchase.PurchaseService.Client client = warehouseClient
                    .getClient();
            client.closePurchase(id);
        } catch (TTransportException e) {
            errorMsg = "Error while establishing connection to the warehouse server";
            logger.error(errorMsg, e);
        } catch (TException e) {
            errorMsg = "Error while scanning in the item";
            logger.error(errorMsg, e);
        } catch (PurchaseServiceException e) {
            errorMsg = e.getMessage();
            logger.error(errorMsg, e);
        }
        return "redirect";
    }

    public String createItemNumberMapping() {
        long itemIdLong = Long.parseLong(itemId);

        try {
            Client warehouseClient = new WarehouseClient().getClient();
            warehouseClient.createItemNumberMapping(itemNo, itemIdLong);
        } catch (TTransportException e) {
            logger.error("Could not create thrift client", e);
        } catch (TException e) {
            logger.error("Could not create item number mapping", e);
        }

        return show();
    }

    public String itemNumberMappingEditNew() {
        return "item-number-mapping";
    }

    public String getName(Item item){
        return ModelUtils.extractProductNameFromItem(item);
    }

    public void setId(String id) {
        this.id = id;
    }

    public String getId() {
        return id;
    }

    public String getErrorMessage() {
        return errorMsg;
    }

    public String getPurchaseOrderId() {
        return purchaseOrderId;
    }

    public String getServletContextPath() {
        return context.getContextPath();
    }

    public String getItemId() {
        return itemId;
    }

    public void setItemId(String itemId) {
        this.itemId = itemId;
    }

    public String getItemNo() {
        return itemNo;
    }

    public void setItemNo(String itemNo) {
        this.itemNo = itemNo;
    }

    public List<Item> getItems() {
        return items;
    }

    public void setItems(List<Item> items) {
        this.items = items;
    }

    public List<LineItem> getLineItems() {
        return lineItems;
    }

    public void setLineItems(List<LineItem> lineItems) {
        this.lineItems = lineItems;
    }

    public Warehouse getWarehouse() {
        return warehouse;
    }
}