|
|
@ -32,72 +32,157 @@ class MigrateStoreBalance extends Command |
|
|
parent::__construct(); |
|
|
parent::__construct(); |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
/** |
|
|
|
|
|
* Execute the console command. |
|
|
|
|
|
* |
|
|
|
|
|
* @return int |
|
|
|
|
|
*/ |
|
|
|
|
|
public function handle() |
|
|
|
|
|
|
|
|
public function getBalanceById($id) |
|
|
{ |
|
|
{ |
|
|
$oldAccountTableName = 'ims_cjdc_store_account'; |
|
|
|
|
|
|
|
|
$oldStoreTableName = 'ims_cjdc_store'; |
|
|
|
|
|
$oldStoreSetTableName = 'ims_cjdc_storeset'; |
|
|
|
|
|
$oldStoreTypeTableName = 'ims_cjdc_storetype'; |
|
|
|
|
|
$oldOrderTableName = 'ims_cjdc_order'; |
|
|
|
|
|
$oldWithdrawalTableName = 'ims_cjdc_withdrawal'; |
|
|
|
|
|
|
|
|
$newBalanceTableName = 'lanzu_user_balance'; |
|
|
|
|
|
|
|
|
// 查询店铺
|
|
|
|
|
|
$stores = DB::table($oldStoreTableName)->select('id','md_type','ps_poundage','award_money')->where('id',$id)->get(); |
|
|
|
|
|
|
|
|
// 判断表是否存在
|
|
|
|
|
|
if(!Schema::hasTable($oldAccountTableName)){ |
|
|
|
|
|
var_dump('旧表不存在'); |
|
|
|
|
|
return 0; |
|
|
|
|
|
} |
|
|
|
|
|
if(!Schema::hasTable($newBalanceTableName)){ |
|
|
|
|
|
var_dump('新表不存在'); |
|
|
|
|
|
return 0; |
|
|
|
|
|
|
|
|
if(count($stores) <= 0){ |
|
|
|
|
|
var_dump('店铺不存在'); |
|
|
|
|
|
return ; |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
// 流水算法
|
|
|
|
|
|
$newData = $this->countStore($oldAccountTableName); |
|
|
|
|
|
// 订单算法
|
|
|
|
|
|
// $newData = $this->countOrder();
|
|
|
|
|
|
|
|
|
//店铺设置
|
|
|
|
|
|
$storeSets = DB::table($oldStoreSetTableName) |
|
|
|
|
|
->select('id','store_id','is_poundage','poundage','dn_poundage','dm_poundage','yd_poundage') |
|
|
|
|
|
->where('store_id',$id)->first(); |
|
|
|
|
|
|
|
|
// var_dump($newData);
|
|
|
|
|
|
// var_dump(count($newData));
|
|
|
|
|
|
// return 0;
|
|
|
|
|
|
|
|
|
// 所有分类
|
|
|
|
|
|
$storeTypes = DB::table($oldStoreTypeTableName)->get()->toArray(); |
|
|
|
|
|
$storeTypeArr = array_column($storeTypes,null,'id'); |
|
|
|
|
|
|
|
|
$bar = $this->output->createProgressBar(count($newData)); |
|
|
|
|
|
$bar->start(); |
|
|
|
|
|
$startTime = time(); |
|
|
|
|
|
$error = []; |
|
|
|
|
|
|
|
|
foreach($stores as $key => $value){ |
|
|
|
|
|
$storeId = $value->id; |
|
|
|
|
|
|
|
|
foreach($newData as $store_id => $money){ |
|
|
|
|
|
$exist = DB::table($newBalanceTableName)->where('source_id',$store_id)->where('user_type',5)->exists(); |
|
|
|
|
|
if($exist){ |
|
|
|
|
|
$error[] = ['store_id'=>$store_id,'money'=>$money,'msg'=>'已存在']; |
|
|
|
|
|
// $saveData = [
|
|
|
|
|
|
// 'balance' => number_format($money,2,'.',''),
|
|
|
|
|
|
// 'updated_at' => time()
|
|
|
|
|
|
// ];
|
|
|
|
|
|
// $res = DB::table($newBalanceTableName)->where('source_id',$store_id)->where('user_type',5)->increment('balance',$saveData['balance']);
|
|
|
|
|
|
// if(!$res){
|
|
|
|
|
|
// $error[] = ['store_id'=>$store_id,'money'=>$money];
|
|
|
|
|
|
// }
|
|
|
|
|
|
|
|
|
// 获取商家手续费 % 如果商家设置有自己的手续费则用商家的
|
|
|
|
|
|
if(!empty($storeSets) && $storeSets->is_poundage == 1){ |
|
|
|
|
|
$poundage = $storeSets; |
|
|
}else{ |
|
|
}else{ |
|
|
$saveData = [ |
|
|
|
|
|
'source_id' => $store_id, |
|
|
|
|
|
'user_type' => 5, |
|
|
|
|
|
'balance' => number_format($money,2,'.',''), |
|
|
|
|
|
'updated_at' => time() |
|
|
|
|
|
]; |
|
|
|
|
|
$res = DB::table($newBalanceTableName)->insert($saveData); |
|
|
|
|
|
if(!$res){ |
|
|
|
|
|
$error[] = ['store_id'=>$store_id,'money'=>$money]; |
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
$poundage = $storeTypeArr[$value->md_type]; |
|
|
} |
|
|
} |
|
|
$bar->advance(); |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
// 商家订单金额
|
|
|
|
|
|
// type '1.外卖2.店内3.预定4.当面付',
|
|
|
|
|
|
// pay_type '1.微信支付2.余额支付3.积分支付4.货到付款',
|
|
|
|
|
|
// state '1.待付款2.待结单3.等待送达4.完成5.已评价6.取消7.拒绝8.退款中9.已退款10.退款拒绝',
|
|
|
|
|
|
|
|
|
|
|
|
// 外卖
|
|
|
|
|
|
$wmOrder = DB::table($oldOrderTableName) |
|
|
|
|
|
->select(DB::raw('sum(money) as total_money'),DB::raw('sum(ps_money) as ps_money'),DB::raw('sum(yhq_money2) as hb_money')) |
|
|
|
|
|
->where('store_id',$storeId) |
|
|
|
|
|
->where('type',1) |
|
|
|
|
|
->whereIn('state',[4,5,10]) |
|
|
|
|
|
->whereIn('pay_type',[1,2]) |
|
|
|
|
|
->first(); |
|
|
|
|
|
|
|
|
|
|
|
// 店内
|
|
|
|
|
|
$dnOrder = DB::table($oldOrderTableName) |
|
|
|
|
|
->select(DB::raw('sum(money) as total_money'),DB::raw('sum(yhq_money2) as hb_money')) |
|
|
|
|
|
->where('store_id',$storeId) |
|
|
|
|
|
->where('type',2) |
|
|
|
|
|
->where('dn_state',2) |
|
|
|
|
|
->whereIn('pay_type',[1,2]) |
|
|
|
|
|
->first(); |
|
|
|
|
|
// 当面
|
|
|
|
|
|
$dmOrder = DB::table($oldOrderTableName) |
|
|
|
|
|
->select(DB::raw('sum(money) as total_money')) |
|
|
|
|
|
->where('store_id',$storeId) |
|
|
|
|
|
->where('type',4) |
|
|
|
|
|
->where('dm_state',2) |
|
|
|
|
|
->whereIn('pay_type',[1,2]) |
|
|
|
|
|
->first(); |
|
|
|
|
|
// 预约
|
|
|
|
|
|
$yyOrder = DB::table($oldOrderTableName) |
|
|
|
|
|
->select(DB::raw('sum(money) as total_money')) |
|
|
|
|
|
->where('store_id',$storeId) |
|
|
|
|
|
->where('type',3) |
|
|
|
|
|
->where('yy_state',3) |
|
|
|
|
|
->whereIn('pay_type',[1,2]) |
|
|
|
|
|
->first(); |
|
|
|
|
|
// 提现
|
|
|
|
|
|
$txTotal = DB::table($oldWithdrawalTableName) |
|
|
|
|
|
->select(DB::raw('sum(tx_cost) as total')) |
|
|
|
|
|
->where('store_id',$storeId) |
|
|
|
|
|
->whereIn('state',[1,2]) |
|
|
|
|
|
->first(); |
|
|
|
|
|
|
|
|
|
|
|
// 商家奖励
|
|
|
|
|
|
$awardTotal = empty($value->award_money) ? 0 : $value->award_money; |
|
|
|
|
|
|
|
|
|
|
|
// 商户配送手续费
|
|
|
|
|
|
$psMoney = number_format(floatval($wmOrder->ps_money)*floatval($value->ps_poundage)/100,2,'.',''); |
|
|
|
|
|
|
|
|
|
|
|
// 不计算拼团和抢购的订单，目前没有这样的订单，在另外的订单表
|
|
|
|
|
|
|
|
|
|
|
|
// 计算 金额 = 奖励 + 订单(外卖+店内+当面+预约) - 手续费 - 提现 - 配送费
|
|
|
|
|
|
$balance = $awardTotal |
|
|
|
|
|
+ ($wmOrder->total_money + $wmOrder->hb_money + $dnOrder->total_money + $dnOrder->hb_money + $dmOrder->total_money + $yyOrder->total_money ) |
|
|
|
|
|
- (( |
|
|
|
|
|
($wmOrder->total_money + $wmOrder->ps_money + $wmOrder->hb_money) * floatval($poundage->poundage) |
|
|
|
|
|
+ ($dnOrder->total_money + $dnOrder->hb_money ) * floatval($poundage->dn_poundage) |
|
|
|
|
|
+ $dmOrder->total_money * floatval($poundage->dm_poundage) |
|
|
|
|
|
+ $yyOrder->total_money * floatval($poundage->yd_poundage) |
|
|
|
|
|
)/100) |
|
|
|
|
|
- $txTotal->total |
|
|
|
|
|
- $psMoney; |
|
|
|
|
|
|
|
|
|
|
|
// $newData[$storeId] = number_format($balance,2,'.','');
|
|
|
|
|
|
|
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
$bar->finish(); |
|
|
|
|
|
var_dump([time()-$startTime]); |
|
|
|
|
|
var_dump($error); |
|
|
|
|
|
return 0; |
|
|
|
|
|
|
|
|
return number_format($balance,2,'.',''); |
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
/** |
|
|
|
|
|
* Execute the console command. |
|
|
|
|
|
* 单个店铺处理 |
|
|
|
|
|
* @return int |
|
|
|
|
|
*/ |
|
|
|
|
|
public function handle() |
|
|
|
|
|
{ |
|
|
|
|
|
$oldStoreTableName = 'ims_cjdc_store'; |
|
|
|
|
|
$newBalanceTableName = 'lanzu_user_balance'; |
|
|
|
|
|
|
|
|
|
|
|
$store_id = 2 ; // 店铺id
|
|
|
|
|
|
$balance = $this->getBalanceById($store_id); |
|
|
|
|
|
|
|
|
|
|
|
// var_dump(number_format($balance,2,'.',''));
|
|
|
|
|
|
// return ;
|
|
|
|
|
|
$res = 1; |
|
|
|
|
|
$userId = 0;// 店铺的提现用户id
|
|
|
|
|
|
$storeInfo = DB::table($oldStoreTableName)->select('user_id')->find($store_id); |
|
|
|
|
|
if(empty($storeInfo) || empty($storeInfo->user_id)){ |
|
|
|
|
|
$res = ['store_id'=>$store_id,'balance'=>$balance,'msg'=>'店铺的用户不存在']; |
|
|
|
|
|
var_dump($res); |
|
|
|
|
|
return ; |
|
|
|
|
|
} |
|
|
|
|
|
$userId = $storeInfo->user_id; |
|
|
|
|
|
|
|
|
|
|
|
$exist = DB::table($newBalanceTableName)->where('source_id',$userId)->where('user_type',5)->exists(); |
|
|
|
|
|
if($exist){ |
|
|
|
|
|
$res = ['store_id'=>$store_id,'balance'=>$balance,'msg'=>'已存在']; |
|
|
|
|
|
}else{ |
|
|
|
|
|
$saveData = [ |
|
|
|
|
|
'source_id' => $userId, |
|
|
|
|
|
'user_type' => 5, |
|
|
|
|
|
'balance' => $balance, |
|
|
|
|
|
'created_at' => time(), |
|
|
|
|
|
'updated_at' => time() |
|
|
|
|
|
]; |
|
|
|
|
|
// var_dump($saveData);
|
|
|
|
|
|
$res = DB::table($newBalanceTableName)->insert($saveData); |
|
|
|
|
|
if(!$res){ |
|
|
|
|
|
$res = ['store_id'=>$store_id,'user_id'=>$userId,'balance'=>$balance,'msg'=>'添加失败']; |
|
|
|
|
|
} |
|
|
|
|
|
}; |
|
|
|
|
|
var_dump($res); |
|
|
|
|
|
return ; |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
/** |
|
|
/** |
|
|
@ -135,7 +220,7 @@ class MigrateStoreBalance extends Command |
|
|
|
|
|
|
|
|
$newData = []; |
|
|
$newData = []; |
|
|
// 查询所有店铺
|
|
|
// 查询所有店铺
|
|
|
$stores = DB::table($oldStoreTableName)->select('id','md_type','ps_poundage','award_money')->get(); |
|
|
|
|
|
|
|
|
$stores = DB::table($oldStoreTableName)->select('id','md_type','ps_poundage','award_money')->where('id',)->get(); |
|
|
|
|
|
|
|
|
//店铺设置
|
|
|
//店铺设置
|
|
|
$storeSets = DB::table($oldStoreSetTableName)->select('id','store_id','is_poundage','poundage','dn_poundage','dm_poundage','yd_poundage')->get()->toArray(); |
|
|
$storeSets = DB::table($oldStoreSetTableName)->select('id','store_id','is_poundage','poundage','dn_poundage','dm_poundage','yd_poundage')->get()->toArray(); |
|
|
@ -225,4 +310,73 @@ class MigrateStoreBalance extends Command |
|
|
|
|
|
|
|
|
return $newData; |
|
|
return $newData; |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
/** |
|
|
|
|
|
* 旧的处理方式 |
|
|
|
|
|
*/ |
|
|
|
|
|
public function old() |
|
|
|
|
|
{ |
|
|
|
|
|
$oldAccountTableName = 'ims_cjdc_store_account'; |
|
|
|
|
|
$newBalanceTableName = 'lanzu_user_balance'; |
|
|
|
|
|
|
|
|
|
|
|
// 判断表是否存在
|
|
|
|
|
|
if(!Schema::hasTable($oldAccountTableName)){ |
|
|
|
|
|
var_dump('旧表不存在'); |
|
|
|
|
|
return 0; |
|
|
|
|
|
} |
|
|
|
|
|
if(!Schema::hasTable($newBalanceTableName)){ |
|
|
|
|
|
var_dump('新表不存在'); |
|
|
|
|
|
return 0; |
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
// 流水算法
|
|
|
|
|
|
$newData = $this->countStore($oldAccountTableName); |
|
|
|
|
|
// 订单算法
|
|
|
|
|
|
// $newData = $this->countOrder();
|
|
|
|
|
|
|
|
|
|
|
|
var_dump($newData); |
|
|
|
|
|
var_dump(count($newData)); |
|
|
|
|
|
return 0; |
|
|
|
|
|
$storeList = DB::table($newBalanceTableName)->pluck('user_id','id'); |
|
|
|
|
|
$bar = $this->output->createProgressBar(count($newData)); |
|
|
|
|
|
$bar->start(); |
|
|
|
|
|
$startTime = time(); |
|
|
|
|
|
$error = []; |
|
|
|
|
|
|
|
|
|
|
|
foreach($newData as $store_id => $money){ |
|
|
|
|
|
$userId = 0; |
|
|
|
|
|
if(!isset($storeList[$store_id])){ |
|
|
|
|
|
$error[] = ['store_id'=>$store_id,'money'=>$money,'msg'=>'店铺的用户不存在']; |
|
|
|
|
|
} |
|
|
|
|
|
$exist = DB::table($newBalanceTableName)->where('source_id',$userId)->where('user_type',5)->exists(); |
|
|
|
|
|
if($exist){ |
|
|
|
|
|
$error[] = ['store_id'=>$store_id,'money'=>$money,'msg'=>'已存在']; |
|
|
|
|
|
// $saveData = [
|
|
|
|
|
|
// 'balance' => number_format($money,2,'.',''),
|
|
|
|
|
|
// 'updated_at' => time()
|
|
|
|
|
|
// ];
|
|
|
|
|
|
// $res = DB::table($newBalanceTableName)->where('source_id',$store_id)->where('user_type',5)->increment('balance',$saveData['balance']);
|
|
|
|
|
|
// if(!$res){
|
|
|
|
|
|
// $error[] = ['store_id'=>$store_id,'money'=>$money];
|
|
|
|
|
|
// }
|
|
|
|
|
|
}else{ |
|
|
|
|
|
$saveData = [ |
|
|
|
|
|
'source_id' => $userId, |
|
|
|
|
|
'user_type' => 5, |
|
|
|
|
|
'balance' => number_format($money,2,'.',''), |
|
|
|
|
|
'updated_at' => time() |
|
|
|
|
|
]; |
|
|
|
|
|
// $res = DB::table($newBalanceTableName)->insert($saveData);
|
|
|
|
|
|
// if(!$res){
|
|
|
|
|
|
// $error[] = ['store_id'=>$store_id,'money'=>$money];
|
|
|
|
|
|
// }
|
|
|
|
|
|
} |
|
|
|
|
|
$bar->advance(); |
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
$bar->finish(); |
|
|
|
|
|
var_dump([time()-$startTime]); |
|
|
|
|
|
var_dump($error); |
|
|
|
|
|
return 0; |
|
|
|
|
|
} |
|
|
} |
|
|
} |
liangyuyan
5 years ago