API_GET_DONE
Some checks failed
K8S Fission Deployment / Deployment fission functions (push) Failing after 13s

This commit is contained in:
QuangMinh_123
2025-12-10 10:36:46 +00:00
parent 24e4db954a
commit ec3b3303f6
2 changed files with 20 additions and 3 deletions

View File

@@ -48,7 +48,7 @@ def make_insert_request():
if crud.exists_phone(phone_number, user_id): if crud.exists_phone(phone_number, user_id):
return jsonify({"error": "Phone is exists"}), 404 return jsonify({"error": "Phone is exists"}), 404
response, status = crud.create_phone(user_id, data) response, status, headers = crud.create_phone(user_id, data)
return jsonify(response) return jsonify(response)
except Exception as e: except Exception as e:
@@ -67,6 +67,17 @@ def make_get_request():
print(paging) print(paging)
response = crud.filter_phone(user_id, paging) response = crud.filter_phone(user_id, paging)
# Kiểm tra xem response có dữ liệu hay không
if not response[0]: # Nếu không có dữ liệu
return jsonify({"message": "No phone numbers found"}), 404, CORS_HEADERS
return jsonify({
"data": response[0], # Dữ liệu (danh sách các số điện thoại)
"status": response[1], # Mã trạng thái HTTP (200)
"headers": response[2] # Headers CORS
}), response[1], response[2]
return jsonify(response), 200, CORS_HEADERS return jsonify(response), 200, CORS_HEADERS
except Exception as e: except Exception as e:
return jsonify({"error": str(e)}), 500 return jsonify({"error": str(e)}), 500

View File

@@ -103,6 +103,7 @@ def filter_phone(user_id: str, paging):
cursor.execute(sql, values) # Thuc Thi Cau Truy Van cursor.execute(sql, values) # Thuc Thi Cau Truy Van
phones = cursor.fetchall() phones = cursor.fetchall()
print("Fetched phones: ", phones) # In ra để kiểm tra
# Chuyển kết quả thành danh sách các đối tượng với tên trường rõ ràng # Chuyển kết quả thành danh sách các đối tượng với tên trường rõ ràng
phone_list = [] phone_list = []
for phone in phones: for phone in phones:
@@ -138,6 +139,11 @@ def delete_phone(phone_id: str, user_id: str) -> dict:
except Exception as e: except Exception as e:
return {"error": str(e)}, 500 return {"error": str(e)}, 500
finally:
if cursor:
cursor.close()
if conn:
conn.close() # Đảm bảo đóng kết nối sau khi xong
def exists_phone(user_id: str, phone_number: str = None, phone_id: str = None): def exists_phone(user_id: str, phone_number: str = None, phone_id: str = None):
@@ -145,14 +151,14 @@ def exists_phone(user_id: str, phone_number: str = None, phone_id: str = None):
conn = init_db_connection() conn = init_db_connection()
cursor = conn.cursor() cursor = conn.cursor()
if phone_number: # Nếu là `POST`, kiểm tra sự tồn tại của phone_number if phone_number: # Nếu là `POST`, kiểm tra sự tồn tại của phone_number => Nghia la kiem tra so
cursor.execute(""" cursor.execute("""
SELECT 1 SELECT 1
FROM ailbl_user_phone FROM ailbl_user_phone
WHERE user_id = %s AND phone_number = %s WHERE user_id = %s AND phone_number = %s
""", (user_id, phone_number)) """, (user_id, phone_number))
elif phone_id: # Nếu là `DELETE`, kiểm tra sự tồn tại của phone_id elif phone_id: # Nếu là `DELETE`, kiểm tra sự tồn tại của phone_id => Nghia la kiem tra id cua so phone do
cursor.execute(""" cursor.execute("""
SELECT 1 SELECT 1
FROM ailbl_user_phone FROM ailbl_user_phone