|
@@ -54,6 +54,7 @@ import org.dromara.hotel.api.service.RemoteOrderService;
|
|
|
import org.dromara.hotel.api.service.RemoteTeamService;
|
|
import org.dromara.hotel.api.service.RemoteTeamService;
|
|
|
import org.dromara.system.api.RemoteDeptService;
|
|
import org.dromara.system.api.RemoteDeptService;
|
|
|
import org.dromara.system.api.domain.vo.RemoteDeptVo;
|
|
import org.dromara.system.api.domain.vo.RemoteDeptVo;
|
|
|
|
|
+import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
|
|
|
import org.springframework.stereotype.Service;
|
|
import org.springframework.stereotype.Service;
|
|
|
|
|
|
|
|
import java.util.ArrayList;
|
|
import java.util.ArrayList;
|
|
@@ -94,6 +95,8 @@ public class TraineeBusiness {
|
|
|
|
|
|
|
|
private final DefaultConfig defaultConfig;
|
|
private final DefaultConfig defaultConfig;
|
|
|
|
|
|
|
|
|
|
+ private final ThreadPoolTaskExecutor threadPoolTaskExecutor;
|
|
|
|
|
+
|
|
|
/**
|
|
/**
|
|
|
* 获取报到学员信息
|
|
* 获取报到学员信息
|
|
|
*
|
|
*
|
|
@@ -366,9 +369,9 @@ public class TraineeBusiness {
|
|
|
remoteBo.setOrderStatus(HotelBusinessConstants.ORDER_STATUS_RZ);
|
|
remoteBo.setOrderStatus(HotelBusinessConstants.ORDER_STATUS_RZ);
|
|
|
remoteBo.setUpdatedBy(Long.valueOf(bo.getUserId()));
|
|
remoteBo.setUpdatedBy(Long.valueOf(bo.getUserId()));
|
|
|
//todo 自助报到,修改房态时没有租户id,所以暂时写一个默认的租户
|
|
//todo 自助报到,修改房态时没有租户id,所以暂时写一个默认的租户
|
|
|
- if(StringUtils.isNotEmpty(bo.getTenantId())){
|
|
|
|
|
|
|
+ if (StringUtils.isNotEmpty(bo.getTenantId())) {
|
|
|
remoteBo.setTenantId(bo.getTenantId());
|
|
remoteBo.setTenantId(bo.getTenantId());
|
|
|
- }else{
|
|
|
|
|
|
|
+ } else {
|
|
|
remoteBo.setTenantId(defaultConfig.getTenantId());
|
|
remoteBo.setTenantId(defaultConfig.getTenantId());
|
|
|
}
|
|
}
|
|
|
|
|
|
|
@@ -457,7 +460,9 @@ public class TraineeBusiness {
|
|
|
traineeCheckIn.setPayStatus(true);
|
|
traineeCheckIn.setPayStatus(true);
|
|
|
traineeCheckIn.setPayDate(DateUtil.format(bo.getCheckInDate(), DefaultConstants.DATE_TIME_FORMAT));
|
|
traineeCheckIn.setPayDate(DateUtil.format(bo.getCheckInDate(), DefaultConstants.DATE_TIME_FORMAT));
|
|
|
|
|
|
|
|
- kafkaProducer.sendKafkaMessage(KafkaTopicConstants.OLD_SYNC_TOPIC, EventTypeConstants.REGISTER_STATUS, EventSenderConstants.YKT, traineeCheckIn);
|
|
|
|
|
|
|
+ threadPoolTaskExecutor.execute(() ->
|
|
|
|
|
+ kafkaProducer.sendKafkaMessage(KafkaTopicConstants.OLD_SYNC_TOPIC, EventTypeConstants.REGISTER_STATUS, EventSenderConstants.YKT, traineeCheckIn)
|
|
|
|
|
+ );
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
public YcLockCardVo queryLockCardInfo(Map<String, Object> mapQuery) {
|
|
public YcLockCardVo queryLockCardInfo(Map<String, Object> mapQuery) {
|