From 8f81492e99af315fd446feff481ce949ba3d0a55 Mon Sep 17 00:00:00 2001 From: jxxghp Date: Tue, 18 Aug 2026 17:10:14 +0800 Subject: [PATCH] =?UTF-8?q?fix:=20=E4=BF=AE=E5=A4=8D=E7=AB=99=E7=82=B9?= =?UTF-8?q?=E6=89=B9=E9=87=8F=E5=AF=BC=E5=85=A5=E6=8A=A5=E9=94=99=EF=BC=88?= =?UTF-8?q?=E9=87=8D=E5=A4=8D=E6=96=B9=E6=B3=95=E8=A6=86=E7=9B=96=E5=AF=BC?= =?UTF-8?q?=E8=87=B4=E5=BC=82=E6=AD=A5=E8=B0=83=E7=94=A8=E5=A4=B1=E6=95=88?= =?UTF-8?q?=EF=BC=89?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- app/application/site/mutation.py | 4 ++-- app/db/oper/site.py | 4 ---- tests/test_site_mutation_command.py | 2 +- 3 files changed, 3 insertions(+), 7 deletions(-) diff --git a/app/application/site/mutation.py b/app/application/site/mutation.py index ef998aee4..5794da621 100644 --- a/app/application/site/mutation.py +++ b/app/application/site/mutation.py @@ -21,7 +21,7 @@ class SiteMutationRepository(Protocol): """读取指定站点。""" ... - async def get_by_domain(self, domain: str) -> Optional[Any]: + async def async_get_by_domain(self, domain: str) -> Optional[Any]: """按域名读取站点。""" ... @@ -90,7 +90,7 @@ class SiteMutationCommand: site_info = await self._indexer_loader(domain) if not site_info: return SiteMutationResult(False, "该站点不支持，请检查站点域名是否正确") - if await self._repository.get_by_domain(domain): + if await self._repository.async_get_by_domain(domain): return SiteMutationResult(False, f"{domain} 站点己存在") values.update({ diff --git a/app/db/oper/site.py b/app/db/oper/site.py index b367b90d5..14a85e5fa 100644 --- a/app/db/oper/site.py +++ b/app/db/oper/site.py @@ -41,10 +41,6 @@ class SiteOper(DbOper): """读取站点写用例需要的目标站点。""" return await self.async_get(site_id) - async def get_by_domain(self, domain: str) -> Optional[Site]: - """按域名读取站点写用例的重复目标。""" - return await Site.async_get_by_domain(self._db, domain) - async def stage_create(self, payload: Mapping[str, Any]) -> None: """暂存新增站点，不由仓储自行提交。""" values = dict(payload) diff --git a/tests/test_site_mutation_command.py b/tests/test_site_mutation_command.py index bad75ec91..0e1a5c370 100644 --- a/tests/test_site_mutation_command.py +++ b/tests/test_site_mutation_command.py @@ -9,7 +9,7 @@ def _command(**overrides): """构造可观察站点写用例及其依赖。""" repository = Mock() repository.get_by_id = AsyncMock(return_value=object()) - repository.get_by_domain = AsyncMock(return_value=None) + repository.async_get_by_domain = AsyncMock(return_value=None) repository.stage_create = AsyncMock() repository.stage_update = AsyncMock(return_value=True) repository.stage_delete = AsyncMock()