querycanceltimeslidaction.java

MM7彩信对接网关示例

package com.rainbow.mms.datadigger;

import java.sql.CallableStatement;
import java.sql.Connection;
import java.sql.ResultSet;
import java.util.LinkedList;
import java.util.List;

import org.apache.log4j.Logger;
import org.hibernate.Session;
import org.hibernate.Transaction;
import org.hibernate.criterion.Restrictions;

import com.opensymphony.webwork.ServletActionContext;
import com.opensymphony.xwork.ActionContext;
import com.opensymphony.xwork.ActionSupport;
import com.rainbow.mms.common.MMSServiceCode;
import com.rainbow.mms.common.MmsGatewayInfo;
import com.rainbow.util.tools.HibernateUtil;
/**
 * 根据用户输入的参数,获得时间切片的统计数据,
 * 从表单里需要获得参数有:unformId,gateWayId,beginTime,endTime
 * 统计结果将以List的形式放在Session中的resultList对象里
 * 
 * @author Rainbow MMS Platform Group Leader -- TrWorks
 *
 */
public class QueryCancelTimeSlidAction extends ActionSupport {
	private static final long serialVersionUID = 1L;
	
	private Logger log = Logger.getLogger(QueryCancelTimeSlidAction.class);

	/**
	 * 根据用户输入的参数,获得产品的生命周期
	 */
	public String execute() throws Exception {
		
		// 取参数
		String unformIdString = ServletActionContext.getRequest().getParameter("serviceList");
		String gateWayIdString = ServletActionContext.getRequest().getParameter("gatewayList");
		String beginTime = ServletActionContext.getRequest().getParameter("beginTime");
		String endTime = ServletActionContext.getRequest().getParameter("endTime");
		
		// 参数校验
		if (unformIdString == null || gateWayIdString == null || 
			beginTime == null || endTime == null || 
			unformIdString.equalsIgnoreCase("") ||
			gateWayIdString.equalsIgnoreCase("") || 
			beginTime.equalsIgnoreCase("") ||
			endTime.equalsIgnoreCase("")){
			log.warn("QueryCancelTimeSlidAction Input Params Error!");
			return ERROR;
		}

		// 参数类型转换
		int uniformId = Integer.parseInt(unformIdString);
		int gateWayId = Integer.parseInt(gateWayIdString);
		
		
		String result = ERROR;
		List resultList = new LinkedList();
		
		// 调用存储过程 MMS_PSysStaticTimeSlid 取结果
		try {
			Session sess = HibernateUtil.currentSession();
			Transaction tx = sess.beginTransaction();
			Connection con = sess.connection();
			CallableStatement state = con.prepareCall("{call MMS_PSysStaticTimeSlid (?, ?, ?, ?)}");
			state.setInt(1, uniformId);
			state.setInt(2, gateWayId);
			state.setString(3, beginTime);
			state.setString(4, endTime);						

			ResultSet set = state.executeQuery();
			tx.commit();
			
			if (set.next()){
				ProductCancelTimeSlid data = new ProductCancelTimeSlid();
				data.setUniformId(uniformId);
				data.setGateWayId(gateWayId);
				data.setBeginTime(beginTime);
				data.setEndTime(endTime);
				data.setCancel1min(set.getInt(1));
				data.setCancel2min(set.getInt(2));
				data.setCancel3min(set.getInt(3));
				data.setCancel4min(set.getInt(4));
				data.setCancel5min(set.getInt(5));
				data.setCancel6min(set.getInt(6));
				data.setCancel7min(set.getInt(7));
				data.setCancel8min(set.getInt(8));
				data.setCancel9min(set.getInt(9));
				data.setCancel10min(set.getInt(10));
				data.setCancel11min(set.getInt(11));
				data.setCancel12min(set.getInt(12));
				data.setCancel13min(set.getInt(13));
				data.setCancel14min(set.getInt(14));
				data.setCancel15min(set.getInt(15));
				data.setCancel20min(set.getInt(16));
				data.setCancel30min(set.getInt(17));
				data.setCancel1hour(set.getInt(18));
				data.setCancel2hour(set.getInt(19));
				data.setCancel12hour(set.getInt(20));
				data.setCancel24hour(set.getInt(21));
				data.setCancel48hour(set.getInt(22));
				data.setCancel72hour(set.getInt(23));
				
				resultList.add(data);
			}		
			
			set.close();
			state.close();
			
			ActionContext.getContext().getSession().put("resultList", resultList);
			
			MmsGatewayInfo gwinfo = (MmsGatewayInfo)sess.load(MmsGatewayInfo.class, new Integer(gateWayIdString));
			MMSServiceCode codeinfo = (MMSServiceCode)sess.createCriteria(MMSServiceCode.class).add(
							Restrictions.eq("uniformID", new Integer(unformIdString))).add(
							Restrictions.eq("gateWayID", new Integer(gateWayIdString))).list().get(0);
			
			ActionContext.getContext().getSession().put("resultList", resultList);
			
			ServletActionContext.getRequest().setAttribute("unformId", unformIdString);
			ServletActionContext.getRequest().setAttribute("unformName", codeinfo.getServiceName());
			ServletActionContext.getRequest().setAttribute("gateWayId", gateWayIdString);
			ServletActionContext.getRequest().setAttribute("gateWayName", gwinfo.getGatewayName());
			ServletActionContext.getRequest().setAttribute("beginTime", beginTime);
			ServletActionContext.getRequest().setAttribute("endTime", endTime);
			
	        result = SUCCESS;

		} catch (Exception e) {
			e.printStackTrace();
			log.error(e);
			result = ERROR;
		}
		finally{
			HibernateUtil.closeSession();
		}
		
		return result;		
	}
}