195 lines
4.9 KiB
PHP
195 lines
4.9 KiB
PHP
<?php
|
||
/**
|
||
* 最新系统推送1.9.7后
|
||
* 软件：信呼OA
|
||
* 最后更新：2021-10-09
|
||
*/
|
||
class JPushChajian extends Chajian{
|
||
|
||
|
||
/**
|
||
* -------------最新原生app推送app是1.2.3版本 和 最新app+---------------
|
||
* title 没有base64的标题
|
||
* desc 已经base64了
|
||
* cont 原始的内容json
|
||
* palias 可推送信息
|
||
*/
|
||
public function push($title, $desc, $cont, $palias)
|
||
{
|
||
|
||
$uids = $palias['uids'];
|
||
$alias2019 = $palias['alias2019'];
|
||
$pushuids = $palias['pushuids']; //可以推送的用户ID 就是ispush=1
|
||
$jparr = $palias['jparr']; //应用内消息
|
||
$xmpush = c('xmpush');
|
||
$hwpush = c('hwpush');
|
||
$getui = c('getui');
|
||
|
||
//可推送判断
|
||
$ketualia = array();
|
||
foreach($alias2019 as $ali1){
|
||
$ali1aa = explode('|', $ali1);
|
||
$_uid = $ali1aa[2];
|
||
if(in_array($_uid, $pushuids))$ketualia[] = $ali1;
|
||
}
|
||
$alias2019 = $ketualia;
|
||
|
||
|
||
//$this->rock->debugs($palias,'pushalias');//判断能不能推送，打印这个
|
||
|
||
$xharr = array(
|
||
'uids' => $uids,
|
||
'title' => $this->rock->jm->base64encode($title),
|
||
'desc' => $desc,
|
||
'jpreg' => arrvalue($palias, 'jpreg'),
|
||
'systype'=> getconfig('systype')
|
||
);
|
||
|
||
if(!$alias2019)return;
|
||
|
||
$getuiand = $getuiios = $mybyarr = $xmarr = $hwarr = $iosar = $puarr = array();
|
||
foreach($alias2019 as $k=>$ali1){
|
||
$ali1aa = explode('|', $ali1);
|
||
$regid = $ali1aa[0];
|
||
$_web = $ali1aa[1];
|
||
if(contain($_web,'custpile')){
|
||
$mybyarr[] = $k; //3
|
||
}else if(contain($_web,'getui')){
|
||
if(contain($_web,'iphone')){
|
||
$getuiios[] = $k; //3
|
||
}else{
|
||
$getuiand[] = $k; //3
|
||
}
|
||
}else if(contain($_web,'mi')){
|
||
$xmarr[] = $k; //0
|
||
}else if(contain($_web,'huawei')){
|
||
$hwarr[] = $k; //3
|
||
}else if(contain($_web,'iphone')){
|
||
$iosar[] = $k; //0
|
||
}else{
|
||
$puarr[] = $ali1;
|
||
}
|
||
}
|
||
|
||
$mymsg = '';
|
||
$desc = $this->rock->jm->base64decode($desc);
|
||
if($xmarr){
|
||
if($xmpush->sendbool()){
|
||
$vstr = $this->getVal($alias2019, $xmarr, 0);
|
||
$msg = $xmpush->androidsend($vstr, $title, $desc);
|
||
if($msg)$mymsg.=chr(10).$msg;
|
||
}else{
|
||
$vsta = $this->getVala($alias2019, $xmarr);
|
||
foreach($vsta as $v)$puarr[] = $v;
|
||
}
|
||
}
|
||
|
||
if($hwarr){
|
||
if($hwpush->sendbool()){
|
||
$vstr = $this->getVal($alias2019, $hwarr, 3);
|
||
$msg = $hwpush->androidsend($vstr, $title, $desc);
|
||
if($msg)$mymsg.=chr(10).$msg;
|
||
}else{
|
||
$vsta = $this->getVala($alias2019, $hwarr);
|
||
foreach($vsta as $v)$puarr[] = $v;
|
||
}
|
||
}
|
||
|
||
if($iosar){
|
||
if($xmpush->jpushiosbool()){
|
||
$vstr = $this->getVal($alias2019, $iosar, 0);
|
||
$msg = $xmpush->jpushiossend($vstr, $title, $desc);
|
||
if($msg)$mymsg.=chr(10).$msg;
|
||
}else{
|
||
$vsta = $this->getVala($alias2019, $iosar);
|
||
foreach($vsta as $v)$puarr[] = $v;
|
||
}
|
||
}
|
||
|
||
if($getuiand){
|
||
if($getui->isandroid()){
|
||
$vstr = $this->getVal($alias2019, $getuiand, 3);
|
||
$msg = $getui->push($vstr, $title, $desc);
|
||
if($msg)$mymsg.=chr(10).$msg;
|
||
}else{
|
||
$vsta = $this->getVala($alias2019, $getuiand);
|
||
foreach($vsta as $v)$puarr[] = $v;
|
||
}
|
||
}
|
||
|
||
if($getuiios){
|
||
if($getui->isios()){
|
||
$vstr = $this->getVal($alias2019, $getuiios, 3);
|
||
$msg = $getui->push($vstr, $title, $desc);
|
||
if($msg)$mymsg.=chr(10).$msg;
|
||
}else{
|
||
$vsta = $this->getVala($alias2019, $getuiios);
|
||
foreach($vsta as $v)$puarr[] = $v;
|
||
}
|
||
}
|
||
|
||
if($mybyarr){
|
||
if($getui->sendbool()){
|
||
$vstr = $this->getVal($alias2019, $mybyarr, 3);
|
||
$msg = $getui->push($vstr, $title, $desc);
|
||
if($msg)$mymsg.=chr(10).$msg;
|
||
}else{
|
||
$msg = '自己编译未配置推送';
|
||
$mymsg.=chr(10).$msg;
|
||
}
|
||
}
|
||
|
||
if($mymsg)$this->rock->debugs($mymsg, 'mypush');
|
||
|
||
|
||
//需要官网隧道
|
||
if($puarr){
|
||
$xharr['alias2019'] = join(',', $puarr);
|
||
$runurl = c('xinhu')->geturlstr('jpushplat', $xharr);
|
||
c('curl')->getcurl($runurl);
|
||
}
|
||
}
|
||
|
||
|
||
private function getVal($alias2019, $new, $oi)
|
||
{
|
||
$stv = array();
|
||
foreach($new as $j){
|
||
$stra = explode('|', $alias2019[$j]);
|
||
if(isset($stra[$oi]))$stv[]= $stra[$oi];
|
||
}
|
||
return $stv;
|
||
}
|
||
|
||
private function getVala($alias2019, $new)
|
||
{
|
||
$stv = array();
|
||
foreach($new as $j){
|
||
$stv[] = $alias2019[$j];
|
||
}
|
||
return $stv;
|
||
}
|
||
|
||
/**
|
||
* 极光自定义消息发送20250105
|
||
*/
|
||
public function sendJpush($arr)
|
||
{
|
||
$receid = $arr['receid'];
|
||
if(isempt($receid))return;
|
||
$toregid= array();
|
||
//$this->rock->debugs($arr,'sendJpush');
|
||
$rows = m('logintoken')->getall('`uid` in('.$receid.') AND `online`=1 AND `ispush`=1');
|
||
foreach($rows as $k=>$rs){
|
||
$regid = arrvalue($rs,'regid');
|
||
if(!isempt($regid))$toregid[] = $regid;
|
||
}
|
||
if(!$toregid)return;
|
||
$runurl = c('xinhu')->geturlstr('jpushmess', array(
|
||
'msgcont' => $this->rock->jm->base64encode(json_encode($arr)),
|
||
'toregid' => join(',', $toregid)
|
||
));
|
||
$str = c('curl')->getcurl($runurl);
|
||
return 'ok';
|
||
}
|
||
} |