Skip to content
Projects
Groups
Snippets
Help
This project
Loading...
Sign in / Register
Toggle navigation
A
amos-boot-biz
Project
Project
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
项目统一框架
amos-boot-biz
Commits
744cc4b2
Commit
744cc4b2
authored
Jul 10, 2025
by
刘林
Browse files
Options
Browse Files
Download
Plain Diff
Merge remote-tracking branch 'origin/develop_tzs_register' into develop_tzs_register
parents
36eab2c3
2b27ec2f
Hide whitespace changes
Inline
Side-by-side
Showing
3 changed files
with
32 additions
and
13 deletions
+32
-13
EsBaseEnterpriseInfo.java
...s/boot/module/common/api/entity/EsBaseEnterpriseInfo.java
+7
-1
EsUserInfo.java
...eejoin/amos/boot/module/common/api/entity/EsUserInfo.java
+10
-4
ComprehensiveStatisticalAnalysisServiceImpl.java
...ice/impl/ComprehensiveStatisticalAnalysisServiceImpl.java
+15
-8
No files found.
amos-boot-system-tzs/amos-boot-module-common/amos-boot-module-common-api/src/main/java/com/yeejoin/amos/boot/module/common/api/entity/EsBaseEnterpriseInfo.java
View file @
744cc4b2
...
@@ -107,11 +107,17 @@ public class EsBaseEnterpriseInfo {
...
@@ -107,11 +107,17 @@ public class EsBaseEnterpriseInfo {
/**
/**
* 涉及设备类型
* 涉及设备类型
code
*/
*/
@Field
(
type
=
FieldType
.
Keyword
)
@Field
(
type
=
FieldType
.
Keyword
)
private
String
equipCategory
;
private
String
equipCategory
;
/**
* 涉及设备类型名称
*/
@Field
(
type
=
FieldType
.
Keyword
)
private
String
equipCategoryName
;
/**
/**
* 公司的orgCode
* 公司的orgCode
...
...
amos-boot-system-tzs/amos-boot-module-common/amos-boot-module-common-api/src/main/java/com/yeejoin/amos/boot/module/common/api/entity/EsUserInfo.java
View file @
744cc4b2
...
@@ -60,7 +60,7 @@ public class EsUserInfo {
...
@@ -60,7 +60,7 @@ public class EsUserInfo {
/**
/**
* 岗位名称-按照new_post显示
* 岗位名称-按照new_post显示
*/
*/
@Field
(
type
=
FieldType
.
Text
)
@Field
(
type
=
FieldType
.
Keyword
)
private
String
postName
;
private
String
postName
;
/**
/**
...
@@ -136,12 +136,18 @@ public class EsUserInfo {
...
@@ -136,12 +136,18 @@ public class EsUserInfo {
private
String
profile
;
private
String
profile
;
/**
/**
* 设备类型
* 设备类型
code
*/
*/
@Field
(
type
=
FieldType
.
Keyword
)
@Field
(
type
=
FieldType
.
Keyword
)
private
String
equipType
;
private
String
equipType
;
/**
/**
* 设备类型名称
*/
@Field
(
type
=
FieldType
.
Keyword
)
private
String
equipTypeName
;
/**
* 职称
* 职称
*/
*/
@Field
(
type
=
FieldType
.
Keyword
)
@Field
(
type
=
FieldType
.
Keyword
)
...
@@ -156,7 +162,7 @@ public class EsUserInfo {
...
@@ -156,7 +162,7 @@ public class EsUserInfo {
/**
/**
* 岗位子类型名称(多个逗号分割)
* 岗位子类型名称(多个逗号分割)
*/
*/
@Field
(
type
=
FieldType
.
Text
)
@Field
(
type
=
FieldType
.
Keyword
)
private
String
subPostName
;
private
String
subPostName
;
/**
/**
...
@@ -168,7 +174,7 @@ public class EsUserInfo {
...
@@ -168,7 +174,7 @@ public class EsUserInfo {
/**
/**
* 管辖机构名称--来源企业表
* 管辖机构名称--来源企业表
*/
*/
@Field
(
type
=
FieldType
.
Text
)
@Field
(
type
=
FieldType
.
Keyword
)
private
String
superviseOrgName
;
private
String
superviseOrgName
;
/**
/**
...
...
amos-boot-system-tzs/amos-boot-module-statistics/amos-boot-module-statistics-biz/src/main/java/com/yeejoin/amos/boot/module/statistcs/biz/service/impl/ComprehensiveStatisticalAnalysisServiceImpl.java
View file @
744cc4b2
...
@@ -380,6 +380,12 @@ public class ComprehensiveStatisticalAnalysisServiceImpl {
...
@@ -380,6 +380,12 @@ public class ComprehensiveStatisticalAnalysisServiceImpl {
String
fuzzyValue
=
String
.
valueOf
(
v
);
String
fuzzyValue
=
String
.
valueOf
(
v
);
BoolQueryBuilder
queryBuilder
=
QueryBuilders
.
boolQuery
();
BoolQueryBuilder
queryBuilder
=
QueryBuilders
.
boolQuery
();
queryBuilder
.
should
(
QueryBuilders
.
wildcardQuery
(
"name"
,
"*"
+
fuzzyValue
+
"*"
));
queryBuilder
.
should
(
QueryBuilders
.
wildcardQuery
(
"name"
,
"*"
+
fuzzyValue
+
"*"
));
queryBuilder
.
should
(
QueryBuilders
.
wildcardQuery
(
"postName"
,
"*"
+
fuzzyValue
+
"*"
));
queryBuilder
.
should
(
QueryBuilders
.
wildcardQuery
(
"subPostName"
,
"*"
+
fuzzyValue
+
"*"
));
queryBuilder
.
should
(
QueryBuilders
.
wildcardQuery
(
"unitName"
,
"*"
+
fuzzyValue
+
"*"
));
queryBuilder
.
should
(
QueryBuilders
.
wildcardQuery
(
"equipCategoryName"
,
"*"
+
fuzzyValue
+
"*"
));
queryBuilder
.
should
(
QueryBuilders
.
wildcardQuery
(
"superviseOrgName"
,
"*"
+
fuzzyValue
+
"*"
));
queryBuilder
.
should
(
QueryBuilders
.
wildcardQuery
(
"address"
,
"*"
+
fuzzyValue
+
"*"
));
queryBuilder
.
minimumShouldMatch
(
1
);
queryBuilder
.
minimumShouldMatch
(
1
);
boolMust
.
must
(
queryBuilder
);
boolMust
.
must
(
queryBuilder
);
}
else
if
(
k
.
equals
(
"unitCategory"
))
{
}
else
if
(
k
.
equals
(
"unitCategory"
))
{
...
@@ -588,6 +594,7 @@ public class ComprehensiveStatisticalAnalysisServiceImpl {
...
@@ -588,6 +594,7 @@ public class ComprehensiveStatisticalAnalysisServiceImpl {
queryBuilder
.
should
(
QueryBuilders
.
wildcardQuery
(
"useUnit.keyword"
,
"*"
+
fuzzyValue
+
"*"
));
queryBuilder
.
should
(
QueryBuilders
.
wildcardQuery
(
"useUnit.keyword"
,
"*"
+
fuzzyValue
+
"*"
));
queryBuilder
.
should
(
QueryBuilders
.
wildcardQuery
(
"address.keyword"
,
"*"
+
fuzzyValue
+
"*"
));
queryBuilder
.
should
(
QueryBuilders
.
wildcardQuery
(
"address.keyword"
,
"*"
+
fuzzyValue
+
"*"
));
queryBuilder
.
should
(
QueryBuilders
.
wildcardQuery
(
"superviseOrgName.keyword"
,
"*"
+
fuzzyValue
+
"*"
));
queryBuilder
.
should
(
QueryBuilders
.
wildcardQuery
(
"superviseOrgName.keyword"
,
"*"
+
fuzzyValue
+
"*"
));
queryBuilder
.
should
(
QueryBuilders
.
wildcardQuery
(
"equipCategoryName.keyword"
,
"*"
+
fuzzyValue
+
"*"
));
queryBuilder
.
should
(
QueryBuilders
.
wildcardQuery
(
"contactUser.keyword"
,
"*"
+
fuzzyValue
+
"*"
));
queryBuilder
.
should
(
QueryBuilders
.
wildcardQuery
(
"contactUser.keyword"
,
"*"
+
fuzzyValue
+
"*"
));
queryBuilder
.
minimumShouldMatch
(
1
);
queryBuilder
.
minimumShouldMatch
(
1
);
boolMust
.
must
(
queryBuilder
);
boolMust
.
must
(
queryBuilder
);
...
@@ -1874,8 +1881,8 @@ public class ComprehensiveStatisticalAnalysisServiceImpl {
...
@@ -1874,8 +1881,8 @@ public class ComprehensiveStatisticalAnalysisServiceImpl {
public
JSONArray
queryRYLX
(
JSONObject
params
)
{
public
JSONArray
queryRYLX
(
JSONObject
params
)
{
JSONArray
result
=
new
JSONArray
();
JSONArray
result
=
new
JSONArray
();
JSONArray
type
=
params
.
containsKey
(
"type"
)
?
JSONObject
.
parseArray
(
JSONObject
.
toJSONString
(
params
.
get
(
"t
ype"
)))
:
new
JSONArray
();
JSONArray
unitType
=
params
.
containsKey
(
"unitType"
)
&&
!
""
.
equals
(
params
.
get
(
"unitType"
))
?
JSONObject
.
parseArray
(
JSONObject
.
toJSONString
(
params
.
get
(
"unitT
ype"
)))
:
new
JSONArray
();
String
subType
=
params
.
containsKey
(
"subType"
)
?
params
.
get
(
"subType
"
).
toString
()
:
""
;
String
newPost
=
params
.
containsKey
(
"newPost"
)
?
params
.
get
(
"newPost
"
).
toString
()
:
""
;
List
<
String
>
typeList
=
new
ArrayList
<>(
Arrays
.
asList
(
List
<
String
>
typeList
=
new
ArrayList
<>(
Arrays
.
asList
(
"QYRYGW"
,
"QYRYGW"
,
...
@@ -1891,21 +1898,21 @@ public class ComprehensiveStatisticalAnalysisServiceImpl {
...
@@ -1891,21 +1898,21 @@ public class ComprehensiveStatisticalAnalysisServiceImpl {
.
in
(
DataDictionary:
:
getType
,
typeList
)
.
in
(
DataDictionary:
:
getType
,
typeList
)
.
list
();
.
list
();
if
(!
""
.
equals
(
subType
))
{
if
(!
""
.
equals
(
newPost
))
{
List
<
DataDictionary
>
childrenrylx
=
dataDictionaryService
.
lambdaQuery
()
List
<
DataDictionary
>
childrenrylx
=
dataDictionaryService
.
lambdaQuery
()
.
in
(
DataDictionary:
:
getParent
,
subType
)
.
in
(
DataDictionary:
:
getParent
,
newPost
)
.
like
(
DataDictionary:
:
getType
,
"QYRYGW"
)
.
like
(
DataDictionary:
:
getType
,
"QYRYGW"
)
.
orderByAsc
(
DataDictionary:
:
getSortNum
)
.
orderByAsc
(
DataDictionary:
:
getSortNum
)
.
list
();
.
list
();
result
=
deployDictionary
(
childrenrylx
);
result
=
deployDictionary
(
childrenrylx
);
}
}
if
(!
ObjectUtils
.
isEmpty
(
type
)
&&
!
t
ype
.
contains
(
"all"
))
{
if
(!
ObjectUtils
.
isEmpty
(
unitType
)
&&
!
unitT
ype
.
contains
(
"all"
))
{
try
{
try
{
ArrayList
<
String
>
postDictCodeList
=
new
ArrayList
<>();
ArrayList
<
String
>
postDictCodeList
=
new
ArrayList
<>();
JsonNode
jsonNode
=
new
ObjectMapper
().
readTree
(
unitTypeLimitUserType
.
getInputStream
());
JsonNode
jsonNode
=
new
ObjectMapper
().
readTree
(
unitTypeLimitUserType
.
getInputStream
());
type
.
forEach
(
unitType
->
{
unitType
.
forEach
(
item
->
{
JsonNode
companyTypeNode
=
jsonNode
.
get
(
unitType
.
toString
());
JsonNode
companyTypeNode
=
jsonNode
.
get
(
item
.
toString
());
if
(
companyTypeNode
!=
null
&&
companyTypeNode
.
isObject
())
{
if
(
companyTypeNode
!=
null
&&
companyTypeNode
.
isObject
())
{
Iterator
<
Map
.
Entry
<
String
,
JsonNode
>>
fields
=
companyTypeNode
.
fields
();
Iterator
<
Map
.
Entry
<
String
,
JsonNode
>>
fields
=
companyTypeNode
.
fields
();
while
(
fields
.
hasNext
())
{
while
(
fields
.
hasNext
())
{
...
@@ -1923,7 +1930,7 @@ public class ComprehensiveStatisticalAnalysisServiceImpl {
...
@@ -1923,7 +1930,7 @@ public class ComprehensiveStatisticalAnalysisServiceImpl {
}
}
}
}
if
(
""
.
equals
(
subType
)
&&
(
ObjectUtils
.
isEmpty
(
type
)
||
t
ype
.
contains
(
"all"
)))
{
if
(
""
.
equals
(
newPost
)
&&
(
ObjectUtils
.
isEmpty
(
unitType
)
||
unitT
ype
.
contains
(
"all"
)))
{
result
=
deployDictionary
(
allPost
);
result
=
deployDictionary
(
allPost
);
}
}
...
...
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