tijiao

app.py

@@ -77,16 +77,16 @@ check_chain = {
         "checker": district_checker,
     },
     "docstarttime":{
-        "checker":bidopentime_checker,
+        "checker":docstarttime_checker,
     },
     "docendtime": {
-        "checker": bidopentime_checker,
+        "checker": docendtime_checker,
     },
     "bidstarttime": {
-        "checker": bidopentime_checker,
+        "checker": bidstarttime_checker,
     },
     "bidendtime": {
-        "checker": bidopentime_checker,
+        "checker": bidendtime_checker,
     },
     "bidopentime": {
         "checker": bidopentime_checker,
@@ -107,7 +107,7 @@ def check_params(func, param_rows: dict, is_check_type=False) -> (bool, list):
     """
     函数传参数
     """
-    _default_params = {"attach_text": {}, "bidamount": 0, "budget": 0,"s_winner":"","bidopentime":0,"publishtime":0,"subtype":"","s_topscopeclass":"","supervisorrate":0,"district":"金水区","com_package":[],"buyer":""}  # 必要参数的默认值
+    _default_params = {"attach_text": {}, "bidamount": 0, "budget": 0,"s_winner":"","bidopentime":0,"publishtime":0,"bidstarttime":0,"bidendtime":0,"docendtime":0,"docstarttime":0,"subtype":"","s_topscopeclass":"","supervisorrate":0,"district":"金水区","com_package":[],"buyer":""}  # 必要参数的默认值
     func_params = inspect.getfullargspec(func)  # 取出函数的参数
     args_annotations = func_params.annotations  # 参数类型dict，取出参数类型
     args_list = func_params.args  # 参数list
@@ -307,6 +307,7 @@ if __name__ == '__main__':
             "type": "结果_关于中标 候选人的公示\n市招示 (\n2018) 字\n施工资格后审第\n0827号"
         }
     ],
+    "bidendtime": 1754614800.0,
     "com_package": [
         {
             "projectcode": "S202501020015",
@@ -557,56 +558,30 @@ if __name__ == '__main__':
     # #     }
     # })
     result = check(row, rules={
-         "bidamount" : {
+         "bidendtime" : {
             "0101" : {
-                "name" : "预算/中标金额，不在[0.7,1.3]",
-                "parent_name" : "金额错误",
-                "parent_code" : "01"
-            },
-            "0102" : {
-                "name" : "过大过小，不在[100，10亿]",
-                "parent_name" : "金额错误",
-                "parent_code" : "01"
-            },
-            "0103" : {
-                "name" : "中标金额小数点位数超过4位",
-                "parent_name" : "金额错误",
-                "parent_code" : "01",
-                "checkFn" : "01"
-            },
-            "0104" : {
-                "name" : "中标金额存在费率，折扣率",
-                "parent_name" : "金额错误",
-                "parent_code" : "01"
-            },
-            "0301" : {
-                "name" : "中标金额<0",
-                "parent_name" : "金额错误",
-                "parent_code" : "01"
-            },
-            "0601" : {
-                "name" : "中标金额 > 预算金额",
-                "parent_name" : "金额错误",
+                "name" : "投标截止日期<投标文件递交开始时间",
+                "parent_name" : "时间有效性异常",
                 "parent_code" : "01"
             }
-        },
-        "buyer": {
-            "0103": {
-                "name": "包含叠词，异常词汇，特殊词汇",
-                "parent_name": "名称错误",
-                "parent_code": "01"
-            },
-            "0301": {
-                "name": "采购单位名称长度<3",
-                "parent_name": "名称长度异常错误",
-                "parent_code": "03"
-            },
-            "0105": {
-                "name": "采购单位与中标单位一致",
-                "parent_name": "名称错误",
-                "parent_code": "01"
-            }
-        },
+        }
+        # "buyer": {
+        #     "0103": {
+        #         "name": "包含叠词，异常词汇，特殊词汇",
+        #         "parent_name": "名称错误",
+        #         "parent_code": "01"
+        #     },
+        #     "0301": {
+        #         "name": "采购单位名称长度<3",
+        #         "parent_name": "名称长度异常错误",
+        #         "parent_code": "03"
+        #     },
+        #     "0105": {
+        #         "name": "采购单位与中标单位一致",
+        #         "parent_name": "名称错误",
+        #         "parent_code": "01"
+        #     }
+        # },
         # "entname": {
         #     },
         # "price": {

client_mongo_mysql_liantong.py

@@ -107,17 +107,17 @@ def batch_load_data():
     end_date = int(datetime.strptime(f"{today_date} 00:00:00", "%Y-%m-%d %H:%M:%S").timestamp())
     # print("end_date", end_date)
     # 规则查询,根据必要条件 公司名称（用户ID）、版本号
-    rules_id = get_rule("北京剑鱼信息技术有限公司", "v1.3")
+    rules_id = get_rule("中国联通", "v1.3")
     print(rules_id)
     # 初始化mysql
     conn = MysqlUtil.connect_to_mysql(host='172.20.45.129', port='4000', user='root', password='=PDT49#80Z!RVv52_z',database='quality')
 
-    max_id = ObjectId("0" * 24)
-    # max_id = ObjectId("6881072ff0c6ad8b095d808e")
+    # max_id = ObjectId("0" * 24)
+    max_id = ObjectId("68864d00f0c6ad8b095e65f9")
     # 查询条件：_id >= max_id, appid匹配，且 createtime 在 [start_date, end_date] 之间
     query = {
-        "_id": {"$gte": max_id},
-        # "_id": max_id,
+        # "_id": {"$gte": max_id},
+        "_id": max_id,
         "appid": "jyGQ1XQQsEAwNeSENOFR9D",
         "createtime": {"$gte": start_date, "$lte": end_date}
     }
@@ -153,7 +153,7 @@ def batch_load_data():
                     area = item.get("area", "")
                     city = item.get("city", "")
                     district = item.get("district", "")
-                    score = item.get("score", "")
+                    score = data.get("score", "")
                     error_type_data = json.dumps(data)
                     create_time = today_date
 

tables/fields/bidendtime.py

@@ -17,6 +17,7 @@ class BidendtimeChecker(object):
         return true  代表返回异常
         """
         if toptype == '招标':
-            if bidendtime < bidstarttime:
-                return True
-        return False
+            if bidendtime and  bidstarttime:
+                if bidendtime < bidstarttime:
+                    return True
+                return False

tables/fields/bidstarttime.py

@@ -17,6 +17,7 @@ class BidstarttimeChecker(object):
         return true  代表返回异常
         """
         if toptype == '招标':
-            if bidstarttime < publishtime:
-                return True
-        return False
+            if bidstarttime and publishtime:
+                if bidstarttime < publishtime:
+                    return True
+                return False

tables/fields/docendtime.py

@@ -17,6 +17,7 @@ class DocendtimeChecker(object):
         return true  代表返回异常
         """
         if toptype == '招标':
-            if docendtime < docstarttime:
-                return True
-        return False
+            if docendtime and docstarttime:
+                if docendtime < docstarttime:
+                    return True
+                return False

tables/fields/docstarttime.py

@@ -17,6 +17,7 @@ class DocstarttimeChecker(object):
         return true  代表返回异常
         """
         if toptype == '招标':
-            if docstarttime < publishtime:
-                return True
-        return False
+            if docstarttime and publishtime:
+                if docstarttime < publishtime:
+                    return True
+                return False