Update app.py

app.py

@@ -3,14 +3,15 @@ import pandas as pd
 import os
 import sqlite3
 from datetime import datetime
-from passlib.hash import bcrypt  # ← بديل bcrypt
+from passlib.hash import bcrypt
 
 st.set_page_config(page_title="نظام إدارة الشكاوى", layout="centered")
 
-# الاتصال بقاعدة البيانات وإنشاء الجداول إذا لم تكن موجودة
+# الاتصال بقاعدة البيانات
 conn = sqlite3.connect("complaints_system (1).db", check_same_thread=False)
 c = conn.cursor()
 
+# إنشاء الجداول
 c.execute('''CREATE TABLE IF NOT EXISTS users (
     id INTEGER PRIMARY KEY AUTOINCREMENT,
     username TEXT UNIQUE,
@@ -25,18 +26,21 @@ c.execute('''CREATE TABLE IF NOT EXISTS complaints (
     complaint_text TEXT,
     status TEXT,
     response TEXT,
-    timestamp TEXT
+    timestamp TEXT,
+    user_comment TEXT
 )''')
 
 conn.commit()
 
-# تهيئة session state
+# تهيئة الجلسة
 if "is_logged_in" not in st.session_state:
     st.session_state.is_logged_in = False
 if "user_type" not in st.session_state:
     st.session_state.user_type = None
 if "username" not in st.session_state:
     st.session_state.username = ""
+if "complaint_input" not in st.session_state:
+    st.session_state.complaint_input = ""
 
 # تسجيل الدخول
 if not st.session_state.is_logged_in:
@@ -48,12 +52,10 @@ if not st.session_state.is_logged_in:
         c.execute("SELECT * FROM users WHERE username=?", (username,))
         user = c.fetchone()
         if user:
-            stored_hashed_password = user[2]
-            role = user[3]
-            if bcrypt.verify(password, stored_hashed_password):  # ✅ التحقق بكلمة السر
+            if bcrypt.verify(password, user[2]):
                 st.session_state.is_logged_in = True
                 st.session_state.username = username
-                st.session_state.user_type = "sender" if role == "sender" else "receiver"
+                st.session_state.user_type = "sender" if user[3] == "sender" else "receiver"
                 st.rerun()
             else:
                 st.error("❌ كلمة المرور غير صحيحة.")
@@ -63,7 +65,7 @@ if not st.session_state.is_logged_in:
 # مقدم الشكوى
 elif st.session_state.user_type == "sender":
     st.title("📨 إرسال شكوى جديدة")
-    complaint_text = st.text_area("📝 وصف الشكوى")
+    st.session_state.complaint_input = st.text_area("📝 وصف الشكوى", value=st.session_state.complaint_input, key="complaint_input")
 
     if st.button("📤 إرسال الشكوى"):
         c.execute("SELECT * FROM complaints WHERE username=?", (st.session_state.username,))
@@ -72,59 +74,80 @@ elif st.session_state.user_type == "sender":
         next_id = len(user_complaints) + 1
         complaint_id = f"{prefix}_{next_id:07}"
 
-
         c.execute("SELECT * FROM complaints WHERE complaint_id=?", (complaint_id,))
         if c.fetchone():
             st.warning("⚠️ تم إرسال هذه الشكوى مسبقًا بناءً على المعرف!")
-        elif complaint_text.strip() == "":
+        elif st.session_state.complaint_input.strip() == "":
             st.warning("⚠️ الرجاء إدخال نص الشكوى.")
         else:
             timestamp = datetime.now().strftime("%Y-%m-%d %H:%M:%S")
-            c.execute("INSERT INTO complaints (complaint_id, username, complaint_text, status, response, timestamp) VALUES (?, ?, ?, ?, ?, ?)",
-                      (complaint_id, st.session_state.username, complaint_text.strip(), "Pending", "", timestamp))
+            c.execute("INSERT INTO complaints (complaint_id, username, complaint_text, status, response, timestamp, user_comment) VALUES (?, ?, ?, ?, ?, ?, ?)",
+                      (complaint_id, st.session_state.username, st.session_state.complaint_input.strip(), "Pending", "", timestamp, ""))
             conn.commit()
             st.success("✅ تم تقديم الشكوى بنجاح")
+            st.session_state.complaint_input = ""  # مسح الصندوق
             st.rerun()
 
     st.subheader("📋 الشكاوى السابقة")
     c.execute("SELECT * FROM complaints WHERE username=? ORDER BY id DESC", (st.session_state.username,))
     complaints = c.fetchall()
+
     for row in complaints:
-        comp_id, username, text, status, response, timestamp = row[1], row[2], row[3], row[4], row[5], row[6]
-        with st.expander(f"📨 {comp_id} | {status}"):
-            if status.lower() == "pending" and (not response or response.strip() == ""):
+        comp_id, username, text, status, response, timestamp, user_comment = row[1:]
+        with st.expander(f"📨 {comp_id} | الحالة: {status}"):
+            st.write(f"📅 تم الإرسال في: {timestamp}")
+            st.write(f"📄 الشكوى: {text}")
+
+            if status.lower() == "pending":
                 new_text = st.text_area("📝 تعديل الشكوى", value=text, key=f"edit_{comp_id}")
                 if st.button("💾 حفظ التعديل", key=f"save_{comp_id}"):
                     c.execute("UPDATE complaints SET complaint_text=? WHERE complaint_id=?", (new_text.strip(), comp_id))
                     conn.commit()
-                    st.success("✅ تم تعديل الشكوى بنجاح")
+                    st.success("✅ تم تعديل الشكوى")
                     st.rerun()
             else:
-                st.info(f"📢 تم تحديث حالة الشكوى إلى: {status}")
-                if response and response.strip():
+                if response:
                     st.success(f"💬 الرد: {response}")
-
-# مستقبل الشكوى
+                    if not user_comment:
+                        comment = st.text_area("✏️ تعليقك على الرد", key=f"comment_{comp_id}")
+                        if st.button("📩 إرسال التعليق", key=f"send_comment_{comp_id}"):
+                            c.execute("UPDATE complaints SET user_comment=? WHERE complaint_id=?", (comment.strip(), comp_id))
+                            conn.commit()
+                            st.success("✅ تم إرسال التعليق بنجاح")
+                            st.rerun()
+                    else:
+                        st.info(f"🗣️ تعليقك السابق: {user_comment}")
+
+# مستقبل الشكوى (الـ admin أو الموظف)
 elif st.session_state.user_type == "receiver":
     st.title("📬 إدارة الشكاوى")
-    c.execute("SELECT * FROM complaints")
+
+    # تنبيه بوجود شكاوى جديدة
+    c.execute("SELECT COUNT(*) FROM complaints WHERE status = 'Pending'")
+    pending_count = c.fetchone()[0]
+    if pending_count > 0:
+        st.warning(f"🚨 يوجد {pending_count} شكوى جديدة لم يتم التعامل معها!")
+
+    c.execute("SELECT * FROM complaints ORDER BY id DESC")
     complaints = c.fetchall()
 
     if not complaints:
-        st.info("لا توجد شكاوى حالياً للتعامل معها.")
+        st.info("لا توجد شكاوى حالياً.")
     else:
         st.subheader("📋 جميع الشكاوى")
         options = {f"{row[1]} - {row[2]}": row for row in complaints}
         selected = st.selectbox("اختر شكوى للتعامل معها", list(options.keys()))
         selected_row = options[selected]
 
-        st.write(f"### ✉️ شكوى: {selected_row[1]}")
         st.subheader(f"📨 معرف الشكوى: {selected_row[1]}")
-        st.write(f"**مقدم الشكوى:** {selected_row[2]}")
-        st.write(f"**الوصف:** {selected_row[3]}")
+        st.write(f"👤 مقدم الشكوى: {selected_row[2]}")
+        st.write(f"📝 الشكوى: {selected_row[3]}")
+        st.write(f"📅 الوقت: {selected_row[6]}")
+        if selected_row[7]:
+            st.info(f"🗣️ تعليق المستخدم على الرد: {selected_row[7]}")
 
         new_status = st.selectbox("🔄 تحديث الحالة", ["Pending", "In Progress", "Resolved"], index=["Pending", "In Progress", "Resolved"].index(selected_row[4]))
-        new_response = st.text_area("📝 الرد على الشكوى", value=selected_row[5] or "")
+        new_response = st.text_area("💬 الرد على الشكوى", value=selected_row[5] or "")
 
         if st.button("💾 حفظ التعديلات"):
             c.execute("UPDATE complaints SET status=?, response=? WHERE complaint_id=?", (new_status, new_response.strip(), selected_row[1]))
@@ -132,7 +155,7 @@ elif st.session_state.user_type == "receiver":
             st.success("✅ تم حفظ التعديلات")
             st.rerun()
 
-# ⛔ زر تسجيل الخروج يظهر دائمًا لأي مستخدم مسجل
+# زر تسجيل الخروج دائم
 if st.session_state.get("is_logged_in"):
     st.markdown("---")
     if st.button("🚪 تسجيل الخروج"):
@@ -141,9 +164,9 @@ if st.session_state.get("is_logged_in"):
         st.session_state.username = ""
         st.rerun()
 
-# 📥 زر لتحميل قاعدة البيانات (لـ admin أو أي مستخدم)
-if os.path.exists("complaints_system.db"):
-    with open("complaints_system.db", "rb") as db_file:
+# زر لتحميل قاعدة البيانات
+if os.path.exists("complaints_system (1).db"):
+    with open("complaints_system (1).db", "rb") as db_file:
         st.download_button(
             label="📥 تحميل complaints_system.db",
             data=db_file,
@@ -151,4 +174,4 @@ if os.path.exists("complaints_system.db"):
             mime="application/octet-stream"
         )
 else:
-    st.warning("⚠️ ملف قاعدة البيانات غير موجود في هذا المسار.")
+    st.warning("⚠️ ملف قاعدة البيانات غير موجود.")