|
@@ -514,15 +514,39 @@ public class OpsAppApi {
|
|
|
return R.success(resultMap);
|
|
|
}
|
|
|
|
|
|
+ /**
|
|
|
+ * 获取维修人员待处理数量
|
|
|
+ * @return
|
|
|
+ */
|
|
|
+ @PostMapping("/getDealCount")
|
|
|
+ public R<Integer> getDealCount() {
|
|
|
+
|
|
|
+ BaseContextHandler.setTenant("0000");
|
|
|
+ LbqWrapper<EquRecord> recordQueryWrap = Wraps.lbQ();
|
|
|
+ //todo 业务类型
|
|
|
+ int count = equRecordService.count();
|
|
|
+ return R.success(count);
|
|
|
+ }
|
|
|
+
|
|
|
private IPage<ProductionResource> pageListEquByProductResourceUserImpl(IPage<ProductionResource> page,
|
|
|
LbqWrapper<ProductionResource> queryWrap) {
|
|
|
IPage<ProductionResource> list = productionTenantResourceService.pageList(page, queryWrap);
|
|
|
+ LbqWrapper<EquRecord> recordQueryWrap = Wraps.lbQ();
|
|
|
+ //recordQueryWrap.eq(EquRecord::getServiceType,"FAILURE");
|
|
|
+ //recordQueryWrap.eq(EquRecord::getStatus,1);
|
|
|
+ List<EquRecord> records = equRecordService.list(recordQueryWrap);
|
|
|
if (null != list.getRecords() && list.getRecords().size() > 0) {
|
|
|
list.getRecords().stream().forEach(item -> {
|
|
|
Map map = productionTenantResourceService.getEquRunInfo(item.getId());
|
|
|
item.setOnlineStatus(map.containsKey("equStatus") ? map.get("equStatus").toString() : "0");
|
|
|
item.setErrMsg(map.containsKey("errMsg") && map.get("errMsg") != null ? map.get("errMsg").toString() : "");
|
|
|
Integer lackCount = productionTenantResourceService.getEquLockCount(item.getId());
|
|
|
+ boolean isDealFlag = records.stream().anyMatch(r->r.getEquId().equals(item.getId()));
|
|
|
+ if(isDealFlag){
|
|
|
+ item.setDealStatus(false);
|
|
|
+ }else{
|
|
|
+ item.setDealStatus(true);
|
|
|
+ }
|
|
|
item.setLackCount(lackCount);
|
|
|
});
|
|
|
}
|