|
@@ -457,7 +457,7 @@ public class WbsTreePrivateServiceImpl extends BaseServiceImpl<WbsTreePrivateMap
|
|
List<WbsTreePrivate> listPrivate = new ArrayList<>();
|
|
List<WbsTreePrivate> listPrivate = new ArrayList<>();
|
|
List<WbsTreeContract> listContract = new ArrayList<>();
|
|
List<WbsTreeContract> listContract = new ArrayList<>();
|
|
//获取当前项目下所有合同段信息
|
|
//获取当前项目下所有合同段信息
|
|
- List<ContractInfo> contractInfos = contractInfoMapper.selectList(Wrappers.<ContractInfo>query().lambda().eq(ContractInfo::getPId, projectId));
|
|
|
|
|
|
+ List<ContractInfo> contractInfos = contractInfoMapper.selectList(Wrappers.<ContractInfo>query().lambda().select(ContractInfo::getId).eq(ContractInfo::getPId, projectId));
|
|
|
|
|
|
for (WbsTreePrivate wbsTreePrivate : wbsTreePrivates) {
|
|
for (WbsTreePrivate wbsTreePrivate : wbsTreePrivates) {
|
|
for (WbsTreePrivate treePrivateNow : wbsTreePrivatesAllNow) {
|
|
for (WbsTreePrivate treePrivateNow : wbsTreePrivatesAllNow) {
|
|
@@ -471,8 +471,8 @@ public class WbsTreePrivateServiceImpl extends BaseServiceImpl<WbsTreePrivateMap
|
|
|| (ObjectUtils.isNotEmpty(wbsTreePrivate.getImportMatchingInfo()) && !wbsTreePrivate.getImportMatchingInfo().equals(treePrivateNow.getImportMatchingInfo()))
|
|
|| (ObjectUtils.isNotEmpty(wbsTreePrivate.getImportMatchingInfo()) && !wbsTreePrivate.getImportMatchingInfo().equals(treePrivateNow.getImportMatchingInfo()))
|
|
|| (ObjectUtils.isNotEmpty(wbsTreePrivate.getMixRatioTestIds()) && !wbsTreePrivate.getMixRatioTestIds().equals(treePrivateNow.getMixRatioTestIds()))
|
|
|| (ObjectUtils.isNotEmpty(wbsTreePrivate.getMixRatioTestIds()) && !wbsTreePrivate.getMixRatioTestIds().equals(treePrivateNow.getMixRatioTestIds()))
|
|
|| (ObjectUtils.isNotEmpty(wbsTreePrivate.getInitTableId()) && !wbsTreePrivate.getInitTableId().equals(treePrivateNow.getInitTableId()))
|
|
|| (ObjectUtils.isNotEmpty(wbsTreePrivate.getInitTableId()) && !wbsTreePrivate.getInitTableId().equals(treePrivateNow.getInitTableId()))
|
|
- || (ObjectUtils.isNotEmpty(wbsTreePrivate.getInitTableName()) && !wbsTreePrivate.getInitTableName().equals(treePrivateNow.getInitTableName()))
|
|
|
|
- )) {
|
|
|
|
|
|
+ || (ObjectUtils.isNotEmpty(wbsTreePrivate.getInitTableName()) && !wbsTreePrivate.getInitTableName().equals(treePrivateNow.getInitTableName())
|
|
|
|
+ || (ObjectUtils.isNotEmpty(wbsTreePrivate.getHtmlUrl()) && !wbsTreePrivate.getHtmlUrl().equals(treePrivateNow.getHtmlUrl()))))) {
|
|
//修改项目wbs信息
|
|
//修改项目wbs信息
|
|
WbsTreePrivate wbsPrivate = BeanUtil.copyProperties(wbsTreePrivate, WbsTreePrivate.class);
|
|
WbsTreePrivate wbsPrivate = BeanUtil.copyProperties(wbsTreePrivate, WbsTreePrivate.class);
|
|
if (wbsPrivate != null) {
|
|
if (wbsPrivate != null) {
|
|
@@ -493,14 +493,18 @@ public class WbsTreePrivateServiceImpl extends BaseServiceImpl<WbsTreePrivateMap
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
|
|
|
|
+ //修改到项目
|
|
if (listPrivate.size() > 0) {
|
|
if (listPrivate.size() > 0) {
|
|
baseMapper.updateBatchWbsPrivate(listPrivate);
|
|
baseMapper.updateBatchWbsPrivate(listPrivate);
|
|
}
|
|
}
|
|
|
|
+
|
|
|
|
+ //修改到合同段
|
|
if (listContract.size() > 0) {
|
|
if (listContract.size() > 0) {
|
|
//获取合同段下的复制、新增节点
|
|
//获取合同段下的复制、新增节点
|
|
List<WbsTreeContract> wbsTreeContractsCopyOrAddAll = new ArrayList<>();
|
|
List<WbsTreeContract> wbsTreeContractsCopyOrAddAll = new ArrayList<>();
|
|
for (ContractInfo contractInfo : contractInfos) {
|
|
for (ContractInfo contractInfo : contractInfos) {
|
|
List<WbsTreeContract> wbsTreeContractsCopyOrAdd = wbsTreeContractMapper.selectList(Wrappers.<WbsTreeContract>lambdaQuery()
|
|
List<WbsTreeContract> wbsTreeContractsCopyOrAdd = wbsTreeContractMapper.selectList(Wrappers.<WbsTreeContract>lambdaQuery()
|
|
|
|
+ .select(WbsTreeContract::getId, WbsTreeContract::getOldId, WbsTreeContract::getProjectId, WbsTreeContract::getContractId)
|
|
.eq(WbsTreeContract::getProjectId, projectId)
|
|
.eq(WbsTreeContract::getProjectId, projectId)
|
|
.eq(WbsTreeContract::getContractId, contractInfo.getId())
|
|
.eq(WbsTreeContract::getContractId, contractInfo.getId())
|
|
.eq(WbsTreeContract::getWbsType, wbsType)
|
|
.eq(WbsTreeContract::getWbsType, wbsType)
|
|
@@ -520,6 +524,7 @@ public class WbsTreePrivateServiceImpl extends BaseServiceImpl<WbsTreePrivateMap
|
|
obj2.setMajorDataType(obj1.getMajorDataType());
|
|
obj2.setMajorDataType(obj1.getMajorDataType());
|
|
obj2.setTableType(obj1.getTableType());
|
|
obj2.setTableType(obj1.getTableType());
|
|
obj2.setTableOwner(obj1.getTableOwner());
|
|
obj2.setTableOwner(obj1.getTableOwner());
|
|
|
|
+ obj2.setHtmlUrl(obj1.getHtmlUrl());
|
|
listContractAdd.add(obj2);
|
|
listContractAdd.add(obj2);
|
|
}
|
|
}
|
|
}
|
|
}
|
|
@@ -802,34 +807,19 @@ public class WbsTreePrivateServiceImpl extends BaseServiceImpl<WbsTreePrivateMap
|
|
|
|
|
|
if (("1").equals(wbsTreePrivate.getWbsType())) {
|
|
if (("1").equals(wbsTreePrivate.getWbsType())) {
|
|
if (("public").equals(projectInfo.getReferenceWbsTemplateType())) {
|
|
if (("public").equals(projectInfo.getReferenceWbsTemplateType())) {
|
|
- /*TODO-------------------------------------公有引用同步--------------------------------------------*/
|
|
|
|
|
|
+ /*TODO-------------------------------------质检公有引用同步--------------------------------------------*/
|
|
//获取当前节点对应的公有引用树下的元素表
|
|
//获取当前节点对应的公有引用树下的元素表
|
|
- WbsTree wbsTree = wbsTreeMapper.selectOne(Wrappers.<WbsTree>query().lambda()
|
|
|
|
- .eq(WbsTree::getId, wbsTreePrivate.getId())
|
|
|
|
- );
|
|
|
|
|
|
+ WbsTree wbsTree = wbsTreeMapper.selectOne(Wrappers.<WbsTree>query().lambda().eq(WbsTree::getId, wbsTreePrivate.getId()));
|
|
List<WbsTree> wbsTreesPublicTables;
|
|
List<WbsTree> wbsTreesPublicTables;
|
|
if (wbsTree.getAncestors().equals("0")) {
|
|
if (wbsTree.getAncestors().equals("0")) {
|
|
//根节点
|
|
//根节点
|
|
- wbsTreesPublicTables = wbsTreeMapper.selectList(Wrappers.<WbsTree>query().lambda()
|
|
|
|
- .eq(WbsTree::getWbsId, wbsTree.getWbsId())
|
|
|
|
- .eq(WbsTree::getType, 2)
|
|
|
|
- .eq(WbsTree::getStatus, 1)
|
|
|
|
- );
|
|
|
|
|
|
+ wbsTreesPublicTables = wbsTreeMapper.selectList(Wrappers.<WbsTree>query().lambda().eq(WbsTree::getWbsId, wbsTree.getWbsId()).eq(WbsTree::getType, 2).eq(WbsTree::getStatus, 1));
|
|
} else {
|
|
} else {
|
|
- wbsTreesPublicTables = wbsTreeMapper.selectList(Wrappers.<WbsTree>query().lambda()
|
|
|
|
- .eq(WbsTree::getWbsId, wbsTree.getWbsId())
|
|
|
|
- .eq(WbsTree::getType, 2)
|
|
|
|
- .eq(WbsTree::getStatus, 1)
|
|
|
|
- .like(WbsTree::getAncestors, wbsTree.getId())
|
|
|
|
- );
|
|
|
|
|
|
+ wbsTreesPublicTables = wbsTreeMapper.selectList(Wrappers.<WbsTree>query().lambda().eq(WbsTree::getWbsId, wbsTree.getWbsId()).eq(WbsTree::getType, 2).eq(WbsTree::getStatus, 1).like(WbsTree::getAncestors, wbsTree.getId()));
|
|
}
|
|
}
|
|
|
|
|
|
//获取当前项目树下的元素表 节点
|
|
//获取当前项目树下的元素表 节点
|
|
- List<WbsTreePrivate> wbsTreePrivatesProjectAll = baseMapper.selectList(Wrappers.<WbsTreePrivate>query().lambda()
|
|
|
|
- .eq(WbsTreePrivate::getProjectId, wbsTreePrivate.getProjectId())
|
|
|
|
- .eq(WbsTreePrivate::getWbsId, wbsTreePrivate.getWbsId())
|
|
|
|
- .eq(WbsTreePrivate::getStatus, 1)
|
|
|
|
- );
|
|
|
|
|
|
+ List<WbsTreePrivate> wbsTreePrivatesProjectAll = baseMapper.selectList(Wrappers.<WbsTreePrivate>query().lambda().eq(WbsTreePrivate::getProjectId, wbsTreePrivate.getProjectId()).eq(WbsTreePrivate::getWbsId, wbsTreePrivate.getWbsId()).eq(WbsTreePrivate::getStatus, 1));
|
|
List<WbsTreePrivate> wbsTreePrivatesProjectNodes = wbsTreePrivatesProjectAll.stream().filter(f -> f.getType().equals(1)).collect(Collectors.toList());
|
|
List<WbsTreePrivate> wbsTreePrivatesProjectNodes = wbsTreePrivatesProjectAll.stream().filter(f -> f.getType().equals(1)).collect(Collectors.toList());
|
|
|
|
|
|
List<WbsTreePrivate> wbsTreePrivatesProjectTables;
|
|
List<WbsTreePrivate> wbsTreePrivatesProjectTables;
|
|
@@ -842,22 +832,17 @@ public class WbsTreePrivateServiceImpl extends BaseServiceImpl<WbsTreePrivateMap
|
|
|
|
|
|
//获取新增的公有元素表addPublicTable
|
|
//获取新增的公有元素表addPublicTable
|
|
List<WbsTree> addPublicTable = wbsTreesPublicTables.stream().filter(f ->
|
|
List<WbsTree> addPublicTable = wbsTreesPublicTables.stream().filter(f ->
|
|
- !wbsTreePrivatesProjectTables.stream().map(WbsTreePrivate::getId).collect(Collectors.toList()).contains(f.getId()))
|
|
|
|
- .collect(Collectors.toList());
|
|
|
|
|
|
+ !wbsTreePrivatesProjectTables.stream().map(WbsTreePrivate::getId).collect(Collectors.toList()).contains(f.getId())).collect(Collectors.toList());
|
|
|
|
|
|
//判断当前新增的表在项目的wbs树中是否存在上级节点,存在表示可以新增,不存在表示不新增
|
|
//判断当前新增的表在项目的wbs树中是否存在上级节点,存在表示可以新增,不存在表示不新增
|
|
List<WbsTree> addPublicTables = addPublicTable.stream().filter(node ->
|
|
List<WbsTree> addPublicTables = addPublicTable.stream().filter(node ->
|
|
- wbsTreePrivatesProjectNodes.stream().map(WbsTreePrivate::getId).collect(Collectors.toList()).contains(node.getParentId())
|
|
|
|
- ).collect(Collectors.toList());
|
|
|
|
|
|
+ wbsTreePrivatesProjectNodes.stream().map(WbsTreePrivate::getId).collect(Collectors.toList()).contains(node.getParentId())).collect(Collectors.toList());
|
|
|
|
|
|
//获取当前项目下所有施工合同段id
|
|
//获取当前项目下所有施工合同段id
|
|
List<ContractInfo> contractInfos = contractInfoMapper.selectList(Wrappers.<ContractInfo>query().lambda().eq(ContractInfo::getPId, wbsTreePrivate.getProjectId()));
|
|
List<ContractInfo> contractInfos = contractInfoMapper.selectList(Wrappers.<ContractInfo>query().lambda().eq(ContractInfo::getPId, wbsTreePrivate.getProjectId()));
|
|
|
|
|
|
//获取当前项目下所有合同段树
|
|
//获取当前项目下所有合同段树
|
|
- List<WbsTreeContract> treeContractListAll = wbsTreeContractMapper.selectList(Wrappers.<WbsTreeContract>query().lambda()
|
|
|
|
- .eq(WbsTreeContract::getProjectId, wbsTreePrivate.getProjectId())
|
|
|
|
- .eq(WbsTreeContract::getStatus, 1)
|
|
|
|
- );
|
|
|
|
|
|
+ List<WbsTreeContract> treeContractListAll = wbsTreeContractMapper.selectList(Wrappers.<WbsTreeContract>query().lambda().eq(WbsTreeContract::getProjectId, wbsTreePrivate.getProjectId()).eq(WbsTreeContract::getStatus, 1));
|
|
List<WbsTreeContract> treeContractListAllNodes = treeContractListAll.stream().filter(f -> f.getType().equals(1)).collect(Collectors.toList());
|
|
List<WbsTreeContract> treeContractListAllNodes = treeContractListAll.stream().filter(f -> f.getType().equals(1)).collect(Collectors.toList());
|
|
List<WbsTreeContract> treeContractListAllTables = treeContractListAll.stream().filter(f -> f.getType().equals(2)).collect(Collectors.toList());
|
|
List<WbsTreeContract> treeContractListAllTables = treeContractListAll.stream().filter(f -> f.getType().equals(2)).collect(Collectors.toList());
|
|
|
|
|
|
@@ -946,35 +931,20 @@ public class WbsTreePrivateServiceImpl extends BaseServiceImpl<WbsTreePrivateMap
|
|
}
|
|
}
|
|
|
|
|
|
} else if (("private").equals(projectInfo.getReferenceWbsTemplateType())) {
|
|
} else if (("private").equals(projectInfo.getReferenceWbsTemplateType())) {
|
|
- /*TODO-------------------------------------私有引用同步--------------------------------------------*/
|
|
|
|
|
|
+ /*TODO-------------------------------------质检私有引用同步--------------------------------------------*/
|
|
//根据wbsTreePrivate的wbsId=私有引用的pKeyId来获取引用树根节点
|
|
//根据wbsTreePrivate的wbsId=私有引用的pKeyId来获取引用树根节点
|
|
WbsTreePrivate wbsTreePrivateRoot = baseMapper.selectOne(Wrappers.<WbsTreePrivate>query().lambda().eq(WbsTreePrivate::getPKeyId, wbsTreePrivate.getWbsId()));
|
|
WbsTreePrivate wbsTreePrivateRoot = baseMapper.selectOne(Wrappers.<WbsTreePrivate>query().lambda().eq(WbsTreePrivate::getPKeyId, wbsTreePrivate.getWbsId()));
|
|
//获取当前私有引用树的元素表信息
|
|
//获取当前私有引用树的元素表信息
|
|
List<WbsTreePrivate> wbsTreePrivateRootTables;
|
|
List<WbsTreePrivate> wbsTreePrivateRootTables;
|
|
if (wbsTreePrivate.getAncestors().equals("0")) {
|
|
if (wbsTreePrivate.getAncestors().equals("0")) {
|
|
//根节点
|
|
//根节点
|
|
- wbsTreePrivateRootTables = baseMapper.selectList(Wrappers.<WbsTreePrivate>query().lambda()
|
|
|
|
- .eq(WbsTreePrivate::getProjectId, wbsTreePrivateRoot.getProjectId())
|
|
|
|
- .eq(WbsTreePrivate::getWbsId, wbsTreePrivateRoot.getWbsId())
|
|
|
|
- .eq(WbsTreePrivate::getType, 2)
|
|
|
|
- .eq(WbsTreePrivate::getStatus, 1)
|
|
|
|
- );
|
|
|
|
|
|
+ wbsTreePrivateRootTables = baseMapper.selectList(Wrappers.<WbsTreePrivate>query().lambda().eq(WbsTreePrivate::getProjectId, wbsTreePrivateRoot.getProjectId()).eq(WbsTreePrivate::getWbsId, wbsTreePrivateRoot.getWbsId()).eq(WbsTreePrivate::getType, 2).eq(WbsTreePrivate::getStatus, 1));
|
|
} else {
|
|
} else {
|
|
- wbsTreePrivateRootTables = baseMapper.selectList(Wrappers.<WbsTreePrivate>query().lambda()
|
|
|
|
- .eq(WbsTreePrivate::getProjectId, wbsTreePrivateRoot.getProjectId())
|
|
|
|
- .eq(WbsTreePrivate::getWbsId, wbsTreePrivateRoot.getWbsId())
|
|
|
|
- .eq(WbsTreePrivate::getType, 2)
|
|
|
|
- .eq(WbsTreePrivate::getStatus, 1)
|
|
|
|
- .like(WbsTreePrivate::getAncestors, wbsTreePrivate.getId())
|
|
|
|
- );
|
|
|
|
|
|
+ wbsTreePrivateRootTables = baseMapper.selectList(Wrappers.<WbsTreePrivate>query().lambda().eq(WbsTreePrivate::getProjectId, wbsTreePrivateRoot.getProjectId()).eq(WbsTreePrivate::getWbsId, wbsTreePrivateRoot.getWbsId()).eq(WbsTreePrivate::getType, 2).eq(WbsTreePrivate::getStatus, 1).like(WbsTreePrivate::getAncestors, wbsTreePrivate.getId()));
|
|
}
|
|
}
|
|
|
|
|
|
//获取当前项目选择的节点下的所有元素表 节点
|
|
//获取当前项目选择的节点下的所有元素表 节点
|
|
- List<WbsTreePrivate> wbsTreePrivatesProjectAll = baseMapper.selectList(Wrappers.<WbsTreePrivate>query().lambda()
|
|
|
|
- .eq(WbsTreePrivate::getProjectId, wbsTreePrivate.getProjectId())
|
|
|
|
- .eq(WbsTreePrivate::getWbsId, wbsTreePrivate.getWbsId())
|
|
|
|
- .eq(WbsTreePrivate::getStatus, 1)
|
|
|
|
- );
|
|
|
|
|
|
+ List<WbsTreePrivate> wbsTreePrivatesProjectAll = baseMapper.selectList(Wrappers.<WbsTreePrivate>query().lambda().eq(WbsTreePrivate::getProjectId, wbsTreePrivate.getProjectId()).eq(WbsTreePrivate::getWbsId, wbsTreePrivate.getWbsId()).eq(WbsTreePrivate::getStatus, 1));
|
|
|
|
|
|
List<WbsTreePrivate> wbsTreePrivatesProjectNodes = wbsTreePrivatesProjectAll.stream().filter(f -> f.getType().equals(1)).collect(Collectors.toList());
|
|
List<WbsTreePrivate> wbsTreePrivatesProjectNodes = wbsTreePrivatesProjectAll.stream().filter(f -> f.getType().equals(1)).collect(Collectors.toList());
|
|
List<WbsTreePrivate> wbsTreePrivatesProjectTables;
|
|
List<WbsTreePrivate> wbsTreePrivatesProjectTables;
|
|
@@ -987,22 +957,17 @@ public class WbsTreePrivateServiceImpl extends BaseServiceImpl<WbsTreePrivateMap
|
|
|
|
|
|
//获取新增的私有元素表addPrivateTable
|
|
//获取新增的私有元素表addPrivateTable
|
|
List<WbsTreePrivate> addPrivateTable = wbsTreePrivateRootTables.stream().filter(f ->
|
|
List<WbsTreePrivate> addPrivateTable = wbsTreePrivateRootTables.stream().filter(f ->
|
|
- !wbsTreePrivatesProjectTables.stream().map(WbsTreePrivate::getId).collect(Collectors.toList()).contains(f.getId()))
|
|
|
|
- .collect(Collectors.toList());
|
|
|
|
|
|
+ !wbsTreePrivatesProjectTables.stream().map(WbsTreePrivate::getId).collect(Collectors.toList()).contains(f.getId())).collect(Collectors.toList());
|
|
|
|
|
|
//获取当前项目下所有施工合同段id
|
|
//获取当前项目下所有施工合同段id
|
|
List<ContractInfo> contractInfos = contractInfoMapper.selectContractIdByProjectId(wbsTreePrivate.getProjectId());
|
|
List<ContractInfo> contractInfos = contractInfoMapper.selectContractIdByProjectId(wbsTreePrivate.getProjectId());
|
|
|
|
|
|
//判断当前新增的表在私有wbs中是否存在上级节点,存在表示可以新增,不存在表示不新增
|
|
//判断当前新增的表在私有wbs中是否存在上级节点,存在表示可以新增,不存在表示不新增
|
|
List<WbsTreePrivate> addPrivateTables = addPrivateTable.stream().filter(node ->
|
|
List<WbsTreePrivate> addPrivateTables = addPrivateTable.stream().filter(node ->
|
|
- wbsTreePrivatesProjectNodes.stream().map(WbsTreePrivate::getId).collect(Collectors.toList()).contains(node.getParentId())
|
|
|
|
- ).collect(Collectors.toList());
|
|
|
|
|
|
+ wbsTreePrivatesProjectNodes.stream().map(WbsTreePrivate::getId).collect(Collectors.toList()).contains(node.getParentId())).collect(Collectors.toList());
|
|
|
|
|
|
//获取当前项目下所有合同段树
|
|
//获取当前项目下所有合同段树
|
|
- List<WbsTreeContract> treeContractListAll = wbsTreeContractMapper.selectList(Wrappers.<WbsTreeContract>query().lambda()
|
|
|
|
- .eq(WbsTreeContract::getProjectId, wbsTreePrivate.getProjectId())
|
|
|
|
- .eq(WbsTreeContract::getStatus, 1)
|
|
|
|
- );
|
|
|
|
|
|
+ List<WbsTreeContract> treeContractListAll = wbsTreeContractMapper.selectList(Wrappers.<WbsTreeContract>query().lambda().eq(WbsTreeContract::getProjectId, wbsTreePrivate.getProjectId()).eq(WbsTreeContract::getStatus, 1));
|
|
List<WbsTreeContract> treeContractListAllNodes = treeContractListAll.stream().filter(f -> f.getType().equals(1)).collect(Collectors.toList());
|
|
List<WbsTreeContract> treeContractListAllNodes = treeContractListAll.stream().filter(f -> f.getType().equals(1)).collect(Collectors.toList());
|
|
List<WbsTreeContract> treeContractListAllTables = treeContractListAll.stream().filter(f -> f.getType().equals(2)).collect(Collectors.toList());
|
|
List<WbsTreeContract> treeContractListAllTables = treeContractListAll.stream().filter(f -> f.getType().equals(2)).collect(Collectors.toList());
|
|
|
|
|
|
@@ -1089,34 +1054,19 @@ public class WbsTreePrivateServiceImpl extends BaseServiceImpl<WbsTreePrivateMap
|
|
}
|
|
}
|
|
if (("2").equals(wbsTreePrivate.getWbsType())) {
|
|
if (("2").equals(wbsTreePrivate.getWbsType())) {
|
|
if (("public").equals(projectInfo.getReferenceWbsTemplateTypeTrial())) {
|
|
if (("public").equals(projectInfo.getReferenceWbsTemplateTypeTrial())) {
|
|
- /*TODO-------------------------------------公有引用同步--------------------------------------------*/
|
|
|
|
|
|
+ /*TODO-------------------------------------试验公有引用同步--------------------------------------------*/
|
|
//获取当前节点对应的公有引用树下的元素表
|
|
//获取当前节点对应的公有引用树下的元素表
|
|
- WbsTree wbsTree = wbsTreeMapper.selectOne(Wrappers.<WbsTree>query().lambda()
|
|
|
|
- .eq(WbsTree::getId, wbsTreePrivate.getId())
|
|
|
|
- );
|
|
|
|
|
|
+ WbsTree wbsTree = wbsTreeMapper.selectOne(Wrappers.<WbsTree>query().lambda().eq(WbsTree::getId, wbsTreePrivate.getId()));
|
|
List<WbsTree> wbsTreesPublicTables;
|
|
List<WbsTree> wbsTreesPublicTables;
|
|
if (wbsTree.getAncestors().equals("0")) {
|
|
if (wbsTree.getAncestors().equals("0")) {
|
|
//根节点
|
|
//根节点
|
|
- wbsTreesPublicTables = wbsTreeMapper.selectList(Wrappers.<WbsTree>query().lambda()
|
|
|
|
- .eq(WbsTree::getWbsId, wbsTree.getWbsId())
|
|
|
|
- .eq(WbsTree::getType, 2)
|
|
|
|
- .eq(WbsTree::getStatus, 1)
|
|
|
|
- );
|
|
|
|
|
|
+ wbsTreesPublicTables = wbsTreeMapper.selectList(Wrappers.<WbsTree>query().lambda().eq(WbsTree::getWbsId, wbsTree.getWbsId()).eq(WbsTree::getType, 2).eq(WbsTree::getStatus, 1));
|
|
} else {
|
|
} else {
|
|
- wbsTreesPublicTables = wbsTreeMapper.selectList(Wrappers.<WbsTree>query().lambda()
|
|
|
|
- .eq(WbsTree::getWbsId, wbsTree.getWbsId())
|
|
|
|
- .eq(WbsTree::getType, 2)
|
|
|
|
- .eq(WbsTree::getStatus, 1)
|
|
|
|
- .like(WbsTree::getAncestors, wbsTree.getId())
|
|
|
|
- );
|
|
|
|
|
|
+ wbsTreesPublicTables = wbsTreeMapper.selectList(Wrappers.<WbsTree>query().lambda().eq(WbsTree::getWbsId, wbsTree.getWbsId()).eq(WbsTree::getType, 2).eq(WbsTree::getStatus, 1).like(WbsTree::getAncestors, wbsTree.getId()));
|
|
}
|
|
}
|
|
|
|
|
|
//获取当前项目树下的元素表 节点
|
|
//获取当前项目树下的元素表 节点
|
|
- List<WbsTreePrivate> wbsTreePrivatesProjectAll = baseMapper.selectList(Wrappers.<WbsTreePrivate>query().lambda()
|
|
|
|
- .eq(WbsTreePrivate::getProjectId, wbsTreePrivate.getProjectId())
|
|
|
|
- .eq(WbsTreePrivate::getWbsId, wbsTreePrivate.getWbsId())
|
|
|
|
- .eq(WbsTreePrivate::getStatus, 1)
|
|
|
|
- );
|
|
|
|
|
|
+ List<WbsTreePrivate> wbsTreePrivatesProjectAll = baseMapper.selectList(Wrappers.<WbsTreePrivate>query().lambda().eq(WbsTreePrivate::getProjectId, wbsTreePrivate.getProjectId()).eq(WbsTreePrivate::getWbsId, wbsTreePrivate.getWbsId()).eq(WbsTreePrivate::getStatus, 1));
|
|
List<WbsTreePrivate> wbsTreePrivatesProjectNodes = wbsTreePrivatesProjectAll.stream().filter(f -> f.getType().equals(1)).collect(Collectors.toList());
|
|
List<WbsTreePrivate> wbsTreePrivatesProjectNodes = wbsTreePrivatesProjectAll.stream().filter(f -> f.getType().equals(1)).collect(Collectors.toList());
|
|
|
|
|
|
List<WbsTreePrivate> wbsTreePrivatesProjectTables;
|
|
List<WbsTreePrivate> wbsTreePrivatesProjectTables;
|
|
@@ -1129,22 +1079,17 @@ public class WbsTreePrivateServiceImpl extends BaseServiceImpl<WbsTreePrivateMap
|
|
|
|
|
|
//获取新增的公有元素表addPublicTable
|
|
//获取新增的公有元素表addPublicTable
|
|
List<WbsTree> addPublicTable = wbsTreesPublicTables.stream().filter(f ->
|
|
List<WbsTree> addPublicTable = wbsTreesPublicTables.stream().filter(f ->
|
|
- !wbsTreePrivatesProjectTables.stream().map(WbsTreePrivate::getId).collect(Collectors.toList()).contains(f.getId()))
|
|
|
|
- .collect(Collectors.toList());
|
|
|
|
|
|
+ !wbsTreePrivatesProjectTables.stream().map(WbsTreePrivate::getId).collect(Collectors.toList()).contains(f.getId())).collect(Collectors.toList());
|
|
|
|
|
|
//判断当前新增的表在项目的wbs树中是否存在上级节点,存在表示可以新增,不存在表示不新增
|
|
//判断当前新增的表在项目的wbs树中是否存在上级节点,存在表示可以新增,不存在表示不新增
|
|
List<WbsTree> addPublicTables = addPublicTable.stream().filter(node ->
|
|
List<WbsTree> addPublicTables = addPublicTable.stream().filter(node ->
|
|
- wbsTreePrivatesProjectNodes.stream().map(WbsTreePrivate::getId).collect(Collectors.toList()).contains(node.getParentId())
|
|
|
|
- ).collect(Collectors.toList());
|
|
|
|
|
|
+ wbsTreePrivatesProjectNodes.stream().map(WbsTreePrivate::getId).collect(Collectors.toList()).contains(node.getParentId())).collect(Collectors.toList());
|
|
|
|
|
|
//获取当前项目下所有施工合同段id
|
|
//获取当前项目下所有施工合同段id
|
|
List<ContractInfo> contractInfos = contractInfoMapper.selectList(Wrappers.<ContractInfo>query().lambda().eq(ContractInfo::getPId, wbsTreePrivate.getProjectId()));
|
|
List<ContractInfo> contractInfos = contractInfoMapper.selectList(Wrappers.<ContractInfo>query().lambda().eq(ContractInfo::getPId, wbsTreePrivate.getProjectId()));
|
|
|
|
|
|
//获取当前项目下所有合同段树
|
|
//获取当前项目下所有合同段树
|
|
- List<WbsTreeContract> treeContractListAll = wbsTreeContractMapper.selectList(Wrappers.<WbsTreeContract>query().lambda()
|
|
|
|
- .eq(WbsTreeContract::getProjectId, wbsTreePrivate.getProjectId())
|
|
|
|
- .eq(WbsTreeContract::getStatus, 1)
|
|
|
|
- );
|
|
|
|
|
|
+ List<WbsTreeContract> treeContractListAll = wbsTreeContractMapper.selectList(Wrappers.<WbsTreeContract>query().lambda().eq(WbsTreeContract::getProjectId, wbsTreePrivate.getProjectId()).eq(WbsTreeContract::getStatus, 1));
|
|
List<WbsTreeContract> treeContractListAllNodes = treeContractListAll.stream().filter(f -> f.getType().equals(1)).collect(Collectors.toList());
|
|
List<WbsTreeContract> treeContractListAllNodes = treeContractListAll.stream().filter(f -> f.getType().equals(1)).collect(Collectors.toList());
|
|
List<WbsTreeContract> treeContractListAllTables = treeContractListAll.stream().filter(f -> f.getType().equals(2)).collect(Collectors.toList());
|
|
List<WbsTreeContract> treeContractListAllTables = treeContractListAll.stream().filter(f -> f.getType().equals(2)).collect(Collectors.toList());
|
|
|
|
|
|
@@ -1233,35 +1178,20 @@ public class WbsTreePrivateServiceImpl extends BaseServiceImpl<WbsTreePrivateMap
|
|
}
|
|
}
|
|
|
|
|
|
} else if (("private").equals(projectInfo.getReferenceWbsTemplateTypeTrial())) {
|
|
} else if (("private").equals(projectInfo.getReferenceWbsTemplateTypeTrial())) {
|
|
- /*TODO-------------------------------------私有引用同步--------------------------------------------*/
|
|
|
|
|
|
+ /*TODO-------------------------------------试验私有引用同步--------------------------------------------*/
|
|
//根据wbsTreePrivate的wbsId=私有引用的pKeyId来获取引用树根节点
|
|
//根据wbsTreePrivate的wbsId=私有引用的pKeyId来获取引用树根节点
|
|
WbsTreePrivate wbsTreePrivateRoot = baseMapper.selectOne(Wrappers.<WbsTreePrivate>query().lambda().eq(WbsTreePrivate::getPKeyId, wbsTreePrivate.getWbsId()));
|
|
WbsTreePrivate wbsTreePrivateRoot = baseMapper.selectOne(Wrappers.<WbsTreePrivate>query().lambda().eq(WbsTreePrivate::getPKeyId, wbsTreePrivate.getWbsId()));
|
|
//获取当前私有引用树的元素表信息
|
|
//获取当前私有引用树的元素表信息
|
|
List<WbsTreePrivate> wbsTreePrivateRootTables;
|
|
List<WbsTreePrivate> wbsTreePrivateRootTables;
|
|
if (wbsTreePrivate.getAncestors().equals("0")) {
|
|
if (wbsTreePrivate.getAncestors().equals("0")) {
|
|
//根节点
|
|
//根节点
|
|
- wbsTreePrivateRootTables = baseMapper.selectList(Wrappers.<WbsTreePrivate>query().lambda()
|
|
|
|
- .eq(WbsTreePrivate::getProjectId, wbsTreePrivateRoot.getProjectId())
|
|
|
|
- .eq(WbsTreePrivate::getWbsId, wbsTreePrivateRoot.getWbsId())
|
|
|
|
- .eq(WbsTreePrivate::getType, 2)
|
|
|
|
- .eq(WbsTreePrivate::getStatus, 1)
|
|
|
|
- );
|
|
|
|
|
|
+ wbsTreePrivateRootTables = baseMapper.selectList(Wrappers.<WbsTreePrivate>query().lambda().eq(WbsTreePrivate::getProjectId, wbsTreePrivateRoot.getProjectId()).eq(WbsTreePrivate::getWbsId, wbsTreePrivateRoot.getWbsId()).eq(WbsTreePrivate::getType, 2).eq(WbsTreePrivate::getStatus, 1));
|
|
} else {
|
|
} else {
|
|
- wbsTreePrivateRootTables = baseMapper.selectList(Wrappers.<WbsTreePrivate>query().lambda()
|
|
|
|
- .eq(WbsTreePrivate::getProjectId, wbsTreePrivateRoot.getProjectId())
|
|
|
|
- .eq(WbsTreePrivate::getWbsId, wbsTreePrivateRoot.getWbsId())
|
|
|
|
- .eq(WbsTreePrivate::getType, 2)
|
|
|
|
- .eq(WbsTreePrivate::getStatus, 1)
|
|
|
|
- .like(WbsTreePrivate::getAncestors, wbsTreePrivate.getId())
|
|
|
|
- );
|
|
|
|
|
|
+ wbsTreePrivateRootTables = baseMapper.selectList(Wrappers.<WbsTreePrivate>query().lambda().eq(WbsTreePrivate::getProjectId, wbsTreePrivateRoot.getProjectId()).eq(WbsTreePrivate::getWbsId, wbsTreePrivateRoot.getWbsId()).eq(WbsTreePrivate::getType, 2).eq(WbsTreePrivate::getStatus, 1).like(WbsTreePrivate::getAncestors, wbsTreePrivate.getId()));
|
|
}
|
|
}
|
|
|
|
|
|
//获取当前项目选择的节点下的所有元素表 节点
|
|
//获取当前项目选择的节点下的所有元素表 节点
|
|
- List<WbsTreePrivate> wbsTreePrivatesProjectAll = baseMapper.selectList(Wrappers.<WbsTreePrivate>query().lambda()
|
|
|
|
- .eq(WbsTreePrivate::getProjectId, wbsTreePrivate.getProjectId())
|
|
|
|
- .eq(WbsTreePrivate::getWbsId, wbsTreePrivate.getWbsId())
|
|
|
|
- .eq(WbsTreePrivate::getStatus, 1)
|
|
|
|
- );
|
|
|
|
|
|
+ List<WbsTreePrivate> wbsTreePrivatesProjectAll = baseMapper.selectList(Wrappers.<WbsTreePrivate>query().lambda().eq(WbsTreePrivate::getProjectId, wbsTreePrivate.getProjectId()).eq(WbsTreePrivate::getWbsId, wbsTreePrivate.getWbsId()).eq(WbsTreePrivate::getStatus, 1));
|
|
|
|
|
|
List<WbsTreePrivate> wbsTreePrivatesProjectNodes = wbsTreePrivatesProjectAll.stream().filter(f -> f.getType().equals(1)).collect(Collectors.toList());
|
|
List<WbsTreePrivate> wbsTreePrivatesProjectNodes = wbsTreePrivatesProjectAll.stream().filter(f -> f.getType().equals(1)).collect(Collectors.toList());
|
|
List<WbsTreePrivate> wbsTreePrivatesProjectTables;
|
|
List<WbsTreePrivate> wbsTreePrivatesProjectTables;
|
|
@@ -1274,22 +1204,17 @@ public class WbsTreePrivateServiceImpl extends BaseServiceImpl<WbsTreePrivateMap
|
|
|
|
|
|
//获取新增的私有元素表addPrivateTable
|
|
//获取新增的私有元素表addPrivateTable
|
|
List<WbsTreePrivate> addPrivateTable = wbsTreePrivateRootTables.stream().filter(f ->
|
|
List<WbsTreePrivate> addPrivateTable = wbsTreePrivateRootTables.stream().filter(f ->
|
|
- !wbsTreePrivatesProjectTables.stream().map(WbsTreePrivate::getId).collect(Collectors.toList()).contains(f.getId()))
|
|
|
|
- .collect(Collectors.toList());
|
|
|
|
|
|
+ !wbsTreePrivatesProjectTables.stream().map(WbsTreePrivate::getId).collect(Collectors.toList()).contains(f.getId())).collect(Collectors.toList());
|
|
|
|
|
|
//获取当前项目下所有施工合同段id
|
|
//获取当前项目下所有施工合同段id
|
|
List<ContractInfo> contractInfos = contractInfoMapper.selectContractIdByProjectId(wbsTreePrivate.getProjectId());
|
|
List<ContractInfo> contractInfos = contractInfoMapper.selectContractIdByProjectId(wbsTreePrivate.getProjectId());
|
|
|
|
|
|
//判断当前新增的表在私有wbs中是否存在上级节点,存在表示可以新增,不存在表示不新增
|
|
//判断当前新增的表在私有wbs中是否存在上级节点,存在表示可以新增,不存在表示不新增
|
|
List<WbsTreePrivate> addPrivateTables = addPrivateTable.stream().filter(node ->
|
|
List<WbsTreePrivate> addPrivateTables = addPrivateTable.stream().filter(node ->
|
|
- wbsTreePrivatesProjectNodes.stream().map(WbsTreePrivate::getId).collect(Collectors.toList()).contains(node.getParentId())
|
|
|
|
- ).collect(Collectors.toList());
|
|
|
|
|
|
+ wbsTreePrivatesProjectNodes.stream().map(WbsTreePrivate::getId).collect(Collectors.toList()).contains(node.getParentId())).collect(Collectors.toList());
|
|
|
|
|
|
//获取当前项目下所有合同段树
|
|
//获取当前项目下所有合同段树
|
|
- List<WbsTreeContract> treeContractListAll = wbsTreeContractMapper.selectList(Wrappers.<WbsTreeContract>query().lambda()
|
|
|
|
- .eq(WbsTreeContract::getProjectId, wbsTreePrivate.getProjectId())
|
|
|
|
- .eq(WbsTreeContract::getStatus, 1)
|
|
|
|
- );
|
|
|
|
|
|
+ List<WbsTreeContract> treeContractListAll = wbsTreeContractMapper.selectList(Wrappers.<WbsTreeContract>query().lambda().eq(WbsTreeContract::getProjectId, wbsTreePrivate.getProjectId()).eq(WbsTreeContract::getStatus, 1));
|
|
List<WbsTreeContract> treeContractListAllNodes = treeContractListAll.stream().filter(f -> f.getType().equals(1)).collect(Collectors.toList());
|
|
List<WbsTreeContract> treeContractListAllNodes = treeContractListAll.stream().filter(f -> f.getType().equals(1)).collect(Collectors.toList());
|
|
List<WbsTreeContract> treeContractListAllTables = treeContractListAll.stream().filter(f -> f.getType().equals(2)).collect(Collectors.toList());
|
|
List<WbsTreeContract> treeContractListAllTables = treeContractListAll.stream().filter(f -> f.getType().equals(2)).collect(Collectors.toList());
|
|
|
|
|
|
@@ -1476,9 +1401,6 @@ public class WbsTreePrivateServiceImpl extends BaseServiceImpl<WbsTreePrivateMap
|
|
jdbcTemplate.execute(delSql);
|
|
jdbcTemplate.execute(delSql);
|
|
}
|
|
}
|
|
|
|
|
|
- //新增
|
|
|
|
- //textDictInfoService.insertBatch(insertData, 1000);
|
|
|
|
-
|
|
|
|
//异步新增
|
|
//异步新增
|
|
List<List<TextdictInfo>> partition1 = Lists.partition(insertData, 1000);
|
|
List<List<TextdictInfo>> partition1 = Lists.partition(insertData, 1000);
|
|
CompletableFuture<Void> handle = CompletableFuture.allOf(partition1.stream().map(addList ->
|
|
CompletableFuture<Void> handle = CompletableFuture.allOf(partition1.stream().map(addList ->
|