diff --git a/yudao-module-inspect/yudao-module-inspect-biz/src/main/java/cn/iocoder/yudao/module/inspect/controller/admin/inspectpatient/InspectPatientController.java b/yudao-module-inspect/yudao-module-inspect-biz/src/main/java/cn/iocoder/yudao/module/inspect/controller/admin/inspectpatient/InspectPatientController.java index 3bb671a..d33724e 100644 --- a/yudao-module-inspect/yudao-module-inspect-biz/src/main/java/cn/iocoder/yudao/module/inspect/controller/admin/inspectpatient/InspectPatientController.java +++ b/yudao-module-inspect/yudao-module-inspect-biz/src/main/java/cn/iocoder/yudao/module/inspect/controller/admin/inspectpatient/InspectPatientController.java @@ -89,7 +89,7 @@ import java.util.Locale; @RequestMapping("/inspect/patient") @Validated public class InspectPatientController { - // private static final AtomicInteger counter = new AtomicInteger(0); + // private static final AtomicInteger counter = new AtomicInteger(0); @Resource private InspectPatientService patientService; @Resource @@ -345,8 +345,8 @@ public class InspectPatientController { LocalDate currentDate = LocalDate.now(); String datePart = currentDate.format(DateTimeFormatter.ofPattern("yyyyMMdd")); // 生成一个6位的序列号 - // int sequenceNumber = counter.incrementAndGet() % 1000000; // 确保序列号是6位数 - // String sequencePart = datePart + String.format("%06d", sequenceNumber); + // int sequenceNumber = counter.incrementAndGet() % 1000000; // 确保序列号是6位数 + // String sequencePart = datePart + String.format("%06d", sequenceNumber); // 生成一个唯一的6位的随机数 Random random = new Random(); String sequencePart; @@ -664,12 +664,12 @@ public class InspectPatientController { case "WBC": case "NIT": if (result.getItemValue() != null && result.getItemValue().contains("+")) { - ncgsb.append("【" + result.getItemName() + "：" + "阳性,值为:" +result.getItemValue()+ "】" + "\n"); + ncgsb.append("【" + result.getItemName() + "：" + "阳性,值为:" + result.getItemValue() + "】" + "\n"); } break; case "URO": if (result.getItemValue() != null && !result.getItemValue().contains("Normal")) { - ncgsb.append("【" + result.getItemName() + "：" + "该项异常,值为:" +result.getItemValue()+ "】" + "\n"); + ncgsb.append("【" + result.getItemName() + "：" + "该项异常,值为:" + result.getItemValue() + "】" + "\n"); } break; case "PRO": @@ -678,29 +678,25 @@ public class InspectPatientController { case "KET": case "GLU": if (result.getItemValue() != null && result.getItemValue().contains("+")) { - ncgsb.append("【" + result.getItemName() + "：" + "阳性,值为:" +result.getItemValue()+ "】" + "\n"); + ncgsb.append("【" + result.getItemName() + "：" + "阳性,值为:" + result.getItemValue() + "】" + "\n"); } break; - case "PH": + case "PH": if (result.getItemValue() != null) { - if(NumberUtils.isNumeric(result.getItemValue())) - { + if (NumberUtils.isNumeric(result.getItemValue())) { double ph = Double.parseDouble(result.getItemValue()); - if(ph<5.0 || ph>8.0) - { - ncgsb.append("【" + result.getItemName() + "：" + "该项异常,值为:" +result.getItemValue()+ "】" + "\n"); + if (ph < 5.0 || ph > 8.0) { + ncgsb.append("【" + result.getItemName() + "：" + "该项异常,值为:" + result.getItemValue() + "】" + "\n"); } - } + } } break; case "SG": if (result.getItemValue() != null) { - if(NumberUtils.isNumeric(result.getItemValue())) - { + if (NumberUtils.isNumeric(result.getItemValue())) { double sg = Double.parseDouble(result.getItemValue()); - if(sg<1.015 || sg>1.025) - { - ncgsb.append("【" + result.getItemName() + "：" + "该项异常,值为:" +result.getItemValue()+ "】" + "\n"); + if (sg < 1.015 || sg > 1.025) { + ncgsb.append("【" + result.getItemName() + "：" + "该项异常,值为:" + result.getItemValue() + "】" + "\n"); } } } @@ -719,7 +715,6 @@ public class InspectPatientController { // break; - } } @@ -739,6 +734,189 @@ public class InspectPatientController { } return success(true); } + @GetMapping("/PushJYPatientInfo") + @Operation(summary = "回传体检相关信息") + public CommonResult PushJYPatientInfo(@RequestParam("medicalSn") String medicalSn) throws JsonProcessingException { + //获取患者信息 + InspectPatientDO patientDO = patientService.getPatientInfo(medicalSn); + if (patientDO != null) { + if (patientDO.getNcgcode() != null && patientDO.getXcgcode() != null && patientDO.getShqx() != null) { + // 定义条形码列表 + List barcodes = Arrays.asList( + patientDO.getNcgcode(), + patientDO.getXcgcode(), + patientDO.getShqx() + ); + ConfigDO config = configService.getConfigByKey("url.reporttj"); + String url = config.getValue(); + //返回实体类 + PatientJYInfoVO patientJYInfoVO = new PatientJYInfoVO(); + //先添加基本信息 + patientJYInfoVO.setPatientname(patientDO.getPName()); + patientJYInfoVO.setIdcard(patientDO.getCardId()); + patientJYInfoVO.setExamindate(patientDO.getMedicalDateTime().toString()); + //心电图信息 + InspectPacsDataDO ecg = pacsDataService.getPacsDataByCode(medicalSn,"ecg"); + if(ecg!=null) + { + if(ecg.getData()!=null) + { + patientJYInfoVO.setElectrokardiagramtypeid(1); + patientJYInfoVO.setElectrocardiogramimg(ecg.getData()); + } + } + for (String barCode : barcodes) { + String response = HttpUtils.get(url + "?" + "barCode=" + barCode + "&" + "hospitalCode=" + patientDO.getHospitalNo()); + if (response != null) { + // 解析 JSON 响应 + ObjectMapper objectMapper = new ObjectMapper(); + try { + ReportResponse reportResponse = objectMapper.readValue(response, ReportResponse.class); + if ("操作成功".equals(reportResponse.getMsg()) && reportResponse.getCode() == 200) { + ReportData reportData = reportResponse.getData(); + // 获取 reportPath + String reportPath = reportData.getReportPath(); + if (!reportPath.contains("报告暂未出")) { + + if (reportData.getResultsAll() != null && reportData.getResultsAll().size() > 0) { + // 获取 results 数组并遍历 + List results = reportData.getResultsAll(); + for (ResultItem result : results) { + switch (result.getItemCode()) { + case "HGB"://血常规血红蛋白 + if (result.getItemValue() != null) { + if (NumberUtils.isNumeric(result.getItemValue())) { + double value = Double.parseDouble(result.getItemValue()); + patientJYInfoVO.setHemoglobin(value); + } + } + break; + case "WBC"://血常规白细胞 + if (result.getItemValue() != null) { + if (NumberUtils.isNumeric(result.getItemValue())) { + double value = Double.parseDouble(result.getItemValue()); + patientJYInfoVO.setLeukocyte(value); + } + } + break; + case "PLT"://血常规血小板 + if (result.getItemValue() != null) { + if (NumberUtils.isNumeric(result.getItemValue())) { + double value = Double.parseDouble(result.getItemValue()); + patientJYInfoVO.setBloodplatelet(value); + } + } + break; + case "PRO"://尿常规尿蛋白 + if (result.getItemValue() != null) + { + patientJYInfoVO.setUrineprotein(result.getItemValue()); + } + break; + case "GLU"://尿常规尿糖 + if (result.getItemValue() != null) + { + patientJYInfoVO.setUrinesugar(result.getItemValue()); + } + case "KET"://尿常规尿酮体 + if (result.getItemValue() != null) + { + patientJYInfoVO.setUnrineketone(result.getItemValue()); + } + break; + case "BLD"://尿常规潜血 + if (result.getItemValue() != null) + { + patientJYInfoVO.setUnrineoccultblood(result.getItemValue()); + } + break; + case "RBC"://血常规红细胞 + if (result.getItemValue() != null) { + if (NumberUtils.isNumeric(result.getItemValue())) { + double value = Double.parseDouble(result.getItemValue()); + patientJYInfoVO.setErythrocyte(value); + } + } + break; + case "TG"://甘油三酯 + if (result.getItemValue() != null) { + if (NumberUtils.isNumeric(result.getItemValue())) { + double value = Double.parseDouble(result.getItemValue()); + patientJYInfoVO.setTriglycercide(value); + } + } + break; + case "TC"://总胆固醇 + if (result.getItemValue() != null) { + if (NumberUtils.isNumeric(result.getItemValue())) { + double value = Double.parseDouble(result.getItemValue()); + patientJYInfoVO.setTotalcholesterol(value); + } + } + break; + case "LDL-C"://低密度脂蛋白胆固醇 + if (result.getItemValue() != null) { + if (NumberUtils.isNumeric(result.getItemValue())) { + double value = Double.parseDouble(result.getItemValue()); + patientJYInfoVO.setLdlc(value); + } + } + break; + case "HDL-C"://高密度脂蛋白胆固醇 + if (result.getItemValue() != null) { + if (NumberUtils.isNumeric(result.getItemValue())) { + double value = Double.parseDouble(result.getItemValue()); + patientJYInfoVO.setHdlc(value); + } + } + break; + } + + } + + } + + + } + + } + } catch (IOException e) { + e.printStackTrace(); + return success(true); + } + } + } + + //获取配置项地址 + ConfigDO configDO = configService.getConfigByKey("url.tjhc"); + // 发送 POST 请求 + String doValue = configDO.getValue(); + // 创建 ObjectMapper 实例 + ObjectMapper objectMapper = new ObjectMapper(); + // 将 Java 对象转换为 JSON 字符串 + String jsonRequestBody = objectMapper.writeValueAsString(patientJYInfoVO); + + // 记录接口返回值 + InspectApplylogSaveReqVO responseLogVO = new InspectApplylogSaveReqVO(); + responseLogVO.setTime(LocalDateTime.now()); + responseLogVO.setMedicalsn(patientDO.getMedicalSn()); + responseLogVO.setIdcard(patientDO.getCardId()); + responseLogVO.setJson(jsonRequestBody); + applylogService.createApplylog(responseLogVO); + String response = HttpUtils.postJson(doValue, jsonRequestBody); + // 记录接口返回值 + InspectApplylogSaveReqVO responseLogVO1 = new InspectApplylogSaveReqVO(); + responseLogVO1.setTime(LocalDateTime.now()); + responseLogVO1.setMedicalsn(patientDO.getMedicalSn()); + responseLogVO1.setIdcard(patientDO.getCardId()); + responseLogVO1.setJson(response); + applylogService.createApplylog(responseLogVO1); + } + + + } + return success(true); + } @GetMapping("/getUSTj") @Operation(summary = "获取超声报告") @@ -1043,7 +1221,7 @@ public class InspectPatientController { for (Map.Entry entry : dataMap.entrySet()) { String key = entry.getKey(); Object value = entry.getValue(); - if (value == null) value="";//一般检查可能为NULL + if (value == null) value = "";//一般检查可能为NULL InspectPatientitemsSaveReqVO inspectPatientitemsSaveReqVO = null; switch (key) { case "temperature": @@ -1188,15 +1366,13 @@ public class InspectPatientController { InspectPatientDO patient = patientService.getPatient(id); return success(BeanUtils.toBean(patient, InspectPatientRespVO.class)); } + @GetMapping("/MedicalSnPatientInfo") @Operation(summary = "获得患者信息 对外暴露") - public CommonResult getMedicalSnPatientInfo(@RequestParam("medicalSn") String medicalSn) - { - if(medicalSn!=null&&!medicalSn.isEmpty()) - { - InspectPatientDO patientDO= patientService.getPatientOfMedicalSn(medicalSn); - if(patientDO!=null) - { + public CommonResult getMedicalSnPatientInfo(@RequestParam("medicalSn") String medicalSn) { + if (medicalSn != null && !medicalSn.isEmpty()) { + InspectPatientDO patientDO = patientService.getPatientOfMedicalSn(medicalSn); + if (patientDO != null) { PersonalInfoVO personalInfoVO = new PersonalInfoVO(); personalInfoVO.setIdCard(patientDO.getCardId()); personalInfoVO.setName(patientDO.getPName()); @@ -1206,13 +1382,10 @@ public class InspectPatientController { personalInfoVO.setAddress(patientDO.getDomicileaddress()); personalInfoVO.setTelephone(patientDO.getPhoneNum()); return success(personalInfoVO); - } - else - { + } else { return success("未查询到体检信息"); } - } - else { + } else { return success("体检编号为空"); } diff --git a/yudao-module-inspect/yudao-module-inspect-biz/src/main/java/cn/iocoder/yudao/module/inspect/controller/admin/inspectpatient/vo/PatientJYInfoVO.java b/yudao-module-inspect/yudao-module-inspect-biz/src/main/java/cn/iocoder/yudao/module/inspect/controller/admin/inspectpatient/vo/PatientJYInfoVO.java new file mode 100644 index 0000000..82a1b27 --- /dev/null +++ b/yudao-module-inspect/yudao-module-inspect-biz/src/main/java/cn/iocoder/yudao/module/inspect/controller/admin/inspectpatient/vo/PatientJYInfoVO.java @@ -0,0 +1,134 @@ +package cn.iocoder.yudao.module.inspect.controller.admin.inspectpatient.vo; + +import io.swagger.v3.oas.annotations.media.Schema; +import lombok.Data; + +@Data +public class PatientJYInfoVO { + + @Schema(description = "姓名") + private String patientname; + + @Schema(description = "身份证号") + private String idcard; + + @Schema(description = "体检日期") + private String examindate; + + @Schema(description = "血红蛋白") + private double hemoglobin; + + @Schema(description = "白细胞") + private double leukocyte; + + @Schema(description = "血小板") + private double bloodplatelet; + + @Schema(description = "红细胞") + private double erythrocyte; + + @Schema(description = "其他常规") + private String otherroutine; + + @Schema(description = "尿蛋白") + private String urineprotein; + + @Schema(description = "尿糖") + private String urinesugar; + + @Schema(description = "尿酮体") + private String unrineketone; + + @Schema(description = "尿潜血") + private String unrineoccultblood; + + @Schema(description = "尿微量白蛋白") + private double unrinemicroalbumin; + + @Schema(description = "其他尿常规") + private String otherunrineroutine; + + @Schema(description = "心电图类型ID") + private int electrokardiagramtypeid; + + @Schema(description = "心电图类型") + private String electrokardiagramtype; + + @Schema(description = "心电图图片") + private String electrocardiogramimg; + + @Schema(description = "SGPT") + private double sgpt; + + @Schema(description = "SGOT") + private double sgot; + + @Schema(description = "白蛋白") + private double albumen; + + @Schema(description = "总胆红素") + private double totalbilirubin; + + @Schema(description = "结合胆红素") + private double conjugatedbilirubin; + + @Schema(description = "血肌酐") + private double serumcreatinine; + + @Schema(description = "尿素氮") + private double bun; + + @Schema(description = "血钾") + private double serumpotassium; + + @Schema(description = "血钠") + private double serumsodium; + + @Schema(description = "低密度脂蛋白胆固醇") + private double ldlc; + + @Schema(description = "高密度脂蛋白胆固醇") + private double hdlc; + + @Schema(description = "甘油三酯") + private double triglycercide; + + @Schema(description = "总胆固醇") + private double totalcholesterol; + + @Schema(description = "空腹血糖（mmol/L）") + private double fastplasmaglucoseml; + + @Schema(description = "空腹血糖（mg/dL）") + private double fastplasmaglucosemgl; + + @Schema(description = "粪便潜血类型ID") + private int fecaloccbloodtypeid; + + @Schema(description = "糖化血红蛋白") + private double glycatedhemog; + + @Schema(description = "HBsAg类型ID") + private int hbsagid; + + @Schema(description = "HBsAg") + private String hbsag; + + @Schema(description = "胸片类型ID") + private int chestxrayid; + + @Schema(description = "胸片") + private String chestxray; + + @Schema(description = "超声类型ID") + private int bultrasoundid; + + @Schema(description = "超声") + private String bultrasound; + + @Schema(description = "随机血糖（mmol/L）") + private String randomglucosemml; + + @Schema(description = "随机血糖（mg/dL）") + private String randomglucosemgl; +} diff --git a/yudao-module-inspect/yudao-module-inspect-biz/src/main/java/cn/iocoder/yudao/module/inspect/service/inspectpacsdata/InspectPacsDataService.java b/yudao-module-inspect/yudao-module-inspect-biz/src/main/java/cn/iocoder/yudao/module/inspect/service/inspectpacsdata/InspectPacsDataService.java index 546ef2e..f6ab5c3 100644 --- a/yudao-module-inspect/yudao-module-inspect-biz/src/main/java/cn/iocoder/yudao/module/inspect/service/inspectpacsdata/InspectPacsDataService.java +++ b/yudao-module-inspect/yudao-module-inspect-biz/src/main/java/cn/iocoder/yudao/module/inspect/service/inspectpacsdata/InspectPacsDataService.java @@ -62,6 +62,11 @@ public interface InspectPacsDataService { * 根据体检编号和类型判断是否存在pacs数据 * */ Boolean IspacsDataExist(String code, String type); + /* + * 根据体检编号和类型查询指定数据 + * */ + InspectPacsDataDO getPacsDataByCode(String code, String type); + /* * * 根据体检编号和类型判断是否存在pacs的item数据 diff --git a/yudao-module-inspect/yudao-module-inspect-biz/src/main/java/cn/iocoder/yudao/module/inspect/service/inspectpacsdata/InspectPacsDataServiceImpl.java b/yudao-module-inspect/yudao-module-inspect-biz/src/main/java/cn/iocoder/yudao/module/inspect/service/inspectpacsdata/InspectPacsDataServiceImpl.java index 519b60f..a944da5 100644 --- a/yudao-module-inspect/yudao-module-inspect-biz/src/main/java/cn/iocoder/yudao/module/inspect/service/inspectpacsdata/InspectPacsDataServiceImpl.java +++ b/yudao-module-inspect/yudao-module-inspect-biz/src/main/java/cn/iocoder/yudao/module/inspect/service/inspectpacsdata/InspectPacsDataServiceImpl.java @@ -96,6 +96,13 @@ public class InspectPacsDataServiceImpl implements InspectPacsDataService { queryWrapper.eq("type", type); return pacsDataMapper.selectList(queryWrapper).size()>0? true:false; } + @Override + public InspectPacsDataDO getPacsDataByCode(String code,String type) { + QueryWrapper queryWrapper = new QueryWrapper<>(); + queryWrapper.eq("code", code); + queryWrapper.eq("type", type); + return pacsDataMapper.selectOne(queryWrapper); + } @Override public Boolean IspacsDataitemExist(String code, String type) {