| 8488 |
amar.kumar |
1 |
package in.shop2020.support.controllers;
|
|
|
2 |
|
|
|
3 |
import java.io.File;
|
|
|
4 |
import java.io.FileInputStream;
|
|
|
5 |
import java.text.SimpleDateFormat;
|
|
|
6 |
import java.util.ArrayList;
|
|
|
7 |
import java.util.Calendar;
|
|
|
8 |
import java.util.Collection;
|
|
|
9 |
import java.util.Collections;
|
|
|
10 |
import java.util.Date;
|
|
|
11 |
import java.util.List;
|
|
|
12 |
|
|
|
13 |
import in.shop2020.logistics.DeliveryType;
|
|
|
14 |
import in.shop2020.logistics.LogisticsInfo;
|
|
|
15 |
import in.shop2020.logistics.LogisticsService;
|
|
|
16 |
import in.shop2020.logistics.PickUpType;
|
|
|
17 |
import in.shop2020.model.v1.catalog.CatalogService;
|
|
|
18 |
import in.shop2020.model.v1.catalog.CatalogServiceException;
|
|
|
19 |
import in.shop2020.model.v1.catalog.EbayItem;
|
|
|
20 |
import in.shop2020.model.v1.catalog.Item;
|
| 9456 |
vikram.rag |
21 |
import in.shop2020.model.v1.catalog.SnapdealItem;
|
| 8488 |
amar.kumar |
22 |
import in.shop2020.model.v1.inventory.InventoryService;
|
|
|
23 |
import in.shop2020.model.v1.inventory.InventoryServiceException;
|
| 8892 |
amar.kumar |
24 |
import in.shop2020.model.v1.inventory.InventoryType;
|
| 8488 |
amar.kumar |
25 |
import in.shop2020.model.v1.inventory.VendorItemPricing;
|
|
|
26 |
import in.shop2020.model.v1.inventory.Warehouse;
|
| 8892 |
amar.kumar |
27 |
import in.shop2020.model.v1.inventory.WarehouseType;
|
| 8488 |
amar.kumar |
28 |
import in.shop2020.model.v1.order.LineItem;
|
|
|
29 |
import in.shop2020.model.v1.order.Order;
|
|
|
30 |
import in.shop2020.model.v1.order.OrderSource;
|
|
|
31 |
import in.shop2020.model.v1.order.OrderStatus;
|
|
|
32 |
import in.shop2020.model.v1.order.OrderType;
|
|
|
33 |
import in.shop2020.model.v1.order.SnapdealOrder;
|
|
|
34 |
import in.shop2020.model.v1.order.SourceDetail;
|
|
|
35 |
import in.shop2020.model.v1.order.Transaction;
|
|
|
36 |
import in.shop2020.model.v1.order.TransactionStatus;
|
|
|
37 |
import in.shop2020.model.v1.order.TransactionService.Client;
|
|
|
38 |
import in.shop2020.model.v1.user.Address;
|
|
|
39 |
import in.shop2020.model.v1.user.User;
|
|
|
40 |
import in.shop2020.payments.Attribute;
|
|
|
41 |
import in.shop2020.payments.PaymentException;
|
|
|
42 |
import in.shop2020.payments.PaymentStatus;
|
|
|
43 |
import in.shop2020.thrift.clients.CatalogClient;
|
|
|
44 |
import in.shop2020.thrift.clients.InventoryClient;
|
|
|
45 |
import in.shop2020.thrift.clients.LogisticsClient;
|
|
|
46 |
import in.shop2020.thrift.clients.PaymentClient;
|
|
|
47 |
import in.shop2020.thrift.clients.TransactionClient;
|
|
|
48 |
import in.shop2020.thrift.clients.UserClient;
|
|
|
49 |
import in.shop2020.support.utils.ReportsUtils;
|
|
|
50 |
|
|
|
51 |
import javax.servlet.http.HttpServletRequest;
|
|
|
52 |
import javax.servlet.http.HttpSession;
|
|
|
53 |
|
|
|
54 |
import org.apache.commons.io.FileUtils;
|
|
|
55 |
import org.apache.poi.hssf.usermodel.HSSFWorkbook;
|
|
|
56 |
import org.apache.poi.ss.usermodel.Cell;
|
|
|
57 |
import org.apache.poi.ss.usermodel.Row;
|
|
|
58 |
import org.apache.poi.ss.usermodel.Sheet;
|
|
|
59 |
import org.apache.poi.ss.usermodel.Workbook;
|
|
|
60 |
import org.apache.struts2.convention.annotation.InterceptorRef;
|
|
|
61 |
import org.apache.struts2.convention.annotation.InterceptorRefs;
|
|
|
62 |
import org.apache.struts2.convention.annotation.Result;
|
|
|
63 |
import org.apache.struts2.convention.annotation.Results;
|
|
|
64 |
import org.apache.struts2.interceptor.ServletRequestAware;
|
|
|
65 |
import org.apache.thrift.TException;
|
|
|
66 |
import org.slf4j.Logger;
|
|
|
67 |
import org.slf4j.LoggerFactory;
|
|
|
68 |
|
|
|
69 |
import com.opensymphony.xwork2.ActionSupport;
|
|
|
70 |
|
|
|
71 |
@SuppressWarnings("serial")
|
|
|
72 |
@InterceptorRefs({
|
|
|
73 |
@InterceptorRef("defaultStack"),
|
|
|
74 |
@InterceptorRef("login")
|
|
|
75 |
})
|
|
|
76 |
@Results({
|
|
|
77 |
@Result(name="authfail", type="redirectAction", params = {"actionName" , "reports"})
|
|
|
78 |
})
|
|
|
79 |
public class SnapdealOrderCreatorController extends ActionSupport implements ServletRequestAware {
|
|
|
80 |
|
|
|
81 |
private static Logger logger = LoggerFactory.getLogger(SnapdealOrderCreatorController.class);
|
|
|
82 |
|
|
|
83 |
private HttpServletRequest request;
|
|
|
84 |
private HttpSession session;
|
|
|
85 |
|
|
|
86 |
private static final int SNAPDEAL_SOURCE_ID = 7;
|
|
|
87 |
|
|
|
88 |
private static final int COURIER_INDEX = 0;
|
|
|
89 |
private static final int PRODUCT_NAME_INDEX = 1;
|
|
|
90 |
private static final int REFERENCE_CODE_INDEX = 2;
|
|
|
91 |
private static final int SUBORDER_ID_INDEX = 3;
|
|
|
92 |
private static final int ITEMID_INDEX = 4;
|
|
|
93 |
private static final int AWB_INDEX = 5;
|
|
|
94 |
private static final int TRANSACTION_DATE_INDEX = 6;
|
|
|
95 |
private static final int BUYER_NAME_INDEX = 8;
|
|
|
96 |
private static final int CITY_INDEX = 9;
|
|
|
97 |
private static final int STATE_INDEX = 10;
|
|
|
98 |
private static final int PINCODE_INDEX = 11;
|
|
|
99 |
private static final int AMOUNT_INDEX = 12;
|
|
|
100 |
private static final int WAREHOUSE_ID_INDEX = 14;
|
|
|
101 |
private static final int OVERRIDE_BILLING_PRICE_INDEX = 15;
|
|
|
102 |
|
|
|
103 |
|
|
|
104 |
private static final int SNAPDEAL_GATEWAY_ID = 18;
|
|
|
105 |
|
|
|
106 |
private static final String FIRSTFLIGHT = "First Flight";
|
| 9110 |
vikram.rag |
107 |
private static final String DELHIVERY = "DELHIVERY";
|
|
|
108 |
private static final String BLUEDART = "Bluedart";
|
|
|
109 |
private static final String CHHOTU = "CHHOTU";
|
|
|
110 |
private static final String LAST_MILE = "LAST_MILE";
|
|
|
111 |
private static final String ECOM = "Ecom Express";
|
|
|
112 |
private static final String EWINGS = "EWINGS";
|
|
|
113 |
private static final String DTDC = "DTDC";
|
| 9188 |
vikram.rag |
114 |
private static final String WAREOLOG = "Wareolog";
|
| 9110 |
vikram.rag |
115 |
private static final String MIRAKLE = "MIRAKLE";
|
|
|
116 |
private static final String RAJIV_TRANSPORT = "RAJIV_TRANSPORT";
|
|
|
117 |
private static final String BLUEDART_HIGH_VALUE = "BLUEDART_HIGH_VALUE";
|
|
|
118 |
private static final String BLUEDART_SURFACE = "BLUEDART_SURFACE";
|
| 9188 |
vikram.rag |
119 |
private static final String BLUEDART_APEX = "BLUEDART APEX";
|
| 9110 |
vikram.rag |
120 |
private static final String ARAMEX = "ARAMEX";
|
|
|
121 |
private static final String GATI = "GATI";
|
|
|
122 |
private static final String INDIA_POST = "INDIA_POST";
|
|
|
123 |
private static final String FEDEX = "FEDEX";
|
|
|
124 |
private static final String IOT = "IOT";
|
| 9147 |
vikram.rag |
125 |
private static final String RED_EXP = "Red Express";
|
| 9110 |
vikram.rag |
126 |
private static final String GHARPAY = "GHARPAY";
|
| 9127 |
vikram.rag |
127 |
private static final String QUANTIUM = "Quantium Solutions";
|
| 9119 |
vikram.rag |
128 |
private static final String GATI_AIR = "GATI AIR";
|
| 9110 |
vikram.rag |
129 |
private static final String VDELIVER = "VDELIVER";
|
| 9136 |
vikram.rag |
130 |
private static final String OVERNITE_EXP = "Overnite Express";
|
| 10236 |
vikram.rag |
131 |
private static final String BIBHA_CARGO = "BIBHA CARGO AND COURIER PVT LTD";
|
| 9110 |
vikram.rag |
132 |
|
| 8488 |
amar.kumar |
133 |
private File orderDataFile;
|
|
|
134 |
private String orderDataFileName;
|
|
|
135 |
private String transactionId;
|
|
|
136 |
private String errorMsg = "";
|
|
|
137 |
private Long rowId = 0L;
|
| 9150 |
vikram.rag |
138 |
|
|
|
139 |
private long paymentId;
|
| 8488 |
amar.kumar |
140 |
|
|
|
141 |
public String create() throws TException {
|
|
|
142 |
File fileToCreate = null;
|
|
|
143 |
orderDataFileName = "OrderSheet_Snapdeal_"+(new Date().toString());
|
|
|
144 |
try {
|
|
|
145 |
fileToCreate = new File("/tmp/", this.orderDataFileName);
|
|
|
146 |
FileUtils.copyFile(this.orderDataFile, fileToCreate);
|
|
|
147 |
} catch (Exception e) {
|
|
|
148 |
logger.error("Error while writing order data file to the local file system for Snapdeal", e);
|
|
|
149 |
addActionError("Error while writing order data file to the local file system");
|
|
|
150 |
}
|
|
|
151 |
|
|
|
152 |
|
|
|
153 |
if(checkForErrors())
|
|
|
154 |
return "authsuccess";
|
|
|
155 |
|
|
|
156 |
//Parse the file and submit the data for update to the transaction service
|
|
|
157 |
Workbook wb = null;
|
|
|
158 |
try {
|
|
|
159 |
wb = new HSSFWorkbook(new FileInputStream(fileToCreate));
|
|
|
160 |
} catch (Exception e) {
|
|
|
161 |
logger.error("Unable to open the File for Order Creation for Snapdeal ", e);
|
|
|
162 |
setErrorMsg(getErrorMsg() + "Error in opening File for Order creation");
|
|
|
163 |
addActionError("Unable to open the File for Order creation");
|
|
|
164 |
}
|
|
|
165 |
if(checkForErrors())
|
|
|
166 |
return "authsuccess";
|
|
|
167 |
|
|
|
168 |
SourceDetail sourceDetail = null;
|
|
|
169 |
User user = null;
|
|
|
170 |
TransactionClient tsc = null;
|
|
|
171 |
try {
|
|
|
172 |
tsc = new TransactionClient();
|
|
|
173 |
sourceDetail = tsc.getClient().getSourceDetail(SNAPDEAL_SOURCE_ID);
|
|
|
174 |
} catch (Exception e) {
|
|
|
175 |
logger.error("Unable to establish connection to the transaction service while getting Snapdeal Source Detail", e);
|
|
|
176 |
setErrorMsg(getErrorMsg() + "Error in Order Service while getting Snapdeal Source Detail");
|
|
|
177 |
addActionError("Error in connecting to Order Service");
|
|
|
178 |
}
|
|
|
179 |
|
|
|
180 |
if(checkForErrors())
|
|
|
181 |
return "authsuccess";
|
|
|
182 |
|
|
|
183 |
try {
|
|
|
184 |
in.shop2020.model.v1.user.UserContextService.Client userClient = new UserClient().getClient();
|
|
|
185 |
user = userClient.getUserByEmail(sourceDetail.getEmail());
|
|
|
186 |
} catch (Exception e) {
|
|
|
187 |
logger.error("Unable to establish connection to the User service", e);
|
|
|
188 |
setErrorMsg(getErrorMsg() + "Unable to get Default Email for Snapdeal ");
|
|
|
189 |
addActionError("Unable to get Default Email for Snapdeal ");
|
|
|
190 |
}
|
|
|
191 |
|
|
|
192 |
if(checkForErrors())
|
|
|
193 |
return "authsuccess";
|
|
|
194 |
|
|
|
195 |
Sheet sheet = wb.getSheetAt(0);
|
|
|
196 |
Row firstRow = sheet.getRow(0);
|
| 9456 |
vikram.rag |
197 |
SnapdealItem snapdealItem;
|
|
|
198 |
in.shop2020.model.v1.catalog.CatalogService.Client catalogClient;
|
| 8488 |
amar.kumar |
199 |
for (Row row : sheet) {
|
|
|
200 |
long orderCountForRow = 0;
|
|
|
201 |
rowId++;
|
|
|
202 |
if(row.equals(firstRow))
|
|
|
203 |
continue;
|
|
|
204 |
try {
|
|
|
205 |
Transaction txn = new Transaction();
|
|
|
206 |
txn.setShoppingCartid(user.getActiveCartId());
|
|
|
207 |
txn.setCustomer_id(user.getUserId());
|
|
|
208 |
txn.setCreatedOn(new Date().getTime());
|
|
|
209 |
txn.setTransactionStatus(TransactionStatus.INIT);
|
|
|
210 |
txn.setStatusDescription("Order for Snapdeal ");
|
|
|
211 |
|
|
|
212 |
List<Order> orders = new ArrayList<Order>();
|
|
|
213 |
|
|
|
214 |
row.getCell(ITEMID_INDEX).setCellType(Cell.CELL_TYPE_STRING);
|
|
|
215 |
Long itemId = Long.parseLong(row.getCell(ITEMID_INDEX).getStringCellValue());
|
|
|
216 |
double listingPrice = 0;
|
|
|
217 |
double overriddenPrice = 0;
|
|
|
218 |
double totalPrice = 0;
|
|
|
219 |
Cell overriddenPriceCell = row.getCell(OVERRIDE_BILLING_PRICE_INDEX);
|
|
|
220 |
if(overriddenPriceCell != null && overriddenPriceCell .getCellType() != Cell.CELL_TYPE_BLANK) {
|
|
|
221 |
overriddenPrice = row.getCell(OVERRIDE_BILLING_PRICE_INDEX).getNumericCellValue();
|
|
|
222 |
}
|
|
|
223 |
|
|
|
224 |
totalPrice = row.getCell(AMOUNT_INDEX).getNumericCellValue();
|
|
|
225 |
listingPrice = totalPrice;
|
|
|
226 |
if(overriddenPrice>=1) {
|
|
|
227 |
totalPrice = overriddenPrice;
|
|
|
228 |
}
|
|
|
229 |
LineItem lineItem = null;
|
|
|
230 |
try {
|
|
|
231 |
lineItem = createLineItem(itemId, totalPrice);
|
| 9456 |
vikram.rag |
232 |
catalogClient = new CatalogClient("catalog_service_server_host_amazon","catalog_service_server_port").getClient();
|
|
|
233 |
snapdealItem = catalogClient.getSnapdealItem(itemId);
|
| 8569 |
amar.kumar |
234 |
Double subOrderId = row.getCell(SUBORDER_ID_INDEX).getNumericCellValue();
|
|
|
235 |
String refCode = row.getCell(REFERENCE_CODE_INDEX).getStringCellValue();
|
|
|
236 |
lineItem.setExtra_info("SubOrderId = " + subOrderId + " ReferenceCode = " + refCode);
|
| 8488 |
amar.kumar |
237 |
} catch (Exception tex) {
|
|
|
238 |
logger.error("Unable to create order for RowId " + rowId, tex);
|
|
|
239 |
setErrorMsg(getErrorMsg() + "<br>Unable to create lineitem using catalog info for RowId " + rowId);
|
|
|
240 |
continue;
|
|
|
241 |
}
|
|
|
242 |
Order t_order = new Order();
|
|
|
243 |
t_order.setCustomer_id(user.getUserId());
|
|
|
244 |
t_order.setCustomer_email(sourceDetail.getEmail());
|
|
|
245 |
row.getCell(BUYER_NAME_INDEX).setCellType(Cell.CELL_TYPE_STRING);
|
|
|
246 |
t_order.setCustomer_name(row.getCell(BUYER_NAME_INDEX).getStringCellValue());
|
| 9215 |
vikram.rag |
247 |
t_order.setCustomer_mobilenumber("+91-9999999999");
|
| 8488 |
amar.kumar |
248 |
t_order.setCustomer_address1("");
|
|
|
249 |
t_order.setCustomer_address2("");
|
|
|
250 |
t_order.setCustomer_city(row.getCell(CITY_INDEX).getStringCellValue());
|
| 10848 |
vikram.rag |
251 |
row.getCell(STATE_INDEX).setCellType(Cell.CELL_TYPE_STRING);
|
| 8488 |
amar.kumar |
252 |
t_order.setCustomer_state(row.getCell(STATE_INDEX).getStringCellValue());
|
|
|
253 |
row.getCell(PINCODE_INDEX).setCellType(Cell.CELL_TYPE_STRING);
|
|
|
254 |
t_order.setCustomer_pincode(row.getCell(PINCODE_INDEX).getStringCellValue());
|
|
|
255 |
t_order.setTotal_amount(lineItem.getTotal_price());
|
|
|
256 |
t_order.setTotal_weight(lineItem.getTotal_weight());
|
|
|
257 |
t_order.setLineitems(Collections.singletonList(lineItem));
|
| 8761 |
vikram.rag |
258 |
t_order.setStatus(OrderStatus.PAYMENT_PENDING);
|
| 8488 |
amar.kumar |
259 |
t_order.setStatusDescription("In Process");
|
|
|
260 |
t_order.setCreated_timestamp(new Date().getTime());
|
|
|
261 |
t_order.setOrderType(OrderType.B2C);
|
|
|
262 |
t_order.setCod(false);
|
|
|
263 |
try {
|
|
|
264 |
Calendar time = Calendar.getInstance();
|
|
|
265 |
time.add(Calendar.DAY_OF_MONTH, 1);
|
| 9288 |
vikram.rag |
266 |
if(time.get(Calendar.DAY_OF_WEEK)!=1){
|
|
|
267 |
t_order.setPromised_shipping_time(time.getTimeInMillis());
|
|
|
268 |
t_order.setExpected_shipping_time(time.getTimeInMillis());
|
|
|
269 |
}
|
|
|
270 |
else{
|
|
|
271 |
t_order.setPromised_shipping_time(time.getTimeInMillis()+24*60*60*1000);
|
|
|
272 |
t_order.setExpected_shipping_time(time.getTimeInMillis()+24*60*60*1000);
|
|
|
273 |
}
|
| 8488 |
amar.kumar |
274 |
time.add(Calendar.DAY_OF_MONTH, 3);
|
|
|
275 |
t_order.setPromised_delivery_time(time.getTimeInMillis());
|
|
|
276 |
t_order.setExpected_delivery_time(time.getTimeInMillis());
|
|
|
277 |
} catch(Exception e) {
|
|
|
278 |
addActionError("Error in updating Shipping or Delivery Time for row number " + rowId);
|
|
|
279 |
logger.error("Error in updating Shipping or Delivery Time for row number " + rowId,e);
|
|
|
280 |
continue;
|
|
|
281 |
}
|
|
|
282 |
|
|
|
283 |
InventoryService.Client inventoryClient = null;
|
|
|
284 |
Warehouse fulfillmentWarehouse= null;
|
|
|
285 |
try {
|
|
|
286 |
inventoryClient = new InventoryClient().getClient();
|
|
|
287 |
Cell warehouseCell = row.getCell(WAREHOUSE_ID_INDEX);
|
|
|
288 |
if(warehouseCell != null && warehouseCell.getCellType() != Cell.CELL_TYPE_BLANK) {
|
|
|
289 |
fulfillmentWarehouse = inventoryClient.getWarehouse(new Double(row.getCell(WAREHOUSE_ID_INDEX).getNumericCellValue()).longValue());
|
|
|
290 |
} else {
|
|
|
291 |
List<Long> itemAvailability = inventoryClient.getItemAvailabilityAtLocation(itemId, 1);
|
|
|
292 |
fulfillmentWarehouse = inventoryClient.getWarehouse(itemAvailability.get(0));
|
|
|
293 |
}
|
|
|
294 |
t_order.setFulfilmentWarehouseId(fulfillmentWarehouse.getId());
|
| 8892 |
amar.kumar |
295 |
|
|
|
296 |
long billingWarehouseId = 0;
|
|
|
297 |
if(fulfillmentWarehouse.getBillingWarehouseId()== 0) {
|
|
|
298 |
inventoryClient = new InventoryClient().getClient();
|
|
|
299 |
List<Warehouse> warehouses = inventoryClient.getWarehouses(WarehouseType.OURS, InventoryType.GOOD, fulfillmentWarehouse.getVendor().getId(), 0, 0);
|
|
|
300 |
for(Warehouse warehouse : warehouses) {
|
|
|
301 |
if(warehouse.getBillingWarehouseId()!=0) {
|
|
|
302 |
billingWarehouseId = warehouse.getBillingWarehouseId();
|
|
|
303 |
break;
|
|
|
304 |
}
|
|
|
305 |
}
|
|
|
306 |
} else {
|
|
|
307 |
billingWarehouseId = fulfillmentWarehouse.getBillingWarehouseId();
|
|
|
308 |
}
|
|
|
309 |
|
|
|
310 |
t_order.setWarehouse_id(billingWarehouseId);
|
|
|
311 |
//t_order.setWarehouse_id(fulfillmentWarehouse.getBillingWarehouseId());
|
| 8488 |
amar.kumar |
312 |
VendorItemPricing vendorItemPricing = inventoryClient.getItemPricing(lineItem.getItem_id(), fulfillmentWarehouse.getVendor().getId());
|
|
|
313 |
t_order.getLineitems().get(0).setTransfer_price(vendorItemPricing.getTransferPrice());
|
|
|
314 |
t_order.getLineitems().get(0).setNlc(vendorItemPricing.getNlc());
|
|
|
315 |
} catch (InventoryServiceException e) {
|
|
|
316 |
addActionError("Error in updating WarehouseId for row number " + rowId);
|
|
|
317 |
setErrorMsg(getErrorMsg() + "<br>Error in updating WarehouseId for row number " + rowId);
|
|
|
318 |
logger.error("Error in updating WarehouseId for row number " + rowId,e);
|
|
|
319 |
continue;
|
|
|
320 |
}
|
|
|
321 |
|
|
|
322 |
String provider = row.getCell(COURIER_INDEX).getStringCellValue();
|
| 9110 |
vikram.rag |
323 |
if(provider.equalsIgnoreCase(FIRSTFLIGHT)) {
|
| 8488 |
amar.kumar |
324 |
t_order.setLogistics_provider_id(12);
|
| 9110 |
vikram.rag |
325 |
} else if(provider.equalsIgnoreCase(DELHIVERY)) {
|
| 8488 |
amar.kumar |
326 |
t_order.setLogistics_provider_id(13);
|
| 9110 |
vikram.rag |
327 |
} else if(provider.equalsIgnoreCase(BLUEDART)) {
|
| 8508 |
amar.kumar |
328 |
t_order.setLogistics_provider_id(14);
|
| 9110 |
vikram.rag |
329 |
} else if(provider.equalsIgnoreCase(ECOM)) {
|
| 8796 |
anupam.sin |
330 |
t_order.setLogistics_provider_id(18);
|
| 9110 |
vikram.rag |
331 |
}else if(provider.equalsIgnoreCase(EWINGS)){
|
|
|
332 |
t_order.setLogistics_provider_id(19);
|
|
|
333 |
}
|
|
|
334 |
else if(provider.equalsIgnoreCase(DTDC)){
|
|
|
335 |
t_order.setLogistics_provider_id(20);
|
|
|
336 |
}
|
|
|
337 |
else if(provider.equalsIgnoreCase(WAREOLOG)){
|
|
|
338 |
t_order.setLogistics_provider_id(21);
|
|
|
339 |
}
|
|
|
340 |
else if(provider.equalsIgnoreCase(MIRAKLE)){
|
|
|
341 |
t_order.setLogistics_provider_id(22);
|
|
|
342 |
}
|
|
|
343 |
else if(provider.equalsIgnoreCase(RAJIV_TRANSPORT)){
|
|
|
344 |
t_order.setLogistics_provider_id(23);
|
|
|
345 |
}
|
|
|
346 |
else if(provider.equalsIgnoreCase(BLUEDART_HIGH_VALUE)){
|
|
|
347 |
t_order.setLogistics_provider_id(24);
|
|
|
348 |
}
|
|
|
349 |
else if(provider.equalsIgnoreCase(BLUEDART_SURFACE)){
|
|
|
350 |
t_order.setLogistics_provider_id(25);
|
|
|
351 |
}
|
|
|
352 |
else if(provider.equalsIgnoreCase(BLUEDART_APEX)){
|
|
|
353 |
t_order.setLogistics_provider_id(26);
|
|
|
354 |
}
|
|
|
355 |
else if(provider.equalsIgnoreCase(ARAMEX)){
|
|
|
356 |
t_order.setLogistics_provider_id(27);
|
|
|
357 |
}
|
|
|
358 |
else if(provider.equalsIgnoreCase(GATI)){
|
|
|
359 |
t_order.setLogistics_provider_id(28);
|
|
|
360 |
}
|
|
|
361 |
else if(provider.equalsIgnoreCase(INDIA_POST)){
|
|
|
362 |
t_order.setLogistics_provider_id(29);
|
|
|
363 |
}
|
|
|
364 |
else if(provider.equalsIgnoreCase(FEDEX)){
|
|
|
365 |
t_order.setLogistics_provider_id(30);
|
|
|
366 |
}
|
|
|
367 |
else if(provider.equalsIgnoreCase(IOT)){
|
|
|
368 |
t_order.setLogistics_provider_id(31);
|
|
|
369 |
}
|
|
|
370 |
else if(provider.equalsIgnoreCase(RED_EXP)){
|
|
|
371 |
t_order.setLogistics_provider_id(32);
|
|
|
372 |
}
|
|
|
373 |
else if(provider.equalsIgnoreCase(VDELIVER)){
|
|
|
374 |
t_order.setLogistics_provider_id(33);
|
|
|
375 |
}
|
|
|
376 |
else if(provider.equalsIgnoreCase(GHARPAY)){
|
|
|
377 |
t_order.setLogistics_provider_id(34);
|
|
|
378 |
}
|
|
|
379 |
else if(provider.equalsIgnoreCase(QUANTIUM)){
|
|
|
380 |
t_order.setLogistics_provider_id(35);
|
|
|
381 |
}
|
|
|
382 |
else if(provider.equalsIgnoreCase(GATI_AIR)){
|
|
|
383 |
t_order.setLogistics_provider_id(36);
|
| 9136 |
vikram.rag |
384 |
}
|
| 9138 |
vikram.rag |
385 |
else if(provider.equalsIgnoreCase(OVERNITE_EXP)){
|
| 9136 |
vikram.rag |
386 |
t_order.setLogistics_provider_id(37);
|
|
|
387 |
}
|
| 10236 |
vikram.rag |
388 |
else if(provider.equalsIgnoreCase(BIBHA_CARGO)){
|
|
|
389 |
t_order.setLogistics_provider_id(38);
|
|
|
390 |
}
|
| 9136 |
vikram.rag |
391 |
else {
|
| 8488 |
amar.kumar |
392 |
addActionError("Unknown logistics provider found for row number " + rowId);
|
|
|
393 |
setErrorMsg(getErrorMsg() + "<br>Unknown logistics provider found for row number " + rowId);
|
|
|
394 |
logger.error("Unknown logistics provider found for row number " + rowId);
|
|
|
395 |
continue;
|
|
|
396 |
}
|
|
|
397 |
|
|
|
398 |
row.getCell(AWB_INDEX).setCellType(Cell.CELL_TYPE_STRING);
|
|
|
399 |
t_order.setAirwaybill_no(row.getCell(AWB_INDEX).getStringCellValue());
|
|
|
400 |
t_order.setTracking_id(row.getCell(AWB_INDEX).getStringCellValue());
|
|
|
401 |
t_order.setTotal_amount(totalPrice);
|
|
|
402 |
t_order.setOrderType(OrderType.B2C);
|
|
|
403 |
t_order.setSource(SNAPDEAL_SOURCE_ID);
|
|
|
404 |
t_order.setOrderType(OrderType.B2C);
|
|
|
405 |
orders.add(t_order);
|
|
|
406 |
orderCountForRow++;
|
|
|
407 |
|
|
|
408 |
txn.setOrders(orders);
|
|
|
409 |
Client transaction_client = new TransactionClient().getClient();
|
|
|
410 |
try {
|
| 9819 |
vikram.rag |
411 |
row.getCell(SUBORDER_ID_INDEX).setCellType(Cell.CELL_TYPE_STRING);
|
|
|
412 |
long subOrderId = Long.parseLong(row.getCell(SUBORDER_ID_INDEX).getStringCellValue());
|
| 8488 |
amar.kumar |
413 |
String referenceCode = row.getCell(REFERENCE_CODE_INDEX).getStringCellValue();
|
|
|
414 |
String productName = row.getCell(PRODUCT_NAME_INDEX).getStringCellValue();
|
|
|
415 |
Date snapdealTxnDate = row.getCell(TRANSACTION_DATE_INDEX).getDateCellValue();
|
|
|
416 |
|
| 9818 |
vikram.rag |
417 |
if(transaction_client.snapdealOrderExists(String.valueOf(subOrderId), referenceCode)) {
|
| 8488 |
amar.kumar |
418 |
setErrorMsg(getErrorMsg() + "<br>Duplicate order for subOrderId " + subOrderId + " for row number " + rowId);
|
|
|
419 |
logger.error("Duplicate order for subOrderId " + subOrderId + " for row number " + rowId);
|
|
|
420 |
continue;
|
|
|
421 |
}
|
|
|
422 |
|
|
|
423 |
transactionId = String.valueOf(transaction_client.createTransaction(txn));
|
| 9150 |
vikram.rag |
424 |
paymentId = createPayment(user, (new Long(subOrderId)).toString(), totalPrice);
|
| 8488 |
amar.kumar |
425 |
|
|
|
426 |
logger.info("Successfully created transaction: " + transactionId + " for amount: " + totalPrice);
|
|
|
427 |
|
|
|
428 |
Transaction transaction = transaction_client.getTransaction(Long.parseLong(transactionId));
|
|
|
429 |
Order order = transaction.getOrders().get(0);
|
|
|
430 |
|
|
|
431 |
inventoryClient.reserveItemInWarehouse(itemId, fulfillmentWarehouse.getId(), 1,
|
|
|
432 |
order.getId(), order.getCreated_timestamp(), order.getPromised_shipping_time(), order.getLineitems().get(0).getQuantity());
|
|
|
433 |
|
|
|
434 |
|
|
|
435 |
SnapdealOrder snapdealOrder = new SnapdealOrder();
|
|
|
436 |
snapdealOrder.setOrderId(order.getId());
|
| 9818 |
vikram.rag |
437 |
snapdealOrder.setSubOrderId(String.valueOf(subOrderId));
|
| 8488 |
amar.kumar |
438 |
snapdealOrder.setReferenceCode(referenceCode);
|
|
|
439 |
snapdealOrder.setProductName(productName);
|
|
|
440 |
snapdealOrder.setSnapdealTxnDate(snapdealTxnDate.getTime());
|
|
|
441 |
snapdealOrder.setListingPrice(listingPrice);
|
| 9456 |
vikram.rag |
442 |
snapdealOrder.setMaxNlc(snapdealItem.getMaxNlc());
|
| 8488 |
amar.kumar |
443 |
transaction_client.createSnapdealOrder(snapdealOrder);
|
| 9818 |
vikram.rag |
444 |
new PaymentClient().getClient().updatePaymentDetails(paymentId, null, null, null, null, null, null, Long.toString(subOrderId), null, PaymentStatus.SUCCESS, null, null);
|
| 8488 |
amar.kumar |
445 |
|
|
|
446 |
} catch (Exception e) {
|
|
|
447 |
logger.error("Error while creating order for rowId " + rowId, e);
|
|
|
448 |
addActionError("Error while creating order for rowId " + rowId);
|
|
|
449 |
setErrorMsg(getErrorMsg() + "<br>Error while creating order for row number " + rowId);
|
|
|
450 |
continue;
|
|
|
451 |
}
|
|
|
452 |
} catch (Exception e) {
|
| 8748 |
amar.kumar |
453 |
logger.error("Error while creating order for row number " + rowId, e);
|
| 8488 |
amar.kumar |
454 |
setErrorMsg(getErrorMsg() + "<br>Error while creating order for row number " + rowId);
|
|
|
455 |
continue;
|
|
|
456 |
}
|
|
|
457 |
}
|
|
|
458 |
|
|
|
459 |
checkForErrors();
|
|
|
460 |
return "authsuccess";
|
|
|
461 |
}
|
|
|
462 |
|
|
|
463 |
private Date interchangeDateAndMonth(Date date) {
|
|
|
464 |
Date updatedDate = new Date(date.getTime());
|
|
|
465 |
updatedDate.setDate(date.getMonth() + 1);
|
|
|
466 |
updatedDate.setMonth(date.getDate() - 1);
|
|
|
467 |
return updatedDate;
|
|
|
468 |
}
|
|
|
469 |
|
|
|
470 |
private LineItem createLineItem(long itemId, double amount) throws CatalogServiceException, TException {
|
|
|
471 |
LineItem lineItem = new LineItem();
|
|
|
472 |
CatalogService.Client catalogClient = new CatalogClient().getClient();
|
|
|
473 |
Item item = catalogClient.getItem(itemId);
|
|
|
474 |
|
|
|
475 |
lineItem.setProductGroup(item.getProductGroup());
|
|
|
476 |
lineItem.setBrand(item.getBrand());
|
|
|
477 |
lineItem.setModel_number(item.getModelNumber());
|
|
|
478 |
lineItem.setModel_name(item.getModelName());
|
|
|
479 |
lineItem.setExtra_info(item.getFeatureDescription());
|
|
|
480 |
lineItem.setQuantity(1);
|
|
|
481 |
lineItem.setItem_id(item.getId());
|
|
|
482 |
lineItem.setUnit_weight(item.getWeight());
|
|
|
483 |
lineItem.setTotal_weight(item.getWeight());
|
|
|
484 |
lineItem.setUnit_price(amount);
|
|
|
485 |
lineItem.setTotal_price(amount);
|
|
|
486 |
|
|
|
487 |
if (item.getColor() == null || "NA".equals(item.getColor())) {
|
|
|
488 |
lineItem.setColor("");
|
|
|
489 |
} else {
|
|
|
490 |
lineItem.setColor(item.getColor());
|
|
|
491 |
}
|
|
|
492 |
return lineItem;
|
|
|
493 |
}
|
|
|
494 |
|
| 9150 |
vikram.rag |
495 |
private long createPayment(User user, String subOrderId, double amount) throws NumberFormatException, PaymentException, TException {
|
| 8488 |
amar.kumar |
496 |
in.shop2020.payments.PaymentService.Client client = new PaymentClient().getClient();
|
| 9150 |
vikram.rag |
497 |
return client.createPayment(user.getUserId(), amount, SNAPDEAL_GATEWAY_ID, Long.valueOf(transactionId), false);
|
| 8488 |
amar.kumar |
498 |
}
|
|
|
499 |
|
|
|
500 |
public String index() {
|
|
|
501 |
if(!ReportsUtils.canAccessReport((Long)session.getAttribute(ReportsUtils.ROLE), "/ebay-dashboard"))
|
|
|
502 |
return "authfail";
|
|
|
503 |
checkForErrors();
|
|
|
504 |
return "authsuccess";
|
|
|
505 |
}
|
|
|
506 |
|
|
|
507 |
private boolean checkForErrors(){
|
|
|
508 |
Collection<String> actionErrors = getActionErrors();
|
|
|
509 |
if(actionErrors != null && !actionErrors.isEmpty()){
|
|
|
510 |
for (String str : actionErrors) {
|
|
|
511 |
errorMsg += "<BR/>" + str;
|
|
|
512 |
}
|
|
|
513 |
return true;
|
|
|
514 |
}
|
|
|
515 |
return false;
|
|
|
516 |
}
|
|
|
517 |
|
|
|
518 |
@Override
|
|
|
519 |
public void setServletRequest(HttpServletRequest request) {
|
|
|
520 |
this.request = request;
|
|
|
521 |
this.session = request.getSession();
|
|
|
522 |
}
|
|
|
523 |
|
|
|
524 |
public String getErrorMsg() {
|
|
|
525 |
return errorMsg;
|
|
|
526 |
}
|
|
|
527 |
|
|
|
528 |
public void setErrorMsg(String errorMsg) {
|
|
|
529 |
this.errorMsg = errorMsg;
|
|
|
530 |
}
|
|
|
531 |
|
|
|
532 |
public Long getRowId() {
|
|
|
533 |
return rowId;
|
|
|
534 |
}
|
|
|
535 |
|
|
|
536 |
public void setRowId(Long rowId) {
|
|
|
537 |
this.rowId = rowId;
|
|
|
538 |
}
|
|
|
539 |
|
|
|
540 |
public File getOrderDataFile() {
|
|
|
541 |
return orderDataFile;
|
|
|
542 |
}
|
|
|
543 |
|
|
|
544 |
public void setOrderDataFile(File orderDataFile) {
|
|
|
545 |
this.orderDataFile = orderDataFile;
|
|
|
546 |
}
|
|
|
547 |
|
|
|
548 |
}
|