| | |
|---|
| | | 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 serchByCondition(Object obj) {
|
|---|
| | | final Stationtraffic straffic=(Stationtraffic) obj;
|
|---|
| | | String sql=" select distinct tb_stationtraffic.num,dev_id,record_time,dayflow,nowflow" +
|
|---|
| | | " ,tb_battinf.stationName,tb_battinf.stationName1,tb_battinf.stationName2,tb_battinf.stationName3,tb_battinf.stationName5 " +
|
|---|
| | | " ,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=? " +
|
|---|
| | | " order by dev_id,record_time asc ";
|
|---|
| | | List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{straffic.getRecord_time(),straffic.getRecord_time1(),straffic.getDev_id()}, new CallBack() {
|
|---|
| | | " 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 nowflow=0;
|
|---|
| | | int dayflow=0;
|
|---|
| | | try {
|
|---|
| | | while(rs.next()){
|
|---|
| | |
|
|---|
| | | int nowflows=rs.getInt("nowflow");
|
|---|
| | | int dayflows=rs.getInt("dayflow");
|
|---|
| | | // 年份，季度，月份
|
|---|
| | | Date dev_recordtime = rs.getTimestamp("record_time");
|
|---|
| | | // 获取具体年份，月份和该月的总天数
|
|---|
| | |
|---|
| | | }
|
|---|
| | | //System.out.println(perid_Times+" "+perid_Time+" "+nowflows);
|
|---|
| | | if(perid_Times.equals(perid_Time)){
|
|---|
| | | nowflow+=nowflows;
|
|---|
| | | dayflow+=dayflows;
|
|---|
| | | }else{
|
|---|
| | | if(perid_Time.equals("")){
|
|---|
| | | perid_Time=perid_Times;
|
|---|
| | | nowflow+=nowflows;
|
|---|
| | | dayflow+=dayflows;
|
|---|
| | | continue;
|
|---|
| | | }
|
|---|
| | | Stationtraffic st=new Stationtraffic();
|
|---|
| | | st.setDev_id(rs.getInt("dev_id"));
|
|---|
| | | st.setNowflow(nowflow);
|
|---|
| | | st.setDayflow(dayflow);
|
|---|
| | | st.setStationName(rs.getString("stationName"));
|
|---|
| | | st.setStationName1(rs.getString("stationName1"));
|
|---|
| | | st.setStationName2(rs.getString("stationName2"));
|
|---|
| | |
|---|
| | | st.setStationName5(rs.getString("stationName5"));
|
|---|
| | | st.setNote(perid_Time);
|
|---|
| | | list.add(st);
|
|---|
| | | nowflow=0;
|
|---|
| | | nowflow+=nowflows;
|
|---|
| | | dayflow=0;
|
|---|
| | | dayflow+=dayflows;
|
|---|
| | | perid_Time=perid_Times;
|
|---|
| | |
|
|---|
| | | }
|
|---|
| | | if(rs.isLast()){
|
|---|
| | | Stationtraffic st=new Stationtraffic();
|
|---|
| | | st.setDev_id(rs.getInt("dev_id"));
|
|---|
| | | st.setNowflow(nowflow);
|
|---|
| | | st.setDayflow(dayflow);
|
|---|
| | | st.setStationName(rs.getString("stationName"));
|
|---|
| | | st.setStationName1(rs.getString("stationName1"));
|
|---|
| | | st.setStationName2(rs.getString("stationName2"));
|
|---|
| | |
|---|
| | | 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);
|
|---|
