编写basic http和view同步和jms mq 同步
linrf
2 years ago
parent
5e59ed431c
commit
2caaf31014
@ -0,0 +1,20 @@
|
||||
package com.docus.server.collect.basic;
|
||||
|
||||
import com.docus.server.collect.service.IHttpTBasicCollectService;
|
||||
import com.docus.server.record.pojo.dto.TBasicDTO;
|
||||
import com.google.common.collect.Lists;
|
||||
import org.springframework.stereotype.Service;
|
||||
|
||||
import java.util.Date;
|
||||
import java.util.List;
|
||||
|
||||
@Service
|
||||
public class HttpTBasicCollectServiceImpl implements IHttpTBasicCollectService {
|
||||
@Override
|
||||
public List<TBasicDTO> getTBasics(Date startDate, Date endDate, long pageNum, long pageSize) {
|
||||
TBasicDTO deptDTO = new TBasicDTO();
|
||||
|
||||
TBasicDTO deptDTO1 = new TBasicDTO();
|
||||
return Lists.newArrayList(deptDTO, deptDTO1);
|
||||
}
|
||||
}
|
||||
@ -0,0 +1,6 @@
|
||||
package com.docus.server.collect.mq;
|
||||
|
||||
public interface IMqCollectService {
|
||||
|
||||
|
||||
}
|
||||
@ -1,10 +0,0 @@
|
||||
package com.docus.server.collect.service;
|
||||
|
||||
import com.docus.server.sys.pojo.dto.TBasicDTO;
|
||||
|
||||
import java.util.Date;
|
||||
import java.util.List;
|
||||
|
||||
public interface IHttpBasicCollectService {
|
||||
List<TBasicDTO> getBasics(Date startDate, Date endDate, long pageNum, long pageSize);
|
||||
}
|
||||
@ -0,0 +1,10 @@
|
||||
package com.docus.server.collect.service;
|
||||
|
||||
import com.docus.server.sys.common.pojo.dto.DeptDTO;
|
||||
|
||||
import java.util.Date;
|
||||
import java.util.List;
|
||||
|
||||
public interface IHttpDeptCollectService {
|
||||
List<DeptDTO> getDepts(Date startDate, Date endDate, long pageNum, long pageSize);
|
||||
}
|
||||
@ -1,10 +1,10 @@
|
||||
package com.docus.server.collect.service;
|
||||
|
||||
import com.docus.server.sys.pojo.dto.TBasicDTO;
|
||||
import com.docus.server.record.pojo.dto.TBasicDTO;
|
||||
|
||||
import java.util.Date;
|
||||
import java.util.List;
|
||||
|
||||
public interface IHttpTBasicCollectService {
|
||||
List<TBasicDTO> getDepts(Date startDate, Date endDate, long pageNum, long pageSize);
|
||||
List<TBasicDTO> getTBasics(Date startDate, Date endDate, long pageNum, long pageSize);
|
||||
}
|
||||
|
||||
@ -1,10 +1,10 @@
|
||||
package com.docus.server.collect.service;
|
||||
|
||||
import com.docus.server.record.pojo.entity.MedicalRecord;
|
||||
import com.docus.server.sys.service.Dept;
|
||||
import com.docus.server.sys.common.pojo.dto.DeptDTO;
|
||||
|
||||
public interface IParseService {
|
||||
MedicalRecord parseHandNumbness(String handNumbness);
|
||||
|
||||
Dept parseDeptXml(String deptXml);
|
||||
DeptDTO parseDeptXml(String deptXml);
|
||||
}
|
||||
|
||||
@ -1,4 +1,4 @@
|
||||
package com.docus.server.sys.pojo.dto;
|
||||
package com.docus.server.sys.common.pojo.dto;
|
||||
|
||||
import lombok.Data;
|
||||
|
||||
@ -1,4 +1,4 @@
|
||||
package com.docus.server.sys.pojo.dto;
|
||||
package com.docus.server.sys.common.pojo.dto;
|
||||
|
||||
import lombok.Data;
|
||||
|
||||
@ -1,4 +1,4 @@
|
||||
package com.docus.server.sys.pojo.dto;
|
||||
package com.docus.server.sys.common.pojo.dto;
|
||||
|
||||
import lombok.Data;
|
||||
|
||||
@ -1,4 +1,4 @@
|
||||
package com.docus.server.sys.pojo.entity;
|
||||
package com.docus.server.sys.common.pojo.entity;
|
||||
|
||||
import io.swagger.annotations.ApiModel;
|
||||
import io.swagger.annotations.ApiModelProperty;
|
||||
@ -1,4 +1,4 @@
|
||||
package com.docus.server.sys.pojo.entity;
|
||||
package com.docus.server.sys.common.pojo.entity;
|
||||
|
||||
|
||||
import io.swagger.annotations.ApiModel;
|
||||
@ -1,18 +0,0 @@
|
||||
package com.docus.server.sys.infrastructure.dao;
|
||||
|
||||
import com.docus.server.sys.service.Dept;
|
||||
import org.springframework.stereotype.Component;
|
||||
|
||||
@Component
|
||||
public class DeptDao implements IDeptDao {
|
||||
|
||||
@Override
|
||||
public void save(Dept dept) {
|
||||
|
||||
}
|
||||
|
||||
@Override
|
||||
public Dept getDept(String code) {
|
||||
return null;
|
||||
}
|
||||
}
|
||||
@ -1,13 +0,0 @@
|
||||
package com.docus.server.sys.infrastructure.dao;
|
||||
|
||||
import com.docus.server.sys.service.Dept;
|
||||
|
||||
public interface IDeptDao {
|
||||
|
||||
public void save(Dept dept);
|
||||
|
||||
|
||||
public Dept getDept(String code);
|
||||
|
||||
|
||||
}
|
||||
@ -1,38 +0,0 @@
|
||||
package com.docus.server.sys.pojo.dto;
|
||||
|
||||
import lombok.Data;
|
||||
|
||||
/**
|
||||
* @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 {
|
||||
private String serialId;
|
||||
private String receive;
|
||||
private String send;
|
||||
private String jzh;
|
||||
private String inpatientNo;
|
||||
private String admissTimes;
|
||||
private String name ;
|
||||
private String admissDate ;
|
||||
private String disDate ;
|
||||
private String admissDeptName ;
|
||||
private String disDeptName ;
|
||||
private String attendingName;
|
||||
private String age;
|
||||
private String sex;
|
||||
private String idCard;
|
||||
private String disDept;
|
||||
private String sexName;
|
||||
private String bedNum;
|
||||
private String isDead;
|
||||
private String admissDays;
|
||||
private String wardCode;
|
||||
private String wardName;
|
||||
private String sdryIndex;
|
||||
}
|
||||
@ -1,24 +0,0 @@
|
||||
package com.docus.server.sys.service;
|
||||
|
||||
import lombok.Data;
|
||||
|
||||
import java.util.Date;
|
||||
import java.util.Map;
|
||||
|
||||
@Data
|
||||
public class Dept {
|
||||
|
||||
private String deptCode;
|
||||
|
||||
private String deptName;
|
||||
|
||||
private Date dataUpdateTime;
|
||||
|
||||
private String source;
|
||||
|
||||
/**
|
||||
* 拓展参数
|
||||
*/
|
||||
private Map<String, String> params;
|
||||
|
||||
}
|
||||
@ -1,34 +0,0 @@
|
||||
package com.docus.server.sys.service;
|
||||
|
||||
import com.docus.server.sys.pojo.dto.TBasicDTO;
|
||||
|
||||
import java.util.List;
|
||||
|
||||
/**
|
||||
* 用户服务
|
||||
*/
|
||||
public interface ITBasicService {
|
||||
/**
|
||||
* 科室注册
|
||||
*
|
||||
* @param deptDTOList 用户注册参数
|
||||
* @return 处理结果
|
||||
*/
|
||||
void batchSaveBasics(List<TBasicDTO> deptDTOList);
|
||||
|
||||
/**
|
||||
* 科室注册
|
||||
*
|
||||
* @param deptDTO 用户注册参数
|
||||
* @return 处理结果
|
||||
*/
|
||||
boolean register(TBasicDTO deptDTO);
|
||||
|
||||
/**
|
||||
* 根据科室编号删除科室
|
||||
*
|
||||
* @param deptCode 科室编码
|
||||
* @return 删除结果
|
||||
*/
|
||||
boolean delDeptByDeptCode(String deptCode);
|
||||
}
|
||||
@ -1,59 +0,0 @@
|
||||
package com.docus.server.sys.service.impl;
|
||||
|
||||
import com.docus.core.util.Func;
|
||||
import com.docus.infrastructure.redis.service.IdService;
|
||||
import com.docus.server.sys.common.UserProperties;
|
||||
import com.docus.server.sys.pojo.dto.UserDTO;
|
||||
import com.docus.server.sys.pojo.dto.UserModifyParam;
|
||||
import com.docus.server.sys.pojo.entity.PowerUser;
|
||||
import com.docus.server.sys.service.ITBasicService;
|
||||
import org.springframework.stereotype.Service;
|
||||
|
||||
import javax.annotation.Resource;
|
||||
import java.util.List;
|
||||
|
||||
/**
|
||||
* 用户服务实现
|
||||
*
|
||||
* @author wyb
|
||||
*/
|
||||
@Service
|
||||
public class TBasicServiceImpl extends ServiceImpl<TBasicMapper, TBasic> implements ITBasicService {
|
||||
@Resource
|
||||
private IdService idService;
|
||||
@Resource
|
||||
private UserProperties userProperties;
|
||||
|
||||
@Override
|
||||
public void batchSavePowerUser(List<UserDTO> userDTOList) {
|
||||
userDTOList.forEach(this::register);
|
||||
}
|
||||
|
||||
@Override
|
||||
public boolean register(UserDTO userDTO) {
|
||||
PowerUser powerUser = baseMapper.getUserByUserName(userDTO.getUserName());
|
||||
UserModifyParam userModifyParam = userDTO.transUserAddParam();
|
||||
if (Func.isEmpty(powerUser)) {
|
||||
long userId = idService.getDateSeq();
|
||||
userModifyParam.setUserId(userId);
|
||||
userModifyParam.setUserPwd(userProperties.getPassword());
|
||||
baseMapper.addUser(userModifyParam);
|
||||
return true;
|
||||
}
|
||||
userModifyParam.setUserId(powerUser.getUserId());
|
||||
baseMapper.updateUser(userModifyParam);
|
||||
return true;
|
||||
}
|
||||
|
||||
@Override
|
||||
public boolean delUserByUserName(String userName) {
|
||||
PowerUser powerUser = baseMapper.getUserByUserName(userName);
|
||||
if (Func.isEmpty(powerUser)) {
|
||||
return true;
|
||||
}
|
||||
baseMapper.delUserByUserName(userName);
|
||||
return true;
|
||||
}
|
||||
|
||||
|
||||
}
|
||||
@ -0,0 +1,21 @@
|
||||
package com.docus.server.his.infrastructure.mapper;
|
||||
|
||||
import com.baomidou.dynamic.datasource.annotation.DS;
|
||||
import com.docus.server.record.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("his")
|
||||
public interface HisTBasicMapper {
|
||||
|
||||
List<TBasicDTO> getTBasicListView(@Param("startDate") Date startDate,
|
||||
@Param("endDate") Date endDate,
|
||||
@Param("offset") long offset,
|
||||
@Param("pageSize") long pageSize);
|
||||
|
||||
|
||||
}
|
||||
@ -1,13 +1,16 @@
|
||||
package com.docus.server.his.service;
|
||||
|
||||
import com.docus.server.sys.pojo.dto.DeptDTO;
|
||||
import com.docus.server.sys.pojo.dto.UserDTO;
|
||||
import com.docus.server.record.pojo.dto.TBasicDTO;
|
||||
import com.docus.server.sys.common.pojo.dto.DeptDTO;
|
||||
import com.docus.server.sys.common.pojo.dto.UserDTO;
|
||||
|
||||
import java.util.Date;
|
||||
import java.util.List;
|
||||
|
||||
public interface IHisService {
|
||||
List<DeptDTO> getDeptListView(Date startDate, Date endDate, long pazeNum, long pageSize);
|
||||
List<DeptDTO> getDeptListView(Date startDate, Date endDate, long pageNum, long pageSize);
|
||||
|
||||
List<UserDTO> getUserListView(Date startDate, Date endDate, long pazeNum, long pageSize);
|
||||
List<UserDTO> getUserListView(Date startDate, Date endDate, long pageNum, long pageSize);
|
||||
|
||||
List<TBasicDTO> getTBasicListView(Date startDate, Date endDate, long pageNum, long pageSize);
|
||||
}
|
||||
|
||||
@ -0,0 +1,49 @@
|
||||
<?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.infrastructure.mapper.HisTBasicMapper">
|
||||
|
||||
<select id="getTBasicListView" resultType="com.docus.server.record.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="getDeptListView" 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="getDeptListView" 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="getDeptListView" 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>
|
||||
Loading…
Reference in New Issue