fix: 同步服务

1.教职工部门、人员同步不再发kafka同步至校内
2.培训班与人员同步不再发kafka同步至校内

ruoyi-server/ruoyi-server-sync/src/main/java/org/dromara/server/sync/service/impl/DeptServiceImpl.java

@@ -70,7 +70,7 @@ public class DeptServiceImpl implements IDeptService {
             bo.setDeptId(entity.getDeptId());
             SysDeptVo vo = TenantHelper.ignore(
                 () -> deptMapper.selectVoById(bo.getDeptId()));
-            kafkaNormalProducer.sendKafkaMessage(KafkaTopicConstants.SYNC_DATA_TOPIC, EventTypeConstants.DEPT, EventSenderEnum.SYSTEM.code(), vo);
+            //kafkaNormalProducer.sendKafkaMessage(KafkaTopicConstants.SYNC_DATA_TOPIC, EventTypeConstants.DEPT, EventSenderEnum.SYSTEM.code(), vo);
         }
         return iCount > 0;
     }
@@ -89,7 +89,7 @@ public class DeptServiceImpl implements IDeptService {
         if (iCount > 0) {
             SysDeptVo vo = TenantHelper.ignore(
                 () -> deptMapper.selectVoById(bo.getDeptId()));
-            kafkaNormalProducer.sendKafkaMessage(KafkaTopicConstants.SYNC_DATA_TOPIC, EventTypeConstants.DEPT, EventSenderEnum.SYSTEM.code(), vo);
+            //kafkaNormalProducer.sendKafkaMessage(KafkaTopicConstants.SYNC_DATA_TOPIC, EventTypeConstants.DEPT, EventSenderEnum.SYSTEM.code(), vo);
         }
         return iCount > 0;
     }
@@ -127,7 +127,7 @@ public class DeptServiceImpl implements IDeptService {
             //SysDeptVo vo = TenantHelper.ignore(
             //    () -> deptMapper.selectVoOne(new LambdaQueryWrapper<SysDept>().eq(SysDept::getOtherId, otherId).eq(SysDept::getTenantId, tenantId)));
 
-            kafkaNormalProducer.sendKafkaMessage(KafkaTopicConstants.SYNC_DATA_TOPIC, EventTypeConstants.DEPT, EventSenderEnum.SYSTEM.code(), vo);
+            //kafkaNormalProducer.sendKafkaMessage(KafkaTopicConstants.SYNC_DATA_TOPIC, EventTypeConstants.DEPT, EventSenderEnum.SYSTEM.code(), vo);
         }
         return iCount > 0;
     }

ruoyi-server/ruoyi-server-sync/src/main/java/org/dromara/server/sync/service/impl/UserAccountServiceImpl.java

@@ -89,7 +89,7 @@ public class UserAccountServiceImpl implements IUserAccountService {
             }
         }
         vo = TenantHelper.ignore(() -> baseMapper.selectVoById(bo.getUserId()));
-        kafkaNormalProducer.sendKafkaMessage(KafkaTopicConstants.SYNC_DATA_TOPIC, EventTypeConstants.ACCOUNT, EventSenderEnum.BACKSTAGE.code(), vo);
+        //kafkaNormalProducer.sendKafkaMessage(KafkaTopicConstants.SYNC_DATA_TOPIC, EventTypeConstants.ACCOUNT, EventSenderEnum.BACKSTAGE.code(), vo);
         return true;
     }
     /**
@@ -101,7 +101,7 @@ public class UserAccountServiceImpl implements IUserAccountService {
     public Boolean deleteById(String userId) {
         UserAccountVo vo = TenantHelper.ignore(() -> baseMapper.selectVoById(userId));
         vo.setDelFlag(DefaultConstants.DELETED);
-        kafkaNormalProducer.sendKafkaMessage(KafkaTopicConstants.SYNC_DATA_TOPIC, EventTypeConstants.ACCOUNT, EventSenderEnum.BACKSTAGE.code(), vo);
+        //kafkaNormalProducer.sendKafkaMessage(KafkaTopicConstants.SYNC_DATA_TOPIC, EventTypeConstants.ACCOUNT, EventSenderEnum.BACKSTAGE.code(), vo);
         return TenantHelper.ignore(() -> baseMapper.update(null, new LambdaUpdateWrapper<UserAccount>()
             .set(UserAccount::getDelFlag, DefaultConstants.DELETED)
             .set(UserAccount::getUpdateBy, userId)
@@ -115,7 +115,7 @@ public class UserAccountServiceImpl implements IUserAccountService {
         vo.setDelFlag(DefaultConstants.DELETED);
         vo.setUpdateBy(operationId);
         vo.setUpdateTime(DateUtil.date());
-        kafkaNormalProducer.sendKafkaMessage(KafkaTopicConstants.SYNC_DATA_TOPIC, EventTypeConstants.ACCOUNT, EventSenderEnum.BACKSTAGE.code(), vo);
+        //kafkaNormalProducer.sendKafkaMessage(KafkaTopicConstants.SYNC_DATA_TOPIC, EventTypeConstants.ACCOUNT, EventSenderEnum.BACKSTAGE.code(), vo);
         return TenantHelper.ignore(() -> baseMapper.update(null, new LambdaUpdateWrapper<UserAccount>()
             .set(UserAccount::getDelFlag, DefaultConstants.DELETED)
             .set(UserAccount::getUpdateBy, operationId)

ruoyi-server/ruoyi-server-sync/src/main/java/org/dromara/server/sync/service/impl/UserCardServiceImpl.java

@@ -68,7 +68,7 @@ public class UserCardServiceImpl implements IUserCardService {
             }
         }
         UserCardVo vo = baseMapper.selectVoById(bo.getCardId());
-        kafkaNormalProducer.sendKafkaMessage(KafkaTopicConstants.SYNC_DATA_TOPIC, EventTypeConstants.CARD, EventSenderEnum.BACKSTAGE.code(), vo);
+        //kafkaNormalProducer.sendKafkaMessage(KafkaTopicConstants.SYNC_DATA_TOPIC, EventTypeConstants.CARD, EventSenderEnum.BACKSTAGE.code(), vo);
         return flag;
     }
 }

ruoyi-server/ruoyi-server-sync/src/main/java/org/dromara/server/sync/service/impl/UserServiceImpl.java

@@ -68,7 +68,7 @@ public class UserServiceImpl implements IUserService {
             Boolean result = userAccountService.doUserAccount(userAccountBo);
         }
         SysUserVo vo = TenantHelper.ignore(()->baseMapper.selectVoById(bo.getUserId()));
-        kafkaNormalProducer.sendKafkaMessage(KafkaTopicConstants.SYNC_DATA_TOPIC, EventTypeConstants.USER, EventSenderEnum.SYSTEM.code(), vo);
+        //kafkaNormalProducer.sendKafkaMessage(KafkaTopicConstants.SYNC_DATA_TOPIC, EventTypeConstants.USER, EventSenderEnum.SYSTEM.code(), vo);
         return rows > 0;
     }
 
@@ -86,7 +86,7 @@ public class UserServiceImpl implements IUserService {
             Boolean result = userAccountService.doUserAccount(userAccountBo);
         }
         SysUserVo vo = TenantHelper.ignore(()->baseMapper.selectVoById(bo.getUserId()));
-        kafkaNormalProducer.sendKafkaMessage(KafkaTopicConstants.SYNC_DATA_TOPIC, EventTypeConstants.USER, EventSenderEnum.SYSTEM.code(), vo);
+        //kafkaNormalProducer.sendKafkaMessage(KafkaTopicConstants.SYNC_DATA_TOPIC, EventTypeConstants.USER, EventSenderEnum.SYSTEM.code(), vo);
         return rows > 0;
     }
 
@@ -101,7 +101,7 @@ public class UserServiceImpl implements IUserService {
         vo.setDelFlag(DefaultConstants.DELETED);
         vo.setUpdateBy(operatorId);
 
-        kafkaNormalProducer.sendKafkaMessage(KafkaTopicConstants.SYNC_DATA_TOPIC, EventTypeConstants.USER, EventSenderEnum.SYSTEM.code(), vo);
+        //kafkaNormalProducer.sendKafkaMessage(KafkaTopicConstants.SYNC_DATA_TOPIC, EventTypeConstants.USER, EventSenderEnum.SYSTEM.code(), vo);
         userAccountService.deleteById(Long.valueOf(userId), operatorId);
         // 删除人员
         return TenantHelper.ignore(() -> baseMapper.update(null, new LambdaUpdateWrapper<SysUser>()