From a332e4fe3a5141a586ae11edf1b4d9a946a1fbc6 Mon Sep 17 00:00:00 2001 From: jiangs <373297395@qq.com> Date: Fri, 5 Jun 2026 17:59:16 +0800 Subject: [PATCH] =?UTF-8?q?=E6=8E=A5=E5=8F=A3=E8=B0=83=E6=95=B4=E5=92=8C?= =?UTF-8?q?=E8=BE=93=E8=A1=80=E5=89=8D=E8=AF=84=E4=BC=B0=E4=B8=9A=E5=8A=A1?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/czblood/bus/cache/OptionCache.java | 67 ++++++++++++++++ .../BloodInterfaceTypeConstants.java | 16 ++++ .../bus/controller/BloodCommonController.java | 17 +++++ .../czblood/bus/enums/BloodInterfaceType.java | 26 ------- .../czblood/bus/mapper/XkParameterMapper.java | 7 ++ .../XkTransfuseApplyTestitemMapper.java | 9 +++ .../com/czblood/bus/pojo/XkParameter.java | 21 +++++ .../bus/pojo/XkTransfuseApplyTestitem.java | 20 +++++ .../bus/pojo/inter/BloodInterfaceStr.java | 14 ---- .../bus/pojo/inter/BloodInterfaceType.java | 5 ++ .../bus/pojo/inter/GetPatientInfoRequest.java | 26 +++++++ .../bus/pojo/inter/GetTestResultRequest.java | 25 ++++++ .../bus/pojo/inter/SqdAuditRequest.java | 10 ++- .../com/czblood/bus/utils/BloodBankUtil.java | 21 +++++ .../czblood/bus/utils/BloodInterfaceUtil.java | 23 +++--- .../resources/mapper/XkParameterMapper.xml | 8 ++ .../mapper/XkTransfuseApplyTestitemMapper.xml | 8 ++ .../TransfuseApplyBeforeController.java | 31 +++++++- .../pojo/TransfuseApplyBeforeDTO.java | 23 ++++++ .../service/TransfuseApplyBeforeService.java | 13 ++++ .../impl/TransfuseApplyBeforeServiceImpl.java | 76 +++++++++++++++++++ .../common/constant/CacheConstants.java | 2 +- 22 files changed, 411 insertions(+), 57 deletions(-) create mode 100644 blood_bus/src/main/java/com/czblood/bus/cache/OptionCache.java create mode 100644 blood_bus/src/main/java/com/czblood/bus/constants/BloodInterfaceTypeConstants.java delete mode 100644 blood_bus/src/main/java/com/czblood/bus/enums/BloodInterfaceType.java create mode 100644 blood_bus/src/main/java/com/czblood/bus/mapper/XkParameterMapper.java create mode 100644 blood_bus/src/main/java/com/czblood/bus/mapper/XkTransfuseApplyTestitemMapper.java create mode 100644 blood_bus/src/main/java/com/czblood/bus/pojo/XkParameter.java create mode 100644 blood_bus/src/main/java/com/czblood/bus/pojo/XkTransfuseApplyTestitem.java delete mode 100644 blood_bus/src/main/java/com/czblood/bus/pojo/inter/BloodInterfaceStr.java create mode 100644 blood_bus/src/main/java/com/czblood/bus/pojo/inter/BloodInterfaceType.java create mode 100644 blood_bus/src/main/java/com/czblood/bus/pojo/inter/GetPatientInfoRequest.java create mode 100644 blood_bus/src/main/java/com/czblood/bus/pojo/inter/GetTestResultRequest.java create mode 100644 blood_bus/src/main/resources/mapper/XkParameterMapper.xml create mode 100644 blood_bus/src/main/resources/mapper/XkTransfuseApplyTestitemMapper.xml create mode 100644 blood_bus_doctor/src/main/java/com/czblood/busDoctor/pojo/TransfuseApplyBeforeDTO.java create mode 100644 blood_bus_doctor/src/main/java/com/czblood/busDoctor/service/TransfuseApplyBeforeService.java create mode 100644 blood_bus_doctor/src/main/java/com/czblood/busDoctor/service/impl/TransfuseApplyBeforeServiceImpl.java diff --git a/blood_bus/src/main/java/com/czblood/bus/cache/OptionCache.java b/blood_bus/src/main/java/com/czblood/bus/cache/OptionCache.java new file mode 100644 index 0000000..93f7eb6 --- /dev/null +++ b/blood_bus/src/main/java/com/czblood/bus/cache/OptionCache.java @@ -0,0 +1,67 @@ +package com.czblood.bus.cache; + +import com.alibaba.fastjson2.JSONArray; +import com.czblood.bus.pojo.XkDmzd; +import com.czblood.bus.pojo.XkParameter; +import com.czblood.common.constant.CacheConstants; +import com.czblood.common.core.redis.RedisCache; +import com.czblood.common.utils.StringUtils; +import com.czblood.common.utils.spring.SpringUtils; + +import java.util.Collection; +import java.util.List; + +/** + * 参数缓存 + */ +public class OptionCache { + + /** + * 设置字典缓存 + * + * @param key 参数键 + * @param xkParameter 参数值 + */ + public static void setDictCache(String key, XkParameter xkParameter) { + removeDictCache( key); + SpringUtils.getBean(RedisCache.class).setCacheObject(getCacheKey(key), xkParameter); + } + + /** + * 获取字典缓存 + * + * @param key 参数键 + * @return dictDatas 字典数据列表 + */ + public static XkParameter getOptCache(String key) { + return SpringUtils.getBean(RedisCache.class).getCacheObject(getCacheKey(key)); + } + + /** + * 删除指定字典缓存 + * + * @param key 字典键 + */ + public static void removeDictCache(String key) { + SpringUtils.getBean(RedisCache.class).deleteObject(getCacheKey(key)); + } + + /** + * 清空字典缓存 + */ + public static void clearDictCache() { + Collection keys = SpringUtils.getBean(RedisCache.class).keys(CacheConstants.XK_PARAMETER_KEY + "*"); + SpringUtils.getBean(RedisCache.class).deleteObject(keys); + } + + + /** + * 设置cache key + * + * @param configKey 参数键 + * @return 缓存键key + */ + public static String getCacheKey(String configKey) { + return CacheConstants.XK_PARAMETER_KEY + configKey; + } +} diff --git a/blood_bus/src/main/java/com/czblood/bus/constants/BloodInterfaceTypeConstants.java b/blood_bus/src/main/java/com/czblood/bus/constants/BloodInterfaceTypeConstants.java new file mode 100644 index 0000000..1366209 --- /dev/null +++ b/blood_bus/src/main/java/com/czblood/bus/constants/BloodInterfaceTypeConstants.java @@ -0,0 +1,16 @@ +package com.czblood.bus.constants; + +public class BloodInterfaceTypeConstants { + /** + * 申请单审核 + */ + public static final String SQD_AUDIT = "SQD_AUDIT"; + /** + * 获取检验结果 + */ + public static final String GET_TEST_RESULT = "GET_TEST_RESULT"; + /** + * 获取患者信息 + */ + public static final String GET_PATIENT_INFO = "GET_PATIENT_INFO"; +} diff --git a/blood_bus/src/main/java/com/czblood/bus/controller/BloodCommonController.java b/blood_bus/src/main/java/com/czblood/bus/controller/BloodCommonController.java index d5ae66a..f64b15e 100644 --- a/blood_bus/src/main/java/com/czblood/bus/controller/BloodCommonController.java +++ b/blood_bus/src/main/java/com/czblood/bus/controller/BloodCommonController.java @@ -1,10 +1,12 @@ package com.czblood.bus.controller; +import com.czblood.bus.cache.OptionCache; import com.czblood.bus.mapper.XkProTransfuseProjectMapper; import com.czblood.bus.pojo.XkDmzd; import com.czblood.bus.pojo.XkProTransfuseProject; import com.czblood.bus.utils.BloodBankUtil; import com.czblood.common.core.domain.Result; +import com.czblood.system.util.CommonUtil; import io.swagger.annotations.Api; import io.swagger.annotations.ApiOperation; import org.springframework.web.bind.annotation.*; @@ -21,6 +23,8 @@ public class BloodCommonController { private XkProTransfuseProjectMapper xkProTransfuseProjectMapper; @Resource private BloodBankUtil bloodBankUtil; + @Resource + CommonUtil commonUtil; @ApiOperation("获取输血前检验项目") @PostMapping("/queryLisProject") @@ -42,4 +46,17 @@ public class BloodCommonController { XkDmzd dictCacheOne = bloodBankUtil.getDictCacheOne(dictType, dictCode); return new Result("0","获取数据成功！",dictCacheOne); } + @ApiOperation("获取当前服务器时间") + @GetMapping("/currentDateTime") + public Result getCurrentDateTime(){ + return new Result("0","获取数据成功",commonUtil.getCurrentTime()); + } + + + @ApiOperation("获取参数的值") + @GetMapping("/getParameterOne") + public Result getParameterOne(String parameterCode){ + String parameterValue = bloodBankUtil.getParameterValue(parameterCode); + return new Result("0","获取参数成功！",parameterValue); + } } diff --git a/blood_bus/src/main/java/com/czblood/bus/enums/BloodInterfaceType.java b/blood_bus/src/main/java/com/czblood/bus/enums/BloodInterfaceType.java deleted file mode 100644 index 19bcac0..0000000 --- a/blood_bus/src/main/java/com/czblood/bus/enums/BloodInterfaceType.java +++ /dev/null @@ -1,26 +0,0 @@ -package com.czblood.bus.enums; - -import com.czblood.bus.pojo.inter.SqdAuditRequest; - -public enum BloodInterfaceType { - /** - * 申请单审核 - */ - SQD_AUDIT("SQD_AUDIT",SqdAuditRequest.class); - - private final String type; - private final Class dataType; // 用 ? 通配符 - - BloodInterfaceType(String type, Class dataType) { - this.type = type; - this.dataType = dataType; - } - - public String getType() { - return type; - } - - public Class getDataType() { - return dataType; - } -} diff --git a/blood_bus/src/main/java/com/czblood/bus/mapper/XkParameterMapper.java b/blood_bus/src/main/java/com/czblood/bus/mapper/XkParameterMapper.java new file mode 100644 index 0000000..fe972b0 --- /dev/null +++ b/blood_bus/src/main/java/com/czblood/bus/mapper/XkParameterMapper.java @@ -0,0 +1,7 @@ +package com.czblood.bus.mapper; + +import com.czblood.bus.pojo.XkParameter; + +public interface XkParameterMapper { + XkParameter queryOne(String parameter_code); +} diff --git a/blood_bus/src/main/java/com/czblood/bus/mapper/XkTransfuseApplyTestitemMapper.java b/blood_bus/src/main/java/com/czblood/bus/mapper/XkTransfuseApplyTestitemMapper.java new file mode 100644 index 0000000..6a877aa --- /dev/null +++ b/blood_bus/src/main/java/com/czblood/bus/mapper/XkTransfuseApplyTestitemMapper.java @@ -0,0 +1,9 @@ +package com.czblood.bus.mapper; + +import com.czblood.bus.pojo.XkTransfuseApplyTestitem; + +import java.util.List; + +public interface XkTransfuseApplyTestitemMapper { + List queryList(String bill_no); +} diff --git a/blood_bus/src/main/java/com/czblood/bus/pojo/XkParameter.java b/blood_bus/src/main/java/com/czblood/bus/pojo/XkParameter.java new file mode 100644 index 0000000..ad209bf --- /dev/null +++ b/blood_bus/src/main/java/com/czblood/bus/pojo/XkParameter.java @@ -0,0 +1,21 @@ +package com.czblood.bus.pojo; + +import lombok.AllArgsConstructor; +import lombok.Data; +import lombok.NoArgsConstructor; + +import java.util.Date; + +@Data +@AllArgsConstructor +@NoArgsConstructor +public class XkParameter { + private String parameter_code; + private String module_code; + private String parameter_name; + private String parameter_value; + private String parameter_default; + private String parameter_bound; + private String parameter_remark; + private Date last_modified; +} diff --git a/blood_bus/src/main/java/com/czblood/bus/pojo/XkTransfuseApplyTestitem.java b/blood_bus/src/main/java/com/czblood/bus/pojo/XkTransfuseApplyTestitem.java new file mode 100644 index 0000000..0e73373 --- /dev/null +++ b/blood_bus/src/main/java/com/czblood/bus/pojo/XkTransfuseApplyTestitem.java @@ -0,0 +1,20 @@ +package com.czblood.bus.pojo; + +import lombok.AllArgsConstructor; +import lombok.Data; +import lombok.NoArgsConstructor; + +import java.util.Date; + +@Data +@AllArgsConstructor +@NoArgsConstructor +public class XkTransfuseApplyTestitem { + private String bill_no; + private Integer sid; + private String item_name; + private String item_result; + private String Item_unit; + private Date test_date; + private String upload_flag; +} diff --git a/blood_bus/src/main/java/com/czblood/bus/pojo/inter/BloodInterfaceStr.java b/blood_bus/src/main/java/com/czblood/bus/pojo/inter/BloodInterfaceStr.java deleted file mode 100644 index 40394e9..0000000 --- a/blood_bus/src/main/java/com/czblood/bus/pojo/inter/BloodInterfaceStr.java +++ /dev/null @@ -1,14 +0,0 @@ -package com.czblood.bus.pojo.inter; - -import com.czblood.bus.enums.BloodInterfaceType; -import lombok.AllArgsConstructor; -import lombok.Data; -import lombok.NoArgsConstructor; - -@Data -@AllArgsConstructor -@NoArgsConstructor -public class BloodInterfaceStr { - public BloodInterfaceType bloodInterfaceType; - public T data; -} diff --git a/blood_bus/src/main/java/com/czblood/bus/pojo/inter/BloodInterfaceType.java b/blood_bus/src/main/java/com/czblood/bus/pojo/inter/BloodInterfaceType.java new file mode 100644 index 0000000..0639c46 --- /dev/null +++ b/blood_bus/src/main/java/com/czblood/bus/pojo/inter/BloodInterfaceType.java @@ -0,0 +1,5 @@ +package com.czblood.bus.pojo.inter; + +public interface BloodInterfaceType { + public String serializationJson(); +} diff --git a/blood_bus/src/main/java/com/czblood/bus/pojo/inter/GetPatientInfoRequest.java b/blood_bus/src/main/java/com/czblood/bus/pojo/inter/GetPatientInfoRequest.java new file mode 100644 index 0000000..8f05ca1 --- /dev/null +++ b/blood_bus/src/main/java/com/czblood/bus/pojo/inter/GetPatientInfoRequest.java @@ -0,0 +1,26 @@ +package com.czblood.bus.pojo.inter; + +import cn.hutool.json.JSONUtil; +import com.czblood.bus.constants.BloodInterfaceTypeConstants; +import io.swagger.annotations.ApiModelProperty; +import lombok.AllArgsConstructor; +import lombok.Data; +import lombok.NoArgsConstructor; + +/** + * 获取病人基本信息 + */ +@Data +@AllArgsConstructor +@NoArgsConstructor +public class GetPatientInfoRequest implements BloodInterfaceType { + + private final String method = BloodInterfaceTypeConstants.GET_PATIENT_INFO; + @ApiModelProperty("住院号") + private String beinhos_id; + + @Override + public String serializationJson() { + return JSONUtil.toJsonStr(this); + } +} diff --git a/blood_bus/src/main/java/com/czblood/bus/pojo/inter/GetTestResultRequest.java b/blood_bus/src/main/java/com/czblood/bus/pojo/inter/GetTestResultRequest.java new file mode 100644 index 0000000..139b8f9 --- /dev/null +++ b/blood_bus/src/main/java/com/czblood/bus/pojo/inter/GetTestResultRequest.java @@ -0,0 +1,25 @@ +package com.czblood.bus.pojo.inter; + +import cn.hutool.json.JSONUtil; +import com.czblood.bus.constants.BloodInterfaceTypeConstants; +import io.swagger.annotations.ApiModelProperty; +import lombok.AllArgsConstructor; +import lombok.Data; +import lombok.NoArgsConstructor; + +/** + * 获取检验结果 + */ +@Data +@AllArgsConstructor +@NoArgsConstructor +public class GetTestResultRequest implements BloodInterfaceType { + private final String method = BloodInterfaceTypeConstants.GET_TEST_RESULT; + @ApiModelProperty("住院号") + private String beinhos_id; + + @Override + public String serializationJson() { + return JSONUtil.toJsonStr( this); + } +} diff --git a/blood_bus/src/main/java/com/czblood/bus/pojo/inter/SqdAuditRequest.java b/blood_bus/src/main/java/com/czblood/bus/pojo/inter/SqdAuditRequest.java index 3e49eac..acc274a 100644 --- a/blood_bus/src/main/java/com/czblood/bus/pojo/inter/SqdAuditRequest.java +++ b/blood_bus/src/main/java/com/czblood/bus/pojo/inter/SqdAuditRequest.java @@ -1,5 +1,7 @@ package com.czblood.bus.pojo.inter; +import cn.hutool.json.JSONUtil; +import com.czblood.bus.constants.BloodInterfaceTypeConstants; import lombok.AllArgsConstructor; import lombok.Data; import lombok.NoArgsConstructor; @@ -10,7 +12,8 @@ import lombok.NoArgsConstructor; @Data @AllArgsConstructor @NoArgsConstructor -public class SqdAuditRequest { +public class SqdAuditRequest implements BloodInterfaceType { + private final String method = BloodInterfaceTypeConstants.SQD_AUDIT; /** * 申请单编号 */ @@ -19,4 +22,9 @@ public class SqdAuditRequest { * 申请单状态 */ private String billStatus; + + @Override + public String serializationJson() { + return JSONUtil.toJsonStr(this); + } } diff --git a/blood_bus/src/main/java/com/czblood/bus/utils/BloodBankUtil.java b/blood_bus/src/main/java/com/czblood/bus/utils/BloodBankUtil.java index 9746b11..344c14f 100644 --- a/blood_bus/src/main/java/com/czblood/bus/utils/BloodBankUtil.java +++ b/blood_bus/src/main/java/com/czblood/bus/utils/BloodBankUtil.java @@ -2,8 +2,13 @@ package com.czblood.bus.utils; import com.czblood.bus.cache.DmzdCache; +import com.czblood.bus.cache.OptionCache; import com.czblood.bus.mapper.XkDmzdMapper; +import com.czblood.bus.mapper.XkParameterMapper; import com.czblood.bus.pojo.XkDmzd; +import com.czblood.bus.pojo.XkParameter; +import com.czblood.common.core.domain.Result; +import org.springframework.data.redis.connection.ReactiveSubscription; import org.springframework.stereotype.Component; import javax.annotation.Resource; @@ -15,6 +20,8 @@ public class BloodBankUtil { @Resource XkDmzdMapper xkDmzdMapper; + @Resource + XkParameterMapper xkParameterMapper; /** @@ -54,5 +61,19 @@ public class BloodBankUtil { } } + /** + * 根据参数编码获取参数值 + * @param parameterCode + * @return + */ + public String getParameterValue(String parameterCode){ + XkParameter parameterCache = OptionCache.getOptCache(parameterCode); + if(parameterCache == null){ + XkParameter xkParameter = xkParameterMapper.queryOne(parameterCode); + return xkParameter.getParameter_value(); + } + return ""; + } + } diff --git a/blood_bus/src/main/java/com/czblood/bus/utils/BloodInterfaceUtil.java b/blood_bus/src/main/java/com/czblood/bus/utils/BloodInterfaceUtil.java index 6674d6b..36aaab0 100644 --- a/blood_bus/src/main/java/com/czblood/bus/utils/BloodInterfaceUtil.java +++ b/blood_bus/src/main/java/com/czblood/bus/utils/BloodInterfaceUtil.java @@ -4,12 +4,10 @@ import cn.hutool.http.HttpRequest; import cn.hutool.http.HttpResponse; import cn.hutool.json.JSONObject; import cn.hutool.json.JSONUtil; -import com.czblood.bus.enums.BloodInterfaceType; -import com.czblood.bus.pojo.inter.BloodInterfaceStr; +import com.czblood.bus.pojo.inter.BloodInterfaceType; import com.czblood.common.config.RuoYiConfig; import com.czblood.common.core.domain.Result; import lombok.extern.slf4j.Slf4j; -import org.apache.poi.ss.formula.functions.T; /** * 接口调用类 @@ -17,11 +15,8 @@ import org.apache.poi.ss.formula.functions.T; @Slf4j public class BloodInterfaceUtil { - public Result invokeBloodInterface(BloodInterfaceStr bloodInterfaceStr) { -// BloodInterfaceStr sqdAuditRequestBloodInterfaceStr = new BloodInterfaceStr<>(); -// sqdAuditRequestBloodInterfaceStr.setBloodInterfaceType(BloodInterfaceType.SQD_AUDIT); -// sqdAuditRequestBloodInterfaceStr.setData(new SqdAuditRequest()); - String jsonStr = JSONUtil.toJsonStr(bloodInterfaceStr); + public static Result invokeBloodInterface(BloodInterfaceType bloodInterfaceType) { + String jsonStr = bloodInterfaceType.serializationJson(); return invokeHttp(jsonStr); } @@ -31,10 +26,12 @@ public class BloodInterfaceUtil { * @param jsonStr * @return */ - private Result invokeHttp(String jsonStr){ + private static Result invokeHttp(String jsonStr){ String interfaceUrl = RuoYiConfig.getInterfaceUrl(); if(interfaceUrl == null || "".equals(interfaceUrl)) return new Result("-1","没有配置接口地址，请检查interfaceUrl配置项！！！"); String retMsg = ""; + log.info("开始调用后台http接口，地址：{}",interfaceUrl); + log.info("入参：{}",jsonStr); try { HttpRequest httpRequest = HttpRequest.post(interfaceUrl); httpRequest.header("Content-Type","application/json"); @@ -42,15 +39,15 @@ public class BloodInterfaceUtil { int status = httpResponse.getStatus(); retMsg = httpResponse.body(); if (status != 200) { - log.info("调用http接口失败："+retMsg); + log.info("调用后台http接口失败："+retMsg); return new Result("-1","调用http接口失败："+retMsg); } }catch (Exception e){ e.printStackTrace(); - log.error("调用lis的http接口出错：",e); - return new Result("-1","调用http接口失败："+e.getMessage()); + log.error("调用后台http接口出错：",e); + return new Result("-1","调用后台http接口失败："+e.getMessage()); } - log.info("调用http接口成功类型：，入参:{}\r\n，出参：{}",jsonStr,retMsg); + log.info("调用后台http接口成功，入参:{}\r\n，出参：{}",jsonStr,retMsg); String message=""; String resultCode=""; // 检查输入是否为空 diff --git a/blood_bus/src/main/resources/mapper/XkParameterMapper.xml b/blood_bus/src/main/resources/mapper/XkParameterMapper.xml new file mode 100644 index 0000000..04108f7 --- /dev/null +++ b/blood_bus/src/main/resources/mapper/XkParameterMapper.xml @@ -0,0 +1,8 @@ + + + + + \ No newline at end of file diff --git a/blood_bus/src/main/resources/mapper/XkTransfuseApplyTestitemMapper.xml b/blood_bus/src/main/resources/mapper/XkTransfuseApplyTestitemMapper.xml new file mode 100644 index 0000000..d684e9a --- /dev/null +++ b/blood_bus/src/main/resources/mapper/XkTransfuseApplyTestitemMapper.xml @@ -0,0 +1,8 @@ + + + + + \ No newline at end of file diff --git a/blood_bus_doctor/src/main/java/com/czblood/busDoctor/controller/TransfuseApplyBeforeController.java b/blood_bus_doctor/src/main/java/com/czblood/busDoctor/controller/TransfuseApplyBeforeController.java index 6ce1b4a..9d77370 100644 --- a/blood_bus_doctor/src/main/java/com/czblood/busDoctor/controller/TransfuseApplyBeforeController.java +++ b/blood_bus_doctor/src/main/java/com/czblood/busDoctor/controller/TransfuseApplyBeforeController.java @@ -1,13 +1,40 @@ package com.czblood.busDoctor.controller; +import com.czblood.bus.pojo.XkTransfuseApplyBefore; +import com.czblood.busDoctor.pojo.TransfuseApplyBeforeDTO; +import com.czblood.busDoctor.service.TransfuseApplyBeforeService; +import com.czblood.common.core.domain.Result; import io.swagger.annotations.Api; +import io.swagger.annotations.ApiOperation; import lombok.extern.slf4j.Slf4j; -import org.springframework.web.bind.annotation.RequestMapping; -import org.springframework.web.bind.annotation.RestController; +import org.springframework.web.bind.annotation.*; + +import javax.annotation.Resource; @Api(tags = "输血前评估") @RestController @RequestMapping("/doctor/applyBefore") @Slf4j public class TransfuseApplyBeforeController { + + @Resource + private TransfuseApplyBeforeService transfuseApplyBeforeService; + + @ApiOperation("查询单据信息") + @GetMapping("/queryList") + public Result queryList(XkTransfuseApplyBefore xkTransfuseApplyBefore){ + return transfuseApplyBeforeService.queryList(xkTransfuseApplyBefore); + } + + @ApiOperation("根据住院号获取病人信息") + @GetMapping("/getPatInfo") + public Result getPatInfo(String patNo){ + return transfuseApplyBeforeService.getPatInfo(patNo); + } + + @ApiOperation("保存信息") + @PostMapping("/save") + public Result save(@RequestBody TransfuseApplyBeforeDTO transfuseApplyBeforeDTO){ + return transfuseApplyBeforeService.save(transfuseApplyBeforeDTO); + } } diff --git a/blood_bus_doctor/src/main/java/com/czblood/busDoctor/pojo/TransfuseApplyBeforeDTO.java b/blood_bus_doctor/src/main/java/com/czblood/busDoctor/pojo/TransfuseApplyBeforeDTO.java new file mode 100644 index 0000000..1f0bfdd --- /dev/null +++ b/blood_bus_doctor/src/main/java/com/czblood/busDoctor/pojo/TransfuseApplyBeforeDTO.java @@ -0,0 +1,23 @@ +package com.czblood.busDoctor.pojo; + +import com.czblood.bus.pojo.*; +import io.swagger.annotations.ApiModelProperty; +import lombok.AllArgsConstructor; +import lombok.Data; +import lombok.NoArgsConstructor; + +import java.util.List; + +@Data +@AllArgsConstructor +@NoArgsConstructor +public class TransfuseApplyBeforeDTO { + @ApiModelProperty(value = "病人信息") + private XkPatientInfo xkPatientInfo; + @ApiModelProperty(value = "输血评估信息") + private List xkTransfuseApplyBefore; + @ApiModelProperty(value = "输血前lis检查项目") + private XkTransfuseApplyTestitem xkTransfuseApplyTestitem; + @ApiModelProperty(value = "输血前申请信息") + private XkTransfuseApply xkTransfuseApply; +} diff --git a/blood_bus_doctor/src/main/java/com/czblood/busDoctor/service/TransfuseApplyBeforeService.java b/blood_bus_doctor/src/main/java/com/czblood/busDoctor/service/TransfuseApplyBeforeService.java new file mode 100644 index 0000000..6135d31 --- /dev/null +++ b/blood_bus_doctor/src/main/java/com/czblood/busDoctor/service/TransfuseApplyBeforeService.java @@ -0,0 +1,13 @@ +package com.czblood.busDoctor.service; + +import com.czblood.bus.pojo.XkTransfuseApplyBefore; +import com.czblood.busDoctor.pojo.TransfuseApplyBeforeDTO; +import com.czblood.common.core.domain.Result; + +public interface TransfuseApplyBeforeService { + Result queryList(XkTransfuseApplyBefore xkTransfuseApplyBefore); + + Result getPatInfo(String patNo); + + Result save(TransfuseApplyBeforeDTO transfuseApplyBeforeDTO); +} diff --git a/blood_bus_doctor/src/main/java/com/czblood/busDoctor/service/impl/TransfuseApplyBeforeServiceImpl.java b/blood_bus_doctor/src/main/java/com/czblood/busDoctor/service/impl/TransfuseApplyBeforeServiceImpl.java new file mode 100644 index 0000000..6ffe8fc --- /dev/null +++ b/blood_bus_doctor/src/main/java/com/czblood/busDoctor/service/impl/TransfuseApplyBeforeServiceImpl.java @@ -0,0 +1,76 @@ +package com.czblood.busDoctor.service.impl; + +import cn.hutool.json.JSONUtil; +import com.czblood.bus.mapper.XkPatientInfoMapper; +import com.czblood.bus.mapper.XkTransfuseApplyBeforeMapper; +import com.czblood.bus.pojo.XkPatientInfo; +import com.czblood.bus.pojo.XkTransfuseApply; +import com.czblood.bus.pojo.XkTransfuseApplyBefore; +import com.czblood.bus.pojo.XkTransfuseApplyTestitem; +import com.czblood.bus.pojo.inter.GetPatientInfoRequest; +import com.czblood.bus.pojo.inter.GetTestResultRequest; +import com.czblood.bus.utils.BloodInterfaceUtil; +import com.czblood.busDoctor.pojo.TransfuseApplyBeforeDTO; +import com.czblood.busDoctor.service.TransfuseApplyBeforeService; +import com.czblood.common.core.domain.Result; +import org.springframework.stereotype.Service; + +import javax.annotation.Resource; +import java.util.List; + +@Service +public class TransfuseApplyBeforeServiceImpl implements TransfuseApplyBeforeService { + + @Resource + XkPatientInfoMapper xkPatientInfoMapper; + @Resource + XkTransfuseApplyBeforeMapper xkTransfuseApplyBeforeMapper; + + @Override + public Result queryList(XkTransfuseApplyBefore xkTransfuseApplyBefore) { + String beinhosId = xkTransfuseApplyBefore.getBeinhos_id(); + //病人基本信息 + XkPatientInfo xkPatientInfo = new XkPatientInfo(); + xkPatientInfo.setBeinhos_id(beinhosId); + List xkPatientInfoList = xkPatientInfoMapper.queryList(xkPatientInfo); + //输血前评估信息 + List xkTransfuseApplyBeforeList = xkTransfuseApplyBeforeMapper.queryList(xkTransfuseApplyBefore); + TransfuseApplyBeforeDTO transfuseApplyBeforeDTO = new TransfuseApplyBeforeDTO(); + if(xkPatientInfoList.size() > 0) transfuseApplyBeforeDTO.setXkPatientInfo(xkPatientInfoList.get(0)); + transfuseApplyBeforeDTO.setXkTransfuseApplyBefore(xkTransfuseApplyBeforeList); + return new Result("0","获取数据成功！", transfuseApplyBeforeDTO); + } + + @Override + public Result getPatInfo(String patNo) { + //调用接口获取病人基本信息 + GetPatientInfoRequest getPatientInfoRequest = new GetPatientInfoRequest(); + getPatientInfoRequest.setBeinhos_id(patNo); + Result result = BloodInterfaceUtil.invokeBloodInterface(getPatientInfoRequest); + if(!result.getCode().equals("0")) return result; + XkTransfuseApply xkTransfuseApply = JSONUtil.parseObj(result.getData()).toBean(XkTransfuseApply.class); + XkPatientInfo xkPatientInfo = JSONUtil.parseObj(result.getData()).toBean(XkPatientInfo.class); + if(xkPatientInfo == null){ + XkPatientInfo xkPatientInfoOne = new XkPatientInfo(); + xkPatientInfoOne.setBeinhos_id(patNo); + List xkPatientInfoList = xkPatientInfoMapper.queryList(xkPatientInfoOne); + if(!xkPatientInfoList.isEmpty()) xkPatientInfo = xkPatientInfoList.get(0); + } + //调用检验接口，获取病人检验信息 + GetTestResultRequest getTestResultRequest = new GetTestResultRequest(); + getTestResultRequest.setBeinhos_id(patNo); + Result result1 = BloodInterfaceUtil.invokeBloodInterface(getTestResultRequest); + if(!result1.getCode().equals("0")) return result1; + XkTransfuseApplyTestitem xkTransfuseApplyTestitem = JSONUtil.parseObj(result.getData()).toBean(XkTransfuseApplyTestitem.class); + TransfuseApplyBeforeDTO transfuseApplyBeforeDTO = new TransfuseApplyBeforeDTO(); + transfuseApplyBeforeDTO.setXkPatientInfo(xkPatientInfo); + transfuseApplyBeforeDTO.setXkTransfuseApplyTestitem(xkTransfuseApplyTestitem); + transfuseApplyBeforeDTO.setXkTransfuseApply(xkTransfuseApply); + return new Result("0","获取数据成功！", transfuseApplyBeforeDTO); + } + + @Override + public Result save(TransfuseApplyBeforeDTO transfuseApplyBeforeDTO) { + return null; + } +} diff --git a/blood_common/src/main/java/com/czblood/common/constant/CacheConstants.java b/blood_common/src/main/java/com/czblood/common/constant/CacheConstants.java index 83adeb5..d66c8a5 100644 --- a/blood_common/src/main/java/com/czblood/common/constant/CacheConstants.java +++ b/blood_common/src/main/java/com/czblood/common/constant/CacheConstants.java @@ -49,6 +49,6 @@ public class CacheConstants /** * 参数 */ - //public static final String COM_OPT_KEY = "com_opt:"; + public static final String XK_PARAMETER_KEY = "xk_parameter:"; }