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
840c1e5d
Commit
840c1e5d
authored
Sep 07, 2023
by
tianbo
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
96333救援时长修改
parent
74a95085
Show whitespace changes
Inline
Side-by-side
Showing
2 changed files
with
5 additions
and
6 deletions
+5
-6
FillingRecordSyncListener.java
...dule/elevator/biz/listener/FillingRecordSyncListener.java
+3
-4
RescueProcessServiceImpl.java
...e/elevator/biz/service/impl/RescueProcessServiceImpl.java
+2
-2
No files found.
amos-boot-system-tzs/amos-boot-module-96333/amos-boot-module-96333-biz/src/main/java/com/yeejoin/amos/boot/module/elevator/biz/listener/FillingRecordSyncListener.java
View file @
840c1e5d
...
@@ -6,7 +6,6 @@ import org.eclipse.paho.client.mqttv3.MqttMessage;
...
@@ -6,7 +6,6 @@ import org.eclipse.paho.client.mqttv3.MqttMessage;
import
org.springframework.beans.factory.annotation.Autowired
;
import
org.springframework.beans.factory.annotation.Autowired
;
import
org.springframework.stereotype.Component
;
import
org.springframework.stereotype.Component
;
import
org.typroject.tyboot.component.emq.EmqxListener
;
import
org.typroject.tyboot.component.emq.EmqxListener
;
import
org.typroject.tyboot.core.foundation.utils.ValidationUtil
;
/**
/**
* @Description: 气瓶充装信息mqtt监听服务
* @Description: 气瓶充装信息mqtt监听服务
...
@@ -23,8 +22,8 @@ public class FillingRecordSyncListener extends EmqxListener {
...
@@ -23,8 +22,8 @@ public class FillingRecordSyncListener extends EmqxListener {
@Override
@Override
public
void
processMessage
(
String
topic
,
MqttMessage
message
)
throws
Exception
{
public
void
processMessage
(
String
topic
,
MqttMessage
message
)
throws
Exception
{
System
.
out
.
println
(
message
);
System
.
out
.
println
(
message
);
if
(!
ValidationUtil
.
isEmpty
(
message
.
toString
()))
{
//
if (!ValidationUtil.isEmpty(message.toString())) {
cylinderInfoService
.
synUnitFillingCheckData
();
//
cylinderInfoService.synUnitFillingCheckData();
}
//
}
}
}
}
}
amos-boot-system-tzs/amos-boot-module-96333/amos-boot-module-96333-biz/src/main/java/com/yeejoin/amos/boot/module/elevator/biz/service/impl/RescueProcessServiceImpl.java
View file @
840c1e5d
...
@@ -100,8 +100,8 @@ public class RescueProcessServiceImpl extends BaseService<RescueProcessDto,Rescu
...
@@ -100,8 +100,8 @@ public class RescueProcessServiceImpl extends BaseService<RescueProcessDto,Rescu
rescueProcessDto
.
setIsTimeout
(
arriveTimes
<
1800000
?
false
:
true
);
rescueProcessDto
.
setIsTimeout
(
arriveTimes
<
1800000
?
false
:
true
);
}
}
// 救援时长 用完成时间减去到达时间
// 救援时长 用完成时间减去到达时间
if
(
rescueTime
!=
null
&&
dispatch
Time
!=
null
)
{
if
(
rescueTime
!=
null
&&
arrive
Time
!=
null
)
{
String
hms
=
DateUtils
.
getTimeDiffString
(
arriveTime
,
dispatch
Time
);
String
hms
=
DateUtils
.
getTimeDiffString
(
rescueTime
,
arrive
Time
);
rescueProcessDto
.
setArriveUseTime
(
hms
);
rescueProcessDto
.
setArriveUseTime
(
hms
);
}
}
SimpleDateFormat
sdf
=
new
SimpleDateFormat
(
"yyyy-MM-dd'T'HH:mm:ss"
);
SimpleDateFormat
sdf
=
new
SimpleDateFormat
(
"yyyy-MM-dd'T'HH:mm:ss"
);
...
...
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