text:(连接池链接更改)

muyu-modules/muyu-etl/muyu-etl-common/pom.xml

@@ -19,7 +19,6 @@
     </properties>
 
     <dependencies>
-
         <dependency>
             <groupId>com.muyu</groupId>
             <artifactId>muyu-modules-system</artifactId>

muyu-modules/muyu-etl/muyu-etl-service/pom.xml

@@ -108,6 +108,10 @@
             <groupId>com.muyu</groupId>
             <artifactId>muyu-common-system</artifactId>
         </dependency>
+        <dependency>
+            <groupId>com.rabbitmq</groupId>
+            <artifactId>amqp-client</artifactId>
+        </dependency>
 
     </dependencies>
 

muyu-modules/muyu-etl/muyu-etl-service/src/main/java/com/muyu/etl/consumer/Consumer_SimpleQueue.java

@@ -0,0 +1,10 @@
+package com.muyu.etl.consumer;
+
+/**
+ * @ClassDescription:
+ * @JdkVersion: 17
+ * @Author: zhangxu
+ * @Created: 2024/5/16 15:02
+ */
+public class Consumer_SimpleQueue {
+}

muyu-modules/muyu-etl/muyu-etl-service/src/main/java/com/muyu/etl/mapper/BrandMapper.java

@@ -0,0 +1,31 @@
+package com.muyu.etl.mapper;
+
+import com.muyu.etl.domain.req.BrandReq;
+import org.apache.ibatis.annotations.Mapper;
+
+import java.util.List;
+
+/**
+ * @ClassDescription:
+ * @JdkVersion: 17
+ * @Author: zhangxu
+ * @Created: 2024/5/16 20:55
+ */
+@Mapper
+public interface BrandMapper {
+
+
+    public List<BrandReq> getBrandList(BrandReq brandReq);
+
+
+    int update();
+
+
+    int insert();
+
+    int delete(BrandReq brandReq);
+
+    int deleteAll(Long[] ids);
+
+
+}

muyu-modules/muyu-etl/muyu-etl-service/src/main/java/com/muyu/etl/produce/Producer_SimpleQueue.java

@@ -0,0 +1,19 @@
+package com.muyu.etl.produce;
+
+
+/**
+ * @ClassDescription:
+ * @JdkVersion: 17
+ * @Author: zhangxu
+ * @Created: 2024/5/16 15:01
+ */
+public class Producer_SimpleQueue {
+
+    private final static String QUEUE_NAME = "simple_queue";
+
+    public static void main(String[] args) {
+        //获取连接及mq通道
+
+    }
+
+}