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

 import com.spice.profitmandi.common.exception.ProfitMandiBusinessException;
 import com.spice.profitmandi.common.model.BulkOrderModel;
 import com.spice.profitmandi.common.util.ExcelUtils;
 import com.spice.profitmandi.dao.cart.CartService;
 import com.spice.profitmandi.dao.entity.catalog.TagListing;
+import com.spice.profitmandi.dao.entity.transaction.Transaction;
+import com.spice.profitmandi.dao.entity.transaction.TransactionApproval;
+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.catalog.TagListingRepository;
 import com.spice.profitmandi.dao.repository.dtr.UserRepository;
+import com.spice.profitmandi.dao.repository.transaction.TransactionApprovalRepository;
+import com.spice.profitmandi.dao.repository.transaction.TransactionRepository;
+import com.spice.profitmandi.dao.repository.user.AddressRepository;
 import com.spice.profitmandi.service.transaction.TransactionService;
 import com.spice.profitmandi.service.wallet.CommonPaymentService;
 import com.spice.profitmandi.service.wallet.WalletService;
 import org.apache.logging.log4j.LogManager;
 import org.apache.logging.log4j.Logger;
+import org.apache.poi.ss.usermodel.Cell;
 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.stereotype.Controller;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
 import org.springframework.web.multipart.MultipartFile;
 import java.util.ArrayList;
 import java.util.List;
 import java.util.Map;
 import java.util.stream.Collectors;
-@Controller
+@Service
+@Transactional(rollbackFor = Throwable.class)
 public class BulkOrderService {
     private static final Logger LOGGER = LogManager.getLogger(BulkOrderService.class);
     @Autowired
     CartService cartService;
     @Autowired
     TagListingRepository tagListingRepository;
     @Autowired
     WalletService walletService;
     @Autowired
     UserRepository userRepository;
+    @Autowired
+    TransactionRepository transactionRepository;
+    @Autowired
+    TransactionApprovalRepository transactionApprovalRepository;
+    @Autowired
+    AddressRepository addressRepository;
+    //TODO:Tejus need to check
-    public void parseBulkOrders(MultipartFile file) throws Exception {
+    public void parseBulkOrders(MultipartFile file, int creatorId) throws Exception {
         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);
             XSSFRow row = mySheet.getRow(rowNumber);
             BulkOrderModel bulkOrderModel = this.createBulkModel(row);
             bulkOrderModels.add(bulkOrderModel);
+        }
         Map<Integer, List<BulkOrderModel>> fofoBulkOrdersMap = bulkOrderModels.stream().collect(Collectors.groupingBy(x -> x.getFofoId()));
+        boolean approvalNotRequired = true;
         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()));
             double totalAmount = 0;
             for (BulkOrderModel fofoBulkOrderModel : fofoBulkOrderModels) {
                 CartItem cartItem = new CartItem();
                 cartItem.setQuantity(fofoBulkOrderModel.getQuantity());
                 cartItem.setItemId(fofoBulkOrderModel.getItemId());
+                boolean isPriceZero = fofoBulkOrderModel.getItemPrice() == 0.0;
                 TagListing tagListing = tagListingRepository.selectByItemId(fofoBulkOrderModel.getItemId());
+                double itemSellingPrice = tagListing.getSellingPrice();
+                double itemMrp = tagListing.getMrp();
+                double customSellingPrice = fofoBulkOrderModel.getItemPrice();
+                int itemId = cartItem.getItemId();
-                //TODO:Tejus need to check
+                if (isPriceZero) {
-                cartItem.setSellingPrice(tagListing.getSellingPrice());
+                    cartItem.setSellingPrice(itemSellingPrice);
+                } else {
+                    if (customSellingPrice <= itemMrp) {
+                        cartItem.setSellingPrice(customSellingPrice);
+                        approvalNotRequired = false;
+                    } else {
+                        throw new ProfitMandiBusinessException("Given price is greater than selling price for item Id - ", itemId, " it should be less or equal of DP");
+                    }
+                }
                 totalAmount += cartItem.getSellingPrice() * cartItem.getQuantity();
                 cartItems.add(cartItem);
+            }
             LOGGER.info("totalAmount of item " + totalAmount);
             double walletAmount = walletService.getWalletAmount(fofoId);
             if (walletAmount < totalAmount) {
-                LOGGER.info("Skippin order due to insufficent balance for id - {}", fofoId);
+                throw new ProfitMandiBusinessException("Skippin order due to insufficent balance for id - ", fofoId, " ,Check wallet Balance ones");
-                continue;
+            }
             UserCart userCart = cartService.setCartItems(fofoId, cartItems);
+            // createtransactionInternally set the value in transaction table
             int transactionId = transactionService.createTransactionInternally(userCart, totalAmount, 0);
+            //Set here created by
+            Transaction transaction = transactionRepository.selectById(transactionId);
+            transaction.setCreatedBy(creatorId);
+            LOGGER.info("transaction  created by {}", transaction.getCreatedBy());
             commonPaymentService.payThroughWallet(transactionId);
-            // Once paid let proceed to process the order further.
+            if (approvalNotRequired) {
-            transactionService.processTransaction(transactionId);
+                transactionService.processTransaction(transactionId);
+            } else {
+                this.createApproval(transactionId);
+            }
+        }
+    }
+    public void createApproval(int transactionId) {
+        TransactionApproval transactionApproval = new TransactionApproval();
+        transactionApproval.setId(transactionId);
+        transactionApproval.setStatus(TransactionApprovalStatus.PENDING);
+        transactionApprovalRepository.persist(transactionApproval);
+    }
     private BulkOrderModel createBulkModel(XSSFRow row) throws ProfitMandiBusinessException {
         BulkOrderModel bulkOrderModel = new BulkOrderModel();
         int i = 0;
         bulkOrderModel.setRowIndex(row.getRowNum());
         try {
+            Cell partneranme = row.getCell(i++);
+            if (partneranme == null)
+                bulkOrderModel.setPartnerName("");
+            else
-            bulkOrderModel.setName(row.getCell(i++).getStringCellValue());
+                bulkOrderModel.setPartnerName(partneranme.getStringCellValue().trim());
+            Cell description = row.getCell(i++);
+            if (description == null)
+                bulkOrderModel.setDescription("");
+            else
-            bulkOrderModel.setDescription(row.getCell(i++).getStringCellValue());
+                bulkOrderModel.setDescription(description.getStringCellValue().trim());
             bulkOrderModel.setFofoId((int) row.getCell(i++).getNumericCellValue());
             bulkOrderModel.setItemId((int) row.getCell(i++).getNumericCellValue());
+            bulkOrderModel.setItemPrice(row.getCell(i++).getNumericCellValue());
             bulkOrderModel.setQuantity((int) row.getCell(i++).getNumericCellValue());
         } catch (Throwable e) {
             LOGGER.info(e.getCause());
-            throw new ProfitMandiBusinessException("Field", "Field at row - " + row.getRowNum() + ", column - " + (i - 1),
-                    "Invalid field value at - " + ExcelUtils.toAlphabet(i - 1) + (row.getRowNum() + 1) + ", " + ExcelUtils.getCellValue(row.getCell(i - 1)));
+            throw new ProfitMandiBusinessException("Field", "Field at row - " + row.getRowNum() + ", column - " + (i - 1), "Invalid field value at - " + ExcelUtils.toAlphabet(i - 1) + (row.getRowNum() + 1) + ", " + ExcelUtils.getCellValue(row.getCell(i - 1)));
+        }
         LOGGER.info(bulkOrderModel);
         return bulkOrderModel;
+    }

Subversion Repositories SmartDukaan

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