diff --git a/app/models/mysql/job.py b/app/models/mysql/job.py index a2e2e49..47aca91 100644 --- a/app/models/mysql/job.py +++ b/app/models/mysql/job.py @@ -35,6 +35,7 @@ class Job(MysqlBase): content_hash: Mapped[Optional[str]] = mapped_column(String(64), comment="内容哈希,用于去重续命") recruit_category: Mapped[Optional[int]] = mapped_column(Integer, comment="招聘分类: 0=校招 1=实习 2=社招 3=其他") expire_at: Mapped[Optional[datetime]] = mapped_column(DateTime, comment="发布日期") + pyname: Mapped[Optional[str]] = mapped_column(String(100), comment="脚本名字") status: Mapped[int] = mapped_column(Integer, default=0, comment="0=上架 1=下架 2=已失效") create_time: Mapped[datetime] = mapped_column(DateTime, nullable=False, comment="创建时间") update_time: Mapped[datetime] = mapped_column(DateTime, nullable=False, comment="更新时间") diff --git a/app/models/pg/app_job_data.py b/app/models/pg/app_job_data.py index d7fe3ab..168ffda 100644 --- a/app/models/pg/app_job_data.py +++ b/app/models/pg/app_job_data.py @@ -31,5 +31,6 @@ class AppJobData(PgBase): created_at: Mapped[datetime] = mapped_column(DateTime, nullable=False, comment="创建时间") updated_at: Mapped[datetime] = mapped_column(DateTime, nullable=False, comment="更新时间") clean_status: Mapped[str] = mapped_column(String(20), default="pending", nullable=False, comment="清洗状态: pending/cleaning/cleaned/discarded") + pyname: Mapped[Optional[str]] = mapped_column(String(100), comment="脚本名字") clean_started_at: Mapped[Optional[datetime]] = mapped_column(DateTime, comment="清洗开始时间") cleaned_at: Mapped[Optional[datetime]] = mapped_column(DateTime, comment="清洗完成时间") diff --git a/app/services/job_clean_service.py b/app/services/job_clean_service.py index 62d7822..c947eaf 100644 --- a/app/services/job_clean_service.py +++ b/app/services/job_clean_service.py @@ -156,6 +156,7 @@ async def _do_clean(data: dict) -> None: content_hash=data.get("content_hash"), source_url=data.get("detail_url"), source_id=str(data_id), + pyname=data.get("pyname"), status=0, create_time=now, update_time=now,