/** * 删除业主命令类 * * 该命令类用于处理第三方系统（如招商系统）删除业主信息的请求。 * 主要功能包括验证删除条件、删除业主基本信息、业主APP用户绑定信息、业主属性和业主账户信息。 * 删除前会进行多项验证，确保业主没有绑定房屋、车位，且没有下属成员。 * * @author 吴学文 * @version 1.0 * @since 2023 */ package com.java110.user.cmd.owner; import com.alibaba.fastjson.JSONObject; import com.java110.core.annotation.Java110Cmd; import com.java110.core.annotation.Java110Transactional; import com.java110.core.context.Environment; import com.java110.core.context.ICmdDataFlowContext; import com.java110.core.event.cmd.Cmd; import com.java110.core.event.cmd.CmdEvent; import com.java110.doc.annotation.*; import com.java110.dto.account.AccountDto; import com.java110.dto.owner.OwnerAttrDto; import com.java110.dto.room.RoomDto; import com.java110.dto.owner.OwnerAppUserDto; import com.java110.dto.owner.OwnerCarDto; import com.java110.dto.owner.OwnerDto; import com.java110.intf.acct.IAccountInnerServiceSMO; import com.java110.intf.user.*; import com.java110.intf.community.IRoomInnerServiceSMO; import com.java110.po.account.AccountPo; import com.java110.po.owner.OwnerAppUserPo; import com.java110.po.owner.OwnerAttrPo; import com.java110.po.owner.OwnerPo; import com.java110.utils.exception.CmdException; import com.java110.utils.util.Assert; import com.java110.utils.util.BeanConvertUtil; import org.springframework.beans.factory.annotation.Autowired; import java.util.List; @Java110CmdDoc(title = "删除业主", description = "第三方系统，比如招商系统删除业主信息", httpMethod = "post", url = "http://{ip}:{port}/app/owner.deleteOwner", resource = "userDoc", author = "吴学文", serviceCode = "owner.deleteOwner", seq = 11) @Java110ParamsDoc(params = { @Java110ParamDoc(name = "communityId", length = 30, remark = "小区ID"), @Java110ParamDoc(name = "memberId", length = 30, remark = "业主ID"), }) @Java110ResponseDoc( params = { @Java110ParamDoc(name = "code", type = "int", length = 11, defaultValue = "0", remark = "返回编号，0 成功 其他失败"), @Java110ParamDoc(name = "msg", type = "String", length = 250, defaultValue = "成功", remark = "描述"), } ) @Java110ExampleDoc( reqBody = "{\n" + "\t\"memberId\": 123123123,\n" + "\t\"communityId\": \"2022121921870161\"\n" + "}", resBody = "{\"code\":0,\"msg\":\"成功\"}" ) @Java110Cmd(serviceCode = "owner.deleteOwner") public class DeleteOwnerCmd extends Cmd { @Autowired private IOwnerInnerServiceSMO ownerInnerServiceSMOImpl; @Autowired private IOwnerV1InnerServiceSMO ownerV1InnerServiceSMOImpl; @Autowired private IRoomInnerServiceSMO roomInnerServiceSMOImpl; @Autowired private IOwnerCarInnerServiceSMO ownerCarInnerServiceSMOImpl; @Autowired private IOwnerAppUserInnerServiceSMO ownerAppUserInnerServiceSMOImpl; @Autowired private IOwnerAppUserV1InnerServiceSMO ownerAppUserV1InnerServiceSMOImpl; @Autowired private IOwnerAttrInnerServiceSMO ownerAttrInnerServiceSMOImpl; @Autowired private IAccountInnerServiceSMO accountInnerServiceSMOImpl; /** * 验证删除业主的请求参数和业务规则 * * 该方法用于验证删除业主请求的合法性，包括： * 1. 验证必要参数是否存在 * 2. 如果是业主类型，验证是否绑定了房屋和车位 * 3. 验证业主下是否有成员存在 * * @param event 命令事件对象 * @param cmdDataFlowContext 命令数据流上下文 * @param reqJson 请求的JSON数据 * @throws CmdException 当验证失败时抛出异常 */ @Override public void validate(CmdEvent event, ICmdDataFlowContext cmdDataFlowContext, JSONObject reqJson) throws CmdException { // 检查当前环境是否为开发环境 Environment.isDevEnv(); // 验证请求参数中是否包含必要的字段 Assert.jsonObjectHaveKey(reqJson, "memberId", "请求报文中未包含memberId"); Assert.jsonObjectHaveKey(reqJson, "communityId", "请求报文中未包含communityId"); // 如果是业主类型，需要进行额外的验证 //todo 如果是业主 if (OwnerDto.OWNER_TYPE_CD_OWNER.equals(reqJson.getString("ownerTypeCd"))) { // 将memberId设置为ownerId用于查询 //ownerId 写为 memberId reqJson.put("ownerId", reqJson.getString("memberId")); // 验证业主是否绑定了房屋 RoomDto roomDto = new RoomDto(); roomDto.setOwnerId(reqJson.getString("ownerId")); List roomDtoList = roomInnerServiceSMOImpl.queryRoomsByOwner(roomDto); if (roomDtoList.size() > 0) { throw new IllegalArgumentException("删除失败,删除前请先解绑房屋信息"); } // 验证业主是否绑定了车位 //查询车位信息 OwnerCarDto ownerCarDto = new OwnerCarDto(); ownerCarDto.setOwnerId(reqJson.getString("ownerId")); List ownerCarDtos = ownerCarInnerServiceSMOImpl.queryOwnerCars(ownerCarDto); if (ownerCarDtos.size() > 0) { throw new IllegalArgumentException("删除失败,删除前请先解绑车位信息"); } //小区楼添加到小区中 //ownerBMOImpl.exitCommunityMember(reqJson, context); } // 如果不是业主类型，直接返回，不进行后续验证 if (!OwnerDto.OWNER_TYPE_CD_OWNER.equals(reqJson.getString("ownerTypeCd"))) { //不是业主成员不管 return; } // 验证业主下是否有成员存在 OwnerDto ownerDto = new OwnerDto(); ownerDto.setOwnerId(reqJson.getString("memberId")); ownerDto.setCommunityId(reqJson.getString("communityId")); ownerDto.setOwnerTypeCds(new String[]{OwnerDto.OWNER_TYPE_CD_MEMBER}); List ownerDtos = ownerInnerServiceSMOImpl.queryOwnerMembers(ownerDto); if (ownerDtos != null && ownerDtos.size() > 0) { throw new IllegalArgumentException("请先删除业主下的成员"); } } /** * 执行删除业主的操作 * * 该方法在事务中执行以下操作： * 1. 删除业主基本信息 * 2. 删除业主APP用户绑定信息 * 3. 删除业主属性信息 * 4. 删除业主账户信息 * * @param event 命令事件对象 * @param cmdDataFlowContext 命令数据流上下文 * @param reqJson 请求的JSON数据 * @throws CmdException 当删除操作失败时抛出异常 */ @Override @Java110Transactional public void doCmd(CmdEvent event, ICmdDataFlowContext cmdDataFlowContext, JSONObject reqJson) throws CmdException { // 准备删除业主基本信息的参数 JSONObject businessOwner = new JSONObject(); businessOwner.put("memberId", reqJson.getString("memberId")); businessOwner.put("communityId", reqJson.getString("communityId")); // 转换为PO对象并执行删除操作 OwnerPo ownerPo = BeanConvertUtil.covertBean(businessOwner, OwnerPo.class); int flag = ownerV1InnerServiceSMOImpl.deleteOwner(ownerPo); if (flag < 1) { throw new CmdException("删除失败"); } // 注释掉的代码：如果不是业主类型，直接返回 // if (!OwnerDto.OWNER_TYPE_CD_OWNER.equals(reqJson.getString("ownerTypeCd"))) { // return; // } // 删除业主APP用户绑定信息 //删除绑定业主信息 OwnerAppUserDto ownerAppUserDto = new OwnerAppUserDto(); ownerAppUserDto.setMemberId(reqJson.getString("memberId")); ownerAppUserDto.setCommunityId(reqJson.getString("communityId")); // 查询业主APP用户绑定信息 //查询app用户表 List ownerAppUserDtos = ownerAppUserInnerServiceSMOImpl.queryOwnerAppUsers(ownerAppUserDto); if (ownerAppUserDtos == null && ownerAppUserDtos.size() < 1) { return; } // 遍历并删除所有业主APP用户绑定记录 for (OwnerAppUserDto ownerAppUser : ownerAppUserDtos) { OwnerAppUserPo ownerAppUserPo = BeanConvertUtil.covertBean(ownerAppUser, OwnerAppUserPo.class); flag = ownerAppUserV1InnerServiceSMOImpl.deleteOwnerAppUser(ownerAppUserPo); if (flag < 1) { throw new CmdException("删除失败"); } // 注释掉的代码：应该删除用户 //todo 应该删除用户 // UserPo userPo = new UserPo(); // userPo.setUserId(ownerAppUser.getUserId()); // userV1InnerServiceSMOImpl.deleteUser(userPo); } // 删除业主属性信息 //删除业主属性表信息 OwnerAttrDto ownerAttrDto = new OwnerAttrDto(); ownerAttrDto.setMemberId(reqJson.getString("memberId")); List ownerAttrDtos = ownerAttrInnerServiceSMOImpl.queryOwnerAttrs(ownerAttrDto); if (ownerAttrDtos != null && ownerAttrDtos.size() > 0) { // 遍历并更新所有业主属性记录的状态为不可用（软删除） for (OwnerAttrDto ownerAttr : ownerAttrDtos) { OwnerAttrPo ownerAttrPo = new OwnerAttrPo(); ownerAttrPo.setAttrId(ownerAttr.getAttrId()); ownerAttrPo.setStatusCd("1"); //0 可用，1 不可用 int i = ownerAttrInnerServiceSMOImpl.updateOwnerAttrInfoInstance(ownerAttrPo); if (i < 1) { throw new CmdException("删除业主属性表失败"); } } } // 删除业主账户信息 //删除业主账户信息 AccountDto accountDto = new AccountDto(); accountDto.setObjId(reqJson.getString("memberId")); List accountDtos = accountInnerServiceSMOImpl.queryAccounts(accountDto); if (accountDtos != null && accountDtos.size() > 0) { // 遍历并更新所有账户记录的状态为不可用（软删除） for (AccountDto account : accountDtos) { AccountPo accountPo = new AccountPo(); accountPo.setAcctId(account.getAcctId()); accountPo.setStatusCd("1"); //0 可用，1 不可用 int i = accountInnerServiceSMOImpl.updateAccount(accountPo); if (i < 1) { throw new CmdException("删除业主账户信息失败"); } } } } }