Skip to content
Projects
Groups
Snippets
Help
Loading...
Help
Submit feedback
Sign in / Register
Toggle navigation
Y
yzg-util
Project
Project
Details
Activity
Releases
Cycle Analytics
Repository
Repository
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Charts
Issues
0
Issues
0
List
Board
Labels
Milestones
Merge Requests
0
Merge Requests
0
CI / CD
CI / CD
Pipelines
Jobs
Schedules
Charts
Wiki
Wiki
Snippets
Snippets
Members
Members
Collapse sidebar
Close sidebar
Activity
Graph
Charts
Create a new issue
Jobs
Commits
Issue Boards
Open sidebar
YZG
yzg-util
Commits
aff8222f
Commit
aff8222f
authored
Aug 12, 2021
by
gongzuquan
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
异常信息优化
parent
1c3d04f9
Changes
32
Hide whitespace changes
Inline
Side-by-side
Showing
32 changed files
with
136 additions
and
61 deletions
+136
-61
YzgError.java
...til-base/src/main/java/com/yanzuoguang/util/YzgError.java
+49
-1
ObjectHelper.java
...src/main/java/com/yanzuoguang/util/base/ObjectHelper.java
+2
-1
ByteHelper.java
...src/main/java/com/yanzuoguang/util/helper/ByteHelper.java
+2
-1
FileHelper.java
...src/main/java/com/yanzuoguang/util/helper/FileHelper.java
+10
-8
FormulaHelper.java
.../main/java/com/yanzuoguang/util/helper/FormulaHelper.java
+4
-2
RandomHelper.java
...c/main/java/com/yanzuoguang/util/helper/RandomHelper.java
+4
-3
RunHelper.java
.../src/main/java/com/yanzuoguang/util/helper/RunHelper.java
+2
-1
StringHelper.java
...c/main/java/com/yanzuoguang/util/helper/StringHelper.java
+2
-1
ZipHelper.java
.../src/main/java/com/yanzuoguang/util/helper/ZipHelper.java
+6
-4
RunnableList.java
...c/main/java/com/yanzuoguang/util/thread/RunnableList.java
+3
-1
RunnableListAutoItem.java
...ava/com/yanzuoguang/util/thread/RunnableListAutoItem.java
+2
-1
TestSfzUtil.java
yzg-util-base/src/test/java/helper/TestSfzUtil.java
+2
-1
TestTypeHelper.java
yzg-util-base/src/test/java/helper/TestTypeHelper.java
+2
-1
TestRunnableListAuto.java
yzg-util-base/src/test/java/thread/TestRunnableListAuto.java
+2
-1
WebAspectUtil.java
...rc/main/java/com/yanzuoguang/cloud/aop/WebAspectUtil.java
+2
-1
ExcelHttp.java
.../src/main/java/com/yanzuoguang/cloud/excel/ExcelHttp.java
+3
-2
SqlCondBase.java
...b/src/main/java/com/yanzuoguang/dao/cond/SqlCondBase.java
+3
-2
SqlCondItem.java
...b/src/main/java/com/yanzuoguang/dao/cond/SqlCondItem.java
+4
-3
BaseDaoImpl.java
...b/src/main/java/com/yanzuoguang/dao/impl/BaseDaoImpl.java
+5
-4
BaseDaoSql.java
...db/src/main/java/com/yanzuoguang/dao/impl/BaseDaoSql.java
+1
-1
TableSqlCache.java
...src/main/java/com/yanzuoguang/dao/impl/TableSqlCache.java
+3
-2
ExcelConsole.java
...-db/src/main/java/com/yanzuoguang/excel/ExcelConsole.java
+6
-5
BaseServiceImpl.java
...in/java/com/yanzuoguang/service/impl/BaseServiceImpl.java
+2
-1
TokenHelper.java
...l-db/src/main/java/com/yanzuoguang/token/TokenHelper.java
+1
-1
MediaHelperExtend.java
...src/main/java/com/yanzuoguang/util/MediaHelperExtend.java
+1
-1
TestMediaHelper.java
...il-image-extend/src/test/java/helper/TestMediaHelper.java
+2
-1
MediaHelper.java
...image/src/main/java/com/yanzuoguang/util/MediaHelper.java
+2
-2
MediaParameter.java
...ge/src/main/java/com/yanzuoguang/util/MediaParameter.java
+3
-3
TestMediaHelper.java
yzg-util-image/src/test/java/helper/TestMediaHelper.java
+1
-1
PrinterHelper.java
...int/src/main/java/com/yanzuoguang/util/PrinterHelper.java
+1
-1
FormatCenter.java
...ava/com/yanzuoguang/util/printer/format/FormatCenter.java
+3
-2
TestPrinterHelper.java
yzg-util-print/src/test/java/helper/TestPrinterHelper.java
+1
-1
No files found.
yzg-util-base/src/main/java/com/yanzuoguang/util/YzgError.java
View file @
aff8222f
...
@@ -13,9 +13,57 @@ public class YzgError {
...
@@ -13,9 +13,57 @@ public class YzgError {
private
static
YzgErrorData
error
=
new
YzgErrorData
(
"999."
);
private
static
YzgErrorData
error
=
new
YzgErrorData
(
"999."
);
private
static
void
init
()
{
private
static
void
init
()
{
error
.
add
(
"000"
,
"%s"
);
error
.
add
(
"001"
,
"该页面未绑定表"
);
error
.
add
(
"001"
,
"该页面未绑定表"
);
error
.
add
(
"002"
,
"类%s未发现表结构"
);
error
.
add
(
"002"
,
"类%s未发现表结构"
);
error
.
add
(
"003"
,
"类%未发现SQL语句%s"
);
error
.
add
(
"003"
,
"类%s未发现SQL语句%s"
);
error
.
add
(
"004"
,
"泛型继承检测错误"
);
error
.
add
(
"005"
,
"视频文件不存在"
);
error
.
add
(
"006"
,
"对象%s不能复制"
);
error
.
add
(
"007"
,
"整形转换成字节的PCD码必须小于100"
);
error
.
add
(
"008"
,
"不能识别文件类型%s"
);
error
.
add
(
"009"
,
"文件类型不为图片、音频、视频"
);
error
.
add
(
"010"
,
"文件%s已存在文件,不能创建目录"
);
error
.
add
(
"011"
,
"创建文件夹失败"
);
error
.
add
(
"012"
,
"文件删除失败"
);
error
.
add
(
"013"
,
"变量名%s不支持"
);
error
.
add
(
"014"
,
"正则表达式错误"
);
error
.
add
(
"015"
,
"length params is error, must be greater than 0, this params is [%s]"
);
error
.
add
(
"016"
,
"random code, essential data is empty."
);
error
.
add
(
"017"
,
"生成时间搓 MD5 ID 时,时间不能为空"
);
error
.
add
(
"018"
,
"压缩时文件夹对象不能为空。"
);
error
.
add
(
"019"
,
"[%s]不是一个文件夹,或者不存在。"
);
error
.
add
(
"020"
,
"删除文件失败"
);
error
.
add
(
"021"
,
"文件%s不存在"
);
error
.
add
(
"022"
,
"没有抛出异常"
);
error
.
add
(
"023"
,
"监视错误"
);
error
.
add
(
"024"
,
"导出时请传入配置信息"
);
error
.
add
(
"025"
,
"不能处理非本条件的字段"
);
error
.
add
(
"026"
,
"代码片段%s:%s:%s为单数"
);
error
.
add
(
"027"
,
"SqlCondItem不支持输入参数,必须带代码片段"
);
error
.
add
(
"028"
,
"需要格式化的字符串不支持"
);
error
.
add
(
"029"
,
"表%s主键值为空时不能更新"
);
error
.
add
(
"030"
,
"修改失败,请确认是否被其他人修改,版本号传入是否正确"
);
error
.
add
(
"031"
,
"统计类型[%s]不支持"
);
error
.
add
(
"032"
,
"SQL语句%s不存在纬度%s"
);
error
.
add
(
"033"
,
"表中未包含MD5字段"
);
error
.
add
(
"034"
,
"Excel已初始化"
);
error
.
add
(
"035"
,
"保存失败"
);
error
.
add
(
"036"
,
"保存路径%s失败"
);
error
.
add
(
"037"
,
"%s失败,该数据可能已被修改"
);
error
.
add
(
"038"
,
"size请在0~1之间"
);
error
.
add
(
"039"
,
"视频转码压缩时文件不存在:%s"
);
error
.
add
(
"040"
,
"audioBitRateZip请在0~1之间"
);
error
.
add
(
"041"
,
"videoSizeZip请在0~1之间"
);
error
.
add
(
"042"
,
"videoBitRateZip请在0~1之间"
);
error
.
add
(
"043"
,
"你需要格式化的字符串格式为空"
);
error
.
add
(
"044"
,
"不能获取文件Mime类型%s"
);
error
.
add
(
"045"
,
"下载失败"
);
error
.
add
(
"046"
,
"创建对象%s出错"
);
error
.
add
(
"047"
,
"不能识别模板"
);
error
.
add
(
"048"
,
"获取视频所缩类图失败:%s"
);
}
}
private
static
void
initTemp
()
{
private
static
void
initTemp
()
{
...
...
yzg-util-base/src/main/java/com/yanzuoguang/util/base/ObjectHelper.java
View file @
aff8222f
package
com
.
yanzuoguang
.
util
.
base
;
package
com
.
yanzuoguang
.
util
.
base
;
import
com.yanzuoguang.util.YzgError
;
import
com.yanzuoguang.util.exception.ExceptionHelper
;
import
com.yanzuoguang.util.exception.ExceptionHelper
;
import
com.yanzuoguang.util.helper.StringHelper
;
import
com.yanzuoguang.util.helper.StringHelper
;
...
@@ -253,7 +254,7 @@ public class ObjectHelper {
...
@@ -253,7 +254,7 @@ public class ObjectHelper {
writeWithFromClass
(
to
,
from
);
writeWithFromClass
(
to
,
from
);
return
(
T
)
to
;
return
(
T
)
to
;
}
catch
(
Exception
e
)
{
}
catch
(
Exception
e
)
{
throw
new
RuntimeException
(
"对象"
+
cls
.
getName
()
+
"不能复制"
,
e
);
throw
YzgError
.
getRuntimeException
(
e
,
"006"
,
cls
.
getName
()
);
}
}
}
}
...
...
yzg-util-base/src/main/java/com/yanzuoguang/util/helper/ByteHelper.java
View file @
aff8222f
package
com
.
yanzuoguang
.
util
.
helper
;
package
com
.
yanzuoguang
.
util
.
helper
;
import
com.yanzuoguang.util.YzgError
;
/**
/**
* 通信格式转换
* 通信格式转换
...
@@ -542,7 +543,7 @@ public class ByteHelper {
...
@@ -542,7 +543,7 @@ public class ByteHelper {
*/
*/
public
static
byte
toBCD
(
int
from
)
{
public
static
byte
toBCD
(
int
from
)
{
if
(
from
>=
BCD_MAX_FLAG
)
{
if
(
from
>=
BCD_MAX_FLAG
)
{
throw
new
RuntimeException
(
"整形转换成字节的PCD码必须小于100
"
);
throw
YzgError
.
getRuntimeException
(
"007
"
);
}
}
byte
bt
=
(
byte
)
((
from
/
BYTE_TEN_UNIT
*
BYTE_HEX_UNIT
)
+
from
%
BYTE_TEN_UNIT
);
byte
bt
=
(
byte
)
((
from
/
BYTE_TEN_UNIT
*
BYTE_HEX_UNIT
)
+
from
%
BYTE_TEN_UNIT
);
return
bt
;
return
bt
;
...
...
yzg-util-base/src/main/java/com/yanzuoguang/util/helper/FileHelper.java
View file @
aff8222f
package
com
.
yanzuoguang
.
util
.
helper
;
package
com
.
yanzuoguang
.
util
.
helper
;
import
com.yanzuoguang.util.YzgError
;
import
java.io.*
;
import
java.io.*
;
import
java.nio.file.Files
;
import
java.nio.file.Files
;
import
java.nio.file.Path
;
import
java.nio.file.Path
;
...
@@ -35,7 +37,7 @@ public class FileHelper {
...
@@ -35,7 +37,7 @@ public class FileHelper {
String
contentType
=
Files
.
probeContentType
(
path
);
String
contentType
=
Files
.
probeContentType
(
path
);
return
contentType
;
return
contentType
;
}
catch
(
Exception
ex
)
{
}
catch
(
Exception
ex
)
{
throw
new
RuntimeException
(
"不能获取文件Mime类型"
+
filePath
,
ex
);
throw
YzgError
.
getRuntimeException
(
ex
,
"044"
,
filePath
);
}
}
}
}
...
@@ -49,12 +51,12 @@ public class FileHelper {
...
@@ -49,12 +51,12 @@ public class FileHelper {
public
static
int
getMediaType
(
String
file
)
{
public
static
int
getMediaType
(
String
file
)
{
String
mimeType
=
FileHelper
.
getMimeType
(
file
);
String
mimeType
=
FileHelper
.
getMimeType
(
file
);
if
(
mimeType
==
null
)
{
if
(
mimeType
==
null
)
{
throw
new
RuntimeException
(
"不能识别文件类型"
+
file
);
throw
YzgError
.
getRuntimeException
(
"008"
,
file
);
}
}
int
type
=
getMediaTypeByMime
(
mimeType
);
int
type
=
getMediaTypeByMime
(
mimeType
);
// System.out.println(mimeType);
// System.out.println(mimeType);
if
(
type
==
FILE_TYPE_NONE
)
{
if
(
type
==
FILE_TYPE_NONE
)
{
throw
new
RuntimeException
(
"文件类型不为图片、音频、视频
"
);
throw
YzgError
.
getRuntimeException
(
"009
"
);
}
}
return
type
;
return
type
;
}
}
...
@@ -100,7 +102,7 @@ public class FileHelper {
...
@@ -100,7 +102,7 @@ public class FileHelper {
if
(
file
.
isDirectory
())
{
if
(
file
.
isDirectory
())
{
return
StringHelper
.
EMPTY
;
return
StringHelper
.
EMPTY
;
}
else
{
}
else
{
throw
new
RuntimeException
(
"文件"
+
file
.
getName
()
+
"已存在文件,不能创建目录"
);
throw
YzgError
.
getRuntimeException
(
"010"
,
file
.
getName
()
);
}
}
}
}
file
.
mkdirs
();
file
.
mkdirs
();
...
@@ -183,11 +185,11 @@ public class FileHelper {
...
@@ -183,11 +185,11 @@ public class FileHelper {
if
(
parentFile
!=
null
)
{
if
(
parentFile
!=
null
)
{
if
(!
parentFile
.
exists
())
{
if
(!
parentFile
.
exists
())
{
if
(!
parentFile
.
mkdirs
())
{
if
(!
parentFile
.
mkdirs
())
{
throw
new
RuntimeException
(
"创建文件夹失败
"
);
throw
YzgError
.
getRuntimeException
(
"011
"
);
}
}
}
}
if
(!
parentFile
.
exists
())
{
if
(!
parentFile
.
exists
())
{
throw
new
RuntimeException
(
"创建文件夹失败
"
);
throw
YzgError
.
getRuntimeException
(
"011
"
);
}
}
}
}
// 文件不存在则创建
// 文件不存在则创建
...
@@ -218,11 +220,11 @@ public class FileHelper {
...
@@ -218,11 +220,11 @@ public class FileHelper {
// 删除文件
// 删除文件
if
(
file
.
exists
())
{
if
(
file
.
exists
())
{
if
(!
file
.
delete
())
{
if
(!
file
.
delete
())
{
throw
new
RuntimeException
(
"文件删除失败
"
);
throw
YzgError
.
getRuntimeException
(
"012
"
);
}
}
}
}
if
(
file
.
exists
())
{
if
(
file
.
exists
())
{
throw
new
RuntimeException
(
"文件删除失败
"
);
throw
YzgError
.
getRuntimeException
(
"012
"
);
}
}
writeFileAppend
(
file
,
content
,
encoding
);
writeFileAppend
(
file
,
content
,
encoding
);
}
catch
(
RuntimeException
e
)
{
}
catch
(
RuntimeException
e
)
{
...
...
yzg-util-base/src/main/java/com/yanzuoguang/util/helper/FormulaHelper.java
View file @
aff8222f
package
com
.
yanzuoguang
.
util
.
helper
;
package
com
.
yanzuoguang
.
util
.
helper
;
import
com.yanzuoguang.util.YzgError
;
import
java.util.ArrayList
;
import
java.util.ArrayList
;
import
java.util.HashMap
;
import
java.util.HashMap
;
import
java.util.List
;
import
java.util.List
;
...
@@ -47,7 +49,7 @@ public class FormulaHelper {
...
@@ -47,7 +49,7 @@ public class FormulaHelper {
public
static
final
int
getExcelIndex
(
String
columnName
)
{
public
static
final
int
getExcelIndex
(
String
columnName
)
{
columnName
=
columnName
.
toLowerCase
();
columnName
=
columnName
.
toLowerCase
();
if
(!
columnName
.
matches
(
"^[a-z]+$"
))
{
if
(!
columnName
.
matches
(
"^[a-z]+$"
))
{
throw
new
RuntimeException
(
"变量名"
+
columnName
+
"不支持"
);
throw
YzgError
.
getRuntimeException
(
"013"
,
columnName
);
}
}
// 从名称转换列序号
// 从名称转换列序号
int
formulaColumnIndex
=
0
;
int
formulaColumnIndex
=
0
;
...
@@ -208,7 +210,7 @@ public class FormulaHelper {
...
@@ -208,7 +210,7 @@ public class FormulaHelper {
Pattern
p
=
Pattern
.
compile
(
regex
);
Pattern
p
=
Pattern
.
compile
(
regex
);
Matcher
matcher
=
p
.
matcher
(
formula
);
Matcher
matcher
=
p
.
matcher
(
formula
);
if
(!
matcher
.
find
())
{
if
(!
matcher
.
find
())
{
throw
new
RuntimeException
(
"正则表达式错误
"
);
throw
YzgError
.
getRuntimeException
(
"014
"
);
}
}
return
matcher
;
return
matcher
;
}
}
...
...
yzg-util-base/src/main/java/com/yanzuoguang/util/helper/RandomHelper.java
View file @
aff8222f
package
com
.
yanzuoguang
.
util
.
helper
;
package
com
.
yanzuoguang
.
util
.
helper
;
import
com.yanzuoguang.util.YzgError
;
import
com.yanzuoguang.util.contants.SystemContants
;
import
com.yanzuoguang.util.contants.SystemContants
;
import
java.util.Random
;
import
java.util.Random
;
...
@@ -63,7 +64,7 @@ public final class RandomHelper {
...
@@ -63,7 +64,7 @@ public final class RandomHelper {
*/
*/
public
static
String
generateRandomCodeSix
(
int
len
)
{
public
static
String
generateRandomCodeSix
(
int
len
)
{
if
(
len
<
1
)
{
if
(
len
<
1
)
{
throw
new
RuntimeException
(
"length params is error, must be greater than 0, this params is ["
+
len
+
"]"
);
throw
YzgError
.
getRuntimeException
(
"015"
,
len
);
}
}
StringBuffer
sb
=
new
StringBuffer
();
StringBuffer
sb
=
new
StringBuffer
();
...
@@ -82,11 +83,11 @@ public final class RandomHelper {
...
@@ -82,11 +83,11 @@ public final class RandomHelper {
*/
*/
public
static
String
generateRandomCode
(
String
charset
,
int
len
)
{
public
static
String
generateRandomCode
(
String
charset
,
int
len
)
{
if
(
null
==
charset
||
""
.
equals
(
charset
))
{
if
(
null
==
charset
||
""
.
equals
(
charset
))
{
throw
new
RuntimeException
(
"random code, essential data is empty.
"
);
throw
YzgError
.
getRuntimeException
(
"016
"
);
}
}
if
(
len
<
1
)
{
if
(
len
<
1
)
{
throw
new
RuntimeException
(
"length params is error, must be greater than 0, this params is ["
+
len
+
"]"
);
throw
YzgError
.
getRuntimeException
(
"015"
,
len
);
}
}
StringBuffer
sb
=
new
StringBuffer
();
StringBuffer
sb
=
new
StringBuffer
();
...
...
yzg-util-base/src/main/java/com/yanzuoguang/util/helper/RunHelper.java
View file @
aff8222f
package
com
.
yanzuoguang
.
util
.
helper
;
package
com
.
yanzuoguang
.
util
.
helper
;
import
com.yanzuoguang.util.YzgError
;
import
com.yanzuoguang.util.thread.ThreadHelper
;
import
com.yanzuoguang.util.thread.ThreadHelper
;
/**
/**
...
@@ -50,7 +51,7 @@ public class RunHelper {
...
@@ -50,7 +51,7 @@ public class RunHelper {
}
}
}
}
if
(
ex
!=
null
)
{
if
(
ex
!=
null
)
{
throw
new
RuntimeException
(
tag
+
ex
.
getMessage
(),
ex
);
throw
YzgError
.
getRuntimeException
(
ex
,
"000"
,
tag
+
ex
.
getMessage
()
);
}
}
}
}
}
}
yzg-util-base/src/main/java/com/yanzuoguang/util/helper/StringHelper.java
View file @
aff8222f
package
com
.
yanzuoguang
.
util
.
helper
;
package
com
.
yanzuoguang
.
util
.
helper
;
import
com.yanzuoguang.util.YzgError
;
import
com.yanzuoguang.util.base.ObjectHelper
;
import
com.yanzuoguang.util.base.ObjectHelper
;
import
com.yanzuoguang.util.exception.ExceptionHelper
;
import
com.yanzuoguang.util.exception.ExceptionHelper
;
...
@@ -959,7 +960,7 @@ public class StringHelper {
...
@@ -959,7 +960,7 @@ public class StringHelper {
*/
*/
public
static
String
getNewMD5Id
(
Date
date
,
Object
...
froms
)
{
public
static
String
getNewMD5Id
(
Date
date
,
Object
...
froms
)
{
if
(
date
==
null
)
{
if
(
date
==
null
)
{
throw
new
RuntimeException
(
"生成时间搓 MD5 ID 时,时间不能为空
"
);
throw
YzgError
.
getRuntimeException
(
"017
"
);
}
}
String
tag
=
getNewIdTag
(
date
.
getTime
());
String
tag
=
getNewIdTag
(
date
.
getTime
());
String
id
=
md51
(
getId
(
froms
));
String
id
=
md51
(
getId
(
froms
));
...
...
yzg-util-base/src/main/java/com/yanzuoguang/util/helper/ZipHelper.java
View file @
aff8222f
...
@@ -2,6 +2,8 @@ package com.yanzuoguang.util.helper;
...
@@ -2,6 +2,8 @@ package com.yanzuoguang.util.helper;
import
com.yanzuoguang.util.YzgError
;
import
java.io.BufferedInputStream
;
import
java.io.BufferedInputStream
;
import
java.io.BufferedOutputStream
;
import
java.io.BufferedOutputStream
;
import
java.io.File
;
import
java.io.File
;
...
@@ -38,10 +40,10 @@ public class ZipHelper {
...
@@ -38,10 +40,10 @@ public class ZipHelper {
*/
*/
public
static
void
zipDirectory
(
File
dirFile
,
File
zipFile
,
boolean
isDir
)
throws
IOException
{
public
static
void
zipDirectory
(
File
dirFile
,
File
zipFile
,
boolean
isDir
)
throws
IOException
{
if
(
dirFile
==
null
)
{
if
(
dirFile
==
null
)
{
throw
new
RuntimeException
(
"压缩时文件夹对象不能为空。
"
);
throw
YzgError
.
getRuntimeException
(
"018
"
);
}
}
if
(!
dirFile
.
isDirectory
())
{
if
(!
dirFile
.
isDirectory
())
{
throw
new
RuntimeException
(
"["
+
dirFile
.
getName
()
+
"]不是一个文件夹,或者不存在。"
);
throw
YzgError
.
getRuntimeException
(
"019"
,
dirFile
.
getName
()
);
}
}
if
(
zipFile
==
null
)
{
if
(
zipFile
==
null
)
{
zipFile
=
new
File
(
dirFile
.
getAbsolutePath
()
+
".zip"
);
zipFile
=
new
File
(
dirFile
.
getAbsolutePath
()
+
".zip"
);
...
@@ -157,7 +159,7 @@ public class ZipHelper {
...
@@ -157,7 +159,7 @@ public class ZipHelper {
if
(
flag
)
{
if
(
flag
)
{
tempFile
.
renameTo
(
zipTo
);
tempFile
.
renameTo
(
zipTo
);
}
else
{
}
else
{
throw
new
RuntimeException
(
"删除文件失败
"
);
throw
YzgError
.
getRuntimeException
(
"020
"
);
}
}
}
}
}
}
...
@@ -215,7 +217,7 @@ public class ZipHelper {
...
@@ -215,7 +217,7 @@ public class ZipHelper {
*/
*/
private
static
void
zipFile
(
String
sourcePath
,
File
file
,
ZipOutputStream
zipOutStream
,
BufferedOutputStream
bufferOutStream
)
throws
IOException
{
private
static
void
zipFile
(
String
sourcePath
,
File
file
,
ZipOutputStream
zipOutStream
,
BufferedOutputStream
bufferOutStream
)
throws
IOException
{
if
(!
file
.
exists
())
{
if
(!
file
.
exists
())
{
throw
new
RuntimeException
(
"文件"
+
file
.
getAbsolutePath
()
+
"不存在"
);
throw
YzgError
.
getRuntimeException
(
"021"
,
file
.
getAbsolutePath
()
);
}
}
// 创建压缩文件实体
// 创建压缩文件实体
ZipEntry
entry
=
new
ZipEntry
(
sourcePath
+
file
.
getName
());
ZipEntry
entry
=
new
ZipEntry
(
sourcePath
+
file
.
getName
());
...
...
yzg-util-base/src/main/java/com/yanzuoguang/util/thread/RunnableList.java
View file @
aff8222f
package
com
.
yanzuoguang
.
util
.
thread
;
package
com
.
yanzuoguang
.
util
.
thread
;
import
com.yanzuoguang.util.YzgError
;
/**
/**
* 根据指定的线程数量, 执行多个Runnable对象
* 根据指定的线程数量, 执行多个Runnable对象
*
*
...
@@ -27,7 +29,7 @@ public class RunnableList extends AbstractThreadList<Runnable> {
...
@@ -27,7 +29,7 @@ public class RunnableList extends AbstractThreadList<Runnable> {
}
catch
(
RuntimeException
ex
)
{
}
catch
(
RuntimeException
ex
)
{
throw
ex
;
throw
ex
;
}
catch
(
Exception
ex
)
{
}
catch
(
Exception
ex
)
{
throw
new
RuntimeException
(
ex
.
getMessage
(),
ex
);
throw
YzgError
.
getRuntimeException
(
"000"
,
ex
.
getMessage
()
);
}
}
}
}
}
}
yzg-util-base/src/main/java/com/yanzuoguang/util/thread/RunnableListAutoItem.java
View file @
aff8222f
package
com
.
yanzuoguang
.
util
.
thread
;
package
com
.
yanzuoguang
.
util
.
thread
;
import
com.yanzuoguang.util.YzgError
;
import
com.yanzuoguang.util.helper.StringHelper
;
import
com.yanzuoguang.util.helper.StringHelper
;
import
java.util.Date
;
import
java.util.Date
;
...
@@ -157,7 +158,7 @@ public class RunnableListAutoItem implements Comparable<RunnableListAutoItem> {
...
@@ -157,7 +158,7 @@ public class RunnableListAutoItem implements Comparable<RunnableListAutoItem> {
if
(
ex
instanceof
RuntimeException
)
{
if
(
ex
instanceof
RuntimeException
)
{
throw
(
RuntimeException
)
ex
;
throw
(
RuntimeException
)
ex
;
}
else
{
}
else
{
throw
new
RuntimeException
(
ex
.
getMessage
(),
ex
);
throw
YzgError
.
getRuntimeException
(
"000"
,
ex
.
getMessage
()
);
}
}
}
}
...
...
yzg-util-base/src/test/java/helper/TestSfzUtil.java
View file @
aff8222f
package
helper
;
package
helper
;
import
base.DemoVo
;
import
base.DemoVo
;
import
com.yanzuoguang.util.YzgError
;
import
com.yanzuoguang.util.helper.*
;
import
com.yanzuoguang.util.helper.*
;
import
com.yanzuoguang.util.vo.ResponseResult
;
import
com.yanzuoguang.util.vo.ResponseResult
;
import
helper.vo.ResponseDataMainResult
;
import
helper.vo.ResponseDataMainResult
;
...
@@ -35,7 +36,7 @@ public class TestSfzUtil {
...
@@ -35,7 +36,7 @@ public class TestSfzUtil {
File
f
=
new
File
(
"src/test/java/helper/"
+
from
);
File
f
=
new
File
(
"src/test/java/helper/"
+
from
);
if
(!
f
.
exists
())
{
if
(!
f
.
exists
())
{
System
.
out
.
println
(
f
.
getAbsoluteFile
());
System
.
out
.
println
(
f
.
getAbsoluteFile
());
throw
new
RuntimeException
(
"视频文件不存在
"
);
throw
YzgError
.
getRuntimeException
(
"005
"
);
}
}
return
f
.
getAbsolutePath
();
return
f
.
getAbsolutePath
();
}
}
...
...
yzg-util-base/src/test/java/helper/TestTypeHelper.java
View file @
aff8222f
package
helper
;
package
helper
;
import
base.DemoVo
;
import
base.DemoVo
;
import
com.yanzuoguang.util.YzgError
;
import
com.yanzuoguang.util.helper.TypeHelper
;
import
com.yanzuoguang.util.helper.TypeHelper
;
import
com.yanzuoguang.util.vo.ResponseResult
;
import
com.yanzuoguang.util.vo.ResponseResult
;
import
helper.vo.ResponseDataMainResult
;
import
helper.vo.ResponseDataMainResult
;
...
@@ -23,7 +24,7 @@ public class TestTypeHelper {
...
@@ -23,7 +24,7 @@ public class TestTypeHelper {
TypeHelper
.
printSuperClass
(
returnType
);
TypeHelper
.
printSuperClass
(
returnType
);
boolean
isSub
=
TypeHelper
.
isSubType
(
returnType
,
ResponseResult
.
class
);
boolean
isSub
=
TypeHelper
.
isSubType
(
returnType
,
ResponseResult
.
class
);
if
(!
isSub
)
{
if
(!
isSub
)
{
throw
new
RuntimeException
(
"泛型继承检测错误
"
);
throw
YzgError
.
getRuntimeException
(
"004
"
);
}
}
}
}
}
}
yzg-util-base/src/test/java/thread/TestRunnableListAuto.java
View file @
aff8222f
package
thread
;
package
thread
;
import
com.yanzuoguang.util.YzgError
;
import
com.yanzuoguang.util.exception.CodeException
;
import
com.yanzuoguang.util.exception.CodeException
;
import
com.yanzuoguang.util.thread.RunnableListAuto
;
import
com.yanzuoguang.util.thread.RunnableListAuto
;
import
com.yanzuoguang.util.thread.ThreadHelper
;
import
com.yanzuoguang.util.thread.ThreadHelper
;
...
@@ -27,7 +28,7 @@ public class TestRunnableListAuto {
...
@@ -27,7 +28,7 @@ public class TestRunnableListAuto {
public
void
test
()
{
public
void
test
()
{
try
{
try
{
runTest
(
true
);
runTest
(
true
);
throw
new
RuntimeException
(
"没有抛出异常
"
);
throw
YzgError
.
getRuntimeException
(
"022
"
);
}
catch
(
Exception
ex
)
{
}
catch
(
Exception
ex
)
{
// Log.error(TestRunnableListAuto.class, ex);
// Log.error(TestRunnableListAuto.class, ex);
}
}
...
...
yzg-util-cloud/src/main/java/com/yanzuoguang/cloud/aop/WebAspectUtil.java
View file @
aff8222f
package
com
.
yanzuoguang
.
cloud
.
aop
;
package
com
.
yanzuoguang
.
cloud
.
aop
;
import
com.yanzuoguang.util.YzgError
;
import
org.springframework.web.context.request.RequestContextHolder
;
import
org.springframework.web.context.request.RequestContextHolder
;
import
org.springframework.web.context.request.ServletRequestAttributes
;
import
org.springframework.web.context.request.ServletRequestAttributes
;
...
@@ -19,7 +20,7 @@ public class WebAspectUtil {
...
@@ -19,7 +20,7 @@ public class WebAspectUtil {
public
static
HttpServletRequest
getRequest
()
{
public
static
HttpServletRequest
getRequest
()
{
ServletRequestAttributes
attributes
=
(
ServletRequestAttributes
)
RequestContextHolder
.
getRequestAttributes
();
ServletRequestAttributes
attributes
=
(
ServletRequestAttributes
)
RequestContextHolder
.
getRequestAttributes
();
if
(
attributes
==
null
)
{
if
(
attributes
==
null
)
{
throw
new
RuntimeException
(
"监视错误
"
);
throw
YzgError
.
getRuntimeException
(
"023
"
);
}
}
return
attributes
.
getRequest
();
return
attributes
.
getRequest
();
}
}
...
...
yzg-util-cloud/src/main/java/com/yanzuoguang/cloud/excel/ExcelHttp.java
View file @
aff8222f
...
@@ -3,6 +3,7 @@ package com.yanzuoguang.cloud.excel;
...
@@ -3,6 +3,7 @@ package com.yanzuoguang.cloud.excel;
import
com.yanzuoguang.cloud.helper.HttpFileHelper
;
import
com.yanzuoguang.cloud.helper.HttpFileHelper
;
import
com.yanzuoguang.excel.*
;
import
com.yanzuoguang.excel.*
;
import
com.yanzuoguang.util.YzgError
;
import
com.yanzuoguang.util.helper.FileHelper
;
import
com.yanzuoguang.util.helper.FileHelper
;
import
com.yanzuoguang.util.helper.JsonHelper
;
import
com.yanzuoguang.util.helper.JsonHelper
;
import
com.yanzuoguang.util.helper.StringHelper
;
import
com.yanzuoguang.util.helper.StringHelper
;
...
@@ -103,7 +104,7 @@ public class ExcelHttp<T extends Object> extends ExcelConsole<T> {
...
@@ -103,7 +104,7 @@ public class ExcelHttp<T extends Object> extends ExcelConsole<T> {
public
static
<
T
extends
Object
,
M
extends
Object
>
void
export
(
ExportBase
<
T
>
req
,
HttpServletResponse
response
,
ExcelDao
<
T
,
M
>
excelDao
)
{
public
static
<
T
extends
Object
,
M
extends
Object
>
void
export
(
ExportBase
<
T
>
req
,
HttpServletResponse
response
,
ExcelDao
<
T
,
M
>
excelDao
)
{
ExportData
config
=
req
.
getConfig
();
ExportData
config
=
req
.
getConfig
();
if
(
config
==
null
)
{
if
(
config
==
null
)
{
throw
new
RuntimeException
(
"导出时请传入配置信息
"
);
throw
YzgError
.
getRuntimeException
(
"024
"
);
}
}
if
(
StringHelper
.
isEmpty
(
config
.
getServerPath
()))
{
if
(
StringHelper
.
isEmpty
(
config
.
getServerPath
()))
{
config
.
setServerPath
(
"/home/cache/"
);
config
.
setServerPath
(
"/home/cache/"
);
...
@@ -136,7 +137,7 @@ public class ExcelHttp<T extends Object> extends ExcelConsole<T> {
...
@@ -136,7 +137,7 @@ public class ExcelHttp<T extends Object> extends ExcelConsole<T> {
}
catch
(
IOException
e
)
{
}
catch
(
IOException
e
)
{
isDown
=
true
;
isDown
=
true
;
e
.
printStackTrace
();
e
.
printStackTrace
();
throw
new
RuntimeException
(
"下载失败"
,
e
);
throw
YzgError
.
getRuntimeException
(
e
,
"045"
);
}
finally
{
}
finally
{
if
(
isDown
)
{
if
(
isDown
)
{
// 删除生成的临时文件
// 删除生成的临时文件
...
...
yzg-util-db/src/main/java/com/yanzuoguang/dao/cond/SqlCondBase.java
View file @
aff8222f
...
@@ -3,6 +3,7 @@ package com.yanzuoguang.dao.cond;
...
@@ -3,6 +3,7 @@ package com.yanzuoguang.dao.cond;
import
com.yanzuoguang.dao.DaoConst
;
import
com.yanzuoguang.dao.DaoConst
;
import
com.yanzuoguang.dao.impl.SqlData
;
import
com.yanzuoguang.dao.impl.SqlData
;
import
com.yanzuoguang.dao.impl.SqlDataField
;
import
com.yanzuoguang.dao.impl.SqlDataField
;
import
com.yanzuoguang.util.YzgError
;
import
com.yanzuoguang.util.base.ObjectHelper
;
import
com.yanzuoguang.util.base.ObjectHelper
;
import
com.yanzuoguang.util.helper.StringHelper
;
import
com.yanzuoguang.util.helper.StringHelper
;
...
@@ -82,7 +83,7 @@ public abstract class SqlCondBase<T extends SqlCondBase> implements SqlCond<T> {
...
@@ -82,7 +83,7 @@ public abstract class SqlCondBase<T extends SqlCondBase> implements SqlCond<T> {
@Override
@Override
public
String
getSql
(
String
sql
,
SqlData
sqlData
,
SqlDataField
sqlDataField
,
Object
model
,
Map
<
String
,
List
<
String
>>
codeMap
)
{
public
String
getSql
(
String
sql
,
SqlData
sqlData
,
SqlDataField
sqlDataField
,
Object
model
,
Map
<
String
,
List
<
String
>>
codeMap
)
{
if
(
sqlDataField
.
getCond
()
!=
this
)
{
if
(
sqlDataField
.
getCond
()
!=
this
)
{
throw
new
RuntimeException
(
"不能处理非本条件的字段
"
);
throw
YzgError
.
getRuntimeException
(
"025
"
);
}
}
if
(
debugRunnable
!=
null
)
{
if
(
debugRunnable
!=
null
)
{
// 用于断点调试的支持
// 用于断点调试的支持
...
@@ -101,7 +102,7 @@ public abstract class SqlCondBase<T extends SqlCondBase> implements SqlCond<T> {
...
@@ -101,7 +102,7 @@ public abstract class SqlCondBase<T extends SqlCondBase> implements SqlCond<T> {
String
fieldName
=
this
.
fields
.
isEmpty
()
?
StringHelper
.
EMPTY
:
this
.
fields
.
get
(
0
);
String
fieldName
=
this
.
fields
.
isEmpty
()
?
StringHelper
.
EMPTY
:
this
.
fields
.
get
(
0
);
// 判断代码片段是否合法
// 判断代码片段是否合法
if
(
sqlDataField
.
getCodes
().
size
()
%
2
==
1
)
{
if
(
sqlDataField
.
getCodes
().
size
()
%
2
==
1
)
{
throw
new
RuntimeException
(
"代码片段"
+
this
.
getClass
().
getSimpleName
()
+
":"
+
sqlData
.
getName
()
+
":"
+
fieldName
+
"为单数"
);
throw
YzgError
.
getRuntimeException
(
"026"
,
this
.
getClass
().
getSimpleName
(),
sqlData
.
getName
(),
fieldName
);
}
}
// 处理代码片段
// 处理代码片段
for
(
int
i
=
0
;
i
<
sqlDataField
.
getCodes
().
size
();
i
=
i
+
DaoConst
.
CODE_UNIT
)
{
for
(
int
i
=
0
;
i
<
sqlDataField
.
getCodes
().
size
();
i
=
i
+
DaoConst
.
CODE_UNIT
)
{
...
...
yzg-util-db/src/main/java/com/yanzuoguang/dao/cond/SqlCondItem.java
View file @
aff8222f
...
@@ -3,6 +3,7 @@ package com.yanzuoguang.dao.cond;
...
@@ -3,6 +3,7 @@ package com.yanzuoguang.dao.cond;
import
com.yanzuoguang.dao.DaoConst
;
import
com.yanzuoguang.dao.DaoConst
;
import
com.yanzuoguang.dao.impl.SqlData
;
import
com.yanzuoguang.dao.impl.SqlData
;
import
com.yanzuoguang.dao.impl.SqlDataField
;
import
com.yanzuoguang.dao.impl.SqlDataField
;
import
com.yanzuoguang.util.YzgError
;
import
com.yanzuoguang.util.base.ObjectHelper
;
import
com.yanzuoguang.util.base.ObjectHelper
;
import
com.yanzuoguang.util.helper.ArrayHelper
;
import
com.yanzuoguang.util.helper.ArrayHelper
;
import
com.yanzuoguang.util.helper.StringHelper
;
import
com.yanzuoguang.util.helper.StringHelper
;
...
@@ -60,7 +61,7 @@ public class SqlCondItem extends SqlCondBase<SqlCondItem> {
...
@@ -60,7 +61,7 @@ public class SqlCondItem extends SqlCondBase<SqlCondItem> {
@Override
@Override
public
String
getSql
(
String
sql
,
SqlData
sqlData
,
SqlDataField
sqlDataField
,
Object
model
,
Map
<
String
,
List
<
String
>>
codeMap
)
{
public
String
getSql
(
String
sql
,
SqlData
sqlData
,
SqlDataField
sqlDataField
,
Object
model
,
Map
<
String
,
List
<
String
>>
codeMap
)
{
if
(
sqlDataField
.
getCond
()
!=
this
)
{
if
(
sqlDataField
.
getCond
()
!=
this
)
{
throw
new
RuntimeException
(
"不能处理非本条件的字段
"
);
throw
YzgError
.
getRuntimeException
(
"025
"
);
}
}
if
(
debugRunnable
!=
null
)
{
if
(
debugRunnable
!=
null
)
{
// 用于断点调试的支持
// 用于断点调试的支持
...
@@ -69,13 +70,13 @@ public class SqlCondItem extends SqlCondBase<SqlCondItem> {
...
@@ -69,13 +70,13 @@ public class SqlCondItem extends SqlCondBase<SqlCondItem> {
int
condType
=
getCondType
(
model
,
sqlDataField
);
int
condType
=
getCondType
(
model
,
sqlDataField
);
switch
(
condType
)
{
switch
(
condType
)
{
case
COND_TYPE_CONST_ONLY_PARA:
{
case
COND_TYPE_CONST_ONLY_PARA:
{
throw
new
RuntimeException
(
"SqlCondItem不支持输入参数,必须带代码片段
"
);
throw
YzgError
.
getRuntimeException
(
"027
"
);
}
}
case
COND_TYPE_CODE_COND:
{
case
COND_TYPE_CODE_COND:
{
String
fieldName
=
this
.
fields
.
isEmpty
()
?
StringHelper
.
EMPTY
:
this
.
fields
.
get
(
0
);
String
fieldName
=
this
.
fields
.
isEmpty
()
?
StringHelper
.
EMPTY
:
this
.
fields
.
get
(
0
);
// 判断代码片段是否合法
// 判断代码片段是否合法
if
(
sqlDataField
.
getCodes
().
size
()
%
2
==
1
)
{
if
(
sqlDataField
.
getCodes
().
size
()
%
2
==
1
)
{
throw
new
RuntimeException
(
"代码片段"
+
this
.
getClass
().
getSimpleName
()
+
":"
+
sqlData
.
getName
()
+
":"
+
fieldName
+
"为单数"
);
throw
YzgError
.
getRuntimeException
(
"026"
,
this
.
getClass
().
getSimpleName
(),
sqlData
.
getName
(),
fieldName
);
}
}
Object
value
=
ObjectHelper
.
get
(
model
,
fieldName
);
Object
value
=
ObjectHelper
.
get
(
model
,
fieldName
);
List
list
=
ArrayHelper
.
getList
(
value
);
List
list
=
ArrayHelper
.
getList
(
value
);
...
...
yzg-util-db/src/main/java/com/yanzuoguang/dao/impl/BaseDaoImpl.java
View file @
aff8222f
...
@@ -4,6 +4,7 @@ import com.yanzuoguang.dao.BaseDao;
...
@@ -4,6 +4,7 @@ import com.yanzuoguang.dao.BaseDao;
import
com.yanzuoguang.dao.DaoConst
;
import
com.yanzuoguang.dao.DaoConst
;
import
com.yanzuoguang.dao.QueryPara
;
import
com.yanzuoguang.dao.QueryPara
;
import
com.yanzuoguang.db.DbExecute
;
import
com.yanzuoguang.db.DbExecute
;
import
com.yanzuoguang.util.YzgError
;
import
com.yanzuoguang.util.base.ObjectHelper
;
import
com.yanzuoguang.util.base.ObjectHelper
;
import
com.yanzuoguang.util.exception.CodeException
;
import
com.yanzuoguang.util.exception.CodeException
;
import
com.yanzuoguang.util.helper.DateHelper
;
import
com.yanzuoguang.util.helper.DateHelper
;
...
@@ -50,7 +51,7 @@ public abstract class BaseDaoImpl extends BaseDaoSql implements BaseDao {
...
@@ -50,7 +51,7 @@ public abstract class BaseDaoImpl extends BaseDaoSql implements BaseDao {
*/
*/
protected
String
getKey
()
{
protected
String
getKey
()
{
if
(
this
.
table
==
null
)
{
if
(
this
.
table
==
null
)
{
throw
new
RuntimeException
(
"类"
+
this
.
getClass
().
getName
()
+
"未发现表结构
"
);
throw
YzgError
.
getRuntimeException
(
"002
"
);
}
}
return
this
.
table
.
getTable
().
getKeyName
();
return
this
.
table
.
getTable
().
getKeyName
();
}
}
...
@@ -170,13 +171,13 @@ public abstract class BaseDaoImpl extends BaseDaoSql implements BaseDao {
...
@@ -170,13 +171,13 @@ public abstract class BaseDaoImpl extends BaseDaoSql implements BaseDao {
public
String
update
(
Object
model
)
{
public
String
update
(
Object
model
)
{
String
keyString
=
this
.
getKeyString
(
model
);
String
keyString
=
this
.
getKeyString
(
model
);
if
(
StringHelper
.
isEmpty
(
keyString
))
{
if
(
StringHelper
.
isEmpty
(
keyString
))
{
throw
new
RuntimeException
(
"表"
+
this
.
table
.
getTable
().
getName
()
+
"主键值为空时不能更新"
);
throw
YzgError
.
getRuntimeException
(
"029"
,
this
.
table
.
getTable
().
getName
()
);
}
}
this
.
check
(
DaoConst
.
OPERATOR_TYPE_UPDATE
,
keyString
,
model
);
this
.
check
(
DaoConst
.
OPERATOR_TYPE_UPDATE
,
keyString
,
model
);
SqlData
sqlData
=
this
.
getSql
(
DaoConst
.
UPDATE
);
SqlData
sqlData
=
this
.
getSql
(
DaoConst
.
UPDATE
);
int
ret
=
updateSql
(
sqlData
,
model
);
int
ret
=
updateSql
(
sqlData
,
model
);
if
(
ret
==
0
)
{
if
(
ret
==
0
)
{
throw
new
RuntimeException
(
"修改失败,请确认是否被其他人修改,版本号传入是否正确
"
);
throw
YzgError
.
getRuntimeException
(
"030
"
);
}
}
String
retVal
=
ret
>
0
?
keyString
:
""
;
String
retVal
=
ret
>
0
?
keyString
:
""
;
return
retVal
;
return
retVal
;
...
@@ -865,7 +866,7 @@ public abstract class BaseDaoImpl extends BaseDaoSql implements BaseDao {
...
@@ -865,7 +866,7 @@ public abstract class BaseDaoImpl extends BaseDaoSql implements BaseDao {
try
{
try
{
from
=
cls
.
newInstance
();
from
=
cls
.
newInstance
();
}
catch
(
Exception
ex
)
{
}
catch
(
Exception
ex
)
{
throw
new
RuntimeException
(
"创建对象"
+
cls
.
getName
()
+
"出错"
,
ex
);
throw
YzgError
.
getRuntimeException
(
ex
,
"046"
,
cls
.
getName
()
);
}
}
ObjectHelper
.
writeWithFrom
(
from
,
request
);
ObjectHelper
.
writeWithFrom
(
from
,
request
);
return
this
.
create
(
from
);
return
this
.
create
(
from
);
...
...
yzg-util-db/src/main/java/com/yanzuoguang/dao/impl/BaseDaoSql.java
View file @
aff8222f
...
@@ -792,7 +792,7 @@ public abstract class BaseDaoSql {
...
@@ -792,7 +792,7 @@ public abstract class BaseDaoSql {
sb
.
append
(
"AVG"
);
sb
.
append
(
"AVG"
);
break
;
break
;
default
:
default
:
throw
new
RuntimeException
(
"统计类型["
+
from
.
getGroupType
()
+
"]不支持"
);
throw
YzgError
.
getRuntimeException
(
"031"
,
from
.
getGroupType
()
);
}
}
sb
.
append
(
"( CASE WHEN "
);
sb
.
append
(
"( CASE WHEN "
);
sb
.
append
(
from
.
getCaseField
());
sb
.
append
(
from
.
getCaseField
());
...
...
yzg-util-db/src/main/java/com/yanzuoguang/dao/impl/TableSqlCache.java
View file @
aff8222f
package
com
.
yanzuoguang
.
dao
.
impl
;
package
com
.
yanzuoguang
.
dao
.
impl
;
import
com.yanzuoguang.dao.DaoConst
;
import
com.yanzuoguang.dao.DaoConst
;
import
com.yanzuoguang.util.YzgError
;
import
com.yanzuoguang.util.cache.MemoryCache
;
import
com.yanzuoguang.util.cache.MemoryCache
;
import
com.yanzuoguang.util.helper.StringHelper
;
import
com.yanzuoguang.util.helper.StringHelper
;
...
@@ -169,7 +170,7 @@ public class TableSqlCache {
...
@@ -169,7 +170,7 @@ public class TableSqlCache {
for
(
String
item
:
tableWhereField
.
getFields
())
{
for
(
String
item
:
tableWhereField
.
getFields
())
{
String
name
=
item
.
toLowerCase
();
String
name
=
item
.
toLowerCase
();
if
(!
sqlFieldHas
.
containsKey
(
name
))
{
if
(!
sqlFieldHas
.
containsKey
(
name
))
{
throw
new
RuntimeException
(
"SQL语句"
+
item
+
"不存在纬度"
+
item
);
throw
YzgError
.
getRuntimeException
(
"032"
,
item
,
item
);
}
}
sqlFieldWhere
.
put
(
name
,
true
);
sqlFieldWhere
.
put
(
name
,
true
);
}
}
...
@@ -195,7 +196,7 @@ public class TableSqlCache {
...
@@ -195,7 +196,7 @@ public class TableSqlCache {
}
else
if
(!
StringHelper
.
isEmpty
(
this
.
table
.
getMD5KeyName
()))
{
}
else
if
(!
StringHelper
.
isEmpty
(
this
.
table
.
getMD5KeyName
()))
{
addString
(
map
,
"{Key}"
,
this
.
table
.
getMD5KeyName
());
addString
(
map
,
"{Key}"
,
this
.
table
.
getMD5KeyName
());
}
else
{
}
else
{
throw
new
RuntimeException
(
"表中未包含MD5字段
"
);
throw
YzgError
.
getRuntimeException
(
"033
"
);
}
}
String
lowerKey
=
this
.
table
.
getKeyName
().
toLowerCase
();
String
lowerKey
=
this
.
table
.
getKeyName
().
toLowerCase
();
...
...
yzg-util-db/src/main/java/com/yanzuoguang/excel/ExcelConsole.java
View file @
aff8222f
package
com
.
yanzuoguang
.
excel
;
package
com
.
yanzuoguang
.
excel
;
import
com.yanzuoguang.db.impl.DbRow
;
import
com.yanzuoguang.db.impl.DbRow
;
import
com.yanzuoguang.util.YzgError
;
import
com.yanzuoguang.util.helper.CheckerHelper
;
import
com.yanzuoguang.util.helper.CheckerHelper
;
import
com.yanzuoguang.util.helper.FileHelper
;
import
com.yanzuoguang.util.helper.FileHelper
;
import
com.yanzuoguang.util.helper.StringHelper
;
import
com.yanzuoguang.util.helper.StringHelper
;
...
@@ -167,7 +168,7 @@ public class ExcelConsole<T extends Object> implements DbRow<T> {
...
@@ -167,7 +168,7 @@ public class ExcelConsole<T extends Object> implements DbRow<T> {
*/
*/
protected
void
initExcel
(
TableHead
head
)
{
protected
void
initExcel
(
TableHead
head
)
{
if
(
this
.
workbook
!=
null
)
{
if
(
this
.
workbook
!=
null
)
{
throw
new
RuntimeException
(
"Excel已初始化
"
);
throw
YzgError
.
getRuntimeException
(
"034
"
);
}
}
// 创建合并对象数据检测
// 创建合并对象数据检测
mergerGroup
=
new
HashMap
<>();
mergerGroup
=
new
HashMap
<>();
...
@@ -393,21 +394,21 @@ public class ExcelConsole<T extends Object> implements DbRow<T> {
...
@@ -393,21 +394,21 @@ public class ExcelConsole<T extends Object> implements DbRow<T> {
out
.
flush
();
out
.
flush
();
}
catch
(
IOException
e
)
{
}
catch
(
IOException
e
)
{
e
.
printStackTrace
();
e
.
printStackTrace
();
throw
new
RuntimeException
(
"保存失败
"
);
throw
YzgError
.
getRuntimeException
(
"035
"
);
}
finally
{
}
finally
{
out
.
close
();
out
.
close
();
}
}
// 判断临时文件是否存在
// 判断临时文件是否存在
File
file
=
new
File
(
fileNameTemp
);
File
file
=
new
File
(
fileNameTemp
);
if
(!
file
.
exists
())
{
if
(!
file
.
exists
())
{
throw
new
RuntimeException
(
"保存路径"
+
this
.
getFileName
()
+
"失败"
);
throw
YzgError
.
getRuntimeException
(
"036"
,
this
.
getFileName
()
);
}
}
// 重命名成正式文件
// 重命名成正式文件
String
fileName
=
this
.
getFileName
();
String
fileName
=
this
.
getFileName
();
file
.
renameTo
(
new
File
(
fileName
));
file
.
renameTo
(
new
File
(
fileName
));
}
catch
(
IOException
e
)
{
}
catch
(
IOException
e
)
{
e
.
printStackTrace
();
e
.
printStackTrace
();
throw
new
RuntimeException
(
"保存失败
"
);
throw
YzgError
.
getRuntimeException
(
"035
"
);
}
}
return
this
;
return
this
;
}
}
...
@@ -428,7 +429,7 @@ public class ExcelConsole<T extends Object> implements DbRow<T> {
...
@@ -428,7 +429,7 @@ public class ExcelConsole<T extends Object> implements DbRow<T> {
File
file
=
new
File
(
this
.
getFileName
());
File
file
=
new
File
(
this
.
getFileName
());
if
(
file
.
exists
())
{
if
(
file
.
exists
())
{
if
(!
file
.
delete
())
{
if
(!
file
.
delete
())
{
throw
new
RuntimeException
(
"文件删除失败
"
);
throw
YzgError
.
getRuntimeException
(
"012
"
);
}
}
}
}
return
this
;
return
this
;
...
...
yzg-util-db/src/main/java/com/yanzuoguang/service/impl/BaseServiceImpl.java
View file @
aff8222f
...
@@ -2,6 +2,7 @@ package com.yanzuoguang.service.impl;
...
@@ -2,6 +2,7 @@ package com.yanzuoguang.service.impl;
import
com.yanzuoguang.dao.BaseDao
;
import
com.yanzuoguang.dao.BaseDao
;
import
com.yanzuoguang.service.BaseService
;
import
com.yanzuoguang.service.BaseService
;
import
com.yanzuoguang.util.YzgError
;
import
com.yanzuoguang.util.helper.StringHelper
;
import
com.yanzuoguang.util.helper.StringHelper
;
import
java.util.ArrayList
;
import
java.util.ArrayList
;
...
@@ -185,7 +186,7 @@ public abstract class BaseServiceImpl<T> implements BaseService<T> {
...
@@ -185,7 +186,7 @@ public abstract class BaseServiceImpl<T> implements BaseService<T> {
*/
*/
private
void
check
(
String
opTag
,
String
serviceTag
,
Object
id
)
{
private
void
check
(
String
opTag
,
String
serviceTag
,
Object
id
)
{
if
(
StringHelper
.
isEmpty
(
id
))
{
if
(
StringHelper
.
isEmpty
(
id
))
{
throw
new
RuntimeException
(
opTag
+
serviceTag
+
"失败,该数据可能已被修改"
);
throw
YzgError
.
getRuntimeException
(
"037"
,
opTag
+
serviceTag
);
}
}
}
}
...
...
yzg-util-db/src/main/java/com/yanzuoguang/token/TokenHelper.java
View file @
aff8222f
...
@@ -71,7 +71,7 @@ public class TokenHelper {
...
@@ -71,7 +71,7 @@ public class TokenHelper {
* @param <T> 数据类型
* @param <T> 数据类型
* @return 缓存的数据
* @return 缓存的数据
*/
*/
public
static
<
T
extends
Object
>
T
get
(
boolean
checkFlag
,
Class
<
T
>
cls
)
{
public
static
<
T
extends
Object
>
T
get
(
boolean
checkFlag
,
Class
<
T
>
cls
)
{
String
id
=
getCurrentId
();
String
id
=
getCurrentId
();
TokenData
tokenData
=
cache
.
get
(
id
);
TokenData
tokenData
=
cache
.
get
(
id
);
if
(
tokenData
==
null
)
{
if
(
tokenData
==
null
)
{
...
...
yzg-util-image-extend/src/main/java/com/yanzuoguang/util/MediaHelperExtend.java
View file @
aff8222f
...
@@ -221,7 +221,7 @@ public class MediaHelperExtend extends ImageHelper {
...
@@ -221,7 +221,7 @@ public class MediaHelperExtend extends ImageHelper {
String
format
,
String
codeC
,
String
format
,
String
codeC
,
float
size
,
int
bitRate
)
throws
EncoderException
{
float
size
,
int
bitRate
)
throws
EncoderException
{
if
(
size
>
1
)
{
if
(
size
>
1
)
{
throw
new
RuntimeException
(
"size请在0~1之间
"
);
throw
YzgError
.
getRuntimeException
(
"038
"
);
}
}
File
source
=
new
File
(
fromFile
);
File
source
=
new
File
(
fromFile
);
File
target
=
new
File
(
toFile
);
File
target
=
new
File
(
toFile
);
...
...
yzg-util-image-extend/src/test/java/helper/TestMediaHelper.java
View file @
aff8222f
package
helper
;
package
helper
;
import
com.yanzuoguang.util.MediaHelperExtend
;
import
com.yanzuoguang.util.MediaHelperExtend
;
import
com.yanzuoguang.util.YzgError
;
import
com.yanzuoguang.util.helper.FileHelper
;
import
com.yanzuoguang.util.helper.FileHelper
;
import
com.yanzuoguang.util.thread.RunnableListAuto
;
import
com.yanzuoguang.util.thread.RunnableListAuto
;
import
it.sauronsoftware.jave.Encoder
;
import
it.sauronsoftware.jave.Encoder
;
...
@@ -75,7 +76,7 @@ public class TestMediaHelper {
...
@@ -75,7 +76,7 @@ public class TestMediaHelper {
File
f
=
new
File
(
"src/test/java/helper/"
+
file
);
File
f
=
new
File
(
"src/test/java/helper/"
+
file
);
if
(!
f
.
exists
())
{
if
(!
f
.
exists
())
{
System
.
out
.
println
(
f
.
getAbsoluteFile
());
System
.
out
.
println
(
f
.
getAbsoluteFile
());
throw
new
RuntimeException
(
"视频文件不存在
"
);
throw
YzgError
.
getRuntimeException
(
"005
"
);
}
}
return
f
.
getAbsolutePath
();
return
f
.
getAbsolutePath
();
}
}
...
...
yzg-util-image/src/main/java/com/yanzuoguang/util/MediaHelper.java
View file @
aff8222f
...
@@ -140,7 +140,7 @@ public class MediaHelper extends ImageHelper {
...
@@ -140,7 +140,7 @@ public class MediaHelper extends ImageHelper {
// 源文件判断
// 源文件判断
File
source
=
new
File
(
fromFile
);
File
source
=
new
File
(
fromFile
);
if
(!
source
.
exists
())
{
if
(!
source
.
exists
())
{
throw
new
RuntimeException
(
"视频转码压缩时文件不存在:"
+
fromFile
);
throw
YzgError
.
getRuntimeException
(
"039"
,
fromFile
);
}
}
File
target
=
new
File
(
toFile
);
File
target
=
new
File
(
toFile
);
if
(!
target
.
getParentFile
().
exists
())
{
if
(!
target
.
getParentFile
().
exists
())
{
...
@@ -163,7 +163,7 @@ public class MediaHelper extends ImageHelper {
...
@@ -163,7 +163,7 @@ public class MediaHelper extends ImageHelper {
String
suffix
=
toFile
.
substring
(
toFile
.
lastIndexOf
(
"."
)
+
1
);
String
suffix
=
toFile
.
substring
(
toFile
.
lastIndexOf
(
"."
)
+
1
);
getGrabberFFmpegImage
(
fromFile
,
toFile
,
suffix
,
FRAME_INDEX
);
getGrabberFFmpegImage
(
fromFile
,
toFile
,
suffix
,
FRAME_INDEX
);
}
catch
(
IOException
ex
)
{
}
catch
(
IOException
ex
)
{
throw
new
RuntimeException
(
"获取视频所缩类图失败:"
+
ex
.
getMessage
(),
ex
);
throw
YzgError
.
getRuntimeException
(
ex
,
"048"
,
ex
.
getMessage
()
);
}
}
}
}
...
...
yzg-util-image/src/main/java/com/yanzuoguang/util/MediaParameter.java
View file @
aff8222f
...
@@ -249,13 +249,13 @@ public class MediaParameter extends BaseVo {
...
@@ -249,13 +249,13 @@ public class MediaParameter extends BaseVo {
this
.
videoSizeZip
=
StringHelper
.
getFirst
(
this
.
videoSizeZip
,
1
f
);
this
.
videoSizeZip
=
StringHelper
.
getFirst
(
this
.
videoSizeZip
,
1
f
);
this
.
videoBitRateZip
=
StringHelper
.
getFirst
(
this
.
videoBitRateZip
,
1
f
);
this
.
videoBitRateZip
=
StringHelper
.
getFirst
(
this
.
videoBitRateZip
,
1
f
);
if
(
audioBitRateZip
>
1
)
{
if
(
audioBitRateZip
>
1
)
{
throw
new
RuntimeException
(
"audioBitRateZip请在0~1之间
"
);
throw
YzgError
.
getRuntimeException
(
"040
"
);
}
}
if
(
videoSizeZip
>
1
)
{
if
(
videoSizeZip
>
1
)
{
throw
new
RuntimeException
(
"videoSizeZip请在0~1之间
"
);
throw
YzgError
.
getRuntimeException
(
"041
"
);
}
}
if
(
videoBitRateZip
>
1
)
{
if
(
videoBitRateZip
>
1
)
{
throw
new
RuntimeException
(
"videoBitRateZip请在0~1之间
"
);
throw
YzgError
.
getRuntimeException
(
"042
"
);
}
}
}
}
...
...
yzg-util-image/src/test/java/helper/TestMediaHelper.java
View file @
aff8222f
...
@@ -19,7 +19,7 @@ public class TestMediaHelper {
...
@@ -19,7 +19,7 @@ public class TestMediaHelper {
File
f
=
new
File
(
"src/test/java/helper/"
+
file
);
File
f
=
new
File
(
"src/test/java/helper/"
+
file
);
if
(!
f
.
exists
())
{
if
(!
f
.
exists
())
{
System
.
out
.
println
(
f
.
getAbsoluteFile
());
System
.
out
.
println
(
f
.
getAbsoluteFile
());
throw
new
RuntimeException
(
"视频文件不存在
"
);
throw
YzgError
.
getRuntimeException
(
"005
"
);
}
}
return
f
.
getAbsolutePath
();
return
f
.
getAbsolutePath
();
}
}
...
...
yzg-util-print/src/main/java/com/yanzuoguang/util/PrinterHelper.java
View file @
aff8222f
...
@@ -67,7 +67,7 @@ public class PrinterHelper {
...
@@ -67,7 +67,7 @@ public class PrinterHelper {
try
{
try
{
pager
=
JsonHelper
.
deserialize
(
from
.
getPager
(),
PrinterPagerData
.
class
);
pager
=
JsonHelper
.
deserialize
(
from
.
getPager
(),
PrinterPagerData
.
class
);
}
catch
(
Exception
ex
)
{
}
catch
(
Exception
ex
)
{
throw
new
RuntimeException
(
"不能识别模板"
,
ex
);
throw
YzgError
.
getRuntimeException
(
ex
,
"047"
);
}
}
// 设置偏移量
// 设置偏移量
pager
.
setMarginTop
(
pager
.
getMarginTop
()
+
top
);
pager
.
setMarginTop
(
pager
.
getMarginTop
()
+
top
);
...
...
yzg-util-print/src/main/java/com/yanzuoguang/util/printer/format/FormatCenter.java
View file @
aff8222f
package
com
.
yanzuoguang
.
util
.
printer
.
format
;
package
com
.
yanzuoguang
.
util
.
printer
.
format
;
import
com.yanzuoguang.util.YzgError
;
import
com.yanzuoguang.util.helper.StringHelper
;
import
com.yanzuoguang.util.helper.StringHelper
;
import
java.util.HashMap
;
import
java.util.HashMap
;
...
@@ -52,7 +53,7 @@ public class FormatCenter {
...
@@ -52,7 +53,7 @@ public class FormatCenter {
private
String
format
(
String
command
,
String
formatValue
)
{
private
String
format
(
String
command
,
String
formatValue
)
{
this
.
initDefault
();
this
.
initDefault
();
if
(
StringHelper
.
isEmpty
(
command
))
{
if
(
StringHelper
.
isEmpty
(
command
))
{
throw
new
RuntimeException
(
"你需要格式化的字符串格式为空
"
);
throw
YzgError
.
getRuntimeException
(
"043
"
);
}
}
String
[]
commands
=
command
.
split
(
":"
);
String
[]
commands
=
command
.
split
(
":"
);
String
name
=
commands
[
0
];
String
name
=
commands
[
0
];
...
@@ -62,7 +63,7 @@ public class FormatCenter {
...
@@ -62,7 +63,7 @@ public class FormatCenter {
}
}
FormatHandle
formatHandle
=
cache
.
get
(
name
);
FormatHandle
formatHandle
=
cache
.
get
(
name
);
if
(
formatHandle
==
null
)
{
if
(
formatHandle
==
null
)
{
throw
new
RuntimeException
(
"需要格式化的字符串不支持
"
);
throw
YzgError
.
getRuntimeException
(
"028
"
);
}
}
return
formatHandle
.
getFormat
(
name
,
format
,
formatValue
);
return
formatHandle
.
getFormat
(
name
,
format
,
formatValue
);
}
}
...
...
yzg-util-print/src/test/java/helper/TestPrinterHelper.java
View file @
aff8222f
...
@@ -72,7 +72,7 @@ public class TestPrinterHelper {
...
@@ -72,7 +72,7 @@ public class TestPrinterHelper {
File
f
=
new
File
(
"src/test/java/helper/"
+
from
);
File
f
=
new
File
(
"src/test/java/helper/"
+
from
);
if
(!
f
.
exists
())
{
if
(!
f
.
exists
())
{
System
.
out
.
println
(
f
.
getAbsoluteFile
());
System
.
out
.
println
(
f
.
getAbsoluteFile
());
throw
new
RuntimeException
(
"视频文件不存在
"
);
throw
YzgError
.
getRuntimeException
(
"005
"
);
}
}
return
f
.
getAbsolutePath
();
return
f
.
getAbsolutePath
();
}
}
...
...
Write
Preview
Markdown
is supported
0%
Try again
or
attach a new file
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment