Subversion Repositories SmartDukaan

package in.shop2020.hotspot.dashbaord.server;

import in.shop2020.model.v1.order.Order;
import in.shop2020.model.v1.order.TransactionService.Client;
import in.shop2020.thrift.clients.TransactionClient;
import in.shop2020.thrift.clients.WarehouseClient;
import in.shop2020.warehouse.InventoryItem;

import java.io.File;
import java.io.FileInputStream;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

import org.apache.poi.hssf.usermodel.HSSFCell;
import org.apache.poi.hssf.usermodel.HSSFSheet;
import org.apache.poi.hssf.usermodel.HSSFWorkbook;
import org.apache.poi.ss.usermodel.DataFormatter;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;


public class ProcessBulkBilling{
        private static  Logger logger = LoggerFactory.getLogger(ProcessBulkBilling.class);

        private String fileName;
        private String logisticsTransactionId;
        private String packageDimensions;
        private List<InventoryItem> inventoryItems;
        private Map<Long, Long> itemQuantityMap= new HashMap<Long, Long>();
        private Map<Long, List<InventoryItem>> inventoryItemMap= new HashMap<Long, List<InventoryItem>>();
        private ArrayList<String> imei_list = new ArrayList<String>();


        ProcessBulkBilling(String fileName, String logisticsTransactionId, String packageDimensions) {
                logger.info("FileName "+fileName+" logisticsTransactionId "+logisticsTransactionId+" packageDimension "+packageDimensions);
                this.fileName = fileName;
                this.logisticsTransactionId = logisticsTransactionId;
                this.packageDimensions = packageDimensions;
        }

        public boolean processReport() {
                try{

                        FileInputStream iFile = new FileInputStream(new File(fileName));
                        HSSFWorkbook workbook = new HSSFWorkbook(iFile);
                        HSSFSheet sheet = workbook.getSheetAt(0);
                        DataFormatter formatter = new DataFormatter();
                        for (int iterator=sheet.getFirstRowNum()+1;iterator<=sheet.getLastRowNum();iterator++){
                                HSSFCell imei_cell = sheet.getRow(iterator).getCell(0);
                                String imei = formatter.formatCellValue(imei_cell).trim();
                                if (imei == null || imei.isEmpty()){
                                        break;
                                }
                                if (imei_list.contains(imei)){
                                        return false;
                                }
                                imei_list.add(imei);
                        }
                        return true;
                }
                catch(Exception e){
                        e.printStackTrace();
                        return false;
                }
        }

        public String checkBillingDetails(){
                List<Order> orders_list;
                try{
                        Client tc = new TransactionClient().getClient();
                        orders_list = tc.getGroupOrdersByLogisticsTxnId(logisticsTransactionId);
                }
                catch(Exception e){
                        e.printStackTrace();
                        return "Service Error!!!";
                }
                long total_quantity = 0;
                for (Order o : orders_list){
                        if (itemQuantityMap.containsKey(o.getLineitems().get(0).getItem_id())){
                                itemQuantityMap.put(o.getLineitems().get(0).getItem_id(), itemQuantityMap.get(o.getLineitems().get(0).getItem_id())+(long)o.getLineitems().get(0).getQuantity());
                        }
                        else{
                                itemQuantityMap.put(o.getLineitems().get(0).getItem_id(), (long)o.getLineitems().get(0).getQuantity());
                        }
                        total_quantity = (long) (total_quantity + o.getLineitems().get(0).getQuantity());
                }
                if (total_quantity != imei_list.size()){
                        return "Quantity and imei mismatch.Supplied imei's not equal to quantity to bill";
                }
                try{
                        in.shop2020.warehouse.WarehouseService.Client wc = new WarehouseClient().getClient();
                        inventoryItems = wc.getInventoryItems(imei_list);
                        for (InventoryItem it : inventoryItems){
                                if (inventoryItemMap.containsKey(it.getItemId())){
                                        inventoryItemMap.get(it.getItemId()).add(it);
                                }
                                else{
                                        List<InventoryItem> it_list = new ArrayList<InventoryItem>();
                                        it_list.add(it);
                                        inventoryItemMap.put(it.getItemId(), it_list);
                                }
                        }
                }
                catch(Exception e){
                        return "Exception while getting inventory items from warehouse";
                }
                logger.info("itemQuantityMap "+itemQuantityMap);
                logger.info("inventoryItemMap "+inventoryItemMap);
                return "success";
        }

}