From d6c9089e00b2b2f057de69c06d5bf3d31b0575d6 Mon Sep 17 00:00:00 2001 From: republicline <1464474399@qq.com> Date: Mon, 25 Nov 2024 12:37:12 +0800 Subject: [PATCH] =?UTF-8?q?commit:=20=E6=B7=BB=E5=8A=A0=E7=BD=97=E5=BA=93?= =?UTF-8?q?=E7=89=88=E6=9C=AC?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../medicine/service/AIMedicineService.java | 2 +- .../service/impl/AIMedicineServiceImpl.java | 63 +++++++++++++------ .../rax/vital/v1/timer/VitalSignTimer.java | 4 +- .../rax/vital/v1/timer/VitalSignTimerWS.java | 32 ++++++++-- 4 files changed, 74 insertions(+), 27 deletions(-) diff --git a/upms/upms-biz/src/main/java/com/rax/vital/v1/medicine/service/AIMedicineService.java b/upms/upms-biz/src/main/java/com/rax/vital/v1/medicine/service/AIMedicineService.java index 98f522b..9a5d705 100644 --- a/upms/upms-biz/src/main/java/com/rax/vital/v1/medicine/service/AIMedicineService.java +++ b/upms/upms-biz/src/main/java/com/rax/vital/v1/medicine/service/AIMedicineService.java @@ -12,7 +12,7 @@ import java.util.Map; public interface AIMedicineService { List getAIMedicine(MongoTemplate template); - List getAIMedicine(Connection connection); + List getAIMedicine(Connection connection,Double finalSelectValue); void changeAIFlagMedicine(MongoTemplate template, String flag, String medicine, String value); } diff --git a/upms/upms-biz/src/main/java/com/rax/vital/v1/medicine/service/impl/AIMedicineServiceImpl.java b/upms/upms-biz/src/main/java/com/rax/vital/v1/medicine/service/impl/AIMedicineServiceImpl.java index c2761d6..ae17cc4 100644 --- a/upms/upms-biz/src/main/java/com/rax/vital/v1/medicine/service/impl/AIMedicineServiceImpl.java +++ b/upms/upms-biz/src/main/java/com/rax/vital/v1/medicine/service/impl/AIMedicineServiceImpl.java @@ -51,7 +51,7 @@ public class AIMedicineServiceImpl implements AIMedicineService { } @Override - public List getAIMedicine(Connection connection) { + public List getAIMedicine(Connection connection,Double finalSelectValue) { List medicineList = new ArrayList<>(); try { Statement statement = connection.createStatement(); @@ -92,24 +92,49 @@ public class AIMedicineServiceImpl implements AIMedicineService { " ORDER BY time DESC LIMIT 1; "; ResultSet resultSet = statement.executeQuery(sql); Map medicine = new HashMap(); - while (resultSet.next()) { - medicine.put("丙泊酚", resultSet.getString("rate_1")); - medicine.put("丙泊酚sum", resultSet.getString("cumu_1")); - medicine.put("舒芬太尼", resultSet.getString("rate_2")); - medicine.put("舒芬太尼sum", resultSet.getString("cumu_2")); - medicine.put("瑞芬太尼", resultSet.getString("rate_3")); - medicine.put("瑞芬太尼sum", resultSet.getString("cumu_3")); - medicine.put("顺阿曲库胺", resultSet.getString("rate_4")); - medicine.put("顺阿曲库胺sum", resultSet.getString("cumu_4")); - medicine.put("尼卡地平", resultSet.getString("rate_5")); - medicine.put("尼卡地平sum", resultSet.getString("cumu_5")); - medicine.put("艾司洛尔", resultSet.getString("rate_6")); - medicine.put("艾司洛尔sum", resultSet.getString("cumu_6")); - medicine.put("麻黄素", resultSet.getString("rate_7")); - medicine.put("麻黄素sum", resultSet.getString("cumu_7")); - medicine.put("阿托品", resultSet.getString("rate_8")); - medicine.put("阿托品sum", resultSet.getString("cumu_8")); - medicine.put("Time", resultSet.getString("time")); + + if (finalSelectValue == 1) { + while (resultSet.next()) { + medicine.put("丙泊酚", resultSet.getString("rate_1")); + medicine.put("丙泊酚sum", resultSet.getString("cumu_1")); + medicine.put("舒芬太尼", resultSet.getString("rate_2")); + medicine.put("舒芬太尼sum", resultSet.getString("cumu_2")); + medicine.put("瑞芬太尼", resultSet.getString("rate_3")); + medicine.put("瑞芬太尼sum", resultSet.getString("cumu_3")); + medicine.put("罗库溴铵", resultSet.getString("rate_4")); + medicine.put("罗库溴铵sum", resultSet.getString("cumu_4")); + medicine.put("尼卡地平", resultSet.getString("rate_5")); + medicine.put("尼卡地平sum", resultSet.getString("cumu_5")); + medicine.put("艾司洛尔", resultSet.getString("rate_6")); + medicine.put("艾司洛尔sum", resultSet.getString("cumu_6")); + medicine.put("麻黄素", resultSet.getString("rate_7")); + medicine.put("麻黄素sum", resultSet.getString("cumu_7")); + medicine.put("阿托品", resultSet.getString("rate_8")); + medicine.put("阿托品sum", resultSet.getString("cumu_8")); + medicine.put("Time", resultSet.getString("time")); + } + } + + if (finalSelectValue == 2 || finalSelectValue == 0) { + while (resultSet.next()) { + medicine.put("丙泊酚", resultSet.getString("rate_1")); + medicine.put("丙泊酚sum", resultSet.getString("cumu_1")); + medicine.put("舒芬太尼", resultSet.getString("rate_2")); + medicine.put("舒芬太尼sum", resultSet.getString("cumu_2")); + medicine.put("瑞芬太尼", resultSet.getString("rate_3")); + medicine.put("瑞芬太尼sum", resultSet.getString("cumu_3")); + medicine.put("顺阿曲库胺", resultSet.getString("rate_4")); + medicine.put("顺阿曲库胺sum", resultSet.getString("cumu_4")); + medicine.put("尼卡地平", resultSet.getString("rate_5")); + medicine.put("尼卡地平sum", resultSet.getString("cumu_5")); + medicine.put("艾司洛尔", resultSet.getString("rate_6")); + medicine.put("艾司洛尔sum", resultSet.getString("cumu_6")); + medicine.put("麻黄素", resultSet.getString("rate_7")); + medicine.put("麻黄素sum", resultSet.getString("cumu_7")); + medicine.put("阿托品", resultSet.getString("rate_8")); + medicine.put("阿托品sum", resultSet.getString("cumu_8")); + medicine.put("Time", resultSet.getString("time")); + } } medicineList.add(medicine); } catch (SQLException e) { diff --git a/upms/upms-biz/src/main/java/com/rax/vital/v1/timer/VitalSignTimer.java b/upms/upms-biz/src/main/java/com/rax/vital/v1/timer/VitalSignTimer.java index 7626109..9c3585b 100644 --- a/upms/upms-biz/src/main/java/com/rax/vital/v1/timer/VitalSignTimer.java +++ b/upms/upms-biz/src/main/java/com/rax/vital/v1/timer/VitalSignTimer.java @@ -157,8 +157,8 @@ public class VitalSignTimer { Connection connection = finalMySQLSource.getConnection(); // List vitalSignsList = vitalSignsService.getVitalSignsList(connection); // result.put("vitalSignsList", vitalSignsList); - List aiMedicineList = aiMedicineService.getAIMedicine(connection); - result.put("aiMedicineList", aiMedicineList); +// List aiMedicineList = aiMedicineService.getAIMedicine(connection); +// result.put("aiMedicineList", aiMedicineList); List docMedicineList = doctorMedicineService.getDocMedicine(connection); result.put("docMedicineList", docMedicineList); Map flag = flagService.getFlag(connection); diff --git a/upms/upms-biz/src/main/java/com/rax/vital/v1/timer/VitalSignTimerWS.java b/upms/upms-biz/src/main/java/com/rax/vital/v1/timer/VitalSignTimerWS.java index d962583..2b49fb9 100644 --- a/upms/upms-biz/src/main/java/com/rax/vital/v1/timer/VitalSignTimerWS.java +++ b/upms/upms-biz/src/main/java/com/rax/vital/v1/timer/VitalSignTimerWS.java @@ -15,7 +15,7 @@ import org.springframework.web.socket.WebSocketMessage; import org.springframework.web.socket.WebSocketSession; import java.io.IOException; -import java.sql.Connection; +import java.sql.*; import java.util.List; import java.util.Map; import java.util.Timer; @@ -138,7 +138,7 @@ public class VitalSignTimerWS { timerTaskMap.put(sessionId, timerTask); } - public void createAndSendMessageMySQL(String database, String username, WebSocketSession session) { + public void createAndSendMessageMySQL(String database, String username, WebSocketSession session) throws SQLException { // synchronized (username) { if (!masterControlMap.containsKey(database)) { masterControlMap.put(database, username); @@ -173,7 +173,28 @@ public class VitalSignTimerWS { } } + CustomDataSource finalDataSource = dataSource; + /** + * 判断罗库溴铵还是顺阿曲库胺 + * 0默认值无意义、1有创、2无创 + * 0默认值无意义、1罗库, 2顺阿 + */ + // 这里只判断罗库还是顺阿 + Connection connection = finalDataSource.getConnection(); + String selectSql = "SELECT sum(罗库) from selecttable;"; + Statement statement = connection.createStatement(); + statement.execute(selectSql); + ResultSet resultSet = statement.getResultSet(); + double selectValue = 0; + while (resultSet.next()) { + System.out.println("selectValue = " + selectValue); + selectValue = resultSet.getDouble("sum(罗库)"); + System.out.println("change:selectValue = " + selectValue); + } + + double finalSelectValue = selectValue; + System.out.println("finalSelectValue = " + finalSelectValue); TimerTask timerTask = new TimerTask() { @Override public void run() { @@ -182,12 +203,13 @@ public class VitalSignTimerWS { // List vitalSignsList = vitalSignsService.getVitalSignsList(connection); Map vitalSignsList = vitalSignsService.getVitalSignsList(connection, username, database); jsonObject.put("vitalSignsList", vitalSignsList); - List aiMedicineList = aiMedicineService.getAIMedicine(connection); + List aiMedicineList = aiMedicineService.getAIMedicine(connection,finalSelectValue); jsonObject.put("aiMedicineList", aiMedicineList); // List docMedicineList = doctorMedicineService.getDocMedicine(connection); // jsonObject.put("docMedicineList", docMedicineList); - List revulsionList = revulsionService.getRevulsionServiceList(connection); - jsonObject.put("revulsionList", revulsionList); + // 诱导期给药, 暂时不用 +// List revulsionList = revulsionService.getRevulsionServiceList(connection); +// jsonObject.put("revulsionList", revulsionList); Map flags = flagService.getFlag(connection); jsonObject.put("flags", flags); jsonObject.put("msgType", "msg");