Tôi muốn sao khi lấy ra danh sách giá thấp nhất rồi thì update Product.notify là 0 vào bảng product

Lấy ra danh sách giá thấp nhất giờ tôi có bảng tôi muốn lấy ra giá thấp nhất và giá đó phải được gửi qua mail và bên dưới là cách tôi thực hiện với SQLAlchemy

Lấy ra danh sách giá thấp nhất bạn có thể thêm một phần mã để cập nhật cột notify của các sản phẩm đã được truy vấn thành 0.
Dưới đây là đoạn mã đã được chỉnh sửa để thực hiện việc đó:

from sqlalchemy import update

def get_min_price(self):
    subquery = self.session.query(
        Product.type,
        func.min(Product.price).label('lowest_price')
    ).filter(
        Product.deleted == 0,
        Product.notify == 1
    ).group_by(Product.type).subquery()

    query_lowest_price_by_type = self.session.query(
        Product.id,
        Product.name,
        Product.url,
        Product.link,
        Product.type,
        Product.price
    ).join(
        subquery,
        (Product.type == subquery.c.type) & (
            Product.price == subquery.c.lowest_price)
    ).filter(
        Product.deleted == 0,
        Product.notify == 1
    )

    # Thực thi câu truy vấn
    lowest_price_by_type = query_lowest_price_by_type.all()

    # Lấy danh sách ID của các sản phẩm đã lấy ra
    product_ids = [product.id for product in lowest_price_by_type]

    # Thực hiện update lại notify là 0 cho các sản phẩm đã lấy ra
    self.session.execute(
        update(Product)
        .where(Product.id.in_(product_ids))
        .values(notify=0)
    )
    self.session.commit()

    lowest_price_by_type = self.sorted_price_min(lowest_price_by_type)

    return lowest_price_by_type

Trong đoạn mã này, chúng ta sử dụng hàm update từ SQLAlchemy để cập nhật các sản phẩm đã được lấy ra từ truy vấn ban đầu, đặt cột notify của chúng thành 0 và commit thay đổi vào cơ sở dữ liệu.

Sản phẩm đó đã thông báo qua 3 ngày trước rồi thì mới tắt thông báo của sản phẩm đó created_at

Để thực hiện việc chỉ cập nhật trạng thái notify thành 0 cho các sản phẩm đã được thông báo cách đây 3 ngày hoặc lâu hơn, bạn có thể sử dụng điều kiện thêm vào truy vấn update.
Điều này yêu cầu so sánh cột created_at với ngày hiện tại trừ đi 3 ngày.

Trước đó bạn có thể test bằng việc xây dựng chức năng sort

Trở lại với đoạn code lấy giá thấp nhất

Tối ưu code lấy giá thấp nhất

Dưới đây là cách bạn có thể chỉnh sửa đoạn mã để thêm điều kiện này:

from sqlalchemy import update, func
from datetime import datetime, timedelta

def get_min_price(self):
    three_days_ago = datetime.now() - timedelta(days=3)

    subquery = self.session.query(
        Product.type,
        func.min(Product.price).label('lowest_price')
    ).filter(
        Product.deleted == 0,
        Product.notify == 1
    ).group_by(Product.type).subquery()

    query_lowest_price_by_type = self.session.query(
        Product.id,
        Product.name,
        Product.url,
        Product.link,
        Product.type,
        Product.price
    ).join(
        subquery,
        (Product.type == subquery.c.type) & (
            Product.price == subquery.c.lowest_price)
    ).filter(
        Product.deleted == 0,
        Product.notify == 1
    )

    # Thực thi câu truy vấn
    lowest_price_by_type = query_lowest_price_by_type.all()

    # Lấy danh sách ID của các sản phẩm đã lấy ra
    product_ids = [product.id for product in lowest_price_by_type]

    # Thực hiện update lại notify là 0 cho các sản phẩm đã được thông báo ít nhất 3 ngày trước
    self.session.execute(
        update(Product)
        .where(
            Product.id.in_(product_ids),
            Product.created_at <= three_days_ago
        )
        .values(notify=0)
    )
    self.session.commit()

    lowest_price_by_type = self.sorted_price_min(lowest_price_by_type)

    return lowest_price_by_type

Trong đoạn mã này:

• three_days_ago được tính bằng cách lấy ngày hiện tại trừ đi 3 ngày.
• Điều kiện Product.created_at <= three_days_ago được thêm vào truy vấn update để đảm bảo rằng chỉ các sản phẩm đã được thông báo ít nhất 3 ngày trước mới được cập nhật.

Full Code

Giờ hãy chia nhỏ thành các hàm nhỏ ra cho linh hoạt

Chia mã thành các hàm nhỏ hơn có thể giúp mã dễ đọc hơn và dễ bảo trì hơn.
Dưới đây là cách bạn có thể chia đoạn mã thành các hàm nhỏ hơn:

from sqlalchemy import update, func
from datetime import datetime, timedelta

class ProductService:
    def __init__(self, session):
        self.session = session

    def get_min_price_subquery(self):
        return self.session.query(
            Product.type,
            func.min(Product.price).label('lowest_price')
        ).filter(
            Product.deleted == 0,
            Product.notify == 1
        ).group_by(Product.type).subquery()

    def get_lowest_price_by_type(self, subquery):
        return self.session.query(
            Product.id,
            Product.name,
            Product.url,
            Product.link,
            Product.type,
            Product.price
        ).join(
            subquery,
            (Product.type == subquery.c.type) & (
                Product.price == subquery.c.lowest_price)
        ).filter(
            Product.deleted == 0,
            Product.notify == 1
        )

    def get_product_ids(self, query):
        return [product.id for product in query.all()]

    def update_notify_status(self, product_ids, three_days_ago):
        self.session.execute(
            update(Product)
            .where(
                Product.id.in_(product_ids),
                Product.created_at <= three_days_ago
            )
            .values(notify=0)
        )
        self.session.commit()

    def get_min_price(self):
        three_days_ago = datetime.now() - timedelta(days=3)

        subquery = self.get_min_price_subquery()
        query_lowest_price_by_type = self.get_lowest_price_by_type(subquery)
        lowest_price_by_type = query_lowest_price_by_type.all()
        product_ids = self.get_product_ids(query_lowest_price_by_type)
        
        self.update_notify_status(product_ids, three_days_ago)

        return self.sorted_price_min(lowest_price_by_type)
    
    def sorted_price_min(self, lowest_price_by_type):
        # Implement your sorting logic here
        return lowest_price_by_type

Giải thích các hàm nhỏ hơn:

1. get_min_price_subquery: Tạo truy vấn con để lấy giá thấp nhất cho từng loại sản phẩm.
2. get_lowest_price_by_type: Tạo truy vấn để lấy sản phẩm có giá thấp nhất cho từng loại sản phẩm.
3. get_product_ids: Lấy danh sách ID của các sản phẩm từ truy vấn.
4. update_notify_status: Cập nhật trạng thái thông báo của các sản phẩm thành 0 nếu chúng đã được thông báo ít nhất 3 ngày trước.
5. get_min_price: Hàm chính gọi các hàm khác và thực hiện toàn bộ quá trình.
6. sorted_price_min: Hàm này là placeholder cho logic sắp xếp của bạn (bạn cần implement logic sắp xếp ở đây).

Bạn có thể gọi hàm get_min_price từ lớp ProductService để lấy danh sách sản phẩm có giá thấp nhất và cập nhật trạng thái notify.

Giải thích từng dòng và quy trình

Tất nhiên! Hãy giải thích từng hàm và quy trình trong mã đã được chia nhỏ cho lấy ra danh sách giá thấp nhất

Class ProductService

Đây là một lớp được thiết kế để thao tác với dịch vụ liên quan đến sản phẩm trong cơ sở dữ liệu.
Nó sử dụng SQLAlchemy để tương tác với cơ sở dữ liệu thông qua đối tượng session được cung cấp khi khởi tạo lớp.

Hàm get_min_price_subquery

def get_min_price_subquery(self):
    return self.session.query(
        Product.type,
        func.min(Product.price).label('lowest_price')
    ).filter(
        Product.deleted == 0,
        Product.notify == 1
    ).group_by(Product.type).subquery()

• Mô tả: Hàm này tạo và trả về một truy vấn con để lấy ra giá thấp nhất cho từng loại sản phẩm (Product.type).
• Công việc:Sử dụng self.session.query để bắt đầu một truy vấn với Product.Sử dụng func.min(Product.price).label(‘lowest_price’) để tính giá thấp nhất và đặt nhãn là lowest_price.Lọc các sản phẩm không bị xóa (Product.deleted == 0) và chỉ những sản phẩm có trạng thái notify là 1 (Product.notify == 1).Nhóm kết quả theo Product.type.Sử dụng .subquery() để tạo một đối tượng truy vấn con.
• Sử dụng self.session.query để bắt đầu một truy vấn với Product.
• Sử dụng func.min(Product.price).label(‘lowest_price’) để tính giá thấp nhất và đặt nhãn là lowest_price.
• Lọc các sản phẩm không bị xóa (Product.deleted == 0) và chỉ những sản phẩm có trạng thái notify là 1 (Product.notify == 1).
• Nhóm kết quả theo Product.type.
• Sử dụng .subquery() để tạo một đối tượng truy vấn con.

• Sử dụng self.session.query để bắt đầu một truy vấn với Product.
• Sử dụng func.min(Product.price).label(‘lowest_price’) để tính giá thấp nhất và đặt nhãn là lowest_price.
• Lọc các sản phẩm không bị xóa (Product.deleted == 0) và chỉ những sản phẩm có trạng thái notify là 1 (Product.notify == 1).
• Nhóm kết quả theo Product.type.
• Sử dụng .subquery() để tạo một đối tượng truy vấn con.

Hàm get_lowest_price_by_type

def get_lowest_price_by_type(self, subquery):
    return self.session.query(
        Product.id,
        Product.name,
        Product.url,
        Product.link,
        Product.type,
        Product.price
    ).join(
        subquery,
        (Product.type == subquery.c.type) & (
            Product.price == subquery.c.lowest_price)
    ).filter(
        Product.deleted == 0,
        Product.notify == 1
    )

• Mô tả: Hàm này tạo và trả về một truy vấn để lấy các sản phẩm có giá thấp nhất cho từng loại sản phẩm, sử dụng kết quả từ truy vấn con đã được chỉ định.
• Công việc:Sử dụng self.session.query để bắt đầu một truy vấn với Product.Sử dụng .join(subquery, …) để nối với truy vấn con subquery.Điều kiện nối là Product.type == subquery.c.type và Product.price == subquery.c.lowest_price, để chỉ lấy sản phẩm có giá thấp nhất cho từng loại.Lọc các sản phẩm không bị xóa (Product.deleted == 0) và chỉ những sản phẩm có trạng thái notify là 1 (Product.notify == 1).
• Sử dụng self.session.query để bắt đầu một truy vấn với Product.
• Sử dụng .join(subquery, …) để nối với truy vấn con subquery.
• Điều kiện nối là Product.type == subquery.c.type và Product.price == subquery.c.lowest_price, để chỉ lấy sản phẩm có giá thấp nhất cho từng loại.
• Lọc các sản phẩm không bị xóa (Product.deleted == 0) và chỉ những sản phẩm có trạng thái notify là 1 (Product.notify == 1).

• Sử dụng self.session.query để bắt đầu một truy vấn với Product.
• Sử dụng .join(subquery, …) để nối với truy vấn con subquery.
• Điều kiện nối là Product.type == subquery.c.type và Product.price == subquery.c.lowest_price, để chỉ lấy sản phẩm có giá thấp nhất cho từng loại.
• Lọc các sản phẩm không bị xóa (Product.deleted == 0) và chỉ những sản phẩm có trạng thái notify là 1 (Product.notify == 1).

Hàm get_product_ids

def get_product_ids(self, query):
    return [product.id for product in query.all()]

• Mô tả: Hàm này lấy danh sách ID của các sản phẩm từ một truy vấn đã cho.
• Công việc:Trả về một danh sách các product.id từ kết quả của query, bằng cách sử dụng list comprehension.
• Trả về một danh sách các product.id từ kết quả của query, bằng cách sử dụng list comprehension.

• Trả về một danh sách các product.id từ kết quả của query, bằng cách sử dụng list comprehension.

Hàm update_notify_status

def update_notify_status(self, product_ids, three_days_ago):
    self.session.execute(
        update(Product)
        .where(
            Product.id.in_(product_ids),
            Product.created_at <= three_days_ago
        )
        .values(notify=0)
    )
    self.session.commit()

• Mô tả: Hàm này cập nhật trạng thái notify của các sản phẩm đã được thông báo từ trước ít nhất 3 ngày trước.
• Công việc:Sử dụng self.session.execute để thực hiện một truy vấn cập nhật (update) cho bảng Product.Điều kiện là chỉ cập nhật các sản phẩm có ID nằm trong danh sách product_ids và có Product.created_at nhỏ hơn hoặc bằng three_days_ago.Đặt notify=0 cho các bản ghi thỏa mãn điều kiện.Gọi self.session.commit() để lưu các thay đổi vào cơ sở dữ liệu.
• Sử dụng self.session.execute để thực hiện một truy vấn cập nhật (update) cho bảng Product.
• Điều kiện là chỉ cập nhật các sản phẩm có ID nằm trong danh sách product_ids và có Product.created_at nhỏ hơn hoặc bằng three_days_ago.
• Đặt notify=0 cho các bản ghi thỏa mãn điều kiện.
• Gọi self.session.commit() để lưu các thay đổi vào cơ sở dữ liệu.

• Sử dụng self.session.execute để thực hiện một truy vấn cập nhật (update) cho bảng Product.
• Điều kiện là chỉ cập nhật các sản phẩm có ID nằm trong danh sách product_ids và có Product.created_at nhỏ hơn hoặc bằng three_days_ago.
• Đặt notify=0 cho các bản ghi thỏa mãn điều kiện.
• Gọi self.session.commit() để lưu các thay đổi vào cơ sở dữ liệu.

Hàm get_min_price

def get_min_price(self):
    three_days_ago = datetime.now() - timedelta(days=3)

    subquery = self.get_min_price_subquery()
    query_lowest_price_by_type = self.get_lowest_price_by_type(subquery)
    lowest_price_by_type = query_lowest_price_by_type.all()
    product_ids = self.get_product_ids(query_lowest_price_by_type)
    
    self.update_notify_status(product_ids, three_days_ago)

    return self.sorted_price_min(lowest_price_by_type)

• Mô tả: Hàm chính thực hiện toàn bộ quy trình để lấy các sản phẩm có giá thấp nhất cho từng loại và cập nhật trạng thái notify.
• Công việc:Tính three_days_ago là ngày hiện tại trừ đi 3 ngày.Gọi self.get_min_price_subquery() để lấy truy vấn con.Gọi self.get_lowest_price_by_type(subquery) để lấy danh sách các sản phẩm có giá thấp nhất cho từng loại.Lấy danh sách product_ids của các sản phẩm đã lấy.Gọi self.update_notify_status(product_ids, three_days_ago) để cập nhật trạng thái notify của các sản phẩm thỏa mãn điều kiện.Trả về kết quả từ self.sorted_price_min(lowest_price_by_type), chưa có logic sắp xếp cụ thể ở đây.
• Tính three_days_ago là ngày hiện tại trừ đi 3 ngày.
• Gọi self.get_min_price_subquery() để lấy truy vấn con.
• Gọi self.get_lowest_price_by_type(subquery) để lấy danh sách các sản phẩm có giá thấp nhất cho từng loại.
• Lấy danh sách product_ids của các sản phẩm đã lấy.
• Gọi self.update_notify_status(product_ids, three_days_ago) để cập nhật trạng thái notify của các sản phẩm thỏa mãn điều kiện.
• Trả về kết quả từ self.sorted_price_min(lowest_price_by_type), chưa có logic sắp xếp cụ thể ở đây.

• Tính three_days_ago là ngày hiện tại trừ đi 3 ngày.
• Gọi self.get_min_price_subquery() để lấy truy vấn con.
• Gọi self.get_lowest_price_by_type(subquery) để lấy danh sách các sản phẩm có giá thấp nhất cho từng loại.
• Lấy danh sách product_ids của các sản phẩm đã lấy.
• Gọi self.update_notify_status(product_ids, three_days_ago) để cập nhật trạng thái notify của các sản phẩm thỏa mãn điều kiện.
• Trả về kết quả từ self.sorted_price_min(lowest_price_by_type), chưa có logic sắp xếp cụ thể ở đây.

Hàm sorted_price_min

def sorted_price_min(self, lowest_price_by_type):
    # Implement your sorting logic here
    return lowest_price_by_type

• Mô tả: Đây là một hàm placeholder cho logic sắp xếp của bạn. Bạn cần cài đặt logic sắp xếp dựa trên yêu cầu cụ thể của bạn.

Tóm tắt quy trình

1. Khởi tạo lớp ProductService: Được truyền vào một phiên làm việc với cơ sở dữ liệu.
2. get_min_price: Lấy giá thấp nhất cho từng loại sản phẩm, cập nhật trạng thái notify của các sản phẩm đã được thông báo ít nhất 3 ngày trước.Tạo truy vấn con để lấy giá thấp nhất cho từng loại.Lấy các sản phẩm có giá thấp nhất cho từng loại.Lấy danh sách ID của các sản phẩm đã lấy.Cập nhật trạng thái notify của các sản phẩm thỏa mãn điều kiện.Trả về danh sách các sản phẩm có giá thấp nhất, có thể đã được sắp xếp (chưa cài đặt logic sắp xếp ở đây).
3. Tạo truy vấn con để lấy giá thấp nhất cho từng loại.
4. Lấy các sản phẩm có giá thấp nhất cho từng loại.
5. Lấy danh sách ID của các sản phẩm đã lấy.
6. Cập nhật trạng thái notify của các sản phẩm thỏa mãn điều kiện.
7. Trả về danh sách các sản phẩm có giá thấp nhất, có thể đã được sắp xếp (chưa cài đặt logic sắp xếp ở đây).

• Tạo truy vấn con để lấy giá thấp nhất cho từng loại.
• Lấy các sản phẩm có giá thấp nhất cho từng loại.
• Lấy danh sách ID của các sản phẩm đã lấy.
• Cập nhật trạng thái notify của các sản phẩm thỏa mãn điều kiện.
• Trả về danh sách các sản phẩm có giá thấp nhất, có thể đã được sắp xếp (chưa cài đặt logic sắp xếp ở đây).

Việc chia nhỏ mã thành các hàm nhỏ giúp dễ bảo trì và mở rộng mã, mỗi hàm thực hiện một nhiệm vụ cụ thể, dễ dàng tái sử dụng và sửa đổi khi cần thiết.

#Mtips5s #Contact

Fanpage: https://www.facebook.com/mtipscoder

Group trao đổi, chia sẻ: https://www.facebook.com/groups/mtipscoder

Website: https://mtips5s.com

Youtube: https://mtips5s.com

Twitter(X): @takagiks99

Instagram: @khuongkara

Threads: @khuongkara

Google Maps: @khuongkara

#Base Code #Souce Code

Bộ công cụ My Self: @tools.mtips5s.com

Github: @github

Npm: @npm

Docker: @docker

Chúc các bạn thành công!