队列模块添加依赖

applications/transfers/transfers-server/pom.xml

@@ -57,6 +57,10 @@
             <groupId>mysql</groupId>
             <artifactId>mysql-connector-java</artifactId>
         </dependency>
+        <dependency>
+            <groupId>org.mybatis.spring.boot</groupId>
+            <artifactId>mybatis-spring-boot-starter</artifactId>
+        </dependency>
     </dependencies>
 
     <build>

applications/transfers/transfers-server/src/main/java/com/usoftchina/saas/transfers/TransfersApplication.java

@@ -1,5 +1,6 @@
 package com.usoftchina.saas.transfers;
 
+import org.mybatis.spring.annotation.MapperScan;
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
@@ -8,10 +9,9 @@ import org.springframework.cloud.openfeign.EnableFeignClients;
 @SpringBootApplication
 @EnableEurekaClient
 @EnableFeignClients("com.usoftchina.saas")
+@MapperScan("com.usoftchina.saas.transfers.mapper")
 public class TransfersApplication {
     public static void main(String[] args) {
         SpringApplication.run(TransfersApplication.class, args);
     }
-
-
 }

applications/transfers/transfers-server/src/main/resources/application.yml

@@ -71,6 +71,9 @@ info:
   version: '@project.version@'
   spring-boot-version: '@spring.boot.version@'
   spring-cloud-version: '@spring.cloud.version@'
+mybatis:
+  type-aliases-package: com.usoftchina.saas.transfers.po
+  mapper-locations: classpath:mapper/*.xml
 auth:
   public-key: auth/pub.key
 ribbon:

applications/transfers/transfers-server/src/main/resources/config/application-dev.yml

@@ -11,3 +11,6 @@ eureka:
     registryFetchIntervalSeconds: 5
     serviceUrl:
       defaultZone: http://${spring.security.user.name}:${spring.security.user.password}@127.0.0.1:8500/eureka/
+logging:
+  level:
+    com.usoftchina.saas.transfers.mapper : debug

applications/transfers/transfers-server/src/test/java/com/usoftchina/saas/transfers/service/RabbitSendServiceTest.java

@@ -25,7 +25,7 @@ public class RabbitSendServiceTest {
     public void TestA_Send() {
         MessageInfo msg = new MessageInfo();
         msg.setBizId("测试");
-        msg.setMsgId("测试0001");
+        msg.setMsgId("测试00001");
         sendService.sendMessage(msg);
     }
 
@@ -34,7 +34,7 @@ public class RabbitSendServiceTest {
         MessageInfo msg = new MessageInfo();
         msg.setBizId("测试");
         msg.setMsgId("测试延迟0001");
-        sendService.sendDelayMessage(msg);
+        sendService.sendDelayMessage(msg, "测试");
     }