news_server

scripts/crontab/push/news_server.php

@@ -136,9 +136,16 @@ $serv->on('Message', function($server, $frame) use($conf){
            //echo $res;
             $matchs=array();
             preg_match("/member_id\|i:(\d+)/i",$sessData,$matchs);//现在
+            $storeMatchs=array();
+            preg_match("/store_id\|i:(\d+)/i",$sessData,$storeMatchs);//现在
            // preg_match("/member_id\|i[^\d]{1,3}(\d+)/i",$res,$matchs);过去
             $memberId=$matchs[1];
-            echo "success".$memberId.'login||||';
+            if(isset($storeMatchs[1]) && $storeMatchs[1]>0 ){
+                $storeId=$storeMatchs[1];
+            }else{
+                $storeId=0;
+            }
+            echo "success:memberid=".$memberId.'login'."\n";
             $redis->expire($realKey,\Our\ApiConst::tenDaySecond);
             if($memberId==(int)$memberId){
                 switch($method) {
@@ -154,7 +161,11 @@ $serv->on('Message', function($server, $frame) use($conf){
                         ];
                         echo 'set:'.KEY_PRE.$memberId,'fd:'.$frame->fd."\r\n";
                         $redis->hSet(KEY_PRE.$memberId,'fd', $frame->fd);
+                        if($storeId){
+                            $redis->hSet(KEY_PRE.$memberId,'store_fd', $frame->fd);
+                        }
                         $server->push($frame->fd,responseJson($async_login_data['status'],$async_login_data['method'],$async_login_data['message'], $async_login_data['data']));
+                        $redis->close();
                         break;
                     default:
                         break;