593 lines
23 KiB
Python
593 lines
23 KiB
Python
#!/usr/bin/env python3
|
||
# -*- coding: utf-8 -*-
|
||
"""
|
||
通用 API 路由模組
|
||
包含：任務觸發、通知、歷史查詢、價格變動等 API
|
||
"""
|
||
|
||
import os
|
||
import threading
|
||
import importlib
|
||
from datetime import datetime, timezone, timedelta
|
||
import re
|
||
from flask import Blueprint, request, jsonify
|
||
from sqlalchemy import func, desc, text
|
||
from urllib.parse import parse_qs, urlparse
|
||
|
||
from auth import login_required
|
||
from config import BASE_DIR
|
||
from database.manager import DatabaseManager
|
||
from database.models import Product, PriceRecord
|
||
from database.edm_models import PromoProduct
|
||
from services.logger_manager import SystemLogger
|
||
from utils.momo_url_utils import build_momo_product_url, normalize_momo_product_url
|
||
from utils.momo_url_utils import is_probable_momo_icode
|
||
|
||
# 時區設定
|
||
TAIPEI_TZ = timezone(timedelta(hours=8))
|
||
|
||
# Logger
|
||
sys_log = SystemLogger("APIRoutes").get_logger()
|
||
|
||
# Blueprint 定義
|
||
api_bp = Blueprint('api', __name__)
|
||
|
||
|
||
# ==========================================
|
||
# 任務觸發 API
|
||
# ==========================================
|
||
|
||
@api_bp.route('/api/run_task', methods=['POST'])
|
||
@login_required
|
||
def trigger_task():
|
||
"""API: 手動觸發 MOMO 爬蟲任務"""
|
||
try:
|
||
client_ip = request.remote_addr
|
||
sys_log.info(f"[Web] [Task] 接收到手動執行請求 | IP: {client_ip}")
|
||
|
||
# 使用獨立的 task_runner 服務，避免循環依賴
|
||
from services.task_runner import run_momo_task_with_notification
|
||
run_momo_task_with_notification()
|
||
|
||
return jsonify({"status": "success", "message": "爬蟲任務已在背景啟動"})
|
||
except Exception as e:
|
||
sys_log.error(f"[Web] [Task] 手動觸發任務失敗 | Error: {e}")
|
||
return jsonify({"status": "error", "message": str(e)}), 500
|
||
|
||
|
||
@api_bp.route('/api/run_edm_task', methods=['POST'])
|
||
@login_required
|
||
def trigger_edm_task():
|
||
"""API: 手動觸發 EDM 爬蟲任務"""
|
||
try:
|
||
target_lpn = "O1K5FBOqsvN" # 預設活動代碼
|
||
sys_log.info(f"[Web] [Task] 接收到手動 EDM 執行請求 | LPN: {target_lpn}")
|
||
|
||
# 強制重載 scheduler 模組
|
||
import scheduler
|
||
importlib.reload(scheduler)
|
||
|
||
# 使用執行緒啟動，避免卡住 Web Server
|
||
task_thread = threading.Thread(target=scheduler.run_edm_task, args=(target_lpn,))
|
||
task_thread.daemon = True
|
||
task_thread.start()
|
||
|
||
return jsonify({"status": "success", "message": f"EDM 爬蟲任務 (LPN: {target_lpn}) 已在背景啟動，請稍後刷新頁面查看結果"})
|
||
except Exception as e:
|
||
sys_log.error(f"[Web] [Task] 手動觸發 EDM 任務失敗 | Error: {e}")
|
||
return jsonify({"status": "error", "message": str(e)}), 500
|
||
|
||
|
||
@api_bp.route('/api/run_festival_task', methods=['POST'])
|
||
@login_required
|
||
def trigger_festival_task():
|
||
"""API: 手動觸發 1.1 狂歡購物節爬蟲任務"""
|
||
try:
|
||
target_lpn = "O7ylWfihYUM"
|
||
sys_log.info(f"[Web] [Task] 接收到手動 Festival 執行請求 | LPN: {target_lpn}")
|
||
|
||
# 延遲導入
|
||
import scheduler
|
||
importlib.reload(scheduler)
|
||
|
||
# 使用執行緒啟動，避免卡住 Web Server
|
||
task_thread = threading.Thread(target=scheduler.run_festival_task, args=(target_lpn,))
|
||
task_thread.daemon = True
|
||
task_thread.start()
|
||
|
||
return jsonify({"status": "success", "message": f"Festival 爬蟲任務 (LPN: {target_lpn}) 已在背景啟動，請稍後刷新頁面查看結果"})
|
||
except Exception as e:
|
||
sys_log.error(f"[Web] [Task] 手動觸發 Festival 任務失敗 | Error: {e}")
|
||
return jsonify({"status": "error", "message": str(e)}), 500
|
||
|
||
|
||
@api_bp.route('/api/run_promo_event_task', methods=['POST'])
|
||
@login_required
|
||
def trigger_promo_event_task():
|
||
"""API: 手動觸發促銷活動爬蟲任務（支援母親節、520、勞動節等）"""
|
||
try:
|
||
data = request.get_json()
|
||
page_type = data.get('page_type', '')
|
||
lpn_code = data.get('lpn_code', '')
|
||
activity_name = data.get('activity_name', '促銷活動')
|
||
|
||
if not page_type or not lpn_code:
|
||
return jsonify({"status": "error", "message": "缺少必要參數: page_type 和 lpn_code"}), 400
|
||
|
||
sys_log.info(f"[Web] [Task] 接收到手動促銷活動執行請求 | Type: {page_type} | LPN: {lpn_code} | Name: {activity_name}")
|
||
|
||
# 延遲導入
|
||
import scheduler
|
||
importlib.reload(scheduler)
|
||
|
||
# 使用執行緒啟動，避免卡住 Web Server
|
||
task_thread = threading.Thread(target=scheduler.run_promo_event_task, args=(lpn_code, page_type, activity_name))
|
||
task_thread.daemon = True
|
||
task_thread.start()
|
||
|
||
return jsonify({"status": "success", "message": f"{activity_name} 爬蟲任務 (LPN: {lpn_code}) 已在背景啟動，請稍後刷新頁面查看結果"})
|
||
except Exception as e:
|
||
sys_log.error(f"[Web] [Task] 手動觸發促銷活動任務失敗 | Error: {e}")
|
||
return jsonify({"status": "error", "message": str(e)}), 500
|
||
|
||
|
||
# ==========================================
|
||
# 通知 API
|
||
# ==========================================
|
||
|
||
@api_bp.route('/api/trigger_momo_notification', methods=['POST'])
|
||
@login_required
|
||
def trigger_momo_notification():
|
||
"""API: 手動觸發商品看板通知"""
|
||
try:
|
||
# 強制重載通知模組
|
||
import scheduler
|
||
import services.notification_manager
|
||
importlib.reload(scheduler)
|
||
importlib.reload(services.notification_manager)
|
||
from services.notification_manager import NotificationManager
|
||
|
||
# 從 dashboard_routes 導入 get_dashboard_stats，避免循環依賴
|
||
from routes.dashboard_routes import get_dashboard_stats
|
||
|
||
# 1. 取得統計數據
|
||
stats = get_dashboard_stats()
|
||
|
||
# 2. 截取儀表板畫面
|
||
dashboard_url = "http://127.0.0.1/"
|
||
screenshot_path = scheduler.capture_page_screenshot(dashboard_url, "momo_dashboard")
|
||
|
||
# 3. 發送通知
|
||
notifier = NotificationManager()
|
||
sys_log.info(f"[Web] [Notification] 手動觸發 MOMO 通知")
|
||
notifier.send_momo_report(stats, screenshot_path)
|
||
|
||
return jsonify({"status": "success", "message": "已發送商品看板通知"})
|
||
except Exception as e:
|
||
sys_log.error(f"[Web] [Notification] 手動通知失敗 | Error: {e}")
|
||
return jsonify({"status": "error", "message": str(e)}), 500
|
||
|
||
|
||
@api_bp.route('/api/trigger_edm_notification', methods=['POST'])
|
||
@login_required
|
||
def trigger_edm_notification():
|
||
"""API: 手動觸發 EDM 比價通知 (不重爬，僅重發)"""
|
||
try:
|
||
# 強制重新載入設定與通知模組
|
||
import config
|
||
import services.notification_manager
|
||
import services.edm_notifier
|
||
importlib.reload(config)
|
||
importlib.reload(services.notification_manager)
|
||
importlib.reload(services.edm_notifier)
|
||
|
||
db = DatabaseManager()
|
||
session = db.get_session()
|
||
try:
|
||
# 找出最新的 batch_id
|
||
latest_batch_tuple = session.query(PromoProduct.batch_id).filter(
|
||
PromoProduct.page_type == 'edm'
|
||
).order_by(desc(PromoProduct.crawled_at)).first()
|
||
|
||
if not latest_batch_tuple:
|
||
return jsonify({"status": "warning", "message": "目前無 EDM 商品資料，請先執行爬蟲"}), 400
|
||
|
||
latest_batch_id = latest_batch_tuple[0]
|
||
|
||
# 取得最新批次的所有異動商品
|
||
products = session.query(PromoProduct).filter(
|
||
PromoProduct.batch_id == latest_batch_id
|
||
).all()
|
||
|
||
if not products:
|
||
return jsonify({"status": "info", "message": "最新一輪掃描中無任何商品異動"}), 200
|
||
|
||
# 嘗試尋找對應的截圖檔案
|
||
screenshot_path = None
|
||
try:
|
||
filename = f"edm_{latest_batch_id}.png"
|
||
potential_path = os.path.join(BASE_DIR, 'web/static/screenshots', filename)
|
||
if os.path.exists(potential_path):
|
||
screenshot_path = potential_path
|
||
except Exception:
|
||
pass
|
||
|
||
from services.edm_notifier import EdmNotifier
|
||
notifier = EdmNotifier()
|
||
sys_log.info(f"[Web] [Notification] 手動觸發 EDM 通知 | Count: {len(products)} | BatchID: {latest_batch_id}")
|
||
notifier.send_edm_report(products, screenshot_path)
|
||
|
||
return jsonify({"status": "success", "message": f"已針對最新批次的 {len(products)} 筆商品異動發送通知"})
|
||
finally:
|
||
session.close()
|
||
except Exception as e:
|
||
sys_log.error(f"[Web] [Notification] 手動通知失敗 | Error: {e}")
|
||
return jsonify({"status": "error", "message": str(e)}), 500
|
||
|
||
|
||
@api_bp.route('/api/test_notification', methods=['POST'])
|
||
@login_required
|
||
def test_notification():
|
||
"""API: 測試訊息通知功能"""
|
||
try:
|
||
from services.notification_manager import NotificationManager
|
||
import config
|
||
import requests
|
||
notifier = NotificationManager()
|
||
|
||
sys_log.info("[Web] [Notification] 執行手動通知發送測試 (Line/Telegram/Email)...")
|
||
|
||
token = getattr(config, 'LINE_CHANNEL_ACCESS_TOKEN', None)
|
||
target_id = getattr(config, 'LINE_GROUP_ID', None)
|
||
|
||
if token and target_id:
|
||
sys_log.info(f"[Web] [Notification] 偵測到 Channel Token: {token[:4]}...{token[-4:]}")
|
||
sys_log.info(f"[Web] [Notification] 目標 ID: {target_id}")
|
||
|
||
# 嘗試直接發送請求
|
||
try:
|
||
headers = {
|
||
"Authorization": f"Bearer {token}",
|
||
"Content-Type": "application/json"
|
||
}
|
||
payload = {
|
||
"to": target_id,
|
||
"messages": [
|
||
{
|
||
"type": "text",
|
||
"text": "這是系統診斷測試訊息 (Messaging API)\n\n連線測試成功！"
|
||
}
|
||
]
|
||
}
|
||
|
||
sys_log.info("[Web] [Notification] 正在嘗試連線至 Line Messaging API (push)...")
|
||
resp = requests.post("https://api.line.me/v2/bot/message/push", headers=headers, json=payload, timeout=10)
|
||
|
||
sys_log.info(f"[Web] [Notification] Line API 回應 | Code: {resp.status_code}")
|
||
sys_log.info(f"[Web] [Notification] Line API 內容 | Body: {resp.text}")
|
||
|
||
if resp.status_code != 200:
|
||
return jsonify({"status": "error", "message": f"Line API 拒絕連線: {resp.status_code} - {resp.text}"}), 400
|
||
except Exception as req_err:
|
||
sys_log.error(f"[Web] [Notification] 直接連線測試發生異常 | Error: {req_err}")
|
||
return jsonify({"status": "error", "message": f"連線異常: {req_err}"}), 500
|
||
else:
|
||
sys_log.warning("[Web] [Notification] 無法偵測到 Messaging API 設定 (Token 或 Group ID 缺失)")
|
||
return jsonify({"status": "error", "message": "設定檔缺少 LINE_CHANNEL_ACCESS_TOKEN 或 LINE_GROUP_ID"}), 400
|
||
|
||
# 呼叫真實的日報發送邏輯
|
||
notifier.send_daily_report()
|
||
|
||
return jsonify({"status": "success", "message": "當日異動通知已發送 (Line/Telegram/Email)"})
|
||
except ImportError:
|
||
return jsonify({"status": "error", "message": "找不到 NotificationManager 模組"}), 500
|
||
except Exception as e:
|
||
sys_log.error(f"[Web] [Notification] 測試通知失敗 | Error: {e}")
|
||
return jsonify({"status": "error", "message": f"發送失敗: {str(e)}"}), 500
|
||
|
||
|
||
# ==========================================
|
||
# 歷史查詢 API
|
||
# ==========================================
|
||
|
||
PRICE_HISTORY_RANGES = {
|
||
'week': {'days': 7, 'label': '近 7 天'},
|
||
'month': {'days': 30, 'label': '近 30 天'},
|
||
'quarter': {'days': 90, 'label': '近 90 天'},
|
||
'year': {'days': 365, 'label': '近 365 天'},
|
||
}
|
||
|
||
|
||
def _resolve_history_range():
|
||
range_key = request.args.get('range', 'month')
|
||
if range_key not in PRICE_HISTORY_RANGES:
|
||
range_key = 'month'
|
||
return range_key, PRICE_HISTORY_RANGES[range_key]
|
||
|
||
|
||
def _build_price_history_payload(session, product):
|
||
range_key, range_meta = _resolve_history_range()
|
||
start_date = datetime.now(TAIPEI_TZ) - timedelta(days=range_meta['days'])
|
||
|
||
records = session.query(PriceRecord).filter(
|
||
PriceRecord.product_id == product.id,
|
||
PriceRecord.timestamp >= start_date
|
||
).order_by(PriceRecord.timestamp).all()
|
||
|
||
data = [{
|
||
't': r.timestamp.strftime('%Y-%m-%d %H:%M'),
|
||
'p': r.price
|
||
} for r in records]
|
||
|
||
competitor_data = []
|
||
competitor_latest = None
|
||
try:
|
||
competitor_rows = session.execute(text("""
|
||
SELECT
|
||
price,
|
||
momo_price,
|
||
competitor_product_id,
|
||
competitor_product_name,
|
||
match_score,
|
||
crawled_at
|
||
FROM competitor_price_history
|
||
WHERE sku = :sku
|
||
AND source = 'pchome'
|
||
AND crawled_at >= :start_date
|
||
AND COALESCE(match_score, 0) >= 0.76
|
||
AND COALESCE(tags, '[]'::jsonb) ? 'identity_v2'
|
||
ORDER BY crawled_at
|
||
"""), {
|
||
"sku": str(product.i_code),
|
||
"start_date": start_date.replace(tzinfo=None),
|
||
}).mappings().all()
|
||
competitor_data = [{
|
||
't': r['crawled_at'].strftime('%Y-%m-%d %H:%M'),
|
||
'p': float(r['price']),
|
||
'momo_price': float(r['momo_price']) if r['momo_price'] is not None else None,
|
||
'product_id': r['competitor_product_id'],
|
||
'product_name': r['competitor_product_name'],
|
||
'match_score': float(r['match_score']) if r['match_score'] is not None else None,
|
||
} for r in competitor_rows]
|
||
if competitor_data:
|
||
competitor_latest = competitor_data[-1]
|
||
except Exception as exc:
|
||
sys_log.warning(
|
||
f"[Web] [History] PChome 競品歷史資料讀取略過 | ICode: {product.i_code} | Error: {exc}"
|
||
)
|
||
|
||
return {
|
||
'range': range_key,
|
||
'range_label': range_meta['label'],
|
||
'product': {
|
||
'id': product.id,
|
||
'i_code': product.i_code,
|
||
'name': product.name,
|
||
},
|
||
'data': data,
|
||
'series': {
|
||
'momo': data,
|
||
'pchome': competitor_data,
|
||
},
|
||
'competitor': competitor_latest,
|
||
}
|
||
|
||
|
||
@api_bp.route('/api/history/<int:product_id>')
|
||
@login_required
|
||
def get_price_history(product_id):
|
||
"""API: 取得商品價格歷史，支援 week/month/quarter/year 區間"""
|
||
db = DatabaseManager()
|
||
session = db.get_session()
|
||
try:
|
||
product = session.query(Product).filter(Product.id == product_id).first()
|
||
if not product:
|
||
return jsonify({'data': [], 'message': '找不到商品'}), 404
|
||
|
||
payload = _build_price_history_payload(session, product)
|
||
if request.args.get('format') == 'v2':
|
||
return jsonify(payload)
|
||
return jsonify(payload['data'])
|
||
except Exception as e:
|
||
sys_log.error(f"[Web] [History] 獲取歷史價格失敗 | ProductID: {product_id} | Error: {e}")
|
||
return jsonify([]), 500
|
||
finally:
|
||
session.close()
|
||
|
||
|
||
@api_bp.route('/api/history/i-code/<path:i_code>')
|
||
@login_required
|
||
def get_price_history_by_i_code(i_code):
|
||
"""API: 以 MOMO 商品 i_code 取得主商品價格歷史"""
|
||
db = DatabaseManager()
|
||
session = db.get_session()
|
||
try:
|
||
product = session.query(Product).filter(Product.i_code == str(i_code)).first()
|
||
if not product:
|
||
return jsonify({'data': [], 'message': '找不到商品'})
|
||
|
||
return jsonify(_build_price_history_payload(session, product))
|
||
except Exception as e:
|
||
sys_log.error(f"[Web] [History] 以 i_code 獲取歷史價格失敗 | ICode: {i_code} | Error: {e}")
|
||
return jsonify({'data': []}), 500
|
||
finally:
|
||
session.close()
|
||
|
||
|
||
@api_bp.route('/api/price_change_details')
|
||
@login_required
|
||
def get_price_change_details():
|
||
"""API: 取得價格變動商品明細 (供彈窗使用)"""
|
||
filter_type = request.args.get('type', '')
|
||
# 以下參數保留以供未來擴展
|
||
# filter_category = request.args.get('category', '')
|
||
# filter_product_id = request.args.get('product_id', '')
|
||
|
||
db = DatabaseManager()
|
||
session = db.get_session()
|
||
try:
|
||
def _safe_product_url(product):
|
||
return normalize_momo_product_url(product.url, product.i_code) or build_momo_product_url(product.i_code)
|
||
|
||
# 取得今日起始時間
|
||
now_taipei = datetime.now(TAIPEI_TZ)
|
||
today_start = now_taipei.replace(hour=0, minute=0, second=0, microsecond=0, tzinfo=None)
|
||
|
||
# 基礎查詢：取得所有商品的最新記錄
|
||
latest_records_subq = session.query(
|
||
func.max(PriceRecord.id).label('max_id')
|
||
).group_by(PriceRecord.product_id).subquery()
|
||
|
||
query = session.query(PriceRecord, Product).join(
|
||
latest_records_subq,
|
||
PriceRecord.id == latest_records_subq.c.max_id
|
||
).join(Product, PriceRecord.product_id == Product.id)
|
||
|
||
# 一次性查詢所有商品的「今日之前最後價格」
|
||
product_ids = [r[0] for r in session.query(PriceRecord.product_id).join(
|
||
latest_records_subq, PriceRecord.id == latest_records_subq.c.max_id
|
||
).all()]
|
||
|
||
yesterday_prices_subq = session.query(
|
||
PriceRecord.product_id,
|
||
func.max(PriceRecord.id).label('max_id')
|
||
).filter(
|
||
PriceRecord.product_id.in_(product_ids),
|
||
PriceRecord.timestamp < today_start
|
||
).group_by(PriceRecord.product_id).subquery()
|
||
|
||
yesterday_prices_q = session.query(
|
||
PriceRecord.product_id, PriceRecord.price
|
||
).join(
|
||
yesterday_prices_subq,
|
||
PriceRecord.id == yesterday_prices_subq.c.max_id
|
||
)
|
||
yesterday_prices_map = {pid: price for pid, price in yesterday_prices_q}
|
||
|
||
# 根據 filter_type 進行篩選
|
||
products = []
|
||
|
||
if filter_type == 'increase':
|
||
# 漲價商品
|
||
for record, product in query.all():
|
||
old_price = yesterday_prices_map.get(product.id)
|
||
if old_price is not None and record.price > old_price:
|
||
products.append({
|
||
'product_id': product.i_code,
|
||
'name': product.name,
|
||
'category': product.category,
|
||
'url': _safe_product_url(product),
|
||
'image_url': product.image_url or '/static/placeholder.png',
|
||
'old_price': old_price,
|
||
'current_price': record.price,
|
||
'change': record.price - old_price,
|
||
'update_time': record.timestamp.strftime('%Y-%m-%d %H:%M')
|
||
})
|
||
|
||
elif filter_type == 'decrease':
|
||
# 降價商品
|
||
for record, product in query.all():
|
||
old_price = yesterday_prices_map.get(product.id)
|
||
if old_price is not None and record.price < old_price:
|
||
products.append({
|
||
'product_id': product.i_code,
|
||
'name': product.name,
|
||
'category': product.category,
|
||
'url': _safe_product_url(product),
|
||
'image_url': product.image_url or '/static/placeholder.png',
|
||
'old_price': old_price,
|
||
'current_price': record.price,
|
||
'change': record.price - old_price,
|
||
'update_time': record.timestamp.strftime('%Y-%m-%d %H:%M')
|
||
})
|
||
|
||
elif filter_type == 'delisted':
|
||
# 下架商品 (今日狀態為 INACTIVE 且今天更新的)
|
||
today_delisted = session.query(Product).filter(
|
||
Product.status == 'INACTIVE',
|
||
Product.updated_at >= today_start
|
||
).all()
|
||
|
||
for product in today_delisted:
|
||
last_record = session.query(PriceRecord).filter(
|
||
PriceRecord.product_id == product.id
|
||
).order_by(PriceRecord.timestamp.desc()).first()
|
||
|
||
if last_record:
|
||
products.append({
|
||
'product_id': product.i_code,
|
||
'name': product.name,
|
||
'category': product.category,
|
||
'url': _safe_product_url(product),
|
||
'image_url': product.image_url or '/static/placeholder.png',
|
||
'last_price': last_record.price,
|
||
'update_time': product.updated_at.strftime('%Y-%m-%d %H:%M') if product.updated_at else ''
|
||
})
|
||
|
||
return jsonify({'products': products})
|
||
|
||
except Exception as e:
|
||
sys_log.error(f"[Web] [PriceChange] 獲取價格變動明細失敗 | Error: {e}")
|
||
return jsonify({'products': []}), 500
|
||
finally:
|
||
session.close()
|
||
|
||
|
||
@api_bp.route('/api/track_momo_link', methods=['POST'])
|
||
@login_required
|
||
def track_momo_link():
|
||
"""API: 記錄 MOMO 連結點擊與異常開啟事件，用於診斷自動開啟來源。"""
|
||
def _is_blocked_momo_url(url: str) -> bool:
|
||
url_l = str(url or '').lower()
|
||
if 'ec404.html' in url_l or 'ec404' in url_l:
|
||
return True
|
||
|
||
try:
|
||
parsed = urlparse(str(url or ''))
|
||
path = (parsed.path or '').lower()
|
||
if 'goodsdetail' in path:
|
||
query = parse_qs(parsed.query or '')
|
||
i_code = (query.get('i_code') or [''])[0]
|
||
if i_code:
|
||
return not is_probable_momo_icode(i_code)
|
||
if not re.search(r'/goodsdetail/[^/]+', path):
|
||
return True
|
||
except Exception:
|
||
pass
|
||
|
||
return False
|
||
|
||
payload = request.get_json(silent=True) or {}
|
||
url = str(payload.get('url') or '').strip()
|
||
effective_url = str(payload.get('effective_url') or '').strip()
|
||
if not url:
|
||
return jsonify({'status': 'ignored', 'reason': 'missing_url'}), 400
|
||
|
||
is_blocked = _is_blocked_momo_url(url) or _is_blocked_momo_url(effective_url)
|
||
level = "[Web] [MOMO_LINK_TRACK] "
|
||
product_id = str(payload.get('product_id', '') or '').strip()
|
||
i_code = str(payload.get('i_code', '') or '').strip()
|
||
source = str(payload.get('source', '') or 'unknown').strip()
|
||
page = str(payload.get('page', '') or '').strip()
|
||
label = str(payload.get('label', '') or '').strip()
|
||
platform = str(payload.get('platform', '') or 'momo').strip()
|
||
product_name = str(payload.get('product_name', '') or '').strip()
|
||
referer = request.headers.get('Referer', '')
|
||
user_ip = request.remote_addr
|
||
|
||
if not effective_url:
|
||
effective_url = url
|
||
|
||
msg = (
|
||
f"{level}platform={platform} source={source} page={page} "
|
||
f"i_code={i_code} product_id={product_id} label={label} "
|
||
f"name={product_name} url={url} effective_url={effective_url} ip={user_ip} referer={referer}"
|
||
)
|
||
|
||
if is_blocked:
|
||
sys_log.warning(msg + " | status=blocked_link")
|
||
else:
|
||
sys_log.info(msg + " | status=tracked")
|
||
|
||
return jsonify({'status': 'ok'})
|