七牛云图片迁移

末蓝、 2022-02-01 04:27 312阅读 0赞

最近公司更换了七牛云账号，需要做个图片素材的迁移，这里记录一下  
项目用的的ci框架  
第一步就是把sdk包放入libraries下，如图  
![在这里插入图片描述][20190513135738777.png]  
然后上代码

<?php
    
    // 更换七牛云账号进行图片迁移
    class AcceptReplace extends CI_Controller {
        
        /**
         *
         * 建日志表记录新旧链接
         *
         */
        public function recordChange() {
            $sql = <<<EOA
    CREATE TABLE if not exists `log_updateqiniuyun` (
      `id` int(11) NOT NULL AUTO_INCREMENT,
      `newurl` varchar(100) DEFAULT NULL,
      `oldurl` varchar(100) DEFAULT NULL,
      `status` tinyint(4) DEFAULT 0,
      `time` int(11) unsigned DEFAULT '0',
      PRIMARY KEY (`id`)
    ) ENGINE=InnoDB DEFAULT CHARSET=utf8;
    EOA;
            $db = $this->load->database('crm', true);
    
            $db->query($sql);
        }
    
        /**
         *
         * 下载七牛上的图片文件并存入指定文件
         *
         */
        public function getFile($url='', $save_dir='', $filename='') 
        {
            if (trim($url) == '') {
                return false;
            }
            //获取远程文件所采用的方法
            $ch = curl_init();
            $timeout = 10;
            curl_setopt($ch, CURLOPT_URL, $url);
            curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
            curl_setopt($ch, CURLOPT_TIMEOUT, 3);
            curl_setopt($ch, CURLOPT_CONNECTTIMEOUT, $timeout);
            $content = curl_exec($ch);
            curl_close($ch);
            
            if(!empty($content)) {
                file_put_contents($save_dir.$filename, $content);
            }
            return false;
        }
        /**
         *
         * 上传到新账户七牛云地址
         *
         */
        public function saveToNewQiniu($url) {
            // 配置
            $access_key = '****';  // 自行查看自己的key
            $secret_key = '****';  
            $bucket = '***'; // 存储空间名称
            $domain = '*****'; // 绑定域名 
            // 上传到七牛后保存的文件名
            $key = time().substr($url, strrpos($url, '.')-4);
            
            require_once APPPATH . 'libraries/autoload.php';
    
            $auth = new Qiniu\Auth($access_key, $secret_key);
            // 生成上传 Token
            $token = $auth->uploadToken($bucket);
            // $bucketManager = new Qiniu\Storage\BucketManager($auth);
            // 初始化 UploadManager 对象并进行文件的上传。
            $uploadMgr = new Qiniu\Storage\UploadManager();
            
            // 调用 UploadManager 的 putFile 方法进行文件的上传。
            list($ret, $err) = $uploadMgr->putFile($token, $key, $url);
    
            if ($err !== null) {
                return $err;
            } else {
                return $ret;
            }
            
        }
        
        public function upload()
        {
            $db = $this->load->database('crm', true);
            $this->recordChange();
            $oldDomain = 'adimg.shishihongbao.com'; // 旧的绑定域名
            $domain = 'adimage.shishihongbao.com'; // 新的绑定域名
            $sql = "SELECT `image_url` FROM `ad_material`";
            $imageUrl = $db->query($sql);
            $path=APPPATH ."cache/images";
            //目录不存在则创建
            if (!is_dir($path)){
                
                $res  = mkdir($path,0777,true);
            }
            $save_dir = APPPATH ."cache/images/";
    
            $status   = 1;
            
            foreach ($imageUrl->result_array() as $value) {
                if(!empty($value['image_url']) && strpos($value['image_url'], $oldDomain)){
                    $oldUrl    = $value['image_url'];
                    if(substr($oldUrl, strrpos($oldUrl, '.')) {
                        $filename  = substr($oldUrl, strrpos($oldUrl, '/')+1);
                    }else {
                        $filename  = substr($oldUrl, strrpos($oldUrl, '/')+1).'.png';
                    }
                    $save_path = $this->getFile($oldUrl, $save_dir, $filename);
                    // print_r($filename);die;
                    // 图片迁移失败记录
                    if(!$save_path) {
                        $status = 0;
                        $db->query("INSERT INTO `log_updateqiniuyun` VALUES (null,'','".$oldUrl."','" . $status."','" .$time." ')");
                    }else {
                        $newUrl    = $this->saveToNewQiniu($save_path['save_path']);
                        // print_r($newUrl);
                        $newUrl1   = 'http://'. $domain .'/'. $newUrl['key'];
                        // 图片迁移成功记录
                        if($newUrl1) {
                            $time  = time();
                            $db->trans_strict(FALSE);
                            $db->trans_start();
                            $db->query("INSERT INTO `log_updateqiniuyun` VALUES (null,'".$newUrl1."','".$oldUrl."','" . $status."','" .$time." ')");
                            // $db->query("UPDATE `ad_material` SET `image_url`=".$newUrl." WHERE `image_url`=".$oldUrl);
                            $db->trans_complete();
                        }
                    }
                    
                }
    
            }
            // 删除本地图片
            $this->removeDir($save_dir);
        }
    
        // 删除本地图片目录
        function removeDir($dirName) 
        { 
            if(! is_dir($dirName)) 
            { 
                return false; 
            } 
            $handle = @opendir($dirName); 
            while(($file = @readdir($handle)) !== false) 
            { 
                if($file != '.' && $file != '..') 
                { 
                    $dir = $dirName . '/' . $file; 
                    is_dir($dir) ? removeDir($dir) : @unlink($dir); 
                } 
            } 
            closedir($handle); 
              
            // rmdir($dirName) ; 
        } 
    
    }

第一次搞这个，有更好的方法可以留言一起讨论呀

[20190513135738777.png]: /images/20220201/0260afd7e3cb4514b48aef243da34aba.png