From caae115579e8ac9b406318e24e35d348602ecd11 Mon Sep 17 00:00:00 2001 From: liquanyu Date: Tue, 13 Dec 2016 12:15:35 +0800 Subject: [PATCH] =?UTF-8?q?his=E6=8E=A5=E5=8F=A3?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/lyms/platform/query/PatientsQuery.java | 12 ++++- .../java/com/lyms/hospitalapi/qhdfy/ConnTools.java | 2 +- .../operate/web/controller/TestController.java | 59 ++++++++++++++++++++++ 3 files changed, 71 insertions(+), 2 deletions(-) diff --git a/platform-dal/src/main/java/com/lyms/platform/query/PatientsQuery.java b/platform-dal/src/main/java/com/lyms/platform/query/PatientsQuery.java index 86862d6..0270e3b 100644 --- a/platform-dal/src/main/java/com/lyms/platform/query/PatientsQuery.java +++ b/platform-dal/src/main/java/com/lyms/platform/query/PatientsQuery.java @@ -108,7 +108,16 @@ public class PatientsQuery extends BaseQuery implements IConvertToNativeQuery { //医院id private List hospitalList; + //档案编号 + private String fileCode; + public String getFileCode() { + return fileCode; + } + + public void setFileCode(String fileCode) { + this.fileCode = fileCode; + } public String getProvinceRegisterId() { return provinceRegisterId; @@ -847,7 +856,8 @@ public class PatientsQuery extends BaseQuery implements IConvertToNativeQuery { MongoCondition con1 = MongoCondition.newInstance("phone", queryNo, MongoOper.IS); MongoCondition con2 = MongoCondition.newInstance("username", queryNo, MongoOper.IS); MongoCondition con3 = MongoCondition.newInstance("cardNo", queryNo, MongoOper.IS); - c1= c.orCondition(new MongoCondition[]{con1, con2, con3}).getCriteria(); + MongoCondition con4 = MongoCondition.newInstance("fileCode", queryNo, MongoOper.IS); + c1= c.orCondition(new MongoCondition[]{con1, con2, con3,con4}).getCriteria(); } if (lastCheckEmployeeId != null) { diff --git a/platform-operate-api/src/main/java/com/lyms/hospitalapi/qhdfy/ConnTools.java b/platform-operate-api/src/main/java/com/lyms/hospitalapi/qhdfy/ConnTools.java index b896ba6..7a30009 100644 --- a/platform-operate-api/src/main/java/com/lyms/hospitalapi/qhdfy/ConnTools.java +++ b/platform-operate-api/src/main/java/com/lyms/hospitalapi/qhdfy/ConnTools.java @@ -15,7 +15,7 @@ import java.sql.SQLException; */ public class ConnTools { private static String hisDirverClassName = "com.microsoft.sqlserver.jdbc.SQLServerDriver"; - private static String hisUrl = "jdbc:sqlserver://168.254.0.7:1443; DatabaseName=THIS4"; + private static String hisUrl = "jdbc:sqlserver://168.254.0.7:1433; DatabaseName=THIS4"; private static String hisUser = "sa"; private static String hisPassword = "ccnms05*"; diff --git a/platform-operate-api/src/main/java/com/lyms/platform/operate/web/controller/TestController.java b/platform-operate-api/src/main/java/com/lyms/platform/operate/web/controller/TestController.java index 4e0bc05..6b1d97f 100644 --- a/platform-operate-api/src/main/java/com/lyms/platform/operate/web/controller/TestController.java +++ b/platform-operate-api/src/main/java/com/lyms/platform/operate/web/controller/TestController.java @@ -441,6 +441,65 @@ public class TestController { return "initCardNo finish - " + a; } + + + @RequestMapping(value = "/modifyRiskFactor", method = RequestMethod.GET) + @ResponseBody + public String modifyRiskFactor(@RequestParam(required = true) String hid) { + PatientsQuery patientQuery = new PatientsQuery(); + patientQuery.setYn(YnEnums.YES.getId()); + patientQuery.setHospitalId(hid); + patientQuery.setrLevel("e637b361-99cf-41eb-84f2-f0dab596e928"); + + + List patientses = patientsService.queryPatient(patientQuery); + int batchSize = 500; + int end = 0; + for (int i = 0; i < patientses.size(); i += batchSize) { + end = (end + batchSize); + if (end > patientses.size()) { + end = patientses.size(); + } + System.out.println("start:" + i + ",end:" + end); + final List tempList = patientses.subList(i, end); + new Thread(new Runnable() { + @Override + public void run() { + if (CollectionUtils.isNotEmpty(tempList)) + { + for (Patients pat : tempList) { + if (pat != null) + { + String levelStr = pat.getRiskLevelId(); + if (com.lyms.platform.common.utils.StringUtils.isNotEmpty(levelStr)) + { + List levels = JsonUtil.toList(levelStr, String.class); + if (CollectionUtils.isNotEmpty(levels) && levels.contains("e637b361-99cf-41eb-84f2-f0dab596e928") && levels.size() > 1) + { + List rFactors = pat.getRiskFactorId(); + if (CollectionUtils.isNotEmpty(rFactors) && rFactors.contains("d42eec03-aa86-45b8-a4e0-78a0ff365fb6")) + { + rFactors.remove("d42eec03-aa86-45b8-a4e0-78a0ff365fb6"); + String resultLevel = JsonUtil.array2JsonString(levels.remove("e637b361-99cf-41eb-84f2-f0dab596e928")); + pat.setRiskLevelId(resultLevel); + patientsService.updatePatient(pat); + } + } + + } + + } + } + } + } + }).start(); + } + + return "modifyRiskFactor finish"; + } + + + public static void main(String[] a) { try { List list = FileUtils.readLines(new File("D:\\temp\\qhdfy_lost1.csv")); -- 1.8.3.1