第php使用workman框架實(shí)現(xiàn)socket服務(wù)以及連接客戶端$iosPkg=$db

-select('a.id,a.vid,a.filename,a.agent,d.pinyin,,c.package_name')

-from('cy_ct_ios_packagea')

-where("a.status=0ANDc.is_send=1")

-leftJoin('cy_ct_ios_mobileversionb','b.id=a.m_v_id')

-rightJoin('cy_ct_ios_versionc','c.id=a.vid')

-leftJoin('cy_gamed','d.id=c.game_id')

-orderByASC(['a.create_time'])-query();

if(empty($iosPkg))thrownew\Exception('沒(méi)有需要待分包的數(shù)據(jù)'.PHP_EOL);

//2.分包

foreach($iosPkgas$one){

try{

//對(duì)當(dāng)前正要分的包把狀態(tài)改為‘分包中'

$db-update('cy_ct_ios_package')-cols([

'status'=2,

])-where("id=".$one['id'])-query();

$filename=$one['pinyin'];

//渠道分包

$verId=@$one['vid'];

$agent=@$one['agent'];

$location=isset($data['location'])$data['location']:1;

$authId=@intval($data['authId']);//授權(quán)文件

if(empty($verId)||empty($agent)){

thrownew\Exception("分包失敗：".$one['id']."版本、渠道為空\(chéng)r\n");

//替換\,否則PHP驗(yàn)證不文件是否存在

$orgPkg=str_replace('\\','',ORGPKG)."{$filename}.ipa";

debug($one['id'].'原包：'.$orgPkg);

debug($one['id'].'是否是文件：'.is_file($orgPkg));

if(!is_file($orgPkg)){

thrownew\Exception("分包失敗：".$one['id']."母包不存在-$orgPkg\r\n");

//從新拼接文件

$orgPkg=ORGPKG."{$filename}.ipa";

//獲取目標(biāo)包存放路徑

$distPkgPath=getDistPkgPath($location);

$distPkg=$distPkgPath."$filename/vers_{$verId}/{$filename}_$agent.ipa";

debug('渠道分包地址：'.$distPkg);

if(file_exists($filename)){

@unlink($filename);

//替換授權(quán)文件

$certMobile=sprintf($connection-pppath,$authId);

//渠道分包

list($msg,$code)=dividePkg($connection-shell,$orgPkg,$distPkg,$agent,$certMobile);

debug('$code'.$code);

if($code!=0){

thrownew\Exception("分包失?。?.$msg."\r\n");

$distPkg=str_replace($distPkgPath,'',$distPkg);

}catch(\Exception$ex){

debug($ex-getMessage());

$code=-1;

$msg=$ex-getMessage();

//3.分包后更新分包結(jié)果，狀態(tài)，下載地址

$status=$code==01:2;

$sdata['status']=$status;

$sdata['message']=$msg;

if($status==1){

$sdata['url']=IOS_URL.$distPkg;

$db-update('cy_ct_ios_package')-cols($sdata)-where("id=".$one['id'])-query();

resonse($connection,$msg,$code);

}catch(\Exception$ex){

resonse($connection,$ex-getMessage());

//Emittedwhennewconnectionc