From 2a4df57dd0c68a38e2e31d46c78b71491ccc26a8 Mon Sep 17 00:00:00 2001
From: zhang xu <2125563902@qq.com>
Date: Thu, 16 May 2024 22:37:53 +0800
Subject: [PATCH] =?UTF-8?q?text:(=E8=BF=9E=E6=8E=A5=E6=B1=A0=E9=93=BE?=
 =?UTF-8?q?=E6=8E=A5=E6=9B=B4=E6=94=B9)?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 muyu-modules/muyu-etl/muyu-etl-common/pom.xml |  1 -
 .../muyu-etl/muyu-etl-service/pom.xml         |  4 +++
 .../etl/consumer/Consumer_SimpleQueue.java    | 10 ++++++
 .../java/com/muyu/etl/mapper/BrandMapper.java | 31 +++++++++++++++++++
 .../etl/produce/Producer_SimpleQueue.java     | 19 ++++++++++++
 5 files changed, 64 insertions(+), 1 deletion(-)
 create mode 100644 muyu-modules/muyu-etl/muyu-etl-service/src/main/java/com/muyu/etl/consumer/Consumer_SimpleQueue.java
 create mode 100644 muyu-modules/muyu-etl/muyu-etl-service/src/main/java/com/muyu/etl/mapper/BrandMapper.java
 create mode 100644 muyu-modules/muyu-etl/muyu-etl-service/src/main/java/com/muyu/etl/produce/Producer_SimpleQueue.java

diff --git a/muyu-modules/muyu-etl/muyu-etl-common/pom.xml b/muyu-modules/muyu-etl/muyu-etl-common/pom.xml
index f5ff68d..fd1f1e3 100644
--- a/muyu-modules/muyu-etl/muyu-etl-common/pom.xml
+++ b/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>
diff --git a/muyu-modules/muyu-etl/muyu-etl-service/pom.xml b/muyu-modules/muyu-etl/muyu-etl-service/pom.xml
index ec86c38..67e4264 100644
--- a/muyu-modules/muyu-etl/muyu-etl-service/pom.xml
+++ b/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>
 
diff --git a/muyu-modules/muyu-etl/muyu-etl-service/src/main/java/com/muyu/etl/consumer/Consumer_SimpleQueue.java b/muyu-modules/muyu-etl/muyu-etl-service/src/main/java/com/muyu/etl/consumer/Consumer_SimpleQueue.java
new file mode 100644
index 0000000..190f9a2
--- /dev/null
+++ b/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 {
+}
diff --git a/muyu-modules/muyu-etl/muyu-etl-service/src/main/java/com/muyu/etl/mapper/BrandMapper.java b/muyu-modules/muyu-etl/muyu-etl-service/src/main/java/com/muyu/etl/mapper/BrandMapper.java
new file mode 100644
index 0000000..b8fff5d
--- /dev/null
+++ b/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);
+
+
+}
diff --git a/muyu-modules/muyu-etl/muyu-etl-service/src/main/java/com/muyu/etl/produce/Producer_SimpleQueue.java b/muyu-modules/muyu-etl/muyu-etl-service/src/main/java/com/muyu/etl/produce/Producer_SimpleQueue.java
new file mode 100644
index 0000000..8e4cf4d
--- /dev/null
+++ b/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通道
+
+    }
+
+}