| 10367 |
vikram.rag |
1 |
package in.shop2020;
|
|
|
2 |
|
|
|
3 |
import in.shop2020.model.v1.catalog.Item;
|
|
|
4 |
import in.shop2020.model.v1.catalog.SnapdealItemDetails;
|
|
|
5 |
import in.shop2020.model.v1.catalog.status;
|
|
|
6 |
import in.shop2020.model.v1.inventory.InventoryType;
|
|
|
7 |
import in.shop2020.model.v1.inventory.ItemInventory;
|
|
|
8 |
import in.shop2020.model.v1.inventory.SnapdealInventoryItem;
|
|
|
9 |
import in.shop2020.model.v1.inventory.Warehouse;
|
|
|
10 |
import in.shop2020.model.v1.inventory.WarehouseLocation;
|
|
|
11 |
import in.shop2020.model.v1.inventory.WarehouseType;
|
|
|
12 |
import in.shop2020.thrift.clients.CatalogClient;
|
|
|
13 |
import in.shop2020.thrift.clients.InventoryClient;
|
|
|
14 |
import in.shop2020.thrift.clients.TransactionClient;
|
|
|
15 |
import in.shop2020.utils.GmailUtils;
|
|
|
16 |
import inventory.Inventory;
|
|
|
17 |
import inventory.InventoryHistory;
|
|
|
18 |
import inventory.InventoryHistoryItems;
|
|
|
19 |
import inventory.InventoryItems;
|
|
|
20 |
import inventory.PendingOrderInventoryHistory;
|
|
|
21 |
import inventory.SnapdealItemForInventory;
|
|
|
22 |
|
|
|
23 |
import java.io.BufferedReader;
|
|
|
24 |
import java.io.File;
|
|
|
25 |
import java.io.FileInputStream;
|
|
|
26 |
import java.io.FileNotFoundException;
|
|
|
27 |
import java.io.FileOutputStream;
|
|
|
28 |
import java.io.IOException;
|
|
|
29 |
import java.io.InputStreamReader;
|
|
|
30 |
import java.io.UnsupportedEncodingException;
|
|
|
31 |
import java.util.ArrayList;
|
|
|
32 |
import java.util.Calendar;
|
|
|
33 |
import java.util.GregorianCalendar;
|
|
|
34 |
import java.util.HashMap;
|
|
|
35 |
import java.util.List;
|
|
|
36 |
import java.util.Map;
|
|
|
37 |
import java.util.Map.Entry;
|
|
|
38 |
|
|
|
39 |
import javax.mail.MessagingException;
|
|
|
40 |
import org.apache.http.HttpResponse;
|
|
|
41 |
import org.apache.http.NameValuePair;
|
|
|
42 |
import org.apache.http.client.ClientProtocolException;
|
|
|
43 |
import org.apache.http.client.entity.UrlEncodedFormEntity;
|
|
|
44 |
import org.apache.http.client.methods.HttpGet;
|
|
|
45 |
import org.apache.http.client.methods.HttpPost;
|
|
|
46 |
import org.apache.http.entity.mime.MultipartEntity;
|
|
|
47 |
import org.apache.http.entity.mime.content.ContentBody;
|
|
|
48 |
import org.apache.http.entity.mime.content.FileBody;
|
|
|
49 |
import org.apache.http.impl.client.DefaultHttpClient;
|
|
|
50 |
import org.apache.http.message.BasicNameValuePair;
|
|
|
51 |
import org.apache.poi.hssf.usermodel.HSSFWorkbook;
|
|
|
52 |
import org.apache.poi.ss.usermodel.Row;
|
|
|
53 |
import org.apache.poi.ss.usermodel.Sheet;
|
|
|
54 |
import org.apache.poi.ss.usermodel.Workbook;
|
|
|
55 |
import org.apache.thrift.TException;
|
|
|
56 |
import org.apache.thrift.transport.TTransportException;
|
|
|
57 |
|
|
|
58 |
import com.google.gson.Gson;
|
|
|
59 |
|
|
|
60 |
public class UpdateSDInventoryUsingPanelNew {
|
|
|
61 |
private static final boolean PANEL = true;
|
|
|
62 |
private static long time = System.currentTimeMillis();
|
|
|
63 |
private static String SNAPDEAL_INVENTORY_SHEET;
|
|
|
64 |
private static Map<Long, SnapdealItemForInventory> allItemsInventoryMap = new HashMap<Long, SnapdealItemForInventory>();
|
|
|
65 |
private static ArrayList<Inventory> currentInventoryItemList;
|
|
|
66 |
static Map<Long,Long> itemIdpendingOrdersMap;
|
|
|
67 |
private static Map<String,InventoryHistory> inventoryhistoryItemMap;
|
|
|
68 |
private static DefaultHttpClient client = new DefaultHttpClient();
|
|
|
69 |
static Map<String,SnapdealItemDetails> snapdealItemMap = new HashMap<String,SnapdealItemDetails>();
|
|
|
70 |
static Map<Long,SnapdealItemDetails> itemSnapdealMap = new HashMap<Long,SnapdealItemDetails>();
|
|
|
71 |
static Map<String,PendingOrderInventoryHistory> PendingOrdersInventoryHistoryMap = new HashMap<String,PendingOrderInventoryHistory>();
|
|
|
72 |
static long lastUpdatedInventoryTime = 0;
|
|
|
73 |
static java.text.SimpleDateFormat sdf;
|
|
|
74 |
static String emailFromAddress;
|
|
|
75 |
static String password;
|
|
|
76 |
static GmailUtils mailer;
|
|
|
77 |
static String sendTo[];
|
|
|
78 |
static StringBuffer notMappedItems =new StringBuffer();
|
|
|
79 |
|
|
|
80 |
public static void initilaize() {
|
|
|
81 |
sdf = new java.text.SimpleDateFormat("yyyy-MM-dd-HH:mm:ss");
|
|
|
82 |
emailFromAddress = "build@shop2020.in";
|
|
|
83 |
password = "cafe@nes";
|
|
|
84 |
mailer = new GmailUtils();
|
|
|
85 |
sendTo = new String[]{"vikram.raghav@shop2020.in"};
|
|
|
86 |
/*sendTo = new String[]{ "sandeep.sachdeva@shop2020.in", "vikram.raghav@shop2020.in", "rajneesh.arora@shop2020.in",
|
|
|
87 |
"khushal.bhatia@shop2020.in","manoj.kumar@saholic.com","chaitnaya.vats@saholic.com",
|
|
|
88 |
"yukti.jain@shop2020.in","manisha.sharma@shop2020.in","chandan.kumar@shop2020.in","ankush.dhingra@shop2020.in"};
|
|
|
89 |
*/itemIdpendingOrdersMap = new HashMap<Long,Long>();
|
|
|
90 |
CatalogClient catalogServiceClient = null;
|
|
|
91 |
try {
|
|
|
92 |
catalogServiceClient = new CatalogClient();
|
|
|
93 |
} catch (TTransportException e1) {
|
|
|
94 |
e1.printStackTrace();
|
|
|
95 |
}
|
|
|
96 |
in.shop2020.model.v1.catalog.CatalogService.Client catalogClient = catalogServiceClient.getClient();
|
|
|
97 |
List<SnapdealItemDetails> allSnapdealItems = null;
|
|
|
98 |
try {
|
|
|
99 |
allSnapdealItems = catalogClient.getAllSnapdealItems();
|
|
|
100 |
} catch (TException e) {
|
|
|
101 |
|
|
|
102 |
e.printStackTrace();
|
|
|
103 |
}
|
|
|
104 |
for(SnapdealItemDetails snapdealItem:allSnapdealItems){
|
|
|
105 |
snapdealItemMap.put(snapdealItem.getSkuAtSnapdeal(),snapdealItem);
|
|
|
106 |
itemSnapdealMap.put(snapdealItem.getItem_id(), snapdealItem);
|
|
|
107 |
//System.out.println("Creating Item and Snapdeal Map " + snapdealItem.getItem_id() + " " + snapdealItem.getSkuAtSnapdeal());
|
|
|
108 |
}
|
|
|
109 |
in.shop2020.model.v1.order.TransactionService.Client transactionClient = null;
|
|
|
110 |
try {
|
|
|
111 |
transactionClient = new TransactionClient("support_transaction_service_server_host","transaction_service_server_port").getClient();
|
|
|
112 |
lastUpdatedInventoryTime = transactionClient.getSourceDetail(7).getLastUpdatedOn();
|
|
|
113 |
//System.out.println("Time is " + lastUpdatedInventoryTime);
|
|
|
114 |
} catch (Exception e) {
|
|
|
115 |
try {
|
|
|
116 |
transactionClient = new TransactionClient("support_transaction_service_server_host","transaction_service_server_port").getClient();
|
|
|
117 |
lastUpdatedInventoryTime = transactionClient.getSourceDetail(7).getLastUpdatedOn();
|
|
|
118 |
} catch (Exception ex) {
|
|
|
119 |
ex.printStackTrace();
|
|
|
120 |
}
|
|
|
121 |
}
|
|
|
122 |
|
|
|
123 |
}
|
|
|
124 |
|
|
|
125 |
private static void calculateinventory(){
|
|
|
126 |
CatalogClient catalogServiceClient = null;
|
|
|
127 |
Map<Long,ItemInventory> availability= new HashMap<Long,ItemInventory>();
|
|
|
128 |
try {
|
|
|
129 |
catalogServiceClient = new CatalogClient();
|
|
|
130 |
} catch (TTransportException e) {
|
|
|
131 |
|
|
|
132 |
e.printStackTrace();
|
|
|
133 |
}
|
|
|
134 |
in.shop2020.model.v1.catalog.CatalogService.Client catalogClient = catalogServiceClient.getClient();
|
|
|
135 |
try {
|
|
|
136 |
List<Item> aliveItems = catalogClient.getAllAliveItems();
|
|
|
137 |
Map<Long,Item> aliveItemsMap = new HashMap<Long,Item>();
|
|
|
138 |
for(in.shop2020.model.v1.catalog.Item thriftItem:aliveItems){
|
|
|
139 |
aliveItemsMap.put(thriftItem.getId(), thriftItem);
|
|
|
140 |
|
|
|
141 |
}
|
|
|
142 |
InventoryClient inventoryServiceClient = new InventoryClient();
|
|
|
143 |
try {
|
|
|
144 |
inventoryServiceClient = new InventoryClient();
|
|
|
145 |
} catch (TTransportException e) {
|
|
|
146 |
e.printStackTrace();
|
|
|
147 |
}
|
|
|
148 |
in.shop2020.model.v1.inventory.InventoryService.Client inventoryClient = inventoryServiceClient.getClient();
|
|
|
149 |
List<in.shop2020.model.v1.inventory.IgnoredInventoryUpdateItems> ignoreItems = inventoryClient.getIgnoredWarehouseidsAndItemids();
|
|
|
150 |
SNAPDEAL_INVENTORY_SHEET = "/home/snapdeal/snapdeal-inventory-"+time+".xls";
|
|
|
151 |
availability = inventoryClient.getInventorySnapshot(0);
|
|
|
152 |
List<Warehouse> allwarehouses = inventoryClient.getWarehouses(null,null,0,0,0);
|
|
|
153 |
Map<Long,Warehouse> allWarehousesMap = new HashMap<Long,Warehouse>();
|
|
|
154 |
for(Warehouse warehouse:allwarehouses){
|
|
|
155 |
allWarehousesMap.put(warehouse.getId(),warehouse);
|
|
|
156 |
}
|
|
|
157 |
List<Warehouse> warehouses = inventoryClient.getWarehouses(WarehouseType.OURS_THIRDPARTY,null,0,0,0);
|
|
|
158 |
List<Warehouse> ours_warehouses = inventoryClient.getWarehouses(WarehouseType.OURS, InventoryType.GOOD, 0, 0, 0);
|
|
|
159 |
List<Long> thirdpartywarehouseids = new ArrayList<Long>();
|
|
|
160 |
List<Long> oursGoodWarehouse = new ArrayList<Long>();
|
|
|
161 |
for(Warehouse warehouse:warehouses){
|
|
|
162 |
thirdpartywarehouseids.add(warehouse.getId());
|
|
|
163 |
}
|
|
|
164 |
for (Warehouse warehouse:ours_warehouses){
|
|
|
165 |
oursGoodWarehouse.add(warehouse.getId());
|
|
|
166 |
}
|
|
|
167 |
long available=0;
|
|
|
168 |
long reserve=0;
|
|
|
169 |
long total_warehouse_held=0;
|
|
|
170 |
long heldForSource=0;
|
|
|
171 |
long total_held=0;
|
|
|
172 |
double nlc=0;
|
|
|
173 |
double maxnlc=0;
|
|
|
174 |
Item thriftItem;
|
|
|
175 |
long sku = 0;
|
|
|
176 |
for(Inventory inventoryItem:currentInventoryItemList){
|
|
|
177 |
if(snapdealItemMap.containsKey(inventoryItem.getSellerSku())){
|
|
|
178 |
sku = snapdealItemMap.get(inventoryItem.getSellerSku()).getItem_id();
|
|
|
179 |
}
|
|
|
180 |
else{
|
|
|
181 |
continue;
|
|
|
182 |
}
|
|
|
183 |
if(aliveItemsMap.get(sku) != null){
|
|
|
184 |
thriftItem = aliveItemsMap.get(sku);
|
|
|
185 |
}
|
|
|
186 |
else{
|
|
|
187 |
continue;
|
|
|
188 |
}
|
|
|
189 |
available=0;
|
|
|
190 |
reserve=0;
|
|
|
191 |
total_warehouse_held=0;
|
|
|
192 |
heldForSource=0;
|
|
|
193 |
total_held=0;
|
|
|
194 |
nlc=0;
|
|
|
195 |
List<Warehouse> vendor_warehouses=null;
|
|
|
196 |
SnapdealItemForInventory item;
|
|
|
197 |
if(availability.get(thriftItem.getId())!=null){
|
|
|
198 |
ItemInventory iteminventory = availability.get(thriftItem.getId());
|
|
|
199 |
Map<Long,Long> itemavailability = new HashMap<Long,Long>();
|
|
|
200 |
itemavailability = iteminventory.getAvailability();
|
|
|
201 |
if (thriftItem.isIsWarehousePreferenceSticky() && thriftItem.getPreferredVendor()!=0){
|
|
|
202 |
//System.out.println("Item id "+thriftItem.getId()+".Found prefered vendor and warehouse is marked sticky (Calculating availability)"+thriftItem.getPreferredVendor());
|
|
|
203 |
vendor_warehouses = inventoryClient.getWarehouses(WarehouseType.THIRD_PARTY,InventoryType.GOOD , thriftItem.getPreferredVendor(), 0, 0);
|
|
|
204 |
vendor_warehouses.addAll(ours_warehouses);
|
|
|
205 |
for (Warehouse warehouse:vendor_warehouses){
|
|
|
206 |
if(warehouse.getBillingWarehouseId()!=7){
|
|
|
207 |
if(warehouse.getLogisticsLocation().equals(WarehouseLocation.Delhi) && warehouse.getWarehouseType().equals(WarehouseType.THIRD_PARTY) && warehouse.getVendor().getId()!=1){
|
|
|
208 |
|
|
|
209 |
}
|
|
|
210 |
else{
|
|
|
211 |
continue;
|
|
|
212 |
}
|
|
|
213 |
}
|
|
|
214 |
in.shop2020.model.v1.inventory.IgnoredInventoryUpdateItems ignoredItem = new in.shop2020.model.v1.inventory.IgnoredInventoryUpdateItems();
|
|
|
215 |
ignoredItem.setItemId(thriftItem.getId());
|
|
|
216 |
ignoredItem.setWarehouseId(warehouse.getId());
|
|
|
217 |
if (itemavailability.get(warehouse.getId())!=null && !thirdpartywarehouseids.contains(warehouse.getId()) && !ignoreItems.contains(ignoredItem)){
|
|
|
218 |
try{
|
|
|
219 |
nlc = inventoryClient.getNlcForWarehouse(warehouse.getId(),thriftItem.getId());
|
|
|
220 |
}
|
|
|
221 |
catch(TTransportException e){
|
|
|
222 |
inventoryClient = inventoryServiceClient.getClient();
|
|
|
223 |
nlc = inventoryClient.getNlcForWarehouse(warehouse.getId(),thriftItem.getId());
|
|
|
224 |
}
|
|
|
225 |
maxnlc = catalogClient.getSnapdealItem(thriftItem.getId()).getMaxNlc();
|
|
|
226 |
|
|
|
227 |
//System.out.println("itemId:" + thriftItem.getId() + "\tmaxnlc: " + maxnlc + "\tnlc:" + nlc + "\twid:" + warehouse.getId() );
|
|
|
228 |
if(nlc !=0 && (maxnlc >= nlc)){
|
|
|
229 |
total_warehouse_held = inventoryClient.getHoldInventoryDetailForItemForWarehouseIdExceptSource(thriftItem.getId(), warehouse.getId(), 0);
|
|
|
230 |
heldForSource = heldForSource + total_warehouse_held - inventoryClient.getHoldInventoryDetailForItemForWarehouseIdExceptSource(thriftItem.getId(), warehouse.getId(), 7);
|
|
|
231 |
available = available + itemavailability.get(warehouse.getId());
|
|
|
232 |
total_held = total_held + total_warehouse_held;
|
|
|
233 |
//System.out.println("itemId:" + thriftItem.getId() + "\ttotal_held: " + total_held + "\theldForSource:" + heldForSource + "\tavailable:" + available);
|
|
|
234 |
}
|
|
|
235 |
else if(maxnlc==0){
|
|
|
236 |
total_warehouse_held = inventoryClient.getHoldInventoryDetailForItemForWarehouseIdExceptSource(thriftItem.getId(), warehouse.getId(), 0);
|
|
|
237 |
heldForSource = heldForSource + total_warehouse_held - inventoryClient.getHoldInventoryDetailForItemForWarehouseIdExceptSource(thriftItem.getId(), warehouse.getId(), 7);
|
|
|
238 |
available = available + itemavailability.get(warehouse.getId());
|
|
|
239 |
total_held = total_held + total_warehouse_held;
|
|
|
240 |
//System.out.println("itemId:" + thriftItem.getId() + "\ttotal_held: " + total_held + "\theldForSource:" + heldForSource + "\tavailable:" + available);
|
|
|
241 |
}
|
|
|
242 |
}
|
|
|
243 |
}
|
|
|
244 |
}
|
|
|
245 |
else{
|
|
|
246 |
for (Map.Entry<Long,Long> entry : itemavailability.entrySet()) {
|
|
|
247 |
if(allWarehousesMap.get(entry.getKey()).getBillingWarehouseId()!=7){
|
|
|
248 |
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){
|
|
|
249 |
|
|
|
250 |
}
|
|
|
251 |
else{
|
|
|
252 |
continue;
|
|
|
253 |
}
|
|
|
254 |
}
|
|
|
255 |
in.shop2020.model.v1.inventory.IgnoredInventoryUpdateItems ignoredItem = new in.shop2020.model.v1.inventory.IgnoredInventoryUpdateItems();
|
|
|
256 |
ignoredItem.setItemId(thriftItem.getId());
|
|
|
257 |
ignoredItem.setWarehouseId(entry.getKey());
|
|
|
258 |
if(!thirdpartywarehouseids.contains(entry.getKey()) && !ignoreItems.contains(ignoredItem)){
|
|
|
259 |
|
|
|
260 |
nlc = inventoryClient.getNlcForWarehouse(entry.getKey(),thriftItem.getId());
|
|
|
261 |
try{
|
|
|
262 |
maxnlc = catalogClient.getSnapdealItem(thriftItem.getId()).getMaxNlc();
|
|
|
263 |
}
|
|
|
264 |
catch(TTransportException e){
|
|
|
265 |
catalogClient = catalogServiceClient.getClient();
|
|
|
266 |
maxnlc = catalogClient.getSnapdealItem(thriftItem.getId()).getMaxNlc();
|
|
|
267 |
}
|
|
|
268 |
//System.out.println("itemId:" + thriftItem.getId() + "\tmaxnlc: " + maxnlc + "\tnlc:" + nlc + "\twid:" + entry.getKey() );
|
|
|
269 |
if(nlc !=0 && (maxnlc >= nlc)){
|
|
|
270 |
total_warehouse_held = inventoryClient.getHoldInventoryDetailForItemForWarehouseIdExceptSource(thriftItem.getId(), entry.getKey(), 0);
|
|
|
271 |
heldForSource = heldForSource + total_warehouse_held - inventoryClient.getHoldInventoryDetailForItemForWarehouseIdExceptSource(thriftItem.getId(), entry.getKey(), 7);
|
|
|
272 |
available = available + entry.getValue();
|
|
|
273 |
total_held = total_held + total_warehouse_held;
|
|
|
274 |
//System.out.println("itemId:" + thriftItem.getId() + "\ttotal_held: " + total_held + "\theldForSource:" + heldForSource + "\tavailable:" + available);
|
|
|
275 |
}
|
|
|
276 |
else if(maxnlc==0){
|
|
|
277 |
total_warehouse_held = inventoryClient.getHoldInventoryDetailForItemForWarehouseIdExceptSource(thriftItem.getId(), entry.getKey(), 0);
|
|
|
278 |
heldForSource = heldForSource + total_warehouse_held - inventoryClient.getHoldInventoryDetailForItemForWarehouseIdExceptSource(thriftItem.getId(), entry.getKey(), 7);
|
|
|
279 |
available = available + itemavailability.get(entry.getKey());
|
|
|
280 |
total_held = total_held + total_warehouse_held;
|
|
|
281 |
//System.out.println("itemId:" + thriftItem.getId() + "\ttotal_held: " + total_held + "\theldForSource:" + heldForSource + "\tavailable:" + available);
|
|
|
282 |
}
|
|
|
283 |
|
|
|
284 |
}
|
|
|
285 |
}
|
|
|
286 |
}
|
|
|
287 |
Map<Long,Long> itemreserve = new HashMap<Long,Long>();
|
|
|
288 |
itemreserve = iteminventory.getReserved();
|
|
|
289 |
if (thriftItem.isIsWarehousePreferenceSticky() && thriftItem.getPreferredVendor()!=0){
|
|
|
290 |
//System.out.println("Item id "+thriftItem.getId()+".Found prefered vendor and warehouse is marked sticky (Calculating Reserve)"+thriftItem.getPreferredVendor());
|
|
|
291 |
for (Warehouse warehouse:vendor_warehouses){
|
|
|
292 |
if(warehouse.getBillingWarehouseId()!=7){
|
|
|
293 |
if(warehouse.getLogisticsLocation().equals(WarehouseLocation.Delhi) && warehouse.getWarehouseType().equals(WarehouseType.THIRD_PARTY) && warehouse.getVendor().getId()!=1){
|
|
|
294 |
|
|
|
295 |
}
|
|
|
296 |
else{
|
|
|
297 |
continue;
|
|
|
298 |
}
|
|
|
299 |
}
|
|
|
300 |
in.shop2020.model.v1.inventory.IgnoredInventoryUpdateItems ignoredItem = new in.shop2020.model.v1.inventory.IgnoredInventoryUpdateItems();
|
|
|
301 |
ignoredItem.setItemId(thriftItem.getId());
|
|
|
302 |
ignoredItem.setWarehouseId(warehouse.getId());
|
|
|
303 |
if (itemreserve.get(warehouse.getId())!=null && !thirdpartywarehouseids.contains(warehouse.getId()) && !ignoreItems.contains(warehouse.getId())){
|
|
|
304 |
nlc = inventoryClient.getNlcForWarehouse(warehouse.getId(),thriftItem.getId());
|
|
|
305 |
maxnlc = catalogClient.getSnapdealItem(thriftItem.getId()).getMaxNlc();
|
|
|
306 |
//System.out.println("itemId:" + thriftItem.getId() + "\tmaxnlc: " + maxnlc + "\tnlc:" + nlc + "\twid:" + warehouse.getId() );
|
|
|
307 |
if(nlc !=0 && (maxnlc >= nlc)){
|
|
|
308 |
reserve = reserve + itemreserve.get(warehouse.getId());
|
|
|
309 |
//System.out.println("itemId:" + thriftItem.getId() + "\ttotal_held: " + total_held + "\theldForSource:" + heldForSource + "\treserve:" + reserve);
|
|
|
310 |
}
|
|
|
311 |
else if(maxnlc==0){
|
|
|
312 |
reserve = reserve + itemreserve.get(warehouse.getId());
|
|
|
313 |
//System.out.println("itemId:" + thriftItem.getId() + "\ttotal_held: " + total_held + "\theldForSource:" + heldForSource + "\treserve:" + reserve);
|
|
|
314 |
}
|
|
|
315 |
|
|
|
316 |
}
|
|
|
317 |
}
|
|
|
318 |
}else{
|
|
|
319 |
for (Map.Entry<Long,Long> entry : itemreserve.entrySet()) {
|
|
|
320 |
if(allWarehousesMap.get(entry.getKey()).getBillingWarehouseId()!=7){
|
|
|
321 |
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){
|
|
|
322 |
|
|
|
323 |
}
|
|
|
324 |
else{
|
|
|
325 |
continue;
|
|
|
326 |
}
|
|
|
327 |
}
|
|
|
328 |
in.shop2020.model.v1.inventory.IgnoredInventoryUpdateItems ignoredItem = new in.shop2020.model.v1.inventory.IgnoredInventoryUpdateItems();
|
|
|
329 |
ignoredItem.setItemId(thriftItem.getId());
|
|
|
330 |
ignoredItem.setWarehouseId(entry.getKey());
|
|
|
331 |
if(!thirdpartywarehouseids.contains(entry.getKey()) && !ignoreItems.contains(ignoredItem)){
|
|
|
332 |
nlc = inventoryClient.getNlcForWarehouse(entry.getKey(),thriftItem.getId());
|
|
|
333 |
maxnlc = catalogClient.getSnapdealItem(thriftItem.getId()).getMaxNlc();
|
|
|
334 |
//System.out.println("itemId:" + thriftItem.getId() + "\tmaxnlc: " + maxnlc + "\tnlc:" + nlc + "\twid:" + entry.getKey() );
|
|
|
335 |
if(nlc !=0 && (maxnlc >= nlc)){
|
|
|
336 |
reserve = reserve + entry.getValue();
|
|
|
337 |
//System.out.println("itemId:" + thriftItem.getId() + "\ttotal_held: " + total_held + "\theldForSource:" + heldForSource + "\treserve:" + reserve);
|
|
|
338 |
}
|
|
|
339 |
else if(maxnlc==0){
|
|
|
340 |
reserve = reserve + entry.getValue();
|
|
|
341 |
//System.out.println("itemId:" + thriftItem.getId() + "\ttotal_held: " + total_held + "\theldForSource:" + heldForSource + "\treserve:" + reserve);
|
|
|
342 |
}
|
|
|
343 |
|
|
|
344 |
}
|
|
|
345 |
|
|
|
346 |
else{
|
|
|
347 |
//System.out.println("skipping inventory for warehouse id " + entry.getKey());
|
|
|
348 |
}
|
|
|
349 |
}
|
|
|
350 |
}
|
|
|
351 |
item= new SnapdealItemForInventory(thriftItem.getId(),available,reserve,heldForSource,thriftItem.getHoldInventory(),thriftItem.getDefaultInventory(),total_held,thriftItem.isRisky(),thriftItem.getItemStatus());
|
|
|
352 |
//System.out.println("itemId:" + thriftItem.getId() + "\tavailable: " + available + "\treserve" + reserve + "\theldForSource:" + heldForSource + "\twebsite_hold:" + thriftItem.getHoldInventory() + "\tdefault_inv:" +thriftItem.getDefaultInventory());
|
|
|
353 |
}
|
|
|
354 |
else{
|
|
|
355 |
item = new SnapdealItemForInventory(thriftItem.getId(),0,0,0,thriftItem.getHoldInventory(),thriftItem.getDefaultInventory(),0,thriftItem.isRisky(),thriftItem.getItemStatus());
|
|
|
356 |
//System.out.println("itemId:" + thriftItem.getId() + "\tavailable: " + available + "\treserve" + reserve + "\theldForSource:" + heldForSource + "\twebsite_hold:" + thriftItem.getHoldInventory() + "\tdefault_inv:" +thriftItem.getDefaultInventory());
|
|
|
357 |
}
|
|
|
358 |
|
|
|
359 |
//System.out.println(" Item details are " + thriftItem.getId() +" " + available + " " + reserve + " " + thriftItem.getHoldInventory() + " "+ thriftItem.getDefaultInventory() + " " + thriftItem.isRisky());
|
|
|
360 |
//System.out.println("+++++++++++++++++++++++");
|
|
|
361 |
allItemsInventoryMap.put(thriftItem.getId(),item);
|
|
|
362 |
|
|
|
363 |
}
|
|
|
364 |
|
|
|
365 |
} catch (TException e) {
|
|
|
366 |
|
|
|
367 |
e.printStackTrace();
|
|
|
368 |
}
|
|
|
369 |
|
|
|
370 |
}
|
|
|
371 |
private static void fetchinventoryhistoryfromsnapdeal() throws UnsupportedEncodingException, TException{
|
|
|
372 |
int i = 1;
|
|
|
373 |
Gson gson = new Gson();
|
|
|
374 |
inventoryhistoryItemMap = new HashMap<String,InventoryHistory>();
|
|
|
375 |
boolean exitfetchinghistory = true;
|
|
|
376 |
System.out.println("Fetching history inventory");
|
|
|
377 |
HttpGet get;
|
|
|
378 |
HttpResponse response = null;
|
|
|
379 |
BufferedReader rd = null;
|
|
|
380 |
while(exitfetchinghistory){
|
|
|
381 |
System.out.println("Fetching inventory history page " +i);
|
|
|
382 |
get = new HttpGet("http://seller.snapdeal.com/inventory/search?gridType=history&_search=false&nd="+time+"&rows=30&page="+i+"&sidx=&sord=dsc");
|
|
|
383 |
|
|
|
384 |
try {
|
|
|
385 |
response = client.execute(get);
|
|
|
386 |
} catch (ClientProtocolException e) {
|
|
|
387 |
|
|
|
388 |
e.printStackTrace();
|
|
|
389 |
} catch (IOException e) {
|
|
|
390 |
|
|
|
391 |
e.printStackTrace();
|
|
|
392 |
}
|
|
|
393 |
|
|
|
394 |
try {
|
|
|
395 |
rd = new BufferedReader(new InputStreamReader(response.getEntity().getContent()));
|
|
|
396 |
|
|
|
397 |
} catch (IllegalStateException e) {
|
|
|
398 |
|
|
|
399 |
e.printStackTrace();
|
|
|
400 |
} catch (IOException e) {
|
|
|
401 |
|
|
|
402 |
e.printStackTrace();
|
|
|
403 |
}
|
|
|
404 |
InventoryHistoryItems inventoryhistoryitems = (InventoryHistoryItems) gson.fromJson(rd, InventoryHistoryItems.class);
|
|
|
405 |
if(inventoryhistoryitems.getRows().size()!=0){
|
|
|
406 |
//System.out.println("Parsing page " + i);
|
|
|
407 |
for(InventoryHistory inventoryhistory : inventoryhistoryitems.getRows()){
|
|
|
408 |
//System.out.println("Inventory History " + inventoryhistory.getSellerSku() +" "+ inventoryhistory.getSupc());
|
|
|
409 |
if(inventoryhistory.getUpdateTime() > lastUpdatedInventoryTime){
|
|
|
410 |
if(inventoryhistoryItemMap.containsKey(inventoryhistory.getSellerSku())){
|
|
|
411 |
if(inventoryhistoryItemMap.get(inventoryhistory.getSellerSku()).getUpdateTime() < inventoryhistory.getUpdateTime()){
|
|
|
412 |
inventoryhistoryItemMap.put(inventoryhistory.getSellerSku(),inventoryhistory);
|
|
|
413 |
}
|
|
|
414 |
}
|
|
|
415 |
else{
|
|
|
416 |
inventoryhistoryItemMap.put(inventoryhistory.getSellerSku(),inventoryhistory);
|
|
|
417 |
}
|
|
|
418 |
}
|
|
|
419 |
else{
|
|
|
420 |
exitfetchinghistory = false;
|
|
|
421 |
}
|
|
|
422 |
}
|
|
|
423 |
}
|
|
|
424 |
else{
|
|
|
425 |
exitfetchinghistory = false;
|
|
|
426 |
}
|
|
|
427 |
i++;
|
|
|
428 |
}
|
|
|
429 |
InventoryClient inventoryServiceClient = new InventoryClient();
|
|
|
430 |
in.shop2020.model.v1.inventory.InventoryService.Client inventoryClient = inventoryServiceClient.getClient();
|
|
|
431 |
List<SnapdealInventoryItem> snapdealInventoryItemHistoryList = inventoryClient.getSnapdealInventorySnapshot();
|
|
|
432 |
if(snapdealInventoryItemHistoryList.size()>0){
|
|
|
433 |
for(SnapdealInventoryItem snapdealInventoryItem:snapdealInventoryItemHistoryList){
|
|
|
434 |
if(itemSnapdealMap.containsKey(snapdealInventoryItem.getItem_id())){
|
|
|
435 |
PendingOrderInventoryHistory pendingOrdersInventoryHistory = new PendingOrderInventoryHistory();
|
|
|
436 |
pendingOrdersInventoryHistory.setPendingOrders(snapdealInventoryItem.getPendingOrders());
|
|
|
437 |
pendingOrdersInventoryHistory.setInventoryHistory(snapdealInventoryItem.getAvailability());
|
|
|
438 |
pendingOrdersInventoryHistory.setLastUpdatedTimestamp(snapdealInventoryItem.getLastUpdatedOnSnapdeal());
|
|
|
439 |
PendingOrdersInventoryHistoryMap.put(itemSnapdealMap.get(snapdealInventoryItem.getItem_id()).getSkuAtSnapdeal(), pendingOrdersInventoryHistory);
|
|
|
440 |
}
|
|
|
441 |
}
|
|
|
442 |
}
|
|
|
443 |
PendingOrderInventoryHistory pendingOrdersInventoryHistory;
|
|
|
444 |
for(Entry<String, InventoryHistory> inventoryHistoryItem :inventoryhistoryItemMap.entrySet()){
|
|
|
445 |
if(PendingOrdersInventoryHistoryMap.containsKey(inventoryHistoryItem.getValue().getSellerSku())){
|
|
|
446 |
pendingOrdersInventoryHistory = PendingOrdersInventoryHistoryMap.get(inventoryHistoryItem.getValue().getSellerSku());
|
|
|
447 |
pendingOrdersInventoryHistory.setInventoryHistory(Long.parseLong(inventoryHistoryItem.getValue().getNewValue()));
|
|
|
448 |
pendingOrdersInventoryHistory.setLastUpdatedTimestamp(inventoryHistoryItem.getValue().getUpdateTime());
|
|
|
449 |
PendingOrdersInventoryHistoryMap.put(inventoryHistoryItem.getValue().getSellerSku(),pendingOrdersInventoryHistory);
|
|
|
450 |
}
|
|
|
451 |
else{
|
|
|
452 |
pendingOrdersInventoryHistory = new PendingOrderInventoryHistory();
|
|
|
453 |
pendingOrdersInventoryHistory.setInventoryHistory(Long.parseLong(inventoryHistoryItem.getValue().getNewValue()));
|
|
|
454 |
pendingOrdersInventoryHistory.setLastUpdatedTimestamp(inventoryHistoryItem.getValue().getUpdateTime());
|
|
|
455 |
pendingOrdersInventoryHistory.setPendingOrders(0);
|
|
|
456 |
PendingOrdersInventoryHistoryMap.put(inventoryHistoryItem.getValue().getSellerSku(),pendingOrdersInventoryHistory);
|
|
|
457 |
}
|
|
|
458 |
}
|
|
|
459 |
}
|
|
|
460 |
|
|
|
461 |
private static void fetchcurrentinventoryfromsnapdeal() throws UnsupportedEncodingException, TException{
|
|
|
462 |
int i = 1;
|
|
|
463 |
int items=0;
|
|
|
464 |
Gson gson = new Gson();
|
|
|
465 |
in.shop2020.model.v1.order.TransactionService.Client transactionClient = null;
|
|
|
466 |
currentInventoryItemList = new ArrayList<Inventory>();
|
|
|
467 |
HttpGet get;
|
|
|
468 |
HttpResponse response = null;
|
|
|
469 |
BufferedReader rd= null;
|
|
|
470 |
System.out.println("Fetching current inventory ");
|
|
|
471 |
while(true){
|
|
|
472 |
//System.out.println("Fetching current inventory page " +i);
|
|
|
473 |
get = new HttpGet("http://seller.snapdeal.com/inventory/search?gridType=normal&_search=false&nd="+time+"&rows="+30+"&page="+i+"&sidx=&sord=asc");
|
|
|
474 |
try {
|
|
|
475 |
response = client.execute(get);
|
|
|
476 |
} catch (ClientProtocolException e) {
|
|
|
477 |
|
|
|
478 |
e.printStackTrace();
|
|
|
479 |
} catch (IOException e) {
|
|
|
480 |
|
|
|
481 |
e.printStackTrace();
|
|
|
482 |
}
|
|
|
483 |
try {
|
|
|
484 |
rd = new BufferedReader(new InputStreamReader(response.getEntity().getContent()));
|
|
|
485 |
} catch (IllegalStateException e) {
|
|
|
486 |
|
|
|
487 |
e.printStackTrace();
|
|
|
488 |
} catch (IOException e) {
|
|
|
489 |
|
|
|
490 |
e.printStackTrace();
|
|
|
491 |
}
|
|
|
492 |
InventoryItems inventoryitems = (InventoryItems) gson.fromJson(rd, InventoryItems.class);
|
|
|
493 |
if(inventoryitems.getRows().size()!=0){
|
|
|
494 |
for(Inventory inventory : inventoryitems.getRows()){
|
|
|
495 |
if(snapdealItemMap.containsKey(inventory.getSellerSku())){
|
|
|
496 |
currentInventoryItemList.add(inventory);
|
|
|
497 |
}
|
|
|
498 |
|
|
|
499 |
else{
|
|
|
500 |
notMappedItems.append("<tr>"
|
|
|
501 |
+ "<td>" + inventory.getProductName() +"</td>"
|
|
|
502 |
+"<td>" + inventory.getSellerSku() + "</td>"
|
|
|
503 |
+"<td>" + inventory.getSupc() + "</td>"
|
|
|
504 |
+"</tr>");
|
|
|
505 |
}
|
|
|
506 |
items++;
|
|
|
507 |
}
|
|
|
508 |
}
|
|
|
509 |
else{
|
|
|
510 |
System.out.println("Fetched " + items);
|
|
|
511 |
break;
|
|
|
512 |
}
|
|
|
513 |
i++;
|
|
|
514 |
}
|
|
|
515 |
in.shop2020.model.v1.catalog.CatalogService.Client catalogServiceClient = null;
|
|
|
516 |
SnapdealItemDetails snapdealitem = null;
|
|
|
517 |
long sku = 0;
|
|
|
518 |
long created_orders;
|
|
|
519 |
long pending_orders;
|
|
|
520 |
Map<Long, Long> itemIdCreatedOrdersMap = null;
|
|
|
521 |
try {
|
|
|
522 |
transactionClient = new TransactionClient("support_transaction_service_server_host","transaction_service_server_port").getClient();
|
|
|
523 |
System.out.println("Last Updated on Time is " + lastUpdatedInventoryTime);
|
|
|
524 |
if(lastUpdatedInventoryTime > 0){
|
|
|
525 |
itemIdCreatedOrdersMap = transactionClient.getOrdersCreatedAfterTimestampForSource(lastUpdatedInventoryTime, 7);
|
|
|
526 |
System.out.println("Item id orders created map size "+ itemIdCreatedOrdersMap.entrySet().size());
|
|
|
527 |
}
|
|
|
528 |
} catch (TTransportException e1) {
|
|
|
529 |
|
|
|
530 |
e1.printStackTrace();
|
|
|
531 |
}
|
|
|
532 |
try {
|
|
|
533 |
catalogServiceClient = new CatalogClient().getClient();
|
|
|
534 |
} catch (TTransportException e1) {
|
|
|
535 |
|
|
|
536 |
e1.printStackTrace();
|
|
|
537 |
}
|
|
|
538 |
List<String> notMappedItems = new ArrayList<String>();
|
|
|
539 |
|
|
|
540 |
for(Inventory inventory:currentInventoryItemList){
|
|
|
541 |
created_orders = 0;
|
|
|
542 |
pending_orders = 0;
|
|
|
543 |
snapdealitem = snapdealItemMap.get(inventory.getSellerSku());
|
|
|
544 |
if(snapdealitem==null){
|
|
|
545 |
notMappedItems.add(inventory.getSellerSku()+" "+inventory.getProductName());
|
|
|
546 |
System.out.println("Not Mapped " + inventory.getSellerSku());
|
|
|
547 |
continue;
|
|
|
548 |
}
|
|
|
549 |
sku = snapdealitem.getItem_id();
|
|
|
550 |
if(sku!=0){
|
|
|
551 |
if(itemIdCreatedOrdersMap!=null && itemIdCreatedOrdersMap.containsKey(sku)){
|
|
|
552 |
created_orders = itemIdCreatedOrdersMap.get(sku);
|
|
|
553 |
}
|
|
|
554 |
System.out.println("Created orders for " + sku +" " + created_orders);
|
|
|
555 |
}
|
|
|
556 |
else{
|
|
|
557 |
continue;
|
|
|
558 |
}
|
|
|
559 |
if(PendingOrdersInventoryHistoryMap.containsKey(inventory.getSellerSku())){
|
|
|
560 |
System.out.println("Calculating Pending Orders for " + inventory.getSellerSku());
|
|
|
561 |
System.out.println("Current Inventory "+inventory.getAvailableInventory());
|
|
|
562 |
System.out.println("History Inventory "+PendingOrdersInventoryHistoryMap.get(inventory.getSellerSku()).getInventoryHistory());
|
|
|
563 |
System.out.println("Created Orders "+created_orders);
|
|
|
564 |
System.out.println("Old Pending Orders "+ PendingOrdersInventoryHistoryMap.get(inventory.getSellerSku()).getPendingOrders());
|
|
|
565 |
if(PendingOrdersInventoryHistoryMap.get(inventory.getSellerSku()).getLastUpdatedTimestamp() > lastUpdatedInventoryTime){
|
|
|
566 |
pending_orders = PendingOrdersInventoryHistoryMap.get(inventory.getSellerSku()).getPendingOrders() + PendingOrdersInventoryHistoryMap.get(inventory.getSellerSku()).getInventoryHistory() - inventory.getAvailableInventory() - created_orders;
|
|
|
567 |
}
|
|
|
568 |
else{
|
|
|
569 |
pending_orders = PendingOrdersInventoryHistoryMap.get(inventory.getSellerSku()).getPendingOrders() - created_orders;
|
|
|
570 |
}
|
|
|
571 |
System.out.println("New Pending Orders "+pending_orders);
|
|
|
572 |
PendingOrderInventoryHistory pendingOrderInventoryHistory = PendingOrdersInventoryHistoryMap.get(inventory.getSellerSku());
|
|
|
573 |
pendingOrderInventoryHistory.setPendingOrders(pending_orders);
|
|
|
574 |
PendingOrdersInventoryHistoryMap.put(inventory.getSellerSku(),pendingOrderInventoryHistory);
|
|
|
575 |
}
|
|
|
576 |
else{
|
|
|
577 |
System.out.print("Could not calculate pending orders " + inventory.getSellerSku() +"\n");
|
|
|
578 |
PendingOrderInventoryHistory pendingOrderInventoryHistory = new PendingOrderInventoryHistory();
|
|
|
579 |
pendingOrderInventoryHistory.setPendingOrders(pending_orders);
|
|
|
580 |
pendingOrderInventoryHistory.setInventoryHistory(inventory.getAvailableInventory());
|
|
|
581 |
pendingOrderInventoryHistory.setLastUpdatedTimestamp(System.currentTimeMillis());
|
|
|
582 |
PendingOrdersInventoryHistoryMap.put(inventory.getSellerSku(),pendingOrderInventoryHistory);
|
|
|
583 |
}
|
|
|
584 |
itemIdpendingOrdersMap.put(sku, pending_orders);
|
|
|
585 |
|
|
|
586 |
}
|
|
|
587 |
}
|
|
|
588 |
|
|
|
589 |
public static void handleLogin() throws ClientProtocolException, IOException{
|
|
|
590 |
HttpGet get = new HttpGet("http://selleraccounts.snapdeal.com/keymaker/login");
|
|
|
591 |
HttpResponse response = null;
|
|
|
592 |
try {
|
|
|
593 |
response = client.execute(get);
|
|
|
594 |
} catch (ClientProtocolException e) {
|
|
|
595 |
|
|
|
596 |
e.printStackTrace();
|
|
|
597 |
} catch (IOException e) {
|
|
|
598 |
|
|
|
599 |
e.printStackTrace();
|
|
|
600 |
}
|
|
|
601 |
BufferedReader rd = null;
|
|
|
602 |
try {
|
|
|
603 |
rd = new BufferedReader(new InputStreamReader(response.getEntity().getContent()));
|
|
|
604 |
} catch (IllegalStateException e1) {
|
|
|
605 |
|
|
|
606 |
e1.printStackTrace();
|
|
|
607 |
} catch (IOException e1) {
|
|
|
608 |
|
|
|
609 |
e1.printStackTrace();
|
|
|
610 |
}
|
|
|
611 |
String line = "";
|
|
|
612 |
StringBuffer sb = new StringBuffer();
|
|
|
613 |
try {
|
|
|
614 |
while ((line = rd.readLine()) != null) {
|
|
|
615 |
sb.append(line);
|
|
|
616 |
//System.out.println(line);
|
|
|
617 |
}
|
|
|
618 |
} catch (IOException e) {
|
|
|
619 |
|
|
|
620 |
e.printStackTrace();
|
|
|
621 |
}
|
|
|
622 |
int i= sb.toString().indexOf("name=\"lt\" value=");
|
|
|
623 |
char[] charArray = sb.toString().toCharArray();
|
|
|
624 |
String lt = "";
|
|
|
625 |
int j=0;
|
|
|
626 |
for(j=i+16;j<=charArray.length;j++){
|
|
|
627 |
|
|
|
628 |
if(charArray[j]==' '){
|
|
|
629 |
break;
|
|
|
630 |
}
|
|
|
631 |
}
|
|
|
632 |
lt = sb.substring(i+17,j-1);
|
|
|
633 |
System.out.println("LT VALUE " + lt);
|
|
|
634 |
i= sb.toString().indexOf("name=\"execution\" value=");
|
|
|
635 |
charArray = sb.toString().toCharArray();
|
|
|
636 |
String ex = "";
|
|
|
637 |
j=0;
|
|
|
638 |
for(j=i+24;j<=charArray.length;j++){
|
|
|
639 |
if(charArray[j]==' '){
|
|
|
640 |
break;
|
|
|
641 |
}
|
|
|
642 |
}
|
|
|
643 |
ex = sb.substring(i+24,j-1);
|
|
|
644 |
System.out.println("EXECUTION VALUE " + ex);
|
|
|
645 |
HttpPost post = new HttpPost("http://selleraccounts.snapdeal.com/login?service=http%3A%2F%2Fseller.snapdeal.com%2Fj_spring_cas_security_check");
|
|
|
646 |
List<NameValuePair> nameValuePairs = new ArrayList<NameValuePair>();
|
|
|
647 |
//nameValuePairs.add(new BasicNameValuePair("username",
|
|
|
648 |
//"khushal.bhatia@saholic.com"));
|
|
|
649 |
nameValuePairs.add(new BasicNameValuePair("username",
|
|
|
650 |
"saholic-snapdeal@saholic.com"));
|
|
|
651 |
//nameValuePairs.add(new BasicNameValuePair("password",
|
|
|
652 |
//"sonline"));
|
|
|
653 |
nameValuePairs.add(new BasicNameValuePair("password",
|
|
|
654 |
"bc452ce4"));
|
|
|
655 |
nameValuePairs.add(new BasicNameValuePair("_eventId","submit"));
|
|
|
656 |
nameValuePairs.add(new BasicNameValuePair("execution",ex));
|
|
|
657 |
nameValuePairs.add(new BasicNameValuePair("lt",lt));
|
|
|
658 |
nameValuePairs.add(new BasicNameValuePair("submit","LOGIN"));
|
|
|
659 |
post.setEntity(new UrlEncodedFormEntity(nameValuePairs,"utf-8"));
|
|
|
660 |
response = client.execute(post);
|
|
|
661 |
rd = new BufferedReader(new InputStreamReader(response.getEntity().getContent()));
|
|
|
662 |
line = "";
|
|
|
663 |
while ((line = rd.readLine()) != null) {
|
|
|
664 |
System.out.println(line);
|
|
|
665 |
}
|
|
|
666 |
get = new HttpGet("http://seller.snapdeal.com/inventory/");
|
|
|
667 |
response = client.execute(get);
|
|
|
668 |
rd = new BufferedReader(new InputStreamReader(response.getEntity().getContent()));
|
|
|
669 |
while ((line = rd.readLine()) != null) {
|
|
|
670 |
//System.out.println(line);
|
|
|
671 |
}
|
|
|
672 |
}
|
|
|
673 |
|
|
|
674 |
|
|
|
675 |
|
|
|
676 |
|
|
|
677 |
@SuppressWarnings("deprecation")
|
| 10371 |
vikram.rag |
678 |
public static void sendsnapdealinventory (){
|
| 10367 |
vikram.rag |
679 |
initilaize();
|
|
|
680 |
try {
|
|
|
681 |
handleLogin();
|
|
|
682 |
} catch (ClientProtocolException e2) {
|
|
|
683 |
System.out.println("Handle login failed");
|
|
|
684 |
e2.printStackTrace();
|
|
|
685 |
} catch (IOException e2) {
|
|
|
686 |
System.out.println("Handle login failed");
|
|
|
687 |
e2.printStackTrace();
|
|
|
688 |
}
|
|
|
689 |
try {
|
|
|
690 |
fetchinventoryhistoryfromsnapdeal();
|
|
|
691 |
} catch (UnsupportedEncodingException e2) {
|
|
|
692 |
System.out.println("History Inventory Fetch failed");
|
|
|
693 |
e2.printStackTrace();
|
| 10371 |
vikram.rag |
694 |
} catch (TException e) {
|
|
|
695 |
e.printStackTrace();
|
| 10367 |
vikram.rag |
696 |
}
|
|
|
697 |
try {
|
|
|
698 |
fetchcurrentinventoryfromsnapdeal();
|
|
|
699 |
} catch (UnsupportedEncodingException e2) {
|
|
|
700 |
System.out.println("Current Inventory Fetch failed");
|
|
|
701 |
e2.printStackTrace();
|
| 10371 |
vikram.rag |
702 |
} catch (TException e) {
|
|
|
703 |
e.printStackTrace();
|
| 10367 |
vikram.rag |
704 |
}
|
|
|
705 |
calculateinventory();
|
|
|
706 |
FileInputStream fis = null;
|
|
|
707 |
Workbook hwb = null;
|
|
|
708 |
Sheet sheet = null;
|
|
|
709 |
if(!PANEL){
|
|
|
710 |
try {
|
|
|
711 |
fis = new FileInputStream("/root/code/trunk/SnapDealFeeds/SellerInventory.xls");
|
|
|
712 |
} catch (FileNotFoundException e) {
|
|
|
713 |
System.out.println("Template File not found");
|
|
|
714 |
e.printStackTrace();
|
|
|
715 |
}
|
|
|
716 |
try {
|
|
|
717 |
hwb = new HSSFWorkbook(fis);
|
|
|
718 |
} catch (IOException e) {
|
|
|
719 |
System.out.println("Could not created workbook I/O Problem");
|
|
|
720 |
e.printStackTrace();
|
|
|
721 |
}
|
|
|
722 |
sheet = hwb.getSheetAt(0);
|
|
|
723 |
}
|
|
|
724 |
Row row = null;
|
|
|
725 |
int iterator=1;
|
|
|
726 |
long available,reserve,defaultinventory,holdinventory,heldorders=0,sent_inventory = 0,totalheld,heldforsource,allocable;
|
|
|
727 |
SnapdealItemForInventory inventoryItem;
|
|
|
728 |
StringBuffer outOfStockItems =new StringBuffer();
|
|
|
729 |
StringBuffer backInStockItems =new StringBuffer();
|
|
|
730 |
StringBuffer inventoryChangeItems =new StringBuffer();
|
|
|
731 |
StringBuffer heldMoreThanAvailable =new StringBuffer();
|
|
|
732 |
long sku = 0;
|
|
|
733 |
SnapdealItemDetails snapdealitem;
|
|
|
734 |
long lastSentInventoryTime = System.currentTimeMillis();
|
|
|
735 |
List<SnapdealInventoryItem> snapdealInventoryItemList = null;
|
|
|
736 |
for(Inventory inventory:currentInventoryItemList){
|
|
|
737 |
//System.out.println(inventory.getSupc()+" "+inventory.getSellerSku()+ " " +inventory.getProductName()+" "+inventory.getAvailableInventory()+" "+inventory.isLive()+" "+itemIdpendingOrdersMap.get(Long.parseLong(inventory.getSellerSku())));
|
|
|
738 |
snapdealInventoryItemList = new ArrayList<SnapdealInventoryItem>();
|
|
|
739 |
if(snapdealItemMap.containsKey(inventory.getSellerSku())){
|
|
|
740 |
snapdealitem = snapdealItemMap.get(inventory.getSellerSku());
|
|
|
741 |
sku = snapdealitem.getItem_id();
|
|
|
742 |
}
|
|
|
743 |
else{
|
|
|
744 |
continue;
|
|
|
745 |
}
|
|
|
746 |
if(snapdealitem.getItem_id()!=0 && snapdealitem.isIsListedOnSnapdeal() && !snapdealitem.isSuppressInventoryFeed()){
|
|
|
747 |
inventoryItem = allItemsInventoryMap.get(sku);
|
|
|
748 |
if(inventoryItem==null){
|
|
|
749 |
continue;
|
|
|
750 |
}
|
|
|
751 |
available = inventoryItem.getAvailability();
|
|
|
752 |
reserve = inventoryItem.getReserve();
|
|
|
753 |
defaultinventory = inventoryItem.getDefaultInventory();
|
|
|
754 |
holdinventory = inventoryItem.getHoldInventory();
|
|
|
755 |
totalheld = inventoryItem.getTotalHeldInventory();
|
|
|
756 |
heldforsource = inventoryItem.getHeldForSource();
|
|
|
757 |
if(itemIdpendingOrdersMap.containsKey(sku)){
|
|
|
758 |
heldorders = itemIdpendingOrdersMap.get(sku);
|
|
|
759 |
if(heldorders < 0){
|
|
|
760 |
heldorders = 0;
|
|
|
761 |
}
|
|
|
762 |
}
|
|
|
763 |
System.out.println("itemId: " + inventoryItem.getId() + "\trisky: " + inventoryItem.getRisky()+
|
|
|
764 |
"\tavailable: " + available + "\treserve: " + reserve + "\theldForSource:" + heldforsource +
|
|
|
765 |
"\twebsite_hold: " + holdinventory + "\ttotal_held: " +totalheld +"\tdefault_inv: "
|
|
|
766 |
+ defaultinventory + "\theldorders " + heldorders);
|
|
|
767 |
if(!PANEL){
|
|
|
768 |
row = sheet.getRow((short) iterator);
|
|
|
769 |
}
|
|
|
770 |
if(!inventoryItem.getStatus().equals(status.PAUSED)){
|
|
|
771 |
if(inventoryItem.getRisky()){
|
|
|
772 |
if((available - reserve) < totalheld && totalheld!=0){
|
|
|
773 |
sent_inventory = (long) Math.floor(((available - reserve)*heldforsource/totalheld)) - heldorders;
|
|
|
774 |
heldMoreThanAvailable.append("<tr>"
|
|
|
775 |
+ "<td>" + inventory.getProductName() +"</td>"
|
|
|
776 |
+"<td>" + sku + "</td>"
|
|
|
777 |
+"<td>" + (available - reserve) + "</td>"
|
|
|
778 |
+"<td>" + totalheld + "</td>"
|
|
|
779 |
+"</tr>");
|
|
|
780 |
}
|
|
|
781 |
else{
|
|
|
782 |
allocable = available - reserve - totalheld - holdinventory;
|
|
|
783 |
if(allocable < 0){
|
|
|
784 |
allocable = 0;
|
|
|
785 |
}
|
|
|
786 |
sent_inventory = Math.round(allocable*2/3) + heldforsource - heldorders ;
|
|
|
787 |
}
|
|
|
788 |
if(sent_inventory < 0){
|
|
|
789 |
sent_inventory = 0;
|
|
|
790 |
}
|
|
|
791 |
}
|
|
|
792 |
else{
|
|
|
793 |
allocable = available - reserve - totalheld;
|
|
|
794 |
if(allocable < 0){
|
|
|
795 |
allocable = 0;
|
|
|
796 |
}
|
|
|
797 |
if((allocable + heldforsource ) > defaultinventory){
|
|
|
798 |
sent_inventory = Math.round(allocable*2/3) + heldforsource - heldorders;
|
|
|
799 |
//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));
|
|
|
800 |
if(sent_inventory < 0){
|
|
|
801 |
sent_inventory = 0;
|
|
|
802 |
}
|
|
|
803 |
}
|
|
|
804 |
else{
|
|
|
805 |
if(defaultinventory > heldorders){
|
|
|
806 |
sent_inventory = defaultinventory - heldorders;
|
|
|
807 |
}
|
|
|
808 |
else{
|
|
|
809 |
sent_inventory = 0;
|
|
|
810 |
}
|
|
|
811 |
}
|
|
|
812 |
}
|
|
|
813 |
}
|
|
|
814 |
else{
|
|
|
815 |
sent_inventory = 0;
|
|
|
816 |
}
|
|
|
817 |
SnapdealInventoryItem snapdealInventoryItem;
|
| 10372 |
vikram.rag |
818 |
sent_inventory = 0;
|
|
|
819 |
if(true){
|
|
|
820 |
//if(inventory.getAvailableInventory()!= sent_inventory){
|
| 10367 |
vikram.rag |
821 |
if(!PANEL){
|
|
|
822 |
row.getCell((short) 0).setCellValue(inventory.getSupc());
|
|
|
823 |
row.getCell((short) 1).setCellValue(inventory.getSellerSku());
|
|
|
824 |
row.getCell((short) 2).setCellValue(inventory.getProductName());
|
|
|
825 |
row.getCell((short) 3).setCellValue(inventory.getAvailableInventory());
|
|
|
826 |
row.getCell((short) 4).setCellValue(sent_inventory);
|
|
|
827 |
if(inventory.isLive()){
|
|
|
828 |
row.getCell((short) 5).setCellValue("Yes");
|
|
|
829 |
}
|
|
|
830 |
else{
|
|
|
831 |
row.getCell((short) 5).setCellValue("No");
|
|
|
832 |
}
|
|
|
833 |
}
|
|
|
834 |
else{
|
|
|
835 |
snapdealInventoryItem = new SnapdealInventoryItem();
|
|
|
836 |
PendingOrderInventoryHistory pendingOrderInventoryHistory = PendingOrdersInventoryHistoryMap.get(inventory.getSellerSku());
|
|
|
837 |
if(snapdealItemMap.containsKey(inventory.getSellerSku())){
|
|
|
838 |
snapdealInventoryItem.setItem_id(snapdealItemMap.get(inventory.getSellerSku()).getItem_id());
|
|
|
839 |
snapdealInventoryItem.setPendingOrders(pendingOrderInventoryHistory.getPendingOrders());
|
|
|
840 |
snapdealInventoryItem.setAvailability(sent_inventory);
|
|
|
841 |
snapdealInventoryItem.setLastUpdatedOnSnapdeal(lastSentInventoryTime);
|
|
|
842 |
snapdealInventoryItemList.add(snapdealInventoryItem);
|
|
|
843 |
}
|
|
|
844 |
UpdateSDIUsingPanel UDSI = new UpdateSDIUsingPanel();
|
|
|
845 |
try {
|
|
|
846 |
UDSI.handleLogin();
|
|
|
847 |
UDSI.updateInventory(sent_inventory,inventory.getSupc());
|
|
|
848 |
} catch (ClientProtocolException e) {
|
|
|
849 |
System.out.println("Could not login and update inventory");
|
|
|
850 |
e.printStackTrace();
|
|
|
851 |
continue;
|
|
|
852 |
} catch (IOException e) {
|
|
|
853 |
System.out.println("Could not login and update inventory I/O");
|
|
|
854 |
e.printStackTrace();
|
|
|
855 |
continue;
|
|
|
856 |
}
|
|
|
857 |
}
|
|
|
858 |
if(inventory.getAvailableInventory()!=0 && sent_inventory==0){
|
|
|
859 |
outOfStockItems.append("<tr>"
|
|
|
860 |
+ "<td>" + inventory.getProductName() +"</td>"
|
|
|
861 |
+"<td>" + sku + "</td>"
|
|
|
862 |
+"<td>" + inventory.getAvailableInventory() + "</td>"
|
|
|
863 |
+"<td>" + sent_inventory + "</td>"
|
|
|
864 |
+"</tr>");
|
|
|
865 |
}
|
|
|
866 |
else if(inventory.getAvailableInventory()==0 && sent_inventory!=0){
|
|
|
867 |
backInStockItems.append("<tr>"
|
|
|
868 |
+ "<td>" + inventory.getProductName() +"</td>"
|
|
|
869 |
+"<td>" + sku + "</td>"
|
|
|
870 |
+"<td>" + inventory.getAvailableInventory() + "</td>"
|
|
|
871 |
+"<td>" + sent_inventory + "</td>"
|
|
|
872 |
+"</tr>");
|
|
|
873 |
}
|
|
|
874 |
else{
|
|
|
875 |
inventoryChangeItems.append("<tr>"
|
|
|
876 |
+ "<td>" + inventory.getProductName() +"</td>"
|
|
|
877 |
+"<td>" + sku + "</td>"
|
|
|
878 |
+"<td>" + inventory.getAvailableInventory() + "</td>"
|
|
|
879 |
+"<td>" + sent_inventory + "</td>"
|
|
|
880 |
+"</tr>");
|
|
|
881 |
}
|
|
|
882 |
iterator++;
|
|
|
883 |
}
|
|
|
884 |
}
|
|
|
885 |
else{
|
|
|
886 |
continue;
|
|
|
887 |
}
|
|
|
888 |
}
|
|
|
889 |
if(iterator > 1){
|
|
|
890 |
FileOutputStream fileOut = null;
|
|
|
891 |
if(!PANEL){
|
|
|
892 |
try {
|
|
|
893 |
fis.close();
|
|
|
894 |
} catch (IOException e2) {
|
|
|
895 |
e2.printStackTrace();
|
|
|
896 |
}
|
|
|
897 |
try {
|
|
|
898 |
System.out.println("Before writing file ");
|
|
|
899 |
fileOut = new FileOutputStream(SNAPDEAL_INVENTORY_SHEET);
|
|
|
900 |
} catch (FileNotFoundException e) {
|
|
|
901 |
|
|
|
902 |
e.printStackTrace();
|
|
|
903 |
}
|
|
|
904 |
try {
|
|
|
905 |
|
|
|
906 |
hwb.write(fileOut);
|
|
|
907 |
} catch (IOException e) {
|
|
|
908 |
|
|
|
909 |
e.printStackTrace();
|
|
|
910 |
}
|
|
|
911 |
HttpPost post = new HttpPost("http://seller.snapdeal.com/inventory/upload");
|
|
|
912 |
File file = new File(SNAPDEAL_INVENTORY_SHEET);
|
|
|
913 |
MultipartEntity mpEntity = new MultipartEntity();
|
|
|
914 |
ContentBody cbFile = new FileBody(file,"application/vnd.ms-excel");
|
|
|
915 |
mpEntity.addPart("file", cbFile);
|
|
|
916 |
post.setEntity(mpEntity);
|
|
|
917 |
System.out.println("Before posting file");
|
|
|
918 |
HttpResponse response=null;
|
|
|
919 |
try {
|
|
|
920 |
response = client.execute(post);
|
|
|
921 |
} catch (ClientProtocolException e2) {
|
|
|
922 |
System.out.println("Error While Posting Inventory File");
|
|
|
923 |
e2.printStackTrace();
|
|
|
924 |
} catch (IOException e2) {
|
|
|
925 |
System.out.println("I/O Error While Posting Inventory File");
|
|
|
926 |
e2.printStackTrace();
|
|
|
927 |
}
|
|
|
928 |
BufferedReader rd = null;
|
|
|
929 |
try {
|
|
|
930 |
rd = new BufferedReader(new InputStreamReader(response.getEntity().getContent()));
|
|
|
931 |
} catch (IllegalStateException e1) {
|
|
|
932 |
|
|
|
933 |
e1.printStackTrace();
|
|
|
934 |
} catch (IOException e1) {
|
|
|
935 |
|
|
|
936 |
e1.printStackTrace();
|
|
|
937 |
}
|
|
|
938 |
String line = "";
|
|
|
939 |
String feedresponse = null;
|
|
|
940 |
try {
|
|
|
941 |
while ((line = rd.readLine()) != null) {
|
|
|
942 |
System.out.println(line);
|
|
|
943 |
feedresponse = line;
|
|
|
944 |
}
|
|
|
945 |
} catch (IOException e) {
|
|
|
946 |
|
|
|
947 |
e.printStackTrace();
|
|
|
948 |
}
|
|
|
949 |
System.out.println("posting response" + feedresponse);
|
|
|
950 |
|
|
|
951 |
}
|
|
|
952 |
int retry = 24;
|
|
|
953 |
boolean feedsuccess =false;
|
|
|
954 |
while(retry>0){
|
|
|
955 |
try {
|
| 10371 |
vikram.rag |
956 |
Thread.sleep(5*60*1000);
|
|
|
957 |
} catch (InterruptedException e) {
|
|
|
958 |
e.printStackTrace();
|
|
|
959 |
}
|
|
|
960 |
try {
|
| 10367 |
vikram.rag |
961 |
lastUpdatedInventoryTime = lastSentInventoryTime;
|
|
|
962 |
fetchinventoryhistoryfromsnapdeal();
|
|
|
963 |
} catch (UnsupportedEncodingException e1) {
|
|
|
964 |
System.out.println("Error while fetching inventory update result");
|
|
|
965 |
e1.printStackTrace();
|
| 10371 |
vikram.rag |
966 |
} catch (TException e) {
|
|
|
967 |
e.printStackTrace();
|
| 10367 |
vikram.rag |
968 |
}
|
|
|
969 |
if(inventoryhistoryItemMap.entrySet().size()==iterator -1){
|
|
|
970 |
feedsuccess = true;
|
|
|
971 |
break;
|
|
|
972 |
}
|
|
|
973 |
retry --;
|
|
|
974 |
}
|
|
|
975 |
String PANEL_TEXT_MAIL = "";
|
|
|
976 |
if(PANEL){
|
|
|
977 |
PANEL_TEXT_MAIL = " (Using Panel)";
|
|
|
978 |
}
|
|
|
979 |
String emailSubjectTxt;
|
|
|
980 |
String text;
|
|
|
981 |
String tableHeader;
|
|
|
982 |
if(feedsuccess){
|
| 10369 |
vikram.rag |
983 |
in.shop2020.model.v1.order.TransactionService.Client transactionClient = null;
|
|
|
984 |
try {
|
|
|
985 |
transactionClient = new TransactionClient("support_transaction_service_server_host","transaction_service_server_port").getClient();
|
|
|
986 |
transactionClient.updateSourceDetailTimestamp(7, lastSentInventoryTime);
|
|
|
987 |
} catch (Exception e) {
|
|
|
988 |
try {
|
|
|
989 |
transactionClient = new TransactionClient("support_transaction_service_server_host","transaction_service_server_port").getClient();
|
|
|
990 |
transactionClient.updateSourceDetailTimestamp(7, lastSentInventoryTime);
|
|
|
991 |
} catch (Exception ex) {
|
|
|
992 |
ex.printStackTrace();
|
|
|
993 |
}
|
|
|
994 |
}
|
| 10371 |
vikram.rag |
995 |
InventoryClient inventoryServiceClient = null;
|
|
|
996 |
try {
|
|
|
997 |
inventoryServiceClient = new InventoryClient();
|
|
|
998 |
} catch (TTransportException e1) {
|
|
|
999 |
e1.printStackTrace();
|
|
|
1000 |
}
|
| 10367 |
vikram.rag |
1001 |
in.shop2020.model.v1.inventory.InventoryService.Client inventoryClient = inventoryServiceClient.getClient();
|
|
|
1002 |
try {
|
|
|
1003 |
inventoryClient.addOrUpdateAllSnapdealInventory(snapdealInventoryItemList);
|
|
|
1004 |
} catch (TException e) {
|
|
|
1005 |
e.printStackTrace();
|
|
|
1006 |
inventoryClient = inventoryServiceClient.getClient();
|
| 10371 |
vikram.rag |
1007 |
try {
|
|
|
1008 |
inventoryClient.addOrUpdateAllSnapdealInventory(snapdealInventoryItemList);
|
|
|
1009 |
} catch (TException e1) {
|
|
|
1010 |
e1.printStackTrace();
|
|
|
1011 |
}
|
| 10367 |
vikram.rag |
1012 |
}
|
|
|
1013 |
emailSubjectTxt = "Products back in stock on Snapdeal "+sdf.format(lastSentInventoryTime) + PANEL_TEXT_MAIL;
|
|
|
1014 |
tableHeader = "<tr>"
|
|
|
1015 |
+ "<td>" + "Product Name" +"</td>"
|
|
|
1016 |
+"<td>" + "Item ID" + "</td>"
|
|
|
1017 |
+"<td>" + "Old Inventory" + "</td>"
|
|
|
1018 |
+"<td>" + "New Inventory" + "</td>"
|
|
|
1019 |
+"</tr>";
|
|
|
1020 |
|
|
|
1021 |
if(backInStockItems.length() > 0){
|
|
|
1022 |
text = "<html><table border=\"1\" align=\"center\">"+tableHeader+backInStockItems.toString()+"</table></html>";
|
|
|
1023 |
try {
|
|
|
1024 |
mailer.sendSSLMessage(sendTo,emailSubjectTxt, emailFromAddress, password, text);
|
|
|
1025 |
//mailer.sendSSLMessage(sendTo, emailSubjectTxt, text, emailFromAddress, password, new ArrayList<File>());
|
|
|
1026 |
} catch (MessagingException e) {
|
|
|
1027 |
e.printStackTrace();
|
|
|
1028 |
}
|
|
|
1029 |
}
|
|
|
1030 |
emailSubjectTxt = "Products out of stock on Snapdeal "+sdf.format(lastSentInventoryTime) + PANEL_TEXT_MAIL;
|
|
|
1031 |
if(outOfStockItems.length() > 0){
|
|
|
1032 |
text = "<html><table border=\"1\" align=\"center\">"+tableHeader+outOfStockItems.toString()+"</table></html>";
|
|
|
1033 |
try {
|
|
|
1034 |
mailer.sendSSLMessage(sendTo,emailSubjectTxt, emailFromAddress, password, text);
|
|
|
1035 |
//mailer.sendSSLMessage(sendTo, emailSubjectTxt, text, emailFromAddress, password, new ArrayList<File>());
|
|
|
1036 |
} catch (MessagingException e) {
|
|
|
1037 |
e.printStackTrace();
|
|
|
1038 |
}
|
|
|
1039 |
}
|
|
|
1040 |
emailSubjectTxt = "Snapdeal Inventory Updated for " +(iterator-1)+" items "+ sdf.format(System.currentTimeMillis())+PANEL_TEXT_MAIL;
|
|
|
1041 |
if(inventoryChangeItems.length() > 0){
|
|
|
1042 |
text = "<html><table border=\"1\" align=\"center\">"+tableHeader+inventoryChangeItems.toString()+"</table></html>";
|
|
|
1043 |
try {
|
|
|
1044 |
mailer.sendSSLMessage(sendTo,emailSubjectTxt, emailFromAddress, password, text);
|
|
|
1045 |
} catch (MessagingException e) {
|
|
|
1046 |
e.printStackTrace();
|
|
|
1047 |
}
|
|
|
1048 |
}
|
|
|
1049 |
}
|
|
|
1050 |
else{
|
|
|
1051 |
emailSubjectTxt = "Snapdeal Inventory Could not be updated "+PANEL_TEXT_MAIL+" " +sdf.format(System.currentTimeMillis());
|
| 10371 |
vikram.rag |
1052 |
try {
|
|
|
1053 |
mailer.sendSSLMessage(sendTo,emailSubjectTxt, emailFromAddress, password,"Please contact Engg ");
|
|
|
1054 |
} catch (MessagingException e) {
|
|
|
1055 |
e.printStackTrace();
|
|
|
1056 |
}
|
| 10367 |
vikram.rag |
1057 |
}
|
|
|
1058 |
tableHeader = "<tr>"
|
|
|
1059 |
+ "<td>" + "Product Name" +"</td>"
|
|
|
1060 |
+"<td>" + "Item ID" + "</td>"
|
|
|
1061 |
+"<td>" + "Available - Reserve" + "</td>"
|
|
|
1062 |
+"<td>" + "Total Held" + "</td>"
|
|
|
1063 |
+"</tr>";
|
|
|
1064 |
|
|
|
1065 |
emailSubjectTxt = "Items with (Total Held > Net Available) Inventory "+ sdf.format(System.currentTimeMillis());
|
|
|
1066 |
if(heldMoreThanAvailable.length() > 0){
|
|
|
1067 |
text = "<html><table border=\"1\" align=\"center\">"+tableHeader+heldMoreThanAvailable.toString()+"</table></html>";
|
|
|
1068 |
try {
|
|
|
1069 |
mailer.sendSSLMessage(sendTo,emailSubjectTxt, emailFromAddress, password, text);
|
|
|
1070 |
//mailer.sendSSLMessage(sendTo,"Snapdeal Inventory Updates sent for " +(iterator-1)+" items "+ sdf.format(System.currentTimeMillis()),inventoryChangeItems.toString(), emailFromAddress, password, new ArrayList<File>());
|
|
|
1071 |
} catch (MessagingException e) {
|
|
|
1072 |
e.printStackTrace();
|
|
|
1073 |
}
|
|
|
1074 |
}
|
|
|
1075 |
|
|
|
1076 |
}
|
|
|
1077 |
else{
|
|
|
1078 |
try {
|
|
|
1079 |
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>());
|
|
|
1080 |
} catch (MessagingException e) {
|
|
|
1081 |
e.printStackTrace();
|
|
|
1082 |
}
|
| 10371 |
vikram.rag |
1083 |
try {
|
|
|
1084 |
Thread.sleep(30*60*1000);
|
|
|
1085 |
} catch (InterruptedException e) {
|
|
|
1086 |
e.printStackTrace();
|
|
|
1087 |
}
|
| 10367 |
vikram.rag |
1088 |
}
|
|
|
1089 |
String tableHeader = "<tr>"
|
|
|
1090 |
+ "<td>" + "Product Name" +"</td>"
|
|
|
1091 |
+"<td>" + "SKU at Snapdeal" + "</td>"
|
|
|
1092 |
+"<td>" + "SUPC" + "</td>"
|
|
|
1093 |
+"</tr>";
|
|
|
1094 |
String text;
|
|
|
1095 |
|
|
|
1096 |
if(notMappedItems.length() >0){
|
|
|
1097 |
text = "<html><table border=\"1\" align=\"center\">"+tableHeader+notMappedItems.toString()+"</table></html>";
|
| 10371 |
vikram.rag |
1098 |
try {
|
|
|
1099 |
mailer.sendSSLMessage(sendTo,"Please create Warehouse ID and Item ID mapping", emailFromAddress, password, text);
|
|
|
1100 |
} catch (MessagingException e) {
|
|
|
1101 |
e.printStackTrace();
|
|
|
1102 |
}
|
| 10367 |
vikram.rag |
1103 |
}
|
|
|
1104 |
|
|
|
1105 |
}
|
|
|
1106 |
|
|
|
1107 |
public static void main(String[] args){
|
|
|
1108 |
while(true){
|
|
|
1109 |
sendsnapdealinventory();
|
|
|
1110 |
}
|
|
|
1111 |
|
|
|
1112 |
}
|
|
|
1113 |
|
|
|
1114 |
}
|