调整项目结构
linrf
2 years ago
parent
b2c2c75c60
commit
d19776f9f7
@ -1,79 +0,0 @@
|
||||
<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/maven-v4_0_0.xsd">
|
||||
<parent>
|
||||
<artifactId>docus-collector-server</artifactId>
|
||||
<groupId>com.docus</groupId>
|
||||
<version>1.0-SNAPSHOT</version>
|
||||
</parent>
|
||||
<modelVersion>4.0.0</modelVersion>
|
||||
<artifactId>bl-sysem</artifactId>
|
||||
<name>Archetype - bl-sysem</name>
|
||||
<url>http://maven.apache.org</url>
|
||||
<dependencies>
|
||||
<dependency>
|
||||
<groupId>com.docus</groupId>
|
||||
<artifactId>docus-sys</artifactId>
|
||||
<version>1.0-SNAPSHOT</version>
|
||||
<scope>compile</scope>
|
||||
</dependency>
|
||||
<dependency>
|
||||
<groupId>com.docus</groupId>
|
||||
<artifactId>docus-medical-record</artifactId>
|
||||
<version>1.0-SNAPSHOT</version>
|
||||
<scope>compile</scope>
|
||||
</dependency>
|
||||
</dependencies>
|
||||
<build>
|
||||
<!-- <resources>-->
|
||||
<!-- <resource>-->
|
||||
<!-- <directory>src/main/java</directory>-->
|
||||
<!-- <includes>-->
|
||||
<!-- <include>**/*.xml</include>-->
|
||||
<!-- </includes>-->
|
||||
<!-- </resource>-->
|
||||
<!-- <resource>-->
|
||||
<!-- <directory>src/main/resources</directory>-->
|
||||
<!-- </resource>-->
|
||||
<!-- </resources>-->
|
||||
|
||||
<plugins>
|
||||
|
||||
<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/mapper</directory>
|
||||
<includes>
|
||||
<include>**/*.*</include>
|
||||
</includes>
|
||||
</resource>
|
||||
</resources>
|
||||
<outputDirectory>../collect-sdry/target/collect-sdry/mybatis.mapper/bl-mapper</outputDirectory>
|
||||
</configuration>
|
||||
</execution>
|
||||
</executions>
|
||||
</plugin>
|
||||
|
||||
<plugin>
|
||||
<groupId>org.apache.maven.plugins</groupId>
|
||||
<artifactId>maven-jar-plugin</artifactId>
|
||||
<version>3.2.0</version>
|
||||
<configuration>
|
||||
<excludes>
|
||||
<exclude>**/*.xml</exclude>
|
||||
</excludes>
|
||||
</configuration>
|
||||
</plugin>
|
||||
</plugins>
|
||||
</build>
|
||||
</project>
|
||||
@ -1,11 +0,0 @@
|
||||
package com.docus.server.bl.common;
|
||||
|
||||
/**
|
||||
* @author linrf
|
||||
* @date 2023/6/9 11:19
|
||||
*/
|
||||
public class DSKeyConstants {
|
||||
|
||||
public static final String DS_KEY = "bl";
|
||||
|
||||
}
|
||||
@ -1,13 +0,0 @@
|
||||
package com.docus.server.bl.common.annotation;
|
||||
|
||||
import org.springframework.stereotype.Component;
|
||||
|
||||
import java.lang.annotation.*;
|
||||
|
||||
@Target({ElementType.TYPE})
|
||||
@Retention(RetentionPolicy.RUNTIME)
|
||||
@Documented
|
||||
@Component
|
||||
public @interface CacheLayer {
|
||||
String value() default "";
|
||||
}
|
||||
@ -1,4 +0,0 @@
|
||||
package com.docus.server.bl.infrastructure.cache;
|
||||
|
||||
public class DeptCacheLayer {
|
||||
}
|
||||
@ -1,4 +0,0 @@
|
||||
package com.docus.server.bl.infrastructure.client;
|
||||
|
||||
public class DownLoadAPI {
|
||||
}
|
||||
@ -1,29 +0,0 @@
|
||||
package com.docus.server.bl.infrastructure.mapper;
|
||||
|
||||
import com.baomidou.dynamic.datasource.annotation.DS;
|
||||
import com.docus.server.bl.common.DSKeyConstants;
|
||||
import org.apache.ibatis.annotations.Mapper;
|
||||
import org.apache.ibatis.annotations.Param;
|
||||
|
||||
import java.util.Date;
|
||||
import java.util.List;
|
||||
import java.util.Map;
|
||||
|
||||
@Mapper
|
||||
@DS(DSKeyConstants.DS_KEY)
|
||||
public interface BlDeptMapper {
|
||||
|
||||
List<Map<String, Object>> page(@Param("startDate") Date startDate,
|
||||
@Param("endDate") Date endDate,
|
||||
@Param("offset") int offset,
|
||||
@Param("pageSize") int pageSize);
|
||||
|
||||
|
||||
List<Map<String, Object>> BatchForJZH(@Param("jzhs") List<String> jzhs);
|
||||
|
||||
List<Map<String, Object>> BatchForJZHAndAdmissTimes(@Param("datas") List<Map<String, Object>> datas);
|
||||
|
||||
List<Map<String, Object>> BatchForZYHAndAdmissTimes(@Param("datas") List<Map<String, Object>> datas);
|
||||
|
||||
List<Map<String, Object>> BatchForEXAMTIME(@Param("datas") List<Map<String, Object>> datas);
|
||||
}
|
||||
@ -1,22 +0,0 @@
|
||||
package com.docus.server.bl.infrastructure.mapper;
|
||||
|
||||
import com.baomidou.dynamic.datasource.annotation.DS;
|
||||
import com.docus.server.bl.common.DSKeyConstants;
|
||||
import com.docus.server.record.common.pojo.dto.TBasicDTO;
|
||||
import org.apache.ibatis.annotations.Mapper;
|
||||
import org.apache.ibatis.annotations.Param;
|
||||
|
||||
import java.util.Date;
|
||||
import java.util.List;
|
||||
|
||||
@Mapper
|
||||
@DS(DSKeyConstants.DS_KEY)
|
||||
public interface BlTBasicMapper {
|
||||
|
||||
List<TBasicDTO> getTBasicListView(@Param("startDate") Date startDate,
|
||||
@Param("endDate") Date endDate,
|
||||
@Param("offset") int offset,
|
||||
@Param("pageSize") int pageSize);
|
||||
|
||||
|
||||
}
|
||||
@ -1,22 +0,0 @@
|
||||
package com.docus.server.bl.infrastructure.mapper;
|
||||
|
||||
import com.baomidou.dynamic.datasource.annotation.DS;
|
||||
import com.docus.server.bl.common.DSKeyConstants;
|
||||
import com.docus.server.sys.common.pojo.dto.UserDTO;
|
||||
import org.apache.ibatis.annotations.Mapper;
|
||||
import org.apache.ibatis.annotations.Param;
|
||||
|
||||
import java.util.Date;
|
||||
import java.util.List;
|
||||
|
||||
@Mapper
|
||||
@DS(DSKeyConstants.DS_KEY)
|
||||
public interface BlUserMapper {
|
||||
|
||||
List<UserDTO> getUserListView(@Param("startDate") Date startDate,
|
||||
@Param("endDate") Date endDate,
|
||||
@Param("offset") int offset,
|
||||
@Param("pageSize") int pageSize);
|
||||
|
||||
|
||||
}
|
||||
@ -1,6 +0,0 @@
|
||||
package com.docus.server.bl.service;
|
||||
|
||||
import com.docus.server.client.api.IHospitalApi;
|
||||
|
||||
public interface IBlService extends IHospitalApi {
|
||||
}
|
||||
@ -1,44 +0,0 @@
|
||||
package com.docus.server.bl.service.impl;
|
||||
|
||||
import com.docus.server.bl.common.DSKeyConstants;
|
||||
import com.docus.server.bl.infrastructure.mapper.BlDeptMapper;
|
||||
import com.docus.server.bl.service.IBlService;
|
||||
import lombok.AllArgsConstructor;
|
||||
import org.springframework.stereotype.Component;
|
||||
|
||||
import java.util.Date;
|
||||
import java.util.List;
|
||||
import java.util.Map;
|
||||
|
||||
@Component(DSKeyConstants.DS_KEY + "ServiceImpl")
|
||||
@AllArgsConstructor
|
||||
public class BlServiceImpl implements IBlService {
|
||||
|
||||
private final BlDeptMapper blDeptMapper;
|
||||
|
||||
@Override
|
||||
public List<Map<String, Object>> page(Date startDate, Date endDate, int pageNum, int pageSize) {
|
||||
return blDeptMapper.page(startDate, endDate, (pageNum - 1) * pageSize, pageSize);
|
||||
}
|
||||
|
||||
@Override
|
||||
public List<Map<String, Object>> BatchForJZH(List<String> jzhs) {
|
||||
return blDeptMapper.BatchForJZH(jzhs);
|
||||
}
|
||||
|
||||
@Override
|
||||
public List<Map<String, Object>> BatchForJZHAndAdmissTimes(List<Map<String, Object>> datas) {
|
||||
return blDeptMapper.BatchForJZHAndAdmissTimes(datas);
|
||||
}
|
||||
|
||||
@Override
|
||||
public List<Map<String, Object>> BatchForZYHAndAdmissTimes(List<Map<String, Object>> datas) {
|
||||
return blDeptMapper.BatchForZYHAndAdmissTimes(datas);
|
||||
}
|
||||
|
||||
@Override
|
||||
public List<Map<String, Object>> BatchForEXAMTIME(List<Map<String, Object>> datas) {
|
||||
return blDeptMapper.BatchForEXAMTIME(datas);
|
||||
}
|
||||
|
||||
}
|
||||
@ -1,180 +0,0 @@
|
||||
<?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.bl.infrastructure.mapper.BlDeptMapper">
|
||||
|
||||
<!--根据更新时间分页查询-->
|
||||
<select id="page" resultType="java.util.Map">
|
||||
SELECT DISTINCT
|
||||
'6' AS SYS_CODE,
|
||||
ZYH AS ZYH,
|
||||
JZH AS FVISIT_ID,
|
||||
FILE_NAME AS REPORT_NAME,
|
||||
'' AS BGLX,
|
||||
'1503577916225949698' AS ASSORTID,
|
||||
EXAM_NO AS RP_EXAM_NO,
|
||||
1 AS PATH_TYPE,
|
||||
FILE_PATHFILE_PATH AS FILE_PATH,
|
||||
0 AS ISDELETE,
|
||||
0 AS state,
|
||||
'' AS jch,
|
||||
'' AS checktime,
|
||||
date_format(AFFIRM_TIME, '%Y-%m-%d %H:%i:%s') AS MODIFYTIME
|
||||
FROM
|
||||
V_JSWZH_LISRECORD
|
||||
WHERE
|
||||
1 = 1
|
||||
AND AFFIRM_TIME <![CDATA[ > ]]> #{startDate}
|
||||
AND AFFIRM_TIME <![CDATA[ <= ]]> #{endDate}
|
||||
ORDER BY
|
||||
date_format(AFFIRM_TIME, '%Y-%m-%d %H:%i:%s') DESC
|
||||
LIMIT #{offset}, #{pageSize}
|
||||
</select>
|
||||
|
||||
<!--根据jzh取得所需采集的批量数据-->
|
||||
<select id="BatchForJZH" resultType="java.util.Map">
|
||||
SELECT
|
||||
'6' AS SYS_CODE,
|
||||
ZYH AS ZYH,
|
||||
JZH AS FVISIT_ID,
|
||||
FILE_NAME AS REPORT_NAME,
|
||||
'' AS BGLX,
|
||||
'1503577916225949698' AS ASSORTID,
|
||||
EXAM_NO AS RP_EXAM_NO,
|
||||
1 AS PATH_TYPE,
|
||||
FILE_PATHFILE_PATH AS FILE_PATH,
|
||||
0 AS ISDELETE,
|
||||
0 AS state,
|
||||
'' AS jch,
|
||||
'' AS checktime,
|
||||
date_format(AFFIRM_TIME, '%Y-%m-%d %H:%i:%s') AS MODIFYTIME
|
||||
FROM
|
||||
V_JSWZH_LISRECORD
|
||||
WHERE
|
||||
1 = 1
|
||||
AND JZH IN
|
||||
<foreach item="item" index="index" collection="jzhs" open="(" separator="," close=")">
|
||||
#{item}
|
||||
</foreach>
|
||||
|
||||
</select>
|
||||
<!--记账号+住院次数-->
|
||||
<select id="BatchForJZHAndAdmissTimes" resultType="java.util.Map">
|
||||
SELECT
|
||||
'6' AS SYS_CODE,
|
||||
ZYH AS ZYH,
|
||||
JZH AS FVISIT_ID,
|
||||
FILE_NAME AS REPORT_NAME,
|
||||
'' AS BGLX,
|
||||
'1503577916225949698' AS ASSORTID,
|
||||
EXAM_NO AS RP_EXAM_NO,
|
||||
1 AS PATH_TYPE,
|
||||
FILE_PATHFILE_PATH AS FILE_PATH,
|
||||
0 AS ISDELETE,
|
||||
0 AS state,
|
||||
'' AS jch,
|
||||
'' AS checktime,
|
||||
date_format(AFFIRM_TIME, '%Y-%m-%d %H:%i:%s') AS MODIFYTIME
|
||||
FROM
|
||||
V_JSWZH_LISRECORD
|
||||
WHERE
|
||||
1 = 1
|
||||
and (
|
||||
<foreach item="item" index="index" collection="datas" open="(" separator="," close=")">
|
||||
(JZH =#{item.FVISIT_ID} and ADMISS_TIMES=#{item.ADMISS_TIMES}) or
|
||||
</foreach>
|
||||
)
|
||||
</select>
|
||||
<select id="BatchForZYHAndAdmissTimes" resultType="java.util.Map">
|
||||
SELECT
|
||||
'6' AS SYS_CODE,
|
||||
ZYH AS ZYH,
|
||||
JZH AS FVISIT_ID,
|
||||
FILE_NAME AS REPORT_NAME,
|
||||
'' AS BGLX,
|
||||
'1503577916225949698' AS ASSORTID,
|
||||
EXAM_NO AS RP_EXAM_NO,
|
||||
1 AS PATH_TYPE,
|
||||
FILE_PATHFILE_PATH AS FILE_PATH,
|
||||
0 AS ISDELETE,
|
||||
0 AS state,
|
||||
'' AS jch,
|
||||
'' AS checktime,
|
||||
date_format(AFFIRM_TIME, '%Y-%m-%d %H:%i:%s') AS MODIFYTIME
|
||||
FROM
|
||||
V_JSWZH_LISRECORD
|
||||
WHERE
|
||||
1 = 1
|
||||
and (
|
||||
<foreach item="item" index="index" collection="datas" open="(" separator="," close=")">
|
||||
(ZYH =#{item.ZYH} and ADMISS_TIMES=#{item.ADMISS_TIMES}) or
|
||||
</foreach>
|
||||
)
|
||||
</select>
|
||||
<select id="BatchForEXAMTIME" resultType="java.util.Map">
|
||||
SELECT
|
||||
'6' AS SYS_CODE,
|
||||
ZYH AS ZYH,
|
||||
JZH AS FVISIT_ID,
|
||||
FILE_NAME AS REPORT_NAME,
|
||||
'' AS BGLX,
|
||||
'1503577916225949698' AS ASSORTID,
|
||||
EXAM_NO AS RP_EXAM_NO,
|
||||
1 AS PATH_TYPE,
|
||||
FILE_PATHFILE_PATH AS FILE_PATH,
|
||||
0 AS ISDELETE,
|
||||
0 AS state,
|
||||
'' AS jch,
|
||||
'' AS checktime,
|
||||
date_format(AFFIRM_TIME, '%Y-%m-%d %H:%i:%s') AS MODIFYTIME
|
||||
FROM
|
||||
V_JSWZH_LISRECORD
|
||||
WHERE
|
||||
1 = 1
|
||||
and (
|
||||
<foreach item="item" index="index" collection="datas" open="(" separator="," close=")">
|
||||
(ZYH =#{item.ZYH} and EXAM_TIME <![CDATA[ >= ]]> STR_TO_DATE(#{item.admiss_date})
|
||||
<if test="item.dis_date != null">
|
||||
and EXAM_TIME <![CDATA[ <= ]]> STR_TO_DATE(#{item.dis_date})
|
||||
</if>
|
||||
</foreach>
|
||||
)
|
||||
</select>
|
||||
|
||||
|
||||
<!-- mysql
|
||||
<select id="list" resultType="com.docus.server.sys.common.pojo.dto.DeptDTO">
|
||||
SELECT `update_time` as update_time ,`dept_code` as dept_code,`dept_name` as dept_name FROM `his`.`his_dept`
|
||||
WHERE update_time between #{startDate} and #{endDate}
|
||||
order by update_time asc
|
||||
LIMIT (#{pageNum} - 1) * #{pageSize} , #{pageSize}
|
||||
</select>
|
||||
-->
|
||||
|
||||
|
||||
<!-- mssqsql
|
||||
<select id="list" resultType="com.docus.server.sys.common.pojo.dto.DeptDTO">
|
||||
select top pageSize `update_time` as update_time ,`dept_code` as dept_code,`dept_name` as dept_name
|
||||
from (select row_number()
|
||||
over(order by sno asc) as rownumber,*
|
||||
from student) temp_row
|
||||
where rownumber>((pageNum-1)*pageSize);
|
||||
</select>
|
||||
-->
|
||||
|
||||
<!-- oracle
|
||||
<select id="list" resultType="com.docus.server.sys.common.pojo.dto.DeptDTO">
|
||||
SELECT * FROM
|
||||
(SELECT tt.*,ROWNUM AS RN FROM
|
||||
(SELECT t.* FROM ${tableName} t
|
||||
where 1=1
|
||||
ORDER BY t.createTime DESC,t.id ) tt
|
||||
WHERE tt.ROWNUM <= #{pageNum}*#{pageSize}
|
||||
) rs
|
||||
WHERE rs.RN > #{pageNum-1}*#{pageSize}
|
||||
</select>
|
||||
-->
|
||||
|
||||
|
||||
</mapper>
|
||||
@ -1,49 +0,0 @@
|
||||
<?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.bl.infrastructure.mapper.BlTBasicMapper">
|
||||
|
||||
<select id="getTBasicListView" resultType="com.docus.server.record.common.pojo.dto.TBasicDTO">
|
||||
SELECT `update_time` as update_time ,`dept_code` as dept_code,`dept_name` as dept_name FROM `his_basic`
|
||||
WHERE update_time between #{startDate} and #{endDate}
|
||||
order by update_time asc
|
||||
LIMIT #{offset}, #{pageSize}
|
||||
</select>
|
||||
|
||||
|
||||
<!-- mysql
|
||||
<select id="list" resultType="com.docus.server.sys.common.pojo.dto.DeptDTO">
|
||||
SELECT `update_time` as update_time ,`dept_code` as dept_code,`dept_name` as dept_name FROM `his`.`his_dept`
|
||||
WHERE update_time between #{startDate} and #{endDate}
|
||||
order by update_time asc
|
||||
LIMIT (#{pageNum} - 1) * #{pageSize} , #{pageSize}
|
||||
</select>
|
||||
-->
|
||||
|
||||
|
||||
<!-- mssqsql
|
||||
<select id="list" resultType="com.docus.server.sys.common.pojo.dto.DeptDTO">
|
||||
select top pageSize `update_time` as update_time ,`dept_code` as dept_code,`dept_name` as dept_name
|
||||
from (select row_number()
|
||||
over(order by sno asc) as rownumber,*
|
||||
from student) temp_row
|
||||
where rownumber>((pageNum-1)*pageSize);
|
||||
</select>
|
||||
-->
|
||||
|
||||
<!-- oracle
|
||||
<select id="list" resultType="com.docus.server.sys.common.pojo.dto.DeptDTO">
|
||||
SELECT * FROM
|
||||
(SELECT tt.*,ROWNUM AS RN FROM
|
||||
(SELECT t.* FROM ${tableName} t
|
||||
where 1=1
|
||||
ORDER BY t.createTime DESC,t.id ) tt
|
||||
WHERE tt.ROWNUM <= #{pageNum}*#{pageSize}
|
||||
) rs
|
||||
WHERE rs.RN > #{pageNum-1}*#{pageSize}
|
||||
</select>
|
||||
-->
|
||||
|
||||
|
||||
</mapper>
|
||||
@ -1,49 +0,0 @@
|
||||
<?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.bl.infrastructure.mapper.BlUserMapper">
|
||||
|
||||
<select id="getUserListView" resultType="com.docus.server.sys.common.pojo.dto.UserDTO">
|
||||
SELECT `update_time` as update_time ,`dept_code` as dept_code,`dept_name` as dept_name FROM `his_user`
|
||||
WHERE update_time between #{startDate} and #{endDate}
|
||||
order by update_time asc
|
||||
LIMIT #{offset}, #{pageSize}
|
||||
</select>
|
||||
|
||||
|
||||
<!-- mysql
|
||||
<select id="list" resultType="com.docus.server.sys.common.pojo.dto.DeptDTO">
|
||||
SELECT `update_time` as update_time ,`dept_code` as dept_code,`dept_name` as dept_name FROM `his`.`his_dept`
|
||||
WHERE update_time between #{startDate} and #{endDate}
|
||||
order by update_time asc
|
||||
LIMIT (#{pageNum} - 1) * #{pageSize} , #{pageSize}
|
||||
</select>
|
||||
-->
|
||||
|
||||
|
||||
<!-- mssqsql
|
||||
<select id="list" resultType="com.docus.server.sys.common.pojo.dto.DeptDTO">
|
||||
select top pageSize `update_time` as update_time ,`dept_code` as dept_code,`dept_name` as dept_name
|
||||
from (select row_number()
|
||||
over(order by sno asc) as rownumber,*
|
||||
from student) temp_row
|
||||
where rownumber>((pageNum-1)*pageSize);
|
||||
</select>
|
||||
-->
|
||||
|
||||
<!-- oracle
|
||||
<select id="list" resultType="com.docus.server.sys.common.pojo.dto.DeptDTO">
|
||||
SELECT * FROM
|
||||
(SELECT tt.*,ROWNUM AS RN FROM
|
||||
(SELECT t.* FROM ${tableName} t
|
||||
where 1=1
|
||||
ORDER BY t.createTime DESC,t.id ) tt
|
||||
WHERE tt.ROWNUM <= #{pageNum}*#{pageSize}
|
||||
) rs
|
||||
WHERE rs.RN > #{pageNum-1}*#{pageSize}
|
||||
</select>
|
||||
-->
|
||||
|
||||
|
||||
</mapper>
|
||||
@ -0,0 +1,4 @@
|
||||
package com.docus.server.record.common;
|
||||
|
||||
public class A {
|
||||
}
|
||||
@ -0,0 +1,4 @@
|
||||
package com.docus.server.sys.common;
|
||||
|
||||
public class A {
|
||||
}
|
||||
@ -0,0 +1,4 @@
|
||||
package com.docus.server.bl.common;
|
||||
|
||||
public class A {
|
||||
}
|
||||
@ -0,0 +1,4 @@
|
||||
package com.docus.server.ecg.common;
|
||||
|
||||
public class A {
|
||||
}
|
||||
@ -0,0 +1,4 @@
|
||||
package com.docus.server.his.common;
|
||||
|
||||
public class A {
|
||||
}
|
||||
@ -0,0 +1,4 @@
|
||||
package com.docus.server.hl.common;
|
||||
|
||||
public class A {
|
||||
}
|
||||
@ -0,0 +1,4 @@
|
||||
package com.docus.server.issubmit.common;
|
||||
|
||||
public class A {
|
||||
}
|
||||
@ -0,0 +1,4 @@
|
||||
package com.docus.server.lis.common;
|
||||
|
||||
public class A {
|
||||
}
|
||||
@ -0,0 +1,4 @@
|
||||
package com.docus.server.pacs.common;
|
||||
|
||||
public class A {
|
||||
}
|
||||
@ -0,0 +1,4 @@
|
||||
package com.docus.server.vte.common;
|
||||
|
||||
public class A {
|
||||
}
|
||||
@ -0,0 +1,4 @@
|
||||
package com.docus.server.zz.common;
|
||||
|
||||
public class A {
|
||||
}
|
||||
@ -1,16 +0,0 @@
|
||||
package com.docus.server.common.db;
|
||||
|
||||
import com.baomidou.mybatisplus.core.incrementer.IKeyGenerator;
|
||||
|
||||
import java.util.UUID;
|
||||
|
||||
public class KeyGenerator implements IKeyGenerator {
|
||||
public static String genId() {
|
||||
return UUID.randomUUID().toString().replace("-", "").toUpperCase();
|
||||
}
|
||||
|
||||
@Override
|
||||
public String executeSql(String incrementerName) {
|
||||
return genId();
|
||||
}
|
||||
}
|
||||
@ -1,91 +0,0 @@
|
||||
package com.docus.server.common.db.type.handler;
|
||||
|
||||
import org.apache.ibatis.type.BaseTypeHandler;
|
||||
import org.apache.ibatis.type.JdbcType;
|
||||
import org.apache.ibatis.type.MappedTypes;
|
||||
|
||||
import java.sql.*;
|
||||
import java.time.LocalDateTime;
|
||||
|
||||
//用于兼容gbase localdatetime 转换
|
||||
@MappedTypes(value = LocalDateTime.class)
|
||||
public class LocalDateTimeTypeHandler extends BaseTypeHandler<LocalDateTime> {
|
||||
|
||||
//驱动是否原生支持
|
||||
private Boolean isJdbcSupport;
|
||||
|
||||
private boolean getIsJdbcSupport(ResultSet rs, String columnName) {
|
||||
if (isJdbcSupport == null) {
|
||||
try {
|
||||
rs.getObject(columnName, LocalDateTime.class);
|
||||
isJdbcSupport = true;
|
||||
} catch (Exception e) {
|
||||
isJdbcSupport = false;
|
||||
}
|
||||
}
|
||||
return isJdbcSupport;
|
||||
}
|
||||
|
||||
private boolean getIsJdbcSupport(CallableStatement cs, int columnIndex) {
|
||||
if (isJdbcSupport == null) {
|
||||
try {
|
||||
cs.getObject(columnIndex, LocalDateTime.class);
|
||||
isJdbcSupport = true;
|
||||
} catch (Exception e) {
|
||||
isJdbcSupport = false;
|
||||
}
|
||||
}
|
||||
return isJdbcSupport;
|
||||
}
|
||||
|
||||
private boolean getIsJdbcSupport(ResultSet rs, int columnIndex) {
|
||||
if (isJdbcSupport == null) {
|
||||
try {
|
||||
rs.getObject(columnIndex, LocalDateTime.class);
|
||||
isJdbcSupport = true;
|
||||
} catch (Exception e) {
|
||||
isJdbcSupport = false;
|
||||
}
|
||||
}
|
||||
return isJdbcSupport;
|
||||
}
|
||||
|
||||
@Override
|
||||
public void setNonNullParameter(PreparedStatement ps, int i, LocalDateTime localDateTime, JdbcType jdbcType) throws SQLException {
|
||||
if (isJdbcSupport != null && isJdbcSupport) {
|
||||
ps.setObject(i, localDateTime);
|
||||
} else {
|
||||
ps.setObject(i, Timestamp.valueOf(localDateTime));
|
||||
}
|
||||
}
|
||||
|
||||
@Override
|
||||
public LocalDateTime getNullableResult(ResultSet resultSet, String columnName) throws SQLException {
|
||||
if (getIsJdbcSupport(resultSet, columnName)) {
|
||||
return resultSet.getObject(columnName, LocalDateTime.class);
|
||||
} else {
|
||||
Timestamp timestamp = resultSet.getTimestamp(columnName);
|
||||
return timestamp == null ? null : timestamp.toLocalDateTime();
|
||||
}
|
||||
}
|
||||
|
||||
@Override
|
||||
public LocalDateTime getNullableResult(ResultSet resultSet, int columnIndex) throws SQLException {
|
||||
if (getIsJdbcSupport(resultSet, columnIndex)) {
|
||||
return resultSet.getObject(columnIndex, LocalDateTime.class);
|
||||
} else {
|
||||
Timestamp timestamp = resultSet.getTimestamp(columnIndex);
|
||||
return timestamp == null ? null : timestamp.toLocalDateTime();
|
||||
}
|
||||
}
|
||||
|
||||
@Override
|
||||
public LocalDateTime getNullableResult(CallableStatement callableStatement, int columnIndex) throws SQLException {
|
||||
if (getIsJdbcSupport(callableStatement, columnIndex)) {
|
||||
return callableStatement.getObject(columnIndex, LocalDateTime.class);
|
||||
} else {
|
||||
Timestamp timestamp = callableStatement.getTimestamp(columnIndex);
|
||||
return timestamp == null ? null : timestamp.toLocalDateTime();
|
||||
}
|
||||
}
|
||||
}
|
||||
@ -1,91 +0,0 @@
|
||||
package com.docus.server.common.db.type.handler;
|
||||
|
||||
import org.apache.ibatis.type.BaseTypeHandler;
|
||||
import org.apache.ibatis.type.JdbcType;
|
||||
import org.apache.ibatis.type.MappedTypes;
|
||||
|
||||
import java.sql.*;
|
||||
import java.time.LocalDate;
|
||||
|
||||
//用于兼容gbase LocalDate 转换
|
||||
@MappedTypes(value = LocalDate.class)
|
||||
public class LocalDateTypeHandler extends BaseTypeHandler<LocalDate> {
|
||||
|
||||
//驱动是否原生支持
|
||||
private Boolean isJdbcSupport;
|
||||
|
||||
private boolean getIsJdbcSupport(ResultSet rs, String columnName) {
|
||||
if (isJdbcSupport == null) {
|
||||
try {
|
||||
rs.getObject(columnName, LocalDate.class);
|
||||
isJdbcSupport = true;
|
||||
} catch (Exception e) {
|
||||
isJdbcSupport = false;
|
||||
}
|
||||
}
|
||||
return isJdbcSupport;
|
||||
}
|
||||
|
||||
private boolean getIsJdbcSupport(CallableStatement cs, int columnIndex) {
|
||||
if (isJdbcSupport == null) {
|
||||
try {
|
||||
cs.getObject(columnIndex, LocalDate.class);
|
||||
isJdbcSupport = true;
|
||||
} catch (Exception e) {
|
||||
isJdbcSupport = false;
|
||||
}
|
||||
}
|
||||
return isJdbcSupport;
|
||||
}
|
||||
|
||||
private boolean getIsJdbcSupport(ResultSet rs, int columnIndex) {
|
||||
if (isJdbcSupport == null) {
|
||||
try {
|
||||
rs.getObject(columnIndex, LocalDate.class);
|
||||
isJdbcSupport = true;
|
||||
} catch (Exception e) {
|
||||
isJdbcSupport = false;
|
||||
}
|
||||
}
|
||||
return isJdbcSupport;
|
||||
}
|
||||
|
||||
@Override
|
||||
public void setNonNullParameter(PreparedStatement ps, int i, LocalDate localDate, JdbcType jdbcType) throws SQLException {
|
||||
if (isJdbcSupport != null && isJdbcSupport) {
|
||||
ps.setObject(i, localDate);
|
||||
} else {
|
||||
ps.setObject(i, Date.valueOf(localDate));
|
||||
}
|
||||
}
|
||||
|
||||
@Override
|
||||
public LocalDate getNullableResult(ResultSet resultSet, String columnName) throws SQLException {
|
||||
if (getIsJdbcSupport(resultSet, columnName)) {
|
||||
return resultSet.getObject(columnName, LocalDate.class);
|
||||
} else {
|
||||
Date date = resultSet.getDate(columnName);
|
||||
return date == null ? null : date.toLocalDate();
|
||||
}
|
||||
}
|
||||
|
||||
@Override
|
||||
public LocalDate getNullableResult(ResultSet resultSet, int columnIndex) throws SQLException {
|
||||
if (getIsJdbcSupport(resultSet, columnIndex)) {
|
||||
return resultSet.getObject(columnIndex, LocalDate.class);
|
||||
} else {
|
||||
Date date = resultSet.getDate(columnIndex);
|
||||
return date == null ? null : date.toLocalDate();
|
||||
}
|
||||
}
|
||||
|
||||
@Override
|
||||
public LocalDate getNullableResult(CallableStatement callableStatement, int columnIndex) throws SQLException {
|
||||
if (getIsJdbcSupport(callableStatement, columnIndex)) {
|
||||
return callableStatement.getObject(columnIndex, LocalDate.class);
|
||||
} else {
|
||||
Date date = callableStatement.getDate(columnIndex);
|
||||
return date == null ? null : date.toLocalDate();
|
||||
}
|
||||
}
|
||||
}
|
||||
@ -1,91 +0,0 @@
|
||||
package com.docus.server.common.db.type.handler;
|
||||
|
||||
import org.apache.ibatis.type.BaseTypeHandler;
|
||||
import org.apache.ibatis.type.JdbcType;
|
||||
import org.apache.ibatis.type.MappedTypes;
|
||||
|
||||
import java.sql.*;
|
||||
import java.time.LocalTime;
|
||||
|
||||
//用于兼容gbase LocalTime 转换
|
||||
@MappedTypes(value = LocalTime.class)
|
||||
public class LocalTimeTypeHandler extends BaseTypeHandler<LocalTime> {
|
||||
|
||||
//驱动是否原生支持
|
||||
private Boolean isJdbcSupport;
|
||||
|
||||
private boolean getIsJdbcSupport(ResultSet rs, String columnName) {
|
||||
if (isJdbcSupport == null) {
|
||||
try {
|
||||
rs.getObject(columnName, LocalTime.class);
|
||||
isJdbcSupport = true;
|
||||
} catch (Exception e) {
|
||||
isJdbcSupport = false;
|
||||
}
|
||||
}
|
||||
return isJdbcSupport;
|
||||
}
|
||||
|
||||
private boolean getIsJdbcSupport(CallableStatement cs, int columnIndex) {
|
||||
if (isJdbcSupport == null) {
|
||||
try {
|
||||
cs.getObject(columnIndex, LocalTime.class);
|
||||
isJdbcSupport = true;
|
||||
} catch (Exception e) {
|
||||
isJdbcSupport = false;
|
||||
}
|
||||
}
|
||||
return isJdbcSupport;
|
||||
}
|
||||
|
||||
private boolean getIsJdbcSupport(ResultSet rs, int columnIndex) {
|
||||
if (isJdbcSupport == null) {
|
||||
try {
|
||||
rs.getObject(columnIndex, LocalTime.class);
|
||||
isJdbcSupport = true;
|
||||
} catch (Exception e) {
|
||||
isJdbcSupport = false;
|
||||
}
|
||||
}
|
||||
return isJdbcSupport;
|
||||
}
|
||||
|
||||
@Override
|
||||
public void setNonNullParameter(PreparedStatement ps, int i, LocalTime LocalTime, JdbcType jdbcType) throws SQLException {
|
||||
if (isJdbcSupport != null && isJdbcSupport) {
|
||||
ps.setObject(i, LocalTime);
|
||||
} else {
|
||||
ps.setObject(i, Time.valueOf(LocalTime));
|
||||
}
|
||||
}
|
||||
|
||||
@Override
|
||||
public LocalTime getNullableResult(ResultSet resultSet, String columnName) throws SQLException {
|
||||
if (getIsJdbcSupport(resultSet, columnName)) {
|
||||
return resultSet.getObject(columnName, LocalTime.class);
|
||||
} else {
|
||||
Time time = resultSet.getTime(columnName);
|
||||
return time == null ? null : time.toLocalTime();
|
||||
}
|
||||
}
|
||||
|
||||
@Override
|
||||
public LocalTime getNullableResult(ResultSet resultSet, int columnIndex) throws SQLException {
|
||||
if (getIsJdbcSupport(resultSet, columnIndex)) {
|
||||
return resultSet.getObject(columnIndex, LocalTime.class);
|
||||
} else {
|
||||
Time time = resultSet.getTime(columnIndex);
|
||||
return time == null ? null : time.toLocalTime();
|
||||
}
|
||||
}
|
||||
|
||||
@Override
|
||||
public LocalTime getNullableResult(CallableStatement callableStatement, int columnIndex) throws SQLException {
|
||||
if (getIsJdbcSupport(callableStatement, columnIndex)) {
|
||||
return callableStatement.getObject(columnIndex, LocalTime.class);
|
||||
} else {
|
||||
Time time = callableStatement.getTime(columnIndex);
|
||||
return time == null ? null : time.toLocalTime();
|
||||
}
|
||||
}
|
||||
}
|
||||
@ -1,31 +0,0 @@
|
||||
package com.docus.server.common.enums;
|
||||
|
||||
public class EnumItemView {
|
||||
|
||||
private Integer value;
|
||||
private String display;
|
||||
|
||||
public EnumItemView() {
|
||||
}
|
||||
|
||||
public EnumItemView(Integer value, String display) {
|
||||
this.value = value;
|
||||
this.display = display;
|
||||
}
|
||||
|
||||
public Integer getValue() {
|
||||
return value;
|
||||
}
|
||||
|
||||
public void setValue(Integer value) {
|
||||
this.value = value;
|
||||
}
|
||||
|
||||
public String getDisplay() {
|
||||
return display;
|
||||
}
|
||||
|
||||
public void setDisplay(String display) {
|
||||
this.display = display;
|
||||
}
|
||||
}
|
||||
@ -1,49 +0,0 @@
|
||||
package com.docus.server.common.enums;
|
||||
|
||||
import org.apache.ibatis.type.BaseTypeHandler;
|
||||
import org.apache.ibatis.type.EnumTypeHandler;
|
||||
import org.apache.ibatis.type.JdbcType;
|
||||
|
||||
import java.sql.CallableStatement;
|
||||
import java.sql.PreparedStatement;
|
||||
import java.sql.ResultSet;
|
||||
import java.sql.SQLException;
|
||||
|
||||
//mybatis枚举类型分发
|
||||
public class EnumTypeHandlerDispatch<E extends Enum<E>> extends BaseTypeHandler<E> {
|
||||
private BaseTypeHandler<E> typeHandler;
|
||||
|
||||
public EnumTypeHandlerDispatch(Class<E> type) {
|
||||
if (type == null) {
|
||||
throw new IllegalArgumentException("Type argument. cannot be nu11");
|
||||
}
|
||||
if (IIntegerEnum.class.isAssignableFrom(type)) {
|
||||
//如果实现了IIntegerEnum,使用自定义的转换器
|
||||
typeHandler = new IntegerEnumHandler(type);
|
||||
} else {
|
||||
//默认转换器
|
||||
typeHandler = new EnumTypeHandler<>(type);
|
||||
}
|
||||
}
|
||||
|
||||
@Override
|
||||
public void setNonNullParameter(PreparedStatement ps, int i, E parameter, JdbcType jdbcType) throws
|
||||
SQLException {
|
||||
typeHandler.setNonNullParameter(ps, i, parameter, jdbcType);
|
||||
}
|
||||
|
||||
@Override
|
||||
public E getNullableResult(ResultSet rs, String columnName) throws SQLException {
|
||||
return typeHandler.getNullableResult(rs, columnName);
|
||||
}
|
||||
|
||||
@Override
|
||||
public E getNullableResult(ResultSet rs, int columnIndex) throws SQLException {
|
||||
return typeHandler.getNullableResult(rs, columnIndex);
|
||||
}
|
||||
|
||||
@Override
|
||||
public E getNullableResult(CallableStatement cs, int columnIndex) throws SQLException {
|
||||
return typeHandler.getNullableResult(cs, columnIndex);
|
||||
}
|
||||
}
|
||||
@ -1,31 +0,0 @@
|
||||
package com.docus.server.common.enums;
|
||||
|
||||
import com.baomidou.mybatisplus.annotation.IEnum;
|
||||
|
||||
import java.util.Objects;
|
||||
|
||||
public interface IIntegerEnum extends IEnum {
|
||||
|
||||
@Override
|
||||
Integer getValue();
|
||||
|
||||
String getDisplay();
|
||||
|
||||
static <T extends IIntegerEnum> T fromValue(Class<T> enumType, Integer value) {
|
||||
for (T object : enumType.getEnumConstants()) {
|
||||
if (Objects.equals(value, object.getValue())) {
|
||||
return object;
|
||||
}
|
||||
}
|
||||
throw new IllegalArgumentException("No. enum value 。" + value + "of " + enumType.getCanonicalName());
|
||||
}
|
||||
|
||||
static <T extends IIntegerEnum> T fromDisplay(Class<T> enumType, String display) {
|
||||
for (T object : enumType.getEnumConstants()) {
|
||||
if (Objects.equals(display, object.getDisplay())) {
|
||||
return object;
|
||||
}
|
||||
}
|
||||
throw new IllegalArgumentException("No. enum value 。" + display + "of " + enumType.getCanonicalName());
|
||||
}
|
||||
}
|
||||
@ -1,48 +0,0 @@
|
||||
package com.docus.server.common.enums;
|
||||
|
||||
import org.apache.ibatis.type.BaseTypeHandler;
|
||||
import org.apache.ibatis.type.JdbcType;
|
||||
|
||||
import java.sql.CallableStatement;
|
||||
import java.sql.PreparedStatement;
|
||||
import java.sql.ResultSet;
|
||||
import java.sql.SQLException;
|
||||
|
||||
//mybatis枚举类型转换
|
||||
public class IntegerEnumHandler<E extends IIntegerEnum> extends BaseTypeHandler<E> {
|
||||
private final Class<E> type;
|
||||
|
||||
public IntegerEnumHandler(Class<E> type) {
|
||||
if (type == null) {
|
||||
throw new IllegalArgumentException("Type argument. cannot. be nu11");
|
||||
}
|
||||
this.type = type;
|
||||
}
|
||||
|
||||
@Override
|
||||
public void setNonNullParameter(PreparedStatement ps, int i, E parameter, JdbcType jdbcType) throws SQLException {
|
||||
if (jdbcType == null) {
|
||||
ps.setInt(i, parameter.getValue());
|
||||
} else {
|
||||
ps.setObject(i, parameter.getValue(), jdbcType.TYPE_CODE); //1 / see r3589
|
||||
}
|
||||
}
|
||||
|
||||
@Override
|
||||
public E getNullableResult(ResultSet rs, String columnName) throws SQLException {
|
||||
String s = rs.getString(columnName);
|
||||
return s == null ? null : IIntegerEnum.fromValue(type, Integer.parseInt(s));
|
||||
}
|
||||
|
||||
@Override
|
||||
public E getNullableResult(ResultSet rs, int columnIndex) throws SQLException {
|
||||
String s = rs.getString(columnIndex);
|
||||
return s == null ? null : IIntegerEnum.fromValue(type, Integer.parseInt(s));
|
||||
}
|
||||
|
||||
@Override
|
||||
public E getNullableResult(CallableStatement cs, int columnIndex) throws SQLException {
|
||||
String s = cs.getString(columnIndex);
|
||||
return s == null ? null : IIntegerEnum.fromValue(type, Integer.parseInt(s));
|
||||
}
|
||||
}
|
||||
@ -1,46 +0,0 @@
|
||||
package com.docus.server.common.service;
|
||||
|
||||
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
||||
import com.baomidou.mybatisplus.extension.service.IService;
|
||||
import com.docus.server.common.service.impl.Sort;
|
||||
|
||||
import java.io.Serializable;
|
||||
import java.util.Collection;
|
||||
import java.util.List;
|
||||
|
||||
public interface IBaseService<T> extends IService<T> {
|
||||
|
||||
T findById(Serializable id);
|
||||
|
||||
List<T> findByIds(Collection<Serializable> ids);
|
||||
|
||||
List<T> findBy(String propertyName, Object propertyValue);
|
||||
|
||||
List<T> findByList(String propertyName, Collection<?> propertyValue);
|
||||
|
||||
List<T> findActiveBy(String propertyName, Object propertyValue);
|
||||
|
||||
List<T> findBy(String propertyName, Object propertyValue, Sort sort);
|
||||
|
||||
List<T> findActiveBy(String propertyName, Object propertyValue, Sort sort);
|
||||
|
||||
T findOneBy(String propertyName, Object propertyValue);
|
||||
|
||||
T findOneByList(String propertyName, Collection<?> propertyValue);
|
||||
|
||||
T findActiveOneBy(String propertyName, Object propertyValue);
|
||||
|
||||
List<T> find(LambdaQueryWrapper<T> queryWrapper);
|
||||
|
||||
T findOne(LambdaQueryWrapper<T> queryWrapper);
|
||||
|
||||
List<T> findAll();
|
||||
|
||||
List<T> findAllActive();
|
||||
|
||||
List<T> findAll(Sort sort);
|
||||
|
||||
List<T> findAllActive(Sort sort);
|
||||
|
||||
int deleteByIdList(List<Serializable> idList);
|
||||
}
|
||||
@ -1,62 +0,0 @@
|
||||
package com.docus.server.common.service.impl;
|
||||
|
||||
import java.util.ArrayList;
|
||||
import java.util.Collections;
|
||||
import java.util.List;
|
||||
|
||||
//排序定义
|
||||
public class Sort {
|
||||
private List<SortItem> sortByProperties = new ArrayList<>();
|
||||
|
||||
// 隐藏构造函数
|
||||
private Sort() {
|
||||
}
|
||||
|
||||
public static Sort byAsc(String property) {
|
||||
return new Sort().thenByAsc(property);
|
||||
}
|
||||
|
||||
public static Sort byDesc(String property) {
|
||||
return new Sort().thenByDesc(property);
|
||||
}
|
||||
|
||||
public Sort thenByAsc(String property) {
|
||||
sortByProperties.add(new SortItem(property, Direction.ASC));
|
||||
|
||||
return this;
|
||||
}
|
||||
|
||||
public Sort thenByDesc(String property) {
|
||||
sortByProperties.add(new SortItem(property, Direction.DESC));
|
||||
return this;
|
||||
}
|
||||
|
||||
|
||||
public List<SortItem> getSortList() {
|
||||
//复制、只读
|
||||
List<SortItem> copyList = new ArrayList<>(sortByProperties);
|
||||
return Collections.unmodifiableList(copyList);
|
||||
}
|
||||
|
||||
public class SortItem {
|
||||
private String property;
|
||||
private Direction direction;
|
||||
|
||||
private SortItem(String property, Direction direction) {
|
||||
this.property = property;
|
||||
this.direction = direction;
|
||||
}
|
||||
|
||||
public String getProperty() {
|
||||
return property;
|
||||
}
|
||||
|
||||
public Direction getDirection() {
|
||||
return direction;
|
||||
}
|
||||
}
|
||||
|
||||
public enum Direction {
|
||||
ASC, DESC;
|
||||
}
|
||||
}
|
||||
@ -1,34 +0,0 @@
|
||||
package com.docus.server.common.util;
|
||||
|
||||
import java.util.HashMap;
|
||||
import java.util.Map;
|
||||
|
||||
public final class ParamsUtils {
|
||||
|
||||
public static Param addParam(String key, Object obj) {
|
||||
return new Param(key, obj);
|
||||
}
|
||||
|
||||
public Map<String, Object> param(String key, Object obj) {
|
||||
return new Param(key, obj).param();
|
||||
}
|
||||
|
||||
public static final class Param {
|
||||
|
||||
private Map<String, Object> params = new HashMap<String, Object>();
|
||||
|
||||
|
||||
public Param(String key, Object value) {
|
||||
addParam(key, value);
|
||||
}
|
||||
|
||||
public Param addParam(String key, Object value) {
|
||||
this.params.put(key, value);
|
||||
return this;
|
||||
}
|
||||
|
||||
public Map<String, Object> param() {
|
||||
return this.params;
|
||||
}
|
||||
}
|
||||
}
|
||||
@ -1,35 +0,0 @@
|
||||
<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/maven-v4_0_0.xsd">
|
||||
<parent>
|
||||
<artifactId>docus-collector-server</artifactId>
|
||||
<groupId>com.docus</groupId>
|
||||
<version>1.0-SNAPSHOT</version>
|
||||
</parent>
|
||||
<modelVersion>4.0.0</modelVersion>
|
||||
<artifactId>docus-archivefile</artifactId>
|
||||
<name>Archetype - docus-archivefile</name>
|
||||
<url>http://maven.apache.org</url>
|
||||
|
||||
<dependencies>
|
||||
<dependency>
|
||||
<groupId>com.docus</groupId>
|
||||
<artifactId>docus-api-common</artifactId>
|
||||
<version>1.0-SNAPSHOT</version>
|
||||
<scope>compile</scope>
|
||||
</dependency>
|
||||
</dependencies>
|
||||
|
||||
<build>
|
||||
<resources>
|
||||
<resource>
|
||||
<directory>src/main/java</directory>
|
||||
<includes>
|
||||
<include>**/*.xml</include>
|
||||
</includes>
|
||||
</resource>
|
||||
<resource>
|
||||
<directory>src/main/resources</directory>
|
||||
</resource>
|
||||
</resources>
|
||||
</build>
|
||||
</project>
|
||||
@ -1,5 +0,0 @@
|
||||
package com.docus.server.record.controller;
|
||||
|
||||
public class Package {
|
||||
|
||||
}
|
||||
@ -1,4 +0,0 @@
|
||||
package com.docus.server.record.controller.param;
|
||||
|
||||
public class Package {
|
||||
}
|
||||
@ -1,4 +0,0 @@
|
||||
package com.docus.server.record.controller.vo;
|
||||
|
||||
public class Package {
|
||||
}
|
||||
@ -1,9 +0,0 @@
|
||||
package com.docus.server.archivefile.mapper;
|
||||
|
||||
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
|
||||
import com.docus.server.archivefile.pojo.entity.CollectsysDictionary;
|
||||
import org.apache.ibatis.annotations.Mapper;
|
||||
|
||||
@Mapper
|
||||
public interface AfCollectSysDictionaryMapper extends BaseMapper<CollectsysDictionary> {
|
||||
}
|
||||
@ -1,31 +0,0 @@
|
||||
package com.docus.server.archivefile.mapper;
|
||||
|
||||
import com.docus.server.archivefile.pojo.entity.AfCollectTask;
|
||||
import org.apache.ibatis.annotations.Mapper;
|
||||
import org.apache.ibatis.annotations.Param;
|
||||
|
||||
/**
|
||||
* 任务采集表mapper
|
||||
*
|
||||
* @author wyb
|
||||
*/
|
||||
@Mapper
|
||||
public interface AfCollectTaskMapper {
|
||||
|
||||
|
||||
/**
|
||||
* 保存任务
|
||||
*
|
||||
* @param afCollectTask 采集任务
|
||||
* @return 数据库操作结果
|
||||
*/
|
||||
int saveTask(@Param("task") AfCollectTask afCollectTask);
|
||||
|
||||
/**
|
||||
* 根据任务主键查询任务
|
||||
*
|
||||
* @param taskId 任务主键
|
||||
* @return 任务信息
|
||||
*/
|
||||
AfCollectTask getTaskById(@Param("id") Long taskId);
|
||||
}
|
||||
@ -1,34 +0,0 @@
|
||||
package com.docus.server.archivefile.mapper;
|
||||
|
||||
import com.docus.server.archivefile.pojo.entity.AfJobTime;
|
||||
import org.apache.ibatis.annotations.Mapper;
|
||||
import org.apache.ibatis.annotations.Param;
|
||||
|
||||
|
||||
/**
|
||||
* job 记录时间
|
||||
* @author wyb
|
||||
*/
|
||||
@Mapper
|
||||
public interface AfJobTimeMapper {
|
||||
/**
|
||||
* 根据任务类型查询任务时间记录
|
||||
* @param jobType 任务类型
|
||||
* @return 任务时间记录
|
||||
*/
|
||||
AfJobTime getAfJobTimeByJobType(@Param("jobType") String jobType);
|
||||
|
||||
/**
|
||||
* 插入job时间参数
|
||||
* @param afJobTime job时间参数
|
||||
* @return 数据库操作结果
|
||||
*/
|
||||
int insert(@Param("afJobTime") AfJobTime afJobTime);
|
||||
|
||||
/**
|
||||
* 修改job时间
|
||||
* @param afJobTime job时间
|
||||
* @return 数据库操作结果
|
||||
*/
|
||||
int updateById(@Param("afJobTime") AfJobTime afJobTime);
|
||||
}
|
||||
@ -1,15 +0,0 @@
|
||||
package com.docus.server.archivefile.mapper;
|
||||
|
||||
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
|
||||
import com.docus.server.archivefile.pojo.entity.AfViewCollectionLog;
|
||||
import org.apache.ibatis.annotations.Mapper;
|
||||
|
||||
/**
|
||||
* @author linrf
|
||||
* @date 2023/6/13 17:05
|
||||
*/
|
||||
@Mapper
|
||||
public interface AfViewCollectionLogMapper extends BaseMapper<AfViewCollectionLog> {
|
||||
|
||||
|
||||
}
|
||||
@ -1,13 +0,0 @@
|
||||
package com.docus.server.record.common.pojo.dto;
|
||||
|
||||
public enum IdType {
|
||||
/**
|
||||
* 记账号
|
||||
*/
|
||||
JZH,
|
||||
|
||||
/**
|
||||
* 病案号
|
||||
*/
|
||||
INPATIENT_NO
|
||||
}
|
||||
@ -1,30 +0,0 @@
|
||||
package com.docus.server.record.common.pojo.dto;
|
||||
|
||||
import com.docus.infrastructure.core.exception.BaseException;
|
||||
import com.docus.server.record.RecordExceptionEnum;
|
||||
|
||||
/**
|
||||
* 住院号
|
||||
*/
|
||||
public class InpatientNo {
|
||||
|
||||
|
||||
private String inpatientNo;
|
||||
|
||||
public InpatientNo(String inpatientNo) {
|
||||
this.inpatientNo = inpatientNo;
|
||||
this.vaid();
|
||||
}
|
||||
|
||||
|
||||
public void vaid() {
|
||||
if (inpatientNo == null) {
|
||||
throw new BaseException(RecordExceptionEnum.NOT_NULL, "inpatientNo不能为空");
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
public static InpatientNo of(String inpatientNo) {
|
||||
return new InpatientNo(inpatientNo);
|
||||
}
|
||||
}
|
||||
@ -1,30 +0,0 @@
|
||||
package com.docus.server.archivefile.pojo.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;
|
||||
}
|
||||
@ -1,72 +0,0 @@
|
||||
package com.docus.server.archivefile.pojo.dto;
|
||||
|
||||
import io.swagger.annotations.ApiModelProperty;
|
||||
import lombok.Data;
|
||||
|
||||
import java.util.Map;
|
||||
|
||||
/**
|
||||
* @BelongsProject: docus-webservice-sdry
|
||||
* @BelongsPackage: com.docus.server.collection.webservice
|
||||
* @Author: chierhao
|
||||
* @CreateTime: 2023-02-25 14:44
|
||||
* @Description: TODO
|
||||
* @Version: 1.0
|
||||
*/
|
||||
@Data
|
||||
public class TBasicDTO {
|
||||
// ---------------------- TBasicDTO info ----------------------
|
||||
@ApiModelProperty(value = "记账号")
|
||||
private String jzh;
|
||||
@ApiModelProperty(value = "病案号")
|
||||
private String inpatientNo;
|
||||
@ApiModelProperty(value = "住院次数")
|
||||
private String admissTimes;
|
||||
@ApiModelProperty(value = "患者姓名")
|
||||
private String name;
|
||||
@ApiModelProperty(value = "住院日期")
|
||||
private String admissDate;
|
||||
@ApiModelProperty(value = "出院日期")
|
||||
private String disDate;
|
||||
@ApiModelProperty(value = "住院科室名称")
|
||||
private String admissDeptName;
|
||||
@ApiModelProperty(value = "出院科室名称")
|
||||
private String disDeptName;
|
||||
@ApiModelProperty(value = "主管医生")
|
||||
private String attending;
|
||||
@ApiModelProperty(value = "主管医生名称")
|
||||
private String attendingName;
|
||||
@ApiModelProperty(value = "责任护士")
|
||||
private String dutyNurse;
|
||||
@ApiModelProperty(value = "住院科室")
|
||||
private String admissDept;
|
||||
@ApiModelProperty(value = "年龄_岁")
|
||||
private String age;
|
||||
@ApiModelProperty(value = "性别")
|
||||
private String sex;
|
||||
@ApiModelProperty(value = "身份证")
|
||||
private String idCard;
|
||||
@ApiModelProperty(value = "出院科室")
|
||||
private String disDept;
|
||||
@ApiModelProperty(value = "性别名称")
|
||||
private String sexName;
|
||||
@ApiModelProperty(value = "床位号")
|
||||
private String bedNum;
|
||||
@ApiModelProperty(value = "是否死亡")
|
||||
private String isDead;
|
||||
@ApiModelProperty(value = "实际住院天数")
|
||||
private String admissDays;
|
||||
// ---------------------- xml info ----------------------
|
||||
private String serialId;
|
||||
private String receive;
|
||||
private String send;
|
||||
// ---------------------- sdry info ----------------------
|
||||
private String wardCode;
|
||||
private String wardName;
|
||||
private String sdryIndex;
|
||||
|
||||
/**
|
||||
* 拓展参数
|
||||
*/
|
||||
private Map<String, Object> params;
|
||||
}
|
||||
@ -1,42 +0,0 @@
|
||||
package com.docus.server.archivefile.pojo.entity;
|
||||
|
||||
import io.swagger.annotations.ApiModel;
|
||||
import io.swagger.annotations.ApiModelProperty;
|
||||
import lombok.Data;
|
||||
import lombok.EqualsAndHashCode;
|
||||
|
||||
import java.io.Serializable;
|
||||
|
||||
/**
|
||||
* <p>
|
||||
*
|
||||
* </p>
|
||||
*
|
||||
* @author 曾文和
|
||||
* @since 2021-05-08
|
||||
*/
|
||||
@Data
|
||||
@EqualsAndHashCode(callSuper = false)
|
||||
@ApiModel(value="AfJobTime对象", description="")
|
||||
public class AfJobTime implements Serializable {
|
||||
|
||||
private static final long serialVersionUID = 1L;
|
||||
|
||||
@ApiModelProperty(value = "主键id")
|
||||
private Long id;
|
||||
|
||||
@ApiModelProperty(value = "最新刷新时间 格式 yyyy-MM-dd HH:mm:ss")
|
||||
private String updateTime;
|
||||
|
||||
@ApiModelProperty(value = "调度类型。")
|
||||
private String jobType;
|
||||
|
||||
public AfJobTime() {
|
||||
}
|
||||
|
||||
public AfJobTime(Long id, String updateTime, String jobType) {
|
||||
this.id = id;
|
||||
this.updateTime = updateTime;
|
||||
this.jobType = jobType;
|
||||
}
|
||||
}
|
||||
@ -1,51 +0,0 @@
|
||||
package com.docus.server.archivefile.pojo.entity;
|
||||
|
||||
import cn.hutool.core.bean.BeanUtil;
|
||||
import cn.hutool.core.bean.copier.CopyOptions;
|
||||
import com.baomidou.mybatisplus.annotation.TableField;
|
||||
import com.baomidou.mybatisplus.annotation.TableId;
|
||||
import com.baomidou.mybatisplus.annotation.TableName;
|
||||
import io.swagger.annotations.ApiModelProperty;
|
||||
import lombok.Data;
|
||||
|
||||
import java.io.Serializable;
|
||||
import java.util.Date;
|
||||
|
||||
/**
|
||||
* @author zengdl
|
||||
* @website https://el-admin.vip
|
||||
* @description /
|
||||
* @date 2022-03-28
|
||||
**/
|
||||
@Data
|
||||
@TableName("af_view_collection_log")
|
||||
public class AfViewCollectionLog implements Serializable {
|
||||
|
||||
@TableId("id")
|
||||
@ApiModelProperty(value = "id")
|
||||
private Long id;
|
||||
|
||||
@TableField("jzh")
|
||||
@ApiModelProperty(value = "记帐号")
|
||||
private String jzh;
|
||||
|
||||
@TableField("sys_code")
|
||||
@ApiModelProperty(value = "采集器分类")
|
||||
private String sysCode;
|
||||
|
||||
@TableField("file_id")
|
||||
@ApiModelProperty(value = "文件id")
|
||||
private String fileId;
|
||||
|
||||
@TableField("file_modify_time")
|
||||
@ApiModelProperty(value = "文件最后修改时间")
|
||||
private String fileModifyTime;
|
||||
|
||||
@TableField("create_time")
|
||||
@ApiModelProperty(value = "创建时间")
|
||||
private Date createTime;
|
||||
|
||||
public void copy(AfViewCollectionLog source) {
|
||||
BeanUtil.copyProperties(source, this, CopyOptions.create().setIgnoreNullValue(true));
|
||||
}
|
||||
}
|
||||
@ -1,33 +0,0 @@
|
||||
package com.docus.server.archivefile.pojo.entity;
|
||||
|
||||
import com.baomidou.mybatisplus.annotation.TableField;
|
||||
import com.baomidou.mybatisplus.annotation.TableId;
|
||||
import com.baomidou.mybatisplus.annotation.TableName;
|
||||
import io.swagger.annotations.ApiModelProperty;
|
||||
import lombok.Data;
|
||||
|
||||
import java.io.Serializable;
|
||||
|
||||
/**
|
||||
* @author zengdl
|
||||
* @website https://el-admin.vip
|
||||
* @description /
|
||||
* @date 2022-09-02
|
||||
**/
|
||||
@Data
|
||||
@TableName("af_collectsys_dictionary")
|
||||
public class CollectsysDictionary implements Serializable {
|
||||
|
||||
@TableId("id")
|
||||
@ApiModelProperty(value = "id 雪花算法")
|
||||
private Long id;
|
||||
|
||||
@TableField("sys_code")
|
||||
@ApiModelProperty(value = "采集来源系统编号")
|
||||
private String sysCode;
|
||||
|
||||
@TableField("sys_name")
|
||||
@ApiModelProperty(value = "采集来源系统名称")
|
||||
private String sysName;
|
||||
|
||||
}
|
||||
@ -1,7 +0,0 @@
|
||||
package com.docus.server.archivefile.service;
|
||||
|
||||
import com.docus.server.archivefile.pojo.entity.CollectsysDictionary;
|
||||
import com.docus.server.common.service.IBaseService;
|
||||
|
||||
public interface IAfCollectSysDictionary extends IBaseService<CollectsysDictionary> {
|
||||
}
|
||||
@ -1,11 +0,0 @@
|
||||
package com.docus.server.archivefile.service;
|
||||
|
||||
import com.docus.server.archivefile.pojo.entity.AfViewCollectionLog;
|
||||
import com.docus.server.common.service.IBaseService;
|
||||
|
||||
/**
|
||||
* @author linrf
|
||||
* @date 2023/6/13 17:05
|
||||
*/
|
||||
public interface IAfViewCollectionLogService extends IBaseService<AfViewCollectionLog> {
|
||||
}
|
||||
@ -1,12 +0,0 @@
|
||||
package com.docus.server.archivefile.service.impl;
|
||||
|
||||
import com.docus.server.archivefile.mapper.AfCollectSysDictionaryMapper;
|
||||
import com.docus.server.archivefile.pojo.entity.CollectsysDictionary;
|
||||
import com.docus.server.archivefile.service.IAfCollectSysDictionary;
|
||||
import com.docus.server.common.service.impl.BaseServiceImpl;
|
||||
import org.springframework.stereotype.Service;
|
||||
|
||||
@Service
|
||||
public class AfCollectSysDictionaryImpl
|
||||
extends BaseServiceImpl<AfCollectSysDictionaryMapper, CollectsysDictionary> implements IAfCollectSysDictionary {
|
||||
}
|
||||
@ -1,18 +0,0 @@
|
||||
package com.docus.server.archivefile.service.impl;
|
||||
|
||||
import com.docus.server.archivefile.mapper.AfViewCollectionLogMapper;
|
||||
import com.docus.server.archivefile.pojo.entity.AfViewCollectionLog;
|
||||
import com.docus.server.archivefile.service.IAfViewCollectionLogService;
|
||||
import com.docus.server.common.service.impl.BaseServiceImpl;
|
||||
import org.springframework.stereotype.Service;
|
||||
|
||||
/**
|
||||
* @author linrf
|
||||
* @date 2023/6/13 17:06
|
||||
*/
|
||||
@Service
|
||||
public class AfViewCollectionLogServiceImpl
|
||||
extends BaseServiceImpl<AfViewCollectionLogMapper, AfViewCollectionLog> implements IAfViewCollectionLogService {
|
||||
|
||||
|
||||
}
|
||||
@ -1,17 +0,0 @@
|
||||
<?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.archivefile.mapper.AfCollectTaskMapper">
|
||||
<insert id="saveTask">
|
||||
INSERT INTO `docus_archivefile`.`af_collect_task`(`id`, `patient_id`, `sysflag`,
|
||||
`state`, `C1`,`C2`, `C3`)
|
||||
VALUES (#{task.id}, #{task.patientId}, #{task.sysflag}, '0', #{task.C1}, #{task.C2}, #{task.C3});
|
||||
</insert>
|
||||
|
||||
<select id="getTaskById" resultType="com.docus.server.archivefile.pojo.entity.AfCollectTask">
|
||||
select *
|
||||
from `docus_archivefile`.`af_collect_task`
|
||||
where `id` = #{id}
|
||||
</select>
|
||||
</mapper>
|
||||
Some files were not shown because too many files have changed in this diff Show More
Loading…
Reference in New Issue