|
@@ -35,7 +35,7 @@ class Events
|
|
|
|
|
|
App::initCommon();
|
|
|
|
|
|
- $info = Db::name('test')->insertGetId(['msg'=>'onWorkerStart','datetime'=>date('Y-m-d H:i:s')]);
|
|
|
+ $info = Db::name('gateway_test')->insertGetId(['msg'=>'onWorkerStart','datetime'=>date('Y-m-d H:i:s')]);
|
|
|
}
|
|
|
|
|
|
/**
|
|
@@ -47,7 +47,7 @@ class Events
|
|
|
{
|
|
|
echo $message.PHP_EOL;
|
|
|
file_put_contents('1.json',$message.PHP_EOL,FILE_APPEND);
|
|
|
- $info = Db::name('test')->insertGetId(['msg'=>'[msg]'.$message,'datetime'=>date('Y-m-d H:i:s')]);
|
|
|
+ $info = Db::name('gateway_test')->insertGetId(['msg'=>'[msg]'.$message,'datetime'=>date('Y-m-d H:i:s')]);
|
|
|
return;
|
|
|
|
|
|
/* $message = json_decode($message,true);
|
|
@@ -92,7 +92,8 @@ class Events
|
|
|
private static function changestatus($message){
|
|
|
//dump($message);
|
|
|
if(isset($message['uid']) && isset($message['value'])){
|
|
|
- redis_set($message['uid'],$message['value']);
|
|
|
+ $redis = newredis();
|
|
|
+ $redis->set('gg_matching_uid_'.$message['uid'], $message['value'], null);
|
|
|
}
|
|
|
return;
|
|
|
}
|
|
@@ -131,7 +132,7 @@ class Events
|
|
|
}
|
|
|
|
|
|
public static function onWorkerStop(){
|
|
|
- $info = Db::name('test')->insertGetId(['msg'=>'onWorkerStop','datetime'=>date('Y-m-d H:i:s')]);
|
|
|
+ $info = Db::name('gateway_test')->insertGetId(['msg'=>'onWorkerStop','datetime'=>date('Y-m-d H:i:s')]);
|
|
|
}
|
|
|
|
|
|
}
|