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.CmdContextUtils;
|
import com.java110.core.context.ICmdDataFlowContext;
|
import com.java110.core.event.cmd.Cmd;
|
import com.java110.core.event.cmd.CmdEvent;
|
import com.java110.core.factory.GenerateCodeFactory;
|
import com.java110.dto.account.AccountDto;
|
import com.java110.dto.owner.OwnerAppUserDto;
|
import com.java110.dto.owner.OwnerDto;
|
import com.java110.dto.owner.OwnerRoomRelDto;
|
import com.java110.dto.user.UserDto;
|
import com.java110.intf.acct.IAccountInnerServiceSMO;
|
import com.java110.intf.user.*;
|
import com.java110.po.account.AccountPo;
|
import com.java110.po.owner.OwnerAppUserPo;
|
import com.java110.po.owner.OwnerPo;
|
import com.java110.po.user.UserPo;
|
import com.java110.utils.exception.CmdException;
|
import com.java110.utils.util.Assert;
|
import com.java110.utils.util.BeanConvertUtil;
|
import com.java110.utils.util.ListUtil;
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
import java.util.List;
|
|
/**
|
* 业主房屋认证审核
|
*/
|
@Java110Cmd(serviceCode = "owner.auditAuthOwner")
|
public class AuditAuthOwnerCmd extends Cmd {
|
|
@Autowired
|
private IOwnerAppUserV1InnerServiceSMO ownerAppUserV1InnerServiceSMOImpl;
|
|
@Autowired
|
private IOwnerAppUserInnerServiceSMO ownerAppUserInnerServiceSMOImpl;
|
|
@Autowired
|
private IUserV1InnerServiceSMO userV1InnerServiceSMOImpl;
|
|
@Autowired
|
private IOwnerRoomRelInnerServiceSMO ownerRoomRelInnerServiceSMOImpl;
|
|
@Autowired
|
private IOwnerV1InnerServiceSMO ownerV1InnerServiceSMOImpl;
|
|
@Autowired
|
private IAccountInnerServiceSMO accountInnerServiceSMOImpl;
|
|
@Override
|
public void validate(CmdEvent event, ICmdDataFlowContext context, JSONObject reqJson) throws CmdException {
|
Assert.hasKeyAndValue(reqJson, "appUserId", "绑定ID不能为空");
|
Assert.hasKeyAndValue(reqJson, "state", "必填，请填写状态");
|
Assert.hasKeyAndValue(reqJson, "remark", "必填，请填写审核说明");
|
Assert.hasKeyAndValue(reqJson, "communityId", "未包含小区信息");
|
|
OwnerAppUserDto ownerAppUserDto = new OwnerAppUserDto();
|
ownerAppUserDto.setAppUserId(reqJson.getString("appUserId"));
|
ownerAppUserDto.setState(OwnerAppUserDto.STATE_AUDITING);
|
List<OwnerAppUserDto> ownerAppUserDtos = ownerAppUserInnerServiceSMOImpl.queryOwnerAppUsers(ownerAppUserDto);
|
Assert.listOnlyOne(ownerAppUserDtos, "审核记录不存在");
|
}
|
|
@Override
|
@Java110Transactional
|
public void doCmd(CmdEvent event, ICmdDataFlowContext context, JSONObject reqJson) throws CmdException {
|
|
String userId = CmdContextUtils.getUserId(context);
|
|
String state = "";
|
// todo 审核拒绝
|
if ("1200".equals(reqJson.getString("state"))) {
|
OwnerAppUserPo ownerAppUserPo = new OwnerAppUserPo();
|
ownerAppUserPo.setAppUserId(reqJson.getString("appUserId"));
|
ownerAppUserPo.setState(OwnerAppUserDto.STATE_AUDIT_ERROR);
|
ownerAppUserPo.setRemark(reqJson.getString("remark"));
|
int flag = ownerAppUserV1InnerServiceSMOImpl.updateOwnerAppUser(ownerAppUserPo);
|
if (flag < 1) {
|
throw new CmdException("修改绑定失败");
|
}
|
return;
|
}
|
|
OwnerAppUserDto ownerAppUserDto = new OwnerAppUserDto();
|
ownerAppUserDto.setAppUserId(reqJson.getString("appUserId"));
|
ownerAppUserDto.setState(OwnerAppUserDto.STATE_AUDITING);
|
List<OwnerAppUserDto> ownerAppUserDtos = ownerAppUserInnerServiceSMOImpl.queryOwnerAppUsers(ownerAppUserDto);
|
|
String memberId = "";
|
// todo 如果是业主
|
if(OwnerDto.OWNER_TYPE_CD_OWNER.equals(ownerAppUserDtos.get(0).getOwnerTypeCd())){
|
memberId = bindOwner(ownerAppUserDtos.get(0));
|
}else {
|
//todo 如果是成员
|
memberId = bindOwnerMember(ownerAppUserDtos.get(0),userId);
|
}
|
|
|
UserPo userPo = new UserPo();
|
userPo.setName(ownerAppUserDtos.get(0).getAppUserName());
|
userPo.setUserId(ownerAppUserDtos.get(0).getUserId());
|
userV1InnerServiceSMOImpl.updateUser(userPo);
|
|
OwnerAppUserPo ownerAppUserPo = new OwnerAppUserPo();
|
ownerAppUserPo.setAppUserId(reqJson.getString("appUserId"));
|
ownerAppUserPo.setState(OwnerAppUserDto.STATE_AUDIT_SUCCESS);
|
ownerAppUserPo.setRemark(reqJson.getString("remark"));
|
ownerAppUserPo.setMemberId(memberId);
|
int flag = ownerAppUserV1InnerServiceSMOImpl.updateOwnerAppUser(ownerAppUserPo);
|
if (flag < 1) {
|
throw new CmdException("修改绑定失败");
|
}
|
|
}
|
|
/**
|
* 绑定成员
|
* @param ownerAppUserDto
|
* @return
|
*/
|
private String bindOwnerMember(OwnerAppUserDto ownerAppUserDto,String userId) {
|
// todo 查看 房屋是否有业主，如果没有添加业主
|
OwnerRoomRelDto ownerRoomRelDto = new OwnerRoomRelDto();
|
ownerRoomRelDto.setRoomId(ownerAppUserDto.getRoomId());
|
List<OwnerRoomRelDto> ownerRoomRelDtos = ownerRoomRelInnerServiceSMOImpl.queryOwnerRoomRels(ownerRoomRelDto);
|
|
if(ListUtil.isNull(ownerRoomRelDtos)){
|
throw new CmdException("房屋未绑定业主");
|
}
|
|
//todo 根据手机号和小区查询 家庭成员是否存在
|
|
OwnerDto ownerDto = new OwnerDto();
|
ownerDto.setOwnerId(ownerRoomRelDtos.get(0).getOwnerId());
|
ownerDto.setLink(ownerAppUserDto.getLink());
|
ownerDto.setCommunityId(ownerAppUserDto.getCommunityId());
|
ownerDto.setOwnerTypeCds(new String[]{
|
OwnerDto.OWNER_TYPE_CD_MEMBER
|
// ,
|
// OwnerDto.OWNER_TYPE_CD_RENTING,
|
// OwnerDto.OWNER_TYPE_CD_OTHER,
|
// OwnerDto.OWNER_TYPE_CD_TEMP
|
});
|
List<OwnerDto> ownerDtos = ownerV1InnerServiceSMOImpl.queryOwners(ownerDto);
|
|
if(!ListUtil.isNull(ownerDtos)){
|
return ownerDtos.get(0).getMemberId();
|
}
|
|
OwnerPo ownerPo = new OwnerPo();
|
ownerPo.setMemberId(GenerateCodeFactory.getGeneratorId("11"));
|
ownerPo.setOwnerId(ownerRoomRelDtos.get(0).getOwnerId());
|
ownerPo.setName(ownerAppUserDto.getAppUserName());
|
ownerPo.setSex("0");
|
ownerPo.setLink(ownerAppUserDto.getLink());
|
ownerPo.setUserId(userId);
|
ownerPo.setRemark("业主认证，审核添加");
|
ownerPo.setOwnerTypeCd(ownerAppUserDto.getOwnerTypeCd());
|
ownerPo.setCommunityId(ownerAppUserDto.getCommunityId());
|
ownerPo.setIdCard(ownerAppUserDto.getIdCard());
|
ownerPo.setState(OwnerDto.STATE_FINISH);
|
ownerPo.setOwnerFlag(OwnerDto.OWNER_FLAG_TRUE);
|
ownerPo.setAddress("无");
|
ownerV1InnerServiceSMOImpl.saveOwner(ownerPo);
|
|
return ownerPo.getMemberId();
|
}
|
|
/**
|
* 绑定业主
|
* @param ownerAppUserDto
|
* @return
|
*/
|
private String bindOwner(OwnerAppUserDto ownerAppUserDto) {
|
|
// todo 查看 房屋是否有业主，如果没有添加业主
|
OwnerRoomRelDto ownerRoomRelDto = new OwnerRoomRelDto();
|
ownerRoomRelDto.setRoomId(ownerAppUserDto.getRoomId());
|
List<OwnerRoomRelDto> ownerRoomRelDtos = ownerRoomRelInnerServiceSMOImpl.queryOwnerRoomRels(ownerRoomRelDto);
|
|
if(ListUtil.isNull(ownerRoomRelDtos)){
|
throw new CmdException("房屋未绑定业主");
|
}
|
|
OwnerPo ownerPo = new OwnerPo();
|
ownerPo.setLink(ownerAppUserDto.getLink());
|
// ownerPo.setName(ownerAppUserDto.getAppUserName());
|
ownerPo.setMemberId(ownerRoomRelDtos.get(0).getOwnerId());
|
ownerPo.setOwnerId(ownerRoomRelDtos.get(0).getOwnerId());
|
ownerV1InnerServiceSMOImpl.updateOwner(ownerPo);
|
|
AccountDto accountDto = new AccountDto();
|
accountDto.setObjId(ownerRoomRelDtos.get(0).getOwnerId());
|
accountDto.setPartId(ownerRoomRelDtos.get(0).getCommunityId());
|
List<AccountDto> accountDtos = accountInnerServiceSMOImpl.queryAccounts(accountDto);
|
if (ListUtil.isNull(accountDtos)) {
|
return ownerRoomRelDtos.get(0).getOwnerId();
|
}
|
|
AccountPo accountPo = new AccountPo();
|
accountPo.setoLink(ownerAppUserDto.getLink());
|
accountPo.setAcctId(accountDtos.get(0).getAcctId());
|
accountInnerServiceSMOImpl.updateAccount(accountPo);
|
|
|
return ownerRoomRelDtos.get(0).getOwnerId();
|
|
}
|
}
|
