market_groups_1219
This commit is contained in:
dengbw
@@ -640,146 +640,173 @@ class GroupsStatistics extends BaseController
|
||||
!$page && $page = 1;
|
||||
!$limit && $limit = 10;
|
||||
$list = [];
|
||||
!$sort && $sort = 'browse';
|
||||
!$order && $order = 'desc';
|
||||
if ($sort == 'order' && !$day) {
|
||||
$sort_order = 'orderTotal ' . $order;
|
||||
} else {
|
||||
$sort_order = $sort . ' ' . $order;
|
||||
}
|
||||
if ($day) {
|
||||
$where = $where_order = $where_sort = ['activityId' => $activityId, 'day' => $day, 'cfUserId>' => 0, 'kpi' => $sort];
|
||||
if ($sort == 'order') {
|
||||
$itemId && $where['itemId'] = $itemId;
|
||||
}
|
||||
$count = $this->mdSyliveActivityKpidata->count($where, 'cfUserId');
|
||||
if ($count) {
|
||||
$res = $this->mdSyliveActivityKpidata->select_groupby('cfUserId', $where, "total {$order},id desc", $page, $limit
|
||||
, "cfUserId,levelId1,levelId2,levelId3,bizId,count(id) as total");
|
||||
$groups_ids = $userIds = [];
|
||||
foreach ($res as $v) {
|
||||
if ($v['levelId1'] && !in_array($v['levelId1'], $groups_ids)) {
|
||||
$groups_ids[] = $v['levelId1'];
|
||||
}
|
||||
if ($v['levelId2'] && !in_array($v['levelId2'], $groups_ids)) {
|
||||
$groups_ids[] = $v['levelId2'];
|
||||
}
|
||||
if ($v['levelId3'] && !in_array($v['levelId3'], $groups_ids)) {
|
||||
$groups_ids[] = $v['levelId3'];
|
||||
}
|
||||
if ($v['bizId'] && !in_array($v['bizId'], $groups_ids)) {
|
||||
$groups_ids[] = $v['bizId'];
|
||||
}
|
||||
$userIds[] = $v['cfUserId'];
|
||||
}
|
||||
$str_groups = $groups_ids ? implode(',', $groups_ids) : -1;
|
||||
$map_groups = $this->mdSyliveGroups->map('groupsId', 'groupsName',
|
||||
["groupsId in({$str_groups})" => null, 'activityId' => $activityId, 'status>=' => 0]);
|
||||
$str_user = $userIds ? implode(',', $userIds) : -1;
|
||||
$map_user = $this->mdSyliveUser->map('userId', 'uname', ["userId in({$str_user})" => null]);
|
||||
foreach ($res as $v) {
|
||||
$cfUserId = intval($v['cfUserId']);
|
||||
$levelName1 = $levelName2 = $levelName3 = $bizName = $consultantName = '-';
|
||||
$map_groups[$v['levelId1']] && $levelName1 = $map_groups[$v['levelId1']];
|
||||
$map_groups[$v['levelId2']] && $levelName2 = $map_groups[$v['levelId2']];
|
||||
$map_groups[$v['levelId3']] && $levelName3 = $map_groups[$v['levelId3']];
|
||||
$map_groups[$v['bizId']] && $bizName = $map_groups[$v['bizId']];
|
||||
$map_user[$cfUserId] && $consultantName = $map_user[$cfUserId];
|
||||
$where_sort['cfUserId'] = $cfUserId;
|
||||
if ($sort == 'browse') {
|
||||
$browse = $v['total'];
|
||||
} else {
|
||||
$where_sort['kpi'] = 'browse';
|
||||
$browse = $this->mdSyliveActivityKpidata->count($where_sort);
|
||||
}
|
||||
if ($sort == 'subscribe') {
|
||||
$subscribe = $v['total'];
|
||||
} else {
|
||||
$where_sort['kpi'] = 'subscribe';
|
||||
$subscribe = $this->mdSyliveActivityKpidata->count($where_sort);
|
||||
}
|
||||
if ($sort == 'watch') {
|
||||
$watch = $v['total'];
|
||||
} else {
|
||||
$where_sort['kpi'] = 'watch';
|
||||
$watch = $this->mdSyliveActivityKpidata->count($where_sort);
|
||||
}
|
||||
if ($sort == 'order') {
|
||||
$order = $v['total'];
|
||||
} else {
|
||||
$where_order['kpi'] = 'order';
|
||||
$where_order['cfUserId'] = $cfUserId;
|
||||
$itemId && $where_order['itemId'] = $itemId;
|
||||
$order = $this->mdSyliveActivityKpidata->count($where_order);
|
||||
}
|
||||
$list[] = ['levelName1' => $levelName1, 'levelName2' => $levelName2, 'levelName3' => $levelName3,
|
||||
'bizName' => $bizName, 'consultantName' => $consultantName, 'browse' => $browse,
|
||||
'subscribe' => $subscribe, 'watch' => $watch, 'order' => $order];
|
||||
}
|
||||
}
|
||||
} else {
|
||||
if ($sort == 'order' && $itemId) {//有订单排序与商品id，区分订单搜索
|
||||
$where = ['activityId' => $activityId, 'itemId' => $itemId, 'cfUserId>' => 0, 'kpi' => $sort];
|
||||
$count = $this->mdSyliveActivityKpidata->count($where, 'cfUserId');
|
||||
$count = 0;
|
||||
$re = $this->mdSyliveActivity->get(['activityId' => $activityId]);
|
||||
if ($re) {
|
||||
$channelId = intval($re['channelId']);
|
||||
!$sort && $sort = 'browse';
|
||||
!$order && $order = 'desc';
|
||||
if ($sort == 'order' && !$day) {
|
||||
$sort_order = 'orderTotal ' . $order;
|
||||
} else {
|
||||
$where = ['activityId' => $activityId, 'status>=' => 0];
|
||||
$count = $this->mdSyliveGroupsUser->count($where);
|
||||
$sort_order = $sort . ' ' . $order;
|
||||
}
|
||||
if ($count) {
|
||||
if ($day) {
|
||||
$createTimeStart = strtotime($day . ' 00:00:00');
|
||||
$createTimeEnd = strtotime($day . ' 23:59:59');
|
||||
$where = $where_order = $where_sort = ['activityId' => $activityId, 'day' => $day, 'cfUserId>' => 0, 'kpi' => $sort];
|
||||
if ($sort == 'order') {
|
||||
$itemId && $where['itemId'] = $itemId;
|
||||
}
|
||||
$count = $this->mdSyliveActivityKpidata->count($where, 'cfUserId');
|
||||
if ($count) {
|
||||
$res = $this->mdSyliveActivityKpidata->select_groupby('cfUserId', $where, "total {$order},id desc", $page, $limit
|
||||
, "cfUserId,levelId1,levelId2,levelId3,bizId,count(id) as total");
|
||||
$groups_ids = $userIds = [];
|
||||
foreach ($res as $v) {
|
||||
if ($v['levelId1'] && !in_array($v['levelId1'], $groups_ids)) {
|
||||
$groups_ids[] = $v['levelId1'];
|
||||
}
|
||||
if ($v['levelId2'] && !in_array($v['levelId2'], $groups_ids)) {
|
||||
$groups_ids[] = $v['levelId2'];
|
||||
}
|
||||
if ($v['levelId3'] && !in_array($v['levelId3'], $groups_ids)) {
|
||||
$groups_ids[] = $v['levelId3'];
|
||||
}
|
||||
if ($v['bizId'] && !in_array($v['bizId'], $groups_ids)) {
|
||||
$groups_ids[] = $v['bizId'];
|
||||
}
|
||||
$userIds[] = $v['cfUserId'];
|
||||
}
|
||||
$str_groups = $groups_ids ? implode(',', $groups_ids) : -1;
|
||||
$map_groups = $this->mdSyliveGroups->map('groupsId', 'groupsName',
|
||||
["groupsId in({$str_groups})" => null, 'activityId' => $activityId, 'status>=' => 0]);
|
||||
$str_user = $userIds ? implode(',', $userIds) : -1;
|
||||
$map_user = $this->mdSyliveUser->map('userId', 'uname', ["userId in({$str_user})" => null]);
|
||||
foreach ($res as $v) {
|
||||
$cfUserId = intval($v['cfUserId']);
|
||||
$levelName1 = $levelName2 = $levelName3 = $bizName = $consultantName = '-';
|
||||
$map_groups[$v['levelId1']] && $levelName1 = $map_groups[$v['levelId1']];
|
||||
$map_groups[$v['levelId2']] && $levelName2 = $map_groups[$v['levelId2']];
|
||||
$map_groups[$v['levelId3']] && $levelName3 = $map_groups[$v['levelId3']];
|
||||
$map_groups[$v['bizId']] && $bizName = $map_groups[$v['bizId']];
|
||||
$map_user[$cfUserId] && $consultantName = $map_user[$cfUserId];
|
||||
$where_sort['cfUserId'] = $cfUserId;
|
||||
if ($sort == 'browse') {
|
||||
$browse = $v['total'];
|
||||
} else {
|
||||
$where_sort['kpi'] = 'browse';
|
||||
$browse = $this->mdSyliveActivityKpidata->count($where_sort);
|
||||
}
|
||||
if ($sort == 'subscribe') {
|
||||
$subscribe = $v['total'];
|
||||
} else {
|
||||
$where_sort['kpi'] = 'subscribe';
|
||||
$subscribe = $this->mdSyliveActivityKpidata->count($where_sort);
|
||||
}
|
||||
if ($sort == 'watch') {
|
||||
$watch = $v['total'];
|
||||
} else {
|
||||
$where_sort['kpi'] = 'watch';
|
||||
$watch = $this->mdSyliveActivityKpidata->count($where_sort);
|
||||
}
|
||||
if ($sort == 'order') {
|
||||
$order = $v['total'];
|
||||
} else {
|
||||
$where_order['kpi'] = 'order';
|
||||
$where_order['cfUserId'] = $cfUserId;
|
||||
$itemId && $where_order['itemId'] = $itemId;
|
||||
$order = $this->mdSyliveActivityKpidata->count($where_order);
|
||||
}
|
||||
$livePV = $watchDuration = 0;
|
||||
if ($limit == 10000 && $channelId) {//导出
|
||||
$livePV = $this->mdSyliveViewlog->count(['cfUserId' => $cfUserId, 'activityId' => $activityId
|
||||
, 'createTime>=' => $createTimeStart, 'createTime<=' => $createTimeEnd]);
|
||||
$re_sum = $this->mdSyliveViewlog->sum('playDuration', ['cfUserId' => $cfUserId, 'activityId' => $activityId
|
||||
, 'createTime>=' => $createTimeStart, 'createTime<=' => $createTimeEnd]);
|
||||
if ($re_sum['playDuration']) {
|
||||
$playDuration = ceil($re_sum['playDuration'] / 60);
|
||||
$watchDuration = round($playDuration / $livePV);
|
||||
}
|
||||
}
|
||||
$list[] = ['levelName1' => $levelName1, 'levelName2' => $levelName2, 'levelName3' => $levelName3,
|
||||
'bizName' => $bizName, 'consultantName' => $consultantName, 'browse' => $browse,
|
||||
'subscribe' => $subscribe, 'watch' => $watch, 'order' => $order, 'livePV' => $livePV, 'watchDuration' => $watchDuration];
|
||||
}
|
||||
}
|
||||
} else {
|
||||
if ($sort == 'order' && $itemId) {//有订单排序与商品id，区分订单搜索
|
||||
$res = $this->mdSyliveActivityKpidata->select_groupby('cfUserId', $where, "orderTotal {$order},id desc"
|
||||
, $page, $limit, "cfUserId,levelId1,levelId2,levelId3,bizId,count(id) as orderTotal");
|
||||
$where = ['activityId' => $activityId, 'itemId' => $itemId, 'cfUserId>' => 0, 'kpi' => $sort];
|
||||
$count = $this->mdSyliveActivityKpidata->count($where, 'cfUserId');
|
||||
} else {
|
||||
$res = $this->mdSyliveGroupsUser->select($where, "{$sort_order},groupsUserId desc", $page, $limit,
|
||||
'userId as cfUserId,levelId1,levelId2,levelId3,bizId,browse,subscribe,orderTotal,watch');
|
||||
$where = ['activityId' => $activityId, 'status>=' => 0];
|
||||
$count = $this->mdSyliveGroupsUser->count($where);
|
||||
}
|
||||
$groups_ids = $userIds = [];
|
||||
foreach ($res as $v) {
|
||||
if ($v['levelId1'] && !in_array($v['levelId1'], $groups_ids)) {
|
||||
$groups_ids[] = $v['levelId1'];
|
||||
}
|
||||
if ($v['levelId2'] && !in_array($v['levelId2'], $groups_ids)) {
|
||||
$groups_ids[] = $v['levelId2'];
|
||||
}
|
||||
if ($v['levelId3'] && !in_array($v['levelId3'], $groups_ids)) {
|
||||
$groups_ids[] = $v['levelId3'];
|
||||
}
|
||||
if ($v['bizId'] && !in_array($v['bizId'], $groups_ids)) {
|
||||
$groups_ids[] = $v['bizId'];
|
||||
}
|
||||
$userIds[] = $v['cfUserId'];
|
||||
}
|
||||
$str_groups = $groups_ids ? implode(',', $groups_ids) : -1;
|
||||
$map_groups = $this->mdSyliveGroups->map('groupsId', 'groupsName',
|
||||
["groupsId in({$str_groups})" => null, 'activityId' => $activityId, 'status>=' => 0]);
|
||||
$str_user = $userIds ? implode(',', $userIds) : -1;
|
||||
$map_user = $this->mdSyliveUser->map('userId', 'uname', ["userId in({$str_user})" => null]);
|
||||
foreach ($res as $v) {
|
||||
$cfUserId = intval($v['cfUserId']);
|
||||
$levelName1 = $levelName2 = $levelName3 = $bizName = $consultantName = '-';
|
||||
$map_groups[$v['levelId1']] && $levelName1 = $map_groups[$v['levelId1']];
|
||||
$map_groups[$v['levelId2']] && $levelName2 = $map_groups[$v['levelId2']];
|
||||
$map_groups[$v['levelId3']] && $levelName3 = $map_groups[$v['levelId3']];
|
||||
$map_groups[$v['bizId']] && $bizName = $map_groups[$v['bizId']];
|
||||
$map_user[$cfUserId] && $consultantName = $map_user[$cfUserId];
|
||||
if ($sort != 'order' && $itemId) {//有商品id，区分订单
|
||||
$order = $this->mdSyliveActivityKpidata->count(['kpi' => 'order', 'cfUserId' => $cfUserId, 'itemId' => $itemId, 'activityId' => $activityId]);
|
||||
if ($count) {
|
||||
if ($sort == 'order' && $itemId) {//有订单排序与商品id，区分订单搜索
|
||||
$res = $this->mdSyliveActivityKpidata->select_groupby('cfUserId', $where, "orderTotal {$order},id desc"
|
||||
, $page, $limit, "cfUserId,levelId1,levelId2,levelId3,bizId,count(id) as orderTotal");
|
||||
} else {
|
||||
$order = $v['orderTotal'];
|
||||
$res = $this->mdSyliveGroupsUser->select($where, "{$sort_order},groupsUserId desc", $page, $limit,
|
||||
'userId as cfUserId,levelId1,levelId2,levelId3,bizId,browse,subscribe,orderTotal,watch');
|
||||
}
|
||||
if ($sort == 'order' && $itemId) {//只改变订单数值，其它不变
|
||||
$re = $this->mdSyliveGroupsUser->get(['userId' => $cfUserId, 'activityId' => $activityId], 'browse,subscribe,watch');
|
||||
$v['browse'] = intval($re['browse']);
|
||||
$v['subscribe'] = intval($re['subscribe']);
|
||||
$v['watch'] = intval($re['watch']);
|
||||
$groups_ids = $userIds = [];
|
||||
foreach ($res as $v) {
|
||||
if ($v['levelId1'] && !in_array($v['levelId1'], $groups_ids)) {
|
||||
$groups_ids[] = $v['levelId1'];
|
||||
}
|
||||
if ($v['levelId2'] && !in_array($v['levelId2'], $groups_ids)) {
|
||||
$groups_ids[] = $v['levelId2'];
|
||||
}
|
||||
if ($v['levelId3'] && !in_array($v['levelId3'], $groups_ids)) {
|
||||
$groups_ids[] = $v['levelId3'];
|
||||
}
|
||||
if ($v['bizId'] && !in_array($v['bizId'], $groups_ids)) {
|
||||
$groups_ids[] = $v['bizId'];
|
||||
}
|
||||
$userIds[] = $v['cfUserId'];
|
||||
}
|
||||
$str_groups = $groups_ids ? implode(',', $groups_ids) : -1;
|
||||
$map_groups = $this->mdSyliveGroups->map('groupsId', 'groupsName',
|
||||
["groupsId in({$str_groups})" => null, 'activityId' => $activityId, 'status>=' => 0]);
|
||||
$str_user = $userIds ? implode(',', $userIds) : -1;
|
||||
$map_user = $this->mdSyliveUser->map('userId', 'uname', ["userId in({$str_user})" => null]);
|
||||
foreach ($res as $v) {
|
||||
$cfUserId = intval($v['cfUserId']);
|
||||
$levelName1 = $levelName2 = $levelName3 = $bizName = $consultantName = '-';
|
||||
$map_groups[$v['levelId1']] && $levelName1 = $map_groups[$v['levelId1']];
|
||||
$map_groups[$v['levelId2']] && $levelName2 = $map_groups[$v['levelId2']];
|
||||
$map_groups[$v['levelId3']] && $levelName3 = $map_groups[$v['levelId3']];
|
||||
$map_groups[$v['bizId']] && $bizName = $map_groups[$v['bizId']];
|
||||
$map_user[$cfUserId] && $consultantName = $map_user[$cfUserId];
|
||||
if ($sort != 'order' && $itemId) {//有商品id，区分订单
|
||||
$order = $this->mdSyliveActivityKpidata->count(['kpi' => 'order', 'cfUserId' => $cfUserId, 'itemId' => $itemId, 'activityId' => $activityId]);
|
||||
} else {
|
||||
$order = $v['orderTotal'];
|
||||
}
|
||||
if ($sort == 'order' && $itemId) {//只改变订单数值，其它不变
|
||||
$re = $this->mdSyliveGroupsUser->get(['userId' => $cfUserId, 'activityId' => $activityId], 'browse,subscribe,watch');
|
||||
$v['browse'] = intval($re['browse']);
|
||||
$v['subscribe'] = intval($re['subscribe']);
|
||||
$v['watch'] = intval($re['watch']);
|
||||
}
|
||||
$browse = intval($v['browse']);
|
||||
$subscribe = intval($v['subscribe']);
|
||||
$watch = intval($v['watch']);
|
||||
$order = intval($order);
|
||||
$livePV = $watchDuration = 0;
|
||||
if ($limit == 10000 && $channelId) {//导出
|
||||
$livePV = $this->mdSyliveViewlog->count(['cfUserId' => $cfUserId, 'activityId' => $activityId]);
|
||||
$re_sum = $this->mdSyliveViewlog->sum('playDuration', ['cfUserId' => $cfUserId, 'activityId' => $activityId]);
|
||||
if ($re_sum['playDuration']) {
|
||||
$playDuration = ceil($re_sum['playDuration'] / 60);
|
||||
$watchDuration = round($playDuration / $livePV);
|
||||
}
|
||||
}
|
||||
$list[] = ['levelName1' => $levelName1, 'levelName2' => $levelName2, 'levelName3' => $levelName3,
|
||||
'bizName' => $bizName, 'consultantName' => $consultantName, 'browse' => $browse,
|
||||
'subscribe' => $subscribe, 'watch' => $watch, 'order' => $order, 'livePV' => $livePV, 'watchDuration' => $watchDuration];
|
||||
}
|
||||
$browse = intval($v['browse']);
|
||||
$subscribe = intval($v['subscribe']);
|
||||
$watch = intval($v['watch']);
|
||||
$order = intval($order);
|
||||
$list[] = ['levelName1' => $levelName1, 'levelName2' => $levelName2, 'levelName3' => $levelName3,
|
||||
'bizName' => $bizName, 'consultantName' => $consultantName, 'browse' => $browse,
|
||||
'subscribe' => $subscribe, 'watch' => $watch, 'order' => $order];
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
@@ -65,7 +65,7 @@ class GroupsUser extends BaseController
|
||||
$roleName = '管理员';
|
||||
}
|
||||
$list[] = [
|
||||
'groupsUserId' => $v['groupsUserId'], 'uname' => $uname, 'nickname' => $nickname, 'mobile' => $mobile
|
||||
'groupsUserId' => $v['groupsUserId'], 'userId' => $v['userId'],'uname' => $uname, 'nickname' => $nickname, 'mobile' => $mobile
|
||||
, 'groupsId' => $groupsId, 'roleName' => $roleName, 'status' => $status, 'createTime' => $createTime];
|
||||
}
|
||||
}
|
||||
|
||||
@@ -57,7 +57,7 @@ class Team extends BaseController
|
||||
$res[$k]['teamId'] = intval($v['teamId']);
|
||||
$res[$k]['parentId'] = intval($v['parentId']);
|
||||
$res[$k]['sortNumber'] = intval($v['sortNumber']);
|
||||
$res[$k]['organizationId'] = $v['organizationId'] ? $v['organizationId'] : '';
|
||||
$res[$k]['organizationId'] = $v['organizationId'] ? intval($v['organizationId']) : '';
|
||||
$city = $logo = [];
|
||||
if ($v['cityId']) {
|
||||
$city[] = $v['provinceId'];
|
||||
|
||||
Reference in New Issue
Block a user