| 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) {
|