package com.fgkj.dao.impl.Ld9;

import java.sql.Connection;
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.dao.LimitNumberFactory;
import com.fgkj.db.DBUtil;
import com.fgkj.dto.LD9_state;
import com.fgkj.dto.Page;
import com.fgkj.dto.ram.Fbs9100_state;

public class LD9_stateImpl implements BaseDAO,CallBack{

	public List getResults(ResultSet rs) {
		// TODO Auto-generated method stub
		return null;
	}

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

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

	public boolean del(Object obj) {
		// TODO Auto-generated method stub
		return false;
	}
    //查询所有LD9设备的实时数据
	public List searchAll() {
		String sql=" select num,dev_id,sys_state,sys_online_vol,sys_group_vol," +
				" sys_now_battnum,sys_now_battstate,sys_now_battvol,sys_now_battcurr," +
				" sys_now_battcap,sys_now_testtime,dev_commcount,dev_errcommcount " +
				" from db_ram_db.tb_ld9_state " +
				" order by sys_now_battnum";
		List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), null, new CallBack() {
			
			public List getResults(ResultSet rs) {
				List list=new ArrayList();
				try {
					while(rs.next()){
						LD9_state ld9=new LD9_state();
						ld9.setNum(rs.getInt("num"));
						ld9.setDev_id(rs.getInt("dev_id"));
						ld9.setSys_state(rs.getInt("sys_state"));
						ld9.setSys_online_vol(rs.getShort("sys_online_vol"));
						ld9.setSys_group_vol(rs.getFloat("sys_group_vol"));
						ld9.setSys_now_battnum(rs.getInt("sys_now_battnum"));
						ld9.setSys_now_battstate(rs.getInt("sys_now_battstate"));
						ld9.setSys_now_battvol(rs.getFloat("sys_now_battvol"));
						ld9.setSys_now_battcurr(rs.getFloat("sys_now_battcurr"));
						ld9.setSys_now_battcap(rs.getFloat("sys_now_battcap"));
						ld9.setSys_now_testtime(rs.getTimestamp("sys_now_testtime"));
						ld9.setDev_commcount(rs.getInt("dev_commcount"));
						ld9.setDev_errcommcount(rs.getInt("dev_errcommcount"));
						list.add(ld9);
					}
				} catch (SQLException e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				}
				return list;
			}
		});
		return list;
	}

	//Ld9设备通信状态查询
	/*
	 * Ld9：op_cmd:0:全部；1：fbs9100,2:fbs9600,3：ld9
     * dev_errcommcount;0:通讯正常，1：通讯中断，100：全部
	 * */
	public List serchByCondition(Object obj) {
		LD9_state ld9=(LD9_state) obj;
		Page page=ld9.getPage();
		Connection conn=DBUtil.getConn();
		String numberSql=" SELECT FOUND_ROWS() number";
		String sql="";
		String baseSql="select SQL_CALC_FOUND_ROWS distinct db_ram_db.tb_ld9_state.num,db_ram_db.tb_ld9_state.dev_ip,db_ram_db.tb_ld9_state.dev_id,db_ram_db.tb_ld9_state.dev_version," +
				"db_ram_db.tb_ld9_state.sys_state,db_ram_db.tb_ld9_state.sys_stop_reason,db_ram_db.tb_ld9_state.dev_commcount,db_ram_db.tb_ld9_state.dev_errcommcount,db_ram_db.tb_ld9_state.timelong, " +
				"db_battinf.tb_battinf.StationName,db_battinf.tb_battinf.FbsDeviceName," +
				"COUNT(DISTINCT db_battinf.tb_battinf.BattGroupId) as cnt," +
				"group_CONCAT(db_ram_db.tb_batt_rtstate.online_vol ORDER BY db_ram_db.tb_batt_rtstate.BattGroupId separator '/') as online_vols,group_CONCAT(db_ram_db.tb_batt_rtstate.group_vol ORDER BY db_ram_db.tb_batt_rtstate.BattGroupId separator '/') as group_vols,group_CONCAT(db_ram_db.tb_batt_rtstate.group_curr ORDER BY db_ram_db.tb_batt_rtstate.BattGroupId separator '/') as group_currs  " +
				"from db_ram_db.tb_ld9_state " +
				"left outer join db_battinf.tb_battinf ON db_ram_db.tb_ld9_state.dev_id=db_battinf.tb_battinf.FBSDeviceId  " +
				"LEFT OUTER JOIN db_ram_db.tb_batt_rtstate ON db_battinf.tb_battinf.battgroupid=db_ram_db.tb_batt_rtstate.battgroupid ";
		
		//通讯中断
		String  comSqlT=" where dev_errcommcount=0  "; 
		String  comSqlF=" where dev_errcommcount>0  "; 
		String  comSqlA=" where dev_errcommcount>-1  "; 
		if(ld9.getDev_errcommcount()==0){
			baseSql+=comSqlT;
		}else if(ld9.getDev_errcommcount()==1){
			baseSql+=comSqlF;
		}else{
			baseSql+=comSqlA;
		}
		//判断是否为管理的机房
		String stationSql=" and db_battinf.tb_battinf.StationId in(select distinct db_battinf.tb_battinf.StationId " +
				" from db_battinf.tb_battinf,db_user.tb_user_battgroup_baojigroup_battgroup,db_user.tb_user_battgroup_baojigroup_usr,db_user.tb_user_inf   " +
				" where db_user.tb_user_battgroup_baojigroup_battgroup.BattGroupId=db_battinf.tb_battinf.BattGroupId   " +
				" and db_user.tb_user_battgroup_baojigroup_usr.baoji_group_id=db_user.tb_user_battgroup_baojigroup_battgroup.baoji_group_id  " +
				" and db_user.tb_user_inf.uid=db_user.tb_user_battgroup_baojigroup_usr.uid  " +
				" and db_user.tb_user_inf.uid=?   ) ";
		baseSql+=stationSql;
		//分组
		String groupSql=" GROUP BY db_ram_db.tb_ld9_state.dev_id ";
		//分页
		String limitSql=" limit ?,? ";
		//最后结果
		sql=baseSql+groupSql+limitSql;
		
		//System.out.println(sql);
		List<Fbs9100_state> list=DAOHelper.executeQueryLimit(sql, conn, new Object[]{ld9.getNum(),(page.getPageCurr()-1)*page.getPageSize(),page.getPageSize()}, new CallBack() {
			List list=new ArrayList();
			public List getResults(ResultSet rs) {
				try {
					while(rs.next()){
						Fbs9100_state fstate=new Fbs9100_state();
						fstate.setNum(rs.getInt("cnt"));//关联电池组个数
						fstate.setDev_ip(rs.getString("dev_ip"));
						fstate.setDev_id(rs.getInt("dev_id"));
						
						fstate.setDev_version(rs.getString("dev_version"));
						fstate.setDev_testtype(rs.getInt("sys_state"));
						fstate.setDev_alarmstate(rs.getInt("sys_stop_reason"));
						fstate.setDev_commcount(rs.getInt("dev_commcount"));
						fstate.setDev_errcommcount(rs.getInt("dev_errcommcount"));
						
						fstate.setStationName(rs.getString("stationName"));
						fstate.setDeviceName(rs.getString("FbsDeviceName"));
						fstate.setOnline_vols(rs.getString("online_vols"));
						fstate.setGroup_vols(rs.getString("group_vols"));
						fstate.setGroup_currs(rs.getString("group_currs"));
						fstate.setDev_captest_timelong(rs.getInt("timelong"));
						//System.out.println(fstate);
						list.add(fstate);
					}
				} catch (SQLException e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				}
				return list;
			}
		});
		//去掉limit条件后的总数
		int number=LimitNumberFactory.GetLimtitNumber(conn, numberSql);
		if(list!=null&&list.size()>0){
			page.setPageAll(number);
			list.get(list.size()-1).setPage(page);
		}
		return list;
	}

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

}