Subversion Repositories SmartDukaan

package com.spice.profitmandi.service.wallet;

import com.spice.profitmandi.common.exception.ProfitMandiBusinessException;

import com.spice.profitmandi.dao.cart.CartService;

import com.spice.profitmandi.dao.entity.transaction.Order;

import com.spice.profitmandi.dao.entity.transaction.Payment;

import com.spice.profitmandi.dao.entity.transaction.Transaction;

import com.spice.profitmandi.dao.repository.transaction.OrderRepository;

import com.spice.profitmandi.dao.repository.transaction.PaymentRepository;

import com.spice.profitmandi.dao.repository.transaction.TransactionRepository;

import com.spice.profitmandi.service.order.OrderService;

import in.shop2020.model.v1.order.WalletReferenceType;

import org.apache.logging.log4j.LogManager;

import org.apache.logging.log4j.Logger;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.stereotype.Component;

import java.time.LocalDateTime;

import java.util.List;

import java.util.stream.Collectors;

@Component

public class CommonPaymentService {

	private static final Logger log = LogManager.getLogger(CommonPaymentService.class);

	@Autowired

	private WalletService walletService;

	@Autowired

	private OrderRepository orderRepository;

	@Autowired

	private OrderService orderService;

	@Autowired

	private TransactionRepository transactionRepository;

	@Autowired

	private PaymentRepository paymentRepository;

	@Autowired

	private CartService cartService;

	public void payThroughWallet(int transactionId) throws ProfitMandiBusinessException {

		Transaction transaction = transactionRepository.selectById(transactionId);

		List<Order> orders = orderRepository.selectAllByTransactionId(transactionId);

		payThroughWallet(transaction, orders);

	}

	public void payThroughWallet(Transaction transaction, List<Order> orders) throws ProfitMandiBusinessException {

		double walletAmount = orders.stream().collect(Collectors.summingDouble(Order::getTotalAmount));

		walletService.consumeAmountFromWallet(transaction.getRetailerId(), transaction.getId(),

				WalletReferenceType.PURCHASE, "Against Order purchase", (float) walletAmount, LocalDateTime.now());

		this.addPayment(transaction, walletAmount);

	}

	private void addPayment(Transaction transaction, double walletAmount) {

		Payment payment = new Payment();

		payment.setAmount(walletAmount);

		payment.setGatewayId(8);

		payment.setStatus(2);

		payment.setGatewayTxnStatus("SUCCESS");

		payment.setDescription("Payment Received");

		payment.setUserId(transaction.getRetailerId());

		payment.setInitTimestamp(LocalDateTime.now());

		payment.setSuccessTimestamp(LocalDateTime.now());

		payment.setDigital(false);

		payment.setMerchantTxnId(transaction.getId());

		paymentRepository.persist(payment);

	}

}