Skip to content
Projects
Groups
Snippets
Help
This project
Loading...
Sign in / Register
Toggle navigation
Y
YeeAmosFireAutoSysRoot
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
station
YeeAmosFireAutoSysRoot
Commits
1833255c
Commit
1833255c
authored
Apr 10, 2024
by
KeYong
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
修改芜湖版本预案
parent
aa932249
Show whitespace changes
Inline
Side-by-side
Showing
11 changed files
with
480 additions
and
15 deletions
+480
-15
PlanTypeEnum.java
.../java/com/yeejoin/amos/fas/common/enums/PlanTypeEnum.java
+24
-0
PlanClassifyTree.java
...ava/com/yeejoin/amos/fas/dao/entity/PlanClassifyTree.java
+4
-0
ContingencyAction.java
...m/yeejoin/amos/fas/business/action/ContingencyAction.java
+18
-1
PlanDetailMapper.java
...eejoin/amos/fas/business/dao/mapper/PlanDetailMapper.java
+2
-0
ContingencyPlanServiceImpl.java
...fas/business/service/impl/ContingencyPlanServiceImpl.java
+9
-4
HandlerMqttMessageImpl.java
...mos/fas/business/service/impl/HandlerMqttMessageImpl.java
+22
-3
PlanStepServiceImpl.java
...n/amos/fas/business/service/impl/PlanStepServiceImpl.java
+17
-0
application-dev.properties
...utoSysStart/src/main/resources/application-dev.properties
+10
-7
PlanDetailMapper.xml
...ysStart/src/main/resources/db/mapper/PlanDetailMapper.xml
+10
-0
plan-step-UHV-gk.json
...utoSysStart/src/main/resources/json/plan-step-UHV-gk.json
+171
-0
plan-step-UHV-zb.json
...utoSysStart/src/main/resources/json/plan-step-UHV-zb.json
+193
-0
No files found.
YeeAmosFireAutoSysCommon/src/main/java/com/yeejoin/amos/fas/common/enums/PlanTypeEnum.java
0 → 100644
View file @
1833255c
package
com
.
yeejoin
.
amos
.
fas
.
common
.
enums
;
import
lombok.AllArgsConstructor
;
import
lombok.Getter
;
/**
* @author keyong
* @title: JudgeSignEnum
* <pre>
* @description: TODO
* </pre>
* @date 2023/3/8 20:54
*/
@Getter
@AllArgsConstructor
public
enum
PlanTypeEnum
{
MAINTRANSFORM
(
"MAINTRANSFORM"
,
"主变"
),
HIGHRESISTANCE
(
"HIGHRESISTANCE"
,
"高抗"
),
NORMAL
(
"NORMAL"
,
"数字预案"
);
private
String
key
;
private
String
describe
;
}
YeeAmosFireAutoSysCommon/src/main/java/com/yeejoin/amos/fas/dao/entity/PlanClassifyTree.java
View file @
1833255c
...
@@ -42,4 +42,7 @@ public class PlanClassifyTree extends BasicEntity {
...
@@ -42,4 +42,7 @@ public class PlanClassifyTree extends BasicEntity {
@Column
(
name
=
"org_code"
)
@Column
(
name
=
"org_code"
)
private
String
orgCode
;
private
String
orgCode
;
@Column
(
name
=
"plan_type"
)
private
String
planType
;
}
}
\ No newline at end of file
YeeAmosFireAutoSysService/src/main/java/com/yeejoin/amos/fas/business/action/ContingencyAction.java
View file @
1833255c
...
@@ -29,6 +29,7 @@ import com.yeejoin.amos.fas.business.util.JSONUtil;
...
@@ -29,6 +29,7 @@ import com.yeejoin.amos.fas.business.util.JSONUtil;
import
com.yeejoin.amos.fas.business.vo.*
;
import
com.yeejoin.amos.fas.business.vo.*
;
import
com.yeejoin.amos.fas.common.enums.ContingencyPlanStatusEnum
;
import
com.yeejoin.amos.fas.common.enums.ContingencyPlanStatusEnum
;
import
com.yeejoin.amos.fas.common.enums.PlanRecordStatusEnum
;
import
com.yeejoin.amos.fas.common.enums.PlanRecordStatusEnum
;
import
com.yeejoin.amos.fas.common.enums.PlanTypeEnum
;
import
com.yeejoin.amos.fas.core.enums.NumberEnum
;
import
com.yeejoin.amos.fas.core.enums.NumberEnum
;
import
com.yeejoin.amos.fas.core.util.DateUtil
;
import
com.yeejoin.amos.fas.core.util.DateUtil
;
import
com.yeejoin.amos.fas.dao.entity.ContingencyPlanInstance
;
import
com.yeejoin.amos.fas.dao.entity.ContingencyPlanInstance
;
...
@@ -159,6 +160,12 @@ public class ContingencyAction implements CustomerAction {
...
@@ -159,6 +160,12 @@ public class ContingencyAction implements CustomerAction {
@Value
(
"classpath:/json/plan-step.json"
)
@Value
(
"classpath:/json/plan-step.json"
)
private
Resource
planStepResource
;
private
Resource
planStepResource
;
@Value
(
"classpath:/json/plan-step-UHV-zb.json"
)
private
Resource
planStepZBResource
;
@Value
(
"classpath:/json/plan-step-UHV-gk.json"
)
private
Resource
planStepGKResource
;
/**
/**
* @param stepCode 当前步骤编号
* @param stepCode 当前步骤编号
* @param stepName 当前步骤名称
* @param stepName 当前步骤名称
...
@@ -804,12 +811,22 @@ public class ContingencyAction implements CustomerAction {
...
@@ -804,12 +811,22 @@ public class ContingencyAction implements CustomerAction {
result
.
add
(
tempmap1
);
result
.
add
(
tempmap1
);
String
instanceId
=
iContingencyInstance
.
getInstanceIdByBatchNOAndCategory
(
"OPERATE"
,
stepName
,
batchNo
);
String
instanceId
=
iContingencyInstance
.
getInstanceIdByBatchNOAndCategory
(
"OPERATE"
,
stepName
,
batchNo
);
String
json
;
String
json
=
null
;
try
{
try
{
if
(
redisTemplate
.
hasKey
(
"planType"
))
{
String
planType
=
redisTemplate
.
boundValueOps
(
"planType"
).
get
(
0
,
-
1
);
if
(
PlanTypeEnum
.
MAINTRANSFORM
.
getKey
().
equalsIgnoreCase
(
planType
))
{
json
=
IOUtils
.
toString
(
planStepZBResource
.
getInputStream
(),
String
.
valueOf
(
StandardCharsets
.
UTF_8
));
}
else
if
(
PlanTypeEnum
.
HIGHRESISTANCE
.
getKey
().
equalsIgnoreCase
(
planType
))
{
json
=
IOUtils
.
toString
(
planStepGKResource
.
getInputStream
(),
String
.
valueOf
(
StandardCharsets
.
UTF_8
));
}
else
{
json
=
IOUtils
.
toString
(
planStepResource
.
getInputStream
(),
String
.
valueOf
(
StandardCharsets
.
UTF_8
));
json
=
IOUtils
.
toString
(
planStepResource
.
getInputStream
(),
String
.
valueOf
(
StandardCharsets
.
UTF_8
));
}
}
}
catch
(
IOException
e
)
{
}
catch
(
IOException
e
)
{
throw
new
RuntimeException
(
"获取预案节点信息失败!"
);
throw
new
RuntimeException
(
"获取预案节点信息失败!"
);
}
}
List
<
PlanStepJsonVO
>
res
=
JSONObject
.
parseArray
(
json
,
PlanStepJsonVO
.
class
);
List
<
PlanStepJsonVO
>
res
=
JSONObject
.
parseArray
(
json
,
PlanStepJsonVO
.
class
);
PlanStepJsonVO
vo
=
res
.
stream
().
filter
(
x
->
x
.
getStepCode
().
equals
(
stepCode
)).
collect
(
Collectors
.
toList
()).
get
(
0
);
PlanStepJsonVO
vo
=
res
.
stream
().
filter
(
x
->
x
.
getStepCode
().
equals
(
stepCode
)).
collect
(
Collectors
.
toList
()).
get
(
0
);
Object
obj
=
equipmentFireEquipmentService
.
automaticExecutePoint
(
vo
.
getIndex
());
Object
obj
=
equipmentFireEquipmentService
.
automaticExecutePoint
(
vo
.
getIndex
());
...
...
YeeAmosFireAutoSysService/src/main/java/com/yeejoin/amos/fas/business/dao/mapper/PlanDetailMapper.java
View file @
1833255c
...
@@ -57,4 +57,6 @@ public interface PlanDetailMapper {
...
@@ -57,4 +57,6 @@ public interface PlanDetailMapper {
String
queryBatchNoByFireEquipmentId
(
@Param
(
"fireEquipmentId"
)
String
fireEquipmentId
);
String
queryBatchNoByFireEquipmentId
(
@Param
(
"fireEquipmentId"
)
String
fireEquipmentId
);
PlanDetailVo
getPlanDetailById
(
@Param
(
"id"
)
String
id
);
}
}
YeeAmosFireAutoSysService/src/main/java/com/yeejoin/amos/fas/business/service/impl/ContingencyPlanServiceImpl.java
View file @
1833255c
...
@@ -13,10 +13,7 @@ import com.yeejoin.amos.fas.business.param.AlarmParam;
...
@@ -13,10 +13,7 @@ import com.yeejoin.amos.fas.business.param.AlarmParam;
import
com.yeejoin.amos.fas.business.service.intfc.*
;
import
com.yeejoin.amos.fas.business.service.intfc.*
;
import
com.yeejoin.amos.fas.business.util.TreeUtil
;
import
com.yeejoin.amos.fas.business.util.TreeUtil
;
import
com.yeejoin.amos.fas.business.vo.*
;
import
com.yeejoin.amos.fas.business.vo.*
;
import
com.yeejoin.amos.fas.common.enums.ContingencyPlanStatusEnum
;
import
com.yeejoin.amos.fas.common.enums.*
;
import
com.yeejoin.amos.fas.common.enums.EquipmentRiskTypeEnum
;
import
com.yeejoin.amos.fas.common.enums.ExecutionTypeEnum
;
import
com.yeejoin.amos.fas.common.enums.PlanRecordStatusEnum
;
import
com.yeejoin.amos.fas.core.enums.NumberEnum
;
import
com.yeejoin.amos.fas.core.enums.NumberEnum
;
import
com.yeejoin.amos.fas.core.enums.ReserveEnum
;
import
com.yeejoin.amos.fas.core.enums.ReserveEnum
;
import
com.yeejoin.amos.fas.core.util.DateUtil
;
import
com.yeejoin.amos.fas.core.util.DateUtil
;
...
@@ -25,6 +22,7 @@ import com.yeejoin.amos.fas.datasync.bo.PlanDetailSyncBo;
...
@@ -25,6 +22,7 @@ import com.yeejoin.amos.fas.datasync.bo.PlanDetailSyncBo;
import
com.yeejoin.amos.fas.datasync.bo.PlanOperationRecordSyncBo
;
import
com.yeejoin.amos.fas.datasync.bo.PlanOperationRecordSyncBo
;
import
com.yeejoin.amos.fas.exception.YeeException
;
import
com.yeejoin.amos.fas.exception.YeeException
;
import
com.yeejoin.amos.feign.privilege.model.RoleModel
;
import
com.yeejoin.amos.feign.privilege.model.RoleModel
;
import
org.apache.commons.io.IOUtils
;
import
org.apache.commons.lang3.StringUtils
;
import
org.apache.commons.lang3.StringUtils
;
import
org.apache.logging.log4j.LogManager
;
import
org.apache.logging.log4j.LogManager
;
import
org.apache.logging.log4j.Logger
;
import
org.apache.logging.log4j.Logger
;
...
@@ -46,6 +44,7 @@ import org.typroject.tyboot.component.emq.EmqxListener;
...
@@ -46,6 +44,7 @@ import org.typroject.tyboot.component.emq.EmqxListener;
import
org.typroject.tyboot.core.foundation.utils.Bean
;
import
org.typroject.tyboot.core.foundation.utils.Bean
;
import
org.typroject.tyboot.core.foundation.utils.ValidationUtil
;
import
org.typroject.tyboot.core.foundation.utils.ValidationUtil
;
import
java.nio.charset.StandardCharsets
;
import
java.util.*
;
import
java.util.*
;
import
java.util.concurrent.atomic.AtomicBoolean
;
import
java.util.concurrent.atomic.AtomicBoolean
;
...
@@ -147,7 +146,13 @@ public class ContingencyPlanServiceImpl implements IContingencyPlanService {
...
@@ -147,7 +146,13 @@ public class ContingencyPlanServiceImpl implements IContingencyPlanService {
logger
.
info
(
"========状态校验==========="
);
logger
.
info
(
"========状态校验==========="
);
ReserveEnum
reserveEnum
=
this
.
runCheck
(
vo
);
ReserveEnum
reserveEnum
=
this
.
runCheck
(
vo
);
result
.
setMessage
(
reserveEnum
.
getText
());
result
.
setMessage
(
reserveEnum
.
getText
());
PlanDetailVo
detailVo
=
planDetailMapper
.
getPlanDetailById
(
vo
.
getPlanId
());
Optional
<
PlanClassifyTree
>
tree
=
classifyTreeDao
.
findById
(
detailVo
.
getClassifyId
());
if
(
tree
.
isPresent
())
{
PlanClassifyTree
entity
=
tree
.
get
();
redisTemplate
.
opsForValue
().
set
(
"planType"
,
entity
.
getPlanType
());
planStepService
.
initPlanStep
();
planStepService
.
initPlanStep
();
}
if
(
ReserveEnum
.
THISRUNNING
.
getStatus
().
equals
(
reserveEnum
.
getStatus
()))
{
if
(
ReserveEnum
.
THISRUNNING
.
getStatus
().
equals
(
reserveEnum
.
getStatus
()))
{
List
<
PlanOperationRecord
>
recordList
=
planOperationRecordDao
.
findByPlanId1
(
Long
.
valueOf
(
vo
.
getPlanId
()));
List
<
PlanOperationRecord
>
recordList
=
planOperationRecordDao
.
findByPlanId1
(
Long
.
valueOf
(
vo
.
getPlanId
()));
result
.
setMessage
(
ReserveEnum
.
THISRUNNING
.
getText
());
result
.
setMessage
(
ReserveEnum
.
THISRUNNING
.
getText
());
...
...
YeeAmosFireAutoSysService/src/main/java/com/yeejoin/amos/fas/business/service/impl/HandlerMqttMessageImpl.java
View file @
1833255c
...
@@ -25,9 +25,11 @@ import com.yeejoin.amos.fas.business.util.RpnUtils;
...
@@ -25,9 +25,11 @@ import com.yeejoin.amos.fas.business.util.RpnUtils;
import
com.yeejoin.amos.fas.business.vo.*
;
import
com.yeejoin.amos.fas.business.vo.*
;
import
com.yeejoin.amos.fas.client.invoke.RsDataQueue
;
import
com.yeejoin.amos.fas.client.invoke.RsDataQueue
;
import
com.yeejoin.amos.fas.common.enums.EquipmentRiskTypeEnum
;
import
com.yeejoin.amos.fas.common.enums.EquipmentRiskTypeEnum
;
import
com.yeejoin.amos.fas.common.enums.PlanTypeEnum
;
import
com.yeejoin.amos.fas.core.util.StringUtil
;
import
com.yeejoin.amos.fas.core.util.StringUtil
;
import
com.yeejoin.amos.fas.dao.entity.*
;
import
com.yeejoin.amos.fas.dao.entity.*
;
import
com.yeejoin.amos.fas.datasync.bo.ContingencyOriginalDataSyncBo
;
import
com.yeejoin.amos.fas.datasync.bo.ContingencyOriginalDataSyncBo
;
import
org.apache.commons.io.IOUtils
;
import
org.apache.commons.lang3.ArrayUtils
;
import
org.apache.commons.lang3.ArrayUtils
;
import
org.slf4j.Logger
;
import
org.slf4j.Logger
;
import
org.slf4j.LoggerFactory
;
import
org.slf4j.LoggerFactory
;
...
@@ -44,6 +46,7 @@ import org.typroject.tyboot.core.foundation.context.RequestContext;
...
@@ -44,6 +46,7 @@ import org.typroject.tyboot.core.foundation.context.RequestContext;
import
java.awt.*
;
import
java.awt.*
;
import
java.math.BigDecimal
;
import
java.math.BigDecimal
;
import
java.nio.charset.StandardCharsets
;
import
java.text.SimpleDateFormat
;
import
java.text.SimpleDateFormat
;
import
java.util.*
;
import
java.util.*
;
import
java.util.List
;
import
java.util.List
;
...
@@ -83,6 +86,12 @@ public class HandlerMqttMessageImpl implements IEquipmentHandlerService {
...
@@ -83,6 +86,12 @@ public class HandlerMqttMessageImpl implements IEquipmentHandlerService {
@Value
(
"${plan.dynamic.execut.topic}"
)
@Value
(
"${plan.dynamic.execut.topic}"
)
private
String
planDynamicExecutTopic
;
private
String
planDynamicExecutTopic
;
@Value
(
"${plan.dynamic.execut.zb.topic}"
)
private
String
planDynamicExecutZBTopic
;
@Value
(
"${plan.dynamic.execut.gk.topic}"
)
private
String
planDynamicExecutGKTopic
;
@Autowired
@Autowired
private
WebMqttComponent
webMqttComponent
;
private
WebMqttComponent
webMqttComponent
;
...
@@ -197,7 +206,7 @@ public class HandlerMqttMessageImpl implements IEquipmentHandlerService {
...
@@ -197,7 +206,7 @@ public class HandlerMqttMessageImpl implements IEquipmentHandlerService {
if
(
"false"
.
equals
(
topicEntity
.
getSimulationDate
())
&&
nameKeys
.
contains
(
typeCode
)
&&
indexStateIsChange
(
equipmentSpecificIndex
))
{
if
(
"false"
.
equals
(
topicEntity
.
getSimulationDate
())
&&
nameKeys
.
contains
(
typeCode
)
&&
indexStateIsChange
(
equipmentSpecificIndex
))
{
log
.
info
(
"指标值没有发生变化: "
+
equipmentSpecificIndex
.
getIotCode
()
+
"-"
+
equipmentSpecificIndex
.
getNameKey
()
+
":"
+
equipmentSpecificIndex
.
getValue
());
log
.
info
(
"指标值没有发生变化: "
+
equipmentSpecificIndex
.
getIotCode
()
+
"-"
+
equipmentSpecificIndex
.
getNameKey
()
+
":"
+
equipmentSpecificIndex
.
getValue
());
// 三维屏指标状态推送,没有绑定模型的设备不需要推送至三维
// 三维屏指标状态推送,没有绑定模型的设备不需要推送至三维
if
(
"true"
.
equals
(
equipmentSpecific
.
getPush3D
()))
{
if
(
"true"
.
equals
(
equipmentSpecific
.
getPush3D
()))
{
equipmentSpecificIndex
.
setId
(
equipmentSpecific
.
getId
());
equipmentSpecificIndex
.
setId
(
equipmentSpecific
.
getId
());
equipmentSpecificIndex
.
setName
(
equipmentSpecific
.
getName
());
equipmentSpecificIndex
.
setName
(
equipmentSpecific
.
getName
());
equipmentSpecificIndex
.
setCode
(
equipmentSpecific
.
getCode
());
equipmentSpecificIndex
.
setCode
(
equipmentSpecific
.
getCode
());
...
@@ -283,7 +292,7 @@ public class HandlerMqttMessageImpl implements IEquipmentHandlerService {
...
@@ -283,7 +292,7 @@ public class HandlerMqttMessageImpl implements IEquipmentHandlerService {
webMqttComponent
.
publish
(
title
,
JSON
.
toJSONString
(
view3dService
.
getEquipStatusList
(
equipmentSpecific
.
getOrgCode
())));
webMqttComponent
.
publish
(
title
,
JSON
.
toJSONString
(
view3dService
.
getEquipStatusList
(
equipmentSpecific
.
getOrgCode
())));
}
}
//根据指标数据处理预案按钮
//根据指标数据处理预案按钮
if
(
planIndex
.
contains
(
nameKey
)
&&
!
ObjectUtils
.
isEmpty
(
equipment
))
{
if
(
planIndex
.
contains
(
nameKey
)
&&
!
ObjectUtils
.
isEmpty
(
equipment
))
{
DeviceRo
deviceRo
=
new
DeviceRo
();
DeviceRo
deviceRo
=
new
DeviceRo
();
deviceRo
.
setEquipmentCode
(
equipment
.
getCode
());
deviceRo
.
setEquipmentCode
(
equipment
.
getCode
());
deviceRo
.
setEquipmentId
(
equipment
.
getId
());
deviceRo
.
setEquipmentId
(
equipment
.
getId
());
...
@@ -298,6 +307,7 @@ public class HandlerMqttMessageImpl implements IEquipmentHandlerService {
...
@@ -298,6 +307,7 @@ public class HandlerMqttMessageImpl implements IEquipmentHandlerService {
/**
/**
* 触发规则(用来)动态执行规则步骤
* 触发规则(用来)动态执行规则步骤
*
* @param equipment
* @param equipment
* @param toke
* @param toke
* @param deviceRo
* @param deviceRo
...
@@ -306,7 +316,16 @@ public class HandlerMqttMessageImpl implements IEquipmentHandlerService {
...
@@ -306,7 +316,16 @@ public class HandlerMqttMessageImpl implements IEquipmentHandlerService {
try
{
try
{
RequestContext
.
setToken
(
toke
.
getToke
());
RequestContext
.
setToken
(
toke
.
getToke
());
RequestContext
.
setProduct
(
toke
.
getProduct
());
RequestContext
.
setProduct
(
toke
.
getProduct
());
ruleTrigger
.
publish
(
deviceRo
,
planDynamicExecutTopic
,
new
String
[]
{});
if
(
redisTemplate
.
hasKey
(
"planType"
))
{
String
planType
=
redisTemplate
.
boundValueOps
(
"planType"
).
get
(
0
,
-
1
);
if
(
PlanTypeEnum
.
MAINTRANSFORM
.
getKey
().
equalsIgnoreCase
(
planType
))
{
ruleTrigger
.
publish
(
deviceRo
,
planDynamicExecutZBTopic
,
new
String
[]{});
}
else
if
(
PlanTypeEnum
.
HIGHRESISTANCE
.
getKey
().
equalsIgnoreCase
(
planType
))
{
ruleTrigger
.
publish
(
deviceRo
,
planDynamicExecutGKTopic
,
new
String
[]{});
}
else
{
ruleTrigger
.
publish
(
deviceRo
,
planDynamicExecutTopic
,
new
String
[]{});
}
}
}
catch
(
Exception
e
)
{
}
catch
(
Exception
e
)
{
e
.
printStackTrace
();
e
.
printStackTrace
();
}
}
...
...
YeeAmosFireAutoSysService/src/main/java/com/yeejoin/amos/fas/business/service/impl/PlanStepServiceImpl.java
View file @
1833255c
package
com
.
yeejoin
.
amos
.
fas
.
business
.
service
.
impl
;
package
com
.
yeejoin
.
amos
.
fas
.
business
.
service
.
impl
;
import
com.alibaba.fastjson.JSON
;
import
com.alibaba.fastjson.JSONObject
;
import
com.alibaba.fastjson.JSONObject
;
import
com.yeejoin.amos.fas.business.service.intfc.IPlanStepService
;
import
com.yeejoin.amos.fas.business.service.intfc.IPlanStepService
;
import
com.yeejoin.amos.fas.business.vo.PlanStepJsonVO
;
import
com.yeejoin.amos.fas.business.vo.PlanStepJsonVO
;
import
com.yeejoin.amos.fas.common.enums.PlanTypeEnum
;
import
org.apache.commons.io.IOUtils
;
import
org.apache.commons.io.IOUtils
;
import
org.apache.commons.lang3.StringUtils
;
import
org.apache.commons.lang3.StringUtils
;
import
org.springframework.beans.factory.annotation.Autowired
;
import
org.springframework.beans.factory.annotation.Autowired
;
...
@@ -15,6 +17,7 @@ import org.springframework.util.CollectionUtils;
...
@@ -15,6 +17,7 @@ import org.springframework.util.CollectionUtils;
import
java.io.IOException
;
import
java.io.IOException
;
import
java.nio.charset.StandardCharsets
;
import
java.nio.charset.StandardCharsets
;
import
java.util.List
;
import
java.util.List
;
import
java.util.Objects
;
import
java.util.stream.Collectors
;
import
java.util.stream.Collectors
;
@Service
@Service
...
@@ -26,6 +29,12 @@ public class PlanStepServiceImpl implements IPlanStepService {
...
@@ -26,6 +29,12 @@ public class PlanStepServiceImpl implements IPlanStepService {
@Value
(
"classpath:/json/plan-step.json"
)
@Value
(
"classpath:/json/plan-step.json"
)
private
Resource
planStepResource
;
private
Resource
planStepResource
;
@Value
(
"classpath:/json/plan-step-UHV-zb.json"
)
private
Resource
planStepZBResource
;
@Value
(
"classpath:/json/plan-step-UHV-gk.json"
)
private
Resource
planStepGKResource
;
@Override
@Override
public
String
getPlanStepRoleCodeByButtonCode
(
String
buttonCode
)
{
public
String
getPlanStepRoleCodeByButtonCode
(
String
buttonCode
)
{
if
(
StringUtils
.
isNotBlank
(
buttonCode
))
{
if
(
StringUtils
.
isNotBlank
(
buttonCode
))
{
...
@@ -65,6 +74,14 @@ public class PlanStepServiceImpl implements IPlanStepService {
...
@@ -65,6 +74,14 @@ public class PlanStepServiceImpl implements IPlanStepService {
@Override
@Override
public
String
getPlanStep
()
{
public
String
getPlanStep
()
{
try
{
try
{
if
(
redisTemplate
.
hasKey
(
"planType"
))
{
String
planType
=
redisTemplate
.
boundValueOps
(
"planType"
).
get
(
0
,
-
1
);
if
(
PlanTypeEnum
.
MAINTRANSFORM
.
getKey
().
equalsIgnoreCase
(
planType
))
{
return
IOUtils
.
toString
(
planStepZBResource
.
getInputStream
(),
String
.
valueOf
(
StandardCharsets
.
UTF_8
));
}
else
if
(
PlanTypeEnum
.
HIGHRESISTANCE
.
getKey
().
equalsIgnoreCase
(
planType
))
{
return
IOUtils
.
toString
(
planStepGKResource
.
getInputStream
(),
String
.
valueOf
(
StandardCharsets
.
UTF_8
));
}
}
return
IOUtils
.
toString
(
planStepResource
.
getInputStream
(),
String
.
valueOf
(
StandardCharsets
.
UTF_8
));
return
IOUtils
.
toString
(
planStepResource
.
getInputStream
(),
String
.
valueOf
(
StandardCharsets
.
UTF_8
));
}
catch
(
IOException
e
)
{
}
catch
(
IOException
e
)
{
throw
new
RuntimeException
(
"获取预案初始化planStep信息失败!"
);
throw
new
RuntimeException
(
"获取预案初始化planStep信息失败!"
);
...
...
YeeAmosFireAutoSysStart/src/main/resources/application-dev.properties
View file @
1833255c
#DB properties:
#DB properties:
spring.datasource.url
=
jdbc:mysql://172.16.1
1.201:3306/dl_business_v3.0.1.3_pyh_0510
?allowMultiQueries=true&serverTimezone=GMT%2B8&characterEncoding=utf8
spring.datasource.url
=
jdbc:mysql://172.16.1
0.241:3306/dl_business_v3.0.1.3
?allowMultiQueries=true&serverTimezone=GMT%2B8&characterEncoding=utf8
spring.datasource.username
=
root
spring.datasource.username
=
root
spring.datasource.password
=
Yeejoin@2020
spring.datasource.password
=
Yeejoin@2020
spring.datasource.driver-class-name
=
com.mysql.cj.jdbc.Driver
spring.datasource.driver-class-name
=
com.mysql.cj.jdbc.Driver
...
@@ -19,7 +19,7 @@ amos.system.user.product=STUDIO_APP_WEB
...
@@ -19,7 +19,7 @@ amos.system.user.product=STUDIO_APP_WEB
eureka.client.serviceUrl.defaultZone
:
http://${spring.security.user.name}:${spring.security.user.password}@172.16.1
1.20
1:10001/eureka/
eureka.client.serviceUrl.defaultZone
:
http://${spring.security.user.name}:${spring.security.user.password}@172.16.1
0.24
1:10001/eureka/
eureka.instance.prefer-ip-address
=
true
eureka.instance.prefer-ip-address
=
true
management.endpoint.health.show-details
=
always
management.endpoint.health.show-details
=
always
management.endpoints.web.exposure.include
=
*
management.endpoints.web.exposure.include
=
*
...
@@ -34,11 +34,11 @@ spring.security.user.password=a1234560
...
@@ -34,11 +34,11 @@ spring.security.user.password=a1234560
#eureka.instance.ip-address = 172.16.1
1.20
1
#eureka.instance.ip-address = 172.16.1
0.24
1
#redis
#redis
spring.redis.database
=
1
spring.redis.database
=
1
spring.redis.host
=
172.16.1
1.20
1
spring.redis.host
=
172.16.1
0.24
1
spring.redis.port
=
6379
spring.redis.port
=
6379
spring.redis.password
=
yeejoin@2020
spring.redis.password
=
yeejoin@2020
spring.redis.jedis.pool.max-active
=
200
spring.redis.jedis.pool.max-active
=
200
...
@@ -51,18 +51,18 @@ windows.img.path = C:\\
...
@@ -51,18 +51,18 @@ windows.img.path = C:\\
linux.img.path
=
/
linux.img.path
=
/
file.uploadUrl
=
C:
\\
upload
\\
files
\\
file.uploadUrl
=
C:
\\
upload
\\
files
\\
#picture read
#picture read
file.readUrl
=
http://172.16.1
1.20
1:8085/file/getFile?in=
file.readUrl
=
http://172.16.1
0.24
1:8085/file/getFile?in=
## emqx
## emqx
emqx.clean-session
=
true
emqx.clean-session
=
true
emqx.client-id
=
${spring.application.name}-${random.int[1024,65536]}
emqx.client-id
=
${spring.application.name}-${random.int[1024,65536]}
emqx.broker
=
tcp://172.16.1
1.20
1:1883
emqx.broker
=
tcp://172.16.1
0.24
1:1883
emqx.client-user-name
=
admin
emqx.client-user-name
=
admin
emqx.client-password
=
public
emqx.client-password
=
public
emqx.max-inflight
=
1000
emqx.max-inflight
=
1000
riskSourceService
riskSourceService
#\u6587\u4EF6\u670D\u52A1\u5668\u5730\u5740
#\u6587\u4EF6\u670D\u52A1\u5668\u5730\u5740
file.downLoad.url
=
http://172.16.1
1.20
1:9000/
file.downLoad.url
=
http://172.16.1
0.24
1:9000/
#\u5E94\u6025\u5904\u7F6E\u79FB\u52A8\u7AEF\u9ED8\u8BA4\u5934\u50CF\u5730\u5740
#\u5E94\u6025\u5904\u7F6E\u79FB\u52A8\u7AEF\u9ED8\u8BA4\u5934\u50CF\u5730\u5740
plan.instance.personImg
=
upload/3dview_icon/plan_via.png
plan.instance.personImg
=
upload/3dview_icon/plan_via.png
...
@@ -105,6 +105,9 @@ plan.web.isUpdatePlanStep=false
...
@@ -105,6 +105,9 @@ plan.web.isUpdatePlanStep=false
maparea.action.is-area
=
action1-2,action1-6
maparea.action.is-area
=
action1-2,action1-6
plan.dynamic.execut.topic
=
\u6362\u
6D41
\u
7AD9
\u
6D88
\u9632\u
4E13
\u9879\u9884\u6848
/autoExec
plan.dynamic.execut.topic
=
\u6362\u
6D41
\u
7AD9
\u
6D88
\u9632\u
4E13
\u9879\u9884\u6848
/autoExec
# \u65B0\u589E\u4E3B\u53D8\u548C\u9AD8\u6297\u81EA\u52A8\u6267\u884C\u4E3B\u9898\u914D\u7F6E
plan.dynamic.execut.zb.topic
=
\u6362\u
6D41
\u
7AD9
\u
6D88
\u9632\u
4E13
\u9879\u9884\u6848
/autoExec-ZB
plan.dynamic.execut.gk.topic
=
\u6362\u
6D41
\u
7AD9
\u
6D88
\u9632\u
4E13
\u9879\u9884\u6848
/autoExec-GK
#\u670D\u52A1\u7AEF\u83B7\u53D6isdp\u7684token\u7528
#\u670D\u52A1\u7AEF\u83B7\u53D6isdp\u7684token\u7528
sso.client.id
=
dce
sso.client.id
=
dce
...
...
YeeAmosFireAutoSysStart/src/main/resources/db/mapper/PlanDetailMapper.xml
View file @
1833255c
...
@@ -134,6 +134,16 @@
...
@@ -134,6 +134,16 @@
and d.is_delete = false
and d.is_delete = false
limit 1
limit 1
</select>
</select>
<select
id=
"getPlanDetailById"
resultType=
"com.yeejoin.amos.fas.business.vo.PlanDetailVo"
>
select
d.classify_id AS classifyId
from
c_plan_detail d
LEFT JOIN c_plan_classify_tree ct ON d.classify_id = ct.id
where d.id = #{id}
and d.is_delete = false
limit 1
</select>
<update
id=
"planReset"
>
<update
id=
"planReset"
>
UPDATE c_plan_detail SET `status` = 2;
UPDATE c_plan_detail SET `status` = 2;
...
...
YeeAmosFireAutoSysStart/src/main/resources/json/plan-step-UHV-gk.json
0 → 100644
View file @
1833255c
[
{
"stepCode"
:
"0"
,
"stepName"
:
"确认火情"
,
"stepStatus"
:
"0"
,
"buttonCode"
:
"FIRE_CONFIRM"
,
"isParallel"
:
"1"
,
"roleCode"
:
"Digital_Responsing_Plan_A"
,
"index"
:
0
,
"checkYesOrNo"
:
""
},
{
"stepCode"
:
"1"
,
"stepName"
:
"汇报,通知,报警"
,
"stepStatus"
:
"0"
,
"buttonCode"
:
"CALL_PHONE"
,
"isParallel"
:
"1"
,
"roleCode"
:
"Digital_Responsing_Plan_A"
,
"index"
:
1
,
"checkYesOrNo"
:
""
},
{
"stepCode"
:
"2"
,
"stepName"
:
"确认开关跳闸"
,
"stepStatus"
:
"0"
,
"buttonCode"
:
"OPEN_THREE_SIDE_SWITCHES"
,
"isParallel"
:
"0"
,
"roleCode"
:
"Digital_Responsing_Plan_A"
,
"index"
:
2
,
"isAuto"
:
0
,
"checkYesOrNo"
:
""
},
{
"stepCode"
:
"3"
,
"stepName"
:
"检查固定喷雾灭火设施启动"
,
"stepStatus"
:
"0"
,
"buttonCode"
:
"OPEN_SPRAYINGSYSTEM"
,
"isParallel"
:
"0"
,
"roleCode"
:
"Digital_Responsing_Plan_A"
,
"index"
:
3
,
"condition"
:
[
{
"equipName"
:
"主机"
,
"equipCode"
:
"92030100TGX44"
,
"equipSpeName"
:
""
,
"equipSpeCode"
:
""
,
"equipSpeIndexKey"
:
"CAFS_CompAirFoamHost_Outfire"
,
"standardValue"
:
"true"
,
"inAndOr"
:
"and"
}
],
"outAndOr"
:
"and"
,
"isAuto"
:
0
,
"checkYesOrNo"
:
""
},
{
"stepCode"
:
"4"
,
"stepName"
:
"启动CAFS消防系统"
,
"stepStatus"
:
"0"
,
"buttonCode"
:
"OPEN_WATERSYSTEM"
,
"isParallel"
:
"0"
,
"roleCode"
:
"Digital_Responsing_Plan_A"
,
"index"
:
4
,
"checkYesOrNo"
:
""
,
"condition"
:
[
{
"equipName"
:
"雨淋阀"
,
"equipCode"
:
"92130300BH644"
,
"equipSpeName"
:
""
,
"equipSpeCode"
:
""
,
"equipSpeIndexKey"
:
"WSS_DelugeValve_Start"
,
"standardValue"
:
"true"
,
"inAndOr"
:
"and"
}
],
"outAndOr"
:
"and"
,
"isAuto"
:
0
},
{
"stepCode"
:
"5"
,
"stepName"
:
"启动CAFS举高灭火机器人"
,
"stepStatus"
:
"0"
,
"buttonCode"
:
"START_TURBOFAN_ROBOT"
,
"isParallel"
:
"0"
,
"roleCode"
:
"Digital_Responsing_Plan_B"
,
"index"
:
5
,
"checkYesOrNo"
:
""
},
{
"stepCode"
:
"6"
,
"stepName"
:
"申请调检修"
,
"stepStatus"
:
"0"
,
"buttonCode"
:
"APPLY_FOR_OVERHAUL"
,
"isParallel"
:
"0"
,
"roleCode"
:
"Digital_Responsing_Plan_A"
,
"index"
:
6
,
"checkYesOrNo"
:
""
},
{
"stepCode"
:
"7"
,
"stepName"
:
"断开交、直流电源"
,
"stepStatus"
:
"0"
,
"buttonCode"
:
"OFF_POWER"
,
"isParallel"
:
"1"
,
"roleCode"
:
"Digital_Responsing_Plan_A"
,
"index"
:
7
,
"checkYesOrNo"
:
""
},
{
"stepCode"
:
"8"
,
"stepName"
:
"执行转检修操作"
,
"stepStatus"
:
"0"
,
"buttonCode"
:
"FIRE_TRANSVERTER_TO_OVERHAUL"
,
"isParallel"
:
"0"
,
"roleCode"
:
"Digital_Responsing_Plan_B"
,
"index"
:
8
,
"checkYesOrNo"
:
""
},
{
"stepCode"
:
"9"
,
"stepName"
:
"电缆沟封堵"
,
"stepStatus"
:
"0"
,
"buttonCode"
:
"PLUG_CABLETRENCH"
,
"isParallel"
:
"0"
,
"roleCode"
:
"Digital_Responsing_Plan_B"
,
"index"
:
9
,
"checkYesOrNo"
:
""
},
{
"stepCode"
:
"10"
,
"stepName"
:
"政府消防队指挥权交接"
,
"stepStatus"
:
"0"
,
"buttonCode"
:
"HANDOVER_FIGTHHING"
,
"isParallel"
:
"0"
,
"roleCode"
:
"Digital_Responsing_Plan_B"
,
"index"
:
10
,
"checkYesOrNo"
:
""
},
{
"stepCode"
:
"11"
,
"stepName"
:
"确认明火扑灭,确认着火设备温度降为环境温度"
,
"stepStatus"
:
"0"
,
"buttonCode"
:
"FIRE_EXTINCT"
,
"isParallel"
:
"0"
,
"roleCode"
:
"Digital_Responsing_Plan_B"
,
"index"
:
11
,
"checkYesOrNo"
:
""
},
{
"stepCode"
:
"12"
,
"stepName"
:
"检查现场情况,汇报调度"
,
"stepStatus"
:
"0"
,
"buttonCode"
:
"ACCIDENT_REPORT"
,
"isParallel"
:
"0"
,
"roleCode"
:
"Digital_Responsing_Plan_B"
,
"index"
:
12
,
"checkYesOrNo"
:
""
},
{
"stepCode"
:
"13"
,
"stepName"
:
"退出预案"
,
"stepStatus"
:
"0"
,
"buttonCode"
:
"END_EMERGENCY"
,
"isParallel"
:
"1"
,
"roleCode"
:
"Digital_Responsing_Plan_B"
,
"index"
:
13
,
"checkYesOrNo"
:
""
}
]
\ No newline at end of file
YeeAmosFireAutoSysStart/src/main/resources/json/plan-step-UHV-zb.json
0 → 100644
View file @
1833255c
[
{
"stepCode"
:
"0"
,
"stepName"
:
"确认火情"
,
"stepStatus"
:
"0"
,
"buttonCode"
:
"FIRE_CONFIRM"
,
"isParallel"
:
"1"
,
"roleCode"
:
"Digital_Responsing_Plan_A"
,
"index"
:
0
,
"checkYesOrNo"
:
""
},
{
"stepCode"
:
"1"
,
"stepName"
:
"汇报,通知,报警"
,
"stepStatus"
:
"0"
,
"buttonCode"
:
"CALL_PHONE"
,
"isParallel"
:
"1"
,
"roleCode"
:
"Digital_Responsing_Plan_A"
,
"index"
:
1
,
"checkYesOrNo"
:
""
},
{
"stepCode"
:
"2"
,
"stepName"
:
"确认开关跳闸"
,
"stepStatus"
:
"0"
,
"buttonCode"
:
"OPEN_THREE_SIDE_SWITCHES"
,
"isParallel"
:
"0"
,
"roleCode"
:
"Digital_Responsing_Plan_A"
,
"index"
:
2
,
"isAuto"
:
0
},
{
"stepCode"
:
"3"
,
"stepName"
:
"检查固定喷雾灭火设施启动"
,
"stepStatus"
:
"0"
,
"buttonCode"
:
"OPEN_SPRAYINGSYSTEM"
,
"isParallel"
:
"0"
,
"roleCode"
:
"Digital_Responsing_Plan_A"
,
"index"
:
3
,
"condition"
:
[
{
"equipName"
:
"主机"
,
"equipCode"
:
"92030100TGX44"
,
"equipSpeName"
:
""
,
"equipSpeCode"
:
""
,
"equipSpeIndexKey"
:
"CAFS_CompAirFoamHost_Outfire"
,
"standardValue"
:
"true"
,
"inAndOr"
:
"and"
}
],
"outAndOr"
:
"and"
,
"isAuto"
:
0
,
"checkYesOrNo"
:
""
},
{
"stepCode"
:
"4"
,
"stepName"
:
"启动CAFS消防系统"
,
"stepStatus"
:
"0"
,
"buttonCode"
:
"OPEN_WATERSYSTEM"
,
"isParallel"
:
"0"
,
"roleCode"
:
"Digital_Responsing_Plan_A"
,
"index"
:
4
,
"checkYesOrNo"
:
""
,
"condition"
:
[
{
"equipName"
:
"雨淋阀"
,
"equipCode"
:
"92130300BH644"
,
"equipSpeName"
:
""
,
"equipSpeCode"
:
""
,
"equipSpeIndexKey"
:
"WSS_DelugeValve_Start"
,
"standardValue"
:
"true"
,
"inAndOr"
:
"and"
}
],
"outAndOr"
:
"and"
,
"isAuto"
:
0
},
{
"stepCode"
:
"5"
,
"stepName"
:
"启动应急排油"
,
"stepStatus"
:
"0"
,
"buttonCode"
:
"DRAIN_OIL_CONFIRM"
,
"isParallel"
:
"0"
,
"roleCode"
:
"Digital_Responsing_Plan_A"
,
"index"
:
5
,
"condition"
:
[
{
"equipName"
:
"排油阀"
,
"equipCode"
:
"92100400VWE44"
,
"equipSpeName"
:
""
,
"equipSpeCode"
:
""
,
"equipSpeIndexKey"
:
"ONL_DrainOilValve_Open"
,
"standardValue"
:
"true"
,
"inAndOr"
:
"and"
}
],
"outAndOr"
:
"and"
,
"isAuto"
:
0
,
"checkYesOrNo"
:
""
},
{
"stepCode"
:
"6"
,
"stepName"
:
"启动CAFS举高灭火机器人"
,
"stepStatus"
:
"0"
,
"buttonCode"
:
"START_TURBOFAN_ROBOT"
,
"isParallel"
:
"0"
,
"roleCode"
:
"Digital_Responsing_Plan_B"
,
"index"
:
6
,
"checkYesOrNo"
:
""
},
{
"stepCode"
:
"7"
,
"stepName"
:
"申请调检修"
,
"stepStatus"
:
"0"
,
"buttonCode"
:
"APPLY_FOR_OVERHAUL"
,
"isParallel"
:
"0"
,
"roleCode"
:
"Digital_Responsing_Plan_A"
,
"index"
:
7
,
"checkYesOrNo"
:
""
},
{
"stepCode"
:
"8"
,
"stepName"
:
"断开交、直流电源"
,
"stepStatus"
:
"0"
,
"buttonCode"
:
"OFF_POWER"
,
"isParallel"
:
"1"
,
"roleCode"
:
"Digital_Responsing_Plan_A"
,
"index"
:
8
,
"checkYesOrNo"
:
""
},
{
"stepCode"
:
"9"
,
"stepName"
:
"执行转检修操作"
,
"stepStatus"
:
"0"
,
"buttonCode"
:
"FIRE_TRANSVERTER_TO_OVERHAUL"
,
"isParallel"
:
"0"
,
"roleCode"
:
"Digital_Responsing_Plan_B"
,
"index"
:
9
,
"checkYesOrNo"
:
""
},
{
"stepCode"
:
"10"
,
"stepName"
:
"电缆沟封堵"
,
"stepStatus"
:
"0"
,
"buttonCode"
:
"PLUG_CABLETRENCH"
,
"isParallel"
:
"0"
,
"roleCode"
:
"Digital_Responsing_Plan_B"
,
"index"
:
10
,
"checkYesOrNo"
:
""
},
{
"stepCode"
:
"11"
,
"stepName"
:
"政府消防队指挥权交接"
,
"stepStatus"
:
"0"
,
"buttonCode"
:
"HANDOVER_FIGTHHING"
,
"isParallel"
:
"0"
,
"roleCode"
:
"Digital_Responsing_Plan_B"
,
"index"
:
11
,
"checkYesOrNo"
:
""
},
{
"stepCode"
:
"12"
,
"stepName"
:
"确认明火扑灭,确认着火设备温度降为环境温度"
,
"stepStatus"
:
"0"
,
"buttonCode"
:
"FIRE_EXTINCT"
,
"isParallel"
:
"0"
,
"roleCode"
:
"Digital_Responsing_Plan_B"
,
"index"
:
12
,
"checkYesOrNo"
:
""
},
{
"stepCode"
:
"13"
,
"stepName"
:
"检查现场情况,汇报调度"
,
"stepStatus"
:
"0"
,
"buttonCode"
:
"ACCIDENT_REPORT"
,
"isParallel"
:
"0"
,
"roleCode"
:
"Digital_Responsing_Plan_B"
,
"index"
:
13
,
"checkYesOrNo"
:
""
},
{
"stepCode"
:
"14"
,
"stepName"
:
"退出预案"
,
"stepStatus"
:
"0"
,
"buttonCode"
:
"END_EMERGENCY"
,
"isParallel"
:
"1"
,
"roleCode"
:
"Digital_Responsing_Plan_B"
,
"index"
:
14
,
"checkYesOrNo"
:
""
}
]
\ 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