fnvtk/cunkebao_v3
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

【存客宝】 获取自动分配规则

Browse Source
This commit is contained in:
wong
2025-04-26 11:18:42 +08:00
parent 68fa1c9a51
commit 19271f13af
5 changed files with 222 additions and 37 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
Server/application/api/config/route.php
View File

@@ -86,5 +86,10 @@ Route::group('v1', function () {
Route::get('getFriendsList', 'app\\api\\controller\\MessageController@getFriendsList'); // 获取微信好友列表 √
Route::get('getChatroomList', 'app\\api\\controller\\MessageController@getChatroomList'); // 同步群聊消息 √
});
// AllotRule控制器路由
Route::group('allot-rule', function () {
Route::get('list', 'app\\api\\controller\\AllotRuleController@getAllRules'); // 获取所有分配规则 √
});
});
});

89
Server/application/api/controller/AllotRuleController.php Normal file
View File

@@ -0,0 +1,89 @@
<?php
namespace app\api\controller;
use app\api\model\CompanyAccountModel;
use app\api\model\AllotRuleModel;
class AllotRuleController extends BaseController
{
/**
* 获取所有分配规则
* @param bool $isInner 是否为内部调用
* @return \think\response\Json
*/
public function getAllRules($data = [], $isInner = false)
{
// 获取授权token
$authorization = trim($this->request->header('authorization', $this->authorization));
if (empty($authorization)) {
if ($isInner) {
return json_encode(['code' => 500, 'msg' => '缺少授权信息']);
} else {
return errorJson('缺少授权信息');
}
}
try {
// 设置请求头
$headerData = ['client:system'];
$header = setHeader($headerData, $authorization, 'plain');
// 发送请求获取所有分配规则
$result = requestCurl($this->baseUrl . 'api/AllotRule/all', [], 'GET', $header);
$response = handleApiResponse($result);
// 保存数据到数据库
if (!empty($response)) {
foreach ($response as $item) {
$this->saveAllotRule($item);
}
}
if ($isInner) {
return json_encode(['code' => 200, 'msg' => 'success', 'data' => $response]);
} else {
return successJson($response);
}
} catch (\Exception $e) {
if ($isInner) {
return json_encode(['code' => 500, 'msg' => '获取分配规则失败：' . $e->getMessage()]);
} else {
return errorJson('获取分配规则失败：' . $e->getMessage());
}
}
}
/**
* 保存分配规则数据到数据库
* @param array $item 分配规则数据
*/
private function saveAllotRule($item)
{
$data = [
'id' => isset($item['id']) ? $item['id'] : '',
'tenantId' => isset($item['tenantId']) ? $item['tenantId'] : 0,
'allotType' => isset($item['allotType']) ? $item['allotType'] : 0,
'allotOnline' => isset($item['allotOnline']) ? $item['allotOnline'] : false,
'kefuRange' => isset($item['kefuRange']) ? $item['kefuRange'] : 0,
'wechatRange' => isset($item['wechatRange']) ? $item['wechatRange'] : 0,
'kefuData' => isset($item['kefuData']) ? json_encode($item['kefuData']) : json_encode([]),
'wechatIds' => isset($item['wechatIds']) ? json_encode($item['wechatIds']) : json_encode([]),
'labels' => isset($item['labels']) ? json_encode($item['labels']) : json_encode([]),
'priorityStrategy' => isset($item['priorityStrategy']) ? json_encode($item['priorityStrategy']) : json_encode([]),
'sortIndex' => isset($item['sortIndex']) ? $item['sortIndex'] : 0,
'creatorAccountId' => isset($item['creatorAccountId']) ? $item['creatorAccountId'] : 0,
'createTime' => isset($item['createTime']) ? (strtotime($item['createTime']) ?: 0) : 0,
'ruleName' => isset($item['ruleName']) ? $item['ruleName'] : '',
];
// 使用ID作为唯一性判断
$rule = AllotRuleModel::where('id', $item['id'])->find();
if ($rule) {
$rule->save($data);
} else {
AllotRuleModel::create($data);
}
}
}

16
Server/application/api/controller/AutomaticAssign.php
View File

@@ -19,7 +19,7 @@ class AutomaticAssign extends BaseController
* 自动分配微信好友
* @return \think\response\Json
*/
public function autoAllotWechatFriend($toAccountId = '', $wechatAccountKeyword = '', $isDeleted = false)
public function autoAllotWechatFriend($data = [])
{
// 获取授权token
$authorization = trim($this->request->header('authorization', $this->authorization));
@@ -29,9 +29,9 @@ class AutomaticAssign extends BaseController
try {
// 获取请求参数
$toAccountId = !empty($toAccountId) ? $toAccountId : input('toAccountId', '');
$wechatAccountKeyword = !empty($wechatAccountKeyword) ? $wechatAccountKeyword : input('wechatAccountKeyword', '');
$isDeleted = !empty($isDeleted) ? $isDeleted : input('isDeleted', false);
$toAccountId = !empty($data['toAccountId']) ? $data['toAccountId'] : input('toAccountId', '');
$wechatAccountKeyword = !empty($data['wechatAccountKeyword']) ? $data['wechatAccountKeyword'] : input('wechatAccountKeyword', '');
$isDeleted = !empty($data['isDeleted']) ? $data['isDeleted'] : input('isDeleted', false);
if (empty($toAccountId)) {
return errorJson('目标账号ID不能为空');
@@ -91,7 +91,7 @@ class AutomaticAssign extends BaseController
* @param bool $isDeleted 是否已删除
* @return \think\response\Json
*/
public function autoAllotWechatChatroom($toAccountId = '', $wechatAccountKeyword = '', $isDeleted = false)
public function autoAllotWechatChatroom($data = [])
{
// 获取授权token
$authorization = trim($this->request->header('authorization', $this->authorization));
@@ -101,9 +101,9 @@ class AutomaticAssign extends BaseController
try {
// 获取请求参数
$toAccountId = !empty($toAccountId) ? $toAccountId : input('toAccountId', '');
$wechatAccountKeyword = !empty($wechatAccountKeyword) ? $wechatAccountKeyword : input('wechatAccountKeyword', '');
$isDeleted = !empty($isDeleted) ? $isDeleted : input('isDeleted', false);
$toAccountId = !empty($data['toAccountId']) ? $data['toAccountId'] : input('toAccountId', '');
$wechatAccountKeyword = !empty($data['wechatAccountKeyword']) ? $data['wechatAccountKeyword'] : input('wechatAccountKeyword', '');
$isDeleted = !empty($data['isDeleted']) ? $data['isDeleted'] : input('isDeleted', false);
if (empty($toAccountId)) {
return errorJson('目标账号ID不能为空');

138
Server/application/api/controller/DeviceController.php
View File

@@ -17,15 +17,15 @@ class DeviceController extends BaseController
* 获取设备列表
* @param string $pageIndex 页码
* @param string $pageSize 每页数量
* @param bool $isJob 是否为定时任务调用
* @param bool $isInner 是否为内部调用
* @return \think\response\Json
*/
public function getlist($data = [],$isJob = false,$isDel = 0)
public function getlist($data = [],$isInner = false,$isDel = 0)
{
// 获取授权token
$authorization = trim($this->request->header('authorization', $this->authorization));
if (empty($authorization)) {
if($isJob){
if($isInner){
return json_encode(['code'=>500,'msg'=>'缺少授权信息']);
}else{
return errorJson('缺少授权信息');
@@ -79,13 +79,13 @@ class DeviceController extends BaseController
}
}
if($isJob){
if($isInner){
return json_encode(['code'=>200,'msg'=>'success','data'=>$response]);
}else{
return successJson($response);
}
} catch (\Exception $e) {
if($isJob){
if($isInner){
return json_encode(['code'=>500,'msg'=>'获取设备列表失败：' . $e->getMessage()]);
}else{
return errorJson('获取设备列表失败：' . $e->getMessage());
@@ -98,14 +98,18 @@ class DeviceController extends BaseController
* @param int $accountId 账号ID
* @return \think\response\Json
*/
public function addDevice($accountId = 0)
public function addDevice($accountId = 0,$isInner = false)
{
if (empty($accountId)) {
$accountId = $this->request->param('accountId', '');
}
if (empty($accountId)) {
return errorJson('账号ID不能为空');
if($isInner){
return json_encode(['code'=>500,'msg'=>'账号ID不能为空']);
}else{
return errorJson('账号ID不能为空');
}
}
try {
@@ -114,7 +118,11 @@ class DeviceController extends BaseController
$deviceSocketHost = Env::get('api.deviceSocketHost', '');
if (empty($tenantGuid) || empty($deviceSocketHost)) {
return errorJson('环境配置不完整，请检查api.guid和api.deviceSocketHost配置');
if($isInner){
return json_encode(['code'=>500,'msg'=>'环境配置不完整，请检查api.guid和api.deviceSocketHost配置']);
}else{
return errorJson('环境配置不完整，请检查api.guid和api.deviceSocketHost配置');
}
}
// 构建设备配置数据
@@ -136,7 +144,11 @@ class DeviceController extends BaseController
'config' => $data
]);
} catch (\Exception $e) {
return errorJson('生成设备二维码失败：' . $e->getMessage());
if($isInner){
return json_encode(['code'=>500,'msg'=>'生成设备二维码失败：' . $e->getMessage()]);
}else{
return errorJson('生成设备二维码失败：' . $e->getMessage());
}
}
}
@@ -144,12 +156,16 @@ class DeviceController extends BaseController
* 更新设备账号
* @return \think\response\Json
*/
public function updateaccount($data = [])
public function updateaccount($data = [],$isInner = false)
{
// 获取授权token
$authorization = trim($this->request->header('authorization', $this->authorization));
if (empty($authorization)) {
return errorJson('缺少授权信息');
if($isInner){
return json_encode(['code'=>500,'msg'=>'缺少授权信息']);
}else{
return errorJson('缺少授权信息');
}
}
try {
@@ -158,11 +174,19 @@ class DeviceController extends BaseController
$accountId = !empty($data['accountId']) ? $data['accountId'] : $this->request->param('accountId', '');
if (empty($id)) {
return errorJson('设备ID不能为空');
if($isInner){
return json_encode(['code'=>500,'msg'=>'设备ID不能为空']);
}else{
return errorJson('设备ID不能为空');
}
}
if (empty($accountId)) {
return errorJson('账号id不能为空');
if($isInner){
return json_encode(['code'=>500,'msg'=>'账号id不能为空']);
}else{
return errorJson('账号id不能为空');
}
}
// 设置请求头
@@ -179,7 +203,11 @@ class DeviceController extends BaseController
return errorJson([],$response);
}
} catch (\Exception $e) {
return errorJson('更新设备账号失败：' . $e->getMessage());
if($isInner){
return json_encode(['code'=>500,'msg'=>'更新设备账号失败：' . $e->getMessage()]);
}else{
return errorJson('更新设备账号失败：' . $e->getMessage());
}
}
}
@@ -295,12 +323,16 @@ class DeviceController extends BaseController
* 创建设备分组
* @return \think\response\Json
*/
public function createGroup($data = [])
public function createGroup($data = [],$isInner = false)
{
// 获取授权token
$authorization = trim($this->request->header('authorization', $this->authorization));
if (empty($authorization)) {
return errorJson('缺少授权信息');
if($isInner){
return json_encode(['code'=>500,'msg'=>'缺少授权信息']);
}else{
return errorJson('缺少授权信息');
}
}
try {
@@ -309,7 +341,11 @@ class DeviceController extends BaseController
$groupMemo = !empty($data['groupMemo']) ? $data['groupMemo'] : $this->request->param('groupMemo', '');
if (empty($groupName)) {
return errorJson('分组名称不能为空');
if($isInner){
return json_encode(['code'=>500,'msg'=>'分组名称不能为空']);
}else{
return errorJson('分组名称不能为空');
}
}
// 构建请求参数
@@ -330,12 +366,24 @@ class DeviceController extends BaseController
if(!empty($res['data'])){
$data = $res['data'][0];
}
return successJson($data,'操作成功');
if($isInner){
return json_encode(['code'=>200,'msg'=>'success','data'=>$data]);
}else{
return successJson($data,'操作成功');
}
}else{
return errorJson([],$response);
if($isInner){
return json_encode(['code'=>500,'msg'=> $result]);
}else{
return errorJson($result);
}
}
} catch (\Exception $e) {
return errorJson('创建设备分组失败：' . $e->getMessage());
if($isInner){
return json_encode(['code'=>500,'msg'=>'创建设备分组失败：' . $e->getMessage()]);
}else{
return errorJson('创建设备分组失败：' . $e->getMessage());
}
}
}
@@ -343,12 +391,16 @@ class DeviceController extends BaseController
* 更新设备分组
* @return \think\response\Json
*/
public function updateDeviceGroup($data = [])
public function updateDeviceGroup($data = [],$isInner = false)
{
// 获取授权token
$authorization = trim($this->request->header('authorization', $this->authorization));
if (empty($authorization)) {
return errorJson('缺少授权信息');
if($isInner){
return json_encode(['code'=>500,'msg'=>'缺少授权信息']);
}else{
return errorJson('缺少授权信息');
}
}
try {
@@ -358,21 +410,37 @@ class DeviceController extends BaseController
$groupMemo = !empty($data['groupMemo']) ? $data['groupMemo'] : $this->request->param('groupMemo', '');
if (empty($id)) {
return errorJson('分组ID不能为空');
if($isInner){
return json_encode(['code'=>500,'msg'=>'分组ID不能为空']);
}else{
return errorJson('分组ID不能为空');
}
}
if (empty($groupName)) {
return errorJson('分组名称不能为空');
if($isInner){
return json_encode(['code'=>500,'msg'=>'分组名称不能为空']);
}else{
return errorJson('分组名称不能为空');
}
}
$group = DeviceGroupModel::where('id', $id)->find();
if(empty($group)){
return errorJson('分组不存在');
if($isInner){
return json_encode(['code'=>500,'msg'=>'分组不存在']);
}else{
return errorJson('分组不存在');
}
}
$isGroupName = DeviceGroupModel::where('groupName', $groupName)->find();
if(!empty($isGroupName)){
return errorJson('分组名称已存在');
if($isInner){
return json_encode(['code'=>500,'msg'=>'分组名称已存在']);
}else{
return errorJson('分组名称已存在');
}
}
// 设置请求头
@@ -393,12 +461,24 @@ class DeviceController extends BaseController
$group->groupName = $groupName;
$group->groupMemo = $groupMemo;
$group->save();
return successJson([],'操作成功');
if($isInner){
return json_encode(['code'=>200,'msg'=>'success','data'=>$group]);
}else{
return successJson($group,'操作成功');
}
}else{
return errorJson($result);
if($isInner){
return json_encode(['code'=>500,'msg'=> $result]);
}else{
return errorJson($result);
}
}
} catch (\Exception $e) {
return errorJson('更新设备分组失败：' . $e->getMessage());
if($isInner){
return json_encode(['code'=>500,'msg'=>'更新设备分组失败：' . $e->getMessage()]);
}else{
return errorJson('更新设备分组失败：' . $e->getMessage());
}
}
}

11
Server/application/api/model/AllotRuleModel.php Normal file
View File

@@ -0,0 +1,11 @@
<?php
namespace app\api\model;
use think\Model;
class AllotRuleModel extends Model
{
// 设置表名
protected $table = 's2_allot_rule';
}