|
|
@@ -0,0 +1,376 @@
|
|
|
+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();
|
|
|
+ }
|
|
|
+
|
|
|
+ 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();
|
|
|
+ }
|
|
|
+
|
|
|
+ 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();
|
|
|
+ }
|
|
|
+ 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();
|
|
|
+ }
|
|
|
+ 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();
|
|
|
+ }
|
|
|
+
|
|
|
+ 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(rs.getString("info"),rs.getString("value"));//名称
|
|
|
+ }
|
|
|
+ System.out.println(map);
|
|
|
+ } catch (Exception e) {
|
|
|
+ e.printStackTrace();
|
|
|
+ }
|
|
|
+ return map;
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+}
|
shiyue