diff --git a/apps/common/event/listener_manage.py b/apps/common/event/listener_manage.py index 8f3faf29e..671cd185a 100644 --- a/apps/common/event/listener_manage.py +++ b/apps/common/event/listener_manage.py @@ -9,6 +9,7 @@ import logging import os import threading +import datetime import traceback from typing import List @@ -229,9 +230,11 @@ class ListenerManagement: next_index = taskType.value + 1 current_index = taskType.value status_number = state.value + current_time = datetime.datetime.now().strftime('%Y-%m-%d %H:%M:%S.%f') + '+00' params_dict = {'${bit_number}': bit_number, '${up_index}': up_index, '${status_number}': status_number, '${next_index}': next_index, - '${table_name}': query_set.model._meta.db_table, '${current_index}': current_index} + '${table_name}': query_set.model._meta.db_table, '${current_index}': current_index, + '${current_time}': current_time} for key in params_dict: _value_ = params_dict[key] exec_sql = exec_sql.replace(key, str(_value_)) diff --git a/apps/dataset/sql/update_paragraph_status.sql b/apps/dataset/sql/update_paragraph_status.sql index 45f9c674f..1e2fc6f08 100644 --- a/apps/dataset/sql/update_paragraph_status.sql +++ b/apps/dataset/sql/update_paragraph_status.sql @@ -6,8 +6,8 @@ status_meta = jsonb_set ( "${table_name}".status_meta, '{state_time,${current_index}}', jsonb_set ( - COALESCE ( "${table_name}".status_meta #> '{state_time,${current_index}}', jsonb_build_object ( '${status_number}', now( ) ) ), + COALESCE ( "${table_name}".status_meta #> '{state_time,${current_index}}', jsonb_build_object ( '${status_number}', '${current_time}' ) ), '{${status_number}}', - CONCAT ( '"', now( ), '"' ) :: JSONB + CONCAT ( '"', '${current_time}', '"' ) :: JSONB ) ) \ No newline at end of file