hemall.terabimsoft.com.cn/app/Jobs/memberParentOfMemberJob.php

<?php
/**
 * Created by PhpStorm.
 * User: dingran
 * Date: 2018/10/22
 * Time: 下午3:50
 */

namespace app\Jobs;


use app\backend\modules\member\models\Member;
use app\common\models\member\ChildrenOfMember;
use app\common\models\member\ParentOfMember;
use Illuminate\Bus\Queueable;
use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Queue\InteractsWithQueue;
use Illuminate\Queue\SerializesModels;

class memberParentOfMemberJob implements ShouldQueue
{
    use InteractsWithQueue, Queueable, SerializesModels;

    private $uniacid;
    private $member_info;
    public $memberModel;
    public $childMemberModel;
    public $pageSize;
    public $offset;

    public function __construct($uniacid, $pageSize, $offset)
    {
        $this->queue    = 'statistics';
        $this->uniacid  = $uniacid;
        $this->pageSize = $pageSize;
        $this->offset   = $offset;
    }

    public function handle()
    {
        \Log::debug('-----queue uniacid-----', $this->uniacid);

        return $this->synRun($this->uniacid);
    }

    /**
     * @param $uniacid
     */
    public function synRun($uniacid)
    {
        ini_set("memory_limit","-1");

        $parentMemberModle      = new ParentOfMember();
        $childMemberModel       = new ChildrenOfMember();
        $memberModel            = new Member();
        $memberModel->_allNodes = collect([]);

        $memberInfo = $memberModel->getTreeAllNodes($uniacid);

        if ($memberInfo->isEmpty()) {
            \Log::debug('----is empty-----');
            return;
        }

        foreach ($memberInfo as $item) {
            $memberModel->_allNodes->put($item->member_id, $item);
        }

        $this->member_info = Member::getAllMembersInfosByQueue($uniacid, $this->pageSize,
            $this->offset)->distinct()->get();
        \Log::debug('------queue member count-----', $this->member_info->count());

        if (!$this->member_info->isEmpty()) {
            \Log::debug('-----queue member empty-----');
        }

        \Log::debug('--------queue synRun -----');

        foreach ($this->member_info as $key => $val) {
            $attr       = [];
            $child_attr = [];

            \Log::debug('--------foreach start------', $val->member_id);
            $memberModel->filter = [];
            $data                = $memberModel->getNodeParents($uniacid, $val->member_id);

            if (!$data->isEmpty()) {
                \Log::debug('--------insert init------');

                foreach ($data as $k => $v) {
                    if ($k != $val->member_id) {
                        $attr[] = [
                            'uniacid'    => $uniacid,
                            'parent_id'  => $k,
                            'level'      => $v['depth'] + 1,
                            'member_id'  => $val->member_id,
                            'created_at' => time()
                        ];

                        $child_attr[] = [
                            'uniacid'    => $uniacid,
                            'child_id'   => $val->member_id,
                            'level'      => $v['depth'] + 1,
                            'member_id'  => $k,
                            'created_at' => time()
                        ];
                    } else {
                        file_put_contents(storage_path("logs/" . date('Y-m-d') . "_batchparent.log"),
                            print_r([$val->member_id, $v, 'insert'], 1), FILE_APPEND);
                    }
                }

                $parentMemberModle->createData($attr);
                $childMemberModel->createData($child_attr);
            }
        }
    }
}