添加公告公告行业

app/service/recruit_announcement_service.py

@@ -15,6 +15,7 @@ from app.models.recruit_announcement_batch import RecruitAnnouncementBatch
 from app.models.recruit_announcement_category import RecruitAnnouncementCategory
 from app.models.recruit_announcement_city import RecruitAnnouncementCity
 from app.models.recruit_announcement_education import RecruitAnnouncementEducation
+from app.models.recruit_announcement_industry import RecruitAnnouncementIndustry
 from app.models.recruit_announcement_tag import RecruitAnnouncementTag
 from app.models.recruit_announcement_year import RecruitAnnouncementYear
 from app.service.company_service import find_or_create_company
@@ -42,7 +43,7 @@ def _truncate(value: object, limit: int) -> str | None:
 
 
 def _save_announcement(announcement_id: int, company_id: int, url: str, data: dict) -> None:
-    """保存公告主表和六张关联表，单事务提交。"""
+    """保存公告主表和七张关联表，单事务提交。"""
     now = datetime.now()
 
     with MysqlSession() as session:
@@ -130,6 +131,17 @@ def _save_announcement(announcement_id: int, company_id: int, url: str, data: di
                 )
             )
 
+        # 行业
+        for industry in data.get("industries") or []:
+            session.execute(
+                insert(RecruitAnnouncementIndustry).values(
+                    id=next_id(),
+                    announcement_id=announcement_id,
+                    industry_name=str(industry)[:64],
+                    create_time=now,
+                )
+            )
+
         # 学历要求
         for edu in data.get("educations") or []:
             session.execute(