Update app.py

app.py

@@ -80,6 +80,12 @@ def create_deepseek_interface():
             lang = "ko" if is_korean else "en"
             loc = "kr" if is_korean else "us"
             
+            # MoneyRadar 방식 정확히 따르기 - serp_type을 news로 변경하고 날짜 범위 추가
+            from datetime import datetime, timedelta
+            now = datetime.utcnow()
+            yesterday = now - timedelta(days=1)
+            date_range = f"{yesterday.strftime('%Y-%m-%d')},{now.strftime('%Y-%m-%d')}"
+            
             # SerpHouse API 호출 실행 - POST 메서드 사용 (MoneyRadar 코드 참고)
             url = "https://api.serphouse.com/serp/live"
             
@@ -91,9 +97,11 @@ def create_deepseek_interface():
                     "loc": loc,
                     "lang": lang,
                     "device": "desktop",
-                    "serp_type": "web",
+                    "serp_type": "news",  # web에서 news로 변경
                     "page": "1",
-                    "num": "5"
+                    "num": "5",
+                    "date_range": date_range,  # 날짜 범위 추가
+                    "sort_by": "date"  # 날짜순 정렬 추가
                 }
             }
             
@@ -106,45 +114,60 @@ def create_deepseek_interface():
             print(f"SerpHouse API 호출 중... 검색어: {search_query}")
             print(f"요청 방식: POST, 페이로드: {payload}")
             
-            # POST 요청 수행
-            response = requests.post(url, json=payload, headers=headers, timeout=(30, 30))
+            # POST 요청 수행 (세션과 재시도 로직 추가)
+            session = requests.Session()
+            retries = requests.packages.urllib3.util.retry.Retry(
+                total=5,
+                backoff_factor=1,
+                status_forcelist=[500, 502, 503, 504, 429],
+                allowed_methods=["POST"]
+            )
+            adapter = requests.adapters.HTTPAdapter(max_retries=retries)
+            session.mount('http://', adapter)
+            session.mount('https://', adapter)
+            
+            response = session.post(
+                url, 
+                json=payload, 
+                headers=headers, 
+                timeout=(30, 30)
+            )
+            
             response.raise_for_status()
             
             print(f"SerpHouse API 응답 상태 코드: {response.status_code}")
             search_results = response.json()
             
-            # 응답 구조 로깅
+            # MoneyRadar의 결과 처리 방식 분석 및 적용
             print(f"응답 구조: {list(search_results.keys()) if isinstance(search_results, dict) else '딕셔너리 아님'}")
             
-            # 검색 결과 파싱 및 포맷팅
+            # 검색 결과 파싱 및 포맷팅 
             formatted_results = []
             formatted_results.append(f"검색어: {search_query}\n\n")
             
-            if "results" in search_results:
-                results = search_results["results"]
-                if "organic" in results:
-                    organic_results = results["organic"]
-                    for result in organic_results[:5]:  # 상위 5개 결과만 사용
+            # 결과 구조 파싱 (MoneyRadar와 동일하게)
+            if "results" in search_results and "results" in search_results["results"]:
+                # 뉴스 결과 파싱
+                news_results = search_results["results"]["results"].get("news", [])
+                if news_results:
+                    for result in news_results[:5]:
                         title = result.get("title", "제목 없음")
                         snippet = result.get("snippet", "내용 없음")
-                        link = result.get("link", "#")
-                        formatted_results.append(f"제목: {title}\n내용: {snippet}\n링크: {link}\n\n")
+                        url = result.get("url", result.get("link", "#"))
+                        source = result.get("source", result.get("channel", "알 수 없음"))
+                        time = result.get("time", result.get("date", "시간 정보 없음"))
+                        
+                        formatted_results.append(
+                            f"제목: {title}\n"
+                            f"출처: {source}\n"
+                            f"시간: {time}\n"
+                            f"내용: {snippet}\n"
+                            f"링크: {url}\n\n"
+                        )
                     
-                    print(f"검색 결과 {len(organic_results)}개 찾음")
+                    print(f"검색 결과 {len(news_results)}개 찾음")
                     return "".join(formatted_results)
             
-            # 다른 가능한 결과 구조 확인
-            if isinstance(search_results, dict) and "organic" in search_results:
-                organic_results = search_results["organic"]
-                for result in organic_results[:5]:
-                    title = result.get("title", "제목 없음")
-                    snippet = result.get("snippet", "내용 없음")
-                    link = result.get("link", "#")
-                    formatted_results.append(f"제목: {title}\n내용: {snippet}\n링크: {link}\n\n")
-                
-                print(f"검색 결과 {len(organic_results)}개 찾음")
-                return "".join(formatted_results)
-            
             print("검색 결과 없음 또는 응답 형식 불일치")
             print(f"응답 내용 미리보기: {str(search_results)[:300]}...")
             return f"검색어 '{search_query}'에 대한 검색 결과가 없거나 API 응답 형식이 예상과 다릅니다."