提交 0ed46fc1 authored 作者: zhoushaopan's avatar zhoushaopan

fix(大屏模块): 更新bug

解决了维修报空指针
上级 96cd4bc8
...@@ -22,6 +22,7 @@ import com.tykj.dev.device.user.subject.entity.Area; ...@@ -22,6 +22,7 @@ import com.tykj.dev.device.user.subject.entity.Area;
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;
import com.tykj.dev.misc.base.BusinessEnum; import com.tykj.dev.misc.base.BusinessEnum;
import com.tykj.dev.misc.base.StatusEnum;
import com.tykj.dev.misc.utils.StringSplitUtil; import com.tykj.dev.misc.utils.StringSplitUtil;
import com.tykj.dev.statistical.cache.StatisticalCache; import com.tykj.dev.statistical.cache.StatisticalCache;
import com.tykj.dev.statistical.service.BigScreenService; import com.tykj.dev.statistical.service.BigScreenService;
...@@ -148,7 +149,10 @@ public class BigScreenServiceImpl implements BigScreenService { ...@@ -148,7 +149,10 @@ public class BigScreenServiceImpl implements BigScreenService {
centerNum.setDeviceAddCount((int) deviceLibraryDao.findAll().stream().filter(deviceLibrary -> deviceLibrary.getCreateTime()!=null&&isPresentYear(deviceLibrary.getCreateTime())).count()); centerNum.setDeviceAddCount((int) deviceLibraryDao.findAll().stream().filter(deviceLibrary -> deviceLibrary.getCreateTime()!=null&&isPresentYear(deviceLibrary.getCreateTime())).count());
//故障率 //故障率
Set<Integer> repairDeviceIds = new HashSet<>(); Set<Integer> repairDeviceIds = new HashSet<>();
List<Task> tasks = taskDao.findAllByBusinessType(BusinessEnum.REPAIR.id).stream().filter(task -> task.getParentTaskId()==null).collect(Collectors.toList()); List<Task> businessList = taskDao.findAllByBusinessType(BusinessEnum.REPAIR.id);
List<Task> tasks = businessList.stream()
.filter(task -> task.getParentTaskId()==null && !task.getBillStatus().equals(StatusEnum.END.id) && !task.getBillStatus().equals(StatusEnum.REVOKEALLOTTASK.id))
.collect(Collectors.toList());
List<RepairSendBill> repairSendBills = tasks.stream() List<RepairSendBill> repairSendBills = tasks.stream()
.map(task -> repairBillService.getOne(task.getBillId())) .map(task -> repairBillService.getOne(task.getBillId()))
.map(repairBill -> repairSendBillDao.findByDeviceRepairBillId(repairBill.getId())) .map(repairBill -> repairSendBillDao.findByDeviceRepairBillId(repairBill.getId()))
...@@ -170,7 +174,8 @@ public class BigScreenServiceImpl implements BigScreenService { ...@@ -170,7 +174,8 @@ public class BigScreenServiceImpl implements BigScreenService {
@Override @Override
public RepairNum getRepairNum() { public RepairNum getRepairNum() {
RepairNum repairNum = new RepairNum(); RepairNum repairNum = new RepairNum();
List<Task> tasks = taskDao.findAllByBusinessType(BusinessEnum.REPAIR.id).stream().filter(task -> task.getParentTaskId()==null).collect(Collectors.toList()); List<Task> tasks = taskDao.findAllByBusinessType(BusinessEnum.REPAIR.id).stream()
.filter(task -> task.getParentTaskId()==null && !task.getBillStatus().equals(StatusEnum.END.id) && !task.getBillStatus().equals(StatusEnum.REVOKEALLOTTASK.id)).collect(Collectors.toList());
List<List<RepairDetail>> repairDetails = tasks.stream() List<List<RepairDetail>> repairDetails = tasks.stream()
.map(task -> repairBillService.getOne(task.getBillId())) .map(task -> repairBillService.getOne(task.getBillId()))
.map(repairBill -> repairDetailDao.findByDeviceRepairBillId(repairBill.getId())) .map(repairBill -> repairDetailDao.findByDeviceRepairBillId(repairBill.getId()))
...@@ -224,7 +229,8 @@ public class BigScreenServiceImpl implements BigScreenService { ...@@ -224,7 +229,8 @@ public class BigScreenServiceImpl implements BigScreenService {
@Override @Override
public List<RepairDevice> getRepairDevices() { public List<RepairDevice> getRepairDevices() {
List<RepairDevice> repairDevices = new ArrayList<>(); List<RepairDevice> repairDevices = new ArrayList<>();
List<Task> tasks = taskDao.findAllByBusinessType(BusinessEnum.REPAIR.id).stream().filter(task -> task.getParentTaskId()==null).collect(Collectors.toList()); List<Task> tasks = taskDao.findAllByBusinessType(BusinessEnum.REPAIR.id).stream()
.filter(task -> task.getParentTaskId()==null && !task.getBillStatus().equals(StatusEnum.END.id) && !task.getBillStatus().equals(StatusEnum.REVOKEALLOTTASK.id)).collect(Collectors.toList());
List<List<RepairDetail>> repairDetails = tasks.stream() List<List<RepairDetail>> repairDetails = tasks.stream()
.map(task -> repairBillService.getOne(task.getBillId())) .map(task -> repairBillService.getOne(task.getBillId()))
.map(repairBill -> repairDetailDao.findByDeviceRepairBillId(repairBill.getId())) .map(repairBill -> repairDetailDao.findByDeviceRepairBillId(repairBill.getId()))
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论