Untitled

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,
      });
    }
  }