Skip to content
Merged
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
34 changes: 27 additions & 7 deletions handler.py
Original file line number Diff line number Diff line change
Expand Up @@ -113,14 +113,34 @@ def menus_transaction(crawled_meals, cursor):
db_menus = cursor.fetchall()
new_menus, deleted_menus, edited_menus = compare_menus(db_menus, crawled_meals, restaurants)

# 원본 코드
# if deleted_menus:
# deleted_menus_id = [str(menu.get("id")) for menu in deleted_menus]
# delete_menus_query = f"""
# DELETE FROM menu
# WHERE id in ({','.join(deleted_menus_id)});
# """
# cursor.execute(delete_menus_query)
# send_deleted_menus_message(deleted_menus)
#

# 축제용 수정된 코드 (prod 전용)
# 축제 기간 (5/13 ~ 5/15) 종료 후 삭제
if deleted_menus:
deleted_menus_id = [str(menu.get("id")) for menu in deleted_menus]
delete_menus_query = f"""
DELETE FROM menu
WHERE id in ({','.join(deleted_menus_id)});
"""
cursor.execute(delete_menus_query)
send_deleted_menus_message(deleted_menus)
deleted_menus_id = []
for menu in deleted_menus:
restaurant_id = menu.get("restaurant_id")
if restaurant_id >= 235 and restaurant_id <= 249:
continue
deleted_menus_id.append(str(menu.get("id")))

if deleted_menus_id:
delete_menus_query = f"""
DELETE FROM menu
WHERE id in ({','.join(deleted_menus_id)});
"""
cursor.execute(delete_menus_query)
send_deleted_menus_message(deleted_menus)

insert_menus_query = """
INSERT INTO menu(restaurant_id, code, date, type, name_kr, price, etc)
Expand Down
Loading