|
@@ -7,6 +7,7 @@ import com.diagbot.dto.Response;
|
|
import com.diagbot.enums.CacheKeyEnum;
|
|
import com.diagbot.enums.CacheKeyEnum;
|
|
import com.diagbot.enums.ModeIdEnum;
|
|
import com.diagbot.enums.ModeIdEnum;
|
|
import com.diagbot.facade.QcClientFacade;
|
|
import com.diagbot.facade.QcClientFacade;
|
|
|
|
+import com.diagbot.facade.str.*;
|
|
import com.diagbot.service.impl.ColumnServiceImpl;
|
|
import com.diagbot.service.impl.ColumnServiceImpl;
|
|
import com.diagbot.vo.QueryVo;
|
|
import com.diagbot.vo.QueryVo;
|
|
import com.diagbot.vo.str.StrContentVO;
|
|
import com.diagbot.vo.str.StrContentVO;
|
|
@@ -30,7 +31,7 @@ public class ColumnFacade extends ColumnServiceImpl {
|
|
* 解析
|
|
* 解析
|
|
* @param queryVo
|
|
* @param queryVo
|
|
*/
|
|
*/
|
|
- public void analyseRec(QueryVo queryVo){
|
|
|
|
|
|
+ public void analyseRec(QueryVo queryVo) {
|
|
try {
|
|
try {
|
|
Response<OutputInfo> resp=qcClientFacade.analyseField(queryVo);
|
|
Response<OutputInfo> resp=qcClientFacade.analyseField(queryVo);
|
|
if(resp.getData()!=null && resp.getData().getPageData()!=null){
|
|
if(resp.getData()!=null && resp.getData().getPageData()!=null){
|
|
@@ -61,7 +62,7 @@ public class ColumnFacade extends ColumnServiceImpl {
|
|
* @Author:liuqq
|
|
* @Author:liuqq
|
|
* @time: ${DATE} ${TIME}
|
|
* @time: ${DATE} ${TIME}
|
|
**/
|
|
**/
|
|
- public void analyseWholeData(StrContentVO strContentVO){
|
|
|
|
|
|
+ public void analyseWholeData(StrContentVO strContentVO) throws Exception{
|
|
//调用解析接口
|
|
//调用解析接口
|
|
Response<OutputInfo> resp=null;
|
|
Response<OutputInfo> resp=null;
|
|
//qcClientFacade.analyseField(queryVo);
|
|
//qcClientFacade.analyseField(queryVo);
|
|
@@ -84,106 +85,167 @@ public class ColumnFacade extends ColumnServiceImpl {
|
|
}
|
|
}
|
|
|
|
|
|
/**
|
|
/**
|
|
- * 数据解析
|
|
|
|
- * @param modelName
|
|
|
|
- * @param entityMap
|
|
|
|
- * @param hospitalId
|
|
|
|
- */
|
|
|
|
- private void analysisData(String modelName,Map<String, Object> entityMap,Long hospitalId,String columnMap){
|
|
|
|
|
|
+ * @Description: 不解析时,先入库
|
|
|
|
+ * @Author:liuqq
|
|
|
|
+ * @time: ${DATE} ${TIME}
|
|
|
|
+ **/
|
|
|
|
+ public void addWholeData(StrContentVO strContentVO){
|
|
|
|
+ String modelName=ModeIdEnum.getName(Integer.parseInt(strContentVO.getModelId()));
|
|
if("入院记录".equals(modelName)){
|
|
if("入院记录".equals(modelName)){
|
|
- aStrAdmissionNoteFacade.dealData(columnMap,entityMap,Long.valueOf(hospitalId));
|
|
|
|
|
|
+ bStrAdmissionNoteFacade.dealData(strContentVO);
|
|
}else if("首次病程录".equals(modelName)){
|
|
}else if("首次病程录".equals(modelName)){
|
|
- aStrFirstRecordFacade.dealData(columnMap,entityMap,Long.valueOf(hospitalId));
|
|
|
|
|
|
+ bStrFirstRecordFacade.dealData(strContentVO);
|
|
}else if("输血后效果评价".equals(modelName)){
|
|
}else if("输血后效果评价".equals(modelName)){
|
|
- aStrBloodResultFacade.dealData(columnMap,entityMap,Long.valueOf(hospitalId));
|
|
|
|
|
|
+ bStrBloodResultFacade.dealData(strContentVO);
|
|
}else if("输血/血制品病程记录".equals(modelName)){
|
|
}else if("输血/血制品病程记录".equals(modelName)){
|
|
- aStrBloodTransfusionFacade.dealData(columnMap,entityMap,Long.valueOf(hospitalId));
|
|
|
|
|
|
+ bStrBloodTransfusionFacade.dealData(strContentVO);
|
|
}else if("转入记录".equals(modelName)){
|
|
}else if("转入记录".equals(modelName)){
|
|
- aStrTransferInNoteFacade.dealData(columnMap,entityMap,Long.valueOf(hospitalId));
|
|
|
|
|
|
+ bStrTransferInNoteFacade.dealData(strContentVO);
|
|
}else if("转出记录".equals(modelName)){
|
|
}else if("转出记录".equals(modelName)){
|
|
- aStrTransferOutNoteFacade.dealData(columnMap,entityMap,Long.valueOf(hospitalId));
|
|
|
|
|
|
+ bStrTransferOutNoteFacade.dealData(strContentVO);
|
|
}else if("病危通知书".equals(modelName)){
|
|
}else if("病危通知书".equals(modelName)){
|
|
- aStrIllCriticallyFacade.dealData(columnMap,entityMap,Long.valueOf(hospitalId));
|
|
|
|
|
|
+ bStrIllCriticallyFacade.dealData(strContentVO);
|
|
}else if("病重通知书".equals(modelName)){
|
|
}else if("病重通知书".equals(modelName)){
|
|
- aStrIllSeriouslFacade.dealData(columnMap,entityMap,Long.valueOf(hospitalId));
|
|
|
|
|
|
+ bStrIllSeriouslFacade.dealData(strContentVO);
|
|
}else if("疑难病例讨论记录".equals(modelName)){
|
|
}else if("疑难病例讨论记录".equals(modelName)){
|
|
- aStrDifficultCaseFacade.dealData(columnMap,entityMap,Long.valueOf(hospitalId));
|
|
|
|
|
|
+ bStrDifficultCaseFacade.dealData(strContentVO);
|
|
}else if("死亡记录".equals(modelName)){
|
|
}else if("死亡记录".equals(modelName)){
|
|
- aStrDeathNoteFacade.dealData(columnMap,entityMap,Long.valueOf(hospitalId));
|
|
|
|
|
|
+ bStrDeathNoteFacade.dealData(strContentVO);
|
|
}else if("死亡病例讨论记录".equals(modelName)){
|
|
}else if("死亡病例讨论记录".equals(modelName)){
|
|
- aStrDeathDiscussionFacade.dealData(columnMap,entityMap,Long.valueOf(hospitalId));
|
|
|
|
|
|
+ bStrDeathDiscussionFacade.dealData(strContentVO);
|
|
}else if("查房记录".equals(modelName)){
|
|
}else if("查房记录".equals(modelName)){
|
|
- aStrWardRecordFacade.dealData(columnMap,entityMap,Long.valueOf(hospitalId));
|
|
|
|
|
|
+ bStrWardRecordFacade.dealData(strContentVO);
|
|
}else if("术后首次病程及谈话记录".equals(modelName)){
|
|
}else if("术后首次病程及谈话记录".equals(modelName)){
|
|
- aStrOperativeFirstRecord.dealData(columnMap,entityMap,Long.valueOf(hospitalId));
|
|
|
|
|
|
+ bStrOperativeFirstRecordFacade.dealData(strContentVO);
|
|
}else if("术前讨论、术前小结".equals(modelName)){
|
|
}else if("术前讨论、术前小结".equals(modelName)){
|
|
- aStrPreoperativeDiscussionFacade.dealData(columnMap,entityMap,Long.valueOf(hospitalId));
|
|
|
|
|
|
+ bStrPreoperativeDiscussionFacade.dealData(strContentVO);
|
|
}else if("手术记录".equals(modelName)){
|
|
}else if("手术记录".equals(modelName)){
|
|
- aStrOperativeNoteFacade.dealData(columnMap,entityMap,Long.valueOf(hospitalId));
|
|
|
|
|
|
+ bStrOperativeNoteFacade.dealData(strContentVO);
|
|
}else if("抢救记录".equals(modelName)){
|
|
}else if("抢救记录".equals(modelName)){
|
|
- aStrRescueNoteFacade.dealData(columnMap,entityMap,Long.valueOf(hospitalId));
|
|
|
|
|
|
+ bStrRescueNoteFacade.dealData(strContentVO);
|
|
}else if("危急值记录".equals(modelName)){
|
|
}else if("危急值记录".equals(modelName)){
|
|
- aStrCrisisNoteFacade.dealData(columnMap,entityMap,Long.valueOf(hospitalId));
|
|
|
|
|
|
+ bStrCrisisNoteFacade.dealData(strContentVO);
|
|
}else if("出院小结".equals(modelName)){
|
|
}else if("出院小结".equals(modelName)){
|
|
- aStrLeaveHospitalFacade.dealData(columnMap,entityMap,Long.valueOf(hospitalId));
|
|
|
|
|
|
+ bStrLeaveHospitalFacade.dealData(strContentVO);
|
|
}else if("会诊申请单".equals(modelName)){
|
|
}else if("会诊申请单".equals(modelName)){
|
|
- aStrConsultationApplyFacade.dealData(columnMap,entityMap,Long.valueOf(hospitalId));
|
|
|
|
|
|
+ bStrConsultationApplyFacade.dealData(strContentVO);
|
|
}else if("会诊结果单".equals(modelName)){
|
|
}else if("会诊结果单".equals(modelName)){
|
|
- aStrConsultationResultFacade.dealData(columnMap,entityMap,Long.valueOf(hospitalId));
|
|
|
|
|
|
+ bStrConsultationResultFacade.dealData(strContentVO);
|
|
}else if("会诊单".equals(modelName)){
|
|
}else if("会诊单".equals(modelName)){
|
|
- aStrConsultationNoteFacade.dealData(columnMap,entityMap,Long.valueOf(hospitalId));
|
|
|
|
|
|
+ bStrConsultationNoteFacade.dealData(strContentVO);
|
|
}else if ("会诊记录".equals(modelName)){
|
|
}else if ("会诊记录".equals(modelName)){
|
|
- aStrConsultationRecordFacade.dealData(columnMap,entityMap,Long.valueOf(hospitalId));
|
|
|
|
|
|
+ bStrConsultationRecordFacade.dealData(strContentVO);
|
|
} else if("阶段小结".equals(modelName)){
|
|
} else if("阶段小结".equals(modelName)){
|
|
- aStrPeriodConclusionFacade.dealData(columnMap,entityMap,Long.valueOf(hospitalId));
|
|
|
|
|
|
+ bStrPeriodConclusionFacade.dealData(strContentVO);
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ /**
|
|
|
|
+ * 数据解析
|
|
|
|
+ * @param modelName
|
|
|
|
+ * @param entityMap
|
|
|
|
+ * @param hospitalId
|
|
|
|
+ */
|
|
|
|
+ private void analysisData(String modelName,Map<String, Object> entityMap,Long hospitalId,String columnMap){
|
|
|
|
+ try{
|
|
|
|
+ if("入院记录".equals(modelName)){
|
|
|
|
+ bStrAdmissionNoteFacade.dealData(columnMap,entityMap,Long.valueOf(hospitalId));
|
|
|
|
+ }else if("首次病程录".equals(modelName)){
|
|
|
|
+ bStrFirstRecordFacade.dealData(columnMap,entityMap,Long.valueOf(hospitalId));
|
|
|
|
+ }else if("输血后效果评价".equals(modelName)){
|
|
|
|
+ bStrBloodResultFacade.dealData(columnMap,entityMap,Long.valueOf(hospitalId));
|
|
|
|
+ }else if("输血/血制品病程记录".equals(modelName)){
|
|
|
|
+ bStrBloodTransfusionFacade.dealData(columnMap,entityMap,Long.valueOf(hospitalId));
|
|
|
|
+ }else if("转入记录".equals(modelName)){
|
|
|
|
+ bStrTransferInNoteFacade.dealData(columnMap,entityMap,Long.valueOf(hospitalId));
|
|
|
|
+ }else if("转出记录".equals(modelName)){
|
|
|
|
+ bStrTransferOutNoteFacade.dealData(columnMap,entityMap,Long.valueOf(hospitalId));
|
|
|
|
+ }else if("病危通知书".equals(modelName)){
|
|
|
|
+ bStrIllCriticallyFacade.dealData(columnMap,entityMap,Long.valueOf(hospitalId));
|
|
|
|
+ }else if("病重通知书".equals(modelName)){
|
|
|
|
+ bStrIllSeriouslFacade.dealData(columnMap,entityMap,Long.valueOf(hospitalId));
|
|
|
|
+ }else if("疑难病例讨论记录".equals(modelName)){
|
|
|
|
+ bStrDifficultCaseFacade.dealData(columnMap,entityMap,Long.valueOf(hospitalId));
|
|
|
|
+ }else if("死亡记录".equals(modelName)){
|
|
|
|
+ bStrDeathNoteFacade.dealData(columnMap,entityMap,Long.valueOf(hospitalId));
|
|
|
|
+ }else if("死亡病例讨论记录".equals(modelName)){
|
|
|
|
+ bStrDeathDiscussionFacade.dealData(columnMap,entityMap,Long.valueOf(hospitalId));
|
|
|
|
+ }else if("查房记录".equals(modelName)){
|
|
|
|
+ bStrWardRecordFacade.dealData(columnMap,entityMap,Long.valueOf(hospitalId));
|
|
|
|
+ }else if("术后首次病程及谈话记录".equals(modelName)){
|
|
|
|
+ bStrOperativeFirstRecordFacade.dealData(columnMap,entityMap,Long.valueOf(hospitalId));
|
|
|
|
+ }else if("术前讨论、术前小结".equals(modelName)){
|
|
|
|
+ bStrPreoperativeDiscussionFacade.dealData(columnMap,entityMap,Long.valueOf(hospitalId));
|
|
|
|
+ }else if("手术记录".equals(modelName)){
|
|
|
|
+ bStrOperativeNoteFacade.dealData(columnMap,entityMap,Long.valueOf(hospitalId));
|
|
|
|
+ }else if("抢救记录".equals(modelName)){
|
|
|
|
+ bStrRescueNoteFacade.dealData(columnMap,entityMap,Long.valueOf(hospitalId));
|
|
|
|
+ }else if("危急值记录".equals(modelName)){
|
|
|
|
+ bStrCrisisNoteFacade.dealData(columnMap,entityMap,Long.valueOf(hospitalId));
|
|
|
|
+ }else if("出院小结".equals(modelName)){
|
|
|
|
+ bStrLeaveHospitalFacade.dealData(columnMap,entityMap,Long.valueOf(hospitalId));
|
|
|
|
+ }else if("会诊申请单".equals(modelName)){
|
|
|
|
+ bStrConsultationApplyFacade.dealData(columnMap,entityMap,Long.valueOf(hospitalId));
|
|
|
|
+ }else if("会诊结果单".equals(modelName)){
|
|
|
|
+ bStrConsultationResultFacade.dealData(columnMap,entityMap,Long.valueOf(hospitalId));
|
|
|
|
+ }else if("会诊单".equals(modelName)){
|
|
|
|
+ bStrConsultationNoteFacade.dealData(columnMap,entityMap,Long.valueOf(hospitalId));
|
|
|
|
+ }else if ("会诊记录".equals(modelName)){
|
|
|
|
+ bStrConsultationRecordFacade.dealData(columnMap,entityMap,Long.valueOf(hospitalId));
|
|
|
|
+ } else if("阶段小结".equals(modelName)){
|
|
|
|
+ bStrPeriodConclusionFacade.dealData(columnMap,entityMap,Long.valueOf(hospitalId));
|
|
|
|
+ }
|
|
|
|
+ log.info(modelName+"---- 解析完成!");
|
|
|
|
+ }catch (Exception e){
|
|
|
|
+ log.error(e.getMessage(),e);
|
|
|
|
+ aMedAbnormalInfoFacade.saveAbnormalInfo("数据解析异常", "",JSON.toJSONString(columnMap),"",e.getMessage());
|
|
}
|
|
}
|
|
- log.info(modelName+"---- 解析完成!");
|
|
|
|
}
|
|
}
|
|
|
|
|
|
@Autowired
|
|
@Autowired
|
|
- private AStrAdmissionNoteFacade aStrAdmissionNoteFacade;
|
|
|
|
|
|
+ private BStrAdmissionNoteFacade bStrAdmissionNoteFacade;
|
|
@Autowired
|
|
@Autowired
|
|
- private AStrFirstRecordFacade aStrFirstRecordFacade;
|
|
|
|
|
|
+ private BStrFirstRecordFacade bStrFirstRecordFacade;
|
|
@Autowired
|
|
@Autowired
|
|
- private AStrPeriodConclusionFacade aStrPeriodConclusionFacade;
|
|
|
|
|
|
+ private BStrPeriodConclusionFacade bStrPeriodConclusionFacade;
|
|
@Autowired
|
|
@Autowired
|
|
- private AStrBloodResultFacade aStrBloodResultFacade;
|
|
|
|
|
|
+ private BStrBloodResultFacade bStrBloodResultFacade;
|
|
@Autowired
|
|
@Autowired
|
|
- private AStrBloodTransfusionFacade aStrBloodTransfusionFacade;
|
|
|
|
|
|
+ private BStrBloodTransfusionFacade bStrBloodTransfusionFacade;
|
|
@Autowired
|
|
@Autowired
|
|
- private AStrTransferInNoteFacade aStrTransferInNoteFacade;
|
|
|
|
|
|
+ private BStrTransferInNoteFacade bStrTransferInNoteFacade;
|
|
@Autowired
|
|
@Autowired
|
|
- private AStrTransferOutNoteFacade aStrTransferOutNoteFacade;
|
|
|
|
|
|
+ private BStrTransferOutNoteFacade bStrTransferOutNoteFacade;
|
|
@Autowired
|
|
@Autowired
|
|
- private AStrIllSeriouslFacade aStrIllSeriouslFacade;
|
|
|
|
|
|
+ private BStrIllSeriouslFacade bStrIllSeriouslFacade;
|
|
@Autowired
|
|
@Autowired
|
|
- private AStrIllCriticallyFacade aStrIllCriticallyFacade;
|
|
|
|
|
|
+ private BStrIllCriticallyFacade bStrIllCriticallyFacade;
|
|
@Autowired
|
|
@Autowired
|
|
- private AStrDifficultCaseFacade aStrDifficultCaseFacade;
|
|
|
|
|
|
+ private BStrDifficultCaseFacade bStrDifficultCaseFacade;
|
|
@Autowired
|
|
@Autowired
|
|
- private AStrDeathNoteFacade aStrDeathNoteFacade;
|
|
|
|
|
|
+ private BStrDeathNoteFacade bStrDeathNoteFacade;
|
|
@Autowired
|
|
@Autowired
|
|
- private AStrDeathDiscussionFacade aStrDeathDiscussionFacade;
|
|
|
|
|
|
+ private BStrDeathDiscussionFacade bStrDeathDiscussionFacade;
|
|
@Autowired
|
|
@Autowired
|
|
- private AStrWardRecordFacade aStrWardRecordFacade;
|
|
|
|
|
|
+ private BStrWardRecordFacade bStrWardRecordFacade;
|
|
@Autowired
|
|
@Autowired
|
|
- private AStrOperativeFirstRecord aStrOperativeFirstRecord;
|
|
|
|
|
|
+ private BStrOperativeFirstRecordFacade bStrOperativeFirstRecordFacade;
|
|
@Autowired
|
|
@Autowired
|
|
- private AStrPreoperativeDiscussionFacade aStrPreoperativeDiscussionFacade;
|
|
|
|
|
|
+ private BStrPreoperativeDiscussionFacade bStrPreoperativeDiscussionFacade;
|
|
@Autowired
|
|
@Autowired
|
|
- private AStrOperativeNoteFacade aStrOperativeNoteFacade;
|
|
|
|
|
|
+ private BStrOperativeNoteFacade bStrOperativeNoteFacade;
|
|
@Autowired
|
|
@Autowired
|
|
- private AStrRescueNoteFacade aStrRescueNoteFacade;
|
|
|
|
|
|
+ private BStrRescueNoteFacade bStrRescueNoteFacade;
|
|
@Autowired
|
|
@Autowired
|
|
- private AStrCrisisNoteFacade aStrCrisisNoteFacade;
|
|
|
|
|
|
+ private BStrCrisisNoteFacade bStrCrisisNoteFacade;
|
|
@Autowired
|
|
@Autowired
|
|
- private AStrLeaveHospitalFacade aStrLeaveHospitalFacade;
|
|
|
|
|
|
+ private BStrLeaveHospitalFacade bStrLeaveHospitalFacade;
|
|
@Autowired
|
|
@Autowired
|
|
- private AStrConsultationApplyFacade aStrConsultationApplyFacade;
|
|
|
|
|
|
+ private BStrConsultationApplyFacade bStrConsultationApplyFacade;
|
|
@Autowired
|
|
@Autowired
|
|
- private AStrConsultationResultFacade aStrConsultationResultFacade;
|
|
|
|
|
|
+ private BStrConsultationResultFacade bStrConsultationResultFacade;
|
|
@Autowired
|
|
@Autowired
|
|
- private AStrConsultationNoteFacade aStrConsultationNoteFacade;
|
|
|
|
|
|
+ private BStrConsultationNoteFacade bStrConsultationNoteFacade;
|
|
@Autowired
|
|
@Autowired
|
|
- private AStrConsultationRecordFacade aStrConsultationRecordFacade;
|
|
|
|
|
|
+ private BStrConsultationRecordFacade bStrConsultationRecordFacade;
|
|
}
|
|
}
|