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.CallBack;
import com.fgkj.dao.DAOHelper;

import com.fgkj.dao.BaseDAO;
import com.fgkj.db.DBUtil;
import com.fgkj.dto.BattInf;
import com.fgkj.dto.Cmcc_Power_Data;
import com.sun.org.apache.bcel.internal.generic.GETFIELD;

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

	public List searchAll() {
		// TODO Auto-generated method stub
		return null;
	}
	//根据电池组id查询cmcc实时表中的实时电流画柱状图
	public List serchByCondition(Object obj) {
		BattInf binf=(BattInf) obj;
		String  sql="SELECT (binary curr1) as curr1,(binary curr2) as curr2,(binary curr3) as curr3,(binary curr4) as curr4,(binary curr5) as curr5  " +
				 "  FROM db_ram_db.cmcc_power_data  " +
				 "  WHERE dev_id IN(SELECT DISTINCT(fbsdeviceid) FROM db_battinf.tb_battinf where stationid=? ) " +
				 "  LIMIT 1";
		List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{binf.getStationId()}, new CallBack() {
			
			public List getResults(ResultSet rs) {
				List list=new ArrayList();
				try {
					while(rs.next()){
						Cmcc_Power_Data cmcc=new Cmcc_Power_Data();
						cmcc.setCurr1(rs.getFloat("curr1"));
						cmcc.setCurr2(rs.getFloat("curr2"));
						cmcc.setCurr3(rs.getFloat("curr3"));
						cmcc.setCurr4(rs.getFloat("curr4"));
						cmcc.setCurr5(rs.getFloat("curr5"));
						list.add(cmcc);
					}
				} 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;
	}
    public static void main(String[] args) {
		Cmcc_Power_DataImpl cimpl=new Cmcc_Power_DataImpl();
		BattInf binf=new BattInf();
		binf.setStationId("42070450");
		List list=cimpl.serchByCondition(binf);
		System.out.println(list.size());
	}
}