webmessageinfo.java

java阿里巴巴代码

package com.saas.biz.webmessageMgr;

import java.util.ArrayList;

import com.saas.biz.commen.commMethodMgr;
import com.saas.biz.dao.repositoryDAO.RepositoryExt;
import com.saas.biz.dao.webmessageDAO.WebmessageDAO;
import com.saas.biz.dao.webmessageDAO.WebmessageExt;
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 WebmessageInfo {

	Dbtable tradeQuery;

	Logger log;

	Buffers inBuffer;

	Buffers outBuffer;

	ArrayList queryResult = new ArrayList();

	public WebmessageInfo()
		{
			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;
		}
	//增加反馈交流信息 add by sjp  date:2007-06-05
	public void addWebMessageInfo(Buffers inbuffer) 
		{
			log.LOG_INFO("进入addWebMessageInfo方法...");
			this.outBuffer = inbuffer;
			WebmessageDAO webmessagedao = new WebmessageDAO();
			webmessagedao.setAccept_user_id(inbuffer.getString("USER_ID"));
			webmessagedao.setUser_id(inbuffer.getString("SESSION_USER_ID"));
			webmessagedao.setCust_id(inbuffer.getString("SESSION_CUST_ID"));
			webmessagedao.setSend_date(inbuffer.getString("SEND_DATE"));
			webmessagedao.setTitle(inbuffer.getString("TITLE"));
			webmessagedao.setContent(inbuffer.getString("CONTENT"));
			int iResult=-1 ;
			try
				{  	
					iResult=addWebMessageInfo(webmessagedao);
				}
			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("退出addWebMessageInfo方法...");
		}
	public int addWebMessageInfo(WebmessageDAO webmessagedao) throws SaasApplicationException 
	{
			commMethodMgr comm = new commMethodMgr();
			WebmessageExt webmessageExt = new WebmessageExt();
			String gen_id = comm.GenTradeId();
			webmessageExt.setParam(":VTRADE_ID", gen_id);
			webmessageExt.setParam(":VACCEPT_USER_ID",webmessagedao.getAccept_user_id());
			webmessageExt.setParam(":VCUST_ID", webmessagedao.getCust_id());
			webmessageExt.setParam(":VUSER_ID", webmessagedao.getUser_id());
			webmessageExt.setParam(":VTITLE", webmessagedao.getTitle());
			webmessageExt.setParam(":VCONTENT", webmessagedao.getContent());
			webmessageExt.setParam(":VSEND_DATE", webmessagedao.getSend_date());
			webmessageExt.setParam(":VDELAY_TAG", "0");
			webmessageExt.setParam(":VREAD_TAG", "0");
			webmessageExt.setParam(":VRSRV_STR1", "");
			webmessageExt.setParam(":VRSRV_STR2", "");
			webmessageExt.setParam(":VRSRV_STR3", "");
			webmessageExt.setParam(":VRSRV_STR6", "");
			webmessageExt.setParam(":VRSRV_STR7", "");
			webmessageExt.setParam(":VRSRV_STR8", "");
			webmessageExt.setParam(":VRSRV_STR9", "");
			webmessageExt.setParam(":VRSRV_STR10", "");
			webmessageExt.setParam(":VRSRV_NUM4", "");
			webmessageExt.setParam(":VRSRV_NUM5", "");
			webmessageExt.setParam(":VREMARK", "");
			tradeQuery.executeBy(webmessageExt.insBy("INS_BY_ALL"));			
			return 0;
	}
	//收取信息 add by sjp  date:2007-06-05
	public void genUserinformation(Buffers inbuffer) 
		{
			log.LOG_INFO("进入genUserinformation方法...");
			this.outBuffer = inbuffer;
			String  user_id =inbuffer.getString("SESSION_USER_ID");
			String  query_param = inbuffer.getString("QUERY_PARAM");
			try 
			{
				if(query_param.equals(""))
				this.queryResult = genUserinformation(user_id);
				else this.queryResult = searchMessage(query_param,user_id);
			} 
			catch (SaasApplicationException e)
			{
				log.LOG_INFO(e.getMessage());

			}
			log.LOG_INFO("退出genUserinformation方法...");
		}
	public ArrayList genUserinformation(String user_id) throws SaasApplicationException 
	{
		ArrayList itemsList = new ArrayList();
		WebmessageExt webmessageExt = new WebmessageExt();
		webmessageExt.setParam(":VACCEPT_USER_ID",user_id);
		itemsList = webmessageExt.selByList("SEL_BY_USER");	 
		return itemsList;
	}
	//收取单条信息 add by sjp  date:2007-06-05
	public void genOneinformation(Buffers inbuffer) 
		{
			log.LOG_INFO("进入genOneinformation方法...");
			this.outBuffer = inbuffer;
			String  trade_id =inbuffer.getString("TRADE_ID");
			try 
			{
				this.queryResult = genOneinformation(trade_id);
			} 
			catch (SaasApplicationException e)
			{
				log.LOG_INFO(e.getMessage());

			}
			log.LOG_INFO("退出genOneinformation方法...");
		}
	public ArrayList genOneinformation(String trade_id) throws SaasApplicationException 
	{
		ArrayList itemsList = new ArrayList();
		WebmessageExt webmessageExt = new WebmessageExt();
		webmessageExt.setParam(":VTRADE_ID",trade_id);
		itemsList = webmessageExt.selByList("SEL_BY_ONE");	 
		return itemsList;
	}
	//阅读信息并且回复 add by sjp  date:2007-06-05
	public void readinfo(Buffers inbuffer)
		{
			log.LOG_INFO("进入readinfo方法...");
			this.outBuffer = inbuffer;
			this.inBuffer = inbuffer;
			int iResult = -1;
			//String trade_id = inbuffer.getString("TRADE_ID");
			WebmessageDAO webmessagedao = new WebmessageDAO();
			webmessagedao.setTrade_id(inbuffer.getString("TRADE_ID"));
			webmessagedao.setAccept_user_id(inbuffer.getString("USER_ID"));
			webmessagedao.setUser_id(inbuffer.getString("SESSION_USER_ID"));
			webmessagedao.setCust_id(inbuffer.getString("SESSION_CUST_ID"));
			webmessagedao.setSend_date(inbuffer.getString("RESEND_DATE"));
			webmessagedao.setTitle(inbuffer.getString("RETITLE"));
			webmessagedao.setContent(inbuffer.getString("RECONTENT"));
			try
			{                                               
				iResult = readinfo(webmessagedao);
			} 
			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("退出readinfo方法...");
		}
	public int readinfo(WebmessageDAO webmessagedao) throws SaasApplicationException
	{	//修改阅读标志
		WebmessageExt webmessageExt = new WebmessageExt();
		commMethodMgr comm = new commMethodMgr();
		WebmessageExt webmessageExt2 = new WebmessageExt();
		webmessageExt.setParam(":VTRADE_ID",webmessagedao.getTrade_id()); 
		webmessageExt.setParam(":VREAD_TAG", "0");
        tradeQuery.executeBy(webmessageExt.insBy("READ_BY_ONE"));
        //增加回复记录
        String gen_id = comm.GenTradeId();
        webmessageExt2.setParam(":VTRADE_ID", gen_id);
        webmessageExt2.setParam(":VACCEPT_USER_ID",webmessagedao.getAccept_user_id());
        webmessageExt2.setParam(":VCUST_ID", webmessagedao.getCust_id());
        webmessageExt2.setParam(":VUSER_ID", webmessagedao.getUser_id());
        webmessageExt2.setParam(":VTITLE", webmessagedao.getTitle());
        webmessageExt2.setParam(":VCONTENT", webmessagedao.getContent());
        webmessageExt2.setParam(":VSEND_DATE", webmessagedao.getSend_date());
        webmessageExt2.setParam(":VDELAY_TAG", "0");
        webmessageExt2.setParam(":VREAD_TAG", "0");
        webmessageExt2.setParam(":VRSRV_STR1", "");
        webmessageExt2.setParam(":VRSRV_STR2", "");
        webmessageExt2.setParam(":VRSRV_STR3", "");
        webmessageExt2.setParam(":VRSRV_STR6", "");
        webmessageExt2.setParam(":VRSRV_STR7", "");
        webmessageExt2.setParam(":VRSRV_STR8", "");
        webmessageExt2.setParam(":VRSRV_STR9", "");
        webmessageExt2.setParam(":VRSRV_STR10", "");
        webmessageExt2.setParam(":VRSRV_NUM4", "");
        webmessageExt2.setParam(":VRSRV_NUM5", "");
        webmessageExt2.setParam(":VREMARK", "");
		tradeQuery.executeBy(webmessageExt2.insBy("INS_BY_ALL"));
        return 0; 
	}
	/**
	 * add  by sjp
	 * @param title
	 * @param cust_id
	 * @return
	 * @throws SaasApplicationException
	 */
	public ArrayList searchMessage(String title,String  cust_id) throws SaasApplicationException 
	{
		
		ArrayList itemsList = new ArrayList();
		WebmessageExt webmessageExt = new WebmessageExt();
		webmessageExt.setParam(":VTITLE","%"+title+"%");
		webmessageExt.setParam(":VACCEPT_USER_ID",cust_id);
		itemsList = webmessageExt.selByList("SEL_BY_SEARCH");	 
		return itemsList;
	}
	
}