blacklistmanage.java

MM7彩信对接网关示例

/*
 * Created on 2005-11-4
 *
 * TODO To change the template for this generated file go to
 * Window - Preferences - Java - Code Style - Code Templates
 */
package com.rainbow.mms.queryservice;

import java.util.List;

import org.hibernate.Criteria;
import org.hibernate.Session;
import org.hibernate.Transaction;
import org.hibernate.criterion.Restrictions;

import com.rainbow.mms.common.CMCCMM7DeliverMsg;
import com.rainbow.util.tools.HibernateUtil;
import com.opensymphony.webwork.ServletActionContext;
import com.opensymphony.xwork.Action;
import com.opensymphony.xwork.ActionContext;
import com.rainbow.mms.common.BlacklistUser;

/**
 * @author Administrator
 *
 * TODO To change the template for this generated type comment go to
 * Window - Preferences - Java - Code Style - Code Templates
 */
public class BlacklistManage implements Action {

	/* (non-Javadoc)
	 * @see com.opensymphony.xwork.Action#execute()
	 */
	public String execute() throws Exception {
		// TODO Auto-generated method stub
		String mobile = ServletActionContext.getRequest().getParameter("mobile");
		String action = ServletActionContext.getRequest().getParameter("action");
		if (mobile == null||action ==null){
			return ERROR;
		}
		action = action.trim();
		BlacklistUser bu = new BlacklistUser();
		bu.setMobile(mobile);
		String result = ERROR;
		String returnResult = "";

		try{
			Session sess = HibernateUtil.currentSession();
			Transaction tx = sess.beginTransaction();
			System.out.println("执行的命令是："+action);
			if(action.equalsIgnoreCase("delete")){
				sess.delete(bu);
				returnResult = "删除成功！";
				
			}
			else if(action.equalsIgnoreCase("new")){
				sess.save(bu);
				returnResult = "添加成功！";
				
			}
			else{
				Criteria cr = sess.createCriteria(BlacklistUser.class);
				if(cr.add(Restrictions.eq("mobile", mobile)).list().size() == 0){
					returnResult = "该用户不在黑名单中！";
				}
					
				else{
					returnResult = "该用户在黑名单中！";
				}
					
			}
			System.out.println(returnResult);
			ActionContext.getContext().getSession().put("result",returnResult);
			tx.commit();
			result = SUCCESS;
		}
		catch(Exception e){
			e.printStackTrace();
			result = ERROR;
		}
		finally{
			HibernateUtil.closeSession();
		}
		
		return result;
	}

}