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
8a80f977
Commit
8a80f977
authored
Oct 28, 2021
by
tianbo
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
bug修改
parent
7e3a8fca
Hide whitespace changes
Inline
Side-by-side
Showing
2 changed files
with
20 additions
and
20 deletions
+20
-20
LatentDangerServiceImpl.java
...danger/business/service/impl/LatentDangerServiceImpl.java
+18
-18
application-dev.properties
...atentdanger/src/main/resources/application-dev.properties
+2
-2
No files found.
amos-boot-module/amos-boot-module-biz/amos-boot-module-latentdanger-biz/src/main/java/com/yeejoin/amos/latentdanger/business/service/impl/LatentDangerServiceImpl.java
View file @
8a80f977
...
@@ -69,7 +69,7 @@ import com.yeejoin.amos.latentdanger.common.remote.RemoteWorkFlowService;
...
@@ -69,7 +69,7 @@ import com.yeejoin.amos.latentdanger.common.remote.RemoteWorkFlowService;
import
com.yeejoin.amos.latentdanger.core.async.AsyncTask
;
import
com.yeejoin.amos.latentdanger.core.async.AsyncTask
;
import
com.yeejoin.amos.latentdanger.core.common.request.LatentDangerResultPushSpcRequest
;
import
com.yeejoin.amos.latentdanger.core.common.request.LatentDangerResultPushSpcRequest
;
import
com.yeejoin.amos.latentdanger.core.common.response.DangerListResponse
;
import
com.yeejoin.amos.latentdanger.core.common.response.DangerListResponse
;
import
com.yeejoin.amos.latentdanger.core.util.StringUtil
;
//
import com.yeejoin.amos.latentdanger.core.util.StringUtil;
import
com.yeejoin.amos.latentdanger.dao.entity.LatentDanger
;
import
com.yeejoin.amos.latentdanger.dao.entity.LatentDanger
;
import
com.yeejoin.amos.latentdanger.dao.entity.LatentDangerFlowRecord
;
import
com.yeejoin.amos.latentdanger.dao.entity.LatentDangerFlowRecord
;
import
com.yeejoin.amos.latentdanger.exception.YeeException
;
import
com.yeejoin.amos.latentdanger.exception.YeeException
;
...
@@ -585,7 +585,7 @@ public class LatentDangerServiceImpl extends BaseService<LatentDangerBo, LatentD
...
@@ -585,7 +585,7 @@ public class LatentDangerServiceImpl extends BaseService<LatentDangerBo, LatentD
}
}
// 过滤出隐患权限菜单路径("B_1,B_2.....B_10")
// 过滤出隐患权限菜单路径("B_1,B_2.....B_10")
Object
obj
=
jsonArray
.
stream
().
filter
(
i
->
i
.
toString
().
matches
(
"^B_\\d+"
)).
collect
(
Collectors
.
toList
());
Object
obj
=
jsonArray
.
stream
().
filter
(
i
->
i
.
toString
().
matches
(
"^B_\\d+"
)).
collect
(
Collectors
.
toList
());
if
(
StringUtil
.
isNot
Empty
(
obj
)
&&
((
List
<
String
>)
obj
).
size
()
>
0
)
{
if
(
!
ValidationUtil
.
is
Empty
(
obj
)
&&
((
List
<
String
>)
obj
).
size
()
>
0
)
{
permissions
=
Joiner
.
on
(
","
).
join
((
List
<
String
>)
obj
);
permissions
=
Joiner
.
on
(
","
).
join
((
List
<
String
>)
obj
);
}
}
return
permissions
;
return
permissions
;
...
@@ -746,15 +746,15 @@ public class LatentDangerServiceImpl extends BaseService<LatentDangerBo, LatentD
...
@@ -746,15 +746,15 @@ public class LatentDangerServiceImpl extends BaseService<LatentDangerBo, LatentD
riskVo
.
setBasis
(
basis
);
riskVo
.
setBasis
(
basis
);
riskVo
.
setPointName
(
patrolBo
.
getPointName
());
riskVo
.
setPointName
(
patrolBo
.
getPointName
());
riskVo
.
setPointNo
(
patrolBo
.
getPointNo
());
riskVo
.
setPointNo
(
patrolBo
.
getPointNo
());
riskVo
.
setPointLevel
(
StringUtil
.
isNot
Empty
(
patrolBo
.
getPointLevel
())
?
patrolBo
.
getPointLevel
()
:
""
);
riskVo
.
setPointLevel
(
!
ValidationUtil
.
is
Empty
(
patrolBo
.
getPointLevel
())
?
patrolBo
.
getPointLevel
()
:
""
);
riskVo
.
setPlanName
(
patrolBo
.
getPlanName
());
riskVo
.
setPlanName
(
patrolBo
.
getPlanName
());
riskVo
.
setCheckTime
(
patrolBo
.
getCheckTime
());
riskVo
.
setCheckTime
(
patrolBo
.
getCheckTime
());
AgencyUserModel
checkUser
=
remoteSecurityService
.
getUserById
(
RequestContext
.
getToken
(),
getProduct
(),
RequestContext
.
getAppKey
(),
patrolBo
.
getCheckUserId
());
AgencyUserModel
checkUser
=
remoteSecurityService
.
getUserById
(
RequestContext
.
getToken
(),
getProduct
(),
RequestContext
.
getAppKey
(),
patrolBo
.
getCheckUserId
());
if
(
StringUtil
.
isNot
Empty
(
checkUser
))
{
if
(
!
ValidationUtil
.
is
Empty
(
checkUser
))
{
riskVo
.
setCheckUser
(
checkUser
.
getRealName
());
riskVo
.
setCheckUser
(
checkUser
.
getRealName
());
}
}
// TODO 使用远程调用替换
// TODO 使用远程调用替换
// RiskFactorBo riskFactorBo =
StringUtil.isNot
Empty(patrolBo.getClassifyOriginalId()) ? riskFactorMapper.getById(Long.valueOf(patrolBo.getClassifyOriginalId())) : null;
// RiskFactorBo riskFactorBo =
!ValidationUtil.is
Empty(patrolBo.getClassifyOriginalId()) ? riskFactorMapper.getById(Long.valueOf(patrolBo.getClassifyOriginalId())) : null;
// if (riskFactorBo != null && riskFactorBo.getEquipmentDepartmentId() != null) {
// if (riskFactorBo != null && riskFactorBo.getEquipmentDepartmentId() != null) {
// DepartmentModel department = remoteSecurityService.getDepartmentByDeptId(RequestContext.getToken(), getProduct(), RequestContext.getAppKey(), riskFactorBo.getEquipmentDepartmentId().toString());
// DepartmentModel department = remoteSecurityService.getDepartmentByDeptId(RequestContext.getToken(), getProduct(), RequestContext.getAppKey(), riskFactorBo.getEquipmentDepartmentId().toString());
// if (department != null) {
// if (department != null) {
...
@@ -886,9 +886,9 @@ public class LatentDangerServiceImpl extends BaseService<LatentDangerBo, LatentD
...
@@ -886,9 +886,9 @@ public class LatentDangerServiceImpl extends BaseService<LatentDangerBo, LatentD
}
}
if
(
reviewRecordBo
!=
null
)
{
if
(
reviewRecordBo
!=
null
)
{
AgencyUserModel
reviewUser
=
userMap
.
get
(
reviewRecordBo
.
getExecuteUserId
());
AgencyUserModel
reviewUser
=
userMap
.
get
(
reviewRecordBo
.
getExecuteUserId
());
reviewInfo
.
put
(
"reviewUserName"
,
StringUtil
.
isNot
Empty
(
reviewUser
)
?
reviewUser
.
getRealName
()
:
""
);
reviewInfo
.
put
(
"reviewUserName"
,
!
ValidationUtil
.
is
Empty
(
reviewUser
)
?
reviewUser
.
getRealName
()
:
""
);
reviewInfo
.
put
(
"reviewDate"
,
StringUtil
.
isNot
Empty
(
reviewUser
)
?
reviewRecordBo
.
getUpdateDate
()
:
""
);
reviewInfo
.
put
(
"reviewDate"
,
!
ValidationUtil
.
is
Empty
(
reviewUser
)
?
reviewRecordBo
.
getUpdateDate
()
:
""
);
reviewInfo
.
put
(
"reviewResult"
,
StringUtil
.
isNot
Empty
(
reviewUser
)
?
reviewRecordBo
.
getExecuteResult
()
:
""
);
reviewInfo
.
put
(
"reviewResult"
,
!
ValidationUtil
.
is
Empty
(
reviewUser
)
?
reviewRecordBo
.
getExecuteResult
()
:
""
);
}
}
result
.
put
(
"baseInfo"
,
baseInfo
);
result
.
put
(
"baseInfo"
,
baseInfo
);
result
.
put
(
"dangerInfo"
,
dangerInfo
);
result
.
put
(
"dangerInfo"
,
dangerInfo
);
...
@@ -1346,7 +1346,7 @@ public class LatentDangerServiceImpl extends BaseService<LatentDangerBo, LatentD
...
@@ -1346,7 +1346,7 @@ public class LatentDangerServiceImpl extends BaseService<LatentDangerBo, LatentD
String
userId
,
String
userRealName
,
String
departmentId
,
String
userId
,
String
userRealName
,
String
departmentId
,
String
departmentName
,
DangerExecuteSubmitDto
executeSubmitDto
,
String
departmentName
,
DangerExecuteSubmitDto
executeSubmitDto
,
ReginParams
reginParams
)
{
ReginParams
reginParams
)
{
if
(
StringUtil
.
isNot
Empty
(
param
.
getReformLimitDate
()))
{
if
(
!
ValidationUtil
.
is
Empty
(
param
.
getReformLimitDate
()))
{
param
.
setReformLimitDate
(
param
.
getReformLimitDate
()
+
" 23:59:59"
);
param
.
setReformLimitDate
(
param
.
getReformLimitDate
()
+
" 23:59:59"
);
}
}
LatentDangerExecuteTypeEnum
executeTypeEnum
=
LatentDangerExecuteTypeEnum
.
getByCode
(
param
.
getExecuteType
());
LatentDangerExecuteTypeEnum
executeTypeEnum
=
LatentDangerExecuteTypeEnum
.
getByCode
(
param
.
getExecuteType
());
...
@@ -1357,7 +1357,7 @@ public class LatentDangerServiceImpl extends BaseService<LatentDangerBo, LatentD
...
@@ -1357,7 +1357,7 @@ public class LatentDangerServiceImpl extends BaseService<LatentDangerBo, LatentD
}
}
// 延期治理时,根据用户选择是否需要公司来构造参数调用工作流
// 延期治理时,根据用户选择是否需要公司来构造参数调用工作流
if
(
StringUtil
.
isNot
Empty
(
param
.
getNeedCompanyVerify
())
if
(
!
ValidationUtil
.
is
Empty
(
param
.
getNeedCompanyVerify
())
&&
executeTypeEnum
.
equals
(
LatentDangerExecuteTypeEnum
.
隐患延期治理车间部门审核通过
))
{
&&
executeTypeEnum
.
equals
(
LatentDangerExecuteTypeEnum
.
隐患延期治理车间部门审核通过
))
{
String
requestBody
=
""
;
String
requestBody
=
""
;
if
(
param
.
getNeedCompanyVerify
()
==
0
)
{
// 延期治理申请 不需要公司审核
if
(
param
.
getNeedCompanyVerify
()
==
0
)
{
// 延期治理申请 不需要公司审核
...
@@ -1648,7 +1648,7 @@ public class LatentDangerServiceImpl extends BaseService<LatentDangerBo, LatentD
...
@@ -1648,7 +1648,7 @@ public class LatentDangerServiceImpl extends BaseService<LatentDangerBo, LatentD
// return;
// return;
// }
// }
// LatentDangerPatrolBo patrolBo = latentDangerPatrolMapper.getByDangerId(latentDangerBo.getId());
// LatentDangerPatrolBo patrolBo = latentDangerPatrolMapper.getByDangerId(latentDangerBo.getId());
// if (patrolBo != null &&
StringUtil.isNot
Empty(patrolBo.getPointOriginalId())) {
// if (patrolBo != null &&
!ValidationUtil.is
Empty(patrolBo.getPointOriginalId())) {
// iRiskJudgmentTaskService.freshRiskJudgmentLangerCount(Long.parseLong(patrolBo.getPointOriginalId()));
// iRiskJudgmentTaskService.freshRiskJudgmentLangerCount(Long.parseLong(patrolBo.getPointOriginalId()));
// }
// }
}
}
...
@@ -1738,7 +1738,7 @@ public class LatentDangerServiceImpl extends BaseService<LatentDangerBo, LatentD
...
@@ -1738,7 +1738,7 @@ public class LatentDangerServiceImpl extends BaseService<LatentDangerBo, LatentD
Set
<
String
>
userIdSet
=
Sets
.
newHashSet
();
Set
<
String
>
userIdSet
=
Sets
.
newHashSet
();
result
.
forEach
(
r
->
{
result
.
forEach
(
r
->
{
userIdSet
.
add
((
String
)
r
.
get
(
"executeUserId"
));
userIdSet
.
add
((
String
)
r
.
get
(
"executeUserId"
));
if
(
StringUtil
.
isNot
Empty
(
r
.
get
(
"handleUserIds"
)))
{
if
(
!
ValidationUtil
.
is
Empty
(
r
.
get
(
"handleUserIds"
)))
{
List
<
String
>
handleUserIds
=
Arrays
.
asList
(
r
.
get
(
"handleUserIds"
).
toString
().
split
(
","
));
List
<
String
>
handleUserIds
=
Arrays
.
asList
(
r
.
get
(
"handleUserIds"
).
toString
().
split
(
","
));
userIdSet
.
addAll
(
handleUserIds
);
userIdSet
.
addAll
(
handleUserIds
);
}
}
...
@@ -1746,13 +1746,13 @@ public class LatentDangerServiceImpl extends BaseService<LatentDangerBo, LatentD
...
@@ -1746,13 +1746,13 @@ public class LatentDangerServiceImpl extends BaseService<LatentDangerBo, LatentD
userIdSet
.
removeAll
(
Collections
.
singleton
(
null
));
userIdSet
.
removeAll
(
Collections
.
singleton
(
null
));
List
<
AgencyUserModel
>
userModels
=
remoteSecurityService
.
listUserByUserIds
(
Joiner
.
on
(
","
).
join
(
userIdSet
));
List
<
AgencyUserModel
>
userModels
=
remoteSecurityService
.
listUserByUserIds
(
Joiner
.
on
(
","
).
join
(
userIdSet
));
if
(
StringUtil
.
isNot
Empty
(
userModels
))
{
if
(
!
ValidationUtil
.
is
Empty
(
userModels
))
{
Map
<
String
,
AgencyUserModel
>
userMap
=
Maps
.
uniqueIndex
(
userModels
,
AgencyUserModel:
:
getUserId
);
Map
<
String
,
AgencyUserModel
>
userMap
=
Maps
.
uniqueIndex
(
userModels
,
AgencyUserModel:
:
getUserId
);
result
.
forEach
(
r
->
{
result
.
forEach
(
r
->
{
r
.
put
(
"executeUserName"
,
StringUtil
.
isNot
Empty
(
r
.
get
(
"executeUserId"
))
?
userMap
.
get
(
r
.
get
(
r
.
put
(
"executeUserName"
,
!
ValidationUtil
.
is
Empty
(
r
.
get
(
"executeUserId"
))
?
userMap
.
get
(
r
.
get
(
"executeUserId"
)).
getRealName
()
:
""
);
"executeUserId"
)).
getRealName
()
:
""
);
List
<
String
>
handleUserNames
=
Lists
.
newArrayList
();
List
<
String
>
handleUserNames
=
Lists
.
newArrayList
();
if
(
StringUtil
.
isNot
Empty
(
r
.
get
(
"handleUserIds"
)))
{
if
(
!
ValidationUtil
.
is
Empty
(
r
.
get
(
"handleUserIds"
)))
{
List
<
String
>
handleUserIds
=
Arrays
.
asList
(
r
.
get
(
"handleUserIds"
).
toString
().
split
(
","
));
List
<
String
>
handleUserIds
=
Arrays
.
asList
(
r
.
get
(
"handleUserIds"
).
toString
().
split
(
","
));
handleUserIds
.
forEach
(
id
->
handleUserNames
.
add
(
userMap
.
get
(
id
).
getRealName
()));
handleUserIds
.
forEach
(
id
->
handleUserNames
.
add
(
userMap
.
get
(
id
).
getRealName
()));
}
}
...
@@ -1780,7 +1780,7 @@ public class LatentDangerServiceImpl extends BaseService<LatentDangerBo, LatentD
...
@@ -1780,7 +1780,7 @@ public class LatentDangerServiceImpl extends BaseService<LatentDangerBo, LatentD
List
allTaskList
;
List
allTaskList
;
String
idsStr
=
(
String
)
pageParam
.
get
(
"dangerIds"
);
String
idsStr
=
(
String
)
pageParam
.
get
(
"dangerIds"
);
List
<
String
>
dangerIdList
=
Lists
.
newArrayList
();
List
<
String
>
dangerIdList
=
Lists
.
newArrayList
();
if
(
StringUtil
.
isNot
Empty
(
idsStr
))
{
if
(
!
ValidationUtil
.
is
Empty
(
idsStr
))
{
// 查询指定隐患
// 查询指定隐患
dangerIdList
=
Lists
.
newArrayList
(
idsStr
.
split
(
","
));
dangerIdList
=
Lists
.
newArrayList
(
idsStr
.
split
(
","
));
}
}
...
@@ -1902,7 +1902,7 @@ public class LatentDangerServiceImpl extends BaseService<LatentDangerBo, LatentD
...
@@ -1902,7 +1902,7 @@ public class LatentDangerServiceImpl extends BaseService<LatentDangerBo, LatentD
@Override
@Override
public
List
<
DangerListResponse
>
export
(
PageParam
pageParam
)
{
public
List
<
DangerListResponse
>
export
(
PageParam
pageParam
)
{
String
idsStr
=
(
String
)
pageParam
.
get
(
"dangerIds"
);
String
idsStr
=
(
String
)
pageParam
.
get
(
"dangerIds"
);
if
(
StringUtil
.
isNot
Empty
(
idsStr
))
{
if
(
!
ValidationUtil
.
is
Empty
(
idsStr
))
{
List
<
String
>
dangerIdList
=
Lists
.
newArrayList
(
idsStr
.
split
(
","
));
List
<
String
>
dangerIdList
=
Lists
.
newArrayList
(
idsStr
.
split
(
","
));
pageParam
.
put
(
"dangerIds"
,
dangerIdList
);
pageParam
.
put
(
"dangerIds"
,
dangerIdList
);
}
}
...
@@ -1951,7 +1951,7 @@ public class LatentDangerServiceImpl extends BaseService<LatentDangerBo, LatentD
...
@@ -1951,7 +1951,7 @@ public class LatentDangerServiceImpl extends BaseService<LatentDangerBo, LatentD
DictBo
dangerLevel
=
DictBo
dangerLevel
=
dangerLevelList
.
stream
().
filter
(
item
->
item
.
getDictDataKey
().
equals
(
e
.
getDangerLevel
())).
collect
(
Collectors
.
toList
()).
get
(
0
);
dangerLevelList
.
stream
().
filter
(
item
->
item
.
getDictDataKey
().
equals
(
e
.
getDangerLevel
())).
collect
(
Collectors
.
toList
()).
get
(
0
);
e
.
setDangerLevel
(
dangerLevel
.
getDictDataValue
());
e
.
setDangerLevel
(
dangerLevel
.
getDictDataValue
());
e
.
setReformType
(!
StringUtil
.
isNot
Empty
(
e
.
getReformType
())
?
""
:
e
.
setReformType
(!
!
ValidationUtil
.
is
Empty
(
e
.
getReformType
())
?
""
:
LatentDangerReformTypeEnum
.
getEnumByCode
(
e
.
getReformType
()).
getName
());
LatentDangerReformTypeEnum
.
getEnumByCode
(
e
.
getReformType
()).
getName
());
e
.
setOvertimeState
(
"0"
.
equals
(
e
.
getOvertimeState
())
?
"否"
:
"是"
);
e
.
setOvertimeState
(
"0"
.
equals
(
e
.
getOvertimeState
())
?
"否"
:
"是"
);
e
.
setDangerTypeName
(
LatentDangerTypeEnum
.
getEnumName
(
e
.
getDangerType
()));
e
.
setDangerTypeName
(
LatentDangerTypeEnum
.
getEnumName
(
e
.
getDangerType
()));
...
...
amos-boot-system-latentdanger/src/main/resources/application-dev.properties
View file @
8a80f977
...
@@ -95,4 +95,4 @@ control.fegin.name=JCS-API-CONTROL
...
@@ -95,4 +95,4 @@ control.fegin.name=JCS-API-CONTROL
supervision.feign.name
=
AMOS-SUPERVISION-API
supervision.feign.name
=
AMOS-SUPERVISION-API
jcs.fegin.name
=
JCS
jcs.fegin.name
=
JCS
onSite.confirm.roleName
=
"Person_charge_unit_fire_protection_supervision_inspection"
onSite.confirm.roleName
=
Person_charge_unit_fire_protection_supervision_inspection
\ No newline at end of file
\ No newline at end of file
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