- 과정중 도출된 잘못된 도메인 이벤트들을 걸러내는 작업을 수행함
    - 검색시>객실 조회됨  :  UI 의 이벤트이지, 업무적인 의미의 이벤트가 아니라서 제외

- 도메인 서열 분리 
    - Core Domain:  ReservationManagement : 없어서는 안될 핵심 서비스이며, 연간 Up-time SLA 수준을 99.999% 목표, 배포주기는 app 의 경우 1주일 1회 미만, store 의 경우 1개월 1회 미만
    - Supporting Domain:   RoomManagement : 경쟁력을 내기위한 서비스이며, SLA 수준은 연간 60% 이상 uptime 목표, 배포주기는 각 팀의 자율이나 표준 스프린트 주기가 1주일 이므로 1주일 1회 이상을 기준으로 함.
    - General Domain:   paymentManagement : 결제서비스로 3rd Party 외부 서비스를 사용하는 것이 경쟁력이 높음 (핑크색으로 이후 전환할 예정)

- 고객은 예약 가능한 객실을 조회할 수 있다
- 고객이 객실을 선택하여 예약한다.
- 고객은 예약을 취소할 수 있다.
- 예약이 완료되면 해당 객실은 '예약불가' 상태로 변경된다.
- 결제가 완료되면 예약이 완료된다.
- 고객은 결제를 취소할 수 있다.
- 고객이 체크아웃 하면 관리자에게 객실 정비 요청이 된다.
- 고객은 객실에 대한 평가를 등록한다.

- 수정된 모델은 모든 요구사항을 커버함.

- Inbound adaptor와 Outbound adaptor를 구분함
- 호출관계에서 PubSub 과 Req/Resp 를 구분함
- 서브 도메인과 바운디드 컨텍스트의 분리:  각 팀의 KPI 별로 아래와 같이 관심 구현 스토리를 나눠가짐

cd ReservationManagement
mvn spring-boot:run

cd RoomManagement
mvn spring-boot:run 

cd PaymentManagement
mvn spring-boot:run  

cd gateway
mvn spring-boot:run  

package hotelmanage;

import javax.persistence.*;

import com.fasterxml.jackson.core.JsonProcessingException;
import com.fasterxml.jackson.databind.ObjectMapper;
import hotelmanage.config.kafka.KafkaProcessor;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.cloud.stream.messaging.Processor;
import org.springframework.messaging.MessageChannel;
import org.springframework.messaging.MessageHeaders;
import org.springframework.messaging.support.MessageBuilder;
import org.springframework.util.MimeTypeUtils;

import java.util.List;

@Entity
@Table(name="ReservationManagement_table")
public class ReservationManagement {

    @Id
    @GeneratedValue(strategy=GenerationType.AUTO)
    private Integer reservationNumber;
    private String customerName;
    private Integer customerId;
    private String reserveStatus;
    private Integer roomNumber;
    private Integer PaymentPrice;
    
   public Integer getReservationNumber() {
        return reservationNumber;
    }

    public void setReservationNumber(Integer reservationNumber) {
        this.reservationNumber = reservationNumber;
    }
    public String getCustomerName() {
        return customerName;
    }

    public void setCustomerName(String customerName) {
        this.customerName = customerName;
    }
    public Integer getCustomerId() {
        return customerId;
    }

    public void setCustomerId(Integer customerId) {
        this.customerId = customerId;
    }
    public String getReserveStatus() {
        return reserveStatus;
    }

    public void setReserveStatus(String reserveStatus) {
        this.reserveStatus = reserveStatus;
    }
    public Integer getRoomNumber() {
        return roomNumber;
    }

    public void setRoomNumber(Integer roomNumber) {
        this.roomNumber = roomNumber;
    }

    public Integer getPaymentPrice() {
        return PaymentPrice;
    }

    public void setPaymentPrice(Integer paymentPrice) {
        PaymentPrice = paymentPrice;
    }

package hotelmanage;

import org.springframework.data.repository.PagingAndSortingRepository;

public interface ReservationManagementRepository extends PagingAndSortingRepository<ReservationManagement, Integer>{

}

#  RoomManagement 서비스의 객실정보처리
http post localhost:8083/roomManagements roomStatus="first"

#  ReservationManagement 서비스의 예약처리
http post localhost:8081/reservationManagements  customerName="Lee" customerId=123 reserveStatus="1" roomNumber=1 paymentPrice=50000

# 예약 상태 확인
http post localhost:8084/rommInfos

# (payment) PaymentManagementService.java

package hotelmanage.external;

import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.*;

@org.springframework.stereotype.Service
@FeignClient(name="reservationNumber", url="${api.url.payment}")
public interface PaymentManagementService {

    @RequestMapping(method= RequestMethod.POST, path="/payments", consumes = "application/json")
    public void CompletePayment(@RequestBody Payment payment);

}

# ReservationManagement.java (Entity)

    @PreUpdate
    public void onPreUpdate(){
        ...
        Application.applicationContext.getBean(hotelmanage.external.PaymentManagementService.class).CompletePayment(payment);
    }

#결제요청
http post http://ReservationManagement:8080/reservationManagements reservationNumber=1 reserveStatus="reserve" customerName="Lee" customerId=123 roomNumber=1 paymentPrice=50001

#객실등록
http post localhost:8083/roomManagements roomStatus="first"

#예약요청 (객실이 있을경우)
http post http://ReservationManagement:8080/reservationManagements  customerName="Lee" customerId=123 reserveStatus="1" roomNumber=1 paymentPrice=50000

#결제요청
http post http://ReservationManagement:8080/reservationManagements reservationNumber=1 reserveStatus="reserve" customerName="Lee" customerId=123 roomNumber=1 paymentPrice=50001

#Check Out
http post http://ReservationManagement:8080/reservationManagements reservationNumber=1 reserveStatus="checkOut" customerName="Lee" customerId=123 roomNumber=1 paymentPrice=50001

package hotelmanage;

@Entity
@Table(name="ReservationManagement_table")
public class ReservationManagement {

 ...
    @PrePersist
    public void onPrePersist(){
        setReserveStatus("reserve");
        Reserved reserved = new Reserved();
        reserved.setReservationNumber(this.getReservationNumber());
        reserved.setReserveStatus(this.getReserveStatus());
        reserved.setCustomerName(this.getCustomerName());
        reserved.setCustomerId(this.getCustomerId());
        reserved.setRoomNumber(this.getRoomNumber());
        reserved.setPaymentPrice(this.getPaymentPrice());

        reserved.publishAfterCommit();
    }

package hotelmanage;

...

@Service
public class PolicyHandler{

    @Autowired
    ReservationManagementRepository reservationManagementrepository;

    @StreamListener(KafkaProcessor.INPUT)
    public void wheneverPaymentCompleted_ChangeResvStatus(@Payload PaymentCompleted paymentcompleted){
        System.out.println(paymentcompleted.toJson());
        if(paymentcompleted.isMe()){
            System.out.println("====================================결제완료 1차====================================");
            if(reservationManagementrepository.findById(paymentcompleted.getReservationNumber()) != null){
                System.out.println("====================================결제완료====================================");
                ReservationManagement reservationManagement = reservationManagementrepository.findById(paymentcompleted.getReservationNumber()).get();
                reservationManagement.setReserveStatus("paymentComp");
                reservationManagementrepository.save(reservationManagement);
            }

        }

    }

}

# 객실 서비스 (room) 를 잠시 내려놓음 (ctrl+c)

#예약처리
http post localhost:8081/reservationManagements  customerName="Lee" customerId=123 reserveStatus="1" roomNumber=1 paymentPrice=50000
   #Success
http post localhost:8081/reservationManagements  customerName="Lee" customerId=123 reserveStatus="1" roomNumber=1 paymentPrice=50000
   #Success

#객실상태 확인
http localhost:8084/roomInfos     # 객실 안바뀜 확인

#객실 서비스 기동
cd RoomManagement
mvn spring-boot:run

#객실상태 확인
http localhost:8084/roomInfos     # 모든 주문의 상태가 "배송됨"으로 확인

RoomManagement.java(Entity)

@Entity
@Table(name="RoomManagement_table")
public class RoomManagement {
    ...

    @PostPersist
    public void onPostPersist(){
        RoomConditionChanged roomConditionChanged = new RoomConditionChanged();
        roomConditionChanged.setRoomNumber(this.getRoomNumber());
        roomConditionChanged.setRoomStatus(this.getRoomStatus());
        BeanUtils.copyProperties(this, roomConditionChanged);
        roomConditionChanged.publishAfterCommit();
    }
    @PostUpdate
    public void onPostUpdate(){
            RoomConditionChanged roomConditionChanged = new RoomConditionChanged();
            roomConditionChanged.setRoomNumber(this.getRoomNumber());
            roomConditionChanged.setRoomStatus(this.getRoomStatus());
            BeanUtils.copyProperties(this, roomConditionChanged);
            roomConditionChanged.publishAfterCommit();
    }

PolicyHandler.java

@Service
public class PolicyHandler{

    @Autowired
    RoomInfoRepository roomInfoRepository;

    @StreamListener(KafkaProcessor.INPUT)
    public void wheneverSave_RoomInfo(@Payload RoomConditionChanged roomConditionChanged){

        if(roomConditionChanged.isMe()){
            System.out.println("##### listener 객실정보저장 : " + roomConditionChanged.toJson());
                RoomInfo roomInfo = new RoomInfo();
                roomInfo.setRoomNumber(roomConditionChanged.getRoomNumber());
                roomInfo.setRoomStatus(roomConditionChanged.getRoomStatus());
                roomInfoRepository.save(roomInfo);
        }
    }
}

# application.yml

hystrix:
  command:
    # 전역설정
    default:
      execution.isolation.thread.timeoutInMilliseconds: 610

# (PaymentManagement) Payment.java (Entity)

    @PrePersist
    public void onPrePersist(){  //결제이력을 저장한 후 적당한 시간 끌기

        ...
        
        try {
                Thread.currentThread().sleep((long) (400 + Math.random() * 220));
                System.out.println("=============결재 승인 완료=============");
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
    }

kubectl autoscale deploy paymentmanagement --min=1 --max=10 --cpu-percent=15

siege -c100 -t120S -r10 --content-type "application/json" 'http://paymentmanagement:8080/payments POST {"reservationStatus": "reserve"}'

kubectl get deploy pay -w

Transactions:                    642 hits
Availability:                  51.16 %
Elapsed time:                  48.78 secs
Data transferred:               0.68 MB
Response time:                  4.39 secs
Transaction rate:              13.16 trans/sec
Throughput:                     0.01 MB/sec
Concurrency:                   57.80
Successful transactions:         642
Failed transactions:             613
Longest transaction:            8.91
Shortest transaction:           0.00

Transactions:                   2293 hits
Availability:                  99.78 %
Elapsed time:                 119.58 secs
Data transferred:               0.70 MB
Response time:                  4.58 secs
Transaction rate:              19.18 trans/sec
Throughput:                     0.01 MB/sec
Concurrency:                   87.80
Successful transactions:        2293
Failed transactions:               5
Longest transaction:           15.44
Shortest transaction:           0.45