|
@@ -75,65 +75,61 @@ public class NeiYeController {
|
|
|
}
|
|
|
|
|
|
if (queryDataResult != null && queryDataResult.size() > 0) {
|
|
|
- //删除非工序节点
|
|
|
- queryDataResult.removeIf(vo -> !new Integer("4").equals(vo.getMajorDataType()));
|
|
|
-
|
|
|
- if(queryDataResult.size() > 0){
|
|
|
- //分组
|
|
|
- List<List<QueryProcessDataVO>> groupList = CommonUtil.getBatchSize(queryDataResult, queryVO.getSize());
|
|
|
- List<QueryProcessDataVO> groupQueryList = groupList.get(queryVO.getCurrent() == 0 ? 0 : queryVO.getCurrent() - 1);
|
|
|
-
|
|
|
- //获取所有施工日志记录
|
|
|
- List<String> primaryKeyIds = groupQueryList.stream().map(QueryProcessDataVO::getPrimaryKeyId).distinct().collect(Collectors.toList());
|
|
|
- List<ConstructionLedger> ledgers = this.constructionLedgerService.list(Wrappers.<ConstructionLedger>lambdaQuery().in(ConstructionLedger::getWbsId, primaryKeyIds));
|
|
|
-
|
|
|
- for (QueryProcessDataVO vo : groupQueryList) {
|
|
|
- //处理父节点信息
|
|
|
- Map<String, String> map = new HashMap<>();
|
|
|
- this.foreachGetParent(map, idToNodeMap, vo.getParentId(), queryVO.getContractId());
|
|
|
-
|
|
|
- //获取当前工序的施工台账信息
|
|
|
- if (ledgers != null && ledgers.size() > 0) {
|
|
|
- Iterator<ConstructionLedger> iterator = ledgers.iterator();
|
|
|
- while (iterator.hasNext()) {
|
|
|
- ConstructionLedger ledger = iterator.next();
|
|
|
- if (vo.getPrimaryKeyId().equals(ledger.getWbsId().toString())) {
|
|
|
- if (ledger.getSiteStartTime() != null && ledger.getSiteEndTime() != null) {
|
|
|
- //获取施工起止时间
|
|
|
- map.put("siteStartToEndTime", DateUtil.format(ledger.getSiteStartTime(), "yyyy-MM-dd") + " ~ " + DateUtil.format(ledger.getSiteEndTime(), "yyyy-MM-dd"));
|
|
|
- }
|
|
|
- if (ledger.getDetectionStartTime() != null && ledger.getDetectionEndTime() != null) {
|
|
|
- //获取检测起止时间
|
|
|
- map.put("detectionStartToEndTime", DateUtil.format(ledger.getDetectionStartTime(), "yyyy-MM-dd") + " ~ " + DateUtil.format(ledger.getDetectionEndTime(), "yyyy-MM-dd"));
|
|
|
- }
|
|
|
- iterator.remove();
|
|
|
- break;
|
|
|
+ //分组
|
|
|
+ List<List<QueryProcessDataVO>> groupList = CommonUtil.getBatchSize(queryDataResult, queryVO.getSize());
|
|
|
+ List<QueryProcessDataVO> groupQueryList = groupList.get(queryVO.getCurrent() == 0 ? 0 : queryVO.getCurrent() - 1);
|
|
|
+
|
|
|
+ //获取所有施工日志记录
|
|
|
+ List<String> primaryKeyIds = groupQueryList.stream().map(QueryProcessDataVO::getPrimaryKeyId).distinct().collect(Collectors.toList());
|
|
|
+ List<ConstructionLedger> ledgers = this.constructionLedgerService.list(Wrappers.<ConstructionLedger>lambdaQuery().in(ConstructionLedger::getWbsId, primaryKeyIds));
|
|
|
+
|
|
|
+ for (QueryProcessDataVO vo : groupQueryList) {
|
|
|
+
|
|
|
+ //处理父节点信息
|
|
|
+ Map<String, String> map = new HashMap<>();
|
|
|
+ this.foreachGetParent(map, idToNodeMap, vo.getParentId(), queryVO.getContractId());
|
|
|
+
|
|
|
+ //获取当前工序的施工台账信息
|
|
|
+ if (ledgers != null && ledgers.size() > 0) {
|
|
|
+ Iterator<ConstructionLedger> iterator = ledgers.iterator();
|
|
|
+ while (iterator.hasNext()) {
|
|
|
+ ConstructionLedger ledger = iterator.next();
|
|
|
+ if (vo.getPrimaryKeyId().equals(ledger.getWbsId().toString())) {
|
|
|
+ if (ledger.getSiteStartTime() != null && ledger.getSiteEndTime() != null) {
|
|
|
+ //获取施工起止时间
|
|
|
+ map.put("siteStartToEndTime", DateUtil.format(ledger.getSiteStartTime(), "yyyy-MM-dd") + " ~ " + DateUtil.format(ledger.getSiteEndTime(), "yyyy-MM-dd"));
|
|
|
}
|
|
|
+ if (ledger.getDetectionStartTime() != null && ledger.getDetectionEndTime() != null) {
|
|
|
+ //获取检测起止时间
|
|
|
+ map.put("detectionStartToEndTime", DateUtil.format(ledger.getDetectionStartTime(), "yyyy-MM-dd") + " ~ " + DateUtil.format(ledger.getDetectionEndTime(), "yyyy-MM-dd"));
|
|
|
+ }
|
|
|
+ iterator.remove();
|
|
|
+ break;
|
|
|
}
|
|
|
}
|
|
|
- //todo 当前缺少是否关联评定、是否关联试验 =================================
|
|
|
- //新增列表数据
|
|
|
- neiYeLedgerVOList.add(new NeiYeLedgerVO(map.get("unitProject"),
|
|
|
- map.get("partProject"),
|
|
|
- map.get("partChildProject"),
|
|
|
- map.get("subentryProject"),
|
|
|
- map.get("subentryChildProject"),
|
|
|
- vo.getTitle(),
|
|
|
- map.get("siteStartToEndTime"),
|
|
|
- map.get("detectionStartToEndTime"),
|
|
|
- new Integer("1").equals(vo.getStatus()) ? "待审批" : new Integer("2").equals(vo.getStatus()) ? "已审批" : "未上报",
|
|
|
- vo.getEvaluate(),
|
|
|
- "false"));
|
|
|
}
|
|
|
- //转换为page信息
|
|
|
- Query query = new Query();
|
|
|
- query.setCurrent(queryVO.getCurrent());
|
|
|
- query.setSize(queryVO.getSize());
|
|
|
- IPage<NeiYeLedgerVO> page = Condition.getPage(query);
|
|
|
- page.setTotal(queryDataResult.size());
|
|
|
- page.setRecords(neiYeLedgerVOList);
|
|
|
- return R.data(page);
|
|
|
+ //todo 当前缺少是否关联评定、是否关联试验 =================================
|
|
|
+ //新增列表数据
|
|
|
+ neiYeLedgerVOList.add(new NeiYeLedgerVO(map.get("unitProject"),
|
|
|
+ map.get("partProject"),
|
|
|
+ map.get("partChildProject"),
|
|
|
+ map.get("subentryProject"),
|
|
|
+ map.get("subentryChildProject"),
|
|
|
+ vo.getTitle(),
|
|
|
+ map.get("siteStartToEndTime"),
|
|
|
+ map.get("detectionStartToEndTime"),
|
|
|
+ new Integer("1").equals(vo.getStatus()) ? "待审批" : new Integer("2").equals(vo.getStatus()) ? "已审批" : "未上报",
|
|
|
+ vo.getEvaluate(),
|
|
|
+ "false"));
|
|
|
}
|
|
|
+ //转换为page信息
|
|
|
+ Query query = new Query();
|
|
|
+ query.setCurrent(queryVO.getCurrent());
|
|
|
+ query.setSize(queryVO.getSize());
|
|
|
+ IPage<NeiYeLedgerVO> page = Condition.getPage(query);
|
|
|
+ page.setTotal(queryDataResult.size());
|
|
|
+ page.setRecords(neiYeLedgerVOList);
|
|
|
+ return R.data(page);
|
|
|
}
|
|
|
}
|
|
|
|