|
@@ -254,11 +254,20 @@ class ThirdPartyPusher:
|
|
|
|
|
|
|
|
if response.status_code == 200:
|
|
if response.status_code == 200:
|
|
|
result = response.json()
|
|
result = response.json()
|
|
|
- if result.get('code') == 200 or result.get('success') == True:
|
|
|
|
|
- logger.info(f"[第三方平台] 批次上报成功: {report.batch_id}")
|
|
|
|
|
|
|
+ status = result.get('status', '')
|
|
|
|
|
+ message = result.get('message', '')
|
|
|
|
|
+ if (result.get('code') == 200 or
|
|
|
|
|
+ result.get('success') == True or
|
|
|
|
|
+ status in ('pending', 'success', 'accepted') or
|
|
|
|
|
+ message == 'accepted'):
|
|
|
|
|
+ logger.info(f"[第三方平台] 批次上报成功: {report.batch_id}, task_id={result.get('task_id')}")
|
|
|
return True
|
|
return True
|
|
|
else:
|
|
else:
|
|
|
logger.warning(f"[第三方平台] 批次上报失败: {result.get('msg', '未知错误')}")
|
|
logger.warning(f"[第三方平台] 批次上报失败: {result.get('msg', '未知错误')}")
|
|
|
|
|
+ try:
|
|
|
|
|
+ logger.warning(f"[第三方平台] 响应内容: {str(result)[:500]}")
|
|
|
|
|
+ except Exception:
|
|
|
|
|
+ pass
|
|
|
else:
|
|
else:
|
|
|
logger.warning(f"[第三方平台] 批次上报失败: HTTP {response.status_code}")
|
|
logger.warning(f"[第三方平台] 批次上报失败: HTTP {response.status_code}")
|
|
|
try:
|
|
try:
|