docus-collector
/
jp2demo
5
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

市一同步联众数据

Browse Source
jp2demo1.0
linjj 1 year ago
parent bcbbd2a7c1
commit 7c3e665fd3
1 changed files with 7 additions and 9 deletions
Show Stats Download Patch File Download Diff File

16
src/main/java/com/docus/demo/service/SyncBasicFileImpl.java
Unescape Escape View File

@ -215,28 +215,26 @@ public class SyncBasicFileImpl implements ISyncBasicFileService {
tbasics.add(tbasic); tbasics.add(tbasic);
//查询是否存在更新，不存在新增 //查询是否存在更新，不存在新增
Tbasic tBasic = basicMapper.getTbasicPatientId(admissId); Tbasic tBasic = basicMapper.getTbasicPatientId(admissId);
log.info("tBasic"+new Gson().toJson(tBasic));
String tBasicPatientId = tBasic.getPatientId();
if (StringUtils.isNotBlank(tbasic.getPh())){ if (StringUtils.isNotBlank(tbasic.getPh())){
return CommonResult.success("存在盘号,保存成功"); return CommonResult.success("存在盘号,保存成功");
} }
if (StringUtils.isBlank(tBasicPatientId)) { if (ObjectUtil.isEmpty(tBasic)) {
if (!basicMapper.addBasic(tbasics)) { if (basicMapper.addBasic(tbasics)) {
basicMapper.insertOrUpdateTbasicSub(tbasicSubList); basicMapper.insertOrUpdateTbasicSub(tbasicSubList);
log.info("新增PatientId为:" + patientId + "的基础数据成功");
} else {
log.info("新增PatientId为:" + patientId + "的基础数据失败"); log.info("新增PatientId为:" + patientId + "的基础数据失败");
return CommonResult.failed("新增PatientId为:" + patientId + "的基础数据失败"); return CommonResult.failed("新增PatientId为:" + patientId + "的基础数据失败");
} else {
log.info("新增PatientId为:" + patientId + "的基础数据成功");
} }
} else { } else {
//存在时先删除基础数据图像数据，后新增 //存在时先删除基础数据图像数据，后新增
if (basicMapper.delTbasicByPatientId(admissId)) { if (basicMapper.delTbasicByPatientId(admissId)) {
//删除tbasic拓展表 //删除tbasic拓展表
basicMapper.delTbasicSub(tBasicPatientId); basicMapper.delTbasicSub(tBasic.getPatientId());
//薪资拓展表 //薪资拓展表
basicMapper.insertOrUpdateTbasicSub(tbasicSubList); basicMapper.insertOrUpdateTbasicSub(tbasicSubList);
//删除路径图像 //删除路径图像
List<ScanAssort> scanAssort = scanAssortMapper.getScanAssort(tBasicPatientId); List<ScanAssort> scanAssort = scanAssortMapper.getScanAssort(tBasic.getPatientId());
if (!CollectionUtils.isEmpty(scanAssort)) { if (!CollectionUtils.isEmpty(scanAssort)) {
for (ScanAssort list : scanAssort) { for (ScanAssort list : scanAssort) {
File file = new File(list.getImagePath() + File.separatorChar + list.getScanPage()); File file = new File(list.getImagePath() + File.separatorChar + list.getScanPage());
@ -248,7 +246,7 @@ public class SyncBasicFileImpl implements ISyncBasicFileService {
} }
} }
//删除文件数据 //删除文件数据
scanAssortMapper.delScanAssort(tBasicPatientId); scanAssortMapper.delScanAssort(tBasic.getPatientId());
if (!basicMapper.addBasic(tbasics)) { if (!basicMapper.addBasic(tbasics)) {
log.info("新增PatientId为:" + patientId + "的基础数据失败"); log.info("新增PatientId为:" + patientId + "的基础数据失败");
return CommonResult.failed("新增PatientId为:" + patientId + "的基础数据失败"); return CommonResult.failed("新增PatientId为:" + patientId + "的基础数据失败");

Write Preview
Loading…
Cancel
Save