usernews.java

动态网站管理发布系统

package com.ntsky.news;

import com.ntsky.common.*;
import com.ntsky.database.SQLDBOperator;
import com.ntsky.persistence.NEWSTable;

import java.io.UnsupportedEncodingException;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.Iterator;
import java.util.Vector;

public class UserNews {

	private SQLDBOperator sdbo;

	public UserNews() {
		sdbo = null;
	}

	public void insUserNews(int classId, int kindId, String headTitle,String content, String user, String newsFrom) {
		if (sdbo == null)sdbo = SQLDBOperator.getInstance("Connection");
		String strSql = "insert into news(classId,kindId,myOther,headTitle,content,newsFrom,author,top,newsTime,state,tag) values(?,?,0,?,?,?,?,0,?,0,0)";
		try {
			sdbo.prepareStatement(strSql);
			sdbo.setInt(1, classId);
			sdbo.setInt(2, kindId);
			sdbo.setString(3, CodeFilter.toHtml(headTitle));
			sdbo.setString(4, CodeFilter.toHtml(content));
			sdbo.setString(5, CodeFilter.toHtml(newsFrom));
			sdbo.setString(6, user);
			sdbo.setString(7, DateUtil.getNowDate());
			sdbo.executeUpdate();
			
		} catch (Exception e) {
			System.out.println("UserNews insUserNews() :" + e.getMessage());
			Debug.writeLog("UserNews insUserNews(), Exception Occured ! Info :" + e.getLocalizedMessage());
		} finally {
			sdbo.Close();
		}
		PageCache.getInstance().updateNewsItemToCache();
	}

	public void delUserNews(int newsId) {
		if (sdbo == null)sdbo = SQLDBOperator.getInstance("Connection");
		String strSql = "delete from news where newsId='" + newsId + "';";
		try {
			sdbo.executeUpdate(strSql);
			PageCache.getInstance().delNewsToCache(newsId);
		} catch (Exception e) {
			System.out.print("UserNews delUserNews() :" + e.getMessage());
			Debug.writeLog("UserNews delUserNews(), Exception Occured ! Info :" + e.getLocalizedMessage());
		} finally {
			sdbo.Close();
		}
	}

	public Iterator editUserNews(int newsId) {
		Vector vector = new Vector();
		if (sdbo == null)
			sdbo = SQLDBOperator.getInstance("Connection");
		String sql = "select * from news where newsId=?;";
		try {
			sdbo.prepareStatement(sql);
			sdbo.setInt(1, newsId);
			ResultSet rs = sdbo.executeQuery();

			while (rs.next()) {
				NEWSTable tableNews = new NEWSTable();
				tableNews.setClassId(rs.getInt("classId"));
				tableNews.setKindId(rs.getInt("kindId"));
				tableNews.setHeadTitle(CodeFilter.toUbbHtml(new String(rs.getString("headTitle").getBytes("iso-8859-1"), "gbk")));
				tableNews.setContent(CodeFilter.toUbbHtml(new String(rs.getString("content").getBytes("iso-8859-1"),"gbk")));
				tableNews.setNewsFrom(CodeFilter.toUbbHtml(new String(rs.getString("newsFrom").getBytes("iso-8859-1"),"gbk")));
				vector.add(tableNews);
			}
			rs.close();

		} catch (SQLException sqlE) {
			System.out.print("News editUserNews() " + sqlE.getMessage());
			Debug.writeLog("News editUserNews(), Exception Occured ! Info :" + sqlE.getLocalizedMessage());
		} catch (UnsupportedEncodingException nullE) {
			System.out.print("News editUserNews() " + nullE.getMessage());
			Debug.writeLog("News editUserNews(), Exception Occured ! Info :" + nullE.getLocalizedMessage());
		} finally {
			sdbo.Close();
		}
		return vector.iterator();
	}

	public void upUserNews(int classId, int kindId, String headTitle,String content, String newsFrom, int newsId) {
		if (sdbo == null)sdbo = SQLDBOperator.getInstance("Connection");
		String strSql = "update news set classId=?,kindId=?,headTitle=?,content=?,newsFrom=?,newsTime='" + DateUtil.getNowDate() + "' where newsId=?;";
		try {
			sdbo.prepareStatement(strSql);
			sdbo.setInt(1, classId);
			sdbo.setInt(2, kindId);
			sdbo.setString(3, CodeFilter.toHtml(headTitle));
			sdbo.setString(4, CodeFilter.toHtml(content));
			sdbo.setString(5, CodeFilter.toHtml(newsFrom));
			sdbo.setInt(6, newsId);
			sdbo.executeUpdate();
			
			PageCache.getInstance().updateNewsItemToCache();
		} catch (Exception e) {
			System.out.print("News upUserNews() " + e.getMessage());
			Debug.writeLog("News upUserNews(), Exception Occured ! Info :" + e.getLocalizedMessage());
		} finally {
			sdbo.Close();
		}
	}
}