|
|
@@ -8,6 +8,7 @@ import cn.hutool.core.util.ObjectUtil;
|
|
|
import lombok.RequiredArgsConstructor;
|
|
|
import lombok.extern.slf4j.Slf4j;
|
|
|
import org.apache.dubbo.config.annotation.DubboReference;
|
|
|
+import org.dromara.backstage.basics.service.IPtRoomService;
|
|
|
import org.dromara.backstage.business.lock.LockBusiness;
|
|
|
import org.dromara.backstage.cardCenter.domain.bo.PtCardBo;
|
|
|
import org.dromara.backstage.cardCenter.service.IPtCardService;
|
|
|
@@ -27,9 +28,11 @@ import org.dromara.backstage.payment.domain.vo.PtBagVo;
|
|
|
import org.dromara.backstage.payment.service.IPtBagService;
|
|
|
import org.dromara.backstage.payment.service.IPtUserAccountService;
|
|
|
import org.dromara.common.core.constant.CacheNames;
|
|
|
+import org.dromara.common.core.constant.DefaultConstants;
|
|
|
import org.dromara.common.core.constant.HotelBusinessConstants;
|
|
|
import org.dromara.common.core.domain.R;
|
|
|
import org.dromara.common.core.domain.model.ErrorInfo;
|
|
|
+import org.dromara.common.core.enums.HotelRoomStatusEnum;
|
|
|
import org.dromara.common.core.enums.ResultCodeEnum;
|
|
|
import org.dromara.common.core.enums.RoomCardTypeEnum;
|
|
|
import org.dromara.common.message.kafka.domain.KafkaHeader;
|
|
|
@@ -79,6 +82,7 @@ public class TraineeBusiness {
|
|
|
private final LockBusiness lockBusiness;
|
|
|
private final KafkaNormalProducer kafkaProducer;
|
|
|
private final SelfBusiness selfBusiness;
|
|
|
+ private final IPtRoomService roomService;
|
|
|
|
|
|
/**
|
|
|
* 获取报到学员信息
|
|
|
@@ -334,13 +338,26 @@ public class TraineeBusiness {
|
|
|
}
|
|
|
}
|
|
|
|
|
|
+ /**
|
|
|
+ * 设置学员报到状态
|
|
|
+ * @param bo 学员报到业务对象
|
|
|
+ * @param ycTraineeVo 学员信息
|
|
|
+ */
|
|
|
private void setCheckInfoStatus(YcTraineeBo bo, YcTraineeVo ycTraineeVo){
|
|
|
+ //更新报到状态
|
|
|
Boolean result = remoteDeptService.updateCheckInStatus(Long.valueOf(bo.getDeptId()),Long.valueOf(bo.getUserId()));
|
|
|
if(result){
|
|
|
ycTraineeVo.setCheckinState(1);
|
|
|
}
|
|
|
+ //更新客房状态
|
|
|
+ result = roomService.updateGuestRoomStatus(bo.getRoomCode(), DefaultConstants.TENANT_ID, HotelRoomStatusEnum.YZ.code());
|
|
|
}
|
|
|
|
|
|
+ /**
|
|
|
+ * 发送报到信息到kafka
|
|
|
+ * @param bo 学员报到业务对象
|
|
|
+ * @param ycTraineeVo 学员信息
|
|
|
+ */
|
|
|
private void sendCheckInMessageToKafka(YcTraineeBo bo, YcTraineeVo ycTraineeVo){
|
|
|
TraineeCheckIn traineeCheckIn = new TraineeCheckIn();
|
|
|
traineeCheckIn.setOtherSysId(ycTraineeVo.getOtherId());
|