feat:基础数据同步服务初始化；开发肇庆第一人医用户，科室，患者基础数据同步

src/main/java/com/docus/server/AppRunBootstrap.java

@@ -0,0 +1,83 @@
+package com.docus.server;
+
+
+import cn.hutool.extra.spring.SpringUtil;
+import com.docus.server.archive.entity.TBasic;
+import com.docus.server.archive.mapper.TBasicMapper;
+import com.docus.server.archive.utils.PinYinUtil;
+import lombok.extern.slf4j.Slf4j;
+import org.mybatis.spring.annotation.MapperScan;
+import org.springframework.beans.BeanUtils;
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.cloud.openfeign.EnableFeignClients;
+
+import java.util.Arrays;
+import java.util.Date;
+import java.util.Properties;
+
+
+/**
+ * @author wyb
+ */
+@Slf4j
+@SpringBootApplication(scanBasePackages ={"com.docus"})
+@MapperScan("com.docus.server.**.mapper")
+@EnableFeignClients(basePackages = {"com.docus"})
+public class AppRunBootstrap {
+    public static void main(String[] args) {
+        Properties props = System.getProperties();
+        props.setProperty("org.apache.cxf.stax.allowInsecureParser", "1");
+        props.setProperty("UseSunHttpHandler", "true");
+        System.setProperty("javax.xml.parsers.DocumentBuilderFactory", "com.sun.org.apache.xerces.internal.jaxp.DocumentBuilderFactoryImpl");
+
+        SpringApplication.run(AppRunBootstrap.class, args);
+    }
+
+    static void testMysql(){
+        TBasicMapper mapper = SpringUtil.getBean(TBasicMapper.class);
+        long currentTimeMillis = System.currentTimeMillis();
+        TBasic tBasic1 = new TBasic();
+        tBasic1.setPatientId("FS-TEST-1");
+        tBasic1.setJzh("jzh"+ currentTimeMillis);
+        tBasic1.setInpatientNo(currentTimeMillis +"");
+        tBasic1.setAdmissTimes(1);
+        tBasic1.setName("佛山测试1");
+        tBasic1.setNameSpell(PinYinUtil.getFirstSpell("佛山测试1"));
+        tBasic1.setSex("1");
+        tBasic1.setSexName("男");
+        tBasic1.setAdmissDate(new Date());
+        tBasic1.setAdmissDept("221");
+        tBasic1.setAdmissDeptName("神经内科");
+        tBasic1.setBedNo("神经内科1-1");
+        tBasic1.setAttending("wyb");
+        tBasic1.setAttendingName("文永斌");
+        tBasic1.setAge(50);
+        tBasic1.setAgeMonth(12);
+        tBasic1.setAgeDay(3);
+        tBasic1.setIdCard("xxxxxx");
+        tBasic1.setTelphone("666");
+        tBasic1.setDisDate(new Date());
+        tBasic1.setDisDept("221");
+        tBasic1.setDisDeptName("神经内科");
+        tBasic1.setTotalCost("28.8");
+        tBasic1.setIsDead(0);
+        tBasic1.setJzCardNo("kh1998");
+        tBasic1.setFileSource(1);
+        tBasic1.setCreateTime(new Date());
+        tBasic1.setUpdateTime(new Date());
+        TBasic tBasic2 = new TBasic();
+        BeanUtils.copyProperties(tBasic1,tBasic2);
+        tBasic2.setPatientId("FS-TEST-2");
+        tBasic2.setAdmissTimes(2);
+        tBasic2.setJzh("jzh"+(currentTimeMillis+555));
+        mapper.insertBatch(Arrays.asList(tBasic1,tBasic2));
+        System.out.println("插入后："+mapper.getByJzh(Arrays.asList(tBasic1.getJzh(),tBasic2.getJzh())));
+        tBasic1.setIdCard("modify-1");
+        tBasic2.setIdCard("modify-2");
+        mapper.updateBatch(Arrays.asList(tBasic1,tBasic2));
+
+        System.out.println("修改后："+mapper.getByJzh(Arrays.asList(tBasic1.getJzh(),tBasic2.getJzh())));
+
+    }
+}

src/main/java/com/docus/server/XxlJobConfig.java

@@ -0,0 +1,87 @@
+package com.docus.server;
+import com.xxl.job.core.executor.impl.XxlJobSpringExecutor;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+/**
+ * @ProjectName:
+ * @Description:
+ * @Param 传输参数
+ * @Return
+ * @Author: 曾文和
+ * @CreateDate: 2021/5/7 16:23
+ * @UpdateUser: 曾文和
+ * @UpdateDate: 2021/5/7 16:23
+ * @UpdateRemark: 更新说明
+ * @Version: 1.0
+ */
+
+
+
+@Configuration
+public class XxlJobConfig {
+    private Logger logger = LoggerFactory.getLogger(XxlJobConfig.class);
+
+    @Value("${xxl.job.admin.addresses}")
+    private String adminAddresses;
+
+    @Value("${xxl.job.accessToken}")
+    private String accessToken;
+
+    @Value("${xxl.job.executor.appname}")
+    private String appname;
+
+    @Value("${xxl.job.executor.address}")
+    private String address;
+
+    @Value("${xxl.job.executor.ip}")
+    private String ip;
+
+    @Value("${xxl.job.executor.port}")
+    private int port;
+
+    @Value("${xxl.job.executor.logpath}")
+    private String logPath;
+
+    @Value("${xxl.job.executor.logretentiondays}")
+    private int logRetentionDays;
+
+
+    @Bean
+    public XxlJobSpringExecutor xxlJobExecutor() {
+        logger.info(">>>>>>>>>>> xxl-job config init.");
+        XxlJobSpringExecutor xxlJobSpringExecutor = new XxlJobSpringExecutor();
+        xxlJobSpringExecutor.setAdminAddresses(adminAddresses);
+        xxlJobSpringExecutor.setAppname(appname);
+        xxlJobSpringExecutor.setAddress(address);
+        xxlJobSpringExecutor.setIp(ip);
+        xxlJobSpringExecutor.setPort(port);
+        xxlJobSpringExecutor.setAccessToken(accessToken);
+        xxlJobSpringExecutor.setLogPath(logPath);
+        xxlJobSpringExecutor.setLogRetentionDays(logRetentionDays);
+
+        return xxlJobSpringExecutor;
+    }
+
+    /**
+     * 针对多网卡、容器内部署等情况，可借助 "spring-cloud-commons" 提供的 "InetUtils" 组件灵活定制注册IP；
+     *
+     *      1、引入依赖：
+     *          <dependency>
+     *             <groupId>org.springframework.cloud</groupId>
+     *             <artifactId>spring-cloud-commons</artifactId>
+     *             <version>${version}</version>
+     *         </dependency>
+     *
+     *      2、配置文件，或者容器启动变量
+     *          spring.cloud.inetutils.preferred-networks: 'xxx.xxx.xxx.'
+     *
+     *      3、获取IP
+     *          String ip_ = inetUtils.findFirstNonLoopbackHostInfo().getIpAddress();
+     *//*
+
+*/
+}

src/main/java/com/docus/server/archive/config/DocusServerUrlConfig.java

@@ -0,0 +1,22 @@
+package com.docus.server.archive.config;
+
+import lombok.Data;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.stereotype.Component;
+
+/**
+ * @author YongBin Wen
+ * @date 2024/3/29 14:00
+ */
+@Component
+@Data
+public class DocusServerUrlConfig {
+    @Value("${docus.url.viewcollect-server}")
+    private String viewCollectServerUrl;
+
+    @Value("${docus.url.downploadlatform-server}")
+    private String downloadPlatformServerUrl;
+
+    @Value("${docus.url.taskdistribute-server}")
+    private String taskDistributeServerUrl;
+}

src/main/java/com/docus/server/archive/entity/PowerDept.java

@@ -0,0 +1,62 @@
+package com.docus.server.archive.entity;
+
+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-15
+ */
+@Data
+@EqualsAndHashCode(callSuper = false)
+@ApiModel(value = "PowerDept对象", description = "科室")
+public class PowerDept implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    @ApiModelProperty(value = "科室id")
+    private Long deptId;
+
+    @ApiModelProperty(value = "科室代码")
+    private String deptCode;
+
+    @ApiModelProperty(value = "科室名称")
+    private String deptName;
+
+    @ApiModelProperty(value = "字典id")
+    private Integer dictId;
+
+    @ApiModelProperty(value = "是否有效")
+    private Integer effective;
+
+    @ApiModelProperty(value = "创建时间")
+    private Date createDate;
+
+    @ApiModelProperty(value = "创建人")
+    private String creater;
+
+    @ApiModelProperty(value = "更新时间")
+    private Date updateDate;
+
+    @ApiModelProperty(value = "更新人")
+    private String updater;
+
+    @ApiModelProperty(value = "备注")
+    private String remark;
+
+    @ApiModelProperty(value = "临床科室排序")
+    private Integer sort;
+
+    @ApiModelProperty(value = "0:非临床科室,1:临床科室")
+    private Integer type;
+
+}

src/main/java/com/docus/server/archive/entity/PowerUser.java

@@ -0,0 +1,116 @@
+package com.docus.server.archive.entity;
+
+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 = "PowerUser对象", description = "用户表")
+public class PowerUser implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    @ApiModelProperty(value = "用户id")
+    private Long userId;
+
+    @ApiModelProperty(value = "登陆名")
+    private String userName;
+
+    @ApiModelProperty(value = "用户密码")
+    private String userPwd;
+
+    @ApiModelProperty(value = "密码修改(0：未修改，1：已修改)")
+    private Integer pwdChange;
+
+    @ApiModelProperty(value = "性别 0 男 1 女")
+    private Integer userSex;
+
+    @ApiModelProperty(value = "年龄")
+    private Integer userAge;
+
+    @ApiModelProperty(value = "电话")
+    private String userTel;
+
+    @ApiModelProperty(value = "邮箱")
+    private String userEmail;
+
+    @ApiModelProperty(value = "微信信息")
+    private String wxBank;
+
+    @ApiModelProperty(value = "职位")
+    private String userPosition;
+
+    @ApiModelProperty(value = "角色")
+    private Long roleId;
+
+    @ApiModelProperty(value = "部门id")
+    private String deptId;
+
+
+    @ApiModelProperty("头像路径")
+    private String userHead;
+
+    @ApiModelProperty(value = "是否有效")
+    private Integer effective;
+
+    @ApiModelProperty(value = "创建时间")
+    private Date createDate;
+
+    @ApiModelProperty(value = "创建人")
+    private String creater;
+
+    @ApiModelProperty(value = "更新时间")
+    private Date updateDate;
+
+    @ApiModelProperty(value = "更新人")
+    private String updater;
+
+    @ApiModelProperty(value = "备注")
+    private String remark;
+
+    @ApiModelProperty(value = "登录标志 默认为0为未登录 1登录")
+    private Integer loginFlag;
+
+    @ApiModelProperty(value = "用户名称")
+    private String name;
+
+    @ApiModelProperty(value = "权限科室 拥有对科室查阅权限")
+    private String powerDept;
+
+    @ApiModelProperty(value = "权限 拥有对主管医生查阅权限")
+    private String powerAttending;
+
+    @ApiModelProperty(value = "助记词")
+    private String mnemonicWords;
+
+
+    @ApiModelProperty("是否可用")
+    private Integer enabled;
+
+
+    @ApiModelProperty("账号状态 0：正常 1：锁定  2：冻结")
+    private Integer accountState;
+
+    @ApiModelProperty("其他角色选择")
+    private String attRoleId;
+
+
+    @ApiModelProperty("微信公众号openid")
+    private String openId;
+
+    @ApiModelProperty("是否第三方账号 0否 1是")
+    private Integer isThird;
+}

src/main/java/com/docus/server/archive/entity/TBasic.java

@@ -0,0 +1,116 @@
+package com.docus.server.archive.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 String jzh;
+
+    @ApiModelProperty(value = "病案号")
+    private String inpatientNo;
+
+    @ApiModelProperty(value = "住院次数")
+    private Integer admissTimes;
+
+    @ApiModelProperty(value = "患者姓名")
+    private String name;
+
+    @ApiModelProperty(value = "患者拼音首拼")
+    private String nameSpell;
+
+    @ApiModelProperty(value = "性别代码")
+    private String sex;
+
+    @ApiModelProperty(value = "性别名称")
+    private String sexName;
+
+    @ApiModelProperty(value = "住院日期")
+    private Date admissDate;
+
+    @ApiModelProperty(value = "住院科室")
+    private String admissDept;
+
+    @ApiModelProperty(value = "住院科室名称")
+    private String admissDeptName;
+
+
+    @ApiModelProperty(value = "床号")
+    private String bedNo;
+
+    @ApiModelProperty(value = "主管医生工号")
+    private String attending;
+
+    @ApiModelProperty(value = "主管医生姓名")
+    private String attendingName;
+
+    @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 disDate;
+
+    @ApiModelProperty(value = "出院科室")
+    private String disDept;
+
+    @ApiModelProperty(value = "出院科室名称")
+    private String disDeptName;
+
+    @ApiModelProperty(value = "患者本次住院总费用")
+    private String totalCost;
+
+    @ApiModelProperty(value = "是否死亡 0 非死亡 1死亡")
+    private Integer isDead;
+
+    @ApiModelProperty(value = "记账卡号")
+    private String jzCardNo;
+
+    @ApiModelProperty(value = "创建时间")
+    private Date createTime;
+
+    @ApiModelProperty(value = "修改时间")
+    private Date updateTime;
+
+    @ApiModelProperty(value = "数据来源 1：需质控归档")
+    private Integer fileSource;
+
+}

src/main/java/com/docus/server/archive/mapper/PowerDeptMapper.java

@@ -0,0 +1,21 @@
+package com.docus.server.archive.mapper;
+
+
+import com.docus.server.archive.entity.PowerDept;
+import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
+
+import java.util.List;
+
+@Mapper
+public interface PowerDeptMapper {
+
+
+    List<PowerDept> list();
+
+    List<PowerDept> findByDeptCodes(@Param("deptCodes") List<String> deptCodes);
+
+    int insertBatch(@Param("deptList") List<PowerDept> deptList);
+
+    int updateBatch(@Param("deptList")List<PowerDept> powerDept);
+}

src/main/java/com/docus/server/archive/mapper/PowerUserMapper.java

@@ -0,0 +1,27 @@
+package com.docus.server.archive.mapper;
+
+
+import com.docus.server.archive.entity.PowerUser;
+import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
+
+import java.util.List;
+
+@Mapper
+public interface PowerUserMapper {
+
+
+    List<PowerUser> list();
+
+    /**
+     * 根据用户工号查询用户信息
+     *
+     * @param userNames 用户工号集合
+     * @return 用户信息
+     */
+    List<PowerUser> findByUserNames(@Param("userNames") List<String> userNames);
+
+    int insertBatch(@Param("userList") List<PowerUser> userList);
+
+    int updateBatch(@Param("userList") List<PowerUser> userList);
+}

src/main/java/com/docus/server/archive/mapper/TBasicMapper.java

@@ -0,0 +1,24 @@
+package com.docus.server.archive.mapper;
+
+
+import com.docus.server.archive.entity.TBasic;
+import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
+
+import java.util.List;
+
+@Mapper
+public interface TBasicMapper {
+
+    /**
+     * 根据记帐号查找基础数据
+     *
+     * @param jzhList 记帐号
+     * @return 基础数据
+     */
+    List<TBasic> getByJzh(@Param("jzhs") List<String> jzhList);
+
+    int insertBatch(@Param("basicList") List<TBasic> basicList);
+
+    int updateBatch(@Param("basicList") List<TBasic> updateList);
+}

src/main/java/com/docus/server/archive/rpc/DownPlatformService.java

@@ -0,0 +1,22 @@
+package com.docus.server.archive.rpc;
+
+import com.docus.infrastructure.web.api.CommonResult;
+import com.docus.server.archive.rpc.dto.ReportDownDto;
+
+/**
+ * 下载平台服务接口
+ *
+ * @author jiashi
+ */
+
+public interface DownPlatformService {
+
+
+    /**
+     * 下载服务文件上报
+     *
+     * @param reportDownDto 下载服务上报参数
+     * @return 结果
+     */
+    CommonResult report(ReportDownDto reportDownDto);
+}

src/main/java/com/docus/server/archive/rpc/TaskDistributeService.java

@@ -0,0 +1,24 @@
+package com.docus.server.archive.rpc;
+
+import com.docus.infrastructure.web.api.CommonResult;
+import com.docus.server.archive.rpc.dto.ReportDownTwoDto;
+
+/**
+ * 无视图任务服务
+ *
+ * @author wyb
+ */
+
+public interface TaskDistributeService {
+
+
+    /**
+     * 无视图-根据采集器类型获取任务信息
+     *
+     * @param collectorId 采集器类型
+     * @return 任务信息
+     */
+    CommonResult<ReportDownTwoDto> getNoViewTaskByCollectorId(String collectorId);
+
+    CommonResult<String> cancel(Long taskId);
+}

src/main/java/com/docus/server/archive/rpc/dto/PatientInfoDTO.java

@@ -0,0 +1,37 @@
+package com.docus.server.archive.rpc.dto;
+
+import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+/**
+ * 患者基础信息
+ *
+ * @author WYBDEV
+ */
+@Data
+@JsonIgnoreProperties(ignoreUnknown = true)
+@ApiModel(value = "患者信息")
+public class PatientInfoDTO {
+    @ApiModelProperty(value = "病案主键")
+    private String patientId;
+    @ApiModelProperty(value = "住院号")
+    private String inpatientNo;
+    @ApiModelProperty(value = "住院次数")
+    private Integer admissTimes;
+    @ApiModelProperty(value = "入院日期 yyyy-MM-dd HH:mm:ss")
+    private String admissDate;
+    @ApiModelProperty(value = "入院科室名称")
+    private String admissDeptName;
+    @ApiModelProperty(value = "出院日期 yyyy-MM-dd HH:mm:ss")
+    private String disDate;
+    @ApiModelProperty(value = "出院科室名称")
+    private String disDeptName;
+    @ApiModelProperty(value = "记账号")
+    private String jzh;
+    @ApiModelProperty(value = "姓名")
+    private String name;
+    @ApiModelProperty(value = "住院id")
+    private String admissId;
+}

src/main/java/com/docus/server/archive/rpc/dto/ReportDownDto.java

@@ -0,0 +1,30 @@
+package com.docus.server.archive.rpc.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;
+}

src/main/java/com/docus/server/archive/rpc/dto/ReportDownPatientDto.java

@@ -0,0 +1,19 @@
+package com.docus.server.archive.rpc.dto;
+
+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;
+}

src/main/java/com/docus/server/archive/rpc/dto/ReportDownScanFileDto.java

@@ -0,0 +1,32 @@
+package com.docus.server.archive.rpc.dto;
+
+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:服务器本地；2：ftp服务器；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;
+
+
+}

src/main/java/com/docus/server/archive/rpc/dto/ReportDownTwoDto.java

@@ -0,0 +1,29 @@
+package com.docus.server.archive.rpc.dto;
+
+import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+import java.util.ArrayList;
+import java.util.List;
+
+@Data
+@JsonIgnoreProperties(ignoreUnknown = true)
+public class ReportDownTwoDto {
+    @ApiModelProperty(value = "档案编号")
+    private String patientId;
+    @ApiModelProperty(value = "记账号")
+    private String jzh;
+    @ApiModelProperty(value = "档案类型")
+    private String recordType;
+    @ApiModelProperty(value = "档案时间")
+    private String createTime;
+    @ApiModelProperty(value = "患者信息")
+    private ReportPatientTwoDto patient =new ReportPatientTwoDto();
+    @ApiModelProperty(value = "住院信息")
+    private List<ReportHospitalTwoDto> hospitals = new ArrayList<>();
+    @ApiModelProperty(value = "任务信息")
+    private List<ReportTaskTwoDto> tasks = new ArrayList<>();
+    @ApiModelProperty(value = "母亲基础信息")
+    private PatientInfoDTO parent;
+}

src/main/java/com/docus/server/archive/rpc/dto/ReportDto.java

@@ -0,0 +1,97 @@
+package com.docus.server.archive.rpc.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:服务器本地；2：ftp服务器；3：共享文件夹
+     */
+    private String filestoragetype;
+
+    /**
+     * 下载对应任务id ,接收处理
+     */
+    private Long taskId;
+
+    /**
+     * 业务病案主键
+     */
+    private String patientId;
+
+    /**
+     * 下载路径类型 1:url，2:base64，3:url base64，4:共享文件，5：本地文件base64
+     */
+    private Integer downtype = 1;
+
+    /**
+     * 患者本次就诊唯一键：患者id【12位】+就诊次
+     * 数
+     */
+    private String visitSn;
+
+    /**
+     *  患者id
+     */
+    private String patientSn;
+
+
+    /**
+     * 检查报告单号，用于顺德人医推送 报告信息和报告地址的关联
+     */
+    private String reportSn;
+
+    /**
+     * 如果多次上传是否合并文件标题
+     */
+    private boolean mergeFileTitle;
+
+
+
+    public ReportDto() {
+    }
+
+}

src/main/java/com/docus/server/archive/rpc/dto/ReportHospitalTwoDto.java

@@ -0,0 +1,27 @@
+package com.docus.server.archive.rpc.dto;
+
+
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+/**
+ *
+ */
+@Data
+public class ReportHospitalTwoDto {
+
+    @ApiModelProperty(value = "患者id")
+    private String patientId;
+    @ApiModelProperty(value = "住院次数")
+    private Integer admissTimes;
+    @ApiModelProperty(value = "住院日期")
+    private String admissDate;
+    @ApiModelProperty(value = "出院日期")
+    private String disDate;
+    @ApiModelProperty(value = "出院科室名称")
+    private String disDeptName;
+    @ApiModelProperty(value = "出院科室名称")
+    private String admissDeptName;
+    @ApiModelProperty(value = "卡号")
+    private String admissId;
+}

src/main/java/com/docus/server/archive/rpc/dto/ReportPatientTwoDto.java

@@ -0,0 +1,18 @@
+package com.docus.server.archive.rpc.dto;
+
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+/**
+ * 上报打印 患者信息
+ */
+@Data
+public class ReportPatientTwoDto {
+
+    @ApiModelProperty(value = "住院号/就诊号")
+    private String inpatientNo;
+    @ApiModelProperty(value = "患者姓名")
+    private String name;
+    @ApiModelProperty(value = "id号")
+    private String patientId;
+}

src/main/java/com/docus/server/archive/rpc/dto/ReportTaskTwoDto.java

@@ -0,0 +1,19 @@
+package com.docus.server.archive.rpc.dto;
+
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+
+/**
+ *
+ */
+@Data
+public class ReportTaskTwoDto {
+    @ApiModelProperty(value = "采集器标识")
+    private String collectorId;
+    @ApiModelProperty(value = "任务id")
+    private Long taskId;
+    @ApiModelProperty(value = "患者id")
+    private String patientId;
+
+}

src/main/java/com/docus/server/archive/rpc/impl/DownPlatformServiceImpl.java

@@ -0,0 +1,51 @@
+package com.docus.server.archive.rpc.impl;
+
+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.server.archive.config.DocusServerUrlConfig;
+import com.docus.server.archive.rpc.DownPlatformService;
+import com.docus.server.archive.rpc.dto.ReportDownDto;
+import com.docus.server.archive.rpc.dto.ReportDownScanFileDto;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Component;
+
+import javax.annotation.Resource;
+
+/**
+ * 下载平台服务接口
+ *
+ * @author jiashi
+ */
+@Component
+@Slf4j
+public class DownPlatformServiceImpl implements DownPlatformService {
+
+    @Resource
+    private DocusServerUrlConfig serverUrlConfig;
+
+    @Override
+    public CommonResult report(ReportDownDto reportDownDto) {
+        String downUrl = serverUrlConfig.getDownloadPlatformServerUrl() + "api/downplatform/report";
+        String requestId = Func.randomUUID();
+        String requestParam = Func.toJson(reportDownDto);
+        ReportDownScanFileDto report = reportDownDto.getScanfiles().get(0);
+        log.info("[{}]调用下载服务，地址：{} ，参数：taskid={}", requestId, downUrl, report.getTaskid());
+        String respBody = post(downUrl, requestParam);
+        log.info("[{}]调用下载服务成功,响应参数：{}", requestId, respBody);
+        return Func.readJson(respBody, CommonResult.class);
+    }
+
+    public String post(String url, String body) {
+        HttpRequest post = HttpUtil.createPost(url);
+        post.setConnectionTimeout(5 * 1000);
+        post.setReadTimeout(60 * 1000);
+        post.header("Content-Type", "application/json; charset=utf-8");
+        post.body(body);
+        HttpResponse response = post.execute();
+        return response.body();
+
+    }
+}

src/main/java/com/docus/server/archive/rpc/impl/TaskDistributeServiceImpl.java

@@ -0,0 +1,48 @@
+package com.docus.server.archive.rpc.impl;
+
+import cn.hutool.http.HttpUtil;
+import com.docus.core.util.Func;
+import com.docus.infrastructure.web.api.CommonResult;
+import com.docus.server.archive.config.DocusServerUrlConfig;
+import com.docus.server.archive.rpc.TaskDistributeService;
+import com.docus.server.archive.rpc.dto.ReportDownTwoDto;
+import com.fasterxml.jackson.core.type.TypeReference;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Component;
+
+import javax.annotation.Resource;
+import java.util.HashMap;
+import java.util.Map;
+
+/**
+ * 无视图任务服务
+ *
+ * @author wyb
+ */
+@Component
+@Slf4j
+public class TaskDistributeServiceImpl implements TaskDistributeService {
+    @Resource
+    private DocusServerUrlConfig serverUrlConfig;
+
+    @Override
+    public CommonResult<ReportDownTwoDto> getNoViewTaskByCollectorId(String collectorId) {
+        String getTaskUrl = serverUrlConfig.getTaskDistributeServerUrl() + "api/noviewtask/GetTask?collectid=" + collectorId;
+        String result = HttpUtil.get(getTaskUrl);
+        return Func.readJson(result, new TypeReference<CommonResult<ReportDownTwoDto>>() {
+        });
+    }
+
+
+    @Override
+    public CommonResult<String> cancel(Long taskId) {
+        String taskCancelUrl = serverUrlConfig.getTaskDistributeServerUrl() + "api/collector/task/cancel";
+        Map<String, Object> param = new HashMap<>(1);
+        param.put("taskId", taskId);
+        log.info("任务作废 地址{}，参数：{}", taskCancelUrl, param);
+        String resp = HttpUtil.post(taskCancelUrl, Func.toJson(param));
+        log.info("任务作废结果：{}", resp);
+        return Func.readJson(resp, new TypeReference<CommonResult<String>>() {
+        });
+    }
+}

src/main/java/com/docus/server/archive/rpc/vo/SdRyBloodReportVO.java

@@ -0,0 +1,27 @@
+package com.docus.server.archive.rpc.vo;
+
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+/**
+ * 顺德人医输血报告单 视图
+ *
+ * @author WYBDEV
+ */
+@Data
+@ApiModel("顺德人医血液报告单查询结果")
+public class SdRyBloodReportVO {
+    @ApiModelProperty("文件id")
+    private String fileId;
+    @ApiModelProperty("住院号")
+    private String inpatientNo;
+    @ApiModelProperty("住院次数")
+    private Integer admissions;
+    @ApiModelProperty("保存文件名")
+    private String fileName;
+    @ApiModelProperty("文件描述标题")
+    private String fileDesc;
+    @ApiModelProperty("文件下载地址")
+    private String fileUrl;
+}

src/main/java/com/docus/server/archive/service/PatientInfoSyncService.java

@@ -0,0 +1,29 @@
+package com.docus.server.archive.service;
+
+import java.time.LocalDateTime;
+
+/**
+ * @author YongBin Wen
+ * @date 2024/3/27 16:25
+ */
+public interface PatientInfoSyncService {
+    /**
+     * 根据出院时间同步
+     *
+     * @param start 开始时间
+     * @param end   结束日期
+     * @date 2024/5/23 15:33
+     * @author YongBin Wen
+     */
+    void syncByDisDate(LocalDateTime start, LocalDateTime end);
+
+    /**
+     * 根据最后修改时间同步
+     *
+     * @param start 开始时间
+     * @param end   结束日期
+     * @date 2024/5/23 15:35
+     * @author YongBin Wen
+     */
+    void syncByModifyTime(LocalDateTime start, LocalDateTime end);
+}

src/main/java/com/docus/server/archive/service/impl/ZqDyRyPatientInfoSyncServiceImpl.java

@@ -0,0 +1,133 @@
+package com.docus.server.archive.service.impl;
+
+import com.docus.core.util.Func;
+import com.docus.infrastructure.redis.service.IdService;
+import com.docus.server.archive.constans.SyncConstant;
+import com.docus.server.archive.converter.ZqDyRyPatientInfoConverter;
+import com.docus.server.archive.entity.TBasic;
+import com.docus.server.archive.mapper.TBasicMapper;
+import com.docus.server.archive.service.PatientInfoSyncService;
+import com.docus.server.zqdyry.entity.ZqDyRyPatientInfoView;
+import com.docus.server.zqdyry.mapper.ZqDyRyPatientInfoViewMapper;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Service;
+
+import javax.annotation.Resource;
+import java.time.LocalDateTime;
+import java.util.*;
+import java.util.function.Function;
+import java.util.stream.Collectors;
+
+/**
+ * @author YongBin Wen
+ * @date 2024/3/27 16:25
+ */
+@Service("ZqDyRy" + SyncConstant.PATIENT_INFO_SYNC_SERVICE_SUFFIX)
+@Slf4j
+public class ZqDyRyPatientInfoSyncServiceImpl implements PatientInfoSyncService {
+    @Resource
+    private TBasicMapper tBasicMapper;
+    @Resource
+    private ZqDyRyPatientInfoViewMapper zqDyRyPatientInfoViewMapper;
+    @Resource
+    private IdService idService;
+
+    @Override
+    public void syncByDisDate(LocalDateTime start, LocalDateTime end) {
+        log.error("肇庆第一人民医院未开发按照出院时间同步患者基础数据！");
+    }
+
+    @Override
+    public void syncByModifyTime(LocalDateTime start, LocalDateTime end) {
+        String startDateTime = Func.formatDateTime(start);
+        String endDateTime = Func.formatDateTime(end);
+        int size = 1000;
+        int pageNumber = 1;
+        while (true) {
+            int startRow = ((pageNumber - 1) * size) + 1;
+            int endRow = pageNumber * size;
+            List<ZqDyRyPatientInfoView> patientInfoViews = zqDyRyPatientInfoViewMapper.pageByModifyTime(startDateTime, endDateTime, startRow, endRow);
+            if (Func.isNotEmpty(patientInfoViews)) {
+                List<TBasic> basicList = patientInfoViews.stream()
+                        .map(ZqDyRyPatientInfoConverter::convertPatientInfo)
+                        .collect(Collectors.toList());
+                saveOrUpdate(basicList);
+            }
+            if (Func.isEmpty(patientInfoViews) || patientInfoViews.size() < size) {
+                break;
+            }
+            pageNumber++;
+        }
+    }
+
+    /**
+     * 根据修改的患者基础信息，根据JZH查询是否存在，并进行相应数据的修改和新增。注：肇庆之前的jzh模式为 住院号@住院次数 组成，需要用两种方式查询
+     *
+     * @param iuBasicList 修改的患者基础信息
+     */
+    private void saveOrUpdate(List<TBasic> iuBasicList) {
+        Date nowDate = new Date();
+        List<String> iuJzhList1 = iuBasicList.stream()
+                .map(TBasic::getJzh)
+                .collect(Collectors.toList());
+        List<String> iuJzhList2 = iuBasicList.stream()
+                .map(e -> e.getInpatientNo().trim() + "@" + e.getAdmissTimes())
+                .collect(Collectors.toList());
+        List<String> iuJzhList = new ArrayList<>();
+        iuJzhList.addAll(iuJzhList1);
+        iuJzhList.addAll(iuJzhList2);
+        List<TBasic> existsBasicList = tBasicMapper.getByJzh(iuJzhList);
+        Map<String, TBasic> existsJzhBasicMap = existsBasicList.stream().collect(Collectors.toMap(TBasic::getJzh, Function.identity()));
+
+        List<TBasic> insertBasicList = new ArrayList<>();
+        List<TBasic> updateBasicList = new ArrayList<>();
+        // todo 未完成的逻辑处理哪些更新，哪些新增
+        for (TBasic iuBasic : iuBasicList) {
+            String maybeJzh = iuBasic.getJzh().trim() + "@" + iuBasic.getAdmissTimes();
+            if (existsJzhBasicMap.containsKey(iuBasic.getJzh()) || existsJzhBasicMap.containsKey(maybeJzh)) {
+                TBasic basic1 = existsJzhBasicMap.get(iuBasic.getJzh());
+                TBasic basic2 = existsJzhBasicMap.get(maybeJzh);
+                TBasic tBasic = Objects.isNull(basic1) ? basic2 : basic1;
+                tBasic.setName(iuBasic.getName());
+                tBasic.setInpatientNo(iuBasic.getInpatientNo());
+                tBasic.setAdmissTimes(iuBasic.getAdmissTimes());
+                tBasic.setSex(iuBasic.getSex());
+                tBasic.setSexName(iuBasic.getSexName());
+                tBasic.setNameSpell(iuBasic.getNameSpell());
+                tBasic.setJzh(iuBasic.getJzh());
+                tBasic.setAdmissDate(iuBasic.getAdmissDate());
+                tBasic.setAdmissDept(iuBasic.getAdmissDept());
+                tBasic.setAdmissDeptName(iuBasic.getAdmissDeptName());
+                tBasic.setBedNo(iuBasic.getBedNo());
+                tBasic.setAttending(iuBasic.getAttending());
+                tBasic.setAttendingName(iuBasic.getAttendingName());
+                tBasic.setAge(iuBasic.getAge());
+                tBasic.setAgeMonth(iuBasic.getAgeMonth());
+                tBasic.setAgeDay(iuBasic.getAgeDay());
+                tBasic.setIdCard(iuBasic.getIdCard());
+                tBasic.setTelphone(iuBasic.getTelphone());
+                tBasic.setDisDate(iuBasic.getDisDate());
+                tBasic.setDisDept(iuBasic.getDisDept());
+                tBasic.setDisDeptName(iuBasic.getDisDeptName());
+                tBasic.setIsDead(iuBasic.getIsDead());
+                tBasic.setTotalCost(iuBasic.getTotalCost());
+                tBasic.setFileSource(iuBasic.getFileSource());
+                tBasic.setUpdateTime(nowDate);
+                updateBasicList.add(tBasic);
+                continue;
+            }
+            iuBasic.setPatientId(String.valueOf(idService.getDateSeq()));
+            iuBasic.setCreateTime(nowDate);
+            iuBasic.setUpdateTime(nowDate);
+            insertBasicList.add(iuBasic);
+        }
+
+        if (Func.isNotEmpty(insertBasicList)) {
+            tBasicMapper.insertBatch(insertBasicList);
+        }
+        if (Func.isNotEmpty(updateBasicList)) {
+            tBasicMapper.updateBatch(updateBasicList);
+        }
+
+    }
+}

src/main/java/com/docus/server/archive/utils/JaxWsDynamicClientUtil.java

@@ -0,0 +1,69 @@
+package com.docus.server.archive.utils;
+
+import org.apache.cxf.endpoint.Client;
+import org.apache.cxf.jaxws.endpoint.dynamic.JaxWsDynamicClientFactory;
+import org.apache.cxf.transport.http.HTTPConduit;
+import org.apache.cxf.transports.http.configuration.HTTPClientPolicy;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import javax.xml.namespace.QName;
+import java.util.Arrays;
+import java.util.Map;
+import java.util.concurrent.ConcurrentHashMap;
+
+/**
+ * 使用JaxWsDynamicClientFactory 调用 webservice
+ *
+ * @author wyb
+ */
+public class JaxWsDynamicClientUtil {
+
+    private static final JaxWsDynamicClientFactory CLIENT_FACTORY = JaxWsDynamicClientFactory.newInstance();
+    private static final Map<String, Client> CLIENT_MAP = new ConcurrentHashMap<>();
+    private static final Logger logger = LoggerFactory.getLogger(JaxWsDynamicClientUtil.class);
+
+    public static String send(String wsdlUrl, String namespaceUri, String operationName, Object[] params) {
+        logger.info("wsdlUrl：" + wsdlUrl + " ,namespaceUri: " + namespaceUri + " ，operationName：" + operationName + "，param:" + Arrays.toString(params));
+        try {
+            Client client = getClient(wsdlUrl);
+            Object[] result;
+            if (namespaceUri == null || namespaceUri.isEmpty()) {
+                result = client.invoke(operationName, params);
+            } else {
+                QName qName = new QName(namespaceUri, operationName);
+                result = client.invoke(qName, params);
+            }
+            logger.info("wsdlUrl：" + wsdlUrl + ",namespaceUri: " + namespaceUri + " ，operationName：" + operationName + "，param:" + Arrays.toString(params) + " 调用成功！");
+            if (result == null || result[0] == null) {
+                return null;
+            }
+            return String.valueOf(result[0]);
+        } catch (Exception ex) {
+            logger.error("wsdlUrl：" + wsdlUrl + ",namespaceUri: " + namespaceUri + " ，operationName：" + operationName + "，param:" + Arrays.toString(params) + " 调用失败了！_"+ex.getMessage(), ex);
+            return null;
+        }
+    }
+
+    public static Client getClient(String wsdlUrl) {
+        if (CLIENT_MAP.get(wsdlUrl) == null) {
+            synchronized (JaxWsDynamicClientUtil.class) {
+                if (CLIENT_MAP.get(wsdlUrl) == null) {
+                    Client client = CLIENT_FACTORY.createClient(wsdlUrl);
+                    setClientParam(client);
+                    CLIENT_MAP.put(wsdlUrl, client);
+                }
+            }
+        }
+        return CLIENT_MAP.get(wsdlUrl);
+    }
+
+    private static void setClientParam(Client client) {
+        HTTPClientPolicy httpClientPolicy = new HTTPClientPolicy();
+        httpClientPolicy.setConnectionTimeout(30 * 1000);
+        httpClientPolicy.setAllowChunking(false);
+        httpClientPolicy.setReceiveTimeout(30 * 1000);
+        HTTPConduit clientConduit = (HTTPConduit) client.getConduit();
+        clientConduit.setClient(httpClientPolicy);
+    }
+}

src/main/java/com/docus/server/archive/utils/PinYinUtil.java

@@ -0,0 +1,101 @@
+package com.docus.server.archive.utils;
+
+import net.sourceforge.pinyin4j.PinyinHelper;
+import net.sourceforge.pinyin4j.format.HanyuPinyinCaseType;
+import net.sourceforge.pinyin4j.format.HanyuPinyinOutputFormat;
+import net.sourceforge.pinyin4j.format.HanyuPinyinToneType;
+import net.sourceforge.pinyin4j.format.HanyuPinyinVCharType;
+import net.sourceforge.pinyin4j.format.exception.BadHanyuPinyinOutputFormatCombination;
+
+/**
+ * 拼音工具类
+ *
+ * @author
+ */
+public class PinYinUtil {
+    /**
+     * 将字符串中的中文转化为拼音,其他字符不变
+     *
+     * @param inputString
+     * @return
+     */
+    public static String getPinYin(String inputString) {
+        HanyuPinyinOutputFormat format = new HanyuPinyinOutputFormat();
+        format.setCaseType(HanyuPinyinCaseType.LOWERCASE);
+        format.setToneType(HanyuPinyinToneType.WITHOUT_TONE);
+        format.setVCharType(HanyuPinyinVCharType.WITH_V);
+
+        char[] input = inputString.trim().toCharArray();
+        String output = "";
+
+        try {
+            for (int i = 0; i < input.length; i++) {
+                if (Character.toString(input[i]).matches("[\\u4E00-\\u9FA5]+")) {
+                    String[] temp = PinyinHelper.toHanyuPinyinStringArray(input[i], format);
+                    output += temp[0];
+                } else {
+                    output += Character.toString(input[i]);
+                }
+            }
+        } catch (BadHanyuPinyinOutputFormatCombination e) {
+            e.printStackTrace();
+        }
+        return output;
+    }
+    /**
+     * 获取汉字串拼音首字母，英文字符不变
+     * @param chinese 汉字串
+     * @return 汉语拼音首字母
+     */
+    public static String getFirstSpell(String chinese) {
+        StringBuffer pybf = new StringBuffer();
+        char[] arr = chinese.toCharArray();
+        HanyuPinyinOutputFormat defaultFormat = new HanyuPinyinOutputFormat();
+        defaultFormat.setCaseType(HanyuPinyinCaseType.LOWERCASE);
+        defaultFormat.setToneType(HanyuPinyinToneType.WITHOUT_TONE);
+        for (int i = 0; i < arr.length; i++) {
+            if (arr[i] > 128) {
+                try {
+                    String[] temp = PinyinHelper.toHanyuPinyinStringArray(arr[i], defaultFormat);
+                    if (temp != null) {
+                        pybf.append(temp[0].charAt(0));
+                    }
+                } catch (BadHanyuPinyinOutputFormatCombination e) {
+                    e.printStackTrace();
+                }
+            } else {
+                pybf.append(arr[i]);
+            }
+        }
+        return pybf.toString().replaceAll("\\W", "").trim();
+    }
+
+    public static void main(String[] args) {
+        String spell = getFirstSpell("牛的");
+        System.out.println(spell);
+    }
+    /**
+     * 获取汉字串拼音，英文字符不变
+     * @param chinese 汉字串
+     * @return 汉语拼音
+     */
+    public static String getFullSpell(String chinese) {
+        StringBuffer pybf = new StringBuffer();
+        char[] arr = chinese.toCharArray();
+        HanyuPinyinOutputFormat defaultFormat = new HanyuPinyinOutputFormat();
+        defaultFormat.setCaseType(HanyuPinyinCaseType.LOWERCASE);
+        defaultFormat.setToneType(HanyuPinyinToneType.WITHOUT_TONE);
+        for (int i = 0; i < arr.length; i++) {
+            if (arr[i] > 128) {
+                try {
+                    pybf.append(PinyinHelper.toHanyuPinyinStringArray(arr[i], defaultFormat)[0]);
+                } catch (BadHanyuPinyinOutputFormatCombination e) {
+                    e.printStackTrace();
+                }
+            } else {
+                pybf.append(arr[i]);
+            }
+        }
+        return pybf.toString();
+    }
+}

src/main/java/com/docus/server/archive/utils/XmlUtil.java

@@ -0,0 +1,857 @@
+/*
+ *      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.archive.utils;
+
+import com.docus.core.util.Exceptions;
+import com.docus.core.util.IoUtil;
+import org.springframework.lang.Nullable;
+import org.w3c.dom.Document;
+import org.w3c.dom.Element;
+import org.w3c.dom.Node;
+import org.w3c.dom.NodeList;
+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;
+
+/**
+ * xpath解析xml
+ *
+ * <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) {
+			synchronized (XmlUtil.class) {
+				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);
+	}
+}

src/main/resources/bin/install.bat

@@ -0,0 +1,33 @@
+@echo off
+
+for /f "delims=" %%t in ('winsw.exe status') do set str=%%t
+echo %str%
+
+
+
+if %str%==Started (
+echo "restart....."
+winsw  stop
+PING 127.0.0.1 -n 10 -w 30000 >NUL
+winsw	 start
+) 
+
+
+
+if %str%==Stopped (
+echo "start....."
+winsw	 start
+) 
+
+
+if %str%==NonExistent (
+echo "deploy and start....."
+winsw	 install
+winsw	 start
+echo c
+) 
+
+
+
+
+

src/main/resources/bin/start.bat

@@ -0,0 +1,21 @@
+set java_opts=-Xms512m -Xmx512m
+set key="java_opts"
+
+
+rem 文件不存在，就跳过
+if not exist java-ops.ini goto end
+
+for /f "tokens=1,2 delims==" %%i in (java-ops.ini) do (
+    if "%%i"==%key% set java_opts=%%j)
+echo java_opts is :  %java_opts%
+
+:end
+
+rem 启动java
+
+java %java_opts% -Dfile.encoding=utf-8   -jar  -Dspring.profiles.active=@profile.name@ -Dloader.path=config,lib @project.build.finalName@.jar
+
+
+
+
+

src/main/resources/bin/stop.bat

@@ -0,0 +1,13 @@
+@echo off
+
+for /f "delims=" %%t in ('winsw.exe status') do set str=%%t
+echo %str%
+
+
+
+if %str%==Started (
+winsw  stop
+@echo wait program stop .....
+PING 127.0.0.1 -n 30 -w 10000 >NUL
+)
+

src/main/resources/bin/update.bat

@@ -0,0 +1,19 @@
+@echo off
+
+set deployDir=%1\docus-collect-basic-data
+if %deployDir%=="" set deployDir=d:\webroot\docus-collect-basic-data
+
+set curr_file=%cd%
+cd /d %deployDir%
+call stop.bat
+cd %curr_file%
+sc query docus-backup-sys |Find  "RUNNING" && ping 127.0.0.1 -n 10 >nul
+rd/s/q %deployDir%\lib
+rd/s/q %deployDir%\dataConfig
+rd/s/q %deployDir%\config
+del /s/q %deployDir%\*.jar
+xcopy /Y/E/I * %deployDir%
+
+cd /d %deployDir%
+call install.bat
+

src/main/resources/bin/winsw.xml

@@ -0,0 +1,8 @@
+<service>
+    <id>docus-collect-basic-data</id>
+    <name>生产-嘉时-基础信息数据采集服务</name>
+    <description>生产-嘉时-基础信息数据采集服务</description>
+    <startmode>Automatic</startmode>
+    <executable>%BASE%\start.bat</executable>
+    <log mode="none"></log>
+</service>

src/main/resources/bootstrap.yml

@@ -0,0 +1,111 @@
+server:
+  port: 9000
+
+spring:
+  application:
+    name: @artifactId@
+  profiles:
+    active: test
+  datasource:
+    dynamic:
+      primary: master #设置默认的数据源，默认值为master
+      strict: false   #是否用严格模式，如果启用在味匹配到指定数据源时抛出异常
+      datasource:
+        master:
+          url: jdbc:log4jdbc:mysql://db.docus.cn:3306/docus_medicalrecord?autoReconnect=true&allowMultiQueries=true&useSSL=false&useUnicode=true&characterEncoding=utf-8&serverTimezone=Asia/Shanghai
+          username: docus
+          password: docus702
+          driver-class-name: net.sf.log4jdbc.sql.jdbcapi.DriverSpy
+          type: com.alibaba.druid.pool.DruidDataSource
+          # 初始化配置
+          initial-size: 3
+          # 最小连接数
+          min-idle: 3
+          # 最大连接数
+          max-active: 15
+          # 获取连接超 时时间
+          max-wait: 5000
+          # 连接有效性检测时间
+          time-between-eviction-runs-millis: 90000
+          # 最大空闲时间
+          min-evictable-idle-time-millis: 1800000
+          test-while-idle: true
+          test-on-borrow: false
+          test-on-return: false
+          validation-query: select 1
+        zqdyry:
+          url: jdbc:oracle:thin:@10.20.28.15:1521:cdrdb
+          username: zqry_blgd
+          password: zqry_blgd666
+          driver-class-name: oracle.jdbc.driver.OracleDriver
+          type: com.alibaba.druid.pool.DruidDataSource
+          # 初始化配置
+          initial-size: 3
+          # 最小连接数
+          min-idle: 3
+          # 最大连接数
+          max-active: 10
+          # 获取连接超 时时间
+          max-wait: 5000
+          # 连接有效性检测时间
+          time-between-eviction-runs-millis: 90000
+          # 最大空闲时间
+          min-evictable-idle-time-millis: 1800000
+          test-while-idle: true
+          test-on-borrow: false
+          test-on-return: false
+          validation-query: select 1 from dual
+  redis:
+    host: redis.docus.cn
+    password: JSdocus@702
+  cloud:
+    nacos:
+      discovery:
+        server-addr: nacos.docus.cn
+        namespace: 34acdf7a-9fc6-4bbd-8aea-9a47c8007ad5
+      config:
+        server-addr: ${spring.cloud.nacos.discovery.server-addr}
+        namespace: 34acdf7a-9fc6-4bbd-8aea-9a47c8007ad5
+        file-extension: yml
+        shared-configs:
+          - comm.${spring.cloud.nacos.config.file-extension}
+
+
+
+docus:
+  sync-service-prefix: ZqDyRy
+  default-user-pwd: fd29cd53ec12616e5f36b77d4afffbff
+  url:
+    # 采集任务补偿地址
+    viewcollect-server: http://localhost:9295/
+    # 报告上报地址
+    downploadlatform-server: http://localhost:9291/
+    # 获取无视图模式采集任务地址
+    taskdistribute-server: http://localhost:9296/
+
+
+  dbtype: mysql
+
+mybatis-plus:
+  configuration:
+    map-underscore-to-camel-case: true
+    call-setters-on-nulls: true
+    log-impl: org.apache.ibatis.logging.stdout.StdOutImpl
+  global-config:
+    db-config:
+      field-strategy: NOT_EMPTY
+      db-type: MYSQL
+xxl:
+  job:
+    accessToken:
+    admin:
+      addresses: http://job.docus.cn:8180/xxl-job-admin
+    executor:
+      appname: docus-collect-basic-data
+      address:
+      ip:
+      port: 19000
+      logretentiondays: 30
+      logpath: D:/xxl-job/docus-collect-basic-data
+
+

src/main/resources/log4jdbc.log4j2.properties

@@ -0,0 +1,2 @@
+# If you use SLF4J. First, you need to tell log4jdbc-log4j2 that you want to use the SLF4J logger
+log4jdbc.spylogdelegator.name=net.sf.log4jdbc.log.slf4j.Slf4jSpyLogDelegator

src/main/resources/logback.xml

@@ -0,0 +1,77 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<configuration debug="false" scan="true" scanPeriod="1 seconds">
+    <contextName>docus-collect-basic-data</contextName>
+    <property name="log.path" value="logs/logback"/>
+
+    <appender name="console" class="ch.qos.logback.core.ConsoleAppender">
+        <encoder>
+            <pattern>[%d{yyyy-MM-dd' 'HH:mm:ss.sss}] [%contextName] [%thread] [%X{traceId}] %-5level %logger{36} - %msg%n</pattern>
+        </encoder>
+    </appender>
+
+    <appender name="file" class="ch.qos.logback.core.rolling.RollingFileAppender">
+        <encoder>
+            <!-- 指定日志输出格式 -->
+            <pattern>[%d{yyyy-MM-dd' 'HH:mm:ss.sss}] [%C] [%t] [%X{traceId}] [%L] [%-5p] %m%n</pattern>
+            <charset>utf-8</charset>
+        </encoder>
+        <!-- 指定收集策略：滚动策略-->
+        <rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
+            <!--指定生成日志保存地址 -->
+            <fileNamePattern>${log.path}%d.%i.log</fileNamePattern>
+            <timeBasedFileNamingAndTriggeringPolicy
+                    class="ch.qos.logback.core.rolling.SizeAndTimeBasedFNATP">
+                <maxFileSize>500MB</maxFileSize>
+            </timeBasedFileNamingAndTriggeringPolicy>
+            <MaxHistory>30</MaxHistory>
+        </rollingPolicy>
+    </appender>
+
+
+
+    <springProfile name="dev">
+        <root level="debug">
+            <appender-ref ref="console"/>
+        </root>
+
+    </springProfile>
+
+
+    <springProfile name="test|prod">
+        <root level="INFO">
+            <appender-ref ref="file"/>
+            <appender-ref ref="console"/>
+        </root>
+    </springProfile>
+
+	    <!--    监控sql日志输出-->
+    <!--  如想看到表格数据，将OFF改为INFO  -->
+    <logger name="jdbc.resultsettable" level="OFF" additivity="false">
+        <appender-ref ref="console"/>
+    </logger>
+
+    <!--    包含 SQL 语句实际的执行时间 及sql语句（与jdbc.sqlonly功能重复）   -->
+    <logger name="jdbc.sqltiming" level="OFF" additivity="false">
+        <appender-ref ref="file"/>
+    </logger>
+
+    <!--      仅仅记录 SQL 语句，会将占位符替换为实际的参数-->
+    <logger name="jdbc.sqlonly" level="OFF" additivity="false">
+        <appender-ref ref="console"/>
+    </logger>
+
+    <!--  包含 ResultSet 的信息，输出篇幅较长  -->
+    <logger name="jdbc.resultset" level="OFF" additivity="false">
+        <appender-ref ref="console"/>
+    </logger>
+
+    <!-- 输出了 Connection 的 open、close 等信息  -->
+    <logger name="jdbc.connection" level="OFF" additivity="false">
+        <appender-ref ref="console"/>
+    </logger>
+
+    <!--    除了 ResultSet 之外的所有JDBC调用信息，篇幅较长 -->
+    <logger name="jdbc.audit" level="OFF" additivity="false">
+        <appender-ref ref="console"/>
+    </logger>
+</configuration>

src/main/resources/mapper/PowerDeptMapper.xml

@@ -0,0 +1,44 @@
+<?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.archive.mapper.PowerDeptMapper">
+    <insert id="insertBatch">
+        INSERT INTO docus_system.power_dept (dept_id, dept_code, dept_name, dict_id,
+                                             effective, create_date, creater, update_date,
+                                             updater, remark, sort, `type`)
+        VALUES
+               <foreach collection="deptList" item="dept" separator=",">
+                   (#{dept.deptId},#{dept.deptCode},#{dept.deptName},#{dept.dictId},
+                    #{dept.effective},#{dept.createDate},#{dept.creater},#{dept.updateDate},
+                    #{dept.updater},#{dept.remark},#{dept.sort},#{dept.type})
+               </foreach>
+    </insert>
+    <update id="updateBatch">
+
+        <foreach collection="deptList" item="dept" >
+            UPDATE docus_system.power_dept
+            SET dept_code=#{dept.deptCode}, dept_name=#{dept.deptName}, dict_id=#{dept.dictId},
+                                               effective=#{dept.effective}, create_date=#{dept.createDate}, creater=#{dept.creater},
+                                               update_date=#{dept.updateDate}, updater=#{dept.updater}, remark=#{dept.remark},
+                                               sort=#{dept.sort}, `type`=#{dept.type} WHERE dept_id=#{dept.deptId};
+        </foreach>
+
+    </update>
+
+    <select id="list" resultType="com.docus.server.archive.entity.PowerDept">
+       SELECT
+              dept_code as deptCode,
+              dept_Name as deptName
+       FROM `docus_system`.`power_dept`
+    </select>
+    <select id="findByDeptCodes" resultType="com.docus.server.archive.entity.PowerDept">
+        select dept_id, dept_code, dept_name, dict_id,
+               effective, create_date, creater, update_date,
+               updater, remark, sort, `type`
+        from `docus_system`.`power_dept`
+        where dept_code in <foreach collection="deptCodes" item="deptCode" separator="," open="(" close=")">
+                                #{deptCode}
+                            </foreach>
+    </select>
+</mapper>

src/main/resources/mapper/PowerUser.xml

@@ -0,0 +1,57 @@
+<?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.archive.mapper.PowerUserMapper">
+    <insert id="insertBatch">
+        INSERT INTO docus_system.power_user (user_id, user_name, user_pwd, user_sex, user_age, user_tel, user_email,
+                                             user_head, user_position, role_id, dept_id, effective, create_date,
+                                             creater, update_date, updater, remark, login_flag, name, power_dept,
+                                             power_attending, wx_bank, enabled, pwd_change, mnemonic_words, account_state,
+                                             att_role_id, open_id, is_third)
+         VALUES
+            <foreach collection="userList" item="user" separator=",">
+                (
+                 #{user.userId},#{user.userName},#{user.userPwd},#{user.userSex},#{user.userAge},#{user.userTel},#{user.userEmail},
+                 #{user.userHead},#{user.userPosition},#{user.roleId},#{user.deptId},#{user.effective},#{user.createDate},
+                 #{user.creater},#{user.updateDate},#{user.updater},#{user.remark},#{user.loginFlag},#{user.name},#{user.powerDept},
+                 #{user.powerAttending},#{user.wxBank},#{user.enabled},#{user.pwdChange},#{user.mnemonicWords},#{user.accountState},
+                 #{user.attRoleId},#{user.openId},#{user.isThird}
+                )
+            </foreach>
+    </insert>
+    <update id="updateBatch">
+        <foreach collection="userList" item="user" >
+            UPDATE docus_system.power_user
+            SET user_name=#{user.userName}, user_pwd=#{user.userPwd}, user_sex=#{user.userSex},
+                user_age=#{user.userAge}, user_tel=#{user.userTel}, user_email=#{user.userEmail},
+                user_head=#{user.userHead}, user_position=#{user.userPosition}, role_id=#{user.roleId},
+                dept_id=#{user.deptId}, effective=#{user.effective}, create_date=#{user.createDate},
+                creater=#{user.creater}, update_date=#{user.updateDate}, updater=#{user.updater}, remark=#{user.remark},
+                login_flag=#{user.loginFlag}, name=#{user.name}, power_dept=#{user.powerDept} ,power_attending=#{user.powerAttending},
+                wx_bank=#{user.wxBank},enabled=#{user.enabled}, pwd_change=#{user.pwdChange}, mnemonic_words=#{user.mnemonicWords},
+                account_state=#{user.accountState}, att_role_id=#{user.attRoleId},
+                open_id=#{user.openId}, is_third=#{user.isThird}
+            WHERE user_id=#{user.userId};
+        </foreach>
+
+    </update>
+
+    <select id="list" resultType="com.docus.server.archive.entity.PowerUser">
+        SELECT
+            user_name as    userName,
+            name
+        FROM `docus_system`.`power_user`
+    </select>
+    <select id="findByUserNames" resultType="com.docus.server.archive.entity.PowerUser">
+        SELECT user_id, user_name, user_pwd, user_sex, user_age, user_tel,
+               user_email, user_head, user_position,role_id, dept_id, effective,
+               create_date, creater,update_date, updater, remark, login_flag, name,
+               power_dept, power_attending, wx_bank, enabled, pwd_change, mnemonic_words,
+               account_state, att_role_id, open_id, is_third
+        FROM docus_system.power_user
+        WHERE user_name in <foreach collection="userNames" item="userName" open="(" close=")" separator=",">
+                                #{userName}
+                            </foreach>
+    </select>
+</mapper>

src/main/resources/mapper/TBasicMapper.xml

@@ -0,0 +1,58 @@
+<?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.archive.mapper.TBasicMapper">
+    <insert id="insertBatch">
+        INSERT INTO `docus_medicalrecord`.`t_basic`
+            (`patient_id`, `admiss_times`, `inpatient_no`,  `name`, `name_spell`,
+             `sex`,  `sex_name`,`age`, `age_month`, `age_day`, `id_card`, `telphone`,
+             `admiss_date`,`admiss_dept`, `admiss_dept_name`,
+             `dis_date`,`dis_dept`, `dis_dept_name`,
+             `attending`, `attending_name`,
+             `is_dead`,`file_source`,
+             `jzh`,`bed_no`, `jz_card_no`, `total_cost`,
+             `create_time`, `update_time`) VALUES
+            <foreach collection="basicList" separator="," item="basic">
+                (
+                 #{basic.patientId},#{basic.admissTimes},#{basic.inpatientNo},#{basic.name},#{basic.nameSpell},
+                 #{basic.sex},#{basic.sexName},#{basic.age},#{basic.ageMonth},#{basic.ageDay},#{basic.idCard},#{basic.telphone},
+                 #{basic.admissDate},#{basic.admissDept},#{basic.admissDeptName},
+                 #{basic.disDate},#{basic.disDept},#{basic.disDeptName},
+                 #{basic.attending},#{basic.attendingName},
+                 #{basic.isDead},#{basic.fileSource},
+                 #{basic.jzh},#{basic.bedNo},#{basic.jzCardNo},#{basic.totalCost},
+                 #{basic.createTime},#{basic.updateTime}
+                )
+            </foreach>
+    </insert>
+    <update id="updateBatch">
+        <foreach collection="basicList"  item="basic">
+          UPDATE  `docus_medicalrecord`.`t_basic`
+          set inpatient_no=#{basic.inpatientNo},admiss_times=#{basic.admissTimes},name=#{basic.name},name_spell=#{basic.nameSpell},
+            `sex`= #{basic.sex},  `sex_name`=#{basic.sexName},`age`=#{basic.age}, `age_month`=#{basic.ageMonth},
+              `age_day`=#{basic.ageDay}, `id_card`=#{basic.idCard}, `telphone`=#{basic.telphone},
+            `admiss_date`=#{basic.admissDate},`admiss_dept`=#{basic.admissDept}, `admiss_dept_name`=#{basic.admissDeptName},
+            `dis_date`=  #{basic.disDate},`dis_dept`=#{basic.disDept}, `dis_dept_name`=#{basic.disDeptName},
+            `attending`= #{basic.attending}, `attending_name`=#{basic.attendingName},
+            `is_dead`=#{basic.isDead},`file_source`=#{basic.fileSource},
+            `jzh`=  #{basic.jzh},`bed_no`=#{basic.bedNo}, `jz_card_no`=#{basic.jzCardNo}, `total_cost`=#{basic.totalCost},
+            `create_time`= #{basic.createTime}, `update_time`=#{basic.updateTime}
+            WHERE patient_id= #{basic.patientId};
+        </foreach>
+    </update>
+
+    <select id="getByJzh" resultType="com.docus.server.archive.entity.TBasic">
+        select `patient_id`, `admiss_times`, `inpatient_no`,  `name`, `name_spell`,
+        `sex`,  `sex_name`,`age`, `age_month`, `age_day`, `id_card`, `telphone`,
+        `admiss_date`,`admiss_dept`, `admiss_dept_name`,
+        `dis_date`,`dis_dept`, `dis_dept_name`,
+        `attending`, `attending_name`,
+        `is_dead`,`file_source`,
+        `jzh`,`bed_no`, `jz_card_no`, `total_cost`
+        from docus_medicalrecord.t_basic
+        where jzh in <foreach collection="jzhs" item="jzh" open="(" close=")" separator=",">
+                        #{jzh}
+                     </foreach>
+    </select>
+</mapper>