| Line 1... |
Line 1... |
| 1 |
package in.shop2020.serving.services;
|
1 |
package in.shop2020.serving.services;
|
| 2 |
|
2 |
|
| 3 |
import in.shop2020.model.v1.catalog.CatalogService;
|
3 |
import in.shop2020.model.v1.catalog.CatalogService;
|
| 4 |
import in.shop2020.model.v1.catalog.CatalogServiceException;
|
4 |
import in.shop2020.model.v1.catalog.CatalogServiceException;
|
| - |
|
5 |
import in.shop2020.model.v1.catalog.FlipkartItem;
|
| 5 |
import in.shop2020.model.v1.catalog.Item;
|
6 |
import in.shop2020.model.v1.catalog.Item;
|
| 6 |
import in.shop2020.model.v1.catalog.SnapdealItem;
|
- |
|
| 7 |
import in.shop2020.model.v1.inventory.InventoryService;
|
7 |
import in.shop2020.model.v1.inventory.InventoryService;
|
| 8 |
import in.shop2020.model.v1.inventory.InventoryServiceException;
|
8 |
import in.shop2020.model.v1.inventory.InventoryServiceException;
|
| 9 |
import in.shop2020.model.v1.inventory.InventoryType;
|
9 |
import in.shop2020.model.v1.inventory.InventoryType;
|
| 10 |
import in.shop2020.model.v1.inventory.VendorItemPricing;
|
10 |
import in.shop2020.model.v1.inventory.VendorItemPricing;
|
| 11 |
import in.shop2020.model.v1.inventory.Warehouse;
|
11 |
import in.shop2020.model.v1.inventory.Warehouse;
|
| Line 160... |
Line 160... |
| 160 |
logger.info("User is " + user.getEmail());
|
160 |
logger.info("User is " + user.getEmail());
|
| 161 |
} catch (Exception e) {
|
161 |
} catch (Exception e) {
|
| 162 |
logger.error("Unable to establish connection to the User service ", e);
|
162 |
logger.error("Unable to establish connection to the User service ", e);
|
| 163 |
}
|
163 |
}
|
| 164 |
logger.info("Before iterating orders in file");
|
164 |
logger.info("Before iterating orders in file");
|
| 165 |
SnapdealItem snapdealItem;
|
165 |
FlipkartItem flipkartItem;
|
| - |
|
166 |
String orderId,subOrderId,create_date,ship_date = null,skuAtFlipkart;
|
| - |
|
167 |
long sku = 0;
|
| 166 |
for(Order order : orders){
|
168 |
for(Order order : orders){
|
| 167 |
|
169 |
|
| 168 |
String orderId,subOrderId,create_date,ship_date = null;
|
- |
|
| 169 |
long sku;
|
- |
|
| 170 |
|
170 |
|
| 171 |
if(order.getExternalId().length()==0 || order.getOrderItemId().length()==0 ){
|
171 |
if(order.getExternalId().length()==0 || order.getOrderItemId().length()==0 ){
|
| 172 |
sb.append(" Could not parse order id " + order.getExternalId()+ " " + order.getExternalId() + "\n");
|
172 |
sb.append(" Could not parse order id " + order.getExternalId()+ " " + order.getExternalId() + "\n");
|
| 173 |
continue;
|
173 |
continue;
|
| 174 |
}
|
174 |
}
|
| 175 |
else{
|
175 |
else{
|
| Line 187... |
Line 187... |
| 187 |
continue;
|
187 |
continue;
|
| 188 |
}
|
188 |
}
|
| 189 |
if(order.getPickup_by_date()!=null){
|
189 |
if(order.getPickup_by_date()!=null){
|
| 190 |
ship_date = order.getPickup_by_date();
|
190 |
ship_date = order.getPickup_by_date();
|
| 191 |
}
|
191 |
}
|
| 192 |
if(order.getSku()==0L){
|
192 |
if(order.getSku().equals("")){
|
| 193 |
sb.append(orderId+" "+subOrderId + " Could not parse sku" +"\n");
|
193 |
sb.append(orderId+" "+subOrderId + " Could not parse sku" +"\n");
|
| 194 |
logger.info(orderId+" "+subOrderId + " Could not parse sku");
|
194 |
logger.info(orderId+" "+subOrderId + " Could not parse sku");
|
| 195 |
continue;
|
195 |
continue;
|
| 196 |
}
|
196 |
}
|
| 197 |
else{
|
197 |
else{
|
| 198 |
sku = order.getSku();
|
198 |
skuAtFlipkart = order.getSku();
|
| 199 |
if(sku ==827100000){
|
- |
|
| 200 |
sku = 8271;
|
- |
|
| 201 |
}
|
- |
|
| 202 |
logger.info(orderId+" "+subOrderId + " Processing sku " + sku);
|
199 |
logger.info(orderId+" "+subOrderId + " Processing sku " + skuAtFlipkart);
|
| 203 |
}
|
200 |
}
|
| 204 |
if(order.getStatusLabel().length()!=0 && (order.getStatusLabel().equalsIgnoreCase("Approved") || order.getStatusLabel().equalsIgnoreCase("confirmed"))){
|
201 |
if(order.getStatusLabel().length()!=0 && (order.getStatusLabel().equalsIgnoreCase("Approved") || order.getStatusLabel().equalsIgnoreCase("confirmed"))){
|
| 205 |
String status = order.getStatus();
|
202 |
String status = order.getStatus();
|
| 206 |
}
|
203 |
}
|
| 207 |
else{
|
204 |
else{
|
| Line 466... |
Line 463... |
| 466 |
sb.append(orderId + " "+ subOrderId + " Could not update delivery time" + " " + "\n");
|
463 |
sb.append(orderId + " "+ subOrderId + " Could not update delivery time" + " " + "\n");
|
| 467 |
exit = true;
|
464 |
exit = true;
|
| 468 |
continue;
|
465 |
continue;
|
| 469 |
}
|
466 |
}
|
| 470 |
}
|
467 |
}
|
| 471 |
snapdealItem = new CatalogClient("catalog_service_server_host_amazon","catalog_service_server_port").getClient().getSnapdealItem(sku);
|
468 |
flipkartItem = new CatalogClient("catalog_service_server_host_amazon","catalog_service_server_port").getClient().getFlipkartItemBySkyAtFlipkart(skuAtFlipkart);
|
| - |
|
469 |
sku = flipkartItem.getItem_id();
|
| 472 |
inventoryClient = new InventoryClient().getClient();
|
470 |
inventoryClient = new InventoryClient().getClient();
|
| 473 |
try {
|
471 |
try {
|
| 474 |
logger.info("Snapdeal Item id is " + snapdealItem.getItem_id());
|
472 |
logger.info("Flipkart Item id is " + flipkartItem.getItem_id());
|
| 475 |
if(snapdealItem.getItem_id()!=0 && snapdealItem.getWarehouseId()!=0) {
|
473 |
if(flipkartItem.getItem_id()!=0 && flipkartItem.getWarehouseId()!=0) {
|
| 476 |
logger.info("SnapdealItem Warehouse Id " + snapdealItem.getWarehouseId());
|
474 |
logger.info("SnapdealItem Warehouse Id " + flipkartItem.getWarehouseId());
|
| 477 |
fulfillmentWarehouse = inventoryClient.getWarehouse(snapdealItem.getWarehouseId());
|
475 |
fulfillmentWarehouse = inventoryClient.getWarehouse(flipkartItem.getWarehouseId());
|
| 478 |
logger.info("fulfillmentWarehouse is " + fulfillmentWarehouse.getId() + " " + fulfillmentWarehouse.getDisplayName() );
|
476 |
logger.info("fulfillmentWarehouse is " + fulfillmentWarehouse.getId() + " " + fulfillmentWarehouse.getDisplayName() );
|
| 479 |
|
477 |
|
| 480 |
} else {
|
478 |
} else {
|
| 481 |
List<Long> itemAvailability = inventoryClient.getItemAvailabilityAtLocation(sku, 1);
|
479 |
List<Long> itemAvailability = inventoryClient.getItemAvailabilityAtLocation(sku, 1);
|
| 482 |
fulfillmentWarehouse = inventoryClient.getWarehouse(itemAvailability.get(0));
|
480 |
fulfillmentWarehouse = inventoryClient.getWarehouse(itemAvailability.get(0));
|
| Line 610... |
Line 608... |
| 610 |
flipkartOrder.setFlipkartSubOrderId(subOrderId);
|
608 |
flipkartOrder.setFlipkartSubOrderId(subOrderId);
|
| 611 |
flipkartOrder.setFlipkartTxnDate(flipkartTxnDate.getTime());
|
609 |
flipkartOrder.setFlipkartTxnDate(flipkartTxnDate.getTime());
|
| 612 |
flipkartOrder.setEmiFee(emiFee);
|
610 |
flipkartOrder.setEmiFee(emiFee);
|
| 613 |
flipkartOrder.setOctroiFee(octroiFee);
|
611 |
flipkartOrder.setOctroiFee(octroiFee);
|
| 614 |
flipkartOrder.setShippingPrice(shippingPrice);
|
612 |
flipkartOrder.setShippingPrice(shippingPrice);
|
| 615 |
flipkartOrder.setMaxNlc(snapdealItem.getMaxNlc());
|
613 |
flipkartOrder.setMaxNlc(flipkartItem.getMaxNlc());
|
| 616 |
in.shop2020.model.v1.order.Attribute attribute = new in.shop2020.model.v1.order.Attribute();
|
614 |
in.shop2020.model.v1.order.Attribute attribute = new in.shop2020.model.v1.order.Attribute();
|
| 617 |
attribute.setName("Buyer Name");
|
615 |
attribute.setName("Buyer Name");
|
| 618 |
attribute.setValue(buyerName);
|
616 |
attribute.setValue(buyerName);
|
| 619 |
attributeList.add(attribute);
|
617 |
attributeList.add(attribute);
|
| 620 |
try {
|
618 |
try {
|