diff --git a/cope2n-api/fwd_api/celery_worker/internal_task.py b/cope2n-api/fwd_api/celery_worker/internal_task.py index f098d1a..ca69595 100755 --- a/cope2n-api/fwd_api/celery_worker/internal_task.py +++ b/cope2n-api/fwd_api/celery_worker/internal_task.py @@ -90,11 +90,13 @@ def process_csv_feedback(csv_file_path, feedback_id): imei2 = row.get('imeiNumber2') purchase_date = row.get('Purchase Date') retailer = row.get('retailer') + invoice_no = row.get('invoice_no') sold_to_party = row.get('Sold to party') server_time = float(row.get('timetakenmilli')) fb['request_id'] = request_id fb['retailername'] = retailer fb['sold_to_party'] = sold_to_party + fb["invoice_no"] = invoice_no fb['purchase_date'] = purchase_date fb['imei_number'] = [imei1, imei2] sub_rq.feedback_result = fb @@ -119,7 +121,6 @@ def process_csv_feedback(csv_file_path, feedback_id): continue _predict_result = copy.deepcopy(predict_result_to_ready(sub_rq.predict_result)) _feedback_result = copy.deepcopy(sub_rq.feedback_result) - # _reviewed_result = copy.deepcopy(sub_rq.reviewed_result) try: 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: @@ -132,9 +133,6 @@ def process_csv_feedback(csv_file_path, feedback_id): if _feedback_result: _feedback_result["imei_number"] = [] - # if _reviewed_result: - # _reviewed_result["imei_number"] = [] - else: try: _predict_result = {"retailername": None, "sold_to_party": None, "purchase_date": [], "imei_number": [_predict_result["imei_number"][image.index_in_request]]}