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



			return "authfail";
		}
		return "edit";
	}
 
 
	public String show() {
		if(!ReportsUtils.canAccessReport((Long)session.getAttribute(ReportsUtils.ROLE), request.getRequestURI().substring(request.getContextPath().length()).split("/")[1])) {
			return "authfail";
		}
		logger.info("Inside show for "+id);
 
		if (StringUtils.equals(id, "bulk-add-options")){
			return "bulk-add-options";
		}
		return "id";
	}
 
	public String loadVendorDiv(){
		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 "vendor-item-pricing-upload";
	}
 
	public String loadVirtualDiv(){
		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 "virtual-bulk-add";
	}
 
	public String loadCatalogDiv(){
		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 "catalog-bulk-add";
	}
 
	public String loadDtrDiv(){
		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 "dtr-bulk-add";
	}
 
	public String uploadItemsDtr() throws IOException, CatalogServiceException, TException{
		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";
		}
		File fileToCreate = new File("/tmp/", "dtr-items.xls");
		FileUtils.copyFile(this.file, fileToCreate);
		FileInputStream iFile = new FileInputStream(new File(file.getAbsolutePath()));
		HSSFWorkbook workbook = new HSSFWorkbook(iFile);
		HSSFSheet sheet = workbook.getSheetAt(0);
 
		List<BulkItems> bulkItemsList= new ArrayList<BulkItems>();
 
		List<Long> items = new ArrayList<Long>();
 
		for (int iterator=sheet.getFirstRowNum()+1;iterator<=sheet.getLastRowNum();iterator++){
			long item_id = (long) sheet.getRow(iterator).getCell(0).getNumericCellValue();
			items.add(item_id);

				sb.append("Item is not valid "+itemId+"\n");
				continue;
			}
			BulkItems b = new BulkItems();
			b.setItem_id(itemId);
 
			if (checkEmptyString(sheet.getRow(iterator).getCell(1))){
				b.setShowMrpFlag(false);
			}
			else{
				int show_mrp_flag = (int) sheet.getRow(iterator).getCell(1).getNumericCellValue();
				b.setShowMrpFlag(show_mrp_flag ==1 ? true : false);
			}
			if (checkEmptyString(sheet.getRow(iterator).getCell(2))){
				b.setTagline("");
			}
			else{
				String tagline = sheet.getRow(iterator).getCell(2).getStringCellValue();
				b.setTagline(tagline);
			}
			if (checkEmptyString(sheet.getRow(iterator).getCell(3))){
				b.setOffer("");
			}
			else{
				String offer = sheet.getRow(iterator).getCell(3).getStringCellValue();
				b.setOffer(offer);
			}
			long category_id = (long) sheet.getRow(iterator).getCell(4).getNumericCellValue();
			if (category_id!=6L){
				sb.append("Category Id is not valid "+itemId+"\n");
			}
			b.setCategory_id(category_id);

		}else{
			setResult("Items added successfully");
		}
		return "item-details-json";
	}
 
	public String updateVirtualInventory() throws IOException, CatalogServiceException, TException, InventoryServiceException{
		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";
		}
 
		File fileToCreate = new File("/tmp/", "vendor-inventory.xls");
		FileUtils.copyFile(this.file, fileToCreate);
		FileInputStream iFile = new FileInputStream(new File(file.getAbsolutePath()));
		HSSFWorkbook workbook = new HSSFWorkbook(iFile);
		HSSFSheet sheet = workbook.getSheetAt(0);
 
		List<BulkAddInventory> vendorInventory= new ArrayList<BulkAddInventory>();
 
		List<Long> items = new ArrayList<Long>();
 
		for (int iterator=sheet.getFirstRowNum()+1;iterator<=sheet.getLastRowNum();iterator++){
			long item_id = (long) sheet.getRow(iterator).getCell(0).getNumericCellValue();
			items.add(item_id);
		}
		Client cc = new CatalogClient().getClient();
		Map<Long, Item> itemMap = cc.getItems(items);
 
		for (int iterator=sheet.getFirstRowNum()+1;iterator<=sheet.getLastRowNum();iterator++){
			long itemId = (long) sheet.getRow(iterator).getCell(0).getNumericCellValue();
			if (itemMap.get(itemId)==null){
				continue;
			}

			b.setWarehouse_id(warehouseId);
			long inventory = (long) sheet.getRow(iterator).getCell(2).getNumericCellValue();
			b.setInventory(inventory);
			vendorInventory.add(b);
		}
 
		InventoryClient inventoryServiceClient = new InventoryClient();
		in.shop2020.model.v1.inventory.InventoryService.Client inventoryClient = inventoryServiceClient.getClient();
		inventoryClient.addInventoryInBulk(vendorInventory);
		setResult("Inventory updated successfully");
		return "item-details-json";
	}
 
	public String addVendorItemPricing() throws IOException, TException, CatalogServiceException{
		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";
		}
		File fileToCreate = new File("/tmp/", "vendor-pricing.xls");
		FileUtils.copyFile(this.file, fileToCreate);
		FileInputStream iFile = new FileInputStream(new File(file.getAbsolutePath()));
		HSSFWorkbook workbook = new HSSFWorkbook(iFile);
		HSSFSheet sheet = workbook.getSheetAt(0);
 
		List<VendorItemPricing> vendorItemPricingList= new ArrayList<VendorItemPricing>();
		List<Long> items = new ArrayList<Long>();
 
		for (int iterator=sheet.getFirstRowNum()+1;iterator<=sheet.getLastRowNum();iterator++){
			long item_id = (long) sheet.getRow(iterator).getCell(0).getNumericCellValue();
			items.add(item_id);
		}
		Client cc = new CatalogClient().getClient();
		Map<Long, Item> itemMap = cc.getItems(items);
 
		for (int iterator=sheet.getFirstRowNum()+1;iterator<=sheet.getLastRowNum();iterator++){
			long itemId = (long) sheet.getRow(iterator).getCell(0).getNumericCellValue();
			if (itemMap.get(itemId)==null){
				continue;
			}

			double tp = (double) sheet.getRow(iterator).getCell(4).getNumericCellValue();
			v.setTransferPrice(tp);
			double nlc = (double) sheet.getRow(iterator).getCell(5).getNumericCellValue();
			v.setNlc(nlc);
			vendorItemPricingList.add(v);
		}
 
		InventoryClient inventoryServiceClient = new InventoryClient();
		in.shop2020.model.v1.inventory.InventoryService.Client inventoryClient = inventoryServiceClient.getClient();
		List<Long> notUpdated = inventoryClient.addVendorItemPricingInBulk(vendorItemPricingList);
 
		if (notUpdated.size() > 0){
			StringBuilder sb = new StringBuilder();
			for (Long x : notUpdated){
				sb.append("Vendor Pricing not updated for "+x+"\n");
			}

		else{
			setResult("Vendor item pricing updated.");
		}
		return "item-details-json";
	}
 
	public String updateItemPricing() throws IOException, CatalogServiceException, TException{
		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";
		}
		File fileToCreate = new File("/tmp/", "item-pricing.xls");
		FileUtils.copyFile(this.file, fileToCreate);
		FileInputStream iFile = new FileInputStream(new File(file.getAbsolutePath()));
		HSSFWorkbook workbook = new HSSFWorkbook(iFile);
		HSSFSheet sheet = workbook.getSheetAt(0);
 
		List<ItemPricing> itemPricingList= new ArrayList<ItemPricing>();
		List<Long> items = new ArrayList<Long>();
 
		for (int iterator=sheet.getFirstRowNum()+1;iterator<=sheet.getLastRowNum();iterator++){
			long item_id = (long) sheet.getRow(iterator).getCell(0).getNumericCellValue();
			items.add(item_id);
		}
		Client cc = new CatalogClient("catalog_service_server_host_amazon","catalog_service_server_port").getClient();
		Map<Long, Item> itemMap = cc.getItems(items);
 
		for (int iterator=sheet.getFirstRowNum()+1;iterator<=sheet.getLastRowNum();iterator++){
			ItemPricing i = new ItemPricing();
			long item_id = (long) sheet.getRow(iterator).getCell(0).getNumericCellValue();
			i.setItem_id(item_id);
			if (itemMap.get(item_id)!=null){

				}
				else{
					double weight = (double) sheet.getRow(iterator).getCell(5).getNumericCellValue();
					i.setWeight(weight);
				}
				itemPricingList.add(i);
			}
		}
		boolean res = cc.updateItemPricing(itemPricingList);
		if (res){
			setResult("Pricing updated successfully");

		else{
			setResult("Unable to update pricing");
		}
		return "item-details-json";
	}
 
	public String downloadVendors() throws TException, IOException{
		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";
		}
		InventoryClient inventoryServiceClient = new InventoryClient();
		in.shop2020.model.v1.inventory.InventoryService.Client inventoryClient = inventoryServiceClient.getClient();
		List<Vendor> vendors = inventoryClient.getAllVendors();
 
		File file = new File("/tmp/vendors.xls");
		HSSFWorkbook hwb=new HSSFWorkbook();
		HSSFSheet sheet =  hwb.createSheet("Vendors");
		HSSFRow rowhead=   sheet.createRow((short)0);
		rowhead.createCell((short) 0).setCellValue("VENDOR_ID");
		rowhead.createCell((short) 1).setCellValue("VENDOR_NAME");
 
		int iterator= 1;
		for (Vendor v : vendors){
			HSSFRow row = sheet.createRow((short)iterator);
			row.createCell((short) 0).setCellValue(v.getId());
			row.createCell((short) 1).setCellValue(v.getName());
			iterator++;
		}
 
		FileOutputStream fileOut = null;
		try {
			fileOut = new FileOutputStream(file);
		} catch (FileNotFoundException e) {
			// TODO Auto-generated catch block

		} catch (IOException e) {
			System.out.println("Unable to stream the manifest file");
		}
		setResult("Vendor Streaming done");
		return "item-details-json";
 
	}
 
	public String downloadWarehouses() throws TException, IOException{
		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";
		}
		InventoryClient inventoryServiceClient = new InventoryClient();
		in.shop2020.model.v1.inventory.InventoryService.Client inventoryClient = inventoryServiceClient.getClient();
		List<Warehouse> warehouses = inventoryClient.getWarehouses(null, null, 0, 0, 0);
 
		File file = new File("/tmp/warehouses.xls");
		HSSFWorkbook hwb=new HSSFWorkbook();
		HSSFSheet sheet =  hwb.createSheet("Warehouses");
		HSSFRow rowhead=   sheet.createRow((short)0);
		rowhead.createCell((short) 0).setCellValue("warehouse_id");

		rowhead.createCell((short) 4).setCellValue("vendor_name");
		rowhead.createCell((short) 5).setCellValue("inventory_type");
		rowhead.createCell((short) 6).setCellValue("warehouse_type");
		rowhead.createCell((short) 7).setCellValue("logistics_location");
		rowhead.createCell((short) 8).setCellValue("state_id");
 
		int iterator= 1;
		for (Warehouse w : warehouses){
			HSSFRow row = sheet.createRow((short)iterator);
			row.createCell((short) 0).setCellValue(w.getId());
			row.createCell((short) 1).setCellValue(w.getDisplayName());

			row.createCell((short) 6).setCellValue(w.getWarehouseType().toString());
			row.createCell((short) 7).setCellValue(w.getLogisticsLocation().toString());
			row.createCell((short) 7).setCellValue(w.getStateId());
			iterator++;
		}
 
		FileOutputStream fileOut = null;
		try {
			fileOut = new FileOutputStream(file);
		} catch (FileNotFoundException e) {
			// TODO Auto-generated catch block

		} catch (IOException e) {
			System.out.println("Unable to stream the manifest file");
		}
		setResult("Warehouse Streaming done");
		return "item-details-json";
 
	}
 
 
	public boolean checkEmptyString(Cell cell){
		if (cell==null || cell.getCellType() == Cell.CELL_TYPE_BLANK){
			return true;
		}
		return false;
	}
 
	public String getItemDetails(){
		return result;
	}
 
	public void setId(String id) {

 
	public void setContext(ServletContext context) {
		this.context = context;
	}
 
 
	public void setServletRequest(HttpServletRequest req) {
		this.request = req;
		this.session = req.getSession();        
	}
 

	}
 
	public void setServletResponse(HttpServletResponse response) {
		this.response = response;
	}
 
	public String getResult() {
		return result;
	}
 
	public void setResult(String result) {
		this.result = result;
	}
 
	public File getFile() {
		return file;
	}
 
	public void setFile(File file) {
		this.file = file;
	}
 
 
}


Subversion Repositories SmartDukaan

(root)/trunk/Support/src/main/java/in/shop2020/support/controllers/BulkAddController.java – Rev 19252 → 19253

Rev 19252		Rev 19253
Line 92...		Line 92...
92	`return "authfail";`	92	`return "authfail";`
93	`}`	93	`}`
94	`return "edit";`	94	`return "edit";`
95	`}`	95	`}`
96		96
97		97
98	`public String show() {`	98	`public String show() {`
99	`if(!ReportsUtils.canAccessReport((Long)session.getAttribute(ReportsUtils.ROLE), request.getRequestURI().substring(request.getContextPath().length()).split("/")[1])) {`	99	`if(!ReportsUtils.canAccessReport((Long)session.getAttribute(ReportsUtils.ROLE), request.getRequestURI().substring(request.getContextPath().length()).split("/")[1])) {`
100	`return "authfail";`	100	`return "authfail";`
101	`}`	101	`}`
102	`logger.info("Inside show for "+id);`	102	`logger.info("Inside show for "+id);`
103		103
104	`if (StringUtils.equals(id, "bulk-add-options")){`	104	`if (StringUtils.equals(id, "bulk-add-options")){`
105	`return "bulk-add-options";`	105	`return "bulk-add-options";`
106	`}`	106	`}`
107	`return "id";`	107	`return "id";`
108	`}`	108	`}`
109		109
110	`public String loadVendorDiv(){`	110	`public String loadVendorDiv(){`
111	`if(!ReportsUtils.canAccessReport((Long)session.getAttribute(ReportsUtils.ROLE), request.getRequestURI().substring(request.getContextPath().length()).split("/")[1].split("!")[0])) {`	111	`if(!ReportsUtils.canAccessReport((Long)session.getAttribute(ReportsUtils.ROLE), request.getRequestURI().substring(request.getContextPath().length()).split("/")[1].split("!")[0])) {`
112	`logger.info(request.getRequestURI().substring(request.getContextPath().length()).split("/")[1].split("!")[0]);`	112	`logger.info(request.getRequestURI().substring(request.getContextPath().length()).split("/")[1].split("!")[0]);`
113	`return "authfail";`	113	`return "authfail";`
114	`}`	114	`}`
115	`return "vendor-item-pricing-upload";`	115	`return "vendor-item-pricing-upload";`
116	`}`	116	`}`
117		117
118	`public String loadVirtualDiv(){`	118	`public String loadVirtualDiv(){`
119	`if(!ReportsUtils.canAccessReport((Long)session.getAttribute(ReportsUtils.ROLE), request.getRequestURI().substring(request.getContextPath().length()).split("/")[1].split("!")[0])) {`	119	`if(!ReportsUtils.canAccessReport((Long)session.getAttribute(ReportsUtils.ROLE), request.getRequestURI().substring(request.getContextPath().length()).split("/")[1].split("!")[0])) {`
120	`logger.info(request.getRequestURI().substring(request.getContextPath().length()).split("/")[1].split("!")[0]);`	120	`logger.info(request.getRequestURI().substring(request.getContextPath().length()).split("/")[1].split("!")[0]);`
121	`return "authfail";`	121	`return "authfail";`
122	`}`	122	`}`
123	`return "virtual-bulk-add";`	123	`return "virtual-bulk-add";`
124	`}`	124	`}`
125		125
126	`public String loadCatalogDiv(){`	126	`public String loadCatalogDiv(){`
127	`if(!ReportsUtils.canAccessReport((Long)session.getAttribute(ReportsUtils.ROLE), request.getRequestURI().substring(request.getContextPath().length()).split("/")[1].split("!")[0])) {`	127	`if(!ReportsUtils.canAccessReport((Long)session.getAttribute(ReportsUtils.ROLE), request.getRequestURI().substring(request.getContextPath().length()).split("/")[1].split("!")[0])) {`
128	`logger.info(request.getRequestURI().substring(request.getContextPath().length()).split("/")[1].split("!")[0]);`	128	`logger.info(request.getRequestURI().substring(request.getContextPath().length()).split("/")[1].split("!")[0]);`
129	`return "authfail";`	129	`return "authfail";`
130	`}`	130	`}`