diff --git a/pom.xml b/pom.xml index e9dfb5757d..6bcbdf5f80 100644 --- a/pom.xml +++ b/pom.xml @@ -15,16 +15,16 @@ yudao-module-system yudao-module-infra - - + + yudao-module-report - + yudao-module-pay - - - + + + yudao-module-ai - + ${project.artifactId} @@ -134,6 +134,15 @@ + + org.apache.maven.plugins + maven-compiler-plugin + + 17 + 17 + UTF-8 + + diff --git a/yudao-framework/yudao-spring-boot-starter-mq/src/main/java/cn/iocoder/yudao/framework/mq/rocketmq/core/Consumer.java b/yudao-framework/yudao-spring-boot-starter-mq/src/main/java/cn/iocoder/yudao/framework/mq/rocketmq/core/Consumer.java deleted file mode 100644 index f4099592ec..0000000000 --- a/yudao-framework/yudao-spring-boot-starter-mq/src/main/java/cn/iocoder/yudao/framework/mq/rocketmq/core/Consumer.java +++ /dev/null @@ -1,26 +0,0 @@ -package cn.iocoder.yudao.framework.mq.rocketmq.core; - -import lombok.RequiredArgsConstructor; -import lombok.extern.slf4j.Slf4j; -import org.apache.rocketmq.spring.annotation.RocketMQMessageListener; -import org.apache.rocketmq.spring.core.RocketMQListener; -import org.springframework.stereotype.Component; - -/** - * - - * - * @author HuangLei - * @since 2025-06-18 - */ -@Component -@Slf4j -@RequiredArgsConstructor -@RocketMQMessageListener( - topic = TopicNameConstants.PAY_REFUND_ORDER, - consumerGroup = GroupConstants.PAY_ORDER_REFUND_GROUP) -public class Consumer implements RocketMQListener { - @Override - public void onMessage(String message) { - log.info("【消费】- {}", message); - } -} \ No newline at end of file diff --git a/yudao-framework/yudao-spring-boot-starter-mq/src/main/java/cn/iocoder/yudao/framework/mq/rocketmq/core/Product.java b/yudao-framework/yudao-spring-boot-starter-mq/src/main/java/cn/iocoder/yudao/framework/mq/rocketmq/core/Product.java deleted file mode 100644 index 8f61bc3e48..0000000000 --- a/yudao-framework/yudao-spring-boot-starter-mq/src/main/java/cn/iocoder/yudao/framework/mq/rocketmq/core/Product.java +++ /dev/null @@ -1,26 +0,0 @@ -package cn.iocoder.yudao.framework.mq.rocketmq.core; - -import cn.iocoder.yudao.framework.common.util.json.JsonUtils; -import jakarta.annotation.PostConstruct; -import lombok.AllArgsConstructor; -import org.apache.rocketmq.spring.core.RocketMQTemplate; -import org.springframework.stereotype.Component; - -/** - * @author HuangLei - * @since 2025-06-18 - */ -@Component -@AllArgsConstructor -public class Product { - - - private final RocketMQTemplate rocketMQTemplate; - - - @PostConstruct - public void init(){ - System.out.println("开始发送消息"); - rocketMQTemplate.convertAndSend("pay-refund-order", JsonUtils.toJsonString("hello world")); - } -} \ No newline at end of file diff --git a/yudao-server/pom.xml b/yudao-server/pom.xml index 49bd846a9c..d5df468a52 100644 --- a/yudao-server/pom.xml +++ b/yudao-server/pom.xml @@ -108,6 +108,12 @@ ${revision} + + cn.iocoder.boot + yudao-spring-boot-starter-mq + ${revision} + + diff --git a/yudao-server/src/main/java/cn/iocoder/yudao/server/YudaoServerApplication.java b/yudao-server/src/main/java/cn/iocoder/yudao/server/YudaoServerApplication.java index 57db3f9421..cfe11fdc8f 100644 --- a/yudao-server/src/main/java/cn/iocoder/yudao/server/YudaoServerApplication.java +++ b/yudao-server/src/main/java/cn/iocoder/yudao/server/YudaoServerApplication.java @@ -9,11 +9,12 @@ import org.springframework.boot.autoconfigure.SpringBootApplication; * 如果你碰到启动的问题,请认真阅读 https://doc.iocoder.cn/quick-start/ 文章 * 如果你碰到启动的问题,请认真阅读 https://doc.iocoder.cn/quick-start/ 文章 * 如果你碰到启动的问题,请认真阅读 https://doc.iocoder.cn/quick-start/ 文章 - * + * cn.iocoder.yudao.server * @author 芋道源码 */ @SuppressWarnings("SpringComponentScan") // 忽略 IDEA 无法识别 ${yudao.info.base-package} -@SpringBootApplication(scanBasePackages = {"${yudao.info.base-package}.server", "${yudao.info.base-package}.module"}) +@SpringBootApplication(scanBasePackages = {"${yudao.info.base-package}.server", "${yudao.info.base-package}.module", + "${yudao.info.base-package}.framework.*"}) public class YudaoServerApplication { public static void main(String[] args) {