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.CtUnit; import cn.huge.module.ctuser.domain.po.CtUser; import cn.huge.module.ctuser.domain.po.CtUserole; import cn.huge.module.ctuser.service.CtUnitService; import cn.huge.module.ctuser.service.CtUserService; import cn.huge.module.ctuser.service.CtUseroleService; import cn.huge.module.cust.constant.RoleBaseEnum; import cn.huge.module.cust.constant.UserBaseConsts; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper; 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; @Autowired private CtUnitService ctUnitService; /** * 用户角色更新-白云角色映射为广州角色 */ 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); } } /** * 单位名称更新-白云单位名称街道办->综治中心 */ public void upUnitNameZzzx(){ try{ QueryWrapper ctUnitQueryWrapper = new QueryWrapper<>(); ctUnitQueryWrapper.eq("unit_grade", UserBaseConsts.UNIT_GRADE_3); List ctUnitList = ctUnitService.list(ctUnitQueryWrapper); for (CtUnit ctUnit: ctUnitList){ ctUnit.setUnitName(ctUnit.getUnitName().replace("街道办", "街综治中心")); ctUnitService.updateById(ctUnit); // 更新人员单位名称 UpdateWrapper ctUserUpdateWrapper = new UpdateWrapper<>(); ctUserUpdateWrapper.eq("unit_id", ctUnit.getId()).set("unit_name", ctUnit.getUnitName()); ctUserService.update(ctUserUpdateWrapper); } }catch (Exception e){ log.error("[ByToGzService.upUnitNameZzzx]调用失败,异常信息:"+e, e); throw new ServiceException("ByToGzService.upUnitNameZzzx", e); } } }