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

 import com.google.gson.reflect.TypeToken;
 import com.spice.profitmandi.common.enumuration.MessageType;
 import com.spice.profitmandi.common.enumuration.SchemeType;
 import com.spice.profitmandi.common.exception.ProfitMandiBusinessException;
 import com.spice.profitmandi.common.model.*;
+import com.spice.profitmandi.dao.entity.catalog.LiquidationDetail;
 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.cart.CartItemMessage;
 import com.spice.profitmandi.dao.entity.WebEntity.NavBar;
+import com.spice.profitmandi.dao.entity.catalog.Bid;
 import com.spice.profitmandi.dao.entity.catalog.Item;
+import com.spice.profitmandi.dao.entity.catalog.Liquidation;
 import com.spice.profitmandi.dao.entity.catalog.TagListing;
 import com.spice.profitmandi.dao.entity.dtr.*;
 import com.spice.profitmandi.dao.entity.fofo.*;
 import com.spice.profitmandi.dao.entity.inventory.State;
 import com.spice.profitmandi.dao.enumuration.cs.EscalationType;
 import com.spice.profitmandi.dao.enumuration.dtr.OtpType;
 import com.spice.profitmandi.dao.enumuration.dtr.WebListingSource;
 import com.spice.profitmandi.dao.enumuration.transaction.OrderStatus;
 import com.spice.profitmandi.dao.model.*;
 import com.spice.profitmandi.dao.model.pendingOrder.PendingOrderDetail;
+import com.spice.profitmandi.dao.repository.catalog.BidRepository;
 import com.spice.profitmandi.dao.repository.catalog.ItemRepository;
+import com.spice.profitmandi.dao.repository.catalog.LiquidationRepository;
 import com.spice.profitmandi.dao.repository.catalog.TagListingRepository;
 import com.spice.profitmandi.dao.repository.cs.CsService;
 import com.spice.profitmandi.dao.repository.dtr.*;
 import com.spice.profitmandi.dao.repository.fofo.*;
 import com.spice.profitmandi.dao.repository.inventory.ItemAvailabilityCacheRepository;
 import com.spice.profitmandi.dao.repository.inventory.StateRepository;
-import com.spice.profitmandi.dao.repository.user.AddressRepository;
 import com.spice.profitmandi.dao.repository.user.UserRepository;
 import com.spice.profitmandi.dao.repository.webRepository.NavBarRepository;
 import com.spice.profitmandi.service.CustomerService;
 import com.spice.profitmandi.service.EmailService;
 import com.spice.profitmandi.service.NotificationService;
 import com.spice.profitmandi.service.authentication.RoleManager;
+import com.spice.profitmandi.service.catalog.BiddingModel;
 import com.spice.profitmandi.service.integrations.zest.InsuranceService;
 import com.spice.profitmandi.service.integrations.zest.MobileInsurancePlan;
 import com.spice.profitmandi.service.inventory.*;
 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.dao.service.OtpProcessor;
-import com.spice.profitmandi.web.req.Address;
 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;
 import com.spice.profitmandi.web.services.PartnerIndexService;
 import io.swagger.annotations.ApiImplicitParam;
 import io.swagger.annotations.ApiImplicitParams;
 import io.swagger.annotations.ApiOperation;
-import org.apache.commons.lang.ObjectUtils;
 import org.apache.commons.lang3.StringUtils;
 import org.apache.http.conn.HttpHostConnectException;
 import org.apache.logging.log4j.LogManager;
 import org.apache.logging.log4j.Logger;
 import org.json.JSONArray;
     @Autowired
     InsurancePolicyRepository insurancePolicyRepository;
     @Autowired
+    LiquidationRepository liquidationRepository;
+    @Autowired
     PendingOrderPlanRepository pendingOrderPlanRepository;
     @Autowired
     private ScratchOfferRepository scratchOfferRepository;
     private static final List<String> offlineOrders = Arrays.asList("EMIOD", "POD");
     @Autowired
     NavBarRepository navBarRepository;
+    @Autowired
+    BidRepository bidRepository;
     List<String> filterableParams = Arrays.asList("brand");
     @RequestMapping(value = "/store/entity/{id}", 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 unit deal object")
         } catch (Exception e) {
             return responseSender.ok(new CustomerModel(false, null));
+        }
+    }
     @RequestMapping(value = "/store/getCustomerById/{id}", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)
     public ResponseEntity<?> getCustomerById(HttpServletRequest request, @PathVariable int id) throws Exception {
         Customer customer = customerRepository.selectById(id);
         customer.setPasswordExist(StringUtils.isNotEmpty(customer.getPassword()));
+        }
         defaultAddress.setDefault(true);
         return responseSender.ok("Default address updated successfully.");
+    }
     @RequestMapping(value = "/store/address/{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<?> getStoresByPincode(HttpServletRequest request, @PathVariable String pincode) throws Exception {
         List<PincodePartner> pincodePartners = pincodePartnerRepository.selectPartnersByPincode(pincode);
         logger.info("customerRetailers" + customerRetailers);
         return responseSender.ok(customerRetailers);
+    }
     @RequestMapping(value = "/store/order", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)
     public ResponseEntity<?> getOrderDetail(HttpServletRequest request, @RequestParam(value = "id") int id, @RequestParam(name = "offset") int offset, @RequestParam(name = "limit") int limit) throws Exception {
         List<PendingOrderDetail> pendingOrderDetails = new ArrayList<>();
         List<Integer> catalogIds = new ArrayList<>();
+    }
     @RequestMapping(value = "/store/partnerStock", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)
     public ResponseEntity<?> partnerStock(HttpServletRequest request, @RequestParam(required = false, defaultValue = "3") String categoryId, @RequestParam int offset,
-                                          @RequestParam int limit, @RequestParam(required = false) String sort, @RequestParam(required = false) String brand,
+      @RequestParam int limit, @RequestParam(required = false) String sort, @RequestParam(required = false) String brand,
-                                          @RequestParam(value = "subCategoryId", required = false) int subCategoryId, @RequestParam(required = false) String queryTerm,
+      @RequestParam(value = "subCategoryId", required = false) int subCategoryId, @RequestParam(required = false) String queryTerm,
-                                          @RequestParam(required = false) String listing, @RequestParam(required = false, defaultValue = "true") boolean partnerStockOnly) throws Throwable {
+      @RequestParam(required = false) String listing, @RequestParam(required = false, defaultValue = "true") boolean partnerStockOnly) throws Throwable {
         List<FofoCatalogResponse> dealResponse = new ArrayList<>();
         UserInfo userInfo = (UserInfo) request.getAttribute("userInfo");
         FofoStore fs = fofoStoreRepository.selectByRetailerId(userInfo.getRetailerId());
         sort = "w" + fs.getWarehouseId() + "_i desc";
         dealResponse = this.getCatalogResponse(
         scratchOffer.setScracthedAt(LocalDateTime.now());
         return responseSender.ok(true);
+    }
     @RequestMapping(value = "/store/navbar", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)
     public ResponseEntity<?> navBars() throws Exception {
         List<NavBar> navBars = navBarRepository.selectAllActive();
         return responseSender.ok(navBars);
+    }
+    @RequestMapping(value = "/store/clearance", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)
+    public ResponseEntity<?> getLiquidations() throws Exception {
+        List<Integer> catalogIds = new ArrayList<>();
+        Map<Integer, JSONObject> contentMap = null;
+        List<Liquidation> liquidations = liquidationRepository.selectAllByStatus(ProfitMandiConstants.LIQUIDATION_ENUM.ACTIVE);
+        if (!liquidations.isEmpty()) {
+            for (Liquidation liquidation : liquidations) catalogIds.add(liquidation.getCatalogId());
+            contentMap = commonSolrService.getContentByCatalogIds(catalogIds);
+        }
+        List<LiquidationDetail> resultList = new ArrayList<>();
+        if (contentMap != null) {
+            for (Liquidation liquidation : liquidations) {
+                List<Bid> bidList = bidRepository.selectBidByLiquidationId(liquidation.getId());
+                LiquidationDetail liquidationDetail = new LiquidationDetail();
+                if(contentMap.containsKey(liquidation.getCatalogId())) {
+                    JSONObject jsonObj = contentMap.get(liquidation.getCatalogId());
+                    liquidationDetail.setLiquidationId(liquidation.getId());
+                    liquidationDetail.setImageURL(jsonObj.getString("imageUrl_s"));
+                    liquidationDetail.setItemName(jsonObj.getString("title_s"));
+                    liquidationDetail.setBrand(jsonObj.getString("title_s"));
+                    liquidationDetail.setCatalogId(jsonObj.getInt("catalogId_i"));
+                    liquidationDetail.setMrp(jsonObj.getFloat("mop_f"));
+                    liquidationDetail.setMop(jsonObj.getFloat("mop_f"));
+                    liquidationDetail.setDp(jsonObj.getFloat("dp_f"));
+                    liquidationDetail.setSuperCatalogs(jsonObj.getString("superCatalogVariants_s"));
+                    liquidationDetail.setStartDate(liquidation.getStartDate());
+                    liquidationDetail.setEndDate(liquidation.getEndDate());
+                    liquidationDetail.setSellingPrice(liquidation.getPrice());
+                    liquidationDetail.setAvailableQuantity(liquidation.getQuantity());
+                    liquidationDetail.setBidList(bidList);
+                    resultList.add(liquidationDetail);
+                }
+            }
+        }
+        return responseSender.ok(resultList);
+    }
+    @RequestMapping(value = "/store/clearance/bid", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_VALUE)
+    @ApiImplicitParams({@ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header")})
+    public ResponseEntity<?> saveBidding(HttpServletRequest request, @RequestBody BiddingModel biddingModel) throws Exception {
+        Bid bid = null;
+        UserInfo userInfo = (UserInfo) request.getAttribute("userInfo");
+        if (biddingModel.getId() != null && biddingModel.getId() > 0) {
+            bid = bidRepository.selectById(biddingModel.getId());
+            if (bid == null) {
+                throw new Exception("Bidding record not found with ID: " + biddingModel.getId());
+            }
+        } else {
+            bid = new Bid();
+        }
+        bid.setLiquidationId(biddingModel.getLiquidationId());
+        bid.setBiddingAmount(biddingModel.getBiddingAmount());
+        bid.setFofoId(userInfo.getRetailerId());
+        bid.setItemName(biddingModel.getItemName());
+        bid.setQuantity(biddingModel.getBidQty());
+        bid.setStatus(ProfitMandiConstants.BID_ENUM.PENDING);
+        bid.setCreatedAt(LocalDateTime.now());
+        if (biddingModel.getId() == null) {
+            bidRepository.persist(bid);
+        }
+        return responseSender.ok("true");
+    }
+}

Subversion Repositories SmartDukaan

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