개발일지-34 [🛒장바구니 도메인: 장바구니 주문]

장바구니 기능 관련 포스팅

---

소금빵을 다시 장바구니에 담고 주문 할 준비를 해보겠다.

6.[GET] /jat/app/basket/order

주문 준비 화면에서 볼 정보들

• 주문 화면에서 주문 정보를 사용자에게 사전으로 보여주기 위한 로직을 구현하였다.
• 주문 화면에 보이는 정보는 : 주문할 가게, 가게의 주소, 내 번호, 주문 총 금액, + 본인의 결제정보 등을 띄워 줄 수있다.
• 나머지 픽업예정시간, 요청사항, 결제사항 등은 구매자가 직접 선택하는 기준으로 정하였다.

• 응답 바디
  • 주문의 주체를 가게에 연관시키기 위하여 storeIdx도 같이 반환해주었다.
    

• 컨트롤러
  

• 서비스
  • 장바구니에 담긴 메뉴를 기준으로 주문 정보를 조회

    public BasketOrderRes getBasketOrder(int userIdx) throws BaseException{
        try{
            BasketOrderRes orderRes = basketDao.getBasketOrder(userIdx);
            return orderRes;
        }catch (IncorrectResultSizeDataAccessException error) { // 쿼리문에 해당하는 결과가 없거나 2개 이상일 때
            throw new BaseException(NO_BASKET_ITEMS);// 장바구니에 담긴 항목없이 주문 불가능합니다.
        }catch(Exception e){
            throw new BaseException(DATABASE_ERROR);
        }
    }

• Dao

// 가게 Idx, 가게 이름, 가게 주소, 폰 번호, 주문 가격 조회
    public BasketOrderRes getBasketOrder(int userIdx) {
        String query = "SELECT\n" +
                "    S.storeIdx,\n" +
                "    S.store_name,\n" +
                "    S.store_address,\n" +
                "    C.phone,\n" +
                "    SUM(B.cnt * TM.price) as orderPrice\n" +
                "FROM Basket B\n" +
                "LEFT JOIN TodayMenu TM on B.todaymenuIdx = TM.todaymenuIdx\n" +
                "LEFT JOIN Stores S on B.storeIdx = S.storeIdx\n" +
                "LEFT JOIN Customers C on B.customerIdx = C.customerIdx\n" +
                "WHERE B.customerIdx = ?\n" +
                "AND B.status != 'D'";

        return this.jdbcTemplate.queryForObject(query,
                (rs, rowNum) -> new BasketOrderRes(
                        rs.getInt("storeIdx"),
                        rs.getString("store_name"),
                        rs.getString("store_address"),
                        rs.getString("phone"),
                        rs.getInt("orderPrice")
                ), userIdx);
    }

테스트

---

7. [POST] /jat/app/basket/order

구매자의 주문하기

• 사용자가 주문 정보를 모두 작성하고 주문을 하여 결제 정보를 발생시키기 위한 단계
• 해당 주문 요청을 발생 시 구매자의 주문현황화면에 주문 요청이 추가가 된다.
• 판매자/구매자 모두 주문에 대해서 같은 테이블을 바라보도록 설계하였다.

• 요청 바디
  • 장바구니에 대한 정보가 없는데, 이는 장바구니 테이블에 유저의 Idx로 정보가 유지되고 있기 때문
    

• 컨트롤러
  

• 서비스

    @Transactional(rollbackFor = BaseException.class)
    public OrderDoneRes postBasketOrder(int userIdx, OrderDoneReq orderReq) throws BaseException {
        // 1) 주문하기 전 장바구니에 담긴 품목 리스트 가져오기
        int storeIdx = orderReq.getStoreIdx();
        List<BasketOrderItem> basketItems;
        try {
            basketItems = basketDao.getBasketOrderItems(userIdx);
        } catch(Exception e){
            throw new BaseException(DATABASE_ERROR);
        }

        // 2) 해당 장바구니 목록들이 가게에 충분히 남아있는지 확인인
        try{
            for (BasketOrderItem bItem : basketItems){
                BasketTodayMenu bTodayMenu = basketDao.checkItemRemain(storeIdx, bItem.getTodayMenuIdx(), bItem.getCnt());
                // 조회한 개수가 가게에 남아있는 개수보다 크다면..?
                if(bTodayMenu.getRemain() < bItem.getCnt() || bTodayMenu.getTodayMenuIdx() != bItem.getTodayMenuIdx()){
                    throw new IncorrectResultSizeDataAccessException(0);
                }
            }
        }catch (IncorrectResultSizeDataAccessException error) { // 쿼리문에 해당하는 결과가 없거나 2개 이상일 때
            throw new BaseException(STORE_TODAY_MENU_LACK); // 가게의 떨이메뉴 개수가 부족하여 주문이 불가능합니다.
        }catch(Exception e){
            throw new BaseException(DATABASE_ERROR);
        }

        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd ");
        String pickupDate = sdf.format(new Date());
        orderReq.setPickupTime(pickupDate + orderReq.getPickupTime());

        try{
            // 주문 정보
            int orderIdx = basketDao.postBasketOrder(userIdx, orderReq);

            // 주문에 들어가는 메뉴 정보
            int orderMenuCnt = basketDao.postBasketOrderItems(orderIdx, basketItems);
            if (orderMenuCnt != basketItems.size())
                throw new Exception();

            // 주문한만큼 오늘의 메뉴 개수 감소
            int tmDescCnt = basketDao.todayMenuDecrease(basketItems);
            if (tmDescCnt != basketItems.size())
                throw new Exception();

            // 주문햇으면 장바구니에 있는 아이템 전부 비활성화
            int basketCount = basketDao.basketItemDone(basketItems);

            return new OrderDoneRes(orderIdx, basketItems.size());
        }catch(Exception e){
            throw new BaseException(ORDER_FAILED);
        }
    }

1. 구매자의 Idx를 이용하여 장바구니 목록을 조회한다.
2. 해당 장바구니 구성품이 현재 가게에 남아있는 등록 메뉴를 대상으로 주문이 가능한지 확인
3. 주문정보를 주문 테이블에 삽입한다. (Order Table)
4. 주문에 관련된 메뉴를 주문 목록 테이블에 삽입한다. (OrderList Table)
5. 오늘의 메뉴 주문한만큼 값 수정
6. 장바구니 초기화
   주문 도메인 포스팅

• Dao

// 구매자의 장바구니 조회
    public List<BasketOrderItem> getBasketOrderItems(int userIdx) {
        String query = "SELECT * FROM Basket WHERE customerIdx = ? AND status = 'A'";

        return this.jdbcTemplate.query(query,
                (rs, rowNum) -> new BasketOrderItem(
                        rs.getInt(1),
                        rs.getInt(2),
                        rs.getInt(3),
                        rs.getInt(4),
                        rs.getInt(5)
                ), userIdx);
    }

// 구매자가 장바구니에 담은 개수가 주문 가능한 개수를 넘는지 확인
    public BasketTodayMenu checkItemRemain(int storeIdx, int todayMenuIdx, int cnt) {
        String query = "SELECT\n" +
                "    *\n" +
                "FROM TodayMenu\n" +
                "WHERE storeIdx = ?\n" +
                "AND todaymenuIdx = ?\n" +
                "AND remain >= ?";

        Object[] params = new Object[]{
                storeIdx,
                todayMenuIdx,
                cnt
        };

        return this.jdbcTemplate.queryForObject(query,
                (rs, rowNum) -> new BasketTodayMenu(
                        rs.getInt("todaymenuIdx"),
                        rs.getInt("remain")
                ),params);
    }

// 주문 정보 발생
    public int postBasketOrder(int userIdx, OrderDoneReq orderReq) {
        String query = "INSERT INTO Orders(storeIdx, customerIdx, request, order_time, pickup_time, payment_status)\n" +
                "VALUES(?, ?, ?, NOW(), ?, ?)";

        Object[] params = new Object[]{
                orderReq.getStoreIdx(),
                userIdx,
                orderReq.getRequest(),
                orderReq.getPickupTime(),
                orderReq.getPaymentStatus()
        };

        this.jdbcTemplate.update(query, params);

        String lastInsertIdQuery = "select last_insert_id()";
        return this.jdbcTemplate.queryForObject(lastInsertIdQuery,int.class);
    }

// 주문 품목 삽입
    public List<BasketOrderItem> getBasketOrderItems(int userIdx) {
        String query = "SELECT * FROM Basket WHERE customerIdx = ? AND status = 'A'";

        return this.jdbcTemplate.query(query,
                (rs, rowNum) -> new BasketOrderItem(
                        rs.getInt(1),
                        rs.getInt(2),
                        rs.getInt(3),
                        rs.getInt(4),
                        rs.getInt(5)
                ), userIdx)
    }

// 떨이 메뉴 등록 현황 수정(개수 감소)
    public int todayMenuDecrease(List<BasketOrderItem> basketItems) {
        String query = "UPDATE TodayMenu\n" +
                "    SET remain = remain - ?\n" +
                "WHERE todaymenuIdx = ?\n" +
                "AND remain >= ?";

        return this.jdbcTemplate.batchUpdate(query,
                basketItems,
                basketItems.size(),
                (PreparedStatement ps, BasketOrderItem bItem) ->{
                    ps.setInt(1, bItem.getCnt());
                    ps.setInt(2, bItem.getTodayMenuIdx());
                    ps.setInt(3, bItem.getCnt());
                }).length;
    }

// 장바구니 초기화
    public int basketItemDone(List<BasketOrderItem> basketItems) {
        String query = "UPDATE Basket\n" +
                "    SET status = 'D'\n" +
                "WHERE basketIdx = ?";

        return this.jdbcTemplate.batchUpdate(query,
                basketItems,
                basketItems.size(),
                (PreparedStatement ps, BasketOrderItem bItem) ->{
                    ps.setInt(1, bItem.getBasketIdx());
                }).length;
    }

테스트

• 주문하기 구매자 화면에서 진행
  

Order Table

주문 정보 올바르게 DB에 반영

OrderLists Table

판매자 주문 현황확인