package blog;

import blog.*;
import java.sql.Connection;
import java.sql.PreparedStatement;

public class Op_msg  implements java.io.Serializable{

	String sqlStr="";
	Connection conn = null;
	PreparedStatement pstmt = null;

	//發表文章
	public String addmsg(javax.servlet.http.HttpServletRequest request,javax.servlet.http.HttpSession session)
		throws Exception {

		if(request.getParameter("PID")==null){
			return "缺少所屬主題信息";	
		}
		if(request.getParameter("boardID")==null){
			return "缺少所屬板塊信息";
		}
		if(session.getAttribute("userID")==null){
			return "用戶ID為空,請登陸";
		}
		
		if(session.getAttribute("userName")==null){
			return "用戶名為空,請登陸";
		}
		DataBase db = new DataBase();
		conn = db.getconn();
		if(Integer.parseInt(request.getParameter("PID"))!=0){
			sqlStr = "select replies from foruminfo where msgID = ?";
			pstmt = conn.prepareStatement(sqlStr);
			pstmt.setInt(1,Integer.parseInt(request.getParameter("PID")));
			java.sql.ResultSet rs = pstmt.executeQuery();
			if(rs.next()){
				int replies = rs.getInt("replies");
				rs.close();
				sqlStr = "update foruminfo set replies = ? where msgID = ?";
				pstmt = conn.prepareStatement(sqlStr);
				pstmt.setInt(1,replies+1);
				pstmt.setInt(2,Integer.parseInt(request.getParameter("PID")));
				pstmt.executeUpdate();
			}
			
		}
		sqlStr = "insert into foruminfo (PID,title,content,author,boardID,authorID,firstTime,authorIP,clicks,replies)values ("
		+"?,?,?,?,?,?,DATE_ADD(now(),Interval 1 year),?,0,0)";
		pstmt = conn.prepareStatement(sqlStr);
		pstmt.setInt(1,Integer.parseInt(request.getParameter("PID")));
		pstmt.setString(2,request.getParameter("title"));
		pstmt.setString(3,request.getParameter("content"));
		pstmt.setString(4,(String)session.getAttribute("userName"));
		pstmt.setInt(5,Integer.parseInt(request.getParameter("boardID")));
		
		pstmt.setInt(6,Integer.parseInt((String)session.getAttribute("userID")));
		pstmt.setString(7,request.getRemoteAddr());
		
    	pstmt.executeUpdate();
    	db.free();
    	return "ok";

	}
	
	//列出板塊內所有文章
	public java.util.ArrayList showmsg(javax.servlet.http.HttpServletRequest request)
		throws Exception{
		if(request.getParameter("boardID")==null){
				return null;
		}
		sqlStr = "select * from forumInfo where boardID =? and PID=0";
		java.util.ArrayList al = new java.util.ArrayList();
		DataBase db = new DataBase();
		conn = db.getconn();
		pstmt = conn.prepareStatement(sqlStr);
		pstmt.setInt(1,Integer.parseInt(request.getParameter("boardID")));
		java.sql.ResultSet rs = pstmt.executeQuery();
		while(rs.next()){
			ForumBean fb = new ForumBean();
			fb.fillAll(rs);
			al.add(fb);
		}
		db.free();
		return al;
	}
	
	//列出文章中所有的帖子
	public java.util.ArrayList showAticle(javax.servlet.http.HttpServletRequest request)
		throws Exception {
		if(request.getParameter("msgID")==null){
			return null;
		}
		

		sqlStr = "select clicks from foruminfo where msgID=?";
		java.util.ArrayList al = new java.util.ArrayList();		
		DataBase db = new DataBase();
		conn = db.getconn();
		pstmt = conn.prepareStatement(sqlStr);
		pstmt.setInt(1,Integer.parseInt(request.getParameter("msgID")));
		java.sql.ResultSet rs = pstmt.executeQuery();
		if(rs.next()){
			int clicks = rs.getInt("clicks");
			sqlStr = "update foruminfo set clicks= ? where msgID= ? ";
			pstmt = conn.prepareStatement(sqlStr);
			pstmt.setInt(1,clicks+1);
			pstmt.setInt(2,Integer.parseInt(request.getParameter("msgID")));
			
			pstmt.executeUpdate();
		}
		sqlStr = "select * from foruminfo where msgID= ? or PID = ?";
		pstmt = conn.prepareStatement(sqlStr);
		pstmt.setInt(1,Integer.parseInt(request.getParameter("msgID")));
		pstmt.setInt(2,Integer.parseInt(request.getParameter("msgID")));
		
		rs = pstmt.executeQuery();
		while(rs.next()){
			ForumBean fb = new ForumBean();
			fb.fillAll(rs);
			al.add(fb);
		}
				
		db.free();
		return al;
	}
		
}