链街Dcat后台
You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
 
 
 
 

143 lines
4.5 KiB

<?php
namespace App\Console\Commands;
use Illuminate\Console\Command;
use Illuminate\Support\Facades\DB;
use Illuminate\Support\Facades\Schema;
class MigrateStore extends Command
{
/**
* The name and signature of the console command.
*
* @var string
*/
protected $signature = 'migrateData:store';
/**
* The console command description.
*
* @var string
*/
protected $description = 'Command 迁移店铺数据';
/**
* Create a new command instance.
*
* @return void
*/
public function __construct()
{
parent::__construct();
}
/**
* Execute the console command.
*
* @return int
*/
public function handle()
{
$oldTableName = 'ims_cjdc_store_new';
$newTableName = 'lanzu_store_new';
$storeImgPath = 'QR_code/code_store_img/wx_store_';/* 商户小程序码 */
$storePayPath = 'QR_code/code_pay_img/wx_pay_';/* 收银二维码 */
// 判断表是否存在
if(!Schema::hasTable($oldTableName)){
var_dump('旧表不存在');
return 0;
}
if(!Schema::hasTable($newTableName)){
var_dump('新表不存在');
return 0;
}
$oldData = DB::table($oldTableName)->orderBy('id','desc')->get();
$bar = $this->output->createProgressBar(count($oldData));
$bar->start();
$startTime = time();
$error = [];
$newData = [];
foreach ($oldData as $key => $value){
$storeId = $value->id;
// 判断在新表是否存在
$exist = DB::table($newTableName)->where('id',$storeId)->exists();
if($exist){
continue;
}
$storeData =[
'id'=>$storeId,
'market_id'=>$value->market_id,
'is_open'=> $value->is_open == 1 ? 1 : 0,
'is_rest'=> $value->is_rest == 1 ? 1 : 0,
'status'=>$value->state,
'category_id'=>$value->md_type,
'user_id'=>$value->user_id,
'admin_id'=>$value->admin_id,
'mm_user_id'=>$value->mm_user_id,
'sort'=>$value->number,
'loudspeaker_imei'=>$value->loudspeaker_imei,
'name'=>$value->name,
'logo'=>$value->logo,
'announcement'=>$value->announcement,
'address' => $value->address,
'business_license'=> ($storeId == 365) ? '' :$value->yyzz,/* 因为365的数据的营业资质数据乱码,目前只有365这个店铺的有问题 */
'zm_img' => $value->zm_img,
'fm_img'=>$value->fm_img,
'tel' => $value->tel,
'link_name'=>$value->link_name,
'link_tel' => $value->link_tel,
'expire_time'=> strtotime($value->rzdq_time),
'time1' => $value->time,
'time2'=>$value->time2,
'time3' => $value->time3,
'time4'=>$value->time4,
'award_money' => $value->award_money,
'sales'=>$value->score,
'grade' => $value->sales,
'code'=>$value->code,
'environment' => $value->environment,
'introduction'=> strip_tags($value->details),
'store_applet_img' => $storeImgPath.$storeId.'.jpg',
'cash_code_img' => $storePayPath.$storeId.'.jpg',
'created_at' => time(),
'updated_at' => time(),
];
// 获商户摊号
$stallInfo = '';
$res = preg_match('/[0-9]/', $value->name, $matches, PREG_OFFSET_CAPTURE);
if($res && count($matches)>0){
$stallInfo = substr($value->name,$matches[0][1]);
}
$storeData['stall_info'] = $stallInfo;
// 商户经纬度
if(!empty($value->coordinates)){
$coordinatesArr = explode(',',$value->coordinates);
$storeData['lng'] = $coordinatesArr[1];
$storeData['lat'] = $coordinatesArr[0];
}
$newData = $storeData;
$res = DB::table($newTableName)->insert($newData);
if(!$res){
$error[] = ['id'=>$storeId];
break;
}
$bar->advance();
}
$bar->finish();
var_dump([time()-$startTime]);
var_dump($error);
return 0;
}
}