|
@@ -3,6 +3,7 @@ package com.usky.vpp.service.impl;
|
|
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
|
|
import com.fasterxml.jackson.core.JsonProcessingException;
|
|
import com.fasterxml.jackson.core.JsonProcessingException;
|
|
|
import com.fasterxml.jackson.databind.ObjectMapper;
|
|
import com.fasterxml.jackson.databind.ObjectMapper;
|
|
|
|
|
+import com.usky.vpp.config.VppUnTenantContext;
|
|
|
import com.usky.vpp.constant.VppDrEventStatus;
|
|
import com.usky.vpp.constant.VppDrEventStatus;
|
|
|
import com.usky.vpp.domain.VppDrEvent;
|
|
import com.usky.vpp.domain.VppDrEvent;
|
|
|
import com.usky.vpp.domain.VppDrParticipation;
|
|
import com.usky.vpp.domain.VppDrParticipation;
|
|
@@ -170,7 +171,7 @@ public class VppDrEventIngestServiceImpl implements VppDrEventIngestService {
|
|
|
event.setEventStatus(EVENT_STATUS_PENDING);
|
|
event.setEventStatus(EVENT_STATUS_PENDING);
|
|
|
applyBaseFields(event, eventMap, descriptor);
|
|
applyBaseFields(event, eventMap, descriptor);
|
|
|
event.setRawPayload(toJson(rawBody));
|
|
event.setRawPayload(toJson(rawBody));
|
|
|
- Integer tenantId = VppAuditHelper.resolveTenantId(dnID);
|
|
|
|
|
|
|
+ Integer tenantId = VppUnTenantContext.resolveTenantId();
|
|
|
if (tenantId != null) {
|
|
if (tenantId != null) {
|
|
|
event.setTenantId(tenantId);
|
|
event.setTenantId(tenantId);
|
|
|
}
|
|
}
|