leavewordsinfo.java

java阿里巴巴代码

package com.saas.biz.leavewordsMgr;

import java.util.ArrayList;
import java.util.HashMap;
import java.util.Iterator;

import com.saas.biz.commen.commMethodMgr;
import com.saas.biz.dao.leavewordsDAO.LeavewordsDAO;
import com.saas.biz.dao.leavewordsDAO.LeavewordsExt;
import com.saas.biz.dao.newsDAO.NewsExt;
import com.saas.sys.buffer.Buffers;
import com.saas.sys.dbm.Dbtable;
import com.saas.sys.exp.SaasApplicationException;
import com.saas.sys.log.Logger;

public class LeavewordsInfo 
{
		Dbtable tradeQuery;
	
		Logger log;
	
		Buffers inBuffer;
	
		Buffers outBuffer;
	
		ArrayList queryResult = new ArrayList();

		public LeavewordsInfo()
		{
			log = new Logger(this);
			tradeQuery = new Dbtable();
		}

		public void setTradeQuery(Dbtable tradeQuery)
		{
			this.tradeQuery = tradeQuery;
		}

		public Dbtable getTradeQuery()
		{
			return this.tradeQuery;
		}

		public void setOutBuffer(Buffers outBuffer)
		{
			this.outBuffer = outBuffer;
		}

		public Buffers getOutBuffer()
		{
			return this.outBuffer;
		}

		public ArrayList getQueryResult()
		{
			return this.queryResult;
		}

		public void setQueryResult(ArrayList queryResult)
		{
			this.queryResult = queryResult;
		}
		
	//查找单条留言
		public void genOneleavewords(Buffers inbuffer)
		{
			log.LOG_INFO("进入genOneleavewords方法...");
			this.outBuffer = inbuffer;
			this.inBuffer = inbuffer;
			String trade_id ="";
			trade_id = inbuffer.getString("TRADE_ID");
			try
			{
				 this.queryResult = genOneleavewords(trade_id);
			} 
			catch (SaasApplicationException e)
			{
					log.LOG_INFO(e.getMessage());
			}
			log.LOG_INFO("退出genOneleavewords方法...");
		}
		
		public ArrayList genOneleavewords(String  trade_id) throws SaasApplicationException
		{		
				LeavewordsExt leavewordsExt = new LeavewordsExt();
				leavewordsExt.setParam(":VTRADE_ID",trade_id);		
				return leavewordsExt.selByList("SEL_BY_PK");
		}
	
	/* purpose: add leaveWords
	 * author: caiwch
	 * date:2008.6.26
	 */
		public void addleavewords( Buffers inbuffer )
		{
			this.outBuffer = inbuffer;
			this.inBuffer = inbuffer;
			
			String root_id = inbuffer.getString( "ROOT_ID" );
			String trade_id = inbuffer.getString( "TRADE_ID" );
			String title = inbuffer.getString( "TITLE" );
			String content = inbuffer.getString( "CONTENT" );
			String word_type = inbuffer.getString( "WORD_TYPE" );
			String cust_id = inbuffer.getString( "CUST_ID" );
			String user_id = inbuffer.getString( "USER_ID" );
			String user_name = inbuffer.getString( "USER_NAME" );
			String phone = inbuffer.getString( "PHONE" );
			String email = inbuffer.getString( "EMAIL" );
			String word_status = inbuffer.getString( "WORD_STATUS" );
			int iResult = -1;
			
			try
			{
					LeavewordsDAO leavewordsdao = new LeavewordsDAO();
					
					leavewordsdao.setTrade_id( trade_id );
					leavewordsdao.setRoot_id( root_id );
					leavewordsdao.setTitle( title );
					leavewordsdao.setContent( content );
					leavewordsdao.setWord_type( word_type );
					leavewordsdao.setCust_id( cust_id );
					leavewordsdao.setUser_id( user_id );
					leavewordsdao.setUser_name( user_name );
					leavewordsdao.setPhone( phone );
					leavewordsdao.setEmail( email );
					leavewordsdao.setWord_status( word_status );
					
					iResult = addleavewords( leavewordsdao );
			}
			catch ( SaasApplicationException e )
			{				
				log.LOG_INFO(e.getMessage());
			}
			if (iResult != 0) 
			{
				this.outBuffer.setInt( "RESULT_CODE", -1 );
				this.outBuffer.setString( "RESULT_INFO", "业务处理失败！" );
			}
			else
			{
				this.outBuffer.setInt( "RESULT_CODE", 0 );
				this.outBuffer.setString( "RESULT_INFO", "业务处理成功！" );
			}
			log.LOG_INFO( "退出addleavewords方法..." );
		}
		
		public int addleavewords(LeavewordsDAO leavewordsdao) throws SaasApplicationException
		{		
				LeavewordsExt leavewordsExt = new LeavewordsExt();
				
				leavewordsExt.setParam( ":VTRADE_ID",leavewordsdao.getTrade_id() );
				leavewordsExt.setParam( ":VROOT_ID",leavewordsdao.getRoot_id() );
				leavewordsExt.setParam( ":VTITLE",leavewordsdao.getTitle() );
				leavewordsExt.setParam( ":VCONTENT",leavewordsdao.getContent() );
				leavewordsExt.setParam( ":VWORD_TYPE",leavewordsdao.getWord_type() );
				leavewordsExt.setParam( ":VCUST_ID",leavewordsdao.getCust_id() );
				leavewordsExt.setParam( ":VUSER_ID",leavewordsdao.getUser_id() );
				leavewordsExt.setParam( ":VUSER_NAME",leavewordsdao.getUser_name() );
				leavewordsExt.setParam( ":VPHONE",leavewordsdao.getPhone() );
				leavewordsExt.setParam( ":VEMAIL",leavewordsdao.getEmail() );
				leavewordsExt.setParam( ":VWORD_STATUS",leavewordsdao.getWord_status() );
				
				tradeQuery.executeBy( leavewordsExt.insBy( "INS_BY_ALL" ) );		
			return  0;
			
		}
		
		
		//显示留言
		public void genLeavewords( Buffers inbuffer )
		{
			log.LOG_INFO( "进入genLeavewords方法..." );
			this.outBuffer = inbuffer;
			String cust_id = inbuffer.getString( "SESSION_CUST_ID" );
			try
			{
				this.queryResult = genLeavewords( cust_id );
			} 
			catch ( SaasApplicationException e )
			{
				log.LOG_INFO( e.getMessage() );
			}
			log.LOG_INFO( "退出genLeavewords方法..." );
		}
		public ArrayList genLeavewords( String strCustId ) throws SaasApplicationException
		{
			ArrayList WordsList = new ArrayList();
			LeavewordsExt leavewordsExt = new LeavewordsExt();
			leavewordsExt.setParam( ":VCUST_ID", strCustId );
			WordsList = leavewordsExt.selByList( "SEL_BY_ROOT_ID" );
			return WordsList;
		}
		//留言回复
		public void anLeavewords( Buffers inbuffer )
		{
			log.LOG_INFO("进入anLeavewords方法...");
			this.outBuffer = inbuffer;
			String trade_id = inbuffer.getString( "TRADE_ID" );
			log.LOG_INFO( "前面trade_id........." + trade_id );
			String rsrv_str3 = inbuffer.getString( "RSRV_STR3" );
			int iResult = -1;
			try
			{
					iResult = anLeavewords( trade_id,rsrv_str3 );
				
			} 
			catch ( SaasApplicationException e )
			{				
					log.LOG_INFO( e.getMessage() );
			}
			if ( iResult != 0 ) 
			{
				this.outBuffer.setInt( "RESULT_CODE", -1 );
				this.outBuffer.setString( "RESULT_INFO", "业务处理失败！" );
			} 
			else
			{
				this.outBuffer.setInt( "RESULT_CODE", 0 );
				this.outBuffer.setString( "RESULT_INFO", "业务处理成功！" );
			}
			log.LOG_INFO( "退出anLeavewords方法..." );
		}
		public int anLeavewords( String strTradeId,String strRsrvStr3 ) throws SaasApplicationException
		{			
				LeavewordsExt leavewordsExt = new LeavewordsExt();
				leavewordsExt.setParam( ":VTRADE_ID",strTradeId );
				leavewordsExt.setParam( ":VRSRV_STR3",strRsrvStr3 );
				log.LOG_INFO( "后面trade_id........." + strTradeId );
				tradeQuery.executeBy( leavewordsExt.insBy( "AN_BY_LIUYAN" ) );		
				return  0;		
		}
		public void delLeavewords( Buffers inbuffer )
		{
			log.LOG_INFO( "进入delLeavewords方法..." );
			this.outBuffer = inbuffer;
			String trade_id =inbuffer.getString( "TRADE_ID" );
			int iResult = -1;
			
			try
			{
					iResult=delLeavewords(trade_id);
				
			}
			catch (SaasApplicationException e)
			{				
					log.LOG_INFO(e.getMessage());
			}
			if (iResult != 0)
			{
				this.outBuffer.setInt("RESULT_CODE", -1);
				this.outBuffer.setString("RESULT_INFO", "业务处理失败！");
			} 
			else 
			{
				this.outBuffer.setInt("RESULT_CODE", 0);
				this.outBuffer.setString("RESULT_INFO", "业务处理成功！");
			}
			log.LOG_INFO("退出delLeavewords方法...");
		}
		
		public int delLeavewords( String strTradeId ) throws SaasApplicationException
		{			
			LeavewordsExt leavewordsExt = new LeavewordsExt();
			leavewordsExt.setParam( ":VTRADE_ID",strTradeId );
			tradeQuery.executeBy( leavewordsExt.insBy( "DEL_BY_LIUYAN" ) );		
			return  0;		
		}
		
		//留言分页查询(收件箱)
		public ArrayList getLeavelListBySend( int iStart, String cust_id ) throws SaasApplicationException
		{
				iStart = iStart * 30;

				ArrayList leaveList = new ArrayList();
				LeavewordsExt leavewordsExt = new LeavewordsExt();
				leavewordsExt.setParam( ":VCUST_ID", cust_id );
				leaveList = leavewordsExt.selByList( "SEL_BY_ROOT_ID", iStart, 30 );			
				return leaveList;
		}
		//留言分页统计(收件箱)
		public int getLeaveNumberBySend( String cust_id ) throws SaasApplicationException
		{
		  ArrayList leaveList = new ArrayList();
			LeavewordsExt leavewordsExt = new LeavewordsExt();
			leavewordsExt.setParam( ":VCUST_ID",cust_id );
			leaveList = leavewordsExt.selByList( "SEL_BY_ROOT_ID" );			
			if( leaveList != null )
			{
				return leaveList.size();
			}	 
			else 
			{
				return 0;
			}
		}	   
		//我发出的留言(发件箱)
		public ArrayList getLeavelListByMy( int iStart, String user_name ) throws SaasApplicationException
		{
				iStart = iStart * 30;

				ArrayList leaveList = new ArrayList();
				LeavewordsExt leavewordsExt = new LeavewordsExt();
				leavewordsExt.setParam( ":VUSER_NAME", user_name );
				leaveList = leavewordsExt.selByList( "SEL_LEAVEL_MY", iStart, 30 );			
				return leaveList;
		}
		//我发出的留言(发件箱)
		public int getLeaveNumberByMy( String user_name ) throws SaasApplicationException
		{
		    ArrayList leaveList = new ArrayList();
			LeavewordsExt leavewordsExt = new LeavewordsExt();
			leavewordsExt.setParam( ":VUSER_NAME", user_name );
			leaveList = leavewordsExt.selByList( "SEL_LEAVEL_MY" );			
			if( leaveList != null )
			{
				return leaveList.size();
			}	 
			else 
			{
				return 0;
			}
		}	   
		//查找单条留言
		public ArrayList getLeaveByTradeId( String trade_id ) throws SaasApplicationException
		{
		    ArrayList leaveList = new ArrayList();
			  LeavewordsExt leavewordsExt = new LeavewordsExt();
			  leavewordsExt.setParam( ":VTRADE_ID", trade_id );
			  leaveList = leavewordsExt.selByList( "SEL_BY_RADE_ID" );			
			 return leaveList;
		}	    
		 
		public void updateStatus( Buffers inbuffer )
		{
			log.LOG_INFO( "进入delLeavewords方法..." );
			this.outBuffer = inbuffer;
			String trade_id =inbuffer.getString( "TRADE_ID" );
			String word_status = inbuffer.getString( "WORD_STATUS" );
			int iResult = -1;
			
			try
			{
					iResult=updateStatus( trade_id, word_status );
				
			}
			catch (SaasApplicationException e)
			{				
					log.LOG_INFO(e.getMessage());
			}
			if (iResult != 0)
			{
				this.outBuffer.setInt("RESULT_CODE", -1);
				this.outBuffer.setString("RESULT_INFO", "业务处理失败！");
			} 
			else 
			{
				this.outBuffer.setInt("RESULT_CODE", 0);
				this.outBuffer.setString("RESULT_INFO", "业务处理成功！");
			}
			log.LOG_INFO("退出delLeavewords方法...");
		}
		
		public int updateStatus( String trade_id,String word_status ) throws SaasApplicationException
		{
			LeavewordsExt leavewordsExt = new LeavewordsExt();
			leavewordsExt.setParam( ":VTRADE_ID",trade_id );
		  leavewordsExt.setParam( ":VWORD_STATUS",word_status );
			tradeQuery.executeBy( leavewordsExt.insBy( "UPDATE_BY_RADE_ID" ) );
			
			return 0;
		}
		
}