diff --git a/src/main/java/com/zcloud/syncData/SyncDataAdviceAspect.java b/src/main/java/com/zcloud/syncData/SyncDataAdviceAspect.java index 2acaf8ab..d50553f2 100644 --- a/src/main/java/com/zcloud/syncData/SyncDataAdviceAspect.java +++ b/src/main/java/com/zcloud/syncData/SyncDataAdviceAspect.java @@ -27,6 +27,7 @@ import java.util.Map; */ @Aspect @Component +@SuppressWarnings("all") public class SyncDataAdviceAspect { @Pointcut(value = "@annotation(com.zcloud.syncData.SyncPlatformAdvice)") diff --git a/src/main/java/com/zcloud/syncData/listener/SyncDataListener.java b/src/main/java/com/zcloud/syncData/listener/SyncDataListener.java index 93c6b1b2..a313f873 100644 --- a/src/main/java/com/zcloud/syncData/listener/SyncDataListener.java +++ b/src/main/java/com/zcloud/syncData/listener/SyncDataListener.java @@ -33,6 +33,7 @@ import java.util.Date; topic = "${mq.consumer.dataChange.tongbu-data-change.topic}", selectorType = SelectorType.TAG, messageModel = MessageModel.BROADCASTING) // 添加广播模式 +@SuppressWarnings("all") public class SyncDataListener implements RocketMQListener { @Autowired @@ -102,10 +103,10 @@ public class SyncDataListener implements RocketMQListener { // 相关方推送 xgfUserService.edit4Mq(syncInfo); } - PageData localData = usersService.findById(syncInfo); - if (localData != null && !localData.isEmpty()){ - usersService.editUser(syncInfo); - } +// PageData localData = usersService.findById(syncInfo); +// if (localData != null && !localData.isEmpty()){ +// usersService.editUser(syncInfo); +// } // 2024.8.9 按郭跃鹏提出:后期各公司从企业端分离后,需要其他公司的用户进行SQL联查,要求新增一张core_user的同步表,用于记录中台的所有用户数据 PageData coreLocalData = coreSyncUserMapper.findById(syncInfo); @@ -134,9 +135,9 @@ public class SyncDataListener implements RocketMQListener { String str = tenCorpDto.getData().getString("syncInfo"); PageData syncInfo = JSONUtil.toBean(str, PageData.class); PageData localData = departmentMapper.findById(syncInfo); - if (localData != null && !localData.isEmpty()){ - departmentMapper.edit(syncInfo); - } +// if (localData != null && !localData.isEmpty()){ +// departmentMapper.edit(syncInfo); +// } PageData coreLocalData = coreSyncDeptMapper.findById(syncInfo); try { @@ -161,9 +162,9 @@ public class SyncDataListener implements RocketMQListener { String str = tenCorpDto.getData().getString("syncInfo"); PageData syncInfo = JSONUtil.toBean(str, PageData.class); PageData localData = corpinfoMapper.findById(syncInfo); - if (localData != null && !localData.isEmpty()){ - corpinfoMapper.edit(syncInfo); - } +// if (localData != null && !localData.isEmpty()){ +// corpinfoMapper.edit(syncInfo); +// } PageData coreLocalData = coreSyncCorpMapper.findById(syncInfo); try {