Subversion Repositories SmartDukaan

Rev

Rev 12335 | Rev 13727 | Go to most recent revision | Show entire file | Ignore whitespace | Details | Blame | Last modification | View Log | RSS feed

Rev 12335 Rev 12523
Line 47... Line 47...
47
import java.util.HashSet;
47
import java.util.HashSet;
48
import java.util.List;
48
import java.util.List;
49
import java.util.Map;
49
import java.util.Map;
50
import java.util.Map.Entry;
50
import java.util.Map.Entry;
51
import java.util.Set;
51
import java.util.Set;
-
 
52
import java.util.TreeMap;
52
 
53
 
53
import org.apache.log4j.Logger;
54
import org.apache.log4j.Logger;
54
import org.apache.thrift.TException;
55
import org.apache.thrift.TException;
55
import org.apache.thrift.transport.TTransportException;
56
import org.apache.thrift.transport.TTransportException;
56
 
57
 
Line 665... Line 666...
665
			in.shop2020.model.v1.inventory.InventoryService.Client inventoryClient = inventoryServiceClient.getClient();
666
			in.shop2020.model.v1.inventory.InventoryService.Client inventoryClient = inventoryServiceClient.getClient();
666
 
667
 
667
			in.shop2020.model.v1.catalog.Item tItem = new in.shop2020.model.v1.catalog.Item();
668
			in.shop2020.model.v1.catalog.Item tItem = new in.shop2020.model.v1.catalog.Item();
668
			setThriftItemParams(tItem, item);
669
			setThriftItemParams(tItem, item);
669
			itemId = catalogClient.addItem(tItem);
670
			itemId = catalogClient.addItem(tItem);
-
 
671
			tItem.setId(itemId);
-
 
672
			Client catalogClientProd = new CatalogClient("catalog_service_server_host_prod","catalog_service_server_port").getClient();
-
 
673
			catalogClientProd.addItem(tItem);
670
			Map<Long, VendorPricings> vendorPricings = item.getVendorPricesMap();
674
			Map<Long, VendorPricings> vendorPricings = item.getVendorPricesMap();
671
			if(vendorPricings != null && !vendorPricings.isEmpty()) {
675
			if(vendorPricings != null && !vendorPricings.isEmpty()) {
672
				in.shop2020.model.v1.inventory.VendorItemPricing tVendorPricing;
676
				in.shop2020.model.v1.inventory.VendorItemPricing tVendorPricing;
673
				for(VendorPricings v : vendorPricings.values()) {
677
				for(VendorPricings v : vendorPricings.values()) {
674
					tVendorPricing = new in.shop2020.model.v1.inventory.VendorItemPricing();
678
					tVendorPricing = new in.shop2020.model.v1.inventory.VendorItemPricing();
Line 1492... Line 1496...
1492
		} catch (Exception e) {
1496
		} catch (Exception e) {
1493
			logger.error("Error while getting all the categories: ", e);
1497
			logger.error("Error while getting all the categories: ", e);
1494
		}
1498
		}
1495
		return categoryList;
1499
		return categoryList;
1496
	}
1500
	}
-
 
1501
	
-
 
1502
	@Override
-
 
1503
	public Map<Long, String> getAllCategoriesMap() {
-
 
1504
		Map<Long, String> categoryList = new TreeMap<Long, String>();
-
 
1505
		try {
-
 
1506
			CatalogClient catalogServiceClient = new CatalogClient();
-
 
1507
			Client catalogClient = catalogServiceClient.getClient();
-
 
1508
 
-
 
1509
			List<in.shop2020.model.v1.catalog.Category> categories = catalogClient.getAllCategories();
-
 
1510
 
-
 
1511
			for(in.shop2020.model.v1.catalog.Category category : categories) {
-
 
1512
				if(category.getParent_category_id() != 10000l && category.getParent_category_id() != 0l){
-
 
1513
					categoryList.put(category.getId(), category.getLabel());
-
 
1514
				}
-
 
1515
				else{
-
 
1516
					continue;
-
 
1517
				}
-
 
1518
			}
-
 
1519
		} catch (Exception e) {
-
 
1520
			logger.error("Error while getting all the categories: ", e);
-
 
1521
		}
-
 
1522
		return categoryList;
-
 
1523
	}
-
 
1524
 
1497
 
1525
 
1498
	@Override
1526
	@Override
1499
	public List<String> getAllBrands() {
1527
	public List<String> getAllBrands() {
1500
		List<String> brandsList = new ArrayList<String>();
1528
		List<String> brandsList = new ArrayList<String>();
1501
		try {
1529
		try {
Line 1853... Line 1881...
1853
																										thriftItem.getAsin(),
1881
																										thriftItem.getAsin(),
1854
																										thriftItem.getHoldInventory(),
1882
																										thriftItem.getHoldInventory(),
1855
																										thriftItem.getDefaultInventory(),stateNameVatPercentageMap,privateDeal);
1883
																										thriftItem.getDefaultInventory(),stateNameVatPercentageMap,privateDeal);
1856
		return item;
1884
		return item;
1857
	}
1885
	}
-
 
1886
 
-
 
1887
	@Override
-
 
1888
	public Map<Long, Double> getVatRates(long itemId, long categoryId) {
-
 
1889
		try {
-
 
1890
			Client catalogClient = new CatalogClient().getClient();
-
 
1891
			return catalogClient.getVatRates(itemId, categoryId);
-
 
1892
		} catch (Exception e){
-
 
1893
			e.printStackTrace();
-
 
1894
			logger.info("Could not fetch vat rates");
-
 
1895
		}
-
 
1896
		return new HashMap<Long, Double>(); 
-
 
1897
	}
-
 
1898
 
-
 
1899
	@Override
-
 
1900
	public Map<Long, String> getAllStatesMap() {
-
 
1901
		Map<Long, String> allStatesMap = new TreeMap<Long, String>();
-
 
1902
		try {
-
 
1903
			InventoryClient inventoryServiceClient = new InventoryClient();
-
 
1904
			in.shop2020.model.v1.inventory.InventoryService.Client inventoryClient = inventoryServiceClient.getClient();
-
 
1905
			Map<Long, StateInfo> stateMasterInfo = inventoryClient.getStateMaster();
-
 
1906
			for( Map.Entry<Long, StateInfo> si : stateMasterInfo.entrySet()){
-
 
1907
				allStatesMap.put(si.getKey(), si.getValue().getStateName());
-
 
1908
			}
-
 
1909
		} catch (Exception e){
-
 
1910
			logger.info("Could not fetch States");
-
 
1911
			e.printStackTrace();
-
 
1912
		}
-
 
1913
		return allStatesMap;
-
 
1914
	}
-
 
1915
 
-
 
1916
	@Override
-
 
1917
	public boolean markPartiallyActive(long itemId, Long categoryId) {
-
 
1918
		try {
-
 
1919
			Client catalogClient = new CatalogClient().getClient();
-
 
1920
			catalogClient.markPartiallyActive(itemId, categoryId);
-
 
1921
			Client catalogClientProd =  new CatalogClient("catalog_service_server_host_prod","catalog_service_server_port").getClient();
-
 
1922
			catalogClientProd.markPartiallyActive(itemId, categoryId);
-
 
1923
			return true;
-
 
1924
		} catch (Exception e){
-
 
1925
			e.printStackTrace();
-
 
1926
			logger.info("Could not update");
-
 
1927
		}
-
 
1928
		return false;
-
 
1929
	}
-
 
1930
 
-
 
1931
	@Override
-
 
1932
	public boolean updateItemStateVat(long itemId, List<in.shop2020.catalog.dashboard.shared.StateVat> svs) {
-
 
1933
		logger.info("In update itemStateVat");
-
 
1934
		try {
-
 
1935
			Map<Long, Double> stateVatMap = new HashMap<Long, Double>();
-
 
1936
			for(in.shop2020.catalog.dashboard.shared.StateVat sv : svs){
-
 
1937
				stateVatMap.put(sv.stateId, sv.vatRate);
-
 
1938
			}
-
 
1939
			Client catalogClient = new CatalogClient().getClient();
-
 
1940
			catalogClient.updateItemStateVat(itemId, stateVatMap);
-
 
1941
			Client catalogClientProd =  new CatalogClient("catalog_service_server_host_prod","catalog_service_server_port").getClient();
-
 
1942
			catalogClientProd.updateItemStateVat(itemId, stateVatMap);
-
 
1943
			return true;
-
 
1944
		} catch (Exception e){
-
 
1945
			e.printStackTrace();
-
 
1946
			logger.info("Could not update");
-
 
1947
			return false;
-
 
1948
		}
-
 
1949
	}
1858
}
1950
}