Subversion Repositories SmartDukaan

Rev

Rev 9835 | Rev 9841 | Go to most recent revision | Details | Compare with Previous | Last modification | View Log | RSS feed

Rev Author Line No. Line
1961 ankur.sing 1 
package in.shop2020.catalog.dashboard.server;
2 
 
3 
import in.shop2020.catalog.dashboard.client.CatalogService;
6530 vikram.rag 4 
 
7190 amar.kumar 5 
import in.shop2020.catalog.dashboard.shared.FreebieItem;
1961 ankur.sing 6 
import in.shop2020.catalog.dashboard.shared.Item;
4431 phani.kuma 7 
import in.shop2020.catalog.dashboard.shared.ItemInventory;
3850 chandransh 8 
import in.shop2020.catalog.dashboard.shared.ItemStatus;
2068 ankur.sing 9 
import in.shop2020.catalog.dashboard.shared.ItemsComparator;
3558 rajveer 10 
import in.shop2020.catalog.dashboard.shared.SourcePricings;
2119 ankur.sing 11 
import in.shop2020.catalog.dashboard.shared.VendorItemMapping;
12 
import in.shop2020.catalog.dashboard.shared.VendorPricings;
5504 phani.kuma 13 
import in.shop2020.catalog.dashboard.shared.VoucherItemMapping;
2378 ankur.sing 14 
import in.shop2020.config.ConfigException;
3907 chandransh 15 
import in.shop2020.content.ContentService;
16 
import in.shop2020.content.ContentServiceException;
5946 rajveer 17 
import in.shop2020.model.v1.catalog.CatalogService.Client;
6838 vikram.rag 18 
import in.shop2020.model.v1.catalog.Insurer;
5706 amit.gupta 19 
import in.shop2020.model.v1.catalog.ItemType;
2105 ankur.sing 20 
import in.shop2020.model.v1.catalog.status;
6096 amit.gupta 21 
import in.shop2020.model.v1.inventory.InventoryService;
6813 amar.kumar 22 
import in.shop2020.model.v1.inventory.ItemStockPurchaseParams;
9687 rajveer 23 
import in.shop2020.model.v1.inventory.OOSStatus;
5504 phani.kuma 24 
import in.shop2020.model.v1.user.VoucherType;
3129 rajveer 25 
import in.shop2020.thrift.clients.CatalogClient;
3907 chandransh 26 
import in.shop2020.thrift.clients.ContentClient;
5946 rajveer 27 
import in.shop2020.thrift.clients.InventoryClient;
2378 ankur.sing 28 
import in.shop2020.thrift.clients.config.ConfigClient;
2119 ankur.sing 29 
import in.shop2020.utils.CategoryManager;
2359 ankur.sing 30 
import in.shop2020.utils.ConfigClientKeys;
6530 vikram.rag 31 
import in.shop2020.model.v1.inventory.IgnoredInventoryUpdateItems;
32 
import in.shop2020.catalog.dashboard.shared.ItemWarehouse;
2427 ankur.sing 33 
import java.io.BufferedReader;
34 
import java.io.FileReader;
2359 ankur.sing 35 
import java.io.IOException;
2427 ankur.sing 36 
import java.text.DateFormat;
37 
import java.text.SimpleDateFormat;
1961 ankur.sing 38 
import java.util.ArrayList;
4957 phani.kuma 39 
import java.util.Arrays;
2105 ankur.sing 40 
import java.util.Calendar;
2068 ankur.sing 41 
import java.util.Collections;
2427 ankur.sing 42 
import java.util.Date;
1992 ankur.sing 43 
import java.util.HashMap;
5118 mandeep.dh 44 
import java.util.HashSet;
1961 ankur.sing 45 
import java.util.List;
1992 ankur.sing 46 
import java.util.Map;
2359 ankur.sing 47 
import java.util.Map.Entry;
5118 mandeep.dh 48 
import java.util.Set;
1961 ankur.sing 49 
 
2427 ankur.sing 50 
import org.apache.log4j.Logger;
3907 chandransh 51 
import org.apache.thrift.TException;
52 
import org.apache.thrift.transport.TTransportException;
2359 ankur.sing 53 
 
1961 ankur.sing 54 
import com.google.gwt.user.server.rpc.RemoteServiceServlet;
55 
 
56 
@SuppressWarnings("serial")
57 
public class CatalogServiceImpl extends RemoteServiceServlet implements CatalogService {
58 
 
3354 chandransh 59 
    private static Logger logger = Logger.getLogger(CatalogServiceImpl.class);
60 
 
3922 chandransh 61 
    private static Logger pushToProdLogger = Logger.getLogger("pushToProdLogger");
62 
 
2427 ankur.sing 63 
    private static Date pushToProdDate;
64 
 
3922 chandransh 65 
    private static String logFile;
66 
 
67 
    private static int maxCount;
68 
 
9640 amar.kumar 69 
    private static final int EBAYSOURCE = 6;
70 
    private static final int SNAPDEALSOURCE = 7;
71 
    private static final int FLIPKARTSOURCE = 8;
72 
 
3922 chandransh 73 
    static {
74 
        try {
75 
            logFile = ConfigClient.getClient().get(ConfigClientKeys.push_prices_to_prod_log_file.toString());
76 
            maxCount = Integer.parseInt(ConfigClient.getClient().get(ConfigClientKeys.push_prices_to_prod_max_count.toString()));
77 
        } catch(ConfigException ce) {
78 
            logger.error("Unable to connect to the config server. Setting sensible defaults.", ce);
79 
            logFile = "/var/log/services/pushToProductionCount/pushToProd.log";
80 
            maxCount = 5;
81 
        }
82 
 
83 
    }
84 
 
3850 chandransh 85 
    @Override
86 
    public int getItemCountByStatus(boolean useStatus, ItemStatus itemStatus){
87 
        int count = 0;
88 
        try{
89 
            CatalogClient catalogServiceClient = new CatalogClient();
5946 rajveer 90 
            Client catalogClient = catalogServiceClient.getClient();
3850 chandransh 91 
 
92 
            status stat = status.findByValue(itemStatus.getValue());
93 
            count = catalogClient.getItemCountByStatus(useStatus, stat);
94 
        }catch(Exception e){
95 
            logger.error("Error while getting the count of items from the catalog service", e);
96 
        }
97 
        return count;
98 
    }
99 
 
100 
    @Override
6530 vikram.rag 101 
	public List<Item> getInventoryOutofSyncItems(int offset, int limit){
102 
        List<Item> itemList = new ArrayList<Item>();
103 
 
104 
        try {
105 
            CatalogClient catalogServiceClient = new CatalogClient();
106 
            Client catalogClient = catalogServiceClient.getClient();
107 
 
108 
            List<in.shop2020.model.v1.catalog.Item> thriftItems = catalogClient.getAllIgnoredInventoryUpdateItemsList(offset, limit);
109 
 
110 
            for(in.shop2020.model.v1.catalog.Item thriftItem : thriftItems) {
9835 rajveer 111 
                itemList.add(getItemFromThriftItem(thriftItem, null, null, null, null, null, null, null, null, null));
6530 vikram.rag 112 
            }
113 
        } catch (Exception e) {
114 
            logger.error("Error while getting all items from the catalog service", e);
115 
        }
116 
        return itemList;
117 
    }
118 
 
119 
    @Override
120 
    public int getInventoryOutofSyncItemsCount(){
121 
	int count=0;
122 
    	try {
123 
            InventoryClient inventoryServiceClient = new InventoryClient();
124 
            in.shop2020.model.v1.inventory.InventoryService.Client inventoryClient = inventoryServiceClient.getClient();
125 
 
126 
            count = inventoryClient.getAllIgnoredInventoryupdateItemsCount();
127 
 
128 
            } catch (Exception e) {
129 
            logger.error("Error while getting all items from the catalog service", e);
130 
        }
131 
    	return count;
132 
    }
133 
 
134 
    @Override
3850 chandransh 135 
    public List<Item> getAllItems(int start, int limit) {
1961 ankur.sing 136 
        List<Item> itemList = new ArrayList<Item>();
2359 ankur.sing 137 
 
1961 ankur.sing 138 
        try {
3129 rajveer 139 
            CatalogClient catalogServiceClient = new CatalogClient();
5946 rajveer 140 
            Client catalogClient = catalogServiceClient.getClient();
2359 ankur.sing 141 
 
3850 chandransh 142 
            List<in.shop2020.model.v1.catalog.Item> thriftItems = catalogClient.getAllItemsInRange(start, limit);
2359 ankur.sing 143 
 
2119 ankur.sing 144 
            for(in.shop2020.model.v1.catalog.Item thriftItem : thriftItems) {
9835 rajveer 145 
                itemList.add(getItemFromThriftItem(thriftItem, null, null, null, null, null, null, null, null, null));
2119 ankur.sing 146 
            }
147 
        } catch (Exception e) {
3354 chandransh 148 
            logger.error("Error while getting all items from the catalog service", e);
2119 ankur.sing 149 
        }
150 
        return itemList;
151 
    }
2208 ankur.sing 152 
 
3850 chandransh 153 
    public List<Item> getAllActiveItems(int start, int limit){
154 
        return getItemsByStatus(status.ACTIVE, start, limit);
2208 ankur.sing 155 
    }
2359 ankur.sing 156 
 
157 
    @Override
3850 chandransh 158 
    public List<Item> getAllPhasedOutItems(int start, int limit){
159 
        return getItemsByStatus(status.PHASED_OUT, start, limit);
2359 ankur.sing 160 
    }
161 
 
162 
    @Override
3850 chandransh 163 
    public List<Item> getAllPausedItems(int start, int limit){
164 
        return getItemsByStatus(status.PAUSED, start, limit);
2208 ankur.sing 165 
    }
2359 ankur.sing 166 
 
167 
    @Override
3850 chandransh 168 
    public List<Item> getAllInProcessItems(int start, int limit) {
169 
        return getItemsByStatus(status.IN_PROCESS, start, limit);
2359 ankur.sing 170 
    }
171 
 
172 
    @Override
3850 chandransh 173 
    public List<Item> getAllContentCompleteItems(int start, int limit) {
174 
        return getItemsByStatus(status.CONTENT_COMPLETE, start, limit);
2359 ankur.sing 175 
    }
176 
 
177 
    public List<Item> getBestDeals(){
2119 ankur.sing 178 
        List<Item> itemList = new ArrayList<Item>();
179 
        try {
3129 rajveer 180 
            CatalogClient catalogServiceClient = new CatalogClient();
5946 rajveer 181 
            Client catalogClient = catalogServiceClient.getClient();
2359 ankur.sing 182 
 
183 
            List<in.shop2020.model.v1.catalog.Item> thriftItems = catalogClient.getBestDeals();
1992 ankur.sing 184 
            for(in.shop2020.model.v1.catalog.Item thriftItem : thriftItems) {
9835 rajveer 185 
                itemList.add(getItemFromThriftItem(thriftItem, null, null, null, null, null, null, null, null, null));
1992 ankur.sing 186 
            }
2359 ankur.sing 187 
        } catch(Exception e){
3354 chandransh 188 
            logger.error("Error while getting the best deals from the catalog service", e);
1961 ankur.sing 189 
        }
2562 chandransh 190 
        //Collections.sort(itemList, new ItemsComparator());
1961 ankur.sing 191 
        return itemList;
192 
    }
193 
 
2359 ankur.sing 194 
    @Override
195 
    public List<Item> getRiskyItems() {
1961 ankur.sing 196 
        List<Item> itemList = new ArrayList<Item>();
197 
        try {
3129 rajveer 198 
            CatalogClient catalogServiceClient = new CatalogClient();
5946 rajveer 199 
            Client catalogClient = catalogServiceClient.getClient();
2359 ankur.sing 200 
 
201 
            List<in.shop2020.model.v1.catalog.Item> thriftItems = catalogClient.getItemsByRiskyFlag();
1992 ankur.sing 202 
            for(in.shop2020.model.v1.catalog.Item thriftItem : thriftItems) {
9835 rajveer 203 
                itemList.add(getItemFromThriftItem(thriftItem, null, null, null, null, null, null, null, null, null));
1992 ankur.sing 204 
            }
1961 ankur.sing 205 
        } catch(Exception e){
3354 chandransh 206 
            logger.error("Error while getting the risky items from the catalog service", e);
1961 ankur.sing 207 
        }
2068 ankur.sing 208 
        Collections.sort(itemList, new ItemsComparator());
1961 ankur.sing 209 
        return itemList;
210 
    }
2359 ankur.sing 211 
 
1961 ankur.sing 212 
    public List<Item> getBestSellers(){
213 
        List<Item> itemList = new ArrayList<Item>();
2359 ankur.sing 214 
 
1961 ankur.sing 215 
        try {
3129 rajveer 216 
            CatalogClient catalogServiceClient = new CatalogClient();
5946 rajveer 217 
            Client catalogClient = catalogServiceClient.getClient();
2359 ankur.sing 218 
 
1961 ankur.sing 219 
            List<in.shop2020.model.v1.catalog.Item> thriftItems = catalogClient.getBestSellers();
1992 ankur.sing 220 
            for(in.shop2020.model.v1.catalog.Item thriftItem : thriftItems) {
9835 rajveer 221 
                itemList.add(getItemFromThriftItem(thriftItem, null, null, null, null, null, null, null, null, null));
1992 ankur.sing 222 
            }
1961 ankur.sing 223 
        } catch(Exception e){
3354 chandransh 224 
            logger.error("Error while getting the best sellers from the catalog service", e);
1961 ankur.sing 225 
        }
226 
        return itemList;
227 
    }
6530 vikram.rag 228 
 
229 
    @Override
230 
    public boolean addtoIgnoredInventoryUpdateItemsIdsWarehouseIds(long itemId,long warehouseId){
231 
    	try {
232 
				InventoryClient inventoryServiceClient = new InventoryClient();
233 
				in.shop2020.model.v1.inventory.InventoryService.Client inventoryClient = inventoryServiceClient.getClient();
234 
				return inventoryClient.insertItemtoIgnoreInventoryUpdatelist(itemId, warehouseId);
235 
			} catch (Exception e) {
236 
            logger.error("Error while inserting item to ignore inventory update list", e);
237 
            }
238 
			return false;
239 
    }
240 
 
241 
    @Override
242 
    public boolean deleteFromIgnoredInventoryUpdateItemsIdsWarehouseIds(long itemId,long warehouseId){
243 
    	try {
244 
    			InventoryClient inventoryServiceClient = new InventoryClient();
245 
    			in.shop2020.model.v1.inventory.InventoryService.Client inventoryClient = inventoryServiceClient.getClient();
246 
    			return inventoryClient.deleteItemFromIgnoredInventoryUpdateList(itemId,warehouseId);
247 
 
248 
		} catch (Exception e) {
6532 amit.gupta 249 
			logger.error("Error while inserting item to ignore inventory update list", e);
6530 vikram.rag 250 
        }
251 
		return false;
252 
}
2359 ankur.sing 253 
 
6530 vikram.rag 254 
 
255 
 
3872 chandransh 256 
    @Override
1961 ankur.sing 257 
    public List<Item> getLatestArrivals(){
258 
        List<Item> itemList = new ArrayList<Item>();
2359 ankur.sing 259 
 
1961 ankur.sing 260 
        try {
3129 rajveer 261 
            CatalogClient catalogServiceClient = new CatalogClient();
5946 rajveer 262 
            Client catalogClient = catalogServiceClient.getClient();
2359 ankur.sing 263 
 
1961 ankur.sing 264 
            List<in.shop2020.model.v1.catalog.Item> thriftItems = catalogClient.getLatestArrivals();
1992 ankur.sing 265 
            for(in.shop2020.model.v1.catalog.Item thriftItem : thriftItems) {
5946 rajveer 266 
                //List<in.shop2020.model.v1.inventory.VendorItemPricing> vip = catalogClient.getAllItemPricing(thriftItem.getId());
9835 rajveer 267 
                itemList.add(getItemFromThriftItem(thriftItem, null, null, null, null, null, null, null, null, null));
1992 ankur.sing 268 
            }
1961 ankur.sing 269 
        } catch(Exception e){
3354 chandransh 270 
            logger.error("Error while getting the latest arrivals from the catalog service", e);
1961 ankur.sing 271 
        }
272 
        return itemList;
273 
    }
2359 ankur.sing 274 
 
3872 chandransh 275 
    @Override
276 
    public List<Item> searchItems(int start, int limit, List<String> searchTerms) {
277 
        List<Item> itemList = new ArrayList<Item>();
278 
 
279 
        try {
280 
            CatalogClient catalogServiceClient = new CatalogClient();
5946 rajveer 281 
            Client catalogClient = catalogServiceClient.getClient();
3872 chandransh 282 
 
283 
            List<in.shop2020.model.v1.catalog.Item> thriftItems = catalogClient.searchItemsInRange(searchTerms, start, limit);
284 
            for(in.shop2020.model.v1.catalog.Item thriftItem : thriftItems) {
9835 rajveer 285 
                itemList.add(getItemFromThriftItem(thriftItem, null, null, null, null, null, null, null, null,null));
3872 chandransh 286 
            }
287 
        } catch(Exception e){
288 
            logger.error("Error while getting the search results from the catalog service", e);
289 
        }
290 
        return itemList;
291 
    }
292 
 
293 
    @Override
294 
    public int getSearchResultCount(List<String> searchTerms){
295 
        int count = 0;
296 
        try {
297 
            CatalogClient catalogServiceClient = new CatalogClient();
5946 rajveer 298 
            Client catalogClient = catalogServiceClient.getClient();
3872 chandransh 299 
 
300 
            count = catalogClient.getSearchResultCount(searchTerms);
301 
        } catch(Exception e){
302 
            logger.error("Error while getting the search results from the catalog service", e);
303 
        }
304 
 
305 
        return count;
306 
    }
307 
 
1961 ankur.sing 308 
    public Item getItem(long itemId){
309 
        try{
3129 rajveer 310 
            CatalogClient catalogServiceClient = new CatalogClient();
5946 rajveer 311 
            Client catalogClient = catalogServiceClient.getClient();
312 
            InventoryClient inventoryServiceClient = new InventoryClient();
313 
            in.shop2020.model.v1.inventory.InventoryService.Client inventoryClient = inventoryServiceClient.getClient();
1961 ankur.sing 314 
            in.shop2020.model.v1.catalog.Item thriftItem = catalogClient.getItem(itemId);
5427 amit.gupta 315 
            Long catalogItemId = thriftItem.getCatalogItemId();
316 
            List<in.shop2020.model.v1.catalog.Item> thriftItems = catalogClient.getItemsByCatalogId(catalogItemId);
317 
            List <Long> sameItemsWithDifferentColors = new ArrayList<Long>();
318 
            if(thriftItems.size()>1){
319 
	            for(in.shop2020.model.v1.catalog.Item tItem : thriftItems ){
320 
	            	Long id = tItem.getId();
321 
		        	if(!id.equals(itemId)){
322 
		        		sameItemsWithDifferentColors.add(id);
323 
		        	}
324 
	            }
325 
            }
5946 rajveer 326 
            List<in.shop2020.model.v1.inventory.VendorItemPricing> vip = inventoryClient.getAllItemPricing(thriftItem.getId());
327 
            List<in.shop2020.model.v1.inventory.VendorItemMapping> vim = inventoryClient.getVendorItemMappings(thriftItem.getId());
3558 rajveer 328 
            List<in.shop2020.model.v1.catalog.SourceItemPricing> sip = catalogClient.getAllSourcePricing(thriftItem.getId());
4423 phani.kuma 329 
            List<in.shop2020.model.v1.catalog.Item> sit = catalogClient.getAllSimilarItems(thriftItem.getId());
5946 rajveer 330 
            in.shop2020.model.v1.inventory.ItemInventory itemInventory = inventoryClient.getItemInventoryByItemId(thriftItem.getId());
6813 amar.kumar 331 
            ItemStockPurchaseParams stockPurchaseParams = inventoryClient.getItemStockPurchaseParams(thriftItem.getId());
9835 rajveer 332 
            Map<Long, String> saleHistory = new HashMap<Long, String>();
333 
            List<OOSStatus> oosStatuses = inventoryClient.getOosStatusesForXDaysForItem(thriftItem.getId(), 0, 5);
334 
            String lastNdaySale = getOosString(oosStatuses);
335 
            saleHistory.put(0L,lastNdaySale);
336 
            List<OOSStatus> webOosStatuses = inventoryClient.getOosStatusesForXDaysForItem(thriftItem.getId(), 1, 5);
337 
            String webLastNdaySale = getOosString(webOosStatuses);
338 
            saleHistory.put(1L,webLastNdaySale);
339 
            List<OOSStatus> amzOosStatuses = inventoryClient.getOosStatusesForXDaysForItem(thriftItem.getId(), 3, 5);
340 
            String amzLastNdaySale = getOosString(amzOosStatuses);
341 
            saleHistory.put(3L,amzLastNdaySale);
342 
            List<OOSStatus> ebayOosStatuses = inventoryClient.getOosStatusesForXDaysForItem(thriftItem.getId(), 6, 5);
343 
            String ebayLastNdaySale = getOosString(ebayOosStatuses);
344 
            saleHistory.put(6L,ebayLastNdaySale);
345 
            List<OOSStatus> spdOosStatuses = inventoryClient.getOosStatusesForXDaysForItem(thriftItem.getId(), 7, 5);
346 
            String spdLastNdaySale = getOosString(spdOosStatuses);
347 
            saleHistory.put(7L,spdLastNdaySale);
348 
            List<OOSStatus> fktOosStatuses = inventoryClient.getOosStatusesForXDaysForItem(thriftItem.getId(), 8, 5);
349 
            String fktLastNdaySale = getOosString(fktOosStatuses);
350 
            saleHistory.put(8L,fktLastNdaySale);
9687 rajveer 351 
 
9835 rajveer 352 
 
7190 amar.kumar 353 
            Long freebieItemId = catalogClient.getFreebieForItem(thriftItem.getId());
5504 phani.kuma 354 
            List<in.shop2020.model.v1.catalog.VoucherItemMapping> tvouchers = catalogClient.getAllItemVouchers(thriftItem.getId());
9835 rajveer 355 
            Item it = getItemFromThriftItem(thriftItem, vip, vim, sip, sit, itemInventory, tvouchers, stockPurchaseParams, saleHistory, freebieItemId);
5427 amit.gupta 356 
            it.setSameItemsWithDifferentColors(sameItemsWithDifferentColors);
357 
            return it;
1961 ankur.sing 358 
        }catch(Exception e){
3354 chandransh 359 
            logger.error("Error while getting the item from the catalog service", e);
1961 ankur.sing 360 
        }
361 
        return null;
362 
    }
9835 rajveer 363 
 
364 
    private String getOosString(List<OOSStatus> oosStatuses){
365 
    	String lastNdaySale = "";
366 
        for(OOSStatus oosStatus : oosStatuses){
367 
        	if(oosStatus.isIs_oos()){
368 
        		lastNdaySale += "X-";
369 
        	}else{
370 
        		lastNdaySale += oosStatus.getNum_orders() + "-";
371 
        	}
372 
        }
373 
        lastNdaySale = lastNdaySale.substring(0, lastNdaySale.length()-1);
374 
        return lastNdaySale;
375 
    }
2359 ankur.sing 376 
 
1961 ankur.sing 377 
    @Override
1992 ankur.sing 378 
    public boolean updateItem(Item item) {
3354 chandransh 379 
        logger.info("Updating item with Id: " + item.getId());
1961 ankur.sing 380 
        try{
3129 rajveer 381 
            CatalogClient catalogServiceClient = new CatalogClient();
5946 rajveer 382 
            Client catalogClient = catalogServiceClient.getClient();
383 
            InventoryClient inventoryServiceClient = new InventoryClient();
384 
            in.shop2020.model.v1.inventory.InventoryService.Client inventoryClient = inventoryServiceClient.getClient();
385 
 
1992 ankur.sing 386 
            in.shop2020.model.v1.catalog.Item tItem = catalogClient.getItem(item.getId());
2126 ankur.sing 387 
            setThriftItemParams(tItem, item);
2359 ankur.sing 388 
 
2105 ankur.sing 389 
            long rItemId;
390 
            if((rItemId = catalogClient.updateItem(tItem)) != item.getId()) {
3354 chandransh 391 
                logger.error("Error updating item, returned Item Id: " + rItemId);
2105 ankur.sing 392 
                return false;
393 
            }
3354 chandransh 394 
            logger.info("Successfully updated item with id: " + item.getId());
2359 ankur.sing 395 
 
396 
            Map<String, VendorItemMapping> vendorMappings = item.getVendorKeysMap();
2119 ankur.sing 397 
            if(vendorMappings != null && !vendorMappings.isEmpty()) {
5946 rajveer 398 
                in.shop2020.model.v1.inventory.VendorItemMapping tVendorMapping;
2359 ankur.sing 399 
 
400 
                for(Entry<String, VendorItemMapping> e : vendorMappings.entrySet()) {
5946 rajveer 401 
                    tVendorMapping = new in.shop2020.model.v1.inventory.VendorItemMapping();
2359 ankur.sing 402 
                    VendorItemMapping v = e.getValue();
2119 ankur.sing 403 
                    tVendorMapping.setVendorId(v.getVendorId());
404 
                    tVendorMapping.setItemKey(v.getItemKey());
405 
                    tVendorMapping.setItemId(item.getId());
5946 rajveer 406 
                    inventoryClient.addVendorItemMapping(e.getKey().substring(e.getKey().indexOf(Item.KEY_SEPARATOR)+1), tVendorMapping);
3354 chandransh 407 
                    logger.info("Updates VendorItemMapping: " + tVendorMapping.toString());
2119 ankur.sing 408 
                }
409 
            }
2359 ankur.sing 410 
 
6813 amar.kumar 411 
            if(item.getMinStockLevel()!=0 || item.getNumOfDaysStock()!=0) {
412 
            	inventoryClient.updateItemStockPurchaseParams(item.getId(), item.getNumOfDaysStock(),
413 
            			item.getMinStockLevel());
414 
            }
415 
 
7239 amar.kumar 416 
            if(item.getFreebieItemId()!=null) {
7190 amar.kumar 417 
            	in.shop2020.model.v1.catalog.FreebieItem freebieItem = new in.shop2020.model.v1.catalog.FreebieItem();
418 
            	freebieItem.setItemId(item.getId());
419 
            	freebieItem.setFreebieItemId(item.getFreebieItemId());
420 
            	catalogClient.addOrUpdateFreebieForItem(freebieItem);
421 
            }
422 
 
2119 ankur.sing 423 
            Map<Long, VendorPricings> vendorPricings = item.getVendorPricesMap();
424 
            if(vendorPricings != null && !vendorPricings.isEmpty()) {
5946 rajveer 425 
                in.shop2020.model.v1.inventory.VendorItemPricing tVendorPricing;
2119 ankur.sing 426 
                for(VendorPricings v : vendorPricings.values()) {
5946 rajveer 427 
                    tVendorPricing = new in.shop2020.model.v1.inventory.VendorItemPricing();
2105 ankur.sing 428 
                    tVendorPricing.setVendorId(v.getVendorId());
429 
                    tVendorPricing.setItemId(item.getId());
430 
                    tVendorPricing.setMop(v.getMop());
431 
                    tVendorPricing.setTransferPrice(v.getTransferPrice());
432 
                    tVendorPricing.setDealerPrice(v.getDealerPrice());
6759 amar.kumar 433 
                    tVendorPricing.setNlc(v.getNlc());
5946 rajveer 434 
                    inventoryClient.addVendorItemPricing(tVendorPricing);
3354 chandransh 435 
                    logger.info("Updated VendorItemPricing: " + tVendorPricing.toString());
2105 ankur.sing 436 
                }
437 
            }
3558 rajveer 438 
 
439 
            Map<Long, SourcePricings> sourcePricings = item.getSourcePricesMap();
440 
            if(sourcePricings != null && !sourcePricings.isEmpty()) {
441 
                in.shop2020.model.v1.catalog.SourceItemPricing tSourcePricings;
442 
                for(SourcePricings s : sourcePricings.values()) {
443 
                	tSourcePricings = new in.shop2020.model.v1.catalog.SourceItemPricing();
444 
                	tSourcePricings.setSourceId(s.getSourceId());
445 
                    tSourcePricings.setItemId(item.getId());
446 
                    tSourcePricings.setMrp(s.getMrp());
447 
                    tSourcePricings.setSellingPrice(s.getSellingPrice());
448 
                    catalogClient.addSourceItemPricing(tSourcePricings);
449 
                    logger.info("Updated SourceItemPricing: " + tSourcePricings.toString());
450 
                }
451 
            }
452 
 
2105 ankur.sing 453 
        }catch(Exception e){
3354 chandransh 454 
            logger.error("Error while updating item: ", e);
2427 ankur.sing 455 
            return false;
2105 ankur.sing 456 
        }
457 
        return true;
1961 ankur.sing 458 
    }
2359 ankur.sing 459 
 
6530 vikram.rag 460 
    @Override
461 
    public List<Long> getMonitoredWarehouseIdsForVendors(List<Long> vendorIds){
462 
    	List<Long> monitoredWarehouseids=null;
463 
    	 try {
464 
			InventoryClient inventoryServiceClient = new InventoryClient();
465 
			 in.shop2020.model.v1.inventory.InventoryService.Client inventoryClient = inventoryServiceClient.getClient();
466 
			 monitoredWarehouseids = inventoryClient.getMonitoredWarehouseForVendors(vendorIds);
467 
		} catch (Exception e) {
468 
			logger.error("Error while getting Monitored warehouse for vendor: ", e);
469 
		}
470 
		return monitoredWarehouseids;
471 
 
472 
    }
473 
 
474 
    @Override
475 
    public List<ItemWarehouse> getignoredInventoryUpdateItemsIdsWarehouseIds(){
476 
		List<ItemWarehouse> ignoredItemIdwarehouseIdList = new ArrayList<ItemWarehouse>();
477 
    	try {
2359 ankur.sing 478 
 
6530 vikram.rag 479 
			InventoryClient inventoryServiceClient = new InventoryClient();
480 
			in.shop2020.model.v1.inventory.InventoryService.Client inventoryClient = inventoryServiceClient.getClient();
481 
			List<IgnoredInventoryUpdateItems> ignoredInventoryUpdateItems = inventoryClient.getIgnoredWarehouseidsAndItemids();
482 
			for(IgnoredInventoryUpdateItems ignoredInventoryUpdateItem:ignoredInventoryUpdateItems){
483 
				ignoredItemIdwarehouseIdList.add(new ItemWarehouse(ignoredInventoryUpdateItem.getItemId(),ignoredInventoryUpdateItem.getWarehouseId()));
484 
			}
485 
 
486 
 
487 
		} catch (Exception e) {
488 
			logger.error("Error while getting Monitored warehouseid and itemid : ", e);
489 
		}
490 
		return ignoredItemIdwarehouseIdList;
491 
 
492 
    }
2066 ankur.sing 493 
    @Override
494 
    public Map<Long, String> getAllVendors() {
495 
        Map<Long, String> vendorMap = new HashMap<Long, String>();
496 
        try {
5946 rajveer 497 
            InventoryClient inventoryServiceClient = new InventoryClient();
498 
            in.shop2020.model.v1.inventory.InventoryService.Client inventoryClient = inventoryServiceClient.getClient();
499 
 
500 
            List<in.shop2020.model.v1.inventory.Vendor> vendors = inventoryClient.getAllVendors();
2359 ankur.sing 501 
 
5946 rajveer 502 
            for(in.shop2020.model.v1.inventory.Vendor v : vendors) {
2066 ankur.sing 503 
                vendorMap.put(v.getId(), v.getName());
504 
            }
505 
        } catch (Exception e) {
3354 chandransh 506 
            logger.error("Error while getting all the vendors: ", e);
2066 ankur.sing 507 
        }
508 
        return vendorMap;
509 
    }
510 
 
511 
    @Override
3558 rajveer 512 
    public Map<Long, String> getAllSources() {
513 
        Map<Long, String> sourceMap = new HashMap<Long, String>();
514 
        try {
515 
            CatalogClient catalogServiceClient = new CatalogClient();
5946 rajveer 516 
            Client catalogClient = catalogServiceClient.getClient();
3558 rajveer 517 
 
518 
            List<in.shop2020.model.v1.catalog.Source> sources = catalogClient.getAllSources();
519 
 
520 
            for(in.shop2020.model.v1.catalog.Source s : sources) {
521 
            	sourceMap.put(s.getId(), s.getName());
522 
            }
523 
        } catch (Exception e) {
524 
            logger.error("Error while getting all the vendors: ", e);
525 
        }
526 
        return sourceMap;
527 
    }
528 
 
529 
    @Override
5118 mandeep.dh 530 
    public Map<Long, String> getShippingWarehouses() {
531 
        Map<Long, String> warehouseMap = new HashMap<Long, String>();
532 
        Set<Long> shippingLocations = new HashSet<Long>();
533 
        try {
5946 rajveer 534 
            InventoryClient inventoryServiceClient = new InventoryClient();
535 
            in.shop2020.model.v1.inventory.InventoryService.Client inventoryClient = inventoryServiceClient.getClient();
536 
 
537 
            List<in.shop2020.model.v1.inventory.Warehouse> warehouses = inventoryClient.getAllWarehouses(true);
5118 mandeep.dh 538 
 
5946 rajveer 539 
            for(in.shop2020.model.v1.inventory.Warehouse warehouse : warehouses) {
5118 mandeep.dh 540 
                shippingLocations.add(warehouse.getShippingWarehouseId());
541 
            }
542 
 
5946 rajveer 543 
            for(in.shop2020.model.v1.inventory.Warehouse warehouse : warehouses) {
5118 mandeep.dh 544 
                if (shippingLocations.contains(warehouse.getId())) {
545 
                    warehouseMap.put(warehouse.getId(), warehouse.getDisplayName());
546 
                }
547 
            }
548 
        } catch (Exception e) {
549 
            logger.error("Error while getting all the warehouses:", e );
550 
        }
551 
        return warehouseMap;
552 
    }
553 
 
554 
    @Override
2066 ankur.sing 555 
    public Map<Long, String> getAllWarehouses() {
556 
        Map<Long, String> warehouseMap = new HashMap<Long, String>();
557 
        try {
5946 rajveer 558 
        	InventoryClient inventoryServiceClient = new InventoryClient();
559 
            in.shop2020.model.v1.inventory.InventoryService.Client inventoryClient = inventoryServiceClient.getClient();
2359 ankur.sing 560 
 
5946 rajveer 561 
            List<in.shop2020.model.v1.inventory.Warehouse> warehouses = inventoryClient.getAllWarehouses(true);
2359 ankur.sing 562 
 
5946 rajveer 563 
            for(in.shop2020.model.v1.inventory.Warehouse w : warehouses) {
2066 ankur.sing 564 
                warehouseMap.put(w.getId(), w.getDisplayName());
565 
            }
566 
        } catch (Exception e) {
3354 chandransh 567 
            logger.error("Error while getting all the warehouses:", e );
2066 ankur.sing 568 
        }
569 
        return warehouseMap;
570 
    }
2105 ankur.sing 571 
 
572 
    @Override
573 
    public long addItem(Item item) {
574 
        long itemId = 0;
575 
        try {
3129 rajveer 576 
            CatalogClient catalogServiceClient = new CatalogClient();
5946 rajveer 577 
            Client catalogClient = catalogServiceClient.getClient();
578 
            InventoryClient inventoryServiceClient = new InventoryClient();
579 
            in.shop2020.model.v1.inventory.InventoryService.Client inventoryClient = inventoryServiceClient.getClient();
2126 ankur.sing 580 
 
2105 ankur.sing 581 
            in.shop2020.model.v1.catalog.Item tItem = new in.shop2020.model.v1.catalog.Item();
2126 ankur.sing 582 
            setThriftItemParams(tItem, item);
2105 ankur.sing 583 
            itemId = catalogClient.addItem(tItem);
584 
 
2119 ankur.sing 585 
            Map<Long, VendorPricings> vendorPricings = item.getVendorPricesMap();
586 
            if(vendorPricings != null && !vendorPricings.isEmpty()) {
5946 rajveer 587 
                in.shop2020.model.v1.inventory.VendorItemPricing tVendorPricing;
2119 ankur.sing 588 
                for(VendorPricings v : vendorPricings.values()) {
5946 rajveer 589 
                    tVendorPricing = new in.shop2020.model.v1.inventory.VendorItemPricing();
2119 ankur.sing 590 
                    tVendorPricing.setVendorId(v.getVendorId());
591 
                    tVendorPricing.setItemId(itemId);
592 
                    tVendorPricing.setMop(v.getMop());
593 
                    tVendorPricing.setTransferPrice(v.getTransferPrice());
6759 amar.kumar 594 
                    tVendorPricing.setNlc(v.getNlc());
2119 ankur.sing 595 
                    tVendorPricing.setDealerPrice(v.getDealerPrice());
5946 rajveer 596 
                    inventoryClient.addVendorItemPricing(tVendorPricing);
2119 ankur.sing 597 
                }
598 
            }
2359 ankur.sing 599 
 
600 
            Map<String, VendorItemMapping> vendorKeysMap = item.getVendorKeysMap();
2119 ankur.sing 601 
            if(vendorKeysMap != null && !vendorKeysMap.isEmpty()) {
5946 rajveer 602 
                in.shop2020.model.v1.inventory.VendorItemMapping tVendorMapping;
2359 ankur.sing 603 
                for(Entry<String, VendorItemMapping> e : vendorKeysMap.entrySet()) {
5946 rajveer 604 
                    tVendorMapping = new in.shop2020.model.v1.inventory.VendorItemMapping();
2359 ankur.sing 605 
                    VendorItemMapping v = e.getValue();
2105 ankur.sing 606 
                    tVendorMapping.setVendorId(v.getVendorId());
607 
                    tVendorMapping.setItemKey(v.getItemKey());
608 
                    tVendorMapping.setItemId(itemId);
5946 rajveer 609 
                    inventoryClient.addVendorItemMapping(e.getKey().substring(e.getKey().indexOf(Item.KEY_SEPARATOR)+1), tVendorMapping);
2105 ankur.sing 610 
                }
611 
            }
6813 amar.kumar 612 
 
613 
        	inventoryClient.updateItemStockPurchaseParams(itemId, item.getNumOfDaysStock(),
614 
        			item.getMinStockLevel());
7190 amar.kumar 615 
 
616 
        	if(item.getFreebieItemId()!=null && item.getFreebieItemId()!=0) {
617 
        		in.shop2020.model.v1.catalog.FreebieItem freebieItem =
618 
        			new in.shop2020.model.v1.catalog.FreebieItem();
619 
        		freebieItem.setItemId(itemId);
620 
        		freebieItem.setFreebieItemId(item.getFreebieItemId());
621 
        		catalogClient.addOrUpdateFreebieForItem(freebieItem);
622 
        	}
623 
 
2105 ankur.sing 624 
        } catch (Exception e) {
3354 chandransh 625 
            logger.error("Error while adding an item: ", e);
2105 ankur.sing 626 
        }
627 
        return itemId;
628 
    }
2119 ankur.sing 629 
 
630 
    @Override
4725 phani.kuma 631 
    public long checkSimilarItem(String brand, String modelNumber, String modelName, String color) {
2359 ankur.sing 632 
 
2119 ankur.sing 633 
        try {
3129 rajveer 634 
            CatalogClient catalogServiceClient = new CatalogClient();
5946 rajveer 635 
            Client catalogClient = catalogServiceClient.getClient();
4725 phani.kuma 636 
            return catalogClient.checkSimilarItem(brand, modelNumber, modelName, color);
2119 ankur.sing 637 
        } catch (Exception e) {
3354 chandransh 638 
            logger.error("Error while checking for a similar item: ", e);
2119 ankur.sing 639 
        }
640 
        return 0;
641 
    }
2359 ankur.sing 642 
 
2126 ankur.sing 643 
    private void setThriftItemParams(in.shop2020.model.v1.catalog.Item tItem, Item item) {
644 
        tItem.setId(tItem.getId());
645 
        tItem.setProductGroup(item.getProductGroup());
646 
        tItem.setBrand(item.getBrand());
647 
        tItem.setModelName(item.getModelName());
648 
        tItem.setModelNumber(item.getModelNumber());
649 
        tItem.setColor(item.getColor());
6241 amit.gupta 650 
        tItem.setShowSellingPrice(item.isShowSellingPrice());
2359 ankur.sing 651 
        tItem.setStatus_description(item.getItemStatusDesc());
2126 ankur.sing 652 
        tItem.setComments(item.getComments());
2359 ankur.sing 653 
 
2489 ankur.sing 654 
        if(item.getMrp() != null) {
2126 ankur.sing 655 
            tItem.setMrp(item.getMrp());
656 
        }
3354 chandransh 657 
 
5586 phani.kuma 658 
        if(item.getCatalogItemId() != null) {
659 
            tItem.setCatalogItemId(item.getCatalogItemId());
660 
        }
661 
 
2489 ankur.sing 662 
        if(item.getSellingPrice() != null) {
2126 ankur.sing 663 
            tItem.setSellingPrice(item.getSellingPrice());
664 
        }
3354 chandransh 665 
 
2489 ankur.sing 666 
        if(item.getWeight() != null) {
2126 ankur.sing 667 
            tItem.setWeight(item.getWeight());
668 
        }
3354 chandransh 669 
 
3359 chandransh 670 
        if(item.getExpectedDelay() != null) {
671 
            tItem.setExpectedDelay(item.getExpectedDelay());
2489 ankur.sing 672 
        }
3354 chandransh 673 
 
4413 anupam.sin 674 
        tItem.setIsWarehousePreferenceSticky(item.isWarehouseStickiness());
675 
 
4506 phani.kuma 676 
        if(item.getPreferredVendor() != null) {
677 
            tItem.setPreferredVendor(item.getPreferredVendor());
678 
        }
6838 vikram.rag 679 
        tItem.setPreferredInsurer(item.getPreferredInsurer());
7291 vikram.rag 680 
 
681 
        if(item.getAsin() != null) {
682 
            tItem.setAsin(item.getAsin());
683 
        }
7305 amit.gupta 684 
        if(item.getHoldInventory()!= null) {
685 
        	tItem.setHoldInventory(item.getHoldInventory());
686 
        }
687 
        else{
688 
        	tItem.setHoldInventory(0);
689 
        }
690 
        if(item.getDefaultInventory()!=null){
691 
        	tItem.setDefaultInventory(item.getDefaultInventory());
692 
        }
693 
        else{
694 
        	tItem.setDefaultInventory(0);
695 
        }
2126 ankur.sing 696 
        tItem.setBestDealText(item.getBestDealsText());
6777 vikram.rag 697 
        tItem.setBestDealsDetailsText(item.getBestDealsDetailsText());
698 
        tItem.setBestDealsDetailsLink(item.getBestDealsDetailsLink());
2489 ankur.sing 699 
        if(item.getBestDealsValue() != null) {
2126 ankur.sing 700 
            tItem.setBestDealValue(item.getBestDealsValue());
701 
        }
3354 chandransh 702 
 
2489 ankur.sing 703 
        if(item.getBestSellingRank() != null) {
2126 ankur.sing 704 
            tItem.setBestSellingRank(item.getBestSellingRank());
705 
        }
3354 chandransh 706 
 
2126 ankur.sing 707 
        tItem.setDefaultForEntity(item.isDefaultForEntity());
2252 ankur.sing 708 
        tItem.setRisky(item.isRisky());
5384 phani.kuma 709 
        tItem.setHasItemNo(item.isHasItemNo());
710 
 
711 
        if(item.isItemType()) {
712 
        	tItem.setType(ItemType.SERIALIZED);
713 
        }
714 
        else {
715 
        	tItem.setType(ItemType.NON_SERIALIZED);
716 
        }
717 
 
2489 ankur.sing 718 
        if(item.getStartDate() != null) {
719 
            tItem.setStartDate(item.getStartDate());
720 
        }
3354 chandransh 721 
 
5217 amit.gupta 722 
        if(item.getExpectedArrivalDate() != null) {
723 
        	tItem.setExpectedArrivalDate(item.getExpectedArrivalDate());
724 
        } else {
725 
        	tItem.unsetComingSoonStartDate();
726 
        	tItem.unsetExpectedArrivalDate();
727 
        	if(status.COMING_SOON.equals(tItem.getItemStatus())){
6277 amit.gupta 728 
        		tItem.setItemStatus(status.CONTENT_COMPLETE);
729 
        		tItem.setStatus_description("Content generation completed");
5217 amit.gupta 730 
        	}
731 
        }
732 
 
733 
        if(item.getComingSoonStartDate() != null) {
734 
        	tItem.setComingSoonStartDate(item.getComingSoonStartDate());
735 
        } else {
736 
        	tItem.unsetComingSoonStartDate();
737 
        }
738 
 
2489 ankur.sing 739 
        if(item.getRetireDate() != null) {
740 
            tItem.setRetireDate(item.getRetireDate());
741 
        }
3354 chandransh 742 
 
2126 ankur.sing 743 
        tItem.setUpdatedOn(Calendar.getInstance().getTimeInMillis());
744 
    }
745 
 
746 
    @Override
747 
    public void pauseItem(long itemId) {
748 
        try {
3129 rajveer 749 
            CatalogClient catalogServiceClient = new CatalogClient();
5946 rajveer 750 
            Client catalogClient = catalogServiceClient.getClient();
2359 ankur.sing 751 
 
2126 ankur.sing 752 
            catalogClient.changeItemStatus(itemId, Calendar.getInstance().getTimeInMillis(), status.PAUSED);
753 
        } catch (Exception e) {
3354 chandransh 754 
            logger.error("Error while pausing the item: " + itemId, e);
2126 ankur.sing 755 
        }
2359 ankur.sing 756 
 
2126 ankur.sing 757 
    }
758 
 
759 
    @Override
760 
    public void markInProcess(long itemId) {
761 
        try {
3129 rajveer 762 
            CatalogClient catalogServiceClient = new CatalogClient();
5946 rajveer 763 
            Client catalogClient = catalogServiceClient.getClient();
2359 ankur.sing 764 
 
2126 ankur.sing 765 
            catalogClient.changeItemStatus(itemId, Calendar.getInstance().getTimeInMillis(), status.IN_PROCESS);
766 
        } catch (Exception e) {
3354 chandransh 767 
            logger.error("Error while marking in-process the item: " + itemId, e);
2126 ankur.sing 768 
        }
769 
    }
2359 ankur.sing 770 
 
2126 ankur.sing 771 
    @Override
772 
    public void phaseoutItem(long itemId) {
773 
        try {
3129 rajveer 774 
            CatalogClient catalogServiceClient = new CatalogClient();
5946 rajveer 775 
            Client catalogClient = catalogServiceClient.getClient();
2359 ankur.sing 776 
 
2126 ankur.sing 777 
            catalogClient.changeItemStatus(itemId, Calendar.getInstance().getTimeInMillis(), status.PHASED_OUT);
778 
        } catch (Exception e) {
3354 chandransh 779 
            logger.error("Error while phasing out the item: " + itemId, e);
2126 ankur.sing 780 
        }
781 
    }
2359 ankur.sing 782 
 
2126 ankur.sing 783 
    @Override
784 
    public void activateItem(long itemId) {
785 
        try {
3129 rajveer 786 
            CatalogClient catalogServiceClient = new CatalogClient();
5946 rajveer 787 
            Client catalogClient = catalogServiceClient.getClient();
2359 ankur.sing 788 
 
2126 ankur.sing 789 
            catalogClient.changeItemStatus(itemId, Calendar.getInstance().getTimeInMillis(), status.ACTIVE);
790 
        } catch (Exception e) {
3354 chandransh 791 
            logger.error("Error while activating the item: " + itemId, e);
2126 ankur.sing 792 
        }
793 
    }
2359 ankur.sing 794 
 
795 
    @Override
796 
    public boolean changeItemRiskyFlag(long itemId, boolean risky) {
797 
        try {
4354 mandeep.dh 798 
            logger.info("Updating risky flag for item id: " + itemId + " to " + risky);
2359 ankur.sing 799 
            // Initialize client for staging server
3129 rajveer 800 
            CatalogClient catalogServiceClient = new CatalogClient();
5946 rajveer 801 
            Client catalogClient = catalogServiceClient.getClient();
2359 ankur.sing 802 
 
803 
            // Initialize client for production server
3165 chandransh 804 
            CatalogClient catalogServiceClient_Prod = new CatalogClient(ConfigClientKeys.catalog_service_server_host_prod.toString(),
2359 ankur.sing 805 
                    ConfigClientKeys.catalog_service_server_port.toString());
5946 rajveer 806 
            Client catalogClient_Prod = catalogServiceClient_Prod.getClient();
2359 ankur.sing 807 
            catalogClient.changeItemRiskyFlag(itemId, risky);
808 
 
809 
            try{
810 
                catalogClient_Prod.changeItemRiskyFlag(itemId, risky);
811 
            }catch(Exception e){
3354 chandransh 812 
                logger.error("Error while updating item's risky flag on production", e);
2359 ankur.sing 813 
                // If not able to change risky flag on production, revert on staging and return false (to show error to user).
814 
                catalogClient.changeItemRiskyFlag(itemId, !risky);
815 
                return false;
816 
            }
817 
        } catch (Exception e) {
3354 chandransh 818 
            logger.error("Error while updating item's risky flag on staging", e);
2359 ankur.sing 819 
            return false;
820 
        }
821 
        return true;
822 
    }
823 
 
2427 ankur.sing 824 
 
825 
    /**
4762 phani.kuma 826 
     * Retuns list of Items filtered by category (column is product_group in catalog.item table)
2427 ankur.sing 827 
     * This list is used to generate master sheet (excel sheet)
828 
     * @param category
4957 phani.kuma 829 
     * @param brand
2427 ankur.sing 830 
     * @return
831 
     */
4957 phani.kuma 832 
    public List<Item> getItemsForMasterSheet(String category, String brand) {
2359 ankur.sing 833 
        List<Item> itemList = new ArrayList<Item>();
834 
        try {
3129 rajveer 835 
            CatalogClient catalogServiceClient = new CatalogClient();
5946 rajveer 836 
            Client catalogClient = catalogServiceClient.getClient();
837 
            InventoryClient inventoryServiceClient = new InventoryClient();
838 
            in.shop2020.model.v1.inventory.InventoryService.Client inventoryClient = inventoryServiceClient.getClient();
2359 ankur.sing 839 
 
4957 phani.kuma 840 
            List<in.shop2020.model.v1.catalog.Item> thriftItems = catalogClient.getItemsForMasterSheet(category, brand);
2359 ankur.sing 841 
 
842 
            for(in.shop2020.model.v1.catalog.Item thriftItem : thriftItems) {
5946 rajveer 843 
                List<in.shop2020.model.v1.inventory.VendorItemPricing> vip = inventoryClient.getAllItemPricing(thriftItem.getId());
844 
                List<in.shop2020.model.v1.inventory.VendorItemMapping> vim = inventoryClient.getVendorItemMappings(thriftItem.getId());
3558 rajveer 845 
                List<in.shop2020.model.v1.catalog.SourceItemPricing> sip = catalogClient.getAllSourcePricing(thriftItem.getId());
9836 rajveer 846 
                itemList.add(getItemFromThriftItem(thriftItem, vip, vim, sip, null, null, null, null, null, null));
2359 ankur.sing 847 
            }
848 
        } catch (Exception e) {
4762 phani.kuma 849 
            logger.error("Error while getting items by category: " + category, e);
2359 ankur.sing 850 
        }
851 
        Collections.sort(itemList, new ItemsComparator());
852 
        return itemList;
853 
    }
854 
 
855 
    @Override
2427 ankur.sing 856 
    public String updateItemOnProduction(Item item) {
5706 amit.gupta 857 
    	if(!canPushToProduction()) {
858 
    		// If we can't push to production, then return that message to user
859 
    		// else move forward with update.
860 
    		return "Maximum push to production count reached for today";
861 
    	}
862 
    	List<Long> itemIds = item.getSameItemsWithDifferentColors();
863 
    	List<Item> items = new ArrayList<Item>();
864 
    	items.add(item);
865 
    	for(Long itemId : itemIds) {
866 
    		try {
867 
    			CatalogClient catalogServiceClient = new CatalogClient();
5946 rajveer 868 
    			Client catalogClient = catalogServiceClient.getClient();
869 
    			InventoryClient inventoryServiceClient = new InventoryClient();
870 
                in.shop2020.model.v1.inventory.InventoryService.Client inventoryClient = inventoryServiceClient.getClient();
871 
 
5706 amit.gupta 872 
    			in.shop2020.model.v1.catalog.Item thriftItem = catalogClient.getItem(itemId);
5946 rajveer 873 
				List<in.shop2020.model.v1.inventory.VendorItemPricing> vip = inventoryClient.getAllItemPricing(thriftItem.getId());
874 
				List<in.shop2020.model.v1.inventory.VendorItemMapping> vim = inventoryClient.getVendorItemMappings(thriftItem.getId());
5706 amit.gupta 875 
				List<in.shop2020.model.v1.catalog.SourceItemPricing> sip = catalogClient.getAllSourcePricing(thriftItem.getId());
9836 rajveer 876 
				items.add(getItemFromThriftItem(thriftItem, vip, vim, sip, null, null, null, null, null, null));
5706 amit.gupta 877 
    		} catch (Exception e) {
878 
    			logger.error("Could not fetch item for : " + itemId, e);
879 
    			return "Could not push to production. No item got pushed.";
880 
    		}
881 
    	}
882 
    	for (Item it : items) {
883 
	        logger.info("Update item on production call, Item Id: " + it.getId());
884 
 
885 
	        try{
886 
	            CatalogClient catalogServiceClient_Prod = new CatalogClient(
887 
	                    ConfigClientKeys.catalog_service_server_host_prod.toString(),
888 
	                    ConfigClientKeys.catalog_service_server_port.toString());
889 
 
5946 rajveer 890 
	            Client catalogClient_Prod = catalogServiceClient_Prod.getClient();
5706 amit.gupta 891 
 
892 
	            in.shop2020.model.v1.catalog.Item tItem = catalogClient_Prod.getItem(it.getId());
893 
 
5946 rajveer 894 
	            InventoryClient inventoryServiceClient = new InventoryClient();
895 
	            in.shop2020.model.v1.inventory.InventoryService.Client inventoryClient = inventoryServiceClient.getClient();
896 
 
5706 amit.gupta 897 
	            if(it.getMrp() != null) {
898 
	                tItem.setMrp(it.getMrp());
899 
	            }
900 
 
901 
	            if(it.getSellingPrice() != null) {
902 
	                tItem.setSellingPrice(it.getSellingPrice());
903 
	            }
904 
 
7700 amit.gupta 905 
                tItem.setBestDealText(it.getBestDealsText());
7198 amar.kumar 906 
 
6826 amit.gupta 907 
	            if (it.getItemStatusValue()  == ItemStatus.ACTIVE.getValue() || it.getItemStatusValue()  == ItemStatus.PAUSED.getValue()) {
908 
	            	tItem.setItemStatus(status.findByValue(it.getItemStatusValue()));
909 
	            	tItem.setStartDate(it.getStartDate());
910 
	            }
5706 amit.gupta 911 
	            long rItemId;
912 
	            if((rItemId = catalogClient_Prod.updateItem(tItem)) != it.getId()) {
913 
	                logger.error("Error updating item on production, returned Item Id: " + rItemId);
914 
	                return "Error updating item prices on production";
915 
	            }
7198 amar.kumar 916 
	            if(it.getFreebieItemId() !=null && it.getFreebieItemId()!=0) {
917 
	            	in.shop2020.model.v1.catalog.FreebieItem freebieItem = new in.shop2020.model.v1.catalog.FreebieItem();
918 
	            	freebieItem.setItemId(it.getId());
919 
	            	freebieItem.setFreebieItemId(it.getFreebieItemId());
920 
	            	catalogClient_Prod.addOrUpdateFreebieForItem(freebieItem);
921 
	            }
5706 amit.gupta 922 
	            logger.info("Successfully updated item: " + it.getId());
923 
 
924 
	            StringBuilder sb = new StringBuilder();
925 
 
926 
	            Map<Long, VendorPricings> vendorPricings = it.getVendorPricesMap();
927 
	            if(vendorPricings != null && !vendorPricings.isEmpty()) {
5946 rajveer 928 
	                in.shop2020.model.v1.inventory.VendorItemPricing tVendorPricing;
5706 amit.gupta 929 
	                for(VendorPricings v : vendorPricings.values()) {
5946 rajveer 930 
	                    tVendorPricing = new in.shop2020.model.v1.inventory.VendorItemPricing();
5706 amit.gupta 931 
	                    tVendorPricing.setVendorId(v.getVendorId());
932 
	                    tVendorPricing.setItemId(it.getId());
933 
	                    tVendorPricing.setMop(v.getMop());
934 
	                    tVendorPricing.setTransferPrice(v.getTransferPrice());
6759 amar.kumar 935 
	                    tVendorPricing.setNlc(v.getNlc());
5706 amit.gupta 936 
	                    tVendorPricing.setDealerPrice(v.getDealerPrice());
5946 rajveer 937 
	                    inventoryClient.addVendorItemPricing(tVendorPricing);
5706 amit.gupta 938 
	                    logger.info("VendorItemPricing updated. " + tVendorPricing.toString());
6759 amar.kumar 939 
	                    sb.append("[VId:" + v.getVendorId() + ",MOP=" + v.getMop() + ",TP=" + v.getTransferPrice() + ",NLC= " +v.getNlc() + ",DP=" + v.getDealerPrice() + "], ");
5706 amit.gupta 940 
	                }
941 
	            }
942 
 
943 
	            Map<String, VendorItemMapping> vendorMappings = it.getVendorKeysMap();
944 
	            if(vendorMappings != null && !vendorMappings.isEmpty()) {
5946 rajveer 945 
	                in.shop2020.model.v1.inventory.VendorItemMapping tVendorMapping;
5706 amit.gupta 946 
	                for(VendorItemMapping vendorItemMapping : vendorMappings.values()) {
5946 rajveer 947 
	                    tVendorMapping = new in.shop2020.model.v1.inventory.VendorItemMapping();
5706 amit.gupta 948 
	                    tVendorMapping.setVendorId(vendorItemMapping.getVendorId());
949 
	                    tVendorMapping.setItemId(it.getId());
950 
	                    tVendorMapping.setItemKey(vendorItemMapping.getItemKey());
5946 rajveer 951 
	                    inventoryClient.addVendorItemMapping(vendorItemMapping.getItemKey(), tVendorMapping);
5706 amit.gupta 952 
	                    logger.info("VendorItemMapping updated. " + tVendorMapping.toString());
953 
	                    sb.append("[VId:" + vendorItemMapping.getVendorId() + ",ItemKey=" + vendorItemMapping.getItemKey() + "], ");
954 
	                }
955 
	            }
956 
 
957 
	            Map<Long, SourcePricings> sourcePricings = it.getSourcePricesMap();
958 
	            if(sourcePricings != null && !sourcePricings.isEmpty()){
959 
	                in.shop2020.model.v1.catalog.SourceItemPricing tSourcePricing;
960 
	                for(SourcePricings s : sourcePricings.values()){
961 
	                    tSourcePricing = new in.shop2020.model.v1.catalog.SourceItemPricing();
962 
	                    tSourcePricing.setSourceId(s.getSourceId());
963 
	                    tSourcePricing.setItemId(it.getId());
964 
	                    tSourcePricing.setMrp(s.getMrp());
965 
	                    tSourcePricing.setSellingPrice(s.getSellingPrice());
966 
	                    catalogClient_Prod.addSourceItemPricing(tSourcePricing);
967 
	                    logger.info("SourceItemPricing updated. " + tSourcePricing.toString());
968 
	                    sb.append("[SId:" + s.getSourceId() + ",MRP=" + s.getMrp() + ",SP=" + s.getSellingPrice() + "], ");
969 
	                }
970 
	            }
971 
 
972 
	            pushToProdLogger.info("Id=" + it.getId() + ",MRP=" + it.getMrp() + ",SP=" + " " + it.getSellingPrice() + sb.toString());
973 
	        } catch (Exception e) {
974 
	            logger.error("Error while updating prices on production", e);
975 
	            return "Error while updating all prices on production. Some of the prices may not have been  updated";
976 
	        }
977 
    	}
2427 ankur.sing 978 
 
3907 chandransh 979 
        try {
980 
            ContentClient contentServiceClient = new ContentClient();
981 
            ContentService.Client contentClient = contentServiceClient.getClient();
982 
 
5706 amit.gupta 983 
            contentClient.pushContentToProduction(items.get(0).getCatalogItemId());
3907 chandransh 984 
        } catch (TTransportException e) {
985 
            logger.error("Error while establishing connection to the content server", e);
986 
            return "Error generating content. Prices updated successfully.";
987 
        } catch (TException e) {
988 
            logger.error("Error while pushing content to production", e);
989 
            return "Error generating content. Prices updated successfully.";
990 
        } catch (ContentServiceException e) {
991 
            logger.error("Error while pushing content to production", e);
992 
            return "Error generating content. Prices updated successfully.";
993 
        }
994 
 
2427 ankur.sing 995 
        return "Prices updated and content generated successfully";
2359 ankur.sing 996 
    }
2427 ankur.sing 997 
 
2489 ankur.sing 998 
    /**
3354 chandransh 999 
     * Returns list of items with a particular status.
1000 
     * @param st
1001 
     * @return
1002 
     */
3850 chandransh 1003 
    private List<Item> getItemsByStatus(status st, int start, int limit) {
3354 chandransh 1004 
        List<Item> itemList = new ArrayList<Item>();
1005 
        try {
1006 
            CatalogClient catalogServiceClient = new CatalogClient();
5946 rajveer 1007 
            Client catalogClient = catalogServiceClient.getClient();
3354 chandransh 1008 
 
3850 chandransh 1009 
            List<in.shop2020.model.v1.catalog.Item> thriftItems = catalogClient.getAllItemsByStatusInRange(st, start, limit);
3354 chandransh 1010 
 
1011 
            for(in.shop2020.model.v1.catalog.Item thriftItem : thriftItems) {
9835 rajveer 1012 
                itemList.add(getItemFromThriftItem(thriftItem, null, null, null, null, null, null, null, null, null));
3354 chandransh 1013 
            }
1014 
        } catch (Exception e) {
1015 
            logger.error("Error while getting items by status: " + st, e);
1016 
        }
1017 
        return itemList;
1018 
    }
1019 
 
1020 
    /**
1021 
     * Creates a new Item object and populates its attributes from thrift item passed as parameter.
4423 phani.kuma 1022 
     * Also creates a Map each for VendorItemPricing, VendorItemMapping, SourceItemPricing and SimilarItems and adds these maps to the
3354 chandransh 1023 
     * new Item object.
1024 
     * @param thriftItem
1025 
     * @param tVendorPricings
1026 
     * @param tVendorMappings
4423 phani.kuma 1027 
     * @param tSourceMappings
1028 
     * @param tSimilarItems
5504 phani.kuma 1029 
     * @param tVoucherMappings
6813 amar.kumar 1030 
     * @param stockPurchaseParams
3354 chandransh 1031 
     * @return item object with attributes copied from thrift item object.
1032 
     */
1033 
    private Item getItemFromThriftItem(in.shop2020.model.v1.catalog.Item thriftItem,
5946 rajveer 1034 
            List<in.shop2020.model.v1.inventory.VendorItemPricing> tVendorPricings,
1035 
            List<in.shop2020.model.v1.inventory.VendorItemMapping> tVendorMappings,
4423 phani.kuma 1036 
            List<in.shop2020.model.v1.catalog.SourceItemPricing> tSourceMappings,
6813 amar.kumar 1037 
            List<in.shop2020.model.v1.catalog.Item> tSimilarItems,
1038 
            in.shop2020.model.v1.inventory.ItemInventory tItemInventory,
1039 
            List<in.shop2020.model.v1.catalog.VoucherItemMapping> tVoucherMappings,
9835 rajveer 1040 
            ItemStockPurchaseParams tStockPurchaseParams, Map<Long,String> saleHistory, Long freebieItemId){
3354 chandransh 1041 
 
1042 
        Map<String, VendorItemMapping> vItemMap = new HashMap<String, VendorItemMapping>();
1043 
        VendorItemMapping vItemMapping;
1044 
        if(tVendorMappings != null) {
5946 rajveer 1045 
            for(in.shop2020.model.v1.inventory.VendorItemMapping vim : tVendorMappings) {
3354 chandransh 1046 
                vItemMapping = new VendorItemMapping();
1047 
                vItemMapping.setVendorId(vim.getVendorId());
1048 
                vItemMapping.setItemKey(vim.getItemKey());
1049 
                vItemMap.put(vItemMapping.getVendorId() + Item.KEY_SEPARATOR + vim.getItemKey(), vItemMapping);
1050 
            }
1051 
        }
1052 
 
1053 
        Map<Long, VendorPricings> vendorPricingMap = new HashMap<Long, VendorPricings>();
1054 
        VendorPricings vPricings;
1055 
        if(tVendorPricings != null) {
5946 rajveer 1056 
            for(in.shop2020.model.v1.inventory.VendorItemPricing vip : tVendorPricings) {
3354 chandransh 1057 
                vPricings = new VendorPricings();
1058 
                vPricings.setVendorId(vip.getVendorId());
1059 
                vPricings.setMop(vip.getMop());
1060 
                vPricings.setDealerPrice(vip.getDealerPrice());
1061 
                vPricings.setTransferPrice(vip.getTransferPrice());
6759 amar.kumar 1062 
                vPricings.setNlc(vip.getNlc());
3354 chandransh 1063 
                vendorPricingMap.put(vPricings.getVendorId(), vPricings);
1064 
            }
1065 
        }
1066 
 
3558 rajveer 1067 
        Map<Long, SourcePricings> sourcePricingMap = new HashMap<Long, SourcePricings>();
1068 
        SourcePricings sPricings;
1069 
        if(tSourceMappings != null) {
1070 
            for(in.shop2020.model.v1.catalog.SourceItemPricing sip : tSourceMappings) {
1071 
                sPricings = new SourcePricings();
1072 
                sPricings.setSourceId(sip.getSourceId());
1073 
                sPricings.setMrp(sip.getMrp());
1074 
                sPricings.setSellingPrice(sip.getSellingPrice());
1075 
                sourcePricingMap.put(sPricings.getSourceId(), sPricings);
1076 
            }
1077 
        }
4423 phani.kuma 1078 
 
1079 
        Map<Long, Item> SimilarItemslist = new HashMap<Long, Item>();
1080 
        Item sItems;
1081 
        if(tSimilarItems != null) {
1082 
            for(in.shop2020.model.v1.catalog.Item sit : tSimilarItems) {
1083 
            	sItems = new Item();
1084 
            	sItems.setCatalogItemId(sit.getCatalogItemId());
1085 
            	sItems.setProductGroup(sit.getProductGroup());
1086 
            	sItems.setBrand(sit.getBrand());
1087 
            	sItems.setModelNumber(sit.getModelNumber());
1088 
            	sItems.setModelName(sit.getModelName());
1089 
            	sItems.setContentCategory(CategoryManager.getCategoryManager().getCategoryLabel(sit.getCategory()));
1090 
            	SimilarItemslist.put(sit.getCatalogItemId(), sItems);
1091 
            }
1092 
        }
3558 rajveer 1093 
 
4431 phani.kuma 1094 
        Map<Long, ItemInventory> itemInventoryMap = new HashMap<Long, ItemInventory>();
1095 
        ItemInventory warehousedata;
5309 rajveer 1096 
        if(tItemInventory != null) {
1097 
        	Map<Long, Long> availabilityMap = tItemInventory.getAvailability();
1098 
        	Map<Long, Long> reservedMap = tItemInventory.getReserved();
8709 amar.kumar 1099 
        	Map<Long, Long> heldMap = tItemInventory.getHeld();
4431 phani.kuma 1100 
            for(Entry<Long, Long> availability : availabilityMap.entrySet()) {
9640 amar.kumar 1101 
            	Map<Integer, Long> heldInventoryMap = new HashMap<Integer, Long>();
4431 phani.kuma 1102 
            	warehousedata = new ItemInventory();
1103 
            	warehousedata.setWarehouseId(availability.getKey());
1104 
            	warehousedata.setAvailability(availability.getValue());
1105 
            	warehousedata.setReserved(reservedMap.get(availability.getKey()));
8709 amar.kumar 1106 
            	warehousedata.setHeld(heldMap.get(availability.getKey()));
9640 amar.kumar 1107 
            	try {
1108 
	            	if(warehousedata.getHeld()>0) {
1109 
	            		InventoryService.Client inventoryClient = new InventoryClient().getClient();
1110 
	            		heldInventoryMap = inventoryClient.getHeldInventoryMapForItem(thriftItem.getId(), availability.getKey());
1111 
	            	}
1112 
	            	if(heldInventoryMap.size()>0) {
1113 
	            		for(Integer source : heldInventoryMap.keySet()) {
1114 
	            			switch(source) {
1115 
	            				case EBAYSOURCE: warehousedata.setEbayHeld(heldInventoryMap.get(source));
9650 amar.kumar 1116 
	            				break;
9640 amar.kumar 1117 
	            				case SNAPDEALSOURCE: warehousedata.setSnapdealHeld(heldInventoryMap.get(source));
9650 amar.kumar 1118 
	            				break;
9640 amar.kumar 1119 
	            				case FLIPKARTSOURCE: warehousedata.setFlipkartHeld(heldInventoryMap.get(source));
1120 
	            			}
1121 
	            		}
1122 
	            	}
1123 
            	} catch (Exception e) {
1124 
            		logger.error("Error in getting data from holdInventoryDetail for itemId " + thriftItem.getId() +
1125 
            				" and warehouse " +availability.getKey());
1126 
            	}
4431 phani.kuma 1127 
            	itemInventoryMap.put(warehousedata.getWarehouseId(), warehousedata);
1128 
            }
1129 
        }
1130 
        else {
1131 
        	itemInventoryMap = null;
1132 
        }
5504 phani.kuma 1133 
 
1134 
        Map<String, VoucherItemMapping> voucherMap = new HashMap<String, VoucherItemMapping>();
1135 
        VoucherItemMapping voucher;
1136 
        if(tVoucherMappings != null) {
1137 
            for(in.shop2020.model.v1.catalog.VoucherItemMapping tvoucher : tVoucherMappings) {
5516 phani.kuma 1138 
            	voucher = new VoucherItemMapping(tvoucher.getAmount(), VoucherType.findByValue((int) tvoucher.getVoucherType()).name());
1139 
            	voucherMap.put(VoucherType.findByValue((int) tvoucher.getVoucherType()).name(), voucher);
5504 phani.kuma 1140 
            }
1141 
        }
6813 amar.kumar 1142 
 
1143 
        in.shop2020.catalog.dashboard.shared.ItemStockPurchaseParams stockPurchaseParams =
1144 
        	new in.shop2020.catalog.dashboard.shared.ItemStockPurchaseParams();
1145 
        if(tStockPurchaseParams != null) {
1146 
        	stockPurchaseParams.setItem_id(tStockPurchaseParams.getItem_id());
1147 
        	stockPurchaseParams.setMinStockLevel(tStockPurchaseParams.getMinStockLevel());
1148 
        	stockPurchaseParams.setNumOfDaysStock(tStockPurchaseParams.getNumOfDaysStock());
1149 
        }
1150 
 
3354 chandransh 1151 
        Item item = new Item(thriftItem.getId(),
1152 
                thriftItem.getProductGroup(),
1153 
                thriftItem.getBrand(),
1154 
                thriftItem.getModelNumber(),
1155 
                thriftItem.getModelName(),
1156 
                thriftItem.getColor(),
1157 
                CategoryManager.getCategoryManager().getCategoryLabel(thriftItem.getCategory()),
1158 
                thriftItem.getCategory(),
1159 
                thriftItem.getComments(),
1160 
                thriftItem.getCatalogItemId(),
1161 
                thriftItem.getFeatureId(),
1162 
                thriftItem.getFeatureDescription(),
1163 
                thriftItem.isSetMrp() ? thriftItem.getMrp() : null,
1164 
                thriftItem.isSetSellingPrice() ? thriftItem.getSellingPrice() : null,
1165 
                thriftItem.isSetWeight() ? thriftItem.getWeight() : null,
1166 
                thriftItem.getAddedOn(),
1167 
                thriftItem.getStartDate(),
5217 amit.gupta 1168 
                thriftItem.isSetComingSoonStartDate() ? thriftItem.getComingSoonStartDate() : null ,
1169 
                thriftItem.isSetExpectedArrivalDate() ? thriftItem.getExpectedArrivalDate() : null ,
3354 chandransh 1170 
                thriftItem.getRetireDate(),
1171 
                thriftItem.getUpdatedOn(),
1172 
                thriftItem.getItemStatus().name(),
1173 
                thriftItem.getItemStatus().getValue(),
1174 
                thriftItem.getStatus_description(),
1175 
                thriftItem.getBestDealText(),
6777 vikram.rag 1176 
                thriftItem.getBestDealsDetailsText(),
1177 
                thriftItem.getBestDealsDetailsLink(),
3354 chandransh 1178 
                thriftItem.isSetBestDealValue() ? thriftItem.getBestDealValue() : null,
1179 
                thriftItem.isSetBestSellingRank() ? thriftItem.getBestSellingRank() : null,
1180 
                thriftItem.isDefaultForEntity(),
1181 
                thriftItem.isRisky(),
3359 chandransh 1182 
                thriftItem.isSetExpectedDelay() ? thriftItem.getExpectedDelay() : null,
4506 phani.kuma 1183 
                thriftItem.isIsWarehousePreferenceSticky(),
5384 phani.kuma 1184 
                thriftItem.isHasItemNo(),
1185 
                ItemType.SERIALIZED.equals(thriftItem.getType()),
6241 amit.gupta 1186 
                thriftItem.isSetShowSellingPrice() ? thriftItem.isShowSellingPrice() : false,
4506 phani.kuma 1187 
                thriftItem.isSetPreferredVendor() ? thriftItem.getPreferredVendor() : null,
6838 vikram.rag 1188 
                thriftItem.isSetPreferredInsurer() ? thriftItem.getPreferredInsurer() : null,
4431 phani.kuma 1189 
                itemInventoryMap,
3354 chandransh 1190 
                vendorPricingMap,
3558 rajveer 1191 
                vItemMap,
4423 phani.kuma 1192 
                sourcePricingMap,
5504 phani.kuma 1193 
                SimilarItemslist,
7972 amar.kumar 1194 
                voucherMap,
1195 
                stockPurchaseParams.getNumOfDaysStock(),
1196 
                stockPurchaseParams.getMinStockLevel(),
9835 rajveer 1197 
                saleHistory,
7972 amar.kumar 1198 
                freebieItemId,
7291 vikram.rag 1199 
                thriftItem.getAsin(),
1200 
                thriftItem.getHoldInventory(),
1201 
                thriftItem.getDefaultInventory());
3354 chandransh 1202 
        return item;
1203 
    }
1204 
 
1205 
    /**
2489 ankur.sing 1206 
     *
3922 chandransh 1207 
     * @return True if push to production count is less than maximum allowed.
2489 ankur.sing 1208 
     */
3922 chandransh 1209 
    private boolean canPushToProduction() {
1210 
        int count = getPushToProdCount(logFile);
1211 
        return count < maxCount;
2427 ankur.sing 1212 
    }
3922 chandransh 1213 
 
2489 ankur.sing 1214 
    /**
1215 
     * If this is the first attempt to push to production for current date, returns 0
1216 
     * else reads number of lines from daily rolling log file to get the count.
1217 
     * @return push to production count for current date
1218 
     */
2498 ankur.sing 1219 
    private int getPushToProdCount(String logfile) {
1220 
        // logfile is "/var/log/services/pushToProductionCount/pushToProd.log"
1221 
        // this should also be set in log4j.properties
2427 ankur.sing 1222 
        int lineCount = 0;
2498 ankur.sing 1223 
        DateFormat dateFormat = new SimpleDateFormat("dd/MM/yyyy");
2427 ankur.sing 1224 
        Date currentDate = Calendar.getInstance().getTime();
1225 
        if(pushToProdDate == null ||  !dateFormat.format(pushToProdDate).equals(dateFormat.format(currentDate))) {
1226 
            pushToProdDate = currentDate;
1227 
            return lineCount;
1228 
        }
1229 
        try {
2498 ankur.sing 1230 
            BufferedReader br = new BufferedReader(new FileReader(logfile));
2427 ankur.sing 1231 
            while (br.readLine() != null) {
1232 
                lineCount++;
1233 
            }
1234 
        } catch (IOException e) {
3354 chandransh 1235 
            logger.error("Error while reading the log file", e);
2427 ankur.sing 1236 
        }
1237 
        return lineCount;
1238 
    }
4423 phani.kuma 1239 
 
1240 
	@Override
1241 
	public boolean deleteSimilarItem(long itemId, long catalogItemId) {
1242 
		try{
1243 
            CatalogClient catalogServiceClient = new CatalogClient();
5946 rajveer 1244 
            Client catalogClient = catalogServiceClient.getClient();
4423 phani.kuma 1245 
 
1246 
            return catalogClient.deleteSimilarItem(itemId, catalogItemId);
1247 
 
1248 
        }catch(Exception e){
1249 
            logger.error("Error while deleting the SimilarItems for: " + itemId, e);
1250 
        }
1251 
        return false;
1252 
	}
1253 
 
1254 
	@Override
1255 
	public Item addSimilarItem(long itemId, long catalogItemId) {
1256 
		try{
1257 
            CatalogClient catalogServiceClient = new CatalogClient();
5946 rajveer 1258 
            Client catalogClient = catalogServiceClient.getClient();
4423 phani.kuma 1259 
            in.shop2020.model.v1.catalog.Item thriftItem = catalogClient.addSimilarItem(itemId, catalogItemId);;
1260 
 
9836 rajveer 1261 
            return getItemFromThriftItem(thriftItem, null, null, null, null, null, null, null, null, null);
4423 phani.kuma 1262 
        }catch(Exception e){
1263 
            logger.error("Error while adding the SimilarItems for: " + itemId, e);
1264 
        }
1265 
        return null;
1266 
	}
4431 phani.kuma 1267 
 
1268 
	@Override
1269 
	public Map<Long, ItemInventory> getProdItemInventory(long itemId) {
1270 
		try {
1271 
            // Initialize client for production server
1272 
            CatalogClient catalogServiceClient_Prod = new CatalogClient(ConfigClientKeys.catalog_service_server_host_prod.toString(),
1273 
                    ConfigClientKeys.catalog_service_server_port.toString());
5946 rajveer 1274 
            Client catalogClient_Prod = catalogServiceClient_Prod.getClient();
1275 
            InventoryClient inventoryServiceClient = new InventoryClient();
1276 
            in.shop2020.model.v1.inventory.InventoryService.Client inventoryClient = inventoryServiceClient.getClient();
1277 
            in.shop2020.model.v1.inventory.ItemInventory thriftItemInventory = inventoryClient.getItemInventoryByItemId(itemId);
4431 phani.kuma 1278 
 
1279 
            Map<Long, ItemInventory> itemInventoryMap = new HashMap<Long, ItemInventory>();
1280 
            ItemInventory warehousedata;
1281 
            if(thriftItemInventory != null) {
1282 
            	Map<Long, Long> availabilityMap = thriftItemInventory.getAvailability();
1283 
            	Map<Long, Long> reservedMap = thriftItemInventory.getReserved();
8708 amar.kumar 1284 
            	Map<Long, Long> heldMap = thriftItemInventory.getHeld();
4431 phani.kuma 1285 
                for(Entry<Long, Long> availability : availabilityMap.entrySet()) {
9640 amar.kumar 1286 
                	Map<Integer, Long> heldInventoryMap = new HashMap<Integer, Long>();
4431 phani.kuma 1287 
                	warehousedata = new ItemInventory();
1288 
                	warehousedata.setWarehouseId(availability.getKey());
1289 
                	warehousedata.setAvailability(availability.getValue());
1290 
                	warehousedata.setReserved(reservedMap.get(availability.getKey()));
8708 amar.kumar 1291 
                	warehousedata.setHeld(heldMap.get(availability.getKey()));
9640 amar.kumar 1292 
                	try {
1293 
	            		if(warehousedata.getHeld()>0) {
1294 
	                		heldInventoryMap = inventoryClient.getHeldInventoryMapForItem(itemId, availability.getKey());
1295 
	                	}
1296 
	                	if(heldInventoryMap.size()>0) {
1297 
	                		for(Integer source : heldInventoryMap.keySet()) {
1298 
	                			switch(source) {
1299 
	                				case EBAYSOURCE: warehousedata.setEbayHeld(heldInventoryMap.get(source));
9649 amar.kumar 1300 
	                				break;
9640 amar.kumar 1301 
	                				case SNAPDEALSOURCE: warehousedata.setSnapdealHeld(heldInventoryMap.get(source));
9649 amar.kumar 1302 
	                				break;
9640 amar.kumar 1303 
	                				case FLIPKARTSOURCE: warehousedata.setFlipkartHeld(heldInventoryMap.get(source));
1304 
	                			}
1305 
	                		}
1306 
	                	}
1307 
                	}catch (Exception e) {
1308 
                		logger.error("Error in getting data from holdInventoryDetail for itemId " + itemId +
1309 
                				" and warehouse " +availability.getKey());
1310 
                	}
4431 phani.kuma 1311 
                	itemInventoryMap.put(warehousedata.getWarehouseId(), warehousedata);
1312 
                }
1313 
            }
1314 
            else {
1315 
            	itemInventoryMap = null;
1316 
            }
1317 
            return itemInventoryMap;
1318 
        } catch (Exception e) {
1319 
            logger.error("Error while updating item's risky flag on staging", e);
1320 
        }
1321 
		return null;
1322 
	}
4649 phani.kuma 1323 
 
1324 
	@Override
1325 
	public boolean addAuthorizationLog(long itemId, String username, String message) {
1326 
		try{
1327 
            CatalogClient catalogServiceClient = new CatalogClient();
5946 rajveer 1328 
            Client catalogClient = catalogServiceClient.getClient();
4649 phani.kuma 1329 
 
1330 
            return catalogClient.addAuthorizationLog(itemId, username, message);
1331 
 
1332 
        }catch(Exception e){
1333 
            logger.error("Error while adding the event for: " + itemId, e);
1334 
        }
1335 
		return false;
1336 
	}
1337 
 
1338 
	@Override
1339 
	public Map<String, String> getConfigdataforPriceCompare() {
1340 
		Map<String, String> ConfigMap = new HashMap<String, String>();
1341 
		try {
1342 
			ConfigMap.put("courier_cost_factor", ConfigClient.getClient().get(ConfigClientKeys.courier_cost_factor.toString()));
1343 
            ConfigMap.put("courier_weight_factor", ConfigClient.getClient().get(ConfigClientKeys.courier_weight_factor.toString()));
1344 
            ConfigMap.put("breakeven_divisor", ConfigClient.getClient().get(ConfigClientKeys.breakeven_divisor.toString()));
1345 
            ConfigMap.put("breakeven_additon_factor", ConfigClient.getClient().get(ConfigClientKeys.breakeven_additon_factor.toString()));
1346 
            ConfigMap.put("transfer_price_percentage", ConfigClient.getClient().get(ConfigClientKeys.transfer_price_percentage.toString()));
1347 
            ConfigMap.put("transfer_price_factor", ConfigClient.getClient().get(ConfigClientKeys.transfer_price_factor.toString()));
1348 
        } catch(ConfigException ce) {
1349 
            logger.error("Unable to connect to the config server. Setting sensible defaults.", ce);
1350 
            ConfigMap.put("courier_cost_factor", "60");
1351 
            ConfigMap.put("courier_weight_factor", "500");
1352 
            ConfigMap.put("breakeven_divisor", "0.98");
1353 
            ConfigMap.put("breakeven_additon_factor", "50");
1354 
            ConfigMap.put("transfer_price_percentage", "2");
1355 
            ConfigMap.put("transfer_price_factor", "50");
1356 
        }
1357 
		return ConfigMap;
1358 
	}
4957 phani.kuma 1359 
 
1360 
	@Override
1361 
	public List<String> getAllCategories() {
1362 
		List<String> categoryList = new ArrayList<String>();
1363 
		List<Long> parentCategoryIDs = Arrays.asList(new Long[] {(long) 0,(long) 10001,(long) 10009,(long) 10049});
1364 
        try {
1365 
            CatalogClient catalogServiceClient = new CatalogClient();
5946 rajveer 1366 
            Client catalogClient = catalogServiceClient.getClient();
4957 phani.kuma 1367 
 
1368 
            List<in.shop2020.model.v1.catalog.Category> categories = catalogClient.getAllCategories();
1369 
 
1370 
            for(in.shop2020.model.v1.catalog.Category category : categories) {
1371 
            	if(!parentCategoryIDs.contains(category.getParent_category_id())){
1372 
            		categoryList.add(category.getDisplay_name());
1373 
            	}
1374 
            	else{
1375 
            		continue;
1376 
            	}
1377 
            }
1378 
        } catch (Exception e) {
1379 
            logger.error("Error while getting all the categories: ", e);
1380 
        }
1381 
        return categoryList;
1382 
	}
1383 
 
1384 
	@Override
1385 
	public List<String> getAllBrands() {
1386 
		List<String> brandsList = new ArrayList<String>();
1387 
        try {
1388 
            CatalogClient catalogServiceClient = new CatalogClient();
5946 rajveer 1389 
            Client catalogClient = catalogServiceClient.getClient();
4957 phani.kuma 1390 
 
1391 
            brandsList = catalogClient.getAllBrands();
1392 
        } catch (Exception e) {
1393 
            logger.error("Error while getting all the categories: ", e);
1394 
        }
1395 
        return brandsList;
1396 
	}
5427 amit.gupta 1397 
 
5504 phani.kuma 1398 
	@Override
5516 phani.kuma 1399 
	public boolean deleteVoucher(Long catalogItemId, Long voucherType) {
5504 phani.kuma 1400 
		try{
1401 
            CatalogClient catalogServiceClient = new CatalogClient();
5946 rajveer 1402 
            Client catalogClient = catalogServiceClient.getClient();
5504 phani.kuma 1403 
 
1404 
            return catalogClient.deleteVoucherForItem(catalogItemId, voucherType);
1405 
 
1406 
        }catch(Exception e){
1407 
            logger.error("Error while deleting the Voucher for: " + catalogItemId, e);
1408 
        }
1409 
        return false;
1410 
	}
1411 
 
1412 
	@Override
5516 phani.kuma 1413 
	public boolean addVoucher(Long catalogItemId, Long voucherType, long voucherAmount) {
5504 phani.kuma 1414 
		try{
1415 
            CatalogClient catalogServiceClient = new CatalogClient();
5946 rajveer 1416 
            Client catalogClient = catalogServiceClient.getClient();
5504 phani.kuma 1417 
 
1418 
            return catalogClient.addupdateVoucherForItem(catalogItemId, voucherType, voucherAmount);
1419 
 
1420 
        }catch(Exception e){
1421 
            logger.error("Error while adding the Voucher for: " + catalogItemId, e);
1422 
        }
1423 
		return false;
1424 
	}
1425 
	@Override
5516 phani.kuma 1426 
	public Map<Long, String> getvoucherTypes() {
1427 
		Map<Long, String> voucherType = new HashMap<Long, String>();
5504 phani.kuma 1428 
		for(VoucherType voucher : VoucherType.values())
1429 
		{
5516 phani.kuma 1430 
			voucherType.put((long) voucher.getValue(), voucher.name());
5504 phani.kuma 1431 
		}
1432 
		return voucherType;
1433 
	}
1434 
 
5586 phani.kuma 1435 
	@Override
1436 
	public boolean getConfigforentityIdMandatory() {
1437 
		try {
1438 
			String entityId_mandatory = ConfigClient.getClient().get(ConfigClientKeys.entityId_mandatory.toString());
1439 
			if (entityId_mandatory.equals("TRUE")) {
1440 
				return true;
1441 
			}
1442 
        } catch(ConfigException ce) {
1443 
            logger.error("Unable to connect to the config server. Setting sensible defaults.", ce);
1444 
        }
1445 
		return false;
1446 
	}
1447 
 
1448 
	@Override
1449 
	public boolean checkEntityId(long entityId) {
1450 
		try {
1451 
            CatalogClient catalogServiceClient = new CatalogClient(ConfigClientKeys.catalog_service_server_host_master.toString(), ConfigClientKeys.catalog_service_server_port.toString());
5946 rajveer 1452 
            Client catalogClient = catalogServiceClient.getClient();
5586 phani.kuma 1453 
            return catalogClient.isValidCatalogItemId(entityId);
1454 
        } catch (Exception e) {
1455 
            logger.error("Error while checking for a Catalog Item Id: ", e);
1456 
        }
1457 
		return false;
1458 
	}
1459 
 
6096 amit.gupta 1460 
	@Override
1461 
	public String updateExpectedDelayOnProd(Item item) {
1462 
		try{
1463 
            CatalogClient catalogServiceClient_Prod = new CatalogClient(
1464 
                    ConfigClientKeys.catalog_service_server_host_prod.toString(),
1465 
                    ConfigClientKeys.catalog_service_server_port.toString());
1466 
 
1467 
            Client catalogClient_Prod = catalogServiceClient_Prod.getClient();
1468 
 
1469 
 
1470 
            in.shop2020.model.v1.catalog.Item tItem = catalogClient_Prod.getItem(item.getId());
1471 
            if(item.getExpectedDelay() != null) {
1472 
            	tItem.setExpectedDelay(item.getExpectedDelay());
7182 amit.gupta 1473 
            	if(item.isItemType()) {
1474 
                	tItem.setType(ItemType.SERIALIZED);
1475 
                }
1476 
                else {
1477 
                	tItem.setType(ItemType.NON_SERIALIZED);
1478 
                }
6096 amit.gupta 1479 
	            long rItemId;
1480 
	            if((rItemId = catalogClient_Prod.updateItem(tItem)) != item.getId()) {
1481 
	                logger.error("Error updating item on production, returned Item Id: " + rItemId);
1482 
	                return "Error updating expected delay on production";
1483 
	            }
6241 amit.gupta 1484 
	            InventoryClient inventoryServiceClient= new InventoryClient();
1485 
	            InventoryService.Client inventoryClient = inventoryServiceClient.getClient();
6096 amit.gupta 1486 
	            inventoryClient.clearItemAvailabilityCacheForItem(rItemId);
1487 
	            logger.info("Successfully updated item: " + item.getId());
1488 
	            return "Expected delay successfully updated on prod";
1489 
            } else {
1490 
            	return "Error:expected delay should not be null";
1491 
            }
1492 
        } catch (Exception e) {
6098 amit.gupta 1493 
            logger.error("Error while updating expected delay on production", e);
1494 
            return "Error while updating expected delay on production";
6096 amit.gupta 1495 
        }
1496 
	}
1497 
 
6838 vikram.rag 1498 
	@Override
1499 
	public Map<Long, String> getAllInsurers() {
1500 
		 Map<Long, String> insurersMap = new HashMap<Long, String>();
1501 
	        try {
1502 
	            CatalogClient catalogServiceClient = new CatalogClient();
1503 
	            in.shop2020.model.v1.catalog.CatalogService.Client catalogClient = catalogServiceClient.getClient();
1504 
 
1505 
	            List<Insurer> insurers = catalogClient.getAllInsurers();
6096 amit.gupta 1506 
 
6838 vikram.rag 1507 
	            for(in.shop2020.model.v1.catalog.Insurer i : insurers) {
1508 
	                insurersMap.put(i.getId(), i.getName());
1509 
	            }
1510 
	        } catch (Exception e) {
1511 
	            logger.error("Error while getting all the vendors: ", e);
1512 
	        }
1513 
	        return insurersMap;
1514 
	}
1515 
 
1516 
 
6096 amit.gupta 1517 
 
1518 
 
1519 
 
6530 vikram.rag 1520 
}