BatchController.php

<?php

namespace App\Http\Controllers;

use Illuminate\Http\Request;
use App\Http\Requests;
use DB;
use RedisDB;

class BatchController extends Controller
{
    public function Entrance(Request $request, $id ){
        //统一入口
        $this->$id($request, $id);
    }

    private function Export($errcode=0,$errmsg='成功',$data=''){
        echo json_encode(['errcode'=>$errcode,'errmsg'=>$errmsg,'data'=>$data]);
        exit();
    }

    //生成spu唯一识别信息
    private function create_spu_mongo()
    {
        set_time_limit(0);
        $starttime = explode(' ',microtime());
        echo microtime();

        $mongo=new \MongoClient(env('MONGO_HOST', ''));
        $mongodb=$mongo->ichunt->spu;


        $count=100;
        $db=DB::connection('spu');


        for($table=0;$table<10;$table++){
            for ($p=1;$p<$count+1;$p++){
                $data=[];
                $list=$db->table('lie_spu_'.$table)->select('spu_name','brand_id','spu_id')->paginate(1000,['*'],'',$p);
                foreach ($list as $k=>$v){
                    $data[]=[
                        'spu_id'=>$v->spu_id,
                        'spu_name'=>$v->spu_name,
                        'brand_id'=>$v->brand_id
                    ];
                }
                $result=$mongodb->batchInsert($data);
                $count=$list->lastPage();
            }
        }

        //程序运行时间
        $endtime = explode(' ',microtime());
        $thistime = $endtime[0]+$endtime[1]-($starttime[0]+$starttime[1]);
        $thistime = round($thistime,3);
        echo "本程序执行耗时：".$thistime." 秒。".time();

    }

    private function create_sku_mongo()
    {
        set_time_limit(0);
        $starttime = explode(' ',microtime());
        echo microtime();

        $mongo=new \MongoClient(env('MONGO_HOST', ''));
        $mongodb=$mongo->ichunt->sku;


        $count=100;

        for ($dbcode=0;$dbcode<10;$dbcode++){

            $db=DB::connection('sku_'.$dbcode);

            for($table=0;$table<10;$table++){
                for ($p=1;$p<$count+1;$p++){
                    $data=[];
                    $list=$db->table('lie_sku_'.$table)->select('goods_id','spu_id','moq','supplier_id')->paginate(10000,['*'],'',$p);
                    foreach ($list as $k=>$v){
                        $data[]=[
                            'goods_id'=>intval($v->goods_id),
                            'spu_id'  =>intval($v->spu_id),
                            'supplier_id'=>intval($v->supplier_id),
                            'moq'=>intval($v->moq)
                        ];
                    }
                    $mongodb->batchInsert($data);
                    $count=$list->lastPage();
                }
            }
        }


        //程序运行时间
        $endtime = explode(' ',microtime());
        $thistime = $endtime[0]+$endtime[1]-($starttime[0]+$starttime[1]);
        $thistime = round($thistime,3);
        echo "本程序执行耗时：".$thistime." 秒。".time();

    }

    private function create_spu_redis($request){

        set_time_limit(0);

        $redis=RedisDB::connection();
        $db=DB::connection('spu');
        $table=$request->input('table');
        $data=[];
        $list=$db->table('lie_spu_'.$table)
            ->select('spu_id','class_id1','class_id2','brand_id','class_id3','spu_name','status','images_l','images_s','encap','pdf','spu_brief','has_rohs','attrs','spu_detail','sale_time','create_time','update_time','remark','bussiness_area')
            ->paginate(1000);

        foreach ($list as $k=>$v){
            $info=(array)$v;
            $info['class_id']=0;

            if(!empty($info['class_id1'])){
                $info['class_id']=$info['class_id1'];
            }
            if(!empty($info['class_id2'])){
                $info['class_id']=$info['class_id2'];
            }
            if(!empty($info['class_id3'])){
                $info['class_id']=$info['class_id3'];
            }

            $info['class_name']=$redis->hget('class',$info['class_id']);


            $info['brand_name']=$redis->hget('brand',$info['brand_id']);


            switch ($info['status']){
                case 0:
                    $info['status_name']='审核中';
                    break;
                case 1:
                    $info['status_name']='上架';
                    break;
                case 2:
                    $info['status_name']='审核不通过';
                    break;
                case 3:
                    $info['status_name']='下架';
                    break;
                default :
                    $info['status_name']='未知';
            }

            $info['create_time_s']=date('Y-m-d H:i',$info['create_time']);

            $data[$v->spu_id]=json_encode($info);
        }
        $result=$redis->hmset('spu',$data);
        $objdata['count']=$list->count();
        $objdata['last_page']=$list->lastPage();

        if($result=='OK'){
            $this->Export(0,'',$objdata);
        }else{
            $this->Export(20001,'写入Redis出错');
        }
    }

    //生成spu唯一识别信息
    private function spu_redis()
    {
        echo 'kkk';die;
        set_time_limit(0);
        $starttime = explode(' ',microtime());
        echo microtime();

        $redis=RedisDB::connection();


        $count=100;
        $db=DB::connection('spu');


        for($table=0;$table<10;$table++){
            for ($p=1;$p<$count+1;$p++){
                $data=[];
                $list=$db->table('lie_spu_'.$table)
                    ->select('spu_id','class_id1','class_id2','brand_id','class_id3','spu_name','status','images_l','images_s','encap','pdf','spu_brief','has_rohs','attrs','spu_detail','sale_time','create_time','update_time','remark','bussiness_area')
                    ->paginate(1000,['*'],'',$p);
                foreach ($list as $k=>$v){
                    $v=(array)$v;
                    $data[$v['spu_id']]=json_encode($v);
                }
                $result=$redis->hmset('spu',$data);
                $count=$list->lastPage();
            }
        }

        //程序运行时间
        $endtime = explode(' ',microtime());
        $thistime = $endtime[0]+$endtime[1]-($starttime[0]+$starttime[1]);
        $thistime = round($thistime,3);
        echo "本程序执行耗时：".$thistime." 秒。".time();

    }

    private function sku_redis(){
        
    }
}