Merge branch 'hot/deposit' of wmtx/sdk into master

读写分离数据同步问题
master
张谷诚 5 years ago committed by Gogs
commit a61d1860af

@ -508,18 +508,19 @@ class BaseController extends Controller {
*/ */
protected function rechargeAwardPoint($user_id, $pay_amount){ protected function rechargeAwardPoint($user_id, $pay_amount){
$point_recorddd=M('point_record','tab_'); $point_recorddd=M('point_record','tab_');
$user = M("user","tab_")->find($user_id); // $user = M("user","tab_")->find($user_id);
if(empty($user_id)){ // if(empty($user_id)){
return true; // return true;
} // }
//奖励用户积分 //奖励用户积分
$point_type = $this->getPointType("recharge_spend"); $point_type = $this->getPointType("recharge_spend");
$point = intval($point_type['point'] * $pay_amount); $point = intval($point_type['point'] * $pay_amount);
$point_recorddd->startTrans(); $point_recorddd->startTrans();
$user_result = false;
if($point > 0){ if($point > 0){
$user['point'] += $point; // $user['point'] += $point;
//积分记录 //积分记录
$data['user_id'] = $user_id; $data['user_id'] = $user_id;
@ -528,8 +529,10 @@ class BaseController extends Controller {
$data['create_time'] = time(); $data['create_time'] = time();
$data['type'] = 1; $data['type'] = 1;
$point_result = M("point_record","tab_")->add($data);//积分记录存储 $point_result = M("point_record","tab_")->add($data);//积分记录存储
$user_result = M("user","tab_")->where(array(
'id' => $user_id
))->setInc("point", $point);//被邀请人积分存储
} }
$user_result = M("user","tab_")->save($user);//被邀请人积分存储
if($point_result === false || $user_result === false){ if($point_result === false || $user_result === false){
$point_recorddd->rollback(); $point_recorddd->rollback();

Loading…
Cancel
Save