feature: 同步功能完善

1.修复部门删除没有同步到本地的bug

ruoyi-common/ruoyi-common-message/src/main/java/org/dromara/common/message/kafka/constant/EventTypeConstants.java

@@ -1,7 +1,5 @@
 package org.dromara.common.message.kafka.constant;
 
-import org.dromara.common.message.kafka.enums.EventSenderEnum;
-
 /**
  * @ClassName EventTypeConstants
  * @Description 消费推送事件类型常量，EventTypeEnum对应

ruoyi-server/ruoyi-server-mqdata/src/main/java/org/dromara/server/mq/event/kafka/impl/local/SystemEventStrategyImpl.java

@@ -40,6 +40,7 @@ public class SystemEventStrategyImpl implements IYktEventStrategy {
 
     @Override
     public void doMsgHandle(String eventType, Object msg) throws Exception {
+        log.info(eventType);
         switch (eventType) {
             case EventTypeConstants.DEPT -> {
                 RemoteDeptBo remoteDeptBo = JSONUtil.toBean(JSONUtil.parseObj(msg), RemoteDeptBo.class);

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

@@ -57,9 +57,7 @@ public class UserAccountServiceImpl implements IUserAccountService {
     @Override
     public Boolean doUserAccount(UserAccountBo bo) {
         UserAccount entity = MapstructUtils.convert(bo, UserAccount.class);
-        log.info("传入账户数据:{}",bo);
         UserAccountVo vo = TenantHelper.ignore(() -> baseMapper.selectVoById(bo.getUserId()));
-        log.info("查询账户数据:{}",vo);
         int rows;
         if(ObjectUtil.isEmpty(vo)){
             // 当前没有一卡通账户，先增加账户信息

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

@@ -6,7 +6,6 @@ import cn.hutool.core.date.DateUtil;
 import cn.hutool.core.util.ObjectUtil;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
-import com.esotericsoftware.minlog.Log;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.dromara.common.core.constant.DefaultConstants;
@@ -64,7 +63,6 @@ public class UserServiceImpl implements IUserService {
         // 新增用户岗位关联
         insertUserDept(bo, bo.getUserDeptBoList());
         if (rows > 0) {
-            Log.info("增加用户");
             UserAccountBo userAccountBo = BeanUtil.copyProperties(bo, UserAccountBo.class);
             userAccountBo.setAccountStatus(UserAccountStatusEnum.IS_OPEN.code().toString());
             Boolean result = userAccountService.doUserAccount(userAccountBo);
@@ -83,7 +81,6 @@ public class UserServiceImpl implements IUserService {
         SysUser sysUser = MapstructUtils.convert(bo, SysUser.class);
         int rows = TenantHelper.ignore(() -> baseMapper.updateById(sysUser));
         if (rows > 0) {
-            log.info("修改用户");
             UserAccountBo userAccountBo = BeanUtil.copyProperties(bo, UserAccountBo.class);
             userAccountBo.setAccountStatus(UserAccountStatusEnum.IS_OPEN.code().toString());
             Boolean result = userAccountService.doUserAccount(userAccountBo);