|
@@ -41,9 +41,9 @@ class PlayerJob extends Job
|
|
|
// 这里的逻辑会在 ConsumerProcess 进程中执行
|
|
|
// var_dump($this->params);
|
|
|
|
|
|
- $this->recode($this->params['player_id'],$this->params['user_id']);
|
|
|
+ $res = $this->recode($this->params['player_id'],$this->params['user_id']);
|
|
|
|
|
|
- LogUtil::info('处理结果', self::LOG_MODULE, __FUNCTION__);
|
|
|
+ LogUtil::info('处理结果', self::LOG_MODULE, __FUNCTION__,$res);
|
|
|
LogUtil::close();
|
|
|
}
|
|
|
|
|
@@ -54,7 +54,7 @@ class PlayerJob extends Job
|
|
|
|
|
|
//给选手加票
|
|
|
$update_rs = Db::table('vote_player')->where('id',$player_id)->increment('votes');
|
|
|
- if($update_rs === false){
|
|
|
+ if(!$update_rs){
|
|
|
Db::rollBack();
|
|
|
return false;
|
|
|
}
|
|
@@ -67,7 +67,7 @@ class PlayerJob extends Job
|
|
|
'createdate' => strtotime(date('Y-m-d')),
|
|
|
'createtime' => time(),
|
|
|
];
|
|
|
- $log_id = Db::table('vote_record')->insertGetId($data);
|
|
|
+ $log_id = Db::table('vote_record')->insert($data);
|
|
|
if(!$log_id){
|
|
|
Db::rollBack();
|
|
|
return false;
|