From cf32b62b2baae720a57d66da0b3ba3a105150483 Mon Sep 17 00:00:00 2001
From: 赵文轩 <1652863494@qq.com>
Date: 星期五, 07 六月 2024 09:48:54 +0800
Subject: [PATCH] 获取数据请求接口
---
ltkj-admin/src/main/java/com/ltkj/web/controller/his/HisApiGetMethodService.java | 233 +++++++++++++++++++++++++++++++++++++++++++++++++++++++--
1 files changed, 222 insertions(+), 11 deletions(-)
diff --git a/ltkj-admin/src/main/java/com/ltkj/web/controller/his/HisApiGetMethodService.java b/ltkj-admin/src/main/java/com/ltkj/web/controller/his/HisApiGetMethodService.java
index e11d986..54e33de 100644
--- a/ltkj-admin/src/main/java/com/ltkj/web/controller/his/HisApiGetMethodService.java
+++ b/ltkj-admin/src/main/java/com/ltkj/web/controller/his/HisApiGetMethodService.java
@@ -1,12 +1,22 @@
package com.ltkj.web.controller.his;
+import cn.hutool.core.util.StrUtil;
import cn.hutool.json.JSONArray;
import cn.hutool.json.JSONObject;
import cn.hutool.json.JSONUtil;
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.ltkj.common.core.domain.AjaxResult;
+import com.ltkj.hosp.domain.HisApiConfig;
+import com.ltkj.hosp.service.HisApiConfigService;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+import org.springframework.transaction.annotation.Transactional;
import java.io.FileInputStream;
import java.io.IOException;
+import java.io.InputStreamReader;
+import java.nio.charset.StandardCharsets;
import java.sql.*;
import java.text.SimpleDateFormat;
import java.util.*;
@@ -17,20 +27,198 @@
* @Author: zhaowenxuan
* @Date: 2024/5/31 14:38
*/
+@Slf4j
+@Component
public class HisApiGetMethodService {
// 鏁版嵁搴撻厤缃枃浠惰矾寰�
- private static final String CONFIG_PATH = "D:\\ltkjprojectconf\\config.properties";
+ private static final String CONFIG_PATH = "/Users/chacca/寮�鍙戠浉鍏�/浠ｇ爜/ltkj_peis/ltkj-admin/src/main/resources/config.properties";
// 鏁版嵁搴撳悕
private static String DB_NAME = "";
+ private static String HIS_URL = "";
+ @Autowired
+ private HisApiMethodService controller;
+ @Autowired
+ private HisApiConfigService hisApiConfigService;
+
+ static {
+ try {
+ Class.forName("com.mysql.cj.jdbc.Driver");
+ } catch (ClassNotFoundException e) {
+ e.printStackTrace();
+ }
+ try {
+ FileInputStream inputStream = new FileInputStream(CONFIG_PATH);
+ Properties props = new Properties();
+ props.load(inputStream);
+ String url = props.getProperty("his_api_url");
+ String port = props.getProperty("his_api_port");
+ HIS_URL=url+":"+port+"/api/His/";
+ } catch (IOException throwables) {
+ throwables.printStackTrace();
+ }
+ }
+
/**
+ * 鑾峰彇鏁版嵁
+ *
+ * @param type 鎺ュ彛浠ｇ爜
+ * @param params 璇锋眰鍙傛暟
+ * @return
+ */
+ @Transactional
+ public AjaxResult getHISData(String type, Map<String, Object> params) {
+// LambdaQueryWrapper<HisApiConfig> lambdaQueryWrapper = new LambdaQueryWrapper<>();
+// lambdaQueryWrapper.eq(HisApiConfig::getApiMethod, type);
+// HisApiConfig hisApiConfig = hisApiConfigService.getOne(lambdaQueryWrapper);
+
+ AjaxResult result = null;
+ // TODO 鍒涘缓琛� 寮勬垚鏁版嵁搴撳姩鎬佽幏鍙� 鎺ュ彛鍦板潃銆佷唬鐮併�佹槸鍚﹀垎椤点�佷富閿甶d銆佷富閿瓧娈�
+ // TODO 浠�2.4.2鑾峰彇鍒版暟鎹� 鏍规嵁his_registration_id鍒犻櫎鏃ф暟鎹湪鎻掑叆鏂版暟鎹� 涓嬪眰涓氬姟鍧囦竴鏍锋牴鎹繑鍥炵殑JYBGID鍒犻櫎鏃ф暟鎹湪鎻掑叆鏂版暟鎹�
+ switch (type) {
+ case "Getoutaccountrecord":
+ result = controller.Getoutaccountrecord(params);
+// result.put("limit", true);
+ break;
+ case "Getoutpatientcostinfo":
+ result = controller.Getoutpatientcostinfo(params);
+// result.put("limit", true);
+ break;
+ case "Getlaburgentinfo":
+ result = controller.Getlaburgentinfo(params);
+// result.put("limit", false);
+ break;
+ case "Getlabgermdetailinfo":
+ result = controller.Getlabgermdetailinfo(params);
+// result.put("limit", false);
+ break;
+ case "Getlabgermrepinfo":
+ result = controller.Getlabgermrepinfo(params);
+// result.put("limit", false);
+ break;
+ case "Getlabreportinfo":
+ result = controller.Getlabreportinfo(params);
+// result.put("limit", true);
+ break;
+ case "Getlabapplyinfo":
+ result = controller.Getlabapplyinfo(params);
+// result.put("limit", false);
+ break;
+ case "Getexamurgentinfo":
+ result = controller.Getexamurgentinfo(params);
+// result.put("limit", true);
+ break;
+ case "Getexamreportinfo":
+ result = controller.Getexamreportinfo(params);
+// result.put("limit", true);
+ break;
+ case "Getexamapplyinfo":
+ result = controller.Getexamapplyinfo(params);
+// result.put("limit", false);
+ break;
+ case "Getlabdetailinfo":
+ result = controller.Getlabdetailinfo(params);
+// result.put("limit", false);
+ break;
+ }
+ String json = result.get("data").toString();
+ JSONObject response = JSONUtil.parseObj(json).getJSONObject("Response");
+ if (response.getStr("ResultCode").toString().equals("0")) {
+ AjaxResult ajaxResult = AjaxResult.success();
+// if ((boolean) result.get("limit")) {
+// ajaxResult = saveArray(json, type);
+ JSONArray resultData = response.getJSONArray("ResultData");
+ List<Map<String, String>> list = new ArrayList<>();
+ for (Object resultDatum : resultData) {
+ JSONObject object = (JSONObject) resultDatum;
+ ajaxResult = save(object, type);
+ Map<String, String> map = new HashMap<>();
+ for (String key : object.keySet()) {
+ String defaultVal = object.get(key).toString();
+ String val = defaultVal.trim().replaceAll("\\s+", "");
+ map.put(key, val);
+ }
+ list.add(map);
+ }
+ ajaxResult.put("data", list);
+// } else {
+// // 浠ラ泦鍚堣繑鍥�
+// JSONArray resultData = response.getJSONArray("ResultData");
+// List<JSONObject> list = JSONUtil.toList(resultData, JSONObject.class);
+// ArrayList<Map<String, String>> maps = new ArrayList<>();
+// for (JSONObject data : list) {
+// ajaxResult = save(data, type);
+// HashMap<String, String> map1 = new HashMap<>();
+// for (String key : data.keySet()) {
+// String defaultVal = data.get(key).toString();
+// String val = defaultVal.trim().replaceAll("\\s+", "");
+// map1.put(key, val);
+// }
+// maps.add(map1);
+// }
+// ajaxResult.put("data", maps);
+// }
+ return ajaxResult;
+ } else {
+ return AjaxResult.error().put("result", JSONUtil.parseObj(json));
+ }
+ }
+
+ /**
+ * ResultData涓哄璞�
* 鏍规嵁his鎺ュ彛杩斿洖鍊� 鎻掑叆鏁版嵁
* 濡傛灉娌℃湁琛ㄥ垯鍒涘缓琛� 鎺ュ彛澧炲姞浜嗗瓧娈靛垯涓鸿〃澧炲姞瀛楁
- * @param json 璇锋眰杩斿洖json
+ *
* @param code 鎺ュ彛浠ｇ爜
* @return 鎵ц鏄惁鎴愬姛
*/
- public AjaxResult save(String json, String code) {
+ public AjaxResult save(JSONObject object, String code) {
+ code = code.toLowerCase();
+// JSONObject jsonObject = JSONUtil.parseObj(json);
+// JSONObject response = jsonObject.getJSONObject("Response");
+ String tabName = "ltkj_" + code;
+// if (response.getStr("ResultCode").equals("0")) {
+// JSONObject object = response.getJSONObject("ResultData");
+ Connection connection = getConnection();
+// for (Object resultDatum : resultData) {
+// JSONObject object = (JSONObject) resultDatum;
+ Boolean isExists = tabIsExists(connection, tabName);
+ if (null == isExists)
+ return AjaxResult.error();
+ if (!isExists) {
+ try {
+ creatTable(object, tabName, connection);
+ } catch (SQLException throwables) {
+ throwables.printStackTrace();
+ return AjaxResult.error();
+ }
+ }
+ //鎻掑叆鏁版嵁
+ try {
+ operationTable(object, tabName, connection);
+ } catch (SQLException throwables) {
+ throwables.printStackTrace();
+ return AjaxResult.error();
+ }
+// }
+ try {
+ if (connection != null)
+ connection.close();
+ } catch (SQLException throwables) {
+ }
+// }
+ return AjaxResult.success();
+ }
+
+ /**
+ * ResultData涓洪泦鍚�
+ * 鏍规嵁his鎺ュ彛杩斿洖鍊� 鎻掑叆鏁版嵁
+ * 濡傛灉娌℃湁琛ㄥ垯鍒涘缓琛� 鎺ュ彛澧炲姞浜嗗瓧娈靛垯涓鸿〃澧炲姞瀛楁
+ *
+ * @param code 鎺ュ彛浠ｇ爜
+ * @return 鎵ц鏄惁鎴愬姛
+ */
+ public AjaxResult saveArray(String json, String code) {
code = code.toLowerCase();
JSONObject jsonObject = JSONUtil.parseObj(json);
JSONObject response = jsonObject.getJSONObject("Response");
@@ -79,12 +267,13 @@
List<String> columns = getColumns(tabName, connection);
ArrayList<String> responseColums = new ArrayList<>();
for (Map.Entry<String, Object> entry : jsonObject.entrySet()) {
- responseColums.add(entry.getKey());
+ String key = entry.getKey().trim().toLowerCase();
+ responseColums.add(key);
}
responseColums.removeAll(columns);
if (!responseColums.isEmpty()) {
for (String colum : responseColums) {
- String sql = "alter table " + tabName + " add column " + colum + " text null";
+ String sql = "alter table " + tabName + " add column " + colum + " VARCHAR(200) null";
Statement statement = connection.createStatement();
statement.executeUpdate(sql);
statement.close();
@@ -106,10 +295,29 @@
private void insertData(String tabName, Connection connection, JSONObject jsonObject) throws SQLException {
StringBuilder insertSqlBuilder = new StringBuilder();
StringBuilder valueBuilder = new StringBuilder();
+ StringBuilder selectSqlBuilder = new StringBuilder();
insertSqlBuilder.append("insert into ").append(tabName).append(" (");
+ selectSqlBuilder.append("select count(1) as count from ").append(tabName).append(" where ");
for (Map.Entry<String, Object> entry : jsonObject.entrySet()) {
- insertSqlBuilder.append(entry.getKey()).append(", ");
- valueBuilder.append("'").append(entry.getValue()).append("', ");
+ String defaultVal = entry.getValue().toString();
+ String key = entry.getKey().trim().toLowerCase();
+ if (StrUtil.isBlank(defaultVal) || defaultVal.equals("null"))
+ continue;
+ String val = defaultVal.trim().replaceAll("\\s+", "");
+ insertSqlBuilder.append(key).append(", ");
+ valueBuilder.append("'").append(val).append("', ");
+ selectSqlBuilder.append(key).append(" = '").append(val).append("' and ");
+ }
+ selectSqlBuilder.delete(selectSqlBuilder.length() - 5, selectSqlBuilder.length());
+ Statement statement = connection.prepareStatement(selectSqlBuilder.toString());
+ ResultSet resultSet = statement.executeQuery(selectSqlBuilder.toString());
+ resultSet.next();
+ String string = resultSet.getString("count");
+ statement.close();
+ // 濡傛灉涓嶄负0 鍒欒繖鏉℃暟鎹瓨鍦� 涓嶈繘琛屾彃鍏�
+ if (!"0".equals(string)) {
+// log.info("鏁版嵁瀛樺湪涓嶉渶瑕佹彃鍏� {}", jsonObject);
+ return;
}
insertSqlBuilder.append("insert_time, ");
String time = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date());
@@ -118,7 +326,7 @@
valueBuilder.delete(valueBuilder.length() - 2, valueBuilder.length());
insertSqlBuilder.append(") values (").append(valueBuilder).append(")");
// 鎻掑叆鏁版嵁
- Statement statement = connection.createStatement();
+ statement = connection.createStatement();
statement.execute(insertSqlBuilder.toString());
statement.close();
}
@@ -153,9 +361,10 @@
private void creatTable(JSONObject data, String tabName, Connection connection) throws SQLException {
StringBuilder sql = new StringBuilder("CREATE TABLE " + tabName + " (");
for (Map.Entry<String, Object> entry : data.entrySet()) {
- sql.append(entry.getKey()).append(" text null,");
+ String key = entry.getKey().trim().toLowerCase();
+ sql.append(key).append(" VARCHAR(200) null,");
}
- sql.append("insert_time").append(" text null,");
+ sql.append("insert_time").append(" VARCHAR(200) null,");
sql = new StringBuilder(sql.substring(0, sql.length() - 1));
sql.append(");");
Statement statement = connection.createStatement();
@@ -194,13 +403,15 @@
private Connection getConnection() {
try {
FileInputStream inputStream = new FileInputStream(CONFIG_PATH);
+ InputStreamReader reader = new InputStreamReader(inputStream, StandardCharsets.UTF_8);
Properties props = new Properties();
- props.load(inputStream);
+ props.load(reader);
String name = props.getProperty("name");
String url = "jdbc:mysql://" + props.getProperty("ip") + ":" + props.getProperty("prot") + "/" + name + "" +
"?useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=false&serverTimezone=GMT%2B8";
String user = props.getProperty("username");
String password = props.getProperty("password");
+ log.info("鏁版嵁搴撻厤缃俊鎭� ->鏁版嵁搴撳悕-{},user-{},password-{},url-{}", name, user, password, url);
Connection connection = DriverManager.getConnection(url, user, password);
DB_NAME = name;
return connection;
--
Gitblit v1.8.0