datadiggerutil.java

MM7彩信对接网关示例

package com.rainbow.mms.datadigger;

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

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

import com.opensymphony.xwork.ActionContext;
import com.opensymphony.xwork.ActionSupport;
import com.rainbow.mms.common.MmsGatewayInfo;
import com.rainbow.util.tools.HibernateUtil;

public class DataDiggerUtil extends ActionSupport {
	private static final long serialVersionUID = 1L;

	private Logger log = Logger.getLogger(DataDiggerUtil.class);

	/**
	 * 根据用户输入的参数,获得产品的生命周期
	 */
	public String execute() throws Exception {

		List gatewayList = (List) ActionContext.getContext().getSession().get(
				"gatewayList");
		List provinfoList = (List) ActionContext.getContext().getSession().get(
				"provinfoList");
		String result = ERROR;

		try {
			Session sess = HibernateUtil.currentSession();

			gatewayList = sess.createCriteria(MmsGatewayInfo.class).add(
								Restrictions.eq("protocalType", "MM7")).list();
			
			ActionContext.getContext().getSession().put("gatewayList", gatewayList);

			if (provinfoList == null) {
				provinfoList = new LinkedList();
				ResultSet s = sess
						.connection()
						.prepareStatement(
								"select distinct(prov) from UT_COMM_MOBILE_SECTION group by prov")
						.executeQuery();
				List provNameList = new LinkedList();
				while (s.next()) {
					provNameList.add(s.getString(1));
				}
				s.close();

				for (int i = 0; i < provNameList.size(); i++) {
					PreparedStatement state = sess
							.connection()
							.prepareStatement(
									"select distinct(city) from UT_COMM_MOBILE_SECTION where prov = ?");
					state.setString(1, (String) provNameList.get(i));
					ResultSet s2 = state.executeQuery();
					List cityNameList = new LinkedList();
					while (s2.next()) {
						cityNameList.add(s2.getString(1));
					}

					ProvInfo info = new ProvInfo();
					info.setProvName((String) provNameList.get(i));
					info.setCitySet(cityNameList);
					provinfoList.add(info);

					s2.close();
					state.close();
				}
				
				ActionContext.getContext().getSession().put("provinfoList", provinfoList);
			}

			result = SUCCESS;

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

		return result;
	}

	public static void main(String[] args) {
		DataDiggerUtil u = new DataDiggerUtil();
		try {
			u.execute();
		} catch (Exception e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
	}
}