querry_contribut_action.java

来自「JAVA 文章管理系统源码」· Java 代码 · 共 436 行

package com.haven.struts.Action;

import java.io.IOException;
import java.io.InputStream;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.List;
import java.util.Properties;

import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;

import org.apache.commons.lang.StringUtils;
import org.apache.struts.action.Action;
import org.apache.struts.action.ActionForm;
import org.apache.struts.action.ActionForward;
import org.apache.struts.action.ActionMapping;
import org.apache.struts.action.ActionMessage;
import org.apache.struts.action.ActionMessages;
import com.haven.sinopec.domain.Application;
import com.haven.struts.ActionForm.BlankForm;
import com.haven.struts.ActionForm.Query_ActionForm;
import com.haven.sinopec.domain.Contribution;

public class Querry_Contribut_Action extends Action {
    
	private void doValue(String zd[], String tj[], String zi[]) {
			for (int i = 0; i < zd.length; i++) {

					if ("like".equals(tj[i])) {
						zi[i] = " '%" + zi[i] + "%'";
					} else if ("in".equals(tj[i])) {
						String tmp[] = StringUtils.split(zi[i], ",");
						String tmpzi = " ";
						for (int j = 0; j < tmp.length; j++) {
							if (j == tmp.length - 1) {
								tmpzi = tmpzi + "'" + tmp[j] + "'";
							} else {
								tmpzi = tmpzi + "'" + tmp[j] + "',";
							}

						}
						zi[i] = " (" + tmpzi + ")";
					} else if ("between".equals(tj[i])) {
						String tmp[] = StringUtils.split(zi[i], ",");
						String tmpzi = " ";
						for (int j = 0; j < tmp.length; j++) {
							if (j == tmp.length - 1) {
								tmpzi = tmpzi + "" + tmp[j] + "";
							} else {
								tmpzi = tmpzi + "" + tmp[j] + " and ";
							}
						}
						zi[i] = tmpzi;

					} else {
						zi[i] = " '" + zi[i] + "'";
					}
				}

		}

	public ActionForward execute(
		ActionMapping mapping,
		ActionForm form,
		HttpServletRequest request,
		HttpServletResponse response)
		throws Exception {
		Connection con = null;
		Statement st = null;
		ResultSet rs = null;
		ResultSet rs1 = null;
		Statement st1 = null;
		Query_ActionForm QueryForm = (Query_ActionForm) form;
		ActionMessages errors = new ActionMessages();

			try {
		 
			String zd[] = QueryForm.getHzd();
			String tj[] = QueryForm.getHtj();
			String zi[] = QueryForm.getHzi();

			List Ry = new ArrayList();
			List sql = new ArrayList();

			String tmp_sql = "select * from contribution where 1 = 1";
			String tmp_sql1;

			/*
				for (int i = 0; i < zd.length; i++) {
					String szd = zd[i];
					String stj = tj[i];
					String szi = zi[i];

					if ("bh".equals(szd)) { //特情代号

						tmp_sql = tmp_sql + " and bh " + stj + szi;

					} else if ("dwbm".equals(szd)) { //线索编号

						tmp_sql = tmp_sql + " and dwbm " + stj + szi;

					} else if ("jzrq".equals(szd)) { //特情种类
						tmp_sql = tmp_sql + " and jzrq  " + stj + szi;

					} else if ("tbdw".equals(szd)) { //管理单位
						tmp_sql = tmp_sql + " and tbdw  " + stj + szi;

					} else if ("gsqc".equals(szd)) { //管理干部
						tmp_sql = tmp_sql + " and gsqc  " + stj + szi;

					} else if ("cym".equals(szd)) { //反映线索时间
						tmp_sql = tmp_sql + " and cym  " + stj + szi;

					} else if ("gszcdz".equals(szd)) { //情报种类
						tmp_sql = tmp_sql + " and gszcdz  " + stj + szi;

					} else if ("gscy".equals(szd)) { //涉案物品
						tmp_sql = tmp_sql + " and gscy  " + stj + szi;

					} else if ("zczj".equals(szd)) { //涉案人员
						tmp_sql = tmp_sql + " and zczj  " + stj + szi;

					} else if ("frdb".equals(szd)) { //案件编号
						tmp_sql = tmp_sql + " and frdb  " + stj + szi;

					} else if ("gsclsj".equals(szd)) { //作案手段
						tmp_sql = tmp_sql + " and gsclsj  " + stj + szi;

					} else if ("bgszd".equals(szd)) { //作案时间
						tmp_sql = tmp_sql + " and bgszd  " + stj + szi;

					} else if ("yb".equals(szd)) { //作案地区
						tmp_sql = tmp_sql + " and yb  " + stj + szi;

					} else if ("gbgc".equals(szd)) { //作案工具
						tmp_sql = tmp_sql + " and gbgc  " + stj + szi;

					} else if ("y_gbgc".equals(szd)) { //线索情况
						tmp_sql = tmp_sql + " and y_gbgc  " + stj + szi;

					} else if ("yyzzh".equals(szd)) { //查证结果
						tmp_sql = tmp_sql + " and yyzzh  " + stj + szi;

					} else if ("djzbm".equals(szd)) { //作案手段
					tmp_sql = tmp_sql + " and djzbm  " + stj + szi;

				    } else if ("ds_djzbm".equals(szd)) { //作案时间
					tmp_sql = tmp_sql + " and ds_djzbm  " + stj + szi;
 
				    } else if ("zzjgbm".equals(szd)) { //作案地区
					tmp_sql = tmp_sql + " and zzjgbm  " + stj + szi;

				    } else if ("txjyxkz".equals(szd)) { //作案工具
					tmp_sql = tmp_sql + " and txjyxkz  " + stj + szi;

				    } else if ("qyxz".equals(szd)) { //线索情况
					tmp_sql = tmp_sql + " and qyxz  " + stj + szi;

				    } else if ("xydj".equals(szd)) { //查证结果
					tmp_sql = tmp_sql + " and xydj  " + stj + szi;

				    }  
					else if ("hylb".equals(szd)) { //作案时间
					tmp_sql = tmp_sql + " and hylb  " + stj + szi;

					} else if ("zyyw".equals(szd)) { //作案地区
					tmp_sql = tmp_sql + " and zyyw  " + stj + szi;

					} else if ("qyqc".equals(szd)) { //作案工具
					tmp_sql = tmp_sql + " and qyqc  " + stj + szi;

					} else if ("xq".equals(szd)) { //线索情况
					tmp_sql = tmp_sql + " and xq  " + stj + szi;

					} else if ("zrk".equals(szd)) { //查证结果
				    tmp_sql = tmp_sql + " and zrk  " + stj + szi;

					} else if ("czrk".equals(szd)) { //作案手段
					tmp_sql = tmp_sql + " and czrk  " + stj + szi;

					} else if ("zmj".equals(szd)) { //作案时间
					tmp_sql = tmp_sql + " and zmj " + stj + szi;
 
					} else if ("zyqfw".equals(szd)) { //作案地区
					tmp_sql = tmp_sql + " and zyqfw  " + stj + szi;

					} else if ("SSDWBH".equals(szd)) { //作案地区
						tmp_sql = tmp_sql + " and ssdwbh  " + stj + szi;

					}else if ("zyq_czrk".equals(szd)) { //作案地区
						tmp_sql = tmp_sql + " and zyq_czrk  " + stj + szi;

					}else if ("jjzzl".equals(szd)) { //作案地区
						tmp_sql = tmp_sql + " and jjzzl  " + stj + szi;

					}else if ("jdp".equals(szd)) { //作案地区
						tmp_sql = tmp_sql + " and jdp  " + stj + szi;

					}else if ("zzl".equals(szd)) { //作案地区
						tmp_sql = tmp_sql + " and zzl  " + stj + szi;

					}else if ("rjgdp".equals(szd)) { //作案地区
						tmp_sql = tmp_sql + " and rjgdp  " + stj + szi;

					}else if ("csjggy".equals(szd)) { //作案地区
						tmp_sql = tmp_sql + " and csjggy  " + stj + szi;

					}else if ("csjgny".equals(szd)) { //作案地区
						tmp_sql = tmp_sql + " and csjgny  " + stj + szi;

					}else if ("csjgfwy".equals(szd)) { //作案地区
						tmp_sql = tmp_sql + " and csjgfwy  " + stj + szi;

					}else if ("csjglyy".equals(szd)) { //作案地区
						tmp_sql = tmp_sql + " and csjglyy  " + stj + szi;

					}else if ("csjgqt".equals(szd)) { //作案地区
						tmp_sql = tmp_sql + " and csjgqt  " + stj + szi;

					}else if ("csjgqt".equals(szd)) { //作案地区
						tmp_sql = tmp_sql + " and csjgqt  " + stj + szi;

					}else if ("gyyh".equals(szd)) { //作案地区
						tmp_sql = tmp_sql + " and gyyh  " + stj + szi;

					}else if ("zxyh".equals(szd)) { //作案地区
						tmp_sql = tmp_sql + " and zxyh  " + stj + szi;

					}else if ("gyxxyh".equals(szd)) { //作案地区
						tmp_sql = tmp_sql + " and gyxxyh  " + stj + szi;

					}else if ("gfsyyh".equals(szd)) { //作案地区
						tmp_sql = tmp_sql + " and gfsyyh  " + stj + szi;

					}else if ("sydxyh".equals(szd)) { //作案地区
						tmp_sql = tmp_sql + " and sydxyh  " + stj + szi;

					}else if ("syzxyh".equals(szd)) { //作案地区
						tmp_sql = tmp_sql + " and syzxyh  " + stj + szi;

					}else if ("syxxyh".equals(szd)) { //作案地区
						tmp_sql = tmp_sql + " and syxxyh  " + stj + szi;

					}else if ("yh".equals(szd)) { //作案地区
						tmp_sql = tmp_sql + " and yh  " + stj + szi;

					}else if ("czc".equals(szd)) { //作案地区
						tmp_sql = tmp_sql + " and czc  " + stj + szi;

					}else if ("zbc".equals(szd)) { //作案地区
						tmp_sql = tmp_sql + " and zbc  " + stj + szi;

					}else if ("gjc".equals(szd)) { //作案地区
						tmp_sql = tmp_sql + " and gjc  " + stj + szi;

					}else if ("jmyh".equals(szd)) { //作案地区
						tmp_sql = tmp_sql + " and jmyh  " + stj + szi;

					}else if ("zyq_yh".equals(szd)) { //作案地区
						tmp_sql = tmp_sql + " and zyq_yh  " + stj + szi;

					}else if ("gl".equals(szd)) { //作案地区
						tmp_sql = tmp_sql + " and gl  " + stj + szi;

					}else if ("ryl".equals(szd)) { //作案地区
						tmp_sql = tmp_sql + " and ryl  " + stj + szi;

					}else if ("trql".equals(szd)) { //作案地区
						tmp_sql = tmp_sql + " and trql  " + stj + szi;

					}else if ("qtrll".equals(szd)) { //作案地区
						tmp_sql = tmp_sql + " and qtrll  " + stj + szi;

					}else if ("zrkt".equals(szd)) { //作案地区
						tmp_sql = tmp_sql + " and zrkt  " + stj + szi;

					}else if ("qtqk".equals(szd)) { //作案地区
						tmp_sql = tmp_sql + " and qtqk  " + stj + szi;

					}else if ("bz".equals(szd)) { //作案地区
						tmp_sql = tmp_sql + " and bz  " + stj + szi;

					}else if ("jhtz".equals(szd)) { //作案地区
						tmp_sql = tmp_sql + " and jhtz  " + stj + szi;

					}else if ("tz".equals(szd)) { //作案地区
						tmp_sql = tmp_sql + " and tz  " + stj + szi;

					}else if ("wcsj".equals(szd)) { //作案地区
						tmp_sql = tmp_sql + " and wcsj  " + stj + szi;

					}else if ("mzjs".equals(szd)) { //作案地区
						tmp_sql = tmp_sql + " and mzjs  " + stj + szi;

					}else if ("tyz".equals(szd)) { //作案地区
						tmp_sql = tmp_sql + " and tyz  " + stj + szi;

					}else if ("zy_tyz".equals(szd)) { //作案地区
						tmp_sql = tmp_sql + " and zy_tyz  " + stj + szi;

					}else if ("dy_tyz".equals(szd)) { //作案地区
						tmp_sql = tmp_sql + " and dy_tyz  " + stj + szi;

					}else if ("csgw".equals(szd)) { //作案地区
						tmp_sql = tmp_sql + " and csgw  " + stj + szi;

					}else if ("csgw_gy".equals(szd)) { //作案地区
						tmp_sql = tmp_sql + " and csgw_gy  " + stj + szi;

					}else if ("csgw_zy".equals(szd)) { //作案地区
						tmp_sql = tmp_sql + " and csgw_zy  " + stj + szi;

					}else if ("csgw_dy".equals(szd)) { //作案地区
						tmp_sql = tmp_sql + " and csgw_dy  " + stj + szi;

					}else if ("zy".equals(szd)) { //作案地区
						tmp_sql = tmp_sql + " and zy  " + stj + szi;

					}else if ("cy".equals(szd)) { //作案地区
						tmp_sql = tmp_sql + " and cy  " + stj + szi;

					}else if ("qy".equals(szd)) { //作案地区
						tmp_sql = tmp_sql + " and qy  " + stj + szi;

					}else if ("m".equals(szd)) { //作案地区
						tmp_sql = tmp_sql + " and m  " + stj + szi;

					}else if ("lpg".equals(szd)) { //作案地区
						tmp_sql = tmp_sql + " and lpg  " + stj + szi;

					}else if ("lng".equals(szd)) { //作案地区
						tmp_sql = tmp_sql + " and lng  " + stj + szi;

					}else if ("trq".equals(szd)) { //作案地区
						tmp_sql = tmp_sql + " and trq  " + stj + szi;

					}else if ("qtxz".equals(szd)) { //作案地区
						tmp_sql = tmp_sql + " and qtxz  " + stj + szi;

					}else if ("jm".equals(szd)) { //作案地区
						tmp_sql = tmp_sql + " and jm  " + stj + szi;

					}else if ("gfsy".equals(szd)) { //作案地区
						tmp_sql = tmp_sql + " and gfsy  " + stj + szi;

					}else if ("cng".equals(szd)) { //作案地区
						tmp_sql = tmp_sql + " and cng  " + stj + szi;

					}else if ("trq_gy".equals(szd)) { //作案地区
						tmp_sql = tmp_sql + " and trq_gy  " + stj + szi;

					}else if ("dxgfsy".equals(szd)) { //作案地区
						tmp_sql = tmp_sql + " and dxgfsy  " + stj + szi;

					}else if ("jyxz_bz".equals(szd)) { //作案地区
						tmp_sql = tmp_sql + " and jyxz_bz  " + stj + szi;

					}else if ("xgsj".equals(szd)) { //作案地区
						tmp_sql = tmp_sql + " and xgsj  " + stj + szi;

					}else {

					tmp_sql = tmp_sql + "and " + szd + " " + stj + szi;

				    }

				}*/
				
			
			try {

				Properties props = new Properties();
				InputStream in =
					Thread
						.currentThread()
						.getContextClassLoader()
						.getResourceAsStream(
						"././././properties/database.properties");

			try {
					props.load(in);
				} catch (IOException e) {
					e.printStackTrace();
				}
				String URL = props.getProperty("url");
				String UserName = props.getProperty("username");
				String Password = props.getProperty("password");
				Class.forName("oracle.jdbc.driver.OracleDriver");
				con = DriverManager.getConnection(URL, UserName, Password);

				st = con.createStatement();
				rs = st.executeQuery(tmp_sql);
				 
				while (rs.next()) {
					Contribution company = new Contribution();
					company.setArticletype(rs.getString("articletype"));
					Ry.add(company);
				}
				
				request.getSession().setAttribute("ResultList", Ry);
				
			} catch (Exception ex) {
				ex.printStackTrace();
			}
			return mapping.findForward("success");
		} catch (Exception e) {
			e.printStackTrace();
			errors.add(
				ActionMessages.GLOBAL_MESSAGE,
				new ActionMessage("Action.error"));
			this.addMessages(request, errors);
			return mapping.findForward("error");
		} finally {
			try {
				if (rs != null) {
					rs.close();
				}
				if (st != null) {
					st.close();
				}

				if (con != null) {
					con.close();
				}
			} catch (Exception e) {
				e.printStackTrace();
				throw new RuntimeException(e.getMessage());
			}
		}

	}
}