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
c1a64e06
Commit
c1a64e06
authored
Feb 20, 2024
by
duanruiming
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
[update] 优化代码6,优化讲台方案灯态定时任务程序可读性
parent
206eb2bd
Changes
1
Hide whitespace changes
Inline
Side-by-side
Showing
1 changed file
with
33 additions
and
20 deletions
+33
-20
SignalStatus4StaticSchemeTask.java
...ava/net/wanji/utc/task/SignalStatus4StaticSchemeTask.java
+33
-20
No files found.
signal-utc-service/src/main/java/net/wanji/utc/task/SignalStatus4StaticSchemeTask.java
View file @
c1a64e06
...
@@ -113,25 +113,7 @@ public class SignalStatus4StaticSchemeTask {
...
@@ -113,25 +113,7 @@ public class SignalStatus4StaticSchemeTask {
if
(
isNotNextSchemeNo
(
crossSchemePO
))
{
if
(
isNotNextSchemeNo
(
crossSchemePO
))
{
continue
;
continue
;
}
}
List
<
CrossSchemePhaseCountDownDTO
>
crossSchemePhaseCountDownList
=
CrossSchemePhaseTimeCountCache
.
crossSchemePhaseCountDownList
;
initLightsStatus
(
crossId
,
code
,
lightsStatusVO
,
date
,
crossSchemePO
,
schemeNo
);
for
(
CrossSchemePhaseCountDownDTO
crossSchemePhaseCountDownDTO
:
crossSchemePhaseCountDownList
)
{
if
(
StringUtils
.
equalsIgnoreCase
(
schemeNo
,
crossSchemePhaseCountDownDTO
.
getSchemeNo
())
&&
StringUtils
.
equalsIgnoreCase
(
crossId
,
crossSchemePhaseCountDownDTO
.
getCrossId
()))
{
lightsStatusVO
.
setCrossId
(
crossId
);
lightsStatusVO
.
setCyclePhaseCountDown
(
0
);
lightsStatusVO
.
setCycleCountDown
(
0
);
lightsStatusVO
.
setSchemeId
(
schemeNo
);
lightsStatusVO
.
setCycleLen
(
crossSchemePO
.
getCycle
());
lightsStatusVO
.
setPhaseId
(
"0"
);
String
currentTimeStr
=
String
.
valueOf
(
date
.
getTime
());
lightsStatusVO
.
setTimeStamp
(
currentTimeStr
);
lightsStatusVO
.
setCode
(
code
);
lightsStatusVO
.
setRunMode
(
"11"
);
lightsStatusVO
.
setControlMode
(
"11"
);
lightsStatusVO
.
setManufacturerCode
(
"STATIC"
);
currentCrossLightStatusCache
.
put
(
crossId
,
lightsStatusVO
);
}
}
}
}
}
}
}
}
...
@@ -142,6 +124,37 @@ public class SignalStatus4StaticSchemeTask {
...
@@ -142,6 +124,37 @@ public class SignalStatus4StaticSchemeTask {
}
}
}
}
/**
* 初始化灯态信息
* @param crossId
* @param code
* @param lightsStatusVO
* @param date
* @param crossSchemePO
* @param schemeNo
*/
private
static
void
initLightsStatus
(
String
crossId
,
String
code
,
LightsStatusVO
lightsStatusVO
,
Date
date
,
CrossSchemePO
crossSchemePO
,
String
schemeNo
)
{
List
<
CrossSchemePhaseCountDownDTO
>
crossSchemePhaseCountDownList
=
CrossSchemePhaseTimeCountCache
.
crossSchemePhaseCountDownList
;
for
(
CrossSchemePhaseCountDownDTO
crossSchemePhaseCountDownDTO
:
crossSchemePhaseCountDownList
)
{
if
(
StringUtils
.
equalsIgnoreCase
(
schemeNo
,
crossSchemePhaseCountDownDTO
.
getSchemeNo
())
&&
StringUtils
.
equalsIgnoreCase
(
crossId
,
crossSchemePhaseCountDownDTO
.
getCrossId
()))
{
lightsStatusVO
.
setCrossId
(
crossId
);
lightsStatusVO
.
setCyclePhaseCountDown
(
0
);
lightsStatusVO
.
setCycleCountDown
(
0
);
lightsStatusVO
.
setSchemeId
(
schemeNo
);
lightsStatusVO
.
setCycleLen
(
crossSchemePO
.
getCycle
());
lightsStatusVO
.
setPhaseId
(
"0"
);
String
currentTimeStr
=
String
.
valueOf
(
date
.
getTime
());
lightsStatusVO
.
setTimeStamp
(
currentTimeStr
);
lightsStatusVO
.
setCode
(
code
);
lightsStatusVO
.
setRunMode
(
"11"
);
lightsStatusVO
.
setControlMode
(
"11"
);
lightsStatusVO
.
setManufacturerCode
(
"STATIC"
);
currentCrossLightStatusCache
.
put
(
crossId
,
lightsStatusVO
);
}
}
}
private
boolean
isNotNextSchemeNo
(
CrossSchemePO
crossSchemePO
)
{
private
boolean
isNotNextSchemeNo
(
CrossSchemePO
crossSchemePO
)
{
if
(
Objects
.
nonNull
(
crossSchemePO
))
{
if
(
Objects
.
nonNull
(
crossSchemePO
))
{
String
schemeNo
=
crossSchemePO
.
getSchemeNo
();
String
schemeNo
=
crossSchemePO
.
getSchemeNo
();
...
@@ -238,7 +251,7 @@ public class SignalStatus4StaticSchemeTask {
...
@@ -238,7 +251,7 @@ public class SignalStatus4StaticSchemeTask {
&&
StringUtils
.
equalsIgnoreCase
(
schemeId
,
String
.
valueOf
(
turnPojo
.
getSchemeNo
()))
&&
StringUtils
.
equalsIgnoreCase
(
schemeId
,
String
.
valueOf
(
turnPojo
.
getSchemeNo
()))
&&
StringUtils
.
equalsIgnoreCase
(
dirTurnPhaseNo
,
String
.
valueOf
(
turnPojo
.
getPhaseNo
())))
{
&&
StringUtils
.
equalsIgnoreCase
(
dirTurnPhaseNo
,
String
.
valueOf
(
turnPojo
.
getPhaseNo
())))
{
Integer
strphase
=
turnPojo
.
getPhaseNo
();
Integer
phaseNoStr
=
turnPojo
.
getPhaseNo
();
if
(
Objects
.
nonNull
(
turnPojo
.
getDirTurnMap
()))
{
if
(
Objects
.
nonNull
(
turnPojo
.
getDirTurnMap
()))
{
for
(
Map
.
Entry
<
Integer
,
List
<
CrossLightsPO
>>
entry
:
turnPojo
.
getDirTurnMap
().
entrySet
())
{
for
(
Map
.
Entry
<
Integer
,
List
<
CrossLightsPO
>>
entry
:
turnPojo
.
getDirTurnMap
().
entrySet
())
{
...
...
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