合并分支 'lyh-server' 到 'master'

Lyh server



查看合并请求 !2487

@@ -9,11 +9,14 @@
 
 
 namespace App\Console\Commands\Ai;
 namespace App\Console\Commands\Ai;
 
 
+use App\Models\Ai\AiVideo;
 use App\Models\Product\Keyword;
 use App\Models\Product\Keyword;
 use App\Models\Product\Product;
 use App\Models\Product\Product;
+use App\Models\Project\AiBlogTask as AiBlogTaskModel;
 use App\Models\Project\AiVideoAutoLog;
 use App\Models\Project\AiVideoAutoLog;
 use App\Models\Project\DeployOptimize;
 use App\Models\Project\DeployOptimize;
 use App\Models\Project\Project;
 use App\Models\Project\Project;
+use App\Services\AiVideoService;
 use App\Services\MidJourneyService;
 use App\Services\MidJourneyService;
 use App\Services\ProjectServer;
 use App\Services\ProjectServer;
 use Illuminate\Console\Command;
 use Illuminate\Console\Command;
@@ -63,7 +66,7 @@ class AiVideoAutoPublish extends Command
         $this->output('开始自动发布Video文章');
         $this->output('开始自动发布Video文章');
         $projectModel = new Project();
         $projectModel = new Project();
         $optimizeModel = new DeployOptimize();
         $optimizeModel = new DeployOptimize();
-        $projectList = $projectModel->list(['is_ai_video'=>1,'project_type'=>0,'delete_status'=>0,'site_status'=>0,'extend_type'=>0],'id',['id']);
+        $projectList = $projectModel->list(['is_ai_video'=>1,'id'=>1,'project_type'=>0,'delete_status'=>0,'site_status'=>0,'extend_type'=>0],'id',['id']);
         foreach ($projectList as $item){
         foreach ($projectList as $item){
             $this->output("项目{$item['id']}开始自动发布");
             $this->output("项目{$item['id']}开始自动发布");
             //获取当前是否开启自动发布aiVideo
             //获取当前是否开启自动发布aiVideo
@@ -147,11 +150,13 @@ class AiVideoAutoPublish extends Command
         $aiVideoAutoLogModel = new AiVideoAutoLog();
         $aiVideoAutoLogModel = new AiVideoAutoLog();
         while (true){
         while (true){
             if($number > 5){
             if($number > 5){
+                echo date('Y-m-d H:i:s').':当前生成图片数量已达到最大限度。'.$number.PHP_EOL;
                 sleep(300);
                 sleep(300);
                 continue;
                 continue;
             }
             }
             $item = $aiVideoAutoLogModel->read(['status'=>0]);
             $item = $aiVideoAutoLogModel->read(['status'=>0]);
-            if(empty($info)){
+            if($item === false){
+                echo date('Y-m-d H:i:s').':无需生成图片的数据。'.PHP_EOL;
                 sleep(60);
                 sleep(60);
                 continue;
                 continue;
             }
             }
@@ -172,6 +177,73 @@ class AiVideoAutoPublish extends Command
     }
     }
 
 
     /**
     /**
+     * @remark :状态为1的数据推送至生成视频任务表
+     * @name   :auto_save_video_task
+     * @author :lyh
+     * @method :post
+     * @time   :2025/8/4 9:39
+     */
+    public function auto_save_video_task(){
+        $aiVideoAutoLogModel = new AiVideoAutoLog();
+        while (true){
+            //获取任务id
+            $task_id = $this->getAutoTaskId();
+            if(empty($task_id)){
+                sleep(300);
+                continue;
+            }
+            $info = $aiVideoAutoLogModel->read(['id'=>$task_id]);
+            if($info === false){
+                echo date('Y-m-d H:i:s').':当前数据不存在或已被删除'.$task_id.PHP_EOL;
+                continue;
+            }
+            try {
+                $aiVideoTaskModel = new AiVideoTask();
+                $aiVideoService = new AiVideoService($info['project_id']);
+                $projectModel = new DeployOptimize();
+                $video_setting = $projectModel->getValue(['project_id'=>$info['project_id']],'video_setting');
+                $storage = $aiVideoTaskModel->videoSetting()[$video_setting ?? 1];
+                $result = $aiVideoService->createTask($info['title'],$info['remark'],$info['images'],[],$storage);
+                if($result['status'] == 200){
+                    $aiVideoTaskModel->addReturnId(['task_id'=>$result['data']['task_id'],'project_id'=>$info['project_id'],'storage'=>$storage]);
+                    ProjectServer::useProject($info['project_id']);
+                    $aiVideoModel = new AiVideo();
+                    $aiVideoModel->addReturnId(['title'=>$info['title'],'task_id'=>$result['data']['task_id'],'description'=>$info['remark'],'project_id'=>$info['project_id'],'images'=>json_encode($info['images'],true),'anchor'=>json_encode([],true)]);
+                    DB::disconnect('custom_mysql');
+                }
+            }catch (\Exception $e){
+                echo '错误信息：'.$e->getMessage().PHP_EOL;
+                continue;
+            }
+        }
+
+
+    }
+
+    /**
+     * @remark :火锅自动发布任务id
+     * @name   :getAutoTaskId
+     * @author :lyh
+     * @method :post
+     * @time   :2025/8/4 9:44
+     */
+    public function getAutoTaskId()
+    {
+        $task_id = Redis::rpop('auto_ai_video_task');
+        if (empty($task_id)) {
+            $aiVideoAutoLogModel = new AiVideoAutoLog();
+            $ids = $aiVideoAutoLogModel->formatQuery(['status'=>1])->pluck('id');
+            if(!empty($ids)){
+                foreach ($ids as $id) {
+                    Redis::lpush('auto_ai_video_task', $id);
+                }
+            }
+            $task_id = Redis::rpop('auto_ai_video_task');
+        }
+        return $task_id;
+    }
+
+    /**
      * @remark :
      * @remark :
      * @name   :getAiVideoParam
      * @name   :getAiVideoParam
      * @author :lyh
      * @author :lyh

@@ -24,6 +24,7 @@ use App\Models\Template\BTemplateMain;
 use App\Models\Template\TemplateTypeMain;
 use App\Models\Template\TemplateTypeMain;
 use App\Models\WebSetting\WebSetting;
 use App\Models\WebSetting\WebSetting;
 use App\Services\AiBlogService;
 use App\Services\AiBlogService;
+use App\Services\CosService;
 use App\Services\Geo\GeoService;
 use App\Services\Geo\GeoService;
 use App\Services\MidJourneyService;
 use App\Services\MidJourneyService;
 use App\Services\ProjectServer;
 use App\Services\ProjectServer;
@@ -47,10 +48,13 @@ class lyhDemo extends Command
     protected $description = '更新路由';
     protected $description = '更新路由';
 
 
     public function handle(){
     public function handle(){
-        $content = "{Introducing the cutting-edge product from Zhejiang Yuexiang Gas Technology Co., Ltd., the Bracket Gas Flowmeter. This innovative gas flowmeter is designed to provide accurate and reliable measurements for a wide range of industrial applications,Equipped with advanced technology and precision components, the Bracket Gas Flowmeter ensures exceptional performance and durability. It offers highly accurate gas flow readings, allowing users to closely monitor and control gas consumption in various processes. The meter's user-friendly interface displays real-time flow rates and totalized flow data, facilitating efficient and convenient data management,With its robust construction and corrosion-resistant materials, the Bracket Gas Flowmeter guarantees long-term reliability, even in harsh operating conditions. It is compatible with various gases such as natural gas, propane, and hydrogen, making it a versatile choice for multiple industries including oil and gas, chemical, and manufacturing,Furthermore, the Bracket Gas Flowmeter is engineered with ease of installation and maintenance in mind. Its compact and space-saving design allows for flexible mounting options, while its modular construction enables quick and hassle-free maintenance. Additionally, it meets international standards for accuracy and safety, ensuring compliance with industry regulations,Choose the Bracket Gas Flowmeter for precise and efficient gas flow measurement, backed by the expertise and commitment of Zhejiang Yuexiang Gas Technology Co., Ltd}，{Shop Quality Brackets: Top China Products & Services for Your Needs}，4K，高清 --no logo --ar 16:9";
-        $midJourneyService = new MidJourneyService();
-        $result = $midJourneyService->imagine($content);
-        dd($result);
+//        $content = "{Introducing the cutting-edge product from Zhejiang Yuexiang Gas Technology Co., Ltd., the Bracket Gas Flowmeter. This innovative gas flowmeter is designed to provide accurate and reliable measurements for a wide range of industrial applications,Equipped with advanced technology and precision components, the Bracket Gas Flowmeter ensures exceptional performance and durability. It offers highly accurate gas flow readings, allowing users to closely monitor and control gas consumption in various processes. The meter's user-friendly interface displays real-time flow rates and totalized flow data, facilitating efficient and convenient data management,With its robust construction and corrosion-resistant materials, the Bracket Gas Flowmeter guarantees long-term reliability, even in harsh operating conditions. It is compatible with various gases such as natural gas, propane, and hydrogen, making it a versatile choice for multiple industries including oil and gas, chemical, and manufacturing,Furthermore, the Bracket Gas Flowmeter is engineered with ease of installation and maintenance in mind. Its compact and space-saving design allows for flexible mounting options, while its modular construction enables quick and hassle-free maintenance. Additionally, it meets international standards for accuracy and safety, ensuring compliance with industry regulations,Choose the Bracket Gas Flowmeter for precise and efficient gas flow measurement, backed by the expertise and commitment of Zhejiang Yuexiang Gas Technology Co., Ltd}，{Shop Quality Brackets: Top China Products & Services for Your Needs}，4K，高清 --no logo --ar 16:9";
+//        $midJourneyService = new MidJourneyService();
+//        $result = $midJourneyService->imagine($content);
+        $url = 'https://ecdn6-nc.globalso.com/upload/p/1/png/2025-08/688dcebc26a7a59911.png';
+        $cosService = new CosService();
+        $data = $cosService->cropAndUploadToCOS($url);
+        dd($data);
     }
     }
 
 
     /**
     /**

@@ -11,6 +11,9 @@ namespace App\Http\Controllers\Api;
 
 
 use App\Enums\Common\Code;
 use App\Enums\Common\Code;
 use App\Models\Project\AiVideoAutoLog;
 use App\Models\Project\AiVideoAutoLog;
+use App\Services\CosService;
+use Illuminate\Support\Facades\Log;
+use Illuminate\Support\Facades\Redis;
 
 
 class AiVideoController extends BaseController
 class AiVideoController extends BaseController
 {
 {
@@ -22,10 +25,43 @@ class AiVideoController extends BaseController
      * @time   :2025/8/2 11:19
      * @time   :2025/8/2 11:19
      */
      */
     public function ImageCallBack(){
     public function ImageCallBack(){
-        $data = $this->param;
-        @file_put_contents(storage_path('logs/lyh_error.log'), var_export($data, true) . PHP_EOL, FILE_APPEND);
-//        $aiVideoAutoLogModel = new AiVideoAutoLog();
-//        $aiVideoAutoLogModel->edit(['result'=>$data],['trigger_id'=>$data['trigger_id']]);
+        $count = Redis::decr('ai_video_image');
+        if ($count < 0) {
+            Redis::set('ai_video_image', 0);
+        }
+        $data = $this->param['attachments'] ?? [];
+        $aiVideoAutoLogModel = new AiVideoAutoLog();
+        if(empty($data) || empty($data['url'])){
+            $aiVideoAutoLogModel->edit(['status'=>9,'result'=>json_encode($this->param,true)],['trigger_id'=>$this->param['id']]);
+        }
+        //获取当前数据详情
+        $info = $aiVideoAutoLogModel->read(['trigger_id'=>$this->param['id']]);
+        if($info === false){
+            Log::channel('ai_video')->info('当前数据不存在或已被删除'.$this->param['id']);
+        }
+        //上传图片  返回cdn链接
+        $cosService = new CosService();
+        $imagePath = $cosService->uploadRemote($info['project_id'],'video',$data['url']);
+        try {
+            if($imagePath){
+                $cos = config('filesystems.disks.cos');
+                $url = $cos['cdn1'].'/'.$imagePath;
+                //裁剪图片为4张
+                $images = [];
+                $cosService = new CosService();
+                $data = $cosService->cropAndUploadToCOS($url);
+                if(!empty($data)){
+                    foreach ($data as $item){
+                        $images[] = ['url'=>$item,'alt'=>''];
+                    }
+                }
+                $images = array_merge($images,$info['images']);
+                Log::channel('ai_video')->info('图片：'.json_encode($images));
+                $aiVideoAutoLogModel->edit(['images'=>$images,'result'=>json_encode($this->param,true),'status'=>1],['id'=>$info['id']]);
+            }
+        }catch (\Exception $e){
+            Log::channel('ai_video')->info('上传图片失败'.$e->getMessage());
+        }
         $this->response('success');
         $this->response('success');
     }
     }
 }
 }

@@ -130,7 +130,6 @@ class CosService
                 'secretKey' => $cos['credentials']['secretKey'],
                 'secretKey' => $cos['credentials']['secretKey'],
             ],
             ],
         ]);
         ]);
-
         if(empty($body_str)){
         if(empty($body_str)){
             try {
             try {
                 $body_str = curl_c($file_url,false);
                 $body_str = curl_c($file_url,false);
@@ -145,7 +144,6 @@ class CosService
         if(!$body_str){
         if(!$body_str){
             return '';
             return '';
         }
         }
-
         try {
         try {
             $cosClient->putObject([
             $cosClient->putObject([
                 'Bucket' => $cos['bucket'],
                 'Bucket' => $cos['bucket'],
@@ -377,4 +375,77 @@ class CosService
         }
         }
         return [];
         return [];
     }
     }
+
+    /**
+     * @remark :ai_video裁剪图片为4张
+     * @name   :cropAndUploadToCOS
+     * @author :lyh
+     * @method :post
+     * @time   :2025/8/2 16:52
+     */
+    public function cropAndUploadToCOS($imageUrl)
+    {
+        // 1. 下载远程图片内容
+        $imageData = file_get_contents($imageUrl);
+        if (!$imageData) {
+            return false;
+        }
+        // 2. 保存原图到临时文件
+        $tempOriginal = tempnam(sys_get_temp_dir(), 'original_') . '.png';
+        file_put_contents($tempOriginal, $imageData);
+        // 3. 使用 GD 加载图像
+        $src = imagecreatefrompng($tempOriginal);
+        if (!$src) {
+            return false;
+        }
+        $width = imagesx($src);
+        $height = imagesy($src);
+        $halfWidth = intval($width / 2);
+        $halfHeight = intval($height / 2);
+        // 4. 从原图 URL 提取路径信息
+        $parsed = parse_url($imageUrl);
+        $pathInfo = pathinfo($parsed['path']); // upload/p/1/png/2025-08/688dcebc26a7a59911.png
+        $cosPath = ltrim($pathInfo['dirname'], '/'); // 相对路径：upload/p/1/png/2025-08
+        $baseName = $pathInfo['filename'];           // 文件名：688dcebc26a7a59911
+        $ext = $pathInfo['extension'] ?? 'png';      // 扩展名
+        // 5. 初始化 COS 客户端
+        $cos = config('filesystems.disks.cos');
+        $cosClient = new Client([
+            'region' => $cos['region'],
+            'credentials' => [
+                'secretId' => $cos['credentials']['secretId'],
+                'secretKey' => $cos['credentials']['secretKey'],
+            ],
+        ]);
+        // 6. 循环裁剪并上传
+        $resultPaths = [];
+        $index = 0;
+        $cos = config('filesystems.disks.cos');
+
+        for ($y = 0; $y < 2; $y++) {
+            for ($x = 0; $x < 2; $x++) {
+                $crop = imagecreatetruecolor($halfWidth, $halfHeight);
+                imagecopy($crop, $src, 0, 0, $x * $halfWidth, $y * $halfHeight, $halfWidth, $halfHeight);
+                $tempCropped = tempnam(sys_get_temp_dir(), 'crop_') . '.png';
+                imagepng($crop, $tempCropped);
+                imagedestroy($crop);
+                // 新文件名，保持路径不变
+                $filename = $baseName . '_part' . $index++ . '.' . $ext;
+                $objectKey = $cosPath . '/' . $filename;
+                // 上传到 COS
+                $cosClient->putObject([
+                    'Bucket' => $cos['bucket'],
+                    'Key' => $objectKey,
+                    'Body' => fopen($tempCropped, 'rb'),
+                ]);
+                // 返回相对路径
+                $resultPaths[] = $cos['cdn1'].'/'.$objectKey;
+                unlink($tempCropped);
+            }
+        }
+        // 清理资源
+        imagedestroy($src);
+        unlink($tempOriginal);
+        return $resultPaths; // 相对路径数组
+    }
 }
 }