diff --git a/api/controllers/plan/Syt.php b/api/controllers/plan/Syt.php index cbd60084..b19beb1e 100644 --- a/api/controllers/plan/Syt.php +++ b/api/controllers/plan/Syt.php @@ -500,7 +500,8 @@ class Syt extends CI_Controller public function tmp(){ $this->load->model('market/market_sylive_customer_model'); - $this->load->model('market/market_sylive_activity_user_model', 'act_user_model'); + $this->load->model('market/market_sylive_order_model'); + $this->load->library('market/sylive2_entity'); $page = $this->input->get('page'); $size = $this->input->get('size'); !$page && $page = 1; @@ -511,14 +512,19 @@ class Syt extends CI_Controller $rows = $this->market_sylive_customer_model->select($where,'customerId asc',$page,$size); if($rows){ foreach ($rows as $key => $val) { - $p_user = []; - $val['cfUserId'] && $p_user = $this->act_user_model->get(['userId'=>$val['cfUserId'],'activityId'=>9]); - $update = []; - $p_user['bizId'] && $update['bizId'] = $p_user['bizId']; - $p_user['levelId1'] && $update['levelId1'] = $p_user['levelId1']; - $p_user['levelId2'] && $update['levelId2'] = $p_user['levelId2']; - $p_user['levelId3'] && $update['levelId3'] = $p_user['levelId3']; - $update && $this->market_sylive_customer_model->update($update,['customerId'=>$val['customerId']]); + $order = $this->market_sylive_order_model->get(['userId'=>$val['userId'],'activityId'=>9,'itemId'=>12]); + if($order){ + //添加kpi + $params = ['a_id' => 9, 'uid' => $val['userId'],'cf_uid' => $val['cfUserId'], 'kpi' => 'beforeOrder']; + $params['tagId'] = $order['id']; + $params['itemId'] = 12; + $params['jsondata'] = [ + 'sid' => $order['sid'], + 'order_id' => $order['id'] + ]; + $params['c_time'] = strtotime($order['createTime']); + $this->sylive2_entity->kpi_log($params); + } } echo '执行完毕'; }else{ diff --git a/common/libraries/market/Sylive2_entity.php b/common/libraries/market/Sylive2_entity.php index 683b812f..81b2789a 100644 --- a/common/libraries/market/Sylive2_entity.php +++ b/common/libraries/market/Sylive2_entity.php @@ -16,6 +16,7 @@ class Sylive2_entity{ $this->ci->load->model('market/market_sylive_groups_model', 'groups_model'); $this->ci->load->model('market/market_sylive_groups_user_model', 'groups_user_model'); $this->ci->load->model('market/market_sys_dictionary_data_model'); + $this->ci->load->model('market/market_sylive_activity_kpidata_model','mdSytActivityKpiData'); } /** @@ -66,6 +67,11 @@ class Sylive2_entity{ 'createTime' => time(), 'day' => date('Y-m-d') ]; + if($params['c_time']){ //指定创建时间 + $addData['updateTime'] = date('Y-m-d H:i:s',$params['c_time']); + $addData['createTime'] = $params['c_time']; + $addData['day'] = date('Y-m-d',$params['c_time']); + } $act_user['bizId'] && $addData['bizId'] = $act_user['bizId']; $act_user['levelId1'] && $addData['levelId1'] = $act_user['levelId1']; $act_user['levelId2'] && $addData['levelId2'] = $act_user['levelId2']; diff --git a/home/controllers/h5/market/sylive2/Act.php b/home/controllers/h5/market/sylive2/Act.php index 238b8d5e..02d258e5 100644 --- a/home/controllers/h5/market/sylive2/Act.php +++ b/home/controllers/h5/market/sylive2/Act.php @@ -566,7 +566,7 @@ class Act extends Wx { 'itemTitle' => $item['title'], 'itemPrice' => 0, 'totalPrice' => 0, - 'expireTime' => 0,//订单过期时间 + 'expireTime' => 0,//订单过sylive2_entity期时间 'status' => 1, 'payTime' => date('Y-m-d H:i:s'), 'createTime' => date('Y-m-d H:i:s') @@ -578,15 +578,17 @@ class Act extends Wx { $p_user['levelId3'] && $unpay['levelId3'] = $p_user['levelId3']; $p_user['userId'] && $unpay['cfUserId'] = $p_user['userId']; $order_id = $this->market_sylive_order_model->add($unpay); - //添加kpi - $params = ['a_id' => $a_id, 'uid' => $this->uid,'cf_uid' => $act_user_row['channelId'], 'kpi' => 'beforeOrder']; - $order_id && $params['tagId'] = intval($order_id); - $params['itemId'] = $itemId; - $params['jsondata'] = [ - 'sid' => $unpay['sid'], - 'order_id' => intval($order_id) - ]; - $this->sylive2_entity->kpi_log($params); + if(is_numeric($order_id)){ + //添加kpi + $params = ['a_id' => $a_id, 'uid' => $this->uid,'cf_uid' => $act_user_row['channelId'], 'kpi' => 'beforeOrder']; + $order_id && $params['tagId'] = intval($order_id); + $params['itemId'] = $itemId; + $params['jsondata'] = [ + 'sid' => $unpay['sid'], + 'order_id' => intval($order_id) + ]; + $this->sylive2_entity->kpi_log($params); + } } } $redis->delete($key);