统计流量

whyclxw

2020-10-22 e9d774c0587d03793b2b08384781525ca5ad2055

统计流量

 gx_tieta/src/com/fgkj/dao/impl/StationtrafficImpl.java

@@ -1,167 +1,257 @@
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);

        }

}

}

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) {
        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 orderSql="  order by dev_id,record_time asc ";
        sql+=orderSql;
        System.out.println(sql);
        List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{straffic.getRecord_time(),straffic.getRecord_time1(),straffic.getDev_id()}, 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 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("2020-01-01 00:00:00");
         Date date2 = sdf.parse("2020-12-31 00:00:00");
		 
         Stationtraffic st=new Stationtraffic();
         st.setNum(3);
         st.setDev_id(910000012);
         st.setNote("1002");
         st.setRecord_time(ActionUtil.getSimpDate(date1));
         st.setRecord_time1(ActionUtil.getSimpDate(date2));
         List<Stationtraffic> list=simpl.serchByInfo(st);
         for (Stationtraffic s : list) {
            System.out.println(s);
        }
}
}