diff --git a/m2pool-modules/m2pool-manage/src/main/java/com/m2pool/manage/mapper/ManageBroadcastMapper.java b/m2pool-modules/m2pool-manage/src/main/java/com/m2pool/manage/mapper/ManageBroadcastMapper.java
index b8c415f..725a7d9 100644
--- a/m2pool-modules/m2pool-manage/src/main/java/com/m2pool/manage/mapper/ManageBroadcastMapper.java
+++ b/m2pool-modules/m2pool-manage/src/main/java/com/m2pool/manage/mapper/ManageBroadcastMapper.java
@@ -1,6 +1,7 @@
 package com.m2pool.manage.mapper;
 
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.m2pool.common.datasource.annotation.DistributionDB;
 import com.m2pool.manage.dto.ManageUserDto;
 import com.m2pool.manage.dto.ManageUserInfoDto;
 import com.m2pool.manage.entity.ManageBroadcast;
@@ -29,5 +30,6 @@ public interface ManageBroadcastMapper extends BaseMapper<ManageBroadcast> {
      * @param coin
      * @return
      */
+    @DistributionDB
     ManageUserInfoDto getUserInfo(@Param("user") String user,@Param("coin") String coin);
 }