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

机构增量同步功能开发

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

@@ -27,6 +27,8 @@ import com.dragonsoft.duceap.base.entity.security.SecurityUser;
 import com.dragonsoft.duceap.base.enums.BooleanEnum;
 import com.dragonsoft.duceap.base.utils.UserContextUtils;
 import com.dragonsoft.duceap.commons.util.collections.CollectionUtils;
+import com.dragonsoft.duceap.commons.util.date.DateConst;
+import com.dragonsoft.duceap.commons.util.date.DateUtils;
 import com.dragonsoft.duceap.commons.util.string.StringUtils;
 import com.dragonsoft.duceap.core.search.Searchable;
 import com.dragonsoft.duceap.core.search.enums.SearchOperator;
@@ -883,9 +885,10 @@ public class SubSyncBusinessImpl implements ISubSyncBusiness {
         //设置同步时间
         SearchParam searchParam = new SearchParam();
         Map<String, SearchParam> filters = new HashMap<>();
-        filters.put("beginUpdateTime", searchParam);
         searchParam.setOperator(SearchOperator.ge.name());
-        searchParam.setValue(syncStartTime);
+        String dateFormat = DateUtils.getDateFormat(syncStartTime, DateConst.HYPHEN_DISPLAY_TIME);
+        searchParam.setValue(dateFormat);
+        filters.put("beginUpdateTime", searchParam);
         apiSearchReq.setFilters(filters);
         apiSearchReq.setPage(pageReq);
         String url = Joiner.on("").join(authConfig.getUserCenterUrl(), userInfoApi);
@@ -1161,9 +1164,10 @@ public class SubSyncBusinessImpl implements ISubSyncBusiness {
         //设置同步时间
         SearchParam searchParam = new SearchParam();
         Map<String, SearchParam> filters = new HashMap<>();
-        filters.put("beginUpdateTime", searchParam);
         searchParam.setOperator(SearchOperator.ge.name());
-        searchParam.setValue(syncStartTime);
+        String dateFormat = DateUtils.getDateFormat(syncStartTime, DateConst.HYPHEN_DISPLAY_TIME);
+        searchParam.setValue(dateFormat);
+        filters.put("beginUpdateTime", searchParam);
         apiSearchReq.setFilters(filters);
         apiSearchReq.setPage(pageReq);
         String url = Joiner.on("").join(authConfig.getUserCenterUrl(), UserApiConstance.ORG_SYNC_API);