私域操盘手 - 流量池列表返工_潜在客户游离状态列表

2025-05-13 12:10:39 +08:00
parent 05c5f6c8e3
commit 869ce043fc
4 changed files with 164 additions and 33 deletions
--- a/Server/application/cunkebao/config/route.php
+++ b/Server/application/cunkebao/config/route.php
@@ -9,25 +9,25 @@ use think\facade\Route;
 Route::group('v1/', function () {
    // 设备管理相关
    Route::group('devices', function () {
-        Route::get('add-results', 'app\cunkebao\controller\device\GetAddResultedV1Controller@index');                // 更新设备任务配置
-        Route::get(':id/related-accounts', 'app\cunkebao\controller\device\GetRelatedAccountsV1Controller@index');   // 设备关联微信账号路由
-        Route::get(':id/handle-logs', 'app\cunkebao\controller\device\GetDeviceHandleLogsV1Controller@index');       // 获取设备操作记录
-        Route::get('', 'app\cunkebao\controller\device\GetDeviceListV1Controller@index');                            // 获取设备列表
-        Route::get(':id', 'app\cunkebao\controller\device\GetDeviceDetailV1Controller@index');                       // 获取设备详情
-        Route::post('', 'app\cunkebao\controller\device\PostAddDeviceV1Controller@index');                           // 添加设备
-        Route::put('refresh', 'app\cunkebao\controller\device\RefreshDeviceDetailV1Controller@index');               // 刷新设备状态
-        Route::delete(':id', 'app\cunkebao\controller\device\DeleteDeviceV1Controller@index');                       // 删除设备
-        Route::post('task-config', 'app\cunkebao\controller\device\UpdateDeviceTaskConfigV1Controller@index');       // 设备任务配置
+        Route::get('add-results', 'app\cunkebao\controller\device\GetAddResultedV1Controller@index');
+        Route::get(':id/related-accounts', 'app\cunkebao\controller\device\GetRelatedAccountsV1Controller@index');
+        Route::get(':id/handle-logs', 'app\cunkebao\controller\device\GetDeviceHandleLogsV1Controller@index');
+        Route::get('', 'app\cunkebao\controller\device\GetDeviceListV1Controller@index');
+        Route::get(':id', 'app\cunkebao\controller\device\GetDeviceDetailV1Controller@index');
+        Route::post('', 'app\cunkebao\controller\device\PostAddDeviceV1Controller@index');
+        Route::put('refresh', 'app\cunkebao\controller\device\RefreshDeviceDetailV1Controller@index');
+        Route::delete(':id', 'app\cunkebao\controller\device\DeleteDeviceV1Controller@index');
+        Route::post('task-config', 'app\cunkebao\controller\device\UpdateDeviceTaskConfigV1Controller@index');
    });

    // 设备微信相关
    Route::group('wechats', function () {
-        Route::get('', 'app\cunkebao\controller\wechat\GetWechatsOnDevicesV1Controller@index');                      // 获取在线微信账号列表
-        Route::get(':id/summary', 'app\cunkebao\controller\wechat\GetWechatOnDeviceSummarizeV1Controller@index');    // 获取微信号详情
-        Route::get(':id/friends', 'app\cunkebao\controller\wechat\GetWechatOnDeviceFriendsV1Controller@index');      // 获取微信好友列表
-        Route::get(':id/friend/:aId', 'app\cunkebao\controller\wechat\GetWechatOnDeviceFriendProfileV1Controller@index'); // 获取微信好友信息
+        Route::get('', 'app\cunkebao\controller\wechat\GetWechatsOnDevicesV1Controller@index');
+        Route::get(':id/summary', 'app\cunkebao\controller\wechat\GetWechatOnDeviceSummarizeV1Controller@index');
+        Route::get(':id/friends', 'app\cunkebao\controller\wechat\GetWechatOnDeviceFriendsV1Controller@index');
+        Route::get(':id/friend/:aId', 'app\cunkebao\controller\wechat\GetWechatOnDeviceFriendProfileV1Controller@index');

-        Route::get('count', 'app\cunkebao\controller\DeviceWechat@count');       // 获取在线微信账号数量
+        Route::get('count', 'app\cunkebao\controller\DeviceWechat@count');
        Route::get('device-count', 'app\cunkebao\controller\DeviceWechat@deviceCount'); // 获取有登录微信的设备数量
        Route::put('refresh', 'app\cunkebao\controller\DeviceWechat@refresh');  // 刷新设备微信状态
        Route::post('transfer-friends', 'app\cunkebao\controller\DeviceWechat@transferFriends'); // 微信好友转移
@@ -39,14 +39,9 @@ Route::group('v1/', function () {
        Route::post('create', 'app\cunkebao\controller\Plan@index');     // 获取场景列表
    });

-    // 流量标签相关
-    Route::group('traffic/tags', function () {
-        Route::get('', 'app\cunkebao\controller\TrafficTag@index');      // 获取标签列表
-    });
-
    // 流量池相关
    Route::group('traffic/pool', function () {
-        Route::post('import', 'app\cunkebao\controller\TrafficPool@importOrders');  // 导入订单标签
+        Route::get('', 'app\cunkebao\controller\traffic\GetDissociateListWithInCompanyV1Controller@index');
    });

    // 工作台相关
--- a/Server/application/cunkebao/controller/traffic/GetDissociateListWithInCompanyV1Controller.php
+++ b/Server/application/cunkebao/controller/traffic/GetDissociateListWithInCompanyV1Controller.php
@@ -0,0 +1,83 @@
+<?php
+
+namespace app\cunkebao\controller\traffic;
+
+use app\common\model\TrafficPool as TrafficPoolModel;
+use app\common\model\WechatFriendShip as WechatFriendShipModel;
+use app\cunkebao\controller\BaseController;
+use library\ResponseHelper;
+
+/**
+ * 流量池控制器
+ */
+class GetDissociateListWithInCompanyV1Controller extends BaseController
+{
+    /**
+     * 构建查询条件
+     *
+     * @param array $params
+     * @return array
+     */
+    protected function makeWhere(array $params = []): array
+    {
+        // 关键词搜索（同时搜索IMEI和备注）
+        if (!empty($keyword = $this->request->param('keyword'))) {
+            $where[] = ['exp', "p.identifier LIKE '%{$keyword}%'"];
+        }
+
+        $where['s.companyId'] = $this->getUserInfo('companyId');
+
+        return array_merge($where, $params);
+    }
+
+    /**
+     * 获取流量池列表
+     *
+     * @param array $where
+     * @return \think\Paginator
+     */
+    protected function getPoolListByCompanyId(array $where): \think\Paginator
+    {
+        $query = TrafficPoolModel::alias('t')
+            ->field(
+                [
+                    't.identifier', 't.mobile', 't.wechatId',
+                    's.id', 's.fromd', 's.status', 's.createTime'
+                ]
+            )
+            ->join('traffic_source s', 't.identifier=s.identifier')
+            ->order('s.id desc');
+
+        foreach ($where as $key => $value) {
+            if (is_numeric($key) && is_array($value) && isset($value[0]) && $value[0] === 'exp') {
+                $query->whereExp('', $value[1]);
+                continue;
+            }
+
+            $query->where($key, $value);
+        }
+
+        return $query->paginate($this->request->param('limit/d', 10), false, ['page' => $this->request->param('page/d', 1)]);
+    }
+
+    /**
+     * 获取流量池列表
+     *
+     * @return \think\response\Json
+     */
+    public function index()
+    {
+        try {
+            $result = $this->getPoolListByCompanyId( $this->makeWhere() );
+
+            return ResponseHelper::success(
+                [
+                    'list'  => $result->items(),
+                    'total' => $result->total(),
+                ]
+            );
+        } catch (\Exception $e) {
+            return ResponseHelper::error($e->getMessage(), $e->getCode());
+        }
+    }
+} 
--- a/Server/application/cunkebao/controller/traffic/GetDissociateTypeListV1Controller.php
+++ b/Server/application/cunkebao/controller/traffic/GetDissociateTypeListV1Controller.php
@@ -0,0 +1,66 @@
+<?php
+
+namespace app\cunkebao\controller\traffic;
+
+use app\common\model\TrafficPool as TrafficPoolModel;
+use app\common\model\WechatFriendShip as WechatFriendShipModel;
+use app\cunkebao\controller\BaseController;
+use library\ResponseHelper;
+
+/**
+ * 流量池控制器
+ */
+class GetDissociateTypeListV1Controller extends BaseController
+{
+
+    /**
+     * 获取流量池列表
+     *
+     * @param array $where
+     * @return \think\Paginator
+     */
+    protected function getPoolListByCompanyId(array $where): \think\Paginator
+    {
+        $query = TrafficPoolModel::alias('t')
+            ->field(
+                [
+                    't.identifier', 't.mobile', 't.wechatId',
+                    's.id', 's.fromd', 's.status', 's.createTime'
+                ]
+            )
+            ->join('traffic_source s', 't.identifier=s.identifier')
+            ->order('s.id desc');
+
+        foreach ($where as $key => $value) {
+            if (is_numeric($key) && is_array($value) && isset($value[0]) && $value[0] === 'exp') {
+                $query->whereExp('', $value[1]);
+                continue;
+            }
+
+            $query->where($key, $value);
+        }
+
+        return $query->paginate($this->request->param('limit/d', 10), false, ['page' => $this->request->param('page/d', 1)]);
+    }
+
+    /**
+     * 获取流量池列表
+     *
+     * @return \think\response\Json
+     */
+    public function index()
+    {
+        try {
+            $result = $this->getPoolListByCompanyId( $this->makeWhere() );
+
+            return ResponseHelper::success(
+                [
+                    'list'  => $result->items(),
+                    'total' => $result->total(),
+                ]
+            );
+        } catch (\Exception $e) {
+            return ResponseHelper::error($e->getMessage(), $e->getCode());
+        }
+    }
+} 
--- a/Server/application/cunkebao/controller/traffic/TrafficPool.php
+++ b/Server/application/cunkebao/controller/traffic/TrafficPool.php
@@ -1,13 +0,0 @@
-<?php
-namespace app\cunkebao\controller\traffic;
-
-use think\Controller;
-use think\facade\Request;
-
-/**
- * 流量池控制器
- */
-class TrafficPool extends Controller
-{
-
-}