queryuserregister.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.sql.CallableStatement;
import java.sql.Connection;
import java.sql.ResultSet;
import java.util.LinkedList;
import java.util.List;

import org.hibernate.Session;
import org.hibernate.Transaction;

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

/**
 * @author Administrator
 *
 * TODO To change the template for this generated type comment go to
 * Window - Preferences - Java - Code Style - Code Templates
 */
public class QueryUserRegister 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");
		if (mobile == null){
			return ERROR;
		}
		
		String result = ERROR;
		List resultList = new LinkedList();
		
		try{
			Session sess = HibernateUtil.currentSession();
			Transaction tx1 = sess.beginTransaction();
			Connection con = sess.connection();
			CallableStatement state = con.prepareCall("{call MMS_PSysQueryUserRegister (?)}");
			state.setString("@cMobile", mobile);
			ResultSet set = state.executeQuery();
			tx1.commit();
			
			while (set.next()){
				UserRegisterRecord usr = new UserRegisterRecord();
				usr.setGatewayName(set.getString("tcGateWayName"));
				usr.setGatewayId(set.getInt("tnGateWayID"));
				usr.setAtProv(set.getString("tcProv"));
				usr.setAtCity(set.getString("tcCity"));
				usr.setMobile(set.getString("tcMobile"));
				usr.setUniformId(set.getInt("tnUniformId"));
				usr.setUniformName(set.getString("tcUniformName"));
				usr.setRegisterBy(set.getInt("tnRegisterBy"));
				usr.setRegisterTime(set.getTimestamp("ttRegisterTime"));
				usr.setLastUpdateTime(set.getTimestamp("ttLastUpdateTime"));
				usr.setMobileType(set.getInt("tnMobileType"));
				usr.setStatus(set.getInt("tnStatus"));
				usr.setStatusName(set.getString("tcStatusName"));
				usr.setDisorderUrl(set.getString("tcDisorderUrl"));
				usr.setSpId(set.getString("tcSpId"));
				usr.setServiceCode(set.getString("tcServiceCode"));
				
				resultList.add(usr);
			}
			ActionContext.getContext().getSession().put("resultListRegisterRecord", resultList);
			result = SUCCESS;
		}
		catch(Exception e){
			e.printStackTrace();
			result = ERROR;
		}
		finally{
			HibernateUtil.closeSession();
		}
		
		return result;
	}

}