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.D000010BaseModel;
import com.miniframe.model.system.DPipe;
import com.miniframe.model.system.DSource;
import com.miniframe.model.system.dao.DPipeMapper;
import com.miniframe.model.system.dao.DSourceMapper;

/**
 * 基础系统,“灾情点源数据修改”逻辑处理（重新生成不覆盖）。
 */
public class D000010Service extends D000010BaseModel implements ExecProcessFlow {
	
	private static final long serialVersionUID = -7051358269847459502L;
		
	/**
	 * 基础系统,“灾情点源数据修改”业务核心处理
 	 */
	public void transExecute() throws Exception {
		Integer sid = this.getA_d000010().getSid();
		Integer pid =this.getA_d000010().getPid();
		double site =this.getA_d000010().getSite();
		DSourceMapper dsm = UtilTools.getBean(DSourceMapper.class);
		DSource ds = dsm.selectByPrimaryKey(sid);
		if(ds==null){
			throw new BusinessException("EB3000004");//点源数据不存在
		}
		DPipeMapper pipeMapper=UtilTools.getBean(DPipeMapper.class);
		DPipe pipe =pipeMapper.selectByPrimaryKey(pid);
		ds.setPname(pipe.getName());
		ds.setPid(pid);
		ds.setPcode(pipe.getCode());
		ds.setSite((float)site);
		ds.setSiteremark(this.getA_d000010().getSiteremark());
		dsm.updateByPrimaryKey(ds);
	}
	
	/**
	 * 基础系统,“灾情点源数据修改”业务前处理
 	 */
	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();
	}

}