tannedcung/sbt-idp
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

update internal task + remove junk code

Browse Source
This commit is contained in:
PhanThanhTrung 2024-03-13 13:18:26 +07:00
parent 6eca045f0e
commit a8999bb9c8
1 changed files with 2 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
cope2n-api/fwd_api/celery_worker/internal_task.py
View File

@ -90,11 +90,13 @@ def process_csv_feedback(csv_file_path, feedback_id):
imei2 = row.get('imeiNumber2') imei2 = row.get('imeiNumber2')
purchase_date = row.get('Purchase Date') purchase_date = row.get('Purchase Date')
retailer = row.get('retailer') retailer = row.get('retailer')
invoice_no = row.get('invoice_no')
sold_to_party = row.get('Sold to party') sold_to_party = row.get('Sold to party')
server_time = float(row.get('timetakenmilli')) server_time = float(row.get('timetakenmilli'))
fb['request_id'] = request_id fb['request_id'] = request_id
fb['retailername'] = retailer fb['retailername'] = retailer
fb['sold_to_party'] = sold_to_party fb['sold_to_party'] = sold_to_party
fb["invoice_no"] = invoice_no
fb['purchase_date'] = purchase_date fb['purchase_date'] = purchase_date
fb['imei_number'] = [imei1, imei2] fb['imei_number'] = [imei1, imei2]
sub_rq.feedback_result = fb sub_rq.feedback_result = fb
@ -119,7 +121,6 @@ def process_csv_feedback(csv_file_path, feedback_id):
continue continue
_predict_result = copy.deepcopy(predict_result_to_ready(sub_rq.predict_result)) _predict_result = copy.deepcopy(predict_result_to_ready(sub_rq.predict_result))
_feedback_result = copy.deepcopy(sub_rq.feedback_result) _feedback_result = copy.deepcopy(sub_rq.feedback_result)
# _reviewed_result = copy.deepcopy(sub_rq.reviewed_result)
try: try:
image.processing_time = time_cost.get(image.doc_type, [0 for _ in range(image.index_in_request)])[image.index_in_request] image.processing_time = time_cost.get(image.doc_type, [0 for _ in range(image.index_in_request)])[image.index_in_request]
except Exception as e: except Exception as e:
@ -132,9 +133,6 @@ def process_csv_feedback(csv_file_path, feedback_id):
if _feedback_result: if _feedback_result:
_feedback_result["imei_number"] = [] _feedback_result["imei_number"] = []
# if _reviewed_result:
# _reviewed_result["imei_number"] = []
else: else:
try: try:
_predict_result = {"retailername": None, "sold_to_party": None, "purchase_date": [], "imei_number": [_predict_result["imei_number"][image.index_in_request]]} _predict_result = {"retailername": None, "sold_to_party": None, "purchase_date": [], "imei_number": [_predict_result["imei_number"][image.index_in_request]]}