lyhDemo.php 9.7 KB
<?php
/**
 * @remark :
 * @name   :lyhDemo.php
 * @author :lyh
 * @method :post
 * @time   :2025/3/24 9:38
 */

namespace App\Console\Commands\LyhTest;

use App\Console\Commands\Domain\DomainInfo;
use App\Http\Logic\Aside\Project\ProjectLogic;
use App\Models\Ai\AiBlog;
use App\Models\Ai\AiBlogAuthor;
use App\Models\Ai\AiCommand;
use App\Models\Com\NoticeLog;
use App\Models\Com\V6WeeklyReport;
use App\Models\Product\Category;
use App\Models\Project\AiBlogTask;
use App\Models\Project\DeployBuild;
use App\Models\Project\DeployOptimize;
use App\Models\Project\OnlineCheck;
use App\Models\Project\Project;
use App\Models\Project\ProjectAiSetting;
use App\Models\ProjectAssociation\ProjectAssociation;
use App\Models\RouteMap\RouteMap;
use App\Models\Template\BTemplateMain;
use App\Models\Template\TemplateTypeMain;
use App\Models\Visit\Visit;
use App\Models\WebSetting\WebLanguage;
use App\Models\WebSetting\WebSetting;
use App\Models\Workchat\MessagePush;
use App\Services\AiBlogService;
use App\Services\AiCommandService;
use App\Services\ProjectServer;
use Illuminate\Console\Command;
use Illuminate\Support\Facades\Schema;
use Illuminate\Support\Facades\Artisan;
use Illuminate\Support\Facades\DB;

class lyhDemo extends Command
{
    /**
     * The name and signature of the console command.
     *
     * @var string
     */
    protected $signature = 'lyh_demo';

    /**
     * The console command description.
     *
     * @var string
     */
    protected $description = '更新路由';

    public function handle(){
        $projectModel = new Project();
        $lists = $projectModel->list(['delete_status' => 0,'project_type'=>0,'extend_type'=>0,'type'=>['in',[1,2,3,4,6]]], 'id', ['id']);
        foreach ($lists as $item){
//            echo date('Y-m-d H:i:s') . '开始--项目的id:'. $item['id'] . PHP_EOL;
            ProjectServer::useProject($item['id']);
            $webSettingModel = new WebSetting();
            $info = $webSettingModel->read(['project_id'=>$item['id']]);
            if($info === false){
                echo '当前数据为空:'.$item['id'].PHP_EOL;
            }
            DB::disconnect('custom_mysql');
        }
    }

    public function _actionTemplateMain(){
        $data = [];
        $projectModel = new Project();
        $lists = $projectModel->list(['delete_status' => 0,'project_type'=>0,'extend_type'=>0,'type'=>['in',[2,3,4,6]]], 'id', ['id']);
        foreach ($lists as $val){
            echo date('Y-m-d H:i:s') . '开始--项目的id:'. $val['id'] . PHP_EOL;
            ProjectServer::useProject($val['id']);
            $bTemplateMainModel = new BTemplateMain();
            $info = $bTemplateMainModel->read(['type'=>2,'is_list'=>1],['id']);
            $categoryModel = new Category();
            $count = $categoryModel->counts(['id'=>['>',0]]);
            if(($info === false) && ($count > 0)){
                $mainModel = new TemplateTypeMain();
                $mainInfo = $mainModel->read(['type'=>2,'is_list'=>1]);
                $main_html = $mainInfo['main_html'];
                $main_css = "<style id='globalsojs-styles'></style>";
                //写入一条初始数据
                $bTemplateMainModel->addReturnId(['type'=>2,'is_list'=>1,'is_custom'=>0,'project_id'=>$val['id'],'main_html'=>$main_html,'main_css'=>$main_css]);
                $data[] = $val['id'];
            }
            DB::disconnect('custom_mysql');
            echo date('Y-m-d H:i:s') . '结束--项目的id:'. $val['id'] . PHP_EOL;
        }
        dd($data);
    }

    public function _action_ai_blog(){
        $projectModel = new Project();
        $lists = $projectModel->list(['delete_status' => 0,'extend_type'=>0,'type'=>['in',[2,3,4,6]]], 'id', ['id']);
        foreach ($lists as $val) {
            $aiSettingInfo = $this->getSetting($val['id']);
            if($aiSettingInfo === false){
                echo '当前项目未注册。'.$val['id'].PHP_EOL;
                continue;
            }
            $aiBlogTaskModel = new AiBlogTask();
            $blog_lists = $aiBlogTaskModel->list(['type'=>2,'status'=>2,'project_id'=>$val['id']]);
            if(empty($blog_lists)){
                echo '未获取到ao_blog'.PHP_EOL;
                continue;
            }
            echo date('Y-m-d H:i:s') . '开始--项目的id:'. $val['id'] . PHP_EOL;
            ProjectServer::useProject($val['id']);
            $aiBlogService = new AiBlogService($val['id']);
            foreach ($blog_lists as $item) {
                $aiBlogModel = new AiBlog();
                $aiBlogInfo = $aiBlogModel->read(['task_id' => $item['task_id']], ['id']);
                if ($aiBlogInfo === false) {
                    continue;
                }
                try {
                    $aiBlogService->task_id = $item['task_id'];
                    //拉取文章数据
                    $result = $aiBlogService->getDetail();
                    if (isset($result) && ($result['status'] == 200)) {
                        $aiBlogModel->edit(['seo_description' => $result['data']['description']], ['task_id' => $item['task_id']]);
                    }
                } catch (\Exception $e) {
                    echo '跳过。' . PHP_EOL;
                    continue;
                }
            }
            DB::disconnect('custom_mysql');
            echo date('Y-m-d H:i:s') . '结束--项目的id:'. $val['id'] . PHP_EOL;
        }
        return true;
    }

    public function _action(){
        $aiBlogTaskModel = new AiBlogTask();
        $lists = $aiBlogTaskModel->list(['type'=>2,'status'=>2,'project_id'=>467]);
        foreach ($lists as $item){
            echo date('Y-m-d H:i:s') . '开始--项目的id:'. $item['project_id'] . PHP_EOL;
            ProjectServer::useProject($item['project_id']);
            $aiBlogModel = new AiBlog();
            $aiBlogInfo = $aiBlogModel->read(['task_id'=>$item['task_id']],['id','route']);
            if($aiBlogInfo === false){
                continue;
            }
            try {
                $aiBlogService = new AiBlogService($item['project_id']);
                $aiBlogService->task_id = $item['task_id'];
                //拉取文章数据
                $result = $aiBlogService->getDetail();
                if(isset($result) && ($result['status'] == 200)){
                    $aiBlogModel->edit(['seo_description'=>$result['data']['description']],['task_id'=>$item['task_id']]);
                }
            }catch (\Exception $e){
                echo '跳过。'.PHP_EOL;
            }
            DB::disconnect('custom_mysql');
            echo date('Y-m-d H:i:s') . '结束--项目的id:'. $item['project_id'] . PHP_EOL;
        }
    }

    public function getSetting($project_id)
    {
        $projectAiSettingModel = new ProjectAiSetting();
        $aiSettingInfo = $projectAiSettingModel->read(['project_id'=>$project_id]);
        return $aiSettingInfo;
    }


    public function _actions() {
        echo '开始执行...' . PHP_EOL;
        ProjectServer::useProject(565);
        $table = 'gl_product_category';
        $connection = DB::connection('custom_mysql');
        $dbName = $connection->getDatabaseName();
        $brandsStr = 'Trimos,insize,Fowler,Mahr,Starrett,Tesa,Mitutoyo,Wixey,Shars,Fisso,Spi,Grizzly,Accumaster,Accuremote,Baker,Sharpe,Compac,Earth,Etalon,Federal,Fell,Fisso,Fowler,Gem,Grizzly,Husky,iGaging,Insize,Kanetec,Magnetics,Mighty,Mitutoyo,Noga,Pittsburgh,Procheck,Saker,Scherr Tumico,Shars,Shinwa,SPI,Starrett,Tesa,Technidea,Trimos,Verdict,Wyler,Wixey';
        $brands = array_unique(array_map('trim', explode(',', $brandsStr)));
        // 获取文本字段
        $columns = $connection->table('information_schema.columns')
            ->where('table_schema', $dbName)
            ->where('table_name', $table)
            ->whereIn('data_type', ['varchar', 'text', 'mediumtext', 'longtext'])
            ->pluck('column_name')
            ->toArray();
        if (empty($columns)) {
            echo "未找到文本字段,退出。" . PHP_EOL;
            return;
        }
        foreach ($columns as $field) {
            $sqlField = "`$field`";
            // 构造第一轮REPLACE表达式(原样品牌)
            $replaceExprRaw = $sqlField;
            foreach ($brands as $brand) {
                $safeBrand = addslashes($brand);
                $replaceExprRaw = "REPLACE(REPLACE($replaceExprRaw, '$safeBrand-', ''), '$safeBrand', '')";
            }
            // 构造第二轮REPLACE表达式(小写品牌)
            $lowerBrands = array_map('strtolower', $brands);
            $replaceExprLower = $sqlField;
            foreach ($lowerBrands as $brand) {
                $safeBrand = addslashes($brand);
                $replaceExprLower = "REPLACE(REPLACE($replaceExprLower, '$safeBrand-', ''), '$safeBrand', '')";
            }
            // 先执行原样品牌替换
            $sqlRaw = "UPDATE `$table` SET $sqlField = $replaceExprRaw WHERE $sqlField IS NOT NULL AND $sqlField != ''";
            echo "执行字段(品牌原样替换):$field" . PHP_EOL;
            try {
                $connection->update($sqlRaw);
            } catch (\Exception $e) {
                echo "字段 $field 原样替换出错:" . $e->getMessage() . PHP_EOL;
            }
            // 再执行小写品牌替换
            $sqlLower = "UPDATE `$table` SET $sqlField = $replaceExprLower WHERE $sqlField IS NOT NULL AND $sqlField != ''";
            echo "执行字段(品牌小写替换):$field" . PHP_EOL;
            try {
                $connection->update($sqlLower);
            } catch (\Exception $e) {
                echo "字段 $field 小写替换出错:" . $e->getMessage() . PHP_EOL;
            }
        }

        echo '执行结束' . PHP_EOL;

        DB::disconnect('custom_mysql');
    }
}