update

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

@@ -29,7 +29,7 @@ res = es.SearchByCondition("DATA_BATCH",["202111231900550001"])
 
 
 ##按批次下或者项目下的指定类检查结果数据
-#res = res[res['FINISH_P_LASTCATEGORY_NAME'] == '台式机']
+#res = res[res['FINISH_P_LASTCATEGORY_NAME'] == '硒鼓/墨粉']
 
 '''
 #状态总揽
@@ -77,9 +77,25 @@ print(res[['DOC_ID','FLOW_NODE_STATUS','FINISH_P_REMARK']].groupby(['FLOW_NODE_S
 
 
 #校验是否有未命名的商品
-category_name = ''
+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]
+    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]
+    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
     if category_name in ['笔记本','台式机','一体电脑','复印纸','工作站']:
         FLOW_NODE_STATUS = "SYS_GET_PARAMS_SUCCESS_REDUCTIVE"
@@ -118,9 +134,19 @@ if category_name:
     if update_res_4['updated'] != 0:
             check_flag = False
             
+    search_field_list = ['FINISH_P_LASTCATEGORY_NAME','FLOW_NODE_STATUS','FINISH_P_NAME','FLOW_FINISH_STATUS']
+    search_field_value_list = [category_name,'SYS_GET_PARAMS_FAILD_END','','N']
+    update_field = "FLOW_NODE_STATUS"
+    update_field_value = FLOW_NODE_STATUS
+    update_res_5 = es.UpdateByMultipleFourCondition(search_field_list,search_field_value_list,update_field,update_field_value)
+    if update_res_5['updated'] != 0:
+            check_flag = False
+
 
 if check_flag:
     date = str(datetime.datetime.now()).split(".")[0]
     res.to_excel(f"（未确认）{date}数据.xlsx")
+else:
+    print("存在未命名的数据，已重置，请稍后重新查看")