~whyclxw/sensor.git

package com.fgkj.dao.impl; 
 
import java.sql.ResultSet; 
import java.sql.SQLException; 
import java.util.ArrayList; 
import java.util.Date; 
import java.util.List; 
 
import com.fgkj.dao.BaseDAO; 
import com.fgkj.dao.CallBack; 
import com.fgkj.dao.DAOHelper; 
import com.fgkj.dao.UinfDaoFactory; 
import com.fgkj.db.DBUtil; 
import com.fgkj.db.IDatabaseName; 
import com.fgkj.dto.BattInf; 
import com.fgkj.dto.User_battgroup_baojigroup; 
import com.fgkj.dto.User_battgroup_baojigroup_battgroup; 
import com.fgkj.dto.User_inf; 
import com.fgkj.dto.User_log; 
import com.fgkj.services.User_logService; 
 
public class User_battgroup_baojigroup_battgroupImpl implements BaseDAO,CallBack{ 
 
    public List getResults(ResultSet rs) { 
        List list = new ArrayList(); 
        try { 
            while (rs.next()) { 
                User_battgroup_baojigroup_battgroup userbattgroup = new User_battgroup_baojigroup_battgroup(); 
 
                userbattgroup.setNum(Integer.parseInt(rs.getString("num"))); 
 
                userbattgroup.setBaoji_group_id(Integer.parseInt(rs.getString("baoji_group_id"))); 
                 
                userbattgroup.setStationId(Integer.parseInt(rs.getString("StationId"))); 
                 
                userbattgroup.setBattGroupId(Integer.parseInt(rs.getString("BattGroupId"))); 
 
 
                list.add(userbattgroup); 
            } 
        } catch (SQLException e) { 
            e.printStackTrace(); 
        } 
        return list; 
    } 
 
    //5.3添加选取电池组或者机房或者维护区 
    public boolean add(Object obj) { 
        User_battgroup_baojigroup_battgroup ugroup=(User_battgroup_baojigroup_battgroup) obj; 
        String sql="insert into db_user.tb_user_battgroup_baojigroup_battgroup(baoji_group_id,StationId,BattGroupId) values(?,?,?)"; 
        Boolean bl=DAOHelper.executeUpdate(DBUtil.getConn(), sql, new Object[]{ugroup.getBaoji_group_id(),ugroup.getStationId(), 
            ugroup.getBattGroupId()}); 
        return bl; 
    } 
    //5.3添加选取电池组或者机房或者维护区(多笔数据) 
    public boolean addPro(Object obj) { 
        List<User_battgroup_baojigroup_battgroup> list=(List) obj; 
        ArrayList sql_strs=new ArrayList(); 
        List<User_log> listU=new ArrayList<User_log>();//存放user_log 
        if(list!=null&&list.size()>0){ 
            for (User_battgroup_baojigroup_battgroup ugroup : list) { 
                String sql="insert into db_user.tb_user_battgroup_baojigroup_battgroup(baoji_group_id,StationId,BattGroupId) values("+ugroup.getBaoji_group_id()+","+ugroup.getStationId()+","+ugroup.getBattGroupId()+")"; 
                sql_strs.add(sql); 
                { 
                    String msg="添加"+ugroup.getNote()+"至"+ugroup.getBaoji_group_name()+"包机组中"; 
                    User_log ulog=UinfDaoFactory.CreateULog(UinfDaoFactory.Increase, msg); 
                    listU.add(ulog); 
                 } 
            } 
        } 
        boolean bl=DAOHelper.makeManualCommit(DBUtil.getConn(), sql_strs); 
        (new User_logService()).addPro(listU);//将用户的操作记录下来 
        return bl; 
    } 
    public boolean update(Object obj) { 
        User_battgroup_baojigroup_battgroup ugroup=(User_battgroup_baojigroup_battgroup) obj; 
        String sql="update db_user.tb_user_battgroup_baojigroup_battgroup set baoji_group_id=?,StationId=?,BattGroupId=? where num=?"; 
        Boolean bl=DAOHelper.executeUpdate(DBUtil.getConn(), sql, new Object[]{ugroup.getBaoji_group_id(),ugroup.getStationId(), 
            ugroup.getBattGroupId(),ugroup.getNum()}); 
        return bl; 
    } 
 
    //5.3删除选取的电池组 
    public boolean del(Object obj) { 
        User_battgroup_baojigroup_battgroup ugroup=(User_battgroup_baojigroup_battgroup) obj; 
        String sql="delete from db_user.tb_user_battgroup_baojigroup_battgroup where baoji_group_id=? and battgroupid=? and stationid=?"; 
        Boolean bl=DAOHelper.executeUpdate(DBUtil.getConn(), sql, new Object[]{ugroup.getBaoji_group_id(),ugroup.getBattGroupId(),ugroup.getStationId()}); 
        return bl; 
    } 
    //5.3删除选取的电池组(多笔数据) 
    public boolean delPro(Object obj) { 
        List<User_battgroup_baojigroup_battgroup> list=(List) obj; 
        ArrayList sql_strs=new ArrayList(); 
        List<User_log> listU=new ArrayList<User_log>();//存放user_log 
        if(list!=null&&list.size()>0){ 
            for (User_battgroup_baojigroup_battgroup ugroup : list) { 
                String sql="delete from db_user.tb_user_battgroup_baojigroup_battgroup where baoji_group_id="+ugroup.getBaoji_group_id()+" and battgroupid="+ugroup.getBattGroupId()+" and stationid="+ugroup.getStationId(); 
                sql_strs.add(sql); 
                { 
                    String msg="删除"+ugroup.getBaoji_group_name()+"包机组中"+ugroup.getNote()+"电池组"; 
                    User_log ulog=UinfDaoFactory.CreateULog(UinfDaoFactory.Delete, msg); 
                    listU.add(ulog); 
                 } 
            } 
        } 
        boolean bl=DAOHelper.makeManualCommit(DBUtil.getConn(), sql_strs); 
        (new User_logService()).addPro(listU);//将用户的操作记录下来 
        return bl; 
    } 
    //5.3删除(删除指定包机组下所有用户) 
    public String delAll(Object obj) { 
        User_battgroup_baojigroup ubao=(User_battgroup_baojigroup) obj; 
        String sql = "delete from db_user.tb_user_battgroup_baojigroup_battgroup where baoji_group_id="+ubao.getBaoji_group_id(); 
        return sql; 
    } 
 
 
    public List searchAll() { 
        String sql = "select * from db_user.tb_user_battgroup_baojigroup_battgroup"; 
        List list = DAOHelper 
                .executeQuery(sql, DBUtil.getConn(), null, 
                        new User_battgroup_baojigroup_battgroupImpl()); 
        return list; 
    } 
   
    //5.1根据uid查机房和电池组 
    public List serchByCondition(Object obj) { 
        User_inf uinf=(User_inf) obj; 
        String sql="select distinct(db_battinf.tb_battinf.stationname),db_battinf.tb_battinf.stationname1,db_battinf.tb_battinf.stationid,db_battinf.tb_battinf.battgroupid,db_battinf.tb_battinf.battgroupname " + 
                "from db_battinf.tb_battinf " + 
                "left outer join db_user.tb_user_battgroup_baojigroup_battgroup on db_user.tb_user_battgroup_baojigroup_battgroup.stationid=db_battinf.tb_battinf.stationid " + 
                "left outer join db_user.tb_user_battgroup_baojigroup_usr on db_user.tb_user_battgroup_baojigroup_usr.baoji_group_id=db_user.tb_user_battgroup_baojigroup_battgroup.baoji_group_id " + 
                "left outer join db_user.tb_user_inf on tb_user_inf.uid=db_user.tb_user_battgroup_baojigroup_usr.uid " + 
                "where db_user.tb_user_inf.uid=?  ORDER BY db_battinf.tb_battinf.stationname1,db_battinf.tb_battinf.BattGroupId"; 
        //System.out.println(sql); 
        List list = DAOHelper 
                .executeQuery(sql, DBUtil.getConn(), new Object[]{uinf.getUId()}, 
                        new CallBack() {                 
                            public List getResults(ResultSet rs) { 
                                List list=new ArrayList(); 
                                try { 
                                    while(rs.next()){ 
                                        BattInf binf=new BattInf(); 
                                        binf.setStationName1(rs.getString("stationName1")); 
                                        binf.setStationName(rs.getString("stationName")); 
                                        binf.setStationId(rs.getString("stationid")); 
                                        binf.setBattGroupName(rs.getString("battGroupName")); 
                                        binf.setBattGroupId(rs.getInt("battgroupid")); 
                                        list.add(binf); 
                                    } 
                                } catch (SQLException e) { 
                                    // TODO Auto-generated catch block 
                                    e.printStackTrace(); 
                                } 
                                return list; 
                            } 
                        }); 
        return list; 
    } 
    //放电测试(查询用户管理的维护区) 
    public List serchStationName1InGroup(Object obj){ 
        User_inf uinf=(User_inf) obj; 
        String sql="select distinct db_battinf.tb_battinf.stationname1  " + 
                "from db_battinf.tb_battinf " + 
                "left outer join db_user.tb_user_battgroup_baojigroup_battgroup on db_user.tb_user_battgroup_baojigroup_battgroup.stationid=db_battinf.tb_battinf.stationid " + 
                "left outer join db_user.tb_user_battgroup_baojigroup_usr on db_user.tb_user_battgroup_baojigroup_usr.baoji_group_id=db_user.tb_user_battgroup_baojigroup_battgroup.baoji_group_id " + 
                "left outer join db_user.tb_user_inf on tb_user_inf.uid=db_user.tb_user_battgroup_baojigroup_usr.uid " + 
                "where db_user.tb_user_inf.uid=?  ORDER BY db_battinf.tb_battinf.stationname1,db_battinf.tb_battinf.BattGroupId"; 
        List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{uinf.getUId()}, new CallBack() { 
            public List getResults(ResultSet rs) { 
                List list=new ArrayList(); 
                try { 
                    while(rs.next()){ 
                        list.add(rs.getString("stationName1")); 
                    } 
                } catch (SQLException e) { 
                    // TODO Auto-generated catch block 
                    e.printStackTrace(); 
                } 
                return list; 
            } 
        }); 
        return list; 
    } 
    //放电测试(查询用户管理的维护区对应的机房) 
    public List serchStationNameInGroup(Object obj){ 
        User_inf uinf=(User_inf) obj; 
        String sql="select distinct db_battinf.tb_battinf.stationname  " + 
                "from db_battinf.tb_battinf " + 
                "left outer join db_user.tb_user_battgroup_baojigroup_battgroup on db_user.tb_user_battgroup_baojigroup_battgroup.stationid=db_battinf.tb_battinf.stationid " + 
                "left outer join db_user.tb_user_battgroup_baojigroup_usr on db_user.tb_user_battgroup_baojigroup_usr.baoji_group_id=db_user.tb_user_battgroup_baojigroup_battgroup.baoji_group_id " + 
                "left outer join db_user.tb_user_inf on tb_user_inf.uid=db_user.tb_user_battgroup_baojigroup_usr.uid " + 
                "where db_user.tb_user_inf.uid=? and db_battinf.tb_battinf.stationname1 like ? ORDER BY db_battinf.tb_battinf.stationname1,db_battinf.tb_battinf.BattGroupId"; 
        List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{uinf.getUId(),"%"+uinf.getUNote()+"%"}, new CallBack() { 
            public List getResults(ResultSet rs) { 
                List list=new ArrayList(); 
                try { 
                    while(rs.next()){ 
                        list.add(rs.getString("stationname")); 
                    } 
                } catch (SQLException e) { 
                    // TODO Auto-generated catch block 
                    e.printStackTrace(); 
                } 
                return list; 
            } 
        }); 
        return list; 
    } 
 
    //首页(查询用户管理的维护区对应的机房和机房ID以及设备id) 
    public List serchStationByStationName1(Object obj){ 
        User_inf uinf=(User_inf) obj; 
        String sql="select distinct db_battinf.tb_battinf.stationname,db_battinf.tb_battinf.stationid,db_battinf.tb_battinf.fBSDeviceId " + 
                "from db_battinf.tb_battinf " + 
                "left outer join db_user.tb_user_battgroup_baojigroup_battgroup on db_user.tb_user_battgroup_baojigroup_battgroup.stationid=db_battinf.tb_battinf.stationid " + 
                "left outer join db_user.tb_user_battgroup_baojigroup_usr on db_user.tb_user_battgroup_baojigroup_usr.baoji_group_id=db_user.tb_user_battgroup_baojigroup_battgroup.baoji_group_id " + 
                "left outer join db_user.tb_user_inf on tb_user_inf.uid=db_user.tb_user_battgroup_baojigroup_usr.uid " + 
                "where db_user.tb_user_inf.uid=? and db_battinf.tb_battinf.stationname1 like ? ORDER BY db_battinf.tb_battinf.stationname1,db_battinf.tb_battinf.BattGroupId"; 
        List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{uinf.getUId(),"%"+uinf.getUNote()+"%"}, new CallBack() { 
            public List getResults(ResultSet rs) { 
                List list=new ArrayList(); 
                try { 
                    while(rs.next()){ 
                        BattInf binf=new BattInf(); 
                        binf.setStationName(rs.getString("stationName")); 
                        binf.setStationId(rs.getString("stationId")); 
                        binf.setFBSDeviceId(rs.getInt("fBSDeviceId")); 
                        list.add(binf); 
                    } 
                } catch (SQLException e) { 
                    // TODO Auto-generated catch block 
                    e.printStackTrace(); 
                } 
                return list; 
            } 
        }); 
        return list; 
    } 
     
    //放电测试(查询用户管理的维护区对应的机房对应的battgroupid) 
    public List serchBattgroupidInGroup(Object obj){ 
        User_inf uinf=(User_inf) obj; 
        String sql="select distinct db_battinf.tb_battinf.battgroupid,db_battinf.tb_battinf.stationName,db_battinf.tb_battinf.battgroupname,db_battinf.tb_battinf.moncount,db_battinf.tb_battinf.GroupIndexInFBSDevice,db_battinf.tb_battinf.FBSDeviceId  " + 
                "from db_battinf.tb_battinf " + 
                "left outer join db_user.tb_user_battgroup_baojigroup_battgroup on db_user.tb_user_battgroup_baojigroup_battgroup.BattGroupId=db_battinf.tb_battinf.BattGroupId " + 
                "left outer join db_user.tb_user_battgroup_baojigroup_usr on db_user.tb_user_battgroup_baojigroup_usr.baoji_group_id=db_user.tb_user_battgroup_baojigroup_battgroup.baoji_group_id " + 
                "left outer join db_user.tb_user_inf on tb_user_inf.uid=db_user.tb_user_battgroup_baojigroup_usr.uid " + 
                "where db_user.tb_user_inf.uid=? and db_battinf.tb_battinf.stationname1 like ? and db_battinf.tb_battinf.stationname like ?  ORDER BY db_battinf.tb_battinf.stationname1,db_battinf.tb_battinf.BattGroupId"; 
        List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{uinf.getUId(),"%"+uinf.getUNote()+"%","%"+uinf.getUName()+"%"}, new CallBack() { 
            public List getResults(ResultSet rs) { 
                List list=new ArrayList(); 
                try { 
                    while(rs.next()){ 
                        BattInf binf=new BattInf(); 
                        binf.setBattGroupId(rs.getInt("battGroupId")); 
                        binf.setStationName(rs.getString("stationName")); 
                        binf.setBattGroupName(rs.getString("battGroupName")); 
                        binf.setMonCount(rs.getInt("monCount")); 
                        binf.setGroupIndexInFBSDevice(rs.getInt("GroupIndexInFBSDevice")); 
                        binf.setFBSDeviceId(rs.getInt("fBSDeviceId")); 
                        list.add(binf); 
                    } 
                } catch (SQLException e) { 
                    e.printStackTrace(); 
                } 
                return list; 
            } 
        }); 
        return list; 
    } 
    //6185下拉(查询用户管理的维护区对应的机房对应的battgroupid) 
    public List serch61850DevidInGroup(Object obj){ 
        User_inf uinf=(User_inf) obj; 
        String sql="select distinct db_battinf.tb_battinf.battgroupid,db_battinf.tb_battinf.stationName,db_battinf.tb_battinf.battgroupname,db_battinf.tb_battinf.moncount,db_battinf.tb_battinf.GroupIndexInFBSDevice,db_battinf.tb_battinf.FBSDeviceId  " + 
                "from db_battinf.tb_battinf " + 
                "left outer join db_user.tb_user_battgroup_baojigroup_battgroup on db_user.tb_user_battgroup_baojigroup_battgroup.BattGroupId=db_battinf.tb_battinf.BattGroupId " + 
                "left outer join db_user.tb_user_battgroup_baojigroup_usr on db_user.tb_user_battgroup_baojigroup_usr.baoji_group_id=db_user.tb_user_battgroup_baojigroup_battgroup.baoji_group_id " + 
                "left outer join db_user.tb_user_inf on tb_user_inf.uid=db_user.tb_user_battgroup_baojigroup_usr.uid " + 
                "where db_user.tb_user_inf.uid=? and db_battinf.tb_battinf.FBSDeviceId like '%6185%'"; 
        List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{uinf.getUId()}, new CallBack() { 
            public List getResults(ResultSet rs) { 
                List list=new ArrayList(); 
                try { 
                    while(rs.next()){ 
                        BattInf binf=new BattInf(); 
                        binf.setBattGroupId(rs.getInt("battGroupId")); 
                        binf.setStationName(rs.getString("stationName")); 
                        binf.setBattGroupName(rs.getString("battGroupName")); 
                        binf.setMonCount(rs.getInt("monCount")); 
                        binf.setGroupIndexInFBSDevice(rs.getInt("GroupIndexInFBSDevice")); 
                        binf.setFBSDeviceId(rs.getInt("fBSDeviceId")); 
                        list.add(binf); 
                    } 
                } catch (SQLException e) { 
                    e.printStackTrace(); 
                } 
                return list; 
            } 
        }); 
        return list; 
    } 
    public List serchByInfo(Object obj) { 
        // TODO Auto-generated method stub 
        return null; 
    } 
     
    public static void main(String[] args) { 
    User_battgroup_baojigroup_battgroupImpl ub= new User_battgroup_baojigroup_battgroupImpl(); 
    /*List<User_battgroup_baojigroup_battgroup> list =ub.searchAll(); 
    for (User_battgroup_baojigroup_battgroup u : list) { 
        System.out.println(u); 
    }*/ 
    User_battgroup_baojigroup_battgroup u=new User_battgroup_baojigroup_battgroup(); 
    u.setNum(4); 
    User_inf uinf=new User_inf(); 
    uinf.setUId(1001); 
    List<BattInf> list =ub.serchByCondition(uinf); 
     
    for (BattInf uu : list) { 
        System.out.println(uu); 
    } 
    System.out.println(list.size()); 
} 
}