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 ManyEnterpriseController manyEnterpriseController;
+    private ManyEnterpriseServiceImpl manyEnterpriseService;
 
     @RabbitListener(queues = "text1")
     public void receiveMessage(String message) {
@@ -43,6 +43,15 @@ 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,5 +14,6 @@ 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,4 +34,20 @@ 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,4 +3,11 @@
 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>