作者 刘锟

Merge remote-tracking branch 'origin/master' into akun

@@ -41,18 +41,36 @@ class lyhDemo extends Command @@ -41,18 +41,36 @@ class lyhDemo extends Command
41 protected $description = '更新路由'; 41 protected $description = '更新路由';
42 42
43 public function handle(){ 43 public function handle(){
44 - //获取  
45 - $keywordPrefixModel = new KeywordPrefix();  
46 - $lists = $keywordPrefixModel->list(['project_id'=>0,'id'=>['<',29]]);  
47 - $whiteModel = new ProjectWhiteHatAffix();  
48 - foreach ($lists as $val) {  
49 - echo date('Y-m-d H:i:s') . '开始--项目的id:' . $val['id'] . PHP_EOL; 44 + return $this->aggregate_keyword_affix();
  45 + }
  46 +
  47 + /**
  48 + * @remark :获取数据
  49 + * @name :aggregate_keyword_affix
  50 + * @author :lyh
  51 + * @method :post
  52 + * @time :2025/6/26 17:58
  53 + */
  54 + public function aggregate_keyword_affix(){
  55 + $projectModel = new Project();
  56 + $lists = $projectModel->list(['delete_status' => 0,'project_type'=>0,'extend_type'=>0,'type'=>['in',[1,2,4,6]]], 'id', ['id']);
  57 + $keywordAffixModel = new AggregateKeywordAffix();
  58 + foreach ($lists as $val){
  59 + $info = $keywordAffixModel->read(['project_id'=>$val['id']]);
  60 +
  61 +
  62 + $prefix = "How To find"."\n"."Why Choose"."\n"."China Top"."\n"."Best Way To Choose"."\n"."Methods To Choose";
  63 + $suffix = "Manufacturer"."\n"."Supplier"."\n"."Products"."\n"."Factory";
  64 + if($info === false){
  65 + echo '执行的项目id:'.$val['id'].PHP_EOL;
50 $data = [ 66 $data = [
51 - 'project_id'=>0,  
52 - 'name'=>$val['keyword'],  
53 - 'type'=>$val['type'], 67 + 'project_id'=>$val['id'],
  68 + 'prefix'=>$prefix,
  69 + 'suffix'=>$suffix,
54 ]; 70 ];
55 - $whiteModel->add($data); 71 + $keywordAffixModel->addReturnId($data);
  72 + }
  73 +
56 } 74 }
57 return true; 75 return true;
58 } 76 }
@@ -52,7 +52,7 @@ class GeneratePage extends Command @@ -52,7 +52,7 @@ class GeneratePage extends Command
52 $noticeModel = new NoticeLog(); 52 $noticeModel = new NoticeLog();
53 while (true){ 53 while (true){
54 $task_id = $this->getTaskId(); 54 $task_id = $this->getTaskId();
55 - if (empty($noticeInfo)) { 55 + if (empty($task_id)) {
56 sleep(10); 56 sleep(10);
57 continue; 57 continue;
58 } 58 }
@@ -90,16 +90,17 @@ class GeneratePage extends Command @@ -90,16 +90,17 @@ class GeneratePage extends Command
90 */ 90 */
91 public function getTaskId() 91 public function getTaskId()
92 { 92 {
93 - $task_id = Redis::rpop('generate_page_id'); 93 + $task_id = Redis::rpop('generate_page');
  94 + echo '任务id:'.$task_id.PHP_EOL;
94 if (empty($task_id)) { 95 if (empty($task_id)) {
95 $noticeModel = new NoticeLog(); 96 $noticeModel = new NoticeLog();
96 - $ids = $noticeModel->selectField(['status'=>0],'id'); 97 + $ids = $noticeModel->selectField(['status'=>0,'type'=>NoticeLog::GENERATE_PAGE],'id');
97 if(!empty($ids)){ 98 if(!empty($ids)){
98 foreach ($ids as $id) { 99 foreach ($ids as $id) {
99 - Redis::lpush('generate_page_id', $id); 100 + Redis::lpush('generate_page', $id);
100 } 101 }
101 } 102 }
102 - $task_id = Redis::rpop('generate_page_id'); 103 + $task_id = Redis::rpop('generate_page');
103 } 104 }
104 return $task_id; 105 return $task_id;
105 } 106 }
@@ -77,7 +77,7 @@ class PushNotify extends Command @@ -77,7 +77,7 @@ class PushNotify extends Command
77 'desc' => $tick->title, 77 'desc' => $tick->title,
78 'size' => 0, 78 'size' => 0,
79 'thumbSize' => 0, 79 'thumbSize' => 0,
80 - 'thumbUrl' => 'https://www.cmer.com/uploads/logo1.png', 80 + 'thumbUrl' => 'https://oa.quanqiusou.cn/logo.ico',
81 'url' => 'https://oa.quanqiusou.cn/tickets?project_id='.$project->uuid 81 'url' => 'https://oa.quanqiusou.cn/tickets?project_id='.$project->uuid
82 ], JSON_UNESCAPED_UNICODE); 82 ], JSON_UNESCAPED_UNICODE);
83 $message_push->send_time = now(); 83 $message_push->send_time = now();
@@ -44,6 +44,7 @@ class WorkOrderDing extends Command @@ -44,6 +44,7 @@ class WorkOrderDing extends Command
44 try { 44 try {
45 $log = TicketLog::where('ding', 0)->first(); 45 $log = TicketLog::where('ding', 0)->first();
46 if (!$log) { 46 if (!$log) {
  47 + echo now() . " INFO | 没有通知任务\n";
47 sleep(3); 48 sleep(3);
48 continue; 49 continue;
49 } 50 }
@@ -69,7 +70,7 @@ class WorkOrderDing extends Command @@ -69,7 +70,7 @@ class WorkOrderDing extends Command
69 $log->ding = 2; 70 $log->ding = 2;
70 $log->save(); 71 $log->save();
71 }catch (\Exception $exception){ 72 }catch (\Exception $exception){
72 - echo date('Y-m-d H:i:s')." ".$exception->getMessage()."\n"; 73 + echo now() . " ERROR | ".$exception->getMessage()."\n";
73 break; 74 break;
74 } 75 }
75 } 76 }
@@ -56,9 +56,9 @@ class TicketChatController extends Controller @@ -56,9 +56,9 @@ class TicketChatController extends Controller
56 $chat->content = $request->input('content'); 56 $chat->content = $request->input('content');
57 $files = $request->input('files'); 57 $files = $request->input('files');
58 if (empty($files) || (is_array($files) && count(array_filter($files, function($v){ return !is_null($v); })) === 0)) { 58 if (empty($files) || (is_array($files) && count(array_filter($files, function($v){ return !is_null($v); })) === 0)) {
59 - $ticket->files = null; 59 + $chat->files = null;
60 } else { 60 } else {
61 - $ticket->files = json_encode($files); 61 + $chat->files = json_encode($files);
62 } 62 }
63 $chat->submit_side = 2; 63 $chat->submit_side = 2;
64 $chat->submit_username = $request->input('submit_username'); 64 $chat->submit_username = $request->input('submit_username');
@@ -29,7 +29,7 @@ class TicketController extends BaseController @@ -29,7 +29,7 @@ class TicketController extends BaseController
29 'logs.engineer:id,name', 29 'logs.engineer:id,name',
30 ]) 30 ])
31 ->where('project_id', $project->id) 31 ->where('project_id', $project->id)
32 - ->where('submit_side', 2) 32 +// ->where('submit_side', 2)
33 ->orderBy('id', 'desc') 33 ->orderBy('id', 'desc')
34 ->paginate($size, ['*'], 'page', $page); 34 ->paginate($size, ['*'], 'page', $page);
35 return response()->json(['data' => $tickets]); 35 return response()->json(['data' => $tickets]);
@@ -7,6 +7,7 @@ use App\Http\Controllers\Aside\BaseController; @@ -7,6 +7,7 @@ use App\Http\Controllers\Aside\BaseController;
7 use App\Http\Requests\Aside\WorkOrder\AsideTicketStoreRequest; 7 use App\Http\Requests\Aside\WorkOrder\AsideTicketStoreRequest;
8 use App\Http\Requests\Aside\WorkOrder\AsideTicketListRequest; 8 use App\Http\Requests\Aside\WorkOrder\AsideTicketListRequest;
9 use App\Http\Requests\Aside\WorkOrder\AsideTicketUpdateRequest; 9 use App\Http\Requests\Aside\WorkOrder\AsideTicketUpdateRequest;
  10 +use App\Http\Requests\Aside\WorkOrder\TicketProjectListRequest;
10 use App\Models\WorkOrder\TicketLog; 11 use App\Models\WorkOrder\TicketLog;
11 use App\Models\WorkOrder\TicketProject; 12 use App\Models\WorkOrder\TicketProject;
12 use App\Models\WorkOrder\Tickets; 13 use App\Models\WorkOrder\Tickets;
@@ -82,6 +83,32 @@ class AsideTicketController extends BaseController @@ -82,6 +83,32 @@ class AsideTicketController extends BaseController
82 } 83 }
83 84
84 /** 85 /**
  86 + * @param TicketProjectListRequest $request
  87 + * @return void
  88 + * A端V5V6项目列表
  89 + */
  90 + public function projectList(TicketProjectListRequest $request)
  91 + {
  92 + $validated = $request->validated();
  93 + $lists = TicketProject::where('is_del', 0)
  94 + ->when(!empty($validated['search']), function ($query) use ($validated) {
  95 + // 查找项目名称或公司名称
  96 + $search = $validated['search'];
  97 + return $query->where(function ($q) use ($search) {
  98 + $q->where('title', 'like', '%' . $search . '%')
  99 + ->orWhere('company_name', 'like', '%' . $search . '%');
  100 + });
  101 + })
  102 + ->when(!empty($validated['version']), function ($query) use ($validated) {
  103 + // 版本号筛选
  104 + $version = $validated['version'];
  105 + return $query->where('version', $version);
  106 + })
  107 + ->paginate($this->row, ['*'], 'page', $this->page);
  108 + $this->response('success', Code::SUCCESS, $lists);
  109 + }
  110 +
  111 + /**
85 * Store a newly created resource in storage. 112 * Store a newly created resource in storage.
86 * 113 *
87 * @param \Illuminate\Http\Request $request 114 * @param \Illuminate\Http\Request $request
@@ -43,7 +43,7 @@ class TicketChatController extends BaseController @@ -43,7 +43,7 @@ class TicketChatController extends BaseController
43 public function store(TicketChatStoreRequest $request, $ticket_id) 43 public function store(TicketChatStoreRequest $request, $ticket_id)
44 { 44 {
45 $validated = $request->validated(); 45 $validated = $request->validated();
46 - $ticket = Tickets::find($request->input('ticket_id')); 46 + $ticket = Tickets::find($ticket_id);
47 if (!$ticket) return response('工单未找到', 404); 47 if (!$ticket) return response('工单未找到', 404);
48 if ($ticket->project->is_del) return response('项目状态异常', 400); 48 if ($ticket->project->is_del) return response('项目状态异常', 400);
49 49
@@ -51,11 +51,11 @@ class TicketChatController extends BaseController @@ -51,11 +51,11 @@ class TicketChatController extends BaseController
51 $chat->ticket_id = $ticket->id; 51 $chat->ticket_id = $ticket->id;
52 $chat->content = $validated['content']; 52 $chat->content = $validated['content'];
53 53
54 - $files = $validated['files']; 54 + $files = $validated['files'] ?? [];
55 if (empty($files) || (is_array($files) && count(array_filter($files, function($v){ return !is_null($v); })) === 0)) { 55 if (empty($files) || (is_array($files) && count(array_filter($files, function($v){ return !is_null($v); })) === 0)) {
56 - $ticket->files = null; 56 + $chat->files = null;
57 } else { 57 } else {
58 - $ticket->files = json_encode($files); 58 + $chat->files = json_encode($files);
59 } 59 }
60 60
61 $chat->submit_username = $this->manage['name']; 61 $chat->submit_username = $this->manage['name'];
@@ -76,6 +76,6 @@ class EnterpriseProductLogic extends BaseLogic @@ -76,6 +76,6 @@ class EnterpriseProductLogic extends BaseLogic
76 $linkModel->insertAll($data); 76 $linkModel->insertAll($data);
77 } 77 }
78 DB::disconnect('custom_mysql'); 78 DB::disconnect('custom_mysql');
79 - return $this->success(['success'=>'成功数量:'.$count-$error_num,'error'=>'失败数量:'.$error_num]); 79 + return $this->success(['success'=>$count,'error'=>$error_num]);
80 } 80 }
81 } 81 }
  1 +<?php
  2 +
  3 +namespace App\Http\Requests\Aside\WorkOrder;
  4 +
  5 +use Illuminate\Foundation\Http\FormRequest;
  6 +
  7 +class TicketProjectListRequest extends FormRequest
  8 +{
  9 + /**
  10 + * Determine if the user is authorized to make this request.
  11 + *
  12 + * @return bool
  13 + */
  14 + public function authorize()
  15 + {
  16 + return true;
  17 + }
  18 +
  19 + /**
  20 + * Get the validation rules that apply to the request.
  21 + *
  22 + * @return array
  23 + */
  24 + public function rules()
  25 + {
  26 + return [
  27 + 'search' => 'nullable|string', // 搜索关键词
  28 + 'version' => 'nullable|in:5,6', // 版本号
  29 + ];
  30 + }
  31 +}
@@ -9,6 +9,7 @@ @@ -9,6 +9,7 @@
9 namespace App\Services; 9 namespace App\Services;
10 10
11 use App\Models\CustomModule\CustomModule; 11 use App\Models\CustomModule\CustomModule;
  12 +use App\Models\Project\AggregateKeywordAffix;
12 use App\Models\Project\Project; 13 use App\Models\Project\Project;
13 use App\Models\RouteMap\RouteMap; 14 use App\Models\RouteMap\RouteMap;
14 use App\Models\Template\BCustomTemplate; 15 use App\Models\Template\BCustomTemplate;
@@ -140,6 +141,8 @@ class ProjectServer @@ -140,6 +141,8 @@ class ProjectServer
140 self::initColumn(); 141 self::initColumn();
141 //初始化search页面 142 //初始化search页面
142 // self::initSearchPage($project_id); 143 // self::initSearchPage($project_id);
  144 + //聚合页关键词前后缀
  145 + self::initAggregateKeywordAffix($project_id);
143 DB::disconnect('custom_mysql'); 146 DB::disconnect('custom_mysql');
144 return true; 147 return true;
145 } 148 }
@@ -280,4 +283,29 @@ class ProjectServer @@ -280,4 +283,29 @@ class ProjectServer
280 } 283 }
281 } 284 }
282 } 285 }
  286 +
  287 + /**
  288 + * @remark :gl_aggregate_keyword_affix处理聚合页关键词前后缀
  289 + * @name :initAffix
  290 + * @author :lyh
  291 + * @method :post
  292 + * @time :2025/6/26 17:48
  293 + */
  294 + public static function initAggregateKeywordAffix($project_id){
  295 + $time = date('Y-m-d H:i:s');
  296 + $prefix = "How To"."\n"."Why"."\n"."Top 5"."\n"."Top 3"."\n"."Best Way To"."\n"."Methods To"."\n"."Top-Rated"."\n"."How To find"."\n"."why choose"."\n"."China Top"."\n"."Best Way To Choose"."\n"."Methods To choose"."\n"."10 tips"."\n"."Top 10"."\n"."How To Select"."\n"."How To Find The Best"."\n"."How To Evaluate"."\n"."How To Compare"."\n"."How To Identify"."\n"."How To Source"."\n"."How To Pick The Right"."\n"."How To Decide Between"."\n"."Why Opt For"."\n"."Why Invest In"."\n"."Why Consider"."\n"."Why Trust"."\n"."Why Professionals Prefer"."\n"."Top Picks For"."\n"."Best Practices For"."\n"."Best Ways To"."\n"."Best Options For"."\n"."Best Brands For"."\n"."Best Methods To"."\n"."Best Strategies For"."\n"."Effective Ways To"."\n"."Proven Methods To"."\n"."Simple Ways To"."\n"."Key Methods For"."\n"."Smart Ways To"."\n"."Practical Methods To"."\n"."Step-by-Step Guide To"."\n"."10 Essential Tips For"."\n"."7 Key Tips To"."\n"."Ultimate Guide To"."\n"."Expert Tips For"."\n"."Must-Know Tips For"."\n"."Quick Tips To"."\n"."Insider Tips For"."\n"."Leading Chinese"."\n"."Best Chinese"."\n"."China’s Best-Selling"."\n"."Why China’s"."\n"."How Chinese Manufacturers"."\n"."Exploring"."\n"."Uncovering"."\n"."Discovering"."\n"."Pinpointing"."\n"."Decoding"."\n"."Reasons to Choose"."\n"."Advantages Explained"."\n"."Where the Value Lies"."\n"."Not to Be Missed"."\n"."Must-Choose Reasons"."\n"."Excellence in"."\n"."Cutting-Edge"."\n"."Premier"."\n"."Champions of"."\n"."The Ultimate Guide to"."\n"."Practical Strategies for"."\n"."Making Smart Choices"."\n"."Key Steps to Choosing"."\n"."Finding Your Perfect Match"."\n"."Avoiding Pitfalls"."\n"."Tips & Tricks for"."\n"."In-Depth Analysis of"."\n"."Methods"."\n"."How-To Guide"."\n"."Step-by-Step Guide"."\n"."The Secret to"."\n"."Must-See List"."\n"."Curated Selection of"."\n"."Trending"."\n"."Popular"."\n"."Don't Miss These"."\n"."Comprehensive Comparison of"."\n"."The Clear Choice of"."\n"."Today's Choice of"."\n"."Expert Choice of";
  297 + $suffix = "Manufacturer"."\n"."Supplier"."\n"."Application"."\n"."Products"."\n"."Service"."\n"."Factory"."\n"."Is The Best"."\n"."Stands Out"."\n"."Dominates"."\n"."in 2025"."\n"."Industry Leaders"."\n"."Industry Giant"."\n"."Market Leader"."\n"."For the Current Year"."\n"."Ahead of the Curve"."\n"."Trusted by Pros"."\n"."Pioneers in the Field"."\n"."Now Trending"."\n"."Sets the Industry Standard"."\n"."Leads the Global Market"."\n"."Delivers Unmatched Quality"."\n"."Guarantees Peak Performance"."\n"."Exceeds Industry Benchmarks"."\n"."Winning in 2025"."\n"."Where Innovation Meets 2025"."\n"."Your Trusted OEM Partner"."\n"."Supplies the World’s Top Brands"."\n"."Manufacturers You Can Rely On"."\n"."Factory-Direct Excellence"."\n"."Custom Solutions,"."\n"."Global Reach"."\n"."Where Service Meets Innovation"."\n"."Your End-to-End Solution"."\n"."More Than a Supplier - A Partner"."\n"."Service Backed by Expertise"."\n"."From Concept to Delivery"."\n"."Outperforms the Competition";
  298 + $info = DB::table('gl_aggregate_keyword_affix')->where('project_id',$project_id)->first();
  299 + if(empty($info)){
  300 + $data = [
  301 + 'project_id'=>$project_id,
  302 + 'prefix'=>$prefix,
  303 + 'suffix'=>$suffix,
  304 + 'created_at' => $time,
  305 + 'updated_at' => $time
  306 + ];
  307 + DB::table('gl_aggregate_keyword_affix')->insert($data);
  308 + }
  309 + return true;
  310 + }
283 } 311 }
@@ -255,6 +255,7 @@ Route::middleware(['aloginauth'])->group(function () { @@ -255,6 +255,7 @@ Route::middleware(['aloginauth'])->group(function () {
255 Route::get('/{id}', [Aside\WorkOrder\AsideTicketController::class, 'show'])->name('admin.tickets.show')->summary('A端工单详情'); 255 Route::get('/{id}', [Aside\WorkOrder\AsideTicketController::class, 'show'])->name('admin.tickets.show')->summary('A端工单详情');
256 Route::post('/{id}', [Aside\WorkOrder\AsideTicketController::class, 'update'])->name('admin.tickets.update')->summary('A端更新工单,审核,邀请同事'); 256 Route::post('/{id}', [Aside\WorkOrder\AsideTicketController::class, 'update'])->name('admin.tickets.update')->summary('A端更新工单,审核,邀请同事');
257 Route::get('/projects/{search}', [Aside\WorkOrder\AsideTicketController::class, 'getProjects'])->name('admin.tickets.projects')->summary('A端V5V6项目列表'); 257 Route::get('/projects/{search}', [Aside\WorkOrder\AsideTicketController::class, 'getProjects'])->name('admin.tickets.projects')->summary('A端V5V6项目列表');
  258 + Route::get('/v56_projects/list', [Aside\WorkOrder\AsideTicketController::class, 'projectList'])->name('admin.tickets.projectList')->summary('A端V5V6项目列表');
258 Route::post('/log/{id}', [Aside\WorkOrder\AsideTicketLogController::class, 'update'])->name('admin.tickets.log.update')->summary('A端工单操作日志更新,完成工单'); 259 Route::post('/log/{id}', [Aside\WorkOrder\AsideTicketLogController::class, 'update'])->name('admin.tickets.log.update')->summary('A端工单操作日志更新,完成工单');
259 Route::get('/chat/{ticket_id}', [Aside\WorkOrder\TicketChatController::class, 'index'])->name('admin.tickets.chat.index')->summary('A端工单聊天记录'); 260 Route::get('/chat/{ticket_id}', [Aside\WorkOrder\TicketChatController::class, 'index'])->name('admin.tickets.chat.index')->summary('A端工单聊天记录');
260 Route::post('/chat/{ticket_id}', [Aside\WorkOrder\TicketChatController::class, 'store'])->name('admin.tickets.chat.store')->summary('A端工单聊天记录创建'); 261 Route::post('/chat/{ticket_id}', [Aside\WorkOrder\TicketChatController::class, 'store'])->name('admin.tickets.chat.store')->summary('A端工单聊天记录创建');