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 sun.security.action.GetIntegerAction;
|
import sun.security.jca.GetInstance;
|
|
import com.fgkj.actions.ActionUtil;
|
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.dto.BattInf;
|
import com.fgkj.dto.Batt_discharge;
|
import com.fgkj.dto.User_inf;
|
import com.fgkj.dto.User_log;
|
import com.fgkj.services.User_logService;
|
|
public class Batt_dischargeImpl implements BaseDAO,CallBack{
|
|
public List getResults(ResultSet rs) {
|
// TODO Auto-generated method stub
|
return null;
|
}
|
//批量添加
|
public boolean add(Object obj) {
|
List<Batt_discharge> list=(List<Batt_discharge>) obj;
|
ArrayList sql_str=new ArrayList();
|
List<User_log> listU=new ArrayList<User_log>();//存放user_log
|
if(list!=null&&list.size()>0){
|
for (int i = 0; i < list.size(); i++) {
|
Batt_discharge bchar=list.get(i); //((User_inf)ActionUtil.getUser()).getUId()
|
String sql = " insert into web_site.tb_batt_discharge(uid,dev_id,record_time) values("+((User_inf)ActionUtil.getUser()).getUId()+","+bchar.getDev_id()+",'"+DAOHelper.sdf.format(new Date())+"')";
|
sql_str.add(sql);
|
{
|
String msg="添加"+bchar.getDev_id()+"机房至放电黑名单!";
|
User_log ulog=UinfDaoFactory.CreateULog(UinfDaoFactory.Increase, msg);
|
listU.add(ulog);
|
}
|
}
|
}
|
(new User_logService()).addPro(listU);//将用户的操作记录下来
|
System.out.println(sql_str);
|
Boolean bl=DAOHelper.makeManualCommit(DBUtil.getConn(), sql_str);
|
return bl;
|
}
|
public boolean update(Object obj) {
|
|
return false;
|
}
|
//移除黑名单
|
public boolean del(Object obj) {
|
List<Batt_discharge> list=(List<Batt_discharge>) obj;
|
ArrayList sql_str=new ArrayList();
|
List<User_log> listU=new ArrayList<User_log>();//存放user_log
|
if(list!=null&&list.size()>0){
|
for (int i = 0; i < list.size(); i++) {
|
Batt_discharge bchar=list.get(i);
|
String sql = " delete from web_site.tb_batt_discharge where dev_id="+bchar.getDev_id();
|
sql_str.add(sql);
|
{
|
String msg="从黑名单移除"+bchar.getDev_id()+"机房!";
|
User_log ulog=UinfDaoFactory.CreateULog(UinfDaoFactory.Delete, msg);
|
listU.add(ulog);
|
}
|
}
|
}
|
(new User_logService()).addPro(listU);//将用户的操作记录下来
|
Boolean bl=DAOHelper.makeManualCommit(DBUtil.getConn(), sql_str);
|
return bl;
|
}
|
//根据省市区县机房信息查询出所有不能放电的站
|
public List searchAll() {
|
String sql=" select distinct dev_id,uid "
|
+ " ,stationName,stationName1,stationName2,FBSDeviceId "
|
+ " from web_site.tb_batt_discharge,db_battinf.tb_battinf "
|
+ " where web_site.tb_batt_discharge.dev_id=db_battinf.tb_battinf.FBSDeviceId "
|
+ " order by dev_id ";
|
List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), null, new CallBack() {
|
|
public List getResults(ResultSet rs) {
|
List list=new ArrayList();
|
try {
|
while(rs.next()){
|
Batt_discharge bd=new Batt_discharge();
|
bd.setDev_id(rs.getInt("dev_id"));
|
bd.setUid(rs.getInt("uid"));
|
bd.setStationName(rs.getString("stationName"));
|
bd.setStationName1(rs.getString("stationName1"));
|
bd.setStationName2(rs.getString("stationName2"));
|
list.add(bd);
|
}
|
} catch (SQLException e) {
|
// TODO Auto-generated catch block
|
e.printStackTrace();
|
}
|
return list;
|
}
|
});
|
return list;
|
}
|
//根据省市区县机房信息查询出所有能放电的机房
|
public List searchAllNotIn() {
|
String sql=" select distinct "
|
+ " stationName,stationName1,stationName2,FBSDeviceId "
|
+ " from web_site.tb_batt_discharge,db_battinf.tb_battinf "
|
+ " where web_site.tb_batt_discharge.dev_id!=db_battinf.tb_battinf.FBSDeviceId "
|
+ " order by dev_id ";
|
List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), null, new CallBack() {
|
|
public List getResults(ResultSet rs) {
|
List list=new ArrayList();
|
try {
|
while(rs.next()){
|
Batt_discharge bd=new Batt_discharge();
|
bd.setDev_id(rs.getInt("FBSDeviceId"));
|
bd.setStationName(rs.getString("stationName"));
|
bd.setStationName1(rs.getString("stationName1"));
|
bd.setStationName2(rs.getString("stationName2"));
|
list.add(bd);
|
}
|
} catch (SQLException e) {
|
// TODO Auto-generated catch block
|
e.printStackTrace();
|
}
|
return list;
|
}
|
});
|
return list;
|
}
|
//根据设备id查询改设备是否被加入至黑名单
|
public List serchByCondition(Object obj) {
|
Batt_discharge bd=(Batt_discharge) obj;
|
String sql="select distinct num,uid,dev_id "
|
+ " from web_site.tb_batt_discharge where dev_id=? limit 1";
|
List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{bd.getDev_id()}, new CallBack() {
|
|
public List getResults(ResultSet rs) {
|
List list=new ArrayList();
|
try {
|
while(rs.next()){
|
Batt_discharge b=new Batt_discharge();
|
b.setNum(rs.getInt("num"));
|
b.setDev_id(rs.getInt("dev_id"));
|
b.setUid(rs.getInt("uid"));
|
list.add(b);
|
}
|
} catch (SQLException e) {
|
// TODO Auto-generated catch block
|
e.printStackTrace();
|
}
|
return list;
|
}
|
});
|
return list;
|
}
|
|
public List serchByInfo(Object obj) {
|
return null;
|
}
|
public static void main(String[] args) {
|
Batt_discharge bd=new Batt_discharge();
|
bd.setDev_id(910000012);
|
List list=new ArrayList();
|
list.add(bd);
|
Batt_dischargeImpl bimpl=new Batt_dischargeImpl();
|
boolean bl=bimpl.add(list);
|
//boolean bl=bimpl.del(list);
|
System.out.println(bl);
|
//List l=bimpl.serchByCondition(bd);
|
//List l=bimpl.searchAll();
|
/*List l=bimpl.searchAllNotIn();
|
System.out.println(l.size());*/
|
}
|
}
|
