Update app.py

app.py

@@ -3,7 +3,7 @@ import requests
 import json
 import time
 import xml.etree.ElementTree as ET
-from datetime import datetime
+from datetime import datetime, timezone
 import pytz
 import logging
 import re
@@ -107,6 +107,15 @@ def get_time_zones():
 
     return times
 
+def build_signal_timestamps():
+    """يبني طوابع وقت الإشارة في جميع المناطق الزمنية + ISO UTC للآلة"""
+    tz_times = get_time_zones()
+    iso_utc = datetime.now(timezone.utc).isoformat()
+    return {
+        "zones": tz_times,      # human-friendly labels per city
+        "iso_utc": iso_utc      # machine-friendly
+    }
+
 def capture_charts():
     """التقاط صور المؤشرات"""
     urls = [
@@ -167,12 +176,14 @@ def build_chat_history(alert_message=None):
 
 
 بداية مهمتك هي اما انشاء صفقة او انتظار
-في حالة المستخدم حاليا في صفقة يرجى متابعتها وذكر نقاط سواء ربح خسارة او اغلاقها الخ... 
+في حالة المستخدم حاليا في صفقة يرجى متابعتها وذكر نقاط سواء ربح خسارة او اغلاقها الخ...
 
 ممنوع منعا باتا ان تنشئ صفقة أخرى مدام المستخدم في صفقة حاليا
 
 ردك سيكون عبارة عن XML لا غير وهي المفاتيح الأساسية لتحريك النظام هنا شرحها
 
+before everything you have <analysis>here take your time to analysis the images for XAUUSD 15min and 1H also the DXY be so pro person and use the SCHOOLS for trading to analysis</analysis>
+
 اولا الانتظار :
 
 <wait>تستخدم هذه في حالة ان المستخدم ينتظر منك انشاء صفقة ولاكن تحليلك يقول ان ليس الوقت المناسب ضع هنا سبب عدم وجود صفقة
@@ -226,17 +237,17 @@ if the user in trade now you need to use the alert as your weapon to know what h
 message from developer :
 
 
-we need to focus the price now where will go the price for (NOW) don't give strategy for another price up or down no no that is bad strategy and we will not get our goal 
+we need to focus the price now where will go the price for (NOW) don't give strategy for another price up or down no no that is bad strategy and we will not get our goal
 
-so what we need is analysis and predction where the price gonna go with some IFs 
+so what we need is analysis and predction where the price gonna go with some IFs
 
-most you strategy make our another model can generate PRO trade by your strategy and queck 
+most you strategy make our another model can generate PRO trade by your strategy and queck
 
 the something worest now we get is for example price now 3335
 
-your analysis say you need to buy if the price 3348 
+your analysis say you need to buy if the price 3348
 
-i don't want this shit i want you to predcion if gonna go up to take the pips from 35 to 48 i want it 
+i don't want this shit i want you to predcion if gonna go up to take the pips from 35 to 48 i want it
 
 do you understand ??
 
@@ -318,7 +329,18 @@ do you understand ??
             message_content += f"الدخول: {current_signal.get('entry', 'N/A')}\n"
             message_content += f"وقف الخسارة: {current_signal.get('stop_loss', 'N/A')}\n"
             message_content += f"الهدف: {current_signal.get('take_profit', 'N/A')}\n"
-            message_content += f"\n(  يرجى التركيز على هذه الصفقة ومراجعتها او اغلاقها، وممنوع انشاء صفقة اخرى الا اذا تعتقد سيحصل عكس التوقغات هنا يجب عليك اغلاق و انشاءاخرى)\n\nTIME NOW : {time_info}\nif the user in trade now you need to use the alert as your weapon to know what happen to the trade by use it for 10 30 50 pip like you want but so close to see what happen to the trade"
+
+            # إظهار توقيت إنشاء الصفقة للذكاء الاصطناعي
+            ts = current_signal.get("timestamps", {})
+            if ts:
+                zones = ts.get("zones", {})
+                iso_utc = ts.get("iso_utc", "N/A")
+                message_content += "أوقات إنشاء الصفقة:\n"
+                for city, t in zones.items():
+                    message_content += f"- {city}: {t}\n"
+                message_content += f"- ISO_UTC: {iso_utc}\n"
+
+            message_content += f"\n(يرجى التركيز على هذه الصفقة ومراجعتها أو إغلاقها، وممنوع إنشاء صفقة أخرى ما دام هناك صفقة مفتوحة. إذا اعتقدت أن الاتجاه سيعكس التوقعات فعليك أولاً إغلاق الصفقة الحالية ثم إنشاء صفقة جديدة. إذا لاحظت أن الصفقة أخذت وقتاً طويلاً دون تحقق الهدف، فتذكّر أن السعر قد يتحرك عكس المطلوب؛ لذلك ليس ضرورياً الإغلاق عند الهدف دائماً، ويمكنك إغلاق ا��صفقة إذا طال زمنها وكان هناك دلائل على الانعكاس، أو الانتظار لفرصة أفضل للدخول مجدداً بسعر مناسب. استعمل المنبّه كأداتك الأساسية لمتابعة الصفقة عبر تحديد مستويات قريبة جداً (10، 30، 50 نقطة) لمعرفة ما يحدث للصفقة.)\n\nالوقت الآن:\n{time_info}"
         else:
             message_content += f" you need to make the signal about SL about  10 mean 1$ okay the pips in gold 100 pip mean 10$ you need to create signals with stop lose max 5 $ and TP to the 100pip mean 10$ 20 30 and TP from 70 80 100 ...المستخدم ليس في اي صفقة حاليا\n\nTIME NOW : {time_info}"
 
@@ -391,9 +413,11 @@ def parse_ai_response(ai_response):
                 signal_data = {
                     "pair": pair_match.group(1).strip(),
                     "type": type_match.group(1).strip(),
-                    "entry": entry_match.group(1).strip(),
-                    "stop_loss": sl_match.group(1).strip(),
-                    "take_profit": tp_match.group(1).strip()
+                    "entry": pair_number(entry_match.group(1).strip()),
+                    "stop_loss": pair_number(sl_match.group(1).strip()),
+                    "take_profit": pair_number(tp_match.group(1).strip()),
+                    # NEW: add timestamps at creation time
+                    "timestamps": build_signal_timestamps()
                 }
 
                 # حفظ الإشارة
@@ -403,12 +427,20 @@ def parse_ai_response(ai_response):
                     result = db_signals.update_user_json_file(auth_token, commit_oid, new_signal)
 
                     if result["success"]:
-                        # إرسال رسالة للمستخدمين
+                        # إرسال رسالة للمستخدمين (مع الوقت)
+                        ts = signal_data["timestamps"]
+                        zones = ts.get("zones", {})
+                        iso_utc = ts.get("iso_utc", "")
+                        # compact one-line times to avoid long messages
+                        times_line = " | ".join([f"{c}: {t}" for c, t in zones.items()])
+
                         signal_message = f"🚨 إشارة جديدة XAUUSD\n\n"
                         signal_message += f"📊 النوع: {signal_data['type']}\n"
                         signal_message += f"🎯 الدخول: {signal_data['entry']}\n"
                         signal_message += f"🛑 وقف الخسارة: {signal_data['stop_loss']}\n"
-                        signal_message += f"💰 الهدف: {signal_data['take_profit']}"
+                        signal_message += f"💰 الهدف: {signal_data['take_profit']}\n"
+                        signal_message += f"🕒 الوقت: {times_line}\n"
+                        
 
                         send_result = send_message_to_api(signal_message)
                         if send_result["success"]:
@@ -503,6 +535,20 @@ def parse_ai_response(ai_response):
 
     return actions_performed
 
+def pair_number(val):
+    """Normalize numeric strings to plain numbers, keep as string but ensure clean format."""
+    # Remove any non-numeric (except dot and minus)
+    cleaned = re.sub(r'[^0-9\.\-]', '', val)
+    # Avoid empty
+    if cleaned == '' or cleaned == '-' or cleaned == '.':
+        return val.strip()
+    # Normalize to up to 3 decimals as typical for XAUUSD quotes (broker dependent)
+    try:
+        num = float(cleaned)
+        return f"{num:.2f}".rstrip('0').rstrip('.') if '.' in f"{num:.2f}" else f"{num:.2f}"
+    except:
+        return val.strip()
+
 def count_xml_tags(ai_response):
     """عد عدد كل XML tag في الرد لأغراض التسجيل"""
     counts = {
@@ -673,7 +719,7 @@ def index():
             "/test_actions": "اختبار معالجة XML tags (POST)",
             "/health": "فحص حالة النظام (GET)"
         },
-        "version": "2.0.0",
+        "version": "2.1.0",
         "execution_priority": "close_trade → signal → send_user → alert"
     })