1.实现批量启用引导词接口\n2.实现批量金融引导词接口

ruoyi-fastapi-backend/module_admin/controller/words_controller.py

@@ -38,6 +38,30 @@ async def get_guide_words_list(
     return ResponseUtil.success(model_content=words_page_query_result)
 
 
+#批量启用引导词
+@wordsController.post('/enable_guide/{guide_ids}',)
+async def enable_guide(
+    request: Request,
+    guide_ids: str,
+    query_db: AsyncSession = Depends(get_db),
+
+):
+    edit_del_result = await WordsService.edit_del_words_services(query_db=query_db, guide_ids=guide_ids, del_flg='0')
+    return ResponseUtil.success(msg=edit_del_result.message)
+
+#批量禁用引导词
+@wordsController.post('/disable_guide/{guide_ids}',)
+async def disable_guide(
+    request: Request,
+    guide_ids: str,
+    query_db: AsyncSession = Depends(get_db),
+
+):
+    edit_del_result = await WordsService.edit_del_words_services(query_db=query_db, guide_ids=guide_ids, del_flg='2')
+    return ResponseUtil.success(msg=edit_del_result.message)
+
+
+
 @wordsController.post('/add_guide'
     # , dependencies=[Depends(CheckUserInterfaceAuth('guide:words:add'))]
                       )

ruoyi-fastapi-backend/module_admin/dao/words_dao.py

@@ -11,6 +11,19 @@ class WordsDao:
     引导词模块数据库操作层
     """
 
+    @classmethod
+    async def edit_del_words(cls, db: AsyncSession, guide_ids: str, del_flag:str):
+
+        guide_id_list = guide_ids.strip(' ').split(',')
+
+        stmt = (
+            update(GuideWords)
+            .values(del_flag = del_flag)
+            .where(GuideWords.guide_id.in_(guide_id_list))
+        )
+
+        return await db.execute(stmt)
+
     @classmethod
     async def get_words_detail_by_id(cls, db: AsyncSession, guide_id: int):
         """

ruoyi-fastapi-backend/module_admin/service/words_service.py

@@ -14,6 +14,19 @@ class WordsService:
     引导词模块服务层
     """
 
+    # 批量禁用/启用引导词
+    @classmethod
+    async def edit_del_words_services(cls, query_db: AsyncSession, guide_ids: str, del_flg:str):
+
+        try:
+            await WordsDao.edit_del_words(query_db, guide_ids, del_flg)
+            await query_db.commit()
+            return CrudResponseModel(is_success=True, message='批量修改')
+        except Exception as e:
+            query_db.rollback()
+            raise e
+
+
     @classmethod
     async def get_words_list_services(
         cls, query_db: AsyncSession, query_object: WordsPageQueryModel, is_page: bool = False