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 
}