tijiao

client.py

@@ -13,8 +13,6 @@ a2s_ip = "192.168.3.240:9090"
 topic = "quality_bid"
 timeout = 120
 
-
-
 # 开始评估
 def start_quality(data: dict, rules_id: int, a2s_ip, topic, timeout, retry=3):
     # 本次不使用SSL，所以channel是不安全的
@@ -33,7 +31,6 @@ def start_quality(data: dict, rules_id: int, a2s_ip, topic, timeout, retry=3):
 
 
 # 获取规则ID
-
 def get_rule(company, version):
     rule_id = ReluClient.find_rule_by_company(ReluMongodb["col"], company, version)
     return rule_id
@@ -47,12 +44,12 @@ def batch_load_purchasinglist():
     print(rules_id)
 
     # max_id = ObjectId("0" * 24)
-    max_id = ObjectId("65409048dd24231d52d9e89c")
+    max_id = ObjectId("5f164bf552c1d9fbf8437ce0")
     while True:
         # db = MongoClient('192.168.3.71', 29099, unicode_decode_error_handler="ignore").re4art
         # coll_user = db["zc_classify_test"]
-        db = MongoClient('192.168.3.166', 27082, unicode_decode_error_handler="ignore").zhengluming
-        coll_user = db["f_sourceinfo_HP_channel_succes_data"]
+        db = MongoClient('192.168.3.166', 27082, unicode_decode_error_handler="ignore").zhengluming_27082
+        coll_user = db["update_data"]
         num=0
         try:
             for item in coll_user.find({"_id":{"$gte":max_id}}).sort("_id",1):
@@ -60,17 +57,13 @@ def batch_load_purchasinglist():
             # for item in coll_user.find().sort("_id",1):
                 max_id = item["_id"]
                 print(max_id)
-                v_baseinfo=item.get("v_baseinfo")
-                if not v_baseinfo:
-                    continue
-                purchasinglist =item["v_baseinfo"].get("purchasinglist")
-                purchasingsource =item["v_baseinfo"].get("purchasingsource")
+                purchasinglist =item.get("purchasinglist")
+                purchasingsource =item.get("purchasingsource")
                 #不存在标的物
                 if not (purchasinglist and purchasingsource):
                     continue
                 item["_id"] = str(item["_id"])
                 # item['detail']=item['details'].replace("\\\"", "\"")
-                item={"purchasinglist":purchasinglist,"purchasingsource":purchasingsource}
                 result = start_quality(item, rules_id, a2s_ip, topic, timeout)
                 print(result)
                 # 示例：result：{'code': 200, 'msg': '成功', 'data': {'title_qa': {'0201': '非汉字占比>55%'}}}