async receiveDetectAI(payload: IReceiveDetect) {
console.log('🚀 ~ payload:', payload)
const post = await this.postRepository.findOne({ where: { post_id: payload.post_id }, relations: { user: true } });
if (!post) return;
await this.postRepository.update(
{ post_id: payload.post_id },
{ ...(payload.type == IS_BOOLEAN.TRUE && { status: STATUS_POST.DETECT_BLOCK }), is_detect: IS_BOOLEAN.TRUE },
);
await this.kafkaProducer.send(TOPIC_KAFKA_NOTIFY_JAVA.SEND_NOTIFICATION, {
customer_id: post.user.user_id.toString(),
title:
payload.type == IS_BOOLEAN.FALSE
? `Bài viết của bạn đã được duyệt, bấm vào đây để xem`
: `Bài viết của bạn bị từ chối vì vi phạm điều khoản AloLine`,
content:
payload.type == IS_BOOLEAN.FALSE
? `Bài viết của bạn đã được duyệt, bấm vào đây để xem`
: `Bài viết của bạn bị từ chối vì vi phạm điều khoản AloLine`,
avatar: post.user.avatar || '',
object_id: payload.post_id,
object_type: payload.type == IS_BOOLEAN.FALSE ? OBJECT_TYPE.DETECT_POST : OBJECT_TYPE.DENIED_POST,
notification_type: payload.type == IS_BOOLEAN.FALSE ? NOTIFICATION_TYPE.DETECT_POST : NOTIFICATION_TYPE.DENIED_POST,
json_addition_data: '',
});
if (!post.auto_post_type && payload.type == IS_BOOLEAN.FALSE) {
await this.kafkaProducer.send(TOPICS.TOPIC_CREATE_POST, {
object_id: payload.post_id,
user_id: post.user.user_id.toString(),
post_create_type: post.is_review ? CREATE_POST_TYPE.REVIEW : CREATE_POST_TYPE.NORMAL,
branch_id: post.is_review ? post.branch.branch_id : IS_BOOLEAN.FALSE,
});
}
}