代码提交

2025-08-22 10:23:05 +08:00
parent 0681c69d67
commit d726be7d66
12 changed files with 363 additions and 23 deletions
--- a/Server/application/cunkebao/config/route.php
+++ b/Server/application/cunkebao/config/route.php
@@ -96,6 +96,7 @@ Route::group('v1/', function () {
        Route::get('device-labels', 'app\cunkebao\controller\WorkbenchController@getDeviceLabels'); // 获取设备微信好友标签统计
        Route::get('group-list', 'app\cunkebao\controller\WorkbenchController@getGroupList'); // 获取群列表
        Route::get('account-list', 'app\cunkebao\controller\WorkbenchController@getAccountList'); // 获取账号列表
+        Route::get('transfer-friends', 'app\cunkebao\controller\WorkbenchController@getTrafficList'); // 获取账号列表

        Route::get('getJdSocialMedia', 'app\cunkebao\controller\WorkbenchController@getJdSocialMedia'); // 获取京东联盟导购媒体
        Route::get('getJdPromotionSite', 'app\cunkebao\controller\WorkbenchController@getJdPromotionSite'); // 获取京东联盟广告位
@@ -155,6 +156,7 @@ Route::group('v1/frontend', function () {
    Route::group('business/poster', function () {
        Route::post('getone', 'app\cunkebao\controller\plan\PosterWeChatMiniProgram@getPosterTaskData');
        Route::post('decryptphone', 'app\cunkebao\controller\plan\PosterWeChatMiniProgram@getPhoneNumber');
+        Route::post('decryptphones', 'app\cunkebao\controller\plan\PosterWeChatMiniProgram@decryptphones');
    });
 });

--- a/Server/application/cunkebao/controller/WorkbenchController.php
+++ b/Server/application/cunkebao/controller/WorkbenchController.php
@@ -58,7 +58,7 @@ class WorkbenchController extends Controller
            $workbench = new Workbench;
            $workbench->name = $param['name'];
            $workbench->type = $param['type'];
-            $workbench->status = 1;
+            $workbench->status = !empty($param['status']) ? 1 : 0;
            $workbench->autoStart = !empty($param['autoStart']) ? 1 : 0;
            $workbench->userId = $userInfo['id'];
            $workbench->companyId = $userInfo['companyId'];
@@ -131,6 +131,8 @@ class WorkbenchController extends Controller
                    $config->maxGroupsPerDay = $param['maxGroupsPerDay'];
                    $config->groupNameTemplate = $param['groupNameTemplate'];
                    $config->groupDescription = $param['groupDescription'];
+                    $config->poolGroups = json_encode($param['poolGroups'] ?? []);
+                    $config->wechatGroups = json_encode($param['wechatGroups'] ?? []);
                    $config->createTime = time();
                    $config->updateTime = time();
                    $config->save();
@@ -201,7 +203,7 @@ class WorkbenchController extends Controller
                $query->field('workbenchId,pushType,startTime,endTime,maxPerDay,pushOrder,isLoop,status,groups,contentLibraries');
            },
            'groupCreate' => function($query) {
-                $query->field('workbenchId,devices,startTime,endTime,groupSizeMin,groupSizeMax,maxGroupsPerDay,groupNameTemplate,groupDescription');
+                $query->field('workbenchId,devices,startTime,endTime,groupSizeMin,groupSizeMax,maxGroupsPerDay,groupNameTemplate,groupDescription,poolGroups,wechatGroups');
            },
            'user' => function ($query) {
                $query->field('id,username');
@@ -277,7 +279,7 @@ class WorkbenchController extends Controller
                            $item->config->status = $item->config->status;
                            $item->config->groups = json_decode($item->config->groups, true);
                            $item->config->contentLibraries = json_decode($item->config->contentLibraries, true);
-                            $item->config->lastPushTime = '22222';
+                            $item->config->lastPushTime = '';
                        }
                        unset($item->groupPush, $item->group_push);
                        break;
@@ -285,6 +287,8 @@ class WorkbenchController extends Controller
                        if (!empty($item->groupCreate)) {
                            $item->config = $item->groupCreate;
                            $item->config->devices = json_decode($item->config->devices, true);
+                            $item->config->poolGroups = json_decode($item->config->poolGroups, true);
+                            $item->config->wechatGroups = json_decode($item->config->wechatGroups, true);
                        }
                        unset($item->groupCreate, $item->group_create);
                        break;
@@ -391,7 +395,7 @@ class WorkbenchController extends Controller
                $query->field('workbenchId,pushType,startTime,endTime,maxPerDay,pushOrder,isLoop,status,groups,contentLibraries');
            },
             'groupCreate' => function($query) {
-                 $query->field('workbenchId,devices,startTime,endTime,groupSizeMin,groupSizeMax,maxGroupsPerDay,groupNameTemplate,groupDescription');
+                 $query->field('workbenchId,devices,startTime,endTime,groupSizeMin,groupSizeMax,maxGroupsPerDay,groupNameTemplate,groupDescription,poolGroups,wechatGroups');
             }
        ];
        $workbench = Workbench::where([
@@ -466,6 +470,8 @@ class WorkbenchController extends Controller
                if (!empty($workbench->groupCreate)) {
                    $workbench->config = $workbench->groupCreate;
                    $workbench->config->deveiceGroups = json_decode($workbench->config->devices, true);
+                    $workbench->config->poolGroups = json_decode($workbench->config->poolGroups, true);
+                    $workbench->config->wechatGroups = json_decode($workbench->config->wechatGroups, true);
                    unset($workbench->groupCreate, $workbench->group_create);
                }
                break;
@@ -600,6 +606,21 @@ class WorkbenchController extends Controller
            $workbench->config->accountGroupsOptions = [];
        }

+        if (!empty($workbench->config->poolGroups)){
+            $poolGroupsOptions = Db::name('traffic_source_package')->alias('tsp')
+                ->join('traffic_source_package_item tspi','tspi.packageId=tsp.id','left')
+                ->whereIn('tsp.companyId', [$this->request->userInfo['companyId'],0])
+                ->whereIn('tsp.id', $workbench->config->poolGroups)
+                ->field('tsp.id,tsp.name,tsp.description,tsp.createTime,count(tspi.id) as num')
+                ->group('tsp.id')
+                ->select();
+            $workbench->config->poolGroupsOptions = $poolGroupsOptions;
+        }else{
+            $workbench->config->poolGroupsOptions = [];
+        }
+
+
+
        return json(['code' => 200, 'msg' => '获取成功', 'data' => $workbench]);
    }

@@ -636,6 +657,7 @@ class WorkbenchController extends Controller
        try {
            // 更新工作台基本信息
            $workbench->name = $param['name'];
+            $workbench->status = !empty($param['status']) ? 1 : 0;
            $workbench->autoStart = !empty($param['autoStart']) ? 1 : 0;
            $workbench->updateTime = time();
            $workbench->save();
@@ -720,6 +742,8 @@ class WorkbenchController extends Controller
                        $config->maxGroupsPerDay = $param['maxGroupsPerDay'];
                        $config->groupNameTemplate = $param['groupNameTemplate'];
                        $config->groupDescription = $param['groupDescription'];
+                        $config->poolGroups = json_encode($param['poolGroups'] ?? []);
+                        $config->wechatGroups = json_encode($param['wechatGroups'] ?? []);
                        $config->updateTime = time();
                        $config->save();
                    }
@@ -859,7 +883,8 @@ class WorkbenchController extends Controller
                        $newConfig->contentTypes = $config->contentTypes;
                        $newConfig->devices = $config->devices;
                        $newConfig->friends = $config->friends;
-                        //$newConfig->targetGroups = $config->targetGroups;
+                        $newConfig->createTime = time();
+                        $newConfig->updateTime = time();
                        $newConfig->save();
                    }
                    break;
@@ -876,6 +901,8 @@ class WorkbenchController extends Controller
                        $newConfig->accountType = $config->accountType;
                        $newConfig->devices = $config->devices;
                        $newConfig->contentLibraries = $config->contentLibraries;
+                        $newConfig->createTime = time();
+                        $newConfig->updateTime = time();
                        $newConfig->save();
                    }
                    break;
@@ -893,6 +920,8 @@ class WorkbenchController extends Controller
                        $newConfig->status = $config->status;
                        $newConfig->groups = $config->groups;
                        $newConfig->contentLibraries = $config->contentLibraries;
+                        $newConfig->createTime = time();
+                        $newConfig->updateTime = time();
                        $newConfig->save();
                    }
                    break;
@@ -909,6 +938,8 @@ class WorkbenchController extends Controller
                        $newConfig->maxGroupsPerDay = $config->maxGroupsPerDay;
                        $newConfig->groupNameTemplate = $config->groupNameTemplate;
                        $newConfig->groupDescription = $config->groupDescription;
+                        $newConfig->poolGroups =  $config->poolGroups;
+                        $newConfig->wechatGroups =  $config->wechatGroups;
                        $newConfig->createTime = time();
                        $newConfig->updateTime = time();
                        $newConfig->save();
--- a/Server/application/cunkebao/controller/plan/PosterWeChatMiniProgram.php
+++ b/Server/application/cunkebao/controller/plan/PosterWeChatMiniProgram.php
@@ -127,6 +127,73 @@ class PosterWeChatMiniProgram extends Controller
        
    }

+
+
+    public function decryptphones() {
+
+        $taskId = request()->param('id');
+        $phone = request()->param('phone');
+        if (!$phone) {
+            return json([
+                'code' => 400,
+                'message' => '手机号不能为空'
+            ]);
+        }
+
+        $task = Db::name('customer_acquisition_task')->where('id', $taskId)->find();
+        if (!$task) {
+            return json([
+                'code' => 400,
+                'message' => '任务不存在'
+            ]);
+        }
+
+        if (!empty($phone)) {
+
+            // TODO 拿到手机号之后的后续操作：
+            // 1. 先写入 ck_traffic_pool 表 identifier  mobile 都是 用 phone字段的值
+            $trafficPool = Db::name('traffic_pool')->where('identifier', $phone)->find();
+            if (!$trafficPool) {
+                Db::name('traffic_pool')->insert([
+                    'identifier' => $phone,
+                    'mobile' => $phone,
+                    'createTime' => time()
+                ]);
+            }
+
+            $taskCustomer = Db::name('task_customer')->where('task_id', $taskId)->where('phone', $phone)->find();
+            if (!$taskCustomer) {
+                Db::name('task_customer')->insert([
+                    'task_id' => $taskId,
+                    // 'identifier' => $phone,
+                    'phone' => $phone,
+                    'source' => $task['name'],
+                    'createTime' => time(),
+                    'tags' => json_encode([]),
+                    'siteTags' => json_encode([]),
+                ]);
+            }
+            // return $phone;
+            return json([
+                'code' => 200,
+                'message' => '获取手机号成功',
+                'data' => $phone
+            ]);
+        } else {
+            // return null;
+            return json([
+                'code' => 400,
+                'message' => '手机号失败:'
+            ]);
+        }
+
+        // return $result;
+
+    }
+
+
+
+
    // todo 获取海报获客任务的任务/海报数据 -- 表还没设计好，不急 ck_customer_acquisition_task
    public function getPosterTaskData() {
        $id = request()->param('id');
--- a/Server/application/cunkebao/validate/Workbench.php
+++ b/Server/application/cunkebao/validate/Workbench.php
@@ -48,8 +48,8 @@ class Workbench extends Validate
        // 自动建群特有参数
        'groupNameTemplate' => 'requireIf:type,4|max:50',
        'maxGroupsPerDay' => 'requireIf:type,4|number|min:1',
-        'groupSizeMin' => 'requireIf:type,4|number|min:1',
-        'groupSizeMax' => 'requireIf:type,4|number|min:1',
+        'groupSizeMin' => 'requireIf:type,4|number|min:1|max:50',
+        'groupSizeMax' => 'requireIf:type,4|number|min:1|max:50',
        // 流量分发特有参数
        'distributeType' => 'requireIf:type,5|in:1,2',
        'maxPerDay' => 'requireIf:type,5|number|min:1',
@@ -130,9 +130,11 @@ class Workbench extends Validate
        'groupSizeMin.requireIf' => '请设置每个群的人数',
        'groupSizeMin.number' => '每个群的人数必须为数字',
        'groupSizeMin.min' => '每个群的人数必须大于0',
+        'groupSizeMin.max' => '每个群的人数最大50人',
        'groupSizeMax.requireIf' => '请设置每个群的人数',
        'groupSizeMax.number' => '每个群的人数必须为数字',
        'groupSizeMax.min' => '每个群的人数必须大于0',
+        'groupSizeMax.max' => '每个群的人数最大50人',
        // 流量分发相关提示
        'distributeType.requireIf' => '请选择流量分发类型',
        'distributeType.in' => '流量分发类型错误',