setName('SyncStoreBasicData')->setDescription('同步商城基础数据'); $this->addArgument("store_id"); $this->addArgument("isSyncMaintenanceData"); $this->addArgument("isSyncHelpData"); $this->addArgument("isSyncRichTextData"); $this->addArgument("isSyncRecoveryData"); $this->addArgument("isSyncServerData"); $this->addArgument("isSyncBannerData"); $this->addArgument("isSyncStoreSettingData"); $this->addArgument("isSyncStoreExpressData"); } 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"); $isSyncRecoveryData = $input->getArgument("isSyncRecoveryData"); $isSyncServerData = $input->getArgument("isSyncServerData"); $isSyncBannerData = $input->getArgument("isSyncBannerData"); $isSyncStoreSettingData = $input->getArgument("isSyncStoreSettingData"); $isSyncStoreExpressData = $input->getArgument("isSyncStoreExpressData"); $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); } if ($isSyncRecoveryData) { $this->syncRecoveryData($store); } if ($isSyncServerData) { $this->syncServerData($store); } if ($isSyncBannerData) { $this->syncBannerData($store); } if ($isSyncStoreSettingData) { $this->syncStoreSettingData($store); } if ($isSyncStoreExpressData) { $this->syncStoreExpressData($store); } Store::where('store_id', $store['store_id'])->update(['is_sync' => 1]); } } /** * 同步物流公司 * [syncStoreExpressData description] * @param [type] $store [description] * @return [type] [description] */ private function syncStoreExpressData($store){ //维修分类数据同步 $expressList = Db::connect("shopMysql")->name('yoshop_express')->where('store_id',self::DEFAULT_STORE_ID)->select()->toArray(); if ($expressList) { foreach ($expressList as &$express) { $info = Express::where('store_id', $store['store_id'])->where('kuaidi100_code', $express['kuaidi100_code'])->where('kdniao_code', $express['kdniao_code'])->find(); if ($info) { echo $express['express_id']."物流公司已存在".PHP_EOL; $ret = Express::where('store_id', $store['store_id'])->where('express_id', $info['express_id'])->update([ 'express_name' => $express['express_name'], 'kuaidi100_code' => $express['kuaidi100_code'], 'kdniao_code' => $express['kdniao_code'], 'original_id' => $express['express_id'], ]); var_dump($ret); continue; } $express['create_time'] = time(); $express['update_time'] = time(); $express['original_id'] = $express['express_id']; $express['store_id'] = $store['store_id']; unset($express['express_id']); $ret = Express::create($express); var_dump($ret->express_id); } unset($express); } } /** * 同步基本信息,七牛云、快递100、99api的配置 * [syncSettingData description] * @param [type] $store [description] * @return [type] [description] */ private function syncStoreSettingData($store){ //99api配置 // $collector = Setting::where('key','collector')->where('store_id', $store['store_id'])->find(); // if (!$collector) { // $collectorData = [ // "key" => "collector", // "describe" => "商品采集设置", // "values" => json_decode('{"config":{"99api":{"apiKey":"9271DA7BF37C6F50BED49B7F0ADD49A2"}}}', true), // "store_id" => $store['store_id'], // "create_time" => time(), // "update_time" => time(), // ]; // $ret = Setting::create($collectorData); // echo "99api配置新增成功"; // var_dump($ret->key); // } //配送设置 $delivery = Setting::where('key','delivery')->where('store_id', $store['store_id'])->find(); if (!$delivery) { $deliveryData = [ "key" => "delivery", "describe" => "配送设置", "values" => json_decode('{"traces":{"enable":1,"default":"kd100","providerConfig":{"kd100":{"customer":"F6CAEF5CEA6B5BF219149B9B42BECAA1","key":"pjVBLUai1633"},"aliyun":{"appCode":""}}},"delivery_type":[10,20,30]}', true), "store_id" => $store['store_id'], "create_time" => time(), "update_time" => time(), ]; $ret = Setting::create($deliveryData); echo "配送设置新增成功"; var_dump($ret->key); } //上传设置 $storage = Setting::where('key','storage')->where('store_id', $store['store_id'])->find(); if (!$storage) { $storageData = [ "key" => "storage", "describe" => "上传设置", "values" => json_decode('{"default":"qiniu","engine":{"qiniu":{"bucket":"saasyovo","access_key":"ehSHgkSkS9lGex8n0-vMf1-wkbgi56yv6fhEwsYS","secret_key":"jNXsuPmTnmfiRlNs-JoAmT833o0qusgXrXqeR3VK","domain":"https:\/\/qiniu.shop.royaum.com.cn"},"aliyun":{"bucket":"","access_key_id":"","access_key_secret":"","domain":"http:\/\/"},"qcloud":{"bucket":"","region":"","secret_id":"","secret_key":"","domain":"http:\/\/"}}}', true), "store_id" => $store['store_id'], "create_time" => time(), "update_time" => time(), ]; $ret = Setting::create($storageData); echo "上传设置新增成功"; var_dump($ret->key); } } /** * 同步富文本数据 * [syncHelpData description] * @param [type] $store [description] * @return [type] [description] */ private function syncRichTextData($store){ //维修分类数据同步 $agreementList = Db::connect("shopMysql")->name('yoshop_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 = Db::connect("shopMysql")->name('yoshop_article_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::connect("shopMysql")->name('yoshop_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 = Db::connect("shopMysql")->name('yoshop_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::connect("shopMysql")->name('yoshop_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 = Db::connect("shopMysql")->name('yoshop_maintenance_category')->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 = Db::connect("shopMysql")->name('yoshop_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::connect("shopMysql")->name('yoshop_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); } } /** * 同步回收数据 * [syncHelpData description] * @param [type] $store [description] * @return [type] [description] */ private function syncRecoveryData($store){ //维修分类数据同步 $articleCategoryList = Db::connect("shopMysql")->name('yoshop_server_recovery_category')->where('store_id',self::DEFAULT_STORE_ID)->where('status', 1)->select()->toArray(); if ($articleCategoryList) { foreach ($articleCategoryList as &$articleCategory) { $info = RecoveryCategory::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::connect("shopMysql")->name('yoshop_upload_file')->where('file_id', $articleCategory['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); } //写入维修数据 $articleCategory['image_id'] = $image_id ?? 0; $ret = RecoveryCategory::create($articleCategory); var_dump($ret->category_id); } unset($articleCategory); } //维修数据同步 $articleList = Db::connect("shopMysql")->name('yoshop_server_recovery')->where('store_id',self::DEFAULT_STORE_ID)->where('status', 1)->select()->toArray(); if ($articleList) { foreach ($articleList as &$article) { $info = ServerRecovery::where('store_id', $store['store_id'])->where('original_id', $article['recovery_id'])->find(); if ($info) { echo $article['recovery_id']."回收已存在".PHP_EOL; continue; } //查询分类id $articleCategory = RecoveryCategory::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['recovery_id']; $article['category_id'] = $articleCategory['category_id']; $article['store_id'] = $store['store_id']; unset($article['recovery_id']); //复制图片 $upload_file = Db::connect("shopMysql")->name('yoshop_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 = ServerRecovery::create($article); //写入图片id var_dump($ret->recovery_id); } unset($article); } } /** * 同步服务数据 * [syncHelpData description] * @param [type] $store [description] * @return [type] [description] */ private function syncServerData($store){ //服务分类数据同步 $articleCategoryList = Db::connect("shopMysql")->name('yoshop_server_category')->where('store_id',self::DEFAULT_STORE_ID)->where('status', 1)->select()->toArray(); if ($articleCategoryList) { foreach ($articleCategoryList as &$articleCategory) { $info = ServerCategory::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::connect("shopMysql")->name('yoshop_upload_file')->where('file_id', $articleCategory['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); } //写入维修数据 $articleCategory['image_id'] = $image_id ?? 0; $ret = ServerCategory::create($articleCategory); var_dump($ret->category_id); } unset($articleCategory); } //服务数据同步 $articleList = Db::connect("shopMysql")->name('yoshop_server')->where('store_id',self::DEFAULT_STORE_ID)->where('status', 1)->select()->toArray(); if ($articleList) { foreach ($articleList as &$article) { $info = Server::where('store_id', $store['store_id'])->where('original_id', $article['server_id'])->find(); if ($info) { echo $article['server_id']."服务已存在".PHP_EOL; continue; } //查询分类id $articleCategory = ServerCategory::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['server_id']; $article['category_id'] = $articleCategory['category_id']; $article['store_id'] = $store['store_id']; unset($article['server_id']); //复制图片 $upload_file = Db::connect("shopMysql")->name('yoshop_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 = Server::create($article); //写入图片id var_dump($ret->server_id); } unset($article); } } /** * 同步轮播图数据 * [syncHelpData description] * @param [type] $store [description] * @return [type] [description] */ private function syncBannerData($store){ //服务分类数据同步 $articleCategoryList = Db::connect("shopMysql")->name('yoshop_banner')->where('store_id',self::DEFAULT_STORE_ID)->where('status', 10)->select()->toArray(); if ($articleCategoryList) { foreach ($articleCategoryList as &$articleCategory) { $info = Banner::where('store_id', $store['store_id'])->where('original_id', $articleCategory['id'])->find(); if ($info) { echo $articleCategory['id']."轮播图已存在".PHP_EOL; continue; } $articleCategory['create_time'] = time(); $articleCategory['update_time'] = time(); $articleCategory['original_id'] = $articleCategory['id']; $articleCategory['store_id'] = $store['store_id']; unset($articleCategory['id']); unset($articleCategory['redirect_url']); //复制图片 $upload_file = Db::connect("shopMysql")->name('yoshop_upload_file')->where('file_id', $articleCategory['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); } //写入维修数据 $articleCategory['image_id'] = $image_id ?? 0; $ret = Banner::create($articleCategory); var_dump($ret->id); } unset($articleCategory); } } }