|
@@ -18,7 +18,7 @@ import java.util.Date;
|
|
|
import java.util.List;
|
|
|
|
|
|
@Component
|
|
|
-public class AMedCrisisFacade extends MedCrisisInfoServiceImpl{
|
|
|
+public class AMedCrisisFacade extends MedCrisisInfoServiceImpl {
|
|
|
|
|
|
@Autowired
|
|
|
@Qualifier("medCrisisInfoServiceImpl")
|
|
@@ -27,43 +27,43 @@ public class AMedCrisisFacade extends MedCrisisInfoServiceImpl{
|
|
|
private AMedAbnormalInfoFacade aMedAbnormalInfoFacade;
|
|
|
|
|
|
public RespDTO<List<AMedCrisisDTO>> executeMedCrisis(List<AMedCrisisVO> list) {
|
|
|
- if(list!=null && list.size()>0){
|
|
|
+ if (list != null && list.size() > 0) {
|
|
|
//循环验证数据有效性
|
|
|
- for (AMedCrisisVO aMedCrisisVO:list) {
|
|
|
- if("".equals(aMedCrisisVO.getRecId())){
|
|
|
+ for (AMedCrisisVO aMedCrisisVO : list) {
|
|
|
+ if ("".equals(aMedCrisisVO.getRecId())) {
|
|
|
return RespDTO.onError("请输入文书编码!");
|
|
|
- }else if("".equals(aMedCrisisVO.getBehospitalCode())) {
|
|
|
+ } else if ("".equals(aMedCrisisVO.getBehospitalCode())) {
|
|
|
return RespDTO.onError("请输入病人住院编码!");
|
|
|
- }else if(aMedCrisisVO.getHospitalId()==null){
|
|
|
+ } else if (aMedCrisisVO.getHospitalId() == null) {
|
|
|
return RespDTO.onError("请输入医院编码!");
|
|
|
- }else if("".equals(aMedCrisisVO.getRecType())){
|
|
|
+ } else if ("".equals(aMedCrisisVO.getRecType())) {
|
|
|
return RespDTO.onError("请输入危急值类型!");
|
|
|
}
|
|
|
}
|
|
|
|
|
|
- List<MedCrisisInfo> medCrisisList=Lists.newArrayList();
|
|
|
- list.stream().forEach(s->{
|
|
|
- MedCrisisInfo medCrisisInfo=new MedCrisisInfo();
|
|
|
- BeanUtil.copyProperties(s,medCrisisInfo);
|
|
|
+ List<MedCrisisInfo> medCrisisList = Lists.newArrayList();
|
|
|
+ list.stream().forEach(s -> {
|
|
|
+ MedCrisisInfo medCrisisInfo = new MedCrisisInfo();
|
|
|
+ BeanUtil.copyProperties(s, medCrisisInfo);
|
|
|
medCrisisInfo.setRepDate(DateUtil.parseDateTime(s.getRepDate()));
|
|
|
medCrisisInfo.setSendDate(DateUtil.parseDateTime(s.getSendDate()));
|
|
|
medCrisisList.add(medCrisisInfo);
|
|
|
});
|
|
|
execute(medCrisisList);
|
|
|
|
|
|
- List<AMedCrisisDTO> medCrisisDtoList=BeanUtil.listCopyTo(list,AMedCrisisDTO.class);
|
|
|
+ List<AMedCrisisDTO> medCrisisDtoList = BeanUtil.listCopyTo(list, AMedCrisisDTO.class);
|
|
|
return RespDTO.onSuc(medCrisisDtoList);
|
|
|
- }else{
|
|
|
+ } else {
|
|
|
return RespDTO.onError("未接收到数据!");
|
|
|
}
|
|
|
}
|
|
|
|
|
|
- public void execute(List<MedCrisisInfo> medCrisisList){
|
|
|
- try{
|
|
|
- List<MedCrisisInfo> addE = Lists.newLinkedList();
|
|
|
- List<MedCrisisInfo> updateE = Lists.newLinkedList();
|
|
|
- if (medCrisisList != null && medCrisisList.size() > 0) {
|
|
|
- medCrisisList.stream().forEach(s -> {
|
|
|
+ public void execute(List<MedCrisisInfo> medCrisisList) {
|
|
|
+ List<MedCrisisInfo> addE = Lists.newLinkedList();
|
|
|
+ List<MedCrisisInfo> updateE = Lists.newLinkedList();
|
|
|
+ if (medCrisisList != null && medCrisisList.size() > 0) {
|
|
|
+ medCrisisList.forEach(s -> {
|
|
|
+ try {
|
|
|
MedCrisisInfo medCrisisInfo = this.getOne(new QueryWrapper<MedCrisisInfo>()
|
|
|
.eq("rec_id", s.getRecId())
|
|
|
.eq("hospital_id", s.getHospitalId())
|
|
@@ -76,17 +76,17 @@ public class AMedCrisisFacade extends MedCrisisInfoServiceImpl{
|
|
|
s.setGmtCreate(new Date());
|
|
|
addE.add(s);
|
|
|
}
|
|
|
- });
|
|
|
- }
|
|
|
- if(addE.size()>0){
|
|
|
- medCrisisInfoService.saveBatch(addE);
|
|
|
- }
|
|
|
- if(updateE.size()>0){
|
|
|
- medCrisisInfoService.updateBatchByKey(updateE);
|
|
|
- }
|
|
|
- }catch (Exception e){
|
|
|
- log.error(e.getMessage(),e);
|
|
|
- aMedAbnormalInfoFacade.saveAbnormalInfo("数据解析", JSON.toJSONString(medCrisisList),"",e.getMessage());
|
|
|
+ } catch (Exception e) {
|
|
|
+ log.error(e.getMessage(), e);
|
|
|
+ aMedAbnormalInfoFacade.saveAbnormalInfo("数据解析", s.getRecId(), JSON.toJSONString(medCrisisList), "", e.getMessage());
|
|
|
+ }
|
|
|
+ });
|
|
|
+ }
|
|
|
+ if (addE.size() > 0) {
|
|
|
+ medCrisisInfoService.saveBatch(addE);
|
|
|
+ }
|
|
|
+ if (updateE.size() > 0) {
|
|
|
+ medCrisisInfoService.updateBatchByKey(updateE);
|
|
|
}
|
|
|
}
|
|
|
}
|