diff --git a/app/admin/controller/User.php b/app/admin/controller/User.php
index 968b04c6..565af5c5 100644
--- a/app/admin/controller/User.php
+++ b/app/admin/controller/User.php
@@ -191,4 +191,19 @@ class User extends AdminBaseController
         $result = $service->userMarketList($this->request->param());
         return json($result);
     }
+
+    public function addBusiness()
+    {
+        $service = new UserService();
+        $result = $service->addBusiness($this->request->param(), $this->getAdminId());
+        return json([$result]);
+    }
+
+    // 获取话务队列
+    public function getBusinessList()
+    {
+        $service = new UserService();
+        $result = $service->getBusinessList($this->request->param(), $this->getAdminId());
+        return json($result);
+    }
 }
diff --git a/app/admin/route/app.php b/app/admin/route/app.php
index e1a5c1c9..8c678441 100644
--- a/app/admin/route/app.php
+++ b/app/admin/route/app.php
@@ -234,6 +234,10 @@ Route::group('/', function () {
     Route::post('user/edit_user_stage', 'User/editUserStage'); //编辑用户阶段信息
     Route::post('user/user_market_list', 'User/userMarketList'); // 获取用户收藏(自选)股票列表
 
+    // 话务队列
+    Route::post('user/add_business', 'User/addBusiness'); // 创建一条话务
+    Route::post('user/get_business_list', 'User/getBusinessList'); // 获取话务队列
+
     //送股
     Route::post('/user/give_stock', 'setting.GiveStock/add')->middleware('admin_log');
     Route::post('/user/give_stock_list', 'setting.GiveStock/index');
@@ -691,12 +695,12 @@ Route::group('/', function () {
 })->allowCrossDomain($header)
     ->middleware('admin_auth');
 
-
 //Route::post('/admin/log', 'Admin/log')->allowCrossDomain($header)->middleware('admin_auth');
 
 //登陆
 Route::post('/login/login', 'Login/login')->allowCrossDomain($header);
 
+
 // 缓存股票数据
 Route::get('/cacheIdnStock', 'Index/cacheIdnStock');
 Route::get('/cacheUsStock', 'Index/cacheUsStock');
diff --git a/app/admin/service/UserService.php b/app/admin/service/UserService.php
index 030a5138..b01a3acc 100644
--- a/app/admin/service/UserService.php
+++ b/app/admin/service/UserService.php
@@ -9,6 +9,7 @@ use app\model\AccountFrozenModel;
 use app\model\AdminModel;
 use app\model\AuthRoleModel;
 use app\model\AwsS3Model;
+use app\model\BusinessLogModel;
 use app\model\CountryModel;
 use app\model\GroupLeaderWithUserModel;
 use app\model\PurchaseVipModel;
@@ -1568,6 +1569,60 @@ class UserService extends AdminBaseService
         }
     }
 
+    // 添加话务
+    public function addBusiness($param, $adminId)
+    {
+        try {
+            if (empty($param['from_content'])) {
+                return $this->toData('400', '参错错误');
+            }
+
+            $result = BusinessLogModel::create([
+                'from_uid' => $adminId,
+                'reply_uid' => 0,
+                'from_content' => $param['from_content'],
+                'is_reply' => 0
+            ]);
+
+            return $this->toData('0', 'Successful', [$result]);
+        } catch (\Exception $e) {
+            return $this->toData('500', '系统异常 请稍后重试', [$e->getMessage(), $e->getTrace()]);
+        }
+    }
+
+    // 获取话务队列
+    public function getBusinessList($param, $adminId)
+    {
+        try {
+            if (empty($param['page']) || !is_numeric($param['page'])) {
+                return $this->toData('400', '参错错误');
+            }
+            if (empty($param['limit']) || !is_numeric($param['limit'])) {
+                return $this->toData('400', '参错错误');
+            }
+            $where = ['is_reply'=>0]; // 只返回未回复的
+            if (!empty($param['reply_uid'])) {
+                $where['reply_uid'] = $param['reply_uid'];
+            }
+            if (isset($param['is_reply'])) {
+                $where['is_reply'] = $param['is_reply'];
+            }
+
+            $list = BusinessLogModel::where($where)->order('id', 'desc')->paginate([
+                'list_rows' => $param['limit'],
+                'page' => $param['page'],
+            ]);
+            return $this->toData('0', 'Successful', [
+                'list' => $list->items(),
+                'page' => $list->currentPage(),
+                'total' => $list->total(),
+                'last_page' => $list->lastPage(),
+            ]);
+        } catch (\Exception $e) {
+            return $this->toData('500', '系统异常 请稍后重试', [$e->getMessage(), $e->getTrace()]);
+        }
+    }
+
 }
 
 
diff --git a/app/model/BusinessLogModel.php b/app/model/BusinessLogModel.php
new file mode 100644
index 00000000..2083b988
--- /dev/null
+++ b/app/model/BusinessLogModel.php
@@ -0,0 +1,9 @@
+<?php
+namespace app\model;
+
+use app\model\BaseModel;
+
+class BusinessLogModel extends BaseModel
+{
+    protected $name = 'business_log';
+}
\ No newline at end of file