add

数据治理平台线下处理/线下处理/参数补充线下处理导出导入脚本_6(查看处理结果并导出确认).py

@@ -80,20 +80,31 @@ print(res[['DOC_ID','FLOW_NODE_STATUS','FINISH_P_REMARK']].groupby(['FLOW_NODE_S
 category_name = '硒鼓/墨粉'
 
 if category_name:
-    '''
+    
     #更新相应字段，以跳过必填参数项补充节点
-    search_field_list = ['DATA_BATCH','FLOW_NODE_STATUS','FINISH_P_LASTCATEGORY_NAME']
-    search_field_value_list = ['202111261625500001','SYS_GET_PARAMS_FAILD_END',category_name]
+    search_field_list = ['DATA_PROJECT_ID','FLOW_NODE_STATUS','FINISH_P_LASTCATEGORY_NAME']
+    search_field_value_list = ['52','SYS_GET_PARAMS_FAILD_END',category_name]
+    update_field = "FLOW_FINISH_STATUS"
+    update_field_value = "Y"
+    es.UpdateByMultipleThreeCondition(search_field_list,search_field_value_list,update_field,update_field_value)
+    
+    search_field_list = ['DATA_PROJECT_ID','FLOW_NODE_STATUS','FINISH_P_LASTCATEGORY_NAME']
+    search_field_value_list = ['52','SYS_GET_PARAMS_FAILD_END',category_name]
+    update_field = "FLOW_NODE_STATUS"
+    update_field_value = "SYS_GET_PARAMS_SUCCESS_END"
+    es.UpdateByMultipleThreeCondition(search_field_list,search_field_value_list,update_field,update_field_value)
+    
+    search_field_list = ['DATA_PROJECT_ID','FLOW_NODE_STATUS','FINISH_P_LASTCATEGORY_NAME']
+    search_field_value_list = ['49','SYS_GET_PARAMS_FAILD_END',category_name]
     update_field = "FLOW_FINISH_STATUS"
     update_field_value = "Y"
     es.UpdateByMultipleThreeCondition(search_field_list,search_field_value_list,update_field,update_field_value)
     
-    search_field_list = ['DATA_BATCH','FLOW_NODE_STATUS','FINISH_P_LASTCATEGORY_NAME']
-    search_field_value_list = ['202111261625500001','SYS_GET_PARAMS_FAILD_END',category_name]
+    search_field_list = ['DATA_PROJECT_ID','FLOW_NODE_STATUS','FINISH_P_LASTCATEGORY_NAME']
+    search_field_value_list = ['49','SYS_GET_PARAMS_FAILD_END',category_name]
     update_field = "FLOW_NODE_STATUS"
     update_field_value = "SYS_GET_PARAMS_SUCCESS_END"
     es.UpdateByMultipleThreeCondition(search_field_list,search_field_value_list,update_field,update_field_value)
-    '''
     
     
     check_flag = True