fix(): 修复cloud-data-process数据处理微服务模块 ---> cloud-event-process事件处理微服务模块
parent
423836afb7
commit
6594363a91
|
@ -9,7 +9,7 @@
|
||||||
<version>3.6.3</version>
|
<version>3.6.3</version>
|
||||||
</parent>
|
</parent>
|
||||||
|
|
||||||
<artifactId>cloud-modules-data-process</artifactId>
|
<artifactId>cloud-modules-event-process</artifactId>
|
||||||
|
|
||||||
<properties>
|
<properties>
|
||||||
<maven.compiler.source>17</maven.compiler.source>
|
<maven.compiler.source>17</maven.compiler.source>
|
||||||
|
@ -18,7 +18,7 @@
|
||||||
</properties>
|
</properties>
|
||||||
|
|
||||||
<description>
|
<description>
|
||||||
cloud-modules-data-process 数据处理
|
cloud-modules-event-process 事件处理
|
||||||
</description>
|
</description>
|
||||||
|
|
||||||
<dependencies>
|
<dependencies>
|
|
@ -1,4 +1,4 @@
|
||||||
package com.muyu.data.process;
|
package com.muyu.event.process;
|
||||||
|
|
||||||
import com.muyu.common.security.annotation.EnableCustomConfig;
|
import com.muyu.common.security.annotation.EnableCustomConfig;
|
||||||
import com.muyu.common.security.annotation.EnableMyFeignClients;
|
import com.muyu.common.security.annotation.EnableMyFeignClients;
|
||||||
|
@ -8,13 +8,13 @@ import org.springframework.boot.autoconfigure.SpringBootApplication;
|
||||||
/**
|
/**
|
||||||
* @Author: zi run
|
* @Author: zi run
|
||||||
* @Date 2024/9/28 22:31
|
* @Date 2024/9/28 22:31
|
||||||
* @Description 数据处理微服启动类
|
* @Description 事件处理微服启动类
|
||||||
*/
|
*/
|
||||||
@EnableCustomConfig
|
@EnableCustomConfig
|
||||||
@EnableMyFeignClients
|
@EnableMyFeignClients
|
||||||
@SpringBootApplication
|
@SpringBootApplication
|
||||||
public class CloudDataProcessApplication {
|
public class CloudEventProcessApplication {
|
||||||
public static void main(String[] args) {
|
public static void main(String[] args) {
|
||||||
SpringApplication.run(CloudDataProcessApplication.class, args);
|
SpringApplication.run(CloudEventProcessApplication.class, args);
|
||||||
}
|
}
|
||||||
}
|
}
|
|
@ -1,4 +1,4 @@
|
||||||
package com.muyu.data.process.basic.config;
|
package com.muyu.event.process.basic.config;
|
||||||
|
|
||||||
import lombok.extern.slf4j.Slf4j;
|
import lombok.extern.slf4j.Slf4j;
|
||||||
import org.apache.iotdb.session.pool.SessionPool;
|
import org.apache.iotdb.session.pool.SessionPool;
|
|
@ -1,7 +1,7 @@
|
||||||
package com.muyu.data.process.basic.service;
|
package com.muyu.event.process.basic.service;
|
||||||
|
|
||||||
import com.muyu.data.process.domain.dto.IoTDbRecordAble;
|
import com.muyu.event.process.domain.dto.IoTDbRecordAble;
|
||||||
import com.muyu.data.process.domain.dto.MeasurementSchemaValuesDTO;
|
import com.muyu.event.process.domain.dto.MeasurementSchemaValuesDTO;
|
||||||
import org.apache.iotdb.common.rpc.thrift.TAggregationType;
|
import org.apache.iotdb.common.rpc.thrift.TAggregationType;
|
||||||
import org.apache.iotdb.isession.SessionDataSet;
|
import org.apache.iotdb.isession.SessionDataSet;
|
||||||
import org.apache.iotdb.tsfile.file.metadata.enums.TSDataType;
|
import org.apache.iotdb.tsfile.file.metadata.enums.TSDataType;
|
|
@ -1,10 +1,10 @@
|
||||||
package com.muyu.data.process.basic.service.impl;
|
package com.muyu.event.process.basic.service.impl;
|
||||||
|
|
||||||
import com.alibaba.fastjson.JSON;
|
import com.alibaba.fastjson.JSON;
|
||||||
import com.muyu.data.process.basic.config.IoTDBSessionConfig;
|
import com.muyu.event.process.basic.config.IoTDBSessionConfig;
|
||||||
import com.muyu.data.process.basic.service.IoTDBService;
|
import com.muyu.event.process.basic.service.IoTDBService;
|
||||||
import com.muyu.data.process.domain.dto.IoTDbRecordAble;
|
import com.muyu.event.process.domain.dto.IoTDbRecordAble;
|
||||||
import com.muyu.data.process.domain.dto.MeasurementSchemaValuesDTO;
|
import com.muyu.event.process.domain.dto.MeasurementSchemaValuesDTO;
|
||||||
import lombok.RequiredArgsConstructor;
|
import lombok.RequiredArgsConstructor;
|
||||||
import lombok.SneakyThrows;
|
import lombok.SneakyThrows;
|
||||||
import lombok.extern.slf4j.Slf4j;
|
import lombok.extern.slf4j.Slf4j;
|
|
@ -1,4 +1,4 @@
|
||||||
package com.muyu.data.process.domain;
|
package com.muyu.event.process.domain;
|
||||||
|
|
||||||
import io.swagger.v3.oas.annotations.media.Schema;
|
import io.swagger.v3.oas.annotations.media.Schema;
|
||||||
import io.swagger.v3.oas.annotations.tags.Tag;
|
import io.swagger.v3.oas.annotations.tags.Tag;
|
|
@ -1,6 +1,6 @@
|
||||||
package com.muyu.data.process.domain;
|
package com.muyu.event.process.domain;
|
||||||
|
|
||||||
import com.muyu.data.process.domain.dto.IoTDbRecordAble;
|
import com.muyu.event.process.domain.dto.IoTDbRecordAble;
|
||||||
import lombok.Data;
|
import lombok.Data;
|
||||||
import lombok.EqualsAndHashCode;
|
import lombok.EqualsAndHashCode;
|
||||||
|
|
|
@ -1,4 +1,4 @@
|
||||||
package com.muyu.data.process.domain;
|
package com.muyu.event.process.domain;
|
||||||
|
|
||||||
import lombok.AllArgsConstructor;
|
import lombok.AllArgsConstructor;
|
||||||
import lombok.Builder;
|
import lombok.Builder;
|
|
@ -1,4 +1,4 @@
|
||||||
package com.muyu.data.process.domain.dto;
|
package com.muyu.event.process.domain.dto;
|
||||||
|
|
||||||
import lombok.AllArgsConstructor;
|
import lombok.AllArgsConstructor;
|
||||||
import lombok.Builder;
|
import lombok.Builder;
|
|
@ -1,4 +1,4 @@
|
||||||
package com.muyu.data.process.domain.dto;
|
package com.muyu.event.process.domain.dto;
|
||||||
|
|
||||||
import lombok.Data;
|
import lombok.Data;
|
||||||
|
|
|
@ -1,4 +1,4 @@
|
||||||
package com.muyu.data.process.domain.dto;
|
package com.muyu.event.process.domain.dto;
|
||||||
|
|
||||||
import lombok.AllArgsConstructor;
|
import lombok.AllArgsConstructor;
|
||||||
import lombok.Data;
|
import lombok.Data;
|
|
@ -11,7 +11,7 @@ nacos:
|
||||||
spring:
|
spring:
|
||||||
application:
|
application:
|
||||||
# 应用名称
|
# 应用名称
|
||||||
name: cloud-data-process
|
name: cloud-event-process
|
||||||
profiles:
|
profiles:
|
||||||
# 环境配置
|
# 环境配置
|
||||||
active: dev
|
active: dev
|
|
@ -1,7 +1,7 @@
|
||||||
<?xml version="1.0" encoding="UTF-8"?>
|
<?xml version="1.0" encoding="UTF-8"?>
|
||||||
<configuration scan="true" scanPeriod="60 seconds" debug="false">
|
<configuration scan="true" scanPeriod="60 seconds" debug="false">
|
||||||
<!-- 日志存放路径 -->
|
<!-- 日志存放路径 -->
|
||||||
<property name="log.path" value="logs/cloud-data-process"/>
|
<property name="log.path" value="logs/cloud-event-process"/>
|
||||||
<!-- 日志输出格式 -->
|
<!-- 日志输出格式 -->
|
||||||
<property name="log.pattern" value="%d{HH:mm:ss.SSS} [%thread] %-5level %logger{20} - [%method,%line] - %msg%n"/>
|
<property name="log.pattern" value="%d{HH:mm:ss.SSS} [%thread] %-5level %logger{20} - [%method,%line] - %msg%n"/>
|
||||||
|
|
|
@ -1,7 +1,7 @@
|
||||||
<?xml version="1.0" encoding="UTF-8"?>
|
<?xml version="1.0" encoding="UTF-8"?>
|
||||||
<configuration scan="true" scanPeriod="60 seconds" debug="false">
|
<configuration scan="true" scanPeriod="60 seconds" debug="false">
|
||||||
<!-- 日志存放路径 -->
|
<!-- 日志存放路径 -->
|
||||||
<property name="log.path" value="logs/cloud-data-process"/>
|
<property name="log.path" value="logs/cloud-event-process"/>
|
||||||
<!-- 日志输出格式 -->
|
<!-- 日志输出格式 -->
|
||||||
<property name="log.pattern" value="%d{HH:mm:ss.SSS} [%thread] %-5level %logger{20} - [%method,%line] - %msg%n"/>
|
<property name="log.pattern" value="%d{HH:mm:ss.SSS} [%thread] %-5level %logger{20} - [%method,%line] - %msg%n"/>
|
||||||
<property name="log.sky.pattern" value="%d{HH:mm:ss.SSS} %yellow([%tid]) [%thread] %-5level %logger{20} - [%method,%line] - %msg%n"/>
|
<property name="log.sky.pattern" value="%d{HH:mm:ss.SSS} %yellow([%tid]) [%thread] %-5level %logger{20} - [%method,%line] - %msg%n"/>
|
|
@ -1,7 +1,7 @@
|
||||||
<?xml version="1.0" encoding="UTF-8"?>
|
<?xml version="1.0" encoding="UTF-8"?>
|
||||||
<configuration scan="true" scanPeriod="60 seconds" debug="false">
|
<configuration scan="true" scanPeriod="60 seconds" debug="false">
|
||||||
<!-- 日志存放路径 -->
|
<!-- 日志存放路径 -->
|
||||||
<property name="log.path" value="logs/cloud-data-process"/>
|
<property name="log.path" value="logs/cloud-event-process"/>
|
||||||
<!-- 日志输出格式 -->
|
<!-- 日志输出格式 -->
|
||||||
<property name="log.pattern" value="%d{HH:mm:ss.SSS} [%thread] %-5level %logger{20} - [%method,%line] - %msg%n"/>
|
<property name="log.pattern" value="%d{HH:mm:ss.SSS} [%thread] %-5level %logger{20} - [%method,%line] - %msg%n"/>
|
||||||
<property name="log.sky.pattern" value="%d{HH:mm:ss.SSS} %yellow([%tid]) [%thread] %-5level %logger{20} - [%method,%line] - %msg%n"/>
|
<property name="log.sky.pattern" value="%d{HH:mm:ss.SSS} %yellow([%tid]) [%thread] %-5level %logger{20} - [%method,%line] - %msg%n"/>
|
|
@ -14,7 +14,7 @@
|
||||||
<module>cloud-modules-file</module>
|
<module>cloud-modules-file</module>
|
||||||
<module>cloud-modules-enterprise</module>
|
<module>cloud-modules-enterprise</module>
|
||||||
<module>cloud-weixin-mp</module>
|
<module>cloud-weixin-mp</module>
|
||||||
<module>cloud-modules-data-process</module>
|
<module>cloud-modules-event-process</module>
|
||||||
</modules>
|
</modules>
|
||||||
|
|
||||||
<artifactId>cloud-modules</artifactId>
|
<artifactId>cloud-modules</artifactId>
|
||||||
|
|
Loading…
Reference in New Issue