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

 import java.io.File;
 import java.io.FileInputStream;
 import java.io.FileWriter;
 import java.io.IOException;
 import java.io.InputStream;
+import java.util.Arrays;
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
 import javax.servlet.ServletContext;
 import org.slf4j.LoggerFactory;
 import com.opensymphony.xwork2.ValidationAwareSupport;
 @SuppressWarnings("serial")
 @InterceptorRefs({
 	@InterceptorRef("defaultStack"),
 	@InterceptorRef("login")
 })
 @Results({
 	private String fileUploadContentType;
 	private String suppressMfnPriceUpdate;
 	private String suppressFbaPriceUpdate;
 	private File file;
 	private String errMsg;
+	private String next;
+	private List<Amazonlisted> amazonItems;
+	private String searchText;
+	private long searchCount;
+	private long totalCount;
+	private String taxCode;
 	public String index() {
-		if(!ReportsUtils.canAccessReport((Long)session.getAttribute(ReportsUtils.ROLE), request.getServletPath())) {
+		if (!ReportsUtils.canAccessReport((Long) session.getAttribute(ReportsUtils.ROLE),request.getServletPath())) {
 			return "authfail";
+		}
 		return "index";
+	}
-	public List<Amazonlisted> fetchItems() throws TException {
+	public String fetchItems() throws TException {
 		Client CatalogClient = new CatalogClient("catalog_service_server_host_amazon","catalog_service_server_port").getClient();
+		if (searchText.length() == 0) {
+			amazonItems = CatalogClient.getAmazonListedItems(Long.valueOf(next), 10);
-		return CatalogClient.getAllAmazonListedItems();
+			totalCount = CatalogClient.getCountForAmazonlistedItems();
+			setSearchCount(totalCount);
+		} else {
+			List<String> subString = Arrays.asList(searchText.split(" "));
+			amazonItems = CatalogClient.searchAmazonItems(subString,Long.valueOf(next), 10);
+			totalCount = CatalogClient.getCountForAmazonlistedItems();
+			searchCount = CatalogClient.getAmazonSearchResultCount(subString);
+		}
+		return "amazon-item-table";
+	}
 	public Amazonlisted fetchItemDetail() throws NumberFormatException, TException {
 		Client CatalogClient = new CatalogClient("catalog_service_server_host_amazon","catalog_service_server_port").getClient();
 		return CatalogClient.getAmazonItemDetails(Long.valueOf(id));
+	}
+		}
 		if(amazonlisted.isSuppressFbaPriceUpdate()!=Boolean.valueOf(suppressFbaPriceUpdate)){
 			amazonlisted.setSuppressFbaPriceUpdate(Boolean.valueOf(suppressFbaPriceUpdate));
 			commit=true;
+		}
+		if(!StringUtils.equals(amazonlisted.getTaxCode(), taxCode)){
+			amazonlisted.setTaxCode(taxCode);
+			commit=true;
+		}
 		if(commit){
 			CatalogClient.updateAmazonItemDetails(amazonlisted);
+		}
 		else{
 			logger.info("Nothing new to commit");
+		}
-		//setUrl("/amazon-list/");
 		return "index";
+	}
 	public void upload() throws IOException, TException {
+		}
 		TransactionClient tcl = new TransactionClient();
 		tcl.getClient().updateTimestampForAmazonOrder(amazonOrderMap);
+	}
 	private void changeItemInventory() throws NumberFormatException, TException {
 		Client CatalogClient = new CatalogClient("catalog_service_server_host_amazon","catalog_service_server_port").getClient();
 		if (StringUtils.isEmpty(holdInventory)) {
 			holdInventory = "0";
 		catch (Exception e){
 			return null;
+		}
+	}
+	public long getFbaInventoryForAmazonItem(String itemId) throws NumberFormatException, TException {
+		InventoryClient inventoryServiceClient = new InventoryClient();
+		try {
+			return inventoryServiceClient.getClient().getAmazonFbaItemInventory(Long.valueOf(itemId));
+		}
+		catch (Exception e){
+			return 0;
+		}
+	}
 	public Long getTimetoShip(String itemId) throws LogisticsServiceException, TException{
 		LogisticsClient logisticsClient = new LogisticsClient();
 		return logisticsClient.getClient().getLogisticsInfo("110001", Long.valueOf(itemId), DeliveryType.COD, PickUpType.COURIER).getShippingTime();
+	}
-	public  Map<Long, Item> getAliveItemMap() throws TTransportException, InterruptedException{
-		List<Item> itemList = null;
-		int retry=0;
-		while(true){
-			try {
-				if (retry==3)
-					break;
-				Client CatalogClient = new CatalogClient("catalog_service_server_host_amazon","catalog_service_server_port").getClient();
-				itemList = CatalogClient.getAllAliveItems();
-				break;
-			} catch ( NullPointerException e) {
-				retry++;
-				System.out.println("Unable to fetch alive items.Retrying");
-				Thread.sleep(3000);
-				e.printStackTrace();
-			} catch (TException e) {
-				retry++;
-				System.out.println("Unable to fetch alive items.Retrying");
-				Thread.sleep(3000);
-				e.printStackTrace();
-			}
-		}
-		Map<Long, Item> itemMap = new HashMap<Long, Item>();
-		for (Item o : itemList) {
-			itemMap.put((Long) o.getId(), o);
-		}
-		return itemMap;
-	}
 	public String runAsinJob() throws IOException, InterruptedException {
 		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";
+		}
 		process.waitFor();
 		logger.info(String.valueOf(process.exitValue()));
 		return "asinjob";
+	}
 	public String runFbaListingJob() throws IOException, InterruptedException {
 		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";
+		}
 		Process process = testProcess.start();
 		process.waitFor();
 		logger.info(String.valueOf(process.exitValue()));
 		return "asinjob";
+	}
 	public String runNonFbaListingJob() throws IOException, InterruptedException {
 		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";
+		}
 		process.waitFor();
 		logger.info(String.valueOf(process.exitValue()));
 		return "asinjob";
+	}
+	public void uploadAsinFile() throws IOException, TException{
+		File fileToCreate = new File("/tmp/", "Amazon-asin-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);
+		Map<Long,Item> amazonAsin = new HashMap<Long,Item>();
+		StringBuilder sb =new StringBuilder();
+		Client CatalogClient=null;
+		try {
+			CatalogClient = new CatalogClient("catalog_service_server_host_amazon","catalog_service_server_port").getClient();
+		} catch (TTransportException e) {
+			e.printStackTrace();
+		}
+		for (int iterator=(sheet.getFirstRowNum()+1);iterator<=sheet.getLastRowNum();iterator++){
+			Item item=null;
+			Long sku;
+			String asin;
+			if (checkEmptyString(sheet.getRow(iterator).getCell(0))){
+				continue;
+			}
+			else {
+				sku=(long) sheet.getRow(iterator).getCell(0).getNumericCellValue();
+				try {
+					item = CatalogClient.getItem(sku);
+				} catch (Exception e) {
+					logger.info("Unable to fetch item details ID= "+sku);
+					logger.info("Unable to fetch item. "+e);
+					sb.append("Service exception ItemId not updated Id= "+sku+"\n");
+					continue;
+				}
+			}
+			if(item.getId() == 0){
+				logger.info("Item Id doesn't exist in catalog Id= "+sku);
+				sb.append("Item Id doesn't exist in catalog Id= "+sku+"\n");
+				continue;
+			}
+			if (!checkEmptyString(sheet.getRow(iterator).getCell(1))){
+				asin = sheet.getRow(iterator).getCell(1).getStringCellValue();
+				item.setAsin(asin);
+			}
+			if (!checkEmptyString(sheet.getRow(iterator).getCell(2))){
+				long virtualInventory =(long) sheet.getRow(iterator).getCell(2).getNumericCellValue();
+				item.setDefaultInventory(virtualInventory);
+			}
+			if (!checkEmptyString(sheet.getRow(iterator).getCell(3))){
+				long riskyInventory =(long) sheet.getRow(iterator).getCell(3).getNumericCellValue();
+				item.setHoldInventory(riskyInventory);
+			}
+			amazonAsin.put(sku, item);
+		}
+		CatalogClient.updateAsin(amazonAsin);
+		logger.info("Amazon Asin Map "+amazonAsin.toString());
+		CatalogClient = new CatalogClient("catalog_service_server_host_amazon","catalog_service_server_port").getClient();
+		CatalogClient.updateAsin(amazonAsin);
+		File file = new File("/tmp/asinfile");
+		FileWriter writer = new FileWriter(file);
+		writer.append(sb.toString());
+		writer.close();
+		byte[] buffer = new byte[(int)file.length()];
+		InputStream input = null;
+		try {
+			int totalBytesRead = 0;
+			input = new BufferedInputStream(new FileInputStream(file));
+			while(totalBytesRead < buffer.length){
+				int bytesRemaining = buffer.length - totalBytesRead;
+				int bytesRead = input.read(buffer, totalBytesRead, bytesRemaining);
+				if (bytesRead > 0){
+					totalBytesRead = totalBytesRead + bytesRead;
+				}
+			}
+		}
+		finally {
+			input.close();
+			file.delete();
+		}
+		response.setHeader("Content-Type", "text/javascript");
+		ServletOutputStream sos;
+		try {
+			sos = response.getOutputStream();
+			sos.write(buffer);
+			sos.flush();
+		} catch (IOException e) {
+			System.out.println("Unable to stream the manifest file");
+		}
+	}
 	public void uploadBulkFile() throws IOException, TException{
 		File fileToCreate = new File("/tmp/", "Amazon-bulk-upload.xls");
 		FileUtils.copyFile(this.file, fileToCreate);
 		FileInputStream iFile = new FileInputStream(new File(file.getAbsolutePath()));
 		HSSFWorkbook workbook = new HSSFWorkbook(iFile);
 					logger.info("Unable to fetch item details ID= "+sku);
 					sb.append("Service exception ItemId not updated Id= "+sku+"\n");
 					continue;
+				}
+			}
 			if(amazonlisted.getItemid() == 0){
 				logger.info("Item Id doesn't exist in amazonlisted Id= "+sku);
 				sb.append("Item Id doesn't exist in amazonlisted Id= "+sku+"\n");
 				continue;
+			}
+				}
 				if ((long)sheet.getRow(iterator).getCell(7).getNumericCellValue()==0){
 					amazonlisted.setSuppressFbaPriceUpdate(false);
+				}
+			}
+			if (!checkEmptyString(sheet.getRow(iterator).getCell(8))){
+				String taxCode = sheet.getRow(iterator).getCell(8).getStringCellValue();
+				amazonlisted.setTaxCode(taxCode);
+			}
 			amazonBulkUpdate.put(sku, amazonlisted);
+		}
 		logger.info("Amazon Bulk Map "+amazonBulkUpdate.toString());
 		CatalogClient = new CatalogClient("catalog_service_server_host_amazon","catalog_service_server_port").getClient();
 		CatalogClient.updateAmazonAttributesInBulk(amazonBulkUpdate);
-		File file = new File("/tmp/temp");
+		File file = new File("/tmp/amazonbulk");
 		FileWriter writer = new FileWriter(file);
 		writer.append(sb.toString());
 		writer.close();
 		byte[] buffer = new byte[(int)file.length()];
 		InputStream input = null;
 			System.out.println("Unable to stream the manifest file");
+		}
+	}
 	public boolean checkEmptyString(Cell cell){
 		if (cell==null){
 			return true;
+		}
 		return false;
 			return "authfail";
+		}
 		return "amazon-shipping-upload";
+	}
+	public String uploadAsin(){
+		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 "amazon-asin-upload";
+	}
 	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";
+		}
+		}
 		if (StringUtils.equals(id, "options")){
 			return "options";
+		}
+		if (StringUtils.equals(id, "item-table")){
+			return "amazon-item-table";
+		}
 		return "id";
+	}
 	public String editNew() {
 		return "editNew";
 	public String getSaholicPrice() {
 		return saholicPrice;
+	}
 	public void setIsTime(String isTime){
+		logger.info("set istime"+isTime);
 		this.isTime = isTime;
+	}
 	public String getIsTime(){
 		return isTime;
 	public String getHandlingTime(){
 		return handlingTime;
+	}
 	public void setCustomHandlingTime(String customHandlingTime){
+		logger.info("set custom handling time"+customHandlingTime);
 		this.customHandlingTime = customHandlingTime;
+	}
 	public String getCustomHandlingTime(){
 		return customHandlingTime;
 	public void setServletRequest(HttpServletRequest req) {
 		this.request = req;
 		this.session = req.getSession();
+	}
-	public static void main(String[] args) throws NumberFormatException, InventoryServiceException, TException, IOException {
-		AmazonListController call = new AmazonListController();
-		//System.out.println(call.runAsinJob());
-	}
 	@Override
 	public void setServletContext(ServletContext arg0) {
 		// TODO Auto-generated method stub
+	}
+	}
 	public String getErrMsg() {
 		return errMsg;
+	}
 	public void setServletResponse(HttpServletResponse response) {
 		this.response = response;
+	}
+	public void setNext(String next) {
+		logger.info("next is"+next);
+		this.next = next;
+	}
+	public String getNext() {
+		return next;
+	}
+	public void setAmazonItems(List<Amazonlisted> amazonItems) {
+		this.amazonItems = amazonItems;
+	}
+	public List<Amazonlisted> getAmazonItems() {
+		return amazonItems;
+	}
+	public void setSearchText(String searchText) {
+		this.searchText = searchText;
+	}
+	public String getSearchText() {
+		return searchText;
+	}
+	public long getSearchCount() {
+		return searchCount;
+	}
+	public long getTotalCount() {
+		return totalCount;
+	}
+	public void setSearchCount(long count) {
+		this.searchCount = count;
+	}
+	public void setTaxCode(String taxCode) {
+		this.taxCode = taxCode;
+	}
+	public String getTaxCode() {
+		return taxCode;
+	}
+}

Subversion Repositories SmartDukaan

(root)/trunk/Support/src/main/java/in/shop2020/support/controllers/AmazonListController.java – Rev 8396 → 8620