package com.java110.user.bmo.rentingAppointment.impl;
|
|
import com.java110.core.annotation.Java110Transactional;
|
import com.java110.core.factory.GenerateCodeFactory;
|
import com.java110.dto.rentingAppointment.RentingAppointmentDto;
|
import com.java110.dto.rentingPool.RentingPoolDto;
|
import com.java110.dto.rentingPool.RentingPoolFlowDto;
|
import com.java110.intf.user.IRentingAppointmentInnerServiceSMO;
|
import com.java110.intf.user.IRentingPoolFlowInnerServiceSMO;
|
import com.java110.intf.user.IRentingPoolInnerServiceSMO;
|
import com.java110.po.rentingAppointment.RentingAppointmentPo;
|
import com.java110.po.rentingPool.RentingPoolPo;
|
import com.java110.po.rentingPoolFlow.RentingPoolFlowPo;
|
import com.java110.user.bmo.rentingAppointment.IConfirmRentingBMO;
|
import com.java110.utils.util.Assert;
|
import com.java110.utils.util.DateUtil;
|
import com.java110.vo.ResultVo;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.http.ResponseEntity;
|
import org.springframework.stereotype.Service;
|
|
import java.util.List;
|
|
@Service("confirmRentingBMOImpl")
|
public class ConfirmRentingBMOImpl implements IConfirmRentingBMO {
|
|
@Autowired
|
private IRentingAppointmentInnerServiceSMO rentingAppointmentInnerServiceSMOImpl;
|
|
@Autowired
|
private IRentingPoolInnerServiceSMO rentingPoolInnerServiceSMOImpl;
|
|
|
@Autowired
|
private IRentingPoolFlowInnerServiceSMO rentingPoolFlowInnerServiceSMOImpl;
|
|
/**
|
* @param rentingAppointmentPo
|
* @return 订单服务能够接受的报文
|
*/
|
@Java110Transactional
|
public ResponseEntity<String> confirm(RentingAppointmentPo rentingAppointmentPo) {
|
|
//查询 预约数据 校验
|
RentingAppointmentDto rentingAppointmentDto = new RentingAppointmentDto();
|
rentingAppointmentDto.setAppointmentId(rentingAppointmentPo.getAppointmentId());
|
List<RentingAppointmentDto> rentingAppointmentDtos = rentingAppointmentInnerServiceSMOImpl.queryRentingAppointments(rentingAppointmentDto);
|
|
Assert.listOnlyOne(rentingAppointmentDtos, "未找到预约信息");
|
|
//校验 房源信息
|
RentingPoolDto rentingPoolDto = new RentingPoolDto();
|
rentingPoolDto.setRentingId(rentingAppointmentPo.getRentingId());
|
List<RentingPoolDto> rentingPoolDtos = rentingPoolInnerServiceSMOImpl.queryRentingPools(rentingPoolDto);
|
|
Assert.listOnlyOne(rentingPoolDtos, "未找到房源信息");
|
|
//预约数据修改 租房成功
|
rentingAppointmentPo.setState(RentingAppointmentDto.STATE_SUCCESS);
|
rentingAppointmentPo.setRoomId(rentingPoolDtos.get(0).getRoomId());
|
int flag = rentingAppointmentInnerServiceSMOImpl.updateRentingAppointment(rentingAppointmentPo);
|
|
if (flag < 1) {
|
return ResultVo.createResponseEntity(ResultVo.CODE_ERROR, "保存失败");
|
}
|
//房源状态修改 待支付
|
RentingPoolPo rentingPoolPo = new RentingPoolPo();
|
rentingPoolPo.setRentingId(rentingPoolDtos.get(0).getRentingId());
|
rentingPoolPo.setState(RentingPoolDto.STATE_TO_PAY);
|
flag = rentingPoolInnerServiceSMOImpl.updateRentingPool(rentingPoolPo);
|
if (flag < 1) {
|
throw new IllegalArgumentException("修改房屋状态失败");
|
}
|
|
//流程中插入租客信息
|
RentingPoolFlowPo rentingPoolFlowPo = new RentingPoolFlowPo();
|
rentingPoolFlowPo.setUserTel(rentingAppointmentDtos.get(0).getTenantTel());
|
rentingPoolFlowPo.setUseName(rentingAppointmentDtos.get(0).getTenantName());
|
rentingPoolFlowPo.setUserRole("2"); //租客
|
rentingPoolFlowPo.setState(RentingPoolFlowDto.STATE_CONFIRM_RENTING);
|
rentingPoolFlowPo.setRentingId(rentingAppointmentPo.getRentingId());
|
rentingPoolFlowPo.setDealTime(DateUtil.getNow(DateUtil.DATE_FORMATE_STRING_A));
|
rentingPoolFlowPo.setFlowId(GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_flowId));
|
rentingPoolFlowPo.setContext("确认租房");
|
rentingPoolFlowPo.setCommunityId(rentingPoolDtos.get(0).getCommunityId());
|
flag = rentingPoolFlowInnerServiceSMOImpl.saveRentingPoolFlow(rentingPoolFlowPo);
|
if (flag < 1) {
|
throw new IllegalArgumentException("修改房屋状态失败");
|
}
|
return ResultVo.createResponseEntity(ResultVo.CODE_OK, "保存成功");
|
}
|
|
}
|
