<?php

namespace Admin\Controller;

use Qiniu\Storage\UploadManager;
use User\Api\UserApi as UserApi;
use OSS\OssClient;
use OSS\Core\OSsException;
use Qiniu\Storage\BucketManager;
use Qiniu\Auth;
use Think\Controller;
use BaiduBce\BceClientConfigOptions;
use BaiduBce\Util\Time;
use BaiduBce\Util\MimeTypes;
use BaiduBce\Http\HttpHeaders;
use BaiduBce\Services\Bos\BosClient;
use BaiduBce\Services\Bos\CannedAcl;
use BaiduBce\Services\Bos\BosOptions;
use BaiduBce\Auth\SignOptions;
use BaiduBce\Log\LogFactory;
use Think\Think;

/**
 * 后台首页控制器
 *
 * @author 麦当苗儿 <zuojiazi@vip.qq.com>
 */
class AutoPackController extends Think
{


    protected function _initialize()
    {
        C(api('Config/lists'));
    }


    public function package()
    {
        $find_web_stie = M('config')
                -> field('value')
                -> where(['name' => 'WEB_SITE'])
                -> find();

        if (null == $find_web_stie) {
            \Think\Log ::record('请先到站点->网站设置->网站域名处设置官网域名');
            exit;
        }

        $this->checkPackageStatus();
        $this->app_package();//app渠道自动打包
        $this->channel();
        $this->launch_package(false);
        $this->leak_detection();
    }

    /**
     * 更改申请游戏的状态
     *
     * @author: 鹿文学[lwx]<fyj301415926@126.com>
     * @since: 2019\4\23 0023 11:22
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     */
    private function checkPackageStatus() {
        $applyModel = M('apply', 'tab_');
        $launchModel = M('apply_launch', 'tab_');

        $launchGameIds = $launchModel
                ->alias('l')
                ->field('l.id')
                ->join('tab_game_source as s on (s.game_id = l.launch_game_id and trim(s.file_name) <> trim(l.game_source_filename))')
                ->where('1=1')
                ->group('l.id')
                ->select();
        if(!empty($launchGameIds)) {

            $ids = array_column($launchGameIds, 'id');

            $launchModel->where(['id'=>['in',$ids]])->setField('launch_packge', 2);

        }

        $launchIds = $launchModel
                ->field('apply_id,count(id) as count')
                ->where(['launch_packge'=>1])
                ->group('apply_id')
                ->select();
        $launchAllIds = $launchModel
                ->field('apply_id,count(id) as count')
                ->group('apply_id')
                ->select();

        $launchId='';
        foreach ($launchIds as $launchValue) {
            foreach ($launchAllIds as $launchAllValue) {
                if($launchValue['apply_id'] == $launchAllValue['apply_id']
                        && $launchValue['count'] == $launchAllValue['count']) {
                    $launchId[]=$launchValue['apply_id'];
                }
            }
        }

        if(!empty($launchId)) {
            $applyModel->where(['id'=>['in',$launchId]])->setField('enable_status', 1);
        }

    }

    /**
     * 投放申请游戏打包
     *
     * @param bool $flag
     *
     * @author: 鹿文学[lwx]<fyj301415926@126.com>
     * @since: 2019\4\17 0017 17:44
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     */
    public function launch_package($flag=true)
    {

        if($flag) {
            $find_web_stie = M('config')
                    -> field('value')
                    -> where(['name' => 'WEB_SITE'])
                    -> find();

            if (null == $find_web_stie) {
                \Think\Log ::record('请先到站点->网站设置->网站域名处设置官网域名');
                exit;
            }

        }

        $zip = new \ZipArchive();

        $applyModel = M('apply', 'tab_');
        $gameSourceModel = M('Game_source', 'tab_');
        $launchModel = M('apply_launch', 'tab_');

        $map['launch_packge'] = ['in',[0,2]];
        $map['launch_status'] = 1;

        $launchData = $launchModel->alias('l')
                    ->field('l.id, l.platform_id, l.apply_id, l.position,l.launch_packge, l.game_source_filename, a.game_id, a.game_name, a.promote_id, a.promote_account, a.sdk_version')
                    ->join('tab_apply as a on(a.id = l.apply_id and a.status=1) ')
                    ->where($map)
                    ->order('apply_id')
                    ->limit(3)
                    ->select();
        if (!empty($launchData)) {

            foreach($launchData as $key => $value) {

                $gameSourceData = $gameSourceModel
                        -> field('id,file_name,source_version')
                        -> where(['game_id' => $value['game_id']])
                        -> find();

                $url = get_game_source_file_url($value['game_id']);
                $launchMap = ['apply_id' => $value['apply_id']];
                if(!file_exists($url) || null == $gameSourceData) {
                    $applyModel -> where(['id' => $value['apply_id']]) -> setField('enable_status', -1);
                    $launchModel->where($launchMap)->setField('launch_packge', -1);
                    continue;
                }

                if($gameSourceData['file_name'] == $value['game_source_filename'] && !empty($value['launch_down_url'])) {
                    $applyModel -> where(['id' => $value['apply_id']]) -> setField('enable_status', 1);
                    $launchModel->where($launchMap)->setField('launch_packge', 1);
                    continue;
                }

                $applyModel -> where(['id' => $value['apply_id']]) -> setField('enable_status', 3);
                $launchModel->where(['platform_id' => $value['platform_id'], 'apply_id' => $value['apply_id'], 'position'=>$value['position']])->setField('launch_packge', 3);
                if($value['sdk_version'] == 1) {
                    $str_ver = ".apk";
                    $file_name = "GamePack";
                    $url_ver = "META-INF/mch.properties";
                } else {
                    $zip_open_game_source = zip_open($url);
                    if($zip_open_game_source) {
                        while ($zip_entry = zip_read($zip_open_game_source)) {
                            if (preg_match("/.app/", zip_entry_name($zip_entry))) {
                                $ios_app = substr(zip_entry_name($zip_entry), 8) . "<br/>";
                            }
                            $new_ios_1 = explode("/", $ios_app);
                        }
                        zip_close($zip_open_game_source);
                    }
                    $str_ver = ".ipa";
                    $file_name = "IosGamePack";
                    $url_ver = "Payload/" . $new_ios_1[0] . "/_CodeSignature/TXChannel";

                }
                $new_name = "game_package" . $value['game_id'] . "-" . $value['promote_id'] . "-" . $value['platform_id'] . "-" . $value['position'] . $str_ver;
                $to = "./Uploads/" . $file_name . "/" . $new_name;
                copy($url, ROOTTT . ltrim($to, './'));
                $zip_res = $zip -> open(ROOTTT . ltrim($to, './'), \ZipArchive::CREATE);

                if($zip_res == true) {
                    #打包数据
                    $pack_data = array(
                            "game_id" => $value["game_id"],
                            "game_name" => $value['game_name'],
                            "game_appid" => get_game_appid($value["game_id"], "id"),
                            "promote_id" => $value['promote_id'],
                            "promote_account" => $value['promote_account'],
                            "source_version" => $gameSourceData['source_version'],
                            'launch_id' => $value['platform_id'],
                            'position' => $value['position'],
                    );

                    $zip -> addFromString($url_ver, json_encode($pack_data));
                    $zip -> close();

                    $newname = $new_name;

                    if(get_tool_status("oss_storage") == 1) {

                        if(C("oss_storage.is_cname")) {
                            $to = "http://" . C("oss_storage.domain") . "/" . str_replace("IosGamePack", "GamePack", $file_name) . "/" . $newname;
                        } else {
                            $to = "https://" . C("oss_storage.bucket") . "." . C("oss_storage.domain") . "/" . str_replace("IosGamePack", "GamePack", $file_name) . "/" . $newname;
                            $to = str_replace('-internal', '', $to);
                        }
                        if(!empty(C('oss_storage.bd_domain')) && strlen(C('oss_storage.bd_domain')) > 5) {
                            $to = C('oss_storage.bd_domain') . "/GamePack/" . $newname;
                        }
                        $new_to = ROOTTT . "Uploads/" . $file_name . "/" . $newname;
                        $updata['savename'] = $newname;
                        $updata['path'] = $new_to;
                        $this -> upload_game_pak_oss($updata);
                        @unlink($new_to);

                    } elseif (get_tool_status("qiniu_storage") == 1) {

                        $this -> dleteQiNiuFile($newname);
                        $url = $this -> upQiNiuFile($newname, ROOTTT . ltrim($to, './'));
                        if (empty($url)) {
                            $this -> error('七牛错误，请检查七牛配置，并确保七牛空间权限正确！');
                        }
                        @unlink(ROOTTT . ltrim($to, './'));
                        $to = "http://" . $url;

                    } elseif (get_tool_status("cos_storage") == 1) {

                        $new_to = ROOTTT . "Uploads/" . $file_name . "/" . $newname;

                        $updata['path'] = $new_to;
                        $updata['savename'] = 'GamePack/'. $newname;

                        $to = $this->upload_cos($updata);


                    } elseif (get_tool_status("bos_storage") == 1) {

                        $to = "http://" . C("bos_storage.bucket") . "." . C("bos_storage.domain") . "/" . $file_name . "/" . $newname;
                        $to = str_replace('-internal', '', $to);
                        $new_to = ROOTTT . "Uploads/" . $file_name . "/" . $newname;
                        $updata['savename'] = $newname;
                        $updata['path'] = $new_to;
                        $this -> upload_bos($updata);
                    }
                    $promote = array('game_id' => $value['game_id'], 'promote_id' => $value['promote_id']);
                    $plist_url = '';
                    if ($value['sdk_version'] == 2) {
                        $plist_url = $this -> create_plist($value['game_id'], $value['promote_id'], get_payload_name($value['game_id']), $to, $value['platform_id'], $value['position']);
                    }

                    $jg = $this -> update_launch_info(['platform_id' => $value['platform_id'], 'apply_id' => $value['apply_id'], 'position'=>$value['position']], $to, $plist_url, $gameSourceData['file_name']);

                    $applyModel -> where(['id' => $value['apply_id']]) -> setField('enable_status', 1);

                } else {

                    $applyModel -> where(['id' => $value['apply_id']]) -> setField('enable_status', -1);
                    $launchModel->where(['platform_id' => $value['platform_id'], 'apply_id' => $value['apply_id'], 'position'=>$value['position']])->setField('launch_packge', -1);
                }


            }

        }

    }


    /**
     * 渠道游戏打包
     *
     * 针对每个申请游戏检测是否存在投放申请：有则更改投放申请状态，使其进入准备打包状态；无则进行渠道游戏打包
     *
     * @author: 鹿文学[lwx]<fyj301415926@126.com>
     * @since: 2019\4\17 0017 14:27
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     */
    private function channel() {
        $zip = new \ZipArchive();

        $map['status'] = 1;
        $map['enable_status'] = ['in', '0,2,3'];

        $applyModel = M('apply', 'tab_');
        $gameSourceModel = M('Game_source', 'tab_');
        $launchModel = M('apply_launch', 'tab_');

        $applys = $applyModel
            ->field('id,game_id,game_name,promote_id,promote_account,sdk_version')
            ->where($map)
            ->order('bale_sort desc,id desc')
            ->limit(200)
            ->select();

        $gameIds = 
        $games = M('game', 'tab_')->field(['id', 'game_appid'])->where(['id' => ['in', $gameIds]])->find();
        $games = index_by_column('id', $games);

        $gameSourceService = new GameSourceService();
        if (!empty($applys)) {
            foreach ($applys as $apply) {

                $gameSource = $gameSourceModel
                    ->field('id,file_name,source_version,file_type')
                    ->where(['game_id' => $apply['game_id']])
                    ->find();

                $gameSourceUrl = $gameSourceService->getGameSourceUrl($gameSource);
                if ($gameSource == null  || !file_exists($gameSourceUrl)) {
                    $applyModel -> where(['id' => $apply['id']]) -> setField('enable_status', -1);
                    continue;
                }

                /* 检测是否存在投放申请，存在则更改投放申请信息，否则进行渠道打包 */
                $launchCount = $launchModel->where(['apply_id'=>$apply['id']])->count();

                if ($launchCount>0) {
                    $applyModel->where(['id' => $apply['id']]) -> setField('enable_status', 3);
                    $launchModel->where(['apply_id' => $apply['id'], 'launch_packge'=>['in', [0,2,3]]])->save(['launch_packge'=>2,'launch_down_url'=>'','launch_plist_url'=>'']);
                } else {
                    $applyModel->where(['id' => $apply['id']]) -> setField('enable_status', 3);

                    $dirName = '';
                    $fileSuffix = '';
                    if ($apply['sdk_version'] == 1) {
                        $fileSuffix = '.apk';
                        $dirName = 'GamePack';
                    } else {
                        $fileSuffix = '.ipa';
                        $dirName = 'IosGamePack';
                    }
                    $channelConfigFile = $gameSourceService->getChannelConfigFile($gameSource);
                    $newName = 'game_package' . $apply['game_id'] . '-' . $apply['promote_id'] . $fileSuffix;
                    $to = './Uploads/' . $dirName . '/' . $newName;
                    $localPath = ROOTTT . ltrim($to, './');
                    copy($gameSourceUrl, $localPath);
                    if ($zip->open($localPath, \ZipArchive::CREATE)) {
                        #打包数据
                        $packData = array(
                                'game_id' => $apply['game_id'],
                                'game_name' => $apply['game_name'],
                                'game_appid' => $games[$apply['game_id']]['game_appid'],
                                'promote_id' => $apply['promote_id'],
                                'promote_account' => $apply['promote_account'],
                                'source_version' => $gameSource['source_version'],
                        );
                        $zip->addFromString($channelConfigFile, json_encode($packData));
                        $zip->close();

                        if (get_tool_status('oss_storage') == 1) {
                            if (C('oss_storage.is_cname')) {
                                $to = 'http://' . C('oss_storage.domain') . '/' . str_replace('IosGamePack', 'GamePack', $dirName) . '/' . $newName;
                            } else {
                                $to = 'https://' . C('oss_storage.bucket') . '.' . C('oss_storage.domain') . '/' . str_replace('IosGamePack', 'GamePack', $dirName) . '/' . $newName;
                                $to = str_replace('-internal', '', $to);
                            }
                            if (!empty(C('oss_storage.bd_domain')) && strlen(C('oss_storage.bd_domain')) > 5) {
                                $to = C('oss_storage.bd_domain') . '/GamePack/' . $newName;
                            }
                            $new_to = ROOTTT . 'Uploads/' . $dirName . '/' . $newName;
                            $updata['savename'] = $newName;
                            $updata['path'] = $new_to;
                            $this->upload_game_pak_oss($updata);

                            if (file_exists($new_to)) {
                                @unlink($new_to);
                            }
                        } elseif (get_tool_status('qiniu_storage') == 1) {

                            $this->dleteQiNiuFile($newName);
                            $url = $this->upQiNiuFile($newName, ROOTTT . ltrim($to, './'));
                            if (empty($url)) {
                                $this -> error('七牛错误，请检查七牛配置，并确保七牛空间权限正确！');
                            }
                            @unlink(ROOTTT . ltrim($to, './'));
                            $to = 'http://' . $url;

                        } elseif (get_tool_status('cos_storage') == 1) {

                            $new_to = ROOTTT . 'Uploads/' . $dirName . '/' . $newName;

                            $updata['path'] = $new_to;
                            $updata['savename'] = 'GamePack/'. $newName;

                            $to = $this->upload_cos($updata);

                        } elseif (get_tool_status('bos_storage') == 1) {
                            $newName = 'game_package' . $apply['game_id'] . '-' . $apply['promote_id'] . $fileSuffix;
                            $to = 'http://' . C('bos_storage.bucket') . '.' . C('bos_storage.domain') . '/' . $dirName . '/' . $newName;
                            $to = str_replace('-internal', '', $to);
                            $new_to = ROOTTT . 'Uploads/' . $dirName . '/' . $newName;
                            $updata['savename'] = $newName;
                            $updata['path'] = $new_to;
                            $this->upload_bos($updata);
                        }
                        $promote = array('game_id' => $apply['game_id'], 'promote_id' => $apply['promote_id']);
                        $plist_url = '';
                        if ($apply['sdk_version'] == 2) {
                            $plist_url = $this->create_plist($promote['game_id'], $promote['promote_id'], get_payload_name($apply['game_id']), $to);
                        }
                        $jieguo = $this->updateinfo($apply['id'], $to, $promote, $plist_url);
                    }
                }
            }
        }
    }


    public function leak_detection()
    {
        $applymodel = M('apply', 'tab_');
        $launchmodel = M('apply_launch', 'tab_');
        $game_somodel = M('Game_source', 'tab_');
        $map['a.status'] = 1;
        $map['a.enable_status'] = 1;
        $map['al.launch_packge'] = array('in', [0, 2, 3]);
        $apply = $applymodel->alias('a')
                ->field('a.id,a.game_id,a.game_name,a.promote_account,a.pack_url,a.plist_url,a.promote_id,a.sdk_version,a.enable_status')
                ->join('tab_apply_launch as al on (al.apply_id=a.id) ')
                ->where($map)
                ->limit(300) 
                ->group('a.id')
                ->select();
        foreach ($apply as $key => $value) {
            $gameSource =  $gameSourceModel
                ->field('id,file_name,source_version,file_type')
                ->where(['game_id' => $value['game_id']])
                ->find();
            $gameSourceUrl = $gameSourceService->getGameSourceUrl($gameSource);
            if ($gameSource || !file_exists($gameSourceUrl)) {
                M('apply', 'tab_') -> where(['id' => $value['id']]) -> setField('enable_status', -1);
                $launchmodel -> where(['apply_id' => $value['id']]) -> setField('launch_packge', 0);
                continue;
            }
            
            if (!empty($gameSourceUrl) && is_file($gameSourceUrl)) {

                $launch = $launchmodel -> where(['apply_id' => $value['id'], 'launch_packge' => array('in', [0, 2, 3])]) -> select();
                $zip = new \ZipArchive();
                foreach ($launch as $k => $v) {

                    if ($value['sdk_version'] == 1) {
                        if (!empty($v['game_source_filename'])) {
                            if ($v['game_source_filename'] == $gameSource['file_name']) {
                                if (!empty($v['launch_down_url'])) {
                                    $launchmodel -> where(['id' => $v['id']]) -> setField(['launch_packge' => 1]);
                                    continue;
                                }
                            }
                        }
                        $str_ver = '.apk';
                        $file_name = "GamePack";
                        $url_ver = "META-INF/mch.properties";
                    } else {
                        if (!empty($v['game_source_filename'])) {
                            if ($v['game_source_filename'] == $gameSource['file_name']) {
                                if (!empty($v['launch_plist_url'])) {
                                    if (!empty($v['launch_down_url'])) {
                                        $launchmodel -> where(['id' => $v['id']]) -> setField(['launch_packge' => 1]);
                                        continue;
                                    }
                                }
                            }
                        }
                        $zip_open_game_source = zip_open($gameSourceUrl);
                        if ($zip_open_game_source) {
                            while ($zip_entry = zip_read($zip_open_game_source)) {
                                if (preg_match("/.app/", zip_entry_name($zip_entry))) {
                                    $ios_app = substr(zip_entry_name($zip_entry), 8) . "<br/>";
                                }
                                $new_ios_1 = explode("/", $ios_app);
                            }
                            zip_close($zip_open_game_source);
                        }
                        $str_ver = ".ipa";
                        $file_name = "IosGamePack";
                        $url_ver = "Payload/" . $new_ios_1[0] . "/_CodeSignature/TXChannel";

                    }
                    $new_name = "game_package" . $value['game_id'] . "-" . $value['promote_id'] . "-" . $v['platform_id'] . "-" . $v['position'] . $str_ver;
                    $to = "./Uploads/" . $file_name . "/" . $new_name;
                    copy($gameSourceUrl, ROOTTT . ltrim($to, './'));
                    $zip_res = $zip -> open(ROOTTT . ltrim($to, './'), \ZipArchive::CREATE);
                    if ($zip_res == true) {
                        #打包数据
                        $pack_data = array(
                                "game_id" => $value["game_id"],
                                "game_name" => $value['game_name'],
                                "game_appid" => get_game_appid($value["game_id"], "id"),
                                "promote_id" => $value['promote_id'],
                                "promote_account" => $value['promote_account'],
                                "source_version" => $gameSource['source_version'],
                                'launch_id' => $v['platform_id'],
                                'position' => $v['position'],
                        );
                        $zip -> addFromString($url_ver, json_encode($pack_data));
                        $zip -> close();
                        $newname = $new_name;
                        if (get_tool_status("oss_storage") == 1) {

                            if (C("oss_storage.is_cname")) {
                                $to = "http://" . C("oss_storage.domain") . "/" . str_replace("IosGamePack", "GamePack", $file_name) . "/" . $newname;
                            } else {
                                $to = "https://" . C("oss_storage.bucket") . "." . C("oss_storage.domain") . "/" . str_replace("IosGamePack", "GamePack", $file_name) . "/" . $newname;
                                $to = str_replace('-internal', '', $to);
                            }
                            if (!empty(C('oss_storage.bd_domain')) && strlen(C('oss_storage.bd_domain')) > 5) {
                                $to = C('oss_storage.bd_domain') . "/GamePack/" . $newname;
                            }
                            $new_to = ROOTTT . "Uploads/" . $file_name . "/" . $newname;
                            $updata['savename'] = $newname;
                            $updata['path'] = $new_to;
                            $this -> upload_game_pak_oss($updata);
                            @unlink($new_to);

                        } elseif (get_tool_status("qiniu_storage") == 1) {

                            $this -> dleteQiNiuFile($newname);
                            $url = $this -> upQiNiuFile($newname, ROOTTT . ltrim($to, './'));
                            if (empty($url)) {
                                $this -> error('七牛错误，请检查七牛配置，并确保七牛空间权限正确！');
                            }
                            @unlink(ROOTTT . ltrim($to, './'));
                            $to = "http://" . $url;

                        } elseif (get_tool_status("cos_storage") == 1) {
                            /*$cos = A('Cos');
                            $cos -> cosupload("", "/" . $file_name . "/" . $newname, 2);
                            $cos_res = $cos -> cosupload(ROOTTT . ltrim($to, './'), "/" . $file_name . "/" . $newname);
                            if (strlen($cos_res) > 10) {
                                @unlink(ROOTTT . ltrim($to, './'));
                                $to = $cos_res;

                            } else {
                                $this -> error("Cos参数错误", U('ios_lists'));
                            }*/


                            $new_to = ROOTTT . "Uploads/" . $file_name . "/" . $newname;

                            $updata['path'] = $new_to;
                            $updata['savename'] = 'GamePack/'. $newname;

                            $to = $this->upload_cos($updata);


                        } elseif (get_tool_status("bos_storage") == 1) {

                            $to = "http://" . C("bos_storage.bucket") . "." . C("bos_storage.domain") . "/" . $file_name . "/" . $newname;
                            $to = str_replace('-internal', '', $to);
                            $new_to = ROOTTT . "Uploads/" . $file_name . "/" . $newname;
                            $updata['savename'] = $newname;
                            $updata['path'] = $new_to;
                            $this -> upload_bos($updata);
                        }
                        $promote = array('game_id' => $value['game_id'], 'promote_id' => $value['promote_id']);
                        $plist_url = '';
                        if ($value['sdk_version'] == 2) {
                            $plist_url = $this -> create_plist($promote['game_id'], $promote['promote_id'], get_payload_name($value['game_id']), $to, $v['platform_id'], $v['position']);
                        }
                        $jg = $this -> update_launch_info(['platform_id' => $v['platform_id'], 'apply_id' => $value['id'], 'position'=>$v['position']], $to, $plist_url, $gameSource['file_name']);

                    }


                }


            } else {
                $applymodel -> where(['id' => $value['id']]) -> setField('enable_status', 2);
                $launchmodel -> where(['apply_id' => $value['id']]) -> setField('launch_packge', 0);
            }

        }

    }

    /**
     * 更改投放申请包信息
     *
     * @author 鹿文学
     */
    public function update_launch_info($map, $pack_url, $plist_url, $source_file)
    {
        $find_web_stie = M('config') -> field('value') -> where(['name' => 'WEB_SITE']) -> find();
        $host = 'http://' . $find_web_stie['value'];
        $hosts = 'https://' . $find_web_stie['value'];
        $model = M('apply_launch', "tab_");
        $data['launch_down_url'] = $pack_url;
        $data['launch_status'] = 1;
        $data['launch_packge'] = 1;
        $data['launch_plist_url'] = $plist_url;
        $data['game_source_filename'] = $source_file;
        $res = $model -> where($map) -> save($data);
        return $res;
    }

    /**
     * app渠道包打包
     *
     * @param  [type] $ids [description]
     *
     * @return [type]      [description]
     */
    public function app_package()
    {
        $map['status'] = 1;
        $map['enable_status'] = 2;
        $arr_id = M('app_apply', 'tab_')->field('id')->where($map)->order('id desc')->limit(300)->select();
        if (empty($arr_id)) {
            return false;
        }
        $ids = array_map('array_shift', $arr_id);
        if (!is_array($ids)) {
            $ids = [$ids];
        }
        foreach ($ids as $key => $value) {
            $apply_data = M('app_apply', 'tab_') -> find($value);
            #获取原包数据
            $source_file = M('app', 'tab_') -> find($apply_data['app_id']);
            if ($apply_data['app_version'] == 1) {
                $app_type = ".apk";
                $url_ver = "META-INF/mch.properties";
            } else {
                $app_type = ".ipa";
                $url_ver = "Payload/XiGuMobileGame.app/_CodeSignature/mch.txt";
            }
            $newname = "app_package" . $apply_data["app_id"] . "-" . $apply_data['promote_id'] . $app_type;
            $to = "./Uploads/GamePack/" . $newname;
            copy($source_file['file_url'], $to);
            #打包新路径
            $zip = new \ZipArchive;
            $res = $zip -> open($to, \ZipArchive::CREATE);
            if ($res == true) {
                #打包数据
                $pack_data = array(
                        "promote_id" => $apply_data['promote_id'],
                        "promote_account" => get_promote_name($apply_data["promote_id"]),
                );
                $zip -> addFromString($url_ver, json_encode($pack_data));
                $zip -> close();
                if (get_tool_status("oss_storage") == 1) {

                    if (C("oss_storage.is_cname")) {
                        $to = "http://" . C("oss_storage.domain") . "/GamePack/" . $newname;
                    } else {
                        $to = "https://" . C("oss_storage.bucket") . "." . C("oss_storage.domain") . "/GamePack/" . $newname;
                        $to = str_replace('-internal', '', $to);
                    }
                    $new_to = "./Uploads/GamePack/" . $newname;
                    $updata['savename'] = $newname;
                    $updata['path'] = $new_to;
                    $this -> upload_game_pak_oss($updata);
                    @unlink($new_to);
                } elseif (get_tool_status("qiniu_storage") == 1) {
                    $this -> dleteQiNiuFile($newname);
                    $url = $this -> upQiNiuFile($newname, $to);
                    @unlink($to);
                    $to = "http://" . $url;
                } elseif (get_tool_status("cos_storage") == 1) {
                    /*$cos = A('Cos');
                    $cos -> cosupload("", "/App/" . $newname, 2);
                    $cos_res = $cos -> cosupload($to, "/App/" . $newname);
                    if (strlen($cos_res) > 10) {
                        @unlink($to);
                        $to = $cos_res;

                    } else {
                        $this -> error("Cos参数错误");
                    }*/

                    $new_to = ROOTTT . "Uploads/GamePack/" . $newname;

                    $updata['path'] = $new_to;
                    $updata['savename'] = 'GamePack/'. $newname;

                    $to = $this->upload_cos($updata);


                }
                if ($apply_data['app_version'] == 2) {
                    $plist_url = A('Plist') -> create_plist_app('1', $apply_data['app_id'], 'app', $to, $apply_data['promote_id']);
                    $apply_data['plist_url'] = $plist_url;
                }
                $apply_data['dow_url'] = $to;
                $apply_data['enable_status'] = 1;
                M('app_apply', 'tab_') -> save($apply_data);
            }
        }


    }


    /**
     *修改申请信息
     */
    public function updateinfo($id, $pack_url, $promote, $plist_url)
    {
        $model = M('Apply', "tab_");
        $data['id'] = $id;
        $data['pack_url'] = $pack_url;
        $data['dow_url'] = '/index.php?s=/Home/Down/down_file/game_id/' . $promote['game_id'] . '/promote_id/' . $promote['promote_id'];
        $data['dow_status'] = 1;
        $data['enable_status'] = 1;
        $data['dispose_id'] = UID;
        $data['dispose_time'] = NOW_TIME;
        $data['plist_url'] = $plist_url;
        $res = $model -> save($data);
        return $res;
    }


    //生成游戏渠道plist文件
    public function create_plist($game_id = 0, $promote_id = 0, $marking = "", $url = "", $platform_id = 0, $position=1)
    {
        $find_web_stie = M('config') -> field('value') -> where(['name' => 'WEB_SITE']) -> find();
        $xml = new \DOMDocument();
        $xml -> load(ROOTTT . 'Uploads/Plist/testdemo.Plist');
        $online = $xml -> getElementsByTagName('dict');//查找节点
        $asd = $online -> item(1) -> getElementsByTagName('string');//第二个节点下所有string
        foreach ($asd as $key => $value) {
            switch ($value -> textContent) {
                case 'ipa_url':
                    if (preg_match("/Uploads/", $url)) {
                        $value -> nodeValue = "https://" . $find_web_stie['value'] . ltrim($url, ".");//"https://iosdemo.vlcms.com/app/MCHSecretary.ipa";//替换xml对应的值
                    } else {
                        $value -> nodeValue = $url;
                    }
                    break;
                case 'icon':
                    $icon_url = get_cover(get_game_icon_id($game_id), 'path', 2);
                    if (preg_match("/http/", $icon_url)) {
                        $value -> nodeValue = $icon_url;
                    } else {
                        $value -> nodeValue = "https://" . $find_web_stie['value'] . $icon_url;
                    }
                    break;
                case 'com.dell':
                    $value -> nodeValue = $marking;
                    break;
                case '1.0.0':
                    $value -> nodeValue = game_version($game_id);
                    break;
                case 'mchdemo':
                    $value -> nodeValue = get_ios_game_name($game_id);
                    break;

            }
            if ($promote_id == 0) {
                $xml -> save(ROOTTT . "Uploads/SourcePlist/$game_id.Plist");
            } elseif ($platform_id > 0) {
                $ppname = $game_id . "-" . $promote_id . "-" . $platform_id . "-" .$position;
                $xml -> save(ROOTTT . "Uploads/GamePlist/$ppname.Plist");
            } else {
                $pname = $game_id . "-" . $promote_id;
                $xml -> save(ROOTTT . "Uploads/GamePlist/$pname.Plist");
            }
        }
        if ($promote_id == 0) {
            return "./Uploads/SourcePlist/$game_id.Plist";
        } elseif ($platform_id > 0) {
            $ppname = $game_id . "-" . $promote_id . "-" . $platform_id . "-" . $position;
            return "./Uploads/GamePlist/$ppname.Plist";
        } else {
            return "./Uploads/GamePlist/$pname.Plist";
        }


    }


    public function qiniu_ios_upload($promote_id, $game_id)
    {
        if (get_tool_status("qiniu_storage") == 1) {
            $map['channelid'] = $promote_id;
            $map['game_id'] = $game_id;
            $find = M('iospacket') -> where($map) -> find();
            if (file_exists("./Uploads/Ios/" . $find['channelpath']) && !empty($find['channelpath'])) {
                $newname = "game_package" . $find["game_id"] . "-" . $find['channelid'] . ".ipa";
                $to = "./Uploads/Ios/" . $find['channelpath'];
                $this -> dleteQiNiuFile($newname);
                $url = $this -> upQiNiuFile($newname, $to);
                if (empty($url)) {
                    $this -> error('七牛错误，请检查七牛配置，并确保七牛空间权限正确！');
                }
                unset($map['channelid']);
                $map['promote_id'] = $promote_id;
                $data['pack_url'] = $url;
                $result = M('apply', 'tab_') -> where($map) -> save($data);
                if ($result !== false) {
                    @unlink($to);
                    $this -> AjaxReturn(['status' => 1, 'msg' => '上传成功']);
                } else {
                    $this -> AjaxReturn(['status' => 0, 'msg' => '上传失败']);
                }
            } else {
                $this -> AjaxReturn(['status' => 0, 'msg' => '文件不存在或已上传云空间']);
            }
        } else {
            $this -> AjaxReturn(['status' => 0, 'msg' => '未开启七牛上传']);
        }
    }


    /**
     *上传到OSS
     */
    public function upload_game_pak_oss($return_data = null)
    {
        /**
         * 根据Config配置，得到一个OssClient实例
         */
        try {
            Vendor('OSS.autoload');
            $ossClient = new \OSS\OssClient(C("oss_storage.accesskeyid"), C("oss_storage.accesskeysecr"), C("oss_storage.domain"));
        } catch (OssException $e) {
            $this -> error($e -> getMessage());
        }
        $bucket = C('oss_storage.bucket');
        // if(preg_match('/.apk/',$return_data['savename']) ){
        $oss_name = "GamePack";
        // }else{
        //       $oss_name="IosGamePack";
        // }
        $oss_file_path = $oss_name . "/" . $return_data["savename"];
        $avatar = $return_data["path"];
        try {

            $this -> multiuploadFile($ossClient, $bucket, $oss_file_path, $avatar);
            return true;
        } catch (OssException $e) {
            /* 返回JSON数据 */
            $this -> error($e -> getMessage());
        }
    }

    /**
     *删除OSS
     */
    public function delete_oss($objectname)
    {
        /**
         * 根据Config配置，得到一个OssClient实例
         */
        try {
            Vendor('OSS.autoload');
            $ossClient = new \OSS\OssClient(C("oss_storage.accesskeyid"), C("oss_storage.accesskeysecr"), C("oss_storage.domain"));
        } catch (OssException $e) {
            $this -> error($e -> getMessage());
        }
        $bucket = C('oss_storage.bucket');
        $objectname = "GamePack/" . $objectname;
        $ossClient -> deleteObject($bucket, $objectname);

    }

    /**
     *上传到BOS
     */
    public function upload_bos($return_data = null)
    {
        /**
         * 根据Config配置，得到一个OssClient实例
         */
        try {
            $BOS_TEST_CONFIG =
                    array(
                            'credentials' => array(
                                    'accessKeyId' => C("bos_storage.AccessKey"),
                                    'secretAccessKey' => C("bos_storage.SecretKey"),
                            ),
                            'endpoint' => C("bos_storage.domain"),
                    );
            require VENDOR_PATH . 'BOS/BaiduBce.phar';
            $client = new BosClient($BOS_TEST_CONFIG);
        } catch (Exception $e) {
            $this -> error($e -> getMessage());
        }
        $bucket = C('bos_storage.bucket');
        $bos_file_path = "GamePack/" . $return_data["savename"]; //在bos的路径
        $avatar = $return_data["path"];
        try {

            $client -> putObjectFromFile($bucket, $bos_file_path, $avatar);
        } catch (Exception $e) {
            $this -> error($e -> getMessage());
        }

    }

    /**
     * 腾讯云上传
     *
     * @param null $data
     *
     * @return mixed
     *
     * @author: 鹿文学[lwx]<fyj301415926@126.com>
     * @since: 2019\4\18 0018 17:40
     */
    public function upload_cos($data=null) {

        Vendor('COS5.vendor.autoload');

        $schema=C("cos_storage.schema")?:"https";

        $secretId = C("cos_storage.SecretId"); //"云 API 密钥 SecretId";
        $secretKey = C("cos_storage.SecretKey"); //"云 API 密钥 SecretKey";
        $region = C("cos_storage.domain"); //设置一个默认的存储桶地域
        $cosClient = new \Qcloud\Cos\Client(
                array(
                        'region' => $region,
                        'schema' => $schema, //协议头部，默认为http
                        'credentials'=> array(
                                'secretId'  => $secretId ,
                                'secretKey' => $secretKey
                        )
                )
        );


        $bucket = C("cos_storage.bucket"); //存储桶名称 格式：BucketName-APPID
        $key = $data['savename'];
        $srcPath = $data["path"];//本地文件绝对路径

        try {
            $result = $cosClient->Upload(
                    $bucket = $bucket,
                    $key = $key,
                    $body = fopen($srcPath, 'rb')
            );
            $location = $result['Location'];
            if(!preg_match('/^(http)|(https)/', $location)) {
                $result['Location'] = 'https://' . $result['Location'];
            }
            return $result['Location'];
        } catch (\Exception $e) {
            $this->error($e->getMessage());
        }

    }


    /*
   删除bos的object
    */
    public function delete_bos($name)
    {
        /**
         * 根据Config配置，得到一个OssClient实例
         */
        try {
            $BOS_TEST_CONFIG =
                    array(
                            'credentials' => array(
                                    'accessKeyId' => C("bos_storage.AccessKey"),
                                    'secretAccessKey' => C("bos_storage.SecretKey"),
                            ),
                            'endpoint' => C("bos_storage.domain"),
                    );
            require VENDOR_PATH . 'BOS/BaiduBce.phar';
            $client = new BosClient($BOS_TEST_CONFIG);
        } catch (Exception $e) {
            $this -> error($e -> getMessage());
        }
        $bucket = C('bos_storage.bucket');
        //$path ="icon/". $name; //在bos的路径
        $path = "GamePack/" . $name;
        $client -> deleteObject($bucket, $path);


    }


    public function game_source($game_id, $type)
    {
        $model = D('GameSource');
        $map['game_id'] = $game_id;
        $map['type'] = $type;
        $data = $model -> where($map) -> find();
        return $data;
    }

    public function multiuploadFile($ossClient, $bucket, $url, $file)
    {
        //$file = __FILE__;
        $options = array();
        try {
            #初始化分片上传文件
            $uploadId = $ossClient -> initiateMultipartUpload($bucket, $url);
            //$ossClient->multiuploadFile($bucket, $url, $file, $options);
        } catch (OssException $e) {
            printf(__FUNCTION__ . ": initiateMultipartUpload FAILED\n");
            printf($e -> getMessage() . "\n");
            return;
        }
        /*
         * step 2. 上传分片
         */
        $partSize = 5 * 1000 * 1024;
        $uploadFile = $file;
        $uploadFileSize = filesize($uploadFile);
        $pieces = $ossClient -> generateMultiuploadParts($uploadFileSize, $partSize);
        $responseUploadPart = array();
        $uploadPosition = 0;
        $isCheckMd5 = true;
        foreach ($pieces as $i => $piece) {
            $fromPos = $uploadPosition + (integer) $piece[$ossClient ::OSS_SEEK_TO];
            $toPos = (integer) $piece[$ossClient ::OSS_LENGTH] + $fromPos - 1;
            $upOptions = array(
                    $ossClient ::OSS_FILE_UPLOAD => $uploadFile,
                    $ossClient ::OSS_PART_NUM => ($i + 1),
                    $ossClient ::OSS_SEEK_TO => $fromPos,
                    $ossClient ::OSS_LENGTH => $toPos - $fromPos + 1,
                    $ossClient ::OSS_CHECK_MD5 => $isCheckMd5,
            );
            if ($isCheckMd5) {
                $contentMd5 = \OSS\Core\OssUtil ::getMd5SumForFile($uploadFile, $fromPos, $toPos);
                $upOptions[$ossClient ::OSS_CONTENT_MD5] = $contentMd5;
            }
            //2. 将每一分片上传到OSS
            try {
                $responseUploadPart[] = $ossClient -> uploadPart($bucket, $url, $uploadId, $upOptions);
            } catch (OssException $e) {
                printf(__FUNCTION__ . ": initiateMultipartUpload, uploadPart - part#{$i} FAILED\n");
                printf($e -> getMessage() . "\n");
                return;
            }
        }
        $uploadParts = array();
        foreach ($responseUploadPart as $i => $eTag) {
            $uploadParts[] = array(
                    'PartNumber' => ($i + 1),
                    'ETag' => $eTag,
            );
        }
        /**
         * step 3. 完成上传
         */
        try {
            $ossClient -> completeMultipartUpload($bucket, $url, $uploadId, $uploadParts);
        } catch (OssException $e) {
            printf(__FUNCTION__ . ": completeMultipartUpload FAILED\n");
            printf($e -> getMessage() . "\n");
            return;
        }
    }

    /**
     * 获取七牛上传token
     */
    public function getQiNiuToken()
    {
        $this -> dleteQiNiuFile($_REQUEST['key']);
        Vendor('Qiniu.autoload');
        $config = C('qiniu_storage');
        $accessKey = $config['AccessKey'];
        $secretKey = $config['SecretKey'];
        $Qiniu = new Auth($accessKey, $secretKey);
        $bucket = $config['bucket'];
        //定义上传后返回客户端的值
        $policy = array(
                'returnBody' => '{"name":$(fname),"size":$(fsize),"key":$(key)}',
        );
        //生成上传token
        $result['uptoken'] = $Qiniu -> uploadToken($bucket, null, 3600, $policy);
        $this -> ajaxReturn($result);
    }

    /**
     * 删除七牛空间文件
     *
     * @param $key
     *
     * @return mixed
     */
    public function dleteQiNiuFile($key)
    {
        Vendor('Qiniu.autoload');
        $config = C('qiniu_storage');
        $accessKey = $config['AccessKey'];
        $secretKey = $config['SecretKey'];
        $auth = new Auth($accessKey, $secretKey);
        //初始化BucketManager
        $bucketMgr = new BucketManager($auth);
        $bucket = C('qiniu_storage.bucket');
        $res = $bucketMgr -> delete($bucket, $key);
        return $res;
    }

    /**
     * 七牛上传
     *
     * @param $newName  上传到七牛的文件名称
     * @param $filePath 文件路径
     */
    public function upQiNiuFile($newName, $filePath)
    {
        Vendor('Qiniu.autoload');
        //读取七牛配置
        $config = C('qiniu_storage');
        $accessKey = $config['AccessKey'];
        $secretKey = $config['SecretKey'];
        //实例化鉴权对象
        $auth = new Auth($accessKey, $secretKey);
        $bucket = $config['bucket'];
        //生成token
        $token = $auth -> uploadToken($bucket);
        //实例化上传类
        $uploadMgr = new UploadManager();
        //上传附件
        list($ret, $err) = $uploadMgr -> putFile($token, $newName, $filePath);
        if ($ret) {

            return $url = $config['domain'] . '/' . $newName;

        } else {
            return '';
        }
    }


}