1 
types:
            product:
                mappings:
                    title:    { search_analyzer: custom_search_analyzer, index_analyzer: custom_index_analyzer, type: string }
                    status:
                    brand.name:    { search_analyzer: custom_search_analyzer, index_analyzer: custom_index_analyzer, type: string }
                    brand:
                      type: "nested"
                      properties:
                          status: ~
                persistence:
                    driver: orm
                    model: MyBundle\Entity\Product\Product
                    provider: 
                      query_builder_method: customProductQueryBuilderElastica
                    listener: ~ 
                    finder: ~

这是我对产品类型的映射。customProductQueryBuilderElastica包含仅填充具有活动状态和相关品牌状态活动的产品的代码。如果我从管理员那里更改产品，它会完美运行。

我想要做的是，当我将品牌状态更改为非活动状态时，所有相关产品都应从 ES 中删除。

为此，我已将品牌用作产品的嵌套并为其创建了监听器，如此处所述，现在我可以自动更改 ES 中每个产品的品牌状态，但我想在品牌状态设置为非活动时删除此类产品。如何以更好的方式实现这一目标？

4

1 回答 1

1

经过多次尝试。我终于实现了我想要的。我在这里发布我的代码并尝试帮助其他人。

感谢@maercky。我参考了他在此处给出的回答

这是我的 config.yml 文件。

types:
            product:
                mappings:
                    title:    { search_analyzer: custom_search_analyzer, index_analyzer: custom_index_analyzer, type: string }
                    status:
                    brand.name:    { search_analyzer: custom_search_analyzer, index_analyzer: custom_index_analyzer, type: string }
                    brand:
                      type: "nested"
                      properties:
                          status: ~
                persistence:
                    driver: orm
                    model: XXX\MyBundle\Entity\Product\Product
                    provider: 
                      query_builder_method: customProductQueryBuilderElastica
                    listener: ~ 
                    finder: ~

此代码将转到 service.yml

fos_elastica.listener.brand.product:
    class: 'XXX\MyBundle\Listener\ElasticaBrandListener'
    arguments:
        - @fos_elastica.object_persister.search.product
        - ['postPersist', 'postUpdate', 'postRemove', 'preRemove']
        - @fos_elastica.indexable
    calls:
        - [ setContainer, [ '@service_container', @fos_elastica.object_persister.search.product ] ]
    tags:
        - { name: 'doctrine.event_subscriber' }

最后这是我的品牌听众

    <?php

namespace  XXX\MyBundle\Listener;

use FOS\ElasticaBundle\Doctrine\Listener as BaseListener;
use Doctrine\Common\EventArgs;
use Symfony\Component\DependencyInjection\ContainerInterface;
use XXX\MyBundle\Entity\Supplier\Brand;
use FOS\ElasticaBundle\Persister\ObjectPersister;

class ElasticaBrandListener extends BaseListener
{

    /** @var \Symfony\Component\DependencyInjection\ContainerInterface */
    private $container;
    private $objectPersisterProducts;

    public function setContainer(ContainerInterface $container,ObjectPersister $objectPersisterProduct) {
        $this->container = $container;
        $this->objectPersisterProducts = $objectPersisterProduct;
    }

    /**
     * @param Doctrine\Common\EventArgs $eventArgs
     */
    public function postUpdate(EventArgs $eventArgs)
    {
        /** @var $brand Brand */
        $brand = $eventArgs->getEntity();

        if ($brand instanceof Brand) {
            $this->scheduledForUpdate[] = $brand;
            foreach ($brand->getProducts() as $product) {
                $brand_status = $brand->getStatus();
                $product_status = $product->getStatus();
                if($brand_status == 'active' && $product_status == 'active'){
                    $this->objectPersisterProducts->replaceOne($product);
                }else{
                    $this->objectPersisterProducts->deleteOne($product);
                }

            }
        }
    }
}
?>

所有这些对我来说都很好，所以我正在为其他人做出贡献。

于 2014-09-26T13:16:24.387 回答