|
@@ -53,18 +53,17 @@ class Response(object):
|
|
|
:return:
|
|
|
"""
|
|
|
select_sql = f"""
|
|
|
- SELECT gh_id, content_status, response, process_times, success_status
|
|
|
+ SELECT gh_id, content_status, response, process_times
|
|
|
FROM {self.article_match_video_table}
|
|
|
WHERE trace_id = '{self.trace_id}';
|
|
|
"""
|
|
|
info_tuple = await self.mysql_client.async_select(select_sql)
|
|
|
- gh_id, content_status, response, process_times, success_status = info_tuple[0]
|
|
|
+ gh_id, content_status, response, process_times = info_tuple[0]
|
|
|
return {
|
|
|
"gh_id": gh_id,
|
|
|
"content_status": content_status,
|
|
|
"response": response,
|
|
|
- "process_times": process_times,
|
|
|
- "success_status": success_status
|
|
|
+ "process_times": process_times
|
|
|
}
|
|
|
|
|
|
def create_gzh_path(self, video_id, shared_uid, gh_id):
|
|
@@ -197,13 +196,6 @@ class Response(object):
|
|
|
response = await self.get_videos_result()
|
|
|
status_code = response.get('content_status')
|
|
|
process_times = response.get('process_times')
|
|
|
- success_status = response.get('success_status')
|
|
|
- if success_status == 1:
|
|
|
- return {
|
|
|
- "traceId": self.trace_id,
|
|
|
- "info": "请联系管理员",
|
|
|
- "error": "该请求已经被请求过一次"
|
|
|
- }
|
|
|
match status_code:
|
|
|
case 0:
|
|
|
if process_times > self.TASK_MAX_PROCESS_TIMES:
|