读写分离-保证userPurseService所有方法强制使用主库

accompany-business/accompany-business-service/src/main/java/com/accompany/business/mybatismapper/UserPurseMapper.java

@@ -39,4 +39,6 @@ public interface UserPurseMapper extends BaseMapper<UserPurse> {
     int updateMinusDiamondsAndGold(@Param("uid") Long uid, @Param("diamonds") Double diamonds, @Param("golds") Double golds);
 
     int excGoldToGuildUsd(@Param("uid") Long uid, @Param("goldNum") Double goldNum, @Param("guildUsdNum") Double guildUsdNum);
+
+    UserPurse queryByUid(@Param("uid") Long uid);
 }

accompany-business/accompany-business-service/src/main/java/com/accompany/business/service/purse/UserPurseService.java

@@ -87,7 +87,7 @@ public class UserPurseService extends ServiceImpl<UserPurseMapper,UserPurse> {
     }
 
     public UserPurse queryUserPurse(Long uid){
-        UserPurse userPurse = getById(uid);
+        UserPurse userPurse = this.baseMapper.queryByUid(uid);
         if (userPurse == null) {
             userPurse = createUserPurse(uid);
         }

accompany-business/accompany-business-service/src/main/resources/accompany/sqlmappers/UserPurseMapper.xml

@@ -69,4 +69,9 @@
       where uid=#{uid} and golds >= #{goldNum};
     </update>
 
+  <select id="queryByUid" resultType="com.accompany.business.model.UserPurse">
+    /* SHARDINGSPHERE_HINT: WRITE_ROUTE_ONLY=true */
+    select * from user_purse where uid = #{uid};
+  </select>
+
 </mapper>