oa.rar_java小系统

package imp.dao; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; import java.util.ArrayList; import java.util.List; import temp.bean.TempMessage; import db.tools.SqlManager; import domain.Message; import domain.User; import base.dao.BaseAbstractInterfaceDaoAdapter; public class MessageDao extends BaseAbstractInterfaceDaoAdapter { /* *按照用户的id查找发给此用户所有消息并封装为Object数组返回 *参数 receiverid 接收消息的用户id * */ public List<Object[]> getAllMessageByReceiverId(Integer receiverId){ List<Object[]> messages = new ArrayList<Object[]>(0); String sql="select m.id,title,content,sendid,u.name,sendtime,status " + "from user u join message m on u.id=sendid where receiverid="+receiverId+""; PreparedStatement ps = SqlManager.openStatement(sql); ResultSet result = SqlManager.select(ps); try{ while(result.next()){ Object objs[] = new Object[7]; objs[0]=result.getInt(1); objs[1]=result.getString(2); objs[2]=result.getString(3); objs[3]=result.getInt(4); objs[4]=result.getString(5); objs[5]=result.getDate(6); objs[6]=result.getInt(7); messages.add(objs); } }catch(Exception ex){ex.printStackTrace();} finally{ SqlManager.closeStatement(result); } return messages; } /* * 按照id查找Message的详细内容，封装为临时对象返回 * 参数 id Message 对象id * */ @Override public Object find(Integer id) { System.out.println("----------"+id); //查询消息语句 String sql="select u.name ,title,content,sendtime,sendid " + "from user u join message m on u.id=m.sendid where m.id="+id+""; //更新为已读状态 String sql2="update message set status=1 where id="+id+""; TempMessage tempMessage=new TempMessage(); PreparedStatement ps = SqlManager.openStatement(sql); ResultSet result = SqlManager.select(ps); try{ if(result.next()){ tempMessage.setName(result.getString(1)); tempMessage.setTitle(result.getString(2)); tempMessage.setContent(result.getString(3)); tempMessage.setSendTime(result.getDate(4)); tempMessage.setSendId(result.getInt(5)); } // 标记此消息为已读 PreparedStatement ps2 = SqlManager.openStatement(sql2); SqlManager.update(ps2); }catch(Exception ex){ex.printStackTrace();} finally{ SqlManager.closeStatement(result); } return tempMessage; } /*保存回复消息的方法*/ public int save(Integer uid,Object e) { int info =0; Message temp =(Message)e; String sql = "insert into message values(null,'"+temp.getTitle()+"'," + "'"+temp.getContent()+"',"+uid+","+temp.getReceiverId()+"," + "sysdate(),0)"; info = SqlManager.update(SqlManager.openStatement(sql)); return info; } /*保存群发消息的方法*/ public int store(Message m,Object e) { int info = 0; String usersid[] = (String[])e;// 转换为字符串数组 Integer intUsersid[]=new Integer[usersid.length]; for(int i=0;i<usersid.length;i++){// 循环处理群发 System.out.println("循环执行"+(i+1)); intUsersid[i]=new Integer(usersid[i]); String sql="insert into message values(null,'"+m.getTitle()+"'," + "'"+m.getContent()+"',"+m.getSendId()+"," + ""+intUsersid[i]+",sysdate(),0)"; info+=SqlManager.update(SqlManager.openStatement(sql)); } return info; } /*执行设为已读或删除的方法 * 参数 flag 执行标记，"read" =设为已读 * "delete" = 删除； * ints 消息id数组 * */ public int doMessages(String flag, Integer[] ints) { // TODO Auto-generated method stub int info=0; //循环执行sql操作 for(int i=0;i<ints.length;i++){ if(flag.equals("read")){ info+=SqlManager.update(SqlManager. openStatement("update message set status=1 where id="+ints[i]+"")); }else if(flag.equals("delete")){ info+=SqlManager.update(SqlManager. openStatement("delete from message where id="+ints[i]+"")); } } return info; // 返回影响数据库的行数 } }