WebSVN – SmartDukaan – Diff – /trunk/profitmandi-dao/src/main/java/com/spice/profitmandi/service/order/BulkOrderService.java

 import com.spice.profitmandi.common.model.BulkOrderModel;
 import com.spice.profitmandi.common.model.LineItemModel;
 import com.spice.profitmandi.common.model.ProfitMandiConstants;
 import com.spice.profitmandi.common.model.TransactionApprovalModel;
 import com.spice.profitmandi.common.util.ExcelUtils;
+import com.spice.profitmandi.common.util.Utils;
 import com.spice.profitmandi.dao.cart.CartService;
 import com.spice.profitmandi.dao.entity.auth.AuthUser;
+import com.spice.profitmandi.dao.entity.catalog.Bid;
+import com.spice.profitmandi.dao.entity.catalog.Liquidation;
 import com.spice.profitmandi.dao.entity.catalog.TagListing;
+import com.spice.profitmandi.dao.entity.dtr.User;
 import com.spice.profitmandi.dao.entity.transaction.*;
+import com.spice.profitmandi.dao.enumuration.cs.EscalationType;
 import com.spice.profitmandi.dao.enumuration.transaction.TransactionApprovalStatus;
 import com.spice.profitmandi.dao.model.CartItem;
 import com.spice.profitmandi.dao.model.UserCart;
 import com.spice.profitmandi.dao.repository.auth.AuthRepository;
 import com.spice.profitmandi.dao.repository.catalog.TagListingRepository;
+import com.spice.profitmandi.dao.repository.cs.CsService;
 import com.spice.profitmandi.dao.repository.dtr.UserRepository;
 import com.spice.profitmandi.dao.repository.transaction.OrderRepository;
 import com.spice.profitmandi.dao.repository.transaction.SDCreditRequirementRepository;
 import com.spice.profitmandi.dao.repository.transaction.TransactionApprovalRepository;
 import com.spice.profitmandi.dao.repository.transaction.TransactionRepository;
 import org.apache.poi.ss.usermodel.Row;
 import org.apache.poi.xssf.usermodel.XSSFRow;
 import org.apache.poi.xssf.usermodel.XSSFSheet;
 import org.apache.poi.xssf.usermodel.XSSFWorkbook;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.mail.javamail.JavaMailSender;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 import org.springframework.web.multipart.MultipartFile;
 import java.math.BigDecimal;
     TransactionApprovalRepository transactionApprovalRepository;
     @Autowired
     AddressRepository addressRepository;
     @Autowired
     OrderRepository orderRepository;
-    @Autowired
-    AuthRepository authRepository;
+    //TODO:Tejus need to check
     @Autowired
     SDCreditRequirementRepository sdCreditRequirementRepository;
-    //TODO:Tejus need to check
     @Autowired
     SDCreditService sdCreditService;
+    @Autowired
+    private CsService csService;
+    @Autowired
+    private JavaMailSender mailSender;
+    @Autowired
+    private AuthRepository authRepository;
-    public void parseBulkOrders(MultipartFile file, int creatorId) throws Exception {
+    public void parseBulkOrders(MultipartFile file, int creatorId) throws Exception, ProfitMandiBusinessException {
         XSSFWorkbook myWorkBook = new XSSFWorkbook(file.getInputStream());
         myWorkBook.setMissingCellPolicy(Row.MissingCellPolicy.RETURN_BLANK_AS_NULL);
         // Return first sheet from the XLSX workbook
         XSSFSheet mySheet = myWorkBook.getSheetAt(0);
                 bulkOrderModels.add(bulkOrderModel);
             } else {
                 break;
+            }
+        }
+        this.generatePurchaseOrder(bulkOrderModels, creatorId, ProfitMandiConstants.PO_TYPE.MANUAL);
+    }
+    public void generatePurchaseOrder(List<BulkOrderModel> bulkOrderModels, int creatorId, ProfitMandiConstants.PO_TYPE type) throws Exception,ProfitMandiBusinessException {
         Map<Integer, List<BulkOrderModel>> fofoBulkOrdersMap = bulkOrderModels.stream().collect(Collectors.groupingBy(x -> x.getFofoId()));
-        boolean approvalNotRequired = true;
+        boolean approvalRequired = false;
         for (Map.Entry<Integer, List<BulkOrderModel>> fofoBulkOrderEntry : fofoBulkOrdersMap.entrySet()) {
             int fofoId = fofoBulkOrderEntry.getKey();
             List<BulkOrderModel> fofoBulkOrderModels = fofoBulkOrderEntry.getValue();
             Map<Integer, Long> orderItemCountMap = fofoBulkOrderModels.stream().collect(Collectors.groupingBy(x -> x.getItemId(), Collectors.counting()));
                 if (isPriceZero || isActualPrice) {
                     cartItem.setSellingPrice(itemSellingPrice);
                 } else {
                     if (customSellingPrice <= tagListing.getMrp() || customSellingPrice <= tagListing.getMop()) {
                         cartItem.setSellingPrice(customSellingPrice);
-                        approvalNotRequired = false;
+                        approvalRequired = true;
                     } else {
                         throw new ProfitMandiBusinessException("Given price is greater than selling price for item Id - ", itemId, " it should be less or equal of DP");
+                    }
             BigDecimal creditAvailability = sdCreditService.getAvailableAmount(fofoId);
             double netAmountInHand = creditAvailability.doubleValue() + walletAmount;
             LOGGER.info("netAmountInHand - " + netAmountInHand);
             if (totalPayableAmount > ProfitMandiConstants.MAX_NEGATIVE_WALLET_VALUE && netAmountInHand < totalPayableAmount) {
+                if (type == ProfitMandiConstants.PO_TYPE.MANUAL) {
-                throw new ProfitMandiBusinessException("Skipping order due to insufficient balance for id - ", fofoId, " ,Check wallet Balance once");
+                    throw new ProfitMandiBusinessException("Skipping order due to insufficient balance for id - ", fofoId, " ,Check wallet Balance once");
+                } else {
+                    this.notifyPartnerRBM(netAmountInHand, totalPayableAmount, fofoId);
+                }
+            }
             UserCart userCart = cartService.setCartItems(fofoId, cartItems);
             // createtransactionInternally set the value in transaction table
             double creditAmountRequired = totalPayableAmount - walletAmount;
             int loanId = 0;
             if (creditAmountRequired > ProfitMandiConstants.MAX_NEGATIVE_WALLET_VALUE) {
                 Loan loan = sdCreditService.createLoan(userCart.getUserId(), creditAmountRequired, 365, "Credit limit assigned via SD Credit");
                 loanId = loan.getId();
+            }
-            //return this.createLoan(userCart.getUserId(), creditAmountRequired);
             int transactionId = transactionService.createTransactionInternally(userCart, totalPayableAmount, 0);
             //Set here created by
             Transaction transaction = transactionRepository.selectById(transactionId);
             transaction.setCreatedBy(creatorId);
             LOGGER.info("transaction  created by {}", transaction.getCreatedBy());
             commonPaymentService.payThroughWallet(transactionId);
-            if (approvalNotRequired) {
+            if (approvalRequired) {
-                transactionService.processTransaction(transactionId,loanId);
-            } else {
                 this.createApproval(transactionId);
+            } else {
+                transactionService.processTransaction(transactionId,loanId);
+            }
+        }
+    }
     public void createApproval(int transactionId) {
         TransactionApproval transactionApproval = new TransactionApproval();
         transactionApproval.setId(transactionId);
+        }
         return approvalModelList;
+    }
+    public void notifyPartnerRBM(double netAmountInHand, double totalPayableAmount, int fofoId) throws Exception, ProfitMandiBusinessException {
+        User user = userRepository.selectById(fofoId);
+        int rbmId = csService.getAuthUserId(ProfitMandiConstants.TICKET_CATEGORY_RBM, EscalationType.L1, fofoId);
+        AuthUser authUser = authRepository.selectById(rbmId);
+        //String[] emailTo = new String[] { authUser.getEmailId() };
+        String[] emailTo = new String[] { "vjangra856@gmail.com" };
+        String[] ccTo = {"vikas.jangra@smartdukaan.com"};
+        String subject = "Dispatch On Hold(Bidding)";
+        String message = String.format(
+                "Dear Team, \n"
+                        + "This is to inform you that the material for %s with the value Rs.%s "
+                        + "purchase is hold till the money against the stock will receive. Kindly inform the partner "
+                        + "about wallet topup with amount of Rs.%s. The material will be dispatched.",
+                user.getFirstName(), totalPayableAmount, (totalPayableAmount - netAmountInHand)
+        );
+        LOGGER.info("mailMessage: {}",message);
+        Utils.sendMailWithAttachments(mailSender, emailTo, ccTo, subject, message);
+    }
+}

Subversion Repositories SmartDukaan

(root)/trunk/profitmandi-dao/src/main/java/com/spice/profitmandi/service/order/BulkOrderService.java – Rev 34312 → 34443