1、测试类按照新的方式做调整

kernel/src/main/java/com/lantone/qc/kernel/web/controller/QCTestController.java

@@ -6,6 +6,7 @@ import com.lantone.qc.kernel.util.CacheFileManager;
 import com.lantone.qc.kernel.util.KernelConstants;
 import com.lantone.qc.pub.jdbc.MysqlJdbc;
 import com.lantone.qc.pub.model.OutputInfo;
+import com.lantone.qc.pub.model.keys.ModelStandardKeys;
 import com.lantone.qc.pub.model.vo.MedrecVo;
 import com.lantone.qc.pub.model.vo.QueryVo;
 import com.lantone.qc.pub.res.Response;
@@ -38,6 +39,200 @@ public class QCTestController {
     @Autowired
     private QCAnalysis qCAnalysis;
 
+    private Map<String, List<String>> inputLabelMap = new HashMap<>();
+    {
+        inputLabelMap.put("入院记录", Lists.newArrayList("姓名", "性别", "年龄", "民族", "职业", "出生地", "婚姻", "联系地址", "病史陈述者", "出生日期", "户口地址", "电话", "入院日期", "记录日期", "主诉", "现病史", "既往史", "个人史", "婚育史", "月经史", "家族史", "体格检查（一）", "体格检查（二）", "辅助检查", "初步诊断", "修正诊断", "医师签名", "补充诊断"));
+    }
+
+    @ApiOperation(value = "质控测试接口，无需token信息", notes = "")
+    @PostMapping("qc_test")
+    public Response<OutputInfo> qc(String cid, String caseNumber, String hospitalId) {
+        Response response = new Response();
+        if (StringUtils.isEmpty(hospitalId)) {
+            response.setData("未填写医院流水号（hospitalId）......");
+        }
+        if (StringUtils.isEmpty(cid)) {
+            response.setData("未填写医院缩写（cid）......");
+        }
+        //key = 患者就诊号
+        Map<String, QueryVo> queryVoMap = createQueryVo(cid, hospitalId, caseNumber);
+        //key = 患者就诊号
+        Map<String, Map<String, String>> inputCaseMappingMap = createInputCaseMapping(hospitalId, caseNumber);
+
+        List<Map<String, Object>> updates = new ArrayList<>();
+        List<Map<String, Object>> wheres = new ArrayList<>();
+        for (Map.Entry<String, QueryVo> entry : queryVoMap.entrySet()) {
+            OutputInfo outputInfo = qCAnalysis.anlysis(entry.getValue());
+
+            Map<String, String> passMap = inputCaseMappingMap.get(entry.getKey());
+            for (Map.Entry<String, String> e : passMap.entrySet()) {
+                Map<String, Object> m = new HashMap<>();
+                Map<String, Object> w = new HashMap<>();
+                if (outputInfo.getResult().get(e.getKey()) == null) {
+                    m.put("check_label", "-2");
+                } else {
+                    m.put("check_label", outputInfo.getResult().get(e.getKey()).get("status"));
+                }
+                w.put("id", e.getValue());
+
+                updates.add(m);
+                wheres.add(w);
+            }
+        }
+        PropertiesUtil propertiesUtil = new PropertiesUtil("kernel.properties");
+        MysqlJdbc mysqlJdbc = new MysqlJdbc(propertiesUtil.getProperty("mysql.test.user"),
+                propertiesUtil.getProperty("mysql.test.password"),
+                propertiesUtil.getProperty("mysql.test.url"));
+        mysqlJdbc.update("qc_inputcases_mapping_all", updates, wheres);
+        return response;
+    }
+
+    public Map<String, QueryVo> createQueryVo(String cid, String hospitalId, String caseNumber) {
+        PropertiesUtil propertiesUtil = new PropertiesUtil("kernel.properties");
+        MysqlJdbc mysqlJdbc = new MysqlJdbc(propertiesUtil.getProperty("mysql.test.user"),
+                propertiesUtil.getProperty("mysql.test.password"),
+                propertiesUtil.getProperty("mysql.test.url"));
+        Connection conn = mysqlJdbc.connect();
+        Statement st = null;
+        ResultSet rs = null;
+        String r1, r2, r3, r4, r5;
+
+        Map<String, QueryVo> queryVoMap = new HashMap<>();
+        QueryVo queryVo = new QueryVo();
+        List<MedrecVo> medrec = new ArrayList<>();
+        try {
+            st = conn.createStatement();
+            String sql = "select case_number from qc_cases_number where hospital_id = " + hospitalId;   //查询医院所有病历号
+            rs = st.executeQuery(sql);
+            List<String> numbers = new ArrayList<>();
+            while (rs.next()) {
+                r1 = rs.getString(1);
+                numbers.add(r1);
+            }
+
+            sql = "select id from qc_mode";   //查询数据模块
+            rs = st.executeQuery(sql);
+            List<String> modeIds = new ArrayList<>();
+            while (rs.next()) {
+                r1 = rs.getString(1);
+                modeIds.add(r1);
+            }
+
+            sql = "select code, name from qc_cases_entry";   //查询所有条目
+            rs = st.executeQuery(sql);
+            Map<String, Map<String, String>> inputCatalogueMap = new HashMap<>();
+            while (rs.next()) {
+                r1 = rs.getString(1);
+                r2 = rs.getString(2);
+                Map<String, String> m = new HashMap<>();
+                m.put("precond","");
+                m.put("name", r2);
+                m.put("code", r1);
+                inputCatalogueMap.put(r1, m);
+            }
+
+            sql = "SELECT h.code, n.case_number, q.name, qmm.text " +
+                    "FROM qc_model_mapping qmm, qc_mode q, qc_cases_number n, qc_hospital_info h " +
+                    "where qmm.case_number_id = n.id and qmm.mode_id = q.id and n.hospital_id = h.id and n.is_deleted = 'N' ";
+            if (StringUtils.isNotEmpty(caseNumber)) {
+                sql = sql + " and n.case_number = " + caseNumber;
+            }
+            sql = sql + " order by n.id, q.id";
+            rs = st.executeQuery(sql);
+            String tempCaseNumber = "", label = "";
+            List<String> details = new ArrayList<>();
+            while (rs.next()) {
+                r1 = rs.getString(1);
+                r2 = rs.getString(2);
+                r3 = rs.getString(3);
+                r4 = rs.getString(4);
+                if (!tempCaseNumber.equals(String.valueOf(r2)) && StringUtils.isNotEmpty(tempCaseNumber)) {
+                    queryVo.setCid(cid);
+                    queryVo.setMedrec(medrec);
+                    queryVo.setInputCatalogueMap(inputCatalogueMap);
+                    queryVoMap.put(r1, queryVo);
+                    //新的一份病历记录
+                    medrec = new ArrayList<>();
+                    queryVo = new QueryVo();
+                }
+                if (r3.equals("入院记录") || r3.equals("首次病程录") || r3.equals("死亡病例讨论记录") || r3.equals("出院小结") || r3.equals("死亡记录")) {
+                    MedrecVo medrecVo = new MedrecVo();
+                    medrecVo.setTitle(r3);
+                    Map<String, Object> m = new HashMap<>();
+                    m.put("content", r4);
+                    medrecVo.setContent(m);
+                    medrec.add(medrecVo);
+                } else if (r3.equals("查房记录") || r3.equals("会诊记录") || r3.equals("医嘱信息") || r3.equals("值班交接制度") || r3.equals("输血/血制品病程记录")
+                        || r3.equals("抢救记录") || r3.equals("危急值记录") || r3.equals("病危通知书") || r3.equals("阶段小结") || r3.equals("疑难病例讨论记录") || r3.equals("病重通知书")
+                        || r3.equals("术前讨论、术前小结") || r3.equals("麻醉记录") || r3.equals("麻醉知情同意书") || r3.equals("麻醉术前访视记录")
+                        || r3.equals("麻醉术后访视记录") || r3.equals("手术知情同意书") || r3.equals("手术记录") || r3.equals("术后首次病程及谈话记录")
+                        || r3.equals("手术风险评估表") || r3.equals("手术安全核查表") || r3.equals("转科记录(转入)") || r3.equals("转科记录(转出)")) {
+                    if (!label.equals(String.valueOf(r3)) && StringUtils.isNotEmpty(label)) {
+                        MedrecVo medrecVo = new MedrecVo();
+                        medrecVo.setTitle(label);
+                        Map<String, Object> m = new HashMap<>();
+                        m.put("content", details);
+                        medrecVo.setContent(m);
+                        medrec.add(medrecVo);
+                        details = new ArrayList<>();
+                    }
+                    details.add(r4);
+                    label = r3;
+                }
+            }
+        } catch (SQLException sqle) {
+            sqle.printStackTrace();
+        } catch (Exception e) {
+            e.printStackTrace();
+        } finally {
+            mysqlJdbc.close(rs, st, conn);
+        }
+        return queryVoMap;
+    }
+
+    public Map<String, Map<String, String>> createInputCaseMapping(String hospitalId, String caseNumber) {
+        Map<String, Map<String, String>> result = new HashMap<>();
+        PropertiesUtil propertiesUtil = new PropertiesUtil("kernel.properties");
+        MysqlJdbc mysqlJdbc = new MysqlJdbc(propertiesUtil.getProperty("mysql.test.user"),
+                propertiesUtil.getProperty("mysql.test.password"),
+                propertiesUtil.getProperty("mysql.test.url"));
+        Connection conn = mysqlJdbc.connect();
+        Statement st = null;
+        ResultSet rs = null;
+        String r1, r2, r3, r4, r5;
+        try {
+            st = conn.createStatement();
+            String sql = "SELECT qim.id, qim.case_number_id, qc.code  FROM qc_inputcases_mapping qim, qc_cases_number q, qc_cases_entry qc " +
+                    "where qim.case_number_id = q.id and qim.cases_entry_id = qc.id and q.is_deleted = 'N' " +
+                    "and q.hospital_id = " + hospitalId ;
+            if (StringUtils.isNotEmpty(caseNumber)) {
+                sql = sql + " and q.case_number = " + caseNumber;
+            }
+            sql = sql + " order by q.id, qim.cases_id ";
+            rs = st.executeQuery(sql);
+
+            String caseNumberId = "";
+            Map<String, String> m = new HashMap<>();
+            while (rs.next()) {
+                r1 = rs.getString(1);
+                r2 = rs.getString(2);
+                r3 = rs.getString(3);
+                if (!caseNumberId.equals(String.valueOf(r2)) && StringUtils.isNotEmpty(caseNumberId)) {
+                    result.put(r2, m);
+                    m = new HashMap<>();
+                }
+                m.put(r3, r1);
+            }
+        } catch (SQLException sqle) {
+            sqle.printStackTrace();
+        } catch (Exception e) {
+            e.printStackTrace();
+        } finally {
+            mysqlJdbc.close(rs, st, conn);
+        }
+        return result;
+    }
+
     @ApiOperation(value = "质控测试接口，无需token信息", notes = "")
     @PostMapping("rec_test")
     public Response<OutputInfo> extract(String caseIds, int length, String cid, String txtId, String hospitalId) {