package com.fgkj.dao.impl;

import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;

import com.fgkj.dao.BaseDAO;
import com.fgkj.dao.CallBack;
import com.fgkj.dao.DAOHelper;
import com.fgkj.db.DBUtil;
import com.fgkj.dto.BattInf_Rebuild;
import com.mysql.fabric.xmlrpc.base.Array;

public class BattInf_RebuildImpl implements BaseDAO,CallBack{

	public List getResults(ResultSet rs) {
		// TODO Auto-generated method stub
		return null;
	}
    //添加
	public boolean add(Object obj) {
		BattInf_Rebuild br=(BattInf_Rebuild) obj;
		String sql="insert into db_battinf.tb_battinf_rebuild(old_stationname,old_battgroupname,old_battproducer,old_stationid,old_battgroupid,old_monum,new_stationname,new_battgroupname,new_battproducer,new_stationid,new_battgroupid,new_monum,rebuild_time,rebuild_uid,rebuild_clear_type) " +
				   "values(?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)";
		boolean bl=DAOHelper.executeUpdate(DBUtil.getConn(), sql, new Object[]{br.getOld_stationname(),br.getOld_battgroupname(),br.getOld_battproducer(),br.getOld_stationid(),br.getOld_battgroupid(),br.getOld_monum(),
			       br.getNew_stationname(),br.getNew_battgroupname(),br.getNew_battproducer(),br.getNew_stationid(),br.getNew_battgroupid(),br.getNew_monum(),br.getRebuild_time(),br.getRebuild_uid(),br.getRebuild_clear_type()});
		return bl;
	}
    //将同电池组同单体的记录变为历史(rebuild_clear_type=0)
	public boolean update(Object obj) {
		BattInf_Rebuild br=(BattInf_Rebuild) obj;
		String sql="update db_battinf.tb_battinf_rebuild set rebuild_clear_type=0 where  new_battgroupid=? and new_monum=? ";
		Boolean bl=DAOHelper.executeUpdate(DBUtil.getConn(), sql, new Object[]{br.getNew_battgroupid(),br.getNew_monum()});
		return bl;
	}

	public boolean del(Object obj) {
		// TODO Auto-generated method stub
		return false;
	}

	public List searchAll() {
		// TODO Auto-generated method stub
		return null;
	}
    //查询new_battgroupid,new_monum是否有被配组的记录
	public List serchByCondition(Object obj) {
		BattInf_Rebuild br=(BattInf_Rebuild) obj;
		String sql="select * from db_battinf.tb_battinf_rebuild  where  new_battgroupid=? and new_monum=? and rebuild_clear_type=1 limit 1";
		List list=DAOHelper.executeQuery(sql, DBUtil.getConn(),new Object[]{br.getNew_battgroupid(),br.getNew_monum()}, new CallBack() {
			
			public List getResults(ResultSet rs) {
				List list=new ArrayList();
				try {
					while(rs.next()){
						BattInf_Rebuild br=new BattInf_Rebuild();
						br.setNew_battgroupid(rs.getInt("new_battgroupid"));
						br.setNew_monum(rs.getInt("new_monum"));
						list.add(br);
					}
				} catch (SQLException e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				}
				return list;
			}
		});
		return list;
	}

	public List serchByInfo(Object obj) {
		// TODO Auto-generated method stub
		return null;
	}

}