|
@@ -115,7 +115,7 @@ public abstract class GenericEntityService<E extends GenericEntity<PK>, PK>
|
|
|
//实现了 RecordModifierEntity接口的实体,将推送 EntityModifyEvent 事件.
|
|
|
if (eventPublisher != null && pushModifyEvent()) {
|
|
|
E old = selectByPk(pk);
|
|
|
- eventPublisher.publishEvent(new GenericsPayloadApplicationEvent<>(this, new EntityModifyEvent<>(old, entity), entityType));
|
|
|
+ eventPublisher.publishEvent(new GenericsPayloadApplicationEvent<>(this, new EntityModifyEvent<>(old, entity), getEntityType()));
|
|
|
}
|
|
|
return createUpdate(entity)
|
|
|
//如果是RecordCreationEntity则不修改creator_id和creator_time
|
|
@@ -175,7 +175,7 @@ public abstract class GenericEntityService<E extends GenericEntity<PK>, PK>
|
|
|
getDao().insert(entity);
|
|
|
|
|
|
if (eventPublisher != null && pushCreatedEvent()) {
|
|
|
- eventPublisher.publishEvent(new GenericsPayloadApplicationEvent<>(this, new EntityCreatedEvent<>(entity), entityType));
|
|
|
+ eventPublisher.publishEvent(new GenericsPayloadApplicationEvent<>(this, new EntityCreatedEvent<>(entity), getEntityType()));
|
|
|
}
|
|
|
return entity.getId();
|
|
|
}
|