48959b0b908dd57bf9dd991b75756ac2698f2b4d..27d341342925f11c19fb7a31da7050f5e9041319
2023-10-19 feiyu02
新增数据分析模块
27d341 对比 | 目录
2023-10-19 feiyu02
修改src文件下的文件路径名称
f5d149 对比 | 目录
已修改2个文件
已删除12个文件
已添加40个文件
已重命名45个文件
4613 ■■■■ 文件已修改
hs_err_pid13764.log 397 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
pom.xml 136 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/flightfeather/monitor/QianduanApplication.java 5 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/flightfeather/monitor/ServletInitializer.java 2 ●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/flightfeather/monitor/analysis/AnalysisController.kt 7 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/flightfeather/monitor/analysis/DataAnalysisInterface.kt 30 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/flightfeather/monitor/analysis/dust/ExceptionValueMutation.kt 39 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/flightfeather/monitor/config/DataSourceConfig.kt 45 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/flightfeather/monitor/config/MybatisConfig4ds1.kt 48 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/flightfeather/monitor/config/TaskPoolConfig.kt 30 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/flightfeather/monitor/controller/AnalysisDataController.java 8 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/flightfeather/monitor/controller/FugitiveDustController.java 8 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/flightfeather/monitor/controller/LoginController.java 11 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/flightfeather/monitor/controller/SqlController.java 10 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/flightfeather/monitor/controller/Vue3FumeController.java 9 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/flightfeather/monitor/domain/ds1/entity/DustExceptionData.java 141 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/flightfeather/monitor/domain/ds1/entity/DustExceptionSetting.java 311 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/flightfeather/monitor/domain/ds1/entity/DustGlobalSetting.java 208 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/flightfeather/monitor/domain/ds1/entity/DustSiteData.java 139 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/flightfeather/monitor/domain/ds1/entity/DustSiteInfo.java 1100 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/flightfeather/monitor/domain/ds1/entity/DustSiteLatestTime.java 59 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/flightfeather/monitor/domain/ds1/entity/DustSiteMap.java 144 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/flightfeather/monitor/domain/ds1/entity/DustStatisticsValue.java 173 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/flightfeather/monitor/domain/ds1/entity/LoginInfo.java 106 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/flightfeather/monitor/domain/ds1/entity/RequestTaskSetting.java 411 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/flightfeather/monitor/domain/ds1/mapper/DustExceptionDataMapper.kt 8 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/flightfeather/monitor/domain/ds1/mapper/DustExceptionSettingMapper.kt 8 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/flightfeather/monitor/domain/ds1/mapper/DustGlobalSettingMapper.kt 8 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/flightfeather/monitor/domain/ds1/mapper/DustSiteDataMapper.kt 8 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/flightfeather/monitor/domain/ds1/mapper/DustSiteInfoMapper.kt 8 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/flightfeather/monitor/domain/ds1/mapper/DustSiteLatestTimeMapper.kt 8 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/flightfeather/monitor/domain/ds1/mapper/DustSiteMapMapper.kt 8 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/flightfeather/monitor/domain/ds1/mapper/DustStatisticsValueMapper.kt 8 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/flightfeather/monitor/domain/ds1/mapper/LoginInfoMapper.kt 8 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/flightfeather/monitor/domain/ds1/mapper/RequestTaskSettingMapper.kt 8 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/flightfeather/monitor/domain/util/MyMapper.java 36 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/flightfeather/monitor/mapper/AnalysisDataMapper.java 4 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/flightfeather/monitor/mapper/FugitiveDustMapper.java 6 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/flightfeather/monitor/mapper/LoginMapper.java 4 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/flightfeather/monitor/mapper/SqlMapper.java 4 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/flightfeather/monitor/mapper/Vue3FumeMapper.java 8 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/flightfeather/monitor/pojo/AnalysisData.java 2 ●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/flightfeather/monitor/pojo/AnalysisDustData.java 2 ●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/flightfeather/monitor/pojo/AuditInfo.java 2 ●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/flightfeather/monitor/pojo/DeviceInfo.java 2 ●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/flightfeather/monitor/pojo/DustDataAccessSetting.java 2 ●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/flightfeather/monitor/pojo/DustExceptionData.java 2 ●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/flightfeather/monitor/pojo/DustExceptionSetting.java 3 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/flightfeather/monitor/pojo/DustExceptionType.java 2 ●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/flightfeather/monitor/pojo/DustSiteData.java 2 ●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/flightfeather/monitor/pojo/FumeAbnormalData.java 2 ●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/flightfeather/monitor/pojo/FumeHistoryData.java 2 ●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/flightfeather/monitor/pojo/LoginUser.java 2 ●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/flightfeather/monitor/pojo/OriginalData.java 2 ●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/flightfeather/monitor/pojo/PageBean.java 2 ●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/flightfeather/monitor/pojo/Result.java 2 ●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/flightfeather/monitor/scheduledtasks/BaseTimingTask.kt 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/flightfeather/monitor/scheduledtasks/ScheduledTaskController.java 2 ●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/flightfeather/monitor/scheduledtasks/TaskController.kt 2 ●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/flightfeather/monitor/service/AnalysisDataService.java 4 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/flightfeather/monitor/service/FugitiveDustService.java 4 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/flightfeather/monitor/service/LoginService.java 7 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/flightfeather/monitor/service/SqlService.java 6 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/flightfeather/monitor/service/Vue3FumeService.java 11 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/flightfeather/monitor/service/impl/AnalysisDataServiceImpl.java 8 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/flightfeather/monitor/service/impl/FugitiveDustServiceImpl.java 10 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/flightfeather/monitor/service/impl/LoginServiceImpl.java 8 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/flightfeather/monitor/service/impl/SqlServiceImpl.java 66 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/flightfeather/monitor/service/impl/Vue3FumeServiceImpl.java 13 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/flightfeather/monitor/utils/MD5Util.java 2 ●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/flightfeather/monitor/utils/UUIDGenerator.kt 2 ●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/job/zsc/controller/dustexception/onlineAnalysisController.java 24 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/job/zsc/dustexceptionanalysis/ExceptionAnalysis.java 36 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/job/zsc/dustexceptionanalysis/analysis/Exceeding.java 38 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/job/zsc/dustexceptionanalysis/database/DustRepository.java 21 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/job/zsc/dustexceptionanalysis/dataprocess/DataProcess.java 14 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/job/zsc/mapper/dustexception/OnlineAnalysisMapper.java 15 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/job/zsc/service/LoginService.java 7 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/job/zsc/service/dustexception/impl/onlineAnalysisServiceImpl.java 7 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/job/zsc/service/dustexception/onlineAnalysisService.java 4 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/job/zsc/service/impl/SqlServiceImpl.java 66 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/job/zsc/service/impl/dustexception/onlineAnalysisImpl.java 10 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/resources/application.yml 19 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/resources/generator/generatorConfig4ds1.xml 86 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/resources/mapper/AnalysisDataMapper.xml 10 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/resources/mapper/FugitiveDustMapper.xml 22 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/resources/mapper/SqlMapper.xml 6 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/resources/mapper/Vue3FumeMapper.xml 22 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/resources/mapper/ds1/DustExceptionDataMapper.xml 23 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/resources/mapper/ds1/DustExceptionSettingMapper.xml 36 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/resources/mapper/ds1/DustGlobalSettingMapper.xml 26 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/resources/mapper/ds1/DustSiteDataMapper.xml 23 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/resources/mapper/ds1/DustSiteInfoMapper.xml 68 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/resources/mapper/ds1/DustSiteLatestTimeMapper.xml 18 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/resources/mapper/ds1/DustSiteMapMapper.xml 24 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/resources/mapper/ds1/DustStatisticsValueMapper.xml 25 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/resources/mapper/ds1/LoginInfoMapper.xml 21 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/resources/mapper/ds1/RequestTaskSettingMapper.xml 37 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/test/java/com/flightfeather/monitor/QianduanApplicationTests.java 10 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
hs_err_pid13764.log
ÎļþÒÑɾ³ý
pom.xml
@@ -9,15 +9,19 @@
        <relativePath/> <!-- lookup parent from repository -->
    </parent>
    <groupId>com.zmc</groupId>
    <artifactId>web_01</artifactId>
    <groupId>com.flightfeather</groupId>
    <artifactId>monitor</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <name>web_01</name>
    <name>monitor</name>
    <packaging>war</packaging>
    <description>web_01</description>
    <description>monitor managet</description>
    <properties>
        <java.version>1.8</java.version>
        <kotlin.version>1.8.22</kotlin.version>
        <!-- tk.mybatis -->
        <mapper.plugin>tk.mybatis.mapper.generator.MapperPlugin</mapper.plugin>
        <mapper.Mapper>tk.mybatis.mapper.common.Mapper</mapper.Mapper>
    </properties>
    <dependencies>
        <dependency>
@@ -28,14 +32,19 @@
            <groupId>org.mybatis.spring.boot</groupId>
            <artifactId>mybatis-spring-boot-starter</artifactId>
            <version>2.3.1</version>
        </dependency>
        <dependency>
            <groupId>org.mybatis.generator</groupId>
            <artifactId>mybatis-generator-core</artifactId>
            <version>1.4.2</version>
        </dependency>
<!--        <dependency>-->
<!--            <groupId>com.mysql</groupId>-->
<!--            <artifactId>mysql-connector-j</artifactId>-->
<!--            <scope>runtime</scope>-->
<!--        </dependency>-->
        <!--tk.mybatis-->
        <dependency>
            <groupId>tk.mybatis</groupId>
            <artifactId>mapper-spring-boot-starter</artifactId>
            <version>4.2.2</version>
        </dependency>
        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
@@ -57,16 +66,10 @@
            <artifactId>pagehelper-spring-boot-starter</artifactId>
            <version>1.4.6</version>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-configuration-processor</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-aop</artifactId>
@@ -92,20 +95,95 @@
    <build>
        <plugins>
<!--            <plugin>-->
<!--                <groupId>org.springframework.boot</groupId>-->
<!--                <artifactId>spring-boot-maven-plugin</artifactId>-->
<!--                <version>3.0.5</version>-->
<!--                <configuration>-->
<!--                    <excludes>-->
<!--                        <exclude>-->
<!--                            <groupId>org.projectlombok</groupId>-->
<!--                            <artifactId>lombok</artifactId>-->
<!--                        </exclude>-->
<!--                    </excludes>-->
<!--                </configuration>-->
<!--            </plugin>-->
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
            <plugin>
                <groupId>org.jetbrains.kotlin</groupId>
                <artifactId>kotlin-maven-plugin</artifactId>
                <configuration>
                    <args>
                        <arg>-Xjsr305=strict</arg>
                    </args>
                    <compilerPlugins>
                        <plugin>spring</plugin>
                    </compilerPlugins>
                </configuration>
                <dependencies>
                    <dependency>
                        <groupId>org.jetbrains.kotlin</groupId>
                        <artifactId>kotlin-maven-allopen</artifactId>
                        <version>${kotlin.version}</version>
                    </dependency>
                </dependencies>
            </plugin>
            <!-- mybatis generator è‡ªåŠ¨ç”Ÿæˆä»£ç æ’ä»¶ -->
            <plugin>
                <groupId>org.mybatis.generator</groupId>
                <artifactId>mybatis-generator-maven-plugin</artifactId>
                <version>1.3.7</version>
                <configuration>
                    <!-- è®¾ç½®æ’件运行的文件路径-->
                    <configurationFile>src/main/resources/generator/generatorConfig4ds1.xml</configurationFile>
                    <overwrite>true</overwrite>
                    <verbose>true</verbose>
                </configuration>
                <dependencies>
                    <!-- https://mvnrepository.com/artifact/tk.mybatis/mapper -->
                    <dependency>
                        <groupId>tk.mybatis</groupId>
                        <artifactId>mapper</artifactId>
                        <version>4.1.5</version>
                    </dependency>
                </dependencies>
            </plugin>
        </plugins>
    </build>
    <!--依赖下载地址-->
    <repositories>
        <repository>
            <id>alimaven</id>
            <name>aliyun maven</name>
            <url>https://maven.aliyun.com/repository/public</url>
        </repository>
        <repository>
            <id>spring-snapshots</id>
            <name>Spring Snapshots</name>
            <url>https://repo.spring.io/snapshot</url>
            <snapshots>
                <enabled>true</enabled>
            </snapshots>
        </repository>
        <repository>
            <id>spring-milestones</id>
            <name>Spring Milestones</name>
            <url>https://repo.spring.io/milestone</url>
            <snapshots>
                <enabled>false</enabled>
            </snapshots>
        </repository>
    </repositories>
    <pluginRepositories>
        <pluginRepository>
            <id>spring-snapshots</id>
            <name>Spring Snapshots</name>
            <url>https://repo.spring.io/snapshot</url>
            <snapshots>
                <enabled>true</enabled>
            </snapshots>
        </pluginRepository>
        <pluginRepository>
            <id>spring-milestones</id>
            <name>Spring Milestones</name>
            <url>https://repo.spring.io/milestone</url>
            <snapshots>
                <enabled>false</enabled>
            </snapshots>
        </pluginRepository>
    </pluginRepositories>
</project>
src/main/java/com/flightfeather/monitor/QianduanApplication.java
ÎļþÃû´Ó src/main/java/com/job/zsc/QianduanApplication.java ÐÞ¸Ä
@@ -1,8 +1,7 @@
package com.job.zsc;
package com.flightfeather.monitor;
import com.job.zsc.scheduledtasks.TaskController;
import com.flightfeather.monitor.scheduledtasks.TaskController;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.ApplicationArguments;
import org.springframework.boot.ApplicationRunner;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
src/main/java/com/flightfeather/monitor/ServletInitializer.java
ÎļþÃû´Ó src/main/java/com/job/zsc/ServletInitializer.java ÐÞ¸Ä
@@ -1,4 +1,4 @@
package com.job.zsc;
package com.flightfeather.monitor;
import org.springframework.boot.builder.SpringApplicationBuilder;
import org.springframework.boot.web.servlet.support.SpringBootServletInitializer;
src/main/java/com/flightfeather/monitor/analysis/AnalysisController.kt
¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,7 @@
package com.flightfeather.monitor.analysis
/**
 * æ•°æ®åˆ†æžæŽ§åˆ¶å™¨
 */
class AnalysisController {
}
src/main/java/com/flightfeather/monitor/analysis/DataAnalysisInterface.kt
¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,30 @@
package com.flightfeather.monitor.analysis
/**
 * æ•°æ®åˆ†æžæŽ¥å£
 */
abstract class DataAnalysisInterface<T, V>(config: V) {
    init {
        initConfig(config)
    }
    abstract fun initConfig(config: V)
    /**
     * æŽ¥æ”¶ä¸‹ä¸€ä¸ªæ—¶é—´ç‚¹çš„æ•°æ®
     */
    abstract fun onNextData(data: T)
    /**
     * å°†åˆ†æžç»“果入库
     */
    abstract fun toDb()
    /**
     * åˆ¤æ–­ç›¸é‚»æ•°æ®æ˜¯å¦è¿žç»­
     */
    fun isContinuous(d1:T, d2:T) {
    }
}
src/main/java/com/flightfeather/monitor/analysis/dust/ExceptionValueMutation.kt
¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,39 @@
package com.flightfeather.monitor.analysis.dust
import com.flightfeather.monitor.analysis.DataAnalysisInterface
import com.flightfeather.monitor.domain.ds1.entity.DustExceptionSetting
import com.flightfeather.monitor.domain.ds1.entity.DustSiteData
import java.util.*
import kotlin.properties.Delegates
/**
 * é‡çº§çªå˜å¼‚常分析
 */
class ExceptionValueMutation(config: DustExceptionSetting) : DataAnalysisInterface<DustSiteData,
        DustExceptionSetting>(config) {
    private var mutationNum by Delegates.notNull<Int>()
    private var mutationRate by Delegates.notNull<Double>()
    private var lastDataTime: Date? = null
    override fun initConfig(config: DustExceptionSetting) {
        mutationNum = config.mutationNum
        mutationRate = config.mutationRate
    }
    override fun onNextData(data: DustSiteData) {
        if (lastDataTime != null) {
            // ç›¸é‚»æ•°æ®æ—¶é—´å°äºŽæˆ–等于30分钟分为一组
        }
        lastDataTime = data.lst
    }
    override fun toDb() {
        TODO("Not yet implemented")
    }
}
src/main/java/com/flightfeather/monitor/config/DataSourceConfig.kt
¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,45 @@
package com.flightfeather.monitor.config
import org.springframework.beans.factory.annotation.Qualifier
import org.springframework.boot.autoconfigure.jdbc.DataSourceProperties
import org.springframework.boot.context.properties.ConfigurationProperties
import org.springframework.context.annotation.Bean
import org.springframework.context.annotation.Configuration
import org.springframework.context.annotation.Primary
import javax.sql.DataSource
/**
 * å¤šæ•°æ®æºé…ç½®
 */
@Configuration
class DataSourceConfig {
    //主数据源配置 ds1数据源
    @Primary
    @Bean(name = ["ds1DataSourceProperties"])
    @ConfigurationProperties(prefix = "spring.datasource.ds1")
    fun ds1DataSourceProperties(): DataSourceProperties? {
        return DataSourceProperties()
    }
    //主数据源 ds1数据源
    @Primary
    @Bean(name = ["ds1DataSource"])
    fun ds1DataSource(@Qualifier("ds1DataSourceProperties") dataSourceProperties: DataSourceProperties): DataSource? {
        return dataSourceProperties.initializeDataSourceBuilder().build()
    }
    //第二个ds2数据源配置
//    @Bean(name = ["ds2DataSourceProperties"])
//    @ConfigurationProperties(prefix = "spring.datasource.ds2")
//    fun ds2DataSourceProperties(): DataSourceProperties? {
//        return DataSourceProperties()
//    }
    //第二个ds2数据源
//    @Bean("ds2DataSource")
//    fun ds2DataSource(@Qualifier("ds2DataSourceProperties") dataSourceProperties: DataSourceProperties): DataSource? {
//        return dataSourceProperties.initializeDataSourceBuilder().build()
//    }
}
src/main/java/com/flightfeather/monitor/config/MybatisConfig4ds1.kt
¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,48 @@
package com.flightfeather.monitor.config
import org.apache.ibatis.session.SqlSessionFactory
import org.mybatis.spring.SqlSessionFactoryBean
import org.mybatis.spring.SqlSessionTemplate
import org.mybatis.spring.annotation.MapperScan
import org.springframework.beans.factory.annotation.Qualifier
import org.springframework.context.annotation.Bean
import org.springframework.context.annotation.Configuration
import org.springframework.context.annotation.Primary
import org.springframework.core.io.support.PathMatchingResourcePatternResolver
import org.springframework.jdbc.datasource.DataSourceTransactionManager
import javax.sql.DataSource
/**
 * Mybatis主数据源ds1配置
 * å¤šæ•°æ®æºé…ç½®ä¾èµ–数据源配置
 * @see  DataSourceConfig
 */
@Configuration
@MapperScan(basePackages = ["com.flightfeather.monitor.domain.ds1.mapper"],
    sqlSessionTemplateRef = "ds1SqlSessionTemplate")
class MybatisConfig4ds1 {
    //主数据源 ds1数据源
    @Primary
    @Bean("ds1SqlSessionFactory")
    @Throws(Exception::class)
    fun ds1SqlSessionFactory(@Qualifier("ds1DataSource") dataSource: DataSource?): SqlSessionFactory? {
        val sqlSessionFactory = SqlSessionFactoryBean()
        sqlSessionFactory.setDataSource(dataSource)
        sqlSessionFactory.setMapperLocations(*PathMatchingResourcePatternResolver().getResources("classpath*:mapper/ds1/*.xml"))
        return sqlSessionFactory.getObject()
    }
    @Primary
    @Bean(name = ["ds1TransactionManager"])
    fun ds1TransactionManager(@Qualifier("ds1DataSource") dataSource: DataSource): DataSourceTransactionManager? {
        return DataSourceTransactionManager(dataSource)
    }
    @Primary
    @Bean(name = ["ds1SqlSessionTemplate"])
    fun ds1SqlSessionTemplate(@Qualifier("ds1SqlSessionFactory") sqlSessionFactory: SqlSessionFactory?): SqlSessionTemplate? {
        return SqlSessionTemplate(sqlSessionFactory)
    }
}
src/main/java/com/flightfeather/monitor/config/TaskPoolConfig.kt
¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,30 @@
package com.flightfeather.monitor.config
import org.springframework.scheduling.annotation.EnableAsync
import org.springframework.aop.interceptor.AsyncExecutionAspectSupport
import org.springframework.context.annotation.Bean
import org.springframework.context.annotation.Configuration
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor
import java.util.concurrent.Executor
import java.util.concurrent.ThreadPoolExecutor
@EnableAsync
@Configuration
class TaskPoolConfig {
    @Bean(name = [AsyncExecutionAspectSupport.DEFAULT_TASK_EXECUTOR_BEAN_NAME])
    fun taskExecutor(): Executor {
        val executor = ThreadPoolTaskExecutor()
        //核心线程池大小
        executor.corePoolSize = 10
        //最大线程数
        executor.maxPoolSize = 20
        //队列容量
        executor.queueCapacity = 200
        //活跃时间
        executor.keepAliveSeconds = 60
        //线程名字前缀
        executor.setThreadNamePrefix("taskExecutor-")
        executor.setRejectedExecutionHandler(ThreadPoolExecutor.CallerRunsPolicy())
        return executor
    }
}
src/main/java/com/flightfeather/monitor/controller/AnalysisDataController.java
ÎļþÃû´Ó src/main/java/com/job/zsc/controller/AnalysisDataController.java ÐÞ¸Ä
@@ -1,8 +1,8 @@
package com.job.zsc.controller;
package com.flightfeather.monitor.controller;
import com.job.zsc.pojo.AnalysisData;
import com.job.zsc.pojo.Result;
import com.job.zsc.service.AnalysisDataService;
import com.flightfeather.monitor.pojo.AnalysisData;
import com.flightfeather.monitor.pojo.Result;
import com.flightfeather.monitor.service.AnalysisDataService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
src/main/java/com/flightfeather/monitor/controller/FugitiveDustController.java
ÎļþÃû´Ó src/main/java/com/job/zsc/controller/FugitiveDustController.java ÐÞ¸Ä
@@ -1,8 +1,8 @@
package com.job.zsc.controller;
package com.flightfeather.monitor.controller;
import com.job.zsc.pojo.*;
import com.job.zsc.service.FugitiveDustService;
import com.flightfeather.monitor.pojo.*;
import com.flightfeather.monitor.service.FugitiveDustService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
@@ -156,7 +156,7 @@
    /*根据异常类型和时段 è¿”回站点名字*/
    @GetMapping("/exceptionsSiteName")
    public Result getSiteNameByTimeAndExceptionType(String [] exceptionType,String beginTime, String endTime){
    public Result getSiteNameByTimeAndExceptionType(String [] exceptionType, String beginTime, String endTime){
        List<DustExceptionData> list = fugitiveDustService.getSiteNameByTimeAndExceptionType(exceptionType,beginTime,endTime);
        return Result.success(list);
    }
src/main/java/com/flightfeather/monitor/controller/LoginController.java
ÎļþÃû´Ó src/main/java/com/job/zsc/controller/LoginController.java ÐÞ¸Ä
@@ -1,14 +1,11 @@
package com.job.zsc.controller;
package com.flightfeather.monitor.controller;
import com.job.zsc.pojo.LoginUser;
import com.job.zsc.pojo.Result;
import com.job.zsc.service.LoginService;
import com.flightfeather.monitor.pojo.LoginUser;
import com.flightfeather.monitor.pojo.Result;
import com.flightfeather.monitor.service.LoginService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import java.util.HashMap;
import java.util.Map;
@RequestMapping("/dust")
@CrossOrigin
src/main/java/com/flightfeather/monitor/controller/SqlController.java
ÎļþÃû´Ó src/main/java/com/job/zsc/controller/SqlController.java ÐÞ¸Ä
@@ -1,9 +1,9 @@
package com.job.zsc.controller;
package com.flightfeather.monitor.controller;
import com.job.zsc.pojo.PageBean;
import com.job.zsc.pojo.Result;
import com.job.zsc.pojo.OriginalData;
import com.job.zsc.service.SqlService;
import com.flightfeather.monitor.pojo.PageBean;
import com.flightfeather.monitor.pojo.Result;
import com.flightfeather.monitor.pojo.OriginalData;
import com.flightfeather.monitor.service.SqlService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.format.annotation.DateTimeFormat;
src/main/java/com/flightfeather/monitor/controller/Vue3FumeController.java
ÎļþÃû´Ó src/main/java/com/job/zsc/controller/Vue3FumeController.java ÐÞ¸Ä
@@ -1,14 +1,11 @@
package com.job.zsc.controller;
package com.flightfeather.monitor.controller;
import com.job.zsc.pojo.*;
import com.job.zsc.service.Vue3FumeService;
import com.flightfeather.monitor.pojo.*;
import com.flightfeather.monitor.service.Vue3FumeService;
import lombok.extern.slf4j.Slf4j;
import org.apache.ibatis.annotations.Param;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.*;
import javax.naming.InsufficientResourcesException;
import java.util.List;
@Slf4j
src/main/java/com/flightfeather/monitor/domain/ds1/entity/DustExceptionData.java
¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,141 @@
package com.flightfeather.monitor.domain.ds1.entity;
import java.util.Date;
import javax.persistence.*;
@Table(name = "dust_exception_data")
public class DustExceptionData {
    @Id
    private Integer id;
    @Column(name = "mn_code")
    private String mnCode;
    private String exception;
    @Column(name = "exception_type")
    private Integer exceptionType;
    private String region;
    @Column(name = "begin_time")
    private Date beginTime;
    @Column(name = "end_time")
    private Date endTime;
    @Column(name = "avg_value")
    private Double avgValue;
    /**
     * @return id
     */
    public Integer getId() {
        return id;
    }
    /**
     * @param id
     */
    public void setId(Integer id) {
        this.id = id;
    }
    /**
     * @return mn_code
     */
    public String getMnCode() {
        return mnCode;
    }
    /**
     * @param mnCode
     */
    public void setMnCode(String mnCode) {
        this.mnCode = mnCode == null ? null : mnCode.trim();
    }
    /**
     * @return exception
     */
    public String getException() {
        return exception;
    }
    /**
     * @param exception
     */
    public void setException(String exception) {
        this.exception = exception == null ? null : exception.trim();
    }
    /**
     * @return exception_type
     */
    public Integer getExceptionType() {
        return exceptionType;
    }
    /**
     * @param exceptionType
     */
    public void setExceptionType(Integer exceptionType) {
        this.exceptionType = exceptionType;
    }
    /**
     * @return region
     */
    public String getRegion() {
        return region;
    }
    /**
     * @param region
     */
    public void setRegion(String region) {
        this.region = region == null ? null : region.trim();
    }
    /**
     * @return begin_time
     */
    public Date getBeginTime() {
        return beginTime;
    }
    /**
     * @param beginTime
     */
    public void setBeginTime(Date beginTime) {
        this.beginTime = beginTime;
    }
    /**
     * @return end_time
     */
    public Date getEndTime() {
        return endTime;
    }
    /**
     * @param endTime
     */
    public void setEndTime(Date endTime) {
        this.endTime = endTime;
    }
    /**
     * @return avg_value
     */
    public Double getAvgValue() {
        return avgValue;
    }
    /**
     * @param avgValue
     */
    public void setAvgValue(Double avgValue) {
        this.avgValue = avgValue;
    }
}
src/main/java/com/flightfeather/monitor/domain/ds1/entity/DustExceptionSetting.java
¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,311 @@
package com.flightfeather.monitor.domain.ds1.entity;
import java.util.Date;
import javax.persistence.*;
@Table(name = "dust_exception_setting")
public class DustExceptionSetting {
    @Id
    private Integer id;
    private String user;
    @Column(name = "update_time")
    private Date updateTime;
    private String version;
    @Column(name = "miss_data_minutes")
    private Integer missDataMinutes;
    @Column(name = "data_low")
    private Double dataLow;
    @Column(name = "long_time_no_change")
    private Integer longTimeNoChange;
    @Column(name = "mutation_num")
    private Integer mutationNum;
    @Column(name = "mutation_rate")
    private Double mutationRate;
    @Column(name = "near_exceed_low_value")
    private Double nearExceedLowValue;
    @Column(name = "near_exceed_high_value")
    private Double nearExceedHighValue;
    @Column(name = "near_exceed_num")
    private Integer nearExceedNum;
    @Column(name = "day_exceed_borderline_low_num")
    private Integer dayExceedBorderlineLowNum;
    @Column(name = "day_exceed_borderline_high_num")
    private Integer dayExceedBorderlineHighNum;
    @Column(name = "change_trend_group")
    private Integer changeTrendGroup;
    @Column(name = "change_trend_interval")
    private Integer changeTrendInterval;
    @Column(name = "change_trend_rate")
    private Double changeTrendRate;
    @Column(name = "exceeding_standard")
    private Double exceedingStandard;
    /**
     * @return id
     */
    public Integer getId() {
        return id;
    }
    /**
     * @param id
     */
    public void setId(Integer id) {
        this.id = id;
    }
    /**
     * @return user
     */
    public String getUser() {
        return user;
    }
    /**
     * @param user
     */
    public void setUser(String user) {
        this.user = user == null ? null : user.trim();
    }
    /**
     * @return update_time
     */
    public Date getUpdateTime() {
        return updateTime;
    }
    /**
     * @param updateTime
     */
    public void setUpdateTime(Date updateTime) {
        this.updateTime = updateTime;
    }
    /**
     * @return version
     */
    public String getVersion() {
        return version;
    }
    /**
     * @param version
     */
    public void setVersion(String version) {
        this.version = version == null ? null : version.trim();
    }
    /**
     * @return miss_data_minutes
     */
    public Integer getMissDataMinutes() {
        return missDataMinutes;
    }
    /**
     * @param missDataMinutes
     */
    public void setMissDataMinutes(Integer missDataMinutes) {
        this.missDataMinutes = missDataMinutes;
    }
    /**
     * @return data_low
     */
    public Double getDataLow() {
        return dataLow;
    }
    /**
     * @param dataLow
     */
    public void setDataLow(Double dataLow) {
        this.dataLow = dataLow;
    }
    /**
     * @return long_time_no_change
     */
    public Integer getLongTimeNoChange() {
        return longTimeNoChange;
    }
    /**
     * @param longTimeNoChange
     */
    public void setLongTimeNoChange(Integer longTimeNoChange) {
        this.longTimeNoChange = longTimeNoChange;
    }
    /**
     * @return mutation_num
     */
    public Integer getMutationNum() {
        return mutationNum;
    }
    /**
     * @param mutationNum
     */
    public void setMutationNum(Integer mutationNum) {
        this.mutationNum = mutationNum;
    }
    /**
     * @return mutation_rate
     */
    public Double getMutationRate() {
        return mutationRate;
    }
    /**
     * @param mutationRate
     */
    public void setMutationRate(Double mutationRate) {
        this.mutationRate = mutationRate;
    }
    /**
     * @return near_exceed_low_value
     */
    public Double getNearExceedLowValue() {
        return nearExceedLowValue;
    }
    /**
     * @param nearExceedLowValue
     */
    public void setNearExceedLowValue(Double nearExceedLowValue) {
        this.nearExceedLowValue = nearExceedLowValue;
    }
    /**
     * @return near_exceed_high_value
     */
    public Double getNearExceedHighValue() {
        return nearExceedHighValue;
    }
    /**
     * @param nearExceedHighValue
     */
    public void setNearExceedHighValue(Double nearExceedHighValue) {
        this.nearExceedHighValue = nearExceedHighValue;
    }
    /**
     * @return near_exceed_num
     */
    public Integer getNearExceedNum() {
        return nearExceedNum;
    }
    /**
     * @param nearExceedNum
     */
    public void setNearExceedNum(Integer nearExceedNum) {
        this.nearExceedNum = nearExceedNum;
    }
    /**
     * @return day_exceed_borderline_low_num
     */
    public Integer getDayExceedBorderlineLowNum() {
        return dayExceedBorderlineLowNum;
    }
    /**
     * @param dayExceedBorderlineLowNum
     */
    public void setDayExceedBorderlineLowNum(Integer dayExceedBorderlineLowNum) {
        this.dayExceedBorderlineLowNum = dayExceedBorderlineLowNum;
    }
    /**
     * @return day_exceed_borderline_high_num
     */
    public Integer getDayExceedBorderlineHighNum() {
        return dayExceedBorderlineHighNum;
    }
    /**
     * @param dayExceedBorderlineHighNum
     */
    public void setDayExceedBorderlineHighNum(Integer dayExceedBorderlineHighNum) {
        this.dayExceedBorderlineHighNum = dayExceedBorderlineHighNum;
    }
    /**
     * @return change_trend_group
     */
    public Integer getChangeTrendGroup() {
        return changeTrendGroup;
    }
    /**
     * @param changeTrendGroup
     */
    public void setChangeTrendGroup(Integer changeTrendGroup) {
        this.changeTrendGroup = changeTrendGroup;
    }
    /**
     * @return change_trend_interval
     */
    public Integer getChangeTrendInterval() {
        return changeTrendInterval;
    }
    /**
     * @param changeTrendInterval
     */
    public void setChangeTrendInterval(Integer changeTrendInterval) {
        this.changeTrendInterval = changeTrendInterval;
    }
    /**
     * @return change_trend_rate
     */
    public Double getChangeTrendRate() {
        return changeTrendRate;
    }
    /**
     * @param changeTrendRate
     */
    public void setChangeTrendRate(Double changeTrendRate) {
        this.changeTrendRate = changeTrendRate;
    }
    /**
     * @return exceeding_standard
     */
    public Double getExceedingStandard() {
        return exceedingStandard;
    }
    /**
     * @param exceedingStandard
     */
    public void setExceedingStandard(Double exceedingStandard) {
        this.exceedingStandard = exceedingStandard;
    }
}
src/main/java/com/flightfeather/monitor/domain/ds1/entity/DustGlobalSetting.java
¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,208 @@
package com.flightfeather.monitor.domain.ds1.entity;
import java.util.Date;
import javax.persistence.*;
@Table(name = "dust_global_setting")
public class DustGlobalSetting {
    @Id
    private Integer id;
    /**
     * ç”¨æˆ·
     */
    private String user;
    /**
     * åˆ›å»ºæ—¶é—´
     */
    @Column(name = "create_time")
    private Date createTime;
    /**
     * æ›´æ–°æ—¶é—´
     */
    @Column(name = "update_time")
    private Date updateTime;
    /**
     * ç±»åž‹ï¼ˆæ‰¬å°˜ï¼Œæ²¹çƒŸï¼‰
     */
    private String type;
    /**
     * è¶…标预设值
     */
    private Double exceeding;
    @Column(name = "begin_time")
    private Date beginTime;
    @Column(name = "end_time")
    private Date endTime;
    private String region;
    @Column(name = "is_regular_time")
    private String isRegularTime;
    /**
     * @return id
     */
    public Integer getId() {
        return id;
    }
    /**
     * @param id
     */
    public void setId(Integer id) {
        this.id = id;
    }
    /**
     * èŽ·å–ç”¨æˆ·
     *
     * @return user - ç”¨æˆ·
     */
    public String getUser() {
        return user;
    }
    /**
     * è®¾ç½®ç”¨æˆ·
     *
     * @param user ç”¨æˆ·
     */
    public void setUser(String user) {
        this.user = user == null ? null : user.trim();
    }
    /**
     * èŽ·å–åˆ›å»ºæ—¶é—´
     *
     * @return create_time - åˆ›å»ºæ—¶é—´
     */
    public Date getCreateTime() {
        return createTime;
    }
    /**
     * è®¾ç½®åˆ›å»ºæ—¶é—´
     *
     * @param createTime åˆ›å»ºæ—¶é—´
     */
    public void setCreateTime(Date createTime) {
        this.createTime = createTime;
    }
    /**
     * èŽ·å–æ›´æ–°æ—¶é—´
     *
     * @return update_time - æ›´æ–°æ—¶é—´
     */
    public Date getUpdateTime() {
        return updateTime;
    }
    /**
     * è®¾ç½®æ›´æ–°æ—¶é—´
     *
     * @param updateTime æ›´æ–°æ—¶é—´
     */
    public void setUpdateTime(Date updateTime) {
        this.updateTime = updateTime;
    }
    /**
     * èŽ·å–ç±»åž‹ï¼ˆæ‰¬å°˜ï¼Œæ²¹çƒŸï¼‰
     *
     * @return type - ç±»åž‹ï¼ˆæ‰¬å°˜ï¼Œæ²¹çƒŸï¼‰
     */
    public String getType() {
        return type;
    }
    /**
     * è®¾ç½®ç±»åž‹ï¼ˆæ‰¬å°˜ï¼Œæ²¹çƒŸï¼‰
     *
     * @param type ç±»åž‹ï¼ˆæ‰¬å°˜ï¼Œæ²¹çƒŸï¼‰
     */
    public void setType(String type) {
        this.type = type == null ? null : type.trim();
    }
    /**
     * èŽ·å–è¶…æ ‡é¢„è®¾å€¼
     *
     * @return exceeding - è¶…标预设值
     */
    public Double getExceeding() {
        return exceeding;
    }
    /**
     * è®¾ç½®è¶…标预设值
     *
     * @param exceeding è¶…标预设值
     */
    public void setExceeding(Double exceeding) {
        this.exceeding = exceeding;
    }
    /**
     * @return begin_time
     */
    public Date getBeginTime() {
        return beginTime;
    }
    /**
     * @param beginTime
     */
    public void setBeginTime(Date beginTime) {
        this.beginTime = beginTime;
    }
    /**
     * @return end_time
     */
    public Date getEndTime() {
        return endTime;
    }
    /**
     * @param endTime
     */
    public void setEndTime(Date endTime) {
        this.endTime = endTime;
    }
    /**
     * @return region
     */
    public String getRegion() {
        return region;
    }
    /**
     * @param region
     */
    public void setRegion(String region) {
        this.region = region == null ? null : region.trim();
    }
    /**
     * @return is_regular_time
     */
    public String getIsRegularTime() {
        return isRegularTime;
    }
    /**
     * @param isRegularTime
     */
    public void setIsRegularTime(String isRegularTime) {
        this.isRegularTime = isRegularTime == null ? null : isRegularTime.trim();
    }
}
src/main/java/com/flightfeather/monitor/domain/ds1/entity/DustSiteData.java
¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,139 @@
package com.flightfeather.monitor.domain.ds1.entity;
import java.util.Date;
import javax.persistence.*;
@Table(name = "ja_t_dust_site_data_info")
public class DustSiteData {
    @Id
    private Integer id;
    @Column(name = "mn_code")
    private String mnCode;
    @Column(name = "dust_value")
    private Double dustValue;
    @Column(name = "noise_value")
    private Double noiseValue;
    private Date lst;
    private String quality;
    private Integer grade;
    private String flag;
    /**
     * @return id
     */
    public Integer getId() {
        return id;
    }
    /**
     * @param id
     */
    public void setId(Integer id) {
        this.id = id;
    }
    /**
     * @return mn_code
     */
    public String getMnCode() {
        return mnCode;
    }
    /**
     * @param mnCode
     */
    public void setMnCode(String mnCode) {
        this.mnCode = mnCode == null ? null : mnCode.trim();
    }
    /**
     * @return dust_value
     */
    public Double getDustValue() {
        return dustValue;
    }
    /**
     * @param dustValue
     */
    public void setDustValue(Double dustValue) {
        this.dustValue = dustValue;
    }
    /**
     * @return noise_value
     */
    public Double getNoiseValue() {
        return noiseValue;
    }
    /**
     * @param noiseValue
     */
    public void setNoiseValue(Double noiseValue) {
        this.noiseValue = noiseValue;
    }
    /**
     * @return lst
     */
    public Date getLst() {
        return lst;
    }
    /**
     * @param lst
     */
    public void setLst(Date lst) {
        this.lst = lst;
    }
    /**
     * @return quality
     */
    public String getQuality() {
        return quality;
    }
    /**
     * @param quality
     */
    public void setQuality(String quality) {
        this.quality = quality == null ? null : quality.trim();
    }
    /**
     * @return grade
     */
    public Integer getGrade() {
        return grade;
    }
    /**
     * @param grade
     */
    public void setGrade(Integer grade) {
        this.grade = grade;
    }
    /**
     * @return flag
     */
    public String getFlag() {
        return flag;
    }
    /**
     * @param flag
     */
    public void setFlag(String flag) {
        this.flag = flag == null ? null : flag.trim();
    }
}
src/main/java/com/flightfeather/monitor/domain/ds1/entity/DustSiteInfo.java
¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,1100 @@
package com.flightfeather.monitor.domain.ds1.entity;
import java.util.Date;
import javax.persistence.*;
@Table(name = "ja_t_dust_site_info")
public class DustSiteInfo {
    @Id
    private Integer id;
    /**
     * è®¾å¤‡ç¼–码
     */
    @Column(name = "mn_code")
    private String mnCode;
    /**
     * å®‰è£…地址
     */
    private String address;
    /**
     * ç«™ç‚¹åç§°
     */
    private String name;
    /**
     * ç«™ç‚¹ç¼–码
     */
    private String code;
    /**
     * å¼€å·¥æ—¶é—´
     */
    @Column(name = "begin_date")
    private Date beginDate;
    /**
     * è¿ç»´å•†
     */
    @Column(name = "duty_company")
    private String dutyCompany;
    /**
     * è¿ç»´å•†id
     */
    @Column(name = "duty_company_id")
    private String dutyCompanyId;
    /**
     * ç»“束时间
     */
    @Column(name = "end_date")
    private Date endDate;
    /**
     * å½“前施工阶段
     */
    @Column(name = "engineering_stage")
    private String engineeringStage;
    /**
     * æ‰€å±žåŒºåŽ¿ä»£ç 
     */
    @Column(name = "group_id")
    private String groupId;
    /**
     * æ‰€å±žåŒºåŽ¿
     */
    @Column(name = "group_name")
    private String groupName;
    /**
     * æ˜¯å¦åœ¨çº¿
     */
    @Column(name = "is_online")
    private String isOnline;
    /**
     * è®¾å¤‡æ˜¯å¦å¼‚常
     */
    @Column(name = "is_trouble")
    private String isTrouble;
    /**
     * æ›´æ–°æ—¶é—´
     */
    @Column(name = "jhpt_update_time")
    private String jhptUpdateTime;
    private String kindex;
    /**
     * çº¬åº¦
     */
    private String latitude;
    /**
     * è”系人
     */
    private String linkman;
    /**
     * ç»åº¦
     */
    private String longitude;
    /**
     * è”系人电话
     */
    private String phone;
    /**
     * æ‰€å±žçœä»½
     */
    private String province;
    /**
     * å†…中外环编码
     */
    @Column(name = "ring_id")
    private String ringId;
    /**
     * å†…中外环
     */
    @Column(name = "ring_name")
    private String ringName;
    /**
     * ç±»åž‹ç¼–码
     */
    @Column(name = "type_id")
    private String typeId;
    /**
     * ç±»åž‹åç§°
     */
    private String typename;
    /**
     * åœæ­¢æ—¶é—´
     */
    @Column(name = "stop_time")
    private Date stopTime;
    private String active;
    /**
     * æ•…障次数
     */
    @Column(name = "trouble_num")
    private Integer troubleNum;
    /**
     * æ–°å¢žæ—¶é—´
     */
    @Column(name = "insert_time")
    private Date insertTime;
    /**
     * é˜¶æ®µå¼€å§‹æ—¥æœŸ
     */
    @Column(name = "stage_begin_date")
    private Date stageBeginDate;
    /**
     * tsp浓度
     */
    private Double tsp;
    /**
     * ç»Ÿè®¡ç±»åž‹ç¼–码
     */
    @Column(name = "union_type_id")
    private String unionTypeId;
    /**
     * å›´å¢™é«˜åº¦
     */
    @Column(name = "wall_height")
    private String wallHeight;
    /**
     * ä¸šåŠ¡æ—¶é—´
     */
    @Column(name = "ywsj_date")
    private Date ywsjDate;
    /**
     * å»ºç­‘面积
     */
    @Column(name = "build_area")
    private String buildArea;
    /**
     * æ–½å·¥å•位
     */
    @Column(name = "construction_unit")
    private String constructionUnit;
    /**
     * ç‚¹ä½æŽ§åˆ¶çº§
     */
    @Column(name = "control_level")
    private String controlLevel;
    /**
     * å¼€å‘商
     */
    private String developers;
    /**
     * æ‰§è¡Œæ—¶é—´
     */
    @Column(name = "do_time")
    private Date doTime;
    /**
     * æ˜¯å¦æœ‰ç›‘测
     */
    @Column(name = "has_monitor")
    private String hasMonitor;
    /**
     * é‡‡é›†æ—¶é—´
     */
    @Column(name = "data_time")
    private Date dataTime;
    /**
     * å½“前施工阶段编码
     */
    @Column(name = "engineering_stage_code")
    private String engineeringStageCode;
    /**
     * è®¾å¤‡ç¼–码
     */
    @Column(name = "equipment_code")
    private String equipmentCode;
    /**
     * å åœ°é¢ç§¯
     */
    @Column(name = "floor_area")
    private String floorArea;
    /**
     * åˆ é™¤æ ‡å¿—位
     */
    @Column(name = "jhpt_delete")
    private String jhptDelete;
    /**
     * å™ªå£°åŠŸèƒ½åŒº
     */
    @Column(name = "noise_region")
    private String noiseRegion;
    /**
     * è´Ÿè´£äºº
     */
    private String responsible;
    /**
     * @return id
     */
    public Integer getId() {
        return id;
    }
    /**
     * @param id
     */
    public void setId(Integer id) {
        this.id = id;
    }
    /**
     * èŽ·å–è®¾å¤‡ç¼–ç 
     *
     * @return mn_code - è®¾å¤‡ç¼–码
     */
    public String getMnCode() {
        return mnCode;
    }
    /**
     * è®¾ç½®è®¾å¤‡ç¼–码
     *
     * @param mnCode è®¾å¤‡ç¼–码
     */
    public void setMnCode(String mnCode) {
        this.mnCode = mnCode == null ? null : mnCode.trim();
    }
    /**
     * èŽ·å–å®‰è£…åœ°å€
     *
     * @return address - å®‰è£…地址
     */
    public String getAddress() {
        return address;
    }
    /**
     * è®¾ç½®å®‰è£…地址
     *
     * @param address å®‰è£…地址
     */
    public void setAddress(String address) {
        this.address = address == null ? null : address.trim();
    }
    /**
     * èŽ·å–ç«™ç‚¹åç§°
     *
     * @return name - ç«™ç‚¹åç§°
     */
    public String getName() {
        return name;
    }
    /**
     * è®¾ç½®ç«™ç‚¹åç§°
     *
     * @param name ç«™ç‚¹åç§°
     */
    public void setName(String name) {
        this.name = name == null ? null : name.trim();
    }
    /**
     * èŽ·å–ç«™ç‚¹ç¼–ç 
     *
     * @return code - ç«™ç‚¹ç¼–码
     */
    public String getCode() {
        return code;
    }
    /**
     * è®¾ç½®ç«™ç‚¹ç¼–码
     *
     * @param code ç«™ç‚¹ç¼–码
     */
    public void setCode(String code) {
        this.code = code == null ? null : code.trim();
    }
    /**
     * èŽ·å–å¼€å·¥æ—¶é—´
     *
     * @return begin_date - å¼€å·¥æ—¶é—´
     */
    public Date getBeginDate() {
        return beginDate;
    }
    /**
     * è®¾ç½®å¼€å·¥æ—¶é—´
     *
     * @param beginDate å¼€å·¥æ—¶é—´
     */
    public void setBeginDate(Date beginDate) {
        this.beginDate = beginDate;
    }
    /**
     * èŽ·å–è¿ç»´å•†
     *
     * @return duty_company - è¿ç»´å•†
     */
    public String getDutyCompany() {
        return dutyCompany;
    }
    /**
     * è®¾ç½®è¿ç»´å•†
     *
     * @param dutyCompany è¿ç»´å•†
     */
    public void setDutyCompany(String dutyCompany) {
        this.dutyCompany = dutyCompany == null ? null : dutyCompany.trim();
    }
    /**
     * èŽ·å–è¿ç»´å•†id
     *
     * @return duty_company_id - è¿ç»´å•†id
     */
    public String getDutyCompanyId() {
        return dutyCompanyId;
    }
    /**
     * è®¾ç½®è¿ç»´å•†id
     *
     * @param dutyCompanyId è¿ç»´å•†id
     */
    public void setDutyCompanyId(String dutyCompanyId) {
        this.dutyCompanyId = dutyCompanyId == null ? null : dutyCompanyId.trim();
    }
    /**
     * èŽ·å–ç»“æŸæ—¶é—´
     *
     * @return end_date - ç»“束时间
     */
    public Date getEndDate() {
        return endDate;
    }
    /**
     * è®¾ç½®ç»“束时间
     *
     * @param endDate ç»“束时间
     */
    public void setEndDate(Date endDate) {
        this.endDate = endDate;
    }
    /**
     * èŽ·å–å½“å‰æ–½å·¥é˜¶æ®µ
     *
     * @return engineering_stage - å½“前施工阶段
     */
    public String getEngineeringStage() {
        return engineeringStage;
    }
    /**
     * è®¾ç½®å½“前施工阶段
     *
     * @param engineeringStage å½“前施工阶段
     */
    public void setEngineeringStage(String engineeringStage) {
        this.engineeringStage = engineeringStage == null ? null : engineeringStage.trim();
    }
    /**
     * èŽ·å–æ‰€å±žåŒºåŽ¿ä»£ç 
     *
     * @return group_id - æ‰€å±žåŒºåŽ¿ä»£ç 
     */
    public String getGroupId() {
        return groupId;
    }
    /**
     * è®¾ç½®æ‰€å±žåŒºåŽ¿ä»£ç 
     *
     * @param groupId æ‰€å±žåŒºåŽ¿ä»£ç 
     */
    public void setGroupId(String groupId) {
        this.groupId = groupId == null ? null : groupId.trim();
    }
    /**
     * èŽ·å–æ‰€å±žåŒºåŽ¿
     *
     * @return group_name - æ‰€å±žåŒºåŽ¿
     */
    public String getGroupName() {
        return groupName;
    }
    /**
     * è®¾ç½®æ‰€å±žåŒºåŽ¿
     *
     * @param groupName æ‰€å±žåŒºåŽ¿
     */
    public void setGroupName(String groupName) {
        this.groupName = groupName == null ? null : groupName.trim();
    }
    /**
     * èŽ·å–æ˜¯å¦åœ¨çº¿
     *
     * @return is_online - æ˜¯å¦åœ¨çº¿
     */
    public String getIsOnline() {
        return isOnline;
    }
    /**
     * è®¾ç½®æ˜¯å¦åœ¨çº¿
     *
     * @param isOnline æ˜¯å¦åœ¨çº¿
     */
    public void setIsOnline(String isOnline) {
        this.isOnline = isOnline == null ? null : isOnline.trim();
    }
    /**
     * èŽ·å–è®¾å¤‡æ˜¯å¦å¼‚å¸¸
     *
     * @return is_trouble - è®¾å¤‡æ˜¯å¦å¼‚常
     */
    public String getIsTrouble() {
        return isTrouble;
    }
    /**
     * è®¾ç½®è®¾å¤‡æ˜¯å¦å¼‚常
     *
     * @param isTrouble è®¾å¤‡æ˜¯å¦å¼‚常
     */
    public void setIsTrouble(String isTrouble) {
        this.isTrouble = isTrouble == null ? null : isTrouble.trim();
    }
    /**
     * èŽ·å–æ›´æ–°æ—¶é—´
     *
     * @return jhpt_update_time - æ›´æ–°æ—¶é—´
     */
    public String getJhptUpdateTime() {
        return jhptUpdateTime;
    }
    /**
     * è®¾ç½®æ›´æ–°æ—¶é—´
     *
     * @param jhptUpdateTime æ›´æ–°æ—¶é—´
     */
    public void setJhptUpdateTime(String jhptUpdateTime) {
        this.jhptUpdateTime = jhptUpdateTime == null ? null : jhptUpdateTime.trim();
    }
    /**
     * @return kindex
     */
    public String getKindex() {
        return kindex;
    }
    /**
     * @param kindex
     */
    public void setKindex(String kindex) {
        this.kindex = kindex == null ? null : kindex.trim();
    }
    /**
     * èŽ·å–çº¬åº¦
     *
     * @return latitude - çº¬åº¦
     */
    public String getLatitude() {
        return latitude;
    }
    /**
     * è®¾ç½®çº¬åº¦
     *
     * @param latitude çº¬åº¦
     */
    public void setLatitude(String latitude) {
        this.latitude = latitude == null ? null : latitude.trim();
    }
    /**
     * èŽ·å–è”ç³»äºº
     *
     * @return linkman - è”系人
     */
    public String getLinkman() {
        return linkman;
    }
    /**
     * è®¾ç½®è”系人
     *
     * @param linkman è”系人
     */
    public void setLinkman(String linkman) {
        this.linkman = linkman == null ? null : linkman.trim();
    }
    /**
     * èŽ·å–ç»åº¦
     *
     * @return longitude - ç»åº¦
     */
    public String getLongitude() {
        return longitude;
    }
    /**
     * è®¾ç½®ç»åº¦
     *
     * @param longitude ç»åº¦
     */
    public void setLongitude(String longitude) {
        this.longitude = longitude == null ? null : longitude.trim();
    }
    /**
     * èŽ·å–è”ç³»äººç”µè¯
     *
     * @return phone - è”系人电话
     */
    public String getPhone() {
        return phone;
    }
    /**
     * è®¾ç½®è”系人电话
     *
     * @param phone è”系人电话
     */
    public void setPhone(String phone) {
        this.phone = phone == null ? null : phone.trim();
    }
    /**
     * èŽ·å–æ‰€å±žçœä»½
     *
     * @return province - æ‰€å±žçœä»½
     */
    public String getProvince() {
        return province;
    }
    /**
     * è®¾ç½®æ‰€å±žçœä»½
     *
     * @param province æ‰€å±žçœä»½
     */
    public void setProvince(String province) {
        this.province = province == null ? null : province.trim();
    }
    /**
     * èŽ·å–å†…ä¸­å¤–çŽ¯ç¼–ç 
     *
     * @return ring_id - å†…中外环编码
     */
    public String getRingId() {
        return ringId;
    }
    /**
     * è®¾ç½®å†…中外环编码
     *
     * @param ringId å†…中外环编码
     */
    public void setRingId(String ringId) {
        this.ringId = ringId == null ? null : ringId.trim();
    }
    /**
     * èŽ·å–å†…ä¸­å¤–çŽ¯
     *
     * @return ring_name - å†…中外环
     */
    public String getRingName() {
        return ringName;
    }
    /**
     * è®¾ç½®å†…中外环
     *
     * @param ringName å†…中外环
     */
    public void setRingName(String ringName) {
        this.ringName = ringName == null ? null : ringName.trim();
    }
    /**
     * èŽ·å–ç±»åž‹ç¼–ç 
     *
     * @return type_id - ç±»åž‹ç¼–码
     */
    public String getTypeId() {
        return typeId;
    }
    /**
     * è®¾ç½®ç±»åž‹ç¼–码
     *
     * @param typeId ç±»åž‹ç¼–码
     */
    public void setTypeId(String typeId) {
        this.typeId = typeId == null ? null : typeId.trim();
    }
    /**
     * èŽ·å–ç±»åž‹åç§°
     *
     * @return typename - ç±»åž‹åç§°
     */
    public String getTypename() {
        return typename;
    }
    /**
     * è®¾ç½®ç±»åž‹åç§°
     *
     * @param typename ç±»åž‹åç§°
     */
    public void setTypename(String typename) {
        this.typename = typename == null ? null : typename.trim();
    }
    /**
     * èŽ·å–åœæ­¢æ—¶é—´
     *
     * @return stop_time - åœæ­¢æ—¶é—´
     */
    public Date getStopTime() {
        return stopTime;
    }
    /**
     * è®¾ç½®åœæ­¢æ—¶é—´
     *
     * @param stopTime åœæ­¢æ—¶é—´
     */
    public void setStopTime(Date stopTime) {
        this.stopTime = stopTime;
    }
    /**
     * @return active
     */
    public String getActive() {
        return active;
    }
    /**
     * @param active
     */
    public void setActive(String active) {
        this.active = active == null ? null : active.trim();
    }
    /**
     * èŽ·å–æ•…éšœæ¬¡æ•°
     *
     * @return trouble_num - æ•…障次数
     */
    public Integer getTroubleNum() {
        return troubleNum;
    }
    /**
     * è®¾ç½®æ•…障次数
     *
     * @param troubleNum æ•…障次数
     */
    public void setTroubleNum(Integer troubleNum) {
        this.troubleNum = troubleNum;
    }
    /**
     * èŽ·å–æ–°å¢žæ—¶é—´
     *
     * @return insert_time - æ–°å¢žæ—¶é—´
     */
    public Date getInsertTime() {
        return insertTime;
    }
    /**
     * è®¾ç½®æ–°å¢žæ—¶é—´
     *
     * @param insertTime æ–°å¢žæ—¶é—´
     */
    public void setInsertTime(Date insertTime) {
        this.insertTime = insertTime;
    }
    /**
     * èŽ·å–é˜¶æ®µå¼€å§‹æ—¥æœŸ
     *
     * @return stage_begin_date - é˜¶æ®µå¼€å§‹æ—¥æœŸ
     */
    public Date getStageBeginDate() {
        return stageBeginDate;
    }
    /**
     * è®¾ç½®é˜¶æ®µå¼€å§‹æ—¥æœŸ
     *
     * @param stageBeginDate é˜¶æ®µå¼€å§‹æ—¥æœŸ
     */
    public void setStageBeginDate(Date stageBeginDate) {
        this.stageBeginDate = stageBeginDate;
    }
    /**
     * èŽ·å–tsp浓度
     *
     * @return tsp - tsp浓度
     */
    public Double getTsp() {
        return tsp;
    }
    /**
     * è®¾ç½®tsp浓度
     *
     * @param tsp tsp浓度
     */
    public void setTsp(Double tsp) {
        this.tsp = tsp;
    }
    /**
     * èŽ·å–ç»Ÿè®¡ç±»åž‹ç¼–ç 
     *
     * @return union_type_id - ç»Ÿè®¡ç±»åž‹ç¼–码
     */
    public String getUnionTypeId() {
        return unionTypeId;
    }
    /**
     * è®¾ç½®ç»Ÿè®¡ç±»åž‹ç¼–码
     *
     * @param unionTypeId ç»Ÿè®¡ç±»åž‹ç¼–码
     */
    public void setUnionTypeId(String unionTypeId) {
        this.unionTypeId = unionTypeId == null ? null : unionTypeId.trim();
    }
    /**
     * èŽ·å–å›´å¢™é«˜åº¦
     *
     * @return wall_height - å›´å¢™é«˜åº¦
     */
    public String getWallHeight() {
        return wallHeight;
    }
    /**
     * è®¾ç½®å›´å¢™é«˜åº¦
     *
     * @param wallHeight å›´å¢™é«˜åº¦
     */
    public void setWallHeight(String wallHeight) {
        this.wallHeight = wallHeight == null ? null : wallHeight.trim();
    }
    /**
     * èŽ·å–ä¸šåŠ¡æ—¶é—´
     *
     * @return ywsj_date - ä¸šåŠ¡æ—¶é—´
     */
    public Date getYwsjDate() {
        return ywsjDate;
    }
    /**
     * è®¾ç½®ä¸šåŠ¡æ—¶é—´
     *
     * @param ywsjDate ä¸šåŠ¡æ—¶é—´
     */
    public void setYwsjDate(Date ywsjDate) {
        this.ywsjDate = ywsjDate;
    }
    /**
     * èŽ·å–å»ºç­‘é¢ç§¯
     *
     * @return build_area - å»ºç­‘面积
     */
    public String getBuildArea() {
        return buildArea;
    }
    /**
     * è®¾ç½®å»ºç­‘面积
     *
     * @param buildArea å»ºç­‘面积
     */
    public void setBuildArea(String buildArea) {
        this.buildArea = buildArea == null ? null : buildArea.trim();
    }
    /**
     * èŽ·å–æ–½å·¥å•ä½
     *
     * @return construction_unit - æ–½å·¥å•位
     */
    public String getConstructionUnit() {
        return constructionUnit;
    }
    /**
     * è®¾ç½®æ–½å·¥å•位
     *
     * @param constructionUnit æ–½å·¥å•位
     */
    public void setConstructionUnit(String constructionUnit) {
        this.constructionUnit = constructionUnit == null ? null : constructionUnit.trim();
    }
    /**
     * èŽ·å–ç‚¹ä½æŽ§åˆ¶çº§
     *
     * @return control_level - ç‚¹ä½æŽ§åˆ¶çº§
     */
    public String getControlLevel() {
        return controlLevel;
    }
    /**
     * è®¾ç½®ç‚¹ä½æŽ§åˆ¶çº§
     *
     * @param controlLevel ç‚¹ä½æŽ§åˆ¶çº§
     */
    public void setControlLevel(String controlLevel) {
        this.controlLevel = controlLevel == null ? null : controlLevel.trim();
    }
    /**
     * èŽ·å–å¼€å‘å•†
     *
     * @return developers - å¼€å‘商
     */
    public String getDevelopers() {
        return developers;
    }
    /**
     * è®¾ç½®å¼€å‘商
     *
     * @param developers å¼€å‘商
     */
    public void setDevelopers(String developers) {
        this.developers = developers == null ? null : developers.trim();
    }
    /**
     * èŽ·å–æ‰§è¡Œæ—¶é—´
     *
     * @return do_time - æ‰§è¡Œæ—¶é—´
     */
    public Date getDoTime() {
        return doTime;
    }
    /**
     * è®¾ç½®æ‰§è¡Œæ—¶é—´
     *
     * @param doTime æ‰§è¡Œæ—¶é—´
     */
    public void setDoTime(Date doTime) {
        this.doTime = doTime;
    }
    /**
     * èŽ·å–æ˜¯å¦æœ‰ç›‘æµ‹
     *
     * @return has_monitor - æ˜¯å¦æœ‰ç›‘测
     */
    public String getHasMonitor() {
        return hasMonitor;
    }
    /**
     * è®¾ç½®æ˜¯å¦æœ‰ç›‘测
     *
     * @param hasMonitor æ˜¯å¦æœ‰ç›‘测
     */
    public void setHasMonitor(String hasMonitor) {
        this.hasMonitor = hasMonitor == null ? null : hasMonitor.trim();
    }
    /**
     * èŽ·å–é‡‡é›†æ—¶é—´
     *
     * @return data_time - é‡‡é›†æ—¶é—´
     */
    public Date getDataTime() {
        return dataTime;
    }
    /**
     * è®¾ç½®é‡‡é›†æ—¶é—´
     *
     * @param dataTime é‡‡é›†æ—¶é—´
     */
    public void setDataTime(Date dataTime) {
        this.dataTime = dataTime;
    }
    /**
     * èŽ·å–å½“å‰æ–½å·¥é˜¶æ®µç¼–ç 
     *
     * @return engineering_stage_code - å½“前施工阶段编码
     */
    public String getEngineeringStageCode() {
        return engineeringStageCode;
    }
    /**
     * è®¾ç½®å½“前施工阶段编码
     *
     * @param engineeringStageCode å½“前施工阶段编码
     */
    public void setEngineeringStageCode(String engineeringStageCode) {
        this.engineeringStageCode = engineeringStageCode == null ? null : engineeringStageCode.trim();
    }
    /**
     * èŽ·å–è®¾å¤‡ç¼–ç 
     *
     * @return equipment_code - è®¾å¤‡ç¼–码
     */
    public String getEquipmentCode() {
        return equipmentCode;
    }
    /**
     * è®¾ç½®è®¾å¤‡ç¼–码
     *
     * @param equipmentCode è®¾å¤‡ç¼–码
     */
    public void setEquipmentCode(String equipmentCode) {
        this.equipmentCode = equipmentCode == null ? null : equipmentCode.trim();
    }
    /**
     * èŽ·å–å åœ°é¢ç§¯
     *
     * @return floor_area - å åœ°é¢ç§¯
     */
    public String getFloorArea() {
        return floorArea;
    }
    /**
     * è®¾ç½®å åœ°é¢ç§¯
     *
     * @param floorArea å åœ°é¢ç§¯
     */
    public void setFloorArea(String floorArea) {
        this.floorArea = floorArea == null ? null : floorArea.trim();
    }
    /**
     * èŽ·å–åˆ é™¤æ ‡å¿—ä½
     *
     * @return jhpt_delete - åˆ é™¤æ ‡å¿—位
     */
    public String getJhptDelete() {
        return jhptDelete;
    }
    /**
     * è®¾ç½®åˆ é™¤æ ‡å¿—位
     *
     * @param jhptDelete åˆ é™¤æ ‡å¿—位
     */
    public void setJhptDelete(String jhptDelete) {
        this.jhptDelete = jhptDelete == null ? null : jhptDelete.trim();
    }
    /**
     * èŽ·å–å™ªå£°åŠŸèƒ½åŒº
     *
     * @return noise_region - å™ªå£°åŠŸèƒ½åŒº
     */
    public String getNoiseRegion() {
        return noiseRegion;
    }
    /**
     * è®¾ç½®å™ªå£°åŠŸèƒ½åŒº
     *
     * @param noiseRegion å™ªå£°åŠŸèƒ½åŒº
     */
    public void setNoiseRegion(String noiseRegion) {
        this.noiseRegion = noiseRegion == null ? null : noiseRegion.trim();
    }
    /**
     * èŽ·å–è´Ÿè´£äºº
     *
     * @return responsible - è´Ÿè´£äºº
     */
    public String getResponsible() {
        return responsible;
    }
    /**
     * è®¾ç½®è´Ÿè´£äºº
     *
     * @param responsible è´Ÿè´£äºº
     */
    public void setResponsible(String responsible) {
        this.responsible = responsible == null ? null : responsible.trim();
    }
}
src/main/java/com/flightfeather/monitor/domain/ds1/entity/DustSiteLatestTime.java
¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,59 @@
package com.flightfeather.monitor.domain.ds1.entity;
import java.util.Date;
import javax.persistence.*;
@Table(name = "du_js_t_site_latest_time")
public class DustSiteLatestTime {
    @Id
    @Column(name = "mn_code")
    private String mnCode;
    @Column(name = "latest_time")
    private Date latestTime;
    @Column(name = "device_status")
    private Integer deviceStatus;
    /**
     * @return mn_code
     */
    public String getMnCode() {
        return mnCode;
    }
    /**
     * @param mnCode
     */
    public void setMnCode(String mnCode) {
        this.mnCode = mnCode == null ? null : mnCode.trim();
    }
    /**
     * @return latest_time
     */
    public Date getLatestTime() {
        return latestTime;
    }
    /**
     * @param latestTime
     */
    public void setLatestTime(Date latestTime) {
        this.latestTime = latestTime;
    }
    /**
     * @return device_status
     */
    public Integer getDeviceStatus() {
        return deviceStatus;
    }
    /**
     * @param deviceStatus
     */
    public void setDeviceStatus(Integer deviceStatus) {
        this.deviceStatus = deviceStatus;
    }
}
src/main/java/com/flightfeather/monitor/domain/ds1/entity/DustSiteMap.java
¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,144 @@
package com.flightfeather.monitor.domain.ds1.entity;
import java.util.Date;
import javax.persistence.*;
@Table(name = "du_js_t_site_map")
public class DustSiteMap {
    @Id
    @Column(name = "Id")
    private Integer id;
    @Column(name = "TZ_User_Id")
    private String tzUserId;
    @Column(name = "TZ_User_Name")
    private String tzUserName;
    @Column(name = "JS_Device_Code")
    private String jsDeviceCode;
    @Column(name = "JS_Device_Name")
    private String jsDeviceName;
    @Column(name = "SV_User_Id")
    private String svUserId;
    @Column(name = "SV_User_Name")
    private String svUserName;
    @Column(name = "Create_Time")
    private Date createTime;
    /**
     * @return Id
     */
    public Integer getId() {
        return id;
    }
    /**
     * @param id
     */
    public void setId(Integer id) {
        this.id = id;
    }
    /**
     * @return TZ_User_Id
     */
    public String getTzUserId() {
        return tzUserId;
    }
    /**
     * @param tzUserId
     */
    public void setTzUserId(String tzUserId) {
        this.tzUserId = tzUserId == null ? null : tzUserId.trim();
    }
    /**
     * @return TZ_User_Name
     */
    public String getTzUserName() {
        return tzUserName;
    }
    /**
     * @param tzUserName
     */
    public void setTzUserName(String tzUserName) {
        this.tzUserName = tzUserName == null ? null : tzUserName.trim();
    }
    /**
     * @return JS_Device_Code
     */
    public String getJsDeviceCode() {
        return jsDeviceCode;
    }
    /**
     * @param jsDeviceCode
     */
    public void setJsDeviceCode(String jsDeviceCode) {
        this.jsDeviceCode = jsDeviceCode == null ? null : jsDeviceCode.trim();
    }
    /**
     * @return JS_Device_Name
     */
    public String getJsDeviceName() {
        return jsDeviceName;
    }
    /**
     * @param jsDeviceName
     */
    public void setJsDeviceName(String jsDeviceName) {
        this.jsDeviceName = jsDeviceName == null ? null : jsDeviceName.trim();
    }
    /**
     * @return SV_User_Id
     */
    public String getSvUserId() {
        return svUserId;
    }
    /**
     * @param svUserId
     */
    public void setSvUserId(String svUserId) {
        this.svUserId = svUserId == null ? null : svUserId.trim();
    }
    /**
     * @return SV_User_Name
     */
    public String getSvUserName() {
        return svUserName;
    }
    /**
     * @param svUserName
     */
    public void setSvUserName(String svUserName) {
        this.svUserName = svUserName == null ? null : svUserName.trim();
    }
    /**
     * @return Create_Time
     */
    public Date getCreateTime() {
        return createTime;
    }
    /**
     * @param createTime
     */
    public void setCreateTime(Date createTime) {
        this.createTime = createTime;
    }
}
src/main/java/com/flightfeather/monitor/domain/ds1/entity/DustStatisticsValue.java
¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,173 @@
package com.flightfeather.monitor.domain.ds1.entity;
import java.util.Date;
import javax.persistence.*;
@Table(name = "dust_statistics_value")
public class DustStatisticsValue {
    @Id
    private Integer id;
    @Column(name = "mn_code")
    private String mnCode;
    private Date lst;
    @Column(name = "day_avg")
    private String dayAvg;
    private String min;
    private String max;
    @Column(name = "day_online")
    private String dayOnline;
    @Column(name = "day_valid")
    private String dayValid;
    @Column(name = "day_exceeding")
    private String dayExceeding;
    private String type;
    /**
     * @return id
     */
    public Integer getId() {
        return id;
    }
    /**
     * @param id
     */
    public void setId(Integer id) {
        this.id = id;
    }
    /**
     * @return mn_code
     */
    public String getMnCode() {
        return mnCode;
    }
    /**
     * @param mnCode
     */
    public void setMnCode(String mnCode) {
        this.mnCode = mnCode == null ? null : mnCode.trim();
    }
    /**
     * @return lst
     */
    public Date getLst() {
        return lst;
    }
    /**
     * @param lst
     */
    public void setLst(Date lst) {
        this.lst = lst;
    }
    /**
     * @return day_avg
     */
    public String getDayAvg() {
        return dayAvg;
    }
    /**
     * @param dayAvg
     */
    public void setDayAvg(String dayAvg) {
        this.dayAvg = dayAvg == null ? null : dayAvg.trim();
    }
    /**
     * @return min
     */
    public String getMin() {
        return min;
    }
    /**
     * @param min
     */
    public void setMin(String min) {
        this.min = min == null ? null : min.trim();
    }
    /**
     * @return max
     */
    public String getMax() {
        return max;
    }
    /**
     * @param max
     */
    public void setMax(String max) {
        this.max = max == null ? null : max.trim();
    }
    /**
     * @return day_online
     */
    public String getDayOnline() {
        return dayOnline;
    }
    /**
     * @param dayOnline
     */
    public void setDayOnline(String dayOnline) {
        this.dayOnline = dayOnline == null ? null : dayOnline.trim();
    }
    /**
     * @return day_valid
     */
    public String getDayValid() {
        return dayValid;
    }
    /**
     * @param dayValid
     */
    public void setDayValid(String dayValid) {
        this.dayValid = dayValid == null ? null : dayValid.trim();
    }
    /**
     * @return day_exceeding
     */
    public String getDayExceeding() {
        return dayExceeding;
    }
    /**
     * @param dayExceeding
     */
    public void setDayExceeding(String dayExceeding) {
        this.dayExceeding = dayExceeding == null ? null : dayExceeding.trim();
    }
    /**
     * @return type
     */
    public String getType() {
        return type;
    }
    /**
     * @param type
     */
    public void setType(String type) {
        this.type = type == null ? null : type.trim();
    }
}
src/main/java/com/flightfeather/monitor/domain/ds1/entity/LoginInfo.java
¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,106 @@
package com.flightfeather.monitor.domain.ds1.entity;
import java.util.Date;
import javax.persistence.*;
@Table(name = "du_js_t_login_info")
public class LoginInfo {
    @Id
    private Integer id;
    @Column(name = "user_name")
    private String userName;
    private String password;
    private String cookie;
    @Column(name = "cookie_timestamp")
    private Date cookieTimestamp;
    private String region;
    /**
     * @return id
     */
    public Integer getId() {
        return id;
    }
    /**
     * @param id
     */
    public void setId(Integer id) {
        this.id = id;
    }
    /**
     * @return user_name
     */
    public String getUserName() {
        return userName;
    }
    /**
     * @param userName
     */
    public void setUserName(String userName) {
        this.userName = userName == null ? null : userName.trim();
    }
    /**
     * @return password
     */
    public String getPassword() {
        return password;
    }
    /**
     * @param password
     */
    public void setPassword(String password) {
        this.password = password == null ? null : password.trim();
    }
    /**
     * @return cookie
     */
    public String getCookie() {
        return cookie;
    }
    /**
     * @param cookie
     */
    public void setCookie(String cookie) {
        this.cookie = cookie == null ? null : cookie.trim();
    }
    /**
     * @return cookie_timestamp
     */
    public Date getCookieTimestamp() {
        return cookieTimestamp;
    }
    /**
     * @param cookieTimestamp
     */
    public void setCookieTimestamp(Date cookieTimestamp) {
        this.cookieTimestamp = cookieTimestamp;
    }
    /**
     * @return region
     */
    public String getRegion() {
        return region;
    }
    /**
     * @param region
     */
    public void setRegion(String region) {
        this.region = region == null ? null : region.trim();
    }
}
src/main/java/com/flightfeather/monitor/domain/ds1/entity/RequestTaskSetting.java
¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,411 @@
package com.flightfeather.monitor.domain.ds1.entity;
import java.util.Date;
import javax.persistence.*;
@Table(name = "du_js_t_request_task_setting")
public class RequestTaskSetting {
    @Id
    private Integer id;
    private String user;
    @Column(name = "update_time")
    private Date updateTime;
    private String region;
    private String version;
    /**
     * æ•°æ®çˆ¬å–开始时间
     */
    @Column(name = "request_start_time")
    private Date requestStartTime;
    /**
     * æ•°æ®çˆ¬å–结束时间
     */
    @Column(name = "request_end_time")
    private Date requestEndTime;
    /**
     * åœ¨çˆ¬å–任务开始结束时间内,爬取的频率
     */
    @Column(name = "request_interval_seconds")
    private Integer requestIntervalSeconds;
    /**
     * ä¸€æ¬¡æ•°æ®çˆ¬å–任务中,按总时长分段执行的每段时间长度
     */
    @Column(name = "request_range_hour")
    private Integer requestRangeHour;
    /**
     * ä¸€æ¬¡æ•°æ®çˆ¬å–任务中,分段执行时的每段的间隔时间
     */
    @Column(name = "request_range_interval_seconds")
    private Integer requestRangeIntervalSeconds;
    /**
     * çˆ¬å–任务异常时再次尝试间隔
     */
    @Column(name = "request_fail_wait_seconds")
    private Integer requestFailWaitSeconds;
    /**
     * çˆ¬å–失败时再次尝试的总次数
     */
    @Column(name = "request_retry_times")
    private Integer requestRetryTimes;
    @Column(name = "statics_daily_time")
    private Date staticsDailyTime;
    @Column(name = "statics_monthly_time")
    private Date staticsMonthlyTime;
    /**
     * å•次登陆失败重新尝试等待时间
     */
    @Column(name = "login_fail_wait_seconds")
    private Integer loginFailWaitSeconds;
    /**
     * ç™»é™†å¤±è´¥è¿žç»­å°è¯•次数
     */
    @Column(name = "login_retry_times")
    private Integer loginRetryTimes;
    /**
     * æ•´ä¸ªçˆ¬å–任务重新开始尝试等待时间
     */
    @Column(name = "task_retry_wait_seconds")
    private Integer taskRetryWaitSeconds;
    /**
     * ç¨‹åºé¦–次执行, ç«™ç‚¹æ•°æ®æœ€æ–°æ—¶åˆ»è¡¨ä¸ºç©ºæ—¶, æ•°æ®èŽ·å–å¼€å§‹æ—¶é—´ç›¸å¯¹å½“æ—¥å¾€å‰åç§»çš„å¤©æ•°
     */
    @Column(name = "first_request_offset_days")
    private Integer firstRequestOffsetDays;
    /**
     * cookie有效时长,单位小时
     */
    @Column(name = "request_cookie_valid_duration")
    private Integer requestCookieValidDuration;
    /**
     * @return id
     */
    public Integer getId() {
        return id;
    }
    /**
     * @param id
     */
    public void setId(Integer id) {
        this.id = id;
    }
    /**
     * @return user
     */
    public String getUser() {
        return user;
    }
    /**
     * @param user
     */
    public void setUser(String user) {
        this.user = user == null ? null : user.trim();
    }
    /**
     * @return update_time
     */
    public Date getUpdateTime() {
        return updateTime;
    }
    /**
     * @param updateTime
     */
    public void setUpdateTime(Date updateTime) {
        this.updateTime = updateTime;
    }
    /**
     * @return region
     */
    public String getRegion() {
        return region;
    }
    /**
     * @param region
     */
    public void setRegion(String region) {
        this.region = region == null ? null : region.trim();
    }
    /**
     * @return version
     */
    public String getVersion() {
        return version;
    }
    /**
     * @param version
     */
    public void setVersion(String version) {
        this.version = version == null ? null : version.trim();
    }
    /**
     * èŽ·å–æ•°æ®çˆ¬å–å¼€å§‹æ—¶é—´
     *
     * @return request_start_time - æ•°æ®çˆ¬å–开始时间
     */
    public Date getRequestStartTime() {
        return requestStartTime;
    }
    /**
     * è®¾ç½®æ•°æ®çˆ¬å–开始时间
     *
     * @param requestStartTime æ•°æ®çˆ¬å–开始时间
     */
    public void setRequestStartTime(Date requestStartTime) {
        this.requestStartTime = requestStartTime;
    }
    /**
     * èŽ·å–æ•°æ®çˆ¬å–ç»“æŸæ—¶é—´
     *
     * @return request_end_time - æ•°æ®çˆ¬å–结束时间
     */
    public Date getRequestEndTime() {
        return requestEndTime;
    }
    /**
     * è®¾ç½®æ•°æ®çˆ¬å–结束时间
     *
     * @param requestEndTime æ•°æ®çˆ¬å–结束时间
     */
    public void setRequestEndTime(Date requestEndTime) {
        this.requestEndTime = requestEndTime;
    }
    /**
     * èŽ·å–åœ¨çˆ¬å–ä»»åŠ¡å¼€å§‹ç»“æŸæ—¶é—´å†…ï¼Œçˆ¬å–çš„é¢‘çŽ‡
     *
     * @return request_interval_seconds - åœ¨çˆ¬å–任务开始结束时间内,爬取的频率
     */
    public Integer getRequestIntervalSeconds() {
        return requestIntervalSeconds;
    }
    /**
     * è®¾ç½®åœ¨çˆ¬å–任务开始结束时间内,爬取的频率
     *
     * @param requestIntervalSeconds åœ¨çˆ¬å–任务开始结束时间内,爬取的频率
     */
    public void setRequestIntervalSeconds(Integer requestIntervalSeconds) {
        this.requestIntervalSeconds = requestIntervalSeconds;
    }
    /**
     * èŽ·å–ä¸€æ¬¡æ•°æ®çˆ¬å–ä»»åŠ¡ä¸­ï¼ŒæŒ‰æ€»æ—¶é•¿åˆ†æ®µæ‰§è¡Œçš„æ¯æ®µæ—¶é—´é•¿åº¦
     *
     * @return request_range_hour - ä¸€æ¬¡æ•°æ®çˆ¬å–任务中,按总时长分段执行的每段时间长度
     */
    public Integer getRequestRangeHour() {
        return requestRangeHour;
    }
    /**
     * è®¾ç½®ä¸€æ¬¡æ•°æ®çˆ¬å–任务中,按总时长分段执行的每段时间长度
     *
     * @param requestRangeHour ä¸€æ¬¡æ•°æ®çˆ¬å–任务中,按总时长分段执行的每段时间长度
     */
    public void setRequestRangeHour(Integer requestRangeHour) {
        this.requestRangeHour = requestRangeHour;
    }
    /**
     * èŽ·å–ä¸€æ¬¡æ•°æ®çˆ¬å–ä»»åŠ¡ä¸­ï¼Œåˆ†æ®µæ‰§è¡Œæ—¶çš„æ¯æ®µçš„é—´éš”æ—¶é—´
     *
     * @return request_range_interval_seconds - ä¸€æ¬¡æ•°æ®çˆ¬å–任务中,分段执行时的每段的间隔时间
     */
    public Integer getRequestRangeIntervalSeconds() {
        return requestRangeIntervalSeconds;
    }
    /**
     * è®¾ç½®ä¸€æ¬¡æ•°æ®çˆ¬å–任务中,分段执行时的每段的间隔时间
     *
     * @param requestRangeIntervalSeconds ä¸€æ¬¡æ•°æ®çˆ¬å–任务中,分段执行时的每段的间隔时间
     */
    public void setRequestRangeIntervalSeconds(Integer requestRangeIntervalSeconds) {
        this.requestRangeIntervalSeconds = requestRangeIntervalSeconds;
    }
    /**
     * èŽ·å–çˆ¬å–ä»»åŠ¡å¼‚å¸¸æ—¶å†æ¬¡å°è¯•é—´éš”
     *
     * @return request_fail_wait_seconds - çˆ¬å–任务异常时再次尝试间隔
     */
    public Integer getRequestFailWaitSeconds() {
        return requestFailWaitSeconds;
    }
    /**
     * è®¾ç½®çˆ¬å–任务异常时再次尝试间隔
     *
     * @param requestFailWaitSeconds çˆ¬å–任务异常时再次尝试间隔
     */
    public void setRequestFailWaitSeconds(Integer requestFailWaitSeconds) {
        this.requestFailWaitSeconds = requestFailWaitSeconds;
    }
    /**
     * èŽ·å–çˆ¬å–å¤±è´¥æ—¶å†æ¬¡å°è¯•çš„æ€»æ¬¡æ•°
     *
     * @return request_retry_times - çˆ¬å–失败时再次尝试的总次数
     */
    public Integer getRequestRetryTimes() {
        return requestRetryTimes;
    }
    /**
     * è®¾ç½®çˆ¬å–失败时再次尝试的总次数
     *
     * @param requestRetryTimes çˆ¬å–失败时再次尝试的总次数
     */
    public void setRequestRetryTimes(Integer requestRetryTimes) {
        this.requestRetryTimes = requestRetryTimes;
    }
    /**
     * @return statics_daily_time
     */
    public Date getStaticsDailyTime() {
        return staticsDailyTime;
    }
    /**
     * @param staticsDailyTime
     */
    public void setStaticsDailyTime(Date staticsDailyTime) {
        this.staticsDailyTime = staticsDailyTime;
    }
    /**
     * @return statics_monthly_time
     */
    public Date getStaticsMonthlyTime() {
        return staticsMonthlyTime;
    }
    /**
     * @param staticsMonthlyTime
     */
    public void setStaticsMonthlyTime(Date staticsMonthlyTime) {
        this.staticsMonthlyTime = staticsMonthlyTime;
    }
    /**
     * èŽ·å–å•æ¬¡ç™»é™†å¤±è´¥é‡æ–°å°è¯•ç­‰å¾…æ—¶é—´
     *
     * @return login_fail_wait_seconds - å•次登陆失败重新尝试等待时间
     */
    public Integer getLoginFailWaitSeconds() {
        return loginFailWaitSeconds;
    }
    /**
     * è®¾ç½®å•次登陆失败重新尝试等待时间
     *
     * @param loginFailWaitSeconds å•次登陆失败重新尝试等待时间
     */
    public void setLoginFailWaitSeconds(Integer loginFailWaitSeconds) {
        this.loginFailWaitSeconds = loginFailWaitSeconds;
    }
    /**
     * èŽ·å–ç™»é™†å¤±è´¥è¿žç»­å°è¯•æ¬¡æ•°
     *
     * @return login_retry_times - ç™»é™†å¤±è´¥è¿žç»­å°è¯•次数
     */
    public Integer getLoginRetryTimes() {
        return loginRetryTimes;
    }
    /**
     * è®¾ç½®ç™»é™†å¤±è´¥è¿žç»­å°è¯•次数
     *
     * @param loginRetryTimes ç™»é™†å¤±è´¥è¿žç»­å°è¯•次数
     */
    public void setLoginRetryTimes(Integer loginRetryTimes) {
        this.loginRetryTimes = loginRetryTimes;
    }
    /**
     * èŽ·å–æ•´ä¸ªçˆ¬å–ä»»åŠ¡é‡æ–°å¼€å§‹å°è¯•ç­‰å¾…æ—¶é—´
     *
     * @return task_retry_wait_seconds - æ•´ä¸ªçˆ¬å–任务重新开始尝试等待时间
     */
    public Integer getTaskRetryWaitSeconds() {
        return taskRetryWaitSeconds;
    }
    /**
     * è®¾ç½®æ•´ä¸ªçˆ¬å–任务重新开始尝试等待时间
     *
     * @param taskRetryWaitSeconds æ•´ä¸ªçˆ¬å–任务重新开始尝试等待时间
     */
    public void setTaskRetryWaitSeconds(Integer taskRetryWaitSeconds) {
        this.taskRetryWaitSeconds = taskRetryWaitSeconds;
    }
    /**
     * èŽ·å–ç¨‹åºé¦–æ¬¡æ‰§è¡Œ, ç«™ç‚¹æ•°æ®æœ€æ–°æ—¶åˆ»è¡¨ä¸ºç©ºæ—¶, æ•°æ®èŽ·å–å¼€å§‹æ—¶é—´ç›¸å¯¹å½“æ—¥å¾€å‰åç§»çš„å¤©æ•°
     *
     * @return first_request_offset_days - ç¨‹åºé¦–次执行, ç«™ç‚¹æ•°æ®æœ€æ–°æ—¶åˆ»è¡¨ä¸ºç©ºæ—¶, æ•°æ®èŽ·å–å¼€å§‹æ—¶é—´ç›¸å¯¹å½“æ—¥å¾€å‰åç§»çš„å¤©æ•°
     */
    public Integer getFirstRequestOffsetDays() {
        return firstRequestOffsetDays;
    }
    /**
     * è®¾ç½®ç¨‹åºé¦–次执行, ç«™ç‚¹æ•°æ®æœ€æ–°æ—¶åˆ»è¡¨ä¸ºç©ºæ—¶, æ•°æ®èŽ·å–å¼€å§‹æ—¶é—´ç›¸å¯¹å½“æ—¥å¾€å‰åç§»çš„å¤©æ•°
     *
     * @param firstRequestOffsetDays ç¨‹åºé¦–次执行, ç«™ç‚¹æ•°æ®æœ€æ–°æ—¶åˆ»è¡¨ä¸ºç©ºæ—¶, æ•°æ®èŽ·å–å¼€å§‹æ—¶é—´ç›¸å¯¹å½“æ—¥å¾€å‰åç§»çš„å¤©æ•°
     */
    public void setFirstRequestOffsetDays(Integer firstRequestOffsetDays) {
        this.firstRequestOffsetDays = firstRequestOffsetDays;
    }
    /**
     * èŽ·å–cookie有效时长,单位小时
     *
     * @return request_cookie_valid_duration - cookie有效时长,单位小时
     */
    public Integer getRequestCookieValidDuration() {
        return requestCookieValidDuration;
    }
    /**
     * è®¾ç½®cookie有效时长,单位小时
     *
     * @param requestCookieValidDuration cookie有效时长,单位小时
     */
    public void setRequestCookieValidDuration(Integer requestCookieValidDuration) {
        this.requestCookieValidDuration = requestCookieValidDuration;
    }
}
src/main/java/com/flightfeather/monitor/domain/ds1/mapper/DustExceptionDataMapper.kt
¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,8 @@
package com.flightfeather.monitor.domain.ds1.mapper
import com.flightfeather.monitor.domain.ds1.entity.DustExceptionData
import com.flightfeather.monitor.domain.util.MyMapper
import org.apache.ibatis.annotations.Mapper
@Mapper
interface DustExceptionDataMapper : MyMapper<DustExceptionData?>
src/main/java/com/flightfeather/monitor/domain/ds1/mapper/DustExceptionSettingMapper.kt
¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,8 @@
package com.flightfeather.monitor.domain.ds1.mapper
import com.flightfeather.monitor.domain.ds1.entity.DustExceptionSetting
import com.flightfeather.monitor.domain.util.MyMapper
import org.apache.ibatis.annotations.Mapper
@Mapper
interface DustExceptionSettingMapper : MyMapper<DustExceptionSetting?>
src/main/java/com/flightfeather/monitor/domain/ds1/mapper/DustGlobalSettingMapper.kt
¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,8 @@
package com.flightfeather.monitor.domain.ds1.mapper
import com.flightfeather.monitor.domain.ds1.entity.DustGlobalSetting
import com.flightfeather.monitor.domain.util.MyMapper
import org.apache.ibatis.annotations.Mapper
@Mapper
interface DustGlobalSettingMapper : MyMapper<DustGlobalSetting?>
src/main/java/com/flightfeather/monitor/domain/ds1/mapper/DustSiteDataMapper.kt
¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,8 @@
package com.flightfeather.monitor.domain.ds1.mapper
import com.flightfeather.monitor.domain.ds1.entity.DustSiteData
import com.flightfeather.monitor.domain.util.MyMapper
import org.apache.ibatis.annotations.Mapper
@Mapper
interface DustSiteDataMapper : MyMapper<DustSiteData?>
src/main/java/com/flightfeather/monitor/domain/ds1/mapper/DustSiteInfoMapper.kt
¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,8 @@
package com.flightfeather.monitor.domain.ds1.mapper
import com.flightfeather.monitor.domain.ds1.entity.DustSiteInfo
import com.flightfeather.monitor.domain.util.MyMapper
import org.apache.ibatis.annotations.Mapper
@Mapper
interface DustSiteInfoMapper : MyMapper<DustSiteInfo?>
src/main/java/com/flightfeather/monitor/domain/ds1/mapper/DustSiteLatestTimeMapper.kt
¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,8 @@
package com.flightfeather.monitor.domain.ds1.mapper
import com.flightfeather.monitor.domain.ds1.entity.DustSiteLatestTime
import com.flightfeather.monitor.domain.util.MyMapper
import org.apache.ibatis.annotations.Mapper
@Mapper
interface DustSiteLatestTimeMapper : MyMapper<DustSiteLatestTime?>
src/main/java/com/flightfeather/monitor/domain/ds1/mapper/DustSiteMapMapper.kt
¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,8 @@
package com.flightfeather.monitor.domain.ds1.mapper
import com.flightfeather.monitor.domain.ds1.entity.DustSiteMap
import com.flightfeather.monitor.domain.util.MyMapper
import org.apache.ibatis.annotations.Mapper
@Mapper
interface DustSiteMapMapper : MyMapper<DustSiteMap?>
src/main/java/com/flightfeather/monitor/domain/ds1/mapper/DustStatisticsValueMapper.kt
¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,8 @@
package com.flightfeather.monitor.domain.ds1.mapper
import com.flightfeather.monitor.domain.ds1.entity.DustStatisticsValue
import com.flightfeather.monitor.domain.util.MyMapper
import org.apache.ibatis.annotations.Mapper
@Mapper
interface DustStatisticsValueMapper : MyMapper<DustStatisticsValue?>
src/main/java/com/flightfeather/monitor/domain/ds1/mapper/LoginInfoMapper.kt
¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,8 @@
package com.flightfeather.monitor.domain.ds1.mapper
import com.flightfeather.monitor.domain.ds1.entity.LoginInfo
import com.flightfeather.monitor.domain.util.MyMapper
import org.apache.ibatis.annotations.Mapper
@Mapper
interface LoginInfoMapper : MyMapper<LoginInfo?>
src/main/java/com/flightfeather/monitor/domain/ds1/mapper/RequestTaskSettingMapper.kt
¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,8 @@
package com.flightfeather.monitor.domain.ds1.mapper
import com.flightfeather.monitor.domain.ds1.entity.RequestTaskSetting
import com.flightfeather.monitor.domain.util.MyMapper
import org.apache.ibatis.annotations.Mapper
@Mapper
interface RequestTaskSettingMapper : MyMapper<RequestTaskSetting?>
src/main/java/com/flightfeather/monitor/domain/util/MyMapper.java
¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,36 @@
/*
 * The MIT License (MIT)
 *
 * Copyright (c) 2014-2016 abel533@gmail.com
 *
 * Permission is hereby granted, free of charge, to any person obtaining a copy
 * of this software and associated documentation files (the "Software"), to deal
 * in the Software without restriction, including without limitation the rights
 * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
 * copies of the Software, and to permit persons to whom the Software is
 * furnished to do so, subject to the following conditions:
 *
 * The above copyright notice and this permission notice shall be included in
 * all copies or substantial portions of the Software.
 *
 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
 * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
 * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
 * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
 * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
 * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
 * THE SOFTWARE.
 */
package com.flightfeather.monitor.domain.util;
import tk.mybatis.mapper.common.Mapper;
import tk.mybatis.mapper.common.MySqlMapper;
/**
 * ç»§æ‰¿è‡ªå·±çš„MyMapper
 */
public interface MyMapper<T> extends Mapper<T>, MySqlMapper<T> {
    //TODO
    //FIXME ç‰¹åˆ«æ³¨æ„ï¼Œè¯¥æŽ¥å£ä¸èƒ½è¢«æ‰«æåˆ°ï¼Œå¦åˆ™ä¼šå‡ºé”™
}
src/main/java/com/flightfeather/monitor/mapper/AnalysisDataMapper.java
ÎļþÃû´Ó src/main/java/com/job/zsc/mapper/AnalysisDataMapper.java ÐÞ¸Ä
@@ -1,6 +1,6 @@
package com.job.zsc.mapper;
package com.flightfeather.monitor.mapper;
import com.job.zsc.pojo.AnalysisData;
import com.flightfeather.monitor.pojo.AnalysisData;
import org.apache.ibatis.annotations.Insert;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Select;
src/main/java/com/flightfeather/monitor/mapper/FugitiveDustMapper.java
ÎļþÃû´Ó src/main/java/com/job/zsc/mapper/FugitiveDustMapper.java ÐÞ¸Ä
@@ -1,6 +1,6 @@
package com.job.zsc.mapper;
package com.flightfeather.monitor.mapper;
import com.job.zsc.pojo.*;
import com.flightfeather.monitor.pojo.*;
import org.apache.ibatis.annotations.Insert;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param;
@@ -19,7 +19,7 @@
    @Select("select DISTINCT name from ja_t_dust_site_info  ")
    List<DustSiteData> allSiteName();
    List<AnalysisDustData> analysisdata( String siteName,String beginTime, String endTime);
    List<AnalysisDustData> analysisdata(String siteName, String beginTime, String endTime);
    List<AnalysisDustData> analysisByTime(String siteName, String beginTime, String endTime);
src/main/java/com/flightfeather/monitor/mapper/LoginMapper.java
ÎļþÃû´Ó src/main/java/com/job/zsc/mapper/LoginMapper.java ÐÞ¸Ä
@@ -1,6 +1,6 @@
package com.job.zsc.mapper;
package com.flightfeather.monitor.mapper;
import com.job.zsc.pojo.LoginUser;
import com.flightfeather.monitor.pojo.LoginUser;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Select;
src/main/java/com/flightfeather/monitor/mapper/SqlMapper.java
ÎļþÃû´Ó src/main/java/com/job/zsc/mapper/SqlMapper.java ÐÞ¸Ä
@@ -1,6 +1,6 @@
package com.job.zsc.mapper;
package com.flightfeather.monitor.mapper;
import com.job.zsc.pojo.OriginalData;
import com.flightfeather.monitor.pojo.OriginalData;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Select;
src/main/java/com/flightfeather/monitor/mapper/Vue3FumeMapper.java
ÎļþÃû´Ó src/main/java/com/job/zsc/mapper/Vue3FumeMapper.java ÐÞ¸Ä
@@ -1,8 +1,8 @@
package com.job.zsc.mapper;
package com.flightfeather.monitor.mapper;
import com.job.zsc.pojo.DeviceInfo;
import com.job.zsc.pojo.FumeAbnormalData;
import com.job.zsc.pojo.FumeHistoryData;
import com.flightfeather.monitor.pojo.DeviceInfo;
import com.flightfeather.monitor.pojo.FumeAbnormalData;
import com.flightfeather.monitor.pojo.FumeHistoryData;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param;
import org.apache.ibatis.annotations.Select;
src/main/java/com/flightfeather/monitor/pojo/AnalysisData.java
ÎļþÃû´Ó src/main/java/com/job/zsc/pojo/AnalysisData.java ÐÞ¸Ä
@@ -1,4 +1,4 @@
package com.job.zsc.pojo;
package com.flightfeather.monitor.pojo;
import com.fasterxml.jackson.annotation.JsonFormat;
import lombok.AllArgsConstructor;
src/main/java/com/flightfeather/monitor/pojo/AnalysisDustData.java
ÎļþÃû´Ó src/main/java/com/job/zsc/pojo/AnalysisDustData.java ÐÞ¸Ä
@@ -1,4 +1,4 @@
package com.job.zsc.pojo;
package com.flightfeather.monitor.pojo;
import com.fasterxml.jackson.annotation.JsonFormat;
import lombok.AllArgsConstructor;
src/main/java/com/flightfeather/monitor/pojo/AuditInfo.java
ÎļþÃû´Ó src/main/java/com/job/zsc/pojo/AuditInfo.java ÐÞ¸Ä
@@ -1,4 +1,4 @@
package com.job.zsc.pojo;
package com.flightfeather.monitor.pojo;
import com.fasterxml.jackson.annotation.JsonFormat;
import lombok.AllArgsConstructor;
src/main/java/com/flightfeather/monitor/pojo/DeviceInfo.java
ÎļþÃû´Ó src/main/java/com/job/zsc/pojo/DeviceInfo.java ÐÞ¸Ä
@@ -1,4 +1,4 @@
package com.job.zsc.pojo;
package com.flightfeather.monitor.pojo;
import lombok.AllArgsConstructor;
import lombok.Data;
src/main/java/com/flightfeather/monitor/pojo/DustDataAccessSetting.java
ÎļþÃû´Ó src/main/java/com/job/zsc/pojo/DustDataAccessSetting.java ÐÞ¸Ä
@@ -1,4 +1,4 @@
package com.job.zsc.pojo;
package com.flightfeather.monitor.pojo;
import lombok.AllArgsConstructor;
import lombok.Data;
src/main/java/com/flightfeather/monitor/pojo/DustExceptionData.java
ÎļþÃû´Ó src/main/java/com/job/zsc/pojo/DustExceptionData.java ÐÞ¸Ä
@@ -1,4 +1,4 @@
package com.job.zsc.pojo;
package com.flightfeather.monitor.pojo;
import com.fasterxml.jackson.annotation.JsonFormat;
import lombok.AllArgsConstructor;
src/main/java/com/flightfeather/monitor/pojo/DustExceptionSetting.java
ÎļþÃû´Ó src/main/java/com/job/zsc/pojo/DustExceptionSetting.java ÐÞ¸Ä
@@ -1,9 +1,8 @@
package com.job.zsc.pojo;
package com.flightfeather.monitor.pojo;
import com.fasterxml.jackson.annotation.JsonFormat;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import java.time.LocalDateTime;
src/main/java/com/flightfeather/monitor/pojo/DustExceptionType.java
ÎļþÃû´Ó src/main/java/com/job/zsc/pojo/DustExceptionType.java ÐÞ¸Ä
@@ -1,4 +1,4 @@
package com.job.zsc.pojo;
package com.flightfeather.monitor.pojo;
import lombok.AllArgsConstructor;
import lombok.Data;
src/main/java/com/flightfeather/monitor/pojo/DustSiteData.java
ÎļþÃû´Ó src/main/java/com/job/zsc/pojo/DustSiteData.java ÐÞ¸Ä
@@ -1,4 +1,4 @@
package com.job.zsc.pojo;
package com.flightfeather.monitor.pojo;
import com.fasterxml.jackson.annotation.JsonFormat;
import lombok.AllArgsConstructor;
src/main/java/com/flightfeather/monitor/pojo/FumeAbnormalData.java
ÎļþÃû´Ó src/main/java/com/job/zsc/pojo/FumeAbnormalData.java ÐÞ¸Ä
@@ -1,4 +1,4 @@
package com.job.zsc.pojo;
package com.flightfeather.monitor.pojo;
import com.fasterxml.jackson.annotation.JsonFormat;
src/main/java/com/flightfeather/monitor/pojo/FumeHistoryData.java
ÎļþÃû´Ó src/main/java/com/job/zsc/pojo/FumeHistoryData.java ÐÞ¸Ä
@@ -1,4 +1,4 @@
package com.job.zsc.pojo;
package com.flightfeather.monitor.pojo;
import com.fasterxml.jackson.annotation.JsonFormat;
import lombok.AllArgsConstructor;
src/main/java/com/flightfeather/monitor/pojo/LoginUser.java
ÎļþÃû´Ó src/main/java/com/job/zsc/pojo/LoginUser.java ÐÞ¸Ä
@@ -1,4 +1,4 @@
package com.job.zsc.pojo;
package com.flightfeather.monitor.pojo;
import lombok.AllArgsConstructor;
import lombok.Data;
src/main/java/com/flightfeather/monitor/pojo/OriginalData.java
ÎļþÃû´Ó src/main/java/com/job/zsc/pojo/OriginalData.java ÐÞ¸Ä
@@ -1,4 +1,4 @@
package com.job.zsc.pojo;
package com.flightfeather.monitor.pojo;
import com.fasterxml.jackson.annotation.JsonFormat;
import lombok.AllArgsConstructor;
src/main/java/com/flightfeather/monitor/pojo/PageBean.java
ÎļþÃû´Ó src/main/java/com/job/zsc/pojo/PageBean.java ÐÞ¸Ä
@@ -1,4 +1,4 @@
package com.job.zsc.pojo;
package com.flightfeather.monitor.pojo;
import lombok.AllArgsConstructor;
import lombok.Data;
src/main/java/com/flightfeather/monitor/pojo/Result.java
ÎļþÃû´Ó src/main/java/com/job/zsc/pojo/Result.java ÐÞ¸Ä
@@ -1,4 +1,4 @@
package com.job.zsc.pojo;
package com.flightfeather.monitor.pojo;
import lombok.AllArgsConstructor;
src/main/java/com/flightfeather/monitor/scheduledtasks/BaseTimingTask.kt
src/main/java/com/flightfeather/monitor/scheduledtasks/ScheduledTaskController.java
ÎļþÃû´Ó src/main/java/com/job/zsc/scheduledtasks/ScheduledTaskController.java ÐÞ¸Ä
@@ -1,4 +1,4 @@
package com.job.zsc.scheduledtasks;
package com.flightfeather.monitor.scheduledtasks;
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
src/main/java/com/flightfeather/monitor/scheduledtasks/TaskController.kt
ÎļþÃû´Ó src/main/java/com/job/zsc/scheduledtasks/TaskController.kt ÐÞ¸Ä
@@ -1,4 +1,4 @@
package com.job.zsc.scheduledtasks
package com.flightfeather.monitor.scheduledtasks
import cn.flightfeather.supervision.timingtask.BaseTimingTask
import org.slf4j.LoggerFactory
src/main/java/com/flightfeather/monitor/service/AnalysisDataService.java
ÎļþÃû´Ó src/main/java/com/job/zsc/service/AnalysisDataService.java ÐÞ¸Ä
@@ -1,6 +1,6 @@
package com.job.zsc.service;
package com.flightfeather.monitor.service;
import com.job.zsc.pojo.AnalysisData;
import com.flightfeather.monitor.pojo.AnalysisData;
import java.util.List;
src/main/java/com/flightfeather/monitor/service/FugitiveDustService.java
ÎļþÃû´Ó src/main/java/com/job/zsc/service/FugitiveDustService.java ÐÞ¸Ä
@@ -1,6 +1,6 @@
package com.job.zsc.service;
package com.flightfeather.monitor.service;
import com.job.zsc.pojo.*;
import com.flightfeather.monitor.pojo.*;
import java.util.List;
src/main/java/com/flightfeather/monitor/service/LoginService.java
¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,7 @@
package com.flightfeather.monitor.service;
import com.flightfeather.monitor.pojo.LoginUser;
public interface LoginService {
    LoginUser login(LoginUser loginUser);
}
src/main/java/com/flightfeather/monitor/service/SqlService.java
ÎļþÃû´Ó src/main/java/com/job/zsc/service/SqlService.java ÐÞ¸Ä
@@ -1,7 +1,7 @@
package com.job.zsc.service;
package com.flightfeather.monitor.service;
import com.job.zsc.pojo.PageBean;
import com.job.zsc.pojo.OriginalData;
import com.flightfeather.monitor.pojo.PageBean;
import com.flightfeather.monitor.pojo.OriginalData;
import java.time.LocalDate;
import java.util.List;
src/main/java/com/flightfeather/monitor/service/Vue3FumeService.java
ÎļþÃû´Ó src/main/java/com/job/zsc/service/Vue3FumeService.java ÐÞ¸Ä
@@ -1,10 +1,9 @@
package com.job.zsc.service;
package com.flightfeather.monitor.service;
import com.job.zsc.pojo.DeviceInfo;
import com.job.zsc.pojo.FumeAbnormalData;
import com.job.zsc.pojo.FumeHistoryData;
import com.job.zsc.pojo.PageBean;
import org.springframework.stereotype.Service;
import com.flightfeather.monitor.pojo.DeviceInfo;
import com.flightfeather.monitor.pojo.FumeAbnormalData;
import com.flightfeather.monitor.pojo.FumeHistoryData;
import com.flightfeather.monitor.pojo.PageBean;
import java.util.List;
src/main/java/com/flightfeather/monitor/service/impl/AnalysisDataServiceImpl.java
ÎļþÃû´Ó src/main/java/com/job/zsc/service/impl/AnalysisDataServiceImpl.java ÐÞ¸Ä
@@ -1,8 +1,8 @@
package com.job.zsc.service.impl;
package com.flightfeather.monitor.service.impl;
import com.job.zsc.mapper.AnalysisDataMapper;
import com.job.zsc.pojo.AnalysisData;
import com.job.zsc.service.AnalysisDataService;
import com.flightfeather.monitor.mapper.AnalysisDataMapper;
import com.flightfeather.monitor.service.AnalysisDataService;
import com.flightfeather.monitor.pojo.AnalysisData;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
src/main/java/com/flightfeather/monitor/service/impl/FugitiveDustServiceImpl.java
ÎļþÃû´Ó src/main/java/com/job/zsc/service/impl/FugitiveDustServiceImpl.java ÐÞ¸Ä
@@ -1,10 +1,10 @@
package com.job.zsc.service.impl;
package com.flightfeather.monitor.service.impl;
import com.flightfeather.monitor.mapper.FugitiveDustMapper;
import com.flightfeather.monitor.pojo.*;
import com.flightfeather.monitor.service.FugitiveDustService;
import com.github.pagehelper.Page;
import com.github.pagehelper.PageHelper;
import com.job.zsc.mapper.FugitiveDustMapper;
import com.job.zsc.pojo.*;
import com.job.zsc.service.FugitiveDustService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
@@ -178,7 +178,7 @@
    }
    @Override
    public List<AnalysisDustData> analysisdataByType(String month,String type) {
    public List<AnalysisDustData> analysisdataByType(String month, String type) {
        List<AnalysisDustData> list = fugitiveDustMapper.analysisdataByType(month,type);
        return list;
    }
src/main/java/com/flightfeather/monitor/service/impl/LoginServiceImpl.java
ÎļþÃû´Ó src/main/java/com/job/zsc/service/impl/LoginServiceImpl.java ÐÞ¸Ä
@@ -1,8 +1,8 @@
package com.job.zsc.service.impl;
package com.flightfeather.monitor.service.impl;
import com.job.zsc.mapper.LoginMapper;
import com.job.zsc.pojo.LoginUser;
import com.job.zsc.service.LoginService;
import com.flightfeather.monitor.mapper.LoginMapper;
import com.flightfeather.monitor.pojo.LoginUser;
import com.flightfeather.monitor.service.LoginService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
src/main/java/com/flightfeather/monitor/service/impl/SqlServiceImpl.java
¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,66 @@
package com.flightfeather.monitor.service.impl;
import com.flightfeather.monitor.mapper.SqlMapper;
import com.flightfeather.monitor.pojo.OriginalData;
import com.flightfeather.monitor.pojo.PageBean;
import com.flightfeather.monitor.service.SqlService;
import com.github.pagehelper.Page;
import com.github.pagehelper.PageHelper;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.time.LocalDate;
import java.util.List;
@Service
public class SqlServiceImpl implements SqlService {
    @Autowired
    private SqlMapper sqlMapper;
    @Override
    public PageBean page(Integer page, Integer pageSize, String shopname, LocalDate begin, LocalDate end) {
        /* //获取总记录数
        Long count=empMapper.count();
        //获取分页查询结果列表
        Integer start =(page-1)*pageSize;
        List<Emp> list=empMapper.list(start,pageSize);*/
        //设置分页参数
        PageHelper.startPage(page, pageSize);
        //执行查询
        List<OriginalData> infoList = sqlMapper.list(shopname, begin, end);
        //获取查询结果
        Page<OriginalData> p1 = (Page<OriginalData>) infoList;
        //封装PageBean对象*/
        PageBean pageBean = new PageBean(p1.getTotal(), p1.getResult());
        return pageBean;
    }
    @Override
    public List<OriginalData> show_all() {
        List<OriginalData> list_sql = sqlMapper.show_all();
        return list_sql;
    }
    @Override
    public List<OriginalData> findShop(String shopname) {
        List<OriginalData> shops = sqlMapper.findShop(shopname);
        return shops;
    }
    @Override
    public List<OriginalData> findDate(LocalDate begin, LocalDate end) {
        List<OriginalData> dates = sqlMapper.findDate(begin, end);
        return dates;
    }
    @Override
    public List<OriginalData> findByForm(String name, String number, String dname, String begin, String end) {
        List<OriginalData> form = sqlMapper.findByForm(name, number, dname, begin, end);
        return form;
    }
}
src/main/java/com/flightfeather/monitor/service/impl/Vue3FumeServiceImpl.java
ÎļþÃû´Ó src/main/java/com/job/zsc/service/impl/Vue3FumeServiceImpl.java ÐÞ¸Ä
@@ -1,14 +1,17 @@
package com.job.zsc.service.impl;
package com.flightfeather.monitor.service.impl;
import com.flightfeather.monitor.mapper.Vue3FumeMapper;
import com.flightfeather.monitor.pojo.DeviceInfo;
import com.flightfeather.monitor.pojo.FumeAbnormalData;
import com.flightfeather.monitor.pojo.FumeHistoryData;
import com.flightfeather.monitor.pojo.PageBean;
import com.flightfeather.monitor.service.Vue3FumeService;
import com.github.pagehelper.Page;
import com.github.pagehelper.PageHelper;
import com.job.zsc.mapper.Vue3FumeMapper;
import com.job.zsc.pojo.*;
import com.job.zsc.service.Vue3FumeService;
import lombok.extern.slf4j.Slf4j;
import org.apache.ibatis.annotations.Param;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.util.List;
@Slf4j
src/main/java/com/flightfeather/monitor/utils/MD5Util.java
ÎļþÃû´Ó src/main/java/com/job/zsc/utils/MD5Util.java ÐÞ¸Ä
@@ -1,4 +1,4 @@
package com.job.zsc.utils;
package com.flightfeather.monitor.utils;
import java.math.BigInteger;
import java.security.MessageDigest;
src/main/java/com/flightfeather/monitor/utils/UUIDGenerator.kt
ÎļþÃû´Ó src/main/java/com/job/zsc/utils/UUIDGenerator.kt ÐÞ¸Ä
@@ -1,4 +1,4 @@
package com.job.zsc.utils
package com.flightfeather.monitor.utils
import org.apache.commons.logging.LogFactory
import java.net.InetAddress
src/main/java/com/job/zsc/controller/dustexception/onlineAnalysisController.java
ÎļþÒÑɾ³ý
src/main/java/com/job/zsc/dustexceptionanalysis/ExceptionAnalysis.java
ÎļþÒÑɾ³ý
src/main/java/com/job/zsc/dustexceptionanalysis/analysis/Exceeding.java
ÎļþÒÑɾ³ý
src/main/java/com/job/zsc/dustexceptionanalysis/database/DustRepository.java
ÎļþÒÑɾ³ý
src/main/java/com/job/zsc/dustexceptionanalysis/dataprocess/DataProcess.java
ÎļþÒÑɾ³ý
src/main/java/com/job/zsc/mapper/dustexception/OnlineAnalysisMapper.java
ÎļþÒÑɾ³ý
src/main/java/com/job/zsc/service/LoginService.java
ÎļþÒÑɾ³ý
src/main/java/com/job/zsc/service/dustexception/impl/onlineAnalysisServiceImpl.java
ÎļþÒÑɾ³ý
src/main/java/com/job/zsc/service/dustexception/onlineAnalysisService.java
ÎļþÒÑɾ³ý
src/main/java/com/job/zsc/service/impl/SqlServiceImpl.java
ÎļþÒÑɾ³ý
src/main/java/com/job/zsc/service/impl/dustexception/onlineAnalysisImpl.java
ÎļþÒÑɾ³ý
src/main/resources/application.yml
@@ -1,13 +1,18 @@
spring:
  datasource:
     driver-class-name: com.mysql.cj.jdbc.Driver
#     url: jdbc:mysql://localhost:3306/fume
#     username: fume
#     password: fume_feiyu2023
    ds1:
      driver-class-name: com.mysql.cj.jdbc.Driver
#      url: jdbc:mysql://localhost:3306/fume
#      username: fume
#      password: fume_feiyu2023
     url: jdbc:mysql://localhost:3306/qianduan_sql
     username: root
     password: 1234
#      url: jdbc:mysql://localhost:3306/qianduan_sql
#      username: root
#      password: 1234
      url: jdbc:mysql://localhost:3306/fume
      username: root
      password: 123456
mybatis:
  configuration:
src/main/resources/generator/generatorConfig4ds1.xml
¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,86 @@
<!--<?xml version="1.0" encoding="UTF-8"?>-->
<!DOCTYPE generatorConfiguration
        PUBLIC "-//mybatis.org//DTD MyBatis Generator Configuration 1.0//EN"
        "http://mybatis.org/dtd/mybatis-generator-config_1_0.dtd">
<generatorConfiguration>
    <!-- æ•°æ®åº“驱动:选择你的本地硬盘上面的数据库驱动包-->
    <classPathEntry
            location="C:\Users\feiyu02\.m2\repository\mysql\mysql-connector-java\8.0.21\mysql-connector-java-8.0.21.jar"/>
    <context id="DB2Tables"  targetRuntime="MyBatis3" defaultModelType="flat">
        <!-- TKmybatis配置 -->
        <property name="javaFileEncoding" value="UTF-8"/>
        <property name="beginningDelimiter" value="`"/>
        <property name="endingDelimiter" value="`"/>
        <plugin type="${mapper.plugin}">
          <property name="mappers" value="${mapper.Mapper}"/>
        </plugin>
        <commentGenerator>
            <property name="suppressDate" value="true"/>
            <!-- æ˜¯å¦åŽ»é™¤è‡ªåŠ¨ç”Ÿæˆçš„æ³¨é‡Š true:是 ï¼š false:否 -->
            <property name="suppressAllComments" value="true"/>
        </commentGenerator>
        <!--数据库链接URL,用户名、密码 -->
        <jdbcConnection driverClass="com.mysql.jdbc.Driver"
                        connectionURL="jdbc:mysql://114.215.109.124/fume?serverTimezone=Asia/Shanghai"
                        userId="fumeRemote"
                        password="feiyu2023">
        </jdbcConnection>
        <javaTypeResolver>
            <property name="forceBigDecimals" value="false"/>
        </javaTypeResolver>
        <!-- ç”Ÿæˆæ¨¡åž‹çš„包名和位置-->
        <javaModelGenerator targetPackage="com.flightfeather.monitor.domain.ds1.entity" targetProject="src/main/java">
            <property name="enableSubPackages" value="true"/>
            <property name="trimStrings" value="true"/>
        </javaModelGenerator>
        <!-- ç”Ÿæˆæ˜ å°„文件的包名和位置-->
        <sqlMapGenerator targetPackage="ds1" targetProject="src/main/resources/mapper">
            <property name="enableSubPackages" value="true"/>
        </sqlMapGenerator>
        <!-- ç”ŸæˆDAO的包名和位置-->
        <javaClientGenerator type="XMLMAPPER" targetPackage="com.flightfeather.monitor.domain.ds1.mapper"
                             targetProject="src/main/java">
            <property name="enableSubPackages" value="true"/>
        </javaClientGenerator>
        <!-- è¦ç”Ÿæˆçš„表 tableName是数据库中的表名或视图名 domainObjectName是实体类名-->
        <table tableName="du_js_t_login_info" domainObjectName="LoginInfo" enableCountByExample="false"
               enableUpdateByExample="false" enableDeleteByExample="false"
               enableSelectByExample="false" selectByExampleQueryId="false"/>
        <table tableName="du_js_t_request_task_setting" domainObjectName="RequestTaskSetting"
               enableCountByExample="false"
               enableUpdateByExample="false" enableDeleteByExample="false"
               enableSelectByExample="false" selectByExampleQueryId="false"/>
        <table tableName="du_js_t_site_latest_time" domainObjectName="DustSiteLatestTime"
               enableCountByExample="false"
               enableUpdateByExample="false" enableDeleteByExample="false"
               enableSelectByExample="false" selectByExampleQueryId="false"/>
        <table tableName="du_js_t_site_map" domainObjectName="DustSiteMap"
               enableCountByExample="false"
               enableUpdateByExample="false" enableDeleteByExample="false"
               enableSelectByExample="false" selectByExampleQueryId="false"/>
        <table tableName="dust_exception_data" domainObjectName="DustExceptionData"
               enableCountByExample="false"
               enableUpdateByExample="false" enableDeleteByExample="false"
               enableSelectByExample="false" selectByExampleQueryId="false"/>
        <table tableName="dust_exception_setting" domainObjectName="DustExceptionSetting"
               enableCountByExample="false"
               enableUpdateByExample="false" enableDeleteByExample="false"
               enableSelectByExample="false" selectByExampleQueryId="false"/>
        <table tableName="dust_global_setting" domainObjectName="DustGlobalSetting"
               enableCountByExample="false"
               enableUpdateByExample="false" enableDeleteByExample="false"
               enableSelectByExample="false" selectByExampleQueryId="false"/>
        <table tableName="dust_statistics_value" domainObjectName="DustStatisticsValue"
               enableCountByExample="false"
               enableUpdateByExample="false" enableDeleteByExample="false"
               enableSelectByExample="false" selectByExampleQueryId="false"/>
        <table tableName="ja_t_dust_site_data_info" domainObjectName="DustSiteData"
               enableCountByExample="false"
               enableUpdateByExample="false" enableDeleteByExample="false"
               enableSelectByExample="false" selectByExampleQueryId="false"/>
        <table tableName="ja_t_dust_site_info" domainObjectName="DustSiteInfo"
               enableCountByExample="false"
               enableUpdateByExample="false" enableDeleteByExample="false"
               enableSelectByExample="false" selectByExampleQueryId="false"/>
    </context>
</generatorConfiguration>
src/main/resources/mapper/AnalysisDataMapper.xml
ÎļþÃû´Ó src/main/resources/com/job/zsc/mapper/AnalysisDataMapper.xml ÐÞ¸Ä
@@ -2,10 +2,10 @@
<!DOCTYPE mapper
        PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
        "https://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.job.zsc.mapper.AnalysisDataMapper">
<mapper namespace="com.flightfeather.monitor.mapper.AnalysisDataMapper">
    <select id="findByDevId" resultType="com.job.zsc.pojo.AnalysisData">
    <select id="findByDevId" resultType="com.flightfeather.monitor.pojo.AnalysisData">
    select * from fm_web_analysis_data
    <where>
        <if test="devId != null and devId != '' ">
@@ -19,7 +19,7 @@
    </select>
<!--信息和数据未分开的数据表分析 ed_data-->
<!--    <select id="find" resultType="com.job.zsc.pojo.AnalysisData">-->
<!--    <select id="find" resultType="AnalysisData">-->
<!--        SELECT-->
<!--        equipment_number as fume_dev_id,-->
<!--        DATE(reporting_time) as fume_date,-->
@@ -67,7 +67,7 @@
<!--        limit 0,500-->
<!--    </select>-->
<!--新表-->
    <select id="find" resultType="com.job.zsc.pojo.AnalysisData">
    <select id="find" resultType="com.flightfeather.monitor.pojo.AnalysisData">
        SELECT
        a.MV_Stat_Code as fume_dev_id,
@@ -119,7 +119,7 @@
    <!-- åŽ»é‡-->
    <select id="search" resultType="com.job.zsc.pojo.AnalysisData">
    <select id="search" resultType="com.flightfeather.monitor.pojo.AnalysisData">
        select a.*,b.DI_Name,b.DI_Supplier
        from fm_web_analysis_data as a join ea_t_device_info as b on a.fume_dev_id = b.DI_Code
        <where>
src/main/resources/mapper/FugitiveDustMapper.xml
ÎļþÃû´Ó src/main/resources/com/job/zsc/mapper/FugitiveDustMapper.xml ÐÞ¸Ä
@@ -2,7 +2,7 @@
<!DOCTYPE mapper
        PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
        "https://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.job.zsc.mapper.FugitiveDustMapper">
<mapper namespace="com.flightfeather.monitor.mapper.FugitiveDustMapper">
    <update id="update">
        update audit_info
        <set>
@@ -30,7 +30,7 @@
        where exception_id = #{exceptionId}
    </update>
    <select id="conditonQueryDustHistoryData" resultType="com.job.zsc.pojo.DustSiteData">
    <select id="conditonQueryDustHistoryData" resultType="com.flightfeather.monitor.pojo.DustSiteData">
        select a.*,b.*
        from ja_t_dust_site_data_info as a join ja_t_dust_site_info as b on a.mn_code = b.mn_code
        <where>
@@ -55,7 +55,7 @@
    </select>
<!--分析数据-->
    <select id="analysisdata" resultType="com.job.zsc.pojo.AnalysisDustData">
    <select id="analysisdata" resultType="com.flightfeather.monitor.pojo.AnalysisDustData">
        select a.*,b.name,b.duty_company from dust_statistics_value as a join ja_t_dust_site_info as b on a.mn_code = b. mn_code
        <where>
            <if test="siteName !=null and siteName != ''">
@@ -70,7 +70,7 @@
    <!--    æ ¹æ®ç«™ç‚¹åå­—和时段进行统计分析-->
    <select id="analysisByTime" resultType="com.job.zsc.pojo.AnalysisDustData">
    <select id="analysisByTime" resultType="com.flightfeather.monitor.pojo.AnalysisDustData">
        select  c.name,d.*
        from ja_t_dust_site_info as c  join
        (
@@ -101,7 +101,7 @@
    <!--条件查询异常数据  åŠ ä¸Šäº†å®¡è®¡ä¿¡æ¯-->
    <select id="getExceptionData" resultType="com.job.zsc.pojo.DustExceptionData">
    <select id="getExceptionData" resultType="com.flightfeather.monitor.pojo.DustExceptionData">
        select *
        from (select a.* ,b.name,b.typename,b.address,b.duty_company
        from dust_exception_data as a join ja_t_dust_site_info as b on a.mn_code = b.mn_code
@@ -129,7 +129,7 @@
    <!--   æ ¹æ®æŸæ®µæ—¶é—´å†…某个异常类型查询对应的店铺名称和设备编号-->
    <select id="getExceptionSitenameAndCode" resultType="com.job.zsc.pojo.DustExceptionData">
    <select id="getExceptionSitenameAndCode" resultType="com.flightfeather.monitor.pojo.DustExceptionData">
        select DISTINCT b.name,a.mn_code
        from dust_exception_data as a join ja_t_dust_site_info as b on a.mn_code = b.mn_code
@@ -145,7 +145,7 @@
    </select>
<!--    æ¡ä»¶æŸ¥è¯¢åŽ†å²æ•°æ®-->
    <select id="conditonQueryHistoryData" resultType="com.job.zsc.pojo.DustSiteData">
    <select id="conditonQueryHistoryData" resultType="com.flightfeather.monitor.pojo.DustSiteData">
        select a.*,b.name,b.duty_Company
        from ja_t_dust_site_data_info as a join ja_t_dust_site_info as b on a.mn_code = b.mn_code
        <where>
@@ -160,7 +160,7 @@
        order by a.lst asc
    </select>
    <select id="getHasAuditedData" resultType="com.job.zsc.pojo.DustExceptionData">
    <select id="getHasAuditedData" resultType="com.flightfeather.monitor.pojo.DustExceptionData">
        select *
        from dust_exception_data as a left join audit_info as b on a.id = b.exception_id
        <where>
@@ -171,7 +171,7 @@
        </where>
    </select>
    <select id="getSiteNameByTimeAndExceptionType" resultType="com.job.zsc.pojo.DustExceptionData">
    <select id="getSiteNameByTimeAndExceptionType" resultType="com.flightfeather.monitor.pojo.DustExceptionData">
        select DISTINCT b.name
        from dust_exception_data as a join ja_t_dust_site_info as b on a.mn_code = b.mn_code
        <where>
@@ -188,7 +188,7 @@
        </where>
    </select>
    <select id="analysisdataByType" resultType="com.job.zsc.pojo.AnalysisDustData">
    <select id="analysisdataByType" resultType="com.flightfeather.monitor.pojo.AnalysisDustData">
        select a.*,b.name,b.duty_company from dust_statistics_value as a join ja_t_dust_site_info as b on a.mn_code = b. mn_code
        <where>
            <if test="month != null and month != null">
@@ -201,7 +201,7 @@
        </where>
    </select>
    <select id="analysisdataByTimeAndType" resultType="com.job.zsc.pojo.AnalysisDustData">
    <select id="analysisdataByTimeAndType" resultType="com.flightfeather.monitor.pojo.AnalysisDustData">
        select a.*,b.name,b.duty_company from dust_statistics_value as a join ja_t_dust_site_info as b on a.mn_code = b. mn_code
        <where>
            <if test="beginTime != null and endTime != null">
src/main/resources/mapper/SqlMapper.xml
ÎļþÃû´Ó src/main/resources/com/job/zsc/mapper/SqlMapper.xml ÐÞ¸Ä
@@ -2,9 +2,9 @@
<!DOCTYPE mapper
        PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
        "https://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.job.zsc.mapper.SqlMapper">
<mapper namespace="com.flightfeather.monitor.mapper.SqlMapper">
    <select id="list" resultType="com.job.zsc.pojo.OriginalData">
    <select id="list" resultType="com.flightfeather.monitor.pojo.OriginalData">
        select * from ed_data
        <where>
            <if test="shopname != null and shopname != '' ">
@@ -20,7 +20,7 @@
    <select id="findByForm" resultType="com.job.zsc.pojo.OriginalData">
    <select id="findByForm" resultType="com.flightfeather.monitor.pojo.OriginalData">
        select * from ed_data
        <where>
            <if test="name != null and name != '' ">
src/main/resources/mapper/Vue3FumeMapper.xml
ÎļþÃû´Ó src/main/resources/com/job/zsc/mapper/Vue3FumeMapper.xml ÐÞ¸Ä
@@ -2,10 +2,10 @@
<!DOCTYPE mapper
        PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
        "https://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.job.zsc.mapper.Vue3FumeMapper">
<mapper namespace="com.flightfeather.monitor.mapper.Vue3FumeMapper">
<!--   è¶…标油烟查询-->
    <select id="conditionQuery" resultType="com.job.zsc.pojo.FumeHistoryData">
    <select id="conditionQuery" resultType="com.flightfeather.monitor.pojo.FumeHistoryData">
        SELECT a1.MV_ID, a1.MV_Stat_Code, b.DI_Name,b.DI_Supplier, a1.MV_Create_Time, a1.MV_Data_Time, a1.MV_Fume_Concentration2
        FROM exceeding_st_data AS a1
        INNER JOIN ea_t_device_info AS b ON a1.MV_Stat_Code = b.DI_Code
@@ -22,7 +22,7 @@
    </select>
    <!--    åŽ†å²æ²¹çƒŸæŸ¥è¯¢-->
<!--    <select id="conditionQueryHistory" resultType="com.job.zsc.pojo.FumeHistoryData">-->
<!--    <select id="conditionQueryHistory" resultType="FumeHistoryData">-->
<!--        SELECT d.DI_Name, c.*-->
<!--        FROM (-->
<!--        SELECT a.*-->
@@ -42,7 +42,7 @@
<!--        ORDER BY c.MV_Data_Time ASC;-->
<!--    </select>-->
    <!--    åŽ†å²æ²¹çƒŸæŸ¥è¯¢ ä¿®æ”¹äº†è¯­å¥-->
    <select id="conditionQueryHistory" resultType="com.job.zsc.pojo.FumeHistoryData">
    <select id="conditionQueryHistory" resultType="com.flightfeather.monitor.pojo.FumeHistoryData">
        SELECT d.DI_Name, c.*
        FROM (
        SELECT a.*
@@ -70,7 +70,7 @@
<!--    æ¡ä»¶æŸ¥è¯¢å¼‚常表-->
    <select id="conditonQueryAbnormalData" resultType="com.job.zsc.pojo.FumeAbnormalData">
    <select id="conditonQueryAbnormalData" resultType="com.flightfeather.monitor.pojo.FumeAbnormalData">
        select a1.dev_id,b.DI_Name,a1.exception_type,a1.region,a1.begin_time,a1.end_time
        from abnormal_data as a1 join ea_t_device_info as b on  a1.dev_id =  b.DI_Code
        <where>
@@ -88,7 +88,7 @@
    </select>
    <!--    æ¡ä»¶æŸ¥è¯¢å¼‚常表 å¢žåŠ äº†å¼‚å¸¸ç±»åž‹é€‰é¡¹-->
    <select id="conditonQueryAbnormalData1" resultType="com.job.zsc.pojo.FumeAbnormalData">
    <select id="conditonQueryAbnormalData1" resultType="com.flightfeather.monitor.pojo.FumeAbnormalData">
        select a1.dev_id,b.DI_Name,a1.exception,a1.exception_type,a1.region,a1.begin_time,a1.end_time
        from abnormal_data as a1 join ea_t_device_info as b on a1.dev_id =  b.DI_Code
        <where>
@@ -108,7 +108,7 @@
    </select>
    <!--根据店铺名选择到处为Excel -->
    <select id="exportByShopName" resultType="com.job.zsc.pojo.FumeHistoryData">
    <select id="exportByShopName" resultType="com.flightfeather.monitor.pojo.FumeHistoryData">
        SELECT a.MV_Stat_Code, b.DI_Name, a.MV_Data_Time, a.MV_Fan_Electricity,a.MV_Purifier_Electricity,a.MV_Fume_Concentration2
        FROM fd_t_minutevalue AS a
        JOIN ea_t_device_info AS b ON a.MV_Stat_Code = b.DI_Code
@@ -126,7 +126,7 @@
    </select>
    <!-- å¤šé€‰åº—铺名 è¿”回多选店铺最新一条数据-->
    <select id="findLaststById" resultType="com.job.zsc.pojo.FumeHistoryData">
    <select id="findLaststById" resultType="com.flightfeather.monitor.pojo.FumeHistoryData">
        SELECT a.MV_Stat_Code, b.DI_Name, b.DI_Supplier, a.MV_Data_Time,a.MV_Fan_Electricity,a.MV_Purifier_Electricity,a.MV_Fume_Concentration2
        FROM fd_t_minutevalue as a
        JOIN ea_t_device_info  as b ON a.MV_Stat_Code = b.DI_Code
@@ -146,7 +146,7 @@
    </select>
    <!-- æ¡ä»¶ç»„合查询异常表  å¼‚常类型选项改为多选-->
    <select id="conditonQueryAbnormalData2" resultType="com.job.zsc.pojo.FumeAbnormalData">
    <select id="conditonQueryAbnormalData2" resultType="com.flightfeather.monitor.pojo.FumeAbnormalData">
        select a1.dev_id,b.DI_Name,b.DI_Supplier,a1.exception,a1.exception_type,a1.region,a1.begin_time,a1.end_time
        from abnormal_data as a1 join ea_t_device_info as b on  a1.dev_id =  b.DI_Code
        <where>
@@ -170,7 +170,7 @@
    <!-- æ¡ä»¶ç»„合查询异常表  å¼‚常类型选项改为多选-->
    <select id="conditonQueryAbnormalData3" resultType="com.job.zsc.pojo.FumeAbnormalData">
    <select id="conditonQueryAbnormalData3" resultType="com.flightfeather.monitor.pojo.FumeAbnormalData">
        select a1.dev_id,b.DI_Name,a1.exception,a1.exception_type,a1.region,a1.begin_time,a1.end_time
        from abnormal_data as a1 join ea_t_device_info as b on a1.dev_id =  b.DI_Code
        <where>
@@ -191,7 +191,7 @@
        </where>
    </select>
    <select id="findShopNameBYTime" resultType="com.job.zsc.pojo.FumeAbnormalData">
    <select id="findShopNameBYTime" resultType="com.flightfeather.monitor.pojo.FumeAbnormalData">
        SELECT DISTINCT b.DI_Name,a.dev_id
        FROM abnormal_data AS a
        JOIN ea_t_device_info AS b ON a.dev_id = b.DI_Code
src/main/resources/mapper/ds1/DustExceptionDataMapper.xml
¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,23 @@
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.flightfeather.monitor.domain.ds1.mapper.DustExceptionDataMapper">
  <resultMap id="BaseResultMap" type="com.flightfeather.monitor.domain.ds1.entity.DustExceptionData">
    <!--
      WARNING - @mbg.generated
    -->
    <id column="id" jdbcType="INTEGER" property="id" />
    <result column="mn_code" jdbcType="VARCHAR" property="mnCode" />
    <result column="exception" jdbcType="VARCHAR" property="exception" />
    <result column="exception_type" jdbcType="INTEGER" property="exceptionType" />
    <result column="region" jdbcType="VARCHAR" property="region" />
    <result column="begin_time" jdbcType="TIMESTAMP" property="beginTime" />
    <result column="end_time" jdbcType="TIMESTAMP" property="endTime" />
    <result column="avg_value" jdbcType="DOUBLE" property="avgValue" />
  </resultMap>
  <sql id="Base_Column_List">
    <!--
      WARNING - @mbg.generated
    -->
    id, mn_code, exception, exception_type, region, begin_time, end_time, avg_value
  </sql>
</mapper>
src/main/resources/mapper/ds1/DustExceptionSettingMapper.xml
¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,36 @@
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.flightfeather.monitor.domain.ds1.mapper.DustExceptionSettingMapper">
  <resultMap id="BaseResultMap" type="com.flightfeather.monitor.domain.ds1.entity.DustExceptionSetting">
    <!--
      WARNING - @mbg.generated
    -->
    <id column="id" jdbcType="INTEGER" property="id" />
    <result column="user" jdbcType="VARCHAR" property="user" />
    <result column="update_time" jdbcType="TIMESTAMP" property="updateTime" />
    <result column="version" jdbcType="VARCHAR" property="version" />
    <result column="miss_data_minutes" jdbcType="INTEGER" property="missDataMinutes" />
    <result column="data_low" jdbcType="DOUBLE" property="dataLow" />
    <result column="long_time_no_change" jdbcType="INTEGER" property="longTimeNoChange" />
    <result column="mutation_num" jdbcType="INTEGER" property="mutationNum" />
    <result column="mutation_rate" jdbcType="DOUBLE" property="mutationRate" />
    <result column="near_exceed_low_value" jdbcType="DOUBLE" property="nearExceedLowValue" />
    <result column="near_exceed_high_value" jdbcType="DOUBLE" property="nearExceedHighValue" />
    <result column="near_exceed_num" jdbcType="INTEGER" property="nearExceedNum" />
    <result column="day_exceed_borderline_low_num" jdbcType="INTEGER" property="dayExceedBorderlineLowNum" />
    <result column="day_exceed_borderline_high_num" jdbcType="INTEGER" property="dayExceedBorderlineHighNum" />
    <result column="change_trend_group" jdbcType="INTEGER" property="changeTrendGroup" />
    <result column="change_trend_interval" jdbcType="INTEGER" property="changeTrendInterval" />
    <result column="change_trend_rate" jdbcType="DOUBLE" property="changeTrendRate" />
    <result column="exceeding_standard" jdbcType="DOUBLE" property="exceedingStandard" />
  </resultMap>
  <sql id="Base_Column_List">
    <!--
      WARNING - @mbg.generated
    -->
    id, user, update_time, version, miss_data_minutes, data_low, long_time_no_change,
    mutation_num, mutation_rate, near_exceed_low_value, near_exceed_high_value, near_exceed_num,
    day_exceed_borderline_low_num, day_exceed_borderline_high_num, change_trend_group,
    change_trend_interval, change_trend_rate, exceeding_standard
  </sql>
</mapper>
src/main/resources/mapper/ds1/DustGlobalSettingMapper.xml
¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,26 @@
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.flightfeather.monitor.domain.ds1.mapper.DustGlobalSettingMapper">
  <resultMap id="BaseResultMap" type="com.flightfeather.monitor.domain.ds1.entity.DustGlobalSetting">
    <!--
      WARNING - @mbg.generated
    -->
    <id column="id" jdbcType="INTEGER" property="id" />
    <result column="user" jdbcType="VARCHAR" property="user" />
    <result column="create_time" jdbcType="TIMESTAMP" property="createTime" />
    <result column="update_time" jdbcType="TIMESTAMP" property="updateTime" />
    <result column="type" jdbcType="VARCHAR" property="type" />
    <result column="exceeding" jdbcType="DOUBLE" property="exceeding" />
    <result column="begin_time" jdbcType="TIMESTAMP" property="beginTime" />
    <result column="end_time" jdbcType="TIMESTAMP" property="endTime" />
    <result column="region" jdbcType="VARCHAR" property="region" />
    <result column="is_regular_time" jdbcType="VARCHAR" property="isRegularTime" />
  </resultMap>
  <sql id="Base_Column_List">
    <!--
      WARNING - @mbg.generated
    -->
    id, user, create_time, update_time, type, exceeding, begin_time, end_time, region,
    is_regular_time
  </sql>
</mapper>
src/main/resources/mapper/ds1/DustSiteDataMapper.xml
¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,23 @@
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.flightfeather.monitor.domain.ds1.mapper.DustSiteDataMapper">
  <resultMap id="BaseResultMap" type="com.flightfeather.monitor.domain.ds1.entity.DustSiteData">
    <!--
      WARNING - @mbg.generated
    -->
    <id column="id" jdbcType="INTEGER" property="id" />
    <result column="mn_code" jdbcType="VARCHAR" property="mnCode" />
    <result column="dust_value" jdbcType="DOUBLE" property="dustValue" />
    <result column="noise_value" jdbcType="DOUBLE" property="noiseValue" />
    <result column="lst" jdbcType="TIMESTAMP" property="lst" />
    <result column="quality" jdbcType="VARCHAR" property="quality" />
    <result column="grade" jdbcType="INTEGER" property="grade" />
    <result column="flag" jdbcType="VARCHAR" property="flag" />
  </resultMap>
  <sql id="Base_Column_List">
    <!--
      WARNING - @mbg.generated
    -->
    id, mn_code, dust_value, noise_value, lst, quality, grade, flag
  </sql>
</mapper>
src/main/resources/mapper/ds1/DustSiteInfoMapper.xml
¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,68 @@
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.flightfeather.monitor.domain.ds1.mapper.DustSiteInfoMapper">
  <resultMap id="BaseResultMap" type="com.flightfeather.monitor.domain.ds1.entity.DustSiteInfo">
    <!--
      WARNING - @mbg.generated
    -->
    <id column="id" jdbcType="INTEGER" property="id" />
    <result column="mn_code" jdbcType="VARCHAR" property="mnCode" />
    <result column="address" jdbcType="VARCHAR" property="address" />
    <result column="name" jdbcType="VARCHAR" property="name" />
    <result column="code" jdbcType="VARCHAR" property="code" />
    <result column="begin_date" jdbcType="TIMESTAMP" property="beginDate" />
    <result column="duty_company" jdbcType="VARCHAR" property="dutyCompany" />
    <result column="duty_company_id" jdbcType="VARCHAR" property="dutyCompanyId" />
    <result column="end_date" jdbcType="TIMESTAMP" property="endDate" />
    <result column="engineering_stage" jdbcType="VARCHAR" property="engineeringStage" />
    <result column="group_id" jdbcType="VARCHAR" property="groupId" />
    <result column="group_name" jdbcType="VARCHAR" property="groupName" />
    <result column="is_online" jdbcType="VARCHAR" property="isOnline" />
    <result column="is_trouble" jdbcType="VARCHAR" property="isTrouble" />
    <result column="jhpt_update_time" jdbcType="VARCHAR" property="jhptUpdateTime" />
    <result column="kindex" jdbcType="VARCHAR" property="kindex" />
    <result column="latitude" jdbcType="VARCHAR" property="latitude" />
    <result column="linkman" jdbcType="VARCHAR" property="linkman" />
    <result column="longitude" jdbcType="VARCHAR" property="longitude" />
    <result column="phone" jdbcType="VARCHAR" property="phone" />
    <result column="province" jdbcType="VARCHAR" property="province" />
    <result column="ring_id" jdbcType="VARCHAR" property="ringId" />
    <result column="ring_name" jdbcType="VARCHAR" property="ringName" />
    <result column="type_id" jdbcType="VARCHAR" property="typeId" />
    <result column="typename" jdbcType="VARCHAR" property="typename" />
    <result column="stop_time" jdbcType="TIMESTAMP" property="stopTime" />
    <result column="active" jdbcType="VARCHAR" property="active" />
    <result column="trouble_num" jdbcType="INTEGER" property="troubleNum" />
    <result column="insert_time" jdbcType="TIMESTAMP" property="insertTime" />
    <result column="stage_begin_date" jdbcType="TIMESTAMP" property="stageBeginDate" />
    <result column="tsp" jdbcType="DOUBLE" property="tsp" />
    <result column="union_type_id" jdbcType="VARCHAR" property="unionTypeId" />
    <result column="wall_height" jdbcType="VARCHAR" property="wallHeight" />
    <result column="ywsj_date" jdbcType="TIMESTAMP" property="ywsjDate" />
    <result column="build_area" jdbcType="VARCHAR" property="buildArea" />
    <result column="construction_unit" jdbcType="VARCHAR" property="constructionUnit" />
    <result column="control_level" jdbcType="VARCHAR" property="controlLevel" />
    <result column="developers" jdbcType="VARCHAR" property="developers" />
    <result column="do_time" jdbcType="TIMESTAMP" property="doTime" />
    <result column="has_monitor" jdbcType="VARCHAR" property="hasMonitor" />
    <result column="data_time" jdbcType="TIMESTAMP" property="dataTime" />
    <result column="engineering_stage_code" jdbcType="VARCHAR" property="engineeringStageCode" />
    <result column="equipment_code" jdbcType="VARCHAR" property="equipmentCode" />
    <result column="floor_area" jdbcType="VARCHAR" property="floorArea" />
    <result column="jhpt_delete" jdbcType="VARCHAR" property="jhptDelete" />
    <result column="noise_region" jdbcType="VARCHAR" property="noiseRegion" />
    <result column="responsible" jdbcType="VARCHAR" property="responsible" />
  </resultMap>
  <sql id="Base_Column_List">
    <!--
      WARNING - @mbg.generated
    -->
    id, mn_code, address, name, code, begin_date, duty_company, duty_company_id, end_date,
    engineering_stage, group_id, group_name, is_online, is_trouble, jhpt_update_time,
    kindex, latitude, linkman, longitude, phone, province, ring_id, ring_name, type_id,
    typename, stop_time, active, trouble_num, insert_time, stage_begin_date, tsp, union_type_id,
    wall_height, ywsj_date, build_area, construction_unit, control_level, developers,
    do_time, has_monitor, data_time, engineering_stage_code, equipment_code, floor_area,
    jhpt_delete, noise_region, responsible
  </sql>
</mapper>
src/main/resources/mapper/ds1/DustSiteLatestTimeMapper.xml
¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,18 @@
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.flightfeather.monitor.domain.ds1.mapper.DustSiteLatestTimeMapper">
  <resultMap id="BaseResultMap" type="com.flightfeather.monitor.domain.ds1.entity.DustSiteLatestTime">
    <!--
      WARNING - @mbg.generated
    -->
    <id column="mn_code" jdbcType="VARCHAR" property="mnCode" />
    <result column="latest_time" jdbcType="TIMESTAMP" property="latestTime" />
    <result column="device_status" jdbcType="INTEGER" property="deviceStatus" />
  </resultMap>
  <sql id="Base_Column_List">
    <!--
      WARNING - @mbg.generated
    -->
    mn_code, latest_time, device_status
  </sql>
</mapper>
src/main/resources/mapper/ds1/DustSiteMapMapper.xml
¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,24 @@
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.flightfeather.monitor.domain.ds1.mapper.DustSiteMapMapper">
  <resultMap id="BaseResultMap" type="com.flightfeather.monitor.domain.ds1.entity.DustSiteMap">
    <!--
      WARNING - @mbg.generated
    -->
    <id column="Id" jdbcType="INTEGER" property="id" />
    <result column="TZ_User_Id" jdbcType="VARCHAR" property="tzUserId" />
    <result column="TZ_User_Name" jdbcType="VARCHAR" property="tzUserName" />
    <result column="JS_Device_Code" jdbcType="VARCHAR" property="jsDeviceCode" />
    <result column="JS_Device_Name" jdbcType="VARCHAR" property="jsDeviceName" />
    <result column="SV_User_Id" jdbcType="VARCHAR" property="svUserId" />
    <result column="SV_User_Name" jdbcType="VARCHAR" property="svUserName" />
    <result column="Create_Time" jdbcType="TIMESTAMP" property="createTime" />
  </resultMap>
  <sql id="Base_Column_List">
    <!--
      WARNING - @mbg.generated
    -->
    Id, TZ_User_Id, TZ_User_Name, JS_Device_Code, JS_Device_Name, SV_User_Id, SV_User_Name,
    Create_Time
  </sql>
</mapper>
src/main/resources/mapper/ds1/DustStatisticsValueMapper.xml
¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,25 @@
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.flightfeather.monitor.domain.ds1.mapper.DustStatisticsValueMapper">
  <resultMap id="BaseResultMap" type="com.flightfeather.monitor.domain.ds1.entity.DustStatisticsValue">
    <!--
      WARNING - @mbg.generated
    -->
    <id column="id" jdbcType="INTEGER" property="id" />
    <result column="mn_code" jdbcType="VARCHAR" property="mnCode" />
    <result column="lst" jdbcType="DATE" property="lst" />
    <result column="day_avg" jdbcType="VARCHAR" property="dayAvg" />
    <result column="min" jdbcType="VARCHAR" property="min" />
    <result column="max" jdbcType="VARCHAR" property="max" />
    <result column="day_online" jdbcType="VARCHAR" property="dayOnline" />
    <result column="day_valid" jdbcType="VARCHAR" property="dayValid" />
    <result column="day_exceeding" jdbcType="VARCHAR" property="dayExceeding" />
    <result column="type" jdbcType="VARCHAR" property="type" />
  </resultMap>
  <sql id="Base_Column_List">
    <!--
      WARNING - @mbg.generated
    -->
    id, mn_code, lst, day_avg, min, max, day_online, day_valid, day_exceeding, type
  </sql>
</mapper>
src/main/resources/mapper/ds1/LoginInfoMapper.xml
¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,21 @@
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.flightfeather.monitor.domain.ds1.mapper.LoginInfoMapper">
  <resultMap id="BaseResultMap" type="com.flightfeather.monitor.domain.ds1.entity.LoginInfo">
    <!--
      WARNING - @mbg.generated
    -->
    <id column="id" jdbcType="INTEGER" property="id" />
    <result column="user_name" jdbcType="VARCHAR" property="userName" />
    <result column="password" jdbcType="VARCHAR" property="password" />
    <result column="cookie" jdbcType="VARCHAR" property="cookie" />
    <result column="cookie_timestamp" jdbcType="TIMESTAMP" property="cookieTimestamp" />
    <result column="region" jdbcType="VARCHAR" property="region" />
  </resultMap>
  <sql id="Base_Column_List">
    <!--
      WARNING - @mbg.generated
    -->
    id, user_name, password, cookie, cookie_timestamp, region
  </sql>
</mapper>
src/main/resources/mapper/ds1/RequestTaskSettingMapper.xml
¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,37 @@
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.flightfeather.monitor.domain.ds1.mapper.RequestTaskSettingMapper">
  <resultMap id="BaseResultMap" type="com.flightfeather.monitor.domain.ds1.entity.RequestTaskSetting">
    <!--
      WARNING - @mbg.generated
    -->
    <id column="id" jdbcType="INTEGER" property="id" />
    <result column="user" jdbcType="VARCHAR" property="user" />
    <result column="update_time" jdbcType="TIMESTAMP" property="updateTime" />
    <result column="region" jdbcType="VARCHAR" property="region" />
    <result column="version" jdbcType="VARCHAR" property="version" />
    <result column="request_start_time" jdbcType="TIMESTAMP" property="requestStartTime" />
    <result column="request_end_time" jdbcType="TIMESTAMP" property="requestEndTime" />
    <result column="request_interval_seconds" jdbcType="INTEGER" property="requestIntervalSeconds" />
    <result column="request_range_hour" jdbcType="INTEGER" property="requestRangeHour" />
    <result column="request_range_interval_seconds" jdbcType="INTEGER" property="requestRangeIntervalSeconds" />
    <result column="request_fail_wait_seconds" jdbcType="INTEGER" property="requestFailWaitSeconds" />
    <result column="request_retry_times" jdbcType="INTEGER" property="requestRetryTimes" />
    <result column="statics_daily_time" jdbcType="TIMESTAMP" property="staticsDailyTime" />
    <result column="statics_monthly_time" jdbcType="TIMESTAMP" property="staticsMonthlyTime" />
    <result column="login_fail_wait_seconds" jdbcType="INTEGER" property="loginFailWaitSeconds" />
    <result column="login_retry_times" jdbcType="INTEGER" property="loginRetryTimes" />
    <result column="task_retry_wait_seconds" jdbcType="INTEGER" property="taskRetryWaitSeconds" />
    <result column="first_request_offset_days" jdbcType="INTEGER" property="firstRequestOffsetDays" />
    <result column="request_cookie_valid_duration" jdbcType="INTEGER" property="requestCookieValidDuration" />
  </resultMap>
  <sql id="Base_Column_List">
    <!--
      WARNING - @mbg.generated
    -->
    id, user, update_time, region, version, request_start_time, request_end_time, request_interval_seconds,
    request_range_hour, request_range_interval_seconds, request_fail_wait_seconds, request_retry_times,
    statics_daily_time, statics_monthly_time, login_fail_wait_seconds, login_retry_times,
    task_retry_wait_seconds, first_request_offset_days, request_cookie_valid_duration
  </sql>
</mapper>
src/test/java/com/flightfeather/monitor/QianduanApplicationTests.java
ÎļþÃû´Ó src/test/java/com/job/zsc/QianduanApplicationTests.java ÐÞ¸Ä
@@ -1,15 +1,11 @@
package com.job.zsc;
package com.flightfeather.monitor;
import com.job.zsc.dustexceptionanalysis.analysis.Exceeding;
import com.job.zsc.dustexceptionanalysis.database.DustRepository;
import com.job.zsc.mapper.dustexception.OnlineAnalysisMapper;
import com.job.zsc.pojo.DustExceptionSetting;
import com.job.zsc.pojo.DustSiteData;
import com.flightfeather.monitor.analysis.database.DustRepository;
import com.flightfeather.monitor.pojo.DustExceptionSetting;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import java.sql.SQLOutput;
import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.*;