update 统一注入变量命名规则

This commit is contained in:
Yjoioooo 2023-03-27 11:40:28 +08:00
parent 22c681a8d4
commit 91ce812225
7 changed files with 67 additions and 68 deletions

View File

@ -35,7 +35,7 @@ import java.util.List;
@RequestMapping("/system/oss/config") @RequestMapping("/system/oss/config")
public class SysOssConfigController extends BaseController { public class SysOssConfigController extends BaseController {
private final ISysOssConfigService sysOssConfigService; private final ISysOssConfigService ossConfigService;
/** /**
* 查询对象存储配置列表 * 查询对象存储配置列表
@ -43,7 +43,7 @@ public class SysOssConfigController extends BaseController {
@SaCheckPermission("system:oss:list") @SaCheckPermission("system:oss:list")
@GetMapping("/list") @GetMapping("/list")
public TableDataInfo<SysOssConfigVo> list(@Validated(QueryGroup.class) SysOssConfigBo bo, PageQuery pageQuery) { public TableDataInfo<SysOssConfigVo> list(@Validated(QueryGroup.class) SysOssConfigBo bo, PageQuery pageQuery) {
return sysOssConfigService.queryPageList(bo, pageQuery); return ossConfigService.queryPageList(bo, pageQuery);
} }
/** /**
@ -55,7 +55,7 @@ public class SysOssConfigController extends BaseController {
@GetMapping("/{ossConfigId}") @GetMapping("/{ossConfigId}")
public R<SysOssConfigVo> getInfo(@NotNull(message = "主键不能为空") public R<SysOssConfigVo> getInfo(@NotNull(message = "主键不能为空")
@PathVariable Long ossConfigId) { @PathVariable Long ossConfigId) {
return R.ok(sysOssConfigService.queryById(ossConfigId)); return R.ok(ossConfigService.queryById(ossConfigId));
} }
/** /**
@ -66,7 +66,7 @@ public class SysOssConfigController extends BaseController {
@RepeatSubmit() @RepeatSubmit()
@PostMapping() @PostMapping()
public R<Void> add(@Validated(AddGroup.class) @RequestBody SysOssConfigBo bo) { public R<Void> add(@Validated(AddGroup.class) @RequestBody SysOssConfigBo bo) {
return toAjax(sysOssConfigService.insertByBo(bo)); return toAjax(ossConfigService.insertByBo(bo));
} }
/** /**
@ -77,7 +77,7 @@ public class SysOssConfigController extends BaseController {
@RepeatSubmit() @RepeatSubmit()
@PutMapping() @PutMapping()
public R<Void> edit(@Validated(EditGroup.class) @RequestBody SysOssConfigBo bo) { public R<Void> edit(@Validated(EditGroup.class) @RequestBody SysOssConfigBo bo) {
return toAjax(sysOssConfigService.updateByBo(bo)); return toAjax(ossConfigService.updateByBo(bo));
} }
/** /**
@ -90,7 +90,7 @@ public class SysOssConfigController extends BaseController {
@DeleteMapping("/{ossConfigIds}") @DeleteMapping("/{ossConfigIds}")
public R<Void> remove(@NotEmpty(message = "主键不能为空") public R<Void> remove(@NotEmpty(message = "主键不能为空")
@PathVariable Long[] ossConfigIds) { @PathVariable Long[] ossConfigIds) {
return toAjax(sysOssConfigService.deleteWithValidByIds(List.of(ossConfigIds), true)); return toAjax(ossConfigService.deleteWithValidByIds(List.of(ossConfigIds), true));
} }
/** /**
@ -100,6 +100,6 @@ public class SysOssConfigController extends BaseController {
@Log(title = "对象存储状态修改", businessType = BusinessType.UPDATE) @Log(title = "对象存储状态修改", businessType = BusinessType.UPDATE)
@PutMapping("/changeStatus") @PutMapping("/changeStatus")
public R<Void> changeStatus(@RequestBody SysOssConfigBo bo) { public R<Void> changeStatus(@RequestBody SysOssConfigBo bo) {
return toAjax(sysOssConfigService.updateOssConfigStatus(bo)); return toAjax(ossConfigService.updateOssConfigStatus(bo));
} }
} }

View File

@ -38,7 +38,7 @@ import java.util.List;
@RequestMapping("/system/oss") @RequestMapping("/system/oss")
public class SysOssController extends BaseController { public class SysOssController extends BaseController {
private final ISysOssService sysOssService; private final ISysOssService ossService;
/** /**
* 查询OSS对象存储列表 * 查询OSS对象存储列表
@ -46,7 +46,7 @@ public class SysOssController extends BaseController {
@SaCheckPermission("system:oss:list") @SaCheckPermission("system:oss:list")
@GetMapping("/list") @GetMapping("/list")
public TableDataInfo<SysOssVo> list(@Validated(QueryGroup.class) SysOssBo bo, PageQuery pageQuery) { public TableDataInfo<SysOssVo> list(@Validated(QueryGroup.class) SysOssBo bo, PageQuery pageQuery) {
return sysOssService.queryPageList(bo, pageQuery); return ossService.queryPageList(bo, pageQuery);
} }
/** /**
@ -58,7 +58,7 @@ public class SysOssController extends BaseController {
@GetMapping("/listByIds/{ossIds}") @GetMapping("/listByIds/{ossIds}")
public R<List<SysOssVo>> listByIds(@NotEmpty(message = "主键不能为空") public R<List<SysOssVo>> listByIds(@NotEmpty(message = "主键不能为空")
@PathVariable Long[] ossIds) { @PathVariable Long[] ossIds) {
List<SysOssVo> list = sysOssService.listByIds(Arrays.asList(ossIds)); List<SysOssVo> list = ossService.listByIds(Arrays.asList(ossIds));
return R.ok(list); return R.ok(list);
} }
@ -74,7 +74,7 @@ public class SysOssController extends BaseController {
if (ObjectUtil.isNull(file)) { if (ObjectUtil.isNull(file)) {
throw new ServiceException("上传文件不能为空"); throw new ServiceException("上传文件不能为空");
} }
SysOssVo oss = sysOssService.upload(file); SysOssVo oss = ossService.upload(file);
SysOssUploadVo uploadVo = new SysOssUploadVo(); SysOssUploadVo uploadVo = new SysOssUploadVo();
uploadVo.setUrl(oss.getUrl()); uploadVo.setUrl(oss.getUrl());
uploadVo.setFileName(oss.getOriginalName()); uploadVo.setFileName(oss.getOriginalName());
@ -90,7 +90,7 @@ public class SysOssController extends BaseController {
@SaCheckPermission("system:oss:download") @SaCheckPermission("system:oss:download")
@GetMapping("/download/{ossId}") @GetMapping("/download/{ossId}")
public void download(@PathVariable Long ossId, HttpServletResponse response) throws IOException { public void download(@PathVariable Long ossId, HttpServletResponse response) throws IOException {
sysOssService.download(ossId, response); ossService.download(ossId, response);
} }
/** /**
@ -103,7 +103,7 @@ public class SysOssController extends BaseController {
@DeleteMapping("/{ossIds}") @DeleteMapping("/{ossIds}")
public R<Void> remove(@NotEmpty(message = "主键不能为空") public R<Void> remove(@NotEmpty(message = "主键不能为空")
@PathVariable Long[] ossIds) { @PathVariable Long[] ossIds) {
return toAjax(sysOssService.deleteWithValidByIds(List.of(ossIds), true)); return toAjax(ossService.deleteWithValidByIds(List.of(ossIds), true));
} }
} }

View File

@ -38,7 +38,7 @@ import java.util.Arrays;
public class SysProfileController extends BaseController { public class SysProfileController extends BaseController {
private final ISysUserService userService; private final ISysUserService userService;
private final ISysOssService sysOssService; private final ISysOssService ossService;
/** /**
* 个人信息 * 个人信息
@ -110,7 +110,7 @@ public class SysProfileController extends BaseController {
if (!StringUtils.equalsAnyIgnoreCase(extension, MimeTypeUtils.IMAGE_EXTENSION)) { if (!StringUtils.equalsAnyIgnoreCase(extension, MimeTypeUtils.IMAGE_EXTENSION)) {
return R.fail("文件格式不正确,请上传" + Arrays.toString(MimeTypeUtils.IMAGE_EXTENSION) + "格式"); return R.fail("文件格式不正确,请上传" + Arrays.toString(MimeTypeUtils.IMAGE_EXTENSION) + "格式");
} }
SysOssVo oss = sysOssService.upload(avatarfile); SysOssVo oss = ossService.upload(avatarfile);
String avatar = oss.getUrl(); String avatar = oss.getUrl();
if (userService.updateUserAvatar(LoginHelper.getUserId(), oss.getOssId())) { if (userService.updateUserAvatar(LoginHelper.getUserId(), oss.getOssId())) {
AvatarVo avatarVo = new AvatarVo(); AvatarVo avatarVo = new AvatarVo();

View File

@ -41,8 +41,7 @@ import java.util.List;
@RequestMapping("/system/tenant") @RequestMapping("/system/tenant")
public class SysTenantController extends BaseController { public class SysTenantController extends BaseController {
private final ISysTenantService sysTenantService; private final ISysTenantService tenantService;
private final ISysUserService sysUserService;
/** /**
* 查询租户列表 * 查询租户列表
@ -51,7 +50,7 @@ public class SysTenantController extends BaseController {
@SaCheckPermission("system:tenant:list") @SaCheckPermission("system:tenant:list")
@GetMapping("/list") @GetMapping("/list")
public TableDataInfo<SysTenantVo> list(SysTenantBo bo, PageQuery pageQuery) { public TableDataInfo<SysTenantVo> list(SysTenantBo bo, PageQuery pageQuery) {
return sysTenantService.queryPageList(bo, pageQuery); return tenantService.queryPageList(bo, pageQuery);
} }
/** /**
@ -62,7 +61,7 @@ public class SysTenantController extends BaseController {
@Log(title = "租户", businessType = BusinessType.EXPORT) @Log(title = "租户", businessType = BusinessType.EXPORT)
@PostMapping("/export") @PostMapping("/export")
public void export(SysTenantBo bo, HttpServletResponse response) { public void export(SysTenantBo bo, HttpServletResponse response) {
List<SysTenantVo> list = sysTenantService.queryList(bo); List<SysTenantVo> list = tenantService.queryList(bo);
ExcelUtil.exportExcel(list, "租户", SysTenantVo.class, response); ExcelUtil.exportExcel(list, "租户", SysTenantVo.class, response);
} }
@ -76,7 +75,7 @@ public class SysTenantController extends BaseController {
@GetMapping("/{id}") @GetMapping("/{id}")
public R<SysTenantVo> getInfo(@NotNull(message = "主键不能为空") public R<SysTenantVo> getInfo(@NotNull(message = "主键不能为空")
@PathVariable Long id) { @PathVariable Long id) {
return R.ok(sysTenantService.queryById(id)); return R.ok(tenantService.queryById(id));
} }
/** /**
@ -89,10 +88,10 @@ public class SysTenantController extends BaseController {
@RepeatSubmit() @RepeatSubmit()
@PostMapping() @PostMapping()
public R<Void> add(@Validated(AddGroup.class) @RequestBody SysTenantBo bo) { public R<Void> add(@Validated(AddGroup.class) @RequestBody SysTenantBo bo) {
if (!sysTenantService.checkCompanyNameUnique(bo)) { if (!tenantService.checkCompanyNameUnique(bo)) {
throw new ServiceException("新增租户'" + bo.getCompanyName() + "'失败,企业名称已存在"); throw new ServiceException("新增租户'" + bo.getCompanyName() + "'失败,企业名称已存在");
} }
return toAjax(sysTenantService.insertByBo(bo)); return toAjax(tenantService.insertByBo(bo));
} }
/** /**
@ -104,11 +103,11 @@ public class SysTenantController extends BaseController {
@RepeatSubmit() @RepeatSubmit()
@PutMapping() @PutMapping()
public R<Void> edit(@Validated(EditGroup.class) @RequestBody SysTenantBo bo) { public R<Void> edit(@Validated(EditGroup.class) @RequestBody SysTenantBo bo) {
sysTenantService.checkTenantAllowed(bo.getTenantId()); tenantService.checkTenantAllowed(bo.getTenantId());
if (!sysTenantService.checkCompanyNameUnique(bo)) { if (!tenantService.checkCompanyNameUnique(bo)) {
throw new ServiceException("修改租户'" + bo.getCompanyName() + "'失败,公司名称已存在"); throw new ServiceException("修改租户'" + bo.getCompanyName() + "'失败,公司名称已存在");
} }
return toAjax(sysTenantService.updateByBo(bo)); return toAjax(tenantService.updateByBo(bo));
} }
/** /**
@ -119,8 +118,8 @@ public class SysTenantController extends BaseController {
@Log(title = "租户", businessType = BusinessType.UPDATE) @Log(title = "租户", businessType = BusinessType.UPDATE)
@PutMapping("/changeStatus") @PutMapping("/changeStatus")
public R<Void> changeStatus(@RequestBody SysTenantBo bo) { public R<Void> changeStatus(@RequestBody SysTenantBo bo) {
sysTenantService.checkTenantAllowed(bo.getTenantId()); tenantService.checkTenantAllowed(bo.getTenantId());
return toAjax(sysTenantService.updateTenantStatus(bo)); return toAjax(tenantService.updateTenantStatus(bo));
} }
/** /**
@ -134,7 +133,7 @@ public class SysTenantController extends BaseController {
@DeleteMapping("/{ids}") @DeleteMapping("/{ids}")
public R<Void> remove(@NotEmpty(message = "主键不能为空") public R<Void> remove(@NotEmpty(message = "主键不能为空")
@PathVariable Long[] ids) { @PathVariable Long[] ids) {
return toAjax(sysTenantService.deleteWithValidByIds(List.of(ids), true)); return toAjax(tenantService.deleteWithValidByIds(List.of(ids), true));
} }
/** /**
@ -171,7 +170,7 @@ public class SysTenantController extends BaseController {
@Log(title = "租户", businessType = BusinessType.UPDATE) @Log(title = "租户", businessType = BusinessType.UPDATE)
@GetMapping("/syncTenantPackage") @GetMapping("/syncTenantPackage")
public R<Void> syncTenantPackage(@NotBlank(message = "租户ID不能为空") String tenantId, @NotBlank(message = "套餐ID不能为空") String packageId) { public R<Void> syncTenantPackage(@NotBlank(message = "租户ID不能为空") String tenantId, @NotBlank(message = "套餐ID不能为空") String packageId) {
return toAjax(sysTenantService.syncTenantPackage(tenantId, packageId)); return toAjax(tenantService.syncTenantPackage(tenantId, packageId));
} }
} }

View File

@ -36,7 +36,7 @@ import java.util.List;
@RequestMapping("/system/tenant/package") @RequestMapping("/system/tenant/package")
public class SysTenantPackageController extends BaseController { public class SysTenantPackageController extends BaseController {
private final ISysTenantPackageService sysTenantPackageService; private final ISysTenantPackageService tenantPackageService;
/** /**
* 查询租户套餐列表 * 查询租户套餐列表
@ -45,7 +45,7 @@ public class SysTenantPackageController extends BaseController {
@SaCheckPermission("system:tenantPackage:list") @SaCheckPermission("system:tenantPackage:list")
@GetMapping("/list") @GetMapping("/list")
public TableDataInfo<SysTenantPackageVo> list(SysTenantPackageBo bo, PageQuery pageQuery) { public TableDataInfo<SysTenantPackageVo> list(SysTenantPackageBo bo, PageQuery pageQuery) {
return sysTenantPackageService.queryPageList(bo, pageQuery); return tenantPackageService.queryPageList(bo, pageQuery);
} }
/** /**
@ -56,7 +56,7 @@ public class SysTenantPackageController extends BaseController {
@Log(title = "租户套餐", businessType = BusinessType.EXPORT) @Log(title = "租户套餐", businessType = BusinessType.EXPORT)
@PostMapping("/export") @PostMapping("/export")
public void export(SysTenantPackageBo bo, HttpServletResponse response) { public void export(SysTenantPackageBo bo, HttpServletResponse response) {
List<SysTenantPackageVo> list = sysTenantPackageService.queryList(bo); List<SysTenantPackageVo> list = tenantPackageService.queryList(bo);
ExcelUtil.exportExcel(list, "租户套餐", SysTenantPackageVo.class, response); ExcelUtil.exportExcel(list, "租户套餐", SysTenantPackageVo.class, response);
} }
@ -70,7 +70,7 @@ public class SysTenantPackageController extends BaseController {
@GetMapping("/{packageId}") @GetMapping("/{packageId}")
public R<SysTenantPackageVo> getInfo(@NotNull(message = "主键不能为空") public R<SysTenantPackageVo> getInfo(@NotNull(message = "主键不能为空")
@PathVariable Long packageId) { @PathVariable Long packageId) {
return R.ok(sysTenantPackageService.queryById(packageId)); return R.ok(tenantPackageService.queryById(packageId));
} }
/** /**
@ -82,7 +82,7 @@ public class SysTenantPackageController extends BaseController {
@RepeatSubmit() @RepeatSubmit()
@PostMapping() @PostMapping()
public R<Void> add(@Validated(AddGroup.class) @RequestBody SysTenantPackageBo bo) { public R<Void> add(@Validated(AddGroup.class) @RequestBody SysTenantPackageBo bo) {
return toAjax(sysTenantPackageService.insertByBo(bo)); return toAjax(tenantPackageService.insertByBo(bo));
} }
/** /**
@ -94,7 +94,7 @@ public class SysTenantPackageController extends BaseController {
@RepeatSubmit() @RepeatSubmit()
@PutMapping() @PutMapping()
public R<Void> edit(@Validated(EditGroup.class) @RequestBody SysTenantPackageBo bo) { public R<Void> edit(@Validated(EditGroup.class) @RequestBody SysTenantPackageBo bo) {
return toAjax(sysTenantPackageService.updateByBo(bo)); return toAjax(tenantPackageService.updateByBo(bo));
} }
/** /**
@ -105,7 +105,7 @@ public class SysTenantPackageController extends BaseController {
@Log(title = "租户套餐", businessType = BusinessType.UPDATE) @Log(title = "租户套餐", businessType = BusinessType.UPDATE)
@PutMapping("/changeStatus") @PutMapping("/changeStatus")
public R<Void> changeStatus(@RequestBody SysTenantPackageBo bo) { public R<Void> changeStatus(@RequestBody SysTenantPackageBo bo) {
return toAjax(sysTenantPackageService.updatePackageStatus(bo)); return toAjax(tenantPackageService.updatePackageStatus(bo));
} }
/** /**
@ -119,6 +119,6 @@ public class SysTenantPackageController extends BaseController {
@DeleteMapping("/{packageIds}") @DeleteMapping("/{packageIds}")
public R<Void> remove(@NotEmpty(message = "主键不能为空") public R<Void> remove(@NotEmpty(message = "主键不能为空")
@PathVariable Long[] packageIds) { @PathVariable Long[] packageIds) {
return toAjax(sysTenantPackageService.deleteWithValidByIds(List.of(packageIds), true)); return toAjax(tenantPackageService.deleteWithValidByIds(List.of(packageIds), true));
} }
} }

View File

@ -43,7 +43,7 @@ public class SysMenuServiceImpl implements ISysMenuService {
private final SysMenuMapper baseMapper; private final SysMenuMapper baseMapper;
private final SysRoleMapper roleMapper; private final SysRoleMapper roleMapper;
private final SysRoleMenuMapper roleMenuMapper; private final SysRoleMenuMapper roleMenuMapper;
private final SysTenantPackageMapper sysTenantPackageMapper; private final SysTenantPackageMapper tenantPackageMapper;
/** /**
* 根据用户查询系统菜单列表 * 根据用户查询系统菜单列表
@ -160,7 +160,7 @@ public class SysMenuServiceImpl implements ISysMenuService {
*/ */
@Override @Override
public List<Long> selectMenuListByPackageId(Long packageId) { public List<Long> selectMenuListByPackageId(Long packageId) {
SysTenantPackage tenantPackage = sysTenantPackageMapper.selectById(packageId); SysTenantPackage tenantPackage = tenantPackageMapper.selectById(packageId);
List<Long> menuIds = StringUtils.splitTo(tenantPackage.getMenuIds(), Convert::toLong); List<Long> menuIds = StringUtils.splitTo(tenantPackage.getMenuIds(), Convert::toLong);
if (CollUtil.isEmpty(menuIds)) { if (CollUtil.isEmpty(menuIds)) {
return List.of(); return List.of();

View File

@ -43,16 +43,16 @@ import java.util.List;
public class SysTenantServiceImpl implements ISysTenantService { public class SysTenantServiceImpl implements ISysTenantService {
private final SysTenantMapper baseMapper; private final SysTenantMapper baseMapper;
private final SysTenantPackageMapper sysTenantPackageMapper; private final SysTenantPackageMapper tenantPackageMapper;
private final SysUserMapper sysUserMapper; private final SysUserMapper userMapper;
private final SysDeptMapper sysDeptMapper; private final SysDeptMapper deptMapper;
private final SysRoleMapper sysRoleMapper; private final SysRoleMapper roleMapper;
private final SysRoleMenuMapper sysRoleMenuMapper; private final SysRoleMenuMapper roleMenuMapper;
private final SysRoleDeptMapper sysRoleDeptMapper; private final SysRoleDeptMapper roleDeptMapper;
private final SysUserRoleMapper sysUserRoleMapper; private final SysUserRoleMapper userRoleMapper;
private final SysDictTypeMapper sysDictTypeMapper; private final SysDictTypeMapper dictTypeMapper;
private final SysDictDataMapper sysDictDataMapper; private final SysDictDataMapper dictDataMapper;
private final SysConfigMapper sysConfigMapper; private final SysConfigMapper configMapper;
/** /**
* 查询租户 * 查询租户
@ -139,14 +139,14 @@ public class SysTenantServiceImpl implements ISysTenantService {
dept.setLeader(bo.getUsername()); dept.setLeader(bo.getUsername());
dept.setParentId(Constants.TOP_PARENT_ID); dept.setParentId(Constants.TOP_PARENT_ID);
dept.setAncestors(Constants.TOP_PARENT_ID.toString()); dept.setAncestors(Constants.TOP_PARENT_ID.toString());
sysDeptMapper.insert(dept); deptMapper.insert(dept);
Long deptId = dept.getDeptId(); Long deptId = dept.getDeptId();
// 角色和部门关联表 // 角色和部门关联表
SysRoleDept roleDept = new SysRoleDept(); SysRoleDept roleDept = new SysRoleDept();
roleDept.setRoleId(roleId); roleDept.setRoleId(roleId);
roleDept.setDeptId(deptId); roleDept.setDeptId(deptId);
sysRoleDeptMapper.insert(roleDept); roleDeptMapper.insert(roleDept);
// 创建系统用户 // 创建系统用户
SysUser user = new SysUser(); SysUser user = new SysUser();
@ -155,18 +155,18 @@ public class SysTenantServiceImpl implements ISysTenantService {
user.setNickName(bo.getUsername()); user.setNickName(bo.getUsername());
user.setPassword(BCrypt.hashpw(bo.getPassword())); user.setPassword(BCrypt.hashpw(bo.getPassword()));
user.setDeptId(deptId); user.setDeptId(deptId);
sysUserMapper.insert(user); userMapper.insert(user);
// 用户和角色关联表 // 用户和角色关联表
SysUserRole userRole = new SysUserRole(); SysUserRole userRole = new SysUserRole();
userRole.setUserId(user.getUserId()); userRole.setUserId(user.getUserId());
userRole.setRoleId(roleId); userRole.setRoleId(roleId);
sysUserRoleMapper.insert(userRole); userRoleMapper.insert(userRole);
String defaultTenantId = TenantConstants.DEFAULT_TENANT_ID; String defaultTenantId = TenantConstants.DEFAULT_TENANT_ID;
List<SysDictType> dictTypeList = sysDictTypeMapper.selectList( List<SysDictType> dictTypeList = dictTypeMapper.selectList(
new LambdaQueryWrapper<SysDictType>().eq(SysDictType::getTenantId, defaultTenantId)); new LambdaQueryWrapper<SysDictType>().eq(SysDictType::getTenantId, defaultTenantId));
List<SysDictData> dictDataList = sysDictDataMapper.selectList( List<SysDictData> dictDataList = dictDataMapper.selectList(
new LambdaQueryWrapper<SysDictData>().eq(SysDictData::getTenantId, defaultTenantId)); new LambdaQueryWrapper<SysDictData>().eq(SysDictData::getTenantId, defaultTenantId));
for (SysDictType dictType : dictTypeList) { for (SysDictType dictType : dictTypeList) {
dictType.setDictId(null); dictType.setDictId(null);
@ -176,16 +176,16 @@ public class SysTenantServiceImpl implements ISysTenantService {
dictData.setDictCode(null); dictData.setDictCode(null);
dictData.setTenantId(tenantId); dictData.setTenantId(tenantId);
} }
sysDictTypeMapper.insertBatch(dictTypeList); dictTypeMapper.insertBatch(dictTypeList);
sysDictDataMapper.insertBatch(dictDataList); dictDataMapper.insertBatch(dictDataList);
List<SysConfig> sysConfigList = sysConfigMapper.selectList( List<SysConfig> sysConfigList = configMapper.selectList(
new LambdaQueryWrapper<SysConfig>().eq(SysConfig::getTenantId, defaultTenantId)); new LambdaQueryWrapper<SysConfig>().eq(SysConfig::getTenantId, defaultTenantId));
for (SysConfig config : sysConfigList) { for (SysConfig config : sysConfigList) {
config.setConfigId(null); config.setConfigId(null);
config.setTenantId(tenantId); config.setTenantId(tenantId);
} }
sysConfigMapper.insertBatch(sysConfigList); configMapper.insertBatch(sysConfigList);
TenantHelper.disableIgnore(); TenantHelper.disableIgnore();
return true; return true;
@ -216,7 +216,7 @@ public class SysTenantServiceImpl implements ISysTenantService {
*/ */
private Long createTenantRole(String tenantId, Long packageId) { private Long createTenantRole(String tenantId, Long packageId) {
// 获取租户套餐 // 获取租户套餐
SysTenantPackage tenantPackage = sysTenantPackageMapper.selectById(packageId); SysTenantPackage tenantPackage = tenantPackageMapper.selectById(packageId);
if (ObjectUtil.isNull(tenantPackage)) { if (ObjectUtil.isNull(tenantPackage)) {
throw new ServiceException("套餐不存在"); throw new ServiceException("套餐不存在");
} }
@ -230,7 +230,7 @@ public class SysTenantServiceImpl implements ISysTenantService {
role.setRoleKey(TenantConstants.TENANT_ADMIN_ROLE_KEY); role.setRoleKey(TenantConstants.TENANT_ADMIN_ROLE_KEY);
role.setRoleSort(1); role.setRoleSort(1);
role.setStatus(TenantConstants.NORMAL); role.setStatus(TenantConstants.NORMAL);
sysRoleMapper.insert(role); roleMapper.insert(role);
Long roleId = role.getRoleId(); Long roleId = role.getRoleId();
// 创建角色菜单 // 创建角色菜单
@ -241,7 +241,7 @@ public class SysTenantServiceImpl implements ISysTenantService {
roleMenu.setMenuId(menuId); roleMenu.setMenuId(menuId);
roleMenus.add(roleMenu); roleMenus.add(roleMenu);
}); });
sysRoleMenuMapper.insertBatch(roleMenus); roleMenuMapper.insertBatch(roleMenus);
return roleId; return roleId;
} }
@ -319,7 +319,7 @@ public class SysTenantServiceImpl implements ISysTenantService {
if (tenant.getAccountCount() == -1) { if (tenant.getAccountCount() == -1) {
return true; return true;
} }
Long userNumber = sysUserMapper.selectCount(new LambdaQueryWrapper<>()); Long userNumber = userMapper.selectCount(new LambdaQueryWrapper<>());
// 如果余额大于0代表还有可用名额 // 如果余额大于0代表还有可用名额
return tenant.getAccountCount() - userNumber > 0; return tenant.getAccountCount() - userNumber > 0;
} }
@ -345,8 +345,8 @@ public class SysTenantServiceImpl implements ISysTenantService {
@Transactional(rollbackFor = Exception.class) @Transactional(rollbackFor = Exception.class)
public Boolean syncTenantPackage(String tenantId, String packageId) { public Boolean syncTenantPackage(String tenantId, String packageId) {
TenantHelper.enableIgnore(); TenantHelper.enableIgnore();
SysTenantPackage tenantPackage = sysTenantPackageMapper.selectById(packageId); SysTenantPackage tenantPackage = tenantPackageMapper.selectById(packageId);
List<SysRole> roles = sysRoleMapper.selectList( List<SysRole> roles = roleMapper.selectList(
new LambdaQueryWrapper<SysRole>().eq(SysRole::getTenantId, tenantId)); new LambdaQueryWrapper<SysRole>().eq(SysRole::getTenantId, tenantId));
List<Long> roleIds = new ArrayList<>(roles.size() - 1); List<Long> roleIds = new ArrayList<>(roles.size() - 1);
List<Long> menuIds = StringUtils.splitTo(tenantPackage.getMenuIds(), Convert::toLong); List<Long> menuIds = StringUtils.splitTo(tenantPackage.getMenuIds(), Convert::toLong);
@ -359,14 +359,14 @@ public class SysTenantServiceImpl implements ISysTenantService {
roleMenu.setMenuId(menuId); roleMenu.setMenuId(menuId);
roleMenus.add(roleMenu); roleMenus.add(roleMenu);
}); });
sysRoleMenuMapper.delete(new LambdaQueryWrapper<SysRoleMenu>().eq(SysRoleMenu::getRoleId, item.getRoleId())); roleMenuMapper.delete(new LambdaQueryWrapper<SysRoleMenu>().eq(SysRoleMenu::getRoleId, item.getRoleId()));
sysRoleMenuMapper.insertBatch(roleMenus); roleMenuMapper.insertBatch(roleMenus);
} else { } else {
roleIds.add(item.getRoleId()); roleIds.add(item.getRoleId());
} }
}); });
if (!roleIds.isEmpty()) { if (!roleIds.isEmpty()) {
sysRoleMenuMapper.delete( roleMenuMapper.delete(
new LambdaQueryWrapper<SysRoleMenu>().in(SysRoleMenu::getRoleId, roleIds).notIn(!menuIds.isEmpty(), SysRoleMenu::getMenuId, menuIds)); new LambdaQueryWrapper<SysRoleMenu>().in(SysRoleMenu::getRoleId, roleIds).notIn(!menuIds.isEmpty(), SysRoleMenu::getMenuId, menuIds));
} }
TenantHelper.disableIgnore(); TenantHelper.disableIgnore();