完善大数据上报

application/api/controller/Notify.php

@@ -1277,6 +1277,36 @@ class Notify extends Api
         error_log('', 3, './dashuju/' . $check_filename);
         $finish_filename = date('Ymd') . '_' . config('data_cp_id') . '_productsdata.finish';
         error_log('', 3, './dashuju/' . $finish_filename);
+
+        //连接ftp
+        $host = config('data_ftp_ip');
+        $port = config('data_ftp_port');
+        $username = config('data_ftp_user');
+        $password = config('data_ftp_pwd');
+        $conn = ftp_connect($host, $port) or die("Could not connect");
+        //登录
+        ftp_login($conn,$username,$password);
+        //开启被动模式
+        ftp_pasv($conn, true);
+        //利用ftp创建目录
+        /*$path = "home/2021-12-08";
+        $this->make_directory($conn,$path);
+        //利用ftp选择进入目录
+        ftp_chdir($conn,$path);*/
+        //开始上传  ftp_put(ftp链接,服务器地址,本地地址,上传模式);
+        if(ftp_put($conn,$filename,'./dashuju/' . $filename,FTP_BINARY)){
+            //上传成功
+        }
+        if(ftp_put($conn,$check_filename,'./dashuju/' . $check_filename,FTP_BINARY)){
+            //上传成功
+        }
+        if(ftp_put($conn,$finish_filename,'./dashuju/' . $finish_filename,FTP_BINARY)){
+            //上传成功
+        }
+        ftp_close($conn);
+        //注意上传端的ftp权限设置
+
+        echo 'wanbi';
     }
 
     //产品包和媒资所属关系
@@ -1359,7 +1389,187 @@ class Notify extends Api
     //大数据文件上传到大数据ftp(每天一点提供)
     public function uploaddataftp() {
         set_time_limit(0);
+        $host = config('data_ftp_ip');
+        $port = config('data_ftp_port');
+        $username = config('data_ftp_user');
+        $password = config('data_ftp_pwd');
+
+        $time = date('Ymd', time() - 86400);
+
+        // 专辑粒度媒资
+        $albumsdata_filename = $time.'_'.config('data_cp_id').'_albumsdata_1.dat';
+        $albumsdata_check_filename = $time.'_'.config('data_cp_id').'_albumsdata_1.chk';
+        $albumsdata_finish_filename = $time.'_'.config('data_cp_id').'_albumsdata_1.finish';
+        // 节目/内容粒度媒资
+        $videosdata_filename = $time.'_'.config('data_cp_id').'_videosdata_1.dat';
+        $videosdata_check_filename = $time.'_'.config('data_cp_id').'_videosdata_1.chk';
+        $videosdata_finish_filename = $time.'_'.config('data_cp_id').'_videosdata_1.finish';
+        //  产品包和媒资所属关系
+        $productalbumdata_filename = $time.'_'.config('data_cp_id').'_productalbumdata_1.dat';
+        $productalbumdata_check_filename = $time.'_'.config('data_cp_id').'_productalbumdata_1.chk';
+        $productalbumdata_finish_filename = $time.'_'.config('data_cp_id').'_productalbumdata_1.finish';
+        //  用户增值产品包当前订购快照
+        $userefforderdata_filename = $time.'_'.config('data_cp_id').'_userefforderdata_1.dat';
+        $userefforderdata_check_filename = $time.'_'.config('data_cp_id').'_userefforderdata_1.chk';
+        $userefforderdata_finish_filename = $time.'_'.config('data_cp_id').'_userefforderdata_1.finish';
+        //  用户增值产品包订购行为
+        $userorderdata_filename = $time.'_'.config('data_cp_id').'_userorderdata_1.dat';
+        $userorderdata_check_filename = $time.'_'.config('data_cp_id').'_userorderdata_1.chk';
+        $userorderdata_finish_filename = $time.'_'.config('data_cp_id').'_userorderdata_1.finish';
+        //  用户观看行为
+        $userplaydata_filename = $time.'_'.config('data_cp_id').'_userplaydata_1.dat';
+        $userplaydata_check_filename = $time.'_'.config('data_cp_id').'_userplaydata_1.chk';
+        $userplaydata_finish_filename = $time.'_'.config('data_cp_id').'_userplaydata_1.finish';
+        //  用户收藏行为
+        $userfavdata_filename = $time.'_'.config('data_cp_id').'_userfavdata_1.dat';
+        $userfavdata_check_filename = $time.'_'.config('data_cp_id').'_userfavdata_1.chk';
+        $userfavdata_finish_filename = $time.'_'.config('data_cp_id').'_userfavdata_1.finish';
+
+        //判断文件是否存在, 不存在则创建
+        if (!file_exists('./dashuju/' . $albumsdata_filename)) {
+            @touch('./dashuju/' . $albumsdata_filename);
+        }
+        if (!file_exists('./dashuju/' . $albumsdata_check_filename)) {
+            @touch('./dashuju/' . $albumsdata_check_filename);
+        }
+        if (!file_exists('./dashuju/' . $albumsdata_finish_filename)) {
+            @touch('./dashuju/' . $albumsdata_finish_filename);
+        }
+        if (!file_exists('./dashuju/' . $videosdata_filename)) {
+            @touch('./dashuju/' . $videosdata_filename);
+        }
+        if (!file_exists('./dashuju/' . $videosdata_check_filename)) {
+            @touch('./dashuju/' . $videosdata_check_filename);
+        }
+        if (!file_exists('./dashuju/' . $videosdata_finish_filename)) {
+            @touch('./dashuju/' . $videosdata_finish_filename);
+        }
+        if (!file_exists('./dashuju/' . $productalbumdata_filename)) {
+            @touch('./dashuju/' . $productalbumdata_filename);
+        }
+        if (!file_exists('./dashuju/' . $productalbumdata_check_filename)) {
+            @touch('./dashuju/' . $productalbumdata_check_filename);
+        }
+        if (!file_exists('./dashuju/' . $productalbumdata_finish_filename)) {
+            @touch('./dashuju/' . $productalbumdata_finish_filename);
+        }
+        if (!file_exists('./dashuju/' . $userefforderdata_filename)) {
+            @touch('./dashuju/' . $userefforderdata_filename);
+        }
+        if (!file_exists('./dashuju/' . $userefforderdata_check_filename)) {
+            @touch('./dashuju/' . $userefforderdata_check_filename);
+        }
+        if (!file_exists('./dashuju/' . $userefforderdata_finish_filename)) {
+            @touch('./dashuju/' . $userefforderdata_finish_filename);
+        }
+        if (!file_exists('./dashuju/' . $userorderdata_filename)) {
+            @touch('./dashuju/' . $userorderdata_filename);
+        }
+        if (!file_exists('./dashuju/' . $userorderdata_check_filename)) {
+            @touch('./dashuju/' . $userorderdata_check_filename);
+        }
+        if (!file_exists('./dashuju/' . $userorderdata_finish_filename)) {
+            @touch('./dashuju/' . $userorderdata_finish_filename);
+        }
+        if (!file_exists('./dashuju/' . $userplaydata_filename)) {
+            @touch('./dashuju/' . $userplaydata_filename);
+        }
+        if (!file_exists('./dashuju/' . $userplaydata_check_filename)) {
+            @touch('./dashuju/' . $userplaydata_check_filename);
+        }
+        if (!file_exists('./dashuju/' . $userplaydata_finish_filename)) {
+            @touch('./dashuju/' . $userplaydata_finish_filename);
+        }
+        if (!file_exists('./dashuju/' . $userfavdata_filename)) {
+            @touch('./dashuju/' . $userfavdata_filename);
+        }
+        if (!file_exists('./dashuju/' . $userfavdata_check_filename)) {
+            @touch('./dashuju/' . $userfavdata_check_filename);
+        }
+        if (!file_exists('./dashuju/' . $userfavdata_finish_filename)) {
+            @touch('./dashuju/' . $userfavdata_finish_filename);
+        }
 
+        //连接ftp
+        $conn = ftp_connect($host, $port) or die("Could not connect");
+        //登录
+        ftp_login($conn,$username,$password);
+        //开启被动模式
+        ftp_pasv($conn, true);
+        //利用ftp创建目录
+        /*$path = "home/2021-12-08";
+        $this->make_directory($conn,$path);
+        //利用ftp选择进入目录
+        ftp_chdir($conn,$path);*/
+        //开始上传  ftp_put(ftp链接,服务器地址,本地地址,上传模式);
+        if(ftp_put($conn,$albumsdata_filename,'./dashuju/' . $albumsdata_filename,FTP_BINARY)){
+            //上传成功
+        }
+        if(ftp_put($conn,$albumsdata_check_filename,'./dashuju/' . $albumsdata_check_filename,FTP_BINARY)){
+            //上传成功
+        }
+        if(ftp_put($conn,$albumsdata_finish_filename,'./dashuju/' . $albumsdata_finish_filename,FTP_BINARY)){
+            //上传成功
+        }
+        if(ftp_put($conn,$videosdata_filename,'./dashuju/' . $videosdata_filename,FTP_BINARY)){
+            //上传成功
+        }
+        if(ftp_put($conn,$videosdata_check_filename,'./dashuju/' . $videosdata_check_filename,FTP_BINARY)){
+            //上传成功
+        }
+        if(ftp_put($conn,$videosdata_finish_filename,'./dashuju/' . $videosdata_finish_filename,FTP_BINARY)){
+            //上传成功
+        }
+        if(ftp_put($conn,$productalbumdata_filename,'./dashuju/' . $productalbumdata_filename,FTP_BINARY)){
+            //上传成功
+        }
+        if(ftp_put($conn,$productalbumdata_check_filename,'./dashuju/' . $productalbumdata_check_filename,FTP_BINARY)){
+            //上传成功
+        }
+        if(ftp_put($conn,$productalbumdata_finish_filename,'./dashuju/' . $productalbumdata_finish_filename,FTP_BINARY)){
+            //上传成功
+        }
+        if(ftp_put($conn,$userefforderdata_filename,'./dashuju/' . $userefforderdata_filename,FTP_BINARY)){
+            //上传成功
+        }
+        if(ftp_put($conn,$userefforderdata_check_filename,'./dashuju/' . $userefforderdata_check_filename,FTP_BINARY)){
+            //上传成功
+        }
+        if(ftp_put($conn,$userefforderdata_finish_filename,'./dashuju/' . $userefforderdata_finish_filename,FTP_BINARY)){
+            //上传成功
+        }
+        if(ftp_put($conn,$userorderdata_filename,'./dashuju/' . $userorderdata_filename,FTP_BINARY)){
+            //上传成功
+        }
+        if(ftp_put($conn,$userorderdata_check_filename,'./dashuju/' . $userorderdata_check_filename,FTP_BINARY)){
+            //上传成功
+        }
+        if(ftp_put($conn,$userorderdata_finish_filename,'./dashuju/' . $userorderdata_finish_filename,FTP_BINARY)){
+            //上传成功
+        }
+        if(ftp_put($conn,$userplaydata_filename,'./dashuju/' . $userplaydata_filename,FTP_BINARY)){
+            //上传成功
+        }
+        if(ftp_put($conn,$userplaydata_check_filename,'./dashuju/' . $userplaydata_check_filename,FTP_BINARY)){
+            //上传成功
+        }
+        if(ftp_put($conn,$userplaydata_finish_filename,'./dashuju/' . $userplaydata_finish_filename,FTP_BINARY)){
+            //上传成功
+        }
+        if(ftp_put($conn,$userfavdata_filename,'./dashuju/' . $userfavdata_filename,FTP_BINARY)){
+            //上传成功
+        }
+        if(ftp_put($conn,$userfavdata_check_filename,'./dashuju/' . $userfavdata_check_filename,FTP_BINARY)){
+            //上传成功
+        }
+        if(ftp_put($conn,$userfavdata_finish_filename,'./dashuju/' . $userfavdata_finish_filename,FTP_BINARY)){
+            //上传成功
+        }
+
+        ftp_close($conn);
+        //注意上传端的ftp权限设置
+
+        echo 'wanbi';
     }
 
     public function make_directory($ftp_stream, $dir){