作者 Your Name
<?php
/**
* @remark :
* @name :SendProduct.php
* @author :lyh
* @method :post
* @time :2024/8/30 14:41
*/
namespace App\Console\Commands\Product;
use App\Models\Blog\Blog;
use App\Models\Domain\DomainInfo;
use App\Models\News\News;
use App\Models\Product\Product;
use App\Models\Project\Project;
use App\Services\ProjectServer;
use Illuminate\Console\Command;
use Illuminate\Support\Facades\DB;
class SendProduct extends Command
{
/**
* The name and signature of the console command.
*
* @var string
*/
protected $signature = 'send_product';
/**
* The console command description.
*
* @var string
*/
protected $description = '根据发布时间发布产品';
/**
* @remark :发布
* @name :handle
* @author :lyh
* @method :post
* @time :2024/8/30 14:42
*/
public function handle(){
$projectModel = new Project();
$list = $projectModel->list(['deleted_status'=>0]);
$data = [];
foreach ($list as $v){
echo date('Y-m-d H:i:s') . 'project_id:'.$v['id'] . PHP_EOL;
ProjectServer::useProject($v['id']);
$domainModel = new DomainInfo();
$domain = $domainModel->getProjectIdDomain($v['id']);
if(empty($domain)){
continue;
}
$arr1 = $this->sendProduct();
$arr2 = $this->sendBlog();
$arr3 = $this->sendNews();
$c_url = $domain.'api/update_page/';
$param = [
'project_id' => $this->user['project_id'],
'type' => 1,
'route' => 3,
'url' => array_merge($arr1,$arr2,$arr3),
'language'=> [],
'is_sitemap' => 0
];
http_post($c_url, json_encode($param));
//TODO::通知C端生成界面
DB::disconnect('custom_mysql');
}
echo date('Y-m-d H:i:s') . 'end' . PHP_EOL;
}
/**
* @remark :发布产品
* @name :sendProduct
* @author :lyh
* @method :post
* @time :2024/8/30 14:44
*/
public function sendProduct(){
$start_date = date('Y-m-d H:i:s');
$end_date = date('Y-m-d 23:59:59');
$productModel = new Product();
$arr = $productModel->formatQuery(['send_time'=>['between',[$start_date,$end_date]],'status'=>3])->pluck('route');
$productModel->edit(['status'=>1],['send_time'=>['between',[$start_date,$end_date]],'status'=>3]);
return $arr;
}
/**
* @remark :定时发布博客
* @name :sendBlog
* @author :lyh
* @method :post
* @time :2024/8/30 15:19
*/
public function sendBlog(){
$start_date = date('Y-m-d H:i:s');
$end_date = date('Y-m-d 23:59:59');
$blogModel = new Blog();
$arr = $blogModel->formatQuery(['send_time'=>['between',[$start_date,$end_date]],'status'=>3])->pluck('url');
$blogModel->edit(['status'=>1],['release_at'=>['between',[$start_date,$end_date]],'status'=>3]);
return $arr;
}
/**
* @remark :定时发布新闻
* @name :sendNews
* @author :lyh
* @method :post
* @time :2024/8/30 15:19
*/
public function sendNews(){
$start_date = date('Y-m-d H:i:s');
$end_date = date('Y-m-d 23:59:59');
$newsModel = new News();
$arr = $newsModel->formatQuery(['send_time'=>['between',[$start_date,$end_date]],'status'=>3])->pluck('url');
$newsModel->edit(['status'=>1],['release_at'=>['between',[$start_date,$end_date]],'status'=>3]);
return $arr;
}
}
... ...
... ... @@ -383,20 +383,12 @@ class ProjectUpdate extends Command
'sort' => $item['sort'] ?? 0,
'files' => $files,
], ['id' => $id]);
} else {
//按6.0展示只更新分类
$model->edit([
'category_id' => $category_id
], ['id' => $id]);
}
}
if ($six_read) {
//关联分类
if ($category_arr) {
CategoryRelated::saveRelated($id, array_column($category_arr, 'id'));
}
if ($six_read) {
//扩展字段
if ($item['extend'] ?? []) {
foreach (array_reverse($item['extend']) as $ke => $ve) {
... ... @@ -508,9 +500,7 @@ class ProjectUpdate extends Command
CollectTask::_insert($item['url'], $project_id, $api_type == 'news' ? RouteMap::SOURCE_NEWS : RouteMap::SOURCE_BLOG, $id, $domain_arr['host'], $link_type, $language_list, $page_list);
} else {
$id = $news['id'];
$six_read = $news['six_read'];
if ($six_read) {
if ($news['six_read']) {
//按5.0展示才需要更新数据
$model->edit([
'name' => $item['ttile'],
... ... @@ -522,7 +512,7 @@ class ProjectUpdate extends Command
'image' => $new_img,
'release_at' => $item['post_date'] ?? date('Y-m-d H:i:s'),
'sort' => $item['sort'] ?? 0,
], ['id' => $id]);
], ['id' => $news['id']]);
}
}
} catch (\Exception $e) {
... ...
... ... @@ -164,8 +164,12 @@ class ProductController extends BaseController
$query = $query->where('title','like','%'.$this->map['title'].'%');
}
if(isset($this->map['status'])){
if($this->map['status'] == 0){
$query = $query->whereIn('status',[0,3]);
}else{
$query = $query->where('status',$this->map['status']);
}
}
if(isset($this->map['created_uid'])){
$query = $query->where('created_uid',$this->map['created_uid']);
}
... ... @@ -721,4 +725,20 @@ class ProductController extends BaseController
$typeModel->del(['project_id'=>$this->user['project_id'],'name'=>$this->param['name']]);
$this->response('success');
}
/**
* @remark :获取按钮
* @name :getButton
* @author :lyh
* @method :post
* @time :2024/8/30 16:29
*/
public function getButton(){
return [
'0'=>'草稿',
'1'=>'发布',
'2'=>'回收站',
'3'=>'待发布'
];
}
}
... ...
... ... @@ -260,6 +260,7 @@ Route::middleware(['bloginauth'])->group(function () {
Route::any('/getProductType', [\App\Http\Controllers\Bside\Product\ProductController::class, 'getProductType'])->name('product_getProductType');
Route::any('/saveType', [\App\Http\Controllers\Bside\Product\ProductController::class, 'saveType'])->name('product_saveType');
Route::any('/delProductType', [\App\Http\Controllers\Bside\Product\ProductController::class, 'delProductType'])->name('product_delProductType');
Route::any('/getButton', [\App\Http\Controllers\Bside\Product\ProductController::class, 'getButton'])->name('product_getButton');
//产品分类
Route::get('category', [\App\Http\Controllers\Bside\Product\CategoryController::class, 'index'])->name('product_category');
Route::get('category/info', [\App\Http\Controllers\Bside\Product\CategoryController::class, 'info'])->name('product_category_info');
... ...