lianjie_admin/app/Console/Commands/MigrateStoreBalance.php

<?php

namespace App\Console\Commands;

use Illuminate\Console\Command;
use Illuminate\Support\Facades\DB;
use Illuminate\Support\Facades\Schema;

class MigrateStoreBalance extends Command
{
    /**
     * The name and signature of the console command.
     *
     * @var string
     */
    protected $signature = 'migrateData:storeBalance';

    /**
     * The console command description.
     *
     * @var string
     */
    protected $description = 'Command 迁移商户余额数据到lanzu_user_balance表';

    /**
     * Create a new command instance.
     *
     * @return void
     */
    public function __construct()
    {
        parent::__construct();
    }

    public function getBalanceById($id)
    {
        $oldStoreTableName = 'ims_cjdc_store';
        $oldStoreSetTableName = 'ims_cjdc_storeset';
        $oldStoreTypeTableName = 'ims_cjdc_storetype';
        $oldOrderTableName = 'ims_cjdc_order';
        $oldWithdrawalTableName = 'ims_cjdc_withdrawal';

        // 查询店铺
        $stores = DB::table($oldStoreTableName)->select('id','md_type','ps_poundage','award_money')->where('id',$id)->get();

        if(count($stores) <= 0){
            var_dump('店铺不存在');
            return ;
        }

        //店铺设置
        $storeSets = DB::table($oldStoreSetTableName)
                ->select('id','store_id','is_poundage','poundage','dn_poundage','dm_poundage','yd_poundage')
                ->where('store_id',$id)->first();

        // 所有分类
        $storeTypes = DB::table($oldStoreTypeTableName)->get()->toArray();
        $storeTypeArr = array_column($storeTypes,null,'id');

        foreach($stores as $key => $value){
            $storeId = $value->id;

            // 获取商家手续费 % 如果商家设置有自己的手续费则用商家的
            if(!empty($storeSets) && $storeSets->is_poundage == 1){
                $poundage = $storeSets;
            }else{
                $poundage = $storeTypeArr[$value->md_type];
            }
            
            // 商家订单金额
            // 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,'.','');

        }
        
        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 ;
    }

    /**
     * 根据订单进行计算
     */
    public function countStore($oldAccountTableName)
    {
        $oldData = DB::table($oldAccountTableName)->orderBy('id','asc')->get();
        $newData = [];
        foreach ($oldData as $key => $value){
            $storeId = $value->store_id;
            if(array_key_exists($storeId,$newData)){
                if($value->type == 2){
                    $newData[$storeId] -= $value->money;
                }else if($value->type == 1){
                    $newData[$storeId] += $value->money;
                }
            }else{
                $newData[$storeId] = $value->money;
            }
        }
        return $newData;
    }

    /**
     * 根据订单进行计算
     */
    public function countOrder()
    {
        $oldStoreTableName = 'ims_cjdc_store';
        $oldStoreSetTableName = 'ims_cjdc_storeset';
        $oldStoreTypeTableName = 'ims_cjdc_storetype';
        $oldOrderTableName = 'ims_cjdc_order';
        $oldWithdrawalTableName = 'ims_cjdc_withdrawal';

        $newData = [];
        // 查询所有店铺
        $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();
        $storeSetArr = array_column($storeSets,null,'store_id');

        // 所有商家分类
        $storeTypes = DB::table($oldStoreTypeTableName)->get()->toArray();
        $storeTypeArr = array_column($storeTypes,null,'id');

        foreach($stores as $key => $value){
            $storeId = $value->id;

            // 获取商家手续费 % 如果商家设置有自己的手续费则用商家的
            if(isset($storeSetArr[$storeId]) && $storeSetArr[$storeId]->is_poundage == 1){
                $poundage = $storeSetArr[$storeId];
            }else{
                $poundage = $storeTypeArr[$value->md_type];
            }

            // 商家订单金额
            // 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] = $balance;
        }
        
        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;
    }
}