yii框架，掃描目錄下文件入數(shù)據(jù)庫

BicycleWarrior 發(fā)布于2019-07-01 10:02 / 2224人閱讀

摘要：需求帶框架下寫一個(gè)定時(shí)任務(wù)，掃描某一目錄下的文件，并導(dǎo)入指定的數(shù)據(jù)庫中實(shí)現(xiàn)把需要入庫的文件放在指定目錄下執(zhí)行定時(shí)任務(wù)導(dǎo)入到庫中定時(shí)任務(wù)代碼導(dǎo)入庫到測試環(huán)境掃描的目錄入庫的數(shù)據(jù)庫對(duì)象分析用戶回答的信息并按格式入庫讀取目錄下文件

需求：

帶yii框架下寫一個(gè)定時(shí)任務(wù)，掃描某一目錄$target下的json文件，并導(dǎo)入指定的數(shù)據(jù)庫中

實(shí)現(xiàn)：

1.把需要入庫的json文件放在指定目錄$target下
2.執(zhí)行定時(shí)任務(wù),導(dǎo)入到mongo庫Vote_teacher中

/opt/modules/php/bin/php /www/web/protected/yiic.php import VoteTeacher

3.定時(shí)任務(wù)代碼：
/web/protected/commandsImportCommand.php

 /tmp/abc1.txt
 */
class ImportCommand extends CConsoleCommand 
{

    public $target="/www/web/html/import/";     //掃描的目錄

    public $model;    //入庫的數(shù)據(jù)庫對(duì)象

    public function run($args) {

        if (isset($args[0])) {
            $this->showMessage("params error", 1);
            exit;
        }
        $this->model = $args[0];
        $this->import();
    }

    /**
     * 分析用戶回答的信息并按格式入庫vote_answer
     * @author      lizhihui
      * @date        2018-4-9
     */
    private function import() 
    {
        $files = scandir($this->target);
        //讀取目錄下文件
        foreach ($files as $key => $val) {
            $val = pathinfo($val);
            $extension = $val["extension"];
            //過濾掉非json格式
            if($extension!="json"){
                continue;
            }

            $filePath=$this->target.$val["basename"];
            $fp=fopen($filePath,"r");
            $content="";
            while (!feof($fp)){
                $content.=fread($fp, filesize($filePath)/10);//每次讀出文件10分之1
            //進(jìn)行處理
            }
            $arr=json_decode($content);
            if(empty($arr)){
                $this->showMessage("no data to import");
                die();
            }

            //實(shí)例化不同數(shù)據(jù)庫
            $tag=true;
            foreach ($arr as $key => $val) {                
                //存儲(chǔ)
                $aVal = (array)$val;
                $model = new $this->model;
                if($model instanceof SMongodb){//動(dòng)態(tài)字段存儲(chǔ)
                    foreach ($aVal as $k => $v) {
                        $model->$k=$v;
                    }
                }else{//非動(dòng)態(tài)字段存儲(chǔ)
                    $model->attributes=$aVal;
                }

                if(!$model->save()){
                    $tag=false;
                }else{
                    unset($model);    //銷毀一個(gè)對(duì)象，再次使用的時(shí)候會(huì)new一個(gè)新的
                }
            }

        }
        if(!$tag){
            $this->showMessage("some error in import");
        }else{
            $this->showMessage("import success!");
        }
    }    


    /**
     * 信息輸出
     * @author      lizhihui
      * @date        2018-4-9
     */
    private function showMessage($str, $err = 0) {
        if (!$str) {
            return false;
        }
        if ($err) {
            echo "[ERROR]";
        } else {
            echo "[SUCCESS]";
        }

        echo date("Y-m-d H:i:s", time()) . " " . $str . "
";

    }
}