news.java

强大的新闻接收史实就知道

package popten.web;
			/****************************************
			*  news_title  POPTEN			*
			*  @author: 边缘孤客			*
			*  Company: http://www.popten.com	*
			*  Copyright: Copyright (c) 2002-10-1	*
			*  @version 1.0 beta			*
			****************************************/
import popten.db.DBConnect;
import popten.util.*;
import java.io.*;
import java.sql.*;
import java.util.*;
import javax.servlet.http.*;

public class News{

private String news_id,cata0_id,cata1_id,cata2_id,cata0_name,cata1_name,cata2_name,news_title,conten,sour,dat,coun,author,imgsrc,img,hot;
public String getnews_id() { return news_id;}
public String getcata0_id() { return cata0_id;}
public String getcata1_id() { return cata1_id;}
public String getcata2_id() { return cata2_id;}
public String getcata0_name() { return cata0_name;}
public String getcata1_name() { return cata1_name;}
public String getcata2_name() { return cata2_name;}
public String getnews_title() { return news_title;}
public String getconten() { return conten;}
public String getsour() { return sour;}
public String getimgsrc() { return imgsrc;}
public String getdat() { return dat;}
public String getimg() { return img;}
public String gethot() { return hot;}
public String getcoun() { return coun;}
public String getauthor() { return author;}
public void setnews_id(String news_id) { this.news_id = news_id; }
public void setcata0_id(String cata0_id) { this.cata0_id = cata0_id; }
public void setcata1_id(String cata1_id) { this.cata1_id = cata1_id; }
public void setcata2_id(String cata2_id) { this.cata2_id = cata2_id; }
public void setcata0_name(String cata0_name) { this.cata0_name = cata0_name; }
public void setcata1_name(String cata1_name) { this.cata1_name = cata1_name; }
public void setcata2_name(String cata2_name) { this.cata2_name = cata2_name; }
public void setnews_title(String news_title) { this.news_title = news_title; }
public void setconten(String conten) { this.conten = conten; }
public void setsour(String sour) { this.sour = sour; }
public void setimgsrc(String imgsrc) { this.imgsrc = imgsrc; }
public void setdat(String dat) { this.dat = dat; }
public void setimg(String img) { this.img = img; }
public void sethot(String hot) { this.hot = hot; }
public void setcoun(String coun) { this.coun = coun; }
public void setauthor(String author) { this.author = author; }
	public News(){}
		/**********************
		*     添加新资料      *
		**********************/
		public static void addNews(HttpServletRequest request) throws Exception {
			boolean foundErr = false;
			String errMsg="";
			String news_title = ParamUtils.getString(request,"news_title","");
			int news_id = ParamUtils.getInt(request,"news_id",0);
			int cata2_id = ParamUtils.getInt(request,"cata2_id",0);
			int cata1_id = ParamUtils.getInt(request,"cata1_id",0);
			int cata0_id = ParamUtils.getInt(request,"cata0_id",0);
			String sour = ParamUtils.getString(request,"sour","");
			String conten = ParamUtils.getString(request,"conten","");
			int hot = ParamUtils.getInt(request,"hot",0);
			int author = ParamUtils.getInt(request,"author",0);
			int img = ParamUtils.getInt(request,"img",0);
			//String dat=GetDate.getStringDate();
			DBConnect dbc = new DBConnect();
			ResultSet rs;
			if(news_title.equals("") || news_title==null){
				errMsg = errMsg + "□ 您没有输入标题！<br>□ 五秒钟后会自动返回上一页。<br><meta HTTP-EQUIV=REFRESH CONTENT='5; URL=javascript:history.go(-1)'>";
				foundErr = true;
			}
			if(conten.equals("") || conten==null){
				errMsg = errMsg + "□ 您没有输入内容！<br>□ 五秒钟后会自动返回上一页。<br><meta HTTP-EQUIV=REFRESH CONTENT='5; URL=javascript:history.go(-1)'>";
				foundErr = true;
			}
			if(cata0_id<=0){
				errMsg = errMsg + "□ 您没选择一级目录！<br>□ 五秒钟后会自动返回上一页。<br><meta HTTP-EQUIV=REFRESH CONTENT='5; URL=javascript:history.go(-1)'>";
				foundErr = true;
			}
			if(cata1_id<=0){
				errMsg = errMsg + "□ 您没选择二级目录！<br>□ 五秒钟后会自动返回上一页。<br><meta HTTP-EQUIV=REFRESH CONTENT='5; URL=javascript:history.go(-1)'>";
				foundErr = true;
			}
			if(cata2_id<=0){
				errMsg = errMsg + "□ 您没选择三级目录！<br>□ 五秒钟后会自动返回上一页。<br><meta HTTP-EQUIV=REFRESH CONTENT='5; URL=javascript:history.go(-1)'>";
				foundErr = true;
			}
			if(!foundErr){
				dbc.prepareStatement("Select * from news where news_title=?");
				dbc.setBytes(1,news_title.getBytes("GBK"));
				rs=dbc.executeQuery();
				if(rs.next()){
					rs.close();
					errMsg = errMsg + "□ 您输入的标题已经存在！<br>□ 五秒钟后会自动返回上一页。<br><meta HTTP-EQUIV=REFRESH CONTENT='5; URL=javascript:history.go(-1)'>";
					foundErr = true;
					}
			}
			if(!foundErr){
				dbc.prepareStatement("Select * from news where news_id=?");
	        		dbc.setInt(1,news_id);
	       			 rs=dbc.executeQuery();
	        		if(!rs.next()){
					dbc.prepareStatement("INSERT INTO news (cata0_id,cata1_id,cata2_id,news_title,conten,sour,dat,img,hot,author) VALUES (?,?,?,?,?,?,Now(),?,?,?)");
					dbc.setInt(1,cata0_id);
					dbc.setInt(2,cata1_id);
					dbc.setInt(3,cata2_id);
					dbc.setBytes(4,news_title.getBytes("GBK"));
					dbc.setBytes(5,conten.getBytes("GBK"));
					dbc.setBytes(6,sour.getBytes("GBK"));
					dbc.setInt(7,img);
					dbc.setInt(8,hot);
					dbc.setInt(9,author);
					dbc.executeUpdate();
					dbc.prepareStatement("UPDATE admin SET news_coun=news_coun+1 WHERE user_id=?");
					dbc.setInt(1,author);
					dbc.executeUpdate();
					dbc.prepareStatement("UPDATE cata2 SET coun=coun+1 WHERE cata2_id=?");
					dbc.setInt(1,cata2_id);
					dbc.executeUpdate();
					dbc.prepareStatement("UPDATE cata1 SET coun=coun+1 WHERE cata1_id=?");
					dbc.setInt(1,cata1_id);
					dbc.executeUpdate();
					dbc.prepareStatement("UPDATE cata0 SET coun=coun+1 WHERE cata0_id=?");
					dbc.setInt(1,cata0_id);
					dbc.executeUpdate();
					dbc.close();
				}
				else{
					dbc.prepareStatement("update news set cata0_id=?,cata1_id=?,cata2_id=?,news_title=?,conten=?,sour=?,dat=Now(),img=?,hot=?,author=? where news_id=?");
					dbc.setInt(1,cata0_id);
					dbc.setInt(2,cata1_id);
					dbc.setInt(3,cata2_id);
					dbc.setBytes(4,news_title.getBytes("GBK"));
					dbc.setBytes(5,conten.getBytes("GBK"));
					dbc.setBytes(6,sour.getBytes("GBK"));
					dbc.setInt(7,img);
					dbc.setInt(8,hot);
					dbc.setInt(9,author);
					dbc.setInt(10,news_id);
					dbc.executeUpdate();
					dbc.prepareStatement("UPDATE admin SET news_coun=news_coun+1 WHERE user_id=?");
					dbc.setInt(1,author);
					dbc.executeUpdate();
					dbc.prepareStatement("UPDATE cata2 SET coun=coun+1 WHERE cata2_id=?");
					dbc.setInt(1,cata2_id);
					dbc.executeUpdate();
					dbc.prepareStatement("UPDATE cata1 SET coun=coun+1 WHERE cata1_id=?");
					dbc.setInt(1,cata1_id);
					dbc.executeUpdate();
					dbc.prepareStatement("UPDATE cata0 SET coun=coun+1 WHERE cata0_id=?");
					dbc.setInt(1,cata0_id);
					dbc.executeUpdate();
					dbc.close();
				}
			}
			if(foundErr) throw new Exception(errMsg);
			}
		/**********************
		*     修改资料        *
		**********************/
		public static void editNews(HttpServletRequest request) throws Exception {
			boolean foundErr = false;
			String errMsg="";
			String news_title = ParamUtils.getString(request,"news_title","");
			String sour = ParamUtils.getString(request,"sour","");
			String conten = ParamUtils.getString(request,"conten","");
			int hot = ParamUtils.getInt(request,"hot",0);
			int img = ParamUtils.getInt(request,"img",0);
			int news_id = ParamUtils.getInt(request,"news_id",0);
			int cata2_id = ParamUtils.getInt(request,"cata2_id",0);
			int cata1_id = ParamUtils.getInt(request,"cata1_id",0);
			int cata0_id = ParamUtils.getInt(request,"cata0_id",0);
			int ocata2_id = ParamUtils.getInt(request,"ocata2_id",0);
			int ocata1_id = ParamUtils.getInt(request,"ocata1_id",0);
			int ocata0_id = ParamUtils.getInt(request,"ocata0_id",0);
			DBConnect dbc = new DBConnect();
			if(news_title.equals("") || news_title==null){
				errMsg = errMsg + "□ 您没有输入标题！<br>□ 五秒钟后会自动返回上一页。<br><meta HTTP-EQUIV=REFRESH CONTENT='5; URL=javascript:history.go(-1)'>";
				foundErr = true;
			}
			if(conten.equals("") || conten==null){
				errMsg = errMsg + "□ 您没有输入内容！<br>□ 五秒钟后会自动返回上一页。<br><meta HTTP-EQUIV=REFRESH CONTENT='5; URL=javascript:history.go(-1)'>";
				foundErr = true;
			}
			if(news_id<=0){
				errMsg = errMsg + "□ 您没有从正常途径进入本页！<br>□ 五秒钟后会自动返回上一页。<br><meta HTTP-EQUIV=REFRESH CONTENT='5; URL=javascript:history.go(-1)'>";
				foundErr = true;

			}
			if(!foundErr){
				dbc.prepareStatement("UPDATE news set cata0_id=?,cata1_id=?,cata2_id=?,news_title=?,conten=?,sour=?,dat=Now(),img=?,hot=? where news_id=?");
				dbc.setInt(1,cata0_id);
				dbc.setInt(2,cata1_id);
				dbc.setInt(3,cata2_id);
				dbc.setBytes(4,news_title.getBytes("GBK"));
				dbc.setBytes(5,conten.getBytes("GBK"));
				dbc.setBytes(6,sour.getBytes("GBK"));
				dbc.setInt(7,img);
				dbc.setInt(8,hot);
				dbc.setInt(9,news_id);
				dbc.executeUpdate();
				dbc.prepareStatement("UPDATE cata2 SET coun=coun+1 WHERE cata2_id=?");
				dbc.setInt(1,cata2_id);
				dbc.executeUpdate();
				dbc.prepareStatement("UPDATE cata1 SET coun=coun+1 WHERE cata1_id=?");
				dbc.setInt(1,cata1_id);
				dbc.executeUpdate();
				dbc.prepareStatement("UPDATE cata0 SET coun=coun+1 WHERE cata0_id=?");
				dbc.setInt(1,cata0_id);
				dbc.executeUpdate();
				dbc.prepareStatement("UPDATE cata2 SET coun=coun-1 WHERE cata2_id=?");
				dbc.setInt(1,ocata2_id);
				dbc.executeUpdate();
				dbc.prepareStatement("UPDATE cata1 SET coun=coun-1 WHERE cata1_id=?");
				dbc.setInt(1,ocata1_id);
				dbc.executeUpdate();
				dbc.prepareStatement("UPDATE cata0 SET coun=coun-1 WHERE cata0_id=?");
				dbc.setInt(1,ocata0_id);
				dbc.executeUpdate();
				dbc.close();
			}
			if(foundErr) throw new Exception(errMsg);
			}
		/************************
		*	读出指定资料	*
		************************/
		public News loadNews(HttpServletRequest request){
			DBConnect dbc = null;
			ResultSet rs;
			int news_id = ParamUtils.getInt(request,"news_id",0);
			News news = new News();
			ICata icata=new ICata();
			try{
				dbc  = new DBConnect();
				dbc.prepareStatement("UPDATE news set coun=coun+1 where news_id=?");
				dbc.setInt(1,news_id);
				dbc.executeUpdate();
				dbc.prepareStatement("select * from news where news_id=?");
				dbc.setInt(1,news_id);
				rs = dbc.executeQuery();
				if(rs.next()){
					ICata cata_name=icata.loadCataName(rs.getString("cata0_id"),rs.getString("cata1_id"),rs.getString("cata2_id"));
					news.setnews_id(rs.getString("news_id"));
					news.setcata0_id(rs.getString("cata0_id"));
					news.setcata0_name(cata_name.getcata0_name());
					news.setcata1_id(rs.getString("cata1_id"));
					news.setcata1_name(cata_name.getcata1_name());
					news.setcata2_id(rs.getString("cata2_id"));
					news.setcata2_name(cata_name.getcata2_name());
					news.setnews_title(rs.getString("news_title"));
					news.setconten(rs.getString("conten"));
					news.setsour(rs.getString("sour"));
					news.setcoun(rs.getString("coun"));
					news.setauthor(rs.getString("author"));
					news.setdat(rs.getString("dat"));
					news.setimg(rs.getString("img"));
					news.sethot(rs.getString("hot"));
				}

			  }
			catch(Exception e){
				System.err.println(e);
			  }
			finally{
				try{
					dbc.close();
				}
				catch(Exception e){
					e.printStackTrace();
				}
			  }
			return news;
			}
		/************************
		*	读出所有资料	*
		************************/
		public Vector loadAll(String str){
			DBConnect dbc = null;
			ResultSet rs;
			Vector newsVector = new Vector();
			try{
				dbc  = new DBConnect();
				dbc.prepareStatement("select * from news ORDER BY ? desc");
				dbc.setBytes(1,str.getBytes("GBK"));
				rs = dbc.executeQuery();
				while(rs.next()){
					News news = new News();
					news.setnews_id(rs.getString("news_id"));
					news.setcata0_id(rs.getString("cata0_id"));
					news.setcata1_id(rs.getString("cata1_id"));
					news.setcata2_id(rs.getString("cata2_id"));
					news.setnews_title(rs.getString("news_title"));
					news.setdat(rs.getString("dat"));
					news.setcoun(rs.getString("coun"));
					news.setauthor(rs.getString("author"));
					newsVector.add(news);
				}
			  }
			catch(Exception e){
				System.err.println(e);
			  }
			finally{
				try{
					dbc.close();
				}
				catch(Exception e){
					e.printStackTrace();
				}
			  }
			return newsVector;
			}
		/**************************
		* 	删除资料	  *
		**************************/
		public static void delNews(HttpServletRequest request) throws Exception {
			boolean foundErr = false;
			String errMsg="";
			int news_id = ParamUtils.getInt(request,"news_id",0);
			int cata2_id = ParamUtils.getInt(request,"cata2_id",0);
			int cata1_id = ParamUtils.getInt(request,"cata1_id",0);
			int cata0_id = ParamUtils.getInt(request,"cata0_id",0);
			if(news_id<=0){
				errMsg = errMsg + "□ 您没有输入序号!<br>□ 五秒钟后会自动返回上一页。<br><meta HTTP-EQUIV=REFRESH CONTENT='5; URL=javascript:history.go(-1)'>";
				foundErr = true;
			}
			if(!foundErr){
				DBConnect dbc = new DBConnect();
				dbc.prepareStatement("delete from news WHERE news_id=?");
				dbc.setInt(1,news_id);
				dbc.executeUpdate();
				//dbc.prepareStatement("alter table news drop news_id");
				//dbc.executeUpdate();
				//dbc.prepareStatement("alter table admin add news_id TINYINT auto_increment primary key");
				//dbc.executeUpdate();
				dbc.prepareStatement("UPDATE cata2 SET coun=coun-1 WHERE cata2_id=?");
				dbc.setInt(1,cata2_id);
				dbc.executeUpdate();
				dbc.prepareStatement("UPDATE cata1 SET coun=coun-1 WHERE cata1_id=?");
				dbc.setInt(1,cata1_id);
				dbc.executeUpdate();
				dbc.prepareStatement("UPDATE cata0 SET coun=coun-1 WHERE cata0_id=?");
				dbc.setInt(1,cata0_id);
				dbc.executeUpdate();
				dbc.close();
			}
			if(foundErr) throw new Exception(errMsg);
			}
		/************************
		*	搜索资料		*
		************************/
		public Vector searchNews(String keyword,String scope,int cata0_id,String arr){
			Vector newsVector = new Vector();
			DBConnect dbc = null;
			ResultSet rs;
			try{
				dbc  = new DBConnect();
				if(scope.equals("title") && cata0_id<1){
					dbc.prepareStatement("select * from news where news_title like ? order by ? desc");
					dbc.setBytes(1,("%"+keyword+"%").getBytes("GBK"));
					dbc.setBytes(2,arr.getBytes("GBK"));
				}
				else if(scope.equals("centen") && cata0_id<1){