dengbw
332 lines
14 KiB
PHP
332 lines
14 KiB
PHP
<?php
|
|
defined('BASEPATH') OR exit('No direct script access allowed');
|
|
require_once APPPATH . 'controllers/api/BaseController.php';
|
|
|
|
/**
|
|
* Notes:私域直播_分组管理
|
|
* Created on: 2022/11/24 17:15
|
|
* Created by: dengbw
|
|
*/
|
|
class Groups extends BaseController
|
|
{
|
|
|
|
public function __construct()
|
|
{
|
|
parent::__construct();
|
|
$this->load->model('market/Market_sylive_groups_model', 'mdSyliveGroups');
|
|
$this->load->model('market/Market_sylive_groups_user_model', 'mdSyliveGroupsUser');
|
|
$this->load->model('market/Market_sylive_user_model', 'mdSyliveUser');
|
|
}
|
|
|
|
/**
|
|
* Notes:获取分组
|
|
* Created on: 2022/9/16 11:11
|
|
* Created by: dengbw
|
|
*/
|
|
public function index_get()
|
|
{
|
|
$activityId = intval($this->input_param('activityId'));
|
|
$unGroupsType = $this->input_param('unGroupsType');
|
|
$where['status>='] = 0;
|
|
$activityId && $where['activityId'] = $activityId;
|
|
$unGroupsType && $where['groupsLevel<>'] = $unGroupsType;
|
|
$sort_order = 'sortNumber asc,groupsId desc';
|
|
$fileds = 'activityId,groupsId,parentId,sortNumber,userFrom,groupsName,ifBiz,statisticsType,originalBizId';
|
|
$res = $this->mdSyliveGroups->select($where, $sort_order, 0, 0, $fileds);
|
|
foreach ($res as $k => $v) {
|
|
$res[$k]['activityId'] = intval($v['activityId']);
|
|
$res[$k]['groupsId'] = intval($v['groupsId']);
|
|
$res[$k]['userFrom'] = intval($v['userFrom']);
|
|
$res[$k]['parentId'] = intval($v['parentId']);
|
|
$res[$k]['sortNumber'] = intval($v['sortNumber']);
|
|
$res[$k]['ifBiz'] = intval($v['ifBiz']);
|
|
$res[$k]['statisticsType'] = $v['statisticsType'] ? intval($v['statisticsType']) : '';
|
|
$res[$k]['originalBizId'] = $v['originalBizId'] ? intval($v['originalBizId']) : '';
|
|
}
|
|
$this->return_response_list($res);
|
|
}
|
|
|
|
/**
|
|
* Notes:查找上级分组
|
|
* Created on: 2022/10/24 15:24
|
|
* Created by: dengbw
|
|
*/
|
|
public function parent_get()
|
|
{
|
|
$parentId = intval($this->input_param('parentId'));
|
|
$sort_order = 'sortNumber asc,groupsId desc';
|
|
$where['status>='] = 0;
|
|
$where['parentId'] = $parentId;
|
|
$res = $this->mdSyliveGroups->select($where, $sort_order, 0, 0, 'groupsId,groupsName');
|
|
$this->return_response_list($res);
|
|
}
|
|
|
|
/**
|
|
* Notes:添加分组
|
|
* Created on: 2022/9/19 16:43
|
|
* Created by: dengbw
|
|
*/
|
|
public function index_post()
|
|
{
|
|
$activityId = intval($this->input_param('activityId'));
|
|
$parentId = intval($this->input_param('parentId'));
|
|
$groupsName = $this->input_param('groupsName');
|
|
$userFrom = intval($this->input_param('userFrom'));
|
|
$sortNumber = intval($this->input_param('sortNumber'));
|
|
$ifBiz = intval($this->input_param('ifBiz'));
|
|
$statisticsType = intval($this->input_param('statisticsType'));
|
|
$originalBizId = intval($this->input_param('originalBizId'));
|
|
if (!$groupsName) {
|
|
$this->return_json('请输入分组名称');
|
|
}
|
|
$groupsLevel = 0;
|
|
if ($parentId) {//判断上级分组
|
|
$re_org = $this->mdSyliveGroups->get(['groupsId' => $parentId]);
|
|
if ($re_org['ifBiz']) {
|
|
$userFrom = $re_org['userFrom'] == 0 ? '门店' : '团队';
|
|
$this->return_json("选择的上级分组{$userFrom}不能保存,请重新选择");
|
|
}
|
|
$re_org['groupsLevel'] == 3 && $ifBiz = 1;//如果上级等级3级，当前分组设为门店
|
|
!$ifBiz && $groupsLevel = $re_org['groupsLevel'] + 1;
|
|
} else {
|
|
$re_org = $this->mdSyliveGroups->get(['parentId' => $parentId]);
|
|
if ($re_org) {
|
|
$this->return_json('请选择上级分组');
|
|
}
|
|
}
|
|
$originalBizId = $ifBiz ? $originalBizId : 0;
|
|
$addDate = ['activityId' => $activityId, 'parentId' => $parentId, 'originalBizId' => $originalBizId, 'groupsName' => $groupsName
|
|
, 'groupsLevel' => $groupsLevel, 'statisticsType' => $statisticsType, 'userFrom' => $userFrom, 'ifBiz' => $ifBiz
|
|
, 'sortNumber' => $sortNumber, 'createTime' => date('Y-m-d H:i:s')];
|
|
$groupsId = $this->mdSyliveGroups->add($addDate);
|
|
if (!$groupsId) {
|
|
$this->return_json('添加分组失败');
|
|
}
|
|
if ($originalBizId) {
|
|
$levelAry = $this->getLevelAry($groupsId);
|
|
$res = $this->mdSyliveUser->select(['bizId' => $originalBizId, 'status>=' => 0], 'userId asc', 0, 0
|
|
, 'userId,organizationId,bizId');
|
|
$addUser = [];
|
|
foreach ($res as $v) {
|
|
$re_user = $this->mdSyliveGroupsUser->get(['activityId' => $activityId, 'userId' => $v['userId'], 'status>=' => 0]);
|
|
if (!$re_user) {
|
|
$type = $v['bizId'] == $v['organizationId'] ? 1 : 0;
|
|
$value = ['userId' => $v['userId'], 'type' => $type, 'activityId' => $activityId
|
|
, 'groupsId' => $groupsId, 'userFrom' => $userFrom, 'createTime' => date('Y-m-d H:i:s')];
|
|
$data = array_merge($value, $levelAry);
|
|
$addUser[] = $data;
|
|
}
|
|
}
|
|
$addUser && $this->mdSyliveGroupsUser->add_batch($addUser);
|
|
}
|
|
$this->return_response();
|
|
}
|
|
|
|
/**
|
|
* Notes:修改分组
|
|
* Created on: 2022/9/19 17:29
|
|
* Created by: dengbw
|
|
*/
|
|
public function index_put()
|
|
{
|
|
$groupsId = intval($this->input_param('groupsId'));
|
|
$parentId = intval($this->input_param('parentId'));
|
|
$groupsName = $this->input_param('groupsName');
|
|
$userFrom = intval($this->input_param('userFrom'));
|
|
$sortNumber = intval($this->input_param('sortNumber'));
|
|
$ifBiz = intval($this->input_param('ifBiz'));
|
|
$statisticsType = intval($this->input_param('statisticsType'));
|
|
$originalBizId = intval($this->input_param('originalBizId'));
|
|
if (!$groupsId) {
|
|
$this->return_json('参数错误');
|
|
}
|
|
if (!$groupsName) {
|
|
$this->return_json('请输入分组名称');
|
|
}
|
|
$re_gro = $this->mdSyliveGroups->get(['groupsId' => $groupsId]);
|
|
$activityId = intval($re_gro['activityId']);
|
|
if ($re_gro && $re_gro['parentId'] != $parentId) {
|
|
$re_user = $this->mdSyliveGroupsUser->get(['groupsId' => $groupsId, 'status>=' => 0, 'activityId' => $activityId]);
|
|
if ($re_user) {
|
|
$this->return_json('此分组已有用户，不能修改上级分组');
|
|
}
|
|
}
|
|
$groupsLevel = 0;
|
|
if ($parentId) {//判断上级分组
|
|
$re_org = $this->mdSyliveGroups->get(['groupsId' => $parentId]);
|
|
if ($re_org['ifBiz']) {
|
|
$userFrom = $re_org['userFrom'] == 0 ? '门店' : '团队';
|
|
$this->return_json("选择的上级分组{$userFrom}不能保存,请重新选择");
|
|
}
|
|
$re_org['groupsLevel'] == 3 && $ifBiz = 1;//如果上级等级3级，当前分组设为门店
|
|
!$ifBiz && $groupsLevel = $re_org['groupsLevel'] + 1;
|
|
} else {
|
|
$re_org = $this->mdSyliveGroups->get(['parentId' => $parentId, 'activityId' => $activityId]);
|
|
if ($re_org && $groupsId != $re_org['groupsId']) {
|
|
$this->return_json('请选择上级分组');
|
|
}
|
|
}
|
|
$originalBizId = $ifBiz ? $originalBizId : 0;
|
|
$upDate = ['parentId' => $parentId, 'originalBizId' => $originalBizId, 'groupsName' => $groupsName, 'groupsLevel' => $groupsLevel,
|
|
'statisticsType' => $statisticsType, 'userFrom' => $userFrom, 'ifBiz' => $ifBiz, 'sortNumber' => $sortNumber];
|
|
$this->mdSyliveGroups->update($upDate, ['groupsId' => $groupsId]);
|
|
if (!$re_gro['originalBizId'] && $originalBizId) {//首次绑定同步用户
|
|
$levelAry = $this->getLevelAry($groupsId);
|
|
$res = $this->mdSyliveUser->select(['bizId' => $originalBizId, 'status>=' => 0], 'userId asc', 0, 0
|
|
, 'userId,organizationId,bizId');
|
|
$addUser = [];
|
|
foreach ($res as $v) {
|
|
$re_user = $this->mdSyliveGroupsUser->get(['activityId' => $activityId, 'userId' => $v['userId'], 'status>=' => 0]);
|
|
if (!$re_user) {
|
|
$type = $v['bizId'] == $v['organizationId'] ? 1 : 0;
|
|
$value = ['userId' => $v['userId'], 'type' => $type, 'activityId' => $activityId
|
|
, 'groupsId' => $groupsId, 'userFrom' => $userFrom, 'createTime' => date('Y-m-d H:i:s')];
|
|
$data = array_merge($value, $levelAry);
|
|
$addUser[] = $data;
|
|
}
|
|
}
|
|
$addUser && $this->mdSyliveGroupsUser->add_batch($addUser);
|
|
}
|
|
$this->return_response();
|
|
}
|
|
|
|
/**
|
|
* Notes:删除分组
|
|
* Created on: 2022/9/19 11:08
|
|
* Created by: dengbw
|
|
*/
|
|
public function index_delete()
|
|
{
|
|
$groupsId = intval($this->input_param('id'));
|
|
if (!$groupsId) {
|
|
$this->return_json('参数错误');
|
|
}
|
|
$ret = $this->mdSyliveGroups->update(['status' => -1], ['groupsId' => $groupsId]);
|
|
if ($ret) {//删除分组用户
|
|
$this->mdSyliveGroupsUser->update(['status' => -1], ['groupsId' => $groupsId]);
|
|
}
|
|
$this->return_response();
|
|
}
|
|
|
|
/**
|
|
* Notes:导出分组所有顾问
|
|
* Created on: 2023/5/6 14:56
|
|
* Created by: dengbw
|
|
*/
|
|
public function consultant_export_get()
|
|
{
|
|
$activityId = $this->inputs['activityId'];
|
|
if (!$activityId) {
|
|
$this->return_json('参数错误');
|
|
}
|
|
$where = ["activityId" => $activityId, "status" => 0];
|
|
$count = $this->mdSyliveGroupsUser->count($where);
|
|
if ($count > 10000) {
|
|
$this->return_json('导出失败,每次导出不能超出10000条数据');
|
|
}
|
|
if ($count == 0) {
|
|
$this->return_json('导出失败,无数据');
|
|
}
|
|
$levels = [];
|
|
$re_gro = $this->mdSyliveGroups->get(['activityId' => $activityId, 'parentId' => 0, 'status>=' => 0]);
|
|
if ($re_gro['statisticsType']) {
|
|
$this->load->model('market/Market_sys_dictionary_data_model', 'mdSysDictionaryData');
|
|
$res_dit = $this->mdSysDictionaryData->select(['status>=' => 0, 'dictId' => $re_gro['statisticsType']], 'sortNumber asc,dictDataId desc'
|
|
, 0, 0, 'dictDataCode,dictDataName');
|
|
foreach ($res_dit as $k => $v) {
|
|
$groupsLevel = intval($v['dictDataCode']);
|
|
$re_gro = $this->mdSyliveGroups->get(['activityId' => $activityId, 'groupsLevel' => $groupsLevel, 'status>=' => 0]);
|
|
if ($re_gro) {
|
|
$levels[] = ['label' => $v['dictDataName'], 'prop' => "levelId{$groupsLevel}"];
|
|
}
|
|
}
|
|
}
|
|
$res = $this->mdSyliveGroupsUser->select($where, "levelId1 asc,bizId asc,groupsUserId asc", 0, 0
|
|
, 'userId,type,userFrom,levelId1,levelId2,levelId3,bizId');
|
|
$list = $userIds = $groupsIds = [];
|
|
foreach ($res as $v) {
|
|
if ($v['levelId1'] && !in_array($v['levelId1'], $groupsIds)) {
|
|
$groupsIds[] = $v['levelId1'];
|
|
}
|
|
if ($v['levelId2'] && !in_array($v['levelId2'], $groupsIds)) {
|
|
$groupsIds[] = $v['levelId2'];
|
|
}
|
|
if ($v['levelId3'] && !in_array($v['levelId3'], $groupsIds)) {
|
|
$groupsIds[] = $v['levelId3'];
|
|
}
|
|
if ($v['bizId'] && !in_array($v['bizId'], $groupsIds)) {
|
|
$groupsIds[] = $v['bizId'];
|
|
}
|
|
if ($v['userId'] && !in_array($v['userId'], $userIds)) {
|
|
$userIds[] = $v['userId'];
|
|
}
|
|
}
|
|
$userIds = $userIds ? implode(",", $userIds) : -1;
|
|
$map_user = $this->mdSyliveUser->map('userId', 'uname,nickname,mobile', ["userId in({$userIds})" => null]);
|
|
$groupsIds = $groupsIds ? implode(',', $groupsIds) : -1;
|
|
$map_groups = $this->mdSyliveGroups->map('groupsId', 'groupsName', ["groupsId in({$groupsIds})" => null, 'activityId' => $activityId]);
|
|
foreach ($res as $v) {
|
|
$uname = $nickname = $mobile = '';
|
|
$user = $map_user[$v['userId']];
|
|
if ($user) {
|
|
$uname = $user['uname'];
|
|
$nickname = $user['nickname'];
|
|
$mobile = $user['mobile'];
|
|
}
|
|
if ($v['type'] == 0) {
|
|
$roleName = '销售';
|
|
} else if ($v['type'] == 1) {
|
|
$roleName = $v['userFrom'] == 0 ? '店长' : '团长';
|
|
} else {
|
|
$roleName = '管理员';
|
|
}
|
|
$list1 = ['uname' => $uname, 'nickname' => $nickname, 'mobile' => $mobile, 'roleName' => $roleName];
|
|
$list2 = [];
|
|
foreach ($levels as $k2 => $v2) {
|
|
$levelId = $v[$v2['prop']];
|
|
$list2[$v2['prop']] = $map_groups[$levelId] ? $map_groups[$levelId] : '';
|
|
}
|
|
$item = count($list2) ? array_merge($list1, $list2) : $list1;
|
|
$item['stores'] = $map_groups[$v['bizId']] ? $map_groups[$v['bizId']] : '';
|
|
$list[] = $item;
|
|
}
|
|
$columns1 = ['姓名', '微信昵称', '手机号', '角色'];
|
|
$columns2 = [];
|
|
foreach ($levels as $k => $v) {
|
|
$columns2[] = $v['label'];
|
|
}
|
|
$columns3 = count($columns2) ? array_merge($columns1, $columns2) : $columns1;
|
|
$columns = array_merge($columns3, ['门店']);
|
|
$this->return_response_list(['list' => $list, 'columns' => $columns]);
|
|
}
|
|
|
|
/**
|
|
* Notes:获取分组等级ID
|
|
* Created on: 2022/11/30 14:30
|
|
* Created by: dengbw
|
|
* @param $groupsId
|
|
* @param array $data
|
|
* @return array
|
|
*/
|
|
private function getLevelAry($groupsId, $data = [])
|
|
{
|
|
$re = $this->mdSyliveGroups->get(['groupsId' => $groupsId], 'groupsId,parentId,groupsLevel,ifBiz');
|
|
if (!$re) {
|
|
return $data;
|
|
} else {
|
|
if ($re['groupsLevel']) {//分类id
|
|
$levelId = "levelId" . $re['groupsLevel'];
|
|
$data[$levelId] = $re['groupsId'];
|
|
}
|
|
if ($re['ifBiz']) {//门店id
|
|
$data['bizId'] = $re['groupsId'];
|
|
}
|
|
if ($re['parentId']) {
|
|
return $this->getLevelAry($re['parentId'], $data);
|
|
} else {
|
|
return $data;
|
|
}
|
|
}
|
|
}
|
|
|
|
} |