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
0b979bf4
Commit
0b979bf4
authored
May 23, 2022
by
chenzhao
Browse files
Options
Browse Files
Download
Plain Diff
Merge branch 'developer' of
http://39.98.45.134:8090/moa/amos-boot-biz
into developer
parents
1d68e515
bc4e45b9
Hide whitespace changes
Inline
Side-by-side
Showing
3 changed files
with
52 additions
and
54 deletions
+52
-54
EquipmentSpecificAlarm.java
...oin/equipmanage/common/entity/EquipmentSpecificAlarm.java
+1
-1
TopographyController.java
.../yeejoin/equipmanage/controller/TopographyController.java
+1
-1
PowerTransferServiceImpl.java
...module/jcs/biz/service/impl/PowerTransferServiceImpl.java
+50
-52
No files found.
amos-boot-module/amos-boot-module-api/amos-boot-module-equip-api/src/main/java/com/yeejoin/equipmanage/common/entity/EquipmentSpecificAlarm.java
View file @
0b979bf4
...
...
@@ -65,7 +65,7 @@ public class EquipmentSpecificAlarm extends BaseEntity {
@TableField
(
"frequency"
)
private
int
frequency
;
@ApiModelProperty
(
value
=
"报警状态:1报警0恢复"
)
@ApiModelProperty
(
value
=
"报警状态:1报警0恢复
-> 1-报警 0-正常
"
)
@TableField
(
"status"
)
private
int
status
;
...
...
amos-boot-module/amos-boot-module-biz/amos-boot-module-equip-biz/src/main/java/com/yeejoin/equipmanage/controller/TopographyController.java
View file @
0b979bf4
...
...
@@ -525,7 +525,7 @@ public class TopographyController extends AbstractBaseController {
alarm
=
list
.
get
(
0
);
equipmentSpecific
.
setStatus
(
alarm
.
getStatus
());
}
else
{
equipmentSpecific
.
setStatus
(
null
);
equipmentSpecific
.
setStatus
(
0
);
}
equipmentSpecific
.
setFullqrCode
(
"01#"
+
equipmentSpecific
.
getQrCode
());
String
sysName
=
this
.
getSystemNameBySpeId
(
equipmentSpecific
);
...
...
amos-boot-module/amos-boot-module-biz/amos-boot-module-jcs-biz/src/main/java/com/yeejoin/amos/boot/module/jcs/biz/service/impl/PowerTransferServiceImpl.java
View file @
0b979bf4
...
...
@@ -808,20 +808,20 @@ public class PowerTransferServiceImpl extends BaseService<PowerTransferDto, Powe
});
}
List
<
Map
<
String
,
Object
>>
collect
=
new
ArrayList
<>();
if
(
null
!=
totalCarList
&&
totalCarList
.
size
()
>
0
)
{
List
<
StatusDto
>
statusByIds1
=
powerTransferCompanyResourcesMapper
.
findStatusByIds
(
carIdList
);
Map
<
Long
,
String
>
statusMap
=
statusByIds1
.
stream
().
collect
(
Collectors
.
toMap
(
StatusDto:
:
getCardId
,
StatusDto:
:
getCarStatus
));
collect
=
totalCarList
.
stream
().
map
(
item
->
{
item
.
put
(
"carState"
,
statusMap
.
get
(
Long
.
valueOf
((
String
)
item
.
get
(
"id"
))));
return
item
;
}).
collect
(
Collectors
.
toList
());
}
//到场车辆信息
List
<
Map
<
String
,
Object
>>
arrivedCarList
=
collect
.
stream
()
.
filter
(
c
->
FireCarStatusEnum
.
到场
.
getCode
().
equals
(
c
.
get
(
"carState"
)))
.
collect
(
Collectors
.
toList
());
//
List<Map<String, Object>> collect = new ArrayList<>();
//
if (null != totalCarList && totalCarList.size() > 0) {
//
List<StatusDto> statusByIds1 = powerTransferCompanyResourcesMapper.findStatusByIds(carIdList);
//
Map<Long, String> statusMap = statusByIds1.stream().collect(Collectors.toMap(StatusDto::getCardId, StatusDto::getCarStatus));
//
collect = totalCarList.stream().map(item -> {
//
item.put("carState", statusMap.get(Long.valueOf((String) item.get("id"))));
//
return item;
//
}).collect(Collectors.toList());
//
}
//
//
//到场车辆信息
//
List<Map<String, Object>> arrivedCarList = collect.stream()
//
.filter(c -> FireCarStatusEnum.到场.getCode().equals(c.get("carState")))
//
.collect(Collectors.toList());
JSONObject
resourceStatistics
=
new
JSONObject
();
...
...
@@ -834,7 +834,7 @@ public class PowerTransferServiceImpl extends BaseService<PowerTransferDto, Powe
dutyPersonCount
(
carIdList
,
arrivedCarIdList
,
resourceStatistics
);
// 车载器材统计
fireAgentOnCarCount
(
totalCarList
,
arrivedCarIdList
,
resourceStatistics
,
"equipment"
,
"equip"
,
arrivedCarList
);
fireAgentOnCarCount
(
totalCarList
,
arrivedCarIdList
,
resourceStatistics
,
"equipment"
,
"equip"
);
// 车载药剂统计 车载水量统计
...
...
@@ -927,54 +927,52 @@ public class PowerTransferServiceImpl extends BaseService<PowerTransferDto, Powe
resourceStatistics
.
put
(
"person"
,
person
);
}
public
void
fireAgentOnCarCount
(
List
<
Map
<
String
,
Object
>>
totalCarList
,
List
<
Long
>
arrivedCarIdList
,
JSONObject
resourceStatistics
,
String
equipType
,
String
jsonKey
,
List
<
Map
<
String
,
Object
>>
arrivedCarList
)
{
double
agentCountArrived
=
0
;
double
agentCountAll
=
0
;
if
(
null
!=
totalCarList
&&
totalCarList
.
size
()>
0
)
{
agentCountAll
=
totalCarList
.
stream
().
mapToDouble
(
car
->
car
.
get
(
"resourceList"
)
!=
null
?
((
List
<
Map
<
String
,
Object
>>)
car
.
get
(
"resourceList"
)).
stream
()
.
filter
(
res
->
equipType
.
equals
(
res
.
get
(
"equipType"
)))
.
mapToDouble
(
c
->
Double
.
parseDouble
(
ValidationUtil
.
isEmpty
(
c
.
get
(
"equipCount"
))
?
"0"
:
c
.
get
(
"equipCount"
).
toString
())).
sum
()
:
0
)
.
sum
();
if
(
null
!=
arrivedCarList
&&
arrivedCarList
.
size
()>
0
)
{
agentCountArrived
=
arrivedCarList
.
stream
().
mapToDouble
(
car
->
car
.
get
(
"resourceList"
)
!=
null
?
((
List
<
Map
<
String
,
Object
>>)
car
.
get
(
"resourceList"
)).
stream
()
.
filter
(
res
->
equipType
.
equals
(
res
.
get
(
"equipType"
)))
.
mapToDouble
(
c
->
Double
.
parseDouble
(
ValidationUtil
.
isEmpty
(
c
.
get
(
"equipCount"
))
?
"0"
:
c
.
get
(
"equipCount"
).
toString
())).
sum
()
:
0
)
.
sum
();
}
}
JSONObject
jsonObject
=
new
JSONObject
();
jsonObject
.
put
(
"total"
,
agentCountAll
);
jsonObject
.
put
(
"count"
,
agentCountArrived
);
resourceStatistics
.
put
(
jsonKey
,
jsonObject
);
public
void
fireAgentOnCarCount
(
List
<
Map
<
String
,
Object
>>
totalCarList
,
List
<
Long
>
arrivedCarList
,
JSONObject
resourceStatistics
,
String
equipType
,
String
jsonKey
)
{
//
// JSONObject jsonObject = new JSONObject();
// if(totalCarList!=null&&totalCarList.size()>0){
// double agentCountAll = totalCarList.stream().mapToDouble(
// double agentCountArrived = 0;
// double agentCountAll = 0;
// if (null != totalCarList && totalCarList.size()>0) {
// agentCountAll = totalCarList.stream().mapToDouble(
// car -> car.get("resourceList") != null ? ((List<Map<String, Object>>) car.get("resourceList")).stream()
// .filter(res -> equipType.equals(res.get("equipType")))
// .mapToDouble(c -> Double.parseDouble(ValidationUtil.isEmpty(c.get("equipCount")
) ? "0" : c.get("equipCount").toString())).sum() : 0)
// .mapToDouble(c -> Double.parseDouble(ValidationUtil.isEmpty(c.get("equipCount")) ? "0" : c.get("equipCount").toString())).sum() : 0)
// .sum();
// if (null != arrivedCarList && arrivedCarList.size()>0) {
// agentCountArrived = arrivedCarList.stream().mapToDouble(
// car -> car.get("resourceList") != null ? ((List<Map<String, Object>>) car.get("resourceList")).stream()
// .filter(res -> equipType.equals(res.get("equipType")))
// .mapToDouble(c -> Double.parseDouble(ValidationUtil.isEmpty(c.get("equipCount")) ? "0" : c.get("equipCount").toString())).sum() : 0)
// .sum();
// }
// }
// JSONObject jsonObject = new JSONObject();
// jsonObject.put("total", agentCountAll);
// jsonObject.put("count", agentCountArrived);
// resourceStatistics.put(jsonKey, jsonObject);
JSONObject
jsonObject
=
new
JSONObject
();
if
(
totalCarList
!=
null
&&
totalCarList
.
size
()>
0
){
double
agentCountAll
=
totalCarList
.
stream
().
mapToDouble
(
car
->
car
.
get
(
"resourceList"
)
!=
null
?
((
List
<
Map
<
String
,
Object
>>)
car
.
get
(
"resourceList"
)).
stream
()
.
filter
(
res
->
equipType
.
equals
(
res
.
get
(
"equipType"
)))
.
mapToDouble
(
c
->
Double
.
parseDouble
(
ValidationUtil
.
isEmpty
(
c
.
get
(
"equipCount"
)
)
?
"0"
:
c
.
get
(
"equipCount"
).
toString
())).
sum
()
:
0
)
.
sum
();
// double agentCountArrived = arrivedCarList.stream().mapToDouble(
// car -> car.get("resourceList") != null ? ((List<Map<String, Object>>) car.get("resourceList")).stream()
// .filter(res -> equipType.equals(res.get("equipType")))
// .mapToDouble(c -> Double.parseDouble(ValidationUtil.isEmpty(c.get("equipCount") ) ? "0" : c.get("equipCount").toString())).sum() : 0)
// .sum();
jsonObject
.
put
(
"total"
,
agentCountAll
);
jsonObject
.
put
(
"count"
,
agentCountAll
);
}
else
{
jsonObject
.
put
(
"total"
,
0
);
jsonObject
.
put
(
"count"
,
0
);
}
//
// jsonObject.put("total", agentCountAll);
// jsonObject.put("count", agentCountAll);
// }else{
// jsonObject.put("total", 0);
// jsonObject.put("count", 0);
// }
//
// resourceStatistics.put(jsonKey, jsonObject);
resourceStatistics
.
put
(
jsonKey
,
jsonObject
);
}
@Override
...
...
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