添加字段 pyname

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="更新时间")

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="清洗完成时间")

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,