13693261870
2024-09-12 b5326f8d497a6f6e97a487cb9c565fdae1dc4790
添加基础类
已添加8个文件
已修改4个文件
1213 ■■■■■ 文件已修改
pom.xml 47 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/se/simu/config/InitConfig.java 48 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/se/simu/config/Knife4jConfig.java 69 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/se/simu/config/MybatisPlusConfig.java 48 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/se/simu/config/RestTemplateConfig.java 100 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/se/simu/controller/WaterController.java 9 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/se/simu/helper/FileHelper.java 444 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/se/simu/helper/GdalHelper.java 116 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/se/simu/helper/StringHelper.java 253 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/se/simu/helper/WebHelper.java 6 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/se/simu/service/SedbService.java 48 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/resources/application.yml 25 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
pom.xml
@@ -35,11 +35,50 @@
            <version>1.18.34</version>
            <optional>true</optional>
        </dependency>
        <!--aop-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-aop</artifactId>
        </dependency>
        <!--mybatis-plus-->
        <dependency>
            <groupId>com.baomidou</groupId>
            <artifactId>mybatis-plus-boot-starter</artifactId>
            <version>3.5.7</version>
        </dependency>
        <!--redis-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-data-redis</artifactId>
        </dependency>
        <!--text-->
        <dependency>
            <groupId>org.apache.commons</groupId>
            <artifactId>commons-text</artifactId>
            <version>1.12.0</version>
        </dependency>
        <!--hutool-->
        <dependency>
            <groupId>cn.hutool</groupId>
            <artifactId>hutool-all</artifactId>
            <version>5.8.29</version>
        </dependency>
        <!--httpclient-->
        <dependency>
            <groupId>org.apache.httpcomponents</groupId>
            <artifactId>httpclient</artifactId>
        </dependency>
        <!--knife4j-->
        <dependency>
            <groupId>com.github.xiaoymin</groupId>
            <artifactId>knife4j-spring-boot-starter</artifactId>
            <version>3.0.3</version>
        </dependency>
        <!--fast-md5-->
        <dependency>
            <groupId>com.joyent.util</groupId>
            <artifactId>fast-md5</artifactId>
            <version>2.7.1</version>
        </dependency>
        <!--fastjson-->
        <dependency>
@@ -52,6 +91,14 @@
            <artifactId>fastjson2</artifactId>
            <version>2.0.52</version>
        </dependency-->
        <!--gdal-->
        <dependency>
            <groupId>org.gdal</groupId>
            <artifactId>gdal</artifactId>
            <!--<version>3.9.0</version>-->
            <version>3.5.0</version>
            <!--version>3.2.0</version-->
        </dependency>
    </dependencies>
    <build>
src/main/java/com/se/simu/config/InitConfig.java
¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,48 @@
package com.se.simu.config;
import com.se.simu.helper.GdalHelper;
import com.se.simu.helper.WebHelper;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.boot.ApplicationArguments;
import org.springframework.boot.ApplicationRunner;
import org.springframework.core.env.Environment;
import org.springframework.stereotype.Component;
import javax.annotation.Resource;
/**
 * åˆå§‹åŒ–配置类
 *
 * @author WWW
 * @date 2024-09-12
 */
@Slf4j
@Component
public class InitConfig implements ApplicationRunner {
    @Resource
    Environment env;
    @Value("${server.port}")
    String serverPort;
    @Value("${server.servlet.context-path}")
    String contextPath;
    @Override
    public void run(ApplicationArguments args) {
        // noinspection AlibabaRemoveCommentedCode
        try {
            log.info("***************** åˆå§‹åŒ– GDAL *****************" + "\n");
            GdalHelper.init(env.getProperty("sys.path.gdalPath"));
            String path = null != contextPath && contextPath.length() > 1 ? contextPath : "";
            log.info("API文档:http://localhost:" + serverPort + path + "/doc.html");
            log.info("API文档:http://{}:{}{}/doc.html", WebHelper.getHostIp(), serverPort, path);
            log.info("***************** ç³»ç»Ÿå¯åŠ¨å®Œæ¯• *****************" + "\n");
        } catch (Exception ex) {
            log.error(ex.getMessage(), ex);
        }
    }
}
src/main/java/com/se/simu/config/Knife4jConfig.java
¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,69 @@
package com.se.simu.config;
import com.github.xiaoymin.knife4j.spring.annotations.EnableKnife4j;
import io.swagger.annotations.ApiOperation;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import springfox.documentation.builders.ApiInfoBuilder;
import springfox.documentation.builders.PathSelectors;
import springfox.documentation.builders.RequestHandlerSelectors;
import springfox.documentation.service.ApiInfo;
import springfox.documentation.service.Contact;
import springfox.documentation.spi.DocumentationType;
import springfox.documentation.spring.web.plugins.Docket;
/**
 * Knife4j配置类
 *
 * @author WWW
 * @date 2024-09-12
 */
@Configuration
@EnableKnife4j
public class Knife4jConfig {
    @Value("${server.port}")
    String serverPort;
    @Value("${knife4j.enabled}")
    private boolean enabled;
    @Value("${knife4j.pathMapping}")
    private String pathMapping;
    @Value("${server.servlet.context-path}")
    String contextPath;
    @Bean
    public Docket createRestApi() {
        return new Docket(new DocumentationType("openApi", "3.0"))
                // æ˜¯å¦å¯ç”¨Swagger
                .enable(enabled)
                // ç”¨æ¥åˆ›å»ºè¯¥API的基本信息,展示在文档的页面中(自定义展示的信息)
                .apiInfo(apiInfo())
                // åˆ†ç»„名称
                .groupName("服务")
                // è®¾ç½®å“ªäº›æŽ¥å£æš´éœ²ç»™Swagger展示
                .select()
                // æ‰«ææ‰€æœ‰æœ‰æ³¨è§£çš„api,用这种方式更灵活
                .apis(RequestHandlerSelectors.withMethodAnnotation(ApiOperation.class))
                // æ‰«ææŒ‡å®šåŒ…中的swagger注解
                // .apis(RequestHandlerSelectors.basePackage("com.cn.project.tool.swagger"))
                // æ‰«ææ‰€æœ‰ .apis(RequestHandlerSelectors.any())
                .paths(PathSelectors.any())
                .build()
                /* è®¾ç½®å®‰å…¨æ¨¡å¼ï¼Œswagger可以设置访问token */
                // .securitySchemes(securitySchemes())
                .pathMapping(pathMapping);
    }
    private ApiInfo apiInfo() {
        return new ApiInfoBuilder()
                //描述字段支持Markdown语法
                .description("接口文档")
                .contact(new Contact("WuWeiwei", "http://127.0.0.1:" + serverPort + contextPath + "/doc.html", "252740454@qq.com"))
                .version("0.2")
                .title("AI后台服务接口文档")
                .build();
    }
}
src/main/java/com/se/simu/config/MybatisPlusConfig.java
¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,48 @@
package com.se.simu.config;
import com.baomidou.mybatisplus.annotation.DbType;
import com.baomidou.mybatisplus.autoconfigure.ConfigurationCustomizer;
import com.baomidou.mybatisplus.core.MybatisConfiguration;
import com.baomidou.mybatisplus.extension.plugins.MybatisPlusInterceptor;
import com.baomidou.mybatisplus.extension.plugins.inner.PaginationInnerInterceptor;
import org.apache.ibatis.type.JdbcType;
import org.mybatis.spring.annotation.MapperScan;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.transaction.annotation.EnableTransactionManagement;
/**
 * Mybatis-Plus分页配置
 *
 * @author WWW
 * @date   2024-09-12
 */
@EnableTransactionManagement
@Configuration
@MapperScan("com.se.ai.mapper")
public class MybatisPlusConfig {
    /**
     * æ–°çš„分页插件,一缓和二缓遵循mybatis的规则,需要设置
     * MybatisConfiguration#useDeprecatedExecutor = false
     * é¿å…ç¼“存出现问题(该属性会在旧插件移除后一同移除)
     */
    @Bean
    public MybatisPlusInterceptor mybatisPlusInterceptor() {
        MybatisPlusInterceptor interceptor = new MybatisPlusInterceptor();
        interceptor.addInnerInterceptor(new PaginationInnerInterceptor(DbType.POSTGRE_SQL));
        return interceptor;
    }
    @Bean
    public ConfigurationCustomizer configurationCustomizer() {
        return new ConfigurationCustomizer() {
            @Override
            public void customize(MybatisConfiguration configuration) {
                configuration.setCacheEnabled(true);
                configuration.setMapUnderscoreToCamelCase(true);
                configuration.setCallSettersOnNulls(true);
                configuration.setJdbcTypeForNull(JdbcType.NULL);
            }
        };
    }
}
src/main/java/com/se/simu/config/RestTemplateConfig.java
¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,100 @@
package com.se.simu.config;
import org.apache.http.client.HttpClient;
import org.apache.http.impl.client.HttpClientBuilder;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.http.client.ClientHttpRequestFactory;
import org.springframework.http.client.HttpComponentsClientHttpRequestFactory;
import org.springframework.http.client.SimpleClientHttpRequestFactory;
import org.springframework.http.converter.HttpMessageConverter;
import org.springframework.http.converter.StringHttpMessageConverter;
import org.springframework.web.client.RestTemplate;
import java.nio.charset.StandardCharsets;
import java.util.List;
/**
 * RestTemplate配置类
 *
 * @author WWW
 * @date   2024-09-12
 */
@Configuration
public class RestTemplateConfig {
    /**
     * è¿žæŽ¥æ± çš„æœ€å¤§è¿žæŽ¥æ•°é»˜è®¤ä¸º0,不限制
     */
    @Value("${remote.maxTotalConnect:0}")
    private int maxTotalConnect;
    /**
     * å•个主机的最大连接数
     */
    @Value("${remote.maxConnectPerRoute:1000}")
    private int maxConnectPerRoute;
    /**
     * è¿žæŽ¥è¶…时默认5s,-1为不限制
     */
    @Value("${remote.connectTimeout:5000}")
    private int connectTimeout;
    /**
     * è¯»å–超时默认30s,-1为不限制
     */
    @Value("${remote.readTimeout:30000}")
    private int readTimeout;
    /**
     * åˆ›å»ºHTTP客户端工厂
     *
     * @return å®¢æˆ·ç«¯å·¥åŽ‚
     */
    private ClientHttpRequestFactory createFactory() {
        if (this.maxTotalConnect <= 0) {
            SimpleClientHttpRequestFactory factory = new SimpleClientHttpRequestFactory();
            factory.setConnectTimeout(this.connectTimeout);
            factory.setReadTimeout(this.readTimeout);
            return factory;
        }
        HttpClient httpClient = HttpClientBuilder.create().setMaxConnTotal(this.maxTotalConnect).setMaxConnPerRoute(this.maxConnectPerRoute).build();
        HttpComponentsClientHttpRequestFactory factory = new HttpComponentsClientHttpRequestFactory(httpClient);
        factory.setConnectTimeout(this.connectTimeout);
        factory.setReadTimeout(this.readTimeout);
        return factory;
    }
    /**
     * åˆå§‹åŒ–RestTemplate,并加入spring的Bean工厂,由spring统一管理
     * å¿…须加注解@LoadBalanced
     *
     * @return
     */
    @Bean
    @ConditionalOnMissingBean(RestTemplate.class)
    public RestTemplate getRestTemplate() {
        RestTemplate restTemplate = new RestTemplate(this.createFactory());
        List<HttpMessageConverter<?>> converterList = restTemplate.getMessageConverters();
        // é‡æ–°è®¾ç½®StringHttpMessageConverter字符集为UTF-8,解决中文乱码问题
        HttpMessageConverter<?> converterTarget = null;
        for (HttpMessageConverter<?> item : converterList) {
            if (StringHttpMessageConverter.class == item.getClass()) {
                converterTarget = item;
                break;
            }
        }
        if (null != converterTarget) {
            converterList.remove(converterTarget);
        }
        converterList.add(1, new StringHttpMessageConverter(StandardCharsets.UTF_8));
        return restTemplate;
    }
}
src/main/java/com/se/simu/controller/WaterController.java
@@ -1,6 +1,7 @@
package com.se.simu.controller;
import com.se.simu.helper.WebHelper;
import com.se.simu.service.SedbService;
import com.se.simu.service.WaterService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.http.HttpStatus;
@@ -22,6 +23,9 @@
@RestController
@RequestMapping("/waterlogging")
public class WaterController {
    @Resource
    SedbService sedbService;
    @Resource
    WaterService waterService;
@@ -146,4 +150,9 @@
        return true;
    }
    @GetMapping("/test")
    public Object test() {
        return sedbService.getToken();
    }
}
src/main/java/com/se/simu/helper/FileHelper.java
¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,444 @@
package com.se.simu.helper;
import com.twmacinta.util.MD5;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.codec.digest.DigestUtils;
import java.io.*;
import java.nio.ByteBuffer;
import java.nio.channels.FileChannel;
import java.nio.charset.StandardCharsets;
import java.security.MessageDigest;
import java.text.DecimalFormat;
import java.util.List;
/**
 * æ–‡ä»¶å¸®åŠ©ç±»
 *
 * @author WWW
 * @date 2024-09-12
 */
@Slf4j
public class FileHelper {
    public final static String POINT = ".";
    public final static int I16 = 16;
    public static final double D1024 = 1024.0;
    public static final double D1050 = 1050.0;
    public final static int I1000000 = 1000000;
    public static final char[] HEX_DIGITS = {'0', '1', '2', '3', '4', '5', '6', '7', '8', '9', 'a', 'b', 'c', 'd', 'e', 'f'};
    /**
     * èŽ·å–æ–‡ä»¶å
     */
    public static String getFileName(String file) {
        int idx = file.lastIndexOf(File.separator);
        if (idx > -1) {
            return file.substring(idx + 1);
        }
        return "";
    }
    /**
     * èŽ·å–æ–‡ä»¶åç§°
     */
    public static String getName(String file) {
        String fileName = getFileName(file);
        int idx = fileName.lastIndexOf(".");
        if (idx > -1) {
            return fileName.substring(0, idx);
        }
        return fileName;
    }
    /**
     * èŽ·å–æ–‡ä»¶æ‰©å±•å
     */
    public static String getExtension(File file) {
        if (file == null) {
            return null;
        }
        String fileName = file.getName().toLowerCase();
        int idx = fileName.indexOf(POINT);
        if (idx == -1) {
            return "";
        }
        return fileName.substring(idx);
    }
    /**
     * èŽ·å–æ–‡ä»¶æ‰©å±•å
     */
    public static String getExtension(String fileName) {
        if (StringHelper.isEmpty(fileName)) {
            return "";
        }
        int idx = fileName.lastIndexOf(POINT);
        if (idx == -1) {
            return "";
        }
        return fileName.substring(idx).toLowerCase();
    }
    /**
     * èŽ·å–å¤šç”¨é€”äº’è”ç½‘é‚®ä»¶æ‰©å±•ç±»åž‹
     */
    public static String getMime(String ext) {
        switch (ext) {
            // å›¾ç‰‡
            case ".tif":
            case ".tiff":
                return "image/tiff";
            case ".img":
                return "application/x-img";
            case ".gif":
                return "image/gif";
            case ".jpg":
            case ".jpeg":
                return "image/jpeg";
            case ".png":
                return "image/png";
            // éŸ³/视频
            case ".mp3":
                return "audio/mp3";
            case ".mp4":
                return "video/mpeg4";
            case ".avi":
                return "video/avi";
            case ".mpg":
            case ".mpeg":
                return "video/mpg";
            case ".wav":
                return "audio/wav";
            case ".wma":
                return "audio/x-ms-wma";
            case ".swf":
                return "application/x-shockwave-flash";
            case ".wmv":
                return "video/x-ms-wmv";
            case ".rm":
                return "application/vnd.rn-realmedia";
            case ".rmvb":
                return "application/vnd.rn-realmedia-vbr";
            // ç½‘页
            case ".js":
                return "application/x-javascript";
            case ".css":
                return "text/css";
            case ".asp":
                return "text/asp";
            case ".mht":
                return "message/rfc822";
            case ".jsp":
            case ".htm":
            case ".html":
            case ".xhtml":
                return "text/html";
            case ".xml":
            case ".svg":
                return "text/xml";
            // æ–‡ä»¶
            case ".txt":
                return "text/plain";
            case ".dbf":
                return "application/x-dbf";
            case ".mdb":
                return "application/msaccess";
            case ".pdf":
                return "application/pdf";
            case ".ppt":
            case ".pptx":
                return "application/x-ppt";
            case ".doc":
            case ".docx":
                return "application/msword";
            case ".xls":
            case ".xlsx":
                return "application/vnd.ms-excel";
            case ".dgn":
                return "application/x-dgn";
            case ".dwg":
                return "application/x-dwg";
            case ".ext":
                return "application/x-msdownload";
            // é»˜è®¤
            default:
                return "application/octet-stream";
        }
    }
    /**
     * å­—节单位换算
     */
    public static String formatByte(long byteNumber) {
        double kbNumber = byteNumber / D1024;
        if (kbNumber < D1024) {
            return new DecimalFormat("#.##KB").format(kbNumber);
        }
        double mbNumber = kbNumber / D1024;
        if (mbNumber < D1024) {
            return new DecimalFormat("#.##MB").format(mbNumber);
        }
        double gbNumber = mbNumber / D1024;
        if (gbNumber < D1024) {
            return new DecimalFormat("#.##GB").format(gbNumber);
        }
        double tbNumber = gbNumber / D1024;
        return new DecimalFormat("#.##TB").format(tbNumber);
    }
    /**
     * èŽ·å–å¹³æ–¹ç±³
     */
    public static String getSquareMeter(double num) {
        if (num < I1000000) {
            return new DecimalFormat("#.##平方米").format(num);
        }
        double knum = num / I1000000;
        return new DecimalFormat("#.##平方千米").format(knum);
    }
    /**
     * byte转MB
     */
    public static double sizeToMb(long size) {
        if (size < D1050) {
            return 0.001;
        }
        String str = String.format("%.3f", size / D1024 / D1024);
        return Double.parseDouble(str);
    }
    /**
     * 3.获取文件MD5码(JDK)
     */
    public static String getMd5ByJdk(String filePath) throws IOException {
        FileInputStream fileStream = new FileInputStream(filePath);
        String md5 = DigestUtils.md5Hex(fileStream);
        fileStream.close();
        return md5;
    }
    /**
     * 2.获取快速 MD5 ç 
     */
    public static String getFastMd5(String filePath) throws IOException {
        String hash = MD5.asHex(MD5.getHash(new File(filePath)));
        MD5 md5 = new MD5();
        md5.Update(hash, null);
        return md5.asHex();
    }
    /**
     * åˆ é™¤æ–‡ä»¶å¤¹
     *
     * @param dir æ–‡ä»¶å¤¹
     */
    public static void deleteDir(String dir) {
        File file = new File(dir);
        deleteFiles(file);
    }
    /**
     * çº§è”删除文件
     *
     * @param file æ–‡ä»¶
     */
    public static void deleteFiles(File file) {
        if (null == file || !file.exists()) {
            return;
        }
        if (file.isDirectory()) {
            File[] files = file.listFiles();
            if (null != files && files.length > 0) {
                for (File f : files) {
                    if (f.isDirectory()) {
                        deleteFiles(f);
                    } else {
                        f.delete();
                    }
                }
            }
        }
        file.delete();
    }
    /**
     * èŽ·å–ç›¸å¯¹è·¯å¾„
     *
     * @param file æ–‡ä»¶
     * @return ç›¸å¯¹è·¯å¾„
     */
    public static String getRelativePath(String file) {
        if (StringHelper.isEmpty(file)) {
            return null;
        }
        int idx = file.lastIndexOf(File.separator);
        int start = file.lastIndexOf(File.separator, idx - 1);
        return file.substring(start + 1);
    }
    /**
     * èŽ·å–è·¯å¾„
     *
     * @param file æ–‡ä»¶
     * @return æ–‡ä»¶è·¯å¾„
     */
    public static String getPath(String file) {
        if (StringHelper.isEmpty(file)) {
            return null;
        }
        int end = file.lastIndexOf(File.separator);
        return file.substring(0, end);
    }
    /**
     * 1.获取文件的MD5
     */
    @SuppressWarnings("unused")
    public static String getFileMd5(String filePath) {
        FileInputStream fis = null;
        try {
            MessageDigest md = MessageDigest.getInstance("MD5");
            fis = new FileInputStream(new File(filePath));
            FileChannel fChannel = fis.getChannel();
            ByteBuffer buffer = ByteBuffer.allocateDirect(1024 * 1024);
            while (fChannel.read(buffer) != -1) {
                buffer.flip();
                md.update(buffer);
                buffer.compact();
            }
            byte[] b = md.digest();
            return byteToHexString(b);
        } catch (Exception ex) {
            ex.printStackTrace();
            return null;
        } finally {
            try {
                if (null != fis) {
                    fis.close();
                }
            } catch (IOException ex) {
                ex.printStackTrace();
            }
        }
    }
    /**
     * å­—节码转16进制
     */
    public static String byteToHexString(byte[] tmp) {
        // æ¯ä¸ªå­—节用 16 è¿›åˆ¶è¡¨ç¤ºçš„话,使用两个字符,
        char[] str = new char[16 * 2];
        // æ‰€ä»¥è¡¨ç¤ºæˆ 16 è¿›åˆ¶éœ€è¦ 32 ä¸ªå­—符,表示转换结果中对应的字符位置
        int k = 0;
        // ä»Žç¬¬ä¸€ä¸ªå­—节开始,对 MD5 çš„æ¯ä¸€ä¸ªå­—节
        for (int i = 0; i < I16; i++) {
            // è½¬æ¢æˆ 16 è¿›åˆ¶å­—符的转换
            byte byte0 = tmp[i];
            // å–字节中高 4 ä½çš„æ•°å­—转换
            str[k++] = HEX_DIGITS[byte0 >>> 4 & 0xf];
            // >>> ä¸ºé€»è¾‘右移,将符号位一起右移, å–字节中低 4 ä½çš„æ•°å­—转换
            str[k++] = HEX_DIGITS[byte0 & 0xf];
        }
        // æ¢åŽçš„结果转换为字符串
        return new String(str);
    }
    /**
     * èŽ·å–å­—ç¬¦ä¸²çš„MD5码
     */
    public static String getStringMd5(String text) {
        StringBuilder builder = new StringBuilder();
        try {
            MessageDigest md5 = MessageDigest.getInstance("MD5");
            byte[] bytes = md5.digest(text.getBytes(StandardCharsets.UTF_8));
            for (byte aByte : bytes) {
                builder.append(Integer.toHexString((0x000000FF & aByte) | 0xFFFFFF00).substring(6));
            }
        } catch (Exception ex) {
            log.error(ex.getMessage(), ex);
        }
        return builder.toString();
    }
    /**
     * æ ¹æ®è·¯å¾„获取文件
     */
    public static void getFilesByPath(List<String> list, String path) {
        File file = new File(path);
        if (file.isDirectory()) {
            File[] files = file.listFiles();
            if (null == files) {
                return;
            }
            for (File f : files) {
                if (f.isDirectory()) {
                    getFilesByPath(list, f.getPath());
                } else {
                    list.add(f.getPath());
                }
            }
        } else {
            list.add(file.getPath());
        }
    }
    /**
     * å¤åˆ¶æ–‡ä»¶
     *
     * @param src  æºæ–‡ä»¶
     * @param dest ç›®å½•文件
     */
    public static void copyFile(File src, File dest) throws IOException {
        InputStream is = null;
        OutputStream os = null;
        try {
            is = new FileInputStream(src);
            os = new FileOutputStream(dest);
            byte[] buffer = new byte[1024];
            int length;
            while ((length = is.read(buffer)) > 0) {
                os.write(buffer, 0, length);
            }
        } finally {
            os.close();
            is.close();
        }
    }
}
src/main/java/com/se/simu/helper/GdalHelper.java
¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,116 @@
package com.se.simu.helper;
import lombok.extern.slf4j.Slf4j;
import org.gdal.gdal.Band;
import org.gdal.gdal.Dataset;
import org.gdal.gdal.gdal;
import org.gdal.gdalconst.gdalconst;
import org.gdal.ogr.ogr;
import org.gdal.osr.SpatialReference;
import org.gdal.osr.osr;
import java.io.File;
/**
 * GDAL帮助类
 *
 * @author WWW
 * @date 2024-09-12
 */
@Slf4j
@SuppressWarnings("ALL")
public class GdalHelper {
    public final static int I4326 = 4326;
    public final static int I4490 = 4490;
    public static SpatialReference SR4326;
    public static SpatialReference SR4490;
    public final static String CGCS2000 = "CGCS2000";
    /**
     * åˆå§‹åŒ–
     */
    public static void init(String gdalPath) {
        // é…ç½®çŽ¯å¢ƒå˜é‡
        if (!StringHelper.isEmpty(gdalPath)) {
            if (WebHelper.isWin()) {
                gdal.SetConfigOption("GDAL_DATA", gdalPath + "/gdal-data");
                gdal.SetConfigOption("PROJ_LIB", gdalPath + "/proj7/share");
                //System.setProperty("PROJ_LIB", gdalPath + "/proj7/share")
                gdal.SetConfigOption("GDAL_DRIVER_PATH", gdalPath + "/gdalplugins");
                String path = System.getenv("PATH");
                if (!path.contains(gdalPath)) {
                    System.setProperty("PATH", path + ";" + gdalPath);
                }
            } else {
                //System.setProperty("java.library.path", gdalPath);
            }
        }
        // æ”¯æŒä¸­æ–‡è·¯å¾„
        gdal.SetConfigOption("GDAL_FILENAME_IS_UTF8", "YES");
        // å±žæ€§è¡¨æ”¯æŒä¸­æ–‡ï¼šCP936
        gdal.SetConfigOption("SHAPE_ENCODING", "");
        gdal.SetConfigOption("PGEO_DRIVER_TEMPLATE", "DRIVER=Microsoft Access Driver (*.mdb, *.accdb);DBQ=%s");
        gdal.SetConfigOption("MDB_DRIVER_TEMPLATE", "DRIVER=Microsoft Access Driver (*.mdb, *.accdb);DBQ=%s");
        // æ³¨å†Œæ‰€æœ‰çš„驱动
        gdal.AllRegister();
        ogr.RegisterAll();
        initSr();
    }
    /**
     * åˆå§‹åŒ–坐标系
     *
     * https://blog.csdn.net/CallmeAdo/article/details/127558139
     */
    public static void initSr() {
        try {
            SR4326 = new SpatialReference();
            SR4326.ImportFromEPSG(I4326);
            // å¯¹äºŽlat/long顺序的地理CRS,数据仍然是long/lat顺序的
            SR4326.SetAxisMappingStrategy(osr.OAMS_TRADITIONAL_GIS_ORDER);
            SR4490 = new SpatialReference();
            SR4490.ImportFromEPSG(I4490);
            SR4490.SetAxisMappingStrategy(osr.OAMS_TRADITIONAL_GIS_ORDER);
        } catch (Exception ex) {
            log.error(ex.getMessage(), ex);
        }
    }
    /**
     * åˆ›å»ºé‡‘å­—å¡”
     */
    public static void createPyramid(String file) {
        Dataset ds = null;
        try {
            File f = new File(file);
            if (!f.exists() || f.isDirectory()) {
                return;
            }
            ds = gdal.Open(file, gdalconst.GA_ReadOnly);
            if (null == ds || ds.getRasterCount() < 1 || null == ds.GetSpatialRef()) {
                return;
            }
            // åˆ›å»ºé‡‘å­—å¡”
            Band band = ds.GetRasterBand(1);
            if (0 == band.GetOverviewCount()) {
                ds.BuildOverviews("nearest", new int[]{2, 4, 6, 8, 16}, null);
            }
        } catch (Exception ex) {
            log.error(ex.getMessage(), ex);
        } finally {
            if (null != ds) {
                ds.delete();
            }
        }
    }
}
src/main/java/com/se/simu/helper/StringHelper.java
¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,253 @@
package com.se.simu.helper;
import java.sql.Timestamp;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;
import java.util.UUID;
import java.util.regex.Matcher;
import java.util.regex.Pattern;
/**
 * å­—符串帮助类
 *
 * @author WWW
 * @date 2024-09-12
 */
public class StringHelper {
    public final static String COMMA = ",";
    public final static String PWD_REG = "^(?![a-zA-Z]+$)(?![A-Z0-9]+$)(?![A-Z\\W!@#$%^&*`~()\\-_+=,.?;<>]+$)(?![a-z0-9]+$)(?![a-z\\W!@#$%^&*`~()\\-_+=,.?;<>]+$)(?![0-9\\W!@#$%^&*`~()\\-_+=,.?;<>]+$)[a-zA-Z0-9\\W!@#$%^&*`~()\\-_+=,.?;<>]{12,20}$";
    /**
     * æ•°å­—正则
     */
    public static final Pattern NUMBER_PATTERN = Pattern.compile("-?\\d+(\\.\\d+)?");
    /**
     * æ ¼å¼åŒ–当前系统日期 1
     */
    public static final SimpleDateFormat YMD_FORMAT = new SimpleDateFormat("yyyy-MM-dd");
    /**
     * æ ¼å¼åŒ–当前系统日期 2
     */
    public static final SimpleDateFormat YMDHMS_FORMAT = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
    /**
     * æ ¼å¼åŒ–当前系统日期 3
     */
    public static final SimpleDateFormat YMD2_FORMAT = new SimpleDateFormat("yyyyMMdd");
    /**
     * æ ¼å¼åŒ–当前系统日期 4
     */
    public static final SimpleDateFormat YMDHMS2_FORMAT = new SimpleDateFormat("yyyyMMddHHmmss");
    /**
     * åˆ¤æ–­å­—符串,是否为整数
     */
    public static boolean isInteger(String str) {
        return str != null && str.matches("[0-9]+");
    }
    /**
     * åˆ¤æ–­å­—符串,是否为浮点数
     */
    public static boolean isNumeric(String str) {
        return str != null && str.matches("-?\\d+(\\.\\d+)?");
    }
    /**
     * åˆ¤æ–­å­—符串,是否为浮点数
     */
    public static boolean isNumeric2(String str) {
        return str != null && NUMBER_PATTERN.matcher(str).matches();
    }
    /**
     * æ—¥æœŸæ­£åˆ™
     */
    public static Pattern datePattern = Pattern.compile("^((\\d{2}(([02468][048])|([13579][26]))[\\-\\/]((((0?[13578])|(1[02]))[\\-\\/]((0?[1-9])|([1-2][0-9])|(3[01])))|(((0?[469])|(11))[\\-\\/]((0?[1-9])|([1-2][0-9])|(30)))|(0?2[\\-\\/]((0?[1-9])|([1-2][0-9])))))|(\\d{2}(([02468][1235679])|([13579][01345789]))[\\-\\/]((((0?[13578])|(1[02]))[\\-\\/]((0?[1-9])|([1-2][0-9])|(3[01])))|(((0?[469])|(11))[\\-\\/]((0?[1-9])|([1-2][0-9])|(30)))|(0?2[\\-\\/]((0?[1-9])|(1[0-9])|(2[0-8]))))))(\\s(((0?[0-9])|([1-2][0-3]))\\:([0-5]?[0-9])((\\s)|(\\:([0-5]?[0-9])))))?$");
    /**
     * SQL正则
     */
    public static Pattern sqlPattern = Pattern.compile("|and|exec|execute|insert|select|delete|update|count|drop|\\*|%|chr|mid|master|truncate|char|declare|sitename|net user|xp_cmdshell|;|or|-|\\+|,|like");
    /**
     * å­—符串转为日期
     */
    public static Date parseDate(String str) {
        try {
            return YMD_FORMAT.parse(str);
        } catch (Exception ex) {
            return null;
        }
    }
    /**
     * å­—符串转为日期时间
     */
    public static Date parseTime(String str) {
        try {
            return YMDHMS_FORMAT.parse(str);
        } catch (Exception e) {
            return null;
        }
    }
    /**
     * åˆ¤æ–­å€¼æ˜¯å¦ä¸ºæ—¥æœŸæ ¼å¼
     */
    public static boolean isDate(String strDate) {
        Matcher m = datePattern.matcher(strDate);
        return m.matches();
    }
    /**
     * å­—符串,是否为null æˆ– ""
     */
    public static boolean isNull(String str) {
        return null == str || str.length() == 0;
    }
    /**
     * å­—符串,是否为空null和空格
     */
    public static boolean isEmpty(String str) {
        return null == str || "".equals(str.trim());
    }
    /**
     * èŽ·å– like å­—符串
     */
    public static String getLikeStr(String str) {
        return isEmpty(str) ? null : "%" + str.trim() + "%";
    }
    /**
     * èŽ·å– like å­—符串
     */
    public static String getLikeUpperStr(String str) {
        return isEmpty(str) ? null : "%" + str.trim().toUpperCase() + "%";
    }
    /**
     * èŽ·å– å³like å­—符串
     */
    public static String getRightLike(String str) {
        return isEmpty(str) ? null : str.trim() + "%";
    }
    /**
     * èŽ·å–å›¾å½¢çš„WKT字符串
     */
    public static String getGeomWkt(String wkt) {
        if (isEmpty(wkt)) {
            return "null";
        }
        return String.format("ST_GeomFromText('%s')", wkt);
    }
    /**
     * é¦–字母大写
     */
    public static String firstCharToUpperCase(String str) {
        return str.substring(0, 1).toUpperCase() + str.substring(1);
    }
    /**
     * é¦–字母小写
     */
    public static String firstCharToLowerCase(String str) {
        return str.substring(0, 1).toLowerCase() + str.substring(1);
    }
    /**
     * åˆ¤æ–­å€¼æ˜¯å¦å­˜åœ¨SQL注入
     *
     * @param str å­—符串
     * @return æ˜¯/否
     */
    public static boolean isSqlInjection(String str) {
        if (null == str) {
            return false;
        }
        Matcher m = sqlPattern.matcher(str);
        return m.matches();
    }
    /**
     * æ ¡éªŒå¯†ç æ˜¯/否合法
     *
     * @param pwd å¯†ç 
     * @return æ˜¯/否为无效的
     */
    public static boolean isPwdInvalid(String pwd) {
        return !Pattern.matches(PWD_REG, pwd);
    }
    /**
     * èŽ·å–GUID
     */
    public static String getGuid() {
        return UUID.randomUUID().toString();
    }
    /**
     * èŽ·å–åˆ†é’Ÿå·®æ•°
     */
    public static long getMinuteDifference(Timestamp ts) {
        return (ts.getTime() - System.currentTimeMillis()) / 1000 / 60;
    }
    /**
     * è¿žæŽ¥List集合
     *
     * @param list list æ•´æ•°é›†åˆ
     * @param join join è¿žæŽ¥å­—符
     * @param <T>  æ³›åž‹ç±»
     * @return å­—符串
     */
    public static <T> String join(List<T> list, String join) {
        if (null == list || list.isEmpty()) {
            return "";
        }
        StringBuilder sb = new StringBuilder();
        for (T t : list) {
            if (null != t) {
                sb.append(t.toString()).append(join);
            }
        }
        if (sb.length() > 0 && sb.lastIndexOf(join) == sb.length() - join.length()) {
            // åˆ é™¤ä»Žç´¢å¼• start å¼€å§‹åˆ° end ä¹‹é—´çš„字符,即 å‰åŒ…括 åŽä¸åŒ…括。
            sb.delete(sb.length() - join.length(), sb.length());
        }
        return sb.toString();
    }
    /**
     * å­—符串转整数集合
     */
    public static List<Integer> strToIntegers(String str) {
        if (isEmpty(str)) {
            return null;
        }
        List<Integer> list = new ArrayList<>();
        for (String s : str.split(COMMA)) {
            list.add(Integer.parseInt(s));
        }
        return list;
    }
}
src/main/java/com/se/simu/helper/WebHelper.java
@@ -31,6 +31,12 @@
    private final static String UNKNOWN = "unknown";
    public static boolean isWin() {
        String osName = System.getProperty("os.name");
        return osName.startsWith("Windows");
    }
    /**
     * æ ¼å¼åŒ–日期
     */
src/main/java/com/se/simu/service/SedbService.java
¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,48 @@
package com.se.simu.service;
import cn.hutool.json.JSONObject;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service;
import org.springframework.web.client.RestTemplate;
import javax.annotation.Resource;
/**
 * SDDB服务类
 *
 * @author WWW
 * @date   2024-09-12
 */
@Slf4j
@Service
public class SedbService {
    @Value("${sedb.url}")
    String url;
    @Value("${sedb.user}")
    String user;
    @Value("${sedb.pwd}")
    String pwd;
    @Resource
    RestTemplate restTemplate;
    public String getToken() {
        //http://106.120.22.26:8013/account-service/security/publickey
        String key = getPublicKey();
        return key;
    }
    public String getPublicKey() {
        String uri = url + "account-service/security/publickey";
        //{"datetime":"2024-09-12 17:24:38","code":200,"data":"MIGfMA0GCSqGSIb3DQEBAQUAA4GNADCBiQKBgQCtFwJCh2taVTEi05C8qT2oG7Y+rDmJhlO4zicpSeRtiro9LsytePeWI7BXM6sfDU0WeKun1izawcfgGkZgnoJuMBluAOKI1tL0uCrR+DreNLqMVtnXHwoWEIk/hGJedDWaf3q22aGDyEB5h9qCq0JklSShP1Ih4ppap4LmgxdTPQIDAQAB"}
        JSONObject obj = restTemplate.getForObject(uri, JSONObject.class);
        return obj.getStr("data");
    }
}
src/main/resources/application.yml
@@ -10,7 +10,30 @@
  application:
    name: SimuServer
mybatis-plus:
  type-aliases-package: com.se.ai.domain
  config-location: classpath:mybatis.xml
  mapper-locations: classpath:mapper/**/*.xml
pagehelper:
  autoDialect: true
  autoRuntimeDialect: true
  reasonable: true
  supportMethodsArguments: true
  params: count=countSql
remote:
  maxTotalConnect: 0
  maxConnectPerRoute: 1000
  connectTimeout: -1
  readTimeout: -1
sys:
  ver: 0.1
  path:
    data: D:\simu
    data: D:\simu
sedb:
  url: http://106.120.22.26:8013/
  user: WUWEIWEI
  pwd: WUWEIWEI