text(测试使用mq初始化多数据源)

muyu-modules/muyu-modules-many/muyu-modules-many-server/src/main/java/com/muyu/authentication/rabbitmq/MessageConsumer.java

@@ -21,7 +21,7 @@ import org.springframework.stereotype.Component;
 public class MessageConsumer {
 
     @Autowired
-    private ManyEnterpriseServiceImpl manyEnterpriseService;
+    private ManyEnterpriseController manyEnterpriseController;
 
     @RabbitListener(queues = "text1")
     public void receiveMessage(String message) {
@@ -43,15 +43,6 @@ public class MessageConsumer {
 
         druidDataSource.put(key,dataSource);
 
-        new Thread(()->{
-            try {
-                Thread.sleep(2000);
-                manyEnterpriseService.manyEnterpriseAdd(parse,key);
-            } catch (InterruptedException e) {
-                throw new RuntimeException(e);
-            }
-        }).start();
-
     }
 
 }

muyu-modules/muyu-modules-many/muyu-modules-many-server/src/main/java/com/muyu/authentication/service/ManyEnterpriseService.java

@@ -14,6 +14,5 @@ import java.util.List;
 public interface ManyEnterpriseService extends IService<Enterprise> {
     List<Enterprise> AllList(String headerValue);
 
-//    String manyEnterpriseAdd(Enterprise enterprise,String key);
 
 }

muyu-modules/muyu-modules-many/muyu-modules-many-server/src/main/java/com/muyu/authentication/service/impl/ManyEnterpriseServiceImpl.java

@@ -34,20 +34,4 @@ public class ManyEnterpriseServiceImpl extends ServiceImpl<ManyEnterpriseMapper,
         DynamicDataSourceHolder.removeDynamicDataSourceKey();
         return enterprises;
     }
-
-
-
-    public String manyEnterpriseAdd(Enterprise enterprise,String key) {
-        log.info("enterprise等于:{}",enterprise);
-        DynamicDataSourceHolder.setDynamicDataSourceKey(key);
-        int insert = manyEnterpriseMapper.enterpriseInsert(enterprise);
-        log.info("insert等于:{}",insert);
-        DynamicDataSourceHolder.removeDynamicDataSourceKey();
-        if (insert > 0) {
-            return "初始成功";
-        }else {
-            return "初始失败";
-        }
-    }
-
 }

muyu-modules/muyu-modules-many/muyu-modules-many-server/src/main/resources/mapper/ManyEnterpriseMapper.xml

@@ -3,11 +3,4 @@
 PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
 "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
 <mapper namespace="com.muyu.authentication.mapper.ManyEnterpriseMapper">
-
-    <insert id="enterpriseInsert">
-        INSERT INTO enterprise
-            (`enterprise_name`, `legal_person`, `business_license_number`, `establishment_date`, `business_scope`, `address`, `contact_phone`, `email`, `status`, `registration_date`, `authentication_date`, `examine_status`, `service_level`, `open_server_id`)
-        VALUES
-            (#{enterpriseName}, #{legalPerson}, #{businessLicenseNumber}, #{establishmentDate}, #{businessScope}, #{address}, #{contactPhone}, #{email},#{status},#{registrationDate},#{authenticationDate},#{examineStatus},#{serviceLevel},#{openServerId});
-    </insert>
 </mapper>