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

 package com.spice.profitmandi.web.controller;
+import java.io.ByteArrayInputStream;
+import java.io.ByteArrayOutputStream;
+import java.io.IOException;
+import java.io.InputStream;
 import java.time.LocalDateTime;
 import java.time.LocalTime;
 import java.time.format.DateTimeFormatter;
 import java.util.ArrayList;
 import java.util.Arrays;
 import org.apache.logging.log4j.Logger;
 import org.json.JSONArray;
 import org.json.JSONObject;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
+import org.springframework.core.io.InputStreamResource;
+import org.springframework.http.HttpHeaders;
+import org.springframework.http.HttpStatus;
 import org.springframework.http.MediaType;
 import org.springframework.http.ResponseEntity;
 import org.springframework.stereotype.Controller;
 import org.springframework.transaction.annotation.Transactional;
 import org.springframework.web.bind.annotation.GetMapping;
 import com.spice.profitmandi.common.enumuration.SchemeType;
 import com.spice.profitmandi.common.exception.ProfitMandiBusinessException;
 import com.spice.profitmandi.common.model.CreatePendingOrderItem;
 import com.spice.profitmandi.common.model.CreatePendingOrderRequest;
 import com.spice.profitmandi.common.model.CustomRetailer;
+import com.spice.profitmandi.common.model.PdfModel;
 import com.spice.profitmandi.common.model.ProfitMandiConstants;
 import com.spice.profitmandi.common.model.SendNotificationModel;
 import com.spice.profitmandi.common.model.UserInfo;
 import com.spice.profitmandi.common.solr.SolrService;
 import com.spice.profitmandi.common.util.FormattingUtils;
+import com.spice.profitmandi.common.util.PdfUtils;
 import com.spice.profitmandi.common.util.Utils;
 import com.spice.profitmandi.common.web.client.RestClient;
 import com.spice.profitmandi.common.web.util.ResponseSender;
 import com.spice.profitmandi.dao.entity.catalog.Item;
 import com.spice.profitmandi.dao.entity.catalog.TagListing;
 import com.spice.profitmandi.dao.entity.dtr.User;
 import com.spice.profitmandi.dao.entity.dtr.WebListing;
 import com.spice.profitmandi.dao.entity.dtr.WebOffer;
 import com.spice.profitmandi.dao.entity.fofo.Customer;
 import com.spice.profitmandi.dao.entity.fofo.CustomerAddress;
+import com.spice.profitmandi.dao.entity.fofo.FofoOrder;
+import com.spice.profitmandi.dao.entity.fofo.FofoOrderItem;
 import com.spice.profitmandi.dao.entity.fofo.FofoStore;
 import com.spice.profitmandi.dao.entity.fofo.PendingOrder;
 import com.spice.profitmandi.dao.entity.fofo.PendingOrderItem;
 import com.spice.profitmandi.dao.entity.fofo.PincodePartner;
 import com.spice.profitmandi.dao.enumuration.dtr.OtpType;
 import com.spice.profitmandi.dao.repository.catalog.ItemRepository;
 import com.spice.profitmandi.dao.repository.catalog.TagListingRepository;
 import com.spice.profitmandi.dao.repository.cs.CsService;
 import com.spice.profitmandi.dao.repository.dtr.FofoStoreRepository;
 import com.spice.profitmandi.dao.repository.dtr.UserAccountRepository;
+import com.spice.profitmandi.dao.repository.user.UserRepository;
 import com.spice.profitmandi.dao.repository.dtr.WebListingRepository;
 import com.spice.profitmandi.dao.repository.dtr.WebOfferRepository;
 import com.spice.profitmandi.dao.repository.dtr.WebProductListingRepository;
 import com.spice.profitmandi.dao.repository.fofo.CurrentInventorySnapshotRepository;
 import com.spice.profitmandi.dao.repository.fofo.CustomerAddressRepository;
 import com.spice.profitmandi.dao.repository.fofo.CustomerRepository;
+import com.spice.profitmandi.dao.repository.fofo.FofoOrderItemRepository;
+import com.spice.profitmandi.dao.repository.fofo.FofoOrderRepository;
 import com.spice.profitmandi.dao.repository.fofo.PendingOrderItemRepository;
 import com.spice.profitmandi.dao.repository.fofo.PendingOrderRepository;
 import com.spice.profitmandi.dao.repository.fofo.PendingOrderService;
 import com.spice.profitmandi.dao.repository.fofo.PincodePartnerRepository;
 import com.spice.profitmandi.dao.repository.inventory.ItemAvailabilityCacheRepository;
 import com.spice.profitmandi.service.inventory.AvailabilityModel;
 import com.spice.profitmandi.service.inventory.FofoAvailabilityInfo;
 import com.spice.profitmandi.service.inventory.FofoCatalogResponse;
 import com.spice.profitmandi.service.inventory.InventoryService;
 import com.spice.profitmandi.service.inventory.SaholicInventoryService;
+import com.spice.profitmandi.service.order.OrderService;
 import com.spice.profitmandi.service.scheme.SchemeService;
 import com.spice.profitmandi.service.user.RetailerService;
 import com.spice.profitmandi.web.processor.OtpProcessor;
 import com.spice.profitmandi.web.res.DealBrands;
 import com.spice.profitmandi.web.res.DealObjectResponse;
 import com.spice.profitmandi.web.res.DealsResponse;
 import com.spice.profitmandi.web.res.ValidateCartResponse;
 	@Autowired
 	private SchemeService schemeService;
 	@Autowired
+	private UserRepository userRepository;
+	@Autowired
 	private ItemAvailabilityCacheRepository itemAvailabilityCacheRepository;
 	@Autowired
 	private WebListingRepository webListingRepository;
 	private NotificationService notificationService;
 	@Autowired
 	private com.spice.profitmandi.dao.repository.dtr.UserRepository dtrUserRepository;
+	@Autowired
+	private FofoOrderRepository fofoOrderRepository;
+	@Autowired
+	private FofoOrderItemRepository fofoOrderItemRepository;
+	@Autowired
+	private OrderService orderService;
 	private static final List<String> offlineOrders = Arrays.asList("EMIOD", "POD");
 	List<String> filterableParams = Arrays.asList("brand");
 	@RequestMapping(value = "/store/entity/{id}", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)
+		}
 		return responseSender.ok(fofoStoreRepository.selectByRetailerId(fofoId).getCode());
+	}
+	@RequestMapping(value = "/store/addresses", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)
+	@ApiImplicitParams({
+			@ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header") })
+	@ApiOperation(value = "Get brand list and count for category")
+	public ResponseEntity<?> getStoresByPincod(HttpServletRequest request, @RequestParam String pincode,
+			@RequestParam(name = "fofoCode", defaultValue = "", required = false) String fofoCode) throws Exception {
+		List<CustomRetailer> customerRetailers = new ArrayList<>();
+		logger.info("fofoCode" + fofoCode);
+		if (fofoCode != null) {
+			FofoStore fs = fofoStoreRepository.selectByStoreCode(fofoCode.toUpperCase());
+			PincodePartner pp = pincodePartnerRepository.selectPartnerByPincode(pincode, fs.getId());
+			if (pp != null) {
+				return responseSender.ok(customerRetailers.add(retailerService.getFofoRetailer(pp.getFofoId())));
+			} else {
+				List<PincodePartner> pincodePartners = pincodePartnerRepository.selectPartnersByPincode(pincode);
+				if (pincodePartners.size() > 0) {
+					List<Integer> fofoIds = pincodePartners.stream().map(x -> x.getFofoId())
+							.collect(Collectors.toList());
+					List<Integer> activefofoIds = fofoStoreRepository.selectByRetailerIds(fofoIds).stream()
+							.filter(x -> x.isActive()).map(x -> x.getId()).collect(Collectors.toList());
+					Map<Integer, CustomRetailer> customerRetailerMap = retailerService.getFofoRetailers(activefofoIds);
+					customerRetailers.addAll(customerRetailerMap.values());
+				}
+				return responseSender.ok(customerRetailers);
+			}
+		} else {
+			List<PincodePartner> pincodePartners = pincodePartnerRepository.selectPartnersByPincode(pincode);
+			if (pincodePartners.size() > 0) {
+				List<Integer> fofoIds = pincodePartners.stream().map(x -> x.getFofoId()).collect(Collectors.toList());
+				List<Integer> activefofoIds = fofoStoreRepository.selectByRetailerIds(fofoIds).stream()
+						.filter(x -> x.isActive()).map(x -> x.getId()).collect(Collectors.toList());
+				Map<Integer, CustomRetailer> customerRetailerMap = retailerService.getFofoRetailers(activefofoIds);
+				customerRetailers.addAll(customerRetailerMap.values());
+			}
+			return responseSender.ok(customerRetailers);
+		}
+	}
 	@RequestMapping(value = "/store/address/detail/{pincode}", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)
 	@ApiImplicitParams({
 			@ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header") })
 	@ApiOperation(value = "Get brand list and count for category")
 	public ResponseEntity<?> getStoresDetailsByPincode(HttpServletRequest request, @PathVariable String pincode)
 	public ResponseEntity<?> getOrderDetail(HttpServletRequest request, @RequestParam(value = "id") int id,
 			@RequestParam(name = "offset") int offset, @RequestParam(name = "limit") int limit) throws Exception {
 		List<CustomerOrderDetail> customerOrderDetails = new ArrayList<>();
 		List<Integer> catalogIds = new ArrayList<>();
 		List<PendingOrder> pendingOrders = pendingOrderRepository.selectByCustomerId(id, offset, limit);
 		if (!pendingOrders.isEmpty()) {
 			for (PendingOrder po : pendingOrders) {
 				List<PendingOrderItem> pois = pendingOrderItemRepository.selectByOrderId(po.getId());
 				for (PendingOrderItem pendingOrderItem : pois) {
 					Item item = itemRepository.selectById(pendingOrderItem.getItemId());
+		}
 		return responseSender.ok(customerOrderDetails);
+	}
+	@RequestMapping(value = "/store/invoiceOrder", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)
+	public ResponseEntity<?> getOrderInvoiceDetail(HttpServletRequest request, @RequestParam(value = "id") int id,
+			@RequestParam(name = "offset") int offset, @RequestParam(name = "limit") int limit) throws Exception {
+		List<CustomerOrderDetail> customerOrderDetails = new ArrayList<>();
+		List<Integer> catalogIds = new ArrayList<>();
+		List<FofoOrder> fofoOrders = fofoOrderRepository.selectOrderByCustomerId(id, offset, limit);
+		if (!fofoOrders.isEmpty()) {
+			for (FofoOrder fo : fofoOrders) {
+				List<FofoOrderItem> fofoOrderItems = fofoOrderItemRepository.selectByOrderId(fo.getId());
+				for (FofoOrderItem fofoOrderItem : fofoOrderItems) {
+					Item item = itemRepository.selectById(fofoOrderItem.getItemId());
+					fofoOrderItem.setItemName(item.getItemDescription());
+					catalogIds.add(item.getCatalogItemId());
+				}
+				Map<Integer, JSONObject> contentMap = commonSolrService.getContentByCatalogIds(catalogIds);
+				for (FofoOrderItem foi : fofoOrderItems) {
+					CustomerOrderDetail customerOrderDetail = new CustomerOrderDetail();
+					Item item = itemRepository.selectById(foi.getItemId());
+					JSONObject jsonObj = contentMap.get(item.getCatalogItemId());
+					customerOrderDetail.setImageUrl(jsonObj.getString("imageUrl_s"));
+					customerOrderDetail.setBrand(item.getBrand());
+					customerOrderDetail.setColor(item.getColor());
+					customerOrderDetail.setFofoOrderItemId(foi.getId());
+					customerOrderDetail.setFofoOrderId(foi.getOrderId());
+					customerOrderDetail.setItemId(foi.getItemId());
+					customerOrderDetail.setModelName(item.getModelName());
+					customerOrderDetail.setModelNumber(item.getModelNumber());
+					customerOrderDetail.setQuantity(foi.getQuantity());
+					customerOrderDetail.setTotalPrice(foi.getSellingPrice());
+					customerOrderDetail.setCreatedTimeStamp(foi.getCreateTimestamp());
+					customerOrderDetail.setInvoiceNumber(fo.getInvoiceNumber());
+					customerOrderDetail.setCancelledTimestamp(fo.getCancelledTimestamp());
+					customerOrderDetails.add(customerOrderDetail);
+				}
+			}
+		}
+		return responseSender.ok(customerOrderDetails);
+	}
+	@RequestMapping(value = "/store/generateInvoice", method = RequestMethod.GET)
+	public ResponseEntity<?> generateInvoice(HttpServletRequest request,
+			@RequestParam(name = ProfitMandiConstants.ORDER_ID) int orderId) throws ProfitMandiBusinessException {
+		PdfModel pdfModel = null;
+		FofoOrder fo = fofoOrderRepository.selectByOrderId(orderId);
+		pdfModel = orderService.getInvoicePdfModel(fo.getFofoId(), orderId);
+		ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream();
+		PdfUtils.generateAndWrite(Arrays.asList(pdfModel), byteArrayOutputStream);
+		try {
+			byteArrayOutputStream.close();
+		} catch (IOException e) {
+			// TODO Auto-generated catch block
+			e.printStackTrace();
+		}
+		final HttpHeaders headers = new HttpHeaders();
+		headers.setContentType(MediaType.APPLICATION_PDF);
+		// headers.setCacheControl("must-revalidate, post-check=0, pre-check=0");
+		headers.setContentType(MediaType.parseMediaType("application/pdf"));
+		headers.set("Content-disposition", "inline; filename=invoice-" + pdfModel.getInvoiceNumber() + ".pdf");
+		headers.add("Cache-Control", "no-cache, no-store, must-revalidate");
+		headers.add("Pragma", "no-cache");
+		headers.add("Expires", "0");
+		headers.setContentLength(byteArrayOutputStream.toByteArray().length);
+		final InputStream inputStream = new ByteArrayInputStream(byteArrayOutputStream.toByteArray());
+		final InputStreamResource inputStreamResource = new InputStreamResource(inputStream);
+		return new ResponseEntity<>(inputStreamResource, headers, HttpStatus.OK);
+		// return responseSender.ok(new
+		// ResponseEntity<byte[]>(byteArrayOutputStream.toByteArray(),
+		// headers,HttpStatus.OK));
+		/*
+		 * ResponseEntity<byte[]> response = new
+		 * ResponseEntity<byte[]>(byteArrayOutputStream.toByteArray(), headers,
+		 * HttpStatus.OK); return response;
+		 */
+	}
 	@RequestMapping(value = "/store/listing", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)
 	public ResponseEntity<?> getStoresListing(HttpServletRequest request) throws Exception {
 		List<WebListing> webListings = webListingRepository.selectAllWebListing(Optional.of(true));
 		UserInfo userInfo = (UserInfo) request.getAttribute("userInfo");
 		for (WebListing webListing : webListings) {
 		return responseSender.ok(true);
+	}
-}
-class UserModel {
+	class UserModel {
-	@JsonProperty(required = true)
+		@JsonProperty(required = true)
-	private String mobile;
+		private String mobile;
-	@JsonProperty(required = true)
+		@JsonProperty(required = true)
-	private String password;
+		private String password;
-	@JsonProperty(required = false)
+		@JsonProperty(required = false)
-	private String firstName;
+		private String firstName;
-	@JsonProperty(required = false)
+		@JsonProperty(required = false)
-	private String lastName;
+		private String lastName;
-	@JsonProperty(required = false)
+		@JsonProperty(required = false)
-	private String email;
+		private String email;
+		@Override
+		public String toString() {
+			return "UserModel [mobile=" + mobile + ", password=" + password + "]";
+		}
-	@Override
-	public String toString() {
+		public String getMobile() {
-		return "UserModel [mobile=" + mobile + ", password=" + password + "]";
+			return mobile;
-	}
+		}
-	public String getMobile() {
+		public void setMobile(String mobile) {
-		return mobile;
+			this.mobile = mobile;
-	}
+		}
-	public void setMobile(String mobile) {
+		public String getPassword() {
-		this.mobile = mobile;
+			return password;
-	}
+		}
-	public String getPassword() {
+		public void setPassword(String password) {
-		return password;
+			this.password = password;
-	}
+		}
-	public void setPassword(String password) {
+		public String getFirstName() {
-		this.password = password;
+			return firstName;
-	}
+		}
-	public String getFirstName() {
+		public void setFirstName(String firstName) {
-		return firstName;
+			this.firstName = firstName;
-	}
+		}
-	public void setFirstName(String firstName) {
+		public String getLastName() {
-		this.firstName = firstName;
+			return lastName;
-	}
+		}
-	public String getLastName() {
+		public void setLastName(String lastName) {
-		return lastName;
+			this.lastName = lastName;
-	}
+		}
-	public void setLastName(String lastName) {
+		public String getEmail() {
-		this.lastName = lastName;
+			return email;
-	}
+		}
-	public String getEmail() {
+		public void setEmail(String email) {
-		return email;
+			this.email = email;
-	}
+		}
-	public void setEmail(String email) {
-		this.email = email;
+	}
-}
-class CustomerModel {
+	class CustomerModel {
-	@JsonProperty(required = false)
+		@JsonProperty(required = false)
-	private Customer customer;
+		private Customer customer;
-	@JsonProperty(required = true)
+		@JsonProperty(required = true)
-	private boolean exists;
+		private boolean exists;
-	public CustomerModel(boolean exists, Customer customer) {
+		public CustomerModel(boolean exists, Customer customer) {
-		super();
+			super();
-		this.customer = customer;
+			this.customer = customer;
-		this.exists = exists;
+			this.exists = exists;
-	}
+		}
-	@Override
+		@Override
-	public String toString() {
+		public String toString() {
-		return "CustomerModel [customer=" + customer + ", exists=" + exists + "]";
+			return "CustomerModel [customer=" + customer + ", exists=" + exists + "]";
-	}
+		}
-	public Customer getCustomer() {
+		public Customer getCustomer() {
-		return customer;
+			return customer;
-	}
+		}
-	public void setCustomer(Customer customer) {
+		public void setCustomer(Customer customer) {
-		this.customer = customer;
+			this.customer = customer;
-	}
+		}
-	public boolean isExists() {
+		public boolean isExists() {
-		return exists;
+			return exists;
-	}
+		}
-	public void setExists(boolean exists) {
+		public void setExists(boolean exists) {
-		this.exists = exists;
+			this.exists = exists;
+		}
+	}
+}

Subversion Repositories SmartDukaan

(root)/trunk/profitmandi-web/src/main/java/com/spice/profitmandi/web/controller/StoreController.java – Rev 28467 → 28566