hemall.terabimsoft.com.cn/app/console/Commands/MigrateHFLevelExcelData.php

<?php
/****************************************************************
 * Author:  king -- LiBaoJia
 * Date:    2020/4/1 4:59 PM
 * Email:   livsyitian@163.com
 * QQ:      995265288
 * IDE:     PhpStorm
 * User:    芸众商城 www.yunzshop.com
 ****************************************************************/
namespace app\Console\Commands;

use app\common\models\MemberShopInfo;
use Illuminate\Console\Command;
use Maatwebsite\Excel\Readers\LaravelExcelReader;
use Yunshop\Haifen\common\model\hfMember;
use Yunshop\Haifen\common\model\levelModel;
use Yunshop\Commission\models\Agents;
use Yunshop\TeamDividend\admin\models\TeamDividendAgencyModel;

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

    /**
     * The console command description.
     *
     * @var string
     */
    protected $description = '迁移会员levelExcel数据';

    protected $uniacid = 3;

    /**
     * Execution entrance
     */
    public function handle()
    {

        if (!app('plugins')->isEnabled('haifen')) {
            file_put_contents(base_path('migrate_hf_level_exception_excel.txt'), "haifen插件未开启" . PHP_EOL, FILE_APPEND);
            return ;
        }

        \YunShop::app()->uniacid = 3;

        $filePath = storage_path('hf_member_level.xlsx');

        $fileContent = \Excel::load($filePath);


        /**
         * @see LaravelExcelReader
         *
         * @var \PHPExcel $fileContent
         */

        $sheet = $fileContent->getActiveSheet();
        /**
         * @var \PHPExcel_Worksheet $sheet
         */
        $highestRow = $sheet->getHighestDataRow();
        $highestColumn = $sheet->getHighestDataColumn();
        $highestColumnCount = \PHPExcel_Cell::columnIndexFromString($highestColumn);

        $row = 2;
        $values = [];
        while ($row <= $highestRow) {
            $col = 0;
            $rowValue = [];
            while ($col < $highestColumnCount) {
                $rowValue[] = (string)$sheet->getCellByColumnAndRow($col, $row)->getValue();
                ++$col;
            }
            $values[] = $rowValue;
            ++$row;
        }

        //dd($values);
        $count = count($values);
        //dd($count);
        $barOne = $this->output->createProgressBar($count);
        foreach ($values as $value) {
            $this->updateMemberLevel($value);
            $barOne->advance();
        }
        $barOne->finish();

        $this->info('Update Member Level Comment');
        $this->comment('Excel data migration completed!');
    }

    public function updateMemberLevel($value)
    {
        //根据mobile查询会员信息
        $user = hfMember::uniacid()->whereHas("hasOneMCMember",function($query) use ($value){
            $query->where("mobile",$value[0]);
        })->first();

        $user = empty($user) ? [] : $user->toArray();

        if (empty($user)) {
            file_put_contents(base_path('migrate_hf_level_exception_excel.txt'), "手机号:".$value[0]."对应的会员不存在" . PHP_EOL, FILE_APPEND);
            return ;
        }

        $this->docking($user['yz_uid'],$value[1],$value[0]);
    }

    public function docking($uid,$level,$mobile)
    {
        $search['level'] = $level;
        $search['status'] = 1;
        $levelModel = levelModel::getSearch($search)->first();
        $levelModel = empty($levelModel) ? [] : $levelModel->toArray();

        if (empty($levelModel)) {
            //throw new ShopException('对应等级未设置');
            file_put_contents(base_path('migrate_hf_level_exception_excel.txt'), "手机号:".$mobile."后台对应的等级不存在" . PHP_EOL, FILE_APPEND);
            return  ;
        }

        if (empty($levelModel['has_one_member_level'])) {
            //throw new ShopException('对应等级设置中的会员等级不存在');
            file_put_contents(base_path('migrate_hf_level_exception_excel.txt'), "手机号:".$mobile."后台对应等级设置中的会员等级不存在" . PHP_EOL, FILE_APPEND);
            return  ;
        }

        //修改会员等级
        $member = MemberShopInfo::uniacid()->where("member_id",$uid)->first();

        if (empty($member)) {
            //throw new ShopException('会员不存在');
            file_put_contents(base_path('migrate_hf_level_exception_excel.txt'), "手机号:".$mobile."会员不存在" . PHP_EOL, FILE_APPEND);
            return  ;
        }

        $member->level_id = $levelModel['member_level_id'];

        if (!$member->save()) {
            //throw new ShopException('更新对应的会员等级失败');
            file_put_contents(base_path('migrate_hf_level_exception_excel.txt'), "手机号:".$mobile."更新对应的会员等级失败" . PHP_EOL, FILE_APPEND);
            return  ;
        }

        //修改分销商等级
        $this->agentLevelUpdate($uid,$member,$mobile,$levelModel);

        //修改经销商等级
        $this->teamDividendLevelUpdate($uid,$member,$mobile,$levelModel);

    }

    public function agentLevelUpdate($uid,$member,$mobile,$levelModel)
    {
        if (app('plugins')->isEnabled('commission')) {

            if (empty($levelModel['has_one_agent_level'])) {
                file_put_contents(base_path('migrate_hf_level_exception_excel.txt'), "手机号:".$mobile."对应等级设置中的分销商等级不存在" . PHP_EOL, FILE_APPEND);
                return  ;
            }

            $agent = Agents::getAgentByMemberId($uid)->first();

            if (empty($agent)) {
                $agentData = [
                    'uniacid' => \YunShop::app()->uniacid,
                    'member_id' => $uid,
                    'parent_id' => $member->parent_id,
                    'parent' => $member->relation,
                    'agent_level_id' => $levelModel['agent_level_id'],
                    'created_at' => time(),
                    'updated_at' => time(),
                ];

                \Log::info('分销商数据：', $agentData);
                Agents::insert($agentData);
            } else {
                if ($agent->agent_level_id != $levelModel['agent_level_id']) {
                    $agentModel = Agents::getAgentByMemberId($uid)->first();
                    $agentModel->agent_level_id = $levelModel['agent_level_id'];
                    if (!$agentModel->save()) {
                        file_put_contents(base_path('migrate_hf_level_exception_excel.txt'), "手机号:".$mobile."编辑对应的分销商等级失败" . PHP_EOL, FILE_APPEND);
                        return  ;
                    }
                }
            }
        }
    }

    public function teamDividendLevelUpdate($uid,$member,$mobile,$levelModel)
    {

        if (app('plugins')->isEnabled('team-dividend')) {

            if (empty($levelModel['has_one_team_dividend_level'])) {
                file_put_contents(base_path('migrate_hf_level_exception_excel.txt'), "手机号:" . $mobile . "对应等级设置中的经销商等级不存在" . PHP_EOL, FILE_APPEND);
                return;
            }

            $dividend = TeamDividendAgencyModel::getAgencyByMemberId($uid)->first();

            if (empty($dividend)) {
                $agency_model = new TeamDividendAgencyModel();
                $agency_model->uniacid = \YunShop::app()->uniacid;
                $agency_model->uid = $uid;
                $agency_model->level = $levelModel['team_dividend_level_id'];
                $agency_model->parent_id = $member['parent_id'];
                $agency_model->relation = $member['relation'];

                if (!$agency_model->save()){
                    file_put_contents(base_path('migrate_hf_level_exception_excel.txt'), "手机号:" . $mobile . "添加对应的经销商等级失败" . PHP_EOL, FILE_APPEND);
                    return;
                }
            } else {
                $dividend_member = TeamDividendAgencyModel::getAgencyInfoByUid($uid);
                $dividend_member->level = $levelModel['team_dividend_level_id'];
                if (!$dividend_member->save()) {
                    //throw new ShopException('更新对应的经销商等级失败');
                    file_put_contents(base_path('migrate_hf_level_exception_excel.txt'), "手机号:" . $mobile . "更新对应的经销商等级失败" . PHP_EOL, FILE_APPEND);
                    return;
                }
            }
        }
    }


}