| New file |
| | |
|---|
| | | 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 com.fgkj.actions.ActionUtil;
|
|---|
| | | import com.fgkj.dao.BaseDAO;
|
|---|
| | | import com.fgkj.dao.CallBack;
|
|---|
| | | import com.fgkj.dao.DAOHelper;
|
|---|
| | | import com.fgkj.dao.LimitNumberFactory;
|
|---|
| | | import com.fgkj.db.DBUtil;
|
|---|
| | | import com.fgkj.db.IDatabaseName;
|
|---|
| | | import com.fgkj.dto.Page;
|
|---|
| | | import com.fgkj.dto.User_inf;
|
|---|
| | | import com.fgkj.dto.User_log;
|
|---|
| | |
|
|---|
| | | public class User_logImpl implements BaseDAO, CallBack {
|
|---|
| | | private SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
|
|---|
| | |
|
|---|
| | | public List getResults(ResultSet rs) {
|
|---|
| | | List list = new ArrayList();
|
|---|
| | | try {
|
|---|
| | | while (rs.next()) {
|
|---|
| | | User_log ulog = new User_log();
|
|---|
| | | ulog.setNum(rs.getInt("num"));
|
|---|
| | | ulog.setuId(rs.getInt("uId"));
|
|---|
| | | ulog.setUOprateType(rs.getInt("uOprateType"));
|
|---|
| | | ulog.setUOprateDay(rs.getTimestamp("uOprateDay"));
|
|---|
| | | ulog.setuTerminalIp(rs.getString("uTerminalIp"));
|
|---|
| | | ulog.setuOprateMsg(rs.getString("uOprateMsg"));
|
|---|
| | | list.add(ulog);
|
|---|
| | | }
|
|---|
| | | } catch (SQLException e) {
|
|---|
| | | // TODO Auto-generated catch block
|
|---|
| | | e.printStackTrace();
|
|---|
| | | } |
|---|
| | | return list;
|
|---|
| | | }
|
|---|
| | | //用户的操作记录下来
|
|---|
| | | public boolean add(Object obj) {
|
|---|
| | | User_log ulog=(User_log) obj;
|
|---|
| | | String sql="insert into db_user.tb_user_log(uId,uOprateType,uOprateDay,uTerminalIp,uOprateMsg) values(?,?,?,?,?)";
|
|---|
| | | Boolean bl=DAOHelper.executeUpdate(DBUtil.getConn(), sql, new Object[]{ulog.getuId(),
|
|---|
| | | ulog.getUOprateType(),ulog.getUOprateDay(),ulog.getuTerminalIp(),ulog.getuOprateMsg()});
|
|---|
| | | return bl;
|
|---|
| | | }
|
|---|
| | | //用户的操作记录下来(记录多条)
|
|---|
| | | public boolean addPro(Object obj) {
|
|---|
| | | List<User_log> list=(List) obj;
|
|---|
| | | ArrayList sql_strs=new ArrayList();
|
|---|
| | | if(list!=null&&list.size()>0){
|
|---|
| | | for (User_log ulog : list) {
|
|---|
| | | String sql="insert into db_user.tb_user_log(uId,uOprateType,uOprateDay,uTerminalIp,uOprateMsg) values("+ulog.getuId()+","+ulog.getUOprateType()+",'"+DAOHelper.sdf.format(ulog.getUOprateDay())+"','"+ulog.getuTerminalIp()+"','"+ulog.getuOprateMsg()+"')";
|
|---|
| | | sql_strs.add(sql);
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | boolean bl=DAOHelper.makeManualCommit(DBUtil.getConn(), sql_strs);
|
|---|
| | | return bl;
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | public boolean update(Object obj) {
|
|---|
| | | User_log ulog=(User_log) obj;
|
|---|
| | | String sql="update db_user.tb_user_log set uId=?,uOprateType=?,uOprateDay=?,uTerminalIp=?,uOprateMsg=? where num=?";
|
|---|
| | | Boolean bl=DAOHelper.executeUpdate(DBUtil.getConn(), sql, new Object[]{ulog.getuId(),
|
|---|
| | | ulog.getUOprateType(),ulog.getUOprateDay(),ulog.getuTerminalIp(),ulog.getuOprateMsg(),ulog.getNum()});
|
|---|
| | | return bl;
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | public boolean del(Object obj) {
|
|---|
| | | User_log ulog=(User_log) obj;
|
|---|
| | | String sql="delete from db_user.tb_user_log where num=?";
|
|---|
| | | Boolean bl=DAOHelper.executeUpdate(DBUtil.getConn(), sql, new Object[]{ulog.getNum()});
|
|---|
| | | return bl;
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | public List searchAll() {
|
|---|
| | | String sql = "select num,uId,uOprateType,uOprateDay,uTerminalIp,uOprateMsg from db_user.tb_user_log order by (uOprateDay) desc";
|
|---|
| | | List list = DAOHelper
|
|---|
| | | .executeQuery(sql, DBUtil.getConn(), null,
|
|---|
| | | new User_logImpl());
|
|---|
| | | return list;
|
|---|
| | | }
|
|---|
| | | @Override
|
|---|
| | | public List serchByCondition(Object obj) {
|
|---|
| | | // TODO Auto-generated method stub
|
|---|
| | | return null;
|
|---|
| | | }
|
|---|
| | | @Override
|
|---|
| | | public List serchByInfo(Object obj) {
|
|---|
| | | // TODO Auto-generated method stub
|
|---|
| | | return null;
|
|---|
| | | }
|
|---|
| | | |
|---|
| | | /*//5.4用户操作记录查询(根据用户名和操作类型)
|
|---|
| | | public List serchByCondition1(Object obj) {
|
|---|
| | | Batt_User_Permit bup=(Batt_User_Permit) obj;
|
|---|
| | | User_log ulog=bup.getUlog();
|
|---|
| | | User_inf uinf=bup.getUinf();
|
|---|
| | | //System.out.println(uinf);
|
|---|
| | | //System.out.println(ulog);
|
|---|
| | | String sql="";
|
|---|
| | | String baseSql = "select tb_user_log.uId,uoprateType,uoprateDay,uterminalIp,uoprateMsg" +
|
|---|
| | | ",tb_user_inf.uName " +
|
|---|
| | | "from db_user.tb_user_inf,db_user.tb_user_log " +
|
|---|
| | | "where tb_user_inf.uId=tb_user_log.uId " +
|
|---|
| | | "and tb_user_inf.uName like ?" +
|
|---|
| | | "and (uoprateDay)>(?) " +
|
|---|
| | | "and (uoprateDay)<(?) ";
|
|---|
| | | String sqlT="and uoprateType=?";
|
|---|
| | | String sqlF="and uoprateType!=?";
|
|---|
| | | |
|---|
| | | if(ulog.getUOprateType()==0){
|
|---|
| | | sql=baseSql+sqlF;
|
|---|
| | | }else{
|
|---|
| | | sql=baseSql+sqlT;
|
|---|
| | | }
|
|---|
| | | //System.out.println("查询操作记录");
|
|---|
| | | String endsql = " ORDER BY uOprateDay DESC ";
|
|---|
| | | sql= sql+endsql;
|
|---|
| | | List list = DAOHelper
|
|---|
| | | .executeQuery(sql, DBUtil.getConn(), new Object[]{"%"+uinf.getUName()+"%",ulog.getUOprateDay(),ulog.getUOprateDay1(),ulog.getUOprateType()},new CallBack() {
|
|---|
| | | |
|---|
| | | public List getResults(ResultSet rs) {
|
|---|
| | | List list=new ArrayList();
|
|---|
| | | try {
|
|---|
| | | while(rs.next()){
|
|---|
| | | Batt_User_Permit bup=new Batt_User_Permit();
|
|---|
| | | User_inf uinf=new User_inf();
|
|---|
| | | uinf.setUName(rs.getString("uName"));
|
|---|
| | | |
|---|
| | | User_log ulog=new User_log();
|
|---|
| | | ulog.setuId(rs.getInt("uId"));
|
|---|
| | | ulog.setUOprateType(rs.getInt("uOprateType"));
|
|---|
| | | ulog.setUOprateDay(rs.getTimestamp("uOprateDay"));
|
|---|
| | | ulog.setuTerminalIp(rs.getString("uTerminalIp"));
|
|---|
| | | ulog.setuOprateMsg(rs.getString("uOprateMsg"));
|
|---|
| | | |
|---|
| | | Page page=new Page();
|
|---|
| | | |
|---|
| | | bup.setUinf(uinf);
|
|---|
| | | bup.setUlog(ulog);
|
|---|
| | | bup.setPage(page);
|
|---|
| | | list.add(bup);
|
|---|
| | | }
|
|---|
| | | } catch (SQLException e) {
|
|---|
| | | // TODO Auto-generated catch block
|
|---|
| | | e.printStackTrace();
|
|---|
| | | } |
|---|
| | | return list;
|
|---|
| | | }
|
|---|
| | | });
|
|---|
| | | List<Batt_User_Permit> listd=new ArrayList();
|
|---|
| | | |
|---|
| | | int index=0;
|
|---|
| | | //System.out.println(list.size());
|
|---|
| | | for(int i=(bup.getPage().getPageCurr()-1)*bup.getPage().getPageSize();i<bup.getPage().getPageSize()*bup.getPage().getPageCurr()&&i<list.size();i++){
|
|---|
| | | listd.add((Batt_User_Permit) list.get(i));
|
|---|
| | | //system.out.println(list.get(i));
|
|---|
| | | ((Batt_User_Permit)listd.get(index++)).getPage().setPageAll(list.size());
|
|---|
| | | }
|
|---|
| | | return listd;
|
|---|
| | | }*/
|
|---|
| | | /*//5.4用户操作记录查询(根据用户名和操作类型)
|
|---|
| | | @SuppressWarnings("unchecked")
|
|---|
| | | public List serchByCondition(Object obj) {
|
|---|
| | | Batt_User_Permit bup=(Batt_User_Permit) obj;
|
|---|
| | | User_log ulog=bup.getUlog();
|
|---|
| | | User_inf uinf=bup.getUinf();
|
|---|
| | | //System.out.println(ulog);
|
|---|
| | | //System.out.println(uinf);
|
|---|
| | | String sql="";
|
|---|
| | | String numberSql=" SELECT FOUND_ROWS() number";
|
|---|
| | | Connection conn=DBUtil.getConn();
|
|---|
| | | String baseSql = "select SQL_CALC_FOUND_ROWS tb_user_log.uId,uoprateType,uoprateDay,uterminalIp,uoprateMsg" +
|
|---|
| | | ",tb_user_inf.uName " +
|
|---|
| | | "from db_user.tb_user_inf,db_user.tb_user_log " +
|
|---|
| | | "where tb_user_inf.uId=tb_user_log.uId " +
|
|---|
| | | "and tb_user_inf.uName like ?" +
|
|---|
| | | "and (uoprateDay)>(?) " +
|
|---|
| | | "and (uoprateDay)<(?) ";
|
|---|
| | | String sqlT="and uoprateType=?";
|
|---|
| | | String sqlF="and uoprateType!=?";
|
|---|
| | | |
|---|
| | | if(ulog.getUOprateType()==0){
|
|---|
| | | sql=baseSql+sqlF;
|
|---|
| | | }else{
|
|---|
| | | sql=baseSql+sqlT;
|
|---|
| | | }
|
|---|
| | | String endsql = " ORDER BY uOprateDay DESC ";
|
|---|
| | | sql= sql+endsql;
|
|---|
| | | String limitSql=" limit ?,? ";
|
|---|
| | | sql+=limitSql;
|
|---|
| | | List<Batt_User_Permit> list = DAOHelper
|
|---|
| | | .executeQueryLimit(sql, conn, new Object[]{"%"+uinf.getUName()+"%",ulog.getUOprateDay(),ulog.getUOprateDay1(),ulog.getUOprateType(),(bup.getPage().getPageCurr() - 1)* bup.getPage().getPageSize(),
|
|---|
| | | bup.getPage().getPageSize()
|
|---|
| | | },new CallBack() {
|
|---|
| | | |
|---|
| | | public List getResults(ResultSet rs) {
|
|---|
| | | List list=new ArrayList();
|
|---|
| | | try {
|
|---|
| | | while(rs.next()){
|
|---|
| | | Batt_User_Permit bup=new Batt_User_Permit();
|
|---|
| | | User_inf uinf=new User_inf();
|
|---|
| | | uinf.setUName(rs.getString("uName"));
|
|---|
| | | |
|---|
| | | User_log ulog=new User_log();
|
|---|
| | | ulog.setuId(rs.getInt("uId"));
|
|---|
| | | ulog.setUOprateType(rs.getInt("uOprateType"));
|
|---|
| | | ulog.setUOprateDay(rs.getTimestamp("uOprateDay"));
|
|---|
| | | ulog.setuTerminalIp(rs.getString("uTerminalIp"));
|
|---|
| | | ulog.setuOprateMsg(rs.getString("uOprateMsg"));
|
|---|
| | | |
|---|
| | | Page page=new Page();
|
|---|
| | | |
|---|
| | | bup.setUinf(uinf);
|
|---|
| | | bup.setUlog(ulog);
|
|---|
| | | bup.setPage(page);
|
|---|
| | | list.add(bup);
|
|---|
| | | }
|
|---|
| | | } 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;
|
|---|
| | | }*/
|
|---|
| | | /*//0.2当前时间的操作记录
|
|---|
| | | public List serchByInfo(Object obj) {
|
|---|
| | | User_log ulog=(User_log) obj;
|
|---|
| | | String sql="select tb_user_log.uId,uoprateType,uoprateDay,uterminalIp,uoprateMsg" +
|
|---|
| | | ",tb_user_inf.uName " +
|
|---|
| | | "from db_user.tb_user_inf,db_user.tb_user_log " +
|
|---|
| | | "where tb_user_inf.uId=tb_user_log.uId " +
|
|---|
| | | "and (uoprateDay)>=(?) " +
|
|---|
| | | "and (uoprateDay)<=(?) ";
|
|---|
| | | List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{ulog.getUOprateDay(),ulog.getUOprateDay1()}, new CallBack() {
|
|---|
| | | |
|---|
| | | public List getResults(ResultSet rs) {
|
|---|
| | | List list=new ArrayList();
|
|---|
| | | try {
|
|---|
| | | while(rs.next()){
|
|---|
| | | Batt_User_Permit bup=new Batt_User_Permit();
|
|---|
| | | User_inf uinf=new User_inf();
|
|---|
| | | uinf.setUName(rs.getString("uName"));
|
|---|
| | | |
|---|
| | | User_log ulog=new User_log();
|
|---|
| | | ulog.setuId(rs.getInt("uId"));
|
|---|
| | | ulog.setUOprateType(rs.getInt("uOprateType"));
|
|---|
| | | ulog.setUOprateDay(rs.getTimestamp("uOprateDay"));
|
|---|
| | | ulog.setuTerminalIp(rs.getString("uTerminalIp"));
|
|---|
| | | ulog.setuOprateMsg(rs.getString("uOprateMsg"));
|
|---|
| | | |
|---|
| | | |
|---|
| | | bup.setUinf(uinf);
|
|---|
| | | bup.setUlog(ulog);
|
|---|
| | | |
|---|
| | | list.add(bup);
|
|---|
| | | }
|
|---|
| | | } catch (SQLException e) {
|
|---|
| | | // TODO Auto-generated catch block
|
|---|
| | | e.printStackTrace();
|
|---|
| | | } |
|---|
| | | return list;
|
|---|
| | | }
|
|---|
| | | });
|
|---|
| | | return list;
|
|---|
| | | }*/
|
|---|
| | | |
|---|
| | | |
|---|
| | |
|
|---|
| | | |
|---|
| | | }
|
|---|
