报错修复

service-issue/service-issue-biz/src/main/java/com/usky/issue/service/impl/CloudSyncReceiveServiceImpl.java

@@ -136,12 +136,12 @@ public class CloudSyncReceiveServiceImpl implements CloudSyncReceiveService {
 
     @Override
     public int countPendingDownQueue(Integer tenantId, String tableName) {
-        Long count = downQueueMapper.selectCount(new LambdaQueryWrapper<IssueSyncDownQueue>()
+        Integer count = downQueueMapper.selectCount(new LambdaQueryWrapper<IssueSyncDownQueue>()
                 .eq(IssueSyncDownQueue::getTenantId, tenantId)
                 .eq(IssueSyncDownQueue::getTableName, tableName)
                 .eq(IssueSyncDownQueue::getStatus, 0)
                 .eq(IssueSyncDownQueue::getDeleted, 0));
-        return count == null ? 0 : count.intValue();
+        return count == null ? 0 : count;
     }
 
     @SuppressWarnings("unchecked")

service-issue/service-issue-biz/src/main/java/com/usky/issue/service/impl/LocalSyncAgentImpl.java

@@ -71,12 +71,11 @@ public class LocalSyncAgentImpl implements LocalSyncAgent {
     @Override
     public int countPending(SyncTypeEnum syncType, IssueCloudConfig config) {
         String tableName = syncType.getCode();
-        Long upCount = syncDataMapper.selectCount(new LambdaQueryWrapper<IssueSyncData>()
+        Integer upCount = syncDataMapper.selectCount(new LambdaQueryWrapper<IssueSyncData>()
                 .eq(IssueSyncData::getTenantId, config.getTenantId())
                 .eq(IssueSyncData::getTableName, tableName)
                 .in(IssueSyncData::getSyncStatus, 0, 2)
                 .eq(IssueSyncData::getDeleted, 0));
-        int downCount = cloudSyncReceiveService.countPendingDownQueue(config.getTenantId(), tableName);
-        return (upCount == null ? 0 : upCount.intValue()) + downCount;
+        return cloudSyncReceiveService.countPendingDownQueue(config.getTenantId(), tableName);
     }
 }