Skip to content
Toggle navigation
P
Projects
G
Groups
S
Snippets
Help
黄嘉阳
/
iot-platform-server
This project
Loading...
Sign in
Toggle navigation
Go to a project
Project
Repository
Issues
0
Merge Requests
0
Pipelines
Wiki
Snippets
Settings
Activity
Graph
Charts
Create a new issue
Jobs
Commits
Issue Boards
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Charts
Commit
098afb54
authored
Sep 13, 2023
by
朱淼
Browse files
Options
_('Browse Files')
Download
Email Patches
Plain Diff
代码整理
parent
f8b8c167
Hide whitespace changes
Inline
Side-by-side
Showing
13 changed files
with
313 additions
and
55 deletions
server-common/src/main/java/com/makeit/enums/HeaderConst.java
server-module/src/main/java/com/makeit/module/controller/dataScreen/DataScreenController.java
server-module/src/main/java/com/makeit/module/controller/workstation/WorkStationController.java
server-service/src/main/java/com/makeit/dto/platform/dataScreen/PlatDataScreenQueryDTO.java
server-service/src/main/java/com/makeit/dto/platform/workstation/WorkStationQueryDTO.java
server-service/src/main/java/com/makeit/service/platform/dataScreen/DataScreenService.java
server-service/src/main/java/com/makeit/service/platform/dataScreen/impl/DataScreenServiceImpl.java
server-service/src/main/java/com/makeit/service/platform/space/impl/PlatSpaceServiceImpl.java
server-service/src/main/java/com/makeit/service/platform/workstation/WorkStationService.java
server-service/src/main/java/com/makeit/service/platform/workstation/impl/WorkStationServiceImpl.java
server-service/src/main/java/com/makeit/vo/platform/dataScreen/PlatAlarmRecordStatisticsVo.java
server-service/src/main/java/com/makeit/vo/platform/dataScreen/PlatMapStatisticsVO.java
server-service/src/main/java/com/makeit/vo/platform/dataScreen/PlatMapStatisticsSpaceVO.java → server-service/src/main/java/com/makeit/vo/platform/workstation/WorkStationStatisticsVO.java
server-common/src/main/java/com/makeit/enums/HeaderConst.java
View file @
098afb54
...
@@ -8,7 +8,7 @@ public class HeaderConst {
...
@@ -8,7 +8,7 @@ public class HeaderConst {
// public static final String PLATFORM_TOKEN = "platformToken";
// public static final String PLATFORM_TOKEN = "platformToken";
public
static
final
String
PLATFORM_TOKEN
=
"token"
;
public
static
final
String
PLATFORM_TOKEN
=
"token"
;
public
static
final
String
TOKEN
=
"token"
;
public
static
final
String
TOKEN
=
"token"
;
public
static
final
String
WECHAT_TOKEN
=
"
wechatT
oken"
;
public
static
final
String
WECHAT_TOKEN
=
"
t
oken"
;
// public static final String CUSTOMER_TOKEN = "customerToken";
// public static final String CUSTOMER_TOKEN = "customerToken";
...
...
server-module/src/main/java/com/makeit/module/controller/dataScreen/DataScreenController.java
View file @
098afb54
...
@@ -61,7 +61,7 @@ public class DataScreenController {
...
@@ -61,7 +61,7 @@ public class DataScreenController {
@ApiOperation
(
"地图统计"
)
@ApiOperation
(
"地图统计"
)
@PostMapping
(
"mapStatistics"
)
@PostMapping
(
"mapStatistics"
)
public
ApiResponseEntity
<
PlatMapStatisticsVO
>
mapStatistics
(
@RequestBody
PlatDataScreenQueryDTO
dto
)
{
public
ApiResponseEntity
<
List
<
PlatMapStatisticsVO
>
>
mapStatistics
(
@RequestBody
PlatDataScreenQueryDTO
dto
)
{
return
ApiResponseUtils
.
success
(
dataScreenService
.
mapStatistics
(
dto
));
return
ApiResponseUtils
.
success
(
dataScreenService
.
mapStatistics
(
dto
));
}
}
}
}
server-module/src/main/java/com/makeit/module/controller/workstation/WorkStationController.java
View file @
098afb54
package
com
.
makeit
.
module
.
controller
.
workstation
;
package
com
.
makeit
.
module
.
controller
.
workstation
;
import
com.makeit.common.response.ApiResponseEntity
;
import
com.makeit.common.response.ApiResponseUtils
;
import
com.makeit.dto.platform.dataScreen.PlatDataScreenQueryDTO
;
import
com.makeit.dto.platform.workstation.WorkStationQueryDTO
;
import
com.makeit.service.platform.workstation.WorkStationService
;
import
com.makeit.vo.platform.dataScreen.PlatAgeStatisticsVO
;
import
com.makeit.vo.platform.workstation.WorkStationStatisticsVO
;
import
io.swagger.annotations.Api
;
import
io.swagger.annotations.Api
;
import
io.swagger.annotations.ApiOperation
;
import
org.springframework.beans.factory.annotation.Autowired
;
import
org.springframework.web.bind.annotation.PostMapping
;
import
org.springframework.web.bind.annotation.RequestBody
;
import
org.springframework.web.bind.annotation.RequestMapping
;
import
org.springframework.web.bind.annotation.RequestMapping
;
import
org.springframework.web.bind.annotation.RestController
;
import
org.springframework.web.bind.annotation.RestController
;
...
@@ -9,5 +20,13 @@ import org.springframework.web.bind.annotation.RestController;
...
@@ -9,5 +20,13 @@ import org.springframework.web.bind.annotation.RestController;
@RequestMapping
(
"/plat/workstation"
)
@RequestMapping
(
"/plat/workstation"
)
public
class
WorkStationController
{
public
class
WorkStationController
{
@Autowired
private
WorkStationService
workStationService
;
@ApiOperation
(
"统计"
)
@PostMapping
(
"statistics"
)
public
ApiResponseEntity
<
WorkStationStatisticsVO
>
statistics
(
@RequestBody
WorkStationQueryDTO
dto
)
{
return
ApiResponseUtils
.
success
(
workStationService
.
statistics
(
dto
));
}
}
}
server-service/src/main/java/com/makeit/dto/platform/dataScreen/PlatDataScreenQueryDTO.java
View file @
098afb54
...
@@ -28,4 +28,5 @@ public class PlatDataScreenQueryDTO {
...
@@ -28,4 +28,5 @@ public class PlatDataScreenQueryDTO {
@JsonFormat
(
pattern
=
"yyyy-MM-dd HH:mm:ss"
)
@JsonFormat
(
pattern
=
"yyyy-MM-dd HH:mm:ss"
)
@ApiModelProperty
(
"结束时间"
)
@ApiModelProperty
(
"结束时间"
)
private
LocalDateTime
endTime
;
private
LocalDateTime
endTime
;
}
}
server-service/src/main/java/com/makeit/dto/platform/workstation/WorkStationQueryDTO.java
0 → 100644
View file @
098afb54
package
com
.
makeit
.
dto
.
platform
.
workstation
;
import
com.fasterxml.jackson.annotation.JsonFormat
;
import
io.swagger.annotations.ApiModel
;
import
io.swagger.annotations.ApiModelProperty
;
import
lombok.Data
;
import
java.time.LocalDateTime
;
import
java.util.List
;
/**
* Controller
*
* @author zm
* @version 2023/9/11
*/
@Data
@ApiModel
(
"PlatDataScreenQueryDto参数"
)
public
class
WorkStationQueryDTO
{
@ApiModelProperty
(
"组织ids"
)
private
List
<
String
>
orgIds
;
@JsonFormat
(
pattern
=
"yyyy-MM-dd HH:mm:ss"
)
@ApiModelProperty
(
"开始时间"
)
private
LocalDateTime
startTime
;
@JsonFormat
(
pattern
=
"yyyy-MM-dd HH:mm:ss"
)
@ApiModelProperty
(
"结束时间"
)
private
LocalDateTime
endTime
;
@ApiModelProperty
(
"长者姓名"
)
private
String
elderName
;
@ApiModelProperty
(
"空间ids"
)
private
List
<
String
>
spaceIds
;
@ApiModelProperty
(
"告警类型"
)
private
String
type
;
}
server-service/src/main/java/com/makeit/service/platform/dataScreen/DataScreenService.java
View file @
098afb54
...
@@ -22,5 +22,5 @@ public interface DataScreenService {
...
@@ -22,5 +22,5 @@ public interface DataScreenService {
PlatBaseInfoStatisticsVO
baseInfoStatistics
(
PlatDataScreenQueryDTO
dto
);
PlatBaseInfoStatisticsVO
baseInfoStatistics
(
PlatDataScreenQueryDTO
dto
);
PlatMapStatisticsVO
mapStatistics
(
PlatDataScreenQueryDTO
dto
);
List
<
PlatMapStatisticsVO
>
mapStatistics
(
PlatDataScreenQueryDTO
dto
);
}
}
server-service/src/main/java/com/makeit/service/platform/dataScreen/impl/DataScreenServiceImpl.java
View file @
098afb54
...
@@ -36,6 +36,7 @@ import org.springframework.stereotype.Service;
...
@@ -36,6 +36,7 @@ import org.springframework.stereotype.Service;
import
java.math.BigDecimal
;
import
java.math.BigDecimal
;
import
java.util.*
;
import
java.util.*
;
import
java.util.function.Function
;
import
java.util.stream.Collectors
;
import
java.util.stream.Collectors
;
/**
/**
...
@@ -136,23 +137,25 @@ public class DataScreenServiceImpl implements DataScreenService {
...
@@ -136,23 +137,25 @@ public class DataScreenServiceImpl implements DataScreenService {
if
(
StringUtil
.
isNotEmpty
(
record
.
getElderIds
())){
if
(
StringUtil
.
isNotEmpty
(
record
.
getElderIds
())){
List
<
String
>
elderIds
=
Arrays
.
asList
(
record
.
getElderIds
().
split
(
","
));
List
<
String
>
elderIds
=
Arrays
.
asList
(
record
.
getElderIds
().
split
(
","
));
PlatAlarmStatisticsListVo
listVo
=
new
PlatAlarmStatisticsListVo
();
PlatAlarmStatisticsListVo
listVo
=
new
PlatAlarmStatisticsListVo
();
String
elderName
=
""
;
for
(
String
elderId
:
elderIds
){
for
(
String
elderId
:
elderIds
){
if
(
elderNameMap
.
get
(
elderId
)!=
null
){
if
(
elderNameMap
.
get
(
elderId
)!=
null
){
listVo
.
setElderName
(
elderNameMap
.
get
(
elderId
)
);
elderName
=
""
.
equals
(
elderName
)
?
elderNameMap
.
get
(
elderId
)
:
elderName
+
","
+
elderNameMap
.
get
(
elderId
);
}
}
listVo
.
setType
(
record
.
getAlarmType
());
if
(
PlatAlarmConfigEnum
.
AlarmTypeEnum
.
HEART
.
getValue
().
equals
(
record
.
getAlarmType
())
||
PlatAlarmConfigEnum
.
AlarmTypeEnum
.
BREATHE
.
getValue
().
equals
(
record
.
getAlarmType
())
){
}
totla
++;
if
(
PlatAlarmRecordEnum
.
AlarmRecordStatusEnum
.
HANDLED
.
getValue
().
equals
(
record
.
getStatus
())){
handledNumber
++;
}
else
{
unhandledNumber
++;
}
list
.
add
(
listVo
);
}
}
if
(
PlatAlarmConfigEnum
.
AlarmTypeEnum
.
HEART
.
getValue
().
equals
(
record
.
getAlarmType
())
||
PlatAlarmConfigEnum
.
AlarmTypeEnum
.
BREATHE
.
getValue
().
equals
(
record
.
getAlarmType
())
){
}
listVo
.
setElderName
(
elderName
);
listVo
.
setType
(
record
.
getAlarmType
());
totla
++;
if
(
PlatAlarmRecordEnum
.
AlarmRecordStatusEnum
.
HANDLED
.
getValue
().
equals
(
record
.
getStatus
())){
handledNumber
++;
}
else
{
unhandledNumber
++;
}
list
.
add
(
listVo
);
}
}
}
}
PlatAlarmStatisticsVO
vo
=
new
PlatAlarmStatisticsVO
();
PlatAlarmStatisticsVO
vo
=
new
PlatAlarmStatisticsVO
();
...
@@ -183,36 +186,82 @@ public class DataScreenServiceImpl implements DataScreenService {
...
@@ -183,36 +186,82 @@ public class DataScreenServiceImpl implements DataScreenService {
}
}
@Override
@Override
public
PlatMapStatisticsVO
mapStatistics
(
PlatDataScreenQueryDTO
dto
)
{
public
List
<
PlatMapStatisticsVO
>
mapStatistics
(
PlatDataScreenQueryDTO
dto
)
{
PlatMapStatisticsVO
vo
=
new
PlatMapStatisticsVO
();
List
<
PlatMapStatisticsVO
>
list
=
new
ArrayList
<>();
List
<
PlatOrg
>
orgs
=
platOrgService
.
list
(
new
QueryWrapper
<
PlatOrg
>().
lambda
()
.
in
(
PlatOrg:
:
getId
,
dto
.
getOrgIds
()));
//取范围最大的管辖区域
List
<
PlatOrg
>
tree
=
platOrgService
.
createOrgTree
(
orgs
);
List
<
String
>
region
=
tree
.
stream
().
filter
(
t
->
StringUtil
.
isNotEmpty
(
t
.
getRegion
())).
map
(
PlatOrg:
:
getRegion
).
collect
(
Collectors
.
toList
());
List
<
ChinaAreaVO
>
areas
=
AreaUtil
.
getByCodeList
(
region
);
List
<
PlatSpace
>
spaces
=
platSpaceService
.
list
(
new
QueryWrapper
<
PlatSpace
>().
lambda
()
List
<
PlatSpace
>
spaces
=
platSpaceService
.
list
(
new
QueryWrapper
<
PlatSpace
>().
lambda
()
.
isNull
(
PlatSpace:
:
getParentId
)
.
isNull
(
PlatSpace:
:
getParentId
)
.
in
(
PlatSpace:
:
getOrgId
,
dto
.
getOrgIds
()));
.
in
(
PlatSpace:
:
getOrgId
,
dto
.
getOrgIds
()));
List
<
PlatElder
>
elders
=
platElderService
.
list
(
new
QueryWrapper
<
PlatElder
>().
lambda
()
List
<
PlatElder
>
elders
=
platElderService
.
list
(
new
QueryWrapper
<
PlatElder
>().
lambda
()
.
isNotNull
(
PlatElder:
:
getBedId
)
.
isNotNull
(
PlatElder:
:
getBedId
)
.
in
(
PlatElder:
:
getOrgId
,
dto
.
getOrgIds
()));
.
in
(
PlatElder:
:
getOrgId
,
dto
.
getOrgIds
()));
for
(
PlatElder
elder
:
elders
){
if
(
StringUtil
.
isNotEmpty
(
elder
.
getStreetSpaceId
())){
elder
.
setSpaceId
(
elder
.
getStreetSpaceId
());
}
else
{
if
(
StringUtil
.
isNotEmpty
(
elder
.
getBuildingSpaceId
()))
{
elder
.
setSpaceId
(
elder
.
getBuildingSpaceId
());
}
else
{
if
(
StringUtil
.
isNotEmpty
(
elder
.
getUnitSpaceId
())){
elder
.
setSpaceId
(
elder
.
getUnitSpaceId
());
}
else
{
if
(
StringUtil
.
isNotEmpty
(
elder
.
getFloorSpaceId
())){
elder
.
setSpaceId
(
elder
.
getFloorSpaceId
());
}
}
}
}
}
Map
<
String
,
List
<
PlatElder
>>
elderMap
=
elders
.
stream
().
collect
(
Collectors
.
groupingBy
(
PlatElder:
:
getSpaceId
));
Map
<
String
,
List
<
PlatElder
>>
elderMap
=
elders
.
stream
().
collect
(
Collectors
.
groupingBy
(
PlatElder:
:
getSpaceId
));
List
<
PlatMapStatisticsSpaceVO
>
list
=
new
ArrayList
<>();
Map
<
String
,
PlatElder
>
platElderMap
=
elders
.
stream
().
collect
(
Collectors
.
toMap
(
PlatElder:
:
getId
,
Function
.
identity
()));
//今日告警
List
<
PlatAlarmRecord
>
alarmRecords
=
platAlarmRecordService
.
list
(
new
QueryWrapper
<
PlatAlarmRecord
>().
lambda
()
.
between
(
PlatAlarmRecord:
:
getAlarmDate
,
dto
.
getStartTime
(),
dto
.
getEndTime
())
.
in
(
PlatAlarmRecord:
:
getOrgId
,
dto
.
getOrgIds
()));
List
<
PlatAlarmRecordStatisticsVo
>
statisticsVos
=
coverToVoList
(
alarmRecords
,
platElderMap
);
Map
<
String
,
List
<
PlatAlarmRecordStatisticsVo
>>
staticsMap
=
statisticsVos
.
stream
().
collect
(
Collectors
.
groupingBy
(
PlatAlarmRecordStatisticsVo:
:
getSpaceId
));
//待处理告警
List
<
PlatAlarmRecord
>
unHandledAlarmRecords
=
platAlarmRecordService
.
list
(
new
QueryWrapper
<
PlatAlarmRecord
>().
lambda
()
.
eq
(
PlatAlarmRecord:
:
getStatus
,
PlatAlarmRecordEnum
.
AlarmRecordStatusEnum
.
UNHANDLED
.
getValue
())
.
in
(
PlatAlarmRecord:
:
getOrgId
,
dto
.
getOrgIds
()));
List
<
PlatAlarmRecordStatisticsVo
>
unHandledStatisticsVos
=
coverToVoList
(
unHandledAlarmRecords
,
platElderMap
);
Map
<
String
,
List
<
PlatAlarmRecordStatisticsVo
>>
unHandledStaticsMap
=
unHandledStatisticsVos
.
stream
().
collect
(
Collectors
.
groupingBy
(
PlatAlarmRecordStatisticsVo:
:
getSpaceId
));
for
(
PlatSpace
space
:
spaces
){
for
(
PlatSpace
space
:
spaces
){
PlatMapStatistics
SpaceVO
spaceVo
=
new
PlatMapStatisticsSpace
VO
();
PlatMapStatistics
VO
vo
=
new
PlatMapStatistics
VO
();
spaceV
o
.
setSpaceId
(
space
.
getId
());
v
o
.
setSpaceId
(
space
.
getId
());
spaceV
o
.
setSpaceName
(
space
.
getName
());
v
o
.
setSpaceName
(
space
.
getName
());
spaceV
o
.
setLatitude
(
space
.
getLatitude
());
v
o
.
setLatitude
(
space
.
getLatitude
());
spaceV
o
.
setLongitude
(
space
.
getLongitude
());
v
o
.
setLongitude
(
space
.
getLongitude
());
if
(
elderMap
.
get
(
space
.
getId
())!=
null
){
if
(
elderMap
.
get
(
space
.
getId
())!=
null
){
spaceV
o
.
setElderNumber
(
Long
.
valueOf
(
elderMap
.
get
(
space
.
getId
()).
size
()));
v
o
.
setElderNumber
(
Long
.
valueOf
(
elderMap
.
get
(
space
.
getId
()).
size
()));
}
}
if
(
staticsMap
.
get
(
space
.
getId
())!=
null
){
vo
.
setAlarmNumber
(
Long
.
valueOf
(
staticsMap
.
get
(
space
.
getId
()).
size
()));
}
if
(
unHandledStaticsMap
.
get
(
space
.
getId
())!=
null
){
vo
.
setUnHandledNumber
(
Long
.
valueOf
(
unHandledStaticsMap
.
get
(
space
.
getId
()).
size
()));
}
list
.
add
(
vo
);
}
}
vo
.
setAreas
(
areas
);
return
vo
;
return
list
;
}
private
List
<
PlatAlarmRecordStatisticsVo
>
coverToVoList
(
List
<
PlatAlarmRecord
>
alarmRecords
,
Map
<
String
,
PlatElder
>
platElderMap
)
{
List
<
PlatAlarmRecordStatisticsVo
>
statisticsVos
=
new
ArrayList
<>();
alarmRecords
.
forEach
(
record
->{
List
<
String
>
elderIds
=
Arrays
.
asList
(
record
.
getElderIds
().
split
(
","
));
if
(
StringUtil
.
isNotEmpty
(
record
.
getElderIds
())
&&
elderIds
.
size
()>
0
){
if
(
platElderMap
.
get
(
elderIds
.
get
(
0
))!=
null
){
PlatAlarmRecordStatisticsVo
statisticsVo
=
BeanDtoVoUtils
.
convert
(
record
,
PlatAlarmRecordStatisticsVo
.
class
);
statisticsVo
.
setSpaceId
(
platElderMap
.
get
(
elderIds
.
get
(
0
)).
getSpaceId
());
statisticsVos
.
add
(
statisticsVo
);
}
}
});
return
statisticsVos
;
}
}
...
...
server-service/src/main/java/com/makeit/service/platform/space/impl/PlatSpaceServiceImpl.java
View file @
098afb54
...
@@ -5,14 +5,18 @@ import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
...
@@ -5,14 +5,18 @@ import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import
com.makeit.dto.platform.space.PlatSpaceAddDTO
;
import
com.makeit.dto.platform.space.PlatSpaceAddDTO
;
import
com.makeit.dto.platform.space.PlatSpaceQueryDTO
;
import
com.makeit.dto.platform.space.PlatSpaceQueryDTO
;
import
com.makeit.dto.platform.space.PlatSpaceVO
;
import
com.makeit.dto.platform.space.PlatSpaceVO
;
import
com.makeit.entity.platform.auth.PlatOrg
;
import
com.makeit.entity.platform.space.PlatRoom
;
import
com.makeit.entity.platform.space.PlatRoom
;
import
com.makeit.entity.platform.space.PlatSpace
;
import
com.makeit.entity.platform.space.PlatSpace
;
import
com.makeit.enums.CodeMessageEnum
;
import
com.makeit.enums.CodeMessageEnum
;
import
com.makeit.exception.BusinessException
;
import
com.makeit.exception.BusinessException
;
import
com.makeit.mapper.platform.space.PlatSpaceMapper
;
import
com.makeit.mapper.platform.space.PlatSpaceMapper
;
import
com.makeit.service.platform.auth.PlatOrgService
;
import
com.makeit.service.platform.space.PlatRoomService
;
import
com.makeit.service.platform.space.PlatRoomService
;
import
com.makeit.service.platform.space.PlatSpaceService
;
import
com.makeit.service.platform.space.PlatSpaceService
;
import
com.makeit.utils.data.convert.BeanDtoVoUtils
;
import
com.makeit.utils.data.convert.BeanDtoVoUtils
;
import
com.makeit.utils.user.plat.PlatUserUtil
;
import
com.makeit.utils.user.plat.PlatUserVO
;
import
com.makeit.vo.platform.space.PlatSpaceAndRoomVO
;
import
com.makeit.vo.platform.space.PlatSpaceAndRoomVO
;
import
jodd.util.StringUtil
;
import
jodd.util.StringUtil
;
import
org.springframework.beans.factory.annotation.Autowired
;
import
org.springframework.beans.factory.annotation.Autowired
;
...
@@ -34,6 +38,8 @@ public class PlatSpaceServiceImpl extends ServiceImpl<PlatSpaceMapper, PlatSpace
...
@@ -34,6 +38,8 @@ public class PlatSpaceServiceImpl extends ServiceImpl<PlatSpaceMapper, PlatSpace
@Autowired
@Autowired
private
PlatRoomService
platRoomService
;
private
PlatRoomService
platRoomService
;
@Autowired
private
PlatOrgService
platOrgService
;
private
void
check
(
PlatSpaceAddDTO
dto
){
private
void
check
(
PlatSpaceAddDTO
dto
){
LambdaQueryWrapper
<
PlatSpace
>
queryWrapper
=
new
LambdaQueryWrapper
<>();
LambdaQueryWrapper
<
PlatSpace
>
queryWrapper
=
new
LambdaQueryWrapper
<>();
...
@@ -57,6 +63,12 @@ public class PlatSpaceServiceImpl extends ServiceImpl<PlatSpaceMapper, PlatSpace
...
@@ -57,6 +63,12 @@ public class PlatSpaceServiceImpl extends ServiceImpl<PlatSpaceMapper, PlatSpace
public
void
add
(
PlatSpaceAddDTO
dto
)
{
public
void
add
(
PlatSpaceAddDTO
dto
)
{
check
(
dto
);
check
(
dto
);
PlatSpace
space
=
BeanDtoVoUtils
.
convert
(
dto
,
PlatSpace
.
class
);
PlatSpace
space
=
BeanDtoVoUtils
.
convert
(
dto
,
PlatSpace
.
class
);
PlatUserVO
userVO
=
PlatUserUtil
.
getUserVO
();
space
.
setOrgId
(
userVO
.
getOrgId
());
PlatOrg
org
=
platOrgService
.
getById
(
userVO
.
getOrgId
());
if
(
org
!=
null
){
space
.
setAttribute
(
org
.
getType
());
}
save
(
space
);
save
(
space
);
}
}
...
...
server-service/src/main/java/com/makeit/service/platform/workstation/WorkStationService.java
0 → 100644
View file @
098afb54
package
com
.
makeit
.
service
.
platform
.
workstation
;
import
com.makeit.dto.platform.workstation.WorkStationQueryDTO
;
import
com.makeit.vo.platform.workstation.WorkStationStatisticsVO
;
/**
* Controller
*
* @author zm
* @version 2023/9/11
*/
public
interface
WorkStationService
{
WorkStationStatisticsVO
statistics
(
WorkStationQueryDTO
dto
);
}
server-service/src/main/java/com/makeit/service/platform/workstation/impl/WorkStationServiceImpl.java
0 → 100644
View file @
098afb54
package
com
.
makeit
.
service
.
platform
.
workstation
.
impl
;
import
com.baomidou.mybatisplus.core.conditions.query.QueryWrapper
;
import
com.makeit.dto.platform.dataScreen.PlatDataScreenQueryDTO
;
import
com.makeit.dto.platform.workstation.WorkStationQueryDTO
;
import
com.makeit.entity.platform.alarm.PlatAlarmRecord
;
import
com.makeit.entity.platform.auth.PlatUser
;
import
com.makeit.entity.platform.device.PlatDevice
;
import
com.makeit.entity.platform.elder.PlatElder
;
import
com.makeit.entity.platform.space.PlatSpace
;
import
com.makeit.enums.CommonEnum
;
import
com.makeit.enums.platform.alarm.PlatAlarmConfigEnum
;
import
com.makeit.enums.platform.alarm.PlatAlarmRecordEnum
;
import
com.makeit.enums.platform.device.PlatDeviceEnum
;
import
com.makeit.enums.platform.elder.PlatElderEnum
;
import
com.makeit.module.iot.enums.DeviceState
;
import
com.makeit.service.platform.alarm.PlatAlarmRecordService
;
import
com.makeit.service.platform.auth.PlatOrgService
;
import
com.makeit.service.platform.auth.PlatUserService
;
import
com.makeit.service.platform.dataScreen.DataScreenService
;
import
com.makeit.service.platform.device.PlatDeviceService
;
import
com.makeit.service.platform.elder.PlatElderService
;
import
com.makeit.service.platform.space.PlatBedService
;
import
com.makeit.service.platform.space.PlatSpaceService
;
import
com.makeit.service.platform.workstation.WorkStationService
;
import
com.makeit.utils.data.convert.BeanDtoVoUtils
;
import
com.makeit.vo.platform.dataScreen.*
;
import
com.makeit.vo.platform.workstation.WorkStationStatisticsVO
;
import
jodd.util.StringUtil
;
import
org.springframework.beans.factory.annotation.Autowired
;
import
org.springframework.stereotype.Service
;
import
java.math.BigDecimal
;
import
java.util.ArrayList
;
import
java.util.Arrays
;
import
java.util.List
;
import
java.util.Map
;
import
java.util.function.Function
;
import
java.util.stream.Collectors
;
/**
* Controller
*
* @author zm
* @version 2023/9/11
*/
@Service
public
class
WorkStationServiceImpl
implements
WorkStationService
{
@Autowired
private
PlatElderService
platElderService
;
@Autowired
private
PlatDeviceService
platDeviceService
;
@Autowired
private
PlatBedService
platBedService
;
@Autowired
private
PlatUserService
platUserService
;
@Autowired
private
PlatAlarmRecordService
platAlarmRecordService
;
@Autowired
private
PlatSpaceService
platSpaceService
;
@Autowired
private
PlatOrgService
platOrgService
;
@Override
public
WorkStationStatisticsVO
statistics
(
WorkStationQueryDTO
dto
)
{
WorkStationStatisticsVO
vo
=
new
WorkStationStatisticsVO
();
//代处理告警
long
unHandledNumber
=
platAlarmRecordService
.
count
(
new
QueryWrapper
<
PlatAlarmRecord
>().
lambda
()
.
eq
(
PlatAlarmRecord:
:
getStatus
,
PlatAlarmRecordEnum
.
AlarmRecordStatusEnum
.
UNHANDLED
.
getValue
())
.
in
(
PlatAlarmRecord:
:
getOrgId
,
dto
.
getOrgIds
()));
vo
.
setUnHandledNumber
(
unHandledNumber
);
return
null
;
}
}
server-service/src/main/java/com/makeit/vo/platform/dataScreen/PlatAlarmRecordStatisticsVo.java
0 → 100644
View file @
098afb54
package
com
.
makeit
.
vo
.
platform
.
dataScreen
;
import
io.swagger.annotations.ApiModel
;
import
io.swagger.annotations.ApiModelProperty
;
import
lombok.Data
;
import
java.time.LocalDateTime
;
import
java.util.Date
;
/**
* Controller
*
* @author zm
* @version 2023/9/13
*/
@Data
@ApiModel
(
"PlatAlarmRecordStatisticsVo对象"
)
public
class
PlatAlarmRecordStatisticsVo
{
/**
* 告警时间
*/
private
Date
alarmDate
;
/**
* 状态 0 待处理 1 已处理
*/
private
String
status
;
/**
* 组织id
*/
private
String
orgId
;
/**
* 老人id,逗号拼接
*/
private
String
elderIds
;
/**
* 空间id
*/
private
String
spaceId
;
}
server-service/src/main/java/com/makeit/vo/platform/dataScreen/PlatMapStatisticsVO.java
View file @
098afb54
...
@@ -2,6 +2,7 @@ package com.makeit.vo.platform.dataScreen;
...
@@ -2,6 +2,7 @@ package com.makeit.vo.platform.dataScreen;
import
com.makeit.utils.area.ChinaAreaVO
;
import
com.makeit.utils.area.ChinaAreaVO
;
import
io.swagger.annotations.ApiModel
;
import
io.swagger.annotations.ApiModel
;
import
io.swagger.annotations.ApiModelProperty
;
import
lombok.Data
;
import
lombok.Data
;
import
java.util.List
;
import
java.util.List
;
...
@@ -16,8 +17,22 @@ import java.util.List;
...
@@ -16,8 +17,22 @@ import java.util.List;
@ApiModel
(
"PlatMapStatisticsVO对象"
)
@ApiModel
(
"PlatMapStatisticsVO对象"
)
public
class
PlatMapStatisticsVO
{
public
class
PlatMapStatisticsVO
{
private
List
<
ChinaAreaVO
>
areas
;
@ApiModelProperty
(
value
=
"空间id"
)
private
List
<
PlatMapStatisticsSpaceVO
>
spaceList
;
private
String
spaceId
;
@ApiModelProperty
(
value
=
"空间名称"
)
private
String
spaceName
;
@ApiModelProperty
(
value
=
"空间地址"
)
private
String
address
;
@ApiModelProperty
(
value
=
"经度"
)
private
String
longitude
;
@ApiModelProperty
(
value
=
"纬度"
)
private
String
latitude
;
@ApiModelProperty
(
value
=
"长者数量"
)
private
Long
elderNumber
;
@ApiModelProperty
(
value
=
"今日告警数"
)
private
Long
alarmNumber
;
@ApiModelProperty
(
value
=
"待处理告警"
)
private
Long
unHandledNumber
;
}
}
server-service/src/main/java/com/makeit/vo/platform/
dataScreen/PlatMapStatisticsSpace
VO.java
→
server-service/src/main/java/com/makeit/vo/platform/
workstation/WorkStationStatistics
VO.java
View file @
098afb54
package
com
.
makeit
.
vo
.
platform
.
dataScree
n
;
package
com
.
makeit
.
vo
.
platform
.
workstatio
n
;
import
io.swagger.annotations.ApiModel
;
import
io.swagger.annotations.ApiModel
;
import
io.swagger.annotations.ApiModelProperty
;
import
io.swagger.annotations.ApiModelProperty
;
...
@@ -8,27 +8,12 @@ import lombok.Data;
...
@@ -8,27 +8,12 @@ import lombok.Data;
* Controller
* Controller
*
*
* @author zm
* @author zm
* @version 2023/9/1
1
* @version 2023/9/1
3
*/
*/
@Data
@Data
@ApiModel
(
"
PlatMapStatisticsSpace
VO对象"
)
@ApiModel
(
"
WorkStationStatistics
VO对象"
)
public
class
PlatMapStatisticsSpace
VO
{
public
class
WorkStationStatistics
VO
{
@ApiModelProperty
(
value
=
"空间id"
)
private
String
spaceId
;
@ApiModelProperty
(
value
=
"空间名称"
)
private
String
spaceName
;
@ApiModelProperty
(
value
=
"空间地址"
)
private
String
address
;
@ApiModelProperty
(
value
=
"经度"
)
private
String
longitude
;
@ApiModelProperty
(
value
=
"纬度"
)
private
String
latitude
;
@ApiModelProperty
(
value
=
"长者数量"
)
private
Long
elderNumber
;
@ApiModelProperty
(
value
=
"今日告警数"
)
private
Long
alarmNumber
;
@ApiModelProperty
(
value
=
"待处理告警"
)
@ApiModelProperty
(
value
=
"待处理告警"
)
private
Long
unHandledNumber
;
private
Long
unHandledNumber
;
}
}
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