Parcourir la source

下发数据时排除掉kafka更新导致的更新数据

xiari il y a 11 mois
Parent
commit
523a0a1f9c

+ 4 - 1
ruoyi-modules/ruoyi-backstage/src/main/java/org/dromara/backstage/payment/service/impl/PtUserAccountServiceImpl.java

@@ -63,6 +63,7 @@ import java.util.*;
 import java.util.stream.Collectors;
 
 import static org.dromara.common.core.constant.DefaultConstants.FULL_SYNC_ADMIN;
+import static org.dromara.common.core.constant.DefaultConstants.KAFKA_SYNC_ADMIN;
 
 /**
  * 一卡通账户Service业务层处理
@@ -683,7 +684,9 @@ public class PtUserAccountServiceImpl implements IPtUserAccountService {
         // 人脸的
         Date date = new Date();
         //排除 全量同步的数据
-        LambdaQueryWrapper<PtUserAccount> between = Wrappers.lambdaQuery(PtUserAccount.class).ne(PtUserAccount::getUpdateBy, FULL_SYNC_ADMIN)
+        LambdaQueryWrapper<PtUserAccount> between = Wrappers.lambdaQuery(PtUserAccount.class)
+            .ne(PtUserAccount::getUpdateBy, FULL_SYNC_ADMIN)
+            .ne(PtUserAccount::getUpdateBy, KAFKA_SYNC_ADMIN)
             .between(PtUserAccount::getUpdateTime, startDate, date);
         List<PtUserAccountVo> userAccountVos = baseMapper.selectVoList(between);
         List<PtUserAccountVo> updatePhotos = userAccountVos.stream().filter(e -> StringUtils.isNotBlank(e.getPhoto())).toList();