From 42ecb4e71fcb8a7e32f1d618d369013385405cc0 Mon Sep 17 00:00:00 2001 From: leijx <1477272687@qq.com> Date: Fri, 29 Jan 2021 17:04:52 +0800 Subject: [PATCH] =?UTF-8?q?1=E3=80=81=E6=96=B0=E5=A2=9E=E6=8E=A5=E6=94=B6?= =?UTF-8?q?=E7=94=B5=E5=AD=90=E7=97=85=E5=8E=86=E6=96=87=E4=B9=A6=E6=88=96?= =?UTF-8?q?=E6=8A=A4=E7=90=86=E6=96=87=E4=BB=B6=EF=BC=8C=E5=9C=A8master?= =?UTF-8?q?=E8=A1=A8=E5=AD=98=E5=85=A5=E7=94=B5=E5=AD=90=E7=97=85=E5=8E=86?= =?UTF-8?q?=E5=8C=BB=E7=94=9F=E6=8F=90=E4=BA=A4=E6=97=B6=E9=97=B4=E3=80=81?= =?UTF-8?q?=E7=94=B5=E5=AD=90=E7=97=85=E5=8E=86=E6=8A=A4=E5=A3=AB=E6=8F=90?= =?UTF-8?q?=E4=BA=A4=E6=97=B6=E9=97=B4=202=E3=80=81=E6=9B=B4=E6=94=B9?= =?UTF-8?q?=E6=A3=80=E9=AA=8C=E6=8A=A5=E5=91=8A=E8=A6=86=E7=9B=96=E5=A4=84?= =?UTF-8?q?=E7=90=86=E4=BD=BF=E7=94=A8=E6=8A=A5=E5=91=8A=E5=8D=95=E5=8F=B7?= =?UTF-8?q?=203=E3=80=81=E6=96=B0=E5=A2=9E=E6=A3=80=E9=AA=8C=E6=8A=A5?= =?UTF-8?q?=E5=91=8A=20=E9=99=A4=E4=BA=86=E5=BD=92=E6=A1=A3=E7=8A=B6?= =?UTF-8?q?=E6=80=81=E4=B8=BA=E5=B7=B2=E5=BD=92=E6=A1=A3=E6=8B=A6=E6=88=AA?= =?UTF-8?q?=EF=BC=8C=E5=85=B6=E4=BB=96=E7=8A=B6=E6=80=81=E4=B8=8D=E6=8B=A6?= =?UTF-8?q?=E6=88=AA=EF=BC=88=E7=AD=89lis=E5=8D=87=E7=BA=A7=E4=B9=8B?= =?UTF-8?q?=E5=90=8E=E6=A3=80=E9=AA=8C=E6=8A=A5=E5=91=8A=E5=8F=96=E6=B6=88?= =?UTF-8?q?=E4=B8=8D=E6=8B=A6=E6=88=AA=EF=BC=89=204=E3=80=81=E6=96=B0?= =?UTF-8?q?=E5=A2=9E=E4=B8=8B=E8=BD=BDpdf=E6=A0=BC=E5=BC=8F=E6=96=87?= =?UTF-8?q?=E4=BB=B6=EF=BC=8C=E5=BD=93=E6=96=87=E4=BB=B6=E5=A4=A7=E5=B0=8F?= =?UTF-8?q?=E5=B0=8F=E4=BA=8E<10=E8=BF=9B=E8=A1=8C=E5=88=A0=E9=99=A4?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/ann/entity/filing/dto/MessageDto.java | 5 ++ .../entity/interfaceEntity/ArchiveMaster.java | 12 ++++ .../repository/ArchiveDetailRepository.java | 6 ++ .../repository/ArchiveMasterRepository.java | 2 +- .../com/ann/service/ArchiveDetailService.java | 2 + .../impl/ArchiveDetailServiceImpl.java | 7 +++ .../com/ann/service/impl/QueueService.java | 55 ++++++++++++++++--- src/main/java/com/ann/utils/FTPUtil.java | 2 +- src/main/resources/application.yml | 38 ++++++------- 9 files changed, 100 insertions(+), 29 deletions(-) diff --git a/src/main/java/com/ann/entity/filing/dto/MessageDto.java b/src/main/java/com/ann/entity/filing/dto/MessageDto.java index 4fca018..12898a4 100644 --- a/src/main/java/com/ann/entity/filing/dto/MessageDto.java +++ b/src/main/java/com/ann/entity/filing/dto/MessageDto.java @@ -54,6 +54,11 @@ public class MessageDto { //20200609 0是老数据 1是新数据 private String isOld; + /** + * 电子病历最后提交时间 + * */ + private Date emrCommitTime; + public MessageDto() { } diff --git a/src/main/java/com/ann/entity/interfaceEntity/ArchiveMaster.java b/src/main/java/com/ann/entity/interfaceEntity/ArchiveMaster.java index 30631df..d0947f9 100644 --- a/src/main/java/com/ann/entity/interfaceEntity/ArchiveMaster.java +++ b/src/main/java/com/ann/entity/interfaceEntity/ArchiveMaster.java @@ -154,4 +154,16 @@ public class ArchiveMaster { * */ private String firstInstance; + + /** + * 医生最后提交时间 + * */ + private Date emrDoctorCommitTime; + + /** + * 护士最后提交时间 + * */ + private Date emrNurseCommitTime; + + } diff --git a/src/main/java/com/ann/repository/ArchiveDetailRepository.java b/src/main/java/com/ann/repository/ArchiveDetailRepository.java index c3159c0..b050a9e 100644 --- a/src/main/java/com/ann/repository/ArchiveDetailRepository.java +++ b/src/main/java/com/ann/repository/ArchiveDetailRepository.java @@ -21,9 +21,15 @@ public interface ArchiveDetailRepository extends JpaRepository findArchiveMasterBySendBackAndSendTime(); } diff --git a/src/main/java/com/ann/service/ArchiveDetailService.java b/src/main/java/com/ann/service/ArchiveDetailService.java index a0c36c6..918c1e8 100644 --- a/src/main/java/com/ann/service/ArchiveDetailService.java +++ b/src/main/java/com/ann/service/ArchiveDetailService.java @@ -17,6 +17,8 @@ public interface ArchiveDetailService { public ArchiveDetail isExit(String id, String type, String source, String applyId) throws Exception; + public ArchiveDetail isExitCheckReportId(String id, String type, String source, String checkReportId) throws Exception; + // public String getTypeNotExits(List type, String masterId); // public String checkExamApply(String masterId) throws Exception; diff --git a/src/main/java/com/ann/service/impl/ArchiveDetailServiceImpl.java b/src/main/java/com/ann/service/impl/ArchiveDetailServiceImpl.java index bda007f..d5bcf56 100644 --- a/src/main/java/com/ann/service/impl/ArchiveDetailServiceImpl.java +++ b/src/main/java/com/ann/service/impl/ArchiveDetailServiceImpl.java @@ -39,6 +39,13 @@ public class ArchiveDetailServiceImpl implements ArchiveDetailService { return null; } + @Override + public ArchiveDetail isExitCheckReportId(String id, String type, String source, String checkReportId) throws Exception { + if (archiveDetailRepository.countByMasterIDAndAssortIDAndSourceAndCheckReportId(id, type, source, checkReportId) > 0) + return archiveDetailRepository.findByMasterIDAndAssortIDAndSourceAndCheckReportIdAndFlag(id, type, source, checkReportId,"0"); + return null; + } + // @Override // public String getTypeNotExits(List type, String masterId) { // return archiveDetailRepository.getTypeNotExits(type, masterId); diff --git a/src/main/java/com/ann/service/impl/QueueService.java b/src/main/java/com/ann/service/impl/QueueService.java index bb9ff4d..78751e9 100644 --- a/src/main/java/com/ann/service/impl/QueueService.java +++ b/src/main/java/com/ann/service/impl/QueueService.java @@ -64,14 +64,24 @@ public class QueueService { ArchiveMaster archiveMaster = archiveMasterService.findByInpNoAndVisitIdAndIsValid(messageDto.getInpNo(), messageDto.getVisitId()); Date date = new Date(); if (archiveMaster != null) { - if (!Objects.equals(messageDto.getType(), AliasName.PATHOLOGY_REPORT) || !Objects.equals(messageDto.getType(), AliasName.MEDICAL_RECORD_HOMEPAGE)) { - if (archiveMaster.getArchiveState().equals("初审") || archiveMaster.getArchiveState().equals("已归档")) { - messageSubordinate.setStatus(3); - messageSubordinateService.save(messageSubordinate); - continue; - } + /**2021-1-26 等lis程序升级 去掉*/ + if (Objects.equals(messageDto.getType(), AliasName.INSPECTION_REPORT) && archiveMaster.getArchiveState().equals("已归档")){ + messageSubordinate.setStatus(3); + messageSubordinateService.save(messageSubordinate); + continue; } + /**2021-1-26 等lis程序升级 去掉*/ + if ( !Objects.equals(messageDto.getType(), AliasName.PATHOLOGY_REPORT) + /**2021-1-26 等lis程序升级 去掉*/ + && !Objects.equals(messageDto.getType(), AliasName.INSPECTION_REPORT) + /**2021-1-26 等lis程序升级 去掉*/ + && (archiveMaster.getArchiveState().equals("初审") || archiveMaster.getArchiveState().equals("已归档")) + ){ + messageSubordinate.setStatus(3); + messageSubordinateService.save(messageSubordinate); + continue; + } String address = messageDto.getReportAddress(); if (address != null && (!address.equals(""))) { // 如果是老数据 @@ -82,7 +92,7 @@ public class QueueService { //如果是检验报告 单独处理 if(Objects.equals(messageDto.getType(),AliasName.INSPECTION_REPORT)){ // 查询库中是否存在 如果存在就更新 - archiveDetail = archiveDetailService.isExit(archiveMaster.getId(), messageDto.getType(), messageDto.getSource(), messageDto.getCheckReportId()); + archiveDetail = archiveDetailService.isExitCheckReportId(archiveMaster.getId(), messageDto.getType(), messageDto.getSource(), messageDto.getCheckReportId()); if (archiveDetail == null) { archiveDetail = new ArchiveDetail(archiveMaster.getId(), date, messageDto.getType(), messageDto.getSource(),messageDto.getApplyId(), messageDto.getCheckReportId(), messageDto.getDetailType()); @@ -109,8 +119,22 @@ public class QueueService { Integer pageNum = 1; if (messageDto.getSource().equals(InterfaceName.NURSE_DATA)) { // 护理单独做处理 + boolean saveFlag = false; + + if(archiveMaster.getEmrNurseCommitTime() == null ){ + archiveMaster.setEmrNurseCommitTime(messageDto.getEmrCommitTime()); + saveFlag = true; + }else if(messageDto.getEmrCommitTime() != null && archiveMaster.getEmrNurseCommitTime() !=null && + !Objects.equals( messageDto.getEmrCommitTime().getTime(),archiveMaster.getEmrNurseCommitTime().getTime())){ + archiveMaster.setEmrNurseCommitTime(messageDto.getEmrCommitTime()); + saveFlag = true; + } + if (archiveMaster.getEmrNurseCmt() == null) { archiveMaster.setEmrNurseCmt("提交"); + saveFlag = true; + } + if(saveFlag){ archiveMasterService.save(archiveMaster); } @@ -134,8 +158,22 @@ public class QueueService { } else if (messageDto.getSource().equals(InterfaceName.DOCTOR_DATA)) { // 医生单独做处理 + boolean saveFlag = false; + + if(archiveMaster.getEmrDoctorCommitTime() == null ){ + archiveMaster.setEmrDoctorCommitTime(messageDto.getEmrCommitTime()); + saveFlag = true; + }else if(messageDto.getEmrCommitTime() != null && archiveMaster.getEmrDoctorCommitTime() !=null && + !Objects.equals( messageDto.getEmrCommitTime().getTime(),archiveMaster.getEmrDoctorCommitTime().getTime())){ + archiveMaster.setEmrDoctorCommitTime(messageDto.getEmrCommitTime()); + saveFlag = true; + } + if (archiveMaster.getEmrDoctorCmt() == null) { archiveMaster.setEmrDoctorCmt("提交"); + saveFlag = true; + } + if(saveFlag){ archiveMasterService.save(archiveMaster); } tempPath = messageDto.getType() + "~" + messageDto.getCaptionDateTime() + "~"; @@ -218,11 +256,12 @@ public class QueueService { messageSubordinate.setRemark("住院号为：" + messageDto.getInpNo() + "的ArchiveMaster为空。。。。"); } } + } } } catch (Exception e) { // 设置参数 - messageSubordinate.setRemark(e + ""); + messageSubordinate.setRemark(e + ",问题发生时间："+new Date()); // 报错删掉患者报告详情信息 if (archiveDetail != null) { if (archiveDetail.getId() != null) { diff --git a/src/main/java/com/ann/utils/FTPUtil.java b/src/main/java/com/ann/utils/FTPUtil.java index 880be2f..4155cbb 100644 --- a/src/main/java/com/ann/utils/FTPUtil.java +++ b/src/main/java/com/ann/utils/FTPUtil.java @@ -106,7 +106,7 @@ public class FTPUtil { } closeFTPConnect(ftp); } - if(file.length() == 0){ + if(file.length() == 0 || file.length() < 10){ FileUtils.deleteImageFile(file); }else{ result = true; diff --git a/src/main/resources/application.yml b/src/main/resources/application.yml index 5949f10..14a7805 100644 --- a/src/main/resources/application.yml +++ b/src/main/resources/application.yml @@ -1,25 +1,25 @@ spring: datasource: - url: jdbc:mysql://localhost:3306/test - # url: jdbc:mysql://10.6.1.127:3306/test - username: root - password: 123456 - driver-class-name: com.mysql.jdbc.Driver + # url: jdbc:mysql://localhost:3306/test + # # url: jdbc:mysql://10.6.1.127:3306/test + # username: root + # password: 123456 + # driver-class-name: com.mysql.jdbc.Driver + # jpa: + # database: mysql + # show-sql: false + # hibernate: + # ddl-auto: update + url: jdbc:sqlserver://10.6.1.127:1433;DatabaseName=DB_PrivilegeManagement_GYFY + # url: jdbc:sqlserver://120.27.212.36:1433;DatabaseName=emr_record + username: sa + password: docus@702 + driver-class-name: com.microsoft.sqlserver.jdbc.SQLServerDriver jpa: - database: mysql + database: sql_server show-sql: false hibernate: - ddl-auto: update - # url: jdbc:sqlserver://10.6.1.127:1433;DatabaseName=DB_PrivilegeManagement_GYFY - # # url: jdbc:sqlserver://120.27.212.36:1433;DatabaseName=emr_record - # username: sa - # password: docus@702 - # driver-class-name: com.microsoft.sqlserver.jdbc.SQLServerDriver - # jpa: - # database: sql_server - # show-sql: false - # hibernate: - # dialect: org.hibernate.dialect.SQLServer2008Dialect + dialect: org.hibernate.dialect.SQLServer2008Dialect thymeleaf: prefix: classpath:/templates/ @@ -50,8 +50,8 @@ file: dischargeRecordPath: D:\\1\dischargeRecord.properties transferRecordPath: D:\\1\transferRecord.properties admissionRecordPath: D:\\1\admissionRecord.properties - pdfPath: D:/project_js - imagePath: D:/images + pdfPath: Z:/project_js + imagePath: Z:/images signContent: 0