Skip to content
Projects
Groups
Snippets
Help
This project
Loading...
Sign in / Register
Toggle navigation
G
gic-cloud
Overview
Overview
Details
Activity
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
data-hook
gic-cloud
Commits
dee84d1f
Commit
dee84d1f
authored
Nov 04, 2021
by
陶光胜
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
取数平台调整
parent
dd99e4e6
Show whitespace changes
Inline
Side-by-side
Showing
2 changed files
with
9 additions
and
9 deletions
+9
-9
CsvResultSetHelper.java
...ic/cloud/data/hook/service/entity/CsvResultSetHelper.java
+8
-8
FreeQueryServiceImpl.java
...ic/cloud/data/hook/service/impl/FreeQueryServiceImpl.java
+1
-1
No files found.
gic-cloud-data-hook-service/src/main/java/com/gic/cloud/data/hook/service/entity/CsvResultSetHelper.java
View file @
dee84d1f
...
@@ -120,7 +120,7 @@ public class CsvResultSetHelper implements ResultSetHelper {
...
@@ -120,7 +120,7 @@ public class CsvResultSetHelper implements ResultSetHelper {
int
columnCount
=
resultSet
.
getMetaData
().
getColumnCount
();
int
columnCount
=
resultSet
.
getMetaData
().
getColumnCount
();
if
(
columnCount
>
0
)
{
if
(
columnCount
>
0
)
{
for
(
int
i
=
0
;
i
<
columnCount
;
i
++)
{
for
(
int
i
=
0
;
i
<
columnCount
;
i
++)
{
String
columnName
=
resultSet
.
getMetaData
().
getColumn
Label
(
i
+
1
);
String
columnName
=
resultSet
.
getMetaData
().
getColumn
Name
(
i
+
1
);
// 数据处理判断
// 数据处理判断
boolean
doDesensi
=
false
;
// 是否进行脱敏
boolean
doDesensi
=
false
;
// 是否进行脱敏
boolean
doDecrypt
=
false
;
// 是否进行解密
boolean
doDecrypt
=
false
;
// 是否进行解密
...
@@ -154,12 +154,12 @@ public class CsvResultSetHelper implements ResultSetHelper {
...
@@ -154,12 +154,12 @@ public class CsvResultSetHelper implements ResultSetHelper {
if
(
allFields
!=
null
&&
isName
(
columnName
)){
if
(
allFields
!=
null
&&
isName
(
columnName
)){
result
.
add
(
DecryptUtils
.
dataSecurityProcessUserName
(
DecryptUtils
.
decrypt
(
resultSet
.
getString
(
columnName
))));
result
.
add
(
DecryptUtils
.
dataSecurityProcessUserName
(
DecryptUtils
.
decrypt
(
resultSet
.
getString
(
columnName
))));
}
else
if
(
allFields
==
null
&&
FilterFieldUtils
.
FILETERS_USER_NAME
.
contains
(
columnName
))
{
}
else
if
(
allFields
==
null
&&
FilterFieldUtils
.
FILETERS_USER_NAME
.
contains
(
columnName
))
{
result
.
add
(
DecryptUtils
.
dataSecurityProcessUserName
(
resultSet
.
getString
(
columnName
)));
result
.
add
(
DecryptUtils
.
dataSecurityProcessUserName
(
resultSet
.
getString
(
i
+
1
)));
}
else
{
}
else
{
result
.
add
(
"******"
);
result
.
add
(
"******"
);
if
(
needDecryptByEnt
&&
isPhoneNumber
(
columnName
)){
if
(
needDecryptByEnt
&&
isPhoneNumber
(
columnName
)){
//导出数据中需要增加加密列,先解密再加密
//导出数据中需要增加加密列,先解密再加密
String
value
=
DecryptUtils
.
getInstance
().
decrypt
(
resultSet
.
getString
(
columnName
));
String
value
=
DecryptUtils
.
getInstance
().
decrypt
(
resultSet
.
getString
(
i
+
1
));
if
(
org
.
apache
.
commons
.
lang3
.
StringUtils
.
isNotBlank
(
value
)){
if
(
org
.
apache
.
commons
.
lang3
.
StringUtils
.
isNotBlank
(
value
)){
byte
[]
bytes
=
rsa
.
encrypt
(
StrUtil
.
bytes
(
value
,
CharsetUtil
.
UTF_8
),
KeyType
.
PublicKey
);
byte
[]
bytes
=
rsa
.
encrypt
(
StrUtil
.
bytes
(
value
,
CharsetUtil
.
UTF_8
),
KeyType
.
PublicKey
);
String
encode
=
Base64
.
encode
(
bytes
);
String
encode
=
Base64
.
encode
(
bytes
);
...
@@ -171,7 +171,7 @@ public class CsvResultSetHelper implements ResultSetHelper {
...
@@ -171,7 +171,7 @@ public class CsvResultSetHelper implements ResultSetHelper {
}
}
}
else
if
(
doDecrypt
)
{
// 如果需要解密处理
}
else
if
(
doDecrypt
)
{
// 如果需要解密处理
//System.out.println("CSV 解密字段名 " + columnName);
//System.out.println("CSV 解密字段名 " + columnName);
String
tmpResult
=
resultSet
.
getString
(
columnName
);
String
tmpResult
=
resultSet
.
getString
(
i
+
1
);
if
(
tmpResult
!=
null
&&
tmpResult
.
length
()
>
0
)
{
if
(
tmpResult
!=
null
&&
tmpResult
.
length
()
>
0
)
{
//tmpResult = DecryptUtils.getInstance().decrypt(tmpResult);
//tmpResult = DecryptUtils.getInstance().decrypt(tmpResult);
tmpResult
=
DecryptUtils
.
getInstance
().
decrypt
(
tmpResult
);
tmpResult
=
DecryptUtils
.
getInstance
().
decrypt
(
tmpResult
);
...
@@ -181,17 +181,17 @@ public class CsvResultSetHelper implements ResultSetHelper {
...
@@ -181,17 +181,17 @@ public class CsvResultSetHelper implements ResultSetHelper {
int
columnType
=
resultSet
.
getMetaData
().
getColumnType
(
i
+
1
);
int
columnType
=
resultSet
.
getMetaData
().
getColumnType
(
i
+
1
);
switch
(
columnType
)
{
switch
(
columnType
)
{
case
Types
.
TIMESTAMP
:
case
Types
.
TIMESTAMP
:
result
.
add
(
resultSet
.
getTimestamp
(
columnName
)
!=
null
?
datetimeFormatter
.
format
(
resultSet
.
getTimestamp
(
columnName
))
:
""
);
result
.
add
(
resultSet
.
getTimestamp
(
i
+
1
)
!=
null
?
datetimeFormatter
.
format
(
resultSet
.
getTimestamp
(
i
+
1
))
:
""
);
break
;
break
;
case
Types
.
DATE
:
case
Types
.
DATE
:
//result[i] = resultSet.getTimestamp(columnName) != null ? dateFormatter.format(resultSet.getTimestamp(columnName)) : "";
//result[i] = resultSet.getTimestamp(columnName) != null ? dateFormatter.format(resultSet.getTimestamp(columnName)) : "";
result
.
add
(
resultSet
.
getDate
(
columnName
)
!=
null
?
dateFormatter
.
format
(
resultSet
.
getDate
(
columnName
))
:
""
);
result
.
add
(
resultSet
.
getDate
(
i
+
1
)
!=
null
?
dateFormatter
.
format
(
resultSet
.
getDate
(
i
+
1
))
:
""
);
break
;
break
;
case
Types
.
TIME
:
case
Types
.
TIME
:
result
.
add
(
resultSet
.
getTimestamp
(
columnName
)
!=
null
?
timeFormatter
.
format
(
resultSet
.
getTimestamp
(
columnName
))
:
""
);
result
.
add
(
resultSet
.
getTimestamp
(
i
+
1
)
!=
null
?
timeFormatter
.
format
(
resultSet
.
getTimestamp
(
i
+
1
))
:
""
);
break
;
break
;
default
:
default
:
result
.
add
(
String
.
valueOf
(
resultSet
.
getObject
(
columnName
)));
result
.
add
(
String
.
valueOf
(
resultSet
.
getObject
(
i
+
1
)));
break
;
break
;
}
// SWITCH OVER
}
// SWITCH OVER
}
// IF ELSE OVER
}
// IF ELSE OVER
...
...
gic-cloud-data-hook-service/src/main/java/com/gic/cloud/data/hook/service/impl/FreeQueryServiceImpl.java
View file @
dee84d1f
...
@@ -438,7 +438,7 @@ public class FreeQueryServiceImpl implements IFreeQueryService {
...
@@ -438,7 +438,7 @@ public class FreeQueryServiceImpl implements IFreeQueryService {
Row
row
=
sheet
.
createRow
(
0
);
Row
row
=
sheet
.
createRow
(
0
);
Cell
cell
;
Cell
cell
;
for
(
int
j
=
0
;
j
<
rs
.
getMetaData
().
getColumnCount
();
++
j
)
{
// 遍历创建表头
for
(
int
j
=
0
;
j
<
rs
.
getMetaData
().
getColumnCount
();
++
j
)
{
// 遍历创建表头
String
colName
=
rs
.
getMetaData
().
getColumn
Label
(
j
+
1
);
String
colName
=
rs
.
getMetaData
().
getColumn
Name
(
j
+
1
);
cell
=
row
.
createCell
(
j
);
cell
=
row
.
createCell
(
j
);
cell
.
setCellValue
(
colName
);
cell
.
setCellValue
(
colName
);
}
}
...
...
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