add new host

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

@@ -17,19 +17,19 @@ from public import zgc_api,Index
 from SimilarCharactor.string_similarity import similarity_cn,similarity_en
 
 
-host = "http://123.56.114.138:9200/"
+host = "http://172.17.148.67:9200/"
 index_name = "model_params_test"
 es = ES_Client(host,index_name)
 
 
 #按批次号检查结果数据
-res = es.SearchByCondition("DATA_BATCH",["202111231900550001"])
+res = es.SearchByCondition("DATA_BATCH",["202112061620460001"])
 #按项目检查结果数据
-#res = es.SearchAimAllByCondition("DATA_PROJECT_NAME","徽采商城数据入库")
+#res = es.SearchAimAllByCondition("DATA_PROJECT_NAME","自贡商城价格监测")
 
 
 ##按批次下或者项目下的指定类检查结果数据
-#res = res[res['FINISH_P_LASTCATEGORY_NAME'] == '硒鼓/墨粉']
+#res = res[res['FINISH_P_LASTCATEGORY_NAME'] == '饮水机']
 
 '''
 #状态总揽
@@ -77,7 +77,7 @@ print(res[['DOC_ID','FLOW_NODE_STATUS','FINISH_P_REMARK']].groupby(['FLOW_NODE_S
 
 
 #校验是否有未命名的商品
-category_name = '硒鼓/墨粉'
+category_name = '平板电视'
 
 if category_name:
     
@@ -106,6 +106,18 @@ if category_name:
     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 = ['59','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 = ['59','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 ['笔记本','台式机','一体电脑','复印纸','工作站']: