WebSVN – SmartDukaan – Diff – /trunk/profitmandi-fofo/src/main/java/com/spice/profitmandi/web/controller/ContentController.java

 import java.io.File;
 import java.io.FileInputStream;
 import java.io.FileNotFoundException;
 import java.io.InputStream;
 import java.io.InputStreamReader;
+import java.sql.Timestamp;
+import java.time.LocalDate;
 import java.time.LocalDateTime;
 import java.time.ZoneOffset;
 import java.util.ArrayList;
 import java.util.Arrays;
 import java.util.HashMap;
 import com.jcraft.jsch.SftpATTRS;
 import com.jcraft.jsch.SftpException;
 import com.spice.profitmandi.common.exception.ProfitMandiBusinessException;
 import com.spice.profitmandi.common.solr.SolrService;
 import com.spice.profitmandi.dao.entity.catalog.Item;
+import com.spice.profitmandi.dao.entity.dtr.DocumentUrl;
 import com.spice.profitmandi.dao.model.ContentPojo;
 import com.spice.profitmandi.dao.model.MediaPojo;
 import com.spice.profitmandi.dao.model.Specification;
 import com.spice.profitmandi.dao.model.SpecificationGroup;
 import com.spice.profitmandi.dao.repository.catalog.ItemRepository;
+import com.spice.profitmandi.dao.repository.dtr.DocumentUrlRepository;
 import com.spice.profitmandi.dao.repository.dtr.Mongo;
 import com.spice.profitmandi.web.model.EntityMediaPojo;
 import com.spice.profitmandi.web.util.MVCResponseSender;
 @Transactional(rollbackOn = Throwable.class)
 	SolrService solrService;
 	@Autowired
 	ItemRepository itemRepository;
+	@Autowired
+	DocumentUrlRepository documentUrlRepository;
 	private Gson gson = new Gson();
 	public static final int Entity_Id = 0;
 	public static final int Title = 1;
 	public static final int KeySpec1 = 2;
 	public static final int KeySpec2 = 3;
 	public static final int KeySpec3 = 4;
 	public static final int KeySpec4 = 5;
 	public static final int Warranty = 6;
 	public static final int Package_Contents = 7;
+	private static final String IMAGE_REMOTE_DIR = "/var/www/dtrdashboard/uploads/campaigns/";
+	private static final String IMAGE_STATIC_SERVER_URL = "https://images.smartdukaan.com/uploads/campaigns";
 	private static final String REMOTE_DIR = "/var/www/static.saholic.com/images/media/";
 	private static final String STATIC_SERVER_URL = "https://static%d.smartdukaan.com/images/media/";
 	private static final String THUMBNAIL = "thumbnail";
 		mongoClient.persistEntity(contentPojo);
 		model.addAttribute("response", mvcResponseSender.createResponseString(true));
 		return "response";
+	}
+	@PostMapping(value = "/image/media/upload")
+	public String uploadImageMediaContent(HttpServletRequest request, @RequestBody MediaPojo mediaPojo, Model model)
+			throws Exception {
+		LOGGER.info("mediaPojo" + mediaPojo);
+		Map<String, InputStream> fileStreamsMap = new HashMap<>();
+		String extension;
+		String base64String = mediaPojo.getImageData();
+		String[] strings = base64String.split(",");
+		switch (strings[0]) {// check image's extension
+		case "data:image/jpeg;base64":
+			extension = "jpeg";
+			break;
+		case "data:image/png;base64":
+			extension = "png";
+			break;
+		default:// should write cases for more images types
+			extension = ".jpg";
+			break;
+		}
+		LOGGER.info("After switch statement = {}", extension);
+		// convert base64 string to binary data
+		byte[] data = DatatypeConverter.parseBase64Binary(strings[1]);
+		Timestamp tm = new Timestamp(System.currentTimeMillis());
+		String fileName = mediaPojo.getTitle() + tm.getTime() + "." + extension;
+		LOGGER.info("After switch statement Filename = {}", fileName);
+		mediaPojo.setImageData(null);
+		mediaPojo.setUrl(IMAGE_STATIC_SERVER_URL + "/" + "image" + LocalDate.now() + "/" + fileName);
+		fileStreamsMap.put(fileName, new ByteArrayInputStream(data));
+		LOGGER.info("fileStreamsMap" + fileStreamsMap);
+		uploadFile(fileStreamsMap);
+		DocumentUrl du = new DocumentUrl();
+		du.setTitle(mediaPojo.getTitle());
+		du.setUrl(mediaPojo.getUrl());
+		du.setCreatedTimestamp(LocalDateTime.now());
+		documentUrlRepository.persist(du);
+		model.addAttribute("documents", du);
+		return "image-url";
+	}
+	private void uploadFile(Map<String, InputStream> fileStreamsMap) throws Exception {
+		ChannelSftp channelSftp = setupJsch();
+		channelSftp.connect();
+		this.fileUpload(channelSftp, fileStreamsMap, IMAGE_REMOTE_DIR + "");
+		channelSftp.exit();
+	}
+	private void fileUpload(ChannelSftp channelSftp, Map<String, InputStream> streamsFileMap, String destinationPath)
+			throws SftpException, FileNotFoundException {
+		channelSftp.cd(destinationPath);
+		String folderName = "image" + LocalDate.now();
+		channelSftp.cd(destinationPath);
+		SftpATTRS attrs = null;
+		// check if the directory is already existing
+		try {
+			attrs = channelSftp.stat(folderName);
+		} catch (Exception e) {
+			System.out.println(destinationPath + "/" + "image" + LocalDate.now() + " not found");
+		}
+		// else create a directory
+		if (attrs == null) {
+			channelSftp.mkdir(folderName);
+			channelSftp.chmod(0755, ".");
+		}
+		channelSftp.cd(folderName);
+		for (Map.Entry<String, InputStream> streamsFileEntry : streamsFileMap.entrySet()) {
+			channelSftp.put(streamsFileEntry.getValue(), streamsFileEntry.getKey(), ChannelSftp.OVERWRITE);
+		}
+	}
+	@GetMapping(value = "/search/image/media")
+	public String getImage(HttpServletRequest request, Model model, @RequestParam String title) throws Exception {
+		List<DocumentUrl> documents = documentUrlRepository.selectBySearch(title);
+		model.addAttribute("documents", documents);
+		return "image-url";
+	}
 	@GetMapping(value = "/content/media")
 	public String getMediaContent(HttpServletRequest request, Model model, @RequestParam int entityId)
 			throws Exception {
 		ContentPojo contentPojo = mongoClient.getEntityById(entityId);
 		if (contentPojo == null) {
+		}
 		EntityMediaPojo empojo = getEntityMediaPojo(contentPojo);
 		model.addAttribute("response", mvcResponseSender.createResponseString(empojo));
 		return "response";
+	}
 	@GetMapping(value = "/catalog-item")
-	public String catalogItem(HttpServletRequest request, Model model)
+	public String catalogItem(HttpServletRequest request, Model model) throws Exception {
-			throws Exception {
 		return "catalog-item";
+	}
 	private EntityMediaPojo getEntityMediaPojo(ContentPojo contentPojo) {
 		EntityMediaPojo ep = new EntityMediaPojo();
 		ep.setDefaultImageIndex(defaultIndex);
 		return ep;
+	}
 	@GetMapping(value = "/entity")
-	public String searchEntity(HttpServletRequest request, @RequestParam(defaultValue="null") String query,
+	public String searchEntity(HttpServletRequest request, @RequestParam(defaultValue = "null") String query,
-							   @RequestParam(defaultValue="0") int categoryId,
-							   @RequestParam(defaultValue="") List<String> brands,
+			@RequestParam(defaultValue = "0") int categoryId, @RequestParam(defaultValue = "") List<String> brands,
-							   @RequestParam(defaultValue="30") int limit,
+			@RequestParam(defaultValue = "30") int limit, Model model) throws Exception {
-							   Model model) throws Exception {
 		model.addAttribute("response", solrService.getContent(query, categoryId, brands, limit));
 		return "response";
+	}
 	@GetMapping(value = "/content/index")
 		return specificationGroups;
+	}
 	private ChannelSftp setupJsch() throws JSchException {
 		JSch jsch = new JSch();
-		Session jschSession = jsch.getSession("root", "192.168.179.131");
+		Session jschSession = jsch.getSession("root", "50.116.10.120");
 		jschSession.setPassword("spic@2015static0");
 		jschSession.setConfig("StrictHostKeyChecking", "no");
 		jschSession.connect();
 		return (ChannelSftp) jschSession.openChannel("sftp");
+	}
 		mediaPrefix = mediaPrefix.replaceAll("/", "-");
 		mediaPrefix = mediaPrefix.replaceAll("-+", "-");
 		return mediaPrefix;
+	}
+	@GetMapping(value = "/urlGeneration")
+	public String urlGeneration(HttpServletRequest request, Model model) throws Exception {
+		return "url-generation";
+	}
+}

Subversion Repositories SmartDukaan

(root)/trunk/profitmandi-fofo/src/main/java/com/spice/profitmandi/web/controller/ContentController.java – Rev 27608 → 28264