package com.fgkj.dao.impl;
|
|
import java.sql.Connection;
|
import java.sql.ResultSet;
|
import java.sql.SQLException;
|
import java.text.ParseException;
|
import java.text.SimpleDateFormat;
|
import java.util.ArrayList;
|
import java.util.Date;
|
import java.util.List;
|
|
import sun.security.jca.GetInstance;
|
|
import com.fgkj.actions.ActionUtil;
|
import com.fgkj.dao.BaseDAO;
|
import com.fgkj.dao.BattTestData;
|
import com.fgkj.dao.CallBack;
|
import com.fgkj.dao.DAOHelper;
|
import com.fgkj.dao.LimitNumberFactory;
|
import com.fgkj.dao.UinfDaoFactory;
|
import com.fgkj.db.DBUtil;
|
import com.fgkj.db.IDatabaseName;
|
import com.fgkj.dto.BattDischarge_plan;
|
import com.fgkj.dto.BattInf;
|
import com.fgkj.dto.BattMap_information;
|
import com.fgkj.dto.Batt_Maint_Dealarm;
|
import com.fgkj.dto.Page;
|
import com.fgkj.dto.User_inf;
|
import com.fgkj.dto.User_log;
|
import com.fgkj.services.User_logService;
|
|
public class BattDischarge_planImpl implements BaseDAO,CallBack{
|
|
public List getResults(ResultSet rs) {
|
List list=new ArrayList();
|
try {
|
while(rs.next()){
|
BattDischarge_plan bplan=new BattDischarge_plan();
|
bplan.setNum(rs.getInt("num"));
|
bplan.setBattgroupid(rs.getInt("battgroupid"));
|
bplan.setBattIndexInFbs(rs.getInt("battIndexInFbs"));
|
bplan.setDischarge_starttime(rs.getDate("discharge_starttime"));
|
bplan.setDischarge_stoptime(rs.getDate("discharge_stoptime"));
|
bplan.setDischarge_state(rs.getInt("discharge_state"));
|
bplan.setDischarge_reason(rs.getInt("discharge_reason"));
|
bplan.setDischarge_cleartype(rs.getInt("discharge_cleartype"));//启用还是结束计划
|
bplan.setPreset_time(rs.getInt("preset_time"));
|
bplan.setPreset_cap(rs.getFloat("preset_cap"));
|
bplan.setPreset_monvol(rs.getFloat("preset_monvol"));
|
bplan.setPreset_groupvol(rs.getFloat("preset_groupvol"));
|
bplan.setPreset_curr(rs.getFloat("preset_curr"));
|
bplan.setPreset_mon(rs.getInt("preset_mon"));
|
bplan.setDcvolhighlimit(rs.getFloat("dcvolhighlimit"));
|
bplan.setChargecurrset(rs.getFloat("chargecurrset"));
|
bplan.setNote(rs.getString("note"));
|
list.add(bplan);
|
}
|
} catch (SQLException e) {
|
e.printStackTrace();
|
}
|
return list;
|
}
|
//添加
|
public boolean add(Object obj) {
|
BattDischarge_plan bplan=(BattDischarge_plan) obj;
|
String sql="insert into web_site.tb_battdischarge_plan(battgroupid,battIndexInFbs,discharge_starttime,discharge_stoptime,discharge_state,discharge_reason,discharge_cleartype,preset_time,preset_cap,preset_monvol,preset_groupvol,preset_curr,preset_mon,dcvolhighlimit,chargecurrset,note) values(?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)";
|
Boolean bl=DAOHelper.executeUpdate(DBUtil.getConn(), sql, new Object[]{bplan.getBattgroupid(),bplan.getBattIndexInFbs(),bplan.getDischarge_starttime(),
|
bplan.getDischarge_stoptime(),bplan.getDischarge_state(),bplan.getDischarge_reason(),bplan.getDischarge_cleartype(),
|
bplan.getPreset_time(),bplan.getPreset_cap(),bplan.getPreset_monvol(),bplan.getPreset_groupvol(),bplan.getPreset_curr(),bplan.getPreset_mon(),
|
bplan.getDcvolhighlimit(),bplan.getChargecurrset(),bplan.getNote()});
|
return bl;
|
}
|
//8.1批量添加电池计划
|
public boolean addPro(Object obj) {
|
List<BattDischarge_plan> list=(List<BattDischarge_plan>) obj;
|
ArrayList<String> sql_str=new ArrayList<String>();
|
List<User_log> listU=new ArrayList<User_log>();//存放user_log
|
if(list!=null&&list.size()>0){
|
for(int i=0;i<list.size();i++){
|
BattDischarge_plan bplan=list.get(i);
|
String sql="insert into web_site.tb_battdischarge_plan(battgroupid,battIndexInFbs,discharge_starttime,discharge_state,discharge_reason,discharge_cleartype,preset_time,preset_cap,preset_monvol,preset_groupvol,preset_curr,preset_mon,dcvolhighlimit,chargecurrset) " +
|
" values("
|
+bplan.getBattgroupid()+","
|
+bplan.getBattIndexInFbs()+","//第几组电池组
|
+"'"+DAOHelper.sdf.format(bplan.getDischarge_starttime())+"',"
|
+bplan.getDischarge_state()+","
|
+"'"+bplan.getDischarge_reason()+"',"
|
+bplan.getDischarge_cleartype()+","
|
+bplan.getPreset_time()+","
|
+bplan.getPreset_cap()+","
|
+bplan.getPreset_monvol()+","
|
+bplan.getPreset_groupvol()+","
|
+bplan.getPreset_curr()+","
|
+bplan.getPreset_mon()+","
|
+bplan.getDcvolhighlimit()+","
|
+bplan.getChargecurrset()
|
+")";
|
sql_str.add(sql);
|
{
|
String msg="添加"+bplan.getNote()+"电池组在"+DAOHelper.sdf.format(bplan.getDischarge_starttime())+"的放电计划";
|
User_log ulog=UinfDaoFactory.CreateULog(UinfDaoFactory.Increase, msg);
|
listU.add(ulog);
|
}
|
}
|
}
|
Boolean bl=DAOHelper.makeManualCommit(DBUtil.getConn(), sql_str);
|
(new User_logService()).addPro(listU);//将用户的操作记录下来
|
return bl;
|
}
|
|
public boolean update(Object obj) {
|
BattDischarge_plan bplan=(BattDischarge_plan) obj;
|
String sql="update web_site.tb_battdischarge_plan set battgroupid=?,battIndexInFbs=?,discharge_starttime=?,discharge_stoptime=?,discharge_state=?,discharge_reason=?,discharge_cleartype=?,preset_time=?,preset_cap=?,preset_monvol=?,preset_groupvol=?,preset_curr=?,preset_mon=?,dcvolhighlimit=?,chargecurrset=?,note=? where num=?";
|
Boolean bl=DAOHelper.executeUpdate(DBUtil.getConn(), sql, new Object[]{bplan.getBattgroupid(),bplan.getBattIndexInFbs(),bplan.getDischarge_starttime(),
|
bplan.getDischarge_stoptime(),bplan.getDischarge_state(),bplan.getDischarge_reason(),bplan.getDischarge_cleartype(),bplan.getPreset_time(),bplan.getPreset_cap(),bplan.getPreset_monvol(),bplan.getPreset_groupvol(),bplan.getPreset_curr(),bplan.getPreset_mon(),bplan.getDcvolhighlimit(),bplan.getChargecurrset(),bplan.getNote(),bplan.getNum()});
|
return bl;
|
}
|
|
//8.1批量修改放电计划的开始时间/放电参数的修改/启用计划和取消计划
|
public boolean updatePro(Object obj) {
|
List<BattDischarge_plan> list=(List<BattDischarge_plan>) obj;
|
ArrayList<String> sql_str=new ArrayList<String>();
|
List<User_log> listU=new ArrayList<User_log>();//存放user_log
|
if(list != null && list.size()>0){
|
for(int i=0;i<list.size();i++){
|
BattDischarge_plan bplan=list.get(i);
|
String sql="update web_site.tb_battdischarge_plan set discharge_starttime='"+DAOHelper.sdf.format(bplan.getDischarge_starttime())+"',discharge_cleartype="+bplan.getDischarge_cleartype()+",discharge_reason="+bplan.getDischarge_reason()+",discharge_state="+bplan.getDischarge_state()+",preset_time="+bplan.getPreset_time()+",preset_cap="+bplan.getPreset_cap()+",preset_monvol="+bplan.getPreset_monvol()+",preset_groupvol="+bplan.getPreset_groupvol()+",preset_curr="+bplan.getPreset_curr()+",preset_mon="+bplan.getPreset_mon()+",dcvolhighlimit="+bplan.getDcvolhighlimit()+",chargecurrset="+bplan.getChargecurrset()+" where num="+bplan.getNum();
|
sql_str.add(sql);
|
{
|
String msg="修改"+bplan.getNote()+"的放电计划信息";
|
User_log ulog=UinfDaoFactory.CreateULog(UinfDaoFactory.Alter, msg);
|
listU.add(ulog);
|
}
|
}
|
}
|
Boolean bl=DAOHelper.makeManualCommit(DBUtil.getConn(), sql_str);
|
(new User_logService()).addPro(listU);//将用户的操作记录下来
|
return bl;
|
}
|
|
public boolean del(Object obj) {
|
BattDischarge_plan bplan=(BattDischarge_plan) obj;
|
String sql="delete from web_site.tb_battdischarge_plan where num=? ";
|
Boolean bl=DAOHelper.executeUpdate(DBUtil.getConn(), sql, new Object[]{bplan.getNum()});
|
return bl;
|
}
|
//8.1批量添加作业计划时先检测计划的可行性
|
public int judgePlan(Object obj) {
|
BattDischarge_plan bplan=(BattDischarge_plan) obj;
|
String sql=" SELECT battgroupid FROM web_site.tb_battdischarge_plan " +
|
" WHERE discharge_starttime>=? and discharge_starttime<=? " +
|
" AND discharge_cleartype=1 and discharge_state in(0,1) " +
|
" AND battgroupid in (select battgroupid FROM db_battinf.tb_battinf where stationname=? ) ";
|
//System.out.println(sql);
|
List list=DAOHelper.executeQuery(sql, DBUtil.getConn(),new Object[]{bplan.getDischarge_starttime1(),bplan.getDischarge_stoptime1(),bplan.getNote()}, new CallBack() {
|
|
public List getResults(ResultSet rs) {
|
List list=new ArrayList();
|
try {
|
while(rs.next()){
|
int battgroupid=rs.getInt("battgroupid");
|
list.add(battgroupid);
|
}
|
} catch (SQLException e) {
|
// TODO Auto-generated catch block
|
e.printStackTrace();
|
}
|
return list;
|
}
|
});
|
//System.out.println(list.size());
|
if(list.size()>0){
|
return 0;
|
}else{
|
return 1;
|
}
|
}
|
|
public List searchAll() {
|
String sql="select num,battgroupid,discharge_starttime,discharge_stoptime,discharge_state,discharge_reason,discharge_cleartype,preset_time,preset_cap,preset_monvol,preset_groupvol,preset_curr,preset_mon,dcvolhighlimit,chargecurrset,note from web_site.tb_battdischarge_plan ";
|
List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), null, new BattDischarge_planImpl());
|
return list;
|
}
|
//8.1放电计划查询
|
/*public List serchByCondition(Object obj) {
|
Batt_Maint_Dealarm bmd=(Batt_Maint_Dealarm) obj;
|
BattInf binf=bmd.getBinf();
|
BattDischarge_plan bplan=bmd.getBplan();
|
String numberSql=" SELECT FOUND_ROWS() number";
|
Connection conn=DBUtil.getConn();
|
String sql="";
|
String baseSql="select SQL_CALC_FOUND_ROWS distinct(tb_battdischarge_plan.battgroupid),tb_battdischarge_plan.num,tb_battdischarge_plan.battIndexInFbs,tb_battdischarge_plan.discharge_starttime,tb_battdischarge_plan.discharge_stoptime, " +
|
"tb_battdischarge_plan.discharge_state,tb_battdischarge_plan.discharge_reason,tb_battdischarge_plan.discharge_cleartype,tb_battdischarge_plan.note," +
|
"tb_battdischarge_plan.preset_time,tb_battdischarge_plan.preset_cap,tb_battdischarge_plan.preset_monvol,tb_battdischarge_plan.preset_groupvol,tb_battdischarge_plan.preset_curr,tb_battdischarge_plan.preset_mon," +
|
"tb_battdischarge_plan.dcvolhighlimit,tb_battdischarge_plan.chargecurrset, " +
|
"db_battinf.tb_battinf.stationname1,db_battinf.tb_battinf.stationname,db_battinf.tb_battinf.battGroupName "+
|
"from web_site.tb_battdischarge_plan " +
|
"left outer join db_battinf.tb_battinf on tb_battdischarge_plan.battgroupid=db_battinf.tb_battinf.battgroupid "+
|
"where db_battinf.tb_battinf.stationname1 like ? and db_battinf.tb_battinf.stationname like ? " +
|
"and tb_battdischarge_plan.discharge_starttime>=? and tb_battdischarge_plan.discharge_starttime<=? " +
|
"and tb_battdischarge_plan.discharge_state=? ";
|
//电池组选择条件
|
String idSqlF=" and db_battinf.tb_battinf.battgroupid=? ";
|
String idSqlT=" and db_battinf.tb_battinf.battgroupid!=? ";
|
if(binf.getBattGroupId()!=0){
|
baseSql+=idSqlF;
|
}else{
|
baseSql+=idSqlT;
|
}
|
String endSql="order by tb_battdischarge_plan.discharge_starttime desc ";
|
String limitSql=" limit ?,? ";
|
sql=baseSql+endSql+limitSql;
|
//System.out.println(sql);
|
List<Batt_Maint_Dealarm> list=DAOHelper.executeQueryLimit(sql, conn,
|
new Object[]{ "%"+binf.getStationName1()+"%",
|
"%"+binf.getStationName()+"%",
|
bplan.getDischarge_starttime(),
|
bplan.getDischarge_starttime1(),
|
bplan.getDischarge_state(),
|
binf.getBattGroupId(),
|
(bmd.getPage().getPageCurr() - 1)* bmd.getPage().getPageSize(),
|
bmd.getPage().getPageSize()
|
}, new CallBack() {
|
public List getResults(ResultSet rs) {
|
List<Batt_Maint_Dealarm> list=new ArrayList();
|
try {
|
while(rs.next()){
|
Batt_Maint_Dealarm bmd=new Batt_Maint_Dealarm();
|
BattInf binf=new BattInf();
|
BattDischarge_plan bplan=new BattDischarge_plan();
|
binf.setStationName(rs.getString("stationName"));
|
binf.setStationName1(rs.getString("stationName1"));
|
binf.setBattGroupName(rs.getString("battGroupName"));
|
|
bplan.setNum(rs.getInt("num"));
|
bplan.setBattgroupid(rs.getInt("battgroupid"));
|
bplan.setBattIndexInFbs(rs.getInt("battIndexInFbs"));//第几组电池组
|
bplan.setDischarge_starttime(rs.getTimestamp("discharge_starttime"));
|
bplan.setDischarge_stoptime(rs.getTimestamp("discharge_stoptime"));
|
bplan.setDischarge_state(rs.getInt("discharge_state"));
|
bplan.setDischarge_reason(rs.getInt("discharge_reason"));
|
bplan.setDischarge_cleartype(rs.getInt("discharge_cleartype"));//计划的启用还是取消
|
bplan.setNote(rs.getString("battGroupName"));//电池组名称
|
bplan.setPreset_time(rs.getInt("preset_time"));
|
bplan.setPreset_cap(rs.getFloat("preset_cap"));
|
bplan.setPreset_monvol(rs.getFloat("preset_monvol"));
|
bplan.setPreset_groupvol(rs.getFloat("preset_groupvol"));
|
bplan.setPreset_curr(rs.getFloat("preset_curr"));
|
bplan.setPreset_mon(rs.getInt("preset_mon"));
|
bplan.setDcvolhighlimit(rs.getFloat("dcvolhighlimit"));
|
bplan.setChargecurrset(rs.getFloat("chargecurrset"));
|
|
|
Page page=new Page();
|
bmd.setBinf(binf);
|
bmd.setBplan(bplan);
|
bmd.setPage(page);
|
list.add(bmd);
|
}
|
} catch (SQLException e) {
|
// TODO Auto-generated catch block
|
e.printStackTrace();
|
}
|
return list;
|
}
|
});
|
//去掉limit条件后的总数
|
int number=LimitNumberFactory.GetLimtitNumber(conn, numberSql);
|
//System.out.println("number: "+number);
|
if(list!=null&&list.size()>0){
|
list.get(list.size()-1).getPage().setPageAll(number);
|
}
|
return list;
|
}*/
|
public List serchByCondition(Object obj) {
|
Batt_Maint_Dealarm bmd=(Batt_Maint_Dealarm) obj;
|
User_inf uinf=bmd.getUinf();
|
BattInf binf=bmd.getBinf();
|
BattDischarge_plan bplan=bmd.getBplan();
|
String numberSql=" SELECT FOUND_ROWS() number";
|
Connection conn=DBUtil.getConn();
|
String sql="";
|
String baseSql="select SQL_CALC_FOUND_ROWS distinct(tb_battdischarge_plan.battgroupid),tb_battdischarge_plan.num,tb_battdischarge_plan.battIndexInFbs,tb_battdischarge_plan.discharge_starttime,tb_battdischarge_plan.discharge_stoptime, " +
|
"tb_battdischarge_plan.discharge_state,tb_battdischarge_plan.discharge_reason,tb_battdischarge_plan.discharge_cleartype,tb_battdischarge_plan.note," +
|
"tb_battdischarge_plan.preset_time,tb_battdischarge_plan.preset_cap,tb_battdischarge_plan.preset_monvol,tb_battdischarge_plan.preset_groupvol,tb_battdischarge_plan.preset_curr,tb_battdischarge_plan.preset_mon," +
|
"tb_battdischarge_plan.dcvolhighlimit,tb_battdischarge_plan.chargecurrset, " +
|
"db_battinf.tb_battinf.stationname1,db_battinf.tb_battinf.stationname,db_battinf.tb_battinf.stationname5,db_battinf.tb_battinf.battGroupName "+
|
"from web_site.tb_battdischarge_plan " +
|
"left outer join db_battinf.tb_battinf on tb_battdischarge_plan.battgroupid=db_battinf.tb_battinf.battgroupid "+
|
"where tb_battdischarge_plan.discharge_starttime>=? and tb_battdischarge_plan.discharge_starttime<=? " +
|
"and tb_battdischarge_plan.discharge_state=? ";
|
//电池组选择条件
|
String idSqlF=" and db_battinf.tb_battinf.battgroupid=? ";
|
String idSqlT=" and db_battinf.tb_battinf.battgroupid!=? ";
|
if(binf.getBattGroupId()!=0){
|
baseSql+=idSqlF;
|
}else{
|
baseSql+=idSqlT;
|
}
|
//用于用户管理的电池组的筛选
|
String userSql=" and tb_battdischarge_plan.battgroupid in(select distinct db_battinf.tb_battinf.battgroupid " +
|
" 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=? " +
|
" and db_battinf.tb_battinf.stationname1 like ? and db_battinf.tb_battinf.stationname like ? and db_battinf.tb_battinf.stationname2 like ? and db_battinf.tb_battinf.stationname5 like ? )";
|
baseSql+=userSql;
|
|
String endSql="order by tb_battdischarge_plan.discharge_starttime desc ";
|
String limitSql=" limit ?,? ";
|
sql=baseSql+endSql+limitSql;
|
//System.out.println(sql);
|
List<Batt_Maint_Dealarm> list=DAOHelper.executeQueryLimit(sql, conn,
|
new Object[]{
|
bplan.getDischarge_starttime(),
|
bplan.getDischarge_starttime1(),
|
bplan.getDischarge_state(),
|
binf.getBattGroupId(),
|
uinf.getUId(),
|
"%"+binf.getStationName1()+"%",
|
"%"+binf.getStationName()+"%",
|
"%"+binf.getStationName2()+"%",
|
"%"+binf.getStationName5()+"%",
|
(bmd.getPage().getPageCurr() - 1)* bmd.getPage().getPageSize(),
|
bmd.getPage().getPageSize()
|
}, new CallBack() {
|
public List getResults(ResultSet rs) {
|
List<Batt_Maint_Dealarm> list=new ArrayList();
|
try {
|
while(rs.next()){
|
Batt_Maint_Dealarm bmd=new Batt_Maint_Dealarm();
|
BattInf binf=new BattInf();
|
BattDischarge_plan bplan=new BattDischarge_plan();
|
binf.setStationName(rs.getString("stationName"));
|
binf.setStationName1(rs.getString("stationName1"));
|
binf.setStationName5(rs.getString("stationName5"));
|
binf.setBattGroupName(rs.getString("battGroupName"));
|
|
bplan.setNum(rs.getInt("num"));
|
bplan.setBattgroupid(rs.getInt("battgroupid"));
|
bplan.setBattIndexInFbs(rs.getInt("battIndexInFbs"));//第几组电池组
|
bplan.setDischarge_starttime(rs.getTimestamp("discharge_starttime"));
|
bplan.setDischarge_stoptime(rs.getTimestamp("discharge_stoptime"));
|
bplan.setDischarge_state(rs.getInt("discharge_state"));
|
bplan.setDischarge_reason(rs.getInt("discharge_reason"));
|
bplan.setDischarge_cleartype(rs.getInt("discharge_cleartype"));//计划的启用还是取消
|
bplan.setNote(rs.getString("battGroupName"));//电池组名称
|
bplan.setPreset_time(rs.getInt("preset_time"));
|
bplan.setPreset_cap(rs.getFloat("preset_cap"));
|
bplan.setPreset_monvol(rs.getFloat("preset_monvol"));
|
bplan.setPreset_groupvol(rs.getFloat("preset_groupvol"));
|
bplan.setPreset_curr(rs.getFloat("preset_curr"));
|
bplan.setPreset_mon(rs.getInt("preset_mon"));
|
bplan.setDcvolhighlimit(rs.getFloat("dcvolhighlimit"));
|
bplan.setChargecurrset(rs.getFloat("chargecurrset"));
|
|
|
Page page=new Page();
|
bmd.setBinf(binf);
|
bmd.setBplan(bplan);
|
bmd.setPage(page);
|
list.add(bmd);
|
}
|
} catch (SQLException e) {
|
// TODO Auto-generated catch block
|
e.printStackTrace();
|
}
|
return list;
|
}
|
});
|
//去掉limit条件后的总数
|
int number=LimitNumberFactory.GetLimtitNumber(conn, numberSql);
|
//System.out.println("number: "+number);
|
if(list!=null&&list.size()>0){
|
list.get(list.size()-1).getPage().setPageAll(number);
|
}
|
return list;
|
}
|
public List serchByInfo(Object obj) {
|
// TODO Auto-generated method stub
|
return null;
|
}
|
//9.1查询机房放电计划中存在放电延时的总数
|
//地图上所有的放电延时机房
|
public int serchByStationId(Object obj){
|
BattMap_information binformation=(BattMap_information) obj;
|
String sql="select count(num) as nums from web_site.tb_battdischarge_plan " +
|
"where " +
|
"battgroupid in (select distinct battgroupid from db_battinf.tb_battinf where stationid=? ) " +
|
"and discharge_state="+BattTestData.test_plan1+" limit 1 ";
|
//System.out.println(sql);
|
List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{binformation.getStationId()}, new CallBack() {
|
|
public List getResults(ResultSet rs) {
|
List list=new ArrayList();
|
try {
|
while(rs.next()){
|
int nums=rs.getInt("nums");
|
list.add(nums);
|
}
|
} catch (SQLException e) {
|
// TODO Auto-generated catch block
|
e.printStackTrace();
|
}
|
return list;
|
}
|
});
|
int nums=0;//最后的结果
|
if(list!=null&&list.size()>0){
|
nums=(Integer) list.get(list.size()-1);
|
}
|
return nums;
|
}
|
|
//8.1查询未开始放电的放电计划总数
|
/*public int searchNums() {
|
String sql="select count(num) as nums " +
|
" from web_site.tb_battdischarge_plan " +
|
" where discharge_state="+BattTestData.test_plan0+" " +
|
" and battgroupid in (select distinct battgroupid from db_battinf.tb_battinf) "+
|
" limit 1 ";
|
//System.out.println(sql);
|
List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), null, new CallBack() {
|
|
public List getResults(ResultSet rs) {
|
List list=new ArrayList();
|
try {
|
while(rs.next()){
|
int nums=rs.getInt("nums");
|
list.add(nums);
|
}
|
} catch (SQLException e) {
|
// TODO Auto-generated catch block
|
e.printStackTrace();
|
}
|
return list;
|
}
|
});
|
int nums=0;//最后的结果
|
if(list!=null&&list.size()>0){
|
nums=(Integer) list.get(list.size()-1);
|
}
|
return nums;
|
}*/
|
public int searchNums(Object obj) {
|
User_inf uinf=(User_inf) obj;
|
String sql="select count(num) as nums " +
|
" from web_site.tb_battdischarge_plan " +
|
" where discharge_state="+BattTestData.test_plan0+" " +
|
" and battgroupid in (select distinct db_battinf.tb_battinf.battgroupid " +
|
" 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=?) "+
|
" limit 1 ";
|
//System.out.println(sql);
|
List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{uinf.getUId()}, new CallBack() {
|
|
public List getResults(ResultSet rs) {
|
List list=new ArrayList();
|
try {
|
while(rs.next()){
|
int nums=rs.getInt("nums");
|
list.add(nums);
|
}
|
} catch (SQLException e) {
|
// TODO Auto-generated catch block
|
e.printStackTrace();
|
}
|
return list;
|
}
|
});
|
int nums=0;//最后的结果
|
if(list!=null&&list.size()>0){
|
nums=(Integer) list.get(list.size()-1);
|
}
|
return nums;
|
}
|
//8.1放电计划管理中饼状图(放电计划统计查询)
|
/*public List searchState(){
|
String sql="SELECT COUNT(num) number,discharge_state from web_site.tb_battdischarge_plan " +
|
" GROUP BY discharge_state ";
|
|
List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), null, new CallBack() {
|
|
public List getResults(ResultSet rs) {
|
List list=new ArrayList();
|
try {
|
while(rs.next()){
|
BattDischarge_plan bplan=new BattDischarge_plan();
|
bplan.setNum(rs.getInt("number"));
|
bplan.setDischarge_state(rs.getInt("discharge_state"));
|
list.add(bplan);
|
}
|
} catch (SQLException e) {
|
// TODO Auto-generated catch block
|
e.printStackTrace();
|
}
|
return list;
|
}
|
});
|
return list;
|
}*/
|
public List searchState(Object obj){
|
User_inf uinf=(User_inf) obj;
|
String sql="SELECT COUNT(num) number,discharge_state,battgroupid from web_site.tb_battdischarge_plan " +
|
" GROUP BY battgroupid,discharge_state ";
|
//用于用户管理的电池组的筛选
|
String userSql=" having web_site.tb_battdischarge_plan.battgroupid in(select distinct db_battinf.tb_battinf.battgroupid " +
|
" 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=? )";
|
sql+=userSql;
|
List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{uinf.getUId()}, new CallBack() {
|
|
public List getResults(ResultSet rs) {
|
List list=new ArrayList();
|
try {
|
while(rs.next()){
|
BattDischarge_plan bplan=new BattDischarge_plan();
|
bplan.setNum(rs.getInt("number"));
|
bplan.setDischarge_state(rs.getInt("discharge_state"));
|
list.add(bplan);
|
}
|
} catch (SQLException e) {
|
// TODO Auto-generated catch block
|
e.printStackTrace();
|
}
|
return list;
|
}
|
});
|
return list;
|
}
|
public static void main(String[] args) throws ParseException {
|
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
|
Date date1 = sdf.parse("2000-01-01");
|
Date date2 = sdf.parse("2020-01-01");
|
|
BattInf binf = new BattInf();
|
binf.setStationName("");
|
binf.setStationName1("");
|
binf.setBattGroupId(0);
|
|
BattDischarge_plan bplan=new BattDischarge_plan();
|
bplan.setDischarge_starttime(ActionUtil.getSimpDate(date1));
|
bplan.setDischarge_starttime1(ActionUtil.getSimpDate(date2));
|
bplan.setDischarge_stoptime(ActionUtil.getSimpDate(date1));
|
bplan.setDischarge_stoptime1(ActionUtil.getSimpDate(date2));
|
bplan.setDischarge_state(2);
|
Page p=new Page();
|
p.setPageCurr(1);
|
p.setPageSize(10);
|
User_inf uinf=new User_inf();
|
uinf.setUId(1038);
|
|
Batt_Maint_Dealarm bmd = new Batt_Maint_Dealarm();
|
bmd.setBinf(binf);
|
bmd.setBplan(bplan);
|
bmd.setPage(p);
|
bmd.setUinf(uinf);
|
|
BattDischarge_planImpl bimpl=new BattDischarge_planImpl();
|
/*List<Batt_Maint_Dealarm> list=bimpl.serchByCondition(bmd);
|
for (Batt_Maint_Dealarm b : list) {
|
System.out.println(b.getBplan());
|
}
|
System.out.println(list.size());*/
|
/*BattMap_information binformation=new BattMap_information();
|
binformation.setStationId("42070451");
|
int nums=bimpl.serchByStationId(binformation);
|
System.out.println(nums);*/
|
/*List<BattDischarge_plan> list=bimpl.searchState(uinf);
|
for (BattDischarge_plan b : list) {
|
System.out.println(b);
|
}*/
|
}
|
}
|
