Subversion Repositories SmartDukaan

Rev

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

Rev 1367 Rev 3104
Line 10... Line 10...
10 
import in.shop2020.support.models.Update;
 10 
import in.shop2020.support.models.Update;
11 
import in.shop2020.thrift.clients.CatalogServiceClient;
 11 
import in.shop2020.thrift.clients.CatalogServiceClient;
12 
 
 12 
 
13 
import org.apache.struts2.rest.DefaultHttpHeaders;
 13 
import org.apache.struts2.rest.DefaultHttpHeaders;
14 
import org.apache.struts2.rest.HttpHeaders;
 14 
import org.apache.struts2.rest.HttpHeaders;
- 
 
 15 
import org.slf4j.Logger;
- 
 
 16 
import org.slf4j.LoggerFactory;
- 
 
 17 
 
15 
import com.opensymphony.xwork2.ModelDriven;
 18 
import com.opensymphony.xwork2.ModelDriven;
16 
 
 19 
 
17 
public class UpdatesController implements ModelDriven<InventoryUpdate>{
 20 
public class UpdatesController implements ModelDriven<InventoryUpdate>{
18 
 
 21 
 
- 
 
 22 
    private static Logger logger = LoggerFactory.getLogger(UpdatesController.class);
- 
 
 23
19 
	private InventoryUpdate inventoryUpdate = new InventoryUpdate();
 24 
	private InventoryUpdate inventoryUpdate = new InventoryUpdate();
20 
	private String timestamp;
 25 
	private String timestamp;
21
26
22 
	private int errorCode = 0;
 27 
	private int errorCode = 0;
23 
	private String errorMessage;
 28 
	private String errorMessage;
Line 33... Line 38...
33 
	public InventoryUpdate getModel() {
 38 
	public InventoryUpdate getModel() {
34 
		return this.inventoryUpdate;
 39 
		return this.inventoryUpdate;
35 
	}
 40 
	}
36
41
37 
	public HttpHeaders show(){
 42 
	public HttpHeaders show(){
38 
		System.out.println("Warehouse Id is:  " + getId());
 43 
		logger.info("Status requested for warehouse id: " + getId());
39 
		CatalogServiceClient catalogServiceClient;
 44 
		CatalogServiceClient catalogServiceClient;
40 
		Client client;
 45 
		Client client;
41
46
42 
		try {
 47 
		try {
43 
			catalogServiceClient = new CatalogServiceClient();
 48 
			catalogServiceClient = new CatalogServiceClient();
44 
			client = catalogServiceClient.getClient();
 49 
			client = catalogServiceClient.getClient();
45 
			long warehouseId = Long.parseLong(getId());
 50 
			long warehouseId = Long.parseLong(getId());
46 
			Warehouse warehouse = client.getWarehouse(warehouseId);
 51 
			Warehouse warehouse = client.getWarehouse(warehouseId);
47 
			setTimestamp(warehouse.getVendorString());
 52 
			setTimestamp(warehouse.getVendorString());
48 
		} catch (Exception e) {
 53 
		} catch (Exception e) {
49 
			e.printStackTrace();
 54 
			logger.error("Error getting the warehouse or setting the timestamp", e);
50 
		}
 55 
		}
51 
		return new DefaultHttpHeaders("lsuccess");
 56 
		return new DefaultHttpHeaders("lsuccess");
52 
	}
 57 
	}
53
58
54
59
55 
	public HttpHeaders create(){
 60 
	public HttpHeaders create(){
56 
		System.out.println(inventoryUpdate);
 61 
		logger.info(inventoryUpdate.toString());
57 
		// need to store all data from object to service
 62 
		// need to store all data from object to service
58 
		CatalogServiceClient catalogServiceClient;
 63 
		CatalogServiceClient catalogServiceClient;
59 
		Client client;
 64 
		Client client;
60 
		try {
 65 
		try {
61 
			catalogServiceClient = new CatalogServiceClient();
 66 
			catalogServiceClient = new CatalogServiceClient();
Line 73... Line 78...
73 
				availability.put(key, quantity);
 78 
				availability.put(key, quantity);
74 
			}
 79 
			}
75 
			client.updateInventory(warehouseId, timestamp, availability);
 80 
			client.updateInventory(warehouseId, timestamp, availability);
76
81
77 
		} catch (Exception e) {
 82 
		} catch (Exception e) {
78 
			e.printStackTrace();
 83 
			logger.error("Unable to update inventory", e);
79 
		}
 84 
		}
80
85
81 
		return new DefaultHttpHeaders("psuccess");
 86 
		return new DefaultHttpHeaders("psuccess");
82 
 
 87 
 
83 
	}
 88 
	}