sylive_order

This commit is contained in:
xiaoyu
2023-10-06 13:13:01 +08:00
parent 7bb348411e
commit d25383b537
4 changed files with 33 additions and 5 deletions
@@ -260,6 +260,7 @@ class Wx extends Common{
!$row_wechat && $row_wechat = $this->user_model->get(['status'=>0,'userId'=>$ma_user['userId']]);//普通用户角色
$this->uid = $row_wechat['userId'];
}
$act_user = $this->act_user_model->get(['activityId'=>$param['a_id'],'userId'=>$this->uid]);
if(!$act_user && $param['a_id']){
$act_data = [
@@ -301,11 +302,25 @@ class Wx extends Common{
if($act_user['levelId3']!=$row_wechat['levelId3']){
$update_ac_user['levelId3'] = $row_wechat['levelId3'];
}
if($param['cf_uid']){
$p_act_user = $this->act_user_model->get(['userId'=>$param['cf_uid'],'activityId'=>$param['a_id']],'userId,channelId');
$update_ac_user['pid'] = $p_act_user['userId'];
}
$update_ac_user && $this->act_user_model->update($update_ac_user,['id'=>$act_user['id']]);
}
$_SESSION[self::SESSION_KEY]['userId'] = $this->uid;
$_SESSION[self::SESSION_KEY]['act_uid'] = $act_user['id'];
echo ("<script>setTimeout('window.location.reload()', 1);</script>");exit;
}else{
//更新pid
$skey = $this->input->get('skey');
$param = $this->myencryption->base64url_decode($skey);
$act_user = $this->act_user_model->get(['activityId'=>$param['a_id'],'userId'=>$this->uid]);
if($param['cf_uid']){
$p_act_user = $this->act_user_model->get(['userId'=>$param['cf_uid'],'activityId'=>$param['a_id']],'userId,channelId');
$update_ac_user['pid'] = $p_act_user['userId'];
}
$update_ac_user && $this->act_user_model->update($update_ac_user,['id'=>$act_user['id']]);
}
return $this->$method();
} catch(Hd_exception $e){//处理异常
+7 -2
View File
@@ -156,8 +156,13 @@ class Item extends Wx{
}
$user = $this->user_model->get(['userId'=>$this->uid]);
$act_user = $this->act_user_model->get(['userId'=>$this->uid,'activityId'=>$a_id]);
$p_user = [];
$act_user['channelId'] && $p_user = $this->act_user_model->get(['userId'=>$act_user['channelId'],'activityId'=>$a_id]);
if($act_user['channelId'] != $act_user['pid']) {
$p_user = $this->act_user_model->get(['userId'=>$act_user['pid'], 'activityId'=>$a_id]);
} else{
$p_user = $this->act_user_model->get(['userId'=>$act_user['channelId'], 'activityId'=>$a_id]);
}
$unpay = $this->market_sylive_order_model->get(['itemId'=>$itemId,'activityId'=>$a_id,'status'=>0,'userId'=>$this->uid,'expireTime>'=>time(),'type'=>0]);
if(!$unpay){
$mb_count = $redis_obj->sCard($mb_key); //获取集合中用户数量
@@ -68,10 +68,16 @@ class Notify extends CI_Controller {
if($res){
$act_user = $this->act_user_model->get(['userId'=>$order['userId'],'activityId'=>$order['activityId']]);
if($kpi == 'order') {
$cf_uid = $act_user['channelId'] == $act_user['pid'] ? $act_user['channelId'] : $act_user['pid'];
}else{
$cf_uid = $act_user['channelId'];
}
$params = [
'a_id' => $order['activityId'],
'uid' => $order['userId'],
'cf_uid' => $act_user['channelId'],
'cf_uid' => $cf_uid,
'kpi' => $kpi,
'tagId' => $order['id'],
'jsondata'=> ['order_id'=>$order['id'],'sid'=>$sid,'mch_id'=>$this->mch_id],
@@ -127,7 +127,7 @@ class groupsOrder extends BaseController
foreach ($res as $v) {
$consultant = $this->consultantGet(['activityId' => $v['activityId'], 'userId' => $v['userId']
, 'levelId1' => $v['levelId1'], 'levelId2' => $v['levelId2'], 'levelId3' => $v['levelId3']
, 'bizId' => $v['bizId'], 'cfUserId' => $v['cfUserId']]);
, 'bizId' => $v['bizId'], 'cfUserId' => $v['cfUserId'], 'itemId' => $v['itemId']]);
$insiders = $map_user[$v['userId']] ? '是' : '否';//内部人员
$list1 = [
'id' => $v['id'], 'sid' => $v['sid'], 'uname' => $v['uname'], 'mobile' => $v['mobile'], 'itemTitle' => $v['itemTitle']
@@ -214,8 +214,9 @@ class groupsOrder extends BaseController
$levelId3 = intval($params['levelId3']);
$bizId = intval($params['bizId']);
$cfUserId = intval($params['cfUserId']);
$itemId = intval($params['itemId']);
if (!$bizId && $params['userId']) {
$re = $this->mdSyliveActivityKpidata->get(['activityId' => $params['activityId'], 'userId' => $params['userId'], 'kpi' => 'order']);
$re = $this->mdSyliveActivityKpidata->get(['activityId' => $params['activityId'], 'userId' => $params['userId'], 'itemId' => $itemId]);
if ($re) {
$levelId1 = $re['levelId1'];
$levelId2 = $re['levelId2'];
@@ -247,6 +248,7 @@ class groupsOrder extends BaseController
$consultantMobile = $re_user['mobile'];
}
}
return ['stores' => $stores, 'consultant' => $consultant, 'consultantMobile' => $consultantMobile, 'levelName1' => $levelName1,
'levelName2' => $levelName2, 'levelName3' => $levelName3];
}