diff --git a/collect-sdry/pom.xml b/collect-sdry/pom.xml index 8bf501f..f01de27 100644 --- a/collect-sdry/pom.xml +++ b/collect-sdry/pom.xml @@ -134,7 +134,6 @@ - diff --git a/collect-sdry/src/main/java/com/docus/server/AppRunBootstrap.java b/collect-sdry/src/main/java/com/docus/server/AppRunBootstrap.java index 225ee49..420bae5 100644 --- a/collect-sdry/src/main/java/com/docus/server/AppRunBootstrap.java +++ b/collect-sdry/src/main/java/com/docus/server/AppRunBootstrap.java @@ -1,7 +1,6 @@ package com.docus.server; - import lombok.extern.slf4j.Slf4j; import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; @@ -10,10 +9,11 @@ import org.springframework.boot.autoconfigure.SpringBootApplication; @Slf4j //@EnableFeignClients(basePackages = ("com.feign")) //@EnableHystrix -@SpringBootApplication(scanBasePackages ={"com.docus"}) +//@MapperScan("com.docus.server") +@SpringBootApplication(scanBasePackages = {"com.docus"}) public class AppRunBootstrap { public static void main(String[] args) { - System.setProperty("javax.xml.parsers.DocumentBuilderFactory","com.sun.org.apache.xerces.internal.jaxp.DocumentBuilderFactoryImpl"); - SpringApplication.run(AppRunBootstrap.class,args); + System.setProperty("javax.xml.parsers.DocumentBuilderFactory", "com.sun.org.apache.xerces.internal.jaxp.DocumentBuilderFactoryImpl"); + SpringApplication.run(AppRunBootstrap.class, args); } } diff --git a/collect-sdry/src/main/java/com/docus/server/CxfConfig.java b/collect-sdry/src/main/java/com/docus/server/CxfConfig.java index 86a6f1e..6dcd0ee 100644 --- a/collect-sdry/src/main/java/com/docus/server/CxfConfig.java +++ b/collect-sdry/src/main/java/com/docus/server/CxfConfig.java @@ -1,7 +1,6 @@ package com.docus.server; import com.docus.server.ws.IWebserviceServer; -import lombok.RequiredArgsConstructor; import org.apache.cxf.Bus; import org.apache.cxf.bus.spring.SpringBus; import org.apache.cxf.jaxws.EndpointImpl; @@ -11,13 +10,13 @@ import org.springframework.boot.web.servlet.ServletRegistrationBean; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; +import javax.annotation.Resource; import javax.xml.ws.Endpoint; @Configuration -@RequiredArgsConstructor public class CxfConfig { - - private final IWebserviceServer webserviceServer; + @Resource + private IWebserviceServer webserviceServer; /** * 注入Servlet,注意beanName不能为dispatcherServlet diff --git a/collect-sdry/src/main/java/com/docus/server/collect/dept/HttpDeptCollectService.java b/collect-sdry/src/main/java/com/docus/server/collect/dept/HttpDeptCollectService.java deleted file mode 100644 index bf70c80..0000000 --- a/collect-sdry/src/main/java/com/docus/server/collect/dept/HttpDeptCollectService.java +++ /dev/null @@ -1,16 +0,0 @@ -package com.docus.server.collect.dept; - -import com.docus.server.collect.service.IHttpDeptCollectService; -import com.docus.server.sys.service.Dept; -import org.springframework.stereotype.Component; - -import java.util.Date; -import java.util.List; - -@Component -public class HttpDeptCollectService implements IHttpDeptCollectService { - @Override - public List getDepts(Date startDate, Date endDate, long pazeNum, long pageSize) { - return null; - } -} diff --git a/collect-sdry/src/main/java/com/docus/server/collect/dept/HttpDeptCollectServiceImpl.java b/collect-sdry/src/main/java/com/docus/server/collect/dept/HttpDeptCollectServiceImpl.java new file mode 100644 index 0000000..66b11b6 --- /dev/null +++ b/collect-sdry/src/main/java/com/docus/server/collect/dept/HttpDeptCollectServiceImpl.java @@ -0,0 +1,34 @@ +package com.docus.server.collect.dept; + +import com.docus.server.collect.service.IHttpDeptCollectService; +import com.docus.server.sys.pojo.dto.DeptDTO; +import com.google.common.collect.Lists; +import org.springframework.stereotype.Service; + +import java.util.Date; +import java.util.List; + +@Service +public class HttpDeptCollectServiceImpl implements IHttpDeptCollectService { + @Override + public List getDepts(Date startDate, Date endDate, long pazeNum, long pageSize) { + DeptDTO deptDTO = new DeptDTO(); + deptDTO.setAuthorId("1"); + deptDTO.setAuthorName("admin"); + deptDTO.setDeptCode("1"); + deptDTO.setDeptName("测试1科"); + deptDTO.setMessageId("1"); + deptDTO.setOperateType("save"); + deptDTO.setReceiver("admin"); + + DeptDTO deptDTO1 = new DeptDTO(); + deptDTO1.setAuthorId("2"); + deptDTO1.setAuthorName("admin2"); + deptDTO1.setDeptCode("2"); + deptDTO1.setDeptName("测试2科"); + deptDTO1.setMessageId("2"); + deptDTO1.setOperateType("save2"); + deptDTO1.setReceiver("admin2"); + return Lists.newArrayList(deptDTO, deptDTO1); + } +} diff --git a/collect-sdry/src/main/java/com/docus/server/collect/medical/record/ParseService.java b/collect-sdry/src/main/java/com/docus/server/collect/medical/record/ParseServiceImpl.java similarity index 53% rename from collect-sdry/src/main/java/com/docus/server/collect/medical/record/ParseService.java rename to collect-sdry/src/main/java/com/docus/server/collect/medical/record/ParseServiceImpl.java index 4619406..37afdd6 100644 --- a/collect-sdry/src/main/java/com/docus/server/collect/medical/record/ParseService.java +++ b/collect-sdry/src/main/java/com/docus/server/collect/medical/record/ParseServiceImpl.java @@ -1,22 +1,22 @@ package com.docus.server.collect.medical.record; -import com.docus.server.record.domain.MedicalRecord; -import com.docus.server.sys.service.Dept; import com.docus.server.collect.service.IParseService; -import org.springframework.stereotype.Component; +import com.docus.server.record.pojo.entity.MedicalRecord; +import com.docus.server.sys.service.Dept; +import org.springframework.stereotype.Service; -@Component -public class ParseService implements IParseService { +@Service +public class ParseServiceImpl implements IParseService { @Override - public MedicalRecord parseHandNumbness(String handNumbness){ + public MedicalRecord parseHandNumbness(String handNumbness) { //TODO: 根据协议进行解析。 return null; } @Override - public Dept parseDeptXml(String deptXml){ + public Dept parseDeptXml(String deptXml) { //TODO: 根据协议进行解析。 return null; } diff --git a/collect-sdry/src/main/resources/bootstrap.yml b/collect-sdry/src/main/resources/bootstrap.yml index 6b71564..83ef4af 100644 --- a/collect-sdry/src/main/resources/bootstrap.yml +++ b/collect-sdry/src/main/resources/bootstrap.yml @@ -17,13 +17,11 @@ spring: driver-class-name: net.sf.log4jdbc.sql.jdbcapi.DriverSpy type: com.alibaba.druid.pool.DruidDataSource his: - 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 + 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 driver-class-name: net.sf.log4jdbc.sql.jdbcapi.DriverSpy type: com.alibaba.druid.pool.DruidDataSource - - redis: host: redis.docus.cn password: JSdocus@702 @@ -39,7 +37,6 @@ spring: shared-configs: - comm.${spring.cloud.nacos.config.file-extension} - docus: dbtype: mysql @@ -48,17 +45,20 @@ mybatis-plus: map-underscore-to-camel-case: true call-setters-on-nulls: true log-impl: org.apache.ibatis.logging.stdout.StdOutImpl + jdbc-type-for-null: null global-config: db-config: + update-strategy: ignored field-strategy: NOT_EMPTY db-type: MYSQL + mapper-locations: classpath*:/mapper/*Mapper.xml xxl: job: accessToken: admin: addresses: http://job.docus.cn:8180/xxl-job-admin executor: - appname: docus-inspection + appname: xxl-job-executor-test address: ip: port: 17781 diff --git a/common-collect/src/main/java/com/docus/server/collect/domain/TaskConfigService.java b/common-collect/src/main/java/com/docus/server/collect/domain/TaskConfigService.java deleted file mode 100644 index 0f2006d..0000000 --- a/common-collect/src/main/java/com/docus/server/collect/domain/TaskConfigService.java +++ /dev/null @@ -1,27 +0,0 @@ -package com.docus.server.collect.domain; - -import org.springframework.stereotype.Component; - -import java.util.Date; - -@Component -public class TaskConfigService implements ITaskConfigService { - - @Override - public void updateAllPointerDate(String id, Date date){ - - } - - - @Override - public void updateIncPointerDate(String id, Date date){ - - } - - - @Override - public TaskConfig getTaskConfig(String id){ - return null; - } - -} diff --git a/common-collect/src/main/java/com/docus/server/collect/domain/TaskConfigServiceImpl.java b/common-collect/src/main/java/com/docus/server/collect/domain/TaskConfigServiceImpl.java new file mode 100644 index 0000000..3583d8d --- /dev/null +++ b/common-collect/src/main/java/com/docus/server/collect/domain/TaskConfigServiceImpl.java @@ -0,0 +1,29 @@ +package com.docus.server.collect.domain; + +import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; +import com.docus.server.collect.infrastructure.mapper.TaskConfigMapper; +import org.springframework.stereotype.Service; + +import java.util.Date; + +@Service +public class TaskConfigServiceImpl extends ServiceImpl implements ITaskConfigService { + + @Override + public void updateAllPointerDate(String id, Date date) { + + } + + + @Override + public void updateIncPointerDate(String id, Date date) { + + } + + + @Override + public TaskConfig getTaskConfig(String id) { + return super.getById(id); + } + +} diff --git a/common-collect/src/main/java/com/docus/server/collect/infrastructure/dao/ReceiveDeptInfoEntity.java b/common-collect/src/main/java/com/docus/server/collect/infrastructure/dao/ReceiveDeptInfoEntity.java index ebeaca6..062870d 100644 --- a/common-collect/src/main/java/com/docus/server/collect/infrastructure/dao/ReceiveDeptInfoEntity.java +++ b/common-collect/src/main/java/com/docus/server/collect/infrastructure/dao/ReceiveDeptInfoEntity.java @@ -1,7 +1,10 @@ package com.docus.server.collect.infrastructure.dao; +import lombok.Data; + import java.util.Date; +@Data public class ReceiveDeptInfoEntity { private String deptCode; diff --git a/common-collect/src/main/java/com/docus/server/collect/infrastructure/mapper/ReceiveDeptInfoMapper.java b/common-collect/src/main/java/com/docus/server/collect/infrastructure/mapper/ReceiveDeptInfoMapper.java index 1c26907..403816a 100644 --- a/common-collect/src/main/java/com/docus/server/collect/infrastructure/mapper/ReceiveDeptInfoMapper.java +++ b/common-collect/src/main/java/com/docus/server/collect/infrastructure/mapper/ReceiveDeptInfoMapper.java @@ -1,8 +1,10 @@ package com.docus.server.collect.infrastructure.mapper; +import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.docus.server.collect.infrastructure.dao.ReceiveDeptInfoEntity; +import org.apache.ibatis.annotations.Mapper; -public interface ReceiveDeptInfoMapper { +@Mapper +public interface ReceiveDeptInfoMapper extends BaseMapper { - public void save(ReceiveDeptInfoEntity receiveDeptInfoEntity); } diff --git a/common-collect/src/main/java/com/docus/server/collect/infrastructure/mapper/TaskConfigMapper.java b/common-collect/src/main/java/com/docus/server/collect/infrastructure/mapper/TaskConfigMapper.java new file mode 100644 index 0000000..4f85347 --- /dev/null +++ b/common-collect/src/main/java/com/docus/server/collect/infrastructure/mapper/TaskConfigMapper.java @@ -0,0 +1,13 @@ +package com.docus.server.collect.infrastructure.mapper; + +import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import com.docus.server.collect.domain.TaskConfig; +import org.apache.ibatis.annotations.Mapper; + +/** + * @Author : linrf + * @create 2023/5/30 9:11 + */ +@Mapper +public interface TaskConfigMapper extends BaseMapper { +} diff --git a/common-collect/src/main/java/com/docus/server/collect/job/DeptHttpCollect.java b/common-collect/src/main/java/com/docus/server/collect/job/DeptHttpCollect.java deleted file mode 100644 index 3d4d1b7..0000000 --- a/common-collect/src/main/java/com/docus/server/collect/job/DeptHttpCollect.java +++ /dev/null @@ -1,50 +0,0 @@ -package com.docus.server.collect.job; - -import com.docus.server.collect.domain.ITaskConfigService; -import com.docus.server.collect.service.IHttpDeptCollectService; -import com.docus.server.sys.service.Dept; -import com.docus.server.sys.service.IDeptService; -import com.xxl.job.core.handler.annotation.XxlJob; -import org.springframework.stereotype.Component; - -import java.util.Date; -import java.util.List; - - -@Component -public class DeptHttpCollect extends AbstractDeptHttpCollect { - - - private final IHttpDeptCollectService httpDeptCollectService; - - - public DeptHttpCollect(IDeptService deptService, ITaskConfigService taskConfigService,IHttpDeptCollectService httpDeptCollectService) { - super(deptService,taskConfigService); - this.httpDeptCollectService = httpDeptCollectService; - } - - /** - * xxl job 手工执行 - */ - @XxlJob("startAllDeptHttpCollect") - public void startCollectAll(){ - super.startCollectAll("1"); - } - - /** - * xxl job 配置定时启动,如果未完成任务跳过。 - */ - @XxlJob("startIncDeptHttpCollect") - public void startCollectIncrement(){ - super.startCollectIncrement("1"); - } - - - @Override - public List getDepts(Date startDate, Date endDate, long pazeNum, long pageSize) { - - //需要根据不同医院去解析不同的内容。使用接口实现的方式。 - - return httpDeptCollectService.getDepts( startDate, endDate, pazeNum, pageSize); - } -} diff --git a/common-collect/src/main/java/com/docus/server/collect/job/DeptViewCollect.java b/common-collect/src/main/java/com/docus/server/collect/job/DeptViewCollect.java deleted file mode 100644 index cde9b19..0000000 --- a/common-collect/src/main/java/com/docus/server/collect/job/DeptViewCollect.java +++ /dev/null @@ -1,48 +0,0 @@ -package com.docus.server.collect.job; - -import com.docus.server.collect.domain.ITaskConfigService; -import com.docus.server.his.service.IHisService; -import com.docus.server.sys.service.Dept; -import com.docus.server.sys.service.IDeptService; -import com.xxl.job.core.handler.annotation.XxlJob; -import org.springframework.stereotype.Component; - -import java.util.Date; -import java.util.List; - -@Component -public class DeptViewCollect extends AbstractDeptHttpCollect { - - private final IHisService hisService; - - protected DeptViewCollect(IDeptService deptService, ITaskConfigService taskConfigService,IHisService hisService) { - super(deptService, taskConfigService); - this.hisService = hisService; - } - - /** - * xxl job 手工执行,全量执行 - */ - @XxlJob("allDeptViewCollect") - public void allDeptViewCollect(){ - super.startCollectAll("2"); - } - - - /** - * xxl job 配置定时启动,如果未完成任务跳过。增量收集 - */ - @XxlJob("incDeptViewCollect") - public void startCollectIncrement(){ - super.startCollectIncrement("1"); - } - - - @Override - public List getDepts(Date startDate, Date endDate, long pageNum, long pageSize) { - - //每家医院按照固定的格式写sql,不同医院需要替换不同的sql即可。 - return hisService.getDeptListView(startDate,endDate,pageNum,pageSize); - } - -} diff --git a/common-collect/src/main/java/com/docus/server/collect/job/AbstractDeptHttpCollect.java b/common-collect/src/main/java/com/docus/server/collect/job/dept/AbstractDeptHttpCollectJob.java similarity index 73% rename from common-collect/src/main/java/com/docus/server/collect/job/AbstractDeptHttpCollect.java rename to common-collect/src/main/java/com/docus/server/collect/job/dept/AbstractDeptHttpCollectJob.java index d28efe9..8a9c2d4 100644 --- a/common-collect/src/main/java/com/docus/server/collect/job/AbstractDeptHttpCollect.java +++ b/common-collect/src/main/java/com/docus/server/collect/job/dept/AbstractDeptHttpCollectJob.java @@ -1,26 +1,27 @@ -package com.docus.server.collect.job; +package com.docus.server.collect.job.dept; import com.docus.server.collect.domain.ITaskConfigService; -import com.docus.server.sys.service.Dept; -import com.docus.server.sys.service.IDeptService; import com.docus.server.collect.domain.TaskConfig; +import com.docus.server.sys.pojo.dto.DeptDTO; +import com.docus.server.sys.service.IPowerDeptService; import com.docus.server.tool.PeriodTime; +import org.springframework.beans.factory.annotation.Autowired; +import javax.annotation.Resource; import java.util.Date; import java.util.List; -public abstract class AbstractDeptHttpCollect { - - private final IDeptService deptService; - +public abstract class AbstractDeptHttpCollectJob { + @Autowired + private final IPowerDeptService deptService; + @Resource private final ITaskConfigService taskConfigService; - protected AbstractDeptHttpCollect(IDeptService deptService, ITaskConfigService taskConfigService) { + protected AbstractDeptHttpCollectJob(IPowerDeptService deptService, ITaskConfigService taskConfigService) { this.deptService = deptService; this.taskConfigService = taskConfigService; } - /** * 启动全量收集任务,时间从数据库读取,全量一般都用手工指定 */ @@ -31,14 +32,14 @@ public abstract class AbstractDeptHttpCollect { List periodTimes = taskConfig.getAllPeriodTimes(); for (PeriodTime periodTime : periodTimes) { //考虑到性能,应该把起始时间和结束时间进行切割拆分到每天。按段查询。 - List depts = null; + List depts = null; int pageNum = 0; while (true) { depts = this.getDepts(periodTime.getPeriodStartDate(), periodTime.getPeriodEndDate(), pageNum, taskConfig.getPageSize()); if (depts == null || depts.size() == 0) { break; } - deptService.save(depts); + deptService.batchSavePowerDept(depts); pageNum++; } taskConfigService.updateAllPointerDate(taskConfigId, periodTime.getPeriodEndDate()); @@ -57,19 +58,20 @@ public abstract class AbstractDeptHttpCollect { List periodTimes = taskConfig.getIncPeriodTimes(); for (PeriodTime periodTime : periodTimes) { //考虑到性能,应该把起始时间和结束时间进行切割拆分到每天。按段查询。 - List depts = null; - int pageNum = 0; - while (true) { + List depts; + int pageNum = 1; + + for (; true; pageNum++) { + depts = this.getDepts(periodTime.getPeriodStartDate(), periodTime.getPeriodEndDate(), pageNum, taskConfig.getPageSize()); if (depts == null || depts.size() == 0) { break; } - deptService.save(depts); - pageNum++; + deptService.batchSavePowerDept(depts); + } taskConfigService.updateIncPointerDate(taskConfigId, periodTime.getPeriodEndDate()); } - } @@ -82,7 +84,7 @@ public abstract class AbstractDeptHttpCollect { * @param pageSize * @return */ - public abstract List getDepts(Date startDate, Date endDate, long pageNum, long pageSize); + public abstract List getDepts(Date startDate, Date endDate, long pageNum, long pageSize); } diff --git a/common-collect/src/main/java/com/docus/server/collect/job/dept/DeptHttpCollectJob.java b/common-collect/src/main/java/com/docus/server/collect/job/dept/DeptHttpCollectJob.java new file mode 100644 index 0000000..2980b86 --- /dev/null +++ b/common-collect/src/main/java/com/docus/server/collect/job/dept/DeptHttpCollectJob.java @@ -0,0 +1,50 @@ +package com.docus.server.collect.job.dept; + +import com.docus.server.collect.domain.ITaskConfigService; +import com.docus.server.collect.service.IHttpDeptCollectService; +import com.docus.server.sys.pojo.dto.DeptDTO; +import com.docus.server.sys.service.IPowerDeptService; +import com.xxl.job.core.handler.annotation.XxlJob; +import org.springframework.stereotype.Component; + +import javax.annotation.Resource; +import java.util.Date; +import java.util.List; + + +@Component +public class DeptHttpCollectJob extends AbstractDeptHttpCollectJob { + + @Resource + private final IHttpDeptCollectService httpDeptCollectService; + + public DeptHttpCollectJob(IPowerDeptService deptService, ITaskConfigService taskConfigService, IHttpDeptCollectService httpDeptCollectService) { + super(deptService, taskConfigService); + this.httpDeptCollectService = httpDeptCollectService; + } + + /** + * xxl jobhandler 手工执行 + */ + @XxlJob("startAllDeptHttpCollect") + public void startAllDeptHttpCollect() { + super.startCollectAll("1"); + } + + /** + * xxl jobhandler 配置定时启动,如果未完成任务跳过。 + */ + @XxlJob("startIncDeptHttpCollect") + public void startIncDeptHttpCollect() { + super.startCollectIncrement("1"); + } + + + @Override + public List getDepts(Date startDate, Date endDate, long pazeNum, long pageSize) { + + //需要根据不同医院去解析不同的内容。使用接口实现的方式。 + + return httpDeptCollectService.getDepts(startDate, endDate, pazeNum, pageSize); + } +} diff --git a/common-collect/src/main/java/com/docus/server/collect/job/dept/DeptViewCollectJob.java b/common-collect/src/main/java/com/docus/server/collect/job/dept/DeptViewCollectJob.java new file mode 100644 index 0000000..4e8a8d5 --- /dev/null +++ b/common-collect/src/main/java/com/docus/server/collect/job/dept/DeptViewCollectJob.java @@ -0,0 +1,52 @@ +package com.docus.server.collect.job.dept; + +import com.docus.server.collect.domain.ITaskConfigService; +import com.docus.server.his.service.IHisService; +import com.docus.server.sys.pojo.dto.DeptDTO; +import com.docus.server.sys.service.IPowerDeptService; +import com.xxl.job.core.context.XxlJobHelper; +import com.xxl.job.core.handler.annotation.XxlJob; +import org.springframework.stereotype.Component; + +import javax.annotation.Resource; +import java.util.Date; +import java.util.List; + +@Component +public class DeptViewCollectJob extends AbstractDeptHttpCollectJob { + @Resource + private final IHisService hisService; + + protected DeptViewCollectJob(IPowerDeptService deptService, ITaskConfigService taskConfigService, IHisService hisService) { + super(deptService, taskConfigService); + this.hisService = hisService; + } + + /** + * xxl jobhandler 手工执行,全量执行 + */ + @XxlJob("startAllDeptViewCollect") + public void startAllDeptViewCollect() { + super.startCollectAll("2"); + } + + + /** + * xxl jobhandler 配置定时启动,如果未完成任务跳过。增量收集 + */ + @XxlJob("startIncDeptViewCollect") + public void startIncDeptViewCollect() { + String jobParam = XxlJobHelper.getJobParam(); + System.out.println(jobParam); + super.startCollectIncrement(jobParam); + } + + + @Override + public List getDepts(Date startDate, Date endDate, long pageNum, long pageSize) { + + //每家医院按照固定的格式写sql,不同医院需要替换不同的sql即可。 + return hisService.getDeptListView(startDate, endDate, pageNum, pageSize); + } + +} diff --git a/common-collect/src/main/java/com/docus/server/collect/mq/MqCollect.java b/common-collect/src/main/java/com/docus/server/collect/mq/MqCollect.java index 260b724..493861d 100644 --- a/common-collect/src/main/java/com/docus/server/collect/mq/MqCollect.java +++ b/common-collect/src/main/java/com/docus/server/collect/mq/MqCollect.java @@ -1,34 +1,35 @@ package com.docus.server.collect.mq; -import com.docus.server.ws.IWsResult; import com.docus.server.sys.service.Dept; import com.docus.server.sys.service.IDeptService; -import lombok.AllArgsConstructor; +import com.docus.server.ws.IWsResult; import lombok.extern.slf4j.Slf4j; +import javax.annotation.Resource; + /** * 每家mq 都不一样,这部分无法预先写好写入,需要根据每家独立编写。 */ -@AllArgsConstructor @Slf4j public class MqCollect { - private final IDeptService deptService; - - private final IWsResult wsResult; + @Resource + private IDeptService deptService; + @Resource + private IWsResult wsResult; - public String receiveDept(String deptXml){ - log.info("收到科室消息:{}",deptXml); - try{ + public String receiveDept(String deptXml) { + log.info("收到科室消息:{}", deptXml); + try { Dept dept = this.parseDeptXml(deptXml); deptService.save(dept); return wsResult.ok(dept.getParams()); - }catch (Exception e){ + } catch (Exception e) { return wsResult.fail(e.getMessage()); } } - public Dept parseDeptXml(String deptXml){ + public Dept parseDeptXml(String deptXml) { return null; } } diff --git a/common-collect/src/main/java/com/docus/server/collect/service/CollectService.java b/common-collect/src/main/java/com/docus/server/collect/service/CollectService.java index 6ef6de0..b3b0fea 100644 --- a/common-collect/src/main/java/com/docus/server/collect/service/CollectService.java +++ b/common-collect/src/main/java/com/docus/server/collect/service/CollectService.java @@ -4,25 +4,27 @@ import com.docus.server.collect.infrastructure.dao.ReceiveDeptInfoEntity; import com.docus.server.collect.infrastructure.mapper.ReceiveDeptInfoMapper; import com.docus.server.sys.service.Dept; import com.docus.server.sys.service.IDeptService; -import lombok.AllArgsConstructor; import org.springframework.stereotype.Component; +import org.springframework.stereotype.Service; + +import javax.annotation.Resource; @Component -@AllArgsConstructor +@Service public class CollectService { + @Resource + private IDeptService deptService; + @Resource + private ReceiveDeptInfoMapper receiveDeptInfoMapper; - private final IDeptService deptService; - - private final ReceiveDeptInfoMapper receiveDeptInfoMapper; - - public void receiveDept(Dept dept){ + public void receiveDept(Dept dept) { //判断任务是否存在。 //保存数据库 //从dept 解析为数据库对象 ReceiveDeptInfoEntity receiveDeptInfoEntity = new ReceiveDeptInfoEntity(); - receiveDeptInfoMapper.save(receiveDeptInfoEntity); + receiveDeptInfoMapper.insert(receiveDeptInfoEntity); //异步写入归档系统,失败自动重试。 deptService.save(dept); @@ -30,5 +32,4 @@ public class CollectService { } - } diff --git a/common-collect/src/main/java/com/docus/server/collect/service/IHttpDeptCollectService.java b/common-collect/src/main/java/com/docus/server/collect/service/IHttpDeptCollectService.java index a0881a7..6d17189 100644 --- a/common-collect/src/main/java/com/docus/server/collect/service/IHttpDeptCollectService.java +++ b/common-collect/src/main/java/com/docus/server/collect/service/IHttpDeptCollectService.java @@ -1,10 +1,10 @@ package com.docus.server.collect.service; -import com.docus.server.sys.service.Dept; +import com.docus.server.sys.pojo.dto.DeptDTO; import java.util.Date; import java.util.List; public interface IHttpDeptCollectService { - List getDepts(Date startDate, Date endDate, long pazeNum, long pageSize); + List getDepts(Date startDate, Date endDate, long pazeNum, long pageSize); } diff --git a/common-collect/src/main/java/com/docus/server/collect/service/IParseService.java b/common-collect/src/main/java/com/docus/server/collect/service/IParseService.java index a94c4f7..565156a 100644 --- a/common-collect/src/main/java/com/docus/server/collect/service/IParseService.java +++ b/common-collect/src/main/java/com/docus/server/collect/service/IParseService.java @@ -1,6 +1,6 @@ package com.docus.server.collect.service; -import com.docus.server.record.domain.MedicalRecord; +import com.docus.server.record.pojo.entity.MedicalRecord; import com.docus.server.sys.service.Dept; public interface IParseService { diff --git a/common-collect/src/main/java/com/docus/server/ws/IWsResult.java b/common-collect/src/main/java/com/docus/server/ws/IWsResult.java index bf1454e..7ffabd9 100644 --- a/common-collect/src/main/java/com/docus/server/ws/IWsResult.java +++ b/common-collect/src/main/java/com/docus/server/ws/IWsResult.java @@ -4,8 +4,8 @@ import java.util.Map; public interface IWsResult { - public String ok(Map params); + String ok(Map params); - public String fail(String message); + String fail(String message); } diff --git a/common-collect/src/main/java/com/docus/server/ws/WsCollect.java b/common-collect/src/main/java/com/docus/server/ws/WsCollect.java index 3ad4b59..51916e3 100644 --- a/common-collect/src/main/java/com/docus/server/ws/WsCollect.java +++ b/common-collect/src/main/java/com/docus/server/ws/WsCollect.java @@ -2,49 +2,48 @@ package com.docus.server.ws; import com.docus.server.collect.service.CollectService; import com.docus.server.collect.service.IParseService; -import com.docus.server.record.domain.MedicalRecord; +import com.docus.server.record.pojo.entity.MedicalRecord; import com.docus.server.record.service.IMedicalRecordService; import com.docus.server.sys.service.Dept; -import com.docus.server.sys.service.IDeptService; -import lombok.AllArgsConstructor; import lombok.extern.slf4j.Slf4j; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Component; @Slf4j -@AllArgsConstructor +@Component public class WsCollect { - - private final IMedicalRecordService medicalRecordService; - - private final IParseService parseService; - - - private final CollectService collectService; - - private final IWsResult wsResult; + @Autowired + private IMedicalRecordService medicalRecordService; + @Autowired + private IParseService parseService; + @Autowired + private CollectService collectService; + @Autowired + private IWsResult wsResult; //接收xml。并且下载病案。 - public String receiveHandNumbness(String handNumbness){ - log.info("收到手麻消息:{}",handNumbness); - try{ + public String receiveHandNumbness(String handNumbness) { + log.info("收到手麻消息:{}", handNumbness); + try { MedicalRecord medicalRecord = parseService.parseHandNumbness(handNumbness); medicalRecordService.receive(medicalRecord); return wsResult.ok(medicalRecord.getParams()); - }catch (Exception e){ + } catch (Exception e) { return wsResult.fail(e.getMessage()); } } - public String receiveDept(String deptXml){ - log.info("收到科室消息:{}",deptXml); - try{ + public String receiveDept(String deptXml) { + log.info("收到科室消息:{}", deptXml); + try { Dept dept = parseService.parseDeptXml(deptXml); //此处需要存储原xml内容。 collectService.receiveDept(dept); return wsResult.ok(dept.getParams()); - }catch (Exception e){ + } catch (Exception e) { return wsResult.fail(e.getMessage()); } } diff --git a/common-collect/src/main/java/com/docus/server/ws/impl/WebserviceServer.java b/common-collect/src/main/java/com/docus/server/ws/impl/WebserviceServer.java index 52d7f28..5fe3cc6 100644 --- a/common-collect/src/main/java/com/docus/server/ws/impl/WebserviceServer.java +++ b/common-collect/src/main/java/com/docus/server/ws/impl/WebserviceServer.java @@ -1,26 +1,27 @@ package com.docus.server.ws.impl; +import com.docus.server.ws.IWebserviceServer; import com.docus.server.ws.WsCollect; -import lombok.AllArgsConstructor; import lombok.extern.slf4j.Slf4j; import org.springframework.stereotype.Service; -import com.docus.server.ws.IWebserviceServer; + +import javax.annotation.Resource; @Slf4j @Service -@AllArgsConstructor public class WebserviceServer implements IWebserviceServer { - private final WsCollect wsCollect; + @Resource + private WsCollect wsCollect; @Override - public String receiveHandNumbness(String handNumbness){ - return wsCollect.receiveHandNumbness(handNumbness); + public String receiveHandNumbness(String handNumbness) { + return wsCollect.receiveHandNumbness(handNumbness); } @Override - public String receiveDept(String deptXml){ - return wsCollect.receiveDept(deptXml); + public String receiveDept(String deptXml) { + return wsCollect.receiveDept(deptXml); } } diff --git a/docus-medical-record/pom.xml b/docus-medical-record/pom.xml index 9093fd5..4963e19 100644 --- a/docus-medical-record/pom.xml +++ b/docus-medical-record/pom.xml @@ -9,4 +9,18 @@ docus-medical-record Archetype - docus-medical-record http://maven.apache.org + + + + + src/main/java + + **/*.xml + + + + src/main/resources + + + diff --git a/docus-medical-record/src/main/java/com/docus/server/record/mapper/TBasicMapper.java b/docus-medical-record/src/main/java/com/docus/server/record/mapper/TBasicMapper.java index f13eb87..ea832c3 100644 --- a/docus-medical-record/src/main/java/com/docus/server/record/mapper/TBasicMapper.java +++ b/docus-medical-record/src/main/java/com/docus/server/record/mapper/TBasicMapper.java @@ -3,6 +3,7 @@ package com.docus.server.record.mapper; import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.docus.server.record.pojo.entity.TBasic; import com.docus.server.record.pojo.entity.TBasicExtend; +import org.apache.ibatis.annotations.Mapper; import org.apache.ibatis.annotations.Param; import java.util.List; @@ -15,6 +16,7 @@ import java.util.List; * @author jiashi * @since 2021-04-14 */ +@Mapper public interface TBasicMapper extends BaseMapper { /** * 根据住院号和住院次数查询业务系统中病案主键 diff --git a/docus-medical-record/src/main/resources/baseMapper/TBasicMapper.xml b/docus-medical-record/src/main/resources/mapper/TBasicMapper.xml similarity index 94% rename from docus-medical-record/src/main/resources/baseMapper/TBasicMapper.xml rename to docus-medical-record/src/main/resources/mapper/TBasicMapper.xml index 6d114ad..665c2bd 100644 --- a/docus-medical-record/src/main/resources/baseMapper/TBasicMapper.xml +++ b/docus-medical-record/src/main/resources/mapper/TBasicMapper.xml @@ -2,7 +2,7 @@ - + select patient_id from t_basic where jzh=#{jzh} - select * from `docus_medicalrecord`.`t_basic` where admiss_date between #{admissStartDate} AND #{admissEndDate} @@ -114,7 +114,7 @@ from `docus_medicalrecord`.`t_basic_extend` where patient_id=#{patientId} - select `patient_id`, `admiss_times`, `inpatient_no`, @@ -137,7 +137,7 @@ limit #{offset} , #{size} - select `patient_id`, `admiss_times`, `inpatient_no`, diff --git a/docus-sys/pom.xml b/docus-sys/pom.xml index 4af915f..77bccd2 100644 --- a/docus-sys/pom.xml +++ b/docus-sys/pom.xml @@ -9,4 +9,18 @@ docus-sys Archetype - docus-sys http://maven.apache.org + + + + + src/main/java + + **/*.xml + + + + src/main/resources + + + diff --git a/docus-sys/src/main/java/com/docus/server/sys/mapper/PowerDeptMapper.java b/docus-sys/src/main/java/com/docus/server/sys/mapper/PowerDeptMapper.java index 6da49e7..cf903fd 100644 --- a/docus-sys/src/main/java/com/docus/server/sys/mapper/PowerDeptMapper.java +++ b/docus-sys/src/main/java/com/docus/server/sys/mapper/PowerDeptMapper.java @@ -1,8 +1,9 @@ package com.docus.server.sys.mapper; import com.baomidou.mybatisplus.core.mapper.BaseMapper; -import com.docus.server.sys.pojo.entity.PowerDept; import com.docus.server.sys.pojo.dto.DeptModifyParam; +import com.docus.server.sys.pojo.entity.PowerDept; +import org.apache.ibatis.annotations.Mapper; import org.apache.ibatis.annotations.Param; /** @@ -13,6 +14,7 @@ import org.apache.ibatis.annotations.Param; * @author wen yongbin * @since 2023年2月25日22:28:58 */ +@Mapper public interface PowerDeptMapper extends BaseMapper { /** diff --git a/docus-sys/src/main/java/com/docus/server/sys/mapper/PowerUserMapper.java b/docus-sys/src/main/java/com/docus/server/sys/mapper/PowerUserMapper.java index bdfb81e..f74fd35 100644 --- a/docus-sys/src/main/java/com/docus/server/sys/mapper/PowerUserMapper.java +++ b/docus-sys/src/main/java/com/docus/server/sys/mapper/PowerUserMapper.java @@ -1,8 +1,9 @@ package com.docus.server.sys.mapper; import com.baomidou.mybatisplus.core.mapper.BaseMapper; -import com.docus.server.sys.pojo.entity.PowerUser; import com.docus.server.sys.pojo.dto.UserModifyParam; +import com.docus.server.sys.pojo.entity.PowerUser; +import org.apache.ibatis.annotations.Mapper; import org.apache.ibatis.annotations.Param; /** @@ -13,6 +14,7 @@ import org.apache.ibatis.annotations.Param; * @author wen yongbin * @since 2023年2月25日22:28:58 */ +@Mapper public interface PowerUserMapper extends BaseMapper { /** diff --git a/docus-sys/src/main/java/com/docus/server/sys/service/DeptService.java b/docus-sys/src/main/java/com/docus/server/sys/service/DeptService.java index 899a904..8815f8e 100644 --- a/docus-sys/src/main/java/com/docus/server/sys/service/DeptService.java +++ b/docus-sys/src/main/java/com/docus/server/sys/service/DeptService.java @@ -8,7 +8,7 @@ import java.util.List; @Component @AllArgsConstructor -public class DeptService implements IDeptService{ +public class DeptService implements IDeptService { private final IDeptDao deptDao; diff --git a/docus-sys/src/main/java/com/docus/server/sys/service/IPowerDeptService.java b/docus-sys/src/main/java/com/docus/server/sys/service/IPowerDeptService.java index 23e9c30..9f445dd 100644 --- a/docus-sys/src/main/java/com/docus/server/sys/service/IPowerDeptService.java +++ b/docus-sys/src/main/java/com/docus/server/sys/service/IPowerDeptService.java @@ -2,10 +2,20 @@ package com.docus.server.sys.service; import com.docus.server.sys.pojo.dto.DeptDTO; +import java.util.List; + /** * 用户服务 */ public interface IPowerDeptService { + /** + * 科室注册 + * + * @param deptDTOList 用户注册参数 + * @return 处理结果 + */ + void batchSavePowerDept(List deptDTOList); + /** * 科室注册 * diff --git a/docus-sys/src/main/java/com/docus/server/sys/service/impl/PowerDeptServiceImpl.java b/docus-sys/src/main/java/com/docus/server/sys/service/impl/PowerDeptServiceImpl.java index 6695e56..993f9d2 100644 --- a/docus-sys/src/main/java/com/docus/server/sys/service/impl/PowerDeptServiceImpl.java +++ b/docus-sys/src/main/java/com/docus/server/sys/service/impl/PowerDeptServiceImpl.java @@ -4,13 +4,14 @@ import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.docus.core.util.Func; import com.docus.infrastructure.redis.service.IdService; import com.docus.server.sys.mapper.PowerDeptMapper; -import com.docus.server.sys.pojo.entity.PowerDept; import com.docus.server.sys.pojo.dto.DeptDTO; import com.docus.server.sys.pojo.dto.DeptModifyParam; +import com.docus.server.sys.pojo.entity.PowerDept; import com.docus.server.sys.service.IPowerDeptService; import org.springframework.stereotype.Service; import javax.annotation.Resource; +import java.util.List; /** * 科室服务实现 @@ -19,34 +20,36 @@ import javax.annotation.Resource; */ @Service public class PowerDeptServiceImpl extends ServiceImpl implements IPowerDeptService { - // @Resource -// private PowerDeptMapper powerDeptMapper; @Resource private IdService idService; + @Override + public void batchSavePowerDept(List deptDTOList) { + deptDTOList.forEach(this::register); + } + @Override public boolean register(DeptDTO deptDTO) { -// PowerDept powerDept = powerDeptMapper.getDeptByDeptCode(deptDTO.getDeptCode()); - PowerDept powerDept = getBaseMapper().getDeptByDeptCode(deptDTO.getDeptCode()); + PowerDept powerDept = baseMapper.getDeptByDeptCode(deptDTO.getDeptCode()); DeptModifyParam deptModifyParam = deptDTO.transDeptAddParam(); if (Func.isEmpty(powerDept)) { long deptId = idService.getDateSeq(); deptModifyParam.setDeptId(deptId); - getBaseMapper().addDept(deptModifyParam); + baseMapper.addDept(deptModifyParam); return true; } deptModifyParam.setDeptId(powerDept.getDeptId()); - getBaseMapper().updateDept(deptModifyParam); + baseMapper.updateDept(deptModifyParam); return true; } @Override public boolean delDeptByDeptCode(String deptCode) { - PowerDept powerDept = getBaseMapper().getDeptByDeptCode(deptCode); + PowerDept powerDept = baseMapper.getDeptByDeptCode(deptCode); if (Func.isEmpty(powerDept)) { return true; } - getBaseMapper().delDeptByDeptCode(deptCode); + baseMapper.delDeptByDeptCode(deptCode); return true; } } diff --git a/docus-sys/src/main/java/com/docus/server/sys/service/impl/PowerUserServiceImpl.java b/docus-sys/src/main/java/com/docus/server/sys/service/impl/PowerUserServiceImpl.java index 893b385..46dc2de 100644 --- a/docus-sys/src/main/java/com/docus/server/sys/service/impl/PowerUserServiceImpl.java +++ b/docus-sys/src/main/java/com/docus/server/sys/service/impl/PowerUserServiceImpl.java @@ -30,27 +30,27 @@ public class PowerUserServiceImpl extends ServiceImpl - + INSERT INTO `docus_system`.`power_dept`(`dept_id`, `dept_code`, diff --git a/docus-sys/src/main/resources/baseMapper/PowerUserMapper.xml b/docus-sys/src/main/resources/mapper/PowerUserMapper.xml similarity index 96% rename from docus-sys/src/main/resources/baseMapper/PowerUserMapper.xml rename to docus-sys/src/main/resources/mapper/PowerUserMapper.xml index 246d97a..9d13962 100644 --- a/docus-sys/src/main/resources/baseMapper/PowerUserMapper.xml +++ b/docus-sys/src/main/resources/mapper/PowerUserMapper.xml @@ -2,7 +2,7 @@ - + INSERT INTO `docus_system`.`power_user`(`user_id`, `user_name`, diff --git a/his-sysem/pom.xml b/his-sysem/pom.xml index 933d8dd..f5074bc 100644 --- a/his-sysem/pom.xml +++ b/his-sysem/pom.xml @@ -17,4 +17,18 @@ compile + + + + + src/main/java + + **/*.xml + + + + src/main/resources + + + diff --git a/his-sysem/src/main/java/com/docus/server/his/infrastructure/HisSysDao.java b/his-sysem/src/main/java/com/docus/server/his/infrastructure/HisSysDao.java index 4fc4a31..9b94eb5 100644 --- a/his-sysem/src/main/java/com/docus/server/his/infrastructure/HisSysDao.java +++ b/his-sysem/src/main/java/com/docus/server/his/infrastructure/HisSysDao.java @@ -1,7 +1,7 @@ package com.docus.server.his.infrastructure; import com.docus.server.his.infrastructure.mapper.HisDeptMapper; -import com.docus.server.sys.service.Dept; +import com.docus.server.sys.pojo.dto.DeptDTO; import lombok.AllArgsConstructor; import org.springframework.stereotype.Component; @@ -16,8 +16,8 @@ public class HisSysDao { private final HisDeptMapper hisDeptMapper; - public List getDeptListView(Date startDate, Date endDate, long pazeNum, long pageSize) { - return hisDeptMapper.getDeptListView(startDate, endDate, pazeNum, pageSize); + public List getDeptListView(Date startDate, Date endDate, long pageNum, long pageSize) { + return hisDeptMapper.getDeptListView(startDate, endDate, (pageNum - 1) * pageSize, pageSize); } diff --git a/his-sysem/src/main/java/com/docus/server/his/infrastructure/mapper/HisDeptMapper.java b/his-sysem/src/main/java/com/docus/server/his/infrastructure/mapper/HisDeptMapper.java index ef07ede..ceff497 100644 --- a/his-sysem/src/main/java/com/docus/server/his/infrastructure/mapper/HisDeptMapper.java +++ b/his-sysem/src/main/java/com/docus/server/his/infrastructure/mapper/HisDeptMapper.java @@ -1,12 +1,16 @@ package com.docus.server.his.infrastructure.mapper; -import com.docus.server.sys.service.Dept; +import com.baomidou.dynamic.datasource.annotation.DS; +import com.docus.server.sys.pojo.dto.DeptDTO; +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 HisDeptMapper { - public List getDeptListView(@Param("startDate") Date startDate, @Param("endDate") Date endDate, @Param("pageNum") long pageNum, @Param("pageSize") long pageSize); + List getDeptListView(@Param("startDate") Date startDate, @Param("endDate") Date endDate, @Param("offset") long offset, @Param("pageSize") long pageSize); } diff --git a/his-sysem/src/main/java/com/docus/server/his/service/IHisService.java b/his-sysem/src/main/java/com/docus/server/his/service/IHisService.java index 249c6ca..1619a8b 100644 --- a/his-sysem/src/main/java/com/docus/server/his/service/IHisService.java +++ b/his-sysem/src/main/java/com/docus/server/his/service/IHisService.java @@ -1,10 +1,10 @@ package com.docus.server.his.service; -import com.docus.server.sys.service.Dept; +import com.docus.server.sys.pojo.dto.DeptDTO; import java.util.Date; import java.util.List; public interface IHisService { - List getDeptListView(Date startDate, Date endDate, long pazeNum, long pageSize); + List getDeptListView(Date startDate, Date endDate, long pazeNum, long pageSize); } diff --git a/his-sysem/src/main/java/com/docus/server/his/service/impl/HisService.java b/his-sysem/src/main/java/com/docus/server/his/service/impl/HisService.java index f95a97b..018a7b4 100644 --- a/his-sysem/src/main/java/com/docus/server/his/service/impl/HisService.java +++ b/his-sysem/src/main/java/com/docus/server/his/service/impl/HisService.java @@ -1,9 +1,8 @@ package com.docus.server.his.service.impl; -import com.baomidou.dynamic.datasource.annotation.DS; import com.docus.server.his.infrastructure.HisSysDao; import com.docus.server.his.service.IHisService; -import com.docus.server.sys.service.Dept; +import com.docus.server.sys.pojo.dto.DeptDTO; import lombok.AllArgsConstructor; import org.springframework.stereotype.Component; @@ -16,9 +15,9 @@ public class HisService implements IHisService { private final HisSysDao hisSysDao; - @DS("his") + @Override - public List getDeptListView(Date startDate, Date endDate, long pazeNum, long pageSize) { + public List getDeptListView(Date startDate, Date endDate, long pazeNum, long pageSize) { return hisSysDao.getDeptListView(startDate, endDate, pazeNum, pageSize); } diff --git a/his-sysem/src/main/resources/baseMapper/HisDeptMapper.xml b/his-sysem/src/main/resources/mapper/HisDeptMapper.xml similarity index 73% rename from his-sysem/src/main/resources/baseMapper/HisDeptMapper.xml rename to his-sysem/src/main/resources/mapper/HisDeptMapper.xml index bcb0a3b..1596b58 100644 --- a/his-sysem/src/main/resources/baseMapper/HisDeptMapper.xml +++ b/his-sysem/src/main/resources/mapper/HisDeptMapper.xml @@ -2,18 +2,18 @@ - + - + SELECT `update_time` as update_time ,`dept_code` as dept_code,`dept_name` as dept_name FROM `his_dept` WHERE update_time between #{startDate} and #{endDate} order by update_time asc - LIMIT (#{pageNum} - 1) * #{pageSize} , #{pageSize} + LIMIT #{offset}, #{pageSize} + + + com.alibaba.cloud @@ -58,11 +58,7 @@ - - mysql - mysql-connector-java - 8.0.28 - + org.projectlombok lombok @@ -85,12 +81,13 @@ 1.2.4 compile + - com.baomidou - mybatis-plus-generator - 3.4.1 - compile + com.alibaba + druid-spring-boot-starter + ${druid.version} + org.apache.velocity velocity-engine-core @@ -185,13 +182,22 @@ spring-boot-starter-test test - + + + com.baomidou + mybatis-plus-boot-starter + 3.4.0 + + + mysql + mysql-connector-java + runtime + com.baomidou dynamic-datasource-spring-boot-starter - 3.3.2 + 3.4.0 - @@ -207,6 +213,4 @@ - - \ No newline at end of file