From b9b5e52f2b44a3db7261f3211d1f2ac6d25aea97 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=AE=87=E5=AE=99=E7=9A=AE=E7=9A=AE=E5=A8=83?= <2964346877@qq.com> Date: Fri, 16 Aug 2024 15:22:07 +0800 Subject: [PATCH] =?UTF-8?q?=E6=A2=85=E5=B7=9E=E4=B8=89=E9=99=A2=E5=9F=BA?= =?UTF-8?q?=E7=A1=80=E6=95=B0=E6=8D=AE=E5=90=8C=E6=AD=A5=E5=8A=A0=E4=B8=BB?= =?UTF-8?q?=E7=AE=A1=E5=8C=BB=E7=94=9F=E5=90=8D=E5=AD=97?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../impl/MzsyPatientInfoSyncServiceImpl.java | 15 +++++++++++++++ .../mzsy/mapper/MzsyPatientInfoViewMapper.java | 3 +++ 2 files changed, 18 insertions(+) diff --git a/src/main/java/com/docus/server/archive/service/impl/MzsyPatientInfoSyncServiceImpl.java b/src/main/java/com/docus/server/archive/service/impl/MzsyPatientInfoSyncServiceImpl.java index d593a5b..4c54ddb 100644 --- a/src/main/java/com/docus/server/archive/service/impl/MzsyPatientInfoSyncServiceImpl.java +++ b/src/main/java/com/docus/server/archive/service/impl/MzsyPatientInfoSyncServiceImpl.java @@ -5,7 +5,9 @@ import com.docus.core.util.ObjectUtil; import com.docus.infrastructure.redis.service.IdService; import com.docus.server.archive.constans.SyncConstant; import com.docus.server.archive.converter.MzsyPatientInfoConverter; +import com.docus.server.archive.entity.PowerUser; import com.docus.server.archive.entity.TBasic; +import com.docus.server.archive.mapper.PowerUserMapper; import com.docus.server.archive.mapper.TBasicMapper; import com.docus.server.archive.service.PatientInfoSyncService; import com.docus.server.mzsy.entity.MzsyPatientInfoView; @@ -30,6 +32,8 @@ public class MzsyPatientInfoSyncServiceImpl implements PatientInfoSyncService { private MzsyPatientInfoViewMapper mzsyPatientInfoViewMapper; @Resource private IdService idService; + @Resource + private PowerUserMapper powerUserMapper; @Override public void syncByDisDate(LocalDateTime start, LocalDateTime end) { @@ -53,6 +57,17 @@ public class MzsyPatientInfoSyncServiceImpl implements PatientInfoSyncService { List basicList = patientInfoViews.stream() .map(MzsyPatientInfoConverter::convertPatientInfo) .collect(Collectors.toList()); + List collect = basicList.stream().map(TBasic::getAttending).collect(Collectors.toList()); + List byUserNames = powerUserMapper.findByUserNames(collect); + if(ObjectUtil.isNotEmpty(byUserNames)){ + Map map = byUserNames.stream().collect(Collectors.toMap(PowerUser::getUserName, PowerUser::getName)); + for (TBasic tBasic : basicList) { + String attending = tBasic.getAttending(); + if(ObjectUtil.isNotEmpty(attending)) { + tBasic.setAttendingName(map.get(attending)); + } + } + } saveOrUpdate(basicList); } if (Func.isEmpty(patientInfoViews) || patientInfoViews.size() < size) { diff --git a/src/main/java/com/docus/server/mzsy/mapper/MzsyPatientInfoViewMapper.java b/src/main/java/com/docus/server/mzsy/mapper/MzsyPatientInfoViewMapper.java index 3ddd169..c5723fb 100644 --- a/src/main/java/com/docus/server/mzsy/mapper/MzsyPatientInfoViewMapper.java +++ b/src/main/java/com/docus/server/mzsy/mapper/MzsyPatientInfoViewMapper.java @@ -15,4 +15,7 @@ public interface MzsyPatientInfoViewMapper { * @return 患者视图数据根据上次同步时间往后查询 */ List pageByViwe(@Param("cyrqStart") String cyrqStart,@Param("startTime") String startTime,@Param("pageNum") Integer pageNum, @Param("pageSize") Integer pageSize); + + + }