|
@ -6,12 +6,15 @@ import com.epmet.commons.mybatis.service.impl.BaseServiceImpl; |
|
|
import com.epmet.commons.rocketmq.messages.IcResiUserAddMQMsg; |
|
|
import com.epmet.commons.rocketmq.messages.IcResiUserAddMQMsg; |
|
|
import com.epmet.commons.tools.constant.FieldConstant; |
|
|
import com.epmet.commons.tools.constant.FieldConstant; |
|
|
import com.epmet.commons.tools.constant.NumConstant; |
|
|
import com.epmet.commons.tools.constant.NumConstant; |
|
|
|
|
|
import com.epmet.commons.tools.dto.result.CustomerStaffInfoCacheResult; |
|
|
import com.epmet.commons.tools.enums.IcResiUserSubStatusEnum; |
|
|
import com.epmet.commons.tools.enums.IcResiUserSubStatusEnum; |
|
|
import com.epmet.commons.tools.exception.EpmetErrorCode; |
|
|
import com.epmet.commons.tools.exception.EpmetErrorCode; |
|
|
import com.epmet.commons.tools.exception.EpmetException; |
|
|
import com.epmet.commons.tools.exception.EpmetException; |
|
|
import com.epmet.commons.tools.page.PageData; |
|
|
import com.epmet.commons.tools.page.PageData; |
|
|
import com.epmet.commons.tools.redis.common.CustomerIcHouseRedis; |
|
|
import com.epmet.commons.tools.redis.common.CustomerIcHouseRedis; |
|
|
|
|
|
import com.epmet.commons.tools.redis.common.CustomerStaffRedis; |
|
|
import com.epmet.commons.tools.redis.common.bean.HouseInfoCache; |
|
|
import com.epmet.commons.tools.redis.common.bean.HouseInfoCache; |
|
|
|
|
|
import com.epmet.commons.tools.security.dto.TokenDto; |
|
|
import com.epmet.commons.tools.security.user.LoginUserUtil; |
|
|
import com.epmet.commons.tools.security.user.LoginUserUtil; |
|
|
import com.epmet.commons.tools.utils.ConvertUtils; |
|
|
import com.epmet.commons.tools.utils.ConvertUtils; |
|
|
import com.epmet.commons.tools.utils.Result; |
|
|
import com.epmet.commons.tools.utils.Result; |
|
@ -23,15 +26,18 @@ import com.epmet.commons.tools.validator.group.UpdateGroup; |
|
|
import com.epmet.constant.IcResiUserConstant; |
|
|
import com.epmet.constant.IcResiUserConstant; |
|
|
import com.epmet.constant.SystemMessageType; |
|
|
import com.epmet.constant.SystemMessageType; |
|
|
import com.epmet.dao.ChangeRelocationDao; |
|
|
import com.epmet.dao.ChangeRelocationDao; |
|
|
|
|
|
import com.epmet.dao.IcResiUserDao; |
|
|
import com.epmet.dto.ChangeRelocationDTO; |
|
|
import com.epmet.dto.ChangeRelocationDTO; |
|
|
import com.epmet.dto.ChangeWelfareDTO; |
|
|
import com.epmet.dto.ChangeWelfareDTO; |
|
|
import com.epmet.dto.IcResiUserDTO; |
|
|
import com.epmet.dto.IcResiUserDTO; |
|
|
import com.epmet.dto.form.IcResiUserTransferFormDTO; |
|
|
import com.epmet.dto.form.IcResiUserTransferFormDTO; |
|
|
|
|
|
import com.epmet.dto.form.OnlyIdFormDTO; |
|
|
import com.epmet.dto.form.RentTenantDataFormDTO; |
|
|
import com.epmet.dto.form.RentTenantDataFormDTO; |
|
|
import com.epmet.dto.form.SystemMsgFormDTO; |
|
|
import com.epmet.dto.form.SystemMsgFormDTO; |
|
|
import com.epmet.dto.result.RentTenantDataResultDTO; |
|
|
import com.epmet.dto.result.RentTenantDataResultDTO; |
|
|
import com.epmet.entity.ChangeRelocationEntity; |
|
|
import com.epmet.entity.ChangeRelocationEntity; |
|
|
import com.epmet.entity.IcResiUserEntity; |
|
|
import com.epmet.entity.IcResiUserEntity; |
|
|
|
|
|
import com.epmet.entity.IcUserChangeRecordEntity; |
|
|
import com.epmet.feign.EpmetMessageOpenFeignClient; |
|
|
import com.epmet.feign.EpmetMessageOpenFeignClient; |
|
|
import com.epmet.redis.ChangeRelocationRedis; |
|
|
import com.epmet.redis.ChangeRelocationRedis; |
|
|
import com.epmet.service.*; |
|
|
import com.epmet.service.*; |
|
@ -78,6 +84,10 @@ public class ChangeRelocationServiceImpl extends BaseServiceImpl<ChangeRelocatio |
|
|
private IcUserTransferRecordService icUserTransferRecordService; |
|
|
private IcUserTransferRecordService icUserTransferRecordService; |
|
|
@Resource |
|
|
@Resource |
|
|
private IcResiUserConfirmService icResiUserConfirmService; |
|
|
private IcResiUserConfirmService icResiUserConfirmService; |
|
|
|
|
|
@Autowired |
|
|
|
|
|
private IcResiUserDao icResiUserDao; |
|
|
|
|
|
@Autowired |
|
|
|
|
|
private IcUserChangeRecordService icUserChangeRecordService; |
|
|
|
|
|
|
|
|
@Override |
|
|
@Override |
|
|
public PageData<ChangeRelocationDTO> page(Map<String, Object> params) { |
|
|
public PageData<ChangeRelocationDTO> page(Map<String, Object> params) { |
|
@ -342,6 +352,36 @@ public class ChangeRelocationServiceImpl extends BaseServiceImpl<ChangeRelocatio |
|
|
} |
|
|
} |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
@Override |
|
|
|
|
|
public void recovery(TokenDto tokenDto, OnlyIdFormDTO dto) { |
|
|
|
|
|
|
|
|
|
|
|
// 更新用户基础信息用户状态信息
|
|
|
|
|
|
ChangeRelocationEntity changeRelocationEntity = baseDao.selectById(dto.getId()); |
|
|
|
|
|
IcResiUserEntity icResiUserEntity = icResiUserDao.selectById(changeRelocationEntity.getIcUserId()); |
|
|
|
|
|
icResiUserEntity.setStatus("0"); |
|
|
|
|
|
icResiUserEntity.setSubStatus("51"); |
|
|
|
|
|
icResiUserDao.updateById(icResiUserEntity); |
|
|
|
|
|
|
|
|
|
|
|
// 添加迁出恢复记录
|
|
|
|
|
|
CustomerStaffInfoCacheResult staffInfoCache = CustomerStaffRedis.getStaffInfo(tokenDto.getCustomerId(), tokenDto.getUserId()); |
|
|
|
|
|
IcUserChangeRecordEntity changeRecordEntity = new IcUserChangeRecordEntity(); |
|
|
|
|
|
changeRecordEntity.setCustomerId(tokenDto.getCustomerId()); |
|
|
|
|
|
changeRecordEntity.setOperatorId(tokenDto.getUserId()); |
|
|
|
|
|
changeRecordEntity.setIcUserId(icResiUserEntity.getId()); |
|
|
|
|
|
changeRecordEntity.setOperatorName(staffInfoCache.getRealName()); |
|
|
|
|
|
changeRecordEntity.setIcUserName(icResiUserEntity.getName()); |
|
|
|
|
|
changeRecordEntity.setType("recovery_moveout"); |
|
|
|
|
|
changeRecordEntity.setTypeName("恢复迁出"); |
|
|
|
|
|
changeRecordEntity.setBeforeChangeName("-"); |
|
|
|
|
|
changeRecordEntity.setAfterChangeName("-"); |
|
|
|
|
|
changeRecordEntity.setChangeTime(new java.util.Date()); |
|
|
|
|
|
icUserChangeRecordService.insert(changeRecordEntity); |
|
|
|
|
|
|
|
|
|
|
|
// 清除迁出表数据
|
|
|
|
|
|
baseDao.deleteById(dto.getId()); |
|
|
|
|
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
public void editResiMq(String customerId, String userId) { |
|
|
public void editResiMq(String customerId, String userId) { |
|
|
//推送MQ事件
|
|
|
//推送MQ事件
|
|
|
IcResiUserAddMQMsg mqMsg = new IcResiUserAddMQMsg(); |
|
|
IcResiUserAddMQMsg mqMsg = new IcResiUserAddMQMsg(); |
|
|