package com.fgkj.dao.impl;
|
|
import java.sql.ResultSet;
|
import java.sql.SQLException;
|
import java.text.ParseException;
|
import java.text.SimpleDateFormat;
|
import java.util.ArrayList;
|
import java.util.Calendar;
|
import java.util.Date;
|
import java.util.List;
|
|
import com.fgkj.actions.ActionUtil;
|
import com.fgkj.dao.BaseDAO;
|
import com.fgkj.dao.CallBack;
|
import com.fgkj.dao.DAOHelper;
|
import com.fgkj.db.DBUtil;
|
import com.fgkj.dto.Stationtraffic;
|
import com.sun.org.apache.bcel.internal.generic.IINC;
|
|
public class StationtrafficImpl 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) {
|
final Stationtraffic straffic=(Stationtraffic) obj;
|
String sql=" select distinct tb_stationtraffic.num,dev_id,record_time,dayflow,nowflow" +
|
" ,tb_battinf.StationId,tb_battinf.stationName,tb_battinf.stationName1,tb_battinf.stationName2,tb_battinf.stationName3,tb_battinf.stationName5 " +
|
" from web_site.tb_stationtraffic,db_battinf.tb_battinf " +
|
" where web_site.tb_stationtraffic.dev_id=db_battinf.tb_battinf.fBSDeviceId " +
|
" and record_time>? and record_time<? " +
|
" and dev_id=? " ;
|
//用户管理
|
String userSql=" and db_battinf.tb_battinf.StationId in(" +
|
" select distinct db_user.tb_user_battgroup_baojigroup_battgroup.StationId from db_user.tb_user_battgroup_baojigroup_battgroup,db_user.tb_user_battgroup_baojigroup_usr where db_user.tb_user_battgroup_baojigroup_battgroup.baoji_group_id=db_user.tb_user_battgroup_baojigroup_usr.baoji_group_id and db_user.tb_user_battgroup_baojigroup_usr.uId=? "+
|
" ) ";
|
sql+=userSql;
|
String orderSql=" order by dev_id,record_time asc ";
|
sql+=orderSql;
|
List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{straffic.getRecord_time(),straffic.getRecord_time1(),straffic.getDev_id(),Integer.parseInt(straffic.getNote())}, new CallBack() {
|
|
public List getResults(ResultSet rs) {
|
List list=new ArrayList();
|
// 时间段
|
String perid_Time = "";
|
Calendar now = Calendar.getInstance();
|
int dayflow=0;
|
try {
|
while(rs.next()){
|
|
int dayflows=rs.getInt("dayflow");
|
// 年份，季度，月份
|
Date dev_recordtime = rs.getTimestamp("record_time");
|
// 获取具体年份，月份和该月的总天数
|
/*int year = dev_recordtime.getYear() + 1900;
|
int month = dev_recordtime.getMonth() + 1;*/
|
now.setTime(dev_recordtime);
|
int year = now.get(Calendar.YEAR);
|
int month = now.get(Calendar.MONTH) + 1; // 0-based!
|
int day = now.get(Calendar.DAY_OF_MONTH);
|
//System.out.println(dev_recordtime+" "+day);
|
String perid_Times="";
|
if(straffic.getNum()==1){//月统计
|
perid_Times = ActionUtil.getFirstDayOfMonth(year, month - 1);
|
perid_Times += "~";
|
perid_Times += ActionUtil.getLastDayOfMonth(year, month - 1);
|
}else if (straffic.getNum()==3) {// 按年份
|
perid_Times = ActionUtil.getFirstDayOfMonth(year, 0);
|
perid_Times += "~";
|
perid_Times += ActionUtil.getLastDayOfMonth(year, 11);
|
}else if(straffic.getNum()==2){ //日统计
|
perid_Times = ActionUtil.getDayTime(year, month-1, day, 1);
|
perid_Times += "~";
|
perid_Times += ActionUtil.getDayTime(year, month-1, day, 4);
|
}
|
//System.out.println(perid_Times+" "+perid_Time+" "+nowflows);
|
if(perid_Times.equals(perid_Time)){
|
dayflow+=dayflows;
|
}else{
|
if(perid_Time.equals("")){
|
perid_Time=perid_Times;
|
dayflow+=dayflows;
|
continue;
|
}
|
Stationtraffic st=new Stationtraffic();
|
st.setDev_id(rs.getInt("dev_id"));
|
st.setDayflow(dayflow);
|
st.setStationName(rs.getString("stationName"));
|
st.setStationName1(rs.getString("stationName1"));
|
st.setStationName2(rs.getString("stationName2"));
|
st.setStationName3(rs.getString("stationName3"));
|
st.setStationName5(rs.getString("stationName5"));
|
st.setNote(perid_Time);
|
list.add(st);
|
dayflow=0;
|
dayflow+=dayflows;
|
perid_Time=perid_Times;
|
|
}
|
if(rs.isLast()){
|
Stationtraffic st=new Stationtraffic();
|
st.setDev_id(rs.getInt("dev_id"));
|
st.setDayflow(dayflow);
|
st.setStationName(rs.getString("stationName"));
|
st.setStationName1(rs.getString("stationName1"));
|
st.setStationName2(rs.getString("stationName2"));
|
st.setStationName3(rs.getString("stationName3"));
|
st.setStationName5(rs.getString("stationName5"));
|
st.setNote(perid_Time);
|
list.add(st);
|
}
|
}
|
|
} 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) throws ParseException {
|
StationtrafficImpl simpl=new StationtrafficImpl();
|
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
|
Date date1 = sdf.parse("2000-01-01 00:00:00");
|
Date date2 = sdf.parse("2020-01-01 00:00:00");
|
|
Stationtraffic st=new Stationtraffic();
|
st.setNum(3);
|
st.setDev_id(910000001);
|
st.setNote("1002");
|
st.setRecord_time(ActionUtil.getSimpDate(date1));
|
st.setRecord_time1(ActionUtil.getSimpDate(date2));
|
List<Stationtraffic> list=simpl.serchByCondition(st);
|
for (Stationtraffic s : list) {
|
System.out.println(s);
|
}
|
}
|
}
|
