-
Notifications
You must be signed in to change notification settings - Fork 136
/
OrderManageService.java
53 lines (46 loc) · 2.11 KB
/
OrderManageService.java
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
package pl.piomin.payment.service;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.kafka.core.KafkaTemplate;
import org.springframework.stereotype.Service;
import pl.piomin.base.domain.Order;
import pl.piomin.payment.domain.Customer;
import pl.piomin.payment.repository.CustomerRepository;
@Service
public class OrderManageService {
private static final String SOURCE = "payment";
private static final Logger LOG = LoggerFactory.getLogger(OrderManageService.class);
private CustomerRepository repository;
private KafkaTemplate<Long, Order> template;
public OrderManageService(CustomerRepository repository, KafkaTemplate<Long, Order> template) {
this.repository = repository;
this.template = template;
}
public void reserve(Order order) {
Customer customer = repository.findById(order.getCustomerId()).orElseThrow();
LOG.info("Found: {}", customer);
if (order.getPrice() < customer.getAmountAvailable()) {
order.setStatus("ACCEPT");
customer.setAmountReserved(customer.getAmountReserved() + order.getPrice());
customer.setAmountAvailable(customer.getAmountAvailable() - order.getPrice());
} else {
order.setStatus("REJECTED");
}
order.setSource(SOURCE);
repository.save(customer);
template.send("payment-orders", order.getId(), order);
LOG.info("Sent: {}", order);
}
public void confirm(Order order) {
Customer customer = repository.findById(order.getCustomerId()).orElseThrow();
LOG.info("Found: {}", customer);
if (order.getStatus().equals("CONFIRMED")) {
customer.setAmountReserved(customer.getAmountReserved() - order.getPrice());
repository.save(customer);
} else if (order.getStatus().equals("ROLLBACK") && !order.getSource().equals(SOURCE)) {
customer.setAmountReserved(customer.getAmountReserved() - order.getPrice());
customer.setAmountAvailable(customer.getAmountAvailable() + order.getPrice());
repository.save(customer);
}
}
}