|
|
@@ -21,25 +21,7 @@ class PiaoQuanPipeline:
|
|
|
max_d = self.rule_dict.get("period", {}).get("max", 1000)
|
|
|
min_d = self.rule_dict.get("period", {}).get("min", 1000)
|
|
|
days = max_d if max_d > min_d else min_d
|
|
|
- if self.platform == "gongzhonghao":
|
|
|
- if (
|
|
|
- int(time.time()) - publish_time_stamp
|
|
|
- > 3600 * 24 * days
|
|
|
- ) and (
|
|
|
- int(time.time()) - update_time_stamp
|
|
|
- > 3600 * 24 * days
|
|
|
- ):
|
|
|
- AliyunLogger.logging(
|
|
|
- code="2004",
|
|
|
- trace_id=self.trace_id,
|
|
|
- platform=self.platform,
|
|
|
- mode=self.mode,
|
|
|
- env=self.env,
|
|
|
- data=self.item,
|
|
|
- message="发布时间超过{}天".format(days),
|
|
|
- )
|
|
|
- return False
|
|
|
- if self.platform == "gongzhongxinhao":
|
|
|
+ if self.platform == "gongzhonghao" or self.platform == "gongzhongxinhao":
|
|
|
if (
|
|
|
int(time.time()) - publish_time_stamp
|
|
|
> 3600 * 24 * days
|
|
|
@@ -179,7 +161,7 @@ class PiaoQuanPipelineTest:
|
|
|
# 判断发布时间
|
|
|
publish_time_stamp = self.item["publish_time_stamp"]
|
|
|
update_time_stamp = self.item["update_time_stamp"]
|
|
|
- if self.platform == "gongzhonghao":
|
|
|
+ if self.platform == "gongzhonghao" or self.platform == "gongzhongxinhao":
|
|
|
if (
|
|
|
int(time.time()) - publish_time_stamp
|
|
|
> 3600 * 24 * int(self.rule_dict.get("period", {}).get("max", 1000))
|
