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 @@ - com.muyu muyu-modules-system 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 @@ com.muyu muyu-common-system + + com.rabbitmq + amqp-client + 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 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通道 + + } + +}