同步删除账户

This commit is contained in:
sxu 2025-04-07 16:27:34 +08:00
parent 1c6c29484c
commit 1039ca16ad
3 changed files with 2 additions and 26 deletions

View File

@ -133,15 +133,6 @@ public class AccInfoController extends BaseController {
/** /**
* 删除账户资料 * 删除账户资料
*/ */
// @ApiOperation(value = "删除账户资料")
// //@PreventRepeatSubmit
// //@RequiresPermissions("account:info:remove")
// @SysLog(title = "账户资料", businessType = OperaType.DELETE, logType = 1,module = "账户管理->删除账户资料")
// @PostMapping("/delete/{userIds}")
// public AjaxResult deleteAccInfoByUserIds(@PathVariable("userIds") Long[] userIds) {
// return toAjax(accInfoService.deleteAccInfoByUserIds(userIds));
// }
@ApiOperation(value = "删除账户资料") @ApiOperation(value = "删除账户资料")
//@PreventRepeatSubmit //@PreventRepeatSubmit
//@RequiresPermissions("account:info:remove") //@RequiresPermissions("account:info:remove")

View File

@ -54,11 +54,9 @@ public interface IAccInfoService {
/** /**
* 删除账户资料信息 * 删除账户资料信息
* *
* @param userIds 账户资料主键 * @param users 账户资料主键
* @return 结果 * @return 结果
*/ */
public int deleteAccInfoByUserIds(Long[] userIds);
public int deleteAccInfoByUserIds(List<SysUser> users); public int deleteAccInfoByUserIds(List<SysUser> users);
public int syncAccInfo(SysUser sysUser); public int syncAccInfo(SysUser sysUser);

View File

@ -98,22 +98,9 @@ public class AccInfoServiceImpl implements IAccInfoService {
/** /**
* 删除账户资料信息 * 删除账户资料信息
* *
* @param userIds 账户资料主键 * @param users 账户资料主键
* @return 结果 * @return 结果
*/ */
@Transactional(
rollbackFor = {Exception.class}
)
public int deleteAccInfoByUserIds(Long[] userIds) {
int count = 0;
for (int i = 0; i < userIds.length; i++) {
accWalletInfoService.deleteAccWalletInfoByUserId(userIds[i]);
//MqUtil.sendDataChange(userId, LeMqConstant.DataChangeType.REMOVE, LeMqConstant.Topic.DATA_CHANGE_CUSTOMER);
count += accInfoMapper.deleteAccInfoByUserId(userIds[i]);
}
return count;
}
@Transactional( @Transactional(
rollbackFor = {Exception.class} rollbackFor = {Exception.class}
) )