Skip to content
Projects
Groups
Snippets
Help
Loading...
Help
Support
Submit feedback
Contribute to GitLab
Sign in / Register
Toggle navigation
T
traffic-signal-platform
Project
Project
Details
Activity
Releases
Cycle Analytics
Repository
Repository
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Charts
Issues
0
Issues
0
List
Boards
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
signal
traffic-signal-platform
Commits
0e26dcd5
Commit
0e26dcd5
authored
Mar 23, 2023
by
duanruiming
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
[update] 删除测试日志
parent
6e61ef46
Changes
2
Hide whitespace changes
Inline
Side-by-side
Showing
2 changed files
with
2 additions
and
7 deletions
+2
-7
CommonEventWarnTask.java
...src/main/java/net/wanji/web/task/CommonEventWarnTask.java
+1
-4
SignalStatusTask.java
...ce/src/main/java/net/wanji/web/task/SignalStatusTask.java
+1
-3
No files found.
signal-control-service/src/main/java/net/wanji/web/task/CommonEventWarnTask.java
View file @
0e26dcd5
...
...
@@ -41,7 +41,7 @@ public class CommonEventWarnTask {
@Autowired
private
TDeviceStatusMapper
tDeviceStatusMapper
;
@Scheduled
(
fixedRate
=
1
*
6
0
*
1000
)
@Scheduled
(
fixedRate
=
3
0
*
1000
)
public
void
pushEvenWarnData
()
{
try
{
Set
<
WebSocketServer
>
events
=
WebSocketServer
.
getWebSocketSet
(
Constant
.
WEBSOCKET_TOPIC_EVENT_WARN
);
...
...
@@ -83,9 +83,7 @@ public class CommonEventWarnTask {
*/
private
JsonViewObject
getSignalWarnData
()
{
List
<
CommonEventAlarmOutVo
>
results
=
new
ArrayList
<>();
log
.
info
(
"=============信号机告警==============="
);
JsonViewObject
jsonViewObject
=
utcFeignClients
.
runningStatusAlarm
();
log
.
info
(
"=============信号机告警jsonViewObject==============:{}"
,
jsonViewObject
);
if
(
Objects
.
isNull
(
jsonViewObject
)
||
jsonViewObject
.
getCode
()
!=
200
)
{
return
jsonViewObject
.
fail
(
"信号机告警UTC服务调用异常!"
);
...
...
@@ -93,7 +91,6 @@ public class CommonEventWarnTask {
LocalDateTime
now
=
LocalDateTime
.
now
();
String
formatNow
=
DateTimeFormatter
.
ofPattern
(
"yyyy-MM-dd HH:mm:ss"
).
format
(
now
);
List
<
Map
<
String
,
Object
>>
content
=
(
List
<
Map
<
String
,
Object
>>)
jsonViewObject
.
getContent
();
log
.
info
(
"=============信号机告警:{}"
,
content
);
content
.
forEach
(
map
->
{
Map
<
String
,
Object
>
result
=
map
;
String
signalId
=
(
String
)
result
.
get
(
"signalId"
);
...
...
signal-control-service/src/main/java/net/wanji/web/task/SignalStatusTask.java
View file @
0e26dcd5
...
...
@@ -36,7 +36,7 @@ public class SignalStatusTask {
private
final
ControlHistMapper
controlHistMapper
;
private
final
TDeviceStatusLogMapper
tDeviceStatusLogMapper
;
@Scheduled
(
fixedRate
=
2
*
60
*
1000
)
@Scheduled
(
fixedRate
=
1
*
60
*
1000
)
@Transactional
public
void
syncSignalStatus
()
{
try
{
...
...
@@ -47,7 +47,6 @@ public class SignalStatusTask {
}
List
<
Map
<
String
,
Object
>>
source
=
(
List
<
Map
<
String
,
Object
>>)
jsonViewObject
.
getContent
();
List
<
SignalStatusVO
>
content
=
BeanMapUtils
.
mapsToObjects
(
source
,
SignalStatusVO
.
class
);
log
.
info
(
"SignalStatusVOTOMap: {}"
,
content
);
content
.
forEach
(
signalStatusVO
->
{
String
signalId
=
signalStatusVO
.
getSignalId
();
String
crossId
=
signalStatusVO
.
getCrossId
();
...
...
@@ -59,7 +58,6 @@ public class SignalStatusTask {
if
(
StringUtils
.
isNotEmpty
(
crossId
))
{
lambdaQueryWrapper
.
eq
(
TDeviceStatusInfo:
:
getCode
,
crossId
);
TDeviceStatusInfo
tDeviceStatusInfo
=
tDeviceStatusMapper
.
selectOne
(
lambdaQueryWrapper
);
log
.
info
(
"TDeviceStatusInfo::getCode: {}"
,
tDeviceStatusInfo
.
getCode
());
if
(
isExucuteUpdate
(
currentSignalStatus
,
currentFaultType
,
tDeviceStatusInfo
))
{
tDeviceStatusInfo
.
setStatus
(
currentSignalStatus
);
...
...
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