feature: 同步服务完善

1.全量人员双向同步

ruoyi-api/ruoyi-api-system/src/main/java/org/dromara/system/api/domain/bo/RemoteUserBo.java

@@ -199,9 +199,10 @@ public class RemoteUserBo implements Serializable {
      */
     private List<RemoteUserDeptBo> userDeptList;
 
-    public RemoteUserBo(Long userId) {
-        this.userId = userId;
-    }
+    /**
+     * 账户流水号
+     */
+    private Long userNo;
 
     public boolean isSuperAdmin() {
         return UserConstants.SUPER_ADMIN_ID.equals(this.userId);

ruoyi-modules/ruoyi-system/src/main/java/org/dromara/system/domain/vo/SysUserVo.java

@@ -175,4 +175,9 @@ public class SysUserVo implements Serializable {
      */
     private Long roleId;
 
+    /**
+     * 账户流水号
+     */
+    private Long userNo;
+
 }

ruoyi-server/ruoyi-server-mqdata/src/main/java/org/dromara/server/mq/consumer/SyncKafkaConsumer.java

@@ -24,12 +24,12 @@ import org.springframework.stereotype.Component;
  */
 @RequiredArgsConstructor
 @Slf4j
-@Component
+//@Component
 @ConditionalOnExpression("'local'.equals('${locationFlag}')")
 public class SyncKafkaConsumer {
     private final EventStrategyContext eventStrategyContext;
 
-    @KafkaListener(topics = "eventBus", groupId = "test-group-id")
+    //@KafkaListener(topics = "eventBus", groupId = "test-group-id")
     public void kafkaReceiveHandler(ConsumerRecord<String, String> record) {
         KafkaMessage<?> receiveMsg = JSONUtil.toBean(record.value(), KafkaMessage.class);
         String eventType = receiveMsg.getHeader().getEventType();