diff --git a/pom.xml b/pom.xml
index ec5ddc3..f02731e 100644
--- a/pom.xml
+++ b/pom.xml
@@ -74,11 +74,6 @@
4.5.13
-
- com.casic
- casic-admin-core
- 2.0.0.alpha
-
@@ -198,6 +193,25 @@
1.8
+
+
+ com.casic
+ casic-core
+ 2.0.0.alpha
+
+
+
+ com.casic
+ casic-admin-support
+ 2.0.0.alpha
+
+
+
+ com.casic
+ casic-admin-core
+ 2.0.0.alpha
+
+
diff --git a/pom.xml b/pom.xml
index ec5ddc3..f02731e 100644
--- a/pom.xml
+++ b/pom.xml
@@ -74,11 +74,6 @@
4.5.13
-
- com.casic
- casic-admin-core
- 2.0.0.alpha
-
@@ -198,6 +193,25 @@
1.8
+
+
+ com.casic
+ casic-core
+ 2.0.0.alpha
+
+
+
+ com.casic
+ casic-admin-support
+ 2.0.0.alpha
+
+
+
+ com.casic
+ casic-admin-core
+ 2.0.0.alpha
+
+
diff --git a/src/main/java/com/casic/CasicApplication.java b/src/main/java/com/casic/CasicApplication.java
index 9afd0b9..affdcb5 100644
--- a/src/main/java/com/casic/CasicApplication.java
+++ b/src/main/java/com/casic/CasicApplication.java
@@ -1,6 +1,7 @@
package com.casic;
import lombok.extern.slf4j.Slf4j;
+import org.mybatis.spring.annotation.MapperScan;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.autoconfigure.jdbc.DataSourceAutoConfiguration;
@@ -19,7 +20,9 @@
@Slf4j
@ComponentScan(basePackages= "com.casic.**")
+@MapperScan(basePackages = {"com.casic.**.dao", "com.casic.**.mapper"})
@SpringBootApplication
+@EnableTransactionManagement(proxyTargetClass = true)
public class CasicApplication {
public static void main(String[] args) {
log.info("CasicApplication is success!");
diff --git a/pom.xml b/pom.xml
index ec5ddc3..f02731e 100644
--- a/pom.xml
+++ b/pom.xml
@@ -74,11 +74,6 @@
4.5.13
-
- com.casic
- casic-admin-core
- 2.0.0.alpha
-
@@ -198,6 +193,25 @@
1.8
+
+
+ com.casic
+ casic-core
+ 2.0.0.alpha
+
+
+
+ com.casic
+ casic-admin-support
+ 2.0.0.alpha
+
+
+
+ com.casic
+ casic-admin-core
+ 2.0.0.alpha
+
+
diff --git a/src/main/java/com/casic/CasicApplication.java b/src/main/java/com/casic/CasicApplication.java
index 9afd0b9..affdcb5 100644
--- a/src/main/java/com/casic/CasicApplication.java
+++ b/src/main/java/com/casic/CasicApplication.java
@@ -1,6 +1,7 @@
package com.casic;
import lombok.extern.slf4j.Slf4j;
+import org.mybatis.spring.annotation.MapperScan;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.autoconfigure.jdbc.DataSourceAutoConfiguration;
@@ -19,7 +20,9 @@
@Slf4j
@ComponentScan(basePackages= "com.casic.**")
+@MapperScan(basePackages = {"com.casic.**.dao", "com.casic.**.mapper"})
@SpringBootApplication
+@EnableTransactionManagement(proxyTargetClass = true)
public class CasicApplication {
public static void main(String[] args) {
log.info("CasicApplication is success!");
diff --git a/src/main/java/com/casic/config/CorsConfig.java b/src/main/java/com/casic/config/CorsConfig.java
index 7d19680..1615fb8 100644
--- a/src/main/java/com/casic/config/CorsConfig.java
+++ b/src/main/java/com/casic/config/CorsConfig.java
@@ -1,31 +1,31 @@
-package com.casic.config;
-
-import org.springframework.context.annotation.Bean;
-import org.springframework.context.annotation.Configuration;
-import org.springframework.web.cors.CorsConfiguration;
-import org.springframework.web.cors.UrlBasedCorsConfigurationSource;
-import org.springframework.web.filter.CorsFilter;
-
-/**
- * 基础框架 - 跨域请求配置
- */
-@Configuration
-public class CorsConfig {
- @Bean
- public CorsFilter corsFilter() {
- UrlBasedCorsConfigurationSource source = new UrlBasedCorsConfigurationSource();
- source.registerCorsConfiguration("/**", buildConfig());
- return new CorsFilter(source);
- }
-
- private CorsConfiguration buildConfig() {
- CorsConfiguration corsConfiguration = new CorsConfiguration();
- // 1允许任何域名使用
- corsConfiguration.addAllowedOrigin("*");
- // 2允许任何头
- corsConfiguration.addAllowedHeader("*");
- // 3允许任何方法(post、get等)
- corsConfiguration.addAllowedMethod("*");
- return corsConfiguration;
- }
-}
\ No newline at end of file
+//package com.casic.config;
+//
+//import org.springframework.context.annotation.Bean;
+//import org.springframework.context.annotation.Configuration;
+//import org.springframework.web.cors.CorsConfiguration;
+//import org.springframework.web.cors.UrlBasedCorsConfigurationSource;
+//import org.springframework.web.filter.CorsFilter;
+//
+///**
+// * 基础框架 - 跨域请求配置
+// */
+//@Configuration
+//public class CorsConfig {
+// @Bean
+// public CorsFilter corsFilter() {
+// UrlBasedCorsConfigurationSource source = new UrlBasedCorsConfigurationSource();
+// source.registerCorsConfiguration("/**", buildConfig());
+// return new CorsFilter(source);
+// }
+//
+// private CorsConfiguration buildConfig() {
+// CorsConfiguration corsConfiguration = new CorsConfiguration();
+// // 1允许任何域名使用
+// corsConfiguration.addAllowedOrigin("*");
+// // 2允许任何头
+// corsConfiguration.addAllowedHeader("*");
+// // 3允许任何方法(post、get等)
+// corsConfiguration.addAllowedMethod("*");
+// return corsConfiguration;
+// }
+//}
\ No newline at end of file
diff --git a/pom.xml b/pom.xml
index ec5ddc3..f02731e 100644
--- a/pom.xml
+++ b/pom.xml
@@ -74,11 +74,6 @@
4.5.13
-
- com.casic
- casic-admin-core
- 2.0.0.alpha
-
@@ -198,6 +193,25 @@
1.8
+
+
+ com.casic
+ casic-core
+ 2.0.0.alpha
+
+
+
+ com.casic
+ casic-admin-support
+ 2.0.0.alpha
+
+
+
+ com.casic
+ casic-admin-core
+ 2.0.0.alpha
+
+
diff --git a/src/main/java/com/casic/CasicApplication.java b/src/main/java/com/casic/CasicApplication.java
index 9afd0b9..affdcb5 100644
--- a/src/main/java/com/casic/CasicApplication.java
+++ b/src/main/java/com/casic/CasicApplication.java
@@ -1,6 +1,7 @@
package com.casic;
import lombok.extern.slf4j.Slf4j;
+import org.mybatis.spring.annotation.MapperScan;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.autoconfigure.jdbc.DataSourceAutoConfiguration;
@@ -19,7 +20,9 @@
@Slf4j
@ComponentScan(basePackages= "com.casic.**")
+@MapperScan(basePackages = {"com.casic.**.dao", "com.casic.**.mapper"})
@SpringBootApplication
+@EnableTransactionManagement(proxyTargetClass = true)
public class CasicApplication {
public static void main(String[] args) {
log.info("CasicApplication is success!");
diff --git a/src/main/java/com/casic/config/CorsConfig.java b/src/main/java/com/casic/config/CorsConfig.java
index 7d19680..1615fb8 100644
--- a/src/main/java/com/casic/config/CorsConfig.java
+++ b/src/main/java/com/casic/config/CorsConfig.java
@@ -1,31 +1,31 @@
-package com.casic.config;
-
-import org.springframework.context.annotation.Bean;
-import org.springframework.context.annotation.Configuration;
-import org.springframework.web.cors.CorsConfiguration;
-import org.springframework.web.cors.UrlBasedCorsConfigurationSource;
-import org.springframework.web.filter.CorsFilter;
-
-/**
- * 基础框架 - 跨域请求配置
- */
-@Configuration
-public class CorsConfig {
- @Bean
- public CorsFilter corsFilter() {
- UrlBasedCorsConfigurationSource source = new UrlBasedCorsConfigurationSource();
- source.registerCorsConfiguration("/**", buildConfig());
- return new CorsFilter(source);
- }
-
- private CorsConfiguration buildConfig() {
- CorsConfiguration corsConfiguration = new CorsConfiguration();
- // 1允许任何域名使用
- corsConfiguration.addAllowedOrigin("*");
- // 2允许任何头
- corsConfiguration.addAllowedHeader("*");
- // 3允许任何方法(post、get等)
- corsConfiguration.addAllowedMethod("*");
- return corsConfiguration;
- }
-}
\ No newline at end of file
+//package com.casic.config;
+//
+//import org.springframework.context.annotation.Bean;
+//import org.springframework.context.annotation.Configuration;
+//import org.springframework.web.cors.CorsConfiguration;
+//import org.springframework.web.cors.UrlBasedCorsConfigurationSource;
+//import org.springframework.web.filter.CorsFilter;
+//
+///**
+// * 基础框架 - 跨域请求配置
+// */
+//@Configuration
+//public class CorsConfig {
+// @Bean
+// public CorsFilter corsFilter() {
+// UrlBasedCorsConfigurationSource source = new UrlBasedCorsConfigurationSource();
+// source.registerCorsConfiguration("/**", buildConfig());
+// return new CorsFilter(source);
+// }
+//
+// private CorsConfiguration buildConfig() {
+// CorsConfiguration corsConfiguration = new CorsConfiguration();
+// // 1允许任何域名使用
+// corsConfiguration.addAllowedOrigin("*");
+// // 2允许任何头
+// corsConfiguration.addAllowedHeader("*");
+// // 3允许任何方法(post、get等)
+// corsConfiguration.addAllowedMethod("*");
+// return corsConfiguration;
+// }
+//}
\ No newline at end of file
diff --git a/src/main/java/com/casic/config/dto/RoleDto.java b/src/main/java/com/casic/config/dto/RoleDto.java
new file mode 100644
index 0000000..ca08f84
--- /dev/null
+++ b/src/main/java/com/casic/config/dto/RoleDto.java
@@ -0,0 +1,11 @@
+package com.casic.config.dto;
+
+import lombok.Data;
+
+@Data
+public class RoleDto {
+
+ private Long id;
+ private String name;
+
+}
diff --git a/pom.xml b/pom.xml
index ec5ddc3..f02731e 100644
--- a/pom.xml
+++ b/pom.xml
@@ -74,11 +74,6 @@
4.5.13
-
- com.casic
- casic-admin-core
- 2.0.0.alpha
-
@@ -198,6 +193,25 @@
1.8
+
+
+ com.casic
+ casic-core
+ 2.0.0.alpha
+
+
+
+ com.casic
+ casic-admin-support
+ 2.0.0.alpha
+
+
+
+ com.casic
+ casic-admin-core
+ 2.0.0.alpha
+
+
diff --git a/src/main/java/com/casic/CasicApplication.java b/src/main/java/com/casic/CasicApplication.java
index 9afd0b9..affdcb5 100644
--- a/src/main/java/com/casic/CasicApplication.java
+++ b/src/main/java/com/casic/CasicApplication.java
@@ -1,6 +1,7 @@
package com.casic;
import lombok.extern.slf4j.Slf4j;
+import org.mybatis.spring.annotation.MapperScan;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.autoconfigure.jdbc.DataSourceAutoConfiguration;
@@ -19,7 +20,9 @@
@Slf4j
@ComponentScan(basePackages= "com.casic.**")
+@MapperScan(basePackages = {"com.casic.**.dao", "com.casic.**.mapper"})
@SpringBootApplication
+@EnableTransactionManagement(proxyTargetClass = true)
public class CasicApplication {
public static void main(String[] args) {
log.info("CasicApplication is success!");
diff --git a/src/main/java/com/casic/config/CorsConfig.java b/src/main/java/com/casic/config/CorsConfig.java
index 7d19680..1615fb8 100644
--- a/src/main/java/com/casic/config/CorsConfig.java
+++ b/src/main/java/com/casic/config/CorsConfig.java
@@ -1,31 +1,31 @@
-package com.casic.config;
-
-import org.springframework.context.annotation.Bean;
-import org.springframework.context.annotation.Configuration;
-import org.springframework.web.cors.CorsConfiguration;
-import org.springframework.web.cors.UrlBasedCorsConfigurationSource;
-import org.springframework.web.filter.CorsFilter;
-
-/**
- * 基础框架 - 跨域请求配置
- */
-@Configuration
-public class CorsConfig {
- @Bean
- public CorsFilter corsFilter() {
- UrlBasedCorsConfigurationSource source = new UrlBasedCorsConfigurationSource();
- source.registerCorsConfiguration("/**", buildConfig());
- return new CorsFilter(source);
- }
-
- private CorsConfiguration buildConfig() {
- CorsConfiguration corsConfiguration = new CorsConfiguration();
- // 1允许任何域名使用
- corsConfiguration.addAllowedOrigin("*");
- // 2允许任何头
- corsConfiguration.addAllowedHeader("*");
- // 3允许任何方法(post、get等)
- corsConfiguration.addAllowedMethod("*");
- return corsConfiguration;
- }
-}
\ No newline at end of file
+//package com.casic.config;
+//
+//import org.springframework.context.annotation.Bean;
+//import org.springframework.context.annotation.Configuration;
+//import org.springframework.web.cors.CorsConfiguration;
+//import org.springframework.web.cors.UrlBasedCorsConfigurationSource;
+//import org.springframework.web.filter.CorsFilter;
+//
+///**
+// * 基础框架 - 跨域请求配置
+// */
+//@Configuration
+//public class CorsConfig {
+// @Bean
+// public CorsFilter corsFilter() {
+// UrlBasedCorsConfigurationSource source = new UrlBasedCorsConfigurationSource();
+// source.registerCorsConfiguration("/**", buildConfig());
+// return new CorsFilter(source);
+// }
+//
+// private CorsConfiguration buildConfig() {
+// CorsConfiguration corsConfiguration = new CorsConfiguration();
+// // 1允许任何域名使用
+// corsConfiguration.addAllowedOrigin("*");
+// // 2允许任何头
+// corsConfiguration.addAllowedHeader("*");
+// // 3允许任何方法(post、get等)
+// corsConfiguration.addAllowedMethod("*");
+// return corsConfiguration;
+// }
+//}
\ No newline at end of file
diff --git a/src/main/java/com/casic/config/dto/RoleDto.java b/src/main/java/com/casic/config/dto/RoleDto.java
new file mode 100644
index 0000000..ca08f84
--- /dev/null
+++ b/src/main/java/com/casic/config/dto/RoleDto.java
@@ -0,0 +1,11 @@
+package com.casic.config.dto;
+
+import lombok.Data;
+
+@Data
+public class RoleDto {
+
+ private Long id;
+ private String name;
+
+}
diff --git a/src/main/java/com/casic/config/task/TaskConfigurer.java b/src/main/java/com/casic/config/task/TaskConfigurer.java
index 699c0e3..5a3a029 100644
--- a/src/main/java/com/casic/config/task/TaskConfigurer.java
+++ b/src/main/java/com/casic/config/task/TaskConfigurer.java
@@ -1,6 +1,7 @@
package com.casic.config.task;
import com.casic.service.DeviceDataService;
+import com.casic.service.IPartitionStrategyService;
import com.casic.service.UserDataDelayReceiver;
import lombok.RequiredArgsConstructor;
import org.springframework.beans.factory.annotation.Autowired;
@@ -24,18 +25,30 @@
private String onlineStateCron;
@Value("${casic.device.transfer-user.cron}")
private String transferUserCron;
-
+ @Value("${casic.device.partition.cron}")
+ private String partitionCron;
private final DeviceDataService deviceDataService;
private final UserDataDelayReceiver userDataDelayReceiver;
+ private final IPartitionStrategyService partitionStrategyService;
@Override
public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
- TriggerTask triggrtTask = new TriggerTask(nextDayDevice(),
+ TriggerTask onlineStateTask = new TriggerTask(nextDayDevice(),
triggerContext -> {
return new CronTrigger(onlineStateCron).nextExecutionTime(triggerContext);
});
- taskRegistrar.addTriggerTask(triggrtTask);
+ TriggerTask transferUserTask = new TriggerTask(getUserData(),
+ triggerContext -> {
+ return new CronTrigger(transferUserCron).nextExecutionTime(triggerContext);
+ });
+ TriggerTask partitionTask = new TriggerTask(createPartition(),
+ triggerContext -> {
+ return new CronTrigger(partitionCron).nextExecutionTime(triggerContext);
+ });
+ taskRegistrar.addTriggerTask(onlineStateTask);
+ taskRegistrar.addTriggerTask(transferUserTask);
+ taskRegistrar.addTriggerTask(partitionTask);
}
private Runnable nextDayDevice() {
@@ -57,6 +70,18 @@
userDataDelayReceiver.saveNewUserData();
}
};
+ }
+
+ /**
+ * 定时同步普光
+ */
+ private Runnable createPartition() {
+ return new Runnable() {
+ @Override
+ public void run() {
+ partitionStrategyService.createPartition("DATA_H2S", "data_h2s_log");
+ }
+ };
}
diff --git a/pom.xml b/pom.xml
index ec5ddc3..f02731e 100644
--- a/pom.xml
+++ b/pom.xml
@@ -74,11 +74,6 @@
4.5.13
-
- com.casic
- casic-admin-core
- 2.0.0.alpha
-
@@ -198,6 +193,25 @@
1.8
+
+
+ com.casic
+ casic-core
+ 2.0.0.alpha
+
+
+
+ com.casic
+ casic-admin-support
+ 2.0.0.alpha
+
+
+
+ com.casic
+ casic-admin-core
+ 2.0.0.alpha
+
+
diff --git a/src/main/java/com/casic/CasicApplication.java b/src/main/java/com/casic/CasicApplication.java
index 9afd0b9..affdcb5 100644
--- a/src/main/java/com/casic/CasicApplication.java
+++ b/src/main/java/com/casic/CasicApplication.java
@@ -1,6 +1,7 @@
package com.casic;
import lombok.extern.slf4j.Slf4j;
+import org.mybatis.spring.annotation.MapperScan;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.autoconfigure.jdbc.DataSourceAutoConfiguration;
@@ -19,7 +20,9 @@
@Slf4j
@ComponentScan(basePackages= "com.casic.**")
+@MapperScan(basePackages = {"com.casic.**.dao", "com.casic.**.mapper"})
@SpringBootApplication
+@EnableTransactionManagement(proxyTargetClass = true)
public class CasicApplication {
public static void main(String[] args) {
log.info("CasicApplication is success!");
diff --git a/src/main/java/com/casic/config/CorsConfig.java b/src/main/java/com/casic/config/CorsConfig.java
index 7d19680..1615fb8 100644
--- a/src/main/java/com/casic/config/CorsConfig.java
+++ b/src/main/java/com/casic/config/CorsConfig.java
@@ -1,31 +1,31 @@
-package com.casic.config;
-
-import org.springframework.context.annotation.Bean;
-import org.springframework.context.annotation.Configuration;
-import org.springframework.web.cors.CorsConfiguration;
-import org.springframework.web.cors.UrlBasedCorsConfigurationSource;
-import org.springframework.web.filter.CorsFilter;
-
-/**
- * 基础框架 - 跨域请求配置
- */
-@Configuration
-public class CorsConfig {
- @Bean
- public CorsFilter corsFilter() {
- UrlBasedCorsConfigurationSource source = new UrlBasedCorsConfigurationSource();
- source.registerCorsConfiguration("/**", buildConfig());
- return new CorsFilter(source);
- }
-
- private CorsConfiguration buildConfig() {
- CorsConfiguration corsConfiguration = new CorsConfiguration();
- // 1允许任何域名使用
- corsConfiguration.addAllowedOrigin("*");
- // 2允许任何头
- corsConfiguration.addAllowedHeader("*");
- // 3允许任何方法(post、get等)
- corsConfiguration.addAllowedMethod("*");
- return corsConfiguration;
- }
-}
\ No newline at end of file
+//package com.casic.config;
+//
+//import org.springframework.context.annotation.Bean;
+//import org.springframework.context.annotation.Configuration;
+//import org.springframework.web.cors.CorsConfiguration;
+//import org.springframework.web.cors.UrlBasedCorsConfigurationSource;
+//import org.springframework.web.filter.CorsFilter;
+//
+///**
+// * 基础框架 - 跨域请求配置
+// */
+//@Configuration
+//public class CorsConfig {
+// @Bean
+// public CorsFilter corsFilter() {
+// UrlBasedCorsConfigurationSource source = new UrlBasedCorsConfigurationSource();
+// source.registerCorsConfiguration("/**", buildConfig());
+// return new CorsFilter(source);
+// }
+//
+// private CorsConfiguration buildConfig() {
+// CorsConfiguration corsConfiguration = new CorsConfiguration();
+// // 1允许任何域名使用
+// corsConfiguration.addAllowedOrigin("*");
+// // 2允许任何头
+// corsConfiguration.addAllowedHeader("*");
+// // 3允许任何方法(post、get等)
+// corsConfiguration.addAllowedMethod("*");
+// return corsConfiguration;
+// }
+//}
\ No newline at end of file
diff --git a/src/main/java/com/casic/config/dto/RoleDto.java b/src/main/java/com/casic/config/dto/RoleDto.java
new file mode 100644
index 0000000..ca08f84
--- /dev/null
+++ b/src/main/java/com/casic/config/dto/RoleDto.java
@@ -0,0 +1,11 @@
+package com.casic.config.dto;
+
+import lombok.Data;
+
+@Data
+public class RoleDto {
+
+ private Long id;
+ private String name;
+
+}
diff --git a/src/main/java/com/casic/config/task/TaskConfigurer.java b/src/main/java/com/casic/config/task/TaskConfigurer.java
index 699c0e3..5a3a029 100644
--- a/src/main/java/com/casic/config/task/TaskConfigurer.java
+++ b/src/main/java/com/casic/config/task/TaskConfigurer.java
@@ -1,6 +1,7 @@
package com.casic.config.task;
import com.casic.service.DeviceDataService;
+import com.casic.service.IPartitionStrategyService;
import com.casic.service.UserDataDelayReceiver;
import lombok.RequiredArgsConstructor;
import org.springframework.beans.factory.annotation.Autowired;
@@ -24,18 +25,30 @@
private String onlineStateCron;
@Value("${casic.device.transfer-user.cron}")
private String transferUserCron;
-
+ @Value("${casic.device.partition.cron}")
+ private String partitionCron;
private final DeviceDataService deviceDataService;
private final UserDataDelayReceiver userDataDelayReceiver;
+ private final IPartitionStrategyService partitionStrategyService;
@Override
public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
- TriggerTask triggrtTask = new TriggerTask(nextDayDevice(),
+ TriggerTask onlineStateTask = new TriggerTask(nextDayDevice(),
triggerContext -> {
return new CronTrigger(onlineStateCron).nextExecutionTime(triggerContext);
});
- taskRegistrar.addTriggerTask(triggrtTask);
+ TriggerTask transferUserTask = new TriggerTask(getUserData(),
+ triggerContext -> {
+ return new CronTrigger(transferUserCron).nextExecutionTime(triggerContext);
+ });
+ TriggerTask partitionTask = new TriggerTask(createPartition(),
+ triggerContext -> {
+ return new CronTrigger(partitionCron).nextExecutionTime(triggerContext);
+ });
+ taskRegistrar.addTriggerTask(onlineStateTask);
+ taskRegistrar.addTriggerTask(transferUserTask);
+ taskRegistrar.addTriggerTask(partitionTask);
}
private Runnable nextDayDevice() {
@@ -57,6 +70,18 @@
userDataDelayReceiver.saveNewUserData();
}
};
+ }
+
+ /**
+ * 定时同步普光
+ */
+ private Runnable createPartition() {
+ return new Runnable() {
+ @Override
+ public void run() {
+ partitionStrategyService.createPartition("DATA_H2S", "data_h2s_log");
+ }
+ };
}
diff --git a/src/main/java/com/casic/controller/DeviceDataController.java b/src/main/java/com/casic/controller/DeviceDataController.java
index d7e3722..e6ae7bc 100644
--- a/src/main/java/com/casic/controller/DeviceDataController.java
+++ b/src/main/java/com/casic/controller/DeviceDataController.java
@@ -1,40 +1,40 @@
-package com.casic.controller;
-
-import com.alibaba.fastjson.JSON;
-import com.casic.service.DeviceDataService;
-import com.casic.service.ThirdDataService;
-import lombok.RequiredArgsConstructor;
-import org.springframework.web.bind.annotation.*;
-
-import java.util.Map;
-
-@RestController
-@RequestMapping("/device")
-@RequiredArgsConstructor
-public class DeviceDataController {
-
- private final DeviceDataService deviceDataService;
-
- @RequestMapping("/recent-data")
- public Object getDeviceRecentData(@RequestParam(value = "deviceType", required = true) String deviceType,
- @RequestParam(value = "recentNum", required = true) String recentNum,
- @RequestParam(value = "devcode", required = false) String devcode) {
- return deviceDataService.getDeviceRecentData(deviceType, recentNum, devcode);
- }
-
- @RequestMapping("/data/list-page")
- public Object getDeviceListPage(@RequestParam(value = "deviceType", required = true) String deviceType,
- @RequestParam(value = "currentIndex", required = true) Integer currentIndex,
- @RequestParam(value = "pageSize", required = true) Integer pageSize,
- @RequestParam(value = "devcode", required = false) String devcode) {
- return deviceDataService.getDeviceListPage(deviceType, currentIndex, pageSize, devcode);
- }
-
- @RequestMapping("/level/{deviceType}")
- public Object getLevelList(@PathVariable("deviceType")String deviceType) {
- return deviceDataService.getLevel(deviceType);
- }
-
-
-
-}
+//package com.casic.controller;
+//
+//import com.alibaba.fastjson.JSON;
+//import com.casic.service.DeviceDataService;
+//import com.casic.service.ThirdDataService;
+//import lombok.RequiredArgsConstructor;
+//import org.springframework.web.bind.annotation.*;
+//
+//import java.util.Map;
+//
+//@RestController
+//@RequestMapping("/device")
+//@RequiredArgsConstructor
+//public class DeviceDataController {
+//
+// private final DeviceDataService deviceDataService;
+//
+// @RequestMapping("/recent-data")
+// public Object getDeviceRecentData(@RequestParam(value = "deviceType", required = true) String deviceType,
+// @RequestParam(value = "recentNum", required = true) String recentNum,
+// @RequestParam(value = "devcode", required = false) String devcode) {
+// return deviceDataService.getDeviceRecentData(deviceType, recentNum, devcode);
+// }
+//
+// @RequestMapping("/data/list-page")
+// public Object getDeviceListPage(@RequestParam(value = "deviceType", required = true) String deviceType,
+// @RequestParam(value = "currentIndex", required = true) Integer currentIndex,
+// @RequestParam(value = "pageSize", required = true) Integer pageSize,
+// @RequestParam(value = "devcode", required = false) String devcode) {
+// return deviceDataService.getDeviceListPage(deviceType, currentIndex, pageSize, devcode);
+// }
+//
+// @RequestMapping("/level/{deviceType}")
+// public Object getLevelList(@PathVariable("deviceType")String deviceType) {
+// return deviceDataService.getLevel(deviceType);
+// }
+//
+//
+//
+//}
diff --git a/pom.xml b/pom.xml
index ec5ddc3..f02731e 100644
--- a/pom.xml
+++ b/pom.xml
@@ -74,11 +74,6 @@
4.5.13
-
- com.casic
- casic-admin-core
- 2.0.0.alpha
-
@@ -198,6 +193,25 @@
1.8
+
+
+ com.casic
+ casic-core
+ 2.0.0.alpha
+
+
+
+ com.casic
+ casic-admin-support
+ 2.0.0.alpha
+
+
+
+ com.casic
+ casic-admin-core
+ 2.0.0.alpha
+
+
diff --git a/src/main/java/com/casic/CasicApplication.java b/src/main/java/com/casic/CasicApplication.java
index 9afd0b9..affdcb5 100644
--- a/src/main/java/com/casic/CasicApplication.java
+++ b/src/main/java/com/casic/CasicApplication.java
@@ -1,6 +1,7 @@
package com.casic;
import lombok.extern.slf4j.Slf4j;
+import org.mybatis.spring.annotation.MapperScan;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.autoconfigure.jdbc.DataSourceAutoConfiguration;
@@ -19,7 +20,9 @@
@Slf4j
@ComponentScan(basePackages= "com.casic.**")
+@MapperScan(basePackages = {"com.casic.**.dao", "com.casic.**.mapper"})
@SpringBootApplication
+@EnableTransactionManagement(proxyTargetClass = true)
public class CasicApplication {
public static void main(String[] args) {
log.info("CasicApplication is success!");
diff --git a/src/main/java/com/casic/config/CorsConfig.java b/src/main/java/com/casic/config/CorsConfig.java
index 7d19680..1615fb8 100644
--- a/src/main/java/com/casic/config/CorsConfig.java
+++ b/src/main/java/com/casic/config/CorsConfig.java
@@ -1,31 +1,31 @@
-package com.casic.config;
-
-import org.springframework.context.annotation.Bean;
-import org.springframework.context.annotation.Configuration;
-import org.springframework.web.cors.CorsConfiguration;
-import org.springframework.web.cors.UrlBasedCorsConfigurationSource;
-import org.springframework.web.filter.CorsFilter;
-
-/**
- * 基础框架 - 跨域请求配置
- */
-@Configuration
-public class CorsConfig {
- @Bean
- public CorsFilter corsFilter() {
- UrlBasedCorsConfigurationSource source = new UrlBasedCorsConfigurationSource();
- source.registerCorsConfiguration("/**", buildConfig());
- return new CorsFilter(source);
- }
-
- private CorsConfiguration buildConfig() {
- CorsConfiguration corsConfiguration = new CorsConfiguration();
- // 1允许任何域名使用
- corsConfiguration.addAllowedOrigin("*");
- // 2允许任何头
- corsConfiguration.addAllowedHeader("*");
- // 3允许任何方法(post、get等)
- corsConfiguration.addAllowedMethod("*");
- return corsConfiguration;
- }
-}
\ No newline at end of file
+//package com.casic.config;
+//
+//import org.springframework.context.annotation.Bean;
+//import org.springframework.context.annotation.Configuration;
+//import org.springframework.web.cors.CorsConfiguration;
+//import org.springframework.web.cors.UrlBasedCorsConfigurationSource;
+//import org.springframework.web.filter.CorsFilter;
+//
+///**
+// * 基础框架 - 跨域请求配置
+// */
+//@Configuration
+//public class CorsConfig {
+// @Bean
+// public CorsFilter corsFilter() {
+// UrlBasedCorsConfigurationSource source = new UrlBasedCorsConfigurationSource();
+// source.registerCorsConfiguration("/**", buildConfig());
+// return new CorsFilter(source);
+// }
+//
+// private CorsConfiguration buildConfig() {
+// CorsConfiguration corsConfiguration = new CorsConfiguration();
+// // 1允许任何域名使用
+// corsConfiguration.addAllowedOrigin("*");
+// // 2允许任何头
+// corsConfiguration.addAllowedHeader("*");
+// // 3允许任何方法(post、get等)
+// corsConfiguration.addAllowedMethod("*");
+// return corsConfiguration;
+// }
+//}
\ No newline at end of file
diff --git a/src/main/java/com/casic/config/dto/RoleDto.java b/src/main/java/com/casic/config/dto/RoleDto.java
new file mode 100644
index 0000000..ca08f84
--- /dev/null
+++ b/src/main/java/com/casic/config/dto/RoleDto.java
@@ -0,0 +1,11 @@
+package com.casic.config.dto;
+
+import lombok.Data;
+
+@Data
+public class RoleDto {
+
+ private Long id;
+ private String name;
+
+}
diff --git a/src/main/java/com/casic/config/task/TaskConfigurer.java b/src/main/java/com/casic/config/task/TaskConfigurer.java
index 699c0e3..5a3a029 100644
--- a/src/main/java/com/casic/config/task/TaskConfigurer.java
+++ b/src/main/java/com/casic/config/task/TaskConfigurer.java
@@ -1,6 +1,7 @@
package com.casic.config.task;
import com.casic.service.DeviceDataService;
+import com.casic.service.IPartitionStrategyService;
import com.casic.service.UserDataDelayReceiver;
import lombok.RequiredArgsConstructor;
import org.springframework.beans.factory.annotation.Autowired;
@@ -24,18 +25,30 @@
private String onlineStateCron;
@Value("${casic.device.transfer-user.cron}")
private String transferUserCron;
-
+ @Value("${casic.device.partition.cron}")
+ private String partitionCron;
private final DeviceDataService deviceDataService;
private final UserDataDelayReceiver userDataDelayReceiver;
+ private final IPartitionStrategyService partitionStrategyService;
@Override
public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
- TriggerTask triggrtTask = new TriggerTask(nextDayDevice(),
+ TriggerTask onlineStateTask = new TriggerTask(nextDayDevice(),
triggerContext -> {
return new CronTrigger(onlineStateCron).nextExecutionTime(triggerContext);
});
- taskRegistrar.addTriggerTask(triggrtTask);
+ TriggerTask transferUserTask = new TriggerTask(getUserData(),
+ triggerContext -> {
+ return new CronTrigger(transferUserCron).nextExecutionTime(triggerContext);
+ });
+ TriggerTask partitionTask = new TriggerTask(createPartition(),
+ triggerContext -> {
+ return new CronTrigger(partitionCron).nextExecutionTime(triggerContext);
+ });
+ taskRegistrar.addTriggerTask(onlineStateTask);
+ taskRegistrar.addTriggerTask(transferUserTask);
+ taskRegistrar.addTriggerTask(partitionTask);
}
private Runnable nextDayDevice() {
@@ -57,6 +70,18 @@
userDataDelayReceiver.saveNewUserData();
}
};
+ }
+
+ /**
+ * 定时同步普光
+ */
+ private Runnable createPartition() {
+ return new Runnable() {
+ @Override
+ public void run() {
+ partitionStrategyService.createPartition("DATA_H2S", "data_h2s_log");
+ }
+ };
}
diff --git a/src/main/java/com/casic/controller/DeviceDataController.java b/src/main/java/com/casic/controller/DeviceDataController.java
index d7e3722..e6ae7bc 100644
--- a/src/main/java/com/casic/controller/DeviceDataController.java
+++ b/src/main/java/com/casic/controller/DeviceDataController.java
@@ -1,40 +1,40 @@
-package com.casic.controller;
-
-import com.alibaba.fastjson.JSON;
-import com.casic.service.DeviceDataService;
-import com.casic.service.ThirdDataService;
-import lombok.RequiredArgsConstructor;
-import org.springframework.web.bind.annotation.*;
-
-import java.util.Map;
-
-@RestController
-@RequestMapping("/device")
-@RequiredArgsConstructor
-public class DeviceDataController {
-
- private final DeviceDataService deviceDataService;
-
- @RequestMapping("/recent-data")
- public Object getDeviceRecentData(@RequestParam(value = "deviceType", required = true) String deviceType,
- @RequestParam(value = "recentNum", required = true) String recentNum,
- @RequestParam(value = "devcode", required = false) String devcode) {
- return deviceDataService.getDeviceRecentData(deviceType, recentNum, devcode);
- }
-
- @RequestMapping("/data/list-page")
- public Object getDeviceListPage(@RequestParam(value = "deviceType", required = true) String deviceType,
- @RequestParam(value = "currentIndex", required = true) Integer currentIndex,
- @RequestParam(value = "pageSize", required = true) Integer pageSize,
- @RequestParam(value = "devcode", required = false) String devcode) {
- return deviceDataService.getDeviceListPage(deviceType, currentIndex, pageSize, devcode);
- }
-
- @RequestMapping("/level/{deviceType}")
- public Object getLevelList(@PathVariable("deviceType")String deviceType) {
- return deviceDataService.getLevel(deviceType);
- }
-
-
-
-}
+//package com.casic.controller;
+//
+//import com.alibaba.fastjson.JSON;
+//import com.casic.service.DeviceDataService;
+//import com.casic.service.ThirdDataService;
+//import lombok.RequiredArgsConstructor;
+//import org.springframework.web.bind.annotation.*;
+//
+//import java.util.Map;
+//
+//@RestController
+//@RequestMapping("/device")
+//@RequiredArgsConstructor
+//public class DeviceDataController {
+//
+// private final DeviceDataService deviceDataService;
+//
+// @RequestMapping("/recent-data")
+// public Object getDeviceRecentData(@RequestParam(value = "deviceType", required = true) String deviceType,
+// @RequestParam(value = "recentNum", required = true) String recentNum,
+// @RequestParam(value = "devcode", required = false) String devcode) {
+// return deviceDataService.getDeviceRecentData(deviceType, recentNum, devcode);
+// }
+//
+// @RequestMapping("/data/list-page")
+// public Object getDeviceListPage(@RequestParam(value = "deviceType", required = true) String deviceType,
+// @RequestParam(value = "currentIndex", required = true) Integer currentIndex,
+// @RequestParam(value = "pageSize", required = true) Integer pageSize,
+// @RequestParam(value = "devcode", required = false) String devcode) {
+// return deviceDataService.getDeviceListPage(deviceType, currentIndex, pageSize, devcode);
+// }
+//
+// @RequestMapping("/level/{deviceType}")
+// public Object getLevelList(@PathVariable("deviceType")String deviceType) {
+// return deviceDataService.getLevel(deviceType);
+// }
+//
+//
+//
+//}
diff --git a/src/main/java/com/casic/dao/PartitionStrategyMapper.java b/src/main/java/com/casic/dao/PartitionStrategyMapper.java
new file mode 100644
index 0000000..a9481d0
--- /dev/null
+++ b/src/main/java/com/casic/dao/PartitionStrategyMapper.java
@@ -0,0 +1,44 @@
+package com.casic.dao;
+
+import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
+
+import java.util.Date;
+
+/**
+ * 分区mapper
+ *
+ * @author lwh
+ */
+@Mapper
+public interface PartitionStrategyMapper {
+
+ /**
+ * 当前表最大分区查询
+ *
+ * @param tableName 分区表名称
+ * @return
+ */
+ String selectMaxId(@Param("tableName") String tableName, @Param("tableOwner") String tableOwner);
+
+ /**
+ * 增加表分区
+ *
+ * @param tableName 表名称
+ * @param partitionName 分区名称
+ * @param time 分区最大值
+ */
+ void createPartition(@Param("tableName") String tableName, @Param("partitionName") String partitionName,
+ @Param("time") String time, @Param("storage") String storage);
+
+ /**
+ * 创建表空间
+ *
+ * @param tableSpaceName 表空间名称
+ * @param dataFilePath 文件地址
+ * @param tableSpaceSize 表空间大小(单位 M)
+ */
+ void createTableSpace(@Param("tableSpaceName") String tableSpaceName, @Param("dataFilePath") String dataFilePath, @Param("tableSpaceSize") Integer tableSpaceSize);
+
+
+}
diff --git a/pom.xml b/pom.xml
index ec5ddc3..f02731e 100644
--- a/pom.xml
+++ b/pom.xml
@@ -74,11 +74,6 @@
4.5.13
-
- com.casic
- casic-admin-core
- 2.0.0.alpha
-
@@ -198,6 +193,25 @@
1.8
+
+
+ com.casic
+ casic-core
+ 2.0.0.alpha
+
+
+
+ com.casic
+ casic-admin-support
+ 2.0.0.alpha
+
+
+
+ com.casic
+ casic-admin-core
+ 2.0.0.alpha
+
+
diff --git a/src/main/java/com/casic/CasicApplication.java b/src/main/java/com/casic/CasicApplication.java
index 9afd0b9..affdcb5 100644
--- a/src/main/java/com/casic/CasicApplication.java
+++ b/src/main/java/com/casic/CasicApplication.java
@@ -1,6 +1,7 @@
package com.casic;
import lombok.extern.slf4j.Slf4j;
+import org.mybatis.spring.annotation.MapperScan;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.autoconfigure.jdbc.DataSourceAutoConfiguration;
@@ -19,7 +20,9 @@
@Slf4j
@ComponentScan(basePackages= "com.casic.**")
+@MapperScan(basePackages = {"com.casic.**.dao", "com.casic.**.mapper"})
@SpringBootApplication
+@EnableTransactionManagement(proxyTargetClass = true)
public class CasicApplication {
public static void main(String[] args) {
log.info("CasicApplication is success!");
diff --git a/src/main/java/com/casic/config/CorsConfig.java b/src/main/java/com/casic/config/CorsConfig.java
index 7d19680..1615fb8 100644
--- a/src/main/java/com/casic/config/CorsConfig.java
+++ b/src/main/java/com/casic/config/CorsConfig.java
@@ -1,31 +1,31 @@
-package com.casic.config;
-
-import org.springframework.context.annotation.Bean;
-import org.springframework.context.annotation.Configuration;
-import org.springframework.web.cors.CorsConfiguration;
-import org.springframework.web.cors.UrlBasedCorsConfigurationSource;
-import org.springframework.web.filter.CorsFilter;
-
-/**
- * 基础框架 - 跨域请求配置
- */
-@Configuration
-public class CorsConfig {
- @Bean
- public CorsFilter corsFilter() {
- UrlBasedCorsConfigurationSource source = new UrlBasedCorsConfigurationSource();
- source.registerCorsConfiguration("/**", buildConfig());
- return new CorsFilter(source);
- }
-
- private CorsConfiguration buildConfig() {
- CorsConfiguration corsConfiguration = new CorsConfiguration();
- // 1允许任何域名使用
- corsConfiguration.addAllowedOrigin("*");
- // 2允许任何头
- corsConfiguration.addAllowedHeader("*");
- // 3允许任何方法(post、get等)
- corsConfiguration.addAllowedMethod("*");
- return corsConfiguration;
- }
-}
\ No newline at end of file
+//package com.casic.config;
+//
+//import org.springframework.context.annotation.Bean;
+//import org.springframework.context.annotation.Configuration;
+//import org.springframework.web.cors.CorsConfiguration;
+//import org.springframework.web.cors.UrlBasedCorsConfigurationSource;
+//import org.springframework.web.filter.CorsFilter;
+//
+///**
+// * 基础框架 - 跨域请求配置
+// */
+//@Configuration
+//public class CorsConfig {
+// @Bean
+// public CorsFilter corsFilter() {
+// UrlBasedCorsConfigurationSource source = new UrlBasedCorsConfigurationSource();
+// source.registerCorsConfiguration("/**", buildConfig());
+// return new CorsFilter(source);
+// }
+//
+// private CorsConfiguration buildConfig() {
+// CorsConfiguration corsConfiguration = new CorsConfiguration();
+// // 1允许任何域名使用
+// corsConfiguration.addAllowedOrigin("*");
+// // 2允许任何头
+// corsConfiguration.addAllowedHeader("*");
+// // 3允许任何方法(post、get等)
+// corsConfiguration.addAllowedMethod("*");
+// return corsConfiguration;
+// }
+//}
\ No newline at end of file
diff --git a/src/main/java/com/casic/config/dto/RoleDto.java b/src/main/java/com/casic/config/dto/RoleDto.java
new file mode 100644
index 0000000..ca08f84
--- /dev/null
+++ b/src/main/java/com/casic/config/dto/RoleDto.java
@@ -0,0 +1,11 @@
+package com.casic.config.dto;
+
+import lombok.Data;
+
+@Data
+public class RoleDto {
+
+ private Long id;
+ private String name;
+
+}
diff --git a/src/main/java/com/casic/config/task/TaskConfigurer.java b/src/main/java/com/casic/config/task/TaskConfigurer.java
index 699c0e3..5a3a029 100644
--- a/src/main/java/com/casic/config/task/TaskConfigurer.java
+++ b/src/main/java/com/casic/config/task/TaskConfigurer.java
@@ -1,6 +1,7 @@
package com.casic.config.task;
import com.casic.service.DeviceDataService;
+import com.casic.service.IPartitionStrategyService;
import com.casic.service.UserDataDelayReceiver;
import lombok.RequiredArgsConstructor;
import org.springframework.beans.factory.annotation.Autowired;
@@ -24,18 +25,30 @@
private String onlineStateCron;
@Value("${casic.device.transfer-user.cron}")
private String transferUserCron;
-
+ @Value("${casic.device.partition.cron}")
+ private String partitionCron;
private final DeviceDataService deviceDataService;
private final UserDataDelayReceiver userDataDelayReceiver;
+ private final IPartitionStrategyService partitionStrategyService;
@Override
public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
- TriggerTask triggrtTask = new TriggerTask(nextDayDevice(),
+ TriggerTask onlineStateTask = new TriggerTask(nextDayDevice(),
triggerContext -> {
return new CronTrigger(onlineStateCron).nextExecutionTime(triggerContext);
});
- taskRegistrar.addTriggerTask(triggrtTask);
+ TriggerTask transferUserTask = new TriggerTask(getUserData(),
+ triggerContext -> {
+ return new CronTrigger(transferUserCron).nextExecutionTime(triggerContext);
+ });
+ TriggerTask partitionTask = new TriggerTask(createPartition(),
+ triggerContext -> {
+ return new CronTrigger(partitionCron).nextExecutionTime(triggerContext);
+ });
+ taskRegistrar.addTriggerTask(onlineStateTask);
+ taskRegistrar.addTriggerTask(transferUserTask);
+ taskRegistrar.addTriggerTask(partitionTask);
}
private Runnable nextDayDevice() {
@@ -57,6 +70,18 @@
userDataDelayReceiver.saveNewUserData();
}
};
+ }
+
+ /**
+ * 定时同步普光
+ */
+ private Runnable createPartition() {
+ return new Runnable() {
+ @Override
+ public void run() {
+ partitionStrategyService.createPartition("DATA_H2S", "data_h2s_log");
+ }
+ };
}
diff --git a/src/main/java/com/casic/controller/DeviceDataController.java b/src/main/java/com/casic/controller/DeviceDataController.java
index d7e3722..e6ae7bc 100644
--- a/src/main/java/com/casic/controller/DeviceDataController.java
+++ b/src/main/java/com/casic/controller/DeviceDataController.java
@@ -1,40 +1,40 @@
-package com.casic.controller;
-
-import com.alibaba.fastjson.JSON;
-import com.casic.service.DeviceDataService;
-import com.casic.service.ThirdDataService;
-import lombok.RequiredArgsConstructor;
-import org.springframework.web.bind.annotation.*;
-
-import java.util.Map;
-
-@RestController
-@RequestMapping("/device")
-@RequiredArgsConstructor
-public class DeviceDataController {
-
- private final DeviceDataService deviceDataService;
-
- @RequestMapping("/recent-data")
- public Object getDeviceRecentData(@RequestParam(value = "deviceType", required = true) String deviceType,
- @RequestParam(value = "recentNum", required = true) String recentNum,
- @RequestParam(value = "devcode", required = false) String devcode) {
- return deviceDataService.getDeviceRecentData(deviceType, recentNum, devcode);
- }
-
- @RequestMapping("/data/list-page")
- public Object getDeviceListPage(@RequestParam(value = "deviceType", required = true) String deviceType,
- @RequestParam(value = "currentIndex", required = true) Integer currentIndex,
- @RequestParam(value = "pageSize", required = true) Integer pageSize,
- @RequestParam(value = "devcode", required = false) String devcode) {
- return deviceDataService.getDeviceListPage(deviceType, currentIndex, pageSize, devcode);
- }
-
- @RequestMapping("/level/{deviceType}")
- public Object getLevelList(@PathVariable("deviceType")String deviceType) {
- return deviceDataService.getLevel(deviceType);
- }
-
-
-
-}
+//package com.casic.controller;
+//
+//import com.alibaba.fastjson.JSON;
+//import com.casic.service.DeviceDataService;
+//import com.casic.service.ThirdDataService;
+//import lombok.RequiredArgsConstructor;
+//import org.springframework.web.bind.annotation.*;
+//
+//import java.util.Map;
+//
+//@RestController
+//@RequestMapping("/device")
+//@RequiredArgsConstructor
+//public class DeviceDataController {
+//
+// private final DeviceDataService deviceDataService;
+//
+// @RequestMapping("/recent-data")
+// public Object getDeviceRecentData(@RequestParam(value = "deviceType", required = true) String deviceType,
+// @RequestParam(value = "recentNum", required = true) String recentNum,
+// @RequestParam(value = "devcode", required = false) String devcode) {
+// return deviceDataService.getDeviceRecentData(deviceType, recentNum, devcode);
+// }
+//
+// @RequestMapping("/data/list-page")
+// public Object getDeviceListPage(@RequestParam(value = "deviceType", required = true) String deviceType,
+// @RequestParam(value = "currentIndex", required = true) Integer currentIndex,
+// @RequestParam(value = "pageSize", required = true) Integer pageSize,
+// @RequestParam(value = "devcode", required = false) String devcode) {
+// return deviceDataService.getDeviceListPage(deviceType, currentIndex, pageSize, devcode);
+// }
+//
+// @RequestMapping("/level/{deviceType}")
+// public Object getLevelList(@PathVariable("deviceType")String deviceType) {
+// return deviceDataService.getLevel(deviceType);
+// }
+//
+//
+//
+//}
diff --git a/src/main/java/com/casic/dao/PartitionStrategyMapper.java b/src/main/java/com/casic/dao/PartitionStrategyMapper.java
new file mode 100644
index 0000000..a9481d0
--- /dev/null
+++ b/src/main/java/com/casic/dao/PartitionStrategyMapper.java
@@ -0,0 +1,44 @@
+package com.casic.dao;
+
+import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
+
+import java.util.Date;
+
+/**
+ * 分区mapper
+ *
+ * @author lwh
+ */
+@Mapper
+public interface PartitionStrategyMapper {
+
+ /**
+ * 当前表最大分区查询
+ *
+ * @param tableName 分区表名称
+ * @return
+ */
+ String selectMaxId(@Param("tableName") String tableName, @Param("tableOwner") String tableOwner);
+
+ /**
+ * 增加表分区
+ *
+ * @param tableName 表名称
+ * @param partitionName 分区名称
+ * @param time 分区最大值
+ */
+ void createPartition(@Param("tableName") String tableName, @Param("partitionName") String partitionName,
+ @Param("time") String time, @Param("storage") String storage);
+
+ /**
+ * 创建表空间
+ *
+ * @param tableSpaceName 表空间名称
+ * @param dataFilePath 文件地址
+ * @param tableSpaceSize 表空间大小(单位 M)
+ */
+ void createTableSpace(@Param("tableSpaceName") String tableSpaceName, @Param("dataFilePath") String dataFilePath, @Param("tableSpaceSize") Integer tableSpaceSize);
+
+
+}
diff --git a/src/main/java/com/casic/dao/UserMapper.java b/src/main/java/com/casic/dao/UserMapper.java
deleted file mode 100644
index 266d786..0000000
--- a/src/main/java/com/casic/dao/UserMapper.java
+++ /dev/null
@@ -1,20 +0,0 @@
-package com.casic.dao;
-
-import com.baomidou.mybatisplus.core.mapper.BaseMapper;
-import com.casic.model.User;
-import org.apache.ibatis.annotations.Mapper;
-import org.apache.ibatis.annotations.Select;
-
-import java.util.List;
-import java.util.Map;
-
-@Mapper
-public interface UserMapper extends BaseMapper {
-
-
- //获取所有的角色
- @Select(" SELECT id,name " +
- " FROM sys_role " +
- " where name like '达州%' ")
- List