瀏覽代碼

refactor:queryDsl引入和消息模块调整

regan 2 年之前
父節點
當前提交
4fc19b06f9
共有 39 個文件被更改,包括 195 次插入2 次删除
  1. 2 1
      iot-common/iot-common-core/src/main/java/cc/iotkit/common/utils/file/FileUtils.java
  2. 0 1
      iot-common/pom.xml
  3. 9 0
      iot-data/iot-data-service/src/main/java/cc/iotkit/data/system/ISysOssConfigData.java
  4. 9 0
      iot-data/iot-data-service/src/main/java/cc/iotkit/data/system/ISysOssData.java
  5. 9 0
      iot-data/iot-data-service/src/main/java/cc/iotkit/data/system/ISysPostData.java
  6. 9 0
      iot-data/iot-data-service/src/main/java/cc/iotkit/data/system/ISysRoleData.java
  7. 9 0
      iot-data/iot-data-service/src/main/java/cc/iotkit/data/system/ISysRoleDeptData.java
  8. 9 0
      iot-data/iot-data-service/src/main/java/cc/iotkit/data/system/ISysRoleMenuData.java
  9. 9 0
      iot-data/iot-data-service/src/main/java/cc/iotkit/data/system/ISysTenantData.java
  10. 9 0
      iot-data/iot-data-service/src/main/java/cc/iotkit/data/system/ISysTenantPackageData.java
  11. 9 0
      iot-data/iot-data-service/src/main/java/cc/iotkit/data/system/ISysUserData.java
  12. 9 0
      iot-data/iot-data-service/src/main/java/cc/iotkit/data/system/ISysUserPostData.java
  13. 9 0
      iot-data/iot-data-service/src/main/java/cc/iotkit/data/system/ISysUserRoleData.java
  14. 35 0
      iot-data/iot-rdb-data-service/pom.xml
  15. 23 0
      iot-data/iot-rdb-data-service/src/main/java/cc/iotkit/data/convert/system/SysConfigMapper.java
  16. 17 0
      iot-data/iot-rdb-data-service/src/main/java/cc/iotkit/data/dao/system/SysConfigRepository.java
  17. 17 0
      iot-data/iot-rdb-data-service/src/main/java/cc/iotkit/data/dao/system/SysDeptRepository.java
  18. 0 0
      iot-module/iot-message-notify/pom.xml
  19. 0 0
      iot-module/iot-message-notify/readme.md
  20. 0 0
      iot-module/iot-message-notify/src/main/java/cc/iotkit/message/config/VertxManager.java
  21. 0 0
      iot-module/iot-message-notify/src/main/java/cc/iotkit/message/enums/ChannelEnum.java
  22. 0 0
      iot-module/iot-message-notify/src/main/java/cc/iotkit/message/event/MessageEvent.java
  23. 0 0
      iot-module/iot-message-notify/src/main/java/cc/iotkit/message/listener/DingTalkEventListener.java
  24. 0 0
      iot-module/iot-message-notify/src/main/java/cc/iotkit/message/listener/EmailEventListener.java
  25. 0 0
      iot-module/iot-message-notify/src/main/java/cc/iotkit/message/listener/MessageEventListener.java
  26. 0 0
      iot-module/iot-message-notify/src/main/java/cc/iotkit/message/listener/PhoneMessageEventListener.java
  27. 0 0
      iot-module/iot-message-notify/src/main/java/cc/iotkit/message/listener/QyWechatEventListener.java
  28. 0 0
      iot-module/iot-message-notify/src/main/java/cc/iotkit/message/listener/VoiceEventListener.java
  29. 0 0
      iot-module/iot-message-notify/src/main/java/cc/iotkit/message/model/DingTalkMessage.java
  30. 0 0
      iot-module/iot-message-notify/src/main/java/cc/iotkit/message/model/EmailConfig.java
  31. 0 0
      iot-module/iot-message-notify/src/main/java/cc/iotkit/message/model/EmailMessage.java
  32. 0 0
      iot-module/iot-message-notify/src/main/java/cc/iotkit/message/model/Message.java
  33. 0 0
      iot-module/iot-message-notify/src/main/java/cc/iotkit/message/model/QyWechatMessage.java
  34. 0 0
      iot-module/iot-message-notify/src/main/java/cc/iotkit/message/notify/EventManager.java
  35. 0 0
      iot-module/iot-message-notify/src/main/java/cc/iotkit/message/notify/EventType.java
  36. 0 0
      iot-module/iot-message-notify/src/main/java/cc/iotkit/message/service/MessageService.java
  37. 0 0
      iot-module/iot-message-notify/消息中心文档.md
  38. 1 0
      iot-module/iot-system/src/main/java/cc/iotkit/system/mapper/SysDeptMapper.java
  39. 1 0
      iot-module/pom.xml

+ 2 - 1
iot-common/iot-common-core/src/main/java/cc/iotkit/common/utils/file/FileUtils.java

@@ -1,10 +1,11 @@
 package cc.iotkit.common.utils.file;
 
 import cn.hutool.core.io.FileUtil;
+import jakarta.servlet.http.HttpServletResponse;
 import lombok.AccessLevel;
 import lombok.NoArgsConstructor;
 
-import javax.servlet.http.HttpServletResponse;
+
 import java.net.URLEncoder;
 import java.nio.charset.StandardCharsets;
 

+ 0 - 1
iot-common/pom.xml

@@ -21,7 +21,6 @@
         <module>iot-common-core</module>
         <module>iot-script-engine</module>
         <module>iot-message-bus</module>
-        <module>iot-message-notify</module>
         <module>iot-common-doc</module>
         <module>iot-common-excel</module>
         <module>iot-common-log</module>

+ 9 - 0
iot-data/iot-data-service/src/main/java/cc/iotkit/data/system/ISysOssConfigData.java

@@ -0,0 +1,9 @@
+package cc.iotkit.data.system;
+
+/**
+ * 操作日志数据接口
+ *
+ * @author sjg
+ */
+public interface ISysOssConfigData {
+}

+ 9 - 0
iot-data/iot-data-service/src/main/java/cc/iotkit/data/system/ISysOssData.java

@@ -0,0 +1,9 @@
+package cc.iotkit.data.system;
+
+/**
+ * 操作日志数据接口
+ *
+ * @author sjg
+ */
+public interface ISysOssData {
+}

+ 9 - 0
iot-data/iot-data-service/src/main/java/cc/iotkit/data/system/ISysPostData.java

@@ -0,0 +1,9 @@
+package cc.iotkit.data.system;
+
+/**
+ * 操作日志数据接口
+ *
+ * @author sjg
+ */
+public interface ISysPostData {
+}

+ 9 - 0
iot-data/iot-data-service/src/main/java/cc/iotkit/data/system/ISysRoleData.java

@@ -0,0 +1,9 @@
+package cc.iotkit.data.system;
+
+/**
+ * 操作日志数据接口
+ *
+ * @author sjg
+ */
+public interface ISysRoleData {
+}

+ 9 - 0
iot-data/iot-data-service/src/main/java/cc/iotkit/data/system/ISysRoleDeptData.java

@@ -0,0 +1,9 @@
+package cc.iotkit.data.system;
+
+/**
+ * 操作日志数据接口
+ *
+ * @author sjg
+ */
+public interface ISysRoleDeptData {
+}

+ 9 - 0
iot-data/iot-data-service/src/main/java/cc/iotkit/data/system/ISysRoleMenuData.java

@@ -0,0 +1,9 @@
+package cc.iotkit.data.system;
+
+/**
+ * 操作日志数据接口
+ *
+ * @author sjg
+ */
+public interface ISysRoleMenuData {
+}

+ 9 - 0
iot-data/iot-data-service/src/main/java/cc/iotkit/data/system/ISysTenantData.java

@@ -0,0 +1,9 @@
+package cc.iotkit.data.system;
+
+/**
+ * 操作日志数据接口
+ *
+ * @author sjg
+ */
+public interface ISysTenantData {
+}

+ 9 - 0
iot-data/iot-data-service/src/main/java/cc/iotkit/data/system/ISysTenantPackageData.java

@@ -0,0 +1,9 @@
+package cc.iotkit.data.system;
+
+/**
+ * 操作日志数据接口
+ *
+ * @author sjg
+ */
+public interface ISysTenantPackageData {
+}

+ 9 - 0
iot-data/iot-data-service/src/main/java/cc/iotkit/data/system/ISysUserData.java

@@ -0,0 +1,9 @@
+package cc.iotkit.data.system;
+
+/**
+ * 操作日志数据接口
+ *
+ * @author sjg
+ */
+public interface ISysUserData {
+}

+ 9 - 0
iot-data/iot-data-service/src/main/java/cc/iotkit/data/system/ISysUserPostData.java

@@ -0,0 +1,9 @@
+package cc.iotkit.data.system;
+
+/**
+ * 操作日志数据接口
+ *
+ * @author sjg
+ */
+public interface ISysUserPostData {
+}

+ 9 - 0
iot-data/iot-data-service/src/main/java/cc/iotkit/data/system/ISysUserRoleData.java

@@ -0,0 +1,9 @@
+package cc.iotkit.data.system;
+
+/**
+ * 操作日志数据接口
+ *
+ * @author sjg
+ */
+public interface ISysUserRoleData {
+}

+ 35 - 0
iot-data/iot-rdb-data-service/pom.xml

@@ -23,6 +23,16 @@
             <artifactId>spring-boot-starter-data-jpa</artifactId>
         </dependency>
 
+        <!-- QueryDSL框架依赖 -->
+        <dependency>
+            <groupId>com.querydsl</groupId>
+            <artifactId>querydsl-apt</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>com.querydsl</groupId>
+            <artifactId>querydsl-jpa</artifactId>
+        </dependency>
+
         <dependency>
             <groupId>com.h2database</groupId>
             <artifactId>h2</artifactId>
@@ -63,6 +73,11 @@
             <groupId>cc.iotkit</groupId>
             <artifactId>iot-data-service</artifactId>
         </dependency>
+        <dependency>
+            <groupId>org.springframework.data</groupId>
+            <artifactId>spring-data-commons</artifactId>
+            <version>2.7.11</version>
+        </dependency>
 
     </dependencies>
 
@@ -90,6 +105,26 @@
                     </annotationProcessorPaths>
                 </configuration>
             </plugin>
+
+            <plugin>
+                <!--因为QueryDsl是类型安全的,所以还需要加上Maven APT plugin,使用 APT 自动生成Q类:-->
+                <groupId>com.mysema.maven</groupId>
+                <artifactId>apt-maven-plugin</artifactId>
+                <version>1.1.3</version>
+                <executions>
+                    <execution>
+                        <phase>generate-sources</phase>
+                        <goals>
+                            <goal>process</goal>
+                        </goals>
+                        <configuration>
+                            <outputDirectory>target/generated-sources/java</outputDirectory>
+                            <processor>com.querydsl.apt.jpa.JPAAnnotationProcessor</processor>
+                        </configuration>
+                    </execution>
+                </executions>
+            </plugin>
+
         </plugins>
     </build>
 

+ 23 - 0
iot-data/iot-rdb-data-service/src/main/java/cc/iotkit/data/convert/system/SysConfigMapper.java

@@ -0,0 +1,23 @@
+package cc.iotkit.data.convert.system;
+
+import cc.iotkit.data.model.TbAlertConfig;
+import cc.iotkit.model.alert.AlertConfig;
+import org.mapstruct.Mapper;
+import org.mapstruct.factory.Mappers;
+
+import java.util.List;
+import java.util.stream.Collectors;
+
+@Mapper
+public interface SysConfigMapper {
+
+    SysConfigMapper M = Mappers.getMapper(SysConfigMapper.class);
+
+    AlertConfig toDto(TbAlertConfig vo);
+
+    TbAlertConfig toVo(AlertConfig dto);
+
+    static List<AlertConfig> toDto(List<TbAlertConfig> alertConfigs) {
+        return alertConfigs.stream().map(M::toDto).collect(Collectors.toList());
+    }
+}

+ 17 - 0
iot-data/iot-rdb-data-service/src/main/java/cc/iotkit/data/dao/system/SysConfigRepository.java

@@ -0,0 +1,17 @@
+/*
+ * +----------------------------------------------------------------------
+ * | Copyright (c) 奇特物联 2021-2022 All rights reserved.
+ * +----------------------------------------------------------------------
+ * | Licensed 未经许可不能去掉「奇特物联」相关版权
+ * +----------------------------------------------------------------------
+ * | Author: xw2sy@163.com
+ * +----------------------------------------------------------------------
+ */
+package cc.iotkit.data.dao.system;
+
+import cc.iotkit.data.model.system.TbSysConfig;
+import org.springframework.data.jpa.repository.JpaRepository;
+
+public interface SysConfigRepository extends JpaRepository<TbSysConfig, Long>, QueryDslPredicateExecutor<TbSysConfig> {
+
+}

+ 17 - 0
iot-data/iot-rdb-data-service/src/main/java/cc/iotkit/data/dao/system/SysDeptRepository.java

@@ -0,0 +1,17 @@
+/*
+ * +----------------------------------------------------------------------
+ * | Copyright (c) 奇特物联 2021-2022 All rights reserved.
+ * +----------------------------------------------------------------------
+ * | Licensed 未经许可不能去掉「奇特物联」相关版权
+ * +----------------------------------------------------------------------
+ * | Author: xw2sy@163.com
+ * +----------------------------------------------------------------------
+ */
+package cc.iotkit.data.dao.system;
+
+import cc.iotkit.data.model.system.TbSysConfig;
+import org.springframework.data.jpa.repository.JpaRepository;
+
+public interface SysDeptRepository extends JpaRepository<TbSysConfig, Long> {
+
+}

+ 0 - 0
iot-common/iot-message-notify/pom.xml → iot-module/iot-message-notify/pom.xml


+ 0 - 0
iot-common/iot-message-notify/readme.md → iot-module/iot-message-notify/readme.md


+ 0 - 0
iot-common/iot-message-notify/src/main/java/cc/iotkit/message/config/VertxManager.java → iot-module/iot-message-notify/src/main/java/cc/iotkit/message/config/VertxManager.java


+ 0 - 0
iot-common/iot-message-notify/src/main/java/cc/iotkit/message/enums/ChannelEnum.java → iot-module/iot-message-notify/src/main/java/cc/iotkit/message/enums/ChannelEnum.java


+ 0 - 0
iot-common/iot-message-notify/src/main/java/cc/iotkit/message/event/MessageEvent.java → iot-module/iot-message-notify/src/main/java/cc/iotkit/message/event/MessageEvent.java


+ 0 - 0
iot-common/iot-message-notify/src/main/java/cc/iotkit/message/listener/DingTalkEventListener.java → iot-module/iot-message-notify/src/main/java/cc/iotkit/message/listener/DingTalkEventListener.java


+ 0 - 0
iot-common/iot-message-notify/src/main/java/cc/iotkit/message/listener/EmailEventListener.java → iot-module/iot-message-notify/src/main/java/cc/iotkit/message/listener/EmailEventListener.java


+ 0 - 0
iot-common/iot-message-notify/src/main/java/cc/iotkit/message/listener/MessageEventListener.java → iot-module/iot-message-notify/src/main/java/cc/iotkit/message/listener/MessageEventListener.java


+ 0 - 0
iot-common/iot-message-notify/src/main/java/cc/iotkit/message/listener/PhoneMessageEventListener.java → iot-module/iot-message-notify/src/main/java/cc/iotkit/message/listener/PhoneMessageEventListener.java


+ 0 - 0
iot-common/iot-message-notify/src/main/java/cc/iotkit/message/listener/QyWechatEventListener.java → iot-module/iot-message-notify/src/main/java/cc/iotkit/message/listener/QyWechatEventListener.java


+ 0 - 0
iot-common/iot-message-notify/src/main/java/cc/iotkit/message/listener/VoiceEventListener.java → iot-module/iot-message-notify/src/main/java/cc/iotkit/message/listener/VoiceEventListener.java


+ 0 - 0
iot-common/iot-message-notify/src/main/java/cc/iotkit/message/model/DingTalkMessage.java → iot-module/iot-message-notify/src/main/java/cc/iotkit/message/model/DingTalkMessage.java


+ 0 - 0
iot-common/iot-message-notify/src/main/java/cc/iotkit/message/model/EmailConfig.java → iot-module/iot-message-notify/src/main/java/cc/iotkit/message/model/EmailConfig.java


+ 0 - 0
iot-common/iot-message-notify/src/main/java/cc/iotkit/message/model/EmailMessage.java → iot-module/iot-message-notify/src/main/java/cc/iotkit/message/model/EmailMessage.java


+ 0 - 0
iot-common/iot-message-notify/src/main/java/cc/iotkit/message/model/Message.java → iot-module/iot-message-notify/src/main/java/cc/iotkit/message/model/Message.java


+ 0 - 0
iot-common/iot-message-notify/src/main/java/cc/iotkit/message/model/QyWechatMessage.java → iot-module/iot-message-notify/src/main/java/cc/iotkit/message/model/QyWechatMessage.java


+ 0 - 0
iot-common/iot-message-notify/src/main/java/cc/iotkit/message/notify/EventManager.java → iot-module/iot-message-notify/src/main/java/cc/iotkit/message/notify/EventManager.java


+ 0 - 0
iot-common/iot-message-notify/src/main/java/cc/iotkit/message/notify/EventType.java → iot-module/iot-message-notify/src/main/java/cc/iotkit/message/notify/EventType.java


+ 0 - 0
iot-common/iot-message-notify/src/main/java/cc/iotkit/message/service/MessageService.java → iot-module/iot-message-notify/src/main/java/cc/iotkit/message/service/MessageService.java


+ 0 - 0
iot-common/iot-message-notify/消息中心文档.md → iot-module/iot-message-notify/消息中心文档.md


+ 1 - 0
iot-module/iot-system/src/main/java/cc/iotkit/system/mapper/SysDeptMapper.java

@@ -1,5 +1,6 @@
 package cc.iotkit.system.mapper;
 
+import cc.iotkit.model.system.SysDept;
 import cc.iotkit.system.domain.vo.SysDeptVo;
 
 import java.util.List;

+ 1 - 0
iot-module/pom.xml

@@ -15,6 +15,7 @@
         <module>iot-system</module>
         <module>iot-manager</module>
         <module>iot-rule-engine</module>
+        <module>iot-message-notify</module>
     </modules>