管道添加NodeId限制

src/main/java/com/miniframe/bisiness/system/D10002Service.java

@@ -36,6 +36,14 @@ public class D10002Service extends D10002BaseModel implements ExecProcessFlow {
 		String sectionPara4 =this.getA_d10002().getSectionPara4();
 		String sectionPara5 =this.getA_d10002().getSectionPara5();
 
+
+		DNodeMapper nodeMapper =UtilTools.getBean(DNodeMapper.class);
+		DNode sNode = nodeMapper.selectByPrimaryKey(snId);
+		DNode eNode = nodeMapper.selectByPrimaryKey(enId);
+		if(sNode==null || eNode==null){
+			throw  new BusinessException("EB3000001");
+		}
+
 		if(pid ==null || pid<=0){//添加
 			pdSnIdEnId(dPipeDao,snId,enId);
 			savePipe(dPipeDao, name, snId, enId, roughCoe, sectionType, sectionPara1, sectionPara2, sectionPara3, sectionPara4, sectionPara5);
@@ -46,6 +54,7 @@ public class D10002Service extends D10002BaseModel implements ExecProcessFlow {
 			}
 			updatePipe(dPipeDao, name, snId, enId, roughCoe, sectionType, sectionPara1, sectionPara2, sectionPara3, sectionPara4, sectionPara5, pipe);
 		}
+
 	}
 
 	private void updatePipe(DPipeMapper dPipeDao, String name, Integer snId, Integer enId, String roughCoe, String sectionType, String sectionPara1, String sectionPara2, String sectionPara3, String sectionPara4, String sectionPara5, DPipe pipe) {