Skip to content
项目
群组
代码片段
帮助
当前项目
正在载入...
登录 / 注册
切换导航面板
D
device-back
项目
项目
详情
活动
周期分析
仓库
仓库
文件
提交
分支
标签
贡献者
图表
比较
统计图
议题
1
议题
1
列表
看板
标记
里程碑
合并请求
0
合并请求
0
CI / CD
CI / CD
流水线
作业
日程
统计图
Wiki
Wiki
代码片段
代码片段
成员
成员
折叠边栏
关闭边栏
活动
图像
聊天
创建新问题
作业
提交
问题看板
Open sidebar
Matrix
device-back
Commits
9039c4cb
提交
9039c4cb
authored
11月 26, 2021
作者:
zhoushaopan
浏览文件
操作
浏览文件
下载
电子邮件补丁
差异文件
feat(退回模块,配套模块,维修模块,用户使用报告模块): 使用缓存
使用缓存
上级
34ff67ce
显示空白字符变更
内嵌
并排
正在显示
8 个修改的文件
包含
69 行增加
和
31 行删除
+69
-31
BackController.java
.../com/tykj/dev/device/allot/controller/BackController.java
+6
-1
MatchingDeviceLibraryServiceImpl.java
...tching/service/impl/MatchingDeviceLibraryServiceImpl.java
+7
-1
RepairController.java
...m/tykj/dev/device/repair/controller/RepairController.java
+21
-13
RepairDetailServiceImpl.java
...v/device/repair/service/impl/RepairDetailServiceImpl.java
+7
-1
BigScreenServiceImpl.java
...kj/dev/statistical/service/impl/BigScreenServiceImpl.java
+2
-1
StatisticalServiceImpl.java
.../dev/statistical/service/impl/StatisticalServiceImpl.java
+7
-5
DeviceUseReportController.java
...evice/usereport/controller/DeviceUseReportController.java
+7
-1
DeviceUseReportServiceImpl.java
...ce/usereport/service/impl/DeviceUseReportServiceImpl.java
+12
-8
没有找到文件。
dev-allot/src/main/java/com/tykj/dev/device/allot/controller/BackController.java
浏览文件 @
9039c4cb
...
@@ -22,6 +22,7 @@ import com.tykj.dev.device.repair.subject.vo.DeviceDetailVo;
...
@@ -22,6 +22,7 @@ import com.tykj.dev.device.repair.subject.vo.DeviceDetailVo;
import
com.tykj.dev.device.repair.subject.vo.RevokeUnderTask
;
import
com.tykj.dev.device.repair.subject.vo.RevokeUnderTask
;
import
com.tykj.dev.device.task.service.TaskService
;
import
com.tykj.dev.device.task.service.TaskService
;
import
com.tykj.dev.device.task.subject.bto.TaskBto
;
import
com.tykj.dev.device.task.subject.bto.TaskBto
;
import
com.tykj.dev.device.user.cache.UnitsCache
;
import
com.tykj.dev.device.user.read.service.MessageService
;
import
com.tykj.dev.device.user.read.service.MessageService
;
import
com.tykj.dev.device.user.read.subject.bto.MessageBto
;
import
com.tykj.dev.device.user.read.subject.bto.MessageBto
;
import
com.tykj.dev.device.user.subject.dao.UserDao
;
import
com.tykj.dev.device.user.subject.dao.UserDao
;
...
@@ -93,6 +94,9 @@ public class BackController {
...
@@ -93,6 +94,9 @@ public class BackController {
@Autowired
@Autowired
private
UnitsService
unitsService
;
private
UnitsService
unitsService
;
@Autowired
private
UnitsCache
unitsCache
;
@ApiOperation
(
value
=
"发起退回业务"
,
notes
=
"可以通过这个接口发起退回任务"
)
@ApiOperation
(
value
=
"发起退回业务"
,
notes
=
"可以通过这个接口发起退回任务"
)
@PostMapping
(
value
=
"/addBackBill"
)
@PostMapping
(
value
=
"/addBackBill"
)
@Transactional
(
rollbackFor
=
Exception
.
class
)
@Transactional
(
rollbackFor
=
Exception
.
class
)
...
@@ -965,7 +969,8 @@ public class BackController {
...
@@ -965,7 +969,8 @@ public class BackController {
AllotBackBill
allotBackBill
=
allotBackBillService
.
getOne
(
billId
);
AllotBackBill
allotBackBill
=
allotBackBillService
.
getOne
(
billId
);
//修改装备得所属所在
//修改装备得所属所在
// deviceLibraryService.updateLocalAndOwn(allotBackBill.getReceiveUnit(),deviceIds);
// deviceLibraryService.updateLocalAndOwn(allotBackBill.getReceiveUnit(),deviceIds);
deviceLibraryService
.
updateLocalAndOwn
(
unitsService
.
findById
(
allotBackBill
.
getReceiveUnitId
()).
getName
(),
deviceIds
);
// deviceLibraryService.updateLocalAndOwn(unitsService.findById(allotBackBill.getReceiveUnitId()).getName(),deviceIds);
deviceLibraryService
.
updateLocalAndOwn
(
unitsCache
.
findById
(
allotBackBill
.
getReceiveUnitId
()).
getName
(),
deviceIds
);
allotBackBillService
.
deleteByAllotBackId
(
billId
);
allotBackBillService
.
deleteByAllotBackId
(
billId
);
taskService
.
deleteById
(
taskId
);
taskService
.
deleteById
(
taskId
);
return
ResponseEntity
.
ok
(
"撤回成功"
);
return
ResponseEntity
.
ok
(
"撤回成功"
);
...
...
dev-matching/src/main/java/com/tykj/dev/device/matching/service/impl/MatchingDeviceLibraryServiceImpl.java
浏览文件 @
9039c4cb
...
@@ -13,6 +13,7 @@ import com.tykj.dev.device.matching.subject.domin.MatchingDeviceLibrary;
...
@@ -13,6 +13,7 @@ import com.tykj.dev.device.matching.subject.domin.MatchingDeviceLibrary;
import
com.tykj.dev.device.matching.subject.vo.MatchingUnitVo
;
import
com.tykj.dev.device.matching.subject.vo.MatchingUnitVo
;
import
com.tykj.dev.device.matching.subject.vo.MatchingDeviceSelectVo
;
import
com.tykj.dev.device.matching.subject.vo.MatchingDeviceSelectVo
;
import
com.tykj.dev.device.matching.subject.vo.RelationDeviceVo
;
import
com.tykj.dev.device.matching.subject.vo.RelationDeviceVo
;
import
com.tykj.dev.device.user.cache.UnitsCache
;
import
com.tykj.dev.device.user.subject.entity.Units
;
import
com.tykj.dev.device.user.subject.entity.Units
;
import
com.tykj.dev.device.user.subject.service.UnitsService
;
import
com.tykj.dev.device.user.subject.service.UnitsService
;
import
com.tykj.dev.device.user.subject.service.UserPublicService
;
import
com.tykj.dev.device.user.subject.service.UserPublicService
;
...
@@ -31,6 +32,7 @@ import org.springframework.data.domain.Pageable;
...
@@ -31,6 +32,7 @@ import org.springframework.data.domain.Pageable;
import
org.springframework.scheduling.annotation.Async
;
import
org.springframework.scheduling.annotation.Async
;
import
org.springframework.stereotype.Service
;
import
org.springframework.stereotype.Service
;
import
javax.annotation.Resource
;
import
javax.persistence.Transient
;
import
javax.persistence.Transient
;
import
java.lang.reflect.Field
;
import
java.lang.reflect.Field
;
import
java.util.*
;
import
java.util.*
;
...
@@ -62,6 +64,9 @@ public class MatchingDeviceLibraryServiceImpl implements MatchingDeviceLibrarySe
...
@@ -62,6 +64,9 @@ public class MatchingDeviceLibraryServiceImpl implements MatchingDeviceLibrarySe
@Autowired
@Autowired
private
RfidService
rfidService
;
private
RfidService
rfidService
;
@Resource
private
UnitsCache
unitsCache
;
@Override
@Override
public
MatchingDeviceLibrary
addEntity
(
MatchingDeviceLibrary
matchingDeviceLibraryEntity
)
{
public
MatchingDeviceLibrary
addEntity
(
MatchingDeviceLibrary
matchingDeviceLibraryEntity
)
{
MatchingDeviceLibrary
matchingDeviceLibrary
=
matchingDeviceLibraryDao
.
save
(
matchingDeviceLibraryEntity
);
MatchingDeviceLibrary
matchingDeviceLibrary
=
matchingDeviceLibraryDao
.
save
(
matchingDeviceLibraryEntity
);
...
@@ -199,7 +204,8 @@ public class MatchingDeviceLibraryServiceImpl implements MatchingDeviceLibrarySe
...
@@ -199,7 +204,8 @@ public class MatchingDeviceLibraryServiceImpl implements MatchingDeviceLibrarySe
// .collect(Collectors.toList());
// .collect(Collectors.toList());
List
<
MatchingDeviceLibrary
>
resultList
=
matchingDeviceLibraryDao
.
findAll
(
getPredicate
(
matchingDeviceSelectVo
).
build
())
List
<
MatchingDeviceLibrary
>
resultList
=
matchingDeviceLibraryDao
.
findAll
(
getPredicate
(
matchingDeviceSelectVo
).
build
())
.
stream
()
.
stream
()
.
filter
(
matchingDeviceLibraryEntity
->
units
.
contains
(
unitsService
.
findById
(
matchingDeviceLibraryEntity
.
getCreateUnitId
()).
getName
()))
.
filter
(
matchingDeviceLibraryEntity
->
units
.
contains
(
unitsCache
.
findById
(
matchingDeviceLibraryEntity
.
getCreateUnitId
()).
getName
()))
.
collect
(
Collectors
.
toList
());
.
collect
(
Collectors
.
toList
());
// List<MatchingDeviceLibrary> resultList = matchingDeviceLibraryDao.findAll().stream()
// List<MatchingDeviceLibrary> resultList = matchingDeviceLibraryDao.findAll().stream()
// .filter(matchingDeviceLibraryEntity -> units.contains(matchingDeviceLibraryEntity.getCreateUnit()))
// .filter(matchingDeviceLibraryEntity -> units.contains(matchingDeviceLibraryEntity.getCreateUnit()))
...
...
dev-repair/src/main/java/com/tykj/dev/device/repair/controller/RepairController.java
浏览文件 @
9039c4cb
...
@@ -31,6 +31,7 @@ import com.tykj.dev.device.task.service.TaskLogService;
...
@@ -31,6 +31,7 @@ import com.tykj.dev.device.task.service.TaskLogService;
import
com.tykj.dev.device.task.service.TaskService
;
import
com.tykj.dev.device.task.service.TaskService
;
import
com.tykj.dev.device.task.subject.bto.TaskBto
;
import
com.tykj.dev.device.task.subject.bto.TaskBto
;
import
com.tykj.dev.device.task.subject.vo.TaskUserVo
;
import
com.tykj.dev.device.task.subject.vo.TaskUserVo
;
import
com.tykj.dev.device.user.cache.UnitsCache
;
import
com.tykj.dev.device.user.read.service.MessageService
;
import
com.tykj.dev.device.user.read.service.MessageService
;
import
com.tykj.dev.device.user.read.subject.bto.MessageBto
;
import
com.tykj.dev.device.user.read.subject.bto.MessageBto
;
import
com.tykj.dev.device.user.subject.dao.UserDao
;
import
com.tykj.dev.device.user.subject.dao.UserDao
;
...
@@ -55,6 +56,7 @@ import org.springframework.transaction.annotation.Transactional;
...
@@ -55,6 +56,7 @@ import org.springframework.transaction.annotation.Transactional;
import
org.springframework.validation.annotation.Validated
;
import
org.springframework.validation.annotation.Validated
;
import
org.springframework.web.bind.annotation.*
;
import
org.springframework.web.bind.annotation.*
;
import
javax.annotation.Resource
;
import
java.util.*
;
import
java.util.*
;
import
java.util.concurrent.Executor
;
import
java.util.concurrent.Executor
;
import
java.util.stream.Collectors
;
import
java.util.stream.Collectors
;
...
@@ -144,6 +146,9 @@ public class RepairController {
...
@@ -144,6 +146,9 @@ public class RepairController {
@Autowired
@Autowired
private
RepairDetailService
repairDetailService
;
private
RepairDetailService
repairDetailService
;
@Resource
private
UnitsCache
unitsCache
;
@ApiOperation
(
value
=
"判断维修装备是否同一个送修单位"
,
notes
=
"可以通过这个接口判断维修装备是否同一个送修单位"
)
@ApiOperation
(
value
=
"判断维修装备是否同一个送修单位"
,
notes
=
"可以通过这个接口判断维修装备是否同一个送修单位"
)
@PostMapping
(
value
=
"/judge"
)
@PostMapping
(
value
=
"/judge"
)
@Transactional
(
rollbackFor
=
Exception
.
class
)
@Transactional
(
rollbackFor
=
Exception
.
class
)
...
@@ -161,7 +166,8 @@ public class RepairController {
...
@@ -161,7 +166,8 @@ public class RepairController {
List
<
Integer
>
collect
=
sendUnits
.
stream
().
distinct
().
collect
(
Collectors
.
toList
());
List
<
Integer
>
collect
=
sendUnits
.
stream
().
distinct
().
collect
(
Collectors
.
toList
());
//如果是同一单位返回单位名称,否则返error
//如果是同一单位返回单位名称,否则返error
if
(
collect
.
size
()
==
1
)
{
if
(
collect
.
size
()
==
1
)
{
Units
units
=
unitsService
.
findById
(
collect
.
get
(
0
));
// Units units = unitsService.findById(collect.get(0));
Units
units
=
unitsCache
.
findById
(
collect
.
get
(
0
));
// return ResponseEntity.ok(sendUnits.iterator().next());
// return ResponseEntity.ok(sendUnits.iterator().next());
return
ResponseEntity
.
ok
(
units
);
return
ResponseEntity
.
ok
(
units
);
}
else
{
}
else
{
...
@@ -1577,7 +1583,7 @@ public class RepairController {
...
@@ -1577,7 +1583,7 @@ public class RepairController {
//获取旧状态 下级送来的
//获取旧状态 下级送来的
Integer
oldStatus
=
repairDetail1
.
getRepairStatus
();
Integer
oldStatus
=
repairDetail1
.
getRepairStatus
();
// if (repairStatusChangeVo.getNewStatus() == 2 && repairDetail1.getOwnUnit().equals(userUtils.getCurrentUserUnitName())) {
// if (repairStatusChangeVo.getNewStatus() == 2 && repairDetail1.getOwnUnit().equals(userUtils.getCurrentUserUnitName())) {
if
(
repairStatusChangeVo
.
getNewStatus
()
==
2
&&
units
Servic
e
.
findById
(
repairDetail1
.
getOwnUnitId
()).
getName
().
equals
(
userUtils
.
getCurrentUserUnitName
()))
{
if
(
repairStatusChangeVo
.
getNewStatus
()
==
2
&&
units
Cach
e
.
findById
(
repairDetail1
.
getOwnUnitId
()).
getName
().
equals
(
userUtils
.
getCurrentUserUnitName
()))
{
repairDetail1
.
setRepairStatus
(
5
);
repairDetail1
.
setRepairStatus
(
5
);
}
else
{
}
else
{
//修改当前任务维修详情单该装备状态
//修改当前任务维修详情单该装备状态
...
@@ -1991,7 +1997,7 @@ public class RepairController {
...
@@ -1991,7 +1997,7 @@ public class RepairController {
// .filter(repairDetail -> repairDetail.getRepairBackBillId()!=null)
// .filter(repairDetail -> repairDetail.getRepairBackBillId()!=null)
// .collect(Collectors.toList());
// .collect(Collectors.toList());
List
<
RepairDetail
>
repairDetails2
=
repairDetails
.
stream
()
List
<
RepairDetail
>
repairDetails2
=
repairDetails
.
stream
()
.
filter
(
repairDetail
->
units
.
contains
(
units
Servic
e
.
findById
(
repairDetail
.
getLocationUnitId
()).
getName
())
.
filter
(
repairDetail
->
units
.
contains
(
units
Cach
e
.
findById
(
repairDetail
.
getLocationUnitId
()).
getName
())
&&
(!
hasYear
||
repairDetail
.
getUpdateTime
().
getYear
()
==
year
-
1900
))
&&
(!
hasYear
||
repairDetail
.
getUpdateTime
().
getYear
()
==
year
-
1900
))
.
filter
(
repairDetail
->
repairDetail
.
getRepairBackBillId
()!=
null
)
.
filter
(
repairDetail
->
repairDetail
.
getRepairBackBillId
()!=
null
)
.
collect
(
Collectors
.
toList
());
.
collect
(
Collectors
.
toList
());
...
@@ -2080,7 +2086,9 @@ public class RepairController {
...
@@ -2080,7 +2086,9 @@ public class RepairController {
//所在在当前单位的
//所在在当前单位的
// List<RepairDetail> repairDetails2 = repairDetails.stream().filter(repairDetail -> repairDetail.getLocationUnit().equals(unitName)).collect(Collectors.toList());
// List<RepairDetail> repairDetails2 = repairDetails.stream().filter(repairDetail -> repairDetail.getLocationUnit().equals(unitName)).collect(Collectors.toList());
List
<
RepairDetail
>
repairDetails2
=
repairDetails
.
stream
().
filter
(
repairDetail
->
List
<
RepairDetail
>
repairDetails2
=
repairDetails
.
stream
().
filter
(
repairDetail
->
unitsService
.
findById
(
repairDetail
.
getLocationUnitId
()).
getName
().
equals
(
unitName
)).
collect
(
Collectors
.
toList
());
// unitsService.findById(repairDetail.getLocationUnitId()).getName().equals(unitName))
unitsCache
.
findById
(
repairDetail
.
getLocationUnitId
()).
getName
().
equals
(
unitName
))
.
collect
(
Collectors
.
toList
());
List
<
WaitingRepairEquipmentVo
>
waitingRepairEquipments
=
new
ArrayList
<>();
List
<
WaitingRepairEquipmentVo
>
waitingRepairEquipments
=
new
ArrayList
<>();
for
(
RepairDetail
repairDetail
:
repairDetails2
)
{
for
(
RepairDetail
repairDetail
:
repairDetails2
)
{
TaskBto
taskBto
=
taskService
.
getParentTaskIsNull
(
repairDetail
.
getDeviceRepairBillId
(),
5
);
TaskBto
taskBto
=
taskService
.
getParentTaskIsNull
(
repairDetail
.
getDeviceRepairBillId
(),
5
);
...
@@ -2605,23 +2613,23 @@ public class RepairController {
...
@@ -2605,23 +2613,23 @@ public class RepairController {
// } else {
// } else {
// return repairDetail.getRepairBackBillId() == null && repairDetail.getRepairStatus().equals(RepairStatusEnum.WAIT_REPAIR.id) && repairDetail.getLocationUnit().equals(repairDetail.getOwnUnit());
// return repairDetail.getRepairBackBillId() == null && repairDetail.getRepairStatus().equals(RepairStatusEnum.WAIT_REPAIR.id) && repairDetail.getLocationUnit().equals(repairDetail.getOwnUnit());
// }
// }
if
(!
units
Service
.
findById
(
repairDetail
.
getLocationUnitId
()).
equals
(
unitsServic
e
.
findById
(
repairDetail
.
getOwnUnitId
())))
{
if
(!
units
Cache
.
findById
(
repairDetail
.
getLocationUnitId
()).
equals
(
unitsCach
e
.
findById
(
repairDetail
.
getOwnUnitId
())))
{
// return repairDetail.getRepairBackBillId() == null && repairDetail.getRepairStatus().equals(RepairStatusEnum.WAIT_REPAIR.id) && repairDetail.getLocationUnit().equals(currentUserUnitName);
// return repairDetail.getRepairBackBillId() == null && repairDetail.getRepairStatus().equals(RepairStatusEnum.WAIT_REPAIR.id) && repairDetail.getLocationUnit().equals(currentUserUnitName);
return
repairDetail
.
getRepairBackBillId
()
==
null
&&
return
repairDetail
.
getRepairBackBillId
()
==
null
&&
repairDetail
.
getRepairStatus
().
equals
(
RepairStatusEnum
.
WAIT_REPAIR
.
id
)
&&
repairDetail
.
getRepairStatus
().
equals
(
RepairStatusEnum
.
WAIT_REPAIR
.
id
)
&&
units
Servic
e
.
findById
(
repairDetail
.
getLocationUnitId
()).
getName
().
equals
(
currentUserUnitName
);
units
Cach
e
.
findById
(
repairDetail
.
getLocationUnitId
()).
getName
().
equals
(
currentUserUnitName
);
}
else
{
}
else
{
// return repairDetail.getRepairBackBillId() == null && repairDetail.getRepairStatus().equals(RepairStatusEnum.WAIT_REPAIR.id)
// return repairDetail.getRepairBackBillId() == null && repairDetail.getRepairStatus().equals(RepairStatusEnum.WAIT_REPAIR.id)
// && repairDetail.getLocationUnit().equals(repairDetail.getOwnUnit());
// && repairDetail.getLocationUnit().equals(repairDetail.getOwnUnit());
return
repairDetail
.
getRepairBackBillId
()
==
null
&&
repairDetail
.
getRepairStatus
().
equals
(
RepairStatusEnum
.
WAIT_REPAIR
.
id
)
return
repairDetail
.
getRepairBackBillId
()
==
null
&&
repairDetail
.
getRepairStatus
().
equals
(
RepairStatusEnum
.
WAIT_REPAIR
.
id
)
&&
units
Servic
e
.
findById
(
repairDetail
.
getLocationUnitId
()).
getName
()
&&
units
Cach
e
.
findById
(
repairDetail
.
getLocationUnitId
()).
getName
()
.
equals
(
units
Servic
e
.
findById
(
repairDetail
.
getOwnUnitId
()).
getName
());
.
equals
(
units
Cach
e
.
findById
(
repairDetail
.
getOwnUnitId
()).
getName
());
}
}
}).
collect
(
Collectors
.
toList
());
}).
collect
(
Collectors
.
toList
());
repairDetails
.
forEach
(
repairDetail
->
{
repairDetails
.
forEach
(
repairDetail
->
{
// if (repairDetail.getLocationUnit().equals(repairDetail.getOwnUnit()))
// if (repairDetail.getLocationUnit().equals(repairDetail.getOwnUnit()))
if
(
units
Servic
e
.
findById
(
repairDetail
.
getLocationUnitId
()).
getName
()
if
(
units
Cach
e
.
findById
(
repairDetail
.
getLocationUnitId
()).
getName
()
.
equals
(
units
Servic
e
.
findById
(
repairDetail
.
getOwnUnitId
()).
getName
())){
.
equals
(
units
Cach
e
.
findById
(
repairDetail
.
getOwnUnitId
()).
getName
())){
repairDetail
.
setDeviceRepairBillId
(
0
);
repairDetail
.
setDeviceRepairBillId
(
0
);
repairDetail
.
setRepairStatus
(
RepairStatusEnum
.
WAIT_SEND
.
id
);
repairDetail
.
setRepairStatus
(
RepairStatusEnum
.
WAIT_SEND
.
id
);
repairDetail
.
setLocationUnit
(
deviceLibraryService
.
getOne
(
repairDetail
.
setLocationUnit
(
deviceLibraryService
.
getOne
(
...
@@ -2722,10 +2730,10 @@ public class RepairController {
...
@@ -2722,10 +2730,10 @@ public class RepairController {
// .collect(Collectors.toList());
// .collect(Collectors.toList());
List
<
RepairDetail
>
repairDetails
=
byRepairBackBillId
.
stream
().
filter
(
repairDetail
->
List
<
RepairDetail
>
repairDetails
=
byRepairBackBillId
.
stream
().
filter
(
repairDetail
->
repairDetail
.
getDeviceRepairBillId
()
!=
null
&&
repairDetail
.
getDeviceRepairBillId
()
!=
null
&&
!
units
Servic
e
.
findById
(
repairDetail
.
getLocationUnitId
()).
getName
()
!
units
Cach
e
.
findById
(
repairDetail
.
getLocationUnitId
()).
getName
()
.
equals
(
units
Servic
e
.
findById
(
repairDetail
.
getOwnUnitId
()).
getName
())
&&
.
equals
(
units
Cach
e
.
findById
(
repairDetail
.
getOwnUnitId
()).
getName
())
&&
repairDetail
.
getRepairStatus
().
equals
(
RepairStatusEnum
.
RECEIVE_WAIT_STORAGE
.
id
)
repairDetail
.
getRepairStatus
().
equals
(
RepairStatusEnum
.
RECEIVE_WAIT_STORAGE
.
id
)
&&
units
Servic
e
.
findById
(
repairDetail
.
getLocationUnitId
()).
getName
().
equals
(
currentUserUnitName
))
&&
units
Cach
e
.
findById
(
repairDetail
.
getLocationUnitId
()).
getName
().
equals
(
currentUserUnitName
))
.
collect
(
Collectors
.
toList
());
.
collect
(
Collectors
.
toList
());
for
(
RepairDetail
repairDetail
:
repairDetails
)
{
for
(
RepairDetail
repairDetail
:
repairDetails
)
{
repairDetail
.
setRepairBackBillId
(
null
);
repairDetail
.
setRepairBackBillId
(
null
);
...
...
dev-repair/src/main/java/com/tykj/dev/device/repair/service/impl/RepairDetailServiceImpl.java
浏览文件 @
9039c4cb
...
@@ -24,6 +24,7 @@ import com.tykj.dev.device.repair.subject.vo.SetDevicesOwnUnit;
...
@@ -24,6 +24,7 @@ import com.tykj.dev.device.repair.subject.vo.SetDevicesOwnUnit;
import
com.tykj.dev.device.task.service.TaskService
;
import
com.tykj.dev.device.task.service.TaskService
;
import
com.tykj.dev.device.task.subject.bto.TaskBto
;
import
com.tykj.dev.device.task.subject.bto.TaskBto
;
import
com.tykj.dev.device.task.subject.domin.Task
;
import
com.tykj.dev.device.task.subject.domin.Task
;
import
com.tykj.dev.device.user.cache.UnitsCache
;
import
com.tykj.dev.device.user.read.subject.bto.MessageBto
;
import
com.tykj.dev.device.user.read.subject.bto.MessageBto
;
import
com.tykj.dev.device.user.subject.entity.Units
;
import
com.tykj.dev.device.user.subject.entity.Units
;
import
com.tykj.dev.device.user.subject.entity.User
;
import
com.tykj.dev.device.user.subject.entity.User
;
...
@@ -41,6 +42,7 @@ import org.springframework.scheduling.annotation.Async;
...
@@ -41,6 +42,7 @@ import org.springframework.scheduling.annotation.Async;
import
org.springframework.stereotype.Service
;
import
org.springframework.stereotype.Service
;
import
org.springframework.util.CollectionUtils
;
import
org.springframework.util.CollectionUtils
;
import
javax.annotation.Resource
;
import
java.util.*
;
import
java.util.*
;
import
java.util.concurrent.CompletableFuture
;
import
java.util.concurrent.CompletableFuture
;
import
java.util.stream.Collectors
;
import
java.util.stream.Collectors
;
...
@@ -81,6 +83,9 @@ public class RepairDetailServiceImpl implements RepairDetailService {
...
@@ -81,6 +83,9 @@ public class RepairDetailServiceImpl implements RepairDetailService {
@Autowired
@Autowired
private
DeviceLogService
deviceLogService
;
private
DeviceLogService
deviceLogService
;
@Resource
private
UnitsCache
unitsCache
;
@Override
@Override
public
RepairDetail
save
(
RepairDetail
deviceRepairDetailEntity
)
{
public
RepairDetail
save
(
RepairDetail
deviceRepairDetailEntity
)
{
RepairDetail
repairDetail
=
deviceRepairDetailDao
.
save
(
deviceRepairDetailEntity
);
RepairDetail
repairDetail
=
deviceRepairDetailDao
.
save
(
deviceRepairDetailEntity
);
...
@@ -348,7 +353,8 @@ public class RepairDetailServiceImpl implements RepairDetailService {
...
@@ -348,7 +353,8 @@ public class RepairDetailServiceImpl implements RepairDetailService {
List
<
String
>
names
=
superiorUnitsList
.
stream
().
map
(
Units:
:
getName
).
collect
(
Collectors
.
toList
());
List
<
String
>
names
=
superiorUnitsList
.
stream
().
map
(
Units:
:
getName
).
collect
(
Collectors
.
toList
());
// List<RepairDetail> exceptionList = repairDetails.stream().filter(repairDetail -> names.contains(repairDetail.getLocationUnit())).sorted(Comparator.comparing(RepairDetail::getCreateTime)).collect(Collectors.toList());
// List<RepairDetail> exceptionList = repairDetails.stream().filter(repairDetail -> names.contains(repairDetail.getLocationUnit())).sorted(Comparator.comparing(RepairDetail::getCreateTime)).collect(Collectors.toList());
List
<
RepairDetail
>
exceptionList
=
repairDetails
.
stream
().
filter
(
repairDetail
->
List
<
RepairDetail
>
exceptionList
=
repairDetails
.
stream
().
filter
(
repairDetail
->
names
.
contains
(
unitsService
.
findById
(
repairDetail
.
getLocationUnitId
()).
getName
()))
// names.contains(unitsService.findById(repairDetail.getLocationUnitId()).getName()))
names
.
contains
(
unitsCache
.
findById
(
repairDetail
.
getLocationUnitId
()).
getName
()))
.
sorted
(
Comparator
.
comparing
(
RepairDetail:
:
getCreateTime
)).
collect
(
Collectors
.
toList
());
.
sorted
(
Comparator
.
comparing
(
RepairDetail:
:
getCreateTime
)).
collect
(
Collectors
.
toList
());
repairDetails
.
removeAll
(
exceptionList
);
repairDetails
.
removeAll
(
exceptionList
);
//维修未入库 等待维修分为接收区装备和市发起维修
//维修未入库 等待维修分为接收区装备和市发起维修
...
...
dev-statistical/src/main/java/com/tykj/dev/statistical/service/impl/BigScreenServiceImpl.java
浏览文件 @
9039c4cb
...
@@ -315,7 +315,8 @@ public class BigScreenServiceImpl implements BigScreenService {
...
@@ -315,7 +315,8 @@ public class BigScreenServiceImpl implements BigScreenService {
// .sorted(Comparator.comparing(SelfCheckBill::getUpdateTime,Comparator.nullsLast(Date::compareTo)).reversed())
// .sorted(Comparator.comparing(SelfCheckBill::getUpdateTime,Comparator.nullsLast(Date::compareTo)).reversed())
// .collect(Collectors.toList());
// .collect(Collectors.toList());
List
<
SelfCheckBill
>
selfCheckBillList
=
selfCheckBills
.
stream
()
List
<
SelfCheckBill
>
selfCheckBillList
=
selfCheckBills
.
stream
()
.
filter
(
selfCheckBill
->
unitsService
.
findById
(
selfCheckBill
.
getCheckUnitId
()).
getName
().
equals
(
unitName
))
// .filter(selfCheckBill -> unitsService.findById(selfCheckBill.getCheckUnitId()).getName().equals(unitName))
.
filter
(
selfCheckBill
->
unitsCache
.
findById
(
selfCheckBill
.
getCheckUnitId
()).
getName
().
equals
(
unitName
))
.
sorted
(
Comparator
.
comparing
(
SelfCheckBill:
:
getUpdateTime
,
Comparator
.
nullsLast
(
Date:
:
compareTo
)).
reversed
())
.
sorted
(
Comparator
.
comparing
(
SelfCheckBill:
:
getUpdateTime
,
Comparator
.
nullsLast
(
Date:
:
compareTo
)).
reversed
())
.
collect
(
Collectors
.
toList
());
.
collect
(
Collectors
.
toList
());
if
(!
selfCheckBillList
.
isEmpty
())
{
if
(!
selfCheckBillList
.
isEmpty
())
{
...
...
dev-statistical/src/main/java/com/tykj/dev/statistical/service/impl/StatisticalServiceImpl.java
浏览文件 @
9039c4cb
...
@@ -256,7 +256,8 @@ public class StatisticalServiceImpl implements StatisticalService {
...
@@ -256,7 +256,8 @@ public class StatisticalServiceImpl implements StatisticalService {
Map
<
String
,
Integer
>
selfCheckBillMap
=
selfCheckBills
.
stream
().
filter
(
selfCheckBill
->
selfCheckBill
.
getCycle
()!=
null
Map
<
String
,
Integer
>
selfCheckBillMap
=
selfCheckBills
.
stream
().
filter
(
selfCheckBill
->
selfCheckBill
.
getCycle
()!=
null
&&
selfCheckBill
.
getTitle
().
equals
(
selfCheckBillList
.
get
(
0
).
getTitle
()))
&&
selfCheckBill
.
getTitle
().
equals
(
selfCheckBillList
.
get
(
0
).
getTitle
()))
.
collect
(
Collectors
.
toMap
(
selfCheckBill
->
.
collect
(
Collectors
.
toMap
(
selfCheckBill
->
unitsService
.
findById
(
selfCheckBill
.
getCheckUnitId
()).
getName
()
// unitsService.findById(selfCheckBill.getCheckUnitId()).getName()
unitsCache
.
findById
(
selfCheckBill
.
getCheckUnitId
()).
getName
()
,
SelfCheckBill:
:
getCheckStatus
,(
v1
,
v2
)->
v1
));
,
SelfCheckBill:
:
getCheckStatus
,(
v1
,
v2
)->
v1
));
//获取所有市
//获取所有市
List
<
Area
>
areas
=
areaDao
.
findAreasByType
(
2
);
List
<
Area
>
areas
=
areaDao
.
findAreasByType
(
2
);
...
@@ -523,7 +524,8 @@ public class StatisticalServiceImpl implements StatisticalService {
...
@@ -523,7 +524,8 @@ public class StatisticalServiceImpl implements StatisticalService {
WorkBench
workBench
=
new
WorkBench
();
WorkBench
workBench
=
new
WorkBench
();
DeviceLibrarySelectVo
deviceLibrarySelectVo
=
new
DeviceLibrarySelectVo
();
DeviceLibrarySelectVo
deviceLibrarySelectVo
=
new
DeviceLibrarySelectVo
();
// deviceLibrarySelectVo.setAreaId(areaCache.findByName("浙江省").getId());
// deviceLibrarySelectVo.setAreaId(areaCache.findByName("浙江省").getId());
deviceLibrarySelectVo
.
setAreaId
(
unitsService
.
findById
(
unit
).
getAreaId
());
// deviceLibrarySelectVo.setAreaId(unitsService.findById(unit).getAreaId());
deviceLibrarySelectVo
.
setAreaId
(
unitsCache
.
findById
(
unit
).
getAreaId
());
workBench
.
setPackingNum
(
packingLibraryDao
.
findAllByIsRootAndPackingStatus
(
0
,
2
).
size
());
workBench
.
setPackingNum
(
packingLibraryDao
.
findAllByIsRootAndPackingStatus
(
0
,
2
).
size
());
// List<DeviceLibrary> deviceLibraries = deviceLibraryService.getCoreDevicePage(deviceLibrarySelectVo);
// List<DeviceLibrary> deviceLibraries = deviceLibraryService.getCoreDevicePage(deviceLibrarySelectVo);
List
<
DeviceLibrary
>
deviceLibraries
=
deviceLibraryService
.
getDeviceByUnitNameAll
(
unit
);
List
<
DeviceLibrary
>
deviceLibraries
=
deviceLibraryService
.
getDeviceByUnitNameAll
(
unit
);
...
@@ -593,7 +595,7 @@ public class StatisticalServiceImpl implements StatisticalService {
...
@@ -593,7 +595,7 @@ public class StatisticalServiceImpl implements StatisticalService {
// .sorted(Comparator.nullsLast(Comparator.comparing(SelfCheckBill::getUpdateTime).reversed()))
// .sorted(Comparator.nullsLast(Comparator.comparing(SelfCheckBill::getUpdateTime).reversed()))
// .collect(Collectors.toList());
// .collect(Collectors.toList());
List
<
SelfCheckBill
>
selfCheckBillList
=
selfCheckBills
.
stream
()
List
<
SelfCheckBill
>
selfCheckBillList
=
selfCheckBills
.
stream
()
.
filter
(
selfCheckBill
->
units
Servic
e
.
findById
(
selfCheckBill
.
getCheckUnitId
()).
getName
().
equals
(
unitName
)
.
filter
(
selfCheckBill
->
units
Cach
e
.
findById
(
selfCheckBill
.
getCheckUnitId
()).
getName
().
equals
(
unitName
)
&&
selfCheckBill
.
getCheckedCount
()
!=
null
)
&&
selfCheckBill
.
getCheckedCount
()
!=
null
)
.
sorted
(
Comparator
.
nullsLast
(
Comparator
.
comparing
(
SelfCheckBill:
:
getUpdateTime
).
reversed
()))
.
sorted
(
Comparator
.
nullsLast
(
Comparator
.
comparing
(
SelfCheckBill:
:
getUpdateTime
).
reversed
()))
.
collect
(
Collectors
.
toList
());
.
collect
(
Collectors
.
toList
());
...
@@ -602,7 +604,7 @@ public class StatisticalServiceImpl implements StatisticalService {
...
@@ -602,7 +604,7 @@ public class StatisticalServiceImpl implements StatisticalService {
// .sorted(Comparator.nullsLast(Comparator.comparing(DeviceCheckDetail::getUpdateTime).reversed()))
// .sorted(Comparator.nullsLast(Comparator.comparing(DeviceCheckDetail::getUpdateTime).reversed()))
// .collect(Collectors.toList());
// .collect(Collectors.toList());
List
<
DeviceCheckDetail
>
deviceCheckDetailList
=
deviceCheckDetails
.
stream
()
List
<
DeviceCheckDetail
>
deviceCheckDetailList
=
deviceCheckDetails
.
stream
()
.
filter
(
deviceCheckDetail
->
units
Servic
e
.
findById
(
deviceCheckDetail
.
getCheckUnitId
()).
getName
().
equals
(
unitName
)
.
filter
(
deviceCheckDetail
->
units
Cach
e
.
findById
(
deviceCheckDetail
.
getCheckUnitId
()).
getName
().
equals
(
unitName
)
&&
deviceCheckDetail
.
getCheckedCount
()
!=
null
)
&&
deviceCheckDetail
.
getCheckedCount
()
!=
null
)
.
sorted
(
Comparator
.
nullsLast
(
Comparator
.
comparing
(
DeviceCheckDetail:
:
getUpdateTime
).
reversed
()))
.
sorted
(
Comparator
.
nullsLast
(
Comparator
.
comparing
(
DeviceCheckDetail:
:
getUpdateTime
).
reversed
()))
.
collect
(
Collectors
.
toList
());
.
collect
(
Collectors
.
toList
());
...
@@ -745,7 +747,7 @@ public class StatisticalServiceImpl implements StatisticalService {
...
@@ -745,7 +747,7 @@ public class StatisticalServiceImpl implements StatisticalService {
// .collect(Collectors.toList());
// .collect(Collectors.toList());
List
<
SelfCheckBill
>
selfCheckBillList
=
selfCheckBills
.
stream
()
List
<
SelfCheckBill
>
selfCheckBillList
=
selfCheckBills
.
stream
()
.
filter
(
selfCheckBill
->
selfCheckBill
.
getTitle
().
contains
(
quarter
)&&
.
filter
(
selfCheckBill
->
selfCheckBill
.
getTitle
().
contains
(
quarter
)&&
units
Servic
e
.
findById
(
selfCheckBill
.
getCheckUnitId
()).
getName
().
equals
(
units
.
get
(
0
).
getName
()))
units
Cach
e
.
findById
(
selfCheckBill
.
getCheckUnitId
()).
getName
().
equals
(
units
.
get
(
0
).
getName
()))
.
collect
(
Collectors
.
toList
());
.
collect
(
Collectors
.
toList
());
if
(
selfCheckBillList
.
size
()==
1
){
if
(
selfCheckBillList
.
size
()==
1
){
SelfCheckBill
selfCheckBill
=
selfCheckBillList
.
get
(
0
);
SelfCheckBill
selfCheckBill
=
selfCheckBillList
.
get
(
0
);
...
...
dev-usereport/src/main/java/com/tykj/dev/device/usereport/controller/DeviceUseReportController.java
浏览文件 @
9039c4cb
...
@@ -3,6 +3,7 @@ package com.tykj.dev.device.usereport.controller;
...
@@ -3,6 +3,7 @@ package com.tykj.dev.device.usereport.controller;
import
com.tykj.dev.config.swagger.AutoDocument
;
import
com.tykj.dev.config.swagger.AutoDocument
;
import
com.tykj.dev.device.file.entity.WrodParameter
;
import
com.tykj.dev.device.file.entity.WrodParameter
;
import
com.tykj.dev.device.file.service.UseReportFIleService
;
import
com.tykj.dev.device.file.service.UseReportFIleService
;
import
com.tykj.dev.device.user.cache.UnitsCache
;
import
com.tykj.dev.device.user.subject.entity.SecurityUser
;
import
com.tykj.dev.device.user.subject.entity.SecurityUser
;
import
com.tykj.dev.device.user.subject.entity.Units
;
import
com.tykj.dev.device.user.subject.entity.Units
;
import
com.tykj.dev.device.user.subject.service.UnitsService
;
import
com.tykj.dev.device.user.subject.service.UnitsService
;
...
@@ -26,6 +27,7 @@ import org.springframework.validation.annotation.Validated;
...
@@ -26,6 +27,7 @@ import org.springframework.validation.annotation.Validated;
import
org.springframework.web.bind.annotation.*
;
import
org.springframework.web.bind.annotation.*
;
import
springfox.documentation.annotations.ApiIgnore
;
import
springfox.documentation.annotations.ApiIgnore
;
import
javax.annotation.Resource
;
import
javax.servlet.http.HttpServletRequest
;
import
javax.servlet.http.HttpServletRequest
;
import
javax.servlet.http.HttpServletResponse
;
import
javax.servlet.http.HttpServletResponse
;
import
java.io.IOException
;
import
java.io.IOException
;
...
@@ -49,6 +51,9 @@ public class DeviceUseReportController {
...
@@ -49,6 +51,9 @@ public class DeviceUseReportController {
@Autowired
@Autowired
UnitsService
unitsService
;
UnitsService
unitsService
;
@Resource
private
UnitsCache
unitsCache
;
@Autowired
@Autowired
private
UseReportFIleService
useReportFIleService
;
private
UseReportFIleService
useReportFIleService
;
@ApiOperation
(
value
=
"模糊查询装备使用报告分页"
,
notes
=
"可以通过这个接口模糊查询装备使用报告分页"
)
@ApiOperation
(
value
=
"模糊查询装备使用报告分页"
,
notes
=
"可以通过这个接口模糊查询装备使用报告分页"
)
...
@@ -103,7 +108,8 @@ public class DeviceUseReportController {
...
@@ -103,7 +108,8 @@ public class DeviceUseReportController {
//新建word模板
//新建word模板
WrodParameter
wrodParameter
=
deviceUseReportDetailVo
.
toWrodParameter
();
WrodParameter
wrodParameter
=
deviceUseReportDetailVo
.
toWrodParameter
();
// Units units= unitsService.findbyName(deviceUseReportDetailVo.getUnit());
// Units units= unitsService.findbyName(deviceUseReportDetailVo.getUnit());
Units
units
=
unitsService
.
findById
(
deviceUseReportDetailVo
.
getUnitId
());
// Units units= unitsService.findById(deviceUseReportDetailVo.getUnitId());
Units
units
=
unitsCache
.
findById
(
deviceUseReportDetailVo
.
getUnitId
());
Instant
instant
=
deviceUseReportDetailVo
.
getCreateTime
().
toInstant
();
Instant
instant
=
deviceUseReportDetailVo
.
getCreateTime
().
toInstant
();
ZoneId
zone
=
ZoneId
.
systemDefault
();
ZoneId
zone
=
ZoneId
.
systemDefault
();
LocalDateTime
localDateTime
=
LocalDateTime
.
ofInstant
(
instant
,
zone
);
LocalDateTime
localDateTime
=
LocalDateTime
.
ofInstant
(
instant
,
zone
);
...
...
dev-usereport/src/main/java/com/tykj/dev/device/usereport/service/impl/DeviceUseReportServiceImpl.java
浏览文件 @
9039c4cb
...
@@ -27,6 +27,7 @@ import com.tykj.dev.device.sendback.entity.vo.RepelManagementVo;
...
@@ -27,6 +27,7 @@ import com.tykj.dev.device.sendback.entity.vo.RepelManagementVo;
import
com.tykj.dev.device.sendback.service.RepelQueryService
;
import
com.tykj.dev.device.sendback.service.RepelQueryService
;
import
com.tykj.dev.device.storage.repository.StorageBillDao
;
import
com.tykj.dev.device.storage.repository.StorageBillDao
;
import
com.tykj.dev.device.storage.subject.domin.StorageBill
;
import
com.tykj.dev.device.storage.subject.domin.StorageBill
;
import
com.tykj.dev.device.user.cache.UnitsCache
;
import
com.tykj.dev.device.user.subject.service.UnitsService
;
import
com.tykj.dev.device.user.subject.service.UnitsService
;
import
com.tykj.dev.device.user.subject.service.UserPublicService
;
import
com.tykj.dev.device.user.subject.service.UserPublicService
;
import
com.tykj.dev.device.user.util.UserUtils
;
import
com.tykj.dev.device.user.util.UserUtils
;
...
@@ -105,6 +106,9 @@ public class DeviceUseReportServiceImpl implements DeviceUseReportService {
...
@@ -105,6 +106,9 @@ public class DeviceUseReportServiceImpl implements DeviceUseReportService {
@Autowired
@Autowired
private
UnitsService
unitsService
;
private
UnitsService
unitsService
;
@Autowired
private
UnitsCache
unitsCache
;
@Override
@Override
public
DeviceUseReport
addEntity
(
DeviceUseReport
deviceUseReportEntity
)
{
public
DeviceUseReport
addEntity
(
DeviceUseReport
deviceUseReportEntity
)
{
return
deviceUseReportDao
.
save
(
deviceUseReportEntity
);
return
deviceUseReportDao
.
save
(
deviceUseReportEntity
);
...
@@ -393,7 +397,7 @@ public class DeviceUseReportServiceImpl implements DeviceUseReportService {
...
@@ -393,7 +397,7 @@ public class DeviceUseReportServiceImpl implements DeviceUseReportService {
// .collect(toList());
// .collect(toList());
List
<
AllotBackBill
>
receiveAllotBackBills
=
allotBackBillDao
.
findAll
().
stream
()
List
<
AllotBackBill
>
receiveAllotBackBills
=
allotBackBillDao
.
findAll
().
stream
()
.
filter
(
allotBackBill
->
allotBackBill
.
getBackStatus
()
==
3
&&
.
filter
(
allotBackBill
->
allotBackBill
.
getBackStatus
()
==
3
&&
userUtils
.
getCurrentUserUnitName
().
equals
(
units
Servic
e
.
findById
(
allotBackBill
.
getReceiveUnitId
()).
getName
())
userUtils
.
getCurrentUserUnitName
().
equals
(
units
Cach
e
.
findById
(
allotBackBill
.
getReceiveUnitId
()).
getName
())
&&
allotBackBill
.
getReceiveTime
().
after
(
date
)
&&
allotBackBill
.
getReceiveTime
().
before
(
date2
))
&&
allotBackBill
.
getReceiveTime
().
after
(
date
)
&&
allotBackBill
.
getReceiveTime
().
before
(
date2
))
.
collect
(
toList
());
.
collect
(
toList
());
//接收退回
//接收退回
...
@@ -412,7 +416,7 @@ public class DeviceUseReportServiceImpl implements DeviceUseReportService {
...
@@ -412,7 +416,7 @@ public class DeviceUseReportServiceImpl implements DeviceUseReportService {
// .collect(toList());
// .collect(toList());
List
<
AllotBackBill
>
sendAllotBackBills
=
allotBackBillDao
.
findAll
().
stream
()
List
<
AllotBackBill
>
sendAllotBackBills
=
allotBackBillDao
.
findAll
().
stream
()
.
filter
(
allotBackBill
->
allotStatusBackList
.
contains
(
allotBackBill
.
getBackStatus
())
&&
.
filter
(
allotBackBill
->
allotStatusBackList
.
contains
(
allotBackBill
.
getBackStatus
())
&&
userUtils
.
getCurrentUserUnitName
().
equals
(
units
Servic
e
.
findById
(
allotBackBill
.
getSendUnitId
()).
getName
())
userUtils
.
getCurrentUserUnitName
().
equals
(
units
Cach
e
.
findById
(
allotBackBill
.
getSendUnitId
()).
getName
())
&&
allotBackBill
.
getSendTime
().
after
(
date
)
&&
allotBackBill
.
getSendTime
().
before
(
date2
))
&&
allotBackBill
.
getSendTime
().
after
(
date
)
&&
allotBackBill
.
getSendTime
().
before
(
date2
))
.
collect
(
toList
());
.
collect
(
toList
());
//发起退回
//发起退回
...
@@ -475,7 +479,7 @@ public class DeviceUseReportServiceImpl implements DeviceUseReportService {
...
@@ -475,7 +479,7 @@ public class DeviceUseReportServiceImpl implements DeviceUseReportService {
// .collect(toList());
// .collect(toList());
String
currentUserUnitName
=
userUtils
.
getCurrentUserUnitName
();
String
currentUserUnitName
=
userUtils
.
getCurrentUserUnitName
();
List
<
RepairSendBill
>
repairDetails
=
repairSendBillDao
.
findAll
().
stream
()
List
<
RepairSendBill
>
repairDetails
=
repairSendBillDao
.
findAll
().
stream
()
.
filter
(
repairSendBill
->
currentUserUnitName
.
equals
(
units
Servic
e
.
findById
(
repairSendBill
.
getSendUnitId
()).
getName
())
.
filter
(
repairSendBill
->
currentUserUnitName
.
equals
(
units
Cach
e
.
findById
(
repairSendBill
.
getSendUnitId
()).
getName
())
&&
toUpRepairStatusList
.
contains
(
repairSendBill
.
getRepairStatus
())
&&
&&
toUpRepairStatusList
.
contains
(
repairSendBill
.
getRepairStatus
())
&&
repairSendBill
.
getUpdateTime
().
after
(
date
)
&&
repairSendBill
.
getUpdateTime
().
before
(
date2
))
repairSendBill
.
getUpdateTime
().
after
(
date
)
&&
repairSendBill
.
getUpdateTime
().
before
(
date2
))
.
collect
(
toList
());
.
collect
(
toList
());
...
@@ -493,7 +497,7 @@ public class DeviceUseReportServiceImpl implements DeviceUseReportService {
...
@@ -493,7 +497,7 @@ public class DeviceUseReportServiceImpl implements DeviceUseReportService {
// .filter(repairSendBill -> repairSendBill.getReceiveUnit().equals(userUtils.getCurrentUserUnitName()) && toUpRepairStatusList.contains(repairSendBill.getRepairStatus()) && repairSendBill.getUpdateTime().after(date) && repairSendBill.getUpdateTime().before(date2))
// .filter(repairSendBill -> repairSendBill.getReceiveUnit().equals(userUtils.getCurrentUserUnitName()) && toUpRepairStatusList.contains(repairSendBill.getRepairStatus()) && repairSendBill.getUpdateTime().after(date) && repairSendBill.getUpdateTime().before(date2))
// .collect(toList());
// .collect(toList());
List
<
RepairSendBill
>
toUpRepairList
=
repairSendBillDao
.
findAll
().
stream
()
List
<
RepairSendBill
>
toUpRepairList
=
repairSendBillDao
.
findAll
().
stream
()
.
filter
(
repairSendBill
->
currentUserUnitName
.
equals
(
units
Servic
e
.
findById
(
repairSendBill
.
getReceiveUnitId
()).
getName
())
.
filter
(
repairSendBill
->
currentUserUnitName
.
equals
(
units
Cach
e
.
findById
(
repairSendBill
.
getReceiveUnitId
()).
getName
())
&&
toUpRepairStatusList
.
contains
(
repairSendBill
.
getRepairStatus
())
&&
repairSendBill
.
getUpdateTime
().
after
(
date
)
&&
repairSendBill
.
getUpdateTime
().
before
(
date2
))
&&
toUpRepairStatusList
.
contains
(
repairSendBill
.
getRepairStatus
())
&&
repairSendBill
.
getUpdateTime
().
after
(
date
)
&&
repairSendBill
.
getUpdateTime
().
before
(
date2
))
.
collect
(
toList
());
.
collect
(
toList
());
if
(
toUpRepairList
.
size
()>
0
){
if
(
toUpRepairList
.
size
()>
0
){
...
@@ -510,7 +514,7 @@ public class DeviceUseReportServiceImpl implements DeviceUseReportService {
...
@@ -510,7 +514,7 @@ public class DeviceUseReportServiceImpl implements DeviceUseReportService {
// .filter(repairBackBill -> repairBackBill.getReceiveUnit().equals(userUtils.getCurrentUserUnitName()) && repairBackList.contains(repairBackBill.getBackStatus()) && repairBackBill.getUpdateTime().after(date) && repairBackBill.getUpdateTime().before(date2))
// .filter(repairBackBill -> repairBackBill.getReceiveUnit().equals(userUtils.getCurrentUserUnitName()) && repairBackList.contains(repairBackBill.getBackStatus()) && repairBackBill.getUpdateTime().after(date) && repairBackBill.getUpdateTime().before(date2))
// .collect(toList());
// .collect(toList());
List
<
RepairBackBill
>
repairBackBills
=
repairBackBillDao
.
findAll
().
stream
()
List
<
RepairBackBill
>
repairBackBills
=
repairBackBillDao
.
findAll
().
stream
()
.
filter
(
repairBackBill
->
units
Servic
e
.
findById
(
repairBackBill
.
getReceiveUnitId
()).
getName
().
equals
(
currentUserUnitName
)
.
filter
(
repairBackBill
->
units
Cach
e
.
findById
(
repairBackBill
.
getReceiveUnitId
()).
getName
().
equals
(
currentUserUnitName
)
&&
repairBackList
.
contains
(
repairBackBill
.
getBackStatus
())
&&
repairBackBill
.
getUpdateTime
().
after
(
date
)
&&
repairBackList
.
contains
(
repairBackBill
.
getBackStatus
())
&&
repairBackBill
.
getUpdateTime
().
after
(
date
)
&&
repairBackBill
.
getUpdateTime
().
before
(
date2
))
&&
repairBackBill
.
getUpdateTime
().
before
(
date2
))
.
collect
(
toList
());
.
collect
(
toList
());
...
@@ -520,7 +524,7 @@ public class DeviceUseReportServiceImpl implements DeviceUseReportService {
...
@@ -520,7 +524,7 @@ public class DeviceUseReportServiceImpl implements DeviceUseReportService {
// .filter(repairBackBill -> repairBackBill.getSendUnit().equals(userUtils.getCurrentUserUnitName()) && repairBackList.contains(repairBackBill.getBackStatus()) && repairBackBill.getUpdateTime().after(date) && repairBackBill.getUpdateTime().before(date2))
// .filter(repairBackBill -> repairBackBill.getSendUnit().equals(userUtils.getCurrentUserUnitName()) && repairBackList.contains(repairBackBill.getBackStatus()) && repairBackBill.getUpdateTime().after(date) && repairBackBill.getUpdateTime().before(date2))
// .collect(toList());
// .collect(toList());
List
<
RepairBackBill
>
repairBackBillList
=
repairBackBillDao
.
findAll
().
stream
()
List
<
RepairBackBill
>
repairBackBillList
=
repairBackBillDao
.
findAll
().
stream
()
.
filter
(
repairBackBill
->
units
Servic
e
.
findById
(
repairBackBill
.
getSendUnitId
()).
getName
().
equals
(
currentUserUnitName
)
&&
repairBackList
.
contains
(
repairBackBill
.
getBackStatus
())
&&
repairBackBill
.
getUpdateTime
().
after
(
date
)
&&
repairBackBill
.
getUpdateTime
().
before
(
date2
))
.
filter
(
repairBackBill
->
units
Cach
e
.
findById
(
repairBackBill
.
getSendUnitId
()).
getName
().
equals
(
currentUserUnitName
)
&&
repairBackList
.
contains
(
repairBackBill
.
getBackStatus
())
&&
repairBackBill
.
getUpdateTime
().
after
(
date
)
&&
repairBackBill
.
getUpdateTime
().
before
(
date2
))
.
collect
(
toList
());
.
collect
(
toList
());
//将数量进行新增 累加数量
//将数量进行新增 累加数量
...
@@ -596,7 +600,7 @@ public class DeviceUseReportServiceImpl implements DeviceUseReportService {
...
@@ -596,7 +600,7 @@ public class DeviceUseReportServiceImpl implements DeviceUseReportService {
// .collect(toList());
// .collect(toList());
List
<
RepairSendBill
>
repairSendBills
=
repairSendBillDao
.
findAll
().
stream
()
List
<
RepairSendBill
>
repairSendBills
=
repairSendBillDao
.
findAll
().
stream
()
.
filter
(
repairSendBill
->
repairSendBill
.
getRepairStatus
()
==
5
&&
.
filter
(
repairSendBill
->
repairSendBill
.
getRepairStatus
()
==
5
&&
userPublicService
.
findByUnitsToname
(
1
).
equals
(
units
Servic
e
.
findById
(
repairSendBill
.
getSendUnitId
()).
getName
())
&&
userPublicService
.
findByUnitsToname
(
1
).
equals
(
units
Cach
e
.
findById
(
repairSendBill
.
getSendUnitId
()).
getName
())
&&
repairSendBill
.
getSendTime
().
after
(
startDate
)
&&
repairSendBill
.
getSendTime
().
before
(
endDate
))
repairSendBill
.
getSendTime
().
after
(
startDate
)
&&
repairSendBill
.
getSendTime
().
before
(
endDate
))
.
collect
(
toList
());
.
collect
(
toList
());
//获取所有维修的装备
//获取所有维修的装备
...
@@ -627,7 +631,7 @@ public class DeviceUseReportServiceImpl implements DeviceUseReportService {
...
@@ -627,7 +631,7 @@ public class DeviceUseReportServiceImpl implements DeviceUseReportService {
// .collect(toList());
// .collect(toList());
List
<
RepairBackBill
>
backBills
=
repairBackBillDao
.
findAll
().
stream
()
List
<
RepairBackBill
>
backBills
=
repairBackBillDao
.
findAll
().
stream
()
.
filter
(
repairBackBill
->
repairBackBill
.
getBackStatus
()
==
5
&&
.
filter
(
repairBackBill
->
repairBackBill
.
getBackStatus
()
==
5
&&
userPublicService
.
findByUnitsToname
(
1
).
equals
(
units
Servic
e
.
findById
(
repairBackBill
.
getReceiveUnitId
()).
getName
())
&&
repairBackBill
.
getCreateTime
().
after
(
startDate
)
&&
repairBackBill
.
getCreateTime
().
before
(
endDate
))
userPublicService
.
findByUnitsToname
(
1
).
equals
(
units
Cach
e
.
findById
(
repairBackBill
.
getReceiveUnitId
()).
getName
())
&&
repairBackBill
.
getCreateTime
().
after
(
startDate
)
&&
repairBackBill
.
getCreateTime
().
before
(
endDate
))
.
collect
(
toList
());
.
collect
(
toList
());
//获取所有的装备维修退回的
//获取所有的装备维修退回的
if
(
backBills
.
size
()>
0
){
if
(
backBills
.
size
()>
0
){
...
...
编写
预览
Markdown
格式
0%
重试
或
添加新文件
添加附件
取消
您添加了
0
人
到此讨论。请谨慎行事。
请先完成此评论的编辑!
取消
请
注册
或者
登录
后发表评论