周海龙 / globalso · 提交

转到一个项目

作者 ZhengBing He
提交 1715d49ffc62bc4a1791eefa903d1bb7070d5776 1 个父辈 82cc311f

is_del

内嵌 并排对比
正在显示 3 个修改的文件 包含 42 行增加 和 50 行删除
... ... @@ -51,7 +51,7 @@ class FetchTicketProjects extends Command
* @return void
* 请求：https://www.quanqiusou.cn/extend_api/webs/globalso_all.php
*/
public function fetch_v5()
public function fetchV5()
{
# pm 项目经理 assm 售后服务经理
$response = Http::get('https://www.quanqiusou.cn/extend_api/webs/globalso_all.php');
... ... @@ -72,13 +72,14 @@ class FetchTicketProjects extends Command
$engineer_id = (strpos($item['cate'], '推广') !== false) ? $assm_id : Manage::where('name', '杨长远')->value('id') ?? 0;
$fields = [
'post_id' => $item['postid'],
'company_name' => $item['company'],
'title' => $item['title'],
'engineer_id' => $engineer_id, // 第一负责人
'assm_id' => $assm_id,
'seom_id' => $seom_id,
'website' => $item['main_url'] ?? '',
'post_id' => $item['postid'],
'company_name' => $item['company'],
'title' => $item['title'],
'engineer_id' => $engineer_id, // 第一负责人
'assm_id' => $assm_id,
'seom_id' => $seom_id,
'website' => $item['main_url'] ?? '',
'is_del' => 0,
];
if (!$project) {
$new = new TicketProject();
... ... @@ -103,6 +104,12 @@ class FetchTicketProjects extends Command
}
echo "V5: {$item['postid']} - {$item['title']} - {$item['company']} - {$item['main_url']}\n";
}
$postids = collect($items)->pluck('postid')->toArray();
// 软删除 gl_ticket_projects 中不存在的项目
TicketProject::where('version', 5)
->whereNotIn('post_id', $postids)
->update(['is_del' => 1]);
echo "V5: fetch completed, total " . count($items) . " items\n";
}
}
... ... @@ -111,12 +118,15 @@ class FetchTicketProjects extends Command
* 1. 按照ID升序查询 gl_project 表 limit 10
* 2。同步到 TicketProject 后，redis 缓存 ID
*/
public function fetch_v6()
public function fetchV6()
{
$lastid = 0;
while (true) {
try {
$items = Project::where('id', '>', intval($lastid))
// ->where('delete_status', 0)
// ->where('extend_type', '!=', 5) // 排除归档项目
// ->where('type', '!=', 8) // 排除归档项目
->orderBy('id', 'asc')
->limit(10)
->get();
... ... @@ -143,22 +153,29 @@ class FetchTicketProjects extends Command
if (in_array($item->type, [Project::TYPE_TWO, Project::TYPE_FOUR, Project::TYPE_SIX])) {
// 优化推广项目
$engineer_id = $assm_id;
}elseif ($item->type == Project::TYPE_THREE) {
} elseif ($item->type == Project::TYPE_THREE) {
$engineer_id = Manage::where('name', '杨长远')->value('id') ?? 0; // 建站类项目找杨长远
}else{
} else {
$engineer_id = collect([
$item->deploy_build->manager_mid ?? 0,
$item->deploy_build->leader_mid ?? 0,
0
])->first(fn($v) => $v !== null && $v !== 0, 0);
}
$is_del = (
$item->extend_type == 5
|| $item->type == 8
|| $item->delete_status == 1
|| $item->site_status == 1
) ? 1 : 0;
$fields = [
'company_name' => $item->company,
'title' => $item->title,
'company_name' => $item->company,
'title' => $item->title,
'assm_id' => $assm_id,
'seom_id' => $seom_id,
'engineer_id' => $engineer_id
'engineer_id' => $engineer_id,
'is_del' => $is_del
];
if (!$project) {
$project = new TicketProject();
... ... @@ -170,7 +187,7 @@ class FetchTicketProjects extends Command
$project->$k = $v;
}
$project->save();
}else{
} else {
$changed = false;
foreach ($fields as $k => $v) {
if ($project->$k != $v) {
... ... @@ -185,7 +202,7 @@ class FetchTicketProjects extends Command
$lastid = $item->id;
echo date('Y-m-d H:i:s') . " V6: $item->id {$item->company} fetch ok \n";
}
}catch (\Exception $exception) {
} catch (\Exception $exception) {
echo $exception;
break;
}
... ... @@ -213,7 +230,7 @@ class FetchTicketProjects extends Command
$lastid = $item->id;
echo date('Y-m-d H:i:s') . " V6: $item->id fetch ok \n";
}
}catch (\Exception $exception) {
} catch (\Exception $exception) {
echo $exception;
break;
}
... ...
... ... @@ -46,12 +46,9 @@ class TicketController extends BaseController
$request->validated();
$project = TicketProject::where('uuid', $project_id)->first();
if (!$project) return $this->error('未找到项目', 404);
if ($project->version == 6){
if ($project->project->projectV6->delete_status) return $this->error('该项目已被删除', 400);
if ($project->project->projectV6->extend_type == 5) return $this->error('未续费', 400);
if ($project->project->projectV6->type == 8) return $this->error('项目已归档', 400);
if ($project->project->projectV6->site_status == 1) return $this->error('站点已关闭', 400);
}
if ($project->is_del) return $this->error('项目状态异常', 400);
if (empty($project->engineer_id)) return $this->error('项目未分配工单负责人', 400);
$result = DB::transaction(function () use ($request, $project) {
$ticket = new Tickets();
$ticket->project_id = $project->id;
... ... @@ -68,21 +65,7 @@ class TicketController extends BaseController
$ticket->submit_username = $request->input('submit_username');
$ticket->save();
$log = new TicketLog();
if ($project->version == 5){
# V5
$log->engineer_id = $project->engineer_id;
}else{
# V6 的项目
if ($project->projectV6->type == 3){
// 项目类型是优化推广，项目负责人找优化
$seo = $project->projectV6->deploy_optimize;
$log->engineer_id = $seo->manager_mid ?? $seo->optimist_mid ?? 0;
}else{
// 非优化推广项目，项目负责人找技术组长
$build = $project->projectV6->deploy_build;
$log->engineer_id = $build->leader_mid ?? 0;
}
}
$log->engineer_id = $project->engineer_id; // 默认第一负责人
$ticket->logs()->save($log);
return $ticket;
});
... ... @@ -107,12 +90,8 @@ class TicketController extends BaseController
if ($ticket->project->uuid !== $project_id) return $this->error('无权限查看该工单', 403);
if ($ticket->project->version == 6){
if ($ticket->project->projectV6->delete_status) return $this->error('该项目已被删除', 400);
if ($ticket->project->projectV6->extend_type == 5) return $this->error('未续费', 400);
if ($ticket->project->projectV6->type == 8) return $this->error('项目已归档', 400);
if ($ticket->project->projectV6->site_status == 1) return $this->error('站点已关闭', 400);
}
if ($ticket->project->is_del) return $this->error('项目状态异常', 400);
return response()->json(['data' => $ticket]);
}
... ...
... ... @@ -73,6 +73,7 @@ class AsideTicketController extends BaseController
$projects = TicketProject::with([
'projectV6:id,company,title',
])
->where('is_del', 0)
->where(function ($query) use ($search) {
$query->where('title', 'like', '%' . $search . '%')
->orWhere('company_name', 'like', '%' . $search . '%')
... ... @@ -95,12 +96,7 @@ class AsideTicketController extends BaseController
{
$request->validated();
$project = TicketProject::where('uuid', $request->input('project_id'))->first();
if ($project->version == 6){
if ($project->projectV6->delete_status) $this->response('该项目已被删除', Code::USER_MODEL_NOTFOUND_ERROE);
if ($project->projectV6->extend_type == 5) $this->response('未续费', Code::USER_MODEL_NOTFOUND_ERROE);
if ($project->projectV6->type == 8) $this->response('项目已归档', Code::USER_MODEL_NOTFOUND_ERROE);
if ($project->projectV6->site_status == 1) $this->response('站点已关闭', Code::USER_MODEL_NOTFOUND_ERROE);
}
if ($project->is_del) $this->response('该项目状态异常', Code::USER_MODEL_NOTFOUND_ERROE);
$result = DB::transaction(function () use ($request, $project) {
$ticket = new Tickets();
$ticket->project_id = $project->id;
... ...