|
|
<?php
|
|
|
// +----------------------------------------------------------------------
|
|
|
// | 徐州梦创信息科技有限公司—专业的游戏运营，推广解决方案.
|
|
|
// +----------------------------------------------------------------------
|
|
|
// | Copyright (c) 2013 http://www.vlcms.com All rights reserved.
|
|
|
// +----------------------------------------------------------------------
|
|
|
// | Author: kefu@vlcms.com QQ：97471547
|
|
|
// +----------------------------------------------------------------------
|
|
|
namespace Admin\Event;
|
|
|
|
|
|
use Think\Controller;
|
|
|
use Base\Service\GameSourceService;
|
|
|
use Base\Tool\PlistParser;
|
|
|
use Base\Tool\ApkParser;
|
|
|
|
|
|
/**
|
|
|
* 后台首页控制器
|
|
|
*
|
|
|
* @author 麦当苗儿 <zuojiazi@vip.qq.com>
|
|
|
*/
|
|
|
class SourceEvent extends Controller
|
|
|
{
|
|
|
|
|
|
public function add_source()
|
|
|
{
|
|
|
$data = $_REQUEST;
|
|
|
$data['file_size'] = round($data['file_size'] / pow(1024, 2), 2) . "MB";
|
|
|
$data['file_url'] = $data['file_url'] . "/" . $data['file_name'];
|
|
|
$data['sdk_version'] = $data['file_type'];
|
|
|
$data['op_id'] = UID;
|
|
|
$data['op_account'] = session("user_auth.username");
|
|
|
$data['create_time'] = NOW_TIME;
|
|
|
$remark = str_replace(array("\r\n", "\r", "\n"), "@@@", $_POST['remark']);
|
|
|
$data['remark'] = json_encode(explode('@@@', $remark));
|
|
|
$data['source_version'] = 0;
|
|
|
$version = '';
|
|
|
$packageName = '';
|
|
|
if ($data['file_type'] == 1) {
|
|
|
$parser = new ApkParser();
|
|
|
$parser->open($data['file_url']);
|
|
|
$version = $parser->getVersionName();
|
|
|
$packageName = $parser->getPackage();
|
|
|
} elseif($data['file_type'] == 2) {
|
|
|
$parser = new PlistParser();
|
|
|
$parser->openFromIpa($data['file_url'], PlistParser::PREG_INFO_PLIST);
|
|
|
$result = $parser->getResult();
|
|
|
$version = $result['CFBundleShortVersionString'];
|
|
|
$packageName = $result['CFBundleIdentifier'];
|
|
|
}
|
|
|
$data['version'] = $version;
|
|
|
$data['bao_name'] = $packageName;
|
|
|
$game = M('game', 'tab_')->where(['id' => $data['game_id']])->find();
|
|
|
$gameSourceService = new GameSourceService();
|
|
|
$result = $gameSourceService->sourcePack($data, $game);
|
|
|
var_dump($result);
|
|
|
if (!$result['status']) {
|
|
|
var_dump($result);die();
|
|
|
$this->error('添加失败' , U('GameSource/lists', ['type' => $data['type']]));
|
|
|
}
|
|
|
$data['plist_url'] = $result['data']['plistUrl'];
|
|
|
$data['org_plist_url'] = $result['data']['orgPlistUrl'];
|
|
|
$data['file_url'] = $result['data']['fileUrl'];
|
|
|
$data['original_url'] = $result['data']['originalUrl'];
|
|
|
if (M('game_source', 'tab_')->add($data)) {
|
|
|
//原包打包
|
|
|
$this->update_game_size($data);
|
|
|
var_dump('success');die();
|
|
|
$this->success('添加成功', U('GameSource/lists', ['type' => $data['type']]));
|
|
|
} else {
|
|
|
var_dump('error');die();
|
|
|
$this->error('添加失败', U('GameSource/lists', ['type' => $data['type']]));
|
|
|
}
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
*修改游戏原包
|
|
|
*/
|
|
|
public function update_source($id = null, $file_name, $from = "")
|
|
|
{
|
|
|
$id || $this -> error('id不能为空');
|
|
|
$model = D('Game_source');
|
|
|
$plist = A("Plist");
|
|
|
$data = $_REQUEST;
|
|
|
$url = $data['file_url'];
|
|
|
$urll = $data['file_url2'];
|
|
|
$data['file_size'] = strpos($data['file_size'], 'MB') ? $data['file_size'] : round($data['file_size'] / pow(1024, 2), 2) . "MB";
|
|
|
$data['file_url'] = $data['file_url'] . "/" . $data['file_name'];
|
|
|
$data['id'] = $id;
|
|
|
$data['op_id'] = UID;
|
|
|
$data['op_account'] = session("user_auth.username");
|
|
|
$data['create_time'] = NOW_TIME;
|
|
|
$remark = str_replace(array("\r\n", "\r", "\n"), "@@@", $_POST['remark']);
|
|
|
$data['remark'] = json_encode(explode('@@@', $remark));
|
|
|
$game_source = $model->where(['id' => $id])->find();
|
|
|
if($game_source['file_name'] == $data['file_name']) {
|
|
|
if ($from == "dev") {
|
|
|
$this -> success('修改成功', U('Developers/source'));
|
|
|
} else {
|
|
|
$this -> success('修改成功', U('GameSource/lists'));
|
|
|
}
|
|
|
}
|
|
|
$data['source_version'] = $game_source['source_version'] + 1;
|
|
|
|
|
|
$game = M('game', 'tab_')->where(['id' => $data['game_id']])->find();
|
|
|
$gameSourceService = new GameSourceService();
|
|
|
$result = $gameSourceService->sourcePack($data, $game);
|
|
|
if (!$result['status']) {
|
|
|
if ($from == "dev") {
|
|
|
$this->error('修改失败', U('Developers/source'));
|
|
|
} else {
|
|
|
$this->error('修改失败', U('GameSource/lists'));
|
|
|
}
|
|
|
}
|
|
|
$data['plist_url'] = $result['data']['plistUrl'];
|
|
|
$data['org_plist_url'] = $result['data']['orgPlistUrl'];
|
|
|
$data['file_url'] = $result['data']['fileUrl'];
|
|
|
$data['original_url'] = $result['data']['originalUrl'];
|
|
|
|
|
|
if ($model->save($data)) {
|
|
|
//渠道包加入打包队列
|
|
|
$appmodel = M('Apply', 'tab_');
|
|
|
$app_map['status'] = 1;
|
|
|
$app_map['game_id'] = $game_source['game_id'];
|
|
|
$app_data = $appmodel->where($app_map)->select();
|
|
|
if ($app_data) {
|
|
|
M()->startTrans();
|
|
|
$app_res = $appmodel->where($app_map)->save(['enable_status'=>2, 'pack_url'=>'', 'plist_url'=>'']);
|
|
|
M('apply_launch', 'tab_') -> where(['launch_game_id'=>$game_source['game_id']])->setField('launch_packge', 0);
|
|
|
if ($app_res === false) {
|
|
|
M()->rollback();
|
|
|
if ($from == "dev") {
|
|
|
$this->error('渠道包打包失败', U('Developers/source'));
|
|
|
} else {
|
|
|
$this->error('渠道包打包失败', U('GameSource/lists'));
|
|
|
}
|
|
|
} else {
|
|
|
M()->commit();
|
|
|
}
|
|
|
}
|
|
|
@unlink($url . "/" . $file_name);
|
|
|
@unlink($urll . "/" . str_replace('.ipa', '.mobileprovision', $file_name));
|
|
|
|
|
|
$this->update_game_size($data);
|
|
|
|
|
|
//发送站内信
|
|
|
$users = M('ucenter_member')->where('status=1') -> field('id')->select();
|
|
|
$content = '游戏：' . $game['game_name'] . ' 已更新，请尽快处理渠道包';
|
|
|
D('Msg')->sendMsg2($users, $content, $game['sdk_version'], $game['id']);
|
|
|
|
|
|
if ($from == "dev") {
|
|
|
$this->success('修改成功', U('Developers/source'));
|
|
|
} else {
|
|
|
$this->success('修改成功', U('GameSource/lists'));
|
|
|
}
|
|
|
} else {
|
|
|
if ($from == "dev") {
|
|
|
$this->error('修改失败', U('Developers/source'));
|
|
|
} else {
|
|
|
$this->error('修改失败', U('GameSource/lists'));
|
|
|
}
|
|
|
}
|
|
|
|
|
|
}
|
|
|
|
|
|
protected function update_game_size($param = null)
|
|
|
{
|
|
|
$model = D('Game');
|
|
|
$map['id'] = $param['game_id'];
|
|
|
$data['game_size'] = $param['file_size'];
|
|
|
// $data['version'] = $param['version'];
|
|
|
if ($param['file_type'] == 1) {
|
|
|
$data['and_dow_address'] = $param['file_url'];
|
|
|
$ggame = $model -> where(array('id' => $map['id'])) -> find();
|
|
|
if ($ggame['sdk_version'] != - 1) {
|
|
|
if ($ggame['sdk_version'] == 2) {
|
|
|
$data['sdk_version'] = 0;
|
|
|
}
|
|
|
} else {
|
|
|
$data['sdk_version'] = 1;
|
|
|
}
|
|
|
} else {
|
|
|
if ($ggame['sdk_version'] != - 1) {
|
|
|
if ($ggame['sdk_version'] == 1) {
|
|
|
$data['sdk_version'] = 0;
|
|
|
}
|
|
|
} else {
|
|
|
$data['sdk_version'] = 2;
|
|
|
}
|
|
|
$data['ios_dow_address'] = $param['file_url'];
|
|
|
}
|
|
|
$model -> where($map) -> save($data);
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
*原包打包
|
|
|
*/
|
|
|
protected function soure_pack($game_id = 0, $file_url = "", $file_type = 1, $source_version = 1, $baoName='', $flag=0, $file_name='')
|
|
|
{
|
|
|
$game_info = M("game", "tab_") -> find($game_id);
|
|
|
$data = array(
|
|
|
"game_id" => $game_info['id'],
|
|
|
"game_name" => $game_info['game_name'],
|
|
|
"game_appid" => $game_info['game_appid'],
|
|
|
"promote_id" => 0,
|
|
|
"promote_account" => "自然注册",
|
|
|
'source_version' => $source_version,
|
|
|
);
|
|
|
|
|
|
$real_file_url = ROOTTT.ltrim($file_url, './');
|
|
|
$temp = explode('/', $file_url);
|
|
|
$newFileName = $temp[count($temp)-1];
|
|
|
|
|
|
$to = $file_url;
|
|
|
$originalUrl = '';
|
|
|
if ($file_type == 1) {
|
|
|
$new_file_url = $real_file_url;
|
|
|
$zip = new \ZipArchive;
|
|
|
$res = $zip -> open($real_file_url, \ZipArchive::CREATE);
|
|
|
$zip -> addFromString('META-INF/mch.properties', json_encode($data));
|
|
|
$zip -> close();
|
|
|
} elseif ($file_type == 2) {
|
|
|
if (preg_match("/.ipa/", $file_url)) {
|
|
|
if($flag == 0 || ($flag ==1 && $newFileName != $file_name)) {
|
|
|
$originalUrl = $file_url;
|
|
|
$new_file_url = str_replace('Uploads/SourcePack', 'Uploads/Ios/original', $real_file_url);
|
|
|
$to = str_replace('Uploads/SourcePack', 'Uploads/Ios/original', $file_url);
|
|
|
$zip_open_game_source = zip_open($real_file_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);
|
|
|
}
|
|
|
$url_ver = "Payload/" . $new_ios_1[0] . "/_CodeSignature/TXChannel";
|
|
|
$zip = new \ZipArchive;
|
|
|
copy($real_file_url, $new_file_url);
|
|
|
$res = $zip -> open($new_file_url, \ZipArchive::CREATE);
|
|
|
$zip -> addFromString($url_ver, json_encode($data));
|
|
|
$zip -> close();
|
|
|
// unlink($real_file_url);
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
|
|
|
$new_path = str_replace("./Uploads/", "", $file_url);
|
|
|
if (get_tool_status("oss_storage") == 1) {
|
|
|
|
|
|
if(C("oss_storage.is_cname")){
|
|
|
$to = "http://".C("oss_storage.domain")."/".str_replace("Ios/original","SourcePack",$new_path);
|
|
|
}else{
|
|
|
$to = "https://".C("oss_storage.bucket").".".C("oss_storage.domain")."/".str_replace("Ios/original","SourcePack",$new_path);
|
|
|
$to = str_replace('-internal', '', $to);
|
|
|
}
|
|
|
|
|
|
$updata['savename'] = $newFileName;
|
|
|
$updata['path'] = $new_file_url;
|
|
|
$this -> upload_game_pak_oss($updata);
|
|
|
} elseif (get_tool_status("cos_storage") == 1) {
|
|
|
$updata['path'] = $new_file_url;
|
|
|
$updata['savename'] = 'SourcePack/'. $newFileName;
|
|
|
$to = $this->upload_cos($updata);
|
|
|
}
|
|
|
|
|
|
$model = D('Game_source');
|
|
|
$model->where(['game_id'=>$game_id])->save(['file_url'=>$to, 'original_url' => $originalUrl]);
|
|
|
|
|
|
$plist = A("Plist");
|
|
|
|
|
|
if ($file_type == 2) {
|
|
|
$data['plist_url'] = "./Uploads/SourcePlist/" . $data['game_id'] . ".Plist";
|
|
|
$plist -> create_plist($game_id, 0, $baoName, $to);
|
|
|
$plist -> create_org_plist($game_id, 0, $baoName, $originalUrl);
|
|
|
}
|
|
|
}
|
|
|
|
|
|
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"), C("oss_storage.is_cname"));
|
|
|
} catch (OssException $e) {
|
|
|
$this -> error($e->getMessage());
|
|
|
}
|
|
|
$bucket = C('oss_storage.bucket');
|
|
|
$oss_name = "SourcePack";
|
|
|
$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());
|
|
|
}
|
|
|
}
|
|
|
|
|
|
|
|
|
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");
|
|
|
$this -> error('1' . $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");
|
|
|
$this -> error($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");
|
|
|
$this -> error($e -> getMessage() . "\n");
|
|
|
return;
|
|
|
}
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
* 腾讯云上传
|
|
|
*
|
|
|
* @param null $data
|
|
|
*
|
|
|
* @return mixed
|
|
|
*
|
|
|
* @author: 鹿文学[lwx]<fyj301415926@126.com>
|
|
|
* @since: 2019\4\18 0018 17:33
|
|
|
*/
|
|
|
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);
|
|
|
}
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
}
|