feature(机构增量同步功能开发): 机构增量同步功能开发

机构增量同步功能开发

dcuc-auth-service/src/main/java/com/dragoninfo/dcuc/auth/sub/repo/AuthUserAddOriRepo.java

@@ -0,0 +1,32 @@
+package com.dragoninfo.dcuc.auth.sub.repo;
+
+import com.dragoninfo.dcuc.auth.sub.entity.AuthUserAddOriginal;
+import com.dragonsoft.duceap.base.annotations.query.NativeQuery;
+import com.dragonsoft.duceap.core.persistent.repository.BaseRepository;
+import org.springframework.data.jpa.repository.Query;
+import org.springframework.stereotype.Repository;
+
+import java.util.List;
+
+/**
+ * @author mazq
+ * @date 2021/12/17
+ */
+@Repository
+public interface AuthUserAddOriRepo extends BaseRepository<AuthUserAddOriginal, String> {
+
+    /**
+     * 获取增量同步人员的id、idcard、deleted字段信息
+     * @return
+     */
+    @NativeQuery("SELECT ID, IDCARD, USER_DELETED, USER_UPDATE_TIME FROM T_AUTH_USER_ADD_ORIGINAL ORDER BY USER_UPDATE_TIME ASC ")
+    List<AuthUserAddOriginal> getIdcards();
+
+    /**
+     * 查询需要删除的人员身份证号
+     * @return
+     */
+    @Query("SELECT idcard FROM AuthUserAddOriginal WHERE userDeleted = '1'")
+    List<String> getDeleteUserIdcards();
+
+}

dcuc-auth-service/src/main/java/com/dragoninfo/dcuc/auth/sub/service/impl/AuthUserAddOriginalServiceImpl.java

@@ -0,0 +1,53 @@
+package com.dragoninfo.dcuc.auth.sub.service.impl;
+
+import com.dragoninfo.dcuc.auth.sub.entity.AuthUserAddOriginal;
+import com.dragoninfo.dcuc.auth.sub.repo.AuthUserAddOriRepo;
+import com.dragoninfo.dcuc.auth.sub.service.IAuthUserAddOriginalService;
+import com.dragonsoft.duceap.commons.util.collections.CollectionUtils;
+import com.dragonsoft.duceap.core.search.Searchable;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.data.domain.Page;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import java.util.List;
+
+/**
+ * @author mazq
+ * @date 2021/12/17
+ */
+@Transactional(rollbackFor = RuntimeException.class)
+@Service
+public class AuthUserAddOriginalServiceImpl implements IAuthUserAddOriginalService {
+
+    @Autowired
+    private AuthUserAddOriRepo repository;
+
+    @Override
+    public void batchSave(List<AuthUserAddOriginal> originals) {
+        if(CollectionUtils.isEmpty(originals)) {
+            return ;
+        }
+        repository.saveAll(originals);
+    }
+
+    @Override
+    public Page<AuthUserAddOriginal> pageSearch(Searchable searchable) {
+        return repository.paging(searchable);
+    }
+
+    @Override
+    public List<AuthUserAddOriginal> getIdcards() {
+        return repository.getIdcards();
+    }
+
+    @Override
+    public void deleteAll() {
+        repository.deleteAll();
+    }
+
+    @Override
+    public List<String> getDeleteUserIdcards() {
+        return repository.getDeleteUserIdcards();
+    }
+}