root/rax-remote-2
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

commit: 添加罗库版本

This commit is contained in:
republicline 2024-11-25 12:37:12 +08:00
parent d7d377435e
commit d6c9089e00
4 changed files with 74 additions and 27 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
upms/upms-biz/src/main/java/com/rax/vital/v1/medicine/service/AIMedicineService.java
View File

@ -12,7 +12,7 @@ import java.util.Map;
public interface AIMedicineService {
List<Map> getAIMedicine(MongoTemplate template);
List<Map> getAIMedicine(Connection connection);
List<Map> getAIMedicine(Connection connection,Double finalSelectValue);
void changeAIFlagMedicine(MongoTemplate template, String flag, String medicine, String value);
}

27
upms/upms-biz/src/main/java/com/rax/vital/v1/medicine/service/impl/AIMedicineServiceImpl.java
View File

@ -51,7 +51,7 @@ public class AIMedicineServiceImpl implements AIMedicineService {
}
@Override
public List<Map> getAIMedicine(Connection connection) {
public List<Map> getAIMedicine(Connection connection,Double finalSelectValue) {
List<Map> medicineList = new ArrayList<>();
try {
Statement statement = connection.createStatement();
@ -92,6 +92,30 @@ public class AIMedicineServiceImpl implements AIMedicineService {
" ORDER BY time DESC LIMIT 1; ";
ResultSet resultSet = statement.executeQuery(sql);
Map medicine = new HashMap();
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"));
@ -111,6 +135,7 @@ public class AIMedicineServiceImpl implements AIMedicineService {
medicine.put("阿托品sum", resultSet.getString("cumu_8"));
medicine.put("Time", resultSet.getString("time"));
}
}
medicineList.add(medicine);
} catch (SQLException e) {
throw new RuntimeException(e);

4
upms/upms-biz/src/main/java/com/rax/vital/v1/timer/VitalSignTimer.java
View File

@ -157,8 +157,8 @@ public class VitalSignTimer {
Connection connection = finalMySQLSource.getConnection();
// List<Map> vitalSignsList = vitalSignsService.getVitalSignsList(connection);
// result.put("vitalSignsList", vitalSignsList);
List<Map> aiMedicineList = aiMedicineService.getAIMedicine(connection);
result.put("aiMedicineList", aiMedicineList);
// List<Map> aiMedicineList = aiMedicineService.getAIMedicine(connection);
// result.put("aiMedicineList", aiMedicineList);
List<Map> docMedicineList = doctorMedicineService.getDocMedicine(connection);
result.put("docMedicineList", docMedicineList);
Map flag = flagService.getFlag(connection);

32
upms/upms-biz/src/main/java/com/rax/vital/v1/timer/VitalSignTimerWS.java
View File

@ -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<Map> vitalSignsList = vitalSignsService.getVitalSignsList(connection);
Map vitalSignsList = vitalSignsService.getVitalSignsList(connection, username, database);
jsonObject.put("vitalSignsList", vitalSignsList);
List<Map> aiMedicineList = aiMedicineService.getAIMedicine(connection);
List<Map> aiMedicineList = aiMedicineService.getAIMedicine(connection,finalSelectValue);
jsonObject.put("aiMedicineList", aiMedicineList);
// List<Map> 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");