linjj
/
docus-collector2.0
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

basedao

Browse Source
segment2.0
beeajax 2 years ago
parent 8ef8c77ee5
commit 3a87cee045
6 changed files with 37 additions and 27 deletions
Show Stats Download Patch File Download Diff File

34
collect-sdry/src/main/resources/bootstrap.yml
Unescape Escape View File

@ -13,92 +13,92 @@ spring:
#公司病案的文件服务数据库
master:
url: jdbc:log4jdbc:mysql://db.docus.cn:3306/docus_archivefile?autoReconnect=true&allowMultiQueries=true&useSSL=false&useUnicode=true&characterEncoding=utf-8&serverTimezone=Asia/Shanghai
username: docus
password: docus702
username: root
password: root
driver-class-name: net.sf.log4jdbc.sql.jdbcapi.DriverSpy
type: com.alibaba.druid.pool.DruidDataSource
#公司病案的系统服务数据库
system:
url: jdbc:log4jdbc:mysql://db.docus.cn:3306/docus_system?autoReconnect=true&allowMultiQueries=true&useSSL=false&useUnicode=true&characterEncoding=utf-8&serverTimezone=Asia/Shanghai
username: docus
password: docus702
username: root
password: root
driver-class-name: net.sf.log4jdbc.sql.jdbcapi.DriverSpy
type: com.alibaba.druid.pool.DruidDataSource
#公司病案的基础服务数据库
record:
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
username: root
password: root
driver-class-name: net.sf.log4jdbc.sql.jdbcapi.DriverSpy
type: com.alibaba.druid.pool.DruidDataSource
#医院的用户/科室/基础数据的数据库
his:
url: jdbc:log4jdbc:mysql://127.0.0.1:3306/his?autoReconnect=true&allowMultiQueries=true&useSSL=false&useUnicode=true&characterEncoding=utf-8&serverTimezone=Asia/Shanghai
username: root
password: root@123456
password: root
driver-class-name: net.sf.log4jdbc.sql.jdbcapi.DriverSpy
type: com.alibaba.druid.pool.DruidDataSource
#病理数据
bl:
url: jdbc:log4jdbc:mysql://127.0.0.1:3306/his?autoReconnect=true&allowMultiQueries=true&useSSL=false&useUnicode=true&characterEncoding=utf-8&serverTimezone=Asia/Shanghai
username: root
password: root@123456
password: root
driver-class-name: net.sf.log4jdbc.sql.jdbcapi.DriverSpy
type: com.alibaba.druid.pool.DruidDataSource
#电生理系统数据
ecg:
url: jdbc:log4jdbc:mysql://127.0.0.1:3306/his?autoReconnect=true&allowMultiQueries=true&useSSL=false&useUnicode=true&characterEncoding=utf-8&serverTimezone=Asia/Shanghai
username: root
password: root@123456
password: root
driver-class-name: net.sf.log4jdbc.sql.jdbcapi.DriverSpy
type: com.alibaba.druid.pool.DruidDataSource
#电子病历系统数据
emr:
url: jdbc:log4jdbc:mysql://127.0.0.1:3306/his?autoReconnect=true&allowMultiQueries=true&useSSL=false&useUnicode=true&characterEncoding=utf-8&serverTimezone=Asia/Shanghai
username: root
password: root@123456
password: root
driver-class-name: net.sf.log4jdbc.sql.jdbcapi.DriverSpy
type: com.alibaba.druid.pool.DruidDataSource
#护理文书系统数据
hl:
url: jdbc:log4jdbc:mysql://127.0.0.1:3306/his?autoReconnect=true&allowMultiQueries=true&useSSL=false&useUnicode=true&characterEncoding=utf-8&serverTimezone=Asia/Shanghai
username: root
password: root@123456
password: root
driver-class-name: net.sf.log4jdbc.sql.jdbcapi.DriverSpy
type: com.alibaba.druid.pool.DruidDataSource
#手麻系统数据
issubmit:
url: jdbc:log4jdbc:mysql://127.0.0.1:3306/his?autoReconnect=true&allowMultiQueries=true&useSSL=false&useUnicode=true&characterEncoding=utf-8&serverTimezone=Asia/Shanghai
username: root
password: root@123456
password: root
driver-class-name: net.sf.log4jdbc.sql.jdbcapi.DriverSpy
type: com.alibaba.druid.pool.DruidDataSource
#lis系统数据
lis:
url: jdbc:log4jdbc:mysql://127.0.0.1:3306/lis?autoReconnect=true&allowMultiQueries=true&useSSL=false&useUnicode=true&characterEncoding=utf-8&serverTimezone=Asia/Shanghai
username: root
password: root@123456
password: root
driver-class-name: net.sf.log4jdbc.sql.jdbcapi.DriverSpy
type: com.alibaba.druid.pool.DruidDataSource
#Pacs系统数据视图
pacs:
url: jdbc:log4jdbc:mysql://127.0.0.1:3306/his?autoReconnect=true&allowMultiQueries=true&useSSL=false&useUnicode=true&characterEncoding=utf-8&serverTimezone=Asia/Shanghai
username: root
password: root@123456
password: root
driver-class-name: net.sf.log4jdbc.sql.jdbcapi.DriverSpy
type: com.alibaba.druid.pool.DruidDataSource
#vte静脉血栓栓塞症
vte:
url: jdbc:log4jdbc:mysql://127.0.0.1:3306/his?autoReconnect=true&allowMultiQueries=true&useSSL=false&useUnicode=true&characterEncoding=utf-8&serverTimezone=Asia/Shanghai
username: root
password: root@123456
password: root
driver-class-name: net.sf.log4jdbc.sql.jdbcapi.DriverSpy
type: com.alibaba.druid.pool.DruidDataSource
#重症系统数据
zz:
url: jdbc:log4jdbc:mysql://127.0.0.1:3306/his?autoReconnect=true&allowMultiQueries=true&useSSL=false&useUnicode=true&characterEncoding=utf-8&serverTimezone=Asia/Shanghai
username: root
password: root@123456
password: root
driver-class-name: net.sf.log4jdbc.sql.jdbcapi.DriverSpy
type: com.alibaba.druid.pool.DruidDataSource
# rabbitmq:
@ -108,7 +108,7 @@ spring:
# password: guest
redis:
host: redis.docus.cn
password: JSdocus@702
# password: JSdocus@702
cloud:
nacos:
discovery:

4
common-collect/src/main/java/com/docus/server/collect/user/view/UserViewCollectJob.java
Unescape Escape View File

@ -52,7 +52,7 @@ public class UserViewCollectJob extends AbstractCollectJob<UserDTO> {
public void doHandle(List<UserDTO> results, String param) {
//docus-BasicDataReceive同步user逻辑
Collection<Object> userNames = ListUtils.distinctSelect(results, UserDTO::getUserName);
List<PowerUser> powerUsers = userService.findByList("userName", userNames);
List<PowerUser> powerUsers = userService.findByList1("userName", userNames);
List<String> existUserNames = ListUtils.distinctSelect(powerUsers, PowerUser::getUserName);
results.forEach(p -> {
@ -90,7 +90,7 @@ public class UserViewCollectJob extends AbstractCollectJob<UserDTO> {
}
}
userService.insertOrUpdatePowerUser(p);
PowerUser powerUser = userService.findOneBy("userName", userName);
PowerUser powerUser = userService.findOneBy1("userName", userName);
PowerThirdLogin powerThirdLogin = new PowerThirdLogin();
powerThirdLogin.setId(idService.getDateSeq());

2
common-collect/src/main/java/com/docus/server/collect/web/service/CollectService.java
Unescape Escape View File

@ -39,6 +39,8 @@ public class CollectService {
/**
* 用户信息
*
* @see TrackRetryListener 重试监听器
*/
@TrackRetryListener("user")
public void insertOrUpdateUser(UserDTO userDTO) {

7
common-docus/docus-sys/src/main/java/com/docus/server/sys/service/IPowerUserService.java
Unescape Escape View File

@ -1,5 +1,6 @@
package com.docus.server.sys.service;
import com.docus.server.common.IService;
import com.docus.server.sys.common.pojo.dto.UserDTO;
import com.docus.server.sys.common.pojo.entity.PowerUser;
@ -9,7 +10,7 @@ import java.util.List;
/**
* 用户服务
*/
public interface IPowerUserService {
public interface IPowerUserService extends IService<PowerUser> {
/**
* 用户注册
*
@ -34,7 +35,7 @@ public interface IPowerUserService {
void batchInsertOrUpdatePowerUser(List<UserDTO> users);
PowerUser findOneBy(String userName, String userValue);
PowerUser findOneBy1(String userName, String userValue);
List<PowerUser> findByList(String userName, Collection<Object> userNames);
List<PowerUser> findByList1(String userName, Collection<Object> userNames);
}

15
common-docus/docus-sys/src/main/java/com/docus/server/sys/service/impl/PowerUserServiceImpl.java
Unescape Escape View File

@ -2,6 +2,7 @@ package com.docus.server.sys.service.impl;
import com.docus.core.util.Func;
import com.docus.infrastructure.redis.service.IdService;
import com.docus.server.common.BaseService;
import com.docus.server.common.config.UserProperties;
import com.docus.server.sys.common.pojo.dto.UserDTO;
import com.docus.server.sys.common.pojo.dto.UserModifyParam;
@ -21,14 +22,20 @@ import java.util.List;
* @author wyb
*/
@Service
public class PowerUserServiceImpl implements IPowerUserService {
public class PowerUserServiceImpl extends BaseService<PowerUser> implements IPowerUserService {
@Resource
private IdService idService;
@Resource
private UserProperties userProperties;
@Resource
private IPowerUserDao userDao;
@Resource
public void setUserDao(IPowerUserDao userDao) {
super.setBaseDao(userDao);
this.userDao = userDao;
}
@Transactional
@Override
public void batchInsertOrUpdatePowerUser(List<UserDTO> userDTOList) {
@ -36,12 +43,12 @@ public class PowerUserServiceImpl implements IPowerUserService {
}
@Override
public PowerUser findOneBy(String userName, String userValue) {
public PowerUser findOneBy1(String userName, String userValue) {
return userDao.findOneBy(userName, userValue);
}
@Override
public List<PowerUser> findByList(String userName, Collection<Object> values) {
public List<PowerUser> findByList1(String userName, Collection<Object> values) {
return userDao.findByList(userName, values);
}

2
docus-api-common/src/main/java/com/docus/server/common/BaseServiceImpl.java → docus-api-common/src/main/java/com/docus/server/common/BaseService.java
Unescape Escape View File

@ -1,6 +1,6 @@
package com.docus.server.common;
public class BaseServiceImpl<T> extends AbstractBaseService<T> {
public class BaseService<T> extends AbstractBaseService<T> {
protected IDao<T> baseDao;
Write Preview
Loading…
Cancel
Save