Commit c1b27da1 authored by wwccw0591's avatar wwccw0591

Merge branch 'master_dev' of git.shenbd.com:qm-develop/shenbd into ccw

parents cebb1463 f7fa4a34
...@@ -153,9 +153,11 @@ class MessageController extends \Our\Controller_AbstractApi { ...@@ -153,9 +153,11 @@ class MessageController extends \Our\Controller_AbstractApi {
} }
public function setAction(){ public function setAction(){
$messageService = \Business\Message\MessageServiceModel::getInstance(); $messageService = \Business\Message\MessageServiceModel::getInstance();
$pushSet['canPush']=$this->req['data']['canPush']; $memberCenterService=\Business\User\MemberCenterServiceModel::getInstance();
$pushSet['sound']=$this->req['data']['sound']; $messageSet=$memberCenterService->getMessageSet($this->memberId);
$pushSet['vibrate']=$this->req['data']['vibrate']; $pushSet['canPush']=!empty($this->req['data']['canPush'])?$this->req['data']['canPush']:$messageSet['canPush'];
$pushSet['sound']=!empty($this->req['data']['sound'])?$this->req['data']['sound']:$messageSet['sound'];
$pushSet['vibrate']=!empty($this->req['data']['vibrate'])?$this->req['data']['vibrate']:$messageSet['vibrate'];
$pushSet['timeDiff']=$this->req['data']['timeDiff']; $pushSet['timeDiff']=$this->req['data']['timeDiff'];
if(isset($pushSet['canPush'])&& isset($pushSet['sound']) && isset($pushSet['vibrate']) ){ if(isset($pushSet['canPush'])&& isset($pushSet['sound']) && isset($pushSet['vibrate']) ){
$res=$messageService->set($this->memberId,$pushSet); $res=$messageService->set($this->memberId,$pushSet);
......
...@@ -48,25 +48,26 @@ class cliOrderClose extends basecli ...@@ -48,25 +48,26 @@ class cliOrderClose extends basecli
$redis->auth($conf['password']); $redis->auth($conf['password']);
} }
$clientPush=\JPush\ClientPush::getInstance(); $clientPush=\JPush\ClientPush::getInstance();
$memberCenterServiceDao=\Business\User\MemberCenterServiceModel::getInstance(); $memberCenterServiceDao=\Business\User\MemberCenterServiceModel::getInstance();
//$messageService=\DAO\MessageHistoryModel::getInstance(); //$messageService=\DAO\MessageHistoryModel::getInstance();
while($pushData=$redis->rPop('push_center')){ while($pushData=$redis->rPop('push_center')){
$addData = unserialize($pushData); $addData = unserialize($pushData);
$addData['message'] = unserialize($addData['message']); $addData['message'] = unserialize($addData['message']);
$res=$memberCenterServiceDao->getMessageSet($addData['toId']); $res=$memberCenterServiceDao->getMessageSet($addData['toId']);
if($res['canPush']==\Our\ApiConst::one){ if($res['canPush']!=\Our\ApiConst::one){
continue; continue;
}else{
if(!empty($res['timeDiff'])){
$timeArr=explode('-',$res['timeDiff']);
if(!empty($timeArr)){
if(\Our\Common::isCurentTimeInSection($timeArr[0],$timeArr[1])){
continue;
}
}
}
} }
// else{
// if(!empty($res['timeDiff'])){
// $timeArr=explode('-',$res['timeDiff']);
// if(!empty($timeArr)){
// if(\Our\Common::isCurentTimeInSection($timeArr[0],$timeArr[1])){
// continue;
// }
// }
// }
//
// }
$clientPush->push($addData); $clientPush->push($addData);
} }
$redis->close(); $redis->close();
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment