JAVA WEB即时通信

package com.mcl.dao; import java.sql.ResultSet; import java.sql.SQLException; import java.text.SimpleDateFormat; import net.sf.json.JSONArray; import net.sf.json.JSONObject; import com.mcl.model.Friend; import com.mcl.model.Message; import com.mcl.model.User; import com.mcl.tools.ConnDB; public class UserDao { /** * 通过用户名来获取用户的id值 * @param loginname * @return id * @throws Exception */ public int getIdByLoginname(String loginname){ int id=0; ConnDB conn=new ConnDB(); String sql="select f_id from t_user where f_loginname='"+loginname+"'"; ResultSet rs=conn.executeQuery(sql); try{ while(rs.next()) { id=rs.getInt(1); } }catch (SQLException e) { e.printStackTrace();// TODO: handle exception } conn.close(); return id; } /** * 通过id来获取用户的昵称 * @param loginname * @return id * @throws Exception */ public String getNameById(int id){ ConnDB conn=new ConnDB(); String sql="select f_name from t_user where f_id='"+id+"'"; ResultSet rs=conn.executeQuery(sql); String name=""; try{ while(rs.next()) { name=rs.getString(1); } }catch (SQLException e) { e.printStackTrace();// TODO: handle exception } conn.close(); return name; } /** * 检查用户是否存在返回boolean类型，用于数据操作时检查数据库 * @param loginname * @return boolean result * @throws Exception */ public boolean isExist(String loginname){ boolean result=false; ConnDB conn=new ConnDB(); String sql="SELECT * FROM t_user where f_loginname='"+loginname+"'"; ResultSet rs=conn.executeQuery(sql); try{ if(rs.next()) { result=true; }else { result=false; //表示用户不存在 } }catch (SQLException e) { e.printStackTrace();// TODO: handle exception } conn.close(); return result; } /** * 检查用户名是否已经存在，用于注册时向页面响应 * @param loginname * @return * @throws Exception */ public String checkUser(String loginname){ String result=""; ConnDB conn=new ConnDB(); String sql="SELECT * FROM t_user where f_loginname='"+loginname+"'"; ResultSet rs=conn.executeQuery(sql); try{ if(rs.next()) { result="很抱歉【"+loginname+"】已被注册"; }else { result="1"; //表示用户没有注册 } }catch (SQLException e) { e.printStackTrace();// TODO: handle exception } conn.close(); return result; } /** * 对用户进行存储 * @param user * @return result * @throws Exception */ public String saveUser(User user){ String result=""; ConnDB conn=new ConnDB(); String sql="INSERT INTO t_user(f_id,f_name,f_loginname,f_password,f_question,f_answer,f_email) VALUES (t_user_seq.Nextval,'"+user.getF_name()+"','"+user.getF_loginName()+"','"+user.getF_password()+"','"+user.getF_question()+"','"+user.getF_answer()+"','"+user.getF_email()+"')"; int rt=conn.executeUpdate(sql); //执行更新 if(rt>0) { result="注册成功"; }else { result="注册失败"; } conn.close(); return result; } /** * 来更改密码 * @param user * @return 字符串来响应给页面 * @throws Exception */ public String changePwd(User user){ String result=""; ConnDB conn=new ConnDB(); UserDao dao=new UserDao(); String sql1="update t_user set f_password='"+user.getF_password()+"' where f_loginname='" +user.getF_loginName()+"' and f_question='"+user.getF_question()+"' and f_answer='"+user.getF_answer()+"'"; if(dao.isExist(user.getF_loginName())==false) //如果不存在该用户 { result="该用户名不存在!!"; }else { int rt=conn.executeUpdate(sql1); if(rt>0) { result="更新成功"; }else { result="更新失败"; } } conn.close(); return result; } /** * 通过用户名，密码进行登录 * @param user * @return 响应页面的字符串 * @throws Exception */ public String loginUser(User user){ String result=""; ConnDB conn1=new ConnDB(); ConnDB conn2=new ConnDB(); String sql="select f_password,f_state from t_user where f_loginname='"+user.getF_loginName()+"'"; //获取密码 String sql1="update t_user set f_state=1 where f_loginname='"+user.getF_loginName()+"'"; //更改状态 ResultSet rs=conn1.executeQuery(sql); try{ if(rs.next()) { String password=rs.getString("f_password"); if(user.getF_password().equals(password)) { if(rs.getInt("f_state")==0) { int rt=conn2.executeUpdate(sql1); if(rt>0) { result="登录"; }else { result="登录失败"; } result="正确"; }else{ result="该用户已登录！"; } }else { result="用户名或者密码错误"; } }else { result="没有此用户！"; } }catch (SQLException e) { e.printStackTrace();// TODO: handle exception } conn1.close(); System.out.println("-----------------------------------登录"); conn2.close(); return result; } /** * 通过用户名查询昵称 * @param loginname * @return name * @throws Exception */ public String getName(String loginname){ String name=""; ConnDB conn=new ConnDB(); String sql="select f_name from t_user where f_loginname='"+loginname+"'"; ResultSet rs=conn.executeQuery(sql); try{ while(rs.next()) { name=rs.getString(1); } }catch (SQLException e) { e.printStackTrace();// TODO: handle exception } conn.close(); return name; } /** * 当载入页面时查询好友以及消息信息存入到数json中 * @param user * @return JSONArray对象 * @throws Exception */ public JSONArray checkUser(Friend user){ ConnDB conn=new ConnDB(); int userid=user.getF_userID(); //获取用户的id值 JSONArray userArr=new JSONArray(); //Json数组 JSONObject userObj=new JSONObject(); String message=""; String sql="select b.f_id,b.f_name,b.f_state,b.f_loginname,(select count(*) from " + "t_message t where t.f_senderid=a.f_friendid and t.f_state=0) as f_count " + "from t_friend a,t_user b where a.f_friendid=b.f_id and a.f_userid="+userid; //查询friendId ResultSet rs1=conn.executeQuery(sql); try { while(rs1.next()) //遍历查询friendid { if(rs1.getInt("f_count")>0) { message="(有"+rs1.getInt("f_count")+"条未读消息)"; //获取几条未读消息 }else { message=""; } int state=rs1.getInt("f_state"); String name=rs1.getString("f_name");//获取昵称 String loginname=rs1.getString("f_loginname"); int friendid=rs1.getInt("f_id"); userObj.put("name", name); //放入json 对象中 userObj.put("state", state); userObj.put("message", message); userObj.put("loginname", loginname); userObj.put("id", friendid); userArr.add(userObj); //将json对象放任json数列中 } } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } conn.close(); return userArr; } /** * 进行注销 * @param user * @return result */ public String outLine(User user){ String result=""; ConnDB conn=new ConnDB(); String sql="update t_user set f_state=0 where f_loginname='"+user.getF_loginName()+"'"; //更改状态 System.out.println(sql); try{ int rt=conn.executeUpdate(sql); System.out.println(rt); if(rt>0) { result="退出成功，谢谢光临"; }else { result="错误~~~~"; } }catch (Exception e) { e.printStackTrace();// TODO: handle exception } conn.close(); System.out.println(result); return result; } /** * 添加好友时先进行查找是否存在该用户 * @param user * @return * @throws Exception */ public String SearchUser(User user){ String result=""; String sql1="select * from t_user where f_loginname='"+user.getF_loginName()+"'"; //查询是否存在要查找的用户 System.out.println(sql1); ConnDB