WebSVN – SmartDukaan – Diff – /trunk/profitmandi-cron/src/main/java/com/smartdukaan/cron/migrations/MovementPoCreator.java

 package com.smartdukaan.cron.migrations;
 import com.spice.profitmandi.common.exception.ProfitMandiBusinessException;
 import com.spice.profitmandi.dao.entity.auth.AuthUser;
 import com.spice.profitmandi.dao.entity.catalog.Item;
+import com.spice.profitmandi.dao.entity.transaction.Order;
 import com.spice.profitmandi.dao.entity.warehouse.Supplier;
 import com.spice.profitmandi.dao.entity.warehouse.WarehousePurchaseOrder;
 import com.spice.profitmandi.dao.model.CreateWarehousePurchaseOrderModel;
 import com.spice.profitmandi.dao.model.InternalMovementAllocationModel;
 import com.spice.profitmandi.dao.model.InternalMovementAvailabilityModel;
 import com.spice.profitmandi.dao.model.ItemWisePurchaseModel;
 import com.spice.profitmandi.dao.repository.auth.AuthRepository;
 import com.spice.profitmandi.dao.repository.catalog.ItemRepository;
+import com.spice.profitmandi.dao.repository.transaction.OrderRepository;
 import com.spice.profitmandi.dao.repository.warehouse.SupplierRepository;
 import com.spice.profitmandi.dao.repository.warehouse.WarehousePurchaseOrderRepository;
 import com.spice.profitmandi.service.warehouse.InternalMovementPricingService;
 import com.spice.profitmandi.service.warehouse.PurchaseOrderService;
+import in.shop2020.model.v1.order.OrderStatus;
+import in.shop2020.purchase.POStatus;
 import org.apache.poi.ss.usermodel.CellType;
 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.transaction.annotation.Transactional;
 import java.io.FileInputStream;
 import java.io.InputStream;
 import java.time.LocalDate;
+import java.time.LocalDateTime;
 import java.util.ArrayList;
+import java.util.Collections;
 import java.util.Comparator;
 import java.util.LinkedHashMap;
 import java.util.List;
 import java.util.Map;
 import java.util.function.Function;
     private ItemRepository itemRepository;
     @Autowired
     private WarehousePurchaseOrderRepository warehousePurchaseOrderRepository;
     @Autowired
     private AuthRepository authRepository;
+    @Autowired
+    private OrderRepository orderRepository;
     public static class Preview {
         public String supplierName;
         public final List<String> problems = new ArrayList<>();
         /** One entry per PO that would be raised, each its priced lines. */
                     + " PO(s) but found " + raised.size() + " near PO id " + firstPoId + " - rolled back, check by hand");
+        }
         return raised.stream().map(WarehousePurchaseOrder::getPoNumber).collect(Collectors.toList());
+    }
+    /**
+     * Closes a movement PO the way the PO screen's Close does (PurchaseOrderController.closePuchaseOrder): refuses if
+     * any order has moved past submitted for processing, otherwise refunds every live order and pre-closes the PO.
+     * Returns what it did, or would do when {@code live} is false.
+     */
+    @Transactional(rollbackFor = Throwable.class)
+    public String close(String poNumber, String closedBy, boolean live) throws Exception {
+        List<WarehousePurchaseOrder> found = warehousePurchaseOrderRepository.selectAllByPONumbers(Collections.singletonList(poNumber));
+        if (found.size() != 1) {
+            throw new ProfitMandiBusinessException("po", poNumber, "No single PO numbered " + poNumber);
+        }
+        WarehousePurchaseOrder po = found.get(0);
+        if (po.getTransactionId() == null || po.getTransactionId() <= 0) {
+            throw new ProfitMandiBusinessException("po", poNumber, poNumber + " raised no movement order");
+        }
+        List<Order> orders = orderRepository.selectAllByTransactionId(po.getTransactionId());
+        int liveOrders = 0;
+        int units = 0;
+        for (Order order : orders) {
+            if (order.getRefundTimestamp() != null) {
+                continue;
+            }
+            if (!OrderStatus.SUBMITTED_FOR_PROCESSING.equals(order.getStatus())) {
+                throw new ProfitMandiBusinessException("po", poNumber, "Order " + order.getId() + " is already "
+                        + order.getStatus() + " - its stock has left, so " + poNumber + " cannot be closed");
+            }
+            liveOrders++;
+            units += order.getLineItem().getQuantity();
+        }
+        String summary = poNumber + " (txn " + po.getTransactionId() + ", status " + po.getStatus() + "): " + liveOrders
+                + " order(s), " + units + " unit(s) to refund, then PRECLOSED";
+        if (!live) {
+            return "WOULD CLOSE " + summary;
+        }
+        for (Order order : orders) {
+            if (order.getRefundTimestamp() == null) {
+                orderRepository.refundOrder(order.getId(), closedBy, "Movement purchase order " + poNumber + " closed",
+                        OrderStatus.CANCELLED_DUE_TO_LOW_INVENTORY);
+            }
+        }
+        po.setStatus(POStatus.PRECLOSED);
+        po.setUpdatedAt(LocalDateTime.now());
+        return "CLOSED " + summary;
+    }
     private static List<ItemWisePurchaseModel> toPurchaseItems(Map<Integer, Integer> quantities) {
         List<ItemWisePurchaseModel> items = new ArrayList<>();
         for (Map.Entry<Integer, Integer> line : quantities.entrySet()) {
             ItemWisePurchaseModel item = new ItemWisePurchaseModel();
             item.setItemId(line.getKey());

Subversion Repositories SmartDukaan

(root)/trunk/profitmandi-cron/src/main/java/com/smartdukaan/cron/migrations/MovementPoCreator.java – Rev 37827 → 37832