admin/liche
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

edit-plan-subscribemsg

Browse Source
This commit is contained in:
lccsw
2022-11-11 19:42:12 +08:00
parent b1e03297b8
commit fbc2122f7e
2 changed files with 72 additions and 21 deletions
Download Patch File Download Diff File Expand all files Collapse all files
api/controllers/plan/Plan.php
+1 -1
View File
@@ -53,7 +53,7 @@ class Plan extends CI_Controller
// $plan[] = array('url' => base_url(array('plan', 'syt', 'subscribemsg')), 'interval' => 1); //私域通模板消息
$plan[] = array('url' => base_url(array('plan', 'syt', 'syn_polyv')), 'interval' => 60); //私域通直播间数据同步
$plan[] = array('url' => base_url(array('plan', 'syt', 'api_viewlog')), 'interval' => 5); //私域通直播间播放日志数据同步
$plan[] = array('url' => base_url(array('plan', 'syt', 'api_viewlog')), 'interval' => 1); //私域通直播间播放日志数据同步
$plan[] = array('url' => base_url(array('plan', 'syt', 'out_time')), 'interval' => 1); //订单过期
$plan[] = array('url' => base_url(array('plan', 'syt', 'union_user')), 'interval' => 1); //直播数据关联用户
api/controllers/plan/Syt.php
+71 -20
View File
@@ -46,14 +46,16 @@ class Syt extends CI_Controller
$where['status'] = 0;
$min_row = $this->mdSytSubscribemsg->get($where,'min(id) as id');
$max_row = $this->mdSytSubscribemsg->get($where,'max(id) as id');
if(($max_row['id']-$min_row['id'])>100){
$ids_arr = [];
for($i=0;$i<$size;$i++){
$ids_arr[] = rand($min_row['id'],$max_row['id']);
}
$ids = implode(',',array_unique($ids_arr));
$ids && $where["id in ({$ids})"] = null;
}
// if(($max_row['id']-$min_row['id'])>1000){
// $ids_arr = [];
// for($i=0;$i<$size;$i++){
// $s_id = rand($min_row['id'],$max_row['id']);
// $s_id += 1;
// $ids_arr[] = $s_id;
// }
// $ids = implode(',',array_unique($ids_arr));
// $ids && $where["id in ({$ids})"] = null;
// }
$res = $this->mdSytSubscribemsg->select($where, 'id asc', 1, $size);
$log = array();
if ($res) {
@@ -127,8 +129,8 @@ class Syt extends CI_Controller
debug_log("开始同步{$item['activityId']}活动直播", $this->log_file, $this->log_dir);
$polyv = new PolyvApi(['channel_id' => $item['channelId']]);
$pl_where = [
'startTime' => strtotime($item['timeStart']) * 1000,
'endTime' => strtotime($item['timeEnd']) * 1000
'startTime' => (strtotime($item['timeStart'])-10*60*60) * 1000,
'endTime' => (strtotime($item['timeEnd'])+24*60*60) * 1000
];
$results = $polyv->getSessionStats($pl_where);
if ($results['status'] == 'success') {
@@ -335,7 +337,17 @@ class Syt extends CI_Controller
$user = $this->user_model->get(['unionid'=>$value['param1']]);
$user && $ac_user = $this->act_user_model->get(['activityId'=>$value['activityId'],'userId'=>$user['userId']]);
if($ac_user['channelId']){
$p_user = $this->user_model->get(['userId'=>$ac_user['channelId']]);
$ac_user['channelId'] && $p_user = $this->user_model->get(['userId'=>$ac_user['channelId']]);
if(!$p_user){
if($ac_user['teamId']){
$t_level_id = $this->sylive_entity->get_team_level($ac_user['teamId']);
$p_user = $t_level_id<3 ? $user : 0;
}
if($ac_user['organizationId']){
$group_id = $this->sylive_entity->get_level($ac_user['organizationId']);
$p_user = $group_id<4 ? $p_user : 0;
}
}
}
if($p_user['teamId']){
$addData['type'] = 1;
@@ -347,8 +359,8 @@ class Syt extends CI_Controller
if($p_user['organizationId']){
$addData['type'] = 0;
$team_lists = $this->sylive_entity->get_level_lists($p_user['organizationId']);
$area_id = $team_lists[0]['organizationId']; //大团长id
$biz_id = $team_lists[1]['organizationId']; //团长id
$area_id = $team_lists[1]['organizationId']; //获取大区id
$biz_id = $team_lists[2]['organizationId']; //获取店铺id
$addData['cfUserId'] = $p_user['userId'];
}
$area_id && $addData['areaId'] = $area_id;
@@ -563,18 +575,20 @@ class Syt extends CI_Controller
if($rows){
foreach ($rows as $key => $val) {
$update = [
'orderTotal' => $this->mdSytActivityKpiData->count(['activityId'=>4,'bizId'=>$val['bizId'],'kpi'=>'order','type'=>0])
'browse' => $this->mdSytActivityKpiData->count(['activityId'=>4,'bizId'=>$val['bizId'],'kpi'=>'browse','type'=>0]),
'subscribe' => $this->mdSytActivityKpiData->count(['activityId'=>4,'bizId'=>$val['bizId'],'kpi'=>'subscribe','type'=>0]),
'orderTotal' => $this->mdSytActivityKpiData->count(['activityId'=>4,'bizId'=>$val['bizId'],'kpi'=>'order','type'=>0]),
'watch' => $this->mdSytActivityKpiData->count(['activityId'=>4,'bizId'=>$val['bizId'],'kpi'=>'watch','type'=>0]),
];
$this->mdSytActivityBiz->update($update,['id'=>$val['id']]);
echo "id:{$val['id']}<br>";
echo "原来订单数{$val['orderTotal']},更新结果:".json_encode($update,JSON_UNESCAPED_UNICODE)."<br>";
echo "id:{$val['id']}原来订单数".json_encode($val,JSON_UNESCAPED_UNICODE)."<br>,更新结果:".json_encode($update,JSON_UNESCAPED_UNICODE)."<br>";
}
}else{
echo '执行结束';
}
}
public function user_order(){
$this->ci->load->model('market/market_sylive_activity_user_model', 'act_user_model');
$this->load->model('market/market_sylive_activity_user_model', 'act_user_model');
$this->load->model('market/market_sylive_activity_kpidata_model','mdSytActivityKpiData');
$page = $this->input->get('page');
$size = $this->input->get('size');
@@ -588,14 +602,51 @@ class Syt extends CI_Controller
if($rows){
foreach ($rows as $key => $val) {
$update = [
'orderTotal' => $this->mdSytActivityKpiData->count(['activityId'=>4,'cfUserId'=>$val['userId'],'kpi'=>'order','type'=>0])
'browse' => $this->mdSytActivityKpiData->count(['activityId'=>4,'cfUserId'=>$val['userId'],'kpi'=>'browse','type'=>0]),
'subscribe' => $this->mdSytActivityKpiData->count(['activityId'=>4,'cfUserId'=>$val['userId'],'kpi'=>'subscribe','type'=>0]),
'orderTotal' => $this->mdSytActivityKpiData->count(['activityId'=>4,'cfUserId'=>$val['userId'],'kpi'=>'order','type'=>0]),
'watch' => $this->mdSytActivityKpiData->count(['activityId'=>4,'cfUserId'=>$val['userId'],'kpi'=>'watch','type'=>0])
];
$this->act_user_model->update($update,['id'=>$val['id']]);
echo "id:{$val['id']}<br>";
echo "原来订单数{$val['orderTotal']},更新结果:".json_encode($update,JSON_UNESCAPED_UNICODE)."<br>";
echo "id:{$val['id']}原来订单数".json_encode($val,JSON_UNESCAPED_UNICODE)."<br>,更新结果:".json_encode($update,JSON_UNESCAPED_UNICODE)."<br>";
}
}else{
echo '执行结束';
}
}
public function up_kpi_jsondata(){
$this->load->model('market/market_sylive_activity_kpidata_model','mdSytActivityKpiData');
$this->load->model('market/market_sylive_order_model','order_model');
$page = $this->input->get('page');
$size = $this->input->get('size');
!$page && $page = 1;
!$size && $size = 20;
$where = [
'activityId' => 4,
'tagId>' => 0,
'jsondata is null' => null,
'kpi' => 'order'
];
$rows = $this->mdSytActivityKpiData->select($where,'id asc',$page,$size);
if($rows){
foreach ($rows as $item) {
$order = $this->order_model->get(['id'=>$item['tagId']]);
if($order){
$jsondata = $item['jsondata'] ? json_decode($item['jsondata'],true) : [];
$jsondata['order_id'] = $order['id'];
$jsondata['sid'] = $order['sid'];
$update = [
'jsondata' => json_encode($jsondata,JSON_UNESCAPED_UNICODE)
];
$this->mdSytActivityKpiData->update($update,['id'=>$item['id']]);
echo "更新成功:".json_encode($update,JSON_UNESCAPED_UNICODE).",kpidata id:{$item['id']}<br>";
}else{
echo "找不到订单:{$item['tagId']},kpidata id:{$item['id']}<br>";
}
}
}
echo $this->mdSytActivityKpiData->db->last_query();exit;
print_r($rows);
}
}