Subversion Repositories SmartDukaan

Rev

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

Rev Author Line No. Line
9560 vikram.rag 1 
package in.shop2020;
9404 vikram.rag 2 
 
9456 vikram.rag 3 
import in.shop2020.model.v1.catalog.CatalogService;
9404 vikram.rag 4 
import in.shop2020.model.v1.catalog.Item;
5 
import in.shop2020.model.v1.catalog.SnapdealItem;
9495 vikram.rag 6 
import in.shop2020.model.v1.catalog.SnapdealItemDetails;
9404 vikram.rag 7 
import in.shop2020.model.v1.inventory.InventoryService.Client;
8 
import in.shop2020.model.v1.inventory.InventoryType;
9 
import in.shop2020.model.v1.inventory.ItemInventory;
10 
import in.shop2020.model.v1.inventory.SnapdealInventoryItem;
11 
import in.shop2020.model.v1.inventory.Warehouse;
9605 vikram.rag 12 
import in.shop2020.model.v1.inventory.WarehouseLocation;
9404 vikram.rag 13 
import in.shop2020.model.v1.inventory.WarehouseType;
14 
import in.shop2020.thrift.clients.CatalogClient;
15 
import in.shop2020.thrift.clients.InventoryClient;
16 
import in.shop2020.thrift.clients.TransactionClient;
9459 vikram.rag 17 
import in.shop2020.utils.GmailUtils;
9404 vikram.rag 18 
import inventory.Inventory;
9456 vikram.rag 19 
import inventory.InventoryHistory;
20 
import inventory.InventoryHistoryItems;
9404 vikram.rag 21 
import inventory.InventoryItems;
9495 vikram.rag 22 
import inventory.PendingOrderInventoryHistory;
9404 vikram.rag 23 
import inventory.SnapdealItemForInventory;
24 
 
25 
import java.io.BufferedReader;
9459 vikram.rag 26 
import java.io.File;
9404 vikram.rag 27 
import java.io.FileInputStream;
28 
import java.io.FileNotFoundException;
29 
import java.io.FileOutputStream;
30 
import java.io.IOException;
31 
import java.io.InputStreamReader;
32 
import java.io.UnsupportedEncodingException;
33 
import java.util.ArrayList;
9459 vikram.rag 34 
import java.util.Calendar;
35 
import java.util.GregorianCalendar;
9404 vikram.rag 36 
import java.util.HashMap;
37 
import java.util.List;
38 
import java.util.Map;
9495 vikram.rag 39 
import java.util.Map.Entry;
9404 vikram.rag 40 
 
9459 vikram.rag 41 
import javax.mail.MessagingException;
42 
 
9404 vikram.rag 43 
import org.apache.http.HttpResponse;
44 
import org.apache.http.NameValuePair;
45 
import org.apache.http.client.ClientProtocolException;
46 
import org.apache.http.client.HttpClient;
47 
import org.apache.http.client.entity.UrlEncodedFormEntity;
48 
import org.apache.http.client.methods.HttpGet;
49 
import org.apache.http.client.methods.HttpPost;
9510 vikram.rag 50 
import org.apache.http.entity.mime.MultipartEntity;
51 
import org.apache.http.entity.mime.content.ContentBody;
52 
import org.apache.http.entity.mime.content.FileBody;
9404 vikram.rag 53 
import org.apache.http.impl.client.DefaultHttpClient;
54 
import org.apache.http.message.BasicNameValuePair;
55 
import org.apache.poi.hssf.usermodel.HSSFWorkbook;
56 
import org.apache.poi.ss.usermodel.Row;
57 
import org.apache.poi.ss.usermodel.Sheet;
58 
import org.apache.poi.ss.usermodel.Workbook;
59 
import org.apache.thrift.TException;
60 
import org.apache.thrift.transport.TTransportException;
9456 vikram.rag 61 
 
9404 vikram.rag 62 
import com.google.gson.Gson;
63 
 
64 
public class CreateSnapDealInventoryFeed {
9456 vikram.rag 65 
	private static long time = System.currentTimeMillis();
9415 vikram.rag 66 
	private static String SNAPDEAL_INVENTORY_SHEET;
9404 vikram.rag 67 
	private static Map<Long, SnapdealItemForInventory> allItemsInventoryMap = new HashMap<Long, SnapdealItemForInventory>();
9501 vikram.rag 68 
	private static ArrayList<Inventory> currentInventoryItemList;
9550 vikram.rag 69 
	static Map<Long,Long> itemIdpendingOrdersMap;
9456 vikram.rag 70 
	private static Map<String,InventoryHistory> inventoryhistoryItemMap;
71 
	private static DefaultHttpClient client = new DefaultHttpClient();
9495 vikram.rag 72 
	static Map<String,SnapdealItemDetails> snapdealItemMap = new HashMap<String,SnapdealItemDetails>();
73 
	static Map<Long,SnapdealItemDetails> itemSnapdealMap = new HashMap<Long,SnapdealItemDetails>();
74 
	static Map<String,PendingOrderInventoryHistory> PendingOrdersInventoryHistoryMap = new HashMap<String,PendingOrderInventoryHistory>();
75 
	static long lastUpdatedInventoryTime = 0;
9580 vikram.rag 76 
	static java.text.SimpleDateFormat sdf;
77 
	static String emailFromAddress;
78 
	static String password;
79 
	static GmailUtils mailer;
80 
	static String sendTo[];
9495 vikram.rag 81 
	static{
9580 vikram.rag 82 
		sdf = new java.text.SimpleDateFormat("yyyy-MM-dd-HH:mm:ss");
83 
		emailFromAddress = "build@shop2020.in";
84 
		password = "cafe@nes";
85 
		mailer = new GmailUtils();
9585 vikram.rag 86 
		//sendTo = new String[]{"vikram.raghav@shop2020.in"};
87 
		sendTo = new String[]{ "sandeep.sachdeva@shop2020.in", "vikram.raghav@shop2020.in", "rajneesh.arora@shop2020.in",
9580 vikram.rag 88 
				"khushal.bhatia@shop2020.in","manoj.kumar@saholic.com","chaitnaya.vats@saholic.com",
89 
				"yukti.jain@shop2020.in","manisha.sharma@shop2020.in","chandan.kumar@shop2020.in","ankush.dhingra@shop2020.in","amar.kumar@shop2020.in"};
9550 vikram.rag 90 
		itemIdpendingOrdersMap = new HashMap<Long,Long>();
9495 vikram.rag 91 
		CatalogClient catalogServiceClient = null;
92 
		try {
93 
			catalogServiceClient = new CatalogClient();
94 
		} catch (TTransportException e1) {
95 
			// TODO Auto-generated catch block
96 
			e1.printStackTrace();
97 
		}
98 
		in.shop2020.model.v1.catalog.CatalogService.Client catalogClient = catalogServiceClient.getClient();
99 
		List<SnapdealItemDetails> allSnapdealItems = null;
100 
		try {
101 
			allSnapdealItems = catalogClient.getAllSnapdealItems();
102 
		} catch (TException e) {
103 
			// TODO Auto-generated catch block
104 
			e.printStackTrace();
105 
		}
106 
		for(SnapdealItemDetails snapdealItem:allSnapdealItems){
107 
			snapdealItemMap.put(snapdealItem.getSkuAtSnapdeal(),snapdealItem);
108 
			itemSnapdealMap.put(snapdealItem.getItem_id(), snapdealItem);
9517 vikram.rag 109 
			//System.out.println("Creating Item and Snapdeal Map " + snapdealItem.getItem_id() + " " + snapdealItem.getSkuAtSnapdeal());
9495 vikram.rag 110 
		}
111 
		in.shop2020.model.v1.order.TransactionService.Client transactionClient = null;
112 
		try {
9497 vikram.rag 113 
			transactionClient = new TransactionClient("support_transaction_service_server_host","transaction_service_server_port").getClient();
9495 vikram.rag 114 
			lastUpdatedInventoryTime = transactionClient.getSourceDetail(7).getLastUpdatedOn();
9539 vikram.rag 115 
			//System.out.println("Time is " + lastUpdatedInventoryTime);
9495 vikram.rag 116 
		} catch (Exception e) {
117 
			try {
9497 vikram.rag 118 
				transactionClient = new TransactionClient("support_transaction_service_server_host","transaction_service_server_port").getClient();
9495 vikram.rag 119 
				lastUpdatedInventoryTime = transactionClient.getSourceDetail(7).getLastUpdatedOn();
120 
			} catch (Exception ex) {
121 
				ex.printStackTrace();
122 
			}
123 
		}
124 
 
125 
	}
126 
 
9404 vikram.rag 127 
	private static void calculateinventory(){
128 
		CatalogClient catalogServiceClient = null;
129 
		Map<Long,ItemInventory> availability= new HashMap<Long,ItemInventory>();
130 
		try {
131 
			catalogServiceClient = new CatalogClient();
132 
		} catch (TTransportException e) {
133 
			// TODO Auto-generated catch block
134 
			e.printStackTrace();
135 
		}
136 
		in.shop2020.model.v1.catalog.CatalogService.Client catalogClient = catalogServiceClient.getClient();
137 
		try {
138 
			List<Item> aliveItems = catalogClient.getAllAliveItems();
139 
			Map<Long,Item> aliveItemsMap = new HashMap<Long,Item>();
140 
			for(in.shop2020.model.v1.catalog.Item thriftItem:aliveItems){
141 
				aliveItemsMap.put(thriftItem.getId(), thriftItem);
142 
 
143 
			}
9495 vikram.rag 144 
			InventoryClient inventoryServiceClient = new InventoryClient();
9404 vikram.rag 145 
			try {
146 
				inventoryServiceClient = new InventoryClient();
147 
			} catch (TTransportException e) {
148 
				e.printStackTrace();
149 
			}
150 
			in.shop2020.model.v1.inventory.InventoryService.Client inventoryClient = inventoryServiceClient.getClient();
151 
			List<in.shop2020.model.v1.inventory.IgnoredInventoryUpdateItems> ignoreItems = inventoryClient.getIgnoredWarehouseidsAndItemids();
9415 vikram.rag 152 
			SNAPDEAL_INVENTORY_SHEET = "/home/snapdeal/snapdeal-inventory-"+time+".xls";
9404 vikram.rag 153 
			availability = inventoryClient.getInventorySnapshot(0);
9456 vikram.rag 154 
			List<Warehouse> allwarehouses = inventoryClient.getWarehouses(null,null,0,0,0);
155 
			Map<Long,Warehouse> allWarehousesMap = new HashMap<Long,Warehouse>();
156 
			for(Warehouse warehouse:allwarehouses){
157 
				allWarehousesMap.put(warehouse.getId(),warehouse);
158 
			}
9404 vikram.rag 159 
			List<Warehouse> warehouses = inventoryClient.getWarehouses(WarehouseType.OURS_THIRDPARTY,null,0,0,0);
160 
			List<Warehouse> ours_warehouses = inventoryClient.getWarehouses(WarehouseType.OURS, InventoryType.GOOD, 0, 0, 0);
161 
			List<Long> thirdpartywarehouseids = new ArrayList<Long>();
162 
			List<Long> oursGoodWarehouse = new ArrayList<Long>();
163 
			for(Warehouse warehouse:warehouses){
164 
				thirdpartywarehouseids.add(warehouse.getId());
165 
			}
166 
			for (Warehouse warehouse:ours_warehouses){
167 
				oursGoodWarehouse.add(warehouse.getId());
168 
			}
169 
			long available=0;
170 
			long reserve=0;
9532 vikram.rag 171 
			long total_warehouse_held=0;
172 
			long heldForSource=0;
9404 vikram.rag 173 
			long total_held=0;
174 
			double nlc=0;
175 
			double maxnlc=0;
176 
			Item thriftItem;
9456 vikram.rag 177 
			long sku = 0;
9501 vikram.rag 178 
			for(Inventory inventoryItem:currentInventoryItemList){
9495 vikram.rag 179 
				if(snapdealItemMap.containsKey(inventoryItem.getSellerSku())){
180 
					sku = snapdealItemMap.get(inventoryItem.getSellerSku()).getItem_id();
9404 vikram.rag 181 
				}
9495 vikram.rag 182 
				else{
183 
					continue;
9456 vikram.rag 184 
				}
185 
				if(aliveItemsMap.get(sku) != null){
186 
					thriftItem = aliveItemsMap.get(sku);
187 
				}
9404 vikram.rag 188 
				else{
189 
					continue;
190 
				}
191 
				available=0;
192 
				reserve=0;
9532 vikram.rag 193 
				total_warehouse_held=0;
194 
				heldForSource=0;
9404 vikram.rag 195 
				total_held=0;
196 
				nlc=0;
197 
				List<Warehouse> vendor_warehouses=null;
198 
				SnapdealItemForInventory item;
199 
				if(availability.get(thriftItem.getId())!=null){
200 
					ItemInventory iteminventory = availability.get(thriftItem.getId());
201 
					Map<Long,Long> itemavailability = new HashMap<Long,Long>();
202 
					itemavailability = iteminventory.getAvailability();
203 
					if (thriftItem.isIsWarehousePreferenceSticky() && thriftItem.getPreferredVendor()!=0){
204 
						//System.out.println("Item id "+thriftItem.getId()+".Found prefered vendor and warehouse is marked sticky (Calculating availability)"+thriftItem.getPreferredVendor());
205 
						vendor_warehouses = inventoryClient.getWarehouses(WarehouseType.THIRD_PARTY,InventoryType.GOOD , thriftItem.getPreferredVendor(), 0, 0);
206 
						vendor_warehouses.addAll(ours_warehouses);
207 
						for (Warehouse warehouse:vendor_warehouses){
9456 vikram.rag 208 
							if(warehouse.getBillingWarehouseId()!=7){
9613 vikram.rag 209 
								if(warehouse.getLogisticsLocation().equals(WarehouseLocation.Delhi) && warehouse.getWarehouseType().equals(WarehouseType.THIRD_PARTY) && warehouse.getVendor().getId()!=1){
9605 vikram.rag 210 
 
211 
								}
212 
								else{
213 
									continue;
214 
								}
9456 vikram.rag 215 
							}
9404 vikram.rag 216 
							in.shop2020.model.v1.inventory.IgnoredInventoryUpdateItems ignoredItem = new in.shop2020.model.v1.inventory.IgnoredInventoryUpdateItems();
217 
							ignoredItem.setItemId(thriftItem.getId());
218 
							ignoredItem.setWarehouseId(warehouse.getId());
219 
							if (itemavailability.get(warehouse.getId())!=null && !thirdpartywarehouseids.contains(warehouse.getId()) && !ignoreItems.contains(ignoredItem)){
220 
								try{
221 
									nlc = inventoryClient.getNlcForWarehouse(warehouse.getId(),thriftItem.getId());
222 
								}
223 
								catch(TTransportException e){
224 
									inventoryClient = inventoryServiceClient.getClient();
225 
									nlc = inventoryClient.getNlcForWarehouse(warehouse.getId(),thriftItem.getId());
226 
								}
227 
								maxnlc = catalogClient.getSnapdealItem(thriftItem.getId()).getMaxNlc();
9613 vikram.rag 228 
 
9517 vikram.rag 229 
								//System.out.println("itemId:" + thriftItem.getId() + "\tmaxnlc: " + maxnlc + "\tnlc:" + nlc + "\twid:" + warehouse.getId() );
9404 vikram.rag 230 
								if(nlc !=0 && (maxnlc >= nlc)){
9532 vikram.rag 231 
									total_warehouse_held = inventoryClient.getHoldInventoryDetailForItemForWarehouseIdExceptSource(thriftItem.getId(), warehouse.getId(), 0);
232 
									heldForSource = heldForSource + total_warehouse_held - inventoryClient.getHoldInventoryDetailForItemForWarehouseIdExceptSource(thriftItem.getId(), warehouse.getId(), 7);
233 
									available = available + itemavailability.get(warehouse.getId());
234 
									total_held = total_held + total_warehouse_held;
9517 vikram.rag 235 
									//System.out.println("itemId:" + thriftItem.getId() + "\ttotal_held: " + total_held + "\theldForSource:" + heldForSource + "\tavailable:" + available);
9404 vikram.rag 236 
								}
9413 vikram.rag 237 
								else if(maxnlc==0){
9532 vikram.rag 238 
									total_warehouse_held = inventoryClient.getHoldInventoryDetailForItemForWarehouseIdExceptSource(thriftItem.getId(), warehouse.getId(), 0);
239 
									heldForSource = heldForSource + total_warehouse_held - inventoryClient.getHoldInventoryDetailForItemForWarehouseIdExceptSource(thriftItem.getId(), warehouse.getId(), 7);
240 
									available = available + itemavailability.get(warehouse.getId());
241 
									total_held = total_held + total_warehouse_held;
9517 vikram.rag 242 
									//System.out.println("itemId:" + thriftItem.getId() + "\ttotal_held: " + total_held + "\theldForSource:" + heldForSource + "\tavailable:" + available);
9404 vikram.rag 243 
								}
244 
							}
245 
						}
246 
					}
247 
					else{
248 
						for (Map.Entry<Long,Long> entry :  itemavailability.entrySet()) {
9456 vikram.rag 249 
							if(allWarehousesMap.get(entry.getKey()).getBillingWarehouseId()!=7){
9613 vikram.rag 250 
								if(allWarehousesMap.get(entry.getKey()).getLogisticsLocation().equals(WarehouseLocation.Delhi) && allWarehousesMap.get(entry.getKey()).getWarehouseType().equals(WarehouseType.THIRD_PARTY) && allWarehousesMap.get(entry.getKey()).getVendor().getId()!=1){
9605 vikram.rag 251 
 
252 
								}
253 
								else{
254 
									continue;
255 
								}
9456 vikram.rag 256 
							}
9404 vikram.rag 257 
							in.shop2020.model.v1.inventory.IgnoredInventoryUpdateItems ignoredItem = new in.shop2020.model.v1.inventory.IgnoredInventoryUpdateItems();
258 
							ignoredItem.setItemId(thriftItem.getId());
259 
							ignoredItem.setWarehouseId(entry.getKey());
260 
							if(!thirdpartywarehouseids.contains(entry.getKey()) && !ignoreItems.contains(ignoredItem)){
9509 vikram.rag 261 
 
9404 vikram.rag 262 
								nlc = inventoryClient.getNlcForWarehouse(entry.getKey(),thriftItem.getId());
263 
								try{
264 
									maxnlc = catalogClient.getSnapdealItem(thriftItem.getId()).getMaxNlc();
265 
								}
266 
								catch(TTransportException e){
267 
									catalogClient = catalogServiceClient.getClient();
268 
									maxnlc = catalogClient.getSnapdealItem(thriftItem.getId()).getMaxNlc();
269 
								}
9517 vikram.rag 270 
								//System.out.println("itemId:" + thriftItem.getId() + "\tmaxnlc: " + maxnlc + "\tnlc:" + nlc + "\twid:" + entry.getKey() );
9404 vikram.rag 271 
								if(nlc !=0 && (maxnlc >= nlc)){
9532 vikram.rag 272 
									total_warehouse_held = inventoryClient.getHoldInventoryDetailForItemForWarehouseIdExceptSource(thriftItem.getId(), entry.getKey(), 0);
273 
									heldForSource = heldForSource + total_warehouse_held - inventoryClient.getHoldInventoryDetailForItemForWarehouseIdExceptSource(thriftItem.getId(), entry.getKey(), 7);
274 
									available =  available + entry.getValue();
275 
									total_held = total_held + total_warehouse_held;
9517 vikram.rag 276 
									//System.out.println("itemId:" + thriftItem.getId() + "\ttotal_held: " + total_held + "\theldForSource:" + heldForSource + "\tavailable:" + available);
9404 vikram.rag 277 
								}
9413 vikram.rag 278 
								else if(maxnlc==0){
9532 vikram.rag 279 
									total_warehouse_held = inventoryClient.getHoldInventoryDetailForItemForWarehouseIdExceptSource(thriftItem.getId(), entry.getKey(), 0);
280 
									heldForSource = heldForSource + total_warehouse_held - inventoryClient.getHoldInventoryDetailForItemForWarehouseIdExceptSource(thriftItem.getId(), entry.getKey(), 7);
281 
									available = available + itemavailability.get(entry.getKey());
282 
									total_held = total_held + total_warehouse_held;
9517 vikram.rag 283 
									//System.out.println("itemId:" + thriftItem.getId() + "\ttotal_held: " + total_held + "\theldForSource:" + heldForSource + "\tavailable:" + available);
9413 vikram.rag 284 
								}
285 
 
9404 vikram.rag 286 
							}
287 
						}
288 
					}
289 
					Map<Long,Long> itemreserve = new HashMap<Long,Long>();
290 
					itemreserve = iteminventory.getReserved();
291 
					if (thriftItem.isIsWarehousePreferenceSticky() && thriftItem.getPreferredVendor()!=0){
292 
						//System.out.println("Item id "+thriftItem.getId()+".Found prefered vendor and warehouse is marked sticky (Calculating Reserve)"+thriftItem.getPreferredVendor());
293 
						for (Warehouse warehouse:vendor_warehouses){
9456 vikram.rag 294 
							if(warehouse.getBillingWarehouseId()!=7){
9613 vikram.rag 295 
								if(warehouse.getLogisticsLocation().equals(WarehouseLocation.Delhi) && warehouse.getWarehouseType().equals(WarehouseType.THIRD_PARTY) && warehouse.getVendor().getId()!=1){
9605 vikram.rag 296 
 
297 
								}
298 
								else{
299 
									continue;
300 
								}
9456 vikram.rag 301 
							}
9404 vikram.rag 302 
							in.shop2020.model.v1.inventory.IgnoredInventoryUpdateItems ignoredItem = new in.shop2020.model.v1.inventory.IgnoredInventoryUpdateItems();
303 
							ignoredItem.setItemId(thriftItem.getId());
304 
							ignoredItem.setWarehouseId(warehouse.getId());
305 
							if (itemreserve.get(warehouse.getId())!=null && !thirdpartywarehouseids.contains(warehouse.getId()) && !ignoreItems.contains(warehouse.getId())){
306 
								nlc = inventoryClient.getNlcForWarehouse(warehouse.getId(),thriftItem.getId());
307 
								maxnlc = catalogClient.getSnapdealItem(thriftItem.getId()).getMaxNlc();
9517 vikram.rag 308 
								//System.out.println("itemId:" + thriftItem.getId() + "\tmaxnlc: " + maxnlc + "\tnlc:" + nlc + "\twid:" + warehouse.getId() );
9404 vikram.rag 309 
								if(nlc !=0 && (maxnlc >= nlc)){
310 
									reserve = reserve + itemreserve.get(warehouse.getId());
9517 vikram.rag 311 
									//System.out.println("itemId:" + thriftItem.getId() + "\ttotal_held: " + total_held + "\theldForSource:" + heldForSource + "\treserve:" + reserve);
9404 vikram.rag 312 
								}
9413 vikram.rag 313 
								else if(maxnlc==0){
314 
									reserve = reserve + itemreserve.get(warehouse.getId());
9517 vikram.rag 315 
									//System.out.println("itemId:" + thriftItem.getId() + "\ttotal_held: " + total_held + "\theldForSource:" + heldForSource + "\treserve:" + reserve);
9413 vikram.rag 316 
								}
317 
 
9404 vikram.rag 318 
							}
319 
						}
320 
					}else{
321 
						for (Map.Entry<Long,Long> entry : itemreserve.entrySet()) {
9456 vikram.rag 322 
							if(allWarehousesMap.get(entry.getKey()).getBillingWarehouseId()!=7){
9613 vikram.rag 323 
								if(allWarehousesMap.get(entry.getKey()).getLogisticsLocation().equals(WarehouseLocation.Delhi) && allWarehousesMap.get(entry.getKey()).getWarehouseType().equals(WarehouseType.THIRD_PARTY) && allWarehousesMap.get(entry.getKey()).getVendor().getId()!=1){
9605 vikram.rag 324 
 
325 
								}
326 
								else{
327 
									continue;
328 
								}
9456 vikram.rag 329 
							}
9404 vikram.rag 330 
							in.shop2020.model.v1.inventory.IgnoredInventoryUpdateItems ignoredItem = new in.shop2020.model.v1.inventory.IgnoredInventoryUpdateItems();
331 
							ignoredItem.setItemId(thriftItem.getId());
332 
							ignoredItem.setWarehouseId(entry.getKey());
333 
							if(!thirdpartywarehouseids.contains(entry.getKey()) && !ignoreItems.contains(ignoredItem)){
334 
								nlc = inventoryClient.getNlcForWarehouse(entry.getKey(),thriftItem.getId());
335 
								maxnlc = catalogClient.getSnapdealItem(thriftItem.getId()).getMaxNlc();
9517 vikram.rag 336 
								//System.out.println("itemId:" + thriftItem.getId() + "\tmaxnlc: " + maxnlc + "\tnlc:" + nlc + "\twid:" + entry.getKey() );
9404 vikram.rag 337 
								if(nlc !=0 && (maxnlc >= nlc)){
338 
									reserve =  reserve + entry.getValue();
9517 vikram.rag 339 
									//System.out.println("itemId:" + thriftItem.getId() + "\ttotal_held: " + total_held + "\theldForSource:" + heldForSource + "\treserve:" + reserve);
9404 vikram.rag 340 
								}
9413 vikram.rag 341 
								else if(maxnlc==0){
342 
									reserve =  reserve + entry.getValue();
9517 vikram.rag 343 
									//System.out.println("itemId:" + thriftItem.getId() + "\ttotal_held: " + total_held + "\theldForSource:" + heldForSource + "\treserve:" + reserve);
9413 vikram.rag 344 
								}
345 
 
9404 vikram.rag 346 
							}
9413 vikram.rag 347 
 
9404 vikram.rag 348 
							else{
349 
								//System.out.println("skipping inventory for warehouse id " + entry.getKey());
350 
							}
351 
						}
352 
					}
9532 vikram.rag 353 
					item= new SnapdealItemForInventory(thriftItem.getId(),available,reserve,heldForSource,thriftItem.getHoldInventory(),thriftItem.getDefaultInventory(),total_held,thriftItem.isRisky(),thriftItem.getItemStatus());
9539 vikram.rag 354 
					//System.out.println("itemId:" + thriftItem.getId() + "\tavailable: " + available + "\treserve" + reserve + "\theldForSource:" + heldForSource + "\twebsite_hold:" + thriftItem.getHoldInventory() + "\tdefault_inv:" +thriftItem.getDefaultInventory());
9404 vikram.rag 355 
				}
356 
				else{
9532 vikram.rag 357 
					item = new SnapdealItemForInventory(thriftItem.getId(),0,0,0,thriftItem.getHoldInventory(),thriftItem.getDefaultInventory(),0,thriftItem.isRisky(),thriftItem.getItemStatus());
9539 vikram.rag 358 
					//System.out.println("itemId:" + thriftItem.getId() + "\tavailable: " + available + "\treserve" + reserve + "\theldForSource:" + heldForSource + "\twebsite_hold:" + thriftItem.getHoldInventory() + "\tdefault_inv:" +thriftItem.getDefaultInventory());
9404 vikram.rag 359 
				}
360 
 
361 
				//System.out.println(" Item details are " + thriftItem.getId() +" " + available + " " + reserve + " " + thriftItem.getHoldInventory() + " "+ thriftItem.getDefaultInventory() + " " + thriftItem.isRisky());
362 
				//System.out.println("+++++++++++++++++++++++");
363 
				allItemsInventoryMap.put(thriftItem.getId(),item);
364 
 
365 
			}
366 
 
367 
		} catch (TException e) {
368 
			// TODO Auto-generated catch block
369 
			e.printStackTrace();
370 
		}
371 
 
372 
	}
9456 vikram.rag 373 
	private static void fetchinventoryhistoryfromsnapdeal() throws UnsupportedEncodingException, TException{
9404 vikram.rag 374 
		HttpPost post = new HttpPost("http://seller.snapdeal.com/login_security_check?spring-security-redirect=http://seller.snapdeal.com/inventory&");
375 
		HttpGet get;
376 
		BufferedReader rd= null;
377 
		List<NameValuePair> nameValuePairs = new ArrayList<NameValuePair>();
378 
		nameValuePairs.add(new BasicNameValuePair("j_username",
379 
		"khushal.bhatia@saholic.com"));
380 
		nameValuePairs.add(new BasicNameValuePair("j_password",
381 
		"sonline"));
382 
		post.setEntity(new UrlEncodedFormEntity(nameValuePairs,"utf-8"));
383 
		HttpResponse response = null;
384 
		try {
385 
			response = client.execute(post);
386 
		} catch (ClientProtocolException e) {
387 
			// TODO Auto-generated catch block
388 
			e.printStackTrace();
389 
		} catch (IOException e) {
390 
			// TODO Auto-generated catch block
391 
			e.printStackTrace();
392 
		}
393 
		try {
394 
			rd = new BufferedReader(new InputStreamReader(response.getEntity().getContent()));
395 
		} catch (IllegalStateException e1) {
396 
			// TODO Auto-generated catch block
397 
			e1.printStackTrace();
398 
		} catch (IOException e1) {
399 
			// TODO Auto-generated catch block
400 
			e1.printStackTrace();
401 
		}
402 
		String line = "";
403 
		try {
404 
			while ((line = rd.readLine()) != null) {
9517 vikram.rag 405 
				//System.out.println(line);
9404 vikram.rag 406 
			}
407 
		} catch (IOException e) {
408 
			// TODO Auto-generated catch block
409 
			e.printStackTrace();
410 
		}
411 
		int i = 1;
412 
		Gson gson = new Gson();
9456 vikram.rag 413 
		inventoryhistoryItemMap = new HashMap<String,InventoryHistory>();
414 
		boolean exitfetchinghistory = true;
9519 vikram.rag 415 
		System.out.println("Fetching history inventory");
9456 vikram.rag 416 
		while(exitfetchinghistory){
9517 vikram.rag 417 
			//System.out.println("Fetching inventory history page " +i);
9456 vikram.rag 418 
			get = new HttpGet("http://seller.snapdeal.com/inventory/search?gridType=history&_search=false&nd="+time+"&rows=30&page="+i+"&sidx=&sord=dsc");
419 
			try {
420 
				response = client.execute(get);
421 
			} catch (ClientProtocolException e) {
422 
				// TODO Auto-generated catch block
423 
				e.printStackTrace();
424 
			} catch (IOException e) {
425 
				// TODO Auto-generated catch block
426 
				e.printStackTrace();
427 
			}
428 
			try {
429 
				rd = new BufferedReader(new InputStreamReader(response.getEntity().getContent()));
430 
			} catch (IllegalStateException e) {
431 
				// TODO Auto-generated catch block
432 
				e.printStackTrace();
433 
			} catch (IOException e) {
434 
				// TODO Auto-generated catch block
435 
				e.printStackTrace();
436 
			}
437 
			InventoryHistoryItems inventoryhistoryitems = (InventoryHistoryItems) gson.fromJson(rd, InventoryHistoryItems.class);
438 
			if(inventoryhistoryitems.getRows().size()!=0){
439 
				//System.out.println("Parsing page " + i);
440 
				for(InventoryHistory inventoryhistory : inventoryhistoryitems.getRows()){
441 
					if(inventoryhistory.getUpdateTime() > lastUpdatedInventoryTime){
442 
						if(inventoryhistoryItemMap.containsKey(inventoryhistory.getSellerSku())){
443 
							if(inventoryhistoryItemMap.get(inventoryhistory.getSellerSku()).getUpdateTime() < inventoryhistory.getUpdateTime()){
444 
								inventoryhistoryItemMap.put(inventoryhistory.getSellerSku(),inventoryhistory);
445 
							}
446 
						}
447 
						else{
448 
							inventoryhistoryItemMap.put(inventoryhistory.getSellerSku(),inventoryhistory);
449 
						}
450 
					}
451 
					else{
452 
						exitfetchinghistory = false;
453 
					}
454 
				}
455 
			}
456 
			else{
457 
				exitfetchinghistory = false;
458 
			}
459 
			i++;
460 
		}
9580 vikram.rag 461 
		if(inventoryhistoryItemMap.entrySet().size()==0){
462 
			try {
463 
				mailer.sendSSLMessage(sendTo,"Error : Last Inventory Sent still not updated"+ sdf.format(System.currentTimeMillis()),"This e-mail is sent when there is some time lag on inventory updation on snapdeal ", emailFromAddress, password, new ArrayList<File>());
464 
			} catch (MessagingException e) {
465 
				// TODO Auto-generated catch block
466 
				e.printStackTrace();
467 
			}
468 
		}
9495 vikram.rag 469 
		InventoryClient inventoryServiceClient = new InventoryClient();
470 
		in.shop2020.model.v1.inventory.InventoryService.Client inventoryClient = inventoryServiceClient.getClient();
471 
		List<SnapdealInventoryItem> snapdealInventoryItemHistoryList = inventoryClient.getSnapdealInventorySnapshot();
472 
		if(snapdealInventoryItemHistoryList.size()>0){
473 
			for(SnapdealInventoryItem snapdealInventoryItem:snapdealInventoryItemHistoryList){
474 
				if(itemSnapdealMap.containsKey(snapdealInventoryItem.getItem_id())){
475 
					PendingOrderInventoryHistory pendingOrdersInventoryHistory = new PendingOrderInventoryHistory();
476 
					pendingOrdersInventoryHistory.setPendingOrders(snapdealInventoryItem.getPendingOrders());
477 
					pendingOrdersInventoryHistory.setInventoryHistory(snapdealInventoryItem.getAvailability());
478 
					pendingOrdersInventoryHistory.setLastUpdatedTimestamp(snapdealInventoryItem.getLastUpdatedOnSnapdeal());
479 
					PendingOrdersInventoryHistoryMap.put(itemSnapdealMap.get(snapdealInventoryItem.getItem_id()).getSkuAtSnapdeal(), pendingOrdersInventoryHistory);
480 
				}
481 
			}
482 
		}
483 
		PendingOrderInventoryHistory  pendingOrdersInventoryHistory;
484 
		for(Entry<String, InventoryHistory> inventoryHistoryItem :inventoryhistoryItemMap.entrySet()){
485 
			if(PendingOrdersInventoryHistoryMap.containsKey(inventoryHistoryItem.getValue().getSellerSku())){
486 
				pendingOrdersInventoryHistory = PendingOrdersInventoryHistoryMap.get(inventoryHistoryItem.getValue().getSellerSku());
487 
				pendingOrdersInventoryHistory.setInventoryHistory(Long.parseLong(inventoryHistoryItem.getValue().getNewValue()));
488 
				pendingOrdersInventoryHistory.setLastUpdatedTimestamp(inventoryHistoryItem.getValue().getUpdateTime());
489 
				PendingOrdersInventoryHistoryMap.put(inventoryHistoryItem.getValue().getSellerSku(),pendingOrdersInventoryHistory);
490 
			}
491 
			else{
492 
				pendingOrdersInventoryHistory = new PendingOrderInventoryHistory();
493 
				pendingOrdersInventoryHistory.setInventoryHistory(Long.parseLong(inventoryHistoryItem.getValue().getNewValue()));
494 
				pendingOrdersInventoryHistory.setLastUpdatedTimestamp(inventoryHistoryItem.getValue().getUpdateTime());
495 
				pendingOrdersInventoryHistory.setPendingOrders(0);
496 
				PendingOrdersInventoryHistoryMap.put(inventoryHistoryItem.getValue().getSellerSku(),pendingOrdersInventoryHistory);
497 
			}
498 
		}
9456 vikram.rag 499 
	}
500 
 
9495 vikram.rag 501 
	private static void fetchcurrentinventoryfromsnapdeal() throws UnsupportedEncodingException, TException{
9456 vikram.rag 502 
		/*client = new DefaultHttpClient();
503 
		HttpPost post = new HttpPost("http://seller.snapdeal.com/login_security_check?spring-security-redirect=http://seller.snapdeal.com/inventory&");
504 
		BufferedReader rd= null;
505 
		List<NameValuePair> nameValuePairs = new ArrayList<NameValuePair>();
506 
		nameValuePairs.add(new BasicNameValuePair("j_username",
507 
		"khushal.bhatia@saholic.com"));
508 
		nameValuePairs.add(new BasicNameValuePair("j_password",
509 
		"sonline"));
510 
		post.setEntity(new UrlEncodedFormEntity(nameValuePairs,"utf-8"));
511 
		HttpResponse response = null;
9404 vikram.rag 512 
		try {
9456 vikram.rag 513 
			response = client.execute(post);
514 
		} catch (ClientProtocolException e) {
9404 vikram.rag 515 
			// TODO Auto-generated catch block
516 
			e.printStackTrace();
9456 vikram.rag 517 
		} catch (IOException e) {
518 
			// TODO Auto-generated catch block
519 
			e.printStackTrace();
9404 vikram.rag 520 
		}
9456 vikram.rag 521 
		try {
522 
			rd = new BufferedReader(new InputStreamReader(response.getEntity().getContent()));
523 
		} catch (IllegalStateException e1) {
524 
			// TODO Auto-generated catch block
525 
			e1.printStackTrace();
526 
		} catch (IOException e1) {
527 
			// TODO Auto-generated catch block
528 
			e1.printStackTrace();
529 
		}
530 
		String line = "";
531 
		try {
532 
			while ((line = rd.readLine()) != null) {
533 
				System.out.println(line);
534 
			}
535 
		} catch (IOException e) {
536 
			// TODO Auto-generated catch block
537 
			e.printStackTrace();
538 
		}*/
539 
		int i = 1;
540 
		int items=0;
541 
		Gson gson = new Gson();
542 
		in.shop2020.model.v1.order.TransactionService.Client transactionClient = null;
9501 vikram.rag 543 
		currentInventoryItemList = new ArrayList<Inventory>();
9456 vikram.rag 544 
		HttpGet get;
545 
		HttpResponse response = null;
546 
		BufferedReader rd= null;
9519 vikram.rag 547 
		System.out.println("Fetching current inventory ");
9404 vikram.rag 548 
		while(true){
9517 vikram.rag 549 
			//System.out.println("Fetching current inventory page " +i);
9404 vikram.rag 550 
			get = new HttpGet("http://seller.snapdeal.com/inventory/search?gridType=normal&_search=false&nd="+time+"&rows="+30+"&page="+i+"&sidx=&sord=asc");
551 
			try {
552 
				response = client.execute(get);
553 
			} catch (ClientProtocolException e) {
554 
				// TODO Auto-generated catch block
555 
				e.printStackTrace();
556 
			} catch (IOException e) {
557 
				// TODO Auto-generated catch block
558 
				e.printStackTrace();
559 
			}
560 
			try {
561 
				rd = new BufferedReader(new InputStreamReader(response.getEntity().getContent()));
562 
			} catch (IllegalStateException e) {
563 
				// TODO Auto-generated catch block
564 
				e.printStackTrace();
565 
			} catch (IOException e) {
566 
				// TODO Auto-generated catch block
567 
				e.printStackTrace();
568 
			}
569 
			InventoryItems inventoryitems = (InventoryItems) gson.fromJson(rd, InventoryItems.class);
570 
			if(inventoryitems.getRows().size()!=0){
571 
				for(Inventory inventory : inventoryitems.getRows()){
9551 vikram.rag 572 
					if(snapdealItemMap.containsKey(inventory.getSellerSku())){
573 
						currentInventoryItemList.add(inventory);
574 
					}
9456 vikram.rag 575 
					items++;
576 
				}
577 
			}
578 
			else{
9552 vikram.rag 579 
				System.out.println("Fetched  " + items);
9456 vikram.rag 580 
				break;
581 
			}
582 
			i++;
583 
		}
584 
		in.shop2020.model.v1.catalog.CatalogService.Client catalogServiceClient = null;
9495 vikram.rag 585 
		SnapdealItemDetails snapdealitem = null;
9456 vikram.rag 586 
		long sku = 0;
587 
		long created_orders;
588 
		long pending_orders;
9571 vikram.rag 589 
		Map<Long, Long> itemIdCreatedOrdersMap = null;
9456 vikram.rag 590 
		try {
9467 vikram.rag 591 
			transactionClient = new TransactionClient("support_transaction_service_server_host","transaction_service_server_port").getClient();
9571 vikram.rag 592 
			System.out.println("Last Updated on Time is  " + lastUpdatedInventoryTime);
593 
			if(lastUpdatedInventoryTime > 0){
594 
				itemIdCreatedOrdersMap = transactionClient.getOrdersCreatedAfterTimestampForSource(lastUpdatedInventoryTime, 7);
9582 vikram.rag 595 
				System.out.println("Item id orders created map size "+ itemIdCreatedOrdersMap.entrySet().size());
9571 vikram.rag 596 
			}
9456 vikram.rag 597 
		} catch (TTransportException e1) {
598 
			// TODO Auto-generated catch block
599 
			e1.printStackTrace();
600 
		}
601 
		try {
602 
			catalogServiceClient = new CatalogClient().getClient();
603 
		} catch (TTransportException e1) {
604 
			// TODO Auto-generated catch block
605 
			e1.printStackTrace();
606 
		}
607 
		List<String> notMappedItems = new ArrayList<String>();
9571 vikram.rag 608 
 
9501 vikram.rag 609 
		for(Inventory inventory:currentInventoryItemList){
9456 vikram.rag 610 
			created_orders = 0;
611 
			pending_orders = 0;
9571 vikram.rag 612 
			snapdealitem = snapdealItemMap.get(inventory.getSellerSku());
613 
			if(snapdealitem==null){
614 
				notMappedItems.add(inventory.getSellerSku()+" "+inventory.getProductName());
615 
				System.out.println("Not Mapped  " + inventory.getSellerSku());
616 
				continue;
9404 vikram.rag 617 
			}
9571 vikram.rag 618 
			sku = snapdealitem.getItem_id();
9584 vikram.rag 619 
			if(sku!=0){
9592 vikram.rag 620 
				if(itemIdCreatedOrdersMap!=null && itemIdCreatedOrdersMap.containsKey(sku)){
9584 vikram.rag 621 
					created_orders = itemIdCreatedOrdersMap.get(sku);
622 
				}
9571 vikram.rag 623 
				System.out.println("Created orders for " + sku +" " + created_orders);
624 
			}
625 
			else{
626 
				continue;
627 
			}
9555 vikram.rag 628 
			if(PendingOrdersInventoryHistoryMap.containsKey(inventory.getSellerSku())){
9559 vikram.rag 629 
				System.out.println("Calculating Pending Orders for " + inventory.getSellerSku());
630 
				System.out.println("Current Inventory "+inventory.getAvailableInventory());
631 
				System.out.println("History Inventory "+PendingOrdersInventoryHistoryMap.get(inventory.getSellerSku()).getInventoryHistory());
632 
				System.out.println("Created Orders "+created_orders);
9587 vikram.rag 633 
				System.out.println("Old Pending Orders "+ PendingOrdersInventoryHistoryMap.get(inventory.getSellerSku()).getPendingOrders());
9604 vikram.rag 634 
				if(PendingOrdersInventoryHistoryMap.get(inventory.getSellerSku()).getLastUpdatedTimestamp() > lastUpdatedInventoryTime){
635 
					pending_orders = PendingOrdersInventoryHistoryMap.get(inventory.getSellerSku()).getPendingOrders() + PendingOrdersInventoryHistoryMap.get(inventory.getSellerSku()).getInventoryHistory() - inventory.getAvailableInventory() - created_orders;
636 
				}
637 
				else{
638 
					pending_orders = PendingOrdersInventoryHistoryMap.get(inventory.getSellerSku()).getPendingOrders();
639 
				}
9587 vikram.rag 640 
				System.out.println("New Pending Orders "+pending_orders);
9557 vikram.rag 641 
				PendingOrderInventoryHistory pendingOrderInventoryHistory = PendingOrdersInventoryHistoryMap.get(inventory.getSellerSku());
642 
				pendingOrderInventoryHistory.setPendingOrders(pending_orders);
643 
				PendingOrdersInventoryHistoryMap.put(inventory.getSellerSku(),pendingOrderInventoryHistory);
9555 vikram.rag 644 
			}
9556 vikram.rag 645 
			else{
9559 vikram.rag 646 
				System.out.print("Could not calculate pending orders " + inventory.getSellerSku() +"\n");
9563 vikram.rag 647 
				PendingOrderInventoryHistory pendingOrderInventoryHistory = new PendingOrderInventoryHistory();
648 
				pendingOrderInventoryHistory.setPendingOrders(pending_orders);
649 
				pendingOrderInventoryHistory.setInventoryHistory(inventory.getAvailableInventory());
9606 vikram.rag 650 
				pendingOrderInventoryHistory.setLastUpdatedTimestamp(System.currentTimeMillis());
9563 vikram.rag 651 
				PendingOrdersInventoryHistoryMap.put(inventory.getSellerSku(),pendingOrderInventoryHistory);
9556 vikram.rag 652 
			}
9456 vikram.rag 653 
			itemIdpendingOrdersMap.put(sku, pending_orders);
9528 vikram.rag 654 
 
9404 vikram.rag 655 
		}
9495 vikram.rag 656 
		List<SnapdealInventoryItem> snapdealInventoryItemList = new ArrayList<SnapdealInventoryItem>();
657 
		SnapdealInventoryItem snapdealInventoryItem;
658 
		for(Entry<String, PendingOrderInventoryHistory> pendingOrderInventoryHistory:PendingOrdersInventoryHistoryMap.entrySet()){
659 
			snapdealInventoryItem = new SnapdealInventoryItem();
660 
			if(snapdealItemMap.containsKey(pendingOrderInventoryHistory.getKey())){
661 
				snapdealInventoryItem.setItem_id(snapdealItemMap.get(pendingOrderInventoryHistory.getKey()).getItem_id());
662 
				snapdealInventoryItem.setPendingOrders(pendingOrderInventoryHistory.getValue().getPendingOrders());
663 
				snapdealInventoryItem.setAvailability(pendingOrderInventoryHistory.getValue().getInventoryHistory());
664 
				snapdealInventoryItem.setLastUpdatedOnSnapdeal(pendingOrderInventoryHistory.getValue().getLastUpdatedTimestamp());
665 
				snapdealInventoryItemList.add(snapdealInventoryItem);
666 
			}
667 
		}
668 
		InventoryClient inventoryServiceClient = new InventoryClient();
669 
		in.shop2020.model.v1.inventory.InventoryService.Client inventoryClient = inventoryServiceClient.getClient();
670 
		try {
671 
			inventoryClient.addOrUpdateAllSnapdealInventory(snapdealInventoryItemList);
672 
		} catch (TException e) {
673 
			// TODO Auto-generated catch block
674 
			e.printStackTrace();
675 
			inventoryClient = inventoryServiceClient.getClient();
676 
			inventoryClient.addOrUpdateAllSnapdealInventory(snapdealInventoryItemList);
677 
		}
678 
 
9404 vikram.rag 679 
	}
680 
 
681 
	@SuppressWarnings("deprecation")
682 
	public static void main(String[] args) throws NumberFormatException, TException, ClientProtocolException, IOException {
9456 vikram.rag 683 
		fetchinventoryhistoryfromsnapdeal();
9495 vikram.rag 684 
		fetchcurrentinventoryfromsnapdeal();
9404 vikram.rag 685 
		calculateinventory();
686 
		in.shop2020.model.v1.catalog.CatalogService.Client catalogServiceClient = null;
687 
		try {
688 
			catalogServiceClient = new CatalogClient().getClient();
689 
		} catch (TTransportException e) {
690 
			// TODO Auto-generated catch block
691 
			e.printStackTrace();
692 
		}
693 
		Client inventoryClient = new InventoryClient().getClient();
9420 vikram.rag 694 
		FileInputStream fis = new FileInputStream("/root/code/trunk/SnapDealFeeds/SellerInventory.xls");
9413 vikram.rag 695 
		Workbook hwb = new HSSFWorkbook(fis);
696 
		Sheet sheet = hwb.getSheetAt(0);
697 
		Row row;
9404 vikram.rag 698 
		int iterator=1;
9532 vikram.rag 699 
		long available,reserve,defaultinventory,holdinventory,heldorders=0,sent_inventory,totalheld,heldforsource,allocable;
9404 vikram.rag 700 
		SnapdealItemForInventory  inventoryItem;
9456 vikram.rag 701 
		StringBuffer outOfStockItems =new StringBuffer();
702 
		StringBuffer backInStockItems =new StringBuffer();
703 
		long sku = 0;
9502 vikram.rag 704 
		SnapdealItemDetails snapdealitem;
9501 vikram.rag 705 
		for(Inventory inventory:currentInventoryItemList){
9456 vikram.rag 706 
			//System.out.println(inventory.getSupc()+" "+inventory.getSellerSku()+ " " +inventory.getProductName()+" "+inventory.getAvailableInventory()+" "+inventory.isLive()+" "+itemIdpendingOrdersMap.get(Long.parseLong(inventory.getSellerSku())));
9508 vikram.rag 707 
			if(snapdealItemMap.containsKey(inventory.getSellerSku())){
708 
				snapdealitem = snapdealItemMap.get(inventory.getSellerSku());
709 
				sku =  snapdealitem.getItem_id();
710 
			}
711 
			else{
712 
				continue;
713 
			}
9404 vikram.rag 714 
			if(snapdealitem.getItem_id()!=0 && snapdealitem.isIsListedOnSnapdeal() && !snapdealitem.isSuppressInventoryFeed()){
9495 vikram.rag 715 
				inventoryItem = allItemsInventoryMap.get(sku);
9404 vikram.rag 716 
				if(inventoryItem==null){
717 
					continue;
718 
				}
9532 vikram.rag 719 
				available = inventoryItem.getAvailability();
9404 vikram.rag 720 
				reserve = inventoryItem.getReserve();
721 
				defaultinventory = inventoryItem.getDefaultInventory();
722 
				holdinventory = inventoryItem.getHoldInventory();
9532 vikram.rag 723 
				totalheld = inventoryItem.getTotalHeldInventory();
724 
				heldforsource = inventoryItem.getHeldForSource();
9555 vikram.rag 725 
 
9495 vikram.rag 726 
				if(itemIdpendingOrdersMap.containsKey(sku)){
727 
					heldorders = itemIdpendingOrdersMap.get(sku);
9458 vikram.rag 728 
					if(heldorders < 0){
729 
						heldorders = 0;
730 
					}
9456 vikram.rag 731 
				}
9539 vikram.rag 732 
				System.out.println("itemId: " + inventoryItem.getId() + "\trisky: " + inventoryItem.getRisky()+
733 
						"\tavailable: " + available + "\treserve: " + reserve + "\theldForSource:" + heldforsource +
9541 vikram.rag 734 
						"\twebsite_hold: " + holdinventory + "\ttotal_held: " +totalheld +"\tdefault_inv: "
9539 vikram.rag 735 
						+ defaultinventory + "\theldorders " + heldorders);
9404 vikram.rag 736 
				row =   sheet.getRow((short) iterator);
9555 vikram.rag 737 
 
9404 vikram.rag 738 
				if(inventoryItem.getRisky()){
9535 vikram.rag 739 
					allocable = available - reserve - totalheld - holdinventory;
740 
					if(allocable < 0){
741 
						allocable = 0;
742 
					}
9533 vikram.rag 743 
					sent_inventory = Math.round(allocable*2/3) + heldforsource - heldorders ;
9539 vikram.rag 744 
					//System.out.println("allocable" + allocable + "\t2/3allocable" + Math.round(allocable*2/3) +  "\theld for source" + heldforsource + "\ttotal held" + totalheld +"\theldorders" +  heldorders + "\tFinal Value is : " + (Math.round(allocable*2/3) +  heldforsource - heldorders));
9533 vikram.rag 745 
					if(sent_inventory < 0){
9415 vikram.rag 746 
						sent_inventory = 0;
9404 vikram.rag 747 
					}
748 
				}
749 
				else{
9535 vikram.rag 750 
					allocable = available - reserve - totalheld;
751 
					if(allocable < 0){
752 
						allocable = 0;
753 
					}
754 
					if((allocable + heldforsource ) > defaultinventory){
755 
						sent_inventory = Math.round(allocable*2/3) +  heldforsource - heldorders;
9539 vikram.rag 756 
						//System.out.println("actual" + allocable + "\t2/3actual" + Math.round(allocable*2/3) +  "\theld for source" + heldforsource + "\theldorders" +  heldorders + "\tFinal Value is : " + (Math.round(allocable*2/3) +  heldforsource - heldorders));
9533 vikram.rag 757 
						if(sent_inventory < 0){
758 
							sent_inventory = 0;
9404 vikram.rag 759 
						}
760 
					}
761 
					else{
762 
						if(defaultinventory > heldorders){
9415 vikram.rag 763 
							sent_inventory = defaultinventory - heldorders;
9404 vikram.rag 764 
						}
765 
						else{
9415 vikram.rag 766 
							sent_inventory = 0;
9404 vikram.rag 767 
						}
768 
					}
769 
				}
9456 vikram.rag 770 
				if(inventory.getAvailableInventory()!= sent_inventory){
771 
					row.getCell((short) 0).setCellValue(inventory.getSupc());
772 
					row.getCell((short) 1).setCellValue(inventory.getSellerSku());
773 
					row.getCell((short) 2).setCellValue(inventory.getProductName());
774 
					row.getCell((short) 3).setCellValue(inventory.getAvailableInventory());
775 
					row.getCell((short) 4).setCellValue(sent_inventory);
776 
					if(inventory.getAvailableInventory()!=0 && sent_inventory==0){
9459 vikram.rag 777 
						outOfStockItems.append(sku+ " " +inventory.getProductName()+" "+inventory.getAvailableInventory()+" "+sent_inventory+"\n");
9456 vikram.rag 778 
					}
779 
					if(inventory.getAvailableInventory()==0 && sent_inventory!=0){
9459 vikram.rag 780 
						backInStockItems.append(sku+ " " +inventory.getProductName()+" "+inventory.getAvailableInventory()+" "+sent_inventory+"\n");
9456 vikram.rag 781 
					}
782 
					if(inventory.isLive()){
783 
						row.getCell((short) 5).setCellValue("Yes");
784 
					}
785 
					else{
786 
						row.getCell((short) 5).setCellValue("No");
787 
					}
788 
					iterator++;
9404 vikram.rag 789 
				}
790 
			}
791 
			else{
792 
				continue;
793 
			}
794 
		}
9566 vikram.rag 795 
		if(iterator > 1){
9558 vikram.rag 796 
			FileOutputStream fileOut = null;
797 
			fis.close();
798 
			try {
799 
				//System.out.println("Before writing file ");
800 
				fileOut = new FileOutputStream(SNAPDEAL_INVENTORY_SHEET);
801 
			} catch (FileNotFoundException e) {
802 
				// TODO Auto-generated catch block
803 
				e.printStackTrace();
804 
			}
805 
			try {
9459 vikram.rag 806 
 
9558 vikram.rag 807 
				hwb.write(fileOut);
808 
			} catch (IOException e) {
809 
				// TODO Auto-generated catch block
810 
				e.printStackTrace();
811 
			}
812 
			HttpClient client = new DefaultHttpClient();
813 
			HttpPost post = new HttpPost("http://seller.snapdeal.com/login_security_check?spring-security-redirect=http://seller.snapdeal.com/inventory&");
814 
			BufferedReader rd= null;
815 
			List<NameValuePair> nameValuePairs = new ArrayList<NameValuePair>();
816 
			nameValuePairs.add(new BasicNameValuePair("j_username",
817 
			"khushal.bhatia@saholic.com"));
818 
			nameValuePairs.add(new BasicNameValuePair("j_password",
819 
			"sonline"));
820 
			post.setEntity(new UrlEncodedFormEntity(nameValuePairs,"utf-8"));
821 
			HttpResponse response = null;
822 
			String line;
823 
			try {
824 
				response = client.execute(post);
825 
				rd = new BufferedReader(new InputStreamReader(response.getEntity().getContent()));
826 
				while ((line = rd.readLine()) != null) {
827 
					System.out.println(line);
828 
				}
9404 vikram.rag 829 
 
9558 vikram.rag 830 
			} catch (ClientProtocolException e) {
831 
				// TODO Auto-generated catch block
832 
				e.printStackTrace();
833 
			} catch (IOException e) {
834 
				// TODO Auto-generated catch block
835 
				e.printStackTrace();
836 
			}
837 
			post = new HttpPost("http://seller.snapdeal.com/inventory/upload");
838 
			File file = new File(SNAPDEAL_INVENTORY_SHEET);
839 
			MultipartEntity mpEntity = new MultipartEntity();
840 
			ContentBody cbFile = new FileBody(file,"application/vnd.ms-excel");
841 
			mpEntity.addPart("file", cbFile);
842 
			post.setEntity(mpEntity);
9564 vikram.rag 843 
			response = client.execute(post);
9558 vikram.rag 844 
			try {
845 
				rd = new BufferedReader(new InputStreamReader(response.getEntity().getContent()));
846 
			} catch (IllegalStateException e1) {
847 
				// TODO Auto-generated catch block
848 
				e1.printStackTrace();
849 
			} catch (IOException e1) {
850 
				// TODO Auto-generated catch block
851 
				e1.printStackTrace();
852 
			}
853 
			line = "";
854 
			String feedresponse = null;
855 
			try {
856 
				while ((line = rd.readLine()) != null) {
857 
					System.out.println(line);
858 
					feedresponse = line;
859 
				}
860 
			} catch (IOException e) {
861 
				// TODO Auto-generated catch block
862 
				e.printStackTrace();
863 
			}
864 
			in.shop2020.model.v1.order.TransactionService.Client transactionClient = null;
865 
			long lastSentInventoryTime = System.currentTimeMillis();
866 
			try {
867 
				transactionClient = new TransactionClient("support_transaction_service_server_host","transaction_service_server_port").getClient();
868 
				transactionClient.updateSourceDetailTimestamp(7, lastSentInventoryTime);
869 
			} catch (Exception e) {
870 
				try {
871 
					transactionClient = new TransactionClient("support_transaction_service_server_host","transaction_service_server_port").getClient();
872 
					transactionClient.updateSourceDetailTimestamp(7, lastSentInventoryTime);
873 
				} catch (Exception ex) {
874 
					ex.printStackTrace();
875 
				}
876 
			}
877 
			String emailSubjectTxt = "Products back in stock on Snapdeal "+sdf.format(lastSentInventoryTime);
878 
			String text = backInStockItems.toString();
879 
			if(text.length() > 0){
880 
				try {
881 
					mailer.sendSSLMessage(sendTo, emailSubjectTxt, text, emailFromAddress, password, new ArrayList<File>());
882 
				} catch (MessagingException e) {
883 
					e.printStackTrace();
884 
				}
885 
			}
886 
			emailSubjectTxt = "Products out of stock on Snapdeal "+sdf.format(lastSentInventoryTime);
887 
			text = outOfStockItems.toString();
888 
			if(text.length() > 0){
889 
				try {
890 
					mailer.sendSSLMessage(sendTo, emailSubjectTxt, text, emailFromAddress, password, new ArrayList<File>());
891 
				} catch (MessagingException e) {
892 
					e.printStackTrace();
893 
				}
894 
			}
895 
			/*			List<File> files = new ArrayList<File>();
9516 vikram.rag 896 
			files.add(new File(SNAPDEAL_INVENTORY_SHEET));
9459 vikram.rag 897 
			try {
9516 vikram.rag 898 
				mailer.sendSSLMessage(sendTo,"Inventory File",feedresponse, emailFromAddress, password, files);
9459 vikram.rag 899 
			} catch (MessagingException e) {
900 
				e.printStackTrace();
901 
			}
9558 vikram.rag 902 
			 */
903 
			try {
904 
				mailer.sendSSLMessage(sendTo,"Snapdeal Inventory Updates sent for " +(iterator-1)+" items "+ sdf.format(System.currentTimeMillis()),feedresponse, emailFromAddress, password, new ArrayList<File>());
905 
			} catch (MessagingException e) {
906 
				e.printStackTrace();
907 
			}
9459 vikram.rag 908 
 
9558 vikram.rag 909 
		}
910 
		else{
911 
			try {
9580 vikram.rag 912 
				mailer.sendSSLMessage(sendTo,"No changes in Snapdeal inventory to update"+ sdf.format(System.currentTimeMillis()),"No change in Snapdeal Inventory to be updated ", emailFromAddress, password, new ArrayList<File>());
9558 vikram.rag 913 
			} catch (MessagingException e) {
914 
				e.printStackTrace();
915 
			}
916 
		}
9495 vikram.rag 917 
 
9528 vikram.rag 918 
 
9555 vikram.rag 919 
 
9404 vikram.rag 920 
	}
921 
 
922 
}