upimagebean.java

电信的网厅的整站代码

package com.doone.fj1w.fjmgr.config;


import com.doone.data.DacClient;
import com.doone.data.DataRow;
import com.doone.data.DataTable;
import com.doone.fj1w.fj1w.login.app.CommitDate;
import com.doone.util.FileLogger;
import com.doone.fj1w.common.*;

public class UpImageBean {
 	public UpImageBean() {
	}
 
	/**
	 * 找出产品的业务介绍
	 * @param dbClient
	 * @return
	 */
	  public  DataTable getHotIntroList(String upCode) {
	        DataTable ret = null;
	        try {
	                  
	            StringBuffer sql = new StringBuffer();
	            sql.append(" select c1.content_id,");
	            sql.append(" c1.create_time,");
	            sql.append(" c1.title,");
	            sql.append(" c2.boardname,");
	            sql.append(" c1.exist_attch,");
	            sql.append(" c1.extract_sign,");
	            sql.append(" c1.tip_order,");
	            sql.append(" c1.click_count,");
	            sql.append(" c2.infoid");
	            sql.append(" from tf_content c1,");
	            sql.append(" (select NAME BoardName,");
	            sql.append(" substr(rootid, 2, instr(rootid, 'a', 2) - 2) rootid,infoid");
	            sql.append(" from (select t.NAME,t.infoid,");
	            sql.append(" t.CODE,");
	            sql.append(" SYS_CONNECT_BY_PATH(t.INFOID, 'a') || 'a' rootid");
	            sql.append(" from vf_object t");
	            sql.append(" connect by prior t.PARENTINFOID = t.INFOID");
	            sql.append(" start with exists");
	            sql.append(" (select 1");
	            sql.append(" from tf_content c");
	            sql.append(" where t.INFOID = c.board_id");
	            sql.append(" and c.contenttype = '02'))");  // contenttype为02的表示已经通过审核的。
	            sql.append(" where length(code) = 12");
	            sql.append(" and code like ?) c2");
	            sql.append(" where c1.board_id = c2.rootid");
	            sql.append(" and c1.delete_sign = 'E' ");
	            sql.append(" and c1.contenttype = '02'");  // contenttype为02的表示已经通过审核的。
	            sql.append(" order by c1.tip_order DESC, c1.last_reply_time DESC, c1.content_id DESC");
	            Object[] ap = new Object[1];
	            ap[0] = upCode + "%";

	            DacClient db = new DacClient();
	            ret = db.executeQuery(sql.toString(), ap);
	        } catch (Exception ex) {
	            FileLogger.getLogger().warn(ex.getMessage(), ex);
	        }

	        return ret;
	    }
	  
	  
	  /**
		 * 找出图片及链接信息
		 * @param dbClient
		 * @return
		 */
		  public  DataTable getContent(String sBoardId) {
			        DataTable ret = null;
		        try {
		            StringBuffer sql = new StringBuffer();
		            sql.append(" select t.title, t.CONTENT, t.CONTENT_id, f.FILE_CONTENT ,f.file_name,f.ATTCH_ID");
		            sql.append(" from tf_content t, tf_attchment f ");
		            sql.append(" where t.content_id = f.content_id ");
		            sql.append(" and (t.CONTENTTYPE = '03' or t.CONTENTTYPE = '04')");
		            sql.append(" and t.BOARD_ID ="+sBoardId);
		            DacClient db = new DacClient();
		            ret = db.executeQuery(sql.toString());
		        
		        } catch (Exception ex) {
		            FileLogger.getLogger().warn(ex.getMessage(), ex);
		        }

		        return ret;
		    }
		  /**
			 * 找出文件及链接信息
			 * @param dbClient
			 * @return
			 */
			  public  DataTable getTextContent(String sBoardId) {
				        DataTable ret = null;
			        try {
			            StringBuffer sql = new StringBuffer();
			            sql.append(" select t.title, t.CONTENT, t.CONTENT_id,t.CONTENTTYPE");
			            sql.append(" from tf_content t ");
			            sql.append(" where  ");
			            sql.append(" (t.CONTENTTYPE = '03' or t.CONTENTTYPE = '04') and t.DELETE_SIGN = 'E' ");
			            sql.append(" and t.BOARD_ID ="+sBoardId+" order by TIP_ORDER desc");
			            DacClient db = new DacClient();
			            System.out.println(sql);
			            ret = db.executeQuery(sql.toString());
			        
			        } catch (Exception ex) {
			            FileLogger.getLogger().warn(ex.getMessage(), ex);
			        }

			        return ret;
			    }  
			  /**
				 * 找出文件及链接信息
				 * @param dbClient
				 * @return
				 */
				  public  int getTextContentCount(String sBoardId) {
					        DataTable ret = null;
					        int count1=0;
				        try {
				            StringBuffer sql = new StringBuffer();
				            sql.append(" select count(t.CONTENT_id) count1");
				            sql.append(" from tf_content t ");
				            sql.append(" where  ");
				            sql.append(" (t.CONTENTTYPE = '03' or t.CONTENTTYPE = '04') and t.DELETE_SIGN = 'E' ");
				            sql.append(" and t.BOARD_ID ="+sBoardId+" order by TIP_ORDER desc");
				            DacClient db = new DacClient();
				            ret = db.executeQuery(sql.toString());
				            if ((ret!=null)&&(ret.getRows().getCount()!=0)){
				            	count1= Integer.parseInt(ret.getRow(0).getString("count1"));
				            }
				        } catch (Exception ex) {
				            FileLogger.getLogger().warn(ex.getMessage(), ex);
				        }

				        return count1;
				    }  
			  /**
				 * 找出文件及链接信息
				 * @param dbClient
				 * @return
				 */
				  public  void delContent(long lBoardId) {
					        DataTable ret = null;
				        try {
				        	String sql1 = "delete tf_attchment where content_id in ( select content_id from tf_content where BOARD_ID =?)"; 
				            String sql2 = " delete   tf_content t where t.BOARD_ID = ?";
				            DacClient db = new DacClient();
				            DacClient db1 = new DacClient();
				            Object[] ap = new Object[1];
				            ap[0] = new Long(lBoardId);
				            db.getStringFromSqlQuery(sql1.toString(), ap);
				            db1.getStringFromSqlQuery(sql2.toString(), ap);
				            db.executeUpdate(sql1,1000,ap);
				            db1.executeUpdate(sql2,1000,ap);
				        } catch (Exception ex) {
				            FileLogger.getLogger().warn(ex.getMessage(), ex);
				        }
				    }  
				  
				  /**
					 * 排序
					 * @param dbClient
					 * @return
					 */
					  public  void sortContent(String sContentId) {
						        DataTable ret = null;
					        try {
					        	String sql1 = "update tf_content set TIP_ORDER=TIP_ORDER+1 where content_id =?"; 
					            DacClient db = new DacClient();
					            Object[] ap = new Object[1];
					            ap[0] = sContentId;
					            db.getStringFromSqlQuery(sql1.toString(), ap);
					            db.executeUpdate(sql1,1000,ap);
					        } catch (Exception ex) {
					            FileLogger.getLogger().warn(ex.getMessage(), ex);
					        }
					    } 
		  /**
			 * 找出链接的业务介绍信息
			 * @param dbClient
			 * @return
			 */
			  public  String getBoardName(String sLINK) {
			        DataTable ret = null;
			        String boardName="";
			        try {
			                  
			            StringBuffer sql = new StringBuffer();
			            sql.append(" SELECT TITLE from tf_content where content_id="+sLINK);
			         	DacClient db = new DacClient();
			            ret = db.executeQuery(sql.toString());
			            if ((ret!=null)&&(ret.getRows().getCount()!=0)){
			            	boardName= ret.getRow(0).getString("TITLE");
			            }
			        } catch (Exception ex) {
			            FileLogger.getLogger().warn(ex.getMessage(), ex);
			        }
			        return boardName;
			    }
			  
		  
			  public  boolean is_int(String s){
				    int i;
				    s.trim();
				    if(s.length()==0)s="0";
				    for(i=0;i<s.length();i++)if("0123456789-".indexOf(s.substring(i,i+1))<0)return(false);
				    if(s.substring(1).indexOf("-")>=0)return false;
				    return true;
				  }
          
			  /**
				 * 找出菜单的信息
				 * @param dbClient
				 * @return
				 */
				  public  String getPurviewName(String sPURVIEWID) {
				        DataTable ret = null;
				        DataTable ret1 = null;
				        String boardName="",purviewName="",sName="";
				        try {
				            StringBuffer sql = new StringBuffer();
				            StringBuffer sql1 = new StringBuffer();
				            sql.append("select NAME from tf_purview where PURVIEWID= ");
				            sql.append(" (  select UPPURVIEWID from tf_purview where PURVIEWID="+sPURVIEWID+" and rownum=1) and rownum=1 ");
				            sql1.append(" select NAME from tf_purview where PURVIEWID="+sPURVIEWID+" and rownum=1");
				         	DacClient db = new DacClient();
				            ret = db.executeQuery(sql.toString());
				            if ((ret!=null)&&(ret.getRows().getCount()!=0)){
				            	boardName=  ret.getRow(0).getString("NAME");
				            }
				            ret1 = db.executeQuery(sql1.toString());
				            if ((ret1!=null)&&(ret1.getRows().getCount()!=0)){
				            	purviewName=  ret1.getRow(0).getString("NAME");
				            }
				            sName = "[" + boardName + "]" + purviewName;
				        } catch (Exception ex) {
				            FileLogger.getLogger().warn(ex.getMessage(), ex);
				        }
				        return sName;
				    }
				  /**
					 * 找出取最新动态+优惠资讯的NAME
					 * @param dbClient
					 * @return
					 */
					  public  String getContentName(String sContentId) {
					        DataTable ret = null;
					        String sName="";
					        try {
					            StringBuffer sql = new StringBuffer();
					            sql.append(" select t.title, t.CONTENT_id ");
					            sql.append(" from tf_content t ");
					            sql.append(" where  ");
					            sql.append(" t.delete_sign = 'E' AND ");
					            sql.append(" t.up_content_id = 0 ");
					            sql.append(" AND t.CONTENTTYPE='02' and  t.content_id =?");  
					            Object[] aParam = new Object[1];
					            aParam[0] = new Long(sContentId);
					            DacClient db = new DacClient();
					            ret = db.executeQuery(sql.toString(), aParam);
					            if ((ret!=null) &&(ret.getRows().getCount()!=0))
					            {sName=ret.getRow(0).getString("TITLE");}
					        } catch (Exception ex) {
					            FileLogger.getLogger().warn(ex.getMessage(), ex);
					        }
					        return sName;
					    }
				  
}