package cn.huge.module.bytogz.service; import cn.huge.base.common.exception.ServiceException; import cn.huge.base.common.utils.DateUtils; import cn.huge.base.common.utils.IdUtils; import cn.huge.module.client.api.impl.UtilsClientImpl; import cn.huge.module.ctrole.constant.ByRoleBaseEnum; import cn.huge.module.ctuser.dao.mapper.CtUseroleMapper; import cn.huge.module.ctuser.domain.po.CtUser; import cn.huge.module.ctuser.domain.po.CtUserole; import cn.huge.module.ctuser.service.CtUserService; import cn.huge.module.ctuser.service.CtUseroleService; import cn.huge.module.cust.constant.RoleBaseEnum; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.google.common.collect.Maps; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.data.domain.Page; import org.springframework.data.domain.PageImpl; import org.springframework.data.domain.PageRequest; import org.springframework.data.redis.core.RedisTemplate; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import java.util.Date; import java.util.List; import java.util.Map; /** * @title: 白云数据割接为广州数据的业务逻辑处理 * @Description 白云数据割接为广州数据的业务逻辑处理 * @company hugeinfo * @author liyj * @Time 2024-08-19 20:04:19 * @version 1.0.0 */ @Slf4j @Service @Transactional(rollbackFor = Exception.class) public class ByToGzService{ @Autowired private RedisTemplate redisTemplate; @Autowired private CtUseroleService ctUseroleService; @Autowired private CtUserService ctUserService; /** * 用户角色更新-白云角色映射为广州角色 */ public void upBytoGzUserole(){ try{ List ctUseroleList = ctUseroleService.list(); for (CtUserole ctUserole: ctUseroleList){ if (ctUserole.getRoleCode().equals(ByRoleBaseEnum.ROLE_5) || ctUserole.getRoleCode().equals(ByRoleBaseEnum.ROLE_7) || ctUserole.getRoleCode().equals(ByRoleBaseEnum.ROLE_8)){ ctUseroleService.removeById(ctUserole.getId()); }else { RoleBaseEnum roleBaseEnum = ByRoleBaseEnum.getGzRole(ctUserole.getRoleCode()); ctUserole.setRoleId(roleBaseEnum.getIndex()); ctUserole.setRoleCode(roleBaseEnum.getIndex()); ctUserole.setRoleName(roleBaseEnum.getDes()); ctUseroleService.updateById(ctUserole); } } }catch (Exception e){ log.error("[ByToGzService.upBytoGzUserole]调用失败,异常信息:"+e, e); throw new ServiceException("ByToGzService.upBytoGzUserole", e); } } }