WebSVN – SmartDukaan – Diff – /trunk/Support/src/main/java/in/shop2020/support/controllers/SnapdealListController.java

 package in.shop2020.support.controllers;
 import in.shop2020.model.v1.catalog.CatalogService.Client;
 import in.shop2020.model.v1.catalog.CatalogServiceException;
 import in.shop2020.model.v1.catalog.Item;
+import in.shop2020.model.v1.catalog.MarketplaceItems;
 import in.shop2020.model.v1.catalog.SnapdealItem;
 import in.shop2020.model.v1.catalog.SnapdealItemDetails;
+import in.shop2020.model.v1.inventory.InventoryServiceException;
+import in.shop2020.model.v1.inventory.InventoryType;
+import in.shop2020.model.v1.inventory.ItemInventory;
+import in.shop2020.model.v1.inventory.Warehouse;
+import in.shop2020.model.v1.inventory.WarehouseType;
 import in.shop2020.model.v1.order.AmazonFbaSalesSnapshot;
 import in.shop2020.model.v1.order.SnapdealOrder;
 import in.shop2020.support.utils.ReportsUtils;
 import in.shop2020.thrift.clients.CatalogClient;
 import in.shop2020.thrift.clients.InventoryClient;
 import in.shop2020.thrift.clients.TransactionClient;
+import in.shop2020.utils.GmailUtils;
+import javax.mail.MessagingException;
 import java.io.BufferedInputStream;
 import java.io.File;
 import java.io.FileInputStream;
 import java.io.FileNotFoundException;
 	private String isSuppressInventoryFeed;
 	private String isSuppressPriceFeed;
 	private String maxNlc;
 	private String sdItemCode;
 	private String supc;
+	private String held;
+	private String lastUpdatedInventoryTimestamp;
+	private String lastCheckedTimestamp;
+	private String otherCost;
+	private String isAutoIncrement;
+	private String isAutoDecrement;
+	private String isManualFavourite;
+	private String isAutoFavourite;
+	private String currentSp;
+	private String currentTp;
+	private String minPosSp;
+	private String minPosTp;
+	private String vat;
+	public String getVat() {
+		return vat;
+	}
+	public void setVat(String vat) {
+		this.vat = vat;
+	}
+	public String getOtherCost() {
+		return otherCost;
+	}
+	public void setOtherCost(String otherCost) {
+		this.otherCost = otherCost;
+	}
+	public String getCurrentSp() {
+		return currentSp;
+	}
+	public void setCurrentSp(String currentSp) {
+		this.currentSp = currentSp;
+	}
+	public String getCurrentTp() {
+		return currentTp;
+	}
+	public void setCurrentTp(String currentTp) {
+		this.currentTp = currentTp;
+	}
+	public String getLastCheckedTimestamp() {
+		return lastCheckedTimestamp;
+	}
+	public String getLastUpdatedInventoryTimestamp() {
+		return lastUpdatedInventoryTimestamp;
+	}
+	public void setLastUpdatedInventoryTimestamp(
+			String lastUpdatedInventoryTimestamp) {
+		this.lastUpdatedInventoryTimestamp = lastUpdatedInventoryTimestamp;
+	}
+	public void setLastCheckedTimestamp(
+			String lastCheckedTimestamp) {
+		this.lastCheckedTimestamp = lastCheckedTimestamp;
+	}
+	public String getIsAutoIncrement() {
+		return isAutoIncrement;
+	}
+	public void setIsAutoIncrement(String isAutoIncrement) {
+		this.isAutoIncrement = isAutoIncrement;
+	}
+	public String getIsAutoDecrement() {
+		return isAutoDecrement;
+	}
+	public void setIsAutoDecrement(String isAutoDecrement) {
+		this.isAutoDecrement = isAutoDecrement;
+	}
+	public String getIsManualFavourite() {
+		return isManualFavourite;
+	}
+	public void setIsManualFavourite(String isManualFavourite) {
+		this.isManualFavourite = isManualFavourite;
+	}
+	public String getIsAutoFavourite() {
+		return isAutoFavourite;
+	}
+	public void setIsAutoFavourite(String isAutoFavourite) {
+		this.isAutoFavourite = isAutoFavourite;
+	}
+	public String getMinPosSp() {
+		return minPosSp;
+	}
+	public void setMinPosSp(String minPosSp) {
+		this.minPosSp = minPosSp;
+	}
+	public String getMinPosTp() {
+		return minPosTp;
+	}
+	public void setMinPosTp(String minPosTp) {
+		this.minPosTp = minPosTp;
+	}
+	public String getHeld() {
+		return held;
+	}
+	public void setHeld(String held) {
+		this.held = held;
+	}
 	public String getSupc() {
 		return supc;
+	}
 	public void setSupc(String supc) {
 		return "snapdeal-item-table";
+	}
 	public SnapdealItemDetails fetchItemDetail() throws NumberFormatException, TException {
 		Client CatalogClient = new CatalogClient("catalog_service_server_host_amazon","catalog_service_server_port").getClient();
-		return CatalogClient.getSnapdealItemDetails(Long.valueOf(id));
+		SnapdealItemDetails sdItemDetails = CatalogClient.getSnapdealItemDetails(Long.valueOf(id));
+		lastUpdatedInventoryTimeStampForItem(sdItemDetails.getLastUpdatedInventoryTimestamp());
+		return sdItemDetails;
+	}
+	public MarketplaceItems fetchMarketplaceDetail() throws NumberFormatException, TException {
+		Client CatalogClient = new CatalogClient("catalog_service_server_host_amazon","catalog_service_server_port").getClient();
+		MarketplaceItems mpItemDetails = CatalogClient.getMarketplacedetailsForItem(Long.valueOf(id), 7);
+		lastCheckedTimeStampForItem(mpItemDetails.getLastCheckedTimestamp());
+		return mpItemDetails;
+	}
+	public void lastUpdatedInventoryTimeStampForItem(long timestamp){
+		setLastUpdatedInventoryTimestamp(new java.util.Date(timestamp).toLocaleString());
+	}
+	public void lastCheckedTimeStampForItem(long timestamp){
+		setLastCheckedTimestamp(new java.util.Date(timestamp).toLocaleString());
+	}
 	public String uploadBulkSheet(){
 		if(!ReportsUtils.canAccessReport((Long)session.getAttribute(ReportsUtils.ROLE), request.getRequestURI().substring(request.getContextPath().length()).split("/")[1].split("!")[0])) {
 			logger.info(request.getRequestURI().substring(request.getContextPath().length()).split("/")[1].split("!")[0]);
 			return "authfail";
+		}
 		return "snapdeal-bulk-upload";
+	}
-	public String update() throws NumberFormatException, TException{
+	public void update() throws NumberFormatException, TException, InventoryServiceException, CatalogServiceException{
 		Client catalogClient = new CatalogClient("catalog_service_server_host_amazon","catalog_service_server_port").getClient();
 		SnapdealItem snapdealItem = catalogClient.getSnapdealItem(Long.valueOf(itemId));
+		MarketplaceItems mpItem = catalogClient.getMarketplacedetailsForItem(Long.valueOf(itemId),7);
+		InventoryClient inventoryServiceClient = new InventoryClient();
+		in.shop2020.model.v1.inventory.InventoryService.Client inventoryClient = inventoryServiceClient.getClient();
+		Warehouse warehouse = inventoryClient.getWarehouse(Long.valueOf(warehouseId));
+		if (!(warehouse.getWarehouseType()==WarehouseType.OURS && warehouse.getInventoryType() == InventoryType.GOOD)){
+			throw new InventoryServiceException();
+		}
 		boolean commit = false;
 		if (snapdealItem.getWarehouseId()!=Long.valueOf(warehouseId)){
 			snapdealItem.setWarehouseId(Long.valueOf(warehouseId));
 			commit = true;
+		}
+		}
 		if (commit){
 			catalogClient.addOrUpdateSnapdealItem(snapdealItem);
+		}
+		MarketplaceItems t_mpItem = updateMarketplaceItemDetails(mpItem);
+		boolean result =catalogClient.updateMarketplaceAttributesForItem(t_mpItem);
-		return "index";
+		if(!result){
+			throw new CatalogServiceException();
+		}
+		if (t_mpItem.getCurrentSp()< t_mpItem.getMinimumPossibleSp()){
+			sendAlert(t_mpItem.getItemId(),t_mpItem.getCurrentSp(),t_mpItem.getMinimumPossibleSp());
+		}
+	}
+	private MarketplaceItems updateMarketplaceItemDetails(MarketplaceItems mpItem){
+		mpItem.setItemId(Long.valueOf(itemId));
+		mpItem.setSource(7);
+		mpItem.setVat(Double.valueOf(vat));
+		mpItem.setCourierCost(Double.valueOf(courierCost));
+		mpItem.setOtherCost(Double.valueOf(otherCost));
+		mpItem.setCurrentSp(Double.valueOf(sellingPrice));
+		mpItem.setCurrentTp(Double.valueOf(transferPrice));
+		mpItem.setAutoDecrement(Boolean.valueOf(isAutoDecrement));
+		mpItem.setAutoIncrement(Boolean.valueOf(isAutoIncrement));
+		mpItem.setManualFavourite(Boolean.valueOf(isManualFavourite));
+		mpItem.setMinimumPossibleSp(Double.valueOf(minPosSp));
+		mpItem.setMinimumPossibleTp(Double.valueOf(minPosTp));
+		return mpItem;
+	}
+	private void sendAlert(long itemId,double sp,double minSp){
+		Item item;
+		try{
+			Client catalogClient = new CatalogClient("catalog_service_server_host_amazon","catalog_service_server_port").getClient();
+			item= catalogClient.getItem(itemId);
+		}
+		catch(Exception e){
+			e.printStackTrace();
+			return;
+		}
+		String emailSubjectTxt="Snapdeal SP is set below Min Possible SP";
+		String[] sendTo=new String[]{ "kshitij.sood@shop2020.in"};
-	public String addNewItem() throws TException{
+		String text = "Item Details\nItem Id: "+itemId+"\nProduct Name: "+item.getBrand()+" "+item.getModelName()+" "+item.getModelNumber()+" "+item.getColor()+"\nSellingPrice: "+sp+"\nMinPossibleSp: "+minSp+"\nUpdated By: "+session.getAttribute(ReportsUtils.USER_NAME).toString();
+		logger.info(text);
+		String emailFromAddress = "build@shop2020.in";
+		String password = "cafe@nes";
+		GmailUtils mailer = new GmailUtils();
+		try {
+			mailer.sendSSLMessage(sendTo, emailSubjectTxt, text, emailFromAddress, password, "");
+		}
+		catch (Exception e) {
+			e.printStackTrace();
+		}
+	}
+	public void addNewItem() throws TException, NumberFormatException, InventoryServiceException, CatalogServiceException{
+		InventoryClient inventoryServiceClient = new InventoryClient();
+		in.shop2020.model.v1.inventory.InventoryService.Client inventoryClient = inventoryServiceClient.getClient();
+		Warehouse warehouse = inventoryClient.getWarehouse(Long.valueOf(warehouseId));
+		if (!(warehouse.getWarehouseType()==WarehouseType.OURS && warehouse.getInventoryType() == InventoryType.GOOD)){
+			throw new InventoryServiceException();
+		}
 		SnapdealItem snapdealItem = new SnapdealItem();
 		snapdealItem.setItem_id(Long.valueOf(itemId));
 		snapdealItem.setWarehouseId(Long.valueOf(warehouseId));
 		snapdealItem.setIsListedOnSnapdeal(Boolean.valueOf(isListedOnSnapdeal));
 		snapdealItem.setSuppressInventoryFeed(Boolean.valueOf(isSuppressInventoryFeed));
 		snapdealItem.setCommission(Double.valueOf(commission));
 		snapdealItem.setServiceTax(Double.valueOf(serviceTax));
 		snapdealItem.setMaxNlc(Double.valueOf(maxNlc));
 		snapdealItem.setSkuAtSnapdeal(sdItemCode);
 		snapdealItem.setSupc(supc);
+		MarketplaceItems mpItem = new MarketplaceItems();
+		MarketplaceItems t_mpItem = updateMarketplaceItemDetails(mpItem);
 		Client catalogClient = new CatalogClient("catalog_service_server_host_amazon","catalog_service_server_port").getClient();
 		catalogClient.addOrUpdateSnapdealItem(snapdealItem);
+		boolean result =catalogClient.updateMarketplaceAttributesForItem(t_mpItem);
-		return "index";
+		if(!result){
+			throw new CatalogServiceException();
+		}
+		if (t_mpItem.getCurrentSp()< t_mpItem.getMinimumPossibleSp()){
+			sendAlert(t_mpItem.getItemId(),t_mpItem.getCurrentSp(),t_mpItem.getMinimumPossibleSp());
+		}
+	}
 	public String getAddNewItemForm(){
 		return "snapdeal-add-item";
+	}
-	public String getItemDetailsInJson() throws NumberFormatException, CatalogServiceException, TException, JSONException{
+	public String getItemDetailsInJson() throws NumberFormatException, CatalogServiceException, TException, JSONException, InventoryServiceException{
 		Client catalogClient =new CatalogClient("catalog_service_server_host_amazon","catalog_service_server_port").getClient();
 		SnapdealItem snapdealItem = catalogClient.getSnapdealItem(Long.valueOf(itemId));
 		if (snapdealItem.getItem_id()!=0){
 			throw new CatalogServiceException();
+		}
 		if (item.getId()==0){
 			throw new CatalogServiceException();
+		}
 		InventoryClient inventoryServiceClient = new InventoryClient();
 		in.shop2020.model.v1.inventory.InventoryService.Client inventoryClient = inventoryServiceClient.getClient();
+		Warehouse warehouse = inventoryClient.getWarehouse(Long.valueOf(warehouseId));
+		if (!(warehouse.getWarehouseType()==WarehouseType.OURS && warehouse.getInventoryType() == InventoryType.GOOD)){
+			throw new InventoryServiceException();
+		}
 		double maxNLC = inventoryClient.getNlcForWarehouse(Long.valueOf(warehouseId), Long.valueOf(itemId));
 		itemObj = new JSONObject();
 		itemObj.put("ItemId", item.getId());
 		itemObj.put("Brand", item.getBrand());
 		itemObj.put("ModelName", item.getModelName());
 		itemObj.put("SellingPrice", item.getSellingPrice());
 		itemObj.put("MaxNlc", maxNLC);
 		return "item-details-json";
+	}
-	public String ke$ha() throws NumberFormatException, TException, JSONException{
+	public String ke$ha() throws NumberFormatException, TException, JSONException, InventoryServiceException{
 		InventoryClient inventoryServiceClient = new InventoryClient();
 		in.shop2020.model.v1.inventory.InventoryService.Client inventoryClient = inventoryServiceClient.getClient();
+		Warehouse warehouse = inventoryClient.getWarehouse(Long.valueOf(warehouseId));
+		if (warehouse.getWarehouseType()==WarehouseType.OURS && warehouse.getInventoryType() == InventoryType.GOOD){
-		double maxNLC = inventoryClient.getNlcForWarehouse(Long.valueOf(warehouseId), Long.valueOf(itemId));
+			double maxNLC = inventoryClient.getNlcForWarehouse(Long.valueOf(warehouseId), Long.valueOf(itemId));
-		itemObj = new JSONObject();
+			itemObj = new JSONObject();
-		itemObj.put("ItemId", itemId);
+			itemObj.put("ItemId", itemId);
-		itemObj.put("WarehouseId", warehouseId);
+			itemObj.put("WarehouseId", warehouseId);
-		itemObj.put("MaxNlc", maxNLC);
+			itemObj.put("MaxNlc", maxNLC);
+		}
+		else{
+			itemObj = new JSONObject();
+			throw new InventoryServiceException();
+		}
 		return "item-details-json";
+	}
+	public ItemInventory getItemInventory(String itemId) throws NumberFormatException, InventoryServiceException, TException{
+		try{
+			InventoryClient inventoryServiceClient = new InventoryClient();
+			in.shop2020.model.v1.inventory.InventoryService.Client inventoryClient = inventoryServiceClient.getClient();
+			in.shop2020.model.v1.inventory.ItemInventory thriftItemInventory = inventoryClient.getItemInventoryByItemId(Long.valueOf(itemId));
+			return thriftItemInventory;
+		}
+		catch(Exception e){
+			logger.error("Unable to get inventory info for item",e);
+			return null;
+		}
+	}
+	public Warehouse getWarehouse(String warehouseId) throws NumberFormatException, TException, InventoryServiceException {
+		InventoryClient inventoryServiceClient = new InventoryClient();
+		return inventoryServiceClient.getClient().getWarehouse(Long.valueOf(warehouseId));
+	}
+	public void changeHeldForSource() throws NumberFormatException, TException, InventoryServiceException{
+		InventoryClient inventoryServiceClient = new InventoryClient();
+		Warehouse warehouse = inventoryServiceClient.getClient().getWarehouse(Long.valueOf(warehouseId));
+		if (!(warehouse.getWarehouseType()==WarehouseType.OURS && warehouse.getInventoryType() == InventoryType.GOOD)){
+			throw new InventoryServiceException();
+		}
+		inventoryServiceClient.getClient().addUpdateHoldInventory(Long.valueOf(itemId),Long.valueOf(warehouseId),Long.valueOf(held),7);
+	}
 	public void downloadSnapdealListings() throws IOException, TException{
 		File file = new File("/tmp/snapdeal-bulk-upload-template.xls");
 		HSSFWorkbook hwb=new HSSFWorkbook();
 		HSSFSheet sheet =  hwb.createSheet("Snapdeal-Listings");
 		HSSFRow rowhead=   sheet.createRow((short)0);
+		}
+	}
-	public void uploadsnapdealBulkSheet() throws IOException, TException{
+	public void uploadsnapdealBulkSheet() throws IOException, TException, NumberFormatException, InventoryServiceException{
 		File fileToCreate = new File("/tmp/", "Snapdeal-bulk-upload.xls");
 		FileUtils.copyFile(this.file, fileToCreate);
 		FileInputStream iFile = new FileInputStream(new File(file.getAbsolutePath()));
 		HSSFWorkbook workbook = new HSSFWorkbook(iFile);
 		HSSFSheet sheet = workbook.getSheetAt(0);
 					new_item = true;
 					snapdealItem = new SnapdealItem();
 					snapdealItem.setItem_id(sku);
+				}
+			}
 			if (checkEmptyString(sheet.getRow(iterator).getCell(1)) && new_item){
 				sb.append(sku + " New Listing - Warehouse Id not Present"+"\n");
 				continue;
+			}
 			if (!checkEmptyString(sheet.getRow(iterator).getCell(1))){
+				Warehouse warehouse = inventoryClient.getWarehouse(Long.valueOf(warehouseId));
+				if (!(warehouse.getWarehouseType()==WarehouseType.OURS && warehouse.getInventoryType() == InventoryType.GOOD)){
+					sb.append(sku + "Not acceptable warehouse"+"\n");
+					continue;
+				}
 				long warehouseId = (long) sheet.getRow(iterator).getCell(1).getNumericCellValue();
 				double maxNLC = inventoryClient.getNlcForWarehouse(warehouseId, item.getId());
 				if (maxNLC==0){
 					sb.append(sku + "Max Nlc can't be 0"+"\n");
 					continue;
+				}
 				if ((long)sheet.getRow(iterator).getCell(6).getNumericCellValue()==0){
 					snapdealItem.setSuppressInventoryFeed(false);
+				}
+			}
 			if (!checkEmptyString(sheet.getRow(iterator).getCell(7))){
 				sheet.getRow(iterator).getCell(7).setCellType(Cell.CELL_TYPE_STRING);
 				String snapdealItemCode = sheet.getRow(iterator).getCell(7).getStringCellValue();
 				snapdealItem.setSkuAtSnapdeal(snapdealItemCode);
+			}
 			if (!checkEmptyString(sheet.getRow(iterator).getCell(8))){
 				sheet.getRow(iterator).getCell(8).setCellType(Cell.CELL_TYPE_STRING);
 				String supc = sheet.getRow(iterator).getCell(8).getStringCellValue();
 				snapdealItem.setSupc(supc);
+			}
 	public String show() {
 		logger.info("Before fetching role");
 		logger.info(request.getSession().toString());
 		logger.info(ReportsUtils.ROLE);
-		logger.info(session.getAttribute(ReportsUtils.ROLE).toString());
+		logger.info(session.getAttribute(ReportsUtils.USER_NAME).toString());
 		logger.info(request.getRequestURI().substring(request.getContextPath().length()).split("/")[1]);
 		if(!ReportsUtils.canAccessReport((Long)session.getAttribute(ReportsUtils.ROLE), request.getRequestURI().substring(request.getContextPath().length()).split("/")[1])) {
 			logger.info(request.getRequestURI().substring(request.getContextPath().length()).split("/")[1]);
 			return "authfail";
+		}
 	public String getItemDetails(){
 		return itemObj.toString();
+	}
+	public double getRoundOfValue(String val){
+		return roundTwoDecimals(Double.valueOf(val));
+	}
+}

Subversion Repositories SmartDukaan

(root)/trunk/Support/src/main/java/in/shop2020/support/controllers/SnapdealListController.java – Rev 9597 → 9725