修改 pipeline

common/pipeline.py

@@ -82,38 +82,37 @@ class PiaoQuanPipeline:
                 )
                 if key == "peroid":
                     flag = 0 <= int(self.item[key]) <= max_value
-                    AliyunLogger.logging(
-                        code="2004",
-                        trace_id=self.trace_id,
-                        platform=self.platform,
-                        mode=self.mode,
-                        env=self.env,
-                        data=self.item,
-                        message="{}: 0 <= {} <= {}, {}".format(
-                            key, self.item[key], max_value, flag
-                        ),
-                    )
-
                     if not flag:
+                        AliyunLogger.logging(
+                            code="2004",
+                            trace_id=self.trace_id,
+                            platform=self.platform,
+                            mode=self.mode,
+                            env=self.env,
+                            data=self.item,
+                            message="{}: 0 <= {} <= {}, {}".format(
+                                key, self.item[key], max_value, flag
+                            ),
+                        )
                         return flag
                 else:
                     flag = int(self.rule_dict[key]["min"]) <= int(self.item[key]) <= max_value
-                    AliyunLogger.logging(
-                        code="2004",
-                        trace_id=self.trace_id,
-                        platform=self.platform,
-                        mode=self.mode,
-                        env=self.env,
-                        data=self.item,
-                        message="{}: {} <= {} <= {}, {}".format(
-                            key,
-                            self.rule_dict[key]["min"],
-                            self.item[key],
-                            max_value,
-                            flag,
-                        ),
-                    )
                     if not flag:
+                        AliyunLogger.logging(
+                            code="2004",
+                            trace_id=self.trace_id,
+                            platform=self.platform,
+                            mode=self.mode,
+                            env=self.env,
+                            data=self.item,
+                            message="{}: {} <= {} <= {}, {}".format(
+                                key,
+                                self.rule_dict[key]["min"],
+                                self.item[key],
+                                max_value,
+                                flag,
+                            ),
+                        )
                         return flag
             else:
                 continue