Update app.py

app.py

@@ -1,9 +1,9 @@
-
 import streamlit as st
 import sqlite3
 from datetime import datetime
 from passlib.hash import bcrypt
 import os
+import shutil
 
 # تهيئة الصفحة
 st.set_page_config(page_title="نظام إدارة الشكاوى", layout="centered")
@@ -33,27 +33,13 @@ def init_db():
             complaint_text TEXT,
             status TEXT,
             response TEXT,
-            timestamp TEXT
+            timestamp TEXT,
+            sender_comment TEXT
         )
     """)
     conn.commit()
     conn.close()
 
-# التأكد من وجود عمود sender_comment
-def ensure_sender_comment_column():
-    conn = get_db_connection()
-    cursor = conn.cursor()
-    cursor.execute("PRAGMA table_info(complaints)")
-    columns = [col[1] for col in cursor.fetchall()]
-    if "sender_comment" not in columns:
-        cursor.execute("ALTER TABLE complaints ADD COLUMN sender_comment TEXT")
-        conn.commit()
-    conn.close()
-
-# استدعاء التهيئة
-init_db()
-ensure_sender_comment_column()
-
 # إدارة حالة الجلسة
 def init_session():
     if "auth" not in st.session_state:
@@ -148,79 +134,116 @@ def sender_page():
 
     conn.close()
 
-# صفحة مستقبل الشكاوى
+# صفحة مستقبل الشكاوى مع لوحة التحكم الإدارية المحمية
 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 "",
-                "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(
-                        "UPDATE complaints SET status = ?, response = ? WHERE complaint_id = ?",
-                        (new_status, new_response.strip(), selected_complaint["complaint_id"])
+    
+    # تبويب للاختيار بين إدارة الشكاوى والتحكم الإداري
+    tab1, tab2 = st.tabs(["إدارة الشكاوى", "لوحة التحكم الإدارية"])
+    
+    with tab1:
+        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 "",
+                    "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(
+                            "UPDATE complaints SET status = ?, response = ? WHERE complaint_id = ?",
+                            (new_status, new_response.strip(), selected_complaint["complaint_id"])
+                        )
+                        conn.commit()
+                        st.success("✅ تم حفظ التعديلات بنجاح")
+                        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()
+    
+    with tab2:
+        st.title("⚙️ لوحة التحكم الإدارية")
+        
+        # كلمة المرور الإدارية (يجب تغييرها في البيئة الإنتاجية)
+        ADMIN_DB_PASSWORD = "Admin@1234"
+        
+        # حقل لإدخال كلمة المرور الإدارية
+        admin_pass = st.text_input("أدخل كلمة المرور الإدارية:", type="password", key="admin_pass")
+        
+        if admin_pass == ADMIN_DB_PASSWORD:
+            st.success("✅ تم المصادقة بنجاح")
+            
+            if os.path.exists("complaintsBD.db"):
+                with open("complaintsBD.db", "rb") as db_file:
+                    st.download_button(
+                        label="📥 تحميل نسخة احتياطية من قاعدة البيانات",
+                        data=db_file,
+                        file_name=f"complaints_backup_{datetime.now().strftime('%Y%m%d')}.db",
+                        mime="application/octet-stream",
+                        key="db_download"
                     )
-                    conn.commit()
-                    st.success("✅ تم حفظ التعديلات بنجاح")
-                    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()
+            
+            if st.button("🔄 إنشاء نسخة احتياطية جديدة", key="create_backup"):
+                backup_name = f"backup_{datetime.now().strftime('%Y%m%d_%H%M')}.db"
+                shutil.copy2("complaintsBD.db", backup_name)
+                st.success(f"تم إنشاء النسخة الاحتياطية: {backup_name}")
+                
+        elif admin_pass:  # إذا أدخل كلمة مرور ولكنها خاطئة
+            st.error("❌ كلمة المرور الإدارية غير صحيحة")
 
 # الواجهة الرئيسية
 def main():
+    init_db()  # التأكد من وجود الجداول
+    
     if not st.session_state.auth["is_logged_in"]:
         login_page()
     else:
@@ -238,14 +261,5 @@ def main():
             }
             st.rerun()
 
-    if os.path.exists("complaintsBD.db"):
-        with open("complaintsBD.db", "rb") as db_file:
-            st.download_button(
-                label="📥 تحميل قاعدة البيانات",
-                data=db_file,
-                file_name="complaintsBD.db",
-                mime="application/octet-stream"
-            )
-
 if __name__ == "__main__":
-    main()
+    main()