package com.fgkj.dao.impl.ram;
|
|
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.ram.Fbs9100s_nibian_state;
|
|
public class Fbs9100s_nibian_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;
|
}
|
|
public List searchAll() {
|
// TODO Auto-generated method stub
|
return null;
|
}
|
//根据设备
|
public List serchByCondition(Object obj) {
|
Fbs9100s_nibian_state fstate=(Fbs9100s_nibian_state) obj;
|
String sql=" select distinct dev_id,nb_num,record_time,AC_ASimVol,AC_ASimCur,AC_BSimVol,AC_BSimCur,AC_CSimVol,AC_CSimCur,A_HZ,B_HZ,C_HZ "
|
+ " ,Power_Pa,Power_Pb,Power_Pc,Power_Sa,Power_Sb,Power_Sc,Temp1,Temp2,RunState,DcACState,InsulaTionRes1,InsulaTionRes2,DCInputVol "
|
+ " ,DCInputCur,SetRun_Stop,SetDischargeCur,CommTxCnt,CommRxCnt "
|
+ " from db_ram_db.tb_fbs9100s_nibian_state "
|
+ " where dev_id=? "
|
+ " order by nb_num asc ";
|
List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{fstate.getDev_id()}, new CallBack() {
|
|
public List getResults(ResultSet rs) {
|
List list=new ArrayList();
|
try {
|
while(rs.next()){
|
Fbs9100s_nibian_state f=new Fbs9100s_nibian_state();
|
f.setDev_id(rs.getInt("dev_id"));
|
f.setNb_num(rs.getInt("nb_num"));
|
f.setRecord_time(rs.getTimestamp("record_time"));
|
f.setAC_ASimVol(rs.getFloat("aC_ASimVol"));
|
f.setAC_ASimCur(rs.getFloat("aC_ASimCur"));
|
f.setAC_BSimVol(rs.getFloat("aC_BSimVol"));
|
f.setAC_BSimCur(rs.getFloat("aC_BSimCur"));
|
f.setAC_CSimVol(rs.getFloat("aC_CSimVol"));
|
f.setAC_CSimCur(rs.getFloat("aC_CSimCur"));
|
f.setA_HZ(rs.getFloat("a_HZ"));
|
f.setB_HZ(rs.getFloat("b_HZ"));
|
f.setC_HZ(rs.getFloat("c_HZ"));
|
f.setPower_Pa(rs.getFloat("power_Pa"));
|
f.setPower_Pb(rs.getFloat("power_Pb"));
|
f.setPower_Pc(rs.getFloat("power_Pc"));
|
f.setPower_Sa(rs.getFloat("power_Sa"));
|
f.setPower_Sb(rs.getFloat("power_Sb"));
|
f.setPower_Sc(rs.getFloat("power_Sc"));
|
f.setTemp1(rs.getFloat("temp1"));
|
f.setTemp2(rs.getFloat("temp2"));
|
f.setRunState(rs.getFloat("runState"));
|
f.setDcACState(rs.getInt("dcACState"));
|
f.setInsulaTionRes1(rs.getInt("insulaTionRes1"));
|
f.setInsulaTionRes2(rs.getInt("insulaTionRes2"));
|
f.setDCInputVol(rs.getFloat("dCInputVol"));
|
f.setDCInputCur(rs.getFloat("dCInputCur"));
|
f.setSetRun_Stop(rs.getInt("setRun_Stop"));
|
f.setSetDischargeCur(rs.getFloat("setDischargeCur"));
|
f.setCommTxCnt(rs.getInt("commTxCnt"));
|
f.setCommRxCnt(rs.getInt("commRxCnt"));
|
list.add(f);
|
}
|
} 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) {
|
Fbs9100s_nibian_stateImpl fimpl=new Fbs9100s_nibian_stateImpl();
|
Fbs9100s_nibian_state fstate=new Fbs9100s_nibian_state();
|
fstate.setDev_id(910000001);
|
List list=fimpl.serchByCondition(fstate);
|
System.out.println(list.size());
|
}
|
}
|