|
@@ -9,9 +9,11 @@ import com.diagbot.facade.MedLisInfoFacade;
|
|
|
import com.diagbot.facade.MedPacsInfoFacade;
|
|
|
import com.diagbot.facade.str.*;
|
|
|
import com.diagbot.util.FJTZDBConnHarp;
|
|
|
+import com.diagbot.util.MapUtil;
|
|
|
import com.diagbot.util.ReadProperties;
|
|
|
import com.diagbot.vo.data.*;
|
|
|
import lombok.extern.slf4j.Slf4j;
|
|
|
+import org.apache.commons.collections4.CollectionUtils;
|
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
|
import org.springframework.stereotype.Component;
|
|
|
|
|
@@ -100,29 +102,31 @@ public class StructuralOldDataFacade {
|
|
|
@Autowired
|
|
|
private MedPacsInfoFacade medPacsInfoFacade;
|
|
|
|
|
|
+
|
|
|
private FJTZDBConnHarp fjtzdbConnHarp = new FJTZDBConnHarp();
|
|
|
|
|
|
|
|
|
/**
|
|
|
* 终末质控,根据时间来导入数据
|
|
|
+ *
|
|
|
* @param structuralDataVo
|
|
|
*/
|
|
|
- public void sendStructuralDataOld(StructuralDataVo structuralDataVo){
|
|
|
+ public void sendStructuralDataOld(StructuralDataVo structuralDataVo) {
|
|
|
try {
|
|
|
- String sql ="select * from med_behospital_info t where t.leaveHospitalDate >=to_date('"+structuralDataVo.getStartDate()
|
|
|
- + "','yyyymmdd') and t.leaveHospitalDate <= to_date('"+structuralDataVo.getStopDate()+"','yyyymmdd')";
|
|
|
+ String sql = "select * from med_behospital_info t where t.behospitalDate >=to_date('" + structuralDataVo.getStartDate()
|
|
|
+ + "','yyyymmdd') and t.behospitalDate <= to_date('" + structuralDataVo.getStopDate() + "','yyyymmdd')";
|
|
|
|
|
|
// String sql ="select t.behospitalCode ,t.patientId from med_behospital_info t where t.leaveHospitalDate is null";
|
|
|
- List<StructuralDataVo> strings =fjtzdbConnHarp.getBehospitalInfoDate(sql);
|
|
|
+ List<StructuralDataVo> strings = fjtzdbConnHarp.getBehospitalInfoDate(sql);
|
|
|
|
|
|
- strings.forEach(s->{
|
|
|
- StructuralDataVo sData =new StructuralDataVo();
|
|
|
- if (null!=structuralDataVo.getModeId()){
|
|
|
+ strings.forEach(s -> {
|
|
|
+ StructuralDataVo sData = new StructuralDataVo();
|
|
|
+ if (null != structuralDataVo.getModeId()) {
|
|
|
sData.setBehospitalCode(s.getBehospitalCode());
|
|
|
sData.setPatientId(s.getPatientId());
|
|
|
sData.setModeId(structuralDataVo.getModeId());
|
|
|
executeOld(sData);
|
|
|
- }else {
|
|
|
+ } else {
|
|
|
for (int i = 0; i < 65; i++) {
|
|
|
String tableName = TableNameEnum.getName(i);
|
|
|
if (null != tableName) {
|
|
@@ -134,207 +138,206 @@ public class StructuralOldDataFacade {
|
|
|
}
|
|
|
}
|
|
|
});
|
|
|
- }catch (Exception e){
|
|
|
- aMedAbnormalInfoFacade.saveAbnormalInfo("保存数据异常", "",JSON.toJSONString(structuralDataVo),"",e.getMessage());
|
|
|
+ } catch (Exception e) {
|
|
|
+ aMedAbnormalInfoFacade.saveAbnormalInfo("保存数据异常", "", JSON.toJSONString(structuralDataVo), "", e.getMessage());
|
|
|
}
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
* 终末质控,单个病人来导入数据
|
|
|
+ *
|
|
|
* @param behospitalCode
|
|
|
*/
|
|
|
- public void sendOnebehospitalCode(String behospitalCode,String patientId){
|
|
|
- StructuralDataVo sData =new StructuralDataVo();
|
|
|
- sData.setBehospitalCode(behospitalCode);
|
|
|
- sData.setPatientId(patientId);
|
|
|
- for (int i = 65; i >0 ; i--) {
|
|
|
- String tableName=TableNameEnum.getName(i);
|
|
|
- if (null!=tableName){
|
|
|
- sData.setModeId(String.valueOf(i));
|
|
|
- executeOld(sData);
|
|
|
- }
|
|
|
+ public void sendOnebehospitalCode(String behospitalCode, String patientId) {
|
|
|
+ StructuralDataVo sData = new StructuralDataVo();
|
|
|
+ sData.setBehospitalCode(behospitalCode);
|
|
|
+ sData.setPatientId(patientId);
|
|
|
+ for (int i = 65; i > 0; i--) {
|
|
|
+ String tableName = TableNameEnum.getName(i);
|
|
|
+ if (null != tableName) {
|
|
|
+ sData.setModeId(String.valueOf(i));
|
|
|
+ executeOld(sData);
|
|
|
}
|
|
|
+ }
|
|
|
}
|
|
|
|
|
|
|
|
|
-
|
|
|
-
|
|
|
-
|
|
|
/**
|
|
|
* 终末,历史数据拉取
|
|
|
+ *
|
|
|
* @param s
|
|
|
*/
|
|
|
- public void executeOld(StructuralDataVo s){
|
|
|
+ public void executeOld(StructuralDataVo s) {
|
|
|
String modelName = ModeIdEnum.getName(Integer.parseInt(s.getModeId()));
|
|
|
s.setTableName(TableNameEnum.getName(Integer.parseInt(s.getModeId())));
|
|
|
try {
|
|
|
- if("首次病程录".equals(modelName)){
|
|
|
- List<HisViewVo> hisViewVos =fjtzdbConnHarp.getHisView(this.sqlOld(s));
|
|
|
- if (hisViewVos.size()>0){
|
|
|
- Map<String,List<HisViewVo>> map=this.executeOldDeci(hisViewVos);
|
|
|
- for (String key:map.keySet()){
|
|
|
- aStrFirstRecordFacade.getOneList(map.get(key),s.getModeId());
|
|
|
+ if ("首次病程录".equals(modelName)) {
|
|
|
+ List<HisViewVo> hisViewVos = fjtzdbConnHarp.getHisView(this.sqlOld(s));
|
|
|
+ if (hisViewVos.size() > 0) {
|
|
|
+ Map<String, List<HisViewVo>> map = this.executeOldDeci(hisViewVos);
|
|
|
+ for (String key : map.keySet()) {
|
|
|
+ aStrFirstRecordFacade.getOneList(map.get(key), s.getModeId());
|
|
|
}
|
|
|
}
|
|
|
- }else if("输血后效果评价".equals(modelName)){
|
|
|
- List<HisViewVo> hisViewVos =fjtzdbConnHarp.getHisView(this.sqlOld(s));
|
|
|
- if (hisViewVos.size()>0){
|
|
|
- Map<String,List<HisViewVo>> map=this.executeOldDeci(hisViewVos);
|
|
|
- for (String key:map.keySet()) {
|
|
|
- aStrBloodResultFacade.getOneList(map.get(key),s.getModeId());
|
|
|
+ } else if ("输血后效果评价".equals(modelName)) {
|
|
|
+ List<HisViewVo> hisViewVos = fjtzdbConnHarp.getHisView(this.sqlOld(s));
|
|
|
+ if (hisViewVos.size() > 0) {
|
|
|
+ Map<String, List<HisViewVo>> map = this.executeOldDeci(hisViewVos);
|
|
|
+ for (String key : map.keySet()) {
|
|
|
+ aStrBloodResultFacade.getOneList(map.get(key), s.getModeId());
|
|
|
}
|
|
|
}
|
|
|
- }else if("输血/血制品病程记录".equals(modelName)){
|
|
|
- List<HisViewVo> hisViewVos =fjtzdbConnHarp.getHisView(this.sqlOld(s));
|
|
|
- if (hisViewVos.size()>0){
|
|
|
- Map<String,List<HisViewVo>> map=this.executeOldDeci(hisViewVos);
|
|
|
- for (String key:map.keySet()) {
|
|
|
- aStrBloodTransfusionFacade.getOneList(map.get(key),s.getModeId());
|
|
|
+ } else if ("输血/血制品病程记录".equals(modelName)) {
|
|
|
+ List<HisViewVo> hisViewVos = fjtzdbConnHarp.getHisView(this.sqlOld(s));
|
|
|
+ if (hisViewVos.size() > 0) {
|
|
|
+ Map<String, List<HisViewVo>> map = this.executeOldDeci(hisViewVos);
|
|
|
+ for (String key : map.keySet()) {
|
|
|
+ aStrBloodTransfusionFacade.getOneList(map.get(key), s.getModeId());
|
|
|
}
|
|
|
}
|
|
|
- }else if("转入记录".equals(modelName)){
|
|
|
- List<HisViewVo> hisViewVos =fjtzdbConnHarp.getHisView(this.sqlOld(s));
|
|
|
- if (hisViewVos.size()>0){
|
|
|
- Map<String,List<HisViewVo>> map=this.executeOldDeci(hisViewVos);
|
|
|
- for (String key:map.keySet()) {
|
|
|
- aStrTransferInNoteFacade.getOneList(map.get(key),s.getModeId());
|
|
|
+ } else if ("转入记录".equals(modelName)) {
|
|
|
+ List<HisViewVo> hisViewVos = fjtzdbConnHarp.getHisView(this.sqlOld(s));
|
|
|
+ if (hisViewVos.size() > 0) {
|
|
|
+ Map<String, List<HisViewVo>> map = this.executeOldDeci(hisViewVos);
|
|
|
+ for (String key : map.keySet()) {
|
|
|
+ aStrTransferInNoteFacade.getOneList(map.get(key), s.getModeId());
|
|
|
}
|
|
|
}
|
|
|
- }else if("转出记录".equals(modelName)){
|
|
|
- List<HisViewVo> hisViewVos =fjtzdbConnHarp.getHisView(this.sqlOld(s));
|
|
|
- if (hisViewVos.size()>0){
|
|
|
- Map<String,List<HisViewVo>> map=this.executeOldDeci(hisViewVos);
|
|
|
- for (String key:map.keySet()) {
|
|
|
- aStrTransferOutNoteFacade.getOneList(map.get(key),s.getModeId());
|
|
|
+ } else if ("转出记录".equals(modelName)) {
|
|
|
+ List<HisViewVo> hisViewVos = fjtzdbConnHarp.getHisView(this.sqlOld(s));
|
|
|
+ if (hisViewVos.size() > 0) {
|
|
|
+ Map<String, List<HisViewVo>> map = this.executeOldDeci(hisViewVos);
|
|
|
+ for (String key : map.keySet()) {
|
|
|
+ aStrTransferOutNoteFacade.getOneList(map.get(key), s.getModeId());
|
|
|
}
|
|
|
}
|
|
|
- }else if("病危通知书".equals(modelName)){
|
|
|
- List<HisViewVo> hisViewVos =fjtzdbConnHarp.getHisView(this.sqlOld(s));
|
|
|
- if (hisViewVos.size()>0){
|
|
|
- Map<String,List<HisViewVo>> map=this.executeOldDeci(hisViewVos);
|
|
|
- for (String key:map.keySet()) {
|
|
|
- aStrIllCriticallyFacade.getOneList(map.get(key),s.getModeId());
|
|
|
+ } else if ("病危通知书".equals(modelName)) {
|
|
|
+ List<HisViewVo> hisViewVos = fjtzdbConnHarp.getHisView(this.sqlOld(s));
|
|
|
+ if (hisViewVos.size() > 0) {
|
|
|
+ Map<String, List<HisViewVo>> map = this.executeOldDeci(hisViewVos);
|
|
|
+ for (String key : map.keySet()) {
|
|
|
+ aStrIllCriticallyFacade.getOneList(map.get(key), s.getModeId());
|
|
|
}
|
|
|
}
|
|
|
- }else if("病重通知书".equals(modelName)){
|
|
|
- List<HisViewVo> hisViewVos =fjtzdbConnHarp.getHisView(this.sqlOld(s));
|
|
|
- if (hisViewVos.size()>0){
|
|
|
- Map<String,List<HisViewVo>> map=this.executeOldDeci(hisViewVos);
|
|
|
- for (String key:map.keySet()) {
|
|
|
- aStrIllSeriouslFacade.getOneList(map.get(key),s.getModeId());
|
|
|
+ } else if ("病重通知书".equals(modelName)) {
|
|
|
+ List<HisViewVo> hisViewVos = fjtzdbConnHarp.getHisView(this.sqlOld(s));
|
|
|
+ if (hisViewVos.size() > 0) {
|
|
|
+ Map<String, List<HisViewVo>> map = this.executeOldDeci(hisViewVos);
|
|
|
+ for (String key : map.keySet()) {
|
|
|
+ aStrIllSeriouslFacade.getOneList(map.get(key), s.getModeId());
|
|
|
}
|
|
|
}
|
|
|
- }else if("疑难病例讨论记录".equals(modelName)){
|
|
|
- List<HisViewVo> hisViewVos =fjtzdbConnHarp.getHisView(this.sqlOld(s));
|
|
|
- if (hisViewVos.size()>0){
|
|
|
- Map<String,List<HisViewVo>> map=this.executeOldDeci(hisViewVos);
|
|
|
- for (String key:map.keySet()) {
|
|
|
- aStrDifficultCaseFacade.getOneList(map.get(key),s.getModeId());
|
|
|
+ } else if ("疑难病例讨论记录".equals(modelName)) {
|
|
|
+ List<HisViewVo> hisViewVos = fjtzdbConnHarp.getHisView(this.sqlOld(s));
|
|
|
+ if (hisViewVos.size() > 0) {
|
|
|
+ Map<String, List<HisViewVo>> map = this.executeOldDeci(hisViewVos);
|
|
|
+ for (String key : map.keySet()) {
|
|
|
+ aStrDifficultCaseFacade.getOneList(map.get(key), s.getModeId());
|
|
|
}
|
|
|
}
|
|
|
- }else if("死亡记录".equals(modelName)){
|
|
|
- List<HisViewVo> hisViewVos =fjtzdbConnHarp.getHisView(this.sqlOld(s));
|
|
|
- if (hisViewVos.size()>0){
|
|
|
- Map<String,List<HisViewVo>> map=this.executeOldDeci(hisViewVos);
|
|
|
- for (String key:map.keySet()) {
|
|
|
- aStrDeathNoteFacade.getOneList(map.get(key),s.getModeId());
|
|
|
+ } else if ("死亡记录".equals(modelName)) {
|
|
|
+ List<HisViewVo> hisViewVos = fjtzdbConnHarp.getHisView(this.sqlOld(s));
|
|
|
+ if (hisViewVos.size() > 0) {
|
|
|
+ Map<String, List<HisViewVo>> map = this.executeOldDeci(hisViewVos);
|
|
|
+ for (String key : map.keySet()) {
|
|
|
+ aStrDeathNoteFacade.getOneList(map.get(key), s.getModeId());
|
|
|
}
|
|
|
}
|
|
|
- }else if("死亡病例讨论记录".equals(modelName)){
|
|
|
- List<HisViewVo> hisViewVos =fjtzdbConnHarp.getMedDeathDiscussion(this.sqlOld(s));
|
|
|
- if (hisViewVos.size()>0){
|
|
|
- Map<String,List<HisViewVo>> map=this.executeOldDeci(hisViewVos);
|
|
|
- for (String key:map.keySet()) {
|
|
|
- aStrDeathDiscussionFacade.getOneList(map.get(key),s.getModeId());
|
|
|
+ } else if ("死亡病例讨论记录".equals(modelName)) {
|
|
|
+ List<HisViewVo> hisViewVos = fjtzdbConnHarp.getMedDeathDiscussion(this.sqlOld(s));
|
|
|
+ if (hisViewVos.size() > 0) {
|
|
|
+ Map<String, List<HisViewVo>> map = this.executeOldDeci(hisViewVos);
|
|
|
+ for (String key : map.keySet()) {
|
|
|
+ aStrDeathDiscussionFacade.getOneList(map.get(key), s.getModeId());
|
|
|
}
|
|
|
}
|
|
|
- }else if("术后首次病程及谈话记录".equals(modelName)){
|
|
|
- List<HisViewVo> hisViewVos =fjtzdbConnHarp.getHisView(this.sqlOld(s));
|
|
|
- if (hisViewVos.size()>0){
|
|
|
- Map<String,List<HisViewVo>> map=this.executeOldDeci(hisViewVos);
|
|
|
- for (String key:map.keySet()) {
|
|
|
- aStrOperativeFirstRecord.getOneList(map.get(key),s.getModeId());
|
|
|
+ } else if ("术后首次病程及谈话记录".equals(modelName)) {
|
|
|
+ List<HisViewVo> hisViewVos = fjtzdbConnHarp.getHisView(this.sqlOld(s));
|
|
|
+ if (hisViewVos.size() > 0) {
|
|
|
+ Map<String, List<HisViewVo>> map = this.executeOldDeci(hisViewVos);
|
|
|
+ for (String key : map.keySet()) {
|
|
|
+ aStrOperativeFirstRecord.getOneList(map.get(key), s.getModeId());
|
|
|
}
|
|
|
}
|
|
|
- }else if("术前讨论、术前小结".equals(modelName)){
|
|
|
- List<HisViewVo> hisViewVos =fjtzdbConnHarp.getHisView(this.sqlOld(s));
|
|
|
- if (hisViewVos.size()>0){
|
|
|
- Map<String,List<HisViewVo>> map=this.executeOldDeci(hisViewVos);
|
|
|
- for (String key:map.keySet()) {
|
|
|
- aStrPreoperativeDiscussionFacade.getOneList(map.get(key),s.getModeId());
|
|
|
+ } else if ("术前讨论、术前小结".equals(modelName)) {
|
|
|
+ List<HisViewVo> hisViewVos = fjtzdbConnHarp.getHisView(this.sqlOld(s));
|
|
|
+ if (hisViewVos.size() > 0) {
|
|
|
+ Map<String, List<HisViewVo>> map = this.executeOldDeci(hisViewVos);
|
|
|
+ for (String key : map.keySet()) {
|
|
|
+ aStrPreoperativeDiscussionFacade.getOneList(map.get(key), s.getModeId());
|
|
|
}
|
|
|
}
|
|
|
- }else if("手术记录".equals(modelName)){
|
|
|
- List<HisViewVo> hisViewVos =fjtzdbConnHarp.getHisView(this.sqlOld(s));
|
|
|
- if (hisViewVos.size()>0){
|
|
|
- Map<String,List<HisViewVo>> map=this.executeOldDeci(hisViewVos);
|
|
|
- for (String key:map.keySet()) {
|
|
|
- aStrOperativeNoteFacade.getOneList(map.get(key),s.getModeId());
|
|
|
+ } else if ("手术记录".equals(modelName)) {
|
|
|
+ List<HisViewVo> hisViewVos = fjtzdbConnHarp.getHisView(this.sqlOld(s));
|
|
|
+ if (hisViewVos.size() > 0) {
|
|
|
+ Map<String, List<HisViewVo>> map = this.executeOldDeci(hisViewVos);
|
|
|
+ for (String key : map.keySet()) {
|
|
|
+ aStrOperativeNoteFacade.getOneList(map.get(key), s.getModeId());
|
|
|
}
|
|
|
}
|
|
|
- }else if("抢救记录".equals(modelName)){
|
|
|
- List<HisViewVo> hisViewVos =fjtzdbConnHarp.getHisView(this.sqlOld(s));
|
|
|
- if (hisViewVos.size()>0){
|
|
|
- Map<String,List<HisViewVo>> map=this.executeOldDeci(hisViewVos);
|
|
|
- for (String key:map.keySet()) {
|
|
|
- aStrRescueNoteFacade.getOneList(map.get(key),s.getModeId());
|
|
|
+ } else if ("抢救记录".equals(modelName)) {
|
|
|
+ List<HisViewVo> hisViewVos = fjtzdbConnHarp.getHisView(this.sqlOld(s));
|
|
|
+ if (hisViewVos.size() > 0) {
|
|
|
+ Map<String, List<HisViewVo>> map = this.executeOldDeci(hisViewVos);
|
|
|
+ for (String key : map.keySet()) {
|
|
|
+ aStrRescueNoteFacade.getOneList(map.get(key), s.getModeId());
|
|
|
}
|
|
|
}
|
|
|
- }else if("出院小结".equals(modelName)){
|
|
|
- List<HisViewVo> hisViewVos =fjtzdbConnHarp.getHisView(this.sqlOld(s));
|
|
|
- if (hisViewVos.size()>0){
|
|
|
- Map<String,List<HisViewVo>> map=this.executeOldDeci(hisViewVos);
|
|
|
- for (String key:map.keySet()) {
|
|
|
- aStrLeaveHospitalFacade.getOneList(map.get(key),s.getModeId());
|
|
|
+ } else if ("出院小结".equals(modelName)) {
|
|
|
+ List<HisViewVo> hisViewVos = fjtzdbConnHarp.getHisView(this.sqlOld(s));
|
|
|
+ if (hisViewVos.size() > 0) {
|
|
|
+ Map<String, List<HisViewVo>> map = this.executeOldDeci(hisViewVos);
|
|
|
+ for (String key : map.keySet()) {
|
|
|
+ aStrLeaveHospitalFacade.getOneList(map.get(key), s.getModeId());
|
|
|
}
|
|
|
}
|
|
|
- }else if("会诊申请单".equals(modelName)){
|
|
|
- List<HisViewVo> hisViewVos =fjtzdbConnHarp.getHisView(this.sqlOld(s));
|
|
|
- if (hisViewVos.size()>0){
|
|
|
- Map<String,List<HisViewVo>> map=this.executeOldDeci(hisViewVos);
|
|
|
- for (String key:map.keySet()) {
|
|
|
- aStrConsultationResultFacade.getOneList(map.get(key),s.getModeId());
|
|
|
+ } else if ("会诊申请单".equals(modelName)) {
|
|
|
+ List<HisViewVo> hisViewVos = fjtzdbConnHarp.getHisView(this.sqlOld(s));
|
|
|
+ if (hisViewVos.size() > 0) {
|
|
|
+ Map<String, List<HisViewVo>> map = this.executeOldDeci(hisViewVos);
|
|
|
+ for (String key : map.keySet()) {
|
|
|
+ aStrConsultationResultFacade.getOneList(map.get(key), s.getModeId());
|
|
|
}
|
|
|
}
|
|
|
- }else if("会诊单".equals(modelName)){
|
|
|
- List<HisViewVo> hisViewVos =fjtzdbConnHarp.getHisView(this.sqlOld(s));
|
|
|
- if (hisViewVos.size()>0){
|
|
|
- Map<String,List<HisViewVo>> map=this.executeOldDeci(hisViewVos);
|
|
|
- for (String key:map.keySet()) {
|
|
|
- aStrConsultationNoteFacade.getOneList(map.get(key),s.getModeId());
|
|
|
+ } else if ("会诊单".equals(modelName)) {
|
|
|
+ List<HisViewVo> hisViewVos = fjtzdbConnHarp.getHisView(this.sqlOld(s));
|
|
|
+ if (hisViewVos.size() > 0) {
|
|
|
+ Map<String, List<HisViewVo>> map = this.executeOldDeci(hisViewVos);
|
|
|
+ for (String key : map.keySet()) {
|
|
|
+ aStrConsultationNoteFacade.getOneList(map.get(key), s.getModeId());
|
|
|
}
|
|
|
}
|
|
|
- }else if ("会诊记录".equals(modelName)){
|
|
|
- List<HisViewVo> hisViewVos =fjtzdbConnHarp.getHisView(this.sqlOld(s));
|
|
|
- if (hisViewVos.size()>0){
|
|
|
- Map<String,List<HisViewVo>> map=this.executeOldDeci(hisViewVos);
|
|
|
- for (String key:map.keySet()) {
|
|
|
- aStrConsultationRecordFacade.getOneList(map.get(key),s.getModeId());
|
|
|
+ } else if ("会诊记录".equals(modelName)) {
|
|
|
+ List<HisViewVo> hisViewVos = fjtzdbConnHarp.getHisView(this.sqlOld(s));
|
|
|
+ if (hisViewVos.size() > 0) {
|
|
|
+ Map<String, List<HisViewVo>> map = this.executeOldDeci(hisViewVos);
|
|
|
+ for (String key : map.keySet()) {
|
|
|
+ aStrConsultationRecordFacade.getOneList(map.get(key), s.getModeId());
|
|
|
}
|
|
|
}
|
|
|
- } else if("阶段小结".equals(modelName)){
|
|
|
- List<HisViewVo> hisViewVos =fjtzdbConnHarp.getHisView(this.sqlOld(s));
|
|
|
- if (hisViewVos.size()>0){
|
|
|
- Map<String,List<HisViewVo>> map=this.executeOldDeci(hisViewVos);
|
|
|
- for (String key:map.keySet()) {
|
|
|
- aStrPeriodConclusionFacade.getOneList(map.get(key),s.getModeId());
|
|
|
+ } else if ("阶段小结".equals(modelName)) {
|
|
|
+ List<HisViewVo> hisViewVos = fjtzdbConnHarp.getHisView(this.sqlOld(s));
|
|
|
+ if (hisViewVos.size() > 0) {
|
|
|
+ Map<String, List<HisViewVo>> map = this.executeOldDeci(hisViewVos);
|
|
|
+ for (String key : map.keySet()) {
|
|
|
+ aStrPeriodConclusionFacade.getOneList(map.get(key), s.getModeId());
|
|
|
}
|
|
|
}
|
|
|
- }else if("查房记录".equals(modelName)){
|
|
|
- List<HisViewVo> hisViewVos =fjtzdbConnHarp.getHisView(this.sqlOld(s));
|
|
|
- if (hisViewVos.size()>0){
|
|
|
- Map<String,List<HisViewVo>> map=this.executeOldDeci(hisViewVos);
|
|
|
- for (String key:map.keySet()) {
|
|
|
- aStrWardRecordFacade.getOneList(map.get(key),s.getModeId());
|
|
|
+ } else if ("查房记录".equals(modelName)) {
|
|
|
+ List<HisViewVo> hisViewVos = fjtzdbConnHarp.getHisView(this.sqlOld(s));
|
|
|
+ if (hisViewVos.size() > 0) {
|
|
|
+ Map<String, List<HisViewVo>> map = this.executeOldDeci(hisViewVos);
|
|
|
+ for (String key : map.keySet()) {
|
|
|
+ aStrWardRecordFacade.getOneList(map.get(key), s.getModeId());
|
|
|
}
|
|
|
}
|
|
|
- }else if ("病案首页".equals(modelName)){
|
|
|
+ } else if ("病案首页".equals(modelName)) {
|
|
|
/**
|
|
|
* 病案首页
|
|
|
*/
|
|
|
- String sql ="select * from "+s.getTableName()+" where behospitalCode='"+s.getBehospitalCode()+"' and patientId='"+s.getPatientId()+ "'";
|
|
|
- List<HisHomePageVO> homePage =fjtzdbConnHarp.getHomePage(sql);
|
|
|
- if (homePage.size()>0) {
|
|
|
+ String sql = "select * from " + s.getTableName() + " where behospitalCode='" + s.getBehospitalCode() + "' and patientId='" + s.getPatientId() + "'";
|
|
|
+ List<HisHomePageVO> homePage = fjtzdbConnHarp.getHomePage(sql);
|
|
|
+ if (homePage.size() > 0) {
|
|
|
aHomePageFacade.getOneList(homePage);//病案首页
|
|
|
/**
|
|
|
* 病案首页诊断
|
|
@@ -348,14 +351,14 @@ public class StructuralOldDataFacade {
|
|
|
* 病案首页手术
|
|
|
*/
|
|
|
List<HomeOperationInfo> homeinfo = new ArrayList<>();
|
|
|
- String sql02 = "select * from med_home_operation_info where " + " homePageId='" + homePage.get(0).getHomePageId() + "' and behospitalCode = '"+s.getBehospitalCode()+"' and patientId='"+s.getPatientId()+ "'";
|
|
|
+ String sql02 = "select * from med_home_operation_info where " + " homePageId='" + homePage.get(0).getHomePageId() + "' and behospitalCode = '" + s.getBehospitalCode() + "' and patientId='" + s.getPatientId() + "'";
|
|
|
List<HomeOperationInfo> homeOperationInfos = fjtzdbConnHarp.getHomeOperation(sql02);
|
|
|
- if (homeOperationInfos.size()>0){
|
|
|
- homeOperationInfos.forEach(h->{
|
|
|
+ if (homeOperationInfos.size() > 0) {
|
|
|
+ homeOperationInfos.forEach(h -> {
|
|
|
homeinfo.add(h);
|
|
|
});
|
|
|
}
|
|
|
- String sql03 = "select * from med_home_operation_info2 where " + "homePageId='" + homePage.get(0).getHomePageId() + "' and behospitalCode = '"+s.getBehospitalCode()+"' and patientId='"+s.getPatientId()+ "'";
|
|
|
+ String sql03 = "select * from med_home_operation_info2 where " + "homePageId='" + homePage.get(0).getHomePageId() + "' and behospitalCode = '" + s.getBehospitalCode() + "' and patientId='" + s.getPatientId() + "'";
|
|
|
List<HomeOperationInfo> homeOperation = fjtzdbConnHarp.getHomeOperation(sql03);
|
|
|
if (homeOperation.size() > 0) {
|
|
|
homeOperation.forEach(home -> {
|
|
@@ -364,99 +367,97 @@ public class StructuralOldDataFacade {
|
|
|
}
|
|
|
aHomeOperationInfoFacade.execute(homeinfo);//病案首页手术
|
|
|
}
|
|
|
- }else if ("医嘱信息".equals(modelName)){
|
|
|
- List<DoctorAdvice> doctorAdvice =fjtzdbConnHarp.getDoctorAdvice(this.sqlOld(s));
|
|
|
- if (doctorAdvice.size()>0){
|
|
|
+ } else if ("医嘱信息".equals(modelName)) {
|
|
|
+ List<DoctorAdvice> doctorAdvice = fjtzdbConnHarp.getDoctorAdvice(this.sqlOld(s));
|
|
|
+ if (doctorAdvice.size() > 0) {
|
|
|
aDoctorAdviceFacade.execute(doctorAdvice);
|
|
|
}
|
|
|
- }else if ("入院登记".equals(modelName)) {
|
|
|
+ } else if ("入院登记".equals(modelName)) {
|
|
|
List<BehospitalInfo> behospitalInfo = fjtzdbConnHarp.getBehospitalInfo(this.sqlOld(s));
|
|
|
if (behospitalInfo.size() > 0) {
|
|
|
aBehospitalInfoFacade.execute(behospitalInfo);
|
|
|
}
|
|
|
- }
|
|
|
- else if ("检查信息".equals(modelName)){
|
|
|
- String sql ="select * from med_pacs_info where behospitalCode ='"+s.getBehospitalCode()+"' and patientId='"+s.getPatientId()+ "'";
|
|
|
- List<MedPacsInfo> pacsInfo =fjtzdbConnHarp.getPacsInfo(sql);
|
|
|
- if (pacsInfo.size()>0){
|
|
|
- pacsInfo.forEach(pacs->{
|
|
|
+ } else if ("检查信息".equals(modelName)) {
|
|
|
+ String sql = "select * from med_pacs_info where behospitalCode ='" + s.getBehospitalCode() + "' and patientId='" + s.getPatientId() + "'";
|
|
|
+ List<MedPacsInfo> pacsInfo = fjtzdbConnHarp.getPacsInfo(sql);
|
|
|
+ if (pacsInfo.size() > 0) {
|
|
|
+ pacsInfo.forEach(pacs -> {
|
|
|
medPacsInfoFacade.save(pacs);
|
|
|
- String pacsSql ="select * from med_pacs_result where behospitalCode ='"+s.getBehospitalCode()+
|
|
|
- "' and recId = '"+pacs.getRepNo()+"'";
|
|
|
- List<MedPacsResult> pacsResult =fjtzdbConnHarp.getPacsResult(pacsSql);
|
|
|
- if (pacsResult.size()>0){
|
|
|
+ String pacsSql = "select * from med_pacs_result where behospitalCode ='" + s.getBehospitalCode() +
|
|
|
+ "' and recId = '" + pacs.getRepNo() + "'";
|
|
|
+ List<MedPacsResult> pacsResult = fjtzdbConnHarp.getPacsResult(pacsSql);
|
|
|
+ if (pacsResult.size() > 0) {
|
|
|
aMedPacsResultFacade.execute(pacsResult);
|
|
|
}
|
|
|
});
|
|
|
|
|
|
}
|
|
|
- }else if ("检验信息".equals(modelName)){
|
|
|
- String sql ="select * from med_lis_info where behospitalCode ='"+s.getBehospitalCode()+"' and patientId='"+s.getPatientId()+ "'";
|
|
|
- List<MedLisInfo> lisInfo =fjtzdbConnHarp.getLisInfo(sql);
|
|
|
- if (lisInfo.size()>0){
|
|
|
- lisInfo.forEach(lis->{
|
|
|
+ } else if ("检验信息".equals(modelName)) {
|
|
|
+ String sql = "select * from med_lis_info where behospitalCode ='" + s.getBehospitalCode() + "' and patientId='" + s.getPatientId() + "'";
|
|
|
+ List<MedLisInfo> lisInfo = fjtzdbConnHarp.getLisInfo(sql);
|
|
|
+ if (lisInfo.size() > 0) {
|
|
|
+ lisInfo.forEach(lis -> {
|
|
|
medLisInfoFacade.save(lis);
|
|
|
- String lisSql ="select * from med_lis_result where behospitalCode ='"+s.getBehospitalCode()+
|
|
|
- "' and recId = '"+lis.getRepNo()+"' and patientId='"+s.getPatientId()+ "'";
|
|
|
- List<MedLisResult> lisResult =fjtzdbConnHarp.getLisResult(lisSql);
|
|
|
- if (lisResult.size()>0){
|
|
|
+ String lisSql = "select * from med_lis_result where behospitalCode ='" + s.getBehospitalCode() +
|
|
|
+ "' and recId = '" + lis.getRepNo() + "' and patientId='" + s.getPatientId() + "'";
|
|
|
+ List<MedLisResult> lisResult = fjtzdbConnHarp.getLisResult(lisSql);
|
|
|
+ if (lisResult.size() > 0) {
|
|
|
aMedLisResultFacade.execute(lisResult);
|
|
|
}
|
|
|
});
|
|
|
|
|
|
}
|
|
|
- }
|
|
|
- else if ("谈话告知书".equals(modelName)){
|
|
|
- List<StrTalkInform> strTalkInforms =fjtzdbConnHarp.getStrTalkInform(this.sqlOld(s));
|
|
|
- if (strTalkInforms.size()>0){
|
|
|
+ } else if ("谈话告知书".equals(modelName)) {
|
|
|
+ List<StrTalkInform> strTalkInforms = fjtzdbConnHarp.getStrTalkInform(this.sqlOld(s));
|
|
|
+ if (strTalkInforms.size() > 0) {
|
|
|
aStrTalkInformFacade.execute(strTalkInforms);
|
|
|
}
|
|
|
- }else if ("知情同意书".equals(modelName)){
|
|
|
- List<StrInformedConsent> strInformedConsents =fjtzdbConnHarp.getStrInformedConsent(this.sqlOld(s));
|
|
|
- if (strInformedConsents.size()>0){
|
|
|
+ } else if ("知情同意书".equals(modelName)) {
|
|
|
+ List<StrInformedConsent> strInformedConsents = fjtzdbConnHarp.getStrInformedConsent(this.sqlOld(s));
|
|
|
+ if (strInformedConsents.size() > 0) {
|
|
|
aStrInformedConsentFacade.execute(strInformedConsents);
|
|
|
}
|
|
|
- }else if ("危急值信息".equals(modelName)){
|
|
|
- List<MedCrisisInfo> medCrisisInfos =fjtzdbConnHarp.getMedCrisisInfo(this.sqlOld(s));
|
|
|
- if (medCrisisInfos.size()>0){
|
|
|
+ } else if ("危急值信息".equals(modelName)) {
|
|
|
+ List<MedCrisisInfo> medCrisisInfos = fjtzdbConnHarp.getMedCrisisInfo(this.sqlOld(s));
|
|
|
+ if (medCrisisInfos.size() > 0) {
|
|
|
aMedCrisisFacade.execute(medCrisisInfos);
|
|
|
}
|
|
|
- }else if("入院记录".equals(modelName)){
|
|
|
- List<FJStrAdmissionNoteVo> medAdmissionNote =fjtzdbConnHarp.getMedAdmissionNote(this.sqlOld(s));
|
|
|
- if (medAdmissionNote.size()>0){
|
|
|
- aStrAdmissionNoteFacade.getOneList(medAdmissionNote,s.getModeId());
|
|
|
+ } else if ("入院记录".equals(modelName)) {
|
|
|
+ List<FJStrAdmissionNoteVo> medAdmissionNote = fjtzdbConnHarp.getMedAdmissionNote(this.sqlOld(s));
|
|
|
+ if (medAdmissionNote.size() > 0) {
|
|
|
+ aStrAdmissionNoteFacade.getOneList(medAdmissionNote, s.getModeId());
|
|
|
}
|
|
|
- }else if("危急值记录".equals(modelName)){
|
|
|
- List<AStrCrisisNoteVO> medCrisisNote =fjtzdbConnHarp.getMedCrisisNote(this.sqlOld(s));
|
|
|
- if (medCrisisNote.size()>0){
|
|
|
- medCrisisNote.forEach(crisis->{
|
|
|
- aStrCrisisNoteFacade.dealData(crisis,s.getModeId());
|
|
|
+ } else if ("危急值记录".equals(modelName)) {
|
|
|
+ List<AStrCrisisNoteVO> medCrisisNote = fjtzdbConnHarp.getMedCrisisNote(this.sqlOld(s));
|
|
|
+ if (medCrisisNote.size() > 0) {
|
|
|
+ medCrisisNote.forEach(crisis -> {
|
|
|
+ aStrCrisisNoteFacade.dealData(crisis, s.getModeId());
|
|
|
});
|
|
|
}
|
|
|
}
|
|
|
- log.info(modelName+"---- 保存数据完成!");
|
|
|
- }catch (Exception e){
|
|
|
- log.error(e.getMessage(),e);
|
|
|
- aMedAbnormalInfoFacade.saveAbnormalInfo("保存数据异常", "",JSON.toJSONString(s),"",e.getMessage());
|
|
|
+ log.info(modelName + "---- 保存数据完成!");
|
|
|
+ } catch (Exception e) {
|
|
|
+ log.error(e.getMessage(), e);
|
|
|
+ aMedAbnormalInfoFacade.saveAbnormalInfo("保存数据异常", "", JSON.toJSONString(s), "", e.getMessage());
|
|
|
}
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
/**
|
|
|
- *把得到的多个数据根据recId来分成一条数据
|
|
|
+ * 把得到的多个数据根据recId来分成一条数据
|
|
|
*/
|
|
|
- public Map<String,List<HisViewVo>> executeOldDeci(List<HisViewVo> hisViewVos){
|
|
|
- Map<String,List<HisViewVo>> map =new HashMap<>();
|
|
|
- hisViewVos.forEach(s->{
|
|
|
- List<HisViewVo> hisViewVos1=map.get(s.getRecId());
|
|
|
- if (hisViewVos1!=null){
|
|
|
+ public Map<String, List<HisViewVo>> executeOldDeci(List<HisViewVo> hisViewVos) {
|
|
|
+ Map<String, List<HisViewVo>> map = new HashMap<>();
|
|
|
+ hisViewVos.forEach(s -> {
|
|
|
+ List<HisViewVo> hisViewVos1 = map.get(s.getRecId());
|
|
|
+ if (hisViewVos1 != null) {
|
|
|
hisViewVos1.add(s);
|
|
|
- map.put(s.getRecId(),hisViewVos1);
|
|
|
- }else {
|
|
|
- List<HisViewVo> h =new ArrayList<>();
|
|
|
+ map.put(s.getRecId(), hisViewVos1);
|
|
|
+ } else {
|
|
|
+ List<HisViewVo> h = new ArrayList<>();
|
|
|
h.add(s);
|
|
|
- map.put(s.getRecId(),h);
|
|
|
+ map.put(s.getRecId(), h);
|
|
|
}
|
|
|
});
|
|
|
return map;
|
|
@@ -464,11 +465,12 @@ public class StructuralOldDataFacade {
|
|
|
|
|
|
/**
|
|
|
* 历史数据拉取
|
|
|
+ *
|
|
|
* @param s
|
|
|
* @return
|
|
|
*/
|
|
|
- public String sqlOld(StructuralDataVo s){
|
|
|
- String sql ="select * from "+s.getTableName()+" where behospitalCode = '"+s.getBehospitalCode()+"' and patientId='"+s.getPatientId()+ "'";
|
|
|
+ public String sqlOld(StructuralDataVo s) {
|
|
|
+ String sql = "select * from " + s.getTableName() + " where behospitalCode = '" + s.getBehospitalCode() + "' and patientId='" + s.getPatientId() + "'";
|
|
|
return sql;
|
|
|
}
|
|
|
}
|