gx处理数据

@@ -36,13 +36,23 @@ class AiDomainTask extends Command
     protected $description = '获取对应域名的ai复制站域名';
 
     public $url = 'https://www.cmer.site/api/globalso_site';
+
+    /**
+     * @remark :执行方法
+     * @name   :handle
+     * @author :lyh
+     * @method :post
+     * @time   :2025/6/19 11:32
+     */
     public function handle(){
-        $data = [];
         $pageSize = 100;
         $page = 1;
-        $domainInfoModel = new DomainInfo();
         $res = http_get($this->url.'?pagesize='.$pageSize.'&page='.$page);
         if($res['status'] != 200){
+            echo date('Y-m-d H:i:s').'请求失败，状态码错误';
+            return false;
+        }
+        if(empty($res['data']['data'])){
             echo date('Y-m-d H:i:s').'请求失败，未拉取到数据';
             return false;
         }
@@ -56,6 +66,31 @@ class AiDomainTask extends Command
             $data = array_values(array_merge($data,$res['data']['data']));
             $page++;
         }
-        dd($data);
+        //处理数据
+        $this->handleData($data);
+        return true;
+    }
+
+    /**
+     * @remark :处理数据
+     * @name   :handleData
+     * @author :lyh
+     * @method :post
+     * @time   :2025/6/19 11:21
+     */
+    public function handleData($data){
+        $domainInfoModel = new DomainInfo();
+        foreach ($data as $item){
+            $info = $domainInfoModel->read(['domain'=>$item['domain']],'id');
+            if($info === false){
+                $info = $domainInfoModel->read(['domain'=>$item['globalso_domain']],'id');
+                if($info !== false){
+                    $domainInfoModel->edit(['ai_domain'=>$item['domain']],['id'=>$info['id']]);
+                }
+            }else{
+                $domainInfoModel->edit(['ai_domain'=>$item['globalso_domain']],['id'=>$info['id']]);
+            }
+        }
+        return true;
     }
 }