Subversion Repositories SmartDukaan

Rev

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

Rev 9240 Rev 9456
Line 109... Line 109...
109
		}
109
		}
110
		int duplicate_orders = 0;
110
		int duplicate_orders = 0;
111
		int new_orders = 0;
111
		int new_orders = 0;
112
		int processed_orders = 0;
112
		int processed_orders = 0;
113
		StringBuffer sb = new StringBuffer();
113
		StringBuffer sb = new StringBuffer();
-
 
114
		LineItem lineItem = null;
-
 
115
		CatalogService.Client catalogClient = null;
-
 
116
		SnapdealItem snapdealItem = null;
-
 
117
		double SellingPrice = 0;
-
 
118
		long sku;
114
		for(Order order:orders.getOrder()){
119
		for(Order order:orders.getOrder()){
115
			long subOrderId = (long) order.getSuborderId();
120
			long subOrderId = (long) order.getSuborderId();
116
			Client transaction_client = null;
121
			Client transaction_client = null;
117
			try {
122
			try {
118
				transaction_client = new TransactionClient().getClient();
123
				transaction_client = new TransactionClient().getClient();
Line 136... Line 141...
136
			System.out.println("User Id is " + user.getUserId());
141
			System.out.println("User Id is " + user.getUserId());
137
			txn.setCreatedOn(new Date().getTime());
142
			txn.setCreatedOn(new Date().getTime());
138
			txn.setTransactionStatus(TransactionStatus.INIT);
143
			txn.setTransactionStatus(TransactionStatus.INIT);
139
			txn.setStatusDescription("Order for Snapdeal ");
144
			txn.setStatusDescription("Order for Snapdeal ");
140
			List<in.shop2020.model.v1.order.Order> orderlist = new ArrayList<in.shop2020.model.v1.order.Order>();
145
			List<in.shop2020.model.v1.order.Order> orderlist = new ArrayList<in.shop2020.model.v1.order.Order>();
141
			LineItem lineItem = null;
-
 
142
			CatalogService.Client catalogClient = null;
-
 
143
			SnapdealItem snapdealItem = null;
-
 
144
			double SellingPrice = 0;
-
 
145
			try {
146
			try {
146
				catalogClient =  new CatalogClient("catalog_service_server_host_amazon","catalog_service_server_port").getClient();
147
				catalogClient =  new CatalogClient("catalog_service_server_host_amazon","catalog_service_server_port").getClient();
-
 
148
				sku = Long.parseLong(order.getSKUCode());
-
 
149
				try{
-
 
150
					snapdealItem = catalogClient.getSnapdealItem(Long.parseLong(order.getSKUCode()));
-
 
151
				}
-
 
152
				catch(NumberFormatException e){
147
				snapdealItem = catalogClient.getSnapdealItem(order.getSKUCode());
153
					snapdealItem = catalogClient.getSnapdealItembySkuAtSnapdeal(order.getSKUCode());
-
 
154
					if(snapdealItem.getItem_id()!=0){
-
 
155
						sku = snapdealItem.getItem_id();
-
 
156
					}
-
 
157
					else{
-
 
158
						sb.append(order.getSuborderId() +" "+"SKU not found "+"\n");
-
 
159
						continue;
-
 
160
					}
-
 
161
				}
148
				if(snapdealItem.getExceptionPrice()!=0 && snapdealItem.getItem_id()!=0 && (order.getSellingPricePerItem() <  snapdealItem.getExceptionPrice())){
162
				if(snapdealItem.getExceptionPrice()!=0 && snapdealItem.getItem_id()!=0 && (order.getSellingPricePerItem() <  snapdealItem.getExceptionPrice())){
149
					SellingPrice = snapdealItem.getExceptionPrice();
163
					SellingPrice = snapdealItem.getExceptionPrice();
150
				}
164
				}
151
				else{
165
				else{
152
					SellingPrice = order.getSellingPricePerItem();
166
					SellingPrice = order.getSellingPricePerItem();
153
				}
167
				}
154
				lineItem = createLineItem(order.getSKUCode(),SellingPrice);
168
				lineItem = createLineItem(sku,SellingPrice);
155
				if(lineItem == null){
169
				if(lineItem == null){
156
					sb.append(order.getSuborderId() +" "+"SKU not found "+"\n");
170
					sb.append(order.getSuborderId() +" "+"SKU not found "+"\n");
157
					continue;
171
					continue;
158
				}
172
				}
159
				lineItem.setExtra_info("SubOrderId = " + order.getSuborderId() + " ReferenceCode = " + order.getReferenceCode());
173
				lineItem.setExtra_info("SubOrderId = " + order.getSuborderId() + " ReferenceCode = " + order.getReferenceCode());
Line 215... Line 229...
215
			try {
229
			try {
216
				inventoryClient = new InventoryClient().getClient();
230
				inventoryClient = new InventoryClient().getClient();
217
				if(snapdealItem.getItem_id()!=0 && snapdealItem.getWarehouseId()!=0) {
231
				if(snapdealItem.getItem_id()!=0 && snapdealItem.getWarehouseId()!=0) {
218
					fulfillmentWarehouse = inventoryClient.getWarehouse(snapdealItem.getWarehouseId());
232
					fulfillmentWarehouse = inventoryClient.getWarehouse(snapdealItem.getWarehouseId());
219
				} else {
233
				} else {
220
					List<Long> itemAvailability = inventoryClient.getItemAvailabilityAtLocation(order.getSKUCode(), 1);
234
					List<Long> itemAvailability = inventoryClient.getItemAvailabilityAtLocation(sku, 1);
221
					fulfillmentWarehouse = inventoryClient.getWarehouse(itemAvailability.get(0));
235
					fulfillmentWarehouse = inventoryClient.getWarehouse(itemAvailability.get(0));
222
					if(fulfillmentWarehouse.getStateId()!=0){
236
					if(fulfillmentWarehouse.getStateId()!=0){
223
						fulfillmentWarehouse = inventoryClient.getWarehouse(7);
237
						fulfillmentWarehouse = inventoryClient.getWarehouse(7);
224
					}
238
					}
225
				}
239
				}
Line 417... Line 431...
417
			try {
431
			try {
418
				inventoryClient.reserveItemInWarehouse(lineItem.getItem_id(), fulfillmentWarehouse.getId(), 1, 
432
				inventoryClient.reserveItemInWarehouse(lineItem.getItem_id(), fulfillmentWarehouse.getId(), 1, 
419
						snapdealorder.getId(), snapdealorder.getCreated_timestamp(), snapdealorder.getPromised_shipping_time(), snapdealorder.getLineitems().get(0).getQuantity());
433
						snapdealorder.getId(), snapdealorder.getCreated_timestamp(), snapdealorder.getPromised_shipping_time(), snapdealorder.getLineitems().get(0).getQuantity());
420
			} catch (InventoryServiceException e1) {
434
			} catch (InventoryServiceException e1) {
421
				logger.error("Problem while reserving item in inventory service" + snapdealorder.getId());
435
				logger.error("Problem while reserving item in inventory service" + snapdealorder.getId());
422
				sb.append(order.getSuborderId() + " Could not reserve inventory for sku "+ order.getSKUCode() +"\n");
436
				sb.append(order.getSuborderId() + " Could not reserve inventory for sku "+ sku +"\n");
423
				continue;
437
				continue;
424
			} catch (TException e1) {
438
			} catch (TException e1) {
425
				logger.error("Problem with inventory service" + snapdealorder.getId());
439
				logger.error("Problem with inventory service" + snapdealorder.getId());
426
				sb.append(order.getSuborderId() + " Problem with inventory service while reserving inventory for sku "+ order.getSKUCode() +"\n");
440
				sb.append(order.getSuborderId() + " Problem with inventory service while reserving inventory for sku "+ sku +"\n");
427
				continue;
441
				continue;
428
			}
442
			}
429
			SnapdealOrder snapdealOrder = new SnapdealOrder();
443
			SnapdealOrder snapdealOrder = new SnapdealOrder();
430
			snapdealOrder.setOrderId(snapdealorder.getId());
444
			snapdealOrder.setOrderId(snapdealorder.getId());
431
			snapdealOrder.setSubOrderId(subOrderId);
445
			snapdealOrder.setSubOrderId(subOrderId);
432
			snapdealOrder.setReferenceCode(referenceCode);
446
			snapdealOrder.setReferenceCode(referenceCode);
433
			snapdealOrder.setProductName(productName);
447
			snapdealOrder.setProductName(productName);
434
			snapdealOrder.setSnapdealTxnDate(snapdealTxnDate.getTime());
448
			snapdealOrder.setSnapdealTxnDate(snapdealTxnDate.getTime());
435
			snapdealOrder.setListingPrice(order.getSellingPricePerItem());
449
			snapdealOrder.setListingPrice(order.getSellingPricePerItem());
-
 
450
			snapdealOrder.setMaxNlc(snapdealItem.getMaxNlc());
436
			try {
451
			try {
437
				transaction_client.createSnapdealOrder(snapdealOrder);
452
				transaction_client.createSnapdealOrder(snapdealOrder);
438
				new PaymentClient().getClient().updatePaymentDetails(paymentId, null, null, null, null, null, null, Long.toString(subOrderId), null, PaymentStatus.SUCCESS, null, null);
453
				new PaymentClient().getClient().updatePaymentDetails(paymentId, null, null, null, null, null, null, Long.toString(subOrderId), null, PaymentStatus.SUCCESS, null, null);
439
				
454
				
440
			} catch (TException e) {
455
			} catch (TException e) {