Update consume_method.py
Browse files- consume_method.py +43 -38
consume_method.py
CHANGED
|
@@ -2,41 +2,46 @@ from flask import jsonify
|
|
| 2 |
from database import get_db
|
| 3 |
|
| 4 |
def consume_user(udid):
|
| 5 |
-
|
| 6 |
-
|
| 7 |
-
|
| 8 |
-
|
| 9 |
-
|
| 10 |
-
|
| 11 |
-
|
| 12 |
-
|
| 13 |
-
|
| 14 |
-
|
| 15 |
-
|
| 16 |
-
|
| 17 |
-
|
| 18 |
-
|
| 19 |
-
|
| 20 |
-
|
| 21 |
-
|
| 22 |
-
|
| 23 |
-
|
| 24 |
-
|
| 25 |
-
|
| 26 |
-
|
| 27 |
-
|
| 28 |
-
(
|
| 29 |
-
|
| 30 |
-
|
| 31 |
-
|
| 32 |
-
|
| 33 |
-
|
| 34 |
-
|
| 35 |
-
(
|
| 36 |
-
|
| 37 |
-
|
| 38 |
-
|
| 39 |
-
|
| 40 |
-
|
| 41 |
-
|
| 42 |
-
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| 2 |
from database import get_db
|
| 3 |
|
| 4 |
def consume_user(udid):
|
| 5 |
+
try:
|
| 6 |
+
db = get_db()
|
| 7 |
+
user = db.execute(
|
| 8 |
+
'SELECT * FROM users WHERE udid = ?',
|
| 9 |
+
(udid,)
|
| 10 |
+
).fetchone()
|
| 11 |
+
|
| 12 |
+
if not user:
|
| 13 |
+
return jsonify({
|
| 14 |
+
"success": False,
|
| 15 |
+
"error": "Kullanıcı bulunamadı"
|
| 16 |
+
}), 404
|
| 17 |
+
|
| 18 |
+
if user['usage_limit'] <= 0:
|
| 19 |
+
return jsonify({
|
| 20 |
+
"success": False,
|
| 21 |
+
"error": "Kullanım hakkınız kalmadı"
|
| 22 |
+
}), 403
|
| 23 |
+
|
| 24 |
+
db.execute(
|
| 25 |
+
'UPDATE users SET usage_limit = usage_limit - 1 WHERE udid = ?',
|
| 26 |
+
(udid,)
|
| 27 |
+
)
|
| 28 |
+
db.commit()
|
| 29 |
+
|
| 30 |
+
updated_user = db.execute(
|
| 31 |
+
'SELECT * FROM users WHERE udid = ?',
|
| 32 |
+
(udid,)
|
| 33 |
+
).fetchone()
|
| 34 |
+
|
| 35 |
+
return jsonify({
|
| 36 |
+
"success": True,
|
| 37 |
+
"data": {
|
| 38 |
+
"user": dict(updated_user),
|
| 39 |
+
"remaining_usage": updated_user['usage_limit']
|
| 40 |
+
}
|
| 41 |
+
})
|
| 42 |
+
|
| 43 |
+
except Exception as e:
|
| 44 |
+
return jsonify({
|
| 45 |
+
"success": False,
|
| 46 |
+
"error": str(e)
|
| 47 |
+
}), 500
|