Update app.py

app.py

@@ -22,7 +22,7 @@ def init_db():
         password TEXT,
         role TEXT
     )''')
-    
+
     conn.execute('''CREATE TABLE IF NOT EXISTS complaints (
         id INTEGER PRIMARY KEY AUTOINCREMENT,
         complaint_id TEXT UNIQUE,
@@ -58,7 +58,7 @@ def login_page():
         conn = get_db_connection()
         user = conn.execute("SELECT * FROM users WHERE username = ?", (username,)).fetchone()
         conn.close()
-        
+
         if user and bcrypt.verify(password, user["password"]):
             st.session_state.auth = {
                 "is_logged_in": True,
@@ -70,69 +70,63 @@ def login_page():
             st.error("❌ كلمة المرور غير صحيحة")
         else:
             st.warning("❌ اسم المستخدم غير موجود")
+
+# صفحة مستقبل الشكاوى
 def receiver_page():
     st.title("📬 إدارة الشكاوى")
-    
+
     conn = get_db_connection()
     try:
-        # حساب عدد الشكاوى المعلقة
         pending_count = conn.execute(
             "SELECT COUNT(*) FROM complaints WHERE status = 'Pending'"
         ).fetchone()[0]
-        
+
         if pending_count > 0:
             st.warning(f"🚨 يوجد {pending_count} شكوى جديدة لم يتم التعامل معها!")
-        
-        # جلب جميع الشكاوى وتحويلها إلى قواميس
+
         complaints = conn.execute(
             "SELECT * FROM complaints ORDER BY id DESC"
         ).fetchall()
-        
-        # تحويل كل صف إلى قاموس قابل للتخزين
+
         complaints_list = [
             {
                 "complaint_id": row["complaint_id"],
                 "username": row["username"],
                 "complaint_text": row["complaint_text"],
                 "status": row["status"],
-                "response": row["response"] or "",  # ضمان عدم وجود None
+                "response": row["response"] or "",
                 "timestamp": row["timestamp"]
             }
             for row in complaints
         ]
-        
+
         if not complaints_list:
             st.info("لا توجد شكاوى حالياً.")
         else:
             st.subheader("📋 جميع الشكاوى")
-            
-            # عرض قائمة اختيار الشكاوى
+
             selected_complaint = st.selectbox(
                 "اختر شكوى للتعامل معها",
                 complaints_list,
                 format_func=lambda x: f"{x['complaint_id']} - {x['username']}"
             )
-            
-            # عرض تفاصيل الشكوى المحددة
+
             st.subheader(f"📨 معرف الشكوى: {selected_complaint['complaint_id']}")
             st.write(f"👤 مقدم الشكوى: {selected_complaint['username']}")
             st.write(f"📝 نص الشكوى: {selected_complaint['complaint_text']}")
             st.write(f"📅 وقت الإرسال: {selected_complaint['timestamp']}")
-            
-            # تحديث حالة الشكوى
+
             new_status = st.selectbox(
                 "🔄 تحديث الحالة",
                 ["Pending", "In Progress", "Resolved"],
                 index=["Pending", "In Progress", "Resolved"].index(selected_complaint["status"])
             )
-            
-            # حقل الرد على الشكوى
+
             new_response = st.text_area(
                 "💬 الرد على الشكوى",
                 value=selected_complaint["response"]
             )
-            
-            # زر حفظ التعديلات
+
             if st.button("💾 حفظ التعديلات"):
                 try:
                     conn.execute(
@@ -141,103 +135,13 @@ def receiver_page():
                     )
                     conn.commit()
                     st.success("✅ تم حفظ التعديلات بنجاح")
-                    st.rerun()  # إعادة تحميل الصفحة لتحديث البيانات
+                    st.rerun()
                 except sqlite3.Error as e:
                     st.error(f"❌ حدث خطأ أثناء الحفظ: {str(e)}")
-                    
     except sqlite3.Error as e:
         st.error(f"❌ حدث خطأ في قاعدة البيانات: {str(e)}")
     finally:
-        conn.close()  # إغلاق الاتصال في جميع الحالات
-    # عرض الشكاوى السابقة
-    st.subheader("📋 الشكاوى السابقة")
-    conn = get_db_connection()
-    complaints = conn.execute(
-        "SELECT * FROM complaints WHERE username = ? ORDER BY id DESC",
-        (st.session_state.auth["username"],)
-    ).fetchall()
-    conn.close()
-
-    for complaint in complaints:
-        with st.expander(f"📨 {complaint['complaint_id']} | الحالة: {complaint['status']}"):
-            st.write(f"📅 تم الإرسال في: {complaint['timestamp']}")
-            st.write(f"📄 الشكوى: {complaint['complaint_text']}")
-
-            if complaint["status"].lower() == "pending":
-                new_text = st.text_area(
-                    "📝 تعديل الشكوى",
-                    value=complaint["complaint_text"],
-                    key=f"edit_{complaint['complaint_id']}"
-                )
-                if st.button("💾 حفظ التعديل", key=f"save_{complaint['complaint_id']}"):
-                    if new_text.strip():
-                        conn = get_db_connection()
-                        conn.execute(
-                            "UPDATE complaints SET complaint_text = ? WHERE complaint_id = ?",
-                            (new_text.strip(), complaint["complaint_id"])
-                        )
-                        conn.commit()
-                        conn.close()
-                        st.success("✅ تم تعديل الشكوى")
-                        st.rerun()
-                    else:
-                        st.warning("⚠️ لا يمكن حفظ شكوى فارغة")
-            elif complaint["response"]:
-                st.success(f"💬 الرد: {complaint['response']}")
-
-# صفحة مستقبل الشكاوى
-def receiver_page():
-    st.title("📬 إدارة الشكاوى")
-    
-    conn = get_db_connection()
-    pending_count = conn.execute(
-        "SELECT COUNT(*) FROM complaints WHERE status = 'Pending'"
-    ).fetchone()[0]
-    
-    if pending_count > 0:
-        st.warning(f"🚨 يوجد {pending_count} شكوى جديدة لم يتم التعامل معها!")
-    
-    complaints = conn.execute(
-        "SELECT * FROM complaints ORDER BY id DESC"
-    ).fetchall()
-    conn.close()
-
-    if not complaints:
-        st.info("لا توجد شكاوى حالياً.")
-    else:
-        st.subheader("📋 جميع الشكاوى")
-        selected_complaint = st.selectbox(
-            "اختر شكوى للتعامل معها",
-            complaints,
-            format_func=lambda x: f"{x['complaint_id']} - {x['username']}"
-        )
-
-        st.subheader(f"📨 معرف الشكوى: {selected_complaint['complaint_id']}")
-        st.write(f"👤 مقدم الشكوى: {selected_complaint['username']}")
-        st.write(f"📝 الشكوى: {selected_complaint['complaint_text']}")
-        st.write(f"📅 الوقت: {selected_complaint['timestamp']}")
-
-        new_status = st.selectbox(
-            "🔄 تحديث الحالة",
-            ["Pending", "In Progress", "Resolved"],
-            index=["Pending", "In Progress", "Resolved"].index(selected_complaint["status"])
-        )
-        
-        new_response = st.text_area(
-            "💬 الرد على الشكوى",
-            value=selected_complaint["response"] or ""
-        )
-
-        if st.button("💾 حفظ التعديلات"):
-            conn = get_db_connection()
-            conn.execute(
-                "UPDATE complaints SET status = ?, response = ? WHERE complaint_id = ?",
-                (new_status, new_response.strip(), selected_complaint["complaint_id"])
-            )
-            conn.commit()
-            conn.close()
-            st.success("✅ تم حفظ التعديلات")
-            st.rerun()
+        conn.close()
 
 # الواجهة الرئيسية
 def main():
@@ -245,7 +149,7 @@ def main():
         login_page()
     else:
         if st.session_state.auth["role"] == "sender":
-            sender_page()
+            st.warning("🛠️ صفحة المرسل لم تُنفذ بعد.")
         else:
             receiver_page()
 
@@ -258,7 +162,6 @@ def main():
             }
             st.rerun()
 
-    # زر تحميل قاعدة البيانات
     if os.path.exists("complaints_system.db"):
         with open("complaints_system.db", "rb") as db_file:
             st.download_button(
@@ -269,4 +172,4 @@ def main():
             )
 
 if __name__ == "__main__":
-    main()
+    main()