|
@@ -2,40 +2,39 @@ package com.lantone.data.facade.data;
|
|
|
|
|
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
|
|
import com.google.common.collect.Lists;
|
|
|
+import com.lantone.data.dto.RespDTO;
|
|
|
import com.lantone.data.entity.MedCrisisInfo;
|
|
|
import com.lantone.data.util.BeanUtil;
|
|
|
import com.lantone.data.util.DateUtil;
|
|
|
+import com.lantone.data.vo.data.MedCrisisVO;
|
|
|
+import lombok.extern.slf4j.Slf4j;
|
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
|
import org.springframework.beans.factory.annotation.Qualifier;
|
|
|
-import org.springframework.beans.factory.annotation.Value;
|
|
|
import org.springframework.stereotype.Component;
|
|
|
|
|
|
import java.util.Date;
|
|
|
import java.util.List;
|
|
|
|
|
|
@Component
|
|
|
+@Slf4j
|
|
|
public class MedCrisisFacade extends MedCrisisInfoServiceImpl {
|
|
|
|
|
|
@Autowired
|
|
|
@Qualifier("medCrisisInfoServiceImpl")
|
|
|
private MedCrisisInfoServiceImpl medCrisisInfoService;
|
|
|
- @Autowired
|
|
|
- private MedAbnormalInfoFacade aMedAbnormalInfoFacade;
|
|
|
- @Value("${log_switch.enable}")
|
|
|
- private boolean logSwitch;
|
|
|
|
|
|
- public RespDTO<List<AMedCrisisDTO>> executeMedCrisis(List<AMedCrisisVO> list) {
|
|
|
+ public RespDTO executeMedCrisis(List<MedCrisisVO> list) {
|
|
|
try{
|
|
|
if (list != null && list.size() > 0) {
|
|
|
//循环验证数据有效性
|
|
|
- for (AMedCrisisVO aMedCrisisVO : list) {
|
|
|
- if ("".equals(aMedCrisisVO.getRecId())) {
|
|
|
+ for (MedCrisisVO medCrisisVO : list) {
|
|
|
+ if ("".equals(medCrisisVO.getRecId())) {
|
|
|
return RespDTO.onError("请输入文书编码!");
|
|
|
- } else if ("".equals(aMedCrisisVO.getBehospitalCode())) {
|
|
|
+ } else if ("".equals(medCrisisVO.getBehospitalCode())) {
|
|
|
return RespDTO.onError("请输入病人住院编码!");
|
|
|
- } else if (aMedCrisisVO.getHospitalId() == null) {
|
|
|
+ } else if (medCrisisVO.getHospitalId() == null) {
|
|
|
return RespDTO.onError("请输入医院编码!");
|
|
|
- } else if ("".equals(aMedCrisisVO.getRecType())) {
|
|
|
+ } else if ("".equals(medCrisisVO.getRecType())) {
|
|
|
return RespDTO.onError("请输入危急值类型!");
|
|
|
}
|
|
|
}
|
|
@@ -50,18 +49,12 @@ public class MedCrisisFacade extends MedCrisisInfoServiceImpl {
|
|
|
});
|
|
|
execute(medCrisisList);
|
|
|
|
|
|
- if(logSwitch){
|
|
|
- medCrisisList.forEach(s->{
|
|
|
- aMedAbnormalInfoFacade.saveAbnormalInfo("危急值信息-正常","", JSON.toJSONString(list),"","");
|
|
|
- });
|
|
|
- }
|
|
|
return RespDTO.onSuc("操作正常!");
|
|
|
} else {
|
|
|
return RespDTO.onError("未接收到数据!");
|
|
|
}
|
|
|
}catch (Exception e){
|
|
|
log.error(e.getMessage(),e);
|
|
|
- aMedAbnormalInfoFacade.saveAbnormalInfo("危急值信息-异常","", JSON.toJSONString(list),"",e.getMessage());
|
|
|
return RespDTO.onError("数据处理异常,详情查看日志表");
|
|
|
}
|
|
|
}
|
|
@@ -86,7 +79,6 @@ public class MedCrisisFacade extends MedCrisisInfoServiceImpl {
|
|
|
}
|
|
|
} catch (Exception e) {
|
|
|
log.error(e.getMessage(), e);
|
|
|
- aMedAbnormalInfoFacade.saveAbnormalInfo("数据解析", s.getRecId(), JSON.toJSONString(medCrisisList), "", e.getMessage());
|
|
|
}
|
|
|
});
|
|
|
}
|