切换数据源

miniapp/src/main/java/com/kym/miniapp/aspect/AppLogAspect.java

@@ -2,6 +2,7 @@ package com.kym.miniapp.aspect;
 
 import cn.dev33.satoken.stp.StpUtil;
 import com.alibaba.fastjson2.JSON;
+import com.baomidou.dynamic.datasource.annotation.DS;
 import com.kym.common.annotation.ApiLog;
 import com.kym.common.utils.HttpContextUtils;
 import com.kym.common.utils.IDGenerator;
@@ -28,6 +29,7 @@ import java.lang.reflect.Method;
  */
 @Aspect
 @Component
+@DS("db-miniapp")
 public class AppLogAspect {
 
     private static final Logger LOGGER = LoggerFactory.getLogger(AppLogAspect.class);

service/src/main/java/com/kym/service/wechat/impl/WxPayServiceImpl.java

@@ -290,6 +290,7 @@ public class WxPayServiceImpl implements WxPayService {
     @SneakyThrows
     @Override
     @Transactional(rollbackFor = Exception.class)
+    @DS("db-miniapp")
     public ResponseEntity<Object> wxNotify(HttpServletRequest request) {
 
         try {