PHP批量保存图片到服务器再上传阿里云 - 陈达辉

/*
     * 批量传输产品主图到阿里云
     */
    public function transferImage(){
        
        $num = 50;
        $p = isset($this->request->get[\'p\'])?$this->request->get[\'p\']:0;
        $nonum = isset($this->request->get[\'nonum\'])?$this->request->get[\'nonum\']:0;
        $start = ($nonum>0)?$nonum:$p*$num;
        
        $query = $this->db->query("SELECT product_id,image,site_id FROM " . DB_PREFIX . "product WHERE is_delete = 0 AND site_id=\'2170254929593344\' AND image LIKE \'%.alicdn.com%\' LIMIT ".$start.",".$num);
        $result = $query->rows;
        
        //图片处理
        if(!empty($result)){

            $aliYunOSS = new AliYunOSS();

            foreach ($result as $key => $value){
                    
                $file = $value[\'image\'];
                
                //保存图片到服务器上
                $data = @file_get_contents($file);
                if(!empty($data)){
                    $ext = pathinfo($file, PATHINFO_EXTENSION);
                    $filename = $value[\'product_id\'].rand(). \'.\' . $ext;
                    $rootFile = DIR_UPLOAD .\'file/\'. $filename;
                    file_put_contents($rootFile, $data);
                     
                    //上传图片到阿里云
                    $fileDir = date(\'Y\', time()) . \'/\' . date(\'m\', time());
                    $ali = $aliYunOSS->uploadFile($rootFile, $value[\'site_id\'].\'/\'.$fileDir.\'/\'.$filename);
                    
                    if($ali[\'success\']==1 && !empty($ali[\'info\'][\'url\'])){
                        $image = $ali[\'info\'][\'url\'];
                        
                        if (ENVIRONMENT == \'pro\') {
                            $image = str_replace(\'http://joinf-website-release.oss-cn-hongkong.aliyuncs.com\', OSS_URL, $image);
                            $image = str_replace(\'https://joinf-website-release.oss-cn-hongkong.aliyuncs.com\', OSS_URL, $image);
                        }
                        
                        $sql = "UPDATE " . DB_PREFIX . "product SET image=\'".$image."\' WHERE product_id=\'".$value[\'product_id\']."\' AND image=\'".$value[\'image\']."\'";
                        $this->db->query($sql);
                        
                        //删除服务器文件
                        unlink($rootFile);
                    }
                }else{
                    $nonum++;
                }
            }
            
            $url = $this->url->createUrl(\'test/transferImage\',\'p=\'.($p+1).\'&nonum=\'.$nonum.\'&rand=\'.rand(1000, 9999));
            echo "<script>window.location.href=\'".$url."\'</script>";
            
        }else{
            echo \'处理完成\';
        }
        
    }