cdss/src/main/java/com/diagbot/util/TZDBConn1.java

package com.diagbot.util;

import com.diagbot.biz.push.entity.Item;
import com.diagbot.biz.push.entity.Lis;
import com.diagbot.biz.push.entity.Pacs;
import com.diagbot.vo.Drug;
import com.google.common.collect.Lists;
import org.apache.commons.lang3.StringUtils;

import java.sql.*;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.ResourceBundle;
import java.util.regex.Pattern;

public class TZDBConn1 {
	private static final String DRIVER = getValue("jdbc.driverClassName1");
    private static final String URL = getValue("jdbc.url1");
    private static final String USERNAME = getValue("jdbc.username1");
    private static final String PASSWORD = getValue("jdbc.password1");

	public static final Long HOSPITAL_ID=Long.valueOf("35");//1:长兴，2：邵逸夫，3：台州市立医院

    private static Connection connection = null;
    private static PreparedStatement sta = null;
	private static ResultSet rs = null;

	/**
     * 读取属性文件中的信息
     *
     * @param key
     * @return
     */
    private static String getValue(String key) {
        // 资源包绑定
        ResourceBundle bundle = ResourceBundle.getBundle("jdbc");
        return bundle.getString(key);
    }

    /**
	 * 加载驱动程序
	 */
	static {
		try {
			Class.forName(DRIVER);
		} catch (ClassNotFoundException e) {
			e.printStackTrace();
		}
	}

	/**
	 * @return 连接对象
	 */
	public Connection getConnection() {
		try {
			connection = DriverManager.getConnection(URL,USERNAME,PASSWORD);
		} catch (SQLException e) {
			e.printStackTrace();
		}
		return connection;
	}

	/**
	 * @param sql sql语句
	 * @param obj 参数
	 * @return 数据集合
	 */
	public ResultSet Query(String sql,Object...obj){
		connection=getConnection();
		try {
			sta=connection.prepareStatement(sql);
			if(obj!=null){
				for(int i=0;i<obj.length;i++){
					sta.setObject(i+1, obj[i]);
				}
			}
			rs=sta.executeQuery();
		} catch (SQLException e) {
			e.printStackTrace();
		}
		return rs;
	}

	/**
	 * 关闭资源
	 */
	public void close() {
		try {
			if (rs != null) {
				rs.close();
			}
		} catch (SQLException e) {
			e.printStackTrace();
		} finally {
			try {
				if (sta != null) {
					sta.close();
				}
			} catch (SQLException e2) {
				e2.printStackTrace();
			} finally {
				if (connection != null) {
					try {
						connection.close();
					} catch (SQLException e) {
						e.printStackTrace();
					}
				}
			}
		}
	}

    /**
     * Drug信息
     *
     * @return
     */
    public List<Drug> getDrug(String sql) {
        List<Drug> drugs = Lists.newLinkedList();
        TZDBConn1 dbconn = new TZDBConn1();
        try {
            rs = dbconn.Query(sql, null);
            while (rs.next()) {
                Drug drug = new Drug();
                drug.setName(rs.getString("name"));//医院项目名称
                drug.setDateValue(rs.getString("dateValue"));//结果时间
                drug.setForm(rs.getString("form"));//药品剂型
                drugs.add(drug);
            }
        } catch (Exception e) {
            e.printStackTrace();
        }finally {
			close();
		}

        return drugs;
    }

    /**
     * Diag信息
     *
     * @return
     */
    public List<Item> getDiag(String sql) {
        List<Item> diags = Lists.newLinkedList();
        TZDBConn1 dbconn = new TZDBConn1();
        try {
            rs = dbconn.Query(sql, null);
            while (rs.next()) {
                Drug drug = new Drug();
                drug.setName(rs.getString("name"));//医院项目名称
				drug.setDateValue(rs.getString("dateValue"));//结果时间
                diags.add(drug);
            }
        } catch (Exception e) {
            e.printStackTrace();
        }finally {
			close();
		}

        return diags;
    }

	/**
	 * Lis信息
	 *
	 * @return
	 */
	public List<Lis> getLis(String sql) {
		List<Lis> list = Lists.newLinkedList();
		TZDBConn1 dbconn = new TZDBConn1();
		try {
			rs = dbconn.Query(sql, null);
			Pattern pattern = Pattern.compile("^[0-9]+(\\.[0-9]*)?$");
			while (rs.next()) {
				Lis lis = new Lis();
				lis.setDetailName(rs.getString("detailName"));//检验细项名称
				lis.setOtherValue(rs.getString("result"));//检验结果值(文本)
				lis.setUnits(rs.getString("unit"));//单位
				if (StringUtils.isNoneBlank(rs.getString("referenceMin"))) {
					lis.setMinValue(pattern.matcher(rs.getString("referenceMin")).matches() ? Double.parseDouble(rs.getString("referenceMin")) : null);//最小值
				}
				if (StringUtils.isNoneBlank(rs.getString("referenceMax"))) {
					lis.setMaxValue(pattern.matcher(rs.getString("referenceMax")).matches() ? Double.parseDouble(rs.getString("referenceMax")) : null);//最大值
				}
				lis.setDateValue(rs.getString("dateValue"));//结果时间
				list.add(lis);
			}
		} catch (Exception e) {
			e.printStackTrace();
		}finally {
			close();
		}
		return list;
	}

	/**
	 * Pacs信息
	 *
	 * @return
	 */
	public List<Pacs> getPacs(String sql) {
		List<Pacs> pacs = Lists.newLinkedList();
		TZDBConn1 dbconn = new TZDBConn1();
		try {
			rs = dbconn.Query(sql, null);
			while (rs.next()) {
				Pacs pacs1 = new Pacs();
				pacs1.setName(rs.getString("repName"));//医院检查名称
				pacs1.setDesc(rs.getString("clinicSight"));//检查描述
				pacs1.setResult(rs.getString("reptDiag"));//检查结果
				pacs1.setDateValue(rs.getString("dateValue"));//结果时间
				pacs.add(pacs1);
			}
		} catch (Exception e) {
			e.printStackTrace();
		}finally {
			close();
		}
		return pacs;
	}


    /**
     * Operation信息
     *
     * @return
     */
    public List<Item> getOperation(String sql) {
        List<Item> items = Lists.newLinkedList();
        TZDBConn1 dbconn = new TZDBConn1();
        try {
            rs = dbconn.Query(sql, null);
            while (rs.next()) {
                Item item = new Item();
                item.setName(rs.getString("operationName"));//手术名称
                item.setDateValue(rs.getString("operationDate"));//开单时间
                items.add(item);
            }
        } catch (Exception e) {
            e.printStackTrace();
        }finally {
			close();
		}

        return items;
    }

//	/**
//	 * DrugOrder信息
//	 * @return
//	 */
//	public List<Drug> getDrugOrder(String sql) {
//		List<Drug> drugs =Lists.newLinkedList();
//		TZDBConn dbconn=new TZDBConn();
//		try {
//			rs =dbconn.Query(sql, null);
//			while(rs.next()){
//				Drug drug=new Drug();
//				drug.setName(rs.getString("name"));//名称
//				drug.setDateValue(rs.getString("dateValue"));//结果时间
//				drug.setForm(rs.getString("form"));//药品剂型
//				drugs.add(drug);
//			}
//		} catch (Exception e) {
//			e.printStackTrace();
//		}
//
//		return drugs;
//	}
//
//	/**
//	 * item信息
//	 * @return
//	 */
//	public List<Item> getOrder(String sql) {
//		List<Item> items =Lists.newLinkedList();
//		TZDBConn dbconn=new TZDBConn();
//		try {
//			rs =dbconn.Query(sql, null);
//			while(rs.next()){
//				Item item=new Item();
//				item.setName(rs.getString("name"));//名称
//				item.setDateValue(rs.getString("dateValue"));
//				item.setFrequency(rs.getString("frequency"));//频次
//				items.add(item);
//			}
//		} catch (Exception e) {
//			e.printStackTrace();
//		}
//
//		return items;
//	}
//	/**
//	 * item信息没频次的
//	 * @return
//	 */
//	public List<Item> getItem(String sql) {
//		List<Item> items =Lists.newLinkedList();
//		TZDBConn dbconn=new TZDBConn();
//		try {
//			rs =dbconn.Query(sql, null);
//			while(rs.next()){
//				Item item=new Item();
//				item.setName(rs.getString("name"));//名称
//				item.setDateValue(rs.getString("dateValue"));
//				items.add(item);
//			}
//		} catch (Exception e) {
//			e.printStackTrace();
//		}
//
//		return items;
//	}
//
//
//	/**
//	 * LisOrder信息
//	 * @return
//	 */
//	public List<Lis> getLisOrder(String sql) {
//		List<Lis> list =Lists.newLinkedList();
//		TZDBConn dbconn=new TZDBConn();
//		try {
//			rs =dbconn.Query(sql, null);
//			Pattern pattern = Pattern.compile("^[0-9]+(\\.[0-9]*)?$");
//			while(rs.next()){
//				Lis lis =new Lis();
//				lis.setName(rs.getString("name"));//名称
//				lis.setDateValue(rs.getString("dateValue"));//结果时间
//				lis.setFrequency(rs.getString("frequency"));//频次
//				list.add(lis);
//			}
//		} catch (Exception e) {
//			e.printStackTrace();
//		}
//		return list;
//	}
//
//	/**
//	 * Pacs信息
//	 * @return
//	 */
//	public List<Pacs> getPacsOrder(String sql) {
//		List<Pacs> pacs =Lists.newLinkedList();
//		TZDBConn dbconn=new TZDBConn();
//		try {
//			rs =dbconn.Query(sql, null);
//			while(rs.next()){
//				Pacs pacs1 =new Pacs();
//				pacs1.setName(rs.getString("name"));//名称
//				pacs1.setDateValue(rs.getString("dateValue"));//结果时间
//				pacs1.setFrequency(rs.getString("frequency"));//频次
//				pacs.add(pacs1);
//			}
//		} catch (Exception e) {
//			e.printStackTrace();
//		}
//		return pacs;
//	}
//
//
//
	/**
	 * 基本信息
	 * @return
	 */

	public  Map<String,String> getInfo(String sql) {
		Map<String,String> map  = new HashMap<>();
		TZDBConn1 dbconn=new TZDBConn1();
		try {
			rs =dbconn.Query(sql, null);
			while(rs.next()){
				map.put("AGE",rs.getString("AGE"));//年龄
				map.put("SEX",rs.getString("SEX"));//性别
				map.put("MARRIAGE",rs.getString("MARRIAGE"));//婚姻
				map.put("CHIEF",rs.getString("CHIEF"));//主诉
				map.put("SYMPTOM",rs.getString("SYMPTOM"));//现病史
				map.put("PASTS",rs.getString("PASTS"));//既往史
				map.put("PERSONAL",rs.getString("PERSONAL"));//个人史
				map.put("MARITAL",rs.getString("MARITAL"));//婚育史
				map.put("FAMILY",rs.getString("FAMILY"));//家族史
				map.put("MENSTRUAL",rs.getString("MENSTRUAL"));//月经史
				map.put("VITAL",rs.getString("VITAL"));//查体
			}
		} catch (Exception e) {
			e.printStackTrace();
		}finally {
			close();
		}
		return map;
	}


}