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

package com.miniframe.bisiness.system;

import java.util.Map;
import com.miniframe.core.ExecProcessFlow;
import com.miniframe.core.exception.BusinessException;
import com.miniframe.core.ext.UtilTools;
import com.miniframe.generate.business.system.model.D10002BaseModel;
import com.miniframe.model.system.DNode;
import com.miniframe.model.system.DPipe;
import com.miniframe.model.system.DPipeSQLBuilder;
import com.miniframe.model.system.SysFile;
import com.miniframe.model.system.dao.DNodeMapper;
import com.miniframe.model.system.dao.DPipeMapper;
import com.miniframe.model.system.dao.SysFileMapper;
import tk.mybatis.mapper.util.StringUtil;

/**
 * 基础系统,“管道数据添加修改”逻辑处理（重新生成不覆盖）。
 */
public class D10002Service extends D10002BaseModel implements ExecProcessFlow {
	
	private static final long serialVersionUID = -7051358269847459502L;
		
	/**
	 * 基础系统,“管道数据添加修改”业务核心处理
 	 */
	public void transExecute() throws Exception {
		DPipeMapper dPipeDao = UtilTools.getBean(DPipeMapper.class);
		Integer pid = this.getA_d10002().getPid();
		String name =this.getA_d10002().getName();
		Integer snId = this.getA_d10002().getSnId();
		Integer enId =this.getA_d10002().getEnId();
		String roughCoe =this.getA_d10002().getRoughCoe();
		String sectionType =this.getA_d10002().getSectionType();
		String sectionPara1 =this.getA_d10002().getSectionPara1();
		String sectionPara2 =this.getA_d10002().getSectionPara2();
		String sectionPara3 =this.getA_d10002().getSectionPara3();
		String sectionPara4 =this.getA_d10002().getSectionPara4();
		String sectionPara5 =this.getA_d10002().getSectionPara5();
		String roughCoeName=this.getA_d10002().getRoughCoeName();
		String code =this.getA_d10002().getCode();

		String gfid = this.getA_d10002().getGfid();
		String bfid = this.getA_d10002().getBfid();
		SysFileMapper sysFileMapper = UtilTools.getBean(SysFileMapper.class);
		SysFile gf = sysFileMapper.selectByPrimaryKey(gfid);
//		if (gf == null) {
////			throw new BusinessException("EB3100020");
//		}
		SysFile bf = sysFileMapper.selectByPrimaryKey(bfid);
//		if (bf == null) {
////			throw new BusinessException("EB3100021");
//		}

		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,code,roughCoeName,gf,bf);
		}else{//修改
			DPipe pipe =dPipeDao.selectByPrimaryKey(pid);
			pdSnIdEnIdNotPid(dPipeDao,snId,enId,pid);
			if(pipe==null){
				throw new BusinessException("EB3100002");
			}
			updatePipe(dPipeDao, name, snId, enId, roughCoe, sectionType, sectionPara1, sectionPara2, sectionPara3, sectionPara4,
					sectionPara5,roughCoeName, pipe,code,gf,bf);
		}




	}


	public void pdSnIdEnIdNotPid(DPipeMapper dPipeDao,Integer snId,Integer enId, Integer pid) throws BusinessException {
		DPipeSQLBuilder sb =new DPipeSQLBuilder();
		DPipeSQLBuilder.Criteria sc = sb.createCriteria();
		sc.andSnidEqualTo(snId);
		sc.andEnidEqualTo(enId);
		sc.andIdNotEqualTo(pid);
		DPipe pip = dPipeDao.selectOneByExample(sb);
		if(pip!=null){
			throw new BusinessException("EB3100001");
		}
	}


	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,String roughCoeName, DPipe pipe,String code,SysFile gf,SysFile bf) {
		pipe.setName(name);
		pipe.setSnid(snId);
		pipe.setEnid(enId);
		pipe.setRoughCoe(Float.valueOf(roughCoe));
		pipe.setSectionType(sectionType);
		pipe.setSectionPara1(Float.valueOf(!StringUtil.isEmpty(sectionPara1)?sectionPara1:"0"));
		pipe.setSectionPara2(Float.valueOf(!StringUtil.isEmpty(sectionPara2)?sectionPara2:"0"));
		pipe.setSectionPara3(Float.valueOf(!StringUtil.isEmpty(sectionPara3)?sectionPara3:"0"));
		pipe.setSectionPara4(Float.valueOf(!StringUtil.isEmpty(sectionPara4)?sectionPara4:"0"));
		pipe.setSectionPara5(Float.valueOf(!StringUtil.isEmpty(sectionPara5)?sectionPara5:"0"));
		pipe.setCode(code);
		pipe.setRoughCoeName(roughCoeName);
		if(gf!=null){
			pipe.setGfid(gf.getId());
			pipe.setGfname(gf.getFilename());

		}
		if(bf!=null){
			pipe.setBfid(bf.getId());
			pipe.setBfname(bf.getFilename());
		}
		dPipeDao.updateByPrimaryKey(pipe);
	}

	public void pdSnIdEnIdExPid(DPipeMapper dPipeDao,Integer snId,Integer enId,Integer pid) throws BusinessException {
		DPipeSQLBuilder sb =new DPipeSQLBuilder();
		DPipeSQLBuilder.Criteria sc = sb.createCriteria();
		sc.andSnidEqualTo(snId);
		sc.andEnidEqualTo(enId);
		sc.andIdNotEqualTo(pid);
		DPipe pip = dPipeDao.selectOneByExample(sb);
		if(pip!=null){
			throw new BusinessException("EB3100001");
		}
	}

	private void savePipe(DPipeMapper dPipeDao, String name, Integer snId, Integer enId, String roughCoe, String sectionType,
						  String sectionPara1, String sectionPara2, String sectionPara3, String sectionPara4, String sectionPara5,
	String code,String roughCoeName ,SysFile gf,SysFile bf) {
		DPipe pipe =new DPipe();
		pipe.setName(name);
		pipe.setSnid(snId);
		pipe.setEnid(enId);
		pipe.setRoughCoe(Float.valueOf(roughCoe));
		pipe.setSectionType(sectionType);
		pipe.setSectionPara1(Float.valueOf(!StringUtil.isEmpty(sectionPara1)?sectionPara1:"0"));
		pipe.setSectionPara2(Float.valueOf(!StringUtil.isEmpty(sectionPara2)?sectionPara2:"0"));
		pipe.setSectionPara3(Float.valueOf(!StringUtil.isEmpty(sectionPara3)?sectionPara3:"0"));
		pipe.setSectionPara4(Float.valueOf(!StringUtil.isEmpty(sectionPara4)?sectionPara4:"0"));
		pipe.setSectionPara5(Float.valueOf(!StringUtil.isEmpty(sectionPara5)?sectionPara5:"0"));
		pipe.setCode(code);
		if(gf!=null){
			pipe.setGfid(gf.getId());
			pipe.setGfname(gf.getFilename());
		}
		if(bf!=null){
			pipe.setBfid(bf.getId());
			pipe.setBfname(bf.getFilename());
		}
		pipe.setRoughCoeName(roughCoeName);
		dPipeDao.insertSelective(pipe);
	}

	public void pdSnIdEnId(DPipeMapper dPipeDao,Integer snId,Integer enId) throws BusinessException {
		DPipeSQLBuilder sb =new DPipeSQLBuilder();
		DPipeSQLBuilder.Criteria sc = sb.createCriteria();
		sc.andSnidEqualTo(snId);
		sc.andEnidEqualTo(enId);
		DPipe pip = dPipeDao.selectOneByExample(sb);
		if(pip!=null){
			throw new BusinessException("EB3100001");
		}
	}

	/**
	 * 基础系统,“管道数据添加修改”业务前处理
 	 */
	public void preTransFlow() throws Exception {
		this.validater();
	}
	
	/**
	 * 基础系统,“管道数据添加修改”业务后处理
 	 */
	public void afterTransFlow() throws Exception {
	
	}
	
	/**
	 * 基础系统,“管道数据添加修改”逻辑入口处理方法
 	 */
 	@SuppressWarnings("rawtypes")
	@Override
	public Map execute(Map vars) throws Exception {
		this.setTransMap(vars);
		preTransFlow();// 执行业务开始的规则检查和校验
		transExecute();// 执行核心业务段
		afterTransFlow();// 执行核心逻辑完成后的收尾逻辑
		return this.getTransMap();
	}

}