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

调整身份授权中间件目录结构

Browse Source
This commit is contained in:
柳清爽
2025-04-08 16:22:55 +08:00
parent cccff5befb
commit 880d132849
6 changed files with 3 additions and 588 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
Server/application/http/middleware/JwtAuth.php → Server/application/common/middleware/jwt.php Executable file → Normal file
View File

@@ -1,5 +1,5 @@
<?php
namespace app\http\middleware;
namespace app\common\middleware;
use app\common\util\JwtUtil;
use think\facade\Log;
@@ -7,7 +7,7 @@ use think\facade\Log;
/**
* JWT认证中间件
*/
class JwtAuth
class jwt
{
/**
* 处理请求

11
Server/application/http/middleware/jwt.php
View File

@@ -1,11 +0,0 @@
<?php
namespace app\http\middleware;
/**
* JWT中间件别名
* 解决类不存在: app\http\middleware\jwt的问题
*/
class jwt extends JwtAuth
{
// 继承JwtAuth的所有功能
}

380
Server/application/plan/controller/Traffic.php
View File

@@ -1,380 +0,0 @@
<?php
namespace app\plan\controller;
use think\Controller;
use think\Request;
use app\plan\model\TrafficPool;
use app\plan\model\TrafficSource;
use app\plan\service\SceneHandler;
use think\facade\Log;
/**
* 流量控制器
*/
class Traffic extends Controller
{
/**
* 初始化
*/
protected function initialize()
{
parent::initialize();
}
/**
* 获取流量池列表
*
* @return \think\response\Json
*/
public function index()
{
$page = Request::param('page', 1, 'intval');
$limit = Request::param('limit', 10, 'intval');
$keyword = Request::param('keyword', '');
$status = Request::param('status', '', 'trim');
$gender = Request::param('gender', '', 'trim');
// 构建查询条件
$where = [];
if (!empty($keyword)) {
$where[] = ['mobile|tags', 'like', "%{$keyword}%"];
}
if ($status !== '') {
$where[] = ['status', '=', intval($status)];
}
if ($gender !== '') {
$where[] = ['gender', '=', intval($gender)];
}
// 查询流量池列表
$result = TrafficPool::getAvailableTraffic($where, 'id desc', $page, $limit);
return json([
'code' => 200,
'msg' => '获取成功',
'data' => $result
]);
}
/**
* 获取流量详情
*
* @param int $id
* @return \think\response\Json
*/
public function read($id)
{
$traffic = TrafficPool::get($id);
if (!$traffic) {
return json([
'code' => 404,
'msg' => '流量记录不存在'
]);
}
// 获取流量来源
$sources = TrafficSource::getSourcesByTrafficId($id);
return json([
'code' => 200,
'msg' => '获取成功',
'data' => [
'traffic' => $traffic,
'sources' => $sources
]
]);
}
/**
* 创建或更新流量
*
* @return \think\response\Json
*/
public function save()
{
$data = Request::post();
// 数据验证
$validate = validate('app\plan\validate\Traffic');
if (!$validate->check($data)) {
return json([
'code' => 400,
'msg' => $validate->getError()
]);
}
try {
// 添加或更新流量
$result = TrafficPool::addOrUpdateTraffic(
$data['mobile'],
$data['gender'] ?? 0,
$data['age'] ?? 0,
$data['tags'] ?? '',
$data['province'] ?? '',
$data['city'] ?? '',
$data['source_channel'] ?? '',
$data['source_detail'] ?? []
);
return json([
'code' => 200,
'msg' => '保存成功',
'data' => $result
]);
} catch (\Exception $e) {
Log::error('保存流量记录异常', [
'data' => $data,
'error' => $e->getMessage(),
'trace' => $e->getTraceAsString()
]);
return json([
'code' => 500,
'msg' => '保存失败：' . $e->getMessage()
]);
}
}
/**
* 更新流量记录
*
* @param int $id
* @return \think\response\Json
*/
public function update($id)
{
$data = Request::put();
// 检查流量记录是否存在
$traffic = TrafficPool::get($id);
if (!$traffic) {
return json([
'code' => 404,
'msg' => '流量记录不存在'
]);
}
// 准备更新数据
$updateData = [];
// 只允许更新特定字段
$allowedFields = ['gender', 'age', 'tags', 'province', 'city', 'status'];
foreach ($allowedFields as $field) {
if (isset($data[$field])) {
$updateData[$field] = $data[$field];
}
}
// 更新流量记录
$traffic->save($updateData);
return json([
'code' => 200,
'msg' => '更新成功'
]);
}
/**
* 删除流量记录
*
* @param int $id
* @return \think\response\Json
*/
public function delete($id)
{
// 检查流量记录是否存在
$traffic = TrafficPool::get($id);
if (!$traffic) {
return json([
'code' => 404,
'msg' => '流量记录不存在'
]);
}
// 更新状态为无效
$traffic->save([
'status' => 0
]);
return json([
'code' => 200,
'msg' => '删除成功'
]);
}
/**
* 获取流量来源统计
*
* @return \think\response\Json
*/
public function sourceStats()
{
$channel = Request::param('channel', '');
$planId = Request::param('plan_id', 0, 'intval');
$sceneId = Request::param('scene_id', 0, 'intval');
$startDate = Request::param('start_date', '', 'trim');
$endDate = Request::param('end_date', '', 'trim');
// 获取统计数据
$stats = TrafficSource::getSourceStats($channel, $planId, $sceneId, $startDate, $endDate);
return json([
'code' => 200,
'msg' => '获取成功',
'data' => $stats
]);
}
/**
* 处理外部流量
*
* @return \think\response\Json
*/
public function handleExternalTraffic()
{
$data = Request::post();
// 验证必要参数
if (empty($data['scene_id']) || empty($data['mobile'])) {
return json([
'code' => 400,
'msg' => '缺少必要参数'
]);
}
try {
// 获取场景处理器
$handler = SceneHandler::getHandler($data['scene_id']);
// 根据场景类型处理流量
switch ($data['scene_type'] ?? '') {
case 'poster':
$result = $handler->handlePosterScan($data['mobile'], $data);
break;
case 'order':
$result = $handler->handleOrderImport($data['orders'] ?? []);
break;
default:
$result = $handler->handleChannelTraffic($data['mobile'], $data['channel'] ?? '', $data);
}
return json([
'code' => 200,
'msg' => '处理成功',
'data' => $result
]);
} catch (\Exception $e) {
Log::error('处理外部流量异常', [
'data' => $data,
'error' => $e->getMessage(),
'trace' => $e->getTraceAsString()
]);
return json([
'code' => 500,
'msg' => '处理失败：' . $e->getMessage()
]);
}
}
/**
* 批量导入流量
*
* @return \think\response\Json
*/
public function importTraffic()
{
// 检查是否上传了文件
$file = Request::file('file');
if (!$file) {
return json([
'code' => 400,
'msg' => '未上传文件'
]);
}
// 检查文件类型，只允许csv或xlsx
$fileExt = strtolower($file->getOriginalExtension());
if (!in_array($fileExt, ['csv', 'xlsx'])) {
return json([
'code' => 400,
'msg' => '仅支持CSV或XLSX格式文件'
]);
}
try {
// 处理上传文件
$saveName = \think\facade\Filesystem::disk('upload')->putFile('traffic', $file);
$filePath = app()->getRuntimePath() . 'storage/upload/' . $saveName;
// 读取文件内容并导入
$results = [];
$success = 0;
$fail = 0;
// 这里简化处理，实际应当使用专业的Excel/CSV解析库
if ($fileExt == 'csv') {
$handle = fopen($filePath, 'r');
// 跳过标题行
fgetcsv($handle);
while (($data = fgetcsv($handle)) !== false) {
if (count($data) < 1) continue;
$mobile = trim($data[0]);
// 验证手机号
if (!preg_match('/^1[3-9]\d{9}$/', $mobile)) {
$fail++;
continue;
}
// 添加或更新流量
TrafficPool::addOrUpdateTraffic(
$mobile,
isset($data[1]) ? intval($data[1]) : 0, // 性别
isset($data[2]) ? intval($data[2]) : 0, // 年龄
isset($data[3]) ? $data[3] : '', // 标签
isset($data[4]) ? $data[4] : '', // 省份
isset($data[5]) ? $data[5] : '', // 城市
'import', // 来源渠道
['detail' => '批量导入'] // 来源详情
);
$success++;
}
fclose($handle);
} else {
// 处理xlsx文件，实际应当使用专业的Excel解析库
// 此处代码省略，依赖于具体的Excel解析库
}
return json([
'code' => 200,
'msg' => '导入完成',
'data' => [
'success' => $success,
'fail' => $fail
]
]);
} catch (\Exception $e) {
Log::error('批量导入流量异常', [
'error' => $e->getMessage(),
'trace' => $e->getTraceAsString()
]);
return json([
'code' => 500,
'msg' => '导入失败：' . $e->getMessage()
]);
}
}
}

164
Server/application/plan/model/PlanExecution.php
View File

@@ -1,164 +0,0 @@
<?php
namespace app\plan\model;
use think\Model;
/**
* 计划执行记录模型
*/
class PlanExecution extends Model
{
// 设置表名
protected $name = 'plan_execution';
protected $prefix = 'tk_';
// 设置主键
protected $pk = 'id';
// 自动写入时间戳
protected $autoWriteTimestamp = 'int';
// 定义时间戳字段名
protected $createTime = 'createTime';
protected $updateTime = 'updateTime';
// 定义字段类型
protected $type = [
'id' => 'integer',
'plan_id' => 'integer',
'traffic_id' => 'integer',
'step' => 'integer',
'status' => 'integer',
'result' => 'json',
'start_time' => 'integer',
'end_time' => 'integer',
'createTime' => 'integer',
'updateTime' => 'integer'
];
/**
* 状态文本获取器
* @param int $value 状态值
* @return string 状态文本
*/
public function getStatusTextAttr($value, $data)
{
$status = [
0 => '等待',
1 => '进行中',
2 => '成功',
3 => '失败'
];
return isset($status[$data['status']]) ? $status[$data['status']] : '未知';
}
/**
* 步骤文本获取器
* @param int $value 步骤值
* @return string 步骤文本
*/
public function getStepTextAttr($value, $data)
{
$steps = [
1 => '基础配置',
2 => '加友计划',
3 => 'API调用',
4 => '标签处理'
];
return isset($steps[$data['step']]) ? $steps[$data['step']] : '未知';
}
/**
* 创建执行记录
* @param int $planId 计划ID
* @param int $step 步骤
* @param array $data 额外数据
* @return int 新增记录ID
*/
public static function createExecution($planId, $step, $data = [])
{
$model = new self();
$model->save(array_merge([
'plan_id' => $planId,
'step' => $step,
'status' => 0, // 等待状态
'start_time' => time()
], $data));
return $model->id;
}
/**
* 更新执行状态
* @param int $id 记录ID
* @param int $status 状态
* @param array $data 额外数据
* @return bool 更新结果
*/
public static function updateExecution($id, $status, $data = [])
{
$updateData = array_merge([
'status' => $status
], $data);
// 如果是完成或失败状态，添加结束时间
if ($status == 2 || $status == 3) {
$updateData['end_time'] = time();
}
return self::where('id', $id)->update($updateData);
}
/**
* 获取计划的执行记录
* @param int $planId 计划ID
* @param int $step 步骤
* @return array 执行记录
*/
public static function getPlanExecutions($planId, $step = null)
{
$where = [
['plan_id', '=', $planId]
];
if ($step !== null) {
$where[] = ['step', '=', $step];
}
return self::where($where)
->order('createTime DESC')
->select();
}
/**
* 获取最近的执行记录
* @param int $planId 计划ID
* @param int $step 步骤
* @return array|null 执行记录
*/
public static function getLatestExecution($planId, $step)
{
return self::where([
['plan_id', '=', $planId],
['step', '=', $step]
])
->order('createTime DESC')
->find();
}
/**
* 关联计划
*/
public function plan()
{
return $this->belongsTo('PlanTask', 'plan_id');
}
/**
* 关联流量
*/
public function traffic()
{
return $this->belongsTo('TrafficPool', 'traffic_id');
}
}

25
Server/application/plan/route.php
View File

@@ -1,25 +0,0 @@
<?php
// +----------------------------------------------------------------------
// | 获客计划模块路由
// +----------------------------------------------------------------------
use think\facade\Route;
// API路由组
Route::group('api/plan', function () {
// 任务相关路由
Route::resource('tasks', 'plan/Task');
Route::get('tasks/:id/execute', 'plan/Task/execute');
Route::get('tasks/:id/start', 'plan/Task/start');
Route::get('tasks/:id/stop', 'plan/Task/stop');
Route::get('cron', 'plan/Task/cron');
// 流量相关路由
Route::resource('traffic', 'plan/Traffic');
Route::get('traffic/stats', 'plan/Traffic/sourceStats');
Route::post('traffic/import', 'plan/Traffic/importTraffic');
Route::post('traffic/external', 'plan/Traffic/handleExternalTraffic');
});
// 返回空数组，避免路由注册冲突
return [];