合并报告推送

3.2.4.44
wyb 2 years ago
parent f9a1451e6a
commit 4e67816b3c

@ -0,0 +1,25 @@
<!-- 报告接收 webservice 需要的数据对应下载服务,标签内有 xpath 路径,则取 接收xml中的数据否则取 标签 value值 -->
<REPORT>
<!--住院号-->
<INPATIENT_NO>/Request/Msg/INHOSP_INDEX_NO</INPATIENT_NO>
<!--住院流水号-->
<JZH>/Request/Msg/INHOSP_NO</JZH>
<!--住院次数-->
<ADMISS_TIMES>/Request/Msg/INHOSP_NUM</ADMISS_TIMES>
<!--采集流水号/报告唯一单号-->
<SERIALNUM>/Request/Msg/UNIQUE_FILE</SERIALNUM>
<!--文件标题-->
<FILE_TITLE>/Request/Msg/FILE_NAME</FILE_TITLE>
<!--下载地址-->
<DOWNURL>/Request/Msg/PDF_PATH</DOWNURL>
<!--表单类型 -->
<TABLE_TYPE>/Request/Msg/TABLE_TYPE</TABLE_TYPE>
<!--文件分类 无则取 TABLE_TYPE 在js-table-type中 取文件分类-->
<ASSORT_ID value="123456"> </ASSORT_ID>
<!--采集系统 文件表的source-->
<SYSTEM_FLAG>/Request/Msg/TABLE_TYPE</SYSTEM_FLAG>
<!--采集类型(文件来源 1:采集器2扫描生产软件)-->
<FILESOURCE value="1"> </FILESOURCE>
<!--文件保存位置类型 1:服务器本地2ftp服务器3共享文件夹-->
<FILE_STORAGE_TYPE value="1"> </FILE_STORAGE_TYPE>
</REPORT>

@ -0,0 +1,5 @@
{
"icu": "重症文件分段id",
"sa": "手麻文件分段id",
"other": "其他文件分段id"
}

@ -0,0 +1,25 @@
<!--嘉时软件webservice接收模板-->
<Request>
<Msg>
<!-- 消息ID号-->
<ID>123456</ID>
<!--住院号-->
<INHOSP_INDEX_NO>012345</INHOSP_INDEX_NO>
<!--住院流水号-->
<INHOSP_NO>012345</INHOSP_NO>
<!--住院次数-->
<INHOSP_NUM>2</INHOSP_NUM>
<!--表单类型-->
<TABLE_TYPE>icu</TABLE_TYPE>
<!--提交时间-->
<SUBMIT_TIME>20220303111800</SUBMIT_TIME>
<!--审核时间-->
<PROOF_TIME>20220303111801</PROOF_TIME>
<!-- 文件路径-->
<PDF_PATH>http://192.168.1.108:9012/file/0123_01.pdf</PDF_PATH>
<!--文件名-->
<FILE_NAME>0123_01</FILE_NAME>
<!--文件唯一值-->
<UNIQUE_FILE>AESHASHMD5DEFIND</UNIQUE_FILE>
</Msg>
</Request>

@ -0,0 +1,11 @@
<!--嘉时软件webservice响应模板-->
<Response>
<Result>
<!--响应状态码 0代表成功 500 代表失败-->
<Code>0</Code>
<!--消息id 请求的 /Request/Msg/ID-->
<MsgId>123456</MsgId>
<!--成功消息 / 失败异常消息-->
<Msg>成功!</Msg>
</Result>
</Response>

@ -1,7 +1,6 @@
package com.docus.server.collection.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.docus.server.collection.entity.TBasic;
import com.docus.server.collection.entity.TBasicExtend;
import org.apache.ibatis.annotations.Param;
@ -15,6 +14,13 @@ import org.apache.ibatis.annotations.Param;
* @since 2021-04-14
*/
public interface TBasicMapper{
/**
*
* @param inpatientNo
* @param admissTimes
* @return
*/
String getPatientIdByInpatientNoAndAdminssTimes(@Param("inpatientNo") String inpatientNo,@Param("adminssTimes") Integer admissTimes);
Integer selectOne(@Param("jzh") String jzh);

@ -25,4 +25,30 @@ public interface ReceiveServer {
* @return
*/
String userModify(String receiveUser);
/**
*
*
* @param icuReportMessage
* @return
*/
String pushICUReport(String icuReportMessage);
/**
* -
*
* @param inspectionReportMessage -
* @return
*/
String pushAddInspectionReport(String inspectionReportMessage);
/**
* -
*
* @param inspectionReportMessage -
* @return
*/
String pushUpdateInspectionReport(String inspectionReportMessage);
}

@ -4,6 +4,7 @@ import com.docus.server.collection.webservice.IDeptServer;
import com.docus.server.collection.webservice.IUserServer;
import com.docus.server.collection.webservice.ReceiveServer;
import com.docus.server.collection.webservice.BasicService;
import com.docus.server.report.webservice.IReportServer;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;
@ -27,6 +28,8 @@ public class ReceiveServerImpl implements ReceiveServer {
private IDeptServer deptServer;
@Resource
private BasicService basicService;
@Resource
private IReportServer reportServer;
@Override
@ -48,4 +51,22 @@ public class ReceiveServerImpl implements ReceiveServer {
public String userModify(String receiveUser) {
return userServer.userModify(receiveUser);
}
@Override
public String pushICUReport(String icuReportMessage) {
return reportServer.pushICUReport(icuReportMessage);
}
@Override
public String pushAddInspectionReport(String inspectionReportMessage) {
return reportServer.pushAddInspectionReport(inspectionReportMessage);
}
@Override
public String pushUpdateInspectionReport(String inspectionReportMessage) {
return reportServer.pushUpdateInspectionReport(inspectionReportMessage);
}
}

@ -0,0 +1,18 @@
package com.docus.server.report.config;
import lombok.Getter;
import lombok.Setter;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;
/**
*
* @author wyb
*/
@Component
@Getter
@Setter
public class ApplicationBusinessConfig {
@Value("${docus.report.downurl:}")
private String downUrl;
}

@ -0,0 +1,44 @@
package com.docus.server.report.controller;
import com.docus.core.util.Func;
import com.docus.infrastructure.web.api.CommonResult;
import com.docus.server.report.service.ReportService;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import lombok.extern.slf4j.Slf4j;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import javax.annotation.Resource;
import java.util.List;
/**
* @author wyb
*
*/
@Slf4j
@Api(tags = "文件上报,补偿控制")
@RestController
@RequestMapping("/report/makeup")
public class ReportDownController {
@Resource
private ReportService reportService;
@ApiOperation(value = "根据任务id补偿报告下载")
@PostMapping("/makeupReportByTaskIds")
public CommonResult<String> makeupReportByTaskIds(@RequestBody List<Long> taskIds){
if (Func.isEmpty(taskIds)) {
return CommonResult.failed("补偿任务id不能为空");
}
try {
reportService.makeupReportByTaskIds(taskIds);
} catch (Exception ex) {
log.error(ex.getMessage(), ex);
return CommonResult.failed("补偿出现了一点小问题!");
}
return CommonResult.success("补偿成功!");
}
}

@ -0,0 +1,30 @@
package com.docus.server.report.dto;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import java.util.List;
@Data
public class ReportDownDto {
@ApiModelProperty(value = "采集器id")
private String collectorid;
@ApiModelProperty(value = "采集器ip")
private String ip;
@ApiModelProperty(value = "分类id")
private String assortid;
@ApiModelProperty(value = "患者信息")
private ReportDownPatientDto patient;
@ApiModelProperty(value = "文件信息")
private List<ReportDownScanFileDto> scanfiles;
@ApiModelProperty(value = "扫描用户代码")
private String scanusercode;
@ApiModelProperty(value = "扫描用户名称")
private String scanusername;
}

@ -0,0 +1,27 @@
package com.docus.server.report.dto;
import com.docus.server.report.entity.AfReportRecord;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
@Data
public class ReportDownPatientDto {
@ApiModelProperty(value = "记帐号")
private String jzh;
@ApiModelProperty(value = "住院次数,记帐号重复则加这个参数无则Null")
private Integer admisstimes;
@ApiModelProperty(value = "病案主键如有传则使用无则使用jzh")
private String patientid;
@ApiModelProperty(value = "病案号")
private String inpatientno;
@ApiModelProperty(value = "物理存储位置,有则传")
private String storagelocation;
public ReportDownPatientDto(AfReportRecord reportRecord) {
this.patientid = reportRecord.getPatientId();
this.jzh = reportRecord.getJzh();
this.admisstimes = reportRecord.getAdmissTimes();
this.inpatientno = reportRecord.getInpatientNo();
}
}

@ -0,0 +1,41 @@
package com.docus.server.report.dto;
import com.docus.server.report.entity.AfReportRecord;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
@Data
public class ReportDownScanFileDto {
@ApiModelProperty(value = "任务id(如无效任务id则不更新任务表数据)")
private Long taskid;
@ApiModelProperty(value = "文件标题")
private String filetitle;
@ApiModelProperty(value = "采集类型(文件来源 1:采集器2扫描生产软件)")
private int filesource;
@ApiModelProperty(value = "下载类型(1:服务器本地2ftp服务器3共享文件夹)")
private int filestoragetype;
@ApiModelProperty(value = "文件类型(1:url,2:base64,3:url base64,4:共享文件5本地文件base64)")
private int filetype=1;
@ApiModelProperty(value = "下载地址")
private String downurl;
// @ApiModelProperty(value = "档案信息")
// private String recordid;
@ApiModelProperty(value = "采集流水号")
private String serialnum;
@ApiModelProperty(value = "排序日期")
private String sortdate;
@ApiModelProperty(value = "是否作废 0否 不作废1是 作废")
private int cancel=0;
public ReportDownScanFileDto(AfReportRecord reportRecord) {
this.taskid=reportRecord.getTaskId();
this.filetitle=reportRecord.getFileName();
this.filesource= 1;
this.filestoragetype=1;
this.filetype=reportRecord.getDownType();
this.downurl=reportRecord.getDownUrl();
this.serialnum=reportRecord.getSerialnum();
}
}

@ -0,0 +1,68 @@
package com.docus.server.report.dto;
import lombok.Data;
/**
*
*/
@Data
public class ReportDto {
/**
*
*/
private String inpatientNo;
/**
* /
*/
private String jzh;
/**
*
*/
private Integer admisstimes;
/**
*
*/
private String sysFlag;
/**
*
*/
private String downUrl;
/**
*
*/
private String fileTitle;
/**
* /id
*/
private String serialnum;
/**
* id
*/
private String assortId;
/**
* ( 1:2)
*/
private String fileSource;
/**
* 1:2ftp3
*/
private String filestoragetype;
/**
* id ,
*/
private Long taskId;
/**
*
*/
private String patientId;
/**
* 1:url2:base643:url base644:5base64
*/
private Integer downtype=1;
}

@ -0,0 +1,79 @@
package com.docus.server.report.entity;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import lombok.EqualsAndHashCode;
import java.io.Serializable;
import java.util.Date;
/**
* <p>
*
* </p>
*
* @author
* @since 2021-05-07
*/
@Data
@EqualsAndHashCode(callSuper = false)
@ApiModel(value = "AfCollectTask对象", description = "病案采集任务")
public class AfCollectTask implements Serializable {
private static final long serialVersionUID = 1L;
@ApiModelProperty(value = "id 主键")
@TableId(value = "id", type = IdType.INPUT)
private Long id;
@ApiModelProperty(value = "病案主键")
private String patientId;
@ApiModelProperty(value = "来源 1护理文书2 电子病历3 Pacs检查4心电图5手麻系统6 Lis检验7病案首页8长临医嘱")
private String sysflag;
@ApiModelProperty(value = "开始时间")
private Date startTime;
@ApiModelProperty(value = "结束时间")
private Date endTime;
@ApiModelProperty(value = "任务耗时(毫秒)")
private Long consumingTime;
@ApiModelProperty(value = "-1 等待采集0未开始1:正在采集2采集错误3采集完成")
private String state;
@ApiModelProperty(value = "同步时间")
private Date syncTime;
@ApiModelProperty(value = "最新重新采集时间")
private Date recollectTime;
@ApiModelProperty(value = "最新重新采集人")
private String recollectName;
@ApiModelProperty(value = "备注")
private String remark;
@ApiModelProperty(value = "报告唯一单号")
private String C1;
@ApiModelProperty(value = "c2")
private String C2;
@ApiModelProperty(value = "记账号")
private String C3;
@ApiModelProperty(value = "c4")
private String C4;
@ApiModelProperty(value = "c6")
private String C6;
@ApiModelProperty(value = "c9")
private String C9;
}

@ -0,0 +1,103 @@
package com.docus.server.report.entity;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import com.docus.server.report.dto.ReportDto;
import lombok.Data;
import java.io.Serializable;
import java.util.Date;
/**
*
*/
@Data
public class AfReportRecord implements Serializable {
private static final long serialVersionUID = 1L;
/**
* af_collect_task id
*/
private Long taskId;
/**
*
*/
private String inpatientNo;
/**
*
*/
private String jzh;
/**
*
*/
private Integer admissTimes;
/**
* 使 |
*/
private String downUrl;
/**
* 1:url2:base643:url base644:5base64
*/
private Integer downType;
/**
* 0 1
*/
private Integer state;
/**
* id
*/
private String serialnum;
/**
*
*/
private String sysflag;
/**
* id
*/
private String zdAssortId;
/**
*
*/
private Date createTime;
/**
*
*/
private Date updateTime;
/**
*
*/
private String fileName;
/**
*
*/
private String patientId;
public AfReportRecord() {
}
public AfReportRecord(ReportDto reportDto){
this.jzh=reportDto.getJzh();
this.admissTimes=reportDto.getAdmisstimes();
this.inpatientNo=reportDto.getInpatientNo();
this.downUrl=reportDto.getDownUrl();
this.sysflag=reportDto.getSysFlag();
this.zdAssortId=reportDto.getAssortId();
this.serialnum=reportDto.getSerialnum();
this.fileName=reportDto.getFileTitle();
this.downType=reportDto.getDowntype();
}
}

@ -0,0 +1,158 @@
package com.docus.server.report.entity;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import lombok.EqualsAndHashCode;
import java.io.Serializable;
import java.util.Date;
/**
* <p>
*
* </p>
*
* @author jiashi
* @since 2021-04-14
*/
@Data
@EqualsAndHashCode(callSuper = false)
@ApiModel(value = "TBasic对象", description = "病案基本信息")
public class TBasic implements Serializable {
private static final long serialVersionUID = 1L;
@ApiModelProperty(value = "病案主键")
@TableId(value = "patient_id", type = IdType.ASSIGN_ID)
private String patientId;
@ApiModelProperty(value = "住院次数")
private Integer admissTimes;
@ApiModelProperty(value = "病案号")
private String inpatientNo;
@ApiModelProperty(value = "住院ID号")
private String admissId;
@ApiModelProperty(value = "患者姓名")
private String name;
@ApiModelProperty(value = "盘号")
private String ph;
@ApiModelProperty(value = "性别")
private String sex;
@ApiModelProperty(value = "年龄_岁")
private Integer age;
@ApiModelProperty(value = "年龄_月")
private Integer ageMonth;
@ApiModelProperty(value = "年龄_天")
private Integer ageDay;
@ApiModelProperty(value = "身份证")
private String idCard;
@ApiModelProperty(value = "手机号码")
private String telphone;
@ApiModelProperty(value = "住院日期")
private Date admissDate;
@ApiModelProperty(value = "住院科室")
private String admissDept;
@ApiModelProperty(value = "住院科室名称")
private String admissDeptName;
@ApiModelProperty(value = "出院日期")
private Date disDate;
@ApiModelProperty(value = "出院科室")
private String disDept;
@ApiModelProperty(value = "出院科室名称")
private String disDeptName;
@ApiModelProperty(value = "实际住院天数")
private Integer admissDays;
@ApiModelProperty(value = "主管医生")
private String attending;
@ApiModelProperty(value = "主管医生名称")
private String attendingName;
@ApiModelProperty(value = "主要诊断编码")
private String mainDiagCode;
@ApiModelProperty(value = "主要诊断名称")
private String mainDiagName;
@ApiModelProperty(value = "主要手术编码")
private String mainOperateCode;
@ApiModelProperty(value = "主要手术名称")
private String mainOperateName;
@ApiModelProperty(value = "是否死亡")
private Integer isDead;
@ApiModelProperty(value = "是否作废(01是)")
private Integer isCancel;
@ApiModelProperty(value = "创建时间")
private Date createTime;
@ApiModelProperty(value = "修改时间")
private Date updateTime;
@ApiModelProperty(value = "是否归档 1已归档0未归档")
private Integer isArchive;
@ApiModelProperty(value = "归档时间")
private Date archiveTime;
@ApiModelProperty(value = "文件来源 1:af_archive_detail,2:t_scan_assort")
private Integer fileSource;
@ApiModelProperty(value = "完整性描述")
private String integrityDesc;
private String bColumn1;
private String bColumn2;
private String bColumn3;
private String bColumn4;
private String bColumn5;
private Integer bColumn6;
private Integer bColumn7;
private Integer bColumn8;
private Integer bColumn9;
private Integer bColumn10;
@ApiModelProperty(value = "姓名缩写(内部构成)")
private String nameSpell;
@ApiModelProperty(value = "性别名称")
private String sexName;
@ApiModelProperty(value = "记账号")
private String jzh;
}

@ -0,0 +1,28 @@
package com.docus.server.report.event;
import lombok.Getter;
import org.springframework.context.ApplicationEvent;
/**
*
* @author wyb
*/
@Getter
public class ReportDownEvent extends ApplicationEvent {
/**
* id ,
*/
private final Long taskId;
/**
*
* @param source
* @param taskId
*/
public ReportDownEvent(Object source,Long taskId) {
super(source);
this.taskId=taskId;
}
}

@ -0,0 +1,83 @@
package com.docus.server.report.listener;
import cn.hutool.http.HttpRequest;
import cn.hutool.http.HttpResponse;
import cn.hutool.http.HttpUtil;
import com.docus.core.util.Func;
import com.docus.infrastructure.web.api.CommonResult;
import com.docus.infrastructure.web.api.ResultCode;
import com.docus.server.report.config.ApplicationBusinessConfig;
import com.docus.server.report.dto.ReportDownDto;
import com.docus.server.report.dto.ReportDownPatientDto;
import com.docus.server.report.dto.ReportDownScanFileDto;
import com.docus.server.report.entity.AfReportRecord;
import com.docus.server.report.event.ReportDownEvent;
import com.docus.server.report.mapper.AfReportRecordMapper;
import lombok.extern.slf4j.Slf4j;
import org.springframework.context.event.EventListener;
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Component;
import javax.annotation.Resource;
import java.util.ArrayList;
import java.util.List;
/**
*
*
* @author wyb
*/
@Component
@Slf4j
public class ReportDownListener {
@Resource
private ApplicationBusinessConfig applicationBusinessConfig;
@Resource
private AfReportRecordMapper afReportRecordMapper;
@EventListener
@Async("threadPoolExecutor")
public void reportDown(ReportDownEvent reportDownEvent) {
// 根据任务id获取上报记录信息
AfReportRecord afReportRecord = afReportRecordMapper.getReportRecordInfoByTaskId(reportDownEvent.getTaskId());
// 组织基础信息数据
ReportDownPatientDto reportDownPatientDto = new ReportDownPatientDto(afReportRecord);
// 组织文件数据
List<ReportDownScanFileDto> reportDownScanFileDtos = new ArrayList<>(5);
ReportDownScanFileDto reportDownScanFileDto = new ReportDownScanFileDto(afReportRecord);
reportDownScanFileDtos.add(reportDownScanFileDto);
// 组织下载数据,基础信息和文件数据
ReportDownDto reportDownDto = new ReportDownDto();
reportDownDto.setAssortid(afReportRecord.getZdAssortId());
reportDownDto.setCollectorid(afReportRecord.getSysflag());
reportDownDto.setScanusercode("admin");
reportDownDto.setScanusername("admin");
reportDownDto.setPatient(reportDownPatientDto);
reportDownDto.setScanfiles(reportDownScanFileDtos);
// 下面是调用下载服务
String requestParam = Func.toJson(reportDownDto);
try {
log.info("调用下载服务,地址:{} ,参数:{}",applicationBusinessConfig.getDownUrl(),requestParam);
HttpRequest post = HttpUtil.createPost(applicationBusinessConfig.getDownUrl());
post.timeout(5 * 1000);
post.header("Content-Type", "application/json; charset=utf-8");
post.body(requestParam);
HttpResponse response = post.execute();
String respBody = response.body();
log.info("调用下载服务成功,响应参数:{}", respBody);
CommonResult commonResult = Func.readJson(respBody, CommonResult.class);
if (ResultCode.SUCCESS.getCode().equals(commonResult.getCode())) {
// 下载返回了成功更新状态
afReportRecordMapper.updateStateByTaskId(reportDownEvent.getTaskId());
}
} catch (Exception e) {
log.error("调用下载服务失败", e);
}
}
}

@ -0,0 +1,27 @@
package com.docus.server.report.mapper;
import com.docus.server.report.entity.AfCollectTask;
import org.apache.ibatis.annotations.Param;
/**
* mapper
* @author wyb
*
*/
public interface AfCollectTaskMapper {
/**
*
* @param afCollectTask
* @return
*/
int saveTask(@Param("task") AfCollectTask afCollectTask);
/**
*
* @param taskId
* @return
*/
AfCollectTask getTaskById(@Param("id") Long taskId);
}

@ -0,0 +1,52 @@
package com.docus.server.report.mapper;
import com.docus.server.report.entity.AfReportRecord;
import org.apache.ibatis.annotations.Param;
import java.util.List;
/**
*
* @author wyb
*/
public interface AfReportRecordMapper {
/**
*
* @param afReportRecord
* @return
*/
int saveRecord(@Param("reportRecord") AfReportRecord afReportRecord);
/**
*
* @param serialnum
* @param inpatientNo
* @param admisstimes
* @param sysFlag
* @return
*/
AfReportRecord getRecordBySerialnumAndInpatientNoAndSysFlag(@Param("serialnum") String serialnum, @Param("inpatientNo")String inpatientNo,@Param("admisstimes") Integer admisstimes, @Param("sysFlag")String sysFlag);
/**
*
* @param afReportRecord
* @return
*/
int updateRecordByTaskId(@Param("reportRecord")AfReportRecord afReportRecord);
/**
*
* @param taskId id
* @return
*/
int updateStateByTaskId(@Param("taskId") Long taskId);
AfReportRecord getReportRecordInfoByTaskId(@Param("taskId") Long taskId);
/**
* idpatientIdid
* @param taskIds id
* @return patientIdid
*/
List<Long> getHasPatientIdTaskIdsByTaskIds(@Param("taskIds") List<Long> taskIds);
}

@ -0,0 +1,24 @@
package com.docus.server.report.service;
import com.docus.server.report.dto.ReportDto;
import java.util.List;
/**
*
* @author wyb
*/
public interface ReportService {
/**
*
* @param reportDto
*/
void report(ReportDto reportDto);
/**
* id
* @param taskIds id
*/
void makeupReportByTaskIds(List<Long> taskIds) throws Exception;
}

@ -0,0 +1,120 @@
package com.docus.server.report.service.impl;
import com.docus.core.util.Func;
import com.docus.infrastructure.redis.service.IdService;
import com.docus.server.collection.mapper.TBasicMapper;
import com.docus.server.report.dto.ReportDto;
import com.docus.server.report.entity.AfCollectTask;
import com.docus.server.report.entity.AfReportRecord;
import com.docus.server.report.event.ReportDownEvent;
import com.docus.server.report.mapper.AfCollectTaskMapper;
import com.docus.server.report.mapper.AfReportRecordMapper;
import com.docus.server.report.service.ReportService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.context.ApplicationContext;
import org.springframework.stereotype.Service;
import javax.annotation.Resource;
import java.util.List;
import java.util.concurrent.TimeUnit;
/**
*
*
* @author wyb
*/
@Slf4j
@Service
public class ReportServiceImpl implements ReportService {
@Resource
private ApplicationContext applicationContext;
@Resource
private AfCollectTaskMapper collectTaskMapper;
@Resource
private AfReportRecordMapper afReportRecordMapper;
@Resource
private TBasicMapper tBasicMapper;
@Resource
private IdService idService;
@Override
public void report(ReportDto reportDto) {
String patientId = null;
try {
// 如果出现多条出错的情况,还是得保存收到的信息,人工干预处理
patientId = tBasicMapper.getPatientIdByInpatientNoAndAdminssTimes(reportDto.getInpatientNo(), reportDto.getAdmisstimes());
} catch (Exception ex) {
log.error("查询病案主键出错了", ex);
}
// 不验证数据,始终保存收到的信息
AfReportRecord afReportRecord = afReportRecordMapper.getRecordBySerialnumAndInpatientNoAndSysFlag(reportDto.getSerialnum(), reportDto.getInpatientNo(), reportDto.getAdmisstimes(), reportDto.getSysFlag());
if (afReportRecord == null) {
long id = idService.getDateSeq();
afReportRecord = new AfReportRecord(reportDto);
afReportRecord.setTaskId(id);
afReportRecord.setPatientId(patientId);
afReportRecordMapper.saveRecord(afReportRecord);
} else {
// 更新 主要更新 url
afReportRecord.setDownUrl(reportDto.getDownUrl());
afReportRecord.setDownType(reportDto.getDowntype());
afReportRecord.setFileName(reportDto.getFileTitle());
afReportRecord.setPatientId(patientId);
afReportRecordMapper.updateRecordByTaskId(afReportRecord);
}
// 不使用事务,不需要回滚上面的保存
// 根据记录中的任务id查询是否需要新增任务
if (Func.isBlank(patientId)) {
log.warn("病案号:{},住院次数:{} 未找到病案基础数据,暂不进行下载任务!", reportDto.getInpatientNo(), reportDto.getAdmisstimes());
return;
}
// 判断是否需要保存任务
AfCollectTask afCollectTask = collectTaskMapper.getTaskById(afReportRecord.getTaskId());
if (afCollectTask == null) {
afCollectTask = new AfCollectTask();
afCollectTask.setId(afReportRecord.getTaskId());
afCollectTask.setC1(reportDto.getSerialnum());
afCollectTask.setC2(reportDto.getFileTitle());
afCollectTask.setC3(reportDto.getJzh());
afCollectTask.setPatientId(patientId);
afCollectTask.setSysflag(reportDto.getSysFlag());
afCollectTask.setState("0");
afCollectTask.setPatientId(patientId);
collectTaskMapper.saveTask(afCollectTask);
}
// 都成功后发布下载事件
applicationContext.publishEvent(new ReportDownEvent(this, afReportRecord.getTaskId()));
}
@Override
public void makeupReportByTaskIds(List<Long> taskIds) throws Exception {
// 定义一批200查询分批次
final int oneBatchCount = 200;
int startIndex = 0;
int toIndex = oneBatchCount;
boolean loop = true;
do {
// 获取截取下标
if (taskIds.size() <= oneBatchCount) {
toIndex = taskIds.size();
// 最后一批截取
loop = false;
}
// 截取每一批
List<Long> makeupTaskIds = taskIds.subList(startIndex, toIndex);
makeupTaskIds = afReportRecordMapper.getHasPatientIdTaskIdsByTaskIds(makeupTaskIds);
if (Func.isNotEmpty(makeupTaskIds)) {
for (Long taskId : makeupTaskIds) {
// 发布下载事件
applicationContext.publishEvent(new ReportDownEvent(this, taskId));
// 等待防止过快
TimeUnit.MILLISECONDS.sleep(50);
}
}
// 当截取长度小于集合长度,可以进行下次循环截取
} while (loop);
}
}

@ -0,0 +1,19 @@
package com.docus.server.report.util;
import lombok.Data;
import java.util.UUID;
import java.util.concurrent.ThreadLocalRandom;
@Data
public class IdUtil {
/**
* 8-4-4-4-12 UUID
* @return 8-4-4-4-12 UUID
*/
public static String standardUUID(){
ThreadLocalRandom random = ThreadLocalRandom.current();
return (new UUID(random.nextLong(), random.nextLong())).toString();
}
}

@ -0,0 +1,41 @@
package com.docus.server.report.util;
import lombok.Data;
/**
* / XML
* @author wyb
*/
@Data
public class JSXMLResult {
private static final String SUCCESS_TEMPLATE="<Response>" +
"<Result>" +
"<Code>0</Code>" +
"<MsgId>%s</MsgId>" +
"<Msg>成功!</Msg>" +
"</Result>" +
"</Response>";
private static final String FAILED_TEMPLATE="<Response>" +
"<Result>" +
"<Code>500</Code>" +
"<MsgId>%s</MsgId>" +
"<Msg>%s</Msg>" +
"</Result>" +
"</Response>";
public static String success(String msgId){
return String.format(SUCCESS_TEMPLATE,msgId);
}
public static String failed(String msgId,String message){
return String.format(FAILED_TEMPLATE,msgId,message);
}
public static void main(String[] args) {
System.out.println(success("100"));
System.out.println(failed("100","随便输出了"));
}
}

@ -0,0 +1,180 @@
package com.docus.server.report.util;
import com.fasterxml.jackson.databind.ObjectMapper;
import org.springframework.util.StringUtils;
import java.io.*;
public class TableJsonRead {
/**
*
* @param path
* @param fileName
* @return
*/
public <T> T Read(String path,String fileName,Class<T> clazz){
String currentPath=CurrentPath();
path = currentPath+"\\"+path;
StringBuilder sb = new StringBuilder();
T dto =null;
File file = new File(path+"\\"+fileName);
try {
if (!file.getParentFile().exists()) {
file.getParentFile().mkdirs();
}
if (!file.exists()) {
try {
file.createNewFile();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
} else {
BufferedReader bufferedReader = null;
bufferedReader = new BufferedReader(new InputStreamReader(new FileInputStream(file)));
String line;
while (!StringUtils.isEmpty(line = bufferedReader.readLine())) {
sb.append(line);
}
if (sb.length() > 0) {
ObjectMapper objectMapper = new ObjectMapper();
//dto = (T)JSONObject.parse(sb.toString());
dto= objectMapper.readValue(sb.toString(), clazz);
//dto = objectMapper.convertValue(o, new TypeReference<T>() { });
}
bufferedReader.close();
}
return dto;
}
catch (Exception ex){
ex.printStackTrace();
return null;
}
}
public <T> T Read(File file,Class<T> clazz) {
StringBuilder sb = new StringBuilder();
T dto =null;
try {
if (!file.getParentFile().exists()) {
file.getParentFile().mkdirs();
}
if (!file.exists()) {
try {
file.createNewFile();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
} else {
BufferedReader bufferedReader = null;
bufferedReader = new BufferedReader(new InputStreamReader(new FileInputStream(file)));
String line;
while (!StringUtils.isEmpty(line = bufferedReader.readLine())) {
sb.append(line);
}
if (sb.length() > 0) {
ObjectMapper objectMapper = new ObjectMapper();
//dto = (T)JSONObject.parse(sb.toString());
dto= objectMapper.readValue(sb.toString(), clazz);
//dto = objectMapper.convertValue(o, new TypeReference<T>() { });
}
bufferedReader.close();
}
return dto;
}
catch (Exception ex){
ex.printStackTrace();
return null;
}
}
/**
* jar
* @return
*/
private String CurrentPath(){
File dir = new File(".");
String currentpath ="";
try {
currentpath = dir.getCanonicalPath();
} catch (IOException e) {
e.printStackTrace();
}
return currentpath;
}
/**
*
* @param path
* @param fileName
* @return
*/
public String ReadContent(String path,String fileName){
String currentPath=CurrentPath();
path = currentPath+"\\"+path;
StringBuilder sb = new StringBuilder();
File file = new File(path+"\\"+fileName);
try {
if (!file.getParentFile().exists()) {
file.getParentFile().mkdirs();
}
if (!file.exists()) {
try {
file.createNewFile();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
} else {
BufferedReader bufferedReader = null;
bufferedReader = new BufferedReader(new InputStreamReader(new FileInputStream(file)));
String line;
while (!StringUtils.isEmpty(line = bufferedReader.readLine())) {
sb.append(line);
}
bufferedReader.close();
}
return sb.toString();
}
catch (Exception ex){
ex.printStackTrace();
return null;
}
}
/**
* json
* @param path
* @param fileName
* @param data json
* @return
*/
public void Save(String path,String fileName,String data){
String currentPath=CurrentPath();
path = currentPath+"\\"+path;
FileWriter fwriter = null;
try {
File file = new File(path);
if (!file.getParentFile().exists()) {
file.getParentFile().mkdirs();
}
fwriter = new FileWriter(path+"\\"+fileName);
fwriter.write(data);
} catch (IOException ex) {
ex.printStackTrace();
} finally {
try {
fwriter.flush();
fwriter.close();
} catch (IOException ex) {
ex.printStackTrace();
}
}
}
}

@ -0,0 +1,850 @@
/*
* Copyright (c) 2018-2028, DreamLu All rights reserved.
*
* Redistribution and use in source and binary forms, with or without
* modification, are permitted provided that the following conditions are met:
*
* Redistributions of source code must retain the above copyright notice,
* this list of conditions and the following disclaimer.
* Redistributions in binary form must reproduce the above copyright
* notice, this list of conditions and the following disclaimer in the
* documentation and/or other materials provided with the distribution.
* Neither the name of the dreamlu.net developer nor the names of its
* contributors may be used to endorse or promote products derived from
* this software without specific prior written permission.
* Author: DreamLu (596392912@qq.com)
*/
package com.docus.server.report.util;
import com.docus.core.util.Exceptions;
import com.docus.core.util.IoUtil;
import org.springframework.lang.Nullable;
import org.w3c.dom.*;
import org.xml.sax.InputSource;
import org.xml.sax.SAXException;
import javax.xml.namespace.QName;
import javax.xml.parsers.DocumentBuilder;
import javax.xml.parsers.DocumentBuilderFactory;
import javax.xml.parsers.ParserConfigurationException;
import javax.xml.xpath.XPath;
import javax.xml.xpath.XPathConstants;
import javax.xml.xpath.XPathExpressionException;
import javax.xml.xpath.XPathFactory;
import java.io.IOException;
import java.io.InputStream;
import java.io.StringReader;
import java.util.HashMap;
import java.util.Map;
/**
* xpathxml
*
* <pre>
*
* http://www.w3school.com.cn/xpath/index.asp
* </pre>
*
* @author L.cm
*/
public class XmlUtil {
private final XPath path;
private final Document doc;
private XmlUtil(InputSource inputSource) throws ParserConfigurationException, SAXException, IOException {
DocumentBuilderFactory dbf = getDocumentBuilderFactory();
DocumentBuilder db = dbf.newDocumentBuilder();
doc = db.parse(inputSource);
path = getXPathFactory().newXPath();
}
/**
*
*
* @param inputSource inputSource
* @return XmlUtil
*/
private static XmlUtil create(InputSource inputSource) {
try {
return new XmlUtil(inputSource);
} catch (ParserConfigurationException | SAXException | IOException e) {
throw Exceptions.unchecked(e);
}
}
/**
*
*
* @param inputStream inputStream
* @return XmlUtil
*/
public static XmlUtil of(InputStream inputStream) {
InputSource inputSource = new InputSource(inputStream);
return create(inputSource);
}
/**
*
*
* @param xmlStr xmlStr
* @return XmlUtil
*/
public static XmlUtil of(String xmlStr) {
StringReader sr = new StringReader(xmlStr.trim());
InputSource inputSource = new InputSource(sr);
XmlUtil xmlUtil = create(inputSource);
IoUtil.closeQuietly(sr);
return xmlUtil;
}
/**
*
*
* @param expression
* @param item
* @param returnType
* @return Object
*/
private Object evalXPath(String expression, @Nullable Object item, QName returnType) {
item = null == item ? doc : item;
try {
return path.evaluate(expression, item, returnType);
} catch (XPathExpressionException e) {
throw Exceptions.unchecked(e);
}
}
/**
* String
*
* @param expression
* @return {String}
*/
public String getString(String expression) {
return (String) evalXPath(expression, null, XPathConstants.STRING);
}
/**
* Boolean
*
* @param expression
* @return {String}
*/
public Boolean getBoolean(String expression) {
return (Boolean) evalXPath(expression, null, XPathConstants.BOOLEAN);
}
/**
* Number
*
* @param expression
* @return {Number}
*/
public Number getNumber(String expression) {
return (Number) evalXPath(expression, null, XPathConstants.NUMBER);
}
/**
*
*
* @param expression
* @return {Node}
*/
public Node getNode(String expression) {
return (Node) evalXPath(expression, null, XPathConstants.NODE);
}
/**
*
*
* @param expression
* @return NodeList
*/
public NodeList getNodeList(String expression) {
return (NodeList) evalXPath(expression, null, XPathConstants.NODESET);
}
/**
* String
*
* @param node
* @param expression node
* @return {String}
*/
public String getString(Object node, String expression) {
return (String) evalXPath(expression, node, XPathConstants.STRING);
}
/**
*
*
* @param node
* @param expression node
* @return {String}
*/
public Boolean getBoolean(Object node, String expression) {
return (Boolean) evalXPath(expression, node, XPathConstants.BOOLEAN);
}
/**
*
*
* @param node
* @param expression node
* @return {Number}
*/
public Number getNumber(Object node, String expression) {
return (Number) evalXPath(expression, node, XPathConstants.NUMBER);
}
/**
*
*
* @param node
* @param expression
* @return {Node}
*/
public Node getNode(Object node, String expression) {
return (Node) evalXPath(expression, node, XPathConstants.NODE);
}
/**
*
*
* @param node
* @param expression node
* @return NodeList
*/
public NodeList getNodeList(Object node, String expression) {
return (NodeList) evalXPath(expression, node, XPathConstants.NODESET);
}
/**
*
*
* @return map
*/
public Map<String, String> toMap() {
Element root = doc.getDocumentElement();
Map<String, String> params = new HashMap<>(16);
// 将节点封装成map形式
NodeList list = root.getChildNodes();
for (int i = 0; i < list.getLength(); i++) {
Node node = list.item(i);
if (node instanceof Element) {
params.put(node.getNodeName(), node.getTextContent());
}
}
return params;
}
private static volatile boolean preventedXXE = false;
private static DocumentBuilderFactory getDocumentBuilderFactory() throws ParserConfigurationException {
DocumentBuilderFactory dbf = XmlHelperHolder.documentBuilderFactory;
if (!preventedXXE) {
preventXXE(dbf);
}
return dbf;
}
/**
* preventXXE
*
* @param dbf
* @throws ParserConfigurationException
*/
private static void preventXXE(DocumentBuilderFactory dbf) throws ParserConfigurationException {
// This is the PRIMARY defense. If DTDs (doctypes) are disallowed, almost all XML entity attacks are prevented
// Xerces 2 only - http://xerces.apache.org/xerces2-j/features.html#disallow-doctype-decl
dbf.setFeature("http://apache.org/xml/features/disallow-doctype-decl", true);
// If you can't completely disable DTDs, then at least do the following:
// Xerces 1 - http://xerces.apache.org/xerces-j/features.html#external-general-entities
// Xerces 2 - http://xerces.apache.org/xerces2-j/features.html#external-general-entities
// JDK7+ - http://xml.org/sax/features/external-general-entities
dbf.setFeature("http://xml.org/sax/features/external-general-entities", false);
// Xerces 1 - http://xerces.apache.org/xerces-j/features.html#external-parameter-entities
// Xerces 2 - http://xerces.apache.org/xerces2-j/features.html#external-parameter-entities
// JDK7+ - http://xml.org/sax/features/external-parameter-entities
dbf.setFeature("http://xml.org/sax/features/external-parameter-entities", false);
// Disable external DTDs as well
dbf.setFeature("http://apache.org/xml/features/nonvalidating/load-external-dtd", false);
// and these as well, per Timothy Morgan's 2014 paper: "XML Schema, DTD, and Entity Attacks"
dbf.setXIncludeAware(false);
dbf.setExpandEntityReferences(false);
preventedXXE = true;
}
private static XPathFactory getXPathFactory() {
return XmlHelperHolder.xPathFactory;
}
/**
*
*/
private static class XmlHelperHolder {
private static DocumentBuilderFactory documentBuilderFactory = DocumentBuilderFactory.newInstance();
private static XPathFactory xPathFactory = XPathFactory.newInstance();
}
private static String str;
static {
str="<PRPA_HIP0032 xmlns=\"urn:hl7-org:v3\" xmlns:xsi=\"http://www.w3.org/2001/XMLSchema-instance\" ITSVersion=\"XML_1.0\" xsi:schemaLocation=\"urn:hl7-org:v3\"> \n" +
" <!--id-消息流水号--> \n" +
" <id extension=\"0f7e4a58-7ce3-436d-8d1b-aee3734e390b\"/> \n" +
" <!--creationTime-消息创建时间--> \n" +
" <creationTime value=\"20230217112826\"/> \n" +
" <!--interactionId-消息的服务标识--> \n" +
" <interactionId root=\"2.16.840.1.113883.1.6\" extension=\"PRPA_IN400003UV\"/> \n" +
" <!--processingCode-处理代码。标识此消息是否是产品、训练、调试系统的一部分。D调试P产\n" +
"品T训练--> \n" +
" <processingCode code=\"P\"/> \n" +
" <!--\n" +
"processingModeCode-处理模型代码。定义此消息是一个文档处理还是一个初始装载的一部分。A\n" +
"存档I初始装载R从存档中恢复T当前处理间隔传递。\n" +
"--> \n" +
" <processingModeCode/> \n" +
" <!--\n" +
"acceptAckCode-接收确认类型 AL总是确认NE从不确认ER仅在错误/或拒绝时确认SU 仅在成功完成时确认。\n" +
"--> \n" +
" <acceptAckCode code=\"AL\"/> \n" +
" <receiver typeCode=\"RCV\"> \n" +
" <device classCode=\"DEV\" determinerCode=\"INSTANCE\"> \n" +
" <id> \n" +
" <item extension=\"Orion-001\"/> \n" +
" </id> \n" +
" </device> \n" +
" </receiver> \n" +
" <sender typeCode=\"SND\"> \n" +
" <device classCode=\"DEV\" determinerCode=\"INSTANCE\"> \n" +
" <id> \n" +
" <item extension=\"InpatienTransfer-001\"/> \n" +
" </id> \n" +
" </device> \n" +
" </sender> \n" +
" <controlActProcess classCode=\"INFO\" moodCode=\"PRP\"> \n" +
" <code code=\"DischargeInfoAdd\"> \n" +
" <displayName value=\"出院登记信息新增\"/> \n" +
" </code> \n" +
" <subject typeCode=\"SUBJ\"> \n" +
" <encounterEvent classCode=\"ENC\" moodCode=\"EVN\"> \n" +
" <id> \n" +
" <!--住院号标识 --> \n" +
" <item root=\"2.16.156.10011.1.12\" extension=\"10082654\"/> \n" +
" </id> \n" +
" <!--住院流水号--> \n" +
" <item root=\"1.2.156.10011.1.2.1.6\" extension=\"213080\"/> \n" +
" <!--就诊事件类别代码--> \n" +
" <code code=\"3\" codeSystem=\"2.16.156.10011.2.3.1.271\" codeSystemName=\"患者类型代码表\"> \n" +
" <displayName value=\"住院\"/> \n" +
" </code> \n" +
" <statusCode/> \n" +
" <!--入\\出院日期时间--> \n" +
" <effectiveTime> \n" +
" <low value=\"20230214100923\"/> \n" +
" <high value=\"20230217160046\"/> \n" +
" </effectiveTime> \n" +
" <!--住院天数--> \n" +
" <lengthOfStayQuantity unit=\"天\" value=\"3\"/> \n" +
" <!--住院次数--> \n" +
" <lengthOfStayQuantity unit=\"次\" value=\"1\"/> \n" +
" <!--患者--> \n" +
" <subject typeCode=\"SBJ\"> \n" +
" <patient classCode=\"PAT\"> \n" +
" <!-- 域ID --> \n" +
" <id root=\"1.2.156.112635.1.2.1.2\" extension=\"03\"/> \n" +
" <id> \n" +
" <!--PatientID--> \n" +
" <item extension=\"z002082795000\"/> \n" +
" </id> \n" +
" <!--患者基本信息--> \n" +
" <patientPerson> \n" +
" <!--患者身份证号--> \n" +
" <id> \n" +
" <item root=\"2.16.156.10011.1.3\" extension=\"450881200609066029\"/> \n" +
" </id> \n" +
" <administrativeGenderCode code=\"2\" codeSystem=\"1.2.156.112635.1.1.3\" codeSystemName=\"生理性别代码表GB/T 2261.1\" displayName=\"女性\"/> \n" +
" <!--年龄(岁)/(月)--> \n" +
" <age unit=\"岁\" value=\"16岁\"/> \n" +
" <!--姓名--> \n" +
" <name xsi:type=\"DSET_EN\"> \n" +
" <item> \n" +
" <part value=\"谢雨欣\"/> \n" +
" </item> \n" +
" </name> \n" +
" </patientPerson> \n" +
" </patient> \n" +
" </subject> \n" +
" <!--登记人--> \n" +
" <discharger typeCode=\"DIS\"> \n" +
" <time>20230217112653</time> \n" +
" <assignedPerson classCode=\"ASSIGNED\"> \n" +
" <!--登记人职工号--> \n" +
" <id> \n" +
" <item root=\"2.16.156.10011.1.4\" extension=\"A-166\"/> \n" +
" </id> \n" +
" <assignedPerson classCode=\"PSN\" determinerCode=\"INSTANCE\"> \n" +
" <!--登记人姓名 --> \n" +
" <name xsi:type=\"DSET_EN\"> \n" +
" <item> \n" +
" <part value=\"潘丽华\"/> \n" +
" </item> \n" +
" </name> \n" +
" </assignedPerson> \n" +
" </assignedPerson> \n" +
" </discharger> \n" +
" <!-- 主任医师签名 --> \n" +
" <authenticator displayName=\"主任医师\"> \n" +
" <!--记录时间--> \n" +
" <time value=\"\"/> \n" +
" <signatureCode/> \n" +
" <assignedEntity> \n" +
" <id root=\"1.2.156.112635.1.1.2\" extension=\"1-173\"/> \n" +
" <code displayName=\"主任医师\"/> \n" +
" <assignedPerson classCode=\"PSN\" determinerCode=\"INSTANCE\"> \n" +
" <name>陈勇明</name> \n" +
" </assignedPerson> \n" +
" </assignedEntity> \n" +
" </authenticator> \n" +
" <!-- 主治医师签名 --> \n" +
" <authenticator displayName=\"主治医师\"> \n" +
" <time value=\"\"/> \n" +
" <signatureCode/> \n" +
" <assignedEntity> \n" +
" <id root=\"1.2.156.112635.1.1.2\" extension=\"1-691\"/> \n" +
" <code displayName=\"主治医师\"/> \n" +
" <assignedPerson classCode=\"PSN\" determinerCode=\"INSTANCE\"> \n" +
" <name>张存良</name> \n" +
" </assignedPerson> \n" +
" </assignedEntity> \n" +
" </authenticator> \n" +
" <!-- 住院医师签名 --> \n" +
" <authenticator displayName=\"住院医师\"> \n" +
" <time value=\"\"/> \n" +
" <signatureCode/> \n" +
" <assignedEntity> \n" +
" <id root=\"1.2.156.112635.1.1.2\" extension=\"1-691\"/> \n" +
" <code displayName=\"住院医师\"/> \n" +
" <assignedPerson classCode=\"PSN\" determinerCode=\"INSTANCE\"> \n" +
" <name>张存良</name> \n" +
" </assignedPerson> \n" +
" </assignedEntity> \n" +
" </authenticator> \n" +
" <!-- 出院病床号、病房、病区、科室和医院的关联 --> \n" +
" <componentOf> \n" +
" <encompassingEncounter> \n" +
" <effectiveTime/> \n" +
" <location> \n" +
" <healthCareFacility> \n" +
" <serviceProviderOrganization> \n" +
" <asOrganizationPartOf classCode=\"PART\"> \n" +
" <!-- DE01.00.026.00 病床号 --> \n" +
" <wholeOrganization classCode=\"ORG\" determinerCode=\"INSTANCE\"> \n" +
" <id root=\"1.2.156.112635.1.2.1.8\" extension=\"59\"/> \n" +
" <name>59</name> \n" +
" <!-- DE01.00.019.00 病房号 --> \n" +
" <asOrganizationPartOf classCode=\"PART\"> \n" +
" <wholeOrganization classCode=\"ORG\" determinerCode=\"INSTANCE\"> \n" +
" <id root=\"1.2.156.112635.1.2.1.28\" extension=\"001\"/> \n" +
" <name>205室</name> \n" +
" <!-- DE08.10.026.00 科室名称 --> \n" +
" <asOrganizationPartOf classCode=\"PART\"> \n" +
" <wholeOrganization classCode=\"ORG\" determinerCode=\"INSTANCE\"> \n" +
" <id root=\"1.2.156.112635.1.1.1\" extension=\"11\"/> \n" +
" <name>耳鼻咽喉头颈外科</name> \n" +
" <!-- DE08.10.054.00 病区名称 --> \n" +
" <asOrganizationPartOf classCode=\"PART\"> \n" +
" <wholeOrganization classCode=\"ORG\" determinerCode=\"INSTANCE\"> \n" +
" <id root=\"1.2.156.112635.1.1.33\" extension=\"B021601\"/> \n" +
" <name>2号楼16楼西区</name> \n" +
" <!--XXX医院 --> \n" +
" <asOrganizationPartOf classCode=\"PART\"> \n" +
" <wholeOrganization classCode=\"ORG\" determinerCode=\"INSTANCE\"> \n" +
" <id root=\"1.2.156.112635\" extension=\"4560886379\"/> \n" +
" <name>南方医科大学顺德医院</name> \n" +
" </wholeOrganization> \n" +
" </asOrganizationPartOf> \n" +
" </wholeOrganization> \n" +
" </asOrganizationPartOf> \n" +
" </wholeOrganization> \n" +
" </asOrganizationPartOf> \n" +
" </wholeOrganization> \n" +
" </asOrganizationPartOf> \n" +
" </wholeOrganization> \n" +
" </asOrganizationPartOf> \n" +
" </serviceProviderOrganization> \n" +
" </healthCareFacility> \n" +
" </location> \n" +
" </encompassingEncounter> \n" +
" </componentOf> \n" +
" <!-- 入院诊断章节 --> \n" +
" <component displayName=\"入院诊断\"> \n" +
" <section> \n" +
" <code code=\"11450-4\" displayName=\"PROBLEM LIST\" codeSystem=\"2.16.840.1.113883.6.1\" codeSystemName=\"LOINC\"/> \n" +
" <text/> \n" +
" <!--入院诊断-西医条目--> \n" +
" <entry displayName=\"入院诊断-西医条目\"> \n" +
" <observation classCode=\"OBS\" moodCode=\"EVN\"> \n" +
" <code code=\"DE05.01.025.00\" codeSystem=\"2.16.156.10011.2.2.1\" codeSystemName=\"卫生信息数据元目录\" displayName=\"入院诊断-西医诊断名称\"/> \n" +
" <!--入院诊断日期--> \n" +
" <effectiveTime value=\"20230214100923\"/> \n" +
" <value xsi:type=\"ST\">突发特发性听觉丧失</value> \n" +
" <entryRelationship typeCode=\"COMP\"> \n" +
" <observation classCode=\"OBS\" moodCode=\"EVN\"> \n" +
" <!--入院诊断-西医诊断编码-代码--> \n" +
" <code code=\"DE05.01.024.00\" codeSystem=\"2.16.156.10011.2.2.1\" codeSystemName=\"卫生信息数据元目录\" displayName=\"入院诊断-西医诊断编码\"/> \n" +
" <value xsi:type=\"CD\" code=\"\" displayName=\"\" codeSystem=\"2.16.156.10011.2.3.3.11\" codeSystemName=\"ICD-10\"/> \n" +
" </observation> \n" +
" </entryRelationship> \n" +
" </observation> \n" +
" </entry> \n" +
" <!--入院诊断-中医条目--> \n" +
" <entry displayName=\"入院诊断-中医条目\"> \n" +
" <observation classCode=\"OBS\" moodCode=\"EVN\"> \n" +
" <code code=\"DE05.10.172.00\" codeSystem=\"2.16.156.10011.2.2.1\" codeSystemName=\"卫生信息数据元目录\" displayName=\"入院诊断-中医病名名称\"/> \n" +
" <!--入院诊断日期--> \n" +
" <effectiveTime value=\"20230214100923\"/> \n" +
" <value xsi:type=\"ST\">无</value> \n" +
" <entryRelationship typeCode=\"COMP\"> \n" +
" <observation classCode=\"OBS\" moodCode=\"EVN\"> \n" +
" <!--入院诊断-中医诊断编码-代码--> \n" +
" <code code=\"\" codeSystem=\"2.16.156.10011.2.2.1\" codeSystemName=\"卫生信息数据元目录\" displayName=\"入院诊断-中医病名代码\"/> \n" +
" <value xsi:type=\"CD\" code=\"\" displayName=\"\" codeSystem=\"2.16.156.10011.2.3.3.14\" codeSystemName=\"中医病证分类与代码表( GB/T 15657)\"/> \n" +
" </observation> \n" +
" </entryRelationship> \n" +
" <entryRelationship typeCode=\"COMP\"> \n" +
" <observation classCode=\"OBS\" moodCode=\"EVN\"> \n" +
" <!--入院诊断-中医证候编码-名称--> \n" +
" <code code=\"\" codeSystem=\"2.16.156.10011.2.2.1\" codeSystemName=\"卫生信息数据元目录\" displayName=\"入院诊断-中医证候名称\"/> \n" +
" <value xsi:type=\"ST\"/> \n" +
" </observation> \n" +
" </entryRelationship> \n" +
" <entryRelationship typeCode=\"COMP\"> \n" +
" <observation classCode=\"OBS\" moodCode=\"EVN\"> \n" +
" <!--入院诊断-中医证候编码-代码--> \n" +
" <code code=\"DE05.10.130.00\" codeSystem=\"2.16.156.10011.2.2.1\" codeSystemName=\"卫生信息数据元目录\" displayName=\"入院诊断-中医证候代码\"/> \n" +
" <value xsi:type=\"CD\" code=\"\" displayName=\"\" codeSystem=\"2.16.156.10011.2.3.3.14\" codeSystemName=\"中医病证分类与代码表( GB/T 15657)\"/> \n" +
" </observation> \n" +
" </entryRelationship> \n" +
" <!--入院诊断顺位--> \n" +
" <entryRelationship typeCode=\"COMP\"> \n" +
" <observation classCode=\"OBS\" moodCode=\"EVN\"> \n" +
" <code code=\"DE05.01.080.00\" codeSystem=\"2.16.156.10011.2.2.1\" codeSystemName=\"卫生信息数据元目录\" displayName=\"入院诊断顺位\"/> \n" +
" <value xsi:type=\"INT\" value=\"1\"/> \n" +
" </observation> \n" +
" </entryRelationship> \n" +
" </observation> \n" +
" </entry> \n" +
" <entry displayName=\"阳性辅助检查\"> \n" +
" <observation classCode=\"OBS\" moodCode=\"EVN\"> \n" +
" <code code=\"DE04.50.128.00\" codeSystem=\"2.16.156.10011.2.2.1\" codeSystemName=\"卫生信息数据元目录\" displayName=\"阳性辅助检查结果\"/> \n" +
" <value xsi:type=\"ST\"/> \n" +
" </observation> \n" +
" </entry> \n" +
" <entry displayName=\"中医“四诊”观察\"> \n" +
" <observation classCode=\"OBS\" moodCode=\"EVN\"> \n" +
" <code code=\"DE02.10.028.00\" codeSystem=\"2.16.156.10011.2.2.1\" codeSystemName=\"卫生信息数据元目录\" displayName=\"中医“四诊”观察结果\"/> \n" +
" <value xsi:type=\"ST\"/> \n" +
" </observation> \n" +
" </entry> \n" +
" <entry displayName=\"治则治法\"> \n" +
" <observation classCode=\"OBS\" moodCode=\"EVN\"> \n" +
" <code code=\"DE06.00.300.00\" displayName=\"治则治法\" codeSystem=\"2.16.156.10011.2.2.1\" codeSystemName=\"卫生信息数据元目录\"/> \n" +
" <value xsi:type=\"ST\"/> \n" +
" </observation> \n" +
" </entry> \n" +
" </section> \n" +
" </component> \n" +
" <!-- 主要健康问题章节 --> \n" +
" <component displayName=\"主要健康问题\"> \n" +
" <section> \n" +
" <code code=\"11450-4\" displayName=\"Problem list\" codeSystem=\"2.16.840.1.113883.6.1\" codeSystemName=\"LOINC\"/> \n" +
" <text/> \n" +
" <entry> \n" +
" <observation classCode=\"OBS\" moodCode=\"EVN\"> \n" +
" <code code=\"DE05.10.148.00\" codeSystem=\"2.16.156.10011.2.2.1\" codeSystemName=\"卫生信息数据元目录\" displayName=\"入院情况\"/> \n" +
" <value xsi:type=\"ST\">常规</value> \n" +
" </observation> \n" +
" </entry> \n" +
" </section> \n" +
" </component> \n" +
" <!-- 住院过程章节 --> \n" +
" <component displayName=\"住院过程\"> \n" +
" <section> \n" +
" <code code=\"8648-8\" displayName=\"Hospital Course\" codeSystem=\"2.16.840.1.113883.6.1\" codeSystemName=\"LOINC\"/> \n" +
" <text/> \n" +
" <entry> \n" +
" <observation classCode=\"OBS\" moodCode=\"EVN\"> \n" +
" <code code=\"DE06.00.296.00\" codeSystem=\"2.16.156.10011.2.2.1\" codeSystemName=\"卫生信息数据元目录\" displayName=\"诊疗过程描述\"/> \n" +
" <value xsi:type=\"ST\"/> \n" +
" </observation> \n" +
" </entry> \n" +
" </section> \n" +
" </component> \n" +
" <!-- 医嘱(用药)章节 --> \n" +
" <component displayName=\"医嘱(用药)\"> \n" +
" <section> \n" +
" <code code=\"46209-3\" codeSystem=\"2.16.840.1.113883.6.1\" displayName=\"Provider Orders\" codeSystemName=\"LOINC\"/> \n" +
" <text/> \n" +
" <entry displayName=\"中药用药方法煎煮方法\"> \n" +
" <observation classCode=\"OBS\" moodCode=\"EVN\"> \n" +
" <code code=\"DE08.50.047.00\" codeSystem=\"2.16.156.10011.2.2.1\" codeSystemName=\"卫生信息数据元目录\" displayName=\"中药用药方法煎煮方法\"/> \n" +
" <value xsi:type=\"ST\"/> \n" +
" </observation> \n" +
" </entry> \n" +
" <entry displayName=\"中药用药方法\"> \n" +
" <observation classCode=\"OBS\" moodCode=\"EVN\"> \n" +
" <code code=\"DE06.00.136.00\" codeSystem=\"2.16.156.10011.2.2.1\" codeSystemName=\"卫生信息数据元目录\" displayName=\"中药用药方法\"/> \n" +
" <value xsi:type=\"ST\"/> \n" +
" </observation> \n" +
" </entry> \n" +
" </section> \n" +
" </component> \n" +
" <!-- 出院诊断章节 --> \n" +
" <component displayName=\"出院诊断\"> \n" +
" <section> \n" +
" <code code=\"11535-2\" displayName=\"Discharge Diagnosis\" codeSystem=\"2.16.840.1.113883.6.1\" codeSystemName=\"LOINC\"/> \n" +
" <text/> \n" +
" <entry displayName=\"出院情况\"> \n" +
" <observation classCode=\"OBS\" moodCode=\"EVN\"> \n" +
" <code code=\"DE06.00.193.00\" codeSystem=\"2.16.156.10011.2.2.1\" codeSystemName=\"卫生信息数据元目录\" displayName=\"出院情况\"/> \n" +
" <value xsi:type=\"ST\">治愈</value> \n" +
" </observation> \n" +
" </entry> \n" +
" <entry displayName=\"出院日期时间\"> \n" +
" <observation classCode=\"OBS\" moodCode=\"EVN\"> \n" +
" <code code=\"DE06.00.017.00\" codeSystem=\"2.16.156.10011.2.2.1\" codeSystemName=\"卫生信息数据元目录\" displayName=\"出院日期时间\"/> \n" +
" <value xsi:type=\"TS\" value=\"20230217160046\"/> \n" +
" </observation> \n" +
" </entry> \n" +
" <!--出院诊断-西医条目--> \n" +
" <entry displayName=\"出院诊断-西医条目\"> \n" +
" <observation classCode=\"OBS\" moodCode=\"EVN\"> \n" +
" <code code=\"DE05.01.025.00\" codeSystem=\"2.16.156.10011.2.2.1\" codeSystemName=\"卫生信息数据元目录\" displayName=\"西医诊断名称\"/> \n" +
" <!--出院诊断日期--> \n" +
" <effectiveTime value=\"20230217160046\"/> \n" +
" <!-- 诊断医师信息 --> \n" +
" <performer typeCode=\"PRF \"> \n" +
" <assignedEntity> \n" +
" <!-- 诊断医生编码 --> \n" +
" <id root=\"1.2.156.112635.1.1.2\" extension=\"1-691\"/> \n" +
" <assignedPerson determinerCode=\"INSTANCE\" classCode=\"PSN\"> \n" +
" <!-- 诊断医生名称 --> \n" +
" <name>张存良</name> \n" +
" </assignedPerson> \n" +
" <representedOrganization classCode=\"ORG\" determinerCode=\"INSTANCE\"> \n" +
" <!-- 诊断科室编码 --> \n" +
" <id root=\"1.2.156.112635.1.1.1\" extension=\"11\"/> \n" +
" <!-- 诊断科室名称 --> \n" +
" <name>耳鼻咽喉头颈外科</name> \n" +
" </representedOrganization> \n" +
" </assignedEntity> \n" +
" </performer> \n" +
" <!--诊断类别 --> \n" +
" <code code=\"H91.200\" codeSystem=\"1.2.156.112635.1.1.29\"> \n" +
" <displayName value=\"出院诊断\">突发特发性听觉丧失</displayName> \n" +
" </code> \n" +
" <!-- 诊断依据 --> \n" +
" <entryRelationship displayName=\"诊断依据\"> \n" +
" <observation classCode=\"OBS\" moodCode=\"EVN\"> \n" +
" <code code=\"DE05.01.070.00\" codeSystem=\"2.16.156.10011.2.2.1\" codeSystemName=\"卫生信息数据元目录 \" displayName=\"诊断依据代码\"/> \n" +
" <value xsi:type=\"ST\" code=\"XXX\">文本</value> \n" +
" </observation> \n" +
" </entryRelationship> \n" +
" <entryRelationship displayName=\"是否主要诊断\"> \n" +
" <observation classCode=\"OBS\" moodCode=\"EVN\"> \n" +
" <code displayName=\"是否主要诊断\"/> \n" +
" <value xsi:type=\"BL\" value=\"false\"/> \n" +
" </observation> \n" +
" </entryRelationship> \n" +
" <entryRelationship displayName=\"是否待查\"> \n" +
" <observation classCode=\"OBS\" moodCode=\"EVN\"> \n" +
" <code displayName=\"是否待查\"/> \n" +
" <value xsi:type=\"BL\" value=\"false\"/> \n" +
" </observation> \n" +
" </entryRelationship> \n" +
" <entryRelationship displayName=\"是否传染病\"> \n" +
" <observation classCode=\"OBS\" moodCode=\"EVN\"> \n" +
" <code displayName=\"是否传染病\"/> \n" +
" <value xsi:type=\"BL\" value=\"false\"/> \n" +
" </observation> \n" +
" </entryRelationship> \n" +
" <!-- 诊断标识号 --> \n" +
" <diagnosisNum value=\"诊断标识号\"/> \n" +
" <value xsi:type=\"ST\"/> \n" +
" <entryRelationship typeCode=\"COMP\" displayName=\"出院诊断-西医诊断\"> \n" +
" <observation classCode=\"OBS\" moodCode=\"EVN\"> \n" +
" <!--出院诊断-西医诊断编码-代码--> \n" +
" <code code=\"DE05.01.024.00\" codeSystem=\"2.16.156.10011.2.2.1\" codeSystemName=\"卫生信息数据元目录\" displayName=\"出院诊断-西医诊断编码\"/> \n" +
" <value xsi:type=\"CD\" code=\"\" displayName=\"\" codeSystem=\"2.16.156.10011.2.3.3.11\" codeSystemName=\"ICD-10\"/> \n" +
" </observation> \n" +
" </entryRelationship> \n" +
" <entryRelationship displayName=\"其他西医诊断\"> \n" +
" <observation classCode=\"OBS\" moodCode=\"EVN\"> \n" +
" <code code=\"DE05.01.024.00\" displayName=\"其他西医诊断编码\" codeSystem=\"2.16.156.10011.2.2.1\" codeSystemName=\"卫生信息数据元目录\"> \n" +
" <qualifier> \n" +
" <name displayName=\"其他西医诊断编码\"/> \n" +
" </qualifier> \n" +
" </code> \n" +
" <value xsi:type=\"CD\" code=\"\" displayName=\"\" codeSystem=\"2.16.156.10011.2.3.3.11\" codeSystemName=\"ICD-10\"/> \n" +
" </observation> \n" +
" </entryRelationship> \n" +
" <!--出院诊断顺位--> \n" +
" <entryRelationship typeCode=\"COMP\" displayName=\"出院诊断顺位\"> \n" +
" <observation classCode=\"OBS\" moodCode=\"EVN\"> \n" +
" <code code=\"DE05.01.080.00\" codeSystem=\"2.16.156.10011.2.2.1\" codeSystemName=\"卫生信息数据元目录\" displayName=\"出院诊断顺位\"/> \n" +
" <value xsi:type=\"INT\" value=\"01\"/> \n" +
" </observation> \n" +
" </entryRelationship> \n" +
" <!--其他医学处置--> \n" +
" <entryRelationship typeCode=\"COMP\" displayName=\"其他医学处置\"> \n" +
" <observation classCode=\"OBS\" moodCode=\"EVN\"> \n" +
" <code code=\"DE06.00.251.00\" displayName=\"其他医学处置\" codeSystem=\"2.16.156.10011.2.2.1\" codeSystemName=\"卫生信息数据元目录\"/> \n" +
" <value xsi:type=\"ST\">无</value> \n" +
" </observation> \n" +
" </entryRelationship> \n" +
" </observation> \n" +
" </entry> \n" +
" <!--出院诊断-中医条目--> \n" +
" <entry displayName=\"出院诊断-中医条目\"> \n" +
" <observation classCode=\"OBS\" moodCode=\"EVN\"> \n" +
" <code code=\"DE05.10.172.00\" codeSystem=\"2.16.156.10011.2.2.1\" codeSystemName=\"卫生信息数据元目录\" displayName=\"出院诊断-中医病名代码\"/> \n" +
" <!--出院诊断日期--> \n" +
" <effectiveTime value=\"20230217160046\"/> \n" +
" <!--中药使用类别--> \n" +
" <entryRelationship typeCode=\"COMP\" displayName=\"中药使用类别\"> \n" +
" <observation classCode=\"OBS\" moodCode=\"EVN\"> \n" +
" <code code=\"DE06.00.164.00\" codeSystem=\"2.16.156.10011.2.2.1\" codeSystemName=\"卫生信息数据元目录\" displayName=\"中药使用类别代码\"/> \n" +
" <!--中药使用类别代码--> \n" +
" <value code=\"9\" displayName=\"其他中药\" codeSystem=\"2.16.156.10011.2.3.1.157\" codeSystemName=\"中药使用类别代码表\" xsi:type=\"CD\"/> \n" +
" </observation> \n" +
" </entryRelationship> \n" +
" <value xsi:type=\"ST\">乳房病类</value> \n" +
" <entryRelationship typeCode=\"COMP\" displayName=\"出院诊断-中医病名\"> \n" +
" <observation classCode=\"OBS\" moodCode=\"EVN\"> \n" +
" <!--出院诊断-中医诊断编码-代码--> \n" +
" <code code=\"DE05.10.130.00\" codeSystem=\"2.16.156.10011.2.2.1\" codeSystemName=\"卫生信息数据元目录\" displayName=\"出院诊断-中医病名代码\"/> \n" +
" <value xsi:type=\"CD\" code=\"\" displayName=\"\" codeSystem=\"2.16.156.10011.2.3.3.14\" codeSystemName=\"中医病证分类与代码表( GB/T 15657)\"/> \n" +
" </observation> \n" +
" </entryRelationship> \n" +
" <entryRelationship typeCode=\"COMP\" displayName=\"出院诊断-中医证候\"> \n" +
" <observation classCode=\"OBS\" moodCode=\"EVN\"> \n" +
" <!--出院诊断-中医证候编码-名称--> \n" +
" <code code=\"\" codeSystem=\"2.16.156.10011.2.2.1\" codeSystemName=\"卫生信息数据元目录\" displayName=\"出院诊断-中医证候名称\"/> \n" +
" <value xsi:type=\"ST\"/> \n" +
" </observation> \n" +
" </entryRelationship> \n" +
" <entryRelationship typeCode=\"COMP\" displayName=\"出院诊断-中医证候\"> \n" +
" <observation classCode=\"OBS\" moodCode=\"EVN\"> \n" +
" <!--出院诊断-中医证候编码-代码--> \n" +
" <code code=\"DE05.10.130.00\" codeSystem=\"2.16.156.10011.2.2.1\" codeSystemName=\"卫生信息数据元目录\" displayName=\"出院诊断-中医证候代码\"/> \n" +
" <value xsi:type=\"CD\" code=\"\" displayName=\"\" codeSystem=\"2.16.156.10011.2.3.3.14\" codeSystemName=\"中医病证分类与代码表( GB/T 15657)\"/> \n" +
" </observation> \n" +
" </entryRelationship> \n" +
" <!--出院诊断顺位--> \n" +
" <entryRelationship typeCode=\"COMP\" displayName=\"出院诊断顺位\"> \n" +
" <observation classCode=\"OBS\" moodCode=\"EVN\"> \n" +
" <code code=\"DE05.01.080.00\" codeSystem=\"2.16.156.10011.2.2.1\" codeSystemName=\"卫生信息数据元目录\" displayName=\"出院诊断顺位\"/> \n" +
" <value xsi:type=\"INT\" value=\"\"/> \n" +
" </observation> \n" +
" </entryRelationship> \n" +
" </observation> \n" +
" </entry> \n" +
" <entry displayName=\"出院时症状与体征\"> \n" +
" <observation classCode=\"OBS\" moodCode=\"EVN\"> \n" +
" <code code=\"DE04.01.117.00\" codeSystem=\"2.16.156.10011.2.2.1\" codeSystemName=\"卫生信息数据元目录\" displayName=\"出院时症状与体征\"/> \n" +
" <value xsi:type=\"ST\"/> \n" +
" </observation> \n" +
" </entry> \n" +
" <entry displayName=\"出院医嘱\"> \n" +
" <observation classCode=\"OBS\" moodCode=\"EVN\"> \n" +
" <code code=\"DE06.00.287.00\" codeSystem=\"2.16.156.10011.2.2.1\" codeSystemName=\"卫生信息数据元目录\" displayName=\"出院医嘱\"/> \n" +
" <value xsi:type=\"ST\"/> \n" +
" </observation> \n" +
" </entry> \n" +
" <!-- 抗菌药物接口所需 --> \n" +
" <antibacterial_drugs> \n" +
" <!-- 诊断类别 --> \n" +
" <diagClass/> \n" +
" <!-- 治疗情况 --> \n" +
" <diagResult/> \n" +
" <!-- 治愈医生工号 --> \n" +
" <healDoc/> \n" +
" </antibacterial_drugs> \n" +
" </section> \n" +
" </component> \n" +
" </encounterEvent> \n" +
" </subject> \n" +
" </controlActProcess> \n" +
" <emr> \n" +
" <!-- 离院方式 --> \n" +
" <P_OUT_TYPE/> \n" +
" <!-- 治疗转归 --> \n" +
" <P_OUT_STATE>治愈</P_OUT_STATE> \n" +
" <!-- 在院状态在院是I出院是O取消入院是N --> \n" +
" <P_IN_STATE>O</P_IN_STATE> \n" +
" <!-- 总费用 --> \n" +
" <TOTAL_COSTS>0</TOTAL_COSTS> \n" +
" </emr> \n" +
" <!-- 抗菌药物接口所需 --> \n" +
" <antibacterial_drugs> \n" +
" <!-- 出院结算类型代码 --> \n" +
" <rcptPolicy>01</rcptPolicy> \n" +
" <!-- 出院医嘱名称 --> \n" +
" <dischgState>出院医嘱</dischgState> \n" +
" </antibacterial_drugs> \n" +
"</PRPA_HIP0032>\n";
}
public static void main(String[] args) {
XmlUtil a=XmlUtil.of(str);
Node node=null;
//id-消息流水号
node = a.getNode("/PRPA_HIP0032/id/@extension");
String serialId = node.toString();
System.out.println(serialId);
//住院流水号
node = a.getNode("/PRPA_HIP0032/controlActProcess/subject/encounterEvent/item/@extension");
String jzh = node.toString();
System.out.println(jzh);
//住院号标识
node = a.getNode("/PRPA_HIP0032/controlActProcess/subject/encounterEvent/id/item/@extension");
String inpatientNo = node.toString();
System.out.println(inpatientNo);
//住院次数[]
node = a.getNode("/PRPA_HIP0032/controlActProcess/subject/encounterEvent/lengthOfStayQuantity[@unit='次']/@value");
String admissTimes=node.toString();
System.out.println(admissTimes);
//姓名
node = a.getNode("/PRPA_HIP0032/controlActProcess/subject/encounterEvent/subject/patient/patientPerson/name/item/part/@value");
String name = node.toString();
System.out.println(name);
//入院日期时间
node = a.getNode("/PRPA_HIP0032/controlActProcess/subject/encounterEvent/effectiveTime/low/@value");
String admissDate = node.toString();
System.out.println(admissDate);
//出院日期时间
node = a.getNode("/PRPA_HIP0032/controlActProcess/subject/encounterEvent/effectiveTime/high/@value");
String disDate = node.toString();
System.out.println(disDate);
//入院诊断科室名称[]
node = a.getNode("/PRPA_HIP0032/controlActProcess/subject/encounterEvent/component[@displayName='入院诊断']/section/entry[@displayName='入院诊断-西医条目']/observation/performer/assignedEntity/representedOrganization/name");
String admissDeptName = node.getTextContent();
System.out.println(admissDeptName);
//出院诊断科室名称[]
node = a.getNode("/PRPA_HIP0032/controlActProcess/subject/encounterEvent/component[@displayName='出院诊断']/section/entry[@displayName='出院诊断-西医条目']/observation/performer/assignedEntity/representedOrganization/name");
String disDeptName = node.getTextContent();
System.out.println(disDeptName);
//主治医师[]
node = a.getNode("/PRPA_HIP0032/controlActProcess/subject/encounterEvent/authenticator[@displayName='主治医师']/assignedEntity/assignedPerson/name");
String attendingName = node.getTextContent();
System.out.println(attendingName);
}
}

@ -0,0 +1,39 @@
package com.docus.server.report.webservice;
import javax.jws.WebMethod;
import javax.jws.WebService;
/**
* @author Fang Ruichuan
* @date 2022-11-14 19:03
*/
@WebService
public interface IReportServer {
/**
*
* @param saReportMessage
* @return
*/
String pushSAReport(String saReportMessage);
/**
*
* @param icuReportMessage
* @return
*/
String pushICUReport(String icuReportMessage);
/**
* -
* @param inspectionReportMessage -
* @return
*/
String pushAddInspectionReport(String inspectionReportMessage);
/**
* -
* @param inspectionReportMessage -
* @return
*/
String pushUpdateInspectionReport(String inspectionReportMessage);
}

@ -0,0 +1,529 @@
package com.docus.server.report.webservice.impl;
import com.alibaba.fastjson.JSONObject;
import com.docus.core.util.DateUtil;
import com.docus.core.util.Func;
import com.docus.infrastructure.core.exception.BaseException;
import com.docus.server.report.dto.ReportDto;
import com.docus.server.report.service.ReportService;
import com.docus.server.report.util.IdUtil;
import com.docus.server.report.util.JSXMLResult;
import com.docus.server.report.util.TableJsonRead;
import com.docus.server.report.util.XmlUtil;
import com.docus.server.report.webservice.IReportServer;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;
import org.w3c.dom.Node;
import javax.annotation.Resource;
import java.util.Date;
/**
* @author wyb
* @date 20233313:42:36
*/
@Service
@Slf4j
public class SdryReportServerImpl implements IReportServer {
@Resource
private ReportService reportService;
@Override
public String pushSAReport(String saReportMessage) {
// 待做
log.info("收到手麻消息:{}", saReportMessage);
String msgId = "";
try {
XmlUtil xmlUtil = XmlUtil.of(saReportMessage);
Node msgNode = xmlUtil.getNode("/Request/Msg/ID");
msgId = msgNode.getTextContent();
ReportDto reportDto = getReportDtoByJSXML(xmlUtil);
verifyReportDto(reportDto);
reportService.report(reportDto);
return JSXMLResult.success(msgId);
} catch (BaseException baseException) {
log.error(baseException.getMessage(), baseException);
return JSXMLResult.failed(msgId, baseException.getMessage());
} catch (Exception ex) {
log.error(ex.getMessage(), ex);
return JSXMLResult.failed(msgId, "系统故障!");
}
}
/**
* 使xml
*
* @param xmlUtil xml
* @return
*/
public ReportDto getReportDtoByJSXML(XmlUtil xmlUtil) {
TableJsonRead jsonRead = new TableJsonRead();
JSONObject tableTypeJson = jsonRead.Read("data-config", "js-table-type.json", JSONObject.class);
String jsReportConfigXml = jsonRead.ReadContent("data-config", "js-report-config.xml");
XmlUtil configXmlUtil = XmlUtil.of(jsReportConfigXml);
Node inpatientNoXpathNode = configXmlUtil.getNode("/REPORT/INPATIENT_NO");
String inpatientNoXpath = inpatientNoXpathNode.getTextContent();
Node inpatientNoNode = xmlUtil.getNode(inpatientNoXpath);
String inpatientNo = inpatientNoNode.getTextContent();
Node jzhXpathNode = configXmlUtil.getNode("/REPORT/JZH");
String jzhXpath = jzhXpathNode.getTextContent();
Node jzhNode = xmlUtil.getNode(jzhXpath);
String jzh = jzhNode.getTextContent();
Node admissTimesXpathNode = configXmlUtil.getNode("/REPORT/ADMISS_TIMES");
String admissTimesXpath = admissTimesXpathNode.getTextContent();
Node admissTimesNode = xmlUtil.getNode(admissTimesXpath);
Integer admissTimes = Integer.valueOf(admissTimesNode.getTextContent());
Node serialnumXpathNode = configXmlUtil.getNode("/REPORT/SERIALNUM");
String serialnumXpath = serialnumXpathNode.getTextContent();
Node serialnumNode = xmlUtil.getNode(serialnumXpath);
String serialnum = serialnumNode.getTextContent();
Node fileTitleXpathNode = configXmlUtil.getNode("/REPORT/FILE_TITLE");
String fileTitleXpath = fileTitleXpathNode.getTextContent();
Node fileTitleNode = xmlUtil.getNode(fileTitleXpath);
String fileTitle = fileTitleNode.getTextContent();
Node downUrlXpathNode = configXmlUtil.getNode("/REPORT/DOWNURL");
String downUrlXpath = downUrlXpathNode.getTextContent();
Node downUrlNode = xmlUtil.getNode(downUrlXpath);
String downUrl = downUrlNode.getTextContent();
Node tableTypeXpathNode = configXmlUtil.getNode("/REPORT/TABLE_TYPE");
String tableTypeXpath = tableTypeXpathNode.getTextContent();
Node tableTypeNode = xmlUtil.getNode(tableTypeXpath);
String tableType = tableTypeNode.getTextContent();
Node assortIdXpathNode = configXmlUtil.getNode("/REPORT/ASSORT_ID");
String assortIdXpath = assortIdXpathNode.getTextContent();
String assortId;
if (Func.isBlank(assortIdXpath)) {
// 如果没有配置 取value 属性如果value也未配置 取 tableType 对应的json配置最终方案默认 other 分段
Node assortIdValueNode = assortIdXpathNode.getAttributes().getNamedItem("value");
if (Func.isEmpty(assortIdValueNode)) {
assortId = assortIdValueNode.getNodeValue();
} else {
assortId = tableTypeJson.getString(tableType);
}
if (Func.isBlank(assortId)) {
assortId = tableTypeJson.getString("other");
}
} else {
Node assortIdNode = xmlUtil.getNode(assortIdXpath);
assortId = assortIdNode.getTextContent();
}
Node sysFlagXpathNode = configXmlUtil.getNode("/REPORT/SYSTEM_FLAG");
String sysFlagXpath = sysFlagXpathNode.getTextContent();
Node sysFlagNode = xmlUtil.getNode(sysFlagXpath);
String sysFlag = sysFlagNode.getTextContent();
Node fileSourceXpathNode = configXmlUtil.getNode("/REPORT/FILESOURCE");
String fileSourceXpath = fileSourceXpathNode.getTextContent();
String fileSource;
if (Func.isBlank(fileSourceXpath)) {
Node fileSourceValueNode = fileSourceXpathNode.getAttributes().getNamedItem("value");
if (Func.isEmpty(fileSourceValueNode)) {
fileSource = null;
} else {
fileSource = fileSourceValueNode.getNodeValue();
}
} else {
Node fileSourceNode = xmlUtil.getNode(fileSourceXpath);
fileSource = fileSourceNode.getTextContent();
}
Node fileStorageTypeXpathNode = configXmlUtil.getNode("/REPORT/FILE_STORAGE_TYPE");
String fileStorageTypeXpath = fileStorageTypeXpathNode.getTextContent();
String fileStorageType;
if (Func.isBlank(fileStorageTypeXpath)) {
Node filestoragetypeValueNode = fileStorageTypeXpathNode.getAttributes().getNamedItem("value");
if (Func.isEmpty(filestoragetypeValueNode)) {
fileStorageType = "1";
} else {
fileStorageType = filestoragetypeValueNode.getNodeValue();
}
} else {
Node filestoragetypeNode = xmlUtil.getNode(fileStorageTypeXpath);
fileStorageType = filestoragetypeNode.getTextContent();
}
ReportDto reportDto = new ReportDto();
reportDto.setAdmisstimes(admissTimes);
reportDto.setInpatientNo(inpatientNo);
reportDto.setJzh(jzh);
reportDto.setSerialnum(serialnum);
reportDto.setFileTitle(fileTitle);
reportDto.setDownUrl(downUrl);
reportDto.setAssortId(assortId);
reportDto.setSysFlag(sysFlag);
reportDto.setFileSource(fileSource);
reportDto.setFilestoragetype(fileStorageType);
return reportDto;
}
@Override
public String pushICUReport(String icuReportMessage) {
log.info("收到重症消息:{}", icuReportMessage);
String msgId = "";
try {
XmlUtil xmlUtil = XmlUtil.of(icuReportMessage);
Node msgNode = xmlUtil.getNode("/Request/Msg/ID");
msgId = msgNode.getTextContent();
ReportDto reportDto = getReportDtoByJSXML(xmlUtil);
verifyReportDto(reportDto);
reportService.report(reportDto);
return JSXMLResult.success(msgId);
} catch (BaseException baseException) {
log.error(baseException.getMessage(), baseException);
return JSXMLResult.failed(msgId, baseException.getMessage());
} catch (Exception ex) {
log.error(ex.getMessage(), ex);
return JSXMLResult.failed(msgId, "系统故障!");
}
}
@Override
public String pushAddInspectionReport(String inspectionReportMessage) {
log.info("收到检查报告新增消息:{}", inspectionReportMessage);
String msgId = "";
String sender = "";
String receiver = "";
try {
XmlUtil xmlUtil = XmlUtil.of(inspectionReportMessage);
msgId = xmlUtil.getNode("/POOR_HIP1008/id/@extension").getNodeValue();
sender = xmlUtil.getNode("/POOR_HIP1008/sender/device/id/item/@extension").getNodeValue();
receiver = xmlUtil.getNode("/POOR_HIP1008/receiver/device/id/item/@extension").getNodeValue();
ReportDto reportDto = getReportDtoByInspectionInsert(xmlUtil);
verifyReportDto(reportDto);
reportService.report(reportDto);
return insertSuccess(msgId, sender, receiver);
} catch (BaseException baseException) {
log.error(baseException.getMessage(), baseException);
return insertFailed(msgId, sender, receiver, baseException.getMessage());
} catch (Exception ex) {
log.error(ex.getMessage(), ex);
return insertFailed(msgId, sender, receiver, "系统错误!");
}
}
@Override
public String pushUpdateInspectionReport(String inspectionReportMessage) {
log.info("收到检查报告更新消息{}", inspectionReportMessage);
String msgId = "";
String sender = "";
String receiver = "";
try {
XmlUtil xmlUtil = XmlUtil.of(inspectionReportMessage);
msgId = xmlUtil.getNode("/POOR_HIP1009/id/@extension").getNodeValue();
sender = xmlUtil.getNode("/POOR_HIP1009/sender/device/id/item/@extension").getNodeValue();
receiver = xmlUtil.getNode("/POOR_HIP1009/receiver/device/id/item/@extension").getNodeValue();
ReportDto reportDto = getReportDtoByInspectionUpdate(xmlUtil);
verifyReportDto(reportDto);
reportService.report(reportDto);
return updateSuccess(msgId, sender, receiver);
} catch (BaseException baseException) {
log.error(baseException.getMessage(), baseException);
return updateFailed(msgId, sender, receiver, baseException.getMessage());
} catch (Exception ex) {
log.error(ex.getMessage(), ex);
return updateFailed(msgId, sender, receiver, "系统错误");
}
}
/**
*
*
* @param reportDto
* @throws BaseException
*/
private void verifyReportDto(ReportDto reportDto) throws BaseException {
if (Func.isBlank(reportDto.getInpatientNo())) {
throw new BaseException("住院号不能为空!");
}
if (Func.isEmpty(reportDto.getAdmisstimes()) && Func.isBlank(reportDto.getJzh())) {
throw new BaseException("当住院号与住院次数都为空时,住院流水号/记账号不能为空!");
}
if (Func.isBlank(reportDto.getFileTitle())) {
throw new BaseException("文件名不能为空!");
}
if (Func.isBlank(reportDto.getDownUrl())) {
throw new BaseException("文件下载路径不能为空!");
}
}
public ReportDto getReportDtoByInspectionInsert(XmlUtil inspectionInsertXmlUtil) {
Node inpatientNoNode = inspectionInsertXmlUtil.getNode("/POOR_HIP1008/controlActProcess/subject/recordTarget/patientRole/id[@root='2.16.156.10011.1.12']/@extension");
String inpatientNo = inpatientNoNode.getNodeValue();
Node admissTimesNode = inspectionInsertXmlUtil.getNode("/POOR_HIP1008/controlActProcess/subject/recordTarget/patientRole/item[@root='1.2.156.112635.1.2.1.7']/@extension");
Integer admissTimes = Integer.valueOf(admissTimesNode.getNodeValue());
// 检查报告单号标识
Node reportFlagNode = inspectionInsertXmlUtil.getNode("/POOR_HIP1008/controlActProcess/subject/recordTarget/patientRole/id[@root='2.16.156.10011.1.32']/@extension");
String reportFlag = reportFlagNode.getNodeValue();
//电子申请单编号
Node eafNoNode = inspectionInsertXmlUtil.getNode("/POOR_HIP1008/controlActProcess/subject/recordTarget/patientRole/id[@root='2.16.156.10011.1.24']/@extension");
String eafNo = eafNoNode.getNodeValue();
String serialnum = reportFlag + "@" + eafNo;
Node assortIdNode = inspectionInsertXmlUtil.getNode("/POOR_HIP1008/controlActProcess/subject/component/structuredBody/component[@displayName='检查报告']/section/entry[@displayName='检查类型']/observation/code/@displayName");
String assortId = assortIdNode.getNodeValue();
Node sysFlagNode = inspectionInsertXmlUtil.getNode("/POOR_HIP1008/controlActProcess/subject/component/structuredBody/component[@displayName='检查报告']/section/entry[@displayName='检查类型']/observation/code/@displayName");
String sysFlag = sysFlagNode.getNodeValue();
Node fileTitleNode = inspectionInsertXmlUtil.getNode("/POOR_HIP1008/controlActProcess/subject/component/structuredBody/component[@displayName='检查报告']/section/entry[@displayName='检查报告类型']/observation/code/@displayName");
String fileTitle = fileTitleNode.getNodeValue();
Node downUrlNode = inspectionInsertXmlUtil.getNode("/POOR_HIP1008/controlActProcess/subject/component/structuredBody/component[@displayName='检查报告图像']/report/entry[@displayName='检查报告图像URL地址']/observation/value");
String downUrl = downUrlNode.getTextContent();
ReportDto reportDto = new ReportDto();
reportDto.setAdmisstimes(admissTimes);
reportDto.setInpatientNo(inpatientNo);
reportDto.setSerialnum(serialnum);
reportDto.setFileTitle(fileTitle);
reportDto.setDownUrl(downUrl);
reportDto.setAssortId(assortId);
reportDto.setSysFlag(sysFlag);
reportDto.setFileSource("1");
reportDto.setFilestoragetype("1");
return reportDto;
}
public ReportDto getReportDtoByInspectionUpdate(XmlUtil inspectionUpdateXmlUtil) {
Node inpatientNoNode = inspectionUpdateXmlUtil.getNode("/POOR_HIP1009/controlActProcess/subject/recordTarget/patientRole/id[@root='2.16.156.10011.1.12']/@extension");
String inpatientNo = inpatientNoNode.getNodeValue();
Node admissTimesNode = inspectionUpdateXmlUtil.getNode("/POOR_HIP1009/controlActProcess/subject/recordTarget/patientRole/item[@root='1.2.156.112635.1.2.1.7']/@extension");
Integer admissTimes = Integer.valueOf(admissTimesNode.getNodeValue());
// 检查报告单号标识
Node reportFlagNode = inspectionUpdateXmlUtil.getNode("/POOR_HIP1009/controlActProcess/subject/recordTarget/patientRole/id[@root='2.16.156.10011.1.32']/@extension");
String reportFlag = reportFlagNode.getNodeValue();
//电子申请单编号
Node eafNoNode = inspectionUpdateXmlUtil.getNode("/POOR_HIP1009/controlActProcess/subject/recordTarget/patientRole/id[@root='2.16.156.10011.1.24']/@extension");
String eafNo = eafNoNode.getNodeValue();
String serialnum = reportFlag + "@" + eafNo;
Node assortIdNode = inspectionUpdateXmlUtil.getNode("/POOR_HIP1009/controlActProcess/subject/component/structuredBody/component[@displayName='检查报告']/section/entry[@displayName='检查类型']/observation/code/@displayName");
String assortId = assortIdNode.getNodeValue();
Node sysFlagNode = inspectionUpdateXmlUtil.getNode("/POOR_HIP1009/controlActProcess/subject/component/structuredBody/component[@displayName='检查报告']/section/entry[@displayName='检查类型']/observation/code/@displayName");
String sysFlag = sysFlagNode.getNodeValue();
Node fileTitleNode = inspectionUpdateXmlUtil.getNode("/POOR_HIP1009/controlActProcess/subject/component/structuredBody/component[@displayName='检查报告']/section/entry[@displayName='检查报告类型']/observation/code/@displayName");
String fileTitle = fileTitleNode.getNodeValue();
Node downUrlNode = inspectionUpdateXmlUtil.getNode("/POOR_HIP1009/controlActProcess/subject/component/structuredBody/component[@displayName='检查报告图像']/report/entry[@displayName='检查报告图像URL地址']/observation/value");
String downUrl = downUrlNode.getTextContent();
ReportDto reportDto = new ReportDto();
reportDto.setAdmisstimes(admissTimes);
reportDto.setInpatientNo(inpatientNo);
reportDto.setSerialnum(serialnum);
reportDto.setFileTitle(fileTitle);
reportDto.setDownUrl(downUrl);
reportDto.setAssortId(assortId);
reportDto.setSysFlag(sysFlag);
reportDto.setFileSource("1");
reportDto.setFilestoragetype("1");
return reportDto;
}
/**
*
*
* @param msgId id
* @param sender
* @param receiver
* @return
*/
public String insertSuccess(String msgId, String sender, String receiver) {
String createTime = Func.format(new Date(), DateUtil.PATTERN_DATETIME_MINI);
return "<MCCI_IN000002UV01 ITSVersion=\"XML_1.0\" xmlns:xsi=\"http://www.w3.org/2001/XMLSchema-instance\" xsi:schemaLocation=\"urn:hl7-org:v3 ../multicacheschemas/MCCI_IN000002UV01.xsd\" xmlns=\"urn:hl7-org:v3\">\n" +
"\t<id root=\"2.16.156.10011.0\" extension=\"" + IdUtil.standardUUID() + "\"/>\n" +
"\t<creationTime value=\"" + createTime + "\"/>\n" +
"\t<interactionId root=\"2.16.840.1.113883.1.6\" extension=\"MCCI_IN000002UV01\" displayable=\"true\"/>\n" +
"\t<processingCode code=\"P\"/>\n" +
"\t<processingModeCode/>\n" +
"\t<acceptAckCode code=\"AL\"/>\n" +
"\t<receiver typeCode=\"RCV\">\n" +
"\t\t<device classCode=\"DEV\" determinerCode=\"INSTANCE\">\n" +
"\t\t\t<id>\n" +
"\t\t\t\t<item root=\"2.16.156.10011.0.1.1\" extension=\"" + receiver + "\"/>\n" +
"\t\t\t</id>\n" +
"\t\t</device>\n" +
"\t</receiver>\n" +
"\t<sender typeCode=\"SND\">\n" +
"\t\t<device classCode=\"DEV\" determinerCode=\"INSTANCE\">\n" +
"\t\t\t<id>\n" +
"\t\t\t\t<item root=\"2.16.156.10011.0.1.2\" extension=\"" + sender + "\"/>\n" +
"\t\t\t</id>\n" +
"\t\t</device>\n" +
"\t</sender>\n" +
"\t<acknowledgement typeCode=\"AA\">\n" +
"\t\t<targetMessage>\n" +
"\t\t\t<id root=\"2.16.156.10011.0\" extension=\"" + msgId + "\"/>\n" +
"\t\t</targetMessage>\n" +
"\t\t<acknowledgementDetail typeCode=\"I\">\n" +
"\t\t\t<text>\n" +
"\t\t\t\t<description value=\"成功!\"/>\n" +
"\t\t\t</text>\n" +
"\t\t</acknowledgementDetail>\n" +
"\t</acknowledgement>\n" +
"</MCCI_IN000002UV01>\n";
}
/**
*
*
* @param msgId id
* @param sender
* @param receiver
* @return
*/
public String insertFailed(String msgId, String sender, String receiver, String failedMessage) {
String createTime = Func.format(new Date(), DateUtil.PATTERN_DATETIME_MINI);
return "<MCCI_IN000002UV01 ITSVersion=\"XML_1.0\" xmlns:xsi=\"http://www.w3.org/2001/XMLSchema-instance\" xsi:schemaLocation=\"urn:hl7-org:v3 ../multicacheschemas/MCCI_IN000002UV01.xsd\" xmlns=\"urn:hl7-org:v3\">\n" +
"\t<id root=\"2.16.156.10011.0\" extension=\"" + IdUtil.standardUUID() + "\"/>\n" +
"\t<creationTime value=\"" + createTime + "\"/>\n" +
"\t<interactionId root=\"2.16.840.1.113883.1.6\" extension=\"MCCI_IN000002UV01\" displayable=\"true\"/>\n" +
"\t<processingCode code=\"P\"/>\n" +
"\t<processingModeCode/>\n" +
"\t<acceptAckCode code=\"AL\"/>\n" +
"\t<receiver typeCode=\"RCV\">\n" +
"\t\t<device classCode=\"DEV\" determinerCode=\"INSTANCE\">\n" +
"\t\t\t<id>\n" +
"\t\t\t\t<item root=\"2.16.156.10011.0.1.1\" extension=\"" + receiver + "\"/>\n" +
"\t\t\t</id>\n" +
"\t\t</device>\n" +
"\t</receiver>\n" +
"\t<sender typeCode=\"SND\">\n" +
"\t\t<device classCode=\"DEV\" determinerCode=\"INSTANCE\">\n" +
"\t\t\t<id>\n" +
"\t\t\t\t<item root=\"2.16.156.10011.0.1.2\" extension=\"" + sender + "\"/>\n" +
"\t\t\t</id>\n" +
"\t\t</device>\n" +
"\t</sender>\n" +
"\t<acknowledgement typeCode=\"AE\">\n" +
"\t\t<targetMessage>\n" +
"\t\t\t<id root=\"2.16.156.10011.0\" extension=\"" + msgId + "\"/>\n" +
"\t\t</targetMessage>\n" +
"\t\t<acknowledgementDetail typeCode=\"I\">\n" +
"\t\t\t<text>\n" +
"\t\t\t\t<description value=\"" + failedMessage + "\"/>\n" +
"\t\t\t</text>\n" +
"\t\t</acknowledgementDetail>\n" +
"\t</acknowledgement>\n" +
"</MCCI_IN000002UV01>\n";
}
/**
*
*
* @param msgId id
* @param sender
* @param receiver
* @return
*/
public String updateSuccess(String msgId, String sender, String receiver) {
String createTime = Func.format(new Date(), DateUtil.PATTERN_DATETIME_MINI);
return "<MCCI_IN000002UV01 ITSVersion=\"XML_1.0\" xmlns:xsi=\"http://www.w3.org/2001/XMLSchema-instance\" xsi:schemaLocation=\"urn:hl7-org:v3 ../multicacheschemas/MCCI_IN000002UV01.xsd\" xmlns=\"urn:hl7-org:v3\">\n" +
"\t<id root=\"2.16.156.10011.0\" extension=\"" + IdUtil.standardUUID() + "\"/>\n" +
"\t<creationTime value=\"" + createTime + "\"/>\n" +
"\t<interactionId root=\"2.16.840.1.113883.1.6\" extension=\"MCCI_IN000002UV01\" displayable=\"true\"/>\n" +
"\t<processingCode code=\"P\"/>\n" +
"\t<processingModeCode/>\n" +
"\t<acceptAckCode code=\"AL\"/>\n" +
"\t<receiver typeCode=\"RCV\">\n" +
"\t\t<device classCode=\"DEV\" determinerCode=\"INSTANCE\">\n" +
"\t\t\t<id>\n" +
"\t\t\t\t<item root=\"2.16.156.10011.0.1.1\" extension=\"" + receiver + "\"/>\n" +
"\t\t\t</id>\n" +
"\t\t</device>\n" +
"\t</receiver>\n" +
"\t<sender typeCode=\"SND\">\n" +
"\t\t<device classCode=\"DEV\" determinerCode=\"INSTANCE\">\n" +
"\t\t\t<id>\n" +
"\t\t\t\t<item root=\"2.16.156.10011.0.1.2\" extension=\"" + sender + "\"/>\n" +
"\t\t\t</id>\n" +
"\t\t</device>\n" +
"\t</sender>\n" +
"\t<acknowledgement typeCode=\"AA\">\n" +
"\t\t<targetMessage>\n" +
"\t\t\t<id root=\"2.16.156.10011.0\" extension=\"" + msgId + "\"/>\n" +
"\t\t</targetMessage>\n" +
"\t\t<acknowledgementDetail typeCode=\"I\">\n" +
"\t\t\t<text>\n" +
"\t\t\t\t<description value=\"成功!\"/>\n" +
"\t\t\t</text>\n" +
"\t\t</acknowledgementDetail>\n" +
"\t</acknowledgement>\n" +
"</MCCI_IN000002UV01>\n";
}
/**
*
*
* @param msgId id
* @param sender
* @param receiver
* @param failedMessage
* @return
*/
public String updateFailed(String msgId, String sender, String receiver, String failedMessage) {
String createTime = Func.format(new Date(), DateUtil.PATTERN_DATETIME_MINI);
return "<MCCI_IN000002UV01 ITSVersion=\"XML_1.0\" xmlns:xsi=\"http://www.w3.org/2001/XMLSchema-instance\" xsi:schemaLocation=\"urn:hl7-org:v3 ../multicacheschemas/MCCI_IN000002UV01.xsd\" xmlns=\"urn:hl7-org:v3\">\n" +
"\t<id root=\"2.16.156.10011.0\" extension=\"" + IdUtil.standardUUID() + "\"/>\n" +
"\t<creationTime value=\"" + createTime + "\"/>\n" +
"\t<interactionId root=\"2.16.840.1.113883.1.6\" extension=\"MCCI_IN000002UV01\" displayable=\"true\"/>\n" +
"\t<processingCode code=\"P\"/>\n" +
"\t<processingModeCode/>\n" +
"\t<acceptAckCode code=\"AL\"/>\n" +
"\t<receiver typeCode=\"RCV\">\n" +
"\t\t<device classCode=\"DEV\" determinerCode=\"INSTANCE\">\n" +
"\t\t\t<id>\n" +
"\t\t\t\t<item root=\"2.16.156.10011.0.1.1\" extension=\"" + receiver + "\"/>\n" +
"\t\t\t</id>\n" +
"\t\t</device>\n" +
"\t</receiver>\n" +
"\t<sender typeCode=\"SND\">\n" +
"\t\t<device classCode=\"DEV\" determinerCode=\"INSTANCE\">\n" +
"\t\t\t<id>\n" +
"\t\t\t\t<item root=\"2.16.156.10011.0.1.2\" extension=\"" + sender + "\"/>\n" +
"\t\t\t</id>\n" +
"\t\t</device>\n" +
"\t</sender>\n" +
"\t<acknowledgement typeCode=\"AE\">\n" +
"\t\t<targetMessage>\n" +
"\t\t\t<id root=\"2.16.156.10011.0\" extension=\"" + msgId + "\"/>\n" +
"\t\t</targetMessage>\n" +
"\t\t<acknowledgementDetail typeCode=\"I\">\n" +
"\t\t\t<text>\n" +
"\t\t\t\t<description value=\"" + failedMessage + "\"/>\n" +
"\t\t\t</text>\n" +
"\t\t</acknowledgementDetail>\n" +
"\t</acknowledgement>\n" +
"</MCCI_IN000002UV01>\n";
}
}

@ -47,6 +47,8 @@ docus:
user:
# 用户默认密码
defpwd: fd29cd53ec12616e5f36b77d4afffbff
report:
downurl: http://localhost:9291/api/downplatform/report
mybatis-plus:
configuration:
map-underscore-to-camel-case: true

@ -0,0 +1,17 @@
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper
PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
"http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.docus.server.report.mapper.AfCollectTaskMapper">
<insert id="saveTask">
INSERT INTO `docus_archivefile`.`af_collect_task`(`id`, `patient_id`, `sysflag`,
`state`, `C1`,`C2`, `C3`)
VALUES (#{task.id}, #{task.patientId}, #{task.sysflag}, '0', #{task.C1}, #{task.C2}, #{task.C3});
</insert>
<select id="getTaskById" resultType="com.docus.server.report.entity.AfCollectTask">
select *
from `docus_archivefile`.`af_collect_task`
where `id` = #{id}
</select>
</mapper>

@ -0,0 +1,56 @@
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper
PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
"http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.docus.server.report.mapper.AfReportRecordMapper">
<insert id="saveRecord">
INSERT INTO `docus_archivefile`.`af_report_record`(`task_id`, `inpatient_no`, `jzh`, `admiss_times`, `down_url`,
`down_type`, `state`, `serialnum`, `sysflag`, `zd_assort_id`,
`create_time`, `update_time`, `file_name`, `patient_id`)
VALUES (#{reportRecord.taskId}, #{reportRecord.inpatientNo}, #{reportRecord.jzh}, #{reportRecord.admissTimes},
#{reportRecord.downUrl}, #{reportRecord.downType}, 0, #{reportRecord.serialnum},
#{reportRecord.sysflag}, #{reportRecord.zdAssortId}, now(), now(), #{reportRecord.fileName},
#{reportRecord.patientId});
</insert>
<update id="updateRecordByTaskId">
update `docus_archivefile`.`af_report_record`
set `down_url`=#{reportRecord.downUrl},
`down_type`=#{reportRecord.downType},
`state`=0,
`file_name`=#{reportRecord.fileName},
`patient_id`=#{reportRecord.patientId},
`update_time`=now()
where `task_id` = #{reportRecord.taskId}
</update>
<update id="updateStateByTaskId">
update `docus_archivefile`.`af_report_record`
set `state`= 1,
`update_time`=now()
where `task_id` = #{taskId}
</update>
<select id="getRecordBySerialnumAndInpatientNoAndSysFlag"
resultType="com.docus.server.report.entity.AfReportRecord">
select *
from `docus_archivefile`.`af_report_record`
where `inpatient_no` = #{inpatientNo}
and `serialnum` = #{serialnum}
and `sysflag` = #{sysFlag}
and admiss_times = #{admisstimes}
</select>
<select id="getReportRecordInfoByTaskId" resultType="com.docus.server.report.entity.AfReportRecord">
select *
from `docus_archivefile`.`af_report_record`
where `task_id` = #{taskId}
</select>
<select id="getHasPatientIdTaskIdsByTaskIds" resultType="java.lang.Long">
SELECT `task_id`
FROM `docus_archivefile`.`af_report_record`
WHERE `patient_id` IS NOT NULL
AND `patient_id` != ''
AND `task_id` IN
<foreach collection="taskIds" separator="," open="(" close=")" item="taskId">
#{taskId}
</foreach>
</select>
</mapper>

@ -3,6 +3,16 @@
PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
"http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.docus.server.collection.mapper.TBasicMapper">
<select id="getPatientIdByInpatientNoAndAdminssTimes" resultType="java.lang.String">
select `patient_id`
from `docus_medicalrecord`.`t_basic`
where `inpatient_no` = #{inpatientNo}
and `admiss_times` = #{adminssTimes}
</select>
<insert id="insert">
INSERT INTO `docus_medicalrecord`.`t_basic`
(`admiss_days`,`is_dead`,`sex_name`,`bed_num`,`age`,`sex`,`id_card`,`dis_dept`,`patient_id`, `admiss_times`, `inpatient_no`,`name`, `admiss_date`, `admiss_dept_name`, `dis_date`, `dis_dept_name`,`attending_name`,`jzh`)

Loading…
Cancel
Save