docus-collector
/
docus-collect-nkzx
4
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

feat：农垦同步转科信息

Browse Source
master
wyb 1 year ago
commit 173b598e9a
26 changed files with 1349 additions and 0 deletions
Show Stats Download Patch File Download Diff File

35
.gitignore vendored
Unescape Escape View File

@ -0,0 +1,35 @@
target/
!.mvn/wrapper/maven-wrapper.jar
### STS ###
.apt_generated
.classpath
.factorypath
.project
.settings
.springBeans
.sts4-cache
docus-services/docus-services-system1/
### IntelliJ IDEA ###
*.log
.idea
*.iws
*.iml
*.ipr
mvnw*
*.cmd
*.mvn
### NetBeans ###
/nbproject/private/
/nbbuild/
/dist/
/nbdist/
/.nb-gradle/
build/
!**/src/main/**/build/
!**/src/test/**/build/
### VS Code ###
.vscode/
logs*

73
assembly.xml
Unescape Escape View File

@ -0,0 +1,73 @@
<assembly xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/assembly-1.0.0.xsd">
<id>exe</id>
<formats>
<format>dir</format>
</formats>
<includeBaseDirectory>false</includeBaseDirectory>
<fileSets>
<fileSet>
<outputDirectory>/lib</outputDirectory>
<directory>${basedir}/target/lib</directory>
</fileSet>
<fileSet>
<outputDirectory>/config</outputDirectory>
<directory>${basedir}/target/resources</directory>
<fileMode>0755</fileMode>
<includes>
<include>*.xml</include>
<include>*.yml</include>
<include>*.properties</include>
</includes>
</fileSet>
<fileSet>
<outputDirectory>/dataConfig</outputDirectory>
<directory>${basedir}/target/dataConfig</directory>
<fileMode>0755</fileMode>
<includes>
<include>*.json</include>
</includes>
</fileSet>
<fileSet>
<outputDirectory>/</outputDirectory>
<directory>${basedir}/target/resources/bin</directory>
<fileMode>0755</fileMode>
<includes>
<include>*.bat</include>
</includes>
</fileSet>
<fileSet>
<outputDirectory>/</outputDirectory>
<directory>${basedir}/target/resources/bin</directory>
<fileMode>0755</fileMode>
<includes>
<include>*.xml</include>
</includes>
</fileSet>
<fileSet>
<outputDirectory>/</outputDirectory>
<directory>${basedir}</directory>
<fileMode>0755</fileMode>
<includes>
<include>*.exe</include>
</includes>
</fileSet>
<!-- 将项目启动jar打包到boot目录中 -->
<fileSet>
<directory>${basedir}/target</directory>
<outputDirectory>/</outputDirectory>
<fileMode>0755</fileMode>
<includes>
<include>${project.build.finalName}.jar</include>
</includes>
</fileSet>
</fileSets>
</assembly>

369
pom.xml
Unescape Escape View File

@ -0,0 +1,369 @@
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<parent>
<groupId>com.docus</groupId>
<artifactId>docus-bom</artifactId>
<version>1.0-SNAPSHOT</version>
</parent>
<modelVersion>4.0.0</modelVersion>
<artifactId>docus-collect-nkzxyy</artifactId>
<dependencies>
<dependency>
<groupId>com.docus</groupId>
<artifactId>docus-knife4j-starter</artifactId>
</dependency>
<dependency>
<groupId>com.belerweb</groupId>
<artifactId>pinyin4j</artifactId>
<version>2.5.1</version>
</dependency>
<!--配置中心客户端-->
<dependency>
<groupId>com.alibaba.cloud</groupId>
<artifactId>spring-cloud-starter-alibaba-nacos-config</artifactId>
<exclusions>
<exclusion>
<artifactId>checker-qual</artifactId>
<groupId>org.checkerframework</groupId>
</exclusion>
<exclusion>
<artifactId>error_prone_annotations</artifactId>
<groupId>com.google.errorprone</groupId>
</exclusion>
</exclusions>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<!--mybatis plus-->
<dependency>
<groupId>com.baomidou</groupId>
<artifactId>mybatis-plus-boot-starter</artifactId>
<version>3.4.0</version>
</dependency>
<dependency>
<groupId>com.baomidou</groupId>
<artifactId>dynamic-datasource-spring-boot-starter</artifactId>
<version>3.4.0</version>
</dependency>
<!--nacos-->
<dependency>
<groupId>com.alibaba.cloud</groupId>
<artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
<exclusions>
<exclusion>
<artifactId>HdrHistogram</artifactId>
<groupId>org.hdrhistogram</groupId>
</exclusion>
<exclusion>
<artifactId>jsr305</artifactId>
<groupId>com.google.code.findbugs</groupId>
</exclusion>
</exclusions>
</dependency>
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
<version>8.0.28</version>
</dependency>
<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
<version>1.18.16</version>
<scope>compile</scope>
</dependency>
<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
<version>1.18.16</version>
<scope>compile</scope>
</dependency>
<dependency>
<groupId>org.bgee.log4jdbc-log4j2</groupId>
<artifactId>log4jdbc-log4j2-jdbc4.1</artifactId>
</dependency>
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>druid</artifactId>
<version>1.2.4</version>
<scope>compile</scope>
</dependency>
<dependency>
<groupId>com.baomidou</groupId>
<artifactId>mybatis-plus-generator</artifactId>
<version>3.4.1</version>
<scope>compile</scope>
</dependency>
<dependency>
<groupId>org.apache.velocity</groupId>
<artifactId>velocity-engine-core</artifactId>
<version>2.0</version>
</dependency>
<dependency>
<groupId>com.xuxueli</groupId>
<artifactId>xxl-job-core</artifactId>
</dependency>
<dependency>
<groupId>com.docus</groupId>
<artifactId>docus-base-starter</artifactId>
<exclusions>
<exclusion>
<artifactId>knife4j-spring-boot-autoconfigure</artifactId>
<groupId>com.github.xiaoymin</groupId>
</exclusion>
</exclusions>
</dependency>
<dependency>
<groupId>com.docus</groupId>
<artifactId>docus-tool-starter</artifactId>
</dependency>
<dependency>
<groupId>com.docus</groupId>
<artifactId>docus-shiro-starter</artifactId>
</dependency>
<dependency>
<groupId>com.docus</groupId>
<artifactId>docus-base-starter</artifactId>
<exclusions>
<exclusion>
<artifactId>springfox-core</artifactId>
<groupId>io.springfox</groupId>
</exclusion>
<exclusion>
<artifactId>springfox-schema</artifactId>
<groupId>io.springfox</groupId>
</exclusion>
<exclusion>
<artifactId>springfox-spi</artifactId>
<groupId>io.springfox</groupId>
</exclusion>
<exclusion>
<artifactId>knife4j-spring-boot-autoconfigure</artifactId>
<groupId>com.github.xiaoymin</groupId>
</exclusion>
</exclusions>
</dependency>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-netflix-hystrix</artifactId>
</dependency>
<!--&lt;!&ndash;添加feign依赖&ndash;&gt;-->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-openfeign</artifactId>
</dependency>
<dependency>
<groupId>junit</groupId>
<artifactId>junit</artifactId>
<scope>test</scope>
</dependency>
<!--sqlserver驱动-->
<dependency>
<groupId>com.microsoft.sqlserver</groupId>
<artifactId>sqljdbc4</artifactId>
<version>4.0</version>
</dependency>
<!-- oracle 驱动-->
<dependency>
<groupId>com.oracle</groupId>
<artifactId>ojdbc6</artifactId>
<version>11.2.0.4.0</version>
</dependency>
<!-- webservice cxf-->
<dependency>
<groupId>org.apache.cxf</groupId>
<artifactId>cxf-spring-boot-starter-jaxws</artifactId>
<version>3.3.4</version>
</dependency>
<dependency>
<groupId>org.dom4j</groupId>
<artifactId>dom4j</artifactId>
<version>2.1.1</version>
</dependency>
</dependencies>
<build>
<resources>
<resource>
<directory>src/main/resources</directory>
<filtering>true</filtering>
</resource>
</resources>
<plugins>
<plugin>
<!--打包时去除第三方依赖-->
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
<version>2.4.4</version>
<configuration>
<layout>ZIP</layout>
<includes>
<include>
<groupId>non-exists</groupId>
<artifactId>non-exists</artifactId>
</include>
</includes>
</configuration>
<executions>
<execution>
<goals>
<goal>repackage</goal>
</goals>
</execution>
</executions>
</plugin>
<!--拷贝第三方依赖文件到指定目录-->
<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-dependency-plugin</artifactId>
<executions>
<execution>
<id>copy-dependencies</id>
<phase>package</phase>
<goals>
<goal>copy-dependencies</goal>
</goals>
<configuration>
<!--target/lib是依赖jar包的输出目录，根据自己喜好配置-->
<outputDirectory>target/lib</outputDirectory>
<excludeTransitive>false</excludeTransitive>
<stripVersion>false</stripVersion>
<includeScope>runtime</includeScope>
</configuration>
</execution>
</executions>
</plugin>
<!-- copy资源文件 -->
<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-resources-plugin</artifactId>
<version>3.2.0</version>
<executions>
<execution>
<id>copy-resources</id>
<phase>package</phase>
<goals>
<goal>copy-resources</goal>
</goals>
<configuration>
<resources>
<resource>
<directory>src/main/resources</directory>
<includes>
<include>**/*.*</include>
</includes>
</resource>
</resources>
<outputDirectory>${project.build.directory}/resources</outputDirectory>
</configuration>
</execution>
<execution>
<id>copy-bin</id>
<phase>package</phase>
<goals>
<goal>copy-resources</goal>
</goals>
<configuration>
<resources>
<resource>
<directory>src/main/resources</directory>
<filtering>true</filtering>
<includes>
<include>bin/*.xml</include>
<include>*.yml</include>
<include>bin/*.bat</include>
</includes>
</resource>
</resources>
<outputDirectory>${project.build.directory}/resources</outputDirectory>
</configuration>
</execution>
<execution>
<id>copy-data-config</id>
<phase>package</phase>
<goals>
<goal>copy-resources</goal>
</goals>
<configuration>
<resources>
<resource>
<directory>../../dataConfig</directory>
<filtering>true</filtering>
</resource>
</resources>
<outputDirectory>${project.build.directory}/dataConfig</outputDirectory>
</configuration>
</execution>
</executions>
</plugin>
<!-- 打jar包时忽略配置文件 -->
<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-jar-plugin</artifactId>
<version>3.2.0</version>
<configuration>
<excludes>
<exclude>**/*.yml</exclude>
</excludes>
</configuration>
</plugin>
<plugin>
<artifactId>maven-assembly-plugin</artifactId>
<executions>
<execution>
<configuration>
<finalName>${project.artifactId}</finalName>
<appendAssemblyId>false</appendAssemblyId>
<descriptors>
<descriptor>assembly.xml</descriptor>
</descriptors>
</configuration>
<id>make-assembly</id>
<phase>package</phase>
<goals>
<goal>single</goal>
</goals>
</execution>
</executions>
</plugin>
</plugins>
</build>
<profiles>
<profile>
<id>dev</id>
<properties>
<profile.name>prod</profile.name>
</properties>
<activation>
<activeByDefault>true</activeByDefault>
</activation>
</profile>
</profiles>
</project>

29
src/main/java/com/docus/server/AppRunBootstrap.java
Unescape Escape View File

@ -0,0 +1,29 @@
package com.docus.server;
import lombok.extern.slf4j.Slf4j;
import org.mybatis.spring.annotation.MapperScan;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.openfeign.EnableFeignClients;
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);
}
}

87
src/main/java/com/docus/server/XxlJobConfig.java
Unescape Escape View File

@ -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();
*//*
*/
}

68
src/main/java/com/docus/server/archive/entity/TBasic.java
Unescape Escape View File

@ -0,0 +1,68 @@
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 = "TBasic对象", description = "病案基本信息")
public class TBasic implements Serializable {
private static final long serialVersionUID = 1L;
@ApiModelProperty(value = "病案主键")
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 Date admissDate;
@ApiModelProperty(value = "住院科室")
private String admissDept;
@ApiModelProperty(value = "住院科室名称")
private String admissDeptName;
@ApiModelProperty(value = "主管医生工号")
private String attending;
@ApiModelProperty(value = "主管医生姓名")
private String attendingName;
@ApiModelProperty(value = "出院日期")
private Date disDate;
@ApiModelProperty(value = "出院科室")
private String disDept;
@ApiModelProperty(value = "出院科室名称")
private String disDeptName;
}

47
src/main/java/com/docus/server/archive/entity/TBasicZkInfo.java
Unescape Escape View File

@ -0,0 +1,47 @@
package com.docus.server.archive.entity;
import lombok.Data;
import java.util.Date;
/**
* 转科信息
*
* @author YongBin Wen
* @date 2024/4/9 13:53
*/
@Data
public class TBasicZkInfo {
/**
* 主键
**/
private Long id;
/**
* 病案主键
**/
private String patientId;
/**
* 转出科室编号
**/
private String outDeptCode;
/**
* 转出科室名称
**/
private String outDeptName;
/**
* 转出日期
**/
private Date outDate;
/**
* 转入科室编号
**/
private String inDeptCode;
/**
* 转入科室名称
**/
private String inDeptName;
/**
* 数据创建时间
**/
private Date createTime;
}

114
src/main/java/com/docus/server/archive/job/SyncZkInfoJob.java
Unescape Escape View File

@ -0,0 +1,114 @@
package com.docus.server.archive.job;
import com.docus.core.util.Func;
import com.docus.infrastructure.core.utils.TableJsonRead;
import com.docus.server.archive.service.ZkInfoSyncService;
import com.xxl.job.core.handler.annotation.XxlJob;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;
import javax.annotation.Resource;
import java.time.LocalDate;
import java.util.Objects;
/**
* @author YongBin Wen
* @date 2024/4/9 14:07
*/
@Component
@Slf4j
public class SyncZkInfoJob {
@Resource
private ZkInfoSyncService zkInfoSyncService;
/**
* 农垦转科信息同步，默认同步当天和前面一天的和所有出院的
*
* @date 2024/3/27 16:27
* @author YongBin Wen
*/
@XxlJob("NkZkInfoSyncJob")
public void nkZkInfoSyncJob() {
log.info("====================> 农垦转科信息同步任务开始 ===================");
try {
nkZkInfoSync();
} catch (Exception e) {
log.error("====================> 农垦转科信息同步任务出错啦！===================" + e.getMessage(), e);
return;
}
log.info("====================> 农垦转科信息同步任务结束 ===================");
}
private void nkZkInfoSync() {
String jobConfigPath = "data-config\\job-config";
String jobConfigName = "NkZkInfoSyncJob.json";
TableJsonRead jsonReader = new TableJsonRead();
NkZkInfoSyncJobConfig syncJobConfig = jsonReader.Read(jobConfigPath, jobConfigName, NkZkInfoSyncJobConfig.class);
syncJobConfig = NkZkInfoSyncJobConfig.checkAndInit(syncJobConfig);
Integer pageSize = syncJobConfig.getPageSize();
Integer pageNumber = syncJobConfig.getPageNumber();
String startDate = syncJobConfig.getStartDate();
LocalDate runLocalDate = LocalDate.now();
String runJobDate = runLocalDate.toString();
while (true) {
int syncCount = zkInfoSyncService.syncZkInfo(startDate + " 00:00:00", runJobDate + " 23:59:59", pageNumber, pageSize);
if (syncCount < pageSize) {
break;
}
pageNumber += 1;
}
// 下次同步则开始多同步一天，防止时间差引起同步缺漏
String nexRunStartDate = runLocalDate.plusDays(-1).toString();
syncJobConfig.setPageNumber(1);
syncJobConfig.setStartDate(nexRunStartDate);
jsonReader.Save(jobConfigPath, jobConfigName, Func.toJson(syncJobConfig));
}
private static class NkZkInfoSyncJobConfig {
private String startDate;
private Integer pageNumber;
private Integer pageSize;
public static NkZkInfoSyncJobConfig checkAndInit(NkZkInfoSyncJobConfig jobConfig) {
if (Objects.isNull(jobConfig)) {
jobConfig = new NkZkInfoSyncJobConfig();
}
if (Objects.isNull(jobConfig.getPageNumber()) || jobConfig.getPageNumber() <= 0) {
jobConfig.setPageNumber(1);
}
if (Objects.isNull(jobConfig.getPageSize()) || jobConfig.getPageSize() <= 0) {
jobConfig.setPageSize(100);
}
if (Objects.isNull(jobConfig.getStartDate())) {
jobConfig.setStartDate(LocalDate.now().toString());
}
return jobConfig;
}
public String getStartDate() {
return startDate;
}
public void setStartDate(String startDate) {
this.startDate = startDate;
}
public Integer getPageNumber() {
return pageNumber;
}
public void setPageNumber(Integer pageNumber) {
this.pageNumber = pageNumber;
}
public Integer getPageSize() {
return pageSize;
}
public void setPageSize(Integer pageSize) {
this.pageSize = pageSize;
}
}
}

15
src/main/java/com/docus/server/archive/mapper/TBasicMapper.java
Unescape Escape View File

@ -0,0 +1,15 @@
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 {
List<TBasic> getByDisDate(@Param("disDateStart") String disDateStart, @Param("disDateEnd") String disDateEnd, @Param("offset") int offset, @Param("size") int size);
}

23
src/main/java/com/docus/server/archive/mapper/TBasicZkInfoMapper.java
Unescape Escape View File

@ -0,0 +1,23 @@
package com.docus.server.archive.mapper;
import com.docus.server.archive.entity.TBasicZkInfo;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param;
import java.util.List;
/**
* 转科信息
*
* @author YongBin Wen
* @date 2024/4/9 13:53
*/
@Mapper
public interface TBasicZkInfoMapper {
int deleteByPatientIds(@Param("patientIds") List<String> patientIds);
int saveBatch(@Param("zkInfos") List<TBasicZkInfo> zkInfos);
List<String> existsZkInfoPatientIds(@Param("patientIds") List<String> patientIds);
}

9
src/main/java/com/docus/server/archive/service/ZkInfoSyncService.java
Unescape Escape View File

@ -0,0 +1,9 @@
package com.docus.server.archive.service;
/**
* @author YongBin Wen
* @date 2024/4/9 14:16
*/
public interface ZkInfoSyncService {
int syncZkInfo(String disDateStart, String disDateEnd, Integer pageNumber, Integer pageSize);
}

79
src/main/java/com/docus/server/archive/service/impl/ZkInfoSyncServiceImpl.java
Unescape Escape View File

@ -0,0 +1,79 @@
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.entity.TBasic;
import com.docus.server.archive.entity.TBasicZkInfo;
import com.docus.server.archive.mapper.TBasicMapper;
import com.docus.server.archive.mapper.TBasicZkInfoMapper;
import com.docus.server.archive.service.ZkInfoSyncService;
import com.docus.server.his.entity.VJswzhZkxx;
import com.docus.server.his.mapper.VJswzhZkxxMapper;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;
import javax.annotation.Resource;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;
import java.util.Map;
import java.util.stream.Collectors;
/**
* @author YongBin Wen
* @date 2024/4/9 14:16
*/
@Service
@Slf4j
public class ZkInfoSyncServiceImpl implements ZkInfoSyncService {
@Resource
private VJswzhZkxxMapper vJswzhZkxxMapper;
@Resource
private TBasicMapper tBasicMapper;
@Resource
private TBasicZkInfoMapper tBasicZkInfoMapper;
@Resource
private IdService idService;
@Override
public int syncZkInfo(String disDateStart, String disDateEnd, Integer pageNumber, Integer pageSize) {
Date nowDate = new Date();
int offset = (pageNumber - 1) * pageSize;
List<TBasic> basicList = tBasicMapper.getByDisDate(disDateStart, disDateEnd, offset, pageSize);
if (Func.isEmpty(basicList)) {
return 0;
}
int querySize = basicList.size();
basicList = basicList.stream().filter(e -> Func.isNotBlank(e.getJzh())).collect(Collectors.toList());
if (Func.isEmpty(basicList)) {
return querySize;
}
List<String> jzhs = basicList.stream().map(TBasic::getJzh).collect(Collectors.toList());
List<String> patientIds = basicList.stream().map(TBasic::getPatientId).collect(Collectors.toList());
Map<String, String> basicJzhPidMap = basicList.stream().collect(Collectors.toMap(TBasic::getJzh, TBasic::getPatientId));
List<VJswzhZkxx> zkxxList = vJswzhZkxxMapper.getZkInfoByJzhs(jzhs);
if (Func.isNotEmpty(zkxxList)) {
List<TBasicZkInfo> zkInfos = new ArrayList<>();
for (VJswzhZkxx vJswzhZkxx : zkxxList) {
TBasicZkInfo zkInfo = new TBasicZkInfo();
zkInfo.setId(idService.getDateSeq());
zkInfo.setPatientId(basicJzhPidMap.get(vJswzhZkxx.getJzh()));
zkInfo.setOutDeptCode(vJswzhZkxx.getZcbq());
zkInfo.setOutDeptName(vJswzhZkxx.getZcks());
zkInfo.setInDeptCode(vJswzhZkxx.getZrbq());
zkInfo.setInDeptName(vJswzhZkxx.getZrks());
zkInfo.setOutDate(vJswzhZkxx.getZcrq());
zkInfo.setCreateTime(nowDate);
zkInfos.add(zkInfo);
}
// 根据病案主键查询已经同步的转科信息，未同步的插入
List<String> existsZkInfoPatientIds = tBasicZkInfoMapper.existsZkInfoPatientIds(patientIds);
zkInfos = zkInfos.stream().filter(zk -> !existsZkInfoPatientIds.contains(zk.getPatientId())).collect(Collectors.toList());
if (Func.isNotEmpty(zkInfos)) {
tBasicZkInfoMapper.saveBatch(zkInfos);
}
log.info("出院日期范围：{} - {} ,页码：{} size：{},查询：{}基础数据，本次新增转科信息数据：{} 条", disDateStart, disDateEnd, pageNumber, pageSize, basicList.size(), zkInfos.size());
}
return querySize;
}
}

39
src/main/java/com/docus/server/his/entity/VJswzhZkxx.java
Unescape Escape View File

@ -0,0 +1,39 @@
package com.docus.server.his.entity;
import lombok.Data;
import java.util.Date;
/**
* 嘉时无纸化转科信息视图
*
* @author YongBin Wen
* @date 2024/4/9 13:46
*/
@Data
public class VJswzhZkxx {
/**
* 记账号
*/
private String jzh;
/**
* 转出病区编号
*/
private String zcbq;
/**
* 转出科室名称
*/
private String zcks;
/**
* 转出时间
*/
private Date zcrq;
/**
* 转入病区编号
*/
private String zrbq;
/**
* 转入科室名称
*/
private String zrks;
}

19
src/main/java/com/docus/server/his/mapper/VJswzhZkxxMapper.java
Unescape Escape View File

@ -0,0 +1,19 @@
package com.docus.server.his.mapper;
import com.baomidou.dynamic.datasource.annotation.DS;
import com.docus.server.his.entity.VJswzhZkxx;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param;
import java.util.List;
/**
* 嘉时无纸化转科信息视图
* @author YongBin Wen
* @date 2024/4/9 13:46
*/
@DS("his")
@Mapper
public interface VJswzhZkxxMapper {
List<VJswzhZkxx> getZkInfoByJzhs(@Param("jzhs") List<String> jzhs);
}

33
src/main/resources/bin/install.bat
Unescape Escape View File

@ -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
)

21
src/main/resources/bin/start.bat
Unescape Escape View File

@ -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

13
src/main/resources/bin/stop.bat
Unescape Escape View File

@ -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
)

19
src/main/resources/bin/update.bat
Unescape Escape View File

@ -0,0 +1,19 @@
@echo off
set deployDir=%1\docus-collect-nkzxyy
if %deployDir%=="" set deployDir=d:\webroot\docus-collect-nkzxyy
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

8
src/main/resources/bin/winsw.xml
Unescape Escape View File

@ -0,0 +1,8 @@
<service>
<id>docus-collect-nkzxyy</id>
<name>生产-嘉时-佛山三院采集服务</name>
<description>生产-嘉时-佛山三院采集服务</description>
<startmode>Automatic</startmode>
<executable>%BASE%\start.bat</executable>
<log mode="none"></log>
</service>

113
src/main/resources/bootstrap.yml
Unescape Escape View File

@ -0,0 +1,113 @@
server:
port: 9314
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
his:
url: jdbc:oracle:thin:@//192.168.0.40:1521/his
username: his_wzh
password: His@2022Wzh
driver-class-name: oracle.jdbc.driver.OracleDriver
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 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}
fsy:
lis:
ws-url: http://10.100.23.96:8095/DCLService.asmx
sysflag: 6
assortid: 1213131
docus:
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-nkzxyy
address:
ip:
port: 19314
logretentiondays: 30
logpath: D:/xxl-job/docus-collect-nkzxyy

2
src/main/resources/log4jdbc.log4j2.properties
Unescape Escape View File

@ -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

77
src/main/resources/logback.xml
Unescape Escape View File

@ -0,0 +1,77 @@
<?xml version="1.0" encoding="UTF-8"?>
<configuration debug="false" scan="true" scanPeriod="1 seconds">
<contextName>docus-collect-nkzxyy</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>

12
src/main/resources/mapper/TBasicMapper.xml
Unescape Escape View File

@ -0,0 +1,12 @@
<?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">
<select id="getByDisDate" resultType="com.docus.server.archive.entity.TBasic">
select patient_id,jzh from docus_medicalrecord.t_basic
where dis_date BETWEEN #{disDateStart} AND #{disDateEnd}
LIMIT ${offset},${size}
</select>
</mapper>

30
src/main/resources/mapper/TBasicZkInfoMapper.xml
Unescape Escape View File

@ -0,0 +1,30 @@
<?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.TBasicZkInfoMapper">
<insert id="saveBatch">
INSERT INTO `docus_medicalrecord`.`t_basic_zk_info`
(`id`, `patient_id`, `out_dept_code`, `out_dept_name`, `out_date`, `in_dept_code`, `in_dept_name`, `create_time`) VALUES
<foreach collection="zkInfos" item="zkInfo" separator=",">
(
#{zkInfo.id},#{zkInfo.patientId},#{zkInfo.outDeptCode},#{zkInfo.outDate},#{zkInfo.outDate},
#{zkInfo.inDeptCode},#{zkInfo.inDeptName},#{zkInfo.createTime}
)
</foreach>
</insert>
<delete id="deleteByPatientIds">
delete from docus_medicalrecord.t_basic_zk_info
where patient_id in <foreach collection="patientIds" item="patientId" separator="," open="(" close=")">
#{patientId}
</foreach>
</delete>
<select id="existsZkInfoPatientIds" resultType="java.lang.String">
select patient_id from docus_medicalrecord.t_basic_zk_info
where patient_id in <foreach collection="patientIds" item="patientId" separator="," open="(" close=")">
#{patientId}
</foreach>
</select>
</mapper>

15
src/main/resources/mapper/VJswzhZkxxMapper.xml
Unescape Escape View File

@ -0,0 +1,15 @@
<?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.his.mapper.VJswzhZkxxMapper">
<select id="getZkInfoByJzhs" resultType="com.docus.server.his.entity.VJswzhZkxx">
SELECT jzh,zcbq,zcks,zcrq,zrbq,zrks
FROM V_JSWZH_ZKXX
where jzh in <foreach collection="jzhs" separator="," item="jzh" open="(" close=")">
#{jzh}
</foreach>
</select>
</mapper>

BIN
winsw.exe
View File

Binary file not shown.
Write Preview
Loading…
Cancel
Save