|
|
|
@ -5,19 +5,36 @@ import com.baomidou.mybatisplus.core.metadata.IPage; |
|
|
|
import com.epmet.commons.mybatis.service.impl.BaseServiceImpl; |
|
|
|
import com.epmet.commons.tools.constant.FieldConstant; |
|
|
|
import com.epmet.commons.tools.constant.NumConstant; |
|
|
|
import com.epmet.commons.tools.dto.result.CustomerStaffInfoCacheResult; |
|
|
|
import com.epmet.commons.tools.enums.GenderEnum; |
|
|
|
import com.epmet.commons.tools.exception.EpmetErrorCode; |
|
|
|
import com.epmet.commons.tools.exception.EpmetException; |
|
|
|
import com.epmet.commons.tools.page.PageData; |
|
|
|
import com.epmet.commons.tools.redis.common.CustomerIcHouseRedis; |
|
|
|
import com.epmet.commons.tools.redis.common.CustomerOrgRedis; |
|
|
|
import com.epmet.commons.tools.redis.common.CustomerStaffRedis; |
|
|
|
import com.epmet.commons.tools.redis.common.bean.GridInfoCache; |
|
|
|
import com.epmet.commons.tools.redis.common.bean.HouseInfoCache; |
|
|
|
import com.epmet.commons.tools.utils.ConvertUtils; |
|
|
|
import com.epmet.commons.tools.utils.Result; |
|
|
|
import com.epmet.dao.IcResiUserConfirmDao; |
|
|
|
import com.epmet.dao.IcResiUserDao; |
|
|
|
import com.epmet.dto.IcResiUserConfirmDTO; |
|
|
|
import com.epmet.dto.form.ConfirmListFormDTO; |
|
|
|
import com.epmet.dto.form.IcResiUserConfirmGetDTO; |
|
|
|
import com.epmet.dto.form.IcResiUserConfirmSubmitDTO; |
|
|
|
import com.epmet.dto.form.MoveOutMemberFormDTO; |
|
|
|
import com.epmet.dto.result.ConfirmListResultDTO; |
|
|
|
import com.epmet.dto.result.MoveOutDetailResultDTO; |
|
|
|
import com.epmet.entity.IcResiUserConfirmEntity; |
|
|
|
import com.epmet.entity.IcResiUserEntity; |
|
|
|
import com.epmet.enums.UserConfirmEnum; |
|
|
|
import com.epmet.redis.IcResiUserConfirmRedis; |
|
|
|
import com.epmet.service.IcResiUserConfirmService; |
|
|
|
import com.github.pagehelper.PageHelper; |
|
|
|
import com.github.pagehelper.PageInfo; |
|
|
|
import lombok.extern.slf4j.Slf4j; |
|
|
|
import org.apache.commons.collections4.CollectionUtils; |
|
|
|
import org.apache.commons.lang3.StringUtils; |
|
|
|
import org.springframework.beans.factory.annotation.Autowired; |
|
|
|
import org.springframework.stereotype.Service; |
|
|
|
@ -33,6 +50,7 @@ import java.util.Map; |
|
|
|
* @author generator generator@elink-cn.com |
|
|
|
* @since v1.0.0 2022-06-01 |
|
|
|
*/ |
|
|
|
@Slf4j |
|
|
|
@Service |
|
|
|
public class IcResiUserConfirmServiceImpl extends BaseServiceImpl<IcResiUserConfirmDao, IcResiUserConfirmEntity> implements IcResiUserConfirmService { |
|
|
|
|
|
|
|
@ -199,4 +217,90 @@ public class IcResiUserConfirmServiceImpl extends BaseServiceImpl<IcResiUserConf |
|
|
|
icResiUserConfirmDao.insert(entity); |
|
|
|
} |
|
|
|
|
|
|
|
/** |
|
|
|
* 迁出审核列表 |
|
|
|
* |
|
|
|
* @param form |
|
|
|
* @Param form |
|
|
|
* @Return {@link PageData< ConfirmListResultDTO >} |
|
|
|
* @Author zhaoqifeng |
|
|
|
* @Date 2022/6/22 14:30 |
|
|
|
*/ |
|
|
|
@Override |
|
|
|
public PageData<ConfirmListResultDTO> confirmList(ConfirmListFormDTO form) { |
|
|
|
//获取工作人员所属组织
|
|
|
|
CustomerStaffInfoCacheResult staffInfo = CustomerStaffRedis.getStaffInfo(form.getCustomerId(), form.getStaffId()); |
|
|
|
if (null == staffInfo) { |
|
|
|
throw new EpmetException(EpmetErrorCode.EPMET_COMMON_OPERATION_FAIL.getCode(), "获取用户信息失败", "获取用户信息失败"); |
|
|
|
} |
|
|
|
form.setAgencyId(staffInfo.getAgencyId()); |
|
|
|
PageHelper.startPage(form.getPageNo(), form.getPageSize()); |
|
|
|
List<ConfirmListResultDTO> list =baseDao.getConfirmList(form); |
|
|
|
PageInfo<ConfirmListResultDTO> pageInfo = new PageInfo<>(list); |
|
|
|
if (CollectionUtils.isNotEmpty(list)) { |
|
|
|
list.forEach(item -> { |
|
|
|
//获取网格信息
|
|
|
|
GridInfoCache gridInfo = CustomerOrgRedis.getGridInfo(item.getGridId()); |
|
|
|
if (null != gridInfo) { |
|
|
|
log.warn("迁出审核列表获取网格缓存失败"); |
|
|
|
item.setGridName(gridInfo.getGridNamePath()); |
|
|
|
} |
|
|
|
//获取房屋信息
|
|
|
|
HouseInfoCache houseInfo = CustomerIcHouseRedis.getHouseInfo(form.getCustomerId(), item.getHomeId()); |
|
|
|
if (null != houseInfo) { |
|
|
|
log.warn("迁出审核列表获取房屋缓存失败"); |
|
|
|
item.setHomeName(houseInfo.getAllName()); |
|
|
|
} |
|
|
|
item.setGender(GenderEnum.getName(item.getGender())); |
|
|
|
item.setConfirmResult(UserConfirmEnum.getName(item.getConfirmResult())); |
|
|
|
}); |
|
|
|
} |
|
|
|
return new PageData<>(list, pageInfo.getTotal()); |
|
|
|
} |
|
|
|
|
|
|
|
/** |
|
|
|
* 迁出审核详情 |
|
|
|
* |
|
|
|
* @param id |
|
|
|
* @Param id |
|
|
|
* @Return {@link MoveOutDetailResultDTO} |
|
|
|
* @Author zhaoqifeng |
|
|
|
* @Date 2022/6/22 16:21 |
|
|
|
*/ |
|
|
|
@Override |
|
|
|
public MoveOutDetailResultDTO moveOutConfirmDetail(String customerId, String id) { |
|
|
|
MoveOutDetailResultDTO result = baseDao.getMoveOutConfirmDetail(id); |
|
|
|
if (null != result) { |
|
|
|
//获取网格信息
|
|
|
|
GridInfoCache gridInfo = CustomerOrgRedis.getGridInfo(result.getGridId()); |
|
|
|
//获取房屋信息
|
|
|
|
HouseInfoCache houseInfo = CustomerIcHouseRedis.getHouseInfo(customerId, result.getHomeId()); |
|
|
|
if (null == houseInfo) { |
|
|
|
throw new EpmetException(EpmetErrorCode.EPMET_COMMON_OPERATION_FAIL.getCode(), "获取房屋信息失败", "获取房屋信息失败"); |
|
|
|
} |
|
|
|
result.setGridName(houseInfo.getGridName()); |
|
|
|
result.setVillageName(houseInfo.getNeighborHoodName()); |
|
|
|
result.setBuildName(houseInfo.getBuildingName()); |
|
|
|
result.setUnitName(houseInfo.getUnitName()); |
|
|
|
result.setHomeName(houseInfo.getDoorName()); |
|
|
|
} |
|
|
|
|
|
|
|
return result; |
|
|
|
} |
|
|
|
|
|
|
|
/** |
|
|
|
* 迁出审核 |
|
|
|
* |
|
|
|
* @param formDTO |
|
|
|
* @Param formDTO |
|
|
|
* @Return {@link null} |
|
|
|
* @Author zhaoqifeng |
|
|
|
* @Date 2022/6/22 16:45 |
|
|
|
*/ |
|
|
|
@Override |
|
|
|
@Transactional(rollbackFor = Exception.class) |
|
|
|
public void moveOutConfirm(IcResiUserConfirmDTO formDTO) { |
|
|
|
baseDao.updateById(ConvertUtils.sourceToTarget(formDTO, IcResiUserConfirmEntity.class)); |
|
|
|
} |
|
|
|
|
|
|
|
} |
|
|
|
|