mirror of
https://gitee.com/jzsw-it/yexuejc-base.git
synced 2025-08-07 03:09:30 +08:00
Compare commits
No commits in common. "4c77c4ebe89db3c6bbdd2db804edb413ffcc713a" and "933eacc1c237cf318cd2cfcddb37e69d205d8a43" have entirely different histories.
4c77c4ebe8
...
933eacc1c2
201
LICENSE
201
LICENSE
@ -1,201 +0,0 @@
|
|||||||
Apache License
|
|
||||||
Version 2.0, January 2004
|
|
||||||
http://www.apache.org/licenses/
|
|
||||||
|
|
||||||
TERMS AND CONDITIONS FOR USE, REPRODUCTION, AND DISTRIBUTION
|
|
||||||
|
|
||||||
1. Definitions.
|
|
||||||
|
|
||||||
"License" shall mean the terms and conditions for use, reproduction,
|
|
||||||
and distribution as defined by Sections 1 through 9 of this document.
|
|
||||||
|
|
||||||
"Licensor" shall mean the copyright owner or entity authorized by
|
|
||||||
the copyright owner that is granting the License.
|
|
||||||
|
|
||||||
"Legal Entity" shall mean the union of the acting entity and all
|
|
||||||
other entities that control, are controlled by, or are under common
|
|
||||||
control with that entity. For the purposes of this definition,
|
|
||||||
"control" means (i) the power, direct or indirect, to cause the
|
|
||||||
direction or management of such entity, whether by contract or
|
|
||||||
otherwise, or (ii) ownership of fifty percent (50%) or more of the
|
|
||||||
outstanding shares, or (iii) beneficial ownership of such entity.
|
|
||||||
|
|
||||||
"You" (or "Your") shall mean an individual or Legal Entity
|
|
||||||
exercising permissions granted by this License.
|
|
||||||
|
|
||||||
"Source" form shall mean the preferred form for making modifications,
|
|
||||||
including but not limited to software source code, documentation
|
|
||||||
source, and configuration files.
|
|
||||||
|
|
||||||
"Object" form shall mean any form resulting from mechanical
|
|
||||||
transformation or translation of a Source form, including but
|
|
||||||
not limited to compiled object code, generated documentation,
|
|
||||||
and conversions to other media types.
|
|
||||||
|
|
||||||
"Work" shall mean the work of authorship, whether in Source or
|
|
||||||
Object form, made available under the License, as indicated by a
|
|
||||||
copyright notice that is included in or attached to the work
|
|
||||||
(an example is provided in the Appendix below).
|
|
||||||
|
|
||||||
"Derivative Works" shall mean any work, whether in Source or Object
|
|
||||||
form, that is based on (or derived from) the Work and for which the
|
|
||||||
editorial revisions, annotations, elaborations, or other modifications
|
|
||||||
represent, as a whole, an original work of authorship. For the purposes
|
|
||||||
of this License, Derivative Works shall not include works that remain
|
|
||||||
separable from, or merely link (or bind by name) to the interfaces of,
|
|
||||||
the Work and Derivative Works thereof.
|
|
||||||
|
|
||||||
"Contribution" shall mean any work of authorship, including
|
|
||||||
the original version of the Work and any modifications or additions
|
|
||||||
to that Work or Derivative Works thereof, that is intentionally
|
|
||||||
submitted to Licensor for inclusion in the Work by the copyright owner
|
|
||||||
or by an individual or Legal Entity authorized to submit on behalf of
|
|
||||||
the copyright owner. For the purposes of this definition, "submitted"
|
|
||||||
means any form of electronic, verbal, or written communication sent
|
|
||||||
to the Licensor or its representatives, including but not limited to
|
|
||||||
communication on electronic mailing lists, source code control systems,
|
|
||||||
and issue tracking systems that are managed by, or on behalf of, the
|
|
||||||
Licensor for the purpose of discussing and improving the Work, but
|
|
||||||
excluding communication that is conspicuously marked or otherwise
|
|
||||||
designated in writing by the copyright owner as "Not a Contribution."
|
|
||||||
|
|
||||||
"Contributor" shall mean Licensor and any individual or Legal Entity
|
|
||||||
on behalf of whom a Contribution has been received by Licensor and
|
|
||||||
subsequently incorporated within the Work.
|
|
||||||
|
|
||||||
2. Grant of Copyright License. Subject to the terms and conditions of
|
|
||||||
this License, each Contributor hereby grants to You a perpetual,
|
|
||||||
worldwide, non-exclusive, no-charge, royalty-free, irrevocable
|
|
||||||
copyright license to reproduce, prepare Derivative Works of,
|
|
||||||
publicly display, publicly perform, sublicense, and distribute the
|
|
||||||
Work and such Derivative Works in Source or Object form.
|
|
||||||
|
|
||||||
3. Grant of Patent License. Subject to the terms and conditions of
|
|
||||||
this License, each Contributor hereby grants to You a perpetual,
|
|
||||||
worldwide, non-exclusive, no-charge, royalty-free, irrevocable
|
|
||||||
(except as stated in this section) patent license to make, have made,
|
|
||||||
use, offer to sell, sell, import, and otherwise transfer the Work,
|
|
||||||
where such license applies only to those patent claims licensable
|
|
||||||
by such Contributor that are necessarily infringed by their
|
|
||||||
Contribution(s) alone or by combination of their Contribution(s)
|
|
||||||
with the Work to which such Contribution(s) was submitted. If You
|
|
||||||
institute patent litigation against any entity (including a
|
|
||||||
cross-claim or counterclaim in a lawsuit) alleging that the Work
|
|
||||||
or a Contribution incorporated within the Work constitutes direct
|
|
||||||
or contributory patent infringement, then any patent licenses
|
|
||||||
granted to You under this License for that Work shall terminate
|
|
||||||
as of the date such litigation is filed.
|
|
||||||
|
|
||||||
4. Redistribution. You may reproduce and distribute copies of the
|
|
||||||
Work or Derivative Works thereof in any medium, with or without
|
|
||||||
modifications, and in Source or Object form, provided that You
|
|
||||||
meet the following conditions:
|
|
||||||
|
|
||||||
(a) You must give any other recipients of the Work or
|
|
||||||
Derivative Works a copy of this License; and
|
|
||||||
|
|
||||||
(b) You must cause any modified files to carry prominent notices
|
|
||||||
stating that You changed the files; and
|
|
||||||
|
|
||||||
(c) You must retain, in the Source form of any Derivative Works
|
|
||||||
that You distribute, all copyright, patent, trademark, and
|
|
||||||
attribution notices from the Source form of the Work,
|
|
||||||
excluding those notices that do not pertain to any part of
|
|
||||||
the Derivative Works; and
|
|
||||||
|
|
||||||
(d) If the Work includes a "NOTICE" text file as part of its
|
|
||||||
distribution, then any Derivative Works that You distribute must
|
|
||||||
include a readable copy of the attribution notices contained
|
|
||||||
within such NOTICE file, excluding those notices that do not
|
|
||||||
pertain to any part of the Derivative Works, in at least one
|
|
||||||
of the following places: within a NOTICE text file distributed
|
|
||||||
as part of the Derivative Works; within the Source form or
|
|
||||||
documentation, if provided along with the Derivative Works; or,
|
|
||||||
within a display generated by the Derivative Works, if and
|
|
||||||
wherever such third-party notices normally appear. The contents
|
|
||||||
of the NOTICE file are for informational purposes only and
|
|
||||||
do not modify the License. You may add Your own attribution
|
|
||||||
notices within Derivative Works that You distribute, alongside
|
|
||||||
or as an addendum to the NOTICE text from the Work, provided
|
|
||||||
that such additional attribution notices cannot be construed
|
|
||||||
as modifying the License.
|
|
||||||
|
|
||||||
You may add Your own copyright statement to Your modifications and
|
|
||||||
may provide additional or different license terms and conditions
|
|
||||||
for use, reproduction, or distribution of Your modifications, or
|
|
||||||
for any such Derivative Works as a whole, provided Your use,
|
|
||||||
reproduction, and distribution of the Work otherwise complies with
|
|
||||||
the conditions stated in this License.
|
|
||||||
|
|
||||||
5. Submission of Contributions. Unless You explicitly state otherwise,
|
|
||||||
any Contribution intentionally submitted for inclusion in the Work
|
|
||||||
by You to the Licensor shall be under the terms and conditions of
|
|
||||||
this License, without any additional terms or conditions.
|
|
||||||
Notwithstanding the above, nothing herein shall supersede or modify
|
|
||||||
the terms of any separate license agreement you may have executed
|
|
||||||
with Licensor regarding such Contributions.
|
|
||||||
|
|
||||||
6. Trademarks. This License does not grant permission to use the trade
|
|
||||||
names, trademarks, service marks, or product names of the Licensor,
|
|
||||||
except as required for reasonable and customary use in describing the
|
|
||||||
origin of the Work and reproducing the content of the NOTICE file.
|
|
||||||
|
|
||||||
7. Disclaimer of Warranty. Unless required by applicable law or
|
|
||||||
agreed to in writing, Licensor provides the Work (and each
|
|
||||||
Contributor provides its Contributions) on an "AS IS" BASIS,
|
|
||||||
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or
|
|
||||||
implied, including, without limitation, any warranties or conditions
|
|
||||||
of TITLE, NON-INFRINGEMENT, MERCHANTABILITY, or FITNESS FOR A
|
|
||||||
PARTICULAR PURPOSE. You are solely responsible for determining the
|
|
||||||
appropriateness of using or redistributing the Work and assume any
|
|
||||||
risks associated with Your exercise of permissions under this License.
|
|
||||||
|
|
||||||
8. Limitation of Liability. In no event and under no legal theory,
|
|
||||||
whether in tort (including negligence), contract, or otherwise,
|
|
||||||
unless required by applicable law (such as deliberate and grossly
|
|
||||||
negligent acts) or agreed to in writing, shall any Contributor be
|
|
||||||
liable to You for damages, including any direct, indirect, special,
|
|
||||||
incidental, or consequential damages of any character arising as a
|
|
||||||
result of this License or out of the use or inability to use the
|
|
||||||
Work (including but not limited to damages for loss of goodwill,
|
|
||||||
work stoppage, computer failure or malfunction, or any and all
|
|
||||||
other commercial damages or losses), even if such Contributor
|
|
||||||
has been advised of the possibility of such damages.
|
|
||||||
|
|
||||||
9. Accepting Warranty or Additional Liability. While redistributing
|
|
||||||
the Work or Derivative Works thereof, You may choose to offer,
|
|
||||||
and charge a fee for, acceptance of support, warranty, indemnity,
|
|
||||||
or other liability obligations and/or rights consistent with this
|
|
||||||
License. However, in accepting such obligations, You may act only
|
|
||||||
on Your own behalf and on Your sole responsibility, not on behalf
|
|
||||||
of any other Contributor, and only if You agree to indemnify,
|
|
||||||
defend, and hold each Contributor harmless for any liability
|
|
||||||
incurred by, or claims asserted against, such Contributor by reason
|
|
||||||
of your accepting any such warranty or additional liability.
|
|
||||||
|
|
||||||
END OF TERMS AND CONDITIONS
|
|
||||||
|
|
||||||
APPENDIX: How to apply the Apache License to your work.
|
|
||||||
|
|
||||||
To apply the Apache License to your work, attach the following
|
|
||||||
boilerplate notice, with the fields enclosed by brackets "[]"
|
|
||||||
replaced with your own identifying information. (Don't include
|
|
||||||
the brackets!) The text should be enclosed in the appropriate
|
|
||||||
comment syntax for the file format. We also recommend that a
|
|
||||||
file or class name and description of purpose be included on the
|
|
||||||
same "printed page" as the copyright notice for easier
|
|
||||||
identification within third-party archives.
|
|
||||||
|
|
||||||
Copyright [yyyy] [name of copyright owner]
|
|
||||||
|
|
||||||
Licensed under the Apache License, Version 2.0 (the "License");
|
|
||||||
you may not use this file except in compliance with the License.
|
|
||||||
You may obtain a copy of the License at
|
|
||||||
|
|
||||||
http://www.apache.org/licenses/LICENSE-2.0
|
|
||||||
|
|
||||||
Unless required by applicable law or agreed to in writing, software
|
|
||||||
distributed under the License is distributed on an "AS IS" BASIS,
|
|
||||||
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
||||||
See the License for the specific language governing permissions and
|
|
||||||
limitations under the License.
|
|
||||||
38
pom.xml
38
pom.xml
@ -6,16 +6,16 @@
|
|||||||
|
|
||||||
<groupId>top.yexuejc</groupId>
|
<groupId>top.yexuejc</groupId>
|
||||||
<artifactId>yexuejc-base</artifactId>
|
<artifactId>yexuejc-base</artifactId>
|
||||||
<version>1.5.1-jdk11</version>
|
<version>1.5.0-jre8</version>
|
||||||
|
|
||||||
<name>yexuejc-base</name>
|
<name>${project.artifactId}</name>
|
||||||
<url>https://github.com/yexuejc/yexuejc-base</url>
|
<url>https://github.com/yexuejc/yexuejc-base</url>
|
||||||
<description>Common toolkits based on JDK11 packaging</description>
|
<description>Common toolkits based on JDK8 packaging</description>
|
||||||
|
|
||||||
<licenses>
|
<licenses>
|
||||||
<license>
|
<license>
|
||||||
<name>The Apache Software License, Version 2.0</name>
|
<name>The Apache Software License, Version 2.0</name>
|
||||||
<url>https://www.apache.org/licenses/LICENSE-2.0.txt</url>
|
<url>http://www.apache.org/licenses/LICENSE-2.0.txt</url>
|
||||||
</license>
|
</license>
|
||||||
</licenses>
|
</licenses>
|
||||||
|
|
||||||
@ -40,19 +40,17 @@
|
|||||||
|
|
||||||
<properties>
|
<properties>
|
||||||
<repos.yexuejc.url>https://nexus.yexuejc.top/repository/</repos.yexuejc.url>
|
<repos.yexuejc.url>https://nexus.yexuejc.top/repository/</repos.yexuejc.url>
|
||||||
<repos.aliyun.url>https://maven.aliyun.com/repository/public</repos.aliyun.url>
|
<repos.aliyun.url>http://maven.aliyun.com/nexus/content/groups/public</repos.aliyun.url>
|
||||||
<repos.jitpack.url>https://jitpack.io</repos.jitpack.url>
|
<repos.jitpack.url>https://jitpack.io</repos.jitpack.url>
|
||||||
<jjwt.version>0.11.5</jjwt.version>
|
<jjwt.version>0.11.5</jjwt.version>
|
||||||
<maven.compiler.verbose>true</maven.compiler.verbose>
|
<maven.compiler.verbose>true</maven.compiler.verbose>
|
||||||
<java.version>11</java.version>
|
<java.version>1.8</java.version>
|
||||||
<validation-api.version>3.0.2</validation-api.version>
|
<validation-api.version>3.0.1</validation-api.version>
|
||||||
|
|
||||||
<commons-io.version>2.11.0</commons-io.version>
|
<commons-io.version>2.11.0</commons-io.version>
|
||||||
<bcprov-jdk15on.version>1.70</bcprov-jdk15on.version>
|
<bcprov-jdk15on.version>1.70</bcprov-jdk15on.version>
|
||||||
<guava.version>31.1-jre</guava.version>
|
<guava.version>31.1-jre</guava.version>
|
||||||
<apache-poi.version>5.2.2</apache-poi.version>
|
<apache-poi.version>5.2.2</apache-poi.version>
|
||||||
<jackson.version>2.14.0</jackson.version>
|
|
||||||
<zip4j.version>2.11.2</zip4j.version>
|
|
||||||
<!-- 文件拷贝时的编码 -->
|
<!-- 文件拷贝时的编码 -->
|
||||||
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
|
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
|
||||||
<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
|
<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
|
||||||
@ -113,22 +111,10 @@
|
|||||||
<artifactId>poi-ooxml</artifactId>
|
<artifactId>poi-ooxml</artifactId>
|
||||||
<version>${apache-poi.version}</version>
|
<version>${apache-poi.version}</version>
|
||||||
</dependency>
|
</dependency>
|
||||||
<dependency>
|
|
||||||
<groupId>com.fasterxml.jackson.dataformat</groupId>
|
|
||||||
<artifactId>jackson-dataformat-csv</artifactId>
|
|
||||||
<version>${jackson.version}</version>
|
|
||||||
</dependency>
|
|
||||||
|
|
||||||
<dependency>
|
|
||||||
<groupId>net.lingala.zip4j</groupId>
|
|
||||||
<artifactId>zip4j</artifactId>
|
|
||||||
<version>${zip4j.version}</version>
|
|
||||||
</dependency>
|
|
||||||
|
|
||||||
<dependency>
|
<dependency>
|
||||||
<groupId>org.junit.jupiter</groupId>
|
<groupId>org.junit.jupiter</groupId>
|
||||||
<artifactId>junit-jupiter-api</artifactId>
|
<artifactId>junit-jupiter-api</artifactId>
|
||||||
<version>5.9.0</version>
|
<version>5.8.1</version>
|
||||||
<scope>test</scope>
|
<scope>test</scope>
|
||||||
</dependency>
|
</dependency>
|
||||||
|
|
||||||
@ -143,8 +129,8 @@
|
|||||||
<version>3.8.1</version>
|
<version>3.8.1</version>
|
||||||
<configuration>
|
<configuration>
|
||||||
<encoding>UTF-8</encoding>
|
<encoding>UTF-8</encoding>
|
||||||
<source>11</source>
|
<source>8</source>
|
||||||
<target>11</target>
|
<target>8</target>
|
||||||
</configuration>
|
</configuration>
|
||||||
</plugin>
|
</plugin>
|
||||||
<!-- 打包源码 -->
|
<!-- 打包源码 -->
|
||||||
@ -210,12 +196,12 @@
|
|||||||
</build>
|
</build>
|
||||||
<repositories>
|
<repositories>
|
||||||
<repository>
|
<repository>
|
||||||
<id>yexuejc-maven</id>
|
<id>yexuejc-nexus-public</id>
|
||||||
<name>yexuejc-nexus-public</name>
|
<name>yexuejc-nexus-public</name>
|
||||||
<url>${repos.yexuejc.url}maven-public/</url>
|
<url>${repos.yexuejc.url}maven-public/</url>
|
||||||
</repository>
|
</repository>
|
||||||
<repository>
|
<repository>
|
||||||
<id>aliyun-maven</id>
|
<id>aliyun-nexus-public</id>
|
||||||
<name>aliyun-nexus-public</name>
|
<name>aliyun-nexus-public</name>
|
||||||
<url>${repos.aliyun.url}</url>
|
<url>${repos.aliyun.url}</url>
|
||||||
</repository>
|
</repository>
|
||||||
|
|||||||
@ -1,21 +0,0 @@
|
|||||||
package com.yexuejc.base.annotation;
|
|
||||||
|
|
||||||
import java.lang.annotation.*;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 设置csv header
|
|
||||||
*
|
|
||||||
* @author MAXF-MAC
|
|
||||||
*/
|
|
||||||
@Target({ElementType.TYPE})
|
|
||||||
@Retention(RetentionPolicy.RUNTIME)
|
|
||||||
@Documented
|
|
||||||
@Inherited
|
|
||||||
public @interface CsvHeader {
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 在类头上设置csv格式的header
|
|
||||||
* @return
|
|
||||||
*/
|
|
||||||
String header();
|
|
||||||
}
|
|
||||||
@ -1,173 +0,0 @@
|
|||||||
package com.yexuejc.base.encrypt;
|
|
||||||
|
|
||||||
import javax.crypto.Cipher;
|
|
||||||
import javax.crypto.spec.IvParameterSpec;
|
|
||||||
import javax.crypto.spec.SecretKeySpec;
|
|
||||||
import java.nio.charset.Charset;
|
|
||||||
import java.nio.charset.StandardCharsets;
|
|
||||||
import java.util.Base64;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* AES加解密
|
|
||||||
*
|
|
||||||
* @author maxf
|
|
||||||
* @class-name AES
|
|
||||||
* @description
|
|
||||||
* @date 2022/11/11 15:36
|
|
||||||
*/
|
|
||||||
public class AES {
|
|
||||||
public static AES builder() {
|
|
||||||
return Instace.aes;
|
|
||||||
}
|
|
||||||
|
|
||||||
private static class Instace {
|
|
||||||
private static AES aes = new AES();
|
|
||||||
}
|
|
||||||
|
|
||||||
public static final String AES_ALGORITHM = "AES";
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 加密模式
|
|
||||||
*/
|
|
||||||
public static enum ALGORITHM {
|
|
||||||
//算法/模式/填充 16字节加密后数据长度 不满16字节加密后长度
|
|
||||||
//AES/CBC/NoPadding 16 不支持
|
|
||||||
AES_CBC_NoPadding("AES/CBC/NoPadding"),
|
|
||||||
//AES/CBC/PKCS5Padding 32 16
|
|
||||||
AES_CBC_PKCS5Padding("AES/CBC/PKCS5Padding"),
|
|
||||||
//AES/CBC/ISO10126Padding 32 16
|
|
||||||
AES_CBC_ISO10126Padding("AES/CBC/ISO10126Padding"),
|
|
||||||
//AES/CFB/NoPadding 16 原始数据长度
|
|
||||||
AES_CFB_NoPadding("AES/CFB/NoPadding"),
|
|
||||||
//AES/CFB/PKCS5Padding 32 16
|
|
||||||
AES_CFB_PKCS5Padding("AES/CFB/PKCS5Padding"),
|
|
||||||
//AES/CFB/ISO10126Padding 32 16
|
|
||||||
AES_CFB_ISO10126Padding("AES/CFB/ISO10126Padding"),
|
|
||||||
//AES/ECB/NoPadding 16 不支持
|
|
||||||
AES_ECB_NoPadding("AES/ECB/NoPadding"),
|
|
||||||
//AES/ECB/PKCS5Padding 32 16
|
|
||||||
AES_ECB_PKCS5Padding("AES/ECB/PKCS5Padding"),
|
|
||||||
//AES/ECB/ISO10126Padding 32 16
|
|
||||||
AES_ECB_ISO10126Padding("AES/ECB/ISO10126Padding"),
|
|
||||||
//AES/OFB/NoPadding 16 原始数据长度
|
|
||||||
AES_OFB_NoPadding("AES/OFB/NoPadding"),
|
|
||||||
//AES/OFB/PKCS5Padding 32 16
|
|
||||||
AES_OFB_PKCS5Padding("AES/OFB/PKCS5Padding"),
|
|
||||||
//AES/OFB/ISO10126Padding 32 16
|
|
||||||
AES_OFB_ISO10126Padding("AES/OFB/ISO10126Padding"),
|
|
||||||
//AES/PCBC/NoPadding 16 不支持
|
|
||||||
AES_PCBC_NoPadding("AES/PCBC/NoPadding"),
|
|
||||||
//AES/PCBC/PKCS5Padding 32 16
|
|
||||||
AES_PCBC_PKCS5Padding("AES/PCBC/PKCS5Padding"),
|
|
||||||
//AES/PCBC/ISO10126Padding 32 16
|
|
||||||
AES_PCBC_ISO10126Padding("AES/PCBC/ISO10126Padding");
|
|
||||||
public String name;
|
|
||||||
|
|
||||||
ALGORITHM(String name) {
|
|
||||||
this.name = name;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
private ALGORITHM algorithm = ALGORITHM.AES_CBC_NoPadding;
|
|
||||||
private String key = "hj7x89H$yuBI0456";
|
|
||||||
private String iv = "NIfb&95GUY86Gfgh";
|
|
||||||
private Charset charset = StandardCharsets.UTF_8;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 加密
|
|
||||||
*
|
|
||||||
* @param data 明文
|
|
||||||
* @return 密文
|
|
||||||
* @Description AES算法加密明文
|
|
||||||
*/
|
|
||||||
public String encrypt(String data) throws Exception {
|
|
||||||
try {
|
|
||||||
|
|
||||||
Cipher cipher = Cipher.getInstance(algorithm.name);
|
|
||||||
int blockSize = cipher.getBlockSize();
|
|
||||||
byte[] dataBytes = data.getBytes(charset);
|
|
||||||
int plaintextLength = dataBytes.length;
|
|
||||||
if (plaintextLength % blockSize != 0) {
|
|
||||||
plaintextLength = plaintextLength + (blockSize - (plaintextLength % blockSize));
|
|
||||||
}
|
|
||||||
byte[] plaintext = new byte[plaintextLength];
|
|
||||||
System.arraycopy(dataBytes, 0, plaintext, 0, dataBytes.length);
|
|
||||||
SecretKeySpec keyspec = new SecretKeySpec(key.getBytes(charset), AES_ALGORITHM);
|
|
||||||
IvParameterSpec ivspec = new IvParameterSpec(iv.getBytes(charset));
|
|
||||||
cipher.init(Cipher.ENCRYPT_MODE, keyspec, ivspec);
|
|
||||||
byte[] encrypted = cipher.doFinal(plaintext);
|
|
||||||
return Base64.getEncoder().encodeToString(encrypted);
|
|
||||||
} catch (Exception e) {
|
|
||||||
e.printStackTrace();
|
|
||||||
return null;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 解密
|
|
||||||
*
|
|
||||||
* @param data 密文
|
|
||||||
* @return 明文
|
|
||||||
* @Description AES算法解密密文
|
|
||||||
*/
|
|
||||||
public String decrypt(String data) throws Exception {
|
|
||||||
try {
|
|
||||||
byte[] encrypted = Base64.getDecoder().decode(data);
|
|
||||||
Cipher cipher = Cipher.getInstance(algorithm.name);
|
|
||||||
SecretKeySpec keyspec = new SecretKeySpec(key.getBytes(charset), AES_ALGORITHM);
|
|
||||||
IvParameterSpec ivspec = new IvParameterSpec(iv.getBytes(charset));
|
|
||||||
cipher.init(Cipher.DECRYPT_MODE, keyspec, ivspec);
|
|
||||||
byte[] original = cipher.doFinal(encrypted);
|
|
||||||
return new String(original, charset).trim();
|
|
||||||
} catch (Exception e) {
|
|
||||||
e.printStackTrace();
|
|
||||||
return null;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
//
|
|
||||||
// public static void main(String[] args) throws Exception {
|
|
||||||
// String str = " 奥萨蒂 asd8阿斯顿8asd ";
|
|
||||||
// AES.builder().setAlgorithm(ALGORITHM.AES_CBC_ISO10126Padding);
|
|
||||||
// AES.builder().setKey("DEsx89H$yuBI0456");
|
|
||||||
// String encrypt = AES.builder().encrypt(str);
|
|
||||||
// System.out.println(encrypt);
|
|
||||||
// String decrypt = AES.builder().decrypt(encrypt);
|
|
||||||
// System.out.println(">>>" + decrypt + "<<<");
|
|
||||||
// }
|
|
||||||
|
|
||||||
public ALGORITHM getAlgorithm() {
|
|
||||||
return algorithm;
|
|
||||||
}
|
|
||||||
|
|
||||||
public AES setAlgorithm(ALGORITHM algorithm) {
|
|
||||||
this.algorithm = algorithm;
|
|
||||||
return this;
|
|
||||||
}
|
|
||||||
|
|
||||||
public String getKey() {
|
|
||||||
return key;
|
|
||||||
}
|
|
||||||
|
|
||||||
public AES setKey(String key) {
|
|
||||||
this.key = key;
|
|
||||||
return this;
|
|
||||||
}
|
|
||||||
|
|
||||||
public String getIv() {
|
|
||||||
return iv;
|
|
||||||
}
|
|
||||||
|
|
||||||
public AES setIv(String iv) {
|
|
||||||
this.iv = iv;
|
|
||||||
return this;
|
|
||||||
}
|
|
||||||
|
|
||||||
public Charset getCharset() {
|
|
||||||
return charset;
|
|
||||||
}
|
|
||||||
|
|
||||||
public AES setCharset(Charset charset) {
|
|
||||||
this.charset = charset;
|
|
||||||
return this;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
@ -1,90 +0,0 @@
|
|||||||
package com.yexuejc.base.pojo;
|
|
||||||
|
|
||||||
import java.util.List;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 压缩文件的参数设定
|
|
||||||
*
|
|
||||||
* @author maxf
|
|
||||||
* @class-name CreateZipFileBean
|
|
||||||
* @description 压缩文件参考 {@link com.yexuejc.base.util.ZipUtil}
|
|
||||||
* @date 2022/11/11 10:30
|
|
||||||
*/
|
|
||||||
public class CreateZipFileBean {
|
|
||||||
/**
|
|
||||||
* 压缩的源文件列表，为空表示压缩整个目录
|
|
||||||
*/
|
|
||||||
private List<String> sourceFileName;
|
|
||||||
/**
|
|
||||||
* 当压缩文件夹时，需要排除的文件。压缩文件时（该参数无效）
|
|
||||||
*/
|
|
||||||
private List<String> excludeFileName;
|
|
||||||
/**
|
|
||||||
* 压缩源文件的目录
|
|
||||||
*/
|
|
||||||
private String sourcePath;
|
|
||||||
/**
|
|
||||||
* 生成压缩文件路径（全路径+压缩文件名）
|
|
||||||
*/
|
|
||||||
private String zipFile;
|
|
||||||
/**
|
|
||||||
* 加密密码
|
|
||||||
*/
|
|
||||||
private String encryptPwd;
|
|
||||||
|
|
||||||
private String writeCharsetName = "UTF-8";
|
|
||||||
|
|
||||||
public List<String> getSourceFileName() {
|
|
||||||
return sourceFileName;
|
|
||||||
}
|
|
||||||
|
|
||||||
public String getEncryptPwd() {
|
|
||||||
return encryptPwd;
|
|
||||||
}
|
|
||||||
|
|
||||||
public CreateZipFileBean setEncryptPwd(String encryptPwd) {
|
|
||||||
this.encryptPwd = encryptPwd;
|
|
||||||
return this;
|
|
||||||
}
|
|
||||||
|
|
||||||
public CreateZipFileBean setSourceFileName(List<String> sourceFileName) {
|
|
||||||
this.sourceFileName = sourceFileName;
|
|
||||||
return this;
|
|
||||||
}
|
|
||||||
|
|
||||||
public String getSourcePath() {
|
|
||||||
return sourcePath;
|
|
||||||
}
|
|
||||||
|
|
||||||
public CreateZipFileBean setSourcePath(String sourcePath) {
|
|
||||||
this.sourcePath = sourcePath;
|
|
||||||
return this;
|
|
||||||
}
|
|
||||||
|
|
||||||
public String getZipFile() {
|
|
||||||
return zipFile;
|
|
||||||
}
|
|
||||||
|
|
||||||
public CreateZipFileBean setZipFile(String zipFile) {
|
|
||||||
this.zipFile = zipFile;
|
|
||||||
return this;
|
|
||||||
}
|
|
||||||
|
|
||||||
public String getWriteCharsetName() {
|
|
||||||
return writeCharsetName;
|
|
||||||
}
|
|
||||||
|
|
||||||
public CreateZipFileBean setWriteCharsetName(String writeCharsetName) {
|
|
||||||
this.writeCharsetName = writeCharsetName;
|
|
||||||
return this;
|
|
||||||
}
|
|
||||||
|
|
||||||
public List<String> getExcludeFileName() {
|
|
||||||
return excludeFileName;
|
|
||||||
}
|
|
||||||
|
|
||||||
public CreateZipFileBean setExcludeFileName(List<String> excludeFileName) {
|
|
||||||
this.excludeFileName = excludeFileName;
|
|
||||||
return this;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
@ -4,6 +4,7 @@ import com.yexuejc.base.util.JsonUtil;
|
|||||||
import jakarta.validation.constraints.Min;
|
import jakarta.validation.constraints.Min;
|
||||||
import jakarta.validation.constraints.NotNull;
|
import jakarta.validation.constraints.NotNull;
|
||||||
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 分页 VO
|
* 分页 VO
|
||||||
*
|
*
|
||||||
|
|||||||
@ -1,85 +0,0 @@
|
|||||||
package com.yexuejc.base.pojo;
|
|
||||||
|
|
||||||
import java.util.List;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* @author maxf
|
|
||||||
* @class-name ReadFileBean
|
|
||||||
* @description 分段读取大文件
|
|
||||||
* @date 2022/5/16 21:53
|
|
||||||
*/
|
|
||||||
public class ReadFileBean<T> {
|
|
||||||
/**
|
|
||||||
* 开始行数
|
|
||||||
*/
|
|
||||||
private int startRowNum;
|
|
||||||
/**
|
|
||||||
* 结束行数
|
|
||||||
*/
|
|
||||||
private int endRowNum;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 每次读取的行数
|
|
||||||
*/
|
|
||||||
private int readRowNum;
|
|
||||||
/**
|
|
||||||
* 开始行到结束行的数据
|
|
||||||
*/
|
|
||||||
private List<T> datas;
|
|
||||||
/**
|
|
||||||
* 文件指针位置,默认0，开始位置
|
|
||||||
*/
|
|
||||||
private long pointer = 0;
|
|
||||||
/**
|
|
||||||
* 文件的length
|
|
||||||
*/
|
|
||||||
private long fileLength;
|
|
||||||
|
|
||||||
|
|
||||||
public ReadFileBean(int readRow) {
|
|
||||||
this.readRowNum = readRow;
|
|
||||||
this.startRowNum = 1;
|
|
||||||
this.endRowNum = 0;
|
|
||||||
}
|
|
||||||
|
|
||||||
public int getReadRowNum() {
|
|
||||||
return readRowNum;
|
|
||||||
}
|
|
||||||
|
|
||||||
public int getStartRowNum() {
|
|
||||||
return startRowNum;
|
|
||||||
}
|
|
||||||
|
|
||||||
public int getEndRowNum() {
|
|
||||||
return endRowNum;
|
|
||||||
}
|
|
||||||
|
|
||||||
public List<T> getDatas() {
|
|
||||||
return datas;
|
|
||||||
}
|
|
||||||
|
|
||||||
public ReadFileBean<T> setDatas(List<T> datas) {
|
|
||||||
this.datas = datas;
|
|
||||||
this.startRowNum = this.endRowNum + 1;
|
|
||||||
this.endRowNum += this.readRowNum;
|
|
||||||
return this;
|
|
||||||
}
|
|
||||||
|
|
||||||
public long getPointer() {
|
|
||||||
return pointer;
|
|
||||||
}
|
|
||||||
|
|
||||||
public ReadFileBean<T> setPointer(long pointer) {
|
|
||||||
this.pointer = pointer;
|
|
||||||
return this;
|
|
||||||
}
|
|
||||||
|
|
||||||
public long getFileLength() {
|
|
||||||
return fileLength;
|
|
||||||
}
|
|
||||||
|
|
||||||
public ReadFileBean<T> setFileLength(long fileLength) {
|
|
||||||
this.fileLength = fileLength;
|
|
||||||
return this;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
@ -1,44 +1,13 @@
|
|||||||
package com.yexuejc.base.util;
|
package com.yexuejc.base.util;
|
||||||
|
|
||||||
import com.fasterxml.jackson.databind.MappingIterator;
|
import java.io.*;
|
||||||
import com.fasterxml.jackson.dataformat.csv.CsvMapper;
|
|
||||||
import com.fasterxml.jackson.dataformat.csv.CsvSchema;
|
|
||||||
import com.google.common.io.ByteStreams;
|
|
||||||
import com.google.common.io.CharStreams;
|
|
||||||
import com.yexuejc.base.annotation.CsvHeader;
|
|
||||||
import com.yexuejc.base.pojo.ReadFileBean;
|
|
||||||
import io.jsonwebtoken.lang.Assert;
|
|
||||||
import org.apache.commons.io.IOUtils;
|
|
||||||
|
|
||||||
import java.io.BufferedInputStream;
|
|
||||||
import java.io.BufferedReader;
|
|
||||||
import java.io.ByteArrayOutputStream;
|
|
||||||
import java.io.File;
|
|
||||||
import java.io.FileInputStream;
|
|
||||||
import java.io.FileNotFoundException;
|
|
||||||
import java.io.FileOutputStream;
|
|
||||||
import java.io.IOException;
|
|
||||||
import java.io.InputStream;
|
|
||||||
import java.io.InputStreamReader;
|
|
||||||
import java.io.OutputStream;
|
|
||||||
import java.io.RandomAccessFile;
|
|
||||||
import java.io.Reader;
|
|
||||||
import java.io.StringWriter;
|
|
||||||
import java.math.BigInteger;
|
import java.math.BigInteger;
|
||||||
import java.nio.MappedByteBuffer;
|
import java.nio.MappedByteBuffer;
|
||||||
import java.nio.channels.FileChannel;
|
import java.nio.channels.FileChannel;
|
||||||
import java.nio.charset.Charset;
|
|
||||||
import java.nio.charset.StandardCharsets;
|
|
||||||
import java.nio.file.Files;
|
|
||||||
import java.nio.file.Path;
|
|
||||||
import java.security.MessageDigest;
|
import java.security.MessageDigest;
|
||||||
import java.security.NoSuchAlgorithmException;
|
import java.security.NoSuchAlgorithmException;
|
||||||
import java.util.ArrayList;
|
|
||||||
import java.util.Base64;
|
import java.util.Base64;
|
||||||
import java.util.List;
|
|
||||||
import java.util.Scanner;
|
|
||||||
import java.util.logging.Logger;
|
import java.util.logging.Logger;
|
||||||
import java.util.stream.Collectors;
|
|
||||||
import java.util.zip.CRC32;
|
import java.util.zip.CRC32;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
@ -56,7 +25,6 @@ public class FileUtil {
|
|||||||
}
|
}
|
||||||
|
|
||||||
private static final String TYPE_TAR_GZ = ".tar.gz";
|
private static final String TYPE_TAR_GZ = ".tar.gz";
|
||||||
private static final String TYPE_CSV = ".csv";
|
|
||||||
private static final String TAR_GZ = "tar.gz";
|
private static final String TAR_GZ = "tar.gz";
|
||||||
|
|
||||||
/**
|
/**
|
||||||
@ -81,7 +49,7 @@ public class FileUtil {
|
|||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 判断文件是否存在,不存在就创建一个空的
|
* 判断文件是否存在
|
||||||
*
|
*
|
||||||
* @param file
|
* @param file
|
||||||
*/
|
*/
|
||||||
@ -174,6 +142,7 @@ public class FileUtil {
|
|||||||
return null;
|
return null;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
/***
|
/***
|
||||||
* 计算SHA1码
|
* 计算SHA1码
|
||||||
*
|
*
|
||||||
@ -317,24 +286,41 @@ public class FileUtil {
|
|||||||
* @return
|
* @return
|
||||||
*/
|
*/
|
||||||
public static String base64ToStr(File file) {
|
public static String base64ToStr(File file) {
|
||||||
|
return new String(base64(file));
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 获取文件base64
|
||||||
|
*
|
||||||
|
* @param file
|
||||||
|
* @return
|
||||||
|
*/
|
||||||
|
public static byte[] base64(File file) {
|
||||||
|
FileInputStream fileInputStream = null;
|
||||||
|
byte[] data = null;
|
||||||
|
// 读取图片字节数组
|
||||||
try {
|
try {
|
||||||
byte[] bytes = Files.readAllBytes(Path.of(file.getPath()));
|
fileInputStream = new FileInputStream(file);
|
||||||
return Base64.getEncoder().encodeToString(bytes);
|
data = new byte[fileInputStream.available()];
|
||||||
|
fileInputStream.read(data);
|
||||||
|
fileInputStream.close();
|
||||||
} catch (IOException e) {
|
} catch (IOException e) {
|
||||||
logger.severe("The operation file is an IO exception.");
|
logger.severe("The operation file is an IO exception.");
|
||||||
|
e.printStackTrace();
|
||||||
}
|
}
|
||||||
return null;
|
// 对字节数组Base64编码
|
||||||
|
return Base64.getEncoder().encode(data);
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* base64转文件
|
* base64转文件
|
||||||
* <p>
|
* <p>
|
||||||
* <i>
|
* <i>
|
||||||
* 文件转base64请使用 {@link FileUtil#base64ToStr(File)}
|
* 文件转base64请使用 {@link FileUtil#base64(File)}
|
||||||
* </i>
|
* </i>
|
||||||
*
|
*
|
||||||
* @param decode {@link FileUtil#base64ToStr(File)} 的结果
|
* @param decode {@link FileUtil#base64ToStr(File)} 的结果
|
||||||
* @param fileName 保存文件名称（包含路径）
|
* @param fileName 文件名称（包含路径）
|
||||||
* @return 返回保存地址
|
* @return 返回保存地址
|
||||||
*/
|
*/
|
||||||
public static String base64ToFile(String decode, String fileName) {
|
public static String base64ToFile(String decode, String fileName) {
|
||||||
@ -345,7 +331,7 @@ public class FileUtil {
|
|||||||
* base64转文件
|
* base64转文件
|
||||||
* <p>
|
* <p>
|
||||||
* <i>
|
* <i>
|
||||||
* 文件转base64请使用 {@link FileUtil#base64ToStr(File)}
|
* 文件转base64请使用 {@link FileUtil#base64(File)}
|
||||||
* </i>
|
* </i>
|
||||||
*
|
*
|
||||||
* @param decode baseByte
|
* @param decode baseByte
|
||||||
@ -419,323 +405,6 @@ public class FileUtil {
|
|||||||
return 0;
|
return 0;
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
|
||||||
* 字符串（csv格式）转 对象
|
|
||||||
*
|
|
||||||
* @param data 转换的字符串 如
|
|
||||||
* <p> ------------ </p>
|
|
||||||
* <p> id,name,age </p>
|
|
||||||
* <p> 1,zhangsan,18 </p>
|
|
||||||
* <p> 2,lisi,20 </p>
|
|
||||||
* <p> ------------ </p>
|
|
||||||
* @param cls 需要转换的对象,含有<b>id,name,age</b>字段
|
|
||||||
* @param delimiter 分隔符
|
|
||||||
* @param <I>
|
|
||||||
* @return
|
|
||||||
*/
|
|
||||||
public static <I> List<I> readCsv(String data, Class<I> cls, char delimiter) throws IOException {
|
|
||||||
CsvMapper csvMapper = new CsvMapper();
|
|
||||||
CsvSchema csvSchema = CsvSchema.emptySchema().withHeader().withColumnSeparator(delimiter);
|
|
||||||
MappingIterator<I> orderLines = csvMapper.readerFor(cls).with(csvSchema).readValues(data);
|
|
||||||
return orderLines.readAll();
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 读取csv文件
|
|
||||||
*
|
|
||||||
* @param csvFilePath 文件地址
|
|
||||||
* @param cls 读取转化的对象
|
|
||||||
* @param hasHeader 是否存在header
|
|
||||||
* @param delimiter 分隔符.默认【,】
|
|
||||||
* @param <I>
|
|
||||||
* @return
|
|
||||||
*/
|
|
||||||
public static <I> List<I> readCsv(final String csvFilePath, Class<I> cls, boolean hasHeader, char delimiter) {
|
|
||||||
if (!isFileExist(csvFilePath)) {
|
|
||||||
throw new RuntimeException(String.format("解析用的csv：\u0020[%s] 文件不存在。", csvFilePath));
|
|
||||||
}
|
|
||||||
if (StrUtil.isEmpty(delimiter)) {
|
|
||||||
delimiter = ',';
|
|
||||||
}
|
|
||||||
try {
|
|
||||||
File csvFile = new File(csvFilePath);
|
|
||||||
CsvMapper csvMapper = new CsvMapper();
|
|
||||||
CsvSchema csvSchema = csvMapper.typedSchemaFor(cls).withStrictHeaders(hasHeader).withColumnSeparator(delimiter).withComments();
|
|
||||||
MappingIterator<I> recordIterator = csvMapper.readerWithTypedSchemaFor(cls).with(csvSchema).readValues(csvFile);
|
|
||||||
return recordIterator.readAll();
|
|
||||||
} catch (IOException e) {
|
|
||||||
throw new RuntimeException("[" + csvFilePath + "] 文件解析失败。", e);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 判断文件是否存在
|
|
||||||
*
|
|
||||||
* @param filePath
|
|
||||||
* @return
|
|
||||||
*/
|
|
||||||
public static boolean isFileExist(String filePath) {
|
|
||||||
if (StrUtil.isEmpty(filePath)) {
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
|
|
||||||
File file = new File(filePath);
|
|
||||||
return file.exists() && !file.isDirectory();
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 分段读取大文件
|
|
||||||
*
|
|
||||||
* @param path 文件路径
|
|
||||||
* @param readFileBean 分段每次读取的bean 初始值需要设置每次读取的行数
|
|
||||||
* @param <T> 读取结果类型bean
|
|
||||||
* @return
|
|
||||||
*/
|
|
||||||
public <T> ReadFileBean<T> readBigFile(String path, ReadFileBean<T> readFileBean, Class<T> readCls) {
|
|
||||||
File file = new File(path);
|
|
||||||
judeFileExists(file);
|
|
||||||
try {
|
|
||||||
RandomAccessFile randomAccessFile = new RandomAccessFile(file, "r");
|
|
||||||
randomAccessFile.seek(readFileBean.getPointer());
|
|
||||||
readFileBean.setFileLength(randomAccessFile.length());
|
|
||||||
List<String> datas = new ArrayList<>();
|
|
||||||
for (int i = 0; i < readFileBean.getReadRowNum(); i++) {
|
|
||||||
String s = randomAccessFile.readLine();
|
|
||||||
datas.add(charsetDecode(s, StandardCharsets.UTF_8));
|
|
||||||
readFileBean.setPointer(randomAccessFile.getFilePointer());
|
|
||||||
}
|
|
||||||
randomAccessFile.close();
|
|
||||||
if (path.contains(TYPE_CSV)) {
|
|
||||||
//csv文件处理
|
|
||||||
datas.add(0, getCsvHeader(readCls));
|
|
||||||
List<T> dataList = readCsv(String.join("\n", datas), readCls, ',');
|
|
||||||
readFileBean.setDatas(dataList);
|
|
||||||
}
|
|
||||||
} catch (FileNotFoundException e) {
|
|
||||||
logger.severe("file exists." + e.getMessage());
|
|
||||||
} catch (IOException e) {
|
|
||||||
logger.severe("read file error." + e.getMessage());
|
|
||||||
}
|
|
||||||
return readFileBean;
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 获取csv的header,使用注解{@link CsvHeader}
|
|
||||||
*
|
|
||||||
* @param cls
|
|
||||||
* @param <T>
|
|
||||||
* @return
|
|
||||||
*/
|
|
||||||
public static <T> String getCsvHeader(Class<T> cls) {
|
|
||||||
CsvHeader annotation = cls.getAnnotation(CsvHeader.class);
|
|
||||||
Assert.notNull(annotation, cls.toString() + "类上需要添加注解@CsvHeader，并指定header。");
|
|
||||||
String header = annotation.header();
|
|
||||||
Assert.notNull(header, cls.toString() + "类上需要添加注解@CsvHeader，并指定header。");
|
|
||||||
return header;
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 把字符串data按照指定编码解码
|
|
||||||
*
|
|
||||||
* @param data 解码字符串
|
|
||||||
* @param charset 字符编码
|
|
||||||
* @return
|
|
||||||
*/
|
|
||||||
public static String charsetDecode(String data, Charset charset) {
|
|
||||||
char[] chars = data.toCharArray();
|
|
||||||
byte[] result = new byte[chars.length];
|
|
||||||
for (int i = 0; i < chars.length; i++) {
|
|
||||||
result[i] = (byte) chars[i];
|
|
||||||
}
|
|
||||||
return new String(result, charset);
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 提供读取IO流方法合集
|
|
||||||
* <p>读取速度快慢顺序：</p>
|
|
||||||
* 1. {@link #read4Buffer(InputStream, Charset)} <br>
|
|
||||||
* 2. {@link #read4IOUtilsCopy(InputStream, Charset)} <br>
|
|
||||||
* 3. {@link #read4ByteStreams(InputStream, Charset)} <br>
|
|
||||||
* 4. {@link #read4Byte(InputStream, Charset)} <br>
|
|
||||||
* 5. {@link #read4StringBuilder(InputStream, Charset)} <br>
|
|
||||||
* 6. {@link #read4BufferedReaderParallel(InputStream, Charset, String)}<br>
|
|
||||||
* 7. {@link #read4BufferedReader(InputStream, Charset, String)}<br>
|
|
||||||
* 8. {@link #read4ScannerA(InputStream)}<br>
|
|
||||||
* 9. {@link #read4BufferIO(InputStream, Charset)}<br>
|
|
||||||
* 10. {@link #read4IOUtils(InputStream, Charset)}<br>
|
|
||||||
* 11. {@link #read4ScannerZ(InputStream)}<br>
|
|
||||||
* 12. {@link #read4CharStreams(InputStream, Charset)}<br>
|
|
||||||
*/
|
|
||||||
public static class FileInput {
|
|
||||||
/**
|
|
||||||
* 读取IO流内容：byte方式
|
|
||||||
*
|
|
||||||
* @param inputStream
|
|
||||||
* @param charset 编码：默认 {@link Charset#defaultCharset()}
|
|
||||||
* @return
|
|
||||||
* @throws IOException
|
|
||||||
*/
|
|
||||||
public static String read4Byte(InputStream inputStream, Charset charset) throws IOException {
|
|
||||||
byte[] bytes = new byte[inputStream.available()];
|
|
||||||
inputStream.read(bytes);
|
|
||||||
return new String(bytes, charset == null ? Charset.defaultCharset() : charset);
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 读取IO流内容：BufferedReader方式
|
|
||||||
*
|
|
||||||
* @param inputStream
|
|
||||||
* @param charset 编码：默认跟随系统 {@link Charset#defaultCharset()}
|
|
||||||
* @param lineSeparator 换行方式：默认跟随系统 {@link System#lineSeparator()}
|
|
||||||
* @return
|
|
||||||
*/
|
|
||||||
public static String read4BufferedReader(InputStream inputStream, Charset charset, String lineSeparator) {
|
|
||||||
return new BufferedReader(
|
|
||||||
new InputStreamReader(inputStream, charset == null ? Charset.defaultCharset() : charset)
|
|
||||||
).lines().collect(Collectors.joining(lineSeparator == null ? System.lineSeparator() : lineSeparator));
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 读取IO流内容：BufferedReader 并行方式
|
|
||||||
*
|
|
||||||
* @param inputStream
|
|
||||||
* @param charset 编码：默认跟随系统 {@link Charset#defaultCharset()}
|
|
||||||
* @param lineSeparator 换行方式：默认跟随系统 {@link System#lineSeparator()}
|
|
||||||
* @return
|
|
||||||
*/
|
|
||||||
public static String read4BufferedReaderParallel(InputStream inputStream, Charset charset, String lineSeparator) {
|
|
||||||
return new BufferedReader(
|
|
||||||
new InputStreamReader(inputStream, charset == null ? Charset.defaultCharset() : charset)
|
|
||||||
).lines().parallel()
|
|
||||||
.collect(Collectors.joining(lineSeparator == null ? System.lineSeparator() : lineSeparator));
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 读取IO流内容：Scanner A方式
|
|
||||||
*
|
|
||||||
* @param inputStream
|
|
||||||
* @return
|
|
||||||
*/
|
|
||||||
public static String read4ScannerA(InputStream inputStream) {
|
|
||||||
Scanner s = new Scanner(inputStream).useDelimiter("\\A");
|
|
||||||
String str = s.hasNext() ? s.next() : "";
|
|
||||||
return str;
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 读取IO流内容：Scanner Z方式
|
|
||||||
*
|
|
||||||
* @param inputStream
|
|
||||||
* @return
|
|
||||||
*/
|
|
||||||
public static String read4ScannerZ(InputStream inputStream) {
|
|
||||||
return new Scanner(inputStream).useDelimiter("\\Z").next();
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 读取IO流内容：StringBuilder方式
|
|
||||||
*
|
|
||||||
* @param inputStream
|
|
||||||
* @param charset 编码：默认跟随系统 {@link Charset#defaultCharset()}
|
|
||||||
* @return
|
|
||||||
*/
|
|
||||||
public static String read4StringBuilder(InputStream inputStream, Charset charset) throws IOException {
|
|
||||||
StringBuilder sb = new StringBuilder();
|
|
||||||
String line;
|
|
||||||
BufferedReader br = new BufferedReader(new InputStreamReader(inputStream, charset == null ? Charset.defaultCharset() : charset));
|
|
||||||
while ((line = br.readLine()) != null) {
|
|
||||||
sb.append(line);
|
|
||||||
}
|
|
||||||
return sb.toString();
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 读取IO流内容：ByteArrayOutputStream方式
|
|
||||||
*
|
|
||||||
* @param inputStream
|
|
||||||
* @param charset 编码：默认跟随系统 {@link Charset#defaultCharset()}
|
|
||||||
* @return
|
|
||||||
*/
|
|
||||||
public static String read4Buffer(InputStream inputStream, Charset charset) throws IOException {
|
|
||||||
ByteArrayOutputStream result = new ByteArrayOutputStream();
|
|
||||||
byte[] buffer = new byte[1024];
|
|
||||||
int length;
|
|
||||||
while ((length = inputStream.read(buffer)) != -1) {
|
|
||||||
result.write(buffer, 0, length);
|
|
||||||
}
|
|
||||||
return result.toString(charset == null ? Charset.defaultCharset().name() : charset.name());
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 读取IO流内容：BufferedInputStream+ByteArrayOutputStream方式
|
|
||||||
*
|
|
||||||
* @param inputStream
|
|
||||||
* @param charset 编码：默认跟随系统 {@link Charset#defaultCharset()}
|
|
||||||
* @return
|
|
||||||
*/
|
|
||||||
public static String read4BufferIO(InputStream inputStream, Charset charset) throws IOException {
|
|
||||||
BufferedInputStream bis = new BufferedInputStream(inputStream);
|
|
||||||
ByteArrayOutputStream buf = new ByteArrayOutputStream();
|
|
||||||
int result = bis.read();
|
|
||||||
while (result != -1) {
|
|
||||||
buf.write((byte) result);
|
|
||||||
result = bis.read();
|
|
||||||
}
|
|
||||||
return buf.toString(charset == null ? Charset.defaultCharset().name() : charset.name());
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 读取IO流内容： 依赖于commons-io:commons-io {@link IOUtils#copy(Reader, OutputStream, Charset)}
|
|
||||||
*
|
|
||||||
* @param inputStream
|
|
||||||
* @param charset 编码：默认跟随系统 {@link Charset#defaultCharset()}
|
|
||||||
* @return
|
|
||||||
* @throws IOException
|
|
||||||
*/
|
|
||||||
public static String read4IOUtilsCopy(InputStream inputStream, Charset charset) throws IOException {
|
|
||||||
StringWriter writer = new StringWriter();
|
|
||||||
IOUtils.copy(inputStream, writer, charset == null ? Charset.defaultCharset() : charset);
|
|
||||||
return writer.toString();
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 读取IO流内容： 依赖于commons-io:commons-io {@link IOUtils#toString(InputStream, Charset)}
|
|
||||||
*
|
|
||||||
* @param inputStream
|
|
||||||
* @param charset 编码：默认跟随系统 {@link Charset#defaultCharset()}
|
|
||||||
* @return
|
|
||||||
* @throws IOException
|
|
||||||
*/
|
|
||||||
public static String read4IOUtils(InputStream inputStream, Charset charset) throws IOException {
|
|
||||||
return IOUtils.toString(inputStream, charset == null ? Charset.defaultCharset() : charset);
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 读取IO流内容： 依赖于com.google.guava:guava {@link CharStreams#toString(Readable)}
|
|
||||||
*
|
|
||||||
* @param inputStream
|
|
||||||
* @param charset 编码：默认跟随系统 {@link Charset#defaultCharset()}
|
|
||||||
* @return
|
|
||||||
* @throws IOException
|
|
||||||
*/
|
|
||||||
public static String read4CharStreams(InputStream inputStream, Charset charset) throws IOException {
|
|
||||||
return CharStreams.toString(new InputStreamReader(inputStream, charset == null ? Charset.defaultCharset() : charset));
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 读取IO流内容： 依赖于com.google.guava:guava {@link ByteStreams#toByteArray(InputStream)}
|
|
||||||
*
|
|
||||||
* @param inputStream
|
|
||||||
* @param charset 编码：默认跟随系统 {@link Charset#defaultCharset()}
|
|
||||||
* @return
|
|
||||||
* @throws IOException
|
|
||||||
*/
|
|
||||||
public static String read4ByteStreams(InputStream inputStream, Charset charset) throws IOException {
|
|
||||||
return new String(ByteStreams.toByteArray(inputStream), charset == null ? Charset.defaultCharset() : charset);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
/*public static void main(String[] args) {
|
/*public static void main(String[] args) {
|
||||||
long size = FileUtil.size(new File("E:\\OS\\deepin-15.6-amd64\\DeepinCloudPrintServerInstaller_1.0.0.1.exe"));
|
long size = FileUtil.size(new File("E:\\OS\\deepin-15.6-amd64\\DeepinCloudPrintServerInstaller_1.0.0.1.exe"));
|
||||||
System.out.println(size);
|
System.out.println(size);
|
||||||
|
|||||||
@ -1,7 +1,5 @@
|
|||||||
package com.yexuejc.base.util;
|
package com.yexuejc.base.util;
|
||||||
|
|
||||||
import com.yexuejc.base.annotation.ToUeProperty;
|
|
||||||
|
|
||||||
import java.io.*;
|
import java.io.*;
|
||||||
import java.lang.reflect.Field;
|
import java.lang.reflect.Field;
|
||||||
import java.time.LocalDate;
|
import java.time.LocalDate;
|
||||||
|
|||||||
@ -1,6 +1,4 @@
|
|||||||
package com.yexuejc.base.annotation;
|
package com.yexuejc.base.util;
|
||||||
|
|
||||||
import com.yexuejc.base.util.ObjUtil;
|
|
||||||
|
|
||||||
import java.lang.annotation.*;
|
import java.lang.annotation.*;
|
||||||
|
|
||||||
@ -1,65 +0,0 @@
|
|||||||
package com.yexuejc.base.util;
|
|
||||||
|
|
||||||
import com.yexuejc.base.pojo.CreateZipFileBean;
|
|
||||||
import net.lingala.zip4j.ZipFile;
|
|
||||||
import net.lingala.zip4j.exception.ZipException;
|
|
||||||
import net.lingala.zip4j.model.ExcludeFileFilter;
|
|
||||||
import net.lingala.zip4j.model.ZipParameters;
|
|
||||||
import net.lingala.zip4j.model.enums.CompressionMethod;
|
|
||||||
import net.lingala.zip4j.model.enums.EncryptionMethod;
|
|
||||||
|
|
||||||
import java.io.File;
|
|
||||||
import java.util.ArrayList;
|
|
||||||
import java.util.HashMap;
|
|
||||||
import java.util.List;
|
|
||||||
import java.util.Map;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 压缩相关
|
|
||||||
* <p>依赖于zip4j：<a href='https://github.com/srikanth-lingala/zip4j'>https://github.com/srikanth-lingala/zip4j</a></p>
|
|
||||||
*
|
|
||||||
* @author maxf
|
|
||||||
* @class-name ZipUtil
|
|
||||||
* @description 文件压缩
|
|
||||||
* @date 2022/11/11 11:09
|
|
||||||
*/
|
|
||||||
public class ZipUtil {
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 创建压缩文件
|
|
||||||
*
|
|
||||||
* @param zipFileBean
|
|
||||||
*/
|
|
||||||
public static void createZipFile(CreateZipFileBean zipFileBean) throws ZipException {
|
|
||||||
ZipParameters zipParameters = new ZipParameters();
|
|
||||||
zipParameters.setCompressionMethod(CompressionMethod.STORE);
|
|
||||||
|
|
||||||
//加密
|
|
||||||
zipParameters.setEncryptFiles(true);
|
|
||||||
zipParameters.setEncryptionMethod(EncryptionMethod.ZIP_STANDARD);
|
|
||||||
ZipFile zipFile = new ZipFile(zipFileBean.getZipFile());
|
|
||||||
if (StrUtil.isNotEmpty(zipFileBean.getEncryptPwd())) {
|
|
||||||
zipFile = new ZipFile(zipFileBean.getZipFile(), zipFileBean.getEncryptPwd().toCharArray());
|
|
||||||
}
|
|
||||||
if (StrUtil.isNotEmpty(zipFileBean.getSourceFileName())) {
|
|
||||||
//压缩文件
|
|
||||||
List<File> filesToAdd = new ArrayList<>(16);
|
|
||||||
Map<String, String> fileNamesMap = new HashMap<>(16);
|
|
||||||
zipFileBean.getSourceFileName().forEach(it -> {
|
|
||||||
String file = zipFileBean.getSourcePath() + File.separator + it;
|
|
||||||
filesToAdd.add(new File(file));
|
|
||||||
fileNamesMap.put(file, it);
|
|
||||||
});
|
|
||||||
zipFile.renameFiles(fileNamesMap);
|
|
||||||
zipFile.addFiles(filesToAdd, zipParameters);
|
|
||||||
} else {
|
|
||||||
//压缩目录
|
|
||||||
ExcludeFileFilter excludeFileFilter = zipFileBean.getExcludeFileName()::contains;
|
|
||||||
zipParameters.setExcludeFileFilter(excludeFileFilter);
|
|
||||||
zipFile.addFolder(new File(zipFileBean.getSourcePath()), zipParameters);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
//checkemun key -> codeMst检索(缓存)
|
|
||||||
//返回exception(message用区分分割文言和exp)
|
|
||||||
@ -1,7 +1,5 @@
|
|||||||
package com.yexuejc.base.util;
|
package com.yexuejc.base.util;
|
||||||
|
|
||||||
import com.yexuejc.base.annotation.ToUeProperty;
|
|
||||||
|
|
||||||
import java.io.Serializable;
|
import java.io.Serializable;
|
||||||
import java.math.BigDecimal;
|
import java.math.BigDecimal;
|
||||||
import java.time.LocalDateTime;
|
import java.time.LocalDateTime;
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user