package com.fgkj.dao.impl.bts61850;

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

import sun.security.jca.GetInstance;

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.BTS_61850_state;
import com.fgkj.dto.LD9_state;
import com.fgkj.dto.Page;
import com.fgkj.dto.ram.Fbs9100_state;

public class BTS_61850_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;
	}

	//查询所有bts61850设备的实时数据
	public List searchAll() {
		String sql=" select num,FBSDeviceId,stc_datatime,stc_groupvol_low,stc_cap_high," +
				" stc_timespan_high,stc_discurr,stc_monvol_low,stc_montmp_high," +
				" stc_workstate,alam_tmp,alam_comm,alam_relay,dev_captest_online,dev_captest_groupvol," +
				" dev_errcommcount,dev_commcount " +
				" from db_ram_db.tb_bts_61850_state " +
				" order by FBSDeviceId";
		List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), null, new CallBack() {
			
			public List getResults(ResultSet rs) {
				List list=new ArrayList();
				try {
					while(rs.next()){
						BTS_61850_state bts=new BTS_61850_state();
						bts.setNum(rs.getInt("num"));
						bts.setFBSDeviceId(rs.getInt("fBSDeviceId"));
						bts.setStc_datatime(rs.getTimestamp("stc_datatime"));
						bts.setStc_groupvol_low(rs.getFloat("stc_groupvol_low"));
						bts.setStc_cap_high(rs.getInt("stc_cap_high"));
						bts.setStc_timespan_high(rs.getInt("stc_timespan_high"));
						bts.setStc_discurr(rs.getInt("stc_discurr"));
						bts.setStc_monvol_low(rs.getFloat("stc_monvol_low"));
						bts.setStc_montmp_high(rs.getFloat("stc_montmp_high"));
						bts.setStc_workstate(rs.getInt("stc_workstate"));
						bts.setAlam_tmp(rs.getInt("alam_tmp"));
						bts.setAlam_comm(rs.getInt("alam_comm"));
						bts.setAlam_relay(rs.getInt("alam_relay"));
						bts.setDev_captest_online(rs.getFloat("dev_captest_online"));
						bts.setDev_captest_groupvol(rs.getFloat("dev_captest_groupvol"));
						bts.setDev_errcommcount(rs.getInt("dev_errcommcount"));
						bts.setDev_commcount(rs.getInt("dev_commcount"));
						list.add(bts);
					}
				} catch (SQLException e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				}
				return list;
			}
		});
		return list;
	}

	//61850设备通信状态查询
	/*
	 * 61850：op_cmd:0:全部；1：fbs9100,2:fbs9600,3：ld9,4:61850
     * dev_errcommcount;0:通讯正常，1：通讯中断，100：全部
	 * */
	public List serchByCondition(Object obj) {
		BTS_61850_state bts=(BTS_61850_state) obj;
		Page page=bts.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_bts_61850_state.num,db_ram_db.tb_bts_61850_state.dev_ip,db_ram_db.tb_bts_61850_state.fBSDeviceId," +
				"db_ram_db.tb_bts_61850_state.alam_tmp,db_ram_db.tb_bts_61850_state.alam_relay,db_ram_db.tb_bts_61850_state.alam_comm," +
				"db_ram_db.tb_bts_61850_state.stc_workstate,db_ram_db.tb_bts_61850_state.dev_commcount,db_ram_db.tb_bts_61850_state.dev_errcommcount,db_ram_db.tb_bts_61850_state.dev_ip,db_ram_db.tb_bts_61850_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_bts_61850_state " +
				"left outer join db_battinf.tb_battinf ON db_ram_db.tb_bts_61850_state.fBSDeviceId=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(bts.getDev_errcommcount()==0){
			baseSql+=comSqlT;
		}else if(bts.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_bts_61850_state.fBSDeviceId ";
		//分页
		String limitSql=" limit ?,? ";
		//最后结果
		sql=baseSql+groupSql+limitSql;
		
		//System.out.println(sql);
		List<Fbs9100_state> list=DAOHelper.executeQueryLimit(sql, conn, new Object[]{bts.getNum(),(page.getPageCurr()-1)*page.getPageSize(),page.getPageSize()}, new CallBack() {
			List list=new ArrayList();
			String alarmstr="";//bts61850告警类型
			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("fBSDeviceId"));
						
						fstate.setDev_testtype(rs.getInt("stc_workstate"));
						fstate.setDev_commcount(rs.getInt("dev_commcount"));
						fstate.setDev_errcommcount(rs.getInt("dev_errcommcount"));
						if(rs.getInt("alam_tmp")==1){
							if(alarmstr.length()>0){
								alarmstr+="/";
							}
							alarmstr+="设备过温告警";
						};
						if(rs.getInt("alam_relay")==1){
							if(alarmstr.length()>0){
								alarmstr+="/";
							}
							alarmstr+="继电器K1告警";
						};
						if(rs.getInt("alam_comm")==1){
							if(alarmstr.length()>0){
								alarmstr+="/";
							}
							alarmstr+="通讯告警";
						};
						fstate.setNote(alarmstr);
						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"));
						alarmstr="";
						//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;
	}

}