setName('syncGoodsToEs')->setDescription('同步商品数据到ES'); $this->addArgument("type"); $this->addArgument("goods_id"); $this->addArgument("store_id"); } protected function execute(Input $input, Output $output) { $type = $input->getArgument("type"); $goods_id = $input->getArgument("goods_id"); $store_id = $input->getArgument("store_id"); if ($type == "goods") { $goodsCateService = new GoodsCateEs(); //$goodsService = new GoodsEs(); //$goodsService->createGoodsIndex(); $goodsCateService->batchCreateGoods($goods_id, $store_id); } elseif ($type == "goods_cate"){ $goodsCateService = new GoodsCateEs(); //$goodsCateService->createGoodsCateIndex(); $goodsCateService->batchCreateGoodsCategory($goods_id, $store_id); } // try { // $goodsService->batchCreateData(); // }catch (\Exception $e) { // $output->writeln($e->getMessage()); // } } }