setName('SyncStoreBasicData')->setDescription('同步商城基础数据'); $this->addArgument("store_id"); $this->addArgument("isSyncMaintenanceData"); $this->addArgument("isSyncHelpData"); $this->addArgument("isSyncRichTextData"); } protected function execute(Input $input, Output $output) { $store_id = $input->getArgument("store_id"); $isSyncMaintenanceData = $input->getArgument("isSyncMaintenanceData"); $isSyncHelpData = $input->getArgument("isSyncHelpData"); $isSyncRichTextData = $input->getArgument("isSyncRichTextData"); $where[] = ['is_sync','=', 0]; $where[] = ['is_delete','=', 0]; $where[] = ['is_recycle','=', 0]; $where[] = ['status','=', 1]; if ($store_id) { $where[] = ['store_id','=', $store_id]; } else { $where[] = ['store_id', '<>', self::DEFAULT_STORE_ID]; } $stores = Store::where($where)->field('store_id,is_sync,is_recycle,status,is_delete')->select()->toArray(); // echo "
";
        // print_r($stores);
        // exit();
        if (!$stores) {
            echo "没有要同步的商城了";
            return;
        }
        foreach ($stores as $store) {
            if ($isSyncMaintenanceData) {
               $this->syncMaintenanceData($store);
            }
            if ($isSyncHelpData) {
               $this->syncHelpData($store);
            }
            if ($isSyncRichTextData) {
               $this->syncRichTextData($store);
            }
            Store::where('store_id', $store['store_id'])->update(['is_sync' => 1]);
        }
        

    }
    /**
     * 同步富文本数据
     * [syncHelpData description]
     * @param  [type] $store [description]
     * @return [type]        [description]
     */
    private function syncRichTextData($store){
        //维修分类数据同步
        $agreementList =  Agreement::where('store_id',self::DEFAULT_STORE_ID)->select()->toArray();
        if ($agreementList) {
            foreach ($agreementList as &$agreement) {
                $info = Agreement::where('store_id', $store['store_id'])->where('original_id', $agreement['id'])->find();
                if ($info) {
                    echo $agreement['id']."富文本已存在".PHP_EOL;
                    continue;
                }
                $agreement['create_time'] = time();
                $agreement['update_time'] = time();
                $agreement['original_id'] = $agreement['id'];
                $agreement['store_id'] = $store['store_id'];
                unset($agreement['id']);
                $ret = Agreement::create($agreement);
                var_dump($ret->id);
            }
            unset($agreement);
        }
    }
    /**
     * 同步帮助中心数据
     * [syncHelpData description]
     * @param  [type] $store [description]
     * @return [type]        [description]
     */
    private function syncHelpData($store){
        //维修分类数据同步
        $articleCategoryList =  Category::where('store_id',self::DEFAULT_STORE_ID)->where('status', 1)->select()->toArray();
        if ($articleCategoryList) {
            foreach ($articleCategoryList as &$articleCategory) {
                $info = Category::where('store_id', $store['store_id'])->where('original_id', $articleCategory['category_id'])->find();
                if ($info) {
                    echo $articleCategory['category_id']."帮助分类已存在".PHP_EOL;
                    continue;
                }
                $articleCategory['create_time'] = time();
                $articleCategory['update_time'] = time();
                $articleCategory['original_id'] = $articleCategory['category_id'];
                $articleCategory['store_id'] = $store['store_id'];
                unset($articleCategory['category_id']);

                //复制图片
                $upload_file = Db::name('upload_file')->where('file_id', $articleCategory['img_id'])->find();
                if ($upload_file) {
                    $upload_file['store_id'] = $store['store_id'];
                    $upload_file['create_time'] = time();
                    unset($upload_file['file_id']);
                    $image_id = Db::name('upload_file')->insertGetId($upload_file);
                }
                //写入维修数据
                $articleCategory['img_id'] = $image_id ?? 0;
                $ret = Category::create($articleCategory);
                var_dump($ret->id);
            }
            unset($articleCategory);
        }
        
        //维修数据同步
        $articleList =  Article::where('store_id',self::DEFAULT_STORE_ID)->where('is_delete', 0)->where('status', 1)->select()->toArray();
        if ($articleList) {
            foreach ($articleList as &$article) {
                $info = Article::where('store_id', $store['store_id'])->where('original_id', $article['article_id'])->find();
                if ($info) {
                    echo $article['article_id']."帮助已存在".PHP_EOL;
                    continue;
                }
                //查询分类id
                $articleCategory = Category::where('original_id', $article['category_id'])->where('store_id', $store['store_id'])->find();
                if (!$articleCategory) {
                    continue;
                }
                $article['create_time'] = time();
                $article['update_time'] = time();
                $article['original_id'] = $article['article_id'];
                $article['category_id'] = $articleCategory['category_id'];
                $article['store_id'] = $store['store_id'];
                unset($article['article_id']);
                //复制图片
                $upload_file = Db::name('upload_file')->where('file_id', $article['image_id'])->find();
                if ($upload_file) {
                    $upload_file['store_id'] = $store['store_id'];
                    $upload_file['create_time'] = time();
                    unset($upload_file['file_id']);
                    $image_id = Db::name('upload_file')->insertGetId($upload_file);
                }
                //写入维修数据
                $article['image_id'] = $image_id;
                $ret = Article::create($article);
                //写入图片id
                var_dump($ret->id);
            }
            unset($article);
        }
    }
    /**
     * 同步维修数据
     * [syncMaintenanceData description]
     * @param  [type] $store [description]
     * @return [type]        [description]
     */
    private function syncMaintenanceData($store){
        //维修分类数据同步
        $maintenanceCategoryList =  MaintenanceCategory::where('store_id',self::DEFAULT_STORE_ID)->where('status', 1)->select()->toArray();
       
        if ($maintenanceCategoryList) {
            foreach ($maintenanceCategoryList as &$maintenanceCategory) {
                $info = MaintenanceCategory::where('store_id', $store['store_id'])->where('original_id', $maintenanceCategory['id'])->find();
                if ($info) {
                    echo $maintenanceCategory['id']."维修分类已存在".PHP_EOL;
                    continue;
                }
                $maintenanceCategory['create_time'] = time();
                $maintenanceCategory['update_time'] = time();
                $maintenanceCategory['original_id'] = $maintenanceCategory['id'];
                $maintenanceCategory['store_id'] = $store['store_id'];
                unset($maintenanceCategory['id']);
                // echo "
";
                // print_r($maintenanceCategory);
                // exit();
                $ret = MaintenanceCategory::create($maintenanceCategory);
                var_dump($ret->id);
            }
            unset($maintenanceCategory);
        }
        
        //维修数据同步
        $maintenanceList =  Maintenance::where('store_id',self::DEFAULT_STORE_ID)->where('is_delete', 0)->select()->toArray();
        
        if ($maintenanceList) {
            foreach ($maintenanceList as &$maintenance) {
                $info = Maintenance::where('store_id', $store['store_id'])->where('original_id', $maintenance['id'])->find();
                if ($info) {
                    echo $maintenance['id']."维修已存在".PHP_EOL;
                    continue;
                }
                // echo "
";
                // print_r($info);
                // exit();
                //查询分类id
                $maintenanceCategory = MaintenanceCategory::where('original_id', $maintenance['category_id'])->where('store_id', $store['store_id'])->find();
                if (!$maintenanceCategory) {
                    continue;
                }
                $maintenance['create_time'] = time();
                $maintenance['update_time'] = time();
                $maintenance['original_id'] = $maintenance['id'];
                $maintenance['category_id'] = $maintenanceCategory['id'];
                $maintenance['store_id'] = $store['store_id'];
                unset($maintenance['id']);
                //复制图片
                $upload_file = Db::name('upload_file')->where('file_id', $maintenance['img_id'])->find();
                if ($upload_file) {
                    $upload_file['store_id'] = $store['store_id'];
                    $upload_file['create_time'] = time();
                    unset($upload_file['file_id']);
                    // echo "
";
                    // print_r($upload_file);
                    // exit();
                    $image_id = Db::name('upload_file')->insertGetId($upload_file);
                }
                
                //写入维修数据
                $maintenance['img_id'] = $image_id ?? 0;
                $ret = Maintenance::create($maintenance);
                //写入图片id
                var_dump($ret->id);
            }
            unset($maintenance);
        }
    }

}