userselfdaoimpl.java

来自「电信计费项目 该系统在Sun Solaris下开发,运行于Apache Tom」· Java 代码 · 共 79 行

package com.tarena.netctoss.model.persist;

import java.util.List;
import java.util.ArrayList;
import java.sql.*;

import com.tarena.util.*;
import com.tarena.netctoss.model.biz.entity.*;

public class UserSelfDAOImpl implements IUserSelfDAO{

	@SuppressWarnings("unchecked")
	public List findAllMonth(Long user_id, int year, int month) {
		Connection con = JDBCFactoryManager.getConnection();
		Statement stmt = null;
		ResultSet rs = null;
		List list = new ArrayList();
		String sql = "select month.time_duration,a.lab_login_name,a.lab_ip,a.base_fee,a.rate_fee from t_monthwdd_"+month+
		" month,(select tu.user_id,tus.lab_login_name,tus.lab_ip,tp.base_fee,tp.rate_fee from "+
		" t_user_wdd tu,t_ServiceUser_wdd tus,t_price_wdd tp where tu.user_id = tus.user_fid and tp.price_id=tus.price_fid " +
		"and tu.user_id ="+ user_id +") a where " +
		"to_char(month.logout_date,'YYYY-MM') ="+"'"+year+(month<10?"-0":"-")+month+"'"+" and month.login_name=a.lab_login_name";
		try {
			stmt = con.createStatement();
			rs = stmt.executeQuery(sql);
			while(rs.next()){
				UserSelf self = new UserSelf();
				self.setBase_fee(rs.getDouble("base_fee"));
				self.setRate_fee(rs.getDouble("rate_fee"));
				self.setLab_ip(rs.getString("lab_ip"));
				self.setLogin_name(rs.getString("lab_login_name"));
				self.setTime_duration(rs.getDouble("time_duration"));
				list.add(self);
			}
		} catch (SQLException e) {
			e.printStackTrace();
		} finally{
			JDBCFactoryManager.release(rs, stmt, null);
		}
		return list;
	}
	
	@SuppressWarnings("unchecked")
	public List findAllDay(Long user_id, int year, int month) {
		Connection con = JDBCFactoryManager.getConnection();
		int days = DateUtil.getLastDay(year, month);
		Statement stmt = null;
		ResultSet rs = null;
		List lists = new ArrayList();
		for(int i=1;i<days;i++){
			String sql ="select to_char(td.login_date,'YYYY-MM-DD HH24:MI:SS') login_time,to_char(td.logout_date,'YYYY-MM-DD HH24:MI:SS') logout_time,td.login_name,td.time_duration,a.base_fee,a.rate_fee from t_detailwdd_"+i+" td, " +
							"(select tu.user_id,tus.lab_login_name,tus.lab_ip ,tp.base_fee,tp.rate_fee from"+
							" t_user_wdd tu,t_ServiceUser_wdd tus ,t_price_wdd tp where tu.user_id = tus.user_fid and tp.price_id=tus.price_fid" +
							" and tu.user_id ="+user_id+") a" +
							" where td.login_name = a.lab_login_name";
			try {
				stmt = con.createStatement();
				rs = stmt.executeQuery(sql);
				while(rs.next()){
					UserDetail detail = new UserDetail();
					detail.setLogout_date(rs.getString("logout_time"));
					detail.setLogin_date(rs.getString("login_time"));
					detail.setTime_duration(rs.getDouble("time_duration"));
					detail.setBase_fee(rs.getDouble("base_fee"));
					detail.setRate_fee(rs.getDouble("rate_fee"));
					detail.setLogin_name(rs.getString("login_name"));
					lists.add(detail);
				}
			} catch (SQLException e) {
				e.printStackTrace();
			}finally{
				JDBCFactoryManager.release(rs, stmt,null);
			}
		}
		return lists;
	}
	
}