whyclxw
2021-03-25 2e5acc768207c8ba20cf895c61d8415ebe581239
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
package com.fgkj.dao.impl;
 
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
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.User_inf;
 
public class User_infImpl implements BaseDAO, CallBack {
 
    @Override
    public List getResults(ResultSet rs) {
        // TODO Auto-generated method stub
        return null;
    }
    //添加用户
    @Override
    public boolean add(Object obj) {
        User_inf uinf=(User_inf) obj;
        String sql=" insert into db_user.tb_user_inf(USnId,UName,Upassword) values(?,?,?) ";
        boolean bl=DAOHelper.executeUpdate( DBUtil.getConn(), sql, new Object[]{uinf.getUSnId(),uinf.getUName(),ActionUtil.EncryptionBase64(uinf.getUSnId())});
        return bl;
    }
    //修改用户密码
    @Override
    public boolean update(Object obj) {
        User_inf uinf=(User_inf) obj;
        String sql=" update  db_user.tb_user_inf set USnId=?,Upassword=? where uid=? ";
        boolean bl=DAOHelper.executeUpdate( DBUtil.getConn(), sql, new Object[]{uinf.getUSnId(),ActionUtil.EncryptionBase64(uinf.getUSnId()),uinf.getUId()});
        return bl;
    }
    //删除用户
    @Override
    public boolean del(Object obj) {
        User_inf uinf=(User_inf) obj;
        String sql="delete from  db_user.tb_user_inf  where uid=? ";
        boolean bl=DAOHelper.executeUpdate( DBUtil.getConn(), sql, new Object[]{uinf.getUId()});
        return bl;
    }
    //查询所有的用户(不含密码)
    @Override
    public List searchAll() {
        String sql=" select distinct uid,UName from db_user.tb_user_inf ";
        List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), null, new CallBack() {
            
            @Override
            public List getResults(ResultSet rs) {
                List list=new ArrayList();
                try {
                    while(rs.next()){
                        User_inf uinf=new User_inf();
                        uinf.setUId(rs.getInt("uId"));
                        uinf.setUName(rs.getString("uName"));
                        list.add(uinf);
                    }
                } catch (SQLException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }
                return list;
            }
        });
        return list;
    }
    //根据输入的用户名查询存在数据库中的用户名和加密密码
    @Override
    public List serchByCondition(Object obj) {
        User_inf uinf=(User_inf) obj;
        String sql = "select tb_user_inf.uid,uname,upassword,unote,IFNULL(db_user.tb_user_battgroup_baojigroup_usr.baoji_group_id,0) as baoji_group_id from db_user.tb_user_inf "
                + " left join db_user.tb_user_battgroup_baojigroup_usr on tb_user_inf.uid=tb_user_battgroup_baojigroup_usr.uid"
                + " where uname=? ";
        List list = DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{uinf.getUName()},
                        new CallBack() {
                            
                            public List getResults(ResultSet rs) {
                                List list=new ArrayList();
                                try {
                                    while(rs.next()){
                                        User_inf uinf=new User_inf();
                                        uinf.setUId(rs.getInt("uId"));
                                        uinf.setUName(rs.getString("uName"));
                                        uinf.setUNote(rs.getString("baoji_group_id"));
                                        uinf.setUpassword(rs.getString("upassword"));
                                        list.add(uinf);
                                    }
                                } catch (SQLException e) {
                                    e.printStackTrace();
                                }                                                            
                                return list;
                            }
                        });
        return list;
    }
    @Override
    public List serchByInfo(Object obj) {
        return null;
    }
    //权限管理——————查出所有的用户标识是否有权限
    public List serchUserByGroup() {
        String sql=" select distinct tb_user_inf.uid,uname,IFNULL(tb_user_battgroup_baojigroup_usr.baoji_group_id,0) as permit_id from tb_user_inf "
                + " LEFT JOIN  tb_user_battgroup_baojigroup_usr on tb_user_inf.uid=tb_user_battgroup_baojigroup_usr.uId "
                + " order by tb_user_inf.uid asc ";
        List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[] {}, new CallBack() {
            
            @Override
            public List getResults(ResultSet rs) {
                List list=new ArrayList();
                try {
                    while(rs.next()) {
                        User_inf u=new User_inf();
                        u.setUId(rs.getInt("uid"));
                        u.setUName(rs.getString("uname"));
                        u.setUNote(rs.getString("permit_id"));
                        list.add(u);
                    }
                } catch (SQLException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }
                return list;
            }
        });
        return list;
    }
    
    
    
}